/********************************************************************* * All Rights reserved,Copyright (c) Fujitsu ,2012 * ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatKKPplanCdConvertUcwk * ソースファイル名 ：JBSbatKKPplanCdConvertUcwk.java * 作成者 ：富士通　 * 作成日 ：2014年4月22日 *＜機能概要＞ *　オプションパック対象契約料金プランコード変換部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v9.00.00 2014/04/22 AS)安井 ANK-2056-00-00 *********************************************************************/ package eo.business.service; import java.util.ArrayList; import java.util.HashMap; import eo.business.common.JBSbatBusinessService; import eo.business.common.JBSbatKKConst; import eo.business.common.JBSbatMatchServiceInterface; import eo.business.common.JKKBatConst; import eo.business.util.file.JBSbatKKIFM019; import eo.business.util.file.JBSbatKKIFM596; import eo.business.util.table.JBSbatKK_M_WRISVC_KOSE; 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; import eo.framework.util.JBSbatStringUtil; /** * (クラスの機能概要)

*
* @author 富士通 */ public class JBSbatKKPplanCdConvertUcwk extends JBSbatBusinessService implements JBSbatMatchServiceInterface { /** 割引サービス構成マスタ抽出結果項目名：料金プランコード(変換対象) */ private static final String TRGT_PPLAN_CD = "TRGT_PPLAN_CD"; /** 割引サービス構成マスタ抽出結果項目名：割引タイプコード */ private static final String TYPE_CD = "TYPE_CD"; /** 割引サービス構成マスタ抽出結果項目名：料金プランコード(変換値) */ private static final String CHG_PPLAN_CD = "CHG_PPLAN_CD"; /** 割引サービス構成マスタ抽出結果項目名：割引サービスコード */ private static final String WRIB_SVC_CD = "WRIB_SVC_CD"; /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** キーマッチ処理フラグ*/ private boolean matchProcFlg; /** マスタファイル処理フラグ*/ private boolean mastProcFlg; /** トランファイル処理フラグ*/ private boolean tranProcFlg; /** テーブル(割引サービス構成)*/ private static final String D_TBL_NAME_KK_M_WRISVC_KOSE = "KK_M_WRISVC_KOSE"; /** SQL定義キー(KK_SELECT_001)*/ private static final String KK_M_WRISVC_KOSE_KK_SELECT_001 = "KK_SELECT_001"; /** テーブルアクセスクラス(割引サービス構成)*/ private JBSbatSQLAccess db_KK_M_WRISVC_KOSE = null; /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /** 運用日付 */ private String unyoDate = null; /** 利用月 */ private String useMon = null; /** 処理月区分 */ private String monthDiv = ""; /** [置換型割引対象料金プランコードリスト] */ ArrayList> cdList = new ArrayList>(); /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); super.logPrint.printDebugLog("initial start"); // DBアクセスクラスを生成します db_KK_M_WRISVC_KOSE = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_M_WRISVC_KOSE); /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ // フリー項目より処理月区分を取得 String[] freeItems = super.freeItem.split(JKKBatConst.S_PARAM_DELIM); monthDiv = freeItems[0]; // 運用日付より対象月を算出 // 運用日付 unyoDate = commonItem.getOpeDate(); useMon = unyoDate.substring(0, 6); if(JBSbatKKConst.TRAN_TRGT_MON_BF.equals(monthDiv)) { useMon = JBSbatDateUtil.adjustMonth(unyoDate, -1).substring(0, 6); } // 割引サービス構成取得(KK_SELECT_001) executeKK_M_WRISVC_KOSE_KK_SELECT_001(getWrisvcKose_S001Param()); // [置換型割引対象料金プランコードリスト]を生成 JBSbatCommonDBInterface pPlanMap = new JBSbatCommonDBInterface(); pPlanMap = db_KK_M_WRISVC_KOSE.selectNext(); while(null != pPlanMap) { // 分割取得した各要素をHashMapに設定 HashMap planMap = new HashMap(); if(null != pPlanMap.getString(JBSbatKK_M_WRISVC_KOSE.PPLAN_CD)) { planMap.put(TRGT_PPLAN_CD, pPlanMap.getString(JBSbatKK_M_WRISVC_KOSE.PPLAN_CD)); // 料金プランコード(変換対象) planMap.put(TYPE_CD, JKKBatConst.WRIB_TYPE_CD_FAMIPA_WRIB); // 割引タイプコード planMap.put(CHG_PPLAN_CD, pPlanMap.getString(JBSbatKK_M_WRISVC_KOSE.RTWRHCG_PPLAN_CD)); // 料金プランコード(変換値) planMap.put(WRIB_SVC_CD, pPlanMap.getString(JBSbatKK_M_WRISVC_KOSE.WRIB_SVC_CD)); // 割引サービスコード // [置換型割引対象料金プラン変換リスト]に蓄積 cdList.add(planMap); } pPlanMap = db_KK_M_WRISVC_KOSE.selectNext(); } super.logPrint.printDebugLog("initial end"); /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @param mastMap　入力電文 * @param tranMap　入力電文 * @param outputInItem 入力情報 * @return JBSbatOutputItem 出力情報 * @throws Exception */ public JBSbatOutputItem execute(JBSbatServiceInterfaceMap mastMap, JBSbatServiceInterfaceMap tranMap, JBSbatOutputItem outputInItem) throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ super.logPrint.printDebugLog("execute start"); // 出力共通電文を生成する。 if (mastMap == null && tranMap != null) { // 入力Ｍのみnullの場合 this.setTranProcFlg(true); // 割引対象契約なし(料金プランコード変換なし)で出力 JBSbatServiceInterfaceMap outMap = setOutMap(tranMap); // 出力フラグON outMap.setOutFlg(true); // 出力共通電文に入出力インターフェースを設定する。 outputInItem.addOutMapList(outMap); } else if (mastMap != null && tranMap == null) { // 入力Ｔのみnullの場合 this.setMastProcFlg(true); } else { // 入力Ｔ、入力Ｍが共にnullでない場合 // キー情報取得 String mastKey = mastMap.getString(JBSbatKKIFM596.SVC_KEI_UCWK_NO); String tranKey = JBSbatStringUtil.Rtrim(tranMap.getString(JBSbatKKIFM019.SVC_KEI_UCWK_NO)); // マッチングキー（マスタ）を作成 if (mastKey.toString().compareTo(tranKey.toString()) == 0) { // 入力Ｍ = 入力Ｔ this.setMatchProcFlg(true); // 割引対象契約あり(料金プランコード変換あり)で出力 JBSbatServiceInterfaceMap outMap = setOutMap(tranMap); chgPplanCd(outMap, mastMap); // 出力フラグON outMap.setOutFlg(true); // 出力共通電文に入出力インターフェースを設定する。 outputInItem.addOutMapList(outMap); } else if (mastKey.toString().compareTo(tranKey.toString()) < 0) { // 入力Ｍ < 入力Ｔ this.setMastProcFlg(true); } else { // 入力Ｍ > 入力Ｔ this.setTranProcFlg(true); // 割引対象契約なし(料金プランコード変換なし)で出力 JBSbatServiceInterfaceMap outMap = setOutMap(tranMap); // 出力フラグON outMap.setOutFlg(true); // 出力共通電文に入出力インターフェースを設定する。 outputInItem.addOutMapList(outMap); } } super.logPrint.printDebugLog("execute end"); return outputInItem; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ db_KK_M_WRISVC_KOSE.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/ /** * @return mastProcFlg を戻します。 */ public boolean isMastProcFlg() { return mastProcFlg; } /** * @return matchProcFlg を戻します。 */ public boolean isMatchProcFlg() { return matchProcFlg; } /** * @return tranProcFlg を戻します。 */ public boolean isTranProcFlg() { return tranProcFlg; } /** * @param mast_ProcFlg 設定する mastProcFlg。 */ public void setMastProcFlg(boolean mast_ProcFlg) { this.mastProcFlg = mast_ProcFlg; } /** * @param match_ProcFlg 設定する matchProcFlg。 */ public void setMatchProcFlg(boolean match_ProcFlg) { this.matchProcFlg = match_ProcFlg; } /** * @param tran_ProcFlg 設定する tranProcFlg。 */ public void setTranProcFlg(boolean tran_ProcFlg) { this.tranProcFlg = tran_ProcFlg; } /** * SQLKEY(KK_SELECT_001)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	バッチ運用日
	 *		 	バッチ運用日
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_M_WRISVC_KOSE_KK_SELECT_001(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); // DBアクセスを実行します super.logPrint.printDebugLog("SQL:KK_M_WRISVC_KOSE_KK_SELECT_001 start"); db_KK_M_WRISVC_KOSE.selectBySqlDefine(paramList, KK_M_WRISVC_KOSE_KK_SELECT_001); super.logPrint.printDebugLog("SQL:KK_M_WRISVC_KOSE_KK_SELECT_001 end"); } /** * SQLKEY(KK_SELECT_001)でDBアクセスを実行する際に必要なパラメータを設定します。
*

* 処理フロー
* 

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

* @param * @return param SQLKEY(KK_SELECT_001)でDBアクセスを実行する際に必要なパラメータ * @throws Exception */ private Object[] getWrisvcKose_S001Param() throws Exception { Object[] ret_Param = { unyoDate, // バッチ運用日 unyoDate, // バッチ運用日 unyoDate // バッチ運用日 }; return ret_Param; } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** *

メソッド名 ：料金計算用サービス契約インターフェイス情報ファイル編集 *
メソッド説明 ：1.ファイル編集対象項目を取得します。 * 2.取得した項目を元にファイル編集を行います。 * @param inMap データ取得情報Map * @return outMap 出力Map * @throws Exception 業務サービス内で発生した例外全般。 */ private JBSbatServiceInterfaceMap setOutMap(JBSbatServiceInterfaceMap inMap) throws Exception { // 出力情報を設定するMap JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap(); outMap.setString(JBSbatKKIFM019.CHSHT_KEI_DIV, inMap.getString(JBSbatKKIFM019.CHSHT_KEI_DIV)); outMap.setString(JBSbatKKIFM019.SVC_KEI_NO, inMap.getString(JBSbatKKIFM019.SVC_KEI_NO)); outMap.setString(JBSbatKKIFM019.SVC_CD, inMap.getString(JBSbatKKIFM019.SVC_CD)); outMap.setString(JBSbatKKIFM019.PRC_GRP_CD, inMap.getString(JBSbatKKIFM019.PRC_GRP_CD)); outMap.setString(JBSbatKKIFM019.PCRS_CD, inMap.getString(JBSbatKKIFM019.PCRS_CD)); outMap.setString(JBSbatKKIFM019.PPLAN_CD, inMap.getString(JBSbatKKIFM019.PPLAN_CD)); outMap.setString(JBSbatKKIFM019.TRGT_KEI_SVC_CD, inMap.getString(JBSbatKKIFM019.TRGT_KEI_SVC_CD)); outMap.setString(JBSbatKKIFM019.SVC_KEI_UCWK_NO, inMap.getString(JBSbatKKIFM019.SVC_KEI_UCWK_NO)); outMap.setString(JBSbatKKIFM019.KKTK_SVC_KEI_NO, inMap.getString(JBSbatKKIFM019.KKTK_SVC_KEI_NO)); outMap.setString(JBSbatKKIFM019.OP_SVC_KEI_NO, inMap.getString(JBSbatKKIFM019.OP_SVC_KEI_NO)); outMap.setString(JBSbatKKIFM019.SEIOPSVC_KEI_NO, inMap.getString(JBSbatKKIFM019.SEIOPSVC_KEI_NO)); outMap.setString(JBSbatKKIFM019.SBOP_SVC_KEI_NO, inMap.getString(JBSbatKKIFM019.SBOP_SVC_KEI_NO)); outMap.setString(JBSbatKKIFM019.WRIB_SVC_KEI_NO, inMap.getString(JBSbatKKIFM019.WRIB_SVC_KEI_NO)); outMap.setString(JBSbatKKIFM019.WRIB_SVC_TRGT_KEI_NO, inMap.getString(JBSbatKKIFM019.WRIB_SVC_TRGT_KEI_NO)); outMap.setString(JBSbatKKIFM019.WRIB_SVC_TANKA_NO, inMap.getString(JBSbatKKIFM019.WRIB_SVC_TANKA_NO)); outMap.setString(JBSbatKKIFM019.OWNR_KEI_NO, inMap.getString(JBSbatKKIFM019.OWNR_KEI_NO)); outMap.setString(JBSbatKKIFM019.TK_HOSHIKI_KEI_NO, inMap.getString(JBSbatKKIFM019.TK_HOSHIKI_KEI_NO)); outMap.setString(JBSbatKKIFM019.SEIKY_KEI_NO, inMap.getString(JBSbatKKIFM019.SEIKY_KEI_NO)); outMap.setString(JBSbatKKIFM019.SVC_STAYMD, inMap.getString(JBSbatKKIFM019.SVC_STAYMD)); outMap.setString(JBSbatKKIFM019.SVC_CHRG_STAYMD, inMap.getString(JBSbatKKIFM019.SVC_CHRG_STAYMD)); outMap.setString(JBSbatKKIFM019.PLAN_STAYMD, inMap.getString(JBSbatKKIFM019.PLAN_STAYMD)); outMap.setString(JBSbatKKIFM019.PLAN_ENDYMD, inMap.getString(JBSbatKKIFM019.PLAN_ENDYMD)); outMap.setString(JBSbatKKIFM019.SVC_DSL_YMD, inMap.getString(JBSbatKKIFM019.SVC_DSL_YMD)); outMap.setString(JBSbatKKIFM019.SVC_DLRE_CD, inMap.getString(JBSbatKKIFM019.SVC_DLRE_CD)); outMap.setString(JBSbatKKIFM019.PNLTY_HASSEI_CD, inMap.getString(JBSbatKKIFM019.PNLTY_HASSEI_CD)); outMap.setString(JBSbatKKIFM019.PLAN_END_SBT_CD, inMap.getString(JBSbatKKIFM019.PLAN_END_SBT_CD)); outMap.setString(JBSbatKKIFM019.KAIHK_YMD, inMap.getString(JBSbatKKIFM019.KAIHK_YMD)); outMap.setString(JBSbatKKIFM019.PAUSE_STP_CD, inMap.getString(JBSbatKKIFM019.PAUSE_STP_CD)); outMap.setString(JBSbatKKIFM019.SVC_PAUSE_YMD, inMap.getString(JBSbatKKIFM019.SVC_PAUSE_YMD)); outMap.setString(JBSbatKKIFM019.SVC_PAUSE_PRC_TSTAYMD, inMap.getString(JBSbatKKIFM019.SVC_PAUSE_PRC_TSTAYMD)); outMap.setString(JBSbatKKIFM019.SVC_PAUSE_RLS_YMD, inMap.getString(JBSbatKKIFM019.SVC_PAUSE_RLS_YMD)); outMap.setString(JBSbatKKIFM019.SVC_CANCEL_YMD, inMap.getString(JBSbatKKIFM019.SVC_CANCEL_YMD)); outMap.setString(JBSbatKKIFM019.SVC_ENDYMD, inMap.getString(JBSbatKKIFM019.SVC_ENDYMD)); outMap.setString(JBSbatKKIFM019.SVC_CHRG_ENDYMD, inMap.getString(JBSbatKKIFM019.SVC_CHRG_ENDYMD)); outMap.setString(JBSbatKKIFM019.IDO_DIV, inMap.getString(JBSbatKKIFM019.IDO_DIV)); outMap.setString(JBSbatKKIFM019.TELNO, inMap.getString(JBSbatKKIFM019.TELNO)); outMap.setString(JBSbatKKIFM019.JIGYOSHA_KEI_ID, inMap.getString(JBSbatKKIFM019.JIGYOSHA_KEI_ID)); outMap.setBigDecimal(JBSbatKKIFM019.KEI_CNT, inMap.getBigDecimal(JBSbatKKIFM019.KEI_CNT)); outMap.setString(JBSbatKKIFM019.CAPA, inMap.getString(JBSbatKKIFM019.CAPA)); outMap.setString(JBSbatKKIFM019.TEIZO_KMK_DIV, inMap.getString(JBSbatKKIFM019.TEIZO_KMK_DIV)); outMap.setBigDecimal(JBSbatKKIFM019.MON_MAX_KEI_CNT, inMap.getBigDecimal(JBSbatKKIFM019.MON_MAX_KEI_CNT)); outMap.setString(JBSbatKKIFM019.GUN_CD, inMap.getString(JBSbatKKIFM019.GUN_CD)); outMap.setString(JBSbatKKIFM019.USE_FAIL_STAYMD, inMap.getString(JBSbatKKIFM019.USE_FAIL_STAYMD)); outMap.setString(JBSbatKKIFM019.USE_FAIL_ENDYMD, inMap.getString(JBSbatKKIFM019.USE_FAIL_ENDYMD)); outMap.setString(JBSbatKKIFM019.SEIRI_NO, inMap.getString(JBSbatKKIFM019.SEIRI_NO)); outMap.setString(JBSbatKKIFM019.UPD_UNYO_YMD, inMap.getString(JBSbatKKIFM019.UPD_UNYO_YMD)); outMap.setString(JBSbatKKIFM019.GENE_ADD_DTM, inMap.getString(JBSbatKKIFM019.GENE_ADD_DTM)); outMap.setString(JBSbatKKIFM019.SVCKEI_SVC_CHRG_STAYMD, inMap.getString(JBSbatKKIFM019.SVCKEI_SVC_CHRG_STAYMD)); outMap.setString(JBSbatKKIFM019.SVCKEI_SVC_CHRG_ENDYMD, inMap.getString(JBSbatKKIFM019.SVCKEI_SVC_CHRG_ENDYMD)); outMap.setString(JBSbatKKIFM019.OYA_KEI_SKBT_CD, inMap.getString(JBSbatKKIFM019.OYA_KEI_SKBT_CD)); outMap.setString(JBSbatKKIFM019.KKOP_SVC_KEI_NO, inMap.getString(JBSbatKKIFM019.KKOP_SVC_KEI_NO)); return outMap; } /** * 料金プランコードの変換処理を行う。 * 料金プランコード（料金サービスコード）が割引サービス構成マスタの料金プランコードと一致、かつ * 入力の契約とひもづく割引タイプコードが割引サービス構成マスタの割引タイプコードと一致する場合 * 料金プランコードを変換する。 * @param outMap * @param mastMap * @throws Exception */ private void chgPplanCd(JBSbatServiceInterfaceMap outMap, JBSbatServiceInterfaceMap mastMap) throws Exception { String pplanCd = JBSbatStringUtil.Rtrim(outMap.getString(JBSbatKKIFM019.PPLAN_CD)); if (pplanCd == null || "".equals(pplanCd)) { // プランコードが未設定の場合、メソッドを終了する。 return; } // 置換候補リスト件数分、以下の処理を繰り返す。 super.logPrint.printDebugLog("置換型割引用料金プランコード変換ループ処理 start"); for (int listNo = 0; listNo < cdList.size(); listNo++) { // 置換候補の料金プランコードを取得する。 HashMap planMap = cdList.get(listNo); // 入力と置換候補が合致する場合、置換候補の料金プランコードを返却 if(planMap.get(TRGT_PPLAN_CD).equals(pplanCd)) { // 割引タイプコード、割引サービスコードが合致するか if (mastMap.get(JBSbatKKIFM596.WRIB_TYPE_CD).equals(planMap.get(TYPE_CD)) && mastMap.get(JBSbatKKIFM596.WRIB_SVC_CD).equals(planMap.get(WRIB_SVC_CD))) { pplanCd = planMap.get(CHG_PPLAN_CD); // 存在が確認できた場合のみ料金プランコードを置換する。 outMap.setString(JBSbatKKIFM019.PPLAN_CD, pplanCd); break; } } } super.logPrint.printDebugLog("置換型割引用料金プランコード変換ループ処理 end"); } }