From 467615249613c312a984097d3ebb673ebef3e10d Mon Sep 17 00:00:00 2001
From: gongchunyi <deslre0381@gmail.com>
Date: 星期五, 20 三月 2026 16:08:58 +0800
Subject: [PATCH] fix: 生产订单内的工艺路线新增工序时基本参数未同步到子表
---
src/main/java/com/ruoyi/production/service/impl/ProductOrderServiceImpl.java | 118 +++++++++++++++++++++++++++++++++++++++--------------------
1 files changed, 78 insertions(+), 40 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 7ee2e65..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,19 +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.appendix.service.AppendixService;
+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;
@@ -76,7 +77,7 @@
private StockUtils stockUtils;
@Autowired
- private AppendixService appendixService;
+ private IProductionOrderAppendixService productionOrderAppendixService;
@Override
public IPage<ProductOrderDto> pageProductOrder(Page<ProductOrder> page, ProductOrderDto productOrder) {
@@ -137,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
@@ -170,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()
@@ -208,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());
@@ -243,19 +275,13 @@
}
// 鍒犻櫎涓棿琛�
- productOrderPlanMapper.delete(Wrappers.<ProductOrderPlan>lambdaQuery().in(ProductOrderPlan::getProductOrderId, ids));
+ productOrderPlanMapper.delete(Wrappers.<ProductOrderPlan>lambdaQuery().eq(ProductOrderPlan::getProductOrderId, id));
// 鍒犻櫎闄勮〃鐨勫伐鑹鸿矾绾夸笌BOM
- for (Long id : ids) {
- ProductOrder productOrder = baseMapper.selectById(id);
- appendixService.deleteData(productOrder.getRouteId());
- }
-
-// productProcessRouteItemMapper.delete(new LambdaQueryWrapper<ProductProcessRouteItem>().in(ProductProcessRouteItem::getProductOrderId, ids));
-// productProcessRouteMapper.delete(new LambdaQueryWrapper<ProductProcessRoute>().in(ProductProcessRoute::getProductOrderId, ids));
+ productionOrderAppendixService.deleteData(order.getId(), order.getRouteId());
// 鍒犻櫎璁㈠崟
- productOrderMapper.delete(new LambdaQueryWrapper<ProductOrder>().in(ProductOrder::getId, ids));
+ productOrderMapper.deleteById(id);
return true;
}
@@ -290,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