From 3a73d6e55a09692bc561e9769cd8651ff57055af Mon Sep 17 00:00:00 2001 From: shoopea Date: Mon, 13 Jan 2020 17:03:56 +0800 Subject: [PATCH] fix job msg del --- job.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/job.go b/job.go index 9778b17..8daf54b 100644 --- a/job.go +++ b/job.go @@ -611,9 +611,11 @@ func jobMsgDelete(j Job) { logOnError(err, "jobMsgDelete : getObjMsg("+strconv.FormatInt(j.Trigger, 10)+")") clientDelTGMsg(j.UserID64, obj.ID64, obj.ChatID64) } else { + delay = p.Delay + p.Delay = 0 p.ObjMsgID64 = j.Trigger b, _ := json.Marshal(p) - _, err = createJob(cacheObjSubType[`job_msg_del`], objJobPriority, j.UserID64, 0, time.Now().Add(p.Delay).UTC(), b) + _, err = createJob(cacheObjSubType[`job_msg_del`], objJobPriority, j.UserID64, 0, time.Now().Add(delay).UTC(), b) } } else { log.Printf("jobMsgDelete : cannot identify msg to delete") @@ -624,9 +626,10 @@ func jobMsgDelete(j Job) { logOnError(err, "jobMsgDelete : getObjMsg("+strconv.FormatInt(p.ObjMsgID64, 10)+")") clientDelTGMsg(j.UserID64, obj.ID64, obj.ChatID64) } else { + delay := p.Delay p.Delay = 0 b, _ := json.Marshal(p) - _, err = createJob(cacheObjSubType[`job_msg_del`], objJobPriority, j.UserID64, 0, time.Now().Add(p.Delay).UTC(), b) + _, err = createJob(cacheObjSubType[`job_msg_del`], objJobPriority, j.UserID64, 0, time.Now().Add(delay).UTC(), b) } }