From 8555f974846ca5b4f4734f52b51e39cd4502df44 Mon Sep 17 00:00:00 2001 From: DESKTOP-71BH0QO\L、ming <172680469@qq.com> Date: 星期五, 02 四月 2021 15:46:30 +0800 Subject: [PATCH] fix:修改bug --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java | 434 ++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 420 insertions(+), 14 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 16c61fe..6033dad 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,21 +1,31 @@ package com.panzhihua.service_community.api; +import com.alibaba.fastjson.JSONArray; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.panzhihua.common.exceptions.ServiceException; +import com.panzhihua.common.model.dtos.community.ComActEasyPhotoCommentDTO; +import com.panzhihua.common.model.dtos.community.PageComActEasyPhotoCommentDTO; +import com.panzhihua.common.model.dtos.community.ComActEasyPhotoCommentUserDTO; +import com.panzhihua.common.model.dtos.community.PageComActDTO; +import com.panzhihua.common.model.vos.LoginUserInfoVO; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.SystemmanagementConfigVO; import com.panzhihua.common.model.vos.community.*; import com.panzhihua.common.model.vos.user.UserPhoneVO; +import com.panzhihua.common.validated.AddGroup; import com.panzhihua.service_community.model.dos.ComActActPrizeDO; import com.panzhihua.service_community.model.dos.ComActDynDO; import com.panzhihua.service_community.model.dos.ComActMicroWishDO; import com.panzhihua.service_community.model.dos.ComMngStructAreaDO; import com.panzhihua.service_community.service.*; + +import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.ObjectUtils; +import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; @@ -54,6 +64,10 @@ private ComMngStructOtherBuildService comMngStructOtherBuildService; @Resource private ComMngVolunteerMngService comMngVolunteerMngService; + @Resource + private ComMngStructAreaDistrictService comMngStructAreaDistrictService; + @Resource + private ComActMessageService comActMessageService; /** * 新增社区活动 @@ -106,8 +120,8 @@ boolean ok = R.isOk(r); if (ok) { Integer hasPrize = comActActivityVO.getHasPrize(); + Long actActivityVOId = comActActivityVO.getId(); if (!ObjectUtils.isEmpty(comActActPrizeVOList) && hasPrize.intValue() == 1) { - Long actActivityVOId = comActActivityVO.getId(); comActActPrizeService.remove(new QueryWrapper<ComActActPrizeDO>().lambda().eq(ComActActPrizeDO::getActivityId, actActivityVOId)); if (!ObjectUtils.isEmpty(comActActPrizeVOList)) { List<ComActActPrizeDO> comActActPrizeDOS = new ArrayList<>(); @@ -122,6 +136,9 @@ return R.fail("保存奖品失败"); } } + }else if(hasPrize.intValue() == 0){ + boolean remove = comActActPrizeService.remove(new QueryWrapper<ComActActPrizeDO>().lambda().eq(ComActActPrizeDO::getActivityId, actActivityVOId)); + log.info("删除社区活动奖品结果【{}】,社区活动id【{}】",remove,actActivityVOId); } } return r; @@ -156,8 +173,8 @@ Page<ComActActivityVO> page = (Page<ComActActivityVO>) r.getData(); List<ComActActivityVO> content = page.getRecords(); if (!ObjectUtils.isEmpty(content)) { - List<ComActActPrizeVO> comActActPrizeVOList = new ArrayList<>(); content.forEach(comActActivityVO1 -> { + List<ComActActPrizeVO> comActActPrizeVOList = new ArrayList<>(); Long id = comActActivityVO1.getId(); List<ComActActPrizeDO> list = comActActPrizeService.list(new QueryWrapper<ComActActPrizeDO>().lambda().eq(ComActActPrizeDO::getActivityId, id)); if (!ObjectUtils.isEmpty(list)) { @@ -168,12 +185,28 @@ }); } comActActivityVO1.setComActActPrizeVOList(comActActPrizeVOList); - comActActPrizeVOList.clear(); + Integer participantMax = comActActivityVO1.getParticipantMax(); + if (participantMax.intValue()==0) { + comActActivityVO1.setType(1); + }else{ + comActActivityVO1.setType(2); + } }); + page.setRecords(content); } } return r; + } + + /** + * 社区后台分页查询社区活动 + * @param comActActivityVO 查询参数 + * @return 返回结果 + */ + @PostMapping("pageactivitycommunityback") + public R pageActivityCommunityBack(@RequestBody ComActActivityVO comActActivityVO){ + return comActActivityService.pageActivityCommunityBack(comActActivityVO); } /** @@ -224,14 +257,30 @@ activitySignVO.setActivityId(id); R r = comActActivityService.listActivitySign(activitySignVO); if (R.isOk(r)) { - List<ActivitySignVO> activitySignVOS = (List<ActivitySignVO>) r.getData(); - int size = activitySignVOS.size(); - if (size>=6) { - comActActivityVO.setActivitySignVOList(activitySignVOS.subList(0,6)); - } else { - comActActivityVO.setActivitySignVOList(activitySignVOS); + List<ActivitySignVO> activitySignVOS = JSONArray.parseArray(JSONArray.toJSONString( r.getData()),ActivitySignVO.class); + if (!ObjectUtils.isEmpty(activitySignVOS)) { + List<ActivitySignVO> collect = activitySignVOS.stream().filter(activitySignVO1 -> activitySignVO1.getIsVolunteer() == 1).collect(Collectors.toList()); + if (!ObjectUtils.isEmpty(collect)) { + int size = collect.size(); + if (size>=6) { + comActActivityVO.setActivityVolunteerList(collect.subList(0,6)); + } else { + comActActivityVO.setActivityVolunteerList(collect); + } + } + List<ActivitySignVO> collect1 = activitySignVOS.stream().filter(activitySignVO1 -> activitySignVO1.getIsVolunteer() == 0).collect(Collectors.toList()); + if (!ObjectUtils.isEmpty(collect1)) { + int size = collect1.size(); + if (size>=6) { + comActActivityVO.setActivitySignVOList(collect1.subList(0,6)); + } else { + comActActivityVO.setActivitySignVOList(collect1); + } + } } + } + comActActivityVO.setIntegral(0); return R.ok(comActActivityVO); } @@ -290,12 +339,20 @@ @PostMapping("putdynamic") public R putDynamic(@RequestBody ComActDynVO comActDynVO) { ComActDynDO comActDynDO = new ComActDynDO(); + Long id = comActDynVO.getId(); BeanUtils.copyProperties(comActDynVO, comActDynDO); + Integer isTopping = comActDynVO.getIsTopping(); + boolean b = isTopping.intValue() == 1; + if(b){ + ComActDynDO comActDynDO1 = comActDynService.getById(id); + Integer status = comActDynDO1.getStatus(); + if (status.intValue()==0) { + return R.fail("该动态还未发布"); + } + } boolean update = comActDynService.updateById(comActDynDO); if (update) { // 最多只能设置三条置顶状态,后边设置会取消先前设置的置顶 - 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)) { @@ -523,7 +580,7 @@ * @param comActVO 编辑内容 * @return 编辑结果 */ - @PutMapping("putCommunity") + @PostMapping("putCommunity") public R putCommunity(@RequestBody ComActVO comActVO) { return comActService.putCommunity(comActVO); } @@ -608,7 +665,22 @@ */ @PostMapping("batchhouse") public R batchHouse(@RequestBody BatchhouseVO batchhouseVO) { - return comMngStructHouseService.batchHouse(batchhouseVO); + R r = comMngStructHouseService.batchHouse(batchhouseVO); + if (R.isOk(r)) { + String areaCode = batchhouseVO.getAreaCode(); + String ruleDoor = batchhouseVO.getRuleDoor(); + String ruleConnector = batchhouseVO.getRuleConnector(); + String ruleFloor = batchhouseVO.getRuleFloor(); + ComMngStructAreaVO comMngStructAreaVO=new ComMngStructAreaVO(); + comMngStructAreaVO.setRoleDoor(ruleDoor); + comMngStructAreaVO.setRoleFloor(ruleFloor); + comMngStructAreaVO.setRoleConnector(ruleConnector); + comMngStructAreaVO.setAreaCode(areaCode); + comMngStructAreaVO.setCommunityId(null); + comMngStructAreaVO.setIsAccumulation(null); + comMngStructAreaService.putArea(comMngStructAreaVO); + } + return r; } /** @@ -633,7 +705,19 @@ R r=comMngStructAreaService.selectAreaByAreaCode(batchhouseVO.getAreaCode()); if (R.isOk(r)) { ComMngStructAreaDO comMngStructAreaDO = (ComMngStructAreaDO)r.getData(); - return comMngStructHouseService.addHouse(batchhouseVO,comMngStructAreaDO); + try { + R r1 = comMngStructHouseService.addHouse(batchhouseVO, comMngStructAreaDO); + return r1; + } catch (Exception e) { + if (e.getMessage().contains("unique_house_name")) { + return R.fail("房屋地址重复"); + }else { + log.error("添加同级地址失败【{}】",e.getMessage()); + return R.fail("添加房屋失败"); + } + } + + } return r; } @@ -880,4 +964,326 @@ return R.ok(); } + /** + * 社区详情 + * @param communityId 社区id + * @return 社区详情 + */ + @PostMapping("detailcommunity") + public R detailCommunity(@RequestParam("communityId") Long communityId){ + return comActService.detailCommunity(communityId); + } + + /** + * 小区详情 + * @param areaId 小区id + * @return 小区信息 + */ + @PostMapping("detailarea") + public R detailArea(@RequestParam("areaId")Long areaId){ + return comMngStructAreaService.detailArea(areaId); + } + + /** + * 分页查询社区 + * @param pageComActDTO 查询参数 + * @return 分页集合 + */ + @PostMapping("pagecommunity") + public R pageCommunity(@RequestBody PageComActDTO pageComActDTO){ + return comActService.pageCommunity(pageComActDTO); + } + + /** + * 志愿者详情 + * @param id 主键 + * @return 志愿者 + */ + @PostMapping("detailvolunteer") + public R detailVolunteer(@RequestParam("id") Long id){ + R r = comMngVolunteerMngService.detailVolunteer(id); + if (R.isOk(r)) { + ComMngVolunteerMngAppletsVO comMngVolunteerMngAppletsVO =(ComMngVolunteerMngAppletsVO) r.getData(); + String phone = comMngVolunteerMngAppletsVO.getPhone(); + List<ComActActivityVO> comActActivityVOS= comActActivityService.listActivityByPhone(phone); + comMngVolunteerMngAppletsVO.setComActActivityVOList(comActActivityVOS); + r.setData(comMngVolunteerMngAppletsVO); + } + return r; + } + + /** + * 查询平台所有的社区 + * @return 社区集合 按照创建顺序倒序排列 + */ + @PostMapping("listcommunityall") + public R listCommunityAll(){ + return comActService.listCommunityAll(); + } + + /** + * 社区管理后台数据看板 代办事件 + * @param communityId 社区id + * @param userId 登录用户信息 + * @return 代办事件列表 + */ + @PostMapping("indexdatacommunitybackstage") + public R indexDataCommunityBackstage(@RequestParam("communityId") Long communityId, @RequestParam("userId")Long userId){ + List<TodoEventsVO> todoEventsVOS=new ArrayList<>(); + List<TodoEventsVO> todoEventsVOS1=comActEasyPhotoService.selectNeedToDo(communityId,userId); + List<TodoEventsVO> todoEventsVOS2=comActMicroWishService.selectNeedToDo(communityId,userId); + List<TodoEventsVO> todoEventsVOS3=comMngVolunteerMngService.selectNeedToDo(communityId,userId); + + TodoEventsVO todoEventsVO=new TodoEventsVO(); + todoEventsVO.setType(1); + todoEventsVO.setNum(todoEventsVOS1.size()); + TodoEventsVO todoEventsVO1=new TodoEventsVO(); + todoEventsVO1.setType(2); + todoEventsVO1.setNum(todoEventsVOS2.size()); + TodoEventsVO todoEventsVO2=new TodoEventsVO(); + todoEventsVO2.setType(4); + todoEventsVO2.setNum(todoEventsVOS3.size()); + todoEventsVOS.add(todoEventsVO); + todoEventsVOS.add(todoEventsVO1); + todoEventsVOS.add(todoEventsVO2); + return R.ok(todoEventsVOS); + } + + /** + * 删除社区 + * @param communityId 社区id + * @return 删除结果 + */ + @PostMapping("delectcommunity") + public R delectCommunity(@RequestParam("communityId") Long communityId){ + return comActService.delectCommunity(communityId); + } + + /** + * 定时任务刷新社区动态置顶状态 + * @return 刷新结果 + */ + @PostMapping("timedtaskdynistopping") + public R timedTaskDynIstopping(){ + return comActDynService.timedTaskDynIstopping(); + } + /** + * 定时任务刷新社区动态发布状态 + * @return + */ + @PostMapping("timedtaskdynstatus") + public R timedTaskDynStatus(){ + return comActDynService.timedTaskDynStatus(); + } + + /** + * 定时任务查询所有要取消的社区活动 + * @return 社区活动集合 + */ + @PostMapping("timedtaskactactivity") + public R timedTaskActActivity(){ + return comActActivityService.timedTaskActActivity(); + } + + /** + * 定时任务刷新社区活动的各个状态 除取消外 + * @return 更新结果 + */ + @PostMapping("timedtaskactactivityall") + R timedTaskActActivityAll(){ + return comActActivityService.timedTaskActActivityAll(); + } + + /** + * 其他建筑详情 + * @param id 主键id + * @return 建筑内容 + */ + @PostMapping("detailotherbuild") + public R detailOtherbuild(@RequestParam("id")Long id){ + return comMngStructOtherBuildService.detailOtherbuild(id); + } + + /** + * 编辑其他建筑 + * @param comMngStructOtherBuildVO 编辑内容 + * @return 编辑结果 + */ + @PostMapping("putotherbuild") + public R putOtherbuild(@RequestBody ComMngStructOtherBuildVO comMngStructOtherBuildVO){ + return comMngStructOtherBuildService.putOtherbuild(comMngStructOtherBuildVO); + } + + /** + * 删除其他建筑 + * @param id 主键 + * @return 删除结果 + */ + @PostMapping("deleteotherbuild") + public R deleteOtherbuild(@RequestParam("id")Long id){ + return comMngStructOtherBuildService.deleteOtherbuild(id); + } + + /** + * 小程序分页查询随手拍 + * @param comActEasyPhotoVO 查询参数 + * @return 返回结果 + */ + @PostMapping("pageeasyphotoapplets") + public R pageEasyPhotoApplets(@RequestBody ComActEasyPhotoVO comActEasyPhotoVO){ + return comActEasyPhotoService.pageEasyPhotoApplets(comActEasyPhotoVO); + } + + /** + * 随手拍评论分页查询 + * @param pageComActEasyPhotoCommentDTO 查询参数 + * @return 查询结果 + */ + @PostMapping("pagecomacteasyphotocomment") + public R pageComActEasyPhotoComment(@RequestBody PageComActEasyPhotoCommentDTO pageComActEasyPhotoCommentDTO){ + return comActEasyPhotoService.pageComActEasyPhotoComment(pageComActEasyPhotoCommentDTO); + } + + /** + * 评论点赞/取消点赞 + * @param comActEasyPhotoCommentUserDTO 操作 + * @return 操作结果 + */ + @PostMapping("commentsign") + public R commentSign(@RequestBody ComActEasyPhotoCommentUserDTO comActEasyPhotoCommentUserDTO){ + return comActEasyPhotoService.commentSign(comActEasyPhotoCommentUserDTO); + } + + /** + * 随手拍--评论--新增评论 + * @param comActEasyPhotoCommentDTO 新增内容 + * @return 新增结果 + */ + @PostMapping("addcomacteasyphotocomment") + public R addComActEasyPhotoComment(@RequestBody ComActEasyPhotoCommentDTO comActEasyPhotoCommentDTO){ + return comActEasyPhotoService.addComActEasyPhotoComment(comActEasyPhotoCommentDTO); + } + + /** + * 查询城市下属所有地区列表 + * @param cityAdcode 城市地址编码 + * @return 地区列表 + */ + @PostMapping("listareadistrict") + public R listAreaDistrict(@RequestParam("cityAdcode") Long cityAdcode){ + return comMngStructAreaDistrictService.listAreaDistrict(cityAdcode); + } + + /** + * 首页图表数据汇总 + * @param communityId 社区id + * @return 图表数据 IndexDataVO + */ + @PostMapping("indexdatacommunitybackstageechart") + public R indexDataCommunityBackstageEchart(@RequestParam("communityId")Long communityId){ + return comActActivityService.indexDataCommunityBackstageEchart(communityId); + } + + /** + * 选择导入的小区 + * @param param 小区名字 模糊查询 + * @param communityId 社区id + * @return 小区集合 ComMngStructAreaVO + */ + @PostMapping("listareas") + public R listAreas(@RequestParam("param")String param, @RequestParam("communityId")Long communityId){ + return comMngStructAreaService.listAreas(param,communityId); + } + + /** + * 检查小区是否已经批量设置过房屋并且返回小区房屋门号规则 + * @param id 小区id + * @return ComMngStructAreaVO + */ + @PostMapping("checkAreaHouse") + public R checkAreaHouse(@RequestParam("id")Long id){ + return comMngStructAreaService.checkAreaHouse(id); + } + /** + * 新增留言 + * @param comActMessageVO 新增留言信息 + * @return 发布结果 + */ + @PostMapping("addmessage") + public R addMessage(@RequestBody ComActMessageVO comActMessageVO){ + // 微信内容审核 + return comActMessageService.addMessage(comActMessageVO); + } + /** + * 我发的留言 + * @return 结果集合 + */ + @PostMapping("pagemymessage") + public R pageMyMessage (@RequestBody ComActMessageVO comActMessageVO){ + return comActMessageService.pageMyMessageApplets(comActMessageVO); + } + /** + * 发给我的留言 + * @return 结果集合 + */ + @PostMapping("pagesendtomemessage") + public R pageSendToMessage (@RequestBody ComActMessageVO comActMessageVO){ + return comActMessageService.pageSendToMessageApplets(comActMessageVO); + } + /** + * 根据id查询留言集合 + * @return 结果集合 + */ + @PostMapping("pagemessagebyuser") + public R pageMessageByUser (@RequestBody ComActMessageVO comActMessageVO){ + return comActMessageService.pageMessageByUserApplets(comActMessageVO); + } + /** + * 社区留言 + * @return 结果集合 + */ + @PostMapping("pagemycommunitymessage") + public R pageMyCommunityMessage (@RequestBody ComActMessageVO comActMessageVO){ + return comActMessageService.pageMyCommunityMessageApplets(comActMessageVO); + } + /** + * 新增留言回复 + * @param comActMessageVO 新增留言回复信息 + * @return 发布结果 + */ + @PostMapping("addmessageback") + public R addMessageBack(@RequestBody ComActMessageBackVO comActMessageBackVO){ + // 微信内容审核 + return comActMessageService.addMessageBack(comActMessageBackVO); + } + @PostMapping("deletemessage") + public R deleteMessage(@RequestBody ComActMessageVO comActMessageVO) { + return comActMessageService.deleteMessage(comActMessageVO); + } + + @PostMapping("resetmessagepublic") + public R resetMessagePublic(@RequestBody ResetComActMessageVO resetComActMessageVO) { + return comActMessageService.resetMessagePublic(resetComActMessageVO); + } + + /** + * 留言详情 + * + * @param id 主键 + * @return 详情内容 + */ + @PostMapping("detailmessage") + public R detailMessage(@RequestParam("id") Long id) { + return comActMessageService.detailMessage(id); + } + + /** + * 导出房屋信息 + * @param areaId + * @return + */ + @PostMapping("house/export") + public R houseExport(@RequestParam("areaId") Long areaId) { + return comMngStructHouseService.houseExport(areaId); + } } -- Gitblit v1.7.1