使用异步方式推送,添加打印

Controller/DetectControllerV2.py

@@ -126,20 +126,20 @@ class NotificationV2View(View):
                       'app_push_config': uid_set_push_list[0]['uid_set__msg_notify']}
 
             # 推送消息,生成推送数据列表
-            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'])
+            # 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'])
 
             # # 异步推送消息和保存数据
-            # push_thread = threading.Thread(
-            #     target=push_and_save_data,
-            #     args=(uid_set_push_list, is_sys_msg),
-            #     kwargs=params)
-            # push_thread.start()
+            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
@@ -158,12 +158,18 @@ class NotificationV2View(View):
 
 
 def push_and_save_data(uid_set_push_list, is_sys_msg, **params):
+    TIME_LOGGER.info('{}开始异步推送'.format(params['uid']))
     # 推送消息,生成推送数据列表
     result = DevicePushService.save_msg_push(uid_set_push_list, **params)
     # 保存推送数据
-    DevicePushService.save_sys_msg(
+    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']))