* 加入御礼書マンション親情報抽出
*
* 「KKPRC00504_加入御礼書ファイル抽出」にて出力された加入御礼書ファイル送信データを元に加入御礼書マンション親情報送信データの作成を行う。
*
* @author 富士通
*/
public class JBSbatKKGetKanuoreParentMans extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** テーブル(加入御礼書発行)*/
private static final String D_TBL_NAME_KK_T_KANUORESO_HAKKO = "KK_T_KANUORESO_HAKKO";
/** テーブルアクセスクラス(加入御礼書発行)*/
private JBSbatSQLAccess db_KK_T_KANUORESO_HAKKO = null;
/** SQL定義キー(KK_SELECT_006)*/
private static final String KK_T_KANUORESO_HAKKO_KK_SELECT_006 = "KK_SELECT_006";
/** 出力件数 */
private int reccnt = 0;
/** ファイル括り文字 */
private static final String SCOPE = "\"";
// ANK-3731-00-00 ADD START
/** 光配線1Gのみフラグ */
private static final String HHS_1GONLY_FLG = "HHS_1GONLY_FLG";
/** 提供方式パターンコード（52 光配線 1Gのみ） */
private static final String TK_HSK_PTN_CD_52 = "52";
// ANK-3731-00-00 ADD END
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
db_KK_T_KANUORESO_HAKKO = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KANUORESO_HAKKO);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// FreeパラメータよりインターフェイスIDとファイル名を取得
// 出力共通電文を生成する。
JBSbatOutputItem outputBean = new JBSbatOutputItem();
// ファイル出力（加入御礼書マンション親情報送信ファイル）
// 運用日付、SYSID、同一回線グループ識別番号をキーに加入御礼書発行を検索する。
Object[] setParam = { this.opeDate, inMap.getString(JBSbatKKIFE425.SYSID),inMap.getString(JBSbatKKIFE425.SAME_KAISEN_GRP_SKBT_NO) };
this.executeKK_T_KANUORESO_HAKKO_KK_SELECT_006(setParam);
// 先頭の1レコードを取得する。
JBSbatCommonDBInterface result = this.db_KK_T_KANUORESO_HAKKO.selectNext();
// 取得できない場合は次処理を終了する。
if(null == result)
{
return null;
}
// ANK-3731-00-00 ADD START
// 光配線1Gのみフラグが'1'の場合、提供方式パターンコードを'52'に置換
if ("1".equals(result.getString(HHS_1GONLY_FLG)))
{
result.setValue(JBSbatKKIFE425.TK_HOSHIKI_PATTERN_CD, TK_HSK_PTN_CD_52);
}
// ANK-3731-00-00 ADD END
// 加入御礼書マンション親情報送信データ用入出力インターフェイスオブジェクトを生成
JBSbatServiceInterfaceMap mapKKIFE425 = new JBSbatServiceInterfaceMap();
// 項目を設定
// SYSID
mapKKIFE425.setString(JBSbatKKIFE425.SYSID,
inMap.getString(JBSbatKKIFE425.SYSID));
// 同一回線グループ番号
mapKKIFE425.setString(JBSbatKKIFE425.SAME_KAISEN_GRP_SKBT_NO,
inMap.getString(JBSbatKKIFE425.SAME_KAISEN_GRP_SKBT_NO));
// 通信速度コード
mapKKIFE425.setString(JBSbatKKIFE425.TONAI_SPEED_CD,
result.getString(JBSbatKKIFE425.TONAI_SPEED_CD));
// 提供方式パターンコード
mapKKIFE425.setString(JBSbatKKIFE425.TK_HOSHIKI_PATTERN_CD,
result.getString(JBSbatKKIFE425.TK_HOSHIKI_PATTERN_CD));
// 提供方式名
mapKKIFE425.setString(JBSbatKKIFE425.TK_HOSHIKI_CD,
result.getString(JBSbatKKIFE425.TK_HOSHIKI_CD));
// アクセス回線種別コード
mapKKIFE425.setString(JBSbatKKIFE425.ACCSS_KISN_SPEED_CD,
result.getString(JBSbatKKIFE425.ACCSS_KISN_SPEED_CD));
// 契約形態コード
mapKKIFE425.setString(JBSbatKKIFE425.KANYU_KEI_PAY_HOSHIKI_CD,
result.getString(JBSbatKKIFE425.KANYU_KEI_PAY_HOSHIKI_CD));
// M-ID
mapKKIFE425.setString(JBSbatKKIFE425.MANSION_ID,
result.getString(JBSbatKKIFE425.MANSION_ID));
// 親機動作モード
mapKKIFE425.setString(JBSbatKKIFE425.PARENT_MODE,
result.getString(JBSbatKKIFE425.PARENT_MODE));
// 予備項目1
mapKKIFE425.setString(JBSbatKKIFE425.YOBI_1,
result.getString(JBSbatKKIFE425.YOBI_1));
// 予備項目2
mapKKIFE425.setString(JBSbatKKIFE425.YOBI_2,
result.getString(JBSbatKKIFE425.YOBI_2));
// 予備項目3
mapKKIFE425.setString(JBSbatKKIFE425.YOBI_3,
result.getString(JBSbatKKIFE425.YOBI_3));
// 予備項目4
mapKKIFE425.setString(JBSbatKKIFE425.YOBI_4,
result.getString(JBSbatKKIFE425.YOBI_4));
// 予備項目5
mapKKIFE425.setString(JBSbatKKIFE425.YOBI_5,
result.getString(JBSbatKKIFE425.YOBI_5));
// 出力フラグを設定
mapKKIFE425.setOutFlg(true);
// 出力共通電文入出力インターフェイスを設定する
outputBean.addOutMapList(mapKKIFE425);
reccnt++;
// 次のレコードへ
return outputBean;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
db_KK_T_KANUORESO_HAKKO.close();
// トレーラ部出力文字列を生成
StringBuffer trailerbuf = new StringBuffer();
trailerbuf.append("E");
trailerbuf.append(",");
trailerbuf.append(reccnt + "");
trailerbuf.append(",");
trailerbuf.append(super.opeDate);
// トレーラレコードの出力
super.commonItem.getOutPutFile().write(SCOPE + trailerbuf.toString().replace(",", SCOPE + "," + SCOPE) + SCOPE);
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**
* SQLKEY(KK_SELECT_006)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約番号 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_KANUORESO_HAKKO_KK_SELECT_006(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); // DBアクセスを実行します db_KK_T_KANUORESO_HAKKO.selectBySqlDefine(paramList, KK_T_KANUORESO_HAKKO_KK_SELECT_006); } /**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/ /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }