From 135a322f44708b1187d37ea4b6859b5d82113e89 Mon Sep 17 00:00:00 2001
From: kongzy <kongzy>
Date: 星期三, 14 八月 2024 11:00:30 +0800
Subject: [PATCH] update gitignore

---
 src/main/java/com/ruoyi/project/tr/specialCheck/Test/ItemDangerReportScheduleTest.java |  448 ++++++++++++++++++++++++++++----------------------------
 1 files changed, 224 insertions(+), 224 deletions(-)

diff --git a/src/main/java/com/ruoyi/project/tr/specialCheck/Test/ItemDangerReportScheduleTest.java b/src/main/java/com/ruoyi/project/tr/specialCheck/Test/ItemDangerReportScheduleTest.java
index 841af68..25a658b 100644
--- a/src/main/java/com/ruoyi/project/tr/specialCheck/Test/ItemDangerReportScheduleTest.java
+++ b/src/main/java/com/ruoyi/project/tr/specialCheck/Test/ItemDangerReportScheduleTest.java
@@ -1,224 +1,224 @@
-package com.ruoyi.project.tr.specialCheck.Test;
-
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.ruoyi.common.utils.BeanCopyUtils;
-import com.ruoyi.doublePrevention.entity.CJReport.CJdto.CJReportResultData;
-import com.ruoyi.doublePrevention.entity.CJReport.CJdto.Data;
-import com.ruoyi.doublePrevention.entity.CJReport.CJdto.ErrorMsgDetails;
-import com.ruoyi.doublePrevention.enums.CJReportEnum;
-import com.ruoyi.doublePrevention.enums.SyncEnum;
-import com.ruoyi.project.tr.riskList.service.IRiskListService;
-import com.ruoyi.project.tr.specialCheck.domin.BO.HandlerSpecialCheckReportParam;
-import com.ruoyi.project.tr.specialCheck.domin.DTO.SpecialCheckItemDangerLogReportDTO;
-import com.ruoyi.project.tr.specialCheck.domin.DTO.SpecialCheckTaskLogReportDTO;
-import com.ruoyi.project.tr.specialCheck.domin.TbSpecialCheckItemDangerLog;
-import com.ruoyi.project.tr.specialCheck.domin.TbSpecialCheckScoreAndDangerLog;
-import com.ruoyi.project.tr.specialCheck.domin.TbSpecialCheckTaskLog;
-import com.ruoyi.project.tr.specialCheck.mapper.*;
-import org.apache.commons.lang3.ObjectUtils;
-import org.bouncycastle.crypto.engines.AESFastEngine;
-import org.bouncycastle.crypto.modes.GCMBlockCipher;
-import org.bouncycastle.crypto.params.AEADParameters;
-import org.bouncycastle.crypto.params.KeyParameter;
-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;
-
-import java.io.*;
-import java.net.HttpURLConnection;
-import java.net.URL;
-import java.nio.charset.StandardCharsets;
-import java.text.SimpleDateFormat;
-import java.time.LocalDateTime;
-import java.time.format.DateTimeFormatter;
-import java.util.*;
-
-@Component
-public class ItemDangerReportScheduleTest {
-
-    private final Logger logger = LoggerFactory.getLogger(this.getClass());
-
-    @Autowired
-    private TbSpecialCheckItemLogMapper itemLogMapper;
-
-    @Autowired
-    private TbSpecialCheckScoreAndDangerLogMapper scoreAndDangerLogMapper;
-
-    String token = "GT6gGJV7JV";
-    String key = "Bv+NeBolwqg2Pbc1yVwrZA==";
-    String iv = "4QC9V8eAiB7tdlgBkMsTAw==";
-
-    public static final int MAC_BIT_SIZE = 128;
-
-    public static String encrypt(String plainText, byte[] key, byte[] iv) {
-        String sr;
-        try {
-            byte[] plainBytes = plainText.getBytes(StandardCharsets.UTF_8);
-            GCMBlockCipher cipher = new GCMBlockCipher(new
-                    AESFastEngine());
-            AEADParameters parameters =
-                    new AEADParameters(new KeyParameter(key),
-                            MAC_BIT_SIZE, iv, null);
-            cipher.init(true, parameters);
-            byte[] encryptedBytes = new
-                    byte[cipher.getOutputSize(plainBytes.length)];
-            int retLen = cipher.processBytes(plainBytes, 0, plainBytes.length,
-                    encryptedBytes, 0);
-            cipher.doFinal(encryptedBytes, retLen);
-            sr = Base64.getEncoder().encodeToString(encryptedBytes);
-        } catch (Exception ex) {
-            throw new RuntimeException(ex.getMessage());
-        }
-        return sr;
-    }
-
-
-    @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/35 * * * ? ")    // 分钟
-//    @Scheduled(cron = "0/5 * * * * ?")
-    public void execReportDateSchedule() throws UnsupportedEncodingException {
-        logger.info("【####】上报数据开始...");
-
-        HttpURLConnection con = null;
-        BufferedReader buffer = null;
-        int responseCode = 200;
-
-//        SimpleDateFormat dateFormatCheckData= new SimpleDateFormat("yyyy-MM-dd");
-//        SimpleDateFormat dateFormat= new SimpleDateFormat("yyyy-MM-dd HH:MM:ss");
-        DateTimeFormatter dateFormatCheckData = DateTimeFormatter.ofPattern("yyyy-MM-dd");
-        DateTimeFormatter dateFormat = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:MM:ss");
-
-        Date date = new Date();
-        //格式化时间,作为token的时间戳
-        SimpleDateFormat tokenDate= new SimpleDateFormat("yyyyMMddHHmmssSSS");
-        String formatDate = tokenDate.format(date);
-
-        logger.info("【token时间】" + formatDate);
-
-        /**
-         * 1、检查项与隐患上报
-         * */
-        System.out.println("【2】检查项与隐患上报-处理数据...");
-//        List<TbSpecialCheckTaskLog> CJRiskAnaUnits = .listReportUnitDate();
-        List<TbSpecialCheckScoreAndDangerLog> scoreAndDangerLogs = scoreAndDangerLogMapper.listScoreAndDangerLogReportList();
-        if (ObjectUtils.isNotEmpty(scoreAndDangerLogs)){
-            //封装上报数据,时间格式化
-            List<SpecialCheckItemDangerLogReportDTO> list = new ArrayList<>();
-
-            for (TbSpecialCheckScoreAndDangerLog scoreAndDangerLog : scoreAndDangerLogs) {
-                SpecialCheckItemDangerLogReportDTO specialCheckItemDangerLogReportDTO = BeanCopyUtils.copyBean(scoreAndDangerLog, SpecialCheckItemDangerLogReportDTO.class);
-                specialCheckItemDangerLogReportDTO.setCreateDate(dateFormat.format(scoreAndDangerLog.getCreateDate()));
-                specialCheckItemDangerLogReportDTO.setUpdateDate(dateFormat.format(scoreAndDangerLog.getUpdateDate()));
-                specialCheckItemDangerLogReportDTO.setCheckDate(dateFormatCheckData.format(scoreAndDangerLog.getCheckDate()));
-                specialCheckItemDangerLogReportDTO.setDeleted(scoreAndDangerLog.getDeleted().toString());
-                list.add(specialCheckItemDangerLogReportDTO);
-            }
-//            logger.info("【【原始数据】】" + JSONObject.toJSONString(list));
-            System.out.println("【【原始数据】】" + JSONObject.toJSONString(list));
-            String AESReportUnitDate = encrypt(JSONObject.toJSONString(list), key.getBytes(), iv.getBytes());
-//            logger.info("【【AES加密结果】】"+ AESReportUnitDate);![](C:/Users/Ad![](C:/Users/Admin/Desktop/所有桌面文件存放/9}AM56M10$6WX){0JRK`$6X.jpg)min/Desktop/所有桌面文件存放/9}AM56M10$6WX){0JRK`$6X.jpg)
-            StringBuffer itemDangerResultBuffer = null;
-
-
-            //上报数据
-             try {
-             URL url = new URL("http://120.71.182.198:9999/v1/data/receive/receiveCheckDangerList");
-             //得到连接对象
-             con = (HttpURLConnection) url.openConnection();
-             //设置请求类型
-             con.setRequestMethod("POST");
-             //允许写出
-             con.setDoOutput(true);
-             //允许读入
-             con.setDoInput(true);
-             //不使用缓存
-             con.setUseCaches(false);
-             con.setInstanceFollowRedirects(true);
-             //设置请求头
-             con.setRequestProperty("X-Access-Token",token+formatDate.toString());
-             //设置Content-Type,此处根据实际情况确定
-             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());
-                //组装入参,设置请求体
-                os.write(JSON.toJSONString(paraMap).getBytes());
-
-                //本段日志,测试成功后,可注释掉
-                if (responseCode == HttpURLConnection.HTTP_OK) {
-                    //得到响应流
-                    InputStream inputStream = con.getInputStream();
-                    //将响应流转换成字符串
-                    itemDangerResultBuffer = new StringBuffer();
-                    String line;
-                    buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
-                    while ((line = buffer.readLine()) != null) {
-                        itemDangerResultBuffer.append(line);
-                    }
-//                    logger.info("result:" + unitResultBuffer.toString());
-                    System.out.println("result:" + itemDangerResultBuffer.toString());
-                }
-
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
-
-            //接收返回值,保存返回值
-            CJReportResultData CJOverhaulLogResult = JSONObject.parseObject(itemDangerResultBuffer.toString(), CJReportResultData.class);
-            //接收返回值,保存返回值
-            List<String> errorIdList= new ArrayList<>();
-            Data data = JSONObject.parseObject(CJOverhaulLogResult.getData(), Data.class);
-            //保存失败结果
-            if (ObjectUtils.isNotEmpty(data)){
-                for (ErrorMsgDetails errorMsgDetail : data.getErrorMsgDetails()) {
-                    errorIdList.add(errorMsgDetail.getId());
-                }
-            }
-            LocalDateTime nowDate = LocalDateTime.now();
-            logger.info("【检查项与隐患】数据上报结果:" + CJOverhaulLogResult.getCode());
-            //设置所有数据上报成功
-            if (CJOverhaulLogResult.getCode().equals(CJReportEnum.SUCCESS.getCode()) || CJOverhaulLogResult.getCode().equals(CJReportEnum.SUCESS_AND_FAIL.getCode())){
-                for (TbSpecialCheckScoreAndDangerLog itemDangerLo : scoreAndDangerLogs) {
-                    HandlerSpecialCheckReportParam handlerCJReportParam = new HandlerSpecialCheckReportParam();
-                    //封装数据
-                    handlerCJReportParam.setId(itemDangerLo.getId());
-                    handlerCJReportParam.setReportStatus(SyncEnum.SYNC_EXEC_SUCCESS.getCode());
-                    handlerCJReportParam.setReportTime(nowDate);
-                    scoreAndDangerLogMapper.updateItemDangerReportStatusById(handlerCJReportParam);
-                }
-            }
-            //设置上报失败的数据,上报失败
-            if (CJOverhaulLogResult.getCode().equals(CJReportEnum.FAIL.getCode()) || CJOverhaulLogResult.getCode().equals(CJReportEnum.SUCESS_AND_FAIL.getCode())){
-                for (String failId : errorIdList) {
-                    //上报失败
-                    HandlerSpecialCheckReportParam handlerCJReportParam = new HandlerSpecialCheckReportParam();
-                    //封装数据
-                    handlerCJReportParam.setId(failId);
-                    handlerCJReportParam.setReportStatus(SyncEnum.SYNC_EXEC_FAIL.getCode());
-                    handlerCJReportParam.setReportTime(nowDate);
-                    scoreAndDangerLogMapper.updateItemDangerReportStatusById(handlerCJReportParam);
-                }
-            }
-
-
-//            logger.info("【1】安全风险分析单元-数据处理完成");
-            System.out.println("【检查项与隐患】-数据处理完成");
-        }else {
-//            logger.info("【1】风险分析单元-无数据上报昌吉州");
-            System.out.println("【检查项与隐患】-无数据上报昌吉州");
-        }
-
-
-
-    }
-}
+package com.ruoyi.project.tr.specialCheck.Test;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.ruoyi.common.utils.BeanCopyUtils;
+import com.ruoyi.doublePrevention.entity.CJReport.CJdto.CJReportResultData;
+import com.ruoyi.doublePrevention.entity.CJReport.CJdto.Data;
+import com.ruoyi.doublePrevention.entity.CJReport.CJdto.ErrorMsgDetails;
+import com.ruoyi.doublePrevention.enums.CJReportEnum;
+import com.ruoyi.doublePrevention.enums.SyncEnum;
+import com.ruoyi.project.tr.riskList.service.IRiskListService;
+import com.ruoyi.project.tr.specialCheck.domin.BO.HandlerSpecialCheckReportParam;
+import com.ruoyi.project.tr.specialCheck.domin.DTO.SpecialCheckItemDangerLogReportDTO;
+import com.ruoyi.project.tr.specialCheck.domin.DTO.SpecialCheckTaskLogReportDTO;
+import com.ruoyi.project.tr.specialCheck.domin.TbSpecialCheckItemDangerLog;
+import com.ruoyi.project.tr.specialCheck.domin.TbSpecialCheckScoreAndDangerLog;
+import com.ruoyi.project.tr.specialCheck.domin.TbSpecialCheckTaskLog;
+import com.ruoyi.project.tr.specialCheck.mapper.*;
+import org.apache.commons.lang3.ObjectUtils;
+import org.bouncycastle.crypto.engines.AESFastEngine;
+import org.bouncycastle.crypto.modes.GCMBlockCipher;
+import org.bouncycastle.crypto.params.AEADParameters;
+import org.bouncycastle.crypto.params.KeyParameter;
+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;
+
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.nio.charset.StandardCharsets;
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
+
+@Component
+public class ItemDangerReportScheduleTest {
+
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    private TbSpecialCheckItemLogMapper itemLogMapper;
+
+    @Autowired
+    private TbSpecialCheckScoreAndDangerLogMapper scoreAndDangerLogMapper;
+
+    String token = "GT6gGJV7JV";
+    String key = "Bv+NeBolwqg2Pbc1yVwrZA==";
+    String iv = "4QC9V8eAiB7tdlgBkMsTAw==";
+
+    public static final int MAC_BIT_SIZE = 128;
+
+    public static String encrypt(String plainText, byte[] key, byte[] iv) {
+        String sr;
+        try {
+            byte[] plainBytes = plainText.getBytes(StandardCharsets.UTF_8);
+            GCMBlockCipher cipher = new GCMBlockCipher(new
+                    AESFastEngine());
+            AEADParameters parameters =
+                    new AEADParameters(new KeyParameter(key),
+                            MAC_BIT_SIZE, iv, null);
+            cipher.init(true, parameters);
+            byte[] encryptedBytes = new
+                    byte[cipher.getOutputSize(plainBytes.length)];
+            int retLen = cipher.processBytes(plainBytes, 0, plainBytes.length,
+                    encryptedBytes, 0);
+            cipher.doFinal(encryptedBytes, retLen);
+            sr = Base64.getEncoder().encodeToString(encryptedBytes);
+        } catch (Exception ex) {
+            throw new RuntimeException(ex.getMessage());
+        }
+        return sr;
+    }
+
+
+    @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/35 * * * ? ")    // 分钟
+//    @Scheduled(cron = "0/5 * * * * ?")
+    public void execReportDateSchedule() throws UnsupportedEncodingException {
+        logger.info("【####】上报数据开始...");
+
+        HttpURLConnection con = null;
+        BufferedReader buffer = null;
+        int responseCode = 200;
+
+//        SimpleDateFormat dateFormatCheckData= new SimpleDateFormat("yyyy-MM-dd");
+//        SimpleDateFormat dateFormat= new SimpleDateFormat("yyyy-MM-dd HH:MM:ss");
+        DateTimeFormatter dateFormatCheckData = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        DateTimeFormatter dateFormat = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:MM:ss");
+
+        Date date = new Date();
+        //格式化时间,作为token的时间戳
+        SimpleDateFormat tokenDate= new SimpleDateFormat("yyyyMMddHHmmssSSS");
+        String formatDate = tokenDate.format(date);
+
+        logger.info("【token时间】" + formatDate);
+
+        /**
+         * 1、检查项与隐患上报
+         * */
+        System.out.println("【2】检查项与隐患上报-处理数据...");
+//        List<TbSpecialCheckTaskLog> CJRiskAnaUnits = .listReportUnitDate();
+        List<TbSpecialCheckScoreAndDangerLog> scoreAndDangerLogs = scoreAndDangerLogMapper.listScoreAndDangerLogReportList();
+        if (ObjectUtils.isNotEmpty(scoreAndDangerLogs)){
+            //封装上报数据,时间格式化
+            List<SpecialCheckItemDangerLogReportDTO> list = new ArrayList<>();
+
+            for (TbSpecialCheckScoreAndDangerLog scoreAndDangerLog : scoreAndDangerLogs) {
+                SpecialCheckItemDangerLogReportDTO specialCheckItemDangerLogReportDTO = BeanCopyUtils.copyBean(scoreAndDangerLog, SpecialCheckItemDangerLogReportDTO.class);
+                specialCheckItemDangerLogReportDTO.setCreateDate(dateFormat.format(scoreAndDangerLog.getCreateDate()));
+                specialCheckItemDangerLogReportDTO.setUpdateDate(dateFormat.format(scoreAndDangerLog.getUpdateDate()));
+                specialCheckItemDangerLogReportDTO.setCheckDate(dateFormatCheckData.format(scoreAndDangerLog.getCheckDate()));
+                specialCheckItemDangerLogReportDTO.setDeleted(scoreAndDangerLog.getDeleted().toString());
+                list.add(specialCheckItemDangerLogReportDTO);
+            }
+//            logger.info("【【原始数据】】" + JSONObject.toJSONString(list));
+            System.out.println("【【原始数据】】" + JSONObject.toJSONString(list));
+            String AESReportUnitDate = encrypt(JSONObject.toJSONString(list), key.getBytes(), iv.getBytes());
+//            logger.info("【【AES加密结果】】"+ AESReportUnitDate);![](C:/Users/Ad![](C:/Users/Admin/Desktop/所有桌面文件存放/9}AM56M10$6WX){0JRK`$6X.jpg)min/Desktop/所有桌面文件存放/9}AM56M10$6WX){0JRK`$6X.jpg)
+            StringBuffer itemDangerResultBuffer = null;
+
+
+            //上报数据
+             try {
+             URL url = new URL("http://120.71.182.198:9999/v1/data/receive/receiveCheckDangerList");
+             //得到连接对象
+             con = (HttpURLConnection) url.openConnection();
+             //设置请求类型
+             con.setRequestMethod("POST");
+             //允许写出
+             con.setDoOutput(true);
+             //允许读入
+             con.setDoInput(true);
+             //不使用缓存
+             con.setUseCaches(false);
+             con.setInstanceFollowRedirects(true);
+             //设置请求头
+             con.setRequestProperty("X-Access-Token",token+formatDate.toString());
+             //设置Content-Type,此处根据实际情况确定
+             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());
+                //组装入参,设置请求体
+                os.write(JSON.toJSONString(paraMap).getBytes());
+
+                //本段日志,测试成功后,可注释掉
+                if (responseCode == HttpURLConnection.HTTP_OK) {
+                    //得到响应流
+                    InputStream inputStream = con.getInputStream();
+                    //将响应流转换成字符串
+                    itemDangerResultBuffer = new StringBuffer();
+                    String line;
+                    buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
+                    while ((line = buffer.readLine()) != null) {
+                        itemDangerResultBuffer.append(line);
+                    }
+//                    logger.info("result:" + unitResultBuffer.toString());
+                    System.out.println("result:" + itemDangerResultBuffer.toString());
+                }
+
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+
+            //接收返回值,保存返回值
+            CJReportResultData CJOverhaulLogResult = JSONObject.parseObject(itemDangerResultBuffer.toString(), CJReportResultData.class);
+            //接收返回值,保存返回值
+            List<String> errorIdList= new ArrayList<>();
+            Data data = JSONObject.parseObject(CJOverhaulLogResult.getData(), Data.class);
+            //保存失败结果
+            if (ObjectUtils.isNotEmpty(data)){
+                for (ErrorMsgDetails errorMsgDetail : data.getErrorMsgDetails()) {
+                    errorIdList.add(errorMsgDetail.getId());
+                }
+            }
+            LocalDateTime nowDate = LocalDateTime.now();
+            logger.info("【检查项与隐患】数据上报结果:" + CJOverhaulLogResult.getCode());
+            //设置所有数据上报成功
+            if (CJOverhaulLogResult.getCode().equals(CJReportEnum.SUCCESS.getCode()) || CJOverhaulLogResult.getCode().equals(CJReportEnum.SUCESS_AND_FAIL.getCode())){
+                for (TbSpecialCheckScoreAndDangerLog itemDangerLo : scoreAndDangerLogs) {
+                    HandlerSpecialCheckReportParam handlerCJReportParam = new HandlerSpecialCheckReportParam();
+                    //封装数据
+                    handlerCJReportParam.setId(itemDangerLo.getId());
+                    handlerCJReportParam.setReportStatus(SyncEnum.SYNC_EXEC_SUCCESS.getCode());
+                    handlerCJReportParam.setReportTime(nowDate);
+                    scoreAndDangerLogMapper.updateItemDangerReportStatusById(handlerCJReportParam);
+                }
+            }
+            //设置上报失败的数据,上报失败
+            if (CJOverhaulLogResult.getCode().equals(CJReportEnum.FAIL.getCode()) || CJOverhaulLogResult.getCode().equals(CJReportEnum.SUCESS_AND_FAIL.getCode())){
+                for (String failId : errorIdList) {
+                    //上报失败
+                    HandlerSpecialCheckReportParam handlerCJReportParam = new HandlerSpecialCheckReportParam();
+                    //封装数据
+                    handlerCJReportParam.setId(failId);
+                    handlerCJReportParam.setReportStatus(SyncEnum.SYNC_EXEC_FAIL.getCode());
+                    handlerCJReportParam.setReportTime(nowDate);
+                    scoreAndDangerLogMapper.updateItemDangerReportStatusById(handlerCJReportParam);
+                }
+            }
+
+
+//            logger.info("【1】安全风险分析单元-数据处理完成");
+            System.out.println("【检查项与隐患】-数据处理完成");
+        }else {
+//            logger.info("【1】风险分析单元-无数据上报昌吉州");
+            System.out.println("【检查项与隐患】-无数据上报昌吉州");
+        }
+
+
+
+    }
+}

--
Gitblit v1.9.2