From a76e1d17d67641993dea6335cb8e1465a94df58d Mon Sep 17 00:00:00 2001
From: liding <756868258@qq.com>
Date: 星期四, 21 五月 2026 15:39:05 +0800
Subject: [PATCH] feat(stock): 优化库存管理和成品树结构功能 1- 为ApproveProcessMapper.xml和ProductBomMapper.xml添加排序功能 2- 在ProductionProductMainDto中新增bomInputQty字段用于产品结构投入数量 3- 修改ProductionProductMainServiceImpl中投入数量计算逻辑,使用前端传入的bomInputQty值 4- 在ProductWorkOrderDto中添加bomInputQty字段并在服务实现中计算标准投入数量 5- 更新SalesLedgerMapper.xml查询逻辑,从product_summary获取电压信息 6- 为SalesLedgerProduct添加stockId字段并修改库存扣减逻辑使用具体库存ID 7- 重构StockInventoryController中的成品库存树查询接口和导入导出功能 8- 新增成品和非成品库存导入导出的数据模型和Excel工具类 9- 优化StockInventoryServiceImpl中的库存扣减逻辑,支持按特定库存ID操作 10- 更新库存导入导出功能,区分成品和非成品类型并提供相应模板

---
 src/main/java/com/ruoyi/stock/service/impl/StockOutRecordServiceImpl.java |  155 ++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 152 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/ruoyi/stock/service/impl/StockOutRecordServiceImpl.java b/src/main/java/com/ruoyi/stock/service/impl/StockOutRecordServiceImpl.java
index 3e2d0f2..08be3ba 100644
--- a/src/main/java/com/ruoyi/stock/service/impl/StockOutRecordServiceImpl.java
+++ b/src/main/java/com/ruoyi/stock/service/impl/StockOutRecordServiceImpl.java
@@ -1,10 +1,37 @@
 package com.ruoyi.stock.service.impl;
 
-import com.ruoyi.stock.pojo.StockOutRecord;
-import com.ruoyi.stock.mapper.StockOutRecordMapper;
-import com.ruoyi.stock.service.StockOutRecordService;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.common.enums.StockOutQualifiedRecordTypeEnum;
+import com.ruoyi.common.enums.StockInUnQualifiedRecordTypeEnum;
+import com.ruoyi.common.enums.StockOutUnQualifiedRecordTypeEnum;
+import com.ruoyi.common.exception.base.BaseException;
+import com.ruoyi.common.utils.EnumUtil;
+import com.ruoyi.common.utils.OrderUtils;
+import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.common.utils.bean.BeanUtils;
+import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.stock.dto.StockInventoryDto;
+import com.ruoyi.stock.dto.StockOutRecordDto;
+import com.ruoyi.stock.dto.StockUninventoryDto;
+import com.ruoyi.stock.execl.StockOutRecordExportData;
+import com.ruoyi.stock.mapper.StockInventoryMapper;
+import com.ruoyi.stock.mapper.StockOutRecordMapper;
+import com.ruoyi.stock.mapper.StockUninventoryMapper;
+import com.ruoyi.stock.pojo.StockInRecord;
+import com.ruoyi.stock.pojo.StockInventory;
+import com.ruoyi.stock.pojo.StockOutRecord;
+import com.ruoyi.stock.pojo.StockUninventory;
+import com.ruoyi.stock.service.StockOutRecordService;
+import lombok.AllArgsConstructor;
 import org.springframework.stereotype.Service;
+
+import javax.servlet.http.HttpServletResponse;
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import java.util.List;
 
 /**
  * <p>
@@ -15,6 +42,128 @@
  * @since 2026-01-21 05:27:04
  */
 @Service
+@AllArgsConstructor
 public class StockOutRecordServiceImpl extends ServiceImpl<StockOutRecordMapper, StockOutRecord> implements StockOutRecordService {
+    private StockOutRecordMapper stockOutRecordMapper;
+    private StockInventoryMapper stockInventoryMapper;
+    private StockUninventoryMapper stockUninventoryMapper;
 
+    @Override
+    public IPage<StockOutRecordDto> listPage(Page page, StockOutRecordDto stockOutRecordDto) {
+        IPage<StockOutRecordDto> result = stockOutRecordMapper.listPage(page, stockOutRecordDto);
+        for (StockOutRecordDto record : result.getRecords()) {
+            record.setRecordTypeName(resolveRecordTypeName(record.getType(), record.getRecordType(), record.getProcessName()));
+        }
+        return result;
+    }
+
+    @Override
+    public int add(StockOutRecordDto stockOutRecordDto) {
+        String no = OrderUtils.countTodayByCreateTime(stockOutRecordMapper, "CK");
+        stockOutRecordDto.setOutboundBatches(no);
+        StockInRecord stockInRecord = new StockInRecord();
+        BeanUtils.copyProperties(stockOutRecordDto, stockInRecord);
+        return stockOutRecordMapper.insert(stockOutRecordDto);
+    }
+
+    @Override
+    public int update(Long id, StockOutRecordDto stockOutRecordDto) {
+        // 鍒ゆ柇瀵硅薄鏄惁瀛樺湪
+        StockOutRecord stockOutRecord = stockOutRecordMapper.selectById(id);
+        if (stockOutRecord == null){
+            throw new BaseException("璇ュ嚭搴撹褰曚笉瀛樺湪,鏃犳硶鏇存柊!!!");
+        }
+
+        String[] ignoreProperties = {"id", "outbound_batches"};//鎺掗櫎id灞炴��
+        BeanUtils.copyProperties(stockOutRecordDto, stockOutRecord, ignoreProperties);
+        return stockOutRecordMapper.updateById(stockOutRecord);
+    }
+
+    @Override
+    public int batchDelete(List<Long> ids) {
+        for (Long id : ids) {
+            StockOutRecord stockOutRecord = stockOutRecordMapper.selectById(id);
+            if (stockOutRecord.getType().equals("0")) {
+                // 鏌ヨ璇ヤ骇鍝佽鏍肩殑鎵�鏈夊簱瀛樿褰曪紝鎸塈D鍗囧簭锛堜笌鍑哄簱鎵e噺椤哄簭涓�鑷达級
+                List<StockInventory> stockInventoryList = stockInventoryMapper.selectList(
+                    new LambdaQueryWrapper<StockInventory>()
+                        .eq(StockInventory::getProductModelId, stockOutRecord.getProductModelId())
+                        .orderByAsc(StockInventory::getId)
+                );
+                if (stockInventoryList.isEmpty()) {
+                    throw new BaseException("搴撳瓨璁板綍涓病鏈夊搴旂殑浜у搧,鏃犳硶鍒犻櫎!!!");
+                }
+                
+                // 鎸夌収鍑哄簱鎵e噺閫昏緫鍙嶅悜鍥炴粴
+                BigDecimal remainingQty = stockOutRecord.getStockOutNum();
+                for (StockInventory stockInventory : stockInventoryList) {
+                    if (remainingQty.compareTo(BigDecimal.ZERO) <= 0) {
+                        break;
+                    }
+                    
+                    BigDecimal lockedQty = stockInventory.getLockedQuantity() == null ? BigDecimal.ZERO : stockInventory.getLockedQuantity();
+                    BigDecimal availableQty = stockInventory.getQualitity().subtract(lockedQty);
+                    if (availableQty.compareTo(BigDecimal.ZERO) <= 0) {
+                        continue;
+                    }
+                    
+                    // 澧炲姞鏁伴噺 = min(鍓╀綑闇�杩旇繕鏁伴噺, 褰撳墠鎵规鍙敤搴撳瓨)
+                    BigDecimal addQty = remainingQty.min(availableQty);
+                    stockInventory.setQualitity(stockInventory.getQualitity().add(addQty));
+                    stockInventory.setVersion(stockInventory.getVersion() == null ? 1 : stockInventory.getVersion() + 1);
+                    stockInventory.setUpdateTime(LocalDateTime.now());
+                    stockInventoryMapper.updateById(stockInventory);
+                    
+                    remainingQty = remainingQty.subtract(addQty);
+                }
+            }else if (stockOutRecord.getType().equals("1")) {
+                StockUninventory stockUninventory = stockUninventoryMapper.selectOne(new LambdaQueryWrapper<StockUninventory>().eq(StockUninventory::getProductModelId, stockOutRecord.getProductModelId()));
+                if (stockUninventory == null) {
+                    throw new BaseException("搴撳瓨璁板綍涓病鏈夊搴旂殑浜у搧,鏃犳硶鍒犻櫎!!!");
+                }else {
+                    StockUninventoryDto stockUninventoryDto = new StockUninventoryDto();
+                    stockUninventoryDto.setProductModelId(stockUninventory.getProductModelId());
+                    stockUninventoryDto.setQualitity(stockOutRecord.getStockOutNum());
+                    stockUninventoryMapper.updateAddStockUnInventory(stockUninventoryDto);
+                }
+            }
+        }
+        return stockOutRecordMapper.deleteBatchIds(ids);
+    }
+
+    @Override
+    public void exportStockOutRecord(HttpServletResponse response, StockOutRecordDto stockOutRecordDto) {
+        List<StockOutRecordExportData> list = stockOutRecordMapper.listStockOutRecordExportData(stockOutRecordDto);
+        for (StockOutRecordExportData stockInRecordExportData : list) {
+            if (stockInRecordExportData.getType().equals("0")) {
+                stockInRecordExportData.setRecordType(resolveQualifiedRecordType(stockInRecordExportData.getRecordType(), stockInRecordExportData.getProcessName()));
+            }else {
+                stockInRecordExportData.setRecordType(EnumUtil.fromCode(StockOutUnQualifiedRecordTypeEnum.class, Integer.parseInt(stockInRecordExportData.getRecordType())).getValue());
+            }
+        }
+        ExcelUtil<StockOutRecordExportData> util = new ExcelUtil<>(StockOutRecordExportData.class);
+        util.exportExcel(response,list, "鍑哄簱璁板綍淇℃伅");
+    }
+
+    private String resolveRecordTypeName(String type, String recordType, String processName) {
+        if ("0".equals(type)) {
+            return resolveQualifiedRecordType(recordType, processName);
+        }
+        return EnumUtil.fromCode(StockOutUnQualifiedRecordTypeEnum.class, Integer.parseInt(recordType)).getValue();
+    }
+
+    private String resolveQualifiedRecordType(String recordType, String processName) {
+        if (StockOutQualifiedRecordTypeEnum.PRODUCTION_REPORT_STOCK_OUT.getCode().equals(recordType)
+                && StringUtils.isNotEmpty(processName)) {
+            return "鐢熶骇鎶ュ伐-" + processName + "-鍑哄簱";
+        }
+        if (recordType == null) {
+            return null;
+        }
+        try {
+            return EnumUtil.fromCode(StockOutQualifiedRecordTypeEnum.class, Integer.parseInt(recordType)).getValue();
+        } catch (NumberFormatException ex) {
+            return recordType;
+        }
+    }
 }

--
Gitblit v1.9.3