/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JKKGiftCdHakkoReqCMPCC * ソースファイル名：JKKGiftCdHakkoReqCMPCC.java * 作成者 ：FJ * 日付 ：2022年01月24日 *＜機能概要＞ * ギフトコード発行依頼(CMP)CC *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v57.00.00 2022/01/24 FJ)北村 ANK-4208-00-00_電子マネー特典導入 **********************************************************************/ package com.fujitsu.futurity.bp.custom.common; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; 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.CCException; import com.fujitsu.futurity.bp.x21.cc.exception.SCCallException; import com.fujitsu.futurity.common.JCMConstants; 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 eo.common.constant.JKKStrConst; import eo.common.constant.JPCModelConstant; import eo.ejb.cbs.cbsmsg.EKK3371C020CBSMsg; import eo.ejb.cbs.cbsmsg.EKK3371C030CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0081B002CBSMsg; import eo.ejb.cbs.cbsmsg.EKK3371B010CBSMsg; import eo.ejb.cbs.cbsmsg.EKK3371B010CBSMsg1List; import eo.ejb.cbs.cbsmsg.EKKA0100001CBSMsg; import eo.ejb.cbs.cbsmsg.EKKA0100002CBSMsg; /** * ギフトコード発行依頼(CMP)CC * * @author 富士通 */ public class JKKGiftCdHakkoReqCMPCC extends AbstractCommonComponent { // ---------- // TemplateID // ---------- /** サービス契約一覧照会(SYSID) */ private static final String TEMPLATE_ID_EKK0081B002 = "EKK0081B002"; /** キャンペーン適用情報一覧照会（SYSID） */ private static final String TEMPLATE_ID_EKK3371B010 = "EKK3371B010"; /** ギフトコード発行依頼（MVNO用） */ private static final String TEMPLATE_ID_EKKA0100002 = "EKKA0100002"; /** キャンペーン適用情報連携状態更新 */ private static final String TEMPLATE_ID_EKK3371C020 = "EKK3371C020"; /** ギフトコード発行依頼更新 */ private static final String TEMPLATE_ID_EKK3371C030 = "EKK3371C030"; // ------------------------ // CCパラメータ // ------------------------ /** CCパラメータ：エラー情報 */ private static final String CC_PARAM_ERROR_INFO = "ERROR_INFO"; /** エラーコードマップキー*/ private static final String CC_PARAM_ERR_CD = "errCode"; /** エラーメッセージマップキー*/ private static final String CC_PARAM_ERR_MSG = "errMessage"; // ------------------------ // パラメータ定数 // ------------------------ /** パラメータ SYSID */ private static final String IN_PARAM_SYSID = "sysid"; /** パラメータ プレゼントコード */ private static final String IN_PARAM_PRESENT_CD = "present_cd"; // ---------- // エラー定数 // ---------- /** リターンメッセージの書式指定文字列 */ private static final String RETURN_MESSAGE_FORMAT = "%1$04d"; /** エラー項目接尾辞 */ private static final String ERRITEM_SUFFIX = "_err"; /** リターンメッセージ取得キー */ private static final String RETURN_MESSAGE_STRING = "RETURN_MESSAGE_"; /** エラーコード 必須チェックエラー*/ private static final String REQUIRED_ERROR = "1001"; /** エラーコード 属性チェックエラー*/ private static final String ATTRIBUTE_ERROR = "1002"; /** エラーコード 桁数チェックエラー*/ private static final String LENGTH_ERROR = "1003"; /** エラーコード サービス契約_存在チェックエラー*/ private static final String SVC_EXISTS_ERROR = "2001"; /** エラーコード プレゼントコード_存在チェックエラー*/ private static final String PRE_EXISTS_ERROR = "2002"; /** エラーコード 処理ステータス_チェックエラー*/ private static final String TRN_STAT_ERROR = "2003"; /** エラーコード 連携エラー*/ private static final String RENKEI_ERROR = "3001"; // ---------- // ギフトコード発行依頼実行結果判定用定数 // ---------- /** 正常終了*/ private static final String SUCCESS = "000"; /**認証エラー*/ private static final String ERR_CD_400 = "400"; /**業務エラー*/ private static final String ERR_CD_500 = "500"; /**メンテナンスモード*/ private static final String ERR_CD_800 = "800"; /**連携状態コード*/ private static final String RNK_STATE_1 = "1"; /**連携状態コード*/ private static final String RNK_STATE_2 = "2"; /**連携状態コード*/ private static final String RNK_STATE_3 = "3"; /**連携状態コード*/ private static final String RNK_STATE_9 = "9"; /**連携状態コード*/ private static final String RNK_STATE_E = "E"; /** 処理ステータス 連携済み*/ private static final String TRN_STAT_RENKEIZUMI = "010"; /** 空文字 */ private static final String EMPTY = ""; /** *

* ギフトコード発行依頼(CMP)CCを実行する。 *

* @param inCBSMsg CBSメッセージ * @param inContext ディスパッチコンテキスト * @throws Throwable */ public IRequestParameterReadWrite execute(SessionHandle handle, IRequestParameterReadWrite param, String fixedText) throws Throwable { // ユーザデータ情報 Map ccMsg = (Map)param.getData(fixedText); try { // パラメータチェックを実行する // 単項目チェック if (!checkUnitParam(ccMsg)) { // 単項目チェックでエラーの場合は業務エラー param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_5000); return param; } // ===リクエストパラメータ=== // SYSID String sysid = (String)ccMsg.get(IN_PARAM_SYSID); // プレゼントコード String presentcd = (String)ccMsg.get(IN_PARAM_PRESENT_CD); // ===レスポンスパラメータ=== // レスポンスパラメータはない // サービス契約一覧照会を実行する。 CAANMsg[] ekk0081b002List = callEKK0081B002(handle, param, fixedText, sysid); // 取得件数が0件の場合 if (ekk0081b002List == null || ekk0081b002List.length == 0) { // SYSID存在チェックエラー List> errList = new ArrayList>(); errList.add(createErrorMap(IN_PARAM_SYSID, sysid, SVC_EXISTS_ERROR)); ccMsg.put(CC_PARAM_ERROR_INFO, errList); // 業務エラー param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_5000); return param; } // キャンペーン適用情報一覧照会（SYSID）を呼び出す。 CAANMsg[] ekk3371b010List = callEKK3371B010(handle, param, fixedText, sysid, presentcd); // 取得件数が0件の場合 if (ekk3371b010List == null || ekk3371b010List.length == 0) { // プレゼントコード存在チェックエラー List> errList = new ArrayList>(); errList.add(createErrorMap(IN_PARAM_PRESENT_CD, presentcd, PRE_EXISTS_ERROR)); ccMsg.put(CC_PARAM_ERROR_INFO, errList); // 業務エラー param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_5000); return param; } // データ抽出項目設定番号を取得する。 String dchskmstNo = ekk3371b010List[0].getString(EKK3371B010CBSMsg1List.DCHSKMST_NO); // 処理ステータスを取得する。 String trnStat = ekk3371b010List[0].getString(EKK3371B010CBSMsg1List.TRN_STAT); // サービス契約番号を取得する。 String svcKeiNo = ekk3371b010List[0].getString(EKK3371B010CBSMsg1List.RNKI_SVC_KEI_NO); // 更新日時を取得する。 String upd_dtm_bf = ekk3371b010List[0].getString(EKK3371B010CBSMsg1List.UPD_DTM); // 処理ステータスの値が連携済以外の場合、エラー。 if (!TRN_STAT_RENKEIZUMI.equals(trnStat)) { // プレゼントコード処理状態チェックエラー List> errList = new ArrayList>(); errList.add(createErrorMap(IN_PARAM_PRESENT_CD, presentcd, TRN_STAT_ERROR)); ccMsg.put(CC_PARAM_ERROR_INFO, errList); // 業務エラー param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_5000); return param; } // ギフトコード発行依頼(MVNO)（EKKA0100002）を呼び出す。 CAANMsg ekka0100002 = callEKKA0100002(handle, param, fixedText, svcKeiNo, presentcd); if (ekka0100002 != null && SUCCESS.equals(ekka0100002.getString(EKKA0100002CBSMsg.RESULTCODE))) { // ギフトコード発行依頼(MVNO)が正常な場合 // ギフトコード発行依頼更新 CAANMsg ekk3371c030 = callEKK3371C030(handle, param, fixedText, dchskmstNo, upd_dtm_bf); } else { // ギフトコード発行依頼(MVNO)がエラーの場合 // キャンペーン適用情報連携状態更新 CAANMsg ekk3371c020 = callEKK3371C020(handle, param, fixedText, dchskmstNo, upd_dtm_bf, ekka0100002); List> errList = new ArrayList>(); errList.add(createErrorMap(EMPTY, EMPTY, RENKEI_ERROR)); ccMsg.put(CC_PARAM_ERROR_INFO, errList); // 業務エラー param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_5000); return param; } // 正常終了 param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_0000); } catch (Throwable e) { // 更新に失敗した場合は param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_9000); throw new CCException("", e); } return param; } /** * 単項目チェック * @param ccMsg * @return チェックの判定 * @throws Exception */ private boolean checkUnitParam(Map ccMsg) { // エラーリスト List> errList = new ArrayList>(); String itemName = null; String itemValue = null; // SYSID itemName = IN_PARAM_SYSID; itemValue = (String)ccMsg.get(itemName); // 必須チェック if ( itemValue == null || "".equals(itemValue) ) { // 必須チェックエラー errList.add(createErrorMap(itemName, itemValue, REQUIRED_ERROR)); } else if (!HalfCharCheck.isEnNumber1Check(itemValue)) { // 属性チェックエラー errList.add(createErrorMap(itemName, itemValue, ATTRIBUTE_ERROR)); } else if (!LengthCheck.isLength1Check(itemValue, 10)) { // 桁数チェックエラー errList.add(createErrorMap(itemName, itemValue, LENGTH_ERROR)); } // SYSID itemName = IN_PARAM_PRESENT_CD; itemValue = (String)ccMsg.get(itemName); // 必須チェック if ( itemValue == null || "".equals(itemValue) ) { // 必須チェックエラー errList.add(createErrorMap(itemName, itemValue, REQUIRED_ERROR)); } else if (!HalfCharCheck.isEnNumber1Check(itemValue)) { // 属性チェックエラー errList.add(createErrorMap(itemName, itemValue, ATTRIBUTE_ERROR)); } else if (!LengthCheck.isLength2Check(itemValue, 1, 30)) { // 桁数チェックエラー errList.add(createErrorMap(itemName, itemValue, LENGTH_ERROR)); } // エラーが存在する場合 if (errList.size() > 0) { ccMsg.put(CC_PARAM_ERROR_INFO, errList); return false; } return true; } /** * EKK0081B002_サービス契約一覧照会(SYSID)を実行する。 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param sysid SYSID * @return 結果 * @throws Throwable 例外が発生した場合 */ private CAANMsg[] callEKK0081B002(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String sysid) throws Throwable { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // サービス契約一覧照会(SYSID)の上りマッピング Object[][] EKK0081B002In = { {EKK0081B002CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK0081B002}, {EKK0081B002CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_2}, // 機能コード："2" {EKK0081B002CBSMsg.KEY_SYSID, sysid} // ＫＥＹ＿SYSYID }; // サービスIF実行 CAANMsg[] EKK0081B002Out = callSC(handle, scCall, param, fixedText, EKK0081B002In).getCAANMsgList(EKK0081B002CBSMsg.EKK0081B002CBSMSG1LIST); // 結果を返却 return EKK0081B002Out; } /** * EKK3371B010_プレゼントコード一覧照会(SYSID)を実行する。 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param sysid SYSID * @param presentcd プレゼントコード * @return 結果 * @throws Throwable 例外が発生した場合 */ private CAANMsg[] callEKK3371B010(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String sysid, String presentcd) throws Throwable { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // プレゼントコード一覧照会(SYSID)の上りマッピング Object[][] ekk3371b010In = { {EKK3371B010CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK3371B010}, {EKK3371B010CBSMsg.FUNC_CODE, "2"}, // 機能コード："2" {EKK3371B010CBSMsg.KEY_SYSID, sysid}, // ＫＥＹ＿SYSID {EKK3371B010CBSMsg.KEY_PRESENTCD, presentcd} // ＫＥＹ＿プレゼントコード }; // サービスIF実行 CAANMsg[] ekk3371b010Out = callSC(handle, scCall, param, fixedText, ekk3371b010In).getCAANMsgList(EKK3371B010CBSMsg.EKK3371B010CBSMSG1LIST);; // 結果を返却 return ekk3371b010Out; } /** * ギフトコード発行依頼(MVNO) *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @return CAANMsg[] 検索結果 * @throws Throwable */ private CAANMsg callEKKA0100002(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String svcKeiNo, String presentcd) throws Throwable { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // ギフトコード発行依頼(MVNO) EKKA0100002 Object[][] ekka0100002In = {{EKKA0100002CBSMsg.TEMPLATEID, TEMPLATE_ID_EKKA0100002}, {EKKA0100002CBSMsg.FUNC_CODE, "1"}, {EKKA0100002CBSMsg.CUSTID, svcKeiNo}, {EKKA0100002CBSMsg.PRESENTCD, presentcd} }; // 実行 CAANMsg ekka0100002Out = callSC(handle, scCall, param, fixedText, ekka0100002In); return ekka0100002Out; } /** * ギフトコード発行依頼更新 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param dchskmstNo * @return CAANMsg[] 検索結果 * @throws Throwable */ private CAANMsg callEKK3371C030(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String dchskmstNo ,String upd_dtm_bf) throws Throwable { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // ギフトコード発行依頼更新 EKK3371C030 Object[][] ekk3371c030In = {{EKK3371C030CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK3371C030}, {EKK3371C030CBSMsg.FUNC_CODE, "1"}, {EKK3371C030CBSMsg.DCHSKMST_NO, dchskmstNo}, {EKK3371C030CBSMsg.GIFTID_HAKKO_REQ_YMD, JCCBPCommon.getOpeDate(null)}, {EKK3371C030CBSMsg.LAST_RNK_DTM, JCCBPCommon.getOpeDateTime(null)}, {EKK3371C030CBSMsg.UPD_DTM_BF, upd_dtm_bf}, }; // 実行 CAANMsg ekk3371c030Msg1List = callSC(handle, scCall, param, fixedText, ekk3371c030In); return ekk3371c030Msg1List; } /** * キャンペーン適用情報連携状態更新 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @return CAANMsg[] 検索結果 * @throws Throwable */ private CAANMsg callEKK3371C020(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String dchskmstNo, String upd_dtm_bf, CAANMsg ekka0100002) throws Throwable { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // キャンペーン適用情報連携状態更新 EKK3371C020 Object[][] ekk3371c020In = {{EKK3371C020CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK3371C020}, {EKK3371C020CBSMsg.FUNC_CODE, "1"}, {EKK3371C020CBSMsg.DCHSKMST_NO, dchskmstNo}, {EKK3371C020CBSMsg.LAST_RNK_RSLT_CD, getRnkRsltCd(ekka0100002)}, {EKK3371C020CBSMsg.LAST_RNK_DTM, JCCBPCommon.getOpeDateTime(null)}, {EKK3371C020CBSMsg.UPD_DTM_BF,upd_dtm_bf}, }; // 実行 CAANMsg ekk3371c020Msg1List = callSC(handle, scCall, param, fixedText, ekk3371c020In); return ekk3371c020Msg1List; } /** * 連携結果コード * @param ekka0100001 * @return */ private String getRnkRsltCd(CAANMsg ekka0100001) { // 電文が返却されていない場合 if (ekka0100001 == null) { return RNK_STATE_E; } // 処理結果コード String resultCd = ekka0100001.getString(EKKA0100001CBSMsg.RESULTCODE); // 処理結果詳細コード String resultDtlCd = ekka0100001.getString(EKKA0100001CBSMsg.RESULTDETAILCODE); if (ERR_CD_400.equals(resultCd)) { return RNK_STATE_1; // 認証エラー } if (ERR_CD_500.equals(resultCd)) { return RNK_STATE_2; // 業務エラー } if (ERR_CD_800.equals(resultCd)) { return RNK_STATE_3; // メンテナンスモード } return RNK_STATE_9; } /** * SC(サービスインターフェイス）を呼び出す。 * * @param handle * @param scCall * @param param * @param dataMapKey * @param mappingData * @return CAANMsg * @throws Exception */ private CAANMsg callSC(SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String dataMapKey, Object[][] mappingData) throws Exception { HashMap paramMap = editInMsg(param, mappingData); Map result = scCall.run(paramMap, handle); CAANMsg[] templates = (CAANMsg[])result.get(JCMConstants.TEMPLATE_LIST_KEY); CAANMsg msg = templates[0]; // リターンコード取得 int returnCode = (Integer)result.get(JCMConstants.RET_CD_INT_KEY); int templateStatus = msg.getInt(JCMConstants.STATUS_INT_KEY); if (returnCode != 0) { templateStatus = 9000; } if (JCMAPLConstMgr.getString(RETURN_MESSAGE_STRING + String.format(RETURN_MESSAGE_FORMAT, templateStatus)) == null) { templateStatus = 0; } int bpStatus = 0; Object obj = param.getControlMapData(SCControlMapKeys.RETURN_CODE); if (obj == null) { bpStatus = -1; } else { bpStatus = Integer.parseInt((String)param.getControlMapData(SCControlMapKeys.RETURN_CODE)); } if (templateStatus > bpStatus) { // BPにサービスコンポーネントのステータスを設定する。 String formatStatus = String.format(RETURN_MESSAGE_FORMAT, templateStatus); String message = JCMAPLConstMgr.getString(RETURN_MESSAGE_STRING + formatStatus); param.setControlMapData(SCControlMapKeys.RETURN_CODE, formatStatus); param.setControlMapData(SCControlMapKeys.RETURN_MESSAGE, message); } setErrorInf(msg, (HashMap)param.getData(dataMapKey)); //エラー情報のマップを取得 ArrayList errList = (ArrayList)param.getControlMapData(SCControlMapKeys.ERROR_INFO); if (errList == null) { errList = new ArrayList(); } // コントロールマップに設定 param.setControlMapData(SCControlMapKeys.ERROR_INFO, TemplateErrorUtil.getErrorInfo(result, errList)); /* ◇処理結果の判定*/ // 取得したリターンコード、ステータスの内容を見て異常かどうかの判断をする。 String rtnCode = result.get(JCMConstants.RET_CD_INT_KEY).toString(); Integer status = msg.getInt(JCMConstants.STATUS_INT_KEY); // 異常の場合、SCCallExceptionを生成してスローする if(!("0".equals(rtnCode) && 0 == status.intValue())) { SCCallException scCallEx = new SCCallException("戻り値不正", rtnCode, status); throw scCallEx; } 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 ("".equals(mappingData[i][1])) { template.setNull((String)mappingData[i][0]); } else { template.set((String)mappingData[i][0], mappingData[i][1]); } } setNullToMsg(template); CAANMsg[] templates = new CAANMsg[1]; templates[0] = template; paramMap.put(JCMConstants.TEMPLATE_LIST_KEY, templates); return paramMap; } /** * エラー情報を設定します。 * * @param msg * @param map * */ private void setErrorInf(CAANMsg msg, HashMap map) { Iterator msgKey = msg.getSchema().getSchemaKeySet().iterator(); while (msgKey.hasNext()) { String key = msgKey.next(); if (key.endsWith(ERRITEM_SUFFIX)) { if (!msg.isNull(key)) { if (!map.containsKey(key)) { map.put(key, msg.getString(key)); } } } } } /** * 未入力項目にnullを設定します。 * @param msg */ private void setNullToMsg(CAANMsg msg) { Iterator caanMsgKeys = msg.getSchema().getSchemaKeySet().iterator(); while (caanMsgKeys.hasNext()) { String key = caanMsgKeys.next(); if (key.endsWith(ERRITEM_SUFFIX)) { String tmpKey = key.substring(0, key.length() - 4); if (!msg.containsKeyOfMsgData(tmpKey)) { msg.setNull(tmpKey); } } } } /** * エラーマップ作成メソッドです。 * * @param itemName 項目名 * @return */ private Map createErrorMap(String itemName, String itemValue, String errCd) { Map returnMap = new HashMap(); // エラーメッセージ設定 String errMessage = itemName + JKKStrConst.COLON + itemValue; returnMap.put(CC_PARAM_ERR_CD, errCd); returnMap.put(CC_PARAM_ERR_MSG, errMessage); return returnMap; } }