From 58dc66a9d999c7d350e1ee4bf32b8d85b6e20e00 Mon Sep 17 00:00:00 2001
From: ZY <zc857179121@qq.com>
Date: 星期六, 21 九月 2024 10:32:42 +0800
Subject: [PATCH] 逻辑调整

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |  607 ++++++++++++++++++++++++++++++++----------------------
 1 files changed, 360 insertions(+), 247 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 19ec133..83d3856 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -6,10 +6,7 @@
 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.PackParam;
+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;
@@ -55,261 +52,268 @@
     @Override
     @Transactional
     public void pakinOrderCreate(OpenOrderPakinParam param) {
-        Order order = orderService.selectByNo(param.getOrderNo());
-        if (!Cools.isEmpty(order)) {
-            throw new CoolException(param.getOrderNo() + "鍗曟嵁宸插瓨鍦紝璇峰嬁閲嶅鎻愪氦");
-        }
-        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());
-            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);
-            }
-        }
-        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);
-            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);
-            orderDetl.setStatus(1);
-            orderDetl.setQty(0.0D);
-            if (!orderDetlService.insert(orderDetl)) {
-                throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
-            }
-        }
+//        Order order = orderService.selectByNo(param.getOrderNo());
+//        if (!Cools.isEmpty(order)) {
+//            throw new CoolException(param.getOrderNo() + "鍗曟嵁宸插瓨鍦紝璇峰嬁閲嶅鎻愪氦");
+//        }
+//        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);
+//            if (DetlDto.has(list, dto)) {
+//                DetlDto detlDto = DetlDto.find(list, dto);
+//                assert detlDto != null;
+//                detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme());
+//            } else {
+//                list.add(dto);
+//            }
+//        }
+//        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);
+//            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);
+//            orderDetl.setStatus(1);
+//            orderDetl.setQty(0.0D);
+//            if (!orderDetlService.insert(orderDetl)) {
+//                throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
+//            }
+//        }
     }
 
     @Override
     @Transactional
     public List<OpenOrderCompeteResult> pakinOrderComplete(OpenOrderCompleteParam param) {
-        List<OpenOrderCompeteResult> results = new ArrayList<>();
-        if (!Cools.isEmpty(param) && !Cools.isEmpty(param.getOrderNo())) {
-            // 鎸囧畾璁㈠崟
-            Order order = orderService.selectByNo(param.getOrderNo());
-            if (null != order) {
-                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
-                results.add(result);
-                result.setOrderNo(order.getOrderNo());
-                result.setOrderTime(order.getOrderTime());
-                result.setOrderType(order.getDocType$());
-                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
-                for (OrderDetl orderDetl : orderDetls) {
-                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
-                }
-                if (order.getSettle() == 4L) {
-                    // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
-                    if (!orderService.updateSettle(order.getId(), 6L, null)) {
-                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-                    }
-                }
-            }
-        } else {
-            // 鎵�鏈夎鍗�
-            List<Order> orders = orderService.selectList(new EntityWrapper<Order>().eq("settle", 4L));
-            for (Order order : orders) {
-                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
-                results.add(result);
-                result.setOrderNo(order.getOrderNo());
-                result.setOrderTime(order.getOrderTime());
-                result.setOrderType(order.getDocType$());
-                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
-                for (OrderDetl orderDetl : orderDetls) {
-                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
-                }
-                // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
-                if (!orderService.updateSettle(order.getId(), 6L, null)) {
-                    throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-                }
-            }
-        }
-        return results;
+//        List<OpenOrderCompeteResult> results = new ArrayList<>();
+//        if (!Cools.isEmpty(param) && !Cools.isEmpty(param.getOrderNo())) {
+//            // 鎸囧畾璁㈠崟
+//            Order order = orderService.selectByNo(param.getOrderNo());
+//            if (null != order) {
+//                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
+//                results.add(result);
+//                result.setOrderNo(order.getOrderNo());
+//                result.setOrderTime(order.getOrderTime());
+//                result.setOrderType(order.getDocType$());
+//                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
+//                for (OrderDetl orderDetl : orderDetls) {
+//                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
+//                }
+//                if (order.getSettle() == 4L) {
+//                    // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
+//                    if (!orderService.updateSettle(order.getId(), 6L, null)) {
+//                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+//                    }
+//                }
+//            }
+//        } else {
+//            // 鎵�鏈夎鍗�
+//            List<Order> orders = orderService.selectList(new EntityWrapper<Order>().eq("settle", 4L));
+//            for (Order order : orders) {
+//                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
+//                results.add(result);
+//                result.setOrderNo(order.getOrderNo());
+//                result.setOrderTime(order.getOrderTime());
+//                result.setOrderType(order.getDocType$());
+//                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
+//                for (OrderDetl orderDetl : orderDetls) {
+//                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
+//                }
+//                // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
+//                if (!orderService.updateSettle(order.getId(), 6L, null)) {
+//                    throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+//                }
+//            }
+//        }
+//        return results;
+        return null;
     }
 
     @Override
+    @Transactional
     public void pakoutOrderCreate(OpenOrderPakoutParam param) {
-        Order order = orderService.selectByNo(param.getOrderNo());
-        if (!Cools.isEmpty(order)) {
-            throw new CoolException(param.getOrderNo() + "鍗曟嵁宸插瓨鍦紝璇峰嬁閲嶅鎻愪氦");
-        }
-        DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.FALSE);
-        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());
-            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);
-            }
-        }
-        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);
-            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);
-            orderDetl.setStatus(1);
-            orderDetl.setQty(0.0D);
-            if (!orderDetlService.insert(orderDetl)) {
-                throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
-            }
-        }
+//        Order order = orderService.selectByNo(param.getOrderNo());
+//        // 濡傛灉鍗曟嵁涓嶅瓨鍦ㄥ垯娣诲姞锛涘鏋滃崟鎹瓨鍦紝浣滀笟涓棤娉曚慨鏀癸紝鍙嶄箣鍒欎慨鏀瑰崟鎹�
+//        if (!Cools.isEmpty(order)) {
+//            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();
+//        // 鍗曟嵁涓绘。
+//        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());
+//            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);
+//            }
+//        }
+//        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);
+//            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);
+//            orderDetl.setStatus(1);
+//            orderDetl.setQty(0.0D);
+//            if (!orderDetlService.insert(orderDetl)) {
+//                throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
+//            }
+//        }
     }
 
     @Override
     public List<OpenOrderCompeteResult> pakoutOrderComplete(OpenOrderCompleteParam param) {
-        List<OpenOrderCompeteResult> results = new ArrayList<>();
-        if (!Cools.isEmpty(param) && !Cools.isEmpty(param.getOrderNo())) {
-            // 鎸囧畾璁㈠崟
-            Order order = orderService.selectByNo(param.getOrderNo());
-            if (null != order) {
-                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
-                results.add(result);
-                result.setOrderNo(order.getOrderNo());
-                result.setOrderTime(order.getOrderTime());
-                result.setOrderType(order.getDocType$());
-                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
-                for (OrderDetl orderDetl : orderDetls) {
-                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
-                }
-                if (order.getSettle() == 4L) {
-                    // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
-                    if (!orderService.updateSettle(order.getId(), 6L, null)) {
-                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-                    }
-                }
-            }
-        } else {
-            // 鎵�鏈夎鍗�
-            List<Order> orders = orderService.selectList(new EntityWrapper<Order>().eq("settle", 4L));
-            for (Order order : orders) {
-                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
-                results.add(result);
-                result.setOrderNo(order.getOrderNo());
-                result.setOrderTime(order.getOrderTime());
-                result.setOrderType(order.getDocType$());
-                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
-                for (OrderDetl orderDetl : orderDetls) {
-                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
-                }
-                // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
-                if (!orderService.updateSettle(order.getId(), 6L, null)) {
-                    throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-                }
-            }
-        }
-        return results;
+//        List<OpenOrderCompeteResult> results = new ArrayList<>();
+//        if (!Cools.isEmpty(param) && !Cools.isEmpty(param.getOrderNo())) {
+//            // 鎸囧畾璁㈠崟
+//            Order order = orderService.selectByNo(param.getOrderNo());
+//            if (null != order) {
+//                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
+//                results.add(result);
+//                result.setOrderNo(order.getOrderNo());
+//                result.setOrderTime(order.getOrderTime());
+//                result.setOrderType(order.getDocType$());
+//                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
+//                for (OrderDetl orderDetl : orderDetls) {
+//                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
+//                }
+//                if (order.getSettle() == 4L) {
+//                    // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
+//                    if (!orderService.updateSettle(order.getId(), 6L, null)) {
+//                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+//                    }
+//                }
+//            }
+//        } else {
+//            // 鎵�鏈夎鍗�
+//            List<Order> orders = orderService.selectList(new EntityWrapper<Order>().eq("settle", 4L));
+//            for (Order order : orders) {
+//                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
+//                results.add(result);
+//                result.setOrderNo(order.getOrderNo());
+//                result.setOrderTime(order.getOrderTime());
+//                result.setOrderType(order.getDocType$());
+//                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
+//                for (OrderDetl orderDetl : orderDetls) {
+//                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
+//                }
+//                // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
+//                if (!orderService.updateSettle(order.getId(), 6L, null)) {
+//                    throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+//                }
+//            }
+//        }
+//        return results;
+        return null;
     }
 
     @Override
@@ -333,7 +337,7 @@
         pack = new Pack(
                 param.getBarcode(),    // 鏉$爜[闈炵┖]
                 analyse.getMatnr(),    // 鍟嗗搧缂栧彿
-                analyse.getBarcode(),    // 鎵瑰彿
+                analyse.getBarcode(),    // 搴忓垪鐮�
                 1L,    // 璁㈠崟鐘舵��
                 1,    // 鐘舵��
                 now,    // 娣诲姞鏃堕棿
@@ -433,4 +437,113 @@
         }
     }
 
+    @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());
+            if (mat == null) {
+                mat = new Mat();
+                // 鍒嗙被
+                Long tagId;
+                // 涓�绾у垎绫�
+                if (!Cools.isEmpty(matParam.getGroupCode()) && !Cools.isEmpty(matParam.getGroupName())) {
+                    Tag priTag = tagService.selectByName(matParam.getGroupCode(), 2);
+                    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(param);
+//            mat.setMatnr(param.getMatnr());
+//            mat.setMaktx(param.getMaktx());
+//            mat.setSpecs(param.getSpecs());
+//            mat.setModel(param.getModel());
+
+                mat.setTagId(tagId);
+                mat.setStatus(1);
+                mat.setCreateTime(now);
+                mat.setUpdateTime(now);
+                if (!matService.insert(mat)) {
+                    throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+                } else {
+                    log.info("鍚屾鏂扮墿鏂橻鍟嗗搧缂栧彿锛歿}]", mat.getMatnr());
+                }
+            } else {
+                mat.sync(param);
+                if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr",matParam.getMatnr()))) {
+                    throw new CoolException("鏇存柊宸插瓨鍦ㄥ晢鍝佷俊鎭け璐ワ紝璇疯仈绯荤鐞嗗憳");
+                }
+            }
+        }
+
+    }
+
 }

--
Gitblit v1.9.1