/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JKKIntrCdHakkoReqCMPLINECC * ソースファイル名：JKKIntrCdHakkoReqCMPLINECC.java * 作成者 ：FJ * 日付 ：2022年11月22日 *＜機能概要＞ * 紹介コード発行依頼（CMP・LINE）CC *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v63.00.00 2022/11/22 FJ）北村 【ANK-4294-00-00】紹介CPの仕組み変更対応 **********************************************************************/ 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.common.util.JPCUtilCommon; import eo.ejb.cbs.cbsmsg.ECK0011A010CBSMsg; import eo.ejb.cbs.cbsmsg.ECK0011A010CBSMsg1List; import eo.ejb.cbs.cbsmsg.ECK0201B040CBSMsg; import eo.ejb.cbs.cbsmsg.ECK0201B040CBSMsg1List; import eo.ejb.cbs.cbsmsg.EKK0081B090CBSMsg1List; import eo.ejb.cbs.cbsmsg.EKK0311D010CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0361B030CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0361B030CBSMsg1List; import eo.ejb.cbs.cbsmsg.EKK0081B090CBSMsg; import eo.ejb.cbs.cbsmsg.EZM0321B010CBSMsg; import eo.ejb.cbs.cbsmsg.EZM0321B010CBSMsg1List; import eo.ejb.common.JCCModelCommon; import eo.ejb.common.edit.JKKejbKK0311NumberParts; /** * 紹介コード発行依頼（CMP・LINE）CC * * @author 富士通 */ public class JKKIntrCdHakkoReqCMPLINECC extends AbstractCommonComponent { // ---------- // TemplateID // ---------- /** サービス契約一覧照会 */ private static final String TEMPLATE_ID_EKK0081B090 = "EKK0081B090"; /** 連絡先一覧照会(紹介者連絡先) */ private static final String TEMPLATE_ID_ECK0201B040 = "ECK0201B040"; /** オプションサービス契約＜ISP＞紹介者Eメール一覧照会 */ private static final String TEMPLATE_ID_EKK0361B030 = "EKK0361B030"; /** お客様一意照会 */ private static final String TEMPLATE_ID_ECK0011A010 = "ECK0011A010"; /** 業務パラメータ一覧照会 */ private static final String TEMPLATE_ID_EZM0321B010 = "EZM0321B010"; /** 紹介登録 */ private static final String TEMPLATE_ID_EKK0311D010 = "EKK0311D010"; // ------------------------ // CCパラメータ // ------------------------ /** CCパラメータ：ボディ情報 */ private final String CC_PARAM_BODY_INFO = "BODY_INFO"; /** 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 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"; /** 単項目チェックでエラー発生 */ public static final int DOMAIN_ERR = 1000; /** 関連チェックでエラー発生 */ public static final int RELATION_ERR = 1100; /** エラーコード サービス契約_存在チェックエラー*/ private static final String SVC_EXISTS_ERROR = "2001"; /** リターンコード(システムエラー) */ public static final String RETURN_CODE_SYSTEMERR = "9000"; // ---------- // 定数 // ---------- /** 予約適用コード（予約）*/ private static final String RSV_APLY_CD_RSV = "1"; /** 予約適用コード（確定）*/ private static final String RSV_APLY_CD_FIX = "2"; /** メール送信コード：未送信 */ private static final String ML_SEND_CD_0 = "0"; /** 紹介種別コード：紹介者 */ private static final String INTR_SBT_CD_1 = "1"; /** テンプレートID(業務パラメータ管理一覧照会) ＫＥＹ＿業務パラメータID */ private static final String KEY_WORK_PARAM_ID_EZM0321B010 = "KK_INTRCD_YK_PRD"; /** エラーコード */ private static final String ERRAR_CD_EA = "EA"; /** *

* 紹介コード発行依頼（CMP・LINE）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); // レスポンス用のパラメータを作成する HashMap responseParam = new HashMap(); ccMsg.put(CC_PARAM_BODY_INFO, responseParam); String opeDate = JCCBPCommon.getOpeDate(null); String intrCd = null; try { // パラメータチェックを実行する // 単項目チェック if (!checkUnitParam(ccMsg)) { // 単項目チェックでエラーの場合は業務エラー param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_5000); return param; } // ===リクエストパラメータ=== // SYSID String sysId = (String)ccMsg.get(IN_PARAM_SYSID); // ===レスポンスパラメータ=== // レスポンスパラメータはない // 契約種別一覧照会（PMP連携用）を実行する。 CAANMsg[] ekk0081b090List = callEKK0081B090(handle, param, fixedText, sysId); // サービス契約の存在チェック if (ekk0081b090List == null || ekk0081b090List.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_2001); return param; } // サービス契約番号を取得する。 String svcKeiNo = ekk0081b090List[0].getString(EKK0081B090CBSMsg1List.SVC_KEI_NO); // 紹介コード採番部品(JKKejbKK0311NumberParts) JKKejbKK0311NumberParts kk3311number = new JKKejbKK0311NumberParts(); // 紹介コード intrCd = kk3311number.getIntrCd(); // 設定メールアドレス String mlad = null; // 連絡先一覧照会(紹介者連絡先)を実行する。 CAANMsg[] eck0201b040List = callECK0201B040(handle, param, fixedText, sysId); // コンテンツ系メールアドレスの存在チェック if (eck0201b040List == null || eck0201b040List.length == 0) { // 存在しない場合、契約メールアドレスを取得する。 mlad = getKeiyakuMlad(handle, param, fixedText, svcKeiNo); } else { // コンテンツ系メールアドレスを設定 mlad = getRrksMailAddress(eck0201b040List); // 対象となるコンテンツ系メールアドレスが存在しない場合 if (mlad == null || mlad.isEmpty()) { // 契約メールアドレスを取得する。 mlad = getKeiyakuMlad(handle, param, fixedText, svcKeiNo); } } // お客様一意照会 CAANMsg[] eck0011a010Out = callECK0011A010(handle, param, fixedText, sysId, opeDate); // 業務パラメータ一覧照会 CAANMsg[] ezm0321b010List = callEZM0321B010(handle, param, fixedText); // 紹介コードの有効範囲日数を取得する。 String work_param_sette_value = ezm0321b010List[0].getString(EZM0321B010CBSMsg1List.WORK_PARAM_SETTE_VALUE); // オンライン運用日に有効範囲日数を加算し、有効期限年月日を設定する。 String set_yk_kigen_ymd = JPCUtilCommon.addDay(opeDate, Integer.parseInt(work_param_sette_value)); // ○EKK0311D010_紹介登録 CAANMsg ekk0311d010out = callEKK0311D010(handle, param, fixedText, intrCd, sysId, svcKeiNo, mlad, set_yk_kigen_ymd, eck0011a010Out); //登録に使用した紹介コードをレスポンスに設定 responseParam.put("intr_cd", intrCd); // 正常終了 param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_0000); } catch (SCCallException e) { // 紹介登録の紹介コード重複チェックエラーの場合 if (RELATION_ERR == e.getStatusCD() && ERRAR_CD_EA.equals(ccMsg.get("intr_cd_err"))) { List> errList = new ArrayList>(); Map returnMap = new HashMap(); returnMap.put(CC_PARAM_ERR_CD, JKKStrConst.RETURN_CD_2002); returnMap.put(CC_PARAM_ERR_MSG, ""); errList.add(returnMap); ccMsg.put(CC_PARAM_ERROR_INFO, errList); // 業務エラー param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_2002); return param; } else { // リターンコード param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_9000); } } catch (Throwable e) { // その他理由で登録に失敗した場合 param.setControlMapData(SCControlMapKeys.RETURN_CODE, JKKStrConst.RETURN_CD_9000); throw new CCException("", e); } // 返却値を設定する param.setData(fixedText, responseParam); 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)); } // エラーが存在する場合 if (errList.size() > 0) { ccMsg.put(CC_PARAM_ERROR_INFO, errList); return false; } return true; } /** * EKK0081B090_契約種別一覧照会（PMP連携用）を実行する。 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param sysid SYSID * @return 結果 * @throws Throwable 例外が発生した場合 */ private CAANMsg[] callEKK0081B090(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String sysid) throws Throwable { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // サービス契約一覧照会(SYSID)の上りマッピング Object[][] EKK0081B090In = { {EKK0081B090CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK0081B090}, {EKK0081B090CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_3}, // 機能コード："3" {EKK0081B090CBSMsg.KEY_SYSID, sysid} // ＫＥＹ＿SYSYID }; // サービスIF実行 CAANMsg[] EKK0081B090Out = callSC(handle, scCall, param, fixedText, EKK0081B090In).getCAANMsgList(EKK0081B090CBSMsg.EKK0081B090CBSMSG1LIST); // 結果を返却 return EKK0081B090Out; } /** * ECK0201B040_連絡先一覧照会(紹介者連絡先)を実行する。 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param sysid SYSID * @return 結果 * @throws Throwable 例外が発生した場合 */ private CAANMsg[] callECK0201B040(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String sysid) throws Throwable { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // サービス契約一覧照会(SYSID)の上りマッピング Object[][] ECK0201B040In = { {ECK0201B040CBSMsg.TEMPLATEID, TEMPLATE_ID_ECK0201B040}, {ECK0201B040CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1}, // 機能コード："1" {ECK0201B040CBSMsg.KEY_SYSID, sysid} // ＫＥＹ＿SYSYID }; // サービスIF実行 CAANMsg[] ECK0201B040Out = callSC(handle, scCall, param, fixedText, ECK0201B040In).getCAANMsgList(ECK0201B040CBSMsg.ECK0201B040CBSMSG1LIST); // 結果を返却 return ECK0201B040Out; } /** * EKK0361B030_オプションサービス契約＜ISP＞紹介者Eメール一覧照会を実行する。 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param svcKeiNo サービス契約番号 * @return 結果 * @throws Throwable 例外が発生した場合 */ private CAANMsg[] callEKK0361B030(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String svcKeiNo) throws Throwable { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // オプションサービス契約＜ISP＞紹介者Eメール一覧照会の上りマッピング Object[][] EKK0361B030In = { {EKK0361B030CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK0361B030}, {EKK0361B030CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1}, // 機能コード："1" {EKK0361B030CBSMsg.KEY_SVC_KEI_NO, svcKeiNo} // ＫＥＹ＿サービス契約番号 }; // サービスIF実行 CAANMsg[] EKK0361B030Out = callSC(handle, scCall, param, fixedText, EKK0361B030In).getCAANMsgList(EKK0361B030CBSMsg.EKK0361B030CBSMSG1LIST); // 結果を返却 return EKK0361B030Out; } /** * お客様一意照会を行う。 * * @param handle * @param param * @param fixedText * @param sysid * @param opeDate * @return CAANMsg[] * @throws Exception */ private CAANMsg[] callECK0011A010(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String sysid, String opeDate) throws Exception { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // お客様一意照会 Object[][] eck0011a010In = {{ECK0011A010CBSMsg.TEMPLATEID, TEMPLATE_ID_ECK0011A010}, {ECK0011A010CBSMsg.FUNC_CODE, "2"}, {ECK0011A010CBSMsg.KEY_SYSID, sysid}, {ECK0011A010CBSMsg.KEY_RSV_APLY_YMD, opeDate}}; // サービスIF実行 CAANMsg[] ECK0011A010Out = callSC(handle, scCall, param, fixedText, eck0011a010In).getCAANMsgList(ECK0011A010CBSMsg.ECK0011A010CBSMSG1LIST); // 結果を返却 return ECK0011A010Out; } /** * EZM0321B010_業務パラメータ一覧照会を実行する。 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @return 結果 * @throws Throwable 例外が発生した場合 */ private CAANMsg[] callEZM0321B010(SessionHandle handle, IRequestParameterReadWrite param, String fixedText) throws Throwable { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // サービス契約一覧照会(SYSID)の上りマッピング Object[][] EZM0321B010In = { {EZM0321B010CBSMsg.TEMPLATEID, TEMPLATE_ID_EZM0321B010}, {EZM0321B010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1}, {EZM0321B010CBSMsg.KEY_WORK_PARAM_ID, KEY_WORK_PARAM_ID_EZM0321B010} }; // サービスIF実行 CAANMsg[] EZM0321B010Out = callSC(handle, scCall, param, fixedText, EZM0321B010In).getCAANMsgList(EZM0321B010CBSMsg.EZM0321B010CBSMSG1LIST); // 結果を返却 return EZM0321B010Out; } /** * 契約メールアドレスを取得し、返却する。 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param svcKeiNo サービス契約番号 * @return 結果 * @throws Throwable 例外が発生した場合 */ private String getKeiyakuMlad(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String svcKeiNo) throws Throwable { CAANMsg[] ekk0361b030List = callEKK0361B030(handle, param, fixedText, svcKeiNo); if (ekk0361b030List != null && ekk0361b030List.length > 0) { // メールアドレスを設定する return ekk0361b030List[0].getString(EKK0361B030CBSMsg1List.MLAD); } return null; } /** * 連絡先メールアドレスを取得する * * @param eck0201b040List * @return * @throws Exception */ private String getRrksMailAddress(CAANMsg[] eck0201b040List) throws Exception { ArrayList> list = new ArrayList>(); String rrksNo = ""; for (int i = 0; i < eck0201b040List.length; i++) { HashMap one = new HashMap(); // 連絡先コードが新しければクリア if (!rrksNo.equals(eck0201b040List[i].getString(ECK0201B040CBSMsg1List.RRKS_NO))) { list.clear(); rrksNo = eck0201b040List[i].getString(ECK0201B040CBSMsg1List.RRKS_NO); } one.put(ECK0201B040CBSMsg1List.GENE_ADD_DTM, eck0201b040List[i].getString(ECK0201B040CBSMsg1List.GENE_ADD_DTM)); one.put(ECK0201B040CBSMsg1List.MLAD, eck0201b040List[i].getString(ECK0201B040CBSMsg1List.MLAD)); one.put(ECK0201B040CBSMsg1List.RSV_APLY_CD, eck0201b040List[i].getString(ECK0201B040CBSMsg1List.RSV_APLY_CD)); list.add(one); } // 先頭の次のレコードが予約レコードかつ先頭が確定レコードの場合、最後のレコードを削除する if (list.size() >= 2 && RSV_APLY_CD_RSV.equals(list.get(1).get(ECK0201B040CBSMsg1List.RSV_APLY_CD)) && RSV_APLY_CD_FIX.equals(list.get(0).get(ECK0201B040CBSMsg1List.RSV_APLY_CD))) { list.remove(0); // 先頭を削除 } // 最後のレコードから確定レコードを探す for (int i=list.size()-1; i >= 0; i--) { if (RSV_APLY_CD_FIX.equals(list.get(i).get(ECK0201B040CBSMsg1List.RSV_APLY_CD))) { return list.get(i).get(ECK0201B040CBSMsg1List.MLAD); } } return null; } /** * 紹介登録 *
* @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText ユーザ定義文字列 * @param intrCd 紹介コード * @param sysId SYSID * @param svcKeiNo サービス契約番号 * @param mlad メールアドレス * @param ykKigenYmd 有効期限年月日 * * @return CAANMsg[] 登録結果 * @throws Throwable */ private CAANMsg callEKK0311D010(SessionHandle handle, IRequestParameterReadWrite param, String fixedText, String intrCd, String sysId, String svcKeiNo, String mlad, String ykKigenYmd, CAANMsg[] eck0011a010Out) throws Throwable { // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // キャンペーン適用情報連携状態更新 EKK3371C020 Object[][] ekk0311d010In = { {EKK0311D010CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK0311D010}, {EKK0311D010CBSMsg.FUNC_CODE, "1"}, {EKK0311D010CBSMsg.INTR_CD, intrCd}, {EKK0311D010CBSMsg.SYSID, sysId}, {EKK0311D010CBSMsg.INTR_SVC_DIV, ""}, {EKK0311D010CBSMsg.INTR_DTM, JCCModelCommon.getSysDateTimeStamp()}, {EKK0311D010CBSMsg.HISHOKAI_NM, ""}, {EKK0311D010CBSMsg.HISHOKAI_RRKS_MLAD, ""}, {EKK0311D010CBSMsg.MSKM_TCH_ML_SEND_DTM, ""}, {EKK0311D010CBSMsg.INTR_SBT_CD, INTR_SBT_CD_1}, {EKK0311D010CBSMsg.CANCEL_TCH_ML_SEND_DTM, ""}, {EKK0311D010CBSMsg.SHOKAISHA_NM, eck0011a010Out[0].getString(ECK0011A010CBSMsg1List.CUST_NM)}, {EKK0311D010CBSMsg.SVC_KEI_NO, svcKeiNo}, {EKK0311D010CBSMsg.SHOKAISHA_EOID, eck0011a010Out[0].getString(ECK0011A010CBSMsg1List.EOID)}, {EKK0311D010CBSMsg.SHOKAISHA_RRKS_MLAD, mlad}, {EKK0311D010CBSMsg.SHOKAISHA_PCD, eck0011a010Out[0].getString(ECK0011A010CBSMsg1List.KEISHA_PCD)}, {EKK0311D010CBSMsg.SHOKAISHA_AD_STATE_NM, eck0011a010Out[0].getString(ECK0011A010CBSMsg1List.KEISHA_STATE_NM)}, {EKK0311D010CBSMsg.SHOKAISHA_AD_CITY_NM, eck0011a010Out[0].getString(ECK0011A010CBSMsg1List.KEISHA_CITY_NM)}, {EKK0311D010CBSMsg.SHOKAISHA_AD_OAZTSU_NM, eck0011a010Out[0].getString(ECK0011A010CBSMsg1List.KEISHA_OAZTSU_NM)}, {EKK0311D010CBSMsg.SHOKAISHA_AD_AZCHO_NM, eck0011a010Out[0].getString(ECK0011A010CBSMsg1List.KEISHA_AZCHO_NM)}, {EKK0311D010CBSMsg.SHOKAISHA_AD_BNCHIGO, eck0011a010Out[0].getString(ECK0011A010CBSMsg1List.KEISHA_BNCHIGO)}, {EKK0311D010CBSMsg.SHOKAISHA_ADRTTM, eck0011a010Out[0].getString(ECK0011A010CBSMsg1List.KEISHA_ADRTTM)}, {EKK0311D010CBSMsg.SHOKAISHA_ADRRM, eck0011a010Out[0].getString(ECK0011A010CBSMsg1List.KEISHA_ADRRM)}, {EKK0311D010CBSMsg.MSKM_ML_SEND_CD, ML_SEND_CD_0}, {EKK0311D010CBSMsg.CANCEL_ML_SEND_CD, ML_SEND_CD_0}, {EKK0311D010CBSMsg.YK_KIGEN_YMD, ykKigenYmd} }; // 実行 CAANMsg ekk0311d010Msg1List = callSC(handle, scCall, param, fixedText, ekk0311d010In); return ekk0311d010Msg1List; } /** * 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; returnMap.put(CC_PARAM_ERR_CD, errCd); returnMap.put(CC_PARAM_ERR_MSG, errMessage); return returnMap; } }