修改购物车

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

@@ -438,7 +438,10 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
         GoblinShoppingCartVoo goblinShoppingCartVoo = (GoblinShoppingCartVoo) redisUtil.get(GoblinRedisConst.FRONT_SHOPCART.concat(userId));
         if (null != goblinShoppingCartVoo) {
             List<GoblinShoppingCartVo> shopList = goblinShoppingCartVoo.getShopList();
-            for (GoblinShoppingCartVo goblinShoppingCartVo : shopList) {
+
+            Iterator<GoblinShoppingCartVo> shopIter = shopList.iterator();
+            while (shopIter.hasNext()){
+                GoblinShoppingCartVo goblinShoppingCartVo=shopIter.next();
                 List<GoblinShoppingCartVoDetail> skuList = goblinShoppingCartVo.getSkuList();
                 Iterator<GoblinShoppingCartVoDetail> iterator = skuList.iterator();
                 while(iterator.hasNext()){
@@ -450,47 +453,22 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
                         }
                     }
                 }
-              /*  for (GoblinShoppingCartVoDetail goblinShoppingCartVoDetail : skuList) {
-
-                }*/
+                if(skuList.size()==0){
+                    shopIter.remove();
+                }
+            }
+            if(shopList.size()==0){
+                deleteRedisMongodbMysqlShop(goblinShoppingCartVoo,userId);
             }
         }
 
-      /*  //创建 voo
-        GoblinShoppingCartVoo goblinShoppingCartVoo1=GoblinShoppingCartVoo.getNew();
-        // 根据shop分类
-        ArrayList<GoblinShoppingCartVo> list=ObjectUtil.goblinShoppingCartVoArrayList();
-        GoblinShoppingCartVo goblinShoppingCartVo=GoblinShoppingCartVo.getNew();
-        goblinShoppingCartVo.setStoreId(storeId);
-        //该商铺下的所有商品
-        ArrayList<GoblinShoppingCartVoDetail> list1=ObjectUtil.goblinShoppingCartVoDetailArrayList();
-        //创建 购物车vo
-        GoblinShoppingCartVoDetail goblinShoppingCartVoDetail=this.setValue(userId,storeId,spuId,skuId,1);
-        list1.add(goblinShoppingCartVoDetail);
-        goblinShoppingCartVo.setSkuList(list1);
-        list.add(goblinShoppingCartVo);
-        goblinShoppingCartVoo1.setShopList(list);
-        goblinShoppingCartVoo1.setGoblinShoppingCartId(IDGenerator.nextSnowId());
-        saveRedisMongodbMysqlShop(goblinShoppingCartVoo1,userId);
+       /* if(this.getShopCartCount(userId)==0){
+            //删除redis、删除mongodb
+            deleteRedisMongodbMysqlShop(goblinShoppingCartVoo,userId);
+        }else{
+            saveRedisMongodbMysqlShop(goblinShoppingCartVoo,userId);
+        }
 */
-        /*for(Map<String,String> map:listMap){
-            //找到位置， 删除
-            //获取
-            GoblinShoppingCartVoo goblinShoppingCartVoo= (GoblinShoppingCartVoo) redisUtil.get(GoblinRedisConst.FRONT_SHOPCART.concat(userId));
-            if(null!=goblinShoppingCartVoo){
-                List<GoblinShoppingCartVo> shopList=goblinShoppingCartVoo.getShopList();
-                for(GoblinShoppingCartVo goblinShoppingCartVo:shopList){
-                    List<GoblinShoppingCartVoDetail> skuList= goblinShoppingCartVo.getSkuList();
-                    String skuId=map.get("skuId");
-                    for(GoblinShoppingCartVoDetail goblinShoppingCartVoDetail:skuList){
-                        if(skuId.equals(goblinShoppingCartVoDetail.getSkuId())){
-                            skuList.remove(goblinShoppingCartVoDetail);
-                        }
-                    }
-                }
-            }
-        }*/
-        saveRedisMongodbMysqlShop(goblinShoppingCartVoo,userId);
     return true;
     }
     /**
@@ -501,6 +479,9 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
     public GoblinShoppingCartVoo getShoppCart(String userId){
         //判断该用户 redis里是否有购物车
         GoblinShoppingCartVoo goblinShoppingCartVoo= (GoblinShoppingCartVoo) redisUtil.get(GoblinRedisConst.FRONT_SHOPCART.concat(userId));
+        if(null==goblinShoppingCartVoo){
+            return null;
+        }
         //遍历里面信息
         for(GoblinShoppingCartVo goblinShoppingCartVo:goblinShoppingCartVoo.getShopList()){
             for(GoblinShoppingCartVoDetail goblinShoppingCartVoDetail:goblinShoppingCartVo.getSkuList()){
@@ -511,7 +492,7 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
                 goblinShoppingCartVoDetail.setGoblinGoodsSkuInfoVo(goblinGoodsSkuInfoVo);
             }
         }
-
+        goblinShoppingCartVoo.setShoopingCount(this.getShopCartCount(userId));
         return goblinShoppingCartVoo;
     }
     public GoblinShoppingCartVoDetail setValue(String userId,String storeId,String spuId,String skuId,Integer number){
@@ -543,7 +524,13 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
             mongoTemplate.save(goblinShoppingCartVoo,GoblinShoppingCartVoo.class.getSimpleName());
         }
         //mysql 消息队列
-
+    }
+    //删除redis 删除mongodb
+    public void deleteRedisMongodbMysqlShop(GoblinShoppingCartVoo goblinShoppingCartVoo,String userId){
+        //redis存储
+        redisUtil.del(GoblinRedisConst.FRONT_SHOPCART.concat(userId));
+        //mongodb 删除
+        mongoTemplate.remove(Query.query(Criteria.where("goblinShoppingCartId").is(goblinShoppingCartVoo.getGoblinShoppingCartId())), GoblinShoppingCartVoo.class, GoblinShoppingCartVoo.class.getSimpleName());
     }