/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbEKK1351B002TPDA * ソースファイル名：JSYejbEKK1351B002TPDA.java * 作成者 ：EK103161 * 日付 ：2012年03月28日 *＜機能概要＞ * データ抽出項目一覧照会２テンプレート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 java.util.ArrayList; import eo.common.constant.JPCModelConstant; import eo.ejb.cbs.cbsmsg.EKK1351B002CBSMsg; import eo.ejb.cbs.cbsmsg.EKK1351B002CBSMsg1List; import eo.ejb.cbm.entity.KK1351ETMsg; import eo.ejb.common.JKKModelCommon; /** * * テンプレートDBアクセス部品　EKK1351B002_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbEKK1351B002TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbEKK1351B002TPDA() { } /** * EKK1351B002_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt_Count = null; PreparedStatement pstmt_Select = null; // リザルトセット ResultSet rsltQuery_Count = null; ResultSet rsltQuery_Select = null; // PreparedStatementのパラメータカウント int iPCnt = 0; // 運用日付の取得 String opeDate = JKKModelCommon.getOpeDate(inMsg); /******************** * SQL文の作成 ********************/ try{ // バインド変数設定値保持用領域 ArrayList arrayParam = new ArrayList(); // バインド変数設定値保持用領域(WHERE区用) ArrayList arrayParamWhere = new ArrayList(); //コネクション取得 con1 = JSYejbConnection.getConnection(KK1351ETMsg.getTableName()); // SQL文の作成(COUNT用) // (1) StringBuffer sql_Buff1 = new StringBuffer(); sql_Buff1.append(" SELECT ") .append(" COUNT(*) AS KK1351_CNT "); // SQL文(SELECT句) // (2) StringBuffer sql_Buff2 = new StringBuffer(); sql_Buff2.append(" SELECT ") .append(" KK1351.DCHSKM_CD ") .append(" ,KK1351.GENE_ADD_DTM ") .append(" ,KK1351.DCHS_TYPE_CD ") .append(" ,KK1351.DSP_DCHSKM_CD ") .append(" ,KK1351.DCHSKM_NM ") .append(" ,KK1351.SET_PSB_STA_YMDHM ") .append(" ,KK1351.SET_PSB_END_YMDHM ") .append(" ,KK1351.DCHS_APLY_OPTNTY_CD ") .append(" ,KK1351.DCHS_RLS_OPTNTY_CD ") .append(" ,KK1351.DCHS_SBT_CD ") .append(" ,KK1351.DCHSKM_STA_CD ") .append(" ,KK1351.STA_ADJ_CD ") .append(" ,KK1351.STA_ADJ_PRD ") .append(" ,KK1351.DCHSKM_END_CD ") .append(" ,KK1351.UPPL_APLY_CNT ") .append(" ,KK1351.DCHSKM_AGING_PRD ") .append(" ,KK1351.UPPL_KEI_CNT ") .append(" ,KK1351.DSP_JUN ") .append(" ,KK1351.JOKEN_TSTAYMD ") .append(" ,KK1351.JOKEN_TENDYMD ") .append(" ,KK1351.APLY_CNT_HAMBET_CD ") .append(" ,KK1351.APLY_CNT ") .append(" ,KK1351.APLY_JOKEN_CD ") .append(" ,KK1351.DCHS_ADD_JOKEN_CD ") .append(" ,KK1351.RSV_APLY_YMD ") .append(" ,KK1351.DCHSKM_TSTAYMD ") .append(" ,KK1351.DCHSKM_TENDYMD ") .append(" ,KK1351.UPD_DTM ") .append(" ,KK1371.DCHSKM_TG_SVC_CD ") .append(" ,KK1371.APLY_JOKEN_GRP ") .append(" ,KK1371.SVC_CD ") .append(" ,KK1371.PRC_GRP_CD ") .append(" ,KK1371.PCRS_CD ") .append(" ,KK1371.PPLAN_CD ") .append(" ,KK1371.OP_SVC_CD ") .append(" ,KK1371.SBOP_SVC_CD ") .append(" ,KK1371.KKTK_SVC_CD ") .append(" ,KK1371.KKTK_SBT_CD ") .append(" ,KK1371.SEIOPSVC_CD ") .append(" ,KK1371.CHGE_BF_SVC_CD ") .append(" ,KK1371.CHGE_BF_PRC_GRP_CD ") .append(" ,KK1371.CHGE_BF_PCRS_CD ") .append(" ,KK1371.CHGE_BF_PPLAN_CD ") .append(" ,KK1371.CHGE_BF_OP_SVC_CD ") .append(" ,KK1371.CHGE_BF_SBOP_SVC_CD ") .append(" ,KK1371.CHGE_BF_KKTK_SVC_CD ") .append(" ,KK1371.CHGE_BF_KKTK_SBT_CD ") .append(" ,KK1371.CHGE_BF_SEIOPSVC_CD ") .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(" ,KK1371.UPPL_AUTO_APLY_KH "); // SQL文(FROM句) // (3) StringBuffer sql_Buff3 = new StringBuffer(); sql_Buff3.append(" FROM ") .append(" KK_M_DCHSKM KK1351 ") .append(" LEFT OUTER JOIN ") .append(" ( ") .append(" SELECT ") .append(" KK1371_00.DCHSKM_CD ") .append(" ,KK1371_00.DCHSKM_TG_SVC_CD ") .append(" ,KK1371_00.APLY_JOKEN_GRP ") .append(" ,KK1371_00.SVC_CD ") .append(" ,KK1371_00.PRC_GRP_CD ") .append(" ,KK1371_00.PCRS_CD ") .append(" ,KK1371_00.PPLAN_CD ") .append(" ,KK1371_00.OP_SVC_CD ") .append(" ,KK1371_00.SBOP_SVC_CD ") .append(" ,KK1371_00.KKTK_SVC_CD ") .append(" ,KK1371_00.KKTK_SBT_CD ") .append(" ,KK1371_00.SEIOPSVC_CD ") .append(" ,KK1371_00.CHGE_BF_SVC_CD ") .append(" ,KK1371_00.CHGE_BF_PRC_GRP_CD ") .append(" ,KK1371_00.CHGE_BF_PCRS_CD ") .append(" ,KK1371_00.CHGE_BF_PPLAN_CD ") .append(" ,KK1371_00.CHGE_BF_OP_SVC_CD ") .append(" ,KK1371_00.CHGE_BF_SBOP_SVC_CD ") .append(" ,KK1371_00.CHGE_BF_KKTK_SVC_CD ") .append(" ,KK1371_00.CHGE_BF_KKTK_SBT_CD ") .append(" ,KK1371_00.CHGE_BF_SEIOPSVC_CD ") .append(" ,KK1371_00.SVC_KEI_YEAR_CNT ") .append(" ,KK1371_00.TRGT_KEI_SVC_CNT ") .append(" ,KK1371_00.TRGT_KEI_SVC_UPPL ") .append(" ,KK1371_00.TRGT_SVC_HAMBET_CD ") .append(" ,KK1371_00.UPPL_AUTO_APLY_KH ") .append(" FROM ") .append(" KK_M_DCHSKM_TG_SVC KK1371_00 ") .append(" WHERE ") .append(" KK1371_00.DCHSKM_TG_SVC_CD || KK1371_00.GENE_ADD_DTM = ") .append(" (SELECT ") .append(" MIN(KK1371_01.DCHSKM_TG_SVC_CD || KK1371_01.GENE_ADD_DTM) ") .append(" FROM ") .append(" KK_M_DCHSKM_TG_SVC KK1371_01 ") .append(" WHERE ") .append(" KK1371_01.DCHSKM_CD = KK1371_00.DCHSKM_CD ") .append(" AND KK1371_01.DCHSKM_TG_SVC_TSTAYMD <= ? ") .append(" AND KK1371_01.DCHSKM_TG_SVC_TENDYMD >= ? "); // パラメータの設定(運用日付を指定) arrayParam.add(opeDate); // パラメータの設定(運用日付を指定) arrayParam.add(opeDate); // サービスIF入力値：ＫＥＹ＿サービスコードが入力された場合 if (!inMsg.isNull(EKK1351B002CBSMsg.KEY_SVC_CD)) { sql_Buff3.append(" AND KK1371_01.SVC_CD = ? "); // パラメータの設定(ＫＥＹ＿サービスコードを指定) arrayParam.add(inMsg.getObject(EKK1351B002CBSMsg.KEY_SVC_CD)); } // サービスIF入力値：ＫＥＹ＿料金グループコードが入力された場合 if (!inMsg.isNull(EKK1351B002CBSMsg.KEY_PRC_GRP_CD)) { sql_Buff3.append(" AND KK1371_01.PRC_GRP_CD = ? "); // パラメータの設定(ＫＥＹ＿料金グループコードを指定) arrayParam.add(inMsg.getObject(EKK1351B002CBSMsg.KEY_PRC_GRP_CD)); } // サービスIF入力値：ＫＥＹ＿料金コースコードが入力された場合 if (!inMsg.isNull(EKK1351B002CBSMsg.KEY_PCRS_CD)) { sql_Buff3.append(" AND KK1371_01.PCRS_CD = ? "); // パラメータの設定(ＫＥＹ＿料金コースコードを指定) arrayParam.add(inMsg.getObject(EKK1351B002CBSMsg.KEY_PCRS_CD)); } // サービスIF入力値：ＫＥＹ＿料金プランコードが入力された場合 if (!inMsg.isNull(EKK1351B002CBSMsg.KEY_PPLAN_CD)) { sql_Buff3.append(" AND KK1371_01.PPLAN_CD = ? "); // パラメータの設定(ＫＥＹ＿料金プランコードを指定) arrayParam.add(inMsg.getObject(EKK1351B002CBSMsg.KEY_PPLAN_CD)); } sql_Buff3.append(" AND (KK1371_01.DCHSKM_TG_SVC_CD, KK1371_01.RSV_APLY_YMD || KK1371_01.GENE_ADD_DTM) = ") .append(" (SELECT ") .append(" KK1371_02.DCHSKM_TG_SVC_CD, MAX(KK1371_02.RSV_APLY_YMD || KK1371_02.GENE_ADD_DTM) ") .append(" FROM ") .append(" KK_M_DCHSKM_TG_SVC KK1371_02 ") .append(" WHERE ") .append(" KK1371_02.DCHSKM_TG_SVC_CD = KK1371_01.DCHSKM_TG_SVC_CD ") .append(" AND KK1371_02.RSV_APLY_YMD <= ? ") .append(" AND KK1371_02.MK_FLG = '0' ") .append(" GROUP BY KK1371_02.DCHSKM_TG_SVC_CD ") .append(" ) ") .append(" ) ") .append(" ) KK1371 ON KK1371.DCHSKM_CD = KK1351.DCHSKM_CD "); // パラメータの設定(運用日付を指定) arrayParam.add(opeDate); // SQL文の作成(WHERE句) // (4) StringBuffer sql_Buff4 = new StringBuffer(); sql_Buff4.append(" WHERE ") .append(" KK1351.DCHS_TYPE_CD = ? "); // パラメータの設定(ＫＥＹ＿データ抽出タイプコードを指定) arrayParamWhere.add(inMsg.getObject(EKK1351B002CBSMsg.KEY_DCHS_TYPE_CD)); // サービスIF入力値：ＫＥＹ＿表示用データ抽出項目コードが入力された場合 if (!inMsg.isNull(EKK1351B002CBSMsg.KEY_DSP_DCHSKM_CD)) { sql_Buff4.append(" AND KK1351.DSP_DCHSKM_CD = ? "); // パラメータの設定(ＫＥＹ＿表示用データ抽出項目コードを指定) arrayParamWhere.add(inMsg.getObject(EKK1351B002CBSMsg.KEY_DSP_DCHSKM_CD)); } sql_Buff4.append(" AND KK1351.DCHSKM_TSTAYMD <= ? ") .append(" AND KK1351.DCHSKM_TENDYMD >= ? ") .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) ") .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 ) "); // パラメータの設定(運用日付を指定) arrayParamWhere.add(opeDate); // パラメータの設定(運用日付を指定) arrayParamWhere.add(opeDate); // パラメータの設定(運用日付を指定) arrayParamWhere.add(opeDate); // SQL文の作成(ORDER BY句) // (5) StringBuffer sql_Buff5 = new StringBuffer(); sql_Buff5.append(" ORDER BY KK1351.DCHSKM_CD ASC "); // カウントの取得 // SQL文の組立て(件数取得用) (1) + (3) + (4) StringBuffer sql_Count = new StringBuffer(); sql_Count.append(sql_Buff1) .append(sql_Buff3); // SQL文_個別部1 if ( "1".equals( inMsg.getString(EKK1351B002CBSMsg.FUNC_CODE) ) ) { sql_Count.append(sql_Buff4); } //prepareStatementにSQL文をセット pstmt_Count = con1.prepareStatement(sql_Count.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Count); // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 for ( int i = 0; i < arrayParam.size(); i++ ) { CAANJDBCUtil.setParam(pstmt_Count, ++iPCnt, arrayParam.get(i)); } // PreparedStatementの指定されたパラメータカラムに 指定された値を設定(WHERE部) if ( "1".equals( inMsg.getString(EKK1351B002CBSMsg.FUNC_CODE) ) ) { for ( int i = 0; i < arrayParamWhere.size(); i++ ) { CAANJDBCUtil.setParam(pstmt_Count, ++iPCnt, arrayParamWhere.get(i)); } } // ResultSetの取得 rsltQuery_Count = pstmt_Count.executeQuery(); // 総検索件数を取得する Long lDataCnt = 0L; if (rsltQuery_Count.next()) { lDataCnt = rsltQuery_Count.getLong("KK1351_CNT"); } // 共通部に値を設定する (総検索件数) inMsg.set(EKK1351B002CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(lDataCnt)); // データ取得件数が0件の場合エラー if (0L == lDataCnt) { inMsg.set(EKK1351B002CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO); return; } // 最大取得件数 Long lMaxNum = inMsg.getStringAsLong(EKK1351B002CBSMsg.MAX_SEARCH_NUM); // 最大取得件数を超えた場合エラー if (lDataCnt > lMaxNum) { inMsg.set(EKK1351B002CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX); return; } // SQL文の組立て(項目取得用) (2) + (3) + (4) + (5) StringBuffer sql_Select = new StringBuffer(); sql_Select.append(sql_Buff2) .append(sql_Buff3); if ( "1".equals( inMsg.getObject(EKK1351B002CBSMsg.FUNC_CODE).toString() ) ) { sql_Select.append(sql_Buff4); } sql_Select.append(sql_Buff5); //prepareStatementにSQL文をセット pstmt_Select = con1.prepareStatement(sql_Select.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Select); // パラメータカウントの初期化 iPCnt = 0; // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 for ( int i = 0; i < arrayParam.size(); i++ ) { CAANJDBCUtil.setParam(pstmt_Select, ++iPCnt, arrayParam.get(i)); } // PreparedStatementの指定されたパラメータカラムに 指定された値を設定(WHERE部) if ( "1".equals( inMsg.getString(EKK1351B002CBSMsg.FUNC_CODE) ) ) { for ( int i = 0; i < arrayParamWhere.size(); i++ ) { CAANJDBCUtil.setParam(pstmt_Select, ++iPCnt, arrayParamWhere.get(i)); } } // ResultSetの取得 rsltQuery_Select = pstmt_Select.executeQuery(); // EKK1351B002CBSMsgの明細にセットする項目 String[] msgKeyList1 = { EKK1351B002CBSMsg1List.DCHSKM_CD , EKK1351B002CBSMsg1List.GENE_ADD_DTM , EKK1351B002CBSMsg1List.DCHS_TYPE_CD , EKK1351B002CBSMsg1List.DSP_DCHSKM_CD , EKK1351B002CBSMsg1List.DCHSKM_NM , EKK1351B002CBSMsg1List.SET_PSB_STA_YMDHM , EKK1351B002CBSMsg1List.SET_PSB_END_YMDHM , EKK1351B002CBSMsg1List.DCHS_APLY_OPTNTY_CD , EKK1351B002CBSMsg1List.DCHS_RLS_OPTNTY_CD , EKK1351B002CBSMsg1List.DCHS_SBT_CD , EKK1351B002CBSMsg1List.DCHSKM_STA_CD , EKK1351B002CBSMsg1List.STA_ADJ_CD , EKK1351B002CBSMsg1List.STA_ADJ_PRD , EKK1351B002CBSMsg1List.DCHSKM_END_CD , EKK1351B002CBSMsg1List.UPPL_APLY_CNT , EKK1351B002CBSMsg1List.DCHSKM_AGING_PRD , EKK1351B002CBSMsg1List.UPPL_KEI_CNT , EKK1351B002CBSMsg1List.DSP_JUN , EKK1351B002CBSMsg1List.JOKEN_TSTAYMD , EKK1351B002CBSMsg1List.JOKEN_TENDYMD , EKK1351B002CBSMsg1List.APLY_CNT_HAMBET_CD , EKK1351B002CBSMsg1List.APLY_CNT , EKK1351B002CBSMsg1List.APLY_JOKEN_CD , EKK1351B002CBSMsg1List.DCHS_ADD_JOKEN_CD , EKK1351B002CBSMsg1List.RSV_APLY_YMD , EKK1351B002CBSMsg1List.DCHSKM_TSTAYMD , EKK1351B002CBSMsg1List.DCHSKM_TENDYMD , EKK1351B002CBSMsg1List.UPD_DTM , EKK1351B002CBSMsg1List.DCHSKM_TG_SVC_CD , EKK1351B002CBSMsg1List.APLY_JOKEN_GRP , EKK1351B002CBSMsg1List.SVC_CD , EKK1351B002CBSMsg1List.PRC_GRP_CD , EKK1351B002CBSMsg1List.PCRS_CD , EKK1351B002CBSMsg1List.PPLAN_CD , EKK1351B002CBSMsg1List.OP_SVC_CD , EKK1351B002CBSMsg1List.SBOP_SVC_CD , EKK1351B002CBSMsg1List.KKTK_SVC_CD , EKK1351B002CBSMsg1List.KKTK_SBT_CD , EKK1351B002CBSMsg1List.SEIOPSVC_CD , EKK1351B002CBSMsg1List.CHGE_BF_SVC_CD , EKK1351B002CBSMsg1List.CHGE_BF_PRC_GRP_CD , EKK1351B002CBSMsg1List.CHGE_BF_PCRS_CD , EKK1351B002CBSMsg1List.CHGE_BF_PPLAN_CD , EKK1351B002CBSMsg1List.CHGE_BF_OP_SVC_CD , EKK1351B002CBSMsg1List.CHGE_BF_SBOP_SVC_CD , EKK1351B002CBSMsg1List.CHGE_BF_KKTK_SVC_CD , EKK1351B002CBSMsg1List.CHGE_BF_KKTK_SBT_CD , EKK1351B002CBSMsg1List.CHGE_BF_SEIOPSVC_CD , EKK1351B002CBSMsg1List.SVC_KEI_YEAR_CNT , EKK1351B002CBSMsg1List.TRGT_KEI_SVC_CNT , EKK1351B002CBSMsg1List.TRGT_KEI_SVC_UPPL , EKK1351B002CBSMsg1List.TRGT_SVC_HAMBET_CD , EKK1351B002CBSMsg1List.UPPL_AUTO_APLY_KH }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery_Select,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK1351B002CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("EKK1351B002CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(EKK1351B002CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // 資源の解放 try{ if(rsltQuery_Count != null){ rsltQuery_Count.close(); } if(pstmt_Count != null){ pstmt_Count.close(); } if(rsltQuery_Select != null){ rsltQuery_Select.close(); } if(pstmt_Select != null){ pstmt_Select.close(); } if(con1 != null){ closeConnection(con1); } }catch(SQLException e){ inMsg.set(EKK1351B002CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }