*
* @author 富士通
*/
public class JBSbatKKRouterDslRsltStatUpd extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(機器提供サービス契約)*/
private static final String D_TBL_NAME_KK_T_KKTK_SVC_KEI = "KK_T_KKTK_SVC_KEI";
/** テーブル(進捗)*/
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_KKTK_SVC_KEI = null;
/** テーブルアクセスクラス(進捗)*/
private JBSbatSQLAccess db_KK_T_PRG = null;
/** テーブルアクセスクラス(サービス契約排他制御)*/
private JBSbatSQLAccess db_KK_T_SVKEI_EXC_CTRL = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** テーブルアクセスクラス(共通部品)*/
private JBSbatSQLAccess stmt = null;
/** 異動区分（機器解約変更）*/
public static final String IDO_DIV_KIKI_DSL_CHG = "00026";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KK_T_KKTK_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KKTK_SVC_KEI);
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);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
// 共通部品用
stmt = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_PRG);
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
String svc_kei_no = "";
// サービス契約番号
svc_kei_no = inMap.getString(JBSbatKKIFM152.SVC_KEI_NO);
JBSbatCommonDBInterface commonDb = null;
JBSbatCommonDBInterface where_map = new JBSbatCommonDBInterface();
where_map.setValue(JBSbatKK_T_SVKEI_EXC_CTRL.SVC_KEI_NO, svc_kei_no);
// サービス契約排他制御の排他検索処理
commonDb = db_KK_T_SVKEI_EXC_CTRL.selectByPrimaryKeysForUpdateWait(where_map);
// 排他エラーの場合
if(null == commonDb)
{
super.logPrint.printBusinessErrorLog("EKKB0360KE",
new String[]{"サービス契約排他制御TBL", svc_kei_no});
super.logPrint.printDebugLog("排他エラーが発生しました。{SVC_KEI_NO:" + svc_kei_no + "}");
return null;
}
// 機器提供サービス契約情報の更新処理
updateKktkSVcKei(inMap);
// サービス契約排他制御更新
upDateSvkeiExcCtrl(svc_kei_no);
// 進捗情報の全項目登録処理
insertHmpInKiki(inMap);
super.logPrint.printDebugLog("execute_END");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_KKTK_SVC_KEI.close();
db_KK_T_PRG.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
// 共通部品用
stmt.close();
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * ルーター解約予約処理状態コード ROUTER_DSL_RSV_TRN_STAT_CD * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * KKTK_SVC_KEI_NO * GENE_ADD_DTM *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_KKTK_SVC_KEI_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("ROUTER_DSL_RSV_TRN_STAT_CD", setParam[0]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("KKTK_SVC_KEI_NO", whereParam[0]);
whereMap.setValue("GENE_ADD_DTM", whereParam[1]);
// DBアクセスを実行します
db_KK_T_KKTK_SVC_KEI.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_DTM * 進捗ステータス PRG_STAT * 進捗年月日時分秒 PRG_DTM * 進捗メモ PRG_MEMO * 進捗特記事項１ PRG_TKJK_1 * 進捗特記事項２ PRG_TKJK_2 * 登録年月日時分秒 ADD_DTM * 登録オペレータアカウント ADD_OPEACNT * 更新年月日時分秒 UPD_DTM * 更新オペレータアカウント UPD_OPEACNT * 削除年月日時分秒 DEL_DTM * 削除オペレータアカウント DEL_OPEACNT * 無効フラグ MK_FLG * 登録運用年月日 ADD_UNYO_YMD * 登録処理ＩＤ ADD_TRN_ID * 更新運用年月日 UPD_UNYO_YMD * 更新処理ＩＤ UPD_TRN_ID * 削除運用年月日 DEL_UNYO_YMD * 削除処理ＩＤ DEL_TRN_ID *
* @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_DTM", setParam[14]);
setMap.setValue("PRG_STAT", setParam[15]);
setMap.setValue("PRG_DTM", setParam[16]);
setMap.setValue("PRG_MEMO", setParam[17]);
setMap.setValue("PRG_TKJK_1", setParam[18]);
setMap.setValue("PRG_TKJK_2", 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]);
setMap.setValue("ADD_UNYO_YMD", setParam[27]);
setMap.setValue("ADD_TRN_ID", setParam[28]);
setMap.setValue("UPD_UNYO_YMD", setParam[29]);
setMap.setValue("UPD_TRN_ID", setParam[30]);
setMap.setValue("DEL_UNYO_YMD", setParam[31]);
setMap.setValue("DEL_TRN_ID", setParam[32]);
// DBアクセスを実行します
db_KK_T_PRG.insertByPrimaryKeys(setMap);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
*
* 機器提供サービス契約情報の更新処理を行います。
*
* 1.PK検索を実行します。
*
* 2.更新処理を実行します。
*
* @param inMap ルータ解約結果更新ファイル情報
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void updateKktkSVcKei(JBSbatServiceInterfaceMap inMap) throws Exception
{
JBSbatCommonDBInterface out_map = null;
JBSbatCommonDBInterface where_map = new JBSbatCommonDBInterface();
// 機器提供サービス契約番号の初期化
String kktkSvcKeiNo = "";
// 世代登録年月日時分秒の初期化
String geneAddDtm = "";
// 機器提供サービス契約番号
kktkSvcKeiNo = inMap.getString(JBSbatKKIFM152.KKTK_SVC_KEI_NO);
// 世代登録年月日時分秒
geneAddDtm = inMap.getString(JBSbatKKIFM152.GENE_ADD_DTM);
// PK検索を行います。
where_map.setValue(JBSbatKK_T_KKTK_SVC_KEI.KKTK_SVC_KEI_NO, kktkSvcKeiNo);
where_map.setValue(JBSbatKK_T_KKTK_SVC_KEI.GENE_ADD_DTM, geneAddDtm);
out_map = db_KK_T_KKTK_SVC_KEI.selectByPrimaryKeys(where_map);
// PK検索結果が「NULL」でない場合
if (null != out_map)
{
// ルーター解約予約処理状態コード（更新項目："3"（帳票出力済）)
String routerDslRsvTrnStatCdUpd = "3";
// 設定項目を設定します
String [] setParam = {routerDslRsvTrnStatCdUpd };
super.logPrint.printDebugLog("更新setParam(ルーター解約予約処理状態コード)：" + setParam[0]);
// 条件項目を設定します
String [] whereParam = {kktkSvcKeiNo, geneAddDtm};
super.logPrint.printDebugLog("更新whereParam(機器提供サービス契約番号)：" + whereParam[0]);
super.logPrint.printDebugLog("更新whereParam(世代登録年月日時分秒)：" + whereParam[1]);
// 機器提供サービス契約テーブルのPK更新を実行する
executeKK_T_KKTK_SVC_KEI_PKUPDATE(setParam, whereParam);
}
// PK検索結果が「NULL」の場合
else
{
// 検索結果が無い場合は、システムエラーにする。
throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0210CE,
new String[]{"機器提供サービス契約", "機器提供サービス契約番号：" + kktkSvcKeiNo});
}
}
/**
*
* 進捗情報の登録処理を行います。
*
* @param inMap ルータ解約結果更新ファイル情報
* @throws Exception メソッド内で発生した例外全般。
*/
private void insertHmpInKiki(JBSbatServiceInterfaceMap inMap) throws Exception
{
// 進捗番号を採番
String seqPrgNo = JBSbatStringUtil.padNumFormString(JBSbatOracleSeqUtil.getNextSeq(commonItem.getConnection(), "SEQ_PRG_NO"), 12);
// サービス契約番号の初期化
String svcKeiNo = "";
// サービス契約番号
svcKeiNo = inMap.getString(JBSbatKKIFM152.SVC_KEI_NO);
// システム日付を取得
String sysDate = JCCBatCommon.getSysDateTimeStamp();
//共通部品（進捗.異動年月日取得部品）より異動年月日時分秒（またはシステム日付）を取得
String idoDtm = JKKBatCommon. getIdoDtmMax(commonItem, svcKeiNo, IDO_DIV_KIKI_DSL_CHG, stmt);
// 登録する進捗のパラメータを設定します
String [] setParam = {
seqPrgNo, // 進捗番号 → 採番
"", // 申込明細番号 → NULL（未設定）
"", // 請求契約番号 → NULL（未設定）
"", // 請求方法番号（口座） → NULL（未設定）
"", // 請求方法番号（クレジットカード） → NULL（未設定）
svcKeiNo, // サービス契約番号 → ルータ解約結果更新ファイル．サービス契約番号
"", // サービス契約内訳番号 → NULL（未設定）
"", // サービス契約回線内訳番号 → NULL（未設定）
"", // 機器提供サービス契約番号 → NULL（未設定）
"", // オプションサービス契約番号 → NULL（未設定）
"", // 請求オプションサービス契約番号 → NULL（未設定）
"", // サブオプションサービス契約番号 → NULL（未設定）
"", // 割引サービス契約番号 → NULL（未設定）
IDO_DIV_KIKI_DSL_CHG, // 異動区分 → "00026"（機器解約変更）
idoDtm, // 異動年月日時分秒 → 共通部品（進捗.異動年月日取得部品）からの戻り値を設定。
"3200", // 進捗ステータス →"3200"（レンタル解約完了）
/* ++++++++++ v1.01.00 修正開始 ++++++++++ */
// sysDate, // 進捗年月日時分秒 → システム日付
super.opeDate + sysDate.substring(8), // 進捗年月日時分秒 → バッチ運用日+実施日のhhmmssSSSを設定。
/* ++++++++++ v1.01.00 修正終了 ++++++++++ */
"", // 進捗メモ → NULL（未設定）
"", // 進捗特記事項１ → NULL（未設定）
"", // 進捗特記事項２ → NULL（未設定）
sysDate, // 登録年月日時分秒 → システム日時
super.batchUserId, // 登録オペレータアカウント → バッチ更新者ＩＤ
sysDate, // 更新年月日時分秒 → システム日時
super.batchUserId, // 更新オペレータアカウント → バッチ更新者ＩＤ
"", // 削除年月日時分秒 → NULL（未設定）
"", // 削除オペレータアカウント → NULL（未設定）
"0", // 無効フラグ → "0"(有効)
"", // 登録運用年月日
"", // 登録処理ID
"", // 更新運用年月日
"", // 更新処理ID
"", // 削除運用年月日
""}; // 削除処理ID
// ログレベルがデバッグモードの場合
if(super.logPrint.chkLogLevel(JBSbatLogUtil.MODE_DEBUG))
{
super.logPrint.printDebugLog("登録setParam( 進捗番号)：" + setParam[0]);
super.logPrint.printDebugLog("登録setParam(申込明細番号)：" + setParam[1]);
super.logPrint.printDebugLog("登録setParam(請求契約番号)：" + setParam[2]);
super.logPrint.printDebugLog("登録setParam(請求方法番号（口座）)：" + setParam[3]);
super.logPrint.printDebugLog("登録setParam(請求方法番号（クレジットカード）)：" + setParam[4]);
super.logPrint.printDebugLog("登録setParam(サービス契約番号)：" + setParam[5]);
super.logPrint.printDebugLog("登録setParam(サービス契約内訳番号)：" + setParam[6]);
super.logPrint.printDebugLog("登録setParam(サービス契約回線内訳番号)：" + setParam[7]);
super.logPrint.printDebugLog("登録setParam(機器提供サービス契約番号)：" + setParam[8]);
super.logPrint.printDebugLog("登録setParam(オプションサービス契約番号)：" + setParam[9]);
super.logPrint.printDebugLog("登録setParam(請求オプションサービス契約番号)：" + setParam[10]);
super.logPrint.printDebugLog("登録setParam(サブオプションサービス契約番号)：" + setParam[11]);
super.logPrint.printDebugLog("登録setParam(割引サービス契約番号)：" + setParam[12]);
super.logPrint.printDebugLog("登録setParam(異動区分)：：" + setParam[13]);
super.logPrint.printDebugLog("登録setParam(異動年月日時分秒)：" + setParam[14]);
super.logPrint.printDebugLog("登録setParam(進捗ステータス)：" + setParam[15]);
super.logPrint.printDebugLog("登録setParam(進捗年月日時分秒)：" + setParam[16]);
super.logPrint.printDebugLog("登録setParam(進捗メモ)：" + setParam[17]);
super.logPrint.printDebugLog("登録setParam(進捗特記事項１)：" + setParam[18]);
super.logPrint.printDebugLog("登録setParam(進捗特記事項２)：" + setParam[19]);
super.logPrint.printDebugLog("登録setParam(登録年月日時分秒)：" + setParam[20]);
super.logPrint.printDebugLog("登録setParam(登録オペレータアカウント)：" + setParam[21]);
super.logPrint.printDebugLog("登録setParam(更新年月日時分秒)：" + setParam[22]);
super.logPrint.printDebugLog("登録setParam(更新オペレータアカウント)：" + setParam[23]);
super.logPrint.printDebugLog("登録setParam(削除年月日時分秒)：" + setParam[24]);
super.logPrint.printDebugLog("登録setParam(削除オペレータアカウント)：" + setParam[25]);
super.logPrint.printDebugLog("登録setParam(無効フラグ)：" + setParam[26]);
super.logPrint.printDebugLog("登録setParam(登録運用年月日)：" + setParam[27]);
super.logPrint.printDebugLog("登録setParam(登録処理ID)：" + setParam[28]);
super.logPrint.printDebugLog("登録setParam(更新運用年月日)：" + setParam[29]);
super.logPrint.printDebugLog("登録setParam(更新処理ID)：" + setParam[30]);
super.logPrint.printDebugLog("登録setParam(削除運用年月日)：" + setParam[31]);
super.logPrint.printDebugLog("登録setParam(削除処理ID)：" + setParam[32]);
}
// 進捗テーブルの全項目登録を実行する
executeKK_T_PRG_PKINSERT(setParam);
}
/**
* サービス契約排他制御への更新処理を行います。
*
* 処理フロー
*
* 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); } }