/*********************************************************************
* All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JKKOneStopDokujiCmnChkCC
* ソースファイル名：JKKOneStopDokujiCmnChkCC.java
* 作成者 ：富士通
* 日付 ：2011年06月13日
*＜機能概要＞
* ワンストップ独自共通チェックコモンコンポーネント部品
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* v18.00.00 2015/07/14 FJ）阪口 【ANK-2631-00-00】ワンストップ案件（ＳＴＥＰ１）
* v18.00.01 2015/10/22 FJ）頼経 【ANK-2694-00-00】ワンストップ案件（ＳＴＥＰ２）
**********************************************************************/
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.CCException;
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.JPCModelConstant;
import eo.ejb.cbs.cbsmsg.ECK0011A010CBSMsg;
import eo.ejb.cbs.cbsmsg.ECK0011A010CBSMsg1List;
import eo.ejb.cbs.cbsmsg.EKK0081A010CBSMsg;
import eo.ejb.cbs.cbsmsg.EKK0081A010CBSMsg1List;
import eo.ejb.cbs.cbsmsg.EZM0051A010CBSMsg;
import eo.ejb.cbs.cbsmsg.EZM0051A010CBSMsg1List;
/**
* ワンストップ独自共通チェック部品.
*
* @author 富士通
*/
public class JKKOneStopDokujiCmnChkCC extends AbstractCommonComponent
{
/** リターンメッセージ */
private static final String RETURN_MESSAGE_STRING = "RETURN_MESSAGE_";
/** リターンメッセージ */
private static final String RETURN_MESSAGE_FORMAT = "%1$04d";
/** エラー用 */
private static final String SC_ERROR_STRING = "サービスコンポーネントエラー";
/**
* ワンストップ独自共通チェック処理を行います。
*
* @param handle
* @param param
* @param fixedText
* @return リクエストパラメータ
* @throws Exception
*/
@SuppressWarnings("unchecked")
public IRequestParameterReadWrite chkOneStopDokujiCmn(SessionHandle handle, IRequestParameterReadWrite param, String fixedText) throws Exception
{
HashMap inMap = (HashMap)param.getData(fixedText);
if (inMap == null)
{
return param;
}
ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker();
HashMap paramMap = setSCInputCommonData(param, new HashMap());
Map result = null;
CAANMsg template = null;
// お客様一意照会
template = editInECK0011A010(param, fixedText); // 上りマッピング
result = scCall.run(putParamMap(paramMap, template), handle); // SC呼び出し
editRetECK0011A010(result, param, fixedText); // 下りマッピング
if (getReturnCode(param) >= JPCModelConstant.SINGLEDATA_ERR)
{ // ステータスが単項目エラー以上であれば例外をスロー
throw new CCException(SC_ERROR_STRING, new Exception());
}
// サービス契約一意照会
template = editInEKK0081A010(param, fixedText); // 上りマッピング
result = scCall.run(putParamMap(paramMap, template), handle); // SC呼び出し
editRetEKK0081A010(result, param, fixedText); // 下りマッピング
if (getReturnCode(param) >= JPCModelConstant.SINGLEDATA_ERR)
{ // ステータスが単項目エラー以上であれば例外をスロー
throw new CCException(SC_ERROR_STRING, new Exception());
}
// ユーザー一意照会
template = editInEZM0051A010(param, fixedText); // 上りマッピング
result = scCall.run(putParamMap(paramMap, template), handle); // SC呼び出し
editRetEZM0051A010(result, param, fixedText); // 下りマッピング
if (getReturnCode(param) >= JPCModelConstant.SINGLEDATA_ERR)
{ // ステータスが単項目エラー以上であれば例外をスロー
throw new CCException(SC_ERROR_STRING, new Exception());
}
// コード名称管理取得部品
String opeDate = (String)inMap.get("ope_Date");
HashMap codeMeishoKanriMap = (HashMap)inMap.get("codeMeishoKanriMap");
Map utilRes = JKKCodeMeishoKanriUtil.getDataList(handle, param, opeDate, (List)codeMeishoKanriMap.get("key_cd_sbt_list"));
codeMeishoKanriMap.put("rslt_cd_sbt_map", utilRes);
HashMap dataMap = (HashMap)param.getData(fixedText);
dataMap.put("codeMeishoKanriMap", codeMeishoKanriMap);
return param;
}
/**
* SCインプット共通データ設定処理を行います。
*
* @param param
* @param paramMap
* @return パラメータマップ
* @throws RequestParameterException
*/
private HashMap setSCInputCommonData(IRequestParameterReadWrite param, HashMap paramMap)
throws RequestParameterException
{
/* SCインプット共通データ */
// **********************************************
// 【取得元：電文ヘッダ(ヘッダ)】
// **********************************************
// 電文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));
return paramMap;
}
/**
* 単一CAANMsgのマッピング処理を行います。
*
* @param paramMap
* @param template
* @return パラメータマップ
* @throws RequestParameterException
*/
private HashMap putParamMap(HashMap paramMap, CAANMsg template) throws RequestParameterException
{
CAANMsg[] templates = new CAANMsg[1];
templates[0] = template;
paramMap.put(JCMConstants.TEMPLATE_LIST_KEY, templates);
return paramMap;
}
/**
* SCの実行ステータスの取得処理を行います。
*
* @param param
* @return SCの実行ステータス
* @throws Exception
*/
private int getReturnCode(IRequestParameterReadWrite param) throws Exception
{
return Integer.parseInt((String)param.getControlMapData(SCControlMapKeys.RETURN_CODE));
}
/**
* CAANMsgに必要なデータのマッピング処理を行います。
*
* @param handle
* @param param
* @param fixedText
* @return パラメータマップ
* @throws RequestParameterException
*/
@SuppressWarnings("unchecked")
public HashMap getInvokeCBS(SessionHandle handle, IRequestParameterReadWrite param, String fixedText)
throws RequestParameterException
{
ArrayList msgList = new ArrayList();
// お客様一意照会
msgList.add(editInECK0011A010(param, fixedText));
// サービス契約一意照会
msgList.add(editInEKK0081A010(param, fixedText));
// ユーザー一意照会
msgList.add(editInEZM0051A010(param, fixedText));
int msgCnt = msgList.size();
CAANMsg[] templates = new CAANMsg[msgCnt];
for (int i = 0; i < msgCnt; i++)
{
templates[i] = msgList.get(i);
}
HashMap paramMap = setSCInputCommonData(param, new HashMap());
paramMap.put(JCMConstants.TEMPLATE_LIST_KEY, templates);
return paramMap;
}
/**
* エラー情報のマッピング処理を行います。
*
* @param param
* @param templates
* @param returnCode
* @param fixedText
* @return リクエストパラメータ
* @throws RequestParameterException
*/
public IRequestParameterReadWrite editErrorInfo(IRequestParameterReadWrite param, CAANMsg[] templates, int returnCode, String fixedText)
throws RequestParameterException
{
int templateCount = 0;
// お客様一意照会
editErrInfoECK0011A010(param, templates[templateCount++], returnCode, fixedText);
// サービス契約一意照会
editErrInfoEKK0081A010(param, templates[templateCount++], returnCode, fixedText);
// ユーザー一意照会
editErrInfoEZM0051A010(param, templates[templateCount++], returnCode, fixedText);
return param;
}
/**
* お客様一意照会の上りマッピング処理を行います。
*
* @param param
* @param fixedText
* @return CAANMsg
* @throws RequestParameterException
*/
@SuppressWarnings("unchecked")
private CAANMsg editInECK0011A010(IRequestParameterReadWrite param, String fixedText) throws RequestParameterException
{
CAANMsg template = new CAANMsg(ECK0011A010CBSMsg.class.getName());
// テンプレートID
template.set(ECK0011A010CBSMsg.TEMPLATEID, "ECK0011A010");
// 機能コード（カレント検索：２）
template.set(ECK0011A010CBSMsg.FUNC_CODE, "2");
// オペレータID
Object operatorId = param.getControlMapData(SCControlMapKeys.OPERATOR_ID);
template.set(JCMConstants.OPERATOR_ID_KEY, operatorId);
// 運用日付
Object operateDate = param.getControlMapData(SCControlMapKeys.OPE_DATE);
template.set(JCMConstants.OPERATE_DATE_KEY, operateDate);
// 運用日時
Object operateDateTime = param.getControlMapData(SCControlMapKeys.OPE_TIME);
template.set(JCMConstants.OPERATE_DATETIME_KEY, operateDateTime);
HashMap parentMap = (HashMap)param.getData(fixedText);
HashMap inMap = (HashMap)parentMap.get("ECK0011A010Map");
// ＫＥＹ＿SYSID
if (inMap == null || inMap.get("key_sysid") == null || "".equals(inMap.get("key_sysid")))
{
template.setNull(ECK0011A010CBSMsg.KEY_SYSID);
}
else
{
template.set(ECK0011A010CBSMsg.KEY_SYSID, (String)inMap.get("key_sysid"));
}
// ＫＥＹ＿予約適用年月日（※入力パラメタの運用日を設定）
if (parentMap == null || parentMap.get("ope_Date") == null || "".equals(parentMap.get("ope_Date")))
{
template.setNull(ECK0011A010CBSMsg.KEY_RSV_APLY_YMD);
}
else
{
template.set(ECK0011A010CBSMsg.KEY_RSV_APLY_YMD, (String)parentMap.get("ope_Date"));
}
return template;
}
/**
* サービス契約一意照会の上りマッピング処理を行います。
*
* @param param
* @param fixedText
* @return CAANMsg
* @throws RequestParameterException
*/
@SuppressWarnings("unchecked")
private CAANMsg editInEKK0081A010(IRequestParameterReadWrite param, String fixedText) throws RequestParameterException
{
CAANMsg template = new CAANMsg(EKK0081A010CBSMsg.class.getName());
// テンプレートID
template.set(EKK0081A010CBSMsg.TEMPLATEID, "EKK0081A010");
// 機能コード（カレント検索：２）
template.set(EKK0081A010CBSMsg.FUNC_CODE, "2");
// オペレータID
Object operatorId = param.getControlMapData(SCControlMapKeys.OPERATOR_ID);
template.set(JCMConstants.OPERATOR_ID_KEY, operatorId);
// 運用日付
Object operateDate = param.getControlMapData(SCControlMapKeys.OPE_DATE);
template.set(JCMConstants.OPERATE_DATE_KEY, operateDate);
// 運用日時
Object operateDateTime = param.getControlMapData(SCControlMapKeys.OPE_TIME);
template.set(JCMConstants.OPERATE_DATETIME_KEY, operateDateTime);
HashMap parentMap = (HashMap)param.getData(fixedText);
HashMap inMap = (HashMap)parentMap.get("EKK0081A010Map");
// ＫＥＹ＿サービス契約番号
if (inMap == null || inMap.get("key_svc_kei_no") == null || "".equals(inMap.get("key_svc_kei_no")))
{
template.setNull(EKK0081A010CBSMsg.KEY_SVC_KEI_NO);
}
else
{
template.set(EKK0081A010CBSMsg.KEY_SVC_KEI_NO, (String)inMap.get("key_svc_kei_no"));
}
// ＫＥＹ＿予約適用年月日（※入力パラメタの運用日を設定）
if (parentMap == null || parentMap.get("ope_Date") == null || "".equals(parentMap.get("ope_Date")))
{
template.setNull(EKK0081A010CBSMsg.KEY_RSV_APLY_YMD);
}
else
{
template.set(EKK0081A010CBSMsg.KEY_RSV_APLY_YMD, (String)parentMap.get("ope_Date"));
}
return template;
}
/**
* ユーザー一意照会の上りマッピング処理を行います。
*
* @param param
* @param fixedText
* @return CAANMsg
* @throws RequestParameterException
*/
@SuppressWarnings("unchecked")
private CAANMsg editInEZM0051A010(IRequestParameterReadWrite param, String fixedText) throws RequestParameterException
{
CAANMsg template = new CAANMsg(EZM0051A010CBSMsg.class.getName());
// テンプレートID
template.set(EZM0051A010CBSMsg.TEMPLATEID, "EZM0051A010");
// 機能コード（デフォルト：１）
template.set(EZM0051A010CBSMsg.FUNC_CODE, "1");
// オペレータID
Object operatorId = param.getControlMapData(SCControlMapKeys.OPERATOR_ID);
template.set(JCMConstants.OPERATOR_ID_KEY, operatorId);
// 運用日付
Object operateDate = param.getControlMapData(SCControlMapKeys.OPE_DATE);
template.set(JCMConstants.OPERATE_DATE_KEY, operateDate);
// 運用日時
Object operateDateTime = param.getControlMapData(SCControlMapKeys.OPE_TIME);
template.set(JCMConstants.OPERATE_DATETIME_KEY, operateDateTime);
HashMap parentMap = (HashMap)param.getData(fixedText);
HashMap inMap = (HashMap)parentMap.get("EZM0051A010Map");
// ＫＥＹ＿ユーザID
if (inMap == null || inMap.get("key_user_id") == null || "".equals(inMap.get("key_user_id")))
{
template.setNull(EZM0051A010CBSMsg.KEY_USER_ID);
}
else
{
template.set(EZM0051A010CBSMsg.KEY_USER_ID, (String)inMap.get("key_user_id"));
}
return template;
}
/**
*お客様一意照会の下りマッピング処理
*
* @param msgList
* @param param
* @param fixedText
* @return リクエストパラメータ
* @throws Exception
*/
@SuppressWarnings("unchecked")
private IRequestParameterReadWrite editRetECK0011A010(Map msgList, IRequestParameterReadWrite param, String fixedText) throws Exception
{
CAANMsg[] templates = (CAANMsg[])msgList.get(JCMConstants.TEMPLATE_LIST_KEY);
CAANMsg template = templates[0];
Object returnCode = msgList.get(JCMConstants.RET_CD_INT_KEY);
HashMap parentMap = (HashMap)param.getData(fixedText);
HashMap dataMap = (HashMap)parentMap.get("ECK0011A010Map");
if (dataMap == null)
{
dataMap = new HashMap();
param.setData(fixedText, dataMap);
}
CAANMsg[] templateArray = template.getCAANMsgList(ECK0011A010CBSMsg.ECK0011A010CBSMSG1LIST);
ArrayList msg1List = (ArrayList)dataMap.get("ECK0011A010CBSMsg1List");
if (msg1List == null)
{
msg1List = new ArrayList();
}
if (templateArray != null)
{
int i = 0;
for (CAANMsg childTemplate : templateArray)
{
if (i >= msg1List.size())
{
msg1List.add(new HashMap());
}
HashMap childMap = (HashMap)msg1List.get(i++);
// SYSID ← お客様.SYSID
if (childTemplate.isNull(ECK0011A010CBSMsg1List.SYSID))
{
childMap.put("sysid", "");
}
else
{
childMap.put("sysid", childTemplate.getString(ECK0011A010CBSMsg1List.SYSID));
}
// お客様名 ← お客様.お客様名
if (childTemplate.isNull(ECK0011A010CBSMsg1List.CUST_NM))
{
childMap.put("cust_nm", "");
}
else
{
childMap.put("cust_nm", childTemplate.getString(ECK0011A010CBSMsg1List.CUST_NM));
}
// お客様カナ名 ← お客様.お客様カナ名
if (childTemplate.isNull(ECK0011A010CBSMsg1List.CUST_KANA))
{
childMap.put("cust_kana", "");
}
else
{
childMap.put("cust_kana", childTemplate.getString(ECK0011A010CBSMsg1List.CUST_KANA));
}
}
}
dataMap.put("ECK0011A010CBSMsg1List", msg1List);
// エラー情報の設定
editErrInfoECK0011A010(param, template, (Integer)returnCode, fixedText);
// エラー情報のマップを取得
ArrayList