/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCHKsdkcpNkinInfChsht
*	ソースファイル名	：JBSbatCHKsdkcpNkinInfChsht.java
*	作成者				：富士通　
*	作成日				：2011年11月02日
*＜機能概要＞
*　コンビニ入金情報抽出部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*   v32.00.00	2017/04/27	FJ)西面		【ANK-2996-00-00】SMSを利用した即時決済
*   v59.00.00	2022/04/18	FJ)吉田		【ANK-4160-00-00】SMBC即時決済入金会計システム化対応
*********************************************************************/
package eo.business.service;

import java.util.HashMap;

import eo.business.common.JACbatDebugLogUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCHbatSeikyKaknoBusinessUtil;
import eo.business.util.file.JBSbatCHIFM116;
import eo.business.util.file.JBSbatCHIFM280;
import eo.business.util.table.JBSbatZM_M_CD_NM_KANRI;
import eo.common.constant.JACStrConst;
import eo.common.constant.JPCBatchMessageConstant;
import eo.common.constant.JZM0171Constant;
import eo.common.util.JPCUtilCommon;
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;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatCHKsdkcpNkinInfChsht extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(料金スケジュール定義)*/
	private static final String D_TBL_NAME_CH_M_PRC_SCHDL_TEIGI = "CH_M_PRC_SCHDL_TEIGI";

	/** テーブルアクセスクラス(料金スケジュール定義)*/
	private JBSbatSQLAccess db_CH_M_PRC_SCHDL_TEIGI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	
	/**▼▼▼▼▼▼クラス変数追加 開始▼▼▼▼▼▼*/
	
	/** 請求収納業務共通クラス */
	private JCHbatSeikyKaknoBusinessUtil skbu = null;
	
	/** 入金予定年月日の年月 */
	private String nkinYoteiYm 	= null;
	
	/** テーブル(コード名称管理)*/
	private static final String D_TBL_NAME_ZM_M_CD_NM_KANRI = "ZM_M_CD_NM_KANRI";
	
	/** SQL定義キー(CH_SELECT_005)*/
	private static final String ZM_M_CD_NM_KANRI_CH_SELECT_005 = "CH_SELECT_005";
	
	/** テーブルアクセスクラス(コード名称管理)*/
	private JBSbatSQLAccess db_ZM_M_CD_NM_KANRI = null;
	
	
	/** 収納機関マップ */
	private HashMap<String,String> shunoKikanMap = null;
	
	/**▲▲▲▲▲▲クラス変数追加 終了▲▲▲▲▲▲*/

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

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

		// 請求収納業務共通クラスをインスタンス化
		this.skbu = new JCHbatSeikyKaknoBusinessUtil(commonItem);
		
		// バッチ運用日から当月年月（入金予定年月日の年月）取得
		this.nkinYoteiYm = this.skbu.getBillYmContain(super.opeDate, "21");
		
		db_ZM_M_CD_NM_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_CD_NM_KANRI);

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

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][inMap=" + inMap.getMap().toString() + "]");
		
		JBSbatOutputItem outputItem = new JBSbatOutputItem();
		
		// ファイル出力情報作成
		outputItem.addOutMapList(this.makeOutputInf(inMap));

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

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

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


	/**
	 * 出力情報を作成します。
	 * 
	 * @param inMap 入力情報
	 * @param kaikYm 会計年月
	 * @return JBSbatServiceInterfaceMap 出力情報
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatServiceInterfaceMap makeOutputInf(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeOutputinf]");
		
		JBSbatServiceInterfaceMap outputinf = new JBSbatServiceInterfaceMap();
		
		// 会計年月
		// v59.00.00 2022/04/18 ANK-4160-00-00 MOD START
//		outputinf.set(JBSbatCHIFM116.SEIKY_YM,				inMap.getString(JBSbatCHIFM280.CVSTORE_PAY_RSV_YMD).substring(0, 6));
		outputinf.set(JBSbatCHIFM116.SEIKY_YM,				inMap.getString(JBSbatCHIFM280.OUT_ORG_SHUNO_YMD).substring(0, 6));
		// v59.00.00 2022/04/18 ANK-4160-00-00 MOD END
		
		// 入金経路コード
		outputinf.set(JBSbatCHIFM116.NYUKIN_ROUTE_CD,		inMap.get(JBSbatCHIFM280.NYUKIN_ROUTE_CD));
		
		// 収納機関コード
		
		if(isSmbc((String)inMap.get(JBSbatCHIFM280.NYUKIN_ROUTE_CD)))
		{
			//入金登録方法コードが自動入金の場合
			if(JACStrConst.NYUKIN_ADD_WAY_CD_AUTO.equals(inMap.get(JBSbatCHIFM280.NYUKIN_ADD_WAY_CD)))
			{
				outputinf.set(JBSbatCHIFM116.SHUNOKIKAN_CD,		JACStrConst.EAN_MAKER_CD_REAL);
			}else{
				
				outputinf.set(JBSbatCHIFM116.SHUNOKIKAN_CD,		JACStrConst.EAN_MAKER_CD_NOMAL);
			}
			
		}else{
			
			if(inMap.get(JBSbatCHIFM280.EAN_MAKER_CD).equals(""))
			{
				outputinf.set(JBSbatCHIFM116.SHUNOKIKAN_CD,		JACStrConst.EAN_MAKER_CD_NOMAL);
			}
			else
			{
				outputinf.set(JBSbatCHIFM116.SHUNOKIKAN_CD,			inMap.get(JBSbatCHIFM280.EAN_MAKER_CD));
			}
		}
		
		// 集計キー１
		if(isSmbc((String)inMap.get(JBSbatCHIFM280.NYUKIN_ROUTE_CD)))
		{
			outputinf.set(JBSbatCHIFM116.KEY_SHUK1,				skbu.fillString(JCHbatSeikyKaknoBusinessUtil.FillType.HalfSpace,
						inMap.getString(JBSbatCHIFM280.SHUNOKIKAN_CD),				10,	true));
			
		}else{
			outputinf.set(JBSbatCHIFM116.KEY_SHUK1,				skbu.fillString(JCHbatSeikyKaknoBusinessUtil.FillType.HalfSpace,
						inMap.getString(JBSbatCHIFM280.CVSTORE_CD),				10,	true));
		}
		
		// 集計キー２
		outputinf.set(JBSbatCHIFM116.KEY_SHUK2,				skbu.fillString(JCHbatSeikyKaknoBusinessUtil.FillType.HalfSpace,
					inMap.getString(JBSbatCHIFM280.CVSTORE_PAY_RSV_YMD),	10,	true));
		
		// 集計キー３
		outputinf.set(JBSbatCHIFM116.KEY_SHUK3,				skbu.fillString(JCHbatSeikyKaknoBusinessUtil.FillType.HalfSpace,
					inMap.getString(JBSbatCHIFM280.OUT_ORG_SHUNO_YMD),		10,	true));
		
		// 処理区分
		outputinf.set(JBSbatCHIFM116.DIV_TRAN,				inMap.get(JBSbatCHIFM280.DIV_TRAN));
		
		// 収納年月区分
		outputinf.set(JBSbatCHIFM116.SHUNO_DIV_YM,			this.getShunoYmDiv(inMap));
		
		// 収納コンビニ会社コード
		outputinf.set(JBSbatCHIFM116.SHUNO_CVSTORE_CD,		inMap.get(JBSbatCHIFM280.CVSTORE_CD));
		
		//TODO コード名称管理から取得必要
		// 収納コンビニ会社名
		outputinf.set(JBSbatCHIFM116.SHUNO_CVSTORE_COMP_NM,	shunoKikanMap.get(inMap.get(JBSbatCHIFM280.SHUNOKIKAN_CD)));
		
		
		//TODO 変更必要
		// コンビニ収納区分
		
		// 収納機関コード
		
		if(isSmbc((String)inMap.get(JBSbatCHIFM280.NYUKIN_ROUTE_CD)))
		{
			//入金登録方法コードが自動入金の場合
			if(JACStrConst.NYUKIN_ADD_WAY_CD_AUTO.equals(inMap.get(JBSbatCHIFM280.NYUKIN_ADD_WAY_CD)))
			{
				outputinf.set(JBSbatCHIFM116.SHUNO_DIV_CVSTORE,		JACStrConst.EAN_MAKER_CD_REAL);
			}else{
				
				outputinf.set(JBSbatCHIFM116.SHUNO_DIV_CVSTORE,		JACStrConst.EAN_MAKER_CD_NOMAL);
			}
			
		}else{
		
			if(inMap.get(JBSbatCHIFM280.EAN_MAKER_CD).equals(""))
			{
				outputinf.set(JBSbatCHIFM116.SHUNO_DIV_CVSTORE,		JACStrConst.EAN_MAKER_CD_NOMAL);
			}
			else
			{
				outputinf.set(JBSbatCHIFM116.SHUNO_DIV_CVSTORE,		inMap.get(JBSbatCHIFM280.EAN_MAKER_CD));
			}
		
		}
		// 収納日
		outputinf.set(JBSbatCHIFM116.OUT_ORG_SHUNO_YMD,		inMap.get(JBSbatCHIFM280.OUT_ORG_SHUNO_YMD));
		
		// 入金処理年月日
		outputinf.set(JBSbatCHIFM116.NYUKIN_TRN_YMD,		inMap.get(JBSbatCHIFM280.NYUKIN_TRN_YMD));
		
		// 入金取消年月日
		outputinf.set(JBSbatCHIFM116.NYUKIN_CL_YMD,			this.getNyukinClYmd(inMap));
		
		// 入金登録方法
		outputinf.set(JBSbatCHIFM116.NYUKIN_ADD_WAY_CD,		inMap.get(JBSbatCHIFM280.NYUKIN_ADD_WAY_CD));
		
		// 入金額
		outputinf.set(JBSbatCHIFM116.NYUKIN_AMNT,			skbu.fillString(JCHbatSeikyKaknoBusinessUtil.FillType.Zero,
					inMap.getString(JBSbatCHIFM280.NYUKIN_AMNT).toString(),	1,	true));
		
		// 入金予定日
		outputinf.set(JBSbatCHIFM116.NKIN__RSVD,			inMap.get(JBSbatCHIFM280.CVSTORE_PAY_RSV_YMD));
		
		// 請求契約番号
		outputinf.set(JBSbatCHIFM116.SEIKY_KEI_NO,			inMap.get(JBSbatCHIFM280.SEIKY_KEI_NO));
		
		// 入金番号
		outputinf.set(JBSbatCHIFM116.NYUKIN_NO,				inMap.get(JBSbatCHIFM280.NYUKIN_NO));
		
		// 請求番号
		outputinf.set(JBSbatCHIFM116.SEIKY_NO,				inMap.get(JBSbatCHIFM280.SEIKY_NO));
		
		// 金庫番号
		outputinf.set(JBSbatCHIFM116.KNK_NO,				inMap.get(JBSbatCHIFM280.MAX_KNK_NO));
		
		// 口座振替結果コード
		outputinf.set(JBSbatCHIFM116.KHRI_RSLT_CD,			JACStrConst.KHRI_RSLT_CD_HRK_NOM);
		
		outputinf.setOutFlg(true);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeOutputinf]");
		
		return outputinf;
	}
	
	/**
	 * 入金情報をもとに収納年月区分を取得します。
	 * 
	 * @param inMap 入力情報
	 * @return String 収納年月区分
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private String getShunoYmDiv(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getShunoYmDiv]");
		
		String shunoYmDiv = JACStrConst.KARA_MOJI;
		
		// 外部組織収納年月日
		String shunoTmd = inMap.getString(JBSbatCHIFM280.OUT_ORG_SHUNO_YMD);
		
		// 外部組織収納年月日の年月を取得
		String shunoYm = shunoTmd.substring(0, 6);
		
		// 入金予定年月日の年月＞外部組織収納年月日の年月の場合
		if(nkinYoteiYm.compareTo(shunoYm) > 0)
		{
			// 収納年月区分（前月収納）
			shunoYmDiv = JACStrConst.SHUNO_YM_DIV_PRV;
		}
		// v59.00.00 2022/04/18 ANK-4160-00-00 DEL START
//		// 入金予定年月日の年月＜外部組織収納年月日の年月の場合
//		else if(nkinYoteiYm.compareTo(shunoYm) < 0)
//		{
//			// 収納年月区分（来月収納）
//			shunoYmDiv = JACStrConst.SHUNO_YM_DIV_NEXT;
//		}
		// v59.00.00 2022/04/18 ANK-4160-00-00 DEL END
		// 上記以外の場合
		else
		{
			// 収納年月区分（当月収納）
			shunoYmDiv = JACStrConst.SHUNO_YM_DIV_TOGETU;
		}
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getShunoYmDiv][nkinYoteiYm=" + nkinYoteiYm
				+ ":shunoYm=" + shunoYm + ":shunoYmDiv=" + shunoYmDiv + "]"):true;
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getShunoYmDiv]");
		return shunoYmDiv;
	}
	
	/**
	 * 入力情報をもとに入金取消年月日を取得します。
	 * 
	 * @param inMap 入力情報
	 * @return String 収納年月区分
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private String getNyukinClYmd(JBSbatServiceInterfaceMap inMap) throws Exception
	{
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getNyukinClYmd]");
		
		String nyukinClYmd = JACStrConst.KARA_MOJI;
		
		// 金庫．カレントレコード件数
		String knkCnt = String.valueOf(inMap.get(JBSbatCHIFM280.KNK_CNT));
		// 金庫．カレントレコード件数（取消）
		String knkClCnt = String.valueOf(inMap.get(JBSbatCHIFM280.KNK_CL_CNT));
		
		// 金庫からの取得がない場合
		if(JACStrConst.KARA_MOJI.equals(knkCnt))
		{
			// 入金取消年月日（入金．入金取消年月日）
			nyukinClYmd = inMap.getString(JBSbatCHIFM280.NYUKIN_CL_YMD);
		}
		// 金庫．カレントレコード件数＝金庫．カレントレコード件数（取消）の場合
		else if(knkCnt.equals(knkClCnt))
		{
			// 入金取消年月日（最大金庫移動年月日）
			nyukinClYmd = inMap.getString(JBSbatCHIFM280.MAX_KNK_IDO_YMD);
		}
		// 上記以外の場合
		else
		{
			// 入金取消年月日（空白）
			nyukinClYmd = JPCUtilCommon.fillHalfSpace(nyukinClYmd, 8, true);
		}
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getNyukinClYmd][nyukinClYmd=" + nyukinClYmd + "]"):true;
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getNyukinClYmd]");
		
		return nyukinClYmd;
	}
	
	/**
	 * 決済代行（ＳＭＢＣ）有無判定処理
	 * 引数として渡された入金経路コードを元に
	 * 決済代行（ＳＭＢＣ）か否かを判断する。
	 * @param nyukinRouteCd
	 * @return true 決済代行（ＳＭＢＣ） false 決済代行（ＳＭＢＣ）以外（null)
	 * @throws Exception
	 */
	private boolean isSmbc(String nyukinRouteCd) throws Exception
	{
		//決済代行（ＳＭＢＣ）の場合trueを返却する
		if(JACStrConst.NYKNKEIRCD_KESSAI_SMBC.equals(nyukinRouteCd))
		{
			return true;
		}
		
		return false;
		
	}
	
	/**
	 * 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 executeZM_M_CD_NM_KANRI_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());

		// DBアクセスを実行します
		db_ZM_M_CD_NM_KANRI.selectBySqlDefine(paramList, ZM_M_CD_NM_KANRI_CH_SELECT_005);
	}
	
	//v32.00.00 2017/04/18 Add Start
	/**
	 * コード名称管理スキーマから、収納機関コードを取得し
	 * マップ形式に変換する
	 * @throws Exception
	 */
	private void getShunoKikanMap() throws Exception
	{
		
		this.shunoKikanMap = new HashMap<String, String>();
		
		JBSbatCommonDBInterface whereParam = new JBSbatCommonDBInterface();
		// コード区分
		whereParam.setValue(JZM0171Constant.CD00911);
		// 適用開始年月日
		whereParam.setValue(super.opeDate);
		// 適用終了年月日
		whereParam.setValue(super.opeDate);
		
		assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][shunoKikanMap][whereParam=" + whereParam.getList().toString() + "]");
		
		// SQL実行
		executeZM_M_CD_NM_KANRI_CH_SELECT_005(whereParam.getList().toArray());
		
		// 結果を取得
		JBSbatCommonDBInterface dbMap = db_ZM_M_CD_NM_KANRI.selectNext();
		
		
		if(null == dbMap)
		{
			// ログ出力（【最重要】ＤＢ未存在エラー）
			String[] msgParam = new String[]
			{ JBSbatZM_M_CD_NM_KANRI.TABLE_NAME, whereParam.getList().toString() };
			throw new JBSbatBusinessException(JPCBatchMessageConstant.ECHB0270CH, msgParam);
		}
		// 結果をマップに設定
		while(dbMap != null)
		{
			// コード区分
			String cdDiv = dbMap.getString(JBSbatZM_M_CD_NM_KANRI.CD_DIV);
			// コード区分名
			String cdDivNm = dbMap.getString(JBSbatZM_M_CD_NM_KANRI.CD_DIV_NM);
			
			this.shunoKikanMap.put(cdDiv, cdDivNm);
			
			dbMap = db_ZM_M_CD_NM_KANRI.selectNext();
		}
		
	}
	
	
	/**▲▲▲▲▲▲メソッド追加 終了▲▲▲▲▲▲*/
}