双重预防项目-国泰新华二开定制版
heheng
7 days ago 7ee844962f050cfc548e5dd661a586a4993cbf89
src/main/java/com/ruoyi/project/tr/specialCheck/scheduleLogTask/SpecialCheckTaskDownload.java
@@ -31,6 +31,8 @@
import java.time.format.DateTimeFormatter;
import java.util.*;
import static com.ruoyi.common.utils.Threads.sleep;
@Component
public class SpecialCheckTaskDownload {
@@ -78,6 +80,7 @@
        }
        return sr;
    }
    public static String decrypt(String encryptedText, byte[] key, byte[] iv) {
        String sr;
        try {
@@ -96,7 +99,7 @@
    }
    @Transactional
  //  @Transactional
//    @Scheduled(cron = "0 0 23 * * ?")    //每天晚上23点执行一次0 0 22,23 * * ?
//    @Scheduled(cron = "0 0 22,23 * * ?")    //每天晚上22、23点执行一次
//    @Scheduled(cron = "0 0/1 * * * ? ")    // 分钟
@@ -128,11 +131,14 @@
        //String taskId = "84766708-9b18-4133-8acf-08aba67792c7";
        String taskId = "a8de03f0-4c3e-43fe-a139-0e4ed34edd35";
        String taskId = "47da41f5-c747-4bd3-b4ab-d4d496e31e93";
        int count = 0;
        /**
         * 1
         * */
//        logger.info("【####】拉取专项任务数据开始...");
        logger.info("【####】拉取专项任务数据开始...");
        TbCheckConfig specialCheckConfig = configMapper.getSpecialCheckConfig();
        if (specialCheckConfig.getStatus() == 2){
@@ -292,7 +298,7 @@
                            item.setId(item.getCheckItemId());
                            int insert = itemTbRepository.insertBatch(item);
                        }
                    count = tbBaseCheckItems.size();
                    }
            }
@@ -309,11 +315,20 @@
         * */
        logger.info("【####】拉取评分细则开始...");
        if (specialCheckConfig.getStatus() == 2){
            if (count <= 0) {
                logger.info("【拉取评分细则开始】-无检查项数据");
                return;
            }
            for (int i = 0; i < count + 20; i++) {
            StringBuffer specialCheckBuffer = null;
            ScoreDownloadRespDTO scoreDownloadRespDTO = new ScoreDownloadRespDTO();
            TbBaseCheckItem baseItemByStatus = itemTbRepository.getBaseItemByStatus(date);
                ScoreDownloadRespDTO scoreDownloadRespDTO = new ScoreDownloadRespDTO();
            Page page = new Page();
            page.setCurrent(String.valueOf(1));
            page.setSize(String.valueOf(1000));
@@ -387,12 +402,16 @@
                        }
                    }
            }
            itemTbRepository.updateStatusById(baseItemByStatus.getId());
            logger.info("【评分细则】-读取结果:" + scoreDownloadRespBO.getCode());
            System.out.println("【评分细则】-读取完成");
                sleep(6000);
            }
        }else {
            System.out.println("【评分细则】- 不读取");
        }