|
|
@@ -1,3 +1,4 @@
|
|
|
+import datetime
|
|
|
import json
|
|
|
import time
|
|
|
|
|
|
@@ -10,9 +11,11 @@ from django.views.generic.base import View
|
|
|
|
|
|
from Ansjer.config import DETECT_PUSH_DOMAIN, DETECT_PUSH_DOMAINS, DETECT_PUSH_DOMAIN_JIUAN, DETECT_PUSH_DOMAINS_JIUAN, \
|
|
|
OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET, AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, LOGGER, ALGORITHM_COMBO_TYPES
|
|
|
+from Ansjer.config import PUSH_BUCKET
|
|
|
from Model.models import Device_Info, Equipment_Info, UidSetModel, UidPushModel, CompanyModel, SysMsgModel, \
|
|
|
AiService, VodBucketModel
|
|
|
from Object.ETkObject import ETkObject
|
|
|
+from Object.OCIObjectStorage import OCIObjectStorage
|
|
|
from Object.RedisObject import RedisObject
|
|
|
from Object.ResponseObject import ResponseObject
|
|
|
from Object.TokenObject import TokenObject
|
|
|
@@ -55,6 +58,9 @@ class DetectControllerViewV2(View):
|
|
|
# 查询推送信息
|
|
|
elif operation == 'queryInfo':
|
|
|
return self.do_query(request_dict, response, userID)
|
|
|
+ # 点击推送信息跳转到列表信息
|
|
|
+ elif operation == 'transferInfo':
|
|
|
+ return self.do_transfer(request_dict, response, userID)
|
|
|
# 更新推送延迟
|
|
|
elif operation == 'updateInterval':
|
|
|
return self.do_update_interval(userID, request_dict, response)
|
|
|
@@ -329,7 +335,7 @@ class DetectControllerViewV2(View):
|
|
|
end_time = int(time.time())
|
|
|
start_time = LocalDateTimeUtil.get_before_days_timestamp(end_time, 7)
|
|
|
|
|
|
- equipment_info_qs, count = EquipmentInfoService.\
|
|
|
+ equipment_info_qs, count = EquipmentInfoService. \
|
|
|
union_equipment_info(userID, uid_list, event_type, start_time, end_time, page, line)
|
|
|
|
|
|
# 查询设备类型,昵称
|
|
|
@@ -365,7 +371,193 @@ class DetectControllerViewV2(View):
|
|
|
config=botocore.client.Config(signature_version='s3v4'),
|
|
|
region_name='cn-northwest-1'
|
|
|
)
|
|
|
+ oci_eur = OCIObjectStorage('eur')
|
|
|
+ oci_us = OCIObjectStorage('us')
|
|
|
+ redis_obj = RedisObject(3)
|
|
|
+ # ai消息标识所有组合标签
|
|
|
+ ai_all_event_type = EquipmentInfoService.get_all_comb_event_type()
|
|
|
+ for equipment_info in equipment_info_qs:
|
|
|
+ uid = equipment_info['devUid']
|
|
|
+ event_time = equipment_info['eventTime']
|
|
|
+ channel = equipment_info['Channel']
|
|
|
+ storage_location = equipment_info['storage_location']
|
|
|
+ border_coords = equipment_info['borderCoords']
|
|
|
+ event_type = equipment_info['eventType']
|
|
|
+ event_tag = equipment_info['eventTag']
|
|
|
+
|
|
|
+ if equipment_info['is_st'] == 1:
|
|
|
+ thumbspng = '{}/{}/{}.jpeg'.format(uid, channel, event_time)
|
|
|
+ if storage_location == 1: # 阿里云oss
|
|
|
+ img_url = oss_img_bucket.sign_url('GET', thumbspng, 300)
|
|
|
+ elif storage_location in [3, 4]:
|
|
|
+ oci = oci_eur if storage_location == 4 else oci_us
|
|
|
+ img_url = DetectControllerViewV2.oci_object_url(oci, thumbspng)
|
|
|
+ else:
|
|
|
+ params = {'Key': thumbspng}
|
|
|
+ if region == 1: # AWS国外
|
|
|
+ params['Bucket'] = 'foreignpush'
|
|
|
+ img_url = aws_s3.generate_presigned_url(
|
|
|
+ 'get_object', Params=params, ExpiresIn=300)
|
|
|
+ else: # AWS国内
|
|
|
+ params['Bucket'] = 'push'
|
|
|
+ img_url = aws_s3_cn.generate_presigned_url(
|
|
|
+ 'get_object', Params=params, ExpiresIn=300)
|
|
|
+
|
|
|
+ equipment_info['img'] = img_url
|
|
|
+ equipment_info['img_list'] = [img_url]
|
|
|
+
|
|
|
+ elif equipment_info['is_st'] == 2:
|
|
|
+ # 列表装载回放时间戳标记
|
|
|
+ split_vod_hls_obj = SplitVodHlsObject()
|
|
|
+ vodqs = split_vod_hls_obj.get_vod_hls_data(
|
|
|
+ uid=uid, channel=channel, start_time=int(event_time)).values('bucket_id')
|
|
|
+ if not vodqs.exists():
|
|
|
+ return response.json(173)
|
|
|
+ vod_bucket_qs = VodBucketModel.objects.filter(id=vodqs[0]['bucket_id']).values('bucket', 'endpoint')
|
|
|
+ if not vod_bucket_qs.exists():
|
|
|
+ return response.json(173)
|
|
|
+ bucket_name = vod_bucket_qs[0]['bucket']
|
|
|
+ endpoint = vod_bucket_qs[0]['endpoint']
|
|
|
+ bucket = oss2.Bucket(auth, endpoint, bucket_name)
|
|
|
+ ts = '{}/vod{}/{}/ts0.ts'.format(uid, channel, event_time)
|
|
|
+ if storage_location == 1: # 阿里云oss
|
|
|
+ thumb0 = bucket.sign_url('GET', ts, 3600,
|
|
|
+ params={'x-oss-process': 'video/snapshot,t_0000,w_700'})
|
|
|
+ thumb1 = bucket.sign_url('GET', ts, 3600,
|
|
|
+ params={'x-oss-process': 'video/snapshot,t_1000,w_700'})
|
|
|
+ thumb2 = bucket.sign_url('GET', ts, 3600,
|
|
|
+ params={'x-oss-process': 'video/snapshot,t_2000,w_700'})
|
|
|
+ equipment_info['img_list'] = [thumb0, thumb1, thumb2]
|
|
|
+ else:
|
|
|
+ params = {'Key': ts}
|
|
|
+ if region == 1: # AWS国外
|
|
|
+ params['Bucket'] = 'foreignpush'
|
|
|
+ img_url = aws_s3.generate_presigned_url(
|
|
|
+ 'get_object', Params=params, ExpiresIn=300)
|
|
|
+ else: # AWS国内
|
|
|
+ params['Bucket'] = 'push'
|
|
|
+ img_url = aws_s3_cn.generate_presigned_url(
|
|
|
+ 'get_object', Params=params, ExpiresIn=300)
|
|
|
+ equipment_info['img_list'] = [img_url]
|
|
|
+
|
|
|
+ elif equipment_info['is_st'] == 3 or equipment_info['is_st'] == 4:
|
|
|
+ # 列表装载回放时间戳标记
|
|
|
+ equipment_info['img_list'] = []
|
|
|
+
|
|
|
+ msg_key = f'{uid}:{channel}:{event_time}'
|
|
|
+ # OCI三张图 获取缓存临时URL
|
|
|
+ img_data = DetectControllerViewV2.get_msg_redis_url(redis_obj, msg_key,
|
|
|
+ equipment_info['is_st'], storage_location)
|
|
|
+ if img_data:
|
|
|
+ equipment_info['img_list'] = img_data
|
|
|
+ else:
|
|
|
+ for i in range(equipment_info['is_st']):
|
|
|
+ thumbspng = '{}/{}/{}_{}.jpeg'.format(uid, channel, event_time, i)
|
|
|
+ if storage_location == 1: # 阿里云oss
|
|
|
+ img_url = oss_img_bucket.sign_url('GET', thumbspng, 300)
|
|
|
+ elif storage_location in [3, 4]: # 国外OCI云
|
|
|
+ oci = oci_eur if storage_location == 4 else oci_us
|
|
|
+ img_url = DetectControllerViewV2.oci_object_url(oci, thumbspng)
|
|
|
+ else:
|
|
|
+ params = {'Key': thumbspng}
|
|
|
+ if region == 1: # 国外AWS
|
|
|
+ params['Bucket'] = 'foreignpush'
|
|
|
+ img_url = aws_s3.generate_presigned_url(
|
|
|
+ 'get_object', Params=params, ExpiresIn=300)
|
|
|
+ else: # 国内AWS
|
|
|
+ params['Bucket'] = 'push'
|
|
|
+ img_url = aws_s3_cn.generate_presigned_url(
|
|
|
+ 'get_object', Params=params, ExpiresIn=300)
|
|
|
+ equipment_info['img_list'].append(img_url)
|
|
|
+ if not img_data and equipment_info['is_st'] == 3 and storage_location in [3, 4]:
|
|
|
+ DetectControllerViewV2.set_msg_redis_url(redis_obj, msg_key, equipment_info['img_list'])
|
|
|
+
|
|
|
+ if uid in uid_type_dict.keys():
|
|
|
+ equipment_info['uid_type'] = uid_type_dict[uid]['type']
|
|
|
+ equipment_info['devNickName'] = uid_type_dict[uid]['NickName']
|
|
|
+ else:
|
|
|
+ equipment_info['uid_type'] = ''
|
|
|
+
|
|
|
+ equipment_info['borderCoords'] = '' if border_coords == '' else eval(border_coords) # ai消息坐标信息
|
|
|
+ equipment_info['ai_event_type_list'] = []
|
|
|
+ # 如果是ai消息类型，则分解eventType, 如：123 -> [1,2,3]
|
|
|
+ if border_coords and event_type in ai_all_event_type:
|
|
|
+ equipment_info['ai_event_type_list'] = list(map(int, str(event_type)))
|
|
|
+ if EquipmentInfoService.is_combo_tag(event_type, event_tag):
|
|
|
+ equipment_info['ai_event_type_list'] += EquipmentInfoService.get_combo_types(event_type, event_tag)
|
|
|
+
|
|
|
+ res.append(equipment_info)
|
|
|
+ return response.json(0, {'datas': res, 'count': count})
|
|
|
+ except Exception as e:
|
|
|
+ return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|
|
|
+
|
|
|
+ @staticmethod
|
|
|
+ def get_msg_redis_url(redis_client, msg_key, is_st, storage_location):
|
|
|
+ if is_st == 3 and storage_location in [3, 4]:
|
|
|
+ img_data = redis_client.get_data(msg_key)
|
|
|
+ if img_data:
|
|
|
+ return json.loads(img_data)
|
|
|
+ return None
|
|
|
+
|
|
|
+ @staticmethod
|
|
|
+ def set_msg_redis_url(redis_client, msg_key, img_list):
|
|
|
+ redis_client.set_data(msg_key, json.dumps(img_list), 580)
|
|
|
+
|
|
|
+ @staticmethod
|
|
|
+ def oci_object_url(oci, obj_name):
|
|
|
+ """
|
|
|
+ 获取OCI对象存储URL 有效期5分钟
|
|
|
+ @param oci:
|
|
|
+ @param obj_name: 对象名称
|
|
|
+ @return: url
|
|
|
+ """
|
|
|
+ time_expires = datetime.datetime.utcnow() + datetime.timedelta(minutes=10)
|
|
|
+ result = oci.get_preauthenticated_request_url(PUSH_BUCKET, 'ociPush', obj_name, time_expires)
|
|
|
+ return result.full_path if result else ''
|
|
|
+
|
|
|
+ def do_transfer(self, request_dict, response, userID):
|
|
|
+ event_time = request_dict.get('eventTime', None)
|
|
|
+ event_type = request_dict.get('eventType', None)
|
|
|
+ region = int(request_dict.get('region', None))
|
|
|
+ uid = request_dict.get('uid', None)
|
|
|
|
|
|
+ if not all([event_time, region, uid]):
|
|
|
+ return response.json(444)
|
|
|
+
|
|
|
+ try:
|
|
|
+ kwargs = {'device_user_id': userID, 'device_uid': uid, 'event_time': event_time, 'event_type': event_type}
|
|
|
+ equipment_info_qs, count = EquipmentInfoService.get_equipment_info(**kwargs)
|
|
|
+
|
|
|
+ # 查询设备类型,昵称
|
|
|
+ dvqs = Device_Info.objects.filter(UID=uid, userID_id=userID).values('UID', 'Type', 'NickName')
|
|
|
+ uid_type_dict = {}
|
|
|
+ for dv in dvqs:
|
|
|
+ uid_type_dict[dv['UID']] = {'type': dv['Type'], 'NickName': dv['NickName']}
|
|
|
+
|
|
|
+ # 没有推送数据返回空列表
|
|
|
+ if count == 0:
|
|
|
+ return response.json(0, {'datas': [], 'count': 0})
|
|
|
+
|
|
|
+ res = []
|
|
|
+ auth = oss2.Auth(OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET)
|
|
|
+ oss_img_bucket = oss2.Bucket(auth, 'oss-cn-shenzhen.aliyuncs.com', 'apg')
|
|
|
+ aws_s3 = boto3.client(
|
|
|
+ 's3',
|
|
|
+ aws_access_key_id=AWS_ACCESS_KEY_ID[1],
|
|
|
+ aws_secret_access_key=AWS_SECRET_ACCESS_KEY[1],
|
|
|
+ config=botocore.client.Config(signature_version='s3v4'),
|
|
|
+ region_name='us-east-1'
|
|
|
+ )
|
|
|
+ aws_s3_cn = boto3.client(
|
|
|
+ 's3',
|
|
|
+ aws_access_key_id=AWS_ACCESS_KEY_ID[0],
|
|
|
+ aws_secret_access_key=AWS_SECRET_ACCESS_KEY[0],
|
|
|
+ config=botocore.client.Config(signature_version='s3v4'),
|
|
|
+ region_name='cn-northwest-1'
|
|
|
+ )
|
|
|
+
|
|
|
+ oci_eur = OCIObjectStorage('eur')
|
|
|
+ oci_us = OCIObjectStorage('us')
|
|
|
# ai消息标识所有组合标签
|
|
|
ai_all_event_type = EquipmentInfoService.get_all_comb_event_type()
|
|
|
for equipment_info in equipment_info_qs:
|
|
|
@@ -381,13 +573,16 @@ class DetectControllerViewV2(View):
|
|
|
thumbspng = '{}/{}/{}.jpeg'.format(uid, channel, event_time)
|
|
|
if storage_location == 1: # 阿里云oss
|
|
|
img_url = oss_img_bucket.sign_url('GET', thumbspng, 300)
|
|
|
+ elif storage_location in [3, 4]:
|
|
|
+ oci = oci_eur if storage_location == 4 else oci_us
|
|
|
+ img_url = DetectControllerViewV2.oci_object_url(oci, thumbspng)
|
|
|
else:
|
|
|
params = {'Key': thumbspng}
|
|
|
- if region == 1: # AWS国外
|
|
|
+ if region == 1: # AWS国外
|
|
|
params['Bucket'] = 'foreignpush'
|
|
|
img_url = aws_s3.generate_presigned_url(
|
|
|
'get_object', Params=params, ExpiresIn=300)
|
|
|
- else: # AWS国内
|
|
|
+ else: # AWS国内
|
|
|
params['Bucket'] = 'push'
|
|
|
img_url = aws_s3_cn.generate_presigned_url(
|
|
|
'get_object', Params=params, ExpiresIn=300)
|
|
|
@@ -410,17 +605,20 @@ class DetectControllerViewV2(View):
|
|
|
bucket = oss2.Bucket(auth, endpoint, bucket_name)
|
|
|
ts = '{}/vod{}/{}/ts0.ts'.format(uid, channel, event_time)
|
|
|
if storage_location == 1: # 阿里云oss
|
|
|
- thumb0 = bucket.sign_url('GET', ts, 3600, params={'x-oss-process': 'video/snapshot,t_0000,w_700'})
|
|
|
- thumb1 = bucket.sign_url('GET', ts, 3600, params={'x-oss-process': 'video/snapshot,t_1000,w_700'})
|
|
|
- thumb2 = bucket.sign_url('GET', ts, 3600, params={'x-oss-process': 'video/snapshot,t_2000,w_700'})
|
|
|
+ thumb0 = bucket.sign_url('GET', ts, 3600,
|
|
|
+ params={'x-oss-process': 'video/snapshot,t_0000,w_700'})
|
|
|
+ thumb1 = bucket.sign_url('GET', ts, 3600,
|
|
|
+ params={'x-oss-process': 'video/snapshot,t_1000,w_700'})
|
|
|
+ thumb2 = bucket.sign_url('GET', ts, 3600,
|
|
|
+ params={'x-oss-process': 'video/snapshot,t_2000,w_700'})
|
|
|
equipment_info['img_list'] = [thumb0, thumb1, thumb2]
|
|
|
else:
|
|
|
params = {'Key': ts}
|
|
|
- if region == 1: # AWS国外
|
|
|
+ if region == 1: # AWS国外
|
|
|
params['Bucket'] = 'foreignpush'
|
|
|
img_url = aws_s3.generate_presigned_url(
|
|
|
'get_object', Params=params, ExpiresIn=300)
|
|
|
- else: # AWS国内
|
|
|
+ else: # AWS国内
|
|
|
params['Bucket'] = 'push'
|
|
|
img_url = aws_s3_cn.generate_presigned_url(
|
|
|
'get_object', Params=params, ExpiresIn=300)
|
|
|
@@ -433,13 +631,16 @@ class DetectControllerViewV2(View):
|
|
|
thumbspng = '{}/{}/{}_{}.jpeg'.format(uid, channel, event_time, i)
|
|
|
if storage_location == 1: # 阿里云oss
|
|
|
img_url = oss_img_bucket.sign_url('GET', thumbspng, 300)
|
|
|
+ elif storage_location in [3, 4]:
|
|
|
+ oci = oci_eur if storage_location == 4 else oci_us
|
|
|
+ img_url = DetectControllerViewV2.oci_object_url(oci, thumbspng)
|
|
|
else:
|
|
|
params = {'Key': thumbspng}
|
|
|
- if region == 1: # 国外AWS
|
|
|
+ if region == 1: # 国外AWS
|
|
|
params['Bucket'] = 'foreignpush'
|
|
|
img_url = aws_s3.generate_presigned_url(
|
|
|
'get_object', Params=params, ExpiresIn=300)
|
|
|
- else: # 国内AWS
|
|
|
+ else: # 国内AWS
|
|
|
params['Bucket'] = 'push'
|
|
|
img_url = aws_s3_cn.generate_presigned_url(
|
|
|
'get_object', Params=params, ExpiresIn=300)
|
|
|
@@ -462,8 +663,7 @@ class DetectControllerViewV2(View):
|
|
|
res.append(equipment_info)
|
|
|
return response.json(0, {'datas': res, 'count': count})
|
|
|
except Exception as e:
|
|
|
- print('error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|
|
|
- return response.json(474)
|
|
|
+ return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|
|
|
|
|
|
def do_update_interval(self, userID, request_dict, response):
|
|
|
uid = request_dict.get('uid', None)
|
