From 70d2a5d0f9c6951b2d4cac954041ed73582ff7eb Mon Sep 17 00:00:00 2001 From: liujie <1793218484@qq.com> Date: 星期一, 09 六月 2025 11:54:00 +0800 Subject: [PATCH] 6.9新增登录失败冻结逻辑 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComCvtBusinessServiceImpl.java | 73 ++++++++++++++++++------------------ 1 files changed, 36 insertions(+), 37 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComCvtBusinessServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComCvtBusinessServiceImpl.java index 8117877..6a7aa51 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComCvtBusinessServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComCvtBusinessServiceImpl.java @@ -1,5 +1,16 @@ package com.panzhihua.service_community.service.impl; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + +import javax.annotation.Resource; + +import org.springframework.beans.BeanUtils; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.util.ObjectUtils; + import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; @@ -24,18 +35,6 @@ import com.panzhihua.service_community.service.ComCvtBusinessIntroduceService; import com.panzhihua.service_community.service.ComCvtBusinessService; import com.panzhihua.service_community.service.ComCvtServeService; -import org.springframework.beans.BeanUtils; -import org.springframework.boot.util.LambdaSafe; -import org.springframework.stereotype.Service; -import org.springframework.transaction.annotation.Transactional; -import org.springframework.util.ObjectUtils; -import org.springframework.util.StringUtils; - -import javax.annotation.Resource; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; -import java.util.stream.Collectors; /** * @description: 便民服务商家接口 @@ -43,7 +42,8 @@ * @date: 2021/3/11 11:11 */ @Service -public class ComCvtBusinessServiceImpl extends ServiceImpl<ComCvtBusinessDAO, ComCvtBusinessDO> implements ComCvtBusinessService { +public class ComCvtBusinessServiceImpl extends ServiceImpl<ComCvtBusinessDAO, ComCvtBusinessDO> + implements ComCvtBusinessService { @Resource private ComCvtBusinessDAO comCvtBusinessDAO; @@ -118,10 +118,12 @@ } BeanUtils.copyProperties(comCvtBusinessDTO, comCvtBusinessDO); comCvtBusinessDAO.updateById(comCvtBusinessDO); - //删除服务范围 - comCvtBusinessAreaDAO.delete(new QueryWrapper<ComCvtBusinessAreaDO>().lambda().eq(ComCvtBusinessAreaDO::getBusinessId, comCvtBusinessDO.getId())); - //删除商家介绍媒体文件 - comCvtBusinessIntroduceDAO.delete(new QueryWrapper<ComCvtBusinessIntroduceDO>().lambda().eq(ComCvtBusinessIntroduceDO::getBusinessId, comCvtBusinessDO.getId())); + // 删除服务范围 + comCvtBusinessAreaDAO.delete(new QueryWrapper<ComCvtBusinessAreaDO>().lambda() + .eq(ComCvtBusinessAreaDO::getBusinessId, comCvtBusinessDO.getId())); + // 删除商家介绍媒体文件 + comCvtBusinessIntroduceDAO.delete(new QueryWrapper<ComCvtBusinessIntroduceDO>().lambda() + .eq(ComCvtBusinessIntroduceDO::getBusinessId, comCvtBusinessDO.getId())); if (comCvtBusinessDTO.getAreaFlag() == 2 && !ObjectUtils.isEmpty(comCvtBusinessDTO.getCommunityIds())) { List<ComCvtBusinessAreaDO> comCvtBusinessAreaDOS = new ArrayList<>(); comCvtBusinessDTO.getCommunityIds().stream().forEach(areaId -> { @@ -146,7 +148,7 @@ } @Override - public R getComCvtBusiness(Long id, String cityCode) { + public R getComCvtBusiness(Long id) { ComCvtBusinessDO comCvtBusinessDO = comCvtBusinessDAO.selectById(id); if (null == comCvtBusinessDO) { return R.fail("商家不存在"); @@ -155,20 +157,14 @@ BeanUtils.copyProperties(comCvtBusinessDO, comCvtBusinessVO); List<ComActDO> comActDOS = new ArrayList<>(); - if(comCvtBusinessDO.getAreaFlag()==1){ - LambdaQueryWrapper<ComActDO> lambdaQueryWrapper = new LambdaQueryWrapper<ComActDO>().eq(ComActDO::getState,0); - if(!StringUtils.isEmpty(cityCode)){ - lambdaQueryWrapper.eq(ComActDO::getCityCode, cityCode); - } + if (comCvtBusinessDO.getAreaFlag() == 1) { + LambdaQueryWrapper<ComActDO> lambdaQueryWrapper = + new LambdaQueryWrapper<ComActDO>().eq(ComActDO::getState, 0); comActDOS = comActDAO.selectList(lambdaQueryWrapper); - }else{ + } else { List<Long> areaIds = comCvtBusinessAreaService.getBusinessServiceAreaIds(comCvtBusinessDO.getId()); - if(!ObjectUtils.isEmpty(areaIds)){ - List<ComActDO> busiDO = comActDAO.selectBatchIds(areaIds); - if(!StringUtils.isEmpty(cityCode) && busiDO!=null && busiDO.size()>0){ - comActDOS = busiDO.stream().filter(comActDO -> cityCode.equals(comActDO.getCityCode())) - .collect(Collectors.toList()); - } + if (!ObjectUtils.isEmpty(areaIds)) { + comActDOS = comActDAO.selectBatchIds(areaIds); } } @@ -190,13 +186,15 @@ @Transactional(rollbackFor = Exception.class) public R deleteComCvtBusiness(Long id) { int delete = comCvtBusinessDAO.deleteById(id); - if (delete==0) { + if (delete == 0) { return R.fail(); } - //删除服务范围 - comCvtBusinessAreaDAO.delete(new QueryWrapper<ComCvtBusinessAreaDO>().lambda().eq(ComCvtBusinessAreaDO::getBusinessId, id)); - //删除商家介绍媒体文件 - comCvtBusinessIntroduceDAO.delete(new QueryWrapper<ComCvtBusinessIntroduceDO>().lambda().eq(ComCvtBusinessIntroduceDO::getBusinessId, id)); + // 删除服务范围 + comCvtBusinessAreaDAO + .delete(new QueryWrapper<ComCvtBusinessAreaDO>().lambda().eq(ComCvtBusinessAreaDO::getBusinessId, id)); + // 删除商家介绍媒体文件 + comCvtBusinessIntroduceDAO.delete( + new QueryWrapper<ComCvtBusinessIntroduceDO>().lambda().eq(ComCvtBusinessIntroduceDO::getBusinessId, id)); return R.ok(); } @@ -213,7 +211,8 @@ } page.setSize(pageSize); page.setCurrent(pageNum); - IPage<ComCvtBusinessVO> iPage = comCvtBusinessDAO.pageComCvtBusinessByServiceArea(page, comCvtBusinessAppletsDTO); + IPage<ComCvtBusinessVO> iPage = + comCvtBusinessDAO.pageComCvtBusinessByServiceArea(page, comCvtBusinessAppletsDTO); return R.ok(iPage); } @@ -225,7 +224,7 @@ } ComCvtBusinessDetailVO comCvtBusinessDetailVO = new ComCvtBusinessDetailVO(); BeanUtils.copyProperties(comCvtBusinessDO, comCvtBusinessDetailVO); - if(comCvtBusinessDO.getAreaFlag()!=1){ + if (comCvtBusinessDO.getAreaFlag() != 1) { List<Long> areaIds = comCvtBusinessAreaService.getBusinessServiceAreaIds(comCvtBusinessDO.getId()); List<ComActDO> comActDOS = comActDAO.selectBatchIds(areaIds); if (!ObjectUtils.isEmpty(comActDOS)) { -- Gitblit v1.7.1