/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JEKKA0020003TPMA * ソースファイル名：JEKKA0020003TPMA.java * 作成者 ：EK911023 * 日付 ：2013年02月15日 *＜機能概要＞ * 宅内機器一意照会（４）独自処理部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * v 5.00.00 2013/06/28 FJ) 大山 LT-2013-0000080 * ********************************************************************************/ package eo.ejb.cbs.mainproc; import java.sql.Connection; import java.util.ArrayList; import java.util.Hashtable; import com.fujitsu.futurity.model.base.CAANConnectionMgr; import com.fujitsu.futurity.model.base.CAANMsg; import com.fujitsu.futurity.model.ejb.common.JSYejbConnection; import com.fujitsu.futurity.model.ejb.common.StatusCodes; import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext; import com.fujitsu.futurity.model.ejb.common.fw.TemplateMainHandler; import eo.common.constant.JWCStrConst; import eo.ejb.cbs.cbsmsg.EKKA0020003CBSMsg; import eo.ejb.cbs.cbsmsg.EKKA0020003CBSMsg1List; import eo.ejb.cbs.cbsmsg.EKKA0020003CBSMsg2List; import eo.ejb.common.JCCModelCommon; import eo.ejb.common.JKKCtrlTnInfo; import eo.ejb.common.JWCCtrlTnInfo; public class JEKKA0020003TPMA implements TemplateMainHandler { /** * 結果コード */ private static final String CMD_RESULT_CD = "CMD_RESULT_CD"; // コマンド実行部品用 public static void ctrlTnInfo(CAANMsg inCBSMsg, AgentDispatchContext inContext) { Hashtable serviceMap = new Hashtable(); ArrayList>list = new ArrayList>(); CAANMsg[] listCaan = inCBSMsg.getCAANMsgList(EKKA0020003CBSMsg.EKKA0020003CBSMSG1LIST); Hashtable serviceMapList_head = new Hashtable(); //operatorID String operatorId = inCBSMsg.getString(EKKA0020003CBSMsg.OPERATORID); if(operatorId != null) { serviceMapList_head.put(JWCCtrlTnInfo.OPERATORID, operatorId); } else { serviceMapList_head.put(JWCCtrlTnInfo.OPERATORID, ""); } //operatorDateTime String operatoDateTime = inCBSMsg.getString(EKKA0020003CBSMsg.OPERATEDATETIME); if(operatoDateTime != null) { serviceMapList_head.put(JWCCtrlTnInfo.OPERATEDATETIME, operatoDateTime); } else { serviceMapList_head.put(JWCCtrlTnInfo.OPERATEDATETIME, ""); } list.add(serviceMapList_head); // for(int i = 0 ; i < listCaan.length ; i++) { Hashtable serviceMapList = new Hashtable(); //ＫＥＹ＿宅内機器型式コード String key_tk_mdl_cd = listCaan[i].getString(EKKA0020003CBSMsg1List.KEY_TK_MDL_CD); if(key_tk_mdl_cd != null) { serviceMapList.put(EKKA0020003CBSMsg1List.KEY_TK_MDL_CD, key_tk_mdl_cd); } else { serviceMapList.put(EKKA0020003CBSMsg1List.KEY_TK_MDL_CD, ""); } //ＫＥＹ＿機器製造番号 String key_kk_seizo_no = listCaan[i].getString(EKKA0020003CBSMsg1List.KEY_KK_SEIZO_NO); if(key_kk_seizo_no != null) { serviceMapList.put(EKKA0020003CBSMsg1List.KEY_KK_SEIZO_NO, key_kk_seizo_no); } else { serviceMapList.put(EKKA0020003CBSMsg1List.KEY_KK_SEIZO_NO, ""); } list.add(serviceMapList); } serviceMap.put(EKKA0020003CBSMsg.EKKA0020003CBSMSG1LIST, list); // 宅内機器コマンド発行部品のスタブ用、 int str_flag = Integer.parseInt(JCCModelCommon.getApplicationConst(JWCStrConst.TN_FLAG)); JKKCtrlTnInfo instance = JKKCtrlTnInfo.getInstance(str_flag); // テーブルのコネクションを取得するして、部品に受け渡しを行う。 Connection con = JSYejbConnection.getConnection("TK_T_TK"); instance.setConnection(con); try { Hashtable ret = instance.ctrlTnInfo_KKA0003(serviceMap, con); CAANMsg[] l_ekka0020003csvmsg2list = null; // 取得した戻り値を元に、inCBSMsgのアウト項目に値を設定して返す ArrayList> retlist = (ArrayList>)ret.get(EKKA0020003CBSMsg.EKKA0020003CBSMSG2LIST); String error_level = (String)ret.get("errorLevel"); if(error_level != null) { inCBSMsg.set(EKKA0020003CBSMsg.ERROR_LEVEL, error_level); } else { inCBSMsg.set(EKKA0020003CBSMsg.ERROR_LEVEL, ""); } String return_cd = (String)ret.get("returnCode"); if(return_cd != null) { inCBSMsg.set(EKKA0020003CBSMsg.RETURN_CD, return_cd); } else { inCBSMsg.set(EKKA0020003CBSMsg.RETURN_CD, ""); } String return_message = (String)ret.get("returnMessage"); if(return_message != null) { inCBSMsg.set(EKKA0020003CBSMsg.RETURN_MESSAGE, return_message); } else { inCBSMsg.set(EKKA0020003CBSMsg.RETURN_MESSAGE, ""); } //結果コードが"1"なら処理を終了する。 if(ret.get(CMD_RESULT_CD) != null && ret.get(CMD_RESULT_CD).equals("1")) { inCBSMsg.set(EKKA0020003CBSMsg.STATUS, StatusCodes.EXTERNAL_IF_ERR1); return; } //エラーレベルが000より大きければ処理を終了する。 if(ret.get("errorLevel") != null && !((String)ret.get("errorLevel")).equals("000")) { inCBSMsg.set(EKKA0020003CBSMsg.STATUS, StatusCodes.EXTERNAL_IF_ERR1); return; } if(retlist != null && !retlist.isEmpty()) { // うまくいけば戻りの電文を設定して終了する。 l_ekka0020003csvmsg2list = new CAANMsg[retlist.size()]; for(int i = 0 ; i < retlist.size() ; i ++) { Hashtable data = retlist.get(i); CAANMsg msg = new CAANMsg("eo.ejb.cbs.cbsmsg.EKKA0020003CBSMsg2List"); l_ekka0020003csvmsg2list[i] = msg; //宅内機器型式コード msg.set(EKKA0020003CBSMsg2List.TK_MDL_CD, (String)data.get(EKKA0020003CBSMsg2List.TK_MDL_CD)); //機器製造番号 msg.set(EKKA0020003CBSMsg2List.KK_SEIZO_NO, (String)data.get(EKKA0020003CBSMsg2List.KK_SEIZO_NO)); //ＭＡＣアドレス msg.set(EKKA0020003CBSMsg2List.MAC_AD, (String)data.get(EKKA0020003CBSMsg2List.MAC_AD)); //ＳＴＢＩＤ msg.set(EKKA0020003CBSMsg2List.STBID, (String)data.get(EKKA0020003CBSMsg2List.STBID)); //仮鍵開年月日 msg.set(EKKA0020003CBSMsg2List.KR_KEY_STA_YMD, (String)data.get(EKKA0020003CBSMsg2List.KR_KEY_STA_YMD)); //宅内機器セット品番号 msg.set(EKKA0020003CBSMsg2List.TAKNKIKI_SETHIN_NO, (String)data.get(EKKA0020003CBSMsg2List.TAKNKIKI_SETHIN_NO)); //宅内機器ステータス msg.set(EKKA0020003CBSMsg2List.TAKNKIKI_STAT, (String)data.get("tk_stat")); //設置場所番号 msg.set(EKKA0020003CBSMsg2List.SETPLACE_NO, (String)data.get(EKKA0020003CBSMsg2List.SETPLACE_NO)); //場所設置年月日 msg.set(EKKA0020003CBSMsg2List.PLC_STC_YMD, (String)data.get(EKKA0020003CBSMsg2List.PLC_STC_YMD)); //上位宅内機器型式コード msg.set(EKKA0020003CBSMsg2List.JOI_TK_MDL_CD, (String)data.get(EKKA0020003CBSMsg2List.JOI_TK_MDL_CD)); //上位機器製造番号 msg.set(EKKA0020003CBSMsg2List.JOI_KK_SEIZO_NO, (String)data.get(EKKA0020003CBSMsg2List.JOI_KK_SEIZO_NO)); //保証開始年月日 msg.set(EKKA0020003CBSMsg2List.HOSHO_STAYMD, (String)data.get(EKKA0020003CBSMsg2List.HOSHO_STAYMD)); //保証終了年月日 msg.set(EKKA0020003CBSMsg2List.HOSHO_ENDYMD, (String)data.get(EKKA0020003CBSMsg2List.HOSHO_ENDYMD)); //ＵＱ認証ＩＤ msg.set(EKKA0020003CBSMsg2List.UQ_NINSHO_ID, (String)data.get(EKKA0020003CBSMsg2List.UQ_NINSHO_ID)); //ＵＱパスワード msg.set(EKKA0020003CBSMsg2List.UQ_PWD, (String)data.get(EKKA0020003CBSMsg2List.UQ_PWD)); //ＥＭ契約者コード msg.set(EKKA0020003CBSMsg2List.EM_KEISHA_CD, (String)data.get(EKKA0020003CBSMsg2List.EM_KEISHA_CD)); //ＩＣＣＩＤ msg.set(EKKA0020003CBSMsg2List.ICC_ID, (String)data.get(EKKA0020003CBSMsg2List.ICC_ID)); //ＭＡＣ認証ＩＤ msg.set(EKKA0020003CBSMsg2List.MAC_NINSHO_ID, (String)data.get(EKKA0020003CBSMsg2List.MAC_NINSHO_ID)); //ＭＳＩＳＤＮ msg.set(EKKA0020003CBSMsg2List.MSISDN, (String)data.get(EKKA0020003CBSMsg2List.MSISDN)); //メーカー名１ msg.set(EKKA0020003CBSMsg2List.MAKER_NM1, (String)data.get(EKKA0020003CBSMsg2List.MAKER_NM1)); //メーカー名２ msg.set(EKKA0020003CBSMsg2List.MAKER_NM2, (String)data.get(EKKA0020003CBSMsg2List.MAKER_NM2)); //宅内機器種別コード msg.set(EKKA0020003CBSMsg2List.TK_SBT_CD, (String)data.get(EKKA0020003CBSMsg2List.TK_SBT_CD)); //ＨＤＤ容量コード msg.set(EKKA0020003CBSMsg2List.HDD_SIZE_CD, (String)data.get(EKKA0020003CBSMsg2List.HDD_SIZE_CD)); //無料ルーター表示文言 msg.set(EKKA0020003CBSMsg2List.MURYO_ROUTER_DISP_MONGON, (String)data.get(EKKA0020003CBSMsg2List.MURYO_ROUTER_DISP_MONGON)); //保有ルータコード msg.set(EKKA0020003CBSMsg2List.HOYU_ROUTER_CD, (String)data.get(EKKA0020003CBSMsg2List.HOYU_ROUTER_CD)); //宅内機器型式略称名 msg.set(EKKA0020003CBSMsg2List.TK_MDL_ALI_NM, (String)data.get(EKKA0020003CBSMsg2List.TK_MDL_ALI_NM)); //宅内機器型式名 msg.set(EKKA0020003CBSMsg2List.TK_MDL_NM, (String)data.get(EKKA0020003CBSMsg2List.TK_MDL_NM)); //メーカーコード msg.set(EKKA0020003CBSMsg2List.MAKER_CD, (String)data.get(EKKA0020003CBSMsg2List.MAKER_CD)); //設置場所住所コード msg.set(EKKA0020003CBSMsg2List.SETPLACE_AD_CD, (String)data.get(EKKA0020003CBSMsg2List.SETPLACE_AD_CD)); //設置場所郵便番号 msg.set(EKKA0020003CBSMsg2List.SETPLACE_PCD, (String)data.get(EKKA0020003CBSMsg2List.SETPLACE_PCD)); //設置場所都道府県名 msg.set(EKKA0020003CBSMsg2List.SETPLACE_STATE_NM, (String)data.get(EKKA0020003CBSMsg2List.SETPLACE_STATE_NM)); //設置場所市区町村名 msg.set(EKKA0020003CBSMsg2List.SETPLACE_CITY_NM, (String)data.get(EKKA0020003CBSMsg2List.SETPLACE_CITY_NM)); //設置場所大字通称名 msg.set(EKKA0020003CBSMsg2List.SETPLACE_OAZTSU_NM, (String)data.get(EKKA0020003CBSMsg2List.SETPLACE_OAZTSU_NM)); //設置場所字丁目名 msg.set(EKKA0020003CBSMsg2List.SETPLACE_AZCHO_NM, (String)data.get(EKKA0020003CBSMsg2List.SETPLACE_AZCHO_NM)); //設置場所番地号 msg.set(EKKA0020003CBSMsg2List.SETPLACE_BNCHIGO, (String)data.get(EKKA0020003CBSMsg2List.SETPLACE_BNCHIGO)); //設置場所住所補記・建物名 msg.set(EKKA0020003CBSMsg2List.SETPLACE_ADRTTM, (String)data.get(EKKA0020003CBSMsg2List.SETPLACE_ADRTTM)); //設置場所住所補記・部屋番号 msg.set(EKKA0020003CBSMsg2List.SETPLACE_ADRRM, (String)data.get(EKKA0020003CBSMsg2List.SETPLACE_ADRRM)); //宅内機器ＳＴＢＴ更新日付 msg.set(EKKA0020003CBSMsg2List.STBT_UPD_DTTM, (String)data.get(EKKA0020003CBSMsg2List.STBT_UPD_DTTM)); //宅内機器基本Ｔ更新日付 msg.set(EKKA0020003CBSMsg2List.KIHONT_UPD_DTTM, (String)data.get(EKKA0020003CBSMsg2List.KIHONT_UPD_DTTM)); //宅内機器ＣＡＳＴ更新日付 msg.set(EKKA0020003CBSMsg2List.CAST_UPD_DTTM, (String)data.get(EKKA0020003CBSMsg2List.CAST_UPD_DTTM)); } inCBSMsg.set(EKKA0020003CBSMsg.EKKA0020003CBSMSG2LIST, l_ekka0020003csvmsg2list); } } catch(Exception e) { e.printStackTrace(); inCBSMsg.set(EKKA0020003CBSMsg.STATUS, StatusCodes.EXTERNAL_IF_ERR1); } finally { if(con != null) { CAANConnectionMgr.getInstance().close(con); } } } }