From 563edf466bd56d91bed9d5d4f1203fefca2709f3 Mon Sep 17 00:00:00 2001 From: "1378012178@qq.com" <1378012178@qq.com> Date: Thu, 28 Aug 2025 10:45:53 +0800 Subject: [PATCH] =?UTF-8?q?=E6=81=A2=E5=A4=8D=E5=AE=9E=E4=BD=93=E7=B1=BB?= =?UTF-8?q?=E5=AD=97=E6=AE=B5=E7=B1=BB=E5=9E=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/heating/entity/Heatanalysis.java | 30 +- .../modules/heating/job/FlowanalysisJob.java | 265 +++++++++--------- 2 files changed, 147 insertions(+), 148 deletions(-) diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/entity/Heatanalysis.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/entity/Heatanalysis.java index 1b358ab..7bafa0d 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/entity/Heatanalysis.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/entity/Heatanalysis.java @@ -100,22 +100,22 @@ public class Heatanalysis extends JeecgEntity { private Integer reportType;//数据采集类型 1设备自动上报 2定时模拟 private String fromFlow; // 温度是否从流量取 0否 1是 private String view031; // 流量设备SN，view031到view047全是从流量表上获取的数据 - private Date view032; // 流量数据上报时间 + private String view032; // 流量数据上报时间 private String view033; // 仪表ID - private int view034; // 数据有效标识 0无效 1有效 - private Double view035; // 供水温度 - private Double view036; // 回水温度 - private Double view037; // 瞬时流量 - private Double view038; // 正累积流量 - private Double view039; // 负累积流量 - private Double view040; // 净累积流量 - private Double view041; // 瞬时热量 - private Double view042; // 正累积热量 - private Double view043; // 负累积热量 - private Double view044; // 净累积热量 - private Double view045; // 流体速度 - private Double view046; // 流量因子 - private Double view047; // 热量因子 + private String view034; // 数据有效标识 0无效 1有效 + private String view035; // 供水温度 + private String view036; // 回水温度 + private String view037; // 瞬时流量 + private String view038; // 正累积流量 + private String view039; // 负累积流量 + private String view040; // 净累积流量 + private String view041; // 瞬时热量 + private String view042; // 正累积热量 + private String view043; // 负累积热量 + private String view044; // 净累积热量 + private String view045; // 流体速度 + private String view046; // 流量因子 + private String view047; // 热量因子 private Integer isExtract;//是否抽取 0否 1是 /**地区类型*/ @Excel(name = "地区类型", width = 15) diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/job/FlowanalysisJob.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/job/FlowanalysisJob.java index c46abbe..17d9be4 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/job/FlowanalysisJob.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/job/FlowanalysisJob.java @@ -32,162 +32,161 @@ import java.io.IOException; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; - /** * 发送消息任务 - * * @author: jeecg-boot */ @Slf4j public class FlowanalysisJob implements Job { - @Autowired - private HeatanalysisService heatanalysisService; + @Autowired + private HeatanalysisService heatanalysisService; - @Autowired - private IBlWaterFlowConfigService WaterFlowConfigService; + @Autowired + private IBlWaterFlowConfigService WaterFlowConfigService; - @Override - public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { + @Override + public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { - log.info(String.format("获取热量水流量数据 ! 时间:" + DateUtils.getTimestamp())); - QueryWrapper queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("del_flag", "0"); - List list = WaterFlowConfigService.list(queryWrapper); - for (BlWaterFlowConfig config : list) { - try { - String sn = config.getSn(); - String json = getWebInfo(sn); - if (StringUtils.equals(json, "false")) continue; - JSONObject jsonObject = new JSONObject(json); - log.info("jsonObject:" + jsonObject); - String success = jsonObject.getStr("success"); - if (StringUtils.equals(success, "true")) { - QueryWrapper heatanalysisQueryWrapper = new QueryWrapper<>(); - heatanalysisQueryWrapper.eq("view031", sn); - heatanalysisQueryWrapper.last("limit 1"); - Heatanalysis heatanalysis = heatanalysisService.getOne(heatanalysisQueryWrapper); - if (heatanalysis != null) { - Date view032_old = heatanalysis.getView032(); - String data = jsonObject.getStr("data"); - JSONObject dataObject = new JSONObject(data); - String view032 = dataObject.getStr("logat"); - if (StringUtils.equals(view032, new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(view032_old))) { - log.info("--------数据重复---------"); - continue; - } - String view033 = dataObject.getStr("ID"); - String view034 = dataObject.getStr("valid"); - String view035 = dataObject.getStr("gswd"); - String view036 = dataObject.getStr("hswd"); - String view037 = dataObject.getStr("flowRate"); - String view037_2 = dataObject.getStr("ssll"); - String view038 = dataObject.getStr("pflowAccumulator"); - String view038_2 = dataObject.getStr("zljll"); - String view039 = dataObject.getStr("nflowAccumulator"); - String view039_2 = dataObject.getStr("fljll"); - String view040 = dataObject.getStr("netflowAccumulator"); - String view040_2 = dataObject.getStr("jljll"); - String view041 = dataObject.getStr("ssrl"); - String view042 = dataObject.getStr("zljrl"); - String view043 = dataObject.getStr("fljrl"); - String view044 = dataObject.getStr("jljrl"); - String view045 = dataObject.getStr("ltsd"); - String view046 = dataObject.getStr("n"); - String view047 = dataObject.getStr("m"); - heatanalysis.setView031(sn); - heatanalysis.setView032(new Date(view032)); - heatanalysis.setView033(view033); - heatanalysis.setView034(Integer.parseInt(view034)); - heatanalysis.setView035(Double.parseDouble(view035)); - heatanalysis.setView036(Double.parseDouble(view036)); - if (StringUtils.isEmpty(view037)) { - heatanalysis.setView037(Double.parseDouble(view037_2)); - } else { - heatanalysis.setView037(Double.parseDouble(view037)); - } - if (StringUtils.isEmpty(view038)) { - heatanalysis.setView038(Double.parseDouble(view038_2)); - } else { - heatanalysis.setView038(Double.parseDouble(view038)); - } - if (StringUtils.isEmpty(view039)) { - heatanalysis.setView039(Double.parseDouble(view039_2)); - } else { - heatanalysis.setView039(Double.parseDouble(view039)); - } - if (StringUtils.isEmpty(view040)) { - heatanalysis.setView040(Double.parseDouble(view040_2)); - } else { - heatanalysis.setView040(Double.parseDouble(view040)); - } - heatanalysis.setView041(Double.parseDouble(view041)); - heatanalysis.setView042(Double.parseDouble(view042)); - heatanalysis.setView043(Double.parseDouble(view043)); - heatanalysis.setView044(Double.parseDouble(view044)); - heatanalysis.setView045(Double.parseDouble(view045)); - heatanalysis.setView046(Double.parseDouble(view046)); - heatanalysis.setView047(Double.parseDouble(view047)); - heatanalysisService.exeWater(heatanalysis); + log.info(String.format("获取热量水流量数据 ! 时间:" + DateUtils.getTimestamp())); + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("del_flag","0"); + List list = WaterFlowConfigService.list(queryWrapper); + for(BlWaterFlowConfig config : list){ + try{ + String sn = config.getSn(); + String json = getWebInfo(sn); + if(StringUtils.equals(json,"false")) continue; + JSONObject jsonObject = new JSONObject(json); + log.info("jsonObject:"+jsonObject); + String success = jsonObject.getStr("success"); + if(StringUtils.equals(success,"true")){ + QueryWrapper heatanalysisQueryWrapper = new QueryWrapper<>(); + heatanalysisQueryWrapper.eq("view031",sn); + heatanalysisQueryWrapper.last("limit 1"); + Heatanalysis heatanalysis = heatanalysisService.getOne(heatanalysisQueryWrapper); + if(heatanalysis != null){ + String view032_old = heatanalysis.getView032(); + String data = jsonObject.getStr("data"); + JSONObject dataObject = new JSONObject(data); + String view032 = dataObject.getStr("logat"); + if(StringUtils.equals(view032,view032_old)){ + log.info("--------数据重复---------"); + continue; + } + String view033 = dataObject.getStr("ID"); + String view034 = dataObject.getStr("valid"); + String view035 = dataObject.getStr("gswd"); + String view036 = dataObject.getStr("hswd"); + String view037 = dataObject.getStr("flowRate"); + String view037_2 = dataObject.getStr("ssll"); + String view038 = dataObject.getStr("pflowAccumulator"); + String view038_2 = dataObject.getStr("zljll"); + String view039 = dataObject.getStr("nflowAccumulator"); + String view039_2 = dataObject.getStr("fljll"); + String view040 = dataObject.getStr("netflowAccumulator"); + String view040_2 = dataObject.getStr("jljll"); + String view041 = dataObject.getStr("ssrl"); + String view042 = dataObject.getStr("zljrl"); + String view043 = dataObject.getStr("fljrl"); + String view044 = dataObject.getStr("jljrl"); + String view045 = dataObject.getStr("ltsd"); + String view046 = dataObject.getStr("n"); + String view047 = dataObject.getStr("m"); + heatanalysis.setView031(sn); + heatanalysis.setView032(view032); + heatanalysis.setView033(view033); + heatanalysis.setView034(view034); + heatanalysis.setView035(view035); + heatanalysis.setView036(view036); + if (StringUtils.isEmpty(view037)){ + heatanalysis.setView037(view037_2); + }else{ + heatanalysis.setView037(view037); + } + if (StringUtils.isEmpty(view038)){ + heatanalysis.setView038(view038_2); + }else{ + heatanalysis.setView038(view038); + } + if (StringUtils.isEmpty(view039)){ + heatanalysis.setView039(view039_2); + }else{ + heatanalysis.setView039(view039); + } + if (StringUtils.isEmpty(view040)){ + heatanalysis.setView040(view040_2); + }else{ + heatanalysis.setView040(view040); + } + heatanalysis.setView041(view041); + heatanalysis.setView042(view042); + heatanalysis.setView043(view043); + heatanalysis.setView044(view044); + heatanalysis.setView045(view045); + heatanalysis.setView046(view046); + heatanalysis.setView047(view047); + heatanalysisService.exeWater(heatanalysis); - } - } + } + } - } catch (Exception e) { - e.printStackTrace(); - } - } - } + } catch (Exception e) { + e.printStackTrace(); + } + } + } - public static String getWebInfo(String sn) { - String result = "false"; - try { - // 1. 创建URL对象 - URL url = new URL("http://49.235.190.102:8068/api/v1/feeding/snap/b501a6e0-d23f-4282-8fab-78661bf999e7/" + sn); - // 2. 打开连接，转换为HttpURLConnection - HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + public static String getWebInfo(String sn) { + String result = "false"; + try { + // 1. 创建URL对象 + URL url = new URL("http://49.235.190.102:8068/api/v1/feeding/snap/b501a6e0-d23f-4282-8fab-78661bf999e7/"+sn); - // 3. 设置请求方法为GET - connection.setRequestMethod("GET"); + // 2. 打开连接，转换为HttpURLConnection + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); - // 4. 可选：设置请求头（例如，指定期望的响应内容类型） - connection.setRequestProperty("Accept", "application/json"); + // 3. 设置请求方法为GET + connection.setRequestMethod("GET"); - // 5. 获取响应代码 - int responseCode = connection.getResponseCode(); - System.out.println("Response Code: " + responseCode); + // 4. 可选：设置请求头（例如，指定期望的响应内容类型） + connection.setRequestProperty("Accept", "application/json"); - // 6. 如果响应成功（200 OK），读取响应体 - if (responseCode == HttpURLConnection.HTTP_OK) { - // 使用BufferedReader读取输入流 - BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream())); - String inputLine; - StringBuilder response = new StringBuilder(); + // 5. 获取响应代码 + int responseCode = connection.getResponseCode(); + System.out.println("Response Code: " + responseCode); - while ((inputLine = in.readLine()) != null) { - response.append(inputLine); - } - in.close(); // 关闭流 + // 6. 如果响应成功（200 OK），读取响应体 + if (responseCode == HttpURLConnection.HTTP_OK) { + // 使用BufferedReader读取输入流 + BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream())); + String inputLine; + StringBuilder response = new StringBuilder(); - // 打印响应结果 - log.info(String.format("获取热量水流量数据 - Response Body:" + response.toString())); - result = response.toString(); - } else { - log.error(String.format("获取热量水流量数据 - GET request failed.")); - result = "false"; - } + while ((inputLine = in.readLine()) != null) { + response.append(inputLine); + } + in.close(); // 关闭流 - // 7. 断开连接 - connection.disconnect(); + // 打印响应结果 + log.info(String.format("获取热量水流量数据 - Response Body:" + response.toString())); + result = response.toString(); + } else { + log.error(String.format("获取热量水流量数据 - GET request failed.")); + result = "false"; + } - } catch (IOException e) { - e.printStackTrace(); - result = "false"; - } - return result; - } + // 7. 断开连接 + connection.disconnect(); + + } catch (IOException e) { + e.printStackTrace(); + result = "false"; + } + return result; + } }