|
|
@@ -55,7 +55,6 @@ class DevicePushService:
|
|
|
else:
|
|
|
uto = UidTokenObject(uidToken)
|
|
|
uid = uto.UID
|
|
|
- LOGGING.info('消息推送-当前UID：{}'.format(uid))
|
|
|
return uid
|
|
|
|
|
|
@staticmethod
|
|
|
@@ -300,7 +299,6 @@ class DevicePushService:
|
|
|
# 保存到redis列表
|
|
|
equipment_info_value = json.dumps(equipment_info_kwargs)
|
|
|
redis_obj.rpush(equipment_info_key, equipment_info_value)
|
|
|
- LOGGING.info('***保存推送消息uid:{},time:{},user_id:{}'.format(uid, params['n_time'], user_id))
|
|
|
saved_user_id_list.append(user_id)
|
|
|
close_old_connections()
|
|
|
# 写入系统消息
|
|
|
@@ -802,7 +800,8 @@ class DevicePushService:
|
|
|
|
|
|
TIME_LOGGER.info('{}推送图片,push_type:{},推送结果:{}'.format(uid, push_type, push_result))
|
|
|
except Exception as e:
|
|
|
- ERROR_INFO_LOGGER.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):
|
