/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom					 *
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKUFcdsOltSetChgRspHjCst
*	ソースファイル名	：JBSbatKUFcdsOltSetChgRspHjCst.java
*	作成者				：富士通　
*	作成日				：2011年07月08日
*＜機能概要＞
*　ＦＣＤＳＯＬＴ設定変更応答済抽出（法人）部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/07/08   富士通		新規作成
*	v7.00.00	2014/02/19   FJ)高橋	【TAI-2014-0000009】
*	v64.00.00	2023/03/28   FJ)謝		【ANK-4352-01-00】【eo定期】法人10G対応 STEP2　工事完了情報連携追加対応
*********************************************************************/
package eo.business.service;

import java.util.HashMap;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JKUBatCommon;
import eo.business.util.file.JBSbatKUIFE035;
import eo.business.util.file.JBSbatKUIFM004;
import eo.business.util.table.JBSbatKU_T_OLT_SETE_CHG;
import eo.common.constant.JKUStrConst;
import eo.common.constant.JPCBatchMessageConstant;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.application.JBSbatBusinessError;
import eo.framework.db.JBSbatSQLAccess;

/**
* ＦＣＤＳＯＬＴ設定変更応答済抽出（法人）部品 <p>
*<BR>
* @author 富士通
*/
public class JBSbatKUFcdsOltSetChgRspHjCst extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(工事案件)*/
	private static final String D_TBL_NAME_KU_T_KOJIAK = "KU_T_KOJIAK";

	/** テーブル(ＯＬＴ設定変更)*/
	private static final String D_TBL_NAME_KU_T_OLT_SETE_CHG = "KU_T_OLT_SETE_CHG";

	/** テーブルアクセスクラス(工事案件)*/
	private JBSbatSQLAccess db_KU_T_KOJIAK = null;

	/** テーブルアクセスクラス(ＯＬＴ設定変更)*/
	private JBSbatSQLAccess db_KU_T_OLT_SETE_CHG = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	
	/**▼▼▼▼▼▼業務が作成した宣言です 開始▼▼▼▼▼▼*/
	/** 工事情報送信(法人)の項目名Map */
	private HashMap<Object, String> indexKjKrInfoMap = new HashMap<Object, String>();
	/**▲▲▲▲▲▲業務が作成した宣言です 終了▲▲▲▲▲▲*/
	
	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_KU_T_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KOJIAK);
		db_KU_T_OLT_SETE_CHG = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_OLT_SETE_CHG);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// 出力共通電文を生成する
		JBSbatOutputItem outputBean = new JBSbatOutputItem();
		
		try
		{
			// 入出力インターフェースオブジェクトを生成
			JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();
			
			// 工事情報送信(法人)を格納するマップを作成
			JBSbatServiceInterfaceMap kjKrInfoMap = new JBSbatServiceInterfaceMap();
			
			// カンマ編集された工事情報送信(法人)を格納する変数
			StringBuilder kjKrInfoString = new StringBuilder();
			
			// 工事情報送信(法人)の項目名Mapを取得
			indexKjKrInfoMap = setIndexKjKrInfoMap();
			
			// 工事案件を格納する変数
			String kojiakNo = inMap.getString(JBSbatKU_T_OLT_SETE_CHG.KOJIAK_NO);
			
			/******************************************************/
			/***** 工事案件をレコードロックする。（wait指定） *****/
			/******************************************************/
			excCtrlKojiak(kojiakNo);
			
			/******************************************************/
			
			// 取得する条件を設定
			Object[] whereParamOlt = new Object[1];
			
			// ＯＬＴ設定変更番号を設定
			whereParamOlt[0] = inMap.getString(JBSbatKU_T_OLT_SETE_CHG.OLT_SET_CHGE_NO);
			
			// 抽出したＯＬＴ設定変更のＯＬＴ設定変更番号で抽出する
			JBSbatCommonDBInterface oltSeteChgSelect = this.executeKU_T_OLT_SETE_CHG_PKSELECT(whereParamOlt);
			
			// ＯＬＴ設定変更に存在しない場合
			if (null == oltSeteChgSelect)
			{
				// 次レコードへ
				super.commit();
				return null;
			}
			
			if(oltSeteChgChanged(oltSeteChgSelect))
			{
				// 次レコードへ
				super.commit();
				return null;
			}
			
			// ＯＬＴ設定変更よりＯＬＴ設定変更番号を取得
			String oltSetChgeNo = inMap.getString(JBSbatKU_T_OLT_SETE_CHG.OLT_SET_CHGE_NO);
			
			// 処理年月日時分秒
			kjKrInfoMap.set(JBSbatKUIFM004.TRN_DTM, inMap.getString(JBSbatKU_T_OLT_SETE_CHG.RNKS_RSP_DTM));
			// レコード種別
			kjKrInfoMap.set(JBSbatKUIFM004.REC_SBT, JKUStrConst.KUIFE035_REC_SBT);
			// 申込書番号（更新対象工事案件番号）
			kjKrInfoMap.set(JBSbatKUIFM004.MSKMSHO_NO, inMap.getString(JBSbatKU_T_OLT_SETE_CHG.UPD_TRGT_KOJIAK_NO));
			// 法人サービス契約番号
			kjKrInfoMap.set(JBSbatKUIFM004.HOJIN_SVC_KEI_NO, inMap.getString(JBSbatKU_T_OLT_SETE_CHG.SVC_KEI_NO));
			
			// ＯＬＴ設定変更より設定結果コードを取得
			String setteRslt = inMap.getString(JBSbatKU_T_OLT_SETE_CHG.SETTE_RSLT_CD);
			
			// 設定結果コードがＯＫ
			if (JKUStrConst.CD01130_SET_FIN.equals(setteRslt))
			{
				// 法人用工事受付種別コード
				kjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_KOJI_FIN_INFO);
				// 開通年月日
				kjKrInfoMap.set(JBSbatKUIFM004.KMK_1, inMap.getString(JBSbatKU_T_OLT_SETE_CHG.RNKS_RSP_DTM).substring(0, 8));
				// 開通遅延適用有無
				kjKrInfoMap.set(JBSbatKUIFM004.KMK_2, null);
				// PON種別コード
				kjKrInfoMap.set(JBSbatKUIFM004.KMK_3, null);
// ANK-4352-01-00 ADD START
				// ONU種別コード
				kjKrInfoMap.set(JBSbatKUIFM004.KMK_4, null);
// ANK-4352-01-00 ADD END

			}
			// 設定結果コードがＮＧ
			else if (JKUStrConst.CD01130_SET_NG.equals(setteRslt))
			{
				// 法人用工事受付種別コード
				kjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_FCDS_SPEED_CHG_NG);
				// エラー情報コード
				kjKrInfoMap.set(JBSbatKUIFM004.KMK_1, inMap.getString(JBSbatKU_T_OLT_SETE_CHG.ERR_INFO_CD));

			}
			
			// 括り文字付与
			kjKrInfoMap.setMap(JKUBatCommon.addDblQuote(kjKrInfoMap.getMap()));
			
			// KjKrInfoMapに格納された各項目のカンマ編集を行う
			kjKrInfoString = JKUBatCommon.editComma(kjKrInfoMap, indexKjKrInfoMap);
			
			// 入出力インターフェースに工事情報送信(法人)を設定する
			outMap.setString(JBSbatKUIFE035.HOJIN_KOJI_KNRN_INFO, kjKrInfoString);
			
			// 出力フラグを設定
			outMap.setOutFlg(true);
			
			// 出力共通電文に入出力インターフェースを設定する。
			outputBean.addOutMapList(outMap);
			
			// ＯＬＴ設定変更更新処理
			// 更新する値を設定
			Object[] setParam = new Object[1];
			// 「否」を設定
			setParam[0] = JKUStrConst.KH_FAIL;
			
			// 更新する条件を設定
			Object[] whereParam = new Object[1];
			whereParam[0] = oltSetChgeNo;
			
			 // 更新処理実行
			executeKU_T_OLT_SETE_CHG_PKUPDATE(setParam, whereParam);
			
		}
		catch (JBSbatBusinessError eBusiness)
		{
			// ロールバック
			commonItem.getConnection().rollback();
			throw eBusiness;
		}

		// コミット
		super.commit();
		
		return outputBean;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
//	/**
//	 * PK(ＰＫ　検索)でDBアクセスを行います。<br>
//	 * <p>
//	 * <b>処理フロー</b><br>
//	 * <pre>
//	 * 1.引数で条件マップを作ります。<br>
//	 *
//	 * 2.DBアクセスを実行します。<br>
//	 * 
//	 * 3.メソッドの呼び出し方です。<br>
//	 *		引数:
//	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
//	 *		 	KOJIAK_NO
//	 * </pre>
//	 * <p>
//	 * @param whereParam 条件項目の値。
//	 * @return JBSbatCommonDBInterface 検索の結果。
//	 * @throws Exception 業務サービス内で発生した例外全般。
//	 */
//	private JBSbatCommonDBInterface executeKU_T_KOJIAK_PKSELECT(Object[] whereParam) throws Exception
//	{
//		// 条件のマップを作成します
//		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
//		whereMap.setValue("KOJIAK_NO", whereParam[0]);
//
//		// DBアクセスを実行します
//		return db_KU_T_KOJIAK.selectByPrimaryKeys(whereMap);
//	}

	/**
	 * PK(ＰＫ　更新)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.引数で条件マップを作ります。<br>
	 *
	 * 3.DBアクセスを実行します。<br>
	 * 
	 * 4.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	完了結果連携要否				FIN_RSLT_RENKEI_YH
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	OLT_SET_CHGE_NO
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @param whereParam 条件項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKU_T_OLT_SETE_CHG_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("FIN_RSLT_RENKEI_YH", setParam[0]);
	
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("OLT_SET_CHGE_NO", whereParam[0]);

		// DBアクセスを実行します
		db_KU_T_OLT_SETE_CHG.updateByPrimaryKeys(whereMap, setMap);
	}
	
	/**
	 * PK(ＰＫ　検索)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で条件マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	OLT_SET_CHGE_NO
	 * </pre>
	 * <p>
	 * @param whereParam 条件項目の値。
	 * @return JBSbatCommonDBInterface 検索の結果。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatCommonDBInterface executeKU_T_OLT_SETE_CHG_PKSELECT(Object[] whereParam) throws Exception
	{
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("OLT_SET_CHGE_NO", whereParam[0]);

		// DBアクセスを実行します
		return db_KU_T_OLT_SETE_CHG.selectByPrimaryKeys(whereMap);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	
	/**▼▼▼▼▼▼業務が作成したメソッドです 開始▼▼▼▼▼▼*/
	
	/**
	 * 工事情報送信(法人)の項目名Mapを設定します。
	 * @return 工事情報送信(法人)の項目名Map
	 */	
	private HashMap<Object, String> setIndexKjKrInfoMap()
	{
		this.indexKjKrInfoMap.put(0, JBSbatKUIFM004.TRN_DTM);
		this.indexKjKrInfoMap.put(1, JBSbatKUIFM004.REC_SBT);
		this.indexKjKrInfoMap.put(2, JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD);
		this.indexKjKrInfoMap.put(3, JBSbatKUIFM004.MSKMSHO_NO);
		this.indexKjKrInfoMap.put(4, JBSbatKUIFM004.HOJIN_SVC_KEI_NO);
		this.indexKjKrInfoMap.put(5, JBSbatKUIFM004.KMK_1);
		this.indexKjKrInfoMap.put(6, JBSbatKUIFM004.KMK_2);
		this.indexKjKrInfoMap.put(7, JBSbatKUIFM004.KMK_3);
// ANK-4352-01-00 ADD START
		this.indexKjKrInfoMap.put(8, JBSbatKUIFM004.KMK_4);
// ANK-4352-01-00 ADD END
		
		return indexKjKrInfoMap;
	}
	
	/**
	 * 工事案件のレコードロックを取得する。
	 * @param kojiakNo 工事案件番号
	 * @return 工事案件検索結果レコード
	 * @throws Exception
	 */
	private JBSbatCommonDBInterface excCtrlKojiak(String kojiakNo) throws Exception
	{
		/** DBアクセス結果を取得するためのMap */
		JBSbatCommonDBInterface kojiakMap = new JBSbatCommonDBInterface();
		
		// 検索処理に渡すパラメタを設定
		Object[] whereParam = new Object[1];
		
		whereParam[0] = kojiakNo;
		
		// 検索処理実行
		kojiakMap = this.executeKU_T_KOJIAK_PKSELECT(whereParam);
		
		// 検索結果が０件
		if (kojiakMap == null)
		{
			// 工事案件に該当の工事案件番号が存在しません。（0000000000）
			commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKUB0650KW, new String[]{
					JKUStrConst.SCHEMANM_KU0011,
					"工事案件番号",
					kojiakNo});
			
			throw new JBSbatBusinessError();
		}
		
		return kojiakMap;
	}
	
	/**
	 * PK(ＰＫ　検索)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で条件マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	KOJIAK_NO
	 * </pre>
	 * <p>
	 * @param whereParam 条件項目の値。
	 * @return JBSbatCommonDBInterface 検索の結果。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatCommonDBInterface executeKU_T_KOJIAK_PKSELECT(Object[] whereParam) throws Exception
	{
		// 条件のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("KOJIAK_NO", whereParam[0]);

		// DBアクセスを実行します
		return db_KU_T_KOJIAK.selectByPrimaryKeysForUpdateWait(whereMap);
	}
	

	/**
	 * ＯＬＴ設定変更　変更有無チェック
	 * @param oltSeteChgSelect 抽出ＯＬＴ設定変更
	 * @return boolean 変更有無
	 * @throws Exception
	 */
	private boolean oltSeteChgChanged(JBSbatCommonDBInterface oltSeteChgSelect) throws Exception
	{
		String finRsltRenkeiYh = oltSeteChgSelect.getString(JBSbatKU_T_OLT_SETE_CHG.FIN_RSLT_RENKEI_YH);
		String kojiKeiSvcCd = oltSeteChgSelect.getString(JBSbatKU_T_OLT_SETE_CHG.KOJI_KEI_SVC_CD);
		
		if(JKUStrConst.KH_PSG.equals(finRsltRenkeiYh) && JKUStrConst.CD01108_INTERNET_OFFICE.equals(kojiKeiSvcCd))
		{
			// 完了結果連携要否が「要」かつ 工事契約サービスコードが「インターネットオフィス」
			return false;
		}
		else
		{
			// 上記に当てはまらない場合は変更されている
			return true;
		}
	}
	/**▲▲▲▲▲▲業務が作成したメソッドです 終了▲▲▲▲▲▲*/
}