From a484168b903a919b24d65a5d95dea88a04d8f34c Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期四, 26 十二月 2024 13:50:33 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/jxgtasrs' into jxgtasrs

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |  273 +++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 188 insertions(+), 85 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 bbd7895..aff9cec 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -114,7 +114,8 @@
         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.getFromOrderNo()
+                    , detail.getMark(),detail.getCustomer(),detail.getSuppName(),detail.getTemp1(),detail.getTemp2(),detail.getTemp3(),detail.getTemp4());
             if (DetlDto.has(list, dto)) {
                 DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch());
                 assert detlDto != null;
@@ -144,6 +145,12 @@
             orderDetl.setSuppCode(detlDto.getFromOrderNo());
             orderDetl.setMemo(detlDto.getMemo());
             orderDetl.setManu(detlDto.getMark());
+            orderDetl.setSupp(detlDto.getSuppName()); //渚涘簲鍟�
+            orderDetl.setSku(detlDto.getCustomer());
+            orderDetl.setTemp1(detlDto.getTemp1());
+            orderDetl.setTemp2(detlDto.getTemp2());
+            orderDetl.setTemp3(detlDto.getTemp3());
+            orderDetl.setTemp4(detlDto.getTemp4());
             if (!orderDetlService.insert(orderDetl)) {
                 throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
             }
@@ -253,7 +260,8 @@
         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.getFromOrderNo()
+                    , detail.getMark(),detail.getCustomer(),detail.getSuppName(),detail.getTemp1(),detail.getTemp2(),detail.getTemp3(),detail.getTemp4());
             if (DetlDto.has(list, dto)) {
                 DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch());
                 assert detlDto != null;
@@ -283,6 +291,12 @@
             orderDetl.setSuppCode(detlDto.getFromOrderNo());
             orderDetl.setMemo(detlDto.getMemo());
             orderDetl.setManu(detlDto.getMark());
+            orderDetl.setSupp(detlDto.getSuppName());
+            orderDetl.setSku(detlDto.getCustomer());
+            orderDetl.setTemp1(detlDto.getTemp1());
+            orderDetl.setTemp2(detlDto.getTemp2());
+            orderDetl.setTemp3(detlDto.getTemp3());
+            orderDetl.setTemp4(detlDto.getTemp4());
             if (!orderDetlService.insert(orderDetl)) {
                 throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
             }
@@ -472,81 +486,19 @@
             // 鍒嗙被
             Long tagId;
             // 涓�绾у垎绫�
-            if (!Cools.isEmpty(matParam.getGroupCode()) && !Cools.isEmpty(matParam.getGroupName())) {
-                Tag priTag = tagService.selectByName(matParam.getGroupCode(), 1);
-                if (priTag == null) {
-                    Tag top = tagService.getTop();
-                    NodeUtils nodeUtils = new NodeUtils();
-                    nodeUtils.executePath(top.getId());
-                    priTag = new Tag(
-                            null,    // 缂栧彿
-                            matParam.getGroupCode(),    // 鍚嶇О
-                            top.getId(),    // 鐖剁骇
-                            top.getName(),    // 鐖剁骇鍚嶇О
-                            nodeUtils.path.toString(),    // 鍏宠仈璺緞
-                            nodeUtils.pathName.toString(),    // 鍏宠仈璺緞鍚�
-                            0,    // 绫诲瀷
-                            null,    // 璐熻矗浜�
-                            null,    // 鍥剧墖
-                            null,    // 绠�瑕佹弿杩�
-                            null,    // 鏁伴噺
-                            2,    // 绛夌骇
-                            null,    // 鎺掑簭
-                            1,    // 鐘舵��
-                            now,    // 娣诲姞鏃堕棿
-                            null,    // 娣诲姞浜哄憳
-                            now,    // 淇敼鏃堕棿
-                            null,    // 淇敼浜哄憳
-                            null    // 澶囨敞
-                    );
-                    if (tagMapper.insert(priTag) == 0) {
-                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-                    }
-                }
-                // 浜岀骇鍒嗙被
-                Tag secTag = tagService.selectByName(matParam.getGroupName(), 2);
-                if (secTag == null) {
-                    NodeUtils nodeUtils = new NodeUtils();
-                    nodeUtils.executePath(priTag.getId());
-                    secTag = new Tag(
-                            null,    // 缂栧彿
-                            matParam.getGroupName(),    // 鍚嶇О
-                            priTag.getId(),    // 鐖剁骇
-                            priTag.getName(),    // 鐖剁骇鍚嶇О
-                            nodeUtils.path.toString(),    // 鍏宠仈璺緞
-                            nodeUtils.pathName.toString(),    // 鍏宠仈璺緞鍚�
-                            0,    // 绫诲瀷
-                            null,    // 璐熻矗浜�
-                            null,    // 鍥剧墖
-                            null,    // 绠�瑕佹弿杩�
-                            null,    // 鏁伴噺
-                            2,    // 绛夌骇
-                            null,    // 鎺掑簭
-                            1,    // 鐘舵��
-                            now,    // 娣诲姞鏃堕棿
-                            null,    // 娣诲姞浜哄憳
-                            now,    // 淇敼鏃堕棿
-                            null,    // 淇敼浜哄憳
-                            null    // 澶囨敞
-                    );
-                    if (tagMapper.insert(secTag) == 0) {
-                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-                    }
-                }
-                tagId = secTag.getId();
-            } else {
-                tagId = tagService.getTop().getId();
+            Tag tag = tagService.selectOne(new EntityWrapper<Tag>().eq("memo", matParam.getGroupCode()));
+            if (tag == null) {
+                throw new CoolException("鍑洪敊锛屾湭鎵惧埌鍒嗙被");
             }
             if (mat == null) {
                 mat = new Mat();
-
                 mat.sync(matParam);
 //            mat.setMatnr(param.getMatnr());
 //            mat.setMaktx(param.getMaktx());
 //            mat.setSpecs(param.getSpecs());
 //            mat.setModel(param.getModel());
 
-                mat.setTagId(tagId);
+                mat.setTagId(tag.getId());
                 mat.setStatus(1);
                 mat.setCreateTime(now);
                 mat.setUpdateTime(now);
@@ -557,7 +509,7 @@
                 }
             } else {
                 mat.sync(matParam);
-                mat.setTagId(tagId);
+                mat.setTagId(tag.getId());
                 if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr",matParam.getMatnr()))) {
                     throw new CoolException("鏇存柊宸插瓨鍦ㄥ晢鍝佷俊鎭け璐ワ紝璇疯仈绯荤鐞嗗憳");
                 }
@@ -571,29 +523,32 @@
     public List<LocDetlByTimeDTO> selectTimeLocDetl(TimeSelectParam param) {
         ArrayList<LocDetlByTimeDTO> locDetlByTimeDTOS = new ArrayList<>();
         EntityWrapper<WrkMastLog> wrkMastLogEntityWrapper = new EntityWrapper<>();
-        wrkMastLogEntityWrapper.ge("appe_time",param.getStartTime());
-        wrkMastLogEntityWrapper.le("appe_time",param.getEndTime());
+        wrkMastLogEntityWrapper.ge("modi_time",param.getStartTime());
+        wrkMastLogEntityWrapper.le("modi_time",param.getEndTime());
 //        wrkMastLogEntityWrapper.isNotNull("sheet_no");
         wrkMastLogService.selectList(wrkMastLogEntityWrapper).forEach(wrkMastLog -> {
             if (wrkMastLog.getWrkSts() == 5 || wrkMastLog.getWrkSts() == 15) {
                 List<WrkDetlLog> wrkDetlLogs = wrkDetlLogService.selectList(new EntityWrapper<WrkDetlLog>()
                         .eq("wrk_no", wrkMastLog.getWrkNo()).eq("zpallet", wrkMastLog.getBarcode()));
                 wrkDetlLogs.forEach(wrkDetlLog -> {
-                    LocDetlByTimeDTO locDetlByTimeDTO = new LocDetlByTimeDTO();
-                    if (!Cools.isEmpty(wrkDetlLog.getOrderNo())){
-                        Order order = orderService.selectByNo(wrkDetlLog.getOrderNo());
-                        if (!Cools.isEmpty(order)) {
-                            locDetlByTimeDTO.setDate(order.getOrderTime());
-                            locDetlByTimeDTO.setWarehouse(order.getItemName());
-                            locDetlByTimeDTO.setOrderType(order.getDocType().toString());
+                    if (wrkDetlLog.getOrderNo() != null && !wrkDetlLog.getOrderNo().isEmpty()) {
+                        LocDetlByTimeDTO locDetlByTimeDTO = new LocDetlByTimeDTO();
+                        if (!Cools.isEmpty(wrkDetlLog.getOrderNo())){
+                            Order order = orderService.selectByNo(wrkDetlLog.getOrderNo());
+                            if (!Cools.isEmpty(order)) {
+                                locDetlByTimeDTO.setDate(order.getOrderTime());
+                                locDetlByTimeDTO.setWarehouse(order.getItemName());
+                                locDetlByTimeDTO.setOrderType(order.getDocType$());
+                            }
+                            locDetlByTimeDTO.setMatnr(wrkDetlLog.getMatnr());
+                            locDetlByTimeDTO.setLocNo(wrkMastLog.getIoType() <100? wrkMastLog.getLocNo(): wrkMastLog.getSourceLocNo());
+                            locDetlByTimeDTO.setBatch(wrkDetlLog.getBatch());
+                            locDetlByTimeDTO.setAnfme(wrkDetlLog.getAnfme());
+                            locDetlByTimeDTO.setOrderNo(wrkDetlLog.getOrderNo());
+                            locDetlByTimeDTO.setMark(wrkDetlLog.getManu());
+                            locDetlByTimeDTO.setWorkNo(wrkDetlLog.getWrkNo().toString());
+                            locDetlByTimeDTOS.add(locDetlByTimeDTO);
                         }
-                        locDetlByTimeDTO.setMatnr(wrkDetlLog.getMatnr());
-                        locDetlByTimeDTO.setLocNo(wrkMastLog.getIoType() <100? wrkMastLog.getLocNo(): wrkMastLog.getSourceLocNo());
-                        locDetlByTimeDTO.setBatch(wrkDetlLog.getBatch());
-                        locDetlByTimeDTO.setAnfme(wrkDetlLog.getAnfme());
-                        locDetlByTimeDTO.setOrderNo(wrkDetlLog.getOrderNo());
-                        locDetlByTimeDTO.setMark(wrkDetlLog.getManu());
-                        locDetlByTimeDTOS.add(locDetlByTimeDTO);
                     }
 
                 });
@@ -632,4 +587,152 @@
         return true;
     }
 
+    @Override
+    @Transactional
+    public void syncTag(List<TagParam> param) {
+
+        param.forEach(tag-> {
+            // 鍒嗙被
+            Long tagId;
+            Date now = new Date();
+            if (Cools.isEmpty(tag.getParentItemClassId())){
+                Tag priTag = tagService.selectByName("鍏ㄩ儴", 1);
+
+                // 浜岀骇鍒嗙被
+                Tag secTag = tagService.selectByName(tag.getName(), 2);
+                if (secTag == null) {
+                    NodeUtils nodeUtils = new NodeUtils();
+                    nodeUtils.executePath(priTag.getId());
+                    secTag = new Tag(
+                            null,    // 缂栧彿
+                            tag.getName(),    // 鍚嶇О
+                            priTag.getId(),    // 鐖剁骇
+                            priTag.getName(),    // 鐖剁骇鍚嶇О
+                            nodeUtils.path.toString(),    // 鍏宠仈璺緞
+                            nodeUtils.pathName.toString(),    // 鍏宠仈璺緞鍚�
+                            0,    // 绫诲瀷
+                            null,    // 璐熻矗浜�
+                            null,    // 鍥剧墖
+                            null,    // 绠�瑕佹弿杩�
+                            null,    // 鏁伴噺
+                            2,    // 绛夌骇
+                            null,    // 鎺掑簭
+                            1,    // 鐘舵��
+                            now,    // 娣诲姞鏃堕棿
+                            null,    // 娣诲姞浜哄憳
+                            now,    // 淇敼鏃堕棿
+                            null,    // 淇敼浜哄憳
+                            tag.getItemClassId()    // 澶囨敞
+                    );
+                    if (tagMapper.insert(secTag) == 0) {
+                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+                    }
+                }
+            }else {
+                Tag priTag =tagService.selectOne(new EntityWrapper<Tag>().eq("memo", tag.getParentItemClassId()));
+                if (priTag == null) {
+                    Tag top = tagService.getTop();
+                    NodeUtils nodeUtils = new NodeUtils();
+                    nodeUtils.executePath(top.getId());
+                    priTag = new Tag(
+                            null,    // 缂栧彿
+                            tag.getParentName(),    // 鍚嶇О
+                            top.getId(),    // 鐖剁骇
+                            top.getName(),    // 鐖剁骇鍚嶇О
+                            nodeUtils.path.toString(),    // 鍏宠仈璺緞
+                            nodeUtils.pathName.toString(),    // 鍏宠仈璺緞鍚�
+                            0,    // 绫诲瀷
+                            null,    // 璐熻矗浜�
+                            null,    // 鍥剧墖
+                            null,    // 绠�瑕佹弿杩�
+                            null,    // 鏁伴噺
+                            2,    // 绛夌骇
+                            null,    // 鎺掑簭
+                            1,    // 鐘舵��
+                            now,    // 娣诲姞鏃堕棿
+                            null,    // 娣诲姞浜哄憳
+                            now,    // 淇敼鏃堕棿
+                            null,    // 淇敼浜哄憳
+                            tag.getParentItemClassId()    // 澶囨敞
+                    );
+                    if (tagMapper.insert(priTag) == 0) {
+                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+                    }
+                }
+
+                // 浜岀骇鍒嗙被
+                Tag secTag = tagService.selectOne(new EntityWrapper<Tag>().eq("memo", tag.getItemClassId()));
+                NodeUtils nodeUtils = new NodeUtils();
+                nodeUtils.executePath(priTag.getId());
+                if (secTag == null) {
+                    secTag = new Tag(
+                            null,    // 缂栧彿
+                            tag.getName(),    // 鍚嶇О
+                            priTag.getId(),    // 鐖剁骇
+                            priTag.getName(),    // 鐖剁骇鍚嶇О
+                            nodeUtils.path.toString(),    // 鍏宠仈璺緞
+                            nodeUtils.pathName.toString(),    // 鍏宠仈璺緞鍚�
+                            0,    // 绫诲瀷
+                            null,    // 璐熻矗浜�
+                            null,    // 鍥剧墖
+                            null,    // 绠�瑕佹弿杩�
+                            null,    // 鏁伴噺
+                            2,    // 绛夌骇
+                            null,    // 鎺掑簭
+                            1,    // 鐘舵��
+                            now,    // 娣诲姞鏃堕棿
+                            null,    // 娣诲姞浜哄憳
+                            now,    // 淇敼鏃堕棿
+                            null,    // 淇敼浜哄憳
+                            tag.getItemClassId()    // 澶囨敞
+                    );
+                    if (tagMapper.insert(secTag) == 0) {
+                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+                    }
+                }else {
+                    secTag.setName(tag.getName());
+                    secTag.setParentId(priTag.getId());
+                    secTag.setParentName(priTag.getName());
+                    secTag.setPath(nodeUtils.path.toString());
+                    secTag.setPathName(nodeUtils.pathName.toString());
+                    if (tagMapper.updateById(secTag) == 0) {
+                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+                    }
+
+                    List<Tag> tags = tagService.selectList(new EntityWrapper<Tag>().eq("parent_id", secTag.getId()));
+                    if (!Cools.isEmpty(tags)) {
+                        for (Tag tag1 : tags) {
+                            tag1.setPath(nodeUtils.path.toString()+","+secTag.getId());
+                            tag1.setPathName(nodeUtils.pathName.toString()+","+secTag.getName());
+                            if (tagMapper.updateById(tag1) == 0) {
+                                throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+                            }
+                        }
+                    }
+
+
+
+
+                }
+
+
+            }
+        });
+    }
+    @Transactional
+    @Override
+    public void orderDelete(String orderNo) {
+        Order order = orderService.selectByNo(orderNo);
+        if (order == null) {
+            throw new CoolException("鏈煡璇㈠埌瀵瑰簲璁㈠崟淇℃伅");
+        }
+        if (order.getSettle() != 1){
+            throw new CoolException("璇ヨ鍗曞凡鏈夊搴斾换鍔★紝绂佹鍒犻櫎");
+        }
+        List<OrderDetl> OrderDetl = orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("order_no", orderNo));
+        if (!Cools.isEmpty(OrderDetl)) {
+            orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_no", orderNo));
+        }
+        orderService.delete(new EntityWrapper<Order>().eq("order_no", orderNo));
+    }
 }

--
Gitblit v1.9.1