*
* @author 富士通
*/
public class JBSbatKKTvKsSvIdoInfoSakusei extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(連携ファイル制御)*/
private static final String D_TBL_NAME_KK_T_RNKI_FILE_CTRL = "KK_T_RNKI_FILE_CTRL";
/** テーブルアクセスクラス(連携ファイル制御)*/
private JBSbatSQLAccess db_KK_T_RNKI_FILE_CTRL = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 物理バッチID（KKPRC01701）*/
private static final String BAT_ID = "KKPRC01701";
/** ファイルID（KKIFE050）*/
private static final String FILE_ID = "KKIFE050 ";
/**
* 該当データカウント
*/
private int count = 0;
/**
* 初期処理
* @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);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
count++;
super.logPrint.printDebugLog("execute_END");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
// eo光テレビ異動情報件数ファイルオブジェクト取得
JBSbatOutputFileUtil obj = super.commonItem.getOutPutFile();
// 該当レコード件数をダブルクォーテーションで囲み設定
obj.write("\"" + count + "\"");
// ファイル連携制御更新
upDateRnkiFileCtrl();
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_RNKI_FILE_CTRL.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 処理済ファイル通番 TRAN_ZUMI_FILE_SEQ * 前回処理実行年月日時分秒 ZNKI_TRAN_RUN_DTM * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * BUTSURI_BAT_ID * FILE_ID *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_RNKI_FILE_CTRL_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("TRAN_ZUMI_FILE_SEQ", setParam[0]);
setMap.setValue("ZNKI_TRAN_RUN_DTM", setParam[1]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("BUTSURI_BAT_ID", whereParam[0]);
whereMap.setValue("FILE_ID", whereParam[1]);
// DBアクセスを実行します
db_KK_T_RNKI_FILE_CTRL.updateByPrimaryKeys(whereMap, setMap);
}
/**
* PK(全項目登録)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 物理バッチＩＤ BUTSURI_BAT_ID * ファイルＩＤ FILE_ID * 処理済ファイル通番 TRAN_ZUMI_FILE_SEQ * 前回処理実行年月日時分秒 ZNKI_TRAN_RUN_DTM * 登録年月日時分秒 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_RNKI_FILE_CTRL_PKINSERT(Object[] setParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("BUTSURI_BAT_ID", setParam[0]);
setMap.setValue("FILE_ID", setParam[1]);
setMap.setValue("TRAN_ZUMI_FILE_SEQ", setParam[2]);
setMap.setValue("ZNKI_TRAN_RUN_DTM", setParam[3]);
setMap.setValue("ADD_DTM", setParam[4]);
setMap.setValue("ADD_OPEACNT", setParam[5]);
setMap.setValue("UPD_DTM", setParam[6]);
setMap.setValue("UPD_OPEACNT", setParam[7]);
setMap.setValue("DEL_DTM", setParam[8]);
setMap.setValue("DEL_OPEACNT", setParam[9]);
setMap.setValue("MK_FLG", setParam[10]);
setMap.setValue("ADD_UNYO_YMD", setParam[11]);
setMap.setValue("ADD_TRN_ID", setParam[12]);
setMap.setValue("UPD_UNYO_YMD", setParam[13]);
setMap.setValue("UPD_TRN_ID", setParam[14]);
setMap.setValue("DEL_UNYO_YMD", setParam[15]);
setMap.setValue("DEL_TRN_ID", setParam[16]);
// DBアクセスを実行します
db_KK_T_RNKI_FILE_CTRL.insertByPrimaryKeys(setMap);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 連携ファイル制御TBL更新
*
* @throws Exception 業務サービス内で発生した例外全般。
* @throws IOException
*/
private void upDateRnkiFileCtrl() throws Exception
{
// EO20H0110J0にて設定した抽出開始タイムスタンプを取得
String searhTimeStamp = this.getSearchTimeStamp();
// 検索条件の設定
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
// 物理バッチID
whereMap.setValue(JBSbatKK_T_RNKI_FILE_CTRL.BUTSURI_BAT_ID, BAT_ID);
// ファイルID
whereMap.setValue(JBSbatKK_T_RNKI_FILE_CTRL.FILE_ID, FILE_ID);
// 連携ファイル制御排他検索を実施します。
JBSbatCommonDBInterface outDbMap = db_KK_T_RNKI_FILE_CTRL.selectByPrimaryKeysForUpdateWait(whereMap);
if (null != outDbMap)
{
// 連携ファイル制御更新処理を実施します。
String file_seq = "";
Object[] setParam = new Object[2];
if(!"".equals(JBSbatStringUtil.Rtrim(outDbMap.getString(JBSbatKK_T_RNKI_FILE_CTRL.TRAN_ZUMI_FILE_SEQ))))
{
int db_value = Integer.parseInt(JBSbatStringUtil.Rtrim(outDbMap.getString(JBSbatKK_T_RNKI_FILE_CTRL.TRAN_ZUMI_FILE_SEQ)));
if(String.valueOf(db_value + 1).length() < 6)
{
file_seq = JBSbatStringUtil.padNumFormString(String.valueOf(db_value + 1), 5);
}
else
{
file_seq = JBSbatStringUtil.padNumFormString(String.valueOf(0), 5);
}
}
else
{
file_seq = JBSbatStringUtil.padNumFormString(String.valueOf(0), 5);
}
// 処理済ファイル通番
setParam[0] = file_seq;
// 前回処理年月日時分秒 → EO20H0110J0にて設定した抽出開始タイムスタンプで更新する。
setParam[1] = searhTimeStamp;
Object[] whereParam = new Object[2];
whereParam[0] = BAT_ID;
whereParam[1] = FILE_ID;
// 更新処理の実行
executeKK_T_RNKI_FILE_CTRL_PKUPDATE(setParam, whereParam);
}
// 検索結果が存在しない場合(登録処理の実施)。
else
{
// 連携ファイル制御登録処理を実施します。
Object[] setParam = new Object[17];
// 物理バッチID
setParam[0] = BAT_ID;
// ファイルID
setParam[1] = FILE_ID;
// 処理済ファイル通番
setParam[2] = "00000";
// 前回処理実行年月日時分秒
setParam[3] = searhTimeStamp;
setParam[4] = "";
setParam[5] = "";
setParam[6] = "";
setParam[7] = "";
setParam[8] = "";
setParam[9] = "";
setParam[10] = "0";
setParam[11] = "";
setParam[12] = "";
setParam[13] = "";
setParam[14] = "";
setParam[15] = "";
setParam[16] = "";
// 登録処理の実行
executeKK_T_RNKI_FILE_CTRL_PKINSERT(setParam);
}
}
/**
* EO20H0110J0にて出力された抽出開始タイムスタンプを取得します。
*
* @return 抽出開始時分秒 * @throws JBSbatBusinessException * @throws IOException 業務サービス内で発生した例外全般。 */ private String getSearchTimeStamp() throws JBSbatBusinessException, IOException { String searhTimeStamp = ""; // 読み込みファイル名取得 String file_name = commonItem.getFreeItem(); BufferedReader br = null; // 前回処理実行年月日時分秒保持ファイルを読み込みます。 try { InputStreamReader is = new InputStreamReader(new FileInputStream(file_name), "Shift-JIS"); br = new BufferedReader(is); if (br.ready()) { // １行読込み searhTimeStamp = br.readLine(); } } catch (IOException e) { // 前回処理実行年月日時分秒保持ファイルがない場合はエラー。 throw new JBSbatBusinessException("EKKB0020CE", new String[]{file_name}); } finally { if (null != br) { br.close(); } } return searhTimeStamp; } }