Procházet zdrojové kódy

新增Redis 获取不到时。重新赋值

chenshibin před 4 roky
rodič
revize
a07ef4743e
1 změnil soubory, kde provedl 17 přidání a 0 odebrání
  1. 17 0
      Controller/DetectControllerV2.py

+ 17 - 0
Controller/DetectControllerV2.py

@@ -102,6 +102,23 @@ class NotificationView(View):
         if have_ykey:
             redis_list = eval(redisObj.get_data(key=ykey))
             print(have_ykey)
+            # 从数据库查询出来
+            uid_push_qs = UidPushModel.objects.filter(uid_set__uid=uid, uid_set__detect_status=1). \
+                values('token_val', 'app_type', 'appBundleId', 'm_code',
+                       'push_type', 'userID_id', 'userID__NickName',
+                       'lang', 'm_code', 'tz', 'uid_set__nickname', 'uid_set__detect_interval', 'uid_set__detect_group',
+                       'uid_set__channel')
+            print(uid_push_qs)
+            # 新建一个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 not redis_list:
+                res_data = {'code': 404, 'msg': 'error !'}
+                return JsonResponse(status=200, data=res_data)
         else:
             # 从数据库查询出来
             uid_push_qs = UidPushModel.objects.filter(uid_set__uid=uid,uid_set__detect_status=1). \