|
|
@@ -75,24 +75,27 @@ class NotificationView(View):
|
|
|
ykey = '{uid}_redis_qs'.format(uid=uid)
|
|
|
# 判断redisObj.get_data(key=pkey):不为空
|
|
|
if redisObj.get_data(key=pkey):
|
|
|
- res_data = {'code': 0, 'msg': 'success,!'}
|
|
|
+ res_data = {'code': 0, 'msg': 'success!'}
|
|
|
return JsonResponse(status=200, data=res_data)
|
|
|
else:
|
|
|
- # 设置推送时间为60秒一次
|
|
|
- redisObj.set_data(key=pkey, val=1, expire=60)
|
|
|
- # print("从数据库查到数据")
|
|
|
- # 从数据库查询出来
|
|
|
- uid_push_qs = UidPushModel.objects.filter(uid_set__uid=uid). \
|
|
|
- values('token_val', 'app_type', 'appBundleId',
|
|
|
- 'push_type', 'userID_id', 'userID__NickName',
|
|
|
- 'lang', 'tz', 'uid_set__nickname')
|
|
|
- # 新建一个list接收数据
|
|
|
- redis_list = []
|
|
|
- # 把数据库数据追加进redis_list
|
|
|
- for qs in uid_push_qs:
|
|
|
- redis_list.append(qs)
|
|
|
- # 修改redis数据，并设置过期时间为10分钟
|
|
|
- redisObj.set_data(key=ykey, val=str(redis_list), expire=60)
|
|
|
+ if redisObj.get_data(key=ykey):
|
|
|
+ redis_list = eval(redisObj.get_data(key=ykey))
|
|
|
+ else:
|
|
|
+ # 设置推送时间为60秒一次
|
|
|
+ redisObj.set_data(key=pkey, val=1, expire=60)
|
|
|
+ print("从数据库查到数据")
|
|
|
+ # 从数据库查询出来
|
|
|
+ uid_push_qs = UidPushModel.objects.filter(uid_set__uid=uid). \
|
|
|
+ values('token_val', 'app_type', 'appBundleId',
|
|
|
+ 'push_type', 'userID_id', 'userID__NickName',
|
|
|
+ 'lang', 'tz', 'uid_set__nickname')
|
|
|
+ # 新建一个list接收数据
|
|
|
+ redis_list = []
|
|
|
+ # 把数据库数据追加进redis_list
|
|
|
+ for qs in uid_push_qs:
|
|
|
+ redis_list.append(qs)
|
|
|
+ # 修改redis数据，并设置过期时间为10分钟
|
|
|
+ redisObj.set_data(key=ykey, val=str(redis_list), expire=600)
|
|
|
if redis_list:
|
|
|
nickname = redis_list[0]['uid_set__nickname']
|
|
|
if not nickname:
|
WuYiPei