2025-03-13

zhaowenxuan

2025-03-13 b47fac6e8cd4a40c6261b26bc753f46bff112206

 ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java

@@ -29,6 +29,7 @@
import java.time.ZonedDateTime;
import java.time.temporal.ChronoUnit;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;

@@ -62,7 +63,7 @@
    @Autowired
    private DataSourceConfig dataSourceConfig;

    private final ReentrantLock reentrantLock = new ReentrantLock();
    private final Map<String, ReentrantLock> lockMap = new ConcurrentHashMap<>();

    // 用来跟踪已调度任务的用户ID集合，避免重复添加任务
    private final Set<String> scheduledTasks = new HashSet<>();
@@ -85,6 +86,8 @@

    // 创建定时任务的方法，用户ID不存在任务时才会添加
    public void createTask(DictHosp dictHosp) {
        log.info("进入创建任务方法 ->{}",dictHosp.getCode());
        log.info("已有任务集合 ->{}", scheduledTasks);
        // 如果任务已经存在，则不重复添加
        if (scheduledTasks.contains(dictHosp.getCode())) {
            return;
@@ -104,18 +107,24 @@
        }, Instant.now().plus(15, ChronoUnit.MINUTES));
    }

    private ReentrantLock getLock(String id) {
        return lockMap.computeIfAbsent(id, k -> new ReentrantLock());
    }

    // 执行日志同步任务的方法
    public void executeTask(DictHosp dictHosp) {
        // 获取锁，确保同一时间只有一个任务执行
        log.info("{}执行结果同步", dictHosp.getCode());
        dataSourceConfig.addDataSource(dictHosp.getDbname());
        DataSourceContextHolder.setDataSourceKey(dictHosp.getDbname());
        String dsqkssj = configService.selectConfigByKey("dsqkssj");
        String dsqjssj = configService.selectConfigByKey("dsqjssj");
        boolean panduandangqianshijian = panduandangqianshijian(dsqkssj, dsqjssj);

        log.info("{}执行结果同步加锁前",JSONUtil.toJsonStr(dictHosp));
        ReentrantLock reentrantLock = getLock(dictHosp.getCode());
        boolean lock = reentrantLock.tryLock();
        try {
            log.info("{}执行结果同步加锁后",JSONUtil.toJsonStr(dictHosp));
            log.info("{}执行结果同步", dictHosp.getCode());
            dataSourceConfig.addDataSource(dictHosp.getDbname());
            DataSourceContextHolder.setDataSourceKey(dictHosp.getDbname());
            String dsqkssj = configService.selectConfigByKey("dsqkssj");
            String dsqjssj = configService.selectConfigByKey("dsqjssj");
            boolean panduandangqianshijian = panduandangqianshijian(dsqkssj, dsqjssj);
            if (!panduandangqianshijian) {
                if (lock) {
                    log.info("任务开始执行时间 -> {}", dateTimeFormat.format(new Date()));
@@ -130,7 +139,7 @@
                    if (null != jy && !jy.isEmpty()) {
                        log.info("同步检验人员 执行数量->{}", jy.size());
                        for (String s : jy) {
                            extractedjianyan(s);
                            extractedjianyan(s,dictHosp.getCode());
                        }
                    }

@@ -138,7 +147,7 @@
                    if (null != jc && !jc.isEmpty()) {
                        log.info("同步检查人员 执行数量->{}", jc.size());
                        for (String s : jc) {
                            extractedjiancha(s);
                            extractedjiancha(s,dictHosp.getCode());
                        }
                    }
                    Map<String, Object> map = new HashMap<>();
@@ -187,13 +196,11 @@
            log.error("定时器执行报错");
            log.error(String.valueOf(e),e.getMessage());
        } finally {
            if (reentrantLock.isLocked()) {
                scheduledTasks.remove(dictHosp.getCode());
                reentrantLock.unlock();
            }
            DataSourceContextHolder.setDataSourceKey(DataSourceType.MASTER.name());
            DataSourceContextHolder.clear();

            reentrantLock.unlock();
            scheduledTasks.remove(dictHosp.getCode());
//            DataSourceContextHolder.setDataSourceKey(DataSourceType.MASTER.name());
//            DataSourceContextHolder.clear();
            log.info("任务{}已释放锁",dictHosp.getCode());
        }
    }

@@ -216,7 +223,7 @@
        taskScheduler.schedule(this::checkAndAddNewTasks, Instant.now().plus(2, ChronoUnit.MINUTES));
    }

    private void extractedjianyan(String s) {
    private void extractedjianyan(String s,String hospId) {
        try {
            List<Aws> awsList = testMapper.getWsxmLtkjHysqdByLisViBySLAVEWS(s);
            if(null !=awsList && !awsList.isEmpty()){
@@ -226,9 +233,22 @@
                awsService.saveBatch(awsList);
                log.info("保存外送项目成功");
            }
            List<LtkjHysqd> hysqdList = testMapper.getCcXZxYyLtkjHysqdByLisVi(s);
            List<LtkjHysqd> wssq = testMapper.getWsxmLtkjHysqdByLisVi(s);
            if(null !=wssq && !wssq.isEmpty())hysqdList.addAll(wssq);
            if(null !=wssq && !wssq.isEmpty()){
                for (LtkjHysqd hysqd : wssq) {
                    LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(hysqd.getTjh(), hysqd.getTmh());
                    if (null != jybgid) {
                        ltkjHysqdService.deletedLtkjHysqdByTjhAndTmh(hysqd.getTjh(), hysqd.getTmh());
                        ltkjHybgdService.deletedLtkjHybgdByTjhAndTmh(hysqd.getTmh());
                    }
                    if (ltkjHysqdService.save(hysqd)) {
                        List<LtkjHybgd> wsbg = testMapper.getWsxmLtkjHybgdByLisVi(s);
                        ltkjHybgdService.saveBatch(wsbg);
                    }
                }
            }

            List<LtkjHysqd> hysqdList = testMapper.getCcXZxYyLtkjHysqdByLisVi(s,hospId);
            if (null != hysqdList && !hysqdList.isEmpty()) {
                for (LtkjHysqd hysqd : hysqdList) {
                    LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(hysqd.getTjh(), hysqd.getTmh());
@@ -238,8 +258,8 @@
                    }
                    if (ltkjHysqdService.save(hysqd)) {
                        List<LtkjHybgd> hybgdList = testMapper.getCcXZxYyLtkjHybgdByLisVi(hysqd.getTmh());
                        List<LtkjHybgd> wsbg = testMapper.getWsxmLtkjHybgdByLisVi(s);
                        if(null !=wsbg && !wsbg.isEmpty())hybgdList.addAll(wsbg);
//                        List<LtkjHybgd> wsbg = testMapper.getWsxmLtkjHybgdByLisVi(s);
//                        if(null !=wsbg && !wsbg.isEmpty())hybgdList.addAll(wsbg);
                        ltkjHybgdService.saveBatch(hybgdList);
                    }
                }
@@ -254,16 +274,16 @@
    }


    private void extractedjiancha(String s) {
    private void extractedjiancha(String s,String hospId) {

        try {
            List<LtkjExamJcsqd> jcsqdList = testMapper.getCcXZxYyPacsLtkjExamJcsqd(s);
            List<LtkjExamJcsqd> jcsqdList = testMapper.getCcXZxYyPacsLtkjExamJcsqd(s,hospId);
            if (null != jcsqdList && !jcsqdList.isEmpty()) {
                DynamicDataSourceContextHolder.clearDataSourceType();
                jcsqdService.deletedLtkjJcsqdByTjhAndTmh(s);
                jcbgdService.deletedLtkjJcbgdByTjhAndTmh(s);
                jcsqdService.saveBatch(jcsqdList);
                List<LtkjExamJcbgd> jcbgdList = testMapper.getCcXZxYyPacsLtkjExamJcbgd(s);
                List<LtkjExamJcbgd> jcbgdList = testMapper.getCcXZxYyPacsLtkjExamJcbgd(s,hospId);
                DynamicDataSourceContextHolder.clearDataSourceType();
                if (null != jcbgdList && !jcbgdList.isEmpty()) jcbgdService.saveBatch(jcbgdList);
                DynamicDataSourceContextHolder.clearDataSourceType();