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

import java.util.ArrayList;
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.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.EFU0371A010CBSMsg;
import eo.ejb.cbs.cbsmsg.EFU0371A010CBSMsg1List;
import eo.ejb.cbs.cbsmsg.EFU0371C010CBSMsg;


/**
 * WEB申込内容表示可否照会の共通コンポーネントクラスです。
 * <br>
 * @author 富士通
 *
 */
public class JFUWebMskmNyoHyojiKahiCC extends AbstractCommonComponent
{
	/** テンプレートID(EFU0371A010) 量販訪販Webアクセス認証キー一意照会 */
	private static final String TEMPLATE_ID_EFU0371A010 = "EFU0371A010";
	/** テンプレートID(EFU0371C010) 量販訪販Webアクセス認証キー変更 */
	private static final String TEMPLATE_ID_EFU0371C010 = "EFU0371C010";

	/** 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エラーコード_1003：桁数チェックエラー */
	private static final String RES_KEY_ERROR_CODE_1003 = "1003";

	/** リクエストパラメータキー ワンタイムパスワード */
	private static final String REQ_KEY_ONETIME_PWD = "onetime_pwd";

	/** レスポンス 認証結果 */
	private static final String RES_AUTH_RESULT = "authentication_result";
	/** レスポンス 受付番号 */
	private static final String RES_MSKMSHO_NO = "mskmsho_no";

	/** 認証結果 OK */
	private static final String AUTH_RESULT_OK = "0";
	/** 認証結果 NG */
	private static final String AUTH_RESULT_NG = "9";

	/** 初期化ベクトル長 */
	private static final int IV_LEN = 16;

	/**
	 * 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);

		// 入力項目のワンタイムパスワードを取得
		String onetimePwd = (String)ccMsg.get(REQ_KEY_ONETIME_PWD);

		// 入力項目を削除
		ccMsg.remove(REQ_KEY_ONETIME_PWD);

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

			// ワンタイムパスワードを初期化ベクトルと受付番号(暗号化済)に分割
			String iv = onetimePwd.substring(0, IV_LEN);
			String enMskmshoNo = onetimePwd.substring(IV_LEN);

			// 受付番号を復号化（プロパティファイルの共通暗号鍵自体が暗号化されているため、暗号鍵を復号化してから使用する）
			String key = JFUCommonUtil.decryptKey("ENCRYPT_KEY", JCMAPLConstMgr.getString("FU_WEBMSKM_SHOKAI_ENCRYPTION_KEY"));
			String deMskmshoNo = "";
			try
			{
				deMskmshoNo = JFUDecryptAES.decryptAES(key, iv, enMskmshoNo);
			}
			catch (Exception e)
			{
				outBusLog(onetimePwd, "受付番号の復号化でException発生");
				// 正常終了(認証結果NG)
				ccMsg.put(RES_AUTH_RESULT, AUTH_RESULT_NG);
				param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_0000);
				param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null);
				return param;
			}

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

			// 量販訪販Webアクセス認証キー一意照会サービスIF実行
			CAANMsg[] efu0371a010CbsMsgList = execEFU0371A010(handle, scCall, param, fixedText, iv);

			// 関連チェック
			if (!checkKnrnParam(onetimePwd, efu0371a010CbsMsgList, deMskmshoNo, iv))
			{
				// 正常終了(認証結果NG)
				ccMsg.put(RES_AUTH_RESULT, AUTH_RESULT_NG);
				param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_0000);
				param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null);
				return param;
			}

			// 量販訪販Webアクセス認証キー変更サービスIF実行
			String updDtm = efu0371a010CbsMsgList[0].getString(EFU0371A010CBSMsg1List.UPD_DTM);
			execEFU0371C010(handle, scCall, param, fixedText, iv, updDtm);

			// 受付番号に復号化した受付番号を設定
			ccMsg.put(RES_MSKMSHO_NO, deMskmshoNo);
		}
		catch (SCCallException scCallEx)
		{
			// システムエラー
			param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_9000);
			param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, RETURN_MESSAGE_SYSTEM_ERROR);
			outBusLog(onetimePwd, RETURN_MESSAGE_SYSTEM_ERROR);
			return param;
		}

		// 正常終了(認証結果OK)
		ccMsg.put(RES_AUTH_RESULT, AUTH_RESULT_OK);
		param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_0000);
		param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null);
		return param;
	}

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

		if (JFUBPCommon.isNull(onetimePwd))
		{
			// 必須チェックエラー
			Map<String, String> errMap = new HashMap<String, String>();
			errMap.put(ERROR_CODE, RES_KEY_ERROR_CODE_1001);
			errMap.put(ERROR_MESSAGE, String.format("%s:", REQ_KEY_ONETIME_PWD));
			errList.add(errMap);
			outBusLog(onetimePwd, "単項目チェックエラー（必須チェック）");
		}
		else if (onetimePwd.length() < (IV_LEN))
		{
			// 桁数チェックエラー
			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", REQ_KEY_ONETIME_PWD, onetimePwd));
			errList.add(errMap);
			outBusLog(onetimePwd, "単項目チェックエラー（桁数チェック）");
		}

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

		return true;
	}

	/**
	 * 関連チェックを行い、チェック結果を返します。
	 * <br/>
	 * @param onetimePwd
	 * @param cbsMsgList
	 * @param deMskmshoNo
	 * @param iv
	 * @return チェックの判定
	 * @throws Exception
	 */
	private boolean checkKnrnParam(String onetimePwd, CAANMsg[] cbsMsgList, String deMskmshoNo, String iv) throws Exception
	{
		if (cbsMsgList == null || cbsMsgList.length == 0)
		{
			// 該当データなし
			outBusLog(onetimePwd, "関連チェックエラー（該当データなし）");
			return false;
		}

		if (!JFUStrConst.CD00016_0.equals(cbsMsgList[0].getString(EFU0371A010CBSMsg1List.WEB_ACCSS_NSKEY_STAT_CD)))
		{
			// Webアクセス認証キー状態コードが無効
			outBusLog(onetimePwd, "関連チェックエラー（Webアクセス認証キー状態コードが無効）");
			return false;
		}

		String sysDtm = JCCBPCommon.getSysDateTimeStamp();
		if (sysDtm.compareTo(cbsMsgList[0].getString(EFU0371A010CBSMsg1List.YK_KIGEN_DTM)) > 0)
		{
			// ワンタイムキー有効期限切れ
			outBusLog(onetimePwd, "関連チェックエラー（ワンタイムキー有効期限切れ）");
			return false;
		}

		if (!cbsMsgList[0].getString(EFU0371A010CBSMsg1List.INPUT_DATA).equals(deMskmshoNo))
		{
			// 複合化した「受付番号」とレコードの「申込書番号」が異なる
			outBusLog(onetimePwd, "関連チェックエラー（複合化した「受付番号」とレコードの「申込書番号」が異なる）");
			return false;
		}

		return true;
	}

	/**
	 * 量販訪販Webアクセス認証キー一意照会サービスIFを実行します。
	 * <br/>
	 * @param handle セッションハンドル
	 * @param scCall SC呼び出し部品
	 * @param param リクエストパラメータ
	 * @param fixedText ユーザ定義文字列
	 * @param iv 初期化ベクトル
	 * @return
	 * @throws Exception
	 */
	private CAANMsg[] execEFU0371A010(SessionHandle handle, ServiceComponentRequestInvoker scCall,
			IRequestParameterReadWrite param, String fixedText, String iv) throws Exception
	{
		CAANMsg[] result = null;
		CAANMsg efu0371a010Msg = null;

		// 上りマッピング
		Object[][] efu0371a010 = {
				{ EFU0371A010CBSMsg.TEMPLATEID, TEMPLATE_ID_EFU0371A010 },
				{ EFU0371A010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1 },
				{ EFU0371A010CBSMsg.KEY_RH_VH_WEB_ACCSS_NSKEY, nullToStr(iv) } };

		// サービスIF実行
		efu0371a010Msg = callSC(handle, scCall, param, fixedText, efu0371a010);
		result = efu0371a010Msg.getCAANMsgList(EFU0371A010CBSMsg.EFU0371A010CBSMSG1LIST);

		return result;
	}

	/**
	 * 量販訪販Webアクセス認証キー変更サービスIFを実行します。
	 * <br/>
	 * @param handle セッションハンドル
	 * @param scCall SC呼び出し部品
	 * @param param リクエストパラメータ
	 * @param fixedText ユーザ定義文字列
	 * @param iv 初期化ベクトル
	 * @param updDtm 更新年月日
	 * @throws Exception
	 */
	private void execEFU0371C010(SessionHandle handle, ServiceComponentRequestInvoker scCall,
			IRequestParameterReadWrite param, String fixedText, String iv, String updDtm) throws Exception
	{
		// 上りマッピング
		Object[][] efu0371c010 = {
				{ EFU0371C010CBSMsg.TEMPLATEID, TEMPLATE_ID_EFU0371C010 },
				{ EFU0371C010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1 },
				{ EFU0371C010CBSMsg.RH_VH_WEB_ACCSS_NSKEY, iv },
				{ EFU0371C010CBSMsg.WEB_ACCSS_NSKEY_STAT_CD, JFUStrConst.CD00016_1 },
				{ EFU0371C010CBSMsg.UPD_DTM_BF, updDtm } };

		// サービスIF実行
		callSC(handle, scCall, param, fixedText, efu0371c010);
	}

	/**
	 * 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 onetimePwd
	 * @param msg
	 */
	private void outBusLog(String onetimePwd, String msg)
	{
		StringBuffer outBusLogMsg = new StringBuffer();
		outBusLogMsg.append("FUIFE204#JFUWebMskmNyoHyojiKahiCC#onetime_pwd(").append(onetimePwd).append(")：").append(msg);
		JSYejbLog.println(JSYLogBase.EXECUTION, this.getClass(), outBusLogMsg);
	}

}