|
@@ -208,7 +208,7 @@ class CloudStorageView(View):
|
|
|
qs = qs.values("id", "title", "content", "price","day", "currency", "bucket__storeDay",
|
|
|
"bucket__bucket", "bucket__area","commodity_code",
|
|
|
"commodity_type", "is_discounts", "virtual_price", "expire",
|
|
|
- "discount_price", "discount_content")
|
|
|
+ "discount_price", "discount_content","symbol")
|
|
|
|
|
|
if qs.exists():
|
|
|
ql = list(qs)
|
|
@@ -478,7 +478,7 @@ class CloudStorageView(View):
|
|
|
now_time = int(time.time())
|
|
|
bv_qs = UID_Bucket.objects.filter(uid=uid,channel=channel, endTime__gte=now_time).order_by('endTime')
|
|
|
if not bv_qs.exists():
|
|
|
- return response.json(103,'未购买')
|
|
|
+ return response.json(10014)
|
|
|
vh_qs = VodHlsModel.objects.filter \
|
|
|
( uid=uid, channel=channel, time__range=(startTime, endTime), endTime__gte=now_time). \
|
|
|
values("id", "time", "sec", "bucket__bucket", "fg", "bucket__endpoint", "bucket__region", "bucket__mold")
|
|
@@ -656,10 +656,10 @@ class CloudStorageView(View):
|
|
|
return response.json(12)
|
|
|
ubqs = UID_Bucket.objects.filter(channel=channel, uid=uid).order_by('endTime')
|
|
|
if not ubqs.exists():
|
|
|
- return response.json(10, '未购买')
|
|
|
+ return response.json(10014)
|
|
|
now_time = int(time.time())
|
|
|
if now_time > ubqs[0].endTime:
|
|
|
- return response.json(102,'已过期')
|
|
|
+ return response.json(10015)
|
|
|
ubqs.update(status=status)
|
|
|
if status == 0:
|
|
|
return response.json(0)
|
|
@@ -869,7 +869,7 @@ class CloudStorageView(View):
|
|
|
values("day", "bucket_id", "bucket__storeDay")
|
|
|
bucketId = smqs[0]['bucket_id']
|
|
|
if not smqs.exists():
|
|
|
- return response.json(0, '套餐已删除')
|
|
|
+ return response.json(173)
|
|
|
addTime = int(smqs[0]["day"]) * 24 * 3600
|
|
|
ubqs = UID_Bucket.objects.filter(uid=UID, channel=channel). \
|
|
|
values("bucket_id", "endTime", "bucket__storeDay")
|
|
@@ -917,7 +917,7 @@ class CloudStorageView(View):
|
|
|
values("day", "bucket_id", "bucket__storeDay", "expire")
|
|
|
bucketId = smqs[0]['bucket_id']
|
|
|
if not smqs.exists():
|
|
|
- return response.json(0, '套餐已删除')
|
|
|
+ return response.json(173)
|
|
|
# ##
|
|
|
ubqs = UID_Bucket.objects.filter(bucket__id=bucketId, uid=UID, channel=channel, endTime__gte=nowTime). \
|
|
|
values("id", "bucket__storeDay", "bucket__region", "endTime").order_by('endTime')[:1]
|
|
@@ -991,16 +991,16 @@ class CloudStorageView(View):
|
|
|
rank = request_dict.get('rank', None)
|
|
|
is_select_discount = request_dict.get('is_select_discount', 0)
|
|
|
if not uid or not channel or not pay_type or not rank:
|
|
|
- return response.json(13, '参数有误.')
|
|
|
+ return response.json(444)
|
|
|
dv_qs = Device_Info.objects.filter(userID_id=userID, UID=uid, isShare=False, isExist=1)
|
|
|
if not dv_qs.exists():
|
|
|
- return response.json(12)
|
|
|
+ return response.json(173)
|
|
|
smqs = Store_Meal.objects.filter(id=rank, pay_type=pay_type). \
|
|
|
values('currency', 'price', 'content', 'day',
|
|
|
'commodity_type', 'title', 'content',
|
|
|
'expire', 'commodity_code', 'discount_price')
|
|
|
if not smqs.exists():
|
|
|
- return response.json(10, '套餐不存在')
|
|
|
+ return response.json(10016)
|
|
|
currency = smqs[0]['currency']
|
|
|
price = smqs[0]['price']
|
|
|
if is_select_discount == '1':
|
|
@@ -1082,7 +1082,7 @@ class CloudStorageView(View):
|
|
|
'result': {"redirectUrl": redirectUrl, "orderID": orderID},
|
|
|
'error_code': 0})
|
|
|
else:
|
|
|
- return response.json(10, '生成订单错误.')
|
|
|
+ return response.json(800)
|
|
|
|
|
|
elif pay_type == 3:
|
|
|
pay = WechatPayObject()
|
|
@@ -1096,7 +1096,7 @@ class CloudStorageView(View):
|
|
|
# 统一调用接口
|
|
|
response = pay.re_finall()
|
|
|
if not response:
|
|
|
- return response.json(10, '生成订单错误.')
|
|
|
+ return response.json(800)
|
|
|
# 回调函数
|
|
|
Order_Model.objects.create(orderID=orderID, UID=uid, channel=channel, userID_id=userID,
|
|
|
desc=content, payType=pay_type, payTime=nowTime,
|
|
@@ -1240,12 +1240,12 @@ class CloudStorageView(View):
|
|
|
VodHlsModel.objects.filter(uid=uid).delete()
|
|
|
else:
|
|
|
if type(vod_id_list).__name__ != 'list':
|
|
|
- return response.json(424, 'vod_id_list格式错误')
|
|
|
+ return response.json(444)
|
|
|
VodHlsModel.objects.filter(id__in=vod_id_list).delete()
|
|
|
except Exception as e:
|
|
|
return response.json(424, repr(e))
|
|
|
else:
|
|
|
- return response.json(0, '删除成功.')
|
|
|
+ return response.json(0)
|
|
|
|
|
|
#设备关联套餐列表
|
|
|
def device_commodity(self, request_dict, response):
|
|
@@ -1254,7 +1254,7 @@ class CloudStorageView(View):
|
|
|
uid_bucket = UID_Bucket.objects.filter(uid=uid, endTime__gte=now_time).values("id", "uid", "endTime",
|
|
|
"bucket__content").order_by('endTime')
|
|
|
if not uid_bucket.exists():
|
|
|
- return response.json(404,'该设备未购买云存套餐.')
|
|
|
+ return response.json(10014)
|
|
|
for index, value in enumerate(uid_bucket):
|
|
|
value['is_use'] = 0
|
|
|
if index == 0:
|
|
@@ -1271,17 +1271,17 @@ class CloudStorageView(View):
|
|
|
"bucket__content").order_by('endTime')
|
|
|
|
|
|
if not using_uid_bucket.exists():
|
|
|
- return response.json(404,'该设备未购买云存套餐.')
|
|
|
+ return response.json(10014)
|
|
|
|
|
|
if int(using_uid_bucket[0]['id']) == int(switch_commodity_id):
|
|
|
- return response.json(404,'切换的云存套餐ID不能与正在使用中的相同.')
|
|
|
+ return response.json(10017)
|
|
|
|
|
|
# UID_Bucket.objects.filter(id=switch_commodity_id).update(is_use=1) #更新转移的云存套餐为使用中
|
|
|
UID_Bucket.objects.filter(id=using_uid_bucket[0]['id']).delete() #删除原来使用中的云存套餐
|
|
|
VodHlsModel.objects.filter(uid=uid).delete() #删除播放列表
|
|
|
StsCrdModel.objects.filter(uid=uid).delete() #删除sts记录
|
|
|
- return response.json(0,'切换云存套餐成功')
|
|
|
- return response.json(404,'切换的套餐ID不能为空')
|
|
|
+ return response.json(0)
|
|
|
+ return response.json(444)
|
|
|
|
|
|
#删除过期云存播放列表
|
|
|
def deleteVodHls(request):
|