fix:申请入驻接口增加微信昵称审核

api/errcode/errcode.go

@@ -117,6 +117,7 @@ var ErrCodeMsgMap = map[ErrCode]string{
 	ErrCodeStreamerNotExist:                    "主播不存在",
 	ErrCodeStreamerRecommListRedisCacheInvalid: "主播推荐服务redis缓存失效",
 	ErrCodeStreamerDuplicateKey:                "主播重复创建",
+	ErrCodeStreamerWxIdSetError:                "主播微信号修改失败，禁止使用[wxid]开头初始微信号",
 
 	ErrCodeFeedbackSrvFail:  "意见反馈服务错误",
 	ErrCodeFeedbackNotExist: "意见反馈不存在",
@@ -413,6 +414,7 @@ const (
 	ErrCodeStreamerNotExist                    ErrCode = -13002 // 主播不存在
 	ErrCodeStreamerRecommListRedisCacheInvalid ErrCode = -13003 // 主播推荐服务redis缓存失效
 	ErrCodeStreamerDuplicateKey                ErrCode = -13004 // 主播重复创建
+	ErrCodeStreamerWxIdSetError                ErrCode = -13005 // 主播禁止设置初始微信号
 
 	// Feedback: 14xxx
 	ErrCodeFeedbackSrvOk    ErrCode = ErrCodeOk

app/mix/service/apiservice.go

@@ -1160,6 +1160,11 @@ func (s *Service) ApiGetStreamerAuthApprovalBasicHisList(ctx *gin.Context, req *
 
 func (s *Service) ApiCreateStreamerAuthApprovalDetails(ctx *gin.Context, req *streamerauthapprovaldetailsproto.ApiCreateReq) (ec errcode.ErrCode) {
 	ec = errcode.ErrCodeStreamerAuthApprovalDetailsSrvOk
+	// 禁止设置[wxid_]开头的初始微信号
+	if strings.HasPrefix(req.GetWechatContact(), "wxid_") {
+		ec = errcode.ErrCodeStreamerWxIdSetError
+		return
+	}
 
 	if ec = s.ApiCreateStreamerAuthApprovalDetailsBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerAuthApprovalSrvOk {
 		return
@@ -1355,6 +1360,11 @@ func (s *Service) GetStreamerAuthApprovalStatuses(ctx *gin.Context, req *streame
 // Streamer
 func (s *Service) ApiUpdateStreamer(ctx *gin.Context, req *streamerproto.ApiUpdateReq) (ec errcode.ErrCode) {
 	ec = errcode.ErrCodeStreamerSrvOk
+	// 禁止设置[wxid_]开头的初始微信号
+	if strings.HasPrefix(req.GetWechatContact(), "wxid_") {
+		ec = errcode.ErrCodeStreamerWxIdSetError
+		return
+	}
 
 	if ec = s.ApiUpdateStreamerBusinessValidate(ctx, req); ec != errcode.ErrCodeStreamerSrvOk {
 		return

app/mix/service/service.go

@@ -2357,6 +2357,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

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
+}

dbstruct/streamerauthapproval.go

@@ -129,6 +129,13 @@ func (p *StreamerAuthApprovalDetails) GetApproveStatus() int64 {
 	return 0
 }
 
+func (p *StreamerAuthApprovalDetails) GetWechatContact() string {
+	if p == nil || p.WechatContact == nil {
+		return ""
+	}
+	return *p.WechatContact
+}
+
 type StreamerAuthApprovalVersion struct {
 	Id      int64 `json:"id" bson:"_id"`          //id,主播的mid
 	Version int64 `json:"version" bson:"version"` //版本号