项目背景:
- 面向用工企业、财税服务商及自由职业者构建三方协作平台,实现四流合一全链路线上化(合同流/业务流/资金流/发票流)
- 通过小程序端提供灵活就业人员项目领取、实名认证、合同签署及结算提现功能,企业端支持批量用工池管理、项目配置及智能风控
-
日均处理结算订单超 200 万笔,支撑用工企业超 5000 家,覆盖灵活就业人员50万+,资金流转规模达 10亿级/月
架构简介:
-
业务层:聚焦用工撮合、任务分发、结算申报等核心场景,支持B端企业灵活配置项目规则(如黑白名单、税种选择)
-
服务层:
-
支付路由引擎:动态匹配银行/第三方支付渠道,结合实时限额、费率、稳定性多维度决策最优路径
-
风控中枢:集成敏感词过滤、黑名单拦截、跨区域核销防控等12类策略,实现结算前/中/后全流程风险管控
-
结算引擎:支持异步批量处理、幂等校验、资金冻结/解冻原子操作,保障高并发场景下数据一致性
-
-
基础层:基于云原生架构实现弹性扩缩容,通过分布式事务框架解决多系统协同问题
核心技术:
- Go(高性能结算服务)、Kubernetes(容器化部署)、Kafka(异步消息队列)、Elasticsearch(风控日志分析)、TiDB(海量结算数据存储)、Drools(风控规则引擎)
项目角色:
-
担任支付路由模块技术负责人,设计基于加权轮询+故障降级的动态渠道分配算法,支付成功率从92%提升至99.5%
-
主导结算引擎重构,引入分段锁+流水号预生成机制,解决万级并发下账户余额更新冲突问题,结算吞吐量提升3倍
-
设计多级风控拦截体系,通过规则引擎动态加载风险策略,拦截异常结算请求1.2万次/日,资损率降低85%
-
实现税务合规自动化:对接电子签章系统生成完税证明,预置经营所得/劳务报酬等计税模板,申报效率提升70%
-
输出《支付渠道高可用设计规范》《灵工结算对账方案》等技术文档,获得集团技术创新奖
关键举措:
- 支付路由智能降级:
- 问题:银行渠道单日限额波动导致大额结算失败率高,人工切换效率低下
- 方案:
- 实时监控渠道状态/限额,结合历史成功率动态计算权重
- 预置降级规则(如“单笔>5万自动路由至银企直连通道”)
- 基于Redis实现渠道状态秒级同步
- 收益:大额支付成功率从78%提升至95%,人工干预量减少90%
- 结算事务最终一致性保障:
- 问题:跨系统(结算+风控+支付)数据不一致导致重复出款
- 方案:
- 采用Saga模式拆解“冻结-出款-解冻”子事务
- 通过Kafka消息补偿机制实现异常自动回滚
- 增加对账任务校验资金流水与业务状态差异
- 收益:资损事件归零,月度对账时长从8小时缩短至30分钟
- 黑名单实时拦截优化:
- 问题:千万级黑名单数据全量加载至Redis导致内存溢出
- 方案:
- 按企业维度分片存储,采用布隆过滤器预判减少无效查询
- 监听数据库Binlog实现增量数据实时同步
- 冷热数据分离(热数据存Redis,全量数据存ES)
- 收益:内存占用降低60%,拦截响应时间<10ms
- 灵工人员实名核验效能提升:
- 问题:OCR识别+公安库校验平均耗时800ms,高峰时段排队严重
- 方案:
- 前置活体检测过滤无效请求(节省30%校验量)
- 采用本地缓存+异步预加载机制存储常用身份证信息
- 设计分级策略(优先调用低并发率渠道)
- 收益:核验平均RT降至200ms,高峰时段吞吐量提升4倍
注:技术亮点设计参考PRD中支付路由、风控、结算等模块的实际需求,避免与示例项目的SpringBoot/Redis等技术栈重复,侧重高并发、分布式事务等场景创新。
- 业务层:聚焦用工撮合、任务分发、结算申报等核心场景,支持 B 端企业灵活配置项目规则(如黑白名单、税种选择)
- 支付路由引擎:动态匹配银行/第三方支付渠道,结合实时限额、费率、稳定性多维度决策最优路径
- 风控中枢:集成敏感词过滤、黑名单拦截、跨区域核销防控等12类策略,实现结算前/中/后全流程风险管控
- 结算引擎:支持异步批量处理、幂等校验、资金冻结/解冻原子操作,保障高并发场景下数据一致性
- 基础层:基于云原生架构实现弹性扩缩容,通过分布式事务框架解决多系统协同问题
核心技术:
- SpringBoot / MySQL / MyBatis / Nacos / Shiro / Redis / RabbitMQ / Elasticsearch
项目角色:
- 作为核心架构师参与项目从0到1的架构设计,主导整体技术方案和系统拆分
- 负责结算域和风控域核心模块设计与实现,实现支付路由、多种税费计算模型
- 主导服务治理与监控体系建设,构建全链路监控、灰度发布、降级熔断等保障机制
- 推动资金安全与合规风控体系建设,设计交易风控策略与审批流程
- 通过技术创新解决平台业务难点,沉淀3项核心专利
关键举措:
-
资金流转引擎设计:
- 问题:灵活用工面临多种结算模式(批量结算、即时激励、串码核销等),涉及企业、众包、灵工三方主体,需确保资金流转安全、合规、可追溯
- 解决方案:
- 设计基于状态机的交易处理引擎,将结算流程拆分为11个独立状态
- 采用分布式事务(Seata)保证下单、预扣款、试算税费等环节的事务一致性
- 结合幂等设计解决分布式事务补偿场景下重复处理问题
- 通过账户分类策略(主账户/子账户/服务费账户/税费账户)隔离不同资金用途
- 收益:
- 日均处理交易10万+笔,资金差错率低于0.001%
- 支持多种灵活用工模式无缝切换,系统稳定性99.99%
-
税费处理引擎实现:
- 问题:灵活用工涉及复杂税费规则(劳务报酬、经营所得、特许权所得),需要动态计算多种税种,且政策随时可能变化
- 解决方案:
- 设计可配置税费规则引擎,支持灵活配置各类税率参数和计算规则
- 采用"策略模式+工厂模式"实现税费计算不同策略的可扩展切换
- 设计月度累计基数表,解决个人所得税累计预扣问题
- 基于责任链模式实现多重税费校验和风险预警
- 收益:
- 税费计算准确率100%,无任何税务合规风险
- 系统可在政策调整后1小时内完成全平台规则更新
-
分布式结算批处理系统:
- 问题:客户存在批量结算需求(单次5万+订单),传统处理方式容易导致系统瓶颈和超时
- 解决方案:
- 设计基于MapReduce思想的分布式批处理框架
- 使用Elastic-Job实现大任务分片,结合内存队列提升处理效率
- 采用滑动窗口限流器控制下游系统压力
- 实现批处理状态可视化和实时监控,支持异常中断后定点恢复
- 收益:
- 批量结算性能提升8倍(5万笔从40分钟优化至5分钟)
- 系统资源利用率提升60%,高峰期可弹性扩容
-
多层级风控体系构建:
- 问题:灵活用工存在身份冒用、合规风险、资金风险等多种风险场景
- 解决方案:
- 设计"注册-签约-结算-提现"全流程风控矩阵
- 基于规则引擎实现实时风控决策,支持自定义风控规则
- 建立风控审核工作流,支持多角色、多层级审核
- 引入区块链技术对关键数据(合同签署、工作成果)进行存证
- 收益:
- 平台风险事件发生率降低85%
- 减少手工审核工作量70%,业务处理效率显著提升
-
支付路由系统优化:
- 问题:多支付渠道(微信、银行卡)存在费率差异、渠道限额和渠道稳定性问题
- 解决方案:
- 实现智能支付路由系统,基于多维度(成本、限额、稳定性)动态选择最优渠道
- 设计带有权重的失败自动切换机制,保障支付通道高可用
- 实现渠道监控和自动预警,及时发现渠道异常
- 引入支付熔断器,防止渠道故障影响整体系统
- 收益:
- 支付成功率提升至99.8%,大幅高于行业平均水平
- 通过智能路由每年节省渠道成本约200万
-
高并发签约服务设计:
- 问题:高峰期短时间内大量用户签约(如项目上新),传统签约流程易造成系统压力
- 解决方案:
- 设计双模式签约流程(手动签约/静默签约),分散签约压力
- 采用库表分片+索引优化,解决签约记录查询性能问题
- 实现签约流程异步化,提升系统吞吐能力
- 基于Redis实现签约限流保护和签约状态缓存
- 收益:
- 系统单日可支持10万+份合同签署
- 签约服务响应时间缩短70%(平均RT从800ms降至240ms)
一、分层架构
-
应用层
提供多终端服务入口,包含:-
商户平台:支撑合同流、业务流、资金流、发票流等核心业务流程
-
小程序:集成众包接入、用工注册、客户注册等C端功能
-
API接口:支持机构用户批量操作与系统集成
-
运营平台:配置菜单权限、费率、风控规则等全局策略
-
-
接入层
通过labor-cloud-gate网关服务统一管理外部请求,实现流量控制、鉴权拦截与协议转换,保障系统安全性。 -
业务层
核心业务处理模块包括:-
会员服务:管理企业/个人注册、权限配置、用工类型转换(雇员↔自由职业者)
-
结算服务:涵盖税费计算、账户冻结、渠道支付、动账通知等资金处理全链路
-
任务服务:支持串码核销、考勤打卡、项目指派等用工过程管理
-
风控服务:实施敏感词过滤、黑名单拦截、年龄检测、余额校验等多维度管控
-
-
基础层
提供底层能力支持:- 支付路由:对接微信/支付宝/银行等多渠道支付
- 实名认证:集成OCR识别、电子签章、静默签约等合规工具
- 数据隔离:通过租户管理实现企业间权限与数据隔离
- 运营支撑:菜单配置、字典服务、日志审计等后台管理
-
三方平台
集成鉴权、短信、电子合同等第三方服务,扩展系统能力边界。
二、关键流程特性
-
资金流闭环
- 虚拟账户体系支持主账户资金池管理与子账户专款专用
- 企业充值→项目结算→税费提现的全流程自动化
- 雇员支付直连企业银行账户,免除计税环节
-
风控体系
- 事前防控:注册阶段黑名单校验、用工类型冲突检测
- 事中拦截:支付时实时校验余额限额、代付权限
- 事后审计:动账通知与流水记录可追溯
-
灵活配置
- 支持按企业维度差异化配置费率、发票类目、协议模板
- 用工人员可跨雇员/自由职业者身份转换,适配多元用工场景
该架构通过层次化设计实现业务解耦,结合自动化流程与可配置策略,满足企业用工管理中的合规性、效率性与扩展性需求。
