lokesh341 commited on
Commit
3acc9f6
·
verified ·
1 Parent(s): e0741ec

Update app.py

Browse files
Files changed (1) hide show
  1. app.py +9 -12
app.py CHANGED
@@ -35,7 +35,7 @@ sf = get_salesforce_connection()
35
  def index():
36
  return render_template('index.html')
37
 
38
- # Fetch items from Sector_Detail__c with search support
39
  @app.route('/get_menu_items', methods=['POST'])
40
  def get_menu_items():
41
  global sf
@@ -45,16 +45,13 @@ def get_menu_items():
45
  logger.error("Salesforce connection failed after retry")
46
  return jsonify({"error": "Unable to connect to Salesforce"}), 500
47
 
48
- data = request.json
49
- dietary_preference = data.get('dietary_preference', 'both').lower()
50
- search_term = data.get('search_term', '').strip()
51
-
52
  try:
53
  soql = "SELECT Name, Image_URL__c, Category__c, Description__c FROM Sector_Detail__c"
54
- if search_term:
55
- soql += f" WHERE Name LIKE '%{search_term}%'"
56
- if dietary_preference in ['vegetarian', 'non-vegetarian']:
57
- soql += f"{' AND' if search_term else ' WHERE'} Category__c = '{dietary_preference.capitalize()}'"
58
  soql += " LIMIT 200"
59
 
60
  logger.info(f"Executing SOQL query: {soql}")
@@ -68,7 +65,7 @@ def get_menu_items():
68
  }
69
  for record in result['records'] if 'Name' in record
70
  ]
71
- logger.info(f"Fetched {len(items)} items from Sector_Detail__c for {dietary_preference} with search '{search_term}'")
72
  return jsonify({"menu_items": items})
73
  except Exception as e:
74
  logger.error(f"Failed to fetch items from Sector_Detail__c: {str(e)}")
@@ -218,8 +215,8 @@ def submit_items():
218
  logger.info(f"Submitting item: {item}")
219
  sf.Ingredient_Object__c.create({
220
  'Ingredient_Name__c': item['name'],
221
- 'Category__c': item.get('category', 'Unknown'),
222
- 'Description__c': item.get('description', 'No description available')
223
  })
224
  logger.info(f"Successfully submitted item to Ingredient_Object__c: {item['name']}")
225
  return jsonify({"success": f"Successfully submitted {len(items)} items to Salesforce"})
 
35
  def index():
36
  return render_template('index.html')
37
 
38
+ # Fetch items from Sector_Detail__c for dietary preferences
39
  @app.route('/get_menu_items', methods=['POST'])
40
  def get_menu_items():
41
  global sf
 
45
  logger.error("Salesforce connection failed after retry")
46
  return jsonify({"error": "Unable to connect to Salesforce"}), 500
47
 
48
+ dietary_preference = request.json.get('dietary_preference', 'both').lower()
 
 
 
49
  try:
50
  soql = "SELECT Name, Image_URL__c, Category__c, Description__c FROM Sector_Detail__c"
51
+ if dietary_preference == 'vegetarian':
52
+ soql += " WHERE Category__c = 'Veg'"
53
+ elif dietary_preference == 'non-vegetarian':
54
+ soql += " WHERE Category__c = 'Non-Veg'"
55
  soql += " LIMIT 200"
56
 
57
  logger.info(f"Executing SOQL query: {soql}")
 
65
  }
66
  for record in result['records'] if 'Name' in record
67
  ]
68
+ logger.info(f"Fetched {len(items)} items from Sector_Detail__c for {dietary_preference}")
69
  return jsonify({"menu_items": items})
70
  except Exception as e:
71
  logger.error(f"Failed to fetch items from Sector_Detail__c: {str(e)}")
 
215
  logger.info(f"Submitting item: {item}")
216
  sf.Ingredient_Object__c.create({
217
  'Ingredient_Name__c': item['name'],
218
+ 'Category__c': item.get('category', 'Unknown'), # Add Category__c
219
+ 'Description__c': item.get('description', 'No description available') # Ensure description is included
220
  })
221
  logger.info(f"Successfully submitted item to Ingredient_Object__c: {item['name']}")
222
  return jsonify({"success": f"Successfully submitted {len(items)} items to Salesforce"})