修改告警阈值重启线程

whyclxw

2024-04-28 b25b814a949d2065a61fd3167206ffb51a57af65

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

@@ -82,6 +82,9 @@
    @Autowired(required = false)
    private BaoJiGroupBattGroupMapper bjBattMapper;

    @Resource
    private RessetStationService ressetStationService;

    //查询最大的自增标识同一机房的标识
    public int getMaxTogetherFlag() {
        int togetherFlag = mapper.getMaxTogetherFlag();
@@ -142,6 +145,8 @@
        mapInfo.setLatitude(stationInf.getStationLatitude());
        mapInfo.setStationName3(stationInf.getStationName3());
        mapMapper.insert(mapInfo);*/
        /*添加机房设置默认值*/
        ressetStationService.setDefaultRessetStation(stationId);
        return new Response().set(1, flag > 0, flag > 0 ? "插入站点成功" : "插入站点失败");
    }

@@ -149,45 +154,49 @@
    @Transactional
    public Response updateName(String stationName, String stationName1, String stationName2, String stationName3, String stationName4, String stationName5
            , String stationIdTogether, String stationId) {
        UpdateWrapper wrapper = new UpdateWrapper();
        wrapper.eq("stationId", stationId);

        UpdateWrapper sinfWrapper = new UpdateWrapper();
        sinfWrapper.eq("stationId", stationId);
        if (stationName != null && !stationName.isEmpty()) {
        UpdateWrapper pinfWrapper = new UpdateWrapper();
        pinfWrapper.eq("stationId", stationId);

        QueryWrapper wrapperZj = new QueryWrapper();
        wrapperZj.eq("stationId", stationId);
        wrapperZj.last(" limit 1");

        StationInf sinfZj = mapper.selectOne(wrapperZj);
        String name=stationName1+"-"+stationName2+"-"+stationName5+"-"+stationName3+"-"+sinfZj.getStationName4();
        sinfWrapper.set("stationName", name);
        /*if (stationName != null && !stationName.isEmpty()) {
            wrapper.set("stationName", stationName);
            sinfWrapper.set("stationName", stationName);
        }
        }*/
        if (stationName1 != null && !stationName1.isEmpty()) {
            wrapper.set("stationName1", stationName1);
            sinfWrapper.set("stationName1", stationName1);
            pinfWrapper.set("stationName1", stationName1);
        }
        if (stationName2 != null && !stationName2.isEmpty()) {
            wrapper.set("stationName2", stationName2);
            sinfWrapper.set("stationName2", stationName2);
            pinfWrapper.set("stationName2", stationName2);
        }
        if (stationName3 != null && !stationName3.isEmpty()) {
            wrapper.set("stationName3", stationName3);
            sinfWrapper.set("stationName3", stationName3);
            pinfWrapper.set("stationName3", stationName3);
        }
        if (stationName4 != null && !stationName4.isEmpty()) {
        /*if (stationName4 != null && !stationName4.isEmpty()) {
            wrapper.set("stationName4", stationName4);
            sinfWrapper.set("stationName4", stationName4);
        }
            pinfWrapper.set("stationName4", stationName4);
        }*/
        if (stationName5 != null && !stationName5.isEmpty()) {
            wrapper.set("stationName5", stationName5);
            sinfWrapper.set("stationName5", stationName5);
            pinfWrapper.set("stationName5", stationName5);
        }
        if (stationIdTogether != null && !stationIdTogether.isEmpty()) {
            //1.先验证同一机房结点信息和电压等级是否一样，若不一样则不允许添加
            QueryWrapper wrapperZj = new QueryWrapper();
            QueryWrapper wrapperGl = new QueryWrapper();
            wrapperZj.eq("stationId", stationId);
            wrapperGl.eq("stationId", stationIdTogether);
            wrapperZj.last(" limit 1");
            wrapperGl.last(" limit 1");

            wrapper.last("limit 1");
            StationInf sinfZj = mapper.selectOne(wrapperZj);
            StationInf sinfGl = mapper.selectOne(wrapperGl);
            if (sinfZj.getNodeStation() != sinfGl.getNodeStation()) {
                return new Response().set(1, false, "设置同一站点时,两站点节点属性不一致");
@@ -213,13 +222,28 @@
        int flag = mapper.update((StationInf) ActionUtil.objeNull, sinfWrapper);
        QueryWrapper queryWrapper = new QueryWrapper();
        queryWrapper.eq("stationId", stationId);
        List listB = binfMapper.selectList(queryWrapper);
        List<Battinf> listB = binfMapper.selectList(queryWrapper);
        //每个电池组修改自己的名字
        if (listB != null && listB.size() > 0) {
            binfMapper.update((Battinf) ActionUtil.objeNull, wrapper);
            for (Battinf binf:listB) {
                UpdateWrapper wrapper = new UpdateWrapper();
                wrapper.eq("stationId", stationId);
                wrapper.set("stationName1", stationName1);
                wrapper.set("stationName2", stationName2);
                wrapper.set("stationName3", stationName3);
                wrapper.set("stationName5", stationName5);
                name=stationName1+"-"+stationName2+"-"+stationName5+"-"+stationName3+"-"+binf.getStationName4();
                wrapper.set("stationName", name);
                wrapper.eq("FBSDeviceId", binf.getFBSDeviceId());
                wrapper.last("limit 1");
                binfMapper.update((Battinf) ActionUtil.objeNull, wrapper);
            }
        }
        List listP = pinfMapper.selectList(queryWrapper);
        if (listP != null && listP.size() > 0) {
            pinfMapper.update((PowerInf) ActionUtil.objeNull, wrapper);
            name=stationName1+"-"+stationName2+"-"+stationName5+"-"+stationName3+"-";
            pinfWrapper.set("stationName", name);
            pinfMapper.update((PowerInf) ActionUtil.objeNull, pinfWrapper);
        }
        return new Response().set(1, flag > 0, flag > 0 ? "编辑机房名成功" : "编辑机房名失败");
    }