From d8e7ad6acb9f6105ac6ff6fe2ce892e622cde256 Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期二, 18 三月 2025 22:11:24 +0800 Subject: [PATCH] Merge remote-tracking branch '喜望/dev-2.0' into dev-2.0 --- springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java | 66 +++++++++++++++++++++++++++------ 1 files changed, 54 insertions(+), 12 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 cb99004..2e4d59c 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 @@ -33,11 +33,13 @@ import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.Lazy; +import org.springframework.core.io.ClassPathResource; 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.*; @@ -410,7 +412,7 @@ //状态为已办结,判断评价按钮 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(); @@ -523,10 +525,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 +565,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); @@ -586,26 +609,37 @@ 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 { @@ -662,12 +696,14 @@ 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); } @@ -776,12 +812,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); @@ -1146,10 +1188,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(); } @@ -1165,14 +1207,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()); @@ -1200,8 +1242,8 @@ 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()); } @@ -1222,7 +1264,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