wishpal_ironfan
/
service
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1

This commit is contained in:
Leufolium 2024-08-01 20:38:22 +08:00
parent bbb3f06e3a
commit 191123ca64
3 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/mix/service/imageauditservice.go
View File

@ -44,7 +44,7 @@ func (s *Service) CreateUpdateStreamerImageAudit(ctx *gin.Context, oldStreamer *
if newStreamer.Cover != nil && !util.IsInt64SliceEqualAsSet(oldStreamer.Cover.GetImageIds(), newStreamer.Cover.GetImageIds()) { if newStreamer.Cover != nil && !util.IsInt64SliceEqualAsSet(oldStreamer.Cover.GetImageIds(), newStreamer.Cover.GetImageIds()) {
tasks = append(tasks, &dbstruct.ImageAuditTask{ tasks = append(tasks, &dbstruct.ImageAuditTask{
Mid: newStreamer.Mid, Mid: oldStreamer.Mid,
RouteUrl: goproto.String(ctx.Request.URL.Path), RouteUrl: goproto.String(ctx.Request.URL.Path),
AssociativeDatabase: goproto.String("streamer"), AssociativeDatabase: goproto.String("streamer"),
AssociativeTableName: goproto.String("streamer"), AssociativeTableName: goproto.String("streamer"),
@ -57,7 +57,7 @@ func (s *Service) CreateUpdateStreamerImageAudit(ctx *gin.Context, oldStreamer *
if newStreamer.Album != nil && !util.IsInt64SliceEqualAsSet(oldStreamer.Album.GetImageIds(), newStreamer.Album.GetImageIds()) { if newStreamer.Album != nil && !util.IsInt64SliceEqualAsSet(oldStreamer.Album.GetImageIds(), newStreamer.Album.GetImageIds()) {
tasks = append(tasks, &dbstruct.ImageAuditTask{ tasks = append(tasks, &dbstruct.ImageAuditTask{
Mid: newStreamer.Mid, Mid: oldStreamer.Mid,
RouteUrl: goproto.String(ctx.Request.URL.Path), RouteUrl: goproto.String(ctx.Request.URL.Path),
AssociativeDatabase: goproto.String("streamer"), AssociativeDatabase: goproto.String("streamer"),
AssociativeTableName: goproto.String("streamer"), AssociativeTableName: goproto.String("streamer"),

9
app/mix/service/textauditservice.go
View File

@ -44,7 +44,7 @@ func (s *Service) CreateUpdateStreamerTextAudit(ctx *gin.Context, oldStreamer *d
if newStreamer.Bio != nil && oldStreamer.GetBio() != newStreamer.GetBio() { if newStreamer.Bio != nil && oldStreamer.GetBio() != newStreamer.GetBio() {
tasks = append(tasks, &dbstruct.TextAuditTask{ tasks = append(tasks, &dbstruct.TextAuditTask{
Mid: newStreamer.Mid, Mid: oldStreamer.Mid,
RouteUrl: goproto.String(ctx.Request.URL.Path), RouteUrl: goproto.String(ctx.Request.URL.Path),
AssociativeDatabase: goproto.String("streamer"), AssociativeDatabase: goproto.String("streamer"),
AssociativeTableName: goproto.String("streamer"), AssociativeTableName: goproto.String("streamer"),
@ -58,7 +58,7 @@ func (s *Service) CreateUpdateStreamerTextAudit(ctx *gin.Context, oldStreamer *d
if newStreamer.AutoResponseMessage != nil && oldStreamer.GetAutoResponseMessage() != newStreamer.GetAutoResponseMessage() { if newStreamer.AutoResponseMessage != nil && oldStreamer.GetAutoResponseMessage() != newStreamer.GetAutoResponseMessage() {
tasks = append(tasks, &dbstruct.TextAuditTask{ tasks = append(tasks, &dbstruct.TextAuditTask{
Mid: newStreamer.Mid, Mid: oldStreamer.Mid,
RouteUrl: goproto.String(ctx.Request.URL.Path), RouteUrl: goproto.String(ctx.Request.URL.Path),
AssociativeDatabase: goproto.String("streamer"), AssociativeDatabase: goproto.String("streamer"),
AssociativeTableName: goproto.String("streamer"), AssociativeTableName: goproto.String("streamer"),
@ -154,15 +154,18 @@ func (s *Service) CreateStreamerAuthApprovalDetailsTextAudit(ctx *gin.Context, n
func (s *Service) CreateZoneTextAudit(ctx *gin.Context, oldZone *dbstruct.Zone, newZone *dbstruct.Zone) (tasks []*dbstruct.TextAuditTask) { func (s *Service) CreateZoneTextAudit(ctx *gin.Context, oldZone *dbstruct.Zone, newZone *dbstruct.Zone) (tasks []*dbstruct.TextAuditTask) {
tasks = make([]*dbstruct.TextAuditTask, 0) tasks = make([]*dbstruct.TextAuditTask, 0)
midp := newZone.Mid
if newZone.Profile != nil { if newZone.Profile != nil {
oldTextPtr := goproto.String("") oldTextPtr := goproto.String("")
if oldZone != nil { if oldZone != nil {
oldTextPtr = oldZone.Profile oldTextPtr = oldZone.Profile
midp = oldZone.Mid
} }
tasks = append(tasks, &dbstruct.TextAuditTask{ tasks = append(tasks, &dbstruct.TextAuditTask{
Mid: newZone.Mid, Mid: midp,
RouteUrl: goproto.String(ctx.Request.URL.Path), RouteUrl: goproto.String(ctx.Request.URL.Path),
AssociativeDatabase: goproto.String("zone"), AssociativeDatabase: goproto.String("zone"),
AssociativeTableName: goproto.String("zone"), AssociativeTableName: goproto.String("zone"),

2
app/mix/service/video_moderation_service.go
View File

@ -17,7 +17,7 @@ func (s *Service) CreateUpdateStreamerVideoModeration(ctx *gin.Context, oldStrea
if newStreamer.Shorts != nil && !util.IsInt64SliceEqualAsSet(oldStreamer.Shorts.GetVideoIds(), newStreamer.Shorts.GetVideoIds()) { if newStreamer.Shorts != nil && !util.IsInt64SliceEqualAsSet(oldStreamer.Shorts.GetVideoIds(), newStreamer.Shorts.GetVideoIds()) {
tasks = append(tasks, &dbstruct.VideoModerationTask{ tasks = append(tasks, &dbstruct.VideoModerationTask{
Mid: newStreamer.Mid, Mid: oldStreamer.Mid,
RouteUrl: goproto.String(ctx.Request.URL.Path), RouteUrl: goproto.String(ctx.Request.URL.Path),
AssociativeDatabase: goproto.String("streamer"), AssociativeDatabase: goproto.String("streamer"),
AssociativeTableName: goproto.String("streamer"), AssociativeTableName: goproto.String("streamer"),