.gitignore
@@ -2,3 +2,5 @@ .idea *.iml *.log springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommunityApi.java
@@ -1,58 +1,39 @@ package com.panzhihua.applets.api; import java.util.Date; import java.util.List; import javax.annotation.Resource; import javax.validation.Valid; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSONObject; import com.panzhihua.applets.weixin.CheckService; import com.panzhihua.common.constants.Constants; import com.panzhihua.common.controller.BaseController; import com.panzhihua.common.model.dtos.common.PageComMngVolunteerOrgTeamDto; import com.panzhihua.common.model.dtos.common.PageComMngVolunteerServiceTypeDto; import com.panzhihua.common.model.dtos.common.PageComMngVolunteerSkillDto; import com.panzhihua.common.model.dtos.community.ActivityInviteDTO; import com.panzhihua.common.model.dtos.community.PageActivityInviteDTO; import com.panzhihua.common.model.dtos.community.PageComStreetDTO; import com.panzhihua.common.model.dtos.community.*; import com.panzhihua.common.model.dtos.property.CommonPage; import com.panzhihua.common.model.vos.LoginUserInfoVO; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.common.ComMngVolunteerOrgTeamVo; import com.panzhihua.common.model.vos.common.ComMngVolunteerServiceTypeVo; import com.panzhihua.common.model.vos.common.ComMngVolunteerSkillVo; import com.panzhihua.common.model.vos.community.*; import com.panzhihua.common.model.vos.neighbor.ActivityAnalysisVO; import com.panzhihua.common.model.vos.neighbor.ActivityAnalysisVO; import com.panzhihua.common.model.vos.neighbor.ComActNeighborCircleAnalysisVO; import com.panzhihua.common.service.community.CommunityWestService; import io.swagger.annotations.*; import org.springframework.util.ObjectUtils; import org.springframework.validation.annotation.Validated; 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.JSONObject; import com.panzhihua.common.controller.BaseController; import com.panzhihua.common.model.dtos.community.ComMngCarAppletDTO; import com.panzhihua.common.model.dtos.community.PageComMngVillageDTO; import com.panzhihua.common.model.dtos.community.PageVolunteerDTO; import com.panzhihua.common.model.vos.LoginUserInfoVO; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.user.SysUserNoticeVO; import com.panzhihua.common.service.community.CommunityService; import com.panzhihua.common.service.community.CommunityWestService; import com.panzhihua.common.service.partybuilding.PartyBuildingService; import com.panzhihua.common.service.user.UserService; import com.panzhihua.common.validated.AddGroup; import com.panzhihua.common.validated.PageGroup; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import io.swagger.annotations.*; import lombok.extern.slf4j.Slf4j; import org.springframework.util.ObjectUtils; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.validation.Valid; import java.util.Date; import java.util.List; import static java.util.Objects.isNull; import static org.apache.commons.lang3.ObjectUtils.isEmpty; @@ -76,12 +57,15 @@ private UserService userService; @Resource private PartyBuildingService partyBuildingService; @Resource private CheckService checkService; @ApiOperation(value = "分页查询小区", response = ComMngStructAreaVO.class) @PostMapping("pagearea") public R pageArea(@RequestBody ComMngStructAreaVO comMngStructAreaVO) { return communityService.pageArea(comMngStructAreaVO); } @ApiOperation(value = "新分页查询小区", response = ComMngVillageVO.class) @PostMapping("pagevillage") public R pageVillage(@RequestBody PageComMngVillageDTO pageComMngVillageDTO) { @@ -177,6 +161,24 @@ public R activityEvaluate(@RequestBody ComActActEvaluateVO comActActEvaluateVO) { LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); comActActEvaluateVO.setUserId(loginUserInfo.getUserId()); String openid = this.getLoginUserInfo().getOpenid(); String appId = this.getAppId(); // 微信内容审核 String evaluateContent = comActActEvaluateVO.getEvaluateContent(); if (StrUtil.isNotBlank(evaluateContent)) { String result = checkService.checkMessageBy(evaluateContent, openid, appId); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } //微信图片审核 String photo = comActActEvaluateVO.getPhoto(); if (StrUtil.isNotBlank(photo)) { if (!checkService.checkImageBy(photo, appId)) { return R.fail(501, "上传图片存在违规信息"); } } return communityService.activityEvaluate(comActActEvaluateVO); } @@ -384,6 +386,7 @@ required = true) @RequestParam(value = "provinceAdcode") Integer provinceAdcode) { return communityService.getCityTreeByProvinceCode(provinceAdcode, null); } @ApiOperation(value = "社区详情", response = ComActVO.class) @GetMapping("community") public R detailCommunity() { @@ -422,6 +425,7 @@ comActActivityVO.setHasPrize(0); return communityService.addActivity(comActActivityVO); } @ApiOperation(value = "单位活动统计",response = ActivityAnalysisVO.class) @GetMapping("activity/analysis") public R activityUnitAnalysis(@RequestParam(value = "year",required = false) Integer year, springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/DiscussApi.java
@@ -1,35 +1,10 @@ package com.panzhihua.applets.api; import java.util.Date; import java.util.List; import java.util.Objects; import javax.annotation.Resource; import javax.validation.Valid; import javax.validation.constraints.NotEmpty; import com.panzhihua.common.model.dtos.community.ComActDiscussVoteOptionDTO; import org.springframework.util.ObjectUtils; import org.springframework.validation.annotation.Validated; 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 cn.hutool.core.util.StrUtil; import com.panzhihua.applets.weixin.CheckService; import com.panzhihua.common.constants.Constants; import com.panzhihua.common.controller.BaseController; import com.panzhihua.common.model.dtos.community.ComActDiscussCommentDTO; import com.panzhihua.common.model.dtos.community.ComActDiscussCommentUserDTO; import com.panzhihua.common.model.dtos.community.ComActDiscussDTO; import com.panzhihua.common.model.dtos.community.ComActDiscussOptionDTO; import com.panzhihua.common.model.dtos.community.ComActDiscussOptionUserDTO; import com.panzhihua.common.model.dtos.community.ComActDiscussUserDTO; import com.panzhihua.common.model.dtos.community.DiscussVoteOptionDTO; import com.panzhihua.common.model.dtos.community.PageComActDiscussCommentDTO; import com.panzhihua.common.model.dtos.community.PageComActDiscussDTO; import com.panzhihua.common.model.dtos.community.*; import com.panzhihua.common.model.dtos.community.integral.admin.AddComActIntegralUserDTO; import com.panzhihua.common.model.vos.LoginUserInfoVO; import com.panzhihua.common.model.vos.R; @@ -39,12 +14,20 @@ import com.panzhihua.common.utlis.DateUtils; import com.panzhihua.common.validated.AddGroup; import com.panzhihua.common.validated.PutGroup; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import lombok.extern.slf4j.Slf4j; import org.springframework.util.ObjectUtils; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.validation.Valid; import java.util.Date; import java.util.List; import java.util.Objects; /** * @program: springcloud_k8s_panzhihuazhihuishequ @@ -65,11 +48,25 @@ @ApiOperation(value = "一起议-新增") @PostMapping("discuss") public R addDiscuss(@RequestBody @Validated(AddGroup.class) ComActDiscussDTO comActDiscussDTO) { String openid = this.getLoginUserInfo().getOpenid(); String appId = this.getAppId(); // 微信内容审核 String discussSubject = comActDiscussDTO.getDiscussSubject(); if (!checkService.checkMessage(discussSubject)) { return R.fail("内容违规"); if (StrUtil.isNotBlank(discussSubject)) { String result = checkService.checkMessageBy(discussSubject, openid, appId); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } //微信图片审核 String photoPah = comActDiscussDTO.getPhotoPah(); if (StrUtil.isNotBlank(photoPah)) { if (!checkService.checkImageBy(photoPah, appId)) { return R.fail(501, "上传图片存在违规信息"); } } Integer type = comActDiscussDTO.getType(); String voteTitle = comActDiscussDTO.getVoteTitle(); List<ComActDiscussOptionDTO> discussOptions = comActDiscussDTO.getDiscussOptions(); @@ -131,6 +128,10 @@ Long discussId = comActDiscussCommentDTO.getDiscussId(); if (null == discussId || 0 == discussId) { return R.fail("一起议主键不能为空"); } String result = checkService.checkMessageBy(comment, this.getLoginUserInfo().getOpenid(), this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } comActDiscussCommentDTO.setUserId(this.getUserId()); // 议事投票计算积分 @@ -195,6 +196,10 @@ if (null == id || 0 == id) { return R.fail("评论主键不能为空"); } String result = checkService.checkMessageBy(comment, this.getLoginUserInfo().getOpenid(), this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } comActDiscussCommentDTO.setUserId(this.getUserId()); return communityService.addDiscussCommentBack(comActDiscussCommentDTO); } springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/HouseApi.java
@@ -2,6 +2,8 @@ import javax.annotation.Resource; import cn.hutool.core.util.StrUtil; import com.panzhihua.common.constants.Constants; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; @@ -43,8 +45,11 @@ public R addHouse(@RequestBody @Validated(AddGroup.class) ComOpsHouseDTO comOpsHouseDTO) { // 微信内容审核 String introduction = comOpsHouseDTO.getIntroduction(); if (!checkService.checkMessage(introduction)) { return R.fail("内容违规"); if (StrUtil.isNotBlank(introduction)) { String result = checkService.checkMessageBy(introduction, this.getLoginUserInfo().getOpenid(),this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); Long userId = loginUserInfo.getUserId(); springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/IndexApi.java
@@ -1,23 +1,14 @@ package com.panzhihua.applets.api; import javax.annotation.Resource; import com.panzhihua.common.model.dtos.common.EditComActEasyPhotoHandlerDto; import com.panzhihua.common.model.dtos.common.EvaluateEasyDto; import com.panzhihua.common.model.dtos.common.PageComActEasyPhotoHandlerDto; import com.panzhihua.common.model.vos.common.ComActEasyPhotoHandlerVo; import com.panzhihua.common.model.vos.community.easyPhoto.BannerVO; import com.panzhihua.common.service.community.ComActEasyPhotoEvaluateFeign; import com.panzhihua.common.service.community.ComActEasyPhotoHandlerFeign; import org.springframework.util.ObjectUtils; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import cn.hutool.core.util.StrUtil; import com.panzhihua.applets.weixin.CheckService; import com.panzhihua.common.constants.Constants; import com.panzhihua.common.controller.BaseController; import com.panzhihua.common.model.dtos.CommonDTO; import com.panzhihua.common.model.dtos.PageDTO; import com.panzhihua.common.model.dtos.common.EditComActEasyPhotoHandlerDto; import com.panzhihua.common.model.dtos.common.EvaluateEasyDto; import com.panzhihua.common.model.dtos.common.PageComActEasyPhotoHandlerDto; import com.panzhihua.common.model.dtos.community.ComActEasyPhotoCommentDTO; import com.panzhihua.common.model.dtos.community.ComActEasyPhotoCommentUserDTO; import com.panzhihua.common.model.dtos.community.NoticeReadDTO; @@ -25,19 +16,26 @@ import com.panzhihua.common.model.vos.LoginUserInfoVO; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.advertisement.ComOpsAdvVO; import com.panzhihua.common.model.vos.common.ComActEasyPhotoHandlerVo; import com.panzhihua.common.model.vos.community.*; import com.panzhihua.common.model.vos.community.easyPhoto.BannerVO; import com.panzhihua.common.model.vos.community.easyPhoto.ComActEasyPhotoClassifyVO; import com.panzhihua.common.model.vos.user.NoticeUnReadVO; import com.panzhihua.common.model.vos.user.SysUserAgreementVO; import com.panzhihua.common.model.vos.user.SysUserNoticeVO; import com.panzhihua.common.service.community.ComActEasyPhotoEvaluateFeign; import com.panzhihua.common.service.community.CommunityService; import com.panzhihua.common.service.user.UserService; import com.panzhihua.common.validated.AddGroup; import com.panzhihua.common.validated.PageGroup; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiOperation; import org.springframework.util.ObjectUtils; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; /** * @program: springcloud_k8s_panzhihuazhihuishequ @@ -74,9 +72,23 @@ @PostMapping("easyphoto") public R addEasyPhoto(@RequestBody @Validated(AddGroup.class) ComActEasyPhotoVO comActEasyPhotoVO) { // 微信内容审核 String msg = comActEasyPhotoVO.getDetail(); if (!checkService.checkMessage(msg)) { return R.fail("内容违规"); String openid = this.getLoginUserInfo().getOpenid(); String appId = this.getAppId(); // 微信内容审核 String detail = comActEasyPhotoVO.getDetail(); if (StrUtil.isNotBlank(detail)) { String result = checkService.checkMessageBy(detail, openid, appId); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } //微信图片审核 String photoPathList = comActEasyPhotoVO.getPhotoPathList(); if (StrUtil.isNotBlank(photoPathList)) { if (!checkService.checkImageBy(photoPathList, appId)) { return R.fail(501, "上传图片存在违规信息"); } } LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); Long communityId = loginUserInfo.getCommunityId(); @@ -104,6 +116,7 @@ comActEasyPhotoHandler.setUserId(this.getUserId()); return this.communityService.queryEasyPhotoHandler(comActEasyPhotoHandler); } /** * description edit 编辑数据 * @@ -163,6 +176,17 @@ @ApiOperation(value = "随手拍--评论--新增评论") @PostMapping("comacteasyphotocomment") public R addComActEasyPhotoComment(@RequestBody ComActEasyPhotoCommentDTO comActEasyPhotoCommentDTO) { // 微信内容审核 String openid = this.getLoginUserInfo().getOpenid(); String appId = this.getAppId(); // 微信内容审核 String comment = comActEasyPhotoCommentDTO.getComment(); if (StrUtil.isNotBlank(comment)) { String result = checkService.checkMessageBy(comment, openid, appId); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } comActEasyPhotoCommentDTO.setUserId(this.getUserId()); return communityService.addComActEasyPhotoComment(comActEasyPhotoCommentDTO); } @@ -208,8 +232,11 @@ public R addMicroWish(@RequestBody @Validated(AddGroup.class) ComActMicroWishVO comActMicroWishVO) { // 微信内容审核 String msg = comActMicroWishVO.getDetail(); if (!checkService.checkMessage(msg)) { return R.fail("内容违规"); if (StrUtil.isNotBlank(msg)) { String result = checkService.checkMessageBy(msg, this.getLoginUserInfo().getOpenid(),this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); Long communityId = loginUserInfo.getCommunityId(); @@ -293,8 +320,11 @@ public R addMessage(@RequestBody @Validated(AddGroup.class) ComActMessageVO comActMessageVO) { // 微信内容审核 String msg = comActMessageVO.getMsgContent(); if (!checkService.checkMessage(msg)) { return R.fail("内容违规"); if (StrUtil.isNotBlank(msg)) { String result = checkService.checkMessageBy(msg, this.getLoginUserInfo().getOpenid(),this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); Long communityId = loginUserInfo.getCommunityId(); @@ -320,8 +350,11 @@ public R addMessageBack(@RequestBody @Validated(AddGroup.class) ComActMessageBackVO comActMessageBackVO) { // 微信内容审核 String msg = comActMessageBackVO.getMsgContent(); if (!checkService.checkMessage(msg)) { return R.fail("内容违规"); if (StrUtil.isNotBlank(msg)) { String result = checkService.checkMessageBy(msg, this.getLoginUserInfo().getOpenid(),this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); Long communityId = loginUserInfo.getCommunityId(); springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/NeighborApi.java
@@ -1,25 +1,22 @@ package com.panzhihua.applets.api; import cn.hutool.core.util.StrUtil; import com.panzhihua.applets.weixin.CheckService; import com.panzhihua.common.constants.Constants; import com.panzhihua.common.constants.NeighborCircleConstants; import javax.annotation.Resource; import com.panzhihua.common.model.vos.neighbor.*; import io.swagger.annotations.ApiModelProperty; import org.springframework.web.bind.annotation.*; import com.panzhihua.common.controller.BaseController; import com.panzhihua.common.model.dtos.neighbor.*; import com.panzhihua.common.model.vos.LoginUserInfoVO; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.neighbor.*; import com.panzhihua.common.service.community.CommunityService; import com.panzhihua.common.utlis.StringUtils; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.*; import static java.util.Objects.isNull; import javax.annotation.Resource; /** * @auther lyq @@ -69,6 +66,19 @@ if(userId == null){ return R.fail("请重新登录"); } String releaseContent = addNeighborCircleAppDTO.getReleaseContent(); if (StrUtil.isNotBlank(releaseContent)) { String result = checkService.checkMessageBy(releaseContent, this.getLoginUserInfo().getOpenid(), this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } String releaseImages = addNeighborCircleAppDTO.getReleaseImages(); if (StrUtil.isNotBlank(releaseImages)) { if (checkService.checkImageBy(releaseImages, this.getAppId())) { return R.fail(501, "上传图片存在违规信息"); } } addNeighborCircleAppDTO.setUserId(userId); if (StringUtils.isNotEmpty(loginUser.getPhone())) { addNeighborCircleAppDTO.setPhone(this.getLoginUserInfo().getPhone()); @@ -78,6 +88,14 @@ } //查询社区自动审核是否开着 if (this.getAppId().equals("wx118de8a734d269f0")) { //花城直接通过 addNeighborCircleAppDTO.setIsExamine(AddComActNeighborCircleAppDTO.isExamine.no); addNeighborCircleAppDTO.setWxExamineResult(AddComActNeighborCircleAppDTO.isExamine.yes); } else { //西区 String key = NeighborCircleConstants.NEIGHBOR_CIRCLE_AUTO_EXAMINE; R isOk = communityService.getSysConfValue(key + communityId,communityId); if(R.isOk(isOk)){ @@ -86,7 +104,7 @@ if(value.equals("1")){ addNeighborCircleAppDTO.setIsExamine(AddComActNeighborCircleAppDTO.isExamine.no); String msg = addNeighborCircleAppDTO.getReleaseContent(); if (checkService.checkMessage(msg)) { if (StrUtil.isEmpty(checkService.checkMessageBy(msg, this.getLoginUserInfo().getOpenid(), this.getAppId()))) { addNeighborCircleAppDTO.setWxExamineResult(AddComActNeighborCircleAppDTO.isExamine.yes); }else{ addNeighborCircleAppDTO.setWxExamineResult(AddComActNeighborCircleAppDTO.isExamine.no); @@ -100,6 +118,7 @@ } }else{ addNeighborCircleAppDTO.setIsExamine(AddComActNeighborCircleAppDTO.isExamine.yes); } } return communityService.addNeighborByApp(addNeighborCircleAppDTO); @@ -164,6 +183,13 @@ if (userId == null) { return R.fail("请先登录"); } String content = commentAppDTO.getContent(); if (StrUtil.isNotBlank(content)) { String result = checkService.checkMessageBy(content, this.getLoginUserInfo().getOpenid(), this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } commentAppDTO.setUserId(userId); return communityService.neighborCommentByApp(commentAppDTO); } @@ -174,6 +200,13 @@ Long userId = this.getLoginUserInfo().getUserId(); if (userId == null) { return R.fail("请先登录"); } String content = replyAppDTO.getContent(); if (StrUtil.isNotBlank(content)) { String result = checkService.checkMessageBy(content, this.getLoginUserInfo().getOpenid(), this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } replyAppDTO.setUserId(userId); return communityService.neighborReplyByApp(replyAppDTO); @@ -238,8 +271,7 @@ /** * 分页查询邻里圈列表 * * @param neighborCircleAppDTO * 请求参数 * @param neighborCircleAppDTO 请求参数 * @return 邻里圈列表 */ @ApiOperation(value = "新版接单问题",response =ComActNeighborCircleAppVO.class ) @@ -252,6 +284,7 @@ /** * 修改数据 * * @param editNeighborCircleAdminVO * @return */ @@ -269,6 +302,7 @@ /** * 求助我的问题数量统计 * * @param type * @param phone * @return springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/NeighborWestApi.java
@@ -1,13 +1,11 @@ package com.panzhihua.applets.api; import cn.hutool.core.util.StrUtil; import com.panzhihua.applets.weixin.CheckService; import com.panzhihua.common.constants.Constants; import com.panzhihua.common.constants.NeighborCircleConstants; import javax.annotation.Resource; import com.panzhihua.common.model.dtos.neighbor.*; import org.springframework.web.bind.annotation.*; import com.panzhihua.common.controller.BaseController; import com.panzhihua.common.model.dtos.neighbor.*; import com.panzhihua.common.model.vos.LoginUserInfoVO; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.neighbor.ComActNeighborCircleAppVO; @@ -16,10 +14,12 @@ import com.panzhihua.common.model.vos.neighbor.ComActNeighborCommentReplyAppVO; import com.panzhihua.common.service.community.CommunityWestService; import com.panzhihua.common.utlis.StringUtils; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; /** * @auther lyq @@ -54,10 +54,30 @@ LoginUserInfoVO loginUser = this.getLoginUserInfo(); Long userId = loginUser.getUserId(); Long communityId = loginUser.getCommunityId(); if(userId == null){ return R.fail("请重新登录"); } addNeighborCircleAppDTO.setUserId(userId); String openid = this.getLoginUserInfo().getOpenid(); String appId = this.getAppId(); // 微信内容审核 String releaseContent = addNeighborCircleAppDTO.getReleaseContent(); if (StrUtil.isNotBlank(releaseContent)) { String result = checkService.checkMessageBy(releaseContent, openid, appId); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } //微信图片审核 String releaseImages = addNeighborCircleAppDTO.getReleaseImages(); if (StrUtil.isNotBlank(releaseImages)) { if (!checkService.checkImageBy(releaseImages, appId)) { return R.fail(501, "上传图片存在违规信息"); } } if (StringUtils.isNotEmpty(loginUser.getPhone())) { addNeighborCircleAppDTO.setPhone(this.getLoginUserInfo().getPhone()); } @@ -65,6 +85,11 @@ addNeighborCircleAppDTO.setCommunityId(communityId); } if(this.getAppId().equals("wx118de8a734d269f0")){ //花城直接通过 addNeighborCircleAppDTO.setIsExamine(AddComActNeighborCircleAppDTO.isExamine.no); addNeighborCircleAppDTO.setWxExamineResult(AddComActNeighborCircleAppDTO.isExamine.yes); }else { //查询社区自动审核是否开着 String key = NeighborCircleConstants.NEIGHBOR_CIRCLE_AUTO_EXAMINE; R isOk = communityWestService.getSysConfValue(key + communityId,communityId); @@ -74,7 +99,7 @@ if(value.equals("1")){ addNeighborCircleAppDTO.setIsExamine(AddComActNeighborCircleAppDTO.isExamine.no); String msg = addNeighborCircleAppDTO.getReleaseContent(); if (checkService.checkMessage(msg)) { if (StrUtil.isEmpty(checkService.checkMessageBy(msg,this.getLoginUserInfo().getOpenid(),this.getAppId()))) { addNeighborCircleAppDTO.setWxExamineResult(AddComActNeighborCircleAppDTO.isExamine.yes); }else{ addNeighborCircleAppDTO.setWxExamineResult(AddComActNeighborCircleAppDTO.isExamine.no); @@ -89,6 +114,8 @@ }else{ addNeighborCircleAppDTO.setIsExamine(AddComActNeighborCircleAppDTO.isExamine.yes); } } return communityWestService.addNeighborByApp(addNeighborCircleAppDTO); } @@ -153,6 +180,16 @@ return R.fail("请先登录"); } commentAppDTO.setUserId(userId); String openid = this.getLoginUserInfo().getOpenid(); String appId = this.getAppId(); // 微信内容审核 String content = commentAppDTO.getContent(); if (StrUtil.isNotBlank(content)) { String result = checkService.checkMessageBy(content, openid, appId); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } return communityWestService.neighborCommentByApp(commentAppDTO); } springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/PartyBuildingApi.java
@@ -4,6 +4,8 @@ import javax.annotation.Resource; import cn.hutool.core.util.StrUtil; import com.panzhihua.common.constants.Constants; import com.panzhihua.common.interfaces.OperLog; import com.panzhihua.common.model.dtos.common.PageComPbCheckUnitDto; import com.panzhihua.common.model.dtos.community.PageMemberForInviteDTO; @@ -207,8 +209,11 @@ public R addActivityinfo(@RequestBody @Validated(AddGroup.class) ComPbActivityDTO comPbActivityDTO) { // 微信内容审核 String msg = comPbActivityDTO.getRichText(); if (!checkService.checkMessage(msg)) { return R.fail("内容违规"); if (StrUtil.isNotBlank(msg)) { String result = checkService.checkMessageBy(msg, this.getLoginUserInfo().getOpenid(),this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); Long userId = loginUserInfo.getUserId(); springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/PartyBuildingWestApi.java
@@ -4,6 +4,8 @@ import javax.annotation.Resource; import cn.hutool.core.util.StrUtil; import com.panzhihua.common.constants.Constants; import com.panzhihua.common.interfaces.OperLog; import com.panzhihua.common.model.dtos.common.PageComPbCheckUnitDto; import com.panzhihua.common.model.vos.common.ComPbCheckUnitVo; @@ -199,8 +201,11 @@ public R addActivityinfo(@RequestBody @Validated(AddGroup.class) ComPbActivityDTO comPbActivityDTO) { // 微信内容审核 String msg = comPbActivityDTO.getRichText(); if (!checkService.checkMessage(msg)) { return R.fail("内容违规"); if (StrUtil.isNotBlank(msg)) { String result = checkService.checkMessageBy(msg, this.getLoginUserInfo().getOpenid(),this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); Long userId = loginUserInfo.getUserId(); springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java
@@ -9,7 +9,9 @@ import javax.annotation.Resource; import javax.validation.Valid; import cn.hutool.core.util.StrUtil; import com.panzhihua.applets.umf.UmfPayUtil; import com.panzhihua.common.constants.Constants; import com.panzhihua.common.constants.HttpStatus; import com.panzhihua.common.model.dtos.community.social.PageProjectDTO; import com.panzhihua.common.model.vos.community.rentHouse.WxPayOrderVO; @@ -397,8 +399,11 @@ public R addFeedback(@RequestBody @Validated(AddGroup.class) SysUserFeedbackDTO sysUserFeedbackDTO) { // 微信内容审核 String msg = sysUserFeedbackDTO.getContent(); if (!checkService.checkMessage(msg)) { return R.fail("内容违规"); if (StrUtil.isNotBlank(msg)) { String result = checkService.checkMessageBy(msg, this.getLoginUserInfo().getOpenid(),this.getAppId()); if (StrUtil.isNotBlank(result)) { return R.fail(501, "填写内容存在 " + result + " 违规信息"); } } LoginUserInfoVO loginUserInfo = this.getLoginUserInfo(); Long userId = loginUserInfo.getUserId(); springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/weixin/CheckService.java
@@ -1,14 +1,21 @@ package com.panzhihua.applets.weixin; import javax.annotation.Resource; import org.springframework.stereotype.Service; import com.panzhihua.applets.config.WxMaConfiguration; import cn.binarywang.wx.miniapp.api.WxMaSecCheckService; import cn.binarywang.wx.miniapp.api.WxMaService; import cn.binarywang.wx.miniapp.bean.security.WxMaMsgSecCheckCheckRequest; import cn.binarywang.wx.miniapp.bean.security.WxMaMsgSecCheckCheckResponse; import cn.binarywang.wx.miniapp.config.WxMaConfig; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.StrUtil; import com.panzhihua.applets.config.WxMaConfiguration; import lombok.extern.slf4j.Slf4j; import me.chanjar.weixin.common.error.WxErrorException; import org.apache.commons.lang.StringUtils; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.ArrayList; import java.util.List; /** * @program: springcloud_k8s_panzhihuazhihuishequ @@ -23,14 +30,102 @@ private WxMaConfiguration wxMaConfiguration; public boolean checkMessage(String msg) { WxMaSecCheckService wxMaSecCheckService = wxMaConfiguration.getMaService("").getSecCheckService(); WxMaService maService = wxMaConfiguration.getMaService(""); WxMaConfig wxMaConfig = maService.getWxMaConfig(); WxMaMsgSecCheckCheckRequest wxMaMsgSecCheckCheckRequest = WxMaMsgSecCheckCheckRequest.builder().version("2").openid(wxMaConfig.getAppid()).scene(2).content(msg).build(); WxMaSecCheckService wxMaSecCheckService = maService.getSecCheckService(); try { boolean b = wxMaSecCheckService.checkMessage(msg); return b; WxMaMsgSecCheckCheckResponse wxMaMsgSecCheckCheckResponse = wxMaSecCheckService.checkMessage(wxMaMsgSecCheckCheckRequest); wxMaMsgSecCheckCheckResponse.getResult(); return true; } catch (WxErrorException e) { log.error("微信审核文字内容出错【{}】", e.getMessage()); e.printStackTrace(); } return false; } public String checkMessageBy(String msg, String openId, String appId) { WxMaMsgSecCheckCheckRequest wxMaMsgSecCheckCheckRequest = WxMaMsgSecCheckCheckRequest.builder().version("2").openid(openId).scene(2).content(msg).build(); WxMaSecCheckService wxMaSecCheckService = wxMaConfiguration.getMaService(appId).getSecCheckService(); try { WxMaMsgSecCheckCheckResponse result = wxMaSecCheckService.checkMessage(wxMaMsgSecCheckCheckRequest); return this.handleResult(result); } catch (WxErrorException e) { log.error("微信审核文字内容出错【{}】", e.getMessage()); e.printStackTrace(); } return null; } public boolean checkImageBy(String url, String appId) { String[] imageUrlArr = url.split(","); for (String imageUrl : imageUrlArr) { WxMaSecCheckService wxMaSecCheckService = wxMaConfiguration.getMaService(appId).getSecCheckService(); try { return wxMaSecCheckService.checkImage(imageUrl); } catch (WxErrorException e) { log.error("微信审核图片内容出错【{}】", e.getMessage()); e.printStackTrace(); } } return true; } /** * 处理微信返回的违规结果 * * @param result * @return */ private String handleResult(WxMaMsgSecCheckCheckResponse result) { List<WxMaMsgSecCheckCheckResponse.DetailBean> detailBeanList = result.getDetail(); if (null != detailBeanList && detailBeanList.size() > 0) { List<String> resultMsgs = new ArrayList<>(); for (WxMaMsgSecCheckCheckResponse.DetailBean detailBean : detailBeanList) { if (0 == detailBean.getErrcode()) { String label = detailBean.getLabel(); if (StrUtil.isNotBlank(label)) { switch (label) { case "100": continue; case "10001": resultMsgs.add("广告"); continue; case "20001": resultMsgs.add("时政"); continue; case "20002": resultMsgs.add("色情"); continue; case "20003": resultMsgs.add("辱骂"); continue; case "20006": resultMsgs.add("违法犯罪"); continue; case "20008": resultMsgs.add("欺诈"); continue; case "20012": resultMsgs.add("低俗"); continue; case "20013": resultMsgs.add("版权"); continue; case "21000": resultMsgs.add("其他"); } } } } if (CollUtil.isNotEmpty(resultMsgs)) { return StringUtils.join(resultMsgs, ","); } } return null; } } springcloud_k8s_panzhihuazhihuishequ/common/.gitignore
New file @@ -0,0 +1,33 @@ HELP.md target/ !.mvn/wrapper/maven-wrapper.jar !**/src/main/**/target/ !**/src/test/**/target/ ### STS ### .apt_generated .classpath .factorypath .project .settings .springBeans .sts4-cache ### IntelliJ IDEA ### .idea *.iws *.iml *.ipr ### NetBeans ### /nbproject/private/ /nbbuild/ /dist/ /nbdist/ /.nb-gradle/ build/ !**/src/main/**/build/ !**/src/test/**/build/ ### VS Code ### .vscode/ springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/community/warehouse/ComActWarehouseOperationVO.java
@@ -1,12 +1,12 @@ package com.panzhihua.common.model.vos.community.warehouse; import java.util.Date; import com.fasterxml.jackson.annotation.JsonFormat; import com.panzhihua.common.utlis.StringUtils; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.util.Date; /** * @title: ComActWarehouseOperationVO @@ -21,10 +21,10 @@ public class ComActWarehouseOperationVO { @ApiModelProperty(value = "操作记录id") private Integer id; private Long id; @ApiModelProperty(value = "物品id") private Integer goodsId; private Long goodsId; @ApiModelProperty(value = "操作内容") private String content; @@ -34,7 +34,7 @@ private Date createTime; @ApiModelProperty(value = "操作人") private Integer userId; private Long userId; @ApiModelProperty("申请人姓名") private String applyName; springcloud_k8s_panzhihuazhihuishequ/community_backstage/src/main/java/com/panzhihua/community_backstage/api/LoginApi.java
@@ -2,6 +2,7 @@ import javax.annotation.Resource; import com.panzhihua.common.interfaces.OperLog; import com.panzhihua.common.model.vos.LoginReturnsVO; import com.panzhihua.common.service.user.UserService; import com.panzhihua.community_backstage.util.MyAESUtil; @@ -33,6 +34,7 @@ @Resource private UserService userService; @OperLog(operModul="用户登录",operType = 1) @ApiOperation(value = "社区平台登录", response = LoginReturnVO.class) @PostMapping("login") public R login(@RequestBody LoginBody loginBody) { @@ -72,6 +74,7 @@ return tokenService.refreshToken(refreshToken); } @OperLog(operModul="用户登出",operType = 1) @ApiOperation(value = "用户登出") @PostMapping("logout") public R updateUserWeiXinPhone() { springcloud_k8s_panzhihuazhihuishequ/grid_app/.gitignore
New file @@ -0,0 +1,33 @@ HELP.md target/ !.mvn/wrapper/maven-wrapper.jar !**/src/main/**/target/ !**/src/test/**/target/ ### STS ### .apt_generated .classpath .factorypath .project .settings .springBeans .sts4-cache ### IntelliJ IDEA ### .idea *.iws *.iml *.ipr ### NetBeans ### /nbproject/private/ /nbbuild/ /dist/ /nbdist/ /.nb-gradle/ build/ !**/src/main/**/build/ !**/src/test/**/build/ ### VS Code ### .vscode/ springcloud_k8s_panzhihuazhihuishequ/grid_backstage/.gitignore
New file @@ -0,0 +1,33 @@ HELP.md target/ !.mvn/wrapper/maven-wrapper.jar !**/src/main/**/target/ !**/src/test/**/target/ ### STS ### .apt_generated .classpath .factorypath .project .settings .springBeans .sts4-cache ### IntelliJ IDEA ### .idea *.iws *.iml *.ipr ### NetBeans ### /nbproject/private/ /nbbuild/ /dist/ /nbdist/ /.nb-gradle/ build/ !**/src/main/**/build/ !**/src/test/**/build/ ### VS Code ### .vscode/ springcloud_k8s_panzhihuazhihuishequ/service_api/.gitignore
New file @@ -0,0 +1,33 @@ HELP.md target/ !.mvn/wrapper/maven-wrapper.jar !**/src/main/**/target/ !**/src/test/**/target/ ### STS ### .apt_generated .classpath .factorypath .project .settings .springBeans .sts4-cache ### IntelliJ IDEA ### .idea *.iws *.iml *.ipr ### NetBeans ### /nbproject/private/ /nbbuild/ /dist/ /nbdist/ /.nb-gradle/ build/ !**/src/main/**/build/ !**/src/test/**/build/ ### VS Code ### .vscode/ springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
@@ -11,6 +11,7 @@ import com.panzhihua.common.utlis.*; import com.panzhihua.service_community.dao.*; import com.panzhihua.service_community.entity.SysUser; import com.panzhihua.service_community.model.dos.*; import org.apache.commons.lang3.ObjectUtils; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; @@ -59,15 +60,6 @@ import com.panzhihua.common.model.vos.user.AdministratorsUserVO; import com.panzhihua.common.service.user.UserService; import com.panzhihua.service_community.entity.ComPbCheckUnit; import com.panzhihua.service_community.model.dos.ComActActivityDO; import com.panzhihua.service_community.model.dos.ComActDO; import com.panzhihua.service_community.model.dos.ComActNeighborCircleBrowseDO; import com.panzhihua.service_community.model.dos.ComActNeighborCircleCommentDO; import com.panzhihua.service_community.model.dos.ComActNeighborCircleCommentReplyDO; import com.panzhihua.service_community.model.dos.ComActNeighborCircleDO; import com.panzhihua.service_community.model.dos.ComActNeighborCircleFabulousDO; import com.panzhihua.service_community.model.dos.ComActNeighborCircleTopicDO; import com.panzhihua.service_community.model.dos.ComPbMemberDO; import com.panzhihua.service_community.service.ComActNeighborCircleBrowseService; import com.panzhihua.service_community.service.ComActNeighborCircleService; import com.panzhihua.service_community.service.ComActNeighborCircleTopicService; @@ -233,6 +225,7 @@ if (StringUtils.isNotEmpty(addNeighborCircleAppDTO.getPhone())) { neighborCircleDO.setReleasePhone(addNeighborCircleAppDTO.getPhone()); } //判断当前邻里圈是否需要审核 if(addNeighborCircleAppDTO.getIsExamine().equals(AddComActNeighborCircleAppDTO.isExamine.no)){ //当邻里圈不需要审核才进入自动审核 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleWestServiceImpl.java
@@ -1,23 +1,12 @@ package com.panzhihua.service_community.service.impl; import java.util.ArrayList; import java.util.Date; import java.util.List; import javax.annotation.Resource; import com.panzhihua.common.model.dtos.neighbor.*; import com.panzhihua.service_community.service.ComActNeighborCircleTopicWestService; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.panzhihua.common.constants.NeighborCircleConstants; import com.panzhihua.common.model.dtos.neighbor.*; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.neighbor.*; import com.panzhihua.common.model.vos.user.AdministratorsUserVO; @@ -26,9 +15,17 @@ import com.panzhihua.service_community.dao.*; import com.panzhihua.service_community.model.dos.*; import com.panzhihua.service_community.service.ComActNeighborCircleBrowseWestService; import com.panzhihua.service_community.service.ComActNeighborCircleTopicWestService; import com.panzhihua.service_community.service.ComActNeighborCircleWestService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.ArrayList; import java.util.Date; import java.util.List; /** * @auther lyq @@ -146,6 +143,7 @@ } neighborCircleDO.setTopicId(circleTopicDO.getId()); } //判断当前邻里圈是否需要审核 if(addNeighborCircleAppDTO.getIsExamine().equals(AddComActNeighborCircleAppDTO.isExamine.no)){ //当邻里圈不需要审核才进入自动审核 @@ -162,6 +160,7 @@ } } if(this.baseMapper.insert(neighborCircleDO) > 0){ return R.ok(); } else { springcloud_k8s_panzhihuazhihuishequ/service_grid/.gitignore
New file @@ -0,0 +1,33 @@ HELP.md target/ !.mvn/wrapper/maven-wrapper.jar !**/src/main/**/target/ !**/src/test/**/target/ ### STS ### .apt_generated .classpath .factorypath .project .settings .springBeans .sts4-cache ### IntelliJ IDEA ### .idea *.iws *.iml *.ipr ### NetBeans ### /nbproject/private/ /nbbuild/ /dist/ /nbdist/ /.nb-gradle/ build/ !**/src/main/**/build/ !**/src/test/**/build/ ### VS Code ### .vscode/ springcloud_k8s_panzhihuazhihuishequ/service_property/.gitignore
New file @@ -0,0 +1,33 @@ HELP.md target/ !.mvn/wrapper/maven-wrapper.jar !**/src/main/**/target/ !**/src/test/**/target/ ### STS ### .apt_generated .classpath .factorypath .project .settings .springBeans .sts4-cache ### IntelliJ IDEA ### .idea *.iws *.iml *.ipr ### NetBeans ### /nbproject/private/ /nbbuild/ /dist/ /nbdist/ /.nb-gradle/ build/ !**/src/main/**/build/ !**/src/test/**/build/ ### VS Code ### .vscode/