|
@@ -145,19 +145,14 @@ class LogManagementView(View):
|
|
return response.json(500, repr(e))
|
|
return response.json(500, repr(e))
|
|
|
|
|
|
def requestPublishMqtt(self, request_dict, response):
|
|
def requestPublishMqtt(self, request_dict, response):
|
|
- # 通用发布主题通知
|
|
|
|
- uid = request_dict.get('uid', None)
|
|
|
|
|
|
+ # 通用发布MQTT主题通知
|
|
msg = request_dict.get('msg', None)
|
|
msg = request_dict.get('msg', None)
|
|
thing_name = request_dict.get('thing_name', None)
|
|
thing_name = request_dict.get('thing_name', None)
|
|
topic_name = request_dict.get('topic_name', None)
|
|
topic_name = request_dict.get('topic_name', None)
|
|
- if not all([uid, msg, thing_name, topic_name]):
|
|
|
|
|
|
+ if not all([msg, thing_name, topic_name]):
|
|
return response.json(444)
|
|
return response.json(444)
|
|
|
|
|
|
try:
|
|
try:
|
|
- # 设备没被添加不发送
|
|
|
|
- device_info_qs = Device_Info.objects.filter(UID=uid).values('UID', 'serial_number')
|
|
|
|
- if not device_info_qs.exists():
|
|
|
|
- return response.json(10043)
|
|
|
|
# 获取数据组织将要请求的url
|
|
# 获取数据组织将要请求的url
|
|
iot = iotdeviceInfoModel.objects.filter(thing_name=thing_name).values('endpoint', 'token_iot_number')
|
|
iot = iotdeviceInfoModel.objects.filter(thing_name=thing_name).values('endpoint', 'token_iot_number')
|
|
if not iot.exists():
|
|
if not iot.exists():
|
|
@@ -181,8 +176,6 @@ class LogManagementView(View):
|
|
return response.json(0)
|
|
return response.json(0)
|
|
return response.json(10044)
|
|
return response.json(10044)
|
|
else:
|
|
else:
|
|
- # print('发布失败')
|
|
|
|
return response.json(10044)
|
|
return response.json(10044)
|
|
except Exception as e:
|
|
except Exception as e:
|
|
- # print(e)
|
|
|
|
return response.json(500, repr(e))
|
|
return response.json(500, repr(e))
|