苏州地铁推送修改

whyclxw

2025-05-07 b22e8e7a2d6f6a2998913c381af5ceba9542d79e

 src/main/java/com/whyc/service/BattInfService.java

@@ -204,6 +204,8 @@
            station.setStationName4(battinf.getStationName4());
            station.setStationName5(battinf.getStationName5());
            station.setTogetherFlag(sinfMapper.getMaxTogetherFlag());
            if(battinf.getStationName9()!=null){//苏州地铁标注为几号线地铁线路（3.5.6.7.8）
            }
            stationInfService.insertStation(station);
            battinf.setStationId(stationId);
            battinf.setFBSDeviceId((long) dev_id);
@@ -966,4 +968,55 @@
            return new Response().set(1,false,"改ukey已绑定");
        }
    }
    //插入初始数据
    public void setDefalut( Map<String,Object> map){
        Map<String,Object> mapNum=new HashMap<>();
        mapNum.put("stionNum",0);
        mapNum.put("devNum",0);
        mapNum.put("battNum",0);
        map.put("3",mapNum);
        map.put("5",mapNum);
        map.put("6",mapNum);
        map.put("7",mapNum);
        map.put("8",mapNum);
    }
    //1统计机房个数，设备个数，电池组个数(苏州地铁)
    public Response getAllInfInSz2(Integer userId) {
        Map<String,Object> map=new HashMap<>();
        //setDefalut(map);
        Map<String,Object> allmap=new HashMap<>();
        int stionNum=0;
        int devNum=0;
        int battNum=0;
        try {
            //查询battinf表中所有机房信息
            List<Battinf> list=battInfMapper.getAllInfInSz2(userId);
            Map<String, List<Battinf>> ListMap = list.stream().collect(Collectors.groupingBy(Battinf::getStationName9));
            for (String stationName9 : ListMap.keySet()) {
                Map<String, Object> battInfoMap = new HashMap<>();
                battInfoMap.put("stionNum",0);
                battInfoMap.put("devNum",0);
                battInfoMap.put("battNum",0);
                List<Battinf> name9List=ListMap.get(stationName9);
                Map<String, List<Battinf>> stationMap = name9List.stream().collect(Collectors.groupingBy(Battinf::getStationId));
                battInfoMap.put("stionNum",stationMap.size());
                stionNum+=stationMap.size();
                Map<Long, List<Battinf>> devMap = name9List.stream().collect(Collectors.groupingBy(Battinf::getFBSDeviceId));
                battInfoMap.put("devNum",devMap.size());
                devNum+=devMap.size();
                Map<Integer, List<Battinf>> battMap = name9List.stream().collect(Collectors.groupingBy(Battinf::getBattGroupId));
                battInfoMap.put("battNum",battMap.size());
                map.put(stationName9,battInfoMap);
                battNum+=battMap.size();
            }
            allmap.put("stionNum",stionNum);
            allmap.put("devNum",devNum);
            allmap.put("battNum",battNum);
            map.put("allmap",allmap);
            return new Response<>().setII(1,true,map,"");
        } catch (Exception e) {
            return new Response<>().set(1,false,"");
        }

    }
}