/*******************************************************************************
*	All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
*	システム名		：eo顧客基幹システム
*	モジュール名	：JEKK0081C250TPMA
*	ソースファイル名：JEKK0081C250TPMA.java
*	作成者			：EKek0048
*	日付			：2011年06月24日
*＜機能概要＞
*	サービス契約お客様変更顧客独自処理部品部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/06/24	富士通		新規作成
*	v8.00.00	2014/06/02	FJ)小島		OM-2014-0001861
*   v10.00.00	2014/09/03	FJ)中野		OM-2014-0002770
*	v33.00.00	2017/09/09	FJ)星野		OM-2017-0000920
********************************************************************************/

package eo.ejb.cbs.mainproc;

import com.fujitsu.futurity.common.JCMConstants;
import com.fujitsu.futurity.model.base.CAANMsg;
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.common.util.JPCUtilCommon;
import eo.ejb.cbs.cbsmsg.EKK0081C250CBSMsg;
import eo.ejb.common.JKKModelCommon;
import eo.ejb.common.db.JEKK0081C250ETDA;
import eo.ejb.common.db.JKKejbKK0081SecProc;
import eo.ejb.common.db.JKKejbKK0081SubTypeCreate;
import eo.ejb.common.db.JKKejbKK0161DBABase;
import eo.ejb.common.db.JKKejbKK0241DBABase;
import eo.ejb.common.db.JKKejbKK0341SecProc;
import eo.ejb.common.db.JKKejbKK0351SecProc;
import eo.ejb.common.entity.JEKK0081C250KRCK;
import eo.ejb.common.entity.JKKejbIdoRestrictController;



/**
 * <p>
 * サービス契約お客様変更顧客独自処理部品部品クラスです。
 * </p>
 * @author 富士通
 */
public class JEKK0081C250TPMA implements TemplateMainHandler
{

	/**
	 * サービス契約お客様変更関連チェック処理の呼び出しを行います。
	 * 
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	 */
	public void execKRCK(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		// 開始ログ出力
		JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "call:JEKK0081C250TPMA#execKRCK");

		// 関連制約処理の呼び出し
		new JEKK0081C250KRCK().execKRCK(inCBSMsg, inContext);

		// 終了ログ出力
		JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "end:JEKK0081C250TPMA#execKRCK");
	}

	/**
	 * サービス契約お客様変更DBアクセス処理の呼び出しを行います。
	 * 
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	 */
	public void execDBAccess(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{

		// 開始ログ出力
		JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "call:JEKK0081C250TPMA#execDBAccess");

		String svcKeiNo = inCBSMsg.getString(EKK0081C250CBSMsg.SVC_KEI_NO);

		// DBアクセス処理の呼び出し
		new JEKK0081C250ETDA().execDBAccess(svcKeiNo, inCBSMsg, inContext);

		// 終了ログ出力
		JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "end:JEKK0081C250TPMA#execDBAccess");
	}

	/**
	 * サービス契約お客様変更顧客独自処理部品
	 * 
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	 */
	public void createSubTypeKK0081(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		// 実行判定
		if (new JKKejbIdoRsvUtil().isSingleIdoRsv(inCBSMsg, inContext))
		{
			// 異動予約のみに振舞う場合、処理を終了する
			return;
		}

		// サービス契約サブタイプ登録処理の呼び出し
		JKKejbKK0081SubTypeCreate instance = new JKKejbKK0081SubTypeCreate(inCBSMsg);
		instance.setSvcKeiNo(inCBSMsg.getString(EKK0081C250CBSMsg.SVC_KEI_NO));
		instance.setGeneAddDtm(inCBSMsg.getString(EKK0081C250CBSMsg.GENE_ADD_DTM));
		instance.createSubTypeKK0081();

	}

	/**
	 * サービス契約お客様変更顧客独自処理部品
	 * 
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	 */
	public void invoke(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		// 実行判定
		if (new JKKejbIdoRsvUtil().isSingleIdoRsv(inCBSMsg, inContext))
		{
			// 異動予約のみに振舞う場合、処理を終了する
			return;
		}

		// 機器提供サービス契約次処理部品
		JKKejbKK0341SecProc kk0341 = new JKKejbKK0341SecProc();

		// オプションサービス契約副次処理部品
		JKKejbKK0351SecProc kk0351 = new JKKejbKK0351SecProc();

		// 引数設定
		String svcKeiNo = inCBSMsg.getString(EKK0081C250CBSMsg.SVC_KEI_NO);
		String sysid = inCBSMsg.getString(EKK0081C250CBSMsg.SYSID);
		String mskmDtlNo = inCBSMsg.getString(EKK0081C250CBSMsg.MSKM_DTL_NO);
		String idoDiv = inCBSMsg.getString(EKK0081C250CBSMsg.IDO_DIV);

		// 設定用予約適用年月日
		String insRsvAplyYmd = null;

		//入力値「予約適用年月日」＜運用日付の場合、運用日付で更新する
		if (JPCUtilCommon.isPastDate(inCBSMsg.getString(EKK0081C250CBSMsg.RSV_APLY_YMD), JKKModelCommon.getOpeDate(inCBSMsg), "0"))
		{
			insRsvAplyYmd = JKKModelCommon.getOpeDate(inCBSMsg);
		}
		// 上記以外の場合、入力値「予約適用年月日」で更新する
		else
		{
			insRsvAplyYmd = inCBSMsg.getString(EKK0081C250CBSMsg.RSV_APLY_YMD);
		}
		
		// OM-2017-0000920対応 20170920 星野 ADD START
		// サービス契約（未来日レコード）のSYSIDを更新する
		JKKejbKK0081SecProc kk0081 = new JKKejbKK0081SecProc();
		kk0081.svcKeiCustChgUpdateFuture(inCBSMsg, svcKeiNo, sysid, insRsvAplyYmd);
		// OM-2017-0000920対応 20170920 星野 ADD START
		
		
		// 入力値「サービス契約番号」からサービス契約内訳を取得する
		CAANMsg[] kk0161MsgList = new JKKejbKK0161DBABase().getKK0161bySvcKei( svcKeiNo, null, JKKModelCommon.getOpeDate(inCBSMsg));
		
		// 入力値「サービス契約番号」からサービス契約回線内訳を取得する
		// OM-2017-0000920対応 20170920 星野 MOD START
//		CAANMsg[] kk0241MsgList = new JKKejbKK0241DBABase().getKK0241bySvcKei(inContext, svcKeiNo, JKKModelCommon.getOpeDate(inCBSMsg), "1");
		CAANMsg[] kk0241MsgList = new JKKejbKK0241DBABase().getKK0241bySvcKei(inContext, svcKeiNo, JKKModelCommon.getOpeDate(inCBSMsg), "3");
		// OM-2017-0000920対応 20170920 星野 MOD END

		// (1)機器提供サービス契約副次部品を呼び出す。
		kk0341.kktkSvcCustChg(inCBSMsg, svcKeiNo, kk0161MsgList, kk0241MsgList, sysid, mskmDtlNo, insRsvAplyYmd, idoDiv);

		// (2)オプションサービス契約副次部品を呼び出す。
		kk0351.opSvKeiCustchg(inCBSMsg, svcKeiNo, kk0161MsgList, sysid, mskmDtlNo, insRsvAplyYmd, idoDiv);
		
		// その他SYSIDを更新
		// OM-2014-0002770 MOD START
		// new JEKK0081C250ETDA().sysidUpdate(inCBSMsg, inContext);
		new JEKK0081C250ETDA().sysidUpdate(inCBSMsg, inContext, kk0241MsgList);
		// OM-2014-0002770 MOD END
	}

	/**
	 * <p>
	 * サービス契約お客様変更時の異動制約チェックを呼び出しを行います。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	*/
	public void idoKhChk(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		// 開始ログ出力
		JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "call:JEKK0081C250TPMA#idoKhChk");

		if (inCBSMsg.isNull(EKK0081C250CBSMsg.SVC_KEI_NO))
		{
			return;
		}

		// 異動可否判定チェック部品の呼び出し
		JKKejbIdoRestrictController idoKh = new JKKejbIdoRestrictController(inCBSMsg);
		
		// 呼び出しパラメータの設定
		idoKh.setBaseDate(inCBSMsg.getString(EKK0081C250CBSMsg.RSV_APLY_YMD));
		idoKh.setIdo_div(inCBSMsg.getString(EKK0081C250CBSMsg.IDO_DIV));
		idoKh.setMskm_dtl_no(inCBSMsg.getString(EKK0081C250CBSMsg.MSKM_DTL_NO));
		idoKh.setTg_skbt_cd(JKKejbIdoRestrictController.TG_SKBT_CD_KK0081);
		idoKh.setSysid_new(inCBSMsg.getString(EKK0081C250CBSMsg.SYSID));
		idoKh.setSysidJoinFlg(true);
		idoKh.setSvc_kei_no(inCBSMsg.getString(EKK0081C250CBSMsg.SVC_KEI_NO));
		
		// 異動可否判定
		boolean rslt = idoKh.isIdoKahi();

		// 異動登録可の場合はtrue、不可の場合はfalse
		if (!rslt)
		{
			inCBSMsg.set(EKK0081C250CBSMsg.IDO_DIV_ERR, idoKh.getErrFlg());
			inCBSMsg.set(JCMConstants.STATUS_INT_KEY, StatusCodes.TEMPLATE_CORRELATION_ERR);
		}
		
		// 終了ログ出力
		JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "end:JEKK0081C250TPMA#idoKhChk");
	}
}
