#!/usr/bin/env python3 # -*- coding: utf-8 -*- """ @Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved. @AUTHOR: ASJRD018 @NAME: AnsjerFormal @software: PyCharm @DATE: 2018/12/5 9:30 @Version: python3.6 @MODIFY DECORD:ansjer dev @file: cloudstorage.py @Contact: chanjunkai@163.com """ import json import time import urllib import boto3 import oss2 import paypalrestsdk import threading import calendar import datetime from aliyunsdkcore import client from aliyunsdksts.request.v20150401 import AssumeRoleRequest from boto3.session import Session from django.http import JsonResponse, HttpResponseRedirect, HttpResponse from django.views.generic.base import View from Ansjer.config import OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET, OSS_ROLE_ARN, SERVER_DOMAIN, PAYPAL_CRD, \ SERVER_DOMAIN_SSL from Model.models import Device_Info, Order_Model, Store_Meal, VodHlsModel, OssCrdModel, UID_Bucket, StsCrdModel, \ ExperienceContextModel, Pay_Type, CDKcontextModel from Object.AliPayObject import AliPayObject from Object.ResponseObject import ResponseObject from Object.TokenObject import TokenObject from Object.UidTokenObject import UidTokenObject from Service.CommonService import CommonService from Object.m3u8generate import PlaylistGenerator from Object.WechatPayObject import WechatPayObject from django.db.models import Q SERVER_DOMAIN = 'http://test.dvema.com/' ''' 生成订单 http://test.dvema.com/cloudstorage/createpayorder?token=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VySUQiOiIxNTY3NzU4MjE4NjE5MTM4MDAxMzgwMDAiLCJleHAiOjE1ODk1MjM0OTIsIm1fY29kZSI6IjEyMzQxMzI0MzIxNCIsImxhbmciOiJlbiIsInVzZXIiOiIxMzExOTY1NzcxMyJ9.e2NdhJtbXrDngZTSmOX_52Y-oxyfUEXjZD_qNxg6VrU&uid=VVDHCVBYDKFMJRWA111A&channel=1&pay_type=0&commodity_code=aws_us_vod_7_val_30 开启开关 http://test.dvema.com/cloudstorage/changevodstatus?token=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VySUQiOiIxNTY3NzU4MjE4NjE5MTM4MDAxMzgwMDAiLCJleHAiOjE1ODk1MjM0OTIsIm1fY29kZSI6IjEyMzQxMzI0MzIxNCIsImxhbmciOiJlbiIsInVzZXIiOiIxMzExOTY1NzcxMyJ9.e2NdhJtbXrDngZTSmOX_52Y-oxyfUEXjZD_qNxg6VrU&uid=VVDHCVBYDKFMJRWA111A&channel=1&status=1 # 获取播放列表 http://localhost:8077/cloudstorage/queryvodlist?token=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VySUQiOiIxNTY3NzU4MjE4NjE5MTM4MDAxMzgwMDAiLCJleHAiOjE1ODk1MjM0OTIsIm1fY29kZSI6IjEyMzQxMzI0MzIxNCIsImxhbmciOiJlbiIsInVzZXIiOiIxMzExOTY1NzcxMyJ9.e2NdhJtbXrDngZTSmOX_52Y-oxyfUEXjZD_qNxg6VrU&uid=VVDHCVBYDKFMJRWA111A&startTime=1&endTime=1954687458&channel=1 # 存储视频列表信息 http://test.dvema.com/cloudstorage/storeplaylist?uidToken=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1aWQiOiJWVkRIQ1ZCWURLRk1KUldBMTExQSIsImNoYW5uZWwiOiIxIn0.eGwi5QKyrXi4WSKRbrUG7iFTChv_Utec2hSnqZkDKt8&time=1586940120&sec=20&fg=10 # 获取订单列表 http://localhost:8077/cloudstorage/queryorder?token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1c2VySUQiOiIxNTY3NzU4MjE4NjE5MTM4MDAxMzgwMDAiLCJsYW5nIjoiZW4iLCJ1c2VyIjoiMTMxMTk2NTc3MTMiLCJtX2NvZGUiOiIxMjM0MTMyNDMyMTQiLCJleHAiOjE1ODk1OTIyNzh9.u211DHiMKg-pqhXv4b2yR__eNyOcSwBZCyPUGjsxFLU&page=1&line=10&uid=VVDHCVBYDKFMJRWA111A # commoditylist http://test.dvema.com/cloudstorage/commoditylist?token=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VySUQiOiIxNTY3NzU4MjE4NjE5MTM4MDAxMzgwMDAiLCJleHAiOjE1ODk1MjM0OTIsIm1fY29kZSI6IjEyMzQxMzI0MzIxNCIsImxhbmciOiJlbiIsInVzZXIiOiIxMzExOTY1NzcxMyJ9.e2NdhJtbXrDngZTSmOX_52Y-oxyfUEXjZD_qNxg6VrU ''' # 设备信息添加 class CloudStorageView(View): def get(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.GET, request, operation) def post(self, request, *args, **kwargs): request.encoding = 'utf-8' operation = kwargs.get('operation') return self.validation(request.POST, request, operation) def validation(self, request_dict, request, operation): response = ResponseObject() if operation is None: return response.json(444, 'error path') elif operation == 'testpaly.m3u8': return self.do_test_play_m3u8(request_dict, response) elif operation == 'dopaypalcallback': return self.do_pay_by_paypal_callback(request_dict, response) elif operation == 'doalicallback': return self.do_pay_by_ali_callback(request) elif operation == 'dowechatnotify': return self.do_pay_by_wechat_callback(request_dict,response) elif operation == 'getsignsts': ip = CommonService.get_ip_address(request) return self.do_get_sign_sts(request_dict, ip, response) # return self.do_get_sign_sts_test(request_dict, ip, response) elif operation == 'storeplaylist': return self.do_store_playlist(request_dict, response) elif operation == 'signplaym3u8': return self.do_sign_play_m3u8(request_dict, response) elif operation == 'payOK': return self.do_pay_ok(request_dict) else: token = request_dict.get('token', None) # 设备主键uid tko = TokenObject(token) response.lang = tko.lang if tko.code != 0: return response.json(tko.code) userID = tko.userID if operation == 'createpayorder': return self.do_create_pay_order(request_dict, userID, response) elif operation == 'changevodstatus': return self.do_change_vod_status(request_dict, userID, response) elif operation == 'queryvodlist': return self.do_query_vod_list(request_dict, userID, response) elif operation == 'commoditylist': return self.do_commodity_list(request_dict, userID, response) elif operation == 'queryorder': return self.do_query_order(request_dict, userID, response) elif operation == 'experienceorder': return self.do_experience_order(request_dict, userID, response) elif operation == 'experiencereset': return self.do_experience_reset(request_dict, userID, response) elif operation == 'deletevodlist': return self.deleteVodList(request_dict, response) elif operation == 'devicecommodity': return self.device_commodity(request_dict, response) elif operation == 'switchdevicecommodity': return self.switch_device_commodity(request_dict, response) else: return response.json(414) def do_test_play_m3u8(self, request_dict, response): playlist_entries = [ { 'name': 'https://azvod1.s3-ap-northeast-1.amazonaws.com/test/output000.ts', 'duration': 10, }, { 'name': 'https://azvod1.s3-ap-northeast-1.amazonaws.com/test/output000.ts', 'duration': 10, }, { 'name': 'https://azvod1.s3-ap-northeast-1.amazonaws.com/test/output000.ts', 'duration': 10, }, ] playlist = PlaylistGenerator(playlist_entries).generate() # return HttpResponse(playlist) # response = HttpResponse(playlist, content_type="application/octet-stream") response = HttpResponse(playlist, content_type="application/vnd.apple.mpegurl") return response def do_query_order(self, request_dict, userID, response): status = request_dict.get('status', None) page = int(request_dict.get('page', None)) line = int(request_dict.get('line', None)) uid = request_dict.get('uid', None) order_qs = Order_Model.objects.filter(userID_id=userID) if status: order_qs = order_qs.filter(status=status) # 筛选指定设备id的订单 if uid: order_qs = order_qs.filter(UID=uid) if not order_qs.exists(): return response.json(173) # return response.json(10, '订单不存在') count = order_qs.count() order_ql = order_qs[(page - 1) * line:page * line]. \ values("orderID", "UID", "channel", "desc", "price", "currency", "addTime", "updTime", "endTime", "pay_url", "payType", "status", "commodity_type", "commodity_code") order_list = list(order_ql) data = [] nowTime = int(time.time()) # 这里需要进行优化 uid_list = [] for od in order_list: uid_list.append(od['UID']) didqs = Device_Info.objects.filter(userID_id=userID, UID__in=uid_list). \ values('id', 'UID', 'Type') for d in order_list: if d['status'] == 0: if d['addTime'] + 3600 < nowTime: d['status'] = 3 for did in didqs: if d['UID'] == did['UID']: d['did'] = did['id'] d['Type'] = did['Type'] data.append(d) return response.json(0, {'data': data, 'count': count}) def do_commodity_list(self, request_dict, userID, response): mold = request_dict.get('mold', None) uid = request_dict.get('uid', None) qs = Store_Meal.objects eq = ExperienceContextModel.objects.filter(uid=uid,experience_type=0).values('id') # userqs = Device_User.objects.filter(userID=userID).values('is_experience') if mold: qs = qs.filter(bucket__mold=mold) else: qs = qs.all() if eq: qs=qs.filter(~Q(pay_type='10')) else: qs = qs.filter(pay_type='10') qs=qs.filter(~Q(pay_type='11')) #过滤不显示激活码套餐 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") if qs.exists(): ql = list(qs) from operator import itemgetter from itertools import groupby ql.sort(key=itemgetter('bucket__area')) res = [] for area, items in groupby(ql, key=itemgetter('bucket__area')): items_list = list(items) for key, val in enumerate(items_list): pay_types = Pay_Type.objects.filter(store_meal=items_list[key]['id']).values("id","payment") items_list[key]['pay_type'] = list(pay_types) res_c = {'area': area, 'items': items_list} res.append(res_c) result = { 'meals': res, 'extra': { 'cloud_banner': 'https://www.dvema.com/web/images/cloud_cn_banner.png', 'cloud_en_baner': 'https://www.dvema.com/web/images/cloud_en_banner.png' } } return response.json(0, result) else: return response.json(0) def do_sign_play_m3u8(self, request_dict, response): uid = request_dict.get('uid', None) channel = request_dict.get('channel', None) storeTime = request_dict.get('time', None) now_time = int(time.time()) vh_qs = VodHlsModel.objects.filter(uid=uid, channel=channel, time=storeTime, endTime__gte=now_time). \ values("sec", "fg", "bucket__bucket", "bucket__endpoint", "bucket__region", "bucket__mold") if not vh_qs.exists(): return response.json(11,'不存在.') sec = vh_qs[0]['sec'] fg = vh_qs[0]['fg'] bucket__region = vh_qs[0]['bucket__region'] bucket_name = vh_qs[0]['bucket__bucket'] print(bucket__region) print(bucket_name) aws_access_key_id = 'AKIA2E67UIMD45Y3HL53' aws_secret_access_key = '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' session = Session( aws_access_key_id=aws_access_key_id, aws_secret_access_key=aws_secret_access_key, region_name=bucket__region ) ''' http://test.dvema.com/cloudstorage/signplaym3u8?uid=VVDHCVBYDKFMJRWA111A&channel=1&time=1586940120&sign=tktktktk ''' conn = session.client('s3') playlist_entries = [] # for i in range(fg): # thumbspng = '{uid}/vod{channel}/{time}/ts{i}.ts'. \ # format(uid=uid, channel=channel, time=storeTime, i=i) # response_url = conn.generate_presigned_url( # 'get_object', # Params={ # 'Bucket': bucket_name, # 'Key': thumbspng # }, # ExpiresIn=3600 # ) # # m3u8 = '{uid}/vod{channel}/{time}/{time}.m3u8'. \ # # format(uid=uid, channel=channel, time=vod['time']) # playlist_entries.append({ # 'name': response_url, # 'duration': sec, # }) for i in range(7): shift = (i+1)*4 duration = (fg >> shift) & 0xf if duration > 0: tsFile = '{uid}/vod{channel}/{time}/ts{i}.ts'. \ format(uid=uid, channel=channel, time=storeTime, i=i) response_url = conn.generate_presigned_url( 'get_object', Params={ 'Bucket': bucket_name, 'Key': tsFile }, ExpiresIn=3600 ) # m3u8 = '{uid}/vod{channel}/{time}/{time}.m3u8'. \ # format(uid=uid, channel=channel, time=vod['time']) playlist_entries.append({ 'name': response_url, 'duration': duration, }) playlist = PlaylistGenerator(playlist_entries).generate() response = HttpResponse(playlist) response['Content-Type'] = 'application/octet-stream' response['Content-Disposition'] = 'attachment;filename="play.m3u8"' return response # response = HttpResponse(playlist, content_type="application/vnd.apple.mpegurl") # response = HttpResponse(playlist, content_type="application/octet-stream") # return response def do_get_sign_sts(self, request_dict, ip, response): uidToken = request_dict.get('uidToken', None) utko = UidTokenObject(uidToken) if utko.flag is False: return response.json(444, 'uidToken') uid = utko.UID channel = utko.channel print(channel) print(uid) now_time = int(time.time()) ubqs = UID_Bucket.objects.filter(uid=uid, channel=channel, endTime__gte=now_time). \ values("bucket__mold", "bucket__bucket", "bucket__endpoint", "bucket__region", "endTime").order_by('endTime') print('-------------bucket') print(ubqs) if ubqs.exists(): if ubqs[0]["bucket__mold"] == 0: # 阿里云 oss sts oc_qs = OssCrdModel.objects.filter(uid=uid, channel=channel). \ values("addTime", "data") if oc_qs.exists(): endTime = int(oc_qs[0]["addTime"]) + 3500 if endTime > now_time: print(endTime) print(now_time) res = json.loads(oc_qs[0]["data"]) return JsonResponse(status=200, data=res) # 套餐id storage = '{uid}/vod{channel}/'.format(uid=uid, channel=channel) bucket_name = ubqs[0]['bucket__bucket'] endpoint = ubqs[0]['bucket__endpoint'] access_key_id = OSS_STS_ACCESS_KEY access_key_secret = OSS_STS_ACCESS_SECRET region_id = ubqs[0]['bucket__region'] role_arn = OSS_ROLE_ARN clt = client.AcsClient(access_key_id, access_key_secret, region_id) req = AssumeRoleRequest.AssumeRoleRequest() # 设置返回值格式为JSON。 req.set_accept_format('json') req.set_RoleArn(role_arn) req.set_RoleSessionName(uid + '_' + channel) req.set_DurationSeconds(3600) Resource_access = "acs:oss:*:*:{bucket_name}/{uid_channel}*". \ format(bucket_name=bucket_name, uid_channel=storage) print(Resource_access) policys = { "Version": "1", "Statement": [ { "Action": ["oss:PutObject", "oss:DeleteObject", ], "Resource": [Resource_access], "Effect": "Allow", "Condition": { "IpAddress": {"acs:SourceIp": ip} # "IpAddress": {"acs:SourceIp": "120.237.157.184"} # "IpAddress": {"acs:SourceIp": "*"} } } ] } req.set_Policy(Policy=json.dumps(policys)) body = clt.do_action(req) # 使用RAM账号的AccessKeyId和AccessKeySecret向STS申请临时token。 token = json.loads(body.decode('utf-8')) print(token) res = { 'AccessKeyId': token['Credentials']['AccessKeyId'], 'AccessKeySecret': token['Credentials']['AccessKeySecret'], 'SecurityToken': token['Credentials']['SecurityToken'], 'Expiration': token['Credentials']['Expiration'], 'expire': '3600', 'endpoint': endpoint, 'bucket_name': bucket_name, 'arn': token['AssumedRoleUser']['Arn'], 'code': 0, 'storage': storage, 'endTime': ubqs[0]['endTime'], 'ip': ip} if oc_qs.exists(): oc_qs.update(data=json.dumps(res), addTime=now_time) else: OssCrdModel.objects.create \ (uid=uid, channel=channel, data=json.dumps(res), addTime=now_time) return JsonResponse(status=200, data=res) elif ubqs[0]["bucket__mold"] == 1: # 亚马逊 s3 sts sts_qs = StsCrdModel.objects.filter(uid=uid, channel=channel). \ values("addTime", "data") if sts_qs.exists(): endTime = int(sts_qs[0]["addTime"]) + 3500 if endTime > now_time: print(endTime) print(now_time) res = json.loads(sts_qs[0]["data"]) return JsonResponse(status=200, data=res) # 套餐id storage = '{uid}/vod{channel}/'.format(uid=uid, channel=channel) bucket_name = ubqs[0]['bucket__bucket'] endpoint = ubqs[0]['bucket__endpoint'] region_id = ubqs[0]['bucket__region'] ############### REGION_NAME = region_id boto3_sts = boto3.client( 'sts', aws_access_key_id='AKIA2E67UIMD45Y3HL53', aws_secret_access_key='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', region_name=REGION_NAME ) print('--------2--test') print(REGION_NAME) Policy = { "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": "s3:*", "Resource": ["arn:aws:s3:::{bucket_name}/{uid_channel}*". format(bucket_name=bucket_name,uid_channel=storage)] } ] } print(Policy) response = boto3_sts.get_federation_token( Name='{role_name}'.format(role_name=uid + '_' + str(channel)), Policy=json.dumps(Policy), DurationSeconds=7200 ) ############### res = { 'AccessKeyId': response['Credentials']['AccessKeyId'], 'AccessKeySecret': response['Credentials']['SecretAccessKey'], 'SessionToken': response['Credentials']['SessionToken'], 'Expiration': response['Credentials']['Expiration'], 'expire': '3600', 'endpoint': endpoint, 'bucket_name': bucket_name, 'arn': response['FederatedUser']['Arn'], 'code': 0, 'storage': storage, 'endTime': ubqs[0]['endTime'], 'ip': ip, } if sts_qs.exists(): sts_qs.update(data=json.dumps(res,default=str), addTime=now_time) else: StsCrdModel.objects.create(uid=uid, channel=channel, data=json.dumps(res, default=str), addTime=now_time, type=1) return JsonResponse(status=200, data=res) else: res = {'code': 404, 'msg': 'data not exists!'} return HttpResponse(json.dumps(res, ensure_ascii=False),content_type="application/json,charset=utf-8") res = {'code': 405, 'msg': 'Not purchased or expired!'} return HttpResponse(json.dumps(res, ensure_ascii=False),content_type="application/json,charset=utf-8") def do_query_vod_list(self, request_dict, userID, response): startTime = int(request_dict.get('startTime', None)) endTime = int(request_dict.get('endTime', None)) uid = request_dict.get('uid', None) channel = request_dict.get('channel', None) dv_qs = Device_Info.objects.filter(UID=uid, userID_id=userID, isShare=False) if not dv_qs.exists(): return response.json(12) 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(10008) 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") vod_play_list = [] print(int(time.time())) for vod in vh_qs: bucket__mold = vod["bucket__mold"] bucket_name = vod["bucket__bucket"] endpoint = vod["bucket__endpoint"] bucket__region = vod["bucket__region"] if bucket__mold == 0: auth = oss2.Auth(OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET) bucket = oss2.Bucket(auth, endpoint, bucket_name) m3u8 = '{uid}/vod{channel}/{time}/{time}.m3u8'. \ format(uid=uid, channel=channel, time=vod['time']) ts = '{uid}/vod{channel}/{time}/ts0.ts'. \ format(uid=uid, channel=channel, time=vod['time']) url = bucket.sign_url('GET', m3u8, 3600, params={'x-oss-process': 'hls/sign'}) urllst = url.split('?') url_start = urllib.parse.unquote(urllst[0]) url_end = urllst[1] vod_play_url = '{url_start}?{url_end}'. \ format(url_start=url_start, url_end=url_end) thumb = bucket.sign_url('GET', ts, 3600, params={'x-oss-process': 'video/snapshot,t_10000,m_fast,w_300'}) vod_play_list.append({'name': vod['time'], 'sign_url': vod_play_url, 'thumb': thumb, 'sec': vod['sec'], 'vod_id': vod['id']}) elif bucket__mold == 1: # aws_access_key_id = 'AKIA2E67UIMD45Y3HL53' # aws_secret_access_key = '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' # session = Session( # aws_access_key_id=aws_access_key_id, # aws_secret_access_key=aws_secret_access_key, # region_name=bucket__region # ) # conn = session.client('s3') # thumbspng = '{uid}/vod{channel}/{time}/Thumb.jpeg'. \ # format(uid=uid, channel=channel, time=vod['time']) # response_url = conn.generate_presigned_url( # 'get_object', # Params={ # 'Bucket': bucket_name, # 'Key': thumbspng # }, # ExpiresIn=3600 # ) # thumb_url = response_url # format(uid=uid, channel=channel, time=vod['time']) vod_url = '{server_domain}/cloudstorage/signplaym3u8?' \ 'uid={uid}&channel={channel}&time={time}&sign=tktktktk'. \ format(server_domain=SERVER_DOMAIN,uid=uid, channel=channel, time=vod['time']) ts_num = vod['fg'] & 0xf vod_play_list.append({ 'name': vod['time'], 'sign_url': vod_url, # 'thumb': thumb_url, 'sec': vod['sec'], 'ts_num' : ts_num, 'vod_id': vod['id'] }), return response.json(0, vod_play_list) def do_store_playlist(self, request_dict, response): uidToken = request_dict.get('uidToken', None) storeTime = request_dict.get('time', None) sec = request_dict.get('sec', None) fg = request_dict.get('fg', None) utko = UidTokenObject(uidToken) if utko.flag is False: return response.json(444, 'uidToken') if not uidToken or not storeTime or not sec: return response.json(0) pass UID = utko.UID channel = utko.channel print('UID:') print(UID) print('channel:') print(channel) now_time = int(time.time()) ubqs = UID_Bucket.objects.filter(uid=UID, channel=channel, is_use=1, endTime__gte=now_time). \ values("bucket__mold", "bucket__bucket", "bucket__endpoint", "bucket__region", "status", "bucket__storeDay", "bucket__id").order_by('endTime') if ubqs.exists(): ub_qs_data = ubqs[0] store_day = ub_qs_data['bucket__storeDay'] bucket_id = ub_qs_data['bucket__id'] end_time = int(storeTime) + store_day * 86400 if ub_qs_data['status'] == 1: if ub_qs_data["bucket__mold"] == 0: oss_crd_qs = OssCrdModel.objects.filter(uid=UID, channel=channel) if oss_crd_qs.exists(): VodHlsModel.objects.create( uid=UID, channel=channel, time=storeTime, endTime=end_time, bucket_id=bucket_id, sec=sec, ) res = {'code': 0, 'msg': '存储成功'} return HttpResponse(json.dumps(res, ensure_ascii=False), content_type="application/json,charset=utf-8") else: res = {'code': 404, 'msg': '设备未购买'} return HttpResponse(json.dumps(res, ensure_ascii=False), content_type="application/json,charset=utf-8") elif ub_qs_data['bucket__mold'] == 1: sts_qs = StsCrdModel.objects.filter(uid=UID, channel=channel, type=1). \ values("addTime", "data") if sts_qs.exists(): VodHlsModel.objects.create( uid=UID, channel=channel, time=storeTime, endTime=end_time, bucket_id=bucket_id, fg=fg, sec=sec, ) res = {'code': 0, 'msg': '存储成功'} return HttpResponse(json.dumps(res, ensure_ascii=False), content_type="application/json,charset=utf-8") else: res = {'code': 404, 'msg': '设备未购买'} return HttpResponse(json.dumps(res, ensure_ascii=False), content_type="application/json,charset=utf-8") else: res = {'code': 404, 'msg': '设备未开启'} return HttpResponse(json.dumps(res, ensure_ascii=False), content_type="application/json,charset=utf-8") else: res = {'code': 404, 'msg': '设备未购买'} return HttpResponse(json.dumps(res, ensure_ascii=False), content_type="application/json,charset=utf-8") # def do_change_vod_status(self, request_dict, userID, response): # uid = request_dict.get('uid', None) # status = request_dict.get('status', None) # channel = request_dict.get('channel', None) # if all([uid, status, channel]): # dv_qs = Device_Info.objects.filter(UID=uid, userID_id=userID, isShare=False, isExist=1) # if dv_qs.exists(): # now_time = int(time.time()) # ub_qs = UID_Bucket.objects.filter(uid=uid, channel=channel, endTime__gte=now_time) # if ub_qs.exists(): # ub_qs.status = status # ub_qs.save() # if status == 0: # return response.json(0) # else: # utko = UidTokenObject() # utko.generate(data={'uid': uid, 'channel': channel}) # uidTK = utko.token # uidTkUrl = "{SERVER_DOMAIN}cloudstorage/getsignsts?uidToken={uidToken}". \ # format(uidToken=uidTK, SERVER_DOMAIN=SERVER_DOMAIN) # storeHlsUrl = "{SERVER_DOMAIN}cloudstorage/storeplaylist?uidToken={uidToken}". \ # format(uidToken=uidTK, SERVER_DOMAIN=SERVER_DOMAIN) # return response.json(0, {'uidTkUrl': uidTkUrl, 'storeHlsUrl': storeHlsUrl}) # else: # return response.json(10, '未购买') # else: # return response.json(12) # else: # return response.json(444, 'uid,status,channel') def do_change_vod_status(self, request_dict, userID, response): uid = request_dict.get('uid', None) status = request_dict.get('status', None) channel = request_dict.get('channel', None) if not uid or not status or not channel: return response.json(444, 'uid,status,channel') dvqs = Device_Info.objects.filter(UID=uid, userID_id=userID, isShare=False) if not dvqs.exists(): return response.json(12) ubqs = UID_Bucket.objects.filter(channel=channel, uid=uid).order_by('endTime') print(ubqs) exit() if not ubqs.exists(): return response.json(10, '未购买') now_time = int(time.time()) if now_time > ubqs[0].endTime: return response.json(10008) ubqs.update(status=status) if status == 0: return response.json(0) utko = UidTokenObject() utko.generate(data={'uid': uid, 'channel': channel}) uidTkUrl = "{SERVER_DOMAIN}cloudstorage/getsignsts?uidToken={uidToken}". \ format(uidToken=utko.token, SERVER_DOMAIN=SERVER_DOMAIN) storeHlsUrl = "{SERVER_DOMAIN}cloudstorage/storeplaylist?uidToken={uidToken}". \ format(uidToken=utko.token, SERVER_DOMAIN=SERVER_DOMAIN) return response.json(0, {'uidTkUrl': uidTkUrl, 'storeHlsUrl': storeHlsUrl}) def do_pay_error(self): response = HttpResponse() response.content = ''' Trading particulars
Trading particulars


Payment failure

Finish
''' return response def do_pay_ok(self,request_dict): response = HttpResponse() paytype = request_dict.get('paytype', None) showtitle = "支付成功" if paytype == "10": showtitle = "成功体验云存" if paytype == "11": showtitle = "兑换成功" response.content = ''' '''+showtitle+'''


'''+showtitle+'''

完成
''' return response def do_pay_by_ali_callback(self, request): response = ResponseObject() data = request.POST.dict() signature = data["sign"] data.pop('sign') orderID = data['out_trade_no'] order_qs = Order_Model.objects.filter(orderID=orderID, status=0) print(order_qs) if not order_qs.exists(): return response.json(404) print(json.dumps(data)) print(signature) # verify aliPayObj = AliPayObject() alipay = aliPayObj.conf() success = alipay.verify(data, signature) if success and data["trade_status"] in ("TRADE_SUCCESS", "TRADE_FINISHED"): print("trade succeed") nowTime = int(time.time()) order_list = order_qs.values("UID", "commodity_code", "channel") UID = order_list[0]['UID'] channel = order_list[0]['channel'] commodity_code = order_list[0]['commodity_code'] order_qs.update(status=1, updTime=nowTime) smqs = Store_Meal.objects.filter(commodity_code=commodity_code). \ values("day", "bucket_id", "bucket__storeDay") bucketId = smqs[0]['bucket_id'] if not smqs.exists(): return response.json(0, '套餐已删除') addTime = int(smqs[0]["day"]) * 24 * 3600 ubqs = UID_Bucket.objects.filter(uid=UID, channel=channel). \ values("bucket_id", "endTime", "bucket__storeDay") nowTime = int(time.time()) if ubqs.exists(): ubqs_count = ubqs.count() ubq = ubqs[ubqs_count - 1, ubqs_count] new_starTime = ubq['endTime'] + 1 ub_cqs = UID_Bucket.objects.create(uid=UID, channel=channel, bucket_id=bucketId, endTime=new_starTime + addTime) uid_bucket_id = ub_cqs.id else: ub_cqs = UID_Bucket.objects.create(uid=UID, channel=channel, bucket_id=bucketId, endTime=nowTime + addTime) uid_bucket_id = ub_cqs.id order_qs.update \ (payTime=nowTime, status=1, updTime=nowTime, uid_bucket_id=uid_bucket_id) red_url = "{SERVER_DOMAIN}cloudstorage/payOK".format(SERVER_DOMAIN=SERVER_DOMAIN) return HttpResponseRedirect(red_url) return response.json(0, signature) def do_pay_by_paypal_callback(self, request_dict, response): paymentId = request_dict.get('paymentId', None) PayerID = request_dict.get('PayerID', None) orderID = request_dict.get('orderID', None) if not paymentId or not PayerID or not orderID: red_url = "{SERVER_DOMAIN}cloudstorage/payError".format(SERVER_DOMAIN=SERVER_DOMAIN) return HttpResponseRedirect(red_url) paypalrestsdk.configure(PAYPAL_CRD) # ID of the payment. This ID is provided when creating payment. payment = paypalrestsdk.Payment.find(paymentId) payres = payment.execute({"payer_id": PayerID}) print(payres) if not payres: red_url = "{SERVER_DOMAIN}cloudstorage/payError".format(SERVER_DOMAIN=SERVER_DOMAIN) return HttpResponseRedirect(red_url) print("Payment execute successfully") order_qs = Order_Model.objects.filter(orderID=orderID) nowTime = int(time.time()) order_list = order_qs.values("UID", "channel", "commodity_code", "rank", "isSelectDiscounts") UID = order_list[0]['UID'] channel = order_list[0]['channel'] rank = order_list[0]['rank'] smqs = Store_Meal.objects.filter(id=rank). \ values("day", "bucket_id", "bucket__storeDay", "expire") bucketId = smqs[0]['bucket_id'] if not smqs.exists(): return response.json(0, '套餐已删除') # ## ubqs = UID_Bucket.objects.filter(bucket__id=bucketId, uid=UID, channel=channel, endTime__gte=nowTime). \ values("id", "bucket__storeDay", "bucket__region", "endTime") expire = smqs[0]['expire'] if order_list[0]['isSelectDiscounts'] == 1: expire = smqs[0]['expire'] * 2 if ubqs.exists(): ubqs_count = ubqs.count() print(ubqs_count) ubq = ubqs[ubqs_count - 1] endTime = CommonService.calcMonthLater(expire,ubq['endTime']) ub_cqs = UID_Bucket.objects.filter(id=ubq['id']).update \ (uid=UID, channel=channel, bucket_id=bucketId, endTime=endTime) uid_bucket_id = ubq['id'] else: endTime = CommonService.calcMonthLater(expire) ub_cqs = UID_Bucket.objects.create \ (uid=UID, channel=channel, bucket_id=bucketId, endTime=endTime) uid_bucket_id = ub_cqs.id order_qs.update(status=1, updTime=nowTime, uid_bucket_id=uid_bucket_id) # return response.json(0) red_url = "{SERVER_DOMAIN}cloudstorage/payOK".format(SERVER_DOMAIN=SERVER_DOMAIN) return HttpResponseRedirect(red_url) def do_pay_by_wechat_callback(self, request_dict, response): result_code = request_dict.get('result_code', None) if result_code == 'SUCCESS': response = HttpResponse() check_sign = WechatPayObject.get_notifypay(request_dict) if not check_sign: return HttpResponse(WechatPayObject.xml_to_dict({'return_code':'FAIL', 'return_msg':'签名失败'})) orderID = request_dict.get('out_trade_no',None) order_qs = Order_Model.objects.filter(orderID=orderID) nowTime = int(time.time()) order_list = order_qs.values("UID", "channel", "commodity_code") UID = order_list[0]['UID'] channel = order_list[0]['channel'] commodity_code = order_list[0]['commodity_code'] smqs = Store_Meal.objects.filter(commodity_code=commodity_code). \ values("day", "bucket_id", "bucket__storeDay") bucketId = smqs[0]['bucket_id'] if not smqs.exists(): return HttpResponse(WechatPayObject.xml_to_dict({'return_code':'FAIL', 'return_msg':'套餐不存在'})) addTime = int(smqs[0]["day"]) * 24 * 3600 # ## ubqs = UID_Bucket.objects.filter(uid=UID, channel=channel, endTime__gte=nowTime). \ values("bucket__storeDay", "bucket__region", "endTime") if ubqs.exists(): ubqs_count = ubqs.count() print(ubqs_count) ubq = ubqs[ubqs_count - 1] print(ubq) new_starTime = ubq['endTime'] + 1 ub_cqs = UID_Bucket.objects.create \ (uid=UID, channel=channel, bucket_id=bucketId, endTime=new_starTime + addTime) uid_bucket_id = ub_cqs.id else: ub_cqs = UID_Bucket.objects.create \ (uid=UID, channel=channel, bucket_id=bucketId, endTime=nowTime + addTime) uid_bucket_id = ub_cqs.id order_qs.update(status=1, updTime=nowTime, uid_bucket_id=uid_bucket_id) return HttpResponse(WechatPayObject.xml_to_dict({'return_code':'SUCCESS', 'return_msg':'OK'})) return HttpResponse(WechatPayObject.xml_to_dict({'return_code':'FAIL', 'return_msg':'参数格式校验错误'})) def do_create_pay_order(self, request_dict, userID, response): uid = request_dict.get('uid', None) channel = request_dict.get('channel', None) pay_type = int(request_dict.get('pay_type', None)) 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, '参数有误.') dv_qs = Device_Info.objects.filter(userID_id=userID, UID=uid, isShare=False, isExist=1) if not dv_qs.exists(): return response.json(12) 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, '套餐不存在') currency = smqs[0]['currency'] price = smqs[0]['price'] if is_select_discount == '1': price = float(smqs[0]['price']) + float(smqs[0]['discount_price']) content = smqs[0]['content'] day = smqs[0]['day'] commodity_code = smqs[0]['commodity_code'] commodity_type = smqs[0]['commodity_type'] # ubqs = UID_Bucket.objects.filter(uid=uid, channel=channel, endTime__gte=nowTime). \ # values("bucket__storeDay", "bucket__region", "endTime") # if ubqs.exists(): # ubqs_count = ubqs.count() # ubq = ubqs[ubqs_count - 1, ubqs_count] # new_starTime = ubq['endTime'] + 1 nowTime = int(time.time()) orderID = CommonService.createOrderID() if pay_type == 1: call_sub_url = "{SERVER_DOMAIN}cloudstorage/dopaypalcallback?orderID={orderID}". \ format(SERVER_DOMAIN=SERVER_DOMAIN, orderID=orderID) # call_sub_url = "http://192.168.136.40:8077/cloudstorage/payExecute?orderID={orderID}".format( # SERVER_DOMAIN=SERVER_DOMAIN, orderID=orderID) call_clc_url = "{SERVER_DOMAIN}cloudstorage/payError".format(SERVER_DOMAIN=SERVER_DOMAIN) paypalrestsdk.configure(PAYPAL_CRD) payment = paypalrestsdk.Payment({ "intent": "sale", "payer": {"payment_method": "paypal"}, "redirect_urls": {"return_url": call_sub_url, "cancel_url": call_clc_url}, "transactions": [{ "item_list": {"items": [ {"name": "Cloud video", "sku": "1", "price": price, "currency": "USD", "quantity": 1}]}, "amount": {"total": price, "currency": currency}, "description": content}]}) if payment.create(): print("Payment created successfully") else: print(payment.error) return response.json(10, payment.error) print(payment) for link in payment.links: if link.rel == "approval_url": approval_url = str(link.href) print("Redirect for approval: %s" % (approval_url)) Order_Model.objects.create(orderID=orderID, UID=uid, channel=channel, userID_id=userID, desc=content, payType=pay_type, payTime=nowTime, price=price, currency=currency, addTime=nowTime, updTime=nowTime, pay_url=approval_url, isSelectDiscounts=is_select_discount, commodity_code=commodity_code, commodity_type=commodity_type,rank_id=rank) return response.json(0, {"redirectUrl": approval_url, "orderID": orderID}) return response.json(10, 'generate_order_false') elif pay_type == 2: try: aliPayObj = AliPayObject() alipay = aliPayObj.conf() subject = smqs[0]['title'] + smqs[0]['content'] order_string = alipay.api_alipay_trade_wap_pay( out_trade_no=orderID, total_amount=price, subject=subject, return_url="{SERVER_DOMAIN_SSL}cloudstorage/payOK".format(SERVER_DOMAIN_SSL=SERVER_DOMAIN_SSL), notify_url="{SERVER_DOMAIN_SSL}cloudstorage/doalicallback".format( SERVER_DOMAIN_SSL=SERVER_DOMAIN_SSL) # return_url="http://192.168.136.40/cloudstorage/payOK", # notify_url="http://192.168.136.40/cloudstorage/aliPayCallback" ) except Exception as e: print(repr(e)) return response.json(10, repr(e)) else: if order_string: redirectUrl = aliPayObj.alipay_prefix + order_string print('---------tttt') print(redirectUrl) Order_Model.objects.create(orderID=orderID, UID=uid, channel=channel, userID_id=userID, desc=content, payType=pay_type, payTime=nowTime, price=price, currency=currency, addTime=nowTime, updTime=nowTime, pay_url=redirectUrl, isSelectDiscounts=is_select_discount, commodity_code=commodity_code, commodity_type=commodity_type,rank_id=rank) return JsonResponse(status=200, data={'result_code': 0, 'reason': 'success', 'result': {"redirectUrl": redirectUrl, "orderID": orderID}, 'error_code': 0}) else: return response.json(10, '生成订单错误.') elif pay_type == 3: # spbill_create_ip = '127.0.0.1' spbill_create_ip = '120.237.157.184' pay = WechatPayObject() notify_url="{SERVER_DOMAIN_SSL}cloudstorage/dowechatnotify".format( SERVER_DOMAIN_SSL=SERVER_DOMAIN_SSL) # 获取参数 price = float(price)*100 parameter_dict = pay.get_parameter(orderID, content, price, spbill_create_ip, notify_url) print('parameter_dict', parameter_dict) # parameter_dict 参数中获取MWEB_URL 调转页面在路径后面添加redirect_url # 统一调用接口 response = pay.re_finall() if not response: return response.json(10, '生成订单错误.') # 回调函数 Order_Model.objects.create(orderID=orderID, UID=uid, channel=channel, userID_id=userID, desc=content, payType=pay_type, payTime=nowTime, price=price, currency=currency, addTime=nowTime, updTime=nowTime, pay_url=notify_url, isSelectDiscounts=is_select_discount, commodity_code=commodity_code, commodity_type=commodity_type,rank_id=rank) return JsonResponse(status=200, data={'result_code': 0, 'reason': 'success', 'result': response, 'orderId': orderID, 'error_code': 0}) # 调起支付接口 # 生成体验订单 def do_experience_order(self, request_dict, userID, response): uid = request_dict.get('uid', None) channel = request_dict.get('channel', None) commodity_code = request_dict.get('commodity_code', None) pay_type = int(request_dict.get('pay_type', None)) rank = request_dict.get('rank', None) cdk = request_dict.get('cdk', None) if cdk != None and pay_type == 11: cdk_qs = CDKcontextModel.objects.filter(cdk=cdk).values('is_activate', 'rank__id', 'rank__commodity_code') if not cdk_qs.exists(): return response.json(10, '无效激活码') if cdk_qs[0]['is_activate'] == 1: return response.json(10, '激活码已被使用过') rank = cdk_qs[0]['rank__id'] commodity_code = cdk_qs[0]['rank__commodity_code'] if uid == None or channel == None or commodity_code == None or pay_type == None or rank == None: return response.json(13, '参数有误.') dv_qs = Device_Info.objects.filter(userID_id=userID, UID=uid, isShare=False, isExist=1) if not dv_qs.exists(): return response.json(12) smqs = Store_Meal.objects.filter(commodity_code=commodity_code, pay_type=pay_type). \ values('currency', 'price', 'content', 'day', 'commodity_type', 'title', 'content') if not smqs.exists(): return response.json(10, '套餐不存在') currency = smqs[0]['currency'] price = smqs[0]['price'] content = smqs[0]['content'] day = smqs[0]['day'] commodity_type = smqs[0]['commodity_type'] # ubqs = UID_Bucket.objects.filter(uid=uid, channel=channel, endTime__gte=nowTime). \ # values("bucket__storeDay", "bucket__region", "endTime") # if ubqs.exists(): # ubqs_count = ubqs.count() # ubq = ubqs[ubqs_count - 1, ubqs_count] # new_starTime = ubq['endTime'] + 1 nowTime = int(time.time()) orderID = CommonService.createOrderID() Order_Model.objects.create(orderID=orderID, UID=uid, channel=channel, userID_id=userID, desc=content, payType=pay_type, payTime=nowTime, price=price, currency=currency, addTime=nowTime, updTime=nowTime, pay_url="体验版", commodity_code=commodity_code, commodity_type=commodity_type, rank_id=rank) order_qs = Order_Model.objects.filter(orderID=orderID) nowTime = int(time.time()) order_list = order_qs.values("UID", "channel", "commodity_code") UID = order_list[0]['UID'] channel = order_list[0]['channel'] commodity_code = order_list[0]['commodity_code'] smqs = Store_Meal.objects.filter(commodity_code=commodity_code). \ values("day", "bucket_id", "bucket__storeDay") bucketId = smqs[0]['bucket_id'] if not smqs.exists(): return response.json(0, '套餐已删除') addTime = int(smqs[0]["day"]) * 24 * 3600 # ## ubqs = UID_Bucket.objects.filter(uid=UID, channel=channel, endTime__gte=nowTime). \ values("bucket__storeDay", "bucket__region", "endTime") if ubqs.exists(): ubqs_count = ubqs.count() print(ubqs_count) ubq = ubqs[ubqs_count - 1] print(ubq) new_starTime = ubq['endTime'] + 1 ub_cqs = UID_Bucket.objects.create \ (uid=UID, channel=channel, bucket_id=bucketId, endTime=new_starTime + addTime) uid_bucket_id = ub_cqs.id else: ub_cqs = UID_Bucket.objects.create \ (uid=UID, channel=channel, bucket_id=bucketId, endTime=nowTime + addTime) uid_bucket_id = ub_cqs.id order_qs.update(status=1, updTime=nowTime, uid_bucket_id=uid_bucket_id) # return response.json(0) returnurl = "{SERVER_DOMAIN}cloudstorage/payOK".format(SERVER_DOMAIN=SERVER_DOMAIN) if pay_type == 10: ExperienceContextModel.objects.create( experience_type=0, uid=uid, do_time=nowTime ) returnurl = "{SERVER_DOMAIN}cloudstorage/payOK?paytype=10".format(SERVER_DOMAIN=SERVER_DOMAIN) if pay_type== 11: update_dict = {} update_dict['is_activate'] = 1 update_dict['order'] = orderID CDKcontextModel.objects.filter(cdk=cdk).update(**update_dict) returnurl = "{SERVER_DOMAIN}cloudstorage/payOK?paytype=11".format(SERVER_DOMAIN=SERVER_DOMAIN) result = returnurl return response.json(0, result) # red_url = # return JsonResponse(status=200, data={'red_url': red_url}) # return HttpResponseRedirect(red_url) #重置设备云存体验 def do_experience_reset(self, request_dict, userID, response): bid = request_dict.get("id",None) ubq = UID_Bucket.objects.filter(id=bid) if ubq: eq =ExperienceContextModel.objects.filter(uid = ubq[0].uid) if eq: eq.delete() Order_Model.objects.filter(uid_bucket_id = bid).delete() ubq.delete() else: return response.json(10007) else: return response.json(0, '重置云存体验失败') return response.json(0,'重置云存体验成功') def deleteVodList(self, request_dict, response): uid = request_dict.get('uid',None) vod_id_list = json.loads(request_dict.get('vod_id_list', None)) is_del_all = request_dict.get('is_del_all',0) try: if is_del_all == 1: VodHlsModel.objects.filter(uid=uid).delete() else: if type(vod_id_list).__name__ != 'list': return response.json(424, 'vod_id_list格式错误') VodHlsModel.objects.filter(id__in=vod_id_list).delete() except Exception as e: return response.json(424, repr(e)) else: return response.json(0, '删除成功.') #设备关联套餐列表 def device_commodity(self, request_dict, response): uid = request_dict.get('uid',None) now_time = int(time.time()) 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,'该设备未购买云存套餐.') for index, value in enumerate(uid_bucket): value['is_use'] = 0 if index == 0: value['is_use'] = 1 return response.json(0,list(uid_bucket)) #切换设备关联套餐 def switch_device_commodity(self, request_dict, response): uid = request_dict.get('uid',None) switch_commodity_id = request_dict.get('switch_commodity_id',None) if switch_commodity_id: #切换设备套餐关联 using_uid_bucket = UID_Bucket.objects.filter(uid=uid, is_use='1').values("id", "uid", "endTime", "bucket__content").order_by('endTime') if not using_uid_bucket.exists(): return response.json(404,'该设备未购买云存套餐.') if int(using_uid_bucket[0]['id']) == int(switch_commodity_id): return response.json(404,'切换的云存套餐ID不能与正在使用中的相同.') # 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不能为空') #删除过期云存播放列表 def deleteVodHls(request): # UID = 'DSXG7481JVA2JM94111A' # channel = 1 # ubqs = UID_Bucket.objects.filter(uid=UID, channel=channel). \ # values("bucket_id", "endTime", "bucket__storeDay") # nowTime = int(time.time()) # if ubqs.exists(): # ubqs_count = ubqs.count() # ubq = ubqs[ubqs_count - 1, ubqs_count] # new_starTime = ubq['endTime'] + 1 # print(new_starTime) # exit() # # # ub_cqs = UID_Bucket.objects.create(uid=UID, channel=channel, bucket_id=bucketId, # # endTime=new_starTime + addTime) # # uid_bucket_id = ub_cqs.id # exit() response = ResponseObject() i = int(request.GET.get('i', 5)) nowTime = int(time.time()) for i in range(i): vh_qs = VodHlsModel.objects.filter(endTime__lte=str(nowTime))[0:10000] id_list = vh_qs.values_list("id", flat=True) print(id_list) VodHlsModel.objects.filter(id__in=list(id_list)).delete() return response.json(0) #删除过期云存关联套餐 def deleteExpiredUidBucket(request): response = ResponseObject() now_time = int(time.time()) expired_uid_bucket = UID_Bucket.objects.filter(endTime__lte=now_time) id_list = expired_uid_bucket.values_list("id", flat=True) UID_Bucket.objects.filter(id__in=list(id_list)).delete() #删除过期云存关联套餐, 后续是否考虑用软删除 return response.json(0)