|
@@ -1,22 +1,13 @@
|
|
|
import json
|
|
|
import logging
|
|
|
-import os
|
|
|
+import threading
|
|
|
|
|
|
-import apns2
|
|
|
-import boto3
|
|
|
-import botocore
|
|
|
-import jpush as jpush
|
|
|
-from botocore import client
|
|
|
from django.http import JsonResponse
|
|
|
from django.views.generic.base import View
|
|
|
-from pyfcm import FCMNotification
|
|
|
|
|
|
-from AnsjerPush.config import AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY
|
|
|
-from AnsjerPush.config import JPUSH_CONFIG, FCM_CONFIG, APNS_CONFIG, BASE_DIR, APNS_MODE
|
|
|
from Object.RedisObject import RedisObject
|
|
|
-from Service.CommonService import CommonService
|
|
|
from Service.DevicePushService import DevicePushService
|
|
|
-from Service.PushService import PushObject
|
|
|
+TIME_LOGGER = logging.getLogger('time')
|
|
|
|
|
|
|
|
|
# 移动侦测V2接口
|
|
@@ -30,7 +21,8 @@ class NotificationV2View(View):
|
|
|
request.encoding = 'utf-8'
|
|
|
return self.validation(request.POST)
|
|
|
|
|
|
- def validation(self, request_dict):
|
|
|
+ @staticmethod
|
|
|
+ def validation(request_dict):
|
|
|
"""
|
|
|
设备触发报警消息推送
|
|
|
@param request_dict:uidToken 加密uid
|
|
@@ -39,11 +31,15 @@ class NotificationV2View(View):
|
|
|
@param request_dict:n_time 设备触发报警时间
|
|
|
@param request_dict:event_type 设备事件类型
|
|
|
@param request_dict:is_st 文件类型(0:无,1:图片,2:视频)
|
|
|
- @param request_dict:region 文件存储区域(1:国外,2国内)
|
|
|
+ @param request_dict:region 文件存储区域(1:国外, 2:国内)
|
|
|
@param request_dict:electricity 电量值
|
|
|
+ @param request_dict:time_token 时间戳token
|
|
|
+ @param request_dict:uid uid
|
|
|
+ @param request_dict:dealings_type 往来检测 1:来,2:离开
|
|
|
+ @param request_dict:detection 检测类型 0:普通,1:算法
|
|
|
"""
|
|
|
logger = logging.getLogger('info')
|
|
|
- logger.info('移动侦测V2接口参数:{}'.format(request_dict))
|
|
|
+ logger.info('消息推送V2接口参数:{}'.format(request_dict))
|
|
|
uidToken = request_dict.get('uidToken', None)
|
|
|
etk = request_dict.get('etk', None)
|
|
|
channel = request_dict.get('channel', '1')
|
|
@@ -52,74 +48,70 @@ class NotificationV2View(View):
|
|
|
is_st = request_dict.get('is_st', None)
|
|
|
region = request_dict.get('region', None)
|
|
|
electricity = request_dict.get('electricity', '')
|
|
|
- time_token = request_dict.get('time_token', None)
|
|
|
- uid = request_dict.get('uid', None)
|
|
|
- # 往来检测 1:来,2:离开
|
|
|
- dealings_type = request_dict.get('dealingsType', 0)
|
|
|
- # 检测类型 0:普通,1:算法
|
|
|
+ dealings_type = int(request_dict.get('dealingsType', 0))
|
|
|
detection = int(request_dict.get('detection', 0))
|
|
|
|
|
|
+ # 参数校验
|
|
|
if not all([channel, n_time]):
|
|
|
- return JsonResponse(status=200, data={
|
|
|
- 'code': 444,
|
|
|
- 'msg': 'param is wrong'})
|
|
|
+ return JsonResponse(status=200, data={'code': 444, 'msg': 'param is wrong'})
|
|
|
if not region or not is_st:
|
|
|
return JsonResponse(status=200, data={'code': 404, 'msg': 'no region or is_st'})
|
|
|
- # 时间戳token校验
|
|
|
- if time_token:
|
|
|
- if not CommonService.check_time_stamp_token(time_token, n_time):
|
|
|
- return JsonResponse(status=200, data={'code': 13, 'msg': 'Timestamp token verification failed'})
|
|
|
- redisObj = RedisObject(db=6)
|
|
|
+
|
|
|
+ is_st = int(is_st)
|
|
|
+ region = int(region)
|
|
|
+ event_type = int(event_type)
|
|
|
+ redis_obj = RedisObject()
|
|
|
try:
|
|
|
- is_st = int(is_st)
|
|
|
- region = int(region)
|
|
|
- event_type = int(event_type)
|
|
|
- if not uid:
|
|
|
- uid = DevicePushService.decode_uid(etk, uidToken) # 解密uid
|
|
|
+ uid = DevicePushService.decode_uid(etk, uidToken)
|
|
|
if len(uid) != 20 and len(uid) != 14:
|
|
|
return JsonResponse(status=200, data={'code': 404, 'msg': 'wrong uid'})
|
|
|
- req_limiting = '{uid}_{channel}_{event_type}_ptl' \
|
|
|
- .format(uid=uid, channel=channel, event_type=event_type)
|
|
|
- is_sys_msg = self.is_sys_msg(int(event_type)) # 判断事件类型是否是系统消息
|
|
|
+ TIME_LOGGER.info('开始推送,uid:{},n_time:{},事件类型:{}'.format(uid, n_time, event_type))
|
|
|
+ # 判断是否为系统消息
|
|
|
+ is_sys_msg = DevicePushService.judge_sys_msg(int(event_type))
|
|
|
if is_sys_msg:
|
|
|
- push_interval = '{uid}_{channel}_{event_type}_flag' \
|
|
|
- .format(uid=uid, channel=channel, event_type=event_type)
|
|
|
+ push_interval = '{uid}_{channel}_{event_type}_flag'.format(uid=uid, channel=channel,
|
|
|
+ event_type=event_type)
|
|
|
else:
|
|
|
push_interval = '{uid}_{channel}_flag'.format(uid=uid, channel=channel)
|
|
|
|
|
|
- cache_req_limiting = redisObj.get_data(key=req_limiting) # 获取请求限流缓存数据
|
|
|
- cache_app_push = redisObj.get_data(key=push_interval) # 获取APP推送消息时间间隔缓存数据
|
|
|
- logger.info('消息推送- 限流key: {}, 推送间隔key: {}'.
|
|
|
- format(cache_req_limiting, cache_app_push))
|
|
|
- if event_type != 606:
|
|
|
+ req_limiting = '{uid}_{channel}_{event_type}_ptl'.format(uid=uid, channel=channel, event_type=event_type)
|
|
|
+ cache_req_limiting = redis_obj.get_data(key=req_limiting) # 获取请求限流缓存数据
|
|
|
+ cache_app_push = redis_obj.get_data(key=push_interval) # 获取APP推送消息时间间隔缓存数据
|
|
|
+ if event_type not in [606, 607]:
|
|
|
if cache_req_limiting: # 限流存在则直接返回
|
|
|
return JsonResponse(status=200, data={'code': 0, 'msg': 'Push again in one minute'})
|
|
|
- redisObj.set_data(key=req_limiting, val=1, expire=60) # 当缓存不存在限流数据 重新设置一分钟请求一次
|
|
|
- uid_push_qs = DevicePushService.query_uid_push(uid, event_type) # 查询uid_set与push数据列表
|
|
|
+ redis_obj.set_data(key=req_limiting, val=1, expire=60) # 当缓存不存在限流数据 重新设置一分钟请求一次
|
|
|
+
|
|
|
+ # 查询uid_push和uid_set数据
|
|
|
+ uid_push_qs = DevicePushService.query_uid_push(uid, event_type)
|
|
|
if not uid_push_qs.exists():
|
|
|
logger.info('消息推送-{}uid_push数据不存在'.format(uid))
|
|
|
return JsonResponse(status=200, data={'code': 176, 'msg': 'no uid_push data'})
|
|
|
+
|
|
|
ai_type = uid_push_qs.first()['uid_set__ai_type']
|
|
|
device_type = uid_push_qs.first()['uid_set__device_type']
|
|
|
- logger.info('ai_type: {}, device_type: {}'.format(ai_type, device_type))
|
|
|
- # 将uid_set以及uid_push 转数组列表
|
|
|
- uid_set_push_list = DevicePushService.cache_uid_push(uid_push_qs)
|
|
|
+
|
|
|
+ # uid_push_qs转存列表
|
|
|
+ uid_set_push_list = DevicePushService.qs_to_list(uid_push_qs)
|
|
|
nickname = uid_set_push_list[0]['uid_set__nickname']
|
|
|
nickname = uid if not nickname else nickname
|
|
|
+
|
|
|
# APP消息提醒推送间隔
|
|
|
detect_interval = uid_set_push_list[0]['uid_set__detect_interval']
|
|
|
- if event_type != 606:
|
|
|
+ if event_type not in [606, 607]:
|
|
|
if not cache_app_push:
|
|
|
# 缓存APP提醒推送间隔 默认1分钟提醒一次
|
|
|
- DevicePushService.cache_push_detect_interval(redisObj, push_interval, detect_interval,
|
|
|
+ DevicePushService.cache_push_detect_interval(redis_obj, push_interval, detect_interval,
|
|
|
uid_set_push_list[0]['uid_set__new_detect_interval'])
|
|
|
else:
|
|
|
cache_app_push = ''
|
|
|
+
|
|
|
bucket = ''
|
|
|
aws_s3_client = ''
|
|
|
if is_st == 1 or is_st == 3: # 使用aws s3
|
|
|
- aws_s3_client = s3_client(region=region)
|
|
|
+ aws_s3_client = DevicePushService.get_s3_client(region=region)
|
|
|
bucket = 'foreignpush' if region == 1 else 'push'
|
|
|
+
|
|
|
kwag_args = {
|
|
|
'uid': uid,
|
|
|
'channel': channel,
|
|
@@ -130,18 +122,22 @@ class NotificationV2View(View):
|
|
|
'is_sys_msg': is_sys_msg, 'channel': channel, 'event_type': event_type, 'n_time': n_time,
|
|
|
'electricity': electricity, 'bucket': bucket, 'aws_s3_client': aws_s3_client,
|
|
|
'app_push': cache_app_push, 'storage_location': 2, 'ai_type': ai_type, 'device_type': device_type,
|
|
|
- 'dealings_type': int(dealings_type), 'detection': detection}
|
|
|
- logger.info('推送数据参数:{}'.format(params))
|
|
|
- # 推送消息,生成推送数据列表
|
|
|
- result = DevicePushService.save_msg_push(uid_set_push_list, **params)
|
|
|
- # 保存推送数据
|
|
|
- DevicePushService.save_sys_msg(is_sys_msg, result['local_date_time'],
|
|
|
- result['sys_msg_list'], result['new_device_info_list'])
|
|
|
+ 'dealings_type': dealings_type, 'detection': detection,
|
|
|
+ 'app_push_config': uid_set_push_list[0]['uid_set__msg_notify']}
|
|
|
+
|
|
|
+ # 异步推送消息和保存数据
|
|
|
+ push_thread = threading.Thread(
|
|
|
+ target=push_and_save_data,
|
|
|
+ args=(uid_set_push_list, is_sys_msg),
|
|
|
+ kwargs=params)
|
|
|
+ push_thread.start()
|
|
|
+
|
|
|
params['aws_s3_client'] = aws_s3_client
|
|
|
params['uid_set_push_list'] = uid_set_push_list
|
|
|
- params['code_dict'] = result
|
|
|
+
|
|
|
result_dict = DevicePushService.get_push_url(**params) # 获取S3对象上传链接
|
|
|
- logger.info('{}触发时间{},推送URL{}'.format(uid, n_time, json.dumps(result_dict)))
|
|
|
+ TIME_LOGGER.info('推送响应,uid:{},n_time:{},事件类型:{},响应:{}'.format(
|
|
|
+ uid, n_time, event_type, json.dumps(result_dict)))
|
|
|
return JsonResponse(status=200, data=result_dict)
|
|
|
except Exception as e:
|
|
|
logger.info('V2推送接口异常, errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|
|
@@ -151,208 +147,14 @@ class NotificationV2View(View):
|
|
|
}
|
|
|
return JsonResponse(status=200, data=json.dumps(data), safe=False)
|
|
|
|
|
|
- @classmethod
|
|
|
- def get_combo_msg_type(cls, ai_type, event_type):
|
|
|
- """
|
|
|
- 获取组合类型,需判断组合类型
|
|
|
- """
|
|
|
- logger = logging.getLogger('info')
|
|
|
- try:
|
|
|
- if ai_type == 0:
|
|
|
- return event_type
|
|
|
- logger.info('LOG------算法小店组合类型十进制值:{}'.format(event_type))
|
|
|
- # 设备十进制算法说明:1:移动侦测,2:人形,4:车型,8:人脸,16:宠物,32:异响,64:区域闯入,
|
|
|
- # 128:区域闯出,256:徘徊检测,512:长时间无人检测
|
|
|
- event_dict = {
|
|
|
- 1: 51,
|
|
|
- 2: 57,
|
|
|
- 4: 58,
|
|
|
- 16: 59,
|
|
|
- 8: 60,
|
|
|
- 32: 61,
|
|
|
- 64: 62,
|
|
|
- 128: 63,
|
|
|
- 256: 64,
|
|
|
- 512: 65
|
|
|
- }
|
|
|
- event_val = event_dict.get(event_type, 0)
|
|
|
- # event_val == 0 没有匹配到单个值则认为组合类型
|
|
|
- # 如是3,则转为二进制11,代表(1+2)触发了移动侦测+人形侦测
|
|
|
- if event_val == 0:
|
|
|
- val = cls.dec_to_bin(event_type)
|
|
|
- return int(val)
|
|
|
- else:
|
|
|
- return int(event_val)
|
|
|
- except Exception as e:
|
|
|
- logger.info('推送错误异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|
|
|
- return event_type
|
|
|
-
|
|
|
- @staticmethod
|
|
|
- def dec_to_bin(num):
|
|
|
- """
|
|
|
- 十进制转二进制
|
|
|
- """
|
|
|
- result = ""
|
|
|
- while num != 0:
|
|
|
- ret = num % 2
|
|
|
- num //= 2
|
|
|
- result = str(ret) + result
|
|
|
- return result
|
|
|
-
|
|
|
- def push_thread_test(self, push_type, aws_s3_client, bucket, key, uid, appBundleId, token_val, event_type, n_time,
|
|
|
- msg_title, msg_text, channel):
|
|
|
- logger = logging.getLogger('info')
|
|
|
- logger.info('推送图片测试:{} {} {} {} {} {} {} {}'.format(push_type, uid, appBundleId, token_val, event_type, n_time,
|
|
|
- msg_title, msg_text))
|
|
|
- try:
|
|
|
- image_url = aws_s3_client.generate_presigned_url('get_object', Params={'Bucket': bucket, 'Key': key},
|
|
|
- ExpiresIn=300)
|
|
|
- logger.info('推送图片url:{}'.format(image_url))
|
|
|
- if push_type == 0:
|
|
|
- PushObject.ios_apns_push(uid, appBundleId, token_val, n_time, event_type, msg_title, msg_text,
|
|
|
- uid, channel, image_url)
|
|
|
- elif push_type == 1:
|
|
|
- PushObject.android_fcm_push(uid, appBundleId, token_val, n_time, event_type, msg_title,
|
|
|
- msg_text, uid, channel, image_url)
|
|
|
- except Exception as e:
|
|
|
- logger.info('推送图片测试异常:{}'.format(e))
|
|
|
-
|
|
|
- @staticmethod
|
|
|
- def is_sys_msg(event_type):
|
|
|
- """
|
|
|
- 判断是否属于系统消息
|
|
|
- @return: True | False
|
|
|
- """
|
|
|
- event_type_list = [702, 703, 704]
|
|
|
- if event_type in event_type_list:
|
|
|
- return True
|
|
|
- return False
|
|
|
-
|
|
|
- def get_msg_text(self, channel, n_time, lang, tz, event_type, electricity='', is_sys=0):
|
|
|
- n_date = CommonService.get_now_time_str(n_time=n_time, tz=tz, lang=lang)
|
|
|
- etype = int(event_type)
|
|
|
- if lang == 'cn':
|
|
|
- if etype == 704:
|
|
|
- msg_type = '剩余电量 ' + electricity
|
|
|
- elif etype == 702:
|
|
|
- msg_type = '摄像头休眠'
|
|
|
- elif etype == 703:
|
|
|
- msg_type = '摄像头唤醒'
|
|
|
- else:
|
|
|
- msg_type = ''
|
|
|
- if is_sys:
|
|
|
- send_text = '{msg_type} 通道:{channel}'.format(msg_type=msg_type, channel=channel)
|
|
|
- else:
|
|
|
- send_text = '{msg_type} 通道:{channel} 日期:{date}'.format(msg_type=msg_type, channel=channel, date=n_date)
|
|
|
- else:
|
|
|
- if etype == 704:
|
|
|
- msg_type = 'Battery remaining ' + electricity
|
|
|
- elif etype == 702:
|
|
|
- msg_type = 'Camera sleep'
|
|
|
- elif etype == 703:
|
|
|
- msg_type = 'Camera wake'
|
|
|
- else:
|
|
|
- msg_type = ''
|
|
|
- if is_sys:
|
|
|
- send_text = '{msg_type} channel:{channel}'. \
|
|
|
- format(msg_type=msg_type, channel=channel)
|
|
|
- else:
|
|
|
- send_text = '{msg_type} channel:{channel} date:{date}'. \
|
|
|
- format(msg_type=msg_type, channel=channel, date=n_date)
|
|
|
- return send_text
|
|
|
-
|
|
|
- def do_jpush(self, uid, channel, appBundleId, token_val, event_type, n_time,
|
|
|
- msg_title, msg_text):
|
|
|
- app_key = JPUSH_CONFIG[appBundleId]['Key']
|
|
|
- master_secret = JPUSH_CONFIG[appBundleId]['Secret']
|
|
|
- _jpush = jpush.JPush(app_key, master_secret)
|
|
|
- push = _jpush.create_push()
|
|
|
- push.audience = jpush.registration_id(token_val)
|
|
|
- push_data = {"alert": "Motion ", "event_time": n_time, "event_type": event_type, "msg": "",
|
|
|
- "received_at": n_time, "sound": "sound.aif", "uid": uid, "zpush": "1", "channel": channel}
|
|
|
- android = jpush.android(alert=msg_text, priority=1, style=1, alert_type=7,
|
|
|
- big_text=msg_text, title=msg_title,
|
|
|
- extras=push_data)
|
|
|
- push.notification = jpush.notification(android=android)
|
|
|
- push.platform = jpush.all_
|
|
|
- res = push.send()
|
|
|
- print(res)
|
|
|
- return res.status_code
|
|
|
-
|
|
|
- def do_fcm(self, uid, channel, appBundleId, token_val, event_type, n_time, msg_title, msg_text):
|
|
|
- logger = logging.getLogger('info')
|
|
|
- try:
|
|
|
- serverKey = FCM_CONFIG[appBundleId]
|
|
|
- except Exception as e:
|
|
|
- logger.info('------fcm_error:{}'.format(repr(e)))
|
|
|
- return 'serverKey abnormal'
|
|
|
- push_service = FCMNotification(api_key=serverKey)
|
|
|
- data = {"alert": "Motion ", "event_time": n_time, "event_type": event_type, "msg": "",
|
|
|
- "received_at": n_time, "sound": "sound.aif", "uid": uid, "zpush": "1", "channel": channel}
|
|
|
- result = push_service.notify_single_device(registration_id=token_val, message_title=msg_title,
|
|
|
- message_body=msg_text, data_message=data,
|
|
|
- extra_kwargs={
|
|
|
- 'default_vibrate_timings': True,
|
|
|
- 'default_sound': True,
|
|
|
- 'default_light_settings': True
|
|
|
- })
|
|
|
- return result
|
|
|
-
|
|
|
- def do_apns(self, uid, channel, appBundleId, token_val, event_type, n_time, msg_title,
|
|
|
- msg_text):
|
|
|
- logger = logging.getLogger('info')
|
|
|
- logger.info("进来do_apns函数了")
|
|
|
- logger.info(token_val)
|
|
|
- logger.info(APNS_MODE)
|
|
|
- logger.info(os.path.join(BASE_DIR, APNS_CONFIG[appBundleId]['pem_path']))
|
|
|
- try:
|
|
|
- cli = apns2.APNSClient(mode=APNS_MODE,
|
|
|
- client_cert=os.path.join(BASE_DIR, APNS_CONFIG[appBundleId]['pem_path']))
|
|
|
-
|
|
|
- push_data = {"alert": "Motion ", "event_time": n_time, "event_type": event_type, "msg": "",
|
|
|
- "received_at": n_time, "sound": "", "uid": uid, "zpush": "1", "channel": channel}
|
|
|
- alert = apns2.PayloadAlert(body=msg_text, title=msg_title)
|
|
|
- payload = apns2.Payload(alert=alert, custom=push_data, sound="default")
|
|
|
-
|
|
|
- # return uid, channel, appBundleId, str(token_val), event_type, n_time, msg_title,msg_text
|
|
|
- n = apns2.Notification(payload=payload, priority=apns2.PRIORITY_LOW)
|
|
|
- res = cli.push(n=n, device_token=token_val, topic=appBundleId)
|
|
|
- print(res.status_code)
|
|
|
- logger.info("apns_推送状态:")
|
|
|
- logger.info(res.status_code)
|
|
|
-
|
|
|
- if res.status_code == 200:
|
|
|
- return res.status_code
|
|
|
- else:
|
|
|
- print('apns push fail')
|
|
|
- print(res.reason)
|
|
|
- logger.info('apns push fail')
|
|
|
- logger.info(res.reason)
|
|
|
- return res.status_code
|
|
|
- except (ValueError, ArithmeticError):
|
|
|
- return 'The program has a numeric format exception, one of the arithmetic exceptions'
|
|
|
- except Exception as e:
|
|
|
- print(repr(e))
|
|
|
- print('do_apns函数错误行号', e.__traceback__.tb_lineno)
|
|
|
- logger.info('do_apns错误:{}'.format(repr(e)))
|
|
|
- return repr(e)
|
|
|
|
|
|
+def push_and_save_data(uid_set_push_list, is_sys_msg, **params):
|
|
|
+ # 推送消息,生成推送数据列表
|
|
|
+ result = DevicePushService.save_msg_push(uid_set_push_list, **params)
|
|
|
+ # 保存推送数据
|
|
|
+ DevicePushService.save_sys_msg(
|
|
|
+ is_sys_msg,
|
|
|
+ result['local_date_time'],
|
|
|
+ result['sys_msg_list'],
|
|
|
+ result['new_device_info_list'])
|
|
|
|
|
|
-def s3_client(region):
|
|
|
- if region == 2: # 国内
|
|
|
- aws_s3_client = boto3.client(
|
|
|
- 's3',
|
|
|
- aws_access_key_id=AWS_ACCESS_KEY_ID[0],
|
|
|
- aws_secret_access_key=AWS_SECRET_ACCESS_KEY[0],
|
|
|
- config=botocore.client.Config(signature_version='s3v4'),
|
|
|
- region_name='cn-northwest-1'
|
|
|
- )
|
|
|
- else: # 国外
|
|
|
- aws_s3_client = boto3.client(
|
|
|
- 's3',
|
|
|
- aws_access_key_id=AWS_ACCESS_KEY_ID[1],
|
|
|
- aws_secret_access_key=AWS_SECRET_ACCESS_KEY[1],
|
|
|
- config=botocore.client.Config(signature_version='s3v4'),
|
|
|
- region_name='us-east-1'
|
|
|
- )
|
|
|
- return aws_s3_client
|