得物管理類目配置線上化：從業務痛點到技術實現詳情 - 後端,數據分析,數據挖掘,效率,效率工具得物技術動態日志

一、引言

在電商交易領域，管理類目作為業務責權劃分、統籌、管理核心載體，隨着業務複雜性的提高，其規則調整頻率從最初的 1 次 / 季度到多次 / 季度，三級類目的規則複雜度也呈指數級上升。傳統依賴數倉底層更新的方式暴露出三大痛點：

行業無法自主、快速調管理類目；
業務管理類目規則調整，不支持校驗類目覆蓋範圍是否有重複/遺漏，延長交付週期；
規則變更成功後、下游系統響應滯後，無法及時應用最新類目規則。

本文將從技術視角解析 “管理類目配置線上化” 項目如何通過全鏈路技術驅動，將規則迭代週期縮短至 1-2 天。

二、業務痛點與技術挑戰：為什麼需要線上化？

2.1 效率瓶頸：手工流程與

高頻迭代的矛盾

問題場景：業務方需線下通過數倉提報規則變更，經數倉開發、測試、BI需要花費大量精力校驗確認，一次類目變更需 3-4 周左右時間才能上線生效，上線時間無法保證。

技術瓶頸：數倉離線同步週期長（T+1），規則校驗依賴人工梳理，無法應對 “商品類目量級激增”。

2.2 質量風險：規則複雜度與

校驗能力的失衡

典型問題：當前的管理類目映射規則，依賴業務收集提報，但從實際操作看管理三級類目映射規則提報質量較差(主要原因為：業務無法及時校驗提報規則是否準確，是否窮舉完善，是否完全無交叉)，存在大量重複 / 遺漏風險。

2.3 系統耦合：底層變更對

下游應用的多米諾效應

連鎖影響：管理類目規則變更會需同步更新交易後台、智能運營系統、商運關係工作台等多下游系統，如無法及時同步，可能會影響下游應用如商運關係工作台的員工分工範圍的準確性，影響商家找人、資質審批等場景應用。

三、技術方案：從架構設計到核心模塊拆解

3.1 分層架構：解耦業務與數據鏈路

3.2 核心模塊技術實現

規則生命週期管理：規則操作流程

提交管理類目唯一性校驗規則

新增：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;
}