yangjun
/
panshi_java_new
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

郊县管网监测指标

This commit is contained in:
1378012178@qq.com 2025-08-28 10:35:50 +08:00
parent bd52ac30c5
commit ceac0d6996
8 changed files with 316 additions and 147 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/controller/HeatanalysisHistoryController.java
View File

@ -54,6 +54,36 @@ public class HeatanalysisHistoryController extends JeecgController<HeatanalysisH
return Result.ok(pageList); return Result.ok(pageList);
} }
/**
* 分页列表查询
*
* @param heatanalysisHistory
* @param pageNo
* @param pageSize
* @param req
* @return
*/
@GetMapping(value = "/jxpage")
public Result<?> queryJxPageList(HeatanalysisHistory heatanalysisHistory, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
@RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize,
@RequestParam(name = "SDateStr", required = false) String SDateStr,
@RequestParam(name = "EDateStr", required = false) String EDateStr, HttpServletRequest req) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
try {
if(StringUtils.isNotBlank(SDateStr)){
heatanalysisHistory.setSDate(sdf.parse(SDateStr));
}
if(StringUtils.isNotBlank(EDateStr)){
heatanalysisHistory.setEDate(sdf.parse(EDateStr));
}
} catch (ParseException e) {
e.printStackTrace();
}
Page<HeatanalysisHistory> page = new Page<HeatanalysisHistory>(pageNo, pageSize);
IPage<HeatanalysisHistory> pageList = service.findJxPage(page, heatanalysisHistory);
return Result.ok(pageList);
}
@GetMapping(value = "/queryHistoryList") @GetMapping(value = "/queryHistoryList")
public Result<?> queryHistoryList(HeatanalysisHistory heatanalysisHistory, HttpServletRequest req) { public Result<?> queryHistoryList(HeatanalysisHistory heatanalysisHistory, HttpServletRequest req) {
return service.findHistoryList(heatanalysisHistory); return service.findHistoryList(heatanalysisHistory);

30
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/entity/Heatanalysis.java
View File

@ -100,22 +100,22 @@ public class Heatanalysis extends JeecgEntity {
private Integer reportType;//数据采集类型 1设备自动上报 2定时模拟 private Integer reportType;//数据采集类型 1设备自动上报 2定时模拟
private String fromFlow; // 温度是否从流量取 0否 1是 private String fromFlow; // 温度是否从流量取 0否 1是
private String view031; // 流量设备SN，view031到view047全是从流量表上获取的数据 private String view031; // 流量设备SN，view031到view047全是从流量表上获取的数据
private String view032; // 流量数据上报时间 private Date view032; // 流量数据上报时间
private String view033; // 仪表ID private String view033; // 仪表ID
private String view034; // 数据有效标识 0无效 1有效 private int view034; // 数据有效标识 0无效 1有效
private String view035; // 供水温度 private Double view035; // 供水温度
private String view036; // 回水温度 private Double view036; // 回水温度
private String view037; // 瞬时流量 private Double view037; // 瞬时流量
private String view038; // 正累积流量 private Double view038; // 正累积流量
private String view039; // 负累积流量 private Double view039; // 负累积流量
private String view040; // 净累积流量 private Double view040; // 净累积流量
private String view041; // 瞬时热量 private Double view041; // 瞬时热量
private String view042; // 正累积热量 private Double view042; // 正累积热量
private String view043; // 负累积热量 private Double view043; // 负累积热量
private String view044; // 净累积热量 private Double view044; // 净累积热量
private String view045; // 流体速度 private Double view045; // 流体速度
private String view046; // 流量因子 private Double view046; // 流量因子
private String view047; // 热量因子 private Double view047; // 热量因子
private Integer isExtract;//是否抽取 0否 1是 private Integer isExtract;//是否抽取 0否 1是
/**地区类型*/ /**地区类型*/
@Excel(name = "地区类型", width = 15) @Excel(name = "地区类型", width = 15)

19
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/entity/HeatanalysisHistory.java
View File

@ -80,6 +80,25 @@ public class HeatanalysisHistory extends JeecgEntity {
private String sim; // sim private String sim; // sim
private String code; // code private String code; // code
private Integer reportType;//数据采集类型 1设备自动上报 2定时模拟 private Integer reportType;//数据采集类型 1设备自动上报 2定时模拟
private String fromFlow; // 温度是否从流量取 0否 1是
private String view031; // 流量设备SN，view031到view047全是从流量表上获取的数据
private Date 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 Integer isExtract;//是否抽取 0否 1是
/**地区类型*/ /**地区类型*/
@Excel(name = "地区类型", width = 15) @Excel(name = "地区类型", width = 15)
@ApiModelProperty(value = "地区类型") @ApiModelProperty(value = "地区类型")

265
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/job/FlowanalysisJob.java
View File

@ -32,161 +32,162 @@ import java.io.IOException;
import java.io.InputStreamReader; import java.io.InputStreamReader;
import java.net.HttpURLConnection; import java.net.HttpURLConnection;
import java.net.URL; import java.net.URL;
/** /**
* 发送消息任务 * 发送消息任务
*
* @author: jeecg-boot * @author: jeecg-boot
*/ */
@Slf4j @Slf4j
public class FlowanalysisJob implements Job { public class FlowanalysisJob implements Job {
@Autowired @Autowired
private HeatanalysisService heatanalysisService; private HeatanalysisService heatanalysisService;
@Autowired @Autowired
private IBlWaterFlowConfigService WaterFlowConfigService; private IBlWaterFlowConfigService WaterFlowConfigService;
@Override @Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
log.info(String.format("获取热量水流量数据 ! 时间:" + DateUtils.getTimestamp())); log.info(String.format("获取热量水流量数据 ! 时间:" + DateUtils.getTimestamp()));
QueryWrapper<BlWaterFlowConfig> queryWrapper = new QueryWrapper<>(); QueryWrapper<BlWaterFlowConfig> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("del_flag","0"); queryWrapper.eq("del_flag", "0");
List<BlWaterFlowConfig> list = WaterFlowConfigService.list(queryWrapper); List<BlWaterFlowConfig> list = WaterFlowConfigService.list(queryWrapper);
for(BlWaterFlowConfig config : list){ for (BlWaterFlowConfig config : list) {
try{ try {
String sn = config.getSn(); String sn = config.getSn();
String json = getWebInfo(sn); String json = getWebInfo(sn);
if(StringUtils.equals(json,"false")) continue; if (StringUtils.equals(json, "false")) continue;
JSONObject jsonObject = new JSONObject(json); JSONObject jsonObject = new JSONObject(json);
log.info("jsonObject:"+jsonObject); log.info("jsonObject:" + jsonObject);
String success = jsonObject.getStr("success"); String success = jsonObject.getStr("success");
if(StringUtils.equals(success,"true")){ if (StringUtils.equals(success, "true")) {
QueryWrapper<Heatanalysis> heatanalysisQueryWrapper = new QueryWrapper<>(); QueryWrapper<Heatanalysis> heatanalysisQueryWrapper = new QueryWrapper<>();
heatanalysisQueryWrapper.eq("view031",sn); heatanalysisQueryWrapper.eq("view031", sn);
heatanalysisQueryWrapper.last("limit 1"); heatanalysisQueryWrapper.last("limit 1");
Heatanalysis heatanalysis = heatanalysisService.getOne(heatanalysisQueryWrapper); Heatanalysis heatanalysis = heatanalysisService.getOne(heatanalysisQueryWrapper);
if(heatanalysis != null){ if (heatanalysis != null) {
String view032_old = heatanalysis.getView032(); Date view032_old = heatanalysis.getView032();
String data = jsonObject.getStr("data"); String data = jsonObject.getStr("data");
JSONObject dataObject = new JSONObject(data); JSONObject dataObject = new JSONObject(data);
String view032 = dataObject.getStr("logat"); String view032 = dataObject.getStr("logat");
if(StringUtils.equals(view032,view032_old)){ if (StringUtils.equals(view032, new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(view032_old))) {
log.info("--------数据重复---------"); log.info("--------数据重复---------");
continue; continue;
} }
String view033 = dataObject.getStr("ID"); String view033 = dataObject.getStr("ID");
String view034 = dataObject.getStr("valid"); String view034 = dataObject.getStr("valid");
String view035 = dataObject.getStr("gswd"); String view035 = dataObject.getStr("gswd");
String view036 = dataObject.getStr("hswd"); String view036 = dataObject.getStr("hswd");
String view037 = dataObject.getStr("flowRate"); String view037 = dataObject.getStr("flowRate");
String view037_2 = dataObject.getStr("ssll"); String view037_2 = dataObject.getStr("ssll");
String view038 = dataObject.getStr("pflowAccumulator"); String view038 = dataObject.getStr("pflowAccumulator");
String view038_2 = dataObject.getStr("zljll"); String view038_2 = dataObject.getStr("zljll");
String view039 = dataObject.getStr("nflowAccumulator"); String view039 = dataObject.getStr("nflowAccumulator");
String view039_2 = dataObject.getStr("fljll"); String view039_2 = dataObject.getStr("fljll");
String view040 = dataObject.getStr("netflowAccumulator"); String view040 = dataObject.getStr("netflowAccumulator");
String view040_2 = dataObject.getStr("jljll"); String view040_2 = dataObject.getStr("jljll");
String view041 = dataObject.getStr("ssrl"); String view041 = dataObject.getStr("ssrl");
String view042 = dataObject.getStr("zljrl"); String view042 = dataObject.getStr("zljrl");
String view043 = dataObject.getStr("fljrl"); String view043 = dataObject.getStr("fljrl");
String view044 = dataObject.getStr("jljrl"); String view044 = dataObject.getStr("jljrl");
String view045 = dataObject.getStr("ltsd"); String view045 = dataObject.getStr("ltsd");
String view046 = dataObject.getStr("n"); String view046 = dataObject.getStr("n");
String view047 = dataObject.getStr("m"); String view047 = dataObject.getStr("m");
heatanalysis.setView031(sn); heatanalysis.setView031(sn);
heatanalysis.setView032(view032); heatanalysis.setView032(new Date(view032));
heatanalysis.setView033(view033); heatanalysis.setView033(view033);
heatanalysis.setView034(view034); heatanalysis.setView034(Integer.parseInt(view034));
heatanalysis.setView035(view035); heatanalysis.setView035(Double.parseDouble(view035));
heatanalysis.setView036(view036); heatanalysis.setView036(Double.parseDouble(view036));
if (StringUtils.isEmpty(view037)){ if (StringUtils.isEmpty(view037)) {
heatanalysis.setView037(view037_2); heatanalysis.setView037(Double.parseDouble(view037_2));
}else{ } else {
heatanalysis.setView037(view037); heatanalysis.setView037(Double.parseDouble(view037));
} }
if (StringUtils.isEmpty(view038)){ if (StringUtils.isEmpty(view038)) {
heatanalysis.setView038(view038_2); heatanalysis.setView038(Double.parseDouble(view038_2));
}else{ } else {
heatanalysis.setView038(view038); heatanalysis.setView038(Double.parseDouble(view038));
} }
if (StringUtils.isEmpty(view039)){ if (StringUtils.isEmpty(view039)) {
heatanalysis.setView039(view039_2); heatanalysis.setView039(Double.parseDouble(view039_2));
}else{ } else {
heatanalysis.setView039(view039); heatanalysis.setView039(Double.parseDouble(view039));
} }
if (StringUtils.isEmpty(view040)){ if (StringUtils.isEmpty(view040)) {
heatanalysis.setView040(view040_2); heatanalysis.setView040(Double.parseDouble(view040_2));
}else{ } else {
heatanalysis.setView040(view040); heatanalysis.setView040(Double.parseDouble(view040));
} }
heatanalysis.setView041(view041); heatanalysis.setView041(Double.parseDouble(view041));
heatanalysis.setView042(view042); heatanalysis.setView042(Double.parseDouble(view042));
heatanalysis.setView043(view043); heatanalysis.setView043(Double.parseDouble(view043));
heatanalysis.setView044(view044); heatanalysis.setView044(Double.parseDouble(view044));
heatanalysis.setView045(view045); heatanalysis.setView045(Double.parseDouble(view045));
heatanalysis.setView046(view046); heatanalysis.setView046(Double.parseDouble(view046));
heatanalysis.setView047(view047); heatanalysis.setView047(Double.parseDouble(view047));
heatanalysisService.exeWater(heatanalysis); heatanalysisService.exeWater(heatanalysis);
} }
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); 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);
public static String getWebInfo(String sn) { // 2. 打开连接，转换为HttpURLConnection
String result = "false"; HttpURLConnection connection = (HttpURLConnection) url.openConnection();
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 // 3. 设置请求方法为GET
HttpURLConnection connection = (HttpURLConnection) url.openConnection(); connection.setRequestMethod("GET");
// 3. 设置请求方法为GET // 4. 可选：设置请求头（例如，指定期望的响应内容类型）
connection.setRequestMethod("GET"); connection.setRequestProperty("Accept", "application/json");
// 4. 可选：设置请求头（例如，指定期望的响应内容类型） // 5. 获取响应代码
connection.setRequestProperty("Accept", "application/json"); int responseCode = connection.getResponseCode();
System.out.println("Response Code: " + responseCode);
// 5. 获取响应代码 // 6. 如果响应成功（200 OK），读取响应体
int responseCode = connection.getResponseCode(); if (responseCode == HttpURLConnection.HTTP_OK) {
System.out.println("Response Code: " + responseCode); // 使用BufferedReader读取输入流
BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
String inputLine;
StringBuilder response = new StringBuilder();
// 6. 如果响应成功（200 OK），读取响应体 while ((inputLine = in.readLine()) != null) {
if (responseCode == HttpURLConnection.HTTP_OK) { response.append(inputLine);
// 使用BufferedReader读取输入流 }
BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream())); in.close(); // 关闭流
String inputLine;
StringBuilder response = new StringBuilder();
while ((inputLine = in.readLine()) != null) { // 打印响应结果
response.append(inputLine); log.info(String.format("获取热量水流量数据 - Response Body:" + response.toString()));
} result = response.toString();
in.close(); // 关闭流 } else {
log.error(String.format("获取热量水流量数据 - GET request failed."));
result = "false";
}
// 打印响应结果 // 7. 断开连接
log.info(String.format("获取热量水流量数据 - Response Body:" + response.toString())); connection.disconnect();
result = response.toString();
} else {
log.error(String.format("获取热量水流量数据 - GET request failed."));
result = "false";
}
// 7. 断开连接 } catch (IOException e) {
connection.disconnect(); e.printStackTrace();
result = "false";
} catch (IOException e) { }
e.printStackTrace(); return result;
result = "false"; }
}
return result;
}
} }

1
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/HeatanalysisHistoryMapper.java
View File

@ -9,5 +9,6 @@ import java.util.List;
public interface HeatanalysisHistoryMapper extends BaseMapper<HeatanalysisHistory> { public interface HeatanalysisHistoryMapper extends BaseMapper<HeatanalysisHistory> {
Page<HeatanalysisHistory> findPage(Page<HeatanalysisHistory> page, @Param("params") HeatanalysisHistory heatanalysisHistory); Page<HeatanalysisHistory> findPage(Page<HeatanalysisHistory> page, @Param("params") HeatanalysisHistory heatanalysisHistory);
Page<HeatanalysisHistory> findJxPage(Page<HeatanalysisHistory> page, @Param("params") HeatanalysisHistory heatanalysisHistory);
List<HeatanalysisHistory> findHistoryList(HeatanalysisHistory heatanalysisHistory); List<HeatanalysisHistory> findHistoryList(HeatanalysisHistory heatanalysisHistory);
} }

97
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/xml/HeatanalysisHistoryMapper.xml
View File

@ -81,6 +81,103 @@
ORDER BY view001 asc ,view002 asc,view004 asc,DATATIME DESC ORDER BY view001 asc ,view002 asc,view004 asc,DATATIME DESC
</select> </select>
<select id="findJxPage" resultType="org.jeecg.modules.heating.entity.HeatanalysisHistory">
select * from (
SELECT
a.id AS "id",
a.view001 AS "view001",
a.view002 AS "view002",
a.view003 AS "view003",
a.view004 AS "view004",
a.datatime AS "datatime",
a.caveat AS "caveat",
a.view005 AS "view005",
a.view006 AS "view006",
a.view007 AS "view007",
a.view008 AS "view008",
a.view009 AS "view009",
a.view010 AS "view010",
a.view011 AS "view011",
a.view012 AS "view012",
a.view013 AS "view013",
a.view014 AS "view014",
a.view015 AS "view015",
a.view016 AS "view016",
a.view017 AS "view017",
a.view018 AS "view018",
a.view019 AS "view019",
a.view020 AS "view020",
a.view021 AS "view021",
a.view022 AS "view022",
a.view023 AS "view023",
a.view024 AS "view024",
a.view025 AS "view025",
a.view026 AS "view026",
a.view027 AS "view001Name",
a.view028 AS "view002Name",
a.view029 AS "view003Name",
a.view030 AS "view004Name",
a.from_flow AS "fromFlow",
a.view031 AS "view031",
a.view032 AS "view032",
a.view033 AS "view033",
a.view034 AS "view034",
a.view035 AS "view035",
a.view036 AS "view036",
a.view037 AS "view037",
a.view038 AS "view038",
a.view039 AS "view039",
a.view040 AS "view040",
a.view041 AS "view041",
a.view042 AS "view042",
a.view043 AS "view043",
a.view044 AS "view044",
a.view045 AS "view045",
a.view046 AS "view046",
a.view047 AS "view047",
a.sim AS "sim",
a.create_by AS "createBy.id",
a.create_date AS "createDate",
a.update_by AS "updateBy.id",
a.update_date AS "updateDate",
a.del_flag AS "delFlag",
a.report_type AS "reportType"
FROM ${params.tableName} a
<where>
a.region_type = #{params.regionType}
And a.del_flag = '0'
<if test="params.view001 != null and params.view001 != ''">
AND a.view001 = #{params.view001}
</if>
<if test="params.view002 != null and params.view002 != ''">
AND a.view002 = #{params.view002}
</if>
<if test="params.view004 != null and params.view004 != '' and params.view004 != -1">
AND a.view004 = #{params.view004}
</if>
<if test="params.view004 != null and params.view004 != '' and params.view004 == -1">
AND a.view004 is null
</if>
<if test="params.SDate != null">
AND a.view032 >= #{params.SDate}
</if>
<if test="params.EDate != null">
AND a.view032 &lt;= #{params.EDate}
</if>
<if test="params.caveat != null">
AND a.caveat = #{params.caveat}
</if>
<if test="params.reportType != null">
AND a.report_type = #{params.reportType}
</if>
<if test="params.sim != null and params.sim != ''">
AND a.sim = #{params.sim}
</if>
</where>
) t
ORDER BY view001 asc ,view002 asc,view004 asc,DATATIME DESC
</select>
<select id="findHistoryList" resultType="org.jeecg.modules.heating.entity.HeatanalysisHistory"> <select id="findHistoryList" resultType="org.jeecg.modules.heating.entity.HeatanalysisHistory">
select * from ( select * from (
SELECT SELECT

1
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/service/HeatanalysisHistoryService.java
View File

@ -9,5 +9,6 @@ import java.util.List;
public interface HeatanalysisHistoryService extends JeecgService<HeatanalysisHistory> { public interface HeatanalysisHistoryService extends JeecgService<HeatanalysisHistory> {
IPage<HeatanalysisHistory> findPage(Page<HeatanalysisHistory> page,HeatanalysisHistory heatanalysisHistory); IPage<HeatanalysisHistory> findPage(Page<HeatanalysisHistory> page,HeatanalysisHistory heatanalysisHistory);
IPage<HeatanalysisHistory> findJxPage(Page<HeatanalysisHistory> page,HeatanalysisHistory heatanalysisHistory);
Result<?> findHistoryList(HeatanalysisHistory heatanalysisHistory); Result<?> findHistoryList(HeatanalysisHistory heatanalysisHistory);
} }

20
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/service/impl/HeatanalysisHistoryServiceImpl.java
View File

@ -45,6 +45,26 @@ public class HeatanalysisHistoryServiceImpl extends JeecgServiceImpl<Heatanalysi
return baseMapper.findPage(page,heatanalysisHistory); return baseMapper.findPage(page,heatanalysisHistory);
} }
public IPage<HeatanalysisHistory> findJxPage(Page<HeatanalysisHistory> page,HeatanalysisHistory heatanalysisHistory){
Date sDate = heatanalysisHistory.getSDate();
String sDateStr = "";
SimpleDateFormat sdf= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
if(sDate!=null){
sDateStr = sdf.format(sDate);
}else{
sDateStr = sdf.format(new Date());
heatanalysisHistory.setSDate(sDate);
}
String tableName = "bl_heatanalysis_"+sDateStr.substring(2, 4)+sDateStr.substring(5, 7);
heatanalysisHistory.setTableName(tableName);
Date eDate = heatanalysisHistory.getEDate();
if(eDate==null){
eDate = new Date();
heatanalysisHistory.setEDate(eDate);
}
return baseMapper.findJxPage(page,heatanalysisHistory);
}
public Result<?> findHistoryList(HeatanalysisHistory heatanalysisHistory){ public Result<?> findHistoryList(HeatanalysisHistory heatanalysisHistory){
Map<String,Object> map = new HashMap<>(); Map<String,Object> map = new HashMap<>();
SimpleDateFormat dayFormat = new SimpleDateFormat("yyyy-MM-dd"); SimpleDateFormat dayFormat = new SimpleDateFormat("yyyy-MM-dd");