移动电话录制与全渠道线索溯源系统

一、移动电话录制方案

1.1 方案对比

1.2 推荐方案：企业微信通话 + 智能录音硬件混合

1.2.1 企业微信通话（首选）

┌─────────────────────────────────────────┐
│         企业微信通话流程                  │
├─────────────────────────────────────────┤
│                                         │
│  销售发起企业微信通话                    │
│       ↓                                 │
│  客户接听（无需安装企业微信）            │
│       ↓                                 │
│  系统自动录音（云端保存）                │
│       ↓                                 │
│  通话结束 → 录音自动推送CRM             │
│       ↓                                 │
│  AI语音转文字 → 生成沟通记录            │
│       ↓                                 │
│  触发商机分析/客户洞察Agent              │
│                                         │
└─────────────────────────────────────────┘

**实现方式**：

# 企业微信通话录音配置
WECHAT_CALL_CONFIG = {
    "enable_recording": True,
    "recording_storage": "cloud",  # cloud/local
    "recording_retention": 365,  # 保留365天
    "auto_sync_crm": True,
    
    "call_types": {
        "audio_call": {  # 语音通话
            "recording": True,
            "max_duration": 7200,  # 最大2小时
            "quality": "high"
        },
        "video_call": {  # 视频通话
            "recording": True,
            "save_video": True,
            "save_audio": True
        }
    },
    
    "notification": {
        "recording_start": "本次通话将被录音，用于服务质量提升",
        "recording_end": "通话已结束，录音已保存"
    }
}

1.2.2 智能录音硬件（备用方案）

**推荐设备**：

**科大讯飞iFLYBUDS Pro功能**：

# 智能录音设备API集成
IFLYBUDS_API_CONFIG = {
    "app_id": "YOUR_APP_ID",
    "api_key": "YOUR_API_KEY",
    "api_secret": "YOUR_API_SECRET",
    
    "sync_settings": {
        "auto_sync": True,
        "sync_interval": 300,  # 5分钟同步一次
        "crm_webhook": "https://api.topcentralMall.cn/webhook/recording"
    },
    
    "recording_settings": {
        "auto_record_calls": True,  # 自动录音通话
        "record_all_calls": True,   # 录制所有通话
        "speaker_separation": True,  # 区分说话人
        "language": "zh-CN",
        "industry": "manufacturing"  # 制造业术语优化
    }
}

# 录音数据同步到CRM
async def sync_recording_to_crm(recording_data: dict):
    """
    同步录音数据到CRM
    """
    record = {
        "record_id": f"MOBILE-{recording_data['timestamp']}-{uuid.uuid4().hex[:8]}",
        "communication_type": "mobile",
        "channel": "移动电话",
        "direction": "outbound" if recording_data['is_outgoing'] else "inbound",
        "communication_time": recording_data['timestamp'],
        "duration": recording_data['duration'],
        
        "initiated_by": recording_data['sales_person'],
        "participants": [recording_data['sales_person'], recording_data['customer_phone']],
        
        "subject": f"移动电话沟通 - {recording_data['customer_name']}",
        "content": recording_data['transcription']['text'],
        "summary": recording_data['transcription']['summary'],
        "recording_url": recording_data['audio_url'],
        
        "sentiment": recording_data['transcription']['sentiment'],
        "intent_category": recording_data['transcription']['intent'],
        "follow_up_items": recording_data['transcription']['action_items'],
        
        "source_system": "iflybuds",
        "source_record_id": recording_data['recording_id']
    }
    
    # 保存到CRM
    await save_communication_record(record)
    
    # 触发AI分析
    await trigger_ai_agents(record)
    
    return record

1.3 移动电话→CRM自动同步流程

┌─────────────────────────────────────────────────────────────┐
│              移动电话沟通 → CRM自动同步流程                  │
├─────────────────────────────────────────────────────────────┤
│                                                             │
│  方式1: 企业微信通话                                          │
│  ┌─────────┐    ┌─────────┐    ┌─────────┐    ┌────────┐ │
│  │ 发起通话 │ → │ 自动录音 │ → │ 云端保存 │ → │ 推送CRM │ │
│  └─────────┘    └─────────┘    └─────────┘    └────────┘ │
│                                                             │
│  方式2: 智能录音设备                                          │
│  ┌─────────┐    ┌─────────┐    ┌─────────┐    ┌────────┐ │
│  │ 通话中  │ → │ 硬件录音 │ → │ 实时转写 │ → │ 推送CRM │ │
│  └─────────┘    └─────────┘    └─────────┘    └────────┘ │
│                                                             │
│  方式3: 手机系统录音（手动）                                  │
│  ┌─────────┐    ┌─────────┐    ┌─────────┐    ┌────────┐ │
│  │ 手动录音 │ → │ 上传云盘 │ → │ AI转文字 │ → │ 推送CRM │ │
│  └─────────┘    └─────────┘    └─────────┘    └────────┘ │
│                                                             │
└─────────────────────────────────────────────────────────────┘

---

二、全渠道线索溯源系统

2.1 线索溯源架构

┌─────────────────────────────────────────────────────────────┐
│                    全渠道线索溯源系统                          │
├─────────────────────────────────────────────────────────────┤
│                                                             │
│  ┌─────────┐ ┌─────────┐ ┌─────────┐ ┌─────────┐        │
│  │ 官网    │ │ SEO站点 │ │ GEO站点 │ │ 小红书  │        │
│  │ 400电话 │ │ B站     │ │ 抖音    │ │ 视频号  │        │
│  │ 快手    │ │ 知乎    │ │ 微博    │ │ 公众号  │        │
│  └────┬────┘ └────┬────┘ └────┬────┘ └────┬────┘        │
│       │           │           │           │                │
│       └───────────┴───────────┴───────────┘                │
│                   │                                         │
│                   ▼                                         │
│       ┌─────────────────────┐                              │
│       │   线索溯源引擎       │                              │
│       │  • UTM参数追踪       │                              │
│       │  • 访客行为分析      │                              │
│       │  • 渠道归因模型      │                              │
│       │  • 客户旅程映射      │                              │
│       └─────────────────────┘                              │
│                   │                                         │
│                   ▼                                         │
│       ┌─────────────────────┐                              │
│       │   线索档案生成       │                              │
│       │  • 来源渠道识别      │                              │
│       │  • 兴趣偏好分析      │                              │
│       │  • 意向度评分        │                              │
│       │  • 初始标签          │                              │
│       └─────────────────────┘                              │
│                                                             │
└─────────────────────────────────────────────────────────────┘

2.2 渠道溯源编码体系

# 全渠道线索溯源编码
LEAD_SOURCE_CODING = {
    # 官方网站
    "OFFICIAL": {
        "code": "OFFICIAL",
        "name": "官方网站",
        "url": "www.topcentralMall.cn",
        "sub_sources": {
            "OFFICIAL-HOME": "首页",
            "OFFICIAL-PRODUCT": "产品页",
            "OFFICIAL-ABOUT": "关于我们",
            "OFFICIAL-CONTACT": "联系页面",
            "OFFICIAL-BLOG": "博客文章",
            "OFFICIAL-CASE": "客户案例",
            "OFFICIAL-DOWNLOAD": "资料下载"
        }
    },
    
    # SEO独立站
    "SEO-SEOTOP": {
        "code": "SEO-SEOTOP",
        "name": "SEO英文站",
        "url": "seotopcentral.com",
        "sub_sources": {
            "SEO-SEOTOP-BLOG": "英文博客",
            "SEO-SEOTOP-LANDING": "着陆页",
            "SEO-SEOTOP-PRODUCT": "产品页"
        }
    },
    "SEO-ITOP": {
        "code": "SEO-ITOP",
        "name": "SEO中文站",
        "url": "itopcentral.cc",
        "sub_sources": {
            "SEO-ITOP-BLOG": "中文博客",
            "SEO-ITOP-LANDING": "着陆页"
        }
    },
    
    # GEO独立站
    "GEO-CN": {
        "code": "GEO-CN",
        "name": "GEO中国站",
        "url": "topcentral.vip",
        "sub_sources": {
            "GEO-CN-ARTICLE": "AIGC文章",
            "GEO-CN-LANDING": "着陆页"
        }
    },
    "GEO-OVERSEAS": {
        "code": "GEO-OVERSEAS",
        "name": "GEO海外站",
        "url": "topcentralgeo.com",
        "sub_sources": {
            "GEO-OVERSEAS-ARTICLE": "AIGC文章",
            "GEO-OVERSEAS-LANDING": "着陆页"
        }
    },
    
    # 社交媒体
    "XIAOHONGSHU": {
        "code": "XIAOHONGSHU",
        "name": "小红书",
        "sub_sources": {
            "XIAOHONGSHU-NOTE": "笔记",
            "XIAOHONGSHU-LIVE": "直播",
            "XIAOHONGSHU-AD": "广告"
        }
    },
    "BILIBILI": {
        "code": "BILIBILI",
        "name": "B站",
        "sub_sources": {
            "BILIBILI-VIDEO": "视频",
            "BILIBILI-LIVE": "直播",
            "BILIBILI-ARTICLE": "专栏"
        }
    },
    "DOUYIN": {
        "code": "DOUYIN",
        "name": "抖音",
        "sub_sources": {
            "DOUYIN-VIDEO": "短视频",
            "DOUYIN-LIVE": "直播",
            "DOUYIN-AD": "信息流广告"
        }
    },
    "KUAISHOU": {
        "code": "KUAISHOU",
        "name": "快手",
        "sub_sources": {
            "KUAISHOU-VIDEO": "短视频",
            "KUAISHOU-LIVE": "直播"
        }
    },
    "WECHAT-VIDEO": {
        "code": "WECHAT-VIDEO",
        "name": "微信视频号",
        "sub_sources": {
            "WECHAT-VIDEO-VIDEO": "短视频",
            "WECHAT-VIDEO-LIVE": "直播"
        }
    },
    "WECHAT-MP": {
        "code": "WECHAT-MP",
        "name": "微信公众号",
        "sub_sources": {
            "WECHAT-MP-ARTICLE": "文章",
            "WECHAT-MP-MENU": "菜单点击",
            "WECHAT-MP-AD": "广告"
        }
    },
    "ZHihu": {
        "code": "ZHIHU",
        "name": "知乎",
        "sub_sources": {
            "ZHIHU-ANSWER": "回答",
            "ZHIHU-ARTICLE": "文章",
            "ZHIHU-LIVE": "Live"
        }
    },
    "WEIBO": {
        "code": "WEIBO",
        "name": "微博",
        "sub_sources": {
            "WEIBO-POST": "博文",
            "WEIBO-AD": "广告"
        }
    }
}

2.3 UTM参数追踪系统

# UTM参数追踪配置
UTM_TRACKING_CONFIG = {
    "parameters": {
        "utm_source": "来源平台",      # xiaohongshu, douyin, baidu
        "utm_medium": "媒介类型",      # social, organic, cpc, email
        "utm_campaign": "活动名称",    # summer2024, newproduct
        "utm_content": "内容标识",     # video1, banner2
        "utm_term": "关键词",          # PCR-ABS, 再生塑料
        
        # 自定义参数
        "utm_channel": "渠道编码",     # XIAOHONGSHU-NOTE
        "utm_creator": "创作者ID",     # KOL001
        "utm_landpage": "着陆页",      # product-abs
        "utm_content_id": "内容ID"     # 笔记ID/视频ID
    },
    
    "tracking_rules": {
        "xiaohongshu": {
            "utm_source": "xiaohongshu",
            "utm_medium": "social",
            "custom_params": ["note_id", "creator_id"]
        },
        "douyin": {
            "utm_source": "douyin",
            "utm_medium": "social",
            "custom_params": ["video_id", "creator_id"]
        },
        "baidu": {
            "utm_source": "baidu",
            "utm_medium": "cpc",
            "custom_params": ["keyword", "ad_group"]
        }
    }
}

# 生成带UTM参数的链接
def generate_tracking_url(base_url: str, source: str, content_id: str = None) -> str:
    """
    生成带追踪参数的URL
    """
    params = {
        "utm_source": source,
        "utm_medium": UTM_TRACKING_CONFIG["tracking_rules"][source]["utm_medium"],
        "utm_campaign": datetime.now().strftime("%Y%m"),
        "utm_content": content_id or "default",
        "utm_channel": source.upper()
    }
    
    query_string = urllib.parse.urlencode(params)
    return f"{base_url}?{query_string}"

# 示例
# https://www.topcentralMall.cn/product/pcr-abs?utm_source=xiaohongshu&utm_medium=social&utm_campaign=202406&utm_content=note123&utm_channel=XIAOHONGSHU

2.4 访客行为追踪

// 网站访客追踪代码
(function() {
    // 初始化追踪
    window.TopcentralTracker = {
        init: function(config) {
            this.config = config;
            this.sessionId = this.generateSessionId();
            this.visitorId = this.getVisitorId();
            this.startTime = new Date();
            
            // 追踪页面浏览
            this.trackPageView();
            
            // 追踪点击
            this.trackClicks();
            
            // 追踪表单
            this.trackForms();
            
            // 追踪滚动深度
            this.trackScrollDepth();
            
            // 追踪停留时间
            this.trackDwellTime();
        },
        
        // 生成会话ID
        generateSessionId: function() {
            return 'sess_' + Date.now() + '_' + Math.random().toString(36).substr(2, 9);
        },
        
        // 获取访客ID（基于Cookie）
        getVisitorId: function() {
            let visitorId = this.getCookie('topcentral_visitor_id');
            if (!visitorId) {
                visitorId = 'visitor_' + Date.now() + '_' + Math.random().toString(36).substr(2, 9);
                this.setCookie('topcentral_visitor_id', visitorId, 365);
            }
            return visitorId;
        },
        
        // 追踪页面浏览
        trackPageView: function() {
            this.sendEvent('pageview', {
                url: window.location.href,
                title: document.title,
                referrer: document.referrer,
                utm_params: this.getUtmParams(),
                timestamp: new Date().toISOString()
            });
        },
        
        // 追踪点击
        trackClicks: function() {
            document.addEventListener('click', function(e) {
                const element = e.target.closest('[data-track]');
                if (element) {
                    TopcentralTracker.sendEvent('click', {
                        element: element.dataset.track,
                        text: element.innerText,
                        url: element.href || null,
                        position: {
                            x: e.clientX,
                            y: e.clientY
                        }
                    });
                }
            });
        },
        
        // 追踪表单
        trackForms: function() {
            document.querySelectorAll('form').forEach(form => {
                form.addEventListener('submit', function(e) {
                    TopcentralTracker.sendEvent('form_submit', {
                        form_id: form.id,
                        form_action: form.action,
                        fields: Array.from(form.elements).map(el => ({
                            name: el.name,
                            type: el.type,
                            filled: !!el.value
                        }))
                    });
                });
            });
        },
        
        // 追踪滚动深度
        trackScrollDepth: function() {
            let maxScroll = 0;
            window.addEventListener('scroll', function() {
                const scrollPercent = Math.round((window.scrollY / (document.body.scrollHeight - window.innerHeight)) * 100);
                if (scrollPercent > maxScroll) {
                    maxScroll = scrollPercent;
                    if (maxScroll % 25 === 0) {  // 25%, 50%, 75%, 100%
                        TopcentralTracker.sendEvent('scroll_depth', {
                            depth: maxScroll
                        });
                    }
                }
            });
        },
        
        // 追踪停留时间
        trackDwellTime: function() {
            setInterval(function() {
                const dwellTime = Math.round((new Date() - TopcentralTracker.startTime) / 1000);
                if (dwellTime % 30 === 0) {  // 每30秒发送一次
                    TopcentralTracker.sendEvent('dwell_time', {
                        seconds: dwellTime
                    });
                }
            }, 30000);
        },
        
        // 获取UTM参数
        getUtmParams: function() {
            const params = new URLSearchParams(window.location.search);
            const utm = {};
            ['utm_source', 'utm_medium', 'utm_campaign', 'utm_content', 'utm_term', 'utm_channel'].forEach(key => {
                if (params.has(key)) {
                    utm[key] = params.get(key);
                }
            });
            return utm;
        },
        
        // 发送事件
        sendEvent: function(eventType, data) {
            const payload = {
                event: eventType,
                session_id: this.sessionId,
                visitor_id: this.visitorId,
                timestamp: new Date().toISOString(),
                data: data
            };
            
            // 发送到追踪服务器
            fetch(this.config.trackingEndpoint, {
                method: 'POST',
                headers: {
                    'Content-Type': 'application/json'
                },
                body: JSON.stringify(payload)
            }).catch(err => console.error('Tracking error:', err));
        },
        
        // Cookie操作
        setCookie: function(name, value, days) {
            const expires = new Date(Date.now() + days * 864e5).toUTCString();
            document.cookie = name + '=' + encodeURIComponent(value) + '; expires=' + expires + '; path=/; domain=.topcentralMall.cn';
        },
        
        getCookie: function(name) {
            return document.cookie.split('; ').reduce((r, v) => {
                const parts = v.split('=');
                return parts[0] === name ? decodeURIComponent(parts[1]) : r;
            }, '');
        }
    };
    
    // 自动初始化
    window.TopcentralTracker.init({
        trackingEndpoint: 'https://api.topcentralMall.cn/tracking/event'
    });
})();

2.5 线索评分模型

# 线索评分模型
LEAD_SCORING_MODEL = {
    # 渠道权重
    "channel_weights": {
        "OFFICIAL": 1.0,        # 官网直接访问 - 高意向
        "SEO-SEOTOP": 0.8,      # SEO英文站 - 中高意向
        "SEO-ITOP": 0.8,        # SEO中文站 - 中高意向
        "GEO-CN": 0.7,          # GEO中国站 - 中意向
        "GEO-OVERSEAS": 0.7,    # GEO海外站 - 中意向
        "XIAOHONGSHU": 0.6,     # 小红书 - 中意向
        "BILIBILI": 0.5,        # B站 - 中低意向
        "DOUYIN": 0.5,          # 抖音 - 中低意向
        "KUAISHOU": 0.4,        # 快手 - 低意向
        "WECHAT-VIDEO": 0.6,    # 视频号 - 中意向
        "WECHAT-MP": 0.7,       # 公众号 - 中高意向
        "ZHIHU": 0.6,           # 知乎 - 中意向
        "WEIBO": 0.4,           # 微博 - 低意向
        "400-PHONE": 1.0,       # 400电话 - 高意向
        "WECHAT-WORK": 0.9,     # 企业微信 - 高意向
        "EMAIL": 0.8,           # 邮件 - 中高意向
        "EXHIBITION": 0.9,      # 展会 - 高意向
        "REFERRAL": 1.0         # 转介绍 - 最高意向
    },
    
    # 行为评分
    "behavior_scores": {
        "pageview": 1,          # 页面浏览
        "product_view": 5,      # 产品页浏览
        "download": 10,         # 资料下载
        "form_start": 5,        # 开始填写表单
        "form_submit": 20,      # 提交表单
        "phone_click": 15,      # 点击电话
        "chat_start": 10,       # 开始咨询
        "video_watch": 3,       # 观看视频（每分钟）
        "scroll_75": 5,         # 滚动到75%
        "return_visit": 10,     # 回访
        "multiple_pages": 2     # 浏览多页面（每页）
    },
    
    # 评分等级
    "score_levels": {
        "hot": {"min": 80, "label": "热门线索", "priority": "立即跟进"},
        "warm": {"min": 50, "label": "温线索", "priority": "24小时内跟进"},
        "cold": {"min": 20, "label": "冷线索", "priority": "3天内跟进"},
        "nurture": {"min": 0, "label": "培育中", "priority": "持续培育"}
    }
}

# 计算线索评分
def calculate_lead_score(lead_data: dict) -> dict:
    """
    计算线索评分
    """
    score = 0
    details = []
    
    # 1. 渠道得分
    channel = lead_data.get("source_code", "UNKNOWN")
    channel_weight = LEAD_SCORING_MODEL["channel_weights"].get(channel, 0.3)
    channel_score = channel_weight * 30  # 渠道权重最高30分
    score += channel_score
    details.append(f"渠道得分: {channel_score:.1f} (权重: {channel_weight})")
    
    # 2. 行为得分
    behaviors = lead_data.get("behaviors", [])
    behavior_score = 0
    for behavior in behaviors:
        action = behavior["action"]
        value = LEAD_SCORING_MODEL["behavior_scores"].get(action, 1)
        behavior_score += value
    behavior_score = min(behavior_score, 40)  # 行为得分最高40分
    score += behavior_score
    details.append(f"行为得分: {behavior_score:.1f}")
    
    # 3. 信息完整度得分
    info_score = 0
    if lead_data.get("company_name"): info_score += 5
    if lead_data.get("contact_name"): info_score += 5
    if lead_data.get("phone"): info_score += 5
    if lead_data.get("email"): info_score += 5
    if lead_data.get("industry"): info_score += 5
    if lead_data.get("product_interest"): info_score += 5
    score += info_score
    details.append(f"信息完整度: {info_score:.1f}")
    
    # 4. 时间衰减（越新的线索分数越高）
    age_days = (datetime.now() - lead_data.get("created_at", datetime.now())).days
    time_decay = max(0, 10 - age_days)  # 10天内最高10分
    score += time_decay
    details.append(f"时效得分: {time_decay:.1f}")
    
    # 5. 确定等级
    level = "nurture"
    for lvl, config in LEAD_SCORING_MODEL["score_levels"].items():
        if score >= config["min"]:
            level = lvl
            break
    
    return {
        "total_score": round(score, 1),
        "max_score": 100,
        "level": level,
        "level_label": LEAD_SCORING_MODEL["score_levels"][level]["label"],
        "priority": LEAD_SCORING_MODEL["score_levels"][level]["priority"],
        "details": details,
        "recommendation": generate_recommendation(level, lead_data)
    }

---

三、客户情感共鸣AI Agent

3.1 A17 客户情感共鸣Agent

# A17 客户情感共鸣Agent
A17_PROMPT = """
你是TopcentralMall的客户情感共鸣专家。你的任务是通过分析客户沟通记录，
发现客户的情感需求、痛点、期望，并生成能够引起客户共鸣的内容和行动建议。

## 核心能力
1. 客户情感分析：识别客户的情绪状态、压力点、期望
2. 共情点发现：找到与客户产生情感共鸣的切入点
3. 个性化沟通：生成能够打动客户的沟通内容
4. 关系深化：建议能够增进客户关系的行为
5. 危机预警：识别可能导致关系破裂的情感信号

## 分析维度

### 1. 客户情感状态
- 当前情绪：焦虑/满意/兴奋/失望/愤怒/平静
- 压力来源：价格/质量/交期/竞争/内部压力
- 期望状态：希望获得什么/担心什么
- 情感需求：被理解/被重视/被支持/安全感

### 2. 客户个性特征
- 沟通风格：直接/委婉/详细/简洁
- 决策风格：理性/感性/谨慎/果断
- 价值观：价格优先/质量优先/服务优先/创新优先
- 人际偏好：正式/随意/专业/友好

### 3. 共情机会点
- 共同挑战：行业痛点、市场压力
- 共同目标：可持续发展、绿色制造
- 共同价值：品质追求、长期合作
- 共同经历：类似项目经验、行业变迁

### 4. 关系深化建议
- 情感连接：如何让客户感到被理解和重视
- 信任建设：如何通过行动建立信任
- 价值共鸣：如何与客户在价值观上产生共鸣
- 长期关系：如何维护长期合作关系

## 输出格式（JSON）
{
    "emotional_analysis": {
        "current_mood": "焦虑",
        "mood_score": -0.3,
        "stress_sources": ["价格波动", "交期压力"],
        "emotional_needs": ["价格稳定", "供应保障"],
        "satisfaction_level": 6.5
    },
    
    "personality_profile": {
        "communication_style": "直接务实",
        "decision_style": "理性谨慎",
        "value_priority": ["质量", "交期", "价格"],
        "relationship_preference": "专业但友好"
    },
    
    "empathy_opportunities": [
        {
            "type": "共同挑战",
            "description": "都面临原材料价格波动压力",
            "suggested_message": "理解今年原材料价格波动给您带来的压力，我们也面临同样的挑战。我们开发了价格锁定机制，可以帮助您稳定成本。"
        },
        {
            "type": "共同价值",
            "description": "都重视绿色可持续发展",
            "suggested_message": "看到贵司也在推进碳中和目标，我们的PCR材料正好可以帮助您实现这一目标，同时降低成本。"
        }
    ],
    
    "relationship_deepening": {
        "immediate_actions": [
            "发送行业价格趋势报告，帮助客户了解市场",
            "提供3个月价格锁定方案，消除客户焦虑",
            "邀请参加我们的绿色制造研讨会"
        ],
        "long_term_strategy": [
            "建立季度业务回顾机制",
            "联合开发定制化材料",
            "邀请成为战略合作伙伴"
        ]
    },
    
    "personalized_communication": {
        "tone": "理解、支持、专业",
        "key_messages": [
            "我们理解您的压力",
            "我们有解决方案",
            "我们与您同在"
        ],
        "avoid_topics": ["过度推销", "贬低竞争对手"],
        "suggested_gifts": "行业白皮书 + 定制样品"
    },
    
    "crisis_signals": [
        {
            "signal": "客户提到'考虑其他供应商'",
            "severity": "high",
            "recommended_response": "立即安排高管拜访，了解具体原因，提供专项解决方案"
        }
    ],
    
    "共鸣内容生成": {
        "wechat_message": "张总，看到最近原材料市场波动，理解您作为采购负责人承受的压力。我们刚推出了'价格护航计划'，可以帮您锁定Q3价格，让您安心安排生产。方便的话，我明天带上详细方案去您办公室聊聊？",
        
        "email_subject": "【价格护航计划】帮您稳定Q3原材料成本",
        
        "phone_script": "张总，我是坚锋的小李。最近看到原材料价格波动，想必您也在关注。我们专门为您这类VIP客户设计了一个价格锁定方案，可以帮您规避价格波动风险。您这周有时间吗，我带上方案去拜访您。"
    }
}
"""

3.2 客户情感共鸣系统实现

# 客户情感共鸣系统
class CustomerEmpathySystem:
    """
    客户情感共鸣系统
    """
    
    def __init__(self):
        self.ai_agent = A17_EmpathyAgent()
        self.communication_analyzer = CommunicationAnalyzer()
        self.content_generator = PersonalizedContentGenerator()
    
    async def analyze_customer_emotion(self, customer_id: str) -> dict:
        """
        分析客户情感状态
        """
        # 1. 获取客户全量沟通记录
        communications = await self.get_customer_communications(customer_id, days=30)
        
        # 2. 分析情感趋势
        emotion_trend = await self.communication_analyzer.analyze_emotion_trend(communications)
        
        # 3. 识别压力点和需求
        pain_points = await self.communication_analyzer.identify_pain_points(communications)
        
        # 4. 生成情感共鸣分析
        empathy_analysis = await self.ai_agent.analyze({
            "customer_id": customer_id,
            "communications": communications,
            "emotion_trend": emotion_trend,
            "pain_points": pain_points
        })
        
        return empathy_analysis
    
    async def generate_empathy_content(self, customer_id: str, context: str) -> dict:
        """
        生成共鸣内容
        """
        # 1. 获取客户画像
        customer_profile = await self.get_customer_profile(customer_id)
        
        # 2. 分析当前情境
        situation_analysis = await self.ai_agent.analyze_situation({
            "customer": customer_profile,
            "context": context
        })
        
        # 3. 生成个性化内容
        content = await self.content_generator.generate({
            "profile": customer_profile,
            "situation": situation_analysis,
            "tone": "empathetic",
            "goal": "build_connection"
        })
        
        return {
            "wechat_message": content["wechat"],
            "email_content": content["email"],
            "phone_script": content["phone"],
            "gift_suggestion": content["gift"]
        }
    
    async def detect_relationship_risk(self, customer_id: str) -> dict:
        """
        检测关系风险
        """
        # 1. 获取最近沟通
        recent_comm = await self.get_customer_communications(customer_id, days=7)
        
        # 2. 检测风险信号
        risk_signals = await self.communication_analyzer.detect_risk_signals(recent_comm)
        
        # 3. 评估风险等级
        risk_level = self.calculate_risk_level(risk_signals)
        
        # 4. 生成预警和应对建议
        if risk_level >= 0.7:
            return {
                "alert": True,
                "risk_level": "high",
                "risk_signals": risk_signals,
                "recommended_actions": [
                    "立即安排高管拜访",
                    "提供专项优惠方案",
                    "了解具体不满原因"
                ],
                "escalation_required": True
            }
        
        return {"alert": False, "risk_level": "low"}

3.3 情感共鸣触发场景

# 情感共鸣触发场景
EMPATHY_TRIGGER_SCENARIOS = {
    "price_concern": {
        "trigger": "客户提到价格压力或竞争对手价格更低",
        "empathy_response": "理解您的成本压力，我们也面临同样的挑战。让我们一起找到双赢的解决方案。",
        "action": "提供价格锁定方案或价值证明"
    },
    
    "delivery_pressure": {
        "trigger": "客户提到交期紧张或生产计划受影响",
        "empathy_response": "生产计划的稳定性对您的业务至关重要，我们完全理解。让我们确保您的供应安全。",
        "action": "提供库存保障或加急生产"
    },
    
    "quality_issue": {
        "trigger": "客户提到质量问题或检测不合格",
        "empathy_response": "质量是我们的生命线，任何问题都不能接受。让我们立即解决，确保不再发生。",
        "action": "立即启动质量改进流程，提供替换品"
    },
    
    "new_project": {
        "trigger": "客户提到新产品开发或新项目",
        "empathy_response": "新项目总是令人兴奋！我们很荣幸能参与您的创新之旅。",
        "action": "提供技术支持，联合开发"
    },
    
    "industry_challenge": {
        "trigger": "客户提到行业困难或市场下滑",
        "empathy_response": "行业确实面临挑战，但危机中总有机遇。让我们一起探索新的可能。",
        "action": "分享行业洞察，提供创新方案"
    },
    
    "personal_milestone": {
        "trigger": "客户生日、公司周年庆、项目成功",
        "empathy_response": "恭喜！这样的里程碑值得庆祝。感谢您让我们成为您成功的一部分。",
        "action": "发送祝贺礼品，安排庆祝活动"
    },
    
    "competition_mention": {
        "trigger": "客户提到正在评估其他供应商",
        "empathy_response": "我们欢迎公平竞争，这也激励我们做得更好。让我们展示为什么我们是最佳合作伙伴。",
        "action": "提供差异化价值证明，安排深度交流"
    }
}

---

四、实施建议

4.1 移动电话录制实施

**推荐方案**：企业微信通话 + 科大讯飞iFLYBUDS Pro

4.2 全渠道溯源实施

4.3 让客户觉得"专业+需要+急客户所急"

**实现方式**：

- 400电话 + IVR专业导航

- 企业微信统一形象

- 快速响应（2小时内回复）

- 专业术语准确使用

- 提供不可替代的技术支持

- 定制化解决方案

- 行业洞察分享

- 成为客户的"材料顾问"

- 紧急订单绿色通道

- 24小时技术支持热线

- 快速样品响应（48小时）

- 实时订单追踪

- AI情感分析客户情绪

- 记住客户偏好和历史

- 预判客户需求

- 主动提供解决方案

- 理解客户行业挑战

- 分享共同经历

- 建立情感连接

- 成为合作伙伴而非供应商

---

**文档版本**: v1.0

**日期**: 2026-06-15

**状态**: 设计方案

**审批人**: admin@topcentral.cn / 麻一明