package service

import (
	"testing"

	"kpt.notice/apiserver/config"
	"kpt.notice/pkg/log"
)

func TestQueryMsgType(t *testing.T) {
	svc := testInit()
	res := svc.QueryMsgType(nil)
	t.Errorf("%#v", res)
}
func TestReceiveMessage(t *testing.T) {
	config.Init()
	log.Init(config.Conf.Log)
	New(config.Conf)
	log.Error("ReceiveMessage=====================")
	b := []byte(`<xml>
		<ToUserName><![CDATA[oLd1b56PwpexCa0QK4NCkza9TKyY]]></ToUserName>
		<FromUserName><![CDATA[oLd1b56PwpexCa0QK4NCkza9TKyY]]></FromUserName>
		<CreateTime>123456789</CreateTime>
		<MsgType><![CDATA[event]]></MsgType>
		<Event><![CDATA[subscribe]]></Event>
		<EventKey><![CDATA[qrscene_tmr.shengmu23]]></EventKey>
		<Ticket><![CDATA[TICKET]]></Ticket>
	  </xml>`)

	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)
}