test stash
This commit is contained in:
parent
5dbfacb1f3
commit
2942d755d8
10
job.go
10
job.go
@ -2129,6 +2129,16 @@ func jobGetStash(j Job) {
|
|||||||
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_busy`])
|
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_busy`])
|
||||||
rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC())
|
rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC())
|
||||||
clientSendCWMsgDelay(userID64, "⚖Exchange", busyUntil.Add(2*time.Second).Sub(time.Now().UTC()))
|
clientSendCWMsgDelay(userID64, "⚖Exchange", busyUntil.Add(2*time.Second).Sub(time.Now().UTC()))
|
||||||
|
|
||||||
|
c := TGCommand{
|
||||||
|
Type: commandReplyMsg,
|
||||||
|
Text: fmt.Sprintf("Client[%d/%d] : %d", (p.ClientCount - len(p.ClientID64) + 1), p.ClientCount, userID64),
|
||||||
|
FromMsgID64: p.MsgID64,
|
||||||
|
FromChatID64: p.ChatID64,
|
||||||
|
ParseMode: cmdParseModeHTML,
|
||||||
|
}
|
||||||
|
TGCmdQueue <- c
|
||||||
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if len(p.ClientID64) == 0 && j.Trigger == 0 {
|
if len(p.ClientID64) == 0 && j.Trigger == 0 {
|
||||||
|
Loading…
Reference in New Issue
Block a user