hy/yumi-golang
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
hy001 2026-05-25 22:55:28 +08:00
parent 72c0d1d633
commit ee5b4f5eaf
1 changed files with 0 additions and 62 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
internal/service/highwin/admin.go
View File

@ -122,11 +122,6 @@ func (w *BroadcastSimulationWorker) Start(ctx context.Context, req ContinuousSim
if w == nil || w.db == nil || w.redis == nil || w.broadcaster == nil {
return nil, common.NewAppError(http.StatusInternalServerError, "simulation_worker_not_configured", "simulation worker is not configured")
}
normalizedRegionCodes, err := w.normalizeConfiguredRegionCodes(ctx, req.SysOrigin, req.RegionCodes)
if err != nil {
return nil, err
}
req.RegionCodes = normalizedRegionCodes
w.mu.Lock()
if w.cancel != nil {
@ -337,63 +332,6 @@ func (w *BroadcastSimulationWorker) sendContinuous(ctx context.Context, req Broa
return err
}
func (w *BroadcastSimulationWorker) normalizeConfiguredRegionCodes(ctx context.Context, sysOrigin string, values []string) ([]string, error) {
var rows []struct {
ID int64
RegionCode string
RegionName string
}
if err := w.db.WithContext(ctx).
Table("voice_room_region_im_group").
Select("id, region_code, region_name").
Where("sys_origin = ? AND status = ? AND group_id <> ?", sysOrigin, "ACTIVE", "").
Find(&rows).Error; err != nil {
return nil, err
}
lookup := map[string]string{}
for _, row := range rows {
code := strings.TrimSpace(row.RegionCode)
if code == "" {
continue
}
for _, key := range []string{
code,
row.RegionName,
strconv.FormatInt(row.ID, 10),
} {
key = strings.ToUpper(strings.TrimSpace(key))
if key != "" {
lookup[key] = code
}
}
}
seen := map[string]struct{}{}
result := make([]string, 0, len(values))
for _, value := range values {
raw := strings.TrimSpace(value)
code := lookup[strings.ToUpper(raw)]
if code == "" {
code = raw
}
if _, ok := lookup[strings.ToUpper(code)]; !ok {
continue
}
key := strings.ToUpper(strings.TrimSpace(code))
if key == "" {
continue
}
if _, exists := seen[key]; exists {
continue
}
seen[key] = struct{}{}
result = append(result, code)
}
if len(result) == 0 {
return nil, common.NewAppError(http.StatusBadRequest, "simulation_region_im_group_missing", "selected regions have no active region im group")
}
return result, nil
}
func (w *BroadcastSimulationWorker) randomOfflineUser(ctx context.Context, sysOrigin string, rng *rand.Rand) (int64, error) {
onlineIDs := w.onlineUserIDs(ctx, sysOrigin)
query := w.db.WithContext(ctx).