From 0eb28fecafb15512c82aeae00b40fb1bca65f08c Mon Sep 17 00:00:00 2001 From: luofl <1442745593@qq.com> Date: 星期五, 21 三月 2025 18:41:57 +0800 Subject: [PATCH] 修改按钮权限 --- springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java | 268 +++++++++++++++++++++++++++++------------------------ 1 files changed, 146 insertions(+), 122 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java index ca73787..57901cc 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java @@ -12,8 +12,11 @@ import com.panzhihua.common.exceptions.ServiceException; import com.panzhihua.common.model.vos.LoginUserInfoVO; import com.panzhihua.common.model.vos.sangeshenbian.SystemUserVo; +import com.panzhihua.common.redis.RedisUtils; +import com.panzhihua.sangeshenbian.config.AutoColumnWidthStrategy; import com.panzhihua.sangeshenbian.dao.ComplaintMapper; import com.panzhihua.sangeshenbian.enums.AuditStatusEnum; +import com.panzhihua.sangeshenbian.enums.ComplaintExportEnum; import com.panzhihua.sangeshenbian.enums.ProcessStatusEnum; import com.panzhihua.sangeshenbian.enums.RateEnum; import com.panzhihua.sangeshenbian.enums.ReportTypeEnum; @@ -33,11 +36,14 @@ import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.Lazy; +import org.springframework.core.io.ClassPathResource; +import org.springframework.data.redis.connection.RedisServer; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.servlet.http.HttpServletResponse; import java.io.IOException; +import java.io.InputStream; import java.net.URLEncoder; import java.text.SimpleDateFormat; import java.util.*; @@ -69,6 +75,7 @@ private final HttpServletResponse response; private final IPartyMemberService partyMemberService; private final IdentityInformationService identityInformationService; + private final RedisUtils redisUtils; @Override public void saveComplaint(Complaint complaint, LoginUserInfoVO loginUserInfoVO) { @@ -96,13 +103,9 @@ complaint.setSerialNumber(serialNumber); Integer accountLevel = 5; //获取当前身份 - IdentityInformation identityInformationVO = identityInformationService.getIdentityInformation(loginUserInfoVO); + IdentityInformation identityInformationVO = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO); //1=党员,2=管理员 SystemUser systemUser = identityInformationVO.getSystemUser(); - List<PermissionsVO> permissions = identityInformationVO.getPermissions(); - if (permissions.isEmpty()) { - throw new ServiceException("请先完善个人信息"); - } Integer identity = identityInformationVO.getIdentity(); if (identity == 2) { accountLevel = systemUser.getAccountLevel(); @@ -185,10 +188,7 @@ Long targetId = null; Integer accountLevel = 5; //获取当前身份,1=党员,2=管理员 - IdentityInformation identityInformation = identityInformationService.getIdentityInformation(loginUserInfoVO); - if (CollectionUtil.isEmpty(identityInformation.getPermissions())) { - throw new ServiceException("请先完善个人信息"); - } + IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO); Integer identity = identityInformation.getIdentity(); //上级 if (systemUserByPhone.isPresent() && null != identity && identity == 2) { @@ -237,17 +237,25 @@ vo.setListControlsButtonStatus(1); vo.setEvaluateButtonStatus(1); vo.setAuditButtonStatus(1); - - ComplaintAuditRecord one = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, vo.getId()) - .ne(ComplaintAuditRecord::getAuditType, 1).orderByDesc(ComplaintAuditRecord::getSort).last(" limit 0, 1")); + // 获取身份 + Integer identity = (Integer) redisUtils.get("identity:" + loginUserInfo.getPhone()); + ComplaintAuditRecord one = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>() + .eq(ComplaintAuditRecord::getComplaintId, vo.getId()) +// .ne(ComplaintAuditRecord::getAuditType, 1) + .orderByDesc(ComplaintAuditRecord::getSort) + .last(" limit 0, 1")); //没有审核数据,且正在办理,则按钮权限是添加人员的 if (null == one && (vo.getStatus() == 0 || vo.getStatus() == 1 || vo.getStatus() == 2)) { if (systemUserByPhone.isPresent()) { SystemUser systemUser = systemUserByPhone.get(); Integer accountLevel = systemUser.getAccountLevel(); Integer isAdmin = systemUser.getIsAdmin(); - //非党员用户,必须是管理员有权限 - if (accountLevel.compareTo(vo.getReportType()) == 0 && ((accountLevel != 5 && 1 == isAdmin) || accountLevel == 5)) { + //当前身份是管理员 + if(2 == identity && accountLevel.compareTo(vo.getReportType()) == 0 && (accountLevel != 5 && 1 == isAdmin)){ + vo.setListControlsButtonStatus(0); + } + //如果当前身份是党员 + if(1 == identity && 5 == vo.getReportType()){ vo.setListControlsButtonStatus(0); } } else { @@ -259,23 +267,26 @@ //有审核数据,且正在办理 if (null != one && (vo.getStatus() == 0 || vo.getStatus() == 1 || vo.getStatus() == 2 || vo.getStatus() == 6)) { //区分是上报数据还是下派数据 - if (one.getAuditType() == 2) { + if (one.getAuditType() == 2 || one.getAuditType() == 1) { //判断当前审核状态 if (one.getAuditStatus() == 1) { //审核状态为通过,则权限给到上报审核的这一层 if (systemUserByPhone.isPresent()) { SystemUser systemUser = systemUserByPhone.get(); - Integer accountLevel = systemUser.getAccountLevel(); Integer isAdmin = systemUser.getIsAdmin(); //非党员用户,必须是管理员有权限 - if (accountLevel.compareTo(one.getReportType()) == 0 && accountLevel != 5 && 1 == isAdmin) { + if (identity.compareTo(one.getReportType()) == 0 && identity != 5 && 1 == isAdmin) { vo.setListControlsButtonStatus(0); } } } else { //没有审核通过,则需要查询上一条审核通过的数据,如果没有则给到添加诉求的人 - ComplaintAuditRecord one1 = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, vo.getId()) - .eq(ComplaintAuditRecord::getAuditType, 2).eq(ComplaintAuditRecord::getAuditStatus, 1).orderByDesc(ComplaintAuditRecord::getSort).last(" limit 0, 1")); + ComplaintAuditRecord one1 = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>() + .eq(ComplaintAuditRecord::getComplaintId, vo.getId()) + .eq(ComplaintAuditRecord::getAuditType, 2) + .eq(ComplaintAuditRecord::getAuditStatus, 1) + .orderByDesc(ComplaintAuditRecord::getSort) + .last(" limit 0, 1")); if (null != one1) { if (systemUserByPhone.isPresent()) { SystemUser systemUser = systemUserByPhone.get(); @@ -292,8 +303,12 @@ SystemUser systemUser = systemUserByPhone.get(); Integer accountLevel = systemUser.getAccountLevel(); Integer isAdmin = systemUser.getIsAdmin(); - //非党员用户,必须是管理员有权限 - if (accountLevel.compareTo(vo.getReportType()) == 0 && ((accountLevel != 5 && 1 == isAdmin) || accountLevel == 5)) { + //当前身份是管理员 + if(2 == identity && accountLevel.compareTo(vo.getReportType()) == 0 && (accountLevel != 5 && 1 == isAdmin)){ + vo.setListControlsButtonStatus(0); + } + //如果当前身份是党员 + if(1 == identity && 5 == vo.getReportType()){ vo.setListControlsButtonStatus(0); } } else { @@ -315,46 +330,8 @@ Integer accountLevel = systemUser.getAccountLevel(); Integer isAdmin = systemUser.getIsAdmin(); //非党员用户,必须是管理员有权限 - if (accountLevel.compareTo(one.getReportType()) == 0 && ((accountLevel != 5 && 1 == isAdmin) || accountLevel == 5)) { + if (accountLevel.compareTo(one.getReportType()) == 0 && 1 == isAdmin && 2 == identity) { vo.setListControlsButtonStatus(0); - } - } else { - if (vo.getReportType() == 5 && one.getReportType() == 5) { - vo.setListControlsButtonStatus(0); - } - } - } else { - //没有审核通过,则需要查询上一条审核通过的数据,如果没有则给到添加诉求的人 - ComplaintAuditRecord one1 = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, vo.getId()) - .eq(ComplaintAuditRecord::getAuditType, 3).eq(ComplaintAuditRecord::getAuditStatus, 1).orderByDesc(ComplaintAuditRecord::getSort).last(" limit 0, 1")); - if (null != one1) { - if (systemUserByPhone.isPresent()) { - SystemUser systemUser = systemUserByPhone.get(); - Integer accountLevel = systemUser.getAccountLevel(); - Integer isAdmin = systemUser.getIsAdmin(); - //非党员用户,必须是管理员有权限 - if (accountLevel.compareTo(one1.getReportType()) == 0 && ((accountLevel != 5 && 1 == isAdmin) || accountLevel == 5)) { - vo.setListControlsButtonStatus(0); - } - } else { - if (vo.getReportType() == 5 && one1.getReportType() == 5) { - vo.setListControlsButtonStatus(0); - } - } - } else { - //没有上一层审核通过的数据,则权限给到添加人 - if (systemUserByPhone.isPresent()) { - SystemUser systemUser = systemUserByPhone.get(); - Integer accountLevel = systemUser.getAccountLevel(); - Integer isAdmin = systemUser.getIsAdmin(); - //非党员用户,必须是管理员有权限 - if (accountLevel.compareTo(vo.getReportType()) == 0 && ((accountLevel != 5 && 1 == isAdmin) || accountLevel == 5)) { - vo.setListControlsButtonStatus(0); - } - } else { - if (vo.getReportType() == 5) { - vo.setListControlsButtonStatus(0); - } } } } @@ -368,7 +345,7 @@ String targetId = ""; Integer accountLevel = 5; //获取当前身份,1=党员,2=管理员 - IdentityInformation identityInformation = identityInformationService.getIdentityInformation(loginUserInfo); + IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfo); if (2 == identityInformation.getIdentity()) { accountLevel = systemUser.getAccountLevel(); switch (accountLevel) { @@ -395,7 +372,8 @@ break; } - ComplaintAuditRecord one2 = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>().eq(ComplaintAuditRecord::getComplaintId, vo.getId()) + ComplaintAuditRecord one2 = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>() + .eq(ComplaintAuditRecord::getComplaintId, vo.getId()) .eq(ComplaintAuditRecord::getLatestFlag, 1)); Integer isAdmin = systemUserByPhone.get().getIsAdmin(); if (one2.getReportType().equals(accountLevel) && one2.getSuperiorId().toString().equals(targetId) && 1 == isAdmin) { @@ -407,12 +385,17 @@ //状态为已办结,判断评价按钮 int count = complaintCommentService.count(new LambdaQueryWrapper<ComplaintComment>().eq(ComplaintComment::getComplaintId, vo.getId()).eq(ComplaintComment::getDelFlag, 0)); - if (vo.getStatus() == 3 && 0 == count) { + if ((vo.getStatus() == 3 || vo.getStatus() == 8) && 0 == count) { if (systemUserByPhone.isPresent()) { SystemUser systemUser = systemUserByPhone.get(); Integer accountLevel = systemUser.getAccountLevel(); Integer isAdmin = systemUser.getIsAdmin(); - if (accountLevel.compareTo(vo.getReportType()) == 0 && ((accountLevel != 5 && 1 == isAdmin) || accountLevel == 5)) { + //当前不是党员身份,需要是管理员才有权限 + if (2 == identity && accountLevel.compareTo(vo.getReportType()) == 0 && accountLevel != 5 && 1 == isAdmin) { + vo.setEvaluateButtonStatus(0); + } + //当前是党员身份,只有是以党员身份提交的数据才有权限 + if(1 == identity && vo.getReportType() == 5){ vo.setEvaluateButtonStatus(0); } } else { @@ -436,10 +419,7 @@ String targetId = ""; Integer accountLevel = 5; //获取当前身份,1=党员,2=管理员 - IdentityInformation identityInformation = identityInformationService.getIdentityInformation(loginUserInfoVO); - if (CollectionUtil.isEmpty(identityInformation.getPermissions())) { - throw new ServiceException("身份信息异常"); - } + IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO); Integer identity = identityInformation.getIdentity(); //上级 if (systemUserByPhone.isPresent() && identity == 2) { @@ -475,7 +455,7 @@ } ComplaintVO detail = baseMapper.getDetail(id); if (detail.getStatus().equals(0)) { - List<ComplaintFlow> list = complaintFlowService.lambdaQuery().eq(ComplaintFlow::getComplaintId, id).orderByAsc(ComplaintFlow::getCreateTime).list(); + List<ComplaintFlow> list = complaintFlowService.lambdaQuery().eq(ComplaintFlow::getComplaintId, id).orderByAsc(ComplaintFlow::getSort).list(); detail.setComplaintFlows(list); } //查询办理进度 @@ -523,10 +503,27 @@ */ @Override public void saveProcess(ComplaintProcessDTO dto, LoginUserInfoVO loginUserInfoVO) { + //获取当前身份 + IdentityInformation identityInformationVO = identityInformationService.getIdentityInformation(loginUserInfoVO); + + List<PermissionsVO> permissions = identityInformationVO.getPermissions(); + if (permissions.isEmpty()) { + throw new ServiceException("请先完善个人信息"); + } + //上级 + String name = ""; + if (identityInformationVO.getIdentity() == 2) { + //1=党员,2=管理员 + SystemUser systemUser = identityInformationVO.getSystemUser(); + name = systemUser.getName(); + }else if (identityInformationVO.getIdentity() == 1){ + PartyMember partyMember = identityInformationVO.getPartyMember(); + name = partyMember.getName(); + } ComplaintProgress complaintProgress = BeanUtil.copyProperties(dto, ComplaintProgress.class); complaintProgress.setCreateTime(new Date()); complaintProgress.setCreateBy(loginUserInfoVO.getUserId()); - complaintProgress.setCreateByName(loginUserInfoVO.getNickName()); + complaintProgress.setCreateByName(name); complaintProgressService.save(complaintProgress); } @@ -546,18 +543,22 @@ throw new ServiceException("请先完善个人信息"); } Integer accountLevel = null; + String name = ""; //上级 if (identityInformationVO.getIdentity() == 2) { //1=党员,2=管理员 SystemUser systemUser = identityInformationVO.getSystemUser(); accountLevel = systemUser.getAccountLevel(); + name = systemUser.getName(); }else if (identityInformationVO.getIdentity() == 1){ accountLevel = 5; + PartyMember partyMember = identityInformationVO.getPartyMember(); + name = partyMember.getName(); } Complaint complaint = BeanUtil.copyProperties(dto, Complaint.class); complaint.setUpdateTime(new Date()); complaint.setCompletionUserId(loginUserInfoVO.getUserId()); - complaint.setCompletionUsername(loginUserInfoVO.getNickName()); + complaint.setCompletionUsername(name); complaint.setCompletionUserPhone(loginUserInfoVO.getPhone()); complaint.setCompletionTime(new Date()); complaint.setCompletionUserLevel(accountLevel); @@ -581,39 +582,42 @@ @Transactional(rollbackFor = Exception.class) public void saveReport(ComplaintReportDTO dto, LoginUserInfoVO loginUserInfoVO) { String phone = loginUserInfoVO.getPhone(); - SystemUser adminUser = systemUserService.getOne(new LambdaQueryWrapper<SystemUser>() - .eq(SystemUser::getPhone, phone) - .eq(SystemUser::getIsAdmin, 1) - .ne(SystemUser::getStatus, 3) - .last("LIMIT 1")); - - IdentityInformation identityInformationVO = identityInformationService.getIdentityInformation(loginUserInfoVO); - if (CollectionUtil.isEmpty(identityInformationVO.getPermissions())) { - throw new ServiceException("请先完成认证"); - } + IdentityInformation identityInformationVO = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO); + SystemUser adminUser = identityInformationVO.getSystemUser(); Long superiorId; int reportType; + int reporterLevel; + Long reporterId = null; String departmentName = ""; + String reporter = ""; if (identityInformationVO.getIdentity() == 1) { PartyMember partyMember = partyMemberService.getPartyMemberByPhone(phone); superiorId = partyMember.getCommunityId(); + reporterId = partyMember.getId(); reportType = 4; + reporterLevel = 5; departmentName = partyMember.getDistricts() + "-" + partyMember.getStreet() + "-" + partyMember.getCommunity(); + reporter = partyMember.getName(); } else if (identityInformationVO.getIdentity() == 2) { int accountLevel = adminUser.getAccountLevel(); // 改为基本类型 if (accountLevel == 1) { throw new ServiceException("市级账号,无法上报!"); } reportType = accountLevel - 1; + reporterLevel = accountLevel; + reporter = adminUser.getName(); // 使用基本类型比较并补充默认分支 if (accountLevel == ReportTypeEnum.COMMUNITY.getCode()) { superiorId = Long.parseLong(adminUser.getStreetId()); + reporterId = adminUser.getCommunityId(); } else if (accountLevel == ReportTypeEnum.STREET.getCode()) { superiorId = Long.parseLong(adminUser.getDistrictsCode()); + reporterId = Long.parseLong(adminUser.getStreetId()); } else if (accountLevel == ReportTypeEnum.DISTRICT.getCode()) { superiorId = 510400L; // 攀枝花市 + reporterId = Long.parseLong(adminUser.getDistrictsCode()); } else if (accountLevel == ReportTypeEnum.PARTY.getCode()) { superiorId = adminUser.getCommunityId(); } else { @@ -670,23 +674,21 @@ complaintAuditRecord.setCreateTime(new Date()); complaintAuditRecord.setUpdateBy(loginUserInfoVO.getUserId()); complaintAuditRecord.setUpdateTime(new Date()); - complaintAuditRecord.setReporter(loginUserInfoVO.getNickName()); + complaintAuditRecord.setReporter(reporter); complaintAuditRecord.setReportType(reportType); complaintAuditRecord.setSuperiorId(superiorId); complaintAuditRecord.setComment(dto.getComment()); complaintAuditRecord.setSort(count + 1); complaintAuditRecord.setDepartmentName(departmentName); + complaintAuditRecord.setReporterLevel(reporterLevel); + complaintAuditRecord.setReporterId(reporterId); complaintAuditRecordService.save(complaintAuditRecord); } @Override @Transactional(rollbackFor = Exception.class) public void saveDispatch(ComplaintDispatch dto, LoginUserInfoVO loginUserInfoVO) { - IdentityInformation identityInformation = identityInformationService.getIdentityInformation(loginUserInfoVO); - List<PermissionsVO> permissions = identityInformation.getPermissions(); - if (CollectionUtil.isEmpty(permissions)) { - throw new ServiceException("请先完成认证"); - } + IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO); if (identityInformation.getIdentity() != 2) { throw new ServiceException("无权下派"); } @@ -754,11 +756,7 @@ @Transactional(rollbackFor = Exception.class) public void reportAudit(ComplaintReporAuditDTO complaintReporAuditDTO, LoginUserInfoVO loginUserInfoVO) { - IdentityInformation identityInformation = identityInformationService.getIdentityInformation(loginUserInfoVO); - List<PermissionsVO> permissions = identityInformation.getPermissions(); - if (CollectionUtil.isEmpty(permissions)) { - throw new ServiceException("请先完成认证"); - } + IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO); SystemUser systemUser = identityInformation.getSystemUser(); if (systemUser == null || identityInformation.getIdentity() != 2) { @@ -792,12 +790,18 @@ if (Objects.isNull(complaintAuditRecord)) { throw new ServiceException("上报申请记录不存在"); } + complaintAuditRecord.setAuditorName(systemUser.getName()); + complaintAuditRecord.setAuditorPhone(systemUser.getPhone()); if (complaintReporAuditDTO.getAuditResult().equals(1)) { complaintAuditRecord.setAuditStatus(1); complaintAuditRecord.setAuditorId(loginUserInfoVO.getUserId()); complaintAuditRecordService.updateById(complaintAuditRecord); //创建流程 - complaintFlowService.createFlow(complaintAuditRecord, 0, loginUserInfoVO.getUserId()); + ComplaintAuditRecord complaintAuditRecord2 = new ComplaintAuditRecord(); + complaintAuditRecord2.setComplaintId(complaintReporAuditDTO.getId()); + complaintAuditRecord2.setSuperiorId(complaintAuditRecord.getReporterId()); + complaintAuditRecord2.setReportType(complaintAuditRecord.getReporterLevel()); + complaintFlowService.createFlow(complaintAuditRecord2, 0, loginUserInfoVO.getUserId()); } else { complaintAuditRecord.setRejectReason(complaintReporAuditDTO.getRejectReason()); complaintAuditRecord.setAuditStatus(2); @@ -810,16 +814,13 @@ @Override @Transactional(rollbackFor = Exception.class) public void saveDelay(ComplaintDelayDTO dto, LoginUserInfoVO loginUserInfoVO) { - IdentityInformation identityInformation = identityInformationService.getIdentityInformation(loginUserInfoVO); - List<PermissionsVO> permissions = identityInformation.getPermissions(); - - if (CollectionUtil.isEmpty(permissions)) { - throw new ServiceException("请先完成认证"); - } + IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO); SystemUser systemUser = systemUserService.getSystemUserAdminByPhone(loginUserInfoVO.getPhone()).orElse(null); Long superiorId; int reportType; + String departmentName = ""; + String reporter = ""; if (identityInformation.getIdentity() == 1) { PartyMember partyMember = partyMemberService.getPartyMemberByPhone(loginUserInfoVO.getPhone()); superiorId = partyMember.getCommunityId(); @@ -827,12 +828,15 @@ throw new ServiceException("延期申请失败,请绑定社区"); } reportType = ReportTypeEnum.COMMUNITY.getCode(); + departmentName = partyMember.getDistricts() + "-" + partyMember.getStreet() + "-" + partyMember.getCommunity(); + reporter = partyMember.getName(); } else if (identityInformation.getIdentity() == 2 && systemUser != null) { int accountLevel = systemUser.getAccountLevel(); // 改为基本类型 if (accountLevel == 1) { throw new ServiceException("市级账号,无法延期申请!"); } reportType = accountLevel - 1; + reporter = systemUser.getName(); // 使用基本类型比较并补充默认分支 if (accountLevel == ReportTypeEnum.COMMUNITY.getCode()) { @@ -846,6 +850,30 @@ } else { // 处理未预期的账号等级 throw new ServiceException("未知的账号等级"); + } + //查询社区信息 + switch (accountLevel) { + case 2: + BcRegion region = bcRegionService.getDistrictByCode(systemUser.getDistrictsCode().toString()); + if (Objects.nonNull(region)) { + departmentName = region.getRegionName(); + } + break; + case 3: + ComStreet street = comStreetService.getById(systemUser.getStreetId().toString()); + if (Objects.nonNull(street)) { + BcRegion district = bcRegionService.getDistrictByCode(street.getAreaCode().toString()); + departmentName = Objects.nonNull(district) ? district.getRegionName() + "-" + street.getName() : street.getName(); + } + break; + case 4: + ComAct act = comActService.getById(systemUser.getCommunityId()); + if (Objects.nonNull(act)) { + ComStreet street2 = comStreetService.getById(systemUser.getStreetId().toString()); + BcRegion district = bcRegionService.getDistrictByCode(act.getAreaCode()); + departmentName = Objects.nonNull(district) && Objects.nonNull(street2) ? district.getRegionName() + "-" + street2.getName() + "-" + act.getName() : act.getName(); + } + break; } } else { throw new ServiceException("无权申请"); @@ -865,22 +893,19 @@ record1.setCreateTime(new Date(System.currentTimeMillis())); record1.setUpdateBy(loginUserInfoVO.getUserId()); record1.setUpdateTime(new Date(System.currentTimeMillis())); - record1.setReporter(loginUserInfoVO.getNickName()); + record1.setReporter(reporter); record1.setReportType(reportType); record1.setSuperiorId(superiorId); record1.setSort(count + 1); record1.setComment(dto.getComment()); + record1.setDepartmentName(departmentName); complaintAuditRecordService.save(record1); } @Override public void delayAudit(ComplaintDelayAuditDTO dto, LoginUserInfoVO loginUserInfoVO) { - IdentityInformation identityInformation = identityInformationService.getIdentityInformation(loginUserInfoVO); - List<PermissionsVO> permissions = identityInformation.getPermissions(); - if (CollectionUtil.isEmpty(permissions)) { - throw new ServiceException("请先完成认证"); - } + IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO); SystemUser systemUser = identityInformation.getSystemUser(); if (identityInformation.getIdentity() != 2 || systemUser == null) { throw new ServiceException("无权审核"); @@ -907,7 +932,7 @@ .eq(ComplaintAuditRecord::getAuditType, 1) .eq(ComplaintAuditRecord::getLatestFlag, 1) .eq(ComplaintAuditRecord::getAuditStatus, 0) - .ne(ComplaintAuditRecord::getSuperiorId, superiorId) + .eq(ComplaintAuditRecord::getSuperiorId, superiorId) .eq(ComplaintAuditRecord::getReportType, accountLevel) .eq(ComplaintAuditRecord::getComplaintId, dto.getComplaintId()) .last("LIMIT 1")); @@ -916,6 +941,8 @@ if (Objects.isNull(complaintAuditRecord)) { throw new ServiceException("诉求延期申请不存在"); } + complaintAuditRecord.setAuditorName(systemUser.getName()); + complaintAuditRecord.setAuditorPhone(systemUser.getPhone()); //审核通过后,设置诉求延期 if (complaintAuditRecord.getAuditType().equals(1) && complaintAuditRecord.getAuditStatus().equals(0) && dto.getAuditResult().equals(1)) { Complaint complaint = getById(complaintAuditRecord.getComplaintId()); @@ -938,7 +965,7 @@ @Override public List<DispatchVO> getDispatchList(LoginUserInfoVO loginUserInfoVO) { - IdentityInformation identityInformation = identityInformationService.getIdentityInformation(loginUserInfoVO); + IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO); SystemUser adminUser = identityInformation.getSystemUser(); @@ -995,12 +1022,8 @@ */ @Override public Page<ComplaintTodoVO> getTodoList(BasePage basePage, LoginUserInfoVO loginUserInfo) { - IdentityInformation identityInformation = identityInformationService.getIdentityInformation(loginUserInfo); - List<PermissionsVO> permissions = identityInformation.getPermissions(); + IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfo); SystemUser systemUser = identityInformation.getSystemUser(); - if (permissions.isEmpty()) { - throw new ServiceException("无权限"); - } String targetId = ""; int isSuperior = 0; //上级 @@ -1069,7 +1092,7 @@ //查询诉求流转记录 List<ComplaintFlow> complaintFlows = complaintFlowService.lambdaQuery() .eq(ComplaintFlow::getComplaintId, id) - .orderByAsc(ComplaintFlow::getCreateTime) + .orderByAsc(ComplaintFlow::getSort) .list(); complaintVO.setComplaintFlows(complaintFlows); //查询评价 @@ -1094,6 +1117,7 @@ response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName + ".xlsx"); EasyExcel.write(response.getOutputStream(), ComplaintExcel.class) .sheet("诉求数据") + .registerWriteHandler(new AutoColumnWidthStrategy()) .doWrite(complaintExcels); } @@ -1148,10 +1172,10 @@ String fileName = ""; switch (type) { case 1: - fileName = "社区问题单"; + fileName = "community_question.docx"; break; case 2: - fileName = "问题处理单"; + fileName = "question_handle.docx"; if (Objects.nonNull(partyMember)) { community = community + "-" + partyMember.getServiceTarget(); } @@ -1167,14 +1191,14 @@ if (Objects.nonNull(record)) { reportType = record.getReportType(); } - fileName = "协调通知单"; + fileName = "notice.docx"; break; } Map<String, Object> map = new HashMap<>(); map.put("community", community); map.put("problemType", complaint.getProblemType()); map.put("descriptionContent", complaint.getDescriptionContent()); - map.put("reportType", ReportTypeEnum.getDescriptionByCode(reportType)); + map.put("reportType", reportType == null ? "" : ReportTypeEnum.getDescriptionByCode(reportType)); map.put("partyOrganization", Objects.nonNull(partyMember) ? partyMember.getPartyOrganization() : ""); map.put("name", complaint.getName()); map.put("contactNumber", complaint.getContactNumber()); @@ -1191,19 +1215,19 @@ } // 在文本中直接使用换行符 map.put("complaintProgress", sb.toString()); - map.put("status", ProcessStatusEnum.getDescriptionByCode(complaint.getStatus())); + map.put("status", ComplaintExportEnum.getEnumByCode(complaint.getStatus()).getDesc()); if (2 == type) { //查询诉求评价 ComplaintComment complaintComment = complaintCommentService.lambdaQuery().eq(ComplaintComment::getComplaintId, id).last("LIMIT 1").one(); if (Objects.nonNull(complaintComment)) { - map.put("rateStr", RateEnum.getEnumByCode(complaintComment.getRate())); + map.put("rateStr", RateEnum.getEnumByCode(complaintComment.getRate()).getDesc()); } } response.setContentType("application/octet-stream"); String fileNameEncode = URLEncoder.encode(fileName, "UTF-8").replaceAll("\\+", "%20"); response.setHeader("Content-disposition", "attachment;filename=\"" + fileNameEncode + ".docx" + "\""); - String fileTemplateName = FileUtil.getPath() + "template/" + fileName + ".docx"; - XWPFTemplate.compile(fileTemplateName).render(map).writeAndClose(response.getOutputStream()); + InputStream resourceAsStream = this.getClass().getResourceAsStream("/template/" + fileName); + XWPFTemplate.compile(resourceAsStream).render(map).writeAndClose(response.getOutputStream()); } @@ -1224,7 +1248,7 @@ String content = "第一行内容\n第二行内容\n第三行内容"; map.put("complaintProgress", content); map.put("status", "处理中"); - XWPFTemplate.compile("F:\\DeskTop\\zhihuishequ\\springcloud_k8s_panzhihuazhihuishequ\\service_sangeshenbian\\src\\main\\resources\\template\\社区问题单.docx").render(map).writeToFile("F:\\DeskTop\\社区.docx"); + XWPFTemplate.compile("F:\\DeskTop\\zhihuishequ\\springcloud_k8s_panzhihuazhihuishequ\\service_sangeshenbian\\src\\main\\resources\\template\\community_question.docx").render(map).writeToFile("F:\\DeskTop\\社区.docx"); } catch (IOException e) { e.printStackTrace(); } -- Gitblit v1.7.1