/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom					 *
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKUHojinKjknrnInfoSaksei
*	ソースファイル名	：JBSbatKUHojinKjknrnInfoSaksei.java
*	作成者				：富士通　
*	作成日				：2011年06月10日
*＜機能概要＞
*　法人工事関連情報作成部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/06/10   富士通		新規作成
*	v30.00.00	2017/10/13   FJ)周藤 	【ANK-2966-00-00】OPMSリプレース（Step２−１）OFの解約、移設連携変更
*	v64.00.00	2023/01/12	 FJ)アラ	【ANK-4352-00-00】法人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_KJ_KNRN_RCV_IF;
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 JBSbatKUHojinKjknrnInfoSaksei 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_KJ_KNRN_RCV_IF = "KU_T_KJ_KNRN_RCV_IF";

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

	/** テーブルアクセスクラス(工事関連受信情報)*/
	private JBSbatSQLAccess db_KU_T_KJ_KNRN_RCV_IF = 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_KJ_KNRN_RCV_IF = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KJ_KNRN_RCV_IF);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// 出力共通電文を生成する。
		JBSbatOutputItem outputBean = new JBSbatOutputItem();
		
		// 入出力インターフェースオブジェクトを生成
		JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();

		// 工事情報送信(法人)を格納するマップを作成
		JBSbatServiceInterfaceMap hjKjKrInfoMap = new JBSbatServiceInterfaceMap();
		
		// カンマ編集された工事情報送信(法人)を格納する変数
		StringBuilder hjKjKrInfoString = new StringBuilder();
		
		// 工事情報送信(法人)の項目名Mapを取得
		indexHjKjKrInfoMap = setIndexHjKjKrInfoMap();
		
		// 工事工程を格納する変数
		String kojistep = inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.OPMS_RNKI_CD).substring(2, 3);
		
		//工事工程により処理を振り分ける
		
		if (JKUStrConst.KJSTEP_DENSO_EQUIP_INFO.equals(kojistep))
		{
			// 工事工程が伝送設備情報
			if (!setDensoEquipInfo(inMap, hjKjKrInfoMap))
			{
				return null;
			}
		}
		else if (JKUStrConst.KJSTEP_KOJI_FIN_INFO.equals(kojistep))
		{
			// 工事工程が工事完了情報
			if (!setKojiFinInfo(inMap, hjKjKrInfoMap))
			{
				return null;
			}
		}
		else if (JKUStrConst.KJSTEP_KOJI_CL_INFO.equals(kojistep))
		{
			// 工事工程が工事取消情報
			if (!setKojiClInfo(inMap, hjKjKrInfoMap))
			{
				return null;
			}
		}
		else
		{
			return outputBean;
		}
		
		// 括り文字付与
		hjKjKrInfoMap.setMap(JKUBatCommon.addDblQuote(hjKjKrInfoMap.getMap()));

		// hjKjKrInfoMapに格納された各項目のカンマ編集を行う
		hjKjKrInfoString = JKUBatCommon.editComma(hjKjKrInfoMap, indexHjKjKrInfoMap);
		
		// 入出力インターフェースに工事情報送信(法人)を設定する
		outMap.setString(JBSbatKUIFE035.HOJIN_KOJI_KNRN_INFO, hjKjKrInfoString);
		
		// 出力フラグを設定
		outMap.setOutFlg(true);

		// 出力共通電文に入出力インターフェースを設定する。
		outputBean.addOutMapList(outMap);
		
		// 工事関連受信情報テーブル更新処理
		// 更新する値を設定
		Object[] setParam = new Object[1];
		// 「抽出済」を設定
		setParam[0] = JKUStrConst.CHSHTFLG_ZUMI;
		
		// 更新する条件を設定
		Object[] whereParam = new Object[3];
		whereParam[0] = inMap.get(JBSbatKU_T_KJ_KNRN_RCV_IF.KOJI_KNRN_RCV_INFO_NO);
		executeKU_T_KJ_KNRN_RCV_IF_PKUPDATE(setParam, whereParam);

		// 出力共通電文を返却
		return outputBean;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼業務チームで作成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * 工事情報送信(法人)_伝送設備情報 設定処理
	 * @param inMap　入力電文(工事関連受信情報)
	 * @param hjKjKrInfoMap　出力情報
	 * @return boolean trueである場合、エラーがありません。falseである場合、エラーを発生しました。
	 * @throws Exception
	 */	
	private boolean setDensoEquipInfo(JBSbatServiceInterfaceMap inMap, JBSbatServiceInterfaceMap hjKjKrInfoMap) throws Exception
	{
		
		/**
		 * 起点変電所コードより集約局コードを取得する。
		 */
		
		// 起点変電所を格納するMap
		JBSbatCommonDBInterface kitenHdshoMap = new JBSbatCommonDBInterface();

		// 検索する値を設定
		Object[] selectParam = new Object[1];
		// 連携データ４(起点変電所コード)を設定
		selectParam[0] = inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_4);
		// 検索処理実行(起点変電所コード)
		// 検索結果を１件取得する
		kitenHdshoMap = this.executeZM_M_KITEN_HDSHO_PKSELECT(selectParam);
		
		// 検索結果が０件
		if (kitenHdshoMap == null)
		{
			// テストエラーメッセージ実装
			// 起点変電所に該当の起点変電所コードが存在しません。（00000000）
			commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKUB0650KW, new String[]{
					"起点変電所",
					"起点変電所コード",
					(String)inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_4)});

			throw new JBSbatBusinessError();
		}
		
		// 処理年月日時分秒
		hjKjKrInfoMap.set(JBSbatKUIFM004.TRN_DTM, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DTM));
		// レコード種別
		hjKjKrInfoMap.set(JBSbatKUIFM004.REC_SBT, JKUStrConst.KUIFE035_REC_SBT);
		// 法人用工事受付種別コード
		hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_DENSO_EQUIP_INFO);
		// 申込書番号
		hjKjKrInfoMap.set(JBSbatKUIFM004.MSKMSHO_NO, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_3));
		// 法人サービス契約番号
		hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_SVC_KEI_NO, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.SVC_KEI_NO));
		// 集約局コード
		hjKjKrInfoMap.set(JBSbatKUIFM004.KMK_1, kitenHdshoMap.getString(JBSbatZM_M_KITEN_HDSHO.SHYAKK_CD));
		
		return true;
	}
	
	/**
	 * 工事情報送信(法人)_工事完了情報 設定処理
	 * @param inMap　入力電文(工事関連受信情報)
	 * @param hjKjKrInfoMap　出力情報
	 * @return boolean trueである場合、エラーがありません。falseである場合、エラーを発生しました。
	 * @throws Exception
	 */	
	private boolean setKojiFinInfo(JBSbatServiceInterfaceMap inMap, JBSbatServiceInterfaceMap hjKjKrInfoMap) throws Exception
	{
		// 処理年月日時分秒
		hjKjKrInfoMap.set(JBSbatKUIFM004.TRN_DTM, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DTM));
		// レコード種別
		hjKjKrInfoMap.set(JBSbatKUIFM004.REC_SBT, JKUStrConst.KUIFE035_REC_SBT);
		// 法人用工事受付種別コード
//ANK-2966-00-00 MOD START
//		hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_KOJI_FIN_INFO);
		//工事関連受信情報の連携データ1(工事案件種別コード)によって処理を分ける
		if(JKUStrConst.CD00577_NEWESTA.equals(inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_1)))
		{
			//「新設」の場合
			hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_KOJI_FIN_INFO);
		}
		else if(JKUStrConst.CD00577_TEKKYO_DSL.equals(inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_1)))
		{
			//「撤去(解約)」の場合
			hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_TEKKYO_KOJI_FIN_INFO);
		}
		else if(JKUStrConst.CD00577_ISETSU.equals(inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_1)))
		{
			//「移設」の場合
			hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_ISETSU_KOJI_FIN_INFO);
		}
//ANK-2966-00-00 MOD END
		// 申込書番号
		hjKjKrInfoMap.set(JBSbatKUIFM004.MSKMSHO_NO, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_3));
		// 法人サービス契約番号
		hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_SVC_KEI_NO, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.SVC_KEI_NO));
		// 開通年月日
		hjKjKrInfoMap.set(JBSbatKUIFM004.KMK_1, iniDateCast(inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_5)));
		// 開通遅延適用有無
		hjKjKrInfoMap.set(JBSbatKUIFM004.KMK_2, null);
		// PON種別コード
		hjKjKrInfoMap.set(JBSbatKUIFM004.KMK_3, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_7));
//ANK-4352-00-00 MOD START
		//ONU種別コード
		hjKjKrInfoMap.set(JBSbatKUIFM004.KMK_4, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_8));		
//ANK-4352-00-00 MOD END
		
		return true;
	}

	/**
	 * 工事情報送信(法人)_工事取消情報 設定処理
	 * @param inMap　入力電文(工事関連受信情報)
	 * @param hjKjKrInfoMap　出力情報
	 * @return boolean trueである場合、エラーがありません。falseである場合、エラーを発生しました。
	 * @throws Exception
	 */	
	private boolean setKojiClInfo(JBSbatServiceInterfaceMap inMap, JBSbatServiceInterfaceMap hjKjKrInfoMap) throws Exception
	{
		// 処理年月日時分秒
		hjKjKrInfoMap.set(JBSbatKUIFM004.TRN_DTM, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DTM));
		// レコード種別
		hjKjKrInfoMap.set(JBSbatKUIFM004.REC_SBT, JKUStrConst.KUIFE035_REC_SBT);
		// 法人用工事受付種別コード
//ANK-2966-00-00 MOD START
//		hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_KOJI_CL_INFO);
		//工事関連受信情報の連携データ1(工事案件種別コード)によって処理を分ける
		if(JKUStrConst.CD00577_NEWESTA.equals(inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_1)))
		{
			//「新設」の場合
			hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_KOJI_CL_INFO);
		}
		else if(JKUStrConst.CD00577_TEKKYO_DSL.equals(inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_1)))
		{
			//「撤去(解約)」の場合
			hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_TEKKYO_KOJI_CL_INFO);
		}
		else if(JKUStrConst.CD00577_ISETSU.equals(inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_1)))
		{
			//「移設」の場合
			hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD, JKUStrConst.KUIFE035_ISETSU_KOJI_CL_INFO);
		}
//ANK-2966-00-00 MOD END
		// 申込書番号
		hjKjKrInfoMap.set(JBSbatKUIFM004.MSKMSHO_NO, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_3));
		// 法人サービス契約番号
		hjKjKrInfoMap.set(JBSbatKUIFM004.HOJIN_SVC_KEI_NO, inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.SVC_KEI_NO));
		// キャンセル登録年月日
		hjKjKrInfoMap.set(JBSbatKUIFM004.KMK_1, iniDateCast(inMap.getString(JBSbatKU_T_KJ_KNRN_RCV_IF.RENKEI_DATA_5)));
		
		return true;
	}
	
	/**
	 * 工事情報送信(法人)の項目名Map
	 * 
	 * @return HashMap<Object, String> 項目名Map
	 * 
	 */	
	private HashMap<Object, String> setIndexHjKjKrInfoMap()
	{
		this.indexHjKjKrInfoMap.put(0, JBSbatKUIFM004.TRN_DTM);
		this.indexHjKjKrInfoMap.put(1, JBSbatKUIFM004.REC_SBT);
		this.indexHjKjKrInfoMap.put(2, JBSbatKUIFM004.HOJIN_YO_KOJI_UK_SBT_CD);
		this.indexHjKjKrInfoMap.put(3, JBSbatKUIFM004.MSKMSHO_NO);
		this.indexHjKjKrInfoMap.put(4, JBSbatKUIFM004.HOJIN_SVC_KEI_NO);
		this.indexHjKjKrInfoMap.put(5, JBSbatKUIFM004.KMK_1);
		this.indexHjKjKrInfoMap.put(6, JBSbatKUIFM004.KMK_2);
		this.indexHjKjKrInfoMap.put(7, JBSbatKUIFM004.KMK_3);
		this.indexHjKjKrInfoMap.put(8, JBSbatKUIFM004.KMK_4);
		this.indexHjKjKrInfoMap.put(9, JBSbatKUIFM004.KMK_5);
		this.indexHjKjKrInfoMap.put(10, JBSbatKUIFM004.KMK_6);
		this.indexHjKjKrInfoMap.put(11, JBSbatKUIFM004.KMK_7);
		this.indexHjKjKrInfoMap.put(12, JBSbatKUIFM004.KMK_8);
		this.indexHjKjKrInfoMap.put(13, JBSbatKUIFM004.KMK_9);
		this.indexHjKjKrInfoMap.put(14, JBSbatKUIFM004.KMK_10);

		return indexHjKjKrInfoMap;
	}
	
	/**
	 * 取得日付がALL9であった場合
	 * 日付項目初期値を返却する
	 * 
	 * @param itemValue
	 * @return strValue
	 */
	private String iniDateCast(String itemValue)
	{
		String strValue = itemValue;
		
		// ALL9の場合、NULLを設定
		if (JKUStrConst.OPMS_INIT_YMD.equals(strValue))
		{
			strValue = JKUStrConst.MAX_YMD;
		}
		
		return strValue;
	}
	/**▲▲▲▲▲▲業務チームで作成したメソッドです 終了▲▲▲▲▲▲*/

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

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

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