From 6ef36f65203392a9c2d9699a74fab34dba85fed8 Mon Sep 17 00:00:00 2001 From: "semin.baek" Date: Mon, 2 Jun 2025 11:25:07 +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/cst.xml | 184 ++++++++++++++++++ src/docs/mapper-examples/awms/mob/emr.xml | 56 ++++++ src/docs/mapper-examples/awms/mob/obs.xml | 15 ++ src/docs/mapper-examples/mkami/mob/cst.xml | 106 ++++++++++ src/docs/mapper-examples/mkami/mob/emr.xml | 56 ++++++ src/docs/mapper-examples/mkami/mob/obs.xml | 60 ++++-- .../settings-examples/dfxagent-ami-dev.json | 123 +++++++++++- .../settings-examples/dfxagent-mkami-dev.json | 102 +++++++++- 8 files changed, 687 insertions(+), 15 deletions(-) create mode 100644 src/docs/mapper-examples/awms/mob/cst.xml create mode 100644 src/docs/mapper-examples/awms/mob/emr.xml create mode 100644 src/docs/mapper-examples/mkami/mob/cst.xml create mode 100644 src/docs/mapper-examples/mkami/mob/emr.xml diff --git a/src/docs/mapper-examples/awms/mob/cst.xml b/src/docs/mapper-examples/awms/mob/cst.xml new file mode 100644 index 0000000..9b96147 --- /dev/null +++ b/src/docs/mapper-examples/awms/mob/cst.xml @@ -0,0 +1,184 @@ + + + + + + /* AMI공사관리 공사기본정보 수신 */ + MERGE INTO TM_SIGONG_MASTER + USING DUAL ON (CONS_NO = #{CONS_NO} AND HDQR_CD = #{HDQR_CD}) + WHEN NOT MATCHED THEN + INSERT ( + CONS_NO, MCONS_NO, HDQR_CD, BROF_CD, CONS_NM, CONS_OTLN, ORGN_CONS_DDCNT, SPSR_EMPID, CSNTI_SEQNO, ACPT_YMD, CONS_BUEN_CLCD, CONS_TPCD, DESN_END_YMD, DESN_CHGER_EMPID + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{CONS_NO}, #{MCONS_NO}, #{HDQR_CD}, #{BROF_CD}, #{CONS_NM}, #{CONS_OTLN}, #{ORGN_CONS_DDCNT}, #{SPSR_EMPID}, #{CSNTI_SEQNO}, #{ACPT_YMD}, #{CONS_BUEN_CLCD}, #{CONS_TPCD}, #{DESN_END_YMD}, #{DESN_CHGER_EMPID} + , 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/awms/mob/emr.xml b/src/docs/mapper-examples/awms/mob/emr.xml new file mode 100644 index 0000000..5a18624 --- /dev/null +++ b/src/docs/mapper-examples/awms/mob/emr.xml @@ -0,0 +1,56 @@ + + + + + + /* 임시조치 전월검침정보(데이터) 수신 */ + MERGE INTO TM_METER_NDL_LST + USING DUAL ON (SEQ = #{SEQ}) + WHEN NOT MATCHED THEN + INSERT ( + SEQ, DEPT1, DEPT2, WHM_NO, CNTR_NO, RECEIVE_YM, GUM_DAY, LST_WHME_NDL_DGTS, LST_MDME_NDL_DGTS, LST_VAR_NDL_DGTS, LST_WHME_NDL_DAY_QTT, LST_DM_MT_NDL_DAY_QTT, LST_VAR_NDL_DAY_QTT, LST_WHME_NDL_EVEN_QTT, LST_DM_MT_NDL_EVEN_QTT, LST_VAR_NDL_EVEN_QTT, LST_WHME_NDL_MNGT_QTT, LST_DM_MT_NDL_MNGT_QTT, LST_VAR_NDL_MNGT_QTT, REG_DATE + ) + VALUES ( + #{SEQ}, #{DEPT1}, #{DEPT2}, #{WHM_NO}, #{CNTR_NO}, #{RECEIVE_YM}, #{GUM_DAY}, #{LST_WHME_NDL_DGTS}, #{LST_MDME_NDL_DGTS}, #{LST_VAR_NDL_DGTS}, #{LST_WHME_NDL_DAY_QTT}, #{LST_DM_MT_NDL_DAY_QTT}, #{LST_VAR_NDL_DAY_QTT}, #{LST_WHME_NDL_EVEN_QTT}, #{LST_DM_MT_NDL_EVEN_QTT}, #{LST_VAR_NDL_EVEN_QTT}, #{LST_WHME_NDL_MNGT_QTT}, #{LST_DM_MT_NDL_MNGT_QTT}, #{LST_VAR_NDL_MNGT_QTT}, TO_DATE(#{REG_DATE}, 'YYYYMMDD') + ) + + + + + + + + + diff --git a/src/docs/mapper-examples/awms/mob/obs.xml b/src/docs/mapper-examples/awms/mob/obs.xml index b4d1661..f46d95f 100644 --- a/src/docs/mapper-examples/awms/mob/obs.xml +++ b/src/docs/mapper-examples/awms/mob/obs.xml @@ -183,4 +183,19 @@ ) + + /* 유지관리 설비DCU정보 수신 */ + MERGE INTO TM_FCTY_DCU_INFO + USING DUAL ON (DEPT1 = #{DEPT1} AND M_METER_ID = #{M_METER_ID}) + WHEN NOT MATCHED THEN + INSERT ( + DCU_ID, DCU_PUBLIC_IP, DCU_USE_YN, DCU_CREATE_DATE, DCU_UPDATE_DATE, BUSI_DIV, DCU_REMOVE_DATE, TRS_FEED_NO, TRS_POLE_NO, TRS_LATITUDE, TRS_LONGITUDE, M_COMPANY, MANF_YM, DLVP_YM, NEW_MAT_NO, DEPT1, DEPT2, FAC_DIV, MODEM_CNT, METER_CNT, KDN_DEPT1, KDN_DEPT2, INST_DIV, INST_L, INST_M, INST_S, CONSIGN_YN, DEFECT_YN, CONSIGN_DATE, ROAD_ADDRESS, ADDRESS, STATE_CHANGE, B_USER, U_DCU_IP, D_MODEM_MAC, IU_DIV, GN_NAME, DCU_SERIAL, FW_BUILD_VER, BUILD_CD, N_MGMT_CD, N_MGMT_DT, BOARD_MAC, MASTER_YN, TDU_YN, TDU_PHASE, TRS_DIV, NET_MAC, NET_GW, NET_COM, NET_MASK, NET_CD, NET_CNTR_ID, COMM_CD, FCTY_CMNT + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{DCU_ID}, #{DCU_PUBLIC_IP}, #{DCU_USE_YN}, TO_TIMESTAMP(DCU_CREATE_DATE}, 'YYYYMMDDHH24MISS'), TO_TIMESTAMP(DCU_UPDATE_DATE}, 'YYYYMMDDHH24MISS'), #{BUSI_DIV}, TO_TIMESTAMP(DCU_REMOVE_DATE}, 'YYYYMMDDHH24MISS'), #{TRS_FEED_NO}, #{TRS_POLE_NO}, #{TRS_LATITUDE}, #{TRS_LONGITUDE}, #{M_COMPANY}, #{MANF_YM}, #{DLVP_YM}, #{NEW_MAT_NO}, #{DEPT1}, #{DEPT2}, #{FAC_DIV}, #{MODEM_CNT}, #{METER_CNT}, #{KDN_DEPT1}, #{KDN_DEPT2}, #{INST_DIV}, #{INST_L}, #{INST_M}, #{INST_S}, #{CONSIGN_YN}, #{DEFECT_YN}, TO_TIMESTAMP(CONSIGN_DATE}, 'YYYYMMDDHH24MISS'), #{ROAD_ADDRESS}, #{ADDRESS}, #{STATE_CHANGE}, #{B_USER}, #{U_DCU_IP}, #{D_MODEM_MAC}, #{IU_DIV}, #{GN_NAME}, #{DCU_SERIAL}, #{FW_BUILD_VER}, #{BUILD_CD}, #{N_MGMT_CD}, TO_TIMESTAMP(N_MGMT_DT}, 'YYYYMMDDHH24MISS'), #{BOARD_MAC}, #{MASTER_YN}, #{TDU_YN}, #{TDU_PHASE}, #{TRS_DIV}, #{NET_MAC}, #{NET_GW}, #{NET_COM}, #{NET_MASK}, #{NET_CD}, #{NET_CNTR_ID}, #{COMM_CD}, #{FCTY_CMNT} + , 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/cst.xml b/src/docs/mapper-examples/mkami/mob/cst.xml new file mode 100644 index 0000000..ee05536 --- /dev/null +++ b/src/docs/mapper-examples/mkami/mob/cst.xml @@ -0,0 +1,106 @@ + + + + + + + + + + + + /* AMI공사관리 시공조치내역_DCU 수신 */ + MERGE INTO T_SIGONG_ACT_DCU + USING DUAL ON (DEPT1 = #{DEPT1} AND BUSI_NUM = #{BUSI_NUM} AND DATA_NUM = #{DATA_NUM} AND EXT_DCU_ID = #{EXT_DCU_ID}) + WHEN NOT MATCHED THEN + INSERT ( + BUSI_NUM, DATA_NUM, EXT_DCU_ID, DCU_ID, WORK_STEP, GN_NAME, DEPT1, DEPT2, KDN_DEPT1, KDN_DEPT2, WORK_DIV, REMV_MEMO, INST_M, INST_S, IND_CBD_DIV_CD, FAC1, MANU_NUM, LINE_FAIR, KVA_A, KVA_B, KVA_C, USE_CT, USE_POWER, AM_BAND, FILM_BAND, GRADEL, G_WIRE, ETC, WORK_REG_ID, WORK_DATE, WORKER1_SEQ, WORKER2_SEQ, WORKER3_SEQ, INST_KIND, INST_TYPE, 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, TRF_MFG_YM_A, TRF_MFG_YM_B, TRF_MFG_YM_C, TRF_MRF_A, TRF_MRF_B, TRF_MRF_C + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{BUSI_NUM}, #{DATA_NUM}, #{EXT_DCU_ID}, #{DCU_ID}, #{WORK_STEP}, #{GN_NAME}, #{DEPT1}, #{DEPT2}, #{KDN_DEPT1}, #{KDN_DEPT2}, #{WORK_DIV}, #{REMV_MEMO}, #{INST_M}, #{INST_S}, #{IND_CBD_DIV_CD}, #{FAC1}, #{MANU_NUM}, #{LINE_FAIR}, #{KVA_A}, #{KVA_B}, #{KVA_C}, #{USE_CT}, #{USE_POWER}, #{AM_BAND}, #{FILM_BAND}, #{GRADEL}, #{G_WIRE}, #{ETC}, #{WORK_REG_ID}, TO_DATE(WORK_DATE, 'YYYYMMDDHH24MISS'), #{WORKER1_SEQ}, #{WORKER2_SEQ}, #{WORKER3_SEQ}, #{INST_KIND}, #{INST_TYPE}, #{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}, #{TRF_MFG_YM_A}, #{TRF_MFG_YM_B}, #{TRF_MFG_YM_C}, #{TRF_MRF_A}, #{TRF_MRF_B}, #{TRF_MRF_C} + , 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') + ) + + + + /* AMI공사관리 시공조치내역_모뎀 수신 */ + MERGE INTO T_SIGONG_ACT_MODEM + USING DUAL ON (DEPT1 = #{DEPT1} AND BUSI_NUM = #{BUSI_NUM} AND INSTR_NUM = #{INSTR_NUM} AND MAC_MODEM = #{MAC_MODEM} AND EXT_FCTY_ID = #{EXT_FCTY_ID}) + WHEN NOT MATCHED THEN + INSERT ( + BUSI_NUM, INSTR_NUM, MAC_MODEM, EXT_FCTY_ID, WORK_STEP, DATA_NUM, DCU_ID, DEPT1, DEPT2, KDN_DEPT1, KDN_DEPT2, WORK_DIV, REMV_MEMO, INST_M, INST_S, IND_CBD_DIV_CD, FCLTY_DIV, MODEM_DIV, SEAL_BOX1, SEAL_BOX2, SEAL_METER1, SEAL_METER2, SEAL_OUTER1, SEAL_OUTER2, LINE_TYPE, VISIT_DIV, SIG_LEVEL, WORK_REG_ID, WORK_DATE, WORKER1_SEQ, WORKER2_SEQ, WORKER3_SEQ, BUNGI, ETC1, ETC2, ATCH_FILE_ID_1, ATCH_FILE_ID_2, ATCH_FILE_ID_3, ATCH_FILE_ID_4, ATCH_FILE_ID_5, EXT_CONN_DEV + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{BUSI_NUM}, #{INSTR_NUM}, #{MAC_MODEM}, #{EXT_FCTY_ID}, #{WORK_STEP}, #{DATA_NUM}, #{DCU_ID}, #{DEPT1}, #{DEPT2}, #{KDN_DEPT1}, #{KDN_DEPT2}, #{WORK_DIV}, #{REMV_MEMO}, #{INST_M}, #{INST_S}, #{IND_CBD_DIV_CD}, #{FCLTY_DIV}, #{MODEM_DIV}, #{SEAL_BOX1}, #{SEAL_BOX2}, #{SEAL_METER1}, #{SEAL_METER2}, #{SEAL_OUTER1}, #{SEAL_OUTER2}, #{LINE_TYPE}, #{VISIT_DIV}, #{SIG_LEVEL}, #{WORK_REG_ID}, TO_DATE(#{WORK_DATE}, 'YYYYMMDDHH24MISS'), #{WORKER1_SEQ}, #{WORKER2_SEQ}, #{WORKER3_SEQ}, #{BUNGI}, #{ETC1}, #{ETC2}, #{ATCH_FILE_ID_1}, #{ATCH_FILE_ID_2}, #{ATCH_FILE_ID_3}, #{ATCH_FILE_ID_4}, #{ATCH_FILE_ID_5}, #{EXT_CONN_DEV} + , 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') + ) + + + + /* AMI공사관리 설치불가/철거내역_DCU 수신 */ + MERGE INTO T_SIGONG_UNABLE_DCU + USING DUAL ON (DEPT1 = #{DEPT1} AND BUSI_NUM = #{BUSI_NUM} AND DATA_NUM = #{DATA_NUM} AND DCU_ID = #{DCU_ID}) + WHEN NOT MATCHED THEN + INSERT ( + BUSI_NUM, DATA_NUM, DCU_ID, WORK_STEP, GN_NAME, DEPT1, DEPT2, KDN_DEPT1, KDN_DEPT2, WORK_DIV, UNABLE_RESULT, UNABLE_DETAIL, UNABLE_INP_DETAIL, ETC, WORK_REG_ID, WORK_DATE, WORKER1_SEQ, WORKER2_SEQ, WORKER3_SEQ, ATCH_FILE_ID_1, ATCH_FILE_ID_2, ATCH_FILE_ID_3 + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{BUSI_NUM}, #{DATA_NUM}, #{DCU_ID}, #{WORK_STEP}, #{GN_NAME}, #{DEPT1}, #{DEPT2}, #{KDN_DEPT1}, #{KDN_DEPT2}, #{WORK_DIV}, #{UNABLE_RESULT}, #{UNABLE_DETAIL}, #{UNABLE_INP_DETAIL}, #{ETC}, #{WORK_REG_ID}, TO_DATE(#{WORK_DATE}, 'YYYYMMDDHH24MISS'), #{WORKER1_SEQ}, #{WORKER2_SEQ}, #{WORKER3_SEQ}, #{ATCH_FILE_ID_1}, #{ATCH_FILE_ID_2}, #{ATCH_FILE_ID_3} + , 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') + ) + + + + /* AMI공사관리 설치불가/철거내역_모뎀 수신 */ + MERGE INTO T_SIGONG_UNABLE_MODEM + USING DUAL ON (DEPT1 = #{DEPT1} AND BUSI_NUM = #{BUSI_NUM} AND INSTR_NUM = #{INSTR_NUM} AND EXT_FCTY_ID = #{EXT_FCTY_ID}) + WHEN NOT MATCHED THEN + INSERT ( + BUSI_NUM, INSTR_NUM, EXT_FCTY_ID, WORK_STEP, DEPT1, DEPT2, KDN_DEPT1, KDN_DEPT2, INST_S, FCLTY_DIV, INST_M, MODEM_DIV, SEAL_BOX1, SEAL_BOX2, SEAL_METER1, SEAL_METER2, SEAL_OUTER1, SEAL_OUTER2, WORK_DIV, UNABLE_RESULT, UNABLE_DETAIL, UNABLE_INP_DETAIL, ETC, WORK_REG_ID, WORK_DATE, WORKER1_SEQ, WORKER2_SEQ, WORKER3_SEQ, ATCH_FILE_ID_1, ATCH_FILE_ID_2, ATCH_FILE_ID_3, ATCH_FILE_ID_4, ATCH_FILE_ID_5 + , MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{BUSI_NUM}, #{INSTR_NUM}, #{EXT_FCTY_ID}, #{WORK_STEP}, #{DEPT1}, #{DEPT2}, #{KDN_DEPT1}, #{KDN_DEPT2}, #{INST_S}, #{FCLTY_DIV}, #{INST_M}, #{MODEM_DIV}, #{SEAL_BOX1}, #{SEAL_BOX2}, #{SEAL_METER1}, #{SEAL_METER2}, #{SEAL_OUTER1}, #{SEAL_OUTER2}, #{WORK_DIV}, #{UNABLE_RESULT}, #{UNABLE_DETAIL}, #{UNABLE_INP_DETAIL}, #{ETC}, #{WORK_REG_ID}, TO_DATE(#{WORK_DATE}, 'YYYYMMDDHH24MISS'), #{WORKER1_SEQ}, #{WORKER2_SEQ}, #{WORKER3_SEQ}, #{ATCH_FILE_ID_1}, #{ATCH_FILE_ID_2}, #{ATCH_FILE_ID_3}, #{ATCH_FILE_ID_4}, #{ATCH_FILE_ID_5} + , 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/emr.xml b/src/docs/mapper-examples/mkami/mob/emr.xml new file mode 100644 index 0000000..9f06da6 --- /dev/null +++ b/src/docs/mapper-examples/mkami/mob/emr.xml @@ -0,0 +1,56 @@ + + + + + + + + + + + + /* 임시조치 당월검침정보(데이터) 수신 */ + MERGE INTO T_METER_NDL_ACT + USING DUAL ON (SEQ = #{SEQ}) + WHEN NOT MATCHED THEN + INSERT ( + SEQ, WHM_NO, CNTR_NO, WHME_NDL_DAY_QTT, DM_MT_NDL_DAY_QTT, VAR_NDL_DAY_QTT, WHME_NDL_EVEN_QTT, DM_MT_NDL_EVEN_QTT, VAR_NDL_EVEN_QTT, WHME_NDL_MNGT_QTT, DM_MT_NDL_MNGT_QTT, VAR_NDL_MNGT_QTT, METER_NDL_LST_SEQ, CONS_CNTR_DIV, WORK_DIV, WHME_NDL_DAY_ATCH_FILE_ID, DM_MT_NDL_DAY_ATCH_FILE_ID, VAR_NDL_DAY_ATCH_FILE_ID, WHME_NDL_EVEN_ATCH_FILE_ID, DM_MT_NDL_EVEN_ATCH_FILE_ID, VAR_NDL_EVEN_ATCH_FILE_ID, WHME_NDL_MNGT_ATCH_FILE_ID, DM_MT_NDL_MNGT_ATCH_FILE_ID, VAR_NDL_MNGT_ATCH_FILE_ID, ACT_DATE, DEPT1, GENT_WHM_NDL_DAY_QTT, GENT_WHM_NDL_EVEN_QTT, GENT_WHM_NDL_MNGT_QTT, ESS_WHME_NDL_DAY_QTT, ESS_WHME_NDL_EVEN_QTT, ESS_WHME_NDL_MNGT_QTT, REG_DATE, REG_ID + ) + VALUES ( + #{SEQ}, #{WHM_NO}, #{CNTR_NO}, #{WHME_NDL_DAY_QTT}, #{DM_MT_NDL_DAY_QTT}, #{VAR_NDL_DAY_QTT}, #{WHME_NDL_EVEN_QTT}, #{DM_MT_NDL_EVEN_QTT}, #{VAR_NDL_EVEN_QTT}, #{WHME_NDL_MNGT_QTT}, #{DM_MT_NDL_MNGT_QTT}, #{VAR_NDL_MNGT_QTT}, #{METER_NDL_LST_SEQ}, #{CONS_CNTR_DIV}, #{WORK_DIV}, #{WHME_NDL_DAY_ATCH_FILE_ID}, #{DM_MT_NDL_DAY_ATCH_FILE_ID}, #{VAR_NDL_DAY_ATCH_FILE_ID}, #{WHME_NDL_EVEN_ATCH_FILE_ID}, #{DM_MT_NDL_EVEN_ATCH_FILE_ID}, #{VAR_NDL_EVEN_ATCH_FILE_ID}, #{WHME_NDL_MNGT_ATCH_FILE_ID}, #{DM_MT_NDL_MNGT_ATCH_FILE_ID}, #{VAR_NDL_MNGT_ATCH_FILE_ID}, TO_DATETIME(#{ACT_DATE}, 'YYYYMMDDHH24MI'), #{DEPT1}, #{GENT_WHM_NDL_DAY_QTT}, #{GENT_WHM_NDL_EVEN_QTT}, #{GENT_WHM_NDL_MNGT_QTT}, #{ESS_WHME_NDL_DAY_QTT}, #{ESS_WHME_NDL_EVEN_QTT}, #{ESS_WHME_NDL_MNGT_QTT}, TO_DATE(#{REG_DATE}, 'YYYYMMDD'), #{REG_ID} + ) + + + diff --git a/src/docs/mapper-examples/mkami/mob/obs.xml b/src/docs/mapper-examples/mkami/mob/obs.xml index 37ff8ba..e480f12 100644 --- a/src/docs/mapper-examples/mkami/mob/obs.xml +++ b/src/docs/mapper-examples/mkami/mob/obs.xml @@ -221,18 +221,56 @@ AND (DEPT1, M_METER_ID) IN ( SELECT DEPT1, M_METER_ID FROM ( - SELECT M_METER_ID, M_CREATE_DATE, M_REMOVE_DATE, M_USE_YN, M_DCU_ID, M_MODEM_MAC, M_MRD, M_UPDATE_DATE, METER_TYPE, CUST_NO, CUST_CATEG, CTNR_STAT, CTNR_PWR, COMBLD_NM, DEPT1, DEPT2, DCU_IP, BUSI_DIV, KDN_DEPT1, KDN_DEPT2, INST_DIV, INST_L, INST_M, INST_S, CONSIGN_YN, DEFECT_YN, MANF_YM, DLVP_YM, CONSIGN_DATE, ROAD_ADDRESS, ADDRESS, ATCH_FILE_ID, ATCH_FILE_ID2, ETC, STATE_CHANGE, MATCH_YN, EXCPT, M_COMPANY, FAC_DIV, CODN_LAT, CODN_LNG, REVERSE_YN, EXCEPT_DIV, IU_DIV, DESN_ST, SV_FEED, TRADE, GUM_DAY, MASTER_YN, TR_FEED_NM, SV_FEED_NM, TR_FEED_NO, SV_FEED_NO, BUILD_CD, MGMT_CD, COMM_CD, ATNT_FCTY_YN, ACT_BUSI_DIV_NM, FCTY_CMNT - , MOD_ID, MOD_DATE, REG_ID, REG_DATE - FROM ( - SELECT M_METER_ID, TO_CHAR(M_CREATE_DATE, 'YYYYMMDDHH24MISS') AS M_CREATE_DATE, TO_CHAR(M_REMOVE_DATE, 'YYYYMMDDHH24MISS') AS M_REMOVE_DATE, M_USE_YN, M_DCU_ID, M_MODEM_MAC, M_MRD, TO_CHAR(M_UPDATE_DATE, 'YYYYMMDDHH24MISS') AS M_UPDATE_DATE, METER_TYPE, CUST_NO, CUST_CATEG, CTNR_STAT, CTNR_PWR, COMBLD_NM, DEPT1, DEPT2, DCU_IP, BUSI_DIV, KDN_DEPT1, KDN_DEPT2, INST_DIV, INST_L, INST_M, INST_S, CONSIGN_YN, DEFECT_YN, MANF_YM, DLVP_YM, TO_CHAR(CONSIGN_DATE, 'YYYYMMDDHH24MISS') AS CONSIGN_DATE, ROAD_ADDRESS, ADDRESS, ATCH_FILE_ID, ATCH_FILE_ID2, DBMS_LOB.SUBSTR(ETC, 4000, 1) AS ETC, STATE_CHANGE, MATCH_YN, EXCPT, M_COMPANY, FAC_DIV, CODN_LAT, CODN_LNG, REVERSE_YN, EXCEPT_DIV, IU_DIV, TO_CHAR(DESN_ST, 'YYYYMMDDHH24MISS') AS DESN_ST, SV_FEED, TRADE, GUM_DAY, MASTER_YN, TR_FEED_NM, SV_FEED_NM, TR_FEED_NO, SV_FEED_NO, BUILD_CD, MGMT_CD, COMM_CD, ATNT_FCTY_YN, ACT_BUSI_DIV_NM, FCTY_CMNT - , MOD_ID, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE - , ROW_NUMBER() OVER (ORDER BY DEPT1, M_METER_ID) AS R_NUM - FROM T_FCTY_CS_METER_INFO - WHERE 1 = 1 - AND NVL(AWMS_SEND_YN, 'N') = 'N' - ) + SELECT M_METER_ID, TO_CHAR(M_CREATE_DATE, 'YYYYMMDDHH24MISS') AS M_CREATE_DATE, TO_CHAR(M_REMOVE_DATE, 'YYYYMMDDHH24MISS') AS M_REMOVE_DATE, M_USE_YN, M_DCU_ID, M_MODEM_MAC, M_MRD, TO_CHAR(M_UPDATE_DATE, 'YYYYMMDDHH24MISS') AS M_UPDATE_DATE, METER_TYPE, CUST_NO, CUST_CATEG, CTNR_STAT, CTNR_PWR, COMBLD_NM, DEPT1, DEPT2, DCU_IP, BUSI_DIV, KDN_DEPT1, KDN_DEPT2, INST_DIV, INST_L, INST_M, INST_S, CONSIGN_YN, DEFECT_YN, MANF_YM, DLVP_YM, TO_CHAR(CONSIGN_DATE, 'YYYYMMDDHH24MISS') AS CONSIGN_DATE, ROAD_ADDRESS, ADDRESS, ATCH_FILE_ID, ATCH_FILE_ID2, DBMS_LOB.SUBSTR(ETC, 4000, 1) AS ETC, STATE_CHANGE, MATCH_YN, EXCPT, M_COMPANY, FAC_DIV, CODN_LAT, CODN_LNG, REVERSE_YN, EXCEPT_DIV, IU_DIV, TO_CHAR(DESN_ST, 'YYYYMMDDHH24MISS') AS DESN_ST, SV_FEED, TRADE, GUM_DAY, MASTER_YN, TR_FEED_NM, SV_FEED_NM, TR_FEED_NO, SV_FEED_NO, BUILD_CD, MGMT_CD, COMM_CD, ATNT_FCTY_YN, ACT_BUSI_DIV_NM, FCTY_CMNT + , MOD_ID, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE + , ROW_NUMBER() OVER (ORDER BY DEPT1, M_METER_ID) AS R_NUM + FROM T_FCTY_CS_METER_INFO WHERE 1 = 1 - AND R_NUM BETWEEN 1 AND 1000 + AND NVL(AWMS_SEND_YN, 'N') = 'N' + ) + WHERE 1 = 1 + AND R_NUM BETWEEN 1 AND 1000 + ) + ]]> + + + + + + diff --git a/src/docs/settings-examples/dfxagent-ami-dev.json b/src/docs/settings-examples/dfxagent-ami-dev.json index f73a8e0..1e0aeeb 100644 --- a/src/docs/settings-examples/dfxagent-ami-dev.json +++ b/src/docs/settings-examples/dfxagent-ami-dev.json @@ -12,7 +12,12 @@ "dropbox-fox-mkami-dev-oracle-receive-atch-file-detail-list", "dropbox-fox-mkami-dev-oracle-receive-work-act-dcu-list", "dropbox-fox-mkami-dev-oracle-receive-work-act-modem-list", - "dropbox-fox-mkami-dev-oracle-receive-work-act-svc-cd-list" + "dropbox-fox-mkami-dev-oracle-receive-work-act-svc-cd-list", + "dropbox-fox-mkami-dev-oracle-receive-sigong-act-dcu-list", + "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" ] } ], @@ -144,6 +149,20 @@ "dataSourceId": "ds-cubrid", "sqlId": "com.kdn.awms.mob.obs.insertFctyCsMeterInfoListForReceive", "description": "유지관리 설비계기정보 수신" + }, + { + "dropBoxId": "dropbox-fox-ami-dev-cubrid-receive-fcty-dcu-info-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.obs.insertFctyDcuInfoListForReceive", + "description": "유지관리 설비DCU정보 수신" + }, + { + "dropBoxId": "dropbox-fox-ami-dev-cubrid-receive-meter-ndl-lst-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.emr.insertMeterNdlLstListForReceive", + "description": "임시조치 전월검침정보(데이터) 수신" } ] }, @@ -248,7 +267,107 @@ "routingHostIdList": [ "fox-mkami-dev-oracle" ], - "description": "유지관리 조치내용_노임품목" + "description": "유지관리 조치내용_노임품목 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-sigong-act-dcu-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.cst.selectSigongActDcuListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.cst.updateSigongActDcuListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-sigong-act-dcu-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "AMI공사관리 시공조치내역_DCU 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-sigong-act-modem-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.cst.selectSigongActModemListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.cst.updateSigongActModemListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-sigong-act-modem-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "AMI공사관리 시공조치내역_모뎀 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-sigong-unable-dcu-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.cst.selectSigongUnableDcuListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.cst.updateSigongUnableDcuListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-sigong-unable-dcu-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "AMI공사관리 설치불가/철거내역_DCU 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-sigong-unable-modem-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.cst.selectSigongUnableModemListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.cst.updateSigongUnableModemListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-sigong-unable-modem-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "AMI공사관리 설치불가/철거내역_모뎀 송신" + }, + { + "postmanId": "postman-fox-ami-dev-cubrid-send-meter-ndl-act-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.emr.selectMeterNdlActListForSend", + "postProcessingSqlId": "com.kdn.awms.mob.emr.updateMeterNdlActListTransferDone" + }, + "recipientHostId": "fox-mkami-dev-oracle", + "recipientDropBoxId": "dropbox-fox-mkami-dev-oracle-receive-meter-ndl-act-list", + "routingHostIdList": [ + "fox-mkami-dev-oracle" + ], + "description": "임시조치 당월검침정보(데이터) 송신" } ] } diff --git a/src/docs/settings-examples/dfxagent-mkami-dev.json b/src/docs/settings-examples/dfxagent-mkami-dev.json index f7e9241..1be90a4 100644 --- a/src/docs/settings-examples/dfxagent-mkami-dev.json +++ b/src/docs/settings-examples/dfxagent-mkami-dev.json @@ -17,7 +17,10 @@ "dropbox-fox-ami-dev-cubrid-receive-fac-err-cur-dcu-list", "dropbox-fox-ami-dev-cubrid-receive-fac-err-cur-modem-list", "dropbox-fox-ami-dev-cubrid-receive-fcty-danger-info-list", - "dropbox-fox-ami-dev-cubrid-receive-fcty-cs-meter-info-list" + "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" ] } ], @@ -93,6 +96,41 @@ "dataSourceId": "ds-oracle", "sqlId": "com.kdn.mkami.mob.obs.insertWorkActSvcCdListForReceive", "description": "유지관리 조치내용_노임품목 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-sigong-act-dcu-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.cst.insertSigongActDcuListForReceive", + "description": "AMI공사관리 시공조치내역_DCU 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-sigong-act-modem-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.cst.insertSigongActModemListForReceive", + "description": "AMI공사관리 시공조치내역_모뎀 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-sigong-unable-dcu-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.cst.insertSigongUnableDcuListForReceive", + "description": "AMI공사관리 설치불가/철거내역_DCU 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-sigong-unable-modem-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.cst.insertSigongUnableModemListForReceive", + "description": "AMI공사관리 설치불가/철거내역_모뎀 수신" + }, + { + "dropBoxId": "dropbox-fox-mkami-dev-oracle-receive-meter-ndl-act-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.emr.insertMeterNdlActListForReceive", + "description": "임시조치 당월검침정보(데이터) 수신" } ] }, @@ -344,7 +382,7 @@ "taskType": "DB_READ_THEN_SEND", "action": { "type": "SCHEDULED", - "cron": "34 0/1 * * * *" + "cron": "35 0/1 * * * *" }, "message": { "messageType": "TRANSFER_DB_TO_DB", @@ -358,6 +396,66 @@ "fox-ami-dev-cubrid" ], "description": "유지관리 설비계기정보 송신" + }, + { + "postmanId": "postman-fox-mkami-dev-oracle-send-fcty-dcu-info-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "36 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.obs.selectFctyDcuInfoListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.obs.updateFctyDcuInfoListTransferDone" + }, + "recipientHostId": "fox-ami-dev-cubrid", + "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-fcty-dcu-info-list", + "routingHostIdList": [ + "fox-ami-dev-cubrid" + ], + "description": "유지관리 설비DCU정보 송신" + }, + { + "postmanId": "postman-fox-mkami-dev-oracle-send-sigong-master-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "37 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.cst.selectSigongMasterListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.cst.updateSigongMasterListTransferDone" + }, + "recipientHostId": "fox-ami-dev-cubrid", + "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-sigong-master-list", + "routingHostIdList": [ + "fox-ami-dev-cubrid" + ], + "description": "유지관리 설비DCU정보 송신" + }, + { + "postmanId": "postman-fox-mkami-dev-oracle-send-meter-ndl-lst-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "38 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.emr.selectMeterNdlLstListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.emr.updateMeterNdlLstListTransferDone" + }, + "recipientHostId": "fox-ami-dev-cubrid", + "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-meter-ndl-lst-list", + "routingHostIdList": [ + "fox-ami-dev-cubrid" + ], + "description": "임시조치 전월검침정보(데이터) 송신" } ] }