user_test.go 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117
  1. package user
  2. import (
  3. "fmt"
  4. "gorm.io/driver/mysql"
  5. "gorm.io/gorm"
  6. "gorm.io/gorm/logger"
  7. "gorm.io/gorm/schema"
  8. req "sghgogs.com/micro/shopping-service/domain/model/request"
  9. "sghgogs.com/micro/shopping-service/domain/repository"
  10. "sghgogs.com/micro/shopping-service/domain/service"
  11. pb "sghgogs.com/micro/shopping-service/proto"
  12. "testing"
  13. "time"
  14. )
  15. func TestUser(t *testing.T) {
  16. address := fmt.Sprintf("%v:%v@(%v:%v)/%v?charset=utf8mb4,utf8&parseTime=True&loc=Local", "root", "xugang131500", "47.56.16.206", 3306, "shopping_wenke")
  17. db, err := gorm.Open(mysql.Open(address), &gorm.Config{
  18. Logger: logger.Default.LogMode(logger.Info),
  19. NamingStrategy: schema.NamingStrategy{
  20. SingularTable: true,
  21. }})
  22. if err != nil {
  23. t.Fatal(err)
  24. }
  25. repo := repository.NewRepository(db)
  26. t.Run("初始化表", func(t *testing.T) {
  27. err = repo.InitTable()
  28. fmt.Println(err)
  29. })
  30. service := service.NewService(repo, "shopping_wenke")
  31. t.Run("创建账号", func(t *testing.T) {
  32. // user := &pb.CreateUserRequest{
  33. // Username: "admin",
  34. // Password: "123456",
  35. // PhoneNumber: "13900000000",
  36. // Email: "john@example.com",
  37. // Avatar: "https://wpimg.wallstcn.com/f778738c-e4f8-4870-b634-56703b4acafe.gif",
  38. // }
  39. // err = service.CreateUser(user)
  40. // fmt.Println("err", err)
  41. })
  42. t.Run("删除", func(t *testing.T) {
  43. // service.DeleteUser(&pb.DeleteUserRequest{UserId: 7})
  44. })
  45. t.Run("更新", func(t *testing.T) {
  46. })
  47. t.Run("查询User数据", func(t *testing.T) {
  48. // group, err2 := service.GetUserGroup(&pb.GetUserGroupRequest{GroupId: 2})
  49. // fmt.Println(group)
  50. // fmt.Println(err2)
  51. var user []req.User
  52. db.Model(&req.User{}).
  53. Where("group_id = ?", 2).
  54. Order("id desc").Find(&user)
  55. fmt.Println(user)
  56. })
  57. t.Run("删除", func(t *testing.T) {
  58. })
  59. t.Run("查询详情", func(t *testing.T) {
  60. user, err2 := service.GetUser(&pb.GetUserRequest{UserId: 1})
  61. fmt.Println(user)
  62. // // db.Preload("ShoppingCart").Where("id = ? AND status = ?", 1, pb.StatusEnum_ENABLED).First(&user)
  63. // // fmt.Println("user", user.ShoppingCart)
  64. fmt.Println(err2)
  65. })
  66. t.Run("修改手机号", func(t *testing.T) {
  67. // err2 := service.UpdateUserPhoneNumber(&pb.UpdateUserPhoneNumberRequest{
  68. // UserId: 4,
  69. // NewPhoneNumber: "13888888888",
  70. // })
  71. // fmt.Println(err2)
  72. })
  73. t.Run("设置状态", func(t *testing.T) {
  74. // service.ToggleUser(&pb.ToggleUserRequest{
  75. // UserId: 1,
  76. // Status: pb.StatusEnum_ENABLED,
  77. // })
  78. })
  79. t.Run("测试时间", func(t *testing.T) {
  80. date := time.Now().AddDate(0, 0, 1)
  81. fmt.Println(date)
  82. fmt.Println(time.Now().Before(date))
  83. })
  84. t.Run("查询", func(t *testing.T) {
  85. list, i, err2 := service.GetUserList(&pb.GetUserListRequest{
  86. Page: 1,
  87. PageSize: 10,
  88. })
  89. fmt.Println(list)
  90. fmt.Println(i)
  91. fmt.Println(err2)
  92. })
  93. t.Run("创建分组", func(t *testing.T) {
  94. err2 := service.CreateUserGroup(&pb.CreateUserGroupRequest{
  95. Name: "前端用户-A组",
  96. Description: "默认进入注册A组",
  97. CreatedBy: "system",
  98. })
  99. fmt.Println(err2)
  100. })
  101. t.Run("测试", func(t *testing.T) {
  102. // group, err2 := service.GetUserGroup(&pb.GetUserGroupRequest{Code: "17a78673-9762-4e9e-8f87-595a049f75bf"})
  103. // fmt.Println(group.Id)
  104. // fmt.Println(err2)
  105. login, i, err2 := service.Login(&pb.LoginRequest{
  106. Username: "admin",
  107. Password: "123456",
  108. Code: "17a78673-9762-4e9e-8f87-595a049f75bf",
  109. })
  110. fmt.Println(login)
  111. fmt.Println(i)
  112. fmt.Println(err2)
  113. })
  114. // service.NewService(repo)
  115. }