/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKSkaLckDteEdit
*	ソースファイル名	：JBSbatKKSkaLckDteEdit.java
*	作成者				：富士通　
*	作成日				：2025年05月06日
*＜機能概要＞
*　スカパー鍵閉め連携年月日編集
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v75.00.00	2025/05/06   GDC)J.Tagongtong		【ANK-4673-00-00】テレビ新コース（スカパー用）導入対応
*
*********************************************************************/
package eo.business.service;

import java.util.HashMap;

import eo.business.common.JBSbatBusinessService;
import eo.business.util.file.JBSbatKKIFM151;
import eo.business.util.table.JBSbatKK_T_IDO_RSV;
import eo.common.constant.JPCBatchMessageConstant;
import eo.common.util.JKKStringUtil;
import eo.framework.application.JBSbatBusinessError;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.util.JCCBatchEsbInterface;

public class JBSbatKKSkaLckDteEdit extends JBSbatBusinessService 
{
	/** テーブル(異動予約)*/
	private static final String D_TBL_NAME_KK_T_IDO_RSV = "KK_T_IDO_RSV";
	
	/** テーブルアクセスクラス(異動予約)*/
	private JBSbatSQLAccess db_KK_T_IDO_RSV = null;
	
	/** SQL定義キー(KK_SELECT_114)*/
	private static final String KK_T_IDO_RSV_KK_SELECT_114 = "KK_SELECT_114";

	/** スカパー鍵情報操作CC */
	public static final String SPTVKEYINFOOPERATECC = "SPTVKEYINFOOPERATECC";
	
	/** 機能コード (更新) */
	private static final String FUNC_CD_UPD = "1";
	
	/** 機能コード (チェックのみ) */
	private static final String FUNC_CD_CHK = "2";
	
	/** 処理コード コース変更 */
	private static final String SHORI_CD_CRS_CHG = "2";
	
	/** スカパー適用基準年月日区分 即時 */
	private static final String SPTV_APLY_STDARDYMD_DIV_JST = "1";
	
	/** スカパー適用基準年月日区分 次月 */
	private static final String SPTV_APLY_STDARDYMD_DIV_NXTM = "2";

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);
		
		// DBアクセスクラスを生成します
		db_KK_T_IDO_RSV = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_IDO_RSV);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Throwable 
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Throwable
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		super.logPrint.printDebugLog("execute_START");
		
		// SQL実行結果取得用mapを生成（異動予約スキーマ取得）
		JBSbatCommonDBInterface idoDivDataMap = new JBSbatCommonDBInterface();
		
		String[] keyParam = {inMap.getString(JBSbatKKIFM151.IDO_RSV_NO)};
		
		executeKK_T_IDO_RSV_KK_SELECT_114(keyParam);
		idoDivDataMap = db_KK_T_IDO_RSV.selectNext();
		
		if(idoDivDataMap != null) 
		{
			// CAS情報の更新チェックを行う
			boolean result = execSvc(FUNC_CD_CHK, SHORI_CD_CRS_CHG, idoDivDataMap);
			
			if(result)
			{
				// CAS情報の登録を行う
				execSvc(FUNC_CD_UPD, SHORI_CD_CRS_CHG, idoDivDataMap);
			} 
		}
		
		super.logPrint.printDebugLog("execute_END");
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	
	/**
	 * サービスを呼び出す
	 * 
	 * @param funcCd 機能コード
	 * @param shoriCd 処理コード
	 * @param idoDivDataMap 異動予約データ
	 * 
	 * @return boolean true:正常、false:エラー
	 * @throws Throwable 
	 */
	@SuppressWarnings("unchecked")
	private boolean execSvc(String funcCd, String shoriCd, JBSbatCommonDBInterface idoDivDataMap) throws Throwable
	{
		// 異動予約番号
		String idoRsvNo = idoDivDataMap.getString(JBSbatKK_T_IDO_RSV.IDO_RSV_NO);
		// 異動区分
		String idoDiv = idoDivDataMap.getString(JBSbatKK_T_IDO_RSV.IDO_DIV);
		// 異動予約詳細コード
		String idoRsvDtlCd = idoDivDataMap.getString(JBSbatKK_T_IDO_RSV.IDO_RSV_DTL_CD);
		// サービス契約番号
		String svcKeiNo = idoDivDataMap.getString(JBSbatKK_T_IDO_RSV.SVC_KEI_NO);
		// 旧料金コース
		String oldPcrs = idoDivDataMap.getString(JBSbatKK_T_IDO_RSV.OLD_PCRS_CD);
		// 新料金コース
		String newPcrs = idoDivDataMap.getString(JBSbatKK_T_IDO_RSV.NEW_PCRS_CD);
		// 予約適用年月日
		String rsvAplyYmd = idoDivDataMap.getString(JBSbatKK_T_IDO_RSV.RSV_APLY_YMD);
		
		HashMap<Object, Object>  paramMap = new HashMap<Object, Object>();
		paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_USECASE_ID, "KKSV1052");
		paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_OPERATION_ID, "KKSV1052OP");
		
		// サービスに渡す業務データを格納するMAP
		HashMap<String, Object> inputMap = new HashMap<String, Object>();
		
		// inputMapに設定するデータをHashMapで構築する。
		HashMap<String, Object>  KKSV1052DataMap = new HashMap<String, Object>();
		
		// 機能コード
		KKSV1052DataMap.put("func_cd", funcCd);
		// 処理コード
		KKSV1052DataMap.put("shori_cd", shoriCd);
		// サービス契約番号
		KKSV1052DataMap.put("svc_kei_no", svcKeiNo);
		// 旧料金コース
		KKSV1052DataMap.put("old_pcrs", oldPcrs);
		// 新料金コース
		KKSV1052DataMap.put("new_pcrs", newPcrs);
		// バッチ運用日付
		String opeDate = commonItem.getOpeDate();
		// スカパー適用基準年月日区分
		if(rsvAplyYmd.compareTo(opeDate) <= 0)
		{
			KKSV1052DataMap.put("sptv_aply_stdardymd_div", SPTV_APLY_STDARDYMD_DIV_JST);
		}
		else
		{
			KKSV1052DataMap.put("sptv_aply_stdardymd_div", SPTV_APLY_STDARDYMD_DIV_NXTM);
		}

		inputMap.put(SPTVKEYINFOOPERATECC, KKSV1052DataMap);
		
		// サービスの処理結果が格納されるMAP
		HashMap<Object, Object> outputMap = new HashMap<Object, Object>();
		
		// サービスの実行
		try
		{
			JCCBatchEsbInterface.invokeService(super.commonItem, paramMap, inputMap, outputMap);
			
			String returnCode = JCCBatchEsbInterface.getReturnCode(outputMap);;
			
			if (!JCCBatchEsbInterface.RETURN_CODE_SUCCESS.equals(returnCode)) 
			{
				throw new JBSbatBusinessError();
			}
			
			HashMap<String, Object> resultMap = null;
			String errCd = "";
			
			if(outputMap.containsKey(SPTVKEYINFOOPERATECC))
			{
				resultMap = (HashMap)outputMap.get(SPTVKEYINFOOPERATECC);
				
				// エラーコードを取得する
				if (resultMap != null)
				{
					errCd = (String) resultMap.get("err_cd");
				}
			}
			
			if(!JKKStringUtil.isNullBlank(errCd))
			{
				// キー情報をログ出力する
				StringBuilder sb = new StringBuilder();
				sb.append("登録状態エラー ")
				.append("(サービス契約番号:")
				.append(svcKeiNo)
				.append("/異動予約番号:")
				.append(idoRsvNo)
				.append("/異動区分:")
				.append(idoDiv)
				.append("/異動予約詳細コード:")
				.append(idoRsvDtlCd)
				.append("/エラーコード:")
				.append(errCd);
				
				super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB0010CW, new String[]{sb.toString()});
				super.commonItem.setErrFlg(true);
				return false;
			}
		}
		catch (Exception ex)
		{
			super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB1010CW, new String[]{"スカパー鍵情報操作 " + "サービス契約番号：" + svcKeiNo });
			super.commonItem.setErrFlg(true);
			return false;
		}
		
		return true;
	}
	
	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(KK_SELECT_114)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			工事案件番号
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKK_T_IDO_RSV_KK_SELECT_114(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());

		// DBアクセスを実行します
		db_KK_T_IDO_RSV.selectBySqlDefine(paramList, KK_T_IDO_RSV_KK_SELECT_114);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		
		// DBアクセスクラスをクローズします
		if (db_KK_T_IDO_RSV != null) {
			db_KK_T_IDO_RSV.close();
		}
		
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}
}