/*******************************************************************************
* All Rights reserved,Copyright (c) K-Opticom
********************************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JSYejbECK0151B020TPDA
* ソースファイル名：JSYejbECK0151B020TPDA.java
* 作成者 ：EK907778
* 日付 ：2012年05月23日
*＜機能概要＞
* 指示書一覧照会（任意条件）テンプレートDBアクセス部品です。
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* ｖ1.00.00
*
********************************************************************************/
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.ejb.cbs.cbsmsg.ECK0151B020CBSMsg;
import eo.ejb.cbs.cbsmsg.ECK0151B020CBSMsg1List;
import eo.ejb.cbm.entity.CK0151ETMsg;
/**
*
* テンプレートDBアクセス部品 ECK0151B020_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/
public class JSYejbECK0151B020TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{
/**
* コンストラクタ
*/
public JSYejbECK0151B020TPDA() {
}
/**
* ECK0151B020_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void
*/
public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){
// コネクション
Connection con1 = null;
// プリペアステートメント
PreparedStatement pstmt = null;
// リザルトセット
ResultSet rsltQuery = null;
/********************
* SQL文の作成
********************/
try{
//コネクション取得
con1 = JSYejbConnection.getConnection(CK0151ETMsg.getTableName());
// SQL文_基本部1
StringBuffer sql_Buff = new StringBuffer();
sql_Buff.append(" SELECT A.SJISHO_NO, ")
.append(" A.SJISHO_NAIYO_SEQ, ")
.append(" A.TRN_CD, ")
.append(" A.TRGT_TABLE_ID, ")
.append(" A.ERR_CNT, ")
.append(" A.TRAN_TRGT_SYSID, ")
.append(" A.RSLT_FLG, ")
.append(" A.PARAMETER_YK_CNT, ")
.append(" A.PARAMETER_1, ")
.append(" A.PARAMETER_2, ")
.append(" A.PARAMETER_3, ")
.append(" A.PARAMETER_4, ")
.append(" A.PARAMETER_5, ")
.append(" A.PARAMETER_6, ")
.append(" A.PARAMETER_7, ")
.append(" A.PARAMETER_8, ")
.append(" A.PARAMETER_9, ")
.append(" A.PARAMETER_10, ")
.append(" A.PARAMETER_11, ")
.append(" A.PARAMETER_12, ")
.append(" A.PARAMETER_13, ")
.append(" A.PARAMETER_14, ")
.append(" A.PARAMETER_15, ")
.append(" A.PARAMETER_16, ")
.append(" A.PARAMETER_17, ")
.append(" A.PARAMETER_18, ")
.append(" A.PARAMETER_19, ")
.append(" A.PARAMETER_20, ")
.append(" A.PARAMETER_21, ")
.append(" A.PARAMETER_22, ")
.append(" A.PARAMETER_23, ")
.append(" A.PARAMETER_24, ")
.append(" A.PARAMETER_25, ")
.append(" A.PARAMETER_26, ")
.append(" A.PARAMETER_27, ")
.append(" A.PARAMETER_28, ")
.append(" A.PARAMETER_29, ")
.append(" A.PARAMETER_30, ")
.append(" A.PARAMETER_31, ")
.append(" A.PARAMETER_32, ")
.append(" A.PARAMETER_33, ")
.append(" A.PARAMETER_34, ")
.append(" A.PARAMETER_35, ")
.append(" A.PARAMETER_36, ")
.append(" A.PARAMETER_37, ")
.append(" A.PARAMETER_38, ")
.append(" A.PARAMETER_39, ")
.append(" A.PARAMETER_40, ")
.append(" A.PARAMETER_41, ")
.append(" A.PARAMETER_42, ")
.append(" A.PARAMETER_43, ")
.append(" A.PARAMETER_44, ")
.append(" A.PARAMETER_45, ")
.append(" A.PARAMETER_46, ")
.append(" A.PARAMETER_47, ")
.append(" A.PARAMETER_48, ")
.append(" A.PARAMETER_49, ")
.append(" A.PARAMETER_50, ")
.append(" A.ADD_DTM, ")
.append(" A.ADD_OPEACNT, ")
.append(" A.UPD_DTM, ")
.append(" A.UPD_OPEACNT, ")
.append(" A.DEL_DTM, ")
.append(" A.DEL_OPEACNT, ")
.append(" A.MK_FLG ")
.append(" FROM CK_T_SJISHO A ");
// SQL文_個別部1
if ( "1".equals( inMsg.getObject(ECK0151B020CBSMsg.FUNC_CODE).toString() ) ) {
sql_Buff.append(" WHERE A.MK_FLG ='0' ");
if (inMsg.getObject(ECK0151B020CBSMsg.KEY_TRN_CD)!= null)
{
sql_Buff.append(" AND A.TRN_CD = ? ");
}
if(inMsg.getObject(ECK0151B020CBSMsg.KEY_TRGT_TABLE_ID) != null)
{
sql_Buff.append(" AND A.TRGT_TABLE_ID = ? ");
}
if(inMsg.getObject(ECK0151B020CBSMsg.KEY_ERR_CNT) != null)
{
sql_Buff.append(" AND A.ERR_CNT < ? ");
}
if (inMsg.getObject(ECK0151B020CBSMsg.KEY_TRAN_TRGT_SYSID)!= null)
{
sql_Buff.append(" AND A.TRAN_TRGT_SYSID = ? ");
}
if(inMsg.getObject(ECK0151B020CBSMsg.KEY_RSLT_FLG) != null)
{
sql_Buff.append(" AND A.RSLT_FLG = ? ");
}
if(inMsg.getObject(ECK0151B020CBSMsg.KEY_ERR_CNT) != null)
{
sql_Buff.append(" AND NOT EXISTS ( ")
.append(" /* エラー回数MAXを超えている指示書が残っているSYSIDの情報は取得しない */ ")
.append(" SELECT 1 ")
.append(" FROM CK_T_SJISHO ")
.append(" WHERE TRAN_TRGT_SYSID = A.TRAN_TRGT_SYSID ")
.append(" AND ERR_CNT >= ? ")
.append(" ) ");
}
sql_Buff.append("ORDER BY");
sql_Buff.append(" TRAN_TRGT_SYSID,");
sql_Buff.append(" SJISHO_NO,");
sql_Buff.append(" SJISHO_NAIYO_SEQ,");
sql_Buff.append(" ADD_DTM");
}
//prepareStatementにSQL文をセット
pstmt = con1.prepareStatement(sql_Buff.toString());
//ログ出力(SQL文の出力)
JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff);
// PreparedStatementの指定されたパラメータカラムに 指定された値を設定
if ( "1".equals( inMsg.getString(ECK0151B020CBSMsg.FUNC_CODE) ) ) {
int cnt=1;
if (inMsg.getObject(ECK0151B020CBSMsg.KEY_TRN_CD) != null)
{
// パラメータの設定(ＫＥＹ＿処理コードを指定)
CAANJDBCUtil.setParam(pstmt, cnt++, inMsg.getObject(ECK0151B020CBSMsg.KEY_TRN_CD));
}
if(inMsg.getObject(ECK0151B020CBSMsg.KEY_TRGT_TABLE_ID) != null)
{
// パラメータの設定(ＫＥＹ＿対象テーブルＩＤを指定)
CAANJDBCUtil.setParam(pstmt, cnt++, inMsg.getObject(ECK0151B020CBSMsg.KEY_TRGT_TABLE_ID));
}
if(inMsg.getObject(ECK0151B020CBSMsg.KEY_ERR_CNT) != null)
{
// パラメータの設定(ＫＥＹ＿エラー回数を指定)
CAANJDBCUtil.setParam(pstmt, cnt++, inMsg.getObject(ECK0151B020CBSMsg.KEY_ERR_CNT));
}
if (inMsg.getObject(ECK0151B020CBSMsg.KEY_TRAN_TRGT_SYSID)!= null)
{
// パラメータの設定(ＫＥＹ＿処理対象ＳＹＳＩＤを指定)
CAANJDBCUtil.setParam(pstmt, cnt++, inMsg.getObject(ECK0151B020CBSMsg.KEY_TRAN_TRGT_SYSID));
}
if(inMsg.getObject(ECK0151B020CBSMsg.KEY_RSLT_FLG) != null)
{
// パラメータの設定(ＫＥＹ＿結果フラグを指定)
CAANJDBCUtil.setParam(pstmt, cnt++, inMsg.getObject(ECK0151B020CBSMsg.KEY_RSLT_FLG));
}
if(inMsg.getObject(ECK0151B020CBSMsg.KEY_ERR_CNT) != null)
{
// パラメータの設定(ＫＥＹ＿エラー回数を指定)
CAANJDBCUtil.setParam(pstmt, cnt++, inMsg.getObject(ECK0151B020CBSMsg.KEY_ERR_CNT));
}
}
// ResultSetの取得
rsltQuery = pstmt.executeQuery();
// ECK0151B020CBSMsgの明細にセットする項目
String[] msgKeyList1 = {
ECK0151B020CBSMsg1List.SJISHO_NO
, ECK0151B020CBSMsg1List.SJISHO_NAIYO_SEQ
, ECK0151B020CBSMsg1List.TRN_CD
, ECK0151B020CBSMsg1List.TRGT_TABLE_ID
, ECK0151B020CBSMsg1List.ERR_CNT
, ECK0151B020CBSMsg1List.TRAN_TRGT_SYSID
, ECK0151B020CBSMsg1List.RSLT_FLG
, ECK0151B020CBSMsg1List.PARAMETER_YK_CNT
, ECK0151B020CBSMsg1List.PARAMETER_1
, ECK0151B020CBSMsg1List.PARAMETER_2
, ECK0151B020CBSMsg1List.PARAMETER_3
, ECK0151B020CBSMsg1List.PARAMETER_4
, ECK0151B020CBSMsg1List.PARAMETER_5
, ECK0151B020CBSMsg1List.PARAMETER_6
, ECK0151B020CBSMsg1List.PARAMETER_7
, ECK0151B020CBSMsg1List.PARAMETER_8
, ECK0151B020CBSMsg1List.PARAMETER_9
, ECK0151B020CBSMsg1List.PARAMETER_10
, ECK0151B020CBSMsg1List.PARAMETER_11
, ECK0151B020CBSMsg1List.PARAMETER_12
, ECK0151B020CBSMsg1List.PARAMETER_13
, ECK0151B020CBSMsg1List.PARAMETER_14
, ECK0151B020CBSMsg1List.PARAMETER_15
, ECK0151B020CBSMsg1List.PARAMETER_16
, ECK0151B020CBSMsg1List.PARAMETER_17
, ECK0151B020CBSMsg1List.PARAMETER_18
, ECK0151B020CBSMsg1List.PARAMETER_19
, ECK0151B020CBSMsg1List.PARAMETER_20
, ECK0151B020CBSMsg1List.PARAMETER_21
, ECK0151B020CBSMsg1List.PARAMETER_22
, ECK0151B020CBSMsg1List.PARAMETER_23
, ECK0151B020CBSMsg1List.PARAMETER_24
, ECK0151B020CBSMsg1List.PARAMETER_25
, ECK0151B020CBSMsg1List.PARAMETER_26
, ECK0151B020CBSMsg1List.PARAMETER_27
, ECK0151B020CBSMsg1List.PARAMETER_28
, ECK0151B020CBSMsg1List.PARAMETER_29
, ECK0151B020CBSMsg1List.PARAMETER_30
, ECK0151B020CBSMsg1List.PARAMETER_31
, ECK0151B020CBSMsg1List.PARAMETER_32
, ECK0151B020CBSMsg1List.PARAMETER_33
, ECK0151B020CBSMsg1List.PARAMETER_34
, ECK0151B020CBSMsg1List.PARAMETER_35
, ECK0151B020CBSMsg1List.PARAMETER_36
, ECK0151B020CBSMsg1List.PARAMETER_37
, ECK0151B020CBSMsg1List.PARAMETER_38
, ECK0151B020CBSMsg1List.PARAMETER_39
, ECK0151B020CBSMsg1List.PARAMETER_40
, ECK0151B020CBSMsg1List.PARAMETER_41
, ECK0151B020CBSMsg1List.PARAMETER_42
, ECK0151B020CBSMsg1List.PARAMETER_43
, ECK0151B020CBSMsg1List.PARAMETER_44
, ECK0151B020CBSMsg1List.PARAMETER_45
, ECK0151B020CBSMsg1List.PARAMETER_46
, ECK0151B020CBSMsg1List.PARAMETER_47
, ECK0151B020CBSMsg1List.PARAMETER_48
, ECK0151B020CBSMsg1List.PARAMETER_49
, ECK0151B020CBSMsg1List.PARAMETER_50
, ECK0151B020CBSMsg1List.ADD_DTM
, ECK0151B020CBSMsg1List.ADD_OPEACNT
, ECK0151B020CBSMsg1List.UPD_DTM
, ECK0151B020CBSMsg1List.UPD_OPEACNT
, ECK0151B020CBSMsg1List.DEL_DTM
, ECK0151B020CBSMsg1List.DEL_OPEACNT
, ECK0151B020CBSMsg1List.MK_FLG
};
// 明細に処理結果(ResultSet)をマッピング
CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.ECK0151B020CBSMsg1List",0);
// inMsg(CBSMsg)に明細をセット
inMsg.set("ECK0151B020CBSMsg1List", outMsg1);
} catch(SQLException e) {
inMsg.set(ECK0151B020CBSMsg.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(ECK0151B020CBSMsg.STATUS, StatusCodes.FIND_DB_ERR);
throw new CAANRuntimeException(e);
}
}
}
}