/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom * ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatKKSvKeiUwSaiInfCht * ソースファイル名 ：JBSbatKKSvKeiUwSaiInfCht.java * 作成者 ：富士通　 * 作成日 ：2011年06月06日 *＜機能概要＞ *　サービス契約内訳差分情報抽出部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v1.00.00 2011/06/06 富士通 新規作成 * v3.00.00 2012/06/28 FJ)北守 【IT2-2012-0000711】サービス開始基準対応（一時金） * v7.00.00 2014/03/05 AS)安井 【OM-2014-0000927】 * v7.00.01 2014/03/15 FJ)民岡 【OM-2014-0001100】 *********************************************************************/ package eo.business.service; import java.util.ArrayList; import eo.business.common.JBSbatBusinessService; import eo.business.common.JBSbatKKConst; import eo.business.common.JBSbatKKPrcIfCommon; import eo.business.common.JKKBatConst; import eo.business.common.JKKbatSaiInfChtCommon; import eo.business.util.file.JBSbatKKIFM019; import eo.business.util.file.JBSbatKKIFM023; import eo.business.util.table.JBSbatKK_T_SVC_KEI; import eo.business.util.table.JBSbatKK_T_SVC_KEI_UCWK; import eo.business.util.table.JBSbatKK_T_SVKEIUW_EOH_TEL; import eo.framework.db.JBSbatSQLAccess; import eo.framework.item.JBSbatCommonDBInterface; import eo.framework.item.JBSbatCommonItem; import eo.framework.item.JBSbatOutputItem; import eo.framework.item.JBSbatServiceInterfaceMap; import eo.framework.util.JBSbatDateUtil; /** * (クラスの機能概要)

*
* @author 富士通 */ public class JBSbatKKSvKeiUwSaiInfCht extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** テーブル(サービス契約内訳)*/ private static final String D_TBL_NAME_KK_T_SVC_KEI_UCWK = "KK_T_SVC_KEI_UCWK"; /** SQL定義キー(KK_SELECT_004)*/ private static final String KK_T_SVC_KEI_UCWK_KK_SELECT_004 = "KK_SELECT_004"; /** SQL定義キー(KK_SELECT_095)*/ private static final String KK_T_SVC_KEI_UCWK_KK_SELECT_095 = "KK_SELECT_095"; /** SQL定義キー(KK_SELECT_074)*/ private static final String KK_T_SVC_KEI_UCWK_KK_SELECT_074 = "KK_SELECT_074"; // ++++++++++ ★性能改善対応 追加開始 ++++++++++ // /** SQL定義キー(KK_SELECT_039)*/ private static final String KK_T_SVC_KEI_UCWK_KK_SELECT_039 = "KK_SELECT_039"; /** サービス契約.料金プランコード */ private String SVC_PPLAN_CD = "SVC_PPLAN_CD"; /** 契約数 */ private static final int KEI_CNT = 1; private JBSbatKKPrcIfCommon prcIfCommon = null; // ++++++++++ ★性能改善対応 追加終了 ++++++++++ // /** テーブルアクセスクラス(サービス契約内訳)*/ private JBSbatSQLAccess db_KK_T_SVC_KEI_UCWK = null; /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /** 運用月開始日保持の為の変数 */ private String strSta = null; /** 運用月終了日保持の為の変数 */ private String strEnd = null; /** バッチ運用日保持の為の変数 */ private String strDate = null; /** フリー項目[処理月区分] */ private String free = null; /** 前回使用のサービス契約番号 */ private String svcKeiNo = ""; /** 異動タイミングチェックレコード退避リスト(DBカラム名) */ ArrayList> WkIdoTmgdbcolNm = null; /** 異動タイミングチェックレコード退避リスト(出力ファイル項目名) */ ArrayList> WkIdoTmgOutfilecolNm = null; /** 異動タイミングチェックレコード退避リスト(DB実値) */ ArrayList> WkIdoTmgdbValue = null; // ++++++++++ 性能改善対応 追加開始 ++++++++++ // /** 差分抽出共通クラス */ private JKKbatSaiInfChtCommon saiInfChtCmn = null; // ++++++++++ 性能改善対応 追加終了 ++++++++++ // /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_KK_T_SVC_KEI_UCWK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI_UCWK); /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ // 運用日付取得 strDate = commonItem.getOpeDate(); String ym = strDate.substring(0, 6); // フリー項目[処理月区分] free = commonItem.getFreeItem(); // 抽出対象期間を算出 // 運用日付から当月の月初、月末、翌月月初を算出 strSta = ym + "01"; strEnd = ym + JBSbatDateUtil.getEndOfMonth(ym); // 処理対象が[前月]の場合、前月分の値に編集 if(JBSbatKKConst.TRAN_TRGT_MON_BF.equals(free)) { strSta = JBSbatDateUtil.adjustMonth(strSta, -1); strEnd = JBSbatDateUtil.adjustMonth(strEnd, -1); } // ++++++++++ 性能改善対応 追加開始 ++++++++++ // // 差分抽出共通クラスを生成 saiInfChtCmn = new JKKbatSaiInfChtCommon(commonItem); // ++++++++++ 性能改善対応 追加終了 ++++++++++ // // ++++++++++ ★性能改善対応 追加開始 ++++++++++ // // ++++++++++ ★TG1-2013-0000635対応 変更開始 ++++++++++ // // 処理区分が従量の場合 //if (JBSbatKKConst.TRAN_TRGT_JURYO.equals(free)) // 処理区分が従量または開始済の場合 if (JBSbatKKConst.TRAN_TRGT_JURYO.equals(free) || JBSbatKKConst.TRAN_TRGT_KAISHI.equals(free)) // ++++++++++ ★TG1-2013-0000635対応 変更終了 ++++++++++ // { // 共通クラスインスタンス生成 prcIfCommon = new JBSbatKKPrcIfCommon(commonItem); } //▼OM-2014-0001100▼ // //▼OM-2014-0000927▼ // // 処理区分が従量の場合 // if (JBSbatKKConst.TRAN_TRGT_JURYO.equals(free)) // { // // 共通クラスインスタンス設定変更 // prcIfCommon.setJuryoUcwkFlg(true); // } // //▲OM-2014-0000927▲ //▲OM-2014-0001100▲ // ++++++++++ ★性能改善対応 追加終了 ++++++++++ // /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @param inMap　入力電文 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ // 抽出契約区分取得 String chshtKeiDiv = inMap.getString(JBSbatKKIFM023.CHSHT_KEI_DIV); //抽出契約区分の判定 if(!(JBSbatKKConst.CHSHT_KEI_DIV_11.equals(chshtKeiDiv)) && !(JBSbatKKConst.CHSHT_KEI_DIV_10.equals(chshtKeiDiv))) { //サービス契約内訳またはサービス契約以外が入っている場合はエラー throw new Exception(); } // 前回と同じサービス契約番号なら処理しない if (svcKeiNo.equals(inMap.getString(JBSbatKKIFM023.SVC_KEI_NO))) { return null; } svcKeiNo = inMap.getString(JBSbatKKIFM023.SVC_KEI_NO); // フリー項目[処理区分]が[キャンセル]の場合には個別SQLを発行 if(JBSbatKKConst.TRAN_TRGT_CANCEL.equals(free)) { // サービス契約情報内訳情報取得_SQLKEY(KK_SELECT_074) executeKK_T_SVC_KEI_UCWK_KK_SELECT_074(getSvcKeiUw_S074Param(inMap)); // ++++++++++ ★性能改善対応 変更開始 ++++++++++ // // フリー項目[処理区分]が[従量分]の場合には個別SQLを発行 } else if (JBSbatKKConst.TRAN_TRGT_JURYO.equals(free)) { // サービス契約情報取得_SQLKEY(KK_SELECT_039) executeKK_T_SVC_KEI_UCWK_KK_SELECT_039(getSvcKei_S039Param(inMap)); // ++++++++++ ★性能改善対応 変更終了 ++++++++++ // // フリー項目[処理区分]が[開始済]の場合には個別SQLを発行 } else if (JBSbatKKConst.TRAN_TRGT_KAISHI.equals(free)) { // サービス契約情報取得_SQLKEY(KK_SELECT_095) executeKK_T_SVC_KEI_UCWK_KK_SELECT_095(getSvcKeiUw_S095Param(inMap)); } else { // サービス契約情報内訳情報取得_SQLKEY(KK_SELECT_004) executeKK_T_SVC_KEI_UCWK_KK_SELECT_004(getSvcKeiUw_S004Param(inMap)); } // 抽出結果取得 // ++++++++++ 性能改善対応 変更開始 ++++++++++ // // JBSbatCommonDBInterface svInfo = new JBSbatCommonDBInterface(); // svInfo = db_KK_T_SVC_KEI_UCWK.selectNext(); JBSbatCommonDBInterface svInfo = db_KK_T_SVC_KEI_UCWK.selectNext(); // ++++++++++ 性能改善対応 変更終了 ++++++++++ // // 取得件数が0件の場合には後続処理不要 if(svInfo == null) { return null; } // 出力情報格納領域 JBSbatOutputItem outputBean = new JBSbatOutputItem(); // ++++++++++ ★性能改善対応 追加開始 ++++++++++ // // 出力情報Map JBSbatServiceInterfaceMap outMap = null; // フリー項目[処理区分]が[従量分]の場合には個別出力処理を実行 if (JBSbatKKConst.TRAN_TRGT_JURYO.equals(free)) { while(svInfo != null) { // 料金計算用サービス契約情報レコードの作成 */ outMap = setOutMap(svInfo); // ファイル編集にて基本情報のサービス契約番号が取得できなかった場合 if (outMap == null) { // 出力領域にnullを返却する return null; } // 電話サービス従量キー(電話番号) String telNo = outMap.getString(JBSbatKKIFM019.TELNO); if(null == telNo || 0 == telNo.length()) { // 処理なし } else { // 出力フラグをON outMap.setOutFlg(true); // 出力データを格納 outputBean.addOutMapList(outMap); } // 次レコード取得 svInfo = db_KK_T_SVC_KEI_UCWK.selectNext(); } return outputBean; } // ++++++++++ ★性能改善対応 追加終了 ++++++++++ // // ++++++++++ ★TG1-2013-0000635対応 変更開始 ++++++++++ // // フリー項目[処理区分]が[開始済]の場合には個別出力処理を実行 if (JBSbatKKConst.TRAN_TRGT_KAISHI.equals(free)) { while(svInfo != null) { // 料金計算用サービス契約情報レコードの作成 */ outMap = setOutMap(svInfo); // ファイル編集にて基本情報のサービス契約番号が取得できなかった場合 if (outMap == null) { // 出力領域にnullを返却する return null; } // 出力フラグをON outMap.setOutFlg(true); // 出力データを格納 outputBean.addOutMapList(outMap); // 次レコード取得 svInfo = db_KK_T_SVC_KEI_UCWK.selectNext(); } return outputBean; } // ++++++++++ ★TG1-2013-0000635対応 変更終了 ++++++++++ // // ++++++++++ 性能改善対応 変更開始 ++++++++++ // // // 差分情報抽出共通クラスインスタンス生成 // // ++++++++++ v3.00.00 変更開始 ++++++++++ // //// JKKbatSaiInfChtCommon saiInfChtCmn = new JKKbatSaiInfChtCommon(); // JKKbatSaiInfChtCommon saiInfChtCmn = new JKKbatSaiInfChtCommon(commonItem); // // ++++++++++ v3.00.00 変更終了 ++++++++++ // saiInfChtCmn.initialize(); // ++++++++++ 性能改善対応 変更終了 ++++++++++ // // バッチ運用月月初設定 saiInfChtCmn.setStrSta(strSta); // 抽出契約区分設定 saiInfChtCmn.setChshtKeiDiv(chshtKeiDiv); // 初回レコードフラグ boolean frstRecFlg = true; // 異動タイミングチェックリスト初期化 initialize(); // 抽出結果全件について出力情報を編集 while(svInfo != null) { // 異動タイミングチェック(翌月分の解約回復は連携対象外) if(chkIdoTmg(svInfo)) { // チェック結果にて出力対象レコードが存在する場合 for(int i=0; i < WkIdoTmgdbcolNm.size(); i++) { if(frstRecFlg) { // 集約情報作成(初回レコード) saiInfChtCmn.makeSykInf(WkIdoTmgdbcolNm.get(i), WkIdoTmgOutfilecolNm.get(i), WkIdoTmgdbValue.get(i), true); frstRecFlg = false; } else { // 集約情報作成(N件目レコード) saiInfChtCmn.makeSykInf(WkIdoTmgdbcolNm.get(i), WkIdoTmgOutfilecolNm.get(i), WkIdoTmgdbValue.get(i), false); } } // 異動タイミングチェックリスト初期化 initialize(); } // 次レコード取得 svInfo = db_KK_T_SVC_KEI_UCWK.selectNext(); } // 編集情報作成 saiInfChtCmn.makeEditInf(); // 出力情報編集 saiInfChtCmn.editSaiInf(outputBean); return outputBean; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_KK_T_SVC_KEI_UCWK.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ // ++++++++++ 性能改善対応 追加開始 ++++++++++ // // 差分抽出共通クラスをクローズします。 saiInfChtCmn.close(); // ++++++++++ 性能改善対応 追加終了 ++++++++++ // // ++++++++++ ★性能改善対応 追加開始 ++++++++++ // // ++++++++++ ★TG1-2013-0000635対応 変更開始 ++++++++++ // // 処理区分が従量の場合 //if (JBSbatKKConst.TRAN_TRGT_JURYO.equals(free)) // 処理区分が従量または開始済の場合 if (JBSbatKKConst.TRAN_TRGT_JURYO.equals(free) || JBSbatKKConst.TRAN_TRGT_KAISHI.equals(free)) // ++++++++++ ★TG1-2013-0000635対応 変更終了 ++++++++++ // { // 共通クラスクローズ prcIfCommon.close(); } // ++++++++++ ★性能改善対応 追加終了 ++++++++++ // } /**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/ /** * SQLKEY(KK_SELECT_004)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数でバイント変数を設定します。

	 *
	 * 2.DBアクセスを実行します。

	 * 
	 * 3.メソッドの呼び出し方です。

	 *		引数:
	 *		@param:順にバイント変数の値を@param配列に入れます。バイント変数は以下に説明します。
	 * 			予約適用コード(適用済)
	 * 			運用日
	 *			サービス契約内訳番号
	 *			運用日
	 *			予約適用コード(適用済)
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_SVC_KEI_UCWK_KK_SELECT_004(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); paramList.setValue(param[3].toString()); paramList.setValue(param[4].toString()); // DBアクセスを実行します db_KK_T_SVC_KEI_UCWK.selectBySqlDefine(paramList, KK_T_SVC_KEI_UCWK_KK_SELECT_004); } // ++++++++++ ★性能改善対応 追加開始 ++++++++++ // /** * SQLKEY(KK_SELECT_039)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数でバイント変数を設定します。

	 *
	 * 2.DBアクセスを実行します。

	 * 
	 * 3.メソッドの呼び出し方です。

	 *		引数:
	 *		@param:順にバイント変数の値を@param配列に入れます。バイント変数は以下に説明します。
	 *			運用日
	 *			運用日
	 *			運用日
	 *			サービス契約内訳番号
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_SVC_KEI_UCWK_KK_SELECT_039(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); paramList.setValue(param[3].toString()); // DBアクセスを実行します db_KK_T_SVC_KEI_UCWK.selectBySqlDefine(paramList, KK_T_SVC_KEI_UCWK_KK_SELECT_039); } // ++++++++++ ★性能改善対応 追加終了 ++++++++++ // /** * SQLKEY(KK_SELECT_095)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数でバイント変数を設定します。

	 *
	 * 2.DBアクセスを実行します。

	 * 
	 * 3.メソッドの呼び出し方です。

	 *		引数:
	 *		@param:順にバイント変数の値を@param配列に入れます。バイント変数は以下に説明します。
	 *		 	バッチ運用日
	 *		 	バッチ運用日
	 *		 	サービス契約内訳番号
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_SVC_KEI_UCWK_KK_SELECT_095(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_SVC_KEI_UCWK.selectBySqlDefine(paramList, KK_T_SVC_KEI_UCWK_KK_SELECT_095); } /** * SQLKEY(KK_SELECT_074)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数でバイント変数を設定します。

	 *
	 * 2.DBアクセスを実行します。

	 * 
	 * 3.メソッドの呼び出し方です。

	 *		引数:
	 *		@param:順にバイント変数の値を@param配列に入れます。バイント変数は以下に説明します。
	 *		 	予約適用コード(予約適用済)
	 *		 	予約適用コード(予約適用済)
	 *		 	サービス契約内訳番号
	 *		 	バッチ運用日
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_SVC_KEI_UCWK_KK_SELECT_074(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); paramList.setValue(param[3].toString()); // DBアクセスを実行します db_KK_T_SVC_KEI_UCWK.selectBySqlDefine(paramList, KK_T_SVC_KEI_UCWK_KK_SELECT_074); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** * SQLKEY(KK_SELECT_004)でDBアクセスを実行する際に必要なパラメータを設定します。
*

* 処理フロー
* 

	 * 1.パラメータ設定処理。
	 *
*

* @param inMap 入力電文 * @return param SQLKEY(KK_SELECT_004)でDBアクセスを実行する際に必要なパラメータ * @throws Exception */ private Object[] getSvcKeiUw_S004Param(JBSbatServiceInterfaceMap inMap) throws Exception { Object[] ret_Param = { JBSbatKKConst.APLY_STAT_RENKEI, strDate, inMap.getString(JBSbatKKIFM023.SVC_KEI_NO), strDate, JBSbatKKConst.APLY_STAT_RENKEI }; return ret_Param; } // ++++++++++ ★性能改善対応 追加開始 ++++++++++ // /** * SQLKEY(KK_SELECT_039)でDBアクセスを実行する際に必要なパラメータを設定します。
*

* 処理フロー
* 

	 * 1.パラメータ設定処理。
	 *
*

* @param inMap 入力電文 * @return param SQLKEY(KK_SELECT_039)でDBアクセスを実行する際に必要なパラメータ * @throws Exception */ private Object[] getSvcKei_S039Param(JBSbatServiceInterfaceMap inMap) throws Exception { Object[] ret_Param = { strDate, strDate, strDate, inMap.getString(JBSbatKKIFM023.SVC_KEI_NO) }; return ret_Param; } // ++++++++++ ★性能改善対応 追加終了 ++++++++++ // /** * SQLKEY(KK_SELECT_095)でDBアクセスを実行する際に必要なパラメータを設定します。
*

* 処理フロー
* 

	 * 1.パラメータ設定処理。
	 *
*

* @param inMap 入力電文 * @return param SQLKEY(KK_SELECT_095)でDBアクセスを実行する際に必要なパラメータ * @throws Exception */ private Object[] getSvcKeiUw_S095Param(JBSbatServiceInterfaceMap inMap) throws Exception { Object[] ret_Param = { strDate, strDate, inMap.getString(JBSbatKKIFM023.SVC_KEI_NO), }; return ret_Param; } /** * SQLKEY(KK_SELECT_074)でDBアクセスを実行する際に必要なパラメータを設定します。
*

* 処理フロー
* 

	 * 1.パラメータ設定処理。
	 *
*

* @param inMap 入力電文 * @return param SQLKEY(KK_SELECT_074)でDBアクセスを実行する際に必要なパラメータ * @throws Exception */ private Object[] getSvcKeiUw_S074Param(JBSbatServiceInterfaceMap inMap) throws Exception { Object[] ret_Param = { JBSbatKKConst.APLY_STAT_RENKEI, JBSbatKKConst.APLY_STAT_RENKEI, inMap.getString(JBSbatKKIFM023.SVC_KEI_NO), strDate }; return ret_Param; } /** * 比較・出力対象情報作成処理 * @param svInfo * @param ctlFlg * @return * @throws Exception */ private ArrayList getKeyList(JBSbatCommonDBInterface svInfo, int wrkDiv) throws Exception { ArrayList aryList = new ArrayList(); // 集約キー(ListA)ArrayList(String配列:[0]DBカラム名 [1]出力ファイル項目名 [2]DB実値) if(wrkDiv == 0) { // 出力情報定義ArrayList(String配列:[0]DBカラム名 [1]出力ファイル項目名 [2]DB実値) aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI.SEIRI_NO, JBSbatKKIFM019.SEIRI_NO, svInfo)); // 整理番号 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI.SVC_KEI_NO, JBSbatKKIFM019.SVC_KEI_NO, svInfo)); // サービス契約番号 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI.SVC_CD, JBSbatKKIFM019.SVC_CD, svInfo)); // サービスコード aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI.PRC_GRP_CD, JBSbatKKIFM019.PRC_GRP_CD, svInfo)); // 料金グループコード aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI.PCRS_CD, JBSbatKKIFM019.PCRS_CD, svInfo)); // 料金コースコード aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.PPLAN_CD, JBSbatKKIFM019.PPLAN_CD, svInfo)); // 料金プランコード aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_KEI_UCWK_NO, JBSbatKKIFM019.SVC_KEI_UCWK_NO, svInfo)); // サービス契約内訳番号 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.TK_HOSHIKI_KEI_NO, JBSbatKKIFM019.TK_HOSHIKI_KEI_NO, svInfo)); // 提供方式契約番号 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_STA_YMD, JBSbatKKIFM019.SVC_STAYMD, svInfo)); // サービス開始年月日 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_CHRG_STAYMD, JBSbatKKIFM019.SVC_CHRG_STAYMD, svInfo)); // サービス課金開始年月日 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.PLAN_CHRG_STAYMD, JBSbatKKIFM019.PLAN_STAYMD, svInfo)); // プラン課金開始年月日 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.IDO_DIV, JBSbatKKIFM019.IDO_DIV, svInfo)); // 異動区分 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.PLAN_END_SBT_CD, JBSbatKKIFM019.PLAN_END_SBT_CD, svInfo)); // プラン終了種別コード aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.PLAN_CHRG_ENDYMD, JBSbatKKIFM019.PLAN_ENDYMD, svInfo)); // プラン課金終了年月日 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_CANCEL_YMD, JBSbatKKIFM019.SVC_CANCEL_YMD, svInfo)); // サービスキャンセル年月日 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_ENDYMD, JBSbatKKIFM019.SVC_ENDYMD, svInfo)); // サービス終了年月日 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_CHRG_ENDYMD, JBSbatKKIFM019.SVC_CHRG_ENDYMD, svInfo)); // サービス課金終了年月日 } // 解約系項目群(ListB)ArrayList(String配列:[0]DBカラム名 [1]出力ファイル項目名 [2]DB実値) else if(wrkDiv == 1) { aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_DSL_YMD, JBSbatKKIFM019.SVC_DSL_YMD, svInfo)); // サービス解約年月日 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.PNLTY_HASSEI_CD, JBSbatKKIFM019.PNLTY_HASSEI_CD, svInfo)); // 違約金発生コード aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_DLRE_CD, JBSbatKKIFM019.SVC_DLRE_CD, svInfo)); // サービス解約理由 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.KAIHK_YMD, JBSbatKKIFM019.KAIHK_YMD, svInfo)); // サービス回復年月日 } // 休止系項目群(ListB)ArrayList(String配列:[0]DBカラム名 [1]出力ファイル項目名 [2]DB実値) else if(wrkDiv == 2) { aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.PAUSE_STP_CD, JBSbatKKIFM019.PAUSE_STP_CD, svInfo)); // 休止中断コード aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_PAUSE_YMD, JBSbatKKIFM019.SVC_PAUSE_YMD, svInfo)); // サービス休止年月日 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_PAUSE_CHRG_STA_YMD, JBSbatKKIFM019.SVC_PAUSE_PRC_TSTAYMD, svInfo)); // サービス休止料金適用開始年月日 aryList.add(setStrctVal(JBSbatKK_T_SVC_KEI_UCWK.SVC_PAUSE_RLS_YMD, JBSbatKKIFM019.SVC_PAUSE_RLS_YMD, svInfo)); // サービス休止解除年月日 } return aryList; } // ++++++++++ ★性能改善対応 追加終了 ++++++++++ // /** *

メソッド名 ：ファイル編集 *
メソッド説明 ：1.ファイル編集対象項目を取得します。 * 2.取得した項目を元にファイル編集を行います。 * @param svInfo データ取得情報Map * @return outMap 出力Map * @throws Exception 業務サービス内で発生した例外全般。 */ private JBSbatServiceInterfaceMap setOutMap(JBSbatCommonDBInterface svInfo) throws Exception { // 出力情報を設定するMap JBSbatServiceInterfaceMap outmap = new JBSbatServiceInterfaceMap(); outmap.setString(JBSbatKKIFM019.CHSHT_KEI_DIV, JKKBatConst.CHSHT_KEI_DIV_11); //抽出契約区分 outmap.setString(JBSbatKKIFM019.SVC_KEI_NO, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_KEI_NO)); //サービス契約番号 outmap.setString(JBSbatKKIFM019.SVC_CD, svInfo.getString(JBSbatKK_T_SVC_KEI.SVC_CD)); //サービスコード outmap.setString(JBSbatKKIFM019.PRC_GRP_CD, svInfo.getString(JBSbatKK_T_SVC_KEI.PRC_GRP_CD)); //料金グループコード outmap.setString(JBSbatKKIFM019.PCRS_CD, svInfo.getString(JBSbatKK_T_SVC_KEI.PCRS_CD)); //料金コースコード outmap.setString(JBSbatKKIFM019.PPLAN_CD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.PPLAN_CD)); //料金プランコード outmap.setString(JBSbatKKIFM019.SVC_KEI_UCWK_NO, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_KEI_UCWK_NO)); //サービス契約内訳番号 outmap.setString(JBSbatKKIFM019.TK_HOSHIKI_KEI_NO, svInfo.getString(JBSbatKK_T_SVC_KEI.TK_HOSHIKI_KEI_NO)); //提供方式契約番号 outmap.setString(JBSbatKKIFM019.SVC_STAYMD, svInfo.getString(JBSbatKK_T_SVC_KEI.SVC_STA_YMD)); //サービス開始年月日 outmap.setString(JBSbatKKIFM019.SVC_CHRG_STAYMD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_CHRG_STAYMD)); //サービス課金開始年月日 outmap.setString(JBSbatKKIFM019.PLAN_STAYMD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.PLAN_CHRG_STAYMD)); //プラン課金開始年月日 outmap.setString(JBSbatKKIFM019.PLAN_ENDYMD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.PLAN_CHRG_ENDYMD)); //プラン課金終了年月日 outmap.setString(JBSbatKKIFM019.SVC_DSL_YMD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_DSL_YMD)); //サービス解約年月日 outmap.setString(JBSbatKKIFM019.SVC_DLRE_CD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_DLRE_CD)); //サービス解約理由コード outmap.setString(JBSbatKKIFM019.PNLTY_HASSEI_CD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.PNLTY_HASSEI_CD)); //違約金発生コード outmap.setString(JBSbatKKIFM019.PLAN_END_SBT_CD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.PLAN_END_SBT_CD)); //プラン終了種別コード outmap.setString(JBSbatKKIFM019.KAIHK_YMD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.KAIHK_YMD)); //回復年月日 outmap.setString(JBSbatKKIFM019.SVC_ENDYMD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_ENDYMD)); //サービス終了年月日 outmap.setString(JBSbatKKIFM019.SVC_CHRG_ENDYMD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_CHRG_ENDYMD)); //サービス課金終了年月日 outmap.setString(JBSbatKKIFM019.IDO_DIV, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.IDO_DIV)); //異動区分 outmap.setString(JBSbatKKIFM019.TELNO, svInfo.getString(JBSbatKK_T_SVKEIUW_EOH_TEL.TELNO)); //電話番号 outmap.setBigDecimal(JBSbatKKIFM019.KEI_CNT, KEI_CNT); //契約数 outmap.setString(JBSbatKKIFM019.SEIRI_NO, svInfo.getString(JBSbatKK_T_SVC_KEI.SEIRI_NO)); //整理番号 // 休止・中断情報(中断レコードの場合には設定不要) if(!JBSbatKKConst.PAUSE_STP_CD_STP.equals(svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.PAUSE_STP_CD))) { outmap.setString(JBSbatKKIFM019.PAUSE_STP_CD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.PAUSE_STP_CD)); //休止中断コード outmap.setString(JBSbatKKIFM019.SVC_PAUSE_YMD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_PAUSE_YMD)); //サービス休止年月日 outmap.setString(JBSbatKKIFM019.SVC_PAUSE_PRC_TSTAYMD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_PAUSE_CHRG_STA_YMD)); //サービス休止課金開始年月日 outmap.setString(JBSbatKKIFM019.SVC_PAUSE_RLS_YMD, svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_PAUSE_RLS_YMD)); //サービス休止解除年月日 } // [従量分]または[開始基準]の処理の場合、付与する基本契約情報を別途特定(プラン変更時対応) if(JBSbatKKConst.TRAN_TRGT_KAISHI.equals(free) || JBSbatKKConst.TRAN_TRGT_JURYO.equals(free)) { // 適用対象となる基本契約の情報を取得(プラン変更時対応) JBSbatCommonDBInterface svcKeiInf = prcIfCommon.getSvcKeiInf(outmap.getString(JBSbatKKIFM019.SVC_KEI_NO)); // 基本契約の契約番号が取得できなかった場合 if(svcKeiInf == null) { // 出力領域にnullを設定し返却 return null; } outmap.setString(JBSbatKKIFM019.SVC_CD, svcKeiInf.getString(JBSbatKK_T_SVC_KEI.SVC_CD)); //サービスコード outmap.setString(JBSbatKKIFM019.PRC_GRP_CD, svcKeiInf.getString(JBSbatKK_T_SVC_KEI.PRC_GRP_CD)); //料金グループコード outmap.setString(JBSbatKKIFM019.PCRS_CD, svcKeiInf.getString(JBSbatKK_T_SVC_KEI.PCRS_CD)); //料金コースコード outmap.setString(JBSbatKKIFM019.SEIRI_NO, svcKeiInf.getString(JBSbatKK_T_SVC_KEI.SEIRI_NO)); //整理番号 // [従量分]の場合には親の適用対象料金プランコードを設定(電話のコース・プランは同期をとる必要あり) if(JBSbatKKConst.TRAN_TRGT_JURYO.equals(free)) { outmap.setString(JBSbatKKIFM019.PPLAN_CD, svcKeiInf.getString(JBSbatKK_T_SVC_KEI.PPLAN_CD)); //料金プランコード } } return outmap ; } // ++++++++++ ★性能改善対応 追加終了 ++++++++++ // /** * 翌月異動情報のオミット判定をします。 * @param svInfo データ取得情報Map * @return outMap 判定結果(true:有効レコード/false:不要レコード) * @throws Exception 業務サービス内で発生した例外全般。 */ private boolean chkIdoTmg(JBSbatCommonDBInterface svInfo) throws Exception { boolean rtnFlg = false; // 編集前情報取得(DBカラム名) WkIdoTmgdbcolNm.add(getKeyList(svInfo,0)); // 編集前情報取得領域(出力ファイル項目名) WkIdoTmgOutfilecolNm.add(getKeyList(svInfo,1)); // 編集前情報取得領域(DB実値) WkIdoTmgdbValue.add(getKeyList(svInfo,2)); // 回復年月日 String kihkYmd = svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.KAIHK_YMD); // 解約年月日 String dslYmd = svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.SVC_DSL_YMD); // 課金終了年月日 String chrgEndYmd = svInfo.getString(JBSbatKK_T_SVC_KEI_UCWK.PLAN_CHRG_ENDYMD); // 解約年月日が設定されている場合 if(null != dslYmd && 0 != dslYmd.length()) { // 課金終了日が月末以前だった場合 if(chrgEndYmd.compareTo(strEnd) <= 0) { rtnFlg = true; } else { // 異動タイミングチェックリスト初期化 initialize(); } // 回復年月日が未設定の場合 } else if (!(null != kihkYmd && 0 != kihkYmd.length())) { rtnFlg = true; } return rtnFlg; } /** * 各変数の初期化を行います。 */ public void initialize() { // ネットレコード退避リスト(DBカラム名) WkIdoTmgdbcolNm = new ArrayList>(); // ネットレコード退避リスト(出力ファイル項目名) WkIdoTmgOutfilecolNm = new ArrayList>(); // ネットレコード退避リスト(DB実値) WkIdoTmgdbValue = new ArrayList>(); } /** * String型配列に値を設定 * [0]：DBカラム名 * [1]：出力ファイル項目名 * [2]：[0]のカラムのDB値 * @param cstName * @param outName * @param svInfo * @return * @throws Exception */ private String[] setStrctVal(String cstName, String outName, JBSbatCommonDBInterface svInfo) throws Exception { String[] strctStr = new String[3]; strctStr[0] = cstName; strctStr[1] = outName; strctStr[2] = svInfo.getString(cstName); return strctStr; } }