*
* @author 富士通
*/
public class JBSbatKKEoidMmbInfFileBnkt extends JBSbatBusinessService
{
/**
* 囲み文字（"）
*/
private static final String MOJI_D = "\"";
/**
* 置換文字列
*/
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 int max_cnt = 0;
/**
* 最大ファイル分割数
*/
private int max_file_cnt = 0;
/**
* 送信ファイル格納場所
*/
private String send_dir = "";
/**
* 分割元ファイルパス
*/
private String in_file_path = "";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
// 上限値を取得します
String[] free_item = commonItem.getFreeItem().split(";");
max_file_cnt = Integer.parseInt(free_item[0]);
max_cnt = Integer.parseInt(free_item[1]);
// 送信ファイル格納場所を取得します
send_dir = free_item[2] + "/";
// 分割元入力ファイルパスを取得します
in_file_path = free_item[3];
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
BufferedReader in_reader = null;
BufferedWriter out_writer = null;
JBSbatOutputItem out_Bean = new JBSbatOutputItem();
JBSbatServiceInterfaceMap out_map = new JBSbatServiceInterfaceMap();
int cnt = 1;
int list_cnt = 0;
int data_cnt = Integer.parseInt(inMap.getString(JBSbatKKIFE026002.DATA_CNT).replace(MOJI_D, ""));
String sys_date = JCCBatCommon.getSysDateTime();
String out_file = "";
try
{
// 入力ファイルクラスを生成します。
in_reader = new BufferedReader(new InputStreamReader(new FileInputStream(in_file_path)));
// レコード件数が10万件以下の場合、以下の処理を行います。
if (max_cnt >= data_cnt)
{
// 分割数をゼロに設定します
cnt = 0;
// 出力ファイルクラスを生成します。
out_file = editSendFileNm(EOID_FILE_NM, sys_date, cnt, CSV_NM);
out_writer = createEoidFile(out_file);
// eoID会員情報ファイルを作成します。
while (in_reader.ready())
{
out_writer.write(in_reader.readLine());
out_writer.write("\r\n");
}
// eoID会員情報件数ファイルを作成します。
createCntFile(sys_date, cnt, data_cnt);
// FTPフラグファイルを作成します。
createFlgFile(sys_date, cnt);
}
// レコード件数が10万件を超過する場合、以下の処理を行います。
else
{
// 出力ファイルクラスを生成します。
out_file = editSendFileNm(EOID_FILE_NM, sys_date, cnt, CSV_NM);
out_writer = createEoidFile(out_file);
// eoID会員情報ファイルを作成します。
while (in_reader.ready())
{
// ファイル分割処理をします
if (max_cnt <= list_cnt && max_file_cnt > cnt)
{
// eoID会員情報件数ファイルを作成します。
createCntFile(sys_date, cnt, list_cnt);
// FTPフラグファイルを作成します。
createFlgFile(sys_date, cnt);
// 初期化処理をします。
out_writer.flush();
out_writer.close();
list_cnt = 0;
cnt++;
// 出力ファイルクラスを生成します。
out_file = editSendFileNm(EOID_FILE_NM, sys_date, cnt, CSV_NM);
out_writer = createEoidFile(out_file);
}
list_cnt++;
out_writer.write(in_reader.readLine());
out_writer.write("\r\n");
}
// eoID会員情報件数ファイルを作成します。
createCntFile(sys_date, cnt, list_cnt);
// FTPフラグファイルを作成します。
createFlgFile(sys_date, cnt);
}
// ファイル名に付与したYYYMMDDhhmmssをｅｏＩＤ会員情報分割数ファイルに出力します。
out_map.setString(JBSbatKKIFM037.FILE_SAKSEI_DTM, sys_date);
// 分割数をｅｏＩＤ会員情報分割数ファイルに出力します。
out_map.setString(JBSbatKKIFM037.BUNKATSU_CNT, cnt);
out_map.setOutFlg(true);
out_Bean.addOutMapList(out_map);
}
catch(IOException ioe)
{
throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0250CE, new String[]{out_file, ioe.getMessage()});
}
finally
{
if (in_reader != null)
{
in_reader.close();
}
if (out_writer != null)
{
out_writer.close();
}
}
super.logPrint.printDebugLog("execute_END");
return out_Bean;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @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.ファイル生成をします。
* *
* @param value eoID会員情報ファイル名。
* @return BufferedWriter 出力ファイルクラス。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private BufferedWriter createEoidFile(String value) throws Exception
{
BufferedWriter out_writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(value)));
return out_writer;
}
/**
* eoID会員情報件数ファイルの作成処理を行います。
*
* 処理フロー
*
* 1.eoID会員情報件数ファイル名を設定します。*
* * 2.ファイル生成をします。
* * 2.ファイルに件数を出力します。
* *
* @param dtm 付加日時。
* @param no 付加連番。
* @param cnt 出力レコード件数。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void createCntFile(String dtm, int no, int cnt) throws Exception
{
BufferedWriter out_writer = null;
String value = editStringCSV(JBSbatStringUtil.padNumFormString(String.valueOf(cnt), 10));
String file_path = editSendFileNm(EOID_FILE_CNT_NM, dtm, no, TXT_NM);
try
{
out_writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file_path)));
out_writer.write(value);
out_writer.write("\r\n");
out_writer.flush();
}
catch(IOException ioe)
{
throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0250CE, new String[]{file_path, ioe.getMessage()});
}
finally
{
if (out_writer != null)
{
out_writer.close();
}
}
}
/**
* FTPフラグファイルの生成処理を行います。
*
* 処理フロー
*
* 1.FTPフラグファイル名を設定します。*
* * 2.ファイル生成をします。
* *
* @param dtm 付加日時。
* @param no 付加連番。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void createFlgFile(String dtm, int no) throws Exception
{
BufferedWriter out_writer = null;
String file_path = editSendFileNm(FTP_FILE_NM, dtm, no, FLG_NM);
try
{
out_writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file_path)));
}
catch(IOException ioe)
{
throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0250CE, new String[]{file_path, ioe.getMessage()});
}
finally
{
if (out_writer != null)
{
out_writer.close();
}
}
}
/**
* 文字列に囲み文字を付加します。
*
* 処理フロー
*
* 1.文字列の前後に囲み文字を追加します。*
* *
* @param data 編集する文字列。 * @return String 編集後文字列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private String editStringCSV(String data) throws Exception { StringBuffer value = new StringBuffer(); value.append(MOJI_D); value.append(data); value.append(MOJI_D); return value.toString(); } }