/*********************************************************************
*	All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名		：eo顧客基幹システム
*	モジュール名	：JEKK0341C530ETDA
*	ソースファイル名：JEKK0341C530ETDA.java
*	作成者			：富士通
*	日付			：2011年10月14日
*＜機能概要＞
*	機器提供サービス契約機器変更手続開始時の副次処理を行う部品
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/10/14	富士通		新規作成
*	v10.00.00	2014/08/08	FJ)小島		ANK-2141-00-00
*
**********************************************************************/

package eo.ejb.common.db;

import com.fujitsu.futurity.common.JCMConstants;
import com.fujitsu.futurity.model.base.CAANMsg;
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.KK0341ETMsg;
import eo.ejb.cbm.entity.KK0341LE;
import eo.ejb.cbm.entity.KK1681ETMsg;
import eo.ejb.cbs.cbsmsg.EKK0341C160CBSMsg;
import eo.ejb.cbs.cbsmsg.EKK0341C530CBSMsg;
import eo.ejb.common.JKKModelCommon;
import eo.ejb.common.edit.JKKejbKK1681NumberParts;

/**
 * <p>
 * 機器提供サービス契約機器変更手続開始の副次処理を行う部品クラスです。
 * </p>
 * @author 富士通
 */
public class JEKK0341C530ETDA implements TemplateMainHandler
{
	/** 異動予約詳細コード：機器変更手続 */
	private static final String OPE_CHNG_PROCE = "012";
	
	// ANK-2141-00-00 ADD START
	/** 異動予約詳細コード：STB宅配交換 */
	private static final String IDO_RSV_DTL_STB_DELIV_CHNG = "029";
	
	/** 異動予約状態コード：未反映 */
	private static final String IDO_RSV_STAT_MI_HANEI = "00";
    // ANK-2141-00-00 ADD END
	
	/** 異動予約状態コード：異動予約対象外 */
	private static final String YOYAKU_OUTSIDE = "04";
	
	/** 無効フラグ(有効) **/
	private static final String MK_FLG_YUKO = "0";
	
	/** 予約適用年月日（設定なしの場合に使用） **/
	private static final String RSV_APLY_YMD = "20991231";
	
	
	/**
	 * <p>
	 * 機器提供サービス契約機器変更手続開始の副次処理を行います。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	*/
	public void execDBAccess(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		// EE対応表の条件の判定

		// 異動予約更新処理を実行
		create(inCBSMsg, inContext);
		
		return;
	}
	
	/**
	 * <p>
	 * 異動予約登録処理のDBアクセス処理を行います。
	 * </p>
	 * @param inCBSMsg 処理対象のメッセージキャリア
	 * @param inContext Agentから渡されたAgentDispatchContext
	*/
	private void create(CAANMsg inCBSMsg, AgentDispatchContext inContext)
	{
		// 機器提供サービス契約の一意照会
		CAANMsg getKk0341Msg = getSelectKk0341(inCBSMsg);
		
		// 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(EKK0341C530CBSMsg.IDO_DIV));
		
		// ANK-2141-00-00 ADD START
		if (inCBSMsg.getString(EKK0341C530CBSMsg.NEW_KIKI_USE_STA_KIBO_YMD) == null)
		{
		// ANK-2141-00-00 ADD END
			// 異動予約詳細コード	IDO_RSV_DTL_CD
			inETMsg.set(KK1681ETMsg.IDO_RSV_DTL_CD, OPE_CHNG_PROCE);

			// 予約適用年月日	RSV_APLY_YMD
			String rsv_aply_ymd = getKk0341Msg.getString(KK0341ETMsg.RSV_APLY_YMD);
			if (null == rsv_aply_ymd || rsv_aply_ymd.length() == 0)
			{
				inETMsg.set(KK1681ETMsg.RSV_APLY_YMD, RSV_APLY_YMD);
			}
			else
			{
				inETMsg.set(KK1681ETMsg.RSV_APLY_YMD, rsv_aply_ymd);
			}

			// 異動予約状態コード	IDO_RSV_STAT_CD
			inETMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, YOYAKU_OUTSIDE);
		// ANK-2141-00-00 ADD START
		}
		else
		{
			CAANMsg inMsg = new CAANMsg(KK0341ETMsg.class.getName());
			inMsg.set(KK0341ETMsg.KKTK_SVC_KEI_NO, inCBSMsg.getString(EKK0341C530CBSMsg.KKTK_SVC_KEI_NO));
			inMsg.set(KK0341ETMsg.RSV_APLY_YMD, JKKModelCommon.getOpeDate(inCBSMsg));
			
			JKKejbKK0341DBABase kk0341dba = new JKKejbKK0341DBABase();
			CAANMsg[] kk0341 = kk0341dba.findByCurrentSecond(inMsg);
			
			// 変更前の機器変更番号を取得
			String oldKikiChgNo = null;
			
			if (inCBSMsg.getString(EKK0341C530CBSMsg.GENE_ADD_DTM).equals(kk0341[0].getString(KK0341ETMsg.GENE_ADD_DTM)))
			{
				// 登録したレコードがカレントになっている場合
				oldKikiChgNo = kk0341[1].getString(KK0341ETMsg.KIKI_CHG_NO);
			}
			else
			{
				// 登録したレコードがカレントになっていない場合
				oldKikiChgNo = kk0341[0].getString(KK0341ETMsg.KIKI_CHG_NO);
			}
			
			// 異動予約詳細コード	IDO_RSV_DTL_CD
			inETMsg.set(KK1681ETMsg.IDO_RSV_DTL_CD, IDO_RSV_DTL_STB_DELIV_CHNG);

			// 予約適用年月日	RSV_APLY_YMD
			String monthEndYmd = inCBSMsg.getString(EKK0341C160CBSMsg.NEW_KIKI_USE_STA_KIBO_YMD).substring(0, 6);
			monthEndYmd = monthEndYmd + JPCUtilCommon.getEndOfMonth(monthEndYmd);
			inETMsg.set(KK1681ETMsg.RSV_APLY_YMD, monthEndYmd);

			// 異動予約状態コード	IDO_RSV_STAT_CD
			inETMsg.set(KK1681ETMsg.IDO_RSV_STAT_CD, IDO_RSV_STAT_MI_HANEI);
			
			// 交換希望年月日	KOKAN_KIBOYMD
			inETMsg.set(KK1681ETMsg.NEW_KIKI_USE_STA_KIBO_YMD, inCBSMsg.getString(EKK0341C530CBSMsg.NEW_KIKI_USE_STA_KIBO_YMD));

			// 新機器変更番号	NEW_KIKI_CHG_NO
			inETMsg.set(KK1681ETMsg.NEW_KIKI_CHG_NO, inCBSMsg.getString(EKK0341C530CBSMsg.KIKI_CHG_NO));

			// 旧機器変更番号	OLD_KIKI_CHG_NO
			inETMsg.set(KK1681ETMsg.OLD_KIKI_CHG_NO, oldKikiChgNo);
			
		}
		// ANK-2141-00-00 ADD END
		
		// 申込明細番号 MSKM_DTL_NO
		inETMsg.set(KK1681ETMsg.MSKM_DTL_NO, inCBSMsg.getString(EKK0341C530CBSMsg.MSKM_DTL_NO));
		
		// 機器提供サービス契約番号	KKTK_SVC_KEI_NO
		inETMsg.set(KK1681ETMsg.KKTK_SVC_KEI_NO, inCBSMsg.getString(EKK0341C530CBSMsg.KKTK_SVC_KEI_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 CAANMsg getSelectKk0341(CAANMsg inCBSMsg)
	{
		// 機器提供サービス契約検索用のパラメータ設定
		CAANMsg msg = new CAANMsg(KK0341ETMsg.class.getName());
		msg.set(KK0341ETMsg.KKTK_SVC_KEI_NO, inCBSMsg.getString(EKK0341C530CBSMsg.KKTK_SVC_KEI_NO));
		msg.set(KK0341ETMsg.GENE_ADD_DTM, inCBSMsg.getString(EKK0341C530CBSMsg.GENE_ADD_DTM));

		// 機器提供サービス契約のプライマリ検索して返却
		return new KK0341LE().findByPrimaryKey(msg);
	}
}