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"
	"context"
	"flag"
	"fmt"
	"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) {
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	TestSystem := messagecenter.NewMessageCenter(zrpc.MustNewClient(c.TestConf))
	req := &messagecenter.CountReq{
		UserType:  2,
		NewUserId: 831,
	}
	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: 42941,
		EntUserId: 42711,
	}
	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:  4,
		UserType: 1,
		SendId:   68826,
		PageSize: 10,
		EntId:    14929,
	}
	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 := encrypt.SE.Encode2Hex("1")
	fmt.Println(a)
	fmt.Println(encrypt.SE.Decode4Hex(a))
	fmt.Println(encrypt.SE.Decode4Hex("4657465d5d"))
	fmt.Println(encrypt.SE.Decode4Hex("4157435b52"))

	/*for d := 0; d <10 ; d++ {
		c:=0
		for i := 0; i <= 10000; i++ {
			b:=rand.New(rand.NewSource(time.Now().UnixNano())).Int63n(100)
			if b<=50{
				c++
			}
		}
		fmt.Println(c)
	}*/

}