京东商城同步测试
This commit is contained in:
@@ -1112,11 +1112,11 @@ func syncJdsStoresSkus(ctx *jxcontext.Context, db *dao.DaoDB, parentTask tasksch
|
|||||||
skuBindInfos1 []*StoreSkuBindInfo
|
skuBindInfos1 []*StoreSkuBindInfo
|
||||||
skuBindInfos2 []*StoreSkuBindInfo
|
skuBindInfos2 []*StoreSkuBindInfo
|
||||||
)
|
)
|
||||||
storeSkusMain, err := dao.GetStoreSkusByNameIDs(db, []int{model.JdShopMainStoreID}, 0)
|
storeSkusMain, err := dao.GetStoreSkusByNameIDs(db, []int{model.JdShopMainStoreID}, 11433)
|
||||||
for _, v := range storeSkusMain {
|
for _, v := range storeSkusMain {
|
||||||
mainSkusMap[v.NameID] = append(mainSkusMap[v.NameID], v)
|
mainSkusMap[v.NameID] = append(mainSkusMap[v.NameID], v)
|
||||||
}
|
}
|
||||||
storeSkus, err := dao.GetStoreSkusByNameIDs(db, []int{storeMap.StoreID}, 0)
|
storeSkus, err := dao.GetStoreSkusByNameIDs(db, []int{storeMap.StoreID}, 11433)
|
||||||
for _, v := range storeSkus {
|
for _, v := range storeSkus {
|
||||||
skusMap[v.NameID] = append(skusMap[v.NameID], v)
|
skusMap[v.NameID] = append(skusMap[v.NameID], v)
|
||||||
}
|
}
|
||||||
@@ -1134,6 +1134,7 @@ func syncJdsStoresSkus(ctx *jxcontext.Context, db *dao.DaoDB, parentTask tasksch
|
|||||||
for _, storeSku := range v {
|
for _, storeSku := range v {
|
||||||
for _, storeSkuMain := range mainSkusMap[k] {
|
for _, storeSkuMain := range mainSkusMap[k] {
|
||||||
if storeSkuMain.StoreSkuStatus == model.StoreSkuBindStatusNormal && storeSku.StoreSkuStatus == model.StoreSkuBindStatusDontSale {
|
if storeSkuMain.StoreSkuStatus == model.StoreSkuBindStatusNormal && storeSku.StoreSkuStatus == model.StoreSkuBindStatusDontSale {
|
||||||
|
fmt.Println("test1", utils.Format4Output(storeSkuMain, false))
|
||||||
updateList = append(updateList, storeSkuMain)
|
updateList = append(updateList, storeSkuMain)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user