diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/exportapi/api/HomeApi.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/exportapi/api/HomeApi.java index 86200ca..7e9f7b6 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/exportapi/api/HomeApi.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/exportapi/api/HomeApi.java @@ -70,7 +70,7 @@ public class HomeApi { //郊县数量(郊县公司数量) LambdaQueryChainWrapper qw3 = thermalcompanyService.lambdaQuery(); - qw3.eq(Thermalcompany::getRegionType,"城区"); + qw3.eq(Thermalcompany::getRegionType,"郊县"); qw3.eq(Thermalcompany::getDelFlag,"0"); qw3.orderByAsc(Thermalcompany::getId); List thermalcompanyList = qw3.list(); diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/controller/HeatanalysisHistoryController.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/controller/HeatanalysisHistoryController.java index 6dac103..2b5c391 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/controller/HeatanalysisHistoryController.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/controller/HeatanalysisHistoryController.java @@ -89,4 +89,14 @@ public class HeatanalysisHistoryController extends JeecgController getHistoryList(HeatanalysisHistory heatanalysisHistory, HttpServletRequest req) { + return service.getHistoryList(heatanalysisHistory); + } + + @GetMapping(value = "/getJxHistoryList") + public Result getJxHistoryList(HeatanalysisHistory heatanalysisHistory, HttpServletRequest req) { + return service.getJxHistoryList(heatanalysisHistory); + } + } diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/controller/HeatsourcestationController.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/controller/HeatsourcestationController.java index 266e82d..0651eae 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/controller/HeatsourcestationController.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/controller/HeatsourcestationController.java @@ -97,8 +97,10 @@ public class HeatsourcestationController extends JeecgController queryWrapper = QueryGenerator.initQueryWrapper(heatsourcestation, req.getParameterMap(),customeRuleMap); + queryWrapper.eq("del_flag","0"); queryWrapper.orderByAsc("company_id"); queryWrapper.orderByAsc("source_id"); + queryWrapper.orderByAsc("id"); Page page = new Page(pageNo, pageSize); IPage pageList = heatsourcestationService.page(page, queryWrapper); return Result.OK(pageList); 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 ceab39c..c47b5d0 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 @@ -54,8 +54,8 @@ public class Heatanalysis extends JeecgEntity { private Integer view001; // 热力公司 private Integer view002; // 热源站 - private String view003; // 热源所 - private String view004; // 换热站 + private Integer view003; // 热源所 + private Integer view004; // 换热站 @Excel(name = "数据时间", width = 20, format = "yyyy-MM-dd HH:mm:ss") @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") @TableField(updateStrategy = FieldStrategy.NEVER) diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/entity/HeatanalysisHistory.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/entity/HeatanalysisHistory.java index f19627f..0be6a90 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/entity/HeatanalysisHistory.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/entity/HeatanalysisHistory.java @@ -37,7 +37,7 @@ public class HeatanalysisHistory extends JeecgEntity { private Integer view001; // 热力公司 private Integer view002; // 热源站 private String view003; // 热源所 - private String view004; // 换热站 + private Integer view004; // 换热站 @Excel(name = "数据时间", width = 20, format = "yyyy-MM-dd HH:mm:ss") @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") @TableField(updateStrategy = FieldStrategy.NEVER) 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 17d9be4..73b4e6d 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 @@ -62,19 +62,20 @@ public class FlowanalysisJob implements Job { 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(); +// QueryWrapper heatanalysisQueryWrapper = new QueryWrapper<>(); +// heatanalysisQueryWrapper.eq("view031",sn); +// heatanalysisQueryWrapper.last("limit 1"); +// Heatanalysis heatanalysis = heatanalysisService.getOne(heatanalysisQueryWrapper); + Heatanalysis heatanalysis = new Heatanalysis(); +// 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; - } +// if(StringUtils.equals(view032,view032_old)){ +// log.info("--------数据重复---------"); +// continue; +// } String view033 = dataObject.getStr("ID"); String view034 = dataObject.getStr("valid"); String view035 = dataObject.getStr("gswd"); @@ -129,7 +130,7 @@ public class FlowanalysisJob implements Job { heatanalysis.setView047(view047); heatanalysisService.exeWater(heatanalysis); - } +// } } } catch (Exception e) { diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/HeatanalysisHistoryMapper.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/HeatanalysisHistoryMapper.java index 00cd908..9721371 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/HeatanalysisHistoryMapper.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/HeatanalysisHistoryMapper.java @@ -11,4 +11,5 @@ public interface HeatanalysisHistoryMapper extends BaseMapper findPage(Page page, @Param("params") HeatanalysisHistory heatanalysisHistory); Page findJxPage(Page page, @Param("params") HeatanalysisHistory heatanalysisHistory); List findHistoryList(HeatanalysisHistory heatanalysisHistory); + List getJxHistoryList(HeatanalysisHistory heatanalysisHistory); } diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/xml/HeatanalysisHistoryMapper.xml b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/xml/HeatanalysisHistoryMapper.xml index ab0e98a..2bb4806 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/xml/HeatanalysisHistoryMapper.xml +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/heating/mapper/xml/HeatanalysisHistoryMapper.xml @@ -38,17 +38,38 @@ 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" + a.report_type AS "reportType", + a.region_type as "regionType" FROM ${params.tableName} a - a.region_type = #{params.regionType} And a.del_flag = '0' + + AND a.region_type = #{params.regionType} + AND a.view001 = #{params.view001} @@ -78,7 +99,7 @@ ) t - ORDER BY view001 asc ,view002 asc,view004 asc,DATATIME DESC + ORDER BY view001 asc ,view002 asc,view004 asc,datatime DESC + + 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 ff119d1..f27a3e5 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 @@ -208,6 +208,24 @@ 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", @@ -216,6 +234,7 @@ a.del_flag AS "delFlag", a.report_type AS "reportType", a.is_extract AS "isExtract", + a.region_type as "regionType", -- b.company_name AS "view001Name", -- c.source_name AS "view002Name", -- d.name AS "view003Name", @@ -268,10 +287,10 @@ count(distinct replace(e.station_name,SUBSTR(e.station_name,instr(e.station_name,'('),10),'')) as VIEW006 FROM BL_HEATANALYSIS a LEFT JOIN BL_thermalcompany b ON b.id=a.view001 - LEFT JOIN BL_heatsourcestation e ON e.id=a.view004 and e.id != 20 + LEFT JOIN BL_heatsourcestation e ON e.id=a.view004 where a.del_flag = '0' group by view001,view001Name - ORDER BY A.view001 DESC + ORDER BY A.view001 ASC