/*********************************************************************
* All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
* システム名 ：eo顧客基幹システム
* モジュール名 ：JBSbatACTwRyoChsht
* ソースファイル名 ：JBSbatACTwRyoChsht.java
* 作成者 ：富士通
* 作成日 ：2013年02月19日
*＜機能概要＞
* 通話料抽出部品です。
*＜修正履歴＞
* バージョン 修正日 修正者 修正内容
* v1.00.00 2013/02/19 富士通 新規作成
* v5.00.01 2013/04/22 富士通 【IT1-2013-0001015】CCMG向け連携ファイル出力内容不備対応
* v5.00.02 2013/09/12 FJ)早崎 【OM-2013-0001946】入力件数０件の場合でもヘッダ部・トレーラ部を出力するように修正
* v5.00.03 2013/10/21 FJ)柴田 【OM-2013-0003275】@前回連携時結果ファイルの処理結果が「0000」の場合のみ
* ファイル通番をインクリメントするように修正。
* A前回連携時結果ファイルのファイル通番が「99999」の場合は
* 「00000」にリセットするように修正。
*********************************************************************/
package eo.business.service;
import java.math.BigDecimal;
import java.util.ArrayList;
import eo.business.common.JACBatCommon;
import eo.business.common.JACbatDebugLogUtil;
import eo.business.common.JACbatRknBusinessUtil;
import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.util.file.JBSbatACIFM197;
import eo.business.util.table.JBSbatAC_T_CN050AP_TW_GK;
import eo.common.constant.JACStrConst;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatDefFileUtil;
import eo.framework.file.JBSbatOutputFileUtil;
import eo.framework.util.JBSbatAplConst;
import eo.framework.util.JBSbatBusinessFileUtil;
import eo.framework.util.JBSbatDateUtil;
import eo.framework.util.JBSbatStringUtil;
/**
* (クラスの機能概要)
*
* @author 富士通
*/
public class JBSbatACTwRyoChsht extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(コンテンツ０５０アプリ通話合計)*/
private static final String D_TBL_NAME_AC_T_CN050AP_TW_GK = "AC_T_CN050AP_TW_GK";
/** SQL定義キー(AC_SELECT_001)*/
private static final String AC_T_CN050AP_TW_GK_AC_SELECT_001 = "AC_SELECT_001";
/** テーブルアクセスクラス(コンテンツ０５０アプリ通話合計)*/
private JBSbatSQLAccess db_AC_T_CN050AP_TW_GK = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** ヘッダー部レコード区分 */
private static final String FILE_DIV_HEAD = "0";
/** データ部レコード区分 */
private static final String FILE_DIV_DATA = "1";
/** トレーラ部レコード区分 */
private static final String FILE_DIV_TRAIL = "2";
/** 課金対象年月 */
private String chrgTrgtYm = null;
/** レコード件数 */
private int recordCount = 0;
/** ファイル通番 */
private int fileTuban = 0;
/** 出力ファイル定義 */
private static final String PRM_OTD = "OTD";
/** 通話料連携ファイル */
private JBSbatBusinessFileUtil outDateFile = null;
/** 通話料連携ファイル出力有無フラグ */
private boolean outZmiFlg = false;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_AC_T_CN050AP_TW_GK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_AC_T_CN050AP_TW_GK);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
// Free項目の取得
String[] freeItem = this.freeItem.split(JACStrConst.FREE_DIV);
// 通話料連携ファイル
this.outDateFile = createFile(freeItem[1], freeItem[0]);
// 課金対象年月（バッチ運用日の前月）を取得する
this.chrgTrgtYm = JBSbatDateUtil.adjustMonth(super.opeDate, -1).substring(0, 6);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][initial]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][opeDate=" + super.opeDate + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[L][initial][freeItem=" + super.freeItem + "]");
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][initial]");
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute]");
assert inMap != null ? JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][execute][inMap = " + inMap.getMap().toString() + "]") : true;
// 通話料連携ファイル出力有無フラグ ← true
outZmiFlg = true;
// ファイル通番を取得する
int fileTuban = Integer.parseInt(inMap.getString(JBSbatACIFM197.FILE_TUBAN).replaceAll(JACStrConst.DOUBLE_QUOTE, ""));
//処理結果を取得する
String shorikekka = inMap.getString(JBSbatACIFM197.SYORI_KEKKA).replaceAll(JACStrConst.DOUBLE_QUOTE, "");
//処理結果が「0000」の場合のみファイル通番をインクリメントする。
if(shorikekka.equals("0000"))
{
// 引き継いだファイル通番が"99999"より小さい値の場合
if (fileTuban < 99999)
{
// ファイル通番＋１
this.fileTuban = fileTuban + 1;
//ファイル通番が"99999"を超えた場合はリセット
}
else if (fileTuban == 99999)
{
this.fileTuban = 0;
}
}
else
{
this.fileTuban = fileTuban;
}
// ヘッダ部情報を取得する
makeHeadRecord();
// データ部情報を取得する
makeDataRecord();
// トレーラ部情報を取得する
makeTrailRecord();
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][execute]");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][terminal]");
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_AC_T_CN050AP_TW_GK.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
// 出力が０件の場合
if(!outZmiFlg)
{
// ヘッダ部情報を取得する
makeHeadRecord();
// トレーラ部情報を取得する
makeTrailRecord();
}
// 通話料連携ファイルクローズ
JCCBatCommon.closeBusinessFileUtil(this.outDateFile);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][terminal]");
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(AC_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。
*
* 2.DBアクセスを実行します。
*
* 3.メソッドの呼び出し方です。
* 引数:
* param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
* 課金対象年月
*
*
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeAC_T_CN050AP_TW_GK_AC_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_AC_T_CN050AP_TW_GK.selectBySqlDefine(paramList, AC_T_CN050AP_TW_GK_AC_SELECT_001);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 引数で渡されたリストを引数で渡された文字で囲み、
* その結果を返却します。
*
* @param trgList 対象リスト
* @param leftMoji 左囲み文字
* @param rightMoji 右囲み文字
* @return rtnList 調整後文字列
* @throws Exception 業務サービス内で発生した例外全般。
*/
private ArrayList quoteList(ArrayList trgList, String leftMoji, String rightMoji) throws Exception
{
ArrayList rtnList = trgList;
if (!trgList.isEmpty() && !leftMoji.isEmpty() && !rightMoji.isEmpty())
{
int size = trgList.size();
StringBuffer buf = null;
for (int i = 0; size > i; i++)
{
buf = new StringBuffer();
buf.append(leftMoji);
buf.append(trgList.get(i));
buf.append(rightMoji);
rtnList.set(i, buf.toString());
}
}
return rtnList;
}
/**
* ヘッダレコード編集処理を行う。
*
* @throws Exception 業務サービス内で発生した例外全般
*/
private void makeHeadRecord() throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeHeadRecord]");
// ヘッダ部 データ リスト
ArrayList dateInfo = new ArrayList();
// ヘッダ部 レコード区分
dateInfo.add(FILE_DIV_HEAD);
// ヘッダ部 データ ファイル作成日
dateInfo.add(JBSbatDateUtil.getSystemDateTime());
// ヘッダ部 データ 対象年月
dateInfo.add(chrgTrgtYm);
// ヘッダ部 データ ファイル通番
dateInfo.add(JBSbatStringUtil.padNumFormString(Integer.toString(fileTuban), 5));
// ヘッダ部 データの要素にダブルクォーテーションを付加
dateInfo = this.quoteList(dateInfo, JACStrConst.DOUBLE_QUOTE, JACStrConst.DOUBLE_QUOTE);
// 通話料連携ファイル出力
JCCBatCommon.printBusinessFileUtil(this.outDateFile, dateInfo);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeHeadRecord]");
}
/**
* データレコード取得編集処理を行う。
*
* @throws Exception 業務サービス内で発生した例外全般
*/
private void makeDataRecord() throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeDataRecord]");
// ＤＢアクセス用のパラメータ定義
JBSbatCommonDBInterface dbList = new JBSbatCommonDBInterface();
// 対象キーの設定
dbList.setValue(this.chrgTrgtYm); // 課金対象年月
// SQL実行
executeAC_T_CN050AP_TW_GK_AC_SELECT_001(dbList.getList().toArray());
// 結果を取得
JBSbatCommonDBInterface dbMap = db_AC_T_CN050AP_TW_GK.selectNext();
// コンテンツ０５０アプリ通話合計情報を退避
while (null != dbMap)
{
// データ部 データ リスト
ArrayList dateInfo = new ArrayList();
// データ部 レコード区分
dateInfo.add(FILE_DIV_DATA);
// データ部 データ SYSID
dateInfo.add(dbMap.getString(JBSbatAC_T_CN050AP_TW_GK.SYSID));
// データ部 データ 契約番号
dateInfo.add(dbMap.getString(JBSbatAC_T_CN050AP_TW_GK.CONT_KEI_NO));
// データ部 データ 税区分
dateInfo.add(dbMap.getString(JBSbatAC_T_CN050AP_TW_GK.KAZEI_HIKAZEI_CD));
// 通話料金合計
BigDecimal pcallPrcGk = new BigDecimal(String.valueOf(dbMap.getString(JBSbatAC_T_CN050AP_TW_GK.PCALL_PRC_GK)));
pcallPrcGk = JACbatRknBusinessUtil.round("3", pcallPrcGk, 0);
// データ部 データ 通話料
dateInfo.add(pcallPrcGk.toString());
// データ部 データの要素にダブルクォーテーションを付加
dateInfo = this.quoteList(dateInfo, JACStrConst.DOUBLE_QUOTE, JACStrConst.DOUBLE_QUOTE);
// 通話料連携ファイル出力
JCCBatCommon.printBusinessFileUtil(this.outDateFile, dateInfo);
recordCount++;
dbMap = db_AC_T_CN050AP_TW_GK.selectNext();
}
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeDataRecord]");
}
/**
* トレーラーレコード取得編集処理を行う。
*
* @throws Exception 業務サービス内で発生した例外全般
*/
private void makeTrailRecord() throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][makeTrailRecord]");
// トレーラ部 データ リスト
ArrayList dateInfo = new ArrayList();
// トレーラ部 レコード区分
dateInfo.add(FILE_DIV_TRAIL);
// トレーラ部 総レコード数
dateInfo.add(JBSbatStringUtil.padNumFormString(Long.toString(recordCount), 9));
// トレーラ部 データの要素にダブルクォーテーションを付加
dateInfo = this.quoteList(dateInfo, JACStrConst.DOUBLE_QUOTE, JACStrConst.DOUBLE_QUOTE);
// 通話料連携ファイル出力
JCCBatCommon.printBusinessFileUtil(this.outDateFile, dateInfo);
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][makeTrailRecord]");
}
/**
* ファイル出力
*
* @param filePath ファイルパス
* @param fileDef ファイル定義
* @return fileUtil ファイルインスタンス
* @throws Exception 業務サービス内で発生した例外全般。
*/
private JBSbatBusinessFileUtil createFile(String filePath, String fileDef) throws Exception
{
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[S][createFile]");
JBSbatOutputFileUtil trailerFile = new JBSbatOutputFileUtil(filePath);
String tempFileDefName = JBSbatAplConst.getAplConstValue(PRM_OTD) + fileDef;
JBSbatDefFileUtil trailerFileDef = new JBSbatDefFileUtil(tempFileDefName, trailerFile);
// ファイルの生成
JBSbatBusinessFileUtil fileUtil = JCCBatCommon.createBusinessFileUtil(filePath
, JACStrConst.ENCODE_MS932
, JACBatCommon.chgKaigyo(JACStrConst.LINE_LF)
, trailerFileDef.getDelimiter());
assert JACbatDebugLogUtil.printDebugLog(super.logPrint, "[E][createFile]");
return fileUtil;
}
}