/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JKKPaywayAddLoginNinsyoUkCC * ソースファイル名：JKKPaywayAddLoginNinsyoUkCC.java * 作成者 ：富士通 * 日付 ：2023年01月18日 *＜機能概要＞ * 支払方法登録ログイン認証受付(FUIFE500)の共通コンポーネント *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v64.0.0 2023/01/18 FJ)松永 新規作成 **********************************************************************/ 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.common.check.DatetimeCheck; import com.fujitsu.futurity.model.common.check.HalfCharCheck; import com.fujitsu.futurity.model.common.check.LengthCheck; import com.fujitsu.futurity.model.common.check.MixCharCheck; import com.fujitsu.futurity.model.ejb.common.JSYejbLog; import eo.common.constant.JFUStrConst; import eo.common.constant.JKKStrConst; import eo.common.constant.JPCModelConstant; import eo.common.util.JFUCommonUtil; import eo.common.util.JFUDecryptAES; import eo.ejb.cbs.cbsmsg.ECK0011A010CBSMsg; import eo.ejb.cbs.cbsmsg.ECK0011A010CBSMsg1List; import eo.ejb.cbs.cbsmsg.ECK0201B001CBSMsg; import eo.ejb.cbs.cbsmsg.ECK0201B001CBSMsg1List; import eo.ejb.cbs.cbsmsg.EKK3501A010CBSMsg; import eo.ejb.cbs.cbsmsg.EKK3501A010CBSMsg1List; public class JKKPaywayAddLoginNinsyoUkCC extends AbstractCommonComponent { /** テンプレートID mineo譲渡受付管理一意照会 */ private static final String TEMPLATE_ID_EKK3501A010 = "EKK3501A010"; /** テンプレートID お客様一意照会 */ private static final String TEMPLATE_ID_ECK0011A010 = "ECK0011A010"; /** テンプレートID 連絡先一覧照会 */ private static final String TEMPLATE_ID_ECK0201B001 = "ECK0201B001"; /** CCパラメータ：ボディ部情報 */ private static final String BODY_INFO = "BODY_INFO"; /** 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 = "システムエラー"; /** リターンメッセージ_復号化処理エラー */ public static final String RETURN_MESSAGE_DECRYPTION_ERROR = "mineo譲渡受付番号の復号化でException発生"; /** 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"; /** リクエストパラメータキー URLキー */ private static final String REQ_KEY_URL_KEY = "url_key"; /** リクエストパラメータキー 生年月日 */ private static final String REQ_KEY_BIRTHD = "birthd"; /** リクエストパラメータキー 契約者カナ名 */ private static final String REQ_KEY_KEISHA_NM_KANA = "keisha_nm_kana"; /** リクエストパラメータキー 連絡先電話番号 */ private static final String REQ_KEY_RRKS_TELNO = "rrks_telno"; /** レスポンス 認証結果 */ private static final String RES_AUTH_RESULT = "ninsho_result"; /** レスポンス SYSID */ private static final String RES_SYSID = "sysid"; /** 認証結果 OK */ private static final String AUTH_RESULT_OK = "1"; /** 認証結果 NG */ private static final String AUTH_RESULT_NG = "0"; /** 初期化ベクトル長 */ private static final int IV_LEN = 16; /** 空文字 */ private static final String BLANK = ""; /** * 支払方法登録ログイン認証受付を行います。 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @return リクエストパラメータ * @throws Throwable 例外が発生した場合 */ @SuppressWarnings("unchecked") public IRequestParameterReadWrite execute( SessionHandle handle , IRequestParameterReadWrite param , String fixedText ) throws Throwable { // 返却したい値を格納するマップ Map returnMap = new HashMap(); // リクエストパラメータを格納しているマップ Map ccMsg = (Map) param.getData(fixedText); // エラー情報を格納しているマップ Map errMap = new HashMap(); // エラー情報マップリスト List> errList = new ArrayList>(); try { // 単項目チェック if (!checkUnitParam(ccMsg)) { // 業務エラー ccMsg.put(BODY_INFO, returnMap); // body部がnullにならないよう空で返しています。 param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_5000); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null); return param; } // URLキーを初期化ベクトルとmineo譲渡受付番号(暗号化済)に分割 String urlKey = (String)ccMsg.get(REQ_KEY_URL_KEY); String iv = urlKey.substring(0, IV_LEN); String enMineoNo = urlKey.substring(IV_LEN); // 暗号化したmineo譲渡受付番号が取得できない場合 if (enMineoNo == null || enMineoNo.isEmpty()) { // 認証結果NGで正常終了 returnMap.put(RES_AUTH_RESULT, AUTH_RESULT_NG); returnMap.put(RES_SYSID, BLANK); param.setData(fixedText, returnMap); param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_0000); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null); return param; } // 復号化処理 String key = JFUCommonUtil.decryptKey("ENCRYPT_KEY", JCMAPLConstMgr.getString("FU_WEBMSKM_SHOKAI_ENCRYPTION_KEY")); String deMineoNo = ""; try { // 復号化実行 deMineoNo = JFUDecryptAES.decryptAES(key, iv, enMineoNo); } catch (Exception e) { outBusLog(ccMsg, RETURN_MESSAGE_DECRYPTION_ERROR); // 認証結果NGで正常終了 returnMap.put(RES_AUTH_RESULT, AUTH_RESULT_NG); returnMap.put(RES_SYSID, BLANK); param.setData(fixedText, returnMap); param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_0000); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null); return param; } // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // mineo譲渡受付管理一意照会サービスIF実行 CAANMsg[] ekk3501a010CbsMsgList = callEKK3501A010(handle, scCall, param, fixedText, deMineoNo); // 検索結果がない場合、処理終了 if (ekk3501a010CbsMsgList == null || ekk3501a010CbsMsgList.length == 0) { // 業務エラーで処理終了 ccMsg.put(BODY_INFO, returnMap); errMap.put(ERROR_CODE, RES_KEY_ERROR_CODE_2001); errMap.put(ERROR_MESSAGE, BLANK); errList.add(errMap); ccMsg.put(ERROR_INFO, errList); param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_5000); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null); return param; } String useKh = ekk3501a010CbsMsgList[0].getString(EKK3501A010CBSMsg1List.USE_KH); String ykKigen = ekk3501a010CbsMsgList[0].getString(EKK3501A010CBSMsg1List.YK_KIGEN_DTM); String currentTime = JFUBPCommon.getSysDateTimeStamp(); // 利用可否が "1"：否 または、有効期限が超過している場合 if ("1".equals(useKh) || (!JFUBPCommon.isNull(ykKigen) && ykKigen.compareTo(currentTime) < 0)) { // 業務エラーで処理終了 ccMsg.put(BODY_INFO, returnMap); errMap.put(ERROR_CODE, RES_KEY_ERROR_CODE_2001); errMap.put(ERROR_MESSAGE, BLANK); errList.add(errMap); ccMsg.put(ERROR_INFO, errList); param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_5000); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null); return param; } // 変数初期化 String birthd = BLANK; String custKana = BLANK; String telno = BLANK; // 取得したmineo譲渡受付管理のレコードからSYSIDを取得 String sysid = ekk3501a010CbsMsgList[0].getString(EKK3501A010CBSMsg1List.SYSID); // SYSIDをキーにお客様一意照会サービスIF実行 CAANMsg[] eck0011a010CbsMsgList = callECK0011A010(handle, scCall, param, fixedText, sysid); // 取得できない場合 if (eck0011a010CbsMsgList == null || eck0011a010CbsMsgList.length == 0) { // 認証結果NGで正常終了 returnMap.put(RES_AUTH_RESULT, AUTH_RESULT_NG); returnMap.put(RES_SYSID, BLANK); param.setData(fixedText, returnMap); param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_0000); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null); return param; } // お客様生年月日・お客様カナ名を変数に設定 birthd = eck0011a010CbsMsgList[0].getString(ECK0011A010CBSMsg1List.CUST_BIRTHD); custKana = eck0011a010CbsMsgList[0].getString(ECK0011A010CBSMsg1List.CUST_KANA); // SYSIDをキーに連絡先一覧照会サービスIF実行して連絡先電話番号を取得 CAANMsg[] eck0201b001List = callECK0201B001(handle, scCall, param, fixedText, sysid); // 取得できたレコードから連絡方法が「電話番号」かつ、 // 連絡先分類コードが「コンテンツ系連絡先」の電話番号を取得する。 for(CAANMsg eck0201b001 : eck0201b001List) { String rrkWayCd = eck0201b001.getString(ECK0201B001CBSMsg1List.RRK_WAY_CD); String rrksBunruiCd = eck0201b001.getString(ECK0201B001CBSMsg1List.RRKS_BUNRUI_CD); if ("003".equals(rrkWayCd) && "1".equals(rrksBunruiCd)) { // 電話番号を変数に設定 telno = eck0201b001.getString(ECK0201B001CBSMsg1List.TELNO); } } // 取得できない場合 if (telno == null || BLANK.equals(telno)) { // 認証結果NGで正常終了 returnMap.put(RES_AUTH_RESULT, AUTH_RESULT_NG); returnMap.put(RES_SYSID, BLANK); param.setData(fixedText, returnMap); param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_0000); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null); return param; } // 設定した変数とリクエストパラメータを比較 // 契約者カナ名とお客様カナ名はスペースを除去して比較する // どれか一つでも一致しない場合 if (!(ccMsg.get(REQ_KEY_BIRTHD).equals(birthd) && ccMsg.get(REQ_KEY_KEISHA_NM_KANA).toString().replaceAll("　", "").equals(custKana.replaceAll("　", "")) && ccMsg.get(REQ_KEY_RRKS_TELNO).equals(telno))) { // 認証結果NGで正常終了 returnMap.put(RES_AUTH_RESULT, AUTH_RESULT_NG); returnMap.put(RES_SYSID, BLANK); param.setData(fixedText, returnMap); param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_0000); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null); return param; } // 認証結果OKで正常終了 returnMap.put(RES_AUTH_RESULT, AUTH_RESULT_OK); returnMap.put(RES_SYSID, sysid); param.setData(fixedText, returnMap); param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_0000); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, null); return param; } catch (SCCallException scCallEx) { // システムエラー outBusLog(ccMsg, RETURN_MESSAGE_SYSTEM_ERROR); param.setData(fixedText, returnMap); param.setControlMapData(SCControlMapKeys.RETURN_CODE, RETURN_CD_9000); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, RETURN_MESSAGE_SYSTEM_ERROR); return param; } } /** * 単項目チェックを行い、チェック結果を返します。 *
* @param ccMsg リクエストパラメータを格納したマップ * @return チェックの判定 * @throws Exception */ private boolean checkUnitParam(Map ccMsg) throws Exception { List> errList = new ArrayList>(); // URLキー String urlKey = (String)ccMsg.get(REQ_KEY_URL_KEY); // 必須チェック if (urlKey == null || urlKey.trim().isEmpty()) { // 必須チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1001,REQ_KEY_URL_KEY, null)); outBusLog(ccMsg, "単項目チェックエラー（必須チェック）"); } // 桁数チェック else if (urlKey.length() < (IV_LEN)) { // 桁数チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1003, REQ_KEY_URL_KEY, urlKey)); outBusLog(ccMsg, "単項目チェックエラー（桁数チェック）"); } // 生年月日 String birthd = (String) ccMsg.get(REQ_KEY_BIRTHD); // 必須チェック if (birthd == null || birthd.trim().isEmpty()) { // 必須チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1001, REQ_KEY_BIRTHD, null)); outBusLog(ccMsg, "単項目チェックエラー（必須チェック）"); } // 属性チェック else if (!DatetimeCheck.isDateCheck(birthd)) { // 属性チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1002, REQ_KEY_BIRTHD, birthd)); outBusLog(ccMsg, "単項目チェックエラー（属性チェック）"); } // 桁数チェック else if (!LengthCheck.isLength2Check(birthd, 8, 8)) { // 桁数チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1003, REQ_KEY_BIRTHD, birthd)); outBusLog(ccMsg, "単項目チェックエラー（桁数チェック）"); } // 契約者カナ名 String keishaNmKana = (String) ccMsg.get(REQ_KEY_KEISHA_NM_KANA); // 必須チェック if (keishaNmKana == null || keishaNmKana.trim().isEmpty()) { // 必須チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1001, REQ_KEY_KEISHA_NM_KANA, null)); outBusLog(ccMsg, "単項目チェックエラー（必須チェック）"); } // 属性チェック else if (!MixCharCheck.isMeigiNinKanaCheck(keishaNmKana)) { // 属性チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1002, REQ_KEY_KEISHA_NM_KANA, keishaNmKana)); outBusLog(ccMsg, "単項目チェックエラー（属性チェック）"); } // 桁数チェック else if (!LengthCheck.isLength2Check(keishaNmKana, 1, 121)) { // 桁数チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1003, REQ_KEY_KEISHA_NM_KANA, keishaNmKana)); outBusLog(ccMsg, "単項目チェックエラー（桁数チェック）"); } // 電話番号 String rrksTelno = (String) ccMsg.get(REQ_KEY_RRKS_TELNO); // 必須チェック if (rrksTelno == null || rrksTelno.trim().isEmpty()) { // 必須チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1001, REQ_KEY_RRKS_TELNO, null)); outBusLog(ccMsg, "単項目チェックエラー（必須チェック）"); } // 属性チェック else if (!HalfCharCheck.isTelno1Check(rrksTelno)) { // 属性チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1002, REQ_KEY_RRKS_TELNO, rrksTelno)); outBusLog(ccMsg, "単項目チェックエラー（属性チェック）"); } // 桁数チェック else if (!LengthCheck.isLength2Check(rrksTelno, 1, 12)) { // 桁数チェックエラー errList.add(getErrInfMap(RES_KEY_ERROR_CODE_1003, REQ_KEY_RRKS_TELNO, rrksTelno)); outBusLog(ccMsg, "単項目チェックエラー（桁数チェック）"); } // エラーが存在する場合 if (errList.size() > 0) { ccMsg.put(ERROR_INFO, errList); return false; } return true; } /** * 単項目チェックのエラーマップ作成メソッドです。 * * @param errorCode エラーの種類 * @param itemName 項目名 * @param itemValue 項目の値 * @return 必須エラーマップ */ private Map getErrInfMap(String errorCode, String itemName, String itemValue) { Map returnMap = new HashMap(); if (RES_KEY_ERROR_CODE_1001.equals(errorCode)) { // エラーメッセージ設定 String errMessage = itemName + JKKStrConst.COLON; returnMap.put(ERROR_CODE, errorCode); returnMap.put(ERROR_MESSAGE, errMessage); } else if (RES_KEY_ERROR_CODE_1002.equals(errorCode) || RES_KEY_ERROR_CODE_1003.equals(errorCode)) { // エラーメッセージ設定 String errMessage = itemName + JKKStrConst.COLON + itemValue; returnMap.put(ERROR_CODE, errorCode); returnMap.put(ERROR_MESSAGE, errMessage); } return returnMap; } /** * mineo譲渡受付管理一意照会を呼び出す。 * 上りマッピング、実行を行います。 *
* @param handle セッションハンドル * @param scCall SC呼び出し部品 * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param deUrlKey 復号化したmieno譲渡受付番号 * @return * @throws Exception */ private CAANMsg[] callEKK3501A010( SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String fixedText, String deUrlKey) throws Exception { CAANMsg[] result = null; CAANMsg ekk3501a010Msg = null; // 上りマッピング Object[][] ekk3501a010 = { { EKK3501A010CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK3501A010 }, { EKK3501A010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1 }, { EKK3501A010CBSMsg.KEY_MINEO_JOTO_UK_NO, nullToStr(deUrlKey) } }; // サービスIF実行 ekk3501a010Msg = callSC(handle, scCall, param, fixedText, ekk3501a010); result = ekk3501a010Msg.getCAANMsgList(EKK3501A010CBSMsg.EKK3501A010CBSMSG1LIST); return result; } /** * お客さま一意照会 を呼び出す。 * 上りマッピング、実行を行います。 * * @param handle セッションハンドル * @param scCall SC呼び出し部品 * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param sysid SYSID * @return サービスIF実行結果 * @throws Throwable */ private CAANMsg[] callECK0011A010( SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String fixedText, String sysid)throws Throwable { CAANMsg[] result = null; CAANMsg eck0011a010Msg = null; // 上りマッピング Object[][] eck0011a010 = { {ECK0011A010CBSMsg.TEMPLATEID, TEMPLATE_ID_ECK0011A010} , {ECK0011A010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_2} , {ECK0011A010CBSMsg.KEY_SYSID, sysid} , {ECK0011A010CBSMsg.KEY_RSV_APLY_YMD, JPCBPCommon.getOpeDate(null)} }; // サービスIF実行 eck0011a010Msg = callSC(handle, scCall, param, fixedText, eck0011a010); result = eck0011a010Msg.getCAANMsgList(ECK0011A010CBSMsg.ECK0011A010CBSMSG1LIST); return result; } /** * 連絡先一覧照会 を呼び出す。 * 上りマッピング、実行を行います。 * * @param handle セッションハンドル * @param scCall SC呼び出し部品 * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param sysid SYSID * @return 取得結果 * @throws Throwable 例外が発生した場合 */ private CAANMsg[] callECK0201B001( SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String fixedText, String sysid)throws Throwable { CAANMsg[] result = null; CAANMsg eck0201b001Msg = null; // 上りマッピング Object[][] eck0201b001 = { {ECK0201B001CBSMsg.TEMPLATEID, TEMPLATE_ID_ECK0201B001} , {ECK0201B001CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1} , {ECK0201B001CBSMsg.KEY_SYSID, sysid} }; // SC実行 eck0201b001Msg = callSC(handle, scCall, param, fixedText, eck0201b001); result = eck0201b001Msg.getCAANMsgList(ECK0201B001CBSMsg.ECK0201B001CBSMSG1LIST); return result; } /** * SC(サービスインターフェイス）を呼び出す。 *
* @param handle セッションハンドル * @param scCall SC呼び出し部品 * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param mappingData マッピングデータ * @return サービスIF実行結果 * @throws Exception */ @SuppressWarnings("unchecked") private CAANMsg callSC( SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String fixedText, Object[][] mappingData) throws Exception { // 上りマッピング処理 HashMap paramMap = editInMsg(param, mappingData); // サービスIF実行呼び出し Map result = scCall.run(paramMap, handle); // SCの戻り値からCAANMsgを取得 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 errList = (ArrayList)param.getControlMapData(SCControlMapKeys.ERROR_INFO); // エラー情報のマップない場合 if (errList == null) { errList = new ArrayList(); } // コントロールマップに設定 param.setControlMapData(SCControlMapKeys.ERROR_INFO, TemplateErrorUtil.getErrorInfo(result, errList)); // 異常の場合、SCCallExceptionを生成してスローする if (!("0".equals(return_code.toString()) && 0 == status)) { throw new SCCallException("戻り値不正", return_code.toString(), status); } return msg; } /** * 共通項目のメッセージを作成します。 * * @param param リクエストパラメータ * @param mappingData マッピングデータ * @return HashMap * @throws RequestParameterException リクエストパラメータの操作でエラーが発生した場合 */ private HashMap editInMsg(IRequestParameterReadWrite param, Object[][] mappingData) throws RequestParameterException { HashMap paramMap = new HashMap(); // 【取得元：電文ヘッダ(ヘッダ)】 // 電文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の呼び出しエラー時のレスポンス情報作成 *
* @param param リクエストパラメータ * @param templates CAANMsgクラス * @param returnCode リターンコード * @param fixedText ユーザ定義文字列 * @param mappingData マッピングデータ * @return IRequestParameterReadWrite * @throws RequestParameterException */ @SuppressWarnings("unchecked") 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 inMap = null; // ユーザデータ情報 inMap = (HashMap)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の場合空文字を返却します。 * * @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 ccMsg, String msg) { StringBuffer outBusLogMsg = new StringBuffer(); outBusLogMsg.append("KKIFExxx#JKKPaywayAddLoginNinsyoUkCC#url_key(").append(ccMsg.get(REQ_KEY_URL_KEY)).append(")：").append(msg); JSYejbLog.println(JSYLogBase.EXECUTION, this.getClass(), outBusLogMsg); } }