chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update get stash

Browse Source
This commit is contained in:
shoopea 2020-06-21 13:03:46 +02:00
parent f44f64db31
commit a68e5b0f73
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
def.go
View File

@ -630,7 +630,7 @@ type JobPayloadGetStash struct {
ClientID64 []int64 `json:"clients_id"` ClientID64 []int64 `json:"clients_id"`
ClientCount int64 `json:"client_count"` ClientCount int64 `json:"client_count"`
Stock []ChatWarsItems `json:"stock"` Stock []ChatWarsItems `json:"stock"`
CleanupMsgs []ChatWarsMessage `json:"cleanup_msg"` CleanupMsg []ChatWarsMessage `json:"cleanup_msg"`
} }
const ( const (

6
job.go
View File

@ -2087,12 +2087,12 @@ func jobGetStash(j Job) {
rule, err := getMsgParsingRule(m) rule, err := getMsgParsingRule(m)
logOnError(err, "jobAlchAll : getMsgParsingRule") logOnError(err, "jobAlchAll : getMsgParsingRule")
if rule.MsgTypeID64 == cacheObjSubType[`msg_exchange_req`] { if rule.MsgTypeID64 == cacheObjSubType[`msg_exchange_req`] {
p.CleanupMsgs = append(p.CleanupMsg, *m) p.CleanupMsg = append(p.CleanupMsg, *m)
setJobPayloadJSON(j.ID64, p) setJobPayloadJSON(j.ID64, p)
rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC()) rescheduleJob(j.ID64, 0, time.Unix(maxUnixTimestamp, 0).UTC())
return return
} else if rule.MsgTypeID64 == cacheObjSubType[`msg_exchange_ack`] { } 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 { for k, v := range p.ClientID64 {
if v == j.UserID64 { if v == j.UserID64 {
p.ClientID64[len(p.ClientID64)-1], p.ClientID64[k] = p.ClientID64[k], p.ClientID64[len(p.ClientID64)-1] 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 j.Trigger = 0
} else if rule.MsgTypeID64 == cacheObjSubType[`msg_busy`] { } else if rule.MsgTypeID64 == cacheObjSubType[`msg_busy`] {
p.CleanupMsgs = append(p.CleanupMsg, *m) p.CleanupMsg = append(p.CleanupMsg, *m)
} }
} }
} }