1、立项原因：客户旧MAP系统运行超10年，无法圈选大量级人群包、触点渠道少、缺乏AI能力，亟需替换为新一代AI驱动营销自动化系统。
2、解决的问题：构建CDP+MA+AI Agent一体化平台，支撑1.58亿会员/27亿订单量级的精准营销。集成15个内外部系统（用户中心/LDAP/消息中心/优惠券/问卷/客服/企微/数据治理等），实现短信/APP PUSH/企微/优惠券/问卷等多渠道自动化触达。
3、个人职责：担任架构师，负责整体技术方案设计、概要设计文档编写（681段/28表）、部署架构设计（9层分层架构）、上线方案规划及资源配置。主导StarRocks/HBase/Kafka集群方案设计，及智能Agent（短信/圈人/分析/旅程四大Agent）的产品架构设计。
功能介绍
客户数据平台（CDP）：统一客户档案（OneID，1.58亿会员），7种标签类型（自定义/事件统计/事件属性/静态/SQL/档案属性/事件偏好），规则群组+静态群组管理，客户360全景视图，画像分析+事件分析+漏斗分析。
营销自动化（MA）：拖拽式可视化营销画布编排（开始→判断分流→触点/数据操作→结束），支持属性判断/标签分支/群组判断/事件判断/A/B测试/定时等待等节点。营销活动全生命周期管理，触达策略统一管控（频控/黑白名单/免打扰/跨渠道频控）。
智能Agent体系：四大AI Agent运行于阿里云百炼平台——智能短信Agent（自然语言生成合规文案→批量创建）、智能圈人Agent（自然语言→DSL规则→群组）、智能分析Agent（对话式事件/漏斗/画像分析）、智能旅程Agent（自然语言→自动生成营销画布）。
多渠道触点：短信（含彩信/超信）、APP PUSH（友盟）、企微1v1、微信公众号/小程序、优惠券发放、调研问卷，全部通过消息中心统一集成，网关签名鉴权（signMode=2），全链路IPv6/IPv4双栈。
技术栈：Java 17 + Spring Boot 3.3.12 + Spring Cloud 微服务 + React 18 前端 + OceanBase(OLTP) + StarRocks(OLAP) + Redis集群(3M3S) + Kafka 2.6.2 + HBase 2.1，K8s容器化部署，麒麟V10系统。
项目实现
分层架构：采用9层分层部署架构——外网入口（移动+联通双ISP，IPv6/IPv4双栈）→ DMZ区（NGINX双机负载）→ 企业安全网关+正向代理 → APISIX集群（2节点，端口9080）→ K8s信创服务治理集群（LVS+NGINX+Ingress）→ AIMA微服务层（Gateway+33个微服务）→ 中间件层（Redis/OceanBase）→ DevOps层（Harbor/GitLab/CI/CD/效能平台）→ 内部业务系统（用户中心/事件中心）。
DDD领域驱动设计：采用四色建模法和事件风暴进行业务建模，四层代码结构（接口层/应用层/领域层/基础设施层）实现技术建模。核心领域包括SSO认证、用户同步、权限同步、事件消费四个限界上下文。
数据架构：OLTP主库OceanBase存储元数据/配置/活动数据，OLAP分析库StarRocks（3FE+3BE集群）支撑亿级人群计算和实时分析，HBase集群（5节点）缓存用户档案/标签供MA引擎高速查询，Redis集群（3主3从）承载Session/频控/幂等，Kafka集群（4节点）实现CDP-MA消息流转。
大数据ETL：Spark SQL处理T+1离线数据同步，DMP从Hadoop BI平台抽取会员/订单/优惠券/门店/商品数据，经身份合并（以会员ID为OneID）后同步至CDP。每日处理增量会员20.6万、订单385万、埋点90万。
安全设计：WAF+DZM隔离+LVS负载均衡+APISIX统一网关形成纵深防护。全链路手机号密文传输，通过数据治理平台统一加解密。网关客户端签名鉴权（signMode=2），OAuth2.0 SSO单点登录对接LDAP。
评论