oying-common/src/main/java/com/oying/utils/DateUtil.java
@@ -15,6 +15,7 @@ public static final DateTimeFormatter DFY_MD_HMS = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); public static final DateTimeFormatter DFY_MD = DateTimeFormatter.ofPattern("yyyy-MM-dd"); public static final DateTimeFormatter DFY_M = DateTimeFormatter.ofPattern("yyyy-MM"); public static final DateTimeFormatter SDF_YMDHMS = DateTimeFormatter.ofPattern("yyyyMMddHHmmss"); /** @@ -126,6 +127,22 @@ } /** * 获取当前时间yyyyMMdd * @return 、yyyyMMdd */ public static String getNowTimeTypeYYYYMMDD() { return DFY_MD.format(LocalDateTime.now()); } /** * 获取当前时间yyyyMM * @return 、yyyyMM */ public static String getNowTimeTypeYYYYMM() { return DFY_M.format(LocalDateTime.now()); } /** * 日期格式化 yyyy-MM-dd * * @param localDateTime / oying-system/src/main/java/com/oying/modules/rider/domain/RiderIncomeDetail.java
@@ -48,10 +48,10 @@ @ApiModelProperty(value = "收入类型：1-配送费，2-奖励，3-补贴") private String incomeType; @ApiModelProperty(value = "收入日期(YYYY-MM-dd)方便统计") @ApiModelProperty(value = "收入日期(YYYYMMdd)方便统计") private String incomeDate; @ApiModelProperty(value = "收入月份YYYY-MM") @ApiModelProperty(value = "收入月份YYYYMM") private String incomeMonth; @ApiModelProperty(value = "订单状态：1-待取货，2-配送中，3-已完成，4-已取消") oying-system/src/main/java/com/oying/modules/rider/domain/vo/OrderRiderOperationVo.java
@@ -25,7 +25,7 @@ @ApiModelProperty(value = "订单号") private String orderNum; @ApiModelProperty(value = "骑手操作类型 1-上报到店 2-上报已取商品") @ApiModelProperty(value = "骑手操作类型 1-上报到店 2-取货配送") private String operationType; } oying-system/src/main/java/com/oying/modules/rider/rest/WxRiderController.java
@@ -41,7 +41,7 @@ @GetMapping("getRiderSourceInfo/{riderId}") @ApiOperation("查询第三方数据骑手信息") @PreAuthorize("@el.check('riderInfo:list')") // @PreAuthorize("@el.check('riderInfo:list')") public ResponseEntity<?> getRiderSourceInfo(@PathVariable Long riderId) { RiderInfo riderInfo = riderInfoService.getRiderSourceInfo(riderId); return ResponseEntity.ok(R.success(riderInfo)); @@ -49,15 +49,15 @@ @GetMapping("syncRiderSourceInfo/{sourcePlatform}") @ApiOperation("同步查询第三方骑手信息 LY") @PreAuthorize("@el.check('riderInfo:edit')") // @PreAuthorize("@el.check('riderInfo:edit')") public ResponseEntity<?> syncRiderSourceInfo(@PathVariable String sourcePlatform) { riderInfoService.syncRiderSourceInfo(sourcePlatform); return ResponseEntity.ok(R.success()); return ResponseEntity.ok(R.success("操作成功")); } @GetMapping("getRiderWalletInfo/{riderId}") @ApiOperation("查询骑手钱包信息") @PreAuthorize("@el.check('riderWalletInfo:list')") // @PreAuthorize("@el.check('riderWalletInfo:list')") public ResponseEntity<?> getRiderWalletInfo(@PathVariable String riderId) { RiderWalletInfo riderWalletInfo = riderWalletInfoService.getRiderWalletInfo(riderId); return ResponseEntity.ok(R.success(riderWalletInfo)); @@ -65,7 +65,7 @@ @GetMapping("getRiderIncomeDetail") @ApiOperation("查询骑手订单收入明细分页") @PreAuthorize("@el.check('riderIncomeDetail:list')") // @PreAuthorize("@el.check('riderIncomeDetail:list')") public ResponseEntity<?> getRiderIncomeDetail(RiderIncomeDetailQueryCriteria criteria) { Page<Object> page = new Page<>(criteria.getPage(), criteria.getSize()); PageResult<RiderIncomeDetail> riderIncomeDetails = riderIncomeDetailService.queryAll(criteria, page); @@ -74,7 +74,7 @@ @GetMapping("getRiderWithdrawalRecord") @ApiOperation("查询骑手提现记录分页") @PreAuthorize("@el.check('riderWithdrawalRecord:list')") // @PreAuthorize("@el.check('riderWithdrawalRecord:list')") public ResponseEntity<?> getRiderWithdrawalRecord(RiderWithdrawalRecordQueryCriteria criteria) { Page<Object> page = new Page<>(criteria.getPage(), criteria.getSize()); PageResult<RiderWithdrawalRecord> riderIncomeDetails = riderWithdrawalRecordService.queryAll(criteria, page); @@ -83,7 +83,7 @@ @GetMapping("getRiderOrderRecord") @ApiOperation("查询骑手订单记录分页") @PreAuthorize("@el.check('riderOrderRecord:list')") // @PreAuthorize("@el.check('riderOrderRecord:list')") public ResponseEntity<?> getRiderOrderRecord(RiderOrderRecordQueryCriteria criteria) { Page<Object> page = new Page<>(criteria.getPage(), criteria.getSize()); PageResult<RiderOrderRecord> riderOrderRecordPageResult = riderOrderRecordService.queryAll(criteria, page); @@ -93,7 +93,7 @@ @GetMapping("riderGrabOrder/{orderNum}") @ApiOperation("骑手接单") @PreAuthorize("@el.check('riderOrderRecord:list')") // @PreAuthorize("@el.check('riderOrderRecord:list')") public ResponseEntity<?> riderGrabOrder(@PathVariable String orderNum) { // 订单号不能为空 if (orderNum == null || orderNum.equals("")) { @@ -105,7 +105,7 @@ @GetMapping("riderCancelOrder/{orderNum}") @ApiOperation("骑手取消接单") @PreAuthorize("@el.check('riderOrderRecord:list')") // @PreAuthorize("@el.check('riderOrderRecord:list')") public ResponseEntity<?> riderCancelOrder(@PathVariable String orderNum) { // 订单号不能为空 if (orderNum == null || orderNum.equals("")) { @@ -115,21 +115,21 @@ return ResponseEntity.ok(R.success(result)); } // @GetMapping("riderCancelOrder/{orderNum}") // @ApiOperation("骑手订单已送达") @GetMapping("riderCompleteOrder/{orderNum}") @ApiOperation("骑手订单已送达") // @PreAuthorize("@el.check('riderOrderRecord:list')") // public ResponseEntity<?> riderCancelOrder(@PathVariable String orderNum) { // // 订单号不能为空 // if (orderNum == null || orderNum.equals("")) { // return ResponseEntity.ok(R.fail(Constants.HTTP_CODE_FAIL, "订单号不能为空")); // } // R result = riderOrderRecordService.riderCancelOrder(orderNum); // return ResponseEntity.ok(R.success(result)); // } public ResponseEntity<?> riderCompleteOrder(@PathVariable String orderNum) { // 订单号不能为空 if (orderNum == null || orderNum.equals("")) { return ResponseEntity.ok(R.fail(Constants.HTTP_CODE_FAIL, "订单号不能为空")); } R result = riderOrderRecordService.riderCompleteOrder(orderNum); return ResponseEntity.ok(R.success(result)); } @GetMapping("riderOperationOrder") @ApiOperation("骑手上报到店") @PreAuthorize("@el.check('riderOrderRecord:list')") @ApiOperation("骑手上报到店/取货配送") // @PreAuthorize("@el.check('riderOrderRecord:list')") public ResponseEntity<?> riderOperationOrder(OrderRiderOperationVo orderRiderOperation) { // 订单号不能为空 if (orderRiderOperation.getOrderNum() == null || orderRiderOperation.getOrderNum().equals("")) { @@ -138,17 +138,5 @@ R result = riderOrderRecordService.riderOperationOrder(orderRiderOperation); return ResponseEntity.ok(R.success(result)); } // @GetMapping("riderCancelOrder/{orderNum}") // @ApiOperation("骑手已取餐") // @PreAuthorize("@el.check('riderOrderRecord:list')") // public ResponseEntity<?> riderCancelOrder(@PathVariable String orderNum) { // // 订单号不能为空 // if (orderNum == null || orderNum.equals("")) { // return ResponseEntity.ok(R.fail(Constants.HTTP_CODE_FAIL, "订单号不能为空")); // } // R result = riderOrderRecordService.riderCancelOrder(orderNum); // return ResponseEntity.ok(R.success(result)); // } } oying-system/src/main/java/com/oying/modules/rider/service/RiderOrderRecordService.java
@@ -87,4 +87,6 @@ * @throws IOException / */ R riderOperationOrder(OrderRiderOperationVo orderRiderOperation); R riderCompleteOrder(String orderNum); } oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderInfoServiceImpl.java
@@ -10,6 +10,8 @@ import com.oying.modules.rider.service.RiderWalletInfoService; import com.oying.modules.rider.utils.Constants; import com.oying.modules.rider.utils.RiderSourceHttpUtils; import com.oying.modules.system.domain.User; import com.oying.modules.system.service.UserService; import com.oying.utils.FileUtil; import com.oying.utils.SecurityUtils; import lombok.RequiredArgsConstructor; @@ -39,8 +41,8 @@ public class RiderInfoServiceImpl extends ServiceImpl<RiderInfoMapper, RiderInfo> implements RiderInfoService { private final RiderInfoMapper riderInfoMapper; private final RiderWalletInfoService riderWalletInfoService; private final UserService userService; @Override public PageResult<RiderInfo> queryAll(RiderInfoQueryCriteria criteria, Page<Object> page) { @@ -118,6 +120,11 @@ newRiderInfo.setRiderId(riderId); newRiderInfo.setSourcePlatform(sourcePlatform); create(newRiderInfo); // 覆盖骑手账号昵称信息 User user = new User(); user.setId(riderId); user.setNickName(infoHttpData.getCardName()); userService.updateById(user); // 创建骑手钱包信息 正常 RiderWalletInfo riderWalletInfo = new RiderWalletInfo(); riderWalletInfo.setRiderId(riderId); oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderOrderRecordServiceImpl.java
@@ -5,14 +5,20 @@ import com.oying.exception.BadRequestException; import com.oying.modules.pc.store.domain.Store; import com.oying.modules.pc.store.service.StoreService; import com.oying.modules.rider.domain.RiderIncomeDetail; import com.oying.modules.rider.domain.RiderInfo; import com.oying.modules.rider.domain.RiderOrderRecord; import com.oying.modules.rider.domain.RiderWalletInfo; import com.oying.modules.rider.domain.vo.OrderRiderOperationVo; import com.oying.modules.rider.service.RiderIncomeDetailService; import com.oying.modules.rider.service.RiderInfoService; import com.oying.modules.rider.service.RiderWalletInfoService; import com.oying.modules.rider.utils.Constants; import com.oying.modules.sh.domain.Order; import com.oying.modules.sh.domain.vo.OrderResponse; import com.oying.modules.sh.service.OrderService; import com.oying.utils.*; import com.oying.utils.enums.OrderStatusEnum; import lombok.RequiredArgsConstructor; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -44,6 +50,8 @@ private final OrderService orderService; private final RiderInfoService riderInfoService; private final StoreService storeService; private final RiderWalletInfoService riderWalletInfoService; private final RiderIncomeDetailService riderIncomeDetailService; @Override public PageResult<RiderOrderRecord> queryAll(RiderOrderRecordQueryCriteria criteria, Page<Object> page) { @@ -119,6 +127,12 @@ @Override @Transactional(rollbackFor = Exception.class) public R riderGrabOrder(String orderNum) { Long riderId = SecurityUtils.getCurrentUserId(); // 查询骑手信息 RiderInfo riderInfo = riderInfoService.getRiderSourceInfo(riderId); if (riderInfo == null || riderInfo.getEnabled().equals(Constants.SOURCE_ENABLED_DFF)) { return R.fail(400, "骑手信息不存在或已过期"); } // 唯一标识当前线程/客户端 String clientId = UUID.randomUUID().toString(); // Redis 锁 key @@ -136,14 +150,10 @@ return R.fail(400, "订单已经被其他骑手接单或顾客取消，请稍后重试"); } // 订单没有被接单或取消的情况下，进行接单操作 // 查询骑手信息 Long riderId = SecurityUtils.getCurrentUserId(); RiderInfo riderInfo = riderInfoService.getRiderSourceInfo(riderId); // 查询商家信息 Store store = storeService.getById(orderResponse.getOrder().getStoreId()); // 1.新增骑手接单记录 addRiderOrderRecord(riderInfo, orderResponse, store); // 2.新增订单接单流程信息 addRiderOrderRecord(riderInfo, orderResponse); // 2.新增订单接单流程信息 骑手接单流程新增 orderService.operationLog(orderResponse, OrderStatusEnum.THREE, riderInfo.getCardName()); // 返回成功信息 return R.success(orderResponse, "接单成功"); } catch (Exception e) { @@ -164,13 +174,13 @@ * * @Date: 2025/7/14 17:48 */ public void addRiderOrderRecord(RiderInfo riderInfo, OrderResponse orderResponse, Store store) { public void addRiderOrderRecord(RiderInfo riderInfo, OrderResponse orderResponse) { RiderOrderRecord riderOrderRecord = new RiderOrderRecord(); riderOrderRecord.setOrderId(orderResponse.getOrder().getOrderId()); riderOrderRecord.setOrderNum(orderResponse.getOrder().getOrderNum()); riderOrderRecord.setMerchantId(orderResponse.getOrder().getStoreId()); riderOrderRecord.setMerchantName(orderResponse.getOrder().getStoreName()); riderOrderRecord.setMerchantAddress(store.getAddress()); riderOrderRecord.setMerchantAddress(orderResponse.getOrder().getStoreAddress()); riderOrderRecord.setReceiverAddress(orderResponse.getAddress().getDetail()); // 当前为接单 设置为待取货状态 0-已接单 1-已到店 2-配送中 3-已完成 4-商家取消 5-骑手取消 6-客户取消 7-系统取消 riderOrderRecord.setOrderStatus(Constants.ORDER_STATUS_OK); @@ -187,14 +197,13 @@ riderOrderRecord.setUserId(orderResponse.getOrder().getUserId()); riderOrderRecord.setUserLongitude(String.valueOf(orderResponse.getAddress().getLongitude())); riderOrderRecord.setUserLatitude(String.valueOf(orderResponse.getAddress().getLatitude())); riderOrderRecord.setMerchantLongitude(String.valueOf(store.getLongitude())); riderOrderRecord.setMerchantLatitude(String.valueOf(store.getLatitude())); riderOrderRecord.setMerchantLongitude(String.valueOf(orderResponse.getOrder().getStoreLongitude())); riderOrderRecord.setMerchantLatitude(String.valueOf(orderResponse.getOrder().getStoreLatitude())); // 配送费详情Id // riderOrderRecord.setDeliveryFeeId(orderResponse.getOrder().getDeliveryFeeId()); riderOrderRecord.setOrderIncome(orderResponse.getOrder().getSendPrice()); create(riderOrderRecord); } @Override public R riderCancelOrder(String orderNum) { @@ -209,12 +218,63 @@ @Override @Transactional(rollbackFor = Exception.class) public R riderOperationOrder(OrderRiderOperationVo orderRiderOperationVo){ // 判断骑手操作类型 // 添加订单操作记录 public R riderOperationOrder(OrderRiderOperationVo orderRiderOperationVo) { OrderResponse orderResponse = orderService.getByOrderNum(orderRiderOperationVo.getOrderNum()); // 判断骑手操作类型 上报到店操作 OperationType=1 if (orderRiderOperationVo.getOperationType().equals(Constants.ORDER_OPERATION_TYPE_STORE)) { // 添加订单操作记录 上报到店操作1 orderService.operationLog(orderResponse, OrderStatusEnum.FIVE, orderResponse.getOrder().getRiderName()); updateRiderOrderStatus(orderRiderOperationVo.getOrderNum(), Constants.ORDER_STATUS_StORE); orderResponse.getOrder().setOrderStatus(OrderStatusEnum.FIVE.getKey()); } else { // 添加订单操作记录 取货配送 OperationType=2 orderService.operationLog(orderResponse, OrderStatusEnum.SIX, orderResponse.getOrder().getRiderName()); updateRiderOrderStatus(orderRiderOperationVo.getOrderNum(), Constants.ORDER_STATUS_DELIVERY); orderResponse.getOrder().setOrderStatus(OrderStatusEnum.SIX.getKey()); } // 修改骑手端的订单状态 updateRiderOrderStatus(orderRiderOperationVo.getOrderNum(), Constants.ORDER_STATUS_StORE); return R.success(); return R.success(orderResponse); } @Override public R riderCompleteOrder(String orderNum) { // 当前订单信息 OrderResponse orderResponse = orderService.getByOrderNum(orderNum); Order order = orderResponse.getOrder(); // 添加订单操作记录 订单完成 orderService.operationLog(orderResponse, OrderStatusEnum.SEVEN, orderResponse.getOrder().getRiderName()); // 修改骑手端的订单状态 updateRiderOrderStatus(orderNum, Constants.ORDER_STATUS_FINISH); // 返回参数 orderResponse.getOrder().setOrderStatus(OrderStatusEnum.SEVEN.getKey()); // 查询骑手钱包信息 RiderWalletInfo riderWalletInfo = riderWalletInfoService.getRiderWalletInfo(String.valueOf(order.getRiderId())); // 修改骑手钱包信息 // 骑手总金额添加配送费 riderWalletInfo.setAmount(riderWalletInfo.getAmount().add(order.getSendPrice())); // 骑手可用余额添加配送费 riderWalletInfo.setAvailableBalance(riderWalletInfo.getAvailableBalance().add(order.getSendPrice())); // 添加累计收入添加配送费 riderWalletInfo.setIncomeTotal(riderWalletInfo.getIncomeTotal().add(order.getSendPrice())); // 完成总单数添加1 riderWalletInfo.setRunTotal(riderWalletInfo.getRunTotal() + 1); riderWalletInfoService.updateById(riderWalletInfo); // 添加骑手收入明细 RiderIncomeDetail riderIncomeDetail = new RiderIncomeDetail(); riderIncomeDetail.setRiderId(order.getRiderId()); riderIncomeDetail.setRiderName(order.getRiderName()); riderIncomeDetail.setRiderPhone(order.getRiderPhone()); riderIncomeDetail.setOrderId(order.getOrderId()); riderIncomeDetail.setOrderNum(order.getOrderNum()); riderIncomeDetail.setIncomeAmount(order.getSendPrice()); riderIncomeDetail.setIncomeType(Constants.INCOME_TYPE_DELIVERY); riderIncomeDetail.setIncomeDate(DateUtil.getNowTimeTypeYYYYMMDD()); riderIncomeDetail.setIncomeMonth(DateUtil.getNowTimeTypeYYYYMM()); riderIncomeDetail.setDeliveryTime(new Timestamp(System.currentTimeMillis())); riderIncomeDetail.setOrderStatus(Constants.ORDER_STATUS_FINISH); riderIncomeDetail.setStartAddress(orderResponse.getOrder().getStoreAddress()); riderIncomeDetail.setEndAddress(orderResponse.getAddress().getDetail()); riderIncomeDetailService.save(riderIncomeDetail); return R.success(orderResponse); } } oying-system/src/main/java/com/oying/modules/rider/utils/Constants.java
@@ -63,4 +63,16 @@ String ORDER_STATUS_CANCEL_RIDER = "5"; String ORDER_STATUS_CANCEL_CUSTOMER = "6"; String ORDER_STATUS_CANCEL_SYSTEM = "7"; /** * 订单操作类型：1-上报到店 2-取货配送 */ String ORDER_OPERATION_TYPE_STORE = "1"; String ORDER_OPERATION_TYPE_DELIVERY = "2"; /** * 收入类型：1-配送费，2-奖励，3-补贴 */ String INCOME_TYPE_DELIVERY = "1"; String INCOME_TYPE_REWARD = "2"; String INCOME_TYPE_SUBSIDY = "3"; } oying-system/src/main/java/com/oying/modules/rider/utils/RiderSourceHttpUtils.java
@@ -88,7 +88,7 @@ RiderSourceInfo riderSourceInfo = new RiderSourceInfo(); riderSourceInfo.setSourcePlatform("LY"); riderSourceInfo.setCardNum("123456789012345678"); riderSourceInfo.setPhone("15202394888"); riderSourceInfo.setPhone("18706999997"); riderSourceInfo.setCardName("张三"); riderSourceInfo.setEnabled(Constants.SOURCE_ENABLED_ON); riderSourceInfoHttp.setData(riderSourceInfo); oying-system/src/main/java/com/oying/modules/security/config/WeiXinProperties.java
@@ -12,6 +12,10 @@ private String appId; // APP密钥 private String appSecret; // 骑手小程序APPID private String riderAppId; // 骑手小程序密钥 private String riderAppSecret; // 跳转小程序类型 private String miniProgramState; /*access_token的KEY*/ oying-system/src/main/java/com/oying/modules/security/rest/AuthController.java
@@ -2,6 +2,8 @@ import cn.hutool.core.util.IdUtil; import com.alibaba.fastjson2.JSONObject; import com.oying.modules.rider.domain.RiderInfo; import com.oying.modules.rider.service.RiderInfoService; import com.oying.modules.security.config.CaptchaConfig; import com.oying.modules.security.config.LoginProperties; import com.oying.modules.security.config.SecurityProperties; @@ -67,6 +69,7 @@ private final WeiXinService weiXinService; private final UserService userService; private final DictDetailService dictDetailService; private final RiderInfoService riderInfoService; @Log("账号密码登录") @ApiOperation("账号密码登录") @@ -224,6 +227,78 @@ user1.setRoles(roles); } @Log("骑手小程序：微信授权登录") @ApiOperation("骑手小程序：微信授权登录") @AnonymousPostMapping(value = "/rider/login/weixin") public ResponseEntity<Object> riderLoginWeixin(@Validated @RequestBody AuthUserWeixinDto authUser, HttpServletRequest request) throws Exception { JSONObject jsonObject; switch (authUser.getType()) { case OLD: jsonObject = weiXinService.code2SessionRider(authUser.getCode()); String openid = jsonObject.getString("openid"); User userDto = userService.findByRiderOpenId(openid); if (userDto == null) { return ResponseEntity.ok(R.success(openid)); } authUser.setUsername(userDto.getUsername()); break; case NEW: jsonObject = weiXinService.getRiderPhoneNumber(authUser.getCode()); String phone = jsonObject.getJSONObject("phone_info").getString("purePhoneNumber"); User user1 = userService.findByName(phone); if (user1 == null) { //创建用户 User user = new User(); user.setUsername(phone); user.setNickName("OYING-" + phone); user.setUserType(ConstantsKey.BUYER); user.setPhone(phone); user.setGender("男"); user.setEnabled(true); getRole(user); user.setPassword(passwordEncoder.encode(phone.substring(phone.length() - 6))); user.setRiderOpenId(authUser.getUsername()); userService.create(user); } else { if (user1.getUserType().equals(ConstantsKey.BUYER)) { if (user1.getRoles() == null) { getRole(user1); } } user1.setRiderOpenId(authUser.getUsername()); // userService.update(user1); userService.updateRiderOpenId(user1); } authUser.setUsername(phone); break; default: throw new BadRequestException("登录类型错误"); } // 获取用户信息 JwtUserDto jwtUser = userDetailsService.loadUserByUsername(authUser.getUsername()); // 查询骑手信息 RiderInfo riderInfo = riderInfoService.getRiderSourceInfo(jwtUser.getUser().getId()); Authentication authentication = new UsernamePasswordAuthenticationToken(jwtUser, null, jwtUser.getAuthorities()); SecurityContextHolder.getContext().setAuthentication(authentication); // 生成令牌 String token = tokenProvider.createToken(jwtUser); // 返回 token 与 用户信息 Map<String, Object> authInfo = new HashMap<String, Object>(2) {{ put("token", properties.getTokenStartWith() + token); put("user", jwtUser); put("rider", riderInfo); }}; if (loginProperties.isSingleLogin()) { // 踢掉之前已经登录的token onlineUserService.kickOutForUsername(authUser.getUsername()); } // 保存在线信息 onlineUserService.save(jwtUser, token, request); // 返回登录信息 return ResponseEntity.ok(R.success(authInfo)); } @ApiOperation("临时授权") @AnonymousGetMapping(value = "/token") public ResponseEntity<Object> loginTest(@RequestParam String username, HttpServletRequest request) { oying-system/src/main/java/com/oying/modules/security/service/WeiXinService.java
@@ -59,6 +59,32 @@ } /** * POST 获取稳定版接口调用凭据 获取小程序全局唯一后台接口调用凭据，token有效期为7200s，开发者需要进行妥善保存。 * * @return accessToken */ public String getStableAccessTokenRider() { String TokenKey = weiXinProperties.getTokenKey() + "_rider"; String accessToken; if (redisUtils.isExpire(TokenKey)) { // 获取接口调用凭据 String url = weiXinProperties.getGetStableAccessToken(); Map<String, Object> map = new LinkedHashMap<>(); map.put("grant_type", "client_credential"); map.put("appid", weiXinProperties.getRiderAppId()); map.put("secret", weiXinProperties.getRiderAppSecret()); map.put("force_refresh", false); JSONObject jsonObject = HttpRequest.exchangeJsonObject(HttpMethod.POST, url, map); accessToken = jsonObject.getString("access_token"); redisUtils.set(TokenKey, accessToken, weiXinProperties.getTokenTime()); } else { // 查询接口调用凭据 accessToken = (String) redisUtils.get(TokenKey); } return accessToken; } /** * GET 小程序登录 登录凭证校验。通过 wx.login 接口获得临时登录凭证 code 后传到开发者服务器调用此接口完成登录流程 * * @param js_code 登录时获取的 code，可通过wx.login获取 @@ -72,6 +98,14 @@ return JSONObject.parseObject(HttpRequest.exchangeString(HttpMethod.GET, url, null)); } public JSONObject code2SessionRider(String js_code) { String url = weiXinProperties.getCode2Session(); url = url.replace("{appid}", weiXinProperties.getRiderAppId()) .replace("{secret}", weiXinProperties.getRiderAppSecret()) .replace("{js_code}", js_code); return JSONObject.parseObject(HttpRequest.exchangeString(HttpMethod.GET, url, null)); } /** * POST 获取手机号 该接口用于将code换取用户手机号。 说明，每个code只能使用一次，code的有效期为5min。 * @@ -87,6 +121,20 @@ } /** * POST 获取手机号 该接口用于将code换取用户手机号。 说明，每个code只能使用一次，code的有效期为5min。 * * @param code 手机号获取凭证 * @return JSONObject */ public JSONObject getRiderPhoneNumber(String code) { String url = weiXinProperties.getGetPhoneNumber(); url = url.replace("{accessToken}", getStableAccessTokenRider()); Map<String, Object> map = new LinkedHashMap<>(); map.put("code", code); return HttpRequest.exchangeJsonObject(HttpMethod.POST, url, map); } /** * POST 该接口用于发送订阅消息。 * * @param data 请求参数 oying-system/src/main/java/com/oying/modules/system/domain/User.java
@@ -77,6 +77,10 @@ @ApiModelProperty(value = "最后修改密码的时间", hidden = true) private Date pwdResetTime; @ApiModelProperty(value = "骑手openid") private String riderOpenId; @Override public boolean equals(Object o) { if (this == o) { oying-system/src/main/java/com/oying/modules/system/mapper/UserMapper.java
@@ -29,6 +29,8 @@ User findByOpenid(@Param("openid") String openid); User findByRiderOpenId(@Param("riderOpenId") String riderOpenId); User findByEmail(@Param("email") String email); User findByPhone(@Param("phone") String phone); @@ -48,4 +50,5 @@ int countByRoles(@Param("roleIds") Set<Long> roleIds); void resetPwd(@Param("userIds") Set<Long> userIds, @Param("pwd") String pwd); } oying-system/src/main/java/com/oying/modules/system/service/UserService.java
@@ -55,6 +55,8 @@ User findByOpenid(String openId); User findByRiderOpenId(String riderOpenId); /** * 根据用户名查询 * @param userName / @@ -120,4 +122,6 @@ * @param pwd 密码 */ void resetPwd(Set<Long> ids, String pwd); void updateRiderOpenId(User user1); } oying-system/src/main/java/com/oying/modules/system/service/impl/UserServiceImpl.java
@@ -174,6 +174,11 @@ } @Override public User findByRiderOpenId(String riderOpenId) { return userMapper.findByRiderOpenId(riderOpenId); } @Override public User getLoginData(String userName) { return userMapper.findByUsername(userName); } @@ -201,6 +206,14 @@ } @Override public void updateRiderOpenId(User user1) { User user = new User(); user.setId(user1.getId()); user.setRiderOpenId(user1.getRiderOpenId()); userMapper.updateById(user); } @Override @Transactional(rollbackFor = Exception.class) public Map<String, String> updateAvatar(MultipartFile multipartFile) { // 文件大小验证 oying-system/src/main/resources/config/application-dev.yml
@@ -132,6 +132,10 @@ app-id: wx2273296a5569cbad # AppSecret app-secret: 4526d72d885be322b17d0694cd6d03f1 # riderAppId rider-app-id: wxec131a77cbf47c7f # riderAppSecret rider-app-secret: 7fa3a13f1a894dfaba6fec4df4043135 # 跳转小程序类型 developer为开发版；trial为体验版；formal为正式版；默认为正式版 mini-program-state: trial # access_token的KEY oying-system/src/main/resources/config/application-prod.yml
@@ -143,6 +143,10 @@ app-id: wx2273296a5569cbad # AppSecret app-secret: 4526d72d885be322b17d0694cd6d03f1 # riderAppId rider-app-id: wxec131a77cbf47c7f # riderAppSecret rider-app-secret: 7fa3a13f1a894dfaba6fec4df4043135 # 跳转小程序类型 developer为开发版；trial为体验版；formal为正式版；默认为正式版 mini-program-state: trial # access_token的KEY oying-system/src/main/resources/mapper/system/UserMapper.xml
@@ -6,6 +6,7 @@ <result column="user_username" property="username"/> <result column="user_user_type" property="userType"/> <result column="user_openid" property="openid"/> <result column="user_rider_open_id" property="riderOpenId"/> <result column="user_nick_name" property="nickName"/> <result column="user_email" property="email"/> <result column="user_phone" property="phone"/> @@ -30,7 +31,7 @@ <sql id="Base_Column_List"> u.user_id as user_user_id, u.username as user_username, u.user_type as user_user_type,u.openid as user_openid, u.user_type as user_user_type,u.openid as user_openid,u.rider_open_id as user_rider_open_id, u.nick_name as user_nick_name, u.email as user_email, u.phone as user_phone, u.gender as user_gender, u.avatar_name as user_avatar_name, u.avatar_path as user_avatar_path, u.enabled as user_enabled, u.pwd_reset_time as user_pwd_reset_time, u.create_by as user_create_by, @@ -108,6 +109,14 @@ where u.openid = #{openid} </select> <select id="findByRiderOpenId" resultMap="BaseResultMap"> select u.password user_password, u.is_admin user_is_admin, <include refid="Base_Column_List"/> from sys_user u where u.rider_open_id = #{riderOpenId} </select> <select id="findByEmail" resultType="com.oying.modules.system.domain.User"> select user_id as id, username from sys_user where email = #{email}
