From ab880672917f213ae90bef735d86c9f1d12e0dda Mon Sep 17 00:00:00 2001 From: shoopea Date: Thu, 23 Jan 2020 14:10:58 +0800 Subject: [PATCH] fix --- job.go | 20 ++++++-------------- 1 file changed, 6 insertions(+), 14 deletions(-) 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