from flask import Flask, render_template, redirect, request, url_for from simple_salesforce import Salesforce from dotenv import load_dotenv import os # Load environment variables from .env file load_dotenv() app = Flask(__name__) # Get Salesforce credentials from environment variables SF_USERNAME = os.getenv('SF_USERNAME') SF_PASSWORD = os.getenv('SF_PASSWORD') SF_SECURITY_TOKEN = os.getenv('SF_SECURITY_TOKEN') SF_DOMAIN = os.getenv('SF_DOMAIN') # Salesforce connection try: print("Attempting Salesforce connection...") sf = Salesforce(username=SF_USERNAME, password=SF_PASSWORD, security_token=SF_SECURITY_TOKEN, domain=SF_DOMAIN) print("Salesforce connection successful!") except Exception as e: print(f"Salesforce connection failed: {e}") sf = None # Route for login page @app.route('/') def login(): print("Login route accessed") # Debug statement return render_template('login.html') # Route to process login @app.route('/auth', methods=['POST']) def auth(): print("Auth route accessed") # Debug statement email = request.form['email'] password = request.form['password'] if not sf: return "Salesforce connection failed. Please check credentials and try again." try: # Query Salesforce for user authentication query = f"SELECT Id, Reward_Points__c FROM Customer_Login__c WHERE Email__c = '{email}' AND Password__c = '{password}'" result = sf.query(query) if result['totalSize'] == 0: return "Invalid Login Details" customer = result['records'][0] reward_points = customer['Reward_Points__c'] # Redirect to rewards page return redirect(url_for('rewards', customer_id=customer['Id'], points=reward_points)) except Exception as e: return f"Error during authentication: {e}" # Route to display rewards page @app.route('/rewards/') def rewards(customer_id): print(f"Rewards route accessed for customer {customer_id}") # Debug statement try: customer = sf.Customer_Login__c.get(customer_id) points = customer['Reward_Points__c'] # Render the rewards page return render_template('rewards.html', points=points, customer_id=customer_id) except Exception as e: return f"Error fetching rewards: {e}" # Route to apply rewards @app.route('/apply_rewards', methods=['POST']) def apply_rewards(): print("Apply rewards route accessed") # Debug statement customer_id = request.form['customer_id'] bill_amount = float(request.form['bill_amount']) apply_rewards = request.form.get('apply_rewards') try: customer = sf.Customer_Login__c.get(customer_id) points = customer['Reward_Points__c'] gst = 0.18 * bill_amount if points >= 500 and apply_rewards: discount = 0.1 * bill_amount final_bill = bill_amount - discount + gst updated_points = points - 500 # Update the customer's reward points in Salesforce sf.Customer_Login__c.update(customer_id, {'Reward_Points__c': updated_points}) message = "You saved 10% on your total bill!" else: # Customers with below 500 points earn 10% of their bill amount as reward points discount = 0 earned_points = 0.1 * bill_amount final_bill = bill_amount + gst updated_points = points + earned_points # Update the customer's reward points in Salesforce sf.Customer_Login__c.update(customer_id, {'Reward_Points__c': updated_points}) message = f"You earned 10% of your bill amount ({earned_points} points) as reward points!" # Render the summary page with Dollar symbol return render_template( 'apply_rewards.html', original_bill=bill_amount, discount=discount, gst=gst, final_bill=final_bill, updated_points=updated_points, message=message ) except Exception as e: return f"Error applying rewards: {e}" if __name__ == '__main__': app.run(debug=True, host="0.0.0.0", port=7860)