feat: 按原型更新商务明细与游戏分析并清理临时资料

internal/data/business/ledger.go

@@ -32,11 +32,8 @@ func ledgerPromotes(db *gorm.DB, scope business.LedgerScope, filter business.Led
 		return q
 	}
 	hits := ledgerBasePromotes(db, scope, filter, "hit")
-	exact := "TRIM(hit.account) = ? COLLATE BINARY"
-	if db.Dialector.Name() == "mysql" {
-		exact = "BINARY TRIM(hit.account) = ?"
-	}
-	hits = hits.Where(exact, filter.PromoteAccount).Where("hit.source_db=" + alias + ".source_db")
+	keyword := strings.ToLower(strings.TrimSpace(filter.PromoteAccount))
+	hits = hits.Where("(INSTR(LOWER(hit.account),?) > 0 OR INSTR(LOWER(hit.nickname),?) > 0)", keyword, keyword).Where("hit.source_db=" + alias + ".source_db")
 	if scope.IncludeSub {
 		root := "CASE WHEN hit.promote_level=1 THEN hit.id WHEN hit.top_promote_id>0 THEN hit.top_promote_id ELSE hit.id END"
 		hits = hits.Where("(" + alias + ".id = (" + root + ") OR " + alias + ".top_promote_id = (" + root + "))")
@@ -232,7 +229,8 @@ func spendQuery(db *gorm.DB, scope business.LedgerScope, filter business.LedgerF
 	q := ledgerScopeQuery(db, scope, filter, "tab_spend").Where("r.pay_time BETWEEN ? AND ?", filter.BeginUnix, filter.EndUnix)
 	if successOnly {
 		q = q.Where("r.pay_status = 1")
-	} else if filter.PayStatus != nil {
+	}
+	if filter.PayStatus != nil {
 		q = q.Where("r.pay_status = ?", *filter.PayStatus)
 	}
 	if len(filter.GameNames) > 0 {
@@ -353,11 +351,13 @@ func fillLedgerNames(db *gorm.DB, scope business.LedgerScope, filter business.Le
 		SourceDB                        string `gorm:"column:source_db"`
 		PlatformBusierID                uint64
 		PlatformBusierAccount, Username string
+		UserID                          uint
+		IDPath                          string `gorm:"column:id_path"`
 	}
 	names := map[business.PlatformKey]bindName{}
 	for start := 0; start < len(pairs); start += 300 {
 		var rows []bindName
-		q := channelBindingQuery(db, scope.Viewer, business.ChannelFilter{}).Select("b.source_db,b.platform_busier_id,b.platform_busier_account,u.username").Where("(b.source_db,b.platform_busier_id) IN ?", portraitBindingPairs(pairs[start:min(start+300, len(pairs))])).Order("b.user_id")
+		q := channelBindingQuery(db, scope.Viewer, business.ChannelFilter{}).Select("b.source_db,b.platform_busier_id,b.platform_busier_account,b.user_id,u.username,u.id_path").Where("(b.source_db,b.platform_busier_id) IN ?", portraitBindingPairs(pairs[start:min(start+300, len(pairs))])).Order("b.user_id")
 		if err := q.Scan(&rows).Error; err != nil {
 			return business.ErrStorage
 		}
@@ -368,6 +368,31 @@ func fillLedgerNames(db *gorm.DB, scope business.LedgerScope, filter business.Le
 			}
 		}
 	}
+	ancestorIDs := map[uint]bool{}
+	paths := map[business.PlatformKey][]uint{}
+	for key, binding := range names {
+		for _, part := range strings.Split(binding.IDPath, ",") {
+			id, err := strconv.ParseUint(strings.TrimSpace(part), 10, 32)
+			if err == nil && id > 0 && uint(id) != binding.UserID {
+				paths[key] = append(paths[key], uint(id))
+				ancestorIDs[uint(id)] = true
+			}
+		}
+	}
+	ids := make([]uint, 0, len(ancestorIDs))
+	for id := range ancestorIDs {
+		ids = append(ids, id)
+	}
+	ancestors := map[uint]string{}
+	for start := 0; start < len(ids); start += 300 {
+		var rows []accountPO
+		if err := db.Select("id,username").Where("id IN ? AND level > 0", ids[start:min(start+300, len(ids))]).Find(&rows).Error; err != nil {
+			return business.ErrStorage
+		}
+		for _, row := range rows {
+			ancestors[row.ID] = row.Username
+		}
+	}
 	for _, target := range targets {
 		n := target.Names
 		if n.PromoteID == nil || *n.PromoteID < 0 {
@@ -380,33 +405,38 @@ func fillLedgerNames(db *gorm.DB, scope business.LedgerScope, filter business.Le
 			if binding, ok := names[business.PlatformKey{SourceDB: c.SourceDB, BusierID: c.BusierID}]; ok {
 				n.BindingAccount = binding.PlatformBusierAccount
 				n.BindingUserName = binding.Username
+				for _, id := range paths[business.PlatformKey{SourceDB: c.SourceDB, BusierID: c.BusierID}] {
+					if name := strings.TrimSpace(ancestors[id]); name != "" {
+						n.BusinessPath = append(n.BusinessPath, name)
+					}
+				}
+				if name := strings.TrimSpace(binding.Username); name != "" {
+					n.BusinessPath = append(n.BusinessPath, name)
+				}
 			}
 		}
 	}
 	return nil
 }
-func (r *ledgerRepo) Games(ctx context.Context, sources []string, keyword string, limit int) ([]*business.GameOption, error) {
+func (r *ledgerRepo) Games(ctx context.Context, viewer business.UserScope, sources []string, keyword string, limit int) ([]*business.GameOption, error) {
 	db := r.data.DB().WithContext(ctx)
-	available, err := businessTableAvailable(db, "tab_game")
+	available, err := approvedGamesAvailable(db)
 	if err != nil {
 		return nil, err
 	}
 	if !available {
 		return nil, business.ErrGameOptionsUnavailable
 	}
-	q := db.Table("tab_game")
-	if len(sources) > 0 {
-		q = q.Where("source_db IN ?", sources)
-	}
+	q := approvedGamesQuery(db, viewer, sources)
 	if keyword != "" {
-		q = q.Where("game_name LIKE ?", "%"+keyword+"%")
+		q = q.Where("INSTR(LOWER(g.game_name),?) > 0", strings.ToLower(keyword))
 	}
 	var rows []struct {
 		ID       uint64
 		SourceDB string `gorm:"column:source_db"`
 		GameName string
 	}
-	if err := q.Select("id,source_db,game_name").Order("game_name,id,source_db").Limit(limit).Scan(&rows).Error; err != nil {
+	if err := q.Select("g.id,g.source_db,g.game_name").Distinct().Order("g.game_name,g.id,g.source_db").Limit(limit).Scan(&rows).Error; err != nil {
 		return nil, business.ErrStorage
 	}
 	result := make([]*business.GameOption, 0, len(rows))