/*********************************************************************
*   All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*   システム名      ：eo顧客基幹システム
*   モジュール名    ：JEKK1681C030KRCK
*   ソースファイル名：JEKK1681C030KRCK.java
*   作成者          ：富士通
*	日付			：2014年08月15日
*＜機能概要＞
*   異動予約更新（交換希望日変更）の関連制約部品クラス
*＜修正履歴＞
*   バージョン  修正日      修正者      修正内容
*	v10.00.00	2014/08/15	富士通		新規作成(ANK-2141-00-00)
*
**********************************************************************/

package eo.ejb.common.entity;

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.StatusCodes;
import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext;

import eo.ejb.cbm.entity.KK1681ETMsg;
import eo.ejb.cbm.entity.KK1681LE;
import eo.ejb.cbs.cbsmsg.EKK1681C030CBSMsg;
import eo.ejb.common.JKKModelCommon;
import eo.ejb.common.JKKModelConst;
import eo.ejb.common.db.JKKejbKK1681DBABase;

/**
 * <p>
 * 異動予約更新（交換希望日変更）の関連制約部品クラスです。
 * </p>
 * @author 富士通
 */
public class JEKK1681C030KRCK
{

	/** 関連チェックエラーフラグ&エラー返却項目(異動予約 STB異動予約存在チェック) */
	private static final String[] KRCK_STB_IDORSV_EXISTS_ERR = {"EA", EKK1681C030CBSMsg.KKTK_SVC_KEI_NO_ERR};
	
	/** 関連チェックエラーフラグ&エラー返却項目(異動予約 C-CAS異動予約存在チェック) */
	private static final String[] KRCK_CCAS_IDORSV_EXISTS_ERR = {"EB", EKK1681C030CBSMsg.KKTK_SVC_KEI_NO_ERR};
	
	/**
	 * <p>
	 * 新しいJEKK1681C030KRCKを作成します。
	 * </p>
	 */
	public JEKK1681C030KRCK()
	{
	}

	/**
	 * <p>
	 * 異動予約更新（交換希望日変更）の関連制約を行います。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	 */
	public void execKRCK(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		try
		{
			// 機器提供サービス契約番号
			String kktkSvcKeiNo = inCBSMsg.getString(EKK1681C030CBSMsg.KKTK_SVC_KEI_NO);

			// 異動予約メッセージインスタンスを生成
			CAANMsg inMsg = new CAANMsg(KK1681ETMsg.class.getName());
			
			// 機器提供サービス契約番号に紐付く異動予約番号を取得するためにメッセージを生成
			inMsg.set(KK1681ETMsg.KKTK_SVC_KEI_NO, kktkSvcKeiNo);
			inMsg.set(KK1681ETMsg.NEW_KIKI_CHG_NO, inCBSMsg.getString(EKK1681C030CBSMsg.NEW_KIKI_CHG_NO));
			inMsg.set(KK1681ETMsg.IDO_RSV_DTL_CD, JKKModelConst.IDO_RSV_DTL_CD_STB_DIRECT_SHIPMENT);
			inMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, JKKModelConst.IDO_RSV_STAT_CD_MI_HANEI);
			inMsg.set(KK1681ETMsg.MK_FLG, JKKModelConst.MK_FLG_YK);

			// KK1681LEインスタンスの生成
			KK1681LE kk1681le = new KK1681LE();
			
			// ロジカルエンティティを生成し、異動予約を検索
			CAANMsg[] kk1681StbMsgList = kk1681le.findByCondition(inMsg);

			// 取得件数が1件でない場合はエラー
			if (kk1681StbMsgList == null || kk1681StbMsgList.length != 1)
			{
				setErrInfo(inCBSMsg, StatusCodes.RELATION_ERR, KRCK_STB_IDORSV_EXISTS_ERR);
				return;
			}

			// 異動予約DBアクセス部品
			JKKejbKK1681DBABase kk1681dba = new JKKejbKK1681DBABase();

			// 機器提供サービス契約からサービス契約内訳に紐づくC-CASの異動予約を取得
			CAANMsg[] kk1681CCasMsgList = kk1681dba.getIdoRsvCCas(kktkSvcKeiNo, JKKModelCommon.getOpeDate(inCBSMsg));

			// 取得件数が2件以上存在する場合はエラー
			if (kk1681CCasMsgList == null || kk1681CCasMsgList.length > 1)
			{
				setErrInfo(inCBSMsg, StatusCodes.RELATION_ERR, KRCK_CCAS_IDORSV_EXISTS_ERR);
				return;
			}
		}
		catch(CAANException ce)
		{
			throw new CAANRuntimeException(ce);
		}
	}
	
	/**
	 * <p>
	 * エラー返却項目にエラーフラグを設定します。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param status エラー時のステータス
	 * @param errInfo[] エラー情報が設定された配列 [0]:エラーフラグ [1]:エラー返却項目
	 */
	private void setErrInfo(CAANMsg inCBSMsg, int status, String[] errInfo)
	{
		inCBSMsg.set(JCMConstants.STATUS_INT_KEY, status);
		inCBSMsg.set(errInfo[1], errInfo[0]);
		return;
	}
}

