Commit 726438e7 authored by suhuiguang's avatar suhuiguang

refact(3库刷新) :优化

1.执行速度调优
parent 92ea3cc2
......@@ -57,7 +57,7 @@ public class EquipmentRefreshHandler implements IDataRefreshHandler {
case UPDATE:
String record = message.getDataId();
ESEquipmentInfo esEquipmentInfo = new ESEquipmentInfo();
Map<String, Object> detail = useInfoService.getBaseMapper().queryDetail(record);
Map<String, Object> detail = useInfoService.getBaseMapper().queryDetailSimple(record);
if(detail == null) {
return;
}
......
......@@ -37,6 +37,8 @@ public interface IdxBizJgUseInfoMapper extends CustomBaseMapper<IdxBizJgUseInfo>
Map<String,Object> queryDetail(@Param("record") String record);
Map<String,Object> queryDetailSimple(@Param("record") String record);
List<Map<String,Object>> queryDetailBatch(@Param("records") List<String> records);
Page<String> selectAddDataRecords(Page<String> page);
......
......@@ -111,6 +111,10 @@
WHERE
ibjui."RECORD" = #{record}
</select>
<select id="queryDetailSimple" resultType="java.util.Map">
<include refid="equip-detail-es-simple"/>
WHERE ibjui."RECORD" = #{record}
</select>
<select id="getUsePlaceAndCodeByRecord" resultType="com.alibaba.fastjson.JSONObject">
SELECT concat_ws('/', ibjui."PROVINCE_NAME", ibjui."CITY_NAME", ibjui."COUNTY_NAME",
ibjui."STREET_NAME") AS "USE_PLACE",
......@@ -132,6 +136,79 @@
])
</update>
<sql id="equip-detail-es-simple">
SELECT
ibjui."RECORD" AS "SEQUENCE_NBR",
ibjui."PROJECT_CONTRAPTION",
ibjui."PROJECT_CONTRAPTION_ID",
ibjui."REC_DATE",
ibjui."USE_UNIT_NAME",
ibjui."USE_UNIT_CREDIT_CODE",
ibjui."USE_INNER_CODE",
ibjui."DATA_SOURCE",
ibjui."CREATE_DATE" ,
ibjui."SAFETY_MANAGER" ,
ibjui."PHONE",
ibjui."USE_DATE",
ibjui."USE_PLACE" as USE_SITE_CODE,
ibjui."DATA_QUALITY_SCORE",
ibjui."IS_NOT_ES",
concat_ws ( '/', ibjui."PROVINCE_NAME", ibjui."CITY_NAME", ibjui."COUNTY_NAME", ibjui."STREET_NAME" ) AS "USE_PLACE",
concat_ws ( '#', ibjui."PROVINCE", ibjui."CITY", ibjui."COUNTY", ibjui."FACTORY_USE_SITE_STREET" ) AS "USE_PLACE_CODE",
ibjui."ADDRESS",
ibjui."EQU_STATE",
ibjui."IS_INTO_MANAGEMENT",
ibjui."USC_UNIT_CREDIT_CODE",
ibjui."USC_UNIT_NAME",
ibjri."EQU_CODE",
ibjri."WHETHER_VEHICLE_CYLINDER",
ibjri."WHETHER_SKID_MOUNTED_PRESSURE_VESSEL",
ibjri."CYLINDER_CATEGORY",
ibjri."WHETHER_SPHERICAL_TANK",
ibjri."CAR_NUMBER",
ibjri."EQU_PRICE",
ibjri."EQU_LIST" AS "EQU_LIST_CODE",
ibjri."EQU_DEFINE" AS "EQU_DEFINE_CODE",
ibjri."PRODUCT_NAME",
ibjri."BRAND_NAME",
ibjri."EQU_TYPE",
ibjri."EQU_CATEGORY" AS "EQU_CATEGORY_CODE",
ibjri."TAG1" AS tag1,
ibjri."USE_ORG_CODE",
ibjsi."ORG_BRANCH_NAME",
ibjsi."ORG_BRANCH_CODE",
ibjfi."FACTORY_NUM",
ibjfi."PRODUCE_UNIT_NAME",
ibjfi."PRODUCE_UNIT_CREDIT_CODE",
ibjfi."PRODUCE_DATE",
ibjoi."CODE96333",
ibjoi."SUPERVISORY_CODE",
ibjoi."CLAIM_STATUS" AS "STATUS",
ibjoi."STATUS" AS problemStatus,
ibjoi."INFORMATION_SITUATION",
ibjoi."EDIT_STATUS",
di."DESIGN_UNIT_CREDIT_CODE",
di."DESIGN_UNIT_NAME",
di."DESIGN_DATE",
tec2.NAME AS "EQU_DEFINE",
tec1.NAME AS "EQU_LIST",
tec.NAME AS "EQU_CATEGORY",
construction_info."CONSTRUCTION_TYPE",
construction_info."USC_DATE",
inspection_info."INSPECT_REPORT",
inspection_info."NEXT_INSPECT_DATE"
FROM
idx_biz_jg_use_info ibjui
LEFT JOIN idx_biz_jg_supervision_info ibjsi ON ibjui."RECORD" = ibjsi."RECORD"
LEFT JOIN idx_biz_jg_register_info ibjri ON ibjui."RECORD" = ibjri."RECORD"
LEFT JOIN idx_biz_jg_other_info ibjoi ON ibjui."RECORD" = ibjoi."RECORD"
LEFT JOIN idx_biz_jg_factory_info ibjfi ON ibjui."RECORD" = ibjfi."RECORD"
LEFT JOIN idx_biz_jg_design_info di ON di."RECORD" = ibjui."RECORD"
LEFT JOIN tz_equipment_category tec ON ibjri."EQU_CATEGORY" = tec.code
LEFT JOIN tz_equipment_category tec1 ON ibjri."EQU_LIST" = tec1.code
LEFT JOIN tz_equipment_category tec2 ON ibjri."EQU_DEFINE" = tec2.code
</sql>
<sql id="equip-detail-es">
SELECT
ibjui."RECORD" AS "SEQUENCE_NBR",
......@@ -154,6 +231,8 @@
ibjui."ADDRESS",
ibjui."EQU_STATE",
ibjui."IS_INTO_MANAGEMENT",
ibjui."USC_UNIT_CREDIT_CODE",
ibjui."USC_UNIT_NAME",
ibjri."EQU_CODE",
ibjri."WHETHER_VEHICLE_CYLINDER",
ibjri."WHETHER_SKID_MOUNTED_PRESSURE_VESSEL",
......@@ -187,8 +266,6 @@
tec2.NAME AS "EQU_DEFINE",
tec1.NAME AS "EQU_LIST",
tec.NAME AS "EQU_CATEGORY",
construction_info."USC_UNIT_CREDIT_CODE",
construction_info."USC_UNIT_NAME",
construction_info."CONSTRUCTION_TYPE",
construction_info."USC_DATE",
inspection_info."INSPECT_REPORT",
......@@ -213,14 +290,14 @@
FROM amos_tzs_biz.idx_biz_jg_inspection_detection_info
ORDER BY "RECORD", "INSPECT_DATE" DESC NULLS LAST
) inspection_info ON ibjui."RECORD" = inspection_info."RECORD"
LEFT JOIN amos_tzs_biz.idx_biz_jg_supervision_info ibjsi ON ibjui."RECORD" = ibjsi."RECORD"
LEFT JOIN amos_tzs_biz.idx_biz_jg_register_info ibjri ON ibjui."RECORD" = ibjri."RECORD"
LEFT JOIN amos_tzs_biz.idx_biz_jg_other_info ibjoi ON ibjui."RECORD" = ibjoi."RECORD"
LEFT JOIN amos_tzs_biz.idx_biz_jg_factory_info ibjfi ON ibjui."RECORD" = ibjfi."RECORD"
LEFT JOIN amos_tzs_biz.idx_biz_jg_design_info di ON di."RECORD" = ibjui."RECORD"
LEFT JOIN amos_tzs_biz.tz_equipment_category tec ON ibjri."EQU_CATEGORY" = tec.code
LEFT JOIN amos_tzs_biz.tz_equipment_category tec1 ON ibjri."EQU_LIST" = tec1.code
LEFT JOIN amos_tzs_biz.tz_equipment_category tec2 ON ibjri."EQU_DEFINE" = tec2.code
LEFT JOIN idx_biz_jg_supervision_info ibjsi ON ibjui."RECORD" = ibjsi."RECORD"
LEFT JOIN idx_biz_jg_register_info ibjri ON ibjui."RECORD" = ibjri."RECORD"
LEFT JOIN idx_biz_jg_other_info ibjoi ON ibjui."RECORD" = ibjoi."RECORD"
LEFT JOIN idx_biz_jg_factory_info ibjfi ON ibjui."RECORD" = ibjfi."RECORD"
LEFT JOIN idx_biz_jg_design_info di ON di."RECORD" = ibjui."RECORD"
LEFT JOIN tz_equipment_category tec ON ibjri."EQU_CATEGORY" = tec.code
LEFT JOIN tz_equipment_category tec1 ON ibjri."EQU_LIST" = tec1.code
LEFT JOIN tz_equipment_category tec2 ON ibjri."EQU_DEFINE" = tec2.code
</sql>
<select id="queryDetailBatch" resultType="java.util.Map">
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment