*
* @author 富士通
*/
public class JBSbatKKTrgtSvcKeiRead extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(契約一時金)*/
private static final String D_TBL_NAME_KK_T_KICJKN = "KK_T_KICJKN";
/** テーブルアクセスクラス(契約一時金)*/
private JBSbatSQLAccess db_KK_T_KICJKN = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
// ++++++++++ v22.00.00 削除開始 ++++++++++
// /** 適用状態コード(確定) */
// private static final String APLY_STAT_CD_FIX = "2";
// ++++++++++ v22.00.00 削除終了 ++++++++++
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KK_T_KICJKN = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KICJKN);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
// 「対象契約一時金更新ファイル」を読み込みます。
// 契約一時金番号
String kicjkinNo = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKKIFM055.KICJKN_NO));
// 一時金設定適用月
String icjknSetteAplyMon = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKKIFM055.ICJKN_SETTE_APLY_MON));
// 更新年月日時分秒
String updDtm = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKKIFM055.UPD_DTM));
super.logPrint.printDebugLog("契約一時金番号 ：" + kicjkinNo);
super.logPrint.printDebugLog("一時金設定適用月：" + icjknSetteAplyMon);
// 契約一時金PK検索メソッドを呼び出し、
// 更新対象の「契約一時金番号」の「更新年月日時分秒」を取得します。
String lastUpdDtmAf = this.getUpdDtm(kicjkinNo);
// 更新日時のチェックを行います。
// 更新日時に相違がある場合、エラー処理を実行します。
if (null == getTimeStampCheck(kicjkinNo, updDtm, lastUpdDtmAf))
{
super.logPrint.printDebugLog("該当データが既に更新されています。" + kicjkinNo);
// MSG 該当データが既に更新されています。（DB:契約一時金 KEY:ZZZZZZZZZZ）
super.logPrint.printBusinessErrorLog("EKKB0360KE", new String[]{"契約一時金", kicjkinNo});
return null;
}
// 契約一時金の更新を行います。
// 更新対象の「契約一時金番号」のパラメータを設定します。
// ++++++++++ v22.00.00 変更開始 ++++++++++
// String [] setParam = {icjknSetteAplyMon, APLY_STAT_CD_FIX}; // 一時金設定適用月,適用状態コード
String [] setParam = {icjknSetteAplyMon, JBSbatKKConst.TEKIYO_STAT_KAKUTEI}; // 一時金設定適用月,適用状態コード
// ++++++++++ v22.00.00 変更終了 ++++++++++
String [] whereParam = {kicjkinNo}; // 契約一時金番号
// 契約一時金の更新を行います。
this.executeKK_T_KICJKN_PKUPDATE(setParam, whereParam);
super.logPrint.printDebugLog("execute_END");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_KICJKN.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 一時金設定適用月 ICJKN_SETTE_APLY_MON * 適用状態コード APLY_STAT_CD * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * KICJKN_NO *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_KICJKN_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("ICJKN_SETTE_APLY_MON", setParam[0]);
setMap.setValue("APLY_STAT_CD", setParam[1]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("KICJKN_NO", whereParam[0]);
// DBアクセスを実行します
db_KK_T_KICJKN.updateByPrimaryKeys(whereMap, setMap);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 契約一時金のPK検索を行います。
*
* @param kicjkinNo 契約一時金番号。
* @return String 更新年月日時分秒。
* @throws Exception メソッド内で発生した例外全般。
*/
private String getUpdDtm(String kicjkinNo) throws Exception
{
// 契約一時金をPK検索します。
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("KICJKN_NO", kicjkinNo);
// DBアクセスを実行します。
JBSbatCommonDBInterface resultMap = db_KK_T_KICJKN.selectByPrimaryKeys(whereMap);
// 検索結果なしの場合、エラー処理を実行します。
if (null == resultMap)
{
super.logPrint.printDebugLog("契約一時金情報が存在しません。" + kicjkinNo);
// MSG 契約一時金に契約一時金番号:ZZZZZZZZZZが存在しません。
throw new JBSbatBusinessException("EKKB0210CE", new String[]{
"契約一時金", "契約一時金番号:" + kicjkinNo});
}
return JBSbatStringUtil.Rtrim(resultMap.getString(JBSbatKK_T_KICJKN.UPD_DTM));
}
/**
* タイムスタンプチェックを実施します。
*
* @param kicjkinNo 契約一時金番号。
* @param lastUpdDtmStrBf 最終更新年月日時分秒。
* @param lastUpdDtmStrAf 最終更新年月日時分秒。
* @return JBSbatCommonDBInterface SQL実行結果取得用インターフェース。
* @throws Exception
*/
private JBSbatCommonDBInterface getTimeStampCheck(String kicjkinNo, String lastUpdDtmStrBf, String lastUpdDtmStrAf) throws Exception
{
super.logPrint.printDebugLog("更新年月日時分秒(初期検索)：" + lastUpdDtmStrBf);
super.logPrint.printDebugLog("更新年月日時分秒(直前値)::：" + lastUpdDtmStrAf);
// タイムスタンプチェックを実施します。
if (lastUpdDtmStrAf.equals(lastUpdDtmStrBf))
{
// 契約一時金番号の排他制御を行います。
// 条件のマップを作成します。
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("KICJKN_NO", kicjkinNo);
// DBアクセスを実行します。
JBSbatCommonDBInterface dbmap = db_KK_T_KICJKN.selectByPrimaryKeysForUpdateWait(whereMap);
super.logPrint.printDebugLog("タイムスタンプチェック結果_OK");
return dbmap;
}
super.logPrint.printDebugLog("タイムスタンプチェック結果_NG");
return null;
}
}