diff --git a/api/errcode/errcode.go b/api/errcode/errcode.go index 9e2545a7..fb786746 100644 --- a/api/errcode/errcode.go +++ b/api/errcode/errcode.go @@ -118,6 +118,7 @@ var ErrCodeMsgMap = map[ErrCode]string{ ErrCodeStreamerNotExist: "主播不存在", ErrCodeStreamerRecommListRedisCacheInvalid: "主播推荐服务redis缓存失效", ErrCodeStreamerDuplicateKey: "主播重复创建", + ErrCodeStreamerWxIdSetError: "主播微信号修改失败,禁止使用[wxid]开头初始微信号", ErrCodeFeedbackSrvFail: "意见反馈服务错误", ErrCodeFeedbackNotExist: "意见反馈不存在", @@ -439,6 +440,7 @@ const ( ErrCodeStreamerNotExist ErrCode = -13002 // 主播不存在 ErrCodeStreamerRecommListRedisCacheInvalid ErrCode = -13003 // 主播推荐服务redis缓存失效 ErrCodeStreamerDuplicateKey ErrCode = -13004 // 主播重复创建 + ErrCodeStreamerWxIdSetError ErrCode = -13005 // 主播禁止设置初始微信号 // Feedback: 14xxx ErrCodeFeedbackSrvOk ErrCode = ErrCodeOk diff --git a/app/mix/service/service.go b/app/mix/service/service.go index f69951e0..df2651fd 100644 --- a/app/mix/service/service.go +++ b/app/mix/service/service.go @@ -2415,6 +2415,10 @@ func (s *Service) OpCreateStreamer(ctx *gin.Context, req *streamerproto.OpCreate func (s *Service) OpUpdateStreamer(ctx *gin.Context, req *streamerproto.OpUpdateReq) (ec errcode.ErrCode) { ec = errcode.ErrCodeStreamerSrvOk + if strings.HasPrefix(req.GetWechatContact(), "wxid_") { + ec = errcode.ErrCodeStreamerWxIdSetError + return + } if ec = s.OpUpdateStreamerBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk { return diff --git a/dbstruct/streamer.go b/dbstruct/streamer.go index 69907dfc..eac7a950 100644 --- a/dbstruct/streamer.go +++ b/dbstruct/streamer.go @@ -89,3 +89,10 @@ func (p *Streamer) GetCity() string { } return *p.City } + +func (p *Streamer) GetWechatContact() string { + if p == nil || p.WechatContact == nil { + return "" + } + return *p.WechatContact +}