Merge branch 'gzdyh_prod'

xusd

23 hours ago e9de6064cc94d6bc63685c5e62046ff810b96dab

 dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseFeedbackService.java

@@ -1,12 +1,16 @@
package cn.huge.module.cases.service;
import java.util.ArrayList;

import cn.huge.base.common.exception.ServiceException;
import cn.huge.base.common.utils.DateUtils;
import cn.huge.base.common.utils.IdUtils;
import cn.huge.base.common.utils.ObjectUtils;
import cn.huge.base.common.utils.ThreadPoolUtils;
import cn.huge.module.cases.consts.CaseTaskConsts;
import cn.huge.module.cases.domain.dto.FileRelateDTO;
import cn.huge.module.cases.domain.dto.MediatorDTO;
import cn.huge.module.cases.domain.po.*;
import cn.huge.module.cases.domain.vo.SaveEventFeedBackVo;
import cn.huge.module.client.api.impl.CustClientImpl;
import cn.huge.module.client.api.impl.SysClientImpl;
import cn.huge.module.client.api.impl.UtilsClientImpl;
@@ -14,15 +18,19 @@
import cn.huge.module.cust.dto.CtUnitDTO;
import cn.huge.module.cust.dto.CtUserDTO;
import cn.huge.module.mediate.constant.CaseBaseConsts;
import cn.huge.module.mediate.constant.CaseBaseConstsEnum;
import cn.huge.module.sys.constant.FileOwnerTypeBaseEnum;
import cn.huge.module.sys.dto.FileIdInfoBaseDTO;
import cn.huge.module.sys.dto.FileInfoBaseDTO;
import cn.huge.module.sys.dto.FileTypeInfoBaseDTO;
import cn.huge.module.utils.TimeUtils;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.google.common.collect.Maps;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.domain.Page;
@@ -32,6 +40,8 @@

import javax.print.DocFlavor;
import java.util.*;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;

/**
@@ -73,6 +83,10 @@

    @Autowired
    private CaseMediatorService caseMediatorService;

    @Autowired
    private CaseInfoService caseInfoService;


    /**
     * 更新对象
@@ -165,10 +179,95 @@
            }
            caseFeedback.setUpdateTime(nowDate);
            this.saveOrUpdate(caseFeedback);

            //  异步同步纠纷办理反馈信息
            asyncSaveEventFeedback(caseFeedback, userId);

        } catch (Exception e) {
            log.error("[caseFeedbackService.savecaseFeedback]调用失败，异常信息：" + e, e);
            throw new ServiceException("caseFeedbackService.savecaseFeedback", e);
        }
    }

    /**
     * 异步保存办理反馈信息
     *
     * @param caseFeedback
     * @param userId
     */
    private void asyncSaveEventFeedback(CaseFeedback caseFeedback, String userId) {
        log.info("同步办理反馈信息开始！！");
        String caseId = caseFeedback.getCaseId();
        CaseInfo caseInfo = caseInfoService.getById(caseId);
        String canalSecond = caseInfo.getCanalSecond();

        //  需要同步的渠道类型
        List<String> needSyncTypeList = new ArrayList<>();
        needSyncTypeList.add(CaseBaseConstsEnum.CASE_CANAL_SECOND_1.getIndex());
        needSyncTypeList.add(CaseBaseConstsEnum.CASE_CANAL_SECOND_2.getIndex());
        needSyncTypeList.add(CaseBaseConstsEnum.CASE_CANAL_SECOND_7.getIndex());

        if (!needSyncTypeList.contains(canalSecond)) {
            log.info("当前来源的事项不需要同步，来源为：" + CaseBaseConstsEnum.getDes(canalSecond));
            return ;
        }

        //  使用completableFuture进行异步处理，使用jdk8的forkjoinPool线程池
        CompletableFuture<Object> future = CompletableFuture.supplyAsync(() -> {
            log.info("异步保存办理反馈信息开始");
            //  保存办理反馈信息后需要同步到大平台中
            String code = caseInfo.getCaseRef();

            //  反馈用户信息
            CtUserDTO ctUserDTO = custClient.clientGetUser(userId);
            CtUnitDTO ctUnitDTO = custClient.getUnitById(ctUserDTO.getUnitId());

            //  反馈意见内容
            String handleContent = caseFeedback.getHandleContent();

            //  反馈时间
            Date now = new Date();
            String appTime = TimeUtils.format(now,TimeUtils.STANDARD_PATTERN);
            String processingTime = TimeUtils.format(TimeUtils.after(now,14),TimeUtils.STANDARD_PATTERN);

            //  构建参数
            SaveEventFeedBackVo saveEventFeedBackVo = new SaveEventFeedBackVo();
            saveEventFeedBackVo.setId(caseFeedback.getId());
            saveEventFeedBackVo.setCode(code);

            //  先传递当前子系统的用户id
            saveEventFeedBackVo.setAppUserId(userId);
            saveEventFeedBackVo.setAppUserName(ctUserDTO.getTrueName());
            saveEventFeedBackVo.setAppOrgId(ctUnitDTO.getId());
            saveEventFeedBackVo.setAppOrgName(ctUnitDTO.getUnitName());

            saveEventFeedBackVo.setAppTime(appTime);
            saveEventFeedBackVo.setApproveContent(handleContent);
            saveEventFeedBackVo.setProcessingTime(processingTime);
            saveEventFeedBackVo.setHandleType("");

            //  附件信息
            //  先获取文件关联表信息
            List<FileRelateDTO> fileRelateDTOS = sysClient.listFileRelateByOwnerId(caseFeedback.getId());
            List<FileInfoBaseDTO> fileInfoBaseDTOS = new ArrayList<>();
            if (CollectionUtils.isNotEmpty(fileRelateDTOS)){
                fileInfoBaseDTOS = fileRelateDTOS.stream()
                        .map(o->{
                            FileInfoBaseDTO fileInfoBaseDTO = new FileInfoBaseDTO();
                            fileInfoBaseDTO.setId(o.getFileId());
                            return fileInfoBaseDTO;
                        }).collect(Collectors.toList());
            }

            saveEventFeedBackVo.setFileInfoList(fileInfoBaseDTOS);

            //  发起同步
            sysClient.saveEventFeedback(saveEventFeedBackVo);
            log.info("异步保存办理反馈信息成功！！");
            return null;
        });


    }

    /**
@@ -333,6 +432,8 @@
                caseFeedback.setHandleType(CaseTaskConsts.HANDLE_TYPE_2);
            }
            this.save(caseFeedback);
            //  异步同步纠纷办理反馈信息
            asyncSaveEventFeedback(caseFeedback, userId);
        } catch (Exception e) {
            log.error("[caseFeedbackService.savecaseFeedback]调用失败，异常信息：" + e, e);
            throw new ServiceException("caseFeedbackService.savecaseFeedback", e);