提交

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/manage/GoblinStorePurchasingServiceImpl.java

@@ -166,6 +166,8 @@ public class GoblinStorePurchasingServiceImpl implements IGoblinStorePurchasingS
 
     @Override
     public ResponseDto<String> purchasingSkuList(String marketId, String storeId, int page) {
+        List<String> spuIds = goblinRedisUtils.getStoreMarketIsConfig(marketId, storeId);
+
         return null;
     }
 
@@ -224,7 +226,7 @@ public class GoblinStorePurchasingServiceImpl implements IGoblinStorePurchasingS
         goblinRedisUtils.setGoodsInfoVo(spuVo);
         relationVo.setSkuList(skuList);
         goblinRedisUtils.addMarketRelation(GoblinStatusConst.MarketPreStatus.MARKET_PRE_PURCHASE.getValue(), params.getStoreMarketId(), relationVo);
-        goblinRedisUtils.addStoreMarketIsConfig(params.getStoreMarketId(), params.getStoreId(), params.getSpuId());
+        goblinRedisUtils.addStoreMarketIsConfig(params.getStoreMarketId(), params.getStoreId(), params.getSpuId(),marketSpuId);
         // 执行sql
         String sqlData = SqlMapping.gets(sqls, sqlsData);
         queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getKey(),
@@ -289,7 +291,7 @@ public class GoblinStorePurchasingServiceImpl implements IGoblinStorePurchasingS
         //redis
         goblinRedisUtils.delGoodsInfoVo(marketSpuId);
         goblinRedisUtils.removeMarketRelation(GoblinStatusConst.MarketPreStatus.MARKET_PRE_PURCHASE.getValue(), marketId, spuId);
-        goblinRedisUtils.delStoreMarketIsConfig(marketId, storeId, spuId);
+        goblinRedisUtils.delStoreMarketIsConfig(marketId, storeId, spuId,marketSpuId);
         //mysql
         queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getKey(),
                 SqlMapping.get("goblin.store.market.delSpuRelation", bean.getDelFlag(), bean.getUpdatedAt(), marketId, storeId, spuId));

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

@@ -112,28 +112,35 @@ public class GoblinRedisUtils {
         redisUtil.del(redisKey);
     }
 
-    public List<String> getStoreMarketIsConfig(String marketId,String storeId){
+
+    /**
+     * 获取 配置的商铺id
+     *
+     * @param marketId
+     * @param storeId
+     */
+    public List<String> getStoreMarketIsConfig(String marketId, String storeId) {
         String redisKey = GoblinRedisConst.REDIS_GOBLIN_STORE_MARKET_ISCONFIG.concat(marketId).concat(":store_id:" + storeId);
         Object obj = redisUtil.get(redisKey);
-        if(obj==null){
+        if (obj == null) {
             return CollectionUtil.arrayListString();
-        }else{
+        } else {
             return (List<String>) obj;
         }
     }
 
-    public void addStoreMarketIsConfig(String marketId,String storeId,String spuId){
+    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<String> voList = getStoreMarketIsConfig(marketId,storeId);
-        voList.add(spuId);
-        redisUtil.set(redisKey,voList);
+        List<String> voList = getStoreMarketIsConfig(marketId, storeId);
+        voList.add(spuId+","+marketSpuId);
+        redisUtil.set(redisKey, voList);
     }
 
-    public void delStoreMarketIsConfig(String marketId,String storeId,String spuId){
+    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<String> voList = getStoreMarketIsConfig(marketId,storeId);
-        voList.remove(spuId);
-        redisUtil.set(redisKey,voList);
+        List<String> voList = getStoreMarketIsConfig(marketId, storeId);
+        voList.remove(spuId+","+marketSpuId);
+        redisUtil.set(redisKey, voList);
     }
 
     /**