|
@@ -405,7 +405,8 @@ class DevicePushService:
|
|
|
push_thread = threading.Thread(target=cls.async_send_picture_push, args=(
|
|
|
push_type, kwargs['aws_s3_client'], kwargs['bucket'], key,
|
|
|
kwargs['uid'], kwargs['appBundleId'], kwargs['token_val'], kwargs['event_type'], kwargs['n_time'],
|
|
|
- push_kwargs['msg_title'], push_kwargs['msg_text'], kwargs['channel'], kwargs['storage_location']))
|
|
|
+ push_kwargs['msg_title'], push_kwargs['msg_text'], kwargs['channel'], kwargs['storage_location'],
|
|
|
+ kwargs['redis_obj']))
|
|
|
push_thread.start()
|
|
|
|
|
|
push_result = True
|
|
@@ -752,7 +753,7 @@ class DevicePushService:
|
|
|
|
|
|
LOGGING.info('{}推送图片,push_type:{},推送结果:{}'.format(uid, push_type, push_result))
|
|
|
except Exception as e:
|
|
|
- LOGGING.error('异步推送图片异常,error_line:{},error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|
|
|
+ ERROR_INFO_LOGGER.error('异步推送图片异常,error_line:{},error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|
|
|
|
|
|
@staticmethod
|
|
|
def oci_object_url(uid, redis_obj, storage_location, bucket, obj_name):
|