*
* @author FJ
*/
public class JBSbatCCSearchSendMail extends JBSbatBusinessService
{
/** 未送信メール情報ファイル格納オブジェクト */
public static String MID_DIR_CC = "MID_DIR_CC";
/** 未送信メール情報ファイル */
public static String FILE_NAME = "CCIFM002001";
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(メール送信)*/
private static final String D_TBL_NAME_CC_T_MAIL_SEND = "CC_T_MAIL_SEND";
/** SQL定義キー(SELECT_LIST_01)*/
private static final String CC_T_MAIL_SEND_CC_SELECT_003 = "CC_SELECT_003";
/** テーブルアクセスクラス(メール送信)*/
private JBSbatSQLAccess db_CC_T_MAIL_SEND = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** メールサーバ同時接続数取得キー */
private static String MAILSEND_CONNECTION = "MAILSEND_CONNECTION";
/** 単一プロセス単一時間に送信可能なメール数 */
private static String MAILSEND_MAX = "MAILSEND_MAX";
/** 未送信メール情報ファイル格納オブジェクト */
private Object[] outFileObjlist = null;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_CC_T_MAIL_SEND = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CC_T_MAIL_SEND);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// メールサーバ同時接続数
String connection = JCCBatCommon.getApplicationConst(MAILSEND_CONNECTION);
if(isEmpty(connection))
{
throw new JCCbatFrameworkException("バッチアプリケーションプロパティファイルのメールサーバ同時接続数[MAILSEND_CONNECTION]は未設定です。");
}
if(!JCCBatCommon.isHannkakuSuuji1(connection) || Integer.parseInt(connection) < 1 || Integer.parseInt(connection) > 99){
throw new JCCbatFrameworkException("バッチアプリケーションプロパティファイルのメールサーバ同時接続数[MAILSEND_CONNECTION]の設定値が不正です。");
}
// 単一プロセス単一時間に送信可能なメール数
String max = JCCBatCommon.getApplicationConst(MAILSEND_MAX);
if(isEmpty(max))
{
throw new JCCbatFrameworkException("バッチアプリケーションプロパティファイルの単一プロセス単一時間に送信可能なメール数[MAILSEND_MAX]は未設定です。");
}
if(!JCCBatCommon.isHannkakuSuuji1(max) || Long.parseLong(max) < 1){
throw new JCCbatFrameworkException("バッチアプリケーションプロパティファイルの単一プロセス単一時間に送信可能なメール数[MAILSEND_MAX]の設定値が不正です。");
}
//中間ファイル出力パスの取得
String mid_path = JCCBatCommon.getApplicationConst(MID_DIR_CC);
if(isEmpty(mid_path)){
throw new JCCbatFrameworkException("バッチアプリケーションプロパティファイルに中間ファイル出力パス「MID_DIR_CC」が設定されていません。");
}
String sysDateTimeStamp = JCCBatCommon.getSysDateTimeStamp();
//ファイル出力パスを生成
mid_path = mid_path + File.separator + FILE_NAME + "_" + sysDateTimeStamp;
//ファイル出力クラスオブジェクトの生成
createFileUtil(Integer.parseInt(connection),mid_path);
//システム日時を設定して、メール送信管理テーブルから送信対象データを取得
executeCC_T_MAIL_SEND_CC_SELECT_003(new Object[]{sysDateTimeStamp, sysDateTimeStamp});
//一時格納用変数を定義
JBSbatCommonDBInterface rsMap = null;
int outCnt = 0;
while((rsMap = db_CC_T_MAIL_SEND.selectNext()) != null){
// 一行をファイルに出力
outputFile(rsMap.getString("MAIL_SEND_NO"), (JBSbatBusinessFileUtil)this.outFileObjlist[outCnt]);
super.logPrint.printDebugLog("MAIL_SEND_NO = " + rsMap.getString("MAIL_SEND_NO"));
//連番に＋１
outCnt++;
if(outCnt >= Integer.parseInt(connection)){
outCnt = 0;
}
}
closeFileUtil();
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_CC_T_MAIL_SEND.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(SELECT_LIST_01)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * メール送信予定年月日時分秒 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCC_T_MAIL_SEND_CC_SELECT_003(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
// システム日付タイムスタンプ
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_CC_T_MAIL_SEND.selectBySqlDefine(paramList, CC_T_MAIL_SEND_CC_SELECT_003);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* ファイル出力処理
* @param データ
* @param 出力ファイル
* @throws Exception
*/
private void outputFile(String data,JBSbatBusinessFileUtil outFileObj)throws Exception
{
// ファイルに出力する
outFileObj.print(data);
}
/**
* ファイル出力クラスの生成
* @param 分割数(同時接続コネクション数)
* @param ファイル名
* @throws Exception
*/
private void createFileUtil(int connection,String fileName)throws Exception
{
outFileObjlist = new Object[connection];
for(int i=0;i