/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbETU0071B010TPDA
* ソースファイル名：JSYejbETU0071B010TPDA.java
* 作成者 ：EK908591
* 日付 ：2012年02月22日
*＜機能概要＞
* 法人用番ポ可否情報取得テンプレートDBアクセス部品です。
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* v3.00.00 2012/03/17 FJ)楠神 新規作成
* v8.00.00 2014/05/16 FJ)高橋 【ANK-2063-00-00】
* v72.00.00 2024/03/11 FJ)永井 ANK-4494-00-00 【eo定期】 双方向番ポ対応
********************************************************************************/
package eo.ejb.cbs.sqlf;
import com.fujitsu.futurity.model.base.CAANMsg;
import com.fujitsu.futurity.model.base.CAANSQLFacility;
import com.fujitsu.futurity.model.base.CAANRuntimeException;
import com.fujitsu.futurity.model.base.CAANJDBCUtil;
import com.fujitsu.futurity.model.ejb.common.JSYejbConnection;
import com.fujitsu.futurity.model.ejb.common.JSYejbLog;
import com.fujitsu.futurity.model.ejb.common.StatusCodes;
import com.fujitsu.futurity.model.ejb.common.fw.TemplateDBAccessHandler;
import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import eo.common.constant.JPCModelConstant;
import eo.ejb.cbs.cbsmsg.ETU0071B010CBSMsg;
import eo.ejb.cbs.cbsmsg.ETU0071B010CBSMsg1List;
import eo.ejb.cbm.entity.AC0091ETMsg;
/**
*
* テンプレートDBアクセス部品 ETU0071B010_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
* @author FJ
*/
public class JSYejbETU0071B010TPDA extends CAANSQLFacility implements TemplateDBAccessHandler
{
/**
* コンストラクタ
*/
public JSYejbETU0071B010TPDA()
{
}
/**
* ETU0071B010_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @param inContext
* @return void
*/
public void invoke(CAANMsg inMsg, AgentDispatchContext inContext)
{
// コネクション
Connection con1 = null;
// プリペアステートメント
PreparedStatement pstmt = null;
// リザルトセット
ResultSet rsltQuery = null;
/********************
* SQL文の作成
********************/
try
{
//コネクション取得
con1 = JSYejbConnection.getConnection(AC0091ETMsg.getTableName());
// SQL文_基本部1
StringBuffer sql_Buff = new StringBuffer();
sql_Buff.append(" SELECT ")
.append(" ZM0301.NO_KUKAKU_CD, ")
.append(" ZM0301.HOJIN_NRN_NO, ")
.append(" ZM0301.HOJIN_NRN_NO_KOPT_MONAI, ")
.append(" ZM0301.KYOKU_NO_TSTAYMD, ")
.append(" ZM0301.KYOKU_NO_TENDYMD ")
.append(" FROM ");
// ANK-4494-00-00 MOD START
// // 番ポ種別コードが"0"の場合
if ("0".equals(inMsg.getObject(ETU0071B010CBSMsg.KEY_BMP_SBT_CD).toString()))
{
// sql_Buff.append(" TU_M_BMPKNAREA_TGKB TU0071 ")
// .append(" LEFT OUTER JOIN ZM_M_KYOKU_NO ZM0301 ON ")
sql_Buff.append(" ZM_M_KYOKU_NO ZM0301 ");
}
// 番ポ種別コードが"1"の場合
else
{
sql_Buff.append(" ZM_M_TELNO ZM0121 ")
.append(" LEFT OUTER JOIN ZM_M_KYOKU_NO ZM0301 ON ")
.append(" ZM0121.KYOKU_NO = ZM0301.KYOKU_NO AND ")
.append(" ZM0301.MK_FLG = '0' ");
}
// ANK-4494-00-00 MOD END
// SQL文_個別部1
if ("1".equals(inMsg.getObject(ETU0071B010CBSMsg.FUNC_CODE).toString()))
{
// 番ポ種別コードが"0"の場合
if ("0".equals(inMsg.getObject(ETU0071B010CBSMsg.KEY_BMP_SBT_CD).toString()))
{
sql_Buff.append(" WHERE ")
.append(" ZM0301.KYOKU_NO = SUBSTR(?, 0, 6) AND ")
.append(" ZM0301.MK_FLG = '0' ");
// ANK-4494-00-00 DEL START
// .append(" TU0071.JUDGE_KYOKU_NO = SUBSTR(?, 0, 7) ")
// .append(" AND ")
// .append(" TU0071.MK_FLG = '0' ");
// .append(" ZM0121.TELNO = ? ")
// .append(" AND ")
// .append(" ( ")
// .append(" ZM0121.TLN_STKU_TSJGS_CD IS NULL ")
// .append(" OR ")
// .append(" ZM0121.TLN_STKU_TSJGS_CD <> '5100' ")
// .append(" OR ")
// .append(" ( ")
// .append(" ZM0121.TLN_STKU_TSJGS_CD = '5100' ")
// .append(" AND ")
// .append(" ZM0121.ITNS_TSJGS_CD IS NOT NULL ")
// .append(" AND ")
// .append(" ZM0121.ITNS_TSJGS_CD <> '5100' ")
// .append(" ) ")
// .append(" ) ")
// .append(" AND ")
// .append(" ZM0121.MK_FLG = '0' ");
// ANK-4494-00-00 DEL END
}
// 番ポ種別コードが"1"の場合
else
{
sql_Buff.append(" WHERE ")
.append(" ZM0121.TELNO = ? ")
.append(" AND ")
// ANK-4494-00-00 MOD START
// .append(" ZM0121.WARIATE_TSJGS_CD = '5100' ")
.append(" ZM0121.TLN_STKU_TSJGS_CD = '5100' ")
// ANK-4494-00-00 MOD END
.append(" AND ")
.append(" ZM0121.HKAT_SIYK_SBT_CD IS NULL ")
.append(" AND ")
.append(" ZM0121.MK_FLG = '0' ");
}
}
//prepareStatementにSQL文をセット
pstmt = con1.prepareStatement(sql_Buff.toString());
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ("1".equals(inMsg.getString(ETU0071B010CBSMsg.FUNC_CODE)))
{
// パラメータの設定(ＫＥＹ＿電話番号を指定)
CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(ETU0071B010CBSMsg.KEY_TELNO));
}
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// ETU0071B010CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
ETU0071B010CBSMsg1List.NO_KUKAKU_CD
, ETU0071B010CBSMsg1List.HOJIN_NRN_NO
, ETU0071B010CBSMsg1List.HOJIN_NRN_NO_KOPT_MONAI
, ETU0071B010CBSMsg1List.KYOKU_NO_TSTAYMD
, ETU0071B010CBSMsg1List.KYOKU_NO_TENDYMD
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery, msgKeyList1, "eo.ejb.cbs.cbsmsg.ETU0071B010CBSMsg1List", 0);
/**
* 検索エラーフラグの設定
*/
// 一括検索の場合
// 検索件数が0件の場合、エラーフラグに"1"を設定して処理終了
if (0 == outMsg1.length)
{
inMsg.set(ETU0071B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO);
inMsg.set(ETU0071B010CBSMsg.TOTAL_SEARCH_NUM, "0");
return;
}
//総検索件数を設定
inMsg.set(ETU0071B010CBSMsg.TOTAL_SEARCH_NUM, Integer.toString(outMsg1.length));
// inMsg(CBSMsg)に明細をセット
inMsg.set("ETU0071B010CBSMsg1List", outMsg1);
}
catch(SQLException e)
{
inMsg.set(ETU0071B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
finally
{
// 資源の解放
try
{
if(rsltQuery != null)
{
rsltQuery.close();
}
if(pstmt != null)
{
pstmt.close();
}
if(con1 != null)
{
closeConnection(con1);
}
}
catch(SQLException e)
{
inMsg.set(ETU0071B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
}
}