o li*D@sddlmZmZmZddlmZddlZddlZddlZddl m Z m Z m Z ddlm Z ddlmZddlmZmZddlmZdd lmZdd lmZmZmZddlZddlZddlZddlZddlZdd lmZddl Z ddl!Z!d e"d e"fddZ#e$dZ%dZ&eedZ$ej'ej()ddZ*eZ+ddda,dZ-ddZ.ddZ/ddZ0ddZ1e+)ddd Z2e+3d!d"e fd#d$Z4e+3d%ed&fd'efd(d)Z5d*Z6e+3d+d,e fd-d.Z7dS)/) APIRouter HTTPExceptionQuery)RedirectResponseN) SpeechText UserQuestion RobotRequest)BackgroundTasks)Body) UploadFileFile) database_demo)OpenAI)loggeropenai_api_keygemini_api_key)genaitextreturncCstdd|S)Nz\s+)resubstrip)rr&/home/air/demo/back/gemini_routerV2.pynormalize_textsrs3z$shanri-ai-chatbot-for-text-to-speech)api_keyGEMINI_API_KEY)info timestampic sXtjd}d}|sdtd<dSd}||ddd }zvt4IdH`}|j||d IdH}|jd krb|}|d d d}t|dd}|d|d} | td<t td<t d| nt d|jWdIdHWdSWdIdHWdS1IdHswYWdSt y} zt d| WYd} ~ dSd} ~ ww)uq [新規] OpenWeatherMap APIを呼び出し、結果をグローバル変数(CACHE)に保存します。 OPENWEATHER_API_KEYzOsaka,JPu天気情報なしrNz/https://api.openweathermap.org/data/2.5/weathermetricja)qappidunitslang)paramsweatherr descriptionmaintempu 、気温u度r u+[Cache] 天気情報を更新しました: u[Cache] 天気APIエラー: uC[Cache] 天気情報の更新中にエラーが発生しました: )osenvironget WEATHER_CACHEhttpx AsyncClient status_codejsonroundtimerrerror Exception) r city_nameurlr(clientresponsedatar+r-formatted_weathererrrupdate_weather_cache.s>    2rAcs`t}tdr|tdtkrtdtdtdStdtIdHtddS)u [新規] キャッシュされた天気を返します。 もしキャッシュがないか、古くなっている場合は新しく取得します。 rr u:[Cache] キャッシュされた天気を使用します: un[Cache] キャッシュが期限切れ、または存在しません。同期呼び出しを実行します。Nu天気情報不明)r7r1CACHE_EXPIRY_SECrrrAr0) current_timerrrget_current_weather_cachedZs   rDc s t}d}dti}d|idddddid }td t4IdHA}|j|||d d IdH}|jd krGtd|j t |jdd| }d|vrUt dddt |d} WdIdHn 1IdHslwYt} d|dtd} d| } tjdddt| d } | | Wdn1swYt}|dtd}t| t|t}tj| rt| t}td| |ddtd|| ddtd ||ddtd!||ddd"td#|S)$Nz6https://texttospeech.googleapis.com/v1/text:synthesizekeyrja-JPzja-JP-Neural2-D) languageCodename audioEncodingMP3)inputvoice audioConfigu --- Google TTS 요청 시작 ---gN@r(r5timeoutr)uGoogle TTS 오류: zGoogle TTS Errorr4detail audioContentzNo audio content in responsezaudio--z.mp3ztmp/tmpT)exist_okwbzGoogle TTS API time: .2fszFile Write time: zS3 Upload time: z Total time: zhttps://z.s3.amazonaws.com/)r7rrrr2r3postr4r8rrr5base64 b64decoder.makedirsopenwrite s3_client upload_file bucket_namepathexistsremove)ruser_idt0r;r(payloadr<r= response_json audio_binaryt1filenamelocal_file_pathft2s3_keyt3t4rrrsynthesize_speechnsR   (     rscCsttjddd}tj|}|j}|j}d|kr dkr%nnd}n d|kr/dkr4nnd }nd|kr>d krCnnd }nd }d|krOd krTnnd }nd |kr^dkrcnnd}nd}|d|d||dS)uO[신규] 현재 JST 기준 시간, 계절, 시간대 인사를 반환합니다. )hoursJSTu春u夏 u秋u冬u朝u昼u夜u%Y年%m月%d日z%H:%M)dater7season time_greeting)datetimetimezone timedeltanowmonthhourstrftime)jstrrrr~rrrrget_current_season_and_times* rz/healthcs ddiS)Nstatushealthyrrrrr health_checksrz /apige/speech speech_textcs6|j}|j}|stdddt||IdH}d|iS)NzText is requiredrP audio_file)r chat_tokenrrs)rrrrrrrspeechs rz/demo/api/stt-from-file.filec sz|s tdddtd|jd|jtttd|IdH}t | d}d }d t i}d d d dddd|id}t 4IdHZ}t}|j|||ddIdH}t} td| |dd|jdkrtd|jt|jd|jd|} d} d| vr| ddddd} WdIdHn 1IdHswYtd | d!| d"WSty} ztd#| td$d%| dd} ~ ww)&u [로봇용 STT 엔드포인트] 1. Pi로부터 'audio/wav' 파일을 업로드 받습니다. 2. Google Cloud Speech API를 사용하여 텍스트로 변환합니다. (OpenAI Whisper 대체) 3. 변환된 텍스트(transcript)를 Pi에게 JSON으로 반환합니다. ru!오디오 파일이 없습니다.rPuSTT 파일 수신: z, type=uT>>> [Async] 天気情報の更新をバックグラウンドで開始しました。Nzutf-8z1https://speech.googleapis.com/v1/speech:recognizerErJi>rFTdefault)encodingsampleRateHertzrGenableAutomaticPunctuationmodelcontent)configaudiog$@rNuGoogle STT 호출 시간: rXu초r)uGoogle STT API 오류: zGoogle STT Error: rresultsr alternatives transcriptuGoogle STT 변환 결과: success)rru-'/demo/api/stt-from-file' 처리 중 오류: rSuSTT 변환 실패: )rrrrl content_typeasyncio create_taskrAreadr[ b64encodedecoderr2r3r7rZr4r8rr5r9) r file_bytesaudio_content_base64stt_urlr(rhr< stt_startr=stt_end result_jsontranscribed_textr@rrrprocess_stt_from_filesT    (ruE良い一日をお過ごしください。お名前は何ですか？z/demo/api/process-textrequestc s|j}|j}|j}td|d|d|z|s4dt}td|t|dt IdHt|d|IdHt |IdH}d d |D}t }t IdH}d |d d |dd|dd|dd|d }d|dg|} |rd} | d| dtjjjd| dd} | jdjj} td| t|d| IdHt| |IdH} | stddd| |d WSty}ztd!|tdd"|dd}~ww)#u= [로봇용 멀티턴(연속대화) 엔드포인트] u+로봇 멀티턴 요청 수신: session_id=z, input=z , LastTurn=zrobot-u새 세션 생성: assistantNusercSsg|] }|d|ddqS)rolerrrr).0rowrrr Tsz,process_robot_multi_turn..u # あなたの役割 あなたは、キャンパスに展示されている、親しみやすく知的な対話型ロボットです。 あなたの主な目的は、学生、教職員、訪問者と自然で、役に立ち、時宜にかなった（その時々に合った）会話を行うことです。 # 会話のルール 1. 常に礼儀正しく、親しみやすいトーンで応答してください。 2. 質問に対して、単に情報で答えるだけでなく、会話を広げるような（キャッチボールするような）応答を心がけてください。 3. 以下の「現在のコンテキスト」情報を、会話の中に**自然に**織り込んでください。 4. **回答は簡潔にし、文字数を40〜50文字程度に制限してください。長くなりすぎないように注意してください。** # 現在のコンテキスト * 現在の日付: r}u * 現在の時刻: r7z (ru) * 現在の季節: r~u * 今日の天気: uC * あなたの場所: 大学 エントランス systemru 🛑 [緊急指令: 会話終了モード] 🛑 これが最後のターンです。これまでの文脈やルールに関係なく、以下の指示を**最優先**で実行してください。 1. **【質問絶対禁止】** いかなる理由があっても、ユーザーに質問をしてはいけません。（「〜はいかがですか？」なども禁止） 2. **【共感 + 感謝】** - まず、ユーザーの発言に短く共感してください。 - その直後に、「お話しできて楽しかったです」や「お話ししてくれてありがとう」といった**感謝や喜びの言葉**を自然に続けてください。 3. **【お元気でね】** - 応答の最後は、必ず「**お元気でね**」というフレーズだけで締めくくってください。 - 文末は必ず「〜。お元気でね」の形になります。 z gpt-4o-mini)rmessages max_tokensruGPT 자연 대화 응답: rSu'TTS S3 업로드에 실패했습니다.rP) audio_url session_idu8'/demo/api/process-text' (멀티턴) 처리 중 오류: u서버 내부 오류: ) user_inputr is_last_turnrruuiduuid4 db_modulesave_robot_chat_messageFIRST_AI_PROMPTget_robot_chat_historyrrDappendr<chat completionscreatechoicesmessagerrsrr9r8)r user_textrr history_rowshistory_messagescontextr*base_system_promptmessages_for_gptlast_turn_instruction chat_responsegpt_response_text s3_audio_urlr@rrrprocess_robot_multi_turn=sb      r)8fastapirrrfastapi.responsesrboto3r.r7schemasrrrr r r r dbr openairrrrrrr2rrrgooglerr[rstrrr<r`rbClientr/r0 gemini_clientrouterr1rBrArDrsrrrZrrrrrrrrsV        ,N!  L