pro/im_manager
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: return default moderation policy when unpublished

Browse Source
This commit is contained in:
richjohnrambo
2026-09-16 23:30:10 +08:00
parent fec2a43b9c
commit 5173bc0aad
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/internal/controller/internalapi/imconfig/im_config.go
+9 -2
View File
@@ -162,12 +162,19 @@ func (c *cConfig) ModerationPolicy(ctx context.Context, req *api.ModerationPolic
PolicyVersion uint `json:"policy_version"` PolicyVersion uint `json:"policy_version"`
SensitiveWordPolicy string `json:"sensitive_word_policy"` SensitiveWordPolicy string `json:"sensitive_word_policy"`
} }
if err = imtenant.RegistryDB().Model(dao.ImSecurityPolicy.Table()).Safe().Ctx(ctx). record, err := imtenant.RegistryDB().Model(dao.ImSecurityPolicy.Table()).Safe().Ctx(ctx).
Fields(columns.PolicyVersion, "CAST("+columns.SensitiveWordPolicy+" AS CHAR) sensitive_word_policy"). Fields(columns.PolicyVersion, "CAST("+columns.SensitiveWordPolicy+" AS CHAR) sensitive_word_policy").
Where(columns.TenantId, tenant.Id).Where(columns.PublishStatus, consts.ImSecurityPublishPublished). Where(columns.TenantId, tenant.Id).Where(columns.PublishStatus, consts.ImSecurityPublishPublished).
WhereNull(columns.DeletedAt).OrderDesc(columns.PolicyVersion).Limit(1).Scan(&row); err != nil { WhereNull(columns.DeletedAt).OrderDesc(columns.PolicyVersion).One()
if err != nil {
return nil, gerror.Wrap(err, "获取商户内容审核策略失败") return nil, gerror.Wrap(err, "获取商户内容审核策略失败")
} }
if record.IsEmpty() {
return res, nil
}
if err = record.Struct(&row); err != nil {
return nil, gerror.Wrap(err, "解析商户内容审核策略失败")
}
if row.PolicyVersion == 0 || strings.TrimSpace(row.SensitiveWordPolicy) == "" { if row.PolicyVersion == 0 || strings.TrimSpace(row.SensitiveWordPolicy) == "" {
return res, nil return res, nil
} }