|
@@ -18,10 +18,11 @@ from django.utils.decorators import method_decorator
|
|
|
from django.views.decorators.csrf import csrf_exempt
|
|
|
from django.views.generic.base import View
|
|
|
|
|
|
-from Model.models import VodBucketModel, UID_Bucket, Store_Meal, Device_Info, OssCrdModel
|
|
|
+from Model.models import VodBucketModel, UID_Bucket, Store_Meal, Device_Info, OssCrdModel, VodHlsModel, StsCrdModel
|
|
|
from Object.ResponseObject import ResponseObject
|
|
|
from Object.TokenObject import TokenObject
|
|
|
from Service.ModelService import ModelService
|
|
|
+from django.db import transaction
|
|
|
import time
|
|
|
|
|
|
|
|
@@ -239,13 +240,15 @@ class UidBucketView(View):
|
|
|
id = request_dict.get('id', None)
|
|
|
page = int(request_dict.get('page', None))
|
|
|
line = int(request_dict.get('line', None))
|
|
|
- d_ubqs = UID_Bucket.objects.filter(id=id)
|
|
|
- uid = d_ubqs[0].uid
|
|
|
- channel = d_ubqs[0].channel
|
|
|
- d_ubqs.delete()
|
|
|
- oss_crd_qs = OssCrdModel.objects.filter(uid=uid, channel=channel)
|
|
|
- if oss_crd_qs.exists():
|
|
|
- oss_crd_qs.delete()
|
|
|
+ uid_bucket_qs = UID_Bucket.objects.filter(id=id)
|
|
|
+ uid = uid_bucket_qs[0].uid
|
|
|
+ bucket_id = uid_bucket_qs[0].bucket_id
|
|
|
+ # channel = uid_bucket_qs[0].channel
|
|
|
+ with transaction.atomic():
|
|
|
+ uid_bucket_qs.delete()
|
|
|
+ # OssCrdModel.objects.filter(uid=uid, channel=channel).delete()
|
|
|
+ VodHlsModel.objects.filter(uid=uid,bucket_id=bucket_id).delete()
|
|
|
+ StsCrdModel.objects.filter(uid=uid,bucket_id=bucket_id).delete()
|
|
|
except Exception as e:
|
|
|
return response.json(10, repr(e))
|
|
|
else:
|