diff --git a/shuili-system/src/main/java/com/kms/yg/sz/mapper/BsSgcSzGcdaMapper.java b/shuili-system/src/main/java/com/kms/yg/sz/mapper/BsSgcSzGcdaMapper.java index fef24b0e..38a01437 100644 --- a/shuili-system/src/main/java/com/kms/yg/sz/mapper/BsSgcSzGcdaMapper.java +++ b/shuili-system/src/main/java/com/kms/yg/sz/mapper/BsSgcSzGcdaMapper.java @@ -30,7 +30,7 @@ public interface BsSgcSzGcdaMapper extends BaseMapper { "and waga_name like concat('%', #{dto.wagaName}, '%') ", "", "", - "and FIND_IN_SET(#{dto.wagaType} , REPLACE(REPLACE(REPLACE(WAGA_TYPE, '[', ''), ']', ''), '\"', '')) ", + "and WAGA_TYPE = #{dto.wagaType} ", "", "", "and adcd = #{dto.adcd} ", diff --git a/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfDangerousTaskItemRelMapper.java b/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfDangerousTaskItemRelMapper.java index 4570746d..51f2e7e2 100644 --- a/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfDangerousTaskItemRelMapper.java +++ b/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfDangerousTaskItemRelMapper.java @@ -51,13 +51,13 @@ public interface DfDangerousTaskItemRelMapper extends BaseMapper" + "WHERE xx.expr_date is null " + "" + - "AND FIND_IN_SET(#{dto.dikeType} , REPLACE(REPLACE(REPLACE(xx.DIKE_TYPE, '[', ''), ']', ''), '\"', '')) " + + "AND xx.dike_type = #{dto.dikeType} " + "" + "" + "AND rw.id = #{dto.id} " + "" + "" + - "AND xx.river_location = #{dto.riverLocation} " + + "AND xx.DIKE_RIVER = #{dto.riverLocation} " + "" + "" + "AND (xx.ADCD_START = #{dto.adcdStart} OR xx.ADCD_START in (SELECT xzqhdm from sys_xzqh where parentid =#{dto.adcdStart}) " + diff --git a/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfDangerousTaskMapper.java b/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfDangerousTaskMapper.java index e5246d65..a263c43d 100644 --- a/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfDangerousTaskMapper.java +++ b/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfDangerousTaskMapper.java @@ -24,13 +24,11 @@ public interface DfDangerousTaskMapper extends BaseMapper { @Select("" }) @@ -115,7 +107,6 @@ public interface DfDangerousTaskMapper extends BaseMapper { @Result(property = "dikeGrad", column = "dike_grad"), @Result(property = "dikePatt", column = "dike_patt"), @Result(property = "engineeringManagementUnit", column = "engineering_management_unit"), - @Result(property = "waterAdministrativeDepartment", column = "water_administrative_department"), @Result(property = "identifyTime", column = "identify_time"), @Result(property = "securityCategory", column = "security_category"), @Result(property = "safetyAppraisalOpinion", column = "safety_appraisal_opinion"), @@ -125,43 +116,43 @@ public interface DfDangerousTaskMapper extends BaseMapper { @Select("") @@ -170,23 +161,23 @@ public interface DfDangerousTaskMapper extends BaseMapper { @Select("") DfDangerousTotalDto selectCountByTaskTotal(@Param("dto") DfDangerousTaskSearchDto dto); diff --git a/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfSuperviseProblemMapper.java b/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfSuperviseProblemMapper.java index ac3072cb..2846df01 100644 --- a/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfSuperviseProblemMapper.java +++ b/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfSuperviseProblemMapper.java @@ -55,15 +55,13 @@ public interface DfSuperviseProblemMapper extends BaseMapper class DfSuperviseProblemProvider { public String selectPage(final Map param) { return new SQL() {{ - SELECT("wt.id,xm.name as projectName,rw.name,nr.content,xx.adcd,xx.DIKE_CODE as dikeCode, xx.DIKE_NAME as dikeName," + - "xx.engineering_management_unit as engineeringManagementUnit,xx.ADCD_START as adcdStart, xx.ADCD_END as adcdEnd,wt.level, wt.status"); + SELECT("wt.id,xm.name as projectName,rw.name,nr.content,xx.adcd,xx.DIKE_CODE as dikeCode, xx.DIKE_NAME as dikeName,xx.adm_dep as engineeringManagementUnit,wt.level, wt.status"); FROM("bs_sgc_df_jdjcgcwt wt"); LEFT_OUTER_JOIN("bs_sgc_df_jdjcbfxm xm on wt.project_id = xm.id"); LEFT_OUTER_JOIN("bs_sgc_df_jdjcbfxmnr nr on wt.project_item_id = nr.id"); LEFT_OUTER_JOIN("bs_sgc_df_jdjcrw rw on wt.TASK_ID = rw.id"); - LEFT_OUTER_JOIN("(SELECT DISTINCT xx.ID,xx.DIKE_CODE,xx.DIKE_NAME,xx.ADCD_START,xx.ADCD_END,xx.adcd,gl.engineering_management_unit " + - " FROM bs_sgc_df_gcda xx LEFT OUTER JOIN bs_sgc_df_gcgl gl ON xx.dike_code = gl.dike_code " + - " WHERE xx.EXPR_DATE IS NULL AND gl.EXPR_DATE IS NULL) xx ON rw.dike_code = xx.DIKE_CODE"); + LEFT_OUTER_JOIN("(SELECT DISTINCT xx.ID,xx.DIKE_CODE,xx.DIKE_NAME,xx.adcd,xx.adm_dep " + + " FROM att_dike_base xx WHERE xx.EXPR_DATE IS NULL ) xx ON rw.dike_code = xx.DIKE_CODE"); WHERE("1=1"); WHERE("rw.state =1"); @@ -75,7 +73,7 @@ public interface DfSuperviseProblemMapper extends BaseMapper } // 管理单位 if (StringUtils.isNotBlank(dto.getEngineeringManagementUnit())) { - WHERE("xx.engineering_management_unit LIKE CONCAT('%', #{dto.engineeringManagementUnit}, '%')"); + WHERE("xx.adm_dep LIKE CONCAT('%', #{dto.engineeringManagementUnit}, '%')"); } // 工程对象 if (StringUtils.isNotBlank(dto.getDikeName())) { @@ -98,13 +96,6 @@ public interface DfSuperviseProblemMapper extends BaseMapper } } - // 判断bs_sgc_df_gcda的adcdStart是否等于sys_xzqh的xzqhdm,或者是否等于xzqhdm的parentid,以及根据parentId获取xzqhdm查询是否等于adcdStart - - - - - - /** * 监督检查任务统计分析 * @param dto @@ -116,13 +107,13 @@ public interface DfSuperviseProblemMapper extends BaseMapper "sum(IF(wt.level='1', 1, 0)) as same,sum(IF(wt.level='2', 1, 0)) as heavy,sum(IF(wt.level='3', 1, 0)) as serious "+ "FROM bs_sgc_df_jdjcgcwt wt " + "LEFT JOIN bs_sgc_df_jdjcrw rw on wt.TASK_ID = rw.id " + - "LEFT JOIN bs_sgc_df_gcda xx on xx.dike_code = rw.dike_code " + + "LEFT JOIN att_dike_base xx on xx.dike_code = rw.dike_code " + "" + "LEFT JOIN sys_xzqh xzqh on xzqh.xzqhdm=#{dto.adcdStart} " + "" + "WHERE xx.EXPR_DATE IS NULL " + "" + - "AND FIND_IN_SET(#{dto.dikeType} , REPLACE(REPLACE(REPLACE(xx.dike_type, '[', ''), ']', ''), '\"', '')) " + + "AND xx.dike_type = #{dto.dikeType} " + "" + "" + "AND xx.river_location = #{dto.riverLocation} " + @@ -131,8 +122,8 @@ public interface DfSuperviseProblemMapper extends BaseMapper "AND wt.task_id = #{dto.taskId} " + "" + "" + - "AND (xx.ADCD_START = #{dto.adcdStart} OR xx.ADCD_START in (SELECT xzqhdm from sys_xzqh where parentid =#{dto.adcdStart}) " + - " or xx.ADCD_START in (select xzqhdm from sys_xzqh where parentid in(SELECT xzqhdm from sys_xzqh where parentid = #{dto.adcdStart}))) " + + "AND (xx.adcd = #{dto.adcdStart} OR xx.adcd in (SELECT xzqhdm from sys_xzqh where parentid =#{dto.adcdStart}) " + + " or xx.adcd in (select xzqhdm from sys_xzqh where parentid in(SELECT xzqhdm from sys_xzqh where parentid = #{dto.adcdStart}))) " + "" + "") DfSuperviseProblemTotalDto countProblemTotal(@Param("dto") DfSuperviseProblemListDto dto); diff --git a/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfSuperviseTaskMapper.java b/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfSuperviseTaskMapper.java index 077c5123..d246af9e 100644 --- a/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfSuperviseTaskMapper.java +++ b/shuili-system/src/main/java/com/kms/yxgh/df/mapper/DfSuperviseTaskMapper.java @@ -37,12 +37,10 @@ public interface DfSuperviseTaskMapper extends BaseMapper { class DfSuperviseTaskProvider { public String selectPage(final Map param) { return new SQL() {{ - SELECT("rw.id, rw.name, rw.CREATE_TIME as createTime, rw.UPDATE_TIME as updateTime,xx.DIKE_NAME as dikeName,gl.ENGINEERING_MANAGEMENT_UNIT as engineeringManagementUnit," + + SELECT("rw.id, rw.name, rw.CREATE_TIME as createTime, rw.UPDATE_TIME as updateTime,xx.DIKE_NAME as dikeName,xx.adm_dep as engineeringManagementUnit," + "rw.dike_code as dikeCode, rw.TASK_TIME as taskTime, rw.INSPECTORS as inspectors, rw.WAY_ID as wayId, rw.START_TIME as startTime, rw.DONE_TIME as doneTime, rw.state "); FROM("bs_sgc_df_jdjcrw rw"); - LEFT_OUTER_JOIN("bs_sgc_df_gcda xx ON xx.dike_code = rw.dike_code"); - LEFT_OUTER_JOIN("bs_sgc_df_gcgl gl on xx.dike_code = gl.dike_code "); - WHERE("gl.EXPR_DATE is null"); + LEFT_OUTER_JOIN("att_dike_base xx ON xx.dike_code = rw.dike_code"); WHERE("xx.EXPR_DATE is null"); if (param.get("dto") != null) { DfSuperviseTaskDto dto = (DfSuperviseTaskDto) param.get("dto"); @@ -53,7 +51,7 @@ public interface DfSuperviseTaskMapper extends BaseMapper { WHERE("rw.name LIKE CONCAT('%',#{dto.name},'%')"); } if (StringUtils.isNotBlank(dto.getEngineeringManagementUnit())) { - WHERE("gl.ENGINEERING_MANAGEMENT_UNIT like concat('%', #{dto.engineeringManagementUnit}, '%')"); + WHERE("xx.adm_dep like concat('%', #{dto.engineeringManagementUnit}, '%')"); } if(StringUtils.isNotBlank(dto.getDikeName())){ WHERE("xx.dike_name LIKE CONCAT('%',#{dto.dikeName},'%')"); @@ -76,14 +74,12 @@ public interface DfSuperviseTaskMapper extends BaseMapper { class DfSuperviseTaskDetailProvider { public String selectTaskInfo(final Map param) { return new SQL() {{ - SELECT("rw.id, rw.name, rw.CREATE_TIME as createTime,rw.weather,rw.inspectors,xx.DIKE_NAME as dikeName,gl.ENGINEERING_MANAGEMENT_UNIT as engineeringManagementUnit,rw.state,rw.content," + + SELECT("rw.id, rw.name, rw.CREATE_TIME as createTime,rw.weather,rw.inspectors,xx.DIKE_NAME as dikeName,xx.adm_dep as engineeringManagementUnit,rw.state,rw.content," + "rw.INSPECTORS as inspectors, rw.WAY_ID as wayId, rw.START_TIME as startTime, rw.DONE_TIME as doneTime,rw.PATROL_UID as patrolUid, rw.PATROL_NAME as patrolName," + "xx.DIKE_NAME as dikeName, xx.DIKE_CODE as dikeCode, xx.DIKE_TYPE as dikeType, " + "(SELECT GROUP_CONCAT(user_name) FROM sys_user tr WHERE FIND_IN_SET(tr.id,(SELECT INSPECTORS FROM bs_sgc_sz_jdjcrw WHERE id=rw.id))) AS inspectorsName"); FROM("bs_sgc_df_jdjcrw rw"); - LEFT_OUTER_JOIN("bs_sgc_df_gcda xx ON xx.dike_code = rw.dike_code"); - LEFT_OUTER_JOIN("bs_sgc_df_gcgl gl ON gl.dike_code = xx.dike_code"); - WHERE("gl.EXPR_DATE is null"); + LEFT_OUTER_JOIN("att_dike_base xx ON xx.dike_code = rw.dike_code"); WHERE("xx.EXPR_DATE is null"); DfSuperviseTaskDto dto = (DfSuperviseTaskDto) param.get("dto"); if (dto != null) { diff --git a/shuili-system/src/main/java/com/kms/yxgh/sz/mapper/SzDangerousTaskItemRelMapper.java b/shuili-system/src/main/java/com/kms/yxgh/sz/mapper/SzDangerousTaskItemRelMapper.java index a1fb9bba..3d5d6f68 100644 --- a/shuili-system/src/main/java/com/kms/yxgh/sz/mapper/SzDangerousTaskItemRelMapper.java +++ b/shuili-system/src/main/java/com/kms/yxgh/sz/mapper/SzDangerousTaskItemRelMapper.java @@ -44,13 +44,13 @@ public interface SzDangerousTaskItemRelMapper extends BaseMapper" + "LEFT JOIN sys_xzqh xzqh on xzqh.xzqhdm=#{dto.adcd} " + "" + "WHERE xx.expr_date is null " + "" + - "AND FIND_IN_SET(#{dto.wagaType} , REPLACE(REPLACE(REPLACE(xx.WAGA_TYPE, '[', ''), ']', ''), '\"', '')) " + + "AND xx.waga_type = #{dto.wagaType} " + "" + "" + "AND rw.id = #{dto.id} " + diff --git a/shuili-system/src/main/java/com/kms/yxgh/sz/mapper/SzDangerousTaskMapper.java b/shuili-system/src/main/java/com/kms/yxgh/sz/mapper/SzDangerousTaskMapper.java index 509575df..babf4e1e 100644 --- a/shuili-system/src/main/java/com/kms/yxgh/sz/mapper/SzDangerousTaskMapper.java +++ b/shuili-system/src/main/java/com/kms/yxgh/sz/mapper/SzDangerousTaskMapper.java @@ -24,13 +24,11 @@ public interface SzDangerousTaskMapper extends BaseMapper { @Select("" }) @@ -113,7 +107,6 @@ public interface SzDangerousTaskMapper extends BaseMapper { @Result(property = "engScal", column = "eng_scal"), @Result(property = "mainBuildGrad", column = "main_build_grad"), @Result(property = "engineeringManagementUnit", column = "engineering_management_unit"), - @Result(property = "waterAdministrativeDepartment", column = "water_administrative_department"), @Result(property = "identifyTime", column = "identify_time"), @Result(property = "securityCategory", column = "security_category"), @Result(property = "safetyAppraisalOpinion", column = "safety_appraisal_opinion"), @@ -122,7 +115,7 @@ public interface SzDangerousTaskMapper extends BaseMapper { IPage selectByAqjdPage(Page page, @Param("dto") SzAqjdProjecDto dto); @Select("") @@ -161,13 +154,13 @@ public interface SzDangerousTaskMapper extends BaseMapper { @Select("