/*********************************************************************
*	All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名		：eo顧客基幹システム
*	モジュール名	：JEKK1401D010TPMA
*	ソースファイル名：JEKK1401D010TPMA.java
*	作成者			：富士通
*	日付			：2012年07月25日
*＜機能概要＞
*	データ抽出項目設定対象契約登録の独自処理を行う部品
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2012/07/25	富士通		新規作成
*
**********************************************************************/

package eo.ejb.cbs.mainproc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import com.fujitsu.futurity.common.JCMConstants;
import com.fujitsu.futurity.model.base.CAANConnectionMgr;
import com.fujitsu.futurity.model.base.CAANJDBCUtil;
import com.fujitsu.futurity.model.base.CAANMsg;
import com.fujitsu.futurity.model.base.CAANRuntimeException;
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.AgentDispatchContext;
import com.fujitsu.futurity.model.ejb.common.fw.TemplateMainHandler;

import eo.ejb.cbm.entity.KK1401ETMsg;
import eo.ejb.cbs.cbsmsg.EKK1401D010CBSMsg;

/**
 * <p>
 * データ抽出項目設定対象契約登録の顧客独自処理部品クラスです。
 * </p>
 * @author 富士通
 */
public class JEKK1401D010TPMA implements TemplateMainHandler
{

	/** 親契約識別コード（サービス契約） */
	private static final String OYA_KEI_CD_SVC = "01";

	/** 親契約識別コード（サービス契約内訳） */
	private static final String OYA_KEI_CD_UCWK = "03";

	/** 親契約識別コード（オプションサービス契約） */
	private static final String OYA_KEI_CD_OP = "04";

	/** 親契約識別コード（サブオプションサービス契約） */
	private static final String OYA_KEI_CD_SBOP = "05";

	/** 親契約識別コード（機器提供サービス契約） */
	private static final String OYA_KEI_CD_KKTK = "06";

	/**
	 * <p>
	 * データ抽出項目設定対象契約登録の顧客独自処理（関連制約）
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	*/
	public void execKRCK(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		// データ抽出項目設定未存在チェック処理
		if (!isDchskmstTgKeiNoExist(inCBSMsg, inContext))
		{
			return;
		}
	}

	/**
	 * <p>
	 * データ抽出項目設定未存在チェックを行う。
	 * </p>
	 * @param inMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	 * @return 対象の契約番号に紐付く、指定データ抽出項目設定対象契約が存在する場合false。それ以外の場合true。
	 */
	private boolean isDchskmstTgKeiNoExist(CAANMsg inMsg, AgentDispatchContext inContext)
	{
		// 対象契約識別コードを取得
		String tgKeiSkbtCd = inMsg.getString(EKK1401D010CBSMsg.TG_KEI_SKBT_CD);

		// チェック条件の判定
		if (!isCheck(inMsg, tgKeiSkbtCd))
		{
			return true;
		}

		// チェック詳細
		Long lDataCnt = getCountKK1401ByTgKeiNo(inMsg, inContext, tgKeiSkbtCd);

		// 該当データが存在した場合、チェックエラーとする
		if (lDataCnt > 0)
		{
			setErrInfo(inMsg, tgKeiSkbtCd);
			return false;
		}

		return true;
		
	}

	/**
	 * <p>
	 * データ抽出項目設定未存在チェックを実施するかの判定を行う。
	 * </p>
	 * @param inMsg 処理対象のメッセージキャリア
	 * @param tgKeiSkbtCd 対象契約識別コード
	 * @return 設定された対象契約識別コードに該当する契約番号が設定されている場合true。それ以外の場合false。
	 */
	private boolean isCheck(CAANMsg inMsg, String tgKeiSkbtCd)
	{
		if (OYA_KEI_CD_SVC.equals(tgKeiSkbtCd))
		{
			// 親契約識別コードが"01"（サービス契約）の場合、サービス契約番号が設定されていたらtrueを返却
			if (!inMsg.isNull(EKK1401D010CBSMsg.SVC_KEI_NO))
			{
				return true;
			}
		}
		if (OYA_KEI_CD_UCWK.equals(tgKeiSkbtCd))
		{
			// 親契約識別コードが"03"（サービス契約内訳）の場合、サービス契約内訳番号が設定されていたらtrueを返却
			if (!inMsg.isNull(EKK1401D010CBSMsg.SVC_KEI_UCWK_NO))
			{
				return true;
			}
		}
		if (OYA_KEI_CD_OP.equals(tgKeiSkbtCd))
		{
			// 親契約識別コードが"04"（オプションサービス契約）の場合、オプションサービス契約番号が設定されていたらtrueを返却
			if (!inMsg.isNull(EKK1401D010CBSMsg.OP_SVC_KEI_NO))
			{
				return true;
			}
		}
		if (OYA_KEI_CD_SBOP.equals(tgKeiSkbtCd))
		{
			// 親契約識別コードが"05"（サブオプションサービス契約）の場合、
			// オプションサービス契約番号、サブオプションサービス契約番号が設定されていたらtrueを返却
			if (!inMsg.isNull(EKK1401D010CBSMsg.OP_SVC_KEI_NO)
					&& !inMsg.isNull(EKK1401D010CBSMsg.SBOP_SVC_KEI_NO))
			{
				return true;
			}
		}
		if (OYA_KEI_CD_KKTK.equals(tgKeiSkbtCd))
		{
			// 親契約識別コードが"06"（機器提供サービス契約）の場合、機器提供サービス契約番号が設定されていたらtrueを返却
			if (!inMsg.isNull(EKK1401D010CBSMsg.KKTK_SVC_KEI_NO))
			{
				return true;
			}
		}

		// 上記条件に該当しない場合はfalseを返却
		return false;
		
	}

	/**
	 * <p>
	 * 対象契約識別コードに対応する契約番号に紐付く、データ抽出項目設定対象契約の契約数を取得します。
	 * </p>
	 * @param inMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	 * @param opSvcCd オプションサービスコード
	 * @param tgKeiSkbtCd 対象契約識別コード
	 * @return 指定された契約番号に紐付くデータ抽出項目設定対象契約の契約数
	 */
	private long getCountKK1401ByTgKeiNo(CAANMsg inMsg, AgentDispatchContext inContext, String tgKeiSkbtCd)
	{
		// コネクション
		Connection con1 = null;
		// プリペアステートメント
		PreparedStatement pstmt = null;
		// リザルトセット
		ResultSet rsltQuery = null;

		// 返却用変数
		long lDataCnt = 0L;

		try
		{
			//コネクション取得
			con1 = JSYejbConnection.getConnection(KK1401ETMsg.getTableName());

			// SQL文
			StringBuffer sql_Buff = new StringBuffer();
			sql_Buff.append(" SELECT ");
			sql_Buff.append("     COUNT(*) AS CNT ");
			sql_Buff.append(" FROM ");
			sql_Buff.append("     KK_T_DCHSKMST KK1391 ");
			sql_Buff.append(" WHERE ");
			sql_Buff.append("     KK1391.DCHSKMST_STAT = '010' ");
			sql_Buff.append("     AND KK1391.DCHSKM_CD = ? ");
			sql_Buff.append("     AND (KK1391.DCHSKMST_NO, KK1391.GENE_ADD_DTM) = ");
			sql_Buff.append("         (SELECT KK1391_GENE.DCHSKMST_NO, MAX(KK1391_GENE.GENE_ADD_DTM) AS KK1391_MAX ");
			sql_Buff.append("          FROM   KK_T_DCHSKMST KK1391_GENE ");
			sql_Buff.append("          WHERE  KK1391_GENE.DCHSKMST_NO = KK1391.DCHSKMST_NO ");
			sql_Buff.append("          AND    KK1391_GENE.MK_FLG = '0' ");
			sql_Buff.append("          GROUP BY KK1391_GENE.DCHSKMST_NO) ");
			sql_Buff.append("     AND EXISTS ( ");
			sql_Buff.append("          SELECT 1 ");
			sql_Buff.append("          FROM   KK_T_DCHSKMST_TG_KEI KK1401 ");
			sql_Buff.append("          WHERE  KK1391.DCHSKMST_NO = KK1401.DCHSKMST_NO ");
			sql_Buff.append("          AND   (KK1401.DCHSKMST_NO, KK1401.DCHSKMST_TG_KEI_NO, KK1401.GENE_ADD_DTM) = ");
			sql_Buff.append("                (SELECT KK1401_GENE.DCHSKMST_NO, KK1401_GENE.DCHSKMST_TG_KEI_NO, MAX(KK1401_GENE.GENE_ADD_DTM) AS KK1401_MAX ");
			sql_Buff.append("                 FROM   KK_T_DCHSKMST_TG_KEI KK1401_GENE ");
			sql_Buff.append("                 WHERE  KK1401_GENE.DCHSKMST_NO = KK1401.DCHSKMST_NO ");
			sql_Buff.append("                 AND    KK1401_GENE.DCHSKMST_TG_KEI_NO = KK1401.DCHSKMST_TG_KEI_NO ");
			sql_Buff.append("                 AND    KK1401_GENE.MK_FLG = '0' ");
			sql_Buff.append("                 GROUP BY KK1401_GENE.DCHSKMST_NO, KK1401_GENE.DCHSKMST_TG_KEI_NO) ");
			if (OYA_KEI_CD_SVC.equals(tgKeiSkbtCd))
			{
				// 親契約識別コードが"01"（サービス契約）の場合、サービス契約番号を条件に含める
				sql_Buff.append("      AND KK1401.SVC_KEI_NO = ? ");
			}
			if (OYA_KEI_CD_UCWK.equals(tgKeiSkbtCd))
			{
				// 親契約識別コードが"03"（サービス契約内訳）の場合、サービス契約内訳番号を条件に含める
				sql_Buff.append("      AND KK1401.SVC_KEI_UCWK_NO = ? ");
			}
			if (OYA_KEI_CD_OP.equals(tgKeiSkbtCd))
			{
				// 親契約識別コードが"04"（オプションサービス契約）の場合、オプションサービス契約番号を条件に含める
				sql_Buff.append("      AND KK1401.OP_SVC_KEI_NO = ? ");
			}
			if (OYA_KEI_CD_SBOP.equals(tgKeiSkbtCd))
			{
				// 親契約識別コードが"05"（サブオプションサービス契約）の場合、
				// オプションサービス契約番号、サブオプションサービス契約番号を条件に含める
				sql_Buff.append("      AND KK1401.OP_SVC_KEI_NO = ? ");
				sql_Buff.append("      AND KK1401.SBOP_SVC_KEI_NO = ? ");
			}
			if (OYA_KEI_CD_KKTK.equals(tgKeiSkbtCd))
			{
				// 親契約識別コードが"06"（機器提供サービス契約）の場合、機器提供サービス契約番号を条件に含める
				sql_Buff.append("      AND KK1401.KKTK_SVC_KEI_NO = ? ");
			}
			sql_Buff.append("         ) ");

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

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

			// パラメータ設定用変数
			int iParam = 1;
			// データ抽出項目コードをパラメータに設定する
			CAANJDBCUtil.setParam(pstmt, iParam++, inMsg.getString(EKK1401D010CBSMsg.DCHSKM_CD));

			if (OYA_KEI_CD_SVC.equals(tgKeiSkbtCd))
			{
				// 親契約識別コードが"01"（サービス契約）の場合、サービス契約番号を条件に含める
				CAANJDBCUtil.setParam(pstmt, iParam++, inMsg.getString(EKK1401D010CBSMsg.SVC_KEI_NO));
			}
			if (OYA_KEI_CD_UCWK.equals(tgKeiSkbtCd))
			{
				// 親契約識別コードが"03"（サービス契約内訳）の場合、サービス契約内訳番号を条件に含める
				CAANJDBCUtil.setParam(pstmt, iParam++, inMsg.getString(EKK1401D010CBSMsg.SVC_KEI_UCWK_NO));
			}
			if (OYA_KEI_CD_OP.equals(tgKeiSkbtCd))
			{
				// 親契約識別コードが"04"（オプションサービス契約）の場合、オプションサービス契約番号を条件に含める
				CAANJDBCUtil.setParam(pstmt, iParam++, inMsg.getString(EKK1401D010CBSMsg.OP_SVC_KEI_NO));
			}
			if (OYA_KEI_CD_SBOP.equals(tgKeiSkbtCd))
			{
				// 親契約識別コードが"05"（サブオプションサービス契約）の場合、
				// オプションサービス契約番号、サブオプションサービス契約番号を条件に含める
				CAANJDBCUtil.setParam(pstmt, iParam++, inMsg.getString(EKK1401D010CBSMsg.OP_SVC_KEI_NO));
				CAANJDBCUtil.setParam(pstmt, iParam++, inMsg.getString(EKK1401D010CBSMsg.SBOP_SVC_KEI_NO));
			}
			if (OYA_KEI_CD_KKTK.equals(tgKeiSkbtCd))
			{
				// 親契約識別コードが"06"（機器提供サービス契約）の場合、機器提供サービス契約番号を条件に含める
				CAANJDBCUtil.setParam(pstmt, iParam++, inMsg.getString(EKK1401D010CBSMsg.KKTK_SVC_KEI_NO));
			}

			// ResultSetの取得
			rsltQuery = pstmt.executeQuery();

			// 件数を返却する
			if (rsltQuery.next())
			{
				lDataCnt = rsltQuery.getLong("CNT");
			}

			return lDataCnt;
		}
		catch(SQLException se)
		{
			throw new CAANRuntimeException(se);
		}
		finally
		{
			// 資源の解放
			try
			{
				if(rsltQuery != null)
				{
					rsltQuery.close();
				}
				if(pstmt != null)
				{
					pstmt.close();
				}
				if(con1 != null)
				{
					CAANConnectionMgr.getInstance().close(con1);
				}
			}
			catch(SQLException se)
			{
				throw new CAANRuntimeException(se);
			}
		}
	}

	/**
	 * <p>
	 * エラー返却項目にエラーフラグを設定します（データ抽出項目設定未存在チェック用）。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inCBSMsgList 処理対象のメッセージキャリア
	 * @param tgKeiSkbtCd 対象契約識別コード
	 */
	private void setErrInfo(CAANMsg inCBSMsg, String tgKeiSkbtCd)
	{
		inCBSMsg.set(JCMConstants.STATUS_INT_KEY, StatusCodes.RELATION_ERR);

		// 対象契約識別コードにより、該当項目にエラーフラグを設定する
		if (OYA_KEI_CD_SVC.equals(tgKeiSkbtCd))
		{
			inCBSMsg.set(EKK1401D010CBSMsg.SVC_KEI_NO_ERR, "EB");
		}
		if (OYA_KEI_CD_UCWK.equals(tgKeiSkbtCd))
		{
			inCBSMsg.set(EKK1401D010CBSMsg.SVC_KEI_UCWK_NO_ERR, "EB");
		}
		if (OYA_KEI_CD_OP.equals(tgKeiSkbtCd))
		{
			inCBSMsg.set(EKK1401D010CBSMsg.OP_SVC_KEI_NO_ERR, "EB");
		}
		if (OYA_KEI_CD_SBOP.equals(tgKeiSkbtCd))
		{
			inCBSMsg.set(EKK1401D010CBSMsg.SBOP_SVC_KEI_NO_ERR, "EB");
		}
		if (OYA_KEI_CD_KKTK.equals(tgKeiSkbtCd))
		{
			inCBSMsg.set(EKK1401D010CBSMsg.KKTK_SVC_KEI_NO_ERR, "EB");
		}

	}

}