修改用水户年用水量统计查询中的bug

liurunyu

2025-07-30 3cbb266f1f8ad0553087eb72b67c61364818e91d

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/tcp/TcpIoHandler.java

@@ -8,9 +8,18 @@

   private TcpUnitAdapter adapter ;

   private boolean stop = false ;//为true时，停止TCP服务，并把已经TCP连接断连接

   public TcpIoHandler(TcpUnitAdapter adapter){
      this.adapter = adapter ;
   }

   public void stop(){
      stop = true ;
   }

   public void recover(){
      this.stop = false ;
   }

   /**
@@ -18,14 +27,22 @@
    */
   @Override
   public void sessionCreated(IoSession session) throws Exception {
      super.sessionCreated(session);
      if(stop){
         session.closeNow() ;
      }else{
         super.sessionCreated(session);
      }
   }
   
   /**
     * 会话open时回调的方法 
     */
    public void sessionOpened(IoSession session) throws Exception {
       this.adapter.newSessionEventCallback().sessionOpened(session);
      if(stop){
         session.closeNow() ;
      }else{
         this.adapter.newSessionEventCallback().sessionOpened(session);
      }
    }
    
   /**
@@ -76,7 +93,11 @@
     */
   @Override
    public void messageReceived(IoSession session, Object message) throws Exception {
       this.adapter.newSessionEventCallback().messageReceived(session, message);
      if(stop){
         session.closeNow() ;
      }else{
         this.adapter.newSessionEventCallback().messageReceived(session, message);
      }
    }

}