Kris
ccc7109c31
主要变更： - 新增实时同步日志统计接口，支持多维度统计（综合、对象、操作类型、状态、时间趋势） - 新增实时同步统计接口，提供服务状态、对象统计和订阅统计 - 实现实时服务手动启动管理，移除自动启动注解 - 移除所有统计相关功能（EventProcessor、DataSynchronizer统计方法） - 解决DataiIntegrationObjectServiceImpl和ObjectRegistryImpl循环依赖问题 - 完善元数据变更统计功能，支持自动时间范围和缺失数据点填充 - 修复SQL布尔值兼容性问题（true/false改为1/0） - 新增SysJobController和SysJobLogController接口文档 - 更新项目文档和变更日志 技术细节： - 添加@Lazy注解解决循环依赖 - 实现时间趋势统计的自动时间范围处理 - 支持多种时间单位（天、周、月、季度）的趋势分析 - 优化同步成功率计算和数据处理完整性 - 遵循项目文档规范，更新唯一真源
2.7 KiB
2.7 KiB
启动事件订阅
接口概述
启动 Salesforce Pub/Sub 事件订阅服务，开始接收来自 Salesforce 的实时变更事件。
接口详情
- 接口名称: 启动事件订阅
- 接口路径:
/integration/realtime/service/start/subscriber - 请求方法:
POST - 权限标识:
integration:realtime:start:subscriber - 接口标签: 【实时服务管理】统一管理
请求参数
Headers
| 参数名 | 类型 | 必填 | 描述 |
|---|---|---|---|
| Authorization | String | 是 | 认证令牌，格式：Bearer {token} |
| Content-Type | String | 是 | 请求内容类型，固定值：application/json |
Query Parameters
无
Body Parameters
无
响应参数
响应结构
{
"success": boolean,
"message": String,
"subscribed": boolean
}
字段说明
| 字段名 | 类型 | 描述 |
|---|---|---|
| success | Boolean | 请求是否成功，true-成功，false-失败 |
| message | String | 响应消息，描述操作结果 |
| subscribed | Boolean | 订阅状态，true-已订阅，false-未订阅 |
响应示例
成功响应
{
"success": true,
"message": "事件订阅启动成功",
"subscribed": true
}
失败响应
{
"success": false,
"message": "事件订阅启动失败: 认证失败",
"subscribed": false
}
错误码说明
| 错误码 | 描述 | 解决方案 |
|---|---|---|
| 401 | 未授权，token 无效或已过期 | 重新登录获取有效 token |
| 403 | 无权限访问该接口 | 联系管理员分配相应权限 |
| 409 | 订阅服务已在运行 | 无需重复启动，或先停止再启动 |
| 500 | 服务器内部错误 | 检查服务器日志，联系技术支持 |
注意事项
- 启动前请确保对象注册表已初始化，否则可能无法订阅到任何事件
- 启动前请确保 Salesforce 配置正确，包括：
- Consumer Key 和 Consumer Secret 已配置
- Access Token 有效
- Pub/Sub API 连接配置正确
- 如果订阅服务已在运行，再次调用此接口不会产生副作用
- 启动成功后，系统会开始接收和处理来自 Salesforce 的实时变更事件
- 订阅服务启动后会自动处理以下事件类型：
- Create（创建）
- Update（更新）
- Delete（删除）
- Undelete（恢复删除）
- 建议在以下场景启动订阅服务：
- 系统初始化完成后
- 对象注册表更新后
- 订阅服务停止后需要重新启动时
- 启动操作是幂等的，可以安全地重复执行