*
* @author 富士通
*/
public class JBSbatKKNttorsPrgAdd extends JBSbatBusinessService
{
/** テーブル(サービス契約)*/
private static final String D_TBL_NAME_KK_T_SVC_KEI = "KK_T_SVC_KEI";
/** テーブル(進捗)*/
private static final String D_TBL_NAME_KK_T_PRG = "KK_T_PRG";
/** テーブル(お客様)*/
private static final String D_TBL_NAME_CK_T_CUST = "CK_T_CUST";
/** テーブルアクセスクラス(サービス契約)*/
private JBSbatSQLAccess db_KK_T_SVC_KEI = null;
/** テーブルアクセスクラス(進捗)*/
private JBSbatSQLAccess db_KK_T_PRG = null;
/** テーブルアクセスクラス(お客様)*/
private JBSbatSQLAccess db_CK_T_CUST = null;
/** テーブルアクセスクラス(共通部品)*/
private JBSbatSQLAccess stmt = null;
/** SQL定義キー(KK_SELECT_002)*/
private static final String KK_T_SVC_KEI_KK_SELECT_032 = "KK_SELECT_032";
/** SQL定義キー(KK_SELECT_237)*/
private static final String KK_T_SVC_KEI_KK_SELECT_237 = "KK_SELECT_237";
/** SQL定義キー(KK_SELECT_020)*/
private static final String CK_T_CUST_KK_SELECT_020 = "KK_SELECT_020";
/** シーケンス定義名(SEQ_PRG_NO)*/
private static final String SEQ_PRG_NO = "SEQ_PRG_NO";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KK_T_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI);
db_KK_T_PRG = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_PRG);
db_CK_T_CUST = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CK_T_CUST);
// 共通部品用
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 svcKeiNo = inMap.getString(JBSbatKKIFM968.SVC_KEI_NO);
// サービス開始年月日
String svcStaymd = inMap.getString(JBSbatKKIFM968.SVC_STAYMD);
// サービス課金開始年月日（ＳＶＣ）
String svcChrgStaymd = inMap.getString(JBSbatKKIFM968.SVC_CHRG_STAYMD);
// SQL定義キー(KK_SELECT_032)を実行する
String [] param = {svcKeiNo, opeDate};
executeKK_T_SVC_KEI_KK_SELECT_032(param);
// 検索結果を取得する
JBSbatCommonDBInterface svcKeiMap = db_KK_T_SVC_KEI.selectNext();
if(null != svcKeiMap)
{
// 異動区分 = 受付時の異動区分を検索し設定する。
String[] selectParam = {svcKeiNo, super.opeDate};
this.executeKK_T_SVC_KEI_KK_SELECT_237(selectParam);
JBSbatCommonDBInterface idoDivMap = db_KK_T_SVC_KEI.selectNext();
// 異動区分
String idoDiv = JBSbatStringUtil.Rtrim(idoDivMap.getString(JBSbatKK_T_SVC_KEI.IDO_DIV));
// サービス契約を登録します。
this.insertPrg(svcKeiMap, idoDiv, svcStaymd, svcChrgStaymd);
// お客様入会年月日設定処理を行う。
this.setCustJoinYMD(svcKeiMap, svcStaymd);
}
super.logPrint.printDebugLog("execute_END");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception {
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
if (db_KK_T_SVC_KEI != null) {
db_KK_T_SVC_KEI.close();
}
if (db_KK_T_PRG != null) {
db_KK_T_PRG.close();
}
if (db_CK_T_CUST != null) {
db_CK_T_CUST.close();
}
if (stmt != null) {
stmt.close();
}
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**
* SQLKEY(KK_SELECT_032)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約番号 * 予約適用年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVC_KEI_KK_SELECT_032(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KK_SELECT_032);
}
/**
* SQLKEY(KK_SELECT_237)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * SVC_KEI_NO * RSV_APLY_YMD *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVC_KEI_KK_SELECT_237(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KK_SELECT_237);
}
/**
* 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);
}
/**
* SQLKEY(KK_SELECT_020)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * SYSID * 予約適用年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCK_T_CUST_KK_SELECT_020(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_CK_T_CUST.selectBySqlDefine(paramList, CK_T_CUST_KK_SELECT_020);
}
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 入会年月日 JOIN_YMD * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * SYSID * GENE_ADD_DTM *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCK_T_CUST_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("JOIN_YMD", setParam[0]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("SYSID", whereParam[0]);
whereMap.setValue("GENE_ADD_DTM", whereParam[1]);
// DBアクセスを実行します
db_CK_T_CUST.updateByPrimaryKeys(whereMap, setMap);
}
/**
* サービス契約を登録します。
*
* @param outMap サービス契約検索結果
* @param String サービス開始年月日
* @throws Exception
*/
private void insertPrg(JBSbatCommonDBInterface outMap, String idoDiv, String svcStaymd, String svcChrgStaymd) throws Exception
{
// 登録用データ格納
Object[] param_add = new Object[33];
// システム日付を取得
String sysDate = JCCBatCommon.getSysDateTimeStamp();
// サービス契約番号を取得
String svcKeiNo = JBSbatStringUtil.Rtrim(outMap.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO));
// 共通部品（進捗.異動年月日取得部品）より異動年月日時分秒（またはシステム日付）を取得
String idoDtm = JKKBatCommon. getIdoDtmMax(commonItem, svcKeiNo, idoDiv, stmt);
// 進捗番号 → 自動採番
param_add[0] = JBSbatStringUtil.padNumFormString(JBSbatOracleSeqUtil.getNextSeq(commonItem.getConnection(), SEQ_PRG_NO), 12);
// 申込明細番号
param_add[1] = JBSbatStringUtil.Rtrim(outMap.getString(JBSbatKK_T_SVC_KEI.MSKM_DTL_NO));
// 請求契約番号 → NULL（未設定）
param_add[2] = "";
// 請求方法番号（口座） → NULL（未設定）
param_add[3] = "";
// 請求方法番号（クレジットカード） → NULL（未設定）
param_add[4] = "";
// サービス契約番号 → サービス開始対象契約取得ファイル.サービス契約番号
param_add[5] = svcKeiNo;
// サービス契約内訳番号 → NULL（未設定）
param_add[6] = "";
// サービス契約回線内訳番号 → NULL（未設定）
param_add[7] = "";
// 機器提供サービス契約番号 → NULL（未設定）
param_add[8] = "";
// オプションサービス契約番号 → NULL（未設定）
param_add[9] = "";
// 請求オプションサービス契約番号 → NULL（未設定）
param_add[10] = "";
// サブオプションサービス契約番号 → NULL（未設定）
param_add[11] = "";
// 割引サービス契約番号 → NULL（未設定）
param_add[12] = "";
// 異動区分 → KK_T_SVC_KEI.KK_SELECT_032.IDO_DIV
param_add[13] = idoDiv;
// 異動年月日時分秒 → 共通部品（進捗.異動年月日取得部品）
param_add[14] = idoDtm;
// 進捗ステータス → 1000
param_add[15] = JBSbatKKConst.CD00647_PRG_STAT_1000;
// 進捗年月日時分秒 → バッチ運用日+実施日のhhmmssSSSを設定。
param_add[16] = super.opeDate + sysDate.substring(8);
// 進捗メモ → NULL（未設定）
param_add[17] = "";
// 進捗特記事項１ → NULL（未設定）
param_add[18] = "";
// 進捗特記事項２ → サービス開始日、サービス課金開始日の表示
param_add[19] = getPrgTkjk2(svcStaymd, svcChrgStaymd);
// 登録年月日時分秒 → システム日時
param_add[20] = sysDate;
// 登録オペレータアカウント → バッチ更新者ＩＤ
param_add[21] = batchUserId;
// 更新年月日時分秒 → システム日時
param_add[22] = sysDate;
// 更新オペレータアカウント → バッチ更新者ＩＤ
param_add[23] = batchUserId;
// 削除年月日時分秒 → NULL（未設定）
param_add[24] = "";
// 削除オペレータアカウント → NULL（未設定）
param_add[25] = "";
// 無効フラグ → "0"(有効)
param_add[26] = JBSbatKKConst.MK_FLG_YK;
// 登録運用年月日 → NULL（未設定）
param_add[27] = "";
// 登録処理ID → NULL（未設定）
param_add[28] = "";
// 更新運用年月日 → NULL（未設定）
param_add[29] = "";
// 更新処理ID → NULL（未設定）
param_add[30] = "";
// 削除運用年月日 → NULL（未設定）
param_add[31] = "";
// 削除処理ID → NULL（未設定）
param_add[32] = "";
// サービス契約の登録を行います。
this.executeKK_T_PRG_PKINSERT(param_add);
}
/**
* 処理結果に対応する進捗特記事項２を返却します。
*
* 処理フロー
*
* * 『"サービス開始日：" + サービス契約に設定したサービス開始年月日 + "サービス課金開始日：" + サービス契約に設定したサービス課金開始年月日』 に編集*
* *
* @param svcStaymd サービス開始年月日。 * @param svcChrgStaymd サービス課金開始年月日。 * @return String 進捗特記事項２ 表示内容 * @throws Exception 業務サービス内で発生した例外全般。 */ private String getPrgTkjk2(String svcStaymd, String svcChrgStaymd) throws Exception { StringBuffer value = new StringBuffer(); if(!"".equals(svcStaymd)) { value.append("サービス開始日："); value.append(JPCFomatString.formatDate(svcStaymd)+" "); } if(!"".equals(svcChrgStaymd)) { value.append("サービス課金開始日："); value.append(JPCFomatString.formatDate(svcChrgStaymd)); } return value.toString(); } /** * * お客様入会年月日設定を行います。 * * @param svcKeiMap サービス契約検索結果 * @param svcStaymd サービス開始年月日。 * @throws Exception メソッド内で発生した例外全般。 */ private void setCustJoinYMD(JBSbatCommonDBInterface svcKeiMap, String svcStaymd) throws Exception { // お客様の検索を行う。 String sysid = JBSbatStringUtil.Rtrim(svcKeiMap.getString(JBSbatKK_T_SVC_KEI.SYSID)); String[] param_cust = {sysid, super.opeDate}; this.executeCK_T_CUST_KK_SELECT_020(param_cust); JBSbatCommonDBInterface custMap = db_CK_T_CUST.selectNext(); if(null != custMap) { // 入会年月日が未設定の場合 String join_ymd = JBSbatStringUtil.Rtrim(custMap.getString(JBSbatCK_T_CUST.JOIN_YMD)); if("".equals(join_ymd)) { // お客様の更新処理を行います。 this.updateCust(custMap, svcStaymd); } else { super.logPrint.printDebugLog("入会年月日 設定済み[" + sysid + "]：" + join_ymd); } } else { super.logPrint.printDebugLog("お客様情報データなし。SYSID：" + sysid); } } /** * * お客様の更新を行います。 * * @param custMap お客様検索結果 * @param svcStaymd サービス開始年月日 * @throws Exception メソッド内で発生した例外全般。 */ private void updateCust(JBSbatCommonDBInterface custMap, String svcStaymd) throws Exception { // お客様の検索結果よりSYSID、GENE_ADD_DTMの取得。 String sysid = JBSbatStringUtil.Rtrim(custMap.getString(JBSbatKK_T_SVC_KEI.SYSID)); String gene_add_dtm = JBSbatStringUtil.Rtrim(custMap.getString(JBSbatKK_T_SVC_KEI.GENE_ADD_DTM)); // お客様の排他制御を行う。 JBSbatCommonDBInterface custMapForUpdate = new JBSbatCommonDBInterface(); custMapForUpdate.setValue(JBSbatCK_T_CUST.SYSID, sysid); custMapForUpdate.setValue(JBSbatCK_T_CUST.GENE_ADD_DTM, gene_add_dtm); JBSbatCommonDBInterface dbmap = db_CK_T_CUST.selectByPrimaryKeysForUpdateWait(custMapForUpdate); if(null != dbmap) { // 入会年月日をサービス開始日でお客様の更新を行う。 String[] setParam = {svcStaymd}; String[] whereParam = {sysid, gene_add_dtm}; this.executeCK_T_CUST_PKUPDATE(setParam, whereParam); } else { super.logPrint.printBusinessErrorLog("EKKB0360KE", new String[]{"お客様", sysid}); super.logPrint.printDebugLog("排他エラーが発生しました。{SYSID:" + sysid + "}"); } } }