多表联查改为用join on

zmc

2023-08-15 d95f78488e734c1defcad4af8b7e79c712937111

多表联查改为用join on

 src/main/java/com/job/zsc/controller/AnalysisDataController.java

@@ -55,8 +55,6 @@
    //去重  对from_web_analysis_data数据库
    @GetMapping("/search")
    public Result search(String shopname,String value,String begin, String end){
        String begin1=begin;
        String end1=end;
        Integer count=analysisDataService.search(shopname,value,begin,end);
        return Result.success(count);
    }

 src/main/java/com/job/zsc/mapper/Vue3FumeMapper.java

@@ -16,8 +16,7 @@

    //两张表联合查询
    @Select("select a.MV_ID,a.MV_Stat_Code,b.DI_Name,a.MV_Create_Time,a.MV_Data_Time,a.MV_Fume_Concentration2\n" +
            "from fd_t_minutevalue as a ,ea_t_device_info as b\n" +
            "where a.MV_Stat_Code = b.DI_Code ")
            "from fd_t_minutevalue as a join ea_t_device_info as b on a.MV_Stat_Code = b.DI_Code ")
    List<FumeHistoryData> findall();

    List<FumeHistoryData> conditionQuery(String devId, String beginTime, String endTime);
@@ -31,8 +30,7 @@
    List<DeviceInfo> allDeviceInfo();

    @Select("select a1.dev_id,b.DI_Name,a1.exception,a1.exception_type,a1.region,a1.begin_time,a1.end_time\n" +
            "from abnormal_data as a1,ea_t_device_info as b\n" +
            "where a1.dev_id =  b.DI_Code")
            "from abnormal_data as a1 join ea_t_device_info as b on  a1.dev_id =  b.DI_Code\n")
    List<FumeAbnormalData> allAbnormalData();

    List<FumeAbnormalData> conditonQueryAbnormalData(String devId, String beginTime, String endTime);
@@ -41,8 +39,8 @@

    //返回该异常类型对应的店铺名和设备编号
    @Select("select DISTINCT b1.DI_Name,a1.dev_id\n" +
            "from abnormal_data as a1,ea_t_device_info as b1\n" +
            "where a1.dev_id = b1.DI_Code and a1.exception_type = #{exceptionType}  ")
            "from abnormal_data as a1 join ea_t_device_info as b1 on a1.dev_id = b1.DI_Code\n" +
            "where a1.exception_type = #{exceptionType}")
    List<FumeAbnormalData> findShopName(String exceptionType);

    List<FumeHistoryData> exportByShopName(@Param("a") String[] shops, String exportBeginTime, String exportEndTime);

 src/main/resources/com/job/zsc/mapper/AnalysisDataMapper.xml

@@ -120,21 +120,19 @@

    <!-- 去重-->
    <select id="search" resultType="Integer">
        select count(*) from fm_web_analysis_data
        select count(*)
        from fm_web_analysis_data as a join ea_t_device_info as b on a.fume_dev_id = b.DI_Code
        <where>
            <if test="shopname != null and shopname != '' ">
                fume_dev_id=(select fume_dev_id
                from shopname_data
                where shop_name like concat('%',#{shopname},'%'))
                a.fume_dev_id like concat('%',#{shopname},'%')
            </if>
            <if test="value != null and value != null">
                or shop_name like concat('%',#{value},'%')
                and b.DI_Name = #{value}
            </if>

            <if test="begin != null and end != null">
                and (fume_date between #{begin} and #{end})
                and a.fume_date between #{begin} and #{end}
            </if>
        </where>
        group by fume_dev_id
    </select>
</mapper>

 src/main/resources/com/job/zsc/mapper/FugitiveDustMapper.xml

@@ -43,28 +43,6 @@
    </select>


<!--    根据站点名字和时段进行统计分析-->
<!--    <select id="analysisByTime" resultType="com.job.zsc.pojo.AnalysisDustData">-->
<!--        select-->
<!--        a.mn_code as mn_code,-->
<!--        DATE(a.lst) as lst,-->
<!--        ROUND(AVG(a.dust_value),3)  as day_avg,-->
<!--        CONCAT(ROUND(COUNT(*)/96*100, 2), '%')  as day_online,-->
<!--        CONCAT(ROUND(SUM(CASE WHEN a.dust_value >0 THEN 1 ELSE 0 END)/COUNT(*) *100, 2), '%') as day_valid,-->
<!--        CONCAT(ROUND(SUM(CASE WHEN a.dust_value >= 1  THEN 1 ELSE 0 END)/96*100,2),'%') as  day_exceeding-->
<!--        from ja_t_dust_site_data_info as a join ja_t_dust_site_info as b on a.mn_code = b.mn_code-->
<!--        <where>-->
<!--            <if test="siteName !=null and siteName != ''">-->
<!--                b.name = #{siteName}-->
<!--            </if>-->

<!--            <if test="beginTime != null and endTime != null">-->
<!--              and  a.lst between #{beginTime} and #{endTime}-->
<!--            </if>-->
<!--        </where>-->
<!--        group by a.mn_code,DATE(a.lst)-->
<!--        order by lst asc-->
<!--    </select>-->
    <!--    根据站点名字和时段进行统计分析-->
    <select id="analysisByTime" resultType="com.job.zsc.pojo.AnalysisDustData">
        select  c.name,d.*

 src/main/resources/com/job/zsc/mapper/SqlMapper.xml

@@ -10,9 +10,7 @@
            <if test="shopname != null and shopname != '' ">
                shopname like concat('%',#{shopname},'%')
            </if>
            <!--<if test="gender != null">
                and gender = #{gender}
            </if>-->

            <if test="begin != null and end != null">
                and reportingTime between #{begin} and #{end}
            </if>

 src/main/resources/com/job/zsc/mapper/Vue3FumeMapper.xml

@@ -7,12 +7,8 @@
<!--   超标油烟查询-->
    <select id="conditionQuery" resultType="com.job.zsc.pojo.FumeHistoryData">
        select a1.MV_ID,a1.MV_Stat_Code,b.DI_Name,a1.MV_Create_Time,a1.MV_Data_Time,a1.MV_Fume_Concentration2
        from exceeding_st_data as a1 , ea_t_device_info as b
        from exceeding_st_data as a1 join ea_t_device_info as b on a1.MV_Stat_Code =  b.DI_Code
        <where>
            <!--  条件为空时查询全部-->
            <if test="(devId ==null or devId == '') and (beginTime ==null and endTime == null)">
                a1.MV_Stat_Code =  b.DI_Code
            </if>

            <if test="devId != null and devId != '' ">
               and a1.MV_Stat_Code = #{devId} and b.DI_Code = #{devId}
@@ -26,25 +22,6 @@
    </select>

<!--    历史油烟查询-->
<!--    <select id="conditionQueryHistory" resultType="com.job.zsc.pojo.FumeHistoryData">-->
<!--        select a1.MV_ID,a1.MV_Stat_Code,b.DI_Name,a1.MV_Data_Time,a1.MV_Fume_Concentration2,a1.MV_Fan_Electricity,a1.MV_Purifier_Electricity-->
<!--        from fd_t_minutevalue as a1 , ea_t_device_info as b-->
<!--        <where>-->
<!--            &lt;!&ndash;  条件为空时查询全部&ndash;&gt;-->
<!--            <if test="(devId ==null or devId == '') or (beginTime ==null and endTime == null)">-->
<!--                a1.MV_Stat_Code =  b.DI_Code-->
<!--            </if>-->
<!--            <if test="devId != null and devId != '' ">-->
<!--                and a1.MV_Stat_Code = #{devId} and b.DI_Code = #{devId}-->
<!--            </if>-->

<!--            <if test="beginTime != null and endTime != null">-->
<!--                and a1.MV_Data_Time between #{beginTime} and #{endTime}-->
<!--            </if>-->
<!--        </where>-->
<!--        order by MV_Data_Time asc-->
<!--    </select>-->
    <!--    历史油烟查询-->
    <select id="conditionQueryHistory" resultType="com.job.zsc.pojo.FumeHistoryData">
        SELECT d.DI_Name, c.*
        FROM (
@@ -52,20 +29,10 @@
        FROM fd_t_minutevalue as a
        LEFT JOIN fd_t_minutevalue  as b ON a.MV_Data_Time = b.MV_Data_Time AND a.MV_Isduplication &lt; b.MV_Isduplication
        WHERE b.MV_ID IS NULL AND a.MV_Stat_Code = #{devId})
        as c,ea_t_device_info as d

<!--        CREATE TEMPORARY TABLE IF NOT EXISTS temp_table AS-->
<!--        SELECT a.*-->
<!--        FROM fd_t_minutevalue AS a-->
<!--        LEFT JOIN fd_t_minutevalue AS b ON a.MV_Data_Time = b.MV_Data_Time AND a.MV_Isduplication < b.MV_Isduplication WHERE b.MV_ID IS NULL AND a.MV_Stat_Code = 'GLHB00000000016004'-->

        as c join ea_t_device_info as d on c.MV_Stat_Code =  d.DI_Code
        <where>
            <!--  条件为空时查询全部-->
            <if test="(devId ==null or devId == '') or (beginTime ==null and endTime == null)">
                c.MV_Stat_Code =  d.DI_Code
            </if>
            <if test="devId != null and devId != '' ">
                and c.MV_Stat_Code = #{devId} and d.DI_Code = #{devId}
                and c.MV_Stat_Code = #{devId}
            </if>

            <if test="beginTime != null and endTime != null">
@@ -78,11 +45,8 @@
<!--    条件查询异常表-->
    <select id="conditonQueryAbnormalData" resultType="com.job.zsc.pojo.FumeAbnormalData">
        select a1.dev_id,b.DI_Name,a1.exception_type,a1.region,a1.begin_time,a1.end_time
        from abnormal_data as a1,ea_t_device_info as b
        from abnormal_data as a1 join ea_t_device_info as b on  a1.dev_id =  b.DI_Code
        <where>
            <if test="(devId ==null or devId == '') or (beginTime ==null and endTime == null)">
                a1.dev_id =  b.DI_Code
            </if>

            <if test="devId != null and devId != '' ">
                and a1.dev_id = #{devId} and b.DI_Code = #{devId}
@@ -99,11 +63,8 @@
    <!--    条件查询异常表 增加了异常类型选项-->
    <select id="conditonQueryAbnormalData1" resultType="com.job.zsc.pojo.FumeAbnormalData">
        select a1.dev_id,b.DI_Name,a1.exception,a1.exception_type,a1.region,a1.begin_time,a1.end_time
        from abnormal_data as a1,ea_t_device_info as b
        from abnormal_data as a1 join ea_t_device_info as b on a1.dev_id =  b.DI_Code
        <where>
            <if test="(devId ==null or devId == '') or (beginTime ==null and endTime == null)">
                a1.dev_id =  b.DI_Code
            </if>

            <if test="devId != null and devId != '' ">
                and a1.dev_id = #{devId} and b.DI_Code = #{devId}
@@ -160,11 +121,8 @@
    <!-- 条件组合查询异常表  异常类型选项改为多选-->
    <select id="conditonQueryAbnormalData2" resultType="com.job.zsc.pojo.FumeAbnormalData">
        select a1.dev_id,b.DI_Name,a1.exception,a1.exception_type,a1.region,a1.begin_time,a1.end_time
        from abnormal_data as a1,ea_t_device_info as b
        from abnormal_data as a1 join ea_t_device_info as b on  a1.dev_id =  b.DI_Code
        <where>
            <if test="(devId ==null or devId == '') or (beginTime ==null and endTime == null)">
                a1.dev_id =  b.DI_Code
            </if>

            <if test="devId != null and devId != '' ">
                and a1.dev_id = #{devId} and b.DI_Code = #{devId}
@@ -187,12 +145,8 @@
    <!-- 条件组合查询异常表  异常类型选项改为多选-->
    <select id="conditonQueryAbnormalData3" resultType="com.job.zsc.pojo.FumeAbnormalData">
        select a1.dev_id,b.DI_Name,a1.exception,a1.exception_type,a1.region,a1.begin_time,a1.end_time
        from abnormal_data as a1,ea_t_device_info as b
        from abnormal_data as a1 join ea_t_device_info as b on a1.dev_id =  b.DI_Code
        <where>
            <if test="(devId ==null or devId == '') or (beginTime ==null and endTime == null)">
                a1.dev_id =  b.DI_Code
            </if>

            <if test="devId != null and devId != '' ">
                and a1.dev_id = #{devId} and b.DI_Code = #{devId}
            </if>