|
@@ -138,7 +138,6 @@ class DevicePushService:
|
|
|
detect_interval = new_detect_interval if new_detect_interval > 0 else detect_interval
|
|
|
detect_interval = 60 if detect_interval < 60 else detect_interval
|
|
|
redis_obj.set_data(key=name, val=1, expire=detect_interval - 5)
|
|
|
- LOGGING.info('消息推送-缓存设置APP推送间隔:{}s'.format(detect_interval))
|
|
|
|
|
|
@classmethod
|
|
|
def save_msg_push(cls, uid_set_push_list, **params):
|
|
@@ -177,11 +176,8 @@ class DevicePushService:
|
|
|
kwag_args['token_val'] = token_val
|
|
|
kwag_args['msg_title'] = msg_title
|
|
|
kwag_args['msg_text'] = msg_text
|
|
|
- LOGGING.info('推送要的数据: {}'.format(kwag_args))
|
|
|
local_date_time = CommonService.get_now_time_str(n_time=params['n_time'], tz=tz, lang='cn')
|
|
|
- LOGGING.info('<<<<<根据时区计算后日期={},时区={}'.format(local_date_time, tz))
|
|
|
local_date_time = local_date_time[0:10]
|
|
|
- LOGGING.info('<<<<<切片后的日期={}'.format(local_date_time))
|
|
|
# 以下是存库
|
|
|
userID_id = up["userID_id"]
|
|
|
if userID_id not in userID_ids:
|
|
@@ -196,7 +192,6 @@ class DevicePushService:
|
|
|
updTime=now_time, uid=params['uid'],
|
|
|
eventType=params['event_type']))
|
|
|
else:
|
|
|
- LOGGING.info('分表存数据start------')
|
|
|
params['userID_id'] = userID_id
|
|
|
# push_permission = DevicePushService.check_share_permission(userID_id,
|
|
|
# params['channel'],params['uid'])
|
|
@@ -334,7 +329,6 @@ class DevicePushService:
|
|
|
# 根据日期获得星期几
|
|
|
week = LocalDateTimeUtil.date_to_week(local_date_time)
|
|
|
EquipmentInfoService.equipment_info_bulk_create(week, new_device_info_list)
|
|
|
- LOGGING.info('设备信息分表批量保存end------')
|
|
|
return True
|
|
|
|
|
|
@classmethod
|