| | |
|---|
| | | * 处理RTU下行命令数据的恒久任务 |
|---|
| | | */ |
|---|
| | | public class ToRtuConstantTask extends CoreTask { |
|---|
| | | |
|---|
| | | private static Logger log = LogManager.getLogger(ToRtuConstantTask.class.getName()); |
|---|
| | | private static final Logger log = LogManager.getLogger(ToRtuConstantTask.class.getName()); |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 在单线程环境中运行 |
|---|
| | |
|---|
| | | } |
|---|
| | | /** |
|---|
| | | * 处理缓存的下行命令节点 |
|---|
| | | * @param now |
|---|
| | | * @param first |
|---|
| | | * @param last |
|---|
| | | * @param now 当前时刻 |
|---|
| | | * @param first 第一个节点 |
|---|
| | | * @param last 是后一个节点 |
|---|
| | | */ |
|---|
| | | private void doDealDownCommand(Long now, Node first, Node last){ |
|---|
| | | if(first != null){ |
|---|
| | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 处理一个节点 |
|---|
| | | * @param now |
|---|
| | | * @param node |
|---|
| | | * @param now 现在时刻 |
|---|
| | | * @param node 节点 |
|---|
| | | */ |
|---|
| | | private void dealNode(Long now, Node node){ |
|---|
| | | TcpDownCommandObj obj = (TcpDownCommandObj)node.obj ; |
|---|
