*
* @author 富士通
*/
public class JBSbatCCWksijUpdDnbnDataOutput extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(業務規制時更新電文)*/
private static final String D_TBL_NAME_CC_T_WKSIJ_UPD_DNBN = "CC_T_WKSIJ_UPD_DNBN";
/** SQL定義キー(CC_SELECT_002)*/
private static final String CC_T_WKSIJ_UPD_DNBN_CC_SELECT_002 = "CC_SELECT_002";
/** テーブルアクセスクラス(業務規制時更新電文)*/
private JBSbatSQLAccess db_CC_T_WKSIJ_UPD_DNBN = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_CC_T_WKSIJ_UPD_DNBN = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CC_T_WKSIJ_UPD_DNBN);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// FREE項目から業務規制時更新電文番号の取得
String free = super.commonItem.getFreeItem();
// free項目がnullまたはブランクの場合
if(free == null || free.length()==0)
{
throw new JBSbatBusinessException("ECCB0120CE",
new String[]{"業務規制時更新電文番号の設定を行ってください。"});
}
// 出力先のディレクトリ取得
String outputDir = JCCBatCommon.getApplicationConst("WKSIJ_UPD_DNBN_MAP_OUTPUT_DIR");
// 取得できない場合はシステムエラーとする。
if(outputDir == null || "".equals(outputDir))
{
throw new JBSbatBusinessException("ECCB0130CE", new String[]{"業務規制時更新電文出力先格納ディレクトリ（キー：WKSIJ_UPD_DNBN_MAP_OUTPUT_DIR）"});
}
// 業務規制時更新電文番号をコロン区切りで切り分け
String[] freeList = free.split(":");
// 業務規制時更新電文番号ごとにXMLファイル出力
for(int i = 0 ; i < freeList.length ; i++)
{
// 業務規制時更新電文番号のチェック
if(freeList[i] == null || freeList[i].length() != 15)
{
throw new JBSbatBusinessException("ECCB0120CE", new String[]{"業務規制時更新電文番号を15桁で設定してください。：" + freeList[i]});
}
String[] paramList = new String[]{freeList[i]};
executeCC_T_WKSIJ_UPD_DNBN_CC_SELECT_002(paramList);
JBSbatCommonDBInterface dbMap = db_CC_T_WKSIJ_UPD_DNBN.selectNext();
if(dbMap != null)
{
// 業務規制時更新電文情報取得
String wksijUpdDnbnNo = dbMap.getString(JBSbatCC_T_WKSIJ_UPD_DNBN.WKSIJ_UPD_DNBN_NO);
// パラメータマップ取得
String param = dbMap.getString(JBSbatCC_T_WKSIJ_UPD_DNBN.PARAM_MAP);
// 入力データマップ取得
String input = dbMap.getString(JBSbatCC_T_WKSIJ_UPD_DNBN.INPUT_DATA_MAP);
// エラー出力データマップ取得
String output = dbMap.getString(JBSbatCC_T_WKSIJ_UPD_DNBN.ERR_OUTPUT_DATA_MAP);
BufferedWriter paramWriter = null;
BufferedWriter inputWriter = null;
BufferedWriter errWriter = null;
try
{
// パラメータマップをXMLファイルへ出力
File paramFile = new File(outputDir + File.separator + wksijUpdDnbnNo + "_" + JBSbatCC_T_WKSIJ_UPD_DNBN.PARAM_MAP + ".xml");
paramWriter = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(paramFile), "UTF-8"));
paramWriter.write(param);
// 入力データマップをXMLファイルへ出力
File inputFile = new File(outputDir + File.separator + wksijUpdDnbnNo + "_" + JBSbatCC_T_WKSIJ_UPD_DNBN.INPUT_DATA_MAP + ".xml");
inputWriter = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(inputFile), "UTF-8"));
inputWriter.write(input);
// エラー出力データマップをXMLファイルへ出力
File errFile = new File(outputDir + File.separator + wksijUpdDnbnNo + "_" + JBSbatCC_T_WKSIJ_UPD_DNBN.ERR_OUTPUT_DATA_MAP + ".xml");
errWriter = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(errFile), "UTF-8"));
errWriter.write(output);
}
finally
{
if(paramWriter != null)
{
paramWriter.close();
}
if(inputWriter != null)
{
inputWriter.close();
}
if(errWriter != null)
{
errWriter.close();
}
}
}
else
{
// 業務規制時更新電文番号をキーにしてデータが取得できなかった場合
super.logPrint.printBusinessErrorLog("ECCB0230AW", new String[]{freeList[i]});
}
}
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_CC_T_WKSIJ_UPD_DNBN.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(CC_SELECT_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 業務規制時更新電文番号 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCC_T_WKSIJ_UPD_DNBN_CC_SELECT_002(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); // DBアクセスを実行します db_CC_T_WKSIJ_UPD_DNBN.selectBySqlDefine(paramList, CC_T_WKSIJ_UPD_DNBN_CC_SELECT_002); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }