Merge branch 'yhg_250102' into debug

desc/wechat/whatsapp.api

@@ -58,6 +58,20 @@ type (
         GroupBlockList  []ContactInfo `json:"groupBlockList,optional"`
     }
 
+	WhatsappPhoneInfo {
+		Avatar  *string `json:"avatar,optional"`
+
+		Industry  *string `json:"industry,optional"`
+
+		Intro *string `json:"intro,optional"`
+
+		Address  *string `json:"address,optional"`
+
+		Email  *string `json:"email,optional"`
+
+		Website  *string `json:"website,optional"`
+	}
+
     // The response data of whatsapp list | Whatsapp列表数据
     WhatsappListResp {
         BaseDataInfo
@@ -96,12 +110,11 @@ type (
         Data WhatsappInfo `json:"data"`
     }
 
-	ConversationalAutomationReq {
+	AutomationReq {
 		WaId  *string `json:"waId,optional"`
-		Cc *string `json:"cc,optional"`
 		Phone  *string `json:"phone,optional"`
 	}
-	ConversationalAutomationResp {
+	AutomationResp {
 		BaseDataInfo
 
 		// Whatsapp list data | Whatsapp列表数据
@@ -117,6 +130,59 @@ type (
 		CommandDescription string `json:"commandDescription,optional"`
 		CommandName string `json:"commandName,optional"`
 	}
+	SetAutomationReq {
+		EnableWelcomeMessage bool `json:"enableWelcomeMessage,optional"`
+		PhoneNumber string `json:"phoneNumber,optional"`
+		Commands []Command `json:"commands,optional"`
+		Prompts []string `json:"prompts,optional"`
+		WaId string `json:"waId,optional"`
+	}
+
+	sendCodeReq {
+		Phone  *string `json:"phone"`
+		WaId  *string `json:"waId"`
+		Method *string `json:"method"`
+		Locale *string `json:"locale"`
+	}
+	submitCodeReq {
+		Phone  *string `json:"phone"`
+		WaId  *string `json:"waId"`
+		Code *string `json:"code"`
+	}
+	getQrcodeReq {
+		Phone  *string `json:"phone"`
+		WaId  *string `json:"waId"`
+	}
+	getQrcodeResp {
+		BaseDataInfo
+		Data []Qrcode `json:"data"`
+	}
+	Qrcode {
+		Phone string `json:"phone,optional"`
+		QrdlCode string `json:"qrdlCode,optional"`
+		GenerateQrImage string `json:"generateQrImage,optional"`
+		PrefilledMessage string `json:"prefilledMessage,optional"`
+		DeepLinkUrl string `json:"deepLinkUrl,optional"`
+		QrImageUrl string `json:"qrImageUrl,optional"`
+	}
+	createQrcodeReq {
+		Phone  string `json:"phone"`
+		GenerateQrImage string `json:"generateQrImage"`
+		PrefilledMessage string `json:"prefilledMessage"`
+		WaId  string `json:"waId"`
+	}
+	updateQrcodeReq {
+		Phone string `json:"phone,optional"`
+		GenerateQrImage string `json:"generateQrImage,optional"`
+		PrefilledMessage string `json:"prefilledMessage,optional"`
+		QrdlCode string `json:"qrdlCode,optional"`
+		WaId  string `json:"waId"`
+	}
+	removeQrcodeReq {
+		Phone string `json:"phone,optional"`
+		QrdlCode string `json:"qrdlCode,optional"`
+		WaId  string `json:"waId"`
+	}
 )
 
 @server(
@@ -132,7 +198,7 @@ service Wechat {
 
     // Update whatsapp information | 更新Whatsapp
     @handler updateWhatsapp
-    post /whatsapp/update (WhatsappInfo) returns (BaseMsgResp)
+    post /whatsapp/update (WhatsappPhoneInfo) returns (BaseMsgResp)
 
     // Delete whatsapp information | 删除Whatsapp信息
     @handler deleteWhatsapp
@@ -146,7 +212,35 @@ service Wechat {
     @handler getWhatsappById
     post /whatsapp (IDReq) returns (WhatsappInfoResp)
 
-	// Get whatsapp by ID | 通过ID获取Whatsapp
-	@handler GetConversationalAutomation
-	post /whatsapp/GetConversationalAutomation (ConversationalAutomationReq) returns (ConversationalAutomationResp)
+	// 发送验证码
+	@handler sendWhatsappCode
+	post /whatsapp/sendCode (sendCodeReq) returns (BaseMsgResp)
+
+	// 提交验证信息
+	@handler submitWhatsappCode
+	post /whatsapp/submitCode (submitCodeReq) returns (BaseMsgResp)
+
+	// 获取开场白
+	@handler getAutomation
+	post /whatsapp/getAutomation (AutomationReq) returns (AutomationResp)
+
+	// 编辑开场白
+	@handler setAutomation
+	post /whatsapp/setAutomation (SetAutomationReq) returns (BaseMsgResp)
+
+	// 获取二维码
+	@handler getQrcode
+	post /whatsapp/getQrcode (getQrcodeReq) returns (getQrcodeResp)
+
+	// 创建二维码
+	@handler createQrcode
+	post /whatsapp/createQrcode (createQrcodeReq) returns (BaseMsgResp)
+
+	// 删除二维码
+	@handler removeQrcode
+	post /whatsapp/removeQrcode (removeQrcodeReq) returns (BaseMsgResp)
+
+	// 修改二维码
+	@handler updateQrcode
+	post /whatsapp/updateQrcode (updateQrcodeReq) returns (BaseMsgResp)
 }

etc/wechat.yaml

@@ -6,8 +6,8 @@ Timeout: 30000
 Mode: "dev"
 
 Auth:
-  AccessSecret: LnQD46hBde0AgFXBer8ZZZe3FgC
-  AccessExpire: 259200
+  AccessSecret: jS6VKDtsJf3z1n2VKDtsJf3z1n2
+  AccessExpire: 2592000
 
 CROSConf:
   Address: '*'
@@ -17,7 +17,7 @@ Log:
   Mode: console
   Encoding: plain
   Stat: false
-  Path: /Users/songbowen/Downloads
+  Path: /tmp
   Level: info
   Compress: false
   KeepDays: 7
@@ -25,8 +25,8 @@ Log:
 
 DatabaseConf:
   Type: mysql
-  Host: localhost
-  Port: 3307
+  Host: mysql-server
+  Port: 3306
   DBName: wechat
   Username: root
   Password: simple-admin.
@@ -37,17 +37,17 @@ DatabaseConf:
 CoreRpc:
   # Target: k8s://default/core-rpc-svc:9101
   Endpoints:
-    - localhost:9101
+    - core-rpc:9101
   Enabled: true
 
 RedisConf:
-  Host: localhost:6380
+  Host: redis-server:6379
 
 CasbinDatabaseConf:
   Type: mysql
-  Host: localhost
-  Port: 3307
-  DBName: wechat-admin
+  Host: mysql-server
+  Port: 3306
+  DBName: wechat_admin
   Username: root
   Password: simple-admin.
   MaxOpenConn: 100
@@ -70,10 +70,18 @@ CasbinConf:
 Miniprogram:
   Appid: wx1452f34bba8fe718
   Secret: 171fdab212fdde0d51b59fa59c9ee070
-  redisaddr: redis-server:6379
+  Redisaddr: redis-server:6379
 
 Aliyun:
   ACCESS_KEY_ID: LTAI5tSJwCQyuaxXR3UxfnWw
   ACCESS_KEY_SECRET: 0pv4xhSPJv9IPSxrkB52FspJk27W7V
   OSS_ENDPOINT: sts.cn-beijing.aliyuncs.com
-  OSS_ROLEARN: acs:ram::1317798064750399:role/ramoss
+  OSS_ROLEARN: acs:ram::1317798064750399:role/ramoss
+
+Fastgpt:
+  BASE_URL: https://newapi.gkscrm.com/v1
+  API_KEY: sk-ZQRNypQOC8ID5WbpCdF263C58dF44271842e86D408Bb3848
+
+Xiaoice:
+  SubscriptionKey: ccaa5a6ff70f4393a934e69b9ace31bb
+  GptbotsAuthorization: app-hQL7oVq57McK5VBHlsMfhtUD

hook/aliyun/whatsapp.go

@@ -52,8 +52,8 @@ func GetCamsAppId() (string, error) {
 	return *isvResponse.Body.AppId, nil
 }
 
-// GetConversationalAutomation 获取号码欢迎消息、开场白和命令
-func GetConversationalAutomation(custSpaceId, phone string) (*cams20200606.GetConversationalAutomationResponse, error) {
+// GetAutomation 获取号码欢迎消息、开场白和命令
+func GetAutomation(custSpaceId, phone string) (*cams20200606.GetConversationalAutomationResponse, error) {
 	client, _err := CreateCamsClient()
 	if _err != nil {
 		return nil, _err
@@ -72,6 +72,31 @@ func GetConversationalAutomation(custSpaceId, phone string) (*cams20200606.GetCo
 	return response, nil
 }
 
+// SetAutomation 设置号码欢迎消息、开场白和命令
+func SetAutomation(custSpaceId, phone string, prompts []string) (*cams20200606.UpdateConversationalAutomationResponse, error) {
+	client, _err := CreateCamsClient()
+	if _err != nil {
+		return nil, _err
+	}
+
+	tmpPrompts := make([]*string, 0)
+	for _, v := range prompts {
+		tmpPrompts = append(tmpPrompts, &v)
+	}
+	request := &cams20200606.UpdateConversationalAutomationRequest{
+		CustSpaceId: tea.String(custSpaceId),
+		PhoneNumber: tea.String(phone),
+		Prompts:     tmpPrompts,
+	}
+
+	response, _err := client.UpdateConversationalAutomation(request)
+	if _err != nil {
+		return nil, _err
+	}
+
+	return response, nil
+}
+
 // AddCamsPhoneNumber 添加WhatsApp号码
 func AddCamsPhoneNumber(phone, cc, custSpaceId, verifiedName string) (*cams20200606.AddChatappPhoneNumberResponse, error) {
 	client, _err := CreateCamsClient()
@@ -93,3 +118,132 @@ func AddCamsPhoneNumber(phone, cc, custSpaceId, verifiedName string) (*cams20200
 
 	return response, nil
 }
+
+// SendCamsCode 发送验证码
+func SendCamsCode(phone, custSpaceId, method, locale string) (*cams20200606.GetChatappVerifyCodeResponse, error) {
+	client, _err := CreateCamsClient()
+	if _err != nil {
+		return nil, _err
+	}
+
+	request := &cams20200606.GetChatappVerifyCodeRequest{
+		PhoneNumber: tea.String(phone),
+		CustSpaceId: tea.String(custSpaceId),
+		Method:      tea.String(method),
+		Locale:      tea.String(locale),
+	}
+
+	response, _err := client.GetChatappVerifyCode(request)
+	if _err != nil {
+		return nil, _err
+	}
+
+	return response, nil
+}
+
+// SubmitCamsCode 提交验证信息
+func SubmitCamsCode(phone, code, custSpaceId string) (*cams20200606.ChatappVerifyAndRegisterResponse, error) {
+	client, _err := CreateCamsClient()
+	if _err != nil {
+		return nil, _err
+	}
+
+	request := &cams20200606.ChatappVerifyAndRegisterRequest{
+		PhoneNumber: tea.String(phone),
+		VerifyCode:  tea.String(code),
+		CustSpaceId: tea.String(custSpaceId),
+	}
+
+	response, _err := client.ChatappVerifyAndRegister(request)
+	if _err != nil {
+		return nil, _err
+	}
+
+	return response, nil
+}
+
+// GetCamsQrcode 获取二维码列表
+func GetCamsQrcode(phone, custSpaceId string) (*cams20200606.ListPhoneMessageQrdlResponse, error) {
+	client, _err := CreateCamsClient()
+	if _err != nil {
+		return nil, _err
+	}
+
+	request := &cams20200606.ListPhoneMessageQrdlRequest{
+		PhoneNumber: tea.String(phone),
+		CustSpaceId: tea.String(custSpaceId),
+	}
+
+	response, _err := client.ListPhoneMessageQrdl(request)
+	if _err != nil {
+		return nil, _err
+	}
+
+	return response, nil
+}
+
+// CreateCamsQrcode 创建二维码
+func CreateCamsQrcode(phone, custSpaceId, generateQrImage, prefilledMessage string) (*cams20200606.CreatePhoneMessageQrdlResponse, error) {
+	client, _err := CreateCamsClient()
+	if _err != nil {
+		return nil, _err
+	}
+
+	request := &cams20200606.CreatePhoneMessageQrdlRequest{
+		PhoneNumber:      tea.String(phone),
+		CustSpaceId:      tea.String(custSpaceId),
+		GenerateQrImage:  tea.String(generateQrImage),
+		PrefilledMessage: tea.String(prefilledMessage),
+	}
+
+	response, _err := client.CreatePhoneMessageQrdl(request)
+	if _err != nil {
+		return nil, _err
+	}
+
+	return response, nil
+}
+
+// UpdateCamsQrcode 修改二维码
+func UpdateCamsQrcode(phone, custSpaceId, generateQrImage, prefilledMessag, qrdlCode string) (*cams20200606.UpdatePhoneMessageQrdlResponse, error) {
+	client, _err := CreateCamsClient()
+	if _err != nil {
+		return nil, _err
+	}
+
+	request := &cams20200606.UpdatePhoneMessageQrdlRequest{
+		PhoneNumber:      tea.String(phone),
+		CustSpaceId:      tea.String(custSpaceId),
+		GenerateQrImage:  tea.String(generateQrImage),
+		PrefilledMessage: tea.String(prefilledMessag),
+		QrdlCode:         tea.String(qrdlCode),
+	}
+
+	response, _err := client.UpdatePhoneMessageQrdl(request)
+	if _err != nil {
+		return nil, _err
+	}
+
+	return response, nil
+}
+
+// RemoveCamsQrcode 删除二维码
+func RemoveCamsQrcode(phone, custSpaceId, qrdlCode string) (*cams20200606.DeletePhoneMessageQrdlResponse, error) {
+	client, _err := CreateCamsClient()
+	if _err != nil {
+		return nil, _err
+	}
+
+	request := &cams20200606.DeletePhoneMessageQrdlRequest{
+		PhoneNumber: tea.String(phone),
+		CustSpaceId: tea.String(custSpaceId),
+		QrdlCode:    tea.String(qrdlCode),
+	}
+
+	response, _err := client.DeletePhoneMessageQrdl(request)
+	if _err != nil {
+		return nil, _err
+	}
+
+	return response, nil
+}

internal/handler/routes.go

@@ -1806,8 +1806,43 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
 				},
 				{
 					Method:  http.MethodPost,
-					Path:    "/whatsapp/GetConversationalAutomation",
-					Handler: whatsapp.GetConversationalAutomationHandler(serverCtx),
+					Path:    "/whatsapp/sendCode",
+					Handler: whatsapp.SendWhatsappCodeHandler(serverCtx),
+				},
+				{
+					Method:  http.MethodPost,
+					Path:    "/whatsapp/submitCode",
+					Handler: whatsapp.SubmitWhatsappCodeHandler(serverCtx),
+				},
+				{
+					Method:  http.MethodPost,
+					Path:    "/whatsapp/getAutomation",
+					Handler: whatsapp.GetAutomationHandler(serverCtx),
+				},
+				{
+					Method:  http.MethodPost,
+					Path:    "/whatsapp/setAutomation",
+					Handler: whatsapp.SetAutomationHandler(serverCtx),
+				},
+				{
+					Method:  http.MethodPost,
+					Path:    "/whatsapp/getQrcode",
+					Handler: whatsapp.GetQrcodeHandler(serverCtx),
+				},
+				{
+					Method:  http.MethodPost,
+					Path:    "/whatsapp/createQrcode",
+					Handler: whatsapp.CreateQrcodeHandler(serverCtx),
+				},
+				{
+					Method:  http.MethodPost,
+					Path:    "/whatsapp/removeQrcode",
+					Handler: whatsapp.RemoveQrcodeHandler(serverCtx),
+				},
+				{
+					Method:  http.MethodPost,
+					Path:    "/whatsapp/updateQrcode",
+					Handler: whatsapp.UpdateQrcodeHandler(serverCtx),
 				},
 			}...,
 		),

internal/handler/whatsapp/get_conversational_automation_handler.go → internal/handler/whatsapp/create_qrcode_handler.go

@@ -10,31 +10,31 @@ import (
 	"wechat-api/internal/types"
 )
 
-// swagger:route post /whatsapp/GetConversationalAutomation whatsapp GetConversationalAutomation
+// swagger:route post /whatsapp/createQrcode whatsapp CreateQrcode
 //
-// Get whatsapp by ID | 通过ID获取Whatsapp
+// 创建二维码
 //
-// Get whatsapp by ID | 通过ID获取Whatsapp
+// 创建二维码
 //
 // Parameters:
 //  + name: body
 //    require: true
 //    in: body
-//    type: ConversationalAutomationReq
+//    type: createQrcodeReq
 //
 // Responses:
-//  200: WhatsappInfoResp
+//  200: BaseMsgResp
 
-func GetConversationalAutomationHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+func CreateQrcodeHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
-		var req types.ConversationalAutomationReq
+		var req types.CreateQrcodeReq
 		if err := httpx.Parse(r, &req, true); err != nil {
 			httpx.ErrorCtx(r.Context(), w, err)
 			return
 		}
 
-		l := whatsapp.NewGetConversationalAutomationLogic(r.Context(), svcCtx)
-		resp, err := l.GetConversationalAutomation(&req)
+		l := whatsapp.NewCreateQrcodeLogic(r.Context(), svcCtx)
+		resp, err := l.CreateQrcode(&req)
 		if err != nil {
 			httpx.ErrorCtx(r.Context(), w, err)
 		} else {

internal/handler/whatsapp/get_automation_handler.go

@@ -0,0 +1,44 @@
+package whatsapp
+
+import (
+	"net/http"
+
+	"github.com/zeromicro/go-zero/rest/httpx"
+
+	"wechat-api/internal/logic/whatsapp"
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+)
+
+// swagger:route post /whatsapp/getAutomation whatsapp GetAutomation
+//
+// 获取开场白
+//
+// 获取开场白
+//
+// Parameters:
+//  + name: body
+//    require: true
+//    in: body
+//    type: AutomationReq
+//
+// Responses:
+//  200: AutomationResp
+
+func GetAutomationHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.AutomationReq
+		if err := httpx.Parse(r, &req, true); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := whatsapp.NewGetAutomationLogic(r.Context(), svcCtx)
+		resp, err := l.GetAutomation(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

internal/handler/whatsapp/get_qrcode_handler.go

@@ -0,0 +1,44 @@
+package whatsapp
+
+import (
+	"net/http"
+
+	"github.com/zeromicro/go-zero/rest/httpx"
+
+	"wechat-api/internal/logic/whatsapp"
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+)
+
+// swagger:route post /whatsapp/getQrcode whatsapp GetQrcode
+//
+// 获取二维码
+//
+// 获取二维码
+//
+// Parameters:
+//  + name: body
+//    require: true
+//    in: body
+//    type: getQrcodeReq
+//
+// Responses:
+//  200: getQrcodeResp
+
+func GetQrcodeHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.GetQrcodeReq
+		if err := httpx.Parse(r, &req, true); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := whatsapp.NewGetQrcodeLogic(r.Context(), svcCtx)
+		resp, err := l.GetQrcode(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

internal/handler/whatsapp/remove_qrcode_handler.go

@@ -0,0 +1,44 @@
+package whatsapp
+
+import (
+	"net/http"
+
+	"github.com/zeromicro/go-zero/rest/httpx"
+
+	"wechat-api/internal/logic/whatsapp"
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+)
+
+// swagger:route post /whatsapp/removeQrcode whatsapp RemoveQrcode
+//
+// 删除二维码
+//
+// 删除二维码
+//
+// Parameters:
+//  + name: body
+//    require: true
+//    in: body
+//    type: removeQrcodeReq
+//
+// Responses:
+//  200: BaseMsgResp
+
+func RemoveQrcodeHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.RemoveQrcodeReq
+		if err := httpx.Parse(r, &req, true); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := whatsapp.NewRemoveQrcodeLogic(r.Context(), svcCtx)
+		resp, err := l.RemoveQrcode(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

internal/handler/whatsapp/send_whatsapp_code_handler.go

@@ -0,0 +1,44 @@
+package whatsapp
+
+import (
+	"net/http"
+
+	"github.com/zeromicro/go-zero/rest/httpx"
+
+	"wechat-api/internal/logic/whatsapp"
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+)
+
+// swagger:route post /whatsapp/sendCode whatsapp SendWhatsappCode
+//
+// 发送验证码
+//
+// 发送验证码
+//
+// Parameters:
+//  + name: body
+//    require: true
+//    in: body
+//    type: sendCodeReq
+//
+// Responses:
+//  200: BaseMsgResp
+
+func SendWhatsappCodeHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.SendCodeReq
+		if err := httpx.Parse(r, &req, true); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := whatsapp.NewSendWhatsappCodeLogic(r.Context(), svcCtx)
+		resp, err := l.SendWhatsappCode(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

internal/handler/whatsapp/set_automation_handler.go

@@ -0,0 +1,44 @@
+package whatsapp
+
+import (
+	"net/http"
+
+	"github.com/zeromicro/go-zero/rest/httpx"
+
+	"wechat-api/internal/logic/whatsapp"
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+)
+
+// swagger:route post /whatsapp/setAutomation whatsapp SetAutomation
+//
+// 编辑开场白
+//
+// 编辑开场白
+//
+// Parameters:
+//  + name: body
+//    require: true
+//    in: body
+//    type: SetAutomationReq
+//
+// Responses:
+//  200: BaseMsgResp
+
+func SetAutomationHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.SetAutomationReq
+		if err := httpx.Parse(r, &req, true); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := whatsapp.NewSetAutomationLogic(r.Context(), svcCtx)
+		resp, err := l.SetAutomation(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

internal/handler/whatsapp/submit_whatsapp_code_handler.go

@@ -0,0 +1,44 @@
+package whatsapp
+
+import (
+	"net/http"
+
+	"github.com/zeromicro/go-zero/rest/httpx"
+
+	"wechat-api/internal/logic/whatsapp"
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+)
+
+// swagger:route post /whatsapp/submitCode whatsapp SubmitWhatsappCode
+//
+// 提交验证信息
+//
+// 提交验证信息
+//
+// Parameters:
+//  + name: body
+//    require: true
+//    in: body
+//    type: submitCodeReq
+//
+// Responses:
+//  200: BaseMsgResp
+
+func SubmitWhatsappCodeHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.SubmitCodeReq
+		if err := httpx.Parse(r, &req, true); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := whatsapp.NewSubmitWhatsappCodeLogic(r.Context(), svcCtx)
+		resp, err := l.SubmitWhatsappCode(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

internal/handler/whatsapp/update_qrcode_handler.go

@@ -0,0 +1,44 @@
+package whatsapp
+
+import (
+	"net/http"
+
+	"github.com/zeromicro/go-zero/rest/httpx"
+
+	"wechat-api/internal/logic/whatsapp"
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+)
+
+// swagger:route post /whatsapp/updateQrcode whatsapp UpdateQrcode
+//
+// 修改二维码
+//
+// 修改二维码
+//
+// Parameters:
+//  + name: body
+//    require: true
+//    in: body
+//    type: updateQrcodeReq
+//
+// Responses:
+//  200: BaseMsgResp
+
+func UpdateQrcodeHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.UpdateQrcodeReq
+		if err := httpx.Parse(r, &req, true); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := whatsapp.NewUpdateQrcodeLogic(r.Context(), svcCtx)
+		resp, err := l.UpdateQrcode(&req)
+		if err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+		} else {
+			httpx.OkJsonCtx(r.Context(), w, resp)
+		}
+	}
+}

internal/handler/whatsapp/update_whatsapp_handler.go

@@ -27,7 +27,7 @@ import (
 
 func UpdateWhatsappHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
-		var req types.WhatsappInfo
+		var req types.WhatsappPhoneInfo
 		if err := httpx.Parse(r, &req, true); err != nil {
 			httpx.ErrorCtx(r.Context(), w, err)
 			return

internal/logic/whatsapp/create_qrcode_logic.go

@@ -0,0 +1,38 @@
+package whatsapp
+
+import (
+	"context"
+	"wechat-api/hook/aliyun"
+
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type CreateQrcodeLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewCreateQrcodeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateQrcodeLogic {
+	return &CreateQrcodeLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx}
+}
+
+func (l *CreateQrcodeLogic) CreateQrcode(req *types.CreateQrcodeReq) (*types.BaseMsgResp, error) {
+	resp := types.BaseMsgResp{Msg: "创建成功"}
+
+	_, err := aliyun.CreateCamsQrcode(req.Phone, req.WaId, req.GenerateQrImage, req.PrefilledMessage)
+	l.Logger.Infof("create qrcode err:%v\n", err)
+
+	if err != nil {
+		resp.Msg = err.Error()
+		resp.Code = 1
+	}
+
+	return &resp, nil
+}

internal/logic/whatsapp/create_whatsapp_logic.go

@@ -2,11 +2,6 @@ package whatsapp
 
 import (
 	"context"
-	"wechat-api/ent"
-	"wechat-api/ent/whatsapp"
-	"wechat-api/internal/utils/dberrorhandler"
-
-	"github.com/suyuan32/simple-admin-common/msg/errormsg"
 	"wechat-api/hook/aliyun"
 	"wechat-api/internal/svc"
 	"wechat-api/internal/types"
@@ -29,42 +24,47 @@ func NewCreateWhatsappLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Cr
 }
 
 func (l *CreateWhatsappLogic) CreateWhatsapp(req *types.WhatsappInfo) (*types.BaseMsgResp, error) {
-	add, err := aliyun.AddCamsPhoneNumber(*req.PhoneName, *req.Cc, *req.WaId, *req.PhoneName)
-	//l.Logger.Infof("add=%v err=%v\n", add, err)
-	if err == nil && *add.Body.Code == "OK" {
-		var stringSlice []string
-
-		_, err := l.svcCtx.DB.Whatsapp.Query().
-			Where(whatsapp.WaID(*req.WaId)).
-			Where(whatsapp.Phone(*req.Phone)).
-			Where(whatsapp.Cc(*req.Cc)).
-			First(l.ctx)
-		if err != nil && ent.IsNotFound(err) {
-			_, err = l.svcCtx.DB.Whatsapp.Create().
-				SetNotNilWaID(req.WaId).
-				SetNotNilCallback(req.Callback).
-				SetNotNilAccount(req.Account).
-				SetNotNilPhone(req.Phone).
-				SetNotNilCc(req.Cc).
-				SetNotNilPhoneName(req.PhoneName).
-				SetNotNilPhoneStatus(req.PhoneStatus).
-				SetNotNilOrganizationID(req.OrganizationId).
-				SetNotNilAgentID(req.AgentId).
-				SetNotNilAPIBase(req.ApiBase).
-				SetNotNilAPIKey(req.ApiKey).
-				SetNotNilAllowList(stringSlice).
-				SetNotNilGroupAllowList(stringSlice).
-				SetNotNilBlockList(stringSlice).
-				SetNotNilGroupBlockList(stringSlice).
-				Save(l.ctx)
+	add, err := aliyun.AddCamsPhoneNumber(*req.Phone, *req.Cc, *req.WaId, *req.PhoneName)
+	l.Logger.Infof("add=%v err=%v\n", add, err)
+	//if err == nil && *add.Body.Code == "OK" {
+	//	var stringSlice []string
+	//
+	//	_, err := l.svcCtx.DB.Whatsapp.Query().
+	//		Where(whatsapp.WaID(*req.WaId)).
+	//		Where(whatsapp.Phone(*req.Phone)).
+	//		Where(whatsapp.Cc(*req.Cc)).
+	//		First(l.ctx)
+	//	if err != nil && ent.IsNotFound(err) {
+	//		_, err = l.svcCtx.DB.Whatsapp.Create().
+	//			SetNotNilWaID(req.WaId).
+	//			SetNotNilCallback(req.Callback).
+	//			SetNotNilAccount(req.Account).
+	//			SetNotNilPhone(req.Phone).
+	//			SetNotNilCc(req.Cc).
+	//			SetNotNilPhoneName(req.PhoneName).
+	//			SetNotNilPhoneStatus(req.PhoneStatus).
+	//			SetNotNilOrganizationID(req.OrganizationId).
+	//			SetNotNilAgentID(req.AgentId).
+	//			SetNotNilAPIBase(req.ApiBase).
+	//			SetNotNilAPIKey(req.ApiKey).
+	//			SetNotNilAllowList(stringSlice).
+	//			SetNotNilGroupAllowList(stringSlice).
+	//			SetNotNilBlockList(stringSlice).
+	//			SetNotNilGroupBlockList(stringSlice).
+	//			Save(l.ctx)
+	//
+	//		if err != nil {
+	//			return nil, dberrorhandler.DefaultEntError(l.Logger, err, req)
+	//		}
+	//	}
+	//}
 
-			if err != nil {
-				return nil, dberrorhandler.DefaultEntError(l.Logger, err, req)
-			}
-		}
+	resp := types.BaseMsgResp{}
+	if err != nil {
+		resp.Msg = err.Error()
+		resp.Code = 1
+	} else {
+		resp.Msg = "添加成功"
 	}
-
-	_ = l.svcCtx.Rds.Del(l.ctx, "wa_info")
-
-	return &types.BaseMsgResp{Msg: errormsg.CreateSuccess}, nil
+	return &resp, nil
 }

internal/logic/whatsapp/get_automation_logic.go

@@ -0,0 +1,58 @@
+package whatsapp
+
+import (
+	"context"
+	"wechat-api/hook/aliyun"
+
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GetAutomationLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewGetAutomationLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetAutomationLogic {
+	return &GetAutomationLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx}
+}
+
+func (l *GetAutomationLogic) GetAutomation(req *types.AutomationReq) (*types.AutomationResp, error) {
+	resp := types.AutomationResp{}
+	automation, err := aliyun.GetAutomation(*req.WaId, *req.Phone)
+	l.Logger.Infof("automation=%v err=%v\n", automation, err)
+	if err != nil {
+		resp.Msg = err.Error()
+		resp.Code = 1
+	}
+
+	// 获取内容并赋值
+	if automation.Body.Data.Commands != nil {
+		for _, v := range automation.Body.Data.Commands {
+			resp.Data.Commands = append(resp.Data.Commands, types.Command{
+				CommandDescription: *v.CommandDescription,
+				CommandName:        *v.CommandName,
+			})
+		}
+	}
+	if automation.Body.Data.Commands != nil {
+		for _, v := range automation.Body.Data.Prompts {
+			resp.Data.Prompts = append(resp.Data.Prompts, *v)
+		}
+	}
+	if automation.Body.Data.PhoneNumber != nil {
+		resp.Data.PhoneNumber = *automation.Body.Data.PhoneNumber
+	}
+
+	if automation.Body.Data.EnableWelcomeMessage != nil {
+		resp.Data.EnableWelcomeMessage = *automation.Body.Data.EnableWelcomeMessage
+	}
+
+	return &resp, nil
+}

internal/logic/whatsapp/get_conversational_automation_logic.go

@@ -1,37 +0,0 @@
-package whatsapp
-
-import (
-	"context"
-	"wechat-api/hook/aliyun"
-
-	"wechat-api/internal/svc"
-	"wechat-api/internal/types"
-
-	"github.com/zeromicro/go-zero/core/logx"
-)
-
-type GetConversationalAutomationLogic struct {
-	logx.Logger
-	ctx    context.Context
-	svcCtx *svc.ServiceContext
-}
-
-func NewGetConversationalAutomationLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetConversationalAutomationLogic {
-	return &GetConversationalAutomationLogic{
-		Logger: logx.WithContext(ctx),
-		ctx:    ctx,
-		svcCtx: svcCtx}
-}
-
-func (l *GetConversationalAutomationLogic) GetConversationalAutomation(req *types.ConversationalAutomationReq) (*types.ConversationalAutomationResp, error) {
-	phone := *req.Cc + *req.Phone
-	response, err := aliyun.GetConversationalAutomation(*req.WaId, phone)
-
-	resp := types.ConversationalAutomationResp{}
-	if err == nil && *response.Body.Code == "OK" {
-		//resp.Data.Commands = response.Body.Data.Commands
-
-	}
-
-	return &resp, nil
-}

internal/logic/whatsapp/get_qrcode_logic.go

@@ -0,0 +1,55 @@
+package whatsapp
+
+import (
+	"context"
+	"wechat-api/hook/aliyun"
+
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type GetQrcodeLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewGetQrcodeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetQrcodeLogic {
+	return &GetQrcodeLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx}
+}
+
+func (l *GetQrcodeLogic) GetQrcode(req *types.GetQrcodeReq) (*types.GetQrcodeResp, error) {
+	resp := types.GetQrcodeResp{}
+	result, err := aliyun.GetCamsQrcode(*req.Phone, *req.WaId)
+	l.Logger.Infof("result=%v err=%v\n", result, err)
+
+	if err != nil {
+		resp.Msg = err.Error()
+		resp.Code = 1
+	} else {
+		if result.Body.Data != nil {
+			for _, v := range result.Body.Data {
+				generateQrImage := "PNG"
+				if v.GenerateQrImage != nil {
+					generateQrImage = *v.GenerateQrImage
+				}
+
+				resp.Data = append(resp.Data, types.Qrcode{
+					Phone:            *v.PhoneNumber,
+					QrdlCode:         *v.QrdlCode,
+					GenerateQrImage:  generateQrImage,
+					PrefilledMessage: *v.PrefilledMessage,
+					DeepLinkUrl:      *v.DeepLinkUrl,
+					QrImageUrl:       *v.QrImageUrl,
+				})
+			}
+		}
+	}
+
+	return &resp, nil
+}

internal/logic/whatsapp/remove_qrcode_logic.go

@@ -0,0 +1,38 @@
+package whatsapp
+
+import (
+	"context"
+	"wechat-api/hook/aliyun"
+
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type RemoveQrcodeLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewRemoveQrcodeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RemoveQrcodeLogic {
+	return &RemoveQrcodeLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx}
+}
+
+func (l *RemoveQrcodeLogic) RemoveQrcode(req *types.RemoveQrcodeReq) (*types.BaseMsgResp, error) {
+	resp := types.BaseMsgResp{Msg: "删除成功"}
+
+	_, err := aliyun.RemoveCamsQrcode(req.Phone, req.WaId, req.QrdlCode)
+	l.Logger.Infof("remove qrcode err:%v\n", err)
+
+	if err != nil {
+		resp.Msg = err.Error()
+		resp.Code = 1
+	}
+
+	return &resp, nil
+}

internal/logic/whatsapp/send_whatsapp_code_logic.go

@@ -0,0 +1,39 @@
+package whatsapp
+
+import (
+	"context"
+	"wechat-api/hook/aliyun"
+
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type SendWhatsappCodeLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewSendWhatsappCodeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SendWhatsappCodeLogic {
+	return &SendWhatsappCodeLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx}
+}
+
+func (l *SendWhatsappCodeLogic) SendWhatsappCode(req *types.SendCodeReq) (*types.BaseMsgResp, error) {
+	resp := types.BaseMsgResp{}
+	_, err := aliyun.SendCamsCode(*req.Phone, *req.WaId, *req.Method, *req.Locale)
+	l.Logger.Infof("err=%v\n", err)
+
+	if err != nil {
+		resp.Msg = err.Error()
+		resp.Code = 1
+	} else {
+		resp.Msg = "发送成功"
+	}
+
+	return &resp, nil
+}

internal/logic/whatsapp/set_automation_logic.go

@@ -0,0 +1,36 @@
+package whatsapp
+
+import (
+	"context"
+	"wechat-api/hook/aliyun"
+
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type SetAutomationLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewSetAutomationLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SetAutomationLogic {
+	return &SetAutomationLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx}
+}
+
+func (l *SetAutomationLogic) SetAutomation(req *types.SetAutomationReq) (*types.BaseMsgResp, error) {
+	resp := types.BaseMsgResp{}
+	_, err := aliyun.SetAutomation(req.WaId, req.PhoneNumber, req.Prompts)
+
+	if err != nil {
+		resp.Code = 1
+		resp.Msg = err.Error()
+	}
+
+	return &resp, nil
+}

internal/logic/whatsapp/submit_whatsapp_code_logic.go

@@ -0,0 +1,36 @@
+package whatsapp
+
+import (
+	"context"
+	"wechat-api/hook/aliyun"
+
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type SubmitWhatsappCodeLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewSubmitWhatsappCodeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SubmitWhatsappCodeLogic {
+	return &SubmitWhatsappCodeLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx}
+}
+
+func (l *SubmitWhatsappCodeLogic) SubmitWhatsappCode(req *types.SubmitCodeReq) (*types.BaseMsgResp, error) {
+	resp := types.BaseMsgResp{}
+	_, err := aliyun.SubmitCamsCode(*req.Phone, *req.Code, *req.WaId)
+
+	if err != nil {
+		resp.Msg = err.Error()
+		resp.Code = 1
+	}
+
+	return &resp, nil
+}

internal/logic/whatsapp/update_qrcode_logic.go

@@ -0,0 +1,38 @@
+package whatsapp
+
+import (
+	"context"
+	"wechat-api/hook/aliyun"
+
+	"wechat-api/internal/svc"
+	"wechat-api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type UpdateQrcodeLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewUpdateQrcodeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateQrcodeLogic {
+	return &UpdateQrcodeLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx}
+}
+
+func (l *UpdateQrcodeLogic) UpdateQrcode(req *types.UpdateQrcodeReq) (*types.BaseMsgResp, error) {
+	resp := types.BaseMsgResp{Msg: "修改成功"}
+
+	_, err := aliyun.UpdateCamsQrcode(req.Phone, req.WaId, req.GenerateQrImage, req.PrefilledMessage, req.QrdlCode)
+	l.Logger.Infof("update qrcode err:%v\n", err)
+
+	if err != nil {
+		resp.Msg = err.Error()
+		resp.Code = 1
+	}
+
+	return &resp, nil
+}

internal/logic/whatsapp/update_whatsapp_logic.go

@@ -3,12 +3,9 @@ package whatsapp
 import (
 	"context"
 
+	"github.com/zeromicro/go-zero/core/logx"
 	"wechat-api/internal/svc"
 	"wechat-api/internal/types"
-	"wechat-api/internal/utils/dberrorhandler"
-
-	"github.com/suyuan32/simple-admin-common/msg/errormsg"
-	"github.com/zeromicro/go-zero/core/logx"
 )
 
 type UpdateWhatsappLogic struct {
@@ -25,25 +22,8 @@ func NewUpdateWhatsappLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Up
 	}
 }
 
-func (l *UpdateWhatsappLogic) UpdateWhatsapp(req *types.WhatsappInfo) (*types.BaseMsgResp, error) {
-	err := l.svcCtx.DB.Whatsapp.UpdateOneID(*req.Id).
-		SetNotNilWaID(req.WaId).
-		SetNotNilCallback(req.Callback).
-		SetNotNilAccount(req.Account).
-		SetNotNilPhone(req.Phone).
-		SetNotNilPhoneName(req.PhoneName).
-		SetNotNilPhoneStatus(req.PhoneStatus).
-		SetNotNilOrganizationID(req.OrganizationId).
-		SetNotNilAgentID(req.AgentId).
-		SetNotNilAPIBase(req.ApiBase).
-		SetNotNilAPIKey(req.ApiKey).
-		Exec(l.ctx)
-
-	if err != nil {
-		return nil, dberrorhandler.DefaultEntError(l.Logger, err, req)
-	}
-
-	_ = l.svcCtx.Rds.Del(l.ctx, "wa_info")
+func (l *UpdateWhatsappLogic) UpdateWhatsapp(req *types.WhatsappPhoneInfo) (*types.BaseMsgResp, error) {
+	resp := types.BaseMsgResp{}
 
-	return &types.BaseMsgResp{Msg: errormsg.UpdateSuccess}, nil
+	return &resp, nil
 }

internal/types/types.go

@@ -3449,6 +3449,16 @@ type WhatsappInfo struct {
 	GroupBlockList []ContactInfo `json:"groupBlockList,optional"`
 }
 
+// swagger:model WhatsappPhoneInfo
+type WhatsappPhoneInfo struct {
+	Avatar   *string `json:"avatar,optional"`
+	Industry *string `json:"industry,optional"`
+	Intro    *string `json:"intro,optional"`
+	Address  *string `json:"address,optional"`
+	Email    *string `json:"email,optional"`
+	Website  *string `json:"website,optional"`
+}
+
 // The response data of whatsapp list | Whatsapp列表数据
 // swagger:model WhatsappListResp
 type WhatsappListResp struct {
@@ -3485,15 +3495,14 @@ type WhatsappInfoResp struct {
 	Data WhatsappInfo `json:"data"`
 }
 
-// swagger:model ConversationalAutomationReq
-type ConversationalAutomationReq struct {
+// swagger:model AutomationReq
+type AutomationReq struct {
 	WaId  *string `json:"waId,optional"`
-	Cc    *string `json:"cc,optional"`
 	Phone *string `json:"phone,optional"`
 }
 
-// swagger:model ConversationalAutomationResp
-type ConversationalAutomationResp struct {
+// swagger:model AutomationResp
+type AutomationResp struct {
 	BaseDataInfo
 	// Whatsapp list data | Whatsapp列表数据
 	Data ConversationalAutomationInfo `json:"data"`
@@ -3512,6 +3521,75 @@ type Command struct {
 	CommandName        string `json:"commandName,optional"`
 }
 
+// swagger:model SetAutomationReq
+type SetAutomationReq struct {
+	EnableWelcomeMessage bool      `json:"enableWelcomeMessage,optional"`
+	PhoneNumber          string    `json:"phoneNumber,optional"`
+	Commands             []Command `json:"commands,optional"`
+	Prompts              []string  `json:"prompts,optional"`
+	WaId                 string    `json:"waId,optional"`
+}
+
+// swagger:model sendCodeReq
+type SendCodeReq struct {
+	Phone  *string `json:"phone"`
+	WaId   *string `json:"waId"`
+	Method *string `json:"method"`
+	Locale *string `json:"locale"`
+}
+
+// swagger:model submitCodeReq
+type SubmitCodeReq struct {
+	Phone *string `json:"phone"`
+	WaId  *string `json:"waId"`
+	Code  *string `json:"code"`
+}
+
+// swagger:model getQrcodeReq
+type GetQrcodeReq struct {
+	Phone *string `json:"phone"`
+	WaId  *string `json:"waId"`
+}
+
+// swagger:model getQrcodeResp
+type GetQrcodeResp struct {
+	BaseDataInfo
+	Data []Qrcode `json:"data"`
+}
+
+type Qrcode struct {
+	Phone            string `json:"phone,optional"`
+	QrdlCode         string `json:"qrdlCode,optional"`
+	GenerateQrImage  string `json:"generateQrImage,optional"`
+	PrefilledMessage string `json:"prefilledMessage,optional"`
+	DeepLinkUrl      string `json:"deepLinkUrl,optional"`
+	QrImageUrl       string `json:"qrImageUrl,optional"`
+}
+
+// swagger:model createQrcodeReq
+type CreateQrcodeReq struct {
+	Phone            string `json:"phone"`
+	GenerateQrImage  string `json:"generateQrImage"`
+	PrefilledMessage string `json:"prefilledMessage"`
+	WaId             string `json:"waId"`
+}
+
+// swagger:model updateQrcodeReq
+type UpdateQrcodeReq struct {
+	Phone            string `json:"phone,optional"`
+	GenerateQrImage  string `json:"generateQrImage,optional"`
+	PrefilledMessage string `json:"prefilledMessage,optional"`
+	QrdlCode         string `json:"qrdlCode,optional"`
+	WaId             string `json:"waId"`
+}
+
+// swagger:model removeQrcodeReq
+type RemoveQrcodeReq struct {
+	Phone    string `json:"phone,optional"`
+	QrdlCode string `json:"qrdlCode,optional"`
+	WaId     string `json:"waId"`
+}
+
 // The data of whatsapp channel information | WhatsappChannel信息
 // swagger:model WhatsappChannelInfo
 type WhatsappChannelInfo struct {