diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/job/HeatingReportJob.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/job/HeatingReportJob.java index 963062c..68d4981 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/job/HeatingReportJob.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/job/HeatingReportJob.java @@ -55,25 +55,26 @@ public class HeatingReportJob implements Job { SimpleDateFormat sdf= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String SDate = sdf.format(new Date()); String tableName = "heatanalysis_"+SDate.substring(2, 4)+SDate.substring(5, 7); + //城区 List list = new ArrayList<>(); - list.add("22423010001");//磐石市白云物业管理有限责任公司 磐石白云物业供热站 白云锅炉房 + list.add("22423010000");//磐石市白云物业管理有限责任公司 磐石白云物业供热站 白云锅炉房 抽取白云换热站一次网22423010001 list.add("12423011000");//磐石市北亚供热有限公司 磐石北亚供热站 北亚锅炉房 -// list.add("");//磐石市颐和供热有限责任公司 磐石颐和供热站 三兴嘉园锅炉房 - list.add("22423030004");//磐石市鼎丰供热有限责任公司 磐石鼎丰供热站 汇城国樾府小区(香格里拉 + list.add("22423040000");//磐石市颐和供热有限责任公司 磐石颐和供热站 颐和锅炉房 2025-09-23上线 抽取城南小学低区一次网22423040002 + list.add("22423030000");//磐石市鼎丰供热有限责任公司 磐石鼎丰供热站 鼎丰锅炉房 抽取鼎丰睿园B区(低区)换热站一次网22423030004 list.add("22423013000");//磐石市冬晨供热有限公司 磐石冬晨供热站 冬晨锅炉房 list.add("22423014000");//磐石市海达供热有限公司 磐石海达供热站 海达锅炉房 - list.add("22423001001");//磐石市红大供热有限公司 磐石红大供热站 红大锅炉房 - list.add("22423002001");//磐石市宏城供热有限公司 磐石宏城供热站 宏城锅炉房 - list.add("22423003002");//磐石市隆昌物业管理有限公司 磐石隆昌物业供热站 隆昌1处锅炉房 - list.add("22423003005");//磐石市琉森供热管理有限公司 磐石琉森供热站 隆昌二处锅炉房 - list.add("32423012001");//磐石市牟力供热有限公司 磐石牟力供热站 牟力锅炉房 + list.add("22423001000");//磐石市红大供热有限公司 磐石红大供热站 红大锅炉房 抽取红大1号站一次网22423001001 + list.add("22423002000");//磐石市宏城供热有限公司 磐石宏城供热站 宏城锅炉房 抽取宏城南站一次网22423002001 + list.add("22423003001");//磐石市隆昌物业管理有限公司 磐石隆昌物业供热站 隆昌锅炉房 抽取隆昌换热站一次网22423003002 + list.add("22423003000");//磐石市琉森供热管理有限公司 磐石琉森供热站 琉森锅炉房 抽取琉森换热站一次网22423003005 + list.add("32423012000");//磐石市牟力供热有限公司 磐石牟力供热站 牟力锅炉房 抽取牟利换热站一次网32423012001 list.add("22423004000");//磐石市三兴供热有限公司 磐石三兴供热站 三兴锅炉房 list.add("12423005000");//磐石市升旺供热有限公司 磐石升旺供热站 升旺锅炉房 - list.add("22423008001");//磐石市万达物业管理有限公司 磐石万达供热站 万达锅炉房 + list.add("22423008000");//磐石市万达物业管理有限公司 磐石万达供热站 万达锅炉房 list.add("22423006000");//磐石市馨达供热有限公司 磐石馨达供热站 馨达锅炉房 list.add("22423009000");//磐石市忠信供热有限公司 磐石忠信供热站 忠信锅炉房 - list.add("22423020000");//磐石市恒升供热有限公司 磐石恒升供热站 恒升锅炉房 -// list.add("");//磐石市柏悦供热有限公司 磐石柏悦供热站 + list.add("22423020000");//磐石市恒升供热有限公司 磐石恒升供热站 恒升锅炉房 + list.add("22423028000");//磐石市柏悦供热有限公司 磐石柏悦供热站 柏悦锅炉房 2025-09-23上线 for(String sim:list){ Heatanalysis heatanalysis = new Heatanalysis(); heatanalysis.setSim(sim); @@ -81,17 +82,16 @@ public class HeatingReportJob implements Job { Heatanalysis heatanalysis2 = heatanalysisService.getHeatOne(heatanalysis); String CompanyName = ""; String HeatName = ""; -// if("1111111111".equals(sim)){ - if("22423010001".equals(sim)){ + if("22423010000".equals(sim)){ CompanyName = "磐石市白云物业管理有限责任公司"; HeatName = "磐石白云物业供热站"; }else if("12423011000".equals(sim)){ CompanyName = "磐石市北亚供热有限公司"; HeatName = "磐石北亚供热站"; - }else if("12423007000".equals(sim)){ + }else if("22423040000".equals(sim)){ CompanyName = "磐石市颐和供热有限责任公司"; HeatName = "磐石颐和供热站"; - }else if("22423030004".equals(sim)){ + }else if("22423030000".equals(sim)){ CompanyName = "磐石市鼎丰供热有限责任公司"; HeatName = "磐石鼎丰供热站"; }else if("22423013000".equals(sim)){ @@ -100,19 +100,19 @@ public class HeatingReportJob implements Job { }else if("22423014000".equals(sim)){ CompanyName = "磐石市海达供热有限公司"; HeatName = "磐石海达供热站"; - }else if("22423001001".equals(sim)){ + }else if("22423001000".equals(sim)){ CompanyName = "磐石市红大供热有限公司"; HeatName = "磐石红大供热站"; - }else if("22423002001".equals(sim)){ + }else if("22423002000".equals(sim)){ CompanyName = "磐石市宏城供热有限公司"; HeatName = "磐石宏城供热站"; - }else if("22423003002".equals(sim)){ + }else if("22423003001".equals(sim)){ CompanyName = "磐石市隆昌物业管理有限公司"; HeatName = "磐石隆昌物业供热站"; - }else if("22423003005".equals(sim)){ + }else if("22423003000".equals(sim)){ CompanyName = "磐石市琉森供热管理有限公司"; HeatName = "磐石琉森供热站"; - }else if("32423012001".equals(sim)){ + }else if("32423012000".equals(sim)){ CompanyName = "磐石市牟力供热有限公司"; HeatName = "磐石牟力供热站"; }else if("22423004000".equals(sim)){ @@ -121,7 +121,7 @@ public class HeatingReportJob implements Job { }else if("12423005000".equals(sim)){ CompanyName = "磐石市升旺供热有限公司"; HeatName = "磐石升旺供热站"; - }else if("22423008001".equals(sim)){ + }else if("22423008000".equals(sim)){ CompanyName = "磐石市万达物业管理有限公司"; HeatName = "磐石万达供热站"; }else if("22423006000".equals(sim)){ @@ -133,11 +133,10 @@ public class HeatingReportJob implements Job { }else if("22423020000".equals(sim)){ CompanyName = "磐石市恒升供热有限公司"; HeatName = "磐石恒升供热站"; + }else if("22423028000".equals(sim)){ + CompanyName = "磐石市柏悦供热有限公司"; + HeatName = "磐石柏悦供热站"; } -// else if("".equals(sim)){ -// CompanyName = "磐石市柏悦供热有限公司"; -// HeatName = "磐石柏悦供热站"; -// } try{ if(CompanyName!=null&&!"".equals(CompanyName)&&heatanalysis2!=null&&!"".equals(heatanalysis2.getId())){ log.info("sim:"+sim); @@ -152,6 +151,109 @@ public class HeatingReportJob implements Job { jsonObject2.put("PrimaryReturnPressure", heatanalysis2.getView008());//回水压力 jsonObject2.put("FeedFlow","0");//供水瞬时流量 jsonObject2.put("ReturnFlow", "0");//供水累计流量 + jsonObject2.put("InstantaneousHeating","0");//瞬时热量 + jsonObject2.put("AccumulatedHeating", "0");//累计热量 + jsonObject.put("InParam", jsonObject2); + jsonObject.put("RequestType", "normal");//默认填写 + jsonObject.put("RequestID","121");//默认填写 + log.info("jsonObject:"+jsonObject); + uploadData5(url,jsonObject.toString(),token); + } + }catch(Exception e){ + e.printStackTrace(); + } + } + + //乡镇 + List xzList = new ArrayList<>(); + xzList.add("22424031001");//取柴河镇 取柴河锅炉房 磐石市丽泽物业管理有限公司 + xzList.add("22424032001");//烟筒山镇 丰焱锅炉房 磐石市丰焱新能源有限公司 + xzList.add("22424032002");//烟筒山镇 吉金农投锅炉房 吉金农投(吉林)投资有限公司 + xzList.add("22424032003");//烟筒山镇 力民实业锅炉房 磐石力民实业有限公司 + xzList.add("22424033001");//吉昌镇 吉昌锅炉房 磐石市盛源有限公司 + xzList.add("22424034001");//明城镇 金地享锅炉房 磐石金地享物业有限公司 + xzList.add("22424034002");//明城镇 鑫诚锅炉房 磐石市鑫诚物业有限责任公司 + xzList.add("22424034003");//明城镇 机械厂锅炉房 磐石金地享物业有限公司 + xzList.add("22424034004");//明城镇 亚太锅炉房 磐石市宏源物业管理有限公司 + xzList.add("22424035001");//石嘴镇 石嘴锅炉房 磐石市鹏润供热有限责任公司 + xzList.add("22424036001");//驿马镇 驿马锅炉房 磐石市驿马镇旭生供热站 + xzList.add("22424037001");//富太镇 富太锅炉房 磐石市富太镇鑫悦晟供热处 + xzList.add("22424038001");//呼兰镇 呼兰锅炉房 磐石市日兴物业有限公司 + xzList.add("22424039001");//红旗岭镇 红旗岭锅炉房 磐石市红宇热力有限公司 + xzList.add("22424040001");//黑石镇 黑石锅炉房 磐石市会发河物业管理有限责任公司 + xzList.add("22424041001");//松山镇 松山锅炉房 磐石市宇盟物业管理有限公司 + for(String sim:xzList){ + Heatanalysis heatanalysis = new Heatanalysis(); + heatanalysis.setSim(sim); + heatanalysis.setTableName(tableName); + Heatanalysis heatanalysisXz = heatanalysisService.getXzHeatOne(heatanalysis); + String CompanyName = ""; + String HeatName = ""; + if("22424031001".equals(sim)){ + CompanyName = "磐石市丽泽物业管理有限公司"; + HeatName = "取柴河锅炉房"; + }else if("22424032001".equals(sim)){ + CompanyName = "磐石市丰焱新能源有限公司"; + HeatName = "丰焱锅炉房"; + }else if("22424032002".equals(sim)){ + CompanyName = "吉金农投(吉林)投资有限公司"; + HeatName = "吉金农投锅炉房"; + }else if("22424032003".equals(sim)){ + CompanyName = "磐石力民实业有限公司"; + HeatName = "力民实业锅炉房"; + }else if("22424033001".equals(sim)){ + CompanyName = "磐石市盛源有限公司"; + HeatName = "吉昌锅炉房"; + }else if("22424034001".equals(sim)){ + CompanyName = "磐石金地享物业有限公司"; + HeatName = "金地享1处锅炉房"; + }else if("22424034002".equals(sim)){ + CompanyName = "磐石市鑫诚物业有限责任公司"; + HeatName = "鑫诚锅炉房"; + }else if("22424034003".equals(sim)){ + CompanyName = "磐石金地享物业有限公司"; + HeatName = "金地享2处锅炉房"; + }else if("22424034004".equals(sim)){ + CompanyName = "磐石市宏源物业管理有限公司"; + HeatName = "亚太锅炉房"; + }else if("22424035001".equals(sim)){ + CompanyName = "磐石市鹏润供热有限责任公司"; + HeatName = "石嘴锅炉房"; + }else if("22424036001".equals(sim)){ + CompanyName = "磐石市驿马镇旭生供热站"; + HeatName = "驿马锅炉房"; + }else if("22424037001".equals(sim)){ + CompanyName = "磐石市富太镇鑫悦晟供热处"; + HeatName = "富太锅炉房"; + }else if("22424038001".equals(sim)){ + CompanyName = "磐石市日兴物业有限公司"; + HeatName = "呼兰锅炉房"; + }else if("22424039001".equals(sim)){ + CompanyName = "磐石市红宇热力有限公司"; + HeatName = "红旗岭锅炉房"; + }else if("22424040001".equals(sim)){ + CompanyName = "磐石市会发河物业管理有限责任公司"; + HeatName = "黑石锅炉房"; + }else if("22424041001".equals(sim)){ + CompanyName = "磐石市宇盟物业管理有限公司"; + HeatName = "松山锅炉房"; + } + try{ + if(CompanyName!=null&&!"".equals(CompanyName)&&heatanalysisXz!=null&&!"".equals(heatanalysisXz.getId())){ + log.info("sim:"+sim); + JSONObject jsonObject = new JSONObject(); + JSONObject jsonObject2 = new JSONObject(); + jsonObject2.put("CompanyName", CompanyName);//供热公司名称 + jsonObject2.put("HeatName", HeatName);//热源名称 + jsonObject2.put("DateTime", sdf.format(new Date()));//数据上传时间 + jsonObject2.put("PrimaryFeedTem", heatanalysisXz.getView035());//供水温度 + jsonObject2.put("PrimaryFeedPressure", heatanalysisXz.getView007());//供水压力 + jsonObject2.put("PrimaryReturnTem", heatanalysisXz.getView036());//回水温度 + jsonObject2.put("PrimaryReturnPressure", heatanalysisXz.getView008());//回水压力 + jsonObject2.put("FeedFlow",heatanalysisXz.getView037());//供水瞬时流量 + jsonObject2.put("ReturnFlow", heatanalysisXz.getView040());//供水累计流量 + jsonObject2.put("InstantaneousHeating",heatanalysisXz.getView041());//瞬时热量 + jsonObject2.put("AccumulatedHeating", heatanalysisXz.getView044());//累计热量 jsonObject.put("InParam", jsonObject2); jsonObject.put("RequestType", "normal");//默认填写 jsonObject.put("RequestID","121");//默认填写 @@ -163,7 +265,6 @@ public class HeatingReportJob implements Job { } } } - } public static void uploadData5(String url,String params,String token) throws IOException { diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/HeatanalysisMapper.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/HeatanalysisMapper.java index bcc9a42..1aa85e6 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/HeatanalysisMapper.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/HeatanalysisMapper.java @@ -10,6 +10,7 @@ import java.util.List; public interface HeatanalysisMapper extends BaseMapper { Heatanalysis getHeatOne(Heatanalysis heatanalysis); + Heatanalysis getXzHeatOne(Heatanalysis heatanalysis); Page findPage(Page page, @Param("params") Heatanalysis heatanalysis); void updateType(Heatanalysis heatanalysis); void updateFaultLevel(Heatanalysis heatanalysis); diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/xml/HeatanalysisMapper.xml b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/xml/HeatanalysisMapper.xml index 6f1d80c..919ed68 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/xml/HeatanalysisMapper.xml +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/xml/HeatanalysisMapper.xml @@ -5,10 +5,30 @@ + +