feat: 生产报工与报工台账功能更改完成

gongchunyi

2026-04-27 0be02df3d287f802c76e5738916301a877dfaa0e

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

@@ -2,8 +2,6 @@

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.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -13,50 +11,50 @@
import com.ruoyi.basic.mapper.ProductModelMapper;
import com.ruoyi.basic.pojo.Product;
import com.ruoyi.basic.pojo.ProductModel;
import com.ruoyi.common.enums.StockInQualifiedRecordTypeEnum;
import com.ruoyi.common.enums.StockOutQualifiedRecordTypeEnum;
import com.ruoyi.common.enums.StockInUnQualifiedRecordTypeEnum;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.bean.BeanUtils;
import com.ruoyi.procurementrecord.mapper.ProcurementRecordOutMapper;
import com.ruoyi.procurementrecord.pojo.ProcurementRecordOut;
import com.ruoyi.procurementrecord.utils.StockUtils;
import com.ruoyi.production.controller.ProductWorkOrderController;
import com.ruoyi.production.dto.ProductStructureDto;
import com.ruoyi.production.dto.ProductionProductMainDto;
import com.ruoyi.production.dto.ProductionReportDailySummaryDto;
import com.ruoyi.production.dto.ProductionReportStateDto;
import com.ruoyi.production.enums.ProductProcessEnum;
import com.ruoyi.production.mapper.ProductionProductReportDailyMapper;
import com.ruoyi.production.pojo.ProductionProductReportDaily;
import com.ruoyi.production.mapper.*;
import com.ruoyi.production.pojo.*;
import com.ruoyi.production.service.ProductionProductMainService;
import com.ruoyi.project.system.domain.SysUser;
import com.ruoyi.project.system.mapper.SysUserMapper;
import com.ruoyi.quality.mapper.QualityInspectMapper;
import com.ruoyi.quality.mapper.QualityInspectParamMapper;
import com.ruoyi.quality.mapper.QualityTestStandardMapper;
import com.ruoyi.quality.pojo.QualityInspect;
import com.ruoyi.quality.pojo.QualityInspectParam;
import com.ruoyi.quality.pojo.QualityTestStandard;
import io.swagger.models.auth.In;
import com.ruoyi.quality.mapper.*;
import com.ruoyi.quality.pojo.*;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.ruoyi.production.mapper.ProductionProductMainMapper;
import oshi.driver.mac.net.NetStat;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.Duration;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

@Service
@AllArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class ProductionProductMainServiceImpl extends ServiceImpl<ProductionProductMainMapper, ProductionProductMain> implements ProductionProductMainService {

    private final ProcurementRecordOutMapper procurementRecordOutMapper;
    private ProductionProductMainMapper productionProductMainMapper;
    private ProductionProductReportDailyMapper productionProductReportDailyMapper;

    private ProductWorkOrderController productWorkOrderController;

    private ProductWorkOrderMapper productWorkOrderMapper;

@@ -64,24 +62,16 @@
    private SysUserMapper userMapper;

    private ProductionProductOutputMapper productionProductOutputMapper;

    private ProcessRouteItemMapper processRouteItemMapper;

    private ProductModelMapper productModelMapper;
    private ProductMapper productMapper;
    private ProductProcessMapper productProcessMapper;

    private QualityInspectMapper qualityInspectMapper;

    private ProductProcessMapper productProcessMapper;
    private ProductProcessRouteMapper productProcessRouteMapper;

    private ProductMapper productMapper;


    private QualityTestStandardMapper qualityTestStandardMapper;
    private QualityUnqualifiedMapper qualityUnqualifiedMapper;

    private QualityInspectParamMapper qualityInspectParamMapper;

    private ProductStructureMapper productStructureMapper;
    private QualityTestStandardParamMapper qualityTestStandardParamMapper;
    private QualityTestStandardMapper qualityTestStandardMapper;

    private ProductionProductInputMapper productionProductInputMapper;

@@ -93,27 +83,162 @@


    @Override
    public IPage<ProductionProductMainDto> listPageProductionProductMainDto(Page page, ProductionProductMainDto productionProductMainDto) {
        return productionProductMainMapper.listPageProductionProductMainDto(page, productionProductMainDto);
    public IPage<ProductionProductMainDto> listPageProductionProductMainDto(Page<ProductionProductMainDto> page, ProductionProductMainDto productionProductMainDto) {
        if (productionProductMainDto == null) {
            productionProductMainDto = new ProductionProductMainDto();
        }
//        productionProductMainDto.setUserId(SecurityUtils.getUserId());
        IPage<ProductionProductMainDto> result = productionProductMainMapper.listPageProductionProductMainDto(page, productionProductMainDto);
        fillHourDefaults(result.getRecords());
        return result;
    }

    @Override
    public IPage<ProductionProductMainDto> listPageProductionProductMainDetailDto(Page<ProductionProductMainDto> page, ProductionProductMainDto productionProductMainDto) {
        if (productionProductMainDto == null) {
            productionProductMainDto = new ProductionProductMainDto();
        }
        IPage<ProductionProductMainDto> result = productionProductMainMapper.listPageProductionProductMainDetailDto(page, productionProductMainDto);
        fillHourDefaults(result.getRecords());
        return result;
    }

    @Override
    public IPage<ProductionProductMainDto> listPageProductionProductMainDailyDto(Page<ProductionProductMainDto> page, ProductionProductMainDto productionProductMainDto) {
        if (productionProductMainDto == null) {
            productionProductMainDto = new ProductionProductMainDto();
        }
        IPage<ProductionProductMainDto> result = productionProductMainMapper.listPageProductionProductMainDailyDto(page, productionProductMainDto);
        fillHourDefaults(result.getRecords());
        return result;
    }

    private void fillHourDefaults(List<ProductionProductMainDto> records) {
        if (records == null || records.isEmpty()) {
            return;
        }
        records.forEach(item -> {
            if (item.getProjectTotalHours() == null) {
                item.setProjectTotalHours(BigDecimal.ZERO);
            }
            if (item.getProcessStandardHours() == null) {
                item.setProcessStandardHours(BigDecimal.ZERO);
            }
            if (item.getActualReportHours() == null) {
                item.setActualReportHours(BigDecimal.ZERO);
            }
            if (item.getDailyPersonHours() == null) {
                item.setDailyPersonHours(BigDecimal.ZERO);
            }
        });
    }

    @Override
    public Boolean addProductMain(ProductionProductMainDto dto) {
        SysUser user = userMapper.selectUserById(dto.getUserId());
        ProductionProductMain productionProductMain = new ProductionProductMain();
        //当前工艺路线对应的工序详情
        ProductProcessRouteItem productProcessRouteItem = productProcessRouteItemMapper.selectById(dto.getProductProcessRouteItemId());
        if (productProcessRouteItem == null) {
            throw new RuntimeException("工艺路线项不存在");
        if (dto.getActionType() == null) {
            if (dto.getId() != null) {
                if (dto.getQuantity() == null || dto.getQuantity().compareTo(BigDecimal.ZERO) <= 0) {
                    throw new ServiceException("结束报工失败: 本次生产数量必须大于0");
                }
                return finishReport(dto);
            }

            Long workOrderId = dto.getWorkOrderId();
            Long itemId = dto.getProductProcessRouteItemId();
            if (workOrderId == null || itemId == null) {
                throw new ServiceException("工单ID和工艺路线项目ID不能为空");
            }
            ProductionProductMain running = getRunning(workOrderId, itemId);
            if (running != null) {
                if (dto.getQuantity() == null || dto.getQuantity().compareTo(BigDecimal.ZERO) <= 0) {
                    throw new ServiceException("结束报工失败: 本次生产数量必须大于0");
                }
                dto.setId(running.getId());
                return finishReport(dto);
            }
            return startReport(dto);
        }
        //当前具体工序
        ProductProcess productProcess = productProcessMapper.selectById(productProcessRouteItem.getProcessId());
        //工艺路线中当前工序对应的产出规格型号
        ProductModel productModel = productModelMapper.selectById(productProcessRouteItem.getProductModelId());
        //查询该生产订单对应的bom
        ProductProcessRoute productProcessRoute = productProcessRouteMapper.selectById(productProcessRouteItem.getProductRouteId());
        /*新增报工主表*/
        //查询最大报工编号

        if (dto.getActionType() == 1) {
            return startReport(dto);
        }
        if (dto.getActionType() == 2) {
            return finishReport(dto);
        }
        throw new ServiceException("无效报工动作: " + dto.getActionType());
    }

    @Override
    public ProductionProductMain getRunning(Long workOrderId, Long productProcessRouteItemId) {
        if (workOrderId == null || productProcessRouteItemId == null) {
            throw new ServiceException("工单ID和工艺路线项目ID不能为空");
        }
        Long currentUserId = SecurityUtils.getUserId();
        return productionProductMainMapper.selectOne(
                Wrappers.<ProductionProductMain>lambdaQuery()
                        .eq(ProductionProductMain::getWorkOrderId, workOrderId)
                        .eq(ProductionProductMain::getProductProcessRouteItemId, productProcessRouteItemId)
                        .eq(ProductionProductMain::getUserId, currentUserId)
                        .eq(ProductionProductMain::getStatus, 0)
                        .orderByDesc(ProductionProductMain::getReportStartTime)
                        .last("limit 1")
        );
    }

    @Override
    public List<ProductionReportDailySummaryDto> dailyDuration(Long workOrderId, Long productProcessRouteItemId, LocalDate startDate, LocalDate endDate) {
        Long userId = SecurityUtils.getUserId();
        return productionProductReportDailyMapper.listDailySummary(
                workOrderId,
                productProcessRouteItemId,
                userId,
                startDate,
                endDate
        );
    }

    @Override
    public ProductionReportStateDto reportState(Long workOrderId, Long productProcessRouteItemId) {
        ProductionProductMain running = getRunning(workOrderId, productProcessRouteItemId);
        ProductionReportStateDto dto = new ProductionReportStateDto();
        if (running == null) {
            dto.setState(1);
            return dto;
        }
        dto.setState(2);
        dto.setRunningId(running.getId());
        dto.setStartTime(running.getReportStartTime());
        return dto;
    }

    private Boolean startReport(ProductionProductMainDto dto) {
        if (dto.getWorkOrderId() == null || dto.getProductProcessRouteItemId() == null) {
            throw new ServiceException("开始报工失败: 工单ID和工艺路线项目ID不能为空");
        }
        if (dto.getUserId() == null) {
            dto.setUserId(SecurityUtils.getUserId());
        }
        if (dto.getUserId() == null) {
            throw new ServiceException("开始报工失败: 无法获取当前登录人");
        }

        QueryWrapper<ProductionProductMain> runningWrapper = new QueryWrapper<>();
        runningWrapper.eq("work_order_id", dto.getWorkOrderId())
                .eq("product_process_route_item_id", dto.getProductProcessRouteItemId())
                .eq("user_id", dto.getUserId())
                .eq("status", 0);
        Long runningCount = productionProductMainMapper.selectCount(runningWrapper);
        if (runningCount != null && runningCount > 0) {
            // 已有进行中的报工时，不再新建，继续沿用到结束报工
            return true;
        }

        SysUser user = userMapper.selectUserById(dto.getUserId());
        if (user == null) {
            throw new ServiceException("报工人不存在");
        }

        ProductionProductMain productionProductMain = new ProductionProductMain();
        String datePrefix = "BG" + LocalDate.now().format(DateTimeFormatter.ofPattern("yyMMdd"));
        QueryWrapper<ProductionProductMain> queryWrapper = new QueryWrapper<>();
        queryWrapper.select("MAX(product_no) as maxNo")
@@ -141,153 +266,341 @@
        String productNo = String.format("%s%03d", datePrefix, sequenceNumber);
        productionProductMain.setProductNo(productNo);
        productionProductMain.setUserId(dto.getUserId());
        productionProductMain.setUserName(dto.getUserName());
        productionProductMain.setUserName(user.getNickName());
        productionProductMain.setProductProcessRouteItemId(dto.getProductProcessRouteItemId());
        productionProductMain.setWorkOrderId(dto.getWorkOrderId());
        productionProductMain.setStatus(0);
        productionProductMain.setReportStartTime(LocalDateTime.now());
        productionProductMainMapper.insert(productionProductMain);
        /*新增报工投入表*/
        List<ProductStructureDto> productStructureDtos = productStructureMapper.listBybomAndProcess(productProcessRoute.getBomId(), productProcess.getId());
        if (productStructureDtos.size() == 0) {
            //如果该工序没有产品结构的投入品,那这个投入品和产出品是同一个
            ProductStructureDto productStructureDto = new ProductStructureDto();
            productStructureDto.setProductModelId(productProcessRouteItem.getProductModelId());
            productStructureDto.setUnitQuantity(BigDecimal.ONE);
            productStructureDtos.add(productStructureDto);
        return true;
    }

    private Boolean finishReport(ProductionProductMainDto dto) {
        if (dto.getId() == null) {
            throw new ServiceException("结束报工失败: 报工ID不能为空");
        }
        for (ProductStructureDto productStructureDto : productStructureDtos) {
            ProductModel productModel1 = productModelMapper.selectById(productStructureDto.getProductModelId());
            Product product = productMapper.selectById(productModel1.getProductId());
            BigDecimal stockQuantity = stockUtils.getStockQuantity(productModel1.getId()).get("stockQuantity");
            if (!(stockQuantity.compareTo(BigDecimal.ZERO) > 0)) {
                throw new RuntimeException(product.getProductName() + "库存为0");
            }
            if (stockQuantity.compareTo(productStructureDto.getUnitQuantity().multiply(dto.getQuantity())) < 0) {
                throw new RuntimeException(product.getProductName() + "库存不足");
            }
            ProductionProductInput productionProductInput = new ProductionProductInput();
            productionProductInput.setProductModelId(productStructureDto.getProductModelId());
            productionProductInput.setQuantity(productStructureDto.getUnitQuantity().multiply(dto.getQuantity()));
            productionProductInput.setProductMainId(productionProductMain.getId());
            productionProductInputMapper.insert(productionProductInput);
            //对应的库存出库
            DateTimeFormatter dateFormat = DateTimeFormatter.ofPattern("yyyyMMdd");
            LocalDate now = LocalDate.now();
            ProcurementRecordOut procurementRecordOut1 = procurementRecordOutMapper.selectCode(dateFormat.format(now));
            Long aLong = procurementRecordOut1 == null ? 1L : Long.valueOf(procurementRecordOut1.getCode().split("LS" + dateFormat.format(now))[1]);
            ProcurementRecordOut.ProcurementRecordOutBuilder procurementRecordOut = ProcurementRecordOut.builder()
                    .procurementRecordStorageId(0)
                    .code("LS" + dateFormat.format(now) + String.format("%03d", aLong + 1))
                    .salesLedgerProductId(productionProductMain.getId())//关联报工产出
                    .inboundBatches(aLong.equals(0L) ? "第1批次" : "第" + (aLong + 1) + "批次")
                    .inboundNum(productionProductInput.getQuantity())
                    .type(4)
                    .createBy(user.getNickName())
                    .productModelId(productModel1.getId());
            procurementRecordOutMapper.insert(procurementRecordOut.build());
        if (dto.getQuantity() == null || dto.getQuantity().compareTo(BigDecimal.ZERO) <= 0) {
            throw new ServiceException("结束报工失败: 本次生产数量必须大于0");
        }
        ProductionProductMain productionProductMain = productionProductMainMapper.selectById(dto.getId());
        if (productionProductMain == null) {
            throw new ServiceException("结束报工失败: 报工记录不存在");
        }
        if (productionProductMain.getStatus() != null && productionProductMain.getStatus() == 1) {
            throw new ServiceException("该报工已结束，请勿重复提交");
        }
        if (productionProductMain.getReportStartTime() == null) {
            throw new ServiceException("该报工缺少开始时间，无法结束");
        }

        LocalDateTime endTime = LocalDateTime.now();
        long durationSeconds = Duration.between(productionProductMain.getReportStartTime(), endTime).getSeconds();
        BigDecimal durationMinutes = secondsToMinutesExact(durationSeconds);
        int finishRows = productionProductMainMapper.update(
                null,
                Wrappers.<ProductionProductMain>lambdaUpdate()
                        .set(ProductionProductMain::getReportEndTime, endTime)
                        .set(ProductionProductMain::getReportDurationMinutes, durationMinutes)
                        .set(ProductionProductMain::getStatus, 1)
                        .eq(ProductionProductMain::getId, productionProductMain.getId())
                        .eq(ProductionProductMain::getStatus, 0)
        );
        if (finishRows <= 0) {
            throw new ServiceException("该报工已结束，请勿重复提交");
        }
        productionProductMain.setReportEndTime(endTime);
        productionProductMain.setReportDurationMinutes(durationMinutes);
        productionProductMain.setStatus(1);

        // 写入“每日时长明细”，跨天自动拆分
        saveDailyDurations(productionProductMain, productionProductMain.getReportStartTime(), endTime);

        dto.setWorkOrderId(productionProductMain.getWorkOrderId());
        dto.setProductProcessRouteItemId(productionProductMain.getProductProcessRouteItemId());
        if (dto.getUserId() == null) {
            dto.setUserId(productionProductMain.getUserId());
        }
        if (dto.getUserName() == null) {
            dto.setUserName(productionProductMain.getUserName());
        }
        if (dto.getScrapQty() == null) {
            dto.setScrapQty(BigDecimal.ZERO);
        }

        SysUser user = userMapper.selectUserById(dto.getUserId());
        if (user == null) {
            throw new ServiceException("报工人不存在");
        }

        //  使用工单关联的生产订单产品型号
        ProductWorkOrder productWorkOrder = productWorkOrderMapper.selectById(dto.getWorkOrderId());
        if (productWorkOrder == null) {
            throw new ServiceException("结束报工失败: 工单不存在");
        }
        ProductOrder productOrder = productOrderMapper.selectById(productWorkOrder.getProductOrderId());
        if (productOrder == null) {
            throw new ServiceException("结束报工失败: 关联生产订单不存在");
        }
        Long outputProductModelId = productOrder.getProductModelId();
        if (outputProductModelId == null) {
            throw new ServiceException("结束报工失败: 生产订单未配置产品型号");
        }

        /*新增报工投入表(无BOM场景: 投入=产出型号, 数量按本次报工数量)*/
        ProductionProductInput productionProductInput = new ProductionProductInput();
        productionProductInput.setProductModelId(outputProductModelId);
        productionProductInput.setQuantity(dto.getQuantity());
        productionProductInput.setProductMainId(productionProductMain.getId());
        productionProductInputMapper.insert(productionProductInput);
        stockUtils.substractStock(outputProductModelId, dto.getQuantity(), StockOutQualifiedRecordTypeEnum.PRODUCTION_REPORT_STOCK_OUT.getCode(), productionProductMain.getId());

        /*新增报工产出表*/
        ProductionProductOutput productionProductOutput = new ProductionProductOutput();
        productionProductOutput.setProductMainId(productionProductMain.getId());
        productionProductOutput.setProductModelId(productProcessRouteItem.getProductModelId());
        productionProductOutput.setProductModelId(outputProductModelId);
        productionProductOutput.setQuantity(dto.getQuantity() != null ? dto.getQuantity() : BigDecimal.ZERO);
        productionProductOutput.setScrapQty(dto.getScrapQty() != null ? dto.getScrapQty() : BigDecimal.ZERO);
        productionProductOutputMapper.insert(productionProductOutput);
        //对应的过程检或者出厂检
        List<ProductProcessRouteItem> productProcessRouteItems = productProcessRouteItemMapper.selectList(Wrappers.<ProductProcessRouteItem>lambdaQuery().eq(ProductProcessRouteItem::getProductRouteId, productProcessRouteItem.getProductRouteId()));
        int inspectType = 1;
        if (productProcessRouteItem.getDragSort()==productProcessRouteItems.size()){
            //最后一道工序生成出厂检
            inspectType = 2;
        //合格数量=报工数量-报废数量
        BigDecimal productQty = productionProductOutput.getQuantity().subtract(productionProductOutput.getScrapQty());
        // 是否需要质检：按 product_process.is_quality 判断（1-需要，0-不需要）
        boolean needQuality = isNeedQualityByWorkOrder(productWorkOrder);

        //只有合格数量>0才能增加相应数据
        if (productQty.compareTo(BigDecimal.ZERO) > 0) {
            // 需要质检时才新增过程检/出厂检
            if (needQuality) {
                createQualityInspect(productionProductMain.getId(), outputProductModelId, productQty, 1, "生产报工");
            }
            stockUtils.addStock(outputProductModelId, productQty, StockInQualifiedRecordTypeEnum.PRODUCTION_REPORT_STOCK_IN.getCode(), productionProductMain.getId());
            /*更新工单和生产订单*/
            int woRows = productWorkOrderMapper.addCompleteQtyIfNotExceed(dto.getWorkOrderId(), productQty);
            if (woRows <= 0) {
                ProductWorkOrder current = productWorkOrderMapper.selectById(dto.getWorkOrderId());
                throw new ServiceException("本次生产数量不能大于剩余数量，剩余数量: "
                        + (current == null ? "0" : current.getPlanQuantity().subtract(current.getCompleteQuantity())));
            }

            // 无工艺路线场景：报工即计入生产订单完成数量
            int poRows = productOrderMapper.addCompleteQtyIfNotExceed(productOrder.getId(), productQty);
            if (poRows <= 0) {
                ProductOrder currentOrder = productOrderMapper.selectById(productOrder.getId());
                throw new ServiceException("本次生产数量不能大于订单剩余数量，剩余数量: "
                        + (currentOrder == null ? "0" : currentOrder.getQuantity().subtract(currentOrder.getCompleteQuantity())));
            }
            ProductOrder latestOrder = productOrderMapper.selectById(productOrder.getId());
            if (needQuality
                    && latestOrder != null
                    && latestOrder.getCompleteQuantity() != null
                    && latestOrder.getQuantity() != null
                    && latestOrder.getCompleteQuantity().compareTo(latestOrder.getQuantity()) >= 0) {
                // 订单完成时新增出厂检
                createQualityInspect(productionProductMain.getId(), outputProductModelId, productQty, 2, null);
            }
            /*添加生产核算        区分工序是计件还是计时*/
            BigDecimal workHours = durationMinutes.divide(BigDecimal.valueOf(60), 2, RoundingMode.HALF_UP);

            SalesLedgerProductionAccounting salesLedgerProductionAccounting = SalesLedgerProductionAccounting.builder()
                    .productMainId(productionProductMain.getId())
                    .schedulingUserId(user.getUserId())
                    .schedulingUserName(user.getNickName())
                    .finishedNum(productQty)
                    .workHours(workHours)
                    .process(resolveProcessTypeName(productWorkOrder))
                    .schedulingDate(LocalDate.now())
                    .tenantId(dto.getTenantId())
                    .build();
            salesLedgerProductionAccountingMapper.insert(salesLedgerProductionAccounting);
        }
        //如果报废数量>0,需要进入报废的库存
        if (ObjectUtils.isNotEmpty(dto.getScrapQty())) {
            if (dto.getScrapQty().compareTo(BigDecimal.ZERO) > 0) {
                stockUtils.addUnStock(outputProductModelId, dto.getScrapQty(), StockInUnQualifiedRecordTypeEnum.PRODUCTION_SCRAP.getCode(), productionProductMain.getId());
            }
        }
        return true;
    }

    /**
     * 创建质检及质检参数
     */
    private void createQualityInspect(Long productMainId, Long productModelId, BigDecimal qty, Integer inspectType, String process) {
        ProductModel productModel = productModelMapper.selectById(productModelId);
        if (productModel == null) {
            return;
        }
        Product product = productMapper.selectById(productModel.getProductId());
        if (product == null) {
            return;
        }
        QualityInspect qualityInspect = new QualityInspect();
        qualityInspect.setProductId(product.getId());
        qualityInspect.setProductName(product.getProductName());
        qualityInspect.setModel(productModel.getModel());
        qualityInspect.setUnit(productModel.getUnit());
        qualityInspect.setQuantity(dto.getQuantity());
        qualityInspect.setProcess(productProcess.getName());
        qualityInspect.setQuantity(qty);
        qualityInspect.setProcess(process);
        qualityInspect.setInspectState(0);
        qualityInspect.setInspectType(inspectType);
        qualityInspect.setProductMainId(productionProductMain.getId());
        qualityInspect.setProductModelId(productModel.getId());
        qualityInspect.setProductMainId(productMainId);
        qualityInspect.setProductModelId(productModelId);
        qualityInspectMapper.insert(qualityInspect);
        qualityTestStandardMapper.selectList(
                new LambdaQueryWrapper<QualityTestStandard>()
                        .eq(QualityTestStandard::getProductId, product.getId())
        ).forEach(standard -> {
            QualityInspectParam param = new QualityInspectParam();
            BeanUtils.copyProperties(standard, param);
            param.setId(null);
            param.setInspectId(qualityInspect.getId());
            qualityInspectParamMapper.insert(param);
        });
        /*更新工单和生产订单*/
        ProductWorkOrder productWorkOrder = productWorkOrderMapper.selectById(dto.getWorkOrderId());
        productWorkOrder.setCompleteQuantity(productWorkOrder.getCompleteQuantity().add(dto.getQuantity()));
        if (ObjectUtils.isNull(productWorkOrder.getActualStartTime())){
            productWorkOrder.setActualStartTime(LocalDate.now());//实际开始时间

        List<QualityTestStandard> qualityTestStandard = qualityTestStandardMapper.getQualityTestStandardByProductId(product.getId(), inspectType, process);
        if (qualityTestStandard.isEmpty()) {
            return;
        }
        if (productWorkOrder.getCompleteQuantity().compareTo(productWorkOrder.getPlanQuantity()) == 0){
            productWorkOrder.setActualEndTime(LocalDate.now());//实际结束时间
        qualityInspect.setTestStandardId(qualityTestStandard.get(0).getId());
        qualityInspectMapper.updateById(qualityInspect);
        qualityTestStandardParamMapper.selectList(Wrappers.<QualityTestStandardParam>lambdaQuery()
                        .eq(QualityTestStandardParam::getTestStandardId, qualityTestStandard.get(0).getId()))
                .forEach(qualityTestStandardParam -> {
                    QualityInspectParam param = new QualityInspectParam();
                    BeanUtils.copyProperties(qualityTestStandardParam, param);
                    param.setId(null);
                    param.setInspectId(qualityInspect.getId());
                    qualityInspectParamMapper.insert(param);
                });
    }

    /**
     * 是否需要质检：依据工序表 is_quality（1-需要，0-不需要）
     */
    private boolean isNeedQualityByWorkOrder(ProductWorkOrder workOrder) {
        if (workOrder == null || workOrder.getProductProcessRouteItemId() == null) {
            return true;
        }
        productWorkOrderMapper.updateById(productWorkOrder);
        //生产订单
        ProductOrder productOrder = productOrderMapper.selectById(productWorkOrder.getProductOrderId());
        if (ObjectUtils.isNull(productOrder.getStartTime())){
            productOrder.setStartTime(LocalDateTime.now());//开始时间
        ProductProcessRouteItem routeItem = productProcessRouteItemMapper.selectById(workOrder.getProductProcessRouteItemId());
        if (routeItem == null || routeItem.getProcessId() == null) {
            return true;
        }
        if (productProcessRouteItem.getDragSort()==productProcessRouteItems.size()){
            //如果是最后一道工序报工之后生产订单完成数量+
            productOrder.setCompleteQuantity(productOrder.getCompleteQuantity().add(dto.getQuantity()));
            if (productOrder.getCompleteQuantity().compareTo(productOrder.getQuantity()) == 0){
                productOrder.setEndTime(LocalDateTime.now());//结束时间
        ProductProcess process = productProcessMapper.selectById(routeItem.getProcessId());
        if (process == null || process.getIsQuality() == null) {
            return true;
        }
        return process.getIsQuality();
    }

    /**
     * 获取工序对应的“部件类型”文案
     */
    private String resolveProcessTypeName(ProductWorkOrder workOrder) {
        if (workOrder == null || workOrder.getProductProcessRouteItemId() == null) {
            return "其他";
        }
        ProductProcessRouteItem routeItem = productProcessRouteItemMapper.selectById(workOrder.getProductProcessRouteItemId());
        if (routeItem == null || routeItem.getProcessId() == null) {
            return "其他";
        }
        ProductProcess process = productProcessMapper.selectById(routeItem.getProcessId());
        if (process == null || process.getType() == null) {
            return "其他";
        }
        for (ProductProcessEnum value : ProductProcessEnum.values()) {
            if (value.getCode().equals(process.getType())) {
                return value.getInfo();
            }
        }
        productOrderMapper.updateById(productOrder);
        /*添加生产核算*/
        SalesLedgerProductionAccounting salesLedgerProductionAccounting = SalesLedgerProductionAccounting.builder()
                .salesLedgerWorkId(productionProductMain.getId())
                .salesLedgerSchedulingId(0L)
                .salesLedgerId(productOrder.getSalesLedgerId())
                .salesLedgerProductId(productOrder.getProductModelId())
                .schedulingUserId(user.getUserId())
                .schedulingUserName(user.getNickName())
                .finishedNum(dto.getQuantity() != null ? dto.getQuantity() : BigDecimal.ZERO)
                .workHours(productProcess.getSalaryQuota())
                .process(productProcess.getName())
                .schedulingDate(LocalDate.now())
                .tenantId(dto.getTenantId())
                .build();
        salesLedgerProductionAccountingMapper.insert(salesLedgerProductionAccounting);
        return true;
        return "其他";
    }

    private void saveDailyDurations(ProductionProductMain main, LocalDateTime start, LocalDateTime end) {
        if (main == null || start == null || end == null) {
            return;
        }
        if (end.isBefore(start)) {
            return;
        }

        // 防止重复写（例如误重复结束时），先删再插
        productionProductReportDailyMapper.delete(
                Wrappers.<ProductionProductReportDaily>lambdaQuery()
                        .eq(ProductionProductReportDaily::getProductMainId, main.getId())
        );

        LocalDateTime cursor = start;
        while (cursor.isBefore(end)) {
            LocalDate date = cursor.toLocalDate();
            LocalDateTime nextDayStart = date.plusDays(1).atStartOfDay();
            LocalDateTime sliceEnd = end.isBefore(nextDayStart) ? end : nextDayStart;

            long seconds = Duration.between(cursor, sliceEnd).getSeconds();
            BigDecimal minutes = secondsToMinutesExact(seconds);
            if (minutes.compareTo(BigDecimal.ZERO) > 0) {
                ProductionProductReportDaily daily = new ProductionProductReportDaily();
                daily.setProductMainId(main.getId());
                daily.setWorkOrderId(main.getWorkOrderId());
                daily.setProductProcessRouteItemId(main.getProductProcessRouteItemId());
                daily.setUserId(main.getUserId());
                daily.setReportDate(date);
                daily.setStartTime(cursor);
                daily.setEndTime(sliceEnd);
                daily.setDurationMinutes(minutes);
                productionProductReportDailyMapper.insert(daily);
            }
            cursor = sliceEnd;
        }
    }

    /**
     * 秒转分钟：包含分秒并向上取整到分钟
     */
    private BigDecimal secondsToMinutesExact(long seconds) {
        if (seconds <= 0L) {
            return BigDecimal.ZERO;
        }
        return BigDecimal.valueOf(seconds).divide(BigDecimal.valueOf(60), 2, RoundingMode.HALF_UP);
    }

    @Override
    public Boolean removeProductMain(ProductionProductMainDto dto) {
        ProductionProductMain productionProductMain = productionProductMainMapper.selectById(dto.getId());
        //该报工对应的工艺路线详情
        ProductProcessRouteItem productProcessRouteItem = productProcessRouteItemMapper.selectById(productionProductMain.getProductProcessRouteItemId());
        ProductionProductOutput productionProductOutput = productionProductOutputMapper.selectList(Wrappers.<ProductionProductOutput>lambdaQuery().eq(ProductionProductOutput::getProductMainId, productionProductMain.getId())).get(0);
    public Boolean removeProductMain(Long id) {
        //判断该条报工是否不合格处理,如果不合格处理了，则不允许删除
        List<QualityInspect> qualityInspects = qualityInspectMapper.selectList(Wrappers.<QualityInspect>lambdaQuery().eq(QualityInspect::getProductMainId, id));
        if (qualityInspects.size() > 0) {
            List<QualityUnqualified> qualityUnqualifieds = qualityUnqualifiedMapper.selectList(Wrappers.<QualityUnqualified>lambdaQuery()
                    .in(QualityUnqualified::getInspectId, qualityInspects.stream().map(QualityInspect::getId).collect(Collectors.toList())));
            if (qualityUnqualifieds.size() > 0 && qualityUnqualifieds.get(0).getInspectState() == 1) {
                throw new ServiceException("该条报工已经不合格处理了，不允许删除");
            }
        }
        ProductionProductMain productionProductMain = productionProductMainMapper.selectById(id);
        List<ProductionProductOutput> outputList = productionProductOutputMapper.selectList(
                Wrappers.<ProductionProductOutput>lambdaQuery().eq(ProductionProductOutput::getProductMainId, productionProductMain.getId())
        );
        ProductionProductOutput productionProductOutput = outputList.isEmpty() ? null : outputList.get(0);
        /*删除核算*/
        salesLedgerProductionAccountingMapper.delete(
                new LambdaQueryWrapper<SalesLedgerProductionAccounting>()
                        .eq(SalesLedgerProductionAccounting::getSalesLedgerWorkId, productionProductMain.getId())
                        .eq(SalesLedgerProductionAccounting::getProductMainId, productionProductMain.getId())
        );
        /*更新工单和生产订单*/
        ProductWorkOrder productWorkOrder = productWorkOrderMapper.selectById(productionProductMain.getWorkOrderId());
        productWorkOrder.setCompleteQuantity(productWorkOrder.getCompleteQuantity().subtract(productionProductOutput.getQuantity()));
        productWorkOrder.setActualEndTime(null);
        productWorkOrderMapper.updateById(productWorkOrder);
        //判断是否是最后一道工序
        List<ProductProcessRouteItem> productProcessRouteItems = productProcessRouteItemMapper.selectList(Wrappers.<ProductProcessRouteItem>lambdaQuery().eq(ProductProcessRouteItem::getProductRouteId, productProcessRouteItem.getProductRouteId()));
        if (productProcessRouteItem.getDragSort() == productProcessRouteItems.size()){
        BigDecimal validQuantity = BigDecimal.ZERO;
        if (productWorkOrder != null && productionProductOutput != null) {
            BigDecimal outputQty = productionProductOutput.getQuantity() == null ? BigDecimal.ZERO : productionProductOutput.getQuantity();
            BigDecimal scrapQty = productionProductOutput.getScrapQty() == null ? BigDecimal.ZERO : productionProductOutput.getScrapQty();
            BigDecimal completeQty = productWorkOrder.getCompleteQuantity() == null ? BigDecimal.ZERO : productWorkOrder.getCompleteQuantity();

            validQuantity = outputQty.subtract(scrapQty);

            productWorkOrder.setCompleteQuantity(completeQty.subtract(validQuantity));
            productWorkOrder.setActualEndTime(null);
            productWorkOrderMapper.updateById(productWorkOrder);
        } else if (productWorkOrder == null) {
            throw new ServiceException("操作失败：工单信息或产出记录不存在");
        }
        // 无工艺路线场景：删除报工时只要有有效产出就扣减生产订单完成数量
        if (productionProductOutput != null && validQuantity.compareTo(BigDecimal.ZERO) > 0) {
            ProductOrder productOrder = productOrderMapper.selectById(productWorkOrder.getProductOrderId());
            productOrder.setCompleteQuantity(productOrder.getCompleteQuantity().subtract(productionProductOutput.getQuantity()));
            if (productOrder == null) {
                throw new ServiceException("关联的生产订单不存在");
            }
            BigDecimal orderCompleteQty = productOrder.getCompleteQuantity() == null ? BigDecimal.ZERO : productOrder.getCompleteQuantity();
            BigDecimal newCompleteQty = orderCompleteQty.subtract(validQuantity);
            productOrder.setCompleteQuantity(newCompleteQty.compareTo(BigDecimal.ZERO) < 0 ? BigDecimal.ZERO : newCompleteQty);
            productOrder.setEndTime(null);
            productOrderMapper.updateById(productOrder);
        }
        /*删除产出*/
        //删除质检
        qualityInspectMapper.selectList(
                new LambdaQueryWrapper<QualityInspect>()
@@ -297,17 +610,28 @@
                    new LambdaQueryWrapper<QualityInspectParam>()
                            .eq(QualityInspectParam::getInspectId, q.getId()));
            qualityInspectMapper.deleteById(q.getId());
            stockUtils.deleteStockInRecord(q.getId(), StockInQualifiedRecordTypeEnum.QUALITYINSPECT_STOCK_IN.getCode());
        });

        // 删除产出记录
        productionProductOutputMapper.delete(new LambdaQueryWrapper<ProductionProductOutput>()
                .eq(ProductionProductOutput::getProductMainId, productionProductMain.getId()));
        /*删除投入*/
        procurementRecordOutMapper.delete(new LambdaQueryWrapper<ProcurementRecordOut>()
                .eq(ProcurementRecordOut::getSalesLedgerProductId, productionProductMain.getId()));
        //删除投入记录
        productionProductInputMapper.delete(new LambdaQueryWrapper<ProductionProductInput>()
                .eq(ProductionProductInput::getProductMainId, productionProductMain.getId()));
        //删除报废的入库记录
        stockUtils.deleteStockInRecord(productionProductMain.getId(), StockInUnQualifiedRecordTypeEnum.PRODUCTION_SCRAP.getCode());
        //删除不需要质检的合格入库
        stockUtils.deleteStockInRecord(productionProductMain.getId(), StockInQualifiedRecordTypeEnum.PRODUCTION_REPORT_STOCK_IN.getCode());
        //删除投入对应的出库记录
        stockUtils.deleteStockOutRecord(productionProductMain.getId(), StockOutQualifiedRecordTypeEnum.PRODUCTION_REPORT_STOCK_OUT.getCode());
        // 删除主表
        productionProductMainMapper.deleteById(productionProductMain.getId());
        return true;
    }

    @Override
    public ArrayList<Long> listMain(List<Long> idList) {
        return productionProductMainMapper.listMain(idList);
    }
}