jy_docs/rpc/userlib/test/userLib_test.go

package test

import (
	"app.yhyue.com/moapp/jy_docs/rpc/userlib/userlibclient"
	"context"
	"github.com/tal-tech/go-zero/core/discov"
	"github.com/tal-tech/go-zero/zrpc"
	"log"
	"testing"
)

//用户收藏单元测试
func Test_UserDocCollect(t *testing.T) {
	client := zrpc.MustNewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: []string{"127.0.0.1:2379"},
			Key:   "jydocs.userlib.rpc",
		},
	})
	userLib := userlibclient.NewUserLib(client)
	resp, err := userLib.DocCollect(context.Background(), &userlibclient.UserCollectRequest{
		DocId:  "0002bef6-8e6d-11eb-8419-0050568f1307",
		UserId: "456",
		AppId:  "10000",
	})
	if err != nil {
		log.Println("UserDoc Collect call error:", err)
	}
	log.Print("UserDoc Collect call response:", resp)
}

//用户取消收藏单元测试
func Test_UserCancelDocCollect(t *testing.T) {
	client := zrpc.MustNewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: []string{"127.0.0.1:2379"},
			Key:   "jydocs.userlib.rpc",
		},
	})
	userLib := userlibclient.NewUserLib(client)
	resp, err := userLib.DocCancelCollect(context.Background(), &userlibclient.UserCancelRequest{
		DocId:  "SUgJfBt1M6nop8kvwcu5",
		UserId: "5d6378301c298a5aac7b5402",
		AppId:  "10000",
	})
	if err != nil {
		log.Println("UserDoc Collect call error:", err)
	}
	log.Print("UserDoc Collect call response:", resp)
}

//下载删除
func Test_UserDocDelete(t *testing.T) {
	client := zrpc.MustNewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: []string{"127.0.0.1:2380"},
			Key:   "jydocs.userlib.rpc",
		},
	})
	userLib := userlibclient.NewUserLib(client)
	resp, err := userLib.DocDelete(context.Background(), &userlibclient.UserRecoveryRequest{
		UserDocId: int32(13),
		AppId:     "10000",
		UserId:    "wh11",
	})
	if err != nil {
		log.Println("UserDoc Collect call error:", err)
	}
	log.Print("UserDoc Collect call response:", resp)
}

//删除找回
func Test_UserDocRestore(t *testing.T) {
	client := zrpc.MustNewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: []string{"127.0.0.1:2380"},
			Key:   "jydocs.userlib.rpc",
		},
	})
	userLib := userlibclient.NewUserLib(client)
	resp, err := userLib.DocRestore(context.Background(), &userlibclient.UserRecoveryRequest{
		UserDocId: int32(10),
		AppId:     "10000",
		UserId:    "wh11",
	})
	if err != nil {
		log.Println("UserDoc Collect call error:", err)
	}
	log.Print("UserDoc Collect call response:", resp)
}

//永久删除
func Test_UserDocPermanentDelete(t *testing.T) {
	client := zrpc.MustNewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: []string{"127.0.0.1:2380"},
			Key:   "jydocs.userlib.rpc",
		},
	})
	userLib := userlibclient.NewUserLib(client)
	resp, err := userLib.DocPermanentDelete(context.Background(), &userlibclient.UserRecoveryRequest{
		UserDocId: int32(10),
		AppId:     "10000",
		UserId:    "wh11",
	})
	if err != nil {
		log.Println("UserDoc Collect call error:", err)
	}
	log.Print("UserDoc Collect call response:", resp)
}

//我的文库0兑换的 1收藏的 2回收站的
func Test_UserDocList(t *testing.T) {
	client := zrpc.MustNewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: []string{"127.0.0.1:2380"},
			Key:   "jydocs.userlib.rpc",
		},
	})
	userLib := userlibclient.NewUserLib(client)
	resp, err := userLib.UserDocs(context.Background(), &userlibclient.UserDocsRequest{
		UserId:          "5d6378301c298a5aac7b5402",
		AppId:           "10000",
		PageSize:        10,
		Page:            1,
		UserDocCategory: 1,
	})
	if err != nil {
		log.Println("UserDoc Collect call error:", err)
	}
	log.Print("UserDoc Collect call response:", resp)
}

//用户转存单元测试
func Test_UserDocDwnload(t *testing.T) {
	client := zrpc.MustNewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: []string{"127.0.0.1:2380"},
			Key:   "jydocs.userlib.rpc",
		},
	})
	userLib := userlibclient.NewUserLib(client)
	resp, err := userLib.DocDownload(context.Background(), &userlibclient.UserCollectRequest{
		DocId:  "010ef774-888c-11eb-8699-0050568f51e7",
		UserId: "456",
		Cost:   1000,
		AppId:  "10000",
	})
	if err != nil {
		log.Println("UserDoc Collect call error:", err)
	}
	log.Print("UserDoc Collect call response:", resp.Message, resp.Code)
}
//账号合并
func Test_MergeUser(t *testing.T) {
	client := zrpc.MustNewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: []string{"127.0.0.1:2380"},
			Key:   "jydocs.userlib.rpc",
		},
	})
	userLib := userlibclient.NewUserLib(client)
	resp, err := userLib.UserMerge(context.Background(), &userlibclient.MergeInfo{
		MergeUser:  "123",
		MergedUser: "456",
		AppId:  "10000",})
	if err != nil {
		log.Println("UserDoc Collect call error:", err)
	}
	log.Print("UserDoc Collect call response:", resp.Message, resp.Code)
}