/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatACUqJgsknSsnPrcKmkShuk
*	ソースファイル名	：JBSbatACUqJgsknSsnPrcKmkShuk.java
*	作成者				：富士通　
*	作成日				：2013年01月28日
*＜機能概要＞
*　UQ事業者間精算料金項目集計部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v4.00.00	2012/11/27  FJ)岡田		【ANK-0137-00-00】対応 新規作成
*	v4.00.01	2013/01/30  FJ)垣内		【ST2-2013-0000325】対応
*	v6.00.00	2013/12/13  FJ)早崎		【OM-2013-0004828】合計集計結果のみ出力
*********************************************************************/
package eo.business.service;

import java.math.BigDecimal;
import java.util.HashMap;
import eo.business.common.JACbatDebugLogUtil;
import eo.business.common.JACbatParamUtil;
import eo.business.common.JACbatRknBusinessUtil;
import eo.business.common.JACbatSchdlUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.util.file.JBSbatACIFM175;
import eo.business.util.table.JBSbatCH_M_PRC_KMK_CS_CHGE;
import eo.common.constant.JACStrConst;
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.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatACUqJgsknSsnPrcKmkShuk extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(料金項目抽出変換)*/
	private static final String D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE = "CH_M_PRC_KMK_CS_CHGE";

	/** テーブル(事業者間精算)*/
	private static final String D_TBL_NAME_CH_T_JGSHAKSSN = "CH_T_JGSHAKSSN";

	/** 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 JBSbatSQLAccess db_CH_T_JGSHAKSSN = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** 料金項目コード検索結果マップ（合計） */
	private HashMap<String, String> resultTtlMap = null;

	/** 退避．集計キー */
	private String bkWorkKey = null;
	
	/** 退避．事業者コード */
	private String jigyoshaCd = null;
	
	/** 退避．事業者契約コード */
	private String jigyoshaKeiCd = null;
	
	/** 退避．精算料金項目コード */
	private String ssnPrcKmkCd = null;
	
	/** 退避．精算年月 */
	private String ssnYm = null;
	
	/** 退避．精算単価 */
	private String ssnTanka = null;
	
	/** 退避．精算金額 */
	private BigDecimal ssnAmnt = BigDecimal.ZERO;
	
	/** 退避．精算数量 */
	private int ssnCnt = 0;
	
	/** 精算数量0件 */
	private static final String SSN_CNT_ZERO = "0";

	
	/**
	 * 初期処理
	 * @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);
		db_CH_T_JGSHAKSSN = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_T_JGSHAKSSN);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");

		// パラメータ取得クラス生成
		JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem);
		
		// 料金項目コード検索結果マップ
		resultTtlMap = new HashMap<String, String>();
		
		// 業務機能識別コード(UQ合計変換)
		String workParaCdTtl = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_AC_WKS_UQCHG_TTL);

		// 料金項目コード検索処理
		searchPrcKmkCd(workParaCdTtl);
		
		// パラメータ取得クラスクローズ
		paramUtil.close();
		
		// 請求年月を取得
		// 料金スケジュール定義アクセス部品初期処理
		JACbatSchdlUtil schdlUtil = new JACbatSchdlUtil(commonItem);

		// 請求年月を取得する
		ssnYm = schdlUtil.getBillDate(super.opeDate, JACStrConst.EVENT_CD_RYOKIN_KEISAN_YMD);

		// 料金スケジュール定義アクセス部品クローズ
		schdlUtil.close();

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @param outputInItem　出力情報
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap, JBSbatOutputItem outputInItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
		
		// 集計キーの生成
		String workKey = getShukeiKey(inMap);
		
		if(inMap != null)
		{
			
			// 退避．集計キーがnullの場合（1レコード目の場合）
			if(this.bkWorkKey == null)
			{
				// ダミーレコード設定
				outputInItem.addOutMapList(new JBSbatServiceInterfaceMap());
				
				// 集計キーの退避
				this.bkWorkKey = workKey;
				
				// 退避項目へ入力データ格納
				setThItem(inMap);

				return outputInItem;
			}
			else
			{
				// 退避．集計キー　＝　入力．集計キーの場合
				if(this.bkWorkKey.equals(workKey))
				{
					
					// 精算金額
					this.ssnAmnt = this.ssnAmnt.add(new BigDecimal(this.ssnTanka));
					
					// 精算件数
					this.ssnCnt++;
				}
				// 退避．集計キー　≠　入力．集計キーの場合
				else
				{
					// 事業者間精算スキーマに登録する
					createJgshakssn();
					
					// 退避項目の初期化
					this.ssnAmnt = BigDecimal.ZERO;
					this.ssnCnt  = 0;

					// 集計キーの退避
					this.bkWorkKey = workKey;
					
					// 退避項目へ入力データ格納
					setThItem(inMap);
				}
				return outputInItem;
			}
		}
		// 最終レコードの場合
		else
		{
			// 事業者間精算スキーマに登録する
			createJgshakssn();
		}

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
		return outputInItem;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_CH_M_PRC_KMK_CS_CHGE.close();
		db_CH_T_JGSHAKSSN.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * 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);
	}

	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	事業者コード				JIGYOSHA_CD
	 *		 	事業者契約コード				JIGYOSHA_KEI_CD
	 *		 	精算料金項目コード				SSN_PRC_KMK_CD
	 *		 	精算年月				SSN_YM
	 *		 	精算金額				SSN_AMNT
	 *		 	精算金額税コード				SSN_AMNT_STAX_CD
	 *		 	精算金額設定年月日				SSN_AMNT_YMD
	 *		 	精算単位				SSN_TANI_CD
	 *		 	精算単価				SSN_TANKA
	 *		 	精算数量				SSN_CNT
	 *		 	登録年月日時分秒				ADD_DTM
	 *		 	登録オペレータアカウント				ADD_OPEACNT
	 *		 	更新年月日時分秒				UPD_DTM
	 *		 	更新オペレータアカウント				UPD_OPEACNT
	 *		 	削除年月日時分秒				DEL_DTM
	 *		 	削除オペレータアカウント				DEL_OPEACNT
	 *		 	無効フラグ				MK_FLG
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCH_T_JGSHAKSSN_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("JIGYOSHA_CD", setParam[0]);
		setMap.setValue("JIGYOSHA_KEI_CD", setParam[1]);
		setMap.setValue("SSN_PRC_KMK_CD", setParam[2]);
		setMap.setValue("SSN_YM", setParam[3]);
		setMap.setValue("SSN_AMNT", setParam[4]);
		setMap.setValue("SSN_AMNT_STAX_CD", setParam[5]);
		setMap.setValue("SSN_AMNT_YMD", setParam[6]);
		setMap.setValue("SSN_TANI_CD", setParam[7]);
		setMap.setValue("SSN_TANKA", setParam[8]);
		setMap.setValue("SSN_CNT", setParam[9]);
		setMap.setValue("ADD_DTM", setParam[10]);
		setMap.setValue("ADD_OPEACNT", setParam[11]);
		setMap.setValue("UPD_DTM", setParam[12]);
		setMap.setValue("UPD_OPEACNT", setParam[13]);
		setMap.setValue("DEL_DTM", setParam[14]);
		setMap.setValue("DEL_OPEACNT", setParam[15]);
		setMap.setValue("MK_FLG", setParam[16]);
	
		// DBアクセスを実行します
		db_CH_T_JGSHAKSSN.insertByPrimaryKeys(setMap);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	/**
	 * 退避項目へ格納します。
	 * @param  inMap    入力電文
	 * @throws Exception 業務サービス内で発生した例外全般
	 */
	private void setThItem(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		// 事業者コード
		this.jigyoshaCd    = inMap.getString(JBSbatACIFM175.JIGYOSHA_CD);
		
		// 事業者契約コード
		this.jigyoshaKeiCd = inMap.getString(JBSbatACIFM175.JIGYOSHA_KEI_CD);
		
		// 精算項目コード
		this.ssnPrcKmkCd   = inMap.getString(JBSbatACIFM175.SSN_KMK_CD);

		// 精算単価
		this.ssnTanka      = inMap.getString(JBSbatACIFM175.AMNT);

		// 精算金額
		this.ssnAmnt = this.ssnAmnt.add(new BigDecimal(this.ssnTanka));
		
		// 精算件数
		this.ssnCnt++;
	}

	/**
	 * 料金項目抽出変換を検索します。
	 * @param  workParaCd    業務機能識別コード
	 * @throws Exception 業務サービス内で発生した例外全般
	 */
	private void searchPrcKmkCd(String workParaCd) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][searchPrcKmkCd]");

		// ＤＢアクセス用のパラメータ定義
		JBSbatCommonDBInterface dbList = new JBSbatCommonDBInterface();

		// 事業者間積算料金 ＷＨＥＲＥ条件設定
		dbList.setValue(super.systemCode); 					// システムコード
		dbList.setValue(workParaCd); 						// 業務機能識別コード
		dbList.setValue(JACStrConst.CHSHT_CHG_CD_CHG); 		// 抽出変換コード
		dbList.setValue(super.opeDate); 					// バッチ運用日
		dbList.setValue(super.opeDate); 					// バッチ運用日

		// 事業者間積算料金データ取得
		executeCH_M_PRC_KMK_CS_CHGE_CH_SELECT_005(dbList.getList().toArray());
		
		// 検索結果取得
		// 抽出データ
		JBSbatCommonDBInterface dbMap = db_CH_M_PRC_KMK_CS_CHGE.selectNext();
		
		// 対象データが存在する場合
		if(dbMap == null)
		{
			// DB未存在エラー
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makeInfo][DB未存在エラー]");
			String[] outCntMsg = {JBSbatCH_M_PRC_KMK_CS_CHGE.TABLE_NAME};
			// エラーログ出力（エラーコード："EACB0250CE"（DB未存在エラー））
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EACB0250CE, outCntMsg);
		}

		// 検索結果がなくなるまで繰り返す
		while(dbMap != null)
		{
			// 精算料金項目コードをキーとして検索結果(料金項目コード)をマップに格納
			String ssnkmkCd = dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_KMK_CD);
			String outPrcKmkCd = dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.OUT_PRC_KMK_CD);

			resultTtlMap.put(ssnkmkCd, outPrcKmkCd);

			// 次レコード取得
			dbMap = db_CH_M_PRC_KMK_CS_CHGE.selectNext();
		}

		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][searchPrcKmkCd]");
		return;
	}

	/**
	 * 集計キーを取得します。
	 * @param  inMap     入力電文
	 * @return String    集計キー
	 * @throws Exception 業務サービス内で発生した例外全般
	 */
	private String getShukeiKey(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getShukeiKey]");
	
		// 集計キー
		String shukeiKey = null;

		StringBuffer keyBuf = new StringBuffer();
		if (inMap != null)
		{
			keyBuf.append(inMap.getString(JBSbatACIFM175.JIGYOSHA_CD)); 		// 事業者コード
			keyBuf.append(inMap.getString(JBSbatACIFM175.JIGYOSHA_KEI_CD)); 	// 事業者契約コード
			keyBuf.append(inMap.getString(JBSbatACIFM175.SSN_KMK_CD)); 			// 精算項目コード
			shukeiKey = keyBuf.toString();
		}
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getShukeiKey][shukeiKey=" + shukeiKey + "]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getShukeiKey]");
	
		return shukeiKey;
	}

	/**
	 * 事業者間精算の登録を行います。
	 * @throws Exception
	 */
	private void createJgshakssn() throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][createJgshakssn]");

		// 料金項目コード検索結果（合計)判定フラグ
		boolean ttlUqKmkFlg = false;
		
		// 精算料金項目コード置換
		String chgPrcKmkCd = this.ssnPrcKmkCd;
		if(resultTtlMap.containsKey(chgPrcKmkCd))
		{
			// 料金項目コード検索結果（合計)判定フラグ ← true
			ttlUqKmkFlg = true;
			
			chgPrcKmkCd = resultTtlMap.get(this.ssnPrcKmkCd);
		}
		
		// 精算金額の丸め処理
		BigDecimal amnt = JACbatRknBusinessUtil.round(JACStrConst.ROUND_DOWN, this.ssnAmnt, 0);

		// 事業者間精算テーブルへ登録
		Object[] setParam = new Object[25];
		setParam[0] = this.jigyoshaCd;						// 事業者コード
		setParam[1] = this.jigyoshaKeiCd;					// 事業者契約コード
		setParam[2] = chgPrcKmkCd;							// 精算料金項目コード
		setParam[3] = this.ssnYm;							// 精算年月
		setParam[4] = amnt.toString();						// 精算金額
		setParam[5] = JACStrConst.KAZEI_HIKAZEI_CD_KAZEI;	// 精算金額税コード
		setParam[6] = super.opeDate;						// 精算金額設定年月日
		setParam[7] = JACStrConst.SSN_TANI_CD_INIT_CNT;		// 精算単位コード
		setParam[8] = this.ssnTanka;						// 精算単価
		
		// 料金項目コード検索結果（合計)判定フラグ = true の場合
		if(ttlUqKmkFlg)
		{
			setParam[9] = String.valueOf(this.ssnCnt); 		// 精算数量
		}
		else
		{
			setParam[9] = this.SSN_CNT_ZERO; 	// 精算数量
		}
		
		executeCH_T_JGSHAKSSN_PKINSERT(setParam);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][createJgshakssn]");
		return;
	}
}