| | |
|---|
| | | * @param stateVo 状态对象 |
|---|
| | | */ |
|---|
| | | private void toMsCenter(PrController controller, String rtuAddr, DataV1 dV1, DataAlarmVo alarmVo, DataStateVo stateVo){ |
|---|
| | | if(alarmVo != null && controller != null){ |
|---|
| | | if(alarmVo != null && controller != null && alarmVo.hasAlarm()){ |
|---|
| | | MsObj msObj = new MsObj() ; |
|---|
| | | msObj.put("name", "报警"); |
|---|
| | | msObj.put("rtuAddr", rtuAddr); |
|---|
| | | msObj.put("intakeId", controller.getIntakeId()); |
|---|
| | | msObj.put("alarm", alarmVo.alarmContent()); |
|---|
| | | msObj.put("dt", dV1.dt); |
|---|
| | | MsCenterUnit.getInstance().pushMs(msObj); |
|---|
| | | } |
|---|
| | | if(stateVo != null && controller != null && stateVo.valveState != null){ |
|---|
| | | MsObj msObj = new MsObj() ; |
|---|
| | | msObj.put("name", "阀态"); |
|---|
| | | msObj.put("rtuAddr", rtuAddr); |
|---|
| | | msObj.put("intakeId", controller.getIntakeId()); |
|---|
| | | msObj.put("state", stateVo.valveState); |
|---|
| | | msObj.put("stateName", stateVo.valveState==0?"开":"关"); |
|---|
| | | msObj.put("dt", dV1.dt); |
|---|
| | | MsCenterUnit.getInstance().pushMs(msObj); |
|---|
| | | } |
|---|
| | | } |
|---|
