{
  "name": "AI邮件自动处理",
  "nodes": [
    {
      "name": "Gmail触发器",
      "type": "n8n-nodes-base.gmailTrigger",
      "parameters": {
        "pollTimes": {"item": [{"mode": "everyMinute"}]},
        "filters": {"includeSpamTrash": false}
      }
    },
    {
      "name": "AI意图分类",
      "type": "n8n-nodes-base.httpRequest",
      "parameters": {
        "url": "https://dashscope.aliyuncs.com/api/v1/services/aigc/text-generation/generation",
        "method": "POST",
        "body": {
          "model": "qwen-max",
          "input": {
            "messages": [
              {
                "role": "system",
                "content": "你是一个邮件分类专家。将邮件分为以下类别：inquiry(询价), complaint(投诉), cooperation(合作), spam(垃圾), other(其他)。只输出类别名称。"
              },
              {
                "role": "user", 
                "content": "{{$json.text}}"
              }
            ]
          }
        }
      }
    },
    {
      "name": "分类路由",
      "type": "n8n-nodes-base.switch",
      "parameters": {
        "rules": [
          {"value": "inquiry", "output": 0},
          {"value": "complaint", "output": 1},
          {"value": "cooperation", "output": 2},
          {"value": "spam", "output": 3}
        ]
      }
    },
    {
      "name": "AI生成询价回复",
      "type": "n8n-nodes-base.httpRequest",
      "parameters": {
        "url": "https://dashscope.aliyuncs.com/api/v1/services/aigc/text-generation/generation",
        "method": "POST",
        "body": {
          "model": "qwen-max",
          "input": {
            "messages": [
              {
                "role": "system",
                "content": "你是公司的商务助理，请根据客户的询价邮件生成专业的回复。包含：1.感谢询价 2.产品简介 3.报价范围 4.邀请进一步沟通。语气专业友好。"
              },
              {
                "role": "user",
                "content": "客户邮件：{{$json.text}}"
              }
            ]
          }
        }
      }
    },
    {
      "name": "发送回复",
      "type": "n8n-nodes-base.gmail",
      "parameters": {
        "operation": "reply",
        "messageId": "{{$json.id}}",
        "message": "{{$json.reply}}"
      }
    },
    {
      "name": "记录到飞书表格",
      "type": "n8n-nodes-base.httpRequest",
      "parameters": {
        "url": "https://open.feishu.cn/open-apis/sheets/v2/spreadsheets/{spreadsheet_token}/values_append",
        "method": "POST",
        "body": {
          "values": [["{{$json.from}}", "{{$json.subject}}", "{{$json.category}}", "{{$json.timestamp}}"]]
        }
      }
    }
  ]
}

# 邮件分类Prompt
CLASSIFICATION_PROMPT = """
你是一个专业的邮件分类系统。请分析以下邮件内容，判断其类别和紧急程度。

邮件内容：
{email_content}

请输出JSON格式：
{{
    "category": "inquiry/complaint/cooperation/spam/other",
    "urgency": "high/medium/low",
    "sentiment": "positive/neutral/negative",
    "key_info": "提取的关键信息（公司名、需求、联系方式等）",
    "suggested_action": "建议的处理方式"
}}
"""

# 自动回复Prompt
AUTO_REPLY_PROMPT = """
你是{company_name}的商务助理{assistant_name}。
请根据客户邮件生成专业回复。

公司信息：
- 主营业务：{business}
- 产品线：{products}
- 报价范围：{price_range}

客户邮件：{email_content}

回复要求：
1. 称呼使用客户姓名（如果能识别）
2. 感谢客户的关注/询价
3. 针对性回答客户问题
4. 提供下一步行动建议
5. 签名使用：{signature}
6. 语气：专业、友好、不卑不亢
"""

class CustomerAnalyticsAutomation:
    def __init__(self, db_config, ai_config):
        self.db = DatabaseConnector(db_config)
        self.ai = AIClient(ai_config)
    
    def generate_weekly_report(self):
        """自动生成周报"""
        # 1. 提取数据
        active_users = self.db.query("SELECT * FROM user_events WHERE date > NOW() - INTERVAL '7 days'")
        churning_users = self.identify_churn_risk()
        upgrade_candidates = self.identify_upgrade_potential()
        
        # 2. AI分析
        analysis = self.ai.analyze({
            "prompt": f"""
            分析以下SaaS产品的周度数据，生成管理层报告：
            
            活跃用户数据：{active_users.summary()}
            流失风险用户：{churning_users}
            升级潜力用户：{upgrade_candidates}
            
            报告要求：
            1. 核心指标概览（DAU/WAU/MAU、留存率、NRR）
            2. 本周亮点（增长点）
            3. 风险预警（流失风险用户及原因分析）
            4. 增长机会（可升级用户及推荐策略）
            5. 下周行动建议（具体到人和时间）
            
            格式：Markdown，包含数据表格和趋势描述。
            """
        })
        
        # 3. 生成可视化图表
        charts = self.generate_charts(active_users)
        
        # 4. 发送报告
        self.send_report(analysis, charts)
    
    def identify_churn_risk(self):
        """AI识别流失风险用户"""
        users = self.db.query("""
            SELECT user_id, last_login, login_frequency, feature_usage
            FROM user_metrics
            WHERE login_frequency < 0.3 AND last_login < NOW() - INTERVAL '5 days'
        """)
        
        prompt = f"""
        分析以下用户数据，识别高流失风险用户并给出挽留建议：
        {users.to_json()}
        
        对每个高风险用户，输出：
        1. 流失概率（0-100%）
        2. 可能原因
        3. 推荐挽留策略
        """
        
        return self.ai.analyze({"prompt": prompt})

【淘宝新订单】→ 提取订单信息 → AI智能匹配SKU
                                    ↓
【拼多多新订单】→ 提取订单信息 → 统一格式化
                                    ↓
【抖音新订单】→ 提取订单信息 → 写入ERP系统
                                    ↓
                              自动生成发货单
                                    ↓
                              通知仓库发货
                                    ↓
                              更新各平台物流信息

报价 = 基础工时费 × 工时 + 复杂度系数 × 基础费
     + AI API成本 × 12个月 + 维护费

示例：
- 简单邮件自动化：500元/时 × 8小时 + 1.2 × 2000 = 6400元
- 复杂AI工作流：800元/时 × 20小时 + 1.5 × 5000 = 23500元