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 |  465 +++++++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 426 insertions(+), 39 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 2992414..aff9cec 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -6,19 +6,21 @@
 import com.core.common.SnowflakeIdWorker;
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.*;
-import com.zy.asrs.entity.param.OpenOrderCompleteParam;
-import com.zy.asrs.entity.param.OpenOrderPakinParam;
-import com.zy.asrs.entity.param.OpenOrderPakoutParam;
+import com.zy.asrs.entity.param.*;
 import com.zy.asrs.entity.result.OpenOrderCompeteResult;
 import com.zy.asrs.entity.result.StockVo;
+import com.zy.asrs.mapper.TagMapper;
 import com.zy.asrs.service.*;
+import com.zy.asrs.utils.MatUtils;
 import com.zy.common.model.DetlDto;
+import com.zy.common.utils.NodeUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.Date;
 import java.util.List;
 
@@ -45,13 +47,26 @@
     private PackService packService;
     @Autowired
     private TagService tagService;
+    @Autowired
+    private TagMapper tagMapper;
+    @Autowired
+    private WrkMastService wrkMastService;
+    @Autowired
+    private WrkMastLogServiceImpl wrkMastLogService;
+    @Autowired
+    private WrkDetlLogServiceImpl wrkDetlLogService;
 
     @Override
     @Transactional
     public void pakinOrderCreate(OpenOrderPakinParam param) {
         Order order = orderService.selectByNo(param.getOrderNo());
+        if (!Cools.isEmpty(order) && order.getSettle() !=1) {
+            throw new CoolException(param.getOrderNo() + "鍗曟嵁宸叉湁宸ヤ綔浠诲姟");
+        }
         if (!Cools.isEmpty(order)) {
-            throw new CoolException(param.getOrderNo() + "鍗曟嵁宸插瓨鍦紝璇峰嬁閲嶅鎻愪氦");
+            boolean orderNo = orderService.delete(new EntityWrapper<Order>().eq("order_no", param.getOrderNo()));
+            boolean orderNo1 = orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_no", param.getOrderNo()));
+
         }
         DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.TRUE);
         Date now = new Date();
@@ -59,30 +74,30 @@
         order = new Order(
                 String.valueOf(snowflakeIdWorker.nextId()),    // 缂栧彿[闈炵┖]
                 param.getOrderNo(),    // 璁㈠崟缂栧彿
-                DateUtils.convert(now),    // 鍗曟嵁鏃ユ湡
+                param.getInboundDate(),    // 鍗曟嵁鏃ユ湡
                 docType.getDocId(),    // 鍗曟嵁绫诲瀷
                 null,    // 椤圭洰缂栧彿
-                null,    //
+                param.getWarehouse(),    //浠撳簱 itemName
                 null,    // 璋冩嫧椤圭洰缂栧彿
-                null,    // 鍒濆绁ㄦ嵁鍙�
-                null,    // 绁ㄦ嵁鍙�
+                param.getOriginWarehouse(),    // 鍒濆绁ㄦ嵁鍙� 鏉ユ簮浠撳簱
+                param.getDepartment(),    // 绁ㄦ嵁鍙�
                 null,    // 瀹㈡埛缂栧彿
-                null,    // 瀹㈡埛
+                param.getSuppliers(),    // 渚涘簲鍟� cstmrName
                 null,    // 鑱旂郴鏂瑰紡
-                null,    // 鎿嶄綔浜哄憳
+                param.getUser(),    // 鍒跺崟浜�
                 null,    // 鍚堣閲戦
                 null,    // 浼樻儬鐜�
                 null,    // 浼樻儬閲戦
                 null,    // 閿�鍞垨閲囪喘璐圭敤鍚堣
                 null,    // 瀹炰粯閲戦
                 null,    // 浠樻绫诲瀷
-                null,    // 涓氬姟鍛�
+                param.getSalesman(),    // 涓氬姟鍛�
                 null,    // 缁撶畻澶╂暟
                 null,    // 閭垂鏀粯绫诲瀷
                 null,    // 閭垂
                 null,    // 浠樻鏃堕棿
                 null,    // 鍙戣揣鏃堕棿
-                null,    // 鐗╂祦鍚嶇О
+                param.getBusinessType(),    // 鐗╂祦鍚嶇О
                 null,    // 鐗╂祦鍗曞彿
                 1L,    // 璁㈠崟鐘舵��
                 1,    // 鐘舵��
@@ -99,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;
@@ -125,6 +141,16 @@
             orderDetl.setUpdateTime(now);
             orderDetl.setStatus(1);
             orderDetl.setQty(0.0D);
+            orderDetl.setThreeCode(detlDto.getOrderNo());
+            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("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
             }
@@ -178,10 +204,15 @@
     }
 
     @Override
+    @Transactional
     public void pakoutOrderCreate(OpenOrderPakoutParam param) {
         Order order = orderService.selectByNo(param.getOrderNo());
+        // 濡傛灉鍗曟嵁涓嶅瓨鍦ㄥ垯娣诲姞锛涘鏋滃崟鎹瓨鍦紝浣滀笟涓棤娉曚慨鏀癸紝鍙嶄箣鍒欎慨鏀瑰崟鎹�
         if (!Cools.isEmpty(order)) {
-            throw new CoolException(param.getOrderNo() + "鍗曟嵁宸插瓨鍦紝璇峰嬁閲嶅鎻愪氦");
+            if (order.getSettle() > 1L) {
+                throw new CoolException(param.getOrderNo() + "姝e湪鍑哄簱锛屾棤娉曚慨鏀瑰崟鎹�");
+            }
+            orderService.remove(order.getId());
         }
         DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.FALSE);
         Date now = new Date();
@@ -189,30 +220,30 @@
         order = new Order(
                 String.valueOf(snowflakeIdWorker.nextId()),    // 缂栧彿[闈炵┖]
                 param.getOrderNo(),    // 璁㈠崟缂栧彿
-                DateUtils.convert(now),    // 鍗曟嵁鏃ユ湡
+                param.getInboundDate(),    // 鍗曟嵁鏃ユ湡
                 docType.getDocId(),    // 鍗曟嵁绫诲瀷
                 null,    // 椤圭洰缂栧彿
-                null,    //
+                param.getWarehouse(),    //浠撳簱 itemName
                 null,    // 璋冩嫧椤圭洰缂栧彿
-                null,    // 鍒濆绁ㄦ嵁鍙�
-                null,    // 绁ㄦ嵁鍙�
+                param.getOriginWarehouse(),    // 鍒濆绁ㄦ嵁鍙� 鏉ユ簮浠撳簱
+                param.getDepartment(),    // 绁ㄦ嵁鍙�
                 null,    // 瀹㈡埛缂栧彿
-                null,    // 瀹㈡埛
+                param.getSuppliers(),    // 渚涘簲鍟� cstmrName
                 null,    // 鑱旂郴鏂瑰紡
-                null,    // 鎿嶄綔浜哄憳
+                param.getUser(),    // 鍒跺崟浜�
                 null,    // 鍚堣閲戦
                 null,    // 浼樻儬鐜�
                 null,    // 浼樻儬閲戦
                 null,    // 閿�鍞垨閲囪喘璐圭敤鍚堣
                 null,    // 瀹炰粯閲戦
                 null,    // 浠樻绫诲瀷
-                null,    // 涓氬姟鍛�
+                param.getSalesman(),    // 涓氬姟鍛�
                 null,    // 缁撶畻澶╂暟
                 null,    // 閭垂鏀粯绫诲瀷
                 null,    // 閭垂
                 null,    // 浠樻鏃堕棿
                 null,    // 鍙戣揣鏃堕棿
-                null,    // 鐗╂祦鍚嶇О
+                param.getBusinessType(),    // 鐗╂祦鍚嶇О
                 null,    // 鐗╂祦鍗曞彿
                 1L,    // 璁㈠崟鐘舵��
                 1,    // 鐘舵��
@@ -229,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;
@@ -255,6 +287,16 @@
             orderDetl.setUpdateTime(now);
             orderDetl.setStatus(1);
             orderDetl.setQty(0.0D);
+            orderDetl.setThreeCode(detlDto.getOrderNo());
+            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("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
             }
@@ -314,17 +356,20 @@
 
     @Override
     @Transactional
-    public void packageUp(String barcode) {
-        Pack pack = packService.selectByBarcode(barcode);
+    public void packageUp(PackParam param) {
+        if (Cools.isEmpty(param.getBarcode())) {
+            throw new CoolException("barcode涓嶈兘涓虹┖");
+        }
+        Mat analyse = MatUtils.analyseMat(param.getBarcode());
+        Pack pack = packService.selectByBarcode(param.getBarcode());
         if (null != pack) {
-            throw new CoolException(barcode + "閲嶅鎻愪氦");
+            throw new CoolException(param.getBarcode() + "閲嶅鎻愪氦");
         }
         Date now = new Date();
-        // todo:luxiaotao 瑙f瀽鏉$爜瑙勫垯锛岃幏鍙栫墿鏂欎唬鐮�
         pack = new Pack(
-                barcode,    // 鏉$爜[闈炵┖]
-                null,    // 鍟嗗搧缂栧彿
-                null,    // 鎵瑰彿
+                param.getBarcode(),    // 鏉$爜[闈炵┖]
+                analyse.getMatnr(),    // 鍟嗗搧缂栧彿
+                analyse.getBarcode(),    // 搴忓垪鐮�
                 1L,    // 璁㈠崟鐘舵��
                 1,    // 鐘舵��
                 now,    // 娣诲姞鏃堕棿
@@ -336,16 +381,358 @@
         if (!packService.insert(pack)) {
             throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
         }
-        Mat mat = new Mat();
-        mat.setTagId(tagService.getTop().getId());
-        mat.setMatnr(barcode);
-        mat.setMaktx(barcode);
-        mat.setStatus(1);
-        mat.setCreateTime(now);
-        mat.setUpdateTime(now);
-        if (!matService.insert(mat)) {
-            throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+
+        Mat mat = matService.selectByMatnr(analyse.getMatnr());
+        if (mat == null) {
+            mat = new Mat();
+            // 鍒嗙被
+            Long tagId;
+            // 涓�绾у垎绫�
+            if (!Cools.isEmpty(param.getGroupCode()) && !Cools.isEmpty(param.getGroupName())) {
+                Tag priTag = tagService.selectByName(param.getGroupCode(), 2);
+                if (priTag == null) {
+                    Tag top = tagService.getTop();
+                    NodeUtils nodeUtils = new NodeUtils();
+                    nodeUtils.executePath(top.getId());
+                    priTag = new Tag(
+                            null,    // 缂栧彿
+                            param.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(param.getGroupName(), 3);
+                if (secTag == null) {
+                    NodeUtils nodeUtils = new NodeUtils();
+                    nodeUtils.executePath(priTag.getId());
+                    secTag = new Tag(
+                            null,    // 缂栧彿
+                            param.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.setTagId(tagId);
+            mat.setMatnr(analyse.getMatnr());
+            mat.setMaktx(param.getMaterialName());
+            mat.setSpecs(param.getConfigureDesc());
+            mat.setModel(analyse.getModel());
+            mat.setStatus(1);
+            mat.setCreateTime(now);
+            mat.setUpdateTime(now);
+            if (!matService.insert(mat)) {
+                throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+            } else {
+                log.info("鎵撳寘涓婄嚎娣诲姞鏂扮墿鏂橻鍟嗗搧缂栧彿锛歿}]", mat.getMatnr());
+            }
         }
     }
 
+    @Override
+    @Transactional
+    public void syncMat(MatSyncParam param) {
+        if (Cools.isEmpty(param.getMatDetails()) || param.getMatDetails().size() <=0 ) {
+            throw new CoolException("鍟嗗搧鏁版嵁涓虹┖");
+        }
+
+        for(MatSyncParam.MatParam matParam : param.getMatDetails()){
+            if(Cools.isEmpty(matParam.getMatnr())){
+                throw new CoolException("鍟嗗搧缂栫爜涓嶈兘涓虹┖");
+            }
+
+            Date now = new Date();
+            Mat mat = matService.selectByMatnr(matParam.getMatnr());
+            // 鍒嗙被
+            Long tagId;
+            // 涓�绾у垎绫�
+            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(tag.getId());
+                mat.setStatus(1);
+                mat.setCreateTime(now);
+                mat.setUpdateTime(now);
+                if (!matService.insert(mat)) {
+                    throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+                } else {
+                    log.info("鍚屾鏂扮墿鏂橻鍟嗗搧缂栧彿锛歿}]", mat.getMatnr());
+                }
+            } else {
+                mat.sync(matParam);
+                mat.setTagId(tag.getId());
+                if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr",matParam.getMatnr()))) {
+                    throw new CoolException("鏇存柊宸插瓨鍦ㄥ晢鍝佷俊鎭け璐ワ紝璇疯仈绯荤鐞嗗憳");
+                }
+            }
+        }
+
+    }
+
+
+    @Override
+    public List<LocDetlByTimeDTO> selectTimeLocDetl(TimeSelectParam param) {
+        ArrayList<LocDetlByTimeDTO> locDetlByTimeDTOS = new ArrayList<>();
+        EntityWrapper<WrkMastLog> wrkMastLogEntityWrapper = new EntityWrapper<>();
+        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 -> {
+                    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);
+                        }
+                    }
+
+                });
+            }
+
+        });
+//        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;
+    }
+
+    @Override
+    @Transactional
+    public boolean agvHaiKang(String wrkNo) {
+        WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", Long.parseLong(wrkNo)));
+        wrkMast.setWrkSts(wrkMast.getWrkStsComplete());
+        wrkMastService.updateById(wrkMast);
+        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