aa
This commit is contained in:
@@ -1913,7 +1913,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
|
|||||||
pageSize = 50
|
pageSize = 50
|
||||||
pages []int
|
pages []int
|
||||||
)
|
)
|
||||||
for page := 1; page < 3079; page++ {
|
for page := 3079; page >= 1; page-- {
|
||||||
pages = append(pages, page)
|
pages = append(pages, page)
|
||||||
}
|
}
|
||||||
task := tasksch.NewParallelTask2("京东会员", tasksch.NewParallelConfig().SetIsContinueWhenError(true).SetParallelCount(1), ctx,
|
task := tasksch.NewParallelTask2("京东会员", tasksch.NewParallelConfig().SetIsContinueWhenError(true).SetParallelCount(1), ctx,
|
||||||
@@ -1947,7 +1947,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
|
|||||||
return retVal, successCount, err
|
return retVal, successCount, err
|
||||||
}, pages)
|
}, pages)
|
||||||
tasksch.HandleTask(task, nil, true).Run()
|
tasksch.HandleTask(task, nil, true).Run()
|
||||||
task.GetResult(0)
|
task.GetID()
|
||||||
//刷新京东真实订单号
|
//刷新京东真实订单号
|
||||||
//var (
|
//var (
|
||||||
// db = dao.GetDB()
|
// db = dao.GetDB()
|
||||||
|
|||||||
Reference in New Issue
Block a user