*
* @author 富士通
*/
public class JBSbatCNSvcSoktHibtSmr extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(処理日付情報)*/
private static final String D_TBL_NAME_CN_T_TRAN_YMD_INFO = "CN_T_TRAN_YMD_INFO";
/** テーブル(コード名称管理)*/
private static final String D_TBL_NAME_ZM_M_CD_NM_KANRI = "ZM_M_CD_NM_KANRI";
/** テーブル(コンテンツサービス)*/
private static final String D_TBL_NAME_CN_M_CONT_SVC = "CN_M_CONT_SVC";
/** テーブル(総括日別サマリー)*/
private static final String D_TBL_NAME_CN_T_SOKT_HIBT_SMR = "CN_T_SOKT_HIBT_SMR";
/** テーブル(会員種別日別サマリー)*/
private static final String D_TBL_NAME_CN_T_MBTYPE_HIBT_SMR = "CN_T_MBTYPE_HIBT_SMR";
/** テーブル(総括月別サマリー)*/
private static final String D_TBL_NAME_CN_T_SOKT_TKBT_SMR = "CN_T_SOKT_TKBT_SMR";
/** SQL定義キー(CN_SELECT_002)*/
private static final String CN_T_TRAN_YMD_INFO_CN_SELECT_002 = "CN_SELECT_002";
/** SQL定義キー(CN_SELECT_001)*/
private static final String ZM_M_CD_NM_KANRI_CN_SELECT_002 = "CN_SELECT_002";
/** SQL定義キー(CN_SELECT_001)*/
private static final String CN_M_CONT_SVC_CN_SELECT_001 = "CN_SELECT_001";
/** SQL定義キー(CN_SELECT_007)*/
private static final String CN_M_CONT_SVC_CN_SELECT_007 = "CN_SELECT_007";
/** SQL定義キー(CN_DELETE_002)*/
private static final String CN_T_SOKT_HIBT_SMR_CN_DELETE_002 = "CN_DELETE_002";
/** SQL定義キー(CN_SELECT_009)*/
private static final String CN_T_MBTYPE_HIBT_SMR_CN_SELECT_009 = "CN_SELECT_009";
/** SQL定義キー(CN_SELECT_004)*/
private static final String CN_T_SOKT_HIBT_SMR_CN_SELECT_005 = "CN_SELECT_005";
/** SQL定義キー(CN_SELECT_010)*/
private static final String CN_T_MBTYPE_HIBT_SMR_CN_SELECT_011 = "CN_SELECT_011";
/** SQL定義キー(CN_SELECT_001)*/
private static final String CN_T_SOKT_TKBT_SMR_CN_SELECT_003 = "CN_SELECT_003";
/** SQL定義キー(CN_SELECT_002)*/
private static final String CN_T_SOKT_TKBT_SMR_CN_SELECT_002 = "CN_SELECT_002";
/** SQL定義キー(CN_INSERT_001)*/
private static final String CN_T_SOKT_HIBT_SMR_CN_INSERT_001 = "CN_INSERT_001";
/** SQL定義キー(CN_INSERT_001)*/
private static final String CN_T_SOKT_TKBT_SMR_CN_INSERT_001 = "CN_INSERT_001";
/** SQL定義キー(CN_UPDATE_001)*/
private static final String CN_T_SOKT_TKBT_SMR_CN_UPDATE_003 = "CN_UPDATE_003";
/** テーブルアクセスクラス(処理日付情報)*/
private JBSbatSQLAccess db_CN_T_TRAN_YMD_INFO = null;
/** テーブルアクセスクラス(コード名称管理)*/
private JBSbatSQLAccess db_ZM_M_CD_NM_KANRI = null;
/** テーブルアクセスクラス(コード名称管理)*/
private JBSbatSQLAccess db_CN_M_CONT_SVC = null;
/** テーブルアクセスクラス(総括日別サマリー)*/
private JBSbatSQLAccess db_CN_T_SOKT_HIBT_SMR = null;
/** テーブルアクセスクラス(会員種別日別サマリー)*/
private JBSbatSQLAccess db_CN_T_MBTYPE_HIBT_SMR = null;
/** テーブルアクセスクラス(総括月別サマリー)*/
private JBSbatSQLAccess db_CN_T_SOKT_TKBT_SMR = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** メッセージキー*/
private static final String ECNB0070AI = JPCBatchMessageConstant.ECNB0070AI;
/** メッセージキー(ECNB0080KE)*/
private static final String ECNB0080KE = JPCBatchMessageConstant.ECNB0080KE;
/** メッセージキー*/
private static final String ECNB0220AI = JPCBatchMessageConstant.ECNB0220AI;
/** メッセージキー*/
private static final String ECNB0420KE = JPCBatchMessageConstant.ECNB0420KE;
/** 処理名称(サービス総括日別会員数サマリー処理)*/
private static final String S_CN_TRAN_DATE_UPDATE = "サービス総括日別会員数サマリー処理";
/** 項目名称(コンテンツサービスコード)*/
private static final String S_CONT_SVC_CD = "コンテンツサービスコード";
/** 項目名称(集計用コンテンツサービス識別コード)*/
private static final String S_SUNK_CONT_SVC_CD = "集計用コンテンツサービス識別コード";
/** 項目名称(集計用コンテンツサービス識別コード)*/
private static final String S_NOT_KEY = "キー項目なし";
/** ミリ秒埋め込み用*/
private static final String S_STA_DAY = "01";
/** ミリ秒埋め込み用*/
private static final String S_END_DAY = "31";
/**
* 初期処理
* @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_ZM_M_CD_NM_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_CD_NM_KANRI);
db_CN_M_CONT_SVC = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CN_M_CONT_SVC);
db_CN_T_SOKT_HIBT_SMR = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CN_T_SOKT_HIBT_SMR);
db_CN_T_MBTYPE_HIBT_SMR = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CN_T_MBTYPE_HIBT_SMR);
db_CN_T_SOKT_TKBT_SMR = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CN_T_SOKT_TKBT_SMR);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
int iInsHibtCnt = 0; // 総括日別サマリー登録件数カウント
int iInsTkbtCnt = 0; // 総括月別サマリー登録件数カウント
int iUpdTkbtCnt = 0; // 総括月別サマリー更新件数カウント
int iContSvcCnt = 0;
String strSunk_Svc_Cd = ""; // コンテンツサービスコード取得用変数
String strSunk_Ymd = ""; // 集計用年月日(当月)
String strBefr_Ymd = ""; // 集計用年月日(前月)
String strSunk_Ym = ""; // 集計用年月(当月)
String strBefr_Ym = ""; // 集計用年月(前月)
String strSunk_StaYmd = ""; // 集計用日付(月初)
String strSunk_EndYmd = ""; // 集計用日付(月末)
// 処理日付情報を取得
JBSbatCommonDBInterface dbList1 = new JBSbatCommonDBInterface();
dbList1. setValue(JCNStrConst.S_BAT_TRAN_CD_SMR);
executeCN_T_TRAN_YMD_INFO_CN_SELECT_002(dbList1.getList().toArray());
// SQL実行結果を取得
JBSbatCommonDBInterface map = new JBSbatCommonDBInterface();
for(map = db_CN_T_TRAN_YMD_INFO.selectNext(); null != map; map = db_CN_T_TRAN_YMD_INFO.selectNext())
{
strSunk_Ymd = map.getString("TRAN_TG_YMD"); // バッチ処理実行日
strBefr_Ymd = map.getString("TRAN_TG_YMD_BEFR"); // バッチ処理実行日前日
strSunk_Ym = map.getString("SIKY_YM"); // バッチ処理実行月
strBefr_Ym = map.getString("TRAN_TG_YMD_BEFRM").substring(0, 6); // バッチ処理実行前月
}
// 処理日付情報が取得できなかった場合は異常終了する。
if("".equals(strSunk_Ymd))
{
super.logPrint.printBusinessErrorLog(ECNB0080KE, new String[]
{S_CN_TRAN_DATE_UPDATE, D_TBL_NAME_CN_T_TRAN_YMD_INFO, "BAT_TRAN_CD=" + JCNStrConst.S_BAT_TRAN_CD_SMR});
throw new JBSbatBusinessException(ECNB0080KE, new String[]
{S_CN_TRAN_DATE_UPDATE, D_TBL_NAME_CN_T_TRAN_YMD_INFO, "BAT_TRAN_CD=" + JCNStrConst.S_BAT_TRAN_CD_SMR});
}
// コード名称管理より「CD01098:集計用コンテンツサービス識別コード」のコード種別を取得
JBSbatCommonDBInterface sunkCd_dbList = new JBSbatCommonDBInterface();
JBSbatCommonDBInterface sunkCd_map = new JBSbatCommonDBInterface();
sunkCd_dbList. setValue(JCNStrConst.S_CD01198); // コード種別コード設定
sunkCd_dbList. setValue(JCNStrConst.S_ONE); // コード区分設定
executeZM_M_CD_NM_KANRI_CN_SELECT_002(sunkCd_dbList.getList().toArray());
sunkCd_map = db_ZM_M_CD_NM_KANRI.selectNext();
if(sunkCd_map == null)
{
super.logPrint.printBusinessErrorLog(ECNB0420KE, new String[] {S_SUNK_CONT_SVC_CD, JCNStrConst.S_CD01198});
throw new JBSbatBusinessException(ECNB0420KE, new String[] {S_SUNK_CONT_SVC_CD, JCNStrConst.S_CD01198});
}
strSunk_Svc_Cd = sunkCd_map.getString("CD_DIV_NM");
// コンテンツサービスよりコンテンツサービスコード件数を取得
JBSbatCommonDBInterface svccdCnt_dbList = new JBSbatCommonDBInterface();
JBSbatCommonDBInterface svccdcnt_map = new JBSbatCommonDBInterface();
executeCN_M_CONT_SVC_CN_SELECT_007(svccdCnt_dbList.getList().toArray());
svccdcnt_map = db_CN_M_CONT_SVC.selectNext();
// 取得できた要素数をカウントする(配列の大きさを確定)
iContSvcCnt = Integer.parseInt(svccdcnt_map.getString("RECORD_CNT"));
// 取得した要素数を元に配列を定義(総括日別サマリー登録用)
String[][] svc_daysmr_map = new String[iContSvcCnt][6];
// 取得した要素数を元に配列を定義(総括月別サマリー登録用)
String[][] svc_monsmr_map = new String[iContSvcCnt][6];
// コンテンツサービスよりコンテンツサービスコードを全件取得(総括日別サマリー取得用)
JBSbatCommonDBInterface svcCd_dbList = new JBSbatCommonDBInterface();
JBSbatCommonDBInterface svcCd_map = new JBSbatCommonDBInterface();
executeCN_M_CONT_SVC_CN_SELECT_001(svcCd_dbList.getList().toArray());
int iCnt = 0;
// コンテンツサービスコードを全て取得し、総括日別サマリー登録用配列に格納、それ以外の箇所は初期化する。
for(svcCd_map = db_CN_M_CONT_SVC.selectNext(); null != svcCd_map; svcCd_map = db_CN_M_CONT_SVC.selectNext())
{
String strContSvcCd = JCNStrConst.S_ZERO + svcCd_map.getString("CONT_SVC_CD");
svc_daysmr_map[iCnt][0] = strContSvcCd;
svc_daysmr_map[iCnt][1] = JCNStrConst.S_ZERO;
svc_daysmr_map[iCnt][2] = JCNStrConst.S_ZERO;
svc_daysmr_map[iCnt][3] = JCNStrConst.S_ZERO;
svc_daysmr_map[iCnt][4] = JCNStrConst.S_ZERO;
svc_daysmr_map[iCnt][5] = JCNStrConst.S_ZERO;
svc_monsmr_map[iCnt][0] = strContSvcCd;
svc_monsmr_map[iCnt][1] = JCNStrConst.S_ZERO;
svc_monsmr_map[iCnt][2] = JCNStrConst.S_ZERO;
svc_monsmr_map[iCnt][3] = JCNStrConst.S_ZERO;
svc_monsmr_map[iCnt][4] = JCNStrConst.S_ZERO;
svc_monsmr_map[iCnt][5] = JCNStrConst.S_ZERO;
iCnt++;
}
if(iCnt == 0)
{
super.logPrint.printBusinessErrorLog(ECNB0420KE, new String[] {S_CONT_SVC_CD, S_NOT_KEY});
throw new JBSbatBusinessException(ECNB0420KE, new String[] {S_CONT_SVC_CD, S_NOT_KEY});
}
// バッチ処理日付に該当する総括日別サマリーデータを削除する。
JBSbatCommonDBInterface delete_dbList = new JBSbatCommonDBInterface();
delete_dbList. setValue(strSunk_Ymd);
delete_dbList. setValue(strSunk_Svc_Cd);
executeCN_T_SOKT_HIBT_SMR_CN_DELETE_002(delete_dbList.getList().toArray());
// 会員種別日別サマリーより当日時点の累計件数、新規件数、解約件数を取得する。
JBSbatCommonDBInterface allCnt_dbList = new JBSbatCommonDBInterface();
JBSbatCommonDBInterface allCnt_map = new JBSbatCommonDBInterface();
allCnt_dbList. setValue(strSunk_Ymd); // 総括日別集計対象年月日
allCnt_dbList. setValue(strSunk_Svc_Cd); // コンテンツサービス識別コード
executeCN_T_MBTYPE_HIBT_SMR_CN_SELECT_009(allCnt_dbList.getList().toArray());
for(allCnt_map = db_CN_T_MBTYPE_HIBT_SMR.selectNext(); allCnt_map != null; allCnt_map = db_CN_T_MBTYPE_HIBT_SMR.selectNext())
{
// 取得したデータを1件読み込み、コンテンツサービス識別コードが同じ時は総括日別サマリー登録用配列に格納を行う
for(int i = 0; i < svc_daysmr_map.length; i++)
{
String strContSvcSkbtCd = allCnt_map.getString("CONT_SVC_SKBT_CD");
String strSumRuikeiCnt = allCnt_map.getString("SUM_RUIKEI_CNT");
if(svc_daysmr_map[i][0].equals(strContSvcSkbtCd))
{
svc_daysmr_map[i][1] = strSumRuikeiCnt;
svc_daysmr_map[i][4] = allCnt_map.getString("SUM_NEW_CNT");
svc_daysmr_map[i][5] = allCnt_map.getString("SUM_DSL_CNT");
}
if(svc_monsmr_map[i][0].equals(strContSvcSkbtCd))
{
svc_monsmr_map[i][1] = strSumRuikeiCnt;
}
}
}
// 総括日別サマリーより前日累計件数を取得
JBSbatCommonDBInterface befdayallCnt_dbList = new JBSbatCommonDBInterface();
JBSbatCommonDBInterface befdayallCnt_map = new JBSbatCommonDBInterface();
befdayallCnt_dbList. setValue(strBefr_Ymd); // 総括日別集計対象年月日
befdayallCnt_dbList. setValue(strSunk_Svc_Cd); // コンテンツサービス識別コード
executeCN_T_SOKT_HIBT_SMR_CN_SELECT_005(befdayallCnt_dbList.getList().toArray());
// 取得したデータを1件読み込み、コンテンツサービス識別コードが同じ時は総括日別サマリー登録用配列に格納を行う
for(befdayallCnt_map = db_CN_T_SOKT_HIBT_SMR.selectNext(); befdayallCnt_map != null; befdayallCnt_map = db_CN_T_SOKT_HIBT_SMR.selectNext())
{
for(int i = 0; i < svc_daysmr_map.length; i++)
{
if(svc_daysmr_map[i][0].equals(befdayallCnt_map.getString("CONT_SVC_SKBT_CD")))
{
svc_daysmr_map[i][2] = befdayallCnt_map.getString("RUIKEI_CNT"); // 前日累計件数格納
}
}
}
// 総括日別サマリーの増分件数を計算
for(int i = 0; i < svc_daysmr_map.length; i++)
{
// 増分件数を計算する。
long lUpCnt = (Long.parseLong(svc_daysmr_map[i][1]))
- (Long.parseLong(svc_daysmr_map[i][2]));
svc_daysmr_map[i][3] = String.valueOf(lUpCnt); // 増分件数格納
}
// 会員種別日別サマリーより今月度の新規契約件数合計、解約件数を取得
strSunk_StaYmd = strSunk_Ym + S_STA_DAY;
strSunk_EndYmd = strSunk_Ym + S_END_DAY;
JBSbatCommonDBInterface tkbtCnt_dbList = new JBSbatCommonDBInterface();
JBSbatCommonDBInterface tkbtCnt_map = new JBSbatCommonDBInterface();
tkbtCnt_dbList. setValue(strSunk_StaYmd); // 総括日別集計対象年月日
tkbtCnt_dbList. setValue(strSunk_EndYmd); // 総括日別集計対象年月日
tkbtCnt_dbList. setValue(strSunk_Svc_Cd); // コンテンツサービス識別コード
executeCN_T_MBTYPE_HIBT_SMR_CN_SELECT_011(tkbtCnt_dbList.getList().toArray());
for(tkbtCnt_map = db_CN_T_MBTYPE_HIBT_SMR.selectNext(); tkbtCnt_map != null; tkbtCnt_map = db_CN_T_MBTYPE_HIBT_SMR.selectNext())
{
// 取得したデータを1件読み込み、コンテンツサービス識別コードが同じ時は総括月別サマリー登録用配列に格納を行う
for(int i = 0; i < svc_monsmr_map.length; i++)
{
if(svc_monsmr_map[i][0].equals(tkbtCnt_map.getString("CONT_SVC_SKBT_CD")))
{
svc_monsmr_map[i][4] = tkbtCnt_map.getString("NEW_CNT_SMR");
svc_monsmr_map[i][5] = tkbtCnt_map.getString("DSL_CNT_SMR");
}
}
}
// 総括月別サマリー前月の累計件数
JBSbatCommonDBInterface befmonallCnt_dbList = new JBSbatCommonDBInterface();
JBSbatCommonDBInterface befmonallCnt_map = new JBSbatCommonDBInterface();
befmonallCnt_dbList. setValue(strBefr_Ym); // 総括日別集計対象年月日
befmonallCnt_dbList. setValue(strSunk_Svc_Cd); // コンテンツサービス識別コード
executeCN_T_SOKT_TKBT_SMR_CN_SELECT_003(befmonallCnt_dbList.getList().toArray());
// 取得したデータを1件読み込み、コンテンツサービス識別コードが同じ時は総括月別サマリー登録用配列に格納を行う
for(befmonallCnt_map = db_CN_T_SOKT_TKBT_SMR.selectNext(); befmonallCnt_map != null; befmonallCnt_map = db_CN_T_SOKT_TKBT_SMR.selectNext())
{
for(int i = 0; i < svc_monsmr_map.length; i++)
{
if(svc_monsmr_map[i][0].equals(befmonallCnt_map.getString("CONT_SVC_SKBT_CD")))
{
svc_monsmr_map[i][2] = befmonallCnt_map.getString("RUIKEI_CNT"); // 前日累計件数格納
}
}
}
// 総括月別サマリーの増分件数を計算する。
for(int i = 0; i < svc_monsmr_map.length; i++)
{
long lUpCnt = (Long.parseLong(svc_monsmr_map[i][1]))
- (Long.parseLong(svc_monsmr_map[i][2]));
svc_monsmr_map[i][3] = String.valueOf(lUpCnt); // 増分件数格納
}
for(int i = 0; i < svc_daysmr_map.length; i++)
{
// 取得した総括日別サマリーデータを登録する。
JBSbatCommonDBInterface hibt_dbList = new JBSbatCommonDBInterface();
hibt_dbList. setValue(strSunk_Ymd); // 総括日別集計対象年月日
hibt_dbList. setValue(svc_daysmr_map[i][0]); // コンテンツサービス識別コード
hibt_dbList. setValue(svc_daysmr_map[i][1]); // 累計件数
hibt_dbList. setValue(svc_daysmr_map[i][3]); // 増分件数
hibt_dbList. setValue(svc_daysmr_map[i][4]); // 新規件数
hibt_dbList. setValue(svc_daysmr_map[i][5]); // 解約件数
hibt_dbList. setValue(JCNStrConst.S_ZERO); // 売上件数
hibt_dbList. setValue(JCNStrConst.S_ZERO); // 売上金額
hibt_dbList. setValue(JCNStrConst.S_ZERO); // 購入者数
// hibt_dbList. setValue(JCNBatCommon.getSysDateTimeStamp()); // 登録年月日時分秒
// hibt_dbList. setValue(commonItem.getBatchUserId()); // 登録オペレータアカウント
// hibt_dbList. setValue(JCNBatCommon.getSysDateTimeStamp()); // 更新年月日時分秒
// hibt_dbList. setValue(commonItem.getBatchUserId()); // 更新オペレータアカウント
hibt_dbList. setValue(""); // 削除年月日時分秒
hibt_dbList. setValue(""); // 削除オペレータアカウント
// hibt_dbList. setValue(JCNStrConst.S_MK_FLG); // 無効フラグ
executeCN_T_SOKT_HIBT_SMR_CN_INSERT_001(hibt_dbList.getList().toArray());
iInsHibtCnt++;
}
for(int i = 0; i < svc_monsmr_map.length; i++)
{
// 総括月別サマリーデータ存在チェック
JBSbatCommonDBInterface existCnt_dbList = new JBSbatCommonDBInterface();
existCnt_dbList. setValue(strSunk_Ym); // 総括月別集計対象年月日
existCnt_dbList. setValue(svc_monsmr_map[i][0]); // コンテンツサービス識別コード
executeCN_T_SOKT_TKBT_SMR_CN_SELECT_002(existCnt_dbList.getList().toArray());
String strExistCnt = "";
strExistCnt = db_CN_T_SOKT_TKBT_SMR.selectNext().getString("RECORD_COUNT");
// 取得結果が0件の場合は登録を行う。
if(JCNStrConst.S_ZERO.equals(strExistCnt))
{
// 取得した結果を総括日別サマリーデータ登録する。
JBSbatCommonDBInterface tkbt_ins_dbList = new JBSbatCommonDBInterface();
tkbt_ins_dbList. setValue(strSunk_Ym); // 総括月別集計対象年月日
tkbt_ins_dbList. setValue(svc_monsmr_map[i][0]); // コンテンツサービス識別コード
tkbt_ins_dbList. setValue(svc_monsmr_map[i][1]); // 累計件数
tkbt_ins_dbList. setValue(svc_monsmr_map[i][3]); // 増分件数
tkbt_ins_dbList. setValue(svc_monsmr_map[i][4]); // 新規件数
tkbt_ins_dbList. setValue(svc_monsmr_map[i][5]); // 解約件数
tkbt_ins_dbList. setValue(JCNStrConst.S_ZERO); // 売上件数
tkbt_ins_dbList. setValue(JCNStrConst.S_ZERO); // 売上金額
tkbt_ins_dbList. setValue(JCNStrConst.S_ZERO); // 購入者数
// tkbt_ins_dbList. setValue(JCNBatCommon.getSysDateTimeStamp()); // 登録年月日時分秒
// tkbt_ins_dbList. setValue(commonItem.getBatchUserId()); // 登録オペレータアカウント
// tkbt_ins_dbList. setValue(JCNBatCommon.getSysDateTimeStamp()); // 更新年月日時分秒
// tkbt_ins_dbList. setValue(commonItem.getBatchUserId()); // 更新オペレータアカウント
tkbt_ins_dbList. setValue(""); // 削除年月日時分秒
tkbt_ins_dbList. setValue(""); // 削除オペレータアカウント
// tkbt_ins_dbList. setValue(JCNStrConst.S_MK_FLG); // 無効フラグ
executeCN_T_SOKT_TKBT_SMR_CN_INSERT_001(tkbt_ins_dbList.getList().toArray());
iInsTkbtCnt++;
}
// 取得結果が0件以外の場合は更新を行う。
else
{
JBSbatCommonDBInterface tkbt_upd_dbList = new JBSbatCommonDBInterface();
tkbt_upd_dbList. setValue(svc_monsmr_map[i][1]); // 累計件数
tkbt_upd_dbList. setValue(svc_monsmr_map[i][3]); // 増分件数
tkbt_upd_dbList. setValue(svc_monsmr_map[i][4]); // 新規件数
tkbt_upd_dbList. setValue(svc_monsmr_map[i][5]); // 解約件数
// tkbt_upd_dbList. setValue(JCNBatCommon.getSysDateTimeStamp()); // 更新年月日時分秒
// tkbt_upd_dbList. setValue(commonItem.getBatchUserId()); // 更新オペレータアカウント
tkbt_upd_dbList. setValue(strSunk_Ym); // 総括月別集計年月
tkbt_upd_dbList. setValue(svc_monsmr_map[i][0]); // コンテンツサービス識別コード
executeCN_T_SOKT_TKBT_SMR_CN_UPDATE_003(tkbt_upd_dbList.getList().toArray());
iUpdTkbtCnt++;
}
}
super.logPrint.printBusinessErrorLog(ECNB0220AI,
new String[]{D_TBL_NAME_CN_T_SOKT_HIBT_SMR, String.valueOf(iInsHibtCnt)}); // 総括日別サマリー登録件数
super.logPrint.printBusinessErrorLog(ECNB0220AI,
new String[]{D_TBL_NAME_CN_T_SOKT_TKBT_SMR, String.valueOf(iInsTkbtCnt)}); // 総括月別サマリー登録件数
super.logPrint.printBusinessErrorLog(ECNB0070AI,
new String[]{D_TBL_NAME_CN_T_SOKT_TKBT_SMR, String.valueOf(iUpdTkbtCnt)}); // 総括月別サマリー更新件数
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_CN_T_TRAN_YMD_INFO.close();
db_ZM_M_CD_NM_KANRI.close();
db_CN_M_CONT_SVC.close();
db_CN_T_SOKT_HIBT_SMR.close();
db_CN_T_MBTYPE_HIBT_SMR.close();
db_CN_T_SOKT_TKBT_SMR.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(CN_SELECT_002)で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_001)で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);
}
/**
* SQLKEY(CN_DELETE_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 総括月別集計対象年月 * コンテンツサービス識別コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_SOKT_HIBT_SMR_CN_DELETE_002(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_CN_T_SOKT_HIBT_SMR.executeBySqlDefine(paramList, CN_T_SOKT_HIBT_SMR_CN_DELETE_002);
}
/**
* SQLKEY(CN_SELECT_009)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 会員種別日別集計対象年月日 * コンテンツサービス識別コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_MBTYPE_HIBT_SMR_CN_SELECT_009(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_CN_T_MBTYPE_HIBT_SMR.selectBySqlDefine(paramList, CN_T_MBTYPE_HIBT_SMR_CN_SELECT_009);
}
/**
* SQLKEY(CN_SELECT_005)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 総括日別集計対象年月日 * コンテンツサービス識別コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_SOKT_HIBT_SMR_CN_SELECT_005(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_CN_T_SOKT_HIBT_SMR.selectBySqlDefine(paramList, CN_T_SOKT_HIBT_SMR_CN_SELECT_005);
}
/**
* SQLKEY(CN_SELECT_010)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 会員種別日別集計対象年月日 * 会員種別日別集計対象年月日 * コンテンツサービス識別コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_MBTYPE_HIBT_SMR_CN_SELECT_011(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_CN_T_MBTYPE_HIBT_SMR.selectBySqlDefine(paramList, CN_T_MBTYPE_HIBT_SMR_CN_SELECT_011);
}
/**
* SQLKEY(CN_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 総括月別集計対象年月 * コンテンツサービス識別コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_SOKT_TKBT_SMR_CN_SELECT_003(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_CN_T_SOKT_TKBT_SMR.selectBySqlDefine(paramList, CN_T_SOKT_TKBT_SMR_CN_SELECT_003);
}
/**
* SQLKEY(CN_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * コード種別コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_M_CONT_SVC_CN_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
// DBアクセスを実行します
db_CN_M_CONT_SVC.selectBySqlDefine(paramList, CN_M_CONT_SVC_CN_SELECT_001);
}
/**
* SQLKEY(CN_SELECT_007)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * コード種別コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_M_CONT_SVC_CN_SELECT_007(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
// DBアクセスを実行します
db_CN_M_CONT_SVC.selectBySqlDefine(paramList, CN_M_CONT_SVC_CN_SELECT_007);
}
/**
* SQLKEY(CN_SELECT_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 総括月別集計対象年月 * コンテンツサービス識別コード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_SOKT_TKBT_SMR_CN_SELECT_002(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_CN_T_SOKT_TKBT_SMR.selectBySqlDefine(paramList, CN_T_SOKT_TKBT_SMR_CN_SELECT_002);
}
/**
* SQLKEY(CN_INSERT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 総括日別集計対象年月日 * コンテンツサービス識別コード * 累計件数 * 増分件数 * 新規件数 * 解約件数 * 売上件数 * 売上金額 * 購入者数 * 削除年月日時分秒 * 削除オペレータアカウント *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_SOKT_HIBT_SMR_CN_INSERT_001(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());
paramList.setValue(param[4].toString());
paramList.setValue(param[5].toString());
paramList.setValue(param[6].toString());
paramList.setValue(param[7].toString());
paramList.setValue(param[8].toString());
paramList.setValue(param[9].toString());
paramList.setValue(param[10].toString());
// DBアクセスを実行します
db_CN_T_SOKT_HIBT_SMR.executeBySqlDefine(paramList, CN_T_SOKT_HIBT_SMR_CN_INSERT_001);
}
/**
* SQLKEY(CN_INSERT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 総括月別集計対象年月 * コンテンツサービス識別コード * 累計件数 * 増分件数 * 新規件数 * 解約件数 * 売上件数 * 売上金額 * 購入者数 * 削除年月日時分秒 * 削除オペレータアカウント *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCN_T_SOKT_TKBT_SMR_CN_INSERT_001(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());
paramList.setValue(param[4].toString());
paramList.setValue(param[5].toString());
paramList.setValue(param[6].toString());
paramList.setValue(param[7].toString());
paramList.setValue(param[8].toString());
paramList.setValue(param[9].toString());
paramList.setValue(param[10].toString());
// DBアクセスを実行します
db_CN_T_SOKT_TKBT_SMR.executeBySqlDefine(paramList, CN_T_SOKT_TKBT_SMR_CN_INSERT_001);
}
/**
* SQLKEY(CN_UPDATE_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 売上件数 * 売上金額 * 総括月別集計対象年月 * コンテンツサービス識別コード *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeCN_T_SOKT_TKBT_SMR_CN_UPDATE_003(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()); paramList.setValue(param[4].toString()); paramList.setValue(param[5].toString()); // DBアクセスを実行します db_CN_T_SOKT_TKBT_SMR.executeBySqlDefine(paramList, CN_T_SOKT_TKBT_SMR_CN_UPDATE_003); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }