liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

读取永辉excel

Browse Source
This commit is contained in:
苏尹岚
2019-11-18 18:40:57 +08:00
parent 07e9f29e5a
commit 469332db88
1 changed files with 97 additions and 119 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
business/jxstore/yonghui/yonghui.go
View File

@@ -104,9 +104,7 @@ func LoadExcelBinByYongHui(ctx *jxcontext.Context, reader io.Reader, isAsync, Is
goodsIDListForPutAway []interface{} goodsIDListForPutAway []interface{}
) )
db := dao.GetDB() db := dao.GetDB()
taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
switch step {
case 0:
//读取excel文件 //读取excel文件
xlsx, err := excelize.OpenReader(reader) xlsx, err := excelize.OpenReader(reader)
if err != nil { if err != nil {
@@ -128,13 +126,14 @@ func LoadExcelBinByYongHui(ctx *jxcontext.Context, reader io.Reader, isAsync, Is
return "", errors.New(errMsg) return "", errors.New(errMsg)
} }
} }
case 1:
//获取微盟所有商品 //获取微盟所有商品
goodsList, err = GetWeiMobGoodsList() goodsList, err = GetWeiMobGoodsList()
if err != nil { if err != nil {
baseapi.SugarLogger.Errorf("GetWeiMobGoodsList error:%v", err) baseapi.SugarLogger.Errorf("GetWeiMobGoodsList error:%v", err)
} }
taskFunc2 := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { task := tasksch.NewParallelTask("获取微盟商品", tasksch.NewParallelConfig().SetIsContinueWhenError(IsContinueWhenError), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(*weimobapi.GoodsInfo) v := batchItemList[0].(*weimobapi.GoodsInfo)
goodsDetail, err := api.WeimobAPI.QueryGoodsDetail(v.GoodsID) goodsDetail, err := api.WeimobAPI.QueryGoodsDetail(v.GoodsID)
if err != nil { if err != nil {
@@ -142,28 +141,26 @@ func LoadExcelBinByYongHui(ctx *jxcontext.Context, reader io.Reader, isAsync, Is
} }
v.GoodsDetailInfo = goodsDetail v.GoodsDetailInfo = goodsDetail
return retVal, err return retVal, err
} }, goodsList)
taskParallel2 := tasksch.NewParallelTask("获取微盟商品", tasksch.NewParallelConfig().SetParallelCount(parallelCount), ctx, taskFunc2, goodsList) tasksch.HandleTask(task, nil, true).Run()
tasksch.HandleTask(taskParallel2, task, true).Run()
_, err = taskParallel2.GetResult(0)
case 2:
//找出excel上有，微盟没有的,有就列出报错，不进行更新 //找出excel上有，微盟没有的,有就列出报错，不进行更新
goodsInfoAndDetailMap := GetGoodsInfoAndDetailMap(goodsList) goodsInfoAndDetailMap := GetGoodsInfoAndDetailMap(goodsList)
skuMapList := GetSkuMapList(skuMap) skuMapList := GetSkuMapList(skuMap)
taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { task1 := tasksch.NewParallelTask("对比Excel上有微盟上没有的商品", tasksch.NewParallelConfig().SetIsContinueWhenError(IsContinueWhenError), ctx,
func(task1 *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
k := batchItemList[0].(string) k := batchItemList[0].(string)
//表示excel上有，微盟上没有 //表示excel上有，微盟上没有
if goodsInfoAndDetailMap[k] == nil { if goodsInfoAndDetailMap[k] == nil {
return "", errors.New(fmt.Sprintf("在微盟上未找到该商品！excel商品ID : [%v]\n", k)) return "", errors.New(fmt.Sprintf("在微盟上未找到该商品！excel商品ID : [%v]\n", k))
} }
return retVal, err return retVal, err
} }, skuMapList)
taskParallel := tasksch.NewParallelTask("对比Excel上有微盟上没有的商品", tasksch.NewParallelConfig().SetIsContinueWhenError(IsContinueWhenError), ctx, taskFunc, skuMapList) tasksch.HandleTask(task1, nil, true).Run()
tasksch.HandleTask(taskParallel, task, true).Run()
_, err = taskParallel.GetResult(0)
case 3:
//找出微盟上有，excel上没有的，有就更新，没有就下架 //找出微盟上有，excel上没有的，有就更新，没有就下架
taskFunc3 := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { task2 := tasksch.NewParallelTask("根据获取的微盟所有商品并更新", tasksch.NewParallelConfig().SetIsContinueWhenError(IsContinueWhenError), ctx,
func(task1 *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
goods := batchItemList[0].(*weimobapi.GoodsInfo) goods := batchItemList[0].(*weimobapi.GoodsInfo)
goodsDetail := goods.GoodsDetailInfo goodsDetail := goods.GoodsDetailInfo
spuCode := goodsDetail.OuterGoodsCode spuCode := goodsDetail.OuterGoodsCode
@@ -194,40 +191,21 @@ func LoadExcelBinByYongHui(ctx *jxcontext.Context, reader io.Reader, isAsync, Is
} }
} }
return retVal, err return retVal, err
} }, goodsList)
taskParallel3 := tasksch.NewParallelTask("根据获取的微盟所有商品并更新", tasksch.NewParallelConfig().SetParallelCount(parallelCount).SetIsContinueWhenError(IsContinueWhenError), ctx, taskFunc3, goodsList) tasksch.HandleTask(task2, nil, true).Run()
tasksch.HandleTask(taskParallel3, task, true).Run() goodsIDListForPutAwayInterface, err := task2.GetResult(0)
goodsIDListForPutAwayInterface, err2 := taskParallel3.GetResult(0)
if err = err2; err != nil {
return "", err
}
goodsIDListForPutAway = goodsIDListForPutAwayInterface goodsIDListForPutAway = goodsIDListForPutAwayInterface
case 4:
// 批量下架微盟商品 // 批量下架微盟商品
// if errMsg == "" { task3 := tasksch.NewParallelTask("下架微盟商品", tasksch.NewParallelConfig().SetIsContinueWhenError(IsContinueWhenError), ctx,
taskFunc4 := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task1 *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
int64Slice := []int64{} int64Slice := []int64{}
for _, v := range batchItemList { for _, v := range batchItemList {
int64Slice = append(int64Slice, v.(int64)) int64Slice = append(int64Slice, v.(int64))
} }
PutAwayWeiMobSku(int64Slice) PutAwayWeiMobSku(int64Slice)
return retVal, err return retVal, err
} }, goodsIDListForPutAway)
taskParallel4 := tasksch.NewParallelTask("下架微盟商品", tasksch.NewParallelConfig().SetParallelCount(parallelCount).SetBatchSize(UpdateGoodsShelfStatusCount), ctx, taskFunc4, goodsIDListForPutAway) tasksch.HandleTask(task3, nil, true).Run()
tasksch.HandleTask(taskParallel4, task, true).Run()
_, err = taskParallel4.GetResult(0)
// }
}
return result, err
}
taskSeq := tasksch.NewSeqTask("读取永辉Excel文件修改微盟商品价格可售状态-序列任务", ctx, taskSeqFunc, 5)
tasksch.HandleTask(taskSeq, nil, true).Run()
if !isAsync {
_, err = taskSeq.GetResult(0)
hint = "1"
} else {
hint = taskSeq.GetID()
}
return hint, err return hint, err
} }