测试4

Controller/DetectControllerV2.py

@@ -127,7 +127,7 @@ class NotificationV2View(View):
                       'uid_set_push_list': uid_set_push_list}
 
             # 推送消息,生成推送数据列表
-            result = DevicePushService.save_msg_push(uid_set_push_list, **params)
+            result = DevicePushService.save_msg_push(**params)
             # 保存推送数据
             DevicePushService.save_sys_msg(
                 is_sys_msg,
@@ -145,17 +145,6 @@ class NotificationV2View(View):
                 kwargs=params)
             push_thread.start()
 
-            a, b = 1, 2
-            kwargs = {
-                'c': 3,
-                'd': 4
-            }
-            test_thread = threading.Thread(
-                target=test_func,
-                args=(a, b),
-                kwargs=kwargs)
-            test_thread.start()
-
             params['aws_s3_client'] = aws_s3_client
             params['uid_set_push_list'] = uid_set_push_list
 
@@ -176,7 +165,7 @@ def push_and_save_data(**params):
     TIME_LOGGER.info('触发异步推送函数:{}'.format(params))
     TIME_LOGGER.info('{}开始异步推送'.format(params['uid']))
     # 推送消息,生成推送数据列表
-    result = DevicePushService.save_msg_push(params['uid_set_push_list'], **params)
+    result = DevicePushService.save_msg_push(**params)
     # 保存推送数据
     TIME_LOGGER.info('{}开始异步存表'.format(params['uid']))
     save_success = DevicePushService.save_sys_msg(
@@ -188,7 +177,3 @@ def push_and_save_data(**params):
         TIME_LOGGER.info('{}异步存表成功'.format(params['uid']))
     else:
         TIME_LOGGER.info('{}异步存表失败'.format(params['uid']))
-
-
-def test_func(a, b, **kwargs):
-    TIME_LOGGER.info('测试异步函数参数:{},{},{}'.format(a, b, kwargs))