1、修改获得绑定控制器的方法； 2、添加文档“取水口控制哭喊及测控数据关系”

liurunyu

2024-01-16 cef843b8175ab3775036f705f7cf69e4bd32c4f3

 pipIrr-platform/pipIrr-mw/pipIrr-mw-accept/src/main/java/com/dy/aceMw/server/tasks/ToRtuConstantTask.java

@@ -26,6 +26,7 @@
         log.error("更新RTU会话上报数据时刻时发生集合操作异常，此异常并不影响系统正常运行", e);
      }
      try{
         //log.info("当前下行命令队列中还有结点数量：" + TcpDownCommandCache.size());
         dealDownCom() ;
      }catch(Exception e){
         log.error(e);
@@ -60,10 +61,10 @@
    */
   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){
            //在dealNode方法中，可能要把last从队列中移除，这时last.pre为空，所以提前把last.pre取出来
            Node pre = last.pre ;
            dealNode(now, last) ;
            return pre ;
         }else{
            //停止
@@ -142,10 +143,12 @@
    * @param node 节点
    */
   private void dealNode(Long now, Node node){
      TcpDownCommandObj obj = (TcpDownCommandObj)node.obj ;
      boolean removeNode = obj.dealSelf(now) ;
      if(removeNode){
         TcpDownCommandCache.removeNode(node);
      if(node != null && node.obj != null){
         TcpDownCommandObj obj = (TcpDownCommandObj)node.obj ;
         boolean removeNode = obj.dealSelf(now) ;
         if(removeNode){
            TcpDownCommandCache.removeNode(node);
         }
      }
   }