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

tt

Browse Source
This commit is contained in:
苏尹岚
2020-12-04 09:49:18 +08:00
parent 219d0fb9cb
commit 7e92f3cf1a
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
business/jxstore/cms/sku.go
View File

@@ -895,7 +895,7 @@ func AddSkuName(ctx *jxcontext.Context, skuNameExt *model.SkuNameExt, userName s
if beego.BConfig.RunMode == "jxgy" { if beego.BConfig.RunMode == "jxgy" {
sku.LadderBoxPrice = 0 sku.LadderBoxPrice = 0
} else if beego.BConfig.RunMode == "prod" { } else if beego.BConfig.RunMode == "prod" {
sku.LadderBoxPrice = 30 sku.LadderBoxPrice = 10
} }
sku.LadderBoxNum = 1 sku.LadderBoxNum = 1
if err = dao.CreateEntity(db, sku); err != nil { if err = dao.CreateEntity(db, sku); err != nil {
@@ -1234,7 +1234,7 @@ func AddSku(ctx *jxcontext.Context, nameID int, sku *model.Sku, userName string)
if beego.BConfig.RunMode == "jxgy" { if beego.BConfig.RunMode == "jxgy" {
sku.LadderBoxPrice = 0 sku.LadderBoxPrice = 0
} else if beego.BConfig.RunMode == "prod" { } else if beego.BConfig.RunMode == "prod" {
sku.LadderBoxPrice = 30 sku.LadderBoxPrice = 10
} }
sku.LadderBoxNum = 1 sku.LadderBoxNum = 1
dao.Begin(db) dao.Begin(db)

4
business/jxstore/tempop/tempop.go
View File

@@ -1763,11 +1763,11 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
` `
err = dao.GetRows(db, &storeMaps, sql, nil) err = dao.GetRows(db, &storeMaps, sql, nil)
storeSkus, _ := dao.GetStoresSkusInfo(db, []int{model.JdShopMainStoreID2}, nil) storeSkus, _ := dao.GetStoresSkusInfo(db, []int{model.JdShopMainStoreID2}, nil)
task := tasksch.NewParallelTask("京东商城门店建商品1", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask("京东商城门店建商品1", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
func(task2 *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task2 *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(*model.StoreSkuBind) v := batchItemList[0].(*model.StoreSkuBind)
if v.JdsID != 0 { if v.JdsID != 0 {
task := tasksch.NewParallelTask("京东商城门店建商品2", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask("京东商城门店建商品2", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeMap := batchItemList[0].(*model.StoreMap) storeMap := batchItemList[0].(*model.StoreMap)
if err = api.JdShop2API.StoreSkuBindStore(false, []string{utils.Int64ToStr(v.JdsID)}, []string{storeMap.VendorStoreID}); err == nil { if err = api.JdShop2API.StoreSkuBindStore(false, []string{utils.Int64ToStr(v.JdsID)}, []string{storeMap.VendorStoreID}); err == nil {