/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom  					 *
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatACInsentivePrcCalcKK
*	ソースファイル名	：JBSbatACInsentivePrcCalcKK.java
*	作成者				：富士通　
*	作成日				：2018年04月19日
*＜機能概要＞
*　インセンティブ料金計算（契約）です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v37.00.00	2018/04/19    富士通		ANK-3366-00-00 新規作成 ｅｏ光設備卸対応
*	v39.01.00	2018/10/05    富士通		IT1-2018-0000158 前月月末取得不備対応
*	v39.02.00	2018/10/30    富士通		【IT1-2018-0000188】卸先事業者インセンティブ設定のカレント取得条件の修正
*********************************************************************/
package eo.business.service;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import eo.business.common.JACbatDebugLogUtil;
import eo.business.common.JACbatSchdlUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.util.file.JBSbatACIFM300;
import eo.business.util.file.JBSbatACIFM299;
import eo.business.util.table.JBSbatCH_M_ORSJGS_INV_SETE;
import eo.common.constant.JACStrConst;
import eo.common.constant.JPCBatchMessageConstant;
import eo.framework.application.JBSbatBusinessException;
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;
import eo.framework.util.JBSbatDateUtil;

/**
* インセンティブ料金計算（契約）<p>
*<BR>
* @author 富士通
*/
public class JBSbatACInsentivePrcCalcKK extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(卸先事業者インセンティブ設定)*/
	private static final String D_TBL_NAME_CH_M_ORSJGS_INV_SETE = "CH_M_ORSJGS_INV_SETE";

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

	/** テーブルアクセスクラス(卸先事業者インセンティブ設定)*/
	private JBSbatSQLAccess db_CH_M_ORSJGS_INV_SETE = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/**▼▼▼▼▼▼クラス変数追加 開始▼▼▼▼▼▼*/	
	
	/** 出力フラグ */
	boolean outputFlg = false;
	
	/** 退避．卸先事業者インセンティブ設定マップ  */
	private HashMap<String, List<JBSbatCommonDBInterface>> tmpOrsIesntivMap = null;
	
	/** 退避．新規申込料金リスト */
	private List<JBSbatCommonDBInterface> valueList = null;

	/**  退避．群月初日 */
	private String tmpCycFst = null;
	
	/**  退避．群月末日 */
	private String tmpCycEnd = null;
	
	/**  退避．新規申込契約料金 */
	private BigDecimal newMakmKeiPrc = null;
	
	/**▲▲▲▲▲▲クラス変数追加 終了▲▲▲▲▲▲*/

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

		// DBアクセスクラスを生成します
		db_CH_M_ORSJGS_INV_SETE = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_M_ORSJGS_INV_SETE);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		
		// IT1-2018-0000158 MOD START
		//// 料金スケジュール定義アクセス部品初期処理
		//JACbatSchdlUtil schdlUtil = new JACbatSchdlUtil(commonItem);
		//
		//try
		//{
		//	// 請求年月を取得する
		//	String seikyYm = schdlUtil.getBillDate(super.opeDate, JACStrConst.EVENT_CD_RYOKIN_KEISAN_YMD);
		//	
		//	// 請求年月から、利用開始終了日取得
		//	String[] strEndYmd = schdlUtil.getUseStrEnd(seikyYm, JACStrConst.EVENT_CD_USE_STAYMD, JACStrConst.EVENT_CD_USE_ENDYMD);
		//	
		//	this.tmpCycFst = strEndYmd[0];	// 群月初日
		//	this.tmpCycEnd = strEndYmd[1];	// 群月末日
		//	assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][群月初日：" + tmpCycFst + "]");
		//	assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][群月末日：" + tmpCycEnd + "]");
		//}
		//finally
		//{
		//	// 料金スケジュール定義アクセス部品クローズ
		//	schdlUtil.close();
		//}
		this.tmpCycEnd = getZngtuLastDay();
		// IT1-2018-0000158 MOD END
		
		// 卸先事業者インセンティブ設定マップを作成
		this.makeOrsIesntivMap();
		
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}
	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		JBSbatOutputItem outputItem = new JBSbatOutputItem(); // 出力共通電文
		
		// 新規申込料金の取得
		this.valueList = getValueList(inMap);
		
// v39.01.00 IT1-2018-0000188 ADD STA
		if(this.valueList == null){
			return outputItem;
		}
// v39.01.00 IT1-2018-0000188 ADD END
		
		newMakmKeiPrc = valueList.get(0).getBigDecimal(JBSbatCH_M_ORSJGS_INV_SETE.NEW_MSKM_KEI_PRC);
		
		// 計算処理
		BigDecimal newMskmInsentivPrc = this.getnewMskmPrc(inMap);
		
		// 上記で取得した値を渡す
		this.makeOutputInfo(inMap,newMskmInsentivPrc,outputItem);

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

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(AC_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 void executeCH_M_ORSJGS_INV_SETE_AC_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
// v39.01.00 IT1-2018-0000188 ADD STA
		paramList.setValue(param[0].toString());
// v39.01.00 IT1-2018-0000188 ADD END


		// DBアクセスを実行します
		db_CH_M_ORSJGS_INV_SETE.selectBySqlDefine(paramList,CH_M_ORSJGS_INV_SETE_AC_SELECT_001);
	}
	
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	
	/**▼▼▼▼▼▼メソッド追加 開始▼▼▼▼▼▼*/
	/**
	 * 卸先事業者インセンティブ設定マスタより、卸先事業者コード、サービスコード、新規申込契約料金を取得し、
	 * 退避．卸先事業者インセンティブ設定マップに保持する
	 * @throws Exception 業務サービス内で発生した例外全般
	 */
	private void makeOrsIesntivMap() throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeOrsIesntivMap]");

		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		
		// 群月末日
		paramList.setValue(this.tmpCycEnd);
		
		// SQL実行
		executeCH_M_ORSJGS_INV_SETE_AC_SELECT_001(paramList.getList().toArray());
		
		JBSbatCommonDBInterface dbMap = db_CH_M_ORSJGS_INV_SETE.selectNext();
		
		// マップの作成
		this.tmpOrsIesntivMap = new HashMap<String, List<JBSbatCommonDBInterface>>();
		
		// 検索結果0件の場合
		if(null == dbMap)
		{
			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeOrsIesntivMap]");
			return;
		}
	
		
		//ブレイク用Key
		String bKey = makeStr(dbMap.getString(JBSbatCH_M_ORSJGS_INV_SETE.ORSJGS_CD), dbMap.getString(JBSbatCH_M_ORSJGS_INV_SETE.SVC_CD));
		
		// 退避マップに設定するバリュー：検索結果のリスト
		ArrayList<JBSbatCommonDBInterface> newMskmPrcList = new ArrayList<JBSbatCommonDBInterface>();
		// 取得出来た場合
		while(dbMap != null)
		{
			// KEY1：卸先事業者コード ＋ サービスコード
			String key = makeStr(dbMap.getString(JBSbatCH_M_ORSJGS_INV_SETE.ORSJGS_CD), dbMap.getString(JBSbatCH_M_ORSJGS_INV_SETE.SVC_CD));
		
			// キーと検索結果のキーが異なった場合
			if(!bKey.equals(key))
			{
				// 卸先事業者インセンティブ設定マップにキーとバリューを設定する
				this.tmpOrsIesntivMap.put(bKey, newMskmPrcList);
				// キーに新たな値を設定する
				bKey = key;
				assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makeOrsIesntivMap]Key:" + bKey);
				// バリューをクリアー
				newMskmPrcList = new ArrayList<JBSbatCommonDBInterface>();
			}
			// 取得結果より卸先事業者インセンティブ設定マップを作成しリストに格納
			newMskmPrcList.add(dbMap);
			
			// 検索結果キークリアー
			key = null;
			
			dbMap =  db_CH_M_ORSJGS_INV_SETE.selectNext();
				
		}

		// 最後の取得結果を格納
		// 卸先事業者インセンティブ設定マップにキーとバリューを設定する
		this.tmpOrsIesntivMap.put(bKey, newMskmPrcList);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeOrsIesntivMap]");
		return;
	}
	
	/**
	 * 卸先事業者インセンティブ設定マップを検索し、新規申込契約料金を取得します
	 * @param inMap 入力電文
	 * @return List 
	 * @throws Exception 業務サービス内で発生した例外全般
	 */
	private List<JBSbatCommonDBInterface> getValueList(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getOrosiInsentive]");
		
		// KEY：卸先事業者コード + サービスコード
		String key = makeStr(inMap.getString(JBSbatACIFM299.ORSJGS_CD),inMap.getString(JBSbatACIFM299.SVC_CD));
		
		// 取得できなかった場合
		if(!this.tmpOrsIesntivMap.containsKey(key))
		{
// v39.01.00 IT1-2018-0000188 MOD STA
//			// DB未存在エラー
//			assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getValueList][DB未存在エラー]");
//			String[] outCntMsg = {JBSbatCH_M_ORSJGS_INV_SETE.TABLE_NAME, key};
//			// エラーログ出力（エラーコード："EACB0250CE"（DB未存在エラー））
//			throw new JBSbatBusinessException(JPCBatchMessageConstant.EACB0250CE, outCntMsg);
			return null;
// v39.01.00 IT1-2018-0000188 MOD END

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

		return this.tmpOrsIesntivMap.get(key);
	}
	
	
	/**
	 * 利用料金を算出をします
	 * @param inMap 入力電文
	 * @return BigDecimal 料金
	 * @throws Exception 業務サービス内で発生した例外全般
	 */
	private BigDecimal getnewMskmPrc(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getnewMskmPrc]");
		
		
		BigDecimal newMskmPrc = BigDecimal.ZERO;
		
		// 料金取得
		// 算出料金　←　卸先事業者別集計情報．抽出件数　×　卸先事業者インセンティブ設定．新規申込料金）
		newMskmPrc = (inMap.getBigDecimal(JBSbatACIFM299.CHST_CNT).multiply(newMakmKeiPrc));

		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getnewMskmPrc]:");
		
		return newMskmPrc;
	}
	
	/**
	 * 利用料金情報（新規申込料金）を出力します
	 * 
	 * @param inMap 入力電文
	 * @param newMskmPrc 新規申込料金
	 * @param outputInItem  出力情報
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void makeOutputInfo(JBSbatServiceInterfaceMap inMap 
									, BigDecimal newMskmInsentivPrc 
									, JBSbatOutputItem outputItem) throws Exception
	{
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeOutputInfo]");
		
		JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();
		
		// 卸先事業者コード
		outMap.setString(JBSbatACIFM300.ORSJGS_CD, 					inMap.getString(JBSbatACIFM299.ORSJGS_CD));
		
		// サービスコード
		outMap.setString(JBSbatACIFM300.SVC_CD, 					inMap.getString(JBSbatACIFM299.SVC_CD));

		// 抽出件数
		outMap.setString(JBSbatACIFM300.CHST_CNT, 					inMap.getBigDecimal(JBSbatACIFM299.CHST_CNT));

		// 新規申込料金
		outMap.setString(JBSbatACIFM300.NEW_MSKM_KEI_PRC, 			newMskmInsentivPrc);

		// 出力フラグ設定
		outMap.setOutFlg(true);
		
		outputItem.addOutMapList(outMap);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeOutputInfo]");

		return;
	}
	
	/**
	 * 文字を連結します
	 * @param  string 文字
	 * @return strBuf 連結した文字列
	 */
		private String makeStr(String ...string)
		{
			StringBuffer strBuf = new StringBuffer();
			for(String str:string)
			{
				if(str == null)
				{
					strBuf.append(JACStrConst.KARA_MOJI);
				}
				else
				{
					strBuf.append(str);
				}
			}
			return strBuf.toString();
		}
	public static void main(String[] args) {
	
	}
	
	// IT1-2018-0000158 ADD START
	/**
	 * 前月末日を取得します。
	 * 
	 * @throws Exception 業務サービス内で発生した例外全般
	 */
	private String getZngtuLastDay() throws Exception
	{
		String zngtuLastDay = "";
		String zngtuLastYmd = "";
		
		// バッチ処理日の前月を取得（YYYYMMDD形式）
		String zngtu = JBSbatDateUtil.adjustMonth(super.opeDate, -1);
		
		// 前処理で取得した前月（YYYYMMDD形式）から年月を取得し、前月の末日を取得（DD形式）
		zngtuLastDay =  JBSbatDateUtil.getEndOfMonth(zngtu.substring(0, 6));
		
		zngtuLastYmd = zngtu.substring(0, 6) + zngtuLastDay;
		
		return zngtuLastYmd;
		
	}
	// IT1-2018-0000158 ADD END
		
	/**▲▲▲▲▲▲メソッド追加 終了▲▲▲▲▲▲*/


}