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

fix job

Browse Source
This commit is contained in:
shoopea 2019-08-23 14:08:45 +08:00
parent 7dfba868ed
commit c47ec52a82
1 changed files with 20 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
job.go
View File

@ -738,29 +738,30 @@ func jobGDeposit(j Job) {
}
}
}
p2 := JobPayloadGDeposit{
MsgID64: p.MsgID64,
ChatID64: p.ChatID64,
ResObjID64: nil,
Status: 1,
/*
p2 := JobPayloadGDeposit{
MsgID64: p.MsgID64,
ChatID64: p.ChatID64,
ResObjID64: nil,
Status: 1,
}
p2.ResObjID64 = append(p2.ResObjID64, obj.ObjID64)
b2, _ := json.Marshal(&p2)
err = createJobCallback(objSubTypeJobGDeposit, j.UserID64, objSubTypeMessageOrderbookAck, b2)
clientSendCWMsg(p.ChatID64, fmt.Sprintf("/t_%s", obj.Code))
logOnError(err, "jobGDeposit : createJobCallback")
}
p2.ResObjID64 = append(p2.ResObjID64, obj.ObjID64)
b2, _ := json.Marshal(&p2)
err = createJobCallback(objSubTypeJobGDeposit, j.UserID64, objSubTypeMessageOrderbookAck, b2)
clientSendCWMsg(p.ChatID64, fmt.Sprintf("/t_%s", obj.Code))
p.ResObjID64 = p.ResObjID64[1:]
}
if len(p.ResObjID64) > 0 {
b, _ := json.Marshal(&p)
err = createJobCallback(objSubTypeJobGDeposit, j.UserID64, objSubTypeMessageOrderbookAck, b)
logOnError(err, "jobGDeposit : createJobCallback")
}
p.ResObjID64 = p.ResObjID64[1:]
}
if len(p.ResObjID64) > 0 {
b, _ := json.Marshal(&p)
err = createJobCallback(objSubTypeJobGDeposit, j.UserID64, objSubTypeMessageOrderbookAck, b)
logOnError(err, "jobGDeposit : createJobCallback")
}
*/
return
} else if p.Status == 1 { /* handle that one resource from the objSubTypeMessageOrderbookAck msg */