Merge remote-tracking branch 'origin/master'

zuoxiao

2025-06-25 d2fc819dc069c7b8d338ae52a90a7f38704fac08

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/tasks/RtuDownConstantTask.java

New file
@@ -0,0 +1,156 @@
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 RtuDownConstantTask extends CoreTask {
   private static final Logger log = LogManager.getLogger(RtuDownConstantTask.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.updateRtuStatus(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);
         }
      }
   }


}