Merge branch 'master' of https://git.trj.tw/golang/mtfosbot

model/donate_setting.go

@@ -46,7 +46,7 @@ func (p *DonateSetting) InsertOrUpdate() (err error) {
 	"end_date" = :end_date,
 	"target_amount" = :target_amount,
 	"title" = :title,
-	"start_amount" = :start_amount`
+	"start_amount" = :start_amount, "mtime" = now()`
 	_, err = x.NamedExec(query, p)
 	return
 }

model/facebook_page.go

@@ -51,7 +51,7 @@ func (p *FacebookPage) AddPage() (err error) {
 
 // UpdatePost -
 func (p *FacebookPage) UpdatePost(postID string) (err error) {
-	query := `update "public"."facebook_page" set "lastpost" = $1 where id = $2`
+	query := `update "public"."facebook_page" set "lastpost" = $1, "mtime" = now() where id = $2`
 	_, err = x.Exec(query, postID, p.ID)
 	if err != nil {
 		return

model/line_message_log.go

@@ -32,8 +32,27 @@ func AddLineMessageLog(g, u, msg, t string) (msglog *LineMessageLog, err error)
 }
 
 // GetLineMessageLogCount -
-func GetLineMessageLogCount() (c int, err error) {
-	err = x.Get(&c, `select count(*) as c from "public"."line_message_log"`)
+func GetLineMessageLogCount(where ...interface{}) (c int, err error) {
+	query := `select count(*) as c from "public"."line_message_log"`
+	values := make([]interface{}, 0)
+	if len(where) > 0 {
+		if whereMap, ok := where[0].(map[string]string); ok {
+			str := ""
+			idx := 1
+			for k, v := range whereMap {
+				if len(str) > 0 {
+					str += " and "
+				}
+				str += fmt.Sprintf(` "%s" = $%d`, k, idx)
+				idx++
+				values = append(values, v)
+			}
+			if len(str) > 0 {
+				query += " where " + str
+			}
+		}
+	}
+	err = x.Get(&c, query, values...)
 	return
 }
 

model/twitch_channel.go

@@ -85,7 +85,7 @@ func (p *TwitchChannel) Add() (err error) {
 
 // UpdateStream -
 func (p *TwitchChannel) UpdateStream(streamID string) (err error) {
-	query := `update "public"."twitch_channel" set "laststream" = $1 where "id" = $2`
+	query := `update "public"."twitch_channel" set "laststream" = $1, "mtime" = now() where "id" = $2`
 	_, err = x.Exec(query, streamID, p.ID)
 	if err != nil {
 		return
@@ -96,7 +96,7 @@ func (p *TwitchChannel) UpdateStream(streamID string) (err error) {
 
 // UpdateName -
 func (p *TwitchChannel) UpdateName(name string) (err error) {
-	_, err = x.Exec(`update "public"."twitch_channel" set "name" = $1 where "id" = $2`, name, p.ID)
+	_, err = x.Exec(`update "public"."twitch_channel" set "name" = $1, "mtime" = now() where "id" = $2`, name, p.ID)
 	if err != nil {
 		return
 	}
@@ -107,14 +107,14 @@ func (p *TwitchChannel) UpdateName(name string) (err error) {
 // UpdateJoin -
 func (p *TwitchChannel) UpdateJoin(join bool) (err error) {
 	p.Join = join
-	_, err = x.NamedExec(`update "public"."twitch_channel" set "join" = :join where "id" = :id`, p)
+	_, err = x.NamedExec(`update "public"."twitch_channel" set "join" = :join, "mtime" = now() where "id" = :id`, p)
 	return
 }
 
 // UpdateOpayID -
 func (p *TwitchChannel) UpdateOpayID(id string) (err error) {
 	p.OpayID = id
-	_, err = x.NamedExec(`update "public"."twitch_channel" set "opayid" = :opayid where "id" = :id`, p)
+	_, err = x.NamedExec(`update "public"."twitch_channel" set "opayid" = :opayid, "mtime" = now() where "id" = :id`, p)
 	return
 }
 

model/youtube_channel.go

@@ -57,14 +57,14 @@ func (p *YoutubeChannel) Add() (err error) {
 // UpdateLastVideo -
 func (p *YoutubeChannel) UpdateLastVideo(vid string) (err error) {
 	p.LastVideo = vid
-	_, err = x.NamedExec(`update "public"."youtube_channel" set "lastvideo" = :lastvideo where "id" = :id`, p)
+	_, err = x.NamedExec(`update "public"."youtube_channel" set "lastvideo" = :lastvideo, "mtime" = now() where "id" = :id`, p)
 	return
 }
 
 // UpdateExpire -
 func (p *YoutubeChannel) UpdateExpire(t int64) (err error) {
 	p.Expire = t
-	_, err = x.NamedExec(`update "public"."youtube_channel" set "expire" = :expire where "id" = :id`, p)
+	_, err = x.NamedExec(`update "public"."youtube_channel" set "expire" = :expire, "mtime" = now() where "id" = :id`, p)
 	if err != nil {
 		return err
 	}

router/api/line.go

@@ -1,6 +1,7 @@
 package api
 
 import (
+	"fmt"
 	"strconv"
 
 	"git.trj.tw/golang/mtfosbot/model"
@@ -49,8 +50,17 @@ func GetLineMessageLog(c *context.Context) {
 	g := c.DefaultQuery("group", "")
 	u := c.DefaultQuery("user", "")
 
-	count, err := model.GetLineMessageLogCount()
+	where := make(map[string]string)
+	if len(g) > 0 {
+		where["group"] = g
+	}
+	if len(u) > 0 {
+		where["user"] = u
+	}
+
+	count, err := model.GetLineMessageLogCount(where)
 	if err != nil {
+		fmt.Println("count error :::: ", err)
 		c.ServerError(nil)
 		return
 	}