美团测试库存

business/jxstore/cms/sync_store_sku.go

@@ -481,6 +481,7 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
 			if !dao.IsVendorThingIDEmpty(sku.VendorSkuID) {
 				bareSku = storeSkuSyncInfo2Bare(sku)
 				if singleStoreHandler == nil {
+					bareSku.Stock = 0
 					stockList = append(stockList, bareSku)
 				} else {
 					deleteList = append(deleteList, bareSku)
@@ -556,15 +557,21 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
 						}
 						if sku.MergedStatus == model.SkuStatusNormal {
 							onlineList = append(onlineList, bareSku)
-							stockList = append(stockList, bareSku)
+							// stockList = append(stockList, bareSku)
 						} else {
 							offlineList = append(offlineList, bareSku)
 							// 因为京东平台以是否有库存表示是否关注，所以不论是否可售，都要设置库存
-							if singleStoreHandler == nil {
-								stockList = append(stockList, bareSku)
-							}
+							// if singleStoreHandler == nil {
+							// 	stockList = append(stockList, bareSku)
+							// }
 						}
 					}
+					if model.IsSyncStatusStock(sku.SkuSyncStatus) {
+						if bareSku == nil {
+							bareSku = storeSkuSyncInfo2Bare(sku)
+						}
+						stockList = append(stockList, bareSku)
+					}
 				}
 				isNeedReorder = model.IsSyncStatusSeq(sku.SkuSyncStatus)
 			}

business/model/model.go

@@ -117,6 +117,10 @@ func IsSyncStatusPrice(syncStatus int8) bool {
 	return (syncStatus & SyncFlagPriceMask) != 0
 }
 
+func IsSyncStatusStock(syncStatus int8) bool {
+	return (syncStatus & SyncFlagStockMask) != 0
+}
+
 func IsSyncStatusSeq(syncStatus int8) bool {
 	return (syncStatus & SyncFlagSeqMask) != 0
 }