需求

mall-miniapp-service/src/main/java/com/gree/mall/miniapp/logic/policy/WorkerLogic.java

@@ -82,7 +82,7 @@ public class WorkerLogic {
         for (WebsitUser websitUser : websitUsers) {
             //保险购买状态，没有购买的意外险
             if (websitUser.getExamineStatus().equals(ExamineWorkerStatusEnum.WAIT_WORKER.getKey()) &&
-                    workerPolicyService.lambdaQuery()
+                    workerPolicyService.lambdaQuery().eq(WorkerPolicy::getWebsitUserId,websitUser.getId())
                     .in(WorkerPolicy::getStatus,"ON","WAIT_ON")
                     .eq(WorkerPolicy::getPolicyType,"AC")
                     .eq(WorkerPolicy::getWebsitUserId,websitUser.getId())
@@ -100,6 +100,7 @@ public class WorkerLogic {
 
             // 购买的意外险，七天后过期 每天提醒一次
             if (  workerPolicyService.lambdaQuery()
+                    .eq(WorkerPolicy::getWebsitUserId,websitUser.getId())
                     .in(WorkerPolicy::getStatus,"ON","WAIT_ON")
                     .le(WorkerPolicy::getEndTime, DateUtil.offsetDay(new Date(),7))
                     .eq(WorkerPolicy::getPolicyType,"AC")
@@ -109,6 +110,7 @@ public class WorkerLogic {
 
 
                 List<WorkerPolicy> list = workerPolicyService.lambdaQuery()
+                        .eq(WorkerPolicy::getWebsitUserId,websitUser.getId())
                         .in(WorkerPolicy::getStatus, "ON", "WAIT_ON")
                         .le(WorkerPolicy::getEndTime, DateUtil.offsetDay(new Date(), 7))
                         .eq(WorkerPolicy::getPolicyType, "AC")
@@ -127,6 +129,7 @@ public class WorkerLogic {
                 }
 
                 workerPolicyService.lambdaUpdate()
+                        .eq(WorkerPolicy::getWebsitUserId,websitUser.getId())
                         .in(WorkerPolicy::getStatus,"OFF")
                         .notIn(WorkerPolicy::getStatus,"ON","WAIT_ON")
                         .eq(WorkerPolicy::getPolicyType,"AC")
@@ -136,6 +139,7 @@ public class WorkerLogic {
 
             // 意外险失效，没有购买的意外险
             if (  workerPolicyService.lambdaQuery()
+                    .eq(WorkerPolicy::getWebsitUserId,websitUser.getId())
                     .in(WorkerPolicy::getStatus,"OFF")
                     .notIn(WorkerPolicy::getStatus,"ON","WAIT_ON")
                     .eq(WorkerPolicy::getPolicyType,"AC")
@@ -144,6 +148,7 @@ public class WorkerLogic {
                     .count() > 0){
 
                 workerPolicyService.lambdaUpdate()
+                        .eq(WorkerPolicy::getWebsitUserId,websitUser.getId())
                         .in(WorkerPolicy::getStatus,"OFF")
                         .notIn(WorkerPolicy::getStatus,"ON","WAIT_ON")
                         .eq(WorkerPolicy::getPolicyType,"AC")