messageCenter/rpc/messagecenter/test/message_test.go

package test

import (
	quitl "app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/encrypt"
	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/internal/config"
	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
	"context"
	"flag"
	"github.com/zeromicro/go-zero/core/conf"
	"github.com/zeromicro/go-zero/zrpc"
	"log"
	"testing"
	"time"
)

var configFile = flag.String("f", "../etc/messagecenter.yaml", "the config file")
var c config.Config

func init() {
	conf.MustLoad(*configFile, &c)
}

//数量查询
func Test_Count(t *testing.T) {
	log.Println(encrypt.SE.Encode2Hex("831"))
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	TestSystem := messagecenter.NewMessageCenter(zrpc.MustNewClient(c.TestConf))
	req := &messagecenter.CountReq{
		UserType:   2,
		NewUserId:  70224,
		PositionId: 1205051306,
	}
	res, err := TestSystem.Count(ctx, req)
	log.Println("res ", res)
	log.Println("err ", err)
}

//用户数量查询
func Test_UserList(t *testing.T) {
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	TestSystem := messagecenter.NewMessageCenter(zrpc.MustNewClient(c.TestConf))
	req := &messagecenter.UserReq{
		Phone:     "",
		UserType:  1,
		StartTime: "",
		EndTime:   "",
		NewUserId: 4318,
		EntUserId: 4318,
	}
	res, err := TestSystem.UserList(ctx, req)
	log.Println("res ", res)
	log.Println("err ", err)
}

//聊天信息查询
func Test_FindMessage(t *testing.T) {
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	TestSystem := messagecenter.NewMessageCenter(zrpc.MustNewClient(c.TestConf))
	req := &messagecenter.MessageReq{
		MsgType:     3,
		UserType:    2,
		SendId:      68826,
		PageSize:    2,
		EntId:       15051,
		LastId:      330239,
		NewUserId:   1205051306,
		EntUserId:   0,
		Sort:        "DESC",
		ChatGroupId: 30001,
		PositionId:  1205051306,
	}
	res, err := TestSystem.FindMessage(ctx, req)
	log.Println("res ", res)
	log.Println("err ", err)
}

//聊天保存
func Test_SaveMessage(t *testing.T) {
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	TestSystem := messagecenter.NewMessageCenter(zrpc.MustNewClient(c.TestConf))
	req := &messagecenter.MessageEntity{
		Title:     "11",
		Content:   "请问在吗?",
		Item:      8,
		ItemType:  6,
		Link:      "1111",
		Appid:     "10000",
		ReceiveId: 2,
		SendId:    4626,
		OwnType:   int64(2),
		Type:      1,
	}
	res, err := TestSystem.SaveMessage(ctx, req)
	log.Println("res ", res)
	log.Println("err ", err)
}

//
func Test_test1(t *testing.T) {
	a := quitl.Int64All(encrypt.SE.Decode4Hex("475c405c5444"))
	log.Println("a----", a)

}