/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbEKK0511B002TPDA
* ソースファイル名：JSYejbEKK0511B002TPDA.java
* 作成者 ：EKek0072
* 日付 ：2011年08月09日
*＜機能概要＞
* 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.common.constant.JPCModelConstant;
import eo.ejb.cbs.cbsmsg.EKK0511B002CBSMsg;
import eo.ejb.cbs.cbsmsg.EKK0511B002CBSMsg1List;
import eo.ejb.cbm.entity.KK0511ETMsg;
import eo.ejb.common.JKKModelCommon;
import eo.ejb.common.JKKejbPagingUtil;
import eo.ejb.common.JZMModelCommon;
/**
*
* テンプレートDBアクセス部品 EKK0511B002_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/
public class JSYejbEKK0511B002TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
/**
* 部分一致検索用（%）
*/
private static final String BBN_ICCHI = "%";
/**
* コンストラクタ
*/
public JSYejbEKK0511B002TPDA() {
}
/**
* EKK0511B002_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void
*/
public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){
// コネクション
Connection con1 = null;
// プリペアステートメント
PreparedStatement pstmt_Count = null;
PreparedStatement pstmt_Page = null;
// リザルトセット
ResultSet rsltQuery_Count = null;
ResultSet rsltQuery_Page = null;
// パラメータのカウント
int iPCnt = 0;
/********************
* SQL文の作成
********************/
try{
//コネクション取得
con1 = JSYejbConnection.getConnection(KK0511ETMsg.getTableName());
// SQL文の作成(ページングヘッダ)
// (1)
StringBuffer sql_Buff1 = new StringBuffer();
sql_Buff1.append(" SELECT * ")
.append(" FROM ( ")
.append(" SELECT ALL_SELECT.*, ROWNUM AS LINE ")
.append(" FROM ( ");
// SQL文の作成(COUNT用)
// (2)
StringBuffer sql_Buff2 = new StringBuffer();
sql_Buff2.append(" SELECT ")
.append(" COUNT(*) AS CNT ");
// SQL文の作成(項目取得)
// (3)
StringBuffer sql_Buff3 = new StringBuffer();
sql_Buff3.append(" SELECT KK0511.BANK_CD ")
.append(" , KK0511.BANK_SHITEN_CD ")
.append(" , KK0511.BANK_NM ")
.append(" , KK0511.BANK_KANA ")
.append(" , KK0511.BANK_SHITEN_NM ")
.append(" , KK0511.BANK_SHITEN_KANA ");
// SQL文の作成(WHERE句)
// (4)
StringBuffer sql_Buff4 =new StringBuffer();
if ( "1".equals( inMsg.getObject(EKK0511B002CBSMsg.FUNC_CODE).toString() ) ) {
sql_Buff4.append(" FROM ")
.append(" KK_M_BANK KK0511 ")
.append(" WHERE ")
.append(" (KK0511.BANK_CD, KK0511.BANK_SHITEN_CD, KK0511.RSV_APLY_YMD || KK0511.GENE_ADD_DTM) = ")
.append(" ( SELECT KK0511_GENE.BANK_CD, KK0511_GENE.BANK_SHITEN_CD, MAX(KK0511_GENE.RSV_APLY_YMD || KK0511_GENE.GENE_ADD_DTM) AS KK0511_MAX ")
.append(" FROM KK_M_BANK KK0511_GENE ")
.append(" WHERE KK0511_GENE.BANK_CD = KK0511.BANK_CD ")
.append(" AND KK0511_GENE.BANK_SHITEN_CD = KK0511.BANK_SHITEN_CD ")
.append(" AND KK0511_GENE.RSV_APLY_YMD <= ? ")
.append(" AND KK0511_GENE.MK_FLG = '0' ")
.append(" GROUP BY KK0511_GENE.BANK_CD, KK0511_GENE.BANK_SHITEN_CD ) ")
.append(" AND KK0511.BANK_TSTAYMD <= ? ")
.append(" AND KK0511.BANK_TENDYMD >= ? ");
//入力値が設定されている場合のみ、検索条件を追加（KEY_BANK_CD）
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_CD))
{
sql_Buff4.append(" AND KK0511.BANK_CD = ? ");
}
//入力値が設定されている場合のみ、検索条件を追加（KEY_BANK_SHITEN_CD）
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_SHITEN_CD))
{
sql_Buff4.append(" AND KK0511.BANK_SHITEN_CD = ? ");
}
//入力値が設定されている場合のみ、検索条件を追加（KEY_BANK_NM）
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_NM))
{
sql_Buff4.append(" AND KK0511.BANK_NM LIKE ? ");
//エスケープ付与
sql_Buff4.append(JZMModelCommon.ESCAPE_SQL_STRING);
}
//入力値が設定されている場合のみ、検索条件を追加（KEY_BANK_KANA）
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_KANA))
{
sql_Buff4.append(" AND KK0511.BANK_KANA LIKE ? ");
//エスケープ付与
sql_Buff4.append(JZMModelCommon.ESCAPE_SQL_STRING);
}
//入力値が設定されている場合のみ、検索条件を追加（KEY_BANK_SHITEN_NM）
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_SHITEN_NM))
{
sql_Buff4.append(" AND KK0511.BANK_SHITEN_NM LIKE ? ");
//エスケープ付与
sql_Buff4.append(JZMModelCommon.ESCAPE_SQL_STRING);
}
//入力値が設定されている場合のみ、検索条件を追加（KEY_BANK_SHITEN_KANA）
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_SHITEN_KANA))
{
sql_Buff4.append(" AND KK0511.BANK_SHITEN_KANA LIKE ? ");
//エスケープ付与
sql_Buff4.append(JZMModelCommon.ESCAPE_SQL_STRING);
}
}
// SQL文の作成(ORDER BY句)
// (5)
StringBuffer sql_Buff5 = new StringBuffer();
sql_Buff5.append(" ORDER BY ")
.append(" KK0511.BANK_CD ASC ")
.append(", KK0511.BANK_SHITEN_CD ASC ");
// SQL文の作成(ページングフッタ)
// (6)
StringBuffer sql_Buff6 = new StringBuffer();
sql_Buff6.append(" ) ALL_SELECT ")
.append(" ) PAGE_SELECT ")
.append(" WHERE PAGE_SELECT.LINE BETWEEN ? AND ? ")
.append(" ORDER BY PAGE_SELECT.LINE ASC ");
// SQL文の組立て(件数取得用) (2) + (4)
StringBuffer sql_Count = new StringBuffer();
sql_Count.append(sql_Buff2)
.append(sql_Buff4);
//prepareStatementにSQL文をセット
pstmt_Count = con1.prepareStatement(sql_Count.toString());
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Count);
// パラメータのカウントの初期化
iPCnt = 0;
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ( "1".equals( inMsg.getString(EKK0511B002CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定
iPCnt = setPram(inMsg, pstmt_Count, iPCnt);
}
// ResultSetの取得
rsltQuery_Count = pstmt_Count.executeQuery();
// 総検索件数を取得する
Long IDataCnt = 0L;
if (rsltQuery_Count.next())
{
IDataCnt = rsltQuery_Count.getLong("CNT");
}
// 表示件数
Long IDispNum = inMsg.getStringAsLong(EKK0511B002CBSMsg.DISPLAY_NUM);
// 表示ページ数
Long IDispPage = inMsg.getStringAsLong(EKK0511B002CBSMsg.DISPLAY_PAGE_NUM);
// 最大取得件数
Long IMaxNum = inMsg.getStringAsLong(EKK0511B002CBSMsg.MAX_SEARCH_NUM);
// 総ページ数
String strMaxPage = JKKejbPagingUtil.calcTotalPage(IDataCnt, IDispNum);
// 共通部に値を設定する
// 総検索件数
inMsg.set(EKK0511B002CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(IDataCnt));
// 総ページ数
inMsg.set(EKK0511B002CBSMsg.TOTAL_PAGE_NUM, strMaxPage);
// データ取得件数が0件の場合エラー
if (0 == IDataCnt)
{
inMsg.set(EKK0511B002CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO);
return;
}
// 最大取得件数を超えた場合エラー
if (IDataCnt > IMaxNum)
{
inMsg.set(EKK0511B002CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX);
return;
}
// SQL文の組立て(項目取得・ページング用)(1) + (3) + (4) + (5) + (6)
StringBuffer sql_Page =new StringBuffer();
sql_Page.append(sql_Buff1)
.append(sql_Buff3)
.append(sql_Buff4)
.append(sql_Buff5)
.append(sql_Buff6);
// prepareStatementにSQL文をセット
pstmt_Page = con1.prepareStatement(sql_Page.toString());
// ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Page);
// 検索対象を算出する
long[] IPages = JKKejbPagingUtil.calcSearchRows(IDispPage, IDispNum);
long IRowSta = IPages[0];
long IRowEnd = IPages[1];
// パラメータのカウントの初期化
iPCnt = 0;
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ( "1".equals( inMsg.getString(EKK0511B002CBSMsg.FUNC_CODE) ) ) {
// パラメータの設定
iPCnt = setPram(inMsg, pstmt_Page, iPCnt);
// パラメータの設定(検索開始行を指定)
CAANJDBCUtil.setParam(pstmt_Page, ++iPCnt, IRowSta);
// パラメータの設定(検索終了行を指定)
CAANJDBCUtil.setParam(pstmt_Page, ++iPCnt, IRowEnd);
}
// ResultSetの取得
rsltQuery_Page = pstmt_Page.executeQuery();
// EKK0511B002CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
EKK0511B002CBSMsg1List.BANK_CD
, EKK0511B002CBSMsg1List.BANK_SHITEN_CD
, EKK0511B002CBSMsg1List.BANK_NM
, EKK0511B002CBSMsg1List.BANK_KANA
, EKK0511B002CBSMsg1List.BANK_SHITEN_NM
, EKK0511B002CBSMsg1List.BANK_SHITEN_KANA
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery_Page,msgKeyList1, "eo.ejb.cbs.cbsmsg.EKK0511B002CBSMsg1List", 0);
// 取得結果が0件の場合は表示ページ該当なしエラー
if (0 >= outMsg1.length)
{
inMsg.set(EKK0511B002CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA);
return;
}
// inMsg(CBSMsg)に明細をセット
inMsg.set("EKK0511B002CBSMsg1List", outMsg1);
} catch(SQLException e) {
inMsg.set(EKK0511B002CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
} finally {
// 資源の解放
try{
if(rsltQuery_Count != null){
rsltQuery_Count.close();
}
if(rsltQuery_Page != null){
rsltQuery_Page.close();
}
if(pstmt_Count != null){
pstmt_Count.close();
}
if(pstmt_Page != null){
pstmt_Page.close();
}
if(con1 != null){
closeConnection(con1);
}
}catch(SQLException e){
inMsg.set(EKK0511B002CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
}
/**
*
* パラメータの設定を行います。
*
* @param inMsg 入力値の格納されたCBSMsg
* @param pstmt プリペアステートメント
* @param iPCnt パラメータのカウント
* @return iPCnt パラメータのカウント
* @exception SQLException
*/
private int setPram(CAANMsg inMsg, PreparedStatement pstmt, int iPCnt) throws SQLException
{
// パラメータの設定(運用日付を設定)
CAANJDBCUtil.setParam(pstmt, ++iPCnt, JKKModelCommon.getOpeDate(inMsg));
// パラメータの設定(運用日付を設定)
CAANJDBCUtil.setParam(pstmt, ++iPCnt, JKKModelCommon.getOpeDate(inMsg));
// パラメータの設定(運用日付を設定)
CAANJDBCUtil.setParam(pstmt, ++iPCnt, JKKModelCommon.getOpeDate(inMsg));
// パラメータの設定(ＫＥＹ＿金融機関コードを指定)
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_CD))
{
CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0511B002CBSMsg.KEY_BANK_CD));
}
// パラメータの設定(ＫＥＹ＿金融機関支店コードを指定)
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_SHITEN_CD))
{
CAANJDBCUtil.setParam(pstmt, ++iPCnt, inMsg.getObject(EKK0511B002CBSMsg.KEY_BANK_SHITEN_CD));
}
// パラメータの設定(ＫＥＹ＿金融機関名を指定)
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_NM))
{
// LIKE検索文字列置き換え処理
String keybanknm = JZMModelCommon.replaceLikeValue(inMsg.getObject(EKK0511B002CBSMsg.KEY_BANK_NM));
keybanknm = BBN_ICCHI + keybanknm + BBN_ICCHI;
CAANJDBCUtil.setParam(pstmt, ++iPCnt, keybanknm);
}
// パラメータの設定(ＫＥＹ＿金融機関カナ名を指定)
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_KANA))
{
// LIKE検索文字列置き換え処理
String keybankkana = JZMModelCommon.replaceLikeValue(inMsg.getObject(EKK0511B002CBSMsg.KEY_BANK_KANA));
keybankkana = BBN_ICCHI + keybankkana + BBN_ICCHI;
CAANJDBCUtil.setParam(pstmt, ++iPCnt, keybankkana);
}
// パラメータの設定(ＫＥＹ＿金融機関支店名を指定)
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_SHITEN_NM))
{
// LIKE検索文字列置き換え処理
String keybankshitennm = JZMModelCommon.replaceLikeValue(inMsg.getObject(EKK0511B002CBSMsg.KEY_BANK_SHITEN_NM));
keybankshitennm = BBN_ICCHI + keybankshitennm + BBN_ICCHI;
CAANJDBCUtil.setParam(pstmt, ++iPCnt, keybankshitennm);
}
// パラメータの設定(ＫＥＹ＿金融機関支店カナ名を指定)
if (!inMsg.isNull(EKK0511B002CBSMsg.KEY_BANK_SHITEN_KANA))
{
// LIKE検索文字列置き換え処理
String keybankshitenkana = JZMModelCommon.replaceLikeValue(inMsg.getObject(EKK0511B002CBSMsg.KEY_BANK_SHITEN_KANA));
keybankshitenkana = BBN_ICCHI + keybankshitenkana + BBN_ICCHI;
CAANJDBCUtil.setParam(pstmt, ++iPCnt, keybankshitenkana);
}
return iPCnt;
}
}