/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbEKK0081B090TPDA
* ソースファイル名：JSYejbEKK0081B090TPDA.java
* 作成者 ：EK907777
* 日付 ：2012年02月27日
*＜機能概要＞
* 契約種別一覧照会（PMP連携用）テンプレートDBアクセス部品です。
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* ｖ1.00.00
* v8.00.00 2014/03/06 FJ）窪田 ST-2014-0000069
* v12.00.00 2015/02/16 FJ）阪口 【IT1-2015-0000009】対策33:照査OKデータのみを検索対象とする
* ｖ16.00.00 2016/01/13 FJ) 寺園 【ST-2016-0000007】ｅｏ電気不具合対応
* v26.00.00 2016/07/19 FJ)頼経 ANK-2887-00-00_指示書連携の見直しについて（フェーズ２）
* v63.00.00 2022/11/22 FJ）北村 【ANK-4294-00-00】紹介CPの仕組み変更対応
*
********************************************************************************/
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.common.constant.JCKStrConst;
import eo.common.constant.JKKStrConst;
import eo.common.util.JCKLcsCommonUtil;
import eo.ejb.cbs.cbsmsg.EKK0081B090CBSMsg;
import eo.ejb.cbs.cbsmsg.EKK0081B090CBSMsg1List;
import eo.ejb.cbm.entity.KK0081ETMsg;
import eo.ejb.common.JCCModelCommon;
/**
*
* テンプレートDBアクセス部品 EKK0081B090_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/
public class JSYejbEKK0081B090TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
/**
* コンストラクタ
*/
public JSYejbEKK0081B090TPDA() {
}
/**
* EKK0081B090_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(KK0081ETMsg.getTableName());
// SQL文_基本部1
StringBuffer sql_Buff = new StringBuffer();
sql_Buff.append(" SELECT ")
.append(" SVC.SVC_KEI_NO ")
.append(" ,SVC.SVC_CD ")
.append(" ,SVC.PRC_GRP_CD ")
.append(" ,DECODE(SVC.SVC_CD,'51','04',SVC.SVC_CD) OLD_ICS_CONTRACT_CD ")
.append(" ,CASE SVC.PRC_GRP_CD ")
.append(" WHEN '" + JCKStrConst.PRC_GRP_CD_EOH_TEL + "' THEN ICS_CD_SVC.OLD_ICS_HUKA_SVC_SBT_CD ")
.append(" ELSE ICS_CD_SVC.OLD_ICS_KEI_SVC_CD ")
.append(" END AS OLD_ICS_KEI_SVC_CD ")
// v26.00.00 ANK-2887-00-00 ADD START
.append(" ,ICS_CD_SVC.OLD_ICS_PPLAN_CD ")
// v26.00.00 ANK-2887-00-00 ADD END
.append(" FROM KK_T_SVC_KEI SVC ");
// SQL文_個別部1
if ( "1".equals( inMsg.getObject(EKK0081B090CBSMsg.FUNC_CODE).toString() ) ) {
sql_Buff.append(" /* 料金グループ */ ")
.append(" INNER JOIN KK_M_PRC_GRP PRCGRP ")
.append(" ON PRCGRP.PRC_GRP_CD = SVC.PRC_GRP_CD ")
.append(" AND PRCGRP.RSV_APLY_YMD || PRCGRP.GENE_ADD_DTM = ")
.append(" (SELECT MAX(PRCGRP_GENE.RSV_APLY_YMD || PRCGRP_GENE.GENE_ADD_DTM) AS PRCGRP_MAX ")
.append(" FROM KK_M_PRC_GRP PRCGRP_GENE ")
.append(" WHERE PRCGRP_GENE.PRC_GRP_CD = PRCGRP.PRC_GRP_CD ")
.append(" AND PRCGRP_GENE.RSV_APLY_YMD <= ? ")
.append(" AND PRCGRP_GENE.PRC_GRP_TSTAYMD <= ? ")
.append(" AND PRCGRP_GENE.PRC_GRP_TENDYMD >= ? ")
.append(" AND PRCGRP_GENE.MK_FLG = '0') ")
.append(" /* 料金コース */ ")
.append(" INNER JOIN KK_M_PCRS PCRS ")
.append(" ON PCRS.PCRS_CD = SVC.PCRS_CD ")
.append(" /* 旧ICSコード変換 */ ")
.append(" INNER JOIN KK_M_OLD_ICS_CD_CHG ICS_CD_SVC ")
.append(" ON ICS_CD_SVC.PRC_GRP_CD = SVC.PRC_GRP_CD AND ICS_CD_SVC.PCRS_CD = SVC.PCRS_CD AND ICS_CD_SVC.PPLAN_CD = SVC.PPLAN_CD ")
.append(" WHERE SVC.SYSID = ? ")
.append(" AND SVC.SVC_CD <> ? /*標準コンテンツ同意のサービスコード*/ ")
.append(" AND SVC.SVC_KEI_STAT IN (" + JCKLcsCommonUtil.convert2String(JCKStrConst.TKCHU_SVC_KEI_STAT_FOR_PMP, "'") + ") ")
// IT1-2015-0000009 ADD START
.append(" AND (SVC.SHOSA_DSL_FIN_CD IS NULL OR SVC.SHOSA_DSL_FIN_CD <> '2') ")
// IT1-2015-0000009 ADD END
.append(" AND SVC.RSV_APLY_YMD || SVC.GENE_ADD_DTM = ")
.append(" (SELECT MAX(SVC_GENE.RSV_APLY_YMD || SVC_GENE.GENE_ADD_DTM) AS SVC_MAX ")
.append(" FROM KK_T_SVC_KEI SVC_GENE ")
.append(" WHERE SVC_GENE.SVC_KEI_NO = SVC.SVC_KEI_NO ")
.append(" AND SVC_GENE.RSV_APLY_YMD <= ? ")
.append(" AND SVC_GENE.RSV_APLY_CD = '2' ")
.append(" AND SVC_GENE.MK_FLG = '0') ")
.append(" AND PCRS.RSV_APLY_YMD || PCRS.GENE_ADD_DTM =")
.append(" (SELECT MAX(GENE.RSV_APLY_YMD || GENE.GENE_ADD_DTM) ")
.append(" FROM KK_M_PCRS GENE ")
.append(" WHERE GENE.PCRS_CD = PCRS.PCRS_CD ")
.append(" AND GENE.RSV_APLY_YMD <= ? ")
.append(" AND GENE.MK_FLG = '0') ")
// ST-2016-0000007 MOD START
// .append(" AND ((PCRS.ID_TCHISHO_HAK_SKBT_CD <> '0' AND SVC.SVC_CD <> '51') ")
// .append(" OR (PCRS.ID_TCHISHO_HAK_SKBT_CD = '0' AND SVC.SVC_CD = '51')) ")
.append(" AND ((PCRS.ID_TCHISHO_HAK_SKBT_CD <> '0' AND SVC.SVC_CD NOT IN('05','51')) ")
.append(" OR (PCRS.ID_TCHISHO_HAK_SKBT_CD = '0' AND SVC.SVC_CD IN('05','51'))) ")
// ST-2016-0000007 MOD END
.append(" AND NVL(ICS_CD_SVC.SOKU_WARI_UM, '0') = ")
.append(" (SELECT CASE ")
.append(" WHEN EXISTS ")
.append(" (SELECT 1 ")
.append(" FROM KK_T_WRISVC_TG_KEI WRISVC_TG_KEI ")
.append(" INNER JOIN ")
.append(" KK_T_WRIB_SVC_KEI WRIB_SVC_KEI ON WRISVC_TG_KEI.WRIB_SVC_KEI_NO = WRIB_SVC_KEI.WRIB_SVC_KEI_NO ")
.append(" INNER JOIN ")
.append(" KK_M_WRIB_SVC WRIB_SVC ON WRIB_SVC_KEI.WRIB_SVC_CD = WRIB_SVC.WRIB_SVC_CD ")
.append(" WHERE WRISVC_TG_KEI.SVC_KEI_NO = SVC.SVC_KEI_NO ")
.append(" AND WRISVC_TG_KEI.GENE_ADD_DTM = ")
.append(" (SELECT MAX(GENE.GENE_ADD_DTM) ")
.append(" FROM KK_T_WRISVC_TG_KEI GENE ")
.append(" WHERE GENE.WRIB_SVC_KEI_NO = WRISVC_TG_KEI.WRIB_SVC_KEI_NO ")
.append(" AND GENE.WRIB_SVC_TRGT_KEI_NO = WRISVC_TG_KEI.WRIB_SVC_TRGT_KEI_NO ")
.append(" ) ")
.append(" AND WRISVC_TG_KEI.WRISVC_TG_KEI_TSTAYMD <= ? ")
.append(" AND WRISVC_TG_KEI.WRISVC_TG_KEI_TENDYMD >= ? ")
.append(" AND WRISVC_TG_KEI.MK_FLG = '0' ")
.append(" AND WRIB_SVC_KEI.WRIB_SVC_KEI_STAT IN (" + JCKLcsCommonUtil.convert2String(JCKStrConst.TKCHU_WRIB_SVC_KEI_STAT_FOR_PMP, "'") + ") /* サービス提供中 */ ")
.append(" AND WRIB_SVC_KEI.RSV_APLY_YMD || WRIB_SVC_KEI.GENE_ADD_DTM = ")
.append(" (SELECT MAX(GENE.RSV_APLY_YMD || GENE.GENE_ADD_DTM) ")
.append(" FROM KK_T_WRIB_SVC_KEI GENE ")
.append(" WHERE GENE.WRIB_SVC_KEI_NO = WRIB_SVC_KEI.WRIB_SVC_KEI_NO ")
.append(" AND GENE.RSV_APLY_YMD <= ? ")
.append(" AND GENE.MK_FLG = '0' ")
.append(" ) ")
.append(" AND WRIB_SVC.WRIB_TYPE_CD = '" + JCKStrConst.WRIB_TYPE_CD_SOKU_WARI + "' /* 即割り */ ")
.append(" AND WRIB_SVC.RSV_APLY_YMD || WRIB_SVC.GENE_ADD_DTM = ")
.append(" (SELECT MAX(GENE.RSV_APLY_YMD || GENE.GENE_ADD_DTM) ")
.append(" FROM KK_M_WRIB_SVC GENE ")
.append(" WHERE GENE.WRIB_SVC_CD = WRIB_SVC.WRIB_SVC_CD ")
.append(" AND GENE.RSV_APLY_YMD <= ? ")
.append(" AND GENE.MK_FLG = '0' ")
.append(" ) ")
.append(" ) THEN '1' ")
.append(" ELSE '0' ")
.append(" END AS SOKU_WARI_UM ")
.append(" FROM DUAL ")
.append(" ) ")
.append(" AND ICS_CD_SVC.OLD_ICS_CD_CHG_TSTAYMD <= ? ")
.append(" AND ICS_CD_SVC.OLD_ICS_CD_CHG_TENDYMD >= ? ")
.append(" AND ICS_CD_SVC.RNK_SAKI_SYS_SKBT_CD = '" + JCKStrConst.RNK_SAKI_SYS_SKBT_CD_AXM + "' ")
.append(" AND ICS_CD_SVC.MK_FLG = '0' ")
.append(" ORDER BY PRCGRP.DSP_JUN, ICS_CD_SVC.OLD_ICS_KEI_SVC_CD, ICS_CD_SVC.OLD_ICS_PPLAN_CD, SVC.SVC_KEI_NO ");
}
// v63.00.00 ANK-4294-00-00 ADD START
// SQL文_個別部3
else if ( "3".equals( inMsg.getObject(EKK0081B090CBSMsg.FUNC_CODE).toString() ) )
{
sql_Buff.append(" /* 料金グループ */ ")
.append(" INNER JOIN KK_M_PRC_GRP PRCGRP ")
.append(" ON PRCGRP.PRC_GRP_CD = SVC.PRC_GRP_CD ")
.append(" AND PRCGRP.RSV_APLY_YMD || PRCGRP.GENE_ADD_DTM = ")
.append(" (SELECT MAX(PRCGRP_GENE.RSV_APLY_YMD || PRCGRP_GENE.GENE_ADD_DTM) AS PRCGRP_MAX ")
.append(" FROM KK_M_PRC_GRP PRCGRP_GENE ")
.append(" WHERE PRCGRP_GENE.PRC_GRP_CD = PRCGRP.PRC_GRP_CD ")
.append(" AND PRCGRP_GENE.RSV_APLY_YMD <= ? ")
.append(" AND PRCGRP_GENE.PRC_GRP_TSTAYMD <= ? ")
.append(" AND PRCGRP_GENE.PRC_GRP_TENDYMD >= ? ")
.append(" AND PRCGRP_GENE.MK_FLG = '0') ")
.append(" /* 料金コース */ ")
.append(" INNER JOIN KK_M_PCRS PCRS ")
.append(" ON PCRS.PCRS_CD = SVC.PCRS_CD ")
.append(" /* 旧ICSコード変換 */ ")
.append(" INNER JOIN KK_M_OLD_ICS_CD_CHG ICS_CD_SVC ")
.append(" ON ICS_CD_SVC.PRC_GRP_CD = SVC.PRC_GRP_CD AND ICS_CD_SVC.PCRS_CD = SVC.PCRS_CD AND ICS_CD_SVC.PPLAN_CD = SVC.PPLAN_CD ")
.append(" WHERE SVC.SYSID = ? ")
.append(" AND SVC.SVC_CD = '" + JCKStrConst.SVC_CD_NET + "' /* ネットサービスのみ抽出 */ ")
.append(" AND SVC.PCRS_CD <> '" + JKKStrConst.CD00134_A88 + "' /* 料金コースコード 卸１ギガコースは対象外 */ ")
.append(" AND SVC.SVC_KEI_STAT IN (" + JCKLcsCommonUtil.convert2String(JCKStrConst.TKCHU_SVC_KEI_STAT_FOR_PMP, "'") + ") ")
.append(" AND (SVC.SHOSA_DSL_FIN_CD IS NULL OR SVC.SHOSA_DSL_FIN_CD <> '2') ")
.append(" AND SVC.RSV_APLY_YMD || SVC.GENE_ADD_DTM = ")
.append(" (SELECT MAX(SVC_GENE.RSV_APLY_YMD || SVC_GENE.GENE_ADD_DTM) AS SVC_MAX ")
.append(" FROM KK_T_SVC_KEI SVC_GENE ")
.append(" WHERE SVC_GENE.SVC_KEI_NO = SVC.SVC_KEI_NO ")
.append(" AND SVC_GENE.RSV_APLY_YMD <= ? ")
.append(" AND SVC_GENE.RSV_APLY_CD = '2' ")
.append(" AND SVC_GENE.MK_FLG = '0') ")
.append(" AND PCRS.RSV_APLY_YMD || PCRS.GENE_ADD_DTM =")
.append(" (SELECT MAX(GENE.RSV_APLY_YMD || GENE.GENE_ADD_DTM) ")
.append(" FROM KK_M_PCRS GENE ")
.append(" WHERE GENE.PCRS_CD = PCRS.PCRS_CD ")
.append(" AND GENE.RSV_APLY_YMD <= ? ")
.append(" AND GENE.MK_FLG = '0') ")
.append(" AND ((PCRS.ID_TCHISHO_HAK_SKBT_CD <> '0' AND SVC.SVC_CD NOT IN('05','51')) ")
.append(" OR (PCRS.ID_TCHISHO_HAK_SKBT_CD = '0' AND SVC.SVC_CD IN('05','51'))) ")
.append(" AND NVL(ICS_CD_SVC.SOKU_WARI_UM, '0') = ")
.append(" (SELECT CASE ")
.append(" WHEN EXISTS ")
.append(" (SELECT 1 ")
.append(" FROM KK_T_WRISVC_TG_KEI WRISVC_TG_KEI ")
.append(" INNER JOIN ")
.append(" KK_T_WRIB_SVC_KEI WRIB_SVC_KEI ON WRISVC_TG_KEI.WRIB_SVC_KEI_NO = WRIB_SVC_KEI.WRIB_SVC_KEI_NO ")
.append(" INNER JOIN ")
.append(" KK_M_WRIB_SVC WRIB_SVC ON WRIB_SVC_KEI.WRIB_SVC_CD = WRIB_SVC.WRIB_SVC_CD ")
.append(" WHERE WRISVC_TG_KEI.SVC_KEI_NO = SVC.SVC_KEI_NO ")
.append(" AND WRISVC_TG_KEI.GENE_ADD_DTM = ")
.append(" (SELECT MAX(GENE.GENE_ADD_DTM) ")
.append(" FROM KK_T_WRISVC_TG_KEI GENE ")
.append(" WHERE GENE.WRIB_SVC_KEI_NO = WRISVC_TG_KEI.WRIB_SVC_KEI_NO ")
.append(" AND GENE.WRIB_SVC_TRGT_KEI_NO = WRISVC_TG_KEI.WRIB_SVC_TRGT_KEI_NO ")
.append(" ) ")
.append(" AND WRISVC_TG_KEI.WRISVC_TG_KEI_TSTAYMD <= ? ")
.append(" AND WRISVC_TG_KEI.WRISVC_TG_KEI_TENDYMD >= ? ")
.append(" AND WRISVC_TG_KEI.MK_FLG = '0' ")
.append(" AND WRIB_SVC_KEI.WRIB_SVC_KEI_STAT IN (" + JCKLcsCommonUtil.convert2String(JCKStrConst.TKCHU_WRIB_SVC_KEI_STAT_FOR_PMP, "'") + ") /* サービス提供中 */ ")
.append(" AND WRIB_SVC_KEI.RSV_APLY_YMD || WRIB_SVC_KEI.GENE_ADD_DTM = ")
.append(" (SELECT MAX(GENE.RSV_APLY_YMD || GENE.GENE_ADD_DTM) ")
.append(" FROM KK_T_WRIB_SVC_KEI GENE ")
.append(" WHERE GENE.WRIB_SVC_KEI_NO = WRIB_SVC_KEI.WRIB_SVC_KEI_NO ")
.append(" AND GENE.RSV_APLY_YMD <= ? ")
.append(" AND GENE.MK_FLG = '0' ")
.append(" ) ")
.append(" AND WRIB_SVC.WRIB_TYPE_CD = '" + JCKStrConst.WRIB_TYPE_CD_SOKU_WARI + "' /* 即割り */ ")
.append(" AND WRIB_SVC.RSV_APLY_YMD || WRIB_SVC.GENE_ADD_DTM = ")
.append(" (SELECT MAX(GENE.RSV_APLY_YMD || GENE.GENE_ADD_DTM) ")
.append(" FROM KK_M_WRIB_SVC GENE ")
.append(" WHERE GENE.WRIB_SVC_CD = WRIB_SVC.WRIB_SVC_CD ")
.append(" AND GENE.RSV_APLY_YMD <= ? ")
.append(" AND GENE.MK_FLG = '0' ")
.append(" ) ")
.append(" ) THEN '1' ")
.append(" ELSE '0' ")
.append(" END AS SOKU_WARI_UM ")
.append(" FROM DUAL ")
.append(" ) ")
.append(" AND ICS_CD_SVC.OLD_ICS_CD_CHG_TSTAYMD <= ? ")
.append(" AND ICS_CD_SVC.OLD_ICS_CD_CHG_TENDYMD >= ? ")
.append(" AND ICS_CD_SVC.RNK_SAKI_SYS_SKBT_CD = '" + JCKStrConst.RNK_SAKI_SYS_SKBT_CD_AXM + "' ")
.append(" AND ICS_CD_SVC.MK_FLG = '0' ")
.append(" ORDER BY PRCGRP.DSP_JUN, ")
.append(" ICS_CD_SVC.OLD_ICS_KEI_SVC_CD, ")
.append(" ICS_CD_SVC.OLD_ICS_PPLAN_CD, ")
.append(" SVC.SVC_KEI_NO ");
}
// v63.00.00 ANK-4294-00-00 ADD END
//prepareStatementにSQL文をセット
pstmt = con1.prepareStatement(sql_Buff.toString());
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);
// 運用日付の取得
String opeDate = JCCModelCommon.getOpeDate(inMsg, null);
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ( "1".equals( inMsg.getString(EKK0081B090CBSMsg.FUNC_CODE) ) ) {
int paramIdx = 0;
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, inMsg.getObject(EKK0081B090CBSMsg.KEY_SYSID));
CAANJDBCUtil.setParam(pstmt, ++paramIdx, JCKStrConst.SVC_CD_HOSTING);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
}
// v63.00.00 ANK-4294-00-00 ADD START
else if ("3".equals( inMsg.getString(EKK0081B090CBSMsg.FUNC_CODE)))
{
int paramIdx = 0;
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, inMsg.getObject(EKK0081B090CBSMsg.KEY_SYSID));
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
CAANJDBCUtil.setParam(pstmt, ++paramIdx, opeDate);
}
// v63.00.00 ANK-4294-00-00 ADD END
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// EKK0081B090CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
EKK0081B090CBSMsg1List.SVC_KEI_NO
, EKK0081B090CBSMsg1List.SVC_CD
, EKK0081B090CBSMsg1List.PRC_GRP_CD
, EKK0081B090CBSMsg1List.CONTRACT_CD
, EKK0081B090CBSMsg1List.SERVICE_CD_PRE
// v26.00.00 ANK-2887-00-00 ADD START
, EKK0081B090CBSMsg1List.OLD_ICS_PPLAN_CD
// v26.00.00 ANK-2887-00-00 ADD END
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK0081B090CBSMsg1List",0);
// inMsg(CBSMsg)に明細をセット
inMsg.set("EKK0081B090CBSMsg1List", outMsg1);
} catch(SQLException e) {
inMsg.set(EKK0081B090CBSMsg.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(EKK0081B090CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
}
}