*
* @author 富士通
*/
public class JBSbatKKTvKsSvIdoInfoChsht extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(サービス契約)*/
private static final String D_TBL_NAME_KK_T_SVC_KEI = "KK_T_SVC_KEI";
/** SQL定義キー(KK_SELECT_322)*/
private static final String KK_T_SVC_KEI_KK_SELECT_322 = "KK_SELECT_322";
/** 共通クラスインスタンス */
private JKKBatKKTvKsSvInfoCommon tvKsSvInfoCommon = null;
/** テーブルアクセスクラス(サービス契約)*/
private JBSbatSQLAccess db_KK_T_SVC_KEI = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// 共通クラスインスタンス生成
tvKsSvInfoCommon = new JKKBatKKTvKsSvInfoCommon(commonItem);
// DBアクセスクラスを生成します
db_KK_T_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
// 出力ファイル用クラスの生成
JBSbatOutputItem out_item = new JBSbatOutputItem();
// 異動情報抽出
BufferedReader in_reader = null;
// シェルにて出力されたファイルを読み込む。
String[] free_item = commonItem.getFreeItem().split(JKKBatConst.S_PARAM_DELIM);
String in_file_nm = free_item[0];
// シェルにて出力された検索時のタイムスタンプを読み込む。
String searhTimeStamp = free_item[1];
super.logPrint.printDebugLog("■抽出開始時タイムスタンプ：" + searhTimeStamp);
try
{
// 入力ファイルクラスを生成します。
in_reader = new BufferedReader(new InputStreamReader(new FileInputStream(in_file_nm)));
// ファイルが終了するまで読込みを繰り返します
while (in_reader.ready())
{
String[] data = in_reader.readLine().split(",");
// サービス契約番号
String svc_kei_no = JBSbatStringUtil.Rtrim(data[0].replace("\"", ""));
super.logPrint.printDebugLog("サービス契約.サービス契約番号：" + svc_kei_no);
// 異動情報抽出共通処理
JBSbatServiceInterfaceMap outMap = tvKsSvInfoCommon.createKKIFE050BaseData(svc_kei_no);
// 出力情報が取得できない場合
if (null == outMap)
{
super.logPrint.printDebugLog("サービス契約が存在しません_1：" + svc_kei_no);
continue;
}
// OM-2016-0001550 MOD START
// // 異動区分を設定する
// String kcn_rido_div = "";
// // 対象となるサービス契約の抽出を行う。
// String[] param = {svc_kei_no};
// this.executeKK_T_SVC_KEI_KK_SELECT_322(param);
//
// JBSbatCommonDBInterface svcKei322Map = db_KK_T_SVC_KEI.selectNext();
//
// //異動区分を設定
// if(null != svcKei322Map)
// {
// //住所変更中
// kcn_rido_div = "10000";
// //引越先のサービス契約番号（「住所変更明細」の変更後識別番号）を設定
// outMap.setString(JBSbatKKIFE050001.HIKKOSHI_SK_CUST_ID, JBSbatStringUtil.Rtrim(svcKei322Map.getString(JBSbatKK_T_ADCHG_DTL.CHAF_SKBT_NO)));
// }
// else if(JBSbatStringUtil.Rtrim(outMap.getString(JBSbatKKIFE050001.YOBI_KMK_1)).equals("910") || JBSbatStringUtil.Rtrim(outMap.getString(JBSbatKKIFE050001.YOBI_KMK_1)).equals("920"))
// {
// //予備項目1=サービス契約.サービス契約ステータス(解約済、キャンセル済は"90000"を設定)
// kcn_rido_div = "90000";
// }
// 異動区分/引越先サービス契約番号設定
String kcn_rido_div = "";
if(JBSbatStringUtil.Rtrim(outMap.getString(JBSbatKKIFE050001.YOBI_KMK_1)).equals("910") || JBSbatStringUtil.Rtrim(outMap.getString(JBSbatKKIFE050001.YOBI_KMK_1)).equals("920"))
{
// 予備項目1(サービス契約ステータス)=解約済、キャンセル済の場合は異動区分に"90000"を設定
kcn_rido_div = "90000";
}
else
{
// 住所変更中チェック
String[] param = {svc_kei_no};
this.executeKK_T_SVC_KEI_KK_SELECT_322(param);
JBSbatCommonDBInterface svcKei322Map = db_KK_T_SVC_KEI.selectNext();
if(null != svcKei322Map)
{
// 住所変更中の場合は異動区分に10000を設定
kcn_rido_div = "10000";
// 住所変更中の場合は引越先サービス契約番号に住所変更明細.変更後識別番号を設定
outMap.setString(JBSbatKKIFE050001.HIKKOSHI_SK_CUST_ID, JBSbatStringUtil.Rtrim(svcKei322Map.getString(JBSbatKK_T_ADCHG_DTL.CHAF_SKBT_NO)));
}
}
// OM-2016-0001550 MOD END
outMap.setString(JBSbatKKIFE050001.IDO_DIV, kcn_rido_div);
out_item.addOutMapList(outMap);
}
in_reader.close();
}
catch(IOException ioe)
{
// ファイル未存在
throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0020CE, new String[]{in_file_nm});
}
finally
{
if (in_reader != null)
{
in_reader.close();
}
}
super.logPrint.printDebugLog("execute_END");
return out_item;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* SQLKEY(KK_SELECT_322)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 予約適用年月日 * 更新年月日時分秒 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_SVC_KEI_KK_SELECT_322(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); // DBアクセスを実行します db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KK_SELECT_322); } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_KK_T_SVC_KEI.close(); // 共通クラスクローズ tvKsSvInfoCommon.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } }