/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatKKCardUkInfoShanaiMailMake
*	ソースファイル名	：JBSbatKKCardUkInfoShanaiMailMake.java
*	作成者				：富士通　
*	作成日				：2022年06月25日
*＜機能概要＞
*　結果情報ファイル編集部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v58.00.00	2022/06/25  FJ)北村		【ANK-3846-09-00】【クレカ】クリアパス→ペイジェント移行
*
*********************************************************************/
package eo.business.service;

import java.util.HashMap;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JKKBatConst;
import eo.business.util.file.JBSbatKKIFM952;
import eo.business.util.table.JBSbatZM_M_WORK_PARAM_KNRI;
import eo.common.util.JKKStringUtil;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatOutputFileUtil;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatKKCardUkInfoShanaiMailMake extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	/** テーブル(業務パラメータ管理)*/
	private static final String D_TBL_NAME_ZM_M_WORK_PARAM_KNRI = "ZM_M_WORK_PARAM_KNRI";

	/** テーブルアクセスクラス(業務パラメータ管理)*/
	private JBSbatSQLAccess db_ZM_M_WORK_PARAM_KNRI = null;

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

	/** 業務パラメータID（カード受付情報社内メール_ＮＧデータ対象） */
	private static final String WKPARA_PARA_MAIL_NG_DATA_CD = "AZKR_MAIL_NG_CD";

	/** 改行コード */
	private static final String CRLF  = "CR+LF";

	/** 文字コード(UTF-8) */
	public static final String UTF8 = "UTF-8";

	/** サイトID：コンシューマ */
	private static final String SITE_ID_CONSUMER  = "4211";
	
	/** サイトID：法人 */
	private static final String SITE_ID_HOJIN  = "4411";

	/** サイトID：コンテンツ */
	private static final String SITE_ID_CONTENTS  = "4212";

	/** 処理結果：0（正常） */
	private static final String TRN_RSLT_0  = "0";

	/** コンシューマ OK件数 */
	private int consumerOkCnt = 0;

	/** コンシューマ NG件数 */
	private int consumerNgCnt = 0;

	/** コンシューマ 無効件数 */
	private int consumerMukoCnt = 0;

	/** 法人 OK件数 */
	private int hojinOkCnt = 0;

	/** 法人 NG件数 */
	private int hojinNgCnt = 0;

	/** 法人 無効件数 */
	private int hojinMukoCnt = 0;

	/** コンテンツ OK件数 */
	private int contentsOkCnt = 0;

	/** コンテンツ NG件数 */
	private int contentsNgCnt = 0;

	/** コンテンツ 無効件数 */
	private int contentsMukoCnt = 0;

	/** カード受付情報社内メール本文ファイル */
	private String mailNaiyoFileName = null;

	/** カード受付情報社内メール本文 */
	private StringBuilder mailData = new StringBuilder();
	
	/** キー処理年月日 */
	private String keytrnYmd = null;
	
	/** メール本文作成フラグ */
	private boolean mailDateInFlg = false;

	/** NGデータチェックマップ*/
	private HashMap<String, Object> ngDataChkMap = null;

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

		// DBアクセスクラスを生成します
		db_ZM_M_WORK_PARAM_KNRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_WORK_PARAM_KNRI);

		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		executeZM_M_WORK_PARAM_KNRI_KK_SELECT_017(new Object[]{ WKPARA_PARA_MAIL_NG_DATA_CD + "%", super.opeDate, super.opeDate});
		JBSbatCommonDBInterface result = db_ZM_M_WORK_PARAM_KNRI.selectNext();
		HashMap<String, Object>retMap = new HashMap<String, Object>();
		// 取得結果判定
		if(result != null)
		{
			// 取得情報をマップに格納する
			while(null != result)
			{
				HashMap<String, String> tmpInfo = new HashMap<String, String>();
				tmpInfo.put(JBSbatZM_M_WORK_PARAM_KNRI.WORK_PARAM_SETTE_VALUE, result.getString(JBSbatZM_M_WORK_PARAM_KNRI.WORK_PARAM_SETTE_VALUE));
				retMap.put(result.getString(JBSbatZM_M_WORK_PARAM_KNRI.WORK_PARAM_SETTE_VALUE), tmpInfo);
				result = db_ZM_M_WORK_PARAM_KNRI.selectNext();
			}
			ngDataChkMap = retMap;
		}

		// フリー項目で渡されたメール本文ファイル名を取得
		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];
			}
		}
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @param inMap　入力電文
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		// 出力共通電文を生成
		JBSbatOutputItem outputItem = new JBSbatOutputItem();

		// メール本文作成フラグをONにする。
		mailDateInFlg = true;

		String trnYmd = inMap.getString(JBSbatKKIFM952.TRN_YMD);
		if (JKKStringUtil.isNullEmpty(keytrnYmd)) 
		{
			keytrnYmd = trnYmd;
		}

		// 処理年月日が違う場合、メール本文作成処理を行う。
		if (!keytrnYmd.equals(trnYmd)) 
		{
			// キー処理年月日にファイルの内容を設定
			setMail(keytrnYmd);
			// 各件数の件数リセットを実施
			setAuthoriDataCountReset();
			// 各件数のカウント処理を実施
			setAuthoriDataCount(inMap);
			keytrnYmd = trnYmd;
		} 
		else 
		{
			// 各件数のカウント処理を実施
			setAuthoriDataCount(inMap);
		}

		return outputItem;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/

		// DBアクセスクラスをクローズします
		db_ZM_M_WORK_PARAM_KNRI.close();
		ngDataChkMap = null;

		// メール本文の設定がない場合（空ファイルの場合）
		if (!mailDateInFlg) {
			setMail(super.opeDate);
		} else {
			setMail(keytrnYmd);
		}

		// メール本文ファイルを作成し、送信内容を出力
		JBSbatOutputFileUtil cntFile = new JBSbatOutputFileUtil(this.mailNaiyoFileName);
		cntFile.setEncode(UTF8);
		cntFile.setLine(CRLF);
		cntFile.createWriter();
		cntFile.write(mailData.toString());
		cntFile.close();

	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}


	/**
	 * メール本文を設定する。
	 * 
	 * 【設定内容例】
	 * 2022年11月02日　有効性チェック結果
	 * コンシューマ　　ＯＫ：10件　ＮＧ：1件　無効：2件
	 * 法人　　　　　　ＯＫ：5件　ＮＧ：1件　無効：1件
	 * コンテンツ　　　ＯＫ：5件　ＮＧ：0件　無効：3件
	 * @param inTrnDate 処理年月日
	 */
	private void setMail(String inTrnDate) {
		// メール本文にすでに設定がある場合、1行分空行を設定する。
		if (mailData.length() > 0) {
			mailData.append("\r\n");
		} 
		// メール本文に設定がない場合、送信日（バッチ運用日）情報を設定する。
		else 
		{
			String paramYear = super.opeDate.substring(0, 4);
			String paramMonth = super.opeDate.substring(4, 6);
			String paramDay = super.opeDate.substring(6, 8);
			// 送信日の情報を設定
			mailData.append("【" + paramYear + "年"+ paramMonth + "月" + paramDay+ "日　送信分】\r\n");
			// 2行分、改行を設定
			mailData.append("\r\n");
			mailData.append("\r\n");
		}
		// メール本文作成フラグをONにする。
		mailDateInFlg = true;

		String paramYear = inTrnDate.substring(0, 4);
		String paramMonth = inTrnDate.substring(4, 6);
		String paramDay = inTrnDate.substring(6, 8);
		mailData.append(paramYear + "年"+ paramMonth + "月" + paramDay+ "日　有効性チェック結果\r\n");
		mailData.append("\r\n");
		// 各サイトID単位の件数を設定する。
		mailData.append("コンシューマ　　ＯＫ："+ consumerOkCnt 
				+ "件　ＮＧ：" + consumerNgCnt 
				+ "件　無効：" + consumerMukoCnt + "件\r\n");
		mailData.append("法人　　　　　　ＯＫ："+ hojinOkCnt 
				+ "件　ＮＧ：" + hojinNgCnt 
				+ "件　無効：" + hojinMukoCnt + "件\r\n");
		mailData.append("コンテンツ　　　ＯＫ："+ contentsOkCnt 
				+ "件　ＮＧ：" + contentsNgCnt 
				+ "件　無効：" + contentsMukoCnt + "件\r\n");
	}

	/**
	 * SQLKEY(AC_SELECT_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	業務パラメータID
	 *		 	業務パラメータ適用開始年月日
	 *		 	業務パラメータ適用終了年月日
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeZM_M_WORK_PARAM_KNRI_KK_SELECT_017(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_WORK_PARAM_KNRI.selectBySqlDefine(paramList, ZM_M_WORK_PARAM_KNRI_KK_SELECT_017);
	}

	/**
	 * 各件数のカウントを行う
	 * 
	 * @param inMap 入力ファイル
	 * @throws Exception 
	 */
	@SuppressWarnings("unchecked")
	private void setAuthoriDataCount(JBSbatServiceInterfaceMap inMap) throws Exception {
		// サイトID
		String siteId = inMap.getString(JBSbatKKIFM952.SITE_ID);
		// 処理結果
		String trnRslt = inMap.getString(JBSbatKKIFM952.TRN_RSLT);
		// レスポンスコード
		String resCode = inMap.getString(JBSbatKKIFM952.AUTH_RSLT_RSP_CD);
		// レスポンス詳細
		String resDtl = inMap.getString(JBSbatKKIFM952.AUTH_RSLT_RSP_DTL);

		// NGデータ判定を行う為のキー（レスポンスコード + , + レスポンス詳細)
		String checkResCode = resCode + "," + resDtl;

		// レスポンスコードが2008の場合レスポンスコードのみで確認する。
		if ("2008".equals(resCode)) {
			checkResCode = resCode + ",";
		}

		// コンシューマのカウント
		if (SITE_ID_CONSUMER.equals(siteId)) 
		{
			if (TRN_RSLT_0.equals(trnRslt)) 
			{
				// 正常終了の為、OKにカウントする。
				consumerOkCnt++;
			} else {
				// 業務パラメータより取得したNGデータの対象となる
				// レスポンスコード + レスポンス詳細の組み合わせかどうかを確認する。
				HashMap<String, String> ngDateChkInfo = (HashMap<String, String>) ngDataChkMap.get(checkResCode);

				// NGデータリストに該当がない場合、無効件数としてカウントする。
				if (ngDateChkInfo == null) 
				{
					consumerMukoCnt++;
				} 
				else
				{
					// 該当がある場合はNGデータ件数のカウントを行う。
					consumerNgCnt++;
				}
			}
		}
		// 法人のカウント
		else if (SITE_ID_HOJIN.equals(siteId)) 
		{
			if (TRN_RSLT_0.equals(trnRslt)) 
			{
				// 正常終了の為、OKにカウントする。
				hojinOkCnt++;
			} else {
				// 業務パラメータより取得したNGデータの対象となる
				// レスポンスコード + レスポンス詳細の組み合わせかどうかを確認する。
				HashMap<String, String> ngDateChkInfo = (HashMap<String, String>) ngDataChkMap.get(checkResCode);

				// NGデータリストに該当がない場合、無効件数としてカウントする。
				if (ngDateChkInfo == null) 
				{
					hojinMukoCnt++;
				} 
				else
				{
					// 該当がある場合はNGデータ件数のカウントを行う。
					hojinNgCnt++;
				}
			}
			
		}
		// コンテンツのカウント
		else if (SITE_ID_CONTENTS.equals(siteId)) 
		{
			if (TRN_RSLT_0.equals(trnRslt)) 
			{
				// 正常終了の為、OKにカウントする。
				contentsOkCnt++;
			} else {
				// 業務パラメータより取得したNGデータの対象となる
				// レスポンスコード + レスポンス詳細の組み合わせかどうかを確認する。
				HashMap<String, String> ngDateChkInfo = (HashMap<String, String>) ngDataChkMap.get(checkResCode);

				// NGデータリストに該当がない場合、無効件数としてカウントする。
				if (ngDateChkInfo == null) 
				{
					contentsMukoCnt++;
				} 
				else
				{
					// 該当がある場合はNGデータ件数のカウントを行う。
					contentsNgCnt++;
				}
			}
		}
	}

	/**
	 * 集計後の件数をリセットする。
	 */
	private void setAuthoriDataCountReset() {
		
		// コンシューマ
		consumerOkCnt = 0;
		consumerNgCnt = 0;
		consumerMukoCnt = 0;
		
		// 法人
		hojinOkCnt = 0;
		hojinNgCnt = 0;
		hojinMukoCnt = 0;
		
		// コンテンツ
		contentsOkCnt = 0;
		contentsNgCnt = 0;
		contentsMukoCnt = 0;
	}
}