/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbKK0441KRCK * ソースファイル名：JSYejbKK0441KRCK.java * 作成者 ：EK912224 * 日付 ：2014年10月14日 *＜機能概要＞ * 関連チェック部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * ********************************************************************************/ 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 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 * execIKK0321D017_9 * execIKK0441C005_1 * execIKK0441C006_1 * execIKK0441C007_1 * execIKK0441C008_1 * execIKK0441C009_1 * execIKK0441D001_1 * execIKK0441D001_2 * execIKK0441D002_1 * execIKK0441D002_6 * execIKK0441D003_1 * execIKK0441D003_6 * execIKK0441D004_1 * execIKK0441D004_6 * execIKK0441D005_1 * execIKK0441D005_2 * execIKK0441D006_1 * execIKK0441D006_2 * execIKK0441D007_1 * execIKK0441D007_2 * execIKK0441D008_1 * execIKK0441D008_2 * execIKK0441D009_1 * execIKK0441D009_2 * execIKK0441D010_1 * execIKK0441D010_2 * execIKK0441D011_1 * execIKK0441D011_2 * execIKK0441D012_1 * execIKK0441D012_2 * execIKK0441D013_1 * execIKK0441D013_2 * execIKK0441D014_1 * execIKK0441D014_2 * execIKK0441D015_1 * execIKK0441D015_2 * execIKK0441D016_1 * execIKK0441D016_2 * execIKK0441D017_1 * execIKK0441D017_2 * execIKK0441D018_1 * execIKK0441D018_2 * execIKK0441D019_1 * execIKK0441D019_2 * execIKK0441D021_1 * execIKK0441D021_2 * execIKK0441D022_1 * execIKK0441D022_3 * execIKK0441D023_1 * execIKK0441D023_3 * execIKK0481D002_10 * execIKK0481D005_9 * execIKK0961D001_6 * execIKK1021D001_9 * execIKK1041D001_7 * execIKK1051D001_9 * execIKK1071D001_10 * execIKK1081D001_7 * execIKK1091D001_11 * execIKK1401D001_9 * execIKK1551D001_9 * execIKK1551D001_14 * execIKK2931D001_18 * */ public class JSYejbKK0441KRCK implements KanrenCheckHandler { /** * コンストラクタ */ public JSYejbKK0441KRCK() { } /** * 請求オプションサービス契約関連チェックを行います。 * * @param inETMsg エンティティ * @param inContext Agentから渡されたAgentDispatchContext */ public void invoke(CAANMsg inETMsg, AgentDispatchContext inContext) { JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "call:JSYejbKK0441KRCK.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.IKK0321D017)){ /** 課金先登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D017_9(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0441C005)){ /** 請求オプションサービス契約解約確定振舞内部 */ int Rtn = 0; Rtn = execIKK0441C005_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0441C006)){ /** 請求オプションサービス契約解約中止振舞内部 */ int Rtn = 0; Rtn = execIKK0441C006_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0441C007)){ /** 請求オプションサービス契約解約手続完了振舞内部 */ int Rtn = 0; Rtn = execIKK0441C007_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0441C008)){ /** 請求オプションサービス契約予約適用年月日振舞内部 */ int Rtn = 0; Rtn = execIKK0441C008_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0441C009)){ /** 請求オプションサービス契約料金プラン変更確定 */ int Rtn = 0; Rtn = execIKK0441C009_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0441D001)){ /** 請求オプションサービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0441D001_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D001_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D002)){ /** 請求オプションサービス契約解約振舞内部 */ int Rtn = 0; Rtn = execIKK0441D002_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D002_6(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D003)){ /** 請求オプションサービス契約情報変更振舞内部 */ int Rtn = 0; Rtn = execIKK0441D003_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D003_6(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D004)){ /** 請求オプションサービス契約キャンセル振舞内部 */ int Rtn = 0; Rtn = execIKK0441D004_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D004_6(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D005)){ /** 照査前請求オプションサービス契約キャンセル取消 */ int Rtn = 0; Rtn = execIKK0441D005_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D005_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D006)){ /** 照査後請求オプションサービス契約キャンセル取消 */ int Rtn = 0; Rtn = execIKK0441D006_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D006_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D007)){ /** 請求オプションサービス契約解約取消振舞内部 */ int Rtn = 0; Rtn = execIKK0441D007_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D007_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D008)){ /** 請求オプションサービス契約解約確定取消振舞内部 */ int Rtn = 0; Rtn = execIKK0441D008_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D008_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D009)){ /** 請求オプションサービス契約回復振舞内部 */ int Rtn = 0; Rtn = execIKK0441D009_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D009_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D010)){ /** 請求オプションサービス契約照査振舞内部 */ int Rtn = 0; Rtn = execIKK0441D010_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D010_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D011)){ /** 請求オプションサービス契約締結振舞内部 */ int Rtn = 0; Rtn = execIKK0441D011_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D011_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D012)){ /** 請求オプションサービス契約停止振舞内部 */ int Rtn = 0; Rtn = execIKK0441D012_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D012_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D013)){ /** 請求オプションサービス契約停止解除振舞内部 */ int Rtn = 0; Rtn = execIKK0441D013_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D013_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D014)){ /** 請求オプションサービス契約開始振舞内部 */ int Rtn = 0; Rtn = execIKK0441D014_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D014_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D015)){ /** 請求オプションサービス契約照査締結振舞内部 */ int Rtn = 0; Rtn = execIKK0441D015_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D015_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D016)){ /** 請求オプションサービス契約サービス契約変更振舞内部 */ int Rtn = 0; Rtn = execIKK0441D016_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D016_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D017)){ /** 請求オプションサービス契約照査取消振舞内部 */ int Rtn = 0; Rtn = execIKK0441D017_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D017_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D018)){ /** 請求オプションサービス契約手続中料金プラン振舞概念 */ int Rtn = 0; Rtn = execIKK0441D018_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D018_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D019)){ /** 休止中請求オプションサービス契約停止解除振舞内部 */ int Rtn = 0; Rtn = execIKK0441D019_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D019_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D021)){ /** 請求オプションサービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0441D021_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D021_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D022)){ /** 請求オプションサービス契約情報変更振舞内部 */ int Rtn = 0; Rtn = execIKK0441D022_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D022_3(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0441D023)){ /** 請求オプションサービス契約解約振舞内部 */ int Rtn = 0; Rtn = execIKK0441D023_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0441D023_3(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0481D002)){ /** 割引サービス対象契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0481D002_10(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0481D005)){ /** 割引サービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0481D005_9(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0961D001)){ /** 利用停止期間登録振舞内部 */ int Rtn = 0; Rtn = execIKK0961D001_6(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK1021D001)){ /** 一時金設定登録振舞内部 */ int Rtn = 0; Rtn = execIKK1021D001_9(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK1041D001)){ /** オーダ設定登録振舞内部 */ int Rtn = 0; Rtn = execIKK1041D001_7(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK1051D001)){ /** 契約一時金登録振舞内部 */ int Rtn = 0; Rtn = execIKK1051D001_9(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK1071D001)){ /** 審査登録振舞内部 */ int Rtn = 0; Rtn = execIKK1071D001_10(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK1081D001)){ /** オーダ発行条件登録振舞内部 */ int Rtn = 0; Rtn = execIKK1081D001_7(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK1091D001)){ /** 進捗登録振舞内部 */ int Rtn = 0; Rtn = execIKK1091D001_11(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK1401D001)){ /** データ抽出項目設定対象契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK1401D001_9(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK1551D001)){ /** オーダ情報作成ワーク登録振舞内部 */ int Rtn = 0; Rtn = execIKK1551D001_9(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK1551D001_14(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK2931D001)){ /** 申込時登録不可契約予約振舞内部 */ int Rtn = 0; Rtn = execIKK2931D001_18(inETMsg, inContext, "EA"); } JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "end:JSYejbKK0441KRCK.invoke"); } /** * IKK0321D017_制約ＮＯ9チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D017_9(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0321ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0321ETMsg.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(KK0321ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0321ETMsg.STATUS)) { inETMsg.set(KK0321ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441C005_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441C005_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441C006_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441C006_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441C007_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441C007_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441C008_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441C008_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } String joken5_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_5 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken5_2 == null){ joken_5 += " IS NULL "; }else{ joken_5 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441C009_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441C009_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D001_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D001_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken3_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken3_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SYSID_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D001_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D001_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SYSID_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D002_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D002_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D002_制約ＮＯ6チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D002_6(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D003_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D003_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D003_制約ＮＯ6チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D003_6(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D004_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D004_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D004_制約ＮＯ6チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D004_6(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D005_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D005_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D005_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D005_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D006_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D006_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D006_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D006_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D007_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D007_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D007_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D007_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D008_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D008_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D008_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D008_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D009_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D009_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D009_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D009_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D010_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D010_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D010_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D010_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D011_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D011_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D011_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D011_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D012_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D012_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D012_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D012_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D013_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D013_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D013_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D013_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D014_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D014_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D014_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D014_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D015_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D015_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D015_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D015_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D016_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D016_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D016_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D016_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D017_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D017_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D017_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D017_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D018_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D018_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D018_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D018_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D019_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D019_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D019_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D019_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D021_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D021_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken3_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken3_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SYSID_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D021_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D021_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SYSID_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D022_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D022_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D022_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D022_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D023_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D023_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0441ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK0441ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0441D023_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D023_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0441ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0441ETMsg.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(KK0441ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0441ETMsg.STATUS)) { inETMsg.set(KK0441ETMsg.STATUS, rtn); } return rtn; } /** * IKK0481D002_制約ＮＯ10チェック * * @param inETMsg チェック対象のETMsg(KK0481ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0481D002_10(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0481ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0481ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0481ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0481ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0481ETMsg.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(KK0481ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0481ETMsg.STATUS)) { inETMsg.set(KK0481ETMsg.STATUS, rtn); } return rtn; } /** * IKK0481D005_制約ＮＯ9チェック * * @param inETMsg チェック対象のETMsg(KK0481ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0481D005_9(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0481ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0481ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0481ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0481ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0481ETMsg.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(KK0481ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0481ETMsg.STATUS)) { inETMsg.set(KK0481ETMsg.STATUS, rtn); } return rtn; } /** * IKK0961D001_制約ＮＯ6チェック * * @param inETMsg チェック対象のETMsg(KK0961ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0961D001_6(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0961ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0961ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0961ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK0961ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0961ETMsg.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(KK0961ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0961ETMsg.STATUS)) { inETMsg.set(KK0961ETMsg.STATUS, rtn); } return rtn; } /** * IKK1021D001_制約ＮＯ9チェック * * @param inETMsg チェック対象のETMsg(KK1021ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1021D001_9(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1021ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1021ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1021ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK1021ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1021ETMsg.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(KK1021ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1021ETMsg.STATUS)) { inETMsg.set(KK1021ETMsg.STATUS, rtn); } return rtn; } /** * IKK1041D001_制約ＮＯ7チェック * * @param inETMsg チェック対象のETMsg(KK1041ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1041D001_7(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1041ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1041ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1041ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK1041ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1041ETMsg.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(KK1041ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1041ETMsg.STATUS)) { inETMsg.set(KK1041ETMsg.STATUS, rtn); } return rtn; } /** * IKK1051D001_制約ＮＯ9チェック * * @param inETMsg チェック対象のETMsg(KK1051ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1051D001_9(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1051ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1051ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1051ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK1051ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1051ETMsg.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(KK1051ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1051ETMsg.STATUS)) { inETMsg.set(KK1051ETMsg.STATUS, rtn); } return rtn; } /** * IKK1071D001_制約ＮＯ10チェック * * @param inETMsg チェック対象のETMsg(KK1071ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1071D001_10(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1071ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1071ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1071ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK1071ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1071ETMsg.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(KK1071ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1071ETMsg.STATUS)) { inETMsg.set(KK1071ETMsg.STATUS, rtn); } return rtn; } /** * IKK1081D001_制約ＮＯ7チェック * * @param inETMsg チェック対象のETMsg(KK1081ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1081D001_7(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1081ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1081ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1081ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK1081ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1081ETMsg.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(KK1081ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1081ETMsg.STATUS)) { inETMsg.set(KK1081ETMsg.STATUS, rtn); } return rtn; } /** * IKK1091D001_制約ＮＯ11チェック * * @param inETMsg チェック対象のETMsg(KK1091ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1091D001_11(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1091ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1091ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1091ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK1091ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1091ETMsg.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(KK1091ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1091ETMsg.STATUS)) { inETMsg.set(KK1091ETMsg.STATUS, rtn); } return rtn; } /** * IKK1401D001_制約ＮＯ9チェック * * @param inETMsg チェック対象のETMsg(KK1401ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1401D001_9(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1401ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1401ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1401ETMsg.SEIOPSVC_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK1401ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1401ETMsg.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(KK1401ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1401ETMsg.STATUS)) { inETMsg.set(KK1401ETMsg.STATUS, rtn); } return rtn; } /** * IKK1551D001_制約ＮＯ9チェック * * @param inETMsg チェック対象のETMsg(KK1551ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1551D001_9(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1551ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1551ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK1551ETMsg.SEIOPSVKEI_GADTM)){ joken2_2 = new String(inETMsg.getObject(KK1551ETMsg.SEIOPSVKEI_GADTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1551ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK1551ETMsg.SEIOPSVKEI_GADTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK1551ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1551ETMsg.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(KK1551ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1551ETMsg.STATUS)) { inETMsg.set(KK1551ETMsg.STATUS, rtn); } return rtn; } /** * IKK1551D001_制約ＮＯ14チェック * * @param inETMsg チェック対象のETMsg(KK1551ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1551D001_14(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1551ETMsg.SEIOPSVC_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1551ETMsg.SEIOPSVC_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK1551ETMsg.CHBF_SEIOPSVKEI_GADTM)){ joken2_2 = new String(inETMsg.getObject(KK1551ETMsg.CHBF_SEIOPSVKEI_GADTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1551ETMsg.SEIOPSVC_KEI_NO) && !inETMsg.isNull(KK1551ETMsg.CHBF_SEIOPSVKEI_GADTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK1551ETMsg.SEIOPSVC_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1551ETMsg.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(KK1551ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1551ETMsg.STATUS)) { inETMsg.set(KK1551ETMsg.STATUS, rtn); } return rtn; } /** * IKK2931D001_制約ＮＯ18チェック * * @param inETMsg チェック対象のETMsg(KK2931ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK2931D001_18(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0441ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 String joken3_1 = new String(); if(!inETMsg.isNull(KK2931ETMsg.SETE_TG_KEI_SKBT_CD)){ joken3_1 = inETMsg.getObject(KK2931ETMsg.SETE_TG_KEI_SKBT_CD).toString(); } String joken3_2 = "07"; // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK2931ETMsg.SETE_TG_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK2931ETMsg.SETE_TG_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.SEIOPSVC_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0441ETMsg.getDBColumnName(KK0441ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (joken3_1.compareTo(joken3_2) == 0 && !inETMsg.isNull(KK2931ETMsg.SETE_TG_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0441ETMsg.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(KK2931ETMsg.SETE_TG_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK2931ETMsg.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(KK2931ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK2931ETMsg.STATUS)) { inETMsg.set(KK2931ETMsg.STATUS, rtn); } return rtn; } }