修改告警阈值重启线程

whyclxw

2024-04-28 b25b814a949d2065a61fd3167206ffb51a57af65

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

@@ -17,10 +17,12 @@
import com.whyc.pojo.Fbs9100Setparam;
import com.whyc.pojo.Li9130SetparamPlan;
import com.whyc.util.ActionUtil;
import com.whyc.util.ThreadLocalUtil;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;

@Service
@@ -271,6 +273,9 @@
            case FBS9100_ComBase.CMD_ForceSetNowBatt:
                m_cmd_ack = FBS9100_ComBase.CMD_ForceSetNowBatt_ACK;
                break;
            case FBS9100_ComBase.CMD_updateXZTime:
                m_cmd_ack = FBS9100_ComBase.CMD_updateXZTimeAck;
                break;
            default:
                return false;
        }
@@ -497,6 +502,10 @@
            case FBS9100_ComBase.CMD_Stop: m_cmd_ack = FBS9100_ComBase.CMD_StopAck; break;
            case FBS9100_ComBase.CMD_EOperatingSwitch_ControlSwitch: m_cmd_ack = FBS9100_ComBase.CMD_EOperatingSwitch_ControlSwitchAck; break;
            case FBS9100_ComBase.CMD_ResetSystem: m_cmd_ack = FBS9100_ComBase.CMD_ResetSystemAck; break;
            case FBS9100_ComBase.CMD_ReadTest_Param: m_cmd_ack = FBS9100_ComBase.CMD_ReadTest_Param_ACK; break;
            case FBS9100_ComBase.CMD_WriteTest_Param: m_cmd_ack = FBS9100_ComBase.CMD_WriteTest_Param_ACK; break;
            case FBS9100_ComBase.CMD_StartDcdcTest: m_cmd_ack = FBS9100_ComBase.CMD_StartDcdcTest_ACK; break;
            case FBS9100_ComBase.CMD_StopDcdcTest: m_cmd_ack = FBS9100_ComBase.CMD_StopDcdcTest_ACK; break;
            default:
                return false;
        }
@@ -674,6 +683,10 @@
        int opCmd = FBS9100_ComBase.CMD_GetDischargeParm;
        return searchParam(devId,opCmd);
    }
    public Response searchML(int devId) {
        int opCmd = FBS9100_ComBase.CMD_ReadTest_Param;
        return searchParam(devId,opCmd);
    }

    private Response searchParam(int devId, int opCmd) {
        boolean res = sendCmdToDev(opCmd, devId);
@@ -700,6 +713,21 @@
        mapper.update((Fbs9100Setparam) ActionUtil.objeNull,update);

        boolean res = sendCmdToDev(FBS9100_ComBase.CMD_SetDischargeParm, devId.intValue());
        return new Response().set(1, res, res ? "修改参数成功" : "设置参数失败,请检查网络");
    }

    public Response updateML(Fbs9100Setparam param) {
        Long devId = param.getDevId();
        UpdateWrapper<Fbs9100Setparam> update = Wrappers.update();
        update.set("dcdc1_outputvol",param.getDcdc1OutputVol())
                .set("dcdc2_outputvol",param.getDcdc2OutputVol())
                .set("dcdc1_outputcurr",param.getDcdc1OutputCurr())
                .set("dcdc2_outputcurr",param.getDcdc2OutputCurr())
                .set("screensaver_time",param.getScreenSaverTime())
                .eq("dev_id",devId);
        mapper.update((Fbs9100Setparam) ActionUtil.objeNull,update);

        boolean res = sendCmdToDev(FBS9100_ComBase.CMD_WriteTest_Param, devId.intValue());
        return new Response().set(1, res, res ? "修改参数成功" : "设置参数失败,请检查网络");
    }

@@ -758,6 +786,16 @@
        return new Response().set(1, res, res ? "修改参数成功" : "设置参数失败,请检查网络");
    }

   //设置参数-61850-同步时间
    public Response update61850SyncTime(int devId,String syncTime) {
        UpdateWrapper<Fbs9100Setparam> update = Wrappers.update();
        update.set("OffLineYHstarttime",ThreadLocalUtil.parse(syncTime,1));//同步时间
        update.eq("dev_id",devId);
        mapper.update((Fbs9100Setparam) ActionUtil.objeNull,update);
        boolean bl=sendCmdToFBS9100Dev(FBS9100_ComBase.CMD_updateXZTime,0,devId);
        return new Response().set(1, bl, bl ? "同步时间成功" : "同步时间失败,请检查网络");
    }

    public Response updateLD6StartTest(int devId) {
        return updateOpCmd(devId,FBS9100_ComBase.LD6_CMD_STARTTEST);
    }