This commit is contained in:
苏尹岚
2020-12-04 16:28:17 +08:00
parent c5587d0073
commit e939fa5ab2
2 changed files with 15 additions and 20 deletions

View File

@@ -461,13 +461,6 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
now := jxutils.OperationTime2HourMinuteFormat(time.Now()) now := jxutils.OperationTime2HourMinuteFormat(time.Now())
var failedList []*partner.StoreSkuInfoWithErr var failedList []*partner.StoreSkuInfoWithErr
for _, sku := range skus { for _, sku := range skus {
if vendorID == model.VendorIDJDShop && storeID != model.JdShopMainStoreID && storeID != model.JdShopMainStoreID2 {
// if model.IsSyncStatusNew(sku.SkuSyncStatus) {
// sku.SkuSyncStatus = sku.SkuSyncStatus - model.SyncFlagNewMask
// }
storeDetail2, _ := dao.GetStoreDetail(db, storeID, vendorID, sku.VendorOrgCode)
vendorStoreID = storeDetail2.VendorStoreID
}
if !useVendorPriceDirectly && if !useVendorPriceDirectly &&
!isSkuLockTimeValid(sku) { !isSkuLockTimeValid(sku) {
sku.VendorPrice = 0 sku.VendorPrice = 0

View File

@@ -250,20 +250,22 @@ func (p *PurchaseHandler) CreateStoreSkus(ctx *jxcontext.Context, storeID int, v
//如果是普通店关注商品 //如果是普通店关注商品
for _, v := range storeSkuList { for _, v := range storeSkuList {
if v.VendorOrgCode == "2" { if v.VendorOrgCode == "2" {
storeSkus, _ := dao.GetStoresSkusInfo(dao.GetDB(), []int{model.JdShopMainStoreID2}, []int{v.SkuID}) for _, vv := range v.StoreSkuSyncInfoJds {
if len(storeSkus) > 0 { storeSkus, _ := dao.GetStoresSkusInfo(dao.GetDB(), []int{model.JdShopMainStoreID2}, []int{vv.SkuID})
for _, vv := range storeSkus { if len(storeSkus) > 0 {
if vv.JdsID != 0 { for _, storeSku := range storeSkus {
status := v.Status if storeSku.JdsID != 0 {
stock := v.Stock status := vv.Status
price := v.VendorPrice stock := vv.Stock
if status == model.StoreSkuBindStatusNormal { price := vv.VendorPrice
api.JdShop2API.StoreWareDoUpdate(status, vv.JdsID, vendorStoreID) if status == model.StoreSkuBindStatusNormal {
api.JdShop2API.StoreWareDoUpdate(status, storeSku.JdsID, vendorStoreID)
}
if stock != 0 {
api.JdShop2API.StoreUpdateStock(stock, storeSku.JdsID, vendorStoreID)
}
api.JdShop2API.StoreUpdatePrice(utils.Float64ToStr(jxutils.IntPrice2Standard(int64(price))), storeSku.JdsID, vendorStoreID)
} }
if stock != 0 {
api.JdShop2API.StoreUpdateStock(stock, vv.JdsID, vendorStoreID)
}
api.JdShop2API.StoreUpdatePrice(utils.Float64ToStr(jxutils.IntPrice2Standard(int64(price))), vv.JdsID, vendorStoreID)
} }
} }
} }