*
* @author 富士通
*/
public class JBSbatKKMaisonOpenJokyoIfSksi extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(連携ファイル制御)*/
private static final String D_TBL_NAME_KK_T_RNKI_FILE_CTRL = "KK_T_RNKI_FILE_CTRL";
/** テーブル(工事案件)*/
private static final String D_TBL_NAME_KU_T_KOJIAK = "KU_T_KOJIAK";
/** テーブル(メゾン開通実績)*/
private static final String D_TBL_NAME_KK_T_MAISON_OPEN_JSK = "KK_T_MAISON_OPEN_JSK";
/** SQL定義キー(KK_SELECT_001)*/
private static final String KK_T_RNKI_FILE_CTRL_KK_SELECT_001 = "KK_SELECT_001";
/** SQL定義キー(KK_SELECT_047)*/
private static final String KU_T_KOJIAK_KK_SELECT_047 = "KK_SELECT_047";
/** SQL定義キー(KK_SELECT_001)*/
private static final String KK_T_MAISON_OPEN_JSK_KK_SELECT_001 = "KK_SELECT_001";
/** SQL定義キー(KK_INSETT_001)*/
private static final String KK_T_MAISON_OPEN_JSK_KK_INSERT_001 = "KK_INSERT_001";
/** SQL定義キー(CH_UPDATE_001)*/
private static final String KK_T_RNKI_FILE_CTRL_CH_UPDATE_001 = "CH_UPDATE_001";
/** テーブルアクセスクラス(連携ファイル制御)*/
private JBSbatSQLAccess db_KK_T_RNKI_FILE_CTRL = null;
/** テーブルアクセスクラス(工事案件)*/
private JBSbatSQLAccess db_KU_T_KOJIAK = null;
/** テーブルアクセスクラス(メゾン開通実績)*/
private JBSbatSQLAccess db_KK_T_MAISON_OPEN_JSK = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 物理バッチID */
private static final String BUTSURI_BAT_ID = "KKPRC62001";
/** 業務パラメータID（補正時間） */
public static final String PARAM_ID_KK_HOSEI_TIME = "KK_HOSEI_TIME";
/** 業務パラメータID（最大検索期間） */
public static final String PARAM_ID_KK_MAX_SEARCH_PRD = "KK_MAX_SEARCH_PRD";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KK_T_RNKI_FILE_CTRL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_RNKI_FILE_CTRL);
db_KU_T_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KOJIAK);
db_KK_T_MAISON_OPEN_JSK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_MAISON_OPEN_JSK);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// システム時間の取得(YYYYMMDDhhmmssSSS)
String sysdate = JCCBatCommon.getSysDateTimeStamp();
// 前回処理実行年月日時分秒を取得する
String rcvRunDtm = "";
rcvRunDtm = getRunDtm();
if (JKKCommonUtil.isNull(rcvRunDtm))
{
//前回処理実行年月日時分秒を取得できなければエラー
throw new JBSbatBusinessException("ECNB0430KE", new String[]{"前回処理実行年月日時分秒", "連携ファイル制御"});
}
// 補正時間を取得
String hoseiTime = "";
hoseiTime = JKKBatCommon.getWorkParamSetteValue(commonItem, PARAM_ID_KK_HOSEI_TIME);
if (JKKCommonUtil.isNull(hoseiTime))
{
//補正時間を取得できなければエラー
throw new JBSbatBusinessException("EKKB0740CE", new String[]{"業務パラメータ", "補正時間"});
}
// 最大検索期間を取得
String maxSearchTime = "";
maxSearchTime = JKKBatCommon.getWorkParamSetteValue(commonItem, PARAM_ID_KK_MAX_SEARCH_PRD);
if (JKKCommonUtil.isNull(maxSearchTime))
{
//最大検索期間を取得できなければエラー
throw new JBSbatBusinessException("EKKB0740CE", new String[]{"業務パラメータ", "最大検索期間"});
}
if ((!JKKCommonUtil.isNull(hoseiTime)) && (!JKKCommonUtil.isNull(maxSearchTime)))
{
// 検索開始年月日時分秒を算出する
String searchStaDtm = "";
searchStaDtm = calcSearhPrd(rcvRunDtm, Calendar.HOUR, hoseiTime);
// 検索終了年月日時分秒を算出する
String searchEndDtm = "";
searchEndDtm = calcSearhPrd(rcvRunDtm, Calendar.DATE, maxSearchTime);
// 工事完了した工事案件を取得し、メゾン開通実績に登録を行う
addKojiAk(searchStaDtm,searchEndDtm);
// システム時間と検索終了年月日時分秒の比較を行う
String zenkaiShoriDtm = "";
if (sysdate.compareTo(searchEndDtm) > 0)
{
zenkaiShoriDtm = searchEndDtm;
}
else
{
zenkaiShoriDtm = sysdate;
}
// 連携ファイル制御の前回処理時間を更新する
updateCtrlFile(zenkaiShoriDtm);
}
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_RNKI_FILE_CTRL.close();
db_KU_T_KOJIAK.close();
db_KK_T_MAISON_OPEN_JSK.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(KK_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 物理バッチID *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_RNKI_FILE_CTRL_KK_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_KK_T_RNKI_FILE_CTRL.selectBySqlDefine(paramList, KK_T_RNKI_FILE_CTRL_KK_SELECT_001);
}
/**
* SQLKEY(KK_SELECT_047)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 検索開始年月日時分秒 * 検索終了年月日時分秒 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKU_T_KOJIAK_KK_SELECT_047(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
// パラメータの設定
// 格納されているキーをセット
paramList.setValue(param[0]);
paramList.setValue(param[1]);
// DBアクセスを実行します
db_KU_T_KOJIAK.selectBySqlDefine(paramList,KU_T_KOJIAK_KK_SELECT_047);
}
/**
* SQLKEY(KK_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 検索開始年月日時分秒 * 検索終了年月日時分秒 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_MAISON_OPEN_JSK_KK_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
// パラメータの設定
// 格納されているキーをセット
paramList.setValue(param[0]);
// DBアクセスを実行します
db_KK_T_MAISON_OPEN_JSK.selectBySqlDefine(paramList,KK_T_MAISON_OPEN_JSK_KK_SELECT_001);
}
/**
* SQLKEY(KK_INSERT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 回線使用契約番号 * PON種別コード * 工事完了年月日 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_MAISON_OPEN_JSK_KK_INSERT_001(String[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0]);
paramList.setValue(param[1]);
paramList.setValue(param[2]);
// DBアクセスを実行します
db_KK_T_MAISON_OPEN_JSK.executeBySqlDefine(paramList, KK_T_MAISON_OPEN_JSK_KK_INSERT_001);
}
/**
* SQLKEY(CH_UPDATE_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 2.DBアクセスを実行します。
* 前回処理実行年月日時分秒 * 物理バッチID *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private int executeKK_T_RNKI_FILE_CTRL_CH_UPDATE_001(String[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0]); paramList.setValue(param[1]); // DBアクセスを実行します return db_KK_T_RNKI_FILE_CTRL.executeBySqlDefine(paramList, KK_T_RNKI_FILE_CTRL_CH_UPDATE_001); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ // 連携ファイル制御テーブル検索 private String getRunDtm() throws Exception { String znkiRunDtm = ""; Object[] param = { BUTSURI_BAT_ID, }; executeKK_T_RNKI_FILE_CTRL_KK_SELECT_001(param); JBSbatCommonDBInterface getZnkiRunDtm = db_KK_T_RNKI_FILE_CTRL.selectNext(); if (!JKKCommonUtil.isNull(getZnkiRunDtm)) { znkiRunDtm = getZnkiRunDtm.getString(JBSbatKK_T_RNKI_FILE_CTRL.ZNKI_TRAN_RUN_DTM); } return znkiRunDtm; } // 検索期間の算出 private String calcSearhPrd(String rcvRunDtm,int calc, String searchTime) throws Exception { Calendar staCalendar = Calendar.getInstance(); SimpleDateFormat hourCluc = new SimpleDateFormat("yyyyMMddHHmmssSSS"); staCalendar.setTime(hourCluc.parse(rcvRunDtm)); staCalendar.add(calc, Integer.parseInt(searchTime)); String calcDtm = hourCluc.format(staCalendar.getTime()); return calcDtm; } // 工事案件テーブル検索、登録 private JBSbatCommonDBInterface addKojiAk(String searchStaDtm,String searchEndDtm) throws Exception { Object[] param = new Object[2]; param[0] = searchStaDtm; param[1] = searchEndDtm; executeKU_T_KOJIAK_KK_SELECT_047(param); JBSbatCommonDBInterface map = new JBSbatCommonDBInterface(); // 抽出したレコードの件数分繰り返す for(map = db_KU_T_KOJIAK.selectNext(); null != map; map = db_KU_T_KOJIAK.selectNext()) { // 回線使用契約番号を取得する String ksnUseKeiNo =map.getString(JBSbatKU_T_KJAK_EOH_NTMANS.KAISEN_USE_KEI_NO); if (!JKKCommonUtil.isNull(ksnUseKeiNo)) { // 回線使用契約番号をキーとして検索を行う Object[] selectparam = new Object[1]; selectparam[0] = ksnUseKeiNo; // メゾン開通実績スキーマにレコードが存在するか確認 executeKK_T_MAISON_OPEN_JSK_KK_SELECT_001(selectparam); JBSbatCommonDBInterface selectChk = db_KK_T_MAISON_OPEN_JSK.selectNext(); if (JKKCommonUtil.isNull(selectChk)) { // 抽出できなければ登録を行う String[] insertParam = new String[3]; // 回線使用契約番号 insertParam[0] = map.getString(JBSbatKU_T_KJAK_EOH_NTMANS.KAISEN_USE_KEI_NO); // PON種別コード insertParam[1] = map.getString(JBSbatKU_T_KOJIAK.PON_SBT_CD); // 工事完了年月日 insertParam[2] = map.getString(JBSbatKU_T_KOJIAK.KOJIAK_JSSI_YMD); executeKK_T_MAISON_OPEN_JSK_KK_INSERT_001(insertParam); } } } return map; } // 連携ファイル制御テーブル更新 private void updateCtrlFile(String zenkaiShoriDtm) throws Exception { String[] updateparam = new String[2]; updateparam[0] = zenkaiShoriDtm; updateparam[1] = BUTSURI_BAT_ID; executeKK_T_RNKI_FILE_CTRL_CH_UPDATE_001(updateparam); } }