From e161681bc97550c5019d902b87114f939033a329 Mon Sep 17 00:00:00 2001 From: PoturaevPetr Date: Wed, 18 Mar 2026 01:33:15 +0500 Subject: [PATCH] =?UTF-8?q?=D0=BD=D0=B5=20=D0=BE=D1=82=D0=BF=D1=80=D0=B0?= =?UTF-8?q?=D0=B2=D0=BB=D1=8F=D1=82=D1=8C=20callback=20=D0=B5=D1=81=D0=BB?= =?UTF-8?q?=D0=B8=20=D1=8D=D1=82=D0=BE=20=D0=B2=D0=BD=D0=B5=D1=88=D0=BD?= =?UTF-8?q?=D0=B9=20=D1=84=D0=B0=D0=B9=D0=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apiApp/routers/ai_conclusion_router.py | 47 +++++++++++++------------- 1 file changed, 24 insertions(+), 23 deletions(-) diff --git a/apiApp/routers/ai_conclusion_router.py b/apiApp/routers/ai_conclusion_router.py index e591428..eb3a6ae 100644 --- a/apiApp/routers/ai_conclusion_router.py +++ b/apiApp/routers/ai_conclusion_router.py @@ -125,29 +125,30 @@ async def save_ai_conclusion(request: AiConclusionRequest, db: Session = Depends # Отправляем webhook в Calls_WEB_Client_main для анализа try: - logger.info(f"📤 Отправка webhook в Calls_WEB_Client_main для {request.filename}") - - webhook_payload = { - "audio_id": str(audio.id), - "filename": request.filename, - "transcription": request.transcription, - "corrected_transcription": request.corrected_transcription, - "segments": request.segments, - "processing_time_seconds": request.processing_time_seconds - } - - webhook_response = requests.post( - WEBHOOK_ENDPOINT, - json=webhook_payload, - headers={"X-Webhook-Key": WEBHOOK_API_KEY}, - timeout=30 - ) - - if webhook_response.status_code == 200: - logger.info(f"✅ Webhook успешно отправлен для {request.filename}") - else: - logger.warning(f"⚠️ Webhook вернул статус {webhook_response.status_code}") - logger.warning(f"Response: {webhook_response.text}") + if (audio.sourse or "").lower() != "external": + logger.info(f"📤 Отправка webhook в Calls_WEB_Client_main для {request.filename}") + + webhook_payload = { + "audio_id": str(audio.id), + "filename": request.filename, + "transcription": request.transcription, + "corrected_transcription": request.corrected_transcription, + "segments": request.segments, + "processing_time_seconds": request.processing_time_seconds + } + + webhook_response = requests.post( + WEBHOOK_ENDPOINT, + json=webhook_payload, + headers={"X-Webhook-Key": WEBHOOK_API_KEY}, + timeout=30 + ) + + if webhook_response.status_code == 200: + logger.info(f"✅ Webhook успешно отправлен для {request.filename}") + else: + logger.warning(f"⚠️ Webhook вернул статус {webhook_response.status_code}") + logger.warning(f"Response: {webhook_response.text}") except requests.exceptions.ConnectionError: logger.error(f"❌ Не удалось подключиться к Calls_WEB_Client_main webhook: {WEBHOOK_ENDPOINT}")