Commit 73aed6f9 authored by 张森's avatar 张森

定时任务问题处理

parent cbc95105
...@@ -33,6 +33,9 @@ public interface PlanTaskMapper extends BaseMapper { ...@@ -33,6 +33,9 @@ public interface PlanTaskMapper extends BaseMapper {
* @return * @return
*/ */
List<HashMap<String, Object>> getPlanTaskInfo(PlanTaskPageParam params); List<HashMap<String, Object>> getPlanTaskInfo(PlanTaskPageParam params);
List<PlanTask> findAllByFinishStatusIn(@Param("ids") List<Integer> finishStatus);
/** /**
* 批量删除 * 批量删除
* @param strArry * @param strArry
......
...@@ -109,14 +109,14 @@ public class JobService implements IJobService { ...@@ -109,14 +109,14 @@ public class JobService implements IJobService {
@Override @Override
@Transactional // @Transactional
public void initScheduler() { public void initScheduler() {
// TODO Auto-generated method stub // TODO Auto-generated method stub
log.debug("======================initScheduler==========================="); log.debug("======================initScheduler===========================");
// 已持久化到数据库,所以不需要这儿初始化 // 已持久化到数据库,所以不需要这儿初始化
// initTaskJob(); initTaskJob();
// initPlanTaskJob(); initPlanTaskJob();
// initMsgJob(); initMsgJob();
} }
@Override @Override
...@@ -157,7 +157,7 @@ public class JobService implements IJobService { ...@@ -157,7 +157,7 @@ public class JobService implements IJobService {
List<Integer> statusList = new ArrayList<Integer>(); List<Integer> statusList = new ArrayList<Integer>();
statusList.add(PlanTaskFinishStatusEnum.NOTSTARTED.getValue()); statusList.add(PlanTaskFinishStatusEnum.NOTSTARTED.getValue());
statusList.add(PlanTaskFinishStatusEnum.UNDERWAY.getValue()); statusList.add(PlanTaskFinishStatusEnum.UNDERWAY.getValue());
List<PlanTask> planTaskList = iPlanTaskDao.findAllByFinishStatusIn(statusList); List<PlanTask> planTaskList = planTaskMapper.findAllByFinishStatusIn(statusList);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
planTaskList.forEach(planTask -> { planTaskList.forEach(planTask -> {
try { try {
......
...@@ -1130,4 +1130,14 @@ ...@@ -1130,4 +1130,14 @@
and finish_status in (0,1) and finish_status in (0,1)
and status = 0 and status = 0
</select> </select>
<select id="findAllByFinishStatusIn" resultType="com.yeejoin.amos.patrol.dao.entity.PlanTask">
select * from p_plan_task where finish_status in
<foreach item="id" collection="ids" index="index" open="(" separator="," close=")">
#{id}
</foreach>
and plan_id in
(select id from p_plan where is_delete = 0 and status = 0)
</select>
</mapper> </mapper>
\ No newline at end of file
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