From c3811d01d1929a98a0f34f70ca187d82ee312dbb Mon Sep 17 00:00:00 2001 From: manailin <261030956@qq.com> Date: 星期三, 03 十一月 2021 17:26:50 +0800 Subject: [PATCH] Merge branch 'test' of http://gitlab.nhys.cdnhxx.com/root/zhihuishequ into test --- springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java | 68 ++++++++++++++++++++++++++++++--- 1 files changed, 61 insertions(+), 7 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java index 58bb6ce..e717966 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java +++ b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java @@ -1,6 +1,12 @@ package com.panzhihua.applets.api; -import java.util.*; +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.Optional; import java.util.concurrent.atomic.AtomicBoolean; import java.util.stream.Collectors; @@ -10,7 +16,14 @@ import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.util.ObjectUtils; import org.springframework.validation.annotation.Validated; -import org.springframework.web.bind.annotation.*; +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; @@ -23,9 +36,20 @@ import com.panzhihua.common.model.dtos.user.SysUserFeedbackDTO; import com.panzhihua.common.model.vos.LoginUserInfoVO; import com.panzhihua.common.model.vos.R; -import com.panzhihua.common.model.vos.community.*; +import com.panzhihua.common.model.vos.community.ComActActEvaluateVO; +import com.panzhihua.common.model.vos.community.ComActActRegistVO; +import com.panzhihua.common.model.vos.community.ComActActivityVO; +import com.panzhihua.common.model.vos.community.ComActEasyPhotoVO; +import com.panzhihua.common.model.vos.community.ComActMicroWishVO; +import com.panzhihua.common.model.vos.community.ComActVO; +import com.panzhihua.common.model.vos.community.ComMngStructAreaVO; +import com.panzhihua.common.model.vos.community.ComMngStructHouseVO; import com.panzhihua.common.model.vos.partybuilding.PartyBuildingMemberVO; -import com.panzhihua.common.model.vos.user.*; +import com.panzhihua.common.model.vos.user.ComMngFamilyInfoVO; +import com.panzhihua.common.model.vos.user.SysUserNoticeVO; +import com.panzhihua.common.model.vos.user.UpdateUserArchivesVO; +import com.panzhihua.common.model.vos.user.UserArchivesVO; +import com.panzhihua.common.model.vos.user.UserPhoneVO; import com.panzhihua.common.service.community.CommunityService; import com.panzhihua.common.service.partybuilding.PartyBuildingService; import com.panzhihua.common.service.user.UserService; @@ -226,17 +250,18 @@ } @ApiOperation(value = "我的活动", response = ComActActivityVO.class) + @ApiImplicitParam(name = "status", value = "活动状态(4 进行中 5 已结束 6 已取消)", required = false) @GetMapping("listactivity") - public R listActivity() { + public R listActivity(@RequestParam("status") Integer status) { LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); Long userId = loginUserInfo.getUserId(); Long communityId = loginUserInfo.getCommunityId(); List<ComActActivityVO> comActActivityVOS = new ArrayList<>(); - R r = communityService.listActivity(userId); + R r = communityService.listActivity(userId, status); if (R.isOk(r)) { comActActivityVOS = (List<ComActActivityVO>)r.getData(); } - R r1 = partyBuildingService.listActivity(userId, communityId); + R r1 = partyBuildingService.listActivity(userId, communityId, status); if (R.isOk(r1)) { List<ComActActivityVO> data = (List<ComActActivityVO>)r1.getData(); comActActivityVOS.addAll(data); @@ -252,6 +277,35 @@ if (!ObjectUtils.isEmpty(comActActivityVOS)) { List<ComActActivityVO> collect = comActActivityVOS.stream() .sorted(Comparator.comparing(ComActActivityVO::getSingDate).reversed()).collect(Collectors.toList()); + //当前用户签到记录列表 + R r2 = communityService.listSignInActivity(userId); + if (R.isOk(r2) && !ObjectUtils.isEmpty(r2.getData())) { + List<ComActActRegistVO> comActActRegistVOS = JSONArray.parseArray(JSONArray.toJSONString(r2.getData()), ComActActRegistVO.class).stream() + .sorted(Comparator.comparing(ComActActRegistVO::getCreateAt).reversed()).collect(toList()); + collect.forEach(comActActivityVO -> { + ArrayList<ComActActRegistVO> currentList = new ArrayList<>(); + comActActRegistVOS.forEach(activitySignInVO -> { + if (comActActivityVO.getId().equals(activitySignInVO.getActivityId())) { + currentList.add(activitySignInVO); + } + }); + if (currentList.size() > 10) { + comActActivityVO.setActivitySignInList(currentList.subList(0, 10)); + } else { + comActActivityVO.setActivitySignInList(currentList); + } + }); + } + //当前用户活动评分 + R r3 = communityService.listEvaluate(userId); + if (R.isOk(r3) && !ObjectUtils.isEmpty(r3.getData())) { + List<ComActActEvaluateVO> comActActEvaluateVOS = JSONArray.parseArray(JSONArray.toJSONString(r3.getData()), ComActActEvaluateVO.class); + collect.forEach(comActActivityVO -> comActActEvaluateVOS.forEach(comActActEvaluateVO -> { + if (comActActEvaluateVO.getActivityId().equals(comActActivityVO.getId())) { + comActActivityVO.setMyRating(comActActEvaluateVO.getStarLevel()); + } + })); + } return R.ok(collect); } return R.ok(comActActivityVOS); -- Gitblit v1.7.1