地图定位

lxw

2023-03-14 02fb7f6ba076feee6914a865f713ccb4cdda12e4

地图定位

 src/main/java/com/whyc/controller/StationInfController.java

@@ -84,4 +84,28 @@
    public Response searchFuse() {
        return service.searchFuse();
    }

    @ApiOperation(value = "首页上点击停电站")
    @GetMapping("searchPowerOff")
    public Response searchPowerOff() {
        return service.searchPowerOff();
    }

    @ApiOperation(value = "首页上点击核容放电站")
    @GetMapping("searchCheckCapDischarge")
    public Response searchCheckCapDischarge() {
        return service.searchCheckCapDischarge();
    }

    @ApiOperation(value = "首页上点击容量不足站")
    @GetMapping("searchCapAlarm")
    public Response searchCapAlarm() {
        return service.searchCapAlarm();
    }

    @ApiOperation(value = "首页上点击电池损坏站")
    @GetMapping("searCapChange")
    public Response searCapChange() {
        return service.searCapChange();
    }
}

 src/main/java/com/whyc/mapper/BadbattMonMapper.java

@@ -39,4 +39,10 @@

    //判断是否落后
    int judgeBatt(int battGroupId);

    //首页上点击电池损坏站
    List<BadbattMon> searCapChange(int userId, float capChange);

    //首页上点击容量不足站
    List<BadbattMon> searchCapAlarm(int userId, float capAlarm, float capChange);
}

 src/main/java/com/whyc/mapper/Fbs9100StateMapper.java

@@ -5,15 +5,22 @@

import java.util.List;

public interface Fbs9100StateMapper extends CustomMapper<Fbs9100State>{
public interface Fbs9100StateMapper extends CustomMapper<Fbs9100State> {
        List<Fbs9100State> searchByCondition(@Param("devErrcommcount") int devErrcommcount, @Param("uId") int uId);

        List<Fbs9100State> getList(Integer deviceId, Integer workState, Long uId);

        List<Fbs9100State> search6185NuclearCap(int uId);

        //第三方接口太供30楼
        List<Fbs9100State> getRealtime(@Param("deviceIds")List deviceIds);
        List<Fbs9100State> getRealtime(@Param("deviceIds") List deviceIds);

        //首页获取停电机房和核容放电机房
        List<Fbs9100State> getStateList(int userId);

        //首页上点击停电站
        List<Fbs9100State> searchPowerOff(String uId);

        //首页上点击核容放电站
        List<Fbs9100State> searchCheckCapDischarge(String uId);
}

 src/main/java/com/whyc/pojo/BadbattMon.java

@@ -46,4 +46,7 @@

    @TableField(exist = false)
    private String battProducer;

    @TableField(exist = false)
    private String stationName;
}

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

@@ -191,8 +191,19 @@
    }

    public List<Fbs9100State> getStateList(int userId) {
        QueryWrapper<Fbs9100State> wrapper = Wrappers.query();
        wrapper.select("dev_workstate");
        return mapper.selectList(wrapper);
        List<Fbs9100State> list = mapper.getStateList(userId);
        return list;
    }

    //首页上点击停电站
    public List<Fbs9100State> searchPowerOff(String uId) {
        List<Fbs9100State> list = mapper.searchPowerOff(uId);
        return list;
    }

    //首页上点击核容放电站
    public List<Fbs9100State> searchCheckCapDischarge(String uId) {
        List<Fbs9100State> list = mapper.searchCheckCapDischarge(uId);
        return list;
    }
}

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

@@ -647,4 +647,50 @@
        List<PwrdevAcdcdata> list = acdcMapper.searchFuse(uId);
        return new Response().setII(1, list.size() > 0, list, "首页上点击整流器故障");
    }

    //首页上点击停电站
    public Response searchPowerOff() {
        String uId = String.valueOf(ActionUtil.getUser().getUId());
        List<Fbs9100State> list = fbs9100StateService.searchPowerOff(uId);
        return new Response().setII(1, list.size() > 0, list, "首页上点击停电站");
    }

    //首页上点击核容放电站
    public Response searchCheckCapDischarge() {
        String uId = String.valueOf(ActionUtil.getUser().getUId());
        List<Fbs9100State> list = fbs9100StateService.searchCheckCapDischarge(uId);
        return new Response().setII(1, list.size() > 0, list, "首页上点击核容放电站");
    }

    //首页上点击容量不足站
    public Response searchCapAlarm() {
        int uId = ActionUtil.getUser().getUId().intValue();
        //1.查询劣化(告警)和损坏(更换)的阈值
        QueryWrapper<AlarmParam> alarmWrapper = new QueryWrapper();
        alarmWrapper.and(wrapper -> {
            return wrapper.eq("alm_name", "Batt_Alarm_Type_CapAlarm").or().eq("alm_name", "Batt_Alarm_Type_CapChange");
        });
        alarmWrapper.orderByAsc("alm_id");
        List<AlarmParam> paramList = alarmParamMapper.selectList(alarmWrapper);
        float capAlarm = paramList.get(0).getAlmLowCoe();//劣化参数0.8
        float capChange = paramList.get(1).getAlmLowCoe();//损坏参数0.6
        List<BadbattMon> list = badbattMonMapper.searchCapAlarm(uId, capAlarm, capChange);
        return new Response().setII(1, list.size() > 0, list, "首页上点击容量不足站");
    }

    //首页上点击电池损坏站
    public Response searCapChange() {
        int uId = ActionUtil.getUser().getUId().intValue();
        //1.查询劣化(告警)和损坏(更换)的阈值
        QueryWrapper<AlarmParam> alarmWrapper = new QueryWrapper();
        alarmWrapper.and(wrapper -> {
            return wrapper.eq("alm_name", "Batt_Alarm_Type_CapAlarm").or().eq("alm_name", "Batt_Alarm_Type_CapChange");
        });
        alarmWrapper.orderByAsc("alm_id");
        List<AlarmParam> paramList = alarmParamMapper.selectList(alarmWrapper);
        float capChange = paramList.get(1).getAlmLowCoe();//损坏参数0.6

        List<BadbattMon> list = badbattMonMapper.searCapChange(uId, capChange);
        return new Response().setII(1, list.size() > 0, list, "首页上点击电池损坏站");
    }
}

 src/main/resources/mapper/BadbattMonMapper.xml

@@ -301,4 +301,44 @@
    from web_site.tb_badbatt_mon
    where battgroupid = #{battGroupId}
  </select>
  <select id="searCapChange" resultType="com.whyc.pojo.BadbattMon">
    select tb_badbatt_mon.*,tb_battinf.stationName
    from web_site.tb_badbatt_mon,db_battinf.tb_battinf
    <where>
      real_cap &lt;=stdcap*#{capChange}
      and tb_badbatt_mon.battGroupId=tb_battinf.battGroupId
      and web_site.tb_badbatt_mon.battgroupid in (select distinct db_battinf.tb_battinf.battgroupid
      from db_battinf.tb_battinf,
      db_user.tb_user_battgroup_baojigroup_battgroup,
      db_user.tb_user_battgroup_baojigroup_usr,
      db_user.tb_user_inf
      where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId =
      db_battinf.tb_battinf.BattGroupId
      and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id =
      db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id
      and db_user.tb_user_inf.uid =
      db_user.tb_user_battgroup_baojigroup_usr.uid
      and db_user.tb_user_inf.uid = #{userId})
    </where>
  </select>
  <select id="searchCapAlarm" resultType="com.whyc.pojo.BadbattMon">
    select tb_badbatt_mon.*,tb_battinf.stationName
    from web_site.tb_badbatt_mon,db_battinf.tb_battinf
    <where>
      real_cap >= stdcap * #{capChange} and real_cap &lt;= stdcap * #{capAlarm}
      and tb_badbatt_mon.battGroupId=tb_battinf.battGroupId
      and web_site.tb_badbatt_mon.battgroupid in (select distinct db_battinf.tb_battinf.battgroupid
      from db_battinf.tb_battinf,
      db_user.tb_user_battgroup_baojigroup_battgroup,
      db_user.tb_user_battgroup_baojigroup_usr,
      db_user.tb_user_inf
      where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId =
      db_battinf.tb_battinf.BattGroupId
      and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id =
      db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id
      and db_user.tb_user_inf.uid =
      db_user.tb_user_battgroup_baojigroup_usr.uid
      and db_user.tb_user_inf.uid = #{userId})
    </where>
  </select>
</mapper>

 src/main/resources/mapper/Fbs9100StateMapper.xml

@@ -2,20 +2,25 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.Fbs9100StateMapper">

<!--
fbs9100：op_cmd:0:全部；1：fbs9100,2:fbs9600
dev_errcommcount;0:通讯正常，1：通讯中断，100：全部
-->
    <!--
    fbs9100：op_cmd:0:全部；1：fbs9100,2:fbs9600
    dev_errcommcount;0:通讯正常，1：通讯中断，100：全部
    -->
    <select id="searchByCondition" resultType="com.whyc.pojo.Fbs9100State">
        select tb_fbs9100_state.dev_ip,tb_fbs9100_state.dev_version,record_datetime,tb_fbs9100_state.dev_id,op_cmd,dev_datetime,dev_testtype,dev_testgroupnum,
        select
        tb_fbs9100_state.dev_ip,tb_fbs9100_state.dev_version,record_datetime,tb_fbs9100_state.dev_id,op_cmd,dev_datetime,dev_testtype,dev_testgroupnum,
        dev_workstate,dev_alarmstate,dev_res_test_state,dev_onlinevollow,dev_eachgroup_battsum,dev_captest_onlinevol,dev_captest_groupvol,dev_captest_curr,
        dev_captest_cap,dev_captest_timelong,dev_restest_moncount,dev_restest_monindex,dev_commcount,dev_errcommcount,db_ram_db.tb_fbs9100_state.dev_61850alarms,dev_last_captest_stop_type,elec_comb_acttive_energy,elec_posi_acttive_energy,elec_rever_acttive_energy,elec_active_power,elec_vol,elec_curr,
        db_battinf.tb_battinf.StationName as stationName,db_battinf.tb_battinf.FbsDeviceName as deviceName,
        COUNT(DISTINCT db_battinf.tb_battinf.BattGroupId) as num,
        group_CONCAT(db_ram_db.tb_batt_rtstate.online_vol ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as online_vols,group_CONCAT(db_ram_db.tb_batt_rtstate.group_vol ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as group_vols,group_CONCAT(db_ram_db.tb_batt_rtstate.group_curr ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as group_currs
        group_CONCAT(db_ram_db.tb_batt_rtstate.online_vol ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId separator '/')
        as online_vols,group_CONCAT(db_ram_db.tb_batt_rtstate.group_vol ORDER BY db_ram_db.tb_batt_rtstate.BattGroupId
        separator '/') as group_vols,group_CONCAT(db_ram_db.tb_batt_rtstate.group_curr ORDER BY
        db_ram_db.tb_batt_rtstate.BattGroupId separator '/') as group_currs
        from db_ram_db.tb_Fbs9100_state
        left outer join db_battinf.tb_battinf ON tb_fbs9100_state.dev_id=db_battinf.tb_battinf.FBSDeviceId
        LEFT OUTER JOIN db_ram_db.tb_batt_rtstate ON db_battinf.tb_battinf.battgroupid=db_ram_db.tb_batt_rtstate.battgroupid
        LEFT OUTER JOIN db_ram_db.tb_batt_rtstate ON
        db_battinf.tb_battinf.battgroupid=db_ram_db.tb_batt_rtstate.battgroupid
        <if test="devErrcommcount==0">
            where dev_errcommcount=0
        </if>
@@ -102,4 +107,60 @@
            #{item}
        </foreach>
    </select>
    <select id="getStateList" resultType="com.whyc.pojo.Fbs9100State">
        select tb_fbs9100_state.dev_workstate
        from db_ram_db.tb_fbs9100_state
        where tb_fbs9100_state.dev_id in (select distinct db_battinf.tb_battinf.fbsdeviceId
                                          from db_battinf.tb_battinf,
                                               db_user.tb_user_battgroup_baojigroup_battgroup,
                                               db_user.tb_user_battgroup_baojigroup_usr,
                                               db_user.tb_user_inf
                                          where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId =
                                                db_battinf.tb_battinf.BattGroupId
                                            and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id =
                                                db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id
                                            and db_user.tb_user_inf.uid =
                                                db_user.tb_user_battgroup_baojigroup_usr.uid
                                            and db_user.tb_user_inf.uid = #{uId})
    </select>
    <select id="searchPowerOff" resultType="com.whyc.pojo.Fbs9100State">
        select tb_fbs9100_state.*, tb_battinf.stationName
        from db_ram_db.tb_fbs9100_state,
             db_battinf.tb_battinf
        where tb_fbs9100_state.dev_id = tb_battinf.fbsdeviceId
          and tb_fbs9100_state.dev_workstate = 3
          and tb_fbs9100_state.dev_id in (select distinct db_battinf.tb_battinf.fbsdeviceId
                                          from db_battinf.tb_battinf
                                             , db_user.tb_user_battgroup_baojigroup_battgroup
                                             , db_user.tb_user_battgroup_baojigroup_usr
                                             , db_user.tb_user_inf
                                          where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId =
                                                db_battinf.tb_battinf.BattGroupId
                                            and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id =
                                                db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id
                                            and db_user.tb_user_inf.uid =
                                                db_user.tb_user_battgroup_baojigroup_usr.uid
                                            and db_user.tb_user_inf.uid = #{uId}
        )
    </select>
    <select id="searchCheckCapDischarge" resultType="com.whyc.pojo.Fbs9100State">
        select tb_fbs9100_state.*, tb_battinf.stationName
        from db_ram_db.tb_fbs9100_state,
             db_battinf.tb_battinf
        where tb_fbs9100_state.dev_id = tb_battinf.fbsdeviceId
          and tb_fbs9100_state.dev_workstate = 2
          and tb_fbs9100_state.dev_id in (select distinct db_battinf.tb_battinf.fbsdeviceId
                                          from db_battinf.tb_battinf
                                             , db_user.tb_user_battgroup_baojigroup_battgroup
                                             , db_user.tb_user_battgroup_baojigroup_usr
                                             , db_user.tb_user_inf
                                          where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId =
                                                db_battinf.tb_battinf.BattGroupId
                                            and db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id =
                                                db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id
                                            and db_user.tb_user_inf.uid =
                                                db_user.tb_user_battgroup_baojigroup_usr.uid
                                            and db_user.tb_user_inf.uid = #{uId}
        )
    </select>
</mapper>