/*********************************************************************
* All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JKKGetShuyoChgKojiCC
* ソースファイル名：JKKGetShuyoChgKojiCC .java
* 作成者 ：FJ
* 日付 ：2022/02/04
*＜機能概要＞
* 収容替工事取得の共通コンポーネント
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* v60.00.00 2022/07/20 FJ)謝 【ANK-4287-00-00】【eo定期】機器オプションの予約機能対応
* v61.00.00 2022/01/31 FJ) 永江 【ANK-4315-00-00】【eo定期】 eoホームゲートウェイ導入対応
**********************************************************************/
package com.fujitsu.futurity.bp.custom.common;
import java.util.ArrayList;
import java.util.Arrays;
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.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.JKKStrConst;
import eo.common.constant.JPCModelConstant;
import eo.common.util.JKKStringUtil;
import eo.ejb.cbs.cbsmsg.EKU0011B010CBSMsg;
import eo.ejb.cbs.cbsmsg.EKU0011B010CBSMsg1List;
import eo.ejb.cbs.cbsmsg.EZM0321A010CBSMsg;
import eo.ejb.cbs.cbsmsg.EZM0321A010CBSMsg1List;
/**
* 収容替工事取得の共通コンポーネントクラスです。
*
* @author 富士通
*
*/
public class JKKGetShuyoChgKojiCC extends AbstractCommonComponent
{
/** テンプレートID(EKU0011B010) 工事案件一覧照会 */
private static final String TEMPLATE_ID_EKU0011B010 = "EKU0011B010";
/** パラメータ名 サービス契約番号 */
private static final String PARAM_SVC_KEI_NO = "svc_kei_no";
/** パラメータ名 収容替工事有無フラグ */
private static final String PARAM_SHUYO_CHG_KOJI_UM_FLG = "shuyo_chg_koji_um_flg";
// ANK-4315-00-00 ADD START
/** パラメータ名 工事有無フラグ */
private static final String PARAM_KOJI_UM_FLG = "koji_um_flg";
/** 業務パラメータ管理一意照会 */
private static final String TEMPLATE_ID_EZM0321A010 = "EZM0321A010";
// ANK-4315-00-00 ADD END
/**
* 収容替工事取得を行う。
*
* @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;
// 収容替工事取得CCマップ
HashMap ccMsg = (HashMap)param.getData(dataMapKey);
if (ccMsg == null)
{
return param;
}
// サービス契約番号
String svcKeiNo = (String)ccMsg.get(PARAM_SVC_KEI_NO);
if (JKKStringUtil.isNullBlank(svcKeiNo))
{
return param;
}
// 収容替工事有無フラグ 初期値：無
String shuyoChgKojiUmFlg = JKKStrConst.CD_DIV_UM_NASHI;
// ANK-4315-00-00 ADD START
// 工事有無フラグ 初期値：無
String kojiUmFlg = JKKStrConst.CD_DIV_UM_NASHI;
// ANK-4315-00-00 ADD END
// SC呼び出し部品のインスタンス生成（引数にはログに出力するクラス名を渡す。空文字を設定した場合はログに出力されない）
ServiceComponentRequestInvoker scCall = new ServiceComponentRequestInvoker();
// ANK-4315-00-00 ADD START
// 機器画面で工事連携できる工事案件種別コードを取得します。
List kikiAddKjakSbt = Arrays.asList((getBuisinessParameter(handle, scCall, param, dataMapKey, JKKStrConst.KK_KIKI_ADD_KJAK_SBT)).split(","));
// ANK-4315-00-00 ADD END
// 工事案件一覧照会処理を行う
CAANMsg[] eku0011b010Msg1List = getKojiakInfo(handle, scCall, param, dataMapKey, svcKeiNo);
// 工事案件一覧情報存在チェック
if (eku0011b010Msg1List != null && eku0011b010Msg1List.length > 0)
{
for (CAANMsg eku0011b010Msg : eku0011b010Msg1List)
{
// 工事案件種別コード
String kojiakSbtCd = eku0011b010Msg.getString(EKU0011B010CBSMsg1List.KOJIAK_SBT_CD);
// 工事案件ステータス
String kojiakStat = eku0011b010Msg.getString(EKU0011B010CBSMsg1List.KOJIAK_STAT);
// ANK-4315-00-00 ADD START
// マンション工事案件状態コード
String manskojiakStat= eku0011b010Msg.getString(EKU0011B010CBSMsg1List.MANS_KOJIAK_STAT_CD);
// ANK-4315-00-00 ADD END
// 工事案件種別コードが「プラン変更(収容替)」 かつ
// 工事案件ステータスが「受付済」以上 かつ
// 工事案件ステータスが「現場作業完了済」以下の場合
if (JKKStrConst.CD00577_PLAN_CHG_SHYO_CHG.equals(kojiakSbtCd)
&& JKKStrConst.CD00474_130.compareTo(kojiakStat) <= 0
&& JKKStrConst.CD00474_190.compareTo(kojiakStat) >= 0)
{
shuyoChgKojiUmFlg = JKKStrConst.CD_DIV_UM_ARI;
// ANK-4315-00-00 DEL START
// break;
// ANK-4315-00-00 DEL END
}
// ANK-4315-00-00 ADD START
//工事案件種別コードが業務パラメータ設定値と一致した場合に処理を行う
if(!kikiAddKjakSbt.contains(kojiakSbtCd))
{
continue;
}
//工事案件ステータス、またはマンション工事案件状態コードが
//130"(受付済)以上"190"(現場作業完了済)以下のレコードが存在する場合、
//工事有無フラグに有を設定する
if(manskojiakStat != null && manskojiakStat != "")
{
kojiakStat = manskojiakStat;
}
if (JKKStrConst.CD00474_130.compareTo(kojiakStat) <= 0
&& JKKStrConst.CD00474_190.compareTo(kojiakStat) >= 0)
{
kojiUmFlg = JKKStrConst.CD_DIV_UM_ARI;
}
// ANK-4315-00-00 ADD END
}
}
// 戻り値設定
ccMsg.put(PARAM_SHUYO_CHG_KOJI_UM_FLG, shuyoChgKojiUmFlg);
// ANK-4315-00-00 ADD START
ccMsg.put(PARAM_KOJI_UM_FLG, kojiUmFlg);
// ANK-4315-00-00 ADD END
return param;
}
// ANK-4315-00-00 ADD START
/**
* 業務パラメータを取得。
*
* @param handle
* @param scCall
* @param param
* @param dataMapKey
* @param keyword
* @return String
* @throws Exception
*/
private String getBuisinessParameter(SessionHandle handle, ServiceComponentRequestInvoker scCall, IRequestParameterReadWrite param,
String dataMapKey, String keyword) throws Exception
{
// ***** EZM0321A010（業務パラメータ管理一意照会）*****
Object[][] ezm0321a010IN = { { EZM0321A010CBSMsg.TEMPLATEID, TEMPLATE_ID_EZM0321A010 }, { EZM0321A010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1 },
{ EZM0321A010CBSMsg.KEY_WORK_PARAM_ID, keyword } };
CAANMsg[] ezm0321a010cbsMsg1list = callSC(handle, scCall, param, dataMapKey, ezm0321a010IN).getCAANMsgList(
EZM0321A010CBSMsg.EZM0321A010CBSMSG1LIST);
return ezm0321a010cbsMsg1list[0].getString(EZM0321A010CBSMsg1List.WORK_PARAM_SETTE_VALUE);
}
// ANK-4315-00-00 ADD END
/**
* 工事案件一覧照会処理を行う。
* @param handle セッションハンドル
* @param scCall SC呼出
* @param param パラメーター
* @param dataMapKey データマップキー
* @param svcKeiNo サービス契約番号
* @throws Throwable
*/
private CAANMsg[] getKojiakInfo(SessionHandle handle,
ServiceComponentRequestInvoker scCall,
IRequestParameterReadWrite param,
String dataMapKey,
String svcKeiNo) throws Throwable
{
// 工事案件一覧照会の上りマッピング
Object[][] eku0011b010In =
{
{EKU0011B010CBSMsg.TEMPLATEID, TEMPLATE_ID_EKU0011B010},
{EKU0011B010CBSMsg.FUNC_CODE, JPCModelConstant.FUNC_CD_1},
{EKU0011B010CBSMsg.SEARCH_TYPE, JPCModelConstant.SAERCH_TYPE_IKT},
{EKU0011B010CBSMsg.MAX_SEARCH_NUM, "999999"},
{EKU0011B010CBSMsg.DISPLAY_NUM, "999999"},
{EKU0011B010CBSMsg.DISPLAY_PAGE_NUM, "1"},
{EKU0011B010CBSMsg.KEY_KOJIAK_NO_SVC_KEI_NO, svcKeiNo}
};
// 工事案件一覧照会処理を行う
CAANMsg eku0011b010Msg = callSC(handle, scCall, param, dataMapKey, eku0011b010In);
// 工事案件一覧照会明細
CAANMsg[] eku0011b010Msg1List = eku0011b010Msg.getCAANMsgList(EKU0011B010CBSMsg.EKU0011B010CBSMSG1LIST);
return eku0011b010Msg1List;
}
/**
* @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++)
{
/* CAANMsg[]の場合 */
if (mappingData[i][1] instanceof CAANMsg[])
{
template.set((String)mappingData[i][0], (CAANMsg[])mappingData[i][1]);
}
/* CAANMsg[]の以外 */
else
{
/* nullの場合*/
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
* @param returnCode
* @param dataMapKey
* @param mappingData
* @return IRequestParameterReadWrite
* @throws RequestParameterException
*/
@SuppressWarnings("unchecked")
private IRequestParameterReadWrite editErrorInfoCom(IRequestParameterReadWrite param,
CAANMsg[] templates,
int returnCode,
String dataMapKey,
Object[][] mappingData) throws RequestParameterException
{
// 本来はサービスインターフェイス分の処理が必要
CAANMsg template = templates[0];
int templateStatus = template.getInt(JCMConstants.STATUS_INT_KEY);
/* 0以外のとき */
if (returnCode != 0)
{
templateStatus = 9000;
}
/* nullのとき */
if (JCMAPLConstMgr.getString("RETURN_MESSAGE_" + String.format("%1$04d", templateStatus)) == null)
{
templateStatus = 0;
}
int bpStatus = 0;
Object obj = param.getControlMapData(SCControlMapKeys.RETURN_CODE);
/* nullの場合 */
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 = (HashMap)param.getData(dataMapKey);
for (int i = 0; i < mappingData.length; i++)
{
/* nullチェック */
if (!template.isNull(mappingData[i][0] + "_err"))
{
/* ユーザデータ情報にエラーを確認する */
if (!inMap.containsKey(mappingData[i][0] + "_err"))
{
inMap.put(mappingData[i][0] + "_err", template.getString(mappingData[i][0] + "_err"));
}
}
}
return param;
}
/**
* SC(サービスインターフェイス）を呼び出す。
*
* @param handle
* @param scCall
* @param param
* @param dataMapKey
* @param mappingData
* @return CAANMsg
* @throws Exception
*/
@SuppressWarnings("unchecked")
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];
// リターンコード取得
Object return_code = result.get(JCMConstants.RET_CD_INT_KEY);
int status = msg.getInt(JCMConstants.STATUS_INT_KEY);
editErrorInfoCom(param, templates, (Integer)return_code, dataMapKey, mappingData);
//エラー情報のマップを取得
ArrayList