优化每年专项数据获取,定时重推数据

heheng

2025-06-06 2b9d73629912d3982af1d96da8f9d50b7863cd58

 src/main/java/com/ruoyi/project/tr/specialCheck/Test/SpecialCheckTaskDownload.java

@@ -3,6 +3,7 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.ruoyi.project.tr.riskList.service.IRiskListService;
import com.ruoyi.project.tr.specialCheck.domin.DownloadDTO.*;
import com.ruoyi.project.tr.specialCheck.domin.TbBaseCheckItem;
@@ -17,6 +18,7 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

@@ -25,6 +27,10 @@
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.time.chrono.ChronoLocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;

@@ -75,6 +81,22 @@
        }
        return sr;
    }
    public static String decrypt(String encryptedText, byte[] key, byte[] iv) {
        String sr;
        try {
            byte[] encryptedBytes = Base64.getDecoder().decode(encryptedText);
            GCMBlockCipher cipher = new GCMBlockCipher(new AESFastEngine());
            AEADParameters parameters = new AEADParameters(new KeyParameter(key), MAC_BIT_SIZE, iv, null);
            cipher.init(false, parameters);
            byte[] decryptedBytes = new byte[cipher.getOutputSize(encryptedBytes.length)];
            int retLen = cipher.processBytes(encryptedBytes, 0, encryptedBytes.length, decryptedBytes, 0);
            cipher.doFinal(decryptedBytes, retLen);
            sr = new String(decryptedBytes, StandardCharsets.UTF_8);
        } catch (Exception ex) {
            throw new RuntimeException(ex.getMessage());
        }
        return sr;
    }


    @Transactional
@@ -82,7 +104,7 @@
//    @Scheduled(cron = "0 0 22,23 * * ?")    //每天晚上22、23点执行一次
//    @Scheduled(cron = "0 0/1 * * * ? ")    // 分钟
//    @Scheduled(cron = "0 0/20 * * * ? ")    // 分钟
//    @Scheduled(cron = "0/5 * * * * ?")
    //@Scheduled(cron = "0/15 * * * * ?")
    public void execReportDateSchedule() throws UnsupportedEncodingException {
        logger.info("【####】拉取专项检查数据开始...");

@@ -100,10 +122,20 @@

        logger.info("【token时间】" + formatDate);

        // 获取当前日期
        LocalDate currentDate = LocalDate.now();

        // 获取今年的1月1号
        LocalDate startOfYear = LocalDate.of(currentDate.getYear(), 1, 1);


        //String taskId = "84766708-9b18-4133-8acf-08aba67792c7";

        String taskId = "a8de03f0-4c3e-43fe-a139-0e4ed34edd35";
        /**
         * 1
         * */
        logger.info("【####】拉取专项任务数据开始...");
//        logger.info("【####】拉取专项任务数据开始...");
        TbCheckConfig specialCheckConfig = configMapper.getSpecialCheckConfig();
        if (specialCheckConfig.getStatus() == 2){

@@ -130,6 +162,8 @@

             OutputStream os = con.getOutputStream();

                 System.out.println("token:"+token+formatDate.toString());

            //本段日志，测试成功后，可注释掉
            if (responseCode == HttpURLConnection.HTTP_OK) {
                //得到响应流
@@ -152,11 +186,20 @@
            //接收返回值，保存返回值
            TbBaseCheckTaskDownloadBO checkTaskDownloadDTO = JSONObject.parseObject(specialCheckBuffer.toString(), TbBaseCheckTaskDownloadBO.class);
            //接收返回值，保存返回值
            CheckTaskData tasks = JSONObject.parseObject(checkTaskDownloadDTO.getData(), CheckTaskData.class);
            if (tasks.getCheckTaskLists().size() > 0){
                for (TbBaseCheckTask checkTask : tasks.getCheckTaskLists()) {
                    checkTask.setStatus(1);
                    int insert = taskTbRepository.insert(checkTask);
            List<TbBaseCheckTask> tbBaseCheckTasks = JSONArray.parseArray(checkTaskDownloadDTO.getData(), TbBaseCheckTask.class);
            if (tbBaseCheckTasks.size() > 0){
                for (TbBaseCheckTask tbBaseCheckTask : tbBaseCheckTasks) {
                    LocalDateTime taskStartTime = tbBaseCheckTask.getTaskStartTime();
                    LocalDate localDate = taskStartTime.toLocalDate();
                    if (localDate.isAfter(startOfYear)) {
                        logger.info("当前日期大于今年的1月1号");
                        tbBaseCheckTask.setStatus(1);
                        tbBaseCheckTask.setId(tbBaseCheckTask.getTaskId());
                        taskId = tbBaseCheckTask.getTaskId();

                        int insert = taskTbRepository.insert(tbBaseCheckTask);

                    }
                }
            }

@@ -180,10 +223,19 @@
            page.setCurrent(String.valueOf(1));
            page.setSize(String.valueOf(1000));

            itemDownloadRespDTO.setTaskId(baseCheckTask.getId());
            itemDownloadRespDTO.setTaskId(taskId);
            itemDownloadRespDTO.setPage(page);
            System.out.println("请求参数：" + JSONObject.toJSONString(itemDownloadRespDTO));

            JSONObject itemDownloadRespDTOJson = new JSONObject();
            itemDownloadRespDTOJson.put("taskId",taskId);
            itemDownloadRespDTOJson.put("page",page);
            System.out.println("【【原始数据2】】" + JSONObject.toJSONString(itemDownloadRespDTOJson));
            String encrypted = encrypt(JSONObject.toJSONString(itemDownloadRespDTOJson), key.getBytes(), iv.getBytes());
            System.out.println("【【加密数据2】】" + encrypted);
            //加密请求数据
            String AESReportUnitDate = encrypt(JSONObject.toJSONString(itemDownloadRespDTO), key.getBytes(), iv.getBytes());
            System.out.println("【【加密数据2】】" + AESReportUnitDate);
            //上报数据
            try {
                URL url = new URL("http://120.71.182.198:9999/v1/data/receive/getCheckItem");
@@ -204,11 +256,11 @@
                con.setRequestProperty("Content-Type", "application/json;charset=utf8");

                OutputStream os = con.getOutputStream();
                Map paraMap = new HashMap();
                paraMap.put("data", AESReportUnitDate); /**封装数据*/
                System.out.println("【【加密请求体】】" +  JSONArray.toJSON(paraMap).toString());
//                Map paraMap = new HashMap();
//                paraMap.put("data", encrypted); /**封装数据*/
               // System.out.println("【【加密请求体】】" +  JSONArray.toJSON(paraMap).toString());
                //组装入参，设置请求体
                os.write(JSON.toJSONString(paraMap).getBytes());
                os.write(JSON.toJSONString(itemDownloadRespDTOJson).getBytes());

                //本段日志，测试成功后，可注释掉
                if (responseCode == HttpURLConnection.HTTP_OK) {
@@ -232,15 +284,22 @@
            //接收返回值，保存返回值
            ItemDownloadRespBO itemDownloadRespBO = JSONObject.parseObject(specialCheckBuffer.toString(), ItemDownloadRespBO.class);
            //接收返回值，保存返回值
            CheckItemData itemData = JSONObject.parseObject(itemDownloadRespBO.getData(), CheckItemData.class);
            if (itemData.getItemLists().size() > 0){
                for (TbBaseCheckItem item : itemData.getItemLists()) {
                    item.setStatus(1);
                    int insert = itemTbRepository.insert(item);
                }
            String data = itemDownloadRespBO.getData();
            if (ObjectUtils.isNotEmpty(data)){
                JSONObject jsonObject = JSON.parseObject(data);
                String data1 = jsonObject.get("data").toString();
                List<TbBaseCheckItem> tbBaseCheckItems = JSONObject.parseArray(data1, TbBaseCheckItem.class);
                    if (ObjectUtils.isNotEmpty(tbBaseCheckItems)){
                        for (TbBaseCheckItem item : tbBaseCheckItems) {
                            item.setStatus(1);
                            item.setId(item.getCheckItemId());
                            int insert = itemTbRepository.insertBatch(item);
                        }

                    }
            }

            taskTbRepository.updateStatusById(baseCheckTask.getId());
            taskTbRepository.updateStatusById(baseCheckTask.getTaskId());

            logger.info("【专项任务检查项】-读取检查项结果：" + itemDownloadRespBO.getCode());
            System.out.println("【专项任务检查项】-读取检查项完成");
@@ -265,11 +324,15 @@
            scoreDownloadRespDTO.setTaskId(baseItemByStatus.getTaskId());
            scoreDownloadRespDTO.setCheckItemId(baseItemByStatus.getId());
            scoreDownloadRespDTO.setPage(page);
            System.out.println("【【加密前请求体】】" +JSON.toJSONString(scoreDownloadRespDTO));
            //加密请求数据
            String AESReportUnitDate = encrypt(JSONObject.toJSONString(scoreDownloadRespDTO), key.getBytes(), iv.getBytes());
            String AESReportUnitDate = encrypt(JSON.toJSONString(scoreDownloadRespDTO), key.getBytes(), iv.getBytes());
            System.out.println("【【加密请求体】】" +AESReportUnitDate);
            String decrypt = decrypt(AESReportUnitDate, key.getBytes(), iv.getBytes());
            System.out.println("【【解密请求体】】" +decrypt);
            //上报数据
            try {
                URL url = new URL("http://120.71.182.198:9999/v1/data/receive/getCheckItem");
                URL url = new URL("http://120.71.182.198:9999/v1/data/receive/getCheckScore");
                //得到连接对象
                con = (HttpURLConnection) url.openConnection();
                //设置请求类型
@@ -287,11 +350,11 @@
                con.setRequestProperty("Content-Type", "application/json;charset=utf8");

                OutputStream os = con.getOutputStream();
                Map paraMap = new HashMap();
                paraMap.put("data", AESReportUnitDate); /**封装数据*/
                System.out.println("【【加密请求体】】" +  JSONArray.toJSON(paraMap).toString());
//                Map paraMap = new HashMap();
//                paraMap.put("data", AESReportUnitDate); /**封装数据*/
//                System.out.println("【【加密请求体】】" +  JSONArray.toJSON(paraMap).toString());
                //组装入参，设置请求体
                os.write(JSON.toJSONString(paraMap).getBytes());
                os.write(JSON.toJSONString(scoreDownloadRespDTO).getBytes());

                //本段日志，测试成功后，可注释掉
                if (responseCode == HttpURLConnection.HTTP_OK) {
@@ -314,14 +377,21 @@

            //接收返回值，保存返回值
            ScoreDownloadRespBO scoreDownloadRespBO = JSONObject.parseObject(specialCheckBuffer.toString(), ScoreDownloadRespBO.class);
            //接收返回值，保存返回值
            CheckScoreData scoreData = JSONObject.parseObject(scoreDownloadRespBO.getData(), CheckScoreData.class);
            if (scoreData.getScoreLists().size() > 0){
                for (TbBaseCheckScore score : scoreData.getScoreLists()) {
                    int insert = scoreTbRepository.insert(score);
                }

            String data = scoreDownloadRespBO.getData();
            if (ObjectUtils.isNotEmpty(data)){
                JSONObject jsonObject = JSON.parseObject(data);
                String data1 = jsonObject.get("data").toString();
                List<TbBaseCheckScore> tbBaseCheckScores = JSONObject.parseArray(data1, TbBaseCheckScore.class);
                    if (ObjectUtils.isNotEmpty(tbBaseCheckScores)){
                        for (TbBaseCheckScore item : tbBaseCheckScores) {
                            item.setId(item.getScoreId());
                            int insert = scoreTbRepository.save(item);
                        }

                    }
            }

            itemTbRepository.updateStatusById(baseItemByStatus.getId());

            logger.info("【评分细则】-读取结果：" + scoreDownloadRespBO.getCode());