/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatCHDpsitZanDataChsht * ソースファイル名 ：JBSbatCHDpsitZanDataChsht.java * 作成者 ：富士通　 * 作成日 ：2011/09/11 *＜機能概要＞ *　 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v1.00.00 2011/09/11 東海林 新規作成 * v4.00.00 2013/05/07 後藤 【TG1-2013-0000291】抽出条件変更 *********************************************************************/ package eo.business.service; import eo.business.common.JACbatDebugLogUtil; import eo.business.common.JACbatParamUtil; import eo.business.common.JBSbatBusinessService; import eo.business.util.file.JBSbatCHIFM106; import eo.business.util.table.JBSbatCH_M_PRC_KMK_CS_CHGE; import eo.business.util.table.JBSbatCH_T_KNK; import eo.common.constant.JACStrConst; import eo.common.constant.JPCBatchMessageConstant; import eo.framework.application.JBSbatBusinessException; 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; /** * (クラスの機能概要)

*
* @author 富士通 */ public class JBSbatCHDpsitZanDataChsht extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** テーブル(料金項目抽出変換)*/ private static final String D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE = "CH_M_PRC_KMK_CS_CHGE"; /** テーブル(金庫)*/ private static final String D_TBL_NAME_CH_T_KNK = "CH_T_KNK"; /** SQL定義キー(CH_SELECT_012)*/ private static final String CH_M_PRC_KMK_CS_CHGE_CH_SELECT_012 = "CH_SELECT_012"; /** SQL定義キー(CH_SELECT_004)*/ private static final String CH_T_KNK_CH_SELECT_004 = "CH_SELECT_004"; /** SQL定義キー(CH_SELECT_005)*/ private static final String CH_T_KNK_CH_SELECT_005 = "CH_SELECT_005"; /** SQL定義キー(CH_SELECT_009)*/ private static final String CH_T_KNK_CH_SELECT_009 = "CH_SELECT_009"; /** テーブルアクセスクラス(料金項目抽出変換)*/ private JBSbatSQLAccess db_CH_M_PRC_KMK_CS_CHGE = null; /** テーブルアクセスクラス(金庫)*/ private JBSbatSQLAccess db_CH_T_KNK = null; /** テーブルアクセスクラス(金庫)*/ private JBSbatSQLAccess db_CH_T_KNK_MOTO = null; /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /** 退避．料金項目コード（前受金） */ private String tihKmkCdMaeuk = null; /** 退避．料金項目コード（前受金充当） */ private String tihKmkCdMaeukJuto = null; /** 退避．料金項目コード（預り金） */ private String tihKmkCdAzukari = null; /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_CH_M_PRC_KMK_CS_CHGE = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_M_PRC_KMK_CS_CHGE); db_CH_T_KNK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_T_KNK); db_CH_T_KNK_MOTO = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CH_T_KNK); /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][opeDate=" + super.opeDate + "]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][freeItem=" + super.freeItem + "]"); // 業務機能識別コード取得 // パラメータ取得共通クラス JACbatParamUtil paramUtil = new JACbatParamUtil(commonItem); // 前受金 String workMaeukekn = paramUtil.getGyoumuParameter(JACStrConst.WKPRA_CH_WKS_MAEUK_AT); // 前受金充当 String workMaeukeknJuto = paramUtil.getGyoumuParameter(JACStrConst.WKPRA_CH_WKS_SRZ_MUK_AT_JT); // 預り金 String workAzukarikn = paramUtil.getGyoumuParameter(JACStrConst.WKPARA_CH_WKS_AZUKARI_AMNT); paramUtil.close(); // 料金項目コード取得 tihKmkCdMaeuk = getPrcKmkCdChsht(workMaeukekn); // 料金項目コード（前受金） tihKmkCdMaeukJuto = getPrcKmkCdChsht(workMaeukeknJuto); // 料金項目コード（前受金充当） tihKmkCdAzukari = getPrcKmkCdChsht(workAzukarikn); // 料金項目コード（預り金） assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]"); /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute() throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]"); // 出力共通電文生成 JBSbatOutputItem outputItem = new JBSbatOutputItem(); // 預り金抽出 currentChsht(tihKmkCdAzukari, outputItem); // 前受金充当・前受金（充当前）抽出 jutoChsht(outputItem); // 前受金抽出 currentChsht(tihKmkCdMaeuk, outputItem); 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_CH_M_PRC_KMK_CS_CHGE.close(); db_CH_T_KNK.close(); db_CH_T_KNK_MOTO.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]"); /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/ /** * SQLKEY(CH_SELECT_012)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	料金項目抽出変換．システムコード
	 *		 	料金項目抽出変換．業務機能識別コード
	 *		 	料金項目抽出変換．抽出変換コード
	 *		 	料金項目抽出変換．適用開始年月日
	 *		 	料金項目抽出変換．適用終了年月日
	 *
*

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

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	履歴データフラグ
	 *		 	金庫料金項目コード
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCH_T_KNK_CH_SELECT_005(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); // DBアクセスを実行します db_CH_T_KNK.selectBySqlDefine(paramList, CH_T_KNK_CH_SELECT_005); } /** * SQLKEY(CH_SELECT_009)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	金庫料金項目コード
	 *		 	金庫移動年月日
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCH_T_KNK_CH_SELECT_009(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); // DBアクセスを実行します db_CH_T_KNK.selectBySqlDefine(paramList, CH_T_KNK_CH_SELECT_009); } /** * SQLKEY(CH_SELECT_004)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	金庫番号
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCH_T_KNK_CH_SELECT_004(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); // DBアクセスを実行します db_CH_T_KNK_MOTO.selectBySqlDefine(paramList, CH_T_KNK_CH_SELECT_004); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** * 料金項目コードを返します。 * * @param workKinoSkbtCd 業務機能識別コード * @return String 料金項目コード * @throws Exception 業務サービス内で発生した例外全般 */ private String getPrcKmkCdChsht(String workKinoSkbtCd) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][getPrcKmkCdChsht]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getPrcKmkCdChsht][workKinoSkbtCd=" + workKinoSkbtCd + "]"); JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(JACStrConst.SYS_CD_CH); // 料金項目抽出変換．システムコード paramList.setValue(workKinoSkbtCd); // 料金項目抽出変換．業務機能識別コード paramList.setValue(JACStrConst.CHSHT_CHG_CD_CST); // 料金項目抽出変換．抽出変換コード（抽出のみ） paramList.setValue(super.opeDate); // 料金項目抽出変換．適用開始年月日 paramList.setValue(super.opeDate); // 料金項目抽出変換．適用終了年月日 assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getPrcKmkCdChsht][paramList=" + paramList.getList().toString() + "]"); // SQL実行 executeCH_M_PRC_KMK_CS_CHGE_CH_SELECT_012(paramList.getList().toArray()); JBSbatCommonDBInterface dbMap = db_CH_M_PRC_KMK_CS_CHGE.selectNext(); // 取得結果判定 if (dbMap == null) { // マスタ未存在エラー String[] msgParam = new String[] { JBSbatCH_M_PRC_KMK_CS_CHGE.TABLE_NAME, paramList.getList().toString() }; throw new JBSbatBusinessException(JPCBatchMessageConstant.ECHB0270CH, msgParam); } String prcKmkCd = dbMap.getString(JBSbatCH_M_PRC_KMK_CS_CHGE.PRC_KMK_CD); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][getPrcKmkCdChsht][dbMap=" + dbMap.getMap().toString() + "]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][getPrcKmkCdChsht]"); return prcKmkCd; } /** * 金庫からカレントデータを取得します。 * * @param prcKmkCd 金庫料金項目コード * @param outputItem 出力情報 * @throws Exception 業務サービス内で発生した例外全般 */ private void currentChsht(String prcKmkCd, JBSbatOutputItem outputItem) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][currentChsht]"); assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][currentChsht][prcKmkCd=" + prcKmkCd + "]"); JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(JACStrConst.KNK_RIREKI_DATA_FLG_CURRENT); // 履歴データフラグ paramList.setValue(prcKmkCd); // 金庫料金項目コード assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][jutoChsht][paramList=" + paramList.getList().toString() + "]"); executeCH_T_KNK_CH_SELECT_005(paramList.getList().toArray()); JBSbatCommonDBInterface dbMap = db_CH_T_KNK.selectNext(); while(dbMap != null) { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][currentChsht][dbMap=" + dbMap.getMap().toString() + "]"); makeOutMap(dbMap, outputItem); dbMap = db_CH_T_KNK.selectNext(); } assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][currentChsht]"); } /** * 前受金充当を取得します。 * * @param prcKmkCd 金庫料金項目コード * @param outputItem 出力情報 * @throws Exception 業務サービス内で発生した例外全般 */ private void jutoChsht(JBSbatOutputItem outputItem) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][jutoChsht]"); JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(super.opeDate); // 金庫移動年月日 paramList.setValue(tihKmkCdMaeukJuto); // 金庫料金項目コード assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][jutoChsht][paramList=" + paramList.getList().toString() + "]"); executeCH_T_KNK_CH_SELECT_009(paramList.getList().toArray()); JBSbatCommonDBInterface dbMap = db_CH_T_KNK.selectNext(); while(dbMap != null) { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][jutoChsht][dbMap=" + dbMap.getMap().toString() + "]"); makeOutMap(dbMap, outputItem); jutoMaeChsht(dbMap.getString(JBSbatCH_T_KNK.IDOMOTO_KNK_NO), outputItem); dbMap = db_CH_T_KNK.selectNext(); } assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][jutoChsht]"); } /** * 充当前の前受金を取得します。 * * @param prcKmkCd 金庫料金項目コード * @param outputItem 出力情報 * @throws Exception 業務サービス内で発生した例外全般 */ private void jutoMaeChsht(String idomotoKnkNo, JBSbatOutputItem outputItem) throws Exception { assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][jutoMaeChsht]"); JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(idomotoKnkNo); // 移動元金庫番号 assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][jutoChsht][paramList=" + paramList.getList().toString() + "]"); executeCH_T_KNK_CH_SELECT_004(paramList.getList().toArray()); JBSbatCommonDBInterface dbMap = db_CH_T_KNK_MOTO.selectNext(); if(dbMap == null) { // 出力件数ログ出力 String[] msgParam = new String[]{JBSbatCH_T_KNK.TABLE_NAME, JBSbatCH_T_KNK.KNK_NO + "：" + idomotoKnkNo}; super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.ECHB0240CW, msgParam); } else { makeOutMap(dbMap, outputItem); } assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][jutoMaeChsht]"); } /** * 出力情報を生成します。 * * @param dbMap * @param outputItem * @throws Exception */ private void makeOutMap(JBSbatCommonDBInterface dbMap, JBSbatOutputItem outputItem) throws Exception { // 入出力オブジェクト生成 JBSbatServiceInterfaceMap outputMap = new JBSbatServiceInterfaceMap(); // 項目設定 outputMap.setString(JBSbatCHIFM106.KNK_NO, dbMap.getString(JBSbatCH_T_KNK.KNK_NO)); // 金庫番号 outputMap.setString(JBSbatCHIFM106.GENE_ADD_DTM, dbMap.getString(JBSbatCH_T_KNK.GENE_ADD_DTM)); // 世代登録年月日時分秒 outputMap.setString(JBSbatCHIFM106.KNK_PRC_KMK_CD, dbMap.getString(JBSbatCH_T_KNK.KNK_PRC_KMK_CD)); // 金庫料金項目コード outputMap.setString(JBSbatCHIFM106.KNK_MOVE_DIV, dbMap.getString(JBSbatCH_T_KNK.KNK_MOVE_CD)); // 金庫移動区分 outputMap.setString(JBSbatCHIFM106.SEIKY_KEI_NO, dbMap.getString(JBSbatCH_T_KNK.SEIKY_KEI_NO)); // 請求契約番号 outputMap.setString(JBSbatCHIFM106.NYUKIN_NO, dbMap.getString(JBSbatCH_T_KNK.NYUKIN_NO)); // 入金番号 outputMap.setString(JBSbatCHIFM106.KNK_AMNT, dbMap.getString(JBSbatCH_T_KNK.KNK_AMNT)); // 金庫金額 outputMap.setString(JBSbatCHIFM106.RIREKI_DATA_FLG, dbMap.getString(JBSbatCH_T_KNK.RIREKI_DATA_FLG)); // 履歴データフラグ // 出力フラグ設定 outputMap.setOutFlg(true); // 出力共通電文に設定 outputItem.addOutMapList(outputMap); } }