Przeglądaj źródła

去除任务过期定时任务

leon 4 lat temu
rodzic
commit
738e828aac

+ 31 - 31
src/main/java/com/mokamrp/privates/task/pangu/CheckFosterwxTaskExpire.java

@@ -32,35 +32,35 @@ public class CheckFosterwxTaskExpire {
     @Autowired
     @Autowired
     public StringRedisTemplate stringRedisTemplate;
     public StringRedisTemplate stringRedisTemplate;
 
 
-    @Scheduled(cron = "0 1 0 * * ?")
-    @SchedulerLock(name = "pangu:CheckFosterwxTaskExpire", lockAtLeastForString = "PT5S", lockAtMostForString = "PT15M")
-    public void execute() {
-        System.out.println("[cronjob]:检测微信养号任务过期");
-        LocalDate lastDay = LocalDate.now().plusDays(-1);
-        List<FosterwxStation> fosterwxStationList = fosterwxStationService.list();
-        for (FosterwxStation fosterwxStation : fosterwxStationList) {
-            List<Integer> tasks = new ArrayList<>();
-            Integer stationId = fosterwxStation.getId();
-            FosterwxTaskScheduleHandle fosterwxTaskScheduleHandle = new FosterwxTaskScheduleHandle();
-            fosterwxTaskScheduleHandle.setStationId(stationId);
-            fosterwxTaskScheduleHandle.setSendDate(lastDay);
-            fosterwxTaskScheduleHandle.setPage(1);
-            fosterwxTaskScheduleHandle.setPagesize(99999);
-            ResHandle<List<FosterwxTaskSchedule>> resHandle = fosterwxTaskScheduleService.getList(fosterwxTaskScheduleHandle);
-            List<FosterwxTaskSchedule> fosterwxTaskScheduleList = resHandle.getList();
-            Map<String, List<FosterwxTaskSchedule>> saveRedis = new HashMap<>();
-            for (FosterwxTaskSchedule fosterwxTaskSchedule : fosterwxTaskScheduleList) {
-                tasks.add(fosterwxTaskSchedule.getTaskId());
-                //.昨日数据直接设置为过期任务
-                FosterwxTaskSchedule save = new FosterwxTaskSchedule();
-                save.setTaskStatus(2);
-                fosterwxTaskScheduleService.update(save, new QueryWrapper<FosterwxTaskSchedule>()
-                        .eq("station_id", fosterwxStation.getId())
-                        .in("task_id", tasks)
-                        .eq("send_date", lastDay)
-                );
-
-            }
-        }
-    }
+//    @Scheduled(cron = "0 1 0 * * ?")
+//    @SchedulerLock(name = "pangu:CheckFosterwxTaskExpire", lockAtLeastForString = "PT5S", lockAtMostForString = "PT15M")
+//    public void execute() {
+//        System.out.println("[cronjob]:检测微信养号任务过期");
+//        LocalDate lastDay = LocalDate.now().plusDays(-1);
+//        List<FosterwxStation> fosterwxStationList = fosterwxStationService.list();
+//        for (FosterwxStation fosterwxStation : fosterwxStationList) {
+//            List<Integer> tasks = new ArrayList<>();
+//            Integer stationId = fosterwxStation.getId();
+//            FosterwxTaskScheduleHandle fosterwxTaskScheduleHandle = new FosterwxTaskScheduleHandle();
+//            fosterwxTaskScheduleHandle.setStationId(stationId);
+//            fosterwxTaskScheduleHandle.setSendDate(lastDay);
+//            fosterwxTaskScheduleHandle.setPage(1);
+//            fosterwxTaskScheduleHandle.setPagesize(99999);
+//            ResHandle<List<FosterwxTaskSchedule>> resHandle = fosterwxTaskScheduleService.getList(fosterwxTaskScheduleHandle);
+//            List<FosterwxTaskSchedule> fosterwxTaskScheduleList = resHandle.getList();
+//            Map<String, List<FosterwxTaskSchedule>> saveRedis = new HashMap<>();
+//            for (FosterwxTaskSchedule fosterwxTaskSchedule : fosterwxTaskScheduleList) {
+//                tasks.add(fosterwxTaskSchedule.getTaskId());
+//                //.昨日数据直接设置为过期任务
+//                FosterwxTaskSchedule save = new FosterwxTaskSchedule();
+//                save.setTaskStatus(2);
+//                fosterwxTaskScheduleService.update(save, new QueryWrapper<FosterwxTaskSchedule>()
+//                        .eq("station_id", fosterwxStation.getId())
+//                        .in("task_id", tasks)
+//                        .eq("send_date", lastDay)
+//                );
+//
+//            }
+//        }
+//    }
 }
 }