采用模拟软件MQTTX进行模拟测试，发现并修改MQTT相关水肥机上行数据与下行命令逻辑bug.

liurunyu

2025-06-23 431bbfaddba9f39496359bc0c1e2dcaf2bb6fca2

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

New file
@@ -0,0 +1,70 @@
package com.dy.rtuMw.server.tasks;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import com.dy.common.mw.core.CoreTask;
import com.dy.common.mw.protocol.MidResult;
import com.dy.common.mw.protocol.Command;
import com.dy.common.mw.protocol.Driver;
import com.dy.common.mw.protocol.ProtocolCache;
import com.dy.rtuMw.server.ServerProperties;
import com.dy.rtuMw.server.forTcp.TcpSessionCache;

/**
 * 从web业务系统发向RTU的命令任务
 * @author Administrator
 *
 */
public class WebDownComTask extends CoreTask {
	
   private static Logger log = LogManager.getLogger(WebDownComTask.class.getName());

   @Override
   public Integer execute() {
      Command com = (Command)this.data ;
      try {
         log.info("下发远程命令" + com.getCode() + "的核心任务开始执行");
         this.deal(com);
      } catch (Exception e) {
         log.error("处理下行命令出错" + (e.getMessage()==null?"!":("，" + e.getMessage())) ,e);
      }
      return null ;
   }
	
   /**
    * 处理命令
    * @param com 命令
    * @throws Exception
    */
   private void deal(Command com) throws Exception{
      String rtuAddr = com.getRtuAddr() ;
      //前面已经判断rtuAddr为空情况，至此其不为空
      Driver dri = null ;
      Object[] objs =  TcpSessionCache.getTcpProtocolNameVersion(rtuAddr) ;
      if(objs == null || objs.length == 0 || objs[0] == null){
         //RTU未曾上线
         int count = ProtocolCache.driverCount() ;
         if(count == 1){
            //只有一个协议
            dri = ProtocolCache.getFirstDriver() ;
         }
      }else{
         String protocolName = (String)objs[0];
         com.protocolVersion = (Short)objs[1];
         dri = ProtocolCache.getDriver(protocolName, com.protocolVersion) ;
      }
      if(dri == null){
         log.error("严重错误，未能得到RTU(" + rtuAddr + ")驱动类实例！");
      }else{
         MidResult[] actions = dri.createCommand(ServerProperties.isLowPower, com)  ;
         log.info("下发远程命令" + com.getCode() + "由协议驱动构造完成");
         if(actions != null){
            for(MidResult act : actions){
               act.action();
            }
         }
      }
   }

}