产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liding
2026-04-23 8e4456bfa6dc84a1c37c13ee515fa9d6347cc480 
 src/main/java/com/ruoyi/production/service/impl/ProductionOrderServiceImpl.java


@@ -5,59 +5,34 @@


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.StorageBlobVO;


import com.ruoyi.basic.mapper.StorageAttachmentMapper;


import com.ruoyi.basic.mapper.StorageBlobMapper;


import com.ruoyi.basic.pojo.StorageAttachment;


import com.ruoyi.basic.pojo.StorageBlob;


import com.ruoyi.basic.utils.FileUtil;


import com.ruoyi.common.constant.StorageAttachmentConstants;


import com.ruoyi.common.exception.ServiceException;


import com.ruoyi.production.bean.dto.ProductionOrderDto;


import com.ruoyi.production.bean.vo.ProductionOrderVo;


import com.ruoyi.production.mapper.ProductionBomStructureMapper;


import com.ruoyi.production.mapper.ProductionOperationTaskMapper;


import com.ruoyi.production.mapper.ProductionOrderBomMapper;


import com.ruoyi.production.mapper.ProductionOrderMapper;


import com.ruoyi.production.mapper.ProductionOrderPickMapper;


import com.ruoyi.production.mapper.ProductionOrderPickRecordMapper;


import com.ruoyi.production.mapper.ProductionOrderRoutingMapper;


import com.ruoyi.production.mapper.ProductionOrderRoutingOperationMapper;


import com.ruoyi.production.mapper.ProductionOrderRoutingOperationParamMapper;


import com.ruoyi.production.mapper.ProductionPlanMapper;


import com.ruoyi.production.mapper.ProductionProductMainMapper;


import com.ruoyi.production.pojo.ProductionOrderPick;


import com.ruoyi.production.pojo.ProductionOrderPickRecord;


import com.ruoyi.production.pojo.ProductionBomStructure;


import com.ruoyi.production.pojo.ProductionOperationTask;


import com.ruoyi.production.pojo.ProductionOrder;


import com.ruoyi.production.pojo.ProductionOrderBom;


import com.ruoyi.production.pojo.ProductionOrderRouting;


import com.ruoyi.production.pojo.ProductionOrderRoutingOperation;


import com.ruoyi.production.pojo.ProductionOrderRoutingOperationParam;


import com.ruoyi.production.pojo.ProductionPlan;


import com.ruoyi.production.pojo.ProductionProductMain;


import com.ruoyi.production.enums.ProductOrderStatusEnum;


import com.ruoyi.production.mapper.*;


import com.ruoyi.production.pojo.*;


import com.ruoyi.production.service.ProductionOrderService;


import com.ruoyi.technology.mapper.TechnologyBomMapper;


import com.ruoyi.technology.mapper.TechnologyBomStructureMapper;


import com.ruoyi.technology.mapper.TechnologyRoutingMapper;


import com.ruoyi.technology.mapper.TechnologyRoutingOperationMapper;


import com.ruoyi.technology.mapper.TechnologyRoutingOperationParamMapper;


import com.ruoyi.technology.pojo.TechnologyBom;


import com.ruoyi.technology.pojo.TechnologyBomStructure;


import com.ruoyi.technology.pojo.TechnologyRouting;


import com.ruoyi.technology.pojo.TechnologyRoutingOperation;


import com.ruoyi.technology.pojo.TechnologyRoutingOperationParam;


import com.ruoyi.sales.mapper.SalesLedgerMapper;


import com.ruoyi.sales.mapper.SalesLedgerProductMapper;


import com.ruoyi.sales.pojo.SalesLedger;


import com.ruoyi.sales.pojo.SalesLedgerProduct;


import com.ruoyi.technology.mapper.*;


import com.ruoyi.technology.pojo.*;


import lombok.RequiredArgsConstructor;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import java.math.BigDecimal;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.format.DateTimeFormatter;


import java.util.ArrayList;


import java.util.Comparator;


import java.util.HashMap;


import java.util.LinkedHashSet;


import java.util.List;


import java.util.Map;


import java.util.Objects;


import java.util.Set;


import java.util.*;


import java.util.stream.Collectors;




@Service


@@ -75,27 +50,39 @@


    private final ProductionOrderPickMapper productionOrderPickMapper;


    private final ProductionOrderPickRecordMapper productionOrderPickRecordMapper;


    private final ProductionPlanMapper productionPlanMapper;


    private final StorageAttachmentMapper storageAttachmentMapper;


    private final StorageBlobMapper storageBlobMapper;


    private final SalesLedgerMapper salesLedgerMapper;


    private final SalesLedgerProductMapper salesLedgerProductMapper;


    private final TechnologyRoutingMapper technologyRoutingMapper;


    private final TechnologyRoutingOperationMapper technologyRoutingOperationMapper;


    private final TechnologyRoutingOperationParamMapper technologyRoutingOperationParamMapper;


    private final TechnologyBomMapper technologyBomMapper;


    private final TechnologyBomStructureMapper technologyBomStructureMapper;


    private final FileUtil fileUtil;




    @Override


    public com.baomidou.mybatisplus.core.metadata.IPage<ProductionOrderVo> pageProductionOrder(Page<ProductionOrderDto> page, ProductionOrderDto dto) {


        Page<ProductionOrder> entityPage = new Page<>(page.getCurrent(), page.getSize(), page.getTotal());


        return this.page(entityPage, buildQueryWrapper(dto)).convert(item -> BeanUtil.copyProperties(item, ProductionOrderVo.class));


        Page<ProductionOrderVo> result = (Page<ProductionOrderVo>) baseMapper.pageProductionOrder(page, dto);


        fillProductImages(result.getRecords());


        return result;


    }




    @Override


    public List<ProductionOrderVo> listProductionOrder(ProductionOrderDto dto) {


        return BeanUtil.copyToList(this.list(buildQueryWrapper(dto)), ProductionOrderVo.class);


        List<ProductionOrderVo> records = baseMapper.listProductionOrder(dto);


        fillProductImages(records);


        return records;


    }




    @Override


    public ProductionOrderVo getProductionOrderInfo(Long id) {


        ProductionOrder item = this.getById(id);


        return item == null ? null : BeanUtil.copyProperties(item, ProductionOrderVo.class);


        ProductionOrderVo item = baseMapper.getProductionOrderInfo(id);


        if (item == null) {


            return null;


        }


        fillProductImages(java.util.Collections.singletonList(item));


        return item;


    }




    @Override


@@ -312,6 +299,7 @@


        ProductionOrder query = dto == null ? new ProductionOrder() : dto;


        return Wrappers.<ProductionOrder>lambdaQuery()


                .eq(query.getId() != null, ProductionOrder::getId, query.getId())


                .eq(query.getSalesLedgerId() != null, ProductionOrder::getSalesLedgerId, query.getSalesLedgerId())


                .eq(query.getProductModelId() != null, ProductionOrder::getProductModelId, query.getProductModelId())


                .eq(query.getTechnologyRoutingId() != null, ProductionOrder::getTechnologyRoutingId, query.getTechnologyRoutingId())


                .like(query.getNpsNo() != null && !query.getNpsNo().trim().isEmpty(), ProductionOrder::getNpsNo, query.getNpsNo())


@@ -363,9 +351,10 @@


        if (productionOrder == null) {


            throw new ServiceException("Production order is required");


        }


        fillFromSalesLedgerProduct(productionOrder);


        fillFromProductionPlans(productionOrder);


        if (productionOrder.getProductModelId() == null) {


            throw new ServiceException("productModelId is required when manually creating a production order");


            throw new ServiceException("productModelId is required");


        }


        if (defaultDecimal(productionOrder.getQuantity()).compareTo(BigDecimal.ZERO) <= 0) {


            throw new ServiceException("quantity must be greater than 0");


@@ -388,6 +377,36 @@


                    || !Objects.equals(oldOrder.getTechnologyRoutingId(), productionOrder.getTechnologyRoutingId())


                    || compareDecimal(oldOrder.getQuantity(), productionOrder.getQuantity()) != 0) {


                throw new ServiceException("Started production orders cannot modify product, routing or quantity");


            }


        }


    }




    private void fillFromSalesLedgerProduct(ProductionOrder productionOrder) {


        if (productionOrder.getSaleLedgerProductId() == null) {


            return;


        }


        // 销售明细是订单来源时，以销售明细为准回填销售台账、产品规格和默认数量。


        SalesLedgerProduct salesLedgerProduct = salesLedgerProductMapper.selectById(productionOrder.getSaleLedgerProductId().longValue());


        if (salesLedgerProduct == null) {


            throw new ServiceException("Sales ledger product not found");


        }


        if (productionOrder.getSalesLedgerId() == null) {


            productionOrder.setSalesLedgerId(salesLedgerProduct.getSalesLedgerId());


        } else if (!Objects.equals(productionOrder.getSalesLedgerId(), salesLedgerProduct.getSalesLedgerId())) {


            throw new ServiceException("salesLedgerId does not match the sales ledger product");


        }


        if (productionOrder.getProductModelId() == null) {


            productionOrder.setProductModelId(salesLedgerProduct.getProductModelId());


        } else if (!Objects.equals(productionOrder.getProductModelId(), salesLedgerProduct.getProductModelId())) {


            throw new ServiceException("productModelId does not match the sales ledger product");


        }


        if (productionOrder.getQuantity() == null || productionOrder.getQuantity().compareTo(BigDecimal.ZERO) <= 0) {


            productionOrder.setQuantity(salesLedgerProduct.getQuantity());


        }


        if (productionOrder.getPlanCompleteTime() == null && productionOrder.getSalesLedgerId() != null) {


            SalesLedger salesLedger = salesLedgerMapper.selectById(productionOrder.getSalesLedgerId());


            if (salesLedger != null && salesLedger.getDeliveryDate() != null) {


                productionOrder.setPlanCompleteTime(salesLedger.getDeliveryDate());


            }


        }


    }


@@ -536,10 +555,10 @@


            return null;


        }


        if (productionPlan.getPromisedDeliveryDate() != null) {


            return productionPlan.getPromisedDeliveryDate().toLocalDate();


            return productionPlan.getPromisedDeliveryDate();


        }


        if (productionPlan.getRequiredDate() != null) {


            return productionPlan.getRequiredDate().toLocalDate();


            return productionPlan.getRequiredDate();


        }


        return null;


    }


@@ -547,4 +566,65 @@


    private int compareDecimal(BigDecimal left, BigDecimal right) {


        return defaultDecimal(left).compareTo(defaultDecimal(right));


    }




    private void fillProductImages(List<ProductionOrderVo> records) {


        if (records == null || records.isEmpty()) {


            return;


        }


        List<Long> productModelIds = records.stream()


                .map(ProductionOrderVo::getProductModelId)


                .filter(Objects::nonNull)


                .distinct()


                .collect(Collectors.toList());


        if (productModelIds.isEmpty()) {


            return;


        }




        List<StorageAttachment> attachments = storageAttachmentMapper.selectList(


                Wrappers.<StorageAttachment>lambdaQuery()


                        .in(StorageAttachment::getRecordId, productModelIds)


                        .eq(StorageAttachment::getApplication, StorageAttachmentConstants.StorageAttachmentImage)


                        .eq(StorageAttachment::getDeleted, 0L)


                        .orderByAsc(StorageAttachment::getId));


        if (attachments == null || attachments.isEmpty()) {


            return;


        }




        Map<Long, List<StorageAttachment>> attachmentMap = attachments.stream()


                .collect(Collectors.groupingBy(StorageAttachment::getRecordId, java.util.LinkedHashMap::new, Collectors.toList()));


        List<Long> blobIds = attachments.stream()


                .map(StorageAttachment::getStorageBlobId)


                .filter(Objects::nonNull)


                .distinct()


                .collect(Collectors.toList());


        if (blobIds.isEmpty()) {


            return;


        }




        Map<Long, StorageBlob> blobMap = storageBlobMapper.selectBatchIds(blobIds).stream()


                .filter(Objects::nonNull)


                .collect(Collectors.toMap(StorageBlob::getId, item -> item));


        for (ProductionOrderVo record : records) {


            List<StorageAttachment> modelAttachments = attachmentMap.get(record.getProductModelId());


            if (modelAttachments == null || modelAttachments.isEmpty()) {


                continue;


            }


            List<StorageBlobVO> images = modelAttachments.stream()


                    .map(StorageAttachment::getStorageBlobId)


                    .map(blobMap::get)


                    .filter(Objects::nonNull)


                    .map(this::toStorageBlobVO)


                    .collect(Collectors.toList());


            if (!images.isEmpty()) {


                record.setProductImages(images);


            }


        }


    }




    private StorageBlobVO toStorageBlobVO(StorageBlob blob) {


        StorageBlobVO vo = BeanUtil.copyProperties(blob, StorageBlobVO.class);


        vo.setPreviewURL(fileUtil.buildSignedPreviewUrl(vo));


        vo.setDownloadURL(fileUtil.buildSignedDownloadUrl(vo));


        return vo;


    }


}