|  |  |  | 
|---|
|  |  |  | package com.dy.aceMw.server.rtuData.p206V1_0_0; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.dy.aceMw.server.rtuData.TaskSurpport; | 
|---|
|  |  |  | import com.dy.aceMw.server.rtuData.dbSv.RtuSv; | 
|---|
|  |  |  | import com.dy.common.mw.protocol.Data; | 
|---|
|  |  |  | import com.dy.common.springUtil.SpringContextUtil; | 
|---|
|  |  |  | import org.apache.logging.log4j.LogManager; | 
|---|
|  |  |  | import org.apache.logging.log4j.Logger; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | public void execute(Object data) { | 
|---|
|  |  |  | Data d = (Data)data ; | 
|---|
|  |  |  | String rtuAddr = d.getRtuAddr() ; | 
|---|
|  |  |  | log.info("RTU" + rtuAddr + "数据到此,还未实现处理:" + data.toString()); | 
|---|
|  |  |  | log.info("RTU" + rtuAddr + "数据到此,进行数据库存储测试"); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | RtuSv sv = (RtuSv)SpringContextUtil.getBean(RtuSv.class) ; | 
|---|
|  |  |  | sv.save(d) ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //得到本地RTU 数据,以备后面节点应用 | 
|---|
|  |  |  | /* | 
|---|
|  |  |  | BuziInterface baseBusi = BuziGeter.getBaseBusi() ; | 
|---|