| | |
|---|
| | | import com.dy.rtuMw.server.forTcp.TcpSessionCache; |
|---|
| | | import com.dy.rtuMw.server.local.CommandInnerDeaLer; |
|---|
| | | import com.dy.rtuMw.server.local.ReturnCommand; |
|---|
| | | import com.dy.rtuMw.server.tasks.RtuDownTask; |
|---|
| | | import com.dy.rtuMw.server.tasks.WebDownComTask; |
|---|
| | | import com.dy.common.mw.core.CoreUnit; |
|---|
| | | import com.dy.common.mw.protocol.Command; |
|---|
| | | import com.dy.common.mw.protocol.CommandType; |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | //生成异步任务 |
|---|
| | | RtuDownTask task = new RtuDownTask() ; |
|---|
| | | WebDownComTask task = new WebDownComTask() ; |
|---|
| | | task.data = command ; |
|---|
| | | try{ |
|---|
| | | log.info("构造下发远程命令" + command.getCode() + "的核心任务，并放入任务队列中"); |
|---|
