From d6ef18f23c4b298cb9b977ab3a5d65e2f4a39fe2 Mon Sep 17 00:00:00 2001
From: luodangjia <luodangjia>
Date: 星期三, 06 十一月 2024 18:02:28 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/OrderController.java |   31 ++++++++++++++++++++++++-------
 1 files changed, 24 insertions(+), 7 deletions(-)

diff --git a/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/OrderController.java b/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/OrderController.java
index 71001eb..f468f8b 100644
--- a/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/OrderController.java
+++ b/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/OrderController.java
@@ -419,12 +419,7 @@
     @RequiresPermissions("order_reassignment")
     @ApiOperation(value = "订单列表-订单派单/改派", tags = {"后台-订单管理"})
     @PostMapping(value = "/reassignment")
-    @ApiImplicitParams({
-            @ApiImplicitParam(value = "操作类型(1:订单派单;2:订单改派)", name = "type", dataType = "Integer", required = true),
-            @ApiImplicitParam(value = "订单id", name = "orderId", dataType = "Integer", required = true),
-            @ApiImplicitParam(value = "服务人员id", name = "workerId", dataType = "Integer", required = true),
-            @ApiImplicitParam(value = "改派原因", name = "applyReason", dataType = "String")
-    })
+
     @Transactional(rollbackFor = Exception.class)
     public R<String> reassignment(@RequestBody OrderReasinDto orderReasinDto) {
 //        String[] split = orderIds.split(",");
@@ -439,13 +434,25 @@
         // 订单派单
         boolean result = true;
         if (Constants.TWO.equals(orderId.getType())) {
+            orderClient.updateArrivalTime(order.getId(),orderReasinDto.getArriveTime());
+
             if (order.getState().equals(Constants.SIX) || order.getState().equals(Constants.THREE)) {
                 orderClient.updateState(order.getId(), Constants.ONE);
+
+                //如果是待改派,将上门时间设置为最新的,并且更新再投原因
+                if (order.getState().equals(Constants.SIX)){
+                    dispatchClient.changeReason(order.getId(), "");
+                }
+
             }
             // 订单状态为 待完工时,需要更改状态 待上门且清空师傅到达预约点时间
             if (order.getState().equals(Constants.TWO)) {
                 orderClient.updateStateAndArrivalTime(orderId.getOrderId(), Constants.ONE);
             }
+
+
+
+
             // 生成改派信息
 //            ChangeDispatch changeDispatch = new ChangeDispatch();
 //            changeDispatch.setWorkerId(item.getServerId());
@@ -461,6 +468,9 @@
 //            changeDispatch.setUserName(item.getReservationName());
 //            changeDispatch.setIsDelete(Constants.ZERO);
 //            result = dispatchClient.saveRecord(changeDispatch).getData();
+        }else {
+            orderClient.updateArrivalTime(order.getId(),orderReasinDto.getArriveTime());
+
         }
         ChannelHandlerContext context = NettyChannelMap.getData(String.valueOf(orderReasinDto.getWorkerId()));
         if (null != context) {
@@ -759,6 +769,7 @@
     public R<String> importTemplate(HttpServletResponse response) throws Exception {
         List<FrozenBuckleImportDTO> list = new ArrayList<>();
         FrozenBuckleImportDTO bean = new FrozenBuckleImportDTO();
+
         list.add(bean);
 
         // 这里URLEncoder.encode可以防止中文乱码
@@ -814,7 +825,7 @@
                 // 设置sheet,默认读取第一个
                 .sheet()
                 // 设置标题(字段列表)所在行数
-                .headRowNumber(2)
+                .headRowNumber(1)
                 .doRead();
         System.err.println(successArrayList);
 
@@ -845,6 +856,8 @@
             Site site = sites.stream().filter(e -> e.getSiteName().equals(frozenBuckleImportDTO.getSiteName())).findFirst().orElse(null);
             if(Objects.nonNull(site)){
                 order.setSiteId(site.getId());
+            }else {
+                return R.fail("站点信息不存在");
             }
             // 师傅信息
             if (StringUtils.hasLength(order.getServerName())) {
@@ -852,6 +865,8 @@
                 if(Objects.nonNull(masterWorker)){
                     order.setServerId(masterWorker.getId());
                     order.setServerPhone(masterWorker.getPhone());
+                }else {
+                    return R.fail("师傅信息不存在");
                 }
                 order.setAcceptTime(new Date());
                 // 待上门
@@ -869,6 +884,8 @@
             if(Objects.nonNull(recoveryServe)){
                 order.setServeId(recoveryServe.getId());
                 order.setServePrice(recoveryServe.getDefaultPrice());
+            }else {
+                return R.fail("回收服务不存在");
             }
             RecoveryServePrice one = recoveryServePriceService.lambdaQuery().eq(RecoveryServePrice::getCity, order.getCityCode()).eq(RecoveryServePrice::getRecoveryServeId, order.getServeId()).eq(BaseEntity::getIsDelete, 0).one();
             if (one==null) {

--
Gitblit v1.7.1