|
|
|
@ -30,6 +30,7 @@ import com.baomidou.mybatisplus.core.conditions.Wrapper; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
|
|
|
|
|
|
|
import jakarta.annotation.Resource; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.springblade.core.log.exception.ServiceException; |
|
|
|
import org.springblade.core.log.exception.ServiceException; |
|
|
|
import org.springblade.core.mp.base.BaseServiceImpl; |
|
|
|
import org.springblade.core.mp.base.BaseServiceImpl; |
|
|
|
@ -64,8 +65,12 @@ import org.springblade.desk.produce.service.IPdaSaveService; |
|
|
|
import org.springblade.desk.produce.service.IWorkOrderService; |
|
|
|
import org.springblade.desk.produce.service.IWorkOrderService; |
|
|
|
import org.springblade.desk.produce.service.IWorkPlanService; |
|
|
|
import org.springblade.desk.produce.service.IWorkPlanService; |
|
|
|
import org.springblade.desk.quality.pojo.dto.PpmReportDetailDTO; |
|
|
|
import org.springblade.desk.quality.pojo.dto.PpmReportDetailDTO; |
|
|
|
|
|
|
|
import org.springblade.desk.quality.pojo.entity.InspectionItem; |
|
|
|
|
|
|
|
import org.springblade.desk.quality.pojo.entity.Standard; |
|
|
|
import org.springblade.desk.quality.pojo.request.ReviewSheetErpSearch; |
|
|
|
import org.springblade.desk.quality.pojo.request.ReviewSheetErpSearch; |
|
|
|
|
|
|
|
import org.springblade.desk.quality.service.IInspectionItemService; |
|
|
|
import org.springblade.desk.quality.service.IReviewSheetService; |
|
|
|
import org.springblade.desk.quality.service.IReviewSheetService; |
|
|
|
|
|
|
|
import org.springblade.desk.quality.service.IStandardService; |
|
|
|
import org.springblade.erpdata.feign.IErpDataReworkTaskClient; |
|
|
|
import org.springblade.erpdata.feign.IErpDataReworkTaskClient; |
|
|
|
import org.springblade.scheduling.pojo.entity.PartRelationEntity; |
|
|
|
import org.springblade.scheduling.pojo.entity.PartRelationEntity; |
|
|
|
import org.springblade.scheduling.pojo.entity.WorkOrderEntity; |
|
|
|
import org.springblade.scheduling.pojo.entity.WorkOrderEntity; |
|
|
|
@ -198,6 +203,12 @@ public class DsTaskingServiceImpl extends BaseServiceImpl<DsTaskingMapper, DsTas |
|
|
|
@Lazy |
|
|
|
@Lazy |
|
|
|
IPdaSaveService pdaSaveService; |
|
|
|
IPdaSaveService pdaSaveService; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Resource |
|
|
|
|
|
|
|
IInspectionItemService inspectionItemService; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Resource |
|
|
|
|
|
|
|
private IStandardService standardService; |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public IPage<DsTaskingVO> selectAssignList(IPage<DsTaskingVO> page, DsTaskingVO dsTasking) { |
|
|
|
public IPage<DsTaskingVO> selectAssignList(IPage<DsTaskingVO> page, DsTaskingVO dsTasking) { |
|
|
|
List<DsTaskingVO> dsTaskingVOS = baseMapper.selectDsTaskingPage(page, dsTasking); |
|
|
|
List<DsTaskingVO> dsTaskingVOS = baseMapper.selectDsTaskingPage(page, dsTasking); |
|
|
|
@ -1065,6 +1076,7 @@ public class DsTaskingServiceImpl extends BaseServiceImpl<DsTaskingMapper, DsTas |
|
|
|
for (DsCraftVO craftVO : dsCraftVOList) { |
|
|
|
for (DsCraftVO craftVO : dsCraftVOList) { |
|
|
|
// 查询工序信息
|
|
|
|
// 查询工序信息
|
|
|
|
List<DsProcessEntity> processEntities = processService.selectDsProcessByCraftId(craftVO.getId()); |
|
|
|
List<DsProcessEntity> processEntities = processService.selectDsProcessByCraftId(craftVO.getId()); |
|
|
|
|
|
|
|
|
|
|
|
// 每次循环创建新的craftTree对象
|
|
|
|
// 每次循环创建新的craftTree对象
|
|
|
|
CraftTreeVO craftTree1 = new CraftTreeVO(); |
|
|
|
CraftTreeVO craftTree1 = new CraftTreeVO(); |
|
|
|
craftVO.setReworkOrder(dsTaskingEntity.getReworkOrder()); |
|
|
|
craftVO.setReworkOrder(dsTaskingEntity.getReworkOrder()); |
|
|
|
@ -1149,6 +1161,20 @@ public class DsTaskingServiceImpl extends BaseServiceImpl<DsTaskingMapper, DsTas |
|
|
|
* 将正常工序列表转换为返工工序列表 |
|
|
|
* 将正常工序列表转换为返工工序列表 |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
private List<PrReworkProcessEntity> convertToReworkProcessList(List<DsProcessEntity> processEntities, DsTaskingEntity dsTaskingEntity) { |
|
|
|
private List<PrReworkProcessEntity> convertToReworkProcessList(List<DsProcessEntity> processEntities, DsTaskingEntity dsTaskingEntity) { |
|
|
|
|
|
|
|
for (DsProcessEntity processEntity : processEntities) { |
|
|
|
|
|
|
|
if (processEntity == null) { |
|
|
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Optional.ofNullable(processEntity.getPpsId()) |
|
|
|
|
|
|
|
.map(processSetService::getById) |
|
|
|
|
|
|
|
.ifPresent(processSet -> processEntity.setProcessName(processSet.getName())); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Optional.ofNullable(processEntity.getCaId()) |
|
|
|
|
|
|
|
.map(craftAbilityService::getById) |
|
|
|
|
|
|
|
.ifPresent(craftAbility -> processEntity.setCraftName(craftAbility.getCaName())); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
List<WorkPlan> originalOrderProcess = pdaSaveService.getOriginalOrderProcess(dsTaskingEntity.getPartCode(), dsTaskingEntity.getBatchNo()); |
|
|
|
List<WorkPlan> originalOrderProcess = pdaSaveService.getOriginalOrderProcess(dsTaskingEntity.getPartCode(), dsTaskingEntity.getBatchNo()); |
|
|
|
// 转换为Map便于快速查找
|
|
|
|
// 转换为Map便于快速查找
|
|
|
|
Map<Long, WorkPlan> workPlanMap = new HashMap<>(); |
|
|
|
Map<Long, WorkPlan> workPlanMap = new HashMap<>(); |
|
|
|
@ -2337,6 +2363,18 @@ public class DsTaskingServiceImpl extends BaseServiceImpl<DsTaskingMapper, DsTas |
|
|
|
processProjectList.forEach(item -> { |
|
|
|
processProjectList.forEach(item -> { |
|
|
|
item.setId(null); |
|
|
|
item.setId(null); |
|
|
|
item.setProcessId(dsProcessEntity.getId()); |
|
|
|
item.setProcessId(dsProcessEntity.getId()); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 根据项目名称查询项目编码
|
|
|
|
|
|
|
|
if (StringUtils.isEmpty(item.getProjectCode()) && !StringUtils.isEmpty(item.getProjectName())) { |
|
|
|
|
|
|
|
Optional.ofNullable(inspectionItemService.selectByName(item.getProjectName())) |
|
|
|
|
|
|
|
.ifPresent(inspectionItem -> item.setProjectCode(inspectionItem.getId().toString())); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 根据项目标准名称查询项目标准
|
|
|
|
|
|
|
|
if (StringUtils.isEmpty(item.getProjectStandard()) && !StringUtils.isEmpty(item.getProjectStandardName())) { |
|
|
|
|
|
|
|
Optional.ofNullable(standardService.selectByName(item.getProjectStandardName())) |
|
|
|
|
|
|
|
.ifPresent(standard -> item.setProjectStandard(standard.getId().toString())); |
|
|
|
|
|
|
|
} |
|
|
|
}); |
|
|
|
}); |
|
|
|
if(!CollectionUtils.isEmpty(processProjectList)){ |
|
|
|
if(!CollectionUtils.isEmpty(processProjectList)){ |
|
|
|
boolean processProjectSaveBatch = processProjectService.saveBatch(processProjectList); |
|
|
|
boolean processProjectSaveBatch = processProjectService.saveBatch(processProjectList); |
|
|
|
|