From cd8ab30f720cd8ab32062024b00c7fe3294a56a4 Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期一, 27 五月 2024 16:28:23 +0800
Subject: [PATCH] ERP接口

---
 src/main/java/com/zy/asrs/controller/OpenController.java |  139 +++++++++++++++++++++++++++++++++++++---------
 1 files changed, 111 insertions(+), 28 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index cae3801..7b763f5 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -149,6 +149,7 @@
      * 鍟嗗搧淇℃伅鍚屾鎺ュ彛
      */
     @PostMapping("/mat/v1")
+    @AppAuth(memo = "鐗╂枡鍚屾鎺ュ彛")
     public synchronized R syncMatInfoErp(@RequestHeader(required = false) String appkey,
                                       @RequestBody(required = false) MatSyncParam param,
                                       HttpServletRequest request){
@@ -156,27 +157,9 @@
         if (Cools.isEmpty(param)) {
             return R.parse(BaseRes.PARAM);
         }
-        MatSyncParam matSyncParam = openService.syncMat(param);
-        if (Cools.isEmpty(matSyncParam.getMats()) || matSyncParam.getMats().size() <=0 ) {
-            return R.error("鏁版嵁寮傚父");
-        }
-        StringBuilder Msg= new StringBuilder("鍘熷洜锛�");
-        int MsgT=0,MsgF=0;
-        for (MatSyncParam.Mats matParam:matSyncParam.getMats()){
-            if (matParam.isType()){
-                MsgT++;
-            }else {
-                MsgF++;
-                Msg.append(matParam.getMatnr()).append(":").append(matParam.getMemo()).append(";");
-            }
-        }
-        if (MsgF==0){
-            return R.ok("鎴愬姛鎺ユ敹鐗╂枡锛�"+MsgT+"涓�");
-        }else if (MsgT==0){
-            return R.ok("鎺ユ敹鐗╂枡澶辫触锛�"+MsgF+"涓�;"+Msg);
-        }else {
-            return R.ok("鎴愬姛鎺ユ敹鐗╂枡锛�"+MsgT+"涓�;"+"鎺ユ敹鐗╂枡澶辫触锛�"+MsgF+"涓�;"+Msg);
-        }
+        openService.syncMat(param);
+
+        return R.ok("鏇存柊鎴愬姛");
 
     }
 
@@ -296,36 +279,73 @@
 
     }
 
+    @PostMapping("/order/pak/default/v1")
+    @AppAuth(memo = "鐢熸垚閫�璐цˉ璐у崟鎹�")
+    public synchronized R orderAccept(@RequestHeader(required = false) String appkey,
+                                     @RequestBody(required = true) OrderSyncParam param,
+                                     HttpServletRequest request){
+        auth(appkey, param, request);
+        if (Cools.isEmpty(param)) {
+            return R.parse(BaseRes.PARAM);
+        }
+
+        String docName = param.get鎿嶄綔鍗曟嵁();
+        boolean pakin = param.getPakin() == 1 ? true : false;
+
+        openService.syncOrder(param,pakin,docName);
+
+        return R.ok("鍗曟嵁鎺ュ彈鎴愬姛");
+
+    }
+
     @PostMapping("/order/pakin/default/v1")
     @AppAuth(memo = "鐢熸垚鍏ュ簱鍗曟嵁")
     public synchronized R orderPakin(@RequestHeader(required = false) String appkey,
-                                        @RequestBody(required = false) Map<String, Object> param,
+                                        @RequestBody(required = true) OrderSyncParam param,
                                         HttpServletRequest request){
         auth(appkey, param, request);
         if (Cools.isEmpty(param)) {
             return R.parse(BaseRes.PARAM);
         }
 
-        openService.syncOrder(param,true);
+        String docName = param.getChildren().get(0).getIQuantity() > 0 ? "閾跺骇閲囪喘鍏ュ簱鍗�" : "閾跺骇閲囪喘閫�璐у崟";
+        boolean pakin = param.getChildren().get(0).getIQuantity() > 0 ? true : false;
 
-        return R.ok("鍏ュ簱鍗曟嵁鎺ュ彈鎴愬姛");
+        openService.syncOrder(param,pakin,docName);
+
+        return R.ok("鍗曟嵁鎺ュ彈鎴愬姛");
 
     }
 
     @PostMapping("/order/pakout/default/v1")
-    @AppAuth(memo = "鐢熸垚鍑哄簱鍗曟嵁")
+    @AppAuth(memo = "鍚屾宸ュ崟鍗曟嵁")
     public synchronized R orderPakout(@RequestHeader(required = false) String appkey,
-                                     @RequestBody(required = false) Map<String, Object> param,
+                                      //@RequestBody(required = false) HashMap<String,Object> param,
+                                     @RequestBody(required = false) OrderProdSyncParam param,
                                      HttpServletRequest request){
 
         auth(appkey, param, request);
         if (Cools.isEmpty(param)) {
             return R.parse(BaseRes.PARAM);
         }
+        if(!Cools.eq("鐢熶骇",param.getCVouchtype())){
+            String docName = param.getIQuantity() > 0 ?  "閾跺骇濮斿鍏ュ簱鍗�" : "閾跺骇濮斿鍏ュ簱閫�璐у崟";
+            boolean pakin = param.getIQuantity() > 0 ? true : false;
+            mappingPakInOrderParam(param,pakin,docName);
 
-        openService.syncOrder(param,false);
+            if(!Cools.isEmpty(param.getChildren())){
+                String docName1 = param.getChildren().get(0).getIQuantity() > 0 ?  "閾跺骇濮斿鏉愭枡鍑哄簱鍗�" : "閾跺骇濮斿鏉愭枡閫�鏂欏崟";
+                boolean pakin1 = param.getChildren().get(0).getIQuantity() > 0 ? true : false;
+                mappingPakOutOrderParam(param,pakin1,docName1);
+            }
 
-        return R.ok("鍑哄簱鍗曟嵁鎺ュ彈鎴愬姛");
+        }else if(!Cools.isEmpty(param.getChildren())) {
+            String docName1 = param.getChildren().get(0).getIQuantity() > 0 ?  "閾跺骇鐢熶骇鏉愭枡鍑哄簱鍗�" : "閾跺骇鐢熶骇鏉愭枡閫�鏂欏崟";
+            boolean pakin1 = param.getChildren().get(0).getIQuantity() > 0 ? true : false;
+            mappingPakOutOrderParam(param,pakin1,docName1);
+        }
+
+        return R.ok("鍗曟嵁鎺ュ彈鎴愬姛");
 
     }
 
@@ -349,4 +369,67 @@
 
     }
 
+    private void mappingPakInOrderParam(OrderProdSyncParam param,boolean pakin,String docName){
+        //鐢熸垚鍗曟嵁涓讳綋
+        OrderSyncParam orderSyncParam = new OrderSyncParam();
+        orderSyncParam.set鎿嶄綔绯荤粺鍙�(param.get鎿嶄綔绯荤粺鍙�());
+        orderSyncParam.setcPOID(param.getOrderNoT());
+        orderSyncParam.setDdate(param.getOrderTime());
+        orderSyncParam.setcMemo(param.getCMemo());
+
+        //鐢熸垚鍗曟嵁鏄庣粏
+        OrderSyncParam.OrderDetl orderDetl = new OrderSyncParam.OrderDetl();
+        orderDetl.setcInvCode(param.getCInvCode());
+        orderDetl.setiQuantity(param.getIQuantity());
+        orderDetl.setcDefine22(param.getDefine24());
+        orderDetl.setbFree1(param.getBFree1());
+        orderDetl.setId(param.getId());
+        orderDetl.setIvouchrowno(param.getIvouchrowno());
+
+        //娣诲姞鍗曟嵁鏄庣粏鍒板崟鎹富浣�
+        List<OrderSyncParam.OrderDetl> orderDetls = new ArrayList<>();
+        orderDetls.add(orderDetl);
+
+        orderSyncParam.setChildren(orderDetls);
+
+//        String docName = param.getIQuantity() > 0 ?  "閾跺骇浜у搧鐢熶骇鍏ュ簱鍗�" : "鍏ュ簱閫�鍥炲崟";
+//        boolean pakin = param.getIQuantity() > 0 ? true : false;
+
+        openService.syncOrder(orderSyncParam,pakin,docName);
+
+        //return orderSyncParam;
+    }
+
+    private void mappingPakOutOrderParam(OrderProdSyncParam param,boolean pakin,String docName){
+        OrderSyncParam orderSyncParam = new OrderSyncParam();
+
+        List<OrderProdSyncParam.ChildInfo> child = param.getChildren();
+
+        //鐢熸垚鍗曟嵁涓讳綋
+        orderSyncParam.set鎿嶄綔绯荤粺鍙�(param.get鎿嶄綔绯荤粺鍙�());
+        orderSyncParam.setcPOID(child.get(0).getOrderNoT());
+        orderSyncParam.setDdate(param.getOrderTime());
+        orderSyncParam.setcMemo("");
+
+        //鐢熸垚鍗曟嵁鏄庣粏
+        List<OrderSyncParam.OrderDetl> orderDetls = new ArrayList<>();
+
+        for(OrderProdSyncParam.ChildInfo childInfo : child){
+            OrderSyncParam.OrderDetl orderDetl = new OrderSyncParam.OrderDetl();
+            orderDetl.setcInvCode(childInfo.getCInvCode());
+            orderDetl.setiQuantity(childInfo.getIQuantity());
+            orderDetl.setCsocode(param.getCsocode());
+            orderDetl.setbFree1(childInfo.getBFree1());
+            orderDetl.setId(childInfo.getIds());
+            orderDetl.setIvouchrowno(childInfo.getIvouchrowno());
+
+            orderDetls.add(orderDetl);
+        }
+        orderSyncParam.setChildren(orderDetls);
+
+        openService.syncOrder(orderSyncParam,false,docName);
+
+        //return orderSyncParam;
+    }
+
 }

--
Gitblit v1.9.1