在线监测-实时监控-A059一体机接口

whyclxw

2022-01-14 7cad667cf7501fa1a908ef33a7c053b6d41f1cda

在线监测-实时监控-A059一体机接口

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

@@ -21,25 +21,47 @@
        return  service.serchdevParam(devId);
    }

    @ApiOperation("在线监测-实时监控-BTS停止")
    @ApiOperation(tags = "在线监测-实时监控",value = "在线监测-实时监控-BTS停止")
    @GetMapping("serchbyDev_id")
    private Response serchbyDev_id(@RequestParam int num, Integer testCmd,@RequestParam int devId){
        return service.serchbyDev_id(num,testCmd,devId);
    }

    @ApiOperation("在线监测-实时监控-重启设备")
    @ApiOperation(tags = "在线监测-实时监控",value = "在线监测-实时监控-重启设备")
    @PostMapping("updateMaintain")
    private Response updateMaintain(@RequestBody Fbs9100Setparam fbs9100Setparam){
        return service.updateMaintain(fbs9100Setparam);
    }
    @ApiOperation(value = "在线监测-实时监控-BTS放电参数设置",notes = "Fbs9100_setparamAction_action_update")
    @ApiOperation(tags = "在线监测-实时监控",value = "在线监测-实时监控-BTS放电参数设置",notes = "Fbs9100_setparamAction_action_update")
    @PostMapping("update")
    private Response update(@RequestBody Fbs9100Setparam fbs9100Setparam){
        return service.update(fbs9100Setparam);
    }
    @ApiOperation(value = "在线监测-实时监控-61850放电参数设置",notes = "Fbs9100_setparamAction_action_update61850Param")

    @ApiOperation(tags = "在线监测-实时监控",value = "在线监测-实时监控-61850放电参数设置",notes = "Fbs9100_setparamAction_action_update61850Param")
    @PostMapping("update61850Param")
    private Response update61850Param(@RequestBody Fbs9100Setparam fbs9100Setparam){
        return service.update61850Param(fbs9100Setparam);
    }

    @ApiOperation(tags = "在线监测-实时监控",value = "在线监测-实时监控-A059发送指令",notes = "Fbs9100_setparamAction_action_updateA059Cmd")
    @GetMapping("updateA059Cmd")
    private Response updateA059Cmd(@RequestParam int opCmd,@RequestParam int devId){
        return service.updateA059Cmd(opCmd,devId);
    }
    @ApiOperation(tags = "在线监测-实时监控",value = "在线监测-实时监控-读取FGCD_A059放电参数",notes = "Fbs9100_setparamAction_action_searchA059Param")
    @GetMapping("searchA059Param")
    private Response searchA059Param(@RequestParam int opCmd,@RequestParam int devId){
        return service.searchA059Param(opCmd,devId);
    }
    @ApiOperation(tags = "在线监测-实时监控",value = "在线监测-实时监控-设置FGCD_A059放电参数",notes = "Fbs9100_setparamAction_action_updateA059Param")
    @PostMapping("updateA059Param")
    private Response updateA059Param(@RequestBody Fbs9100Setparam a059setParam){
        return service.updateA059Param(a059setParam);
    }
    @ApiOperation(tags = "在线监测-实时监控",value = "在线监测-实时监控-一体机拓扑图界面添加一个温度报警的设置值",notes = "Fbs9100_setparamAction_action_serchCharHighTmp")
    @GetMapping("serchCharHighTmp")
    private Response serchCharHighTmp(@RequestParam int devId){
        return service.serchCharHighTmp(devId);
    }
}

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

@@ -21,13 +21,13 @@
    private Fbs9100StateService service;

    @ApiOperation("开关状态")
    @GetMapping("/serchContactorState")
    @GetMapping("serchContactorState")
    private Response serchContactorState(@RequestParam int devId){
        return service.serchContactorState(devId);
    }

    @ApiOperation("FBS9100设备通信状态查询")
    @GetMapping("/searchByCondition")
    @GetMapping("searchByCondition")
    public Response searchByCondition(@RequestParam int pageNum,@RequestParam int pageSize,@RequestParam int devErrcommcount){
        UserInf userInf = ActionUtil.getUser();
        return service.searchByCondition(pageNum,pageSize,devErrcommcount,userInf.getUId().intValue());
@@ -39,4 +39,15 @@
        return new Response().setII(1,"这是个描述性接口,请通过ws协议调用!具体ws接口为:/fg/deviceWorkState,发送信息:{\"devId\":910000001,\"devWorkstate\":0,\"note\":1002}");
    }

    @ApiOperation(value = "一体机烟雾报警确认",notes = "Fbs9100_stateAction_action_update_dev_res_test_state")
    @GetMapping("update_dev_res_test_state")
    public Response update_dev_res_test_state(@RequestParam int devId){
        return service.update_dev_res_test_state(devId);
    }

    @ApiOperation(value = "一体机界面弹出框确认操作",notes = "Fbs9100_stateAction_action_update_dev_alarmstate")
    @GetMapping("update_dev_alarmstate")
    public Response update_dev_alarmstate(@RequestParam int num,@RequestParam int devId){
        return service.update_dev_alarmstate(num,devId);
    }
}

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

@@ -14,4 +14,6 @@
    Boolean updateBtsParam(Fbs9100Setparam fbs9100Setparam);
    //在线监测-实时监控-61850放电参数设置
    Boolean update61850Param(Fbs9100Setparam fbs9100Setparam);
    //在线监测-实时监控-设置FGCD_A059放电参数
    Boolean updateA059Param(Fbs9100Setparam a059setParam);
}

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

@@ -84,7 +84,40 @@
        if(b){
            bl=sendCmdToFBS9100Dev(fbs9100Setparam.getNum().intValue(),0,fbs9100Setparam.getDevId().intValue());
        }
        return new Response().set(1,bl,bl==true?"修改参数成功!":"设置9100参数失败,请检查网络!");
        return new Response().set(1,bl,bl==true?"修改参数成功!":"设置61850参数失败,请检查网络!");
    }

    //在线监测-实时监控-A059发送指令
    public Response updateA059Cmd(int opCmd, int devId) {
        boolean bl=sendCmdToFBS9100Dev(opCmd,0,devId);
        return new Response().set(1,bl,bl==true?"修改参数成功!":"启动A059失败,请检查网络!");
    }

    //在线监测-实时监控-读取FGCD_A059放电参数
    public Response searchA059Param(int opCmd, int devId) {
        PageHelper.startPage(1,1);
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("dev_id",devId);
        Fbs9100Setparam a059param=mapper.selectOne(wrapper);
        boolean bl=sendCmdToFBS9100Dev(opCmd,0,devId);
        return new Response().setII(1,bl,a059param,bl==true?"读取参数成功!":"读取A059参数失败,请检查网络!");
    }
    //在线监测-实时监控-设置FGCD_A059放电参数
    public Response updateA059Param(Fbs9100Setparam a059setParam) {
        Boolean b=mapper.updateA059Param(a059setParam);
        boolean bl=false;
        if(b){
            bl=sendCmdToFBS9100Dev(a059setParam.getNum().intValue(),0,a059setParam.getDevId().intValue());
        }
        return new Response().set(1,bl,bl==true?"修改参数成功!":"设置A059参数失败,请检查网络!");
    }
    //一体机拓扑图界面添加一个温度报警的设置值
    public Response serchCharHighTmp(int devId) {
        PageHelper.startPage(1,1);
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("dev_id",devId);
        Fbs9100Setparam a059param=mapper.selectOne(wrapper);
        return new Response().set(1,a059param);
    }
    //机房命令操作设备时的cmd和ack校验  test_type  -->默认启动测试的类型
    public boolean sendCmdToFBS9100Dev(int cmd,int test_type,int dev_id)

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

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
@@ -8,6 +9,7 @@
import com.whyc.pojo.Battinf;
import com.whyc.pojo.Fbs9100State;
import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import javax.xml.crypto.Data;
@@ -19,6 +21,8 @@
public class Fbs9100StateService {
    @Resource
    private Fbs9100StateMapper mapper;
    @Autowired
    private Fbs9100SetparamService service;

    //开关状态
    public Response serchContactorState(int devId) {
@@ -42,4 +46,52 @@
        List<Fbs9100State> list = mapper.getList(deviceId, workState, uId);
        return new Response<List<Fbs9100State>>().set(1,list);
    }
    //一体机烟雾报警确认
    public Response update_dev_res_test_state(int devId) {
        UpdateWrapper wrapper=new UpdateWrapper();
        wrapper.set("dev_res_test_state",0);
        wrapper.eq("dev_id",devId);
        int flag=mapper.update(null,wrapper);
        return  new Response().set(1,flag>0?true:false);
    }
    //一体机界面弹出框确认操作
    public Response update_dev_alarmstate(int num, int devId) {
        int dev_alarmstat=0;
        int flag=0;
        boolean bl=false;
        String msg="";
        UpdateWrapper wrapper=new UpdateWrapper();
        if(num==1){//确认操作
            dev_alarmstat=2;
            wrapper.set("dev_alarmstate",dev_alarmstat);
            wrapper.eq("dev_id",devId);
            flag=mapper.update(null,wrapper);
            if(flag>0){
                boolean b=service.sendCmdToFBS9100Dev(35,0, devId);
                if(b){
                    bl=true;
                    msg="修改成功!";
                }else{
                    bl=false;
                    msg="停止失败!";
                }
            } else{
                bl=false;
                msg="修改失败!";
            }
        }else{//取消操作时
            dev_alarmstat=3;
            wrapper.set("dev_alarmstate",dev_alarmstat);
            wrapper.eq("dev_id",devId);
            flag=mapper.update(null,wrapper);
            if(flag>0){
                bl=true;
                msg="修改成功!";
            }else{
                bl=false;
                msg="修改失败!";
            }
        }
        return new Response().set(1,bl,msg);
    }
}

 src/main/resources/mapper/Fbs9100SetparamMapper.xml

@@ -17,6 +17,15 @@
              ,monomerVol_Low=#{monomervolLow},DCVolHighLimit=#{DCVolHighLimit},ChargeCurrSet=#{ChargeCurrSet}
               where dev_id=#{devId}
    </update>
    <update id="updateA059Param">
        UPDATE db_ram_db.tb_fbs9100_setparam SET  dev_ip=#{devIp}, op_cmd=#{opCmd}, TestCmd=#{TestCmd}, HourRate=#{HourRate}, DisCurr=#{DisCurr},
            DisCap=#{DisCap}, DisTime=#{DisTime}, GroupVol_LOW=#{groupvolLow}, MonomerVol_LOW=#{monomervolLow}, MonomerLowCount=#{MonomerLowCount}, BattGroupNum=#{BattGroupNum}, OnlineVolLowAction=#{OnlineVolLowAction},
            DCVolHighLimit=#{DCVolHighLimit}, ChargeCurrSet=#{ChargeCurrSet}, MonomerTmp_High=#{monomertmpHigh}, AutoTestStartVol=#{AutoTestStartVol}, OnLineVol_Low=#{onlinevolLow}, OffLineYH_Cycle=#{offlineyhCycle},
            OffLineYHstarttime=#{OffLineYHstarttime}, OffLineYHTimes=#{OffLineYHTimes}, OffLineYHOnceCycle=#{OffLineYHOnceCycle}, MonCount=#{MonCount}, MonVol=#{MonVol}, DisPower=#{DisPower}, DisPreRes=#{DisPreRes},
            CharCap=#{CharCap}, CharTimeLong=#{CharTimeLong}, FloatCharTimeLong=#{FloatCharTimeLong}, CharSotpCurr=#{CharSotpCurr}, MonVolHightLimit=#{MonVolHightLimit}, MonVolHightLimitCount=#{MonVolHightLimitCount},
            CharHighTmp=#{CharHighTmp}, DisWaitTime=#{DisWaitTime}, CharWaitTime=#{CharWaitTime} , FlowOver_Count = #{flowoverCount},  FlowOver_CharCurr_1 = #{flowoverCharcurr1},  FlowOver_CharCurr_2 =#{flowoverCharcurr2},  FlowOver_CharCurr_3 =#{flowoverCharcurr3},
            FlowOver_CharTime_1 =#{flowoverChartime1},  FlowOver_CharTime_2 =#{flowoverChartime2},  FlowOver_CharTime_3 =#{flowoverChartime3} WHERE dev_id = #{devId}
    </update>

    <select id="serchbyDev_id" resultType="com.whyc.pojo.Fbs9100Setparam">
        select db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.FBSDeviceId,db_battinf.tb_battinf.FBSDeviceIp,db_battinf.tb_battinf.BattGroupName,db_battinf.tb_battinf.BattGroupId