/*********************************************************************
*	All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名		：eo顧客基幹システム
*	モジュール名	：JEKK0191C050ETDA
*	ソースファイル名：JEKK0191C050ETDA.java
*	作成者			：富士通
*	日付			：2011年10月14日
*＜機能概要＞
*	サービス契約内訳<eo光電話>使用開始時の副次処理を行う部品
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/10/14	富士通		新規作成
*   v4.00.00    2013/03/23  FJ)寺本     OT-2013-0000311
*   v4.00.01    2013/04/09  FJ)寺本     ��697
*   v7.00.00    2014/02/13  FJ)小島     OM-2014-0000664
*   v8.00.00    2014/03/10  FJ)寺園     ANK-1855-00-00
**********************************************************************/

package eo.ejb.common.db;

import com.fujitsu.futurity.common.JCMConstants;
import com.fujitsu.futurity.model.base.CAANException;
import com.fujitsu.futurity.model.base.CAANMsg;
import com.fujitsu.futurity.model.base.CAANRuntimeException;
import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext;
import com.fujitsu.futurity.model.ejb.common.fw.TemplateMainHandler;

import eo.common.util.JPCUtilCommon;
import eo.ejb.cbm.entity.KK0161ETMsg;
import eo.ejb.cbm.entity.KK0161LE;
import eo.ejb.cbm.entity.KK0351ETMsg;
import eo.ejb.cbm.entity.KK0371ETMsg;
import eo.ejb.cbm.entity.KK1681ETMsg;
import eo.ejb.cbs.cbsmsg.EKK0191C050CBSMsg;
import eo.ejb.common.JKKModelCommon;
import eo.ejb.common.JKKModelConst;
import eo.ejb.common.edit.JKKejbKK1681NumberParts;

/**
 * <p>
 * サービス契約内訳<eo光電話>使用開始の副次処理を行う部品クラスです。
 * </p>
 * @author 富士通
 */
public class JEKK0191C050ETDA implements TemplateMainHandler
{
	/** 異動予約詳細コード：サービス開始 */
	private static final String SERVICE_START = "004";
	
	/** 異動予約状態コード：異動予約対象外 */
	private static final String YOYAKU_OUTSIDE = "04";
	
	/** 無効フラグ：有効 */
	private static final String MK_FLG_YUKO = "0";

	/** 継続後契約変更手続中フラグ：変更手続中である */
	private static final String KEIZK_AF_KEI_CHGECHU_FLG_ON = "1";
	
	/** 予約適用コード：予約確定 */
	private static final String RSV_APLY_CD_RSV_FIXED = "2";
	
	/**
	 * <p>
	 * サービス契約内訳<eo光電話>使用開始の副次処理を行います。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	*/
	public void execDBAccess(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		// 予約適用年月日の設定値取得
		String rsv_aply_ymd = getSvSvcStaymd(inCBSMsg);

		// EE対応表の条件の判定
		if(!checkJoken(inCBSMsg, inContext, rsv_aply_ymd))
		{
			return;
			
		}

		// 異動予約登録処理を実行
		create(inCBSMsg, inContext, rsv_aply_ymd);
		
		return;
	}
	
	/**
	 * <p>
	 * サービス契約内訳<eo光電話>使用開始の副次処理を行います。
	 * （電話番号変更時のオプションサービス契約に対する振舞い）
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	 * @throws CAANException 
	 */
	public void execDBAccessKK0351(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		// 実施条件
		if (!isExecute(inCBSMsg))
		{
			return;
		}

		// 更新処理開始
		// 電話番号変更時の新電話番号の「サービス契約内訳」のサービス契約内訳番号
		String svcKeiUcwkNo = inCBSMsg.getString(EKK0191C050CBSMsg.SVC_KEI_UCWK_NO);

		// 電話番号変更時の新電話番号の「サービス契約内訳」を取得する
		CAANMsg searchKey = new CAANMsg(KK0161ETMsg.class.getName());
		searchKey.set(KK0161ETMsg.SVC_KEI_UCWK_NO, svcKeiUcwkNo);
		searchKey.set(KK0161ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(inCBSMsg));

		CAANMsg kk0161Info = new JKKejbKK0161DBABase().findByCurrent(searchKey);

		// 検索結果が0件の場合
		if (kk0161Info == null)
		{
			throw new CAANRuntimeException("サービス契約内訳のカレント取得に失敗しました。サービス契約内訳番号=[" + svcKeiUcwkNo + "]");
		}

		// 電話番号変更時の新電話番号の「サービス契約内訳」のサービス契約内訳番号(継続元サービス契約内訳番号)を取得する
		String keizkMtSvcKeiUcwkNo = kk0161Info.getString(KK0161ETMsg.KEIZK_MT_SVC_KEI_UCWK_NO);

		// サービス契約内訳番号に紐付くオプションサービス契約を取得します
		JKKejbKK0351DBABase kk0351dba = new JKKejbKK0351DBABase();
		CAANMsg[] kk0351InfoList = kk0351dba.getKK0351bySvcKeiUcwk(keizkMtSvcKeiUcwkNo, null, JKKModelCommon.getOpeDate(inCBSMsg));

		// 設定する世代登録年月日時分秒からミリ秒を除去します。
		String geneAddDtmBase = inCBSMsg.getString(EKK0191C050CBSMsg.KK0161_GENE_ADD_DTM).substring(0, 14);
		
		for (CAANMsg kk0351Info : kk0351InfoList)
		{
			// オプションサービス契約番号に紐付くオプションサービス契約を取得します
			CAANMsg[] kk0351RirekiList = kk0351dba.getKK0351byOpSvcKeiRireki(keizkMtSvcKeiUcwkNo, 
					kk0351Info.getString(KK0351ETMsg.OP_SVC_KEI_NO), null, JKKModelCommon.getOpeDate(inCBSMsg));
			
			int i = 0;
			for (CAANMsg kk0351Rireki : kk0351RirekiList)
			{
				// オプションサービス契約の履歴を全て登録します
				StringBuilder stb = new StringBuilder();
				stb.append(geneAddDtmBase);
				stb.append(JPCUtilCommon.padNumFormString(String.valueOf(i++), 3));
				this.createKK0351(inCBSMsg, kk0161Info, kk0351Rireki, stb.toString());
			}
		}
	}

	/**
	 * <p>
	 * オプションサービス契約の登録を行うか否かの実施条件
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @return true：実施する false：実施しない
	 */
	private boolean isExecute(CAANMsg inCBSMsg)
	{
		// オプションサービス紐付変更未実施フラグが"1"（紐付変更を実施しない）の場合は副次処理は行なわない
		if (!inCBSMsg.isNull(EKK0191C050CBSMsg.OP_SVC_HMZK_NOCHG_FLG) &&
				"1".equals(inCBSMsg.getString(EKK0191C050CBSMsg.OP_SVC_HMZK_NOCHG_FLG))) 
		{
			return false;
		}
		
		//*副次処理******************************************************************************************
		//*　使用開始対象の「サービス契約内訳」が電話番号変更により新規追加されている場合、                 *
		//*　電話番号の切換(旧→新)時に、配下の「オプションサービス契約」のサービス契約内訳番号を更新する。 *
		//*　条件：継続後契約変更手続中フラグ＝"1"(変更手続中である)のレコードが存在すること。              *
		//***************************************************************************************************
		CAANMsg searchkey = new CAANMsg(KK0161ETMsg.class.getName());
		searchkey.set(KK0161ETMsg.SVC_KEI_UCWK_NO, inCBSMsg.getString(EKK0191C050CBSMsg.SVC_KEI_UCWK_NO));
		searchkey.set(KK0161ETMsg.KEIZK_AF_KEI_CHGECHU_FLG, KEIZK_AF_KEI_CHGECHU_FLG_ON);
		searchkey.set(KK0161ETMsg.MK_FLG, MK_FLG_YUKO);

		CAANMsg[] kk0161InfoList = null;
		try
		{
			kk0161InfoList = new KK0161LE().findByCondition(searchkey);
		}
		catch (CAANException ce)
		{
			// 処理失敗
			throw new CAANRuntimeException(ce);
		}

		// 検索結果が1件以上存在する場合
		if (kk0161InfoList.length > 0)
		{
			return true;
		}
		return false;
	}

	/**
	 * <p>
	 * オプションサービス契約登録処理のDBアクセス処理を行います。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param kk0161Info サービス契約内訳のカレント情報
	 * @param kk0351Info オプションサービス契約のカレント情報
	*/
	private void createKK0351(CAANMsg inCBSMsg, CAANMsg kk0161Info, CAANMsg kk0351Info, String setGeneAddDtm)
	{
		// サブタイプ検索用にオプションサービス契約番号と世代を保持しておく
		String opSvcKeiNo = kk0351Info.getString(KK0351ETMsg.OP_SVC_KEI_NO);
		String geneAddDtm = kk0351Info.getString(KK0351ETMsg.GENE_ADD_DTM);

		// サービス契約内訳.世代登録年月日時分秒　⇒　オプションサービス契約.世代登録年月日時分秒
		kk0351Info.set(KK0351ETMsg.GENE_ADD_DTM, setGeneAddDtm);

		// サービス契約内訳.サービス契約内訳番号　⇒　オプションサービス契約.サービス契約内訳番号
		kk0351Info.set(KK0351ETMsg.SVC_KEI_UCWK_NO, kk0161Info.getString(KK0161ETMsg.SVC_KEI_UCWK_NO));

		// サービス契約内訳.申込明細番号　⇒　オプションサービス契約.申込明細番号
		kk0351Info.set(KK0351ETMsg.MSKM_DTL_NO, kk0161Info.getString(KK0161ETMsg.MSKM_DTL_NO));

		// 運用日付　⇒　オプションサービス契約.予約適用年月日
		kk0351Info.set(KK0351ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(inCBSMsg));

		// 予約確定　⇒　オプションサービス契約.予約適用コード
		kk0351Info.set(KK0351ETMsg.RSV_APLY_CD, RSV_APLY_CD_RSV_FIXED);

		// 運用日付　⇒　オプションサービス契約.オプションサービス契約引継発生年月日
		kk0351Info.set(KK0351ETMsg.OP_SVC_KEI_HKHASYMD, JKKModelCommon.getOpeDate(inCBSMsg));

		// 入力.異動区分　⇒　オプションサービス契約.異動区分
		kk0351Info.set(KK0351ETMsg.IDO_DIV, inCBSMsg.getString(EKK0191C050CBSMsg.IDO_DIV));

		// 共通.登録年月日時分秒　⇒　オプションサービス契約.登録年月日時分秒
		kk0351Info.set(KK0351ETMsg.ADD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));

		// 共通.登録オペレータアカウント　⇒　オプションサービス契約.登録オペレータアカウント
		kk0351Info.set(KK0351ETMsg.ADD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));

		// 共通.更新年月日時分秒　⇒　オプションサービス契約.更新年月日時分秒
		kk0351Info.set(KK0351ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));

		// 共通.更新オペレータアカウント　⇒　オプションサービス契約.更新オペレータアカウント
		kk0351Info.set(KK0351ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));

		// 有効　⇒　オプションサービス契約.無効フラグ
		kk0351Info.set(KK0351ETMsg.MK_FLG, MK_FLG_YUKO);

		// オプションサービス契約の登録
		JKKejbDBAUtil dba = new JKKejbDBAUtil(inCBSMsg);
		dba.create(kk0351Info);
		
		//***************************************************************************************
		// オプションサービス契約＜電話＞（サブタイプ）を生成する                               *
		//***************************************************************************************
		// オプションサービス契約＜電話＞をプライマリ検索する
		CAANMsg kk0371Info = new JKKejbKK0371DBABase().getKK0371Primary(opSvcKeiNo, geneAddDtm);

		// オプションサービス契約.世代登録年月日時分秒　⇒　オプションサービス契約<電話>.世代登録年月日時分秒
		kk0371Info.set(KK0371ETMsg.GENE_ADD_DTM, setGeneAddDtm);

		// 共通.登録年月日時分秒　⇒　オプションサービス契約<電話>.登録年月日時分秒
		kk0371Info.set(KK0371ETMsg.ADD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));

		// 共通.登録オペレータアカウント　⇒　オプションサービス契約<電話>.登録オペレータアカウント
		kk0371Info.set(KK0371ETMsg.ADD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));

		// 共通.更新年月日時分秒　⇒　オプションサービス契約<電話>.更新年月日時分秒
		kk0371Info.set(KK0371ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));

		// 共通.更新オペレータアカウント　⇒　オプションサービス契約<電話>.更新オペレータアカウント
		kk0371Info.set(KK0371ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));

		// 有効　⇒　オプションサービス契約<電話>.無効フラグ
		kk0371Info.set(KK0371ETMsg.MK_FLG, JKKModelConst.MK_FLG_YK);

		// オプションサービス契約<電話>の登録
		dba = new JKKejbDBAUtil(inCBSMsg);
		dba.create(kk0371Info);
	}

	/**
	 * <p>
	 * 異動予約登録処理のDBアクセス処理を行います。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	 * @param rsv_aply_ymd 予約適用年月日
	*/
	private void create(CAANMsg inCBSMsg, AgentDispatchContext inContext, String rsv_aply_ymd)
	{
		// ETMsgの作成
		CAANMsg inETMsg = new CAANMsg(KK1681ETMsg.class.getName());
		
		// 採番処理
		JKKejbKK1681NumberParts numberParts = new JKKejbKK1681NumberParts();
		String ido_rsv_no = numberParts.getIdoRsvNo(inCBSMsg, inContext);
		
		// 異動予約番号	IDO_RSV_NO
		inETMsg.set(KK1681ETMsg.IDO_RSV_NO, ido_rsv_no);
		
		// 異動区分	IDO_DIV
		inETMsg.set(KK1681ETMsg.IDO_DIV, inCBSMsg.getString(EKK0191C050CBSMsg.IDO_DIV));
		
		// 異動予約詳細コード	IDO_RSV_DTL_CD
		inETMsg.set(KK1681ETMsg.IDO_RSV_DTL_CD, SERVICE_START);
		
		// 予約適用年月日	RSV_APLY_YMD
		inETMsg.set(KK1681ETMsg.RSV_APLY_YMD, rsv_aply_ymd);
		
		// 異動予約状態コード	IDO_RSV_STAT_CD
		inETMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, YOYAKU_OUTSIDE);

		// カレントレコードの取得(サービス契約内訳)
		JKKejbKK0161DBABase kk0161Db = new JKKejbKK0161DBABase();
		CAANMsg inMsg0161 = new CAANMsg(KK0161ETMsg.class.getName());
		inMsg0161.set(KK0161ETMsg.SVC_KEI_UCWK_NO, inCBSMsg.getString(EKK0191C050CBSMsg.SVC_KEI_UCWK_NO));
		inMsg0161.set(KK0161ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(inCBSMsg));
		CAANMsg ret0161 = kk0161Db.findByCurrent(inMsg0161);
		
		// 申込明細番号	MSKM_DTL_NO
		inETMsg.set(KK1681ETMsg.MSKM_DTL_NO, ret0161.getString(KK0161ETMsg.MSKM_DTL_NO));
		
		// サービス契約内訳番号	SVC_KEI_UCWK_NO
		inETMsg.set(KK1681ETMsg.SVC_KEI_UCWK_NO, inCBSMsg.getString(EKK0191C050CBSMsg.SVC_KEI_UCWK_NO));
		
		// 登録年月日時分秒	ADD_DTM
		inETMsg.set(KK1681ETMsg.ADD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));
		
		// 登録オペレータアカウント	ADD_OPEACNT
		inETMsg.set(KK1681ETMsg.ADD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));
		
		// 更新年月日時分秒	UPD_DTM
		inETMsg.set(KK1681ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));
		
		// 更新オペレータアカウント	UPD_OPEACNT
		inETMsg.set(KK1681ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));
		
		// 無効フラグ	MK_FLG
		inETMsg.set(KK1681ETMsg.MK_FLG, MK_FLG_YUKO);

		// 異動予約番号の登録
		JKKejbDBAUtil dba = new JKKejbDBAUtil(inCBSMsg);
		dba.create(inETMsg);
	
		return;
	}

	/**
	 * <p>
	 * 異動予約登録処理の条件チェックを行います。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext ディスパッチコンテキスト
	 * @param rsv_aply_ymd 予約適用年月日
	 * @return チェック結果(OK:true, NG:false)
	*/
	private boolean checkJoken(CAANMsg inCBSMsg, AgentDispatchContext inContext, String rsv_aply_ymd)
	{
		if( rsv_aply_ymd != null && rsv_aply_ymd.compareTo(JKKModelCommon.getOpeDate(inCBSMsg)) > 0)
		{
			return true;
		}
		
		return false;
	}

	/**
	 * <p>
	 * サービス契約内訳のサービス開始年月日を取得します。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージ
	 * @return オプションサービス契約のサービス開始年月日
	 */
	private String getSvSvcStaymd(CAANMsg inCBSMsg)
	{
		// サービス契約内訳検索用のパラメータ設定
		CAANMsg msg = new CAANMsg(KK0161ETMsg.class.getName());
		msg.set(KK0161ETMsg.SVC_KEI_UCWK_NO, inCBSMsg.getString(EKK0191C050CBSMsg.SVC_KEI_UCWK_NO));
		msg.set(KK0161ETMsg.GENE_ADD_DTM, inCBSMsg.getString(EKK0191C050CBSMsg.KK0161_GENE_ADD_DTM));

		// サービス契約内訳のプライマリ検索
		CAANMsg ret = new KK0161LE().findByPrimaryKey(msg);

		// 取得したレコードのサービス開始年月日を返却
		return ret.getString(KK0161ETMsg.SVC_STA_YMD);
	}
}