*
* @author 富士通
*/
public class JBSbatKKDmSendTrgtIktSel extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(配送)*/
private static final String D_TBL_NAME_DK_T_HAISO = "DK_T_HAISO";
/** テーブル(機器提供サービス契約)*/
private static final String D_TBL_NAME_KK_T_KKTK_SVC_KEI = "KK_T_KKTK_SVC_KEI";
/** テーブル(サービス契約回線内訳)*/
private static final String D_TBL_NAME_KK_T_SVKEI_KAISEN_UW = "KK_T_SVKEI_KAISEN_UW";
/** テーブル(お客様)*/
private static final String D_TBL_NAME_CK_T_CUST = "CK_T_CUST";
/** SQL定義キー(KK_SELECT_018)*/
private static final String DK_T_HAISO_KK_SELECT_018 = "KK_SELECT_018";
/** SQL定義キー(KK_SELECT_188)*/
private static final String KK_T_KKTK_SVC_KEI_KK_SELECT_188 = "KK_SELECT_188";
/** SQL定義キー(KK_SELECT_049)*/
private static final String KK_T_SVKEI_KAISEN_UW_KK_SELECT_049 = "KK_SELECT_049";
/** SQL定義キー(KK_SELECT_063)*/
private static final String CK_T_CUST_KK_SELECT_063 = "KK_SELECT_063";
/** テーブルアクセスクラス(配送)*/
private JBSbatSQLAccess db_DK_T_HAISO = null;
/** テーブルアクセスクラス(機器提供サービス契約)*/
private JBSbatSQLAccess db_KK_T_KKTK_SVC_KEI = null;
/** テーブルアクセスクラス(サービス契約回線内訳)*/
private JBSbatSQLAccess db_KK_T_SVKEI_KAISEN_UW = null;
/** テーブルアクセスクラス(お客様)*/
private JBSbatSQLAccess db_CK_T_CUST = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_DK_T_HAISO = new JBSbatSQLAccess(commonItem, D_TBL_NAME_DK_T_HAISO);
db_KK_T_KKTK_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KKTK_SVC_KEI);
db_KK_T_SVKEI_KAISEN_UW = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVKEI_KAISEN_UW);
db_CK_T_CUST = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CK_T_CUST);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
// 出力ファイル情報
JBSbatOutputItem outputItem = new JBSbatOutputItem();
// シェルで実行されたSQLで抽出された工事案件、工事案件対象宅内機器情報から、
// E-PON→GE-PON設備切替工事の情報を対象として抽出します。
// SYSID
String sysid = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKU_T_KOJIAK.SYSID));
// 連携サービス契約番号
String svc_kei_no = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKU_T_KOJIAK.RNKI_SVC_KEI_NO));
// 機器提供サービス契約番号
String kktk_svc_kei_no = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKU_T_KJAK_TG_TKKIKI.KKTK_SVC_KEI_NO));
// 変更機器変更番号の取得
String chge_kiki_chg_no = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKU_T_KJAK_TG_TKKIKI.CHGE_KIKI_CHG_NO));
// 予定機器変更番号の取得
String rsv_kiki_chg_no = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKU_T_KJAK_TG_TKKIKI.RSV_KIKI_CHG_NO));
/* ++++++++++ v10.00.00 追加開始 ++++++++++ */
// 工事案件番号
String kojiak_no = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKU_T_KOJIAK.KOJIAK_NO));
/* ++++++++++ v10.00.00 追加終了 ++++++++++ */
super.logPrint.printDebugLog("機器提供サービス契約番号：" + kktk_svc_kei_no);
super.logPrint.printDebugLog("変更機器変更番号 ：" + chge_kiki_chg_no);
super.logPrint.printDebugLog("予定機器変更番号 ：" + rsv_kiki_chg_no);
// 機器変更番号
String kiki_chg_no = "";
// 工事案件対象宅内機器.変更機器変更番号が設定されている場合
if (!"".equals(chge_kiki_chg_no))
{
// 配送、配送対象物品TBL、機器提供サービス契約TBL検索パラメータに変更機器変更番号をセットします。
kiki_chg_no = chge_kiki_chg_no;
}
// 工事案件対象宅内機器.変更機器変更番号が設定されていない場合
else
{
// 配送、配送対象物品TBL、機器提供サービス契約TBL検索パラメータに予定機器変更番号をセットします。
kiki_chg_no = rsv_kiki_chg_no;
}
// 配送、配送対象物品TBLを検索します。
// （配送ステータスが「004」完了済、出荷完了年月日＝バッチ運用日のデータ）
JBSbatCommonDBInterface outMap018 = this.selectHaiso018( kktk_svc_kei_no, kiki_chg_no);
// 検索結果を判断します。
if (null == outMap018)
{
// 取得できなかった場合読み飛ばす。
return null;
}
// 機器提供サービス契約TBLを検索します。
// （カレントデータを取得。機器提供サービス契約ステータスが「910」解約済「920」キャンセル済 以外のデータ）
JBSbatCommonDBInterface outMap188 = this.selectKktkSvcKei188(kktk_svc_kei_no, kiki_chg_no);
// 検索結果を判断します。
if (null == outMap188)
{
// 取得できなかった場合読み飛ばす。
return null;
}
// サービス契約番号
//String svc_kei_no = JBSbatStringUtil.Rtrim(outMap188.getString(JBSbatKK_T_KKTK_SVC_KEI.SVC_KEI_NO));
// サービス契約回線内訳番号
String svc_kei_kaisen_ucwk_no = JBSbatStringUtil.Rtrim(outMap188.getString(JBSbatKK_T_KKTK_SVC_KEI.SVC_KEI_KAISEN_UCWK_NO));
// サービス契約回線内訳を検索します。
// （カレントデータを取得。）
JBSbatCommonDBInterface outMap049 = this.selectSvkeiKaisenUw049(svc_kei_kaisen_ucwk_no);
// 検索結果を判断します。
if (null == outMap049)
{
// 取得できなかった場合読み飛ばす。
return null;
}
// お客様を検索します。
// （カレントデータを取得。）
JBSbatCommonDBInterface outMap063 = this.selectCust063(sysid);
// お客様名
String cust_nm = "";
// 検索結果を判断します。
if (null != outMap063)
{
// お客様名
cust_nm = JBSbatStringUtil.Rtrim(outMap063.getString(JBSbatCK_T_CUST.CUST_NM));
}
// 出力ファイルデータMAP
JBSbatServiceInterfaceMap outDataMap = new JBSbatServiceInterfaceMap();
// 設備切替ＤＭ送付情報ファイルへ出力する項目のデータを設定
setOtf1FileInfo(outDataMap, svc_kei_no, cust_nm, outMap049, kojiak_no);
outDataMap.setOutFlg(true);
outputItem.addOutMapList(outDataMap);
super.logPrint.printDebugLog("execute_END");
return outputItem;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_DK_T_HAISO.close();
db_KK_T_KKTK_SVC_KEI.close();
db_KK_T_SVKEI_KAISEN_UW.close();
db_CK_T_CUST.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(KK_SELECT_018)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 機器提供サービス契約番号 * 機器変更番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeDK_T_HAISO_KK_SELECT_018(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_DK_T_HAISO.selectBySqlDefine(paramList, DK_T_HAISO_KK_SELECT_018);
}
/**
* SQLKEY(KK_SELECT_188)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 機器提供サービス契約番号 * 機器変更番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_KKTK_SVC_KEI_KK_SELECT_188(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_KK_T_KKTK_SVC_KEI.selectBySqlDefine(paramList, KK_T_KKTK_SVC_KEI_KK_SELECT_188);
}
/**
* SQLKEY(KK_SELECT_049)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約回線内訳番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVKEI_KAISEN_UW_KK_SELECT_049(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_KK_T_SVKEI_KAISEN_UW.selectBySqlDefine(paramList, KK_T_SVKEI_KAISEN_UW_KK_SELECT_049);
}
/**
* SQLKEY(KK_SELECT_063)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * SYSID * 予約適用年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCK_T_CUST_KK_SELECT_063(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_KK_SELECT_063);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 配送、配送対象物品TBLの検索を行います。(KK_SELECT_018)
*
* @param kktkSvcKeiNo 機器提供サービス契約番号
* @param kkChgNo 機器変更番号
* @param opeDate 出荷完了日
* @return JBSbatCommonDBInterface 入出力インターフェースオブジェクト
* @throws Exception メソッド内で発生した例外全般
*/
private JBSbatCommonDBInterface selectHaiso018(String kktkSvcKeiNo, String kkChgNo) throws Exception
{
super.logPrint.printDebugLog("selectHaiso018_検索");
// 配送、配送対象物品TBLを検索します。
// 配送、配送対象物品TBL検索条件項目を設定します。
Object[] paramList = new Object[3];
paramList[0] = kktkSvcKeiNo; // 機器提供サービス契約番号
paramList[1] = kkChgNo; // 機器変更番号
paramList[2] = super.opeDate; // 出荷完了日
// 配送、配送対象物品情報検索処理を実行します。
executeDK_T_HAISO_KK_SELECT_018(paramList);
// 検索結果を取得します。
JBSbatCommonDBInterface outDbMap = db_DK_T_HAISO.selectNext();
return outDbMap;
}
/**
* 機器提供サービス契約TBLの検索を行います。(KK_SELECT_188)
*
* @param kktkSvcKeiNo 機器提供サービス契約番号
* @param kkChgNo 機器変更番号
* @return JBSbatCommonDBInterface 入出力インターフェースオブジェクト
* @throws Exception メソッド内で発生した例外全般
*/
private JBSbatCommonDBInterface selectKktkSvcKei188(String kktkSvcKeiNo, String kkChgNo) throws Exception
{
super.logPrint.printDebugLog("selectKktkSvcKei188_検索");
// 機器提供サービス契約TBLを検索し、世代のMAXを取得します。
// 機器提供サービス契約TBL検索条件項目を設定します。
Object[] paramList = new Object[2];
paramList[0] = kktkSvcKeiNo; // 機器提供サービス契約番号
paramList[1] = kkChgNo; // 機器変更番号
// 機器提供サービス契約情報検索処理を実行します。
executeKK_T_KKTK_SVC_KEI_KK_SELECT_188(paramList);
// 検索結果を取得します。
JBSbatCommonDBInterface outDbMap = db_KK_T_KKTK_SVC_KEI.selectNext();
return outDbMap;
}
/**
* サービス契約回線内訳TBLの検索を行います。(KK_SELECT_049)
*
* @param svc_kei_kaisen_ucwk_no サービス契約回線内訳番号
* @param
* @return JBSbatCommonDBInterface 入出力インターフェースオブジェクト
* @throws Exception メソッド内で発生した例外全般
*/
private JBSbatCommonDBInterface selectSvkeiKaisenUw049(String svc_kei_kaisen_ucwk_no) throws Exception
{
super.logPrint.printDebugLog("selectSvkeiKaisenUw049_検索");
// サービス契約回線内訳TBLを検索し、世代のMAXを取得します。
// サービス契約回線内訳TBL検索条件項目を設定します。
Object[] paramList = new Object[1];
paramList[0] = svc_kei_kaisen_ucwk_no; // サービス契約回線内訳番号
// サービス契約回線内訳情報検索処理を実行します。
executeKK_T_SVKEI_KAISEN_UW_KK_SELECT_049(paramList);
// 検索結果を取得します。
JBSbatCommonDBInterface outDbMap = db_KK_T_SVKEI_KAISEN_UW.selectNext();
return outDbMap;
}
/**
* お客様TBLの検索を行います。(KK_SELECT_063)
*
* @param sysid SYSID
* @param opeDate バッチ運用日
* @return JBSbatCommonDBInterface 入出力インターフェースオブジェクト
* @throws Exception メソッド内で発生した例外全般
*/
private JBSbatCommonDBInterface selectCust063(String sysid) throws Exception
{
super.logPrint.printDebugLog("selectCust063_検索");
// お客様TBLを検索し、世代のMAXを取得します。
// お客様TBL検索条件項目を設定します。
Object[] paramList = new Object[2];
paramList[0] = sysid; // SYSID
paramList[1] = super.opeDate; // バッチ運用日
// お客様情報検索処理を実行します。
executeCK_T_CUST_KK_SELECT_063(paramList);
// 検索結果を取得します。
JBSbatCommonDBInterface outDbMap = db_CK_T_CUST.selectNext();
return outDbMap;
}
/**
* 出力ファイル（設備切替ＤＭ送付情報）のデータを設定します。
*
* 処理フロー
*
* 1.データ設定処理。 **
* @param outDataMap 出力ファイルデータMAP * @param svc_kei_no サービス契約番号 * @param cust_nm お客様名 * @param outMap049 サービス契約回線内訳TBL検索結果 * @param kojiak_no 工事案件番号 * @throws Exception */ private void setOtf1FileInfo(JBSbatServiceInterfaceMap outDataMap, String svc_kei_no, String cust_nm, JBSbatCommonDBInterface outMap049, String kojiak_no) throws Exception { // サービス契約番号 outDataMap.setString(JBSbatKKIFM591.SVC_KEI_NO, svc_kei_no); // お客様名 outDataMap.setString(JBSbatKKIFM591.CUST_NM, cust_nm); // 回線場所郵便番号 outDataMap.setString(JBSbatKKIFM591.KAISEN_PLACE_PCD, JBSbatStringUtil.Rtrim(outMap049.getString(JBSbatKK_T_SVKEI_KAISEN_UW.KAISEN_PLACE_PCD))); // 回線場所都道府県名 outDataMap.setString(JBSbatKKIFM591.KAISEN_PLACE_STATE_NM, JBSbatStringUtil.Rtrim(outMap049.getString(JBSbatKK_T_SVKEI_KAISEN_UW.KAISEN_PLACE_STATE_NM))); // 回線場所市区町村名 outDataMap.setString(JBSbatKKIFM591.KAISEN_PLACE_CITY_NM, JBSbatStringUtil.Rtrim(outMap049.getString(JBSbatKK_T_SVKEI_KAISEN_UW.KAISEN_PLACE_CITY_NM))); // 回線場所大字通称名 outDataMap.setString(JBSbatKKIFM591.KAISEN_PLACE_OAZTSU_NM, JBSbatStringUtil.Rtrim(outMap049.getString(JBSbatKK_T_SVKEI_KAISEN_UW.KAISEN_PLACE_OAZTSU_NM))); // 回線場所字丁目名 outDataMap.setString(JBSbatKKIFM591.KAISEN_PLACE_AZCHO_NM, JBSbatStringUtil.Rtrim(outMap049.getString(JBSbatKK_T_SVKEI_KAISEN_UW.KAISEN_PLACE_AZCHO_NM))); // 回線場所番地号 outDataMap.setString(JBSbatKKIFM591.KAISEN_PLACE_BNCHIGO, JBSbatStringUtil.Rtrim(outMap049.getString(JBSbatKK_T_SVKEI_KAISEN_UW.KAISEN_PLACE_BNCHIGO))); // 回線場所住所補記・建物名 outDataMap.setString(JBSbatKKIFM591.KAISEN_PLACE_ADRTTM, JBSbatStringUtil.Rtrim(outMap049.getString(JBSbatKK_T_SVKEI_KAISEN_UW.KAISEN_PLACE_ADRTTM))); // 回線場所住所補記・部屋番号 outDataMap.setString(JBSbatKKIFM591.KAISEN_PLACE_ADRRM, JBSbatStringUtil.Rtrim(outMap049.getString(JBSbatKK_T_SVKEI_KAISEN_UW.KAISEN_PLACE_ADRRM))); /* ++++++++++ v10.00.00 追加開始 ++++++++++ */ // 工事案件番号 outDataMap.setString(JBSbatKKIFM591.KOJIAK_NO, kojiak_no); /* ++++++++++ v10.00.00 追加終了 ++++++++++ */ } }