接收返回值捕获异常，打印log

换个名字嗨起来

2024-07-25 2bf2a296ee98bf48026e90da5c7a7b5525fb9f67

 src/main/java/com/ruoyi/doublePrevention/scheduls/ExecCJReportDateSchedule.java

@@ -10,6 +10,7 @@
import com.ruoyi.doublePrevention.entity.CJReport.CJdto.Data;

import com.ruoyi.doublePrevention.entity.CJReport.CJdto.ErrorMsgDetails;

import com.ruoyi.doublePrevention.entity.CJReport.CJdto.HandlerDO.*;

import com.ruoyi.doublePrevention.entity.PreventReportConfig;

import com.ruoyi.doublePrevention.enums.CJReportEnum;

import com.ruoyi.doublePrevention.enums.SyncEnum;

import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam;

@@ -59,6 +60,8 @@
    private PreventCJReportPointService CJPointService;

    @Autowired

    private PreventCJReportOverhaulLogService CJOverhaulLogService;

    @Autowired

    private PreventReportConfigService preventReportConfigService;



    String token = "GT6gGJV7JV";

    String key = "Bv+NeBolwqg2Pbc1yVwrZA==";

@@ -91,9 +94,9 @@


    @Transactional

//    @Scheduled(cron = "0 0 23 * * ?")    //每天晚上23点执行一次0 0 22,23 * * ?

    @Scheduled(cron = "0 0 22,23 * * ?")    //每天晚上22、23点执行一次

//    @Scheduled(cron = "0 0/1 * * * ? ")    // 分钟

    //@Scheduled(cron = "0/30 * * * * ?")

//    @Scheduled(cron = "0 0 22,23 * * ?")    //每天晚上22、23点执行一次

    @Scheduled(cron = "0 0/10 * * * ? ")    // 分钟

//    @Scheduled(cron = "0/30 * * * * ?")

    public void execReportDateSchedule() throws UnsupportedEncodingException {

        logger.info("【####】上报数据开始...");



@@ -110,6 +113,11 @@


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



        //使用风险分析单元数据上报主配置，作为自动上报开关

        PreventReportConfig reportConfig = preventReportConfigService.getReportConfigById(SyncEnum.REPORT_CONFIG_RISK_ANA_UNIT.getCode());

        if (reportConfig.getReportType() == 0){

            return;

        }



        /**

         * 1、处理安全风险分析单元数据

@@ -473,10 +481,9 @@
                cjReportCheckTaskFromWorkDTO.setCreateDate(dateFormat.format(cjTaskFromWork.getCreateDate()));

                cjReportCheckTaskFromWorkDTO.setUpdateDate(dateFormat.format(cjTaskFromWork.getUpdateDate()));

                cjReportCheckTaskFromWorkDTO.setTaskStartTime(dateFormat.format(cjTaskFromWork.getCreateDate()));

                cjReportCheckTaskFromWorkDTO.setWorkStartTime(dateFormat.format(cjTaskFromWork.getUpdateDate()));

                cjReportCheckTaskFromWorkDTO.setWorkEndTime(dateFormat.format(cjTaskFromWork.getUpdateDate()));

                reportCheckTaskFromWorkList.add(cjReportCheckTaskFromWorkDTO);

            }

            System.out.println(Arrays.toString(reportCheckTaskFromWorkList.toArray()));

            //数据上报

            String AESReportTaskFromWork = encrypt(JSONObject.toJSONString(reportCheckTaskFromWorkList), key.getBytes(), iv.getBytes());

            StringBuffer taskFromWorkResultBuffer = null;

@@ -578,10 +585,10 @@
                cjReportCheckRecordFromTaskDTO.setIsDefend(cjRecordFromTask.getDefend());

                reportRecordFromTaskList.add(cjReportCheckRecordFromTaskDTO);

            }

            System.out.println(Arrays.toString(reportRecordFromTaskList.toArray()));

//            System.out.println(Arrays.toString(reportRecordFromTaskList.toArray()));

            //数据加密

            String AESReportRecordFromTask = encrypt(JSONObject.toJSONString(reportRecordFromTaskList), key.getBytes(), iv.getBytes());



            logger.info("【test】数据加密完成,开始上报数据");

            StringBuffer recordFromTaskResultBuffer = null;

            //上报数据

            try {

@@ -624,9 +631,19 @@
                e.printStackTrace();

            }



            logger.info("【test】接收返回值");

            CJReportResultData CJRecordFromTaskResult = new CJReportResultData();

            try {

                CJRecordFromTaskResult =  JSONObject.parseObject(recordFromTaskResultBuffer.toString(), CJReportResultData.class);

            }catch (Exception e){

                e.printStackTrace();

                logger.info("【test】接收返回值异常");

            }



            //接收返回值，保存返回值

            CJReportResultData CJRecordFromTaskResult = JSONObject.parseObject(recordFromTaskResultBuffer.toString(), CJReportResultData.class);

//            CJReportResultData CJRecordFromTaskResult = JSONObject.parseObject(recordFromTaskResultBuffer.toString(), CJReportResultData.class);

            //接收返回值，保存返回值

            logger.info("【test】保存上报结果");

            List<String> errorIdList= new ArrayList<>();

            Data data = JSONObject.parseObject(CJRecordFromTaskResult.getData(), Data.class);

            //保存失败结果