/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCHMaeukkinSosaiInfoHuka
*	ソースファイル名	：JBSbatCHMaeukkinSosaiInfoHuka.java
*	作成者				：富士通　
*	作成日				：2011年08月16日
*＜機能概要＞
*　前受金相殺情報付加部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/08/16   富士通		新規作成
*	v4.00.00	2013/05/07   FJ)早崎	【TG1-2013-0000248】対応
*	v5.00.00	2013/07/13   FJ)早崎	【LT-2013-0000451】前受金相殺結果情報のみ対応
*	v5.01.00	2013/10/07   FJ)間		【OM-2013-0001983】前受金相殺結果情報のみ存在する場合、例外を投げないよう修正
*********************************************************************/
package eo.business.service;

import java.util.HashSet;

import eo.business.common.JACbatDebugLogUtil;
import eo.business.common.JACbatParamUtil;
import eo.business.common.JBSbatBusinessService;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;
import eo.business.common.JBSbatMatchServiceInterface;
import eo.business.util.file.JBSbatCHIFI007;
import eo.business.util.file.JBSbatCHIFM070;
import eo.business.util.table.JBSbatCH_M_PRC_KMK_CS_CHGE;
import eo.common.constant.JPCBatchMessageConstant;
import eo.common.constant.JACStrConst;

/**
* 前受金相殺情報付加 <p>
*<BR>
* @author 富士通
*/
public class JBSbatCHMaeukkinSosaiInfoHuka extends JBSbatBusinessService implements JBSbatMatchServiceInterface
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	
	/** テーブル(料金項目抽出変換)*/
	private static final String D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE = "CH_M_PRC_KMK_CS_CHGE";

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

	/** テーブルアクセスクラス(料金項目抽出変換)*/
	private JBSbatSQLAccess db_CH_M_PRC_KMK_CS_CHGE = null;

	/** キーマッチ処理フラグ*/
	private boolean matchProcFlg;

	/** マスタファイル処理フラグ*/
	private boolean mastProcFlg;

	/** トランファイル処理フラグ*/
	private boolean tranProcFlg;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** 前受金相殺フラグ */
	private boolean maeukkinSosaiFlg;

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

		// DBアクセスクラスを生成します
		db_CH_M_PRC_KMK_CS_CHGE = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		
		// 前受金相殺フラグ ← false
		this.maeukkinSosaiFlg = false;
		
		// パラメータ取得共通クラス
		JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);
		
		// 業務機能識別コード取得
		
		// 前受金相殺（相殺済額）
		String sosaiZumi = paramUtil.getGyoumuParameter(JACStrConst.WKPRA_CH_WKS_MUK_SSI_ZUMI);
		
		// パラメータ取得共通クラス クローズ
		paramUtil.close();

		// 相殺済額情報取得
		selectPrcKmkCdChsht(sosaiZumi, JACStrConst.CHSHT_CHG_CD_CST);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][opeDate=" + super.opeDate + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param mastMap　入力電文(当月請求データ（合算請求情報付加）)
	 * @param tranMap　入力電文(前受金相殺結果情報)
	 * @param outputInItem  入力情報
	 * @return JBSbatOutputItem 出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap mastMap, JBSbatServiceInterfaceMap tranMap, JBSbatOutputItem outputInItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
		assert mastMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][mastMap=" + mastMap.getMap().toString() + "]") : true;
		assert tranMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][tranMap=" + tranMap.getMap().toString() + "]") : true;

		// 当月請求データ（合算請求情報付加）のみ存在する
		if (mastMap != null && tranMap == null)
		{
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍのみ存在する]");
			if(!maeukkinSosaiFlg)
			{
				// 前受金相殺なしと判定し、当月請求データ（前受金相殺情報付加）出力
				outputSeikyInfo(mastMap, JACStrConst.MAEUKKIN_SOSAI_UM_FLG_NASHI, outputInItem);
			}
			this.maeukkinSosaiFlg = false;
			
			// 次の当月請求データ（合算請求情報付加）読み込み
			this.setMastProcFlg(true);
		}
		
		// 前受金相殺結果情報のみ存在する
		else if (mastMap == null && tranMap != null)
		{
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｔのみ存在する]");
			
			// 次の前受金相殺結果情報読み込み
			this.setTranProcFlg(true);
		}
		
		// 当月請求データ（合算請求情報付加）、前受金相殺結果情報ともに存在する
		else
		{
			// マッチングキー（請求契約番号）取得
			String mastSeiKeiNo = mastMap.getString(JBSbatCHIFM070.SEIKY_KEI_NO);
			String tranSeiKeiNo = tranMap.getString(JBSbatCHIFI007.SEIKY_KEI_NO);

			// マッチ
			int retCompare = mastSeiKeiNo.compareTo(tranSeiKeiNo);
			if (retCompare == 0)
			{
				assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍ、入力Ｔともに存在する][入力Ｍ＝入力Ｔ（マッチ）]");

				if(!maeukkinSosaiFlg)
				{
					// 前受金相殺情報チェックし、当月請求データ（前受金相殺情報付加）出力
					if (isSosaiInfoExist(tranMap))
					{
						// 前受金相殺有り
						outputSeikyInfo(mastMap, JACStrConst.MAEUKKIN_SOSAI_UM_FLG_ARI, outputInItem);
						this.maeukkinSosaiFlg = true;
					}
				}

				// 次の前受金相殺結果情報読み込み
				this.setTranProcFlg(true);
			}
			
			// 入力Ｍ＜入力Ｔ
			else if (retCompare < 0)
			{
				assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍ、入力Ｔともに存在する][入力Ｍ＜入力Ｔ]");

				if(!maeukkinSosaiFlg)
				{
					// 前受金相殺なしと判定し、当月請求データ（前受金相殺情報付加）出力
					outputSeikyInfo(mastMap, JACStrConst.MAEUKKIN_SOSAI_UM_FLG_NASHI, outputInItem);
				}
				this.maeukkinSosaiFlg = false;
				
				// 次の当月請求データ（合算請求情報付加）読み込み
				this.setMastProcFlg(true);
			}
			
			// 入力Ｍ＞入力Ｔ
			else
			{
				assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][入力Ｍ、入力Ｔともに存在する][入力Ｍ＞入力Ｔ]");
				
				// 次の前受金相殺結果情報読み込み
				this.setTranProcFlg(true);
			}
		}
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
		return outputInItem;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 当月請求データ（前受金相殺情報付加）を出力共通電文に出力する
	 * @param mastMap 入力電文(当月請求データ（合算請求情報付加）)
	 * @param sosaiFlg 前受金相殺有無フラグ
	 * @param outputInItem 出力共通電文
	 * @throws Exception
	 */
	private void outputSeikyInfo(JBSbatServiceInterfaceMap mastMap,
									String sosaiFlg,
									JBSbatOutputItem outputInItem) throws Exception
	{
		// 当月請求データ（合算請求情報付加）を全項目コピー
		JBSbatServiceInterfaceMap retMap = new JBSbatServiceInterfaceMap();
		retMap.setMap(mastMap.getMap());

		//  前受金相殺有無フラグを設定
		retMap.set(JBSbatCHIFM070.MAEUKKIN_SOSAI_UMU_FLG, sosaiFlg);

		// 出力フラグを設定(ファイル出力する)
		retMap.setOutFlg(true);

		// 出力共通電文に入出力インターフェースを設定する
		outputInItem.addOutMapList(retMap);
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][outputSeikyInfo]");
	}
	
	/**
	 * 相殺済情報存在チェック処理
	 * @param tranMap 前受金相殺結果情報
	 * @return 判定結果(true:前受金相殺有り、false:前受金相殺なし)
	 * @throws Exception
	 */
	private boolean isSosaiInfoExist(JBSbatServiceInterfaceMap tranMap) throws Exception
	{
		
		// トラン情報キー
		String searchKey = this.makeStr(tranMap.getString(JBSbatCHIFI007.PRC_GRP_CD), tranMap.getString(JBSbatCHIFI007.PCRS_CD), tranMap.getString(JBSbatCHIFI007.PRC_SVC_CD), tranMap.getString(JBSbatCHIFI007.PRC_KMK_CD));
		
		if (this.sosaiZumiSet.contains(searchKey))
		{
			// 前受金相殺あり
			return true;
		}
		else
		{
			// 前受金相殺なし
			return false;
		}
	}
	
	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_CH_M_PRC_KMK_CS_CHGE.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * @return mastProcFlg を戻します。
	 */
	public boolean isMastProcFlg()
	{
		return mastProcFlg;
	}

	/**
	 * @return matchProcFlg を戻します。
	 */
	public boolean isMatchProcFlg()
	{
		return matchProcFlg;
	}

	/**
	 * @return tranProcFlg を戻します。
	 */
	public boolean isTranProcFlg()
	{
		return tranProcFlg;
	}

	/**
	 * @param mast_ProcFlg 設定する mastProcFlg。
	 */
	public void setMastProcFlg(boolean mast_ProcFlg)
	{
		this.mastProcFlg = mast_ProcFlg;
	}

	/**
	 * @param match_ProcFlg 設定する matchProcFlg。
	 */
	public void setMatchProcFlg(boolean match_ProcFlg)
	{
		this.matchProcFlg = match_ProcFlg;
	}

	/**
	 * @param tran_ProcFlg 設定する tranProcFlg。
	 */
	public void setTranProcFlg(boolean tran_ProcFlg)
	{
		this.tranProcFlg = tran_ProcFlg;
	}

	
	/**
	 * SQLKEY(CH_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 executeCH_M_PRC_KMK_CS_CHGE_CH_SELECT_005(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());

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

	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	
	/**
	 * 料金項目抽出変換検索結果を返します。
	 * @param workKinoSkbtCd   業務機能識別コード
	 * @param chshChgCd        抽出変換コード
	 * @return prcKmkCsChgeMap 料金項目抽出変換検索結果MAP
	 * @throws Exception       業務サービス内で発生した例外全般
	 */
	private void selectPrcKmkCdChsht(String workKinoSkbtCd, String chshChgCd) throws Exception
	{
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][selectPrcKmkCdChsht]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][selectPrcKmkCdChsht][workKinoSkbtCd=" + workKinoSkbtCd + "]");
		
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		
		// 料金項目抽出変換．システムコード
		paramList.setValue(super.systemCode);
		
		// 料金項目抽出変換．業務機能識別コード
		paramList.setValue(workKinoSkbtCd);
		
		// 料金項目抽出変換．抽出変換コード
		paramList.setValue(chshChgCd);
		
		// 料金項目抽出変換．適用開始年月日
		paramList.setValue(super.opeDate);
		
		// 料金項目抽出変換．適用終了年月日
		paramList.setValue(super.opeDate);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectPrcKmkCdChsht][paramList=" + paramList.getList().toString() + "]");
		
		// SQL実行
		executeCH_M_PRC_KMK_CS_CHGE_CH_SELECT_005(paramList.getList().toArray());
		JBSbatCommonDBInterface prcKmkCsChgeMap = db_CH_M_PRC_KMK_CS_CHGE.selectNext(); 
		
		// 取得結果判定
		if (prcKmkCsChgeMap == null)
		{
			// DB未存在エラー
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectPrcKmkCdChsht][DB未存在エラー]");
			String[] msgParam = {JBSbatCH_M_PRC_KMK_CS_CHGE.TABLE_NAME,paramList.getList().toString()};
			throw new JBSbatBusinessException(JPCBatchMessageConstant.ECHB0270CH, msgParam);
		}
		
		// 相殺済額情報セット設定
		sosaiZumiSet = new HashSet<String>();
		while(prcKmkCsChgeMap != null)
		{
			// 料金グループコード＋料金コースコード＋料金サービスコード＋料金項目コード
			String setValue = this.makeStr(prcKmkCsChgeMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_GRP_CD)
										   ,prcKmkCsChgeMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PCRS_CD)
										   ,prcKmkCsChgeMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_SVC_CD)
										   ,prcKmkCsChgeMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_KMK_CD));
			
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][selectPrcKmkCdChsht][sosaiZumiSet=" + setValue + "]");
			sosaiZumiSet.add(setValue);
			
			prcKmkCsChgeMap = db_CH_M_PRC_KMK_CS_CHGE.selectNext(); 
		}
		
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][selectPrcKmkCdChsht]");

	}
	
	/**
	 * 文字を連結します
	 * @param  string 文字
	 * @return strBuf 連結した文字列
	 */
	private String makeStr(String ...string)
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeStr]");
		
		StringBuffer strBuf = new StringBuffer();
		for(String str:string)
		{
			if(str == null)
			{
				strBuf.append(JACStrConst.KARA_MOJI);
			}
			else
			{
				strBuf.append(str);
			}
		}
		
		assert strBuf != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][strBuf][strBuf = " + strBuf.toString() + "]") : true;
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeStr]");
		
		return strBuf.toString();
	}
}