liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
suyl
2021-05-13 18:24:05 +08:00
parent 861bffc87b
commit 80e6fc77c9
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
business/jxstore/tempop/tempop.go
View File

@@ -1913,10 +1913,10 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
pageSize = 20 pageSize = 20
pages []int pages []int
) )
for page := 1; page < 5; page++ { for page := 1; page < 7678; page++ {
pages = append(pages, 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) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) {
page := batchItemList[0].(int) page := batchItemList[0].(int)
results, _ := api.JdAPI.QueryMemberTransListByCondition(page, pageSize) results, _ := api.JdAPI.QueryMemberTransListByCondition(page, pageSize)
@@ -1944,8 +1944,8 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
} }
return retVal, successCount, err return retVal, successCount, err
}, pages) }, pages)
tasksch.HandleTask(task, nil, false).Run() tasksch.HandleTask(task, nil, true).Run()
task.GetID() task.GetResult(0)
//刷新京东真实订单号 //刷新京东真实订单号
//var ( //var (
// db = dao.GetDB() // db = dao.GetDB()