需求

mall-server-api/src/main/java/com/gree/mall/manager/logic/policy/AgreementLogic.java

@@ -778,6 +778,7 @@ public class AgreementLogic {
     public void task4() {
         List<WebsitUser> websitUsers = websitUserService.lambdaQuery().eq(WebsitUser::getExamineStatus, "WAIT_WORKER").list();
 
+        //保险齐全变成待保险审批
         for (WebsitUser websitUser : websitUsers) {
             if (workerPolicyService.lambdaQuery().in(WorkerPolicy::getStatus, "BZZ", "DSX")
                     .eq(WorkerPolicy::getWebsitUserId, websitUser.getId()).count() > 1) {
@@ -787,6 +788,7 @@ public class AgreementLogic {
         }
         List<WebsitUser> websitUsersOk = websitUserService.lambdaQuery().eq(WebsitUser::getExamineStatus, "OK").list();
 
+        //失效工程师
         for (WebsitUser websitUser : websitUsersOk) {
             if (workerPolicyService.lambdaQuery().in(WorkerPolicy::getStatus, "BZZ")
                     .eq(WorkerPolicy::getWebsitUserId, websitUser.getId()).count() < 2) {
@@ -1059,4 +1061,19 @@ public class AgreementLogic {
         }
 
     }
+
+    public void task6() {
+        List<WebsitUser> websitUsers = websitUserService.lambdaQuery().eq(WebsitUser::getExamineStatus, ExamineStatusEnum.OK.getKey()).list();
+
+        List<String> websitUserIds = websitUsers.stream().map(WebsitUser::getId).collect(Collectors.toList());
+
+
+        List<WorkerPolicy> workerPolicies = workerPolicyService.lambdaQuery().in(WorkerPolicy::getWebsitUserId, websitUserIds)
+                .eq(WorkerPolicy::getPolicyType,PolicyTypeEnum.IN.getKey())
+                .list();
+
+        for (WebsitUser websitUser : websitUsers) {
+
+        }
+    }
 }

mall-server-api/src/main/java/com/gree/mall/manager/schedule/InsureEmailSchedule.java

@@ -60,4 +60,9 @@ public class InsureEmailSchedule {
 
 
 
+    //工伤提前三天续保
+    @Scheduled(fixedDelay = 60* 1000)
+    public void task6(){
+        agreementLogic.task6();
+    }
 }

mall-server-api/src/main/java/com/gree/mall/manager/schedule/SyncSchedule.java

@@ -41,7 +41,7 @@ public class SyncSchedule {
 
 
     //同步工单数据
-   // @Scheduled(fixedDelay = 5* 1000)
+    @Scheduled(fixedDelay = 5* 1000)
     public void task3() throws IOException, MessagingException {
         syncOrderInfoLogic.task3();
     }