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