电操开关遥调遥控点位读取/设置

whycxzp

2022-11-05 403cb373bb78caf1f61aa2c757eb392f3d732eab

电操开关遥调遥控点位读取/设置

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

@@ -86,4 +86,17 @@
    public Response SetNowBatt(@RequestParam int devId, @RequestParam int opCmd, @RequestParam int battGroupNum) {
        return service.SetNowBatt(devId, opCmd, battGroupNum);
    }

    @ApiOperation(tags = "电操开关遥调遥控点位",value = "设置参数")
    @PostMapping("updateEOperatingSwitchParam")
    public Response updateEOperatingSwitchParam(@RequestBody Fbs9100Setparam fbs9100Setparam){
        return service.updateEOperatingSwitch(fbs9100Setparam);
    }

    @ApiOperation(tags = "电操开关遥调遥控点位",value = "设置参数")
    @PostMapping("getEOperatingSwitchParam")
    public Response getEOperatingSwitchParam(@RequestParam int devId){
        return service.getEOperatingSwitch(devId);
    }

}

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

@@ -24,4 +24,6 @@

    //在线监测-实时监控-设置FGCD_A059当前电池组
    Boolean SetNowBatt(int devId, int battGroupNum);

    Boolean updateEOperatingSwitch(Fbs9100Setparam fbs9100Setparam);
}

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

@@ -277,7 +277,7 @@
    private Float monVolStd;
    @TableField(exist = false)
    private Integer monCount;
    @TableField(exist = false)
    @TableField("MonCapStd")
    private Float monCapStd;
    @TableField(exist = false)
    private Float loadCurr;

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

@@ -2,6 +2,7 @@

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.FBS9100_ComBase;
@@ -327,4 +328,67 @@
        return res_exe;
    }

    public boolean sendCmdToDev(int opCmd,int dev_id)
    {
        int m_cmd = opCmd;
        int m_cmd_ack = opCmd;
        switch(m_cmd) {
            case FBS9100_ComBase.CMD_SetDischargeParm: m_cmd_ack = FBS9100_ComBase.CMD_SetDischargeParmAck; break;
            case FBS9100_ComBase.CMD_GetDischargeParm: m_cmd_ack = FBS9100_ComBase.CMD_GetDischargeParmAck; break;

            default:
                return false;
        }
        //更新op_cmd
        UpdateWrapper updateWrapper=new UpdateWrapper();
        updateWrapper.set("op_cmd",m_cmd);
        updateWrapper.eq("dev_id",dev_id);
        int flag=mapper.update(null,updateWrapper);
        boolean res_exe = false;
        if(flag>0)
        {
            PageHelper.startPage(1,1);
            QueryWrapper queryWrapper=new QueryWrapper();
            queryWrapper.eq("dev_id",dev_id);
            for(int n=0; n<40; n++)
            {

                Fbs9100Setparam fbs9100Setparam=mapper.selectOne(queryWrapper);
                if(fbs9100Setparam!=null){
                    if(fbs9100Setparam.getOpCmd()==m_cmd_ack){
                        res_exe = true;
                        break;
                    }
                    try {
                        Thread.sleep(250);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }else {
                    break;
                }
            }
        }
        return res_exe;
    }
    public Response updateEOperatingSwitch(Fbs9100Setparam fbs9100Setparam) {
        Boolean b=mapper.updateEOperatingSwitch(fbs9100Setparam);
        boolean bl=false;
        if(b){
            bl=sendCmdToDev(FBS9100_ComBase.CMD_SetDischargeParm,fbs9100Setparam.getDevId().intValue());
        }
        return new Response().set(1,bl,bl==true?"修改参数成功!":"设置参数失败,请检查网络!");
    }

    public Response getEOperatingSwitch(int devId) {
        boolean b = sendCmdToDev(FBS9100_ComBase.CMD_GetDischargeParm, devId);
        if(b){
            QueryWrapper<Fbs9100Setparam> query = Wrappers.query();
            query.eq("dev_id",devId).last(" limit 1");
            Fbs9100Setparam param = mapper.selectOne(query);
            return new Response().setII(1, true,param,null);
        }
        return new Response().set(1,false,"读取参数失败,请检查网络!");

    }
}

 src/main/resources/mapper/Fbs9100SetparamMapper.xml

@@ -158,7 +158,24 @@
            HV_mon_uppernum3 = #{hvMonUppernum3}
        WHERE dev_id = #{devId}
    </update>

    <update id="updateEOperatingSwitch">
        update db_ram_db.tb_Fbs9100_setparam
        set
        TestCmd=#{TestCmd},
        DisCurr=#{DisCurr},
        DisCap=#{DisCap},
        DisTime=#{DisTime},
        groupVol_Low=#{groupvolLow},
        monomerVol_Low=#{monomervolLow},
        monomerLowCount=#{MonomerLowCount},
        battGroupNum=#{BattGroupNum},
        onlineVolLowAction=#{OnlineVolLowAction},
        MonomerTmp_High=#{monomertmpHigh},
        DisWaitTime=#{DisWaitTime}
        MonVol=#{MonVol}
        MonCapStd=#{monCapStd}
        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