*
* @author 富士通
*/
public class JBSbatKKPcSetupReqDataSnd extends JBSbatBusinessService
{
/**
* 外部インターフェイスID
*/
private static final String IF_ID = "KKIFE018";
/** エラー区分取得キー */
private static final String KEY_ERR_KBN = "ERR_KBN";
/** ファイルエラー取得キー */
private static final String KEY_FILE_ERR = "FILE_ERR";
/** エラーメッセージ取得キー */
private static final String KEY_ERR_MESSAGE = "ERR_MESSAGE";
/** 接続エラー取得キー */
private static final String KEY_CONNECT_ERR = "CONNECT_ERR";
/** 送信ファイル名 */
private static final String SEND_FILE_NAME = "temp500162000001%1$s000000";
/** テキストファイル名 */
private static final String TEXT_FILE_NAME = "CKN1500162000001%1$s000000_%2$s";
/** 情報区分 */
private static final String INFO_KBN = "CKN1";
/** 配信者の振分ID */
private static final String HAISHIN_ID = "500162000001";
/** 固定文字列：「000000」 */
private static final String ZERO_STR = "000000";
/** ファイル数 */
private static final String FILE_NUM = "002";
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 送信ファイル格納場所
*/
private String snd_dir = "";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
// フリー項目からファイル格納場所を取得します
String file_path = commonItem.getFreeItem();
// 取得出来なかった場合、エラーとします。
if (file_path.length() == 0)
{
throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0130CE, new String[]{"フリー項目：送信ファイル格納パス名"});
}
snd_dir = file_path + "/";
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
// 送信対象のファイル名を取得。
String file_nm = inMap.getString(JBSbatKKIFM119.SEND_FILE_NM);
// 拡張子なしファイル名
String snd_file_nm = snd_dir + file_nm;
// 圧縮ファイル名取得
String zipFileNm = file_nm + ".tar.gz";
zipFileNm = snd_dir + zipFileNm;
// リネーム処理
File outFile1 = new File(zipFileNm);
File outFile2 = new File(snd_file_nm);
outFile1.renameTo(outFile2);
// 依頼会社コード取得
String reqSkVscpSkbtCd = inMap.getString(JBSbatKKIFM119.REQ_SK_VSCP_SKBT_CD);
// テキストファイル作成
String textFileName = executeOutFile(reqSkVscpSkbtCd);
textFileName = snd_dir + textFileName;
super.logPrint.printDebugLog("FTP送信ファイル----->" + snd_file_nm);
// データファイルの送信
this.execFTP(snd_file_nm);
// テキストファイルの送信
this.execFTP(textFileName);
super.logPrint.printDebugLog("execute_END");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* テキストファイル終了処理
* @param reqSkVscpSkbtCd 依頼会社コード
* @return String
* @throws Exception
*/
private String executeOutFile(String reqSkVscpSkbtCd) throws Exception
{
// ファイル生成
BufferedWriter out_writer_cnt = null;
//テキストファイル名
String newFileNm = null;
try{
// ファイル名に付加するシステム日付を取得します
String file_nm_sysdate = JBSbatDateUtil.getSystemDateTime();
// 送信ファイル名
String zipFileNm = String.format(SEND_FILE_NAME, reqSkVscpSkbtCd);
// テキストファイル名
newFileNm = String.format(TEXT_FILE_NAME, reqSkVscpSkbtCd, file_nm_sysdate);
// ファイル生成
out_writer_cnt = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(snd_dir + newFileNm)));
StringBuilder sb = new StringBuilder();
// 情報区分(CKN1)固定
sb.append(INFO_KBN);
// 配信者の振分ID(500162000001)固定
sb.append(HAISHIN_ID);
// 集信者の振分ID(依頼会社コード)
sb.append(reqSkVscpSkbtCd);
// 固定文字列：「000000」
sb.append(ZERO_STR);
// 圧縮されたファイル名
sb.append(zipFileNm);
// ファイル数(002)固定
sb.append(FILE_NUM);
out_writer_cnt.write(sb.toString());
// ファイル出力
out_writer_cnt.flush();
}
catch(IOException e)
{
throw new JBSbatBusinessException("EKKB0250CE", new String[]{newFileNm, e.getMessage()});
}
finally
{
if (null != out_writer_cnt)
{
out_writer_cnt.close();
}
}
return newFileNm;
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* ESB連携部品を使用してファイル送信を行います。
*
* 処理フロー
*
* 1.ファイルパスが空の場合、エラーとします。*
* * 2.連携部品の引数を作成します。
* * 3.ESB連携部品を実行します。
* * 4.処理結果が正常以外の場合、エラーを発生させます。
* *
* @param file_path 転送対象ファイルパス。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void execFTP(String file_path) throws Exception
{
ArrayList