/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatKKMcafeeBuyReq * ソースファイル名 ：JBSbatKKMcafeeBuyReq.java * 作成者 ：富士通　 * 作成日 ：2017年04月18日 *＜機能概要＞ *　マカフィー購入依頼部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v32.00.00 2017/04/18 FJ)原田 【ANK-3149-00-00】新セキュリティパック * v32.00.01 2017/05/08 FJ)原田 【ANK-3149-02-00】CMP画面URLの通知メール送信 * v32.00.02 2017/06/06 FJ)原田 【ST-2017-0000009】新セキュリティーパック案件の外部接続時におけるシステムエラー対応 * v32.01.00 2017/07/07 FJ)原田 【OM-2017-0000695】対応 * v37.00.00 2018/03/08 FJ)周藤 【ANK-3403-00-00】マカフィー連携エラー時のメッセージInfo対応 * v71.00.00 2024/01/30 GDC)v.auditor 【ANK-4468-00-00】eo光ネット「シンプルプラン」追加対応 * v71.00.01 2024/07/29 FJ)張 【ANK-4468-00-01】eo光ネット「シンプルプラン」追加対応 *********************************************************************/ package eo.business.service; import java.util.ArrayList; import java.util.HashMap; import java.util.HashSet; import java.util.Map; import eo.business.common.JBSbatBusinessService; import eo.business.common.JCCBatCommon; import eo.business.util.table.JBSbatCK_T_RRKS; import eo.business.util.table.JBSbatKK_T_OPSVKEI_ISP; import eo.business.util.table.JBSbatKK_T_TAJGS_KEI_IDT; import eo.business.util.table.JBSbatCK_T_CUST; import eo.business.util.table.JBSbatCC_M_MAIL; import eo.common.util.JKKCtrlMcafeeInfo; import eo.common.util.JKKStringUtil; import eo.framework.db.JBSbatSQLAccess; import eo.framework.item.JBSbatCommonDBInterface; import eo.framework.item.JBSbatCommonItem; import eo.framework.item.JBSbatOutputItem; /** * (クラスの機能概要)

*
* @author 富士通 */ public class JBSbatKKMcafeeBuyReq extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** 処理日付格納用（YYYYMMDD） */ private String sysDate = null; /** 他事業者契約異動通知結果コード（エラー） */ private String TAJGS_KEI_IDT_RSLT_CD_ERR = "1"; /** コマンド実行結果（正常） */ private String CMD_RESULT_CD_OK = "0"; /** テーブルアクセスクラス(他事業者契約異動通知)*/ private JBSbatSQLAccess db_KK_T_TAJGS_KEI_IDT = null; /** テーブルアクセスクラス（更新用）(他事業者契約異動通知)*/ private JBSbatSQLAccess db_upd_KK_T_TAJGS_KEI_IDT = null; /** テーブルアクセスクラス(オプションサービス契約＜ＩＳＰ＞)*/ private JBSbatSQLAccess db_KK_T_OPSVKEI_ISP = null; // ANK-3149-02-00 ADD START /** テーブルアクセスクラス（メール送信用）(オプションサービス契約＜ＩＳＰ＞)*/ private JBSbatSQLAccess db_MAIL_SEND_KK_T_OPSVKEI_ISP = null; // ANK-3149-02-00 ADD END // ANK-4468-00-00 ADD START /** テーブルアクセスクラス（メール送信用）(連絡先)*/ private JBSbatSQLAccess db_MAIL_SEND_CK_T_RRKS = null; // ANK-4468-00-00 ADD END /** マカフィー購入依頼 */ private static final String MCAFEE_BUY_REQ = "0101"; // OM-2017-0000695 ADD START /** トランザクション・コード（ワーニング：5001） */ private static final String TRANSACTION_CD_WARN_5001= "5001"; /** トランザクション・コード（ワーニング：5002） */ private static final String TRANSACTION_CD_WARN_5002 = "5002"; // OM-2017-0000695 ADD END /** SQL定義キー(KK_UPDATE_007) */ private static final String KK_T_TAJGS_KEI_IDT_KK_UPDATE_007 = "KK_UPDATE_007"; /** SQL定義キー(KK_SELECT_001) */ private static final String KK_T_TAJGS_KEI_IDT_KK_SELECT_001 = "KK_SELECT_001"; /** SQL定義キー(KK_UPDATE_003) */ private static final String KK_T_TAJGS_KEI_IDT_KK_UPDATE_003 = "KK_UPDATE_003"; /** SQL定義キー(KK_UPDATE_028) */ private static final String KK_T_OPSVKEI_ISP_KK_SELECT_028 = "KK_SELECT_028"; /** SQL定義キー(KK_UPDATE_001) */ private static final String KK_T_OPSVKEI_ISP_KK_UPDATE_001 = "KK_UPDATE_001"; // ANK-3149-02-00 ADD START /** SQL定義キー(KK_SELECT_030) */ private static final String KK_T_OPSVKEI_ISP_KK_SELECT_030 = "KK_SELECT_030"; // ANK-4468-00-00 ADD START /** SQL定義キー(KK_SELECT_013) */ private static final String CK_T_RRKS_KK_SELECT_013 = "KK_SELECT_013"; // ANK-4468-00-00 ADD END /** 送信予定年月日時分秒設定キー */ private static final String MAIL_SEND_RSV_DTM = "MAIL_SEND_RSV_DTM"; /** メールの送信パターン(ディレイド) */ private static final String MAIL_SEND_PATTERN_CD_02 = "02"; /** メールの送信パターンコード設定キー */ private static final String MAIL_SEND_PATTERN_CD = "MAIL_SEND_PATTERN_CD"; /** メールの送信先アドレス設定キー */ private static final String MLAD_TO = "MLAD_TO"; /** メールの送信先アドレス表示名設定キー */ private static final String MLAD_TO_NM = "MLAD_TO_NM"; /** 本文に埋め込む非定型な置換文字列設定キー*/ private static final String TEXT_HTK_CKAN_MOJI = "TEXT_HTK_CKAN_MOJI"; /** メールコード（マカフィー購入依頼）*/ private static final String MAIL_CODE_0101 = "KKM1000015"; /** ０件（メール情報の登録件数）*/ private static final int ZERO = 0; // ANK-3149-02-00 ADD END /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /** * 初期処理 * @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); db_upd_KK_T_TAJGS_KEI_IDT = new JBSbatSQLAccess(commonItem, JBSbatKK_T_TAJGS_KEI_IDT.TABLE_NAME); db_KK_T_OPSVKEI_ISP = new JBSbatSQLAccess(commonItem, JBSbatKK_T_OPSVKEI_ISP.TABLE_NAME); // ANK-3149-02-00 ADD START db_MAIL_SEND_KK_T_OPSVKEI_ISP = new JBSbatSQLAccess(commonItem, JBSbatKK_T_OPSVKEI_ISP.TABLE_NAME); // ANK-3149-02-00 ADD END // ANK-4468-00-00 ADD START db_MAIL_SEND_CK_T_RRKS = new JBSbatSQLAccess(commonItem, JBSbatCK_T_RRKS.TABLE_NAME); // ANK-4468-00-00 ADD END /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @return JBSbatOutputItem　出力情報 * @throws Exception 各種エクセプション */ public JBSbatOutputItem execute() throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ String[] param = null; // システム日付取得 sysDate = commonItem.getOpeDate(); // 他事業者契約異動種別コードが"0101"(マカフィー購入依頼)の // 他事業者契約異動通知状態コードを "0"（未通知） →"3"（処理依頼中）へ更新 param = new String[]{MCAFEE_BUY_REQ}; // 他事業者契約異動通知状態コードの更新を実行 executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_007(param); super.commit(); // 送信対象のデータの情報取得 executeKK_T_TAJGS_KEI_IDT_KK_SELECT_001(); JBSbatCommonDBInterface sqlResultMap = new JBSbatCommonDBInterface(); super.logPrint.printDebugLog("********** マカフィー購入依頼処理 START **********"); // 取得できた件数分while文で電文作成→送受信メソッド呼び出し→DB登録を行う while((sqlResultMap = db_KK_T_TAJGS_KEI_IDT.selectNext()) != null) { // 1件ずつデータを取って HashMap serviceMap = new HashMap(); // serviceMapに電文の作成に必要なデータを格納 // 他事業者契約異動通知番号 serviceMap.put("tajgsKeiIdoNo", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDT_NO)); // 他事業者契約異動種別コード serviceMap.put("tajgsKeiIdoSbtCd", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDO_SBT_CD)); // マカフィー会員ID serviceMap.put("mcafeeMemberId", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.MCAFEE_MEMBER_ID)); // マカフィー用認証メールアドレス serviceMap.put("mcafeeNinshoMlad", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.MCAFEE_NINSHO_MLAD)); // マカフィー用認証パスワード serviceMap.put("mcafeeNinshoPwd", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.MCAFEE_NINSHO_PWD)); // オプションサービス契約番号 serviceMap.put("opSvcKeiNo", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.OP_SVC_KEI_NO)); // ANK-3149-02-00 ADD START // サービス契約番号 serviceMap.put("svcKeiNo", sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.SVC_KEI_NO)); // ANK-3149-02-00 ADD END super.logPrint.printDebugLog("************ 申込依頼対象データ ************"); super.logPrint.printDebugLog("他事業者契約異動通知番号: " + sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.TAJGS_KEI_IDT_NO)); super.logPrint.printDebugLog("マカフィー会員ID: " + sqlResultMap.getString(JBSbatKK_T_TAJGS_KEI_IDT.MCAFEE_MEMBER_ID)); // コマンド発行部品のインスタンスを取得 JKKCtrlMcafeeInfo instance = JKKCtrlMcafeeInfo.getInstance(); // マカフィー連携処理呼出 Map ret = instance.call_KKIFE354(serviceMap); if (CMD_RESULT_CD_OK.equals(ret.get("CMD_RESULT_CD"))) { ArrayList> nodelist = new ArrayList>(); HashMap resultinfo = new HashMap(); nodelist = (ArrayList>)ret.get("CMD_RESULT_DETAIL"); resultinfo = (HashMap)nodelist.get(0); // リターンコードから他事業者契約異動結果コードを判定 String returnCode = (String)resultinfo.get("returnCode"); String tajgsKeiIdtRsltCd = analyzeResult(returnCode); /** 返却された結果を他事業者契約通知テーブルに反映させる */ // ST-2017-0000009 MOD START // param = new String[]{(String)resultinfo.get("mcafeeBuyId") // ,JCCBatCommon.getSysDateTimeStamp() // ,tajgsKeiIdtRsltCd // ,(String)resultinfo.get("returnCode") // ,(String)serviceMap.get("tajgsKeiIdoNo") // }; param = new String[]{JKKStringUtil.nullToBlank((String)resultinfo.get("mcafeeBuyId")) ,JCCBatCommon.getSysDateTimeStamp() ,tajgsKeiIdtRsltCd ,JKKStringUtil.nullToBlank((String)resultinfo.get("returnCode")) ,(String)serviceMap.get("tajgsKeiIdoNo") }; // ST-2017-0000009 MOD END executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_003(param); // ST-2017-0000009 DEL START // // オプションサービス契約＜ISP＞に更新する対象のレコードを検索 // param = new String[]{(String)serviceMap.get("opSvcKeiNo") ,sysDate}; // executeKK_T_OPSVKEI_ISP_KK_SELECT_028(param); // // JBSbatCommonDBInterface opSvkeiIspUpdTrgt = db_KK_T_OPSVKEI_ISP.selectNext(); // HashMap childTrgtList = (HashMap)opSvkeiIspUpdTrgt.getMap(); // // // 返却された結果をオプションサービス契約＜ISP＞テーブルに反映させる // param = new String[]{(String)resultinfo.get("mcafeeBuyId") // ,(resultinfo.get("mcafeeSehnDlUrl") != null ? (String)resultinfo.get("mcafeeSehnDlUrl") : "") // ,(String)childTrgtList.get("OP_SVC_KEI_NO") // ,(String)childTrgtList.get("GENE_ADD_DTM") // }; // executeKK_T_OPSVKEI_ISP_KK_UPDATE_001(param); // ST-2017-0000009 DEL END super.commit(); if(TAJGS_KEI_IDT_RSLT_CD_ERR.equals(tajgsKeiIdtRsltCd)) { super.logPrint.printDebugLog("マカフィー申込依頼処理にて返却値の異常が発生しています。"); // ログを出力 StringBuilder msg = new StringBuilder(); msg.append("他事業者契約異動通知番号[").append((String)serviceMap.get("tajgsKeiIdoNo")).append("]") // ST-2017-0000009 MOD START // .append("トランザクション・コード[").append((String)resultinfo.get("returnCode")).append("]") // .append("トランザクション・コード説明[").append((String)resultinfo.get("returnCodeSetmei")).append("]") .append("トランザクション・コード[").append(JKKStringUtil.nullToBlank((String)resultinfo.get("returnCode"))).append("]") .append("トランザクション・コード説明[").append(JKKStringUtil.nullToBlank((String)resultinfo.get("returnCodeSetmei"))).append("]") // ST-2017-0000009 MOD END ; // ANK-3403-00-00 MOD START //commonItem.getLogPrint().printBusinessErrorLog("EKKB1370AE", new String[] {msg.toString()}); commonItem.getLogPrint().printBusinessErrorLog("EKKB1520AW", new String[] {msg.toString()}); // ANK-3403-00-00 MOD END // OM-2017-0000695 ADD START // リクエストとレスポンスの電文を出力 String log = (String)ret.get("LOG_RESULT"); commonItem.getLogPrint().printBusinessErrorLog("EKKB1200AI", new String[] {log}); // OM-2017-0000695 ADD END continue; } // OM-2017-0000695 ADD START // トランザクション・コードがワーニング("5001","5002")のときにもリクエストとレスポンスの電文を出力 if(TRANSACTION_CD_WARN_5001.equals(returnCode) || TRANSACTION_CD_WARN_5002.equals(returnCode)) { String log = (String)ret.get("LOG_RESULT"); commonItem.getLogPrint().printBusinessErrorLog("EKKB1200AI", new String[] {log}); } // OM-2017-0000695 ADD END // ST-2017-0000009 ADD START // オプションサービス契約＜ISP＞に更新する対象のレコードを検索 param = new String[]{(String)serviceMap.get("opSvcKeiNo") ,sysDate}; executeKK_T_OPSVKEI_ISP_KK_SELECT_028(param); JBSbatCommonDBInterface opSvkeiIspUpdTrgt = db_KK_T_OPSVKEI_ISP.selectNext(); HashMap childTrgtList = (HashMap)opSvkeiIspUpdTrgt.getMap(); // 返却された結果をオプションサービス契約＜ISP＞テーブルに反映させる param = new String[]{JKKStringUtil.nullToBlank((String)resultinfo.get("mcafeeBuyId")) ,JKKStringUtil.nullToBlank((String)resultinfo.get("mcafeeSehnDlUrl")) ,(String)childTrgtList.get("OP_SVC_KEI_NO") ,(String)childTrgtList.get("GENE_ADD_DTM") }; executeKK_T_OPSVKEI_ISP_KK_UPDATE_001(param); super.commit(); // ST-2017-0000009 ADD END // ANK-3149-02-00 ADD START // マカフィーマルチアクセスダウンロード準備完了通知メールの送信処理 mailSendInfoKakno(commonItem,serviceMap); super.commit(); // ANK-3149-02-00 ADD END } else { super.logPrint.printDebugLog("マカフィー申込依頼処理中に通信異常が発生しました。"); // 他事業者契約異動通知スキーマに結果エラーで登録 param = new String[]{"" ,JCCBatCommon.getSysDateTimeStamp() ,TAJGS_KEI_IDT_RSLT_CD_ERR ,"" ,(String)serviceMap.get("tajgsKeiIdoNo") }; executeKK_T_TAJGS_KEI_IDT_KK_UPDATE_003(param); super.commit(); // ログを出力 StringBuilder msg = new StringBuilder(); String log = (String)ret.get("LOG_RESULT"); msg.append("他事業者契約異動通知番号[").append((String)serviceMap.get("tajgsKeiIdoNo")).append("]") .append("CMD_ERROR_CD[").append((String)ret.get("CMD_ERROR_CD")).append("]") .append("CMD_ERROR_MESSAGE[").append((String)ret.get("CMD_ERROR_MESSAGE")).append("]") ; // ANK-3403-00-00 MOD START //commonItem.getLogPrint().printBusinessErrorLog("EKKB0990CE", new String[] {msg.toString()}); commonItem.getLogPrint().printBusinessErrorLog("EKKB1510AW", new String[] {msg.toString()}); // ANK-3403-00-00 MOD END commonItem.getLogPrint().printBusinessErrorLog("EKKB1200AI", new String[] {log}); continue; } } super.logPrint.printDebugLog("********** マカフィー購入依頼処理 END **********"); return null; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception 各種エクセプション */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_KK_T_TAJGS_KEI_IDT.close(); db_upd_KK_T_TAJGS_KEI_IDT.close(); db_KK_T_OPSVKEI_ISP.close(); // ANK-3149-02-00 ADD START db_MAIL_SEND_KK_T_OPSVKEI_ISP.close(); // ANK-3149-02-00 ADD END // ANK-4468-00-00 ADD START db_MAIL_SEND_CK_T_RRKS.close(); // ANK-4468-00-00 ADD END /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/ /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** * 電文の返却値から他事業者契約異動通知に登録する値を編集します *
* @param returnCode リターンコード * @return HashMap 他事業者契約異動通知に登録する値（他事業者契約異動通知結果コード、他事業者契約異動通知結果詳細コード） */ public String analyzeResult(String returnCode) { String tajgsKeiIdtRsltCd = ""; if("1000".equals(returnCode) || "5001".equals(returnCode) || "5002".equals(returnCode)) { tajgsKeiIdtRsltCd = "0"; } else { tajgsKeiIdtRsltCd = "1"; } return tajgsKeiIdtRsltCd; } /** * SQLKEY(KK_UPDATE_001)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			"0101"(マカフィー購入依頼)
	 *
*

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

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			"0101"(マカフィー購入依頼)
	 *
*

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

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			ユーザーサブスクリプションPIN
	 *			サブスクリプションID
	 *			他事業者契約異動通知結果コード
	 *			他事業者契約異動通知結果詳細コード
	 *			他事業者契約異動通知番号
	 *
*

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

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			BBSS会員ID
	 *			システム日付
	 *
*

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

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *			オプションサービス契約番号
	 *			世代登録年月日
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_OPSVKEI_ISP_KK_UPDATE_001(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); paramList.setValue(param[3].toString()); // DBアクセスを実行します db_KK_T_OPSVKEI_ISP.executeBySqlDefine(paramList, KK_T_OPSVKEI_ISP_KK_UPDATE_001); } // ANK-3149-02-00 ADD START /** * SQLKEY(KK_SELECT_030)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

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

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

* 処理フロー
* 

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

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

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

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

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCK_T_RRKS_KK_SELECT_013(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); // ANK-4468-00-01 ADD START paramList.setValue(param[3].toString()); // ANK-4468-00-01 ADD END // DBアクセスを実行します db_MAIL_SEND_CK_T_RRKS.selectBySqlDefine(paramList, CK_T_RRKS_KK_SELECT_013); } // ANK-4468-00-00 ADD END /** * メール送信情報格納処理です。
*

* @param commonItem バッチ共通電文 * @param map パラメータ情報格納 * @throws Exception 業務サービス内で発生した例外全般。 * @throws IOException */ private void mailSendInfoKakno(JBSbatCommonItem commonItem, HashMap map) throws Exception { // サービス契約番号を取得 String svcKeiNo = (String)map.get("svcKeiNo"); String[] param = new String[]{svcKeiNo ,sysDate ,sysDate ,sysDate }; // DBアクセス実行 executeKK_T_OPSVKEI_ISP_KK_SELECT_030(param); // 結果取得用Map初期化 JBSbatCommonDBInterface sqlResultMap = new JBSbatCommonDBInterface(); // ANK-4468-00-00 ADD START String[] param2 = new String[]{sysDate ,sysDate ,svcKeiNo // ANK-4468-00-01 ADD START ,sysDate // ANK-4468-00-01 ADD END }; // DBアクセス実行 executeCK_T_RRKS_KK_SELECT_013(param2); // 結果取得用Map初期化 JBSbatCommonDBInterface sqlResultMap2 = new JBSbatCommonDBInterface(); // データ追加済メールアドレスハッシュマップ初期化 HashSet addedMail = new HashSet(); // ANK-4468-00-00 ADD END // メール情報の登録の件数をカウントする int mailCnt = 0; // 取得できた件数分、メール送信共通部品呼び出し→DB登録を行う while((sqlResultMap = db_MAIL_SEND_KK_T_OPSVKEI_ISP.selectNext()) != null) { mailCnt ++; // 取得項目の必須チェック boolean result = isSingleCheckKK_T_OPSVKEI_ISP_KK_SELECT_030(sqlResultMap, svcKeiNo); // 必須チェックエラーの場合、エラーとして処理をスキップする。 if(result == false) { super.commonItem.setErrFlg(true); // 処理をスキップ continue; } // メール送信情報格納Map HashMap infoMap = new HashMap(); // 変数初期化 String sysDateTime = null; // 処理日時分秒を取得 String[] htk_cakn_moji = new String[1]; // メール本文非定型文字格納 String[] mail_to = new String[1]; // メール送信先アドレス String[] mail_toNm = new String[1]; // メール送信先アドレス表示名 // 処理日時分秒を取得 sysDateTime = JCCBatCommon.getSysDateTimeStamp(); // メールアドレス取得 String mlad = sqlResultMap.getString(JBSbatKK_T_OPSVKEI_ISP.MLAD); // お客様名取得 String custNm = sqlResultMap.getString(JBSbatCK_T_CUST.CUST_NM); // 送信予定年月日時分秒の設定 infoMap.put(MAIL_SEND_RSV_DTM, sysDateTime); // メール送信パターンの設定 infoMap.put(MAIL_SEND_PATTERN_CD, MAIL_SEND_PATTERN_CD_02); // メールコードの設定 infoMap.put(JBSbatCC_M_MAIL.MAIL_CD, MAIL_CODE_0101); // メール送信先アドレス（TO）の設定。 mail_to[0] = mlad; infoMap.put(MLAD_TO, mail_to); // メール送信先アドレス表示名（TO）の設定。＜お客様名＞ mail_toNm[0] = custNm; infoMap.put(MLAD_TO_NM, mail_toNm); // 置換文字列_メール本文非定型部１の設定。（お客様名） htk_cakn_moji[0] = custNm; infoMap.put(TEXT_HTK_CKAN_MOJI, htk_cakn_moji); mailSendExecute(commonItem, infoMap); // ANK-4468-00-00 ADD START // ハッシュセットにデータ追加済メールアドレスを追加 addedMail.add(mlad); // ANK-4468-00-00 ADD END } // ANK-4468-00-00 ADD START // 取得できた件数分、メール送信共通部品呼び出し→DB登録を行う while((sqlResultMap2 = db_MAIL_SEND_CK_T_RRKS.selectNext()) != null) { // 取得項目の必須チェック boolean result = isSingleCheckCK_T_RRKS_KK_SELECT_013(sqlResultMap2, svcKeiNo); // 必須チェックエラーの場合、エラーとして処理をスキップする。 if(result == false) { super.commonItem.setErrFlg(true); // 処理をスキップ continue; } // メール送信情報格納Map HashMap infoMap = new HashMap(); // 変数初期化 String sysDateTime = null; // 処理日時分秒を取得 String[] htk_cakn_moji = new String[1]; // メール本文非定型文字格納 String[] mail_to = new String[1]; // メール送信先アドレス String[] mail_toNm = new String[1]; // メール送信先アドレス表示名 // 処理日時分秒を取得 sysDateTime = JCCBatCommon.getSysDateTimeStamp(); // メールアドレス取得 String mlad = sqlResultMap2.getString(JBSbatCK_T_RRKS.MLAD); // お客様名取得 String custNm = sqlResultMap2.getString(JBSbatCK_T_CUST.CUST_NM); // 連絡先.メールアドレスが@で取得したオプションサービス契約_ISP.メールアドレスと同一の場合、支払変更登録完了お知らせメール向けリストに出力しない if (!addedMail.contains(mlad)) { mailCnt ++; // 送信予定年月日時分秒の設定 infoMap.put(MAIL_SEND_RSV_DTM, sysDateTime); // メール送信パターンの設定 infoMap.put(MAIL_SEND_PATTERN_CD, MAIL_SEND_PATTERN_CD_02); // メールコードの設定 infoMap.put(JBSbatCC_M_MAIL.MAIL_CD, MAIL_CODE_0101); // メール送信先アドレス（TO）の設定。 mail_to[0] = mlad; infoMap.put(MLAD_TO, mail_to); // メール送信先アドレス表示名（TO）の設定。＜お客様名＞ mail_toNm[0] = custNm; infoMap.put(MLAD_TO_NM, mail_toNm); // 置換文字列_メール本文非定型部１の設定。（お客様名） htk_cakn_moji[0] = custNm; infoMap.put(TEXT_HTK_CKAN_MOJI, htk_cakn_moji); mailSendExecute(commonItem, infoMap); } } // ANK-4468-00-00 ADD END if(ZERO == mailCnt) { // ANK-3403-00-00 MOD START //commonItem.getLogPrint().printBusinessErrorLog("EKKB0290AW", commonItem.getLogPrint().printBusinessErrorLog("EKKB1530AI", // ANK-3403-00-00 MOD END new String[]{"サービス契約番号:" + svcKeiNo + "に紐づくメールオプション"}); super.commonItem.setErrFlg(true); } } /** *入力情報の単項目チェック
*

* @param sqlResultMap 入力データ（TXT又はDB）を格納されたMap。 * @param svcKeiNo サービス契約番号 * @return boolean trueである場合、エラーがありません。falseである場合、エラー。 */ private boolean isSingleCheckKK_T_OPSVKEI_ISP_KK_SELECT_030(JBSbatCommonDBInterface sqlResultMap, String svcKeiNo) throws Exception { // お客さま名の必須チェック if(JKKStringUtil.isNullBlank(sqlResultMap.getString(JBSbatCK_T_CUST.CUST_NM))) { commonItem.getLogPrint().printBusinessErrorLog("EKKB0230TW", new String[]{"サービス契約番号:" + svcKeiNo + "に紐づくお客様名"}); return false; } // メールアドレスの必須チェック if(JKKStringUtil.isNullBlank(sqlResultMap.getString(JBSbatKK_T_OPSVKEI_ISP.MLAD))) { commonItem.getLogPrint().printBusinessErrorLog("EKKB0230TW", new String[]{"サービス契約番号:" + svcKeiNo + "に紐づくメールアドレス"}); return false; } return true; } // ANK-4468-00-00 ADD START /** *入力情報の単項目チェック
*

* @param sqlResultMap 入力データ（TXT又はDB）を格納されたMap。 * @param svcKeiNo サービス契約番号 * @return boolean trueである場合、エラーがありません。falseである場合、エラー。 */ private boolean isSingleCheckCK_T_RRKS_KK_SELECT_013(JBSbatCommonDBInterface sqlResultMap, String svcKeiNo) throws Exception { // お客さま名の必須チェック if(JKKStringUtil.isNullBlank(sqlResultMap.getString(JBSbatCK_T_CUST.CUST_NM))) { commonItem.getLogPrint().printBusinessErrorLog("EKKB0230TW", new String[]{"サービス契約番号:" + svcKeiNo + "に紐づくお客様名"}); return false; } // メールアドレスの必須チェック if(JKKStringUtil.isNullBlank(sqlResultMap.getString(JBSbatCK_T_RRKS.MLAD))) { commonItem.getLogPrint().printBusinessErrorLog("EKKB0230TW", new String[]{"サービス契約番号:" + svcKeiNo + "に紐づくメールアドレス"}); return false; } return true; } // ANK-4468-00-00 ADD END /** * メール送信情報格納処理
*

* @param commonItem バッチ共通電文 * @param map パラメータ情報格納 * @return HashMap map 採番部品で発行した採番値をセットしたHashMap。 * @throws Exception 業務サービス内で発生した例外全般。 * @throws IOException */ private HashMap mailSendExecute(JBSbatCommonItem commonItem, HashMap map) throws Exception { // メール送信情報格納処理を呼び出します。 HashMap result_map = JCCBatCommon.insertTMailSend(commonItem, map); return result_map; } // ANK-3149-02-00 ADD END }