DevicePushService.py 46 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037
  1. # -*- encoding: utf-8 -*-
  2. """
  3. @File : DevicePushService.py
  4. @Time : 2022/11/23 11:40
  5. @Author : stephen
  6. @Email : zhangdongming@asj6.wecom.work
  7. @Software: PyCharm
  8. """
  9. import datetime
  10. import hashlib
  11. import json
  12. import logging
  13. import threading
  14. import time
  15. import boto3
  16. import botocore
  17. import oss2
  18. import requests
  19. from obs import ObsClient
  20. from AnsjerPush.Config.aiConfig import DEVICE_EVENT_TYPE, ALGORITHM_COMBO_TYPES
  21. from AnsjerPush.config import CONFIG_INFO, CONFIG_CN, MULTI_CHANNEL_TYPE_LIST, SYS_EVENT_TYPE_LIST, AWS_ACCESS_KEY_ID, \
  22. AWS_SECRET_ACCESS_KEY, EVENT_DICT, EVENT_DICT_CN, CONFIG_TEST, HUAWEICLOUD_AK, HUAWEICLOUD_SK, \
  23. HUAWEICLOUD_OBS_SERVER, HUAWEICLOUD_PUSH_BUKET, OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET
  24. from AnsjerPush.config import XMPUSH_CONFIG, OPPOPUSH_CONFIG, XM_PUSH_CHANNEL_ID
  25. from Model.models import UidPushModel, SysMsgModel, DeviceSharePermission, DeviceChannelUserSet, \
  26. DeviceChannelUserPermission, UidSetModel, Device_Info, UserAudioVideoPush, PushLog
  27. from Object.ETkObject import ETkObject
  28. from Object.OCIObjectStorage import OCIObjectStorage
  29. from Object.UidTokenObject import UidTokenObject
  30. from Object.utils import LocalDateTimeUtil
  31. from Service.CommonService import CommonService
  32. from Service.EquipmentInfoService import EquipmentInfoService, EQUIPMENT_INFO_DICT
  33. from Service.HuaweiPushService.HuaweiPushService import HuaweiPushObject
  34. from Service.PushService import PushObject
  35. from django.db import close_old_connections
  36. LOGGING = logging.getLogger('info')
  37. TIME_LOGGER = logging.getLogger('time')
  38. ERROR_INFO_LOGGER = logging.getLogger('error_info')
  39. class DevicePushService:
  40. @staticmethod
  41. def decode_uid(etk, uidToken):
  42. """
  43. 解密UID,优先解密etk 否则判断uidToken
  44. """
  45. # 解密获取uid
  46. if etk:
  47. eto = ETkObject(etk)
  48. uid = eto.uid
  49. else:
  50. uto = UidTokenObject(uidToken)
  51. uid = uto.UID
  52. LOGGING.info('消息推送-当前UID:{}'.format(uid))
  53. return uid
  54. @staticmethod
  55. def judge_sys_msg(event_type):
  56. """
  57. 判断是否属于系统消息
  58. @param event_type: 事件类型
  59. @return: bool
  60. """
  61. if event_type in SYS_EVENT_TYPE_LIST:
  62. return True
  63. return False
  64. @staticmethod
  65. def get_s3_client(region):
  66. """
  67. 根据地区获取S3 client
  68. @param region: 地区,1:国外, 2:国内
  69. @return: aws_s3_client
  70. """
  71. if int(region) == 1:
  72. aws_s3_client = boto3.client(
  73. 's3',
  74. aws_access_key_id=AWS_ACCESS_KEY_ID[1],
  75. aws_secret_access_key=AWS_SECRET_ACCESS_KEY[1],
  76. config=botocore.client.Config(signature_version='s3v4'),
  77. region_name='us-east-1'
  78. )
  79. else:
  80. aws_s3_client = boto3.client(
  81. 's3',
  82. aws_access_key_id=AWS_ACCESS_KEY_ID[0],
  83. aws_secret_access_key=AWS_SECRET_ACCESS_KEY[0],
  84. config=botocore.client.Config(signature_version='s3v4'),
  85. region_name='cn-northwest-1'
  86. )
  87. return aws_s3_client
  88. @classmethod
  89. def query_uid_push(cls, uid, event_type, button='1'):
  90. """
  91. 查询uid_push和uid_set数据
  92. @param uid: uid
  93. @param event_type: 事件类型
  94. @param button: 按钮
  95. @return: uid_push_qs
  96. """
  97. if event_type not in [606, 607]:
  98. uid_push_qs = UidPushModel.objects.filter(uid_set__uid=uid, uid_set__detect_status=1) \
  99. .exclude(token_val='0'). \
  100. values('token_val', 'app_type', 'appBundleId', 'm_code', 'push_type', 'userID_id', 'userID__NickName',
  101. 'lang', 'm_code', 'tz', 'uid_set__nickname', 'uid_set__detect_interval', 'uid_set__detect_group',
  102. 'uid_set__channel', 'uid_set__ai_type', 'uid_set__device_type', 'uid_set__new_detect_interval',
  103. 'uid_set__msg_notify')
  104. else:
  105. # 一键通话只推主用户
  106. device_info_qs = Device_Info.objects.filter(UID=uid).values('vodPrimaryUserID')
  107. primary_user_id = device_info_qs[0]['vodPrimaryUserID']
  108. if event_type == 607: # 音视频通话根据用户按钮来推送
  109. button_qs = UserAudioVideoPush.objects.filter(uid=uid).values('buttonUser1', 'buttonUser2')
  110. if button_qs.exists():
  111. primary_user_id = button_qs[0]['buttonUser1'] if button == '1' else button_qs[0]['buttonUser2']
  112. uid_push_qs = UidPushModel.objects.filter(uid_set__uid=uid, userID_id=primary_user_id) \
  113. .exclude(token_val='0'). \
  114. values('token_val', 'app_type', 'appBundleId', 'm_code', 'push_type', 'userID_id', 'userID__NickName',
  115. 'lang', 'm_code', 'tz', 'uid_set__nickname', 'uid_set__detect_interval', 'uid_set__detect_group',
  116. 'uid_set__channel', 'uid_set__ai_type', 'uid_set__device_type', 'uid_set__new_detect_interval',
  117. 'uid_set__msg_notify', 'jg_token_val')
  118. return uid_push_qs
  119. @staticmethod
  120. def qs_to_list(qs):
  121. """
  122. qs对象转存列表
  123. @param qs: query set对象
  124. @return: qs_list
  125. """
  126. qs_list = []
  127. for i in qs:
  128. qs_list.append(i)
  129. return qs_list
  130. @staticmethod
  131. def cache_push_detect_interval(redis_obj, name, detect_interval, new_detect_interval):
  132. """
  133. 缓存设置推送消息的时间间隔
  134. @param redis_obj: redis对象
  135. @param name: redis key
  136. @param detect_interval: 原推送时间间隔
  137. @param new_detect_interval: 新推送时间间隔
  138. """
  139. if CONFIG_INFO != CONFIG_CN:
  140. detect_interval = new_detect_interval if new_detect_interval > 0 else detect_interval
  141. detect_interval = 60 if detect_interval < 60 else detect_interval
  142. else: # 国内推送兼容问题,有值并且大于旧消息间隔则使用new_detect_interval
  143. detect_interval = new_detect_interval if new_detect_interval > detect_interval else detect_interval
  144. redis_obj.set_data(key=name, val=1, expire=detect_interval - 5)
  145. @classmethod
  146. def push_msg(cls, **params):
  147. """
  148. 推送消息
  149. @param params: 推送参数
  150. @return: bool
  151. """
  152. try:
  153. uid = params['uid']
  154. params['event_tag'] = cls.get_event_tag(params['ai_type'], params['event_type'], params['detection'])
  155. is_app_push = True if params['event_type'] in [606, 607] else \
  156. cls.is_send_app_push(
  157. params['event_type'], params['event_tag'], params['app_push_config'], params['app_push'], uid)
  158. # 低功耗产品推送,休眠702、低电量704提醒,并且detection=0,0标识单事件类型,1标识多事件类型
  159. is_app_push = True if params['event_type'] in [702, 704] and params['detection'] == 0 else is_app_push
  160. redis_obj = params['redis_obj']
  161. # 推送
  162. if is_app_push:
  163. msg_key = 'PUSH:MSG:IMAGE:{}:{}:{}'.format(params['uid'], params['channel'], params['n_time'])
  164. d_params = {'is_st': params['is_st'], 'storage_location': params['storage_location'],
  165. 'event_tag': params['event_tag'], 'event_type': params['event_type']}
  166. redis_obj.set_data(msg_key, json.dumps(d_params), 60)
  167. push_kwargs = params['push_kwargs']
  168. for up in params['uid_set_push_list']:
  169. push_type = up['push_type']
  170. lang = up['lang']
  171. tz = up['tz']
  172. if tz is None or tz == '':
  173. tz = 0
  174. if params['event_type'] in [606, 607] and push_type in [5, 6]:
  175. push_kwargs['jg_token_val'] = up['jg_token_val']
  176. else:
  177. if 'jg_token_val' in push_kwargs:
  178. push_kwargs.pop('jg_token_val')
  179. appBundleId = up['appBundleId']
  180. token_val = up['token_val']
  181. # 发送标题
  182. msg_title = cls.get_msg_title(nickname=params['nickname'])
  183. # 发送内容
  184. msg_text = cls.get_msg_text(channel=params['channel'], n_time=params['n_time'], lang=lang, tz=tz,
  185. event_type=params['event_type'], ai_type=params['ai_type'],
  186. device_type=params['device_type'], electricity=params['electricity'],
  187. dealings_type=params['dealings_type'], event_tag=params['event_tag']
  188. )
  189. # 补齐推送参数
  190. push_kwargs['appBundleId'] = appBundleId
  191. push_kwargs['token_val'] = token_val
  192. push_kwargs['msg_title'] = msg_title
  193. push_kwargs['msg_text'] = msg_text
  194. params['push_kwargs'] = push_kwargs
  195. params['appBundleId'] = appBundleId
  196. params['token_val'] = token_val
  197. params['lang'] = lang
  198. params['tz'] = tz
  199. params['push_type'] = push_type
  200. params['redis_obj'] = redis_obj
  201. # GlobalThreadPool().submit(cls.send_app_msg_push, **params)
  202. push_thread = threading.Thread(
  203. target=cls.send_app_msg_push,
  204. kwargs=params
  205. )
  206. push_thread.start()
  207. except Exception as e:
  208. ERROR_INFO_LOGGER.info(
  209. '推送消息线程异常,uid:{},error_line:{},error_msg:{}'
  210. .format(params['uid'], e.__traceback__.tb_lineno, repr(e)))
  211. @classmethod
  212. def save_msg_push(cls, **params):
  213. """
  214. 保存推送数据和推送消息
  215. @param params: 推送参数
  216. @return: bool
  217. """
  218. sys_msg_list = []
  219. saved_user_id_list = []
  220. uid = params['uid']
  221. now_time = int(time.time())
  222. redis_obj = params['redis_obj']
  223. try:
  224. params['event_tag'] = cls.get_event_tag(params['ai_type'], params['event_type'], params['detection'])
  225. save_equipment_info = False
  226. equipment_info_key = EquipmentInfoService.randoms_choice_equipment_info_key()
  227. LOGGING.info('***保存推送消息uid:{},push_list:{}'.format(uid, params['uid_set_push_list']))
  228. for up in params['uid_set_push_list']:
  229. lang = up['lang']
  230. tz = up['tz']
  231. if tz is None or tz == '':
  232. tz = 0
  233. # 保存系统消息或推送消息数据
  234. user_id = up['userID_id']
  235. if user_id not in saved_user_id_list: # 防止同一用户重复写入数据
  236. # 系统消息
  237. if params['is_sys_msg']:
  238. sys_msg_text = cls.get_msg_text(channel=params['channel'], n_time=params['n_time'], lang=lang,
  239. tz=tz, is_sys=1, device_type=params['device_type'],
  240. event_type=params['event_type'],
  241. electricity=params['electricity'])
  242. sys_msg_list.append(SysMsgModel(userID_id=user_id, msg=sys_msg_text, addTime=now_time,
  243. updTime=now_time, uid=uid, eventType=params['event_type']))
  244. # 保存推送消息
  245. else:
  246. if not save_equipment_info:
  247. save_equipment_info = True
  248. params['userID_id'] = user_id
  249. answer_status = 1 if params['dealings_type'] == 1 else 0
  250. equipment_info_kwargs = {
  251. 'device_user_id': params['userID_id'],
  252. 'event_time': params['n_time'],
  253. 'event_type': params['event_type'],
  254. 'device_uid': params['uid'],
  255. 'device_nick_name': params['nickname'],
  256. 'channel': params['channel'],
  257. 'alarm': 'Motion \tChannel:{}'.format(params['channel']),
  258. 'is_st': params['is_st'],
  259. 'add_time': int(time.time()),
  260. 'storage_location': params['storage_location'],
  261. 'event_tag': params['event_tag'],
  262. 'answer_status': answer_status
  263. }
  264. # 保存到redis列表
  265. equipment_info_value = json.dumps(equipment_info_kwargs)
  266. redis_obj.rpush(equipment_info_key, equipment_info_value)
  267. LOGGING.info('***保存推送消息uid:{},time:{},user_id:{}'.format(uid, params['n_time'], user_id))
  268. saved_user_id_list.append(user_id)
  269. close_old_connections()
  270. # 写入系统消息
  271. if sys_msg_list:
  272. SysMsgModel.objects.bulk_create(sys_msg_list)
  273. if save_equipment_info:
  274. equipment_info_list = []
  275. equipment_info_model = EQUIPMENT_INFO_DICT[equipment_info_key]
  276. # 一键通话和视频通话需要实时写入数据
  277. # 正式服通过定时任务批量写入数据
  278. if params['event_type'] in [606, 607] or CONFIG_INFO == CONFIG_TEST:
  279. end = 0
  280. # 缓存数据多于100条,批量保存前100条,否则保存全部
  281. equipment_info_len = redis_obj.llen(equipment_info_key)
  282. end = 99 if equipment_info_len > 100 else equipment_info_len - 1
  283. if end != 0:
  284. equipment_info_redis_list = redis_obj.lrange(equipment_info_key, 0, end)
  285. redis_obj.ltrim(equipment_info_key, end + 1, -1)
  286. for equipment_info in equipment_info_redis_list:
  287. equipment_info_data = eval(equipment_info)
  288. # 设备昵称存在表情,解码utf-8
  289. if equipment_info_data.get('device_nick_name') is not None:
  290. equipment_info_data['device_nick_name'] = equipment_info_data['device_nick_name']. \
  291. encode('UTF-8', 'ignore').decode('UTF-8')
  292. equipment_info_list.append(equipment_info_model(**equipment_info_data))
  293. equipment_info_model.objects.bulk_create(equipment_info_list)
  294. return True
  295. except Exception as e:
  296. ERROR_INFO_LOGGER.info(
  297. '保存推送数据和推送消息线程异常,uid:{}, error_line:{}, error_msg:{}'.
  298. format(uid, e.__traceback__.tb_lineno, repr(e)))
  299. return False
  300. @classmethod
  301. def get_event_tag(cls, ai_type, event_type, detection=0):
  302. """
  303. 获取事件标签
  304. """
  305. algorithm = False
  306. if ai_type > 0 and detection == 1:
  307. algorithm = True
  308. elif (ai_type == 7 and event_type <= 7) or (ai_type == 47 and event_type <= 47) or (detection == 1):
  309. algorithm = True
  310. if not algorithm:
  311. return ',' + str(event_type) + ','
  312. event_res = DEVICE_EVENT_TYPE.get(event_type, 0)
  313. if event_res > 0:
  314. return ',' + str(event_res) + ','
  315. event_type = cls.dec_to_bin(event_type)
  316. types = cls.get_combo_types(event_type)
  317. res = ','.join(types) + ','
  318. return ',' + res
  319. @classmethod
  320. def get_combo_types(cls, event_type):
  321. """
  322. 获取设备算法组合类型
  323. 51:移动侦测,52:传感器报警,53:影像遗失,54:PIR,55:门磁报警,56:外部发报,57:人型报警(提示:有人出现),58:车型,59:宠物,60:人脸,61:异响,
  324. 62:区域闯入,63:区域闯出,64:长时间无人检测,65:长时间无人检测,66:往来检测,67:哭声检测,68:手势检测,69:火焰检测
  325. 0:代表空字符,702:摄像头休眠,703:摄像头唤醒,704:电量过低
  326. AWS AI识别 1:人形,2:车型,3:宠物,4:包裹。云端AI类型
  327. """
  328. try:
  329. types = []
  330. event_type = str(event_type)
  331. len_type = len(event_type)
  332. for i in range(len_type):
  333. e_type = event_type[len_type - 1 - i]
  334. if e_type == '1':
  335. types.append(str(ALGORITHM_COMBO_TYPES[i]))
  336. LOGGING.info('算法对照打印:{}'.format(ALGORITHM_COMBO_TYPES))
  337. return types
  338. except Exception as e:
  339. LOGGING.info('推送错误异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  340. return event_type
  341. @staticmethod
  342. def dec_to_bin(num):
  343. """
  344. 十进制转二进制
  345. """
  346. result = ""
  347. while num != 0:
  348. ret = num % 2
  349. num //= 2
  350. result = str(ret) + result
  351. return result
  352. @classmethod
  353. def send_app_msg_push(cls, **kwargs):
  354. """
  355. 发送推送
  356. @kwargs :
  357. @return push_result: bool
  358. """
  359. try:
  360. push_type = kwargs['push_type']
  361. push_kwargs = kwargs['push_kwargs']
  362. push_result = False
  363. uid = kwargs['uid']
  364. # is_st为1或3,且推送类型为apns,gcm,华为,异步推送图片
  365. if (kwargs['is_st'] == 1 or kwargs['is_st'] == 3) and \
  366. (push_type == 0 or push_type == 1 or push_type == 3):
  367. if kwargs['is_st'] == 1:
  368. key = '{}/{}/{}.jpeg'.format(kwargs['uid'], kwargs['channel'], kwargs['n_time'])
  369. else:
  370. key = '{}/{}/{}_0.jpeg'.format(kwargs['uid'], kwargs['channel'], kwargs['n_time'])
  371. # 开始异步推送图片
  372. # thread_pool = GlobalThreadPool()
  373. # thread_pool.submit(cls.async_send_picture_push, (
  374. # push_type, kwargs['aws_s3_client'], kwargs['bucket'], key,
  375. # kwargs['uid'], kwargs['appBundleId'], kwargs['token_val'], kwargs['event_type'], kwargs['n_time'],
  376. # push_kwargs['msg_title'], push_kwargs['msg_text'], kwargs['channel'], kwargs['storage_location']))
  377. push_thread = threading.Thread(target=cls.async_send_picture_push, args=(
  378. push_type, kwargs['aws_s3_client'], kwargs['bucket'], key,
  379. kwargs['uid'], kwargs['appBundleId'], kwargs['token_val'], kwargs['event_type'], kwargs['n_time'],
  380. push_kwargs['msg_title'], push_kwargs['msg_text'], kwargs['channel'], kwargs['storage_location'],
  381. kwargs['redis_obj']))
  382. push_thread.start()
  383. push_result = True
  384. # 不推图
  385. else:
  386. if push_type in [0, 1, 2]:
  387. kwargs = {
  388. 'nickname': kwargs['uid'],
  389. 'app_bundle_id': kwargs['appBundleId'],
  390. 'token_val': kwargs['token_val'],
  391. 'n_time': kwargs['n_time'],
  392. 'event_type': kwargs['event_type'],
  393. 'msg_title': push_kwargs['msg_title'],
  394. 'msg_text': push_kwargs['msg_text'],
  395. 'uid': kwargs['uid'],
  396. 'channel': kwargs['channel']
  397. }
  398. if push_type == 0: # ios apns
  399. push_result = PushObject.ios_apns_push(**kwargs)
  400. elif push_type == 1: # android gcm
  401. push_result = PushObject.android_fcm_push_v1(**kwargs)
  402. elif push_type == 2: # android jpush
  403. kwargs.pop('uid')
  404. push_result = PushObject.android_jpush(**kwargs)
  405. elif push_type == 3:
  406. huawei_push_object = HuaweiPushObject()
  407. huawei_push_object.send_push_notify_message(**push_kwargs)
  408. elif push_type == 4: # android xmpush
  409. if kwargs['event_type'] in [606, 607]:
  410. channel_id = 111934
  411. else:
  412. channel_id = 104551
  413. cls.do_xmpush(channel_id=channel_id, **push_kwargs)
  414. push_result = True
  415. elif push_type == 5: # android vivopush
  416. push_result = PushObject.android_vivopush(**push_kwargs)
  417. elif push_type == 6: # android oppopush
  418. channel_id = 'DEVICE_REMINDER'
  419. cls.do_oppopush(channel_id=channel_id, **push_kwargs)
  420. push_result = True
  421. elif push_type == 7: # android meizupush
  422. push_result = PushObject.android_meizupush(**push_kwargs)
  423. elif push_type == 8: # android honorpush
  424. push_result = PushObject.android_honorpush(**push_kwargs)
  425. if kwargs['event_type'] in [606, 607]:
  426. close_old_connections()
  427. # 写入日志表
  428. PushLog.objects.create(uid=uid, event_type=kwargs['event_type'], created_time=int(time.time()),
  429. content=push_kwargs, push_result=push_result, push_type=push_type)
  430. return push_result
  431. except Exception as e:
  432. ERROR_INFO_LOGGER.info('发送推送线程异常uid:{},type:{},error_line:{},error_msg:{}'
  433. .format(kwargs['uid'], kwargs['push_type'], e.__traceback__.tb_lineno, repr(e)))
  434. return False
  435. @staticmethod
  436. def get_msg_title(nickname):
  437. """
  438. 获取消息标题
  439. """""
  440. return nickname
  441. @staticmethod
  442. def get_event_type_text(lang, event_type, dealings_type):
  443. """
  444. 事件类型文案键值查找
  445. """
  446. if lang == 'cn':
  447. if event_type in EVENT_DICT_CN:
  448. if isinstance(EVENT_DICT_CN[event_type], dict):
  449. msg_type = EVENT_DICT_CN[event_type][dealings_type]
  450. else:
  451. msg_type = EVENT_DICT_CN[event_type]
  452. else:
  453. msg_type = '未知事件类型 '
  454. return msg_type
  455. else:
  456. if event_type in EVENT_DICT:
  457. if isinstance(EVENT_DICT[event_type], dict):
  458. msg_type = EVENT_DICT[event_type][dealings_type]
  459. else:
  460. msg_type = EVENT_DICT[event_type]
  461. else:
  462. msg_type = 'Unknown event type'
  463. return msg_type
  464. @staticmethod
  465. def get_msg_text(channel, n_time, lang, tz, event_type, electricity='', is_sys=0, dealings_type=0, ai_type=0,
  466. device_type=0, event_tag=''):
  467. """
  468. 获取消息文本
  469. @param: channel 通道号
  470. @param: n_time 触发事件
  471. @param: lang 语言
  472. @param: tz 时区
  473. @param: event_type 事件类型
  474. @param: electricity 电量
  475. @param: is_sys 是否系统消息
  476. @param: dealings_type 往来类型 1 进 1 离开
  477. @param: ai_type 设备本地AI只能算法 事件类型
  478. @param: device_type 设备类型
  479. @param: event_tag 设备算法事件标签
  480. """
  481. msg_type = ''
  482. event_type = int(event_type)
  483. device_type = int(device_type)
  484. event_list = []
  485. if event_tag:
  486. event_list = [int(event) for event in event_tag.split(',') if event]
  487. events_to_remove = [702, 703, 704]
  488. for event in events_to_remove:
  489. if event in event_list:
  490. event_list.remove(event)
  491. if lang == 'cn':
  492. if event_type == 51:
  493. msg_type = '检测到画面变化'
  494. elif event_type == 52:
  495. msg_type = '传感器报警'
  496. elif event_type == 53:
  497. msg_type = '影像遗失'
  498. elif event_type == 54:
  499. msg_type = 'PIR'
  500. elif event_type == 55:
  501. msg_type = '门磁报警'
  502. elif event_type == 56:
  503. msg_type = '外部发报'
  504. elif event_type == 57:
  505. msg_type = '有人出现'
  506. elif event_type == 58:
  507. msg_type = '有车出现'
  508. elif event_type == 59:
  509. msg_type = '有宠物出现'
  510. elif event_type == 60:
  511. msg_type = '发现人脸'
  512. elif event_type == 61:
  513. msg_type = '有异响'
  514. elif event_type == 62:
  515. msg_type = '区域闯入'
  516. elif event_type == 63:
  517. msg_type = '区域闯出'
  518. elif event_type == 64:
  519. msg_type = '有人徘徊'
  520. elif event_type == 65:
  521. msg_type = '长时间无人出现'
  522. elif event_type == 704:
  523. msg_type = '电量低'
  524. elif event_type == 702:
  525. msg_type = '摄像头休眠'
  526. elif event_type == 703:
  527. msg_type = '摄像头唤醒'
  528. elif event_type in [606, 607]:
  529. msg_type = '有人呼叫,请点击查看'
  530. if event_type not in [606, 607] and ai_type > 0 and event_list:
  531. msg_type = ''.join([DevicePushService.get_event_type_text(lang, item, dealings_type)
  532. for item in event_list])
  533. if is_sys:
  534. if device_type in MULTI_CHANNEL_TYPE_LIST:
  535. send_text = '{} 通道:{}'.format(msg_type, channel)
  536. else:
  537. send_text = msg_type
  538. else:
  539. if device_type in MULTI_CHANNEL_TYPE_LIST:
  540. send_text = '{} 通道:{}'.format(msg_type, channel)
  541. else:
  542. send_text = '{}'.format(msg_type)
  543. else:
  544. if event_type == 51:
  545. msg_type = 'Screen change detected'
  546. elif event_type == 52:
  547. msg_type = 'Sensor alarms'
  548. elif event_type == 53:
  549. msg_type = 'Lost images'
  550. elif event_type == 54:
  551. msg_type = 'PIR'
  552. elif event_type == 55:
  553. msg_type = 'Door magnetic alarm'
  554. elif event_type == 56:
  555. msg_type = 'External reporting'
  556. elif event_type == 57:
  557. msg_type = 'Person detected'
  558. elif event_type == 58:
  559. msg_type = 'Vehicle detected'
  560. elif event_type == 59:
  561. msg_type = 'Pet detected'
  562. elif event_type == 60:
  563. msg_type = 'Human face detected'
  564. elif event_type == 61:
  565. msg_type = 'Abnormal sound detected'
  566. elif event_type == 62:
  567. msg_type = 'Intrusion detected in the area'
  568. elif event_type == 63:
  569. msg_type = 'Area vacated'
  570. elif event_type == 64:
  571. msg_type = 'Loitering detected'
  572. elif event_type == 65:
  573. msg_type = 'No appearance for a long time'
  574. elif event_type == 704:
  575. msg_type = 'low battery'
  576. elif event_type == 702:
  577. msg_type = 'Camera sleep'
  578. elif event_type == 703:
  579. msg_type = 'Camera wake'
  580. elif event_type in [606, 607]:
  581. msg_type = 'Someone is calling, please click to view'
  582. if event_type not in [606, 607] and ai_type > 0 and event_list:
  583. msg_type = ''.join([DevicePushService.get_event_type_text(lang, item, dealings_type)
  584. for item in event_list])
  585. if is_sys:
  586. if device_type in MULTI_CHANNEL_TYPE_LIST:
  587. send_text = '{} channel:{}'.format(msg_type, channel)
  588. else:
  589. send_text = msg_type
  590. else:
  591. if device_type in MULTI_CHANNEL_TYPE_LIST:
  592. send_text = '{} channel:{}'.format(msg_type, channel)
  593. else:
  594. send_text = '{}'.format(msg_type)
  595. return send_text
  596. @staticmethod
  597. def do_xmpush(channel_id, uid, channel, appBundleId, token_val, event_type, n_time,
  598. msg_title, msg_text):
  599. """
  600. android 国内小米APP消息提醒推送
  601. """
  602. url = 'https://api.xmpush.xiaomi.com/v3/message/regid'
  603. app_secret = XMPUSH_CONFIG[appBundleId]
  604. # payload = {'alert': 'Motion', 'msg': '', 'sound': 'sound.aif', 'zpush': '1',
  605. # 'received_at': n_time, 'event_time': n_time, 'event_type': event_type,
  606. # 'uid': uid, 'channel': channel
  607. # }
  608. data = {
  609. 'title': msg_title,
  610. 'description': msg_text,
  611. 'payload': 'payload',
  612. 'restricted_package_name': appBundleId,
  613. 'registration_id': token_val,
  614. 'extra.channel_id': channel_id,
  615. 'extra.alert': 'Motion',
  616. 'extra.msg': '',
  617. 'extra.sound': 'sound.aif',
  618. 'extra.zpush': '1',
  619. 'extra.received_at': n_time,
  620. 'extra.event_time': n_time,
  621. 'extra.event_type': event_type,
  622. 'extra.uid': uid,
  623. 'extra.channel': channel,
  624. }
  625. headers = {
  626. 'Authorization': 'key={}'.format(app_secret)
  627. }
  628. response = requests.post(url, data=data, headers=headers)
  629. if response.status_code == 200:
  630. LOGGING.info('uid:{},时间:{}小米推送结果:{}'.format(uid, n_time, response.json()))
  631. return response.json()
  632. @staticmethod
  633. def do_oppopush(channel_id, uid, channel, appBundleId, token_val, event_type, n_time,
  634. msg_title, msg_text, jg_token_val=''):
  635. """
  636. android 国内oppo APP消息提醒推送
  637. """
  638. app_key = OPPOPUSH_CONFIG[appBundleId]['Key']
  639. master_secret = OPPOPUSH_CONFIG[appBundleId]['Secret']
  640. url = 'https://api.push.oppomobile.com/'
  641. now_time = str(round(time.time() * 1000))
  642. # 1、实例化一个sha256对象
  643. sha256 = hashlib.sha256()
  644. # 2、调用update方法进行加密
  645. sha256.update((app_key + now_time + master_secret).encode('utf-8'))
  646. # 3、调用hexdigest方法,获取加密结果
  647. sign = sha256.hexdigest()
  648. # 获取auth_token
  649. get_token_url = url + 'server/v1/auth'
  650. post_data = {
  651. 'app_key': app_key,
  652. 'sign': sign,
  653. 'timestamp': now_time
  654. }
  655. headers = {'Content-Type': 'application/x-www-form-urlencoded'}
  656. response = requests.post(get_token_url, data=post_data, headers=headers)
  657. result = response.json()
  658. # 发送推送
  659. push_url = url + 'server/v1/message/notification/unicast'
  660. extra_data = {'alert': 'Motion', 'msg': '', 'sound': 'sound.aif', 'zpush': '1',
  661. 'received_at': n_time, 'event_time': n_time, 'event_type': event_type,
  662. 'uid': uid, 'channel': channel}
  663. message = {
  664. "target_type": 2,
  665. "target_value": token_val,
  666. "notification": {
  667. "title": msg_title,
  668. "content": msg_text,
  669. 'channel_id': channel_id,
  670. 'action_parameters': extra_data,
  671. 'click_action_type': 4,
  672. 'click_action_activity': 'com.ansjer.zccloud_a.AJ_MainView.AJ_Home.AJMainActivity'
  673. }
  674. }
  675. push_data = {
  676. 'auth_token': result['data']['auth_token'],
  677. 'message': json.dumps(message)
  678. }
  679. response = requests.post(push_url, data=push_data, headers=headers)
  680. if response.status_code == 200:
  681. LOGGING.info("oppo推送返回值:{},uid:{},time:{},event:{}".format(response.json(), uid, now_time, event_type))
  682. if event_type in [606, 607]:
  683. PushObject.jpush_transparent_transmission(msg_title, msg_text, appBundleId, jg_token_val, extra_data)
  684. return response.json()
  685. @classmethod
  686. def async_send_picture_push(cls, push_type, aws_s3_client, bucket, key, uid, appBundleId, token_val,
  687. event_type, n_time, msg_title, msg_text, channel, storage_reg, redis_obj):
  688. """
  689. 异步推送图片
  690. """
  691. try:
  692. if storage_reg == 1:
  693. # 阿里云
  694. auth = oss2.Auth(OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET)
  695. oss_img_bucket = oss2.Bucket(auth, 'oss-cn-shenzhen.aliyuncs.com', 'apg')
  696. image_url = oss_img_bucket.sign_url('GET', key, 300)
  697. elif storage_reg in [3, 4]:
  698. image_url = DevicePushService.oci_object_url(uid, redis_obj, storage_reg, bucket, key)
  699. elif storage_reg == 5:
  700. image_url = DevicePushService.create_obs_signed_url(key, 'GET')
  701. else:
  702. image_url = aws_s3_client.generate_presigned_url(
  703. 'get_object', Params={'Bucket': bucket, 'Key': key}, ExpiresIn=3600)
  704. push_result = False
  705. if push_type == 0:
  706. push_result = PushObject.ios_apns_push(
  707. uid, appBundleId, token_val, n_time, event_type, msg_title, msg_text, uid, channel, image_url)
  708. elif push_type == 1:
  709. push_result = PushObject.android_fcm_push_v1(
  710. uid, appBundleId, token_val, n_time, event_type, msg_title, msg_text, uid, channel, image_url)
  711. elif push_type == 3:
  712. huawei_push_object = HuaweiPushObject()
  713. push_result = huawei_push_object.send_push_notify_message(
  714. token_val=token_val, msg_title=msg_title, msg_text=msg_text, uid=uid, event_type=event_type,
  715. n_time=n_time, image_url=image_url, channel=channel)
  716. TIME_LOGGER.info('{}推送图片,push_type:{},推送结果:{}'.format(uid, push_type, push_result))
  717. except Exception as e:
  718. ERROR_INFO_LOGGER.error('异步推送图片异常,error_line:{},error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  719. @staticmethod
  720. def oci_object_url(uid, redis_obj, storage_location, bucket, obj_name):
  721. """
  722. 获取OCI对象存储URL 有效期5分钟
  723. @param uid: uid
  724. @param redis_obj: 缓存客户端
  725. @param storage_location: 存储区域
  726. @param bucket: 存储桶
  727. @param obj_name: 对象名称
  728. @return: url
  729. """
  730. try:
  731. uid_key = f'PUSH:PICTURE:OCI:URL:{uid}'
  732. oci_url = redis_obj.get_data(uid_key)
  733. if oci_url:
  734. return oci_url + obj_name
  735. oci = OCIObjectStorage('eur' if storage_location == 4 else 'us')
  736. prefix_name = f'{uid}/'
  737. time_expires = datetime.datetime.utcnow() + datetime.timedelta(minutes=60)
  738. result = oci.get_preauthenticated_request_url(bucket, 'ociPush', prefix_name, time_expires,
  739. 'AnyObjectRead') # 授权到指定uid文件夹
  740. full_url = result.full_path if result else ''
  741. redis_obj.set_data(uid_key, full_url, 3580)
  742. return full_url + obj_name
  743. except Exception as e:
  744. LOGGING.error('oci查询消息列表异常error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
  745. return ''
  746. @staticmethod
  747. def create_oci_req_url(storage_location, bucket, obj_name, oci=None):
  748. """
  749. 创建oci预认证请求url
  750. """
  751. if not oci:
  752. region = 'eur' if storage_location == 4 else 'us'
  753. oci = OCIObjectStorage(region)
  754. time_expires = datetime.datetime.utcnow() + datetime.timedelta(minutes=60)
  755. result = oci.create_ereauthenticated_request(bucket, 'ociPush', obj_name, time_expires)
  756. if not result:
  757. return ''
  758. return result.full_path + result.object_name
  759. @staticmethod
  760. def get_res_data(**kwargs):
  761. """
  762. 获取响应数据
  763. @return: res_data
  764. """
  765. res_data = {'code': 0, 'msg': 'success'}
  766. is_st = kwargs['is_st']
  767. storage_location = kwargs['storage_location']
  768. if is_st == 0 or is_st == 2:
  769. res_data['msg'] = 'success 0 or 2'
  770. elif is_st == 1:
  771. key_name = '{}/{}/{}.jpeg'.format(kwargs['uid'], kwargs['channel'], kwargs['n_time'])
  772. params = {'Key': key_name}
  773. if kwargs['region'] == 2: # 2:国内
  774. params['Bucket'] = 'push'
  775. else: # 1:国外
  776. params['Bucket'] = 'foreignpush'
  777. # 区域是国外 并且存储位置OCI
  778. if kwargs['region'] == 1 and storage_location in [3, 4]:
  779. # OCI
  780. img_url = DevicePushService.create_oci_req_url(storage_location, params['Bucket'], key_name)
  781. res_data['img_push'] = img_url
  782. res_data['msg'] = 'success 1'
  783. else:
  784. # 华为云
  785. img_url = DevicePushService.create_obs_signed_url(key_name, 'PUT')
  786. res_data['img_push'] = img_url
  787. res_data['msg'] = 'success 1'
  788. elif is_st == 3:
  789. img_url_list = []
  790. if kwargs['region'] == 2: # 2:国内
  791. params = {'Bucket': 'push'}
  792. else: # 1:国外
  793. params = {'Bucket': 'foreignpush'}
  794. oci_client = None
  795. if storage_location in [3, 4]: # 三张图的时候提前获取实例化OCI
  796. region = 'eur' if storage_location == 4 else 'us'
  797. oci_client = OCIObjectStorage(region)
  798. for i in range(kwargs['is_st']):
  799. key_name = '{}/{}/{}_{}.jpeg'.format(kwargs['uid'], kwargs['channel'], kwargs['n_time'], i)
  800. params['Key'] = key_name
  801. if kwargs['region'] == 1:
  802. # OCI
  803. img_url = DevicePushService.create_oci_req_url(storage_location, params['Bucket'], key_name,
  804. oci_client)
  805. img_url_list.append(img_url)
  806. else:
  807. # 华为云
  808. img_url = DevicePushService.create_obs_signed_url(key_name, 'PUT')
  809. img_url_list.append(img_url)
  810. res_data['img_url_list'] = img_url_list
  811. res_data['msg'] = 'success 3'
  812. return res_data
  813. @staticmethod
  814. def generate_s3_url(aws_s3_client, params):
  815. """
  816. 获取S3对象URL
  817. """
  818. response_url = aws_s3_client.generate_presigned_url(
  819. ClientMethod='put_object',
  820. Params=params,
  821. ExpiresIn=3600
  822. )
  823. return response_url
  824. @staticmethod
  825. def create_obs_signed_url(key_name, method):
  826. """
  827. 生成对象存储预签名URL
  828. @param key_name: 对象名称
  829. @param method: 方法
  830. @return: 预签名URL
  831. """
  832. obs_client = ObsClient(
  833. access_key_id=HUAWEICLOUD_AK, secret_access_key=HUAWEICLOUD_SK, server=HUAWEICLOUD_OBS_SERVER)
  834. res = obs_client.createSignedUrl(
  835. method=method, bucketName=HUAWEICLOUD_PUSH_BUKET, objectKey=key_name, expires=3600)
  836. return res.signedUrl
  837. @staticmethod
  838. def check_share_permission(user_id, channel, uid):
  839. """
  840. 检查用户是否有权限接收设备报警推送
  841. """
  842. user_permission_qs = DeviceChannelUserSet.objects.filter(user_id=user_id, uid=uid) \
  843. .values('id', 'channels')
  844. # 根据当前用户与uid查询是否设置过通道权限,不存在则不是分享设备
  845. if not user_permission_qs.exists():
  846. return True
  847. up_id = user_permission_qs[0]['id']
  848. channels = user_permission_qs[0]['channels']
  849. channels_list = [int(val) for val in channels.split(',')]
  850. # 当前uid是属于分享设备并且设置了权限
  851. # 判断通道是否设置了权限,不存在则当前通道没有权限接受消息推送
  852. if int(channel) not in channels_list:
  853. return False
  854. permission_qs = DeviceSharePermission.objects.filter(code='AlarmMessages').values('id')
  855. p_id = permission_qs[0]['id']
  856. # 当前通道存在设置则查看是否有 消息推送权限
  857. channel_permission_qs = DeviceChannelUserPermission.objects \
  858. .filter(channel_user_id=up_id, permission_id=p_id) \
  859. .values('permission_id', 'channel_user_id')
  860. if not channel_permission_qs.exists():
  861. return False
  862. return True
  863. @classmethod
  864. def is_algorithm_type(cls, uid, event_type):
  865. """
  866. 判断是否是算法类型 62、63、64、65、66不限制推送
  867. """
  868. uid_set_qs = UidSetModel.objects.filter(uid=uid).values('ai_type')
  869. if not uid_set_qs.exists():
  870. return False
  871. if uid_set_qs[0]['ai_type'] == 0:
  872. return False
  873. event_types = [62, 63, 64, 65, 66]
  874. event_res = DEVICE_EVENT_TYPE.get(event_type, 0)
  875. if event_res in event_types:
  876. return True
  877. event_types2 = cls.get_combo_types(event_type)
  878. if not event_types2:
  879. return False
  880. c = [x for x in event_types if x in event_types2]
  881. return True if c else False
  882. @staticmethod
  883. def is_send_app_push(event_type, event_tag, app_push_config, msg_interval=None, uid=None):
  884. """
  885. 是否进行APP消息提醒
  886. @return: True|False
  887. """
  888. try:
  889. if not app_push_config:
  890. return True
  891. is_push = app_push_config['appPush']
  892. if is_push != 1: # 1:进行APP提醒,其它则不执行APP提醒
  893. return False
  894. if msg_interval: # 存在消息间隔数据缓存 不推送APP消息
  895. return False
  896. all_day = app_push_config['pushTime']['allDay']
  897. # 允许设备类型APP提醒列表
  898. app_event_types = app_push_config['eventTypes']['device']
  899. if all_day == 0: # 1:全天提醒,0:自定义时间提醒
  900. push_time_config = app_push_config['pushTime']
  901. # 计算当前时间是否在自定义消息提醒范围内
  902. if not DevicePushService.is_push_notify_allowed_now(push_time_config):
  903. LOGGING.info('{}APP推送提醒不在自定义时间内:{}'.format(uid, push_time_config))
  904. return False
  905. # APP接收提醒,判断识别类型是否勾选提醒
  906. push_result = DevicePushService.is_type_push(event_type, event_tag, app_event_types)
  907. LOGGING.info('{}APP推送消息类型提醒是否执行:{}'.format(uid, push_result))
  908. return push_result
  909. except Exception as e:
  910. LOGGING.info('{}判断是否执行APP推送异常,errLine:{}, errMsg:{}'.format(uid, e.__traceback__.tb_lineno, repr(e)))
  911. return True
  912. @staticmethod
  913. def is_type_push(event_type, event_tag, app_event_types):
  914. # 检查事件标签和应用事件类型是否都存在
  915. if event_tag and app_event_types:
  916. # 将事件标签按逗号分割成列表,并转换为整数类型
  917. tag_list = [int(event) for event in event_tag.split(',') if event]
  918. # 判断是否有任一标签允许应用提醒
  919. return any(item in app_event_types for item in tag_list)
  920. # 检查事件类型和用户所选事件类型是否都存在,并判断事件类型在用户所选事件类型列表中
  921. return event_type and app_event_types and event_type in app_event_types
  922. @staticmethod
  923. def is_push_notify_allowed_now(push_time_config):
  924. """
  925. 判断当前时间是否在允许APP推送提醒
  926. """
  927. now_time = int(time.time())
  928. start_time = push_time_config['startTime']
  929. end_time = push_time_config['endTime']
  930. repeat = push_time_config['repeat']
  931. tz = push_time_config['timeZone']
  932. # 获取当前日期和周几
  933. now_date, week = DevicePushService.get_now_date_and_week(now_time, tz)
  934. # 判断是否在重复日范围内
  935. if not DevicePushService.is_repeated(week, repeat):
  936. return False
  937. # 计算当前日期在一天中的秒数
  938. seconds = LocalDateTimeUtil.convert_time_to_seconds(now_date)
  939. # 判断是否在APP推送提醒范围内
  940. return DevicePushService.is_in_effect(start_time, end_time, seconds)
  941. @staticmethod
  942. def is_in_effect(start, end, now_seconds):
  943. """
  944. 判断是否在提醒时间范围内
  945. @params: 开始时间秒
  946. @params: 结束时间秒
  947. @params: 当前时间秒
  948. @return: 当前时间是在范围内返回True 否则False
  949. """
  950. if start < end:
  951. return start <= now_seconds <= end
  952. else:
  953. return start <= now_seconds or now_seconds <= end
  954. @staticmethod
  955. def is_repeated(week_day, repeat_day):
  956. """
  957. 判断是否重复日
  958. @params: week_day 周几
  959. @params: 重复日1-127
  960. @return: 如果当前日期在重复日则返回True否则False
  961. """
  962. # 判断对应位置上的值是否为 1
  963. is_repeat = (repeat_day >> (week_day - 1)) & 1 == 1
  964. return is_repeat
  965. @staticmethod
  966. def get_now_date_and_week(now_time, tz):
  967. now_data = CommonService.get_now_time_str(now_time, tz, 'cn')
  968. week = LocalDateTimeUtil.date_to_week(now_data)
  969. return now_data, week