From 8c738f747e89bd0f3130267e0aee4114d570fb24 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B0=B9=E8=88=9F?= <13007110208@163.com>
Date: Fri, 18 Apr 2025 11:30:51 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=96=87=E5=AD=97=E8=AF=86?=
 =?UTF-8?q?=E5=88=AB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 docker-compose.yaml     |   4 ++++
 main.py                 |  36 ++++++++++++++++++++++++++++++++++--
 requirements.txt        | Bin 108 -> 142 bytes
 utils/music_analysis.py |  40 ++++++++++++++++++++++++++++++++++++++++
 4 files changed, 78 insertions(+), 2 deletions(-)
 create mode 100644 utils/music_analysis.py

diff --git a/docker-compose.yaml b/docker-compose.yaml
index 92cf622..ab364d2 100644
--- a/docker-compose.yaml
+++ b/docker-compose.yaml
@@ -7,6 +7,10 @@ services:
         restart: always
         container_name: douyin
         image: registry.cn-hangzhou.aliyuncs.com/yinzhou_docker_hub/douyin:yz1
+        #环境变量需要替换成自己的
+        environment:
+            DASHSCOPE_API_KEY: sk-063b48fffb914d558ddcddc5166fd34d
+
         ports:
             - "1314:1314"
         depends_on:
diff --git a/main.py b/main.py
index 77ed251..0057baf 100644
--- a/main.py
+++ b/main.py
@@ -2,6 +2,7 @@ from fastapi import FastAPI, Query
 import uvicorn
 import requests
 from utils.response import success_response, error_400_response, error_503_response
+from utils.music_analysis import music_analysis
 
 app = FastAPI(title="douyin文档", swagger_ui_parameters={
     "defaultModelsExpandDepth": -1
@@ -11,6 +12,36 @@ DEFAULT_PC_VIDEO_URL = 'https://v.douyin.com/-NvlqBdIJo4/'
 DEFAULT_mobile_VIDEO_URL = 'https://v.douyin.com/BCfMrTFPYGQ/'
 
 
+@app.get('/douyin_video', tags=["抖音"], summary="返回视屏信息,最全的接口了")
+def douyin_video(video_url: str = Query(DEFAULT_mobile_VIDEO_URL, min_length=10)):
+    print(video_url)
+    if not video_url:
+        return {"code": 400, "message": "An error occurred.", "data": "请指定video_url"}
+
+    # 获取get请求参数
+    url = "http://douyin_tiktok_download_api:9579/api/hybrid/video_data"
+
+
+    querystring = {"url": video_url, "minimal": "true"}
+    response = requests.request("GET", url, params=querystring)
+    print(response.text)
+    print(response.json()['data']['music']['play_url'])
+
+
+    try:
+        if response.json()['code'] == 200:
+            video_url=response.json()['data']['video_data']['wm_video_url']
+            video_music=response.json()['data']['music']['play_url']['url_list'][0]
+            content=music_analysis(video_music)
+            return success_response({"video_url": video_url,"video_music": video_music,"content": content
+                                     })
+
+    except Exception as e:
+        print(e)
+        return error_400_response({"data": "解析字段失败."})
+
+    return error_503_response({"data": "抖音风控稍后请求."})
+
 @app.get('/douyin_content', tags=["抖音"], summary="手机和pc获取文案")
 def douyin_content(video_url: str = Query(DEFAULT_mobile_VIDEO_URL, min_length=10)):
     print(video_url)
@@ -69,12 +100,13 @@ def douyin_phone(video_url: str = Query(DEFAULT_mobile_VIDEO_URL, min_length=10)
     # 获取get请求参数
     url = "http://douyin_tiktok_download_api:9579/api/hybrid/video_data"
 
+
     querystring = {"url": video_url, "minimal": "true"}
     response = requests.request("GET", url, params=querystring)
-    print(response.json()['data']['author']['avatar_thumb'])
+    print(response.text)
     try:
         if response.json()['code'] == 200:
-            return success_response({"phone_url": response.json()['data']['author']['avatar_thumb']['url_list']
+            return success_response({"phone_url": response.json()['data']['video_data']['wm_video_url']
                                      })
 
     except Exception as e:
diff --git a/requirements.txt b/requirements.txt
index cf03a2dc07a3bdb854140e19bcefe19f720555f9..f1253e62a8ff138852e5d6a4c29521502e9d66d8 100644
GIT binary patch
delta 40
ncmd1lW1Ntql){k6P|T14#K{c#3<V6S47?0nP*xsLE|UQO!xRW-

delta 5
McmeBU%$bk_00o}`_y7O^

diff --git a/utils/music_analysis.py b/utils/music_analysis.py
new file mode 100644
index 0000000..ac1b04f
--- /dev/null
+++ b/utils/music_analysis.py
@@ -0,0 +1,40 @@
+from http import HTTPStatus
+from dashscope.audio.asr import Transcription
+import dashscope
+import requests
+
+
+
+def music_analysis(music_url):
+    transcribe_response = Transcription.async_call(
+        model='paraformer-v2',
+        file_urls=[music_url],
+        language_hints=['zh', 'en']  # “language_hints”只支持paraformer-v2模型
+    )
+
+    while True:
+        if transcribe_response.output.task_status == 'SUCCEEDED' or transcribe_response.output.task_status == 'FAILED':
+            break
+        transcribe_response = Transcription.fetch(task=transcribe_response.output.task_id)
+
+    if transcribe_response.status_code == HTTPStatus.OK:
+        url=transcribe_response.output['results'][0]['transcription_url']
+        print(url)
+
+        # 发送GET请求
+        response = requests.get(url)
+        text = ''
+
+        # 验证响应状态
+        if response.status_code == 200:
+            # 解析JSON数据
+            data = response.json()
+            for transcripts in data['transcripts']:
+                text += transcripts['text']
+
+        else:
+            print(f"请求失败，状态码：{response.status_code}")
+    return text
+
+if __name__ == '__main__':
+    music_analysis('https://lf26-music-east.douyinstatic.com/obj/ies-music-hj/7494207652008839996.mp3')