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

test

Browse Source
This commit is contained in:
shoopea 2019-06-14 12:18:52 +08:00
parent 776c5949c2
commit e79667d36c
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
job.go
View File

@ -207,12 +207,12 @@ func jobRescan(j Job) {
SQLMsgIdentifyQueue <- ids[0] SQLMsgIdentifyQueue <- ids[0]
err = setJobDone(j.ID64) err = setJobDone(j.ID64)
logOnError(err, "jobRescan : setJobDone(1)") logOnError(err, "jobRescan : setJobDone(1)")
if r.MsgID64 != 0 || r.ChatID64 != 0 { if p.MsgID64 != 0 || p.ChatID64 != 0 {
m := TGCommand{ m := TGCommand{
Type: commandReplyMsg, Type: commandReplyMsg,
Text: "One message processed.", Text: "One message processed.",
FromMsgID64: r.MsgID64, FromMsgID64: p.MsgID64,
FromChatID64: r.ChatID64, FromChatID64: p.ChatID64,
} }
TGCmdQueue <- m TGCmdQueue <- m
} }
@ -223,8 +223,8 @@ func jobRescan(j Job) {
m := TGCommand{ m := TGCommand{
Type: commandReplyMsg, Type: commandReplyMsg,
Text: "No message processed.", Text: "No message processed.",
FromMsgID64: r.MsgID64, FromMsgID64: p.MsgID64,
FromChatID64: r.ChatID64, FromChatID64: p.ChatID64,
} }
TGCmdQueue <- m TGCmdQueue <- m
} }