|
@@ -85,14 +85,15 @@ class EquipmentMessagePushView(View):
|
|
|
qs_data['new_detect_interval'] = int(interval)
|
|
|
qs_data['is_notification'] = status
|
|
|
UidSetModel.objects.create(**qs_data)
|
|
|
- if uid_set_qs.exists() and status == 1:
|
|
|
- qs_data = {
|
|
|
- 'updTime': n_time,
|
|
|
- }
|
|
|
- if interval:
|
|
|
- qs_data['new_detect_interval'] = int(interval)
|
|
|
- qs_data['is_notification'] = status
|
|
|
- uid_set_qs.update(**qs_data)
|
|
|
+ if status == 1:
|
|
|
+ if uid_set_qs.exists():
|
|
|
+ qs_data = {
|
|
|
+ 'updTime': n_time,
|
|
|
+ }
|
|
|
+ if interval:
|
|
|
+ qs_data['new_detect_interval'] = int(interval)
|
|
|
+ qs_data['is_notification'] = status
|
|
|
+ uid_set_qs.update(**qs_data)
|
|
|
if status == 0:
|
|
|
ai_service_qs = AiService.objects.filter(uid=uid, use_status=1)
|
|
|
if ai_service_qs.exists():
|
|
@@ -105,7 +106,7 @@ class EquipmentMessagePushView(View):
|
|
|
logger.info("推送>>>> mqtt回调:{}".format(req_success))
|
|
|
if uid_set_qs.exists():
|
|
|
uid_set_data = {'updTime': n_time, 'uid': uid, 'new_detect_interval': int(interval),
|
|
|
- 'detect_status': int(interval)}
|
|
|
+ 'detect_status': int(interval), 'is_notification': status}
|
|
|
uid_set_qs.update(**uid_set_data)
|
|
|
return response.json(0)
|
|
|
except Exception as e:
|