/*******************************************************************************
*	 All Rights reserved,Copyright (c) K-Opticom 
********************************************************************************
*＜プログラム内容＞
*	システム名		：eo顧客基幹システム
*	モジュール名	：JSYejbEKK1121B001TPDA
*	ソースファイル名：JSYejbEKK1121B001TPDA.java
*	作成者			：EK909308
*	日付			：2011年10月24日
*＜機能概要＞
*	SQLFacility
*	テンプレートDBアクセス部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	ｖ1.00.00
*	v4.01.00    2013/07/11  FJ          【LT-2013-0000377】障害対応
*	v7.00.00    2014/04/04  FJ)澁谷     【TAI-2014-0000010】対応
*	v65.00.00   2023/02/07  FJ)吉田あ   【ANK-4346-00-00】【eo定期】CCMG再構築対応
*
********************************************************************************/

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.EKK1121B001CBSMsg;
import eo.ejb.cbs.cbsmsg.EKK1121B001CBSMsg1List;
import eo.ejb.cbm.entity.KK1121ETMsg;
import eo.ejb.common.JKKejbPagingUtil;

/**
*
*  テンプレートDBアクセス部品　EKK1121B001_SQLF<br>
*  入力された項目からSQL文を動的に組み立て、<br>
*  検索結果をCBSMsgにセットします。<br>
*/
public class JSYejbEKK1121B001TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
	

	/** 
	 * ソート項目用（メールＩＤ)
	 */
	private static final String SORT_MAILID = "1";

	/** 
	 * ソート項目用（ｅｏＩＤ)
	 */
	private static final String SORT_EOID = "2";

	/** 
	 * ソート項目用（メール送信年月日時分秒)
	 */
	private static final String SORT_MAIL_SEND_DTM = "3";

	/** 
	 * ソート区分用（昇順)
	 */
	private static final String SORT_ASC = "1";

	/** 
	 * ソート区分用（降順)
	 */
	private static final String SORT_DESC = "2";

	/**
	 * コンストラクタ
	 */
	public JSYejbEKK1121B001TPDA()	{
	}
	
	/**
	*   EKK1121B001_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;
		
		/******************** 
		 * SQL文の作成
		 ********************/

		try{
			
			//コネクション取得
			con1 = JSYejbConnection.getConnection(KK1121ETMsg.getTableName());
			
			// バインド変数設定値保持用領域
			ArrayList<Object> arrayParam = new ArrayList<Object>();
			
			// SQL文の作成(件数取得用)
			// (1)
			StringBuffer sql_BuffCount = new StringBuffer();
			sql_BuffCount.append(" SELECT  ")
						.append("     COUNT(*) AS CNT  ")
						.append("     FROM ");
			
			// 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("   KK1121.MAIL_ID ")
						.append("  ,KK1121.EOID ")
						.append("  ,KK1121.SENDS_KSH_KANA ")
						.append("  ,KK1121.SENDS_MLAD ")
						.append("  ,KK1121.MAIL_SEND_DTM ")
						.append("  ,KK1121.MAIL_CD ")
						.append("  ,KK1121.SEND_CNT ")
						.append("  ,KK1121.MAIL_TITLE ")
						.append("  ,KK1121.MAIL_SEND_STAT_CD ")
						.append("  ,KK1121.CONT_SVC_CD ")
	/* ++++++++++ v4.01.00 追加開始 ++++++++++ */
						.append("  ,CC0021.MAIL_SEND_STAT ")
	/* ++++++++++ v4.01.00 追加完了 ++++++++++ */
						.append(" FROM ")
			/* ++++++++++ v4.01.00 修正開始 ++++++++++ */
//						.append("   KK_T_MAIL_INFO KK1121 ");
						.append("   KK_T_MAIL_INFO KK1121 ")
						.append(" LEFT OUTER JOIN (  ")
						.append("     SELECT CC0021_TMP.MAIL_SEND_STAT ")
						.append("           ,CC0021_TMP.MAIL_SEND_NO ")
						.append("     FROM   CC_T_MAIL_SEND CC0021_TMP ")			
						.append("     WHERE  CC0021_TMP.MK_FLG='0' ")
						.append(" ) CC0021  ")
						.append(" ON     CC0021.MAIL_SEND_NO = KK1121.MAIL_SEND_NO  ");
			/* ++++++++++ v4.01.00 修正完了 ++++++++++ */
			// SQL文_個別部1
			// (4)
			StringBuffer sql_BuffUni1 = new StringBuffer();
			if ( "1".equals( inMsg.getObject(EKK1121B001CBSMsg.FUNC_CODE).toString() ) ) {
				sql_BuffUni1.append(" WHERE ")
							.append("   KK1121.SYSID = ? ");
				// バインド変数リストの更新(SYSID)
				arrayParam.add(inMsg.getObject(EKK1121B001CBSMsg.KEY_SYSID));
				
				// サービスIF入力値：コンテンツサービスコードが入力された場合
				if(!inMsg.isNull(EKK1121B001CBSMsg.KEY_CONT_SVC_CD))
				{
					// SQL文の連結
					sql_BuffUni1.append(" AND KK1121.CONT_SVC_CD = ? ");
					// バインド変数リストの更新
					arrayParam.add(inMsg.getObject(EKK1121B001CBSMsg.KEY_CONT_SVC_CD));
					
				}
				// サービスIF入力値：コンテンツサービスコードが入力された場合
				if(!inMsg.isNull(EKK1121B001CBSMsg.KEY_EOID))
				{
					// SQL文の連結
					sql_BuffUni1.append(" AND KK1121.EOID = ? ");
					// バインド変数リストの更新
					arrayParam.add(inMsg.getObject(EKK1121B001CBSMsg.KEY_EOID));
					
				}
				// サービスIF入力値：コンテンツサービスコードが入力された場合
				if(!inMsg.isNull(EKK1121B001CBSMsg.KEY_SENDS_MLAD))
				{
					// SQL文の連結
					sql_BuffUni1.append(" AND KK1121.SENDS_MLAD = ? ");
					// バインド変数リストの更新
					arrayParam.add(inMsg.getObject(EKK1121B001CBSMsg.KEY_SENDS_MLAD));
					
				}
				// サービスIF入力値：コンテンツサービスコードが入力された場合
				if(!inMsg.isNull(EKK1121B001CBSMsg.KEY_MAIL_CD))
				{
					// SQL文の連結
					sql_BuffUni1.append(" AND KK1121.MAIL_CD = ? ");
					// バインド変数リストの更新
					arrayParam.add(inMsg.getObject(EKK1121B001CBSMsg.KEY_MAIL_CD));
					
				}
				// サービスIF入力値：コンテンツサービスコードが入力された場合
				if(!inMsg.isNull(EKK1121B001CBSMsg.KEY_MAIL_SEND_DTM_FROM))
				{
					// SQL文の連結
					sql_BuffUni1.append(" AND KK1121.MAIL_SEND_DTM >= ? ");
					// バインド変数リストの更新
					arrayParam.add(inMsg.getObject(EKK1121B001CBSMsg.KEY_MAIL_SEND_DTM_FROM));
					
				}
				// サービスIF入力値：コンテンツサービスコードが入力された場合
				if(!inMsg.isNull(EKK1121B001CBSMsg.KEY_MAIL_SEND_DTM_TO))
				{
					// SQL文の連結
					sql_BuffUni1.append(" AND KK1121.MAIL_SEND_DTM <= ? ");
					// バインド変数リストの更新
					arrayParam.add(inMsg.getObject(EKK1121B001CBSMsg.KEY_MAIL_SEND_DTM_TO));
					
				}
				// ANK-4346-00-00 ADD START
				sql_BuffUni1.append(" AND KK1121.MAIL_ID NOT LIKE '3%' ");
				// ANK-4346-00-00 ADD END
				sql_BuffUni1.append(" AND KK1121.MK_FLG = '0' ");
			}
			// SQL文_ORDER BY部
			// (5)
			StringBuffer sql_BuffOrder = new StringBuffer();

			// ソート区分判定
			String strSortKbn = null;
			if(SORT_ASC.equals(inMsg.getObject(EKK1121B001CBSMsg.KEY_SORT_KBN)))
			{
				strSortKbn = " ASC";
			}
			else if(SORT_DESC.equals(inMsg.getObject(EKK1121B001CBSMsg.KEY_SORT_KBN)))
			{
				strSortKbn = " DESC";
			}
			else
			{
				strSortKbn = "";
			}

			// ソート項目判定
			if(SORT_MAILID.equals(inMsg.getObject(EKK1121B001CBSMsg.KEY_SORT_ITEM_NO)))
			{
				sql_BuffOrder.append(" ORDER BY KK1121.MAIL_ID")
				.append(strSortKbn);
			}
			else if(SORT_EOID.equals(inMsg.getObject(EKK1121B001CBSMsg.KEY_SORT_ITEM_NO)))
			{
				sql_BuffOrder.append(" ORDER BY KK1121.EOID")
				.append(strSortKbn);
			}
			else if(SORT_MAIL_SEND_DTM.equals(inMsg.getObject(EKK1121B001CBSMsg.KEY_SORT_ITEM_NO)))
			{
				sql_BuffOrder.append(" ORDER BY KK1121.MAIL_SEND_DTM")
				.append(strSortKbn);
			}
			else if(inMsg.isNull(EKK1121B001CBSMsg.KEY_SORT_ITEM_NO))
			{
				sql_BuffOrder.append(" ORDER BY KK1121.MAIL_SEND_DTM DESC ");
			}
			
			// SQL文の作成(ページングフッタ)
			// (6)	
			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) + ( (3) + (4) )
			StringBuffer sql_getCount = new StringBuffer();
				sql_getCount.append(sql_BuffCount)
							.append(" ( ")
							.append(sql_BuffBase1)
							.append(sql_BuffUni1)
							.append(" ) ");
			
			// prepareStatementにSQL文をセット
				pstmt_Count = con1.prepareStatement(sql_getCount.toString());
			
			//ログ出力(SQL文の出力)
			JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_getCount);
			
			// バインド変数設定順制御用変数
			int iParamCntr = 0;
			
			// PreparedStatementの指定されたパラメータカラムにバインド変数リストから取得して設定
			if ( "1".equals( inMsg.getString(EKK1121B001CBSMsg.FUNC_CODE) ) ) {
				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(EKK1121B001CBSMsg.DISPLAY_NUM);
			
			// 表示ページ数
			Long iDispPage = inMsg.getStringAsLong(EKK1121B001CBSMsg.DISPLAY_PAGE_NUM);
			
			// 総ページ数
			String strMaxPage = JKKejbPagingUtil.calcTotalPage(iDataCnt, iDispNum);
			
			// 最大取得件数
			long lMaxNum = inMsg.getStringAsLong(EKK1121B001CBSMsg.MAX_SEARCH_NUM);
			
			// 共通部に値を設定する
			// 総検索件数
			inMsg.set(EKK1121B001CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(iDataCnt));
			
			// 総ページ数
			inMsg.set(EKK1121B001CBSMsg.TOTAL_PAGE_NUM, strMaxPage);
			
			// SQL文の組立て(項目取得・ページング用)(2) + (3) + (4) + (5) + (6)
			StringBuffer sql_getPage = new StringBuffer();
				sql_getPage.append(sql_BuffPageHeader)
						.append(sql_BuffBase1)
						.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の指定されたパラメータカラムに 指定された値を設定
			if ( "1".equals( inMsg.getString(EKK1121B001CBSMsg.FUNC_CODE))) {
				// パラメータの設定
				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();
		
			// EKK1121B001CBSMsgの明細にセットする項目
			String[] msgKeyList1 = {
					  EKK1121B001CBSMsg1List.MAIL_ID
					, EKK1121B001CBSMsg1List.EOID
					, EKK1121B001CBSMsg1List.SENDS_KSH_KANA
					, EKK1121B001CBSMsg1List.SENDS_MLAD
					, EKK1121B001CBSMsg1List.MAIL_SEND_DTM
					, EKK1121B001CBSMsg1List.MAIL_CD
					, EKK1121B001CBSMsg1List.SEND_CNT
					, EKK1121B001CBSMsg1List.MAIL_TITLE
					, EKK1121B001CBSMsg1List.MAIL_SEND_STAT_CD
					, EKK1121B001CBSMsg1List.CONT_SVC_CD
					, EKK1121B001CBSMsg1List.MAIL_SEND_STAT
			};
			
			// 明細に処理結果(ResultSet)をマッピング
			CAANMsg[] outMsg1 = mapMessageList(rsltQuery_Page,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK1121B001CBSMsg1List",0);
			
			// 取得結果が0件の場合は表示ページ該当なしエラー
			if (0L == outMsg1.length)
			{
				inMsg.set(EKK1121B001CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA);
				return;
			}
			// 最大取得件数を超えた場合エラー
			if (iDataCnt > lMaxNum)
			{
				inMsg.set(EKK1121B001CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX);
			}
			
			// inMsg(CBSMsg)に明細をセット
			inMsg.set("EKK1121B001CBSMsg1List", outMsg1);
			

		} catch(SQLException e) {
			inMsg.set(EKK1121B001CBSMsg.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(EKK1121B001CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
				throw new CAANRuntimeException(e);
			}
		}
	}
}