|
|
@@ -56,7 +56,6 @@ class DevicePushService:
|
|
|
else:
|
|
|
uto = UidTokenObject(uidToken)
|
|
|
uid = uto.UID
|
|
|
- LOGGING.info('消息推送-当前UID：{}'.format(uid))
|
|
|
return uid
|
|
|
|
|
|
@staticmethod
|
|
|
@@ -261,7 +260,6 @@ class DevicePushService:
|
|
|
|
|
|
save_equipment_info = False
|
|
|
equipment_info_key = EquipmentInfoService.randoms_choice_equipment_info_key()
|
|
|
- LOGGING.info('***保存推送消息uid:{},push_list:{}'.format(uid, params['uid_set_push_list']))
|
|
|
for up in params['uid_set_push_list']:
|
|
|
lang = up['lang']
|
|
|
tz = up['tz']
|
|
|
@@ -302,7 +300,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()
|
|
|
# 写入系统消息
|
|
|
@@ -322,11 +319,6 @@ class DevicePushService:
|
|
|
end = 99 if equipment_info_len > 100 else equipment_info_len - 1
|
|
|
if CONFIG_INFO == CONFIG_TEST:
|
|
|
end = equipment_info_len
|
|
|
- LOGGING.info(
|
|
|
- 'uid:{},time:{},存表:{},条数：{}, 事件类型：{}'.format(uid, params['n_time'], equipment_info_key,
|
|
|
- end,
|
|
|
- params['event_type']))
|
|
|
-
|
|
|
if end != 0:
|
|
|
equipment_info_redis_list = redis_obj.lrange(equipment_info_key, 0, end)
|
|
|
redis_obj.ltrim(equipment_info_key, end + 1, -1)
|
Ansjer