package com.dy.rtuMw.server.rtuData.p206V2; import com.dy.common.mw.protocol.p206V2.upVos.DataStateVo; import com.dy.rtuMw.server.rtuData.TaskSurpport; import com.dy.rtuMw.server.rtuData.dbSv.DbSv; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import java.util.Date; /** * @Author: liurunyu * @Date: 2024/8/9 9:49 * @Description */ public class TkDealVirCardStateV2 extends TaskSurpport { private static final Logger log = LogManager.getLogger(TkDealVirCardStateV2.class.getName()) ; //类ID,一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkDealVirCardStateV2" ; /** * 执行节点任务:虚拟卡在取水口上的占用状态改为非占用状态 * @param data 需要处理的数据 */ @Override public void execute(Object data) { Object[] objs = this.getTaskResults(TkDealAlarmStatusV2.taskId); if(objs != null && objs.length >= 2){ Long intakeId = (Long)objs[0] ; Byte valveState = (Byte)objs[1] ; if(intakeId != null && valveState.byteValue() == DataStateVo.ValveCloseState){ objs = this.getTaskResults(TkPreGenObjsV2.taskId); DbSv sv = (DbSv) objs[0]; //虚拟卡在取水口上的占用状态改为非占用状态 Date now = new Date() ; sv.updateVirCardNoUseState(intakeId, now); } } } }