作者 钟来

模块整理

@@ -106,6 +106,7 @@ public class MqttCallback implements MqttCallbackExtended { @@ -106,6 +106,7 @@ public class MqttCallback implements MqttCallbackExtended {
106 ServerDto dto = businessAgreement.analysis(topic,businessAgreement.toData(businessDto)); 106 ServerDto dto = businessAgreement.analysis(topic,businessAgreement.toData(businessDto));
107 if(null == dto) 107 if(null == dto)
108 { 108 {
  109 + terminalService.publish(TopicUtil.generateSendMessageTopic(topic),"2");
109 return; 110 return;
110 } 111 }
111 log.info("{} 解析到的dto【{}】",dto); 112 log.info("{} 解析到的dto【{}】",dto);