From a68e5b0f73c6c847a07ee0c73aa8dd3c143547b5 Mon Sep 17 00:00:00 2001 From: shoopea Date: Sun, 21 Jun 2020 13:03:46 +0200 Subject: [PATCH] update get stash --- def.go | 2 +- job.go | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/def.go b/def.go index 0698913..285df6c 100644 --- a/def.go +++ b/def.go @@ -630,7 +630,7 @@ type JobPayloadGetStash struct { ClientID64 []int64 `json:"clients_id"` ClientCount int64 `json:"client_count"` Stock []ChatWarsItems `json:"stock"` - CleanupMsgs []ChatWarsMessage `json:"cleanup_msg"` + CleanupMsg []ChatWarsMessage `json:"cleanup_msg"` } const ( diff --git a/job.go b/job.go index 7b375f8..66693a7 100644 --- a/job.go +++ b/job.go @@ -2087,12 +2087,12 @@ func jobGetStash(j Job) { rule, err := getMsgParsingRule(m) logOnError(err, "jobAlchAll : getMsgParsingRule") if rule.MsgTypeID64 == cacheObjSubType[`msg_exchange_req`] { - p.CleanupMsgs = append(p.CleanupMsg, *m) + p.CleanupMsg = append(p.CleanupMsg, *m) setJobPayloadJSON(j.ID64, p) rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC()) return } else if rule.MsgTypeID64 == cacheObjSubType[`msg_exchange_ack`] { - p.CleanupMsgs = append(p.CleanupMsg, *m) + p.CleanupMsg = append(p.CleanupMsg, *m) for k, v := range p.ClientID64 { if v == j.UserID64 { p.ClientID64[len(p.ClientID64)-1], p.ClientID64[k] = p.ClientID64[k], p.ClientID64[len(p.ClientID64)-1] @@ -2101,7 +2101,7 @@ func jobGetStash(j Job) { } j.Trigger = 0 } else if rule.MsgTypeID64 == cacheObjSubType[`msg_busy`] { - p.CleanupMsgs = append(p.CleanupMsg, *m) + p.CleanupMsg = append(p.CleanupMsg, *m) } } }