Forráskód Böngészése

预测保存 修复工业库挂掉,定时任务获取的未来三小时数据重复问题 这种问题不再保存

wangmiaomiao 8 hónapja
szülő
commit
b1ed2723d9

+ 5 - 5
slibra-quartz/src/main/java/com/slibra/quartz/task/RyTask.java

@@ -926,14 +926,14 @@ public class RyTask
 
         //防止工业库挂掉以后持续预测同一数据
         //2024年6月20日14:59:23 因为预测bug 判断是否生成过了否则不生成
-        String remark = tXinyiForecastComparison.getRemark();
-        String category = tXinyiForecastComparison.getCategory();
         TXinyiForecastComparison tXinyiForecastComparisonReq = new TXinyiForecastComparison();
-        tXinyiForecastComparisonReq.setRemark(remark);
-        tXinyiForecastComparisonReq.setCategory(category);
+        tXinyiForecastComparisonReq.setRemark(tXinyiForecastComparison.getRemark());
+        tXinyiForecastComparisonReq.setCategory(tXinyiForecastComparison.getCategory());
+        //2024年7月18日15:04:37 如果工业库挂掉以后,不管什么时刻,调用预测返回的未来三小时时间都是一样的,再增加一个查询条件
+        tXinyiForecastComparisonReq.setForecastTimeOne(tXinyiForecastComparison.getForecastTimeOne());//一个时刻就可以了 没必要再比较第二和第三时刻了。
         List<TXinyiForecastComparison> tXinyiForecastComparisons = this.xinyiForecastComparisonService.selectTXinyiForecastComparisonList(tXinyiForecastComparisonReq);
         if(!CollectionUtils.isEmpty(tXinyiForecastComparisons)){
-            log.error("预测已经进行过了,无需重复运行~~~~~~~~~~~@@@@@@@,时间为{}\n类型为{}", remark, category);
+            log.error("预测已经进行过了,无需重复运行~~~~~~~~~~~@@@@@@@,要保存的预测数据为{}", JSON.toJSONString(tXinyiForecastComparison));
             return;
         }