/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名：eo顧客基幹システム * モジュール名：JSYejbEKK1371A010TPDA * ソースファイル名：JSYejbEKK1371A010TPDA.java * 作成者：EK103066 * 日付：2012年03月26日 *＜機能概要＞ * SQLFacility * テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン修正日修正者修正内容 * ｖ1.00.00 * ********************************************************************************/ package eo.ejb.cbs.sqlf; import com.fujitsu.futurity.model.base.CAANMsg; import com.fujitsu.futurity.model.base.CAANSQLFacility; import com.fujitsu.futurity.model.base.CAANRuntimeException; import com.fujitsu.futurity.model.base.CAANJDBCUtil; import com.fujitsu.futurity.model.ejb.common.JSYejbConnection; import com.fujitsu.futurity.model.ejb.common.JSYejbLog; import com.fujitsu.futurity.model.ejb.common.StatusCodes; import com.fujitsu.futurity.model.ejb.common.fw.TemplateDBAccessHandler; import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import eo.ejb.cbs.cbsmsg.EKK1371A010CBSMsg; import eo.ejb.cbs.cbsmsg.EKK1371A010CBSMsg1List; import eo.ejb.cbm.entity.KK1371ETMsg; import eo.ejb.common.JKKModelCommon; import eo.ejb.common.db.JKKejbExclusiveProcKK1351; /** * * テンプレートDBアクセス部品　EKK1371A010_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbEKK1371A010TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbEKK1371A010TPDA() { } /** * EKK1371A010_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; /******************** * SQL文の作成 ********************/ try{ //コネクション取得 con1 = JSYejbConnection.getConnection(KK1371ETMsg.getTableName()); // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" KK1371.DCHSKM_TG_SVC_CD ") .append(" , KK1371.GENE_ADD_DTM ") .append(" , KK1371.DCHSKM_CD ") .append(" , (SELECT KK1351.DCHSKM_NM ") .append(" FROM KK_M_DCHSKM KK1351 ") .append(" WHERE KK1351.DCHSKM_CD = KK1371.DCHSKM_CD ") .append(" AND (KK1351.DCHSKM_CD, KK1351.RSV_APLY_YMD || KK1351.GENE_ADD_DTM) = ") .append(" (SELECT KK1351_GENE.DCHSKM_CD, MAX(KK1351_GENE.RSV_APLY_YMD || KK1351_GENE.GENE_ADD_DTM) AS KK1351_MAX ") .append(" FROM KK_M_DCHSKM KK1351_GENE ") .append(" WHERE KK1351_GENE.DCHSKM_CD = KK1351.DCHSKM_CD ") .append(" AND KK1351_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK1351_GENE.MK_FLG = '0' ") .append(" GROUP BY KK1351_GENE.DCHSKM_CD)) AS DCHSKM_CD_NM ") .append(" , KK1371.APLY_JOKEN_GRP ") .append(" , KK1371.SVC_CD ") .append(" , (SELECT KK0751.SVC_NM ") .append(" FROM KK_M_SVC KK0751 ") .append(" WHERE KK0751.SVC_CD = KK1371.SVC_CD ") .append(" AND (KK0751.SVC_CD, KK0751.RSV_APLY_YMD || KK0751.GENE_ADD_DTM) = ") .append(" (SELECT KK0751_GENE.SVC_CD, MAX(KK0751_GENE.RSV_APLY_YMD || KK0751_GENE.GENE_ADD_DTM) AS KK0751_MAX ") .append(" FROM KK_M_SVC KK0751_GENE ") .append(" WHERE KK0751_GENE.SVC_CD = KK0751.SVC_CD ") .append(" AND KK0751_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0751_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0751_GENE.SVC_CD)) AS SVC_CD_NM ") .append(" , KK1371.PRC_GRP_CD ") .append(" , (SELECT KK0781.PRC_GRP_NM ") .append(" FROM KK_M_PRC_GRP KK0781 ") .append(" WHERE KK0781.PRC_GRP_CD = KK1371.PRC_GRP_CD ") .append(" AND (KK0781.PRC_GRP_CD, KK0781.RSV_APLY_YMD || KK0781.GENE_ADD_DTM) = ") .append(" (SELECT KK0781_GENE.PRC_GRP_CD, MAX(KK0781_GENE.RSV_APLY_YMD || KK0781_GENE.GENE_ADD_DTM) AS KK0781_MAX ") .append(" FROM KK_M_PRC_GRP KK0781_GENE ") .append(" WHERE KK0781_GENE.PRC_GRP_CD = KK0781.PRC_GRP_CD ") .append(" AND KK0781_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0781_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0781_GENE.PRC_GRP_CD)) AS PRC_GRP_CD_NM ") .append(" , KK1371.PCRS_CD ") .append(" , (SELECT KK0791.PCRS_NM ") .append(" FROM KK_M_PCRS KK0791 ") .append(" WHERE KK0791.PCRS_CD = KK1371.PCRS_CD ") .append(" AND (KK0791.PCRS_CD, KK0791.RSV_APLY_YMD || KK0791.GENE_ADD_DTM) = ") .append(" (SELECT KK0791_GENE.PCRS_CD, MAX(KK0791_GENE.RSV_APLY_YMD || KK0791_GENE.GENE_ADD_DTM) AS KK0791_MAX ") .append(" FROM KK_M_PCRS KK0791_GENE ") .append(" WHERE KK0791_GENE.PCRS_CD = KK0791.PCRS_CD ") .append(" AND KK0791_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0791_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0791_GENE.PCRS_CD)) AS PCRS_CD_NM ") .append(" , KK1371.PPLAN_CD ") .append(" , (SELECT KK0591.PPLAN_NM ") .append(" FROM KK_M_PPLAN KK0591 ") .append(" WHERE KK0591.PPLAN_CD = KK1371.PPLAN_CD ") .append(" AND KK0591.MK_FLG = '0') AS PPLAN_CD_NM ") .append(" , KK1371.OP_SVC_CD ") .append(" , (SELECT KK0821.OP_SVC_NM ") .append(" FROM KK_M_OP_SVC KK0821 ") .append(" WHERE KK0821.OP_SVC_CD = KK1371.OP_SVC_CD ") .append(" AND (KK0821.OP_SVC_CD, KK0821.RSV_APLY_YMD || KK0821.GENE_ADD_DTM) = ") .append(" (SELECT KK0821_GENE.OP_SVC_CD, MAX(KK0821_GENE.RSV_APLY_YMD || KK0821_GENE.GENE_ADD_DTM) AS KK0821_MAX ") .append(" FROM KK_M_OP_SVC KK0821_GENE ") .append(" WHERE KK0821_GENE.OP_SVC_CD = KK0821.OP_SVC_CD ") .append(" AND KK0821_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0821_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0821_GENE.OP_SVC_CD)) AS OP_SVC_CD_NM ") .append(" , KK1371.SBOP_SVC_CD ") .append(" , (SELECT KK0831.SBOP_SVC_NM ") .append(" FROM KK_M_SBOP_SVC KK0831 ") .append(" WHERE KK0831.SBOP_SVC_CD = KK1371.SBOP_SVC_CD ") .append(" AND (KK0831.SBOP_SVC_CD, KK0831.GENE_ADD_DTM) = ") .append(" (SELECT KK0831_GENE.SBOP_SVC_CD, MAX(KK0831_GENE.GENE_ADD_DTM) AS KK0831_MAX ") .append(" FROM KK_M_SBOP_SVC KK0831_GENE ") .append(" WHERE KK0831_GENE.SBOP_SVC_CD = KK0831.SBOP_SVC_CD ") .append(" AND KK0831_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0831_GENE.SBOP_SVC_CD)) AS SBOP_SVC_CD_NM ") .append(" , KK1371.KKTK_SVC_CD ") .append(" , (SELECT KK0771.KKTK_SVC_NM ") .append(" FROM KK_M_KKTK_SVC KK0771 ") .append(" WHERE KK0771.KKTK_SVC_CD = KK1371.KKTK_SVC_CD ") .append(" AND KK0771.MK_FLG = '0') AS KKTK_SVC_CD_NM ") .append(" , KK1371.KKTK_SBT_CD ") .append(" , (SELECT ZM0171_01.CD_DIV_NM ") .append(" FROM ZM_M_CD_NM_KANRI ZM0171_01 ") .append(" WHERE ZM0171_01.CD_SBT_CD = 'CD00212' ") .append(" AND ZM0171_01.CD_DIV = KK1371.KKTK_SBT_CD ") .append(" AND ZM0171_01.MK_FLG = '0') AS KKTK_SBT_CD_NM ") .append(" , KK1371.SEIOPSVC_CD ") .append(" , (SELECT KK0761.SEIOPSVC_NM ") .append(" FROM KK_M_SEIOPSVC KK0761 ") .append(" WHERE KK0761.SEIOPSVC_CD = KK1371.SEIOPSVC_CD ") .append(" AND KK0761.MK_FLG = '0') AS SEIOPSVC_CD_NM ") .append(" , KK1371.CHGE_BF_SVC_CD ") .append(" , (SELECT KK0751.SVC_NM ") .append(" FROM KK_M_SVC KK0751 ") .append(" WHERE KK0751.SVC_CD = KK1371.CHGE_BF_SVC_CD ") .append(" AND (KK0751.SVC_CD, KK0751.RSV_APLY_YMD || KK0751.GENE_ADD_DTM) = ") .append(" (SELECT KK0751_GENE.SVC_CD, MAX(KK0751_GENE.RSV_APLY_YMD || KK0751_GENE.GENE_ADD_DTM) AS KK0751_MAX ") .append(" FROM KK_M_SVC KK0751_GENE ") .append(" WHERE KK0751_GENE.SVC_CD = KK0751.SVC_CD ") .append(" AND KK0751_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0751_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0751_GENE.SVC_CD)) AS CHGE_BF_SVC_CD_NM ") .append(" , KK1371.CHGE_BF_PRC_GRP_CD ") .append(" , (SELECT KK0781.PRC_GRP_NM ") .append(" FROM KK_M_PRC_GRP KK0781 ") .append(" WHERE KK0781.PRC_GRP_CD = KK1371.CHGE_BF_PRC_GRP_CD ") .append(" AND (KK0781.PRC_GRP_CD, KK0781.RSV_APLY_YMD || KK0781.GENE_ADD_DTM) = ") .append(" (SELECT KK0781_GENE.PRC_GRP_CD, MAX(KK0781_GENE.RSV_APLY_YMD || KK0781_GENE.GENE_ADD_DTM) AS KK0781_MAX ") .append(" FROM KK_M_PRC_GRP KK0781_GENE ") .append(" WHERE KK0781_GENE.PRC_GRP_CD = KK0781.PRC_GRP_CD ") .append(" AND KK0781_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0781_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0781_GENE.PRC_GRP_CD)) AS CHGE_BF_PRC_GRP_CD_NM ") .append(" , KK1371.CHGE_BF_PCRS_CD ") .append(" , (SELECT KK0791.PCRS_NM ") .append(" FROM KK_M_PCRS KK0791 ") .append(" WHERE KK0791.PCRS_CD = KK1371.CHGE_BF_PCRS_CD ") .append(" AND (KK0791.PCRS_CD, KK0791.RSV_APLY_YMD || KK0791.GENE_ADD_DTM) = ") .append(" (SELECT KK0791_GENE.PCRS_CD, MAX(KK0791_GENE.RSV_APLY_YMD || KK0791_GENE.GENE_ADD_DTM) AS KK0791_MAX ") .append(" FROM KK_M_PCRS KK0791_GENE ") .append(" WHERE KK0791_GENE.PCRS_CD = KK0791.PCRS_CD ") .append(" AND KK0791_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0791_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0791_GENE.PCRS_CD)) AS CHGE_BF_PCRS_CD_NM ") .append(" , KK1371.CHGE_BF_PPLAN_CD ") .append(" , (SELECT KK0591.PPLAN_NM ") .append(" FROM KK_M_PPLAN KK0591 ") .append(" WHERE KK0591.PPLAN_CD = KK1371.CHGE_BF_PPLAN_CD ") .append(" AND KK0591.MK_FLG = '0') AS CHGE_BF_PPLAN_CD_NM ") .append(" , KK1371.CHGE_BF_OP_SVC_CD ") .append(" , (SELECT KK0821.OP_SVC_NM ") .append(" FROM KK_M_OP_SVC KK0821 ") .append(" WHERE KK0821.OP_SVC_CD = KK1371.CHGE_BF_OP_SVC_CD ") .append(" AND (KK0821.OP_SVC_CD, KK0821.RSV_APLY_YMD || KK0821.GENE_ADD_DTM) = ") .append(" (SELECT KK0821_GENE.OP_SVC_CD, MAX(KK0821_GENE.RSV_APLY_YMD || KK0821_GENE.GENE_ADD_DTM) AS KK0821_MAX ") .append(" FROM KK_M_OP_SVC KK0821_GENE ") .append(" WHERE KK0821_GENE.OP_SVC_CD = KK0821.OP_SVC_CD ") .append(" AND KK0821_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0821_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0821_GENE.OP_SVC_CD)) AS CHGE_BF_OP_SVC_CD_NM ") .append(" , KK1371.CHGE_BF_SBOP_SVC_CD ") .append(" , (SELECT KK0831.SBOP_SVC_NM ") .append(" FROM KK_M_SBOP_SVC KK0831 ") .append(" WHERE KK0831.SBOP_SVC_CD = KK1371.CHGE_BF_SBOP_SVC_CD ") .append(" AND (KK0831.SBOP_SVC_CD, KK0831.GENE_ADD_DTM) = ") .append(" (SELECT KK0831_GENE.SBOP_SVC_CD, MAX(KK0831_GENE.GENE_ADD_DTM) AS KK0831_MAX ") .append(" FROM KK_M_SBOP_SVC KK0831_GENE ") .append(" WHERE KK0831_GENE.SBOP_SVC_CD = KK0831.SBOP_SVC_CD ") .append(" AND KK0831_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0831_GENE.SBOP_SVC_CD)) AS CHGE_BF_SBOP_SVC_CD_NM ") .append(" , KK1371.CHGE_BF_KKTK_SVC_CD ") .append(" , (SELECT KK0771.KKTK_SVC_NM ") .append(" FROM KK_M_KKTK_SVC KK0771 ") .append(" WHERE KK0771.KKTK_SVC_CD = KK1371.CHGE_BF_KKTK_SVC_CD ") .append(" AND KK0771.MK_FLG = '0') AS CHGE_BF_KKTK_SVC_CD_NM ") .append(" , KK1371.CHGE_BF_KKTK_SBT_CD ") .append(" , (SELECT ZM0171_02.CD_DIV_NM ") .append(" FROM ZM_M_CD_NM_KANRI ZM0171_02 ") .append(" WHERE ZM0171_02.CD_SBT_CD = 'CD00212' ") .append(" AND ZM0171_02.CD_DIV = KK1371.CHGE_BF_KKTK_SBT_CD ") .append(" AND ZM0171_02.MK_FLG = '0') AS CHGE_BF_KKTK_SBT_CD_NM ") .append(" , KK1371.CHGE_BF_SEIOPSVC_CD ") .append(" , (SELECT KK0761.SEIOPSVC_NM ") .append(" FROM KK_M_SEIOPSVC KK0761 ") .append(" WHERE KK0761.SEIOPSVC_CD = KK1371.CHGE_BF_SEIOPSVC_CD ") .append(" AND KK0761.MK_FLG = '0') AS CHGE_BF_SEIOPSVC_CD_NM ") .append(" , KK1371.SVC_KEI_YEAR_CNT ") .append(" , KK1371.TRGT_KEI_SVC_CNT ") .append(" , KK1371.TRGT_KEI_SVC_UPPL ") .append(" , KK1371.TRGT_SVC_HAMBET_CD ") .append(" , (SELECT ZM0171_03.CD_DIV_NM ") .append(" FROM ZM_M_CD_NM_KANRI ZM0171_03 ") .append(" WHERE ZM0171_03.CD_SBT_CD = 'CD00288' ") .append(" AND ZM0171_03.CD_DIV = KK1371.TRGT_SVC_HAMBET_CD ") .append(" AND ZM0171_03.MK_FLG = '0') AS TRGT_SVC_HAMBET_CD_NM ") .append(" , KK1371.UPPL_AUTO_APLY_KH ") .append(" , (SELECT ZM0171_04.CD_DIV_NM ") .append(" FROM ZM_M_CD_NM_KANRI ZM0171_04 ") .append(" WHERE ZM0171_04.CD_SBT_CD = 'CD00003' ") .append(" AND ZM0171_04.CD_DIV = KK1371.UPPL_AUTO_APLY_KH ") .append(" AND ZM0171_04.MK_FLG = '0') AS UPPL_AUTO_APLY_KH_NM ") .append(" , KK1371.RSV_APLY_YMD ") .append(" , KK1371.DCHSKM_TG_SVC_TSTAYMD ") .append(" , KK1371.DCHSKM_TG_SVC_TENDYMD ") .append(" , KK1371.ADD_DTM ") .append(" , KK1371.ADD_OPEACNT ") .append(" , KK1371.UPD_DTM ") .append(" , KK1371.UPD_OPEACNT ") .append(" , KK1371.DEL_DTM ") .append(" , KK1371.DEL_OPEACNT ") .append(" , KK1371.MK_FLG ") .append(" , (SELECT ZM0171_05.CD_DIV_NM ") .append(" FROM ZM_M_CD_NM_KANRI ZM0171_05 ") .append(" WHERE ZM0171_05.CD_SBT_CD = 'CD00016' ") .append(" AND ZM0171_05.CD_DIV = KK1371.MK_FLG ") .append(" AND ZM0171_05.MK_FLG = '0') AS MK_FLG_NM ") .append(" , NULL AS LAST_UPD_DTM ") .append(" FROM ") .append(" KK_M_DCHSKM_TG_SVC KK1371 "); // SQL文_個別部1 if ( "1".equals( inMsg.getObject(EKK1371A010CBSMsg.FUNC_CODE).toString() ) ) { sql_Buff.append(" WHERE ") .append(" KK1371.DCHSKM_TG_SVC_CD = ? ") .append(" AND KK1371.GENE_ADD_DTM = ? ") .append(" AND KK1371.MK_FLG = '0' "); } if ( "2".equals( inMsg.getObject(EKK1371A010CBSMsg.FUNC_CODE).toString() ) ) { sql_Buff.append(" WHERE KK1371.DCHSKM_TG_SVC_CD = ? ") .append(" AND (KK1371.DCHSKM_TG_SVC_CD, KK1371.RSV_APLY_YMD || KK1371.GENE_ADD_DTM) = ") .append(" (SELECT KK1371_GENE.DCHSKM_TG_SVC_CD, MAX(KK1371_GENE.RSV_APLY_YMD || KK1371_GENE.GENE_ADD_DTM) AS KK1371_MAX ") .append(" FROM KK_M_DCHSKM_TG_SVC KK1371_GENE ") .append(" WHERE KK1371_GENE.DCHSKM_TG_SVC_CD = KK1371.DCHSKM_TG_SVC_CD ") .append(" AND KK1371_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK1371_GENE.MK_FLG = '0' ") .append(" GROUP BY KK1371_GENE.DCHSKM_TG_SVC_CD) "); } //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに指定された値を設定 if ( "1".equals( inMsg.getString(EKK1371A010CBSMsg.FUNC_CODE) ) ) { // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 1, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 2, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 3, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 4, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 5, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 6, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 7, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 8, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 9, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(ＫＥＹ＿データ抽出項目対象サービスコードを指定) CAANJDBCUtil.setParam(pstmt, 10, inMsg.getObject(EKK1371A010CBSMsg.KEY_DCHSKM_TG_SVC_CD)); // パラメータの設定(ＫＥＹ＿世代登録年月日時分秒を指定) CAANJDBCUtil.setParam(pstmt, 11, inMsg.getObject(EKK1371A010CBSMsg.KEY_GENE_ADD_DTM)); } if ( "2".equals( inMsg.getString(EKK1371A010CBSMsg.FUNC_CODE) ) ) { // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 1, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 2, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 3, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 4, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 5, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 6, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 7, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 8, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(運用日付を指定) CAANJDBCUtil.setParam(pstmt, 9, JKKModelCommon.getOpeDate(inMsg)); // パラメータの設定(ＫＥＹ＿データ抽出項目対象サービスコードを指定) CAANJDBCUtil.setParam(pstmt, 10, inMsg.getObject(EKK1371A010CBSMsg.KEY_DCHSKM_TG_SVC_CD)); // パラメータの設定(ＫＥＹ＿予約適用年月日を指定) CAANJDBCUtil.setParam(pstmt, 11, inMsg.getObject(EKK1371A010CBSMsg.KEY_RSV_APLY_YMD)); } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EKK1371A010CBSMsgの明細にセットする項目 String[] msgKeyList1 = { EKK1371A010CBSMsg1List.DCHSKM_TG_SVC_CD , EKK1371A010CBSMsg1List.GENE_ADD_DTM , EKK1371A010CBSMsg1List.DCHSKM_CD , EKK1371A010CBSMsg1List.DCHSKM_CD_NM , EKK1371A010CBSMsg1List.APLY_JOKEN_GRP , EKK1371A010CBSMsg1List.SVC_CD , EKK1371A010CBSMsg1List.SVC_CD_NM , EKK1371A010CBSMsg1List.PRC_GRP_CD , EKK1371A010CBSMsg1List.PRC_GRP_CD_NM , EKK1371A010CBSMsg1List.PCRS_CD , EKK1371A010CBSMsg1List.PCRS_CD_NM , EKK1371A010CBSMsg1List.PPLAN_CD , EKK1371A010CBSMsg1List.PPLAN_CD_NM , EKK1371A010CBSMsg1List.OP_SVC_CD , EKK1371A010CBSMsg1List.OP_SVC_CD_NM , EKK1371A010CBSMsg1List.SBOP_SVC_CD , EKK1371A010CBSMsg1List.SBOP_SVC_CD_NM , EKK1371A010CBSMsg1List.KKTK_SVC_CD , EKK1371A010CBSMsg1List.KKTK_SVC_CD_NM , EKK1371A010CBSMsg1List.KKTK_SBT_CD , EKK1371A010CBSMsg1List.KKTK_SBT_CD_NM , EKK1371A010CBSMsg1List.SEIOPSVC_CD , EKK1371A010CBSMsg1List.SEIOPSVC_CD_NM , EKK1371A010CBSMsg1List.CHGE_BF_SVC_CD , EKK1371A010CBSMsg1List.CHGE_BF_SVC_CD_NM , EKK1371A010CBSMsg1List.CHGE_BF_PRC_GRP_CD , EKK1371A010CBSMsg1List.CHGE_BF_PRC_GRP_CD_NM , EKK1371A010CBSMsg1List.CHGE_BF_PCRS_CD , EKK1371A010CBSMsg1List.CHGE_BF_PCRS_CD_NM , EKK1371A010CBSMsg1List.CHGE_BF_PPLAN_CD , EKK1371A010CBSMsg1List.CHGE_BF_PPLAN_CD_NM , EKK1371A010CBSMsg1List.CHGE_BF_OP_SVC_CD , EKK1371A010CBSMsg1List.CHGE_BF_OP_SVC_CD_NM , EKK1371A010CBSMsg1List.CHGE_BF_SBOP_SVC_CD , EKK1371A010CBSMsg1List.CHGE_BF_SBOP_SVC_CD_NM , EKK1371A010CBSMsg1List.CHGE_BF_KKTK_SVC_CD , EKK1371A010CBSMsg1List.CHGE_BF_KKTK_SVC_CD_NM , EKK1371A010CBSMsg1List.CHGE_BF_KKTK_SBT_CD , EKK1371A010CBSMsg1List.CHGE_BF_KKTK_SBT_CD_NM , EKK1371A010CBSMsg1List.CHGE_BF_SEIOPSVC_CD , EKK1371A010CBSMsg1List.CHGE_BF_SEIOPSVC_CD_NM , EKK1371A010CBSMsg1List.SVC_KEI_YEAR_CNT , EKK1371A010CBSMsg1List.TRGT_KEI_SVC_CNT , EKK1371A010CBSMsg1List.TRGT_KEI_SVC_UPPL , EKK1371A010CBSMsg1List.TRGT_SVC_HAMBET_CD , EKK1371A010CBSMsg1List.TRGT_SVC_HAMBET_CD_NM , EKK1371A010CBSMsg1List.UPPL_AUTO_APLY_KH , EKK1371A010CBSMsg1List.UPPL_AUTO_APLY_KH_NM , EKK1371A010CBSMsg1List.RSV_APLY_YMD , EKK1371A010CBSMsg1List.DCHSKM_TG_SVC_TSTAYMD , EKK1371A010CBSMsg1List.DCHSKM_TG_SVC_TENDYMD , EKK1371A010CBSMsg1List.ADD_DTM , EKK1371A010CBSMsg1List.ADD_OPEACNT , EKK1371A010CBSMsg1List.UPD_DTM , EKK1371A010CBSMsg1List.UPD_OPEACNT , EKK1371A010CBSMsg1List.DEL_DTM , EKK1371A010CBSMsg1List.DEL_OPEACNT , EKK1371A010CBSMsg1List.MK_FLG , EKK1371A010CBSMsg1List.MK_FLG_NM , EKK1371A010CBSMsg1List.LAST_UPD_DTM }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK1371A010CBSMsg1List",0); if (outMsg1.length > 0) { String lastUpdDtm = null; // 検索結果に"データ抽出項目コード"が設定されていた場合 if (null != outMsg1[0].getString(EKK1371A010CBSMsg1List.DCHSKM_CD)) { lastUpdDtm = new JKKejbExclusiveProcKK1351().getLastUpdDtmDchskm(inMsg, outMsg1[0].getString(EKK1371A010CBSMsg1List.DCHSKM_CD)); } // 取得した最大最終更新年月日時分秒を設定 outMsg1[0].set(EKK1371A010CBSMsg1List.LAST_UPD_DTM, lastUpdDtm); } // inMsg(CBSMsg)に明細をセット inMsg.set("EKK1371A010CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(EKK1371A010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // 資源の解放 try{ if(rsltQuery != null){ rsltQuery.close(); } if(pstmt != null){ pstmt.close(); } if(con1 != null){ closeConnection(con1); } }catch(SQLException e){ inMsg.set(EKK1371A010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }