乡镇数据上传省平台,乡镇配置增加二维码上传

This commit is contained in:
曹磊 2025-10-09 17:53:32 +08:00
parent fd952f9f3b
commit 020feaf7eb
6 changed files with 160 additions and 30 deletions

View File

@ -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<String> 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<String> 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 {

View File

@ -10,6 +10,7 @@ import java.util.List;
public interface HeatanalysisMapper extends BaseMapper<Heatanalysis> {
Heatanalysis getHeatOne(Heatanalysis heatanalysis);
Heatanalysis getXzHeatOne(Heatanalysis heatanalysis);
Page<Heatanalysis> findPage(Page<Heatanalysis> page, @Param("params") Heatanalysis heatanalysis);
void updateType(Heatanalysis heatanalysis);
void updateFaultLevel(Heatanalysis heatanalysis);

View File

@ -5,10 +5,30 @@
<select id="getHeatOne" resultType="org.jeecg.modules.heating.entity.Heatanalysis">
SELECT
id,
VIEW005,
VIEW006,
VIEW007,
VIEW008
view005 AS "view005",
view006 AS "view006",
view007 AS "view007",
view008 AS "view008"
FROM
BL_HEATANALYSIS
WHERE
sim = #{sim}
ORDER BY
DATATIME DESC
LIMIT 1
</select>
<select id="getXzHeatOne" resultType="org.jeecg.modules.heating.entity.Heatanalysis">
SELECT
id,
view035 AS "view035",
view036 AS "view036",
view007 AS "view007",
view008 AS "view008",
view037 AS "view037",
view040 AS "view040",
view041 AS "view041",
view044 AS "view044"
FROM
BL_HEATANALYSIS
WHERE

View File

@ -10,6 +10,7 @@ import java.util.List;
public interface HeatanalysisService extends JeecgService<Heatanalysis> {
Heatanalysis getHeatOne(Heatanalysis heatanalysis);
Heatanalysis getXzHeatOne(Heatanalysis heatanalysis);
IPage<Heatanalysis> findPage(Page<Heatanalysis> page,Heatanalysis heatanalysis);
void updateType(Heatanalysis heatanalysis);
void updateFaultLevel(Heatanalysis heatanalysis);

View File

@ -22,6 +22,10 @@ public class HeatanalysisServiceImpl extends JeecgServiceImpl<HeatanalysisMapper
return baseMapper.getHeatOne(heatanalysis);
}
public Heatanalysis getXzHeatOne(Heatanalysis heatanalysis) {
return baseMapper.getXzHeatOne(heatanalysis);
}
public IPage<Heatanalysis> findPage(Page<Heatanalysis> page,Heatanalysis heatanalysis){
return baseMapper.findPage(page,heatanalysis);
}

View File

@ -82,4 +82,7 @@ public class BlWaterFlowConfig implements Serializable {
/**地区类型*/
@Excel(name = "地区类型", width = 15)
private java.lang.String regionType;
/**二维码*/
@Excel(name = "二维码", width = 15)
private java.lang.String qrCode;
}