*
* @author 富士通
*/
public class JBSbatKKTrgtKeiIcjknUpdate extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(契約一時金)*/
private static final String D_TBL_NAME_KK_T_KICJKN = "KK_T_KICJKN";
/** テーブル(進捗)*/
private static final String D_TBL_NAME_KK_T_PRG = "KK_T_PRG";
/** テーブル(サービス契約排他制御)*/
private static final String D_TBL_NAME_KK_T_SVKEI_EXC_CTRL = "KK_T_SVKEI_EXC_CTRL";
/** テーブルアクセスクラス(契約一時金)*/
private JBSbatSQLAccess db_KK_T_KICJKN = null;
/** テーブルアクセスクラス(進捗)*/
private JBSbatSQLAccess db_KK_T_PRG = null;
/** テーブルアクセスクラス(サービス契約排他制御)*/
private JBSbatSQLAccess db_KK_T_SVKEI_EXC_CTRL = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @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);
db_KK_T_PRG = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_PRG);
db_KK_T_SVKEI_EXC_CTRL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVKEI_EXC_CTRL);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
// 中間ファイルよりキー項目の取得
//String kicjknNo = inMap.getString(JBSbatKKIFM055.KICJKN_NO);
//String svcKeiNo = inMap.getString(JBSbatKKIFM055.SVC_KEI_NO);
//String lastUpdDtmBf = inMap.getString(JBSbatKKIFM055.UPD_DTM_BF);
// サービス契約排他制御より最終更新日時を取得し同じ場合排他をかけます。
//String lastUpdDtmAf = searchSvkeiExcCtrl(svcKeiNo);
//if(null == isTimeStampCheck(svcKeiNo, lastUpdDtmBf, lastUpdDtmAf))
//{
//super.logPrint.printBusinessErrorLog("EKKB0360KE", new String[]{"サービス契約排他制御TBL", svcKeiNo});
//super.logPrint.printDebugLog("排他エラーが発生しました。{SVC_KEI_NO:" + svcKeiNo + "}");
//return null;
//}
// SQL実行結果取得用mapを生成（契約一時金）
//JBSbatCommonDBInterface kicjknMap = new JBSbatCommonDBInterface();
// 契約一時金テーブルに排他制御処理を実行する
//kicjknMap.setValue("KICJKN_NO", kicjknNo);
//db_KK_T_KICJKN.selectByPrimaryKeysForUpdate(kicjknMap);
// 設定項目を設定します
//String [] setParam = {"2"};
//super.logPrint.printDebugLog("setParam(適用状態コード)：" + setParam[0]);
// 条件項目を設定します
//String [] whereParam = {kicjknNo};
//super.logPrint.printDebugLog("whereParam(KICJKN_NO)：：：：：" + whereParam[0]);
// サービス契約のPK更新を実行する
//executeKK_T_KICJKN_PKUPDATE(setParam, whereParam);
// TODO 進捗の登録は「UIA28_機能仕様補足(進捗について)」提供後
// 進捗情報の登録処理を行います。
//insertPrg();
// サービス契約排他制御への更新処理を実行する
//upDateSvkeiExcCtrl(svcKeiNo);
super.logPrint.printDebugLog("execute_END");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_KICJKN.close();
db_KK_T_PRG.close();
db_KK_T_SVKEI_EXC_CTRL.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 適用状態コード 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("APLY_STAT_CD", setParam[0]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("KICJKN_NO", whereParam[0]);
// DBアクセスを実行します
db_KK_T_KICJKN.updateByPrimaryKeys(whereMap, setMap);
}
/**
* PK(全項目登録)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 進捗番号 PRG_NO * 申込明細番号 MSKM_DTL_NO * 請求契約番号 SEIKY_KEI_NO * 請求方法番号（口座） SEIKY_WAY_NO_KOZA * 請求方法番号（クレジットカード） SEIKY_WAY_NO_CRECARD * サービス契約番号 SVC_KEI_NO * サービス契約内訳番号 SVC_KEI_UCWK_NO * サービス契約回線内訳番号 SVC_KEI_KAISEN_UCWK_NO * 機器提供サービス契約番号 KKTK_SVC_KEI_NO * オプションサービス契約番号 OP_SVC_KEI_NO * 請求オプションサービス契約番号 SEIOPSVC_KEI_NO * サブオプションサービス契約番号 SBOP_SVC_KEI_NO * 割引サービス契約番号 WRIB_SVC_KEI_NO * 異動区分 IDO_DIV * 異動理由コード IDO_RSN_CD * 異動年月日時分秒 IDO_DTM * 進捗ステータス PRG_STAT * 進捗年月日時分秒 PRG_DTM * 進捗結果コード PRG_RSLT_CD * 進捗メモ PRG_MEMO * 登録年月日時分秒 ADD_DTM * 登録オペレータアカウント ADD_OPEACNT * 更新年月日時分秒 UPD_DTM * 更新オペレータアカウント UPD_OPEACNT * 削除年月日時分秒 DEL_DTM * 削除オペレータアカウント DEL_OPEACNT * 無効フラグ MK_FLG *
* @param setParam 設定項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_PRG_PKINSERT(Object[] setParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("PRG_NO", setParam[0]);
setMap.setValue("MSKM_DTL_NO", setParam[1]);
setMap.setValue("SEIKY_KEI_NO", setParam[2]);
setMap.setValue("SEIKY_WAY_NO_KOZA", setParam[3]);
setMap.setValue("SEIKY_WAY_NO_CRECARD", setParam[4]);
setMap.setValue("SVC_KEI_NO", setParam[5]);
setMap.setValue("SVC_KEI_UCWK_NO", setParam[6]);
setMap.setValue("SVC_KEI_KAISEN_UCWK_NO", setParam[7]);
setMap.setValue("KKTK_SVC_KEI_NO", setParam[8]);
setMap.setValue("OP_SVC_KEI_NO", setParam[9]);
setMap.setValue("SEIOPSVC_KEI_NO", setParam[10]);
setMap.setValue("SBOP_SVC_KEI_NO", setParam[11]);
setMap.setValue("WRIB_SVC_KEI_NO", setParam[12]);
setMap.setValue("IDO_DIV", setParam[13]);
setMap.setValue("IDO_RSN_CD", setParam[14]);
setMap.setValue("IDO_DTM", setParam[15]);
setMap.setValue("PRG_STAT", setParam[16]);
setMap.setValue("PRG_DTM", setParam[17]);
setMap.setValue("PRG_RSLT_CD", setParam[18]);
setMap.setValue("PRG_MEMO", setParam[19]);
setMap.setValue("ADD_DTM", setParam[20]);
setMap.setValue("ADD_OPEACNT", setParam[21]);
setMap.setValue("UPD_DTM", setParam[22]);
setMap.setValue("UPD_OPEACNT", setParam[23]);
setMap.setValue("DEL_DTM", setParam[24]);
setMap.setValue("DEL_OPEACNT", setParam[25]);
setMap.setValue("MK_FLG", setParam[26]);
// DBアクセスを実行します
db_KK_T_PRG.insertByPrimaryKeys(setMap);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
*
* 進捗情報の登録を行います。
*
* @throws Exception メソッド内で発生した例外全般。
*/
private void insertPrg() throws Exception
{
// // SQL実行結果取得用mapを生成（サービス契約）
// JBSbatCommonDBInterface svcKeiMap = new JBSbatCommonDBInterface();
//
// // SQL定義キー(KK_SELECT_032)を実行する
// String [] selectParam = {svcKeiNo, opeDate};
// super.logPrint.printDebugLog("selectParam：：：：：" + selectParam);
// executeKK_T_SVC_KEI_KK_SELECT_032(selectParam);
// // 検索結果を取得する
// for(svcKeiMap = db_KK_T_SVC_KEI.selectNext(); null != svcKeiMap ; svcKeiMap = db_KK_T_SVC_KEI.selectNext())
// {
// //サービス契約情報の項目を取得
// String mskmDtlNo = svcKeiMap.getString("MSKM_DTL_NO");
// String idoDiv = svcKeiMap.getString("IDO_DIV");
// String idoRsnCd = svcKeiMap.getString("IDO_RSN_CD");
// String prgStat = "";
// if("OK".equals(tknChsHntiCd))
// {
// prgStat = "9530";
// }
// else
// {
// prgStat = "953E";
// }
// if(tknChsSudksJruYmd != null)
// {
// prgStat = "9540";
// }
//
// String prgRsltCd = "";
// if("OK".equals(tknChsHntiCd))
// {
// prgRsltCd = "OK";
// }
// else
// {
// prgRsltCd = "NG";
// }
//
// /* ++++++++++ v1.02.00 追加開始 ++++++++++ */
// String sysDate = JBSbatInterface.getSystemDateTimeStamp();
// /* ++++++++++ v1.02.00 追加終了 ++++++++++ */
//
// // 登録する進捗のパラメータを設定します
// String [] setParam = {
// JBSbatOracleSeqUtil.getNextSeq(commonItem.getConnection(), SEQ_PRG_NO), // 進捗番号 → 自動採番
// mskmDtlNo, // 申込明細番号 → KK_T_SVC_KEI.KK_SELECT_002.MSKM_DTL_NO
// "", // 請求契約番号 → NULL（未設定）
// "", // 請求方法番号（口座） → NULL（未設定）
// "", // 請求方法番号（クレジットカード） → NULL（未設定）
// svcKeiNo, // サービス契約番号 → 宅内調査結果情報中間ファイル．サービス契約番号
// "", // サービス契約内訳番号 → NULL（未設定）
// "", // サービス契約回線内訳番号 → NULL（未設定）
// "", // 機器提供サービス契約番号 → NULL（未設定）
// "", // オプションサービス契約番号 → NULL（未設定）
// "", // 請求オプションサービス契約番号 → NULL（未設定）
// "", // サブオプションサービス契約番号 → NULL（未設定）
// "", // 割引サービス契約番号 → NULL（未設定）
// idoDiv, // 異動区分 → KK_T_SVC_KEI.KK_SELECT_002.IDO_DIV
// idoRsnCd, // 異動理由コード → KK_SELECT_002.IDO_RSN_CD
// tknChsJishiYmd, // 異動年月日時分秒 → 宅内調査結果情報中間ファイル．宅内調査実施年月日
// prgStat, // 進捗ステータス → "9530"or"953E"or"9540"
//
// /* ++++++++++ v1.02.00 修正開始 ++++++++++ */
// JBSbatInterface.getSystemDateTimeStamp(), // 進捗年月日時分秒 → システム日時
// super.opeDate + sysDate.substring(8), // 進捗年月日時分秒 → バッチ運用日+実施日のhhmmssSSSを設定。
// /* ++++++++++ v1.02.00 修正終了 ++++++++++ */
//
// prgRsltCd, // 進捗結果コード → "OK"or"NG"
// "", // 進捗メモ → NULL（未設定）
//
// /* ++++++++++ v1.02.00 修正開始 ++++++++++ */
// JBSbatInterface.getSystemDateTimeStamp(),
// sysDate, // 登録年月日時分秒 → システム日時
// /* ++++++++++ v1.02.00 修正終了 ++++++++++ */
//
// batchUserId, // 登録オペレータアカウント → バッチ更新者ＩＤ
// /* ++++++++++ v1.02.00 修正開始 ++++++++++ */
// JBSbatInterface.getSystemDateTimeStamp(), // 更新年月日時分秒 → システム日時
// sysDate, // 更新年月日時分秒 → システム日時
// /* ++++++++++ v1.02.00 修正終了 ++++++++++ */
//
// batchUserId, // 更新オペレータアカウント → バッチ更新者ＩＤ
// "", // 削除年月日時分秒 → NULL（未設定）
// "", // 削除オペレータアカウント → NULL（未設定）
// "0"}; // 無効フラグ → "0"(有効)
//
// super.logPrint.printDebugLog("setParam：：：：：" + setParam);
// executeKK_T_PRG_PKINSERT(setParam);
// }
}
/**
* サービス契約排他制御テーブルの検索を行います。
*
* @param svc_kei_no サービス契約番号
* @throws Exception
*/
private String searchSvkeiExcCtrl(String svc_kei_no) throws Exception
{
// SQL実行結果取得用mapを生成（サービス契約TBL）
JBSbatCommonDBInterface pkMap = new JBSbatCommonDBInterface();
// 条件項目を設定します
pkMap.setValue(JBSbatKK_T_SVKEI_EXC_CTRL.SVC_KEI_NO, svc_kei_no);
super.logPrint.printDebugLog("pkParam(ｻｰﾋﾞｽ契約番号)：：：：：：" + svc_kei_no);
// PK検索を行う
JBSbatCommonDBInterface outMap = db_KK_T_SVKEI_EXC_CTRL.selectByPrimaryKeys(pkMap);
if(outMap == null)
{
super.logPrint.printDebugLog("サービス契約排他制御情報が存在しません。");
// MSG サービス契約排他制御テーブルにサービス契約番号:ZZZZZZZZZZが存在しません。
throw new JBSbatBusinessException("EKKB0210CE", new String[]{"サービス契約排他制御", "サービス契約番号:" + svc_kei_no});
}
return outMap.getString(JBSbatKK_T_SVKEI_EXC_CTRL.LAST_UPD_DTM);
}
/**
* タイムスタンプチェックを実施します。
*
* @param svcKeiNo サービス契約番号。
* @param lastUpdDtmStrBf 最終更新年月日時分秒。
* @param lastUpdDtmStrAf 最終更新年月日時分秒。
* @throws Exception
*/
private JBSbatCommonDBInterface isTimeStampCheck(String svcKeiNo, String lastUpdDtmStrBf, String lastUpdDtmStrAf) throws Exception
{
// ログレベルがデバッグモードの場合
if(super.logPrint.chkLogLevel(JBSbatLogUtil.MODE_DEBUG))
{
super.logPrint.printDebugLog("更新年月日時分秒(初期検索)：" + lastUpdDtmStrBf);
super.logPrint.printDebugLog("更新年月日時分秒(直前値)::：" + lastUpdDtmStrAf);
}
// タイムスタンプチェックの実施。
if(lastUpdDtmStrAf.equals(lastUpdDtmStrBf))
{
JBSbatCommonDBInterface svkeiExcCtrlMap = new JBSbatCommonDBInterface();
// サービス契約排他制御テーブルに排他制御処理を実行する
svkeiExcCtrlMap.setValue(JBSbatKK_T_SVKEI_EXC_CTRL.SVC_KEI_NO, svcKeiNo);
JBSbatCommonDBInterface dbmap = db_KK_T_SVKEI_EXC_CTRL.selectByPrimaryKeysForUpdateWait(svkeiExcCtrlMap);
if(super.logPrint.chkLogLevel(JBSbatLogUtil.MODE_DEBUG))
{
super.logPrint.printDebugLog("タイムスタンプチェック結果_OK");
}
return dbmap;
}
if(super.logPrint.chkLogLevel(JBSbatLogUtil.MODE_DEBUG))
{
super.logPrint.printDebugLog("タイムスタンプチェック結果_NG");
}
return null;
}
/**
* サービス契約排他制御への更新処理を行います。
*
* 処理フロー
*
* 1.更新処理を実行します。*
* *
* @param svcKeiNo サービス契約番号。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void upDateSvkeiExcCtrl(String svcKeiNo) throws Exception { // サービス契約排他制御の最終更新年月日時分秒の更新を行う。 JBSbatCommonDBInterface paramMap = new JBSbatCommonDBInterface(); JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); // サービス契約番号を設定 whereMap.setValue(JBSbatKK_T_SVKEI_EXC_CTRL.SVC_KEI_NO, svcKeiNo); // 最終更新年月日時分秒を更新。 paramMap.setValue(JBSbatKK_T_SVKEI_EXC_CTRL.LAST_UPD_DTM, JBSbatDateUtil.getSystemDateTimeStamp()); db_KK_T_SVKEI_EXC_CTRL.updateByPrimaryKeys(whereMap, paramMap); } }