userLib_test.go 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. package test
  2. import (
  3. "app.yhyue.com/moapp/jy_docs/rpc/userlib/userlibclient"
  4. "context"
  5. "github.com/tal-tech/go-zero/core/discov"
  6. "github.com/tal-tech/go-zero/zrpc"
  7. "log"
  8. "testing"
  9. )
  10. //用户收藏单元测试
  11. func Test_UserDocCollect(t *testing.T) {
  12. client := zrpc.MustNewClient(zrpc.RpcClientConf{
  13. Etcd: discov.EtcdConf{
  14. Hosts: []string{"127.0.0.1:2379"},
  15. Key: "jydocs.userlib.rpc",
  16. },
  17. })
  18. userLib := userlibclient.NewUserLib(client)
  19. resp, err := userLib.DocCollect(context.Background(), &userlibclient.UserCollectRequest{
  20. DocId: "1",
  21. UserId: "1",
  22. Cost: 0,
  23. })
  24. if err != nil {
  25. log.Println("UserDoc Collect call error:", err)
  26. }
  27. log.Print("UserDoc Collect call response:", resp)
  28. }
  29. //用户取消收藏单元测试
  30. func Test_UserCancelDocCollect(t *testing.T) {
  31. client := zrpc.MustNewClient(zrpc.RpcClientConf{
  32. Etcd: discov.EtcdConf{
  33. Hosts: []string{"127.0.0.1:2379"},
  34. Key: "jydocs.userlib.rpc",
  35. },
  36. })
  37. userLib := userlibclient.NewUserLib(client)
  38. resp, err := userLib.DocCancelCollect(context.Background(), &userlibclient.UserDeleteRequest{
  39. DocId: "7",
  40. })
  41. if err != nil {
  42. log.Println("UserDoc Collect call error:", err)
  43. }
  44. log.Print("UserDoc Collect call response:", resp)
  45. }
  46. //下载删除
  47. func Test_UserDocDelete(t *testing.T) {
  48. client := zrpc.MustNewClient(zrpc.RpcClientConf{
  49. Etcd: discov.EtcdConf{
  50. Hosts: []string{"127.0.0.1:2380"},
  51. Key: "jydocs.userlib.rpc",
  52. },
  53. })
  54. userLib := userlibclient.NewUserLib(client)
  55. resp, err := userLib.DocDelete(context.Background(), &userlibclient.UserRecoveryRequest{
  56. UserDocId: int32(10),
  57. })
  58. if err != nil {
  59. log.Println("UserDoc Collect call error:", err)
  60. }
  61. log.Print("UserDoc Collect call response:", resp)
  62. }
  63. //删除找回
  64. func Test_UserDocRestore(t *testing.T) {
  65. client := zrpc.MustNewClient(zrpc.RpcClientConf{
  66. Etcd: discov.EtcdConf{
  67. Hosts: []string{"127.0.0.1:2380"},
  68. Key: "jydocs.userlib.rpc",
  69. },
  70. })
  71. userLib := userlibclient.NewUserLib(client)
  72. resp, err := userLib.DocRestore(context.Background(), &userlibclient.UserRecoveryRequest{
  73. UserDocId: int32(10),
  74. })
  75. if err != nil {
  76. log.Println("UserDoc Collect call error:", err)
  77. }
  78. log.Print("UserDoc Collect call response:", resp)
  79. }
  80. //永久删除
  81. func Test_UserDocPermanentDelete(t *testing.T) {
  82. client := zrpc.MustNewClient(zrpc.RpcClientConf{
  83. Etcd: discov.EtcdConf{
  84. Hosts: []string{"127.0.0.1:2380"},
  85. Key: "jydocs.userlib.rpc",
  86. },
  87. })
  88. userLib := userlibclient.NewUserLib(client)
  89. resp, err := userLib.DocPermanentDelete(context.Background(), &userlibclient.UserRecoveryRequest{
  90. UserDocId: int32(10),
  91. })
  92. if err != nil {
  93. log.Println("UserDoc Collect call error:", err)
  94. }
  95. log.Print("UserDoc Collect call response:", resp)
  96. }
  97. //用户转存单元测试
  98. func Test_UserDocDwnload(t *testing.T) {
  99. client := zrpc.MustNewClient(zrpc.RpcClientConf{
  100. Etcd: discov.EtcdConf{
  101. Hosts: []string{"127.0.0.1:2380"},
  102. Key: "jydocs.userlib.rpc",
  103. },
  104. })
  105. userLib := userlibclient.NewUserLib(client)
  106. resp, err := userLib.DocDownload(context.Background(), &userlibclient.UserCollectRequest{
  107. DocId: "123",
  108. UserId: "wh5",
  109. Cost:1000,
  110. })
  111. if err != nil {
  112. log.Println("UserDoc Collect call error:", err)
  113. }
  114. log.Print("UserDoc Collect call response:", resp.Message,resp.Code)
  115. }