Update app.py

app.py

@@ -60,14 +60,13 @@ def insert_reconciliation_to_salesforce(df, sf):
     return f"Inserted {inserted_count} records into Salesforce"
 
 def generate_suggestion(row):
-    if row['Anomaly'] == -1 or abs(row['Deviation']) > 15:
-        if row['Deviation'] < -15:
-            shortage = abs(row['Planned_Quantity'] - row['Used_Quantity'])
-            return f"Shortage: Order {shortage:.0f} more units of {row['Material_Type']}."
-        elif row['Deviation'] > 15:
-            excess = row['Used_Quantity'] - row['Planned_Quantity']
-            return f"Excess: Reduce future orders by {excess:.0f} units of {row['Material_Type']}."
-    return "No action needed."
+    if row['Deviation'] > 15:
+        excess = row['Used_Quantity'] - row['Planned_Quantity']
+        return f"Overuse Alert: Reduce future orders by {excess:.0f} units of {row['Material_Type']}."
+    elif row['Deviation'] < -15:
+        surplus = abs(row['Planned_Quantity'] - row['Used_Quantity'])
+        return f"Surplus Detected: {surplus:.0f} units unused. Consider reducing future orders."
+    return "Usage as planned. No action needed."
 
 def reconcile_materials(csv_file):
     if isinstance(csv_file, str):
@@ -113,10 +112,10 @@ def reconcile_materials(csv_file):
     # Enforce anomaly for deviation beyond 15%
     df.loc[df['Deviation'].abs() > 15, 'Anomaly'] = -1
 
-    # AI Suggestions & Status
+    # AI Suggestions & Status (updated block)
     df['AI_Suggestion'] = df.apply(generate_suggestion, axis=1)
     df['Reconciliation_Status'] = df.apply(
-        lambda row: 'Flagged' if row['Anomaly'] == -1 or abs(row['Deviation']) > 15 else 'Complete',
+        lambda row: 'Flagged' if abs(row['Deviation']) > 15 else 'Complete',
         axis=1
     )