fix(标准主计划): 数据回显完善

This commit is contained in:
yjz
2024-07-30 20:20:56 +08:00
parent 3b2f88facf
commit 09c46f148a
2 changed files with 41 additions and 24 deletions
@@ -202,9 +202,10 @@ public class LawsConformityAssessmentLibraryServiceImpl extends ServiceImpl<Laws
QueryWrapper<LawsConformityAssessmentLibrary> queryWrapper = new QueryWrapper<>(); QueryWrapper<LawsConformityAssessmentLibrary> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(StringUtils.isNotBlank(lawsConformityAssessmentLibrary.getStandardNumber()), queryWrapper.eq(StringUtils.isNotBlank(lawsConformityAssessmentLibrary.getStandardNumber()),
"d.standard_number", lawsConformityAssessmentLibrary.getStandardNumber()); "d.standard_number", lawsConformityAssessmentLibrary.getStandardNumber());
if (StringUtils.isNotBlank(lawsConformityAssessmentLibrary.getApplicableMarket())) { queryWrapper.like(StringUtils.isNotBlank(lawsConformityAssessmentLibrary.getApplicableMarket())
queryWrapper.in("d.applicable_market", Arrays.asList(lawsConformityAssessmentLibrary.getApplicableMarket().split(","))); ,"lms.country", lawsConformityAssessmentLibrary.getApplicableMarket());
} queryWrapper.orderByAsc("cs.valuation_time");
queryWrapper.last("limit 1");
List<LawsConformityAssessmentLibrary> result = lawsConformityAssessmentLibraryMapper.queryByPage(queryWrapper); List<LawsConformityAssessmentLibrary> result = lawsConformityAssessmentLibraryMapper.queryByPage(queryWrapper);
if (CollectionUtils.isNotEmpty(result)){ if (CollectionUtils.isNotEmpty(result)){
return result.get(0); return result.get(0);
@@ -217,7 +217,8 @@ public class LawsStandardMasterPlanServiceImpl
.map(ProcessNewStandardImport::getProcessInstanceId).collect(Collectors.toList()); .map(ProcessNewStandardImport::getProcessInstanceId).collect(Collectors.toList());
List<ProcessAll> processAllList = processAllService.list(new LambdaQueryWrapper<ProcessAll>() List<ProcessAll> processAllList = processAllService.list(new LambdaQueryWrapper<ProcessAll>()
.in(ProcessAll::getProcessInstanceId, processInstanceIdList) .in(ProcessAll::getProcessInstanceId, processInstanceIdList)
.orderByAsc(ProcessAll::getEndTime)); .orderByAsc(ProcessAll::getEndTime)
.last("limit 1"));
if (CollectionUtils.isNotEmpty(processAllList)){ if (CollectionUtils.isNotEmpty(processAllList)){
ProcessAll processAll = processAllList.get(0); ProcessAll processAll = processAllList.get(0);
lawsStandardMasterPlanSublist.setActualCompletionDate(processAll.getEndTime()); lawsStandardMasterPlanSublist.setActualCompletionDate(processAll.getEndTime());
@@ -267,10 +268,11 @@ public class LawsStandardMasterPlanServiceImpl
break; break;
// 车型整改 // 车型整改
case LawsStandardMasterPlanCommon.VEHICLE_MODEL_RECTIFICATION: case LawsStandardMasterPlanCommon.VEHICLE_MODEL_RECTIFICATION:
// 根据 标准编号+整改状态为已关闭 最迟关闭(修改时间) 查询 不符合项库
List<LawsEvaluationNotMetLibrary> list = lawsEvaluationNotMetLibraryService.list( List<LawsEvaluationNotMetLibrary> list = lawsEvaluationNotMetLibraryService.list(
new LambdaQueryWrapper<LawsEvaluationNotMetLibrary>() new LambdaQueryWrapper<LawsEvaluationNotMetLibrary>()
.eq(LawsEvaluationNotMetLibrary::getStandardId, .eq(LawsEvaluationNotMetLibrary::getStandardNumber,
lawsStandardMasterPlan.getStandardId()) lawsDomesticStandard.getStandardNumber())
.eq(LawsEvaluationNotMetLibrary::getRectifyStatus, "2") .eq(LawsEvaluationNotMetLibrary::getRectifyStatus, "2")
.orderByDesc(LawsEvaluationNotMetLibrary::getUpdateTime)); .orderByDesc(LawsEvaluationNotMetLibrary::getUpdateTime));
if (CollectionUtils.isNotEmpty(list)){ if (CollectionUtils.isNotEmpty(list)){
@@ -405,23 +407,35 @@ public class LawsStandardMasterPlanServiceImpl
public void syncRegulatoryComplianceInvestigation(LawsConformityAssessmentLibrary lawsConformityAssessmentLibrary) { public void syncRegulatoryComplianceInvestigation(LawsConformityAssessmentLibrary lawsConformityAssessmentLibrary) {
LawsStandardMasterPlanVO lawsStandardMasterPlanVO = new LawsStandardMasterPlanVO(); LawsStandardMasterPlanVO lawsStandardMasterPlanVO = new LawsStandardMasterPlanVO();
String standardNumber = lawsConformityAssessmentLibrary.getStandardNumber(); String standardNumber = lawsConformityAssessmentLibrary.getStandardNumber();
String applicableMarket = lawsConformityAssessmentLibrary.getApplicableMarket(); String applicableMarkets = lawsConformityAssessmentLibrary.getApplicableMarket();
if (StringUtils.isBlank(standardNumber) || StringUtils.isBlank(applicableMarket)){ if (StringUtils.isBlank(standardNumber) || StringUtils.isBlank(applicableMarkets)){
return; return;
} }
lawsStandardMasterPlanVO.setStandardNumber(standardNumber); // 适用市场可能会有多个
lawsStandardMasterPlanVO.setApplicableMarket(applicableMarket); for (String applicableMarket : applicableMarkets.split(",")) {
List<LawsStandardMasterPlanVO> lawsStandardMasterPlanVOList = queryByList(lawsStandardMasterPlanVO); // 判断是不是最早的
if (CollectionUtils.isNotEmpty(lawsStandardMasterPlanVOList)){ lawsConformityAssessmentLibrary.setStandardNumber(standardNumber);
// 更新标准主计划数据 lawsConformityAssessmentLibrary.setApplicableMarket(applicableMarket);
List<String> idList = lawsStandardMasterPlanVOList.stream() LawsConformityAssessmentLibrary lawsConformityAssessmentLibrary1 =
.map(LawsStandardMasterPlanVO::getId).collect(Collectors.toList()); lawsConformityAssessmentLibraryService.queryOne(lawsConformityAssessmentLibrary);
lawsStandardMasterPlanSublistService.update(new LambdaUpdateWrapper<LawsStandardMasterPlanSublist>() if (!Objects.isNull(lawsConformityAssessmentLibrary1) &&
.in(LawsStandardMasterPlanSublist::getMasterPlanId, idList) lawsConformityAssessmentLibrary1.getId().equals(lawsConformityAssessmentLibrary.getId())){
.eq(LawsStandardMasterPlanSublist::getType, // 查询标准主计划
LawsStandardMasterPlanCommon.REGULATORY_COMPLIANCE_INVESTIGATION) lawsStandardMasterPlanVO.setStandardNumber(standardNumber);
.isNull(LawsStandardMasterPlanSublist::getAssociationId) lawsStandardMasterPlanVO.setApplicableMarket(applicableMarket);
.set(LawsStandardMasterPlanSublist::getAssociationId, lawsConformityAssessmentLibrary.getId())); List<LawsStandardMasterPlanVO> lawsStandardMasterPlanVOList = queryByList(lawsStandardMasterPlanVO);
if (CollectionUtils.isNotEmpty(lawsStandardMasterPlanVOList)){
// 更新标准主计划数据
List<String> idList = lawsStandardMasterPlanVOList.stream()
.map(LawsStandardMasterPlanVO::getId).collect(Collectors.toList());
lawsStandardMasterPlanSublistService.update(new LambdaUpdateWrapper<LawsStandardMasterPlanSublist>()
.in(LawsStandardMasterPlanSublist::getMasterPlanId, idList)
.eq(LawsStandardMasterPlanSublist::getType,
LawsStandardMasterPlanCommon.REGULATORY_COMPLIANCE_INVESTIGATION)
.isNull(LawsStandardMasterPlanSublist::getAssociationId)
.set(LawsStandardMasterPlanSublist::getAssociationId, lawsConformityAssessmentLibrary.getId()));
}
}
} }
} }
@@ -470,7 +484,8 @@ public class LawsStandardMasterPlanServiceImpl
.map(ProcessNewStandardImport::getProcessInstanceId).collect(Collectors.toList()); .map(ProcessNewStandardImport::getProcessInstanceId).collect(Collectors.toList());
List<ProcessAll> processAllList = processAllService.list(new LambdaQueryWrapper<ProcessAll>() List<ProcessAll> processAllList = processAllService.list(new LambdaQueryWrapper<ProcessAll>()
.in(ProcessAll::getProcessInstanceId, processInstanceIdList) .in(ProcessAll::getProcessInstanceId, processInstanceIdList)
.orderByAsc(ProcessAll::getEndTime)); .orderByAsc(ProcessAll::getEndTime)
.last("limit 1"));
if (CollectionUtils.isNotEmpty(processAllList)){ if (CollectionUtils.isNotEmpty(processAllList)){
ProcessAll processAll = processAllList.get(0); ProcessAll processAll = processAllList.get(0);
masterPlanSublist.setActualCompletionDate(processAll.getEndTime()); masterPlanSublist.setActualCompletionDate(processAll.getEndTime());
@@ -527,7 +542,7 @@ public class LawsStandardMasterPlanServiceImpl
// 法规符合性排查 // 法规符合性排查
LawsStandardMasterPlanSublist masterPlanSublist3 = new LawsStandardMasterPlanSublist(); LawsStandardMasterPlanSublist masterPlanSublist3 = new LawsStandardMasterPlanSublist();
masterPlanSublist3.setType(LawsStandardMasterPlanCommon.REGULATORY_COMPLIANCE_INVESTIGATION); masterPlanSublist3.setType(LawsStandardMasterPlanCommon.REGULATORY_COMPLIANCE_INVESTIGATION);
// 根据 标准名称+适用市场 查询 法规符合性排查 // 根据 标准编号+适用市场 最早评估日期 查询 法规符合性排查
LawsConformityAssessmentLibrary lawsConformityAssessmentLibrary = LawsConformityAssessmentLibrary lawsConformityAssessmentLibrary =
new LawsConformityAssessmentLibrary(); new LawsConformityAssessmentLibrary();
lawsConformityAssessmentLibrary.setStandardNumber(lawsDomesticStandard.getStandardNumber()); lawsConformityAssessmentLibrary.setStandardNumber(lawsDomesticStandard.getStandardNumber());
@@ -543,9 +558,10 @@ public class LawsStandardMasterPlanServiceImpl
// 车型整改 // 车型整改
LawsStandardMasterPlanSublist masterPlanSublist4 = new LawsStandardMasterPlanSublist(); LawsStandardMasterPlanSublist masterPlanSublist4 = new LawsStandardMasterPlanSublist();
masterPlanSublist4.setType(LawsStandardMasterPlanCommon.VEHICLE_MODEL_RECTIFICATION); masterPlanSublist4.setType(LawsStandardMasterPlanCommon.VEHICLE_MODEL_RECTIFICATION);
// 根据 标准编号+整改状态为已关闭 最迟关闭(修改时间) 查询 不符合项库
List<LawsEvaluationNotMetLibrary> lawsEvaluationNotMetLibraryList = lawsEvaluationNotMetLibraryService.list( List<LawsEvaluationNotMetLibrary> lawsEvaluationNotMetLibraryList = lawsEvaluationNotMetLibraryService.list(
new LambdaQueryWrapper<LawsEvaluationNotMetLibrary>() new LambdaQueryWrapper<LawsEvaluationNotMetLibrary>()
.eq(LawsEvaluationNotMetLibrary::getStandardId, standardId) .eq(LawsEvaluationNotMetLibrary::getStandardNumber, lawsDomesticStandard.getStandardNumber())
.eq(LawsEvaluationNotMetLibrary::getRectifyStatus, "2") .eq(LawsEvaluationNotMetLibrary::getRectifyStatus, "2")
.orderByDesc(LawsEvaluationNotMetLibrary::getUpdateTime)); .orderByDesc(LawsEvaluationNotMetLibrary::getUpdateTime));
if (CollectionUtils.isNotEmpty(lawsEvaluationNotMetLibraryList)){ if (CollectionUtils.isNotEmpty(lawsEvaluationNotMetLibraryList)){