/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKUHojinHktgKojiInfoCst
*	ソースファイル名	：JBSbatKUHojinHktgKojiInfoCst.java
*	作成者				：富士通　
*	作成日				：2012年07月10日
*＜機能概要＞
*　法人引継ぎ工事情報抽出部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2012/07/10   富士通		新規作成
*	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.JCCBatCommon;
import eo.business.common.JKUBatCommon;
import eo.business.util.file.JBSbatKUIFE035;
import eo.business.util.file.JBSbatKUIFM004;
import eo.business.util.table.JBSbatKU_T_HOJINSVKEI_KJAK;
import eo.business.util.table.JBSbatKU_T_KJ_KNRN_RCV_IF;
import eo.business.util.table.JBSbatKU_T_KOJIAK;
import eo.business.util.table.JBSbatZM_M_KITEN_HDSHO;
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 JBSbatKUHojinHktgKojiInfoCst extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(起点変電所)*/
	private static final String D_TBL_NAME_ZM_M_KITEN_HDSHO = "ZM_M_KITEN_HDSHO";

	/** テーブル(法人サービス契約＿工事案件)*/
	private static final String D_TBL_NAME_KU_T_HOJINSVKEI_KJAK = "KU_T_HOJINSVKEI_KJAK";

	/** テーブル(工事案件)*/
	private static final String D_TBL_NAME_KU_T_KOJIAK = "KU_T_KOJIAK";

	/** SQL定義キー(KU_SELECT_007)*/
	private static final String KU_T_HOJINSVKEI_KJAK_KU_SELECT_007 = "KU_SELECT_007";

	/** テーブルアクセスクラス(起点変電所)*/
	private JBSbatSQLAccess db_ZM_M_KITEN_HDSHO = null;

	/** テーブルアクセスクラス(法人サービス契約＿工事案件)*/
	private JBSbatSQLAccess db_KU_T_HOJINSVKEI_KJAK = null;

	/** テーブルアクセスクラス(工事案件)*/
	private JBSbatSQLAccess db_KU_T_KOJIAK = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

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

		// DBアクセスクラスを生成します
		db_ZM_M_KITEN_HDSHO = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_KITEN_HDSHO);
		db_KU_T_HOJINSVKEI_KJAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_HOJINSVKEI_KJAK);
		db_KU_T_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KOJIAK);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		
		// 工事情報送信(法人)の項目名Mapを作成
		indexHjKjKrInfoMap = createIndexHjKjKrInfoMap();
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		// 出力共通電文を生成する。
		JBSbatOutputItem outputBean = new JBSbatOutputItem();
		
		// 入力情報（工事案件）の工事案件番号
		String kojiakNo = inMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_NO);
		
		// バインド変数を設定
		Object[] whereParam = new Object[3];
		whereParam[0] = kojiakNo;
		whereParam[1] = opeDate;
		whereParam[2] = opeDate;
		
		// 法人サービス契約_工事案件の取得と存在チェック
		executeKU_T_HOJINSVKEI_KJAK_KU_SELECT_007(whereParam);
		JBSbatCommonDBInterface hjsvcKjakRsDB = db_KU_T_HOJINSVKEI_KJAK.selectNext();
		
		if (false == isExistCheckKU_T_HOJINSVKEI_KJAK_KU_SELECT_007(hjsvcKjakRsDB, kojiakNo))
		{
			throw new JBSbatBusinessError();
		}
		
		// 法人サービス契約番号
		String hojinSvcKeiNo = hjsvcKjakRsDB.getString(JBSbatKU_T_HOJINSVKEI_KJAK.HJIN_EO_YKAE_SVKEI_NO);
		
		// 起点変電所マスタレコードの取得
		String kitenHdshoCd = inMap.getString(JBSbatKU_T_KOJIAK.KITEN_HDSHO_CD);
		JBSbatCommonDBInterface kitenHdshoRsDB = null;
		if (null != kitenHdshoCd)
		{
			kitenHdshoRsDB = executeZM_M_KITEN_HDSHO_PKSELECT(new String[]{kitenHdshoCd});
		}
		
		// 集約局コードの取得
		String shyakkCd = null;
		if (null != kitenHdshoRsDB)
		{
			shyakkCd = kitenHdshoRsDB.getString(JBSbatZM_M_KITEN_HDSHO.SHYAKK_CD);
		}
		
		// ---ファイル出力
		
		// 伝送設備情報
		outputBean.addOutMapList(getOutMapDensoEquipInfo(inMap, hojinSvcKeiNo, shyakkCd));
		
		// 開通完了情報
		outputBean.addOutMapList(getOutMapKaitsuFinInfo(inMap, hojinSvcKeiNo, shyakkCd));
		
		// ---更新処理
		
		// 工事案件更新
		executeKU_T_KOJIAK_PKUPDATE(
				new String[]{JKUStrConst.TOKUSHU_KOJIAK_SKBT_CD_IO_KJ_INF_RNKI_FIN},
				new String[]{kojiakNo});
		
		return outputBean;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

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

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

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

	/**
	 * SQLKEY(KU_SELECT_007)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	工事案件番号
	 *		 	法人サービス契約＿工事案件適用開始年月日
	 *		 	法人サービス契約＿工事案件適用終了年月日
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeKU_T_HOJINSVKEI_KJAK_KU_SELECT_007(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());

		// DBアクセスを実行します
		db_KU_T_HOJINSVKEI_KJAK.selectBySqlDefine(paramList, KU_T_HOJINSVKEI_KJAK_KU_SELECT_007);
	}

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

		// DBアクセスを実行します
		db_KU_T_KOJIAK.updateByPrimaryKeys(whereMap, setMap);
	}
	
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	
	/**▼▼▼▼▼▼業務チームで作成したメソッドです 開始▼▼▼▼▼▼*/
	
	/**
	 * 工事情報送信(法人)の項目名Map
	 * 
	 * @return HashMap<Object, String> 項目名Map
	 * 
	 */	
	private HashMap<Object, String> createIndexHjKjKrInfoMap()
	{
		HashMap<Object, String> retMap = new HashMap<Object, String>();
		
		retMap.put(0, JBSbatKUIFM004.TRN_DTM);
		retMap.put(1, JBSbatKUIFM004.REC_SBT);
		retMap.put(2, JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD);
		retMap.put(3, JBSbatKUIFM004.MSKMSHO_NO);
		retMap.put(4, JBSbatKUIFM004.HOJIN_SVC_KEI_NO);
		retMap.put(5, JBSbatKUIFM004.KMK_1);
		retMap.put(6, JBSbatKUIFM004.KMK_2);
		retMap.put(7, JBSbatKUIFM004.KMK_3);
		retMap.put(8, JBSbatKUIFM004.KMK_4);
		retMap.put(9, JBSbatKUIFM004.KMK_5);
		retMap.put(10, JBSbatKUIFM004.KMK_6);
		retMap.put(11, JBSbatKUIFM004.KMK_7);
		retMap.put(12, JBSbatKUIFM004.KMK_8);
		retMap.put(13, JBSbatKUIFM004.KMK_9);
		retMap.put(14, JBSbatKUIFM004.KMK_10);

		return retMap;
	}
	
	/**
	 *入力情報（法人サービス契約_工事案件）の存在チェックを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.存在チェックを行います。<br>
	 * 
	 * 2.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		nRsCnt:レコード数
	 *		kojiakNo:工事案件番号
	 * </pre>
	 * <p>
	 * @param rsDB レコードデータオブジェクト。
	 * @param kojiakNo 検索を行う元となる工事案件番号
	 * @return  boolean trueである場合、エラーがありません。falseである場合、エラーを発生しました。
	 */
	private boolean isExistCheckKU_T_HOJINSVKEI_KJAK_KU_SELECT_007(JBSbatCommonDBInterface rsDB, String kojiakNo)
	{
		int nRsCnt = 0;
		if(rsDB != null)
		{
			nRsCnt = 1;
		}
		// 存在チェックを行います(SQLKEY=KU_SELECT_007)
		if(nRsCnt != 1)
		{
			commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKUB0650KW, new String[]{
															JKUStrConst.SCHEMANM_KU0071,
															"工事案件番号",
															kojiakNo});
			return false;
		}
		return true;
	}
	
	/**
	 * 出力共通電文（伝送設備情報）を設定します。
	 * @param inMap			入力電文（工事案件）
	 * @param hojinSvcKeiNo	法人サービス契約番号
	 * @param shyakkCd		集約局コード
	 * @return	出力共通電文（伝送設備情報）
	 * @throws Exception
	 */
	private JBSbatServiceInterfaceMap getOutMapDensoEquipInfo(JBSbatServiceInterfaceMap inMap, String hojinSvcKeiNo, String shyakkCd) throws Exception
	{
		// ---項目の設定
		
		JBSbatServiceInterfaceMap setMap = new JBSbatServiceInterfaceMap();

		// 処理年月日時分秒
		setMap.setString(JBSbatKUIFM004.TRN_DTM, JCCBatCommon.getSysDateTime());
		// レコード種別
		setMap.setString(JBSbatKUIFM004.REC_SBT, JKUStrConst.KUIFE035_REC_SBT);
		// 法人用工事受付種別コード
		setMap.setString(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_DENSO_EQUIP_INFO);
		// 申込書番号
		setMap.setString(JBSbatKUIFM004.MSKMSHO_NO, inMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_NO));
		// 法人サービス契約番号
		setMap.setString(JBSbatKUIFM004.HOJIN_SVC_KEI_NO, hojinSvcKeiNo);
		
		// 集約局コード
		setMap.setString(JBSbatKUIFM004.KMK_1, convNull(shyakkCd));
		
		// ---出力電文の作成

		return getOutMap(setMap);
	}
	
	/**
	 * 出力共通電文（開通完了情報）を設定します
	 * @param inMap			入力電文（工事案件）
	 * @param hojinSvcKeiNo	法人サービス契約番号
	 * @param shyakkCd		集約局コード
	 * @return	出力共通電文（開通完了情報）
	 * @throws Exception
	 */
	private JBSbatServiceInterfaceMap getOutMapKaitsuFinInfo(JBSbatServiceInterfaceMap inMap, String hojinSvcKeiNo, String shyakkCd) throws Exception
	{
		// ---項目の設定

		JBSbatServiceInterfaceMap setMap = new JBSbatServiceInterfaceMap();
		
		// 処理年月日時分秒
		setMap.setString(JBSbatKUIFM004.TRN_DTM, JCCBatCommon.getSysDateTime());
		// レコード種別
		setMap.setString(JBSbatKUIFM004.REC_SBT, JKUStrConst.KUIFE035_REC_SBT);
		// 法人用工事受付種別コード
		setMap.setString(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_KOJI_FIN_INFO);
		// 申込書番号
		setMap.setString(JBSbatKUIFM004.MSKMSHO_NO, inMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_NO));
		// 法人サービス契約番号
		setMap.setString(JBSbatKUIFM004.HOJIN_SVC_KEI_NO, hojinSvcKeiNo);
		
		// 開通年月日
		setMap.setString(JBSbatKUIFM004.KMK_1, convNull(inMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_JSSI_YMD)));
		// 開通遅延適用有無
		setMap.setString(JBSbatKUIFM004.KMK_2, convNull(null));
		// PON種別コード
		setMap.setString(JBSbatKUIFM004.KMK_3, convNull(inMap.getString(JBSbatKU_T_KOJIAK.PON_SBT_CD)));
// ANK-4352-01-00 ADD START
		// ONU種別コード
		setMap.setString(JBSbatKUIFM004.KMK_4, convNull(inMap.getString(JBSbatKU_T_KOJIAK.PON_SBT_CD)));
// ANK-4352-01-00 ADD END
		
		// ---出力電文の作成

		return getOutMap(setMap);
	}
	
	/**
	 * 出力共通電文（工事情報送信(法人)）に変換します
	 * @param setMap	項目設定済みの入出力インターフェースオブジェクト
	 * @return	工事情報送信(法人)
	 * @throws Exception
	 */
	private JBSbatServiceInterfaceMap getOutMap(JBSbatServiceInterfaceMap setMap) throws Exception
	{
		JBSbatServiceInterfaceMap tempMap = new JBSbatServiceInterfaceMap();
		JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();
		
		// 括り文字付与
		tempMap.setMap(JKUBatCommon.addDblQuote(setMap.getMap()));
		// カンマ編集
		StringBuilder outMapString = JKUBatCommon.editComma(tempMap, indexHjKjKrInfoMap);
		// 入出力インターフェースに設定する
		outMap.setString(JBSbatKUIFE035.HOJIN_KOJI_KNRN_INFO, outMapString);
		// 出力フラグを設定
		outMap.setOutFlg(true);
		
		return outMap;
	}
	
	/**
	 * 文字列がNullである場合、"":ブランク に変換を行う
	 * @param convStr 変換を行う文字列
	 * @return	nullであればブランク、null以外であれば引数のconvStr
	 */
	private String convNull(String convStr)
	{
		if (null == convStr)
		{
			return "";
		}
		return convStr;
	}
	/**▲▲▲▲▲▲業務チームで作成したメソッドです 終了▲▲▲▲▲▲*/
}