读取永辉excel
This commit is contained in:
@@ -199,8 +199,8 @@ func LoadExcelBinByYongHui(ctx *jxcontext.Context, reader io.Reader, isAsync, Is
|
|||||||
taskParallel3 := tasksch.NewParallelTask("根据获取的微盟所有商品并更新", tasksch.NewParallelConfig().SetParallelCount(parallelCount).SetIsContinueWhenError(IsContinueWhenError), ctx, taskFunc3, goodsList)
|
taskParallel3 := tasksch.NewParallelTask("根据获取的微盟所有商品并更新", tasksch.NewParallelConfig().SetParallelCount(parallelCount).SetIsContinueWhenError(IsContinueWhenError), ctx, taskFunc3, goodsList)
|
||||||
tasksch.HandleTask(taskParallel3, task, true).Run()
|
tasksch.HandleTask(taskParallel3, task, true).Run()
|
||||||
goodsIDListForPutAwayInterface, err2 = taskParallel3.GetResult(0)
|
goodsIDListForPutAwayInterface, err2 = taskParallel3.GetResult(0)
|
||||||
if err = err2; err != nil {
|
if err2 != nil {
|
||||||
return "", err
|
errMsg += err2.Error()
|
||||||
}
|
}
|
||||||
case 3:
|
case 3:
|
||||||
// 批量下架微盟商品
|
// 批量下架微盟商品
|
||||||
@@ -219,7 +219,7 @@ func LoadExcelBinByYongHui(ctx *jxcontext.Context, reader io.Reader, isAsync, Is
|
|||||||
// }
|
// }
|
||||||
}
|
}
|
||||||
if err == nil {
|
if err == nil {
|
||||||
return result, errors.New(errMsg + err2.Error())
|
return result, errors.New(errMsg)
|
||||||
}
|
}
|
||||||
return result, err
|
return result, err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user