|
|
@@ -370,7 +370,7 @@ class SmartSwitchView(View):
|
|
|
redis_obj.CONN.expire(task_id + 'do_notify', 60)
|
|
|
if not is_lock:
|
|
|
return
|
|
|
- result = CommonService.req_publish_mqtt_msg(serial_number, topic_name, msg, qos=2)
|
|
|
+ result = CommonService.req_publish_mqtt_msg(serial_number, topic_name, msg)
|
|
|
LOGGER.info('定时发送mqtt结果：{}，参数：{}，{}，{}，{}，{}，线程：{}，进程：{}'.format(result, serial_number, topic_name, msg,
|
|
|
now_time, task_id,
|
|
|
threading.get_ident(), os.getpid()))
|
