|
|
@@ -135,10 +135,12 @@ class NotificationV2View(View):
|
|
|
result['new_device_info_list'])
|
|
|
|
|
|
# # 异步推送消息和保存数据
|
|
|
- TIME_LOGGER.info('异步推送参数:{},{},{}'.format(uid_set_push_list, is_sys_msg, params))
|
|
|
+ TIME_LOGGER.info('uid_set_push_list:{}'.format(uid_set_push_list))
|
|
|
+ TIME_LOGGER.info('is_sys_msg:{}'.format(is_sys_msg))
|
|
|
+ TIME_LOGGER.info('params:{}'.format(params))
|
|
|
+
|
|
|
push_thread = threading.Thread(
|
|
|
target=push_and_save_data,
|
|
|
- args=(uid_set_push_list, is_sys_msg),
|
|
|
kwargs=params)
|
|
|
push_thread.start()
|
|
|
|
|
|
@@ -169,22 +171,22 @@ class NotificationV2View(View):
|
|
|
return JsonResponse(status=200, data=json.dumps(data), safe=False)
|
|
|
|
|
|
|
|
|
-def push_and_save_data(uid_set_push_list, is_sys_msg, **params):
|
|
|
+def push_and_save_data(**params):
|
|
|
TIME_LOGGER.info('触发异步推送函数')
|
|
|
TIME_LOGGER.info('{}开始异步推送'.format(params['uid']))
|
|
|
# 推送消息,生成推送数据列表
|
|
|
- result = DevicePushService.save_msg_push(uid_set_push_list, **params)
|
|
|
- # 保存推送数据
|
|
|
- TIME_LOGGER.info('{}开始异步存表'.format(params['uid']))
|
|
|
- save_success = DevicePushService.save_sys_msg(
|
|
|
- is_sys_msg,
|
|
|
- result['local_date_time'],
|
|
|
- result['sys_msg_list'],
|
|
|
- result['new_device_info_list'])
|
|
|
- if save_success:
|
|
|
- TIME_LOGGER.info('{}异步存表成功'.format(params['uid']))
|
|
|
- else:
|
|
|
- TIME_LOGGER.info('{}异步存表失败'.format(params['uid']))
|
|
|
+ # result = DevicePushService.save_msg_push(uid_set_push_list, **params)
|
|
|
+ # # 保存推送数据
|
|
|
+ # TIME_LOGGER.info('{}开始异步存表'.format(params['uid']))
|
|
|
+ # save_success = DevicePushService.save_sys_msg(
|
|
|
+ # is_sys_msg,
|
|
|
+ # result['local_date_time'],
|
|
|
+ # result['sys_msg_list'],
|
|
|
+ # result['new_device_info_list'])
|
|
|
+ # if save_success:
|
|
|
+ # TIME_LOGGER.info('{}异步存表成功'.format(params['uid']))
|
|
|
+ # else:
|
|
|
+ # TIME_LOGGER.info('{}异步存表失败'.format(params['uid']))
|
|
|
|
|
|
|
|
|
def test_func(a, b, **kwargs):
|
