|
@@ -750,20 +750,35 @@ public class AgreementLogic {
|
|
|
.set(PolicyOrder::getPolicyOrderStatus,PolicyOrderStatusEnum.YSX.getKey()).update();
|
|
|
|
|
|
|
|
|
- workerPolicyService.lambdaUpdate()
|
|
|
- .ge(WorkerPolicy::getEndTime,new Date())
|
|
|
- .le(WorkerPolicy::getStartTime,new Date())
|
|
|
- .ne(WorkerPolicy::getStatus,PolicyOrderStatusEnum.BZZ.getKey())
|
|
|
- .set(WorkerPolicy::getStatus,PolicyOrderStatusEnum.BZZ.getKey())
|
|
|
- .update();
|
|
|
+ List<PolicyOrder> list = policyOrderService.lambdaQuery()
|
|
|
+ .ge(PolicyOrder::getEndTime, new Date())
|
|
|
+ .le(PolicyOrder::getStartTime, new Date())
|
|
|
+ .eq(PolicyOrder::getIsReceipt, IsYesNoEnum.YES.getKey())
|
|
|
+ .ne(PolicyOrder::getPolicyOrderStatus, PolicyOrderStatusEnum.BZZ.getKey())
|
|
|
+ .select(PolicyOrder::getId)
|
|
|
+ .list();
|
|
|
+
|
|
|
+ if (!CollectionUtils.isEmpty(list)){
|
|
|
+ workerPolicyService.lambdaUpdate()
|
|
|
+ .ge(WorkerPolicy::getEndTime,new Date())
|
|
|
+ .le(WorkerPolicy::getStartTime,new Date())
|
|
|
+ .in(WorkerPolicy::getOrderId,list.stream().map(PolicyOrder::getId).collect(Collectors.toList()))
|
|
|
+ .ne(WorkerPolicy::getStatus,PolicyOrderStatusEnum.BZZ.getKey())
|
|
|
+ .set(WorkerPolicy::getStatus,PolicyOrderStatusEnum.BZZ.getKey())
|
|
|
+ .update();
|
|
|
+ }
|
|
|
+
|
|
|
|
|
|
policyOrderService.lambdaUpdate()
|
|
|
.ge(PolicyOrder::getEndTime,new Date())
|
|
|
.le(PolicyOrder::getStartTime,new Date())
|
|
|
+ .eq(PolicyOrder::getIsReceipt,IsYesNoEnum.YES.getKey())
|
|
|
.ne(PolicyOrder::getPolicyOrderStatus,PolicyOrderStatusEnum.BZZ.getKey())
|
|
|
.set(PolicyOrder::getPolicyOrderStatus,PolicyOrderStatusEnum.BZZ.getKey())
|
|
|
.update();
|
|
|
|
|
|
+
|
|
|
+
|
|
|
}
|
|
|
|
|
|
|