package com.ruoyi.production.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
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.mapper.ProductMapper;
|
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.DictUtils;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.common.utils.bean.BeanUtils;
|
import com.ruoyi.procurementrecord.utils.StockUtils;
|
import com.ruoyi.production.dto.*;
|
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.*;
|
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 java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.time.Duration;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
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 ProductionProductMainMapper productionProductMainMapper;
|
private ProductionProductReportDailyMapper productionProductReportDailyMapper;
|
|
|
private ProductWorkOrderMapper productWorkOrderMapper;
|
|
private ProductProcessRouteItemMapper productProcessRouteItemMapper;
|
private SysUserMapper userMapper;
|
|
private ProductionProductOutputMapper productionProductOutputMapper;
|
private ProductModelMapper productModelMapper;
|
private ProductMapper productMapper;
|
private ProductProcessMapper productProcessMapper;
|
|
private QualityInspectMapper qualityInspectMapper;
|
private QualityUnqualifiedMapper qualityUnqualifiedMapper;
|
|
private QualityInspectParamMapper qualityInspectParamMapper;
|
private QualityTestStandardParamMapper qualityTestStandardParamMapper;
|
private QualityTestStandardMapper qualityTestStandardMapper;
|
|
private ProductionProductInputMapper productionProductInputMapper;
|
|
private ProductOrderMapper productOrderMapper;
|
|
private SalesLedgerProductionAccountingMapper salesLedgerProductionAccountingMapper;
|
|
private StockUtils stockUtils;
|
|
|
@Override
|
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 List<ProductionProductMainSummaryExportDto> listSummaryExportData(ProductionProductMainDto productionProductMainDto) {
|
return listPageProductionProductMainDto(new Page<>(1, -1), productionProductMainDto)
|
.getRecords()
|
.stream()
|
.map(item -> {
|
ProductionProductMainSummaryExportDto exportDto = new ProductionProductMainSummaryExportDto();
|
exportDto.setProcess(item.getProcess());
|
exportDto.setWorkOrderNo(item.getWorkOrderNo());
|
exportDto.setSalesContractNo(item.getSalesContractNo());
|
exportDto.setProductOrderNpsNo(item.getProductOrderNpsNo());
|
exportDto.setProductName(item.getProductName());
|
exportDto.setProductModelName(item.getProductModelName());
|
exportDto.setUnit(item.getUnit());
|
exportDto.setProjectTotalHours(item.getProjectTotalHours());
|
exportDto.setProcessStandardHours(item.getProcessStandardHours());
|
exportDto.setActualReportHours(item.getActualReportHours());
|
exportDto.setDailyPersonHours(item.getDailyPersonHours());
|
exportDto.setOutputTotalQuantity(item.getOutputTotalQuantity());
|
exportDto.setScrapTotalQuantity(item.getScrapTotalQuantity());
|
return exportDto;
|
})
|
.collect(Collectors.toList());
|
}
|
|
@Override
|
public List<ProductionProductMainDetailExportDto> listDetailExportData(ProductionProductMainDto productionProductMainDto) {
|
return listPageProductionProductMainDetailDto(new Page<>(1, -1), productionProductMainDto)
|
.getRecords()
|
.stream()
|
.map(item -> {
|
ProductionProductMainDetailExportDto exportDto = new ProductionProductMainDetailExportDto();
|
exportDto.setProductNo(item.getProductNo());
|
exportDto.setNickName(item.getNickName());
|
exportDto.setProcess(item.getProcess());
|
exportDto.setWorkOrderNo(item.getWorkOrderNo());
|
exportDto.setSalesContractNo(item.getSalesContractNo());
|
exportDto.setProductOrderNpsNo(item.getProductOrderNpsNo());
|
exportDto.setProductName(item.getProductName());
|
exportDto.setProductModelName(item.getProductModelName());
|
exportDto.setQuantity(item.getQuantity());
|
exportDto.setScrapQty(item.getScrapQty());
|
exportDto.setUnit(item.getUnit());
|
exportDto.setProcessStandardHours(item.getProcessStandardHours());
|
exportDto.setActualReportHours(item.getActualReportHours());
|
exportDto.setDailyPersonHours(item.getDailyPersonHours());
|
exportDto.setCreateTime(item.getCreateTime());
|
return exportDto;
|
})
|
.collect(Collectors.toList());
|
}
|
|
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) {
|
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);
|
}
|
|
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) {
|
ProductionReportStateDto dto = new ProductionReportStateDto();
|
ProductWorkOrder workOrder = productWorkOrderMapper.selectById(workOrderId);
|
if (workOrder != null) {
|
BigDecimal planQty = workOrder.getPlanQuantity() == null ? BigDecimal.ZERO : workOrder.getPlanQuantity();
|
BigDecimal completeQty = workOrder.getCompleteQuantity() == null ? BigDecimal.ZERO : workOrder.getCompleteQuantity();
|
// 生产报工数量已完成
|
if (planQty.compareTo(BigDecimal.ZERO) > 0 && completeQty.compareTo(planQty) >= 0) {
|
dto.setState(3);
|
return dto;
|
}
|
}
|
|
ProductionProductMain running = getRunning(workOrderId, productProcessRouteItemId);
|
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")
|
.likeRight("product_no", datePrefix);
|
List<Map<String, Object>> resultList = productionProductMainMapper.selectMaps(queryWrapper);
|
int sequenceNumber = 1;
|
if (resultList != null && !resultList.isEmpty()) {
|
Map<String, Object> result = resultList.get(0);
|
if (result != null) {
|
Object maxNoObj = result.get("maxNo");
|
if (maxNoObj != null) {
|
String lastNo = maxNoObj.toString();
|
System.out.println("lastNo: " + lastNo);
|
if (lastNo.startsWith(datePrefix)) {
|
try {
|
String seqStr = lastNo.substring(datePrefix.length());
|
sequenceNumber = Integer.parseInt(seqStr) + 1;
|
} catch (NumberFormatException e) {
|
sequenceNumber = 1;
|
}
|
}
|
}
|
}
|
}
|
String productNo = String.format("%s%03d", datePrefix, sequenceNumber);
|
productionProductMain.setProductNo(productNo);
|
productionProductMain.setUserId(dto.getUserId());
|
productionProductMain.setUserName(user.getNickName());
|
productionProductMain.setProductProcessRouteItemId(dto.getProductProcessRouteItemId());
|
productionProductMain.setWorkOrderId(dto.getWorkOrderId());
|
productionProductMain.setStatus(0);
|
productionProductMain.setReportStartTime(LocalDateTime.now());
|
productionProductMainMapper.insert(productionProductMain);
|
return true;
|
}
|
|
private Boolean finishReport(ProductionProductMainDto dto) {
|
if (dto.getId() == null) {
|
throw new ServiceException("结束报工失败: 报工ID不能为空");
|
}
|
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(outputProductModelId);
|
productionProductOutput.setQuantity(dto.getQuantity() != null ? dto.getQuantity() : BigDecimal.ZERO);
|
productionProductOutput.setScrapQty(dto.getScrapQty() != null ? dto.getScrapQty() : BigDecimal.ZERO);
|
productionProductOutputMapper.insert(productionProductOutput);
|
//合格数量=报工数量-报废数量
|
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())));
|
// }
|
List<ProductProcessRouteItemDto> productProcessRouteItemDtos = productProcessRouteItemMapper.listItem(productOrder.getId());
|
ProductOrder currentOrder = productOrderMapper.selectById(productOrder.getId());
|
if (productProcessRouteItemDtos.get(productProcessRouteItemDtos.size() - 1).getId().equals(dto.getProductProcessRouteItemId())) {
|
int poRows = productOrderMapper.addCompleteQtyIfNotExceed(productOrder.getId(), productQty);
|
if (poRows <= 0) {
|
throw new ServiceException("本次生产数量不能大于订单剩余数量，剩余数量: "
|
+ (currentOrder == null ? "0" : currentOrder.getQuantity().subtract(currentOrder.getCompleteQuantity())));
|
}
|
}
|
if (needQuality
|
&& currentOrder != null
|
&& currentOrder.getCompleteQuantity() != null
|
&& currentOrder.getQuantity() != null
|
&& currentOrder.getCompleteQuantity().compareTo(currentOrder.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(qty);
|
qualityInspect.setProcess(process);
|
qualityInspect.setInspectState(0);
|
qualityInspect.setInspectType(inspectType);
|
qualityInspect.setProductMainId(productMainId);
|
qualityInspect.setProductModelId(productModelId);
|
qualityInspectMapper.insert(qualityInspect);
|
|
List<QualityTestStandard> qualityTestStandard = qualityTestStandardMapper.getQualityTestStandardByProductId(product.getId(), inspectType, process);
|
if (qualityTestStandard.isEmpty()) {
|
return;
|
}
|
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;
|
}
|
ProductProcessRouteItem routeItem = productProcessRouteItemMapper.selectById(workOrder.getProductProcessRouteItemId());
|
if (routeItem == null || routeItem.getProcessId() == null) {
|
return true;
|
}
|
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 "其他";
|
}
|
String dictLabel = DictUtils.getDictLabel("product_process_type", String.valueOf(process.getType()));
|
return (dictLabel == null || dictLabel.isEmpty()) ? "其他" : dictLabel;
|
}
|
|
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(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::getProductMainId, productionProductMain.getId())
|
);
|
/*更新工单和生产订单*/
|
ProductWorkOrder productWorkOrder = productWorkOrderMapper.selectById(productionProductMain.getWorkOrderId());
|
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());
|
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>()
|
.eq(QualityInspect::getProductMainId, productionProductMain.getId())
|
).forEach(q -> {
|
qualityInspectParamMapper.delete(
|
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()));
|
//删除投入记录
|
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);
|
}
|
}
|
