| | |
| | | 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; |
| | |
| | | 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.*; |
| | |
| | | private final HttpServletResponse response; |
| | | private final IPartyMemberService partyMemberService; |
| | | private final IdentityInformationService identityInformationService; |
| | | private final RedisUtils redisUtils; |
| | | |
| | | @Override |
| | | public void saveComplaint(Complaint complaint, LoginUserInfoVO loginUserInfoVO) { |
| | |
| | | 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(); |
| | |
| | | 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) { |
| | |
| | | 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 { |
| | |
| | | //有审核数据,且正在办理 |
| | | 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(); |
| | |
| | | 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 { |
| | |
| | | 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); |
| | | } |
| | | } |
| | | } |
| | | } |
| | |
| | | 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) { |
| | |
| | | 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) { |
| | |
| | | |
| | | //状态为已办结,判断评价按钮 |
| | | 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 { |
| | |
| | | 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) { |
| | |
| | | } |
| | | 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); |
| | | } |
| | | //查询办理进度 |
| | |
| | | */ |
| | | @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); |
| | | } |
| | | |
| | |
| | | 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); |
| | |
| | | @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 { |
| | |
| | | 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("无权下派"); |
| | | } |
| | |
| | | @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) { |
| | |
| | | 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); |
| | |
| | | @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(); |
| | |
| | | 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()) { |
| | |
| | | } 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("无权申请"); |
| | |
| | | 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("无权审核"); |
| | |
| | | .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")); |
| | |
| | | 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()); |
| | |
| | | @Override |
| | | public List<DispatchVO> getDispatchList(LoginUserInfoVO loginUserInfoVO) { |
| | | |
| | | IdentityInformation identityInformation = identityInformationService.getIdentityInformation(loginUserInfoVO); |
| | | IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO); |
| | | |
| | | SystemUser adminUser = identityInformation.getSystemUser(); |
| | | |
| | |
| | | */ |
| | | @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; |
| | | //上级 |
| | |
| | | //查询诉求流转记录 |
| | | List<ComplaintFlow> complaintFlows = complaintFlowService.lambdaQuery() |
| | | .eq(ComplaintFlow::getComplaintId, id) |
| | | .orderByAsc(ComplaintFlow::getCreateTime) |
| | | .orderByAsc(ComplaintFlow::getSort) |
| | | .list(); |
| | | complaintVO.setComplaintFlows(complaintFlows); |
| | | //查询评价 |
| | |
| | | response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName + ".xlsx"); |
| | | EasyExcel.write(response.getOutputStream(), ComplaintExcel.class) |
| | | .sheet("诉求数据") |
| | | .registerWriteHandler(new AutoColumnWidthStrategy()) |
| | | .doWrite(complaintExcels); |
| | | } |
| | | |
| | |
| | | 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(); |
| | | } |
| | |
| | | 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()); |
| | |
| | | } |
| | | // 在文本中直接使用换行符 |
| | | 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()); |
| | | } |
| | | |
| | | |
| | |
| | | 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(); |
| | | } |