feat: manage global app release policies

server/internal/logic/sys/im_app_release.go

@@ -2,7 +2,12 @@ package sys
 
 import (
 	"context"
+	"fmt"
+
 	"hotgo/internal/consts"
+	"hotgo/internal/library/contexts"
+	"hotgo/internal/library/imkafka"
+	"hotgo/internal/library/imtenant"
 	"hotgo/internal/model/input/sysin"
 	"hotgo/internal/service"
 
@@ -26,10 +31,7 @@ func (s *sSysImAppRelease) List(ctx context.Context, in *sysin.ImAppReleaseListI
 	if err = in.Filter(ctx); err != nil {
 		return
 	}
-	db, tenant, err := resolveImTenantDB(ctx, in.TenantId)
-	if err != nil {
-		return
-	}
+	db := imtenant.RegistryDB()
 	if err = s.ensureDefaults(ctx, db); err != nil {
 		return
 	}
@@ -45,10 +47,6 @@ func (s *sSysImAppRelease) List(ctx context.Context, in *sysin.ImAppReleaseListI
 		err = gerror.Wrap(err, "获取IM客户端版本策略失败，请稍后重试！")
 		return
 	}
-	for _, item := range list {
-		item.TenantId = tenant.Id
-		item.TenantName = tenant.Name
-	}
 	return
 }
 
@@ -56,10 +54,7 @@ func (s *sSysImAppRelease) Edit(ctx context.Context, in *sysin.ImAppReleaseEditI
 	if err = in.Filter(ctx); err != nil {
 		return
 	}
-	db, tenant, err := resolveImTenantDB(ctx, in.TenantId)
-	if err != nil {
-		return
-	}
+	db := imtenant.RegistryDB()
 	if err = s.ensureDefaults(ctx, db); err != nil {
 		return
 	}
@@ -96,9 +91,17 @@ func (s *sSysImAppRelease) Edit(ctx context.Context, in *sysin.ImAppReleaseEditI
 		}
 		targetId = idValue.Int64()
 	}
-	_ = writeImAdminAudit(ctx, tenant.Id, action, "im_app_release", targetId, "success", g.Map{
+	_ = writeImAdminAudit(ctx, 0, action, "im_app_release", targetId, "success", g.Map{
 		"platform": in.Platform, "channel": in.Channel, "update_type": in.UpdateType,
 	})
+	if err = imkafka.PublishConfigEvent(ctx, imkafka.ConfigEventInput{
+		TenantCode: "*", EventType: "app.release.updated", Group: "app_release",
+		Keys: []string{in.Platform, in.Channel}, BizID: in.Platform + ":" + in.Channel,
+		Actor:     &imkafka.Actor{Type: "admin", ID: fmt.Sprint(contexts.GetUserId(ctx))},
+		CreatedBy: contexts.GetUserId(ctx),
+	}); err != nil {
+		g.Log().Warningf(ctx, "版本策略已保存，缓存失效事件等待 Outbox 重试: %v", err)
+	}
 	return nil
 }