*
* @author 富士通
*/
public class JBSbatCCWksijUpdDnbnDataUpd 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";
/** SQL定義キー(CC_UPDATE_003)*/
private static final String CC_T_WKSIJ_UPD_DNBN_CC_UPDATE_003 = "CC_UPDATE_003";
/** テーブルアクセスクラス(業務規制時更新電文)*/
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 inputDir = JCCBatCommon.getApplicationConst("WKSIJ_UPD_DNBN_MAP_INPUT_DIR");
// 取得できない場合はシステムエラーとする。
if(inputDir == null || "".equals(inputDir))
{
throw new JBSbatBusinessException("ECCB0130CE", new String[]{"業務規制時更新電文入力先格納ディレクトリ（キー：WKSIJ_UPD_DNBN_MAP_INPUT_DIR）"});
}
// 業務規制時更新電文番号をコロン区切りで切り分け
String[] freeList = free.split(":");
// 業務規制時更新電文番号ごとにサービス呼び出し
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)
{
// パラメータオブジェクト
FileInputStream paramFile = null;
XMLDecoder paramDeco = null;
XMLEncoder paramEnco = null;
ByteArrayOutputStream paramBaos = null;
// 入力データオブジェクト
FileInputStream inputDataFile = null;
XMLDecoder inputDataDeco = null;
XMLEncoder inputDataEnco = null;
ByteArrayOutputStream inputDataBaos = null;
String filePath = null;
try
{
// 対象XMLファイルを取得する。
// パラメータマップ
filePath = freeList[i] + "_" + JBSbatCC_T_WKSIJ_UPD_DNBN.PARAM_MAP + ".xml";
paramFile = new FileInputStream(inputDir + File.separator + filePath);
paramDeco = new XMLDecoder(new BufferedInputStream(paramFile));
// マップに変換できるかチェックを行う。できない場合はシステムエラー
HashMap usecaseMap = (HashMap)paramDeco.readObject();
// 変換できれば再度、String文字列に変換
paramBaos = new ByteArrayOutputStream();
paramEnco = new XMLEncoder(paramBaos);
paramEnco.writeObject(usecaseMap);
// 入力データマップ
filePath = freeList[i] + "_" + JBSbatCC_T_WKSIJ_UPD_DNBN.INPUT_DATA_MAP + ".xml";
inputDataFile = new FileInputStream(inputDir + File.separator + filePath);
inputDataDeco = new XMLDecoder(new BufferedInputStream(inputDataFile));
// マップに変換できるかチェックを行う。できない場合はシステムエラー
HashMap inputDataMap = (HashMap)inputDataDeco.readObject();
// 変換できれば再度、String文字列に変換
inputDataBaos = new ByteArrayOutputStream();
inputDataEnco = new XMLEncoder(inputDataBaos);
inputDataEnco.writeObject(inputDataMap);
}
catch(Exception e)
{
// マップチェック時にエラーが発生した旨を設定
super.logPrint.printBusinessErrorLog("ECCB0120CE", new String[]{"ファイルチェックエラーです。:" + filePath});
throw e;
}
finally
{
if(paramFile != null)
{
paramFile.close();
}
if(paramDeco != null)
{
paramDeco.close();
}
if(paramEnco != null)
{
paramEnco.close();
}
if(inputDataFile != null)
{
inputDataFile.close();
}
if(inputDataDeco != null)
{
inputDataDeco.close();
}
if(inputDataEnco != null)
{
inputDataEnco.close();
}
}
// システム日付取得
String sysDateTime = JCCBatCommon.getSysDateTimeStamp();
// 業務規制時更新電文更新
String[] param = new String[]{paramBaos.toString("UTF-8"), inputDataBaos.toString("UTF-8"),sysDateTime, batchUserId, freeList[i]};
executeCC_T_WKSIJ_UPD_DNBN_CC_UPDATE_003(param);
}
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);
}
/**
* SQLKEY(CC_UPDATE_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * パラメータマップ * 入力データマップ * 更新年月日時分秒 * 更新オペレータアカウント * 業務規制時更新電文番号 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCC_T_WKSIJ_UPD_DNBN_CC_UPDATE_003(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); paramList.setValue(param[3].toString()); paramList.setValue(param[4].toString()); // DBアクセスを実行します db_CC_T_WKSIJ_UPD_DNBN.executeBySqlDefine(paramList, CC_T_WKSIJ_UPD_DNBN_CC_UPDATE_003); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }