/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCHKhriSeikyInfoMlSksi
*	ソースファイル名	：JBSbatCHKhriSeikyInfoMlSksi.java
*	作成者				：富士通　
*	作成日				：2023年06月21日
*＜機能概要＞
*　口座振替請求情報メール作成部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2023/06/21   富士通		新規作成
*	v67.00.00	2023/06/21   FJ)中川	【ANK-4415-00-00】口振請求及びWeb申込システム移行 STEP1
*********************************************************************/
package eo.business.service;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.HashMap;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JKKBatConst;
import eo.business.util.table.JBSbatCC_M_MAIL;
import eo.common.constant.JACStrConst;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatInputFileUtil;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.util.JBSbatStringUtil;
import eo.framework.util.JCCBatchEsbInterface;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatCHKhriSeikyInfoMlSksi extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(メール)*/
	private static final String D_TBL_NAME_CC_M_MAIL = "CC_M_MAIL";

	/** SQL定義キー(CH_SELECT_001)*/
	private static final String CC_M_MAIL_CH_SELECT_001 = "CH_SELECT_001";

	/** テーブルアクセスクラス(メール)*/
	private JBSbatSQLAccess db_CC_M_MAIL = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** メールコード(口座振替請求情報メール) */
	private static final String MAIL_CD_KHRISEIKYINFOMLSKSI = "CHM1000015";
	
	/** メール情報リスト */
	private JBSbatCommonDBInterface mailList = null;
	
	/** 口座振替請求情報メール本文ファイル */
	private String mailNaiyoFileName = null;
	
	/** 口座振替請求情報メール本文 */
	private String mailText = null;
	
	/** ユースケースID 口座振替請求情報メール */
	private static final String USECASE_ID_CHSV0095 = "CHSV0095";
	
	/** オペレーションID 口座振替請求情報メール */
	private static final String OPERATION_ID_CHSV0095 = "CHSV0095OP";
	
	/** マッピングID */
	private static final String MAPPING_ID_01 = "CHSV009501CC";
	
	/** サービスのリターンコード(正常) */
	private static final String RETURN_CODE_SUCCESS = "0000";

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_CC_M_MAIL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CC_M_MAIL);
		String[] mailKey = { MAIL_CD_KHRISEIKYINFOMLSKSI, super.opeDate, super.opeDate, super.opeDate };
		this.executeCC_M_MAIL_CH_SELECT_001(mailKey);
		this.mailList = db_CC_M_MAIL.selectNext();
		// メールの取得に失敗した場合
		if (this.mailList == null)
		{
			// メッセージ内容 %1%の取得に失敗しました。%2%
			throw new JBSbatBusinessException("EKKB0740CE", new String[] {"メール", "メールコード(" + MAIL_CD_KHRISEIKYINFOMLSKSI + ")"});
		}

		// フリー項目で渡されたメール本文ファイル名を取得
		String freeNames = super.freeItem;
		if(freeNames != null && !"".equals(freeNames))
		{
			String[] fileNames = freeNames.split(JKKBatConst.S_PARAM_DELIM);
			if (fileNames.length == 1)
			{
				this.mailNaiyoFileName = fileNames[0];
			}
		}
		// 入力ファイルの内容を取得
		mailText = readFile(mailNaiyoFileName);
		
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// メール送信サービスを呼出す。
		callMailSendService();
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_CC_M_MAIL.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	/**
	 * SQLKEY(CH_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 executeCC_M_MAIL_CH_SELECT_001(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());

		// DBアクセスを実行します
		db_CC_M_MAIL.selectBySqlDefine(paramList, CC_M_MAIL_CH_SELECT_001);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
	
	/**
	 * ファイル読み込み処理を行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で読込ファイルディレクトリ(フルパス)を設定します。<br>
	 *
	 * 2.引数を元にファイル読込を行い、行をStringBuilder変数へ格納します。<br>
	 * 
	 * </pre>
	 * <p>
	 * @param strFileDir    出力ディレクトリ(フルパス)。
	 * @return resultSb     返却用文字列
	 * @throws Exception    業務サービス内で発生した例外全般。
	 */
	public static String readFile(String strFileDir) throws Exception
	{
		JBSbatInputFileUtil inFileUtil = new JBSbatInputFileUtil(strFileDir);
		inFileUtil.setEncode(JACStrConst.ENCODE_SJIS);
		inFileUtil.createReader();

		String strLine = "";
		String[] strSplit = null;
		StringBuilder resultSb = new StringBuilder();

		try
		{
			for(strLine = inFileUtil.readLine(); null != strLine; strLine = inFileUtil.readLine())
			{
				strSplit = strLine.split(",", 2);
				if(strSplit.length == 1)
				{
					strSplit = new String[]{strLine.split(",")[0], ""};
				}
				
				if(strSplit[0].equals("1"))
				{
					resultSb.append(strSplit[1] + "\r\n");
				}
			}

			return resultSb.toString();

		} 
		catch (IOException e)
		{
			throw e;
		}
		finally
		{
			inFileUtil.close();
		}
	}
	
	/**
	 * 口座振替請求情報メール作成用のサービスを呼出します。
	 * 
	 * @throws Exception 
	 */
	@SuppressWarnings("unchecked")
	private void callMailSendService() throws Exception
	{
		HashMap<String, Object> paramMap = new HashMap<String, Object>();
		
		// ユースケースIDを格納
		paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_USECASE_ID, USECASE_ID_CHSV0095);
		paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_OPERATION_ID, OPERATION_ID_CHSV0095);
		
		// メール情報を取得
		String mailSender    = JBSbatStringUtil.Rtrim(mailList.getString(JBSbatCC_M_MAIL.SENDM_MLAD));
		String mlDaimei      = JBSbatStringUtil.Rtrim(mailList.getString(JBSbatCC_M_MAIL.MAIL_TITLE));
		
		// 入力電文からパラメータを取得する
		// サービスの処理用のパラメータ設定
		HashMap<String, Object> inputMap = new HashMap<String, Object>();
		
		HashMap<String, Object> ccMap = new HashMap<String, Object>();
		
		ArrayList<HashMap> ecc0021D010List1 = new ArrayList<HashMap>();
		ArrayList<HashMap> ecc0021D010List2 = new ArrayList<HashMap>();
		ArrayList<HashMap> ecc0021D010List3 = new ArrayList<HashMap>();
		ArrayList<HashMap> ecc0021D010List4 = new ArrayList<HashMap>();
		ArrayList<HashMap> ecc0021D010List5 = new ArrayList<HashMap>();
		
		// 処理コード
		ccMap.put("func_code", "1");
		// メールコード
		ccMap.put("mail_cd", MAIL_CD_KHRISEIKYINFOMLSKSI);
		// メール送信パターンコード　01:リアルタイム
		ccMap.put("mail_send_pattern_cd", "01");
		// 01.メールアドレスを設定する
		HashMap list1Map = new HashMap();
		// 送信先メールアドレス
		list1Map.put("mlad", mailSender);
		// 送信元メールアドレス
		list1Map.put("sendm_mlad", mailSender);
		// メールタイトル
		list1Map.put("mail_title", mlDaimei);
		// メール設定フィールドコード　01:to
		list1Map.put("mlad_set_field_cd", "01");
		ecc0021D010List1.add(list1Map);
		ccMap.put("ECC0021D010CBSMsg1List", ecc0021D010List1);

		// 読み込んだファイル内容を設定
		HashMap list2Map = new HashMap();
		
		// メール本文ファイルから読み込んだ内容を設定
		list2Map.put("text_htk_ckam_moji", mailText);
		ecc0021D010List2.add(list2Map);

		ccMap.put("ECC0021D010CBSMsg2List", ecc0021D010List2);

		// その他の設定
		ccMap.put("ECC0021D010CBSMsg3List", ecc0021D010List3);
		ccMap.put("ECC0021D010CBSMsg4List", ecc0021D010List4);
		ccMap.put("ECC0021D010CBSMsg5List", ecc0021D010List5);

		inputMap.put(MAPPING_ID_01, ccMap);
		
		// サービスの処理結果の格納用MAP
		HashMap<String, Object> outputMap = new HashMap<String, Object>();

		JCCBatchEsbInterface.invokeService(super.commonItem, paramMap, inputMap, outputMap);
		
		String returnCode = JCCBatchEsbInterface.getReturnCode(outputMap);
		if(!RETURN_CODE_SUCCESS.equals(returnCode))
		{
			//サービスがエラーを返した場合
			StringBuffer err_msg = new StringBuffer();
			err_msg.append("メール送信日：" + super.opeDate);
			super.logPrint.printBusinessErrorLog("EKKB2160CE", new String[] { err_msg.toString() });
			return;
		}
	}
}
