数据服务总线对接与业务线索清洗平台产品系统

政务多源业务数据汇聚场景。各业务系统数据通过服务总线接入，对原始警情、业务原始记录自动过滤脏数据，提取有效线索，入库存储，支持业务人员检索核查，减轻人工筛选工作量。

1. 对接数据服务总线，消费上游推送业务数据；
​
2. 数据校验、脏数据剔除、字段清洗、线索规则过滤；
​
3. Kafka消息异步解耦，数据写入MySQL+ES；
​
4. 提供REST查询接口，支持多条件线索检索、批量数据导出；
​
5. XXL-Job定时任务，异常数据日志留存、失败重试。

基于SpringBoot + MyBatis-Plus开发；Kafka负责消息接收；Elasticsearch构建索引实现高速检索；XXL-Job调度离线清洗任务；实现总线通道适配、数据规则化处理；输出完整接口文档、部署脚本，支持内网私有化部署。