diff --git a/business/partner/purchase/jd/store_sku.go b/business/partner/purchase/jd/store_sku.go index c8cf02bdb..778ffb995 100644 --- a/business/partner/purchase/jd/store_sku.go +++ b/business/partner/purchase/jd/store_sku.go @@ -10,17 +10,22 @@ import ( "git.rosy.net.cn/jx-callback/globals/api" ) +const ( + MaxStockQty = 100000000 +) + // 京东到家,以有库存表示关注(认领) func (p *PurchaseHandler) SyncStoreSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int, isForce bool, userName string) (err error) { var storeSkus []*model.StoreSkuBind for _, storeID := range storeIDs { sqlParams := []interface{}{ + utils.DefaultTimeValue, storeID, } sql := ` SELECT * FROM store_sku_bind - WHERE store_id = ? + WHERE (deleted_at = ? OR jd_sync_status <> 0) AND store_id = ? ` if skuIDs != nil && len(skuIDs) > 0 { sql += " AND sku_id IN (" + dao.GenQuestionMarks(len(skuIDs)) + ")" @@ -56,7 +61,7 @@ func (p *PurchaseHandler) SyncStoreSkus(db *dao.DaoDB, storeIDs []int, skuIDs [] if storeSku.JdSyncStatus&(model.SyncFlagDeletedMask|model.SyncFlagNewMask) != 0 || isForce { // 关注或取消关注 stock := &jdapi.SkuStock{ OutSkuId: utils.Int2Str(storeSku.SkuID), - StockQty: 9999, + StockQty: MaxStockQty, } if storeSku.DeletedAt != utils.DefaultTimeValue { stock.StockQty = 0