archive_test.go 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
  1. package service
  2. import (
  3. "go-common/app/interface/main/push-archive/dao"
  4. "go-common/app/interface/main/push-archive/model"
  5. "testing"
  6. "github.com/smartystreets/goconvey/convey"
  7. )
  8. func Test_groupparam(t *testing.T) {
  9. initd()
  10. expect := map[string]string{
  11. "1#ai:pushlist_follow_recent": "follow",
  12. "1#ai:pushlist_play_recent": "play",
  13. "1#ai:pushlist_offline_up": "offline",
  14. "2#special": "special",
  15. }
  16. convey.Convey("推送的group参数", t, func() {
  17. for k, g := range s.dao.FanGroups {
  18. group := s.getGroupParam(g)
  19. convey.So(group, convey.ShouldEqual, expect[k])
  20. }
  21. })
  22. }
  23. func Test_usersettingfilter(t *testing.T) {
  24. initd()
  25. mid := int64(11111111)
  26. s.userSettings[mid] = &model.Setting{Type: model.PushTypeForbid}
  27. allow := s.filterUserSetting(mid, model.RelationSpecial)
  28. convey.Convey("usersettings filter关闭开关,则排除", t, func() {
  29. convey.So(allow, convey.ShouldEqual, false)
  30. })
  31. s.userSettings[mid] = nil
  32. allow = s.filterUserSetting(mid, model.RelationSpecial)
  33. convey.Convey("usersettings filter未设置开关,则允许", t, func() {
  34. convey.So(allow, convey.ShouldEqual, true)
  35. })
  36. s.userSettings[mid] = &model.Setting{Type: model.PushTypeAttention}
  37. allow = s.filterUserSetting(mid, model.RelationSpecial)
  38. convey.Convey("usersettings filter设置未所有关注,则允许", t, func() {
  39. convey.So(allow, convey.ShouldEqual, true)
  40. })
  41. }
  42. func Test_ispgc(t *testing.T) {
  43. arc := new(model.Archive)
  44. convey.Convey("pgc稿件判断", t, func() {
  45. arc.Attribute = int32(110336)
  46. convey.So(s.isPGC(arc), convey.ShouldEqual, true)
  47. arc.Attribute = int32(16512)
  48. convey.So(s.isPGC(arc), convey.ShouldEqual, false)
  49. })
  50. }
  51. func TestServicefansByAbtest(t *testing.T) {
  52. initd()
  53. group := &dao.FanGroup{
  54. Hitby: "ab_test",
  55. HBaseTable: "push_archive_ab_test",
  56. HBaseFamily: []string{"cf"},
  57. }
  58. fans := []int64{1, 2, 3, 4, 5, 6}
  59. convey.Convey("fansByAbtest", t, func() {
  60. exists, notExists := s.fansByAbtest(group, fans)
  61. t.Logf("exists(%v)", exists)
  62. t.Logf("notExists(%v)", notExists)
  63. })
  64. }