Merge branch 'feature-wxid_filtration-wxy-20241209' into test

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

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

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