From f32123863ebd008ee172c4c39ddeab77d538c121 Mon Sep 17 00:00:00 2001 From: "semin.baek" Date: Mon, 2 Jun 2025 19:37:19 +0900 Subject: [PATCH] =?UTF-8?q?=ED=8F=AD=EC=8A=A4=EC=86=8C=ED=94=84=ED=8A=B8?= =?UTF-8?q?=20=EC=97=85=EB=AC=B4=20=EC=A7=80=EC=9B=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/docs/mapper-examples/awms/mob/mtr.xml | 337 ++++++++++++++++++ src/docs/mapper-examples/mkami/mob/mtr.xml | 233 ++++++++++++ .../settings-examples/dfxagent-ami-dev.json | 169 ++++++++- .../settings-examples/dfxagent-mkami-dev.json | 114 +++++- 4 files changed, 851 insertions(+), 2 deletions(-) create mode 100644 src/docs/mapper-examples/awms/mob/mtr.xml create mode 100644 src/docs/mapper-examples/mkami/mob/mtr.xml diff --git a/src/docs/mapper-examples/awms/mob/mtr.xml b/src/docs/mapper-examples/awms/mob/mtr.xml new file mode 100644 index 0000000..7926717 --- /dev/null +++ b/src/docs/mapper-examples/awms/mob/mtr.xml @@ -0,0 +1,337 @@ + + + + + + /* 계기관리 계기작업공사정보 수신 */ + MERGE INTO TM_MTR_MST + USING DUAL ON (HDQR_CD = #{HDQR_CD} AND CONS_NO = #{CONS_NO} AND WRK_NTTN_SEQNO = #{WRK_NTTN_SEQNO}) + WHEN NOT MATCHED THEN + INSERT ( + HDQR_CD, CONS_NO, WRK_NTTN_SEQNO, CONS_OVVW_CTT, WRK_STRT_SCHL_DT, WRK_END_SCHL_DT, BIZP_CD + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{HDQR_CD}, #{CONS_NO}, #{WRK_NTTN_SEQNO}, #{CONS_OVVW_CTT, TO_TIMESTAMP(#{WRK_STRT_SCHL_DT}, 'YYYYMMDDHH24MISS'), TO_TIMESTAMP(#{WRK_END_SCHL_DT}, 'YYYYMMDDHH24MISS'), #{BIZP_CD} + , NVL(#{MOD_ID}, 'DFXAGENT_USER'), TO_TIMESTAMP(NVL(#{MOD_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS'), NVL(#{REG_ID}, 'DFXAGENT_USER'), TO_TIMESTAMP(NVL(#{REG_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS') + ) + + + + /* 계기관리 계기작업공사현장정보 수신 */ + MERGE INTO TM_MTR_MST_DETAIL + USING DUAL ON (HDQR_CD = #{HDQR_CD} AND CONS_NO = #{CONS_NO} AND WRK_NTTN_SEQNO = #{WRK_NTTN_SEQNO}) + WHEN NOT MATCHED THEN + INSERT ( + HDQR_CD, CONS_NO, WRK_NTTN_SEQNO, ACPT_NO, WRK_PLCE_NM, WRK_PLCE_ADDR_CTT + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{HDQR_CD}, #{CONS_NO}, #{WRK_NTTN_SEQNO}, #{ACPT_NO}, #{WRK_PLCE_NM}, #{WRK_PLCE_ADDR_CTT} + , NVL(#{MOD_ID}, 'DFXAGENT_USER'), TO_TIMESTAMP(NVL(#{MOD_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS'), NVL(#{REG_ID}, 'DFXAGENT_USER'), TO_TIMESTAMP(NVL(#{REG_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS') + ) + + + + /* 계기관리 작업 대상 정보 수신 */ + MERGE INTO TM_MTR_INST + USING DUAL ON (HDQR_CD = #{HDQR_CD} AND CONS_NO = #{CONS_NO} AND CONS_TGT_SEQNO = #{CONS_TGT_SEQNO}) + WHEN NOT MATCHED THEN + INSERT ( + HDQR_CD, CONS_NO, CONS_TGT_SEQNO, WORK_STEP, LAY_STS_CD, LAY_METR_CL_CD, OFFICE_CD, TGT_YEAR, CNTR_NO, WHM_NO, WHM_SEQNO, PLAN_CONS_KND_CD, ACPT_YMD, ACPT_SEQNO, DIST_LV_HV_CLCD, CNTR_CLAS_CD, CNTR_PWR, BUPE_ID + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{HDQR_CD}, #{CONS_NO}, #{CONS_TGT_SEQNO}, #{WORK_STEP}, #{LAY_STS_CD}, #{LAY_METR_CL_CD}, #{OFFICE_CD}, #{TGT_YEAR}, #{CNTR_NO}, #{WHM_NO}, #{WHM_SEQNO}, #{PLAN_CONS_KND_CD}, #{ACPT_YMD}, #{ACPT_SEQNO}, #{DIST_LV_HV_CLCD}, #{CNTR_CLAS_CD}, #{CNTR_PWR}, #{BUPE_ID} + , NVL(#{MOD_ID}, 'DFXAGENT_USER'), TO_TIMESTAMP(NVL(#{MOD_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS'), NVL(#{REG_ID}, 'DFXAGENT_USER'), TO_TIMESTAMP(NVL(#{REG_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS') + ) + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/src/docs/mapper-examples/mkami/mob/mtr.xml b/src/docs/mapper-examples/mkami/mob/mtr.xml new file mode 100644 index 0000000..4c2d05f --- /dev/null +++ b/src/docs/mapper-examples/mkami/mob/mtr.xml @@ -0,0 +1,233 @@ + + + + + + + + + + + + + + + + + + + + + + + + /* 계기관리 부설 작업 상세 정보 수신 */ + MERGE INTO T_MTR_REMO + USING DUAL ON (HDQR_CD AND CONS_NO = #{CONS_NO} AND CONS_TGT_SEQNO = #{CONS_TGT_SEQNO} AND LAY_METR_DTLS_CL_CD = #{LAY_METR_DTLS_CL_CD}) + WHEN NOT MATCHED THEN + INSERT ( + HDQR_CD, CONS_NO, CONS_TGT_SEQNO, LAY_METR_DTLS_CL_CD, WHM_NO, MATL_NO, MATL_STAT_CLCD, CHRG_APLY_ST_YMD, MANU_CD, PRDC_YM, EFEC_YM, POSS_CLCD, WHM_LOC_CD, CNTR_CLAS_CD, MR_DD, ATCH_FILE_ID_1, ATCH_FILE_ID_2, ATCH_FILE_ID_3, ATCH_FILE_ID_4, ATCH_FILE_ID_5, ATCH_FILE_ID_6, ATCH_FILE_ID_7, ATCH_FILE_ID_8, ATCH_FILE_ID_9, ATCH_FILE_ID_10, ATCH_FILE_ID_11, PGM_ID, DISM_RSN_CD, MODM_BLTIN_YN, MODEM_DIV, MODEM_MAC, WHME_STAT_CD, PURC_CLCD, DISM_YMD, LST_MR_YMD, METR_MLTV, RCA_DISM_RSN_BIGCSS_CD, RCA_DISM_RSN_MEDI_CD, RCA_DISM_RSN_MICL_CD, RCA_DISM_RSN_CD, RCA_BAD_CS_BIGCSS_CD, RCA_BAD_CS_MEDI_CD, RCA_BAD_CS_CD, RCA_ETC_RSN, DFCT_CLCD, OTSD_DISM_YN, WHM_REFE_CLCD, WHM_REFEMO, MODEM_REFEMO, REFEMO + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{HDQR_CD}, #{CONS_NO}, #{CONS_TGT_SEQNO}, #{LAY_METR_DTLS_CL_CD}, #{WHM_NO}, #{MATL_NO}, #{MATL_STAT_CLCD}, #{CHRG_APLY_ST_YMD}, #{MANU_CD}, #{PRDC_YM}, #{EFEC_YM}, #{POSS_CLCD}, #{WHM_LOC_CD}, #{CNTR_CLAS_CD}, #{MR_DD}, #{ATCH_FILE_ID_1}, #{ATCH_FILE_ID_2}, #{ATCH_FILE_ID_3}, #{ATCH_FILE_ID_4}, #{ATCH_FILE_ID_5}, #{ATCH_FILE_ID_6}, #{ATCH_FILE_ID_7}, #{ATCH_FILE_ID_8}, #{ATCH_FILE_ID_9}, #{ATCH_FILE_ID_10}, #{ATCH_FILE_ID_11}, #{PGM_ID}, #{DISM_RSN_CD}, #{MODM_BLTIN_YN}, #{MODEM_DIV}, #{MODEM_MAC}, #{WHME_STAT_CD}, #{PURC_CLCD}, #{DISM_YMD}, #{LST_MR_YMD}, #{METR_MLTV}, #{RCA_DISM_RSN_BIGCSS_CD}, #{RCA_DISM_RSN_MEDI_CD}, #{RCA_DISM_RSN_MICL_CD}, #{RCA_DISM_RSN_CD}, #{RCA_BAD_CS_BIGCSS_CD}, #{RCA_BAD_CS_MEDI_CD}, #{RCA_BAD_CS_CD}, #{RCA_ETC_RSN}, #{DFCT_CLCD}, #{OTSD_DISM_YN}, #{WHM_REFE_CLCD}, #{WHM_REFEMO}, #{MODEM_REFEMO}, #{REFEMO} + , NVL(#{MOD_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{MOD_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS'), NVL(#{REG_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{REG_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS') + ) + + + + /* 계기관리 부속 변류기 작업 정보 수신 */ + MERGE INTO T_MTR_CT + USING DUAL ON (HDQR_CD AND CONS_NO = #{CONS_NO} AND CONS_TGT_SEQNO = #{CONS_TGT_SEQNO} AND LAY_METR_DTLS_CL_CD = #{LAY_METR_DTLS_CL_CD}) + WHEN NOT MATCHED THEN + INSERT ( + HDQR_CD, CONS_NO, CONS_TGT_SEQNO, LAY_METR_DTLS_CL_CD, MATL_NO, TS1_CURR, TS1_CRN_SCRT_COEF, TS1_CRN_MLTV, PT_TRRT, CPT_GRADE_CD + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{HDQR_CD}, #{CONS_NO}, #{CONS_TGT_SEQNO}, #{LAY_METR_DTLS_CL_CD}, #{MATL_NO}, #{TS1_CURR}, #{TS1_CRN_SCRT_COEF}, #{TS1_CRN_MLTV}, #{PT_TRRT}, #{CPT_GRADE_CD} + , NVL(#{MOD_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{MOD_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS'), NVL(#{REG_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{REG_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS') + ) + + + + /* 계기관리 부속 변류기 상세 작업 정보 수신 */ + MERGE INTO T_MTR_CT_DETAIL + USING DUAL ON (HDQR_CD AND CONS_NO = #{CONS_NO} AND CONS_TGT_SEQNO = #{CONS_TGT_SEQNO} AND LAY_METR_DTLS_CL_CD = #{LAY_METR_DTLS_CL_CD} AND CT_SEQNO = #{CT_SEQNO}) + WHEN NOT MATCHED THEN + INSERT ( + HDQR_CD, CONS_NO, CONS_TGT_SEQNO, LAY_METR_DTLS_CL_CD, CT_SEQNO, MANU_CD, MNFCT_NO, PRDC_YM, MATL_STAT_CLCD, POSS_CLCD, WHM_LOC_CD, BAD_CS_CD, DISM_RSN_CD, PURC_CLCD, DFCT_CLCD, REFEMO + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{HDQR_CD}, #{CONS_NO}, #{CONS_TGT_SEQNO}, #{LAY_METR_DTLS_CL_CD}, #{CT_SEQNO}, #{MANU_CD}, #{MNFCT_NO}, #{PRDC_YM}, #{MATL_STAT_CLCD}, #{POSS_CLCD}, #{WHM_LOC_CD}, #{BAD_CS_CD}, #{DISM_RSN_CD}, #{PURC_CLCD}, #{DFCT_CLCD}, #{REFEMO} + , NVL(#{MOD_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{MOD_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS'), NVL(#{REG_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{REG_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS') + ) + + + + /* 계기관리 부속 타임스위치 작업 정보 수신 */ + MERGE INTO T_MTR_TS + USING DUAL ON (HDQR_CD AND CONS_NO = #{CONS_NO} AND CONS_TGT_SEQNO = #{CONS_TGT_SEQNO} AND LAY_METR_DTLS_CL_CD = #{LAY_METR_DTLS_CL_CD}) + WHEN NOT MATCHED THEN + INSERT ( + HDQR_CD, CONS_NO, CONS_TGT_SEQNO, LAY_METR_DTLS_CL_CD, MATL_NO, LV_MANU_CD, HV_MANU_CD, MNFCT_NO, PRDC_YM, MATL_STAT_CLCD, POSS_CLCD, RGCU_CD, TISW_TIZO_CLCD, LAY_YMD, BAD_CS_CD, DISM_RSN_CD, PURC_CLCD, DFCT_CLCD, REFEMO, DISM_YMD + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{HDQR_CD}, #{CONS_NO}, #{CONS_TGT_SEQNO}, #{LAY_METR_DTLS_CL_CD}, #{MATL_NO}, #{LV_MANU_CD}, #{HV_MANU_CD}, #{MNFCT_NO}, #{PRDC_YM}, #{MATL_STAT_CLCD}, #{POSS_CLCD}, #{RGCU_CD}, #{TISW_TIZO_CLCD}, #{LAY_YMD}, #{BAD_CS_CD}, #{DISM_RSN_CD}, #{PURC_CLCD}, #{DFCT_CLCD}, #{REFEMO}, #{DISM_YMD} + , NVL(#{MOD_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{MOD_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS'), NVL(#{REG_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{REG_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS') + ) + + + + /* 계기관리 부속 전자접촉기 작업 정보 수신 */ + MERGE INTO T_MTR_MS + USING DUAL ON (HDQR_CD AND CONS_NO = #{CONS_NO} AND CONS_TGT_SEQNO = #{CONS_TGT_SEQNO} AND LAY_METR_DTLS_CL_CD = #{LAY_METR_DTLS_CL_CD}) + WHEN NOT MATCHED THEN + INSERT ( + HDQR_CD, CONS_NO, CONS_TGT_SEQNO, LAY_METR_DTLS_CL_CD, MATL_NO, MANU_CD, MNFCT_NO, PRDC_YM, MATL_STAT_CLCD, ELEC_SW_MGNT_CNT_CD, MS_RGCU_CD, TISW_TIZO_CLCD, LAY_YMD, POSS_CLCD, BIST_CLCD, BAD_CS_CD, DISM_RSN_CD, PURC_CLCD, DFCT_CLCD, REFEMO + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{HDQR_CD}, #{CONS_NO}, #{CONS_TGT_SEQNO}, #{LAY_METR_DTLS_CL_CD}, #{MATL_NO}, #{MANU_CD}, #{MNFCT_NO}, #{PRDC_YM}, #{MATL_STAT_CLCD}, #{ELEC_SW_MGNT_CNT_CD}, #{MS_RGCU_CD}, #{TISW_TIZO_CLCD}, #{LAY_YMD}, #{POSS_CLCD}, #{BIST_CLCD}, #{BAD_CS_CD}, #{DISM_RSN_CD}, #{PURC_CLCD}, #{DFCT_CLCD}, #{REFEMO} + , NVL(#{MOD_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{MOD_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS'), NVL(#{REG_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{REG_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS') + ) + + + + /* 계기관리 부속 계기함 작업 정보 수신 */ + MERGE INTO T_MTR_MB + USING DUAL ON (HDQR_CD AND CONS_NO = #{CONS_NO} AND CONS_TGT_SEQNO = #{CONS_TGT_SEQNO} AND LAY_METR_DTLS_CL_CD = #{LAY_METR_DTLS_CL_CD}) + WHEN NOT MATCHED THEN + INSERT ( + HDQR_CD, CONS_NO, CONS_TGT_SEQNO, LAY_METR_DTLS_CL_CD, MATL_NO, POSS_CLCD, DISM_RSN_CD, PURC_CLCD + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + {HDQR_CD}, #{CONS_NO}, #{CONS_TGT_SEQNO}, #{LAY_METR_DTLS_CL_CD}, #{MATL_NO}, #{POSS_CLCD}, #{DISM_RSN_CD}, #{PURC_CLCD} + , NVL(#{MOD_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{MOD_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS'), NVL(#{REG_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{REG_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS') + ) + + + + /* 계기관리 부속 SPD 작업 정보 수신 */ + MERGE INTO T_MTR_SPD + USING DUAL ON (HDQR_CD AND CONS_NO = #{CONS_NO} AND CONS_TGT_SEQNO = #{CONS_TGT_SEQNO} AND LAY_METR_DTLS_CL_CD = #{LAY_METR_DTLS_CL_CD}) + WHEN NOT MATCHED THEN + INSERT ( + HDQR_CD, CONS_NO, CONS_TGT_SEQNO, LAY_METR_DTLS_CL_CD, MATL_NO, MANU_CD, MNFCT_NO, PRDC_YM, MATL_STAT_CLCD, POSS_CLCD, LAY_YMD, BAD_CS_CD, DISM_RSN_CD, PURC_CLCD, DFCT_CLCD, REFEMO + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{HDQR_CD}, #{CONS_NO}, #{CONS_TGT_SEQNO}, #{LAY_METR_DTLS_CL_CD}, #{MATL_NO}, #{MANU_CD}, #{MNFCT_NO}, #{PRDC_YM}, #{MATL_STAT_CLCD}, #{POSS_CLCD}, #{LAY_YMD}, #{BAD_CS_CD}, #{DISM_RSN_CD}, #{PURC_CLCD}, #{DFCT_CLCD}, #{REFEMO} + , NVL(#{MOD_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{MOD_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS'), NVL(#{REG_ID}, 'DFXAGENT_USER'), TO_DATE(NVL(#{REG_DATE}, TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')), 'YYYYMMDDHH24MISS') + ) + + + diff --git a/src/docs/settings-examples/dfxagent-ami-dev.json b/src/docs/settings-examples/dfxagent-ami-dev.json index 1e0aeeb..f0bbfc4 100644 --- a/src/docs/settings-examples/dfxagent-ami-dev.json +++ b/src/docs/settings-examples/dfxagent-ami-dev.json @@ -17,7 +17,13 @@ "dropbox-fox-mkami-dev-oracle-receive-sigong-act-modem-list", "dropbox-fox-mkami-dev-oracle-receive-sigong-unable-dcu-list", "dropbox-fox-mkami-dev-oracle-receive-sigong-unable-modem-list", - "dropbox-fox-mkami-dev-oracle-receive-meter-ndl-act-list" + "dropbox-fox-mkami-dev-oracle-receive-meter-ndl-act-list", + "dropbox-fox-mkami-dev-oracle-receive-mtr-remo-list", + "dropbox-fox-mkami-dev-oracle-receive-mtr-ct-list", + "dropbox-fox-mkami-dev-oracle-receive-mtr-ct-detail-list", + "dropbox-fox-mkami-dev-oracle-receive-mtr-ts-list", + "dropbox-fox-mkami-dev-oracle-receive-mtr-ms-list", + "dropbox-fox-mkami-dev-oracle-receive-mtr-mb-list" ] } ], @@ -163,6 +169,27 @@ "dataSourceId": "ds-cubrid", "sqlId": "com.kdn.awms.mob.emr.insertMeterNdlLstListForReceive", "description": "임시조치 전월검침정보(데이터) 수신" + }, + { + "dropBoxId": "dropbox-fox-ami-dev-cubrid-receive-mtr-mst-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.insertMtrMstListForReceive", + "description": "계기관리 계기작업공사정보 수신" + }, + { + "dropBoxId": "dropbox-fox-ami-dev-cubrid-receive-mtr-mst-detail-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.insertMtrMstDetailListForReceive", + "description": "계기관리 계기작업공사현장정보 수신" + }, + { + "dropBoxId": "dropbox-fox-ami-dev-cubrid-receive-mtr-inst-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.insertMtrInstForReceive", + "description": "계기관리 작업 대상 정보 수신" } ] }, @@ -368,6 +395,146 @@ "fox-mkami-dev-oracle" ], "description": "임시조치 당월검침정보(데이터) 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-mtr-remo-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "2 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.selectMtrRemoListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.mtr.updateMtrRemoListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-remo-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "계기관리 부설 작업 상세 정보 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-mtr-ct-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "2 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.selectMtrCtListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.mtr.updateMtrCtListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-ct-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "계기관리 부속 변류기 작업 정보 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-mtr-ct-detail-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "2 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.selectMtrCtDetailListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.mtr.updateMtrCtDetailListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-ct-detail-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "계기관리 부속 변류기 상세 작업 정보 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-mtr-ts-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "2 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.selectMtrTsListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.mtr.updateMtrTsListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-ts-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "계기관리 부속 타임스위치 작업 정보 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-mtr-ms-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "2 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.selectMtrMsListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.mtr.updateMtrMsListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-ms-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "계기관리 부속 전자접촉기 작업 정보 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-mtr-mb-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "2 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.selectMtrMbListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.mtr.updateMtrMbListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-mb-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "계기관리 부속 계기함 작업 정보 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-mtr-spd-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "2 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.selectMtrSpdListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.mtr.updateMtrSpdListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-spd-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "계기관리 부속 SPD 작업 정보 송신" } ] } diff --git a/src/docs/settings-examples/dfxagent-mkami-dev.json b/src/docs/settings-examples/dfxagent-mkami-dev.json index 1be90a4..ae35434 100644 --- a/src/docs/settings-examples/dfxagent-mkami-dev.json +++ b/src/docs/settings-examples/dfxagent-mkami-dev.json @@ -20,7 +20,10 @@ "dropbox-fox-ami-dev-cubrid-receive-fcty-cs-meter-info-list", "dropbox-fox-ami-dev-cubrid-receive-fcty-dcu-info-list", "dropbox-fox-ami-dev-cubrid-receive-sigong-master-list", - "dropbox-fox-ami-dev-cubrid-receive-meter-ndl-lst-list" + "dropbox-fox-ami-dev-cubrid-receive-meter-ndl-lst-list", + "dropbox-fox-ami-dev-cubrid-receive-mtr-mst-list", + "dropbox-fox-ami-dev-cubrid-receive-mtr-mst-detail-list", + "dropbox-fox-ami-dev-cubrid-receive-mtr-inst-list" ] } ], @@ -131,6 +134,55 @@ "dataSourceId": "ds-oracle", "sqlId": "com.kdn.mkami.mob.emr.insertMeterNdlActListForReceive", "description": "임시조치 당월검침정보(데이터) 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-remo-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.insertMtrRemoListForReceive", + "description": "계기관리 부설 작업 상세 정보 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-ct-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.insertMtrCtListForReceive", + "description": "계기관리 부속 변류기 작업 정보 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-ct-detail-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.insertMtrCtDetailListForReceive", + "description": "계기관리 부속 변류기 상세 작업 정보 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-ts-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.insertMtrTsListForReceive", + "description": "계기관리 부속 타임스위치 작업 정보 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-ms-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.insertMtrMsListForReceive", + "description": "계기관리 부속 전자접촉기 작업 정보 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-mb-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.insertMtrMbListForReceive", + "description": "계기관리 부속 계기함 작업 정보 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-mtr-spd-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.insertMtrSpdListForReceive", + "description": "계기관리 부속 SPD 작업 정보 수신" } ] }, @@ -456,6 +508,66 @@ "fox-ami-dev-cubrid" ], "description": "임시조치 전월검침정보(데이터) 송신" + }, + { + "postmanId": "postman-fox-mkami-dev-oracle-send-mtr-mst-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "39 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.selectMtrMstListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.mtr.updateMtrMstListTransferDone" + }, + "recipientHostId": "fox-ami-dev-cubrid", + "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-mtr-mst-list", + "routingHostIdList": [ + "fox-ami-dev-cubrid" + ], + "description": "계기관리 계기작업공사정보 송신" + }, + { + "postmanId": "postman-fox-mkami-dev-oracle-send-mtr-mst-detail-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "39 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.selectMtrMstDetailListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.mtr.updateMtrMstDetailListTransferDone" + }, + "recipientHostId": "fox-ami-dev-cubrid", + "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-mtr-mst-detail-list", + "routingHostIdList": [ + "fox-ami-dev-cubrid" + ], + "description": "계기관리 계기작업공사현장정보 송신" + }, + { + "postmanId": "postman-fox-mkami-dev-oracle-send-mtr-inst-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "39 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.selectMtrInstListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.mtr.updateMtrInstListTransferDone" + }, + "recipientHostId": "fox-ami-dev-cubrid", + "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-mtr-inst-list", + "routingHostIdList": [ + "fox-ami-dev-cubrid" + ], + "description": "계기관리 작업 대상 정보 송신" } ] }