|
@@ -81,7 +81,7 @@ class DetectControllerView(View):
|
|
if not qs.exists():
|
|
if not qs.exists():
|
|
return response.json(0, {'datas': [], 'count': 0})
|
|
return response.json(0, {'datas': [], 'count': 0})
|
|
qs = qs.values('id', 'devUid', 'devNickName', 'Channel', 'eventType', 'status', 'alarm', 'eventTime',
|
|
qs = qs.values('id', 'devUid', 'devNickName', 'Channel', 'eventType', 'status', 'alarm', 'eventTime',
|
|
- 'receiveTime','is_st')
|
|
|
|
|
|
+ 'receiveTime', 'is_st')
|
|
count = qs.count()
|
|
count = qs.count()
|
|
qr = qs[(page - 1) * line:page * line]
|
|
qr = qs[(page - 1) * line:page * line]
|
|
# send_json = CommonService.qs_to_dict(res)
|
|
# send_json = CommonService.qs_to_dict(res)
|
|
@@ -92,8 +92,8 @@ class DetectControllerView(View):
|
|
for p in qr:
|
|
for p in qr:
|
|
if p['is_st'] == '1':
|
|
if p['is_st'] == '1':
|
|
p['img'] = bucket.sign_url('GET',
|
|
p['img'] = bucket.sign_url('GET',
|
|
- '{uid}/{channel}/{time}.jpeg'.format(uid=p['devUid'], channel=p['Channel'],
|
|
|
|
- time=p['eventTime']), 300)
|
|
|
|
|
|
+ '{uid}/{channel}/{time}.jpeg'.format(uid=p['devUid'], channel=p['Channel'],
|
|
|
|
+ time=p['eventTime']), 300)
|
|
res.append(p)
|
|
res.append(p)
|
|
return response.json(0, {'datas': res, 'count': count})
|
|
return response.json(0, {'datas': res, 'count': count})
|
|
|
|
|
|
@@ -104,31 +104,31 @@ class DetectControllerView(View):
|
|
app_type = request_dict.get('app_type', None)
|
|
app_type = request_dict.get('app_type', None)
|
|
push_type = request_dict.get('push_type', None)
|
|
push_type = request_dict.get('push_type', None)
|
|
status = request_dict.get('status', None)
|
|
status = request_dict.get('status', None)
|
|
- m_code = request_dict.get('m_code',None)
|
|
|
|
|
|
+ m_code = request_dict.get('m_code', None)
|
|
print('status')
|
|
print('status')
|
|
print(status)
|
|
print(status)
|
|
if not status:
|
|
if not status:
|
|
- return response.json(444,'status')
|
|
|
|
|
|
+ return response.json(444, 'status')
|
|
if status == '0':
|
|
if status == '0':
|
|
- if not all([app_type,appBundleId,uid,m_code]):
|
|
|
|
- return response.json(444,'app_type,appBundleId,uid,m_code')
|
|
|
|
|
|
+ if not all([app_type, appBundleId, uid, m_code]):
|
|
|
|
+ return response.json(444, 'app_type,appBundleId,uid,m_code')
|
|
uid_app_qs = UID_App.objects.filter(appBundleId=appBundleId, userID_id=userID, m_code=m_code,
|
|
uid_app_qs = UID_App.objects.filter(appBundleId=appBundleId, userID_id=userID, m_code=m_code,
|
|
- uid=uid,app_type=app_type)
|
|
|
|
|
|
+ uid=uid, app_type=app_type)
|
|
if uid_app_qs.exists():
|
|
if uid_app_qs.exists():
|
|
uid_app_qs.update(status=0)
|
|
uid_app_qs.update(status=0)
|
|
return response.json(0)
|
|
return response.json(0)
|
|
else:
|
|
else:
|
|
return response.json(173)
|
|
return response.json(173)
|
|
elif status == '1':
|
|
elif status == '1':
|
|
- if not all([appBundleId,app_type,token_val,uid,m_code]):
|
|
|
|
- return response.json(444,'appBundleId,app_type,token_val,uid,m_code')
|
|
|
|
|
|
+ if not all([appBundleId, app_type, token_val, uid, m_code]):
|
|
|
|
+ return response.json(444, 'appBundleId,app_type,token_val,uid,m_code')
|
|
dvqs = Device_Info.objects.filter(userID_id=userID, UID=uid)
|
|
dvqs = Device_Info.objects.filter(userID_id=userID, UID=uid)
|
|
|
|
|
|
if dvqs.exists():
|
|
if dvqs.exists():
|
|
now_time = int(time.time())
|
|
now_time = int(time.time())
|
|
try:
|
|
try:
|
|
uid_app_qs = UID_App.objects.filter(appBundleId=appBundleId, userID_id=userID, token_val=token_val,
|
|
uid_app_qs = UID_App.objects.filter(appBundleId=appBundleId, userID_id=userID, token_val=token_val,
|
|
- uid=uid,m_code=m_code)
|
|
|
|
|
|
+ uid=uid, m_code=m_code)
|
|
print(uid_app_qs)
|
|
print(uid_app_qs)
|
|
if uid_app_qs.exists():
|
|
if uid_app_qs.exists():
|
|
uid_app_qs.update(status=1)
|
|
uid_app_qs.update(status=1)
|
|
@@ -141,6 +141,7 @@ class DetectControllerView(View):
|
|
push_type=push_type,
|
|
push_type=push_type,
|
|
token_val=token_val,
|
|
token_val=token_val,
|
|
status=1,
|
|
status=1,
|
|
|
|
+ m_code=m_code,
|
|
addTime=now_time,
|
|
addTime=now_time,
|
|
updTime=now_time)
|
|
updTime=now_time)
|
|
except Exception as e:
|
|
except Exception as e:
|
|
@@ -179,7 +180,7 @@ class NotificationView(View):
|
|
event_type = request_dict.get('event_type', None)
|
|
event_type = request_dict.get('event_type', None)
|
|
is_st = request_dict.get('is_st', None)
|
|
is_st = request_dict.get('is_st', None)
|
|
if not all([uidToken, channel, n_time]):
|
|
if not all([uidToken, channel, n_time]):
|
|
- return JsonResponse(status=404,data={})
|
|
|
|
|
|
+ return JsonResponse(status=404, data={})
|
|
# return response.json(444)
|
|
# return response.json(444)
|
|
utko = UidTokenObject(uidToken)
|
|
utko = UidTokenObject(uidToken)
|
|
uid = utko.UID
|
|
uid = utko.UID
|
|
@@ -197,7 +198,7 @@ class NotificationView(View):
|
|
# android jpush
|
|
# android jpush
|
|
elif push_type == 2:
|
|
elif push_type == 2:
|
|
self.do_jpush(request_dict, ua, response)
|
|
self.do_jpush(request_dict, ua, response)
|
|
- self.do_save_equipment_info(ua, n_time, channel, event_type,is_st)
|
|
|
|
|
|
+ self.do_save_equipment_info(ua, n_time, channel, event_type, is_st)
|
|
#############
|
|
#############
|
|
# 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
|
|
# 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
|
|
|
|
|
|
@@ -352,7 +353,7 @@ class NotificationView(View):
|
|
except Exception as e:
|
|
except Exception as e:
|
|
return response.json(10, repr(e))
|
|
return response.json(10, repr(e))
|
|
|
|
|
|
- def do_save_equipment_info(self, uaql, n_time, channel, event_type,is_st):
|
|
|
|
|
|
+ def do_save_equipment_info(self, uaql, n_time, channel, event_type, is_st):
|
|
Equipment_Info.objects.create(
|
|
Equipment_Info.objects.create(
|
|
userID_id=uaql['userID_id'],
|
|
userID_id=uaql['userID_id'],
|
|
eventTime=n_time,
|
|
eventTime=n_time,
|