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": "임시조치 전월검침정보(데이터) 송신"
}
]
}