chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
shoopea 2019-05-11 13:12:16 +08:00
parent 0ef91c7361
commit d6db9a08ba
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
bot.go
View File

@ -80,8 +80,8 @@ func botMsgRescan(m *tb.Message) (string, error) {
} }
r := regexp.MustCompile("^[0-9]+$") r := regexp.MustCompile("^[0-9]+$")
if r.MatchString(m.Payload) { if r.MatchString(m.Payload) {
fmt.Sprintf(s, "SELECT o.id from obj o where o.id = %s and o.obj_type_id = %d and o.obj_sub_type_id = %d;", m.Payload, objTypeMessage, objSubTypeMessageUnknown) fmt.Sprintf(q, "SELECT o.id from obj o where o.id = %s and o.obj_type_id = %d and o.obj_sub_type_id = %d;", m.Payload, objTypeMessage, objSubTypeMessageUnknown)
p.Query = s p.Query = q
b, _ := json.Marshal(p) b, _ := json.Marshal(p)
log.Printf("botMsgRescan : %s\n", string(b)) log.Printf("botMsgRescan : %s\n", string(b))
err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanMsg, time.Now(), b) err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanMsg, time.Now(), b)
@ -95,8 +95,8 @@ func botMsgRescan(m *tb.Message) (string, error) {
} }
r = regexp.MustCompile("^all$") r = regexp.MustCompile("^all$")
if r.MatchString(m.Payload) { if r.MatchString(m.Payload) {
fmt.Sprintf(s, "SELECT o.id from obj o where o.obj_type_id = %d and o.obj_sub_type_id = %d;", objTypeMessage, objSubTypeMessageUnknown) fmt.Sprintf(q, "SELECT o.id from obj o where o.obj_type_id = %d and o.obj_sub_type_id = %d;", objTypeMessage, objSubTypeMessageUnknown)
p.Query = s p.Query = q
b, _ := json.Marshal(p) b, _ := json.Marshal(p)
log.Printf("botMsgRescan : %s\n", string(b)) log.Printf("botMsgRescan : %s\n", string(b))
err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanAllMsg, time.Now(), b) err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanAllMsg, time.Now(), b)