| | |
| | | import com.dy.aceMw.server.rtuData.dbSv.DbSv; |
| | | import com.dy.common.mw.protocol.Data; |
| | | import com.dy.common.springUtil.SpringContextUtil; |
| | | import com.dy.common.util.DateTime; |
| | | import com.dy.pipIrrGlobal.pojoPr.PrController; |
| | | import com.dy.pipIrrGlobal.pojoPr.PrControllerTramp; |
| | | import org.apache.logging.log4j.LogManager; |
| | |
| | | //数据库中未查询到控制器(RTU实体) |
| | | //流浪者控制器 |
| | | PrControllerTramp rtuTramp = sv.getPrControllerTrampByRtuAddr(rtuAddr); |
| | | if(rtuTramp == null){ |
| | | rtuTramp = new PrControllerTramp(null, rtuAddr, d.getProtocol(), DateTime.yyyy_MM_dd_HH_mm_ss()) ; |
| | | this.taskResult = new Object[]{sv, null, rtuTramp} ; |
| | | this.toNextOneTask(data, TkDealControllerTramp.taskId); |
| | | } |
| | | //if(rtuTramp == null){ |
| | | // rtuTramp = new PrControllerTramp(null, rtuAddr, d.getProtocol(), DateTime.yyyy_MM_dd_HH_mm_ss()) ; |
| | | // this.taskResult = new Object[]{sv, null, rtuTramp} ; |
| | | // this.toNextOneTask(data, TkDealControllerTramp.taskId); |
| | | //} |
| | | } |
| | | //不论是否为流浪控制器(RTU实体),都要进行下步工作 |
| | | this.taskResult = new Object[]{sv, controller, null} ; |