From aad170db8e65a67d1ba34e72a21eb19d91a05373 Mon Sep 17 00:00:00 2001 From: manailin <261030956@qq.com> Date: 星期二, 30 十一月 2021 17:26:22 +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 | 46 +++++++++++++++++++++++++++++++++------------- 1 files changed, 33 insertions(+), 13 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 baaf378..68ef37a 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,17 +1,18 @@ package com.panzhihua.applets.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.Optional; -import java.util.TreeSet; import java.util.concurrent.atomic.AtomicBoolean; import java.util.stream.Collectors; import javax.annotation.Resource; -import com.panzhihua.common.model.vos.community.ComActActEvaluateVO; +import org.apache.commons.lang.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.util.ObjectUtils; @@ -36,6 +37,7 @@ 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.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; @@ -95,6 +97,17 @@ if (!ObjectUtils.isEmpty(data)) { LoginUserInfoVO loginUserInfoVO = (LoginUserInfoVO)data; R r1 = communityService.detailHouse(userId); + if(StringUtils.isNotEmpty(loginUserInfoVO.getIdCard())){ + //查询实名用户绑定的实有人口地址 + R r4=communityService.selectByIdCard(loginUserInfoVO.getIdCard()); + if(R.isOk(r4)){ + String address= (String) r4.getData(); + if(StringUtils.isNotEmpty(address)){ + loginUserInfoVO.setAddress(address); + r.setData(loginUserInfoVO); + } + } + } if (null != communityId && 0 != communityId) { R r2 = communityService.detailCommunity(communityId); if (R.isOk(r2)) { @@ -249,8 +262,9 @@ } @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(); @@ -259,7 +273,7 @@ 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); @@ -275,18 +289,24 @@ 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())) { - ArrayList<ComActActRegistVO> comActActRegistVOS = JSONArray.parseArray(JSONArray.toJSONString(r2.getData()), ComActActRegistVO.class).stream() - .sorted(Comparator.comparing(ComActActRegistVO::getCreateAt).reversed()) - .collect(Collectors.collectingAndThen(Collectors.toCollection(() -> - new TreeSet<>(Comparator.comparing(f -> String.join("", f.getUserId().toString(), f.getActivityId().toString())))), ArrayList::new)); - collect.forEach(comActActivityVO -> comActActRegistVOS.forEach(activitySignInVO -> { - if (comActActivityVO.getId().equals(activitySignInVO.getActivityId())) { - comActActivityVO.setActivitySignInDate(activitySignInVO.getCreateAt()); + 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); -- Gitblit v1.7.1