| | |
| | | Data d = (Data)data ; |
| | | Object subD = d.getSubData() ; |
| | | if(subD != null){ |
| | | boolean toNext = false ; |
| | | DataV1 dV1 = (DataV1)subD ; |
| | | if(dV1 != null && dV1.subData != null){ |
| | | //dV1.dataCd81Vo、 dV1.dataCd84Vo 与 dV1.dataCdC0Vo 不会同时有值 |
| | |
| | | if(dataCd81Vo.stateVo != null && dataCd81Vo.stateVo.valveState != null && dataCd81Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){ |
| | | if(controller != null && controller.getIntakeId() != null){ |
| | | this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ; |
| | | toNext = true ; |
| | | } |
| | | } |
| | | } |
| | |
| | | if(dataCd84Vo.stateVo != null && dataCd84Vo.stateVo.valveState != null && dataCd84Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){ |
| | | if(controller != null && controller.getIntakeId() != null){ |
| | | this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ; |
| | | toNext = true ; |
| | | } |
| | | }*/ |
| | | } |
| | |
| | | if(dataCdC0Vo.stateVo != null && dataCdC0Vo.stateVo.valveState != null && dataCdC0Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){ |
| | | if(controller != null && controller.getIntakeId() != null){ |
| | | this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ; |
| | | toNext = true ; |
| | | } |
| | | } |
| | | } |
| | |
| | | log.error("保存控制器报警和状态数据时发生异常", e); |
| | | } |
| | | } |
| | | if(toNext){ |
| | | this.toNextTasks(d); |
| | | } |
| | | } |
| | | } |
| | | /** |