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