package com.dy.rtuMw.server.tasks;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
import com.dy.common.queue.Node;
|
import com.dy.common.mw.core.CoreTask;
|
import com.dy.rtuMw.server.forTcp.TcpDownCommandCache;
|
import com.dy.rtuMw.server.forTcp.TcpDownCommandObj;
|
import com.dy.rtuMw.server.forTcp.TcpSessionCache;
|
|
/**
|
* 处理RTU下行命令数据的恒久任务
|
*/
|
public class ToRtuConstantTask extends CoreTask {
|
private static final Logger log = LogManager.getLogger(ToRtuConstantTask.class.getName());
|
|
/**
|
* 在单线程环境中运行
|
*/
|
@Override
|
public Integer execute() {
|
try{
|
dealTcpSession() ;
|
}catch(Exception e){
|
log.error("更新RTU会话上报数据时刻时发生集合操作异常，此异常并不影响系统正常运行", e);
|
}
|
try{
|
//log.info("当前下行命令队列中还有结点数量：" + TcpDownCommandCache.size());
|
dealDownCom() ;
|
}catch(Exception e){
|
log.error(e);
|
}
|
return TcpDownCommandCache.size()>0?0:1 ;
|
}
|
/**
|
* 处理TCP缓存中的各个TCP Session的上行数据时刻
|
*/
|
private void dealTcpSession(){
|
TcpSessionCache.updateUpDataTime(System.currentTimeMillis() ) ;
|
}
|
|
|
/**
|
* 处理下行命令
|
*/
|
public void dealDownCom() {
|
Node first = TcpDownCommandCache.getFirstQueueNode() ;
|
if(first != null){
|
Node last = TcpDownCommandCache.getLastQueueNode() ;
|
while (last != null){
|
last = this.doDealDownComm(System.currentTimeMillis(), first, last);
|
}
|
}
|
}
|
/**
|
* 处理缓存的下行命令节点
|
* @param now 当前时刻
|
* @param first 第一个节点
|
* @param last 最后一个节点
|
*/
|
private Node doDealDownComm(Long now, Node first, Node last){
|
if(last != null){
|
//在dealNode方法中，可能要把last从队列中移除，这时last.pre为空，所以提前把last.pre取出来
|
Node pre = last.pre ;
|
dealNode(now, last) ;
|
if(first != last){
|
return pre ;
|
}else{
|
//停止
|
return null ;
|
}
|
}else{
|
return null ;
|
}
|
}
|
|
|
|
////////////////////////////////////////////////
|
//
|
//以下实现，采用了递归调用，当队列缓存结点很多时，会产生栈溢出异常
|
//
|
////////////////////////////////////////////////
|
/**
|
* 处理下行命令
|
public Integer dealDownCommand(Long now) {
|
Node first = TcpDownCommandCache.getFirstQueueNode() ;
|
if(first != null){
|
Integer count = TcpDownCommandCache.size() ;
|
Node last = TcpDownCommandCache.getLastQueueNode() ;
|
this.doDealDownCommand(now, first, last);
|
return count ;
|
}
|
return null ;
|
}
|
*/
|
/**
|
* 处理缓存的下行命令节点
|
* @param now 当前时刻
|
* @param first 第一个节点
|
* @param last 最后一个节点
|
private void doDealDownCommand1(Long now, Node first, Node last){
|
if(first != null){
|
//在dealNode方法中，可能要把first从队列中移除，这时first.next为空，所以提前把first.next取出来
|
Node next = first.next ;
|
dealNode(now, first) ;
|
if(last != null && first != last){
|
doDealDownCommand(now, next, last) ;
|
}else if(last != null && first == last){
|
//停止
|
}else if(last == null){
|
//这种情况不会存在
|
doDealDownCommand(now, next, last) ;
|
}
|
}
|
}
|
*/
|
/**
|
* 处理缓存的下行命令节点
|
* @param now 当前时刻
|
* @param first 第一个节点
|
* @param last 最后一个节点
|
private void doDealDownCommand(Long now, Node first, Node last){
|
if(last != null){
|
//在dealNode方法中，可能要把last从队列中移除，这时last.pre为空，所以提前把last.pre取出来
|
Node pre = last.pre ;
|
dealNode(now, last) ;
|
if(first != null && first != last){
|
doDealDownCommand(now, first, pre) ;
|
}else if(first != null && first == last){
|
//停止
|
}else if(first == null){
|
//这种情况不会存在
|
doDealDownCommand(now, null, pre) ;
|
}
|
}
|
}
|
*/
|
/**
|
* 处理一个节点
|
* @param now 现在时刻
|
* @param node 节点
|
*/
|
private void dealNode(Long now, Node node){
|
if(node != null && node.obj != null){
|
TcpDownCommandObj obj = (TcpDownCommandObj)node.obj ;
|
boolean removeNode = obj.dealSelf(now) ;
|
if(removeNode){
|
TcpDownCommandCache.removeNode(node);
|
}
|
}
|
}
|
|
|
}
|
