增加不符合预期视频拼接时候去除功能

common/material.py

@@ -116,6 +116,15 @@ class Material():
             if item[0] == '管理后台':
                 return item[1]
 
+    @classmethod
+    def get_inconformity_id(cls):
+        inconformity_id = Feishu.get_values_batch("prod", "succinct", "8AxpYW")
+        inconformity_id_list = []
+        for item in inconformity_id[1:]:
+            print(item[0])
+            inconformity_id_list.append(item[0])
+        return inconformity_id_list
+
     @classmethod
     def get_id(cls, audio_id):
         current_time = datetime.now()

common/sql_help.py

@@ -70,3 +70,13 @@ class sql():
             count = 0
         count = str(count).replace('(', '').replace(')', '').replace(',', '')
         return int(count)
+
+
+    @classmethod
+    def update_inconformity_id_list(cls, id):
+        update_sql = f""" update video_url set status={0}  WHERE video_id ="{id}" """
+        MysqlHelper.update_values(
+            sql=update_sql,
+            env="prod",
+            machine="",
+        )

video_capture/douyin/douyin_author/douyin_author.py

@@ -38,7 +38,7 @@ class douyinAuthor():
     def insert_videoUrl(cls, video_id, account_id, oss_object_key):
         current_time = datetime.now()
         formatted_time = current_time.strftime("%Y-%m-%d %H:%M")
-        insert_sql = f"""INSERT INTO video_url (video_id, account_id, oss_object_key, time) values ("{video_id}", "{account_id}", "{oss_object_key}", "{formatted_time}")"""
+        insert_sql = f"""INSERT INTO video_url (video_id, account_id, oss_object_key, time , status) values ("{video_id}", "{account_id}", "{oss_object_key}", "{formatted_time}", 1)"""
         MysqlHelper.update_values(
             sql=insert_sql,
             env="prod",

video_capture/kuaishou/kuaishou_author/kuaishou_author.py

@@ -27,7 +27,7 @@ class kuaishouAuthor():
     def insert_videoUrl(cls, video_id, account_id, oss_object_key):
         current_time = datetime.now()
         formatted_time = current_time.strftime("%Y-%m-%d %H:%M")
-        insert_sql = f"""INSERT INTO video_url (video_id, account_id, oss_object_key, time) values ("{video_id}", "{account_id}", "{oss_object_key}", "{formatted_time}")"""
+        insert_sql = f"""INSERT INTO video_url (video_id, account_id, oss_object_key, time, status) values ("{video_id}", "{account_id}", "{oss_object_key}", "{formatted_time}", 1)"""
         MysqlHelper.update_values(
             sql=insert_sql,
             env="prod",

video_stitching/video_stitching.py

@@ -117,7 +117,7 @@ class VideoStitching():
                 SELECT video_id
                 FROM video_audio b
                 WHERE a.oss_object_key = b.oss_object_key AND b.time = '{formatted_time}'
-            ) AND a.account_id = {account}  limit 35;"""
+            ) AND a.account_id = {account} and a.`status` = 1  limit 35;"""
         url_list = MysqlHelper.get_values(url_list, "prod")
         return url_list