From 9346f597cc502a069679f01505594d8ca6e9f8d0 Mon Sep 17 00:00:00 2001 From: puhanshu <a9236326> Date: 星期三, 15 六月 2022 15:01:10 +0800 Subject: [PATCH] bug修改 --- springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java | 72 ++++++++++++++++++++++++++++++------ 1 files changed, 60 insertions(+), 12 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 0a6de9d..df531f7 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 @@ -12,8 +12,10 @@ import java.util.stream.Collectors; import javax.annotation.Resource; +import javax.validation.Valid; import com.panzhihua.common.constants.HttpStatus; +import com.panzhihua.common.model.dtos.community.social.PageProjectDTO; import org.apache.commons.lang.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.data.redis.core.StringRedisTemplate; @@ -279,11 +281,11 @@ if (R.isOk(r)&&r.getData()!=null) { comActActivityVOS = (List<ComActActivityVO>)r.getData(); } - R r1 = partyBuildingService.listActivity(userId, communityId, status); - if (R.isOk(r1)&&r1.getData()!=null) { - List<ComActActivityVO> data = (List<ComActActivityVO>)r1.getData(); - comActActivityVOS.addAll(data); - } +// R r1 = partyBuildingService.listActivity(userId, communityId, status); +// if (R.isOk(r1)&&r1.getData()!=null) { +// List<ComActActivityVO> data = (List<ComActActivityVO>)r1.getData(); +// comActActivityVOS.addAll(data); +// } if (!ObjectUtils.isEmpty(comActActivityVOS)) { String s = JSONArray.toJSONString(comActActivityVOS); List<ComActActivityVO> comActActivityVOS1 = new ArrayList<>(); @@ -305,6 +307,30 @@ comActActRegistVOS.forEach(activitySignInVO -> { if (comActActivityVO.getId().equals(activitySignInVO.getActivityId())) { currentList.add(activitySignInVO); + if(comActActivityVO.getType()!=3){ + comActActivityVO.setIsComment(1); + if(comActActivityVO.getTimes()==null){ + comActActivityVO.setTimes(1); + comActActivityVO.setAward(comActActivityVO.getRewardIntegral()); + } + else { + comActActivityVO.setTimes(comActActivityVO.getTimes()+1); + comActActivityVO.setAward(comActActivityVO.getRewardIntegral()*comActActivityVO.getTimes()); + } + } + else { + if(activitySignInVO.getEndTime()!=null){ + comActActivityVO.setIsComment(1); + if(comActActivityVO.getTimes()==null){ + comActActivityVO.setTimes(1); + comActActivityVO.setAward(comActActivityVO.getRewardIntegral()); + } + else { + comActActivityVO.setTimes(comActActivityVO.getTimes()+1); + comActActivityVO.setAward(comActActivityVO.getRewardIntegral()*comActActivityVO.getTimes()); + } + } + } } }); if (currentList.size() > 10) { @@ -312,17 +338,31 @@ } else { comActActivityVO.setActivitySignInList(currentList); } + if(comActActivityVO.getLimit()>0&¤tList.size()>0){ + if(comActActivityVO.getType()==3){ + if(comActActivityVO.getLimit()==currentList.size()||currentList.get(currentList.size()-1).getEndTime()!=null){ + comActActivityVO.setIsRegist(1); + } + } + else { + if(comActActivityVO.getLimit()==currentList.size()){ + comActActivityVO.setIsRegist(1); + } + } + } }); } //当前用户活动评分 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()); - } - })); + collect.forEach(comActActivityVO -> { + List<ComActActEvaluateVO> evaluateVOS=comActActEvaluateVOS.stream().filter(comActActEvaluateVO -> comActActEvaluateVO.getActivityId().equals(comActActivityVO.getId())).collect(toList()); + if(comActActivityVO.getSignCount()<=evaluateVOS.size()){ + comActActivityVO.setIsComment(0); + } + comActActivityVO.setComActActEvaluateVOList(evaluateVOS); + }); } return R.ok(collect); } @@ -414,7 +454,7 @@ } // 判断用户是否已认证成功 - R certUser = partyBuildingService.userCertification(userId); + R certUser = partyBuildingService.userCertification(userId,communityId); Object certUserInfo = certUser.getData(); AtomicBoolean userCertified = new AtomicBoolean(false); @@ -449,6 +489,7 @@ } else { partyBuildingMemberVO.setIdCard(loginUserInfo.getIdCard()); partyBuildingMemberVO.setName(loginUserInfo.getName()); + partyBuildingMemberVO.setPhone(loginUserInfo.getPhone()); } R r = partyBuildingService.addPartyBuildingMember(partyBuildingMemberVO); @@ -461,7 +502,7 @@ // 党员认证查询 LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); Long userId = loginUserInfo.getUserId(); - R r = partyBuildingService.userCertification(userId); + R r = partyBuildingService.userCertification(userId,this.getCommunityId()); if (R.isOk(r)) { List<PartyBuildingMemberVO> partyBuildingMemberVOList = @@ -499,4 +540,11 @@ userArchivesVO.setUserId(userId); return userService.updateUserArchives(userArchivesVO); } + + @ApiOperation(value = "分页查询用户报名的项目") + @PostMapping("project") + public R pageProjectWhichIsSignedByUser(@RequestBody @Valid PageProjectDTO pageProjectDTO) { + pageProjectDTO.setUserId(this.getUserId()); + return communityService.pageProjectWhichIsSignedByUser(pageProjectDTO); + } } -- Gitblit v1.7.1