Commit 2c601ae4 authored by tianbo's avatar tianbo

fix(amos-boot-module-jg): 修复安全问题追溯生成逻辑- 修复维保和检验超期设备状态更新逻辑

-优化未超期设备的处理流程,避免不必要地更新操作
parent d3106873
...@@ -145,14 +145,14 @@ public class SafetyProblemTracingGenServiceImpl{ ...@@ -145,14 +145,14 @@ public class SafetyProblemTracingGenServiceImpl{
correctData.addAll(inspectionSet); correctData.addAll(inspectionSet);
} else if (!maintenanceSet.isEmpty()) { } else if (!maintenanceSet.isEmpty()) {
// 再次查询维保备案这些数据有没有检验超期的问题 // 再次查询维保备案这些数据有没有检验超期的问题
maintenanceSet.removeAll(realOutOfInspectRecord);
// 没有则可以愉快地更新设备状态为正常 // 没有则可以愉快地更新设备状态为正常
maintenanceSet.retainAll(realOutOfInspectRecord); correctData.addAll(maintenanceSet);
// 再次查询检验这些数据有没有维保超期问题 // 再次查询检验这些数据有没有维保超期问题
// 没有则可以愉快地更新设备状态为正常
inspectionSet.retainAll(realOutOfMaintenanceRecord); inspectionSet.retainAll(realOutOfMaintenanceRecord);
// 没有则可以愉快地更新设备状态为正常
correctData.addAll(maintenanceSet);
correctData.addAll(inspectionSet); correctData.addAll(inspectionSet);
} }
idxBizJgOtherInfoService.lambdaUpdate().set(IdxBizJgOtherInfo::getStatus, null) idxBizJgOtherInfoService.lambdaUpdate().set(IdxBizJgOtherInfo::getStatus, null)
.in(IdxBizJgOtherInfo::getRecord, correctData).update(); .in(IdxBizJgOtherInfo::getRecord, correctData).update();
...@@ -182,6 +182,9 @@ public class SafetyProblemTracingGenServiceImpl{ ...@@ -182,6 +182,9 @@ public class SafetyProblemTracingGenServiceImpl{
List<String> outOfMaintenanceEquipIds = problemList.stream().map(SafetyProblemTracing::getSourceId).collect(Collectors.toList()); List<String> outOfMaintenanceEquipIds = problemList.stream().map(SafetyProblemTracing::getSourceId).collect(Collectors.toList());
// 未超期但错误生成的维保超期设备 // 未超期但错误生成的维保超期设备
outOfMaintenanceEquipIds.removeIf(realOutOfMaintenanceRecord::contains); outOfMaintenanceEquipIds.removeIf(realOutOfMaintenanceRecord::contains);
if (ValidationUtil.isEmpty(outOfMaintenanceEquipIds)) {
return Lists.newArrayList();
}
safetyProblemTracingService.lambdaUpdate() safetyProblemTracingService.lambdaUpdate()
.set(SafetyProblemTracing::getProblemStatusCode, SafetyProblemStatusEnum.HANDLED.getCode()) .set(SafetyProblemTracing::getProblemStatusCode, SafetyProblemStatusEnum.HANDLED.getCode())
.set(SafetyProblemTracing::getProblemStatus, SafetyProblemStatusEnum.HANDLED.getName()) .set(SafetyProblemTracing::getProblemStatus, SafetyProblemStatusEnum.HANDLED.getName())
...@@ -210,6 +213,9 @@ public class SafetyProblemTracingGenServiceImpl{ ...@@ -210,6 +213,9 @@ public class SafetyProblemTracingGenServiceImpl{
List<String> outOfInspectionEquipIds = problemList.stream().map(SafetyProblemTracing::getSourceId).collect(Collectors.toList()); List<String> outOfInspectionEquipIds = problemList.stream().map(SafetyProblemTracing::getSourceId).collect(Collectors.toList());
// 未超期但错误生成的检验超期设备 // 未超期但错误生成的检验超期设备
outOfInspectionEquipIds.removeIf(realOutOfInspectRecord::contains); outOfInspectionEquipIds.removeIf(realOutOfInspectRecord::contains);
if (ValidationUtil.isEmpty(outOfInspectionEquipIds)) {
return Lists.newArrayList();
}
safetyProblemTracingService.lambdaUpdate() safetyProblemTracingService.lambdaUpdate()
.set(SafetyProblemTracing::getProblemStatusCode, SafetyProblemStatusEnum.HANDLED.getCode()) .set(SafetyProblemTracing::getProblemStatusCode, SafetyProblemStatusEnum.HANDLED.getCode())
.set(SafetyProblemTracing::getProblemStatus, SafetyProblemStatusEnum.HANDLED.getName()) .set(SafetyProblemTracing::getProblemStatus, SafetyProblemStatusEnum.HANDLED.getName())
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment