From 8320d8a04fec16cec42b7045e44405f50488b7f4 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期五, 29 十一月 2024 13:57:53 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |  219 ++++++++++++++++++++++++++++++++++++------------------
 1 files changed, 147 insertions(+), 72 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..b000233 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,7 @@
         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());
             if (DetlDto.has(list, dto)) {
                 DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch());
                 assert detlDto != null;
@@ -144,6 +144,8 @@
             orderDetl.setSuppCode(detlDto.getFromOrderNo());
             orderDetl.setMemo(detlDto.getMemo());
             orderDetl.setManu(detlDto.getMark());
+            orderDetl.setSupp(detlDto.getSuppName());
+            orderDetl.setSku(detlDto.getCustomer());
             if (!orderDetlService.insert(orderDetl)) {
                 throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
             }
@@ -253,7 +255,7 @@
         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());
             if (DetlDto.has(list, dto)) {
                 DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch());
                 assert detlDto != null;
@@ -283,6 +285,8 @@
             orderDetl.setSuppCode(detlDto.getFromOrderNo());
             orderDetl.setMemo(detlDto.getMemo());
             orderDetl.setManu(detlDto.getMark());
+            orderDetl.setSupp(detlDto.getSuppName());
+            orderDetl.setSku(detlDto.getCustomer());
             if (!orderDetlService.insert(orderDetl)) {
                 throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
             }
@@ -472,81 +476,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 +499,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,8 +513,8 @@
     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) {
@@ -585,7 +527,7 @@
                         if (!Cools.isEmpty(order)) {
                             locDetlByTimeDTO.setDate(order.getOrderTime());
                             locDetlByTimeDTO.setWarehouse(order.getItemName());
-                            locDetlByTimeDTO.setOrderType(order.getDocType().toString());
+                            locDetlByTimeDTO.setOrderType(order.getDocType$());
                         }
                         locDetlByTimeDTO.setMatnr(wrkDetlLog.getMatnr());
                         locDetlByTimeDTO.setLocNo(wrkMastLog.getIoType() <100? wrkMastLog.getLocNo(): wrkMastLog.getSourceLocNo());
@@ -593,6 +535,7 @@
                         locDetlByTimeDTO.setAnfme(wrkDetlLog.getAnfme());
                         locDetlByTimeDTO.setOrderNo(wrkDetlLog.getOrderNo());
                         locDetlByTimeDTO.setMark(wrkDetlLog.getManu());
+                        locDetlByTimeDTO.setWorkNo(wrkDetlLog.getWrkNo().toString());
                         locDetlByTimeDTOS.add(locDetlByTimeDTO);
                     }
 
@@ -632,4 +575,136 @@
         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("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+                            }
+                        }
+                    }
+
+
+
+
+                }
+
+
+            }
+        });
+    }
 }

--
Gitblit v1.9.1