/*******************************************************************************
*	 All Rights reserved,Copyright (c) K-Opticom 
********************************************************************************
*＜プログラム内容＞
*	システム名		：eo顧客基幹システム
*	モジュール名	：JSYejbEKK0531B001TPDA
*	ソースファイル名：JSYejbEKK0531B001TPDA.java
*	作成者			：EK907441
*	日付			：2011年10月19日
*＜機能概要＞
*	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 java.util.ArrayList;

import eo.common.constant.JPCModelConstant;
import eo.ejb.cbs.cbsmsg.EKK0531B001CBSMsg;
import eo.ejb.cbs.cbsmsg.EKK0531B001CBSMsg1List;
import eo.ejb.cbm.entity.KK0531ETMsg;
import eo.ejb.common.JKKejbPagingUtil;
import eo.ejb.common.JZMModelCommon;

/**
*
*  テンプレートDBアクセス部品　EKK0531B001_SQLF<br>
*  入力された項目からSQL文を動的に組み立て、<br>
*  検索結果をCBSMsgにセットします。<br>
*/
public class JSYejbEKK0531B001TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
	
	/**
	 * コンストラクタ
	 */
	public JSYejbEKK0531B001TPDA()	{
	}
	
	/**
	*   EKK0531B001_SQLF<br>
	*   @param inMsg    入力値の格納されたCBSMsg <br>
	*   @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;
		
		// バインド変数設定値保持用領域
		ArrayList<Object> arrayParam = new ArrayList<Object>();
		
		/******************** 
		 * SQL文の作成
		 ********************/

		try{
			
			//コネクション取得
			con1 = JSYejbConnection.getConnection(KK0531ETMsg.getTableName());
			
			// SQL文の作成(件数取得用)
			// (1)
			StringBuffer sql_BuffCount = new StringBuffer();
			sql_BuffCount.append(" SELECT  ")
			.append("     COUNT(*) AS CNT  ");
			
			// SQL文の作成(ページングヘッダ)
			// (2)
			StringBuffer sql_BuffPageHeader = new StringBuffer();
			sql_BuffPageHeader.append("SELECT *  ")
			.append("FROM (  ")
			.append("    SELECT ALL_SELECT.*, ROWNUM AS LINE  ")
			.append("    FROM (  ");
			
			// SQL文_基本部1
			// (3)
			StringBuffer sql_BuffBase1 = new StringBuffer();
			sql_BuffBase1.append(" SELECT ")
					.append("   KK0531.CRECARD_COMP_CD ")
					.append("  ,KK0531.CRECARD_JIGYO_CD ")
					.append("  ,(SELECT ")
					.append("      ZM0171_A.CD_DIV_NM ")
					.append("    FROM ")
					.append("      ZM_M_CD_NM_KANRI ZM0171_A ")
					.append("    WHERE ")
					.append("      ZM0171_A.CD_SBT_CD = 'CD00420' ")
					.append("    AND ZM0171_A.CD_DIV = KK0531.CRECARD_JIGYO_CD ")
					.append("    AND ZM0171_A.MK_FLG = '0' ")
					.append("   ) AS CRECARD_JIGYO_CD_NM ")
					.append("  ,KK0531.CREDIT_KOKAN_CD ")
					.append("  ,KK0531.CRECARD_COMP_NM ")
					.append("  ,KK0531.CRECARD_COMP_ALI ")
					.append("  ,KK0531.MEMBSTR_NO_15 ")
					.append("  ,KK0531.MEMBSTR_NO_12 ")
					.append("  ,KK0531.MEMBSTR_NM ")
					.append("  ,KK0531.MEMBSTR_ALI ")
					.append("  ,KK0531.MEMBSTR_ALI_15_MOJI ")
					.append("  ,KK0531.YK_REQ_DIV ")
					.append("  ,KK0531.YK_REQ_STA_YM ")
					.append("  ,KK0531.SEIKYUS_HASSO_RSV_DIV ")
					.append("  ,KK0531.CRECARD_USER_ID ")
					.append("  ,KK0531.SHUK_LV_CD ")
					.append("  ,(SELECT ")
					.append("      ZM0171_B.CD_DIV_NM ")
					.append("    FROM ")
					.append("      ZM_M_CD_NM_KANRI ZM0171_B ")
					.append("    WHERE ")
					.append("      ZM0171_B.CD_SBT_CD = 'CD00388' ")
					.append("    AND ZM0171_B.CD_DIV = KK0531.SHUK_LV_CD ")
					.append("    AND ZM0171_B.MK_FLG = '0' ")
					.append("   ) AS SHUK_LV_CD_NM ")
					.append("  ,KK0531.DEAL_CD_HEADER ")
					.append("  ,KK0531.DEAL_CD_DATA ")
					.append("  ,KK0531.DEAL_CD_TRAILER ")
					.append("  ,KK0531.FLRLMT_FIRST ")
					.append("  ,KK0531.FLRLMT_ZOUBUN ")
					.append("  ,KK0531.FLRLMT_UPPL ")
					.append("  ,KK0531.FIRST_SEIKY_YM ")
					.append("  ,KK0531.BUNKATSU_CNT_CD ")
					.append("  ,(SELECT ")
					.append("      ZM0171_C.CD_DIV_NM ")
					.append("    FROM ")
					.append("      ZM_M_CD_NM_KANRI ZM0171_C ")
					.append("    WHERE ")
					.append("      ZM0171_C.CD_SBT_CD = 'CD00390' ")
					.append("    AND ZM0171_C.CD_DIV = KK0531.BUNKATSU_CNT_CD ")
					.append("    AND ZM0171_C.MK_FLG = '0' ")
					.append("   ) AS BUNKATSU_CNT_CD_NM ")
					.append("  ,KK0531.BNS_DSP ")
					.append("  ,KK0531.SHONIN_NO_FUYO_YH ")
					.append("  ,KK0531.SHONIN_NO_FUYO_AMNT ")
					.append("  ,KK0531.FILE_DIV_HEADER ")
					.append("  ,KK0531.FILE_DIV_DATA ")
					.append("  ,KK0531.FILE_DIV_TRAILER ")
					.append("  ,KK0531.FILE_DIV_END ")
					.append("  ,KK0531.COMMISION_SNST_WAY_CD ")
					.append("  ,KK0531.COMMISION_RT ")
					.append("  ,KK0531.CUST_NO_FUYO_YH ")
					.append("  ,KK0531.SEIKY_YM_FUYO_YH ")
					.append("  ,KK0531.DSP_JUN ")
					.append("  ,KK0531.CRECARD_COMP_TSTAYMD ")
					.append("  ,KK0531.CRECARD_COMP_TENDYMD ");
			
			// SQL文_基本部2
			// (4)
			StringBuffer sql_BuffBase2 = new StringBuffer();
			sql_BuffBase2.append(" FROM  ")
					.append("   KK_M_CRECARD_COMP KK0531 ");

			// SQL文_個別部1
			// (5)
			StringBuffer sql_BuffUni1 = new StringBuffer();
			// SQL文_個別部1
			sql_BuffUni1.append(" WHERE ")
					.append("   KK0531.MK_FLG = '0' ");
 			
 			// サービスIF入力値：ＫＥＹ＿クレジットカード会社名
 			createLikeSentence(inMsg, EKK0531B001CBSMsg.KEY_CRECARD_COMP_NM, sql_BuffUni1, "KK0531.CRECARD_COMP_NM", arrayParam);
 			// ＫＥＹ＿クレジットカード会社適用開始年月日
			if(!inMsg.isNull(EKK0531B001CBSMsg.KEY_CRECARD_COMP_TSTAYMD))
 			{
 				// SQL文の結合
				sql_BuffUni1.append(" AND KK0531.CRECARD_COMP_TSTAYMD >= ? ");
 				// バインド変数設定リストの更新
 				arrayParam.add(inMsg.getObject(EKK0531B001CBSMsg.KEY_CRECARD_COMP_TSTAYMD));
 			}
			// ＫＥＹ＿クレジットカード会社適用終了年月日
			if(!inMsg.isNull(EKK0531B001CBSMsg.KEY_CRECARD_COMP_TENDYMD))
 			{
 				// SQL文の結合
				sql_BuffUni1.append(" AND KK0531.CRECARD_COMP_TENDYMD <= ? ");
 				// バインド変数設定リストの更新
 				arrayParam.add(inMsg.getObject(EKK0531B001CBSMsg.KEY_CRECARD_COMP_TENDYMD));
 			}

			// SQL文_ORDER BY部
			// (6)
			StringBuffer sql_BuffOrder = new StringBuffer();
			sql_BuffOrder.append(" ORDER BY ")
					.append("   KK0531.CRECARD_COMP_CD ASC ")
					.append("  ,KK0531.CRECARD_COMP_TSTAYMD ASC ")
					.append("  ,KK0531.CRECARD_COMP_TENDYMD ASC ");
			
			// SQL文の作成(ページングフッタ)
			// (7)	
			StringBuffer sql_BuffPageFooter = new StringBuffer();
				sql_BuffPageFooter.append(" ) ALL_SELECT ")
								.append(" ) PAGE_SELECT ")
								.append(" WHERE PAGE_SELECT.LINE BETWEEN ? AND ? ")
								.append(" ORDER BY PAGE_SELECT.LINE ASC ");

			// SQL文の組立て(件数取得用) (1) + (4) + (5)
			StringBuffer sql_getCount = new StringBuffer();
				sql_getCount.append(sql_BuffCount)
							.append(sql_BuffBase2)
							.append(sql_BuffUni1);	
			
			// prepareStatementにSQL文をセット
			pstmt_Count = con1.prepareStatement(sql_getCount.toString());
			
			//ログ出力(SQL文の出力)
			JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_getCount);
			
			// バインド変数設定順制御用変数
			int iParamCntr = 0;
			
			// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
			for(iParamCntr = 0; iParamCntr < arrayParam.size(); iParamCntr++)
			{
				// バインド変数に設定
				CAANJDBCUtil.setParam(pstmt_Count, (iParamCntr + 1), arrayParam.get(iParamCntr));
			}
			
			// ResultSetの取得
			rsltQuery_Count = pstmt_Count.executeQuery();
			
			// 総検索件数を取得する
			Long iDataCnt = 0L;
			if (rsltQuery_Count.next())
			{
				iDataCnt = rsltQuery_Count.getLong("CNT");
			}
			
			// 表示件数
			Long iDispNum = inMsg.getStringAsLong(EKK0531B001CBSMsg.DISPLAY_NUM);
			
			// 表示ページ数
			Long iDispPage = inMsg.getStringAsLong(EKK0531B001CBSMsg.DISPLAY_PAGE_NUM);
			
			// 総ページ数
			String strMaxPage = JKKejbPagingUtil.calcTotalPage(iDataCnt, iDispNum);
			
			// 共通部に値を設定する
			// 総検索件数
			inMsg.set(EKK0531B001CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(iDataCnt));
			
			// 総ページ数
			inMsg.set(EKK0531B001CBSMsg.TOTAL_PAGE_NUM, strMaxPage);
			
			// SQL文の組立て(項目取得・ページング用)(2) + (3) + (4) + (5) + (6) + (7)
			StringBuffer sql_getPage = new StringBuffer();
				sql_getPage.append(sql_BuffPageHeader)
						.append(sql_BuffBase1)
						.append(sql_BuffBase2)
						.append(sql_BuffUni1)
						.append(sql_BuffOrder)
						.append(sql_BuffPageFooter);

			// prepareStatementにSQL文をセット
			pstmt_Page = con1.prepareStatement(sql_getPage.toString());

			// ログ出力(SQL文の出力)
			JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_getPage);

			// 検索対象を算出する
			long[] iPages = JKKejbPagingUtil.calcSearchRows(iDispPage, iDispNum);
			long iRowSta = iPages[0];
			long iRowEnd = iPages[1];

			// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
			// パラメータの設定
			for(iParamCntr = 0; iParamCntr < arrayParam.size(); iParamCntr++)
			{
				// バインド変数に設定
				CAANJDBCUtil.setParam(pstmt_Page, (iParamCntr + 1), arrayParam.get(iParamCntr));
			}
			// パラメータの設定(検索開始行を指定)
			CAANJDBCUtil.setParam(pstmt_Page, ++iParamCntr, iRowSta);
			// パラメータの設定(検索終了行を指定)
			CAANJDBCUtil.setParam(pstmt_Page, ++iParamCntr, iRowEnd);

			// ResultSetの取得
			rsltQuery_Page = pstmt_Page.executeQuery();	
			
			// EKK0531B001CBSMsgの明細にセットする項目
			String[] msgKeyList1 = {
					  EKK0531B001CBSMsg1List.CRECARD_COMP_CD
					, EKK0531B001CBSMsg1List.CRECARD_JIGYO_CD
					, EKK0531B001CBSMsg1List.CRECARD_JIGYO_CD_NM
					, EKK0531B001CBSMsg1List.CREDIT_KOKAN_CD
					, EKK0531B001CBSMsg1List.CRECARD_COMP_NM
					, EKK0531B001CBSMsg1List.CRECARD_COMP_ALI
					, EKK0531B001CBSMsg1List.MEMBSTR_NO_15
					, EKK0531B001CBSMsg1List.MEMBSTR_NO_12
					, EKK0531B001CBSMsg1List.MEMBSTR_NM
					, EKK0531B001CBSMsg1List.MEMBSTR_ALI
					, EKK0531B001CBSMsg1List.MEMBSTR_ALI_15_MOJI
					, EKK0531B001CBSMsg1List.YK_REQ_DIV
					, EKK0531B001CBSMsg1List.YK_REQ_STA_YM
					, EKK0531B001CBSMsg1List.SEIKYUS_HASSO_RSV_DIV
					, EKK0531B001CBSMsg1List.CRECARD_USER_ID
					, EKK0531B001CBSMsg1List.SHUK_LV_CD
					, EKK0531B001CBSMsg1List.SHUK_LV_CD_NM
					, EKK0531B001CBSMsg1List.DEAL_CD_HEADER
					, EKK0531B001CBSMsg1List.DEAL_CD_DATA
					, EKK0531B001CBSMsg1List.DEAL_CD_TRAILER
					, EKK0531B001CBSMsg1List.FLRLMT_FIRST
					, EKK0531B001CBSMsg1List.FLRLMT_ZOUBUN
					, EKK0531B001CBSMsg1List.FLRLMT_UPPL
					, EKK0531B001CBSMsg1List.FIRST_SEIKY_YM
					, EKK0531B001CBSMsg1List.BUNKATSU_CNT_CD
					, EKK0531B001CBSMsg1List.BUNKATSU_CNT_CD_NM
					, EKK0531B001CBSMsg1List.BNS_DSP
					, EKK0531B001CBSMsg1List.SHONIN_NO_FUYO_YH
					, EKK0531B001CBSMsg1List.SHONIN_NO_FUYO_AMNT
					, EKK0531B001CBSMsg1List.FILE_DIV_HEADER
					, EKK0531B001CBSMsg1List.FILE_DIV_DATA
					, EKK0531B001CBSMsg1List.FILE_DIV_TRAILER
					, EKK0531B001CBSMsg1List.FILE_DIV_END
					, EKK0531B001CBSMsg1List.COMMISION_SNST_WAY_CD
					, EKK0531B001CBSMsg1List.COMMISION_RT
					, EKK0531B001CBSMsg1List.CUST_NO_FUYO_YH
					, EKK0531B001CBSMsg1List.SEIKY_YM_FUYO_YH
					, EKK0531B001CBSMsg1List.DSP_JUN
					, EKK0531B001CBSMsg1List.CRECARD_COMP_TSTAYMD
					, EKK0531B001CBSMsg1List.CRECARD_COMP_TENDYMD
			};
			
			// 明細に処理結果(ResultSet)をマッピング
			CAANMsg[] outMsg1 = mapMessageList(rsltQuery_Page,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK0531B001CBSMsg1List",0);
			
			// 取得結果が0件の場合は表示ページ該当なしエラー
			if (0L == outMsg1.length)
			{
				inMsg.set(EKK0531B001CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA);
				return;
			}
			
			// inMsg(CBSMsg)に明細をセット
			inMsg.set("EKK0531B001CBSMsg1List", outMsg1);
			

		} catch(SQLException e) {
			inMsg.set(EKK0531B001CBSMsg.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(EKK0531B001CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
				throw new CAANRuntimeException(e);
			}
		}
	}
	
	/**
	 * <p>
	 * LIKE検索のSQL文を連結し、バインド変数リストの設定を行います
	 * </p>
	 * @param inMsg 入力値の格納されたCBSMsg
	 * @param strKey 項目を取得するためのキー
	 * @param sqlBuf SQL文
	 * @param sqlUni SQL文の固有部分
	 * @param arrayParam バインド変数のリスト
	 */
	private void createLikeSentence(CAANMsg inMsg, String strKey, StringBuffer sqlBuf, String sqlUni, ArrayList<Object> arrayParam)
	{
		// 該当キーに紐づくサービスIF入力値が設定された場合
		if(!inMsg.isNull(strKey))
		{
			// SQL文の結合
			sqlBuf.append(" AND " + sqlUni + " LIKE ? "); 
			// エスケープ付与
			sqlBuf.append(JZMModelCommon.ESCAPE_SQL_STRING);
			// LIKE検索文字列置き換え処理後、バインド変数設定リストの更新
			arrayParam.add(JZMModelCommon.replaceLikeValue(inMsg.getObject(strKey)) + "%");
		}
	}
}