京东恢复id

business/jxstore/cms/sku.go

@@ -2201,30 +2201,17 @@ func RefreshJdDepot(ctx *jxcontext.Context) (err error) {
 	var (
 		pageSize      = 20
 		searchResults []*jdapi.SearchDeleteWareResult
-		searchResultsInterface []interface{}
 		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 {
+			searchResults = append(searchResults, 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))
-	}
 	for _, v := range searchResults {
 		param := &jdapi.OpSkuParam{
 			TraceID:     ctx.GetTrackInfo(),