/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatCRUpdateTaioKirokBySmsHaisinRslt * ソースファイル名 ：JBSbatCRUpdateTaioKirokBySmsHaisinRslt.java * 作成者 ：富士通　 * 作成日 ：2021年08月21日 *＜機能概要＞ *　SMS配信結果対応記録更新 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ54.00.00 2021/08/20 FJ)星野 ANK-4092-08-00_【CX戦略WG方針対応STEP2】 対応記録画面からのＳＭＳ送信挙動の変更 * ｖ56.00.00 2021/11/25 FJ)舘山 ANK-4174-00-00_開通前マイページ関連業務改善（2022年1月下旬リリース） *********************************************************************/ package eo.business.service; import java.util.HashMap; import java.util.List; import eo.business.common.JBSbatBusinessService; import eo.business.common.JCCBatCommon; import eo.business.common.JCCbatShoriIraiUtil; import eo.business.common.JCRBatCommon; import eo.business.common.JKKBatConst; import eo.business.util.file.JBSbatCRIFM007; import eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ; import eo.business.util.table.JBSbatCR_T_TAIO_KIROK; import eo.common.constant.JKKStrConst; import eo.common.constant.JPCBatchMessageConstant; import eo.common.util.JCRUtilCommon; import eo.framework.application.JBSbatBusinessError; import eo.framework.application.JBSbatBusinessException; 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; import eo.framework.util.JCCBatchEsbInterface; /** * SMS配信結果対応記録更新

*
* @author 富士通 */ public class JBSbatCRUpdateTaioKirokBySmsHaisinRslt extends JBSbatBusinessService { /** リクエストキー */ private static final String CRSV029801CC = "CRSV029801CC"; /** SMS配信結果対応記録更新サービス ユースケースID */ private static final String USECASE_ID = "CRSV0298"; /** SMS配信結果対応記録更新 オペレーションID */ private static final String OPERATION_ID = "CRSV0298OP"; /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** テーブル(対応記録)*/ private static final String D_TBL_NAME_CR_T_TAIO_KIROK = "CR_T_TAIO_KIROK"; /** テーブルアクセスクラス(対応記録)*/ private JBSbatSQLAccess db_CR_T_TAIO_KIROK = null; /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /** SMS配信結果対応記録更新ファイル定義ファイル名 */ private static final String CRIFM007_DEF = "CRIFM007.def"; /** 入力ファイル定義 */ private static final String PARAM_IND = "IND"; /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_CR_T_TAIO_KIROK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CR_T_TAIO_KIROK); /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute() throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ // ディレイド処理依頼情報リストを取得する List> shoriIraiList = JCCbatShoriIraiUtil.getShoriIraiInfo(commonItem, this.jobid); if(shoriIraiList==null || shoriIraiList.isEmpty()) { return null; } // ディレイド処理依頼番号 String shoriIraiNo = ""; // 入力電子ファイル管理番号 String fileKanriNo = ""; // SMS配信結果対応記録更新リストファイル JBSbatInputFileUtil CRIFM007FileUtil = null; // SMS配信結果対応記録更新リスト定義ファイル JBSbatDefFileUtil CRIFM007FileDef = null; // Readファイル（SMS配信結果対応記録更新一覧ファイル） String CRIFM007DefName = JBSbatAplConst.getAplConstValue(PARAM_IND) + CRIFM007_DEF; // ディレイド処理依頼情報リストの件数分繰り返す for (HashMap shoriIrai : shoriIraiList) { // 入力電子ファイル管理番号 fileKanriNo = (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.INPUT_EFILE_KANRI_NO); // ディレイド処理依頼番号 shoriIraiNo = (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.DLYD_TRN_REQ_NO); super.logPrint.printDebugLog("入力電子ファイル管理番号" + fileKanriNo); super.logPrint.printDebugLog("ディレイド処理依頼番号" + shoriIraiNo); try { // 電子ファイル管理からSMS配信結果対応記録更新リストファイルを取得する String CRIFM007FilePath = JCCBatCommon.searchDenshiFile(commonItem, fileKanriNo); // SMS配信結果対応記録更新リストファイルオブジェクトを生成する CRIFM007FileUtil = new JBSbatInputFileUtil(CRIFM007FilePath); // SMS配信結果対応記録更新リスト定義ファイルオブジェクトを生成する CRIFM007FileDef = new JBSbatDefFileUtil(CRIFM007DefName, CRIFM007FileUtil); // SMS配信結果対応記録更新リストファイルレコード件数 int CRIFM007RecordCnt = 0; // Readerオブジェクトを生成する CRIFM007FileUtil.createReader(); // SMS配信結果対応記録更新リストファイルの件数分繰り返す while (CRIFM007FileUtil.ready()) { // ファイルから１レコードを取得する String line = CRIFM007FileUtil.readLine(); // SMS配信結果対応記録更新リストファイルレコード件数カウント CRIFM007RecordCnt++; // １レコードの情報をマップに格納する JBSbatServiceInterfaceMap recordMap = CRIFM007FileDef.lineToObject(line, CRIFM007FileUtil, CRIFM007RecordCnt); // ディレイド処理依頼の情報取得 // 対応記録番号 String taioKirokNo = recordMap.getString(JBSbatCRIFM007.TAIO_KIROK_NO); // メッセージID String msgId = recordMap.getString(JBSbatCRIFM007.MSG_ID); // SMS配信結果コード String haisinRsltCd = recordMap.getString(JBSbatCRIFM007.HAISIN_RSLT_CD); if(JCRUtilCommon.isNull(taioKirokNo)) { continue; } // ANK-4174-00-00 ADD START // 対応記録明細番号 String taioKirokDtlNo = ""; // 対応記録番号から対応記録明細番号を分離する String[] values = taioKirokNo.split("-"); if (values.length > 1) { taioKirokNo = values[0]; taioKirokDtlNo = values[1]; } // ANK-4174-00-00 ADD END // 対応記録をPK検索 String[] whereParam = new String[] {taioKirokNo}; JBSbatCommonDBInterface selectedData = executeCR_T_TAIO_KIROK_PKSELECT(whereParam); if(selectedData==null) { continue; } // ユーザーID String userId = selectedData.getString(JBSbatCR_T_TAIO_KIROK.TAIO_USER_ID); // ユーザー名 String userNm = JCRBatCommon.getUserNm(commonItem, userId); // 業務個別設定組織 String workGroupCd = JCRBatCommon.getWorkGroupCd(commonItem, userId, null); // 送付部署名 String workGroupNm = JCRBatCommon.getWkkbtOrgNm(commonItem, workGroupCd); // 対応開始年月日時分秒 String taioStaDtm = selectedData.getString(JBSbatCR_T_TAIO_KIROK.TAIO_STA_DTM); // 更新前更新年月日時分秒 String updDtmBf = selectedData.getString(JBSbatCR_T_TAIO_KIROK.UPD_DTM); // サービス呼出パラメータ設定 HashMap serviceMap = new HashMap(); // 対応記録番号 serviceMap.put("taio_kirok_no", taioKirokNo); // ANK-4174-00-00 ADD START // 対応記録番号 serviceMap.put("taio_kirok_dtl_no", taioKirokDtlNo); // ANK-4174-00-00 ADD END // メッセージID serviceMap.put("msg_id", msgId); // SMS配信結果コード serviceMap.put("haisin_rslt_cd", haisinRsltCd); // 対応開始年月日時分秒 serviceMap.put("taio_sta_dtm", taioStaDtm); // ユーザーID serviceMap.put("user_id", userId); // ユーザー名 serviceMap.put("user_nm", userNm); // 業務個別設定組織コード serviceMap.put("wkkbt_org_cd", workGroupCd); // 業務個別設定組織名 serviceMap.put("wkkbt_org_nm", workGroupNm); // 更新前更新年月日時分秒 serviceMap.put("upd_dtm_bf", updDtmBf); // サービス呼出 doExecute(serviceMap); } // ディレイド処理依頼結果更新 JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, JKKStrConst.DLYD_TRN_RSLT_CD_COMPLETE, null); } // エラーの場合はマイナーエラーとログを出力し、処理を終了する。 catch(Exception e) { super.logPrint.printDebugLog("Exception:" + e.getMessage()); commonItem.getConnection().rollback(); // ディレイド処理依頼のステータスに「処理エラー」で更新 JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, JKKBatConst.RESULT_SYSERR, null); commonItem.getConnection().commit(); // 業務エラーログ出力 e.printStackTrace(); super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB1270CW , new String[]{e.toString()}); super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB1270CW , new String[]{"入力電子ファイル管理番号" + fileKanriNo}); super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB1270CW , new String[]{"ディレイド処理依頼番号" + shoriIraiNo}); throw e; } finally { // ファイルクローズ // Read if(CRIFM007FileUtil != null) { CRIFM007FileUtil.close(); } } } return null; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_CR_T_TAIO_KIROK.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /** * PK(ＰＫ　検索)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

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

* @param whereParam 条件項目の値。 * @return JBSbatCommonDBInterface 検索の結果。 * @throws Exception 業務サービス内で発生した例外全般。 */ private JBSbatCommonDBInterface executeCR_T_TAIO_KIROK_PKSELECT(Object[] whereParam) throws Exception { // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("TAIO_KIROK_NO", whereParam[0]); // DBアクセスを実行します return db_CR_T_TAIO_KIROK.selectByPrimaryKeys(whereMap); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** * SMS配信結果対応記録更新CC呼び出し処理 * * @param inMap 入力電文 * @return HashMap 処理結果 * @throws Exception */ private HashMap doExecute(HashMap excuteMap) throws Exception { HashMap paramMap = new HashMap(); // サービスに渡す業務データを格納するMAP HashMap inputMap = new HashMap(); // サービスの処理結果が格納されるMAP HashMap outputMap = new HashMap(); // サービスＩＤのセット paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_USECASE_ID, USECASE_ID); paramMap.put(JCCBatchEsbInterface.TELEGRAM_INFO_OPERATION_ID, OPERATION_ID); // inputMapにCCに必要な情報をセットする inputMap.put(CRSV029801CC, excuteMap); // SMS配信結果対応記録更新CCを呼び出す JCCBatchEsbInterface.invokeService(super.commonItem, paramMap, inputMap, outputMap); String returnCode = outputMap.get(JCCBatchEsbInterface.RETURN_CODE).toString(); if(!JCCBatchEsbInterface.RETURN_CODE_SUCCESS.equals(returnCode)) { throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0270CE, new String[]{"SMS配信結果対応記録更新"}); } // 処理結果を返却する return outputMap; } }