From e061d201decb0c3344d1bfc2237081a7edc0aa0d Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期一, 15 四月 2024 14:51:48 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |  202 ++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 184 insertions(+), 18 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 d2a726d..ed50a08 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -18,6 +18,7 @@
 import com.zy.asrs.utils.MatUtils;
 import com.zy.common.model.DetlDto;
 import com.zy.common.utils.NodeUtils;
+import com.zy.erp.kingdee.enums.KingDeeUtilType;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -116,7 +117,7 @@
                 null,    // 鍙戣揣鏃堕棿
                 null,    // 鐗╂祦鍚嶇О
                 null,    // 鐗╂祦鍗曞彿
-                4L,    // 璁㈠崟鐘舵��
+                1L,    // 璁㈠崟鐘舵��
                 1,    // 鐘舵��
                 9527L,    // 娣诲姞浜哄憳
                 now,    // 娣诲姞鏃堕棿
@@ -133,14 +134,26 @@
         for (DetlDto detail : orderDetails) {
             DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme(),detail.getOwnerName(),detail.getPayment());
             dto.setBeBatch(detail.getBeBatch());
-            if (DetlDto.has(list, dto)) {
-                DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch());
-                assert detlDto != null;
-                detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme());
-            } else {
-                list.add(dto);
+            KingDeeUtilType kingDeeUtilType = KingDeeUtilType.get(docType.getDocName());
+            if (kingDeeUtilType.entryId==1){
+                if (DetlDto.has2(list, dto)) {
+                    DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),detail.getOwnerName(),detail.getBeBatch());
+                    assert detlDto != null;
+                    detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme());
+                } else {
+                    list.add(dto);
+                }
+                dto.setWeight(detail.getWeight());
+            }else {
+                if (DetlDto.has1(list, dto)) {
+                    DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),detail.getOwnerName());
+                    assert detlDto != null;
+                    detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme());
+                } else {
+                    list.add(dto);
+                }
+                dto.setWeight(detail.getWeight());
             }
-            dto.setWeight(detail.getWeight());
         }
         for (DetlDto detlDto : list) {
             Mat mat = matService.selectByMatnr(detlDto.getMatnr());
@@ -168,7 +181,7 @@
             if (Cools.isEmpty(locOwner)){
                 throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
             }else {
-                orderDetl.setOwner(locOwner.getId().intValue());
+                orderDetl.setOwner(locOwner.getId());
             }
             orderDetl.setPayment(detlDto.getPayment());
             orderDetl.setStatus(1);
@@ -185,6 +198,20 @@
     @Transactional
     public void pakoutOrderCreate(OpenOrderPakoutParam param) {
         Order order = orderService.selectByNo(param.getOrderNo());
+
+        for (DetlDto detlDto : param.getOrderDetails()){
+            if (Cools.isEmpty(detlDto) || Cools.isEmpty(detlDto.getOwnerName(),detlDto.getPayment())){
+                throw new CoolException(param.getOrderNo() + "缂哄皯璐т富鎴栬揣鐗╁舰鎬�");
+            }else {
+                LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName()));
+                if (Cools.isEmpty(locOwner)){
+                    LocOwner locOwner1 = new LocOwner();
+                    locOwner1.setOwner(detlDto.getOwnerName());
+                    locOwnerService.insert(locOwner1);
+                }
+            }
+        }
+
         // 濡傛灉鍗曟嵁涓嶅瓨鍦ㄥ垯娣诲姞锛涘鏋滃崟鎹瓨鍦紝浣滀笟涓棤娉曚慨鏀癸紝鍙嶄箣鍒欎慨鏀瑰崟鎹�
         if (!Cools.isEmpty(order)) {
             if (order.getSettle() > 1L) {
@@ -223,7 +250,7 @@
                 null,    // 鍙戣揣鏃堕棿
                 null,    // 鐗╂祦鍚嶇О
                 null,    // 鐗╂祦鍗曞彿
-                4L,    // 璁㈠崟鐘舵��
+                1L,    // 璁㈠崟鐘舵��
                 1,    // 鐘舵��
                 9527L,    // 娣诲姞浜哄憳
                 now,    // 娣诲姞鏃堕棿
@@ -238,16 +265,28 @@
         List<DetlDto> list = new ArrayList<>();
         List<DetlDto> orderDetails = param.getOrderDetails();
         for (DetlDto detail : orderDetails) {
-            DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme());
+            DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme(),detail.getOwnerName(),detail.getPayment());
             dto.setBeBatch(detail.getBeBatch());
-            if (DetlDto.has(list, dto)) {
-                DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch());
-                assert detlDto != null;
-                detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme());
-            } else {
-                list.add(dto);
+            KingDeeUtilType kingDeeUtilType = KingDeeUtilType.get(docType.getDocName());
+            if (kingDeeUtilType.entryId==1){
+                if (DetlDto.has2(list, dto)) {
+                    DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),detail.getOwnerName(),detail.getBeBatch());
+                    assert detlDto != null;
+                    detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme());
+                } else {
+                    list.add(dto);
+                }
+                dto.setWeight(detail.getWeight());
+            }else {
+                if (DetlDto.has1(list, dto)) {
+                    DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),detail.getOwnerName());
+                    assert detlDto != null;
+                    detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme());
+                } else {
+                    list.add(dto);
+                }
+                dto.setWeight(detail.getWeight());
             }
-            dto.setWeight(detail.getWeight());
         }
         for (DetlDto detlDto : list) {
             Mat mat = matService.selectByMatnr(detlDto.getMatnr());
@@ -266,8 +305,135 @@
             orderDetl.setUpdateTime(now);
             orderDetl.setStatus(1);
             orderDetl.setQty(0.0D);
+            orderDetl.setOwner(detlDto.getOwner());
             orderDetl.setBeBatch(detlDto.getBeBatch());
             orderDetl.setWeight(detlDto.getWeight());
+            LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName()));
+            if (Cools.isEmpty(locOwner)){
+                throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
+            }else {
+                orderDetl.setOwner(locOwner.getId());
+            }
+            if (!orderDetlService.insert(orderDetl)) {
+                throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
+            }
+        }
+    }
+
+    @Override
+    @Transactional
+    public void pakmoveOrderCreate(OpenOrderPakmoveParam param) {
+        Order order = orderService.selectByNo(param.getOrderNo());
+        if (!Cools.isEmpty(order)) {
+            throw new CoolException(param.getOrderNo() + "鍗曟嵁宸插瓨鍦紝璇峰嬁閲嶅鎻愪氦");
+        }
+
+        for (DetlDto detlDto : param.getOrderDetails()){
+            if (Cools.isEmpty(detlDto) || Cools.isEmpty(detlDto.getOwnerName(),detlDto.getPayment())){
+                throw new CoolException(param.getOrderNo() + "缂哄皯璐т富鎴栬揣鐗╁舰鎬�");
+            }else {
+                LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName()));
+                if (Cools.isEmpty(locOwner)){
+                    LocOwner locOwner1 = new LocOwner();
+                    locOwner1.setOwner(detlDto.getOwnerName());
+                    locOwnerService.insert(locOwner1);
+                }
+            }
+        }
+        DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.TRUE);
+        Date now = new Date();
+        // 鍗曟嵁涓绘。
+        order = new Order(
+                String.valueOf(snowflakeIdWorker.nextId()),    // 缂栧彿[闈炵┖]
+                param.getOrderNo(),    // 璁㈠崟缂栧彿
+                DateUtils.convert(now),    // 鍗曟嵁鏃ユ湡
+                docType.getDocId(),    // 鍗曟嵁绫诲瀷
+                null,    // 椤圭洰缂栧彿
+                null,    //
+                null,    // 璋冩嫧椤圭洰缂栧彿
+                null,    // 鍒濆绁ㄦ嵁鍙�
+                null,    // 绁ㄦ嵁鍙�
+                null,    // 瀹㈡埛缂栧彿
+                null,    // 瀹㈡埛
+                null,    // 鑱旂郴鏂瑰紡
+                null,    // 鎿嶄綔浜哄憳
+                null,    // 鍚堣閲戦
+                null,    // 浼樻儬鐜�
+                null,    // 浼樻儬閲戦
+                null,    // 閿�鍞垨閲囪喘璐圭敤鍚堣
+                null,    // 瀹炰粯閲戦
+                null,    // 浠樻绫诲瀷
+                null,    // 涓氬姟鍛�
+                null,    // 缁撶畻澶╂暟
+                null,    // 閭垂鏀粯绫诲瀷
+                null,    // 閭垂
+                null,    // 浠樻鏃堕棿
+                null,    // 鍙戣揣鏃堕棿
+                null,    // 鐗╂祦鍚嶇О
+                null,    // 鐗╂祦鍗曞彿
+                1L,    // 璁㈠崟鐘舵��
+                1,    // 鐘舵��
+                9527L,    // 娣诲姞浜哄憳
+                now,    // 娣诲姞鏃堕棿
+                9527L,    // 淇敼浜哄憳
+                now,    // 淇敼鏃堕棿
+                null    // 澶囨敞
+        );
+        if (!orderService.insert(order)) {
+            throw new CoolException("鐢熸垚鍗曟嵁涓绘。澶辫触锛岃鑱旂郴绠$悊鍛�");
+        }
+        // 鍗曟嵁鏄庣粏妗�
+        List<DetlDto> list = new ArrayList<>();
+        List<DetlDto> orderDetails = param.getOrderDetails();
+        for (DetlDto detail : orderDetails) {
+            DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme(),detail.getOwnerName(),detail.getPayment());
+            dto.setBeBatch(detail.getBeBatch());
+            dto.setSourceLocName(detail.getSourceLocName());
+            dto.setTargetLocName(detail.getTargetLocName());
+            if (DetlDto.has3(list, dto)) {
+                DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),dto.getOwnerName(),dto.getSourceLocName(),dto.getTargetLocName());
+                assert detlDto != null;
+                detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme());
+            } else {
+                list.add(dto);
+            }
+            dto.setWeight(detail.getWeight());
+        }
+        for (DetlDto detlDto : list) {
+            Mat mat = matService.selectByMatnr(detlDto.getMatnr());
+            if (Cools.isEmpty(mat)) {
+                throw new CoolException(detlDto.getMatnr() + "缂栧彿鍟嗗搧妫�绱㈠け璐ワ紝璇峰厛娣诲姞鍟嗗搧");
+            }
+            OrderDetl orderDetl = new OrderDetl();
+            orderDetl.sync(mat);
+
+            //鎵瑰彿涓虹┖浼氬嚭鐜伴棶棰橈紝璁剧疆涓�涓粯璁ゅ��
+            if (detlDto.getBatch() == null) {
+                orderDetl.setBatch("");
+            } else {
+                orderDetl.setBatch(detlDto.getBatch());
+
+            }
+            orderDetl.setAnfme(detlDto.getAnfme());
+            orderDetl.setOrderId(order.getId());
+            orderDetl.setOrderNo(order.getOrderNo());
+            orderDetl.setCreateBy(9527L);
+            orderDetl.setCreateTime(now);
+            orderDetl.setUpdateBy(9527L);
+            orderDetl.setUpdateTime(now);
+            LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName()));
+            if (Cools.isEmpty(locOwner)){
+                throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
+            }else {
+                orderDetl.setOwner(locOwner.getId());
+            }
+            orderDetl.setPayment(detlDto.getPayment());
+            orderDetl.setStatus(1);
+            orderDetl.setQty(0.0D);
+            orderDetl.setBeBatch(detlDto.getBeBatch());
+            orderDetl.setWeight(detlDto.getWeight());
+            orderDetl.setSourceLocName(detlDto.getSourceLocName());
+            orderDetl.setTargetLocName(detlDto.getTargetLocName());
             if (!orderDetlService.insert(orderDetl)) {
                 throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
             }

--
Gitblit v1.9.1