*
* @author 富士通
*/
public class JBSbatKKUpdCashPostSiteKanriNo extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(キャッシュポスト契約)*/
private static final String D_TBL_NAME_KK_T_CASHPOST_KEI = "KK_T_CASHPOST_KEI";
/** SQL定義キー(KK_UPDATE_001)*/
private static final String KK_T_CASHPOST_KEI_KK_UPDATE_001 = "KK_UPDATE_001";
/** SQL定義キー(KK_SELECT_004)*/
private static final String KK_T_CASHPOST_KEI_KK_SELECT_004 = "KK_SELECT_004";
/** テーブルアクセスクラス(キャッシュポスト契約)*/
private JBSbatSQLAccess db_KK_T_CASHPOST_KEI = null;
/** 総更新レコード件数 */
private int allUpdCnt = 0;
/** 総更新処理件数 */
private int allUpdshoriCnt = 0;
/** ヘッダーカウント */
private int headerCnt = 0;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KK_T_CASHPOST_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_CASHPOST_KEI);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @throws Exception
*/
public void execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
// ヘッダーは読み飛ばす
if(headerCnt == 0)
{
headerCnt++;
return;
}
if(inMap.getString("CASHPOST_UK_NO") == null)
{
return;
}
// 受付で検索してcashpost契約番号を検索
// 2個以上はアウト
// ログを出す。
// キャッシュポスト受付番号を取得(半角ハイフン削除)
String ukNo = inMap.getString("CASHPOST_UK_NO").replaceAll("-", "");
// サイト管理番号を取得
String siteKanriNo = inMap.getString("SITE_KANRI_NO");
// サイト管理番号の件数が2件以上無い場合のみ更新処理を実行
if(judgeSameCashPostKeiNo(ukNo))
{
String[] msgParam = new String[]{"CASHPOST受付番号" , "CASHPOST受付番号:"+ukNo };
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB2150AI, msgParam);
}
else
{
// 更新処理を実行
updateSiteKanriNo(siteKanriNo, ukNo);
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_CASHPOST_KEI.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.ECHB1190AI,
new String[] {"合計レコード", String.valueOf(allUpdCnt)});
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EKKB1650AI,
new String[] {"レコード更新", String.valueOf(allUpdshoriCnt)});
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* キャッシュポスト契約更新処理
*
* @param siteKanriNo サイト管理番号
* @param ukNo キャッシュポスト受付番号
* @throws Exception
*/
private void updateSiteKanriNo(String siteKanriNo, String ukNo) throws Exception
{
String[] param = new String[2];
// サイト管理番号
param[0] = siteKanriNo;
// キャッシュポスト受付番号
param[1] = ukNo;
// キャッシュポスト契約更新処理実施
executeKK_T_CASHPOST_KEI_KK_UPDATE_001(param);
}
/**
* SQLKEY(KK_UPDATE_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サイト管理番号 * キャッシュポスト受付番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_CASHPOST_KEI_KK_UPDATE_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
//▼▼▼件数取得のため自働生成部を変更▼▼▼
int cnt = db_KK_T_CASHPOST_KEI.executeBySqlDefine(paramList, KK_T_CASHPOST_KEI_KK_UPDATE_001);
//▲▲▲件数取得のため自働生成部を変更▲▲▲
if(cnt <= 0)
{
String[] msgParam = new String[]{"更新対象レコード無し:CASHPOST受付番号:"+param[1].toString()};
super.logPrint.printBusinessErrorLog(JPCBatchMessageConstant.EACB1000CI, msgParam);
}
else
{
allUpdCnt = allUpdCnt + cnt;
allUpdshoriCnt++;
}
}
/**
* SQLKEY(KK_SELECT_004)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サイト管理番号 * キャッシュポスト受付番号 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private boolean judgeSameCashPostKeiNo(String ukNo) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(ukNo); boolean sameCashPostKeiNoFlg = false; // DBアクセスを実行します int getCashPostCnt = db_KK_T_CASHPOST_KEI.executeBySqlDefine(paramList, KK_T_CASHPOST_KEI_KK_SELECT_004); if(getCashPostCnt >= 2) { sameCashPostKeiNoFlg = true; } return sameCashPostKeiNoFlg; } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }