package com.dy.aceMw.server.rtuData.p206V1_0_0; import com.dy.aceMw.server.rtuData.TaskSurpport; import com.dy.common.mw.protocol.Data; import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; /** * @Author liurunyu * @Date 2024/4/2 13:45 * @LastEditTime 2024/4/2 13:45 * @Description 处理命令响应上报 */ public class TkRtuDealCommandResponse extends TaskSurpport { private static final Logger log = LogManager.getLogger(TkRtuDealCommandResponse.class.getName()) ; //类ID,一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkRtuDealCommandResponse" ; /** * 执行节点任务:处理命令响应上报 * @param data 需要处理的数据 */ @Override public void execute(Object data) { Data d = (Data) data; Object subD = d.getSubData(); if (subD != null) { DataV1_0_1 dV1_0_1 = (DataV1_0_1) subD; // if (dV1_0_1 != null && dV1_0_1.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_0_1, dV1_0_1.dataCdC0Vo) ; // this.saveHistory(sv, controller, d.getRtuAddr(),dV1_0_1, dV1_0_1.dataCdC0Vo) ; // }catch (Exception e){ // log.error("保存控制器自报数据时发生异常", e); // } // } } } }