diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index 41cbf3da9..f559bddf0 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -2199,32 +2199,19 @@ func writeToExcel(excelTitle []string, dataList interface{}, ctx *jxcontext.Cont func RefreshJdDepot(ctx *jxcontext.Context) (err error) { var ( - pageSize = 20 - searchResults []*jdapi.SearchDeleteWareResult - searchResultsInterface []interface{} - db = dao.GetDB() - pageList []int + pageSize = 20 + searchResults []*jdapi.SearchDeleteWareResult + db = dao.GetDB() + pageList []int // skuIDs []int ) for i := 186; i < 367; i++ { - pageList = append(pageList, i) - } - task := tasksch.NewParallelTask("RefreshOrdersPriceInfo", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, - func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { - page := batchItemList[0].(int) - searchDeleteWareResults, err := api.JdAPI.SearchDeleteWare("2020-04-22", "2020-04-23", page, pageSize) - if err == nil && len(searchDeleteWareResults) > 0 { - for _, v := range searchDeleteWareResults { - retVal = []*jdapi.SearchDeleteWareResult{v} - } - } - return retVal, err - }, pageList) - tasksch.HandleTask(task, nil, true).Run() - searchResultsInterface, err = task.GetResult(0) - for _, v := range searchResultsInterface { - searchResults = append(searchResults, v.(*jdapi.SearchDeleteWareResult)) + searchDeleteWareResults, err := api.JdAPI.SearchDeleteWare("2020-04-22", "2020-04-23", page, pageSize) + if err == nil && len(searchDeleteWareResults) > 0 { + searchResults = append(searchResults, searchDeleteWareResults...) + } } + for _, v := range searchResults { param := &jdapi.OpSkuParam{ TraceID: ctx.GetTrackInfo(),