对接E云管家与Dify
编辑 | blame | 历史 | 原始文档

E云管家-DifyAI对接服务

这是一个用于将E云管家消息转发到DifyAI并返回AI回答的后端服务程序。

功能特性

  • 接收E云管家的群聊消息回调
  • 过滤和验证消息（仅处理群聊消息，忽略自己发送的消息）
  • 使用Redis队列管理用户消息，防止并发处理
  • 自动获取和保存联系人信息
  • 支持DifyAI流式和阻塞两种模式
  • 流式模式：实时接收AI回复，响应更快
  • 阻塞模式：等待完整回复后返回，更稳定
  • 将AI回答发送回群聊
  • 完整的日志记录和错误处理

系统架构

E云管家 -> 回调接口 -> Redis队列 -> 后台工作进程 -> DifyAI -> 回复消息
                                      ↓
                                   MySQL数据库

技术栈

  • 后端框架: FastAPI
  • 数据库: MySQL + SQLAlchemy
  • 缓存/队列: Redis
  • 日志: Loguru
  • 部署: Docker + Docker Compose

快速开始

1. 环境准备

确保已安装以下软件：
- Python 3.11+
- Docker & Docker Compose
- MySQL 8.0+
- Redis 7+

2. 配置环境变量

复制环境变量模板：
bash cp .env.example .env

编辑 .env 文件，配置以下参数：
```env

数据库配置

DATABASE_URL=mysql+pymysql://username:password@localhost:3306/ecloud_dify

Redis配置

REDIS_URL=redis://localhost:6379/0

E云管家配置

ECLOUD_BASE_URL=http://your-ecloud-domain.com
ECLOUD_AUTHORIZATION=your-authorization-token

DifyAI配置

DIFY_BASE_URL=https://api.dify.ai/v1
DIFY_API_KEY=your-dify-api-key
```

3. 使用Docker部署（推荐）

# 启动所有服务
docker-compose up -d

# 查看日志
docker-compose logs -f app

4. 手动部署

# 安装依赖
pip install -r requirements.txt

# 启动MySQL和Redis（或使用Docker）
docker-compose up -d mysql redis

# 初始化数据库
python app/utils/database_init.py

# 启动应用
python main.py

API接口

回调接口

POST /api/v1/callback

接收E云管家的消息回调。

请求体示例：
json { "account": "17200000000", "messageType": "80001", "wcId": "wxid_phyyedw9xap22", "data": { "content": "消息内容", "fromGroup": "25411981800@chatroom", "fromUser": "wxid_ynu1tgjz156j22", "memberCount": 8, "msgId": 1685074592, "newMsgId": 1497474118261484795, "self": false, "timestamp": 1640772092, "toUser": "wxid_phyyedw9xap22", "wId": "12491ae9-62aa-4f7a-83e6-9db4e9f28e3c" } }

健康检查

GET /api/v1/health

检查服务运行状态。

消息处理流程

  1. 消息过滤: 检查是否为群聊消息（messageType=80001）且非自己发送
  2. 入队处理: 将消息加入用户专属的Redis队列
  3. 联系人管理: 检查并获取群组联系人信息
  4. AI对话: 调用DifyAI接口获取回答
  5. 回复发送: 将AI回答发送回群聊
  6. 记录保存: 保存对话记录到数据库

数据库表结构

contacts（联系人表）

  • id: 主键
  • wc_id: 微信ID/群ID（唯一）
  • nick_name: 昵称
  • user_name: 微信用户名
  • 其他联系人信息字段...

conversations（对话记录表）

  • id: 主键
  • from_user: 发送用户微信ID
  • conversation_id: Dify对话ID
  • group: 群组ID
  • hour: 小时标识(YYYYMMDD_HH)
  • content: 对话内容(JSON格式)
  • is_processed: 是否已处理
  • is_sent: 是否已发送
  • 唯一性约束: (from_user, conversation_id, group, hour)

配置说明

主要配置项在 config.json 中：

DifyAI配置

  • dify.streaming_enabled: 是否启用流式模式（默认：false）
  • dify.streaming_timeout: 流式请求超时时间，单位秒（默认：120）
  • dify.base_url: DifyAI API地址
  • dify.api_key: DifyAI API密钥

消息处理配置

  • message_processing.max_retry_count: 最大重试次数（默认3次）
  • message_processing.retry_delay: 重试延迟（默认5秒）
  • message_processing.queue_timeout: 队列超时时间（默认300秒）

流式模式说明

启用流式模式的优势：
- 实时响应：边生成边返回，用户体验更好
- 更快感知：无需等待完整回复即可开始处理
- 连接保活：自动处理ping事件，保持连接稳定

配置示例：
json { "dify": { "streaming_enabled": true, "streaming_timeout": 180 } }

日志管理

日志文件位置：
- 应用日志: logs/app.log
- 错误日志: logs/app_error.log

日志级别可通过环境变量 LOG_LEVEL 配置。

监控和维护

查看队列状态

# 连接Redis查看队列
redis-cli
> KEYS ecloud_queue:*
> LLEN ecloud_queue:用户ID

查看处理状态

> KEYS ecloud_processing:*
> GET ecloud_processing:用户ID

故障排除

常见问题

  1. 数据库连接失败
  • 检查数据库配置和网络连接
  • 确认数据库用户权限
  1. Redis连接失败
  • 检查Redis服务状态
  • 确认Redis配置
  1. DifyAI调用失败
  • 检查API密钥是否正确
  • 确认网络连接和API配额
  1. E云管家回调失败
  • 检查回调URL配置
  • 确认服务端口开放

开发指南

项目结构

├── app/
│   ├── api/          # API接口
│   ├── models/       # 数据模型
│   ├── services/     # 业务服务
│   ├── utils/        # 工具函数
│   └── workers/      # 后台工作进程
├── logs/             # 日志文件
├── tests/            # 测试文件
├── config.py         # 配置文件
├── main.py           # 应用入口
└── requirements.txt  # 依赖包

运行测试

pytest tests/

许可证

MIT License