*
* @author 富士通
*/
public class JBSbatCKHuryoCustChkRsltUpd 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_JUDGE = "KK_T_JUDGE";
/** テーブル(審査詳細)*/
private static final String D_TBL_NAME_KK_T_JUDGE_DTL = "KK_T_JUDGE_DTL";
/** テーブル(進捗)*/
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";
/** SQL定義キー(CK_SELECT_003)*/
private static final String KK_T_SVC_KEI_CK_SELECT_003 = "CK_SELECT_003";
/** SQL定義キー(CK_SELECT_003)*/
private static final String KK_T_JUDGE_CK_SELECT_003 = "CK_SELECT_003";
/** テーブルアクセスクラス(サービス契約)*/
private JBSbatSQLAccess db_KK_T_SVC_KEI = null;
/** テーブルアクセスクラス(審査)*/
private JBSbatSQLAccess db_KK_T_JUDGE = null;
/** テーブルアクセスクラス(審査詳細)*/
private JBSbatSQLAccess db_KK_T_JUDGE_DTL = null;
/** テーブルアクセスクラス(進捗)*/
private JBSbatSQLAccess db_KK_T_PRG = null;
/** テーブルアクセスクラス(サービス契約排他制御)*/
private JBSbatSQLAccess db_KK_T_SVKEI_EXC_CTRL = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** テーブルアクセスクラス(共通部品)*/
private JBSbatSQLAccess stmt = null;
/** シーケンス定義名(SEQ_PRG_NO)*/
private static final String SEQ_PRG_NO = "SEQ_PRG_NO";
/** テーブル名(サービス契約)*/
private static final String TABLE_NAME_SVC_KEI = "サービス契約";
/** 接頭語(チェック日：)*/
private static final String PREFIX = "チェック日：";
/**
* 申込番号
*/
protected String mskmNo = "";
/**
* ＳＹＳＩＤ
*/
protected String sysid = "";
/**
* 申込種別コード
*/
protected String mskmSbtCd = "";
/**
* 申込明細番号
*/
protected String mskmDtlNo = "";
/**
* お客様名
*/
protected String custNm = "";
/**
* お客様カナ名
*/
protected String custKana = "";
/**
* お客様生年月日
*/
protected String custBirthd = "";
/**
* 契約者タイプコード
*/
protected String keishaTypeCd = "";
/**
* サービス契約番号
*/
protected String svcKeiNo = "";
/**
* 異動区分
*/
protected String idoDiv = "";
/**
* 審査番号
*/
protected String judgeNo = "";
/**
* 電話番号
*/
protected String telno = "";
/**
* 親権者名
*/
protected String skshaNm = "";
/**
* 親権者名カナ
*/
protected String skshaKana = "";
/**
* 親権者生年月日
*/
protected String skshaBirthd = "";
/**
* 親権者電話番号
*/
protected String skshaTelno = "";
/**
* 請求契約番号
*/
protected String seikyKeiNo = "";
/**
* 送付先カナ名
*/
protected String shsKana = "";
/**
* 不良顧客チェック結果
*/
protected String huryocustChkRslt = "";
/**
* サービス契約番号（サービス契約）
*/
protected String svcKeiNo_svcKei = "";
/**
* 世代登録年月日時分秒（サービス契約）
*/
protected String geneAddDtm_svcKei = "";
/**
* 料金グループコード（サービス契約）
*/
protected String prcGrpCd_svcKei = "";
/**
* 異動区分（サービス契約）
*/
protected String idoDiv_svcKei = "";
/**
* 異動ＮＧ状態コード（サービス契約）
*/
protected String idoNgStatCd_svcKei = "";
/**
* 更新年月日時分秒(初期検索)
*/
protected String lastUpdDtmBf = "";
/**
* お客様審査判定結果コード
*/
protected String custJudgeRsltCd = "";
/**
* 親権者審査判定結果コード
*/
protected String skshaJudgeRsltCd = "";
/**
* 請求先審査判定結果コード
*/
protected String seikyJudgeRsltCd = "";
/**
* 初期処理
* @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_JUDGE = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_JUDGE);
db_KK_T_JUDGE_DTL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_JUDGE_DTL);
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");
// 中間ファイルの読み込みを行います。
getCkifm001(inMap);
// サービス契約排他制御より最終更新日時を取得し同じ場合排他をかけます。
String lastUpdDtmAf = searchSvkeiExcCtrl(svcKeiNo);
if(null == timeStampCheck(svcKeiNo, lastUpdDtmBf, lastUpdDtmAf))
{
// OM-2015-0000527 MOD START
// super.logPrint.printBusinessErrorLog("EKKB0360KE", new String[]{"サービス契約排他制御TBL", svcKeiNo});
// throw new JBSbatBusinessError("排他エラーが発生しました。{SVC_KEI_NO:" + svcKeiNo + "}");
super.logPrint.printBusinessErrorLog("EZMB0190KW", new String[]{"サービス契約排他制御TBL", svcKeiNo});
throw new JBSbatBusinessError(JBSbatBusinessBase.DEAD_LOCK_ERROR);
// OM-2015-0000527 MOD END
}
// サービス契約情報の取得を行います。
getSvcKeiInfo();
// 審査テーブルの更新を行います。
updateJudge();
// 審査詳細テーブルの登録（契約者不良顧客チェックデータ）
insertJudgeDtl("039", custJudgeRsltCd);
// 審査詳細テーブルの登録（親権者不良顧客チェックデータ）
insertJudgeDtl("040", skshaJudgeRsltCd);
// 審査詳細テーブルの登録（請求先不良顧客チェックデータ）
insertJudgeDtl("041", seikyJudgeRsltCd);
// バイント変数のリストを生成します
JBSbatCommonDBInterface judgeList = new JBSbatCommonDBInterface();
judgeList.setValue(sysid); // SYSID
judgeList.setValue(mskmDtlNo); // 申込明細番号
judgeList.setValue(svcKeiNo); // サービス契約番号
// 審査情報件数を取得
int getJudgeCount = db_KK_T_JUDGE.executeBySqlDefine(judgeList, KK_T_JUDGE_CK_SELECT_003);
// 審査情報件数が0件の場合
if(0 == getJudgeCount)
{
// サービス契約の更新を行います。
updateSVcKei();
}
// 審査件数が0件以外の場合、かつ異動NG状態コードが【空白】または【支払方法NG】または【番ポエリアチェックNG】の場合。
else if(0 != getJudgeCount
&& ("".equals(idoNgStatCd_svcKei) || "080E".equals(idoNgStatCd_svcKei)
|| "B50E".equals(idoNgStatCd_svcKei)))
{
// サービス契約の更新を行います。
updateSVcKei();
}
else
{
// サービス契約の更新を行わない。
}
// 進捗登録を行います。
insertPrg();
super.logPrint.printDebugLog("execute_END");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_SVC_KEI.close();
db_KK_T_JUDGE.close();
db_KK_T_JUDGE_DTL.close();
db_KK_T_PRG.close();
db_KK_T_SVKEI_EXC_CTRL.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
// 共通部品用
stmt.close();
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(CK_SELECT_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約．サービス契約番号 * サービス契約．予約適用年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVC_KEI_CK_SELECT_003(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_CK_SELECT_003);
}
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 審査年月日 JUDGE_YMD * 結果コード JUDGE_JUDGE_RSLT_CD * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * JUDGE_NO *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_JUDGE_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("JUDGE_YMD", setParam[0]);
setMap.setValue("JUDGE_JUDGE_RSLT_CD", setParam[1]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("JUDGE_NO", whereParam[0]);
// DBアクセスを実行します
db_KK_T_JUDGE.updateByPrimaryKeys(whereMap, setMap);
}
/**
* PK(全項目登録)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 審査番号 JUDGE_NO * 審査詳細種別コード JDG_DTL_SBT_CD * 審査対象画面タブコード JUDGE_TG_SCREEN_TAB_CD * 審査対象画面項目コード JUDGE_TG_SCREEN_KMK_CD * 審査年月日 JUDGE_YMD * 審査判定結果コード JUDGE_JUDGE_RSLT_CD * 審査詳細メッセージＩＤ JDG_DTL_MSG_ID * メッセージ埋込み文字 MSG_UMKM_MOJI * 登録年月日時分秒 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_JUDGE_DTL_PKINSERT(Object[] setParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("JUDGE_NO", setParam[0]);
setMap.setValue("JDG_DTL_SBT_CD", setParam[1]);
setMap.setValue("JUDGE_TG_SCREEN_TAB_CD", setParam[2]);
setMap.setValue("JUDGE_TG_SCREEN_KMK_CD", setParam[3]);
setMap.setValue("JUDGE_YMD", setParam[4]);
setMap.setValue("JUDGE_JUDGE_RSLT_CD", setParam[5]);
setMap.setValue("JDG_DTL_MSG_ID", setParam[6]);
setMap.setValue("MSG_UMKM_MOJI", setParam[7]);
setMap.setValue("ADD_DTM", setParam[8]);
setMap.setValue("ADD_OPEACNT", setParam[9]);
setMap.setValue("UPD_DTM", setParam[10]);
setMap.setValue("UPD_OPEACNT", setParam[11]);
setMap.setValue("DEL_DTM", setParam[12]);
setMap.setValue("DEL_OPEACNT", setParam[13]);
setMap.setValue("MK_FLG", setParam[14]);
setMap.setValue("ADD_UNYO_YMD", setParam[15]);
setMap.setValue("ADD_TRN_ID", setParam[16]);
setMap.setValue("UPD_UNYO_YMD", setParam[17]);
setMap.setValue("UPD_TRN_ID", setParam[18]);
setMap.setValue("DEL_UNYO_YMD", setParam[19]);
setMap.setValue("DEL_TRN_ID", setParam[20]);
// DBアクセスを実行します
db_KK_T_JUDGE_DTL.insertByPrimaryKeys(setMap);
}
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 異動NG状態コード IDO_NG_STAT_CD * 審査結果コード SKEKKA_CD * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * SVC_KEI_NO * GENE_ADD_DTM *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVC_KEI_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("IDO_NG_STAT_CD", setParam[0]);
setMap.setValue("SKEKKA_CD", setParam[1]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("SVC_KEI_NO", whereParam[0]);
whereMap.setValue("GENE_ADD_DTM", whereParam[1]);
// DBアクセスを実行します
db_KK_T_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);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
*
* 中間ファイルの読み込みを行います。
*
* @param inMap 中間ファイルの値。
* @throws Exception メソッド内で発生した例外全般。
*/
private void getCkifm001(JBSbatServiceInterfaceMap inMap) throws Exception
{
mskmNo = inMap.getString(JBSbatCKIFM001.MSKM_NO); // 申込番号
sysid = inMap.getString(JBSbatCKIFM001.SYSID); // ＳＹＳＩＤ
mskmSbtCd = inMap.getString(JBSbatCKIFM001.MSKM_SBT_CD); // 申込種別コード
mskmDtlNo = inMap.getString(JBSbatCKIFM001.MSKM_DTL_NO); // 申込明細番号
custNm = inMap.getString(JBSbatCKIFM001.CUST_NM); // お客様名
custKana = inMap.getString(JBSbatCKIFM001.CUST_KANA); // お客様カナ名
custBirthd = inMap.getString(JBSbatCKIFM001.CUST_BIRTHD); // お客様生年月日
keishaTypeCd = inMap.getString(JBSbatCKIFM001.KEISHA_TYPE_CD); // 契約者タイプコード
svcKeiNo = inMap.getString(JBSbatCKIFM001.SVC_KEI_NO); // サービス契約番号
idoDiv = inMap.getString(JBSbatCKIFM001.IDO_DIV); // 異動区分
judgeNo = inMap.getString(JBSbatCKIFM001.JUDGE_NO); // 審査番号
telno = inMap.getString(JBSbatCKIFM001.TELNO); // 電話番号
skshaNm = inMap.getString(JBSbatCKIFM001.SKSHA_NM); // 親権者名
skshaKana = inMap.getString(JBSbatCKIFM001.SKSHA_KANA); // 親権者名カナ
skshaBirthd = inMap.getString(JBSbatCKIFM001.SKSHA_BIRTHD); // 親権者生年月日
skshaTelno = inMap.getString(JBSbatCKIFM001.SKSHA_TELNO); // 親権者電話番号
seikyKeiNo = inMap.getString(JBSbatCKIFM001.SEIKY_KEI_NO); // 請求契約番号
shsKana = inMap.getString(JBSbatCKIFM001.SHS_KANA); // 送付先カナ名
huryocustChkRslt = inMap.getString(JBSbatCKIFM001.HURYOCUST_CHK_RSLT); // 不良顧客チェック結果
lastUpdDtmBf = inMap.getString(JBSbatCKIFM001.UPD_DTM_BF); // 更新年月日時分秒
custJudgeRsltCd = inMap.getString(JBSbatCKIFM001.CUST_JUDGE_JUDGE_RSLT_CD); // お客様審査判定結果コード
skshaJudgeRsltCd = inMap.getString(JBSbatCKIFM001.SKSHA_JUDGE_JUDGE_RSLT_CD); // 親権者審査判定結果コード
seikyJudgeRsltCd = inMap.getString(JBSbatCKIFM001.SEIKY_JUDGE_JUDGE_RSLT_CD); // 請求先審査判定結果コード
}
/**
*
* サービス契約情報の取得を行います。
* @return
*
* @throws Exception メソッド内で発生した例外全般。
*/
private void getSvcKeiInfo() throws Exception
{
// 検索条件としてサービス契約番号、バッチ運用日を設定。
// SQL定義キー(CK_SELECT_003)を実行する
String [] selectParam01 = {svcKeiNo, commonItem.getOpeDate()};
super.logPrint.printDebugLog("selectParam(サービス契約番号)：" + selectParam01[0]);
super.logPrint.printDebugLog("selectParam(予約適用年月日)：：" + selectParam01[1]);
// サービス契約検索処理(CK_SELECT_003)の実行。
executeKK_T_SVC_KEI_CK_SELECT_003(selectParam01);
JBSbatCommonDBInterface svcKeiMap = db_KK_T_SVC_KEI.selectNext();
if(null == svcKeiMap)
{
throw new JBSbatBusinessException("EKKB0150JE", new String[]{TABLE_NAME_SVC_KEI});
}
// フィールド変数の初期化
svcKeiNo_svcKei = "";
geneAddDtm_svcKei = "";
prcGrpCd_svcKei = "";
idoDiv_svcKei = "";
idoNgStatCd_svcKei = "";
// 検索結果のサービス契約情報をフィールド変数に設定する。
svcKeiNo_svcKei = JBSbatStringUtil.Rtrim(svcKeiMap.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO));
geneAddDtm_svcKei = JBSbatStringUtil.Rtrim(svcKeiMap.getString(JBSbatKK_T_SVC_KEI.GENE_ADD_DTM));
prcGrpCd_svcKei = JBSbatStringUtil.Rtrim(svcKeiMap.getString(JBSbatKK_T_SVC_KEI.PRC_GRP_CD));
idoDiv_svcKei = JBSbatStringUtil.Rtrim(svcKeiMap.getString(JBSbatKK_T_SVC_KEI.IDO_DIV));
idoNgStatCd_svcKei = JBSbatStringUtil.Rtrim(svcKeiMap.getString(JBSbatKK_T_SVC_KEI.IDO_NG_STAT_CD));
}
/**
*
* 審査テーブルの更新処理を行います。
*
* @throws Exception メソッド内で発生した例外全般。
*/
private void updateJudge() throws Exception
{
// SQL実行結果取得用mapを生成（審査）
JBSbatCommonDBInterface judgeMap = new JBSbatCommonDBInterface();
// 審査テーブルに排他制御処理を実行する
judgeMap.setValue("JUDGE_NO", judgeNo);
db_KK_T_JUDGE.selectByPrimaryKeysForUpdateWait(judgeMap);
// 設定項目を設定します
String [] setParam01 = {commonItem.getOpeDate(), huryocustChkRslt};
super.logPrint.printDebugLog("setParam(審査年月日)：" + setParam01[0]);
super.logPrint.printDebugLog("setParam(結果コード)：" + setParam01[1]);
// 条件項目を設定します
String [] whereParam01 = {judgeNo};
super.logPrint.printDebugLog("whereParam(JUDGE_NO)：：：" + whereParam01[0]);
// 審査テーブルのPK更新を実行する
executeKK_T_JUDGE_PKUPDATE(setParam01, whereParam01);
}
/**
*
* 審査詳細情報の登録処理を行います。
*
* @param jdgDtlSbtCd 審査詳細種別コード
* @param jdgRsltCd 審査判定結果コード
* @throws Exception メソッド内で発生した例外全般。
*/
private void insertJudgeDtl(String jdgDtlSbtCd, String jdgRsltCd) throws Exception
{
// システム日付を取得
String sysDate = JCCBatCommon.getSysDateTimeStamp();
// 登録する審査詳細のパラメータを設定します
String [] setParam = {
judgeNo, // 審査番号 → 不良顧客チェックファイル.審査番号
jdgDtlSbtCd, // 審査詳細種別コード → パラメータ.審査詳細種別コード
"", // 審査対象画面タブコード → NULL（未設定）
"", // 審査対象画面項目コード → NULL（未設定）
this.opeDate, // 審査年月日 → 運用日付
jdgRsltCd, // 審査判定結果コード → パラメータ.審査判定結果コード
"", // 審査詳細メッセージID → NULL（未設定）
"", // メッセージ埋込み文字 → NULL（未設定）
sysDate, // 登録年月日時分秒 → システム日時
batchUserId, // 登録オペレータアカウント → バッチ更新者ＩＤ
sysDate, // 更新年月日時分秒 → システム日時
batchUserId, // 更新オペレータアカウント → バッチ更新者ＩＤ
"", // 削除年月日時分秒 → NULL（未設定）
"", // 削除オペレータアカウント → NULL（未設定）
"0", // 無効フラグ → "0"(有効)
"", // 登録運用年月日 → NULL（未設定）
"", // 登録処理ID → NULL（未設定）
"", // 更新運用年月日 → NULL（未設定）
"", // 更新処理ID → NULL（未設定）
"", // 削除運用年月日 → NULL（未設定）
""}; // 削除処理ID → NULL（未設定）
executeKK_T_JUDGE_DTL_PKINSERT(setParam);
}
/**
*
* サービス契約情報の更新処理を行います。
*
* @throws Exception メソッド内で発生した例外全般。
*/
private void updateSVcKei() throws Exception
{
// SQL実行結果取得用mapを生成（サービス契約）
JBSbatCommonDBInterface updSvcKeiMap = new JBSbatCommonDBInterface();
// サービス契約テーブルに排他制御処理を実行する
updSvcKeiMap.setValue("SVC_KEI_NO", svcKeiNo_svcKei);
updSvcKeiMap.setValue("GENE_ADD_DTM", geneAddDtm_svcKei);
db_KK_T_SVC_KEI.selectByPrimaryKeysForUpdateWait(updSvcKeiMap);
// 異動NG状態コード
String idoNgStatCd = "";
// 審査結果コード
String judgeResultCd = "";
// 不良顧客チェック結果が「0」の場合
if("00".equals(huryocustChkRslt))
{
idoNgStatCd = "";
judgeResultCd = "71";
}
// 不良顧客チェック結果が「01」の場合
else
{
idoNgStatCd = "070E";
if("02".equals(prcGrpCd_svcKei) || "03".equals(prcGrpCd_svcKei))
{
judgeResultCd = "33";
}
else if("11".equals(prcGrpCd_svcKei) || "12".equals(prcGrpCd_svcKei) || "13".equals(prcGrpCd_svcKei))
{
judgeResultCd = "93";
}
}
// 設定項目を設定します
String [] setParam02 = {idoNgStatCd, judgeResultCd};
super.logPrint.printDebugLog("setParam02(異動NG状態コード)：" + setParam02[0]);
super.logPrint.printDebugLog("setParam02(審査結果コード)：：" + setParam02[1]);
// 条件項目を設定します
String [] whereParam02 = {svcKeiNo_svcKei, geneAddDtm_svcKei};
super.logPrint.printDebugLog("whereParam02(SVC_KEI_NO)：：：" + whereParam02[0]);
super.logPrint.printDebugLog("whereParam02(GENE_ADD_DTM)：：" + whereParam02[1]);
// サービス契約テーブルのPK更新を実行する
executeKK_T_SVC_KEI_PKUPDATE(setParam02, whereParam02);
// サービス契約排他制御への更新処理を実行する
upDateSvkeiExcCtrl(svcKeiNo_svcKei);
}
/**
*
* 進捗情報の登録処理を行います。
*
* @throws Exception メソッド内で発生した例外全般。
*/
private void insertPrg() throws Exception
{
// 進捗ステータス
String prgStat = "";
// 不良顧客チェック結果が「0」の場合
if("00".equals(huryocustChkRslt))
{
prgStat = "0700";
}
// 不良顧客チェック結果が「1」の場合
else
{
prgStat = "070E";
}
// システム日付を取得
String sysDate = JCCBatCommon.getSysDateTimeStamp();
//共通部品（進捗.異動年月日取得部品）より異動年月日時分秒（またはシステム日付）を取得
String idoDtm = JKKBatCommon. getIdoDtmMax(commonItem, svcKeiNo, idoDiv_svcKei, stmt);
// 進捗特記事項を取得
String prgTokki = editDate(JCCBatCommon.getSysDate());
// 登録する進捗のパラメータを設定します
String [] setParam = {
JBSbatStringUtil.padNumFormString(
JBSbatOracleSeqUtil.getNextSeq(commonItem.getConnection(), SEQ_PRG_NO), 12), // 進捗番号 → 自動採番
mskmDtlNo, // 申込明細番号 → 不良顧客チェックファイル.申込明細番号
"", // 請求契約番号 → NULL（未設定）
"", // 請求方法番号（口座） → NULL（未設定）
"", // 請求方法番号（クレジットカード） → NULL（未設定）
svcKeiNo, // サービス契約番号 → 不良顧客チェックファイル.サービス契約番号
"", // サービス契約内訳番号 → NULL（未設定）
"", // サービス契約回線内訳番号 → NULL（未設定）
"", // 機器提供サービス契約番号 → NULL（未設定）
"", // オプションサービス契約番号 → NULL（未設定）
"", // 請求オプションサービス契約番号 → NULL（未設定）
"", // サブオプションサービス契約番号 → NULL（未設定）
"", // 割引サービス契約番号 → NULL（未設定）
idoDiv_svcKei, // 異動区分 → KK_T_SVC_KEI.CK_SELECT_003.IDO_DIV
idoDtm, // 異動年月日時分秒 → KK_T_IDO_RSN.CK_SELECT_001.IDO_DTM
prgStat, // 進捗ステータス → "0700"or"070E"
super.opeDate + sysDate.substring(8), // 進捗年月日時分秒 → バッチ運用日+実施日のhhmmssSSSを設定。
"", // 進捗メモ → NULL（未設定）
"", // 進捗特記事項１ → NULL（未設定）
prgTokki, // 進捗特記事項２ → 『チェック日：YYYY/MM/DD※１』を設定する。※１：システム日付
sysDate, // 登録年月日時分秒 → システム日時
batchUserId, // 登録オペレータアカウント → バッチ更新者ＩＤ
sysDate, // 更新年月日時分秒 → システム日時
batchUserId, // 更新オペレータアカウント → バッチ更新者ＩＤ
"", // 削除年月日時分秒 → NULL（未設定）
"", // 削除オペレータアカウント → NULL（未設定）
"0", // 無効フラグ → "0"(有効)
"", // 登録運用年月日 → NULL（未設定）
"", // 登録処理ID → NULL（未設定）
"", // 更新運用年月日 → NULL（未設定）
"", // 更新処理ID → NULL（未設定）
"", // 削除運用年月日 → NULL（未設定）
""}; // 削除処理ID → NULL（未設定）
executeKK_T_PRG_PKINSERT(setParam);
}
/**
* サービス契約排他制御テーブルの検索を行います。
*
* @param svc_kei_no サービス契約番号
* @return 最終更新年月日時分秒
* @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(null == outMap)
{
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 var1 サービス契約番号。
* @param lastUpdDtmStrBf 最終更新年月日時分秒。
* @param lastUpdDtmStrAf 最終更新年月日時分秒。
* @return サービス契約排他制御情報
* @throws Exception
*/
private JBSbatCommonDBInterface timeStampCheck(String var1, 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, var1);
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 var1 サービス契約番号。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void upDateSvkeiExcCtrl(String var1) throws Exception
{
// サービス契約排他制御の最終更新年月日時分秒の更新を行う。
JBSbatCommonDBInterface paramMap = new JBSbatCommonDBInterface();
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
// サービス契約番号を設定
whereMap.setValue(JBSbatKK_T_SVKEI_EXC_CTRL.SVC_KEI_NO, var1);
// 最終更新年月日時分秒を更新。
paramMap.setValue(JBSbatKK_T_SVKEI_EXC_CTRL.LAST_UPD_DTM, JBSbatDateUtil.getSystemDateTimeStamp());
db_KK_T_SVKEI_EXC_CTRL.updateByPrimaryKeys(whereMap, paramMap);
}
/**
* 年月日（YYYYMMDD）を"YYYY/MM/DD"形式に編集し先頭に「チェック日：」を付与します。
*
* 処理フロー
*
* 1.年月日を"チェック日：YYYY/MM/DD"形式にします。*
* *
* @param data 編集する年月日。 * @return String 編集後年月日。 * @throws Exception 業務サービス内で発生した例外全般。 */ private String editDate(String data) throws Exception { StringBuffer value = new StringBuffer(); if (null == data || 8 < data.length()) { return ""; } value.append(PREFIX); value.append(data.subSequence(0, 4)); value.append("/"); value.append(data.subSequence(4, 6)); value.append("/"); value.append(data.subSequence(6, 8)); return value.toString(); } }