- (deleted_at = '1970-01-01 00:00:00' OR jd_sync_status <> 0) in jd SyncStoreSkus.

This commit is contained in:
gazebo
2018-10-10 18:16:38 +08:00
parent d23f36a109
commit d58e03619d

View File

@@ -10,17 +10,22 @@ import (
"git.rosy.net.cn/jx-callback/globals/api" "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) { func (p *PurchaseHandler) SyncStoreSkus(db *dao.DaoDB, storeIDs []int, skuIDs []int, isForce bool, userName string) (err error) {
var storeSkus []*model.StoreSkuBind var storeSkus []*model.StoreSkuBind
for _, storeID := range storeIDs { for _, storeID := range storeIDs {
sqlParams := []interface{}{ sqlParams := []interface{}{
utils.DefaultTimeValue,
storeID, storeID,
} }
sql := ` sql := `
SELECT * SELECT *
FROM store_sku_bind FROM store_sku_bind
WHERE store_id = ? WHERE (deleted_at = ? OR jd_sync_status <> 0) AND store_id = ?
` `
if skuIDs != nil && len(skuIDs) > 0 { if skuIDs != nil && len(skuIDs) > 0 {
sql += " AND sku_id IN (" + dao.GenQuestionMarks(len(skuIDs)) + ")" 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 { // 关注或取消关注 if storeSku.JdSyncStatus&(model.SyncFlagDeletedMask|model.SyncFlagNewMask) != 0 || isForce { // 关注或取消关注
stock := &jdapi.SkuStock{ stock := &jdapi.SkuStock{
OutSkuId: utils.Int2Str(storeSku.SkuID), OutSkuId: utils.Int2Str(storeSku.SkuID),
StockQty: 9999, StockQty: MaxStockQty,
} }
if storeSku.DeletedAt != utils.DefaultTimeValue { if storeSku.DeletedAt != utils.DefaultTimeValue {
stock.StockQty = 0 stock.StockQty = 0