/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JDKCommon66CC * ソースファイル名：JDKCommon66CC.java * 作成者 ：FJ * 日付 ：2019年01月31日 *＜機能概要＞ * BCAS解約の共通コンポーネント *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v40.00.00 2019/01/31 FJ) 謝 【ANK-3488-10-00】在庫出荷によるＢＣＡＳ解約対応 新規作成 **********************************************************************/ package com.fujitsu.futurity.bp.custom.common; import java.util.ArrayList; import java.util.HashMap; 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.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 eo.common.constant.JDKStrConst; import eo.common.constant.JPCModelConstant; import eo.common.util.JDKCommonUtil; import eo.common.util.JPCDateUtil; import eo.ejb.cbs.cbsmsg.EDK0301B060CBSMsg; import eo.ejb.cbs.cbsmsg.EDK0301B060CBSMsg1List; import eo.ejb.cbs.cbsmsg.EDK0301D010CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0341A010CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0341A010CBSMsg1List; import eo.ejb.cbs.cbsmsg.EKK0341B002CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0341B002CBSMsg1List; import eo.ejb.cbs.cbsmsg.EKK0341B501CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0341B501CBSMsg1List; import eo.ejb.cbs.cbsmsg.EKK0341C340CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0341C350CBSMsg; /** * BCAS解約部品です。

*
* @author 富士通 */ public class JDKCommon66CC extends AbstractCommonComponent { /** 機器提供サービス契約一覧照会（サービス契約番号） */ private static final String TEMPLATE_ID_EKK0341B002 = "EKK0341B002"; /** 機器提供サービス契約一意照会 */ private static final String TEMPLATE_ID_EKK0341A010 = "EKK0341A010"; /** 機器提供サービス契約一覧照会(サービス契約内訳番号) */ private static final String TEMPLATE_ID_EKK0341B501 = "EKK0341B501"; /** 機器提供サービス契約解約 */ private static final String TEMPLATE_ID_EKK0341C340 = "EKK0341C340"; /** 機器提供サービス契約解約確定 */ private static final String TEMPLATE_ID_EKK0341C350 = "EKK0341C350"; /** 返品機器取消一覧照会 */ private static final String TEMPLATE_ID_EDK0301B060 = "EDK0301B060"; /** 返品機器受付 */ private static final String TEMPLATE_ID_EDK0301D010 = "EDK0301D010"; /** * BCAS解約を行う。 * @param handle セッションハンドル * @param param リクエストパラメータ * @param fixedText サービスメッセージ * @return リクエストパラメータ * @throws Throwable */ @SuppressWarnings("unchecked") public IRequestParameterReadWrite execute(SessionHandle handle, IRequestParameterReadWrite param, String fixedText) throws Throwable { String dataMapKey = fixedText; // BCAS解約CCマップ HashMap ccMsg = (HashMap)param.getData(dataMapKey); if (ccMsg == null) { return param; } // 機能コード String funcCode = (String)ccMsg.get("func_code"); // 更新モード以外の場合、処理を終了する if (!JPCModelConstant.FUNC_CD_1.equals(funcCode)) { return param; } // STB機種変更判定CCマップ HashMap dksv007612cc = (HashMap)param.getData("DKSV007612CC"); if (dksv007612cc == null) { return param; } // 機器リスト ArrayList> kikiList = (ArrayList>)dksv007612cc.get("kikiList"); if (kikiList == null || kikiList.size() == 0) { return param; } // SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない） ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker(); // 機器リストの件数分、処理を繰り返し行う for(int i = 0; i < kikiList.size(); i++) { HashMap kikiMap = (HashMap)kikiList.get(i); // STB機器交換タイプ String stbKikiKokanType = (String)kikiMap.get("stb_kiki_kokan_type"); // 機器提供サービス契約番号 String kktkSvcKeiNo = (String)kikiMap.get("kktk_svc_kei_no"); // サービス契約番号 String svcKeiNo = (String)kikiMap.get("svc_kei_no"); // STB→4KSTB交換の場合 if(JDKStrConst.STB_KIKI_KOKAN_TYPE_STB_4KSTB.equals(stbKikiKokanType)) { // 機器提供サービス契約一覧照会（サービス契約番号）サービスI/F実行 CAANMsg[] ekk0341b002MsgList = execEKK0341B002(ccMsg, handle, scCall, param, dataMapKey, svcKeiNo, kktkSvcKeiNo); if (ekk0341b002MsgList == null || ekk0341b002MsgList.length == 0) { continue; } // サービス提供中フラグ boolean svcTeikyoChuFlg = false; // 契約変更中フラグ boolean keiChgChuFlg = false; // 世代登録年月日時分秒 String geneAddDtm = ""; // 最終更新年月日時分秒 String lastUpdDtm = ""; for (CAANMsg ekk0341b002Msg : ekk0341b002MsgList) { // 機器提供サービス契約ステータス String kktkSvcKeiStat = ekk0341b002Msg.getString(EKK0341B002CBSMsg1List.KKTK_SVC_KEI_STAT); // 機器提供サービス契約ステータスがサービス提供中の場合 if (JDKStrConst.CD00056_STAT_TEIKYO_CHU.equals(kktkSvcKeiStat)) { svcTeikyoChuFlg = true; geneAddDtm = ekk0341b002Msg.getString(EKK0341B002CBSMsg1List.GENE_ADD_DTM); } // 機器提供サービス契約ステータスが契約変更中の場合 else if (JDKStrConst.CD00056_STAT_KEI_CHG_CHU.equals(kktkSvcKeiStat)) { keiChgChuFlg = true; } } // サービス提供中のデータが存在するかつ、契約変更中のデータが存在しない場合 if(svcTeikyoChuFlg && !keiChgChuFlg) { // 機器提供サービス契約一意照会サービスI/F実行 CAANMsg[] ekk0341A010MsgList = execEKK0341A010(ccMsg, handle, scCall, param, dataMapKey, kktkSvcKeiNo, geneAddDtm); if (ekk0341A010MsgList == null || ekk0341A010MsgList.length == 0) { continue; } // サービス契約内訳番号 String svcKeiUcwkNo = ekk0341A010MsgList[0].getString(EKK0341A010CBSMsg1List.SVC_KEI_UCWK_NO); // 機器提供サービス契約一覧照会(サービス契約内訳番号)サービスI/F実行 CAANMsg[] ekk0341B501MsgList = execEKK0341B501(ccMsg, handle, scCall, param, dataMapKey, svcKeiUcwkNo); if (ekk0341B501MsgList == null || ekk0341B501MsgList.length == 0) { continue; } // BCASデータのメッセージ CAANMsg bcasMsg = null; for (CAANMsg ekk0341B501Msg : ekk0341B501MsgList) { // 機器提供サービス契約ステータスが解約済、キャンセル済以外かつ、 // 機器提供サービスコードがB-CASのデータを取得する if (!JDKStrConst.CD00056_STAT_DSLZUMI.equals(ekk0341B501Msg.getString(EKK0341B501CBSMsg1List.KKTK_SVC_KEI_STAT)) && !JDKStrConst.CD00056_STAT_CANCELZUMI.equals(ekk0341B501Msg.getString(EKK0341B501CBSMsg1List.KKTK_SVC_KEI_STAT)) && JDKStrConst.KKTK_SVC_CD_B_CAS.equals(ekk0341B501Msg.getString(EKK0341B501CBSMsg1List.KKTK_SVC_CD))) { bcasMsg = ekk0341B501Msg; break; } } if (bcasMsg == null) { continue; } // 最終更新年月日時分秒 lastUpdDtm = ekk0341A010MsgList[0].getString(EKK0341A010CBSMsg1List.LAST_UPD_DTM); // 機器提供サービス契約解約サービスI/F実行 CAANMsg ekk0341c340Msg = execEKK0341C340(ccMsg, handle, scCall, param, dataMapKey, bcasMsg, lastUpdDtm); // 最終更新年月日時分秒 lastUpdDtm = ekk0341c340Msg.getString(EKK0341C340CBSMsg.UPD_DTM); // 機器提供サービス契約解約確定サービスI/F実行 execEKK0341C350(ccMsg, handle, scCall, param, dataMapKey, bcasMsg, lastUpdDtm); // 返品機器有無フラグ false:無、true:有 boolean hmpinKikiUmFlg = false; // 返品機器取消一覧照会サービスI/F実行 CAANMsg[] edk0301b060MsgList = execEDK0301B060(ccMsg, handle, scCall, param, dataMapKey, bcasMsg); if (edk0301b060MsgList != null && ekk0341B501MsgList.length > 0) { for (CAANMsg edk0301b060Msg : edk0301b060MsgList) { // 返品機器ステータスが受付済または、倉入済の場合 if (JDKStrConst.HMPIN_KIKI_STAT_UKETSUKE.equals(edk0301b060Msg.getString(EDK0301B060CBSMsg1List.HMPIN_KIKI_STAT)) || JDKStrConst.HMPIN_KIKI_STAT_KURAIRE.equals(edk0301b060Msg.getString(EDK0301B060CBSMsg1List.HMPIN_KIKI_STAT))) { hmpinKikiUmFlg = true; break; } } } // 返品機器登録されていない場合 if (!hmpinKikiUmFlg) { // 返品機器受付サービスI/F実行 execEDK0301D010(ccMsg, handle, scCall, param, dataMapKey, ekk0341A010MsgList[0], bcasMsg); } } } } return param; } /** * 機器提供サービス契約一覧照会（サービス契約番号）を行う。 * @param ccMsg 識別コードマップ * @param handle セッションハンドル * @param scCall SC呼出 * @param param パラメーター * @param dataMapKey データマップキー * @param svcKeiNo サービス契約番号 * @param kktkSvcKeiNo 機器提供サービス契約番号 * @return 機器提供サービス契約一覧照会（サービス契約番号）マップ * @throws Exception */ private CAANMsg[] execEKK0341B002(HashMap ccMsg, SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String dataMapKey, String svcKeiNo, String kktkSvcKeiNo) throws Exception { // 機器提供サービス契約一覧照会（サービス契約番号）サービスI/Fの上りマッピング Object[][] ekk0341b002In = { {EKK0341B002CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK0341B002}, {EKK0341B002CBSMsg.FUNC_CODE, "11"}, {EKK0341B002CBSMsg.KEY_SVC_KEI_NO, svcKeiNo}, {EKK0341B002CBSMsg.KEY_KKTK_SVC_KEI_NO, kktkSvcKeiNo} }; // サービスI/F実行 CAANMsg[] ekk0341b002MsgList = callSC(handle, scCall, param, dataMapKey, ekk0341b002In, ccMsg).getCAANMsgList(EKK0341B002CBSMsg.EKK0341B002CBSMSG1LIST); return ekk0341b002MsgList; } /** * 機器提供サービス契約一意照会を行う。 * @param ccMsg 識別コードマップ * @param handle セッションハンドル * @param scCall SC呼出 * @param param パラメーター * @param dataMapKey データマップキー * @param kktkSvcKeiNo 機器提供サービス契約番号 * @param geneAddDtm 世代登録年月日時分秒 * @return 機器提供サービス契約一意照会マップ * @throws Exception */ private CAANMsg[] execEKK0341A010(HashMap ccMsg, SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String dataMapKey, String kktkSvcKeiNo, String geneAddDtm) throws Exception { // 機器提供サービス契約一意照会サービスI/Fの上りマッピング Object[][] ekk0341a010In = { {EKK0341A010CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK0341A010}, {EKK0341A010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1}, {EKK0341A010CBSMsg.KEY_KKTK_SVC_KEI_NO, kktkSvcKeiNo}, {EKK0341A010CBSMsg.KEY_GENE_ADD_DTM, geneAddDtm} }; // サービスI/F実行 CAANMsg[] ekk0341a010MsgList = callSC(handle, scCall, param, dataMapKey, ekk0341a010In, ccMsg).getCAANMsgList(EKK0341A010CBSMsg.EKK0341A010CBSMSG1LIST); return ekk0341a010MsgList; } /** * 機器提供サービス契約一覧照会(サービス契約内訳番号)を行う。 * @param ccMsg 識別コードマップ * @param handle セッションハンドル * @param scCall SC呼出 * @param param パラメーター * @param dataMapKey データマップキー * @param svcKeiUcwkNo サービス契約内訳番号 * @return 機器提供サービス契約一覧照会(サービス契約内訳番号)マップ * @throws Exception */ private CAANMsg[] execEKK0341B501(HashMap ccMsg, SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String dataMapKey, String svcKeiUcwkNo) throws Exception { // 機器提供サービス契約一覧照会(サービス契約内訳番号)サービスI/Fの上りマッピング Object[][] ekk0341b501In = { {EKK0341B501CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK0341B501}, {EKK0341B501CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1}, {EKK0341B501CBSMsg.KEY_SVC_KEI_UCWK_NO, svcKeiUcwkNo} }; // サービスI/F実行 CAANMsg[] ekk0341b501MsgList = callSC(handle, scCall, param, dataMapKey, ekk0341b501In, ccMsg).getCAANMsgList(EKK0341B501CBSMsg.EKK0341B501CBSMSG1LIST); return ekk0341b501MsgList; } /** * 機器提供サービス契約解約を行う。 * @param ccMsg 識別コードマップ * @param handle セッションハンドル * @param scCall SC呼出 * @param param パラメーター * @param dataMapKey データマップキー * @param bcasMsg bcasデータのメッセージ * @param lastUpdDtm 最終更新年月日時分秒 * @return 機器提供サービス契約解約マップ * @throws Exception */ private CAANMsg execEKK0341C340(HashMap ccMsg, SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String dataMapKey, CAANMsg bcasMsg, String lastUpdDtm) throws Exception { // 機器提供サービス契約解約サービスI/Fの上りマッピング Object[][] ekk0341c340In = { {EKK0341C340CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK0341C340}, {EKK0341C340CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1}, {EKK0341C340CBSMsg.KKTK_SVC_KEI_NO, bcasMsg.getString(EKK0341B501CBSMsg1List.KKTK_SVC_KEI_NO)}, {EKK0341C340CBSMsg.MSKM_DTL_NO, bcasMsg.getString(EKK0341B501CBSMsg1List.MSKM_DTL_NO)}, {EKK0341C340CBSMsg.RSV_TSTA_KIBO_YMD, ""}, {EKK0341C340CBSMsg.SVC_ENDYMD, JCCBPCommon.getOpeDate(null)}, {EKK0341C340CBSMsg.SVC_CHRG_ENDYMD, getEndYmd(JCCBPCommon.getOpeDate(null))}, {EKK0341C340CBSMsg.SVC_DLRE_CD, JDKStrConst.CD00879_TUJYO_DSL}, {EKK0341C340CBSMsg.SVC_DLRE_MEMO, ""}, {EKK0341C340CBSMsg.ZANCHI_FLG, ""}, {EKK0341C340CBSMsg.PNLTY_HASSEI_CD, ""}, {EKK0341C340CBSMsg.IDO_DIV, bcasMsg.getString(EKK0341B501CBSMsg1List.IDO_DIV)}, {EKK0341C340CBSMsg.TAKNKIKI_IDO_CD, bcasMsg.getString(EKK0341B501CBSMsg1List.TAKNKIKI_IDO_CD)}, {EKK0341C340CBSMsg.UPD_DTM_BF, lastUpdDtm}, {EKK0341C340CBSMsg.SVC_KEI_NO, bcasMsg.getString(EKK0341B501CBSMsg1List.SVC_KEI_NO)} }; // サービスI/F実行 CAANMsg ekk0341c340Msg = callSC(handle, scCall, param, dataMapKey, ekk0341c340In, ccMsg); return ekk0341c340Msg; } /** * 機器提供サービス契約解約確定を行う。 * @param ccMsg 識別コードマップ * @param handle セッションハンドル * @param scCall SC呼出 * @param param パラメーター * @param dataMapKey データマップキー * @param bcasMsg bcasデータのメッセージ * @param lastUpdDtm 最終更新年月日時分秒 * @return 機器提供サービス契約解約確定マップ * @throws Exception */ private CAANMsg execEKK0341C350(HashMap ccMsg, SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String dataMapKey, CAANMsg bcasMsg, String lastUpdDtm) throws Exception { // 機器提供サービス契約解約確定サービスI/Fの上りマッピング Object[][] ekk0341c350In = { {EKK0341C350CBSMsg.TEMPLATEID, TEMPLATE_ID_EKK0341C350}, {EKK0341C350CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1}, {EKK0341C350CBSMsg.KKTK_SVC_KEI_NO, bcasMsg.getString(EKK0341B501CBSMsg1List.KKTK_SVC_KEI_NO)}, {EKK0341C350CBSMsg.SVC_ENDYMD, JCCBPCommon.getOpeDate(null)}, {EKK0341C350CBSMsg.SVC_CHRG_ENDYMD, getEndYmd(JCCBPCommon.getOpeDate(null))}, {EKK0341C350CBSMsg.SVC_DLRE_CD, JDKStrConst.CD00879_TUJYO_DSL}, {EKK0341C350CBSMsg.SVC_DLRE_MEMO, ""}, {EKK0341C350CBSMsg.ZANCHI_FLG, ""}, {EKK0341C350CBSMsg.TAKNKIKI_IDO_CD, bcasMsg.getString(EKK0341B501CBSMsg1List.TAKNKIKI_IDO_CD)}, {EKK0341C350CBSMsg.KAISHU_KIKI_UM, ""}, {EKK0341C350CBSMsg.UPD_DTM_BF, lastUpdDtm}, {EKK0341C350CBSMsg.PLAN_END_SBT_CD, ""} }; // サービスI/F実行 CAANMsg ekk0341c350Msg = callSC(handle, scCall, param, dataMapKey, ekk0341c350In, ccMsg); return ekk0341c350Msg; } /** * 返品機器取消一覧照会を行う。 * @param ccMsg 識別コードマップ * @param handle セッションハンドル * @param scCall SC呼出 * @param param パラメーター * @param dataMapKey データマップキー * @param bcasMsg bcasデータのメッセージ * @return 返品機器取消一覧照会マップ * @throws Exception */ private CAANMsg[] execEDK0301B060(HashMap ccMsg, SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String dataMapKey, CAANMsg bcasMsg) throws Exception { // 返品機器取消一覧照会サービスI/Fの上りマッピング Object[][] edk0301b060In = { {EDK0301B060CBSMsg.TEMPLATEID, TEMPLATE_ID_EDK0301B060}, {EDK0301B060CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_3}, {EDK0301B060CBSMsg.KEY_KIKI_SEIZO_NO, bcasMsg.getString(EKK0341B501CBSMsg1List.KIKI_SEIZO_NO)} }; // サービスI/F実行 CAANMsg[] edk0301b060MsgList = callSC(handle, scCall, param, dataMapKey, edk0301b060In, ccMsg).getCAANMsgList(EDK0301B060CBSMsg.EDK0301B060CBSMSG1LIST); return edk0301b060MsgList; } /** * 返品機器受付を行う。 * @param ccMsg 識別コードマップ * @param handle セッションハンドル * @param scCall SC呼出 * @param param パラメーター * @param dataMapKey データマップキー * @param stbMsg stbデータのメッセージ * @param bcasMsg bcasデータのメッセージ * @return 返品機器受付マップ * @throws Exception */ private CAANMsg execEDK0301D010(HashMap ccMsg, SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String dataMapKey, CAANMsg stbMsg, CAANMsg bcasMsg) throws Exception { // 返品機器受付サービスI/Fの上りマッピング Object[][] edk0301d010In = { {EDK0301D010CBSMsg.TEMPLATEID, TEMPLATE_ID_EDK0301D010}, {EDK0301D010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1}, {EDK0301D010CBSMsg.HMPIN_UK_YMD, JCCBPCommon.getOpeDate(null)}, {EDK0301D010CBSMsg.HMPIN_DIV, JDKStrConst.RENTAL}, {EDK0301D010CBSMsg.KOJI_COMP_CD, ""}, {EDK0301D010CBSMsg.YOTAKU_SAKI_OFFC_CD, ""}, {EDK0301D010CBSMsg.PLACE_NO, bcasMsg.getString(EKK0341B501CBSMsg1List.KIKI_STC_SAKI_PLACE_NO)}, {EDK0301D010CBSMsg.KKTK_SVC_KEI_NO, bcasMsg.getString(EKK0341B501CBSMsg1List.KKTK_SVC_KEI_NO)}, {EDK0301D010CBSMsg.TAKNKIKI_MODEL_CD, bcasMsg.getString(EKK0341B501CBSMsg1List.TAKNKIKI_MODEL_CD)}, {EDK0301D010CBSMsg.KIKI_SEIZO_NO, bcasMsg.getString(EKK0341B501CBSMsg1List.KIKI_SEIZO_NO)}, {EDK0301D010CBSMsg.HUZOKUHIN_MODEL_CD, ""}, {EDK0301D010CBSMsg.BTRYHOZN_NO, ""}, {EDK0301D010CBSMsg.HMPIN_MOTO_KSITEI_FLG, ""}, {EDK0301D010CBSMsg.HMPIN_RSN_CD, JDKStrConst.CD00293_OTHER_EOTV}, {EDK0301D010CBSMsg.HMPIN_RSN_MEMO, ""}, {EDK0301D010CBSMsg.TROUBLE_NAIYO, ""}, {EDK0301D010CBSMsg.ADD_OPTNTY_KEI_IDO_DIV, stbMsg.getString(EKK0341A010CBSMsg1List.IDO_DIV)}, {EDK0301D010CBSMsg.ADD_OPTNTY_KEI_IDO_DTM, JCCBPCommon.getOpeDateTimeStamp(null)}, {EDK0301D010CBSMsg.LOAD_OYA_SVKEI_NO, bcasMsg.getString(EKK0341B501CBSMsg1List.SVC_KEI_NO)}, {EDK0301D010CBSMsg.GDS_STAT_CD, ""}, {EDK0301D010CBSMsg.TK_SBT_CD, bcasMsg.getString(EKK0341B501CBSMsg1List.KKTK_SBT_CD)}, {EDK0301D010CBSMsg.BTRYHOZN_UK_YMD, ""}, {EDK0301D010CBSMsg.KIKI_CHG_NO, bcasMsg.getString(EKK0341B501CBSMsg1List.KIKI_CHG_NO)} }; // サービスI/F実行 CAANMsg edk0301d010Msg = callSC(handle, scCall, param, dataMapKey, edk0301d010In, ccMsg); return edk0301d010Msg; } /** * SC(サービスインターフェイス）を呼び出す。 * @param handle セッションハンドル * @param scCall SC呼び出し部品 * @param param リクエストパラメータ * @param dataMapKey パラメータキー * @param mappingData マッピングデータ * @param ccMsg 識別コードマップ * @return CAANMsg * @throws Exception */ @SuppressWarnings("unchecked") private CAANMsg callSC(SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param, String dataMapKey, Object[][] mappingData, HashMap ccMsg) 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]; // リターンコード取得 Object return_code = result.get(JCMConstants.RET_CD_INT_KEY); Integer status = msg.getInt(JCMConstants.STATUS_INT_KEY); editErrorInfoCom(param, templates, (Integer)return_code, mappingData, ccMsg); //エラー情報のマップを取得 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)); CAANMsg template = new CAANMsg(String.format("eo.ejb.cbs.cbsmsg.%sCBSMsg", (String)mappingData[0][1])); // オペレータ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]); } } CAANMsg[] templates = new CAANMsg[1]; templates[0] = template; paramMap.put(JCMConstants.TEMPLATE_LIST_KEY, templates); return paramMap; } /** * エラー情報を取得する。 * @param param リクエストパラメータ * @param templates CAANMsgクラス * @param returnCode リターンコード * @param mappingData マッピングデータ * @param ccMsg 識別コードマップ * @return IRequestParameterReadWrite * @throws RequestParameterException */ private IRequestParameterReadWrite editErrorInfoCom(IRequestParameterReadWrite param, CAANMsg[] templates, int returnCode, Object[][] mappingData, HashMap ccMsg) throws RequestParameterException { // 本来はサービスインターフェイス分の処理が必要 CAANMsg template = templates[0]; int templateStatus = template.getInt(JCMConstants.STATUS_INT_KEY); if (returnCode != 0) { templateStatus = 9000; } if (JCMAPLConstMgr.getString("RETURN_MESSAGE_" + String.format("%1$04d", 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("%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 = ccMsg; for (int i = 0; i < mappingData.length; i++) { if (!template.isNull(mappingData[i][0] + "_err")) { if (!inMap.containsKey(mappingData[i][0] + "_err")) { // ユーザ情報は「key_」がない為、「key_」を削除する。 if (((String)mappingData[i][0]).startsWith("key_")) { String key = (String)mappingData[i][0]; inMap.put(key.substring(4) + "_err", template.getString(mappingData[i][0] + "_err")); } else { inMap.put(mappingData[i][0] + "_err", template.getString(mappingData[i][0] + "_err")); } } } } return param; } /** * 指定日付の月末日を取得する * @param date 指定日付 * @return 月末日付(yyyyMMdd) * @throws Exception */ private String getEndYmd(String date) throws Exception { if (JDKCommonUtil.isNull((date))) { return ""; } String endYmd = date.substring(0, 6) + JPCDateUtil.getEndOfMonth(date); return endYmd; } }