*
* @author 富士通
*/
public class JBSbatKKInsertPrg 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";
/** SQL定義キー(KK_SELECT_002)*/
private static final String KK_T_SVC_KEI_KK_SELECT_032 = "KK_SELECT_032";
/** テーブルアクセスクラス(サービス契約)*/
private JBSbatSQLAccess db_KK_T_SVC_KEI = null;
/** テーブルアクセスクラス(進捗)*/
private JBSbatSQLAccess db_KK_T_PRG = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** テーブルアクセスクラス(共通部品)*/
private JBSbatSQLAccess stmt = null;
/**
* サービス契約番号
*/
protected String svcKeiNo = "";
/**
* 宅内調査実施年月日
*/
protected String tknChsJishiYmd = "";
/**
* 宅内調査判定コード
*/
protected String tknChsHntiCd = "";
/**
* 宅内調査承諾書受領年月日
*/
protected String tknChsSudksJruYmd = "";
/** シーケンス定義名(SEQ_PRG_NO)*/
private static final String SEQ_PRG_NO = "SEQ_PRG_NO";
/** 進捗ステータス(9540:承諾書受領)*/
private static final String PRG_STAT_SHODAKUSHO_RCP = "9540";
/** 進捗ステータス(9530:宅内調査OK)*/
private static final String PRG_STAT_TAKCHO_OK = "9530";
/** 進捗ステータス(953E:宅内調査NG)*/
private static final String PRG_STAT_TAKCHO_NG = "953E";
/** スペース（全角） */
public static final String SPACE_ZENKAKU = " ";
/** 宅内調査判定コード(OK) */
private static final String RSLT_CD_OK = "1";
/**
* 初期処理
* @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);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
// 共通部品用
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");
// 中間ファイルの読み込みを行います。
getKkifm052(inMap);
// 進捗情報の登録処理を行います。
insertPrg(inMap);
super.logPrint.printDebugLog("execute_END");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_SVC_KEI.close();
db_KK_T_PRG.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
// 共通部品用
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);
}
/**
* 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 getKkifm052(JBSbatServiceInterfaceMap inMap) throws Exception
{
svcKeiNo = inMap.getString(JBSbatKKIFM052.SVC_KEI_NO);
tknChsJishiYmd = inMap.getString(JBSbatKKIFM052.TKN_CHS_JS_YMD);
tknChsHntiCd = inMap.getString(JBSbatKKIFM052.TKN_CHS_HNT_CD);
tknChsSudksJruYmd = inMap.getString(JBSbatKKIFM052.TKN_CHS_SDS_JRY_YMD);
}
/**
*
* 進捗情報の登録を行います。
* @param inMap 中間ファイルの値。
* @throws Exception メソッド内で発生した例外全般。
*/
private void insertPrg(JBSbatServiceInterfaceMap inMap) 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 svcKeiStat = JBSbatStringUtil.Rtrim(svcKeiMap.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_STAT));
if("020".equals(svcKeiStat) || "030".equals(svcKeiStat))
{
// 宅内調査結果情報ファイル.宅内調査承諾書受領年月日!=""
// 進捗ステータス="9540:承諾書受領"の進捗作成
if(!"".equals(tknChsSudksJruYmd))
{
// 進捗登録
insertPrgData(svcKeiMap, PRG_STAT_SHODAKUSHO_RCP, inMap);
}
// 宅内調査結果情報ファイル.宅内調査判定コード="1" OK
// 進捗ステータス="9530:宅内調査OK"の進捗作成
if(RSLT_CD_OK.equals(tknChsHntiCd))
{
// 進捗登録
insertPrgData(svcKeiMap, PRG_STAT_TAKCHO_OK, inMap);
}
else
{
// 宅内調査結果情報ファイル.宅内調査判定コード="2" NG
// 進捗ステータス="953E:宅内調査NG"の進捗作成
if(!"".equals(tknChsHntiCd))
{
// 進捗登録
insertPrgData(svcKeiMap, PRG_STAT_TAKCHO_NG, inMap);
}
else
{
// 宅内調査判定コードが未設定のデータは進捗の登録は行わない。
// （宅内調査を行わないマンションデータ、ｅｏモバイル他）
}
}
}
}
}
/**
*
* 進捗情報の登録を行います。
* @param svcKeiMap サービス契約情報
* @param prgStat 進捗ステータス
* @param inMap 中間ファイルの値。
* @throws Exception メソッド内で発生した例外全般。
*/
private void insertPrgData(JBSbatCommonDBInterface svcKeiMap, String prgStat, JBSbatServiceInterfaceMap inMap) throws Exception
{
// サービス契約情報の項目を取得
// 申込明細番号
String mskmDtlNo = JBSbatStringUtil.Rtrim(svcKeiMap.getString(JBSbatKK_T_SVC_KEI.MSKM_DTL_NO));
// 異動区分
String idoDiv = JBSbatStringUtil.Rtrim(svcKeiMap.getString(JBSbatKK_T_SVC_KEI.IDO_DIV));
// 異動年月日時分秒取得
String idoDtm = JKKBatCommon.getIdoDtmMax(commonItem, svcKeiNo, idoDiv, stmt);
// 特記事項2編集処理
String tkjk2 = editPrgTkjk2(prgStat, inMap);
// システム日付を取得
String sysDate = JCCBatCommon.getSysDateTimeStamp();
// 登録する進捗のパラメータを設定します
String [] setParam = {
JBSbatStringUtil.padNumFormString(
JBSbatOracleSeqUtil.getNextSeq(commonItem.getConnection(), SEQ_PRG_NO), 12),// 進捗番号 → 自動採番
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_032.IDO_DIV
idoDtm, // 異動年月日時分秒 →進捗.異動年月日時分秒または、システム日時
prgStat, // 進捗ステータス → 9530,953E,9540
super.opeDate + sysDate.substring(8), // 進捗年月日時分秒 → バッチ運用日+実施日のhhmmssSSSを設定。
"", // 進捗メモ → NULL（未設定）
"", // 進捗特記事項１ → NULL（未設定）
tkjk2, // 進捗特記事項２ → 補足資料参照
sysDate, // 登録年月日時分秒 → システム日時
batchUserId, // 登録オペレータアカウント → バッチ更新者ＩＤ
sysDate, // 更新年月日時分秒 → システム日時
batchUserId, // 更新オペレータアカウント → バッチ更新者ＩＤ
"", // 削除年月日時分秒 → NULL（未設定）
"", // 削除オペレータアカウント → NULL（未設定）
"0", // 無効フラグ → "0"(有効)
"", // 登録運用年月日 → NULL（未設定）
"", // 登録処理ID → NULL（未設定）
"", // 更新運用年月日 → NULL（未設定）
"", // 更新処理ID → NULL（未設定）
"", // 削除運用年月日 → NULL（未設定）
""}; // 削除処理ID → NULL（未設定）
executeKK_T_PRG_PKINSERT(setParam);
}
/**
* 進捗ステータスにより特記事項2を編集します。
*
* @param prgStat 進捗ステータス * @param inMap 中間ファイルの値。 * @throws Exception */ private String editPrgTkjk2(String prgStat, JBSbatServiceInterfaceMap inMap) throws Exception { // 編集後文字列 StringBuilder sb = new StringBuilder(); sb.append("連携日："); // 連携年月日 スラッシュ編集 sb.append(JPCUtilCommon.formatDate(inMap.getString(JBSbatKKIFM052.RNK_YMD))); // 調査結果 String result = ""; // 宅内調査判定コード="1" if(RSLT_CD_OK.equals(tknChsHntiCd)) { result = "ＯＫ"; } else { result = "ＮＧ"; } sb.append(SPACE_ZENKAKU); sb.append("調査結果："); sb.append(result); sb.append(SPACE_ZENKAKU); // 進捗ステータス="9540:承諾書受領" if(PRG_STAT_SHODAKUSHO_RCP.equals(prgStat)) { sb.append("承諾書受領日："); // 宅内調査承諾書受領年月日 スラッシュ編集 sb.append(JPCUtilCommon.formatDate(tknChsSudksJruYmd)); } // 進捗ステータス="9530:宅内調査OK" または、 // 進捗ステータス="953E:宅内調査NG" else { sb.append("調査実施日："); // 宅内調査実施年月日 スラッシュ編集 sb.append(JPCUtilCommon.formatDate(tknChsJishiYmd)); } // 連携日：2012/07/21 調査結果：ＯＫ 調査実施日：2012/07/11 // 連携日：2012/07/21 調査結果：ＮＧ 調査実施日：2012/07/11 // 連携日：2012/07/21 調査結果：ＯＫ 承諾書受領日：2012/07/11 // 連携日：2012/07/21 調査結果：ＮＧ 承諾書受領日：2012/07/11 super.logPrint.printDebugLog("進捗特記事項2----->" + sb.toString()); return sb.toString(); } }