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: 1180, PageSize: 10, NewUserId: 831, } 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("2742") fmt.Println(a) fmt.Println(encrypt.SE.Decode4Hex(a)) fmt.Println(encrypt.SE.Decode4Hex("415a4856")) 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) }*/ }