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