/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKNttorsStaTgDataCst
*	ソースファイル名	：JBSbatKKNttorsStaTgDataCst.java
*	作成者				：富士通
*	作成日				：2024年09月05日
*＜機能概要＞
*	NTT卸開始対象データ抽出部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*   v73.00.01   2024/09/05  GDC)ml.alcantara   ANK-4427-00-00_【NTT卸対応】
*********************************************************************/
package eo.business.service;

import eo.business.common.JACbatDebugLogUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.util.file.JBSbatKKIFM965;
import eo.business.util.table.JBSbatKK_T_WAO_RNKI_IF;
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;

/**
* NTT卸開始対象データ抽出 <p>
*<BR>
* @author 富士通
*/
public class JBSbatKKNttorsStaTgDataCst extends JBSbatBusinessService
{
	/** テーブル(WAO連携情報)*/
	private static final String D_TBL_NAME_KK_T_WAO_RNKI_IF = "KK_T_WAO_RNKI_IF";
	/** テーブルアクセスクラス(WAO連携情報)*/
	private JBSbatSQLAccess db_KK_T_WAO_RNKI_IF = null;
	/** SQL定義キー(KK_SELECT_001)*/
	private static final String KK_T_WAO_RNKI_IF_KK_SELECT_001 = "KK_SELECT_001";
	
	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);
		
		// DBアクセスクラスを生成します
		db_KK_T_WAO_RNKI_IF = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_WAO_RNKI_IF);
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}
	
	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		assert 	JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
		JBSbatOutputItem outputBean = new JBSbatOutputItem();
		// バッチ運用日付の取得
		String opeDate = super.opeDate;
		
		// WAO連携情報テーブルから未抽出のWAO連携情報を取得し
		JBSbatCommonDBInterface resultMap = executeKK_T_WAO_RNKI_IF_KK_SELECT_001(new String[]{ opeDate });
		while(resultMap != null)
		{
			JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();
			// サービス契約番号
			outMap.set(JBSbatKKIFM965.SVC_KEI_NO, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.SVC_KEI_NO));
			// CAF番号
			outMap.set(JBSbatKKIFM965.CAF_NO, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.CAF_NO));
			// WAO連携識別コード
			outMap.set(JBSbatKKIFM965.WAO_RNKI_SKBT_CD, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.WAO_RNKI_SKBT_CD));
			// 宅内工事完了予定年月日
			outMap.set(JBSbatKKIFM965.TAKNI_KOJI_FIN_RSV_YMD, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.TAKNI_KOJI_FIN_RSV_YMD));
			// 工事案件実施年月日
			outMap.set(JBSbatKKIFM965.KOJIAK_JSSI_YMD, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.KOJIAK_JSSI_YMD));
			// 派遣有無
			outMap.set(JBSbatKKIFM965.HAKEN_UM, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.HAKEN_UM));
			// 契約電話番号
			outMap.set(JBSbatKKIFM965.KEI_TELNO, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.KEI_TELNO));
			// 送付先郵便番号
			outMap.set(JBSbatKKIFM965.SOHUS_PCD, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.SOHUS_PCD));
			// WAO送付先住所
			outMap.set(JBSbatKKIFM965.WAO_SOHUS_AD, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.WAO_SOHUS_AD));
			// WAO送付先氏名
			outMap.set(JBSbatKKIFM965.WAO_SOHUS_NM, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.WAO_SOHUS_NM));
			// ご利用サービス
			outMap.set(JBSbatKKIFM965.USE_SVC, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.USE_SVC));
			// WAO申込
			outMap.set(JBSbatKKIFM965.WAO_MSKM, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.WAO_MSKM));
			// WAO光電話
			outMap.set(JBSbatKKIFM965.WAO_HIKARI_TEL, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.WAO_HIKARI_TEL));
			// WAO光電話パック
			outMap.set(JBSbatKKIFM965.WAO_HIKARI_TEL_PACK, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.WAO_HIKARI_TEL_PACK));
			// 申込内容(テレビ)
			outMap.set(JBSbatKKIFM965.MSKM_NAIYO_TV, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.MSKM_NAIYO_TV));
			// WAO設置先住所1
			outMap.set(JBSbatKKIFM965.WAO_STC_SAKI_AD_1, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.WAO_STC_SAKI_AD_1));
			// WAO設置先住所2
			outMap.set(JBSbatKKIFM965.WAO_STC_SAKI_AD_2, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.WAO_STC_SAKI_AD_2));
			// レンタルHGW
			outMap.set(JBSbatKKIFM965.RENT_HGW, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.RENT_HGW));
			// 無線LANカード
			outMap.set(JBSbatKKIFM965.MLAN_CARD, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.MLAN_CARD));
			// 異動情報_設置場所住所
			outMap.set(JBSbatKKIFM965.IDO_IF_SETPLACE_AD, resultMap.getString(JBSbatKK_T_WAO_RNKI_IF.IDO_IF_SETPLACE_AD));
			
			outMap.setOutFlg(true);
			
			outputBean.addOutMapList(outMap);
			resultMap = db_KK_T_WAO_RNKI_IF.selectNext();
		}
		assert 	JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
		return outputBean;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}
	
	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		assert 	JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
		// DBクローズ処理
		db_KK_T_WAO_RNKI_IF.close();
		assert 	JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}
	
	/**
	 * SQLKEY(KK_SELECT_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	日中バッチ運用年月日
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatCommonDBInterface executeKK_T_WAO_RNKI_IF_KK_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		
		// DBアクセスを実行します
		db_KK_T_WAO_RNKI_IF.selectBySqlDefine(paramList, KK_T_WAO_RNKI_IF_KK_SELECT_001);
		
		return db_KK_T_WAO_RNKI_IF.selectNext();
	}
}