From 21d0e7ab9d5c7316225a3e9eecf465cd37c9bd85 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期四, 05 六月 2025 14:15:07 +0800
Subject: [PATCH] 123

---
 src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java |   86 ++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 81 insertions(+), 5 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..c9d2f09 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,10 @@
 package com.zy.asrs.service.impl;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 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 +15,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.web.BaseController;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -36,6 +42,8 @@
     private DocTypeService docTypeService;
     @Autowired
     private WrkDetlService wrkDetlService;
+    @Autowired
+    private MatService matService;
 
     @Override
     public Order selectByNo(String orderNo) {
@@ -52,6 +60,11 @@
     }
 
     @Override
+    public List<OrderDetl> selectTotalDetls(Long orderId) {
+        return orderDetlMapper.selectTotalDetls(orderId);
+    }
+
+    @Override
     public boolean updateSettle(Long orderId, Long settle, Long userId) {
         return this.baseMapper.updateSettle(orderId, settle, userId) > 0;
     }
@@ -59,7 +72,7 @@
     @Override
     public void checkComplete(String orderNo) {
         Order order = this.selectByNo(orderNo);
-        if (order.getSettle() >= 4L) {
+        if (order==null || order.getSettle() >= 4L) {
             return;
         }
         List<OrderDetl> orderDetls = orderDetlMapper.selectList(new EntityWrapper<OrderDetl>().eq("order_id", order.getId()));
@@ -70,20 +83,34 @@
                 break;
             }
         }
-        if (complete) {
+        if (complete && wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().like("order_no", orderNo)) == 0) {
             // 鍑哄簱璁㈠崟閲嶆柊鏁寸悊鏄庣粏
             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() + "銆戞槑缁嗗け璐�");
+                    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);
+                    if (!BaseController.isJSON(wrkDetl.getOrderNo())) {
+                        orderDetl.setQty(orderDetl.getAnfme());
+                    } else {
+                        // 璁㈠崟鍚堝苟鍑哄簱
+                        List<OrderDto> orderDtoList = JSON.parseArray(wrkDetl.getOrderNo(), OrderDto.class);
+
+                        for (OrderDto one : orderDtoList) {
+                            if (one.getOrderNo().equals(orderNo)) {
+                                orderDetl.setAnfme(one.getAnfme());
+                                orderDetl.setQty(one.getAnfme());
+                                break;
+                            }
+                        }
+                    }
                     orderDetl.setStatus(1);
                     orderDetl.setCreateTime(order.getCreateTime());
                     orderDetl.setCreateBy(order.getCreateBy());
@@ -141,6 +168,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 +192,49 @@
         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, 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;
+    }
+
+    /**
+     * 鏌ヨ涓婃姤瀹岀粨鍘嗗彶妗�
+     * @return
+     */
+    @Override
+    public List<Order> selectToBeHistoryOrder() {
+        return this.baseMapper.selectToBeHistoryOrder();
+    }
+
+    @Override
+    public List<Order> selectOrderNoL(String orderNo) {
+        return this.baseMapper.selectOrderNoL(orderNo);
+    }
 }

--
Gitblit v1.9.1