update

whycrzg

2021-03-11 c7bc3855af95cb0078935017a4c5a0366ed1fe54

update

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

@@ -1,6 +1,7 @@
package com.whyc.controller;

import com.whyc.dto.Response;
import com.whyc.service.AlarmService;
import com.whyc.service.BatteryService;
import com.whyc.util.CommonUtil;
import io.swagger.annotations.Api;
@@ -10,6 +11,7 @@
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.Map;

@@ -24,6 +26,9 @@
    @Autowired
    private BatteryService service;

    @Resource
    private AlarmService alarmService;

    /**
     *
     * 浮充数量
@@ -39,4 +44,74 @@
        return response;
    }


    @GetMapping("monCapacity")
    @ApiOperation(notes = "", value = "单体容量")
    public Response<Map> getMonCapacity(HttpServletRequest request) {
        int userId = CommonUtil.getUser(request).getId();

        return alarmService.getMonCapacity(userId);

    }


    /**
     * 内阻测试数量、故障数量
     *
     * @param request
     * @return
     */
    @GetMapping("onlineVol")
    @ApiOperation(notes = "", value = "在线电压和组端电压")
    public Response<Map> getOnlineAndGroupVol(HttpServletRequest request) {
        int userId = CommonUtil.getUser(request).getId();

        return alarmService.getOnlineAndGroupVol(userId);

    }


    /**
     * BTS 设备状态
     *
     * @param request
     * @return
     */
    @GetMapping("btsStatus")
    @ApiOperation(notes = "", value = "BTS设备状态")
    public Response<Map> getBTSEquipState(HttpServletRequest request) {
        int userId = CommonUtil.getUser(request).getId();

        return alarmService.getDeviceStatus(userId);

    }


    @GetMapping("discharge")
    @ApiOperation(notes = "", value = "放电电流")
    public Response<Map> getDischargeState(HttpServletRequest request) {
        int userId = CommonUtil.getUser(request).getId();

        return alarmService.getDischargeState(userId);

    }

    @GetMapping("charge")
    @ApiOperation(notes = "", value = "放电和 充电电流")
    public Response<Map> getCharge(HttpServletRequest request) {
        int userId = CommonUtil.getUser(request).getId();

        return alarmService.getCharge(userId);

    }

    @GetMapping("monVRT")
    @ApiOperation(notes = "", value = "单体电压、内阻和温度状态")
    public Response<Map> getMonVRT(HttpServletRequest request) {
        int userId = CommonUtil.getUser(request).getId();

        return alarmService.getMonVRT(userId);

    }

}

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

New file
@@ -0,0 +1,63 @@
//package com.whyc.controller;
//
//import com.whyc.dto.Response;
//import com.whyc.pojo.User;
//import com.whyc.service.AlarmService;
//import com.whyc.util.CommonUtil;
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiOperation;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.*;
//
//import javax.servlet.http.HttpServletRequest;
//import java.util.ArrayList;
//import java.util.Map;
//
//
///**
// * 单体容量告警
// */
//@RestController
//@RequestMapping("monAlarm")
//@Deprecated
//@Api(tags = "单体容量")
//public class MonAlarmController {
//
//    @Autowired
//    AlarmService alarmService;
//
//
//    @GetMapping("monCapacity")
//    @ApiOperation(notes = "", value = "单体容量")
//    public Response<Map> getMonCapacity(HttpServletRequest request) {
//        int userId = CommonUtil.getUser(request).getId();
///*        Response<Boolean> objectResponse = new Response<>();
//        objectResponse.setCode(1);
//        objectResponse.setData(true);
//        return objectResponse;*/
//
//        return alarmService.getMonCapacity(userId);
//
//    }
//
//    @GetMapping("tt")
//    @ApiOperation(notes = "", value = "单体容量tt")
//    public Response<Object> tt(@RequestParam(value = "名字",required = true) String name,@RequestParam(value = "msg",required = true) String msg) {
//        Response objectResponse = new Response<>();
//        objectResponse.setCode(1);
//        objectResponse.setMsg(msg);
//        objectResponse.setData(new ArrayList<>());
//        return objectResponse;
//
//    }
//
//    @PostMapping("po")
//    @ApiOperation(notes = "", value = "posttest")
//    public Response<User> potest(@RequestBody User user) {
//        Response objectResponse = new Response<>();
//        objectResponse.setCode(1);
//        objectResponse.setData(user);
//        return objectResponse;
//
//    }
//}

 src/main/java/com/whyc/dto/BattalarmData.java

New file
@@ -0,0 +1,230 @@
package com.whyc.dto;

import com.fasterxml.jackson.annotation.JsonFormat;

import java.io.Serializable;
import java.util.Date;

public class BattalarmData implements Serializable{
    private Integer num;
    private Integer battGroupId;
    private Integer monNum;
    private Long record_Id;
    private Integer alm_id;
    private Integer alm_signal_id;
    private Integer alm_level;
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "Asia/Shanghai")
    private Date alm_start_time;
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "Asia/Shanghai")
    private Date alm_start_time1;
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "Asia/Shanghai")
    private Date alm_end_time;
    private Float alm_value;
    private Integer alm_is_confirmed;
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "Asia/Shanghai")
    private Date alm_confirmed_time;
    private Integer alm_cleared_type;
    private Integer usr_Id;

    private String stationid;
    private String stationname;
    private String battGroupName;
    private String alarmname;
    private String alarmtype;
    private String note;

    public Integer getNum() {
        return num;
    }

    public void setNum(Integer num) {
        this.num = num;
    }

    public Integer getBattGroupId() {
        return battGroupId;
    }

    public void setBattGroupId(Integer battGroupId) {
        this.battGroupId = battGroupId;
    }

    public Integer getMonNum() {
        return monNum;
    }

    public void setMonNum(Integer monNum) {
        this.monNum = monNum;
    }

    public Long getRecord_Id() {
        return record_Id;
    }

    public void setRecord_Id(Long record_Id) {
        this.record_Id = record_Id;
    }

    public Integer getAlm_id() {
        return alm_id;
    }

    public void setAlm_id(Integer alm_id) {
        this.alm_id = alm_id;
    }

    public Integer getAlm_signal_id() {
        return alm_signal_id;
    }

    public void setAlm_signal_id(Integer alm_signal_id) {
        this.alm_signal_id = alm_signal_id;
    }

    public Integer getAlm_level() {
        return alm_level;
    }

    public void setAlm_level(Integer alm_level) {
        this.alm_level = alm_level;
    }

    public Date getAlm_start_time() {
        return alm_start_time;
    }

    public void setAlm_start_time(Date alm_start_time) {
        this.alm_start_time = alm_start_time;
    }

    public Date getAlm_start_time1() {
        return alm_start_time1;
    }

    public void setAlm_start_time1(Date alm_start_time1) {
        this.alm_start_time1 = alm_start_time1;
    }

    public Date getAlm_end_time() {
        return alm_end_time;
    }

    public void setAlm_end_time(Date alm_end_time) {
        this.alm_end_time = alm_end_time;
    }

    public Float getAlm_value() {
        return alm_value;
    }

    public void setAlm_value(Float alm_value) {
        this.alm_value = alm_value;
    }

    public Integer getAlm_is_confirmed() {
        return alm_is_confirmed;
    }

    public void setAlm_is_confirmed(Integer alm_is_confirmed) {
        this.alm_is_confirmed = alm_is_confirmed;
    }

    public Date getAlm_confirmed_time() {
        return alm_confirmed_time;
    }

    public void setAlm_confirmed_time(Date alm_confirmed_time) {
        this.alm_confirmed_time = alm_confirmed_time;
    }

    public Integer getAlm_cleared_type() {
        return alm_cleared_type;
    }

    public void setAlm_cleared_type(Integer alm_cleared_type) {
        this.alm_cleared_type = alm_cleared_type;
    }

    public Integer getUsr_Id() {
        return usr_Id;
    }

    public void setUsr_Id(Integer usr_Id) {
        this.usr_Id = usr_Id;
    }

    public String getStationid() {
        return stationid;
    }

    public void setStationid(String stationid) {
        this.stationid = stationid;
    }

    public String getStationname() {
        return stationname;
    }

    public void setStationname(String stationname) {
        this.stationname = stationname;
    }

    public String getBattGroupName() {
        return battGroupName;
    }

    public void setBattGroupName(String battGroupName) {
        this.battGroupName = battGroupName;
    }

    public String getAlarmname() {
        return alarmname;
    }

    public void setAlarmname(String alarmname) {
        this.alarmname = alarmname;
    }

    public String getAlarmtype() {
        return alarmtype;
    }

    public void setAlarmtype(String alarmtype) {
        this.alarmtype = alarmtype;
    }

    public String getNote() {
        return note;
    }

    public void setNote(String note) {
        this.note = note;
    }

    @Override
    public String toString() {
        return "BattalarmData{" +
                "num=" + num +
                ", battGroupId=" + battGroupId +
                ", monNum=" + monNum +
                ", record_Id=" + record_Id +
                ", alm_id=" + alm_id +
                ", alm_signal_id=" + alm_signal_id +
                ", alm_level=" + alm_level +
                ", alm_start_time=" + alm_start_time +
                ", alm_start_time1=" + alm_start_time1 +
                ", alm_end_time=" + alm_end_time +
                ", alm_value=" + alm_value +
                ", alm_is_confirmed=" + alm_is_confirmed +
                ", alm_confirmed_time=" + alm_confirmed_time +
                ", alm_cleared_type=" + alm_cleared_type +
                ", usr_Id=" + usr_Id +
                ", stationid='" + stationid + '\'' +
                ", stationname='" + stationname + '\'' +
                ", battGroupName='" + battGroupName + '\'' +
                ", alarmname='" + alarmname + '\'' +
                ", alarmtype='" + alarmtype + '\'' +
                ", note='" + note + '\'' +
                '}';
    }
}

 src/main/java/com/whyc/dto/BatttestdataInf.java

New file
@@ -0,0 +1,343 @@
package com.whyc.dto;

import com.fasterxml.jackson.annotation.JsonFormat;
import org.apache.ibatis.type.Alias;

import java.io.Serializable;
import java.util.Date;


@Alias("Batttestdata_inf")
public class BatttestdataInf implements Serializable {
    private Integer num;
    private Integer battGroupId;
    private Integer test_record_count;
    private Integer test_record_count_ex;
    private Integer test_type;
    private Integer record_time_interval;
    private Integer data_new;
    private Integer data_available;
    private Integer record_num;
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
    private Date test_starttime;
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
    private Date test_starttime_ex;
    private Integer test_starttype;
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
    private Date record_time;
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
    private Date record_time1;
    private Integer test_timelong;
    private Integer test_stoptype;
    private String test_stoptype_reason;//放电终止原因
    private String test_starttypeHex;//存放具体的放电测试的类型
    private Float group_vol;
    private Float test_curr;
    private Float test_cap;
    private Integer max_monnum;
    private Float max_monvol;
    private Integer min_monnum;
    private Float min_monvol;
    private Integer mon_num;
    private Float mon_vol;
    private Integer upload_usr_id;
    //stationname四个变量用于数据统计报表查询6.4
    private String stationname1;
    private String stationname2;
    private String stationname3;
    private String stationname4;

    public Integer getNum() {
        return num;
    }

    public void setNum(Integer num) {
        this.num = num;
    }

    public Integer getBattGroupId() {
        return battGroupId;
    }

    public void setBattGroupId(Integer battGroupId) {
        this.battGroupId = battGroupId;
    }

    public Integer getTest_record_count() {
        return test_record_count;
    }

    public void setTest_record_count(Integer test_record_count) {
        this.test_record_count = test_record_count;
    }

    public Integer getTest_record_count_ex() {
        return test_record_count_ex;
    }

    public void setTest_record_count_ex(Integer test_record_count_ex) {
        this.test_record_count_ex = test_record_count_ex;
    }

    public Integer getTest_type() {
        return test_type;
    }

    public void setTest_type(Integer test_type) {
        this.test_type = test_type;
    }

    public Integer getRecord_time_interval() {
        return record_time_interval;
    }

    public void setRecord_time_interval(Integer record_time_interval) {
        this.record_time_interval = record_time_interval;
    }

    public Integer getData_new() {
        return data_new;
    }

    public void setData_new(Integer data_new) {
        this.data_new = data_new;
    }

    public Integer getData_available() {
        return data_available;
    }

    public void setData_available(Integer data_available) {
        this.data_available = data_available;
    }

    public Integer getRecord_num() {
        return record_num;
    }

    public void setRecord_num(Integer record_num) {
        this.record_num = record_num;
    }

    public Date getTest_starttime() {
        return test_starttime;
    }

    public void setTest_starttime(Date test_starttime) {
        this.test_starttime = test_starttime;
    }

    public Date getTest_starttime_ex() {
        return test_starttime_ex;
    }

    public void setTest_starttime_ex(Date test_starttime_ex) {
        this.test_starttime_ex = test_starttime_ex;
    }

    public Integer getTest_starttype() {
        return test_starttype;
    }

    public void setTest_starttype(Integer test_starttype) {
        this.test_starttype = test_starttype;
    }

    public Date getRecord_time() {
        return record_time;
    }

    public void setRecord_time(Date record_time) {
        this.record_time = record_time;
    }

    public Date getRecord_time1() {
        return record_time1;
    }

    public void setRecord_time1(Date record_time1) {
        this.record_time1 = record_time1;
    }

    public Integer getTest_timelong() {
        return test_timelong;
    }

    public void setTest_timelong(Integer test_timelong) {
        this.test_timelong = test_timelong;
    }

    public Integer getTest_stoptype() {
        return test_stoptype;
    }

    public void setTest_stoptype(Integer test_stoptype) {
        this.test_stoptype = test_stoptype;
    }

    public String getTest_stoptype_reason() {
        return test_stoptype_reason;
    }

    public void setTest_stoptype_reason(String test_stoptype_reason) {
        this.test_stoptype_reason = test_stoptype_reason;
    }

    public String getTest_starttypeHex() {
        return test_starttypeHex;
    }

    public void setTest_starttypeHex(String test_starttypeHex) {
        this.test_starttypeHex = test_starttypeHex;
    }

    public Float getGroup_vol() {
        return group_vol;
    }

    public void setGroup_vol(Float group_vol) {
        this.group_vol = group_vol;
    }

    public Float getTest_curr() {
        return test_curr;
    }

    public void setTest_curr(Float test_curr) {
        this.test_curr = test_curr;
    }

    public Float getTest_cap() {
        return test_cap;
    }

    public void setTest_cap(Float test_cap) {
        this.test_cap = test_cap;
    }

    public Integer getMax_monnum() {
        return max_monnum;
    }

    public void setMax_monnum(Integer max_monnum) {
        this.max_monnum = max_monnum;
    }

    public Float getMax_monvol() {
        return max_monvol;
    }

    public void setMax_monvol(Float max_monvol) {
        this.max_monvol = max_monvol;
    }

    public Integer getMin_monnum() {
        return min_monnum;
    }

    public void setMin_monnum(Integer min_monnum) {
        this.min_monnum = min_monnum;
    }

    public Float getMin_monvol() {
        return min_monvol;
    }

    public void setMin_monvol(Float min_monvol) {
        this.min_monvol = min_monvol;
    }

    public Integer getMon_num() {
        return mon_num;
    }

    public void setMon_num(Integer mon_num) {
        this.mon_num = mon_num;
    }

    public Float getMon_vol() {
        return mon_vol;
    }

    public void setMon_vol(Float mon_vol) {
        this.mon_vol = mon_vol;
    }

    public Integer getUpload_usr_id() {
        return upload_usr_id;
    }

    public void setUpload_usr_id(Integer upload_usr_id) {
        this.upload_usr_id = upload_usr_id;
    }

    public String getStationname1() {
        return stationname1;
    }

    public void setStationname1(String stationname1) {
        this.stationname1 = stationname1;
    }

    public String getStationname2() {
        return stationname2;
    }

    public void setStationname2(String stationname2) {
        this.stationname2 = stationname2;
    }

    public String getStationname3() {
        return stationname3;
    }

    public void setStationname3(String stationname3) {
        this.stationname3 = stationname3;
    }

    public String getStationname4() {
        return stationname4;
    }

    public void setStationname4(String stationname4) {
        this.stationname4 = stationname4;
    }

    @Override
    public String toString() {
        return "Batttestdata_inf{" +
                "num=" + num +
                ", battGroupId=" + battGroupId +
                ", test_record_count=" + test_record_count +
                ", test_record_count_ex=" + test_record_count_ex +
                ", test_type=" + test_type +
                ", record_time_interval=" + record_time_interval +
                ", data_new=" + data_new +
                ", data_available=" + data_available +
                ", record_num=" + record_num +
                ", test_starttime=" + test_starttime +
                ", test_starttime_ex=" + test_starttime_ex +
                ", test_starttype=" + test_starttype +
                ", record_time=" + record_time +
                ", record_time1=" + record_time1 +
                ", test_timelong=" + test_timelong +
                ", test_stoptype=" + test_stoptype +
                ", test_stoptype_reason='" + test_stoptype_reason + '\'' +
                ", test_starttypeHex='" + test_starttypeHex + '\'' +
                ", group_vol=" + group_vol +
                ", test_curr=" + test_curr +
                ", test_cap=" + test_cap +
                ", max_monnum=" + max_monnum +
                ", max_monvol=" + max_monvol +
                ", min_monnum=" + min_monnum +
                ", min_monvol=" + min_monvol +
                ", mon_num=" + mon_num +
                ", mon_vol=" + mon_vol +
                ", upload_usr_id=" + upload_usr_id +
                ", stationname1='" + stationname1 + '\'' +
                ", stationname2='" + stationname2 + '\'' +
                ", stationname3='" + stationname3 + '\'' +
                ", stationname4='" + stationname4 + '\'' +
                '}';
    }
}

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

New file
@@ -0,0 +1,27 @@
package com.whyc.mapper;

import org.apache.ibatis.annotations.Param;

public interface BattAlarmDataMapper {


    //告警总数
    Integer getTotalAlarms(int userId);

    //告警机房总数
    Integer getTotalAlarmRooms(int userId);

    //低告警数量
    Integer getLowAlarmsNO(int userId);

    //告警总数比例
    Integer getTotalAlarmsScale(int userId);

    Integer getLowAlarmRoomsScale(int userId);

    //高告警数量
    Integer getHighAlarmsNO(int userId);

    //根据类型查询告警数量 almSignalId
    Integer getAlarmsNO(@Param(value = "almSignalId") int almSignalId, @Param(value = "userId") int userId);
}

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

New file
@@ -0,0 +1,9 @@
package com.whyc.mapper;

import org.apache.ibatis.annotations.Param;

public interface BattDevDataMapper {



}

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

New file
@@ -0,0 +1,6 @@
package com.whyc.mapper;

public interface BattResDataMapper {


}

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

New file
@@ -0,0 +1,21 @@
package com.whyc.mapper;

import com.whyc.dto.BatttestdataInf;

import java.util.List;

public interface BattTestDataMapper {


    List<BatttestdataInf> getAlarmInfByUserId(int userId);

    Integer getTotalAlarms(int userId);

    Integer getTotalAlarmRooms(int userId);

    Integer getLowAlarmsNO(int userId);

    Integer getTotalAlarmsScale(int userId);

    Integer getLowAlarmRoomsScale(int userId);
}

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

New file
@@ -0,0 +1,22 @@
package com.whyc.mapper;

import org.apache.ibatis.annotations.Param;

public interface Fbs9100StateMapper {

    //核容数量
    Integer getHeRongNO(@Param(value = "devId") int devId , @Param(value = "userId") int userId);

    //在线浮充数量
    Integer getOnlineFloatNO(@Param(value = "devId") int devId , @Param(value = "userId") int userId);

    //充电数量
    Integer getChargeNO(@Param(value = "devId") int devId , @Param(value = "userId") int userId);

    //内阻测试数量
    Integer getResTestNO(@Param(value = "devId") int devId , @Param(value = "userId") int userId);

    //故障数量
    Integer getErrNO(@Param(value = "devId") int devId , @Param(value = "userId") int userId);

}

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

New file
@@ -0,0 +1,252 @@
package com.whyc.service;

import com.whyc.constant.PowerAlarmConstant;
import com.whyc.dto.Response;
import com.whyc.mapper.BattAlarmDataMapper;
import com.whyc.mapper.Fbs9100StateMapper;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;

@Service
public class AlarmService {

    @Resource
    private BattAlarmDataMapper battAlarmDataMapper;
    @Resource
    private Fbs9100StateMapper fbs9100StateMapper;

    /**
     * 单体容量 monCapStd
     * alm_id
     * Alarm_CapAlarm =119010
     * @param userId
     * @return
     */
    public Response<Map> getMonCapacity(int userId) {
        Response<Map> response = new Response();   //TODO RZG
        Map<String, Integer> resultMap = new HashMap<String, Integer>();

        try {
            Integer lowAlarmsNO = battAlarmDataMapper.getLowAlarmsNO(userId);
//            Integer totalAlarmsScale = battAlarmDataMapper.getTotalAlarmsScale(userId);
            Integer totalAlarms = battAlarmDataMapper.getTotalAlarms(userId);
            Integer totalAlarmRooms = battAlarmDataMapper.getTotalAlarmRooms(userId);
//            Integer lowAlarmRoomsScale = battAlarmDataMapper.getLowAlarmRoomsScale(userId);

            resultMap.put("lowAlarmsNO", lowAlarmsNO);     //低告警数量
            resultMap.put("totalAlarmsScale", 1);      //告警总数比例
            resultMap.put("totalAlarms", totalAlarms);        //告警总数
            resultMap.put("totalAlarmRooms", totalAlarmRooms);      //告警机房总数
            resultMap.put("lowAlarmRoomsScale", 1);    //低告警机房数比例
            response.setCode(1);
            response.setData(resultMap);
        } catch (Exception e) {
            e.printStackTrace();
            response.setCode(0);
            return response;
        }
        return response;
    }
 ;

    /**
     * 在线电压和组端电压
     * alm_id 电池告警参数
     * Alarm_vol_Online =119001
     * Alarm_vol_Group =119002
     *
     * @param userId
     * @return
     */
    public Response getOnlineAndGroupVol(int userId) {
//        select alm_signal_id,count(alm_signal_id) as num from db_alarm.tb_battalarm_data alarm where alm_id in (119001,119002,119003,119004)
        Response<Map> response = new Response();   //TODO RZG
        HashMap<String, Object> resultMap = new HashMap<>();
        Map<String, Integer> resMap = new HashMap<>();//内阻测试数量
        Map<String, Integer> errMap = new HashMap<>();//故障数量

        try {
            Integer highAlarmsNO = battAlarmDataMapper.getAlarmsNO(PowerAlarmConstant.ALM_SIGNAL_ID_OnlineVolHigh, userId);
            Integer lowAlarmsNO = battAlarmDataMapper.getAlarmsNO(PowerAlarmConstant.ALM_SIGNAL_ID_OnlineVolLow, userId);

            resMap.put("highAlarmsNO", highAlarmsNO);     //高告警数量    alm_signal_id:online 1 high; 2 low
            resMap.put("lowAlarmsNO", lowAlarmsNO);     //低告警数量
            resMap.put("totalAlarmsScale", 1);      //告警总数比例

            Integer totalAlarms = battAlarmDataMapper.getTotalAlarms(userId);
            resMap.put("totalAlarms", 1);        //告警总数

            Integer totalAlarmRooms = battAlarmDataMapper.getTotalAlarmRooms(userId);
            resMap.put("totalAlarmRooms", 1);      //告警机房总数

            resMap.put("lowAlarmRoomsScale", 1);    //低告警机房数比例
            resultMap.put("resMap", resMap);


            errMap.put("highAlarmsNO", 1);     //高告警数量
            errMap.put("lowAlarmsNO", 1);     //低告警数量
            errMap.put("totalAlarmsScale", 1);      //告警总数比例
            errMap.put("totalAlarms", 1);        //告警总数
            errMap.put("totalAlarmRooms", 1);      //告警机房总数
            errMap.put("lowAlarmRoomsScale", 1);    //低告警机房数比例
            resultMap.put("errMap", errMap);

            response.setCode(1);
            response.setData(resultMap);
        } catch (Exception e) {
            e.printStackTrace();
            response.setCode(0);
            return response;
        }

        return response;
    }


    /**
     * BTS 设备状态
     *
     * @param userId
     * @return
     */
    public Response getDeviceStatus(int userId) {

        Response<Map> response = new Response();   //TODO RZG
        Map<String, Integer> resultMap = new HashMap<>();
        try {


            int devId = 910000001;
            Integer herongNO = fbs9100StateMapper.getHeRongNO(devId, userId);    //dev_workstate 0 在线浮充; 2 核容测试; 4 内阻测试;
//            com.fgkj.dao.impl.ram.Fbs9100_stateImpl#seach6185Nuclear_cap 核容测试
//        Integer onlineFloatNO = fbs9100StateMapper.getOnlineFloatNO(devId,userId);
//        Integer chargeNO = fbs9100StateMapper.getChargeNO(devId,userId);
//        Integer resTestNO = fbs9100StateMapper.getResTestNO(devId,userId);
//        Integer errNO = fbs9100StateMapper.getErrNO(devId,userId);
            resultMap.put("herongNO", herongNO);    //核容数量
            resultMap.put("onlineFloatNO", 1);    //在线浮充数量
            resultMap.put("chargeNO", 1);    //充电数量
            resultMap.put("resTestNO", 1);    //内阻测试数量
            resultMap.put("errNO", 1);    //故障数量
            response.setCode(1);
            response.setData(resultMap);
        } catch (Exception e) {
            e.printStackTrace();
            response.setCode(0);
            return response;
        }
        return response;
    }


    /**
     * 放电电流 Alarm_curr_Discharge =119004
     *
     * @param userId
     * @return
     */
    public Response getDischargeState(int userId) {

        Response<Map> response = new Response();   //TODO RZG
        Map<String, Integer> resultMap = new HashMap<>();

        try {
            resultMap.put("lowAlarmsNO", 1);     //低告警数量 alm_signal_id:DisChargeCurr 7 high; 8 low
            resultMap.put("totalAlarmRooms", 1);      //告警机房总数
            resultMap.put("alarmRoomsScale", 1);    //告警机房数比例
            resultMap.put("totalAlarms", 1);        //告警总数
            resultMap.put("totalAlarmsScale", 1);      //告警总数比例
            response.setCode(1);
            response.setData(resultMap);
        } catch (Exception e) {
            e.printStackTrace();
            response.setCode(0);
            return response;
        }
        return response;
    }

    //    充电电流

    /**
     * 放电和 充电电流
     * alm_id 电池告警参数
     * @param userId
     * @return
     */
    public Response getCharge(int userId) {

        Response<Map> response = new Response();   //TODO RZG
        HashMap<String, Object> resultMap = new HashMap<>();
        Map<String, Integer> disCharge = new HashMap<>();//放电电流  Alarm_curr_Discharge =119004
        Map<String, Integer> reCharge = new HashMap<>();//充电电流   Alarm_curr_Charge =119003


        disCharge.put("highAlarmsNO", 1);     //高告警数量    alm_signal_id:ChargeCurrHigh 5 high; 6 low
        disCharge.put("totalAlarms", 1);        //告警总数
        disCharge.put("totalAlarmsScale", 1);      //告警总数比例
        disCharge.put("totalAlarmRooms", 1);      //告警机房总数
        disCharge.put("alarmRoomsScale", 1);    //告警机房数比例
        resultMap.put("disCharge", disCharge);

        reCharge.put("highAlarmsNO", 1);     //高告警数量
        reCharge.put("totalAlarms", 1);        //告警总数
        reCharge.put("totalAlarmsScale", 1);      //告警总数比例
        reCharge.put("totalAlarmRooms", 1);      //告警机房总数
        reCharge.put("alarmRoomsScale", 1);    //告警机房数比例
        resultMap.put("reCharge", reCharge);

        response.setCode(1);
        response.setData(resultMap);
        return response;
    }


    /**
     * 单体电压、内阻和温度
     * alm_id 电池告警参数
     * @param userId
     * @return
     */
    public Response getMonVRT(int userId) {

        Response<Map> response = new Response();   //TODO RZG
        HashMap<String, Object> resultMap = new HashMap<>();
        Map<String, Integer> monVolMap = new HashMap<>();//单体电压  Alarm_vol_Monomer =119005;
        Map<String, Integer> monResMap = new HashMap<>();//单体内阻  Alarm_res_Monomer =119007
        Map<String, Integer> monTemMap = new HashMap<>();//单体温度  Alarm_tmp_Monomer =119006


        monVolMap.put("highAlarmsNO", 1);     //高告警数量    alm_signal_id 9
        monVolMap.put("lowAlarmsNO", 1);     //低告警数量     alm_signal_id   10
        monVolMap.put("totalAlarms", 1);        //告警总数
        monVolMap.put("totalAlarmsScale", 1);      //告警总数比例
        monVolMap.put("totalAlarmRooms", 1);      //告警机房总数
        monVolMap.put("alarmRoomsScale", 1);    //告警机房数比例
        resultMap.put("monVolMap", monVolMap);

        monResMap.put("highAlarmsNO", 1);     //高告警数量    alm_signal_id 13
        monResMap.put("lowAlarmsNO", 1);     //低告警数量     alm_signal_id 14
        monResMap.put("totalAlarms", 1);        //告警总数
        monResMap.put("totalAlarmsScale", 1);      //告警总数比例
        monResMap.put("totalAlarmRooms", 1);      //告警机房总数
        monResMap.put("alarmRoomsScale", 1);    //告警机房数比例
        resultMap.put("monResMap", monResMap);

        monTemMap.put("highAlarmsNO", 1);     //高告警数量    alm_signal_id 11
        monTemMap.put("lowAlarmsNO", 1);     //低告警数量     alm_signal_id 12
        monTemMap.put("totalAlarms", 1);        //告警总数
        monTemMap.put("totalAlarmsScale", 1);      //告警总数比例
        monTemMap.put("totalAlarmRooms", 1);      //告警机房总数
        monTemMap.put("alarmRoomsScale", 1);    //告警机房数比例
        resultMap.put("monTemMap", monTemMap);

        response.setCode(1);
        response.setData(resultMap);
        return response;
    }

}

 src/main/resources/mapper/BattAlarmDataMapper.xml

New file
@@ -0,0 +1,153 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.BattAlarmDataMapper">

    <!-- GROUP BY inf.StationId-->
    <select id="getTotalAlarms" resultType="java.lang.Integer">
        SELECT count(*)
        FROM (
                 SELECT inf.StationId
                 FROM db_alarm.tb_battalarm_data alarm,
                      db_battinf.tb_battinf inf
                 WHERE alarm.BattGroupId = inf.BattGroupId
                   AND alm_cleared_type = 0
                   AND alm_id = 119010
                   AND inf.StationId IN (
                     SELECT DISTINCT inf.StationId
                     FROM (
                              SELECT StationId
                              FROM db_battinf.tb_battinf
                          ) inf,
                          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.StationId = inf.StationId
                       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}
                 )
             ) temp
    </select>


    <select id="getTotalAlarmRooms" resultType="java.lang.Integer">
        SELECT count(*)
        FROM (
                 SELECT inf.StationId
                 FROM db_alarm.tb_battalarm_data alarm,
                      db_battinf.tb_battinf inf
                 WHERE alarm.BattGroupId = inf.BattGroupId
                   AND alm_cleared_type = 0
                   AND alm_id = 119010
                   AND inf.StationId IN (
                     SELECT DISTINCT inf.StationId
                     FROM (
                              SELECT StationId
                              FROM db_battinf.tb_battinf
                          ) inf,
                          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.StationId = inf.StationId
                       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}
                 )
                 GROUP BY inf.BattGroupId
             ) temp
    </select>

    <select id="getLowAlarmsNO" resultType="java.lang.Integer">
        SELECT count(*)
        FROM (
                 SELECT inf.StationId
                 FROM db_alarm.tb_battalarm_data alarm,
                      db_battinf.tb_battinf inf
                 WHERE alarm.BattGroupId = inf.BattGroupId
                   AND alm_cleared_type = 0
                   AND alm_id = 119010
                   AND alm_signal_id = ${@com.whyc.constant.PowerAlarmConstant@ALM_SIGNAL_ID_MonVolLow}
                   AND inf.StationId IN (
                     SELECT DISTINCT inf.StationId
                     FROM (
                              SELECT StationId
                              FROM db_battinf.tb_battinf
                          ) inf,
                          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.StationId = inf.StationId
                       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}
                 )
             ) temp
    </select>
    <select id="getTotalAlarmsScale" resultType="java.lang.Integer">


    </select>
    <select id="getLowAlarmRoomsScale" resultType="java.lang.Integer"></select>

    <select id="getHighAlarmsNO" resultType="java.lang.Integer">
        SELECT count(*)
        FROM (
                 SELECT inf.StationId
                 FROM db_alarm.tb_battalarm_data alarm,
                      db_battinf.tb_battinf inf
                 WHERE alarm.BattGroupId = inf.BattGroupId
                   AND alm_cleared_type = 0
                   AND alm_signal_id = ${@com.whyc.constant.PowerAlarmConstant@ALM_SIGNAL_ID_MonVolHigh}
                   AND inf.StationId IN (
                     SELECT DISTINCT inf.StationId
                     FROM (
                              SELECT StationId
                              FROM db_battinf.tb_battinf
                          ) inf,
                          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.StationId = inf.StationId
                       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}
                 )
             ) temp
    </select>

    <!--在线电压,组端电压 ;机房对应权限 StationId/BattgroupId-->
    <!--select alm_signal_id,count(alm_signal_id) as num from db_alarm.tb_battalarm_data alarm where alm_id in (119001,119002,119003,119004) -->
    <select id="getAlarmsNO" resultType="java.lang.Integer">

        SELECT count(*)
        FROM (
                 SELECT inf.StationId
                 FROM db_alarm.tb_battalarm_data alarm,
                      db_battinf.tb_battinf inf
                 WHERE alarm.BattGroupId = inf.BattGroupId
                   AND alm_cleared_type = 0
                   AND alm_signal_id = #{almSignalId}
                   AND inf.StationId IN (
                     SELECT DISTINCT inf.StationId
                     FROM (
                              SELECT StationId
                              FROM db_battinf.tb_battinf
                          ) inf,
                          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.StationId = inf.StationId
                       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}
                 )
             ) temp

    </select>

</mapper>

 src/main/resources/mapper/BattDevDataMapper.xml

New file
@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.BattDevDataMapper" >


</mapper>

 src/main/resources/mapper/BattResDataMapper.xml

New file
@@ -0,0 +1,5 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.BattResDataMapper" >

</mapper>

 src/main/resources/mapper/BattTestDataMapper.xml

New file
@@ -0,0 +1,84 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.BattTestDataMapper" >


    <select id="getAlarmInfByUserId" resultType="com.whyc.dto.BatttestdataInf"></select>
    <select id="getTotalAlarms" resultType="java.lang.Integer">
        SELECT
            count(*)
        FROM
            (
                SELECT
                    inf.StationId
                FROM
                    db_alarm.tb_battalarm_data alarm,
                    db_battinf.tb_battinf inf
                WHERE
                    alarm.BattGroupId = inf.BattGroupId
                  AND alm_cleared_type = 0
                  AND inf.StationId IN (
                    SELECT DISTINCT
                        inf.StationId
                    FROM
                        (
                            SELECT
                                StationId
                            FROM
                                db_battinf.tb_battinf
                        ) inf,
                        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.StationId = inf.StationId
                      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}
                )
                GROUP BY
                    inf.StationId
            ) temp
    </select>
    <select id="getTotalAlarmRooms" resultType="java.lang.Integer">
        SELECT
            count(*)
        FROM
            (
                SELECT
                    inf.StationId
                FROM
                    db_alarm.tb_battalarm_data alarm,
                    db_battinf.tb_battinf inf
                WHERE
                    alarm.BattGroupId = inf.BattGroupId
                  AND alm_cleared_type = 0
                  AND inf.StationId IN (
                    SELECT DISTINCT
                        inf.StationId
                    FROM
                        (
                            SELECT
                                StationId
                            FROM
                                db_battinf.tb_battinf
                        ) inf,
                        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.StationId = inf.StationId
                      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}
                )
                GROUP BY
                    inf.BattGroupId
            ) temp;
    </select>
    <select id="getLowAlarmsNO" resultType="java.lang.Integer"></select>
    <select id="getTotalAlarmsScale" resultType="java.lang.Integer"></select>
    <select id="getLowAlarmRoomsScale" resultType="java.lang.Integer"></select>


</mapper>

 src/main/resources/mapper/Fbs9100StateMapper.xml

New file
@@ -0,0 +1,42 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.Fbs9100StateMapper" >

    <!--核容数量-->
    <select id="getHeRongNO" resultType="java.lang.Integer">
        SELECT COUNT(db_ram_db.tb_fbs9100_state.dev_id)
        FROM db_ram_db.tb_fbs9100_state,
             db_battinf.tb_battinf
        WHERE db_ram_db.tb_fbs9100_state.dev_id = db_battinf.tb_battinf.fbsdeviceid
          AND db_ram_db.tb_fbs9100_state.dev_id = #{devId}
          AND db_ram_db.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 = #{userId}
        )

    </select>
    <!--dev_data_flowsum-->
    <select id="getOnlineFloatNO" resultType="java.lang.Integer">

    </select>

    <!-- 充电数量 test_type alm_type -->
    <select id="getChargeNO" resultType="java.lang.Integer"></select>

    <!--dev_restest_count 内阻测试数量-->
    <select id="getResTestNO" resultType="java.lang.Integer"></select>

    <!--dev_errcommcount 通讯故障数？-->
    <select id="getErrNO" resultType="java.lang.Integer">


    </select>
</mapper>