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

银豹同步到京西ooooo

Browse Source
This commit is contained in:
苏尹岚
2020-04-29 14:42:54 +08:00
parent 0589f6a947
commit 34683bb26e
2 changed files with 19 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -950,7 +950,7 @@ func syncStoreSkusFromYb(ctx *jxcontext.Context, storeID, vendorID int, vendorSt
deleteList = append(deleteList, v) deleteList = append(deleteList, v)
} }
} }
fmt.Println("remoteSkuList", len(remoteSkuList)) // fmt.Println("remoteSkuList", len(remoteSkuList))
// fmt.Println("addList", len(addList)) // fmt.Println("addList", len(addList))
// fmt.Println("updateList", len(updateList)) // fmt.Println("updateList", len(updateList))
// fmt.Println("deleteList", len(deleteList)) // fmt.Println("deleteList", len(deleteList))
@@ -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) {

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

@@ -415,12 +415,12 @@ func loopPages(parameterType, parameterValue string, skuNameList *[]*partner.Sku
return err return err
} }
for _, v := range resultPages.Result { for _, v := range resultPages.Result {
// resultp, err := api.YinBaoAPI.QueryProductImagesByBarcode(v.Barcode) resultp, err := api.YinBaoAPI.QueryProductImagesByBarcode(v.Barcode)
// resultp, err := getProductImages(vendorStoreID, v.Barcode) // resultp, err := getProductImages(vendorStoreID, v.Barcode)
if err != nil { if err != nil {
return err return err
} }
var resultp []*yinbaoapi.QueryProductImagesByBarcodeResult // var resultp []*yinbaoapi.QueryProductImagesByBarcodeResult
vv := &yinbaoapi.QueryProductByBarcodeResult{} vv := &yinbaoapi.QueryProductByBarcodeResult{}
err = utils.Map2StructByJson(utils.Struct2MapByJson(v), vv, false) err = utils.Map2StructByJson(utils.Struct2MapByJson(v), vv, false)
if skuName := vendorSku2Jx(vv, resultp); skuName != nil { if skuName := vendorSku2Jx(vv, resultp); skuName != nil {