/*********************************************************************
* All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*    システム名      ：eo顧客基幹システム
*    モジュール名    ：JFUWebMskmShokaiOtPwdSendCC
*    ソースファイル名：JFUWebMskmShokaiOtPwdSendCC.java
*    作成者          ：富士通
*    日付            ：2022年07月20日
*＜機能概要＞
*    WEB申込内容照会ワンタイムパスワード発行(FUIFE203)の共通コンポーネント
*＜修正履歴＞
*    バージョン      修正日      修正者      修正内容
*    v60.0.0         2022/07/20  FJ)新谷    【ANK-4231-00-00】OMO構想対応
**********************************************************************/
package com.fujitsu.futurity.bp.custom.common;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.fujitsu.futurity.bp.x21.bpm.ServiceComponentRequestInvoker;
import com.fujitsu.futurity.bp.x21.bpm.db.SessionHandle;
import com.fujitsu.futurity.bp.x21.bpm.exception.RequestParameterException;
import com.fujitsu.futurity.bp.x21.bpm.parameter.IRequestParameterReadWrite;
import com.fujitsu.futurity.bp.x21.cc.AbstractCommonComponent;
import com.fujitsu.futurity.bp.x21.cc.exception.SCCallException;
import com.fujitsu.futurity.common.JCMConstants;
import com.fujitsu.futurity.common.JSYLogBase;
import com.fujitsu.futurity.common.x01.sc.SCControlMapKeys;
import com.fujitsu.futurity.mapping.bp.common.TemplateErrorUtil;
import com.fujitsu.futurity.model.base.CAANMsg;
import com.fujitsu.futurity.model.common.JCMAPLConstMgr;
import com.fujitsu.futurity.model.common.check.HalfCharCheck;
import com.fujitsu.futurity.model.common.check.LengthCheck;
import com.fujitsu.futurity.model.ejb.common.JSYejbLog;

import eo.common.constant.JFUStrConst;
import eo.common.constant.JPCModelConstant;
import eo.common.util.JFUCommonUtil;
import eo.common.util.JFUDecryptAES;
import eo.ejb.cbs.cbsmsg.EFU0371D010CBSMsg;
import eo.ejb.cbs.cbsmsg.EFU0381A010CBSMsg;
import eo.ejb.cbs.cbsmsg.EFU0381A010CBSMsg1List;


/**
 * WEB申込内容照会ワンタイムパスワード発行の共通コンポーネントクラスです。
 * <br>
 * @author 富士通
 *
 */
public class JFUWebMskmShokaiOtPwdSendCC extends AbstractCommonComponent
{
	/** テンプレートID(EFU0381A010) Web申込内容一時保存一意照会 */
	private static final String TEMPLATE_ID_EFU0381A010 = "EFU0381A010";
	/** テンプレートID(EFU0371D010) 量販訪販Webアクセス認証キー登録 */
	private static final String TEMPLATE_ID_EFU0371D010 = "EFU0371D010";

	/** CCパラメータ：エラー情報 */
	private static final String ERROR_INFO = "ERROR_INFO";
	/** CCパラメータ：エラーコード */
	private static final String ERROR_CODE = "errCode";
	/** CCパラメータ：エラーメッセージ */
	private static final String ERROR_MESSAGE = "errMessage";

	/** APIリターンコード_0000 正常終了 */
	private static final String RETURN_CD_0000 = "0000";
	/** APIリターンコード_5000 業務エラー */
	private static final String RETURN_CD_5000 = "5000";
	/** APIリターンコード_9000_システムエラー */
	private static final String RETURN_CD_9000 = "9000";
	/** リターンメッセージ_システムエラー */
	public static final String RETURN_MESSAGE_SYSTEM_ERROR = "システムエラー";

	/** APIエラーコード_1001：必須チェックエラー */
	private static final String RES_KEY_ERROR_CODE_1001 = "1001";
	/** APIエラーコード_1002：属性チェックエラー */
	private static final String RES_KEY_ERROR_CODE_1002 = "1002";
	/** APIエラーコード_1003：桁数チェックエラー */
	private static final String RES_KEY_ERROR_CODE_1003 = "1003";
	/** APIエラーコード_2001：該当データなしエラー */
	private static final String RES_KEY_ERROR_CODE_2001 = "2001";
	/** APIエラーコード_2002：申込ステータスエラー */
	private static final String RES_KEY_ERROR_CODE_2002 = "2002";

	/** リクエストパラメータキー 受付番号 */
	private static final String REQ_KEY_MSKMSHO_NO = "mskmsho_no";

	/** レスポンス ワンタイムキー */
	private static final String RES_ONTIME_PWD = "onetime_pwd";

	/** Web申込ステータス 受付済 */
	private static final String WEBMK_STAT_UKEZUMI = "010";

	/** ユーザーID 固定値 */
	private static final String USER_ID = "9999999999";
	/** 代理店コード 固定値 */
	private static final String AGNT_CD = "99999999999";
	/** 量販訪販Webアクセス認証キー種別コード 新フロントシステム */
	private static final String RH_VH_WEB_ACCSS_NSKEY_SBT_CD = "02";

	/**
	 * WEB申込内容照会ワンタイムパスワード発行を行います。
	 * <br>
	 * @param handle セッションハンドル
	 * @param param リクエストパラメータ
	 * @param fixedText ユーザ定義文字列
	 * @return リクエストパラメータ
	 * @throws Throwable 例外が発生した場合
	 */
	public IRequestParameterReadWrite execute(SessionHandle handle, IRequestParameterReadWrite param, String fixedText) throws Throwable
	{

		Map<String, Object> ccMsg = (Map<String, Object>)param.getData(fixedText);

		try
		{
			// 単項目チェック
			if (!checkUnitParam(ccMsg))
			{
				// 業務エラー
				param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_5000);
				param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null);
				return param;
			}

			// SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない）
			ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker();

			// Web申込内容一時保存一意照会サービスIF実行
			String mskmshoNo = (String)ccMsg.get(REQ_KEY_MSKMSHO_NO);
			CAANMsg[] efu0381a010CbsMsgList = execEFU0381A010(handle, scCall, param, fixedText, mskmshoNo);

			// 関連チェック
			if (!checkKnrnParam(ccMsg, efu0381a010CbsMsgList))
			{
				// 業務エラー
				param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_5000);
				param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null);
				return param;
			}

			// 量販訪販Webアクセス認証キー登録サービスIF実行
			String webAcssNskey = execEFU0371D010(handle, scCall, param, fixedText, mskmshoNo);

			// 受付番号を暗号化（プロパティファイルの共通暗号鍵自体が暗号化されているため、暗号鍵を復号化してから使用する）
			String key = JFUCommonUtil.decryptKey("ENCRYPT_KEY", JCMAPLConstMgr.getString("FU_WEBMSKM_SHOKAI_ENCRYPTION_KEY")); 
			String enMskmshoNo = JFUDecryptAES.encryptAES(key, webAcssNskey, mskmshoNo);

			// ワンタイムパスワードに「Webアクセス認証キー(初期化ベクトル) + 暗号化した受付番号」を設定
			ccMsg.put(RES_ONTIME_PWD, webAcssNskey + enMskmshoNo);

			// 入力項目の申込書番号を削除
			ccMsg.remove(REQ_KEY_MSKMSHO_NO);
		}
		catch (SCCallException scCallEx)
		{
			// システムエラー
			param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_9000);
			param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, RETURN_MESSAGE_SYSTEM_ERROR);
			outBusLog(ccMsg, RETURN_MESSAGE_SYSTEM_ERROR);
			return param;
		}

		// 正常終了
		param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_0000);
		param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null);
		return param;
	}

	/**
	 * 単項目チェックを行い、チェック結果を返します。
	 * <br/>
	 * @param ccMsg
	 * @return チェックの判定
	 * @throws Exception
	 */
	private boolean checkUnitParam(Map<String, Object> ccMsg) throws Exception
	{
		List<Map<String, String>> errList = new ArrayList<Map<String, String>>();

		String itemName = REQ_KEY_MSKMSHO_NO;
		String itemValue = (String)ccMsg.get(itemName);

		if (JFUBPCommon.isNull(itemValue))
		{
			// 必須チェックエラー
			Map<String, String> errMap = new HashMap<String, String>();
			errMap.put(ERROR_CODE, RES_KEY_ERROR_CODE_1001);
			errMap.put(ERROR_MESSAGE, String.format("%s:", itemName));
			errList.add(errMap);
			outBusLog(ccMsg, "単項目チェックエラー（必須チェック）");
		}
		else
		{
			if (!HalfCharCheck.isEnNumber1Check(itemValue))
			{
				// 属性チェックエラー
				Map<String, String> errMap = new HashMap<String, String>();
				errMap.put(ERROR_CODE, RES_KEY_ERROR_CODE_1002);
				errMap.put(ERROR_MESSAGE, String.format("%s:%s", itemName, itemValue));
				errList.add(errMap);
				outBusLog(ccMsg, "単項目チェックエラー（属性チェック）");
			}
			if (!LengthCheck.isLength1Check(itemValue, 10))
			{
				// 桁数チェックエラー
				Map<String, String> errMap = new HashMap<String, String>();
				errMap.put(ERROR_CODE, RES_KEY_ERROR_CODE_1003);
				errMap.put(ERROR_MESSAGE, String.format("%s:%s", itemName, itemValue));
				errList.add(errMap);
				outBusLog(ccMsg, "単項目チェックエラー（桁数チェック）");
			}
		}

		if (errList.size() > 0)
		{
			ccMsg.put(ERROR_INFO, errList);
			return false;
		}

		return true;
	}

	/**
	 * 関連チェックを行い、チェック結果を返します。
	 * <br/>
	 * @param ccMsg
	 * @return チェックの判定
	 * @throws Exception
	 */
	private boolean checkKnrnParam(Map<String, Object> ccMsg, CAANMsg[] cbsMsgList) throws Exception
	{
		List<Map<String, String>> errList = new ArrayList<Map<String, String>>();

		String itemName = REQ_KEY_MSKMSHO_NO;
		String itemValue = (String)ccMsg.get(itemName);

		if (cbsMsgList == null || cbsMsgList.length == 0)
		{
			// 該当データなしエラー
			Map<String, String> errMap = new HashMap<String, String>();
			errMap.put(ERROR_CODE, RES_KEY_ERROR_CODE_2001);
			errMap.put(ERROR_MESSAGE, String.format("%s:%s", itemName, itemValue));
			errList.add(errMap);
			outBusLog(ccMsg, "関連チェックエラー（該当データなし）");
		}
		else if (!WEBMK_STAT_UKEZUMI.equals(cbsMsgList[0].getString(EFU0381A010CBSMsg1List.WEBMK_STAT)))
		{
			// 申込ステータスエラー
			Map<String, String> errMap = new HashMap<String, String>();
			errMap.put(ERROR_CODE, RES_KEY_ERROR_CODE_2002);
			errMap.put(ERROR_MESSAGE, String.format("%s:%s", itemName, itemValue));
			errList.add(errMap);
			outBusLog(ccMsg, "関連チェックエラー（申込ステータスが受付済以外）");
		}

		if (errList.size() > 0)
		{
			ccMsg.put(ERROR_INFO, errList);
			return false;
		}

		return true;
	}

	/**
	 * Web申込内容一時保存一意照会サービスIFを実行します。
	 * <br/>
	 * @param handle セッションハンドル
	 * @param scCall SC呼び出し部品
	 * @param param リクエストパラメータ
	 * @param fixedText ユーザ定義文字列
	 * @param mskmshoNo 受付番号
	 * @return
	 * @throws Exception
	 */
	private CAANMsg[] execEFU0381A010(SessionHandle handle, ServiceComponentRequestInvoker scCall,
			IRequestParameterReadWrite param, String fixedText, String mskmshoNo) throws Exception
	{
		CAANMsg[] result = null;
		CAANMsg efu0381a010Msg = null;

		// 上りマッピング
		Object[][] efu0381a010 = {
				{ EFU0381A010CBSMsg.TEMPLATEID, TEMPLATE_ID_EFU0381A010 },
				{ EFU0381A010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1 },
				{ EFU0381A010CBSMsg.KEY_MSKMSHO_NO, nullToStr(mskmshoNo) } };

		// サービスIF実行
		efu0381a010Msg = callSC(handle, scCall, param, fixedText, efu0381a010);
		result = efu0381a010Msg.getCAANMsgList(EFU0381A010CBSMsg.EFU0381A010CBSMSG1LIST);

		return result;
	}

	/**
	 * 量販訪販Webアクセス認証キー登録サービスIFを実行します。
	 * <br/>
	 * @param handle セッションハンドル
	 * @param scCall SC呼び出し部品
	 * @param param リクエストパラメータ
	 * @param fixedText ユーザ定義文字列
	 * @param mskmshoNo 受付番号
	 * @return
	 * @throws Exception
	 */
	private String execEFU0371D010(SessionHandle handle, ServiceComponentRequestInvoker scCall,
			IRequestParameterReadWrite param, String fixedText, String mskmshoNo) throws Exception
	{
		String result = null;
		CAANMsg efu0371d010Msg = null;

		// ワンタイムキー有効期限を取得
		String onekeyKigen = JCMAPLConstMgr.getString("FU_WEBMSKM_SHOKAI_ONEKEY_KIGEN_MIN");
		if (JFUBPCommon.isNull(onekeyKigen))
		{
			// 取得できない場合は1分で固定
			onekeyKigen = "1";
		}

		// システム日付 ＋ 有効期限を取得する
		Calendar calendar = Calendar.getInstance();
		SimpleDateFormat formYMDHMS = new SimpleDateFormat("yyyyMMddHHmmssSSS");
		calendar.setTime(formYMDHMS.parse(JPCBPCommon.getSysDateTimeStamp()));
		calendar.add(Calendar.MINUTE, Integer.parseInt(onekeyKigen));
		String work_yk_time = formYMDHMS.format(calendar.getTime());

		// 上りマッピング
		Object[][] efu0371d010 = {
				{ EFU0371D010CBSMsg.TEMPLATEID, TEMPLATE_ID_EFU0371D010 },
				{ EFU0371D010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_3 },
				{ EFU0371D010CBSMsg.USER_ID, USER_ID },
				{ EFU0371D010CBSMsg.AGNT_CD, AGNT_CD },
				{ EFU0371D010CBSMsg.RH_VH_WEBANK_SBT_CD, RH_VH_WEB_ACCSS_NSKEY_SBT_CD },
				{ EFU0371D010CBSMsg.YK_KIGEN_DTM, work_yk_time },
				{ EFU0371D010CBSMsg.WEB_ACCSS_NSKEY_STAT_CD, JFUStrConst.CD00016_0 },
				{ EFU0371D010CBSMsg.INPUT_DATA, nullToStr(mskmshoNo) } };

		// サービスIF実行
		efu0371d010Msg = callSC(handle, scCall, param, fixedText, efu0371d010);
		result = efu0371d010Msg.getString(EFU0371D010CBSMsg.RH_VH_WEB_ACCSS_NSKEY);

		return result;
	}

	/**
	 * SC(サービスインターフェイス）を呼び出します。
	 * <br/>
	 * @param handle セッションハンドル
	 * @param scCall SC呼び出し部品
	 * @param param リクエストパラメータ
	 * @param fixedText ユーザ定義文字列
	 * @param mappingData マッピングデータ
	 * @return CAANMsg
	 * @throws Exception
	 */
	private CAANMsg callSC(SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String fixedText, Object[][] mappingData) throws Exception
	{
		HashMap<String, Object> paramMap = editInMsg(param, mappingData);

		Map<?, ?> result = scCall.run(paramMap, handle);

		CAANMsg[] templates = (CAANMsg[])result.get(JCMConstants.TEMPLATE_LIST_KEY);
		CAANMsg msg = templates[0];

		// リターンコード取得
		Object return_code = result.get(JCMConstants.RET_CD_INT_KEY);
		int status = msg.getInt(JCMConstants.STATUS_INT_KEY);

		editErrorInfoCom(param, templates, (Integer)return_code, fixedText, mappingData);

		//エラー情報のマップを取得
		ArrayList<Object> errList = (ArrayList<Object>)param.getControlMapData(SCControlMapKeys.ERROR_INFO);

		if (errList == null)
		{
			// エラー情報のマップない場合

			errList = new ArrayList<Object>();
		}

		// コントロールマップに設定
		param.setControlMapData(SCControlMapKeys.ERROR_INFO, TemplateErrorUtil.getErrorInfo(result, errList));

		if (!("0".equals(return_code.toString()) && 0 == status))
		{
			// 異常の場合、SCCallExceptionを生成してスローする

			throw new SCCallException("戻り値不正", return_code.toString(), status);
		}
		return msg;
	}

	/**
	 * 共通項目のメッセージを作成します。
	 * 
	 * @param param リクエストパラメータ
	 * @param mappingData マッピングデータ
	 * @return HashMap<String, Object>
	 * @throws RequestParameterException リクエストパラメータの操作でエラーが発生した場合
	 */
	private HashMap<String, Object> editInMsg(IRequestParameterReadWrite param, Object[][] mappingData) throws RequestParameterException
	{
		HashMap<String, Object> paramMap = new HashMap<String, Object>();

		// 【取得元：電文ヘッダ(ヘッダ)】
		// 電文ID
		paramMap.put(JCMConstants.TRANZACTION_ID_KEY, param.getTelegramID());
		// ユースケースID
		paramMap.put(JCMConstants.USECASE_ID_KEY, param.getUsecaseID());
		// オペレーションID
		paramMap.put(JCMConstants.OPERATION_ID_KEY, param.getOperationID());
		// サービス呼び出し区分
		paramMap.put(JCMConstants.CALL_TYPE_KEY, param.getCallType());

		// 【取得元：ユーザエリア(コントロールマップ)】
		// 依頼先ホスト名
		paramMap.put(JCMConstants.CLIENT_HOST_NAME_KEY, param.getControlMapData(SCControlMapKeys.REQ_HOSTNAME));
		// 依頼元IPアドレス
		paramMap.put(JCMConstants.CLIENT_IP_ADDRESS_KEY, param.getControlMapData(SCControlMapKeys.REQ_HOSTIP));
		// 依頼元画面ID
		paramMap.put(JCMConstants.INVOKE_GAMEN_ID_KEY, param.getControlMapData(SCControlMapKeys.REQ_VIEWID));
		// オペレータID
		paramMap.put(JCMConstants.OPERATOR_ID_KEY, param.getControlMapData(SCControlMapKeys.OPERATOR_ID));

		String svcIf = (String)mappingData[0][1];

		CAANMsg template = new CAANMsg(String.format("eo.ejb.cbs.cbsmsg.%sCBSMsg", svcIf));

		// オペレータID
		template.set(JCMConstants.OPERATOR_ID_KEY, param.getControlMapData(SCControlMapKeys.OPERATOR_ID));
		// 運用日付
		template.set(JCMConstants.OPERATE_DATE_KEY, param.getControlMapData(SCControlMapKeys.OPE_DATE));
		// 運用日時
		template.set(JCMConstants.OPERATE_DATETIME_KEY, param.getControlMapData(SCControlMapKeys.OPE_TIME));

		for (int i = 0; i < mappingData.length; i++)
		{
			if (mappingData[i][1] instanceof CAANMsg[])
			{
				// CAANMsg[]の場合
				template.set((String)mappingData[i][0], (CAANMsg[])mappingData[i][1]);
			}
			else
			{
				// CAANMsg[]の以外
				if (JFUStrConst.EMPTY.equals(mappingData[i][1]))
				{
					// nullの場合

					template.setNull((String)mappingData[i][0]);
				}
				else
				{
					// それ以外

					template.set((String)mappingData[i][0], mappingData[i][1]);
				}
			}
		}

		CAANMsg[] templates = new CAANMsg[1];
		templates[0] = template;
		paramMap.put(JCMConstants.TEMPLATE_LIST_KEY, templates);

		return paramMap;
	}

	/**
	 * サービスIFの呼び出しエラー時のレスポンス情報作成
	 * <br/>
	 * @param param リクエストパラメータ
	 * @param templates CAANMsgクラス
	 * @param returnCode リターンコード
	 * @param fixedText ユーザ定義文字列
	 * @param mappingData マッピングデータ
	 * @return IRequestParameterReadWrite
	 * @throws RequestParameterException
	 */
	private IRequestParameterReadWrite editErrorInfoCom(IRequestParameterReadWrite param, CAANMsg[] templates, int returnCode, String fixedText, Object[][] mappingData)
			throws RequestParameterException
	{
		// 本来はサービスインターフェイス分の処理が必要
		CAANMsg template = templates[0];
		int templateStatus = template.getInt(JCMConstants.STATUS_INT_KEY);

		if (returnCode != 0)
		{
			// 0以外のとき

			templateStatus = 9000;
		}

		if (JCMAPLConstMgr.getString("RETURN_MESSAGE_" + String.format("%1$04d", templateStatus)) == null)
		{
			// nullの場合

			templateStatus = 0;
		}

		int bpStatus = 0;
		Object obj = param.getControlMapData(SCControlMapKeys.RETURN_CODE);
		if (obj == null)
		{
			// nullの場合

			bpStatus = -1;
		}
		else
		{
			// 他の場合
			bpStatus = Integer.parseInt((String)param.getControlMapData(SCControlMapKeys.RETURN_CODE));
		}
		if (templateStatus > bpStatus)
		{
			// ステータスを比較

			// BPにサービスコンポーネントのステータスを設定する。
			String formatStatus = String.format("%1$04d", templateStatus);
			String message = JCMAPLConstMgr.getString("RETURN_MESSAGE_" + formatStatus);
			param.setControlMapData(SCControlMapKeys.RETURN_CODE, formatStatus);
			param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, message);
		}

		HashMap<String, String> inMap = null;

		// ユーザデータ情報
		inMap = (HashMap<String, String>)param.getData(fixedText);

		for (int i = 0; i < mappingData.length; i++)
		{
			if (!template.isNull(mappingData[i][0] + "_err"))
			{
				// nullの場合

				// ユーザデータ情報にエラーを確認する
				if (!inMap.containsKey(mappingData[i][0] + "_err"))
				{
					inMap.put(mappingData[i][0] + "_err", template.getString(mappingData[i][0] + "_err"));
				}
			}
		}
		return param;
	}

	/**
	 * 値がnullの場合空文字を返却します。
	 * <br/>
	 * @param str 値
	 * @return 値 or 値がnullの場合空文字を返却
	 */
	private String nullToStr(String str)
	{
		if (str == null)
		{
			// 値がnullの場合

			str = JFUStrConst.EMPTY;
		}
		return str;
	}

	/**
	 * ビジネスログを出力します。
	 *
	 * @param ccMsg
	 * @param msg
	 */
	private void outBusLog(Map<String, Object> ccMsg, String msg)
	{
		StringBuffer outBusLogMsg = new StringBuffer();
		outBusLogMsg.append("FUIFE203#JFUWebMskmShokaiOtPwdSendCC#mskmsho_no(").append(ccMsg.get(REQ_KEY_MSKMSHO_NO)).append(")：").append(msg);
		JSYejbLog.println(JSYLogBase.EXECUTION, this.getClass(), outBusLogMsg);
	}

}