Merge branch 'master' of http://git.mokasz.com/marketing/moka-private

src/main/java/com/mokamrp/privates/tast/pangu/SyncFosterwxTaskEdit.java

@@ -1,11 +1,9 @@
 package com.mokamrp.privates.tast.pangu;
 
 import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.mokamrp.privates.constant.RedisKey;
-import com.mokamrp.privates.entity.pangu.AddFosterwxMobileHandle;
-import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobile;
-import com.mokamrp.privates.mapper.pangu.pojo.FosterwxMobileWxfriend;
 import com.mokamrp.privates.mapper.pangu.pojo.FosterwxTaskSchedule;
 import com.mokamrp.privates.service.pangu.FosterwxMobileService;
 import com.mokamrp.privates.service.pangu.FosterwxMobileWxfriendService;
@@ -16,7 +14,7 @@ import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
-import java.util.ArrayList;
+import java.time.LocalDateTime;
 import java.util.List;
 
 @Component
@@ -61,7 +59,7 @@ public class SyncFosterwxTaskEdit {
                 }
                 FosterwxTaskSchedule save = new FosterwxTaskSchedule();
                 save.setErrMsg(fosterwxTaskSchedule.getErrMsg());
-                if (!fosterwxTaskSchedule.getTaskStatus().equals(0)){
+                if (!fosterwxTaskSchedule.getTaskStatus().equals(0)) {
                     save.setTaskStatus(fosterwxTaskSchedule.getTaskStatus());
                 }
                 //.更新
@@ -75,4 +73,24 @@ public class SyncFosterwxTaskEdit {
             }
         }
     }
+
+    @Scheduled(cron = "1 0 0 * * ?")
+    public void updateYesterdayStatus() {
+        // 当前事件
+        LocalDateTime localDateTime = LocalDateTime.now();
+        // 一天前
+        LocalDateTime yesterdayTime = localDateTime.minusDays(1);
+
+        LambdaQueryWrapper<FosterwxTaskSchedule> fosterwxTaskScheduleLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        fosterwxTaskScheduleLambdaQueryWrapper.between(FosterwxTaskSchedule::getSendTime, yesterdayTime, localDateTime);
+        fosterwxTaskScheduleLambdaQueryWrapper.ne(FosterwxTaskSchedule::getTaskStatus, 1);
+
+        List<FosterwxTaskSchedule> fosterwxTaskScheduleList = fosterwxTaskScheduleService.list(fosterwxTaskScheduleLambdaQueryWrapper);
+
+        fosterwxTaskScheduleList.forEach(fosterwxTaskSchedule -> {
+            fosterwxTaskSchedule.setTaskStatus(2);
+            fosterwxTaskSchedule.setUpdateAt(LocalDateTime.now());
+            fosterwxTaskScheduleService.updateById(fosterwxTaskSchedule);
+        });
+    }
 }