完善代码

liurunyu

2025-08-18 a2aaa19a13112d29c7b32ce2ca54cdc847d3a5ba

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol4Mqtt/MqttMsgParser.java

@@ -18,7 +18,7 @@
            if(topicGrp.length != 5){
                throw new Exception("接收的mqtt消息主题不可识别") ;
            }else{
                if(NumUtil.isPlusIntNumber(topicGrp[4])){
                if(!NumUtil.isPlusIntNumber(topicGrp[4])){
                    throw new Exception("接收的mqtt消息主题不可识别") ;
                }
                if(Integer.parseInt(topicGrp[4]) <= 0){
@@ -57,7 +57,7 @@
        if(com.protocolVersion == null){
            throw new Exception("接收到MQTT命令，但未提供协议版本号") ;
        }
        if(com.code != null && com.code.trim().length() != 0){
        if(com.code == null || com.code.trim().length() == 0){
            throw new Exception("接收到MQTT命令，但未提供功能码") ;
        }
        if(com.protocol.equals(ProtocolConstantSdV1.protocolName)){
@@ -73,7 +73,7 @@


    public static void main(String[] args) {
        String s = "ym/sd1/10000/control/m1" ;
        String s = "jyg/sd1/2430002404000840/weather/1" ;
        String[] ss = s.split("/") ;
        for (String s1 : ss) {
            System.out.println(s1);