Commit f8911063 by huangfusuper

修噶工作流扫描帮助定义

parent bbe22ad8
...@@ -21,6 +21,7 @@ import java.util.concurrent.TimeUnit; ...@@ -21,6 +21,7 @@ import java.util.concurrent.TimeUnit;
@Component @Component
@Slf4j @Slf4j
public class FlowThreadRunHelper extends BaseThreadRunHelper { public class FlowThreadRunHelper extends BaseThreadRunHelper {
private final int PRE_TIME = 30;
private static final String LOCK_NAME = "flow_lock"; private static final String LOCK_NAME = "flow_lock";
private final DataSource dataSource; private final DataSource dataSource;
...@@ -38,7 +39,7 @@ public class FlowThreadRunHelper extends BaseThreadRunHelper { ...@@ -38,7 +39,7 @@ public class FlowThreadRunHelper extends BaseThreadRunHelper {
@Override @Override
public Long start() { public Long start() {
Long preTestTime = System.currentTimeMillis()+ TimeUnit.HOURS.toMillis(30); Long preTestTime = System.currentTimeMillis()+ TimeUnit.HOURS.toMillis(PRE_TIME);
//这个查询时有一个条件是 剩余次数不等于0也就是说 等于0的就查询不出来 //这个查询时有一个条件是 剩余次数不等于0也就是说 等于0的就查询不出来
List<Flow> halfAnHourFlow = flowService.findHalfAnHourFlow(preTestTime); List<Flow> halfAnHourFlow = flowService.findHalfAnHourFlow(preTestTime);
if (CollectionUtil.isNotEmpty(halfAnHourFlow)) { if (CollectionUtil.isNotEmpty(halfAnHourFlow)) {
......
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