From 3f30983db5b3cd2b25cb215579501a2ef134883c Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期五, 04 八月 2023 17:00:11 +0800
Subject: [PATCH] agv 订单出库功能完善

---
 src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java |  105 ++++++++++++++++++++++++++++++++++++++++------------
 1 files changed, 81 insertions(+), 24 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java
index 2f34254..2c6449c 100644
--- a/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java
@@ -1,6 +1,7 @@
 package com.zy.asrs.service.impl;
 
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.baomidou.mybatisplus.service.impl.ServiceImpl;
 import com.core.common.Cools;
 import com.core.common.DateUtils;
 import com.core.common.SnowflakeIdWorker;
@@ -11,8 +12,10 @@
 import com.zy.asrs.mapper.OrderDetlMapper;
 import com.zy.asrs.mapper.OrderMapper;
 import com.zy.asrs.service.*;
-import com.baomidou.mybatisplus.service.impl.ServiceImpl;
 import com.zy.common.model.DetlDto;
+import com.zy.common.model.OrderDto;
+import com.zy.common.model.OrderMergeVo;
+import com.zy.common.service.erp.ErpService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -36,6 +39,12 @@
     private DocTypeService docTypeService;
     @Autowired
     private WrkDetlService wrkDetlService;
+    @Autowired
+    private AgvWrkDetlService agvWrkDetlService;
+    @Autowired
+    private MatService matService;
+    @Autowired
+    private ErpService erpService;
 
     @Override
     public Order selectByNo(String orderNo) {
@@ -59,10 +68,14 @@
     @Override
     public void checkComplete(String orderNo) {
         Order order = this.selectByNo(orderNo);
+        if(Cools.isEmpty(order)){
+            return;
+        }
         if (order.getSettle() >= 4L) {
             return;
         }
         List<OrderDetl> orderDetls = orderDetlMapper.selectList(new EntityWrapper<OrderDetl>().eq("order_id", order.getId()));
+        // 浣滀笟鏁伴噺鏄惁绛変簬鏁伴噺
         boolean complete = true;
         for (OrderDetl orderDetl : orderDetls) {
             if (orderDetl.getAnfme() > orderDetl.getQty()) {
@@ -70,30 +83,34 @@
                 break;
             }
         }
-        if (complete) {
+        // 濡傛灉 浣滀笟鏁伴噺绛変簬鍗曟嵁鎬绘暟閲� && 宸ヤ綔鏄庣粏妗d腑鏃犺鍗曟嵁鐨勬暟鎹� && AGV宸ヤ綔鏄庣粏妗d腑鏃犺鍗曟嵁鐨勬暟鎹�
+        if (complete
+                && wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().like("order_no", orderNo)) < 1
+                && agvWrkDetlService.selectCount(new EntityWrapper<AgvWrkDetl>().like("order_no",orderNo)) < 1) {
             // 鍑哄簱璁㈠崟閲嶆柊鏁寸悊鏄庣粏
-            DocType docType = docTypeService.selectById(order.getDocType());
-            if (null != docType && docType.getPakout() == 1) {
-                if (!orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_id", order.getId()))) {
-                    throw new CoolException("閲嶆暣鍑哄簱璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戞槑缁嗗け璐�");
-                }
-                List<WrkDetl> wrkDetls = wrkDetlService.selectAndLogByOrderNo(orderNo);
-                for (WrkDetl wrkDetl : wrkDetls) {
-                    OrderDetl orderDetl = new OrderDetl();
-                    orderDetl.sync(wrkDetl);
-                    orderDetl.setQty(orderDetl.getAnfme());
-                    orderDetl.setOrderId(order.getId());
-                    orderDetl.setOrderNo(orderNo);
-                    orderDetl.setStatus(1);
-                    orderDetl.setCreateTime(order.getCreateTime());
-                    orderDetl.setCreateBy(order.getCreateBy());
-                    orderDetl.setUpdateTime(order.getUpdateTime());
-                    orderDetl.setUpdateBy(order.getUpdateBy());
-                    if (!orderDetlService.insert(orderDetl)) {
-                        throw new CoolException("閲嶆暣鍑哄簱璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戞槑缁嗗け璐�");
-                    }
-                }
-            }
+//            DocType docType = docTypeService.selectById(order.getDocType());
+//            if (null != docType && docType.getPakout() == 1) {
+//                // 閲嶇粍鏄庣粏
+//                if (!orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_id", order.getId()))) {
+//                    throw new CoolException("閲嶆暣鍑哄簱璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戞槑缁嗗け璐�");
+//                }
+//                List<WrkDetl> wrkDetls = wrkDetlService.selectAndLogByOrderNo(orderNo);
+//                for (WrkDetl wrkDetl : wrkDetls) {
+//                    OrderDetl orderDetl = new OrderDetl();
+//                    orderDetl.sync(wrkDetl);
+//                    orderDetl.setQty(orderDetl.getAnfme());
+//                    orderDetl.setOrderId(order.getId());
+//                    orderDetl.setOrderNo(orderNo);
+//                    orderDetl.setStatus(1);
+//                    orderDetl.setCreateTime(order.getCreateTime());
+//                    orderDetl.setCreateBy(order.getCreateBy());
+//                    orderDetl.setUpdateTime(order.getUpdateTime());
+//                    orderDetl.setUpdateBy(order.getUpdateBy());
+//                    if (!orderDetlService.insert(orderDetl)) {
+//                        throw new CoolException("閲嶆暣鍑哄簱璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戞槑缁嗗け璐�");
+//                    }
+//                }
+//            }
 
             if (!this.updateSettle(order.getId(), 4L, null)) {
                 throw new CoolException("淇敼璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戠姸鎬佷负宸插畬鎴愬け璐�");
@@ -141,6 +158,10 @@
                     throw new CoolException("淇敼鍗曟嵁鏄庣粏鏁伴噺澶辫触");
                 }
             }
+            // 宸ヤ綔妗f槑缁嗘洿鏂板崟鎹紪鍙�
+            for (WrkDetl wrkDetl : wrkDetls) {
+                wrkDetlService.updateOrderNo(orderNo, wrkDetl.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch());
+            }
         } catch (Exception e) {
             log.error("", e);
             return false;
@@ -161,4 +182,40 @@
         return this.baseMapper.selectComplete();
     }
 
+    @Override
+    public List<OrderMergeVo> mergePreview(List<Long> ids) {
+        List<OrderMergeVo> result = new ArrayList<>();
+        for (Long orderId : ids) {
+            Order order = this.selectById(orderId);
+            // 鑾峰彇鎵�鏈夋湭浣滀笟鐨勬槑缁�
+            List<OrderDetl> orderDetls = orderDetlService.selectRemainder(orderId);
+            for (OrderDetl orderDetl : orderDetls) {
+                Double leave = orderDetl.getAnfme() - orderDetl.getQty();
+                OrderMergeVo vo = new OrderMergeVo(orderDetl.getMatnr(), orderDetl.getBatch(), leave);
+                OrderDto orderDto = new OrderDto(orderDetl.getOrderNo(), null,null, leave);
+                if (OrderMergeVo.has(result, vo)) {
+                    OrderMergeVo exist = OrderMergeVo.find(result, vo.getMatnr(), vo.getBatch());
+                    assert exist != null;
+                    exist.setAnfme(exist.getAnfme() + vo.getAnfme());
+                    exist.getOrderDtos().add(orderDto);
+                } else {
+                    vo.getOrderDtos().add(orderDto);
+                    result.add(vo);
+                }
+
+            }
+        }
+        for (OrderMergeVo vo : result) {
+            Mat mat = matService.selectByMatnr(vo.getMatnr());
+            assert mat != null;
+            vo.setMaktx(mat.getMaktx());
+            vo.setSpecs(mat.getSpecs());
+        }
+        return result;
+    }
+    @Override
+    public List<Order> selectorderNoL(String orderNo) {
+        return this.baseMapper.selectorderNoL(orderNo);
+    }
+
 }

--
Gitblit v1.9.1