package com.dy.rtuMw.server.rtuData.p206V202404; import com.dy.common.mw.protocol.Data; import com.dy.common.mw.protocol.p206V202404.DataV202404; import com.dy.rtuMw.server.rtuData.TaskSurpport; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; /** * @Author liurunyu * @Date 2024/5/8 14:18 * @Description 处理命令响应上报 */ public class TkRtuDealCommandResponseV202404 extends TaskSurpport { private static final Logger log = LogManager.getLogger(TkRtuDealCommandResponseV202404.class.getName()) ; //类ID,一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkRtuDealCommandResponseV202404" ; /** * 执行节点任务:处理命令响应上报 * @param data 需要处理的数据 */ @Override public void execute(Object data) { Data d = (Data)data ; Object protocolData = d.getSubData() ; if(protocolData != null){ DataV202404 dV202404 = (DataV202404)protocolData ; if(dV202404 != null) { // if (dV1 != null && dV1.dataCdC0Vo != null) { // Object[] objs = this.getTaskResults(TkPreGenObjs.taskId) ; // DbSv sv = (DbSv)objs[0] ; // PrController controller = (PrController)objs[1] ; // try{ // this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dV1, dV1.dataCdC0Vo) ; // this.saveHistory(sv, controller, d.getRtuAddr(),dV1, dV1.dataCdC0Vo) ; // }catch (Exception e){ // log.error("保存控制器自报数据时发生异常", e); // } // } } } } }