From 321ebdf330ad299e87132cc51a6c3affe3f51e4d Mon Sep 17 00:00:00 2001 From: manailin <261030956@qq.com> Date: 星期五, 10 九月 2021 11:24:16 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/test' into test --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java | 45 ++++++++++++++++++++++----------------------- 1 files changed, 22 insertions(+), 23 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java index ac35e8a..7e2c566 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java @@ -1,16 +1,16 @@ package com.panzhihua.service_community.api; +import static java.util.stream.Collectors.toList; + import java.util.ArrayList; import java.util.Comparator; import java.util.Date; import java.util.List; import java.util.Map; import java.util.Optional; -import java.util.stream.Collectors; import javax.annotation.Resource; -import cn.hutool.core.date.DateUtil; import com.panzhihua.service_community.model.dos.*; import com.panzhihua.service_community.service.*; import org.springframework.beans.BeanUtils; @@ -50,11 +50,11 @@ import com.panzhihua.common.model.dtos.community.questnaire.StatisticsSummaryDTO; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.SystemmanagementConfigVO; -import com.panzhihua.common.model.vos.community.ComActActRegistVO; import com.panzhihua.common.model.vos.community.ActivitySignVO; import com.panzhihua.common.model.vos.community.BatchhouseVO; import com.panzhihua.common.model.vos.community.ComActActEvaluateVO; import com.panzhihua.common.model.vos.community.ComActActPrizeVO; +import com.panzhihua.common.model.vos.community.ComActActRegistVO; import com.panzhihua.common.model.vos.community.ComActActivityVO; import com.panzhihua.common.model.vos.community.ComActDynVO; import com.panzhihua.common.model.vos.community.ComActEasyPhotoVO; @@ -89,6 +89,7 @@ import com.panzhihua.service_community.dao.ComEldersAuthHistoryRecordMapper; import com.panzhihua.service_community.dao.ComMngPopulationDAO; +import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.IdcardUtil; import lombok.extern.slf4j.Slf4j; @@ -279,6 +280,7 @@ } else { comActActivityVO1.setType(2); } + fillActivitySignList(id, comActActivityVO1); }); page.setRecords(content); } @@ -371,21 +373,20 @@ } }); } - //签到时间 - Optional.ofNullable(userId).ifPresent(currentUserId -> { - R listSignInResult = comActActivityService.listSignInActivity(currentUserId); - if (R.isOk(listSignInResult) && !ObjectUtils.isEmpty(listSignInResult.getData())) { - Optional<ComActActRegistVO> optional = JSONArray.parseArray(JSONArray.toJSONString(listSignInResult.getData()), ComActActRegistVO.class).stream() - .filter(activitySignInVO -> activitySignInVO.getActivityId().equals(id)) - .sorted(Comparator.comparing(ComActActRegistVO::getCreateAt).reversed()).findFirst(); - if (optional.isPresent()) { - comActActivityVO.setActivitySignInDate(optional.get().getCreateAt()); - } - } - }); + fillActivitySignList(id, comActActivityVO); + comActActivityVO.setIntegral(0); + return R.ok(comActActivityVO); + } + + /** + * 填充活动报名名单 + * @param activityId 活动id + * @param comActActivityVO 需填充VO + */ + private void fillActivitySignList(Long activityId, ComActActivityVO comActActivityVO) { //活动报名名单 ActivitySignVO activitySignVO = new ActivitySignVO(); - activitySignVO.setActivityId(id); + activitySignVO.setActivityId(activityId); R r = comActActivityService.listActivitySigns(activitySignVO); if (R.isOk(r)) { List<ActivitySignVO> activitySignVOS = @@ -397,7 +398,7 @@ } } List<ActivitySignVO> collect = activitySignVOS.stream() - .filter(activitySignVO1 -> activitySignVO1.getIsVolunteer() == 1).collect(Collectors.toList()); + .filter(activitySignVO1 -> activitySignVO1.getIsVolunteer() == 1).collect(toList()); if (!ObjectUtils.isEmpty(collect)) { int size = collect.size(); if (size >= 6) { @@ -407,7 +408,7 @@ } } List<ActivitySignVO> collect1 = activitySignVOS.stream() - .filter(activitySignVO1 -> activitySignVO1.getIsVolunteer() == 0).collect(Collectors.toList()); + .filter(activitySignVO1 -> activitySignVO1.getIsVolunteer() == 0).collect(toList()); if (!ObjectUtils.isEmpty(collect1)) { int size = collect1.size(); if (size >= 6) { @@ -419,8 +420,6 @@ } } - comActActivityVO.setIntegral(0); - return R.ok(comActActivityVO); } /** @@ -622,7 +621,7 @@ int size = list.size(); if (size == 4) { List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getCreateAt)) - .collect(Collectors.toList()); + .collect(toList()); ComActDynDO comActDynDO1 = collect.get(0); comActDynDO1.setIsTopping(0); boolean update = comActDynService.updateById(comActDynDO1); @@ -675,7 +674,7 @@ int size = list.size(); if (size == 4) { List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getUpdateAt)) - .collect(Collectors.toList()); + .collect(toList()); ComActDynDO comActDynDO1 = collect.get(0); comActDynDO1.setIsTopping(0); boolean updateById = comActDynService.updateById(comActDynDO1); @@ -914,7 +913,7 @@ boolean save = comActMicroWishService.save(comActMicroWishDO); if (save) { wishOperationRecordService.addOperationRecord("用户提交微心愿",comActMicroWishVO.getSponsorId() - ,comActMicroWishDO.getId(),ComActMicroWishOperationRecordDO.type.ytj,"用户提交微心愿",null); + ,comActMicroWishDO.getId(), ComActMicroWishOperationRecordDO.type.ytj,"用户提交微心愿",null); return R.ok(); } return R.fail(); -- Gitblit v1.7.1