product_service_test.go 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798
  1. package service
  2. import (
  3. "database/sql"
  4. "encoding/json"
  5. "fmt"
  6. "testing"
  7. _ "github.com/go-sql-driver/mysql"
  8. "xiaoniaokuaiyan.com/xiaoniao/config"
  9. "xiaoniaokuaiyan.com/xiaoniao/dal"
  10. "xiaoniaokuaiyan.com/xiaoniao/entity"
  11. "xiaoniaokuaiyan.com/xiaoniao/util"
  12. )
  13. func TestGetByCateId(t *testing.T) {
  14. psrv := &ProductService{
  15. dal.DefaultProductDal,
  16. }
  17. cateIds := []int{11}
  18. pager := dal.Pager{
  19. PageIndex: 1,
  20. PageSize: 1000,
  21. }
  22. sp := dal.SortParam{
  23. SortBy: "PRICE",
  24. SortDir: -1,
  25. }
  26. data, err := psrv.ProductGetByCateId(cateIds, pager, 0, sp)
  27. if err != nil {
  28. t.Fatal(err)
  29. }
  30. dl := data.([]*entity.ProductDB)
  31. for _, pitem := range dl {
  32. fmt.Printf("%+v", pitem)
  33. }
  34. }
  35. func TestGetProductById(t *testing.T) {
  36. psrv := &ProductService{
  37. dal.DefaultProductDal,
  38. }
  39. r, err := psrv.ProductGet([]int{3})
  40. if err != nil {
  41. t.Fatal(err)
  42. }
  43. buf, _ := json.Marshal(r)
  44. fmt.Println(string(buf))
  45. }
  46. func TestPureGetCateId(t *testing.T) {
  47. db, err := sql.Open("mysql", "xiaoniao_n:xn654^%$@(123.57.224.234:3306)/xiaoniao_db")
  48. if err != nil {
  49. t.Fatal(err)
  50. }
  51. rows, err := db.Query("select t2.id from t_product t2 left join t_product_category_product t1 on t1.product_id = t2.id where t1.cat_id = ? and t2.is_putaway = 0 and t2.is_delete = 0 order by sort_no desc limit ?,?", 6, 0, 1000)
  52. if err != nil {
  53. t.Fatal(err)
  54. }
  55. var pid uint64
  56. for rows.Next() {
  57. rows.Scan(&pid)
  58. fmt.Println(pid)
  59. }
  60. }
  61. func TestScanOrder(t *testing.T) {
  62. db, err := sql.Open("mysql", "xiaoniao_n:xn654^%$@(123.57.224.234:3306)/xiaoniao_db")
  63. if err != nil {
  64. t.Fatal(err)
  65. }
  66. rows, err := db.Query("select * from t_order order by created_at desc limit 5")
  67. if err != nil {
  68. t.Fatal(err)
  69. }
  70. olist := []entity.Order{}
  71. err = util.ScanStruct(rows, &olist)
  72. if err != nil {
  73. t.Fatal(err)
  74. }
  75. for _, oitem := range olist {
  76. fmt.Println(oitem)
  77. }
  78. }
  79. func TestGetTop(t *testing.T) {
  80. config.Reload("config.ini")
  81. psrv := &ProductService{
  82. dal.DefaultProductDal,
  83. }
  84. data, err := psrv.GetTop(3, 1)
  85. if err != nil {
  86. t.Fatal(err)
  87. }
  88. fmt.Println(data)
  89. }