From 70d2a5d0f9c6951b2d4cac954041ed73582ff7eb Mon Sep 17 00:00:00 2001 From: liujie <1793218484@qq.com> Date: 星期一, 09 六月 2025 11:54:00 +0800 Subject: [PATCH] 6.9新增登录失败冻结逻辑 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java | 928 ++++++++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 747 insertions(+), 181 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 c309429..fa4f27b 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,27 +1,31 @@ package com.panzhihua.service_community.api; -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 static java.util.stream.Collectors.toList; + +import java.math.BigDecimal; +import java.math.RoundingMode; +import java.util.*; import javax.annotation.Resource; +import com.panzhihua.common.controller.BaseController; +import com.panzhihua.common.model.dtos.PageBaseDTO; +import com.panzhihua.common.model.dtos.community.ActivityInviteDTO; +import com.panzhihua.common.model.dtos.community.PageActivityInviteDTO; +import com.panzhihua.common.model.dtos.property.CommonPage; +import com.panzhihua.common.model.vos.LoginUserInfoVO; +import com.panzhihua.common.model.vos.community.ComActActivityTypeVO; +import com.panzhihua.common.model.vos.community.volunteer.ComMngVolunteerExcelVO; +import com.panzhihua.common.model.vos.user.SysTemplateConfigVO; +import com.panzhihua.service_community.dao.ComActActEvaluateDAO; +import com.panzhihua.service_community.model.dos.*; +import com.panzhihua.service_community.service.*; +import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.BeanUtils; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.ObjectUtils; import org.springframework.util.StringUtils; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.PathVariable; -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 org.springframework.web.bind.annotation.*; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; @@ -47,11 +51,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; @@ -85,33 +89,8 @@ import com.panzhihua.service_community.dao.ComActActSignDAO; import com.panzhihua.service_community.dao.ComEldersAuthHistoryRecordMapper; import com.panzhihua.service_community.dao.ComMngPopulationDAO; -import com.panzhihua.service_community.model.dos.ComActActEvaluateDO; -import com.panzhihua.service_community.model.dos.ComActActPrizeDO; -import com.panzhihua.service_community.model.dos.ComActDynDO; -import com.panzhihua.service_community.model.dos.ComActEasyPhotoDO; -import com.panzhihua.service_community.model.dos.ComActMicroWishDO; -import com.panzhihua.service_community.model.dos.ComEldersAuthHistoryRecordDO; -import com.panzhihua.service_community.model.dos.ComEldersAuthUserDO; -import com.panzhihua.service_community.model.dos.ComMngStructAreaDO; -import com.panzhihua.service_community.model.dos.EldersAuthDO; -import com.panzhihua.service_community.service.ComActActEvaluateService; -import com.panzhihua.service_community.service.ComActActPrizeService; -import com.panzhihua.service_community.service.ComActActivityService; -import com.panzhihua.service_community.service.ComActDynService; -import com.panzhihua.service_community.service.ComActEasyPhotoActivityService; -import com.panzhihua.service_community.service.ComActEasyPhotoService; -import com.panzhihua.service_community.service.ComActMessageService; -import com.panzhihua.service_community.service.ComActMicroWishService; -import com.panzhihua.service_community.service.ComActQuestnaireService; -import com.panzhihua.service_community.service.ComActService; -import com.panzhihua.service_community.service.ComEldersAuthUserService; -import com.panzhihua.service_community.service.ComMngStructAreaDistrictService; -import com.panzhihua.service_community.service.ComMngStructAreaService; -import com.panzhihua.service_community.service.ComMngStructHouseService; -import com.panzhihua.service_community.service.ComMngStructOtherBuildService; -import com.panzhihua.service_community.service.ComMngVolunteerMngService; -import com.panzhihua.service_community.service.EldersAuthService; +import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.IdcardUtil; import lombok.extern.slf4j.Slf4j; @@ -124,7 +103,7 @@ @Slf4j @RestController @RequestMapping("/") -public class CommunityApi { +public class CommunityApi extends BaseController { @Resource public ComMngPopulationDAO comMngPopulationDAO; @Resource @@ -167,6 +146,18 @@ private ComActEasyPhotoActivityService comActEasyPhotoActivityService; @Resource private ComActActEvaluateService comActActEvaluateService; + @Resource + private ComEldersAuthElderlyService comEldersAuthElderlyService; + @Resource + private ComActMicroWishOperationRecordService wishOperationRecordService; + @Resource + private ComActActEvaluateDAO comActActEvaluateDAO; + @Resource + private ComActActivityInviteService comActActivityInviteService; + @Resource + private RabbitTemplate rabbitTemplate; + @Resource + private AutomessageSysUserService automessageSysUserService; /** * 新增社区活动 @@ -292,12 +283,15 @@ }); } comActActivityVO1.setComActActPrizeVOList(comActActPrizeVOList); - Integer participantMax = comActActivityVO1.getParticipantMax(); - if (participantMax.intValue() == 0) { - comActActivityVO1.setType(1); - } else { - comActActivityVO1.setType(2); + Integer volunteerMax = comActActivityVO1.getVolunteerMax(); + if(comActActivityVO1.getType()==null){ + if (volunteerMax.intValue() != 0) { + comActActivityVO1.setType(1); + } else { + comActActivityVO1.setType(2); + } } + fillActivitySignList(id, comActActivityVO1); }); page.setRecords(content); } @@ -308,7 +302,7 @@ /** * 社区后台分页查询社区活动 - * + * * @param comActActivityVO * 查询参数 * @return 返回结果 @@ -351,7 +345,9 @@ */ @PostMapping("detailactivity") public R detailActivity(@RequestParam("id") Long id, - @RequestParam(value = "userId", required = false) Long userId) { + @RequestParam(value = "userId", required = false) Long userId, + @RequestParam(value = "pageNum",defaultValue = "1", required = false) Long pageNum, + @RequestParam(value = "pageSize",defaultValue = "10", required = false) Long pageSize) { ComActActivityVO comActActivityVO = comActActivityService.inforActivity(id, userId); if (ObjectUtils.isEmpty(comActActivityVO)) { return R.fail("活动不存在"); @@ -368,43 +364,49 @@ }); comActActivityVO.setComActActPrizeVOList(comActActPrizeVOS); } + // //活动评价 - List<ComActActEvaluateDO> comActActEvaluateDOList = comActActEvaluateService - .list(new QueryWrapper<ComActActEvaluateDO>().lambda().eq(ComActActEvaluateDO::getActivityId, id)); - if (!ObjectUtils.isEmpty(comActActEvaluateDOList)) { - List<ComActActEvaluateVO> comActActEvaluateVOList = new ArrayList<>(); - comActActEvaluateDOList.forEach(comActActEvaluateDO -> { - ComActActEvaluateVO comActActEvaluateVO = new ComActActEvaluateVO(); - BeanUtils.copyProperties(comActActEvaluateDO, comActActEvaluateVO); - comActActEvaluateVOList.add(comActActEvaluateVO); - }); - comActActivityVO.setComActActEvaluateVOList(comActActEvaluateVOList); - //活动评价总数 - comActActivityVO.setEvaluateAmount(comActActEvaluateDOList.size()); - //当前用户对活动的评分 - Optional.ofNullable(userId).ifPresent(currentUserId -> { - Optional<ComActActEvaluateDO> optional = comActActEvaluateDOList.stream() - .filter(comActActEvaluateDO -> comActActEvaluateDO.getUserId().equals(currentUserId)).findFirst(); - if (optional.isPresent()) { - comActActivityVO.setMyRating(optional.get().getStarLevel()); - } - }); - } - //签到时间 - 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()); - } + IPage<ComActActEvaluateVO> comActActEvaluatePage = comActActEvaluateDAO.getEvaluateListPage(new Page(pageNum,pageSize),id); + comActActivityVO.setComActActEvaluateVOList(comActActEvaluatePage.getRecords()); + //活动评价总数 + comActActivityVO.setEvaluateAmount(comActActEvaluatePage.getTotal()); + List<ComActActEvaluateDO> comActActEvaluateList = comActActEvaluateDAO + .selectList(new QueryWrapper<ComActActEvaluateDO>().lambda().eq(ComActActEvaluateDO::getActivityId, id)); + if (comActActEvaluateList != null && comActActEvaluateList.size() > 0) { + BigDecimal starNum = BigDecimal.ZERO; + //总星级 + for (ComActActEvaluateDO evaluate:comActActEvaluateList) { + starNum = starNum.add(BigDecimal.valueOf(evaluate.getStarLevel()==null?0:evaluate.getStarLevel())); } - }); + //评分星级(如果无评分默认5分)=总星级/总评价人数 + if(starNum.compareTo(BigDecimal.ZERO) == 0){ + comActActivityVO.setEvaluateLevel(BigDecimal.valueOf(5)); + }else{ + comActActivityVO.setEvaluateLevel(starNum.divide(BigDecimal.valueOf(comActActEvaluateList.size()),2, RoundingMode.HALF_UP)); + } + }else{ + comActActivityVO.setEvaluateLevel(BigDecimal.valueOf(5)); + } + //当前用户对活动的评分 + ComActActEvaluateVO userActEvaluateVO = comActActEvaluateDAO.getEvaluateListByUserId(id,userId); + if(userActEvaluateVO != null){ + comActActivityVO.setMyRating(userActEvaluateVO.getStarLevel()); + } + 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); + activitySignVO.setStatus(1); R r = comActActivityService.listActivitySigns(activitySignVO); if (R.isOk(r)) { List<ActivitySignVO> activitySignVOS = @@ -416,7 +418,7 @@ } } List<ActivitySignVO> collect = activitySignVOS.stream() - .filter(activitySignVO1 -> activitySignVO1.getIsVolunteer() == 1).collect(Collectors.toList()); + .filter(activitySignVO1 -> activitySignVO1.getSignIdentity() == 3).collect(toList()); if (!ObjectUtils.isEmpty(collect)) { int size = collect.size(); if (size >= 6) { @@ -426,7 +428,7 @@ } } List<ActivitySignVO> collect1 = activitySignVOS.stream() - .filter(activitySignVO1 -> activitySignVO1.getIsVolunteer() == 0).collect(Collectors.toList()); + .filter(activitySignVO1 -> activitySignVO1.getSignIdentity() == 1).collect(toList()); if (!ObjectUtils.isEmpty(collect1)) { int size = collect1.size(); if (size >= 6) { @@ -435,11 +437,19 @@ comActActivityVO.setActivitySignVOList(collect1); } } + List<ActivitySignVO> collect2 = activitySignVOS.stream() + .filter(activitySignVO1 -> activitySignVO1.getSignIdentity() == 2).collect(toList()); + if (!ObjectUtils.isEmpty(collect2)) { + int size = collect2.size(); + if (size >= 6) { + comActActivityVO.setActivityPbList(collect2.subList(0, 6)); + } else { + comActActivityVO.setActivityPbList(collect2); + } + } } } - comActActivityVO.setIntegral(0); - return R.ok(comActActivityVO); } /** @@ -571,6 +581,18 @@ } /** + * description getRegistLists 查询活动未签到 + * @param comActActRegistVO 查询参数 + * @return R 查询结果 + * @author txb + * @date 2021/8/25 9:33 + */ + @PostMapping("activity/noRegist/getList") + public R getNoRegistLists(@RequestBody ComActActRegistVO comActActRegistVO){ + return comActActivityService.getNoRegistLists(comActActRegistVO); + } + + /** * description activityStagistics 活动数据统计 * @param activityId 活动id * @return R 统计结果 @@ -583,6 +605,30 @@ } /** + * 获取活动历史封面 getPictureList + * @param userId 用户id + * @return R 统计结果 + * @author txb + * @date 2021/8/27 13:33 + */ + @GetMapping("/activity/picture/getList") + public R getPictureList(@RequestParam("userId") Long userId){ + return comActActivityService.getPictureList(userId); + } + + /** + * 获取系统预置图库 getSysPictureList + * @param type 图库类型 + * @return R 系统图库集 + * @author txb + * @date 2021/8/27 13:33 + */ + @GetMapping("/activity/sysPicture/getList") + public R getSysPictureList(@RequestParam(value = "type") Integer type){ + return comActActivityService.getSysPictureList(type); + } + + /** * 新增社区动态 * * @param comActDynVO @@ -591,33 +637,153 @@ */ @PostMapping("adddynamic") public R addDynamic(@RequestBody ComActDynVO comActDynVO) { - ComActDynDO comActDynDO = new ComActDynDO(); - BeanUtils.copyProperties(comActDynVO, comActDynDO); - boolean save = comActDynService.save(comActDynDO); - if (save) { - // 最多只能设置三条置顶状态,后边设置会取消先前设置的置顶 - Integer isTopping = comActDynVO.getIsTopping(); - boolean b = isTopping.intValue() == 1; - if (b) { - List<ComActDynDO> list = comActDynService.list(new QueryWrapper<ComActDynDO>().lambda() - .eq(ComActDynDO::getIsTopping, 1).eq(ComActDynDO::getCommunityId, comActDynVO.getCommunityId())); - if (!ObjectUtils.isEmpty(list)) { - int size = list.size(); - if (size == 4) { - List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getCreateAt)) - .collect(Collectors.toList()); - ComActDynDO comActDynDO1 = collect.get(0); - comActDynDO1.setIsTopping(0); - boolean update = comActDynService.updateById(comActDynDO1); - if (!update) { - return R.fail("修改置顶状态失败"); + + if(comActDynVO==null) + { + return R.fail("参数不能为空"); + } + + if(comActDynVO.getCommunityList()!=null && comActDynVO.getCommunityList().size()>0 ) + { + for(String communityId:comActDynVO.getCommunityList()) + { + ComActDynDO comActDynDO = new ComActDynDO(); + BeanUtils.copyProperties(comActDynVO, comActDynDO); + + comActDynDO.setCommunityId(communityId); + + switch (comActDynVO.getType()) + { + //74 + case "党务公开": + comActDynDO.setType("74"); + break; + //75 + case "服务公开": + comActDynDO.setType("75"); + break; + //77 + case "财务公开": + comActDynDO.setType("77"); + break; + case "项目公开": + comActDynDO.setType("1559820224499318786"); + break; + // + case "资金公开": + case "资产公开": + case "资源公开": + case "村集体经济组织项目": + comActDynDO.setType(comActDynService.getTypeId(communityId,comActDynVO.getType())); + break; + } + + if(StringUtils.isEmpty(comActDynVO.getType())) + { + return R.fail("分类选择错误"); + } + + + boolean save = comActDynService.save(comActDynDO); + if (save) { + if(comActDynVO.getCategory()!=null&&comActDynVO.getCategory()==4){ + comActDynVO.setId(comActDynDO.getId()); + comActDynVO.setCommunityId(communityId); + rabbitTemplate.convertAndSend("huacheng.acid.message.exchange", "huacheng.acid.message.key", comActDynVO); + } + // 最多只能设置三条置顶状态,后边设置会取消先前设置的置顶 + Integer isTopping = comActDynVO.getIsTopping(); + boolean b = isTopping.intValue() == 1; + if (b) { + List<ComActDynDO> list = comActDynService.list(new QueryWrapper<ComActDynDO>().lambda() + .eq(ComActDynDO::getIsTopping, 1).eq(ComActDynDO::getCommunityId, communityId)); + if (!ObjectUtils.isEmpty(list)) { + int size = list.size(); + if (size == 4) { + List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getCreateAt)) + .collect(toList()); + ComActDynDO comActDynDO1 = collect.get(0); + comActDynDO1.setIsTopping(0); + boolean update = comActDynService.updateById(comActDynDO1); + if (!update) { + return R.fail("修改置顶状态失败"); + } + } + } + } + } + } + return R.ok(); + +// ComActDynDO comActDynDO = new ComActDynDO(); +// BeanUtils.copyProperties(comActDynVO, comActDynDO); +// +// boolean save = comActDynService.save(comActDynDO); +// if (save) { +// if(comActDynVO.getCategory()!=null&&comActDynVO.getCategory()==4){ +// comActDynVO.setId(comActDynDO.getId()); +// rabbitTemplate.convertAndSend("huacheng.acid.message.exchange", "huacheng.acid.message.key", comActDynVO); +// } +// // 最多只能设置三条置顶状态,后边设置会取消先前设置的置顶 +// Integer isTopping = comActDynVO.getIsTopping(); +// boolean b = isTopping.intValue() == 1; +// if (b) { +// List<ComActDynDO> list = comActDynService.list(new QueryWrapper<ComActDynDO>().lambda() +// .eq(ComActDynDO::getIsTopping, 1).eq(ComActDynDO::getCommunityId, comActDynVO.getCommunityId())); +// if (!ObjectUtils.isEmpty(list)) { +// int size = list.size(); +// if (size == 4) { +// List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getCreateAt)) +// .collect(toList()); +// ComActDynDO comActDynDO1 = collect.get(0); +// comActDynDO1.setIsTopping(0); +// boolean update = comActDynService.updateById(comActDynDO1); +// if (!update) { +// return R.fail("修改置顶状态失败"); +// } +// } +// } +// } +// return R.ok(); +// } + + } + else + { + ComActDynDO comActDynDO = new ComActDynDO(); + BeanUtils.copyProperties(comActDynVO, comActDynDO); + + comActDynDO.setCommunityId(comActDynVO.getCommunityId()); + boolean save = comActDynService.save(comActDynDO); + if (save) { + if(comActDynVO.getCategory()!=null&&comActDynVO.getCategory()==4){ + comActDynVO.setId(comActDynVO.getId()); + comActDynVO.setCommunityId(comActDynVO.getCommunityId()); + rabbitTemplate.convertAndSend("huacheng.acid.message.exchange", "huacheng.acid.message.key", comActDynVO); + } + // 最多只能设置三条置顶状态,后边设置会取消先前设置的置顶 + Integer isTopping = comActDynVO.getIsTopping(); + boolean b = isTopping.intValue() == 1; + if (b) { + List<ComActDynDO> list = comActDynService.list(new QueryWrapper<ComActDynDO>().lambda() + .eq(ComActDynDO::getIsTopping, 1).eq(ComActDynDO::getCommunityId, comActDynVO.getCommunityId())); + if (!ObjectUtils.isEmpty(list)) { + int size = list.size(); + if (size == 4) { + List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getCreateAt)) + .collect(toList()); + ComActDynDO comActDynDO1 = collect.get(0); + comActDynDO1.setIsTopping(0); + boolean update = comActDynService.updateById(comActDynDO1); + if (!update) { + return R.fail("修改置顶状态失败"); + } } } } } return R.ok(); } - return R.fail(); } /** @@ -648,6 +814,32 @@ // } BeanUtils.copyProperties(comActDynVO, comActDynDO); + switch (comActDynVO.getType()) + { + //74 + case "党务公开": + comActDynDO.setType("74"); + break; + //75 + case "服务公开": + comActDynDO.setType("75"); + break; + //77 + case "财务公开": + comActDynDO.setType("77"); + break; + case "项目公开": + comActDynDO.setType("1559820224499318786"); + break; + // + case "资金公开": + case "资产公开": + case "资源公开": + case "村集体经济组织项目": + comActDynDO.setType(comActDynService.getTypeId(comActDynDO.getCommunityId(),comActDynVO.getType())); + break; + } + boolean update = comActDynService.updateById(comActDynDO); if (update) { // 最多只能设置三条置顶状态,后边设置会取消先前设置的置顶 @@ -658,7 +850,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); @@ -738,6 +930,17 @@ } /** + * 分页查询随手拍 浪潮专用 + * + * 查询参数 + * @return 心愿列表 + */ + @GetMapping("pageEasyPhotoAdminLC") + public R pageEasyPhotoAdminLC(@RequestParam("pageNum") Long pageNum,@RequestParam("pageSize") Long pageSize) { + return comActEasyPhotoService.pageEasyPhotoAdminLC(pageNum,pageSize); + } + + /** * 城管安排 * * @param comActEasyPhotoVO @@ -755,6 +958,20 @@ @PostMapping("exportEasyPhoto") public R exportEasyPhoto(@RequestBody ExportEasyPhotoDTO exportEasyPhotoDTO) { return comActEasyPhotoService.export(exportEasyPhotoDTO); + } + + /** + * 随手拍详情-脱敏 + * + * @param id + * 随手拍主键 + * @param userId + * 登录用户 + * @return 详情内容 + */ + @PostMapping("detaileasyphotodesensitize") + public R detailEasyPhotoDesensitize(@RequestParam("id") Long id, @RequestParam("userId") Long userId) { + return comActEasyPhotoService.detailEasyPhotoDesensitize(id, userId); } /** @@ -806,6 +1023,16 @@ return comActMicroWishService.pageMicroWish(comActMicroWishVO); } + @PostMapping("pagemicrowish/applets") + public R pageMicroWishApplets(@RequestBody ComActMicroWishVO comActMicroWishVO) { + return comActMicroWishService.pageMicroWishApplets(comActMicroWishVO); + } + + @PostMapping("pagemicrowish/appletsDesensitize") + public R pageMicroWishAppletsDesensitize(@RequestBody ComActMicroWishVO comActMicroWishVO) { + return comActMicroWishService.pageMicroWishAppletsDesensitize(comActMicroWishVO); + } + /** * 心愿详情 * @@ -818,6 +1045,19 @@ @PostMapping("detailmicrowish") public R detailMicroWish(@RequestParam("id") Long id, @RequestParam("userId") Long userId) { return comActMicroWishService.detailMicroWish(id, userId); + } + /** + * 心愿详情 - 脱敏 + * + * @param id + * 查询主键 + * @param userId + * 登录用户id + * @return 心愿内容 + */ + @PostMapping("detailmicrowishdesensitize") + public R detailMicroWishDesensitize(@RequestParam("id") Long id, @RequestParam("userId") Long userId) { + return comActMicroWishService.detailMicroWishDesensitize(id, userId); } /** @@ -870,7 +1110,7 @@ /** * 查询随手拍是否有活动 - * + * * @return 活动详情 */ @PostMapping("getEasyPhotoActivity") @@ -891,6 +1131,8 @@ BeanUtils.copyProperties(comActMicroWishVO, comActMicroWishDO); boolean save = comActMicroWishService.save(comActMicroWishDO); if (save) { + wishOperationRecordService.addOperationRecord("用户提交微心愿",comActMicroWishVO.getSponsorId() + ,comActMicroWishDO.getId(), ComActMicroWishOperationRecordDO.type.ytj,"用户提交微心愿",null); return R.ok(); } return R.fail(); @@ -1159,17 +1401,17 @@ /** * 查询所有建筑类型 - * + * * @return 类型列表 */ @PostMapping("listbuildtype") - public R listBuildType() { - return comMngStructOtherBuildService.listBuildType(); + public R listBuildType(@RequestParam("communityId")Long communityId) { + return comMngStructOtherBuildService.listBuildType(communityId); } /** * 分页查询 其他建筑 - * + * * @param comMngStructOtherBuildVO * 分页查询参数 * @return 查询结果 @@ -1181,19 +1423,28 @@ /** * 增加志愿者 - * + * * @param comMngVolunteerMngVO * 志愿者信息 * @return 增加结果 */ @PostMapping("addvolunteer") R addVolunteer(@RequestBody ComMngVolunteerMngVO comMngVolunteerMngVO) { + Long submitUserId = comMngVolunteerMngVO.getSubmitUserId(); + if (Objects.nonNull(submitUserId)) { + //获取小程序用户信息 + R<LoginUserInfoVO> userInfoR = userService.getUserInfoByUserId(submitUserId.toString()); + LoginUserInfoVO userInfo = userInfoR.getData(); + if (Objects.nonNull(userInfo)) { + comMngVolunteerMngVO.setIdCard(userInfo.getIdCard()); + } + } return comMngVolunteerMngService.addVolunteer(comMngVolunteerMngVO); } /** * 获取志愿者详情 - * + * * @param id * @return */ @@ -1370,8 +1621,10 @@ * @return 活动列表 */ @PostMapping("listactivity") - public R listActivity(@RequestParam("userId") Long userId) { - return comActActivityService.listActivity(userId); + public R listActivity(@RequestParam("userId") Long userId, + @RequestParam(value = "status", required = false) Integer status, + @RequestParam(value = "type", required = false) Integer type) { + return comActActivityService.listActivity(userId, status,type); } /** @@ -1477,8 +1730,8 @@ * @return 社区集合 按照创建顺序倒序排列 */ @PostMapping("listcommunityall") - public R listCommunityAll() { - return comActService.listCommunityAll(); + public R listCommunityAll(@RequestParam("areaCode") String areaCode) { + return comActService.listCommunityAll(areaCode); } /** @@ -1623,6 +1876,19 @@ return comActEasyPhotoService.pageEasyPhotoApplets(comActEasyPhotoVO); } + + /** + * 小程序分页查询随手拍 脱敏 + * + * @param comActEasyPhotoVO + * 查询参数 + * @return 返回结果 + */ + @PostMapping("pageeasyphotoappletsdesensitize") + public R pageEasyPhotoAppletsDesensitize(@RequestBody ComActEasyPhotoVO comActEasyPhotoVO) { + return comActEasyPhotoService.pageEasyPhotoAppletsDesensitize(comActEasyPhotoVO); + } + /** * 随手拍评论分页查询 * @@ -1633,6 +1899,18 @@ @PostMapping("pagecomacteasyphotocomment") public R pageComActEasyPhotoComment(@RequestBody PageComActEasyPhotoCommentDTO pageComActEasyPhotoCommentDTO) { return comActEasyPhotoService.pageComActEasyPhotoComment(pageComActEasyPhotoCommentDTO); + } + + /** + * 随手拍评论分页查询 - 脱敏 + * + * @param pageComActEasyPhotoCommentDTO + * 查询参数 + * @return 查询结果 + */ + @PostMapping("pagecomacteasyphotocommentdesensitize") + public R pageComActEasyPhotoCommentDesensitize(@RequestBody PageComActEasyPhotoCommentDTO pageComActEasyPhotoCommentDTO) { + return comActEasyPhotoService.pageComActEasyPhotoCommentDesensitize(pageComActEasyPhotoCommentDTO); } /** @@ -2097,67 +2375,71 @@ if (authUserDO == null) { return R.fail("未查询到老人信息"); } - - Long elderId = authUserDO.getId(); - boolean canReAuthThisMonth = comEldersAuthUserService.checkReAuthAgain(elderId); - if (!canReAuthThisMonth) { - return R.fail("当月已认证,不能再次进行认证"); - } - + //根据身份证获取出生日期并获取岁数 String idCard = authUserDO.getIdCard(); - - Long loginUserId = eldersAuthAddByFamilyDTO.getUserId(); - EldersAuthDO eldersAuthDO = new EldersAuthDO(); - eldersAuthDO.setSumitUserId(loginUserId); - eldersAuthDO.setCreateBy(loginUserId); - eldersAuthDO.setCreateAt(new Date()); - eldersAuthDO.setIdCard(idCard); - eldersAuthDO.setAuthUserName(authUserDO.getName()); - eldersAuthDO.setVideoUrl(eldersAuthAddByFamilyDTO.getVideoUrl()); - eldersAuthDO.setFamilyUserId(authUserDO.getId()); - eldersAuthDO.setAge(IdcardUtil.getAgeByIdCard(idCard)); - // 根据身份证查询出籍贯 出生日期 - // String domicile = IdCard.domicile(eldersAuthDO.getIdCard()); - String domicile = eldersAuthService.queryDomicile(eldersAuthDO.getIdCard()); - if (StringUtils.isEmpty(domicile)) { - domicile = "暂无"; - } - Date birthDay = IdCard.birthDay(idCard); - eldersAuthDO.setDomicile(domicile); - eldersAuthDO.setBirthDay(birthDay); - int add = eldersAuthService.getBaseMapper().insert(eldersAuthDO); - if (add == 1) { - // 设置认证成功 - Long familyUserId = eldersAuthDO.getFamilyUserId(); - ComEldersAuthUserDO comEldersAuthUserDO = new ComEldersAuthUserDO(); - comEldersAuthUserDO.setId(familyUserId); - comEldersAuthUserDO.setIsAuth(1); - boolean updated = comEldersAuthUserService.updateById(comEldersAuthUserDO); - if (!updated) { - throw new ServiceException("添加认证失败,更新认证状态"); - } - // 认证成功 添加认证记录 - List<ComEldersAuthHistoryRecordDO> authHistoryRecordDOList = - comEldersAuthHistoryRecordMapper.selectList(new QueryWrapper<ComEldersAuthHistoryRecordDO>().lambda() - .eq(ComEldersAuthHistoryRecordDO::getIdCard, idCard) - .ge(ComEldersAuthHistoryRecordDO::getCreateAt, DateUtils.getFirstDayOfMonth())); - if (authHistoryRecordDOList.isEmpty()) { - ComEldersAuthHistoryRecordDO authHistoryRecordDO = new ComEldersAuthHistoryRecordDO(); - authHistoryRecordDO.setUserId(eldersAuthAddByFamilyDTO.getFamilyUserId()); - authHistoryRecordDO.setAuthId(eldersAuthDO.getId()); - BeanUtils.copyProperties(eldersAuthDO, authHistoryRecordDO); - authHistoryRecordDO.setId(null); - authHistoryRecordDO.setBrithday(AgeUtils.getAgeFormatBirthday(IdcardUtil.getBirthByIdCard(idCard))); - authHistoryRecordDO.setAge(IdcardUtil.getAgeByIdCard(idCard)); - authHistoryRecordDO.setIsAuth(1); - authHistoryRecordDO.setDomicile(domicile); - comEldersAuthHistoryRecordMapper.insert(authHistoryRecordDO); - } - return R.ok(eldersAuthDO.getId()); - } + long year=DateUtil.betweenYear(birthDay,DateUtil.date(),true); + if(authUserDO.getBigAgeId()!=null){ + ComEldersAuthElderlyDO comEldersAuthElderlyDO=comEldersAuthElderlyService.getById(authUserDO.getBigAgeId()); + if(comEldersAuthElderlyDO!=null&&comEldersAuthElderlyDO.getIsExist()==ComEldersAuthElderlyDO.isExist.yes&&comEldersAuthElderlyDO.getIsBigAge()==ComEldersAuthElderlyDO.isBigAge.yes&&year>=80){ + Long elderId = authUserDO.getId(); + boolean canReAuthThisMonth = comEldersAuthUserService.checkReAuthAgain(elderId); + if (!canReAuthThisMonth) { + return R.fail("当月已认证,不能再次进行认证"); + } + Long loginUserId = eldersAuthAddByFamilyDTO.getUserId(); + EldersAuthDO eldersAuthDO = new EldersAuthDO(); + eldersAuthDO.setSumitUserId(loginUserId); + eldersAuthDO.setCreateBy(loginUserId); + eldersAuthDO.setCreateAt(new Date()); + eldersAuthDO.setIdCard(idCard); + eldersAuthDO.setAuthUserName(authUserDO.getName()); + eldersAuthDO.setVideoUrl(eldersAuthAddByFamilyDTO.getVideoUrl()); + eldersAuthDO.setFamilyUserId(authUserDO.getId()); + eldersAuthDO.setAge(IdcardUtil.getAgeByIdCard(idCard)); + // 根据身份证查询出籍贯 出生日期 + // String domicile = IdCard.domicile(eldersAuthDO.getIdCard()); + String domicile = eldersAuthService.queryDomicile(eldersAuthDO.getIdCard()); + if (StringUtils.isEmpty(domicile)) { + domicile = "暂无"; + } + eldersAuthDO.setDomicile(domicile); + eldersAuthDO.setBirthDay(birthDay); + int add = eldersAuthService.getBaseMapper().insert(eldersAuthDO); + if (add == 1) { + // 设置认证成功 + Long familyUserId = eldersAuthDO.getFamilyUserId(); + ComEldersAuthUserDO comEldersAuthUserDO = new ComEldersAuthUserDO(); + comEldersAuthUserDO.setId(familyUserId); + comEldersAuthUserDO.setIsAuth(1); + boolean updated = comEldersAuthUserService.updateById(comEldersAuthUserDO); + if (!updated) { + throw new ServiceException("添加认证失败,更新认证状态"); + } + // 认证成功 添加认证记录 + List<ComEldersAuthHistoryRecordDO> authHistoryRecordDOList = + comEldersAuthHistoryRecordMapper.selectList(new QueryWrapper<ComEldersAuthHistoryRecordDO>().lambda() + .eq(ComEldersAuthHistoryRecordDO::getIdCard, idCard) + .ge(ComEldersAuthHistoryRecordDO::getCreateAt, DateUtils.getFirstDayOfMonth())); + if (authHistoryRecordDOList.isEmpty()) { + ComEldersAuthHistoryRecordDO authHistoryRecordDO = new ComEldersAuthHistoryRecordDO(); + authHistoryRecordDO.setUserId(eldersAuthAddByFamilyDTO.getFamilyUserId()); + authHistoryRecordDO.setAuthId(eldersAuthDO.getId()); + BeanUtils.copyProperties(eldersAuthDO, authHistoryRecordDO); + authHistoryRecordDO.setId(null); + authHistoryRecordDO.setBrithday(AgeUtils.getAgeFormatBirthday(IdcardUtil.getBirthByIdCard(idCard))); + authHistoryRecordDO.setAge(IdcardUtil.getAgeByIdCard(idCard)); + authHistoryRecordDO.setIsAuth(1); + authHistoryRecordDO.setDomicile(domicile); + comEldersAuthHistoryRecordMapper.insert(authHistoryRecordDO); + } + return R.ok(eldersAuthDO.getId()); + } - return R.fail(); + } + return R.fail("不满足认证条件"); + } + return R.fail("未查询到高龄老人库数据"); } /** @@ -2198,10 +2480,11 @@ String openid = map.get("openid"); try { WxXCXTempSend util = new WxXCXTempSend(); - String accessToken = util.getAppAccessToken(); + R<SysTemplateConfigVO> sysTemplateConfigVO=userService.selectTemplate(eldersAuthFeedbackAddDTO.getAreaCode(),5); + String accessToken = util.getAccessToken(); WxUtil.sendSubscribeRZSH(openid, accessToken, "高龄认证", DateUtils.format(eldersAuthDO.getCreateAt(), DateUtils.ymdhms_format), - eldersAuthFeedbackAddDTO.getFeedBack()); + eldersAuthFeedbackAddDTO.getFeedBack(),sysTemplateConfigVO.getData().getTemplateId()); } catch (Exception e) { log.error("推送审核状态订阅消息失败,失败原因:" + e.getMessage()); } @@ -2264,7 +2547,17 @@ */ @GetMapping("/eventgrid/community/list") public R getCommunityLists() { - return comActService.getCommunityLists(); + return comActService.getCommunityLists(this.getAppId()); + } + + /** + * 查询西区社区列表 + * + * @return 社区列表 + */ + @GetMapping("/eventgrid/community/westList") + public R getWestCommunityLists(@RequestParam(value = "areaCode",required = false)String areaCode) { + return comActService.getWestCommunityLists(areaCode); } /** @@ -2293,6 +2586,24 @@ return comActEasyPhotoService.getUserReward(userId, communityId); } + /** + * 获取首页弹窗接口 + * + * @param userId + * 用户id + * @param communityId + * 社区id + * @return 首页弹窗接口 + */ + @PostMapping("easyphoto/getUserRewards") + public R getUserRewards(@RequestParam("userId") Long userId, @RequestParam("communityId") Long communityId) { + return comActEasyPhotoService.getUserReward(userId, communityId); + } + + @PostMapping("easyphoto/getUserRewardsNew") + public R getUserRewardsNew(@RequestParam("userId") Long userId, @RequestParam("communityId") Long communityId) { + return comActEasyPhotoService.getUserRewardNew(userId, communityId); + } /** * 读取用户随手拍奖励 * @@ -2401,4 +2712,259 @@ public R easyPhotoNoHandleList(@RequestParam("communityId") Long communityId) { return comActEasyPhotoService.easyPhotoNoHandleList(communityId); } + + /** + * 微心愿处理人列表 + * @param communityId 社区id + * @param type 处理人类型(1.后台用户 2.党员 3.志愿者) + * @return 处理人列表 + */ + @GetMapping("wish/handle/list/admin") + public R wishHandleListAdmin(@RequestParam(value = "communityId") Long communityId,@RequestParam("type") Integer type){ + return R.ok(comActMicroWishService.wishHandleListAdmin(communityId,type)); + } + + /** + * 社区后台分页查询微心愿 + * @param comActMicroWishVO 请求参数 + * @return 微心愿列表 + */ + @PostMapping("pagemicrowishAdmin") + public R pageMicroWishAdmin(@RequestBody ComActMicroWishVO comActMicroWishVO) { + return comActMicroWishService.pageMicroWishAdmin(comActMicroWishVO); + } + + /** + * 活动报名签到情况 + * @param id 活动主键id + * @return + */ + @GetMapping("activity/sign-in/list") + public R listSignInRecord(@RequestParam("id") Long id) { + return comActActivityService.listSignInRecord(id); + } + + /** + * 活动签到记录 + * @param id 活动主键 + * @param userId 用户id + * @return + */ + @GetMapping("activity/regist/list") + public R listRegistRecord(@RequestParam("id") Long id, @RequestParam("userId") Long userId) { + return comActActivityService.listRegistRecord(id, userId); + } + + /** + * 获取活动类型(目前只有志愿者活动需要获取) + * @param communityId + * @param type + * @return + */ + @GetMapping("activity/type/list") + public R listActivityType(@RequestParam("communityId") Long communityId, @RequestParam("type") Integer type) { + return comActActivityService.listActivityType(communityId, type); + } + + /** + * 添加活动类型 + * @param comActActivityTypeVO + * @return + */ + @PostMapping("activity/type/add") + public R addActivityType(@RequestBody ComActActivityTypeVO comActActivityTypeVO) { + return comActActivityService.addActivityType(comActActivityTypeVO); + } + + /** + * 我的评价 + * @param userId + * @param activityId 活动id + * @return + */ + @GetMapping("activity/my-evaluate") + public R listMyActivityEvaluate(@RequestParam("userId") Long userId, @RequestParam("activityId") Long activityId) { + return comActActEvaluateService.listMyActivityEvaluate(userId, activityId); + } + + /** + * 志愿者导入 + * + * @param list 志愿者数据列表 + * @param communityId 社区id + * @param userId 用户id + * @return 导入结果 + */ + @PostMapping("/volunteer/import/admin") + public R importVolunteerAdmin(@RequestBody List<ComMngVolunteerExcelVO> list, + @RequestParam(value = "communityId") Long communityId, @RequestParam(value = "userId") Long userId) { + return comMngVolunteerMngService.importVolunteerAdmin(list,communityId,userId); + } + + /** + * [方法描述] 根据社区ID查询所属城市所在区区域代码, + * + * @param communityId + * 社区ID + * @return String 区域code + * @author manailin + * @date 2022/2/17 10:09 + */ + @GetMapping("act/getActBelongRegionCode") + public String getActBelongRegionCode(@RequestParam("communityId") Long communityId) { + return comActActivityService.getActBelongRegionCode(communityId); + } + + /** + * 党员活动统计 + * @param communityId + * @param year + * @return + */ + @GetMapping("activity/partyMemberCount") + public R partyMemberCount(@RequestParam("communityId")Long communityId,@RequestParam("year")String year){ + return comActActivityService.partyMemberCount(communityId,year); + } + + /** + * 党员活动详情数据 + * @return + */ + @PostMapping("activity/partyMemberDetail") + public R partyMemberDetail(@RequestBody CommonPage commonPage){ + return comActActivityService.partyMemberDetail(commonPage); + } + + + /** + * 导出党员活动详情数据 + * @return + */ + @PostMapping("activity/exportPartyMemberDetail") + public R exportPartyMemberDetail(@RequestBody CommonPage commonPage){ + return comActActivityService.exportPartyMemberDetail(commonPage); + } + + /** + * 批量删除活动 + * @param ids + * @return + */ + @PostMapping("batchDel") + public R deleteActivities(@RequestBody List<Long> ids) { + return R.ok(comActActivityService.removeByIds(ids)); + } + + /** + * 获取人大代表反馈记录 + * @param id + * @return + */ + @GetMapping("dpc/feedback") + public R getFeedbackList(@RequestParam("id") Long id) { + return comActEasyPhotoService.getFeedbackList(id); + } + + /** + * 人大代表反馈随手拍 + * @param comActEasyPhotoVO + * @return + */ + @PostMapping("dpc/feedback") + public R addEasyPhotoFeedbackForDpc(@RequestBody ComActEasyPhotoVO comActEasyPhotoVO) { + return comActEasyPhotoService.addEasyPhotoFeedbackForDpc(comActEasyPhotoVO); + } + + /** + * 活动邀请列表 + * @param pageActivityInviteDTO + * @return + */ + @PostMapping("activity/invite/list") + public R pageActivityInviteList(@RequestBody PageActivityInviteDTO pageActivityInviteDTO) { + return comActActivityInviteService.pageActivityInviteList(pageActivityInviteDTO); + } + + /** + * 添加邀请人员 + * @param list + * @return + */ + @PostMapping("activity/invite/add") + public R activityInviteAdd(@RequestBody List<ActivityInviteDTO> list) { + return comActActivityInviteService.activityInviteAdd(list); + } + + /** + * 删除邀请人员 + * @param id + * @return + */ + @DeleteMapping("activity/invite/delete") + public R activityInviteDelete(@RequestParam("id") Long id) { + return comActActivityInviteService.activityInviteDelete(id); + } + + /** + * 根据id查询重复的社区id集合 + * @param id + * @return + */ + @GetMapping("selectCommunityIds") + public R selectCommunityIds(@RequestParam("id") Long id){ + return comActService.selectIds(id); + } + + + /** + * 通过id查询用户 + * @param id + * @return + */ + @GetMapping("selectAutomessageSysUserById") + public R selectAutomessageSysUserById(@RequestParam("id") Long id){ + return automessageSysUserService.selectAutomessageSysUserById(id); + } + + /** + * 根据id查询重复的社区id集合 + * @return + */ + @GetMapping("selectBasicData") + public R selectBasicData(){ + return comActService.selectBasicData(); + } + + /** + * 统计在职干部特长 + * @return + */ + @GetMapping("statisticsPbMemberType") + public R statisticsPbMemberType(){ + return comActService.statisticsPbMemberType(); + } + + /** + * 统计单位 + * @return + */ + @GetMapping("selectUnitByNatureName") + public R selectUnitByNatureName(){ + return comActService.selectUnitByNatureName(); + } + + /** + * 大屏-社区活动分页 + * @return + */ + @PostMapping("pageActivityBigScreen") + public R pageActivityBigScreen(@RequestBody PageBaseDTO pageBaseDTO){ + return comActActivityService.pageActivityBigScreen(pageBaseDTO); + } + + @GetMapping("easyphoto/selectStatisticsPhoto") + public R selectStatisticsPhoto() { + return comActEasyPhotoService.selectStatisticsPhoto(); + } + } -- Gitblit v1.7.1