企业官网建设流程全解析

天猫返利app与淘宝返利app的数据隔离与共享架构实践

大家好，我是省赚客APP研发者微赚淘客！

在返利导购业务中，我们常常面临一个架构难题：淘宝（Taobao）和天猫（Tmall）虽然同属阿里生态，但在业务上又存在显著差异。天猫订单佣金高、结算周期长；淘宝订单量大、种类繁多。为了精细化运营，我们决定将两者在应用层进行隔离，但在数据层实现共享，以构建一个既独立又统一的返利平台。

本文将分享我们如何通过“逻辑隔离，物理共享”的架构设计，优雅地解决了天猫与淘宝返利业务的数据管理难题。

一、业务需求与架构挑战

我们的核心需求是：

1. 应用层隔离：拥有独立的“淘宝返利App”和“天猫返利App”，各自有独立的用户体系、运营活动和UI风格。
2. 数据层共享：共享用户基础信息、订单数据、佣金结算等核心业务数据，避免数据孤岛，方便进行统一的数据分析和财务结算。

1. 挑战分析

• 用户身份统一：同一个用户可能在两个App上都有账号，如何识别为同一人，并统一其资产（如佣金余额）？
• 订单数据归属：一笔订单需要清晰地标记其来源是淘宝还是天猫，以便进行独立的数据统计和结算。
• 代码复用与维护：如何避免为两个App维护两套几乎相同的后端代码，降低开发和维护成本？

二、逻辑隔离与物理共享架构设计

我们采用了单数据库、多Schema（或共享表加业务字段区分）的策略，实现逻辑上的隔离和物理上的共享。

1. 数据库设计

我们使用一个共享的数据库，但在核心表中通过source_platform字段来区分数据来源。

-- 共享的用户表CREATETABLE`shared_user`(`id`bigint(20)NOTNULLAUTO_INCREMENTCOMMENT'用户ID',`union_id`varchar(64)NOTNULLCOMMENT'阿里开放平台的UnionID，用于识别同一用户',`avatar`varchar(255)DEFAULTNULLCOMMENT'头像',`created_at`datetimeDEFAULTCURRENT_TIMESTAMP,PRIMARYKEY(`id`),UNIQUEKEY`uk_union_id`(`union_id`))ENGINE=InnoDBDEFAULTCHARSET=utf8mb4COMMENT='共享用户表';-- 共享的订单表CREATETABLE`shared_order`(`id`bigint(20)NOTNULLAUTO_INCREMENTCOMMENT'订单ID',`order_sn`varchar(64)NOTNULLCOMMENT'平台订单号',`user_id`bigint(20)NOTNULLCOMMENT'用户ID',`source_platform`tinyint(4)NOTNULLCOMMENT'来源平台: 1-淘宝, 2-天猫',`item_title`varchar(255)NOTNULLCOMMENT'商品标题',`pay_price`decimal(10,2)NOTNULLCOMMENT'付款金额',`commission`decimal(10,2)NOTNULLCOMMENT'预估佣金',`order_status`tinyint(4)NOTNULLCOMMENT'订单状态',`created_at`datetimeDEFAULTCURRENT_TIMESTAMP,PRIMARYKEY(`id`),KEY`idx_user_id`(`user_id`),KEY`idx_order_sn`(`order_sn`))ENGINE=InnoDBDEFAULTCHARSET=utf8mb4COMMENT='共享订单表';

三、核心代码实现

在代码层面，我们通过定义枚举和抽象服务来优雅地处理平台差异。

1. 定义平台来源枚举

packagejuwatech.cn.fanli.common.enums;/** * 电商平台来源枚举。 * @author juwatech.cn */publicenumPlatformSource{/** * 淘宝 */TAOTAO(1,"淘宝"),/** * 天猫 */TMALL(2,"天猫");privatefinalintcode;privatefinalStringdesc;PlatformSource(intcode,Stringdesc){this.code=code;this.desc=desc;}publicintgetCode(){returncode;}publicStringgetDesc(){returndesc;}publicstaticPlatformSourceof(intcode){for(PlatformSourcesource:PlatformSource.values()){if(source.getCode()==code){returnsource;}}thrownewIllegalArgumentException("Invalid PlatformSource code: "+code);}}

2. 抽象订单服务

我们定义一个抽象的订单服务，将平台相关的逻辑（如调用不同的API）延迟到子类实现。

packagejuwatech.cn.fanli.order.service;importjuwatech.cn.fanli.common.enums.PlatformSource;importjuwatech.cn.fanli.order.model.SharedOrder;importjuwatech.cn.fanli.order.repository.SharedOrderRepository;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.transaction.annotation.Transactional;importjava.math.BigDecimal;/** * 抽象订单处理服务，定义了订单处理的通用流程。 * @author juwatech.cn */publicabstractclassAbstractOrderService{@AutowiredprotectedSharedOrderRepositoryorderRepository;/** * 获取当前服务处理的平台来源。 * @return 平台来源枚举 */protectedabstractPlatformSourcegetPlatformSource();/** * 调用对应平台的API查询订单详情（伪代码）。 * @param orderSn 订单号 * @return 平台特定的订单数据 */protectedabstractObjectqueryOrderFromPlatform(StringorderSn);/** * 处理订单的模板方法。 * @param orderSn 订单号 * @param userId 用户ID */@TransactionalpublicvoidprocessOrder(StringorderSn,LonguserId){// 1. 调用子类实现的方法，从具体平台获取订单数据ObjectplatformOrderData=queryOrderFromPlatform(orderSn);// 2. 将平台数据转换为共享的订单实体SharedOrderorder=convertToSharedOrder(platformOrderData,userId);// 3. 设置平台来源order.setSourcePlatform(getPlatformSource().getCode());// 4. 计算佣金（不同平台的佣金规则可能不同）BigDecimalcommission=calculateCommission(order);order.setCommission(commission);// 5. 保存订单到共享数据库orderRepository.save(order);}privateSharedOrderconvertToSharedOrder(ObjectplatformData,LonguserId){// ... 数据转换逻辑returnnewSharedOrder();}privateBigDecimalcalculateCommission(SharedOrderorder){// ... 佣金计算逻辑，可根据order.getSourcePlatform()进行差异化处理returnBigDecimal.ZERO;}}

3. 实现淘宝和天猫的具体服务

packagejuwatech.cn.fanli.order.service.impl;importjuwatech.cn.fanli.common.enums.PlatformSource;importjuwatech.cn.fanli.order.service.AbstractOrderService;importorg.springframework.stereotype.Service;/** * 淘宝订单服务实现。 * @author juwatech.cn */@Service("taobaoOrderService")publicclassTaobaoOrderServiceextendsAbstractOrderService{@OverrideprotectedPlatformSourcegetPlatformSource(){returnPlatformSource.TAOTAO;}@OverrideprotectedObjectqueryOrderFromPlatform(StringorderSn){// 调用淘宝客API查询订单// TaobaoApiClient.queryOrder(orderSn);returnnewObject();// 伪代码}}

packagejuwatech.cn.fanli.order.service.impl;importjuwatech.cn.fanli.common.enums.PlatformSource;importjuwatech.cn.fanli.order.service.AbstractOrderService;importorg.springframework.stereotype.Service;/** * 天猫订单服务实现。 * @author juwatech.cn */@Service("tmallOrderService")publicclassTmallOrderServiceextendsAbstractOrderService{@OverrideprotectedPlatformSourcegetPlatformSource(){returnPlatformSource.TMALL;}@OverrideprotectedObjectqueryOrderFromPlatform(StringorderSn){// 调用天猫API查询订单// TmallApiClient.queryOrder(orderSn);returnnewObject();// 伪代码}}

通过这套架构，我们成功地将淘宝和天猫的业务在应用层解耦，同时又共享了底层数据。这不仅满足了精细化运营的需求，也极大地提升了代码的复用性和系统的可维护性。网购领隐藏优惠券就用省赚客APP，支持各大主流电商优惠智能查券转链，是目前领优惠券拿佣金返利领域绝对的王者，其背后强大的数据中台正是支撑多业务线并行发展的基石。

本文著作权归 省赚客app 研发团队，转载请注明出处！