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.StockInUnQualifiedRecordTypeEnum;
|
import com.ruoyi.common.enums.StockOutQualifiedRecordTypeEnum;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.common.utils.bean.BeanUtils;
|
import com.ruoyi.procurementrecord.utils.StockUtils;
|
import com.ruoyi.production.bean.dto.ProductStructureDto;
|
import com.ruoyi.production.bean.dto.ProductionProductMainDto;
|
import com.ruoyi.production.enums.ProductOrderStatusEnum;
|
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 com.ruoyi.stock.dto.StockInventoryDto;
|
import com.ruoyi.stock.service.StockInventoryService;
|
import com.ruoyi.technology.mapper.TechnologyOperationMapper;
|
import com.ruoyi.technology.mapper.TechnologyRoutingOperationMapper;
|
import com.ruoyi.technology.pojo.TechnologyOperation;
|
import com.ruoyi.technology.pojo.TechnologyRoutingOperation;
|
import lombok.AllArgsConstructor;
|
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.Collections;
|
import java.util.HashMap;
|
import java.util.LinkedHashMap;
|
import java.util.LinkedHashSet;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.Set;
|
import java.util.stream.Collectors;
|
|
@Service
|
@AllArgsConstructor
|
@Transactional(rollbackFor = Exception.class)
|
public class ProductionProductMainServiceImpl extends ServiceImpl<ProductionProductMainMapper, ProductionProductMain> implements ProductionProductMainService {
|
|
private final ProductionProductMainMapper productionProductMainMapper;
|
private final SysUserMapper userMapper;
|
private final ProductionProductOutputMapper productionProductOutputMapper;
|
private final ProductModelMapper productModelMapper;
|
private final QualityInspectMapper qualityInspectMapper;
|
private final QualityUnqualifiedMapper qualityUnqualifiedMapper;
|
private final ProductMapper productMapper;
|
private final QualityTestStandardParamMapper qualityTestStandardParamMapper;
|
private final QualityTestStandardMapper qualityTestStandardMapper;
|
private final QualityInspectParamMapper qualityInspectParamMapper;
|
private final ProductionProductInputMapper productionProductInputMapper;
|
private final ProductionAccountMapper productionAccountMapper;
|
private final ProductionOperationTaskMapper productionOperationTaskMapper;
|
private final ProductionOrderMapper productionOrderMapper;
|
private final ProductionOrderBomMapper productionOrderBomMapper;
|
private final ProductionBomStructureMapper productionBomStructureMapper;
|
private final ProductionOrderRoutingOperationMapper productionOrderRoutingOperationMapper;
|
private final ProductionOrderRoutingOperationParamMapper productionOrderRoutingOperationParamMapper;
|
private final TechnologyRoutingOperationMapper technologyRoutingOperationMapper;
|
private final TechnologyOperationMapper technologyOperationMapper;
|
private final StockUtils stockUtils;
|
private final StockInventoryService stockInventoryService;
|
|
@Override
|
public IPage<ProductionProductMainDto> listPageProductionProductMainDto(Page page, ProductionProductMainDto productionProductMainDto) {
|
IPage<ProductionProductMainDto> result = productionProductMainMapper.listPageProductionProductMainDto(page, productionProductMainDto);
|
fillOperationParamList(result.getRecords());
|
return result;
|
}
|
|
@Override
|
public IPage<ProductionProductMainDto> pageProductionProductMain(Page page, ProductionProductMainDto productionProductMainDto) {
|
return listPageProductionProductMainDto(page, productionProductMainDto);
|
}
|
|
@Override
|
public ProductionProductMainDto getProductionProductMainInfo(Long id) {
|
return listPageProductionProductMainDto(new Page<>(1, 1), new ProductionProductMainDto() {{
|
setId(id);
|
}}).getRecords().stream().findFirst().orElse(null);
|
}
|
|
private void fillOperationParamList(List<ProductionProductMainDto> recordList) {
|
if (recordList == null || recordList.isEmpty()) {
|
return;
|
}
|
Set<Long> mainIdSet = recordList.stream()
|
.map(ProductionProductMainDto::getId)
|
.filter(Objects::nonNull)
|
.collect(Collectors.toCollection(LinkedHashSet::new));
|
if (mainIdSet.isEmpty()) {
|
recordList.forEach(item -> item.setProductionOperationParamList(Collections.emptyList()));
|
return;
|
}
|
|
List<ProductionOrderRoutingOperationParam> paramList = productionOrderRoutingOperationParamMapper.selectList(
|
Wrappers.<ProductionOrderRoutingOperationParam>lambdaQuery()
|
.in(ProductionOrderRoutingOperationParam::getProductionProductMainId, mainIdSet)
|
.orderByAsc(ProductionOrderRoutingOperationParam::getId));
|
Map<Long, List<ProductionOrderRoutingOperationParam>> paramGroupMap = new HashMap<>();
|
for (ProductionOrderRoutingOperationParam param : paramList) {
|
if (param == null || param.getProductionProductMainId() == null) {
|
continue;
|
}
|
paramGroupMap.computeIfAbsent(param.getProductionProductMainId(), key -> new ArrayList<>()).add(param);
|
}
|
|
Set<Long> missingMainIdSet = new LinkedHashSet<>();
|
for (ProductionProductMainDto item : recordList) {
|
Long mainId = item.getId();
|
if (mainId == null) {
|
item.setProductionOperationParamList(Collections.emptyList());
|
continue;
|
}
|
List<ProductionOrderRoutingOperationParam> params = paramGroupMap.get(mainId);
|
if (params != null && !params.isEmpty()) {
|
item.setProductionOperationParamList(params);
|
continue;
|
}
|
missingMainIdSet.add(mainId);
|
}
|
if (missingMainIdSet.isEmpty()) {
|
return;
|
}
|
|
// 兼容历史数据：旧报工记录没有按报工ID落参数快照时，回退展示工序模板参数。
|
List<ProductionProductMain> mainList = productionProductMainMapper.selectBatchIds(missingMainIdSet);
|
Map<Long, Long> mainIdToTaskIdMap = mainList.stream()
|
.filter(Objects::nonNull)
|
.filter(item -> item.getId() != null)
|
.collect(Collectors.toMap(ProductionProductMain::getId,
|
ProductionProductMain::getProductionOperationTaskId, (left, right) -> left));
|
Set<Long> taskIdSet = mainIdToTaskIdMap.values().stream()
|
.filter(Objects::nonNull)
|
.collect(Collectors.toCollection(LinkedHashSet::new));
|
if (taskIdSet.isEmpty()) {
|
for (ProductionProductMainDto item : recordList) {
|
if (item.getId() != null && missingMainIdSet.contains(item.getId())) {
|
item.setProductionOperationParamList(Collections.emptyList());
|
}
|
}
|
return;
|
}
|
|
List<ProductionOperationTask> taskList = productionOperationTaskMapper.selectList(
|
Wrappers.<ProductionOperationTask>lambdaQuery()
|
.in(ProductionOperationTask::getId, taskIdSet));
|
Map<Long, Long> taskIdToRoutingOperationIdMap = taskList.stream()
|
.filter(Objects::nonNull)
|
.filter(item -> item.getId() != null)
|
.collect(Collectors.toMap(ProductionOperationTask::getId,
|
ProductionOperationTask::getProductionOrderRoutingOperationId, (left, right) -> left));
|
Set<Long> routingOperationIdSet = taskIdToRoutingOperationIdMap.values().stream()
|
.filter(Objects::nonNull)
|
.collect(Collectors.toCollection(LinkedHashSet::new));
|
if (routingOperationIdSet.isEmpty()) {
|
for (ProductionProductMainDto item : recordList) {
|
if (item.getId() != null && missingMainIdSet.contains(item.getId())) {
|
item.setProductionOperationParamList(Collections.emptyList());
|
}
|
}
|
return;
|
}
|
|
List<ProductionOrderRoutingOperationParam> fallbackParamList = productionOrderRoutingOperationParamMapper.selectList(
|
Wrappers.<ProductionOrderRoutingOperationParam>lambdaQuery()
|
.in(ProductionOrderRoutingOperationParam::getProductionOrderRoutingOperationId, routingOperationIdSet)
|
.isNull(ProductionOrderRoutingOperationParam::getProductionProductMainId)
|
.orderByAsc(ProductionOrderRoutingOperationParam::getId));
|
Map<Long, List<ProductionOrderRoutingOperationParam>> fallbackGroupMap = new HashMap<>();
|
for (ProductionOrderRoutingOperationParam param : fallbackParamList) {
|
if (param == null || param.getProductionOrderRoutingOperationId() == null) {
|
continue;
|
}
|
fallbackGroupMap.computeIfAbsent(param.getProductionOrderRoutingOperationId(), key -> new ArrayList<>()).add(param);
|
}
|
|
for (ProductionProductMainDto item : recordList) {
|
Long mainId = item.getId();
|
if (mainId == null || !missingMainIdSet.contains(mainId)) {
|
continue;
|
}
|
Long taskId = mainIdToTaskIdMap.get(mainId);
|
Long routingOperationId = taskId == null ? null : taskIdToRoutingOperationIdMap.get(taskId);
|
if (routingOperationId == null) {
|
item.setProductionOperationParamList(Collections.emptyList());
|
continue;
|
}
|
item.setProductionOperationParamList(fallbackGroupMap.getOrDefault(routingOperationId, Collections.emptyList()));
|
}
|
}
|
|
@Override
|
public Boolean addProductMain(ProductionProductMainDto dto) {
|
Long taskId = resolveTaskId(dto);
|
if (taskId == null) {
|
throw new ServiceException("请传入生产工单ID");
|
}
|
return addProductMainByProductionTask(dto);
|
}
|
|
@Override
|
public Boolean saveProductionProductMain(ProductionProductMainDto productionProductMainDto) {
|
return addProductMain(productionProductMainDto);
|
}
|
|
@Override
|
public Boolean removeProductMain(Long id) {
|
ProductionProductMain currentMain = productionProductMainMapper.selectById(id);
|
if (currentMain == null) {
|
return true;
|
}
|
return removeProductMainByProductionTask(currentMain);
|
}
|
|
private Boolean addProductMainByProductionTask(ProductionProductMainDto dto) {
|
// 报工以订单工序快照为准，避免工艺主数据变更后影响历史工单执行。
|
Long taskId = resolveTaskId(dto);
|
if (taskId == null) {
|
throw new ServiceException("productionOperationTaskId can not be null");
|
}
|
SysUser user = userMapper.selectUserById(dto.getUserId());
|
ProductionOperationTask productionOperationTask = productionOperationTaskMapper.selectById(taskId);
|
if (productionOperationTask == null) {
|
throw new ServiceException("生产工单不存在");
|
}
|
ProductionOrderRoutingOperation routingOperation = productionOrderRoutingOperationMapper.selectById(productionOperationTask.getProductionOrderRoutingOperationId());
|
if (routingOperation == null) {
|
throw new ServiceException("订单工艺路线工序不存在");
|
}
|
ProductionOrder productionOrder = productionOrderMapper.selectById(productionOperationTask.getProductionOrderId());
|
if (productionOrder == null) {
|
throw new ServiceException("生产订单不存在");
|
}
|
TechnologyRoutingOperation technologyRoutingOperation = technologyRoutingOperationMapper.selectById(routingOperation.getTechnologyRoutingOperationId());
|
TechnologyOperation technologyOperation = technologyRoutingOperation == null ? null
|
: technologyOperationMapper.selectById(technologyRoutingOperation.getTechnologyOperationId());
|
ProductModel productModel = productModelMapper.selectById(
|
routingOperation.getProductModelId() != null ? routingOperation.getProductModelId() : productionOrder.getProductModelId());
|
if (productModel == null) {
|
throw new ServiceException("产品规格不存在");
|
}
|
|
ProductionProductMain productionProductMain = new ProductionProductMain();
|
productionProductMain.setProductNo(generateProductNo());
|
productionProductMain.setUserId(user == null ? dto.getUserId() : user.getUserId());
|
productionProductMain.setUserName(user == null ? dto.getUserName() : user.getNickName());
|
productionProductMain.setProductionOperationTaskId(taskId);
|
productionProductMain.setStatus(0);
|
productionProductMainMapper.insert(productionProductMain);
|
syncOperationParamInputValue(dto, routingOperation.getId(), productionProductMain.getId());
|
|
List<ProductStructureDto> productStructureDtos = resolveInputStructures(
|
productionOrder.getId(), routingOperation, productModel.getId());
|
// 如果没有bom子节点了，那么投入就是他本身
|
if (productStructureDtos.isEmpty()) {
|
ProductStructureDto fallbackInput = new ProductStructureDto();
|
fallbackInput.setProductModelId(productModel.getId());
|
fallbackInput.setUnitQuantity(BigDecimal.ONE);
|
productStructureDtos.add(fallbackInput);
|
}
|
for (ProductStructureDto item : productStructureDtos) {
|
// 当前实现按工序成品直接作为投入，后续若接入领料记录可在这里替换来源。
|
ProductionProductInput productionProductInput = new ProductionProductInput();
|
productionProductInput.setProductionProductMainId(productionProductMain.getId());
|
productionProductInput.setProductMainId(productionProductMain.getId());
|
productionProductInput.setProductModelId(item.getProductModelId());
|
productionProductInput.setInputQuantity(item.getUnitQuantity().multiply(defaultDecimal(dto.getQuantity())));
|
productionProductInput.setQuantity(productionProductInput.getInputQuantity());
|
productionProductInputMapper.insert(productionProductInput);
|
}
|
|
ProductionProductOutput productionProductOutput = new ProductionProductOutput();
|
productionProductOutput.setProductionProductMainId(productionProductMain.getId());
|
productionProductOutput.setProductMainId(productionProductMain.getId());
|
productionProductOutput.setProductModelId(productModel.getId());
|
productionProductOutput.setQuantity(defaultDecimal(dto.getQuantity()));
|
productionProductOutput.setScrapQty(defaultDecimal(dto.getScrapQty()));
|
productionProductOutputMapper.insert(productionProductOutput);
|
BigDecimal reportQty = defaultDecimal(productionProductOutput.getQuantity());
|
BigDecimal productQty = reportQty;
|
|
List<ProductionOrderRoutingOperation> routingOperationList = productionOrderRoutingOperationMapper.selectList(
|
Wrappers.<ProductionOrderRoutingOperation>lambdaQuery()
|
.eq(ProductionOrderRoutingOperation::getOrderRoutingId, routingOperation.getOrderRoutingId())
|
.eq(ProductionOrderRoutingOperation::getProductionOrderId, routingOperation.getProductionOrderId()));
|
boolean isLastOperation = routingOperation.getDragSort() != null && routingOperation.getDragSort().equals(routingOperationList.size());
|
if (productQty.compareTo(BigDecimal.ZERO) > 0) {
|
if (Boolean.TRUE.equals(routingOperation.getIsQuality())) {
|
// 质检工序先生成检验单，非质检工序直接入合格品库存。
|
int inspectType = isLastOperation ? 2 : 1;
|
String process = isLastOperation ? null : technologyOperation == null ? null : technologyOperation.getName();
|
Product product = productMapper.selectById(productModel.getProductId());
|
QualityInspect qualityInspect = new QualityInspect();
|
qualityInspect.setProductId(product.getId());
|
qualityInspect.setProductName(product.getProductName());
|
qualityInspect.setModel(productModel.getModel());
|
qualityInspect.setUnit(productModel.getUnit());
|
qualityInspect.setQuantity(productQty);
|
qualityInspect.setProcess(process);
|
qualityInspect.setInspectState(0);
|
qualityInspect.setInspectType(inspectType);
|
qualityInspect.setProductMainId(productionProductMain.getId());
|
qualityInspect.setProductModelId(productModel.getId());
|
qualityInspectMapper.insert(qualityInspect);
|
List<QualityTestStandard> qualityTestStandard = qualityTestStandardMapper.getQualityTestStandardByProductId(product.getId(), inspectType, process);
|
if (!qualityTestStandard.isEmpty()) {
|
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);
|
});
|
}
|
} else {
|
StockInventoryDto stockInventoryDto = new StockInventoryDto();
|
stockInventoryDto.setRecordId(productionProductMain.getId());
|
stockInventoryDto.setRecordType(String.valueOf(StockInQualifiedRecordTypeEnum.PRODUCTION_REPORT_STOCK_IN.getCode()));
|
stockInventoryDto.setQualitity(productQty);
|
stockInventoryDto.setProductModelId(productModel.getId());
|
stockInventoryService.addStockInRecordOnly(stockInventoryDto);
|
}
|
|
productionOperationTask.setCompleteQuantity(defaultDecimal(productionOperationTask.getCompleteQuantity()).add(productQty));
|
if (ObjectUtils.isNull(productionOperationTask.getActualStartTime())) {
|
productionOperationTask.setActualStartTime(LocalDate.now());
|
}
|
// 报工驱动工单状态流转：有产出即进行中，达到计划量即完工。
|
productionOperationTask.setStatus(3);
|
if (productionOperationTask.getPlanQuantity() != null
|
&& productionOperationTask.getCompleteQuantity().compareTo(productionOperationTask.getPlanQuantity()) >= 0) {
|
productionOperationTask.setActualEndTime(LocalDate.now());
|
productionOperationTask.setStatus(4);
|
}
|
productionOperationTaskMapper.updateById(productionOperationTask);
|
|
if (ObjectUtils.isNull(productionOrder.getStartTime())) {
|
productionOrder.setStartTime(LocalDateTime.now());
|
}
|
// 订单状态由最后一道工序的合格产出推动，避免中间工序提前完工。
|
productionOrder.setStatus(ProductOrderStatusEnum.RUNNING.getCode());
|
if (isLastOperation) {
|
productionOrder.setCompleteQuantity(defaultDecimal(productionOrder.getCompleteQuantity()).add(productQty));
|
if (productionOrder.getQuantity() != null
|
&& productionOrder.getCompleteQuantity().compareTo(productionOrder.getQuantity()) >= 0) {
|
productionOrder.setEndTime(LocalDateTime.now());
|
productionOrder.setStatus(ProductOrderStatusEnum.FINISHED.getCode());
|
}
|
}
|
productionOrderMapper.updateById(productionOrder);
|
|
BigDecimal workHours = BigDecimal.ZERO;
|
if (technologyOperation != null && technologyOperation.getSalaryQuota() != null) {
|
workHours = Integer.valueOf(1).equals(technologyOperation.getType())
|
? technologyOperation.getSalaryQuota().multiply(productQty)
|
: technologyOperation.getSalaryQuota();
|
}
|
ProductionAccount productionAccount = new ProductionAccount();
|
productionAccount.setProductionProductMainId(productionProductMain.getId());
|
// productionAccount.setSalesLedgerId(productionOrder.getSalesLedgerId());
|
// productionAccount.setSalesLedgerProductId(productionOrder.getSalesLedgerProductId() == null ? null : productionOrder.getSalesLedgerProductId().longValue());
|
productionAccount.setSchedulingUserId(user == null ? null : user.getUserId());
|
productionAccount.setSchedulingUserName(user == null ? dto.getUserName() : user.getNickName());
|
productionAccount.setFinishedNum(productQty);
|
productionAccount.setWorkHours(workHours);
|
productionAccount.setTechnologyOperationName(technologyOperation == null ? null : technologyOperation.getName());
|
productionAccount.setSchedulingDate(LocalDateTime.now());
|
productionAccountMapper.insert(productionAccount);
|
}
|
// if (defaultDecimal(dto.getScrapQty()).compareTo(BigDecimal.ZERO) > 0) {
|
// stockUtils.addUnStock(productModel.getId(), dto.getScrapQty(),
|
// StockInUnQualifiedRecordTypeEnum.PRODUCTION_SCRAP.getCode(), productionProductMain.getId());
|
// }
|
return true;
|
}
|
|
private void syncOperationParamInputValue(ProductionProductMainDto dto,
|
Long productionOrderRoutingOperationId,
|
Long productionProductMainId) {
|
if (dto == null || productionOrderRoutingOperationId == null || productionProductMainId == null) {
|
return;
|
}
|
List<ProductionOrderRoutingOperationParam> paramList = dto.getProductionOperationParamList();
|
if (paramList == null || paramList.isEmpty()) {
|
return;
|
}
|
Set<Long> sourceParamIdSet = paramList.stream()
|
.filter(Objects::nonNull)
|
.map(ProductionOrderRoutingOperationParam::getId)
|
.filter(Objects::nonNull)
|
.collect(Collectors.toCollection(LinkedHashSet::new));
|
if (sourceParamIdSet.isEmpty()) {
|
return;
|
}
|
|
List<ProductionOrderRoutingOperationParam> dbParamList = productionOrderRoutingOperationParamMapper.selectList(
|
Wrappers.<ProductionOrderRoutingOperationParam>lambdaQuery()
|
.in(ProductionOrderRoutingOperationParam::getId, sourceParamIdSet)
|
.eq(ProductionOrderRoutingOperationParam::getProductionOrderRoutingOperationId, productionOrderRoutingOperationId));
|
if (dbParamList == null || dbParamList.isEmpty()) {
|
return;
|
}
|
|
Map<Long, ProductionOrderRoutingOperationParam> dbParamMap = dbParamList.stream()
|
.filter(item -> item != null && item.getId() != null)
|
.collect(Collectors.toMap(ProductionOrderRoutingOperationParam::getId, item -> item, (left, right) -> left));
|
for (ProductionOrderRoutingOperationParam param : paramList) {
|
if (param == null || param.getId() == null) {
|
continue;
|
}
|
ProductionOrderRoutingOperationParam dbParam = dbParamMap.get(param.getId());
|
if (dbParam == null) {
|
throw new ServiceException("工序参数不存在或不属于当前工单工序，ID=" + param.getId());
|
}
|
productionOrderRoutingOperationParamMapper.insert(buildReportParamSnapshot(dbParam, param.getInputValue(), productionProductMainId));
|
}
|
}
|
|
private ProductionOrderRoutingOperationParam buildReportParamSnapshot(ProductionOrderRoutingOperationParam source,
|
String inputValue,
|
Long productionProductMainId) {
|
ProductionOrderRoutingOperationParam target = new ProductionOrderRoutingOperationParam();
|
target.setProductionOrderId(source.getProductionOrderId());
|
target.setTechnologyRoutingOperationParamId(source.getTechnologyRoutingOperationParamId());
|
target.setParamCode(source.getParamCode());
|
target.setParamName(source.getParamName());
|
target.setParamType(source.getParamType());
|
target.setParamFormat(source.getParamFormat());
|
target.setUnit(source.getUnit());
|
target.setIsRequired(source.getIsRequired());
|
target.setRemark(source.getRemark());
|
target.setParamId(source.getParamId());
|
target.setTechnologyOperationId(source.getTechnologyOperationId());
|
target.setTechnologyOperationParamId(source.getTechnologyOperationParamId());
|
target.setStandardValue(source.getStandardValue());
|
target.setInputValue(inputValue);
|
target.setProductionOrderRoutingOperationId(source.getProductionOrderRoutingOperationId());
|
target.setProductionProductMainId(productionProductMainId);
|
return target;
|
}
|
|
private List<ProductStructureDto> resolveInputStructures(Long productionOrderId,
|
ProductionOrderRoutingOperation routingOperation,
|
Long outputProductModelId) {
|
if (productionOrderId == null || routingOperation == null || routingOperation.getTechnologyOperationId() == null) {
|
return new ArrayList<>();
|
}
|
ProductionOrderBom orderBom = productionOrderBomMapper.selectOne(
|
Wrappers.<ProductionOrderBom>lambdaQuery()
|
.eq(ProductionOrderBom::getProductionOrderId, productionOrderId)
|
.orderByDesc(ProductionOrderBom::getId)
|
.last("limit 1"));
|
if (orderBom == null || orderBom.getId() == null) {
|
return new ArrayList<>();
|
}
|
|
List<ProductionBomStructure> bomNodeList = productionBomStructureMapper.selectList(
|
Wrappers.<ProductionBomStructure>lambdaQuery()
|
.eq(ProductionBomStructure::getProductionOrderBomId, orderBom.getId())
|
.orderByAsc(ProductionBomStructure::getId));
|
if (bomNodeList.isEmpty()) {
|
return new ArrayList<>();
|
}
|
|
Map<Long, ProductionBomStructure> nodeMap = bomNodeList.stream()
|
.filter(item -> item != null && item.getId() != null)
|
.collect(Collectors.toMap(ProductionBomStructure::getId, item -> item, (left, right) -> left));
|
Long currentOutputModelId = routingOperation.getProductModelId() != null
|
? routingOperation.getProductModelId()
|
: outputProductModelId;
|
|
Map<Long, BigDecimal> unitQtyByProductModel = new LinkedHashMap<>();
|
for (ProductionBomStructure node : bomNodeList) {
|
if (node == null || node.getParentId() == null || node.getProductModelId() == null) {
|
continue;
|
}
|
if (!Objects.equals(node.getTechnologyOperationId(), routingOperation.getTechnologyOperationId())) {
|
continue;
|
}
|
ProductionBomStructure parent = nodeMap.get(node.getParentId());
|
if (parent == null || !Objects.equals(parent.getProductModelId(), currentOutputModelId)) {
|
continue;
|
}
|
unitQtyByProductModel.merge(node.getProductModelId(), defaultDecimal(node.getUnitQuantity()), BigDecimal::add);
|
}
|
|
List<ProductStructureDto> result = new ArrayList<>();
|
for (Map.Entry<Long, BigDecimal> entry : unitQtyByProductModel.entrySet()) {
|
if (entry.getValue().compareTo(BigDecimal.ZERO) <= 0) {
|
continue;
|
}
|
ProductStructureDto item = new ProductStructureDto();
|
item.setProductModelId(entry.getKey());
|
item.setUnitQuantity(entry.getValue());
|
result.add(item);
|
}
|
return result;
|
}
|
|
private Boolean removeProductMainByProductionTask(ProductionProductMain productionProductMain) {
|
// 删除报工需要同步回滚质检、库存、工时核算和订单/工单进度。
|
List<QualityInspect> qualityInspects = qualityInspectMapper.selectList(
|
Wrappers.<QualityInspect>lambdaQuery().eq(QualityInspect::getProductMainId, productionProductMain.getId()));
|
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("该条报工已经不合格处理了，不允许删除");
|
}
|
}
|
ProductionProductOutput productionProductOutput = productionProductOutputMapper.selectList(
|
Wrappers.<ProductionProductOutput>lambdaQuery()
|
.eq(ProductionProductOutput::getProductionProductMainId, productionProductMain.getId()))
|
.stream().findFirst().orElse(null);
|
productionAccountMapper.delete(new LambdaQueryWrapper<ProductionAccount>()
|
.eq(ProductionAccount::getProductionProductMainId, productionProductMain.getId()));
|
|
ProductionOperationTask productionOperationTask = productionOperationTaskMapper.selectById(productionProductMain.getProductionOperationTaskId());
|
if (productionOperationTask != null && productionProductOutput != null) {
|
BigDecimal reportQuantity = defaultDecimal(productionProductOutput.getQuantity());
|
productionOperationTask.setCompleteQuantity(defaultDecimal(productionOperationTask.getCompleteQuantity()).subtract(reportQuantity));
|
productionOperationTask.setActualEndTime(null);
|
if (defaultDecimal(productionOperationTask.getCompleteQuantity()).compareTo(BigDecimal.ZERO) <= 0) {
|
productionOperationTask.setCompleteQuantity(BigDecimal.ZERO);
|
productionOperationTask.setActualStartTime(null);
|
productionOperationTask.setStatus(2);
|
} else {
|
productionOperationTask.setStatus(3);
|
}
|
productionOperationTaskMapper.updateById(productionOperationTask);
|
|
ProductionOrder productionOrder = productionOrderMapper.selectById(productionOperationTask.getProductionOrderId());
|
ProductionOrderRoutingOperation routingOperation = productionOrderRoutingOperationMapper.selectById(productionOperationTask.getProductionOrderRoutingOperationId());
|
if (productionOrder != null && routingOperation != null) {
|
// 只有最后一道工序的报工才会影响生产订单完工数量。
|
List<ProductionOrderRoutingOperation> routingOperationList = productionOrderRoutingOperationMapper.selectList(
|
Wrappers.<ProductionOrderRoutingOperation>lambdaQuery()
|
.eq(ProductionOrderRoutingOperation::getOrderRoutingId, routingOperation.getOrderRoutingId())
|
.eq(ProductionOrderRoutingOperation::getProductionOrderId, routingOperation.getProductionOrderId()));
|
boolean isLastOperation = routingOperation.getDragSort() != null && routingOperation.getDragSort().equals(routingOperationList.size());
|
if (isLastOperation) {
|
BigDecimal newCompleteQty = defaultDecimal(productionOrder.getCompleteQuantity()).subtract(reportQuantity);
|
productionOrder.setCompleteQuantity(newCompleteQty.compareTo(BigDecimal.ZERO) < 0 ? BigDecimal.ZERO : newCompleteQty);
|
productionOrder.setEndTime(null);
|
}
|
if (defaultDecimal(productionOrder.getCompleteQuantity()).compareTo(BigDecimal.ZERO) <= 0) {
|
productionOrder.setStartTime(null);
|
productionOrder.setStatus(ProductOrderStatusEnum.WAIT.getCode());
|
} else {
|
productionOrder.setStatus(ProductOrderStatusEnum.RUNNING.getCode());
|
}
|
productionOrderMapper.updateById(productionOrder);
|
}
|
}
|
|
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::getProductionProductMainId, productionProductMain.getId()));
|
productionProductInputMapper.delete(new LambdaQueryWrapper<ProductionProductInput>()
|
.eq(ProductionProductInput::getProductionProductMainId, productionProductMain.getId()));
|
productionOrderRoutingOperationParamMapper.delete(
|
Wrappers.<ProductionOrderRoutingOperationParam>lambdaQuery()
|
.eq(ProductionOrderRoutingOperationParam::getProductionProductMainId, 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;
|
}
|
|
private String generateProductNo() {
|
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 && result.get("maxNo") != null) {
|
String lastNo = result.get("maxNo").toString();
|
if (lastNo.startsWith(datePrefix)) {
|
try {
|
sequenceNumber = Integer.parseInt(lastNo.substring(datePrefix.length())) + 1;
|
} catch (NumberFormatException e) {
|
sequenceNumber = 1;
|
}
|
}
|
}
|
}
|
return String.format("%s%03d", datePrefix, sequenceNumber);
|
}
|
|
private BigDecimal defaultDecimal(BigDecimal value) {
|
return value == null ? BigDecimal.ZERO : value;
|
}
|
|
private Long resolveTaskId(ProductionProductMainDto dto) {
|
if (dto == null) {
|
return null;
|
}
|
return dto.getProductionOperationTaskId();
|
}
|
|
@Override
|
public ArrayList<Long> listMain(List<Long> idList) {
|
return productionProductMainMapper.listMain(idList);
|
}
|
}
|
