修改 删除正在下单商品 同事删除sku

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

@@ -319,6 +319,8 @@ public class GoblinZhengzaiServiceImpl implements IGoblinZhengzaiService {
             int restStock = redisUtils.getSkuStock(GoblinStatusConst.MarketPreStatus.MARKET_PRE_ZHENGZAI.getValue(), marketSkuId);
             int restStockDe = redisUtils.decrSkuStock(GoblinStatusConst.MarketPreStatus.MARKET_PRE_ZHENGZAI.getValue(), marketSkuId, restStock);
             redisUtils.incrSkuStock(null, skuId, restStock + restStockDe);
+            mongoUtils.delGoodsSkuInfoVo(marketSkuId);
+            redisUtils.delGoodsSkuInfoVo(marketSkuId);
         }
         //mongo
         mongoUtils.delGoodsInfoVo(marketSpuId);

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

@@ -284,7 +284,7 @@ public class GoblinMongoUtils {
         query.fields().include("storeId");
         List<GoblinStoreInfoVo> voList = mongoTemplate.find(query, GoblinStoreInfoVo.class, GoblinStoreInfoVo.class.getSimpleName());
         ArrayList<String> list = CollectionUtil.arrayListString();
-        for(GoblinStoreInfoVo goblinStoreInfoVo:voList){
+        for (GoblinStoreInfoVo goblinStoreInfoVo : voList) {
             list.add(goblinStoreInfoVo.getStoreId());
         }
         return list;
@@ -303,14 +303,19 @@ public class GoblinMongoUtils {
     }
 
     public boolean delGoodsInfoVo(String spuId) {
-//        return mongoTemplate.remove(Query.query(Criteria.where("spuId").is(spuId).and("delFlg").is("0")),
-//                GoblinGoodsInfoVo.class, GoblinGoodsInfoVo.class.getSimpleName()).getDeletedCount() > 0;
         return mongoTemplate.getCollection(GoblinGoodsInfoVo.class.getSimpleName()).updateOne(
                 Query.query(Criteria.where("spuId").is(spuId).and("delFlg").is("0")).getQueryObject(),
                 Update.update("delFlg", "1").getUpdateObject()
         ).getModifiedCount() > 0;
     }
 
+    public boolean delGoodsSkuInfoVo(String spuId) {
+        return mongoTemplate.getCollection(GoblinGoodsSkuInfoVo.class.getSimpleName()).updateOne(
+                Query.query(Criteria.where("skuId").is(spuId).and("delFlg").is("0")).getQueryObject(),
+                Update.update("delFlg", "1").getUpdateObject()
+        ).getModifiedCount() > 0;
+    }
+
     public boolean delGoodsInfoVoBySpuIds(String storeId, List<String> spuIdList, String uid, LocalDateTime time) {
         return mongoTemplate.updateMulti(
                 Query.query(Criteria.where("storeId").is(storeId).and("spuId").in(spuIdList.toArray()).and("delFlg").is("0")),
@@ -897,11 +902,13 @@ public class GoblinMongoUtils {
         query.skip(skipCount).limit(size).with(Sort.by(Sort.Order.desc("createdAt")));
         return mongoTemplate.find(query, GoblinStoreOrderVo.class, GoblinStoreOrderVo.class.getSimpleName());
     }
+
     public List<GoblinFrontBanner> getListBanner() {
         Query query = Query.query(Criteria.where("delTag").is(0).and("bannerType").is(1));
         return mongoTemplate.find(query,
                 GoblinFrontBanner.class, GoblinFrontBanner.class.getSimpleName());
     }
+
     public List<GoblinFrontBanner> getMiddleBanner() {
         Query query = Query.query(Criteria.where("delTag").is(0).and("bannerType").is(2));
         return mongoTemplate.find(query,