*
* @author 富士通
*/
public class JBSbatKKEoidMmbInfFileSend extends JBSbatBusinessService
{
/**
* 囲み文字（"）
*/
private static final String MOJI_D = "\"";
/**
* 外部インターフェイスID
*/
private static final String IF_ID = "KKIFE026";
/**
* 置換文字列
*/
private static final String YMDHMS99 = "%1$s%2$02d";
/**
* eoID会員情報ファイル名
*/
private static final String EOID_FILE_NM = "FLGC02T010_DAT_";
/**
* eoID会員情報ファイル名（拡張子）
*/
private static final String CSV_NM = ".csv";
/**
* eoID会員情報件数ファイル名
*/
private static final String EOID_FILE_CNT_NM = "FLGC02T020_CNT_";
/**
* eoID会員情報件数ファイル名（拡張子）
*/
private static final String TXT_NM = ".txt";
/**
* FTPフラグファイル名
*/
private static final String FTP_FILE_NM = "FLGC02T030_FTP_";
/**
* FTPフラグファイル名
*/
private static final String FLG_NM = ".flg";
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 送信ファイル格納場所
*/
private String send_dir = "";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
// ファイル格納パスを取得します
send_dir = commonItem.getFreeItem() + "/";
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
String in_dtm = inMap.getString(JBSbatKKIFM037.FILE_SAKSEI_DTM).replace(MOJI_D, "");
int in_cnt = inMap.getInt(JBSbatKKIFM037.BUNKATSU_CNT);
// ファイル分割数＞０の場合、以下の処理を行います。
if (0 < in_cnt)
{
// ファイル分割数だけ以下の処理を繰り返します。
for (int i = 0; i < in_cnt; i++)
{
// 分割したeoID会員情報ファイルの送信処理を行います。
executeEoIdFile(in_dtm, i + 1);
// 分割したeoID会員情報件数ファイルの送信処理を行います。
executeEoIdCntFile(in_dtm, i + 1);
// 分割連番を付与したFTPフラグファイルの送信処理を行います。
executeFtpFlgFile(in_dtm, i + 1);
}
}
// ファイル分割数＝０の場合、以下の処理を行います。
else
{
// eoID会員情報ファイルの送信処理を行います。
executeEoIdFile(in_dtm, in_cnt);
// eoID会員情報件数ファイルの送信処理を行います。
executeEoIdCntFile(in_dtm, in_cnt);
// FTPフラグファイルの送信処理を行います。
executeFtpFlgFile(in_dtm, in_cnt);
}
super.logPrint.printDebugLog("execute_END");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 送信ファイル名を編集します。
*
* 処理フロー
*
* 1.連番が0の場合、連番なしファイル名を返却します。*
* * 1.上記以外の場合、連番ありファイル名を返却します。
* *
* @param file 対象ファイル名。
* @param dtm 付加日時。
* @param no 付加連番。
* @param type 対象拡張子。
* @return String eoID会員情報ファイル名。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private String editSendFileNm(String file, String dtm, int no, String type) throws Exception
{
StringBuffer file_nm = new StringBuffer();
file_nm.append(send_dir);
file_nm.append(file);
if (no == 0)
{
file_nm.append(dtm);
}
else
{
file_nm.append(String.format(YMDHMS99, dtm, no));
}
file_nm.append(type);
return file_nm.toString();
}
/**
* eoID会員情報ファイルの送信処理を行います。
*
* 処理フロー
*
* 1.転送対象のeoID会員情報ファイル名を設定します。*
* * 2.ESB連携部品を実行します。
* *
* @param dtm 付加日時。
* @param no 付加連番。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeEoIdFile(String dtm, int no) throws Exception
{
String file_path = editSendFileNm(EOID_FILE_NM, dtm, no, CSV_NM);
executeESB(file_path);
}
/**
* eoID会員情報件数ファイルの送信処理を行います。
*
* 処理フロー
*
* 1.転送対象のeoID会員情報件数ファイル名を設定します。*
* * 2.ESB連携部品を実行します。
* *
* @param dtm 付加日時。
* @param no 付加連番。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeEoIdCntFile(String dtm, int no) throws Exception
{
String file_path = editSendFileNm(EOID_FILE_CNT_NM, dtm, no, TXT_NM);
executeESB(file_path);
}
/**
* FTPフラグファイルの送信処理を行います。
*
* 処理フロー
*
* 1.転送対象のFTPフラグファイル名を設定します。*
* * 2.ESB連携部品を実行します。
* *
* @param dtm 付加日時。
* @param no 付加連番。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeFtpFlgFile(String dtm, int no) throws Exception
{
String file_path = editSendFileNm(FTP_FILE_NM, dtm, no, FLG_NM);
executeESB(file_path);
}
/**
* ESB連携部品を使用してファイル送信を行います。
*
* 処理フロー
*
* 1.連携部品の引数を作成します。*
* * 2.ESB連携部品を実行します。
* * 3.処理結果が正常以外の場合、エラーを発生させます。
* *
* @param value 転送対象ファイルパス。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeESB(String value) throws Exception
{
ArrayList