优化云存关联AI标签

Controller/CloudStorage.py

@@ -651,7 +651,7 @@ class CloudStorageView(View):
             vod_vo, week = split_vod_hls_obj.creat_vod_hls_data(uid=uid, channel=channel, start_time=start_time,
                                                                 end_time=end_time, bucket_id=bucket_id, fg=fg, sec=sec)
 
-            split_vod_hls_obj.cloud_vod_hls_tag(vod_vo.id, week, uid, start_time)
+            split_vod_hls_obj.cloud_vod_hls_tag(vod_vo.id, week, uid, start_time, sec)  # 云存关联AI标签
             end_time_stamp = datetime.datetime.fromtimestamp(int(start_time))
             end_time_str = datetime.datetime(end_time_stamp.year, end_time_stamp.month, 1)
             end_time_stamp = CommonService.str_to_timestamp(end_time_str.strftime('%Y-%m-%d %H:%M:%S'))

Service/VodHlsService.py

@@ -174,31 +174,26 @@ class SplitVodHlsObject:
         return vod_hls
 
     @classmethod
-    def cloud_vod_hls_tag(cls, vod_id, num, uid, start_time):
+    def cloud_vod_hls_tag(cls, vod_id, num, uid, start_time, sec):
         """
         云存回调信息关联标签
         @param vod_id: 云存回放信息id
-        @param num: 所在表编号
+        @param num: 云存所在表编号
         @param uid: 设备UID
         @param start_time: 云存开始时间
+        @param sec: 云存片段秒数
         @return: True | False
         """
         try:
-            # 查询设备是否有使用中的ai服务
-            # ai_service_qs = AiService.objects \
-            #     .filter(uid=uid, detect_status=1, use_status=1, endTime__gt=start_time) \
-            #     .values('detect_group')
-            # if not ai_service_qs.exists():
-            #     return False
             start_time = int(start_time)
-            end_time = start_time + 5
+            end_time = start_time + sec
             vod_tag_qs = VodHlsTag.objects.filter(ai_event_time__range=(start_time, end_time), uid=uid)
             if not vod_tag_qs.exists():
                 return False
             vod_tag_qs.update(vod_hls_id=vod_id, tab_num=num)
             return True
         except Exception as e:
-            print('异常详情,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
+            print('cloud_vod_hls_tag异常详情,uid:{},errLine:{},errMsg:{}'.format(uid, e.__traceback__.tb_lineno, repr(e)))
             return False
 
     @classmethod