This commit is contained in:
suyl
2021-06-17 10:10:34 +08:00
parent ee614ea369
commit c037b8df1f

View File

@@ -1856,7 +1856,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeMap := batchItemList[0].(*model.StoreMap)
storeSkus, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, nil)
storeSkus, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, []int{6092260, 27007, 6043692, 27008, 27009})
FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []*model.StoreSkuBind) (result interface{}, successCount int, err error) {
api := jd.GetAPI("320406")
var ids []int64