*
* @author 富士通
*/
public class JBSbatKKKjRsltFileSaksei 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";
/** SQL定義キー(KK_SELECT_001)*/
private static final String KU_T_KOJIAK_KK_SELECT_001 = "KK_SELECT_001";
/** テーブルアクセスクラス(連携ファイル制御)*/
private JBSbatSQLAccess db_KK_T_RNKI_FILE_CTRL = null;
/** テーブルアクセスクラス(工事案件)*/
private JBSbatSQLAccess db_KU_T_KOJIAK = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 物理バッチID（KKPRC01601）*/
private static final String BAT_ID = "KKPRC01601";
/** ファイルID（KKIFE044）*/
private static final String FILE_ID = "KKIFE044 ";
/** フラグファイル名 */
private String FLG_FILE_NAME = "";
/** 該当データカウント */
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);
db_KU_T_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KOJIAK);
// シェルからのFREEパラメータ取得
this.FLG_FILE_NAME = commonItem.getFreeItem();
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
// 出力共通電文を生成する。
JBSbatOutputItem outputBean = new JBSbatOutputItem();
JBSbatCommonDBInterface db_map = null;
String znkiJssiDate = "";
// 連携ファイル制御を検索します。
String[] para1 = {BAT_ID, FILE_ID};
db_map = executeKK_T_RNKI_FILE_CTRL_PKSELECT(para1);
// 前回実施日が取得できた場合
if (null != db_map)
{
String znkiJssiTimestamp = JBSbatStringUtil.Rtrim(db_map.getString(JBSbatKK_T_RNKI_FILE_CTRL.ZNKI_TRAN_RUN_DTM));
try {
// バッチ運用日と同日でない場合、先頭8桁を「前回運用日」とします。
if (!super.opeDate.equals(znkiJssiTimestamp.substring(0, 8)))
{
znkiJssiDate = znkiJssiTimestamp.substring(0, 8);
}
// バッチ運用日と同日の場合、バッチ運用日-1日を「前回運用日」とします。
else
{
znkiJssiDate = JBSbatDateUtil.adjustDate(super.opeDate, -1);
}
} catch (Exception e) {
throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0090TE, new String[] {"ZNKI_TRAN_RUN_DTM:" + znkiJssiTimestamp});
}
}
// 前回実施日が取得できなかった場合、バッチ運用日-1日を「前回運用日」とします。
else
{
znkiJssiDate = JBSbatDateUtil.adjustDate(super.opeDate, -1);
}
// 対象となるサービス契約の検索を行います。
String[] para2 = {znkiJssiDate, super.opeDate, super.opeDate};
this.executeKU_T_KOJIAK_KK_SELECT_001(para2);
JBSbatCommonDBInterface kojiakResult = db_KU_T_KOJIAK.selectNext();
if(null == kojiakResult)
{
super.logPrint.printDebugLog("工事案件実施年月日＞「" + znkiJssiDate + "」、工事案件実施年月日＜＝「" + super.opeDate + "」のTV事業者(KCN)分の工事結果情報の検索結果がありませんでした。");
}
else
{
while(null != kojiakResult)
{
// 入出力インターフェースオブジェクトを生成(工事結果送信ファイル用)
JBSbatServiceInterfaceMap outmap = new JBSbatServiceInterfaceMap();
// サービス契約番号 → サービス契約番号を設定します。
outmap.set(JBSbatKKIFE045001.SVC_KEI_NO, JBSbatStringUtil.Rtrim(kojiakResult.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO)));
// 顧客コード → KCN番号を設定します。未設定の場合は10桁の半角空白を設定する。
String kcn_no = JBSbatStringUtil.Rtrim(kojiakResult.getString(JBSbatKK_T_KCN_RNK_KEI_INF.KCN_NO));
if("".equals(kcn_no))
{
kcn_no = " ";
}
outmap.set(JBSbatKKIFE045001.CUST_CD, kcn_no);
// 工事完了日 → 工事案件実施年月日を取得
outmap.set(JBSbatKKIFE045001.KOJI_FIN_DAY, JBSbatStringUtil.Rtrim(kojiakResult.getString(JBSbatKU_T_KOJIAK.KOJIAK_JSSI_YMD)));
// ファイルに出力する
outmap.setOutFlg(true);
outputBean.addOutMapList(outmap);
// 件数をカウントアップ
count++;
kojiakResult = db_KU_T_KOJIAK.selectNext();
}
}
super.logPrint.printDebugLog("execute_END");
return outputBean;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_RNKI_FILE_CTRL.close();
db_KU_T_KOJIAK.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
// 工事結果ファイル（ｅｔｖ２）件数ファイルオブジェクト生成
JBSbatOutputFileUtil obj = super.commonItem.getOutPutFile2();
// 該当レコード件数をダブルクォーテーションで囲み設定
obj.write("\"" + count + "\"");
// 工事結果ファイル（ｅｔｖ２）フラグファイルの出力
this.createFlgFile();
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* PK(ＰＫ 検索)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で条件マップを作ります。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * BUTSURI_BAT_ID * FILE_ID *
* @param whereParam 条件項目の値。
* @return JBSbatCommonDBInterface 検索の結果。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private JBSbatCommonDBInterface executeKK_T_RNKI_FILE_CTRL_PKSELECT(Object[] whereParam) throws Exception
{
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("BUTSURI_BAT_ID", whereParam[0]);
whereMap.setValue("FILE_ID", whereParam[1]);
// DBアクセスを実行します
return db_KK_T_RNKI_FILE_CTRL.selectByPrimaryKeys(whereMap);
}
/**
* SQLKEY(KK_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * KOJIAK_FIN_DTM * KOJIAK_FIN_DTM * RSV_APLY_YMD *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKU_T_KOJIAK_KK_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
paramList.setValue(param[2].toString());
// DBアクセスを実行します
db_KU_T_KOJIAK.selectBySqlDefine(paramList, KU_T_KOJIAK_KK_SELECT_001);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 工事結果ファイル（ｅｔｖ２）フラグファイルを出力します。
*
* @param str 指定文字列 * @return ダブルクォーテーションが付加された文字列 * @throws Exception 業務サービス内で発生した例外全般。 */ private void createFlgFile() throws IOException, JBSbatBusinessException { // 一時ファイル読込み処理 BufferedWriter wr = null; try { // 工事結果ファイル（ｅｔｖ２）フラグファイルの生成(SJIS) wr = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(FLG_FILE_NAME), JKKBatConst.SJIS)); // ファイル出力 wr.flush(); } catch(IOException e) { throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0250CE, new String[]{FLG_FILE_NAME, e.getMessage()}); } finally { if (wr != null) { wr.close(); } } } }