Browse Source

添加redis锁3

lang 3 years ago
parent
commit
4740d9dcef
1 changed files with 3 additions and 3 deletions
  1. 3 3
      Controller/CloudStorage.py

+ 3 - 3
Controller/CloudStorage.py

@@ -1201,9 +1201,9 @@ class CloudStorageView(View):
 
         redisObj = RedisObject()
         isLock = redisObj.CONN.setnx(uid+'do_experience_order', 1)
-        re.CONN.expire(uid+'do_experience_order', 60)
+        redisObj.CONN.expire(uid+'do_experience_order', 60)
         if not isLock:
-            return json(200000, 'Invalid request')
+            return response.json(5)
 
         if cdk is not None and pay_type == 11:
             cdk_qs = CDKcontextModel.objects.filter(cdk=cdk).values('is_activate', 'rank__id', 'rank__commodity_code')
@@ -1215,7 +1215,7 @@ class CloudStorageView(View):
             commodity_code = cdk_qs[0]['rank__commodity_code']
 
         if uid is None or channel is None or commodity_code is None or pay_type is None or rank is None:
-            del_data(key=uid + 'do_experience_order')
+            redisObj.del_data(key=uid + 'do_experience_order')
             return response.json(13, '参数有误.')
 
         dvq = Device_Info.objects.filter(UID=uid)