/*********************************************************************
*	All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名		：eo顧客基幹システム
*	モジュール名	：JEKK0181C040ETDA
*	ソースファイル名：JEKK0181C040ETDA.java
*	作成者			：富士通
*	日付			：2013年03月27日
*＜機能概要＞
*	サービス契約内訳<eo光TV>使用開始時の副次処理を行う部品
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*   v4.00.00    2013/03/27  FJ）寺園    IT1-2013-0000534
*   v20.00.00   2015/11/02  FJ)中林     ANK-2197-00-00対応
*   v23.00.00   2016/03/02  FJ)森脇     OM-2016-0000505 対応
*   v23.00.01   2016/04/22  FJ)森脇     OM-2016-0001051 対応
**********************************************************************/

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.ejb.cbm.entity.KK0161ETMsg;
import eo.ejb.cbm.entity.KK0161LE;
import eo.ejb.cbm.entity.KK1681ETMsg;
import eo.ejb.cbm.entity.KK1681LE;
import eo.ejb.cbs.cbsmsg.EKK0181C040CBSMsg;
import eo.ejb.common.JKKModelCommon;
import eo.ejb.common.edit.JKKejbKK1681NumberParts;

/**
 * <p>
 * サービス契約内訳<eo光TV>使用開始の副次処理を行う部品クラスです。
 * </p>
 * @author 富士通
 */
public class JEKK0181C040ETDA implements TemplateMainHandler
{
	/** 異動予約詳細コード：サービス開始 */
	private static final String SERVICE_START = "004";
	
	// OM-2016-0000505 ADD START
	/** 異動予約詳細コード：サービス開始時主従切替 */
	private static final String SERVICE_START_TV_MAINSUBKEI = "030";
	// OM-2016-0000505 ADD END

	/** 異動予約状態コード：異動予約対象外 */
	private static final String YOYAKU_OUTSIDE = "04";
	
	/** 無効フラグ：有効 */
	private static final String MK_FLG_YUKO = "0";

	// ▼▼▼▼▼ ANK-2197-00-00 2015/11/02 ADD START ▼▼▼▼▼
	/** 異動予約状態コード：未反映 */
	private static final String YOYAKU_UNREFLECT = "00";

	/** 異動区分(00066)：TV契約主従料金設定 */
	private static final String IDO_DIV_TV_MAINSUBKEI = "00066";
	// ▲▲▲▲▲ ANK-2197-00-00 2015/11/02 ADD END ▲▲▲▲▲

	/**
	 * <p>
	 * サービス契約内訳<eo光TV>使用開始の副次処理を行います。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	*/
	public void execDBAccess(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
// OM-2016-0000505 MOD START
//		// ▼▼▼▼▼ ANK-2197-00-00 2015/11/02 ADD START ▼▼▼▼▼
//		// STB主従切替の異動予約を登録
//		createKK1681_YOYAKU(inCBSMsg, inContext);
//		// ▲▲▲▲▲ ANK-2197-00-00 2015/11/02 ADD END ▲▲▲▲▲

		// サービス契約内訳のカレントレコード取得
		CAANMsg inMsgKK0161 = new CAANMsg(KK0161ETMsg.class.getName());
		inMsgKK0161.set(KK0161ETMsg.SVC_KEI_UCWK_NO, inCBSMsg.getString(EKK0181C040CBSMsg.SVC_KEI_UCWK_NO));
		inMsgKK0161.set(KK0161ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(inCBSMsg));
		CAANMsg curMsgKK0161 = new JKKejbKK0161DBABase().findByCurrent(inMsgKK0161);

		// レコード取得できなければ、処理をしない
		if(curMsgKK0161 == null)
		{
			return;
		}

		// カレントレコードのプラン課金開始年月日を参照
		String plan_chrg_staymd = curMsgKK0161.getString(KK0161ETMsg.PLAN_CHRG_STAYMD);

		// 異動予約より、予約適用年月日・サービス契約番号が同一のレコードを取得
		CAANMsg[] msgList = getTvMainSubKeiJudgeList(plan_chrg_staymd, curMsgKK0161.getString(KK0161ETMsg.SVC_KEI_NO));

		if(msgList != null && msgList.length != 0)
		{
			// レコードが存在すれば、新たに登録する必要がないため、異動予約への登録を行わない
		}
		else
		{
			// レコードが存在しない為、異動予約を作成
			createKK1681_YOYAKU(inCBSMsg, inContext, plan_chrg_staymd, curMsgKK0161, null);
		}
		// OM-2016-0001051 ADD START
		// 予約適用年月日の設定値取得
		String rsv_aply_ymd = getSvSvcStaymd(inCBSMsg);
		// OM-2016-0001051 ADD END
		// OM-2016-0001051 MOD START
		// 異動予約より、予約適用年月日・サービス契約番号が同一のレコードを取得
//		msgList = getTvMainSubKeiJudgeList(JKKModelCommon.getOpeDate(inCBSMsg), curMsgKK0161.getString(KK0161ETMsg.SVC_KEI_NO));
		msgList = getTvMainSubKeiJudgeList(rsv_aply_ymd, curMsgKK0161.getString(KK0161ETMsg.SVC_KEI_NO));
		// OM-2016-0001051 MOD END

		if(msgList != null && msgList.length != 0)
		{
			// レコードが存在すれば、新たに登録する必要がないため、異動予約への登録を行わない
		}
		else
		{
			// レコードが存在しない為、異動予約を作成
			// OM-2016-0001051 MOD START
//			createKK1681_YOYAKU(inCBSMsg, inContext ,JKKModelCommon.getOpeDate(inCBSMsg), curMsgKK0161, SERVICE_START_TV_MAINSUBKEI);
			createKK1681_YOYAKU(inCBSMsg, inContext ,rsv_aply_ymd, curMsgKK0161, SERVICE_START_TV_MAINSUBKEI);
			// OM-2016-0001051 MOD END
		}
// OM-2016-0000505 MOD END
// OM-2016-0001051 DEL START
//		// 予約適用年月日の設定値取得
//		String rsv_aply_ymd = getSvSvcStaymd(inCBSMsg);
// OM-2016-0001051 DEL END

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

		// 異動予約登録処理を実行
		create(inCBSMsg, inContext, rsv_aply_ymd);

		return;
	}

	// ▼▼▼▼▼ ANK-2197-00-00 2015/11/02 ADD START ▼▼▼▼▼
	/**
	 * STB主従切替用の異動予約登録
	 * @param inCBSMsg  処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	 */	
// OM-2016-0000505 MOD START
//	public void createKK1681_YOYAKU(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	public void createKK1681_YOYAKU(CAANMsg inCBSMsg, AgentDispatchContext inContext, String plan_chrg_staymd, CAANMsg curMsgKK0161, String idoRsvDtlCd)
	{
// OM-2016-0000505 MOD END
// OM-2016-0000505 DEL START
//		// サービス契約内訳のカレントレコード取得
//		CAANMsg inMsgKK0161 = new CAANMsg(KK0161ETMsg.class.getName());
//		inMsgKK0161.set(KK0161ETMsg.SVC_KEI_UCWK_NO, inCBSMsg.getString(EKK0181C040CBSMsg.SVC_KEI_UCWK_NO));
//		inMsgKK0161.set(KK0161ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(inCBSMsg));
//		CAANMsg curMsgKK0161 = new JKKejbKK0161DBABase().findByCurrent(inMsgKK0161);
//
//		// レコード取得できなければ、処理をしない
//		if(curMsgKK0161 == null)
//		{
//			return;
//		}
//
//		// カレントレコードのプラン課金開始年月日を参照
//		String plan_chrg_staymd = curMsgKK0161.getString(KK0161ETMsg.PLAN_CHRG_STAYMD);
//
//		// 異動予約より、予約適用年月日・サービス契約番号が同一のレコードを取得
//		CAANMsg[] msgList = getTvMainSubKeiJudgeList(plan_chrg_staymd, curMsgKK0161.getString(KK0161ETMsg.SVC_KEI_NO));
//
//		// レコードが存在すれば、新たに登録する必要がないため、異動予約への登録を行わない
//		if(msgList != null && msgList.length != 0)
//		{
//			return;
//		}
// OM-2016-0000505 DEL END

		// 異動予約更新用Msg生成
		CAANMsg create1681ETMsg = new CAANMsg(KK1681ETMsg.class.getName());

		// 採番処理
		String ido_rsv_no = new JKKejbKK1681NumberParts().getIdoRsvNo(inCBSMsg, inContext);

		// 異動予約番号
		create1681ETMsg.set(KK1681ETMsg.IDO_RSV_NO, ido_rsv_no);

		// 異動区分
		create1681ETMsg.set(KK1681ETMsg.IDO_DIV, IDO_DIV_TV_MAINSUBKEI);

		// OM-2016-0000505 ADD START
		// 異動予約詳細コード <- サービス開始時主従切替を設定
		create1681ETMsg.set(KK1681ETMsg.IDO_RSV_DTL_CD, idoRsvDtlCd);
		// OM-2016-0000505 ADD END

		// 予約適用年月日
		// STB主従切替の異動予約適用年月日は、プラン課金開始年月日を設定
		create1681ETMsg.set(KK1681ETMsg.RSV_APLY_YMD, plan_chrg_staymd);

		// 異動予約状態コード
		create1681ETMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, YOYAKU_UNREFLECT);

		// 申込明細番号
		create1681ETMsg.set(KK1681ETMsg.MSKM_DTL_NO, curMsgKK0161.getString(KK0161ETMsg.MSKM_DTL_NO));

		// サービス契約番号
		create1681ETMsg.set(KK1681ETMsg.SVC_KEI_NO, curMsgKK0161.getString(KK0161ETMsg.SVC_KEI_NO));

		// 登録年月日時分秒
		create1681ETMsg.set(KK1681ETMsg.ADD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));

		// 登録オペレータアカウント
		create1681ETMsg.set(KK1681ETMsg.ADD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));

		// 更新年月日時分秒
		create1681ETMsg.set(KK1681ETMsg.UPD_DTM, inCBSMsg.getString(JCMConstants.OPERATE_DATETIME_KEY));

		// 更新オペレータアカウント
		create1681ETMsg.set(KK1681ETMsg.UPD_OPEACNT, inCBSMsg.getString(JCMConstants.OPERATOR_ID_KEY));

		// 無効フラグ	MK_FLG
		create1681ETMsg.set(KK1681ETMsg.MK_FLG, MK_FLG_YUKO);

		// 更新処理の実行
		JKKejbDBAUtil dbaUtil1681 = new JKKejbDBAUtil(inCBSMsg);
		dbaUtil1681.create(create1681ETMsg);
	}
	// ▲▲▲▲▲ ANK-2197-00-00 2015/11/02 ADD END ▲▲▲▲▲

	// ▼▼▼▼▼ ANK-2197-00-00 2015/11/02 ADD START ▼▼▼▼▼
	/**
	 * DBよりSTB主従切替の異動予約レコードを取得して返却する。
	 * @param rsv_aply_ymd 予約適用年月日
	 * @param svc_kei_no サービス契約番号
	 * @return STB主従切替対象の異動予約情報を転記したCAANMsg[]
	 */
	private CAANMsg[] getTvMainSubKeiJudgeList(String rsv_aply_ymd, String svc_kei_no)
	{
		// 異動予約参照用Msg生成
		CAANMsg conditionETMsg = new CAANMsg(KK1681ETMsg.class.getName());
		conditionETMsg.set(KK1681ETMsg.IDO_DIV, IDO_DIV_TV_MAINSUBKEI);
		conditionETMsg.set(KK1681ETMsg.RSV_APLY_YMD, rsv_aply_ymd);
		conditionETMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, YOYAKU_UNREFLECT);
		conditionETMsg.set(KK1681ETMsg.SVC_KEI_NO, svc_kei_no);
		conditionETMsg.set(KK1681ETMsg.MK_FLG, MK_FLG_YUKO);

		try
		{
			return new KK1681LE().findByCondition(conditionETMsg);
		}
		catch (CAANException ce)
		{
			throw new CAANRuntimeException(ce);
		}
	}
	// ▲▲▲▲▲ ANK-2197-00-00 2015/11/02 ADD END ▲▲▲▲▲

	/**
	 * <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>
	 * 異動予約登録処理の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(EKK0181C040CBSMsg.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(EKK0181C040CBSMsg.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(EKK0181C040CBSMsg.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 処理対象のメッセージ
	 * @return オプションサービス契約のサービス開始年月日
	 */
	private String getSvSvcStaymd(CAANMsg inCBSMsg)
	{
		// サービス契約内訳検索用のパラメータ設定
		CAANMsg msg = new CAANMsg(KK0161ETMsg.class.getName());
		msg.set(KK0161ETMsg.SVC_KEI_UCWK_NO, inCBSMsg.getString(EKK0181C040CBSMsg.SVC_KEI_UCWK_NO));
		msg.set(KK0161ETMsg.GENE_ADD_DTM, inCBSMsg.getString(EKK0181C040CBSMsg.KK0161_GENE_ADD_DTM));

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

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