From d973389e9864b99973f3b8133a9357e4cbd17275 Mon Sep 17 00:00:00 2001
From: wangxinyu <wangxinyu4585@163.com>
Date: Mon, 9 Dec 2024 16:18:43 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=B8=BB=E6=92=AD=E5=BE=AE=E4=BF=A1?=
 =?UTF-8?q?=E5=8F=B7=E4=B8=8D=E8=83=BD=E8=AE=BE=E7=BD=AE[wxid]=E5=BC=80?=
 =?UTF-8?q?=E5=A4=B4=E7=9A=84=E5=88=9D=E5=A7=8B=E5=BE=AE=E4=BF=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 api/errcode/errcode.go     | 2 ++
 app/mix/service/service.go | 4 ++++
 dbstruct/streamer.go       | 7 +++++++
 3 files changed, 13 insertions(+)

diff --git a/api/errcode/errcode.go b/api/errcode/errcode.go
index 4daf4307..4c72ca8f 100644
--- a/api/errcode/errcode.go
+++ b/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
diff --git a/app/mix/service/service.go b/app/mix/service/service.go
index 1e02ef0a..a52494b9 100644
--- a/app/mix/service/service.go
+++ b/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
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
+}