1

zj

2025-09-25 6287f5366df7a0f13fef767ce7d6505979a13b22

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
package com.ruoyi.im.task;
 
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ruoyi.im.service.MedicalInsuranceAccountService;
import com.ruoyi.im.service.UserPolicyService;
import com.ruoyi.system.domain.MedicalInsuranceAccount;
import com.ruoyi.system.domain.UserPolicy;
import io.swagger.models.auth.In;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
 
import java.time.LocalDate;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
 
/**
 * @program: ruoyiim
 * @description:
 * @create: 2025-09-21 14:21
 **/
@Component
public class MedicalInsuranceTask {
 
    @Autowired
    UserPolicyService userPolicyService;
 
    private final AtomicBoolean syncINStockData = new AtomicBoolean(false);
 
    private final Lock syncINStockDataLock = new ReentrantLock();
 
    @Autowired
    MedicalInsuranceAccountService medicalInsuranceAccountService;
 
    /**
     * 定时筛选用户保单状态
     */
    @Scheduled(cron = "0 0 0 * * ?")
    public void insuranceExpires() {
        if (syncINStockData.get()) { // 判断任务是否在处理中
            return;
        }
        if (syncINStockDataLock.tryLock()) {
            try {
                syncINStockData.set(true); // 设置处理中标识为true
                expires();
            } finally {
                syncINStockDataLock.unlock();
                syncINStockData.set(false); // 设置处理中标识为false
            }
        }
    }
 
    private void expires() {
        List<UserPolicy> list = userPolicyService.list(new LambdaQueryWrapper<UserPolicy>()
                .eq(UserPolicy::getPolicyStatus, UserPolicy.PolicyStatus.ACTIVE)
        );
        List<Integer> ids = new ArrayList<>();
        list.forEach(f->{
            if(isExpired(f.getEndDate())){
                f.setPolicyStatus(UserPolicy.PolicyStatus.EXPIRED);
                ids.add(f.getId());
            }
        });
        userPolicyService.updateBatchById(list);
        List<MedicalInsuranceAccount> insuranceAccountList = medicalInsuranceAccountService.list(new LambdaQueryWrapper<MedicalInsuranceAccount>()
                .in(MedicalInsuranceAccount::getPolicyId, ids)
        );
        insuranceAccountList.forEach(f->{
            f.setAccountStatus(MedicalInsuranceAccount.AccountStatus.SUSPENDED);
        });
        medicalInsuranceAccountService.updateBatchById(insuranceAccountList);
    }
 
    public boolean isExpired(LocalDate endDate) {
        return LocalDate.now().isAfter(endDate);
    }
}