|
|
@@ -255,6 +255,7 @@ 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))
|
|
|
|
|
|
if end != 0:
|
|
|
equipment_info_redis_list = redis_obj.lrange(equipment_info_key, 0, end)
|
|
|
@@ -268,7 +269,6 @@ class DevicePushService:
|
|
|
encode('UTF-8', 'ignore').decode('UTF-8')
|
|
|
equipment_info_list.append(equipment_info_model(**equipment_info_data))
|
|
|
equipment_info_model.objects.bulk_create(equipment_info_list)
|
|
|
- LOGGING.info('uid:{},time:{},存表:{}'.format(uid, params['n_time'], equipment_info_key))
|
|
|
return True
|
|
|
except Exception as e:
|
|
|
LOGGING.info('推送消息或存表异常uid{}: error_line:{}, error_msg:{}'.format(uid, e.__traceback__.tb_lineno, repr(e)))
|
peng