/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbKK0491KRCK * ソースファイル名：JSYejbKK0491KRCK.java * 作成者 ：EK919112 * 日付 ：2015年09月18日 *＜機能概要＞ * 関連チェック部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ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 eo.ejb.common.JPCModelCommon; import com.fujitsu.futurity.model.base.CAANConnectionMgr; import com.fujitsu.futurity.model.base.CAANJDBCUtil; import com.fujitsu.futurity.model.base.CAANMsg; import com.fujitsu.futurity.model.base.CAANRuntimeException; /** * 請求契約関連チェッククラスです。 * ＜メソッド一覧＞ * invoke * execICH0011D002_1 * execICH0011D003_1 * execICH0111D002_1 * execICH0191D001_2 * execICH0191D002_2 * execICH0331C001_1 * execICH0331C002_1 * execICH0331D001_1 * execICK0061D001_3 * execIKK0321D002_2 * execIKK0321D003_2 * execIKK0321D004_2 * execIKK0321D005_2 * execIKK0321D006_2 * execIKK0321D008_2 * execIKK0321D009_2 * execIKK0321D010_2 * execIKK0321D011_2 * execIKK0321D012_2 * execIKK0321D013_2 * execIKK0321D014_2 * execIKK0321D016_2 * execIKK0321D017_2 * execIKK0321D018_2 * execIKK0321D019_1 * execIKK0321D020_1 * execIKK0321D025_1 * execIKK0441D001_9 * execIKK0441D021_9 * execIKK0491C001_1 * execIKK0491C001_3 * execIKK0491C002_1 * execIKK0491C002_3 * execIKK0491D001_1 * execIKK0491D001_2 * execIKK0491D002_1 * execIKK0491D002_2 * execIKK0491D003_1 * execIKK0491D003_2 * execIKK0491D003_5 * execIKK0491D004_1 * execIKK0491D004_2 * execIKK0491D004_6 * execIKK0491D005_1 * execIKK0491D005_2 * execIKK0491D005_3 * execIKK0491D006_1 * execIKK0491D006_2 * execIKK0491D007_1 * execIKK0491D007_2 * execIKK0491D007_5 * execIKK0491D008_1 * execIKK0491D008_2 * execIKK0491D008_3 * execIKK0541D001_2 * execIKK1031D001_3 * execIKK1091D001_3 * execIKK1151C001_7 * execIKK1151D001_7 * execICH0941D001_3 * execICH0941D002_4 * execIKK3401D001_1 * */ public class JSYejbKK0491KRCK implements KanrenCheckHandler { /** * コンストラクタ */ public JSYejbKK0491KRCK() { } /** * 請求契約関連チェックを行います。 * * @param inETMsg エンティティ * @param inContext Agentから渡されたAgentDispatchContext */ public void invoke(CAANMsg inETMsg, AgentDispatchContext inContext) { JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "call:JSYejbKK0491KRCK.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.ICH0011D002)){ /** 請求確定債権登録振舞内部 */ int Rtn = 0; Rtn = execICH0011D002_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICH0011D003)){ /** 収納済債権登録振舞内部 */ int Rtn = 0; Rtn = execICH0011D003_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICH0111D002)){ /** 入金登録振舞内部 */ int Rtn = 0; Rtn = execICH0111D002_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICH0191D001)){ /** 金庫登録振舞内部 */ int Rtn = 0; Rtn = execICH0191D001_2(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICH0191D002)){ /** 金庫登録振舞内部 */ int Rtn = 0; Rtn = execICH0191D002_2(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICH0331C001)){ /** 請求引抜変更内部 */ int Rtn = 0; Rtn = execICH0331C001_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICH0331C002)){ /** 請求書引抜解除振舞内部 */ int Rtn = 0; Rtn = execICH0331C002_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICH0331D001)){ /** 請求書引抜登録内部 */ int Rtn = 0; Rtn = execICH0331D001_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICK0061D001)){ /** 不良顧客登録振舞内部 */ int Rtn = 0; Rtn = execICK0061D001_3(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0321D002)){ /** オプションサービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D002_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D003)){ /** オプションサービス契約<サポート>登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D003_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D004)){ /** サービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D004_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D005)){ /** 機器提供サービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D005_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D006)){ /** オプションサービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D006_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D008)){ /** サブオプションサービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D008_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D009)){ /** サービス契約内訳登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D009_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D010)){ /** サブオプションサービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D010_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D011)){ /** サービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D011_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D012)){ /** オプションサービス契約<電話>登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D012_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D013)){ /** サブオプションサービス契約<電話>登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D013_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D014)){ /** サービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D014_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D016)){ /** サービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D016_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D017)){ /** 課金先登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D017_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D018)){ /** サービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D018_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0321D019)){ /** 機器オプションサービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D019_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0321D020)){ /** サービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D020_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0321D025)){ /** サービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0321D025_1(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK0441D001)){ /** 請求オプションサービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0441D001_9(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0441D021)){ /** 請求オプションサービス契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0441D021_9(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK0491C001)){ /** 請求契約予約結果反映振舞内部 */ int Rtn = 0; Rtn = execIKK0491C001_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491C001_3(inETMsg, inContext, "EA"); } }else if(eventID.equals(EventIDList.IKK0491C002)){ /** 請求契約予約取消振舞内部 */ int Rtn = 0; Rtn = execIKK0491C002_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491C002_3(inETMsg, inContext, "EA"); } }else if(eventID.equals(EventIDList.IKK0491D001)){ /** 請求契約登録振舞内部 */ int Rtn = 0; Rtn = execIKK0491D001_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D001_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0491D002)){ /** クレジット有効性NG登録振舞内部 */ int Rtn = 0; Rtn = execIKK0491D002_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D002_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0491D003)){ /** 請求契約内容変更振舞内部 */ int Rtn = 0; Rtn = execIKK0491D003_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D003_2(inETMsg, inContext, "EB"); } if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D003_5(inETMsg, inContext, "EA"); } }else if(eventID.equals(EventIDList.IKK0491D004)){ /** 請求支払先変更振舞内部 */ int Rtn = 0; Rtn = execIKK0491D004_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D004_2(inETMsg, inContext, "EB"); } if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D004_6(inETMsg, inContext, "EA"); } }else if(eventID.equals(EventIDList.IKK0491D005)){ /** 請求契約解約振舞内部 */ int Rtn = 0; Rtn = execIKK0491D005_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D005_2(inETMsg, inContext, "EB"); } if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D005_3(inETMsg, inContext, "EA"); } }else if(eventID.equals(EventIDList.IKK0491D006)){ /** 請求契約登録（予約情報入力）振舞内部 */ int Rtn = 0; Rtn = execIKK0491D006_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D006_2(inETMsg, inContext, "EB"); } }else if(eventID.equals(EventIDList.IKK0491D007)){ /** 請求契約お客様変更振舞内部 */ int Rtn = 0; Rtn = execIKK0491D007_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D007_2(inETMsg, inContext, "EB"); } if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D007_5(inETMsg, inContext, "EA"); } }else if(eventID.equals(EventIDList.IKK0491D008)){ /** 支払方法通知メール制御コード変更振舞内部 */ int Rtn = 0; Rtn = execIKK0491D008_1(inETMsg, inContext, "EA"); if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D008_2(inETMsg, inContext, "EB"); } if(Rtn <= StatusCodes.WARNING){ Rtn = execIKK0491D008_3(inETMsg, inContext, "EA"); } }else if(eventID.equals(EventIDList.IKK0541D001)){ /** 請求抑止登録振舞内部 */ int Rtn = 0; Rtn = execIKK0541D001_2(inETMsg, inContext, "EB"); }else if(eventID.equals(EventIDList.IKK1031D001)){ /** クレジットオーソリ実績登録振舞内部 */ int Rtn = 0; Rtn = execIKK1031D001_3(inETMsg, inContext, "EC"); }else if(eventID.equals(EventIDList.IKK1091D001)){ /** 進捗登録振舞内部 */ int Rtn = 0; Rtn = execIKK1091D001_3(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK1151C001)){ /** 加入御礼書発行変更振舞内部 */ int Rtn = 0; Rtn = execIKK1151C001_7(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.IKK1151D001)){ /** 加入御礼書発行登録振舞内部 */ int Rtn = 0; Rtn = execIKK1151D001_7(inETMsg, inContext, "EA"); }else if(eventID.equals(EventIDList.ICH0941D001)){ /** パーフェクト口座登録振舞内部 */ int Rtn = 0; Rtn = execICH0941D001_3(inETMsg, inContext, "EC"); }else if(eventID.equals(EventIDList.ICH0941D002)){ /** パーフェクト口座更新振舞内部 */ int Rtn = 0; Rtn = execICH0941D002_4(inETMsg, inContext, "EC"); } else if(eventID.equals(EventIDList.IKK3401D001)){ /** 支払方法変更受付情報登録振舞内部 */ int Rtn = 0; Rtn = execIKK3401D001_1(inETMsg, inContext, "EA"); } JSYejbLog.println(JSYejbLog.DEBUG, getClass(), "end:JSYejbKK0491KRCK.invoke"); } /** * ICH0011D002_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CH0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICH0011D002_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CH0011ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CH0011ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CH0011ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CH0011ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CH0011ETMsg.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(CH0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CH0011ETMsg.STATUS)) { inETMsg.set(CH0011ETMsg.STATUS, rtn); } return rtn; } /** * ICH0011D003_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CH0011ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICH0011D003_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CH0011ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CH0011ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CH0011ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CH0011ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CH0011ETMsg.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(CH0011ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CH0011ETMsg.STATUS)) { inETMsg.set(CH0011ETMsg.STATUS, rtn); } return rtn; } /** * ICH0111D002_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CH0111ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICH0111D002_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CH0111ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CH0111ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CH0111ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CH0111ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CH0111ETMsg.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(CH0111ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CH0111ETMsg.STATUS)) { inETMsg.set(CH0111ETMsg.STATUS, rtn); } return rtn; } /** * ICH0191D001_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CH0191ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICH0191D001_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CH0191ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CH0191ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CH0191ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CH0191ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CH0191ETMsg.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(CH0191ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CH0191ETMsg.STATUS)) { inETMsg.set(CH0191ETMsg.STATUS, rtn); } return rtn; } /** * ICH0191D002_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(CH0191ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICH0191D002_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CH0191ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CH0191ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CH0191ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CH0191ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CH0191ETMsg.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(CH0191ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CH0191ETMsg.STATUS)) { inETMsg.set(CH0191ETMsg.STATUS, rtn); } return rtn; } /** * ICH0331C001_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CH0331ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICH0331C001_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CH0331ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CH0331ETMsg.SEIKY_KEI_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CH0331ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CH0331ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CH0331ETMsg.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(CH0331ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CH0331ETMsg.STATUS)) { inETMsg.set(CH0331ETMsg.STATUS, rtn); } return rtn; } /** * ICH0331C002_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CH0331ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICH0331C002_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CH0331ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CH0331ETMsg.SEIKY_KEI_NO).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CH0331ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CH0331ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CH0331ETMsg.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(CH0331ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CH0331ETMsg.STATUS)) { inETMsg.set(CH0331ETMsg.STATUS, rtn); } return rtn; } /** * ICH0331D001_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(CH0331ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICH0331D001_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CH0331ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CH0331ETMsg.SEIKY_KEI_NO).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CH0331ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CH0331ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CH0331ETMsg.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(CH0331ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CH0331ETMsg.STATUS)) { inETMsg.set(CH0331ETMsg.STATUS, rtn); } return rtn; } /** * ICK0061D001_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(CK0061ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICK0061D001_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CK0061ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CK0061ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CK0061ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CK0061ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CK0061ETMsg.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(CK0061ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CK0061ETMsg.STATUS)) { inETMsg.set(CK0061ETMsg.STATUS, rtn); } return rtn; } /** * IKK0321D002_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D002_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D003_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D003_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D004_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D004_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D005_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D005_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D006_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D006_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D008_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D008_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D009_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D009_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D010_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D010_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D011_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D011_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D012_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D012_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D013_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D013_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D014_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D014_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D016_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D016_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D017_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D017_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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.SEIKY_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; } /** * IKK0321D018_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D018_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D019_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D019_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D020_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D020_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0321D025_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0321ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0321D025_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0321ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0321ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0321ETMsg.SEIKY_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; } /** * IKK0441D001_制約ＮＯ9チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D001_9(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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.SEIKY_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_制約ＮＯ9チェック * * @param inETMsg チェック対象のETMsg(KK0441ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0441D021_9(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0441ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0441ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0441ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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.SEIKY_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; } /** * IKK0491C001_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491C001_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0491ETMsg.GENE_ADD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491C001_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491C001_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; // チェック条件定数 // 制約部品引数定義 Object joken_1_prm_1 = "KK0491"; // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.UPD_DTM)) { // 判定条件 if(JPCModelCommon.succeededExclusiveLockForGene(inETMsg, inContext, joken_1_prm_1 ) == false){ inETMsg.set(KK0491ETMsg.UPD_DTM_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491C002_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491C002_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0491ETMsg.GENE_ADD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491C002_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491C002_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; // チェック条件定数 // 制約部品引数定義 Object joken_1_prm_1 = "KK0491"; // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.UPD_DTM)) { // 判定条件 if(JPCModelCommon.succeededExclusiveLockForGene(inETMsg, inContext, joken_1_prm_1 ) == false){ inETMsg.set(KK0491ETMsg.UPD_DTM_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D001_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D001_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0491ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SYSID_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D001_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D001_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SYSID_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D002_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D002_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0491ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D002_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D002_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D003_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D003_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D003_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D003_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0491ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D003_制約ＮＯ5チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D003_5(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; // チェック条件定数 // 制約部品引数定義 Object joken_1_prm_1 = "KK0491"; // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.UPD_DTM)) { // 判定条件 if(JPCModelCommon.succeededExclusiveLockForGene(inETMsg, inContext, joken_1_prm_1 ) == false){ inETMsg.set(KK0491ETMsg.UPD_DTM_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D004_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D004_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D004_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D004_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0491ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D004_制約ＮＯ6チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D004_6(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; // チェック条件定数 // 制約部品引数定義 Object joken_1_prm_1 = "KK0491"; // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.UPD_DTM)) { // 判定条件 if(JPCModelCommon.succeededExclusiveLockForGene(inETMsg, inContext, joken_1_prm_1 ) == false){ inETMsg.set(KK0491ETMsg.UPD_DTM_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D005_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D005_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_3 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D005_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D005_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken4_2 = null; if(!inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)){ joken4_2 = new String(inETMsg.getObject(KK0491ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_4 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken4_2 == null){ joken_4 += " IS NULL "; }else{ joken_4 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_4 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken4_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken4_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(rsltQuery.getLong("CNT")>0){ inETMsg.set(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D005_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D005_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; // チェック条件定数 // 制約部品引数定義 Object joken_1_prm_1 = "KK0491"; // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.UPD_DTM)) { // 判定条件 if(JPCModelCommon.succeededExclusiveLockForGene(inETMsg, inContext, joken_1_prm_1 ) == false){ inETMsg.set(KK0491ETMsg.UPD_DTM_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D006_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D006_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken4_2 = null; if(!inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)){ joken4_2 = new String(inETMsg.getObject(KK0491ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_4 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken4_2 == null){ joken_4 += " IS NULL "; }else{ joken_4 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.getTableName()).append(" WHERE ") .append("(" + joken_1 + " AND " + joken_4 + " ) "); // ＳＱＬ文の解析 pstmtQuery = con.prepareStatement(sqlQuery.toString()); // パラメータの設定 int para_idx = 1; if(joken1_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken1_2); } if(joken4_2 != null){ CAANJDBCUtil.setParam(pstmtQuery, para_idx++ , joken4_2); } // ＳＱＬ文の実行 rsltQuery = pstmtQuery.executeQuery(); if(rsltQuery.next()){ // 判定条件 if(rsltQuery.getLong("CNT")>0){ inETMsg.set(KK0491ETMsg.SYSID_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D006_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D006_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SYSID_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D007_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D007_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D007_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D007_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0491ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D007_制約ＮＯ5チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D007_5(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; // チェック条件定数 // 制約部品引数定義 Object joken_1_prm_1 = "KK0491"; // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.UPD_DTM)) { // 判定条件 if(JPCModelCommon.succeededExclusiveLockForGene(inETMsg, inContext, joken_1_prm_1 ) == false){ inETMsg.set(KK0491ETMsg.UPD_DTM_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D008_制約ＮＯ1チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D008_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D008_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D008_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0491ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK0491ETMsg.GENE_ADD_DTM).toString()); } // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0491ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0491ETMsg.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(KK0491ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0491D008_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(KK0491ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0491D008_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; // チェック条件定数 // 制約部品引数定義 Object joken_1_prm_1 = "KK0491"; // チェック条件 if (!inETMsg.isNull(KK0491ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK0491ETMsg.UPD_DTM)) { // 判定条件 if(JPCModelCommon.succeededExclusiveLockForGene(inETMsg, inContext, joken_1_prm_1 ) == false){ inETMsg.set(KK0491ETMsg.UPD_DTM_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } // ステータスのセット if (rtn > inETMsg.getInt(KK0491ETMsg.STATUS)) { inETMsg.set(KK0491ETMsg.STATUS, rtn); } return rtn; } /** * IKK0541D001_制約ＮＯ2チェック * * @param inETMsg チェック対象のETMsg(KK0541ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK0541D001_2(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK0541ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK0541ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK0541ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK0541ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK0541ETMsg.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(KK0541ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK0541ETMsg.STATUS)) { inETMsg.set(KK0541ETMsg.STATUS, rtn); } return rtn; } /** * IKK1031D001_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(KK1031ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1031D001_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1031ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1031ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = null; if(!inETMsg.isNull(KK1031ETMsg.SEIKY_KEI_GENE_ADD_DTM)){ joken2_2 = new String(inETMsg.getObject(KK1031ETMsg.SEIKY_KEI_GENE_ADD_DTM).toString()); } String joken3_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.GENE_ADD_DTM); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } String joken_3 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken3_2 == null){ joken_3 += " IS NULL "; }else{ joken_3 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1031ETMsg.SEIKY_KEI_NO) && !inETMsg.isNull(KK1031ETMsg.SEIKY_KEI_GENE_ADD_DTM)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK1031ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1031ETMsg.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(KK1031ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1031ETMsg.STATUS)) { inETMsg.set(KK1031ETMsg.STATUS, rtn); } return rtn; } /** * IKK1091D001_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(KK1091ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1091D001_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1091ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1091ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1091ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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.SEIKY_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; } /** * IKK1151C001_制約ＮＯ7チェック * * @param inETMsg チェック対象のETMsg(KK1151ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1151C001_7(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1151ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1151ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1151ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK1151ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1151ETMsg.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(KK1151ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1151ETMsg.STATUS)) { inETMsg.set(KK1151ETMsg.STATUS, rtn); } return rtn; } /** * IKK1151D001_制約ＮＯ7チェック * * @param inETMsg チェック対象のETMsg(KK1151ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK1151D001_7(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK1151ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK1151ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK1151ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK1151ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK1151ETMsg.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(KK1151ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK1151ETMsg.STATUS)) { inETMsg.set(KK1151ETMsg.STATUS, rtn); } return rtn; } /** * ICH0941D001_制約ＮＯ3チェック * * @param inETMsg チェック対象のETMsg(CH0941ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICH0941D001_3(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CH0941ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CH0941ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CH0941ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CH0941ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CH0941ETMsg.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(CH0941ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CH0941ETMsg.STATUS)) { inETMsg.set(CH0941ETMsg.STATUS, rtn); } return rtn; } /** * ICH0941D002_制約ＮＯ4チェック * * @param inETMsg チェック対象のETMsg(CH0941ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execICH0941D002_4(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(CH0941ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(CH0941ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(CH0941ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(CH0941ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(CH0941ETMsg.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(CH0941ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(CH0941ETMsg.STATUS)) { inETMsg.set(CH0941ETMsg.STATUS, rtn); } return rtn; } /** * IKK3401D001_制約ＮＯ1チェック * @param inETMsg チェック対象のETMsg(KK3401ETMsg) * @param inContext Agentから渡されたAgentDispatchContext * @param errFlag ERRフラグ * @return int チェック結果 */ private int execIKK3401D001_1(CAANMsg inETMsg, AgentDispatchContext inContext, String errFlag){ // ステータス int rtn = 0; Connection con = JSYejbConnection.getConnection(KK0491ETMsg.getTableName()); PreparedStatement pstmtQuery = null; ResultSet rsltQuery = null; StringBuffer sqlQuery = new StringBuffer(); try{ // チェック条件定数 // ＳＱＬ引数定義 String joken1_2 = null; if(!inETMsg.isNull(KK3401ETMsg.SEIKY_KEI_NO)){ joken1_2 = new String(inETMsg.getObject(KK3401ETMsg.SEIKY_KEI_NO).toString()); } String joken2_2 = "0"; // 条件文定義 String joken_1 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.SEIKY_KEI_NO); if(joken1_2 == null){ joken_1 += " IS NULL "; }else{ joken_1 += " = ? "; } String joken_2 = KK0491ETMsg.getDBColumnName(KK0491ETMsg.MK_FLG); if(joken2_2 == null){ joken_2 += " IS NULL "; }else{ joken_2 += " = ? "; } // チェック条件 if (!inETMsg.isNull(KK3401ETMsg.SEIKY_KEI_NO)) { // ＳＱＬ文の組み立て sqlQuery.append("SELECT COUNT(*) CNT FROM ").append(KK0491ETMsg.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(KK3401ETMsg.SEIKY_KEI_NO_ERR, errFlag); if("W".equals(errFlag.substring(0,1))){ rtn = StatusCodes.WARNING; } else { rtn = StatusCodes.RELATION_ERR; } } } } } catch(SQLException e) { inETMsg.set(KK3401ETMsg.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(KK3401ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ステータスのセット if (rtn > inETMsg.getInt(KK3401ETMsg.STATUS)) { inETMsg.set(KK3401ETMsg.STATUS, rtn); } return rtn; } }