From e98eeaaa5766511fdb8e6d5e412eb1c59d1f07ce Mon Sep 17 00:00:00 2001
From: heheng <475597332@qq.com>
Date: 星期二, 24 六月 2025 10:24:43 +0800
Subject: [PATCH] 隐患来源功能外加仓吉基础数据定时上报
---
src/main/java/com/ruoyi/project/tr/specialCheck/scheduleLogTask/ItemDangerReportSchedule.java | 28 ++++++++++++----------------
1 files changed, 12 insertions(+), 16 deletions(-)
diff --git a/src/main/java/com/ruoyi/project/tr/specialCheck/Test/ItemDangerReportScheduleTest.java b/src/main/java/com/ruoyi/project/tr/specialCheck/scheduleLogTask/ItemDangerReportSchedule.java
similarity index 88%
rename from src/main/java/com/ruoyi/project/tr/specialCheck/Test/ItemDangerReportScheduleTest.java
rename to src/main/java/com/ruoyi/project/tr/specialCheck/scheduleLogTask/ItemDangerReportSchedule.java
index 25a658b..3a7e854 100644
--- a/src/main/java/com/ruoyi/project/tr/specialCheck/Test/ItemDangerReportScheduleTest.java
+++ b/src/main/java/com/ruoyi/project/tr/specialCheck/scheduleLogTask/ItemDangerReportSchedule.java
@@ -1,4 +1,4 @@
-package com.ruoyi.project.tr.specialCheck.Test;
+package com.ruoyi.project.tr.specialCheck.scheduleLogTask;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
@@ -9,13 +9,9 @@
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;
@@ -39,7 +35,7 @@
import java.util.*;
@Component
-public class ItemDangerReportScheduleTest {
+public class ItemDangerReportSchedule {
private final Logger logger = LoggerFactory.getLogger(this.getClass());
@@ -80,12 +76,12 @@
@Transactional
// @Scheduled(cron = "0 0 23 * * ?") //每天晚上23点执行一次0 0 22,23 * * ?
-// @Scheduled(cron = "0 0 22,23 * * ?") //每天晚上22、23点执行一次
+ @Scheduled(cron = "15 12 12,23 * * ?") //每天晚上22、23点执行一次
// @Scheduled(cron = "0 0/1 * * * ? ") // 分钟
// @Scheduled(cron = "0 0/35 * * * ? ") // 分钟
// @Scheduled(cron = "0/5 * * * * ?")
public void execReportDateSchedule() throws UnsupportedEncodingException {
- logger.info("【####】上报数据开始...");
+ logger.info("scoreAndDangerLog【####】上报数据开始...");
HttpURLConnection con = null;
BufferedReader buffer = null;
@@ -101,12 +97,12 @@
SimpleDateFormat tokenDate= new SimpleDateFormat("yyyyMMddHHmmssSSS");
String formatDate = tokenDate.format(date);
- logger.info("【token时间】" + formatDate);
+ logger.info("scoreAndDangerLog【token时间】" + formatDate);
/**
* 1、检查项与隐患上报
* */
- System.out.println("【2】检查项与隐患上报-处理数据...");
+ logger.info("scoreAndDangerLog【2】检查项与隐患上报-处理数据...");
// List<TbSpecialCheckTaskLog> CJRiskAnaUnits = .listReportUnitDate();
List<TbSpecialCheckScoreAndDangerLog> scoreAndDangerLogs = scoreAndDangerLogMapper.listScoreAndDangerLogReportList();
if (ObjectUtils.isNotEmpty(scoreAndDangerLogs)){
@@ -122,7 +118,7 @@
list.add(specialCheckItemDangerLogReportDTO);
}
// logger.info("【【原始数据】】" + JSONObject.toJSONString(list));
- System.out.println("【【原始数据】】" + JSONObject.toJSONString(list));
+ logger.info("scoreAndDangerLog【【原始数据】】" + JSONObject.toJSONString(list));
String AESReportUnitDate = encrypt(JSONObject.toJSONString(list), key.getBytes(), iv.getBytes());
// logger.info("【【AES加密结果】】"+ AESReportUnitDate);{0JRK`$6X.jpg)min/Desktop/所有桌面文件存放/9}AM56M10$6WX){0JRK`$6X.jpg)
StringBuffer itemDangerResultBuffer = null;
@@ -150,7 +146,7 @@
OutputStream os = con.getOutputStream();
Map paraMap = new HashMap();
paraMap.put("data", AESReportUnitDate); /**封装数据*/
- System.out.println("【【加密请求体】】" + JSONArray.toJSON(paraMap).toString());
+ logger.info("scoreAndDangerLog【【加密请求体】】" + JSONArray.toJSON(paraMap).toString());
//组装入参，设置请求体
os.write(JSON.toJSONString(paraMap).getBytes());
@@ -166,7 +162,7 @@
itemDangerResultBuffer.append(line);
}
// logger.info("result:" + unitResultBuffer.toString());
- System.out.println("result:" + itemDangerResultBuffer.toString());
+ logger.info("scoreAndDangerLog【result】:" + itemDangerResultBuffer.toString());
}
} catch (Exception e) {
@@ -185,7 +181,7 @@
}
}
LocalDateTime nowDate = LocalDateTime.now();
- logger.info("【检查项与隐患】数据上报结果：" + CJOverhaulLogResult.getCode());
+ logger.info("scoreAndDangerLog【检查项与隐患】数据上报结果：" + CJOverhaulLogResult.getCode());
//设置所有数据上报成功
if (CJOverhaulLogResult.getCode().equals(CJReportEnum.SUCCESS.getCode()) || CJOverhaulLogResult.getCode().equals(CJReportEnum.SUCESS_AND_FAIL.getCode())){
for (TbSpecialCheckScoreAndDangerLog itemDangerLo : scoreAndDangerLogs) {
@@ -212,10 +208,10 @@
// logger.info("【1】安全风险分析单元-数据处理完成");
- System.out.println("【检查项与隐患】-数据处理完成");
+ logger.info("scoreAndDangerLog【检查项与隐患】-数据处理完成");
}else {
// logger.info("【1】风险分析单元-无数据上报昌吉州");
- System.out.println("【检查项与隐患】-无数据上报昌吉州");
+ logger.info("scoreAndDangerLog【检查项与隐患】-无数据上报昌吉州");
}
--
Gitblit v1.9.2