/*********************************************************************
*  All Rights reserved,Copyright (c) Fujitsu ,2011					 *
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatACPrcEntaiMobaIfOut
*	ソースファイル名	：JBSbatACPrcEntaiMobaIfOut.java
*	作成者				：富士通　
*	作成日				：2011年06月23日
*＜機能概要＞
*　料金延滞顧客モバイル情報出力部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/06/23   富士通		新規作成
*********************************************************************/
package eo.business.service;

import java.util.ArrayList;

import eo.business.common.JACbatParamUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.util.file.JBSbatACIFM068;
import eo.business.util.file.JBSbatACIFM069;
import eo.business.util.file.JBSbatACIFM070;
import eo.business.util.table.JBSbatAC_T_EOMOBA_DTL;
import eo.business.util.table.JBSbatAC_T_EOMOBA_GOKEI;
import eo.business.util.table.JBSbatCH_T_TOKUSOKU;
import eo.common.constant.JACStrConst;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatDefFileUtil;
import eo.framework.file.JBSbatOutputFileUtil;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.util.JBSbatAplConst;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatACPrcEntaiMobaIfOut extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(システムパラメータ管理)*/
	private static final String D_TBL_NAME_ZM_M_SYS_PARAM_KNRI = "ZM_M_SYS_PARAM_KNRI";

	/** テーブル(ｅｏモバイル明細)*/
	private static final String D_TBL_NAME_AC_T_EOMOBA_DTL = "AC_T_EOMOBA_DTL";

	/** テーブル(ｅｏモバイル合計)*/
	private static final String D_TBL_NAME_AC_T_EOMOBA_GOKEI = "AC_T_EOMOBA_GOKEI";

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

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

	/** テーブルアクセスクラス(システムパラメータ管理)*/
	private JBSbatSQLAccess db_ZM_M_SYS_PARAM_KNRI = null;

	/** テーブルアクセスクラス(ｅｏモバイル明細)*/
	private JBSbatSQLAccess db_AC_T_EOMOBA_DTL = null;

	/** テーブルアクセスクラス(ｅｏモバイル合計)*/
	private JBSbatSQLAccess db_AC_T_EOMOBA_GOKEI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** 料金延滞対象年月 */
	private String prcEntaiTgYm = "";

	/** 下線記号 */
	private static final String UNDERBAR = "_";

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

		// DBアクセスクラスを生成します
		db_ZM_M_SYS_PARAM_KNRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_SYS_PARAM_KNRI);
		db_AC_T_EOMOBA_DTL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_AC_T_EOMOBA_DTL);
		db_AC_T_EOMOBA_GOKEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_AC_T_EOMOBA_GOKEI);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/

		// ▼ 料金延滞対象年月ファイルを生成する
		String[] free = super.freeItem.split(JACStrConst.FREE_DIV);

		// 出力ファイルオブジェクトを生成する
		JBSbatOutputFileUtil outFileObj = new JBSbatOutputFileUtil(free[1]);

		// 出力定義ファイル名を取得する
		String outFileDefName = JBSbatAplConst.getAplConstValue("OTD") + free[0];

		// 出力定義ファイルオブジェクトを生成する
		JBSbatDefFileUtil outFileDef = new JBSbatDefFileUtil(outFileDefName, outFileObj);

		// Writerオブジェクトを生成する。
		outFileObj.createWriter();
		
		JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);

		// ▼ システムパラメータより延滞対象期間を取得する
		String entaiTgPrd = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_AC_ARP_ENTAI_CST_MBL);
		
		paramUtil.close();

		// ▼ 料金延滞対象年月を算出する
		prcEntaiTgYm = JCCBatCommon.addMonth(super.opeDate, Integer.parseInt(entaiTgPrd) * -1).substring(0, 6);

		// 料金延滞対象年月の出力
		JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();
		outMap.set(JBSbatACIFM070.TG_YM, prcEntaiTgYm);
		outMap.set(JBSbatACIFM070.KASEN, UNDERBAR);
		outMap.set(JBSbatACIFM070.TRN_DTM, JCCBatCommon.getSysDateTime());
		outMap.setOutFlg(true);

		outFileObj.print(outMap, outFileDef);
		outFileObj.close();
		/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// 請求契約番号
		String seikyKeiNo = inMap.getString(JBSbatCH_T_TOKUSOKU.SEIKY_KEI_NO);

		// 出力共通電文オブジェクト生成
		JBSbatOutputItem outputBean = new JBSbatOutputItem();

		// ｅｏモバイル明細の取得
		ArrayList<JBSbatServiceInterfaceMap> outMapDtl = getPrcEntaiCustDtl(seikyKeiNo);
		for (JBSbatServiceInterfaceMap outMap : outMapDtl)
		{
			// 料金延滞顧客明細データの出力
			outputBean.addOutMapList(outMap);
		}

		// ｅｏモバイル合計の取得
		ArrayList<JBSbatServiceInterfaceMap> outMapGokei = getPrcEntaiCustGokei(seikyKeiNo);
		for (JBSbatServiceInterfaceMap outMap : outMapGokei)
		{
			// 料金延滞顧客合計データの出力
			outputBean.addOutMapList_2(outMap);
		}

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/

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

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

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

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

	/**
	 * 請求契約番号を元にｅｏモバイル明細データを取得し、出力電文Mapを生成する
	 * @param seikyKeiNo	請求契約番号
	 * @return	出力電文Map
	 * @throws Exception
	 */
	private ArrayList<JBSbatServiceInterfaceMap> getPrcEntaiCustDtl(String seikyKeiNo) throws Exception
	{
		ArrayList<JBSbatServiceInterfaceMap> retList = new ArrayList<JBSbatServiceInterfaceMap>();

		// ｅｏモバイル明細の取得
		executeAC_T_EOMOBA_DTL_AC_SELECT_005(new Object[] {seikyKeiNo, prcEntaiTgYm});
		JBSbatCommonDBInterface record = db_AC_T_EOMOBA_DTL.selectNext();
		while (record != null)
		{
			// 出力電文の生成
			JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();

			// サービス契約番号
			outMap.set(JBSbatACIFM068.SVC_KEI_NO, record.getValue(JBSbatAC_T_EOMOBA_DTL.SVC_KEI_NO));

			// 料金コースコード
			outMap.set(JBSbatACIFM068.PCRS_CD, record.getValue(JBSbatAC_T_EOMOBA_DTL.PCRS_CD));

			// 請求契約番号
			outMap.set(JBSbatACIFM068.SEIKY_KEI_NO, record.getValue(JBSbatAC_T_EOMOBA_DTL.SEIKY_KEI_NO));

			// 請求年月
			outMap.set(JBSbatACIFM068.SEIKY_YM, record.getValue(JBSbatAC_T_EOMOBA_DTL.SEIKY_YM));

			// 事業者用契約ID
			outMap.set(JBSbatACIFM068.JIGYOSHA_KEI_ID, record.getValue(JBSbatAC_T_EOMOBA_DTL.JIGYOSHA_KEI_ID));

			// 利用年月
			outMap.set(JBSbatACIFM068.USE_YM, record.getValue(JBSbatAC_T_EOMOBA_DTL.USE_YM));

			// 通信開始年月日時分秒
			outMap.set(JBSbatACIFM068.TSUSHIN_STA_DTM, record.getValue(JBSbatAC_T_EOMOBA_DTL.TSUSHIN_STA_DTM));

			// 通信終了年月日時分秒
			outMap.set(JBSbatACIFM068.TSUSHIN_END_DTM, record.getValue(JBSbatAC_T_EOMOBA_DTL.TSUSHIN_END_DTM));

			// 利用バイト数
			outMap.set(JBSbatACIFM068.USE_BYTE_CNT, record.getValue(JBSbatAC_T_EOMOBA_DTL.USE_BYTE_CNT));

			// 利用パケット数
			outMap.set(JBSbatACIFM068.USE_PCT_CNT, record.getValue(JBSbatAC_T_EOMOBA_DTL.USE_PCT_CNT));

			// 料金項目コード
			outMap.set(JBSbatACIFM068.PRC_KMK_CD, record.getValue(JBSbatAC_T_EOMOBA_DTL.PRC_KMK_CD));

			// 登録年月日時分秒
			outMap.set(JBSbatACIFM068.ADD_DTM, record.getValue(JBSbatAC_T_EOMOBA_DTL.ADD_DTM));

			// 登録オペレータアカウント
			outMap.set(JBSbatACIFM068.ADD_OPEACNT, record.getValue(JBSbatAC_T_EOMOBA_DTL.ADD_OPEACNT));

			// 更新年月日時分秒
			outMap.set(JBSbatACIFM068.UPD_DTM, record.getValue(JBSbatAC_T_EOMOBA_DTL.UPD_DTM));

			// 更新オペレータアカウント
			outMap.set(JBSbatACIFM068.UPD_OPEACNT, record.getValue(JBSbatAC_T_EOMOBA_DTL.UPD_OPEACNT));

			// 削除年月日時分秒
			outMap.set(JBSbatACIFM068.DEL_DTM, record.getValue(JBSbatAC_T_EOMOBA_DTL.DEL_DTM));

			// 削除オペレータアカウント
			outMap.set(JBSbatACIFM068.DEL_OPEACNT, record.getValue(JBSbatAC_T_EOMOBA_DTL.DEL_OPEACNT));

			// 無効フラグ
			outMap.set(JBSbatACIFM068.MK_FLG, record.getValue(JBSbatAC_T_EOMOBA_DTL.MK_FLG));

			// 出力フラグ
			outMap.setOutFlg(true);

			// 明細出力用リストに追加
			retList.add(outMap);

			record = db_AC_T_EOMOBA_DTL.selectNext();
		}
		return retList;
	}
	
	/**
	 * 請求契約番号を元にｅｏモバイル合計データを取得し、出力電文Mapを生成する
	 * @param seikyKeiNo	請求契約番号
	 * @return	出力電文Map
	 * @throws Exception
	 */
	private ArrayList<JBSbatServiceInterfaceMap> getPrcEntaiCustGokei(String seikyKeiNo) throws Exception
	{
		ArrayList<JBSbatServiceInterfaceMap> retList = new ArrayList<JBSbatServiceInterfaceMap>();

		// ｅｏモバイル合計の取得
		executeAC_T_EOMOBA_GOKEI_AC_SELECT_003(new Object[] {seikyKeiNo, prcEntaiTgYm});
		JBSbatCommonDBInterface record = db_AC_T_EOMOBA_GOKEI.selectNext();
		while (record != null)
		{
			// 出力電文の生成
			JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();

			// サービス契約番号
			outMap.set(JBSbatACIFM069.SVC_KEI_NO, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.SVC_KEI_NO));

			// 料金コースコード
			outMap.set(JBSbatACIFM069.PCRS_CD, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.PCRS_CD));

			// 請求年月
			outMap.set(JBSbatACIFM069.SEIKY_YM, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.SEIKY_YM));

			// 事業者用契約ＩＤ
			outMap.set(JBSbatACIFM069.JIGYOSHA_KEI_ID, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.JIGYOSHA_KEI_ID));

			// 請求契約番号
			outMap.set(JBSbatACIFM069.SEIKY_KEI_NO, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.SEIKY_KEI_NO));

			// 利用年月
			outMap.set(JBSbatACIFM069.USE_YM, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.USE_YM));

			// 利用バイト数合計
			outMap.set(JBSbatACIFM069.USE_BYTE_CNT_GOKEI, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.USE_BYTE_CNT_GOKEI));

			// 利用パケット数合計
			outMap.set(JBSbatACIFM069.USE_PCT_CNT_GOKEI, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.USE_PCT_CNT_GOKEI));

			// 料金項目コード
			outMap.set(JBSbatACIFM069.PRC_KMK_CD, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.PRC_KMK_CD));

			// 登録年月日時分秒
			outMap.set(JBSbatACIFM069.ADD_DTM, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.ADD_DTM));

			// 登録オペレータアカウント
			outMap.set(JBSbatACIFM069.ADD_OPEACNT, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.ADD_OPEACNT));

			// 更新年月日時分秒
			outMap.set(JBSbatACIFM069.UPD_DTM, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.UPD_DTM));

			// 更新オペレータアカウント
			outMap.set(JBSbatACIFM069.UPD_OPEACNT, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.UPD_OPEACNT));

			// 削除年月日時分秒
			outMap.set(JBSbatACIFM069.DEL_DTM, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.DEL_DTM));

			// 削除オペレータアカウント
			outMap.set(JBSbatACIFM069.DEL_OPEACNT, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.DEL_OPEACNT));

			// 無効フラグ
			outMap.set(JBSbatACIFM069.MK_FLG, record.getValue(JBSbatAC_T_EOMOBA_GOKEI.MK_FLG));

			// 出力フラグ
			outMap.setOutFlg(true);

			// 合計出力用リストに追加
			retList.add(outMap);

			record = db_AC_T_EOMOBA_GOKEI.selectNext();
		}
		return retList;
	}
}