Upload app.py.txt

app.py.txt

@@ -0,0 +1,173 @@
+import gradio as gr
+import pandas as pd
+import numpy as np
+import os
+from openai import OpenAI
+
+# --- 設定 ---
+api_key = os.getenv("OPENAI_API_KEY")
+
+# 固定ファイル名
+MASTER_FILE = "master.csv"
+PLM_FILE = "plm.csv"
+
+def robust_read_csv(path, target_columns):
+    """
+    タイトル行や空行をスキップし、特定のカラム名が含まれる行をヘッダーとして自動認識して読み込む。
+    """
+    if not os.path.exists(path):
+        return None, f"ファイル '{path}' が見つかりません。"
+
+    encodings = ['cp932', 'utf-8', 'shift_jis']
+    for enc in encodings:
+        try:
+            # まずはヘッダーなしで全行読み込む
+            raw_df = pd.read_csv(path, encoding=enc, header=None, on_bad_lines='skip', engine='python')
+            
+            # ターゲットとなるカラム名が含まれる行を探す
+            header_idx = None
+            for i, row in raw_df.iterrows():
+                row_values = [str(x) for x in row.values]
+                # target_columnsのいずれかが含まれている行をヘッダーとみなす
+                if any(col in row_values for col in target_columns):
+                    header_idx = i
+                    break
+            
+            if header_idx is not None:
+                # 特定した行をヘッダーとして再読み込み
+                df = pd.read_csv(path, encoding=enc, skiprows=header_idx)
+                # カラム名に含まれる改行コードなどを除去
+                df.columns = [str(c).replace('\n', '').strip() for c in df.columns]
+                return df, None
+            else:
+                return None, f"ヘッダー行（{target_columns}）が見つかりませんでした。"
+                
+        except UnicodeDecodeError:
+            continue
+        except Exception as e:
+            return None, str(e)
+            
+    return None, "文字コードの判定に失敗しました。"
+
+# データの読み込み（起動時に実行）
+# 原紙マスタは「品番」、PLMは「代表銘柄」をキーにヘッダーを探索
+M_DF, M_ERR = robust_read_csv(MASTER_FILE, ["品番", "親品番", "銘柄名"])
+P_DF, P_ERR = robust_read_csv(PLM_FILE, ["代表銘柄", "品名", "材料名"])
+
+def analyze_cd_logic(target_brand):
+    # エラーチェック
+    if M_DF is None: return f"❌ マスタ読み込みエラー: {M_ERR}"
+    if P_DF is None: return f"❌ PLMデータ読み込みエラー: {P_ERR}"
+    if not api_key: return "❌ OpenAI APIキーが未設定です。"
+    if not target_brand: return "⚠️ 銘柄名または親品番を入力してください。"
+
+    client = OpenAI(api_key=api_key)
+
+    try:
+        # 1. 銘柄検索ロジック (親品番、銘柄名、一般名称銘柄)
+        # カラム名の揺れに対応（マスタ側）
+        brand_mask = (M_DF['親品番'].astype(str) == target_brand) | \
+                     (M_DF['銘柄名'].astype(str) == target_brand)
+        
+        # 3列目（一般名称銘柄）も検索対象に
+        if M_DF.shape[1] > 2:
+            brand_mask |= (M_DF.iloc[:, 2].astype(str) == target_brand)
+        
+        brand_data = M_DF[brand_mask]
+        
+        if brand_data.empty:
+            return f"❌ 銘柄「{target_brand}」はマスタに見つかりません。"
+        
+        spec = brand_data.iloc[0]
+        
+        # 2. 製品紐付け（PLM側）
+        related_prods = P_DF[P_DF['代表銘柄'].astype(str) == target_brand]
+        prod_names = related_prods['品名'].unique()[:5] if not related_prods.empty else ["紐付けなし"]
+
+        # 3. CDロジック判定（資材1G戦略に基づく）
+        findings = []
+
+        # A. 共用銘柄化（メーカー集約）
+        all_variants = M_DF[M_DF['親品番'] == spec['親品番']].copy()
+        all_variants['price'] = pd.to_numeric(all_variants['仕入単価（新）'], errors='coerce')
+        if all_variants['製紙会社'].nunique() > 1:
+            p_max = all_variants['price'].max()
+            p_min = all_variants['price'].min()
+            if p_max > p_min:
+                findings.append(f"【共用銘柄化】同一品番内で複数メーカー混在。単価差 {p_max - p_min:.1f}円/kg。安値メーカーへの全量集約。")
+
+        # B. 環境対応（1Gナレッジ）
+        if str(spec.get('古紙使用フラグ')) == '1':
+            findings.append("【環境対応見直し】古紙配合品からFSC認証紙へのスペック変更。1G事例（▲18M/年）に基づくコスト構造の改善。")
+
+        # C. 価値の再定義（一般品化）
+        if '1' in [str(spec.get('特抄フラグ')), str(spec.get('特寸フラグ'))]:
+            findings.append("【価値の再定義】特注仕様（特抄・特寸）を廃止し、一般流通品へ集約。供給ソース固定化の解消と相見積の実施。")
+
+        # D. 仕様変更（薄物化）
+        gram = pd.to_numeric(spec['坪量　g/㎡'], errors='coerce')
+        if not np.isnan(gram) and gram > 70:
+            findings.append(f"【仕様変更】現行{gram}g/㎡。オーバースペックの可能性。一段階下の米坪（薄物化）による原資コスト低減。")
+
+        if not findings:
+            return "💡 明確な自動判定ロジックに該当する施策は見つかりませんでした。市場市況に基づく価格交渉、または物流商流の効率化を検討してください。"
+
+        # 4. AIによる具体的施策の肉付け
+        prompt = f"""
+        あなたは製造業の戦略調達プロフェッショナルです。以下のデータ分析結果に基づき、実務に即した「CD施策シート」を作成してください。
+        
+        【対象銘柄情報】
+        銘柄: {spec['銘柄名']}
+        製紙会社: {spec['製紙会社']} / 現行単価: {spec['仕入単価（新）']}円
+        主要使用製品: {', '.join(prod_names)}
+        検出された論理: {" / ".join(findings)}
+        
+        【出力ルール】
+        - 交渉メール案、反論対策、導入文、挨拶は一切含めないでください。
+        - 以下の4項目を1セットとして、各切り口ごとに鋭く、論理的なアクションを出力してください。
+        
+        1. 切り口
+        2. 具体的な方法
+        3. 現状の課題（データからの根拠）
+        4. 提案内容と期待効果（具体的アクションプラン）
+        """
+
+        response = client.chat.completions.create(
+            model="gpt-4o",
+            messages=[{"role": "system", "content": "あなたは論理的で実務に厳しい調達分析官です。"},
+                      {"role": "user", "content": prompt}],
+            temperature=0.3
+        )
+        return response.choices[0].message.content
+
+    except Exception as e:
+        return f"🚨 解析エラー: {str(e)}"
+
+# --- Gradio UI ---
+with gr.Blocks(theme=gr.themes.Soft()) as demo:
+    gr.Markdown("# 🛡️ CDG AI Strategist - 論理分析特化版")
+    gr.Markdown("不規則なCSV形式にも対応した強化版読み込みエンジンを搭載しています。")
+    
+    with gr.Row():
+        with gr.Column(scale=1):
+            brand_input = gr.Textbox(label="銘柄名 / 親品番 を入力", placeholder="例: Jｳﾒ70AC")
+            btn = gr.Button("CD戦略を生成", variant="primary")
+            
+            # ステータス表示
+            if M_DF is not None:
+                gr.Markdown(f"✅ 原紙マスタ: {len(M_DF)}行 読み込み完了")
+            else:
+                gr.Markdown(f"❌ 原紙マスタ: {M_ERR}")
+            
+            if P_DF is not None:
+                gr.Markdown(f"✅ PLMデータ: {len(P_DF)}行 読み込み完了")
+            else:
+                gr.Markdown(f"❌ PLMデータ: {P_ERR}")
+                
+        with gr.Column(scale=2):
+            output = gr.Markdown(label="CD施策詳細レポート")
+
+    btn.click(fn=analyze_cd_logic, inputs=brand_input, outputs=output)
+
+if __name__ == "__main__":
+    demo.launch()