浏览代码

市自来水更新:
1.更改泵组优化接口调用预测时间增加未来一天
2.增加营业片区小时实际用水量数据定时任务
3.更改预测的组织机构条件范围查新
4.更改营业片区预测插值bug和原始数据采集bug
5.更改小时水量预测查询接口,支持查询营业所数据
6.优化数据库链接回收机制
7.15分钟预测值查询接口支持营业所查询

1037015548@qq.com 2 周之前
父节点
当前提交
5ae763fa59

+ 9 - 0
src/main/java/com/shkpr/service/aimodelpower/bizmgr/KprAimWaterCollecationBizFun.java

@@ -851,6 +851,15 @@ public class KprAimWaterCollecationBizFun {
                         String zoneName = zoneNameOpt.get().toString();
                         childList.add(zoneName);
                     }
+                }else if(level==-1){
+                    List<Map<String,Object>> orgConfig = getWaterTapWaterApi().getOrgConfig(false,0,0,"");
+                    Map<String,Object> objectMap = orgConfig.stream()
+                            .filter(mapX -> Objects.equals(jpTbMHourWater.getOrgId(), mapX.get("org_id")))
+                            .findFirst().orElse(null);
+                    if(objectMap!=null) {
+                        childList.add(objectMap.get("org_name").toString());
+                        childIdList.add(objectMap.get("org_id").toString());
+                    }
                 }
                 //TODO 开始查询
                 // 结果集合,存储 childList 对应的组织机构 ID

+ 2 - 1
src/main/java/com/shkpr/service/aimodelpower/controllerapi/WaterCollecationController.java

@@ -438,7 +438,8 @@ public class WaterCollecationController {
                 Map<String, Map<String, List<String>>> result = getWaterWorks();
                 Map<String, String> workZonIds = getWaterZoneIds();
                 if (!MapUtils.isEmpty(result) && !MapUtils.isEmpty(workZonIds)) {
-                    int level = findOrgLevel(result, KprAimWaterCollecationBizFun.findOrgNameByOrgId(workZonIds, oJsonParam.getOrgId()).get().toString());
+                    String orgId = KprAimWaterCollecationBizFun.findOrgNameByOrgId(workZonIds, oJsonParam.getOrgId()).orElse(null);
+                    int level = findOrgLevel(result, orgId);
                     oRes = KprAimWaterCollecationBizFun.selectTbMinutesWaterList(oJsonParam, level, result, workZonIds);
                 }
             }