From c6786a51cbeb05d702dbc9068481f707ebd863d6 Mon Sep 17 00:00:00 2001 From: huanghongfa <18228131219@163.com> Date: 星期一, 25 一月 2021 17:14:46 +0800 Subject: [PATCH] 党员活动 --- springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java | 17 +++++++++++++++++ 1 files changed, 17 insertions(+), 0 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java index 3aeb13f..3167acc 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java @@ -3,6 +3,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.panzhihua.common.exceptions.PartyBuildingMemberException; import com.panzhihua.common.model.dtos.partybuilding.ActivitySignUpDTO; import com.panzhihua.common.model.dtos.partybuilding.ComPbActivityDTO; import com.panzhihua.common.model.vos.LoginUserInfoVO; @@ -22,6 +23,7 @@ import org.apache.http.client.utils.DateUtils; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import org.springframework.util.ObjectUtils; import javax.annotation.Resource; @@ -437,11 +439,26 @@ * @return 创建结果 */ @Override + @Transactional(rollbackFor = Exception.class) public R addActivityApplets(ComPbActivityDTO comPbActivityDTO) { ComPbActivityDO comPbActivityDO=new ComPbActivityDO(); + Long createBy = comPbActivityDTO.getCreateBy(); BeanUtils.copyProperties(comPbActivityDTO,comPbActivityDO); int insert = comBpActivityDAO.insert(comPbActivityDO); if (insert>0) { + ComPbActivityDO comPbActivityDO1 = comBpActivityDAO.selectOne(new QueryWrapper<ComPbActivityDO>().lambda().eq(ComPbActivityDO::getName, comPbActivityDTO.getName()).eq(ComPbActivityDO::getCover, comPbActivityDTO.getCover()).last(" order by create_at desc limit 1 ")); + Long comPbActivityDO1Id = comPbActivityDO1.getId(); + ComPbMemberDO comPbMemberDO = comPbMemberDAO.selectByUserId(createBy); + if (ObjectUtils.isEmpty(comPbMemberDO)) { + log.error("【{}】不是党员",createBy); + throw new PartyBuildingMemberException("用户不是党员"); + } + Long comPbMemberDOId = comPbMemberDO.getId(); + ComPbActivityMemberDO comPbActivityMemberDO=new ComPbActivityMemberDO(); + comPbActivityMemberDO.setMemberId(comPbMemberDOId); + comPbActivityMemberDO.setActivityId(comPbActivityDO1Id); + comPbActivityMemberDO.setCreateAt(new Date()); + comPbActivityMemberDAO.insert(comPbActivityMemberDO); return R.ok(); } return R.fail(); -- Gitblit v1.7.1