增加飞书通知

carry_video/carry_video.py

@@ -121,12 +121,28 @@ class CarryViode:
             logger.error(f"[+] {url}该链接不是抖/快 不做处理")
             AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                  "不是抖/快不做处理", "1001", str(data))
+            text = (
+                f"**负责人**: {data['name']}\n"
+                f"**内容**: {data}\n"
+                f"**失败信息**: 该链接不是抖/快 不做处理\n"
+            )
+            Feishu.finish_bot(text,
+                              "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                              "【 搬运&改造效率工具失败通知 】")
             return
         if not url:
             in_carry_video_data(REDIS_NAME, data)
             logger.info(f"[+] {url}没有获取到视频链接,等待重新处理")
             AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                  "没有获取到视频链接，等待重新处理", "1002", str(data))
+            text = (
+                f"**负责人**: {data['name']}\n"
+                f"**内容**: {data}\n"
+                f"**失败信息**: 没有获取到视频链接，等待重新处理\n"
+            )
+            Feishu.finish_bot(text,
+                              "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                              "【 搬运&改造效率工具失败通知 】")
             return
         logger.info(f"[+] {url}开始处理标题")
         if data["title_category"] == "AI标题" or data["trailer_share"] == "AI标题":
@@ -140,7 +156,14 @@ class CarryViode:
             logger.error(f"[+] {url}下载失败")
             AliyunLogger.logging(data["name"],"效率工具", data["tag_transport_channel"], data["video_url"],
                                  "视频下载失败", "3002", str(data))
-            print("飞书通知")
+            text = (
+                f"**负责人**: {data['name']}\n"
+                f"**内容**: {data}\n"
+                f"**失败信息**: 视频下载失败\n"
+            )
+            Feishu.finish_bot(text,
+                              "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                              "【 搬运&改造效率工具失败通知 】")
             return
         logger.info(f"[+] {url}开始视频下载成功")
         if data["transform_rule"] == '否':
@@ -151,6 +174,14 @@ class CarryViode:
                 logger.error(f"[+] {REDIS_NAME}的{data}数据发送oss失败")
                 AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                      "改造失败,发送oss失败", "3001", str(data))
+                text = (
+                    f"**负责人**: {data['name']}\n"
+                    f"**内容**: {data}\n"
+                    f"**失败信息**: 视频发送OSS失败\n"
+                )
+                Feishu.finish_bot(text,
+                                  "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                                  "【 搬运&改造效率工具失败通知 】")
                 return
             logger.info(f"[+] {REDIS_NAME}的{data}数据发送oss成功")
             oss_object_key = oss_object_key.get("oss_object_key")
@@ -180,6 +211,14 @@ class CarryViode:
                     logger.error(f"[+] {REDIS_NAME}的{data}数据片尾获取失败")
                     AliyunLogger.logging(data["name"],"效率工具", data["tag_transport_channel"], data["video_url"],
                                          "改造失败,片尾获取失败", "3001", str(data))
+                    text = (
+                        f"**负责人**: {data['name']}\n"
+                        f"**内容**: {data}\n"
+                        f"**失败信息**: 获取片尾失败\n"
+                    )
+                    Feishu.finish_bot(text,
+                                      "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                                      "【 搬运&改造效率工具失败通知 】")
                     return
                 logger.info(f"[+] {REDIS_NAME}的{data}数据片尾获取成功")
                 pw_srt = TTS.getSrt(pw_url)
@@ -188,6 +227,14 @@ class CarryViode:
                     logger.error(f"[+] {REDIS_NAME}的{data}数据片尾音频下载失败")
                     AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                          "改造失败,片尾音频下载失败", "3001", str(data))
+                    text = (
+                        f"**负责人**: {data['name']}\n"
+                        f"**内容**: {data}\n"
+                        f"**失败信息**: 片尾音频下载失败\n"
+                    )
+                    Feishu.finish_bot(text,
+                                      "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                                      "【 搬运&改造效率工具失败通知 】")
                     return
                 logger.info(f"[+] {REDIS_NAME}的{data}数据片尾音频下载成功")
                 jpg_path = FFmpeg.video_png(video_path, file_path)  # 生成视频最后一帧jpg
@@ -195,6 +242,14 @@ class CarryViode:
                     logger.error(f"[+] {REDIS_NAME}的{data}数据片尾获取最后一帧失败")
                     AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                          "改造失败,获取最后一帧失败", "3001", str(data))
+                    text = (
+                        f"**负责人**: {data['name']}\n"
+                        f"**内容**: {data}\n"
+                        f"**失败信息**: 获取视频最后一帧失败\n"
+                    )
+                    Feishu.finish_bot(text,
+                                      "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                                      "【 搬运&改造效率工具失败通知 】")
                     return
                 logger.info(f"[+] {REDIS_NAME}的{data}数据片尾获取最后一帧成功")
                 pw_path = FFmpeg.pw_video(jpg_path, file_path, pw_mp3_path, pw_srt)  # 生成片尾视频
@@ -202,6 +257,14 @@ class CarryViode:
                     logger.error(f"[+] {REDIS_NAME}的{data}数据片尾拼接失败")
                     AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                          "改造失败,片尾拼接失败", "3001", str(data))
+                    text = (
+                        f"**负责人**: {data['name']}\n"
+                        f"**内容**: {data}\n"
+                        f"**失败信息**: 片尾拼接失败\n"
+                    )
+                    Feishu.finish_bot(text,
+                                      "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                                      "【 搬运&改造效率工具失败通知 】")
                     return
                 pw_video_list = [video_path, pw_path]
                 video_path = FFmpeg.concatenate_videos(pw_video_list, video_path)  # 视频与片尾拼接到一起
@@ -209,6 +272,14 @@ class CarryViode:
                     logger.error(f"[+] {REDIS_NAME}的{data}数据合并拼接失败")
                     AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                          "改造失败,合并拼接失败", "3001", str(data))
+                    text = (
+                        f"**负责人**: {data['name']}\n"
+                        f"**内容**: {data}\n"
+                        f"**失败信息**: 视频合并拼接失败\n"
+                    )
+                    Feishu.finish_bot(text,
+                                      "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                                      "【 搬运&改造效率工具失败通知 】")
                     return
                 logger.info(f"[+] {REDIS_NAME}的{data}数据合并拼接成功")
             if data["video_share"]:
@@ -217,6 +288,14 @@ class CarryViode:
                     logger.error(f"[+] {REDIS_NAME}的{data}数据添加片中字幕失败")
                     AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                          "改造失败,添加片中字幕失败", "3001", str(data))
+                    text = (
+                        f"**负责人**: {data['name']}\n"
+                        f"**内容**: {data}\n"
+                        f"**失败信息**: 视频片中增加字幕失败\n"
+                    )
+                    Feishu.finish_bot(text,
+                                      "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                                      "【 搬运&改造效率工具失败通知 】")
                     return
                 logger.info(f"[+] {REDIS_NAME}的{data}数据添加片中字幕成功")
             logger.info(f"[+] {REDIS_NAME}的{data}数据开始发送oss")
@@ -226,6 +305,14 @@ class CarryViode:
                 logger.error(f"[+] {REDIS_NAME}的{data}数据发送oss失败")
                 AliyunLogger.logging(data["name"],"效率工具", data["tag_transport_channel"], data["video_url"],
                                      "改造失败,发送oss失败", "3001", str(data))
+                text = (
+                    f"**负责人**: {data['name']}\n"
+                    f"**内容**: {data}\n"
+                    f"**失败信息**: 视频发送OSS失败\n"
+                )
+                Feishu.finish_bot(text,
+                                  "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                                  "【 搬运&改造效率工具失败通知 】")
                 return
             logger.info(f"[+] {REDIS_NAME}的{data}数据发送oss成功")
             oss_object_key = oss_object_key.get("oss_object_key")
@@ -242,6 +329,14 @@ class CarryViode:
                 logger.error(f"[+] {REDIS_NAME}的{data}写入票圈后台失败")
                 AliyunLogger.logging(data["name"], "效率工具",data["tag_transport_channel"], data["video_url"],
                                      "改造失败,写入票圈后台失败", "3001", str(data))
+                text = (
+                    f"**负责人**: {data['name']}\n"
+                    f"**内容**: {data}\n"
+                    f"**失败信息**: 视频写入票圈后台失败，视频ID{code}\n"
+                )
+                Feishu.finish_bot(text,
+                                  "https://open.feishu.cn/open-apis/bot/v2/hook/65bc5463-dee9-46d0-bc2d-ec6c49a8f3cd",
+                                  "【 搬运&改造效率工具失败通知 】")
                 continue
             pq_list.append(code)
             logger.info(f"[+] {REDIS_NAME}的{data}写入票圈成功，返回视频id{code}")