/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom * ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatKKWribSvTgKeiSaiInfEdit * ソースファイル名 ：JBSbatKKWribSvTgKeiSaiInfEdit.java * 作成者 ：富士通　 * 作成日 ：2011年06月20日 *＜機能概要＞ *　割引サービス対象契約差分情報抽出部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v1.00.00 2011/06/20 富士通 新規作成 * v4.00.00 2013/04/21 FJ)上田 【TAI-2012-0000142】設定階層識別コード想定外の場合オミット * v4.00.01 2013/04/21 FJ)上田 【ST2-2013-0001747】解約および回復レコードの判定変更 * v6.00.00 2013/12/11 AS)安井 【OM-2013-0004764】 * v6.00.01 2014/01/06 AS)安井 【OM-2013-0005081】休止中セット割対応 * v7.00.00 2013/12/27 FJ)上田 【ANK-1578-00-00】多機能ルーター対応 *********************************************************************/ package eo.business.service; import java.util.ArrayList; import java.util.LinkedList; import eo.business.common.JBSbatBusinessService; import eo.business.common.JBSbatKKConst; import eo.business.common.JKKbatSaiInfChtCommon; import eo.business.util.file.JBSbatKKIFM019; import eo.business.util.file.JBSbatKKIFM023; import eo.business.util.table.JBSbatKK_M_WRIB_SVC_TANKA; import eo.business.util.table.JBSbatKK_T_SVC_KEI; import eo.business.util.table.JBSbatKK_T_WRIB_SVC_KEI; import eo.business.util.table.JBSbatKK_T_WRISVC_TG_KEI; 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 JBSbatKKWribSvTgKeiSaiInfEdit extends JBSbatBusinessService { /** 運用月開始日保持の為の変数 */ private String strSta = null; /** 運用月終了日保持の為の変数 */ private String strEnd = null; /** バッチ運用日保持の為の変数 */ private String strDate = null; /** フリー項目[処理月区分] */ private String free = null; /** 割引サービス単価マスタ／料金グループコード */ static String TAN_PRC_GRP = "TAN_PRC_GRP"; /** 割引サービス単価マスタ／料金コースコード */ static String TAN_PCRS = "TAN_PCRS"; /** 割引サービス単価マスタ／料金プランコード */ static String TAN_PPLAN = "TAN_PPLAN"; /** 割引サービス単価マスタ／サービスコード */ static String TAN_SVC = "TAN_SVC"; /** 割引サービス単価マスタ／機器提供サービスコード */ static String TAN_KKTK_SVC = "TAN_KKTK_SVC"; /** 割引サービス単価マスタ／オプションサービスコード */ static String TAN_OP_SVC = "TAN_OP_SVC"; /** 割引サービス単価マスタ／サブオプションサービスコード */ static String TAN_SBOP_SVC = "TAN_SBOP_SVC"; /** 割引サービス単価マスタ／請求オプションサービスコード */ static String TAN_SEIOPSVC = "TAN_SEIOPSVC"; // ++++++++++ v7.00.00 追加開始 ++++++++++ // /** 割引サービス単価マスタ／機器オプションサービスコード */ static String TAN_KKOPSVC = "TAN_KKOPSVC"; // ++++++++++ v7.00.00 追加終了 ++++++++++ // /** 当該契約／料金グループコード */ static String PRC_GRP_CD = "PRC_GRP_CD"; /** 当該契約／料金コースコード */ static String TARGET_PCRS = "TARGET_PCRS"; /** 当該契約／料金プランコード */ static String TARGET_PPLAN = "TARGET_PPLAN"; /** 当該契約／サービスコード */ static String TARGET_SVC = "TARGET_SVC"; /** 当該契約／割引サービス契約.プラン課金終了年月日 */ static String W_PLAN_CHRG_ENDYMD = "W_PLAN_CHRG_ENDYMD"; /** 割引サービス契約内訳_MAX課金終了日 */ static String MAX_UCWK_CHRG_ENDYMD = "MAX_UCWK_CHRG_ENDYMD"; /** 割引サービス契約内訳_課金終了日 */ static String PLAN_CHRG_ENDYMD = "PLAN_CHRG_ENDYMD"; /** 初回レコードフラグ */ boolean frstRecFlg = true; /** 内訳適用終了フラグ */ private boolean uwAplyEndFlg = false; /** 差分抽出共通クラス */ private JKKbatSaiInfChtCommon saiInfChtCmn = null; // ++++++++++ v4.00.01 追加開始 ++++++++++ // /** 異動タイミングチェックレコード退避リスト */ ArrayList WkIdoTmgSvInfo = null; // ++++++++++ v4.00.01 追加終了 ++++++++++ // //▼OM-2013-0005081▼ /** 休止中断コード(00) */ static String PAUSE_STP_CD_00 = "00"; //▲OM-2013-0005081▲ /** 入力情報格納クラス */ private class Results{ private LinkedList mainQueue=new LinkedList(); private LinkedList reserveQueue=new LinkedList(); /** 消費可能な内容が存在するなら内容を返却。 * 存在しない場合はnullを返却する。 */ public JBSbatCommonDBInterface selectNextOrNull(){ return convertFromInterfaceMapOrNull(selectNextInterfaceMapOrNull()); } private JBSbatServiceInterfaceMap selectNextInterfaceMapOrNull(){ return mainQueue.isEmpty()?null:mainQueue.pollFirst(); } private JBSbatCommonDBInterface convertFromInterfaceMapOrNull(JBSbatServiceInterfaceMap inMap){ if(inMap==null){ return null; } JBSbatCommonDBInterface result=new JBSbatCommonDBInterface(); for(Object key:inMap.getMap().keySet()){ String keyString=key.toString(); try { result.setValue(keyString, inMap.getString(keyString)); } catch (Exception e) { return null; } } return result; } /** キューに消費可能な内容が存在するか否かを返却。 * このため、リザーブキューの内容の有無によっては * 結果が左右されない。 */ public boolean hasConsumeResult(){ return !mainQueue.isEmpty(); } /** キューが空か否かを返却。 */ public boolean isEmpty(){ return mainQueue.isEmpty(); } /** リザーブキューの内容を消費可能な内容としてメインキューへ移動。 */ public void moveFromReserve(){ mainQueue.addAll(reserveQueue); reserveQueue.clear(); } /** 入力内容をキュー末尾へ追加。 */ public void enqueue(JBSbatServiceInterfaceMap inMap){ mainQueue.addLast(inMap); } /** 入力内容をリザーブキュー末尾へ追加。 */ public void enqueueToReserve(JBSbatServiceInterfaceMap inMap){ reserveQueue.addLast(inMap); } /** 指定したキー項目によるキーブレイクの有無を返却。 */ public boolean hasKeybreak(JBSbatServiceInterfaceMap inMap,String key){ if(!hasConsumeResult()){ return false; } if(inMap==null){ return true; } String target; try { target = inMap.getString(key); } catch (Exception e) { return true; } if(target==null){ return true; } JBSbatServiceInterfaceMap referenceMap=mainQueue.peekLast(); if(referenceMap==null){ return true; } String reference; try { reference = referenceMap.getString(key); } catch (Exception e) { return true; } return !reference.equals(target); } } private Results results; /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // 運用日付取得 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); // 入力情報格納クラスを生成 this.results=new Results(); /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @param inMap　入力電文 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ super.logPrint.printDebugLog("execute start"); //最終レコードの場合 if(commonItem.isEndRecordFlg()){ //通常の呼び出し JBSbatOutputItem outputBean=execureProcedure(inMap); //残分処理のための呼び出し JBSbatOutputItem outputBeanFixed=execureProcedure(null); //結果の結合 JBSbatOutputItem outputBeanFinalized=concatinateOutputItem(outputBean,outputBeanFixed); return outputBeanFinalized; }else{ JBSbatOutputItem outputBean=execureProcedure(inMap); return outputBean; } /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * @param inMap * @return * @throws Exception */ private JBSbatOutputItem execureProcedure(JBSbatServiceInterfaceMap inMap) throws Exception { //リザーブに内容がある場合キューへ移動 this.results.moveFromReserve(); //入力がありでキューが空の場合[初回もしくは吐出後初回] if(inMap!=null && this.results.isEmpty()){ //無条件でキューイングしてリターン this.results.enqueue(inMap); return null; } //入力がありでキューが有の場合 if(inMap!=null && this.results.hasConsumeResult()){ //キュー末尾とキーブレイクチェック[サービス契約番号について] if(this.results.hasKeybreak(inMap, JBSbatKKIFM023.SVC_KEI_NO)){ //ブレイク有りの場合リザーブキューへキューイングし後続へ this.results.enqueueToReserve(inMap); }else{ //ブレイク無しの場合キューへキューイングしリターン this.results.enqueue(inMap); return null; } } //入力がなしの場合[入力終了] //そのまま後続へ // 出力情報格納領域 JBSbatOutputItem outputBean = new JBSbatOutputItem(); //後続処理 キューが消費可能である限り継続 while(this.results.hasConsumeResult()){ //従来同等のインターフェイスでデータを返却 JBSbatCommonDBInterface svInfo = this.results.selectNextOrNull(); // 抽出結果が０件の場合、後続処理不要 if(svInfo == null) { return null; } else { // 割引サービス単価マスタ突合(無効レコードは出力不要) svInfo = chkTanka(svInfo); if(svInfo == null) { return null; } } // // 出力情報格納領域 // JBSbatOutputItem outputBean = new JBSbatOutputItem(); // 入力情報 String crWrSvTgKeiNo = ""; String crWrSvTanNo = ""; // 退避情報(１件目処理用に入力情報を初期設定) String bfWrSvTgKeiNo = svInfo.getString(JBSbatKK_T_WRISVC_TG_KEI.WRIB_SVC_TRGT_KEI_NO);; String bfWrSvTanNo = svInfo.getString(JBSbatKK_M_WRIB_SVC_TANKA.WRIB_SVC_TANKA_NO); // 初期化 init(); // ++++++++++ v4.00.01 追加開始 ++++++++++ // // 異動タイミングチェックリスト初期化 initialize(); // ++++++++++ v4.00.01 追加終了 ++++++++++ // // 抽出結果全件について出力情報を編集 while(svInfo != null) { // 異動タイミングチェック(翌月分の解約回復は連携対象外) if(chkIdoTmg(svInfo)) { // ++++++++++ v4.00.01 変更開始 ++++++++++ // // チェック結果にて出力対象レコードが存在する場合 for(int i=0; i < WkIdoTmgSvInfo.size(); i++) { /** タイミングチェックレコード格納用リスト */ JBSbatCommonDBInterface WkIdoTmgSvRec = WkIdoTmgSvInfo.get(i); // 入力情報を取得 // crWrSvTgKeiNo = svInfo.getString(JBSbatKK_T_WRISVC_TG_KEI.WRIB_SVC_TRGT_KEI_NO); // crWrSvTanNo = svInfo.getString(JBSbatKK_M_WRIB_SVC_TANKA.WRIB_SVC_TANKA_NO); crWrSvTgKeiNo = WkIdoTmgSvRec.getString(JBSbatKK_T_WRISVC_TG_KEI.WRIB_SVC_TRGT_KEI_NO); crWrSvTanNo = WkIdoTmgSvRec.getString(JBSbatKK_M_WRIB_SVC_TANKA.WRIB_SVC_TANKA_NO); // 割引サービス対象契約番号または割引サービス単価番号に差異がある場合、 // 他の割引サービスの情報に切り替わった場合には蓄積情報を出力した後、各作業領域を初期化 // (割引サービス対象契約のみ、検索条件の契約番号から複数の割引情報が抽出されるため) if(!crWrSvTgKeiNo.equals(bfWrSvTgKeiNo) || !crWrSvTanNo.equals(bfWrSvTanNo)) { // 編集情報作成 saiInfChtCmn.makeEditInf(); // 出力情報編集 saiInfChtCmn.editSaiInf(outputBean); // 初期化 init(); } // 割引サービス内訳適用終了年月日 // String uwChrgEndYmd = svInfo.getString(PLAN_CHRG_ENDYMD); String uwChrgEndYmd = WkIdoTmgSvRec.getString(PLAN_CHRG_ENDYMD); // 割引課金終了年月日 // String wrChrgEndYmd = svInfo.getString(W_PLAN_CHRG_ENDYMD); String wrChrgEndYmd = WkIdoTmgSvRec.getString(W_PLAN_CHRG_ENDYMD); // 課金終了日が未設定の場合には処理不要 if(!isNullBlunk(uwChrgEndYmd) && !isNullBlunk(wrChrgEndYmd)) { // 処理月前月末以前で既に課金終了している内訳に対して適用終了情報を反映 // ※処理月同月に適用終了となる内訳はまだ適用終了扱いにはしない if(strSta.compareTo(uwChrgEndYmd ) > 0) { // 割引サービスの解約にて課金終了 // if(!isNullBlunk(svInfo.getString(JBSbatKK_T_WRIB_SVC_KEI.SVC_DSL_YMD)) && wrChrgEndYmd.compareTo(uwChrgEndYmd) == 0) //▼OM-2013-0004764▼ //if(!isNullBlunk(WkIdoTmgSvRec.getString(JBSbatKK_T_WRIB_SVC_KEI.SVC_DSL_YMD)) && wrChrgEndYmd.compareTo(uwChrgEndYmd) == 0) if(!isNullBlunk(WkIdoTmgSvRec.getString(JBSbatKK_T_WRIB_SVC_KEI.SVC_DSL_YMD)) && wrChrgEndYmd.compareTo(uwChrgEndYmd) == 0 && !uwAplyEndFlg) //▲OM-2013-0004764▲ { // 内訳適用終了フラグはOFF uwAplyEndFlg = false; } // 割引サービスが未解約(＝期間(適用回数)満了による課金終了) // 割引サービスの解約以前に課金終了(＝期間(適用回数)満了による課金終了) // ※割引の解約や適用終了のタイミングで既に内訳が適用終了済の状態(解約時の更新対象外) else { // 内訳適用終了フラグをON(同一内訳の後続レコードは処理不要) uwAplyEndFlg = true; } } } // 当該割引サービスの基本課金終了日設定 ※[20991231]以外の初期値対応(割引固有) // (解約以外の入力情報に設定されている課金終了日にて随時更新) // if(isNullBlunk(svInfo.getString(JBSbatKK_T_WRIB_SVC_KEI.SVC_DSL_YMD))) if(isNullBlunk(WkIdoTmgSvRec.getString(JBSbatKK_T_WRIB_SVC_KEI.SVC_DSL_YMD))) { // if(!isNullBlunk(svInfo.getString(W_PLAN_CHRG_ENDYMD))) if(!isNullBlunk(WkIdoTmgSvRec.getString(W_PLAN_CHRG_ENDYMD))) { // saiInfChtCmn.setWriSvcBaseChrgEndYmd(svInfo.getString(W_PLAN_CHRG_ENDYMD)); saiInfChtCmn.setWriSvcBaseChrgEndYmd(WkIdoTmgSvRec.getString(W_PLAN_CHRG_ENDYMD)); } else { saiInfChtCmn.setWriSvcBaseChrgEndYmd(""); } } if(frstRecFlg) { // 集約情報作成(初回レコード) // saiInfChtCmn.makeSykInf(getKeyList(svInfo, 0, true), getKeyList(svInfo, 1, true), getKeyList(svInfo, 2, true), true); saiInfChtCmn.makeSykInf(getKeyList(WkIdoTmgSvRec, 0, true), getKeyList(WkIdoTmgSvRec, 1, true), getKeyList(WkIdoTmgSvRec, 2, true), true); frstRecFlg = false; } else { // 内訳適用終了フラグがONの場合には処理不要 if(!uwAplyEndFlg) { // 集約情報作成(N件目レコード) // saiInfChtCmn.makeSykInf(getKeyList(svInfo, 0, false), getKeyList(svInfo, 1, false), getKeyList(svInfo, 2, false), false); saiInfChtCmn.makeSykInf(getKeyList(WkIdoTmgSvRec, 0, false), getKeyList(WkIdoTmgSvRec, 1, false), getKeyList(WkIdoTmgSvRec, 2, false), false); } } // 退避情報を更新 bfWrSvTgKeiNo = crWrSvTgKeiNo; bfWrSvTanNo = crWrSvTanNo; } // 異動タイミングチェックリスト初期化 initialize(); // ++++++++++ v4.00.01 変更終了 ++++++++++ // } // 次レコード取得 //従来同等のインターフェイスでデータを返却 svInfo = this.results.selectNextOrNull(); // 割引サービス単価マスタ突合(無効レコードは出力不要) svInfo = chkTanka(svInfo); } // 編集情報作成 saiInfChtCmn.makeEditInf(); // 出力情報編集 saiInfChtCmn.editSaiInf(outputBean); return outputBean; } return null; } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // 差分抽出共通クラスをクローズします。 saiInfChtCmn.close(); /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /** *

メソッド名 ：初期編集 *
メソッド説明 ：1.初期編集を行います。 * @param inMap 入力電文 * @param opInItem 集約情報(編集前) * @param fstRecFlg 初回レコードフラグ * @return opInItem 集約情報(編集後) * @throws Exception 業務サービス内で発生した例外全般。 */ public void init() throws Exception { // 差分情報抽出共通クラス初期化 saiInfChtCmn.initialize(); // バッチ運用月月初設定 saiInfChtCmn.setStrSta(strSta); // 抽出契約区分設定 saiInfChtCmn.setChshtKeiDiv(JBSbatKKConst.CHSHT_KEI_DIV_51); // 内訳適用終了フラグ uwAplyEndFlg = false; // 初回レコードフラグ frstRecFlg = true; // 割引サービスの課金終了基準日 saiInfChtCmn.setWriSvcBaseChrgEndYmd(""); } /** *
メソッド名 ：割引サービス単価マスタデータ突合 *
メソッド説明 ：1.料金コース・料金プランについて、マスタと当該契約の同項目のマッチングを行います。 * 2.合致する場合には、該当するレコードを返却します。 * 3.合致しなかった場合には、NULLを返却します。 * @param svInfo データ取得情報Map * @return svInfo データ取得情報Map * @throws Exception 業務サービス内で発生した例外全般。 * */ private JBSbatCommonDBInterface chkTanka(JBSbatCommonDBInterface svInfo) throws Exception { // 出力要否フラグ boolean outFlg = false; // 割引サービス単価種別コード String tankaSbtCd = ""; // 設定階層識別コード String setteLvCd = ""; // 対象サービスコード String tgSvcCd = ""; //従来同等のインターフェイスでデータを返却 for(;svInfo != null; svInfo = this.results.selectNextOrNull()) { // 割引サービス単価種別コード tankaSbtCd = svInfo.getString(JBSbatKK_M_WRIB_SVC_TANKA.WRIB_SVC_TANKA_SBT_CD); // 設定階層識別コード setteLvCd = svInfo.getString(JBSbatKK_M_WRIB_SVC_TANKA.SETTE_LV_SKCD); // 設定階層識別コードが設定なし(0) if(setteLvCd.equals(JBSbatKKConst.SETTE_SKBT_NONE)) { // 出力対象とする(突合不要) outFlg = true; break; } // 設定階層識別コードが各種サービス(1)の場合 if(setteLvCd.equals(JBSbatKKConst.SETTE_SKBT_SVC)) { // サービス契約 if(tankaSbtCd.equals(JBSbatKKConst.TANKA_SBT_SVC_KEI)) { tgSvcCd = TAN_SVC; } // サービス契約内訳 if(tankaSbtCd.equals(JBSbatKKConst.TANKA_SBT_SVC_KEI_UCWK)) { tgSvcCd = TAN_SVC; } // オプションサービス契約 if(tankaSbtCd.equals(JBSbatKKConst.TANKA_SBT_OP_SVC_KEI)) { tgSvcCd = TAN_OP_SVC; } // 機器提供サービス契約 if(tankaSbtCd.equals(JBSbatKKConst.TANKA_SBT_KKTK_SVC_KEI)) { tgSvcCd = TAN_KKTK_SVC; } // サブオプションサービス契約 if(tankaSbtCd.equals(JBSbatKKConst.TANKA_SBT_SBOP_SVC_KEI)) { tgSvcCd = TAN_SBOP_SVC; } // 請求オプションサービス契約 if(tankaSbtCd.equals(JBSbatKKConst.TANKA_SBT_SEIOPSVC_KEI)) { tgSvcCd = TAN_SEIOPSVC; } // ++++++++++ v7.00.00 追加開始 ++++++++++ // // 機器オプションサービス契約 if(tankaSbtCd.equals(JBSbatKKConst.TANKA_SBT_KKOPSVC_KEI)) { tgSvcCd = TAN_KKOPSVC; } // ++++++++++ v7.00.00 追加終了 ++++++++++ // if(!isNullBlunk(svInfo.getString(tgSvcCd)) && !isNullBlunk(svInfo.getString(TARGET_SVC)) && svInfo.getString(tgSvcCd).equals(svInfo.getString(TARGET_SVC))) { outFlg = true; break; } } // 設定階層識別コードがeoブランド(2)の場合 else if(setteLvCd.equals(JBSbatKKConst.SETTE_SKBT_EO_BRAND)) { // 出力対象とする(突合不要) outFlg = true; break; } // 設定階層識別コードが料金グループ(3) else if(setteLvCd.equals(JBSbatKKConst.SETTE_SKBT_PRC_GRP)) { if(!isNullBlunk(svInfo.getString(PRC_GRP_CD)) && !isNullBlunk(svInfo.getString(TAN_PRC_GRP)) && svInfo.getString(PRC_GRP_CD).equals(svInfo.getString(TAN_PRC_GRP)) ) { outFlg = true; break; } } // 設定階層識別コードが料金コース(4) else if(setteLvCd.equals(JBSbatKKConst.SETTE_SKBT_PCRS)) { if(!isNullBlunk(svInfo.getString(TARGET_PCRS)) && !isNullBlunk(svInfo.getString(TAN_PCRS)) && svInfo.getString(TARGET_PCRS).equals(svInfo.getString(TAN_PCRS)) ) { outFlg = true; break; } } // 設定階層識別コードが料金プラン(5) else if(setteLvCd.equals(JBSbatKKConst.SETTE_SKBT_PPLAN)) { if(!isNullBlunk(svInfo.getString(TARGET_PPLAN)) && !isNullBlunk(svInfo.getString(TAN_PPLAN)) && svInfo.getString(TARGET_PPLAN).equals(svInfo.getString(TAN_PPLAN)) ) { outFlg = true; break; } } else { // ++++++++++ v4.00.00 変更開始 ++++++++++ // // 出力対象とする(突合不要) //outFlg = true; //break; // ++++++++++ v4.00.00 変更終了 ++++++++++ // } } if(outFlg) { return svInfo; } else { return null; } } /** * 比較・出力対象情報作成処理 * @param svInfo * @param wrkDiv * @param frstFlg * @return aryList * @throws Exception */ private ArrayList getKeyList(JBSbatCommonDBInterface svInfo, int wrkDiv, boolean frstFlg) throws Exception { ArrayList aryList = new ArrayList(); // 集約キー(ListA)ArrayList(String配列:[0]DBカラム名 [1]出力ファイル項目名 [2]DB実値) if(wrkDiv == 0) { 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_WRIB_SVC_KEI.PPLAN_CD, JBSbatKKIFM019.PPLAN_CD, svInfo)); // 料金プランコード aryList.add(setStrctVal(JBSbatKK_T_WRISVC_TG_KEI.WRIB_SVC_TRGT_SVC_CD, JBSbatKKIFM019.TRGT_KEI_SVC_CD, svInfo)); // 割引サービス対象サービスコード（対象契約サービスコード） aryList.add(setStrctVal(JBSbatKK_T_WRISVC_TG_KEI.SVC_KEI_UCWK_NO, JBSbatKKIFM019.SVC_KEI_UCWK_NO, svInfo)); // サービス契約内訳番号 aryList.add(setStrctVal(JBSbatKK_T_WRISVC_TG_KEI.KKTK_SVC_KEI_NO, JBSbatKKIFM019.KKTK_SVC_KEI_NO, svInfo)); // 機器提供サービス契約番号 aryList.add(setStrctVal(JBSbatKK_T_WRISVC_TG_KEI.OP_SVC_KEI_NO, JBSbatKKIFM019.OP_SVC_KEI_NO, svInfo)); // オプションサービス契約番号 aryList.add(setStrctVal(JBSbatKK_T_WRISVC_TG_KEI.SBOP_SVC_KEI_NO, JBSbatKKIFM019.SBOP_SVC_KEI_NO, svInfo)); // サブオプションサービス契約番号 aryList.add(setStrctVal(JBSbatKK_T_WRISVC_TG_KEI.WRIB_SVC_KEI_NO, JBSbatKKIFM019.WRIB_SVC_KEI_NO, svInfo)); // 割引サービス契約番号 aryList.add(setStrctVal(JBSbatKK_T_WRISVC_TG_KEI.WRIB_SVC_TRGT_KEI_NO, JBSbatKKIFM019.WRIB_SVC_TRGT_KEI_NO, svInfo)); // 割引サービス対象契約番号 // ++++++++++ v7.00.00 追加開始 ++++++++++ // aryList.add(setStrctVal(JBSbatKK_T_WRISVC_TG_KEI.KKOP_SVC_KEI_NO, JBSbatKKIFM019.KKOP_SVC_KEI_NO, svInfo)); // 機器オプションサービス契約番号 // ++++++++++ v7.00.00 追加終了 ++++++++++ // // 割引額算出基準年月日が設定されている場合サービス開始年月日に設定 if(isNullBlunk(svInfo.getString(JBSbatKK_T_WRIB_SVC_KEI.WRIB_AMNT_SNST_STDARDYMD))) { aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.SVC_STA_YMD, JBSbatKKIFM019.SVC_STAYMD, svInfo)); // サービス開始年月日 } else { aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.WRIB_AMNT_SNST_STDARDYMD, JBSbatKKIFM019.SVC_STAYMD, svInfo)); // 割引額算出基準年月日 } aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.PLAN_CHRG_STAYMD, JBSbatKKIFM019.PLAN_STAYMD, svInfo)); // プラン課金開始年月日 aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.IDO_DIV, JBSbatKKIFM019.IDO_DIV, svInfo)); // 異動区分 aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.PLAN_END_SBT_CD, JBSbatKKIFM019.PLAN_END_SBT_CD, svInfo)); // プラン終了種別コード aryList.add(setStrctVal(JBSbatKK_M_WRIB_SVC_TANKA.WRIB_SVC_TANKA_NO, JBSbatKKIFM019.WRIB_SVC_TANKA_NO, svInfo)); // 割引サービス単価番号 aryList.add(setStrctVal(JBSbatKK_T_WRISVC_TG_KEI.SEIOPSVC_KEI_NO, JBSbatKKIFM019.SEIOPSVC_KEI_NO, svInfo)); // 請求オプションサービス契約番号 aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.SVC_CHRG_STAYMD, JBSbatKKIFM019.SVC_CHRG_STAYMD, svInfo)); // サービス課金開始年月日 // aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.PLAN_CHRG_ENDYMD, JBSbatKKIFM019.PLAN_ENDYMD, svInfo)); // プラン課金終了年月日 aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.SVC_CANCEL_YMD, JBSbatKKIFM019.SVC_CANCEL_YMD, svInfo)); // サービスキャンセル年月日 aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.SVC_ENDYMD, JBSbatKKIFM019.SVC_ENDYMD, svInfo)); // サービス終了年月日 aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.SVC_CHRG_ENDYMD, JBSbatKKIFM019.SVC_CHRG_ENDYMD, svInfo)); // サービス課金終了年月日 // [プラン課金終了年月日] // 内訳適用終了フラグがOFFの場合には課金終了日の編集 if(!uwAplyEndFlg) { // 初回レコード(カレント)は編集不要 if(frstFlg) { aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.PLAN_CHRG_ENDYMD, JBSbatKKIFM019.PLAN_ENDYMD, svInfo)); } else { // 割引サービス契約内訳のプラン課金終了年月日(カレント)に割引サービスの当該値を設定 String[] strctStr = new String[3]; strctStr[0] = JBSbatKK_T_WRIB_SVC_KEI.PLAN_CHRG_ENDYMD; strctStr[1] = JBSbatKKIFM019.PLAN_ENDYMD; strctStr[2] = svInfo.getString(W_PLAN_CHRG_ENDYMD); aryList.add(strctStr); } } // 内訳適用終了フラグがONの場合には編集不要 else { aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.PLAN_CHRG_ENDYMD, JBSbatKKIFM019.PLAN_ENDYMD, svInfo)); } } // 解約系項目群(ListB)ArrayList(String配列:[0]DBカラム名 [1]出力ファイル項目名 [2]DB実値) else if(wrkDiv == 1) { // [サービス解約年月日] 内訳適用終了フラグがONの場合には固有編集 if(uwAplyEndFlg) { // サービス解約年月日(内訳の適用終了日＋１) String[] strctSvcDslYmd = new String[3]; strctSvcDslYmd[0] = JBSbatKK_T_WRIB_SVC_KEI.SVC_DSL_YMD; strctSvcDslYmd[1] = JBSbatKKIFM019.SVC_DSL_YMD; strctSvcDslYmd[2] = JBSbatDateUtil.adjustDate(svInfo.getString(PLAN_CHRG_ENDYMD), 1); aryList.add(strctSvcDslYmd); // 違約金発生コード(未設定) String[] strctPnltyHasseiCd = new String[3]; strctPnltyHasseiCd[0] = JBSbatKK_T_WRIB_SVC_KEI.PNLTY_HASSEI_CD; strctPnltyHasseiCd[1] = JBSbatKKIFM019.PNLTY_HASSEI_CD; strctPnltyHasseiCd[2] = ""; aryList.add(strctPnltyHasseiCd); // サービス解約理由(キャンペーン終了) String[] strctSvcDlreCd = new String[3]; strctSvcDlreCd[0] = JBSbatKK_T_WRIB_SVC_KEI.SVC_DLRE_CD; strctSvcDlreCd[1] = JBSbatKKIFM019.SVC_DLRE_CD; strctSvcDlreCd[2] = JBSbatKKConst.SVC_DLRE_CPN; aryList.add(strctSvcDlreCd); // サービス回復年月日(未設定) String[] strctKaihk = new String[3]; strctKaihk[0] = JBSbatKK_T_WRIB_SVC_KEI.KAIHK_YMD; strctKaihk[1] = JBSbatKKIFM019.KAIHK_YMD; strctKaihk[2] = ""; aryList.add(strctKaihk); } else { aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.SVC_DSL_YMD, JBSbatKKIFM019.SVC_DSL_YMD, svInfo)); // サービス解約年月日 aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.PNLTY_HASSEI_CD, JBSbatKKIFM019.PNLTY_HASSEI_CD, svInfo)); // 違約金発生コード aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.SVC_DLRE_CD, JBSbatKKIFM019.SVC_DLRE_CD, svInfo)); // サービス解約理由 aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.KAIHK_YMD, JBSbatKKIFM019.KAIHK_YMD, svInfo)); // サービス回復年月日 } } // 休止系項目群(ListB)ArrayList(String配列:[0]DBカラム名 [1]出力ファイル項目名 [2]DB実値) else if(wrkDiv == 2) { //▼OM-2013-0005081▼ // 休止中断コード String pauseStpCd = null; if(!isNullBlunk(svInfo.getString(JBSbatKK_T_WRIB_SVC_KEI.WRTGKEI_SVC_PAUSE_YMD))) { pauseStpCd = PAUSE_STP_CD_00; } String[] pauseStpCdAry = new String[3]; pauseStpCdAry[0] = JBSbatKK_T_SVC_KEI.PAUSE_STP_CD; pauseStpCdAry[1] = JBSbatKKIFM019.PAUSE_STP_CD; pauseStpCdAry[2] = pauseStpCd; aryList.add(pauseStpCdAry); aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.WRTGKEI_SVC_PAUSE_YMD, JBSbatKKIFM019.SVC_PAUSE_YMD, svInfo)); // サービス休止年月日 aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.WRTGKEI_SVC_PAUSE_YMD, JBSbatKKIFM019.SVC_PAUSE_PRC_TSTAYMD, svInfo)); // サービス休止料金適用開始年月日 aryList.add(setStrctVal(JBSbatKK_T_WRIB_SVC_KEI.WRTGKEI_SVC_PAUSE_RLS_YMD, JBSbatKKIFM019.SVC_PAUSE_RLS_YMD, svInfo)); // サービス休止解除年月日 //▲OM-2013-0005081▲ } return aryList; } /** * String型配列に値を設定 * [0]：DBカラム名 * [1]：出力ファイル項目名 * [2]：[0]のカラムのDB値 * @param cstName * @param outName * @param svInfo * @return strctStr * @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; } /** * null、空文字を判定 * @param str * @return true:値なし／false:値あり */ private boolean isNullBlunk(String str) { if (str == null || str.equals("")) { return true; } return false; } /** * 翌月異動情報のオミット判定をします。 * @param svInfo データ取得情報Map * @return outMap 判定結果(true:有効レコード/false:不要レコード) * @throws Exception 業務サービス内で発生した例外全般。 */ private boolean chkIdoTmg(JBSbatCommonDBInterface svInfo) throws Exception { // ++++++++++ v4.00.01 追加開始 ++++++++++ // // 編集前情報取得領域 WkIdoTmgSvInfo.add(svInfo); // ++++++++++ v4.00.01 追加終了 ++++++++++ // // ++++++++++ v4.00.01 変更開始 ++++++++++ // // boolean rtnFlg = true; boolean rtnFlg = false; // 回復年月日 String kfkYmd = svInfo.getString(JBSbatKK_T_WRIB_SVC_KEI.KAIHK_YMD); // 解約年月日 String dslYmd = svInfo.getString(JBSbatKK_T_WRIB_SVC_KEI.SVC_DSL_YMD); // 課金終了年月日 String ChrgEndYmd = svInfo.getString(W_PLAN_CHRG_ENDYMD); // if(null != dslYmd && 0 != dslYmd.length() && dslYmd.compareTo(strEnd) > 0) if(null != dslYmd && 0 != dslYmd.length()) { if(ChrgEndYmd.compareTo(strEnd) <= 0) { rtnFlg = true; } else { // 異動タイミングチェックリスト初期化 initialize(); } // 回復年月日が未設定の場合 } else if (!(null != kfkYmd && 0 != kfkYmd.length())) { rtnFlg = true; } // if(null != kfkYmd && 0 != kfkYmd.length() && kfkYmd.compareTo(strEnd) > 0) // { // rtnFlg = false; // } // ++++++++++ v4.00.01 変更終了 ++++++++++ // return rtnFlg; } // ++++++++++ v4.00.01 追加開始 ++++++++++ // /** * 各変数の初期化を行います。 */ public void initialize() { // 退避リスト初期化 WkIdoTmgSvInfo = new ArrayList(); } // ++++++++++ v4.00.01 追加終了 ++++++++++ // /** * JBSbatOutputItemを結合します。 */ @SuppressWarnings("unchecked") private JBSbatOutputItem concatinateOutputItem(JBSbatOutputItem outputBeanFirst, JBSbatOutputItem outputBeanSecond) { JBSbatOutputItem result=new JBSbatOutputItem(); outputBeanFirst=(outputBeanFirst==null)?new JBSbatOutputItem():outputBeanFirst; outputBeanSecond=(outputBeanSecond==null)?new JBSbatOutputItem():outputBeanSecond; ArrayList outMapListFirst=outputBeanFirst.getOutMapList(); ArrayList outMapListSecond=outputBeanSecond.getOutMapList(); ArrayList outMapListResult=new ArrayList(); outMapListResult.addAll(outMapListFirst); outMapListResult.addAll(outMapListSecond); result.setOutMapList(outMapListResult); return result; } }