*
* @author 富士通
*/
public class JBSbatKKKCNSendInfoFileSakusei extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(連携ファイル制御)*/
private static final String D_TBL_NAME_KK_T_RNKI_FILE_CTRL = "KK_T_RNKI_FILE_CTRL";
/** テーブルアクセスクラス(連携ファイル制御)*/
private JBSbatSQLAccess db_KK_T_RNKI_FILE_CTRL = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** エラーメッセージ(置換え文字列：%2%) */
private static final String MASSEAGE = "ファイル出力";
/** エンコード */
private static final String ENCODE = "Shift-JIS";
/** 外部インターフェイスID */
private static final String IF_ID = "ZDIFE012";
/** 物理バッチID（KKPRC01601）*/
private static final String BAT_ID = "KKPRC01601";
/** ファイルID（KKIFE044）*/
private static final String FILE_ID = "KKIFE044 ";
/** データカウンタ */
private static int data_cnt = 0;
/** 出力ファイル格納先 */
private String file_path = "";
/** 前回実施日 */
private String znkiJssiDate = "";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// フリー項目から格納先を取得します
file_path = commonItem.getFreeItem();
// 取得出来なかった場合、エラーとします。
if (file_path.length() == 0)
{
throw new JBSbatBusinessException(
JPCBatchMessageConstant.EKKB0130CE, new String[]{"フリー項目：送信ファイル格納パス名"});
}
// DBアクセスクラスを生成します
db_KK_T_RNKI_FILE_CTRL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_RNKI_FILE_CTRL);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
JBSbatCommonDBInterface db_map = null;
// 連携ファイル制御を検索します。
String[] para1 = {BAT_ID, FILE_ID};
db_map = executeKK_T_RNKI_FILE_CTRL_PKSELECT(para1);
// 前回実施日が取得できた場合
if (null != db_map)
{
String znkiJssiTimestamp = JBSbatStringUtil.Rtrim(db_map.getString(JBSbatKK_T_RNKI_FILE_CTRL.ZNKI_TRAN_RUN_DTM));
try{
// バッチ運用日と同日でない場合、先頭8桁を「前回運用日」とします。
if (!super.opeDate.equals(znkiJssiTimestamp.substring(0, 8)))
{
znkiJssiDate = znkiJssiTimestamp.substring(0, 8);
}
// バッチ運用日と同日の場合、バッチ運用日-1日を「前回運用日」とします。
else
{
znkiJssiDate = JBSbatDateUtil.adjustDate(super.opeDate, -1);
}
} catch (Exception e) {
throw new JBSbatBusinessException(
JPCBatchMessageConstant.EKKB0090TE, new String[] {"ZNKI_TRAN_RUN_DTM:" + znkiJssiTimestamp});
}
}
// 前回実施日が取得できなかった場合、バッチ運用日-1日を「前回運用日」とします。
else
{
znkiJssiDate = JBSbatDateUtil.adjustDate(super.opeDate, -1);
}
super.logPrint.printDebugLog("前回実施日：" + znkiJssiDate);
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
// 出力共通電文を生成する。
JBSbatOutputItem outputBean = new JBSbatOutputItem();
// 入出力インターフェースオブジェクトを生成(異動情報結果ファイル用)
JBSbatServiceInterfaceMap outmap = new JBSbatServiceInterfaceMap();
// サービス契約の検索結果より抽出項目を取得
String sysid = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKK_T_MSKM_DTL.SYSID));
String msmsho_no = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKK_T_MSKM_DTL.MSKMSHO_NO));
String msmsho_ymd = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKK_T_MSKM_DTL.MSKM_YMD));
super.logPrint.printDebugLog("前回実施日：：" + znkiJssiDate);
super.logPrint.printDebugLog("申込年月日：：" + msmsho_ymd);
super.logPrint.printDebugLog("バッチ運用日：" + super.opeDate);
// 申込年月日と前回運用日の期間判定を行います。
// 申込年月日が前回運用日より未来日、かつバッチ運用日と同日か過去日の場合、対象レコードとします。
// 前回運用日 ＜ 申込年月日 かつ 申込年月日 ＜＝ バッチ運用日
if (znkiJssiDate.compareTo(msmsho_ymd) < 0 && msmsho_ymd.compareTo(super.opeDate) <= 0)
{
super.logPrint.printDebugLog("★前回運用日 ＜ 申込年月日 かつ 申込年月日 ＜＝ バッチ運用日：処理対象レコード");
}
else
{
super.logPrint.printDebugLog(
"★前回運用日 ＜ 申込年月日 かつ 申込年月日 ＜＝ バッチ運用日でない：処理対象外レコード");
// 処理対象外としてスキップします。
return null;
}
outmap.set(JBSbatKKIFM143001.MSKMSHO_NO,msmsho_no);
outmap.set(JBSbatKKIFM143001.SYSID, sysid);
super.logPrint.printDebugLog("出力 ＳＹＳＩＤ：" + sysid);
super.logPrint.printDebugLog("出力 申込書番号：" + msmsho_no);
// データカウントＵＰ
data_cnt++;
//出力フラグを設定
outmap.setOutFlg(true);
outputBean.addOutMapList(outmap);
super.logPrint.printDebugLog("execute_END");
return outputBean;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_RNKI_FILE_CTRL.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
if(commonItem.getOutPutFile() != null) {
commonItem.getOutPutFile().close();
}
// 件数ファイルOBJの取得。
JBSbatOutputFileUtil out_file_obj = commonItem.getOutPutFile2();
// データ件数の出力。
out_file_obj.write("\"" + String.valueOf(data_cnt) + "\"");
out_file_obj.close();
// フラグファイルの出力。
executeOutputFile();
// ファイル名を加工します。(「.flg」を削除する)
String new_filePath = file_path.replaceAll(".FLG", "");
// ＫＣＮ送信用データ受信情報ファイルの送信
executeSendtFile(new_filePath + ".CSV");
// ＫＣＮ送信用データ受信件数ファイルの送信
executeSendtFile(new_filePath + ".CNT");
// ＫＣＮ送信用データ受信フラグファイルの送信
executeSendtFile(new_filePath + ".FLG");
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* PK(ＰＫ 検索)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で条件マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * BUTSURI_BAT_ID * FILE_ID *
* @param whereParam 条件項目の値。
* @return JBSbatCommonDBInterface 検索の結果。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private JBSbatCommonDBInterface executeKK_T_RNKI_FILE_CTRL_PKSELECT(Object[] whereParam) throws Exception
{
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("BUTSURI_BAT_ID", whereParam[0]);
whereMap.setValue("FILE_ID", whereParam[1]);
// DBアクセスを実行します
return db_KK_T_RNKI_FILE_CTRL.selectByPrimaryKeys(whereMap);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 中間ファイルを出力します。
*
* @throws JBSbatBusinessException
* @throws IOException 業務サービス内で発生した例外全般。
*/
private void executeOutputFile() throws IOException, JBSbatBusinessException
{
// 一時ファイル読込み処理
BufferedWriter wr = null;
try
{
// パラメータで渡された中間ファイルを出力する。
wr = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file_path), ENCODE));
}
catch(IOException e)
{
throw new JBSbatBusinessException("EKKB0250CE", new String[]{file_path, MASSEAGE});
}
finally
{
if (wr != null)
{
wr.close();
}
}
}
/**
* 中間ファイルを送信します。
* 共通イメージ（ESBサーバ）へデータ、件数、フラグファイルを送信します。
*
* @param new_filePath 送信ファイルパス
* @throws JBSbatBusinessException
* @throws IOException 業務サービス内で発生した例外全般。
*/
private void executeSendtFile(String new_filePath) throws IOException, JBSbatBusinessException
{
ArrayList