From d9eee1919dbff7ffddc48b1f4fee2ec41a54a2a2 Mon Sep 17 00:00:00 2001
From: huanghongfa <18228131219@163.com>
Date: 星期二, 05 一月 2021 18:19:52 +0800
Subject: [PATCH] 运营后台完成
---
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java | 57 ++++++++++++++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 52 insertions(+), 5 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java
index ed13908..072d4a1 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java
@@ -19,8 +19,11 @@
import org.springframework.util.ObjectUtils;
import javax.annotation.Resource;
+import java.util.ArrayList;
import java.util.Date;
import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
/**
* @program: springcloud_k8s_panzhihuazhihuishequ
@@ -84,10 +87,10 @@
Page page = new Page<>();
Long pageNum = comActActivityVO.getPageNum();
Long pageSize = comActActivityVO.getPageSize();
- if (ObjectUtils.isEmpty(pageNum)||0==pageNum) {
+ if (null==pageNum||0==pageNum) {
pageNum = 1l;
}
- if (ObjectUtils.isEmpty(pageSize)||0==pageSize) {
+ if (null==pageSize||0==pageSize) {
pageSize = 10l;
}
page.setSize(pageSize);
@@ -126,7 +129,7 @@
ComActActivityDO comActActivityDO=new ComActActivityDO();
comActActivityDO.setId(comActActivityVO.getId());
comActActivityDO.setStatus(comActActivityVO.getStatus());
- comActActivityDO.setCancelReason(comActActivityVO.getCancelRenson());
+ comActActivityDO.setCancelReason(comActActivityVO.getCancelReason());
int update = comActActivityDAO.updateById(comActActivityDO);
if (update>0) {
return R.ok();
@@ -148,6 +151,7 @@
ComActActSignDO comActActSignDO = comActActSignDAO.selectOne(new QueryWrapper<ComActActSignDO>().lambda().eq(ComActActSignDO::getActivityId, id).eq(ComActActSignDO::getUserId, userId));
if (!ObjectUtils.isEmpty(comActActSignDO)) {
comActActivityVO.setIsSign(1);
+ comActActivityVO.setIsVolunteer(comActActSignDO.getIsVolunteer());
}else {
}
@@ -178,10 +182,10 @@
Page page = new Page<>();
Long pageNum = comActActivityVO.getPageNum();
Long pageSize = comActActivityVO.getPageSize();
- if (ObjectUtils.isEmpty(pageNum)||0==pageNum) {
+ if (null==pageNum||0==pageNum) {
pageNum = 1l;
}
- if (ObjectUtils.isEmpty(pageSize)||0==pageSize) {
+ if (null==pageSize||0==pageSize) {
pageSize = 10l;
}
page.setSize(pageSize);
@@ -218,5 +222,48 @@
return R.fail();
}
+ /**
+ * 用户参加的所有社区活动
+ *
+ * @param userId 用户id
+ * @return 活动列表
+ */
+ @Override
+ public R listActivity(Long userId) {
+ List<ComActActSignDO> comActActSignDOS = comActActSignDAO.selectList(new QueryWrapper<ComActActSignDO>().lambda().eq(ComActActSignDO::getUserId, userId));
+ if (ObjectUtils.isEmpty(comActActSignDOS)) {
+ return R.fail();
+ }
+ List<Long> longs = comActActSignDOS.stream().map(comActActSignDO -> comActActSignDO.getActivityId()).collect(Collectors.toList());
+ List<ComActActivityDO> comActActivityDOS = comActActivityDAO.selectBatchIds(longs);
+ List<ComActActivityVO>comActActivityVOS=new ArrayList<>();
+ comActActivityDOS.forEach(comActActivityDO -> {
+ ComActActivityVO comActActivityVO=new ComActActivityVO();
+ BeanUtils.copyProperties(comActActivityDO,comActActivityVO);
+ List<ComActActSignDO> collect = comActActSignDOS.stream().filter(comActActSignDO -> comActActSignDO.getActivityId().equals(comActActivityVO.getId())).limit(1).collect(Collectors.toList());
+ ComActActSignDO comActActSignDO = collect.get(0);
+ Integer isVolunteer = comActActSignDO.getIsVolunteer();
+ if (isVolunteer.intValue()==1) {
+ comActActivityVO.setType(1);
+ }else{
+ comActActivityVO.setType(2);
+ }
+ comActActivityVOS.add(comActActivityVO);
+ });
+ return R.ok(comActActivityVOS);
+ }
+
+ /**
+ * 查询志愿者参与的所有已经完成的活动
+ *
+ * @param phone 用户手机号
+ * @return 所有活动集合
+ */
+ @Override
+ public List<ComActActivityVO> listActivityByPhone(String phone) {
+ List<ComActActivityVO> comActActivityVOS=comActActivityDAO.listActivityByPhone(phone);
+ return comActActivityVOS;
+ }
+
}
--
Gitblit v1.7.1