库存相关 redis

liquidnet-bus-api/liquidnet-service-goblin-api/src/main/java/com/liquidnet/service/goblin/constant/GoblinRedisConst.java

@@ -48,6 +48,6 @@ public class GoblinRedisConst {
     /**
      * SKU剩余库存
      */
-    public static final String REALSTOCK_SKU = PREFIX.concat("realstock_sku:");
+    public static final String REAL_STOCK_SKU = PREFIX.concat("real_stock_sku:");
     /* ----------------------------------------------------------------- */
 }

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/util/GoblinRedisUtils.java

@@ -17,6 +17,49 @@ public class GoblinRedisUtils {
     @Autowired
     GoblinMongoUtils goblinMongoUtils;
 
+
+    /* ---------------------------------------- sku库存相关 ---------------------------------------- */
+    public void setSkuStock(String marketPre, String skuId, Integer stock) {
+        String rk = GoblinRedisConst.REAL_STOCK_SKU;
+        if (marketPre != null) {
+            rk = rk.concat(marketPre + ":");
+        }
+        rk = rk.concat(skuId);
+        redisUtil.set(rk, stock);
+    }
+
+    public int getSkuStock(String marketPre, String skuId) {
+        String rk = GoblinRedisConst.REAL_STOCK_SKU;
+        if (marketPre != null) {
+            rk = rk.concat(marketPre + ":");
+        }
+        rk = rk.concat(skuId);
+        Object obj = redisUtil.get(rk);
+        if (obj == null) {
+            return 0;
+        } else {
+            return (int) obj;
+        }
+    }
+
+    public int incrSkuStock(String marketPre, String skuId, Integer stock) {
+        String rk = GoblinRedisConst.REAL_STOCK_SKU;
+        if (marketPre != null) {
+            rk = rk.concat(marketPre + ":");
+        }
+        rk = rk.concat(skuId);
+        return (int) redisUtil.incr(rk, stock);
+    }
+
+    public int decrSkuStock(String marketPre, String skuId, Integer stock) {
+        String rk = GoblinRedisConst.REAL_STOCK_SKU;
+        if (marketPre != null) {
+            rk = rk.concat(marketPre + ":");
+        }
+        rk = rk.concat(skuId);
+        return (int) redisUtil.decr(rk, stock);
+    }
+
     /* ---------------------------------------- 商品数据源 ---------------------------------------- */
 
     public boolean setGoodsInfoVo(GoblinGoodsInfoVo vo) {
@@ -129,7 +172,7 @@ public class GoblinRedisUtils {
         }
     }
 
-    public void addStoreMarketIsConfig(String marketId, String storeId, String spuId,String marketSpuId) {
+    public void addStoreMarketIsConfig(String marketId, String storeId, String spuId, String marketSpuId) {
         String redisKey = GoblinRedisConst.REDIS_GOBLIN_STORE_MARKET_ISCONFIG.concat(marketId).concat(":store_id:" + storeId);
         List<GoblinStoreMarketIsConfigVo> voList = getStoreMarketIsConfig(marketId, storeId);
         GoblinStoreMarketIsConfigVo vo = GoblinStoreMarketIsConfigVo.getNew();
@@ -139,12 +182,12 @@ public class GoblinRedisUtils {
         redisUtil.set(redisKey, voList);
     }
 
-    public void delStoreMarketIsConfig(String marketId, String storeId, String spuId,String marketSpuId) {
+    public void delStoreMarketIsConfig(String marketId, String storeId, String spuId, String marketSpuId) {
         String redisKey = GoblinRedisConst.REDIS_GOBLIN_STORE_MARKET_ISCONFIG.concat(marketId).concat(":store_id:" + storeId);
         List<GoblinStoreMarketIsConfigVo> voList = getStoreMarketIsConfig(marketId, storeId);
-        for (int i =0 ;i<voList.size();i++){
-            String itemSpuId= voList.get(i).getSpuId();
-            if(spuId.equals(itemSpuId)){
+        for (int i = 0; i < voList.size(); i++) {
+            String itemSpuId = voList.get(i).getSpuId();
+            if (spuId.equals(itemSpuId)) {
                 voList.remove(i);
             }
         }