From 1a5f7432c404946f9ec358b5cb6281a823c466c1 Mon Sep 17 00:00:00 2001 From: luodangjia <luodangjia> Date: 星期二, 14 一月 2025 16:55:07 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java | 48 ++++++++++++++++++++++++++++++++---------------- 1 files changed, 32 insertions(+), 16 deletions(-) diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java index 4ac605c..6274b40 100644 --- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java +++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java @@ -177,14 +177,6 @@ } OrderDetailVO orderDetailVO = new OrderDetailVO(); orderDetailVO.setDistributionMode(order.getDistributionMode()); - Technician technician = new Technician(); - if (order.getTechnicianId() != null){ - R<Technician> shopdetail = technicianClient.shopdetail(order.getTechnicianId()); - if (shopdetail.getCode() != R.SUCCESS){ - throw new ServiceException("获取技师信息失败"); - } - technician = shopdetail.getData(); - } Shop shop = shopR.getData(); orderDetailVO.setId(order.getId()); orderDetailVO.setOrderStatus(order.getOrderStatus()); @@ -209,18 +201,19 @@ orderDetailVO.setLongitude(shop.getLongitude()); orderDetailVO.setLatitude(shop.getLatitude()); orderDetailVO.setShopId(shop.getId()); - orderDetailVO.setTechnicianName(technician.getName()); - orderDetailVO.setTechnicianId(technician.getId()); if(order.getOrderType() == 1){ List<TechnicianSubscribe> data = technicianSubscribeClient.getTechnicianSubscribeList(order.getId()).getData(); if(data.size() > 0){ Long id = data.get(0).getId(); orderDetailVO.setTechnicianSubscribeId(id.toString()); + Technician technician = technicianClient.shopdetail(order.getTechnicianId()).getData(); + orderDetailVO.setTechnicianName(technician.getName()); + orderDetailVO.setTechnicianId(technician.getId()); } } // 生成核销码BASE64 try { - String base64 = QRCodeGenerator.generateQRCodeBase64(order.getOrderNumber(), 124, 124); + String base64 = QRCodeGenerator.generateQRCodeBase64(String.valueOf(order.getId()), 124, 124); orderDetailVO.setWriteOffCode(base64); } catch (Exception e) { e.printStackTrace(); @@ -258,7 +251,7 @@ @Override @Transactional(rollbackFor = Exception.class) - public void writeOff(String id,Integer shopId) { + public void writeOff(String id,Integer shopId, Integer technicianId) { LoginUser loginUserApplet = tokenService.getLoginUserApplet(); Order order = orderMapper.selectById(id); boolean check = check(order, shopId, loginUserApplet.getUserid()); @@ -283,6 +276,7 @@ order.setAfterSaleTime(LocalDateTime.now().plusDays(days)); order.setEndTime(LocalDateTime.now()); order.setCancellerAppUserId(loginUserApplet.getUserid()); + order.setTechnicianId(technicianId); orderMapper.updateById(order); } @@ -334,7 +328,9 @@ orderPageListVo.setUserName(appUser.getName()); orderPageListVo.setPhone(appUser.getPhone()); } - RefundPass one = refundPassService.getOne(new LambdaQueryWrapper<RefundPass>().eq(RefundPass::getOrderId, orderPageListVo.getId()).eq(RefundPass::getDelFlag, 0).last(" order by create_time desc limit 0, 1")); +// RefundPass one = refundPassService.getOne(new LambdaQueryWrapper<RefundPass>().eq(RefundPass::getOrderId, orderPageListVo.getId()).eq(RefundPass::getDelFlag, 0).last(" order by create_time desc limit 0,1")); + RefundPass one = refundPassService.lambdaQuery().eq(RefundPass::getOrderId, orderPageListVo.getId()).one(); + orderPageListVo.setRefundPassId(null != one ? one.getId().toString() : null); } return pageInfo.setRecords(list); @@ -377,8 +373,8 @@ * @return */ @Override - public R confirmDelivery(Long orderId, String code) { - Order order = this.getById(orderId); + public R confirmDelivery(ConfirmDelivery confirmDelivery) { + Order order = this.getById(confirmDelivery.getOrderId()); if(1 == order.getPayStatus()){ return R.fail("订单还未完成支付"); } @@ -389,8 +385,28 @@ return R.fail("无效的操作"); } //添加快递号和修改订单状态 - order.setExpressJson(code); + order.setExpressJson(confirmDelivery.getCode()); + order.setDeliverProvince(confirmDelivery.getDeliverProvince()); + order.setDeliverProvinceCode(confirmDelivery.getDeliverProvinceCode()); + order.setDeliverCity(confirmDelivery.getDeliverCity()); + order.setDeliverCityCode(confirmDelivery.getDeliverCityCode()); + order.setDeliverDistrict(confirmDelivery.getDeliverDistrict()); + order.setDeliverDistrictCode(confirmDelivery.getDeliverDistrictCode()); order.setOrderStatus(2); + //添加查询快递信息队列 + //一小时后定时查询快递信息 + SystemConfig systemConfig = systemConfigClient.getSystemConfig(3).getData(); + JSONObject jsonObject = JSON.parseObject(systemConfig.getContent()); + Integer waitTime = jsonObject.getInteger("waitTime"); + redisTemplate.opsForZSet().add("order_express", order.getId(), LocalDateTime.now().plusHours(waitTime).toEpochSecond(ZoneOffset.UTC)); + + JSONObject jsonObject1 = JSON.parseObject(confirmDelivery.getCode()); + String com = jsonObject1.getString("com"); + String num = jsonObject1.getString("num"); + UserAddress userAddress = JSON.parseObject(order.getAddressJson(), UserAddress.class); + MapTrackKD100Vo mapTrackKD100Vo = ExpressDeliveryUtil.kd100MapTrack(com, num, order.getDeliverProvince() + order.getDeliverCity(), + userAddress.getProvince() + userAddress.getCity()); + order.setExpressResult(JSON.toJSONString(mapTrackKD100Vo)); this.updateById(order); return R.ok(); } -- Gitblit v1.7.1