*
* @author 富士通
*/
public class JBSbatKUGenesisSvkeiChgInfoCst extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(工事案件ＰＫ検索)*/
private static final String D_TBL_NAME_KU_T_KOJIAK = "KU_T_KOJIAK";
/** テーブル(先行設計)*/
private static final String D_TBL_NAME_KU_T_SENKO_DSGN = "KU_T_SENKO_DSGN";
// ANK-3366-00-00 ADD START
/** テーブル(お客様)*/
private static final String D_TBL_NAME_CK_T_CUST = "CK_T_CUST";
/** SQL定義キー(KU_SELECT_001)*/
private static final String CK_T_CUST_KU_SELECT_001 = "KU_SELECT_001";
// ANK-3366-00-00 ADD END
/** SQL定義キー(KU_SELECT_004)*/
private static final String KU_T_SENKO_DSGN_KU_SELECT_004 = "KU_SELECT_004";
/** テーブルアクセスクラス(工事案件ＰＫ検索)*/
private JBSbatSQLAccess db_KU_T_KOJIAK = null;
/** テーブルアクセスクラス(先行設計)*/
private JBSbatSQLAccess db_KU_T_SENKO_DSGN = null;
// ANK-3366-00-00 ADD START
/** テーブルアクセスクラス(お客様)*/
private JBSbatSQLAccess db_CK_T_CUST = null;
// ANK-3366-00-00 ADD END
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**▼▼▼▼▼▼業務チームで作成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(工事案件＜光ネットマンション＞)*/
private static final String D_TBL_NAME_KU_T_KJAK_EOH_NTMANS = "KU_T_KJAK_EOH_NTMANS";
/** テーブル(局番)*/
private static final String D_TBL_NAME_ZM_M_KYOKU_NO = "ZM_M_KYOKU_NO";
/** テーブルアクセスクラス(工事案件＜光ネットマンション＞) */
private JBSbatSQLAccess dKuTKjakEohNtMans = null;
/** テーブルアクセスクラス(番ポ可能エリア対象局番)*/
private JBSbatSQLAccess db_ZM_M_KYOKU_NO = null;
/**▲▲▲▲▲▲業務チームで作成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KU_T_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KOJIAK);
db_KU_T_SENKO_DSGN = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_SENKO_DSGN);
// ANK-3366-00-00 ADD START
db_CK_T_CUST = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CK_T_CUST);
// ANK-3366-00-00 ADD END
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
dKuTKjakEohNtMans = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KJAK_EOH_NTMANS);
db_ZM_M_KYOKU_NO = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_KYOKU_NO);
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// 出力共通電文を生成する。
JBSbatOutputItem outputBean = new JBSbatOutputItem();
// 入出力インターフェースオブジェクトを生成
JBSbatServiceInterfaceMap outMap = null;
// 工事案件番号
String kojiakNo = inMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_NO);
// 先行設計検索
JBSbatCommonDBInterface senkouMap = this.findKU_T_SENKO(kojiakNo);
// 先行設計が存在しない場合、次レコードへ
if(null == senkouMap)
{
// ログ出力し、次レコードへ
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKUB0650KW, new String[]{
JKUStrConst.SCHEMANM_KU0101,
"工事案件番号",
kojiakNo});
throw new JBSbatBusinessError();
}
// 出力ファイルを編集
outMap = this.setOutMap(inMap, senkouMap);
// 出力共通電文に入出力インターフェースを設定する。
outputBean.addOutMapList(outMap);
// 工事案件を更新
this.updateKU_T_KOJIAK(inMap);
return outputBean;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KU_T_KOJIAK.close();
db_KU_T_SENKO_DSGN.close();
// ANK-3366-00-00 ADD START
db_CK_T_CUST.close();
// ANK-3366-00-00 ADD END
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
dKuTKjakEohNtMans.close();
db_ZM_M_KYOKU_NO.close();
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(KU_SELECT_004)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 工事案件番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKU_T_SENKO_DSGN_KU_SELECT_004(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_KU_T_SENKO_DSGN.selectBySqlDefine(paramList, KU_T_SENKO_DSGN_KU_SELECT_004);
}
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * Ｇｅｎｅｓｉｓ前回連携サービス契約番号 GENESIS_ZNKI_RNKI_SVKEI_NO * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * KOJIAK_NO *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKU_T_KOJIAK_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("GENESIS_ZNKI_RNKI_SVKEI_NO", setParam[0]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("KOJIAK_NO", whereParam[0]);
// DBアクセスを実行します
db_KU_T_KOJIAK.updateByPrimaryKeys(whereMap, setMap);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**▼▼▼▼▼▼業務チームで作成したメソッドです 開始▼▼▼▼▼▼*/
/**
* 出力共通電文を設定します。
* @param inMap 入力電文
* @param senkouMap 先行設計
* @return 出力共通電文
* @throws Exception
*/
private JBSbatServiceInterfaceMap setOutMap(JBSbatServiceInterfaceMap inMap, JBSbatCommonDBInterface senkouMap) throws Exception
{
// バッチ共通アクセッサー
JKUBatCommon jKUBatCommon = new JKUBatCommon();
// 出力電文
JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();
// 出力フラグを設定
outMap.setOutFlg(true);
// ANK-3366-00-00 ADD START
// 工事案件のSYSID
String sysidParam = inMap.getString(JBSbatKU_T_KOJIAK.SYSID);
// お客様取得処理を呼び出し、卸先事業者コードを取得する
String orsjgsCd = findOrsjgsCd(sysidParam);
// ANK-3366-00-00 ADD END
// 現在工程
outMap.setString(JBSbatKUIFE023.NOW_STEP, JKUStrConst.KEI_STAT_KEI_CHU);
// 工事案件番号
outMap.setString(JBSbatKUIFE023.KOJIAK_NO, inMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_NO));
// 電話番号種別
outMap.setString(JBSbatKUIFE023.TELNO_SBT, null);
// 回線場所電話番号分割
String[] kaisenPlaceTelno = new String[3];
// 住所変更確定年月日時分秒
String adChgFixDtm = inMap.getString(JBSbatKU_T_KOJIAK.AD_CHG_FIX_DTM);
// 工事案件種別コードが住所変更(新設)かつ住所変更確定年月日時分秒に値が入っている場合
if(JKUStrConst.CD00577_AD_CHG_NEWESTA.equals(inMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_SBT_CD))
&& true == this.nullCheckPrivate(adChgFixDtm) )
{
// 回線場所電話番号を設定する
kaisenPlaceTelno = jKUBatCommon.splitTln(commonItem, senkouMap.getString(JBSbatKU_T_SENKO_DSGN.KAISEN_PLACE_TELNO), db_ZM_M_KYOKU_NO);
}
else
{
// お客様自宅電話番号を設定する
kaisenPlaceTelno = jKUBatCommon.splitTln(commonItem, inMap.getString(JBSbatKU_T_KOJIAK.CUST_HOME_TELNO), db_ZM_M_KYOKU_NO);
}
if(null != kaisenPlaceTelno)
{
// 回線場所電話番号１
outMap.setString(JBSbatKUIFE023.KAISEN_PLACE_TELNO_1, kaisenPlaceTelno[0]);
// 回線場所電話番号２
outMap.setString(JBSbatKUIFE023.KAISEN_PLACE_TELNO_2, kaisenPlaceTelno[1]);
// 回線場所電話番号３
outMap.setString(JBSbatKUIFE023.KAISEN_PLACE_TELNO_3, kaisenPlaceTelno[2]);
}
// お客様名１
outMap.setString(JBSbatKUIFE023.CUST_NM_1, JKUBatCommon.getCustName1(inMap.getString(JBSbatKU_T_KOJIAK.CUST_NM)));
// お客様名２
String[] custName2 = JKUBatCommon.splitString(JKUBatCommon.getCustName2(inMap.getString(JBSbatKU_T_KOJIAK.CUST_NM)), 30, true);
outMap.setString(JBSbatKUIFE023.CUST_NM_2, custName2[0]);
// お客様カナ名
String[] custKana = JKUBatCommon.splitString(inMap.getString(JBSbatKU_T_KOJIAK.CUST_KANA), 30, true);
outMap.setString(JBSbatKUIFE023.CUST_KANA, custKana[0]);
// 連絡先電話番号種別
outMap.setString(JBSbatKUIFE023.CUST_RRKS_TELNO_SBT_CD, null);
// お客様連絡先電話番号分割
String[] custRrksTelno = new String[3];
custRrksTelno = jKUBatCommon.splitTln(commonItem, inMap.getString(JBSbatKU_T_KOJIAK.CUST_RRKS_TELNO), db_ZM_M_KYOKU_NO);
if(null != custRrksTelno)
{
// お客様連絡先電話番号１
outMap.setString(JBSbatKUIFE023.CUST_RRKS_TELNO_1, custRrksTelno[0]);
// お客様連絡先電話番号２
outMap.setString(JBSbatKUIFE023.CUST_RRKS_TELNO_2, custRrksTelno[1]);
// お客様連絡先電話番号３
outMap.setString(JBSbatKUIFE023.CUST_RRKS_TELNO_3, custRrksTelno[2]);
}
// 備考
outMap.setString(JBSbatKUIFE023.BIKO, null);
// サービス契約番号
outMap.setString(JBSbatKUIFE023.SVC_KEI_NO, inMap.getString(JBSbatKU_T_KOJIAK.RNKI_SVC_KEI_NO));
// 都道府県名
outMap.setString(JBSbatKUIFE023.STATE_NM, inMap.getString(JBSbatKU_T_KOJIAK.TENTAKU_SAKI_STATE_NM));
// 市区町村名
outMap.setString(JBSbatKUIFE023.CITY_NM, inMap.getString(JBSbatKU_T_KOJIAK.TENTAKU_SAKI_CITY_NM));
// 大字通称名
outMap.setString(JBSbatKUIFE023.OAZTSU_NM, inMap.getString(JBSbatKU_T_KOJIAK.TENTAKU_SAKI_OAZTSU_NM));
// 字丁目名
outMap.setString(JBSbatKUIFE023.AZCHO_NM, inMap.getString(JBSbatKU_T_KOJIAK.TENTAKU_SAKI_AZCHO_NM));
// 住所番地号
outMap.setString(JBSbatKUIFE023.AD_BNCHIGO, inMap.getString(JBSbatKU_T_KOJIAK.TENTAKU_SAKI_AD_BNCHIGO));
// 住所補記・建物名
outMap.setString(JBSbatKUIFE023.ADRTTM, inMap.getString(JBSbatKU_T_KOJIAK.TENTAKU_SAKI_ADRTTM));
// 住所補記・部屋番号
outMap.setString(JBSbatKUIFE023.ADRRM, inMap.getString(JBSbatKU_T_KOJIAK.TENTAKU_SAKI_ADRRM));
// Ｘ座標（６系）
outMap.setString(JBSbatKUIFE023.XZAHYO_6, inMap.getString(JBSbatKU_T_KOJIAK.XZAHYO_6));
// Ｙ座標（６系）
outMap.setString(JBSbatKUIFE023.YZAHYO_6, inMap.getString(JBSbatKU_T_KOJIAK.YZAHYO_6));
// お客様連絡先携帯電話番号分割
String[] custRrksktaitelno = new String[3];
custRrksktaitelno = jKUBatCommon.splitTln(commonItem, inMap.getString(JBSbatKU_T_KOJIAK.CUST_KTAI_TELNO), db_ZM_M_KYOKU_NO);
if(null != custRrksktaitelno)
{
// お客様連絡先携帯電話番号１
outMap.setString(JBSbatKUIFE023.CUST_RRKS_KTAI_TELNO_1, custRrksktaitelno[0]);
// お客様連絡先携帯電話番号２
outMap.setString(JBSbatKUIFE023.CUST_RRKS_KTAI_TELNO_2, custRrksktaitelno[1]);
// お客様連絡先携帯電話番号３
outMap.setString(JBSbatKUIFE023.CUST_RRKS_KTAI_TELNO_3, custRrksktaitelno[2]);
}
// 利用場所階数
outMap.setString(JBSbatKUIFE023.USE_PLACE_KAISU, inMap.getString(JBSbatKU_T_KOJIAK.KCKU_FLR_CNT_CD));
// 工事案件完了年月日
outMap.setString(JBSbatKUIFE023.KOJIAK_FIN_YMD, null);
// Ｘ座標（５系）
outMap.setString(JBSbatKUIFE023.XZAHYO_5, inMap.getString(JBSbatKU_T_KOJIAK.XZAHYO_5));
// Ｙ座標（５系）
outMap.setString(JBSbatKUIFE023.YZAHYO_5, inMap.getString(JBSbatKU_T_KOJIAK.YZAHYO_5));
// 設備向けコード変換（分類コード、新料金プラン）
HashMap
* 処理フロー
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCK_T_CUST_KU_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_CK_T_CUST.selectBySqlDefine(paramList, CK_T_CUST_KU_SELECT_001);
}
//ANK-3366-00-00 ADD END
/**▲▲▲▲▲▲業務チームで作成したメソッドです 終了▲▲▲▲▲▲*/
//ANK-3885-00-00 ADD START
/**
* PK(ＰＫ 検索)でDBアクセスを行います。
* 処理フロー
* @param whereParam 条件項目の値。
* @return JBSbatCommonDBInterface 検索の結果。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private JBSbatCommonDBInterface executeKU_T_KJAK_EOH_NTMANS_PKSELECT(Object[] whereParam) throws Exception
{
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("KOJIAK_NO", whereParam[0]);
// DBアクセスを実行します
return dKuTKjakEohNtMans.selectByPrimaryKeys(whereMap);
}
//ANK-3885-00-00 ADD END
}
*
*
* 1.引数でバイント変数を設定します。
*
*
* 2.DBアクセスを実行します。
*
* 3.メソッドの呼び出し方です。
* 引数:
* param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
* SYSID
* 予約適用年月日
*
*
*
* 1.引数で条件マップを作ります。
*
*
* 2.DBアクセスを実行します。
*
* 3.メソッドの呼び出し方です。
* 引数:
* whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
* KOJIAK_NO
*