新增所有设备告警阈值字段及对应名称

whycxzp

2021-05-10 82903ec7eea4bc7f18466330bf728aa9580c657b

新增所有设备告警阈值字段及对应名称

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

@@ -15,6 +15,9 @@
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("afeInverter")
@Api(tags = "afe变频器-逆变器的数据信息")
@@ -35,6 +38,12 @@
        return service.getInfoByDeviceId(devId);
    }

    @GetMapping("field")
    @ApiOperation(value = "查询告警阈值字段")
    public Response<Map<String, List>> getField(){
        return service.getField();
    }

    @GetMapping("tableNames")
    @ApiOperation(value = "查询历史记录存在的表")
    public Response<String> getTableNames(){

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

@@ -14,6 +14,9 @@
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.Map;


@RequestMapping("centralMonitorSys")
@RestController
@@ -29,6 +32,18 @@
        return service.getInfoByDevId(devId);
    }

    @GetMapping("inField")
    @ApiOperation(value = "查询告警阈值字段-进线屏")
    public Response<Map<String,List>> getInField(){
        return service.getInField();
    }

    @GetMapping("outField")
    @ApiOperation(value = "查询告警阈值字段-出线屏")
    public Response<Map<String,List>> getOutField(){
        return service.getOutField();
    }

    /**
     * ======History======
     * 历史查询时,因为历史记录是按照日期分表的,如果查询所有的日期表(union)后再分页,会导致速度极慢,故查询按照单个日期查询

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

@@ -14,6 +14,9 @@
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.Map;


@RequestMapping("centralMonitorSysST")
@RestController
@@ -29,6 +32,12 @@
        return service.getInfoByDevId(devId);
    }

    @GetMapping("field")
    @ApiOperation(value = "查询告警阈值字段")
    public Response<Map<String, List>> getField(){
        return service.getField();
    }

    /**
     * ======History======
     * 历史查询时,因为历史记录是按照日期分表的,如果查询所有的日期表(union)后再分页,会导致速度极慢,故查询按照单个日期查询

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

@@ -15,6 +15,7 @@
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.Map;

/**
 * Oil通讯
@@ -40,6 +41,12 @@
        return service.getInfoByDevId(devId);
    }

    @GetMapping("field")
    @ApiOperation(value = "查询告警阈值字段")
    public Response<Map<String, List>> getField(){
        return service.getField();
    }

    /**
     * ======History======
     * 历史查询时,因为历史记录是按照日期分表的,如果查询所有的日期表(union)后再分页,会导致速度极慢,故查询按照单个日期查询

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

@@ -14,6 +14,9 @@
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("rectifierPower")
@Api(tags = "大功率整流电源-数据信息")
@@ -34,6 +37,12 @@
        return service.getInfoByDevId(devId);
    }

    @GetMapping("field")
    @ApiOperation(value = "查询告警阈值字段")
    public Response<Map<String, List>> getField(){
        return service.getField();
    }

    /**
     * ======History======
     * 历史查询时,因为历史记录是按照日期分表的,如果查询所有的日期表(union)后再分页,会导致速度极慢,故查询按照单个日期查询

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

@@ -14,7 +14,7 @@

@RestController
@RequestMapping("rectifierPowerCtrl")
@Api(tags = "大功率整流电源-控制状态")
@Api(tags = "大功率整流电源-控制")
public class RectifierPowerCtrlController {

    @Autowired

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

@@ -15,6 +15,9 @@
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.Map;

/**
 * UPS通讯
 */
@@ -33,6 +36,12 @@
        return service.getStauts();
    }

    @GetMapping("field")
    @ApiOperation(value = "查询告警阈值字段")
    public Response<Map<String, List>> getField(){
        return service.getField();
    }

    /**
     * ======History======
     * 历史查询时,因为历史记录是按照日期分表的,如果查询所有的日期表(union)后再分页,会导致速度极慢,故查询按照单个日期查询

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

@@ -16,6 +16,7 @@
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.Map;

/**
 * Water通讯
@@ -40,6 +41,11 @@
    public Response<WaterComm> getInfoByDevId(@RequestParam int devId){
        return service.getInfoByDevId(devId);
    }
    @GetMapping("field")
    @ApiOperation(value = "查询告警阈值字段")
    public Response<Map<String, List>> getField(){
        return service.getField();
    }

    /**
     * ======History======

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

@@ -14,7 +14,10 @@
import org.springframework.stereotype.Service;

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

@Service
public class AFEInverterService {
@@ -44,6 +47,23 @@
        return new Response<AFEInverterState>().set(1,afeInverterState);
    }

    public Response<Map<String, List>> getField() {
        Map<String,List> fieldMap = new HashMap();
        List<String> fieldNames = new LinkedList();
        fieldNames.add("输出电流");
        fieldNames.add("输出电压");
        fieldNames.add("模块温度");

        List<String> fieldValues = new LinkedList();
        fieldValues.add("output_curr");
        fieldValues.add("output_vol");
        fieldValues.add("model_tmp");

        fieldMap.put("fieldNames",fieldNames);
        fieldMap.put("fieldValues",fieldValues);
        return new Response<Map<String,List>>().set(1,fieldMap);
    }

    /**======History======*/

    public Response<PageInfo<AFEInverterState>> getHistory(int pageNum, int pageSize,int devId) {

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

@@ -24,7 +24,14 @@
        return new Response<List<AlarmRule>>().set(1,alarmRules);
    }

    /**
     * 必须考虑阈值和级别的关系
     * @param alarmRule
     * @return
     */
    public Response add(AlarmRule alarmRule) {
        //查询同一字段,同一个under或者over,是否已经存在记录
        //如果存在了记录,则按照 一般,重要,严重区分:一般1,严重2,...
        mapper.insert(alarmRule);
        return new Response().setMsg(1,"新增成功");
    }

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

@@ -13,7 +13,10 @@
import org.springframework.web.bind.annotation.RequestParam;

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

@Service
public class CentralMonitorSysRTService {
@@ -44,6 +47,35 @@
        return new Response<List<CentralMonitorSysRT>>().set(1,centralMonitorSysRTS);
    }


    public Response<Map<String,List>> getInField() {
        Map<String,List> fieldMap = new HashMap();
        List<String> fieldNames = new LinkedList();
        fieldNames.add("进线屏电压");
        fieldNames.add("进线屏电流");

        List<String> fieldValues = new LinkedList();
        fieldValues.add("panel_vol");
        fieldValues.add("panel_curr");

        fieldMap.put("fieldNames",fieldNames);
        fieldMap.put("fieldValues",fieldValues);
        return new Response<Map<String,List>>().set(1,fieldMap);
    }

    public Response<Map<String,List>> getOutField() {
        Map<String,List> fieldMap = new HashMap();
        List<String> fieldNames = new LinkedList();
        fieldNames.add("出线屏电流");

        List<String> fieldValues = new LinkedList();
        fieldValues.add("panel_curr");

        fieldMap.put("fieldNames",fieldNames);
        fieldMap.put("fieldValues",fieldValues);
        return new Response<Map<String,List>>().set(1,fieldMap);
    }

    /*======History======*/
    public Response<PageInfo<CentralMonitorSysRT>> getHistory(int pageNum, int pageSize, int devId) {
        List<String> tableNames = commonMapper.getTableName("db_3.5mw_motor_history", "tb_central_monitor_sys_rt_" + devId);

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

@@ -13,7 +13,10 @@
import org.springframework.stereotype.Service;

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

@Service
public class CentralMonitorSysSTService {
@@ -38,6 +41,25 @@
        }
    }

    public Response<Map<String, List>> getField() {
        Map<String,List> fieldMap = new HashMap();
        List<String> fieldNames = new LinkedList();
        fieldNames.add("A排电流");
        fieldNames.add("A排电压");
        fieldNames.add("B排电流");
        fieldNames.add("B排电压");

        List<String> fieldValues = new LinkedList();
        fieldValues.add("curr_a");
        fieldValues.add("vol_a");
        fieldValues.add("curr_b");
        fieldValues.add("vol_b");

        fieldMap.put("fieldNames",fieldNames);
        fieldMap.put("fieldValues",fieldValues);
        return new Response<Map<String,List>>().set(1,fieldMap);
    }

    public Response<PageInfo<CentralMonitorSysST>> getHistory(int pageNum, int pageSize, int devId) {
        List<String> tableNames = commonMapper.getTableName("db_3.5mw_motor_history", "tb_central_monitor_sys_st_" + devId);
        PageHelper.startPage(pageNum,pageSize);

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

@@ -13,7 +13,10 @@
import org.springframework.stereotype.Service;

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

/**
 * Oil通讯
@@ -53,6 +56,41 @@
        }
    }

    public Response<Map<String, List>> getField() {
        Map<String,List> fieldMap = new HashMap();
        List<String> fieldNames = new LinkedList();
        fieldNames.add("油站回油温度");
        fieldNames.add("润滑油出口流量");
        fieldNames.add("润滑油压力1");
        fieldNames.add("润滑油压力2");
        fieldNames.add("油站出口1压力");
        fieldNames.add("油站出口2压力");
        fieldNames.add("油站出口3压力");
        fieldNames.add("油站出口4压力");
        fieldNames.add("润滑油回油流量");
        fieldNames.add("油站冷却水压力");
        fieldNames.add("油站冷却水回水温度");
        fieldNames.add("油站出油温度");

        List<String> fieldValues = new LinkedList();
        fieldValues.add("oil_returnTmp");
        fieldValues.add("oil_outFlow");
        fieldValues.add("oil_pre1");
        fieldValues.add("oil_pre2");
        fieldValues.add("oil_outpre1");
        fieldValues.add("oil_outpre2");
        fieldValues.add("oil_outpre3");
        fieldValues.add("oil_outpre4");
        fieldValues.add("oil_returnFlow");
        fieldValues.add("oil_coolpre");
        fieldValues.add("oil_coolTmp");
        fieldValues.add("oil_outTmp");

        fieldMap.put("fieldNames",fieldNames);
        fieldMap.put("fieldValues",fieldValues);
        return new Response<Map<String,List>>().set(1,fieldMap);
    }

    public Response<PageInfo<OilComm>> getHistory(int pageNum, int pageSize, int devId) {
        List<String> tableNames = commonMapper.getTableName("db_3.5mw_motor_history", "tb_oil_comm_" + devId);
        PageHelper.startPage(pageNum,pageSize);

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

@@ -16,7 +16,10 @@

import javax.annotation.Resource;
import java.sql.Wrapper;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

@Service
public class RectifierPowerService {
@@ -49,4 +52,19 @@
        PageInfo<RectifierPowerRT> rectifierPowerRTPageInfo = new PageInfo<>(rectifierPowerRTs);
        return new Response<PageInfo<RectifierPowerRT>>().set(1,rectifierPowerRTPageInfo);
    }

    public Response<Map<String, List>> getField() {
        Map<String,List> fieldMap = new HashMap();
        List<String> fieldNames = new LinkedList();
        fieldNames.add("整流电源电压");
        fieldNames.add("整流电源电流");

        List<String> fieldValues = new LinkedList();
        fieldValues.add("rectifier_vol");
        fieldValues.add("rectifier_curr");

        fieldMap.put("fieldNames",fieldNames);
        fieldMap.put("fieldValues",fieldValues);
        return new Response<Map<String,List>>().set(1,fieldMap);
    }
}

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

@@ -11,7 +11,10 @@
import org.springframework.stereotype.Service;

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

/**
 * UPS通讯
@@ -38,6 +41,33 @@
        }
    }

    public Response<Map<String, List>> getField() {
        Map<String,List> fieldMap = new HashMap();
        List<String> fieldNames = new LinkedList();
        fieldNames.add("输入电压");
        fieldNames.add("输入频率");
        fieldNames.add("输出电压");
        fieldNames.add("输出频率");
        fieldNames.add("负载容量");
        fieldNames.add("负载电流");
        fieldNames.add("UPS内部温度");
        fieldNames.add("电池电压");

        List<String> fieldValues = new LinkedList();
        fieldValues.add("input_vol");
        fieldValues.add("input_rate");
        fieldValues.add("output_vol");
        fieldValues.add("output_rate");
        fieldValues.add("load_cap");
        fieldValues.add("load_curr");
        fieldValues.add("ups_inTmp");
        fieldValues.add("batt_vol");;

        fieldMap.put("fieldNames",fieldNames);
        fieldMap.put("fieldValues",fieldValues);
        return new Response<Map<String,List>>().set(1,fieldMap);
    }

    public Response<PageInfo<UPSComm>> getHistory(int pageNum, int pageSize, int devId) {
        List<String> tableNames = commonMapper.getTableName("db_3.5mw_motor_history", "tb_ups_comm_" + devId);
        PageHelper.startPage(pageNum,pageSize);

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

@@ -13,7 +13,10 @@
import org.springframework.stereotype.Service;

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

/**
 * Water通讯
@@ -53,6 +56,41 @@
        }
    }

    public Response<Map<String, List>> getField() {
        Map<String,List> fieldMap = new HashMap();
        List<String> fieldNames = new LinkedList();
        fieldNames.add("水站回水温度");
        fieldNames.add("冷冻水出口流量");
        fieldNames.add("冷冻水压力1");
        fieldNames.add("冷冻水压力2");
        fieldNames.add("水站出口1压力");
        fieldNames.add("水站出口2压力");
        fieldNames.add("水站出口3压力");
        fieldNames.add("水站出口4压力");
        fieldNames.add("冷冻水回水流量");
        fieldNames.add("水站冷却水压力");
        fieldNames.add("水站冷却水回水温度");
        fieldNames.add("水站出水温度");

        List<String> fieldValues = new LinkedList();
        fieldValues.add("water_returnTmp");
        fieldValues.add("water_outFlow");
        fieldValues.add("water_pre1");
        fieldValues.add("water_pre2");
        fieldValues.add("water_outpre1");
        fieldValues.add("water_outpre2");
        fieldValues.add("water_outpre3");
        fieldValues.add("water_outpre4");
        fieldValues.add("water_returnFlow");
        fieldValues.add("water_coolpre");
        fieldValues.add("water_coolTmp");
        fieldValues.add("water_outTmp");

        fieldMap.put("fieldNames",fieldNames);
        fieldMap.put("fieldValues",fieldValues);
        return new Response<Map<String,List>>().set(1,fieldMap);
    }

    public Response<PageInfo<WaterComm>> getHistory(int pageNum, int pageSize, int devId) {
        List<String> tableNames = commonMapper.getTableName("db_3.5mw_motor_history", "tb_water_comm_" + devId);
        PageHelper.startPage(pageNum,pageSize);