迭代：4.11版本

luofl

2025-04-14 e3a7b5f659b6967d8b426f20c8b52fe740be50b6

 springcloud_k8s_panzhihuazhihuishequ/service_sangeshenbian/src/main/java/com/panzhihua/sangeshenbian/service/impl/ComplaintServiceImpl.java

@@ -2,7 +2,6 @@

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.collection.CollectionUtil;
import cn.idev.excel.EasyExcel;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
@@ -29,15 +28,14 @@
import com.panzhihua.sangeshenbian.model.vo.ComplaintVO;
import com.panzhihua.sangeshenbian.model.vo.DispatchVO;
import com.panzhihua.sangeshenbian.service.*;
import com.panzhihua.sangeshenbian.utils.FileUtil;
import com.panzhihua.sangeshenbian.warpper.IdentityInformation;
import com.panzhihua.sangeshenbian.warpper.MgtComplaintQuery;
import com.panzhihua.sangeshenbian.warpper.PermissionsVO;
import jodd.util.StringUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
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;

@@ -181,7 +179,34 @@
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void saveAndReport(ComplaintVO complaintVO, LoginUserInfoVO loginUserInfo) {
        Complaint complaint = new Complaint();
        BeanUtil.copyProperties(complaintVO, complaint);
        saveComplaint(complaint, loginUserInfo);
        ComplaintReportDTO dto = new ComplaintReportDTO();
        dto.setComplaintId(complaint.getId());
        dto.setComment(complaintVO.getComment());
        saveReport(dto, loginUserInfo);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void saveAndComplete(ComplaintSaveAndCompleteDTO complaintVO, LoginUserInfoVO loginUserInfo) {
        Complaint complaint = new Complaint();
        BeanUtil.copyProperties(complaintVO, complaint);
        saveComplaint(complaint, loginUserInfo);

        ComplaintCompletionDTO complaintCompletionDTO = complaintVO.getComplaintCompletionDTO();
        complaintCompletionDTO.setComplaintId(complaint.getId());
        complaintCompletionDTO.setId(complaint.getId());
        saveResult(complaintCompletionDTO, loginUserInfo);
    }

    @Override
    public Page<ComplaintVO> complaintList(ComplaintQuery query, LoginUserInfoVO loginUserInfoVO) {


        Page<ComplaintVO> page = new Page<>(query.getPageNum(), query.getPageSize());
        //判断当前登录用户级别，查询对应工单
        Optional<SystemUser> systemUserByPhone = systemUserService.getSystemUserAdminByPhone(loginUserInfoVO.getPhone());
@@ -190,6 +215,7 @@
        //获取当前身份，1=党员，2=管理员
        IdentityInformation identityInformation = identityInformationService.getCurrentIdentityInformation(loginUserInfoVO);
        Integer identity = identityInformation.getIdentity();
        query.setUserId(loginUserInfoVO.getUserId());
        //上级
        if (systemUserByPhone.isPresent() && null != identity && identity == 2) {
            SystemUser systemUser = systemUserByPhone.get();
@@ -225,7 +251,14 @@
        //查询对应诉求
        //page = baseMapper.selectComplaintPage(page, query, targetId, isSuperior);
        page = baseMapper.selectComplaintPage1(page, query, accountLevel, targetId);
        page.getRecords().forEach(s -> buttonPermission(s, systemUserByPhone, loginUserInfoVO));

        page.getRecords().forEach(s -> {
            buttonPermission(s, systemUserByPhone, loginUserInfoVO);
            Integer auditButtonStatus = s.getAuditButtonStatus();
            if (auditButtonStatus == 1 && s.getStatus() == 5 && !Objects.equals(s.getAuditCreateBy(), loginUserInfoVO.getUserId())){
                s.setStatus(0);
            }
        });
        return page;
    }

@@ -404,6 +437,16 @@
                }
            }
        }

        Long auditCreateBy = vo.getAuditCreateBy();
        Long userId = loginUserInfo.getUserId();
        if (null != auditCreateBy && auditCreateBy.compareTo(userId) == 0 && vo.getStatus() == 5) {
            vo.setWithdrawButtonStatus(0);
        }else {
            vo.setWithdrawButtonStatus(1);
        }


    }


@@ -475,6 +518,10 @@


        buttonPermission(detail, systemUserByPhone, loginUserInfoVO);
        Integer auditButtonStatus = detail.getAuditButtonStatus();
        if (auditButtonStatus == 1 && detail.getStatus() == 5 && !Objects.equals(detail.getAuditCreateBy(), loginUserInfoVO.getUserId())){
            detail.setStatus(0);
        }


//        //已办结，显示评价按钮
@@ -577,6 +624,8 @@
        return complaintProgressService.lambdaQuery().eq(ComplaintProgress::getComplaintId, complaintId)
                .orderByAsc(ComplaintProgress::getCreateTime).list();
    }



    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -683,6 +732,41 @@
        complaintAuditRecord.setReporterLevel(reporterLevel);
        complaintAuditRecord.setReporterId(reporterId);
        complaintAuditRecordService.save(complaintAuditRecord);
    }

    @Override
    public void reportWithdraw(ComplaintReportWithdrawDTO dto, LoginUserInfoVO loginUserInfoVO) {
        ComplaintAuditRecord complaintAuditRecord = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>()
                .eq(ComplaintAuditRecord::getComplaintId, dto.getComplaintId())
                .eq(ComplaintAuditRecord::getAuditType, 2)
                .eq(ComplaintAuditRecord::getLatestFlag, true));
        if (Objects.isNull(complaintAuditRecord)) {
            throw new ServiceException("未找到相关记录");
        }
        complaintAuditRecord.setAuditStatus(3);
        complaintAuditRecord.setUpdateBy(loginUserInfoVO.getUserId());
        complaintAuditRecord.setUpdateTime(new Date());
        complaintAuditRecord.setLatestFlag(false);
        complaintAuditRecordService.updateById(complaintAuditRecord);

        // 获取上一条记录
        ComplaintAuditRecord lastRecord = complaintAuditRecordService.getOne(new LambdaQueryWrapper<ComplaintAuditRecord>()
                .ne(ComplaintAuditRecord::getId, complaintAuditRecord.getId())
                .eq(ComplaintAuditRecord::getComplaintId, dto.getComplaintId())
                .eq(ComplaintAuditRecord::getAuditType, 2)
                .eq(ComplaintAuditRecord::getLatestFlag, false)
                .orderByDesc(ComplaintAuditRecord::getSort)
        );
        if (Objects.nonNull(lastRecord)) {
            // 复制上一条记录
            ComplaintAuditRecord newRecord = new ComplaintAuditRecord();
            BeanUtils.copyProperties(lastRecord, newRecord);
            newRecord.setId(null);
            newRecord.setLatestFlag(true);
            newRecord.setUpdateBy(loginUserInfoVO.getUserId());
            newRecord.setUpdateTime(new Date());
            complaintAuditRecordService.save(newRecord);
        }
    }

    @Override
@@ -1122,7 +1206,7 @@
    }

    @Override
    public void downloadFile(Long id, Integer type) throws IOException {
    public void downloadFile(Long id, Integer type, SystemUserVo loginUserInfo) throws IOException {
        Complaint complaint = baseMapper.getDetailBg(id);
        if (Objects.isNull(complaint)) {
            throw new ServiceException("该诉求不存在");
@@ -1177,7 +1261,9 @@
            case 2:
                fileName = "question_handle.docx";
                if (Objects.nonNull(partyMember)) {
                    community = community + "-" + partyMember.getServiceTarget();
                    if (StringUtil.isNotBlank(partyMember.getServiceTarget())) {
                        community = community + "-" + partyMember.getServiceTarget();
                    }
                }
                reportType = complaint.getCompletionUserLevel();
                break;
@@ -1199,7 +1285,9 @@
        map.put("problemType", complaint.getProblemType());
        map.put("descriptionContent", complaint.getDescriptionContent());
        map.put("reportType", reportType == null ? "" : ReportTypeEnum.getDescriptionByCode(reportType));
        map.put("partyOrganization", Objects.nonNull(partyMember) ? partyMember.getPartyOrganization() : "");
        if (Objects.nonNull(partyMember)) {
            map.put("partyOrganization", StringUtil.isNotBlank(partyMember.getPartyOrganization()) ? partyMember.getPartyOrganization() : "");
        }
        map.put("name", complaint.getName());
        map.put("contactNumber", complaint.getContactNumber());
        map.put("nickname", complaint.getReportUserName());
@@ -1222,6 +1310,7 @@
            if (Objects.nonNull(complaintComment)) {
                map.put("rateStr", RateEnum.getEnumByCode(complaintComment.getRate()).getDesc());
            }
            //map.put("departmentLevel", ReportTypeEnum.getDescriptionByCode(loginUserInfo.getAccountLevel()) + "级");
        }
        response.setContentType("application/octet-stream");
        String fileNameEncode = URLEncoder.encode(fileName, "UTF-8").replaceAll("\\+", "%20");