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

fix

Browse Source
This commit is contained in:
shoopea 2020-06-29 11:04:13 +02:00
parent e057c8ccf3
commit c23c2203b2
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
def.go
View File

@ -638,6 +638,7 @@ type JobPayloadShopsSlave struct {
type JobPayloadGetStash struct { type JobPayloadGetStash struct {
MsgID64 int64 `json:"msg_id"` MsgID64 int64 `json:"msg_id"`
ChatID64 int64 `json:"chat_id"` ChatID64 int64 `json:"chat_id"`
UserID64 int64 `json:"user_id"`
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"`

3
job.go
View File

@ -2082,7 +2082,7 @@ func jobGetStash(j Job) {
fmt.Printf("jobGetStash : Start ..\n") fmt.Printf("jobGetStash : Start ..\n")
fmt.Printf("jobGetStash : Trigger : %d\n", j.Trigger) fmt.Printf("jobGetStash : Trigger : %d\n", j.Trigger)
fmt.Printf("jobGetStash : UserID64 : %d\n", j.UserID64) fmt.Printf("jobGetStash : UserID64 : %d\n", p.UserID64)
fmt.Printf("jobGetStash : len(p.ClientID64) : %d\n", len(p.ClientID64)) fmt.Printf("jobGetStash : len(p.ClientID64) : %d\n", len(p.ClientID64))
if j.Trigger > 0 { if j.Trigger > 0 {
@ -2137,6 +2137,7 @@ func jobGetStash(j Job) {
clt.Mux.Unlock() clt.Mux.Unlock()
} }
} }
p.UserID64 = userID64
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_exchange_req`]) setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_exchange_req`])
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_exchange_ack`]) setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_exchange_ack`])
setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_busy`]) setJobCallback(j.ID64, userID64, cacheObjSubType[`msg_busy`])