*
* @author 富士通
*/
public class JBSbatKKEMoneyTktnTkyoTchMailSksi extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(メール)*/
private static final String D_TBL_NAME_CC_M_MAIL = "CC_M_MAIL";
/** テーブル(お客様)*/
private static final String D_TBL_NAME_CK_T_CUST = "CK_T_CUST";
/** SQL定義キー(KK_SELECT_004)*/
private static final String CC_M_MAIL_KK_SELECT_004 = "KK_SELECT_004";
/** SQL定義キー(KK_SELECT_002)*/
private static final String CK_T_CUST_KK_SELECT_002 = "KK_SELECT_002";
/** テーブルアクセスクラス(メール)*/
private JBSbatSQLAccess db_CC_M_MAIL = null;
/** テーブルアクセスクラス(お客様)*/
private JBSbatSQLAccess db_CK_T_CUST = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 依頼完了フラグ（ＮＧ）*/
private static final String IRI_FIN_FLG_NG = "1";
/** 特典適用通知メール（メールコード）*/
private static final String MAIL_CODE_KKM1000033 = "KKM1000033";
/** メールマスタ定義 */
private JBSbatCommonDBInterface mailMap = null;
/** メールアドレス取得部品 */
private JBSbatKKEMoneyMailUtil mailUtil = null;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_CC_M_MAIL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CC_M_MAIL);
db_CK_T_CUST = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CK_T_CUST);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
// メールマスタの取得
Object[] params1 = new Object[] {
super.opeDate
,super.opeDate
,MAIL_CODE_KKM1000033
,super.opeDate
,super.opeDate
,super.opeDate
};
executeCC_M_MAIL_KK_SELECT_004(params1);
mailMap = db_CC_M_MAIL.selectNext();
if (mailMap == null)
{
// メールマスタが設定されていないため、エラー
throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0270CE,
new String[] { "メールマスタが存在しない（"+ MAIL_CODE_KKM1000033 +"）" });
}
// メールアドレス共通部品を取得
mailUtil = new JBSbatKKEMoneyMailUtil();
mailUtil.initial(commonItem);
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @throws Exception
*/
@SuppressWarnings("unchecked")
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// 出力共通電文を生成する。
super.logPrint.printDebugLog("execute_START");
JBSbatOutputItem outputBean = new JBSbatOutputItem();
if (IRI_FIN_FLG_NG.equals(inMap.getString(JBSbatKKIFM940.TKTN_IRI_FIN_FLG)))
{
super.logPrint.printDebugLog("skip");
return outputBean;
}
// お客様名の取得
Object[] custParams = new Object[] {
inMap.get(JBSbatKKIFM940.SYSID)
,super.opeDate
};
executeCK_T_CUST_KK_SELECT_002(custParams);
JBSbatCommonDBInterface custMap = db_CK_T_CUST.selectNext();
if (custMap != null)
{
// メールアドレス取得
String[] mlads = getCustMailAddress(inMap.getString(JBSbatKKIFM940.SYSID), inMap.getString(JBSbatKKIFM940.SVC_KEI_NO));
// メール本文
String mailText = new StringBuilder().append(mailMap.getString(JBSbatCC_M_MAIL.MAIL_TEXT)).toString();
// お客様名置換
mailText = mailText.replaceFirst("%", custMap.getString(JBSbatCK_T_CUST.CUST_NM));
// 改行コードの置換
mailText = mailText.replaceAll("\r\n", "\\\\n");
// 全てに連携する
for (String mlad : mlads)
{
// 出力登録
JBSbatServiceInterfaceMap map = new JBSbatServiceInterfaceMap();
map.set(JBSbatKKIFE398.SVC_KEI_NO, inMap.getString(JBSbatKKIFM940.SVC_KEI_NO)); // サービス契約番号
map.set(JBSbatKKIFE398.SENDS_MLAD, mlad); // メール宛先
map.set(JBSbatKKIFE398.SENDM_MLAD_DSP_NM, mailMap.getString(JBSbatCC_M_MAIL.SENDM_MLAD_DSP_NM)); // メール送信者名
map.set(JBSbatKKIFE398.SENDM_MLAD, mailMap.getString(JBSbatCC_M_MAIL.SENDM_MLAD)); // メール送信者
map.set(JBSbatKKIFE398.HNSIN_MLAD, mailMap.getString(JBSbatCC_M_MAIL.HNSIN_MLAD)); // メール返信先
map.set(JBSbatKKIFE398.HNSIN_ERR_MLAD, mailMap.getString(JBSbatCC_M_MAIL.ERR_MLAD)); // エラーメール返信先
map.set(JBSbatKKIFE398.MAIL_TITLE, mailMap.getString(JBSbatCC_M_MAIL.MAIL_TITLE)); // メール題名
map.set(JBSbatKKIFE398.MAIL_TEXT, mailText); // メール本文
map.set(JBSbatKKIFE398.TAIO_KIROK_TITLE, mailMap.getString(JBSbatZM_M_TCHI_MAIL_SENDS.TAIO_KIROK_TITLE)); // 対応記録タイトル
map.setOutFlg(true);
// 追加する
outputBean.addOutMapList(map);
}
}
else
{
// エラー情報のログ
printBusinessErrorLog(JPCBatchMessageConstant.EKKB1010CW,
new String[] {"お客様が存在しない（"+inMap.get(JBSbatKKIFM940.SYSID)+"）"});
super.commonItem.setErrFlg(true);
}
super.logPrint.printDebugLog("execute_END");
return outputBean;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
db_CC_M_MAIL.close();
db_CK_T_CUST.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
mailUtil.terminal();
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(KK_SELECT_004)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 運用日 * 運用日 * メールコード * 運用日 * 運用日 * 運用日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCC_M_MAIL_KK_SELECT_004(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()); // 運用日
paramList.setValue(param[5].toString()); // 運用日
// DBアクセスを実行します
db_CC_M_MAIL.selectBySqlDefine(paramList, CC_M_MAIL_KK_SELECT_004);
}
/**
* SQLKEY(KK_SELECT_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * SYSID * 運用日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCK_T_CUST_KK_SELECT_002(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString()); // SYSID
paramList.setValue(param[1].toString()); // 運用日
// DBアクセスを実行します
db_CK_T_CUST.selectBySqlDefine(paramList, CK_T_CUST_KK_SELECT_002);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲
/**
* お客様のメールアドレスを取得する。
*
* @param sysid
* @param svcKeiNo
*/
private String[] getCustMailAddress(String sysid, String svcKeiNo) throws Exception
{
// 契約者メールアドレス取得
ArrayList