/********************************************************************* * All Rights reserved,Copyright (c) Fujitsu ,2011 * ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatCHOrcReAdjTrgtChsht * ソースファイル名 ：JBSbatCHOrcReAdjTrgtChsht.java * 作成者 ：富士通　 * 作成日 ：2011年10月23日 *＜機能概要＞ *　料金再調整対象抽出部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v1.00.00 2011/10/23 富士通 新規作成 * v3.00 2012/06/12 FJ）冨井 【ANK-0024-04-00】ファイル項目追加 *********************************************************************/ package eo.business.service; import eo.business.common.JACbatDebugLogUtil; import eo.business.common.JBSbatBusinessService; import eo.business.util.file.JBSbatCHIFI005; import eo.business.util.file.JBSbatCHIFM103; import eo.business.util.table.JBSbatAC_T_ICJKN; import eo.common.constant.JACStrConst; import eo.framework.item.JBSbatCommonItem; import eo.framework.item.JBSbatServiceInterfaceMap; import eo.framework.item.JBSbatOutputItem; import eo.framework.item.JBSbatCommonDBInterface; import eo.framework.db.JBSbatSQLAccess; /** * (クラスの機能概要)

*
* @author 富士通 */ public class JBSbatCHOrcReAdjTrgtChsht extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** テーブル(一時金)*/ private static final String D_TBL_NAME_AC_T_ICJKN = "AC_T_ICJKN"; /** SQL定義キー(CH_SELECT_001)*/ private static final String AC_T_ICJKN_CH_SELECT_001 = "CH_SELECT_001"; /** テーブルアクセスクラス(一時金)*/ private JBSbatSQLAccess db_AC_T_ICJKN = null; /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /** 退避．請求契約番号*/ private String tihSekyukeiNo = null; /** 退避．請求年月*/ private String tihSeikyYm = null; /** 退避．料金コースコード*/ private String tihPcrsCd = null; /** 退避．料金サービスコード*/ private String tihPrcsvcCd = null; /** 退避．料金項目コード*/ private String tihPrckmkCd = null; /** 退避．対処区分*/ private String tihTaisyoDiv = null; /** 退避．整理番号*/ private String tihSeiriNo = null; /** 退避．料金グループコード*/ private String tihPrcGrpCd = null; /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_AC_T_ICJKN = new JBSbatSQLAccess(commonItem, D_TBL_NAME_AC_T_ICJKN); /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][opeDate=" + super.opeDate + "]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][commonItem=" + super.commonItem + "]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]"); /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @param inMap　入力電文 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]"); assert inMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][Map=" + inMap.getMap().toString() + "]") : true; // 出力共通電文生成 JBSbatOutputItem outputItem = new JBSbatOutputItem(); // 1.料金再調整対象抽出 // 料金再調整対象出力処理 // 入力データチェック // 入力．請求契約番号 ＝ 退避．請求契約番号 かつ 入力．請求年月 ＝ 退避．請求年月 の場合 if(inMap.get(JBSbatCHIFI005.SEIKY_KEI_NO).equals(tihSekyukeiNo) && inMap.get(JBSbatCHIFI005.SEIKY_YM).equals(tihSeikyYm)) { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]"); // 処理を抜ける return null; // 上記以外の場合 } else { // 料金調整対象抽出 tihSekyukeiNo = inMap.get(JBSbatCHIFI005.SEIKY_KEI_NO).toString(); // 請求契約番号 tihSeikyYm = inMap.get(JBSbatCHIFI005.SEIKY_YM).toString(); // 請求年月 tihSeiriNo = inMap.get(JBSbatCHIFI005.SEIRI_NO).toString(); // 整理番号 } // 2.料金調整対象抽出 // ＤＢアクセス用のパラメータ定義 JBSbatCommonDBInterface dbList = new JBSbatCommonDBInterface(); // パラメータ設定 dbList.setValue(tihSekyukeiNo); // 請求契約番号 dbList.setValue(tihSeikyYm); // 請求年月 dbList.setValue(JACStrConst.ICJKN_SBT_CD_MANUAL_PRC_ADJ); // 一時金種別コード（2:手動（料金調整）） dbList.setValue(JACStrConst.ICJKN_SBT_CD_LUMP_PRC_ADJ); // 一時金種別コード（5:一括（料金調整）） dbList.setValue(JACStrConst.ICJKN_TRKM_STAT_ZUMI); // 一時金取込ステータス （2:取込済） assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][tihSekyukeiNo=" + tihSekyukeiNo + "]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][tihSeikyYm=" + tihSeikyYm + "]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][ICJKN_MANUAL_PRC_ADJ=" + JACStrConst.ICJKN_SBT_CD_MANUAL_PRC_ADJ + "]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][ICJKN_LUMP_PRC_ADJ=" + JACStrConst.ICJKN_SBT_CD_LUMP_PRC_ADJ + "]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][execute][ICJKN_TRKM_STAT_ZUMI=" + JACStrConst.ICJKN_TRKM_STAT_ZUMI + "]"); // SELECT文発行 executeAC_T_ICJKN_CH_SELECT_001(dbList.getList().toArray()); // 結果を取得 JBSbatCommonDBInterface dbMap = db_AC_T_ICJKN.selectNext(); // 該当データあり if (dbMap != null) { // 料金出力処理実施 // 取得データ分のファイルを作成する while (dbMap != null) { // 3.料金再調整出力 outputItem = makeOutData(inMap, dbMap, outputItem); dbMap = db_AC_T_ICJKN.selectNext(); } } // 該当データなし else { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]"); // 処理を抜ける return null; } assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]"); // 出力共通電文返却 return outputItem; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]"); /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_AC_T_ICJKN.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]"); /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /** * 料金出力情報作成処理 * @param inMap　入力電文 * @param dbMap　一時金情報 * @param outMap　出力共通電文 * @return JBSbatOutputItem　出力共通電文 * @throws Exception 業務サービス内で発生した例外全般 */ private JBSbatOutputItem makeOutData(JBSbatServiceInterfaceMap inMap, JBSbatCommonDBInterface dbMap, JBSbatOutputItem outMap) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeOutData]"); // 条件による対処区分の設定 // 対処区分：追加の場合 if(dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PRC_GRP_CD).equals(JACStrConst.TRGT_PRC_GRP_CD_SP) && dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PCRS_CD).equals(JACStrConst.TRGT_PCRS_CD_SP) && dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PRC_SVC_CD).equals(JACStrConst.TRGT_PRC_SVC_CD_SP) && dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PRC_KMK_CD).equals(JACStrConst.TRGT_PRC_KMK_CD_SP)) { tihPrcGrpCd = dbMap.getString(JBSbatAC_T_ICJKN.PRC_GRP_CD); // 退避．料金グループコード ← 一時金．料金グループコード tihPcrsCd = dbMap.getString(JBSbatAC_T_ICJKN.PCRS_CD); // 退避．料金コースコード ← 一時金．料金コースコード tihPrcsvcCd = dbMap.getString(JBSbatAC_T_ICJKN.PRC_SVC_CD); // 退避．料金サービスコード ← 一時金．料金サービスコード tihPrckmkCd = dbMap.getString(JBSbatAC_T_ICJKN.PRC_KMK_CD); // 退避．料金項目コード ← 一時金．料金項目コード tihTaisyoDiv = JACStrConst.TAI_DIV_ADD; // 退避．対処区分 ← "2"（追加） } // 対処区分：削除の場合 else if(dbMap.getString(JBSbatAC_T_ICJKN.PRC_GRP_CD).equals(JACStrConst.PRC_GRP_CD_SP) && dbMap.getString(JBSbatAC_T_ICJKN.PCRS_CD).equals(JACStrConst.PCRS_CD_SP) && dbMap.getString(JBSbatAC_T_ICJKN.PRC_SVC_CD).equals(JACStrConst.PRC_SVC_CD_SP) && dbMap.getString(JBSbatAC_T_ICJKN.PRC_KMK_CD).equals(JACStrConst.PRC_KMK_CD_SP)) { tihPrcGrpCd = dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PRC_GRP_CD);// 退避．料金グループコード ← 一時金．対象料金グループコード tihPcrsCd = dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PCRS_CD); // 退避．料金コースコード ← 一時金．対象料金コースコード tihPrcsvcCd = dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PRC_SVC_CD);// 退避．料金サービスコード ← 一時金．対象料金サービスコード tihPrckmkCd = dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PRC_KMK_CD);// 退避．料金項目コード ← 一時金．対象料金項目コード tihTaisyoDiv = JACStrConst.TAI_DIV_DEL; // 退避．対処区分 ← "3"（削除） } // 対処区分：調整の場合 else { tihPrcGrpCd = dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PRC_GRP_CD); // 退避．料金グループコード ← 一時金．対象料金グループコード tihPcrsCd = dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PCRS_CD); // 退避．料金コースコード ← 一時金．対象料金コースコード tihPrcsvcCd = dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PRC_SVC_CD); // 退避．料金サービスコード ← 一時金．対象料金サービスコード tihPrckmkCd = dbMap.getString(JBSbatAC_T_ICJKN.TRGT_PRC_KMK_CD); // 退避．料金項目コード ← 一時金．対象料金項目コード tihTaisyoDiv = JACStrConst.TAI_DIV_ADJ; // 退避．対処区分 ← "1"（調整） } // 入出力オブジェクト生成 JBSbatServiceInterfaceMap outputMap = new JBSbatServiceInterfaceMap(); // 項目設定 outputMap.setString(JBSbatCHIFM103.SEIKY_KEI_NO, tihSekyukeiNo); // 請求契約番号 outputMap.setString(JBSbatCHIFM103.SEIKY_YM, tihSeikyYm); // 請求年月 outputMap.setString(JBSbatCHIFM103.SEIRI_NO, tihSeiriNo); // 整理番号 outputMap.setString(JBSbatCHIFM103.SVC_KEI_NO, dbMap.getString(JBSbatAC_T_ICJKN.SVC_KEI_NO)); // サービス契約番号 outputMap.setString(JBSbatCHIFM103.PRC_GRP_CD, tihPrcGrpCd); // 料金グループコード outputMap.setString(JBSbatCHIFM103.PCRS_CD, tihPcrsCd); // 料金コースコード outputMap.setString(JBSbatCHIFM103.PRC_SVC_CD, tihPrcsvcCd); // 料金サービスコード outputMap.setString(JBSbatCHIFM103.PRC_KMK_CD, tihPrckmkCd); // 料金項目コード outputMap.setString(JBSbatCHIFM103.ICJKN_PRC, dbMap.getString(JBSbatAC_T_ICJKN.ICJKN_PRC)); // 一時金料金 outputMap.setString(JBSbatCHIFM103.ICJKN_UPD_USER_ID, dbMap.getString(JBSbatAC_T_ICJKN.ICJKN_UPD_USER_ID)); // 一時金更新ユーザーＩＤ outputMap.setString(JBSbatCHIFM103.ICJKN_UPD_DTM, dbMap.getString(JBSbatAC_T_ICJKN.ICJKN_UPD_DTM)); // 一時金更新年月日時分秒 outputMap.setString(JBSbatCHIFM103.ICJKN_ADD_SEQ, dbMap.getString(JBSbatAC_T_ICJKN.ICJKN_ADD_SEQ)); // 一時金登録番号 outputMap.setString(JBSbatCHIFM103.ICJKN_UPD_SEQ, dbMap.getString(JBSbatAC_T_ICJKN.ICJKN_UPD_SEQ)); // 一時金更新枝番 outputMap.setString(JBSbatCHIFM103.TAISYO_DIV, tihTaisyoDiv); // 対処区分 // 出力フラグ設定 outputMap.setOutFlg(true); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][makeOutData][outputMap=" + outputMap.toString() + "]"); // 出力共通電文に設定 outMap.addOutMapList(outputMap); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeOutData]"); // 出力共通電文返却 return outMap; } /**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/ /** * SQLKEY(CH_SELECT_001)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	請求契約番号
	 *		 	請求年月
	 *		 	一時金種別コード
	 *		 	一時金種別コード
	 *		 	一時金取込ステータス
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeAC_T_ICJKN_CH_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()); paramList.setValue(param[3].toString()); paramList.setValue(param[4].toString()); // DBアクセスを実行します db_AC_T_ICJKN.selectBySqlDefine(paramList, AC_T_ICJKN_CH_SELECT_001); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }