From d931366345516793364f15f1f4f42ce318dac0f7 Mon Sep 17 00:00:00 2001
From: quyixiao <2621048238@qq.com>
Date: Wed, 16 Dec 2020 11:09:39 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/lz/modules/job/dao/ScheduleJobDao.java  | 3 +++
 .../modules/job/service/impl/ScheduleJobServiceImpl.java  | 8 +++++++-
 src/main/resources/mapper/job/ScheduleJobDao.xml          | 6 ++++++
 3 files changed, 16 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/lz/modules/job/dao/ScheduleJobDao.java b/src/main/java/com/lz/modules/job/dao/ScheduleJobDao.java
index 4b277a76..12b3cf3b 100644
--- a/src/main/java/com/lz/modules/job/dao/ScheduleJobDao.java
+++ b/src/main/java/com/lz/modules/job/dao/ScheduleJobDao.java
@@ -12,6 +12,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.lz.modules.job.entity.ScheduleJobEntity;
 import org.apache.ibatis.annotations.Mapper;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -26,4 +27,6 @@ public interface ScheduleJobDao extends BaseMapper<ScheduleJobEntity> {
 	 * 批量更新状态
 	 */
 	int updateBatch(Map<String, Object> map);
+
+	List<ScheduleJobEntity> selectAll();
 }
diff --git a/src/main/java/com/lz/modules/job/service/impl/ScheduleJobServiceImpl.java b/src/main/java/com/lz/modules/job/service/impl/ScheduleJobServiceImpl.java
index 6d33f1d1..c4c2487f 100644
--- a/src/main/java/com/lz/modules/job/service/impl/ScheduleJobServiceImpl.java
+++ b/src/main/java/com/lz/modules/job/service/impl/ScheduleJobServiceImpl.java
@@ -33,12 +33,18 @@ public class ScheduleJobServiceImpl extends ServiceImpl<ScheduleJobDao, Schedule
 	@Autowired
     private Scheduler scheduler;
 
+
+
+	@Autowired
+	private ScheduleJobDao scheduleJobMapper;
+
+
 	/**
 	 * 项目启动时，初始化定时器
 	 */
 	@PostConstruct
 	public void init(){
-		List<ScheduleJobEntity> scheduleJobList = this.list();
+		List<ScheduleJobEntity> scheduleJobList = scheduleJobMapper.selectAll();
 		for(ScheduleJobEntity scheduleJob : scheduleJobList){
 			CronTrigger cronTrigger = ScheduleUtils.getCronTrigger(scheduler, scheduleJob.getJobId());
             //如果不存在，则创建
diff --git a/src/main/resources/mapper/job/ScheduleJobDao.xml b/src/main/resources/mapper/job/ScheduleJobDao.xml
index 5c35544c..603ec916 100644
--- a/src/main/resources/mapper/job/ScheduleJobDao.xml
+++ b/src/main/resources/mapper/job/ScheduleJobDao.xml
@@ -11,4 +11,10 @@
 		</foreach>
 	</update>
 
+
+	<select id="selectAll" resultType="com.lz.modules.job.entity.ScheduleJobEntity">
+		select * from schedule_job where status = 0
+	</select>
+
+
 </mapper>

From ddc7cbaab899e18f46d845f1fe60e7ef83e9001a Mon Sep 17 00:00:00 2001
From: quyixiao <2621048238@qq.com>
Date: Wed, 16 Dec 2020 11:21:57 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../modules/sys/service/app/impl/ResultRecordServiceImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java b/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java
index 16d1eccd..ede99e92 100644
--- a/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java
+++ b/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java
@@ -1463,7 +1463,7 @@ public class ResultRecordServiceImpl extends ServiceImpl<ResultRecordMapper, Res
         if(CollectionUtils.isEmpty(flowRecordRunning) ){
             flowRecords = flowRecordService.selectFlowRecordByResultRecordId(recordDetailDto.getResultRecordId());
         }else{
-            flowRecords = flowRecordService.selectFlowRecordByRecordIdLeFlowIndex(recordDetailDto.getResultRecordId(),flowRecordRunning.get(0).getFlowIndex());
+            flowRecords = flowRecordService.selectFlowRecordByRecordIdLeFlowIndex(recordDetailDto.getResultRecordId(),flowRecordRunning.get(0).getFlowIndex() -1 );
         }
         int flowIndex = 0;
         List<ResetDataResp> resetDataResps = new ArrayList<>();