From 17a63200983a8e154a1eb3549d1caffa050372c1 Mon Sep 17 00:00:00 2001
From: liding <756868258@qq.com>
Date: 星期一, 30 三月 2026 17:14:45 +0800
Subject: [PATCH] feat:1.生产订单领用 2.报工领用（关联订单领用） 3.报工删除（关联报工领用） 4.不合格处理（返工生成返工附件并下载）
---
src/main/java/com/ruoyi/production/service/impl/ProductOrderServiceImpl.java | 76 +++++++++++++++++++++++++++++++++++++-
1 files changed, 74 insertions(+), 2 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 43be949..3d694ca 100644
--- a/src/main/java/com/ruoyi/production/service/impl/ProductOrderServiceImpl.java
+++ b/src/main/java/com/ruoyi/production/service/impl/ProductOrderServiceImpl.java
@@ -4,22 +4,29 @@
import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
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.basic.dto.SelectOptionDTO;
+import com.ruoyi.common.enums.StockOutQualifiedRecordTypeEnum;
import com.ruoyi.common.exception.base.BaseException;
+import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.procurementrecord.utils.StockUtils;
+import com.ruoyi.production.dto.DrawMaterialDto;
import com.ruoyi.production.dto.ProductOrderDto;
import com.ruoyi.production.dto.ProductStructureDto;
import com.ruoyi.production.mapper.*;
import com.ruoyi.production.pojo.*;
import com.ruoyi.production.service.ProductOrderService;
import com.ruoyi.quality.mapper.QualityInspectMapper;
+import com.ruoyi.stock.mapper.StockInventoryMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import java.math.BigDecimal;
import java.time.LocalDate;
@@ -66,6 +73,13 @@
@Autowired
private StockUtils stockUtils;
+
+ @Autowired
+ private ProductStructureMapper productStructureMapper;
+
+ @Autowired
+ private StockInventoryMapper stockInventoryMapper;
+
@Override
public IPage<ProductOrderDto> pageProductOrder(Page page, ProductOrderDto productOrder) {
@@ -161,11 +175,11 @@
//濡傛灉宸茬粡寮�濮嬬敓浜�,涓嶈兘鍒犻櫎
//鏌ヨ鐢熶骇璁㈠崟涓嬬殑宸ュ崟
List<ProductWorkOrder> productWorkOrders = productWorkOrderMapper.selectList(Wrappers.<ProductWorkOrder>lambdaQuery().in(ProductWorkOrder::getProductOrderId, ids));
- if (productWorkOrders.size()>0){
+ if (productWorkOrders.size() > 0) {
//鍒ゆ柇鏄惁鏈夋姤宸ユ暟鎹�
List<ProductionProductMain> productionProductMains = productionProductMainMapper.selectList(Wrappers.<ProductionProductMain>lambdaQuery()
.in(ProductionProductMain::getWorkOrderId, productWorkOrders.stream().map(ProductWorkOrder::getId).collect(Collectors.toList())));
- if (productionProductMains.size()>0){
+ if (productionProductMains.size() > 0) {
throw new RuntimeException("鐢熶骇璁㈠崟宸茬粡寮�濮嬬敓浜�,涓嶈兘鍒犻櫎");
}
//鍒犻櫎宸ュ崟
@@ -236,4 +250,62 @@
List<ProductOrder> productOrders = productOrderMapper.selectList(null);
return productOrders.stream().map(productOrder -> new SelectOptionDTO<>(productOrder.getBatchNo(), productOrder.getBatchNo())).collect(Collectors.toList());
}
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public int drawMaterials(ProductOrderDto productOrderDto) {
+ if (productOrderDto == null || productOrderDto.getId() == null) {
+ throw new RuntimeException("鍙傛暟閿欒");
+ }
+
+ String jsonString = productOrderDto.getDrawMaterials();
+ if (StringUtils.isEmpty(jsonString)) {
+ throw new RuntimeException("棰嗘枡鏄庣粏涓嶈兘涓虹┖");
+ }
+
+ List<DrawMaterialDto> drawMaterialsList;
+ try {
+ drawMaterialsList = JSON.parseArray(jsonString, DrawMaterialDto.class);
+ } catch (Exception e) {
+ throw new RuntimeException("棰嗘枡鏄庣粏鏍煎紡閿欒");
+ }
+
+ if (CollectionUtils.isEmpty(drawMaterialsList)) {
+ throw new RuntimeException("棰嗘枡鏄庣粏涓嶈兘涓虹┖");
+ }
+ // 濡傛灉鏈夋暟鎹厛鍔犲簱瀛�
+ ProductOrder productOrder = productOrderMapper.selectById(productOrderDto.getId());
+ if (productOrder != null) {
+ List<DrawMaterialDto> materialDtoList = JSON.parseArray(productOrder.getDrawMaterials(), DrawMaterialDto.class);
+ for (DrawMaterialDto drawMaterialDto : materialDtoList) {
+ stockUtils.addStock(drawMaterialDto.getProductModelId(), drawMaterialDto.getRequisitionQty(), null, productOrderDto.getId());
+ }
+ }
+
+ // 澶勭悊棰嗘枡锛堟墸鍑忓簱瀛橈級
+ try {
+ for (DrawMaterialDto drawMaterialDto : drawMaterialsList) {
+ if (drawMaterialDto.getProductModelId() == null) {
+ throw new RuntimeException("浜у搧鍨嬪彿ID涓嶈兘涓虹┖");
+ }
+ stockUtils.substractStock(drawMaterialDto.getProductModelId(), drawMaterialDto.getRequisitionQty(), StockOutQualifiedRecordTypeEnum.DRAW_MATERIALS_STOCK_OUT.getCode(), productOrderDto.getId());
+ }
+ } catch (Exception e) {
+ throw new RuntimeException("棰嗘枡澶辫触锛�" + e.getMessage());
+ }
+
+ // JSON瀛楃涓插瓨鍌�
+ String newJsonString = JSON.toJSONString(drawMaterialsList);
+ int update = productOrderMapper.update(null,
+ new LambdaUpdateWrapper<ProductOrder>()
+ .eq(ProductOrder::getId, productOrderDto.getId())
+ .set(ProductOrder::getDrawMaterials, newJsonString));
+
+ // 鏍￠獙鏇存柊缁撴灉
+ if (update == 0) {
+ throw new RuntimeException("鏇存柊璁㈠崟澶辫触");
+ }
+
+ return update;
+ }
}
--
Gitblit v1.9.3