Commit e009fec6 by huangfusuper

延长快照记录时间

parent b2db90a4
...@@ -114,7 +114,7 @@ public class JobSnapshotThreadRunHelper extends BaseThreadRunHelper { ...@@ -114,7 +114,7 @@ public class JobSnapshotThreadRunHelper extends BaseThreadRunHelper {
//删除超过期限的快照 //删除超过期限的快照
flowStatusSnapshootMapper.deleteOutSnapShoot(snapshootDate * 24 * 60 * 60 * 1000); flowStatusSnapshootMapper.deleteOutSnapShoot(snapshootDate * 24 * 60 * 60 * 1000);
return UNIVERSAL_WAIT_TIME; return SELLP_TIME;
} }
......
...@@ -57,7 +57,6 @@ public class MakeUpFlowThreadRunHelper extends BaseThreadRunHelper { ...@@ -57,7 +57,6 @@ public class MakeUpFlowThreadRunHelper extends BaseThreadRunHelper {
*/ */
Map<Integer, WaitingRecord> nextRunFlow = allByTriggerTime.stream() Map<Integer, WaitingRecord> nextRunFlow = allByTriggerTime.stream()
.collect(Collectors.toMap(WaitingRecord::getFlowId, Function.identity(), BinaryOperator.minBy(Comparator.comparingInt(WaitingRecord::getWaitOrder)))); .collect(Collectors.toMap(WaitingRecord::getFlowId, Function.identity(), BinaryOperator.minBy(Comparator.comparingInt(WaitingRecord::getWaitOrder))));
Random random = new Random(); Random random = new Random();
nextRunFlow.forEach((key,value) ->{ nextRunFlow.forEach((key,value) ->{
/*保证数据为串行*/ /*保证数据为串行*/
......
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