/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatKUFcdsOltSetChgRspCst * ソースファイル名 ：JBSbatKUFcdsOltSetChgRspCst.java * 作成者 ：富士通　 * 作成日 ：2012年05月14日 *＜機能概要＞ *　ＦＣＤＳＯＬＴ設定変更応答済抽出部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v1.00.00 2012/05/14 富士通 新規作成 *********************************************************************/ package eo.business.service; import java.util.HashMap; import eo.business.common.JBSbatBusinessService; import eo.business.common.JKUBatCommon; import eo.business.util.file.JBSbatKKIFI023; import eo.business.util.file.JBSbatKUIFM003; import eo.business.util.table.JBSbatKU_T_KJAK_EOH_NET; import eo.business.util.table.JBSbatKU_T_KJAK_EOH_NTMANS; import eo.business.util.table.JBSbatKU_T_OLT_SETE_CHG; import eo.business.util.table.JBSbatKU_T_SVKEI_KOJIAK; import eo.common.constant.JKUStrConst; import eo.common.constant.JPCBatchMessageConstant; import eo.framework.item.JBSbatCommonItem; import eo.framework.item.JBSbatServiceInterfaceMap; import eo.framework.item.JBSbatOutputItem; import eo.framework.item.JBSbatCommonDBInterface; import eo.framework.application.JBSbatBusinessError; import eo.framework.db.JBSbatSQLAccess; /** * ＦＣＤＳＯＬＴ設定変更応答済抽出部品

*
* @author 富士通 */ public class JBSbatKUFcdsOltSetChgRspCst extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** テーブル(工事案件)*/ private static final String D_TBL_NAME_KU_T_KOJIAK = "KU_T_KOJIAK"; /** テーブル(サービス契約＿工事案件)*/ private static final String D_TBL_NAME_KU_T_SVKEI_KOJIAK = "KU_T_SVKEI_KOJIAK"; /** テーブル(工事案件＜ｅｏ光ネット＞)*/ private static final String D_TBL_NAME_KU_T_KJAK_EOH_NET = "KU_T_KJAK_EOH_NET"; /** テーブル(工事案件＜ｅｏ光ネットマンション＞)*/ private static final String D_TBL_NAME_KU_T_KJAK_EOH_NTMANS = "KU_T_KJAK_EOH_NTMANS"; /** テーブル(ＯＬＴ設定変更)*/ private static final String D_TBL_NAME_KU_T_OLT_SETE_CHG = "KU_T_OLT_SETE_CHG"; /** テーブルアクセスクラス(工事案件)*/ private JBSbatSQLAccess db_KU_T_KOJIAK = null; /** テーブルアクセスクラス(サービス契約＿工事案件)*/ private JBSbatSQLAccess db_KU_T_SVKEI_KOJIAK = null; /** テーブルアクセスクラス(工事案件＜ｅｏ光ネット＞)*/ private JBSbatSQLAccess db_KU_T_KJAK_EOH_NET = null; /** テーブルアクセスクラス(工事案件＜ｅｏ光ネットマンション＞)*/ private JBSbatSQLAccess db_KU_T_KJAK_EOH_NTMANS = null; /** テーブルアクセスクラス(ＯＬＴ設定変更)*/ private JBSbatSQLAccess db_KU_T_OLT_SETE_CHG = null; /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /**▼▼▼▼▼▼業務が作成した宣言です 開始▼▼▼▼▼▼*/ /** 通番項目に設定される定数 */ private static final String SEQ_ZERO = "000000000000"; /** 金額項目に設定される定数 */ private static final String PRICE_ZERO = "0"; /** 工事関連情報の項目名Map */ private HashMap indexKjKrInfoMap = new HashMap(); /**▲▲▲▲▲▲業務が作成した宣言です 終了▲▲▲▲▲▲*/ /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_KU_T_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KOJIAK); db_KU_T_SVKEI_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_SVKEI_KOJIAK); db_KU_T_KJAK_EOH_NET = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KJAK_EOH_NET); db_KU_T_KJAK_EOH_NTMANS = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KJAK_EOH_NTMANS); db_KU_T_OLT_SETE_CHG = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_OLT_SETE_CHG); /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @param inMap　入力電文 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ // 出力共通電文を生成する。 JBSbatOutputItem outputBean = new JBSbatOutputItem(); // 入出力インターフェースオブジェクトを生成 JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap(); // カンマ編集された工事関連情報を格納する変数 StringBuilder kjKrInfoString = null; // 工事関連情報の項目名Mapを取得 indexKjKrInfoMap = setIndexKjKrInfoMap(); // ＯＬＴ設定変更より工事案件番号を取得 String kojiakNo = inMap.getString(JBSbatKU_T_OLT_SETE_CHG.KOJIAK_NO); if(kojiakNo == null) { // ログ出力し、次レコードへ super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKUB0650KW, new String[]{ JKUStrConst.SCHEMANM_KU0211, "工事案件番号", kojiakNo}); throw new JBSbatBusinessError(); } // バインド変数を設定 Object[] kojiakParam = new Object[1]; kojiakParam[0] = kojiakNo; // 工事案件プライマリーキー検索結果を取得するためのMap JBSbatCommonDBInterface kojiakMap = new JBSbatCommonDBInterface(); // 工事案件検索結果を１件取得する kojiakMap = this.executeKU_T_KOJIAK_PKSELECT(kojiakParam); // 工事案件存在チェック if(kojiakMap == null) { // 工事案件に該当の工事案件番号が存在しません。（00000000） commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKUB0650KW, new String[]{ JKUStrConst.SCHEMANM_KU0011, "工事案件番号", kojiakNo}); // 次レコードへ throw new JBSbatBusinessError(); } // ＯＬＴ設定変更よりサービス契約番号を取得 String svckeiNo = inMap.getString(JBSbatKU_T_OLT_SETE_CHG.SVC_KEI_NO); // バインド変数を設定 Object[] svckeiKjakParam = new Object[2]; svckeiKjakParam[0] = svckeiNo; svckeiKjakParam[1] = kojiakNo; // サービス契約＿工事案件プライマリーキー検索結果を取得するためのMap JBSbatCommonDBInterface svckeiKjakMap = new JBSbatCommonDBInterface(); // サービス契約＿工事案件検索結果を１件取得する svckeiKjakMap = this.executeKU_T_SVKEI_KOJIAK_PKSELECT(svckeiKjakParam); // サービス契約_工事案件存在チェック if(svckeiKjakMap == null) { // サービス契約_工事案件に該当の工事案件番号が存在しません。（00000000） commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKUB0650KW, new String[]{ JKUStrConst.SCHEMANM_KU0081, "工事案件番号", kojiakNo}); // 次レコードへ throw new JBSbatBusinessError(); } // 工事案件サブスキーマより、工事範囲コードを取得する String kojiScopeCd = getKojiScopeCd(kojiakNo); // 工事関連情報を格納するマップを作成 JBSbatServiceInterfaceMap kjKrInfoMap = new JBSbatServiceInterfaceMap(); // レコード区分 kjKrInfoMap.set(JBSbatKUIFM003.REC_KBN, JKUStrConst.KKIFI023_KOJI_FIN); // サービス契約番号 kjKrInfoMap.set(JBSbatKUIFM003.SVC_KEI_NO, svckeiNo); // サービス契約回線内訳番号 kjKrInfoMap.set(JBSbatKUIFM003.SVC_KEI_KAISEN_UCWK_NO, svckeiKjakMap.getString(JBSbatKU_T_SVKEI_KOJIAK.SVC_KEI_KAISEN_UCWK_NO)); // 連携年月日 kjKrInfoMap.set(JBSbatKUIFM003.RENKEI_YMD, inMap.getString(JBSbatKU_T_OLT_SETE_CHG.RNKS_RSP_DTM).substring(0, 8)); // 通番 kjKrInfoMap.set(JBSbatKUIFM003.SEQ, SEQ_ZERO); // 新規変更区分 kjKrInfoMap.set(JBSbatKUIFM003.NEW_CHG_DIV, null); // 工事案件種別コード kjKrInfoMap.set(JBSbatKUIFM003.KOJIAK_SBT_CD, kojiakMap.getString(JBSbatKU_T_OLT_SETE_CHG.KOJIAK_SBT_CD)); // 工事案件番号 kjKrInfoMap.set(JBSbatKUIFM003.KOJIAK_NO, kojiakNo); // 項目１ 工事案件結果コード kjKrInfoMap.set(JBSbatKUIFM003.KMK_1, inMap.getString(JBSbatKU_T_OLT_SETE_CHG.SETTE_RSLT_CD)); // 項目２ 工事案件実施年月日 kjKrInfoMap.set(JBSbatKUIFM003.KMK_2, inMap.getString(JBSbatKU_T_OLT_SETE_CHG.RNKS_RSP_DTM).substring(0, 8)); // 項目３ PON識別コード kjKrInfoMap.set(JBSbatKUIFM003.KMK_3, null); // 項目４ 工事金額（標準） kjKrInfoMap.set(JBSbatKUIFM003.KMK_4, PRICE_ZERO); // 項目５ 工事金額（標準外） kjKrInfoMap.set(JBSbatKUIFM003.KMK_5, PRICE_ZERO); // 項目６ 工事金額（標準）電話宅内工事費用 kjKrInfoMap.set(JBSbatKUIFM003.KMK_6, PRICE_ZERO); // 項目７ 工事金額（標準外）電話宅内工事費用 kjKrInfoMap.set(JBSbatKUIFM003.KMK_7, PRICE_ZERO); // 項目８ 工事金額（標準）宅内工事（LAN）費用 kjKrInfoMap.set(JBSbatKUIFM003.KMK_8, PRICE_ZERO); // 項目９ 工事金額（標準外）宅内工事（LAN）費用 kjKrInfoMap.set(JBSbatKUIFM003.KMK_9, PRICE_ZERO); // 項目１０ 工事範囲コード kjKrInfoMap.set(JBSbatKUIFM003.KMK_10, kojiScopeCd); // 括り文字付与 kjKrInfoMap.setMap(JKUBatCommon.addDblQuote(kjKrInfoMap.getMap())); // KjKrInfoMapに格納された各項目のカンマ編集を行う kjKrInfoString = JKUBatCommon.editComma(kjKrInfoMap, indexKjKrInfoMap); // 入出力インターフェースに工事関連情報を設定する outMap.setString(JBSbatKKIFI023.KOJI_KNRN_INFO, kjKrInfoString); // 出力フラグを設定 outMap.setOutFlg(true); // 出力共通電文に入出力インターフェースを設定する。 outputBean.addOutMapList(outMap); // ＯＬＴ設定変更更新処理 // 更新する値を設定 Object[] setParam = new Object[1]; // 「否」を設定 setParam[0] = JKUStrConst.KH_FAIL; // 更新する条件を設定 Object[] whereParam = new Object[1]; whereParam[0] = inMap.getString(JBSbatKU_T_OLT_SETE_CHG.OLT_SET_CHGE_NO); // 更新処理実行 executeKU_T_OLT_SETE_CHG_PKUPDATE(setParam, whereParam); return outputBean; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_KU_T_KOJIAK.close(); db_KU_T_SVKEI_KOJIAK.close(); db_KU_T_KJAK_EOH_NET.close(); db_KU_T_KJAK_EOH_NTMANS.close(); db_KU_T_OLT_SETE_CHG.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/ /** * PK(ＰＫ　検索)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数で条件マップを作ります。

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

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

	 *		引数:
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	KOJIAK_NO
	 *
*

* @param whereParam 条件項目の値。 * @return JBSbatCommonDBInterface 検索の結果。 * @throws Exception 業務サービス内で発生した例外全般。 */ private JBSbatCommonDBInterface executeKU_T_KOJIAK_PKSELECT(Object[] whereParam) throws Exception { // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("KOJIAK_NO", whereParam[0]); // DBアクセスを実行します return db_KU_T_KOJIAK.selectByPrimaryKeys(whereMap); } /** * PK(ＰＫ　検索)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数で条件マップを作ります。

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

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

	 *		引数:
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	SVC_KEI_NO
	 *		 	KOJIAK_NO
	 *
*

* @param whereParam 条件項目の値。 * @return JBSbatCommonDBInterface 検索の結果。 * @throws Exception 業務サービス内で発生した例外全般。 */ private JBSbatCommonDBInterface executeKU_T_SVKEI_KOJIAK_PKSELECT(Object[] whereParam) throws Exception { // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("SVC_KEI_NO", whereParam[0]); whereMap.setValue("KOJIAK_NO", whereParam[1]); // DBアクセスを実行します return db_KU_T_SVKEI_KOJIAK.selectByPrimaryKeys(whereMap); } /** * PK(ＰＫ　検索)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数で条件マップを作ります。

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

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

	 *		引数:
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	KOJIAK_NO
	 *
*

* @param whereParam 条件項目の値。 * @return JBSbatCommonDBInterface 検索の結果。 * @throws Exception 業務サービス内で発生した例外全般。 */ private JBSbatCommonDBInterface executeKU_T_KJAK_EOH_NET_PKSELECT(Object[] whereParam) throws Exception { // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("KOJIAK_NO", whereParam[0]); // DBアクセスを実行します return db_KU_T_KJAK_EOH_NET.selectByPrimaryKeys(whereMap); } /** * PK(ＰＫ　検索)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数で条件マップを作ります。

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

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

	 *		引数:
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	KOJIAK_NO
	 *
*

* @param whereParam 条件項目の値。 * @return JBSbatCommonDBInterface 検索の結果。 * @throws Exception 業務サービス内で発生した例外全般。 */ private JBSbatCommonDBInterface executeKU_T_KJAK_EOH_NTMANS_PKSELECT(Object[] whereParam) throws Exception { // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("KOJIAK_NO", whereParam[0]); // DBアクセスを実行します return db_KU_T_KJAK_EOH_NTMANS.selectByPrimaryKeys(whereMap); } /** * PK(ＰＫ　更新)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数で設定項目マップを作ります。

	 *
	 * 2.引数で条件マップを作ります。

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

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

	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	完了結果連携要否				FIN_RSLT_RENKEI_YH
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	OLT_SET_CHGE_NO
	 *
*

* @param setParam 設定項目の値。 * @param whereParam 条件項目の値。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKU_T_OLT_SETE_CHG_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception { // 設定値のマップを作成します JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("FIN_RSLT_RENKEI_YH", setParam[0]); // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("OLT_SET_CHGE_NO", whereParam[0]); // DBアクセスを実行します db_KU_T_OLT_SETE_CHG.updateByPrimaryKeys(whereMap, setMap); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /**▼▼▼▼▼▼業務が作成したメソッドです 開始▼▼▼▼▼▼*/ /** * 工事案件＜eo光ネットマンション＞または工事案件＜eo光ネット＞から工事範囲コードを取得します * @param kojiakNo 工事案件番号 * @return 工事範囲コード * @throws Exception */ private String getKojiScopeCd(String kojiakNo) throws Exception { String[] whereParam = new String[1]; whereParam[0] = kojiakNo; String kojiScopeCd = null; // ---工事案件サブスキーマの検索を実行する // 工事案件＜eo光ネットマンション＞ JBSbatCommonDBInterface ku0061DBI = executeKU_T_KJAK_EOH_NTMANS_PKSELECT(whereParam); // 工事案件＜eo光ネット＞ JBSbatCommonDBInterface ku0021DBI = executeKU_T_KJAK_EOH_NET_PKSELECT(whereParam); // ---サブスキーマに不整合がある場合のエラー処理 // 両方存在しない場合 if (null == ku0061DBI && null == ku0021DBI) { // ログ出力し、次レコードへ // %1%に該当の%2%が存在しません。（%3%） commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKUB0650KW, new String[]{ JKUStrConst.SCHEMANM_KU0021 + "と" + JKUStrConst.SCHEMANM_KU0061, "工事案件番号", whereParam[0]}); throw new JBSbatBusinessError(); } // 両方存在する場合 if (null != ku0061DBI && null != ku0021DBI) { // ログ出力し、次レコードへ // 一意のはずの%1%が%2%に複数あります。(%3%) commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EKUB0440KE, new String[]{ "工事案件番号", JKUStrConst.SCHEMANM_KU0021 + "と" + JKUStrConst.SCHEMANM_KU0061, whereParam[0]}); throw new JBSbatBusinessError(); } // ---工事範囲コードを取得する // 工事案件＜eo光ネットマンション＞ if (null != ku0061DBI) { kojiScopeCd = ku0061DBI.getString(JBSbatKU_T_KJAK_EOH_NTMANS.KOJI_SCOPE_CD); } else // 工事案件＜eo光ネット＞ { kojiScopeCd = ku0021DBI.getString(JBSbatKU_T_KJAK_EOH_NET.KOJI_SCOPE_CD); } return kojiScopeCd; } /** * 工事関連情報の項目名Mapを設定します。 * @return 工事関連情報の項目名Map */ private HashMap setIndexKjKrInfoMap() { this.indexKjKrInfoMap.put(0, JBSbatKUIFM003.REC_KBN); this.indexKjKrInfoMap.put(1, JBSbatKUIFM003.SVC_KEI_NO); this.indexKjKrInfoMap.put(2, JBSbatKUIFM003.SVC_KEI_KAISEN_UCWK_NO); this.indexKjKrInfoMap.put(3, JBSbatKUIFM003.RENKEI_YMD); this.indexKjKrInfoMap.put(4, JBSbatKUIFM003.SEQ); this.indexKjKrInfoMap.put(5, JBSbatKUIFM003.NEW_CHG_DIV); this.indexKjKrInfoMap.put(6, JBSbatKUIFM003.KOJIAK_SBT_CD); this.indexKjKrInfoMap.put(7, JBSbatKUIFM003.KOJIAK_NO); this.indexKjKrInfoMap.put(8, JBSbatKUIFM003.KMK_1); this.indexKjKrInfoMap.put(9, JBSbatKUIFM003.KMK_2); this.indexKjKrInfoMap.put(10, JBSbatKUIFM003.KMK_3); this.indexKjKrInfoMap.put(11, JBSbatKUIFM003.KMK_4); this.indexKjKrInfoMap.put(12, JBSbatKUIFM003.KMK_5); this.indexKjKrInfoMap.put(13, JBSbatKUIFM003.KMK_6); this.indexKjKrInfoMap.put(14, JBSbatKUIFM003.KMK_7); this.indexKjKrInfoMap.put(15, JBSbatKUIFM003.KMK_8); this.indexKjKrInfoMap.put(16, JBSbatKUIFM003.KMK_9); this.indexKjKrInfoMap.put(17, JBSbatKUIFM003.KMK_10); return indexKjKrInfoMap; } /**▲▲▲▲▲▲業務が作成したメソッドです 終了▲▲▲▲▲▲*/ }