/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JEKKA0020001TPMA * ソースファイル名：JEKKA0020001TPMA.java * 作成者 ：EK911023 * 日付 ：2013年02月15日 *＜機能概要＞ * 設置場所一意照会独自処理部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * ｖ32.00.00 2017/05/26 FJ)河邊 【OM-2017-0000488】オープンカーソルエラー * ********************************************************************************/ 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.EKKA0020001CBSMsg; import eo.ejb.cbs.cbsmsg.EKKA0020001CBSMsg1List; import eo.ejb.cbs.cbsmsg.EKKA0020001CBSMsg2List; import eo.ejb.common.JCCModelCommon; import eo.ejb.common.JKKCtrlTnInfo; import eo.ejb.common.JWCCtrlTnInfo; public class JEKKA0020001TPMA implements TemplateMainHandler { // コマンド実行部品用 public static void ctrlTnInfo(CAANMsg inCBSMsg, AgentDispatchContext inContext) { Hashtable serviceMap = new Hashtable(); ArrayList>list = new ArrayList>(); CAANMsg[] listCaan = inCBSMsg.getCAANMsgList(EKKA0020001CBSMsg.EKKA0020001CBSMSG1LIST); Hashtable serviceMapList_head = new Hashtable(); //operatorID String operatorId = inCBSMsg.getString(EKKA0020001CBSMsg.OPERATORID); if(operatorId != null) { serviceMapList_head.put(JWCCtrlTnInfo.OPERATORID, operatorId); } else { serviceMapList_head.put(JWCCtrlTnInfo.OPERATORID, ""); } //operatorDateTime String operatoDateTime = inCBSMsg.getString(EKKA0020001CBSMsg.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_setplace_no = listCaan[i].getString(EKKA0020001CBSMsg1List.KEY_SETPLACE_NO); if(key_setplace_no != null) { serviceMapList.put(EKKA0020001CBSMsg1List.KEY_SETPLACE_NO, key_setplace_no); } else { serviceMapList.put(EKKA0020001CBSMsg1List.KEY_SETPLACE_NO, ""); } list.add(serviceMapList); } serviceMap.put(EKKA0020001CBSMsg.EKKA0020001CBSMSG1LIST, 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_KKA0001(serviceMap, con); CAANMsg[] l_ekka0020001csvmsg2list = null; // 取得した戻り値を元に、inCBSMsgのアウト項目に値を設定して返す ArrayList> retlist = (ArrayList>)ret.get(EKKA0020001CBSMsg.EKKA0020001CBSMSG2LIST); String error_level = (String)ret.get("errorLevel"); if(error_level != null) { inCBSMsg.set(EKKA0020001CBSMsg.ERROR_LEVEL, error_level); } else { inCBSMsg.set(EKKA0020001CBSMsg.ERROR_LEVEL, ""); } String return_cd = (String)ret.get("returnCode"); if(return_cd != null) { inCBSMsg.set(EKKA0020001CBSMsg.RETURN_CD, return_cd); } else { inCBSMsg.set(EKKA0020001CBSMsg.RETURN_CD, ""); } String return_message = (String)ret.get("returnMessage"); if(return_message != null) { inCBSMsg.set(EKKA0020001CBSMsg.RETURN_MESSAGE, return_message); } else { inCBSMsg.set(EKKA0020001CBSMsg.RETURN_MESSAGE, ""); } //エラーレベルが000より大きければ処理を終了する。 if(ret.get("errorLevel") != null && !((String)ret.get("errorLevel")).equals("000")) { inCBSMsg.set(EKKA0020001CBSMsg.STATUS, StatusCodes.EXTERNAL_IF_ERR1); return; } if(retlist != null && !retlist.isEmpty()) { // うまくいけば戻りの電文を設定して終了する。 l_ekka0020001csvmsg2list = 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.EKKA0020001CBSMsg2List"); l_ekka0020001csvmsg2list[i] = msg; //設置場所番号 msg.set(EKKA0020001CBSMsg2List.SETPLACE_NO, (String)data.get(EKKA0020001CBSMsg2List.SETPLACE_NO)); //設置場所住所コード msg.set(EKKA0020001CBSMsg2List.SETPLACE_AD_CD, (String)data.get(EKKA0020001CBSMsg2List.SETPLACE_AD_CD)); //設置場所郵便番号 msg.set(EKKA0020001CBSMsg2List.SETPLACE_PCD, (String)data.get(EKKA0020001CBSMsg2List.SETPLACE_PCD)); //設置場所都道府県名 msg.set(EKKA0020001CBSMsg2List.SETPLACE_STATE_NM, (String)data.get(EKKA0020001CBSMsg2List.SETPLACE_STATE_NM)); //設置場所市区町村名 msg.set(EKKA0020001CBSMsg2List.SETPLACE_CITY_NM, (String)data.get(EKKA0020001CBSMsg2List.SETPLACE_CITY_NM)); //設置場所大字通称名 msg.set(EKKA0020001CBSMsg2List.SETPLACE_OAZTSU_NM, (String)data.get(EKKA0020001CBSMsg2List.SETPLACE_OAZTSU_NM)); //設置場所字丁目名 msg.set(EKKA0020001CBSMsg2List.SETPLACE_AZCHO_NM, (String)data.get(EKKA0020001CBSMsg2List.SETPLACE_AZCHO_NM)); //設置場所番地号 msg.set(EKKA0020001CBSMsg2List.SETPLACE_BNCHIGO, (String)data.get(EKKA0020001CBSMsg2List.SETPLACE_BNCHIGO)); //設置場所住所補記・建物名 msg.set(EKKA0020001CBSMsg2List.SETPLACE_ADRTTM, (String)data.get(EKKA0020001CBSMsg2List.SETPLACE_ADRTTM)); //設置場所住所補記・部屋番号 msg.set(EKKA0020001CBSMsg2List.SETPLACE_ADRRM, (String)data.get(EKKA0020001CBSMsg2List.SETPLACE_ADRRM)); } inCBSMsg.set(EKKA0020001CBSMsg.EKKA0020001CBSMSG2LIST, l_ekka0020001csvmsg2list); } } catch(Exception e) { e.printStackTrace(); inCBSMsg.set(EKKA0020001CBSMsg.STATUS, StatusCodes.EXTERNAL_IF_ERR1); } // OM-2017-0000488 2017/05/26 ADD START finally { // 資源の解放 if (con != null) { CAANConnectionMgr.getInstance().close(con); } } // OM-2017-0000488 2017/05/26 ADD END } }