75 lines
2.6 KiB
Go
75 lines
2.6 KiB
Go
package mtwmapi
|
|
|
|
import (
|
|
"encoding/base64"
|
|
"encoding/json"
|
|
"fmt"
|
|
"git.rosy.net.cn/baseapi/utils"
|
|
"github.com/go-redis/redis"
|
|
"reflect"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
const (
|
|
MTIMPushUrl = "wss://wpush.meituan.com/websocket"
|
|
TestAppID = "589_WMOPEN"
|
|
TestToken = "wo589i4VsZHFH2fh4uVsr6Dtc3k6vG8Xu0vxpreBQFy6QAvg"
|
|
|
|
TestMTIM589 = "wss://wpush.meituan.com/websocket/589_WMOPEN/wo589i4VsZHFH2fh4uVsr6Dtc3k6vG8Xu0vxpreBQFy6QAvg"
|
|
TestMTIM4123 = "wss://wpush.meituan.com/websocket/4123_WMOPEN/wo4123aAVXDUkZDYucMoTDAZgsMzjrR_porZcLGv2GmWRNOiw"
|
|
TestWssUrl = "wss://www.jxc4.com:443/v2/event/TestWebsocket"
|
|
TestWssUrl1 = "wss://www-jxgy.jxc4.com:443/v2/im/StartWebSocket"
|
|
)
|
|
|
|
var rdb = redis.NewClient(&redis.Options{
|
|
//Addr: "www.jxc4.com:6379",
|
|
//Password: "",
|
|
Addr: "127.0.0.1:6379",
|
|
Password: "123456",
|
|
DB: 0,
|
|
})
|
|
|
|
func TestSendMsg(t *testing.T) {
|
|
data := PushContentReq{
|
|
AppID: 589,
|
|
AppPoiCode: "8694203",
|
|
MsgID: 20230615,
|
|
MsgContent: "QYEyt4edHFiW0Fg0iKqeSKZ+Dab9zKJWSLwQuE38J+XL/1BUIwkqy3sf3E9lOK77",
|
|
MsgSource: 1,
|
|
MsgType: 1,
|
|
Cts: int(time.Now().Unix()),
|
|
OpenUserID: 12248014636,
|
|
}
|
|
dataMar, err := json.Marshal(data)
|
|
fmt.Println(string(dataMar))
|
|
ret, err := api.MsgSend(string(dataMar))
|
|
fmt.Println(ret, err)
|
|
}
|
|
|
|
func TestMashal(t *testing.T) {
|
|
var pushContent = PushContentReq{}
|
|
str := "{\"app_id\":589,\"app_poi_code\":\"8694203\",\"msg_id\":20230615,\"msg_content\":\"3/ SR3dQEf/G7nBfw1K3UN6UaYlCFaxKmbS76MPuJ9w=\",\"msg_source\":1,\"msg_type\":1,\"cts\":1686902500,\"open_user_id\":12248014636,\"order_id\":0,\"group_id\":0,\"app_spu_codes\":\"\"}"
|
|
if err := json.Unmarshal([]byte(str), &pushContent); err == nil {
|
|
fmt.Println(pushContent)
|
|
}
|
|
}
|
|
|
|
func TestImDecpryt(t *testing.T) {
|
|
msg := "1YAUiB1SGjIlq9yGnlMidg3bpzod7wD8rRdz0avVyqGLAtoBkpcb9TX4MtStdOPPV8S/IGWpBoebIkcy4TPsTOjod4k3IBjAjjjueiy6so3JN8I/NGmMe0cgMV88HlfXBrv/rn2FSij1zOGIMUcLWeiMh81aLMTMIjf43t1kG4mAor8D4P9v5lPv7Pjqa4MzxGqo0K/pGTE3MrXDRoyAw7JyhdICxDBCZUwNFDrIDnWvdQrYoMjNf8cWZw1MZHdk"
|
|
data, _ := base64.StdEncoding.DecodeString(msg)
|
|
key1 := utils.LimitUTF8StringLen2("a81eb3df418d83d6a1a4b7c572156d2f", 16)
|
|
fmt.Println(key1)
|
|
//key, _ := base64.StdEncoding.DecodeString("a81eb3df418d83d6a1a4b7c572156d2f")
|
|
//data, err := utils.AESCBC16Decrypt([]byte(msg), []byte("a81eb3df418d83d6"), []byte("a81eb3df418d83d6"))
|
|
//data, err := utils.AESCBCDecpryt([]byte(msg), key, key)
|
|
res, err := utils.AESCBCDecpryt(data, []byte(key1), []byte(key1))
|
|
fmt.Println(err)
|
|
fmt.Println(reflect.TypeOf(res))
|
|
fmt.Println(string(res))
|
|
}
|
|
|
|
func TestRand(t *testing.T) {
|
|
fmt.Println(time.Now().Unix())
|
|
}
|