12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182 |
- package dao
- import (
- "context"
- "fmt"
- "testing"
- "time"
- "go-common/app/admin/main/reply/model"
- xtime "go-common/library/time"
- . "github.com/smartystreets/goconvey/convey"
- )
- func deleteReplyContent(d *Dao, oid int64, rpid int64) error {
- _delSQL := "Delete from reply_content_%d where rpid = ?"
- _, err := d.db.Exec(context.Background(), fmt.Sprintf(_delSQL, hit(oid)), rpid)
- if err != nil {
- return err
- }
- return nil
- }
- func TestReplyContent(t *testing.T) {
- _inContSQL := "INSERT IGNORE INTO reply_content_%d (rpid,message,ats,ip,plat,device,version,ctime,mtime) VALUES(?,?,?,?,?,?,?,?,?)"
- d := _d
- c := context.Background()
- now := time.Now()
- rc := model.ReplyContent{
- ID: 1,
- Message: "test",
- Device: "iphone",
- Version: "beta",
- CTime: xtime.Time(now.Unix()),
- MTime: xtime.Time(now.Unix()),
- }
- _, err := d.db.Exec(c, fmt.Sprintf(_inContSQL, hit(6)), rc.ID, rc.Message, rc.Ats, rc.IP, rc.Plat, rc.Device, rc.Version, rc.CTime, rc.MTime)
- if err != nil {
- t.Logf("insert reply content %v", err)
- t.FailNow()
- }
- defer deleteReplyContent(d, 6, 1)
- rc2 := model.ReplyContent{
- ID: 2,
- Message: "test2",
- Device: "iphone2",
- Version: "beta2",
- CTime: xtime.Time(now.Unix()),
- MTime: xtime.Time(now.Unix()),
- }
- _, err = d.db.Exec(c, fmt.Sprintf(_inContSQL, hit(86)), rc2.ID, rc2.Message, rc2.Ats, rc2.IP, rc2.Plat, rc2.Device, rc2.Version, rc2.CTime, rc2.MTime)
- if err != nil {
- t.Logf("insert reply content %v", err)
- t.FailNow()
- }
- defer deleteReplyContent(d, 86, 2)
- Convey("reply_content test", t, WithDao(func(d *Dao) {
- Convey("get update content", WithDao(func(d *Dao) {
- now = time.Now()
- rows, err := d.UpReplyContent(c, 86, 2, "test3", now)
- So(err, ShouldBeNil)
- So(rows, ShouldBeGreaterThan, 0)
- }))
- Convey("get reply_content", WithDao(func(d *Dao) {
- content, err := d.ReplyContent(c, 86, 2)
- So(err, ShouldBeNil)
- So(content, ShouldNotBeNil)
- So(content.ID, ShouldEqual, 2)
- So(content.CTime, ShouldEqual, now.Unix())
- So(content.Message, ShouldEqual, "test3")
- }))
- Convey("find reply_contents", WithDao(func(d *Dao) {
- cMap, err := d.ReplyContents(c, []int64{6, 86}, []int64{1, 2})
- So(err, ShouldBeNil)
- So(len(cMap), ShouldEqual, 2)
- So(cMap[1].ID, ShouldEqual, 1)
- So(cMap[1].Message, ShouldEqual, "test")
- So(cMap[2].ID, ShouldEqual, 2)
- So(cMap[2].Message, ShouldEqual, "test3")
- }))
- }))
- }
|