/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbCR0011KRCK * ソースファイル名：JSYejbCR0011KRCK.java * 作成者 ：EK909582 * 日付 ：2014年02月06日 *＜機能概要＞ * 関連チェック部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * ｖ56.00.00 2021/12/02 FJ)舘山 ANK-4174-00-00_開通前マイページ関連業務改善（2022年1月下旬リリース） * ********************************************************************************/ package eo.ejb.cbm.entity; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Timestamp; import java.text.SimpleDateFormat; import java.text.ParsePosition; import com.fujitsu.futurity.model.ejb.common.JSYejbLog; 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 eo.ejb.common.EventIDList; import com.fujitsu.futurity.model.ejb.common.fw.KanrenCheckHandler; import eo.ejb.common.entity.JCRejbCR0011KRCK; import eo.ejb.common.JPCModelCommon; import com.fujitsu.futurity.model.base.CAANConnectionMgr; import com.fujitsu.futurity.model.base.CAANJDBCUtil; import com.fujitsu.futurity.model.base.CAANMsg; import com.fujitsu.futurity.model.base.CAANRuntimeException; /** * 対応記録関連チェッククラスです。 * ＜メソッド一覧＞ * invoke * execICR0011C001_1 * execICR0011C001_2 * execICR0011C003_1 * execICR0011C003_2 * execICR0011C004_1 * execICR0011C004_5 * execICR0011C004_6 * execICR0011C004_8 * execICR0011C005_1 * execICR0011C005_2 * execICR0011C006_1 * execICR0011C006_2 * execICR0011C007_1 * execICR0011C007_2 * execICR0011C009_1 * execICR0011C009_2 * execICR0011C010_1 * execICR0011C010_2 * execICR0011C011_1 * execICR0011C011_2 * execICR0011C012_1 * execICR0011C012_2 * execICR0011C013_1 * execICR0011C013_2 * execICR0011C014_1 * execICR0011C014_3 * execICR0011C015_1 * execICR0011C015_2 * execICR0011D003_1 * execICR0021C001_1 * execICR0021C002_1 * execICR0021C003_2 * execICR0021C004_1 * execICR0021D004_2 * execICR0021D005_2 * execICR0021D014_2 * execICR0021D015_2 * execICR0021D017_2 * execICR0021D018_2 * execICR0021D019_2 * execICR0021D020_5 * execICR0021D021_2 * execICR0031D001_1 * execICR0111C002_3 * execICR0231D001_2 * execICR0431D001_1 * execIKK2491D001_6 * execIZM0181C001_6 * execIZM0181D001_7 * */ public class JSYejbCR0011KRCK implements KanrenCheckHandler { /** * コンストラクタ */ public JSYejbCR0011KRCK() { } /** * 対応記録関連チェックを行います。 * * @param inETMsg エンティティ * @param inContext Agentから渡されたAgentDispatchContext */ public void invoke(CAANMsg inETMsg, AgentDispatchContext inContext) { JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "call:JSYejbCR0011KRCK.invoke"); // inETMsgのチェック if(inETMsg == null) { throw new CAANRuntimeException("inETMsgがnullです。"); } // 振舞IDの取り出し String eventID = inETMsg.getString("eventID"); if(eventID == null) { throw new CAANRuntimeException("振舞IDがnullです。"); } // 処理の振り分け // イベントの振り分け if(eventID.equals(EventIDList.ICR0011C001)){ /** 対応記録キャンセル振舞内部 */ int Rtn = 0; Rtn = execICR0011C001_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C001_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C003)){ /** 対応記録エスカレーションアクセプト振舞内部 */ int Rtn = 0; Rtn = execICR0011C003_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C003_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C004)){ /** 対応記録内容変更振舞内部 */ int Rtn = 0; Rtn = execICR0011C004_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C004_5(inETMsg, inContext, "EE"); } if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C004_6(inETMsg, inContext, "EF"); } if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C004_8(inETMsg, inContext, "ED"); } }else if(eventID.equals(EventIDList.ICR0011C005)){ /** 対応記録エスカレーション開始(キューBOX)振舞内部 */ int Rtn = 0; Rtn = execICR0011C005_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C005_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C006)){ /** 対応記録エスカレーション開始（ユーザー）振舞内部 */ int Rtn = 0; Rtn = execICR0011C006_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C006_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C007)){ /** 対応記録エスカレーションリジェクト振舞内部 */ int Rtn = 0; Rtn = execICR0011C007_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C007_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C009)){ /** 対応記録キャンセル再開振舞内部 */ int Rtn = 0; Rtn = execICR0011C009_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C009_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C010)){ /** 対応記録クローズ振舞内部 */ int Rtn = 0; Rtn = execICR0011C010_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C010_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C011)){ /** 対応記録強制取得振舞内部 */ int Rtn = 0; Rtn = execICR0011C011_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C011_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C012)){ /** 対応記録クローズ再開振舞内部 */ int Rtn = 0; Rtn = execICR0011C012_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C012_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C013)){ /** 対応記録簡易メモ変更振舞内部 */ int Rtn = 0; Rtn = execICR0011C013_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C013_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C014)){ /** 対応記録問合せ客紐付振舞内部 */ int Rtn = 0; Rtn = execICR0011C014_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C014_3(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011C015)){ /** 対応記録変更(資料送付指示)振舞内部 */ int Rtn = 0; Rtn = execICR0011C015_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execICR0011C015_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.ICR0011D003)){ /** 対応記録登録振舞内部 */ int Rtn = 0; Rtn = execICR0011D003_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICR0021C001)){ /** 対応記録明細変更振舞内部 */ int Rtn = 0; Rtn = execICR0021C001_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICR0021C002)){ /** 対応記録明細変更(メモ)振舞内部 */ int Rtn = 0; Rtn = execICR0021C002_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICR0021C003)){ /** 対応記録明細変更(返信メール作成)振舞内部 */ int Rtn = 0; Rtn = execICR0021C003_2(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICR0021C004)){ /** 対応記録明細変更(メール転送)振舞内部 */ int Rtn = 0; Rtn = execICR0021C004_1(inETMsg, inContext, "EA"); // ANK-4174-00-00 ADD START }else if(eventID.equals(EventIDList.ICR0021C005)){ /** 対応記録明細変更(SMS送信)振舞内部 */ int Rtn = 0; Rtn = execICR0021C004_1(inETMsg, inContext, "EA"); // ANK-4174-00-00 ADD END }else if(eventID.equals(EventIDList.ICR0021D004)){ /** 対応記録明細登録振舞内部 */ int Rtn = 0; Rtn = execICR0021D004_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.ICR0021D005)){ /** 対応記録明細登録振舞内部 */ int Rtn = 0; Rtn = execICR0021D005_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.ICR0021D014)){ /** 対応記録明細登録(メモ)振舞内部 */ int Rtn = 0; Rtn = execICR0021D014_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.ICR0021D015)){ /** 対応記録明細登録(返信メール作成)振舞内部 */ int Rtn = 0; Rtn = execICR0021D015_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.ICR0021D017)){ /** 対応記録明細登録(返信メール送信)振舞内部 */ int Rtn = 0; Rtn = execICR0021D017_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.ICR0021D018)){ /** 対応記録明細登録(メール転送)振舞内部 */ int Rtn = 0; Rtn = execICR0021D018_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.ICR0021D019)){ /** 対応記録明細登録(転送メール送信)振舞内部 */ int Rtn = 0; Rtn = execICR0021D019_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.ICR0021D020)){ /** 対応記録明細登録(資料送付指示)振舞内部 */ int Rtn = 0; Rtn = execICR0021D020_5(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.ICR0021D021)){ /** 対応記録明細登録(SMS送信)振舞内部 */ int Rtn = 0; Rtn = execICR0021D021_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.ICR0031D001)){ /** 対応記録内訳登録振舞内部 */ int Rtn = 0; Rtn = execICR0031D001_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICR0111C002)){ /** キューBOX削除振舞内部 */ int Rtn = 0; Rtn = execICR0111C002_3(inETMsg, inContext, "EC"); }else if(eventID.equals(EventIDList.ICR0231D001)){ /** 対応履歴電子ファイル管理登録振舞内部 */ int Rtn = 0; Rtn = execICR0231D001_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.ICR0431D001)){ /** 資料送付記録登録振舞概念 */ int Rtn = 0; Rtn = execICR0431D001_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK2491D001)){ /** 電話番号予約復活用ワーク登録振舞内部 */ int Rtn = 0; Rtn = execIKK2491D001_6(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IZM0181C001)){ /** 電話番号予約変更振舞内部 */ int Rtn = 0; Rtn = execIZM0181C001_6(inETMsg, inContext, "EE"); }else if(eventID.equals(EventIDList.IZM0181D001)){ /** 電話番号予約登録振舞内部 */ int Rtn = 0; Rtn = execIZM0181D001_7(inETMsg, inContext, "EG"); } JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "end:JSYejbCR0011KRCK.invoke"); } /** * ICR0011C001_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C001_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C001_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C001_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C003_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C003_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C003_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C003_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C004_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C004_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C004_制約ＮＯ5チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C004_5(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; // チェック条件定数 // 制約部品引数定義 Object joken_1_prm_1 = "1"; Object joken_1_prm_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken_1_prm_2 = inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO); } Object joken_1_prm_3 = null; if(!inETMsg.isNull(CR0011ETMsg.CALLBK_KIBO_YMD)){ joken_1_prm_3 = inETMsg.getObject(CR0011ETMsg.CALLBK_KIBO_YMD); } Object joken_1_prm_4 = null; if(!inETMsg.isNull(CR0011ETMsg.CALLBK_KIBO_TIME)){ joken_1_prm_4 = inETMsg.getObject(CR0011ETMsg.CALLBK_KIBO_TIME); } Object joken_1_prm_5 = null; if(!inETMsg.isNull(CR0011ETMsg.CALLBK_SHITEI_TYPE_CD)){ joken_1_prm_5 = inETMsg.getObject(CR0011ETMsg.CALLBK_SHITEI_TYPE_CD); } // チェック条件 if (inETMsg.isNull(CR0011ETMsg.CALLBK_SHITEI_TYPE_CD) && !inETMsg.isNull(CR0011ETMsg.CALLBK_KIBO_YMD)) { // 判定条件 if(!(JCRejbCR0011KRCK.isCheckCallbkKiboDtm(inETMsg, inContext, joken_1_prm_1, joken_1_prm_2, joken_1_prm_3, joken_1_prm_4, joken_1_prm_5 ) == true)){ inETMsg.set(CR0011ETMsg.CALLBK_KIBO_TIME_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C004_制約ＮＯ6チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C004_6(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; // チェック条件定数 // 制約部品引数定義 Object joken_1_prm_1 = "2"; Object joken_1_prm_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken_1_prm_2 = inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO); } Object joken_1_prm_3 = null; if(!inETMsg.isNull(CR0011ETMsg.CALLBK_KIBO_YMD)){ joken_1_prm_3 = inETMsg.getObject(CR0011ETMsg.CALLBK_KIBO_YMD); } Object joken_1_prm_4 = null; if(!inETMsg.isNull(CR0011ETMsg.CALLBK_KIBO_TIME)){ joken_1_prm_4 = inETMsg.getObject(CR0011ETMsg.CALLBK_KIBO_TIME); } Object joken_1_prm_5 = null; if(!inETMsg.isNull(CR0011ETMsg.CALLBK_SHITEI_TYPE_CD)){ joken_1_prm_5 = inETMsg.getObject(CR0011ETMsg.CALLBK_SHITEI_TYPE_CD); } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.CALLBK_SHITEI_TYPE_CD) && !inETMsg.isNull(CR0011ETMsg.CALLBK_KIBO_YMD)) { // 判定条件 if(!(JCRejbCR0011KRCK.isCheckCallbkKiboDtm(inETMsg, inContext, joken_1_prm_1, joken_1_prm_2, joken_1_prm_3, joken_1_prm_4, joken_1_prm_5 ) == true)){ inETMsg.set(CR0011ETMsg.CALLBK_KIBO_YMD_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C004_制約ＮＯ8チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C004_8(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; // 制約部品引数定義 Object joken_1_prm_1 = "CR0011"; // 判定条件 if(JPCModelCommon.succeededExclusiveLock(inETMsg, inContext, joken_1_prm_1 ) == false){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C005_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C005_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C005_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C005_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken5_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_5 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken5_2 == null){ joken_5 += " IS NULL "; }else{ joken_5 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_5 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken5_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken5_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C006_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C006_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C006_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C006_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; String joken3_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken3_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C007_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C007_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C007_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C007_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C009_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C009_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C009_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C009_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C010_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C010_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C010_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C010_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C011_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C011_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C011_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C011_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C012_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C012_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C012_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C012_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C013_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C013_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C013_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C013_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C014_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C014_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C014_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C014_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C015_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C015_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011C015_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011C015_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(CR0011ETMsg.UPD_DTM)){ joken2_2 = new String(inETMsg.getObject(CR0011ETMsg.UPD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.UPD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO) && !inETMsg.isNull(CR0011ETMsg.UPD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0011ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0011D003_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0011D003_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0011ETMsg.TAIO_KIROK_NO).toString()); } // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0011ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append(joken_1); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(rsltQuery.getLong("CNT")>0){ inETMsg.set(CR0011ETMsg.TAIO_USER_ID_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0011ETMsg.STATUS)) { inETMsg.set(CR0011ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021C001_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021C001_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021C002_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021C002_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021C003_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021C003_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021C004_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021C004_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021D004_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021D004_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021D005_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021D005_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021D014_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021D014_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021D015_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021D015_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021D017_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021D017_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021D018_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021D018_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021D019_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021D019_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021D020_制約ＮＯ5チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021D020_5(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0021D021_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0021D021_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0021ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0021ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0021ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0021ETMsg.STATUS)) { inETMsg.set(CR0021ETMsg.STATUS, rtn); } return rtn; } /** * ICR0031D001_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0031ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0031D001_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0031ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0031ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0031ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0031ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0031ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0031ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0031ETMsg.STATUS)) { inETMsg.set(CR0031ETMsg.STATUS, rtn); } return rtn; } /** * ICR0111C002_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(CR0111ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0111C002_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0111ETMsg.QUE_BOX_NO)){ joken1_2 = new String(inETMsg.getObject(CR0111ETMsg.QUE_BOX_NO).toString()); } String joken2_2 = "102"; String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.QUE_BOX_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TOIAWASE_STAT_CD); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0111ETMsg.QUE_BOX_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + "(" + joken_1 + " AND " + joken_2 + " ) " + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(rsltQuery.getLong("CNT")>0){ inETMsg.set(CR0111ETMsg.QUE_BOX_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0111ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0111ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0111ETMsg.STATUS)) { inETMsg.set(CR0111ETMsg.STATUS, rtn); } return rtn; } /** * ICR0231D001_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CR0231ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0231D001_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0231ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0231ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0231ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0231ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0231ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0231ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0231ETMsg.STATUS)) { inETMsg.set(CR0231ETMsg.STATUS, rtn); } return rtn; } /** * ICR0431D001_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CR0431ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICR0431D001_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CR0431ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(CR0431ETMsg.TAIO_KIROK_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CR0431ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_3 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken3_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken3_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(CR0431ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CR0431ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(CR0431ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CR0431ETMsg.STATUS)) { inETMsg.set(CR0431ETMsg.STATUS, rtn); } return rtn; } /** * IKK2491D001_制約ＮＯ6チェック * * @param inETMsg チェック対象のETMsg(KK2491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK2491D001_6(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK2491ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(KK2491ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK2491ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(KK2491ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK2491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(KK2491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK2491ETMsg.STATUS)) { inETMsg.set(KK2491ETMsg.STATUS, rtn); } return rtn; } /** * IZM0181C001_制約ＮＯ6チェック * * @param inETMsg チェック対象のETMsg(ZM0181ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIZM0181C001_6(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(ZM0181ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(ZM0181ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(ZM0181ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(ZM0181ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(ZM0181ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(ZM0181ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(ZM0181ETMsg.STATUS)) { inETMsg.set(ZM0181ETMsg.STATUS, rtn); } return rtn; } /** * IZM0181D001_制約ＮＯ7チェック * * @param inETMsg チェック対象のETMsg(ZM0181ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIZM0181D001_7(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(CR0011ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(ZM0181ETMsg.TAIO_KIROK_NO)){ joken1_2 = new String(inETMsg.getObject(ZM0181ETMsg.TAIO_KIROK_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.TAIO_KIROK_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = CR0011ETMsg.getDBColumnName(CR0011ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(ZM0181ETMsg.TAIO_KIROK_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(CR0011ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_2 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken2_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken2_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(!(rsltQuery.getLong("CNT")>0)){ inETMsg.set(ZM0181ETMsg.TAIO_KIROK_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(ZM0181ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // このメソッドで確保した資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmtQuery != null) { pstmtQuery.close(); } if(con != null) { CAANConnectionMgr.getInstance().close(con); } } catch(SQLException e) { inETMsg.set(ZM0181ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(ZM0181ETMsg.STATUS)) { inETMsg.set(ZM0181ETMsg.STATUS, rtn); } return rtn; } }