| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632 | 
							- from django.views.generic.base import View
 
- from django.utils.decorators import method_decorator
 
- from django.views.decorators.csrf import csrf_exempt
 
- from Service.ModelService import ModelService
 
- from Model.models import Equipment_Stream
 
- from Object.AWS.S3ClassObject import S3ClassObject
 
- from Object.AWS.ElasticTranscoder import ElasticTranscoder
 
- import traceback, xmltodict, requests, re, subprocess, time, os,simplejson as json
 
- from ffmpy import FFmpeg
 
- from Object.AWS.CloudfrontSignCookie import BetterThanBoto
 
- from Ansjer.config import NGINX_RTMP_STAT, RTMP_PUSH_URL
 
- from Ansjer.settings import BASE_DIR
 
- from Object.TokenObject import TokenObject
 
- from Object.ResponseObject import ResponseObject
 
- from Service.CommonService import CommonService
 
- from django.http import HttpResponse
 
- '''
 
- 移动端=>
 
- 增:
 
- http://192.168.136.40:8077/media/stream?token=test&channel=1&status=1&uid=1&operation=add
 
- 删:
 
- http://192.168.136.40:8077/media/stream?token=test&id=11&id=12&operation=delete
 
- 改:
 
- http://192.168.136.40:8077/media/stream?token=test&id=13&operation=update&status=0
 
- 查:
 
- http://192.168.136.40:8077/media/stream?token=test&operation=query
 
- 获取视频播放地址
 
- http://13.56.215.252:82/media/stream?token=test&channel=99&uid=2N1K3LE78TYJ38CE111A&filename=1526882855.flv&operation=getVodHls
 
- http://192.168.136.40:8077/media/stream?token=test&channel=1&uid=1&operation=getVodUrl&filename=1_1-1523247439.mp4
 
- 获取所有保存s3的视频
 
- http://192.168.136.40:8077/media/stream?token=test&channel=1&uid=1&operation=getAllVideo
 
- 删除设备视频多个,key值传多个即可
 
- http://192.168.136.40:8077/media/stream?token=test&key=UKPAH63V23U4ZHEB111A_1/UKPAH63V23U4ZHEB111A_1-1524039164.mp4&uid=UKPAH63V23U4ZHEB111A&channel=1&operation=getDelVideo
 
- ----------------------------------------------------------------------------------------------------
 
- 后台=>
 
- 验证推流权限
 
- http://192.168.136.40:8077/media/auth_stream?userID=151547867345163613800138001&uid=1&channel=1&access_token=test
 
- 验证播放权限(直播)
 
- http://192.168.136.40:8077/media/auth_live?userID=151547867345163613800138001&uid=1&channel=1&token=test
 
- rtmp://192.168.136.45:1935/hls/UKPAH63V23U4ZHEB111A_88?userID=151547867
 
- 获取所有推流的设备信息
 
- http://192.168.136.40:8077/media/stream?token=test&page=1&line=10&operation=getAdminAllStream
 
- 删除流
 
- http://192.168.136.40:8077/media/stream?token=test&id=1&id=2&id=3&operation=getAdminDelStream
 
- 删除指定设备视频
 
- http://192.168.136.40:8077/media/stream?token=test&key=1&key=2&key=3&operation=getAdminDelVideo
 
- 更新
 
- http://192.168.136.40:8077/media/stream?token=test&id=13&operation=getAdminUpdateStream&status=0
 
- 获取指定设备存储的视频播放地址
 
- http://192.168.136.40:8077/media/stream?token=test&channel=1&uid=1&filename=1_1-1523247439.mp4&operation=getAdminVodUrl
 
- hls播放
 
- http://13.56.215.252:82/media/stream?token=test&channel=1&status=1&uid=2N1K3LE78TYJ38CE111A&operation=add&rank=1
 
- '''
 
- class StreamMedia(View):
 
-     @method_decorator(csrf_exempt)
 
-     def dispatch(self, *args, **kwargs):
 
-         return super(StreamMedia, self).dispatch(*args, **kwargs)
 
-     def get(self, request, *args, **kwargs):
 
-         request.encoding = 'utf-8'
 
-         return self.validation(request_dict=request.GET)
 
-     def post(self, request, *args, **kwargs):
 
-         request.encoding = 'utf-8'
 
-         return self.validation(request_dict=request.POST)
 
-     def validation(self, request_dict, *args, **kwargs):
 
-         response = ResponseObject()
 
-         token = request_dict.get('token', None)
 
-         if token is not None:
 
-             tko = TokenObject(token)
 
-             tko.valid()
 
-             response.lang = tko.lang
 
-             if tko.code == 0:
 
-                 userID = tko.userID
 
-                 own_permission = ModelService.check_permission(userID=userID, permID=60)
 
-                 if own_permission is not True:
 
-                     operation = request_dict.get('operation', None)
 
-                     if operation == 'add':
 
-                         return self.add_stream(token=token, request_dict=request_dict, userID=userID, response=response)
 
-                     elif operation == 'delete':
 
-                         return self.delete_stream(request_dict=request_dict, userID=userID, response=response)
 
-                     elif operation == 'update':
 
-                         return self.update_stream(userID=userID, request_dict=request_dict, response=response)
 
-                     elif operation == 'query':
 
-                         return self.query_stream(userID=userID, response=response)
 
-                     elif operation == 'getDelVideo':
 
-                         return self.get_del_video(userID=userID, request_dict=request_dict, response=response)
 
-                     elif operation == 'getAllVideo':
 
-                         return self.get_all_video(request_dict=request_dict, userID=userID, response=response)
 
-                     elif operation == 'getVodUrl':
 
-                         return self.get_vod_url(request_dict=request_dict, response=response)
 
-                     elif operation == 'getVodHls':
 
-                         return self.get_vod_hls(request_dict=request_dict, response=response)
 
-                     elif operation == 'getAdminAllStream':
 
-                         return self.get_admin_all_stream(request_dict=request_dict, userID=userID, response=response)
 
-                     elif operation == 'getAdminDelStream':
 
-                         return self.get_admin_del_stream(request_dict=request_dict, userID=userID, response=response)
 
-                     elif operation == 'getAdminUpdateStream':
 
-                         return self.get_admin_update_stream(request_dict=request_dict, userID=userID, response=response)
 
-                     elif operation == 'getAdminVodUrl':
 
-                         return self.get_admin_vod_url(request_dict=request_dict, userID=userID, response=response)
 
-                     elif operation == 'getAdminFindStream':
 
-                         return self.get_admin_find_stream(request_dict=request_dict, userID=userID, response=response)
 
-                     elif operation == 'getAdminDelVideo':
 
-                         return self.get_admin_del_video(request_dict=request_dict, userID=userID, response=response)
 
-                     elif operation == 'getAllServerJson':
 
-                         return self.get_all_server_json(userID=userID, response=response)
 
-                     elif operation == 'getAdminHlsVod':
 
-                         return self.get_admin_hls_vod(userID=userID, request_dict=request_dict, response=response)
 
-                     elif operation == 'getAdminAddStream':
 
-                         return self.get_admin_add_stream(userID=userID, request_dict=request_dict, response=response)
 
-                     else:
 
-                         return response.json(444, 'operation')
 
-                 else:
 
-                     return response.json(404)
 
-             else:
 
-                 return response.json(tko.code)
 
-         else:
 
-             return response.json(311)
 
-     def add_stream(self, token, userID, request_dict, response):
 
-         channel = request_dict.get('channel', None)
 
-         status = request_dict.get('status', None)
 
-         uid = request_dict.get('uid', None)
 
-         flag_param = CommonService.get_param_flag(data=[channel, status, uid])
 
-         if flag_param is True:
 
-             is_user = ModelService.check_own_device(userID=userID, UID=uid)
 
-             if is_user is True:
 
-                 stream_queryset = Equipment_Stream.objects.filter(userID=userID, uid=uid, channel=channel, rank=1)
 
-                 if stream_queryset.exists():
 
-                     return response.json(174)
 
-                 try:
 
-                     flag = Equipment_Stream.objects.create(userID=userID, status=status, uid=uid, channel=channel,
 
-                                                            access_token=token)
 
-                 except Exception as e:
 
-                     errorInfo = traceback.format_exc()
 
-                     print(errorInfo)
 
-                     return response.json(424, errorInfo)
 
-                 else:
 
-                     if flag:
 
-                         rtmp_url = RTMP_PUSH_URL
 
-                         rtmp_name = uid + '_' + channel + '?userID=' + userID + '&uid=' + uid + '&channel=' + channel + '&access_token=' + token
 
-                         return response.json(0, {'userID': userID, 'channel': channel,
 
-                                                  'uid': uid,
 
-                                                  'status': status,
 
-                                                  'access_token': token,
 
-                                                  'rtmp_url': rtmp_url,
 
-                                                  'rtmp_name': rtmp_name})
 
-             else:
 
-                 return response.json(14)
 
-         else:
 
-             return response.json(444, 'channel, status, uid')
 
-     def delete_stream(self, request_dict, userID,response):
 
-         id_list = request_dict.getlist('id', None)
 
-         if len(id_list):
 
-             for id in id_list:
 
-                 Equipment_Stream.objects.filter(id=id, userID=userID).delete()
 
-             return response.json(0)
 
-         return response.json(444)
 
-     def update_stream(self, userID, request_dict,response):
 
-         id = request_dict.get('id', None)
 
-         status = request_dict.get('status', None)
 
-         is_update = Equipment_Stream.objects.filter(id=id, userID=userID).update(status=status)
 
-         if is_update:
 
-             return response.json(0, {'id': id, 'status': status})
 
-         return response.json(444)
 
-     def query_stream(self, userID,response):
 
-         equipment_stream_queryset = Equipment_Stream.objects.filter(userID=userID)
 
-         if equipment_stream_queryset.exists():
 
-             res = CommonService.qs_to_dict(equipment_stream_queryset)
 
-             return response.json(0,res)
 
-         else:
 
-             return response.json(0)
 
-     def get_all_video(self, request_dict, userID,response):
 
-         uid = request_dict.get('uid', None)
 
-         channel = request_dict.get('channel', None)
 
-         if uid is not None and channel is not None:
 
-             own_permission = ModelService.check_permission(userID=userID, permID=30)
 
-             own_device = ModelService.check_own_device(userID=userID, UID=uid)
 
-             if own_permission is True or own_device is True:
 
-                 s3 = S3ClassObject()
 
-                 data = s3.get_all_object(prefix=uid + '_' + channel + '/flv')
 
-                 return response.json(0, {'files': data})
 
-             else:
 
-                 return response.json(404)
 
-         return response.json(444,'uid,channel')
 
-     def get_vod_url(self, request_dict,response):
 
-         uid = request_dict.get('uid', None)
 
-         channel = request_dict.get('channel', None)
 
-         filename = request_dict.get('filename', None)
 
-         if uid is not None and filename is not None and channel is not None:
 
-             s3 = S3ClassObject()
 
-             url = s3.get_generate_vod_url(uid + '_' + channel + '/' + filename)
 
-             return response.json(0, {'url': url})
 
-         else:
 
-             return response.json(444)
 
-     def get_admin_all_stream(self, request_dict, userID,response):
 
-         # 判断
 
-         own_permission = ModelService.check_permission(userID=userID, permID=30)
 
-         if own_permission is True:
 
-             page = int(request_dict.get('page', None))
 
-             line = int(request_dict.get('line', None))
 
-             equipment_stream_queryset = Equipment_Stream.objects.all()
 
-             if equipment_stream_queryset.exists():
 
-                 equipment_stream_count = equipment_stream_queryset.count()
 
-                 equipment_stream_res = equipment_stream_queryset[(page - 1) * line:page * line]
 
-                 send_json = CommonService.qs_to_dict(equipment_stream_res)
 
-                 send_json['count'] = equipment_stream_count
 
-                 send_json = CommonService.qs_to_dict(equipment_stream_queryset)
 
-                 return response.json(0, send_json)
 
-             else:
 
-                 return response.json(0)
 
-         else:
 
-             return response.json(404)
 
-     def get_admin_del_stream(self, request_dict, userID,response):
 
-         # 判断
 
-         own_permission = ModelService.check_permission(userID=userID, permID=10)
 
-         if own_permission is True:
 
-             id_list = request_dict.getlist('id', None)
 
-             if len(id_list):
 
-                 for id in id_list:
 
-                     Equipment_Stream.objects.filter(id=id).delete()
 
-                 return response.json(0)
 
-             else:
 
-                 return response.json(444)
 
-         return response.json(404)
 
-     def get_admin_del_video(self, request_dict, userID,response):
 
-         # 判断
 
-         own_permission = ModelService.check_permission(userID=userID, permID=10)
 
-         if own_permission is True:
 
-             key_list = request_dict.getlist('key', None)
 
-             if len(key_list):
 
-                 uid = request_dict.get('uid', None)
 
-                 channel = request_dict.get('channel', None)
 
-                 if uid is not None and channel is not None:
 
-                     re_uid = re.compile(r'^' + uid + '_' + str(channel))
 
-                     re_flag = False
 
-                     print(key_list)
 
-                     for keys in key_list:
 
-                         re_flag = re_uid.match(keys)
 
-                         if re_flag is not True:
 
-                             break
 
-                     print(re_flag)
 
-                     if re_flag:
 
-                         s3 = S3ClassObject()
 
-                         response = s3.del_object_list(keylist=key_list)
 
-                         if response['Deleted']:
 
-                             return response.json(0,
 
-                                                 {'deleted': response['Deleted']})
 
-         return response.json(444)
 
-     def get_del_video(self, request_dict, userID,response):
 
-         uid = request_dict.get('uid', None)
 
-         channel = request_dict.get('channel', None)
 
-         if uid is not None and channel is not None:
 
-             own_permission = ModelService.check_own_device(userID=userID, UID=uid)
 
-             if own_permission is True:
 
-                 key_list = request_dict.getlist('key', None)
 
-                 if len(key_list) > 0 and key_list is not None:
 
-                     re_uid = re.compile(r'^' + uid + '_' + str(channel))
 
-                     re_flag = False
 
-                     print(key_list)
 
-                     for keys in key_list:
 
-                         re_flag = re_uid.match(keys)
 
-                         if re_flag is not True:
 
-                             break
 
-                     if re_flag:
 
-                         s3 = S3ClassObject()
 
-                         response = s3.del_object_list(keylist=key_list)
 
-                         if response['Deleted']:
 
-                             return response.json(0)
 
-             else:
 
-                 return response.json(404)
 
-         return response.json(444)
 
-     def get_admin_update_stream(self, userID, request_dict,response):
 
-         own_permission = ModelService.check_permission(userID=userID, permID=50)
 
-         if own_permission is True:
 
-             id = request_dict.get('id', None)
 
-             status = request_dict.get('status', None)
 
-             param_flag = CommonService.get_param_flag(data=[status, id])
 
-             if param_flag is True:
 
-                 is_update = Equipment_Stream.objects.filter(id=id).update(status=status)
 
-                 if is_update:
 
-                     return response.json(0, {'id': id, 'status': status})
 
-             else:
 
-                 return response.json(444)
 
-         else:
 
-             return response.json(404)
 
-     def get_admin_vod_url(self, userID, request_dict,response):
 
-         own_permission = ModelService.check_permission(userID=userID, permID=30)
 
-         if own_permission is True:
 
-             uid = request_dict.get('uid', None)
 
-             channel = request_dict.get('channel', None)
 
-             filename = request_dict.get('filename', None)
 
-             if uid is not None and filename is not None and channel is not None:
 
-                 s3 = S3ClassObject()
 
-                 url = s3.get_generate_vod_url(uid + '_' + channel + '/' + filename)
 
-                 return response.json(0, {'url': url})
 
-             else:
 
-                 return response.json(444)
 
-         else:
 
-             return response.json(404)
 
-     def get_admin_find_stream(self, userID, request_dict,response):
 
-         own_permission = ModelService.check_permission(userID=userID, permID=20)
 
-         if own_permission is True:
 
-             content = request_dict.get('content', None)
 
-             page = int(request_dict.get('page', None))
 
-             line = int(request_dict.get('line', None))
 
-             param_flag = CommonService.get_param_flag(data=[content, page, line])
 
-             if param_flag is True:
 
-                 content = json.loads(content)
 
-                 search_kwargs = CommonService.get_kwargs(data=content)
 
-                 equipment_stream_queryset = Equipment_Stream.objects.filter(**search_kwargs)
 
-                 if equipment_stream_queryset.exists():
 
-                     equipment_stream_count = equipment_stream_queryset.count()
 
-                     equipment_stream_res = equipment_stream_queryset[(page - 1) * line:page * line]
 
-                     send_json = CommonService.qs_to_dict(equipment_stream_res)
 
-                     send_json['count'] = equipment_stream_count
 
-                     return response.json(0, send_json)
 
-                 else:
 
-                     return response.json(0)
 
-             else:
 
-                 return response.json(444)
 
-         else:
 
-             return response.json(404)
 
-     def get_all_server_json(self, userID,response):
 
-         own_permission = ModelService.check_permission(userID=userID, permID=20)
 
-         if own_permission is True:
 
-             url = NGINX_RTMP_STAT
 
-             res = requests.get(url)
 
-             xml_content = res.text
 
-             xml_dict = xmltodict.parse(xml_content)
 
-             if len(xml_dict):
 
-                 return response.json(0, {'data': xml_dict})
 
-         else:
 
-             return response.json(404)
 
-     def get_admin_add_stream(self, token, userID, request_dict,response):
 
-         channel = request_dict.get('channel', None)
 
-         status = request_dict.get('status', None)
 
-         uid = request_dict.get('uid', None)
 
-         flag_param = CommonService.get_param_flag(data=[channel, status, uid])
 
-         if flag_param is True:
 
-             own_perm = ModelService.check_permission(userID=userID, permID=40)
 
-             if own_perm is True:
 
-                 stream_queryset = Equipment_Stream.objects.filter(uid=uid, channel=channel)
 
-                 if stream_queryset.exists():
 
-                     return response.json(174)
 
-                 try:
 
-                     flag = Equipment_Stream.objects.create(userID=userID, status=status, uid=uid, channel=channel,
 
-                                                            access_token=token)
 
-                 except Exception as e:
 
-                     errorInfo = traceback.format_exc()
 
-                     print(errorInfo)
 
-                     return response.json(424, {'details': errorInfo})
 
-                 else:
 
-                     if flag:
 
-                         rtmp_url = RTMP_PUSH_URL
 
-                         rtmp_name = uid + '_' + channel + '?userID=' + userID + '&uid=' + uid + '&channel=' + channel + '&access_token=' + token
 
-                         return response.json(0,
 
-                                             {'userID': userID, 'channel': channel,
 
-                                              'uid': uid,
 
-                                              'status': status,
 
-                                              'access_token': token,
 
-                                              'rtmp_url': rtmp_url,
 
-                                              'rtmp_name': rtmp_name})
 
-             else:
 
-                 return response.json(404)
 
-         else:
 
-             return response.json(444)
 
-     def get_admin_hls_vod(self, request_dict, userID,response):
 
-         own_permission = ModelService.check_permission(userID=userID, permID=30)
 
-         if own_permission is True:
 
-             uid = request_dict.get('uid', None)
 
-             channel = request_dict.get('channel', None)
 
-             filename = request_dict.get('filename', None)
 
-             param_flag = CommonService.get_param_flag(data=[uid, filename, channel])
 
-             if param_flag is True:
 
-                 uid_channel = uid + '_' + channel
 
-                 InputKey = uid_channel + '/flv/' + filename
 
-                 ts = filename.split('.')[0]
 
-                 vod_key = uid_channel + '/' + ts
 
-                 elastictranscoder = ElasticTranscoder()
 
-                 res = elastictranscoder.create_job(
 
-                     # InputKey='2N1K3LE78TYJ38CE111A_99/flv/1526882855.flv',
 
-                     InputKey=InputKey,
 
-                     # OutputKey='vod/2N1K3LE78TYJ38CE111A_99/1526882855'
 
-                     OutputKey='vod/' + vod_key
 
-                 )
 
-                 if res is True:
 
-                     domain_prefix = 'http://d3596w5a6euckc.cloudfront.net/vod'
 
-                     vod_url = domain_prefix + '/' + vod_key + '.m3u8'
 
-                     return response.json(0, {'vodurl': vod_url})
 
-                 else:
 
-                     return response.json(403)
 
-             else:
 
-                 return response.json(444)
 
-         else:
 
-             return response.json(404)
 
-     def get_vod_hls(self, request_dict,response):
 
-         uid = request_dict.get('uid', None)
 
-         channel = request_dict.get('channel', None)
 
-         filename = request_dict.get('filename', None)
 
-         param_flag = CommonService.get_param_flag(data=[uid, filename, channel])
 
-         if param_flag is True:
 
-             uid_channel = uid + '_' + channel
 
-             InputKey = uid_channel + '/flv/' + filename
 
-             ts = filename.split('.')[0]
 
-             vod_key = uid_channel + '/' + ts
 
-             elastictranscoder = ElasticTranscoder()
 
-             res = elastictranscoder.create_job(
 
-                 InputKey=InputKey,
 
-                 OutputKey='vod/' + vod_key
 
-             )
 
-             if res is True:
 
-                 domain_prefix = 'http://d3596w5a6euckc.cloudfront.net/vod'
 
-                 vod_url = domain_prefix + '/' + vod_key + '.m3u8'
 
-                 vod_cookie_url = domain_prefix + '/' + uid_channel + '/*'
 
-                 expires_at = int(time.time()) + 7200
 
-                 cf = BetterThanBoto()
 
-                 vodCookie = cf.create_signed_cookies(url=vod_cookie_url, keypair_id="APKAINI6BNPKV54NHH7Q",
 
-                                                      expires_at=expires_at,
 
-                                                      private_key_file=os.path.join(BASE_DIR,
 
-                                                                                    'Ansjer/file/pk-APKAINI6BNPKV54NHH7Q.pem'))
 
-                 return response.json(0, {'vodurl': vod_url, 'vodCookie': vodCookie})
 
-             else:
 
-                 return response.json(403)
 
-         else:
 
-             return response.json(444)
 
- # 推流验证
 
- @csrf_exempt
 
- def Auth_Stream(request, *callback_args,
 
-                 **callback_kwargs):
 
-     if request.method == 'GET':
 
-         request.encoding = 'utf-8'
 
-         request_dict = request.GET
 
-     if request.method == 'POST':
 
-         request.encoding = 'utf-8'
 
-         request_dict = request.POST
 
-     access_token = request_dict.get('access_token', None)
 
-     userID = request_dict.get('userID', None)
 
-     uid = request_dict.get('uid', None)
 
-     channel = request_dict.get('channel', None)
 
-     param_flag = CommonService.get_param_flag(data=[access_token, userID, uid, channel])
 
-     if param_flag is True:
 
-         own_permission = ModelService.check_permission(userID=userID, permID=60)
 
-         if own_permission is True:
 
-             equipment_stream_queryset = Equipment_Stream.objects.filter(userID=userID, uid=uid, channel=channel,
 
-                                                                         status=1, access_token=access_token)
 
-             if equipment_stream_queryset.exists():
 
-                 return HttpResponse(status=200)
 
-     return HttpResponse(status=404)
 
- # 播放验证
 
- @csrf_exempt
 
- def Auth_Live(request, *callback_args,
 
-               **callback_kwargs):
 
-     if request.method == 'GET':
 
-         request.encoding = 'utf-8'
 
-         request_dict = request.GET
 
-     if request.method == 'POST':
 
-         request.encoding = 'utf-8'
 
-         request_dict = request.POST
 
-     response = ResponseObject()
 
-     token = request_dict.get('token', None)
 
-     if token is not None:
 
-         tko = TokenObject(token)
 
-         tko.valid()
 
-         response.lang = tko.lang
 
-         if tko.code == 0:
 
-             userID = tko.userID
 
-             uid = request_dict.get('uid', None)
 
-             channel = request_dict.get('channel', None)
 
-             if userID is not None and uid is not None and channel is not None:
 
-                 own_permission = ModelService.check_permission(userID=userID, permID=90)
 
-                 if own_permission is True:
 
-                     equipment_stream_queryset = Equipment_Stream.objects.filter(userID=userID, uid=uid, channel=channel,
 
-                                                                                 status=1)
 
-                     if equipment_stream_queryset.exists():
 
-                         return HttpResponse(status=200)
 
-     return HttpResponse(status=404)
 
- @csrf_exempt
 
- def send_video_s3(request, *callback_args,
 
-                   **callback_kwargs):
 
-     if request.method == 'GET':
 
-         request.encoding = 'utf-8'
 
-         request_dict = request.GET
 
-     if request.method == 'POST':
 
-         request.encoding = 'utf-8'
 
-         request_dict = request.POST
 
-     # 文件名
 
-     basename = request_dict.get('basename', None)
 
-     print(basename)
 
-     if basename != None:
 
-         base_path = '/tmp/flv/'
 
-         file_base_path = base_path + basename
 
-         input_path = file_base_path + '.flv'
 
-         output_path = file_base_path + '.mp4'
 
-         if os.path.exists(input_path):
 
-             uid_channel = basename.split('-')[0]
 
-             uid = uid_channel.split('_')[0]
 
-             channel = uid_channel.split('_')[1]
 
-             equipment_stream_queryset = Equipment_Stream.objects.filter(channel=channel, uid=uid, status=1)
 
-             if equipment_stream_queryset.exists():
 
-                 try:
 
-                     key = uid_channel + '/' + basename + '.mp4'
 
-                     # 转换到
 
-                     ff = FFmpeg(
 
-                         inputs={input_path: None},
 
-                         outputs={output_path: ['-vcodec', 'copy', '-strict', '-2']}
 
-                     )
 
-                     ff.run()
 
-                     # 截取第一帧当缩略图
 
-                     # ffmpeg -i 555.flv -y -f image2 -ss 08.010 -t 0.001 -s 352x240 b.jpg
 
-                 except Exception as e:
 
-                     errorInfo = traceback.format_exc()
 
-                     print(errorInfo)
 
-                 else:
 
-                     if os.path.exists(output_path):
 
-                         s3 = S3ClassObject()
 
-                         s3_response = s3.put_mp4_object(body=open(output_path, 'rb'), key=key)
 
-                         print(s3_response)
 
-                         if s3_response['ResponseMetadata']['HTTPStatusCode'] == 200:
 
-                             # 记录保存文件容量,由于此操作过于频繁入库,上线代码去掉
 
-                             file_size = CommonService.get_file_size(file_path=output_path, suffix_type='MB',
 
-                                                                     decimal_point=2)
 
-                             size = equipment_stream_queryset[0].total_flow
 
-                             if size:
 
-                                 pass
 
-                             else:
 
-                                 size = 0
 
-                             equipment_stream_queryset.update(total_flow=size + file_size)
 
-                             #
 
-                             rm_common = 'rm ' + input_path + ' ' + output_path
 
-                             subprocess.Popen(rm_common, shell=True)
 
-                             return HttpResponse(status=200)
 
-                         else:
 
-                             rm_common = 'rm ' + input_path + ' ' + output_path
 
-                             print('respone error')
 
-                             subprocess.Popen(rm_common, shell=True)
 
-         return HttpResponse(status=403)
 
-     else:
 
-         return HttpResponse(404)
 
- @csrf_exempt
 
- def push_flv_s3(request, *callback_args,
 
-                 **callback_kwargs):
 
-     if request.method == 'GET':
 
-         request.encoding = 'utf-8'
 
-         request_dict = request.GET
 
-     if request.method == 'POST':
 
-         request.encoding = 'utf-8'
 
-         request_dict = request.POST
 
-     # 文件名
 
-     basename = request_dict.get('basename', None)
 
-     response = ResponseObject()
 
-     if basename != None:
 
-         base_path = 'tmp/flv/'
 
-         file_base_path = base_path + basename
 
-         flv_path = file_base_path + '.flv'
 
-         if os.path.exists(flv_path):
 
-             dict_file = basename.split('-')
 
-             uid_channel = dict_file[0]
 
-             file_time = dict_file[1]
 
-             uid = uid_channel.split('_')[0]
 
-             channel = uid_channel.split('_')[1]
 
-             equipment_stream_queryset = Equipment_Stream.objects.filter(channel=channel, uid=uid, status=1)
 
-             if equipment_stream_queryset.exists():
 
-                 try:
 
-                     jpg_path = file_base_path + '.jpg'
 
-                     # 截取第一帧当缩略图ffmpeg -i 2N1K3LE78TYJ38CE111A_99-1526882169.flv -y -f image2 -t 0.001 -s 352x240 a.jpg
 
-                     ff = FFmpeg(
 
-                         inputs={flv_path: None},
 
-                         outputs={jpg_path: ['-y', '-f', 'image2', '-t', '0.001', '-s', '352x240']}
 
-                     )
 
-                     ff.cmd
 
-                     ff.run()
 
-                 except Exception as e:
 
-                     errorInfo = traceback.format_exc()
 
-                     print(errorInfo)
 
-                 else:
 
-                     if os.path.exists(jpg_path):
 
-                         s3 = S3ClassObject()
 
-                         flv_key = uid_channel + '/flv/' + file_time + '.flv'
 
-                         jpg_key = uid_channel + '/jpg/' + file_time + '.jpg'
 
-                         try:
 
-                             flv_response = s3.put_object(body=open(flv_path, 'rb'), key=flv_key)
 
-                             jpg_response = s3.put_object(body=open(jpg_path, 'rb'), key=jpg_key)
 
-                             if flv_response['ResponseMetadata']['HTTPStatusCode'] == 200 and \
 
-                                     jpg_response['ResponseMetadata']['HTTPStatusCode'] == 200:
 
-                                 code = 0
 
-                             else:
 
-                                 code = 444
 
-                         except Exception as e:
 
-                             print(repr(e))
 
-                             code = 444
 
-                             pass
 
-                         path_list = [flv_path, jpg_path]
 
-                         for i in path_list:
 
-                             try:
 
-                                 os.remove(i)
 
-                             except Exception as e:
 
-                                 print(repr(e))
 
-                                 pass
 
-                         return response.json(code)
 
-     return response.json(444)
 
 
  |