调试

sph_sy_main.py

@@ -16,7 +16,7 @@ def video_start_sph():
 
 # 每天早上 6 点执行
 schedule.every().day.at("01:00").do(video_start_sph)
-SphNrxs.sph_nrxs_data()
+# SphNrxs.sph_nrxs_data()
 while True:
     schedule.run_pending()
     time.sleep(1)

video_rewriting/video_processor.py

@@ -199,7 +199,7 @@ class VideoProcessor:
                     Feishu.finish_bot(text,
                                       "https://open.feishu.cn/open-apis/bot/v2/hook/e7697dc6-5254-4411-8b59-3cd0742bf703",
                                       "【 机器改造通知 】")
-                    if channel_id == "快手历史" or channel_id == "抖音历史":
+                    if channel_id == "快手历史" or channel_id == "抖音历史" or channel_id == "视频号历史":
                         explain = "历史爆款"
                     else:
                         explain = "新供给"

xssy_channel/sph_nrxs.py

@@ -268,27 +268,28 @@ class SphNrxs:
                             #     has_used = cls.get_hx(appid)
                             #     if has_used:
                             #         if has_used == '0':
-                            sqlCollect.insert_xssy_sph_info(uid, nick_name, user_name, "0", "", pq_id)
-                            values = [
-                                [
-                                    "视频号",
-                                    nick_name,
-                                    str(pq_id),
-                                    "5",
-                                    "通用-分享到群",
-                                    "AI片尾引导",
-                                    "",
-                                    "",
-                                    "AI标题",
-                                    "",
-                                    f"溯源账号:{uid}"
+                            res = sqlCollect.insert_xssy_sph_info(uid, nick_name, user_name, "0", "", pq_id)
+                            if res == 1:
+                                values = [
+                                    [
+                                        "视频号",
+                                        nick_name,
+                                        str(pq_id),
+                                        "5",
+                                        "通用-分享到群",
+                                        "AI片尾引导",
+                                        "",
+                                        "",
+                                        "AI标题",
+                                        "",
+                                        f"溯源账号:{uid}"
+                                    ]
                                 ]
-                            ]
-                            Feishu.insert_columns("WGIYsSDdxhItBwtJ0xgc0yE7nEg", '0701bd', "ROWS", 1, 2)
-                            time.sleep(0.5)
-                            Feishu.update_values("WGIYsSDdxhItBwtJ0xgc0yE7nEg", '0701bd', "B2:Z2",
-                                                 values)
-                            Feishu.bot("xinxin", '视频号溯源成功提示', f'原账号:{uid}，溯源到的账号:{nick_name},写入账号：{pq_id}', 'xinxin')
+                                Feishu.insert_columns("WGIYsSDdxhItBwtJ0xgc0yE7nEg", '0701bd', "ROWS", 1, 2)
+                                time.sleep(0.5)
+                                Feishu.update_values("WGIYsSDdxhItBwtJ0xgc0yE7nEg", '0701bd', "B2:Z2",
+                                                     values)
+                                Feishu.bot("xinxin", '视频号溯源成功提示', f'原账号:{uid}，溯源到的账号:{nick_name},写入账号：{pq_id}', 'xinxin')
                         else:
                             # sqlCollect.insert_xssy_sph_info(uid, nick_name, user_name, has_used, appid)
                             sqlCollect.insert_xssy_sph_info(uid, nick_name, user_name, "1")