go: Divide and Conquer Algorithm

项目结构展示了一个使用Go语言实现的分治算法(Divide and Conquer)珠宝销售管理示例。包含多个组件核心数据结构定义了订单、销售汇总、权限节点等实体分治算法实现销售统计分治(SaleStatDAC) - 计算各类销售数据风险订单分治(RiskOrderDAC) - 检测高额订单权限检查分治(PermissionDAC) - 基于二叉树验证权限业务服务层提供门店业绩统计、时间维度报表、风险订单扫描等功能应用示例演示了并行门店业绩统计、年度报表生成、风险订单检测和权限验证示例采用模块化设计包含常量定义、工具函数、实体模型、存储库、分治算法核心和服务层展示了分治算法在销售分析、风险控制和权限管理中的实际应用。/* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:01 # User : geovindu # Product : GoLand # Project : goalgorithms # File : const.go */ package constants // 风控阈值 10万元 const RiskAmountThreshold 100000.0 // 门店列表 var ShopList []string{福田店, 南山店} // 季度对应月份 var QuarterMonthMap map[int][]int{ 1: {1, 2, 3}, 2: {4, 5, 6}, 3: {7, 8, 9}, 4: {10, 11, 12}, } // 产品品类 var CategoryList []string{黄金, 钻石, 彩宝, 银饰} // 权限常量 const ( PermDiamondAdjust 钻石调价 PermExportAllShop 全门店数据导出 PermShopAdjust 本店调价 PermModifyRole 修改角色权限 PermViewSelfSale 查看个人业绩 PermViewStock 库存盘点 ) /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:01 # User : geovindu # Product : GoLand # Project : goalgorithms # File : util.go */ package utils import ( fmt sync ) // FormatFloat 金额保留两位小数输出 func FormatFloat(val float64) string { return fmt.Sprintf(%.2f, val) } // ParallelBatchExecute 并发执行任务 func ParallelBatchExecute(tasks []func() interface{}) []interface{} { var wg sync.WaitGroup resChan : make(chan interface{}, len(tasks)) for _, task : range tasks { wg.Add(1) go func(fn func() interface{}) { defer wg.Done() resChan - fn() }(task) } wg.Wait() close(resChan) results : make([]interface{}, 0, len(tasks)) for v : range resChan { results append(results, v) } return results } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:02 # User : geovindu # Product : GoLand # Project : goalgorithms # File : order.go */ package entity // JewelryOrder 珠宝订单实体 type JewelryOrder struct { OrderID string ShopName string SaleMonth int Quarter int Category string SaleAmount float64 Profit float64 SellerID string } // SaleSummary 销售汇总统计结构体 type SaleSummary struct { TotalSales float64 TotalProfit float64 Gold float64 Diamond float64 Gem float64 Silver float64 } // Add 合并两个统计结果替代python 运算符 func (s SaleSummary) Add(other SaleSummary) SaleSummary { return SaleSummary{ TotalSales: s.TotalSales other.TotalSales, TotalProfit: s.TotalProfit other.TotalProfit, Gold: s.Gold other.Gold, Diamond: s.Diamond other.Diamond, Gem: s.Gem other.Gem, Silver: s.Silver other.Silver, } } // ToMap 转为map用于打印输出 func (s SaleSummary) ToMap() map[string]float64 { return map[string]float64{ 总销售额: s.TotalSales, 总毛利: s.TotalProfit, 黄金: s.Gold, 钻石: s.Diamond, 彩宝: s.Gem, 银饰: s.Silver, } } // BuildSingleSummary 单订单生成汇总 func BuildSingleSummary(order JewelryOrder) SaleSummary { s : SaleSummary{ TotalSales: order.SaleAmount, TotalProfit: order.Profit, } switch order.Category { case 黄金: s.Gold order.SaleAmount case 钻石: s.Diamond order.SaleAmount case 彩宝: s.Gem order.SaleAmount case 银饰: s.Silver order.SaleAmount } return s } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:02 # User : geovindu # Product : GoLand # Project : goalgorithms # File : role.go */ package entity // JewelryRoleNode 权限二叉树节点 type JewelryRoleNode struct { RoleName string Permissions []string Left *JewelryRoleNode Right *JewelryRoleNode } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:05 # User : geovindu # Product : GoLand # Project : goalgorithms # File : order_repo.go */ package repository import ( goalgorithms/divideconquer/constants goalgorithms/divideconquer/entity ) type OrderRepository struct { data []entity.JewelryOrder } func NewOrderRepo() *OrderRepository { return OrderRepository{ data: make([]entity.JewelryOrder, 0), } } func (r *OrderRepository) Add(order entity.JewelryOrder) { r.data append(r.data, order) } func (r *OrderRepository) BatchAdd(orders []entity.JewelryOrder) { r.data append(r.data, orders...) } func (r *OrderRepository) GetAll() []entity.JewelryOrder { copySlice : make([]entity.JewelryOrder, len(r.data)) copy(copySlice, r.data) return copySlice } // SplitByShop 按门店拆分订单 func (r *OrderRepository) SplitByShop() map[string][]entity.JewelryOrder { splitMap : make(map[string][]entity.JewelryOrder) for _, shop : range constants.ShopList { splitMap[shop] make([]entity.JewelryOrder, 0) } for _, o : range r.data { if arr, ok : splitMap[o.ShopName]; ok { splitMap[o.ShopName] append(arr, o) } } return splitMap } // SplitByMonth 按月份拆分订单 func (r *OrderRepository) SplitByMonth() map[int][]entity.JewelryOrder { splitMap : make(map[int][]entity.JewelryOrder, 12) for m : 1; m 12; m { splitMap[m] make([]entity.JewelryOrder, 0) } for _, o : range r.data { splitMap[o.SaleMonth] append(splitMap[o.SaleMonth], o) } return splitMap } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:06 # User : geovindu # Product : GoLand # Project : goalgorithms # File : role_repo.go */ package repository import goalgorithms/divideconquer/entity type RoleRepository struct { root *entity.JewelryRoleNode } func NewRoleRepo() *RoleRepository { return RoleRepository{} } func (r *RoleRepository) SetRoot(root *entity.JewelryRoleNode) { r.root root } func (r *RoleRepository) GetRoot() *entity.JewelryRoleNode { return r.root } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:06 # User : geovindu # Product : GoLand # Project : goalgorithms # File : base_dac.go */ package dac // 泛型约束 Go1.18 type Input any type Output any // BaseDAC 分治标准抽象接口 type BaseDAC[T Input, R Output] interface { Conquer(data T) R Combine(left, right R) R } // RecursiveDAC 通用递归分治实现 func RecursiveDAC[T Input, R Output](d BaseDAC[T, R], data []T, l, r int) R { if l r { return d.Conquer(data[l]) } mid : (l r) / 2 leftRes : RecursiveDAC(d, data, l, mid) rightRes : RecursiveDAC(d, data, mid1, r) return d.Combine(leftRes, rightRes) } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:06 # User : geovindu # Product : GoLand # Project : goalgorithms # File : stat_dac.go */ package dac import goalgorithms/divideconquer/entity // SaleStatDAC 销售统计分治 type SaleStatDAC struct{} func (s *SaleStatDAC) Conquer(order entity.JewelryOrder) entity.SaleSummary { return entity.BuildSingleSummary(order) } func (s *SaleStatDAC) Combine(left, right entity.SaleSummary) entity.SaleSummary { return left.Add(right) } func (s *SaleStatDAC) CalcTotal(data []entity.JewelryOrder) entity.SaleSummary { if len(data) 0 { return entity.SaleSummary{} } return RecursiveDAC[entity.JewelryOrder, entity.SaleSummary](s, data, 0, len(data)-1) } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:07 # User : geovindu # Product : GoLand # Project : goalgorithms # File : risk_dac.go */ package dac import goalgorithms/divideconquer/entity // RiskOrderDAC 风险订单分治检索 type RiskOrderDAC struct { Threshold float64 } func NewRiskDAC(threshold float64) *RiskOrderDAC { return RiskOrderDAC{Threshold: threshold} } // 指针接收者 func (r *RiskOrderDAC) Conquer(order entity.JewelryOrder) []entity.JewelryOrder { if order.SaleAmount r.Threshold { return []entity.JewelryOrder{order} } return []entity.JewelryOrder{} } func (r *RiskOrderDAC) Combine(left, right []entity.JewelryOrder) []entity.JewelryOrder { return append(left, right...) } func (r *RiskOrderDAC) ScanRisk(data []entity.JewelryOrder) []entity.JewelryOrder { if len(data) 0 { return []entity.JewelryOrder{} } // 直接传指针 r return RecursiveDAC[entity.JewelryOrder, []entity.JewelryOrder](r, data, 0, len(data)-1) } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述 # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:09 # User : geovindu # Product : GoLand # Project : goalgorithms # File : perm_dac.go */ package dac import goalgorithms/divideconquer/entity type PermissionDAC struct{} func NewPermDAC() *PermissionDAC { return PermissionDAC{} } // CheckPerm 二叉树分治校验权限 func (p *PermissionDAC) CheckPerm(root *entity.JewelryRoleNode, targetPerm string) bool { if root nil { return false } // 当前节点匹配 for _, perm : range root.Permissions { if perm targetPerm { return true } } // Divide 左右子树 leftOk : p.CheckPerm(root.Left, targetPerm) rightOk : p.CheckPerm(root.Right, targetPerm) return leftOk || rightOk } // FilterOrderByPerm 分治过滤当前角色可见订单 func (p *PermissionDAC) FilterOrderByPerm(orders []entity.JewelryOrder, rolePerms []string, sellerID string) []entity.JewelryOrder { var dacFilter func(l, r int) []entity.JewelryOrder dacFilter func(l, r int) []entity.JewelryOrder { if l r { ord : orders[l] // 导购只能查看本人订单 hasSelfPerm : false for _, p : range rolePerms { if p 查看个人业绩 { hasSelfPerm true break } } if hasSelfPerm ord.SellerID ! sellerID { return []entity.JewelryOrder{} } return []entity.JewelryOrder{ord} } mid : (l r) / 2 left : dacFilter(l, mid) right : dacFilter(mid1, r) return append(left, right...) } if len(orders) 0 { return []entity.JewelryOrder{} } return dacFilter(0, len(orders)-1) } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:15 # User : geovindu # Product : GoLand # Project : goalgorithms # File : perm_service.go */ package service import ( goalgorithms/divideconquer/dac goalgorithms/divideconquer/entity goalgorithms/divideconquer/repository ) type PermissionService struct { repo *repository.RoleRepository dac *dac.PermissionDAC } func NewPermService(repo *repository.RoleRepository) *PermissionService { return PermissionService{ repo: repo, dac: dac.NewPermDAC(), } } func (s *PermissionService) HasPermission(permKey string) bool { root : s.repo.GetRoot() return s.dac.CheckPerm(root, permKey) } func (s *PermissionService) GetVisibleOrders(allOrders []entity.JewelryOrder, sellerID string) []entity.JewelryOrder { root : s.repo.GetRoot() if root nil { return []entity.JewelryOrder{} } return s.dac.FilterOrderByPerm(allOrders, root.Permissions, sellerID) } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:16 # User : geovindu # Product : GoLand # Project : goalgorithms # File : sale_stat_service.go */ package service import ( fmt goalgorithms/divideconquer/constants goalgorithms/divideconquer/dac goalgorithms/divideconquer/entity goalgorithms/divideconquer/repository goalgorithms/divideconquer/utils ) type SaleStatService struct { repo *repository.OrderRepository dac *dac.SaleStatDAC } func NewSaleStatService(repo *repository.OrderRepository) *SaleStatService { return SaleStatService{ repo: repo, dac: dac.SaleStatDAC{}, } } // StatByShopParallel 多线程分治统计门店业绩 func (s *SaleStatService) StatByShopParallel() map[string]entity.SaleSummary { shopSplit : s.repo.SplitByShop() tasks : make([]func() interface{}, 0, len(shopSplit)) shopNames : make([]string, 0, len(shopSplit)) for shop, ords : range shopSplit { shopNames append(shopNames, shop) ordCopy : ords tasks append(tasks, func() interface{} { return s.dac.CalcTotal(ordCopy) }) } resList : utils.ParallelBatchExecute(tasks) shopResult : make(map[string]entity.SaleSummary) totalAll : entity.SaleSummary{} for i, name : range shopNames { sum : resList[i].(entity.SaleSummary) shopResult[name] sum totalAll totalAll.Add(sum) } shopResult[集团全部门店合计] totalAll return shopResult } // StatByTime 按月分治合并季度年度 func (s *SaleStatService) StatByTime() map[string]interface{} { monthSplit : s.repo.SplitByMonth() monthSummary : make(map[int]entity.SaleSummary, 12) for m, ords : range monthSplit { monthSummary[m] s.dac.CalcTotal(ords) } quarterSummary : map[int]entity.SaleSummary{ 1: {}, 2: {}, 3: {}, 4: {}, } yearTotal : entity.SaleSummary{} for q, monthArr : range constants.QuarterMonthMap { for _, m : range monthArr { quarterSummary[q] quarterSummary[q].Add(monthSummary[m]) } } for _, ms : range monthSummary { yearTotal yearTotal.Add(ms) } monthMap : make(map[string]entity.SaleSummary, 12) for m : 1; m 12; m { monthMap[fmt.Sprintf(%d月, m)] monthSummary[m] } return map[string]interface{}{ 月度明细: monthMap, 季度汇总: quarterSummary, 年度总报表: yearTotal, } } /* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:16 # User : geovindu # Product : GoLand # Project : goalgorithms # File : risk_service.go */ package service import ( goalgorithms/divideconquer/dac goalgorithms/divideconquer/entity goalgorithms/divideconquer/repository ) type RiskScreenService struct { repo *repository.OrderRepository dac *dac.RiskOrderDAC } func NewRiskService(repo *repository.OrderRepository, threshold float64) *RiskScreenService { return RiskScreenService{ repo: repo, dac: dac.NewRiskDAC(threshold), } } func (r *RiskScreenService) ScanHighAmountOrders() []entity.JewelryOrder { all : r.repo.GetAll() return r.dac.ScanRisk(all) } func (r *RiskScreenService) ModifyThreshold(newVal float64) { r.dac.Threshold newVal }调用/* # 版权所有 2026 ©涂聚文有限公司™ ® # 许可信息查看言語成了邀功盡責的功臣還需要行爲每日來值班嗎 # 描述Divide and Conquer Algorithm # Author : geovindu,Geovin Du 涂聚文. # IDE : goLang 2024.3.6 go 26.2 # os : windows 10 # database : mysql 9.0 sql server 2019, postgreSQL 17.0 Oracle 21c Neo4j # Datetime : 2026/7/19 7:17 # User : geovindu # Product : GoLand # Project : goalgorithms # File : divideconquerbll.go */ package bll import ( fmt goalgorithms/divideconquer/app goalgorithms/divideconquer/constants goalgorithms/divideconquer/entity goalgorithms/divideconquer/utils ) func DivideConquerMain() { // 初始化应用门面 appIns : app.NewJewelryApp() // 模拟测试订单 mockOrders : []entity.JewelryOrder{ {O001, 福田店, 2, 1, 黄金, 6280, 1300, S001}, {O002, 福田店, 3, 1, 钻石, 128600, 48000, S001}, {O003, 南山店, 5, 2, 彩宝, 8900, 3600, S002}, {O004, 南山店, 6, 2, 钻石, 96000, 39000, S002}, {O005, 福田店, 9, 3, 银饰, 499, 220, S003}, {O006, 南山店, 11, 4, 钻石, 156000, 62000, S004}, {O007, 福田店, 12, 4, 黄金, 8600, 1800, S003}, } appIns.BatchAddOrders(mockOrders) // 构建多层权限树 guide : entity.JewelryRoleNode{ RoleName: 门店导购, Permissions: []string{constants.PermViewSelfSale}, } keeper : entity.JewelryRoleNode{ RoleName: 仓管, Permissions: []string{constants.PermViewStock}, } shopMgr : entity.JewelryRoleNode{ RoleName: 门店店长, Permissions: []string{constants.PermShopAdjust}, Left: guide, Right: keeper, } areaMgr : entity.JewelryRoleNode{ RoleName: 华南区域经理, Permissions: []string{constants.PermDiamondAdjust}, Left: shopMgr, } groupAdmin : entity.JewelryRoleNode{ RoleName: 集团管理员, Permissions: []string{constants.PermExportAllShop, constants.PermModifyRole}, Left: areaMgr, } appIns.BuildPermissionTree(groupAdmin) // 1. 并行分治门店业绩统计 fmt.Println( 【并行分治-门店业绩汇总】 ) shopStat : appIns.QueryShopSalesStat() for shop, summary : range shopStat { fmt.Printf(\n【%s】\n, shop) dataMap : summary.ToMap() for k, v : range dataMap { fmt.Printf(%s: %s\n, k, utils.FormatFloat(v)) } } // 2. 时间维度分治报表 fmt.Println(\n 【时间分治-年度经营报表】 ) timeStat : appIns.QueryTimeSalesStat() yearSum : timeStat[年度总报表].(entity.SaleSummary) fmt.Printf(全年总销售额%s全年毛利%s\n, utils.FormatFloat(yearSum.TotalSales), utils.FormatFloat(yearSum.TotalProfit)) fmt.Println(\n季度汇总) quarterMap : timeStat[季度汇总].(map[int]entity.SaleSummary) for q, s : range quarterMap { fmt.Printf(Q%d 销售总额%s\n, q, utils.FormatFloat(s.TotalSales)) } // 3. 风控高客单订单 fmt.Println(\n 【风控分治-超10万异常订单】 ) riskList : appIns.QueryRiskOrders() if len(riskList) 0 { for _, item : range riskList { fmt.Printf(订单%s | %s | %s | %s元\n, item.OrderID, item.ShopName, item.Category, utils.FormatFloat(item.SaleAmount)) } } else { fmt.Println(无风险订单) } // 4. 权限校验 fmt.Println(\n 【树形分治权限校验】 ) fmt.Printf(区域经理是否可钻石调价%t\n, appIns.CheckPermission(constants.PermDiamondAdjust)) fmt.Printf(店长是否可导出全门店数据%t\n, appIns.CheckPermission(constants.PermExportAllShop)) fmt.Printf(集团是否可修改角色权限%t\n, appIns.CheckPermission(constants.PermModifyRole)) // 5. 数据权限过滤导购S001 fmt.Println(\n 【分治数据权限过滤-导购S001可见订单】 ) userOrders : appIns.GetUserVisibleOrders(S001) for _, o : range userOrders { fmt.Printf(%s | 开单人:%s | %s\n, o.OrderID, o.SellerID, utils.FormatFloat(o.SaleAmount)) } }输出