我要投稿

得物管理类目配置线上化：从业务痛点到技术实现

发布日期：2025-11-05 18:34:54 浏览次数： 1515

作者：得物技术

微信搜一搜，关注“得物技术”

一、引言

二、业务痛点与技术挑战：为什么需要线上化？

1. 效率瓶颈：手工流程与高频迭代的矛盾

2. 质量风险：规则复杂度与校验能力的失衡

3. 系统耦合：底层变更对下游应用的多米诺效应

三、技术方案：从架构设计到核心模块拆解

1. 分层架构：解耦业务与数据链路

2. 核心模块技术实现

3. 数据模型设计

4. 数仓计算逻辑

四、项目成果与技术价值

五、总结

一

引言

在电商交易领域，管理类目作为业务责权划分、统筹、管理核心载体，随着业务复杂性的提高，其规则调整频率从最初的 1 次 / 季度到多次 / 季度，三级类目的规则复杂度也呈指数级上升。传统依赖数仓底层更新的方式暴露出三大痛点：

行业无法自主、快速调管理类目；
业务管理类目规则调整，不支持校验类目覆盖范围是否有重复/遗漏，延长交付周期；
规则变更成功后、下游系统响应滞后，无法及时应用最新类目规则。

本文将从技术视角解析 “管理类目配置线上化” 项目如何通过全链路技术驱动，将规则迭代周期缩短至 1-2 天。

二

业务痛点与技术挑战：

为什么需要线上化？

效率瓶颈：手工流程与

高频迭代的矛盾

问题场景：业务方需线下通过数仓提报规则变更，经数仓开发、测试、BI需要花费大量精力校验确认，一次类目变更需 3-4 周左右时间才能上线生效，上线时间无法保证。

技术瓶颈：数仓离线同步周期长（T+1），规则校验依赖人工梳理，无法应对 “商品类目量级激增”。

质量风险：规则复杂度与

校验能力的失衡

典型问题：当前的管理类目映射规则，依赖业务收集提报，但从实际操作看管理三级类目映射规则提报质量较差(主要原因为：业务无法及时校验提报规则是否准确，是否穷举完善，是否完全无交叉)，存在大量重复 / 遗漏风险。

系统耦合：底层变更对

下游应用的多米诺效应

连锁影响：管理类目规则变更会需同步更新交易后台、智能运营系统、商运关系工作台等多下游系统，如无法及时同步，可能会影响下游应用如商运关系工作台的员工分工范围的准确性，影响商家找人、资质审批等场景应用。

三

技术方案：从架构设计到核心模块拆解

分层架构：解耦业务与数据链路

核心模块技术实现

规则生命周期管理：规则操作流程

提交管理类目唯一性校验规则

新增：id为空，则为新增

删除：当前db数据不在提交保存列表中

更新：名称或是否兜底类目或规则改变则发生更新【其中如果只有名称改变则只触发审批，不需等待数据校验，业务规则校验逻辑为将所有规则包含id，按照顺序排序拼接之后结果是否相等】

多级类目查询

构建管理类目树

/** * 构建管理类目树 */public List<ManagementCategoryDTO> buildTree(List<ManagementCategoryEntity> managementCategoryEntities) {    Map<Long, ManagementCategoryDTO> managementCategoryMap = new HashMap<>();    for (ManagementCategoryEntity category : managementCategoryEntities) {        ManagementCategoryDTO managementCategoryDTO = ManagementCategoryMapping.convertEntity2DTO(category);        managementCategoryMap.put(category.getId(), managementCategoryDTO);    }        // 找到根节点    List<ManagementCategoryDTO> rootNodes = new ArrayList<>();    for (ManagementCategoryDTO categoryNameDTO : managementCategoryMap.values()) {        //管理一级类目 parentId是0        if (Objects.equals(categoryNameDTO.getLevel(), ManagementCategoryLevelEnum.FIRST.getId()) && Objects.equals(categoryNameDTO.getParentId(), 0L)) {            rootNodes.add(categoryNameDTO);        }    }    // 构建树结构    for (ManagementCategoryDTO node : managementCategoryMap.values()) {        if (node.getLevel() > ManagementCategoryLevelEnum.FIRST.getId()) {            ManagementCategoryDTO parentNode = managementCategoryMap.get(node.getParentId());            if (parentNode != null) {                parentNode.getItems().add(node);            }        }    }    return rootNodes;}

填充管理类目规则


/** * 填充规则信息 */private void populateRuleData(List<ManagementCategoryDTO> managementCategoryDTOS, List<ManagementCategoryRuleEntity> managementCategoryRuleEntities) {    if (CollectionUtils.isEmpty(managementCategoryDTOS) || CollectionUtils.isEmpty(managementCategoryRuleEntities)) {        return;    }    List<ManagementCategoryRuleDTO> managementCategoryRuleDTOS =managementCategoryMapping.convertRuleEntities2DTOS(managementCategoryRuleEntities);    // 将规则集合按 categoryId 分组    Map<Long, List<ManagementCategoryRuleDTO>> rulesByCategoryIdMap = managementCategoryRuleDTOS.stream()            .collect(Collectors.groupingBy(ManagementCategoryRuleDTO::getCategoryId));    // 递归填充规则到树结构    fillRulesRecursively(managementCategoryDTOS, rulesByCategoryIdMap);
}
/** * 递归填充规则到树结构 */private static void fillRulesRecursively(List<ManagementCategoryDTO> managementCategoryDTOS, Map<Long, List<ManagementCategoryRuleDTO>> rulesByCategoryIdMap) {    if (CollectionUtils.isEmpty(managementCategoryDTOS) || MapUtils.isEmpty(rulesByCategoryIdMap)) {        return;    }    for (ManagementCategoryDTO node : managementCategoryDTOS) {        // 获取当前节点对应的规则列表        List<ManagementCategoryRuleDTO> rules = rulesByCategoryIdMap.getOrDefault(node.getId(), new ArrayList<>());        node.setRules(rules);        // 递归处理子节点        fillRulesRecursively(node.getItems(), rulesByCategoryIdMap);    }}

状态机驱动：管理类目生命周期管理

超时机制：基于时间阈值的流程阻塞保护

其中，为防止长时间运营处于待确认规则状态，造成其他规则阻塞规则修改，定时判断待确认规则状态持续时间，当时间超过xxx时间之后，则将待确认状态改为长时间未操作，放弃变更状态，并飞书通知规则修改人。

管理类目状态变化级联传播策略

类目生效和失效状态为级联操作。规则如下：

管理二级类目有草稿状态时，不允许下挂三级类目的编辑；
管理三级类目有草稿状态时，不允许对应二级类目的规则编辑；
类目生效失效状态为级联操作，上层修改下层级联修改状态，如果下层管理类目存在草稿状态，则自动更改为放弃更改状态。

规则变更校验逻辑

当一次提交，可能出现的情况如下。一次提交可能会产生多个草稿，对应多个审批流程。

新增管理类目规则：

一级管理类目可以直接新增（点击新增一级管理类目）
二级管理类目和三级管理类目不可同时新增
三级管理类目需要在已有二级类目基础上新增

只有名称修改触发直接审批，有规则修改需要等待数仓计算结果之后，运营提交发起审批。

交互通知中心：飞书卡片推送

变更规则数据计算结果依赖数仓kafka计算结果回调。
基于飞书卡片推送数仓计算结果，回调提交审批和放弃变更事件。

飞书卡片：

卡片结果

卡片操作结果

审批流程：多维度权限控制与飞书集成

提交审批的四种情况：

名称修改
一级类目新增
管理类目规则修改
生效失效变更

审批通过，将草稿内容更新到管理类目表中，将管理类目设置为生效中。

审批驳回，清空草稿内容。

审批人分配机制：多草稿并行审批方案

一次提交可能会产生多个草稿，对应多个审批流程。

审批逻辑

public Map<String, List<String>> buildApprover(        ManagementCategoryDraftEntity draftEntity,        Map<Long, Set<String>> catAuditorMap,        Map<String, String> userIdOpenIdMap,        Integer hasApprover) {        Map<String, List<String>> nodeApprover = new HashMap<>();
    // 无审批人模式，直接查询超级管理员    if (!Objects.equals(hasApprover, ManagementCategoryUtils.HAS_APPROVER_YES)) {        nodeApprover.put(ManagementCategoryApprovalField.NODE_SUPER_ADMIN_AUDIT,                queryApproverList(0L, catAuditorMap, userIdOpenIdMap));        return nodeApprover;    }        Integer level = draftEntity.getLevel();    Integer draftType = draftEntity.getType();    boolean isEditOperation = ManagementCategoryDraftTypeEnum.isEditOp(draftType);        // 动态构建审批链（支持N级类目）    List<Integer> approvalChain = buildApprovalChain(level);    for (int i = 0; i < approvalChain.size(); i++) {        int currentLevel = approvalChain.get(i);        Long categoryId = getCategoryIdByLevel(draftEntity, currentLevel);                // 生成节点名称（如：NODE_LEVEL2_ADMIN_AUDIT）        String nodeKey = String.format(                ManagementCategoryApprovalField.NODE_LEVEL_X_ADMIN_AUDIT_TEMPLATE,                currentLevel        );                // 编辑操作且当前层级等于提交层级时，添加本级审批人 【新增的管理类目没有还没有对应的审批人】        if (isEditOperation && currentLevel == level) {            addApprover(nodeApprover, nodeKey, categoryId, catAuditorMap, userIdOpenIdMap);        }                // 非本级审批人（上级层级）        if (currentLevel != level) {            addApprover(nodeApprover, nodeKey, categoryId, catAuditorMap, userIdOpenIdMap);        }    }        return nodeApprover;}
private List<Integer> buildApprovalChain(Integer level) {    List<Integer> approvalChain = new ArrayList<>();    if (level == 3) {        approvalChain.add(2); // 管二审批人        approvalChain.add(1); // 管一审批人    } else if (level == 2) {        approvalChain.add(2); // 管二审批人        approvalChain.add(1); // 管一审批人    } else if (level == 1) {        approvalChain.add(1); // 管一审批人        approvalChain.add(0); // 超管    }    return approvalChain;}