New file |
| | |
| | | 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); |
| | | // } |
| | | // } |
| | | } |
| | | } |
| | | } |
| | | } |