Commit 1f0a82b9 by guo_minglei@163.com

修改记录快照线程

parent b7eea6f2
......@@ -48,4 +48,10 @@ public interface FlowMapper {
* @return
*/
List<Flow> findONStartUp();
/**
* 获取全部的工作流
* @return
*/
List<Flow> findAll();
}
\ No newline at end of file
......@@ -53,8 +53,8 @@ public class StatusSnapshootThreadRunHelper extends BaseThreadRunHelper {
if (num != null && num >= 1){
return (60 - LocalDateTime.now().getMinute()) * 60 * 1000L;
}else {
//获取所有在调度上的工作流
List<Flow> flowList = flowMapper.findONStartUp();
//获取所有的工作流
List<Flow> flowList = flowMapper.findAll();
if (flowList != null && flowList.size() > 0){
LocalDateTime hourDateTime = localDateTime
.minusMinutes(localDateTime.getMinute()) //减去分钟
......
......@@ -80,6 +80,11 @@
from flow
where start_up = '0'
</select>
<select id="findAll" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from flow
</select>
<delete id="deleteById" parameterType="java.lang.Integer">
<!-- generated @mbg.generated date: 2019-12-31 -->
......
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