o i@sHddlZddlZddlmZddlmZddlmZddlm Z m Z ddl m Z m Z mZmZmZmZmZmZmZmZe dZe dZd d Zd d Zd dZde fddZde fddZdefddZdefddZdefddZdefddZ defddZ!defdd Z"defd!d"Z#d#e$fd$d%Z%defd&d'Z&d#e$fd(d)Z'dS)*N)types)datetime)logger) get_db_config genai_client) CheckInRequestMorningAssessmentRequestMorningReflectionRequest EndDayRequestSubmitSalesReportRequestBossCommentRequestCounselingRequestFinalReviewAnalysisRequestSubmitFinalReviewRequestFinishCounselingRequest Sales_B_DB Sales_C_DBcCtjjditSN)mysql connectorconnect B_DB_CONFIGrrr>/home/air/goalskill_sales/back/app/models/today_goal_module.pyget_db_connectionrcCrr)rrr C_DB_CONFIGrrrrget_c_db_connectionrrc Csd}d}zfz6t}|}d|d}|D]}t|d}|d}||||||fq|td|d|WntyY} ztd|d t| WYd} ~ nd} ~ wwW|ra||ri|dSdS|rq||rx|ww) u goals 리스트의 current 값으로 Sales_C_DB를 업데이트합니다. 단, achievement_rate(달성률)은 Sales_C_DB 테이블에 이미 저장된 'target' 값을 기준으로 계산합니다. Nz UPDATE z SET achievement = %s, achievement_rate = IF(target > 0, ROUND((%s / target) * 100), 0) WHERE session_id = %s AND category = %s current_countcategoryzDEBUG: Updated z using DB targets for session zError updating Sales_C_DB (z): ) rcursorfloatexecutecommitprint Exceptionstrclose) session_idgoals table_nameconnr! update_sqlgcurrentr errrupdate_sales_c_dbAs. $  r1 checkin_datac Csr|jdd}zz|d|jf|}|std|jdk}d}|||j|j||j|jft|d}||j}|d||jf| |d r[t|d dkr[t|d }nt|d }d d } |rd } | |j} | |} | |} d| d| |dd}d| |dd|d}nd} d}d|| |dWW| St y}z| |d}~ww| w)NT dictionaryz!SELECT * FROM goals WHERE id = %su!目標が見つかりません。rz INSERT INTO check_in_logs (goal_id, increment_count, is_success, user_mood, session_type) VALUES (%s, %s, %s, %s, %s) rz1UPDATE goals SET current_count = %s WHERE id = %sadjusted_target_countoriginal_target_countcSs|rt|S|S)N) is_integerint)numrrrfmtsz"process_30min_checkin..fmtPRAISEu (累計: /unit)uお疲れ様です！30分でu進みましたね。u) この調子でいきましょう！🔥 COUNSELINGun実績なしですね。ということですが、焦らずいきましょう。次の30分で挽回です！success)status is_successai_modemessage) r!r#goal_idfetchone ValueErrorincrement_count user_mood session_typer"r$r(r&rollback)db_connr2r!goalrBinsert_log_sqlcurrent_db_valnew_current_countdisplay_targetr:rC formatted_incformatted_currformatted_target progress_inforDr0rrrprocess_30min_checkinms^       rV request_datac CsD|jdd}zz|d|jf|}|stdg}d}d}|D]0}t|d}t|d} ||7}|| 7}|dkrFt| |d nd} ||d | || d q$|dkr\d} nt||d } g} d } d }d }| dkrd } d| d}d}|D]}|d|d|dfq|nId} d| d}d}|D]<}t|d}t|d} | |kr|}n || }t| |d}|d||df||kr| |d|d||dqd}||| ||jf| |d|jf| }|rt |d|d| | ||| |dWW| St y}z||d}~ww| w)NTr3&SELECT * FROM goals WHERE plan_id = %su'評価する目標はありません。r6rrdtitler[r/targetrateHIGH(u 全達成率 uQ%. 素晴らしいペースです！各項目も順調に進んでいますね。ux現在のペースが良いので、午後の目標はそのまま維持します。このまま完走しましょう！z9UPDATE goals SET adjusted_target_count = %s WHERE id = %sidLOWuE%. 目標に対して少し遅れている項目が見られます。uu負担を減らして完走できるよう、未達成の項目を中心に目標を現実的に調整しました。r )rEr original_targetadjusted_targetz UPDATE daily_plans SET morning_motivation_score = %s, ai_feedback_summary = %s WHERE id = %s 0SELECT session_id FROM daily_plans WHERE id = %sr)today_sales_am_daily)motivation_levelscore ai_summaryafternoon_actionadjusted_goals breakdown)r!r#plan_idfetchallrGr"r8appendroundr$rFr1r(r&rK)rLrWr!r*breakdown_listtotal_original_targettotal_current_countr.originalr/r^rjadjusted_goals_listrirkrlrM new_target remaining update_query plan_infor0rrrevaluate_morning_motivations           r|c Cst|jdd}z.zd}|||j|jf|dddWW|Sty4}z||d}~ww|w)NTr3z9UPDATE daily_plans SET user_reflection = %s WHERE id = %su保存されました。u率直な振り返り、ありがとうございました。 記録していただいた悩みは、より良い成果のための土台になります。 午後も応援します！💪)rD ai_advice)r!r#reflection_textror$r(r&rK)rLrWr!r-r0rrrsave_morning_reflection(s   rc Cs|jdd}zz|d|jf|}|stdg}d}d}g}|D]e}|ddkr2t|dnt|d} t|d } || 7}|| 7}| dkrRt| | d nd} ||d | | | d |} | rlt| n| | d <tt|d| d<tt|d| d<|| q$|dkrt||d nd} |d |jf| |d|jf| }|rt |d|d| d krd}n | dkrd}nd}| |||dWW| Sty}z||d}~ww| w)NTr3rXzData Not FoundrYr5rr6rrZr[r\u<UPDATE daily_plans SET total_status = '完了' WHERE id = %srgr)today_sales_pm_dailyu^本当にお疲れ様でした！目標完全達成、素晴らしい一日でしたね！🎉Pujお疲れ様でした！今日も一日よく頑張りました。ゆっくり休んでください。🍵umお疲れ様でした。今日は少し大変でしたか？明日はきっと良い日になります！💪) final_scorerDrnr*)r!r#rorprGr"r8rqcopyr7r$rFr1r(r&rK)rLrWr!r*rs total_target total_current updated_goalsr. target_val current_valr^g_copyrr{msgr0rrrfinish_day_and_get_report>sl $    rc Cs|jdd}z@z-d}|||j|j|jf||jdkr*dddWW|Sdd dWW|StyF}z| |d}~ww|w) NTr3z| UPDATE daily_plans SET boss_comment = %s WHERE session_id = %s AND date = %s rerroru?該当日付のレポートは見つかりませんでした。rArDr@u0フィードバックが保存されました。) r!r# boss_commentr)dater$rowcountr(r&rKrLrWr!sqlr0rrrsave_boss_comments(      rc Cs|jdd}zIz6d}|jD]}|jr%|jr%|||j|j|j|jfq d}|||jf|ddiWW| St yO}z| |d}~ww| w)NTr3z INSERT INTO sales_report_reflections (plan_id, goal_id, reflection_text, session_id) VALUES (%s, %s, %s, %s) zSELECT id FROM daily_plans WHERE session_id = %s AND date = %suデータなしzmSELECT title, current_count, original_target_count, adjusted_target_count, unit FROM goals WHERE plan_id = %srbr5rr6r[: rr<r=z, u現在の午前の成果: []u SELECT sender, message FROM daily_counseling WHERE session_id = %s AND DATE(created_at) = %s -- [중요] 오늘 생성된 대화만 가져옴 ORDER BY created_at ASC r`senderUserAIrD z#Google API Key is missing in configu あなたは営業社員のメンタルケアとコーチングを行う専門AIです。 # ユーザー情報 - 現在の時刻: 午後1時 (午前業務終了後) - 本日の成果データ: u (形式: 目標項目: 現在/目標) # 行動指針 1. **コンディション確認 (最優先)**: - ユーザーの発言から「頭痛」「腹痛」「体調が悪い」「集中できない」などの**不調**が読み取れる場合は、成果の良し悪しに関わらず、まず体を気遣ってください。 - その上で、**「体調が優れないようですね。午後の目標数値を少し下げましょうか？」** と必ず提案してください。 **[重要: 提案に対する反応への対応]** - **A. ユーザーが「下げてほしい」「はい」と同意した場合**: 「分かりました。午後の目標数値を調整します。」とだけ答えてください。これ以外の余計な慰めやアドバイスは一切不要です。 - **B. ユーザーが「いいえ」「そのままやる」と断った場合**: 不調をおして頑張ろうとするその姿勢を**強く称賛**し、「無理は禁物ですが、その意気込みならきっとできます！」と全力で応援してください。 2. **共感**: (体調に問題がない場合) まずユーザーの感情に寄り添ってください。否定せず受け入れてください。 3. **分析**: 成果データを見て、客観的な事実に基づいたアドバイスをしてください。 - 進捗が良い場合(50%以上): 褒めて、午後の勢いをつける言葉を。 - 進捗が悪い場合(50%未満): 責めずに、「午後は量より質でいこう」などの切り替えの提案を。 4. **提案**: 抽象的な精神論ではなく、具体的な行動(Action)を1つ提案してください。 (例: "まずは得意な顧客から電話してみましょう", "5分だけコーヒーブレイクを取りましょう") 5. **口調**: 丁寧ですが、親しみやすい先輩のような口調で。(〜ですね、〜しましょう) 6. **長さ**: 3文以内で簡潔に。長すぎると読まれません。 gemini-2.5-flashu1Contextを踏まえて、私の最新の発言「u!」に返答してください。g?system_instruction temperaturemodelcontentsconfigu_ これ以上相談したいことがなければ、下のボタンを押してください。zGemini API Error: uB通信エラーが発生しました。申し訳ありません。botr@)rAreply)r!rnowstrftimer#r)rDr$rorFrprqjoinrrGmodelsgenerate_contentrGenerateContentConfigtextr&r%r(rK)rLrWr! today_strrplanplan_sql context_msgr* goal_listr.r] goal_status history_sql history_rowschat_history_textrowroleai_response_text system_promptresponseai_errorr0rrrprocess_counseling_messages ,      rc Cs|jdd}zz|d|jf|}d}|||jf|}d}|||jf|}d}|r?ddd |D}nd }d} d } d } |D]1} t| d } t| d }| | 7} | |7} | d| dd|d| | dd| dpudd 7} qI| d krt| | dnd }tdurt dd|d|d| d}tj j ddt j |dd d!}|j}d"||d#WW|Sty}ztd$|d%d&d d#WYd}~W|Sd}~ww|w)'NTr3rXz SELECT g.title, g.original_target_count, g.current_count, g.unit, r.reflection_text FROM goals g LEFT JOIN sales_report_reflections r ON g.id = r.goal_id WHERE g.plan_id = %s z SELECT message, sender FROM daily_counseling WHERE session_id = %s AND DATE(created_at) = CURDATE() ORDER BY created_at ASC r`rcSs$g|]}d|dd|dqS)- rrrDr).0logrrr js$z,generate_final_ai_review..u#特になし (Consultation skipped)rr6rrr[rr<r=z (Reflection: r~uなしz) rZzGemini Client Not ConfigureduI あなたは営業チームの優秀なマネージャーAIです。 部下が提出した「本日の営業日報」と、午前中に交わした「相談内容」を総合的に分析し、一日の総括コメントを作成してください。 # 📊 データ 1. 全体達成率: u9% 2. 午前中の相談内容 (Context): u@ 3. 詳細レポート (振り返り): u # 📝 指示 1. **ストーリーの接続**: もし午前中に悩み(相談)があったなら、その悩みが午後どうなったか（克服したか、まだ続いているか）に触れてください。 2. **労いと称賛**: 結果だけでなく、過程やメンタルの変化を褒めてください。 3. **分析**: ユーザーが書いた「振り返り」と「実績」を照らし合わせてフィードバックしてください。 4. **次へのアクション**: 明日に向けた簡潔なアドバイスを1つ。 5. **トーン**: 温かく、信頼できるパートナーとして。 ruH本日の日報に対するフィードバックをお願いします。gffffff?rrr@)rA ai_comment total_ratezError generating review: ruAI分析中にエラーが発生しました。しかし、今日の一日は確実にあなたの力になっています。お疲れ様でした。)r!r#rorpr)rr"r8rrGrrrrrr(r&r%)rLrWr!r*rdetails counsel_sql counsel_logscounseling_contextreport_summaryrrdr]r/rrrrr0rrrgenerate_final_ai_reviewJsr   8     rc Csv|jdd}z/zd}|||j|j|jf|ddiWW|Sty5}z||d}~ww|w)NTr3z UPDATE daily_plans SET final_user_comment = %s, final_ai_comment = %s WHERE id = %s rDuT日報が完全に保存されました。本日も本当にお疲れ様でした！) r!r#final_user_commentfinal_ai_commentror$r(r&rKrrrrsave_final_reviews    rr)c Csx|jdd}zzd}|||f|}g}|D]}d}|||df|}g} |D]@} t| d} t| d} | dkrHt| | d nd} | | d | rWt| n| | r`t| n| | d | | d pjd dq.d}||||df|}||dt|d|d|d|d|d|d| |d qd|iWW|St y}z|d}~ww|w)NTr3z SELECT id, date, total_status, boss_comment, final_ai_comment, final_user_comment, morning_motivation FROM daily_plans WHERE session_id = %s ORDER BY date DESC LIMIT 30 a% SELECT g.title, g.original_target_count, g.current_count, g.unit, r.reflection_text FROM goals g LEFT JOIN sales_report_reflections r ON g.id = r.goal_id WHERE g.plan_id = %s rbr6rrrZr[r=r~r`)r[r]r/r=r^ reflectionz SELECT sender, message, DATE_FORMAT(created_at, '%H:%i') as time FROM daily_counseling WHERE session_id = %s AND DATE(created_at) = %s ORDER BY created_at ASC r total_statusrrrmorning_motivation) rorrArrrmindsetrcounseling_logsdata) r!r#rpr"r8rqr7r'r(r&)rLr)r!rplansresultsp detail_sqlrformatted_detailsrorigcurrr^rrr0rrrget_boss_daily_reportssX          rc Cs|jdd}zwz]d}|||jf|}|s#dddWW|Sddd |D}tdur5td d }tjj d d |t j |ddd}|j }d} || ||j f|d|dWW|Sty}} z |td| | d} ~ ww|w)NTr3z SELECT sender, message FROM daily_counseling WHERE session_id = %s AND DATE(created_at) = CURDATE() ORDER BY created_at ASC skippedzNo counseling logs found.rrcSs"g|] }|dd|dqS)rrrDr)rlrrrrs"z0summarize_morning_counseling..zGoogle API Key is missingu あなたは営業マネージャーのアシスタントAIです。 午前業務終了後の「部下との相談チャットログ」を分析し、 部下の「現在のモチベーション状態」や「抱えている悩み」を 日本語で 1〜2文の簡潔な要約文 にまとめてください。 この要約はデータベースの 'morning_motivation' カラムに保存され、 上司が部下の状態を把握するために使われます。 出力例: - 電話が繋がらず落ち込んでいたが、午後はアプローチを変えて頑張るとのこと。 - 目標を上回るペースで進んでおり、意欲は非常に高い。 - 疲れが見えるため、午後のこまめな休憩を提案した。 - コンディションが悪そうなので、午後の目標数を減らすことを提案した。 rz Chat Logs: g?rrzs2   0/,GtQhHB