From 4315c959d95e106ff9e18c28398087aeee7d077d Mon Sep 17 00:00:00 2001
From: dubin <bindu_bean@163.com>
Date: 星期一, 09 三月 2026 15:12:08 +0800
Subject: [PATCH] 对接接口开发

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |  119 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 119 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 16387bb..d845703 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -947,6 +947,125 @@
         return result;
     }
 
+    /**
+     * 鍏�/鍑哄簱閫氱煡鍗曚笅鍙�
+     * @param param
+     */
+    @Override
+    public void orderCreate(OpenOrderParam param) {
+        Order order = orderService.selectByNo(param.getOrderNo());
+        if (!Cools.isEmpty(order)){
+            throw new CoolException(param.getOrderNo() + "璁㈠崟宸插瓨鍦紝璇峰嬁閲嶅鍒涘缓");
+        }
+        Date now = new Date();
+        order = new Order(
+                String.valueOf(snowflakeIdWorker.nextId()), // 缂栧彿[闈炵┖]
+                param.getOrderNo(), // 璁㈠崟缂栫爜[闈炵┖]
+                DateUtils.convert(now), //鍗曟嵁鏃ユ湡
+                param.getOrderType(), //璁㈠崟绫诲瀷
+                null, //椤圭洰缂栧彿
+                null, //椤圭洰鍚嶇О 瀹㈡埛PO鍙�
+                null, //璋冩嫧椤圭洰缂栧彿
+                null, //鍒濆绁ㄦ嵁鍙�
+                null, //绁ㄦ嵁鍙�
+                null, //瀹㈡埛缂栧彿
+                null, //瀹㈡埛
+                param.getOrderInternalCode(), //鍗曟嵁鍐呯爜
+                param.getWkType(), //涓氬姟绫诲瀷
+                null, //鍚堣閲戦
+                null, //浼樻儬鐜�
+                null, //浼樻儬閲戦
+                null, //閿�鍞垨閲囪喘璐圭敤鍚堣
+                null, //瀹炰粯閲戦
+                null, //浠樻绫诲瀷 1: 鐜伴噾  2: 璁拌处
+                null, //涓氬姟鍛�
+                null, //缁撶畻澶╂暟
+                null, //閭垂鏀粯绫诲瀷 1: 鍦ㄧ嚎鏀粯  2: 璐у埌浠樻
+                null, //閭垂
+                param.getBusinessTime(), //涓氬姟鏃ユ湡
+                param.getCreateTime(), //鍒涘缓鏃ユ湡
+                null, //鐗╂祦鍚嶇О
+                null, //鐗╂祦鍗曞彿
+                1L, //璁㈠崟鐘舵��
+                1, //鐘舵�� 1: 姝e父  0: 绂佺敤
+                9527L, //娣诲姞浜哄憳
+                now, //娣诲姞鏃堕棿
+                9527L, //淇敼浜哄憳
+                now, //淇敼鏃堕棿
+                param.getStationId(), //鍏�/鍑哄簱鎺ラ┏绔欑偣
+                param.getOperateType() // 鎿嶄綔绫诲瀷 1.鏂板 2.淇敼 3.鍙栨秷
+        );
+        if (!orderService.insert(order)){
+            throw new CoolException("淇濆瓨璁㈠崟涓绘。澶辫触,璇疯仈绯荤鐞嗗憳锛�"+order);
+        }
+        List<OpenOrderParam.OrderItem> list = new ArrayList<>();
+        List<OpenOrderParam.OrderItem> orderItems = param.getOrderItems();
+        for (OpenOrderParam.OrderItem item : orderItems){
+            OpenOrderParam.OrderItem orderItem = new OpenOrderParam.OrderItem(
+                    item.getLineId(),
+                    item.getMatNr(),
+                    item.getMakTx(),
+                    item.getAnfme(),
+                    item.getSpec(),
+                    item.getModel(),
+                    item.getUnit(),
+                    item.getBatch(),
+                    item.getPalletId(),
+                    item.getPlanNo(),
+                    item.getTargetWareHouseId(),
+                    item.getSourceWareHouseId()
+            );
+            if (OpenOrderParam.OrderItem.hasLineNumber(list,orderItem)){
+                OpenOrderParam.OrderItem oi = OpenOrderParam.OrderItem.findLineNumber(
+                        list,
+                        item.getLineId(),
+                        item.getMatNr(),
+                        item.getMakTx(),
+                        item.getAnfme(),
+                        item.getSpec(),
+                        item.getModel(),
+                        item.getUnit(),
+                        item.getBatch(),
+                        item.getPalletId(),
+                        item.getPlanNo(),
+                        item.getTargetWareHouseId(),
+                        item.getSourceWareHouseId()
+                );
+                assert oi != null;
+                oi.setAnfme(oi.getAnfme() + orderItem.getAnfme());
+            } else {
+                list.add(orderItem);
+            }
+        }
+        for (OpenOrderParam.OrderItem orderItem : list) {
+            Mat mat = matService.selectByMatnr(orderItem.getMatNr());
+            if (Cools.isEmpty(mat)){
+                throw new CoolException("璁㈠崟鏄庣粏涓殑鍟嗗搧缂栧彿涓嶅瓨鍦細" + orderItem.getMatNr());
+            }
+            OrderDetl orderDetl = new OrderDetl();
+            orderDetl.sync(mat);
+            orderDetl.setOrderNo(order.getOrderNo()); // 璁㈠崟缂栧彿
+            orderDetl.setOrderId(order.getId()); // 璁㈠崟鍐呯爜
+            orderDetl.setStandby1(order.getTel()); // 琛屽唴鐮� 鍞竴鏍囪瘑
+            orderDetl.setAnfme(orderItem.getAnfme()); // 璁㈠崟鏁伴噺
+            orderDetl.setBarcode(orderItem.getBatch()); // 鎵规
+            orderDetl.setStandby2(orderItem.getPalletId()); // 鎵樼洏鐮�
+            orderDetl.setStandby3(orderItem.getPlanNo()); // 璁″垝璺熻釜鍙�
+            orderDetl.setBoxType1(orderItem.getSourceWareHouseId()); // 寤鸿鍏ュ簱浠撳簱
+            orderDetl.setBoxType2(orderItem.getTargetWareHouseId()); // 寤鸿鍑哄簱浠撳簱
+            orderDetl.setCreateBy(9527L);
+            orderDetl.setCreateTime(now);
+            orderDetl.setUpdateBy(9527L);
+            orderDetl.setUpdateTime(now);
+            orderDetl.setStatus(1);
+            orderDetl.setQty(0.0D);
+//            orderDetl.setPakinPakoutStatus(1);
+            if (!orderDetlService.insert(orderDetl)) {
+                throw new CoolException("淇濆瓨璁㈠崟鏄庣粏澶辫触,璇疯仈绯荤鐞嗗憳锛�"+orderDetl);
+            }
+        }
+    }
+
     @Override
     @Transactional
     public List<AgvLocListDetlParam> getAgvLocList(AgvLocListParam param) {

--
Gitblit v1.9.1