diff --git a/job.go b/job.go index 4424ec6..7b375f8 100644 --- a/job.go +++ b/job.go @@ -2099,14 +2099,14 @@ func jobGetStash(j Job) { p.ClientID64 = p.ClientID64[:len(p.ClientID64)-1] } } - p.Trigger = 0 + j.Trigger = 0 } else if rule.MsgTypeID64 == cacheObjSubType[`msg_busy`] { p.CleanupMsgs = append(p.CleanupMsg, *m) } } } - if len(p.ClientID64) > 0 && p.Trigger == 0 { + if len(p.ClientID64) > 0 && j.Trigger == 0 { var ( userID64 int64 = 0 busyUntil time.Time = time.Now().UTC() @@ -2128,7 +2128,7 @@ func jobGetStash(j Job) { clientSendCWMsgDelay(userID64, "âš–Exchange", time.Now().UTC().Add(-2*time.Second).Sub(busyUntil)) } - if len(p.ClientID64) == 0 && p.Trigger == 0 { + if len(p.ClientID64) == 0 && j.Trigger == 0 { for _, m := range p.CleanupMsg { clientDelTGMsg(m.TGUserID64, m.ID64, m.ChatID64) }