* メール情報採番部品クラスです。 *
* @author 富士通 */ public class JKKejbKK1121NumberParts extends JKKejbNumberPartsBase { /** シーケンス定義名(メールID（eo顧客基幹システム）) */ private static final String SEQ_NAME_1 = "SEQ_MAIL_ID"; /** シーケンス定義名(メールID（Myポータルシステム）) */ private static final String SEQ_NAME_2 = "SEQ_MAIL_ID_PMP"; /** シーケンス定義名(メールID（コンテンツ管理システム）) */ private static final String SEQ_NAME_3 = "SEQ_MAIL_ID_CONT"; /** 接頭語(メールID) */ private static final String PREFIX_MAILID = ""; /** メール採番区分：1(eo顧客基幹システム) */ private static final String INDEX_KBN_EO = "1"; /** メール採番区分：2(Myポータルシステム) */ private static final String INDEX_KBN_PMP = "2"; /** メール採番区分：3(コンテンツ管理システム) */ private static final String INDEX_KBN_CONT = "3"; /** 桁数 */ private static final int SEQUENCE_LENGTH = 10; /** * コンストラクタです。 */ public JKKejbKK1121NumberParts() { } /** ** メールIDの採番を行います。 *
* @param mailIdKbn Input．メール採番区分 * @return 採番されたメールID */ public String getMailId(String mailIdKbn) { // SEQ結果取得 String value = null; // Oracleシーケンスによる採番 if (INDEX_KBN_EO.equals(mailIdKbn)) { value = JCCModelCommon.getFormatedNextSeq(SEQ_NAME_1, PREFIX_MAILID, SEQUENCE_LENGTH); } else if (INDEX_KBN_PMP.equals(mailIdKbn)) { value = JCCModelCommon.getFormatedNextSeq(SEQ_NAME_2, PREFIX_MAILID, SEQUENCE_LENGTH); } else if (INDEX_KBN_CONT.equals(mailIdKbn)) { value = JCCModelCommon.getFormatedNextSeq(SEQ_NAME_3, PREFIX_MAILID, SEQUENCE_LENGTH); } return value; } /** ** メール送信回数の編集を行います。 *
* @param inMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext * @return 編集されたメール送信回数 */ public String getSendCnt(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; // 返却用変数 String maxSendCnt = null; try { //コネクション取得 con1 = JSYejbConnection.getConnection(KK1121ETMsg.getTableName()); // SQL文 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" MAX(KK1121.SEND_CNT) + 1 AS MAX_SEND_CNT ") .append(" FROM ") .append(" KK_T_MAIL_INFO KK1121 ") .append(" WHERE ") .append(" KK1121.MAIL_ID = ? "); //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // パラメータの設定(メールID) CAANJDBCUtil.setParam(pstmt, 1, inCBSMsg.getObject(EKK1121D010CBSMsg.MAIL_ID)); // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // 最大の送信回数を取得する if (rsltQuery.next()) { maxSendCnt = rsltQuery.getString("MAX_SEND_CNT"); } if (maxSendCnt==null) { maxSendCnt = "1"; } } catch(SQLException se) { throw new CAANRuntimeException(se); } finally { // 資源の解放 try { if(rsltQuery != null) { rsltQuery.close(); } if(pstmt != null) { pstmt.close(); } if(con1 != null) { CAANConnectionMgr.getInstance().close(con1); } } catch(SQLException se) { throw new CAANRuntimeException(se); } } return maxSendCnt; } }