/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名：eo顧客基幹システム * モジュール名：JBSbatKKAutoShosaRsltListSksi * ソースファイル名：JBSbatKKAutoShosaRsltListSksi.java * 作成者：富士通　 * 作成日：2011年10月20日 *＜機能概要＞ *　自動照査結果リスト作成部品です。 *＜修正履歴＞ * バージョン修正日修正者修正内容 * v1.00.00 2011/10/20 富士通新規作成 *********************************************************************/ package eo.business.service; import java.util.ArrayList; import java.util.List; import eo.business.common.JBSbatBusinessService; import eo.business.common.JBSbatInterface; import eo.business.common.JKKBatCommon; import eo.business.common.JKKBatConst; import eo.business.common.JKKBatStringUtil; import eo.business.util.file.JBSbatKKIFE159; import eo.business.util.table.JBSbatCK_T_CUST; import eo.business.util.table.JBSbatKK_M_MSKM_SBT; import eo.business.util.table.JBSbatKK_M_PPLAN; import eo.business.util.table.JBSbatKK_M_PRC_GRP; import eo.business.util.table.JBSbatKK_M_WRIB_SVC; import eo.business.util.table.JBSbatKK_T_AUTO_SHOSA_RSLT; import eo.business.util.table.JBSbatKK_T_ICJKN_SETTE; import eo.business.util.table.JBSbatKK_T_WRIB_SVC_KEI; import eo.business.util.table.JBSbatZM_M_CD_NM_KANRI; 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.JBSbatStringUtil; /** * 自動照査結果リスト作成バッチ * 自動照査を行ったデータを自動照査結果リスト送信に出力する。

*
* @author 富士通 */ public class JBSbatKKAutoShosaRsltListSksi extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です開始▼▼▼▼▼▼*/ /** テーブル(割引サービス契約)*/ private static final String D_TBL_NAME_KK_T_WRIB_SVC_KEI = "KK_T_WRIB_SVC_KEI"; /** テーブル(一時金設定)*/ private static final String D_TBL_NAME_KK_T_ICJKN_SETTE = "KK_T_ICJKN_SETTE"; /** テーブル(自動照査結果)*/ private static final String D_TBL_NAME_KK_T_AUTO_SHOSA_RSLT = "KK_T_AUTO_SHOSA_RSLT"; /** SQL定義キー(KK_SELECT_013)*/ private static final String KK_T_WRIB_SVC_KEI_KK_SELECT_013 = "KK_SELECT_013"; /** SQL定義キー(KK_SELECT_001)*/ private static final String KK_T_ICJKN_SETTE_KK_SELECT_001 = "KK_SELECT_001"; /** SQL定義キー(KK_UPDATE_002)*/ private static final String KK_T_AUTO_SHOSA_RSLT_KK_UPDATE_002 = "KK_UPDATE_002"; /** テーブルアクセスクラス(割引サービス契約)*/ private JBSbatSQLAccess db_KK_T_WRIB_SVC_KEI = null; /** テーブルアクセスクラス(一時金設定)*/ private JBSbatSQLAccess db_KK_T_ICJKN_SETTE = null; /** テーブルアクセスクラス(自動照査結果)*/ private JBSbatSQLAccess db_KK_T_AUTO_SHOSA_RSLT = null; /**▲▲▲▲▲▲ツールから生成した宣言です終了▲▲▲▲▲▲*/ /** 一時支払料金番号上2桁（01） */ public static final String TMP_PAY_PRC_NO_KAMI_2_01 = "01"; /** 一時支払料金番号上2桁（02） */ public static final String TMP_PAY_PRC_NO_KAMI_2_02 = "02"; /** 一時支払料金番号上2桁（03） */ public static final String TMP_PAY_PRC_NO_KAMI_2_03 = "03"; /** 一時金区分（事務手数料） */ public static final String ICJKN_KBN_JMTE = "事務手数料"; /** 一時金区分（標準工事費） */ public static final String ICJKN_KBN_STDARD_KOJIHI = "標準工事費"; /** 一時金区分（機器代金） */ public static final String ICJKN_KBN_KIKI_DKN = "機器代金"; /** DBキー（仮メール） */ public static final String DB_KEY_KARI_ML = "KARI_ML"; /** DBキー（オプトイン） */ public static final String DB_KEY_OPTIN = "OPTIN"; /** 空文字 */ public static final String STR_EMPTY = ""; /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_KK_T_WRIB_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_WRIB_SVC_KEI); db_KK_T_ICJKN_SETTE = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_ICJKN_SETTE); db_KK_T_AUTO_SHOSA_RSLT = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_AUTO_SHOSA_RSLT); /**▲▲▲▲▲▲ツールから生成した初期化のソースです終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @param inMap　入力電文 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ // 入力電文より必要項目を取得 String autoShosaRsltNo = inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.AUTO_SHOSA_RSLT_NO); String autoShosaRsltCd = inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.AUTO_SHOSA_RSLT_CD); String mskmDtlNo = inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.MSKM_DTL_NO); String svcKeiNo = inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.SVC_KEI_NO); // 出力電文を生成 JBSbatOutputItem outputBean = new JBSbatOutputItem(); if (JKKBatConst.AUTO_SHOSA_RSLT_CD_PSB_DTL.equals(autoShosaRsltCd)) { // 自動照査結果コードが"01"(自動照査可(詳細情報))の場合 // 運用日を取得 String opeDate = commonItem.getOpeDate(); // サービス契約番号に紐つく割引サービス契約情報を取得 Object[] whereParam1 = { //↓↓↓2013-05-05変更　外接品質強化試験障害対応（No.13 キャンペーンや割引の名称が付かない）↓↓↓ opeDate, opeDate, opeDate, svcKeiNo, opeDate, opeDate, opeDate, opeDate, svcKeiNo, opeDate //↑↑↑2013-05-05変更　外接品質強化試験障害対応（No.13 キャンペーンや割引の名称が付かない）↑↑↑ }; executeKK_T_WRIB_SVC_KEI_KK_SELECT_013(whereParam1); List wribSvcKeiMapList = new ArrayList(); JBSbatCommonDBInterface wribSvcKeiMap = db_KK_T_WRIB_SVC_KEI.selectNext(); while (wribSvcKeiMap != null) { wribSvcKeiMapList.add(wribSvcKeiMap); wribSvcKeiMap = db_KK_T_WRIB_SVC_KEI.selectNext(); } // サービス契約番号・申込明細番号に紐つく一時金設定情報を取得 Object[] whereParam2 = { svcKeiNo, mskmDtlNo }; executeKK_T_ICJKN_SETTE_KK_SELECT_001(whereParam2); List icjknSetteMapList = new ArrayList(); JBSbatCommonDBInterface icjknSetteMap = db_KK_T_ICJKN_SETTE.selectNext(); while (icjknSetteMap != null) { icjknSetteMapList.add(icjknSetteMap); icjknSetteMap = db_KK_T_ICJKN_SETTE.selectNext(); } // 自動照査結果リスト送信への出力情報を設定 setOutFileMap(inMap, outputBean, wribSvcKeiMapList, icjknSetteMapList); } // 自動照査結果の自動照査結果リスト出力済フラグを出力済に更新する Object[] updateParam = { JKKBatConst.ZM_FLG_ZM, autoShosaRsltNo }; executeKK_T_AUTO_SHOSA_RSLT_KK_UPDATE_002(updateParam); return outputBean; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_KK_T_WRIB_SVC_KEI.close(); db_KK_T_ICJKN_SETTE.close(); db_KK_T_AUTO_SHOSA_RSLT.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /**▼▼▼▼▼▼ツールから生成したメソッドです開始▼▼▼▼▼▼*/ /** * SQLKEY(KK_SELECT_013)でDBアクセスを行います。
*

* 処理フロー
*

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	運用日
	 *		 	運用日
	 *		 	サービス契約番号
	 *

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_WRIB_SVC_KEI_KK_SELECT_013(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); //↓↓↓2013-05-05変更　外接品質強化試験障害対応（No.13 キャンペーンや割引の名称が付かない）↓↓↓ for (int i = 0; i < param.length; i++) { paramList.setValue(param[i].toString()); } //↑↑↑2013-05-05変更　外接品質強化試験障害対応（No.13 キャンペーンや割引の名称が付かない）↑↑↑ // DBアクセスを実行します db_KK_T_WRIB_SVC_KEI.selectBySqlDefine(paramList, KK_T_WRIB_SVC_KEI_KK_SELECT_013); } /** * SQLKEY(KK_SELECT_001)でDBアクセスを行います。
*

* 処理フロー
*

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	サービス契約番号
	 *		 	申込明細番号
	 *

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

* 処理フロー
*

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	自動照査結果リスト出力済フラグ
	 *		 	更新年月日時分秒
	 *		 	更新オペレータアカウント
	 *		 	自動照査結果番号
	 *

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_AUTO_SHOSA_RSLT_KK_UPDATE_002(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); // DBアクセスを実行します db_KK_T_AUTO_SHOSA_RSLT.executeBySqlDefine(paramList, KK_T_AUTO_SHOSA_RSLT_KK_UPDATE_002); } /**▲▲▲▲▲▲ツールから生成したメソッドです終了▲▲▲▲▲▲*/ /** * 自動照査結果リスト送信への出力情報を設定する。
*

* 処理フロー
*

	 * 1.引数情報を元に自動照査結果リスト送信への出力情報を設定する。

	 *

* @param inMap 入力電文。 * @param outputBean 出力電文。 * @param wribSvcKeiMapList 割引サービス契約マップリスト。 * @param icjknSetteMapList 一時金設定マップリスト * @throws Exception 業務サービス内で発生した例外全般。 */ private void setOutFileMap(JBSbatServiceInterfaceMap inMap, JBSbatOutputItem outputBean, List wribSvcKeiMapList, List icjknSetteMapList) throws Exception { // 自動照査結果リスト送信へ出力するレコード数を算出 int length = wribSvcKeiMapList.size() == 0 && icjknSetteMapList.size() == 0 ? 1 : wribSvcKeiMapList.size() > icjknSetteMapList.size() ? wribSvcKeiMapList.size() : icjknSetteMapList.size(); for (int i = 0; i < length; i++) { // 自動照査結果リスト送信マップを生成 JBSbatServiceInterfaceMap outFileMap = new JBSbatServiceInterfaceMap(); // 自動照査結果情報を設定 // IT1-2012-0000986 2012/09/05 start outFileMap.setString(JBSbatKKIFE159.MSKM_SBT, JKKBatStringUtil.getLCutString(JBSbatInterface.trim(inMap.getString(JBSbatKK_M_MSKM_SBT.MSKM_SBT_NM)), 10)); // TAI-2012-0000089 2012.08.01 MOD START // outFileMap.setString(JBSbatKKIFE159.MSKM_YMD, JBSbatInterface.trim(inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.MSKM_YMD))); outFileMap.setString(JBSbatKKIFE159.MSKM_YMD, JKKBatStringUtil.getFormatDate(JBSbatInterface.trim(inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.MSKM_YMD)), JKKBatConst.S_HALF_SLASH )); // TAI-2012-0000089 2012.08.01 MOD END outFileMap.setString(JBSbatKKIFE159.KEY_SVC, JKKBatStringUtil.getLCutString(JBSbatInterface.trim(inMap.getString(JBSbatKK_M_PRC_GRP.PRC_GRP_NM)),15)); outFileMap.setString(JBSbatKKIFE159.MSKMSHO_NO, JBSbatStringUtil.padNumFormString(JBSbatInterface.trim(inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.MSKMSHO_NO)),10)); outFileMap.setString(JBSbatKKIFE159.MSKM_DTL_NO, JBSbatStringUtil.padNumFormString(JBSbatInterface.trim(inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.MSKM_DTL_NO)),12)); outFileMap.setString(JBSbatKKIFE159.CUST_NM, JKKBatStringUtil.getLCutString(JBSbatInterface.trim(inMap.getString(JBSbatCK_T_CUST.CUST_NM)),15)); outFileMap.setString(JBSbatKKIFE159.SVC_KEI_NO, JBSbatStringUtil.padNumFormString(JBSbatInterface.trim(inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.SVC_KEI_NO)),12)); outFileMap.setString(JBSbatKKIFE159.PPLAN, JKKBatStringUtil.getLCutString(JBSbatInterface.trim(inMap.getString(JBSbatKK_M_PPLAN.PPLAN_NM)),15)); //↓↓↓2013-05-05変更　外接品質強化試験障害対応（No.11 eoモバイルは認証ＩＤ不要）↓↓↓ String ninshoId = JBSbatInterface.trim(inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.NINSHO_ID)); if (JKKBatCommon.isNotNull(ninshoId)) { outFileMap.setString(JBSbatKKIFE159.NINSHO_ID, JBSbatStringUtil.padNumFormString(JKKBatStringUtil.getLCutString(ninshoId,10),10)); } else { outFileMap.setString(JBSbatKKIFE159.NINSHO_ID, ""); } //↑↑↑2013-05-05変更　外接品質強化試験障害対応（No.11 eoモバイルは認証ＩＤ不要）↑↑↑ outFileMap.setString(JBSbatKKIFE159.SHK_EOID, JBSbatStringUtil.padNumFormString( JKKBatStringUtil.getLCutString(JBSbatInterface.trim(inMap.getString(JBSbatKK_T_AUTO_SHOSA_RSLT.SHK_EOID)),15),15)); // IT1-2012-0000986 2012/09/05 end outFileMap.setString(JBSbatKKIFE159.KARI_ML, JBSbatInterface.trim(inMap.getString(DB_KEY_KARI_ML))); outFileMap.setString(JBSbatKKIFE159.OPTIN, JBSbatInterface.trim(inMap.getString(DB_KEY_OPTIN))); outFileMap.setString(JBSbatKKIFE159.CP_CD, STR_EMPTY); outFileMap.setString(JBSbatKKIFE159.CP_NM, STR_EMPTY); outFileMap.setString(JBSbatKKIFE159.WRIB_CD, STR_EMPTY); outFileMap.setString(JBSbatKKIFE159.WRIB_NM, STR_EMPTY); outFileMap.setString(JBSbatKKIFE159.HANYO_CD, STR_EMPTY); outFileMap.setString(JBSbatKKIFE159.HANYO_NM, STR_EMPTY); outFileMap.setString(JBSbatKKIFE159.ICJKN_KBN, STR_EMPTY); outFileMap.setString(JBSbatKKIFE159.ICJKN_NYO, STR_EMPTY); if (i < wribSvcKeiMapList.size()) { // 割引サービス契約情報が存在する場合 //↓↓↓2013-05-05変更　外接品質強化試験障害対応（No.13 キャンペーンや割引の名称が付かない）↓↓↓ JBSbatCommonDBInterface wribSvcMap = wribSvcKeiMapList.get(i); String wribTypeCd = JBSbatInterface.trim(wribSvcMap.getString("TYPE_CD")); //JBSbatKK_M_WRIB_SVC.WRIB_TYPE_CD)); // IT1-2012-0000986 2012/09/05 start String wribSvcCd = //JBSbatStringUtil.padNumFormString( JBSbatInterface.trim(wribSvcMap.getString("KM_CD")); //JBSbatKK_T_WRIB_SVC_KEI.WRIB_SVC_CD)),10); String wribSvcNm = JKKBatStringUtil.getLCutString( JBSbatInterface.trim(wribSvcMap.getString("KM_NM")), 15); //JBSbatKK_M_WRIB_SVC.WRIB_SVC_NM)),15); // IT1-2012-0000986 2012/09/05 end //↑↑↑2013-05-05変更　外接品質強化試験障害対応（No.13 キャンペーンや割引の名称が付かない）↑↑↑ boolean isWrib = JKKBatConst.WRIB_TYPE_CD_SET_WRIB.equals(wribTypeCd) || //10 JKKBatConst.WRIB_TYPE_CD_FAMIPA_WRIB.equals(wribTypeCd) || //20 JKKBatConst.WRIB_TYPE_CD_CHOKI_USE_WRIB.equals(wribTypeCd) || //30 JKKBatConst.WRIB_TYPE_CD_SOKU_WRI.equals(wribTypeCd) || //31 JKKBatConst.WRIB_TYPE_CD_GRP_WRIB.equals(wribTypeCd); //40 if (JKKBatConst.WRIB_TYPE_CD_CMP_WRIB.equals(wribTypeCd) || JKKBatConst.WRIB_TYPE_CD_CMP_WRIB_MNKHT.equals(wribTypeCd)) { outFileMap.setString(JBSbatKKIFE159.CP_CD, wribSvcCd); outFileMap.setString(JBSbatKKIFE159.CP_NM, wribSvcNm); } else if (isWrib) { outFileMap.setString(JBSbatKKIFE159.WRIB_CD, wribSvcCd); outFileMap.setString(JBSbatKKIFE159.WRIB_NM, wribSvcNm); } else if (JKKBatConst.WRIB_TYPE_CD_CD_SET_KMK.equals(wribTypeCd)) { outFileMap.setString(JBSbatKKIFE159.HANYO_CD, wribSvcCd); outFileMap.setString(JBSbatKKIFE159.HANYO_NM, wribSvcNm); } } if (i < icjknSetteMapList.size()) { // 一時金設定情報が存在する場合 JBSbatCommonDBInterface icjknSetteMap = icjknSetteMapList.get(i); String tmpPayPrcNo = JBSbatInterface.trim(icjknSetteMap.getString(JBSbatKK_T_ICJKN_SETTE.TMP_PAY_PRC_NO)); String icjknKbn = null; if (tmpPayPrcNo.length() >= 2) { // ※PGReliefにてワーニングが発生するが、 // 機能要件上、止むを得ないのでためワーニングを無視する String tmpPayPrcNoKami2 = tmpPayPrcNo.substring(0, 2); if (TMP_PAY_PRC_NO_KAMI_2_01.equals(tmpPayPrcNoKami2)) { icjknKbn = ICJKN_KBN_JMTE; } else if (TMP_PAY_PRC_NO_KAMI_2_02.equals(tmpPayPrcNoKami2)) { icjknKbn = ICJKN_KBN_STDARD_KOJIHI; } else if (TMP_PAY_PRC_NO_KAMI_2_03.equals(tmpPayPrcNoKami2)) { icjknKbn = ICJKN_KBN_KIKI_DKN; } } outFileMap.setString(JBSbatKKIFE159.ICJKN_KBN, icjknKbn); // IT1-2012-0000986 2012/09/05 start outFileMap.setString(JBSbatKKIFE159.ICJKN_NYO, JKKBatStringUtil.getLCutString(JBSbatInterface.trim(icjknSetteMap.getString(JBSbatZM_M_CD_NM_KANRI.CD_DIV_NM)),5)); // IT1-2012-0000986 2012/09/05 end } // 出力フラグを設定する outFileMap.setOutFlg(true); // 自動照査結果リスト送信マップを追加 outputBean.addOutMapList(outFileMap); } } }