| New file | 
|  |  |  | 
|---|
|  |  |  | package com.dy.rtuMw.server.rtuData.p206V2; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.dy.common.mw.protocol.Data; | 
|---|
|  |  |  | import com.dy.common.mw.protocol.p206V2.DataV2; | 
|---|
|  |  |  | import com.dy.common.mw.protocol.p206V2.upVos.DataCd02Vo; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoPr.PrControllerTramp; | 
|---|
|  |  |  | import com.dy.rtuMw.server.rtuData.TaskSurpport; | 
|---|
|  |  |  | import org.apache.logging.log4j.LogManager; | 
|---|
|  |  |  | import org.apache.logging.log4j.Logger; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * @Author liurunyu | 
|---|
|  |  |  | * @Date 2024/2/22 16:56 | 
|---|
|  |  |  | * @LastEditTime 2024/2/22 16:56 | 
|---|
|  |  |  | * @Description | 
|---|
|  |  |  | * 处理非流浪控制器,此任务无具体业务逻辑,只是在任务xml配置文件中,框住其子任务节点 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public class TkDealControllerNoTrampV2 extends TaskSurpport { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private static final Logger log = LogManager.getLogger(TkDealControllerNoTrampV2.class.getName()) ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //类ID,一定与Tree.xml配置文件中配置一致 | 
|---|
|  |  |  | public static final String taskId = "TkDealControllerNoTrampV2" ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 执行节点任务 | 
|---|
|  |  |  | * @param data 需要处理的数据 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void execute(Object data) { | 
|---|
|  |  |  | Data d = (Data)data ; | 
|---|
|  |  |  | Object[] objs = this.getTaskResults(TkPreGenObjsV2.taskId) ; | 
|---|
|  |  |  | PrControllerTramp tramp = (PrControllerTramp)objs[2] ; | 
|---|
|  |  |  | if(tramp == null){ | 
|---|
|  |  |  | boolean toNext = true ; | 
|---|
|  |  |  | if(d.getSubData() != null) { | 
|---|
|  |  |  | DataV2 dataV2 = (DataV2)d.getSubData() ; | 
|---|
|  |  |  | if(dataV2 != null && dataV2.subData != null && dataV2.subData instanceof DataCd02Vo){ | 
|---|
|  |  |  | //过滤掉心跳数据 | 
|---|
|  |  |  | toNext = false ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(toNext){ | 
|---|
|  |  |  | this.toNextTasks(data); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|