From 343ad45b4b676dd2b4b225cbd01b133f0326f09a Mon Sep 17 00:00:00 2001 From: "semin.baek" Date: Wed, 28 May 2025 16:47:29 +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/obs.xml | 41 ++++++ src/docs/mapper-examples/mkami/mob/obs.xml | 120 ++++++++++++++++++ .../settings-examples/dfxagent-ami-dev.json | 21 +++ .../settings-examples/dfxagent-mkami-dev.json | 72 ++++++++++- 4 files changed, 249 insertions(+), 5 deletions(-) diff --git a/src/docs/mapper-examples/awms/mob/obs.xml b/src/docs/mapper-examples/awms/mob/obs.xml index 7dc4365..b4d1661 100644 --- a/src/docs/mapper-examples/awms/mob/obs.xml +++ b/src/docs/mapper-examples/awms/mob/obs.xml @@ -142,4 +142,45 @@ ]]> + + /* 유지관리 위험불가개소 수신 */ + MERGE INTO TM_FCTY_DANGER_INFO + USING DUAL ON (DEPT1 = #{DEPT1} AND FCTY_ID = #{FCTY_ID}) + WHEN NOT MATCHED THEN + INSERT ( + DEPT1, DEPT2, FCTY_ID, FCTY_TYPE, PHASE3, MORE10, ETC, MEMO, GOSO_LOCA, CORPS, NEAR_ROAD, LONG_DIS, TOUGH_ROAD, MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{DEPT1}, #{DEPT2}, #{FCTY_ID}, #{FCTY_TYPE}, #{PHASE3}, #{MORE10}, #{ETC}, #{MEMO}, #{GOSO_LOCA}, #{CORPS}, #{NEAR_ROAD}, #{LONG_DIS}, #{TOUGH_ROAD}, 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_FAC_ERR_CLR + USING DUAL ON (ERR_ID = #{ERR_ID}) + WHEN NOT MATCHED THEN + INSERT ( + ERR_ID, DEPT1, DEPT2, NEW_FCTY_YN, EVENT_END_DT, MOD_ID, MOD_DATE, REG_ID, REG_DATE + ) + VALUES ( + #{ERR_ID}, #{DEPT1}, #{DEPT2}, #{NEW_FCTY_YN}, TO_TIMESTAMP(EVENT_END_DT, 'YYYYMMDDHH24MISS'), 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_FCTY_CS_METER_INFO + USING DUAL ON (DEPT1 = #{DEPT1} AND M_METER_ID = #{M_METER_ID}) + WHEN NOT MATCHED THEN + INSERT ( + 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 + ) + VALUES ( + #{M_METER_ID}, TO_TIMESTAMP(#{M_CREATE_DATE}, 'YYYYMMDDHH24MISS'), TO_TIMESTAMP(#{M_REMOVE_DATE}, 'YYYYMMDDHH24MISS'), #{M_USE_YN}, #{M_DCU_ID}, #{M_MODEM_MAC}, #{M_MRD}, TO_TIMESTAMP(#{M_UPDATE_DATE}, 'YYYYMMDDHH24MISS'), #{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_TIMESTAMP(#{CONSIGN_DATE}, 'YYYYMMDDHH24MISS'), #{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}, TO_TIMESTAMP(#{DESN_ST}, 'YYYYMMDDHH24MISS'), #{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} + , 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/obs.xml b/src/docs/mapper-examples/mkami/mob/obs.xml index 2af2ad4..37ff8ba 100644 --- a/src/docs/mapper-examples/mkami/mob/obs.xml +++ b/src/docs/mapper-examples/mkami/mob/obs.xml @@ -117,4 +117,124 @@ ) + + + + + + + + + + + + + + + + + + diff --git a/src/docs/settings-examples/dfxagent-ami-dev.json b/src/docs/settings-examples/dfxagent-ami-dev.json index 739d848..f73a8e0 100644 --- a/src/docs/settings-examples/dfxagent-ami-dev.json +++ b/src/docs/settings-examples/dfxagent-ami-dev.json @@ -123,6 +123,27 @@ "dataSourceId": "ds-cubrid", "sqlId": "com.kdn.awms.mob.obs.insertFacErrCurModemListForReceive", "description": "유지관리 작업대상_모뎀 수신" + }, + { + "dropBoxId": "dropbox-fox-ami-dev-cubrid-receive-fcty-danger-info-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.obs.insertFctyDangerInfoListForReceive", + "description": "유지관리 위험불가개소 수신" + }, + { + "dropBoxId": "dropbox-fox-ami-dev-cubrid-receive-fac-err-clr-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.obs.insertFacErrClrListForReceive", + "description": "유지관리 계기장애처리완료 수신" + }, + { + "dropBoxId": "dropbox-fox-ami-dev-cubrid-receive-fcty-cs-meter-info-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.obs.insertFctyCsMeterInfoListForReceive", + "description": "유지관리 설비계기정보 수신" } ] }, diff --git a/src/docs/settings-examples/dfxagent-mkami-dev.json b/src/docs/settings-examples/dfxagent-mkami-dev.json index 3d3009b..f7e9241 100644 --- a/src/docs/settings-examples/dfxagent-mkami-dev.json +++ b/src/docs/settings-examples/dfxagent-mkami-dev.json @@ -15,7 +15,9 @@ "dropbox-fox-ami-dev-cubrid-receive-kdn-dept-list", "dropbox-fox-ami-dev-cubrid-receive-work-group-list", "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-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" ] } ], @@ -222,7 +224,7 @@ "taskType": "DB_READ_THEN_SEND", "action": { "type": "SCHEDULED", - "cron": "6 1 0 * * *" + "cron": "7 1 0 * * *" }, "message": { "messageType": "TRANSFER_DB_TO_DB", @@ -242,7 +244,7 @@ "taskType": "DB_READ_THEN_SEND", "action": { "type": "SCHEDULED", - "cron": "6 1 0 * * *" + "cron": "8 1 0 * * *" }, "message": { "messageType": "TRANSFER_DB_TO_DB", @@ -262,7 +264,7 @@ "taskType": "DB_READ_THEN_SEND", "action": { "type": "SCHEDULED", - "cron": "1 0/1 * * * *" + "cron": "31 0/1 * * * *" }, "message": { "messageType": "TRANSFER_DB_TO_DB", @@ -282,7 +284,7 @@ "taskType": "DB_READ_THEN_SEND", "action": { "type": "SCHEDULED", - "cron": "1 0/1 * * * *" + "cron": "32 0/1 * * * *" }, "message": { "messageType": "TRANSFER_DB_TO_DB", @@ -296,6 +298,66 @@ "fox-ami-dev-cubrid" ], "description": "유지관리 작업대상_모뎀 송신" + }, + { + "postmanId": "postman-fox-mkami-dev-oracle-send-fcty-danger-info-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "33 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.obs.selectFctyDangerInfoListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.obs.updateFctyDangerInfoListTransferDone" + }, + "recipientHostId": "fox-ami-dev-cubrid", + "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-fcty-danger-info-list", + "routingHostIdList": [ + "fox-ami-dev-cubrid" + ], + "description": "유지관리 위험불가개소 송신" + }, + { + "postmanId": "postman-fox-mkami-dev-oracle-send-fac-err-clr-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "34 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.obs.selectFacErrClrListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.obs.updateFacErrClrListTransferDone" + }, + "recipientHostId": "fox-ami-dev-cubrid", + "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-fac-err-clr-list", + "routingHostIdList": [ + "fox-ami-dev-cubrid" + ], + "description": "유지관리 계기장애처리완료 송신" + }, + { + "postmanId": "postman-fox-mkami-dev-oracle-send-fcty-cs-meter-info-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "34 0/1 * * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.obs.selectFctyCsMeterInfoListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.obs.updateFctyCsMeterInfoListTransferDone" + }, + "recipientHostId": "fox-ami-dev-cubrid", + "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-fcty-cs-meter-info-list", + "routingHostIdList": [ + "fox-ami-dev-cubrid" + ], + "description": "유지관리 설비계기정보 송신" } ] }