|
|
|
|
@ -521,6 +521,23 @@ public class ReportFlowService extends ServiceImpl<ReportFlowMapper,ReportFlow>
|
|
|
|
|
//
|
|
|
|
|
endFlow.setType("end"); |
|
|
|
|
boolean ok2 = baseMapper.insert(endFlow) > 0; |
|
|
|
|
|
|
|
|
|
// 确保 warning_record 存在且有 supervisionTime(预警时间)
|
|
|
|
|
WarningRecord warningRecord = warningRecordMapper.selectOne( |
|
|
|
|
new LambdaQueryWrapper<WarningRecord>() |
|
|
|
|
.eq(WarningRecord::getReportId, queryParam.getReportId()) |
|
|
|
|
); |
|
|
|
|
if (warningRecord == null) { |
|
|
|
|
warningRecord = new WarningRecord(); |
|
|
|
|
warningRecord.setReportId(queryParam.getReportId()); |
|
|
|
|
warningRecord.setSupervisionTime(LocalDateTime.now()); |
|
|
|
|
warningRecord.setCreateTime(LocalDateTime.now()); |
|
|
|
|
warningRecordMapper.insert(warningRecord); |
|
|
|
|
} else if (warningRecord.getSupervisionTime() == null) { |
|
|
|
|
warningRecord.setSupervisionTime(LocalDateTime.now()); |
|
|
|
|
warningRecordMapper.updateById(warningRecord); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
return Result.success(ok1 && ok2); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|