app.py

app.py

@@ -1,7 +1,8 @@
-from flask import Flask, render_template_string, jsonify, send_file
+from flask import Flask, render_template_string, jsonify, Response
 import pandas as pd
-from io import BytesIO
 import os
+from collections import Counter
+from io import BytesIO
 
 app = Flask(__name__)
 
@@ -91,12 +92,40 @@ def quarter_trends_df():
     qdf = qdf.sort_values(["YEAR", "QNUM"]).drop(columns=["YEAR", "QNUM"])
     return qdf
 
+
+def get_top_faqs(limit=6):
+    """Read logged queries and return top N most common questions."""
+    if not os.path.exists("faq_log.csv"):
+        return [
+            "Which block type had the highest backlog last quarter?",
+            "Which customers have the most open blocked orders?",
+            "How many orders have multiple active blocks?",
+            "What is the trend of delivery blocks across quarters?",
+            "Which blocks contribute the most to total backlog value?"
+        ]
+    with open("faq_log.csv", "r", encoding="utf-8") as f:
+        lines = [l.strip() for l in f if l.strip()]
+    # keep last 500
+    if len(lines) > 500:
+        with open("faq_log.csv", "w", encoding="utf-8") as f:
+            f.write("\n".join(lines[-500:]))
+    common = [q for q, _ in Counter(lines).most_common(limit)]
+    return common if common else ["Ask me about blocked orders or quarterly trends!"]
+
 # -----------------------------------------------------
 # Chatbot Endpoint
 # -----------------------------------------------------
 @app.route("/chat_ollama/<query>")
 def chat_ollama(query):
     q = query.lower().strip()
+
+    # Log the user query to file
+    try:
+        with open("faq_log.csv", "a", encoding="utf-8") as f:
+            f.write(q + "\n")
+    except Exception as e:
+        print("FAQ log write error:", e)
+
     reply = "No relevant insight found. Try asking about customers, block types, or quarterly trends."
 
     try:
@@ -120,7 +149,7 @@ def chat_ollama(query):
             main_block = block_counts.index[0] if not block_counts.empty else "general"
             reply = (
                 f"{cust_name} currently holds the highest backlog value (${value:,.0f}) "
-                f"with {main_block} as the main issue. Coordinate cross-functionally to resolve {main_block.lower()} constraints and improve throughput."
+                f"with {main_block} as the main issue. Coordinate cross-functionally to resolve {main_block.lower()} constraints."
             )
 
         # --- MULTIPLE BLOCK ORDERS ---
@@ -142,7 +171,7 @@ def chat_ollama(query):
                 top = bs.iloc[0]
                 reply = (
                     f"{top['BLOCK_TYPE']} block represents the largest backlog exposure "
-                    f"(${top[WORTH_COL]:,.0f}). Engage respective teams to address {top['BLOCK_TYPE'].lower()} issues and accelerate order release."
+                    f"(${top[WORTH_COL]:,.0f}). Engage respective teams to address {top['BLOCK_TYPE'].lower()} issues."
                 )
 
         # --- QUARTERLY TREND LOGIC ---
@@ -153,22 +182,17 @@ def chat_ollama(query):
                     qdf["QUARTER"].unique(),
                     key=lambda q: (int(q[:4]), int(q[-1]))
                 )
-                if not quarters:
-                    reply = "No quarterly trend data available."
-                else:
-                    latest_quarter = quarters[-2] if len(quarters) >= 2 else quarters[-1]
+                if quarters:
                     next_quarter = quarters[-1]
-
                     next_q_df = qdf[qdf["QUARTER"] == next_quarter]
                     if not next_q_df.empty:
                         top_block = next_q_df.sort_values(WORTH_COL, ascending=False).iloc[0]
                         reply = (
-                            f"Upcoming {next_quarter}: {top_block['BLOCK_TYPE']} block shows highest exposure "
-                            f"(${top_block[WORTH_COL]:,.0f}). Prepare mitigation plans with {top_block['BLOCK_TYPE'].lower()} owners."
+                            f"In {next_quarter}, {top_block['BLOCK_TYPE']} block shows the highest exposure "
+                            f"(${top_block[WORTH_COL]:,.0f}). Prepare mitigation plans with owners."
                         )
                     else:
-                        reply = f"No data found for next quarter ({next_quarter})."
-
+                        reply = f"No data found for {next_quarter}."
     except Exception as e:
         reply = f"(Error: {e})"
 
@@ -223,12 +247,7 @@ def data_quarter_trends():
     qdf = quarter_trends_df()
     if qdf.empty:
         return jsonify({"columns": [], "rows": [], "insight": "No quarterly data found."})
-    quarters = sorted(
-        qdf["QUARTER"].unique(),
-        key=lambda q: (int(q[:4]), int(q[-1]))
-    )
-    latest_quarter = quarters[-2] if len(quarters) >= 2 else quarters[-1]
-    next_quarter = quarters[-1]
+    next_quarter = qdf["QUARTER"].max()
     next_q_df = qdf[qdf["QUARTER"] == next_quarter]
     if not next_q_df.empty:
         top_block = next_q_df.sort_values(WORTH_COL, ascending=False).iloc[0]
@@ -246,9 +265,8 @@ def data_quarter_trends():
     })
 
 # -----------------------------------------------------
-# HTML Template (unchanged layout)
+# HTML Template with adaptive FAQ placeholder
 # -----------------------------------------------------
-
 HTML = """
 <!doctype html>
 <html>
@@ -264,15 +282,8 @@ body{margin:0;font-family:'Segoe UI',sans-serif;overflow:hidden;}
 .tiles{padding:10px;display:grid;grid-template-columns:1fr 1fr;gap:10px;}
 .tile{background:#f4f4f4;color:#0A2048;border-radius:10px;text-align:center;box-shadow:0 1px 4px rgba(0,0,0,.2);padding:10px;font-weight:600;cursor:pointer;transition:0.2s;}
 .tile:hover{background:#e2e2e2;}
-#faqTile{
-  background:linear-gradient(135deg,#0A2048,#1c398b);
-  color:white;
-  font-style:italic;
-  grid-column:span 2;
-}
-#faqTile:hover{
-  background:linear-gradient(135deg,#1a2b60,#334b9a);
-}
+#faqTile{background:linear-gradient(135deg,#0A2048,#1c398b);color:white;font-style:italic;grid-column:span 2;}
+#faqTile:hover{background:linear-gradient(135deg,#1a2b60,#334b9a);}
 .chat{flex:1;overflow-y:auto;padding:10px;background:#fafafa;}
 .msg-bot{background:white;border:1px solid #ddd;border-radius:10px;padding:10px;margin-bottom:8px;line-height:1.4;}
 .table-wrap{overflow-x:auto;overflow-y:auto;max-height:60vh;margin-top:6px;border:1px solid #ddd;border-radius:6px;background:#fff;}
@@ -289,155 +300,102 @@ button:hover{background:#122b6b;}
 </head>
 <body>
 <div class="container">
-  <iframe title="Midterm Control Tower" width="1140" height="541.25"
-    src="https://app.powerbi.com/reportEmbed?reportId=c74ac0ec-b0f8-48b9-b7a7-4baab36d9ac5&autoAuth=true&ctid=41f88ecb-ca63-404d-97dd-ab0a169fd138"
-    frameborder="0" allowFullScreen="true"></iframe>
-
-  <div class="assistant">
-    <div class="header">Blocks Assistant</div>
-
-    <div class="tiles">
-      <div class="tile" onclick="loadTile('/data/summary')">Overall Block Summary</div>
-      <div class="tile" onclick="loadTile('/data/focus_area')">Actionable Focus Area</div>
-      <div class="tile" onclick="loadTile('/data/multiple_blocks')">Multiple Block Orders</div>
-      <div class="tile" onclick="loadTile('/data/quarter_trends')">Quarter-wise Trends</div>
-      <!-- New dynamic FAQ tile -->
-      <div class="tile" id="faqTile" onclick="autoAskFAQ()">💡 FAQ: <span id="faqText"></span></div>
-    </div>
-
-    <div id="chat" class="chat">
-      <div class="msg-bot"><b>Hello!</b><br>I'm your Blocks Assistant. How can I help you today?</div>
-    </div>
-
-    <div class="searchBox">
-      <input id="searchInput" placeholder="Ask about blocks or customers..." onkeypress="if(event.key==='Enter')sendChat()">
-      <button onclick="sendChat()">Search</button>
-    </div>
+<iframe title="Midterm Control Tower" src="https://app.powerbi.com/reportEmbed?reportId=c74ac0ec-b0f8-48b9-b7a7-4baab36d9ac5&autoAuth=true&ctid=41f88ecb-ca63-404d-97dd-ab0a169fd138" frameborder="0" allowFullScreen="true" class="dashboard"></iframe>
+<div class="assistant">
+  <div class="header">Blocks Assistant</div>
+  <div class="tiles">
+    <div class="tile" onclick="loadTile('/data/summary')">Overall Block Summary</div>
+    <div class="tile" onclick="loadTile('/data/focus_area')">Actionable Focus Area</div>
+    <div class="tile" onclick="loadTile('/data/multiple_blocks')">Multiple Block Orders</div>
+    <div class="tile" onclick="loadTile('/data/quarter_trends')">Quarter-wise Trends</div>
+    <div class="tile" id="faqTile" onclick="autoAskFAQ()">💡 FAQ: <span id="faqText"></span></div>
+  </div>
+  <div id="chat" class="chat">
+    <div class="msg-bot"><b>Hello!</b><br>I'm your Blocks Assistant. How can I help you today?</div>
+  </div>
+  <div class="searchBox">
+    <input id="searchInput" placeholder="Ask about blocks or customers..." onkeypress="if(event.key==='Enter')sendChat()">
+    <button onclick="sendChat()">Search</button>
   </div>
 </div>
-
+</div>
 <script>
 function markdownToHTML(t){return t.replace(/\\*\\*(.*?)\\*\\*/g,'<strong>$1</strong>').replace(/\\n/g,'<br>');}
-
 async function loadTile(url){
-  const res=await fetch(url);
-  const j=await res.json();
-  const chat=document.getElementById('chat');
-  const section=document.createElement('div');
-  section.className='msg-bot';
-  section.style.borderTop='2px solid #eee';
-  section.style.marginTop='10px';
-  let html=`<p>${j.insight||''}</p>`;
-  if(j.columns?.length){
-    html+=`<div class='table-wrap'><table><tr>${j.columns.map(c=>`<th>${c}</th>`).join('')}</tr>`;
-    html+=j.rows.map(r=>`<tr>${j.columns.map(c=>`<td>${r[c]??''}</td>`).join('')}</tr>`).join('')+'</table></div>';
-    if(j.download){html+=`<a class='download' href='${window.location.origin + j.download}' target='_blank'>📥 Download CSV</a>`;}
-  }
-  section.innerHTML=html;
-  chat.appendChild(section);
-  chat.scrollTop=chat.scrollHeight;
+ const res=await fetch(url);const j=await res.json();
+ const chat=document.getElementById('chat');
+ const section=document.createElement('div');section.className='msg-bot';section.style.borderTop='2px solid #eee';section.style.marginTop='10px';
+ let html=`<p>${j.insight||''}</p>`;
+ if(j.columns?.length){
+   html+=`<div class='table-wrap'><table><tr>${j.columns.map(c=>`<th>${c}</th>`).join('')}</tr>`;
+   html+=j.rows.map(r=>`<tr>${j.columns.map(c=>`<td>${r[c]??''}</td>`).join('')}</tr>`).join('')+'</table></div>';
+   if(j.download){html+=`<a class='download' href='${window.location.origin + j.download}' target='_blank'>📥 Download CSV</a>`;}
+ }
+ section.innerHTML=html;chat.appendChild(section);chat.scrollTop=chat.scrollHeight;
 }
-
 async function sendChat(){
-  const q=document.getElementById('searchInput').value.trim();
-  if(!q)return;
-  const chat=document.getElementById('chat');
-  const u=document.createElement('div');
-  u.className='msg-bot';
-  u.style.background='#0A2048';
-  u.style.color='white';
-  u.textContent=q;
-  chat.appendChild(u);
-  document.getElementById('searchInput').value='';
-  const thinking=document.createElement('div');
-  thinking.className='msg-bot';
-  thinking.textContent='Thinking...';
-  chat.appendChild(thinking);
-  chat.scrollTop=chat.scrollHeight;
-  const res=await fetch('/chat_ollama/'+encodeURIComponent(q));
-  const j=await res.json();
-  thinking.remove();
-  const b=document.createElement('div');
-  b.className='msg-bot';
-  b.innerHTML=markdownToHTML(j.response);
-  chat.appendChild(b);
-  chat.scrollTop=chat.scrollHeight;
+ const q=document.getElementById('searchInput').value.trim();if(!q)return;
+ const chat=document.getElementById('chat');
+ const u=document.createElement('div');u.className='msg-bot';u.style.background='#0A2048';u.style.color='white';u.textContent=q;chat.appendChild(u);
+ document.getElementById('searchInput').value='';
+ const thinking=document.createElement('div');thinking.className='msg-bot';thinking.textContent='Thinking...';chat.appendChild(thinking);chat.scrollTop=chat.scrollHeight;
+ const res=await fetch('/chat_ollama/'+encodeURIComponent(q));const j=await res.json();thinking.remove();
+ const b=document.createElement('div');b.className='msg-bot';b.innerHTML=markdownToHTML(j.response);chat.appendChild(b);chat.scrollTop=chat.scrollHeight;
 }
-
-// -------------------------------------------
-// Rotating FAQ Tile Logic
-// -------------------------------------------
-const faqs=[
-  "Which block type had the highest backlog last quarter?",
-  "Which customers have the most open blocked orders?",
-  "How many orders have multiple active blocks?",
-  "What is the trend of delivery blocks across quarters?",
-  "Which blocks contribute the most to total backlog value?"
-];
+const faqs=[PLACEHOLDER_FAQS];
 let faqIndex=0;
-function rotateFAQ(){
-  const faqText=document.getElementById('faqText');
-  if(!faqText)return;
-  faqText.textContent=faqs[faqIndex];
-  faqIndex=(faqIndex+1)%faqs.length;
-}
-setInterval(rotateFAQ,5000); // Change every 5 seconds
-rotateFAQ();
-function autoAskFAQ(){
-  const q=document.getElementById('faqText').textContent;
-  document.getElementById('searchInput').value=q;
-  sendChat();
-}
+function rotateFAQ(){const faqText=document.getElementById('faqText');if(!faqText)return;faqText.textContent=faqs[faqIndex];faqIndex=(faqIndex+1)%faqs.length;}
+setInterval(rotateFAQ,5000);rotateFAQ();
+function autoAskFAQ(){const q=document.getElementById('faqText').textContent;document.getElementById('searchInput').value=q;sendChat();}
 </script>
 </body>
 </html>
 """
 
-
-@app.route("/")
-def home(): return render_template_string(HTML)
 # -----------------------------------------------------
-# Download Endpoints (CSV export)
+# Dynamic injection of top FAQs
 # -----------------------------------------------------
-from flask import Response
+@app.route("/")
+def home():
+    faqs = get_top_faqs()
+    faq_js_array = "[" + ",".join([f'"{f}"' for f in faqs]) + "]"
+    html_with_faqs = HTML.replace("const faqs=[PLACEHOLDER_FAQS];", f"const faqs={faq_js_array};")
+    return render_template_string(html_with_faqs)
 
+# -----------------------------------------------------
+# CSV Download Endpoints
+# -----------------------------------------------------
 def df_to_csv_response(dataframe, filename):
-    """Convert a DataFrame to downloadable CSV response."""
     csv_data = dataframe.to_csv(index=False)
-    return Response(
-        csv_data,
-        mimetype="text/csv",
-        headers={"Content-Disposition": f"attachment;filename={filename}.csv"}
-    )
+    return Response(csv_data, mimetype="text/csv", headers={"Content-Disposition": f"attachment;filename={filename}.csv"})
 
 @app.route("/download/summary")
 def download_summary():
     bs = block_summary_df()
     if bs.empty:
-        return jsonify({"error": "No data available"}), 404
+        return jsonify({"error": "No data"}), 404
     return df_to_csv_response(bs, "block_summary")
 
 @app.route("/download/focus")
 def download_focus():
     top2, _ = actionable_focus_df()
     if top2.empty:
-        return jsonify({"error": "No data available"}), 404
+        return jsonify({"error": "No data"}), 404
     return df_to_csv_response(top2, "actionable_focus")
 
 @app.route("/download/multiple")
 def download_multiple():
     mb = multiple_block_df()
     if mb.empty:
-        return jsonify({"error": "No data available"}), 404
+        return jsonify({"error": "No data"}), 404
     return df_to_csv_response(mb, "multiple_blocks")
 
 @app.route("/download/quarter")
 def download_quarter():
     qdf = quarter_trends_df()
     if qdf.empty:
-        return jsonify({"error": "No data available"}), 404
+        return jsonify({"error": "No data"}), 404
     return df_to_csv_response(qdf, "quarter_trends")
 
 if __name__ == "__main__":
     app.run(host="0.0.0.0", port=7860)
-