messageCenter/rpc/messagecenter/test/message_test.go

package test

import (
	"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"
	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/service"
	"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: 5524,
	}
	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:   2,
		UserType:  2,
		SendId:    68826,
		PageSize:  10,
		EntId:     14929,
		LastId:    0,
		NewUserId: 74175,
		EntUserId: 0,
		Sort:      "",
		//ChatGroupId: 1,
		PositionId: 584,
	}
	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) {
	b := service.GetUserAllPosition(74175)
	log.Println(b)
}