/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatSCEMSODRsltHojinCss * ソースファイル名 ：JBSbatSCEMSODRsltHojinCss.java * 作成者 ：富士通　 * 作成日 ：2011年08月25日 *＜機能概要＞ *　イー・モバイルSOD結果(法人)抽出部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v1.00.00 2011/08/25 富士通 新規作成 *********************************************************************/ package eo.business.service; import eo.business.common.JBSbatBusinessService; import eo.business.common.JCCBatCommon; import eo.common.constant.JSCStrConstant; 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; import eo.framework.application.JBSbatBusinessException; /** * (クラスの機能概要)

*
* @author 富士通 */ public class JBSbatSCEMSODRsltHojinCst extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** テーブル(モバイルオーダ)*/ private static final String D_TBL_NAME_SC_T_MOBILE_ORDER = "SC_T_MOBILE_ORDER"; /** テーブル(ＥＭオーダ送受信情報)*/ private static final String D_TBL_NAME_SC_T_EM_ODR_SRINF = "SC_T_EM_ODR_SRINF"; /** テーブルアクセスクラス(モバイルオーダ)*/ private JBSbatSQLAccess db_SC_T_MOBILE_ORDER = null; /** テーブルアクセスクラス(ＥＭオーダ送受信情報)*/ private JBSbatSQLAccess db_SC_T_EM_ODR_SRINF = null; /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_SC_T_MOBILE_ORDER = new JBSbatSQLAccess(commonItem, D_TBL_NAME_SC_T_MOBILE_ORDER); db_SC_T_EM_ODR_SRINF = new JBSbatSQLAccess(commonItem, D_TBL_NAME_SC_T_EM_ODR_SRINF); /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @param inMap　入力電文 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ logPrint.printDebugLog("JBSbatSCEMSODRsltHojinCst#execute start"); // 出力共通電文を生成する JBSbatOutputItem outputBean = new JBSbatOutputItem(); // 入出力インターフェースオブジェクトを生成 JBSbatServiceInterfaceMap outmap1 = new JBSbatServiceInterfaceMap(); JBSbatServiceInterfaceMap outmap2 = new JBSbatServiceInterfaceMap(); // モバイルオーダテーブルのレコードロックの取得 JBSbatCommonDBInterface whereMap = null; JBSbatCommonDBInterface resultMap = null; whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("MOBILE_ORDER_NO", inMap.getString("SOD_RENKEI_SEQ")); resultMap = db_SC_T_MOBILE_ORDER.selectByPrimaryKeysForUpdateWait(whereMap); if(resultMap == null) { super.logPrint.printDebugLog("モバイルオーダテーブルにレコードが存在しません。"); throw new JBSbatBusinessException("ESCB0100CE", new String[] {inMap.getString("SVC_KEI_NO"), inMap.getString("EM_KEISHA_CD"), D_TBL_NAME_SC_T_MOBILE_ORDER}); } String sTrnDate = ""; String sTrnTime = ""; String sRsltCd = ""; if(inMap.getString("SOD_RSLT_ADD_DTM") != null) { sTrnDate = inMap.getString("SOD_RSLT_ADD_DTM").substring(0, 8); sTrnTime = inMap.getString("SOD_RSLT_ADD_DTM").substring(8, 14); } if(inMap.getString("SOD_TRAN_RSLT_DTAIL_CD") != null) { sRsltCd = inMap.getString("SOD_TRAN_RSLT_DTAIL_CD").substring(0, 4); } // ファイル出力 if(JSCStrConstant.MOBILE_ODER_CD_CHG.equals(inMap.getString("MOBILE_ORDER_CD"))) // モバイル要求種別コード { // モバイルオーダコードが課金 //課金受付結果 outmap1.setString("EM_REC_SBT_CD", JSCStrConstant.EM_RECORD_TYPE_BODY); //レコードタイプ outmap1.setString("MOBILE_YOKYU_SBT_CD", JSCStrConstant.MOBILE_YOKYU_CHRG_UK_RSLT); //モバイル要求種別コード outmap1.setString("SVC_KEI_NO", inMap.getString("SVC_KEI_NO")); //サービス契約番号 outmap1.setString("YOBI_2", ""); //予備2 outmap1.setString("YOBI_3", ""); //予備3 outmap1.setString("YOBI_4", ""); //予備4 outmap1.setString("EM_KEISHA_CD", inMap.getString("EM_KEISHA_CD")); //EM契約者コード outmap1.setString("YOBI_5", ""); //予備5 outmap1.setString("EM_SET_YMD_1", inMap.getString("EM_SET_YMD_1")); //EM設定年月日1 outmap1.setString("EM_SET_YMD_2", ""); //EM設定年月日2 outmap1.setString("EM_SET_YMD_3", ""); //EM設定年月日3 outmap1.setString("UK_TRAN_RSLT_CD", sRsltCd); //受付処理結果コード outmap1.setString("TRN_DATE", ""); //異動日付 outmap1.setString("TRN_TIME", ""); //異動時刻 outmap1.setString("RENBAN", ""); //予備7 //課金情報 outmap2.setString("EM_REC_SBT_CD", JSCStrConstant.EM_RECORD_TYPE_BODY); //レコードタイプ outmap2.setString("MOBILE_YOKYU_SBT_CD", JSCStrConstant.MOBILE_YOKYU_CHRG_UK_INFO); //モバイル要求種別コード outmap2.setString("SVC_KEI_NO", inMap.getString("SVC_KEI_NO")); //サービス契約番号 outmap2.setString("YOBI_2", ""); //予備2 outmap2.setString("YOBI_3", ""); //予備3 outmap2.setString("YOBI_4", ""); //予備4 outmap2.setString("EM_KEISHA_CD", inMap.getString("EM_KEISHA_CD")); //EM契約者コード outmap2.setString("YOBI_5", ""); //予備5 outmap2.setString("EM_SET_YMD_1", inMap.getString("EM_SET_YMD_1")); //EM設定年月日1 outmap2.setString("EM_SET_YMD_2", inMap.getString("EM_SET_YMD_2")); //EM設定年月日2 outmap2.setString("EM_SET_YMD_3", ""); //EM設定年月日3 outmap2.setString("UK_TRAN_RSLT_CD", ""); //受付処理結果コード outmap2.setString("TRN_DATE", sTrnDate); //異動日付 outmap2.setString("TRN_TIME", sTrnTime); //異動時刻 outmap2.setString("RENBAN", ""); //予備7 } else if(JSCStrConstant.MOBILE_ODER_CD_DSL.equals(inMap.getString("MOBILE_ORDER_CD"))) { // モバイルオーダコードが解約 //解約受付結果 outmap1.setString("EM_REC_SBT_CD", JSCStrConstant.EM_RECORD_TYPE_BODY); //レコードタイプ outmap1.setString("MOBILE_YOKYU_SBT_CD", JSCStrConstant.MOBILE_YOKYU_DSL_UK_RSLT); //モバイル要求種別コード outmap1.setString("SVC_KEI_NO", inMap.getString("SVC_KEI_NO")); //サービス契約番号 outmap1.setString("YOBI_2", ""); //予備2 outmap1.setString("YOBI_3", ""); //予備3 outmap1.setString("YOBI_4", ""); //予備4 outmap1.setString("EM_KEISHA_CD", inMap.getString("EM_KEISHA_CD")); //EM契約者コード outmap1.setString("YOBI_5", ""); //予備5 outmap1.setString("EM_SET_YMD_1", ""); //EM設定年月日1 outmap1.setString("EM_SET_YMD_2", ""); //EM設定年月日2 outmap1.setString("EM_SET_YMD_3", ""); //EM設定年月日3 outmap1.setString("UK_TRAN_RSLT_CD", sRsltCd); //受付処理結果コード outmap1.setString("TRN_DATE", ""); //異動日付 outmap1.setString("TRN_TIME", ""); //異動時刻 outmap1.setString("RENBAN", ""); //予備7 //解約情報 outmap2.setString("EM_REC_SBT_CD", JSCStrConstant.EM_RECORD_TYPE_BODY); //レコードタイプ outmap2.setString("MOBILE_YOKYU_SBT_CD", JSCStrConstant.MOBILE_YOKYU_DSL_UK_INFO); //モバイル要求種別コード outmap2.setString("SVC_KEI_NO", inMap.getString("SVC_KEI_NO")); //サービス契約番号 outmap2.setString("YOBI_2", ""); //予備2 outmap2.setString("YOBI_3", ""); //予備3 outmap2.setString("YOBI_4", ""); //予備4 outmap2.setString("EM_KEISHA_CD", inMap.getString("EM_KEISHA_CD")); //EM契約者コード outmap2.setString("YOBI_5", ""); //予備5 outmap2.setString("EM_SET_YMD_1", ""); //EM設定年月日1 outmap2.setString("EM_SET_YMD_2", inMap.getString("EM_SET_YMD_2")); //EM設定年月日2 outmap2.setString("EM_SET_YMD_3", inMap.getString("EM_SET_YMD_3")); //EM設定年月日3 outmap2.setString("UK_TRAN_RSLT_CD", ""); //受付処理結果コード outmap2.setString("TRN_DATE", sTrnDate); //異動日付 outmap2.setString("TRN_TIME", sTrnTime); //異動時刻 outmap2.setString("RENBAN", ""); //予備7 } else if(JSCStrConstant.MOBILE_ODER_CD_STP.equals(inMap.getString("MOBILE_ORDER_CD"))) { // モバイルオーダコードが一時中断 //一時中断受付結果 outmap1.setString("EM_REC_SBT_CD", JSCStrConstant.EM_RECORD_TYPE_BODY); //レコードタイプ outmap1.setString("MOBILE_YOKYU_SBT_CD", JSCStrConstant.MOBILE_YOKYU_TMP_STP_UK_RSLT); //モバイル要求種別コード outmap1.setString("SVC_KEI_NO", inMap.getString("SVC_KEI_NO")); //サービス契約番号 outmap1.setString("YOBI_2", ""); //予備2 outmap1.setString("YOBI_3", ""); //予備3 outmap1.setString("YOBI_4", ""); //予備4 outmap1.setString("EM_KEISHA_CD", inMap.getString("EM_KEISHA_CD")); //EM契約者コード outmap1.setString("YOBI_5", ""); //予備5 outmap1.setString("EM_SET_YMD_1", ""); //EM設定年月日1 outmap1.setString("EM_SET_YMD_2", ""); //EM設定年月日2 outmap1.setString("EM_SET_YMD_3", ""); //EM設定年月日3 outmap1.setString("UK_TRAN_RSLT_CD", sRsltCd); //受付処理結果コード outmap1.setString("TRN_DATE", ""); //異動日付 outmap1.setString("TRN_TIME", ""); //異動時刻 outmap1.setString("RENBAN", ""); //予備7 //一時中断情報 outmap2.setString("EM_REC_SBT_CD", JSCStrConstant.EM_RECORD_TYPE_BODY); //レコードタイプ outmap2.setString("MOBILE_YOKYU_SBT_CD", JSCStrConstant.MOBILE_YOKYU_TMP_STP_UK_INFO); //モバイル要求種別コード outmap2.setString("SVC_KEI_NO", inMap.getString("SVC_KEI_NO")); //サービス契約番号 outmap2.setString("YOBI_2", ""); //予備2 outmap2.setString("YOBI_3", ""); //予備3 outmap2.setString("YOBI_4", ""); //予備4 outmap2.setString("EM_KEISHA_CD", inMap.getString("EM_KEISHA_CD")); //EM契約者コード outmap2.setString("YOBI_5", ""); //予備5 outmap2.setString("EM_SET_YMD_1", ""); //EM設定年月日1 outmap2.setString("EM_SET_YMD_2", inMap.getString("EM_SET_YMD_2")); //EM設定年月日2 outmap2.setString("EM_SET_YMD_3", ""); //EM設定年月日3 outmap2.setString("UK_TRAN_RSLT_CD", ""); //受付処理結果コード outmap2.setString("TRN_DATE", sTrnDate); //異動日付 outmap2.setString("TRN_TIME", sTrnTime); //異動時刻 outmap2.setString("RENBAN", ""); //予備7 } else if(JSCStrConstant.MOBILE_ODER_CD_RLS.equals(inMap.getString("MOBILE_ORDER_CD"))) { // モバイルオーダコードが中断解除 //中断解除受付結果 outmap1.setString("EM_REC_SBT_CD", JSCStrConstant.EM_RECORD_TYPE_BODY); //レコードタイプ outmap1.setString("MOBILE_YOKYU_SBT_CD", JSCStrConstant.MOBILE_YOKYU_STP_RLS_UK_RSLT); //モバイル要求種別コード outmap1.setString("SVC_KEI_NO", inMap.getString("SVC_KEI_NO")); //サービス契約番号 outmap1.setString("YOBI_2", ""); //予備2 outmap1.setString("YOBI_3", ""); //予備3 outmap1.setString("YOBI_4", ""); //予備4 outmap1.setString("EM_KEISHA_CD", inMap.getString("EM_KEISHA_CD")); //EM契約者コード outmap1.setString("YOBI_5", ""); //予備5 outmap1.setString("EM_SET_YMD_1", ""); //EM設定年月日1 outmap1.setString("EM_SET_YMD_2", ""); //EM設定年月日2 outmap1.setString("EM_SET_YMD_3", ""); //EM設定年月日3 outmap1.setString("UK_TRAN_RSLT_CD", sRsltCd); //受付処理結果コード outmap1.setString("TRN_DATE", ""); //異動日付 outmap1.setString("TRN_TIME", ""); //異動時刻 outmap1.setString("RENBAN", ""); //予備7 //中断解除情報 outmap2.setString("EM_REC_SBT_CD", JSCStrConstant.EM_RECORD_TYPE_BODY); //レコードタイプ outmap2.setString("MOBILE_YOKYU_SBT_CD", JSCStrConstant.MOBILE_YOKYU_STP_RLS_UK_INFO); //モバイル要求種別コード outmap2.setString("SVC_KEI_NO", inMap.getString("SVC_KEI_NO")); //サービス契約番号 outmap2.setString("YOBI_2", ""); //予備2 outmap2.setString("YOBI_3", ""); //予備3 outmap2.setString("YOBI_4", ""); //予備4 outmap2.setString("EM_KEISHA_CD", inMap.getString("EM_KEISHA_CD")); //EM契約者コード outmap2.setString("YOBI_5", ""); //予備5 outmap2.setString("EM_SET_YMD_1", ""); //EM設定年月日1 outmap2.setString("EM_SET_YMD_2", inMap.getString("EM_SET_YMD_2")); //EM設定年月日2 outmap2.setString("EM_SET_YMD_3", ""); //EM設定年月日3 outmap2.setString("UK_TRAN_RSLT_CD", ""); //受付処理結果コード outmap2.setString("TRN_DATE", sTrnDate); //異動日付 outmap2.setString("TRN_TIME", sTrnTime); //異動時刻 outmap2.setString("RENBAN", ""); //予備7 } /** 受付結果、情報データ出力判定 */ // 受付処理結果コードが設定 if (JCCBatCommon.isNotNull(sRsltCd)) { // 受付結果データ outmap1.setOutFlg(true); outputBean.addOutMapList(outmap1); if (JSCStrConstant.SOD_TRAN_RSLT_CD_NORMAL.equals(sRsltCd)) { // 情報データ outmap2.setOutFlg(true); outputBean.addOutMapList(outmap2); } } // 受付処理結果コードが未設定 else { // 情報データのみ outmap2.setOutFlg(true); outputBean.addOutMapList(outmap2); } // EM送受信テーブルのアップデート // パラメータ String[] param1 = { JSCStrConstant.SOD_RNKI_STAT_FIN // SOD業務連携ステータス(業務連携済み) }; String[] param2 = { inMap.getString("SRINF_KANRI_NO") // 送受信情報管理番号 }; // 更新 try { executeSC_T_EM_ODR_SRINF_PKUPDATE(param1, param2); } catch(Exception e) // PGReliefで警告が出るが、自動生成されたメソッドがExceptionをthrowするので、対応できない { throw new JBSbatBusinessException("ESCB0040CE", new String[] {inMap.getString("SVC_KEI_NO"), inMap.getString("EM_KEISHA_CD"), D_TBL_NAME_SC_T_EM_ODR_SRINF}); } // モバイルオーダテーブルのアップデート String[] param3 = { inMap.getString("SOD_RENKEI_SEQ") }; try { executeSC_T_MOBILE_ORDER_PKUPDATE(param1, param3); } catch(Exception e) // // PGReliefで警告が出るが、自動生成されたメソッドがExceptionをthrowするので、対応できない { throw new JBSbatBusinessException("ESCB0040CE", new String[] {inMap.getString("SVC_KEI_NO"), inMap.getString("EM_KEISHA_CD"), D_TBL_NAME_SC_T_MOBILE_ORDER}); } logPrint.printDebugLog("JBSbatSCEMSODRsltHojinCst#execute end"); return outputBean; // ファイルを出力 /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_SC_T_MOBILE_ORDER.close(); db_SC_T_EM_ODR_SRINF.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ // 入力行数の取得 int cnt = commonItem.getInputCount(); if(0 == cnt) { super.logPrint.printLogMsg("ESCB0080AI", "イー・モバイルSOD結果(法人)送信ファイル"); } /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/ /** * PK(ＰＫ　更新)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

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

	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	ＳＯＤ業務連携ステータス				SOD_WORK_RNKI_STAT
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	MOBILE_ORDER_NO
	 *
*

* @param setParam 設定項目の値。 * @param whereParam 条件項目の値。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeSC_T_MOBILE_ORDER_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception { // 設定値のマップを作成します JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("SOD_WORK_RNKI_STAT", setParam[0]); // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("MOBILE_ORDER_NO", whereParam[0]); // DBアクセスを実行します db_SC_T_MOBILE_ORDER.updateByPrimaryKeys(whereMap, setMap); } /** * PK(ＰＫ　更新)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

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

	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	ＳＯＤ業務連携ステータス				SOD_WORK_RNKI_STAT
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	SRINF_KANRI_NO
	 *
*

* @param setParam 設定項目の値。 * @param whereParam 条件項目の値。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeSC_T_EM_ODR_SRINF_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception { // 設定値のマップを作成します JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("SOD_WORK_RNKI_STAT", setParam[0]); // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("SRINF_KANRI_NO", whereParam[0]); // DBアクセスを実行します db_SC_T_EM_ODR_SRINF.updateByPrimaryKeys(whereMap, setMap); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }