From f9d2c4dddf9e6d8d8f6eb843fd83c8e580a3e863 Mon Sep 17 00:00:00 2001 From: huanghongfa <huanghongfa123456> Date: 星期一, 26 四月 2021 15:56:43 +0800 Subject: [PATCH] 修复bug --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopStoreServiceImpl.java | 36 +++++++++++++++++++++++++++++------- 1 files changed, 29 insertions(+), 7 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopStoreServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopStoreServiceImpl.java index 9e6e1c0..c1e9169 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopStoreServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopStoreServiceImpl.java @@ -19,7 +19,9 @@ import com.panzhihua.service_community.dao.ComShopStoreDAO; import com.panzhihua.service_community.model.dos.ComShopGoodsAttrDO; import com.panzhihua.service_community.model.dos.ComShopGoodsDO; +import com.panzhihua.service_community.model.dos.ComShopOrderDO; import com.panzhihua.service_community.model.dos.ComShopStoreDO; +import com.panzhihua.service_community.service.ComShopOrderService; import com.panzhihua.service_community.service.ComShopStoreService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; @@ -27,6 +29,8 @@ import javax.annotation.Resource; import java.util.List; +import java.util.stream.Collectors; +import java.util.stream.Stream; /** * @auther lyq @@ -41,9 +45,6 @@ private ComShopGoodsDAO shopGoodsDAO; @Resource private ComShopGoodsAttrDAO comShopGoodsAttrDAO; - @Resource - private UserService userService; - /** * 查询店铺列表 * @@ -57,6 +58,11 @@ IPage<PageShopStoreVO> comShopStoreVOIPage = this.baseMapper.pageShopStore(page, pageComShopStoreDTO); return R.ok(comShopStoreVOIPage); } + + @Resource + private UserService userService; + @Resource + private ComShopOrderService orderService; /** * 查询店铺详情 @@ -133,7 +139,7 @@ ComShopStoreDO oldComShopStoreDO = this.baseMapper.selectOne(new LambdaQueryWrapper<ComShopStoreDO>() .eq(ComShopStoreDO::getStoreAccount, storeVO.getStoreAccount()).eq(ComShopStoreDO::getDeleteStatus,ComShopStoreDO.deleteStatus.no)); if (oldComShopStoreDO != null) { - return R.fail("商家已注册"); + return R.fail("商家账号已注册"); } //新增店铺先判断是否拥有已删除的店铺 ComShopStoreDO comShopStoreDO = this.baseMapper.selectOne(new LambdaQueryWrapper<ComShopStoreDO>() @@ -185,13 +191,26 @@ .lambda().eq(ComShopGoodsDO::getStoreId,shopStoreDO.getId()) .eq(ComShopGoodsDO::getDeleteStatus,ComShopGoodsDO.deleteStatus.no) .eq(ComShopGoodsDO::getStatus,ComShopGoodsDO.status.sell)); - if(!shopGoodsList.isEmpty()){//如果有正常商品则提示无法删除 return R.fail("店铺下有商品正在出售,无法删除店铺"); } - + List<ComShopOrderDO> comShopOrderDOS = orderService.getBaseMapper().selectList(new LambdaQueryWrapper<ComShopOrderDO>() + .eq(ComShopOrderDO::getStoreId,shopStoreDO.getId())); + List<ComShopOrderDO> filterOrder = comShopOrderDOS.stream() + .filter(order -> order.getStatus() < ComShopOrderDO.status.dpj) + .collect(Collectors.toList()); + if(!filterOrder.isEmpty()){ + return R.fail("店铺下还有订单未完成"); + } + //删除商家下的订单 + comShopOrderDOS.forEach(order->{ + order.setDeleteStatus(ComShopOrderDO.deleteStatus.yes); + orderService.getBaseMapper().updateById(order); + }); shopStoreDO.setDeleteStatus(2); this.baseMapper.updateById(shopStoreDO); + //删除sys_user 物理删除 + this.baseMapper.deleteSysUserBySysUserId(shopStoreDO.getSysUserId()); } }else { return R.fail("未查询到店铺"); @@ -227,10 +246,13 @@ R<LoginUserInfoVO> loginUserInfoVOR = userService.getUserInfo(account+"_5"); LoginUserInfoVO loginUserInfoVO = JSONObject.parseObject(JSONObject.toJSONString(loginUserInfoVOR.getData()), LoginUserInfoVO.class); + if(loginUserInfoVO==null){ + return R.fail(500, "该账号不存在"); + } ComShopStoreDO comShopStoreDO = this.baseMapper.selectOne(new LambdaQueryWrapper<ComShopStoreDO>() .eq(ComShopStoreDO::getDeleteStatus, 1).eq(ComShopStoreDO::getSysUserId, loginUserInfoVO.getUserId())); if (comShopStoreDO == null) { - R.fail(500, "商铺不存在"); + return R.fail(500, "该账号不存在"); } ShopStoreVO shopStoreVO = new ShopStoreVO(); BeanUtils.copyProperties(comShopStoreDO, shopStoreVO); -- Gitblit v1.7.1