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

Merge pull request 'by Robin at 20230102; fix imageaudit' (#33) from fix-20230102-BUG0001-Robin into test 

Reviewed-on: #33
This commit is contained in:
chenhao 2024-01-02 16:49:45 +08:00
parent e5d6e1adbb ce47257020
commit 1b90e9fd44
1 changed files with 2 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -63,27 +63,6 @@ func (s *Service) CreateUpdateStreamerImageAudit(ctx *gin.Context, oldStreamer *
}, rollBackFunc)) }, rollBackFunc))
} }
// if newStreamer.Shorts != nil {
// rollBackFunc := func() error {
// return _DefaultStreamer.OpUpdate(ctx, &streamerproto.OpUpdateReq{
// Streamer: &dbstruct.Streamer{
// Uid: oldStreamer.Uid,
// Shorts: oldStreamer.Shorts,
// },
// })
// }
// tasks = append(tasks, imageaudit.NewImageAuditTaskControlBlock(&dbstruct.ImageAuditTask{
// RouteUrl: goproto.String(ctx.Request.URL.Path),
// AssociativeDatabase: goproto.String("streamer"),
// AssociativeTableName: goproto.String("streamer"),
// AssociativeTableId: oldStreamer.Id,
// AssociativeTableColumn: goproto.String("shorts"),
// AuditedMedia: newStreamer.Shorts,
// OldMedia: oldStreamer.Shorts,
// }, rollBackFunc))
// }
if newStreamer.Album != nil { if newStreamer.Album != nil {
rollBackFunc := func() error { rollBackFunc := func() error {
return _DefaultStreamer.OpUpdate(ctx, &streamerproto.OpUpdateReq{ return _DefaultStreamer.OpUpdate(ctx, &streamerproto.OpUpdateReq{
@ -138,7 +117,7 @@ func (s *Service) GetAccountUpdateImageFunc(ctx *gin.Context, column string, med
func (s *Service) GetStreamerUpdateImageFunc(ctx *gin.Context, column string, media *dbstruct.MediaComponent, id *int64) func() error { func (s *Service) GetStreamerUpdateImageFunc(ctx *gin.Context, column string, media *dbstruct.MediaComponent, id *int64) func() error {
switch column { switch column {
case "avatar": case "cover":
return func() error { return func() error {
return _DefaultStreamer.OpUpdate(ctx, &streamerproto.OpUpdateReq{ return _DefaultStreamer.OpUpdate(ctx, &streamerproto.OpUpdateReq{
Streamer: &dbstruct.Streamer{ Streamer: &dbstruct.Streamer{
@ -147,21 +126,12 @@ func (s *Service) GetStreamerUpdateImageFunc(ctx *gin.Context, column string, me
}, },
}) })
} }
// case "shorts":
// return func() error {
// return _DefaultStreamer.OpUpdate(ctx, &streamerproto.OpUpdateReq{
// Streamer: &dbstruct.Streamer{
// Uid: id,
// Shorts: media,
// },
// })
// }
case "album": case "album":
return func() error { return func() error {
return _DefaultStreamer.OpUpdate(ctx, &streamerproto.OpUpdateReq{ return _DefaultStreamer.OpUpdate(ctx, &streamerproto.OpUpdateReq{
Streamer: &dbstruct.Streamer{ Streamer: &dbstruct.Streamer{
Mid: id, Mid: id,
Cover: media, Album: media,
}, },
}) })
} }