diff --git a/job.go b/job.go index a2dc23a..683ae14 100644 --- a/job.go +++ b/job.go @@ -1520,21 +1520,17 @@ func jobGWithdraw(j Job) { } } - m, err := getObjMsg(j.Trigger) - logOnError(err, "jobGWithdraw : getObjMsg") - if err == nil { - p.CleanupMsg = append(p.CleanupMsg, *m) - } + p.CleanupMsg = append(p.CleanupMsg, *m) if isUnique { for _, req := range p.Items { if req.Inspect { - p2 = JobPayloadMsgDel{ + p2 := JobPayloadMsgDel{ MsgTypeID64: cacheObjSubType[`msg_g_inspect_req`], Delay: (10 * time.Second), ObjMsgID64: 0, } - b2, _ = json.Marshal(p2) + b2, _ := json.Marshal(p2) createJobCallback(cacheObjSubType[`job_msg_del`], j.UserID64, p2.MsgTypeID64, b2, time.Minute) p.Inspecting = req.Code @@ -1568,20 +1564,16 @@ func jobGWithdraw(j Job) { } p.Inspecting = `` - m, err := getObjMsg(j.Trigger) - logOnError(err, "jobGWithdraw : getObjMsg") - if err == nil { - p.CleanupMsg = append(p.CleanupMsg, *m) - } + p.CleanupMsg = append(p.CleanupMsg, *m) for _, req := range p.Items { if req.Inspect { - p2 = JobPayloadMsgDel{ + p2 := JobPayloadMsgDel{ MsgTypeID64: cacheObjSubType[`msg_g_inspect_req`], Delay: (10 * time.Second), ObjMsgID64: 0, } - b2, _ = json.Marshal(p2) + b2, _ := json.Marshal(p2) createJobCallback(cacheObjSubType[`job_msg_del`], j.UserID64, p2.MsgTypeID64, b2, time.Minute) p.Inspecting = req.Code