diff --git a/src/docs/mapper-examples/awms/mob/mtr.xml b/src/docs/mapper-examples/awms/mob/mtr.xml index 3df147c..d8226e5 100644 --- a/src/docs/mapper-examples/awms/mob/mtr.xml +++ b/src/docs/mapper-examples/awms/mob/mtr.xml @@ -589,7 +589,7 @@ + + + + diff --git a/src/docs/mapper-examples/mkami/fmp/cdm.xml b/src/docs/mapper-examples/mkami/fmp/cdm.xml index 6038fbb..cb42ea8 100644 --- a/src/docs/mapper-examples/mkami/fmp/cdm.xml +++ b/src/docs/mapper-examples/mkami/fmp/cdm.xml @@ -289,6 +289,7 @@ AND NVL(AWMS_SEND_YN, 'N') = 'N' ) WHERE 1 = 1 + AND SV_ID IS NOT NULL AND R_NUM BETWEEN 1 AND 1000 ]]> @@ -304,12 +305,23 @@ SELECT WORK_GP_NO FROM ( SELECT WORK_GP_NO, WORK_GP_NM, KDN_DEPT1, KDN_DEPT2, WORKER1_SEQ, WORKER2_SEQ, WORKER3_SEQ, SV_SEQ, USE_YN, WORKER1_DIV, WORKER2_DIV, WORKER3_DIV, MOD_ID, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE + , CASE WHEN WORKER1_DIV = 'E' THEN (SELECT MAX(ID) FROM T_AD_USER X WHERE X.SEQ = WORKER1_SEQ) + WHEN WORKER1_DIV = 'T' THEN (SELECT MAX(ID) FROM T_ETC_USER X WHERE X.SEQ = WORKER1_SEQ) + ELSE (SELECT MAX(ID) FROM (SELECT ID FROM T_AD_USER X1 WHERE X1.SEQ = WORKER1_SEQ UNION ALL SELECT ID FROM T_ETC_USER X2 WHERE X2.SEQ = WORKER1_SEQ) WHERE ROWNUM = 1) END AS WORKER1_ID + , CASE WHEN WORKER2_DIV = 'E' THEN (SELECT MAX(ID) FROM T_AD_USER X WHERE X.SEQ = WORKER2_SEQ) + WHEN WORKER2_DIV = 'T' THEN (SELECT MAX(ID) FROM T_ETC_USER X WHERE X.SEQ = WORKER2_SEQ) + ELSE (SELECT MAX(ID) FROM (SELECT ID FROM T_AD_USER X1 WHERE X1.SEQ = WORKER2_SEQ UNION ALL SELECT ID FROM T_ETC_USER X2 WHERE X2.SEQ = WORKER2_SEQ) WHERE ROWNUM = 1) END AS WORKER2_ID + , CASE WHEN WORKER3_DIV = 'E' THEN (SELECT MAX(ID) FROM T_AD_USER X WHERE X.SEQ = WORKER3_SEQ) + WHEN WORKER3_DIV = 'T' THEN (SELECT MAX(ID) FROM T_ETC_USER X WHERE X.SEQ = WORKER3_SEQ) + ELSE (SELECT MAX(ID) FROM (SELECT ID FROM T_AD_USER X1 WHERE X1.SEQ = WORKER3_SEQ UNION ALL SELECT ID FROM T_ETC_USER X2 WHERE X2.SEQ = WORKER3_SEQ) WHERE ROWNUM = 1) END AS WORKER3_ID + , (SELECT MAX(ID) FROM (SELECT ID FROM T_AD_USER X1 WHERE X1.SEQ = SV_SEQ UNION ALL SELECT ID FROM T_ETC_USER X2 WHERE X2.SEQ = SV_SEQ) WHERE ROWNUM = 1) AS SV_ID , ROW_NUMBER() OVER (ORDER BY WORK_GP_NO) AS R_NUM FROM T_WORK_GROUP WHERE 1 = 1 AND NVL(AWMS_SEND_YN, 'N') = 'N' ) WHERE 1 = 1 + AND SV_ID IS NOT NULL AND R_NUM BETWEEN 1 AND 1000 ) ]]> diff --git a/src/docs/mapper-examples/mkami/mob/mtr.xml b/src/docs/mapper-examples/mkami/mob/mtr.xml index 3934bff..f26418a 100644 --- a/src/docs/mapper-examples/mkami/mob/mtr.xml +++ b/src/docs/mapper-examples/mkami/mob/mtr.xml @@ -629,7 +629,7 @@ , AWMS_SEND_DATE = SYSDATE WHERE 1 = 1 AND (OFFICE_CD, TGT_YEAR, CNTR_NO, WHM_NO, WHM_SEQNO, PLAN_CONS_KND_CD) IN ( - OFFICE_CD, TGT_YEAR, CNTR_NO, WHM_NO, WHM_SEQNO, PLAN_CONS_KND_CD + SELECT OFFICE_CD, TGT_YEAR, CNTR_NO, WHM_NO, WHM_SEQNO, PLAN_CONS_KND_CD FROM ( SELECT OFFICE_CD, TGT_YEAR, CNTR_NO, WHM_NO, WHM_SEQNO, PLAN_CONS_KND_CD, HDQR_CD, DIST_LV_HV_CLCD, CNTR_CLAS_CD, CNTR_PWR, SPLY_MODE_CD, CUST_ADDR_CNID, POSS_CLCD, PRDC_YM, LAY_YMD, EFEC_YM, WHM_LOC_CD, WHM_KND_CD, WHM_BX_KND_CD, WHM_BX_STAT_CD, COCMP_BUPE_ID, PLAN_CONS_CHASU, PLAN_CONS_CASE_YN, CONS_NO, CONS_CSWRK_YMD, DISM_YMD, DISM_NDL_VAL, LAY_WHM_NO, LAY_PRDC_YM, WHM_LAY_YMD, LAY_NDL, CSWRK_RSLT_REGST_YN, NOT_CSWRK_RSN, WHM_CAPY_CD, GROU_CONS_YN, PBLSH_SEQNO, WHM_DISM_RSN_CD, WHM_DISM_STAT_CD, LIPO_NO, TRMR_NO, PACH_CLCD, ISLN_PRM_YN, ISLN_PRM_RATIO, MATL_NO, TRMR_LINE_NM, TRMR_LINE_NO, LIPO_LINE_NM, LIPO_LINE_NO, REPL_SCHE_MM, RSN_BIGCSS_CD, RSN_MEDI_CD, RSN_MEMO, RMRK, WRK_STRT_SCHL_YMD, WRK_END_SCHL_YMD, TCHGR_NM, TCHGR_TEL_NO, CNSWK_CO_NM, CNSWK_CO_TEL_NO, FLDST_AGNT_NM, FLDST_AGNT_MPHN_NO, TRNS_YMD, TRNS_HH, OTPT_YMD, OTPT_HH , TO_CHAR(PRIM_REGST_DT, 'YYYYMMDDHH24MISS') AS PRIM_REGST_DT, PRIM_RGST_EMPID, TO_CHAR(LST_CHG_DT, 'YYYYMMDDHH24MISS') AS LST_CHG_DT, LST_CHPE_EMPID @@ -644,4 +644,45 @@ ]]> + + + + + + diff --git a/src/docs/settings-examples/dfxagent-ami-dev.json b/src/docs/settings-examples/dfxagent-ami-dev.json index c285328..e13324f 100644 --- a/src/docs/settings-examples/dfxagent-ami-dev.json +++ b/src/docs/settings-examples/dfxagent-ami-dev.json @@ -307,6 +307,13 @@ "dataSourceId": "ds-cubrid", "sqlId": "com.kdn.awms.mob.mtr.insertJat1010ToMtrInstListForReceive", "description": "계기관리 실효계기 작업 대상리스트 수신" + }, + { + "dropBoxId": "dropbox-fox-ami-dev-cubrid-receive-mtr-acpt-inst-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.insertJct0101ToMtrInstListForReceive", + "description": "계기관리 실효계기 외 작업 대상리스트 수신" } ] }, diff --git a/src/docs/settings-examples/dfxagent-ami-oper.json b/src/docs/settings-examples/dfxagent-ami-oper.json index 7faf821..520d639 100644 --- a/src/docs/settings-examples/dfxagent-ami-oper.json +++ b/src/docs/settings-examples/dfxagent-ami-oper.json @@ -307,6 +307,13 @@ "dataSourceId": "ds-cubrid", "sqlId": "com.kdn.awms.mob.mtr.insertJat1010ToMtrInstListForReceive", "description": "계기관리 실효계기 작업 대상리스트 수신" + }, + { + "dropBoxId": "dropbox-ami-cubrid-receive-mtr-acpt-inst-list", + "taskType": "RECEIVE_DB_TO_DB_SAVE", + "dataSourceId": "ds-cubrid", + "sqlId": "com.kdn.awms.mob.mtr.insertJct0101ToMtrInstListForReceive", + "description": "계기관리 실효계기 외 작업 대상리스트 수신" } ] }, diff --git a/src/docs/settings-examples/dfxagent-mkami-dev.json b/src/docs/settings-examples/dfxagent-mkami-dev.json index aef503f..0d42b82 100644 --- a/src/docs/settings-examples/dfxagent-mkami-dev.json +++ b/src/docs/settings-examples/dfxagent-mkami-dev.json @@ -39,7 +39,8 @@ "dropbox-fox-ami-dev-cubrid-receive-mtrl-tp-list", "dropbox-fox-ami-dev-cubrid-receive-amms-reg-co-to-sbcn-co-list", "dropbox-fox-ami-dev-cubrid-receive-amms-reg-co-to-inln-co-list", - "dropbox-fox-ami-dev-cubrid-receive-mtr-expire-inst-list" + "dropbox-fox-ami-dev-cubrid-receive-mtr-expire-inst-list", + "dropbox-fox-ami-dev-cubrid-receive-mtr-acpt-inst-list" ] } ], @@ -934,6 +935,26 @@ "fox-ami-dev-cubrid" ], "description": "계기관리 실효계기 작업 대상리스트 송신" + }, + { + "postmanId": "postman-fox-mkami-dev-oracle-send-mtr-acpt-inst-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "19 1 0 * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.selectJct0101ListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.mtr.updateJct0101ListTransferDone" + }, + "recipientHostId": "fox-ami-dev-cubrid", + "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-mtr-acpt-inst-list", + "routingHostIdList": [ + "fox-ami-dev-cubrid" + ], + "description": "계기관리실효계기 외 작업 대상리스트 송신" } ] } diff --git a/src/docs/settings-examples/dfxagent-mkami-oper.json b/src/docs/settings-examples/dfxagent-mkami-oper.json index ac7b5ef..f235f2d 100644 --- a/src/docs/settings-examples/dfxagent-mkami-oper.json +++ b/src/docs/settings-examples/dfxagent-mkami-oper.json @@ -39,7 +39,8 @@ "dropbox-ami-cubrid-receive-mtrl-tp-list", "dropbox-ami-cubrid-receive-amms-reg-co-to-sbcn-co-list", "dropbox-ami-cubrid-receive-amms-reg-co-to-inln-co-list", - "dropbox-ami-cubrid-receive-mtr-expire-inst-list" + "dropbox-ami-cubrid-receive-mtr-expire-inst-list", + "dropbox-ami-cubrid-receive-mtr-acpt-inst-list" ] } ], @@ -440,7 +441,7 @@ "taskType": "DB_READ_THEN_SEND", "action": { "type": "SCHEDULED", - "cron": "8 1 0 * * *" + "cron": "46 0/1 * * * *" }, "message": { "messageType": "TRANSFER_DB_TO_DB", @@ -846,7 +847,7 @@ "messageType": "TRANSFER_DB_TO_DB", "dataSourceId": "ds-oracle", "sqlId": "com.kdn.mkami.mob.mtl.selectPcknListForSend", - "postProcessingSqlId": "com.kdn.mkami.mob.mtl.updatePkcnListTransferDone" + "postProcessingSqlId": "com.kdn.mkami.mob.mtl.updatePcknListTransferDone" }, "recipientHostId": "ami-cubrid", "recipientDropBoxId": "dropbox-ami-cubrid-receive-pckn-list", @@ -934,6 +935,26 @@ "ami-cubrid" ], "description": "계기관리 실효계기 작업 대상리스트 송신" + }, + { + "postmanId": "postman-mkami-oracle-send-mtr-acpt-inst-list", + "taskType": "DB_READ_THEN_SEND", + "action": { + "type": "SCHEDULED", + "cron": "19 1 0 * * *" + }, + "message": { + "messageType": "TRANSFER_DB_TO_DB", + "dataSourceId": "ds-oracle", + "sqlId": "com.kdn.mkami.mob.mtr.selectJct0101ListForSend", + "postProcessingSqlId": "com.kdn.mkami.mob.mtr.updateJct0101ListTransferDone" + }, + "recipientHostId": "ami-cubrid", + "recipientDropBoxId": "dropbox-ami-cubrid-receive-mtr-acpt-inst-list", + "routingHostIdList": [ + "ami-cubrid" + ], + "description": "계기관리 실효계기 외 작업 대상리스트 송신" } ] } diff --git a/src/docs/settings-examples/dfxagent.json b/src/docs/settings-examples/dfxagent.json index d2278cf..4e961a5 100644 --- a/src/docs/settings-examples/dfxagent.json +++ b/src/docs/settings-examples/dfxagent.json @@ -836,7 +836,7 @@ "messageType": "TRANSFER_DB_TO_DB", "dataSourceId": "ds-oracle", "sqlId": "com.kdn.mkami.mob.mtl.selectPcknListForSend", - "postProcessingSqlId": "com.kdn.mkami.mob.mtl.updatePkcnListTransferDone" + "postProcessingSqlId": "com.kdn.mkami.mob.mtl.updatePcknListTransferDone" }, "recipientHostId": "fox-ami-dev-cubrid", "recipientDropBoxId": "dropbox-fox-ami-dev-cubrid-receive-pckn-list",