更改条件

channel_ks/ks_feed_list.py

@@ -270,8 +270,8 @@ class KsFeedVideo:
                                                   photo_id, category_name, age, oss_object=None, video_uid=None)
 
                         continue
-                    video_percent = '%.2f' % (share_count / view_count)
-                    special = float(0.1)
+                    video_percent = '%.4f' % (share_count / view_count)
+                    special = float(0.001)
                     if float(video_percent) < special or share_count < 500 or duration < 30 or duration > 600:
                         sqlCollect.insert_ks_data(user_name, user_sex, time_data, caption, view_count, like_count, share_count, duration, main_mv_url, thumbnail_url, user_id, '1', photo_id, category_name, age, oss_object=None, video_uid=None)
                         continue
@@ -279,20 +279,21 @@ class KsFeedVideo:
                     oss_object_key = Oss.channel_upload_oss(main_mv_url, photo_id)
                     time.sleep(2)
                     oss_object = oss_object_key.get("oss_object_key")
-                    pq_id = cls.get_id_by_category(category_name)
-                    if pq_id:
-                        video_uid = cls.insert_piaoquantv(oss_object, caption, pq_id, thumbnail_url)
-                        sqlCollect.insert_ks_data(user_name, user_sex, time_data, caption, view_count,
-                                                  like_count, share_count, duration, main_mv_url, thumbnail_url,
-                                                  user_id, '0', photo_id, category_name, age, oss_object, video_uid)
-                        current_time = datetime.now()
-                        formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
-                        values = [
-                            [category_name, user_name, photo_id, user_sex, caption, view_count, like_count, share_count, duration,
-                             main_mv_url, thumbnail_url, user_id, age, pq_id, video_uid, time_data, formatted_time]]
-                        Feishu.insert_columns("PlcisKhObhzmBothRutc65sJnph", "8fQxFv", "ROWS", 1, 2)
-                        time.sleep(0.5)
-                        Feishu.update_values("PlcisKhObhzmBothRutc65sJnph", "8fQxFv", "A2:Z2", values)
+                    # pq_id = cls.get_id_by_category(category_name)
+                    # if pq_id:
+                    pq_id = 71603611
+                    video_uid = cls.insert_piaoquantv(oss_object, caption, pq_id, thumbnail_url)
+                    sqlCollect.insert_ks_data(user_name, user_sex, time_data, caption, view_count,
+                                              like_count, share_count, duration, main_mv_url, thumbnail_url,
+                                              user_id, '0', photo_id, category_name, age, oss_object, video_uid)
+                    current_time = datetime.now()
+                    formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
+                    values = [
+                        [category_name, user_name, photo_id, user_sex, caption, view_count, like_count, share_count, duration,
+                         main_mv_url, thumbnail_url, user_id, age, pq_id, video_uid, time_data, formatted_time]]
+                    Feishu.insert_columns("PlcisKhObhzmBothRutc65sJnph", "8fQxFv", "ROWS", 1, 2)
+                    time.sleep(0.5)
+                    Feishu.update_values("PlcisKhObhzmBothRutc65sJnph", "8fQxFv", "A2:Z2", values)
                 time.sleep(80)
             except Exception as exc:
                 print(f"异常信息: {exc}")