测试打印

Controller/DetectControllerV2.py

@@ -126,20 +126,30 @@ 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()
+            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
@@ -173,3 +183,6 @@ def push_and_save_data(uid_set_push_list, is_sys_msg, **params):
     else:
         TIME_LOGGER.info('{}异步存表失败'.format(params['uid']))
 
+
+def test_func(a, b, **kwargs):
+    TIME_LOGGER.info('测试异步函数参数:{},{},{}'.format(a, b, kwargs))