package service import ( "testing" "kpt.notice/apiserver/config" "kpt.notice/apiserver/model" "kpt.notice/pkg/log" ) func TestReceiveMessage(t *testing.T) { config.Init() log.Init(config.Conf.Log) New(config.Conf) log.Error("ReceiveMessage=====================") b := []byte(` 123456789 `) ReceiveMessage(b) } func testInit() *Service { config.Init() log.Init(config.Conf.Log) return New(config.Conf) } func TestInsertMessage(t *testing.T) { svc := testInit() for i := 1; i < 3; i++ { log.Error("i=======", i) var m []model.MessageType switch { case i == 1: defer svc.QueryMsgType(1) { if err := recover(); err != nil { log.Errorf("%v", err) } else { m = svc.QueryMsgType(1) } } case i == 2: svc.DB.Where("id = ?", 1).Find(&m) } log.Errorf("%#v", m) } // file, err := ioutil.ReadFile("/Users/desire/kptdev/msg_push/json/message.json") // if err != nil || len(file) == 0 { // panic(err) // } // req := new(http.MessageReq) // json.Unmarshal([]byte(file), req) // // log.Errorf("%#v", req) // svc.InsertMessage(req) } func TestCreateQRcode(t *testing.T) { // resp, err := CreateQRCode("") // if err == nil { // m := make(map[string]string) // json.Unmarshal(resp, &m) // // t.Errorf("%#v", m["expire_seconds"]) // t.Errorf("%v", string(resp)) // t.Errorf("%v\n", url.QueryEscape(m["ticket"])) // } else { // t.Errorf("%#v", err) // } } func TestGetMsgByType(t *testing.T) { // res, err := getMsgByType(1) // if err != nil { // t.Error(err) // } // t.Errorf("%#v", res) } func TestUpdateStatus(t *testing.T) { // GormDB() // UpdateMessage(20) } func TestMsgSend(t *testing.T) { // GormDB() SendInstantMsg() } func TestQueryOpenid(t *testing.T) { // GormDB() // res, _ := QueryOpenid([]string{"15800900542"}) // t.Errorf("%#v", res) }