*
* @author 富士通
*/
public class JBSbatKKMansHhsSwchAfUpdate extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(異動予約)*/
private static final String D_TBL_NAME_KK_T_IDO_RSV = "KK_T_IDO_RSV";
/** テーブル(工事案件)*/
private static final String D_TBL_NAME_KU_T_KOJIAK = "KU_T_KOJIAK";
/** テーブル(工事案件＜ｅｏ光ネットマンション＞)*/
private static final String D_TBL_NAME_KU_T_KJAK_EOH_NTMANS = "KU_T_KJAK_EOH_NTMANS";
/** SQL定義キー(KK_UPDATE_003)*/
private static final String KK_T_IDO_RSV_KK_UPDATE_003 = "KK_UPDATE_003";
/** SQL定義キー(KK_UPDATE_005)*/
private static final String KU_T_KOJIAK_KK_UPDATE_005 = "KK_UPDATE_005";
/** SQL定義キー(KK_UPDATE_002)*/
private static final String KU_T_KJAK_EOH_NTMANS_KK_UPDATE_002 = "KK_UPDATE_002";
/** テーブルアクセスクラス(異動予約)*/
private JBSbatSQLAccess db_KK_T_IDO_RSV = null;
/** テーブルアクセスクラス(工事案件)*/
private JBSbatSQLAccess db_KU_T_KOJIAK = null;
/** テーブルアクセスクラス(工事案件＜ｅｏ光ネットマンション＞)*/
private JBSbatSQLAccess db_KU_T_KJAK_EOH_NTMANS = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KK_T_IDO_RSV = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_IDO_RSV);
db_KU_T_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KOJIAK);
db_KU_T_KJAK_EOH_NTMANS = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KJAK_EOH_NTMANS);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// フリー項目を取得
String[] freeItem = commonItem.getFreeItem().split(JKKBatConst.S_PARAM_DELIM);
// 異動予約更新ファイルを読込
JBSbatInputFileUtil idoUpdateFile = new JBSbatInputFileUtil(freeItem[0]);
idoUpdateFile.setEncode(JKKBatConst.SJIS);
idoUpdateFile.createReader();
// 異動予約更新データの一行目
String idoUpdateData = idoUpdateFile.readLine();
// 工事案件更新ファイルを読込
JBSbatInputFileUtil kojiUpdateFile = new JBSbatInputFileUtil(freeItem[1]);
kojiUpdateFile.setEncode(JKKBatConst.SJIS);
kojiUpdateFile.createReader();
// 工事案件更新データの一行目
String kojiUpdateData = kojiUpdateFile.readLine();
// 異動予約更新データを取得し、更新を行う
while (idoUpdateData != null)
{
// 異動予約更新パラメータを保存する配列
String[] idoUpdateParam = idoUpdateData.split(JKKBatConst.S_SEP_CAM);
// パラメータ設定
String[] param = {idoUpdateParam[1], idoUpdateParam[2]};
// 異動予約更新
executeKK_T_IDO_RSV_KK_UPDATE_003(param);
// 次のデータを取得する
idoUpdateData = idoUpdateFile.readLine();
}
// 工事案件更新データを取得し、更新を行う
while (kojiUpdateData != null)
{
// 異動予約更新パラメータを保存する配列
String[] kojiUpdateParam = kojiUpdateData.split(JKKBatConst.S_SEP_CAM);
// 工事案件更新パラメータ設定
String[] param1 = {kojiUpdateParam[0]};
// 工事案件更新
executeKU_T_KOJIAK_KK_UPDATE_005(param1);
// 工事案件＜ｅｏ光ネットマンション＞更新パラメータ設定
String[] param2 = {kojiUpdateParam[1], kojiUpdateParam[0]};
// 工事案件＜ｅｏ光ネットマンション＞更新
executeKU_T_KJAK_EOH_NTMANS_KK_UPDATE_002(param2);
// 次のデータを取得する
kojiUpdateData = kojiUpdateFile.readLine();
}
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_IDO_RSV.close();
db_KU_T_KOJIAK.close();
db_KU_T_KJAK_EOH_NTMANS.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(KK_UPDATE_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 予約適用年月日 * 異動予約番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_IDO_RSV_KK_UPDATE_003(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_KK_T_IDO_RSV.executeBySqlDefine(paramList, KK_T_IDO_RSV_KK_UPDATE_003);
}
/**
* SQLKEY(KK_UPDATE_005)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 工事案件番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKU_T_KOJIAK_KK_UPDATE_005(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_KU_T_KOJIAK.executeBySqlDefine(paramList, KU_T_KOJIAK_KK_UPDATE_005);
}
/**
* SQLKEY(KK_UPDATE_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 解約希望年月日 * 工事案件番号 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKU_T_KJAK_EOH_NTMANS_KK_UPDATE_002(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); // DBアクセスを実行します db_KU_T_KJAK_EOH_NTMANS.executeBySqlDefine(paramList, KU_T_KJAK_EOH_NTMANS_KK_UPDATE_002); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }