银豹创建商品测试
This commit is contained in:
@@ -434,7 +434,6 @@ func (v *VendorSync) SyncStoresSkus2(ctx *jxcontext.Context, parentTask tasksch.
|
|||||||
task, hint, err := v.LoopStoresMap2(ctx, parentTask, db, fmt.Sprintf("同步门店商品信息:%v", storeIDs), isAsync, isManageIt, vendorIDs, storeIDs, false,
|
task, hint, err := v.LoopStoresMap2(ctx, parentTask, db, fmt.Sprintf("同步门店商品信息:%v", storeIDs), isAsync, isManageIt, vendorIDs, storeIDs, false,
|
||||||
func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (interface{}, error) {
|
func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (interface{}, error) {
|
||||||
loopMapInfo := batchItemList[0].(*LoopStoreMapInfo)
|
loopMapInfo := batchItemList[0].(*LoopStoreMapInfo)
|
||||||
globals.SugarLogger.Debugf("ssss,[%v]", utils.Format4Output(loopMapInfo, false))
|
|
||||||
if handler := v.GetStoreHandler(loopMapInfo.VendorID); handler != nil {
|
if handler := v.GetStoreHandler(loopMapInfo.VendorID); handler != nil {
|
||||||
parallelCount := 5
|
parallelCount := 5
|
||||||
if model.MultiStoresVendorMap[loopMapInfo.VendorID] == 1 {
|
if model.MultiStoresVendorMap[loopMapInfo.VendorID] == 1 {
|
||||||
@@ -456,8 +455,6 @@ func (v *VendorSync) SyncStoresSkus2(ctx *jxcontext.Context, parentTask tasksch.
|
|||||||
}, loopMapInfo.StoreMapList)
|
}, loopMapInfo.StoreMapList)
|
||||||
t.AddChild(loopStoreTask).Run()
|
t.AddChild(loopStoreTask).Run()
|
||||||
_, err = loopStoreTask.GetResult(0)
|
_, err = loopStoreTask.GetResult(0)
|
||||||
} else {
|
|
||||||
globals.SugarLogger.Debugf("yaer")
|
|
||||||
}
|
}
|
||||||
return nil, partner.AddVendorInfo2Err(err, loopMapInfo.VendorID)
|
return nil, partner.AddVendorInfo2Err(err, loopMapInfo.VendorID)
|
||||||
}, isContinueWhenError)
|
}, isContinueWhenError)
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package yb
|
package yb
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
|
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
|
||||||
@@ -23,8 +24,11 @@ type PurchaseHandler struct {
|
|||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
if api.YinBaoAPI != nil {
|
if api.YinBaoAPI != nil {
|
||||||
|
fmt.Println("test2")
|
||||||
CurPurchaseHandler = New()
|
CurPurchaseHandler = New()
|
||||||
partner.RegisterPurchasePlatform(CurPurchaseHandler)
|
partner.RegisterPurchasePlatform(CurPurchaseHandler)
|
||||||
|
} else {
|
||||||
|
fmt.Println("test1")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -407,3 +407,6 @@ getWeixin2TokenURL = "http://www.jxc4.com/v2/sys/GetWX2Token"
|
|||||||
getWeimobTokenURL = "http://www.jxc4.com/v2/sys/GetWeimobToken"
|
getWeimobTokenURL = "http://www.jxc4.com/v2/sys/GetWeimobToken"
|
||||||
|
|
||||||
dbConnectStr = "root:WebServer@1@tcp(127.0.0.1:3306)/jxd_dev_0?charset=utf8mb4&loc=Local&parseTime=true"
|
dbConnectStr = "root:WebServer@1@tcp(127.0.0.1:3306)/jxd_dev_0?charset=utf8mb4&loc=Local&parseTime=true"
|
||||||
|
|
||||||
|
yinbaoAppKey = "682628966212343269"
|
||||||
|
yinbaoAppID = "18C0E0867E467DBC26EFF5E957B02EC4"
|
||||||
Reference in New Issue
Block a user