/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatKKBbssRsDslReqFileSend * ソースファイル名 ：JBSbatKKBbssRsDslReqFileSend.java * 作成者 ：富士通　 * 作成日 ：2017年04月18日 *＜機能概要＞ *　ＢＢＳＳライセンス解約依頼ファイル送信部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v32.00.00 2017/04/18 FJ)原田 【ANK-3149-00-00】新セキュリティパック * v32.00.01 2017/06/13 FJ)原田 【IT1-2017-0000083】対応 * v54.00.00 2021/09/01 FJ)星野 ANK-4069-00-00_バッチ・DBサーバーリプレース対応 *********************************************************************/ package eo.business.service; import java.io.IOException; import java.util.ArrayList; import eo.business.common.JBSbatBusinessService; import eo.business.common.JCCBatCommon; import eo.business.util.table.JBSbatKK_T_TAJGS_KEI_IDT; import eo.common.constant.JPCBatchMessageConstant; import eo.common.util.JKKStringUtil; import eo.framework.application.JBSbatBusinessException; import eo.framework.application.JCCbatFrameworkException; import eo.framework.db.JBSbatSQLAccess; import eo.framework.file.JBSbatDefFileUtil; import eo.framework.file.JBSbatInputFileUtil; import eo.framework.item.JBSbatCommonDBInterface; import eo.framework.item.JBSbatCommonItem; import eo.framework.item.JBSbatOutputItem; import eo.framework.item.JBSbatServiceInterfaceMap; import eo.framework.util.JBSbatAplConst; /** * (クラスの機能概要)

*
* @author 富士通 */ public class JBSbatKKBbssRsDslReqFileSend extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ // ANK-4069-00-00対応 20210901 星野 DEL START // /** 外部インターフェイスID */ // private static final String IF_ID = "KKIFE356"; // ANK-4069-00-00対応 20210901 星野 DEL END /** 電子ファイル管理(レコード件数) */ private int fileRecord = 0; /** テーブルアクセスクラス(他事業者契約異動通知) */ private JBSbatSQLAccess db_KK_T_TAJGS_KEI_IDT = null; /** SQL定義キー(KK_UPDATE_006) */ private static final String KK_T_TAJGS_KEI_IDT_KK_UPDATE_006 = "KK_UPDATE_006"; /** 他事業者契約異動通知結果コード */ private static String TAJGS_KEI_IDT_RSLT_CD = "TAJGS_KEI_IDT_RSLT_CD"; /** BBSS会員ID */ private static String BBSS_MEMBER_ID = "BBSS_MEMBER_ID"; /** 他事業者契約異動通知結果コード（正常終了） */ private static String SUCCESS = "0"; /** 他事業者契約異動通知結果コード（エラー） */ private static String FAIL = "1"; /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /** * 初期処理 * @param commonItem バッチ共通パラメータ電文 * @throws Exception 各種エクセプション */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_KK_T_TAJGS_KEI_IDT = new JBSbatSQLAccess(commonItem, JBSbatKK_T_TAJGS_KEI_IDT.TABLE_NAME); /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @return JBSbatOutputItem　出力情報 * @throws Exception 各種エクセプション */ public JBSbatOutputItem execute() throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ String sendFileNm = commonItem.getFreeItem(); super.logPrint.printDebugLog("********** BBSS解約依頼ファイル送信処理 START **********"); ArrayList rtnFileList = new ArrayList(); JBSbatInputFileUtil inFileObj = new JBSbatInputFileUtil(sendFileNm); try { // 入力ファイルの定義取得 String inDefFileName = JBSbatAplConst.getAplConstValue("IND") + "KKIFE356.def"; if(sendFileNm != null) { // 電子ファイル情報ファイル読み込み JBSbatDefFileUtil defFileUtil = new JBSbatDefFileUtil(inDefFileName, inFileObj); inFileObj.createReader(); while (inFileObj.ready()) { // レコードの１件を取得 JBSbatServiceInterfaceMap retInMap = defFileUtil.lineToObject(inFileObj.readLine(), inFileObj, 0); // ファイル最終行はトレーラ部のため回避 if (!JKKStringUtil.isNullBlank(retInMap.getString("MEMBER_ID"))) { // リストに設定 rtnFileList.add(retInMap.getString("MEMBER_ID")); } // レコードのカウントアップ fileRecord++; } } } catch(IOException ioe) { throw new JBSbatBusinessException(JPCBatchMessageConstant.EDKB0660CE, new String[]{ioe.getMessage()}); } finally { if (null != inFileObj) { inFileObj.close(); } } // BBSSに、BBSSライセンス解約依頼ファイルのデータをFTP送信する executeESB(sendFileNm, rtnFileList); super.logPrint.printDebugLog("********** BBSS解約依頼ファイル送信処理 END **********"); return null; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception 各種エクセプション */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // IT1-2017-0000083 ADD START db_KK_T_TAJGS_KEI_IDT.close(); // IT1-2017-0000083 ADD END /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /** * ESB連携部品を使用してファイル送信を行います。
*

* 処理フロー
* 

	 * 1.連携部品の引数を作成します。

	 * 
	 * 2.ESB連携部品を実行します。

	 * 
	 * 3.処理結果が正常以外の場合、エラーを発生させます。

	 * 
	 *
*

* @param value 転送対象ファイルパス。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeESB(String value, ArrayList updTrgList) throws Exception { // ANK-4069-00-00対応 20210901 星野 DEL START // ArrayList fileList = new ArrayList(); // HashMap outMap = new HashMap(); // // fileList.add(value); // ANK-4069-00-00対応 20210901 星野 DEL END try { // ANK-4069-00-00対応 20210901 星野 DEL START // // 転送処理を実行します // boolean result = JCCBatCommon.putFTP(super.commonItem, fileList, IF_ID, JCCBatCommon.ISI, outMap); // // // // 正常終了時 // if (result) // { // ANK-4069-00-00対応 20210901 星野 DEL END // 他事業者契約異動通知の他事業者契約異動通知結果詳細コードを"正常終了"で更新 updKkTTajgsKeiIdt(updTrgList, true); // ANK-4069-00-00対応 20210901 星野 DEL START // } // // エラー発生時 // else // { // // 他事業者契約異動通知の他事業者契約異動通知結果詳細コードを"エラー"で更新 // updKkTTajgsKeiIdt(updTrgList, false); // // // エラーコード // String errCd = ""; // // 送信ファイル名 // String fileName = ""; // // // 接続エラー詳細 // HashMap errDtl = new HashMap(); // // String errKbn = outMap.get("ERR_KBN").toString(); // // // 接続エラーの場合 // if ("1".equals(errKbn)) // { // errDtl = (HashMap)outMap.get("CONNECT_ERR"); // if(errDtl != null) // { // // エラーコードを設定 // errCd = errDtl.get("ERR_CD").toString(); // } // super.logPrint.printDebugLog("ファイル転送失敗" + errCd); // super.logPrint.printBusinessErrorLog("EKKB1410CE", new String[]{errCd}); // // ファイルエラーの場合 // } else if ("2".equals(errKbn)) // { // ArrayList fileErr = (ArrayList)outMap.get("FILE_ERR"); // errDtl = (HashMap)fileErr.get(0); // if(errDtl != null) // { // // エラーコードを設定 // errCd = errDtl.get("ERR_CD").toString(); // // ファイル名を設定 // fileName = errDtl.get("FILE_NAME").toString(); // } // super.logPrint.printDebugLog("ファイル転送失敗" + "ファイル名" + fileName + "エラーコード" + errCd); // super.logPrint.printBusinessErrorLog("EKKB1420CE", new String[]{fileName, errCd}); // } // } // ANK-4069-00-00対応 20210901 星野 DEL END } catch(Exception e) { // 他事業者契約異動通知の他事業者契約異動通知結果詳細コードを"エラー"で更新 updKkTTajgsKeiIdt(updTrgList, false); throw new JCCbatFrameworkException("BBSSライセンス解約依頼ファイル送信で例外が発生しました。" + e); } } /** * ファイル送信の結果から他事業者契約異動通知へ実行結果の登録を行う * @param updTrgList 更新対象データのキー項目 * @param ret 送信の成功/失敗のステータス（true：成功, false：失敗） */ private void updKkTTajgsKeiIdt(ArrayList updTrgList, boolean ret) throws Exception { // ファイル送信が成功したかどうかの判定 if(ret == true) { TAJGS_KEI_IDT_RSLT_CD = SUCCESS; } else { TAJGS_KEI_IDT_RSLT_CD = FAIL; } String[] param = null; for(int i = 0; i < updTrgList.size(); i++) { BBSS_MEMBER_ID = updTrgList.get(i); param = new String[]{TAJGS_KEI_IDT_RSLT_CD, JCCBatCommon.getSysDateTimeStamp(), BBSS_MEMBER_ID}; // 他事業者契約異動通知へ実行結果の登録を実行 executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_006(param); super.commit(); } } /** * SQLKEY(KK_UPDATE_006)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			BBSS会員ID
	 *			他事業者契約異動通知結果コード 
	 *
*

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