pip install pandas schedule sendgrid twilio python-dotenv jinja2

import smtplib, os
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText
from dotenv import load_dotenv

load_dotenv()
EMAIL_HOST = os.getenv('EMAIL_HOST', 'smtp.gmail.com')
EMAIL_USER = os.getenv('EMAIL_USER')
EMAIL_PASS = os.getenv('EMAIL_PASS')

def send_email(to_email, subject, html_body):
    msg = MIMEMultipart('alternative')
    msg['Subject'] = subject
    msg['From'] = EMAIL_USER
    msg['To'] = to_email
    msg.attach(MIMEText(html_body, 'html'))
    with smtplib.SMTP(EMAIL_HOST, 587) as server:
        server.starttls()
        server.login(EMAIL_USER, EMAIL_PASS)
        server.sendmail(EMAIL_USER, to_email, msg.as_string())
    return True

import pandas as pd
from datetime import datetime, timedelta

def segment_customers(df):
    now = datetime.now()
    active   = df[df['last_purchase'] >= now - timedelta(days=30)]
    at_risk  = df[(df['last_purchase'] < now - timedelta(days=30)) &
                  (df['last_purchase'] >= now - timedelta(days=90))]
    dormant  = df[df['last_purchase'] < now - timedelta(days=90)]
    return {'active': active, 'at_risk': at_risk, 'dormant': dormant}

def run_segmented_campaign(filepath):
    df = pd.read_csv(filepath)
    df['last_purchase'] = pd.to_datetime(df['last_purchase'])
    segments = segment_customers(df)
    for _, c in segments['at_risk'].iterrows():
        html = '<h2>' + c['name'] + '님, 보고 싶었습니다!</h2>'
        html += '<p>특별 30% 할인 쿠폰: <b>COMEBACK30</b></p>'
        send_email(c['email'], '다시 돌아오세요! 특별 혜택이 기다립니다', html)

from twilio.rest import Client
import os

client = Client(os.getenv('TWILIO_ACCOUNT_SID'), os.getenv('TWILIO_AUTH_TOKEN'))
TWILIO_NUMBER = os.getenv('TWILIO_PHONE_NUMBER')

def send_sms(to_number, message):
    result = client.messages.create(
        body=message, from_=TWILIO_NUMBER, to=to_number
    )
    return result.sid

def send_order_confirmation_sms(order):
    msg = '[코드픽] ' + order['customer_name'] + '님, 주문 #'
    msg += str(order['order_id']) + '가 확인되었습니다. 영업일 기준 2~3일 내 배송됩니다!'
    return send_sms(order['phone'], msg)

def send_flash_sale_sms(customers, discount, end_time):
    for c in customers:
        msg = '[코드픽] ' + c['name'] + '님! 오늘 ' + end_time
        msg += '까지만 ' + str(discount) + '% 할인! 지금 바로 codepick.kr 방문!'
        send_sms(c['phone'], msg)

import schedule

class MarketingWorkflow:
    def welcome_workflow(self, new_user):
        # 즉시: 환영 이메일 발송
        send_email(new_user['email'], new_user['name'] + '님 환영합니다!',
                   '<p>코드픽에 오신 것을 환영합니다.</p>')

        # 3일 후: 첫 구매 유도 SMS
        def first_purchase_sms():
            send_sms(new_user['phone'],
                     '[코드픽] ' + new_user['name'] + '님, 첫 구매 10% 쿠폰: FIRST10')
            return schedule.CancelJob
        schedule.every(3).days.do(first_purchase_sms)

    def abandoned_cart_workflow(self, cart_data):
        user  = cart_data['user']
        items = cart_data['items']
        names = ', '.join([i['name'] for i in items[:2]])
        # 1시간 후 이메일
        send_email(user['email'], '장바구니를 잊으셨나요?',
                   '<p>' + names + ' 등이 기다리고 있습니다.</p>')
        # 24시간 후 SMS
        def cart_sms():
            send_sms(user['phone'], '[코드픽] 장바구니 재고 부족! codepick.kr/cart')
            return schedule.CancelJob
        schedule.every(24).hours.do(cart_sms)

import requests
from datetime import datetime

class CRMIntegration:
    def __init__(self, api_url, api_key):
        self.api_url = api_url
        self.headers = {'Authorization': 'Bearer ' + api_key,
                        'Content-Type': 'application/json'}

    def get_customer_profile(self, customer_id):
        return requests.get(self.api_url + '/customers/' + customer_id,
                            headers=self.headers).json()

    def update_engagement(self, customer_id, event):
        payload = {'customer_id': customer_id, 'event': event,
                   'timestamp': datetime.now().isoformat()}
        requests.post(self.api_url + '/events', json=payload, headers=self.headers)

    def get_high_value_customers(self, min_ltv):
        r = requests.get(self.api_url + '/customers',
                         params={'min_ltv': min_ltv, 'status': 'active'},
                         headers=self.headers)
        return r.json()['customers']

def calculate_campaign_metrics(campaign_id, db_conn):
    query = (
        'SELECT COUNT(*) as total_sent,'
        ' SUM(CASE WHEN opened=1 THEN 1 ELSE 0 END) as opened,'
        ' SUM(CASE WHEN clicked=1 THEN 1 ELSE 0 END) as clicked,'
        ' SUM(CASE WHEN converted=1 THEN 1 ELSE 0 END) as converted,'
        ' SUM(revenue) as total_revenue'
        ' FROM campaign_logs WHERE campaign_id = %s'
    )
    row = db_conn.execute(query, (campaign_id,)).fetchone()
    opened = row['opened'] or 0
    total  = row['total_sent'] or 1
    return {
        'open_rate':        round(opened / total * 100, 2),
        'ctr':              round(row['clicked'] / opened * 100, 2) if opened else 0,
        'conversion_rate':  round(row['converted'] / total * 100, 2),
        'total_revenue':    row['total_revenue'],
    }