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

银豹到京西测试拉商品数

Browse Source
This commit is contained in:
苏尹岚
2020-04-29 14:39:33 +08:00
parent bd0a82306f
commit 0589f6a947
2 changed files with 28 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
business/jxstore/cms/sync.go
View File

@@ -958,22 +958,22 @@ func syncStoreSkusFromYb(ctx *jxcontext.Context, storeID, vendorID int, vendorSt
store, _ := dao.GetStoreDetail(db, storeID, vendorID) store, _ := dao.GetStoreDetail(db, storeID, vendorID)
switch step { switch step {
case 0: case 0:
if len(addList) > 0 { // if len(addList) > 0 {
taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { // taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
var ( // var (
v = batchItemList[0].(*partner.SkuNameInfo) // v = batchItemList[0].(*partner.SkuNameInfo)
upc = v.YbBarCode // upc = v.YbBarCode
) // )
err = AddSkuNameByUpc(ctx, upc, store, v) // err = AddSkuNameByUpc(ctx, upc, store, v)
if err != nil { // if err != nil {
task.AddFailedList(putils.GetErrMsg2FailedSingleList(nil, err, storeID, model.VendorChineseNames[vendorID], "根据upc创建京西商品")) // task.AddFailedList(putils.GetErrMsg2FailedSingleList(nil, err, storeID, model.VendorChineseNames[vendorID], "根据upc创建京西商品"))
} // }
return retVal, err // return retVal, err
} // }
taskParallel := tasksch.NewParallelTask("创建商品", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, taskFunc, addList) // taskParallel := tasksch.NewParallelTask("创建商品", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, taskFunc, addList)
tasksch.HandleTask(taskParallel, task, true).Run() // tasksch.HandleTask(taskParallel, task, true).Run()
_, err = taskParallel.GetResult(0) // _, err = taskParallel.GetResult(0)
} // }
case 1: case 1:
if len(deleteList) > 0 { if len(deleteList) > 0 {
taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {

12
business/partner/purchase/yb/store_sku.go
View File

@@ -124,6 +124,18 @@ func (p *PurchaseHandler) GetStoreSkusFullInfo(ctx *jxcontext.Context, parentTas
} }
} }
} else { } else {
for _, v := range result.Result {
resultp, err := api.YinBaoAPI.QueryProductImagesByBarcode(v.Barcode)
// resultp, err := getProductImages(vendorStoreID, v.Barcode)
if err != nil {
return nil, err
}
vv := &yinbaoapi.QueryProductByBarcodeResult{}
err = utils.Map2StructByJson(utils.Struct2MapByJson(v), vv, false)
if skuName := vendorSku2Jx(vv, resultp); skuName != nil {
skuNameList = append(skuNameList, skuName)
}
}
loopPages(result.PostBackParameter.ParameterType, result.PostBackParameter.ParameterValue, &skuNameList, vendorStoreID) loopPages(result.PostBackParameter.ParameterType, result.PostBackParameter.ParameterValue, &skuNameList, vendorStoreID)
} }
} }