feat: 报工投入用“投入重量/数量”

liding

6 天以前 6256daf29f4c44944fa71a7dbd211b06bf1a495d

 src/main/java/com/ruoyi/production/service/impl/ProductWorkOrderServiceImpl.java

@@ -11,6 +11,7 @@
import com.deepoove.poi.data.Pictures;
import com.ruoyi.common.utils.MatrixToImageWriter;
import com.ruoyi.production.dto.ProductWorkOrderDto;
import com.ruoyi.production.dto.ProductStructureDto;
import com.ruoyi.production.mapper.*;
import com.ruoyi.production.pojo.*;
import com.ruoyi.production.service.ProductWorkOrderService;
@@ -30,6 +31,7 @@
import java.math.RoundingMode;
import java.net.URLEncoder;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;

@Service
@@ -44,6 +46,10 @@
    private ProductProcessRouteItemMapper productProcessRouteItemMapper;
    @Autowired
    private ProductProcessMapper productProcessMapper;
    @Autowired
    private ProductProcessRouteMapper productProcessRouteMapper;
    @Autowired
    private ProductStructureMapper productStructureMapper;
    @Autowired
    private ProductionProductMainMapper productionProductMainMapper;
    @Autowired
@@ -61,6 +67,7 @@
    @Override
    public IPage<ProductWorkOrderDto> listPage(Page<ProductWorkOrderDto> page, ProductWorkOrderDto productWorkOrder) {
        IPage<ProductWorkOrderDto> productWorkOrderDtoIPage = productWorkOrdermapper.pageProductWorkOrder(page, productWorkOrder);
        Map<String, BigDecimal> bomInputQtyCache = new HashMap<>();
        productWorkOrderDtoIPage.getRecords().forEach(record -> {
            // 是否能报工： 1. 第一个工序能报工 2. 上一个工序已报工 3. 之前的工序未被隔离
            Integer currentDragSort = record.getDragSort();
@@ -126,6 +133,62 @@
            } else {
                record.setActualQualifiedRate((record.getCompleteQuantity().subtract(totalScrapQty)).multiply(BigDecimal.valueOf(100)));
            }

            // 查询当前工单对应产品结构中的标准投入数量
            String bomInputQtyCacheKey = record.getProductRouteId() + "_" + record.getProcessId() + "_" + record.getPlanQuantity();
            BigDecimal bomInputQty = bomInputQtyCache.get(bomInputQtyCacheKey);
            if (bomInputQty == null) {
                bomInputQty = BigDecimal.ZERO;
                ProductProcessRoute productProcessRoute = productProcessRouteMapper.selectById(record.getProductRouteId());
                if (productProcessRoute != null && productProcessRoute.getBomId() != null && record.getProcessId() != null) {
                    List<ProductStructureDto> productStructureDtos = productStructureMapper.listBybomAndProcess(
                            productProcessRoute.getBomId(),
                            record.getProcessId()
                    );

                    if (CollectionUtils.isEmpty(productStructureDtos)) {
                        bomInputQty = record.getPlanQuantity() == null ? BigDecimal.ZERO : record.getPlanQuantity();
                    } else {
                        Set<Long> parentIds = productStructureDtos.stream()
                                .map(ProductStructureDto::getParentId)
                                .filter(Objects::nonNull)
                                .collect(Collectors.toSet());

                        Map<Long, ProductStructureDto> parentMap = new HashMap<>();
                        if (CollectionUtils.isNotEmpty(parentIds)) {
                            parentMap = productStructureMapper.selectByIds(parentIds)
                                    .stream()
                                    .collect(Collectors.toMap(ProductStructureDto::getId, Function.identity(), (a, b) -> a));
                        }

                        BigDecimal planQty = record.getPlanQuantity() == null ? BigDecimal.ZERO : record.getPlanQuantity();
                        for (ProductStructureDto productStructureDto : productStructureDtos) {
                            BigDecimal childQty = productStructureDto.getUnitQuantity();
                            if (childQty == null || childQty.compareTo(BigDecimal.ZERO) <= 0) {
                                continue;
                            }

                            BigDecimal parentQty = BigDecimal.ONE;
                            if (productStructureDto.getParentId() != null) {
                                ProductStructureDto parent = parentMap.get(productStructureDto.getParentId());
                                if (parent != null && parent.getUnitQuantity() != null && parent.getUnitQuantity().compareTo(BigDecimal.ZERO) > 0) {
                                    parentQty = parent.getUnitQuantity();
                                }
                            }

                            if (parentQty.compareTo(BigDecimal.ZERO) <= 0) {
                                continue;
                            }

                            bomInputQty = bomInputQty.add(
                                    childQty.divide(parentQty, 6, RoundingMode.HALF_UP).multiply(planQty)
                            );
                        }
                    }
                }
                bomInputQtyCache.put(bomInputQtyCacheKey, bomInputQty);
            }
            record.setBomInputQty(bomInputQty);
        });
        return productWorkOrderDtoIPage;
    }