feat：创建效能分析模块

wangwh

2024-10-25 e32c502ce9ecd3d93cde809adc6cfd77d8c62f79

feat：创建效能分析模块

 dyh-service/dyh-mediate/src/main/java/cn/huge/module/analysis/controller/AnalysisWebController.java

New file
@@ -0,0 +1,42 @@
package cn.huge.module.analysis.controller;

import cn.huge.base.common.utils.ReturnFailUtils;
import cn.huge.base.common.utils.ReturnSucUtils;
import cn.huge.module.analysis.service.AnalysisService;
import cn.huge.module.cases.domain.po.CaseInfo;
import cn.huge.module.cases.service.CaseInfoService;
import com.google.common.collect.Maps;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.util.Map;

/**
 * @title: 纠纷信息主表接口api-web端
 * @description: 纠纷信息主表接口api-web端
 * @company: hugeinfo
 * @author: wangwh
 * @time: 2024-08-27 10:00:57
 * @version: 1.0.0
 */
@Slf4j
@RestController
@RequestMapping("/api/web/analysis")
public class AnalysisWebController {

    @Autowired(required = false)
    private HttpServletRequest request;

    @Autowired
    private AnalysisService service;




}

 dyh-service/dyh-mediate/src/main/java/cn/huge/module/analysis/dao/mapper/AnalysisMapper.java

New file
@@ -0,0 +1,26 @@
package cn.huge.module.analysis.dao.mapper;

import cn.huge.module.cases.domain.dto.*;
import cn.huge.module.cases.domain.po.CaseInfo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.data.domain.PageRequest;
import org.springframework.stereotype.Repository;

import java.util.List;
import java.util.Map;

/**
* @title: 纠纷信息主表持久层业务处理
* @Description 此处仅涉及复杂SQL操作，务必不要在此再次写单表的CRUD操作，因为mybatisPlus已经实现。
* @company: hugeinfo
* @author: wangwh
* @time: 2024-08-27 10:00:57
* @version 1.0.0
*/
@Repository
public interface AnalysisMapper extends BaseMapper<CaseInfo>{



}

 dyh-service/dyh-mediate/src/main/java/cn/huge/module/analysis/dao/mapper/xml/AnalysisMapper.xml

New file
@@ -0,0 +1,202 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!-- 
 * @title: 纠纷信息主表
 * @description: 自定义sql，请自行实现业务逻辑
 * @company: hugeinfo
 * @author: wangwh
 * @time:2024-08-27 10:00:57
 * @version 1.0.0
-->
<mapper namespace="cn.huge.module.analysis.dao.mapper.AnalysisMapper">
    <!-- 条件 -->
    <sql id="statisticsAVG-wherePart">
        <if test="terms != null">
            <if test="terms.queProv != null and terms.queProv !=''">
                and t1.que_prov = #{terms.queProv}
            </if>
            <if test="terms.queCity != null and terms.queCity !=''">
                and t1.que_city = #{terms.queCity}
            </if>
            <if test="terms.queArea != null and terms.queArea !=''">
                and t1.que_area = #{terms.queArea}
            </if>
            <if test="terms.queRoad != null and terms.queRoad !=''">
                and t1.que_road = #{terms.queRoad}
            </if>
            <if test="terms.queVillage != null and terms.queVillage !=''">
                and t1.que_village = #{terms.queVillage}
            </if>
            <if test="terms.createStart != null and terms.createStart !='' and terms.createEnd != null and terms.createEnd !=''">
                and (DATE_FORMAT(t2.create_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.createStart}
                and DATE_FORMAT(t2.create_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.createEnd})
            </if>
            <if test="terms.handleStart != null and terms.handleStart !='' and terms.handleEnd != null and terms.handleEnd !=''">
                and (DATE_FORMAT(t2.handle_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.handleStart}
                and DATE_FORMAT(t2.handle_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.handleEnd})
            </if>
            <if test="terms.queVillage != null and terms.queVillage !=''">
                and t1.que_village = #{terms.queVillage}
            </if>
            <if test="terms.mediType != null and terms.mediType !=''">
                and medi_type = #{terms.mediType}
            </if>
            <if test="terms.caseTypeFirst != null and terms.caseTypeFirst !=''">
                and case_type_first = #{terms.caseTypeFirst}
            </if>
        </if>
    </sql>

    <!--  统计任务平均时长  -->
    <select id="statisticsAVG" resultType="java.lang.Long">
        select AVG(case when (t2.node_id = 'ZJ_DFP' or t2.node_id = 'QJ_DFP' or t2.node_id = 'SJ_DFP' or t2.node_id = 'DFP') then count(usetime_hour) end) as fp,
               AVG(case when (t2.node_id = 'ZJ_DSL' or t2.node_id = 'QJ_DSL' or t2.node_id = 'SJ_DSL' or t2.node_id = 'DSL') then usetime_hour end) as sl,
               AVG(case when (t2.node_id = 'BLFK' and t2.status = '2') then usetime_hour end) as sl,
               count(case when (t2.node_id = 'ZJ_DFP' or t2.node_id = 'QJ_DFP' or t2.node_id = 'SJ_DFP' or t2.node_id = 'DFP') and t2.overtime_status = 1 then overtime_hour end) as fpcs,
               count(case when (t2.node_id = 'ZJ_DSL' or t2.node_id = 'QJ_DSL' or t2.node_id = 'SJ_DSL' or t2.node_id = 'DSL') and t2.overtime_status = 1 then overtime_hour end) as slcs
        from dyh_case_info t1 left join dyh_case_task t2 on t1.id = t2.case_id
        where
            t2.status = 2
        <include refid="statisticsAVG-wherePart"/>
    </select>

    <!-- 条件 -->
    <sql id="statisticsApplyAVG-wherePart">
        <if test="terms.queProv != null and terms.queProv !=''">
            and t1.que_prov = #{terms.queProv}
        </if>
        <if test="terms.queCity != null and terms.queCity !=''">
            and t1.que_city = #{terms.queCity}
        </if>
        <if test="terms.queArea != null and terms.queArea !=''">
            and t1.que_area = #{terms.queArea}
        </if>
        <if test="terms.queRoad != null and terms.queRoad !=''">
            and t1.que_road = #{terms.queRoad}
        </if>
        <if test="terms.queVillage != null and terms.queVillage !=''">
            and t1.que_village = #{terms.queVillage}
        </if>
        <if test="terms.queVillage != null and terms.queVillage !=''">
            and t1.que_village = #{terms.queVillage}
        </if>
        <if test="terms.mediType != null and terms.mediType !=''">
            and t1.medi_type = #{terms.mediType}
        </if>
        <if test="terms.caseTypeFirst != null and terms.caseTypeFirst !=''">
            and t1.case_type_first = #{terms.caseTypeFirst}
        </if>
    </sql>

    <!--  统计审批平均时长  -->
    <select id="statisticsApplyAVG" resultType="java.lang.Long">
        select select avg(usetime_hour)
        form
        (
        select usetime_hour
        from dyh_case_info t1 left join dyh_case_appear t2 on t1.id = t2.case_id
        where t2.apply_status = 1
        <if test="terms != null">
            <if test="terms.createStart != null and terms.createStart !='' and terms.createEnd != null and terms.createEnd !=''">
                and (DATE_FORMAT(t2.appear_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.createStart}
                and DATE_FORMAT(t2.appear_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.createEnd})
            </if>
            <if test="terms.handleStart != null and terms.handleStart !='' and terms.handleEnd != null and terms.handleEnd !=''">
                and (DATE_FORMAT(t2.audit_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.handleStart}
                and DATE_FORMAT(t2.audit_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.handleEnd})
            </if>
            <include refid="statisticsApplyAVG-wherePart"/>
        </if>
        union all
        select usetime_hour
        from dyh_case_info t1 left join dyh_case_assist_apply t2 on t1.id = t2.case_id
        where t2.apply_status = 1
        <if test="terms != null">
            <if test="terms.createStart != null and terms.createStart !='' and terms.createEnd != null and terms.createEnd !=''">
                and (DATE_FORMAT(t2.apply_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.createStart}
                and DATE_FORMAT(t2.apply_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.createEnd})
            </if>
            <if test="terms.handleStart != null and terms.handleStart !='' and terms.handleEnd != null and terms.handleEnd !=''">
                and (DATE_FORMAT(t2.audit_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.handleStart}
                and DATE_FORMAT(t2.audit_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.handleEnd})
            </if>
            <include refid="statisticsApplyAVG-wherePart"/>
        </if>
        union all
        select usetime_hour
        from dyh_case_info t1 left join dyh_case_return t2 on t1.id = t2.case_id
        where t2.return_status = 1
        <if test="terms != null">
            <if test="terms.createStart != null and terms.createStart !='' and terms.createEnd != null and terms.createEnd !=''">
                and (DATE_FORMAT(t2.return_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.createStart}
                and DATE_FORMAT(t2.return_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.createEnd})
            </if>
            <if test="terms.handleStart != null and terms.handleStart !='' and terms.handleEnd != null and terms.handleEnd !=''">
                and (DATE_FORMAT(t2.audit_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.handleStart}
                and DATE_FORMAT(t2.audit_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.handleEnd})
            </if>
            <include refid="statisticsApplyAVG-wherePart"/>
        </if>
        union all
        select usetime_hour
        from dyh_case_info t1 left join dyh_case_windup_apply t2 on t1.id = t2.case_id
        where t2.apply_status = 1
        <if test="terms != null">
            <if test="terms.createStart != null and terms.createStart !='' and terms.createEnd != null and terms.createEnd !=''">
                and (DATE_FORMAT(t2.apply_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.createStart}
                and DATE_FORMAT(t2.apply_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.createEnd})
            </if>
            <if test="terms.handleStart != null and terms.handleStart !='' and terms.handleEnd != null and terms.handleEnd !=''">
                and (DATE_FORMAT(t2.audit_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.handleStart}
                and DATE_FORMAT(t2.audit_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.handleEnd})
            </if>
            <include refid="statisticsApplyAVG-wherePart"/>
        </if>
        )
    </select>

    <!-- 条件 -->
    <sql id="statisticsSuperviseAVG-wherePart">
        t2.sup_status = 1
        <if test="terms.queProv != null and terms.queProv !=''">
            and t1.que_prov = #{terms.queProv}
        </if>
        <if test="terms.queCity != null and terms.queCity !=''">
            and t1.que_city = #{terms.queCity}
        </if>
        <if test="terms.queArea != null and terms.queArea !=''">
            and t1.que_area = #{terms.queArea}
        </if>
        <if test="terms.queRoad != null and terms.queRoad !=''">
            and t1.que_road = #{terms.queRoad}
        </if>
        <if test="terms.queVillage != null and terms.queVillage !=''">
            and t1.que_village = #{terms.queVillage}
        </if>
        <if test="terms.queVillage != null and terms.queVillage !=''">
            and t1.que_village = #{terms.queVillage}
        </if>
        <if test="terms.mediType != null and terms.mediType !=''">
            and t1.medi_type = #{terms.mediType}
        </if>
        <if test="terms.caseTypeFirst != null and terms.caseTypeFirst !=''">
            and t1.case_type_first = #{terms.caseTypeFirst}
        </if>
        <if test="terms.createStart != null and terms.createStart !='' and terms.createEnd != null and terms.createEnd !=''">
            and (DATE_FORMAT(t2.sup_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.createStart}
            and DATE_FORMAT(t2.sup_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.createEnd})
        </if>
        <if test="terms.handleStart != null and terms.handleStart !='' and terms.handleEnd != null and terms.handleEnd !=''">
            and (DATE_FORMAT(t2.reply_time,'%Y-%m-%d %H:%i') <![CDATA[ >= ]]> #{terms.handleStart}
            and DATE_FORMAT(t2.reply_time,'%Y-%m-%d %H:%i') <![CDATA[ <= ]]> #{terms.handleEnd})
        </if>
    </sql>

    <!--  统计督办平均时长  -->
    <select id="statisticsSuperviseAVG" resultType="java.lang.Long">
        select usetime_hour
        from dyh_case_info t1 left join dyh_case_supervise t2 on t1.id = t2.case_id
        <include refid="statisticsSuperviseAVG-wherePart"/>
    </select>

</mapper> 

 dyh-service/dyh-mediate/src/main/java/cn/huge/module/analysis/service/AnalysisService.java

New file
@@ -0,0 +1,66 @@
package cn.huge.module.analysis.service;

import cn.huge.base.common.exception.ServiceException;
import cn.huge.base.common.utils.*;
import cn.huge.module.analysis.dao.mapper.AnalysisMapper;
import cn.huge.module.cases.dao.mapper.CaseInfoMapper;
import cn.huge.module.cases.domain.dto.*;
import cn.huge.module.cases.domain.po.CaseAgent;
import cn.huge.module.cases.domain.po.CaseInfo;
import cn.huge.module.cases.domain.po.CaseInfoUnfold;
import cn.huge.module.cases.domain.po.CasePerson;
import cn.huge.module.cases.service.*;
import cn.huge.module.client.api.impl.CustClientImpl;
import cn.huge.module.client.api.impl.SysClientImpl;
import cn.huge.module.client.api.impl.UtilsClientImpl;
import cn.huge.module.constant.BaseConsts;
import cn.huge.module.cust.dto.CtUserDTO;
import cn.huge.module.cust.dto.PaUserDTO;
import cn.huge.module.draft.service.CasedraftInfoService;
import cn.huge.module.mediate.constant.*;
import cn.huge.module.mediate.dto.WechatBindCaseDTO;
import cn.huge.module.sys.dto.FileIdTypeInfoBaseDTO;
import cn.huge.module.sys.dto.QueAddrBaseDTO;
import cn.huge.module.sys.dto.QueAreaDTO;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.IOException;
import java.util.*;
import java.util.stream.Collectors;

/**
 * @author wangwh
 * @version 1.0.0
 * @title: 纠纷信息主表业务逻辑处理
 * @Description 纠纷信息主表业务逻辑处理
 * @company hugeinfo
 * @Time 2024-08-27 10:00:57
 */
@Slf4j
@Service
@Transactional(rollbackFor = Exception.class)
public class AnalysisService extends ServiceImpl<AnalysisMapper, CaseInfo> {

    @Autowired
    private CaseInfoMapper mapper;

    @Autowired
    private UtilsClientImpl utilsClient;




}