/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCHEoMbKsiDslZmChsht
*	ソースファイル名	：JBSbatCHEoMbKsiDslZmChsht.java
*	作成者				：富士通　
*	作成日				：2012年01月22日
*＜機能概要＞
*　ｅｏモバイル強制解約予告済者抽出部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2012/01/22   富士通		新規作成
*********************************************************************/
package eo.business.service;

import java.util.ArrayList;

import eo.business.common.JACbatDebugLogUtil;
import eo.business.common.JACbatParamUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCHbatSeikyKaknoBusinessUtil;
import eo.business.util.file.JBSbatCHIFE048;
import eo.business.util.file.JBSbatCHIFM101;
import eo.business.util.table.JBSbatCH_T_SEIKY_UCWK;
import eo.business.util.table.JBSbatKK_M_PCRS;
import eo.business.util.table.JBSbatKK_M_PRC_GRP;
import eo.business.util.table.JBSbatKK_T_SVC_KEI;
import eo.common.constant.JACStrConst;
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;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatCHEoMbKsiDslZmChsht extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(請求)*/
	private static final String D_TBL_NAME_CH_T_SEIKY = "CH_T_SEIKY";

	/** テーブル(サービス契約)*/
	private static final String D_TBL_NAME_KK_T_SVC_KEI = "KK_T_SVC_KEI";

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

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

	/** テーブルアクセスクラス(請求)*/
	private JBSbatSQLAccess db_CH_T_SEIKY = null;

	/** テーブルアクセスクラス(サービス契約)*/
	private JBSbatSQLAccess db_KK_T_SVC_KEI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** 退避．督促データ識別(強制解約予告情報データ)*/
	private String tihTokusokuDataSkbt = null;
	
	/** 退避．eoモバイル*/
	private String tihEoMobile = null;
	
	/** 退避．請求年月（当月）*/
	private String tihSikyYm = null;
	
	/** 出力ファイル桁数（30桁） */
	private static final int LENGTH_LIMIT_30 = 30;
	
	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_CH_T_SEIKY = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_T_SEIKY);
		db_KK_T_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][opeDate=" + super.opeDate + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][freeItem=" + super.freeItem + "]");
		
		// パラメータ取得部品の初期処理を行う。（パラメータ取得部品．コンストラクタ使用）
		JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);
		
		try
		{
			// 督促データ識別の取得（業パラ）
			this.tihTokusokuDataSkbt = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_CH_TKSK_DATA_SKBT_07);
			// 料金項目コード（eoモバイル）（シスパラ）

			this.tihEoMobile = paramUtil.getGyoumuParameter(JACStrConst.WKPRA_CH_WKS_EO_MOBILE);
		}
		finally
		{
			// パラメータ取得部品のクローズ処理を行う。（パラメータ取得部品．クローズ使用）
			paramUtil.close();
		}
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][tihTokusokuDataSkbt=" + this.tihTokusokuDataSkbt + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][tihEoMobile=" + this.tihEoMobile + "]");
		
		// 当月の取得
		getSikyYm();
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][tihSikyYm=" + this.tihSikyYm + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}
	
	/**
	 * 請求年月を取得します。
	 * 
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void getSikyYm() throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getSikyYm]");
		
		JCHbatSeikyKaknoBusinessUtil su = new JCHbatSeikyKaknoBusinessUtil(commonItem);
		try
		{
			// 請求年月取得
			this.tihSikyYm = su.getBillYmContain(super.opeDate, JACStrConst.EVENT_CD_RYOKIN_KEISAN_YMD);
		}
		finally
		{
			su.close();
		}
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getSikyYm]");
		return;
	}
	
	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
		assert inMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][inMap=" + inMap.getMap().toString() + "]") : true;
		
		JBSbatOutputItem outputItem = new JBSbatOutputItem();
		// 督促データ識別判定
		if(!tihTokusokuDataSkbt.equals(inMap.getString(JBSbatCHIFM101.TOKUSOKU_DATA_SKBT)))
		{
			
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力．督促データ識別 ≠ 初期処理．督促データ識別 の場合]");
			// 処理を終了し次のレコードを読み込む
			return outputItem;
		}
		
		// サービス契約番号の取得
		// 2. 未納債権の取得
		ArrayList<String> seikyInfoList = new ArrayList<String>();
		makeSeikyInfo(inMap, seikyInfoList);
		
		if(seikyInfoList.isEmpty())
		{
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][請求スキーマおよび関連スキーマ 該当データなしの場合]");
			// 処理を終了し次のレコードを読み込む
			return outputItem;
		}
		// サービス契約情報の取得
		for(int i = 0; i < seikyInfoList.size() ; i++)
		{
			String svcKeiNo = seikyInfoList.get(i);
			ArrayList<JBSbatCommonDBInterface> svcKeiInfoList = new ArrayList<JBSbatCommonDBInterface>();
			makeSvcKeiInfo(svcKeiNo, svcKeiInfoList);
			if(svcKeiInfoList.isEmpty())
			{
				assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][請求スキーマおよび関連スキーマ 該当データなしの場合]");
				// ＤＢ取得項目を空で出力します。
				
				makeOutputInfo(outputItem, inMap, svcKeiNo, null);
				return outputItem;
			}
			for(int j = 0; j < svcKeiInfoList.size() ; j++)
			{
				// 強制解約予告済リスト作成
				JBSbatCommonDBInterface dbSvcKeiMap = svcKeiInfoList.get(j);
				makeOutputInfo(outputItem, inMap, svcKeiNo, dbSvcKeiMap);
			}
		}
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
		return outputItem;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 請求情報を取得して、リストを作成にします。
	 * 
	 * @param inMap　入力電文
	 * @param list　取得用の空リスト
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void makeSeikyInfo(JBSbatServiceInterfaceMap inMap, ArrayList<String> list) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeSeikyInfo]");
		
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		
		paramList.setValue(super.systemCode);								// システムコード（"CH"（請求収納））
		paramList.setValue(this.tihEoMobile);								// 業務機能識別コード（初期処理．eoモバイル）
		paramList.setValue(JACStrConst.CHSHT_CHG_CD_CST);					// 抽出変換コード（"1"（抽出のみ））
		paramList.setValue(super.opeDate);									// 料金項目抽出変換適用開始年月日（バッチ運用日）
		paramList.setValue(super.opeDate);									// 料金項目抽出変換適用終了年月日（バッチ運用日）
		paramList.setValue(super.opeDate);									// 予約適用年月日（バッチ運用日）
		paramList.setValue(inMap.getString(JBSbatCHIFM101.SEIKY_KEI_NO));	// 請求契約番号（督促対象情報．請求契約番号）
		paramList.setValue(this.tihSikyYm);									// 請求年月（初期処理．当月）
		paramList.setValue(this.tihSikyYm);									// 請求年月（初期処理．当月）（請求内訳．請求年月用）
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makeSeikyInfo][paramList=" + paramList.getList().toString() + "]");
		
		// SQL実行
		executeCH_T_SEIKY_CH_SELECT_031(paramList.getList().toArray());
		
		JBSbatCommonDBInterface dbMap = db_CH_T_SEIKY.selectNext();
		
		// 取得出来た場合のみ
		if(dbMap != null)
		{	
			while(dbMap != null)
			{
				list.add(dbMap.getString(JBSbatCH_T_SEIKY_UCWK.SVC_KEI_NO));
				dbMap = db_CH_T_SEIKY.selectNext();
			}
		}
		assert list != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeSeikyInfo][list=" + list.toString() + "]") : true;
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeSeikyInfo]");
		return;
	}
	

	/**
	 * サービス契約を取得して、リストを作成にします。
	 * 
	 * @param svcKeiNo　サービス契約番号
	 * @param list　取得用の空リスト
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void makeSvcKeiInfo(String svcKeiNo, ArrayList<JBSbatCommonDBInterface> list) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeSvcKeiInfo]");
		
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		
		paramList.setValue(svcKeiNo);				// サービス契約．サービス契約番号（請求内訳．サービス契約番号）
		paramList.setValue(super.opeDate);			// サービス契約．予約適用年月日（バッチ運用日）
		paramList.setValue(super.opeDate);			// 料金グループ．予約適用開始年月日（バッチ運用日）
		paramList.setValue(super.opeDate);			// 料金グループ．料金グループ適用開始年月日（バッチ運用日）
		paramList.setValue(super.opeDate);			// 料金グループ．料金グループ適用終了年月日（バッチ運用日）
		paramList.setValue(super.opeDate);			// 料金プラン．料金プラン適用開始年月日（バッチ運用日）
		paramList.setValue(super.opeDate);			// 料金コース．予約適用開始年月日（バッチ運用日）
		paramList.setValue(super.opeDate);			// 料金コース．料金コース適用開始年月日（バッチ運用日）
		paramList.setValue(super.opeDate);			// 料金コース．料金コース適用終了年月日（バッチ運用日）
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makeSvcKeiInfo][paramList=" + paramList.getList().toString() + "]");
		
		// SQL実行
		executeKK_T_SVC_KEI_CH_SELECT_003(paramList.getList().toArray());
		
		JBSbatCommonDBInterface dbMap = db_KK_T_SVC_KEI.selectNext();
		
		// 取得出来た場合のみ
		if(dbMap != null)
		{	
			while(dbMap != null)
			{
				list.add(dbMap);
				dbMap = db_KK_T_SVC_KEI.selectNext();
			}
		}
		assert list != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeSvcKeiInfo][list=" + list.toString() + "]") : true;
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeSvcKeiInfo]");
		return;
	}
	
	/**
	 * 債権切り離し対象情報作成を作成します
	 * @param outputInItem　出力情報
	 * @param inMap　入力電文
	 * @param svcKeiNo　請求内訳．サービス契約番号
	 * @param dbSeikyMap　サービス契約DB情報
	 * @throws Exception
	 */
	private void makeOutputInfo(JBSbatOutputItem outputInItem, JBSbatServiceInterfaceMap inMap, String svcKeiNo, JBSbatCommonDBInterface dbSeikyMap) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeOutputInfo]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeOutputInfo][inMap=" + inMap.getMap().toString() + "]");
		
		JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();

		// 契約サービス
		String svcCd = JACStrConst.KARA_MOJI;
		// サービス名称
		String svcNm = JACStrConst.KARA_MOJI;
		// 料金プラン
		String pplanCd = JACStrConst.KARA_MOJI;
		// プラン名称
		String pplanNm = JACStrConst.KARA_MOJI;

		// サービス契約DB情報に値が設定されている場合
		if(null != dbSeikyMap)
		{
			svcCd = dbSeikyMap.getString(JBSbatKK_T_SVC_KEI.PRC_GRP_CD);
			svcNm = getFormatString(dbSeikyMap.getString(JBSbatKK_M_PRC_GRP.PRC_GRP_NM));
			pplanCd = dbSeikyMap.getString(JBSbatKK_T_SVC_KEI.PCRS_CD);
			pplanNm = getFormatString(dbSeikyMap.getString(JBSbatKK_M_PCRS.PCRS_NM));
		}
		
		// 契約サービス
		outMap.set(JBSbatCHIFE048.SVC_CD, 		svcCd);
		// サービス名称
		outMap.set(JBSbatCHIFE048.SVC_NM, 		svcNm);
		// 料金プラン
		outMap.set(JBSbatCHIFE048.PPLAN_CD, 	pplanCd);
		// プラン名称
		outMap.set(JBSbatCHIFE048.PPLAN_NM, 	pplanNm);
		// 請求契約番号
		outMap.set(JBSbatCHIFE048.SEIKY_KEI_NO, inMap.get(JBSbatCHIFM101.SEIKY_KEI_NO));
		// サービス契約番号
		outMap.set(JBSbatCHIFE048.SVC_KEI_NO, 	svcKeiNo);
		
		// 出力内容を項目ごとにダブルクォーテーション（""）で囲む
		outMap.setMap(JCHbatSeikyKaknoBusinessUtil.quote(outMap.getMap(), JACStrConst.DOUBLE_QUOTE, JACStrConst.DOUBLE_QUOTE));
		
		// 出力フラグ設定
		outMap.setOutFlg(true);
		
		// 出力処理
		outputInItem.addOutMapList(outMap);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makeOutputInfo][outputItem = " + outMap.getMap().toString() + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeOutputInfo]");
	}
	
	/**
	 * 桁数のチェックを行い、オーバしてる場合は指定の桁数にあわせて返却を行います。
	 * @param str　文字列
	 * @return 変換後文字列
	 * @throws Exception
	 */
	private String getFormatString(String str)throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getFormatString]");
		
		if(str != null && str.length() > LENGTH_LIMIT_30)
		{
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getFormatString]");
			return str.substring(0, LENGTH_LIMIT_30);
		}
		else
		{
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getFormatString]");
			return str;
		}
		
	}
	
	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_CH_T_SEIKY.close();
		db_KK_T_SVC_KEI.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	
	/**
	 * SQLKEY(CH_SELECT_031)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	システムコード
	 *		 	業務機能識別コード
	 *		 	抽出変換コード
	 *		 	料金項目抽出変換適用開始年月日
	 *		 	料金項目抽出変換適用終了年月日
	 *		 	予約適用年月日
	 *		 	請求契約番号
	 *		 	請求年月
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCH_T_SEIKY_CH_SELECT_031(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());
		paramList.setValue(param[3].toString());
		paramList.setValue(param[4].toString());
		paramList.setValue(param[5].toString());
		paramList.setValue(param[6].toString());
		paramList.setValue(param[7].toString());
		paramList.setValue(param[8].toString());

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

	/**
	 * SQLKEY(CH_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 executeKK_T_SVC_KEI_CH_SELECT_003(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());
		paramList.setValue(param[3].toString());
		paramList.setValue(param[4].toString());
		paramList.setValue(param[5].toString());
		paramList.setValue(param[6].toString());
		paramList.setValue(param[7].toString());

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