diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index f4fdcaff7..e986cd649 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1913,10 +1913,10 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { pageSize = 20 pages []int ) - for page := 1; page < 5; page++ { + for page := 1; page < 7678; page++ { pages = append(pages, page) } - task := tasksch.NewParallelTask2("京东会员", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, + task := tasksch.NewParallelTask2("京东会员", tasksch.NewParallelConfig().SetIsContinueWhenError(true).SetParallelCount(1), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) { page := batchItemList[0].(int) results, _ := api.JdAPI.QueryMemberTransListByCondition(page, pageSize) @@ -1944,8 +1944,8 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { } return retVal, successCount, err }, pages) - tasksch.HandleTask(task, nil, false).Run() - task.GetID() + tasksch.HandleTask(task, nil, true).Run() + task.GetResult(0) //刷新京东真实订单号 //var ( // db = dao.GetDB()