From 2bf2a296ee98bf48026e90da5c7a7b5525fb9f67 Mon Sep 17 00:00:00 2001
From: 换个名字嗨起来 <577530412@qq.com>
Date: 星期四, 25 七月 2024 15:53:24 +0800
Subject: [PATCH] 接收返回值捕获异常,打印log

---
 src/main/java/com/ruoyi/doublePrevention/scheduls/ExecCJReportDateSchedule.java |   21 +++++++++++++++------
 1 files changed, 15 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/ruoyi/doublePrevention/scheduls/ExecCJReportDateSchedule.java b/src/main/java/com/ruoyi/doublePrevention/scheduls/ExecCJReportDateSchedule.java
index 499132d..008cea5 100644
--- a/src/main/java/com/ruoyi/doublePrevention/scheduls/ExecCJReportDateSchedule.java
+++ b/src/main/java/com/ruoyi/doublePrevention/scheduls/ExecCJReportDateSchedule.java
@@ -95,9 +95,8 @@
     @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 0/20 * * * ? ")    // 分钟
-    //@Scheduled(cron = "0/30 * * * * ?")
+    @Scheduled(cron = "0 0/10 * * * ? ")    // 分钟
+//    @Scheduled(cron = "0/30 * * * * ?")
     public void execReportDateSchedule() throws UnsupportedEncodingException {
         logger.info("【####】上报数据开始...");
 
@@ -116,7 +115,7 @@
 
         //使用风险分析单元数据上报主配置,作为自动上报开关
         PreventReportConfig reportConfig = preventReportConfigService.getReportConfigById(SyncEnum.REPORT_CONFIG_RISK_ANA_UNIT.getCode());
-        if (reportConfig.getReportState() == 0){
+        if (reportConfig.getReportType() == 0){
             return;
         }
 
@@ -589,7 +588,7 @@
 //            System.out.println(Arrays.toString(reportRecordFromTaskList.toArray()));
             //数据加密
             String AESReportRecordFromTask = encrypt(JSONObject.toJSONString(reportRecordFromTaskList), key.getBytes(), iv.getBytes());
-
+            logger.info("【test】数据加密完成,开始上报数据");
             StringBuffer recordFromTaskResultBuffer = null;
             //上报数据
             try {
@@ -632,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);
             //保存失败结果

--
Gitblit v1.9.2