소스 검색

优化发布MQTT消息

zhangdongming 2 년 전
부모
커밋
1ff169b1cc
1개의 변경된 파일3개의 추가작업 그리고 1개의 파일을 삭제
  1. 3 1
      Controller/EquipmentManagerV3.py

+ 3 - 1
Controller/EquipmentManagerV3.py

@@ -92,7 +92,9 @@ class EquipmentManagerV3(View):
             topic_name = f'/wakeup/{serial_number}_0'
             # 发布消息内容
             msg = {'payload': 'A'}
-            CommonService.req_publish_mqtt_msg(serial_number, topic_name, msg)
+            result = CommonService.req_publish_mqtt_msg(serial_number, topic_name, msg)
+            if not result:
+                return response.json(10044)
             return response.json(0)
         except Exception as e:
             LOGGER.info('****设备唤醒发布消息异常:{},{}'.format(serial_number, repr(e)))