adminuser_test.go 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. package adminuser
  2. import (
  3. "context"
  4. "fmt"
  5. "gorm.io/driver/mysql"
  6. "gorm.io/gorm"
  7. "gorm.io/gorm/logger"
  8. "gorm.io/gorm/schema"
  9. "reflect"
  10. "sghgogs.com/micro/shopping-service/domain/repository"
  11. "sghgogs.com/micro/shopping-service/domain/service"
  12. pb "sghgogs.com/micro/shopping-service/proto"
  13. "testing"
  14. )
  15. func TestAdminUser(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. newService := service.NewService(repo, "shoppingservice")
  31. t.Run("创建", func(t *testing.T) {
  32. err2 := newService.CreateAdminUser(context.Background(), &pb.CreateAdminUserRequest{
  33. Username: "job_admin",
  34. Password: "123456",
  35. PhoneNumber: "13988888888",
  36. Email: "sghblog@163.com",
  37. Avatar: "https://wpimg.wallstcn.com/f778738c-e4f8-4870-b634-56703b4acafe.gif",
  38. Roles: []int64{1, 2},
  39. })
  40. fmt.Println(err2)
  41. })
  42. t.Run("更新", func(t *testing.T) {
  43. newService.UpdateAdminUser(context.Background(), &pb.UpdateAdminUserRequest{
  44. UserId: 7,
  45. PhoneNumber: "13988888888",
  46. Email: "sghblog@163.com",
  47. Avatar: "https://wpimg.wallstcn.com/f778738c-e4f8-4870-b634-56703b4acafe.gif",
  48. })
  49. })
  50. t.Run("更新", func(t *testing.T) {
  51. newService.ToggleAdminUser(context.Background(), &pb.ToggleAdminUserRequest{
  52. UserId: 4,
  53. Status: pb.StatusEnum_DISABLED,
  54. })
  55. })
  56. t.Run("删除", func(t *testing.T) {
  57. err2 := newService.DeleteAdminUser(&pb.DeleteAdminUserRequest{UserId: 5})
  58. fmt.Println(err2)
  59. // newService.DeleteAdminUser(&pb.DeleteAdminUserRequest{UserId: 2})
  60. })
  61. t.Run("获取列表", func(t *testing.T) {
  62. list, i, err2 := newService.GetAdminUserList(&pb.GetAdminUserListRequest{
  63. Page: 1,
  64. PageSize: 10,
  65. Code: "17a78673-9762-4e9e-8f87-595a049f75bf",
  66. })
  67. fmt.Println(list)
  68. fmt.Println(i)
  69. fmt.Println(err2)
  70. })
  71. t.Run("获取所有", func(t *testing.T) {
  72. user, err2 := newService.GetAllAdminUser()
  73. fmt.Println(user, err2)
  74. })
  75. }
  76. func filterNilFields(m map[string]interface{}) map[string]interface{} {
  77. result := make(map[string]interface{})
  78. for key, value := range m {
  79. // 判断是否为布尔值或数值类型的默认零值
  80. if value != reflect.Zero(reflect.TypeOf(value)).Interface() {
  81. result[key] = value
  82. }
  83. }
  84. return result
  85. }