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/SpecialCheckTaskDownload.java |  670 +++++++++++++++++++++++++++---------------------------
 1 files changed, 335 insertions(+), 335 deletions(-)

diff --git a/src/main/java/com/ruoyi/project/tr/specialCheck/Test/SpecialCheckTaskDownload.java b/src/main/java/com/ruoyi/project/tr/specialCheck/Test/SpecialCheckTaskDownload.java
index cdc07c5..8ccc6f5 100644
--- a/src/main/java/com/ruoyi/project/tr/specialCheck/Test/SpecialCheckTaskDownload.java
+++ b/src/main/java/com/ruoyi/project/tr/specialCheck/Test/SpecialCheckTaskDownload.java
@@ -1,335 +1,335 @@
-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.project.tr.riskList.service.IRiskListService;
-import com.ruoyi.project.tr.specialCheck.domin.DownloadDTO.*;
-import com.ruoyi.project.tr.specialCheck.domin.TbBaseCheckItem;
-import com.ruoyi.project.tr.specialCheck.domin.TbBaseCheckScore;
-import com.ruoyi.project.tr.specialCheck.domin.TbBaseCheckTask;
-import com.ruoyi.project.tr.specialCheck.domin.TbCheckConfig;
-import com.ruoyi.project.tr.specialCheck.mapper.*;
-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.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.format.DateTimeFormatter;
-import java.util.*;
-
-@Component
-public class SpecialCheckTaskDownload {
-
-    private final Logger logger = LoggerFactory.getLogger(this.getClass());
-
-    @Autowired
-    private TbBaseCheckCompanyMapper companyTbRepository;
-    @Autowired
-    private TbBaseCheckItemMapper itemTbRepository;
-    @Autowired
-    private TbBaseCheckScoreMapper scoreTbRepository;
-    @Autowired
-    private TbBaseCheckTaskMapper taskTbRepository;
-    @Autowired
-    private TbSpecialCheckTaskLogMapper taskSpecialLogMapper;
-    @Autowired
-    private IRiskListService riskListService;
-    @Autowired
-    private TbCheckConfigMapper configMapper;
-
-    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/20 * * * ? ")    // 分钟
-//    @Scheduled(cron = "0/5 * * * * ?")
-    public void execReportDateSchedule() throws UnsupportedEncodingException {
-        logger.info("【####】拉取专项检查数据开始...");
-
-        HttpURLConnection con = null;
-        BufferedReader buffer = null;
-        int responseCode = 200;
-
-        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
-         * */
-        logger.info("【####】拉取专项任务数据开始...");
-        TbCheckConfig specialCheckConfig = configMapper.getSpecialCheckConfig();
-        if (specialCheckConfig.getStatus() == 2){
-
-            StringBuffer specialCheckBuffer = null;
-
-            //上报数据
-             try {
-             URL url = new URL("http://120.71.182.198:9999/v1/data/receive/getCheckTask");
-             //得到连接对象
-             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();
-
-            //本段日志,测试成功后,可注释掉
-            if (responseCode == HttpURLConnection.HTTP_OK) {
-                //得到响应流
-                InputStream inputStream = con.getInputStream();
-                //将响应流转换成字符串
-                specialCheckBuffer = new StringBuffer();
-                String line;
-                buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
-                while ((line = buffer.readLine()) != null) {
-                    specialCheckBuffer.append(line);
-                }
-//                    logger.info("result:" + unitResultBuffer.toString());
-                System.out.println("result:" + specialCheckBuffer.toString());
-            }
-
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
-
-            //接收返回值,保存返回值
-            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);
-                }
-            }
-
-            logger.info("【专项检查任务】-读取任务结果:" + checkTaskDownloadDTO.getCode());
-            System.out.println("【专项检查任务】-读取任务完成");
-        }else {
-            System.out.println("【专项检查任务】- 不读取任务");
-        }
-
-        /**
-         * 2
-         * */
-        logger.info("【####】拉取检查项数据开始...");
-        if (specialCheckConfig.getStatus() == 2){
-
-            StringBuffer specialCheckBuffer = null;
-
-            ItemDownloadRespDTO itemDownloadRespDTO = new ItemDownloadRespDTO();
-            TbBaseCheckTask baseCheckTask = taskTbRepository.getBaseCheckTaskByStatus(date);
-            Page page = new Page();
-            page.setCurrent(String.valueOf(1));
-            page.setSize(String.valueOf(1000));
-
-            itemDownloadRespDTO.setTaskId(baseCheckTask.getId());
-            itemDownloadRespDTO.setPage(page);
-            //加密请求数据
-            String AESReportUnitDate = encrypt(JSONObject.toJSONString(itemDownloadRespDTO), key.getBytes(), iv.getBytes());
-            //上报数据
-            try {
-                URL url = new URL("http://120.71.182.198:9999/v1/data/receive/getCheckItem");
-                //得到连接对象
-                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();
-                    //将响应流转换成字符串
-                    specialCheckBuffer = new StringBuffer();
-                    String line;
-                    buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
-                    while ((line = buffer.readLine()) != null) {
-                        specialCheckBuffer.append(line);
-                    }
-//                    logger.info("result:" + unitResultBuffer.toString());
-                    System.out.println("result:" + specialCheckBuffer.toString());
-                }
-
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
-
-            //接收返回值,保存返回值
-            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);
-                }
-            }
-
-            taskTbRepository.updateStatusById(baseCheckTask.getId());
-
-            logger.info("【专项任务检查项】-读取检查项结果:" + itemDownloadRespBO.getCode());
-            System.out.println("【专项任务检查项】-读取检查项完成");
-        }else {
-            System.out.println("【专项任务检查项】- 不读取检查项");
-        }
-
-        /**
-         * 3
-         * */
-        logger.info("【####】拉取评分细则开始...");
-        if (specialCheckConfig.getStatus() == 2){
-
-            StringBuffer specialCheckBuffer = null;
-
-            ScoreDownloadRespDTO scoreDownloadRespDTO = new ScoreDownloadRespDTO();
-            TbBaseCheckItem baseItemByStatus = itemTbRepository.getBaseItemByStatus(date);
-            Page page = new Page();
-            page.setCurrent(String.valueOf(1));
-            page.setSize(String.valueOf(1000));
-
-            scoreDownloadRespDTO.setTaskId(baseItemByStatus.getTaskId());
-            scoreDownloadRespDTO.setCheckItemId(baseItemByStatus.getId());
-            scoreDownloadRespDTO.setPage(page);
-            //加密请求数据
-            String AESReportUnitDate = encrypt(JSONObject.toJSONString(scoreDownloadRespDTO), key.getBytes(), iv.getBytes());
-            //上报数据
-            try {
-                URL url = new URL("http://120.71.182.198:9999/v1/data/receive/getCheckItem");
-                //得到连接对象
-                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();
-                    //将响应流转换成字符串
-                    specialCheckBuffer = new StringBuffer();
-                    String line;
-                    buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
-                    while ((line = buffer.readLine()) != null) {
-                        specialCheckBuffer.append(line);
-                    }
-//                    logger.info("result:" + unitResultBuffer.toString());
-                    System.out.println("result:" + specialCheckBuffer.toString());
-                }
-
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
-
-            //接收返回值,保存返回值
-            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);
-                }
-
-            }
-            itemTbRepository.updateStatusById(baseItemByStatus.getId());
-
-            logger.info("【评分细则】-读取结果:" + scoreDownloadRespBO.getCode());
-            System.out.println("【评分细则】-读取完成");
-        }else {
-            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.project.tr.riskList.service.IRiskListService;
+import com.ruoyi.project.tr.specialCheck.domin.DownloadDTO.*;
+import com.ruoyi.project.tr.specialCheck.domin.TbBaseCheckItem;
+import com.ruoyi.project.tr.specialCheck.domin.TbBaseCheckScore;
+import com.ruoyi.project.tr.specialCheck.domin.TbBaseCheckTask;
+import com.ruoyi.project.tr.specialCheck.domin.TbCheckConfig;
+import com.ruoyi.project.tr.specialCheck.mapper.*;
+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.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.format.DateTimeFormatter;
+import java.util.*;
+
+@Component
+public class SpecialCheckTaskDownload {
+
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    private TbBaseCheckCompanyMapper companyTbRepository;
+    @Autowired
+    private TbBaseCheckItemMapper itemTbRepository;
+    @Autowired
+    private TbBaseCheckScoreMapper scoreTbRepository;
+    @Autowired
+    private TbBaseCheckTaskMapper taskTbRepository;
+    @Autowired
+    private TbSpecialCheckTaskLogMapper taskSpecialLogMapper;
+    @Autowired
+    private IRiskListService riskListService;
+    @Autowired
+    private TbCheckConfigMapper configMapper;
+
+    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/20 * * * ? ")    // 分钟
+//    @Scheduled(cron = "0/5 * * * * ?")
+    public void execReportDateSchedule() throws UnsupportedEncodingException {
+        logger.info("【####】拉取专项检查数据开始...");
+
+        HttpURLConnection con = null;
+        BufferedReader buffer = null;
+        int responseCode = 200;
+
+        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
+         * */
+        logger.info("【####】拉取专项任务数据开始...");
+        TbCheckConfig specialCheckConfig = configMapper.getSpecialCheckConfig();
+        if (specialCheckConfig.getStatus() == 2){
+
+            StringBuffer specialCheckBuffer = null;
+
+            //上报数据
+             try {
+             URL url = new URL("http://120.71.182.198:9999/v1/data/receive/getCheckTask");
+             //得到连接对象
+             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();
+
+            //本段日志,测试成功后,可注释掉
+            if (responseCode == HttpURLConnection.HTTP_OK) {
+                //得到响应流
+                InputStream inputStream = con.getInputStream();
+                //将响应流转换成字符串
+                specialCheckBuffer = new StringBuffer();
+                String line;
+                buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
+                while ((line = buffer.readLine()) != null) {
+                    specialCheckBuffer.append(line);
+                }
+//                    logger.info("result:" + unitResultBuffer.toString());
+                System.out.println("result:" + specialCheckBuffer.toString());
+            }
+
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+
+            //接收返回值,保存返回值
+            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);
+                }
+            }
+
+            logger.info("【专项检查任务】-读取任务结果:" + checkTaskDownloadDTO.getCode());
+            System.out.println("【专项检查任务】-读取任务完成");
+        }else {
+            System.out.println("【专项检查任务】- 不读取任务");
+        }
+
+        /**
+         * 2
+         * */
+        logger.info("【####】拉取检查项数据开始...");
+        if (specialCheckConfig.getStatus() == 2){
+
+            StringBuffer specialCheckBuffer = null;
+
+            ItemDownloadRespDTO itemDownloadRespDTO = new ItemDownloadRespDTO();
+            TbBaseCheckTask baseCheckTask = taskTbRepository.getBaseCheckTaskByStatus(date);
+            Page page = new Page();
+            page.setCurrent(String.valueOf(1));
+            page.setSize(String.valueOf(1000));
+
+            itemDownloadRespDTO.setTaskId(baseCheckTask.getId());
+            itemDownloadRespDTO.setPage(page);
+            //加密请求数据
+            String AESReportUnitDate = encrypt(JSONObject.toJSONString(itemDownloadRespDTO), key.getBytes(), iv.getBytes());
+            //上报数据
+            try {
+                URL url = new URL("http://120.71.182.198:9999/v1/data/receive/getCheckItem");
+                //得到连接对象
+                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();
+                    //将响应流转换成字符串
+                    specialCheckBuffer = new StringBuffer();
+                    String line;
+                    buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
+                    while ((line = buffer.readLine()) != null) {
+                        specialCheckBuffer.append(line);
+                    }
+//                    logger.info("result:" + unitResultBuffer.toString());
+                    System.out.println("result:" + specialCheckBuffer.toString());
+                }
+
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+
+            //接收返回值,保存返回值
+            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);
+                }
+            }
+
+            taskTbRepository.updateStatusById(baseCheckTask.getId());
+
+            logger.info("【专项任务检查项】-读取检查项结果:" + itemDownloadRespBO.getCode());
+            System.out.println("【专项任务检查项】-读取检查项完成");
+        }else {
+            System.out.println("【专项任务检查项】- 不读取检查项");
+        }
+
+        /**
+         * 3
+         * */
+        logger.info("【####】拉取评分细则开始...");
+        if (specialCheckConfig.getStatus() == 2){
+
+            StringBuffer specialCheckBuffer = null;
+
+            ScoreDownloadRespDTO scoreDownloadRespDTO = new ScoreDownloadRespDTO();
+            TbBaseCheckItem baseItemByStatus = itemTbRepository.getBaseItemByStatus(date);
+            Page page = new Page();
+            page.setCurrent(String.valueOf(1));
+            page.setSize(String.valueOf(1000));
+
+            scoreDownloadRespDTO.setTaskId(baseItemByStatus.getTaskId());
+            scoreDownloadRespDTO.setCheckItemId(baseItemByStatus.getId());
+            scoreDownloadRespDTO.setPage(page);
+            //加密请求数据
+            String AESReportUnitDate = encrypt(JSONObject.toJSONString(scoreDownloadRespDTO), key.getBytes(), iv.getBytes());
+            //上报数据
+            try {
+                URL url = new URL("http://120.71.182.198:9999/v1/data/receive/getCheckItem");
+                //得到连接对象
+                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();
+                    //将响应流转换成字符串
+                    specialCheckBuffer = new StringBuffer();
+                    String line;
+                    buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
+                    while ((line = buffer.readLine()) != null) {
+                        specialCheckBuffer.append(line);
+                    }
+//                    logger.info("result:" + unitResultBuffer.toString());
+                    System.out.println("result:" + specialCheckBuffer.toString());
+                }
+
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+
+            //接收返回值,保存返回值
+            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);
+                }
+
+            }
+            itemTbRepository.updateStatusById(baseItemByStatus.getId());
+
+            logger.info("【评分细则】-读取结果:" + scoreDownloadRespBO.getCode());
+            System.out.println("【评分细则】-读取完成");
+        }else {
+            System.out.println("【评分细则】- 不读取");
+        }
+
+
+    }
+}

--
Gitblit v1.9.2