diff --git a/business/jxstore/cms/job.go b/business/jxstore/cms/job.go index 848173d8b..4346f0db4 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), nil, + task := tasksch.NewParallelTask("CheckJdDeliveryWeight", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), jxcontext.AdminCtx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { deliveryOrder := batchItemList[0].(*model.DeliveryOrder) waybill, err := api.JdEclpAPI.WaybillQuery(deliveryOrder.VendorWaybillID)