From 346d463346701e8714b3a3a3ebb21e21960b5484 Mon Sep 17 00:00:00 2001
From: gongchunyi <deslre0381@gmail.com>
Date: 星期五, 20 三月 2026 15:06:47 +0800
Subject: [PATCH] feat: 查看生产订单对应的生产计划来源

---
 src/main/java/com/ruoyi/production/service/impl/ProductOrderServiceImpl.java |  115 ++++++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 81 insertions(+), 34 deletions(-)

diff --git a/src/main/java/com/ruoyi/production/service/impl/ProductOrderServiceImpl.java b/src/main/java/com/ruoyi/production/service/impl/ProductOrderServiceImpl.java
index 4a0cebc..ef1db88 100644
--- a/src/main/java/com/ruoyi/production/service/impl/ProductOrderServiceImpl.java
+++ b/src/main/java/com/ruoyi/production/service/impl/ProductOrderServiceImpl.java
@@ -1,18 +1,20 @@
 package com.ruoyi.production.service.impl;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.common.exception.ServiceException;
 import com.ruoyi.procurementrecord.utils.StockUtils;
 import com.ruoyi.production.dto.ProductOrderDto;
+import com.ruoyi.production.dto.ProductOrderSourceDto;
 import com.ruoyi.production.dto.ProductStructureDto;
 import com.ruoyi.production.enums.ProductOrderStatusEnum;
 import com.ruoyi.production.mapper.*;
 import com.ruoyi.production.pojo.*;
+import com.ruoyi.production.service.IProductionOrderAppendixService;
 import com.ruoyi.production.service.ProductOrderService;
 import com.ruoyi.productionPlan.mapper.ProductOrderPlanMapper;
 import com.ruoyi.productionPlan.mapper.ProductionPlanMapper;
@@ -74,6 +76,9 @@
     @Autowired
     private StockUtils stockUtils;
 
+    @Autowired
+    private IProductionOrderAppendixService productionOrderAppendixService;
+
     @Override
     public IPage<ProductOrderDto> pageProductOrder(Page<ProductOrder> page, ProductOrderDto productOrder) {
         return productOrderMapper.pageProductOrder(page, productOrder);
@@ -133,25 +138,48 @@
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public Boolean revoke(ProductOrder productOrder) {
-        // todo 鍒ゆ柇鏄惁浜х敓鎶ュ伐淇℃伅
-
-        // 鏌ヨ鍚堝苟鐨勭敓浜ц鍒�
-        List<ProductOrderPlan> productOrderPlans = productOrderPlanMapper.selectList(Wrappers.<ProductOrderPlan>lambdaQuery().in(ProductOrderPlan::getProductOrderId, productOrder.getId()));
-        if (productOrderPlans.isEmpty()) {
-            throw new RuntimeException("鍚堝苟鐨勭敓浜ц鍒掍笉瀛樺湪");
+    public Boolean revoke(List<Long> ids) {
+        List<ProductOrder> orders = productOrderMapper.selectBatchIds(ids);
+        if (orders.isEmpty()) {
+            throw new RuntimeException("鐢熶骇璁㈠崟涓嶅瓨鍦�");
         }
+        for (ProductOrder order : orders) {
+            if (!ProductOrderStatusEnum.canRevoke(order.getStatus())) {
+                throw new RuntimeException("鍙湁銆愬緟寮�濮嬨�戠姸鎬佺殑璁㈠崟鎵嶅彲浠ユ挙鍥�");
+            }
+        }
+
+        // 鍥為��鐢熶骇璁″垝
+        List<ProductOrderPlan> productOrderPlans = productOrderPlanMapper.selectList(Wrappers.<ProductOrderPlan>lambdaQuery().in(ProductOrderPlan::getProductOrderId, ids));
         for (ProductOrderPlan productOrderPlan : productOrderPlans) {
             ProductionPlan productionPlan = productionPlanMapper.selectById(productOrderPlan.getProductionPlanId());
-            productionPlan.setAssignedQuantity(productionPlan.getAssignedQuantity().subtract(productOrderPlan.getAssignedQuantity()));
-            productionPlanMapper.updateById(productionPlan);
+            if (productionPlan != null) {
+                BigDecimal newAssigned = productionPlan.getAssignedQuantity().subtract(productOrderPlan.getAssignedQuantity());
+                if (newAssigned.compareTo(BigDecimal.ZERO) < 0) {
+                    newAssigned = BigDecimal.ZERO;
+                }
+                productionPlan.setAssignedQuantity(newAssigned);
+                BigDecimal volume = productionPlan.getVolume() == null ? BigDecimal.ZERO : productionPlan.getVolume();
+                int status;
+                if (newAssigned.compareTo(BigDecimal.ZERO) == 0) {
+                    status = 0; // 鏈笅鍙�
+                } else if (newAssigned.compareTo(volume) < 0) {
+                    status = 1; // 閮ㄥ垎涓嬪彂
+                } else {
+                    status = 2; // 宸蹭笅鍙�
+                }
+                productionPlan.setStatus(status);
+                productionPlanMapper.updateById(productionPlan);
+            }
         }
-        // 鍒犻櫎鍏宠仈鍏崇郴
-        productOrderPlanMapper.delete(Wrappers.<ProductOrderPlan>lambdaQuery().in(ProductOrderPlan::getProductOrderId, productOrder.getId()));
-        // 鍒犻櫎璁㈠崟
-        productOrderMapper.deleteById(productOrder.getId());
-        // todo 鍒犻櫎璁㈠崟涓嬬殑宸ヨ壓璺嚎瀛愯〃
-        return null;
+
+        // 灏嗚鍗曠姸鎬佹敼涓哄凡鍙栨秷
+        for (ProductOrder order : orders) {
+            order.setStatus(ProductOrderStatusEnum.CANCEL.getCode());
+        }
+        updateBatchById(orders);
+
+        return true;
     }
 
     @Override
@@ -166,32 +194,40 @@
 
     @Override
     public Boolean addProductOrder(ProductOrder productOrder) {
-        String string = generateNextOrderNo(LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd")));
-        productOrder.setNpsNo(string);
+        fillAndSaveProductOrder(productOrder);
+        return true;
+    }
+
+    @Override
+    public Long insertProductOrder(ProductOrder productOrder) {
+        fillAndSaveProductOrder(productOrder);
+        return productOrder.getId();
+    }
+
+    private void fillAndSaveProductOrder(ProductOrder productOrder) {
+        String orderNo = generateNextOrderNo(LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd")));
+        productOrder.setNpsNo(orderNo);
         productOrder.setCompleteQuantity(BigDecimal.ZERO);
         this.save(productOrder);
         if (ObjectUtils.isNotEmpty(productOrder.getRouteId())) {
             this.bindingRoute(productOrder);
         }
-        return true;
     }
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public Boolean delete(Long[] ids) {
-        List<ProductOrder> orders = productOrderMapper.selectList(Wrappers.<ProductOrder>lambdaQuery().in(ProductOrder::getId, ids));
+    public Boolean delete(Long id) {
+        ProductOrder order = productOrderMapper.selectById(id);
 
-        if (orders.isEmpty()) {
+        if (order == null) {
             throw new RuntimeException("鐢熶骇璁㈠崟涓嶅瓨鍦�");
         }
-        for (ProductOrder order : orders) {
-            if (!ProductOrderStatusEnum.canDelete(order.getStatus())) {
-                throw new RuntimeException("鍙湁銆愬緟寮�濮嬨�佸凡鍙栨秷銆戠姸鎬佺殑璁㈠崟鎵嶅彲浠ュ垹闄�");
-            }
+        if (!ProductOrderStatusEnum.canDelete(order.getStatus())) {
+            throw new RuntimeException("鍙湁銆愬緟寮�濮嬨�佸凡鍙栨秷銆戠姸鎬佺殑璁㈠崟鎵嶅彲浠ュ垹闄�");
         }
 
         //  鏄惁宸茬敓浜�
-        List<ProductWorkOrder> productWorkOrders = productWorkOrderMapper.selectList(Wrappers.<ProductWorkOrder>lambdaQuery().in(ProductWorkOrder::getProductOrderId, ids));
+        List<ProductWorkOrder> productWorkOrders = productWorkOrderMapper.selectList(Wrappers.<ProductWorkOrder>lambdaQuery().eq(ProductWorkOrder::getProductOrderId, id));
 
         if (!productWorkOrders.isEmpty()) {
             List<Long> workOrderIds = productWorkOrders.stream()
@@ -204,11 +240,11 @@
             }
 
             //  鍒犻櫎宸ュ崟
-            productWorkOrderMapper.delete(Wrappers.<ProductWorkOrder>lambdaQuery().in(ProductWorkOrder::getProductOrderId, ids));
+            productWorkOrderMapper.delete(Wrappers.<ProductWorkOrder>lambdaQuery().eq(ProductWorkOrder::getProductOrderId, id));
         }
 
         //  鍥為��鐢熶骇璁″垝
-        List<ProductOrderPlan> productOrderPlans = productOrderPlanMapper.selectList(Wrappers.<ProductOrderPlan>lambdaQuery().in(ProductOrderPlan::getProductOrderId, ids));
+        List<ProductOrderPlan> productOrderPlans = productOrderPlanMapper.selectList(Wrappers.<ProductOrderPlan>lambdaQuery().eq(ProductOrderPlan::getProductOrderId, id));
 
         for (ProductOrderPlan productOrderPlan : productOrderPlans) {
             ProductionPlan productionPlan = productionPlanMapper.selectById(productOrderPlan.getProductionPlanId());
@@ -239,14 +275,13 @@
         }
 
         // 鍒犻櫎涓棿琛�
-        productOrderPlanMapper.delete(Wrappers.<ProductOrderPlan>lambdaQuery().in(ProductOrderPlan::getProductOrderId, ids));
+        productOrderPlanMapper.delete(Wrappers.<ProductOrderPlan>lambdaQuery().eq(ProductOrderPlan::getProductOrderId, id));
 
-        // TODO: 鍒犻櫎闄勮〃鐨勫伐鑹鸿矾绾夸笌BOM
-        productProcessRouteItemMapper.delete(new LambdaQueryWrapper<ProductProcessRouteItem>().in(ProductProcessRouteItem::getProductOrderId, ids));
-        productProcessRouteMapper.delete(new LambdaQueryWrapper<ProductProcessRoute>().in(ProductProcessRoute::getProductOrderId, ids));
+        //  鍒犻櫎闄勮〃鐨勫伐鑹鸿矾绾夸笌BOM
+        productionOrderAppendixService.deleteData(order.getId(), order.getRouteId());
 
         //  鍒犻櫎璁㈠崟
-        productOrderMapper.delete(new LambdaQueryWrapper<ProductOrder>().in(ProductOrder::getId, ids));
+        productOrderMapper.deleteById(id);
 
         return true;
     }
@@ -281,5 +316,17 @@
         return "SC" + datePrefix + String.format("%04d", sequence);
     }
 
+    @Override
+    public List<ProductOrderSourceDto> productOrderSource(Long orderId) {
+        if (orderId == null) {
+            throw new ServiceException("鏌ヨ璁㈠崟鏁版嵁涓嶈兘涓虹┖");
+        }
+        ProductOrder productOrder = getById(orderId);
+        if (productOrder == null) {
+            throw new ServiceException("鏌ヨ澶辫触,鐢熶骇璁㈠崟涓嶅瓨鍦�");
+        }
 
+        List<ProductOrderSourceDto> list = baseMapper.productOrderSource(orderId);
+        return list;
+    }
 }

--
Gitblit v1.9.3