File size: 4,677 Bytes
6a477c5
 
 
 
 
71978cc
6a477c5
 
4be2e38
6a477c5
 
 
540f4a3
6a477c5
4be2e38
6a477c5
 
 
 
 
 
 
 
 
 
 
 
 
 
71978cc
567f5b5
6a477c5
a2f1a4d
6a477c5
 
 
4be2e38
427c1b1
 
 
6a477c5
 
 
 
567f5b5
71978cc
427c1b1
 
 
 
 
 
 
 
567f5b5
427c1b1
 
 
567f5b5
427c1b1
 
 
 
 
 
 
 
567f5b5
427c1b1
 
 
 
a2f1a4d
6a477c5
427c1b1
 
 
540f4a3
427c1b1
 
 
 
 
 
 
 
 
 
567f5b5
427c1b1
 
 
567f5b5
427c1b1
567f5b5
427c1b1
 
 
 
 
 
567f5b5
427c1b1
 
 
 
 
 
 
6a477c5
 
427c1b1
b265fec
6a477c5
 
567f5b5
427c1b1
6a477c5
427c1b1
567f5b5
a2f1a4d
6a477c5
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
from flask import Flask, render_template, request, jsonify
from simple_salesforce import Salesforce
from dotenv import load_dotenv
import os
import logging

# Load environment variables from .env file
load_dotenv()

# Set up logging
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)

app = Flask(__name__, template_folder='templates', static_folder='static')

# Function to get Salesforce connection
def get_salesforce_connection():
    try:
        sf = Salesforce(
            username=os.getenv('SFDC_USERNAME'),
            password=os.getenv('SFDC_PASSWORD'),
            security_token=os.getenv('SFDC_SECURITY_TOKEN'),
            domain=os.getenv('SFDC_DOMAIN', 'login')
        )
        logger.info("Successfully connected to Salesforce")
        return sf
    except Exception as e:
        logger.error(f"Error connecting to Salesforce: {e}")
        return None

# Initialize Salesforce connection globally
sf = get_salesforce_connection()

@app.route('/')
def index():
    return render_template('index.html')

# Fetch all menu items (names and images) from Salesforce
@app.route('/get_menu_items', methods=['GET'])
def get_menu_items():
    global sf
    if not sf:
        sf = get_salesforce_connection()
        if not sf:
            return jsonify({"error": "Unable to connect to Salesforce"}), 500

    try:
        soql = "SELECT Name, Image_URL__c FROM Sector_Detail__c LIMIT 200"
        logger.info(f"Executing SOQL query: {soql}")
        result = sf.query(soql)
        menu_items = [
            {"name": record['Name'], "image_url": record.get('Image_URL__c', '')}
            for record in result['records'] if 'Name' in record
        ]
        logger.info(f"Fetched {len(menu_items)} menu items")
        return jsonify({"menu_items": menu_items})
    except Exception as e:
        logger.error(f"Failed to fetch menu items: {str(e)}")
        return jsonify({"error": "Failed to fetch menu items from Salesforce"}), 500

# Fetch details (description and ingredients) for a specific menu item
@app.route('/get_item_details', methods=['POST'])
def get_item_details():
    global sf
    if not sf:
        sf = get_salesforce_connection()
        if not sf:
            return jsonify({"error": "Unable to connect to Salesforce"}), 500

    item_name = request.json.get('item_name', '').strip()
    if not item_name:
        return jsonify({"error": "Item name is required"}), 400

    try:
        soql = f"SELECT Name, Description__c, Ingredients__c, Image_URL__c FROM Sector_Detail__c WHERE Name = '{item_name}' LIMIT 1"
        logger.info(f"Executing SOQL query: {soql}")
        result = sf.query(soql)

        if result['totalSize'] == 0:
            return jsonify({"error": f"No item found with name '{item_name}'"}), 404

        record = result['records'][0]
        item_details = {
            "name": record.get('Name', ''),
            "description": record.get('Description__c', 'No description available'),
            "ingredients": record.get('Ingredients__c', 'No ingredients listed'),
            "image_url": record.get('Image_URL__c', '')
        }
        logger.info(f"Fetched details for {item_name}")
        return jsonify({"item_details": item_details})
    except Exception as e:
        logger.error(f"Failed to fetch item details: {str(e)}")
        return jsonify({"error": "Failed to fetch item details from Salesforce"}), 500

# Suggest suitable items based on user input
@app.route('/suggest_items', methods=['POST'])
def suggest_items():
    global sf
    if not sf:
        sf = get_salesforce_connection()
        if not sf:
            return jsonify({"error": "Unable to connect to Salesforce"}), 500

    search_term = request.json.get('search_term', '').strip().lower()
    if not search_term:
        return jsonify({"error": "Search term is required"}), 400

    try:
        soql = f"SELECT Name, Image_URL__c FROM Sector_Detail__c WHERE Name LIKE '%{search_term}%' OR Ingredients__c LIKE '%{search_term}%' LIMIT 10"
        logger.info(f"Executing SOQL query: {soql}")
        result = sf.query(soql)
        suggestions = [
            {"name": record['Name'], "image_url": record.get('Image_URL__c', '')}
            for record in result['records'] if 'Name' in record
        ]
        logger.info(f"Fetched {len(suggestions)} suggestions for '{search_term}'")
        return jsonify({"suggestions": suggestions})
    except Exception as e:
        logger.error(f"Failed to fetch suggestions: {str(e)}")
        return jsonify({"error": "Failed to fetch suggestions from Salesforce"}), 500

if __name__ == '__main__':
    app.run(debug=True, host='0.0.0.0', port=7860)