wechat-api/internal/pkg/wechat_ws/test/main.go

package main

import (
	"github.com/zeromicro/go-zero/core/logx"
	"net/url"
	"wechat-api/internal/pkg/wechat_ws"
)

func msgHandler(msg wechat_ws.MsgJsonObject) error {
	logx.Info("当前处理的消息是：", msg)
	return nil
}

func main() {
	//u := url.URL{Scheme: "ws", Host: "chat.gkscrm.com:13088"}
	u := url.URL{Scheme: "ws", Host: "wecom.gkscrm.com:15088"}

	logx.Info(u.String())

	client, err := wechat_ws.NewWechatWsClient(u.String(), "default")
	if err != nil {
		return
	}

	go client.WritePump()

	//client.SendMsg([]byte(`{"msgType":"text","message":"你好"}`))
	client.SendMsg([]byte(`{
    "MsgType": "TalkToFriendTask",
    "Content": {
        "WxId": "1688856818598875",
        "ConvId": "7881302495311662",
        "ContentType": "Text",
        "Content": "5L2g5aW9",
        "TaskId": 17409293978671188
    }
}`))
	//
	//time.Sleep(5)
	//
	//client.SendMsg([]byte(`{"msgType":"text","message":"二次你好"}`))

	client.ReadPump(msgHandler)
}