*
* @author 富士通
*/
public class JBSbatCNIspSikyChsht extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(処理日付情報)*/
private static final String D_TBL_NAME_CN_T_TRAN_YMD_INFO = "CN_T_TRAN_YMD_INFO";
/** テーブル(コンテンツISP課金)*/
private static final String D_TBL_NAME_CN_T_CONT_ISP_CHRG = "CN_T_CONT_ISP_CHRG";
/** テーブル(コード名称管理)*/
private static final String D_TBL_NAME_ZM_M_CD_NM_KANRI = "ZM_M_CD_NM_KANRI";
/** SQL定義キー(CN_SELECT_002)*/
private static final String CN_T_TRAN_YMD_INFO_CN_SELECT_002 = "CN_SELECT_002";
/** SQL定義キー(CN_SELECT_004)*/
private static final String CN_T_CONT_ISP_CHRG_CN_SELECT_004 = "CN_SELECT_004";
/** SQL定義キー(CN_SELECT_002)*/
private static final String ZM_M_CD_NM_KANRI_CN_SELECT_002 = "CN_SELECT_002";
/** テーブルアクセスクラス(処理日付情報)*/
private JBSbatSQLAccess db_CN_T_TRAN_YMD_INFO = null;
/** テーブルアクセスクラス(コンテンツISP課金)*/
private JBSbatSQLAccess db_CN_T_CONT_ISP_CHRG = null;
/** テーブルアクセスクラス(コード名称管理)*/
private JBSbatSQLAccess db_ZM_M_CD_NM_KANRI = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** メッセージキー(ECNB0090AI)*/
private static final String ECNB0090AI = "ECNB0090AI";
/** メッセージキー(ECNB0080KE)*/
private static final String ECNB0080KE = "ECNB0080KE";
/** ファイル名(クレカ請求集計ファイル)*/
private static final String S_CNIFM001001_NM = "ISP請求集計ファイル";
/** 処理名称(ISP請求集計データ抽出)*/
private static final String S_CN_T_ISP_DATA_CHSHT = "ISP請求集計データ抽出";
/** 翌月取得時に連結する日付(DD)*/
private static final String S_FIRST_DD = "01";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_CN_T_TRAN_YMD_INFO = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CN_T_TRAN_YMD_INFO);
db_CN_T_CONT_ISP_CHRG = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CN_T_CONT_ISP_CHRG);
db_ZM_M_CD_NM_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_CD_NM_KANRI);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// 運用日付取得
String strOpeDate = commonItem.getOpeDate();
// 料金項目コード格納変数
String str_Prc_Kmk_Cd = "";
// 課金額格納変数
long l_Chrg_Amnt = 0;
String strChrgAmnt = "";
// 売上減額格納変数
long l_Sales_Gen_Amnt = 0;
String strGenAmnt = "";
// 補償費格納変数
long l_Conpensation = 0;
String strConAmnt = "";
// 料金コースコード、料金サービスコード、料金項目コード空白設定変数
//-- 20120804 内部IF料金コース、料金サービス削除対応
// String str_Pcrs_Cd = JCNBatCommon.adjustCharSize("", 3, JCNStrConst.SJIS);
// String str_Prc_Svc_Cd = JCNBatCommon.adjustCharSize("", 12, JCNStrConst.SJIS);
String str_Prc_Kmk_Cd_space = JCNBatCommon.adjustCharSize("", 11, JCNStrConst.SJIS);
// コンテンツサービスマスタに存在するコンテンツサービスコード格納変数
String str_Cont_Svc_Cd_Mst = "";
// eonetIDコンテンツ利用料料金項目コード格納変数
String str_Eonet_ID_Prc_Kmk_Cd = "";
// 出力共通電文を生成する。
JBSbatOutputItem outputBean = new JBSbatOutputItem();
// 処理日付情報を取得
JBSbatCommonDBInterface dbList1 = new JBSbatCommonDBInterface();
dbList1. setValue(JCNStrConst.S_BAT_TRAN_CD_ISP);
executeCN_T_TRAN_YMD_INFO_CN_SELECT_002(dbList1.getList().toArray());
// SQL実行結果取得用mapを生成
JBSbatCommonDBInterface map = new JBSbatCommonDBInterface();
String strSiky_Ym = "";
String strSiky_Next_Ymd = "";
for(map = db_CN_T_TRAN_YMD_INFO.selectNext(); null != map; map = db_CN_T_TRAN_YMD_INFO.selectNext())
{
strSiky_Ym = map.getString("SIKY_YM");
// ANK-3420-00-00 MOD START
//strSiky_Next_Ymd = map.getString("TRAN_TG_YMD_NEXTM") + S_FIRST_DD;
strSiky_Next_Ymd = map.getString("TRAN_TG_YMD_NEXTM");
// ANK-3420-00-00 MOD END
}
// 処理日付情報が取得できなかった場合は異常終了する。
if("".equals(strSiky_Ym))
{
super.logPrint.printBusinessErrorLog(ECNB0080KE, new String[]
{S_CN_T_ISP_DATA_CHSHT, D_TBL_NAME_CN_T_TRAN_YMD_INFO, "BAT_TRAN_CD=" + JCNStrConst.S_BAT_TRAN_CD_ISP});
throw new JBSbatBusinessException(ECNB0080KE, new String[]
{S_CN_T_ISP_DATA_CHSHT, D_TBL_NAME_CN_T_TRAN_YMD_INFO, "BAT_TRAN_CD=" + JCNStrConst.S_BAT_TRAN_CD_ISP});
}
// コード名称管理よりeonetIDコンテンツ利用料料金項目コード取得
JBSbatCommonDBInterface dbList2 = new JBSbatCommonDBInterface();
dbList2. setValue(JCNStrConst.S_CD01286);
dbList2. setValue(1);
executeZM_M_CD_NM_KANRI_CN_SELECT_002(dbList2.getList().toArray());
for(map = db_ZM_M_CD_NM_KANRI.selectNext(); null != map; map = db_ZM_M_CD_NM_KANRI.selectNext())
{
str_Eonet_ID_Prc_Kmk_Cd = map.getString("CD_DIV_NM");
}
// コンテンツISP課金より取得
JBSbatCommonDBInterface dbList3 = new JBSbatCommonDBInterface();
dbList3. setValue(strSiky_Ym);
dbList3. setValue(strSiky_Ym);
dbList3. setValue(strSiky_Next_Ymd);
dbList3. setValue(strOpeDate);
executeCN_T_CONT_ISP_CHRG_CN_SELECT_004(dbList3.getList().toArray());
int mapCnt = 0;
for(map = db_CN_T_CONT_ISP_CHRG.selectNext(); null != map; map = db_CN_T_CONT_ISP_CHRG.selectNext())
{
// コンテンツISP課金データファイルの作成
JBSbatServiceInterfaceMap outmap = new JBSbatServiceInterfaceMap();
// 項目を設定
outmap.setString(JBSbatCNIFM001001.CHRG_TRGT_YM, map.getString("ISP_CHRG_TRGT_YM"));
outmap.setString(JBSbatCNIFM001001.ISP_KSSAI_SVC_KEI_NO, map.getString("ISP_KSSAI_SVC_KEI_NO"));
outmap.setString(JBSbatCNIFM001001.CONT_SVC_CD, map.getString("CONT_SVC_CD"));
outmap.setString(JBSbatCNIFM001001.TAXAREA, map.getString("TAXAREA"));
// outmap.setString(JBSbatCNIFM001001.PCRS_CD, str_Pcrs_Cd);
// outmap.setString(JBSbatCNIFM001001.PRC_SVC_CD, str_Prc_Svc_Cd);
// 料金項目コードがNULL、且つ、コンテンツサービスマスタにコンテンツコードが存在しない場合は空白を設定
// 料金項目コードがNULL、且つ、コンテンツサービスマスタにコンテンツコードが存在する場合はeonetIDコンテンツ利用料の料金項目コードを設定
str_Prc_Kmk_Cd = map.getString("PRC_KMK_CD");
str_Cont_Svc_Cd_Mst = map.getString("CONT_SVC_CD_MST");
if (str_Prc_Kmk_Cd == null)
{
if(str_Cont_Svc_Cd_Mst == null)
{
str_Prc_Kmk_Cd = str_Prc_Kmk_Cd_space;
}
else
{
str_Prc_Kmk_Cd = str_Eonet_ID_Prc_Kmk_Cd;
}
}
outmap.setString(JBSbatCNIFM001001.PRC_KMK_CD, str_Prc_Kmk_Cd); // 料金項目コード設定
l_Chrg_Amnt = Long.parseLong(map.getString("CHRG_AMNT"));
if (l_Chrg_Amnt < 0)
{
// 課金額が0未満の場合は「-」を含めて12桁になるように0埋めする。
String strMidAmnt = String.valueOf(l_Chrg_Amnt);
strChrgAmnt = JCNStrConst.S_HAIFUN + JCNBatCommon.strZeroPad(strMidAmnt.substring(1, strMidAmnt.length()), 11);
}
else
{
// 課金額が0以上の場合は12桁になるように0埋めする。
String strMidAmnt = String.valueOf(l_Chrg_Amnt);
strChrgAmnt = JCNBatCommon.strZeroPad(strMidAmnt, 12);
}
outmap.setString(JBSbatCNIFM001001.CHRG_AMNT, strChrgAmnt); // 課金額設定
l_Sales_Gen_Amnt = Long.parseLong(map.getString("SALES_GEN_AMNT"));
if (l_Sales_Gen_Amnt < 0)
{
// 売上減額が0未満の場合は「-」を含めて12桁になるように0埋めする。
String strMidGen = String.valueOf(l_Sales_Gen_Amnt);
strGenAmnt = JCNStrConst.S_HAIFUN + JCNBatCommon.strZeroPad(strMidGen.substring(1, strMidGen.length()), 11);
}
else
{
// 売上減額が0以上の場合は12桁になるように0埋めする。
String strMidAmnt = String.valueOf(l_Sales_Gen_Amnt);
strGenAmnt = JCNBatCommon.strZeroPad(strMidAmnt, 12);
}
outmap.setString(JBSbatCNIFM001001.SALES_GEN_AMNT, strGenAmnt); // 売上減額設定
l_Conpensation = Long.parseLong(map.getString("COMPENSATION"));
if (l_Conpensation < 0)
{
// 売上減額が0未満の場合は「-」を含めて12桁になるように0埋めする。
String strMidCon = String.valueOf(l_Conpensation);
strConAmnt = JCNStrConst.S_HAIFUN + JCNBatCommon.strZeroPad(strMidCon.substring(1, strMidCon.length()), 11);
}
else
{
// 売上減額が0以上の場合は12桁になるように0埋めする。
String strMidAmnt = String.valueOf(l_Conpensation);
strConAmnt = JCNBatCommon.strZeroPad(strMidAmnt, 12);
}
outmap.setString(JBSbatCNIFM001001.COMPENSATION, strConAmnt); // 補償費設定
outmap.setString(JBSbatCNIFM001001.CONT_CD, map.getString("CONT_CD")); // コンテンツコード設定
outmap.setString(JBSbatCNIFM001001.CONT_KEI_NO, map.getString("CONT_KEI_NO")); // コンテンツ契約番号設定
// ANK-3636-00-00 ADD START
outmap.setString(JBSbatCNIFM001001.CHRG_JTN_TAX_RT, map.getString("CHRG_JTN_TAX_RT")); // 課金時税率
// ANK-3636-00-00 ADD END
// 出力フラグを設定
outmap.setOutFlg(true);
// 出力共通電文に入出力インターフェースを設定する。
outputBean.addOutMapList(outmap);
mapCnt++;
}
// コンテンツISP課金の取得件数が0件の場合はファイルに[NO_DATA]を出力
if(mapCnt == 0)
{
// コンテンツISP課金データファイルの作成
JBSbatServiceInterfaceMap outmap = new JBSbatServiceInterfaceMap();
//
outmap.setString(JBSbatCNIFM001001.CHRG_TRGT_YM, JCNStrConst.S_NO_DATA);
// 出力フラグを設定
outmap.setOutFlg(true);
// 出力共通電文に入出力インターフェースを設定する。
outputBean.addOutMapList(outmap);
}
// 処理結果ログ出力
super.logPrint.printBusinessErrorLog(ECNB0090AI, new String[] {S_CNIFM001001_NM, String.valueOf(mapCnt)});
return outputBean;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_CN_T_TRAN_YMD_INFO.close();
db_CN_T_CONT_ISP_CHRG.close();
db_ZM_M_CD_NM_KANRI.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(CN_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * バッチ処理コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_TRAN_YMD_INFO_CN_SELECT_002(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_CN_T_TRAN_YMD_INFO.selectBySqlDefine(paramList, CN_T_TRAN_YMD_INFO_CN_SELECT_002);
}
/**
* SQLKEY(CN_SELECT_004)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * CHRG_TRGT_YM * CHRG_TRGT_YM * CHRG_TRGT_YM_AFTYMD *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_CONT_ISP_CHRG_CN_SELECT_004(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
paramList.setValue(param[2].toString());
paramList.setValue(param[3].toString());
// DBアクセスを実行します
db_CN_T_CONT_ISP_CHRG.selectBySqlDefine(paramList, CN_T_CONT_ISP_CHRG_CN_SELECT_004);
}
/**
* SQLKEY(CN_SELECT_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * コード種別コード * コード区分 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeZM_M_CD_NM_KANRI_CN_SELECT_002(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); // DBアクセスを実行します db_ZM_M_CD_NM_KANRI.selectBySqlDefine(paramList, ZM_M_CD_NM_KANRI_CN_SELECT_002); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }