根据excel创建标品改为异步
This commit is contained in:
@@ -1740,18 +1740,18 @@ func buildCreateUpcSkuByExcelErr(v *model.SkuName, errMsg string) (createUpcSkuB
|
||||
return createUpcSkuByExcelErr
|
||||
}
|
||||
|
||||
func CreateUpcSkuByExcel(ctx *jxcontext.Context, files []*multipart.FileHeader) (err error) {
|
||||
func CreateUpcSkuByExcel(ctx *jxcontext.Context, files []*multipart.FileHeader) (hint string, err error) {
|
||||
if len(files) == 0 {
|
||||
return errors.New("没有文件上传!")
|
||||
return "", errors.New("没有文件上传!")
|
||||
}
|
||||
fileHeader := files[0]
|
||||
file, err := fileHeader.Open()
|
||||
err = CreateUpcSkuByExcelBin(ctx, file)
|
||||
hint, err = CreateUpcSkuByExcelBin(ctx, file)
|
||||
file.Close()
|
||||
return err
|
||||
return hint, err
|
||||
}
|
||||
|
||||
func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (err error) {
|
||||
func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (hint string, err error) {
|
||||
var (
|
||||
db = dao.GetDB()
|
||||
skuParams []*model.SkuName
|
||||
@@ -1955,8 +1955,8 @@ func CreateUpcSkuByExcelBin(ctx *jxcontext.Context, reader io.Reader) (err error
|
||||
}
|
||||
taskSeq := tasksch.NewSeqTask2("根据excel创建标品-序列任务", ctx, true, taskSeqFunc, 3)
|
||||
tasksch.HandleTask(taskSeq, nil, true).Run()
|
||||
_, err = taskSeq.GetResult(0)
|
||||
return err
|
||||
hint = taskSeq.GetID()
|
||||
return hint, err
|
||||
}
|
||||
|
||||
func writeToExcel(excelTitle []string, dataList interface{}, task *tasksch.SeqTask) (err error) {
|
||||
|
||||
Reference in New Issue
Block a user