diff --git a/business/jxstore/cms/job.go b/business/jxstore/cms/job.go index fc883c1e5..848173d8b 100644 --- a/business/jxstore/cms/job.go +++ b/business/jxstore/cms/job.go @@ -1218,7 +1218,7 @@ func CheckJdDeliveryWeight(ctx *jxcontext.Context) (err error) { if err != nil { return err } - task := tasksch.NewParallelTask("CheckJdDeliveryWeight", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx, + task := tasksch.NewParallelTask("CheckJdDeliveryWeight", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), nil, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { deliveryOrder := batchItemList[0].(*model.DeliveryOrder) waybill, err := api.JdEclpAPI.WaybillQuery(deliveryOrder.VendorWaybillID)