From 12067f657bc3dc169a7a466e433374368e8daf73 Mon Sep 17 00:00:00 2001
From: chen.llin <1442464845@qq.comm>
Date: 星期日, 18 一月 2026 16:14:27 +0800
Subject: [PATCH] 越库订单逻辑调整

---
 src/main/java/com/zy/asrs/controller/OrderPakinController.java |   46 ++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 46 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OrderPakinController.java b/src/main/java/com/zy/asrs/controller/OrderPakinController.java
index 4b61e60..eb1f397 100644
--- a/src/main/java/com/zy/asrs/controller/OrderPakinController.java
+++ b/src/main/java/com/zy/asrs/controller/OrderPakinController.java
@@ -13,6 +13,7 @@
 import com.zy.asrs.service.*;
 import com.zy.common.model.DetlDto;
 import com.zy.common.web.BaseController;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
@@ -20,6 +21,7 @@
 
 import java.util.*;
 
+@Slf4j
 @RestController
 @RequestMapping("order/pakin")
 public class OrderPakinController extends BaseController {
@@ -44,6 +46,27 @@
     private WrkMastLogService wrkMastLogService;
     @Autowired
     private ClientService clientService;
+    @Autowired
+    private CrossDockService crossDockService;
+
+    @RequestMapping(value = "/order/list/pda/page/auth")
+    @ManagerAuth
+    public R pdaPageList(@RequestParam(required = true)Long tagId,
+                         @RequestParam(defaultValue = "1")Integer curr,
+                         @RequestParam(defaultValue = "10")Integer limit){
+        List<DocType> docTypes = docTypeService.selectList(new EntityWrapper<DocType>().eq("pakin", 1));
+        ArrayList<Integer> arrayList = new ArrayList<>();
+        docTypes.forEach(docType -> {
+            arrayList.add(docType.getDocId().intValue());
+        });
+        EntityWrapper<OrderPakin> wrapper = new EntityWrapper<>();
+//        wrapper.eq("tag_id", tagId);
+        wrapper.in("doc_type", arrayList);
+        wrapper.in("settle",1,2);
+        wrapper.orderBy("create_time", false);
+        Page<OrderPakin> orderPage = orderService.selectPage(new Page<>(curr, limit), wrapper);
+        return R.ok().add(orderPage);
+    }
 
     @RequestMapping(value = "/order/nav/list/auth")
     @ManagerAuth
@@ -187,6 +210,29 @@
                 }
             }
         }
+        
+        // 瓒婂簱鍔熻兘锛氬鏋滃嬀閫変簡瓒婂簱璁㈠崟锛屾棤璁轰粈涔堢被鍨嬬殑璁㈠崟閮芥寜鐓ц秺搴撻�昏緫澶勭悊
+        Boolean isCrossDock = param.getIsCrossDock();
+        log.info("妫�鏌ヨ秺搴撹鍗曟爣璇嗭紝isCrossDock锛歿}锛岀被鍨嬶細{}锛岃鍗曞彿锛歿}", 
+                isCrossDock, isCrossDock != null ? isCrossDock.getClass().getName() : "null", order.getOrderNo());
+        
+        // 鍒ゆ柇鏄惁涓鸿秺搴撹鍗曪紙鏀寔 Boolean.TRUE 鎴� true 瀛楃涓诧級
+        boolean shouldProcessCrossDock = Boolean.TRUE.equals(isCrossDock) || 
+                (isCrossDock != null && isCrossDock.toString().equalsIgnoreCase("true"));
+        
+        if (shouldProcessCrossDock) {
+            log.info("寮�濮嬪鐞嗚秺搴撹鍗曪紝璁㈠崟鍙凤細{}锛岃鍗旾D锛歿}", order.getOrderNo(), order.getId());
+            String outOrderNo = crossDockService.processCrossDockInbound(order, param, getUserId());
+            // 閲嶆柊鏌ヨ璁㈠崟锛岀‘淇濈姸鎬佸凡鏇存柊
+            OrderPakin finalOrder = orderService.selectById(order.getId());
+            if (finalOrder != null) {
+                log.info("瓒婂簱璁㈠崟澶勭悊瀹屾垚锛岃鍗曞彿锛歿}锛屾渶缁堢姸鎬侊細{}", finalOrder.getOrderNo(), finalOrder.getSettle());
+            }
+            return R.ok("瓒婂簱鍏ュ簱鍗曞垱寤烘垚鍔燂紝宸茶嚜鍔ㄧ敓鎴愯秺搴撳嚭搴撳崟锛�" + outOrderNo);
+        } else {
+            log.info("闈炶秺搴撹鍗曪紝璁㈠崟鍙凤細{}锛岀姸鎬佷繚鎸佷负锛歿}", order.getOrderNo(), order.getSettle());
+        }
+        
         return R.ok("璁㈠崟娣诲姞鎴愬姛");
     }
 

--
Gitblit v1.9.1