From 993956917c04f3f97e69df049a9427be4f67add3 Mon Sep 17 00:00:00 2001 From: huanghongfa <huanghongfa123456> Date: 星期一, 06 九月 2021 18:36:51 +0800 Subject: [PATCH] bug修复 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java | 22 ++++++++++++++++++++++ 1 files changed, 22 insertions(+), 0 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java index 2139a1d..b065e26 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java @@ -6,6 +6,7 @@ import javax.annotation.Resource; +import com.panzhihua.service_community.service.ComActNeighborCircleTopicService; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -61,6 +62,8 @@ private ComActDAO comActDAO; @Resource private ComActNeighborCircleTopicMapper comActNeighborCircleTopicMapper; + @Resource + private ComActNeighborCircleTopicService comActNeighborCircleTopicService; /** * 分页查询邻里圈列表 @@ -139,6 +142,25 @@ neighborCircleDO.setRefuseReason("内容违规"); } } + //判断用户的话题是否是新增的 + if(StringUtils.isNotEmpty(addNeighborCircleAppDTO.getTopicName())){ + //新增邻里圈话题 + ComActNeighborCircleTopicDO circleTopicDO = comActNeighborCircleTopicMapper.selectOne(new QueryWrapper<ComActNeighborCircleTopicDO>() + .lambda().eq(ComActNeighborCircleTopicDO::getCommunityId,neighborCircleDO.getCommunityId()) + .eq(ComActNeighborCircleTopicDO::getName,addNeighborCircleAppDTO.getTopicName())); + if(circleTopicDO == null){ + circleTopicDO = new ComActNeighborCircleTopicDO(); + circleTopicDO.setCommunityId(neighborCircleDO.getCommunityId()); + circleTopicDO.setName(addNeighborCircleAppDTO.getTopicName()); + circleTopicDO.setCreateBy(neighborCircleDO.getReleaseId()); + circleTopicDO.setCreateAt(new Date()); + circleTopicDO.setCount(1); + circleTopicDO.setHotNum(0L); + circleTopicDO.setStatus(ComActNeighborCircleTopicDO.status.yes); + comActNeighborCircleTopicMapper.insert(circleTopicDO); + } + neighborCircleDO.setTopicId(circleTopicDO.getId()); + } if(this.baseMapper.insert(neighborCircleDO) > 0){ return R.ok(); -- Gitblit v1.7.1