폭스소프트 업무 지원

main
semin.baek 8 months ago
parent 343ad45b4b
commit 6ef36f6520

@ -0,0 +1,184 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.kdn.awms.mob.cst">
<insert id="insertFacErrCurDcuListForReceive">
/* 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')
)
</insert>
<select id="selectSigongActDcuListForSend" resultType="map">
<![CDATA[
/* AMI공사관리 시공조치내역_DCU 송신 */
SELECT 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
FROM (
SELECT 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_CHAR(WORK_DATE, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY DEPT1, BUSI_NUM, DATA_NUM, EXT_DCU_ID) AS R_NUM
FROM TM_SIGONG_ACT_DCU
WHERE 1 = 1
AND NVL(MKAMI_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
]]>
</select>
<update id="updateSigongActDcuListTransferDone">
<![CDATA[
/* AMI공사관리 시공조치내역_DCU 송신 상태 변경 */
UPDATE TM_SIGONG_ACT_DCU
SET MKAMI_SEND_YN = 'Y'
, MKAMI_SEND_DATE = SYSTIMESTAMP
WHERE 1 = 1
AND (DEPT1, BUSI_NUM, DATA_NUM, EXT_DCU_ID) IN (
SELECT DEPT1, BUSI_NUM, DATA_NUM, EXT_DCU_ID
FROM (
SELECT 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_CHAR(WORK_DATE, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY DEPT1, BUSI_NUM, DATA_NUM, EXT_DCU_ID) AS R_NUM
FROM TM_SIGONG_ACT_DCU
WHERE 1 = 1
AND NVL(MKAMI_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
)
]]>
</update>
<select id="selectSigongActModemListForSend" resultType="map">
<![CDATA[
/* AMI공사관리 시공조치내역_모뎀 송신 */
SELECT 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
FROM (
SELECT 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_CHAR(WORK_DATE, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY DEPT1, BUSI_NUM, INSTR_NUM, MAC_MODEM, EXT_FCTY_ID) AS R_NUM
FROM TM_SIGONG_ACT_MODEM
WHERE 1 = 1
AND NVL(MKAMI_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
]]>
</select>
<update id="updateSigongActModemListTransferDone">
<![CDATA[
/* AMI공사관리 시공조치내역_DCU 송신 상태 변경 */
UPDATE TM_SIGONG_ACT_MODEM
SET MKAMI_SEND_YN = 'Y'
, MKAMI_SEND_DATE = SYSTIMESTAMP
WHERE 1 = 1
AND (DEPT1, BUSI_NUM, INSTR_NUM, MAC_MODEM, EXT_FCTY_ID) IN (
SELECT DEPT1, BUSI_NUM, INSTR_NUM, MAC_MODEM, EXT_FCTY_ID
FROM (
SELECT 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_CHAR(WORK_DATE, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY DEPT1, BUSI_NUM, INSTR_NUM, MAC_MODEM, EXT_FCTY_ID) AS R_NUM
FROM TM_SIGONG_ACT_MODEM
WHERE 1 = 1
AND NVL(MKAMI_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
)
]]>
</update>
<select id="selectSigongUnableDcuListForSend" resultType="map">
<![CDATA[
/* AMI공사관리 설치불가/철거내역_DCU 송신 */
SELECT 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
FROM (
SELECT 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_CHAR(WORK_DATE, 'YYYYMMDDHH24MISS') AS WORK_DATE, WORKER1_SEQ, WORKER2_SEQ, WORKER3_SEQ, ATCH_FILE_ID_1, ATCH_FILE_ID_2, ATCH_FILE_ID_3
, 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, BUSI_NUM, DATA_NUM, DCU_ID) AS R_NUM
FROM TM_SIGONG_UNABLE_DCU
WHERE 1 = 1
AND NVL(MKAMI_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
]]>
</select>
<update id="updateSigongUnableDcuListTransferDone">
<![CDATA[
/* AMI공사관리 설치불가/철거내역_DCU 송신 상태 변경 */
UPDATE TM_SIGONG_UNABLE_DCU
SET MKAMI_SEND_YN = 'Y'
, MKAMI_SEND_DATE = SYSTIMESTAMP
WHERE 1 = 1
AND (DEPT1, BUSI_NUM, DATA_NUM, DCU_ID) IN (
SELECT DEPT1, BUSI_NUM, DATA_NUM, DCU_ID
FROM (
SELECT 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_CHAR(WORK_DATE, 'YYYYMMDDHH24MISS') AS WORK_DATE, WORKER1_SEQ, WORKER2_SEQ, WORKER3_SEQ, ATCH_FILE_ID_1, ATCH_FILE_ID_2, ATCH_FILE_ID_3
, 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, BUSI_NUM, DATA_NUM, DCU_ID) AS R_NUM
FROM TM_SIGONG_UNABLE_DCU
WHERE 1 = 1
AND NVL(MKAMI_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
)
]]>
</update>
<select id="selectSigongUnableModemListForSend" resultType="map">
<![CDATA[
/* AMI공사관리 설치불가/철거내역_모뎀 송신 */
SELECT 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
FROM (
SELECT 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_CHAR(WORK_DATE, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY DEPT1, BUSI_NUM, INSTR_NUM, EXT_FCTY_ID) AS R_NUM
FROM TM_SIGONG_UNABLE_MODEM
WHERE 1 = 1
AND NVL(MKAMI_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
]]>
</select>
<update id="updateSigongUnableModemListTransferDone">
<![CDATA[
/* AMI공사관리 설치불가/철거내역_모뎀 송신 상태 변경 */
UPDATE TM_SIGONG_UNABLE_MODEM
SET MKAMI_SEND_YN = 'Y'
, MKAMI_SEND_DATE = SYSTIMESTAMP
WHERE 1 = 1
AND (DEPT1, BUSI_NUM, INSTR_NUM, EXT_FCTY_ID) IN (
SELECT DEPT1, BUSI_NUM, INSTR_NUM, EXT_FCTY_ID
FROM (
SELECT 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_CHAR(WORK_DATE, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY DEPT1, BUSI_NUM, INSTR_NUM, EXT_FCTY_ID) AS R_NUM
FROM TM_SIGONG_UNABLE_MODEM
WHERE 1 = 1
AND NVL(MKAMI_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
)
]]>
</update>
</mapper>

@ -0,0 +1,56 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.kdn.awms.mob.emr">
<insert id="insertMeterNdlLstListForReceive">
/* 임시조치 전월검침정보(데이터) 수신 */
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')
)
</insert>
<select id="selectMeterNdlActListForSend" resultType="map">
<![CDATA[
/* 임시조치 당월검침정보(데이터) 송신 */
SELECT 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
FROM (
SELECT 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_CHAR(ACT_DATE, 'YYYYMMDDHH24MI') AS 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, TO_CHAR(REG_DATE, 'YYYYMMDD') AS REG_DATE, REG_ID
, ROW_NUMBER() OVER (ORDER BY SEQ) AS R_NUM
FROM TM_METER_NDL_ACT
WHERE 1 = 1
AND NVL(MKAMI_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
]]>
</select>
<update id="updateMeterNdlActListTransferDone">
<![CDATA[
/* 임시조치 당월검침정보(데이터) 송신 상태 변경 */
UPDATE TM_METER_NDL_ACT
SET MKAMI_SEND_YN = 'Y'
, MKAMI_SEND_DATE = SYSTIMESTAMP
WHERE 1 = 1
AND SEQ IN (
SELECT SEQ
FROM (
SELECT 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_CHAR(ACT_DATE, 'YYYYMMDDHH24MI') AS 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, TO_CHAR(REG_DATE, 'YYYYMMDD') AS REG_DATE, REG_ID
, ROW_NUMBER() OVER (ORDER BY SEQ) AS R_NUM
FROM TM_METER_NDL_ACT
WHERE 1 = 1
AND NVL(MKAMI_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
)
]]>
</update>
</mapper>

@ -183,4 +183,19 @@
) )
</insert> </insert>
<insert id="insertFctyDcuInfoListForReceive">
/* 유지관리 설비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')
)
</insert>
</mapper> </mapper>

@ -0,0 +1,106 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.kdn.mkami.mob.cst">
<select id="selectSigongMasterListForSend" resultType="map">
<![CDATA[
/* AMI공사관리 공사기본정보 송신 */
SELECT 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
FROM (
SELECT 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, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY CONS_NO, HDQR_CD) AS R_NUM
FROM T_SIGONG_MASTER
WHERE 1 = 1
AND NVL(AWMS_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
]]>
</select>
<update id="updateSigongMasterListTransferDone">
<![CDATA[
/* AMI공사관리 공사기본정보 송신 상태 변경 */
UPDATE T_SIGONG_MASTER
SET AWMS_SEND_YN = 'Y'
, AWMS_SEND_DATE = SYSDATE
WHERE 1 = 1
AND (CONS_NO, HDQR_CD) IN (
SELECT CONS_NO, HDQR_CD
FROM (
SELECT 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, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY CONS_NO, HDQR_CD) AS R_NUM
FROM T_SIGONG_MASTER
WHERE 1 = 1
AND NVL(AWMS_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
)
]]>
</update>
<insert id="insertSigongActDcuListForReceive">
/* 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')
)
</insert>
<insert id="insertSigongActModemListForReceive">
/* 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')
)
</insert>
<insert id="insertSigongUnableDcuListForReceive">
/* 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')
)
</insert>
<insert id="insertSigongUnableModemListForReceive">
/* 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')
)
</insert>
</mapper>

@ -0,0 +1,56 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.kdn.mkami.mob.emr">
<select id="selectMeterNdlLstListForSend" resultType="map">
<![CDATA[
/* 임시조치 전월검침정보(데이터) 송신 */
SELECT 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
FROM (
SELECT 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_CHAR(REG_DATE, 'YYYYMMDD') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY SEQ) AS R_NUM
FROM T_METER_NDL_LST
WHERE 1 = 1
AND NVL(AWMS_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
]]>
</select>
<update id="updateMeterNdlLstListTransferDone">
<![CDATA[
/* 임시조치 전월검침정보(데이터) 송신 상태 변경 */
UPDATE T_METER_NDL_LST
SET AWMS_SEND_YN = 'Y'
, AWMS_SEND_DATE = SYSDATE
WHERE 1 = 1
AND SEQ IN (
SELECT SEQ
FROM (
SELECT 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_CHAR(REG_DATE, 'YYYYMMDD') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY SEQ) AS R_NUM
FROM T_METER_NDL_LST
WHERE 1 = 1
AND NVL(AWMS_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
)
]]>
</update>
<insert id="insertMeterNdlActListForReceive">
/* 임시조치 당월검침정보(데이터) 수신 */
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}
)
</insert>
</mapper>

@ -220,9 +220,6 @@
WHERE 1 = 1 WHERE 1 = 1
AND (DEPT1, M_METER_ID) IN ( AND (DEPT1, M_METER_ID) IN (
SELECT DEPT1, M_METER_ID 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 ( 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 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 , MOD_ID, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
@ -237,4 +234,45 @@
]]> ]]>
</update> </update>
<select id="selectFctyDcuInfoListForSend" resultType="map">
<![CDATA[
/* 유지관리 설비DCU정보 송신 */
SELECT 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
FROM (
SELECT DCU_ID, DCU_PUBLIC_IP, DCU_USE_YN, TO_CHAR(DCU_CREATE_DATE, 'YYYYMMDDHH24MISS') AS DCU_CREATE_DATE, TO_CHAR(DCU_UPDATE_DATE, 'YYYYMMDDHH24MISS') AS DCU_UPDATE_DATE, BUSI_DIV, TO_CHAR(DCU_REMOVE_DATE, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(CONSIGN_DATE, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(N_MGMT_DT, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY DEPT1, DCU_ID) AS R_NUM
FROM T_FCTY_DCU_INFO
WHERE 1 = 1
AND NVL(AWMS_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
]]>
</select>
<update id="updateFctyDcuInfoListTransferDone">
<![CDATA[
/* 유지관리 설비DCU정보 송신 상태 변경 */
UPDATE T_FCTY_DCU_INFO
SET AWMS_SEND_YN = 'Y'
, AWMS_SEND_DATE = SYSDATE
WHERE 1 = 1
AND (DEPT1, DCU_ID) IN (
SELECT DEPT1, DCU_ID
FROM (
SELECT DCU_ID, DCU_PUBLIC_IP, DCU_USE_YN, TO_CHAR(DCU_CREATE_DATE, 'YYYYMMDDHH24MISS') AS DCU_CREATE_DATE, TO_CHAR(DCU_UPDATE_DATE, 'YYYYMMDDHH24MISS') AS DCU_UPDATE_DATE, BUSI_DIV, TO_CHAR(DCU_REMOVE_DATE, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(CONSIGN_DATE, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(N_MGMT_DT, 'YYYYMMDDHH24MISS') AS 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, TO_CHAR(MOD_DATE, 'YYYYMMDDHH24MISS') AS MOD_DATE, REG_ID, TO_CHAR(REG_DATE, 'YYYYMMDDHH24MISS') AS REG_DATE
, ROW_NUMBER() OVER (ORDER BY DEPT1, DCU_ID) AS R_NUM
FROM T_FCTY_DCU_INFO
WHERE 1 = 1
AND NVL(AWMS_SEND_YN, 'N') = 'N'
)
WHERE 1 = 1
AND R_NUM BETWEEN 1 AND 1000
)
]]>
</update>
</mapper> </mapper>

@ -12,7 +12,12 @@
"dropbox-fox-mkami-dev-oracle-receive-atch-file-detail-list", "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-dcu-list",
"dropbox-fox-mkami-dev-oracle-receive-work-act-modem-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", "dataSourceId": "ds-cubrid",
"sqlId": "com.kdn.awms.mob.obs.insertFctyCsMeterInfoListForReceive", "sqlId": "com.kdn.awms.mob.obs.insertFctyCsMeterInfoListForReceive",
"description": "유지관리 설비계기정보 수신" "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": [ "routingHostIdList": [
"fox-mkami-dev-oracle" "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": "임시조치 당월검침정보(데이터) 송신"
} }
] ]
} }

@ -17,7 +17,10 @@
"dropbox-fox-ami-dev-cubrid-receive-fac-err-cur-dcu-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-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", "dataSourceId": "ds-oracle",
"sqlId": "com.kdn.mkami.mob.obs.insertWorkActSvcCdListForReceive", "sqlId": "com.kdn.mkami.mob.obs.insertWorkActSvcCdListForReceive",
"description": "유지관리 조치내용_노임품목 수신" "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", "taskType": "DB_READ_THEN_SEND",
"action": { "action": {
"type": "SCHEDULED", "type": "SCHEDULED",
"cron": "34 0/1 * * * *" "cron": "35 0/1 * * * *"
}, },
"message": { "message": {
"messageType": "TRANSFER_DB_TO_DB", "messageType": "TRANSFER_DB_TO_DB",
@ -358,6 +396,66 @@
"fox-ami-dev-cubrid" "fox-ami-dev-cubrid"
], ],
"description": "유지관리 설비계기정보 송신" "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": "임시조치 전월검침정보(데이터) 송신"
} }
] ]
} }

Loading…
Cancel
Save