fix shop slave

This commit is contained in:
shoopea 2020-02-11 10:12:50 +08:00
parent f33570cc6f
commit 47e6db4353

14
job.go
View File

@ -2345,12 +2345,7 @@ func jobShopsSlave(j Job) {
} }
TGCmdQueue <- c TGCmdQueue <- c
for i, link := range p.Shops { p.Shops = append(p.Shops[:0], p.Shops[i+1:]...)
if cwm.Link == link {
p.Shops = append(p.Shops[:i], p.Shops[i+1:]...)
break
}
}
err = setJobPayloadJSON(j.ID64, p) err = setJobPayloadJSON(j.ID64, p)
logOnError(err, "jobShopsSlave : setJobPayloadJSON") logOnError(err, "jobShopsSlave : setJobPayloadJSON")
@ -2366,12 +2361,7 @@ func jobShopsSlave(j Job) {
err = setJobPayloadJSONUnsafe(p.JobCallbackID64, p2) err = setJobPayloadJSONUnsafe(p.JobCallbackID64, p2)
muxObjJob.Unlock() muxObjJob.Unlock()
for i, link := range p.Shops { p.Shops = append(p.Shops[:0], p.Shops[i+1:]...)
if cwm.Link == link {
p.Shops = append(p.Shops[:i], p.Shops[i+1:]...)
break
}
}
err = setJobPayloadJSON(j.ID64, p) err = setJobPayloadJSON(j.ID64, p)
logOnError(err, "jobShopsSlave : setJobPayloadJSON") logOnError(err, "jobShopsSlave : setJobPayloadJSON")