From 002dad83de409449f2c356f33f54f13dbed28527 Mon Sep 17 00:00:00 2001 From: 彭雪彬 <1724387007@qq.com> Date: Tue, 15 Jul 2025 18:30:59 +0800 Subject: [PATCH] 骑手完成订单配送 --- oying-system/src/main/java/com/oying/modules/rider/utils/RiderSourceHttpUtils.java | 2 oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderOrderRecordServiceImpl.java | 84 ++++++++++++++++++++++++--- oying-system/src/main/java/com/oying/modules/rider/domain/RiderIncomeDetail.java | 4 oying-common/src/main/java/com/oying/utils/DateUtil.java | 17 +++++ oying-system/src/main/java/com/oying/modules/rider/domain/vo/OrderRiderOperationVo.java | 2 oying-system/src/main/java/com/oying/modules/rider/service/RiderOrderRecordService.java | 2 oying-system/src/main/java/com/oying/modules/rider/utils/Constants.java | 12 ++++ oying-system/src/main/java/com/oying/modules/rider/rest/WxRiderController.java | 26 ++++---- oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderInfoServiceImpl.java | 9 ++ oying-system/src/main/java/com/oying/modules/security/rest/AuthController.java | 6 ++ 10 files changed, 136 insertions(+), 28 deletions(-) diff --git a/oying-common/src/main/java/com/oying/utils/DateUtil.java b/oying-common/src/main/java/com/oying/utils/DateUtil.java index 1ab0205..d74db88 100644 --- a/oying-common/src/main/java/com/oying/utils/DateUtil.java +++ b/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 / diff --git a/oying-system/src/main/java/com/oying/modules/rider/domain/RiderIncomeDetail.java b/oying-system/src/main/java/com/oying/modules/rider/domain/RiderIncomeDetail.java index a3fd5e5..16f1a54 100644 --- a/oying-system/src/main/java/com/oying/modules/rider/domain/RiderIncomeDetail.java +++ b/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-已取消") diff --git a/oying-system/src/main/java/com/oying/modules/rider/domain/vo/OrderRiderOperationVo.java b/oying-system/src/main/java/com/oying/modules/rider/domain/vo/OrderRiderOperationVo.java index e766bce..a6861f1 100644 --- a/oying-system/src/main/java/com/oying/modules/rider/domain/vo/OrderRiderOperationVo.java +++ b/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; } diff --git a/oying-system/src/main/java/com/oying/modules/rider/rest/WxRiderController.java b/oying-system/src/main/java/com/oying/modules/rider/rest/WxRiderController.java index c7ba1d3..cba6827 100644 --- a/oying-system/src/main/java/com/oying/modules/rider/rest/WxRiderController.java +++ b/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("")) { @@ -117,19 +117,19 @@ @GetMapping("riderCompleteOrder/{orderNum}") @ApiOperation("骑手订单已送达") - @PreAuthorize("@el.check('riderOrderRecord:list')") + // @PreAuthorize("@el.check('riderOrderRecord:list')") public ResponseEntity<?> riderCompleteOrder(@PathVariable String orderNum) { // 订单号不能为空 if (orderNum == null || orderNum.equals("")) { return ResponseEntity.ok(R.fail(Constants.HTTP_CODE_FAIL, "订单号不能为空")); } - R result = riderOrderRecordService.riderCancelOrder(orderNum); + 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("")) { diff --git a/oying-system/src/main/java/com/oying/modules/rider/service/RiderOrderRecordService.java b/oying-system/src/main/java/com/oying/modules/rider/service/RiderOrderRecordService.java index b7e36e8..67c9d43 100644 --- a/oying-system/src/main/java/com/oying/modules/rider/service/RiderOrderRecordService.java +++ b/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); } diff --git a/oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderInfoServiceImpl.java b/oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderInfoServiceImpl.java index 26ed831..a3d6291 100644 --- a/oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderInfoServiceImpl.java +++ b/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); diff --git a/oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderOrderRecordServiceImpl.java b/oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderOrderRecordServiceImpl.java index 4065fe9..bb45c60 100644 --- a/oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderOrderRecordServiceImpl.java +++ b/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,12 @@ 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.新增订单接单流程信息 + // 2.新增订单接单流程信息 骑手接单流程新增 + orderService.operationLog(orderResponse, OrderStatusEnum.THREE); // 返回成功信息 return R.success(orderResponse, "接单成功"); } catch (Exception e) { @@ -195,7 +207,6 @@ create(riderOrderRecord); } - @Override public R riderCancelOrder(String orderNum) { // 查询当前订单信息 @@ -209,12 +220,65 @@ @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); + updateRiderOrderStatus(orderRiderOperationVo.getOrderNum(), Constants.ORDER_STATUS_StORE); + orderResponse.getOrder().setOrderStatus(OrderStatusEnum.FIVE.getKey()); + } else { + // 添加订单操作记录 取货配送 OperationType=2 + orderService.operationLog(orderResponse, OrderStatusEnum.SIX); + 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); + // 修改骑手端的订单状态 + 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("待完善"); + riderIncomeDetail.setEndAddress("待完善"); + riderIncomeDetailService.save(riderIncomeDetail); + return R.success(orderResponse); + } + + + } diff --git a/oying-system/src/main/java/com/oying/modules/rider/utils/Constants.java b/oying-system/src/main/java/com/oying/modules/rider/utils/Constants.java index 04da98c..af9f5c5 100644 --- a/oying-system/src/main/java/com/oying/modules/rider/utils/Constants.java +++ b/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"; } diff --git a/oying-system/src/main/java/com/oying/modules/rider/utils/RiderSourceHttpUtils.java b/oying-system/src/main/java/com/oying/modules/rider/utils/RiderSourceHttpUtils.java index 191cbda..346d4ed 100644 --- a/oying-system/src/main/java/com/oying/modules/rider/utils/RiderSourceHttpUtils.java +++ b/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); diff --git a/oying-system/src/main/java/com/oying/modules/security/rest/AuthController.java b/oying-system/src/main/java/com/oying/modules/security/rest/AuthController.java index c35e3d6..5ce08d2 100644 --- a/oying-system/src/main/java/com/oying/modules/security/rest/AuthController.java +++ b/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("账号密码登录") @@ -274,6 +277,8 @@ } // 获取用户信息 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); // 生成令牌 @@ -282,6 +287,7 @@ Map<String, Object> authInfo = new HashMap<String, Object>(2) {{ put("token", properties.getTokenStartWith() + token); put("user", jwtUser); + put("rider", riderInfo); }}; if (loginProperties.isSingleLogin()) { // 踢掉之前已经登录的token -- Gitblit v1.9.3