From 797a5ff00e5b9d730e2778d09effe9f81cb4bd58 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期一, 21 十月 2024 10:57:12 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |  204 ++++++++++++++++++++++++++++----------------------
 1 files changed, 115 insertions(+), 89 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 96242bc..c77280d 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -51,6 +51,10 @@
     private TagMapper tagMapper;
     @Autowired
     private WrkMastService wrkMastService;
+    @Autowired
+    private WrkMastLogServiceImpl wrkMastLogService;
+    @Autowired
+    private WrkDetlLogServiceImpl wrkDetlLogService;
 
     @Override
     @Transactional
@@ -458,76 +462,77 @@
 
             Date now = new Date();
             Mat mat = matService.selectByMatnr(matParam.getMatnr());
+            // 鍒嗙被
+            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();
+            }
             if (mat == null) {
                 mat = new Mat();
-                // 鍒嗙被
-                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(), 3);
-                    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,    // 鏁伴噺
-                                3,    // 绛夌骇
-                                null,    // 鎺掑簭
-                                1,    // 鐘舵��
-                                now,    // 娣诲姞鏃堕棿
-                                null,    // 娣诲姞浜哄憳
-                                now,    // 淇敼鏃堕棿
-                                null,    // 淇敼浜哄憳
-                                null    // 澶囨敞
-                        );
-                        if (tagMapper.insert(secTag) == 0) {
-                            throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-                        }
-                    }
-                    tagId = secTag.getId();
-                } else {
-                    tagId = tagService.getTop().getId();
-                }
+
                 mat.sync(matParam);
 //            mat.setMatnr(param.getMatnr());
 //            mat.setMaktx(param.getMaktx());
@@ -545,6 +550,7 @@
                 }
             } else {
                 mat.sync(matParam);
+                mat.setTagId(tagId);
                 if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr",matParam.getMatnr()))) {
                     throw new CoolException("鏇存柊宸插瓨鍦ㄥ晢鍝佷俊鎭け璐ワ紝璇疯仈绯荤鐞嗗憳");
                 }
@@ -557,30 +563,50 @@
     @Override
     public List<LocDetlByTimeDTO> selectTimeLocDetl(TimeSelectParam param) {
         ArrayList<LocDetlByTimeDTO> locDetlByTimeDTOS = new ArrayList<>();
-        EntityWrapper<LocDetl> locDetlEntityWrapper = new EntityWrapper<>();
-        locDetlEntityWrapper.ge("appe_time",param.getStartTime());
-        locDetlEntityWrapper.le("appe_time",param.getEndTime());
-        List<LocDetl> locDetls = locDetlService.selectList(locDetlEntityWrapper);
-        if (!Cools.isEmpty(locDetls)) {
-            for (LocDetl locDetl : locDetls) {
+        EntityWrapper<WrkMastLog> wrkMastLogEntityWrapper = new EntityWrapper<>();
+        wrkMastLogEntityWrapper.ge("appe_time",param.getStartTime());
+        wrkMastLogEntityWrapper.le("appe_time",param.getEndTime());
+        wrkMastLogEntityWrapper.isNotNull("sheet_no");
+        wrkMastLogService.selectList(wrkMastLogEntityWrapper).forEach(wrkMastLog -> {
+            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(locDetl.getOrderNo())){
-                    Order order = orderService.selectByNo(locDetl.getOrderNo());
-                    if (!Cools.isEmpty(order)) {
-                        locDetlByTimeDTO.setDate(order.getOrderTime());
-                        locDetlByTimeDTO.setWarehouse(order.getItemName());
-                        locDetlByTimeDTO.setOrderType(order.getDocType().toString());
-                    }
+                Order order = orderService.selectByNo(wrkMastLog.getSheetNo());
+                if (!Cools.isEmpty(order)) {
+                    locDetlByTimeDTO.setDate(order.getOrderTime());
+                    locDetlByTimeDTO.setWarehouse(order.getItemName());
+                    locDetlByTimeDTO.setOrderType(order.getDocType().toString());
                 }
-
-                locDetlByTimeDTO.setMatnr(locDetl.getMatnr());
-                locDetlByTimeDTO.setLocNo(locDetl.getLocNo());
-                locDetlByTimeDTO.setBatch(locDetl.getBatch());
-                locDetlByTimeDTO.setAnfme(locDetl.getAnfme());
-                locDetlByTimeDTO.setOrderNo(locDetl.getOrderNo());
+                locDetlByTimeDTO.setMatnr(wrkDetlLog.getMatnr());
+                locDetlByTimeDTO.setLocNo(wrkMastLog.getIoType() <100? wrkMastLog.getLocNo(): wrkMastLog.getSourceLocNo());
+                locDetlByTimeDTO.setBatch(wrkDetlLog.getBatch());
+                locDetlByTimeDTO.setAnfme(wrkDetlLog.getAnfme());
+                locDetlByTimeDTO.setOrderNo(wrkMastLog.getSheetNo());
                 locDetlByTimeDTOS.add(locDetlByTimeDTO);
-            }
-        }
+            });
+
+        });
+//        if (!Cools.isEmpty(locDetls)) {
+//            for (LocDetl locDetl : locDetls) {
+//
+//                if (!Cools.isEmpty(locDetl.getOrderNo())){
+//                    Order order = orderService.selectByNo(locDetl.getOrderNo());
+//                    if (!Cools.isEmpty(order)) {
+//                        locDetlByTimeDTO.setDate(order.getOrderTime());
+//                        locDetlByTimeDTO.setWarehouse(order.getItemName());
+//                        locDetlByTimeDTO.setOrderType(order.getDocType().toString());
+//                    }
+//                }
+//
+//                locDetlByTimeDTO.setMatnr(locDetl.getMatnr());
+//                locDetlByTimeDTO.setLocNo(locDetl.getLocNo());
+//                locDetlByTimeDTO.setBatch(locDetl.getBatch());
+//                locDetlByTimeDTO.setAnfme(locDetl.getAnfme());
+//                locDetlByTimeDTO.setOrderNo(locDetl.getOrderNo());
+//                locDetlByTimeDTOS.add(locDetlByTimeDTO);
+//            }
+//        }
         return locDetlByTimeDTOS;
     }
 

--
Gitblit v1.9.1