| |
| import schedule |
| import time |
| import smtplib |
| from email.mime.text import MimeText |
| from email.mime.multipart import MimeMultipart |
| from datetime import datetime, timedelta |
| from analytics import Analytics |
| import os |
|
|
| class AutomationManager: |
| def __init__(self, db_manager, whatsapp_manager): |
| self.db = db_manager |
| self.whatsapp = whatsapp_manager |
| |
| def daily_payment_reminders(self): |
| """Send payment reminders for overdue payments""" |
| overdue_payments = self.db.get_pending_payments() |
| |
| for _, payment in overdue_payments.iterrows(): |
| if payment['pending_amount'] > 0: |
| customer = self.db.get_dataframe('customers', |
| f"SELECT * FROM customers WHERE customer_id = {payment['customer_id']}") |
| |
| if not customer.empty: |
| customer_data = customer.iloc[0] |
| message = f"""Hello {customer_data['name']}, |
| |
| This is a friendly reminder that your payment of ₹{payment['pending_amount']:,.2f} for invoice {payment['invoice_no']} is overdue. |
| |
| Please make the payment at your earliest convenience. |
| |
| Thank you, |
| Sales Team""" |
| |
| self.whatsapp.send_message(customer_data['mobile'], message) |
| |
| def demo_followups(self): |
| """Send follow-up messages for demos""" |
| upcoming_followups = self.db.get_dataframe('demos', ''' |
| SELECT d.*, c.name as customer_name, c.mobile, p.product_name |
| FROM demos d |
| JOIN customers c ON d.customer_id = c.customer_id |
| JOIN products p ON d.product_id = p.product_id |
| WHERE d.follow_up_date = date('now') |
| AND d.conversion_status = 'Not Converted' |
| ''') |
| |
| for _, demo in upcoming_followups.iterrows(): |
| message = f"""Hello {demo['customer_name']}, |
| |
| Following up on your demo of {demo['product_name']} on {demo['demo_date']}. |
| |
| How was your experience? Would you like to place an order or need another demo? |
| |
| Best regards, |
| Sales Team""" |
| |
| self.whatsapp.send_message(demo['mobile'], message) |
| |
| def weekly_performance_report(self): |
| """Generate and send weekly performance report""" |
| analytics = Analytics(self.db) |
| |
| sales_summary = analytics.get_sales_summary() |
| demo_stats = analytics.get_demo_conversion_rates() |
| payment_analysis = analytics.get_payment_analysis() |
| |
| report = f""" |
| 📊 WEEKLY PERFORMANCE REPORT |
| ---------------------------- |
| Total Sales: ₹{sales_summary.get('total_sales', 0):,.2f} |
| Pending Payments: ₹{sales_summary.get('pending_amount', 0):,.2f} |
| Demo Conversion Rate: {demo_stats.get('conversion_rate', 0):.1f}% |
| Total Customers: {analytics.get_customer_analysis().get('total_customers', 0)} |
| |
| Generated on: {datetime.now().strftime('%Y-%m-%d %H:%M')} |
| """ |
| |
| |
| self._save_report(report) |
| return report |
| |
| def _save_report(self, report): |
| """Save report to file""" |
| filename = f"reports/weekly_report_{datetime.now().strftime('%Y%m%d')}.txt" |
| os.makedirs('reports', exist_ok=True) |
| |
| with open(filename, 'w') as f: |
| f.write(report) |
