/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCNSoktShbtInfoSmr
*	ソースファイル名	：JBSbatCNSoktShbtInfoSmr.java
*	作成者				：富士通　
*	作成日				：2011年10月03日
*＜機能概要＞
*　総括週別集計情報サマリー処理部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/10/03   富士通		新規作成
*	v4.00.00	2013/02/06	FJ)小林		【TAI-2012-0000142】処理日付情報データ不在メッセージを見直し
*********************************************************************/
package eo.business.service;

import java.util.ArrayList;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCNBatCommon;
import eo.common.constant.JCNStrConst;
import eo.common.constant.JPCBatchMessageConstant;
import eo.common.util.JPCDateUtil;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatCNSoktShbtInfoSmr 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_CN_T_SOKT_HIBT_SMR = "CN_T_SOKT_HIBT_SMR";

	/** テーブル(総括週別サマリー)*/
	private static final String D_TBL_NAME_CN_T_SOKT_SHBT_SMR = "CN_T_SOKT_SHBT_SMR";

	/** SQL定義キー(CN_SELECT_002)*/
	private static final String CN_T_TRAN_YMD_INFO_CN_SELECT_002 = "CN_SELECT_002";

	/** SQL定義キー(CN_SELECT_003)*/
	private static final String CN_T_SOKT_HIBT_SMR_CN_SELECT_003 = "CN_SELECT_003";

	/** SQL定義キー(CN_SELECT_004)*/
	private static final String CN_T_SOKT_HIBT_SMR_CN_SELECT_004 = "CN_SELECT_004";

	/** SQL定義キー(CN_SELECT_001)*/
	private static final String CN_T_SOKT_SHBT_SMR_CN_SELECT_001 = "CN_SELECT_001";

	/** SQL定義キー(CN_INSERT_001)*/
	private static final String CN_T_SOKT_SHBT_SMR_CN_INSERT_001 = "CN_INSERT_001";

	/** SQL定義キー(CN_DELETE_001)*/
	private static final String CN_T_SOKT_SHBT_SMR_CN_DELETE_001 = "CN_DELETE_001";

	/** テーブルアクセスクラス(処理日付情報)*/
	private JBSbatSQLAccess db_CN_T_TRAN_YMD_INFO = null;

	/** テーブルアクセスクラス(総括日別サマリー)*/
	private JBSbatSQLAccess db_CN_T_SOKT_HIBT_SMR = null;

	/** テーブルアクセスクラス(総括週別サマリー)*/
	private JBSbatSQLAccess db_CN_T_SOKT_SHBT_SMR = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
	
	/** テーブルアクセスクラス(総括日別サマリー)*/
	private JBSbatSQLAccess db_CN_T_SOKT_HIBT_SMR_2 = null;
	
	/** メッセージキー*/
	private static final String ECNB0080KE = JPCBatchMessageConstant.ECNB0080KE;
	
	/** メッセージキー*/
	private static final String ECNB0410JW = JPCBatchMessageConstant.ECNB0410JW;
	
	/** メッセージキー*/
	private static final String ECNB0220AI = JPCBatchMessageConstant.ECNB0220AI;
	
	/** 処理名(総括週別集計情報サマリー)*/
	public static final String S_JOB_NAME = "総括週別集計情報サマリー";
	
	/** 処理日付算出用数値*/
	public static final int I_M_SEVEN = -7;

	/**
	 * 初期処理
	 * @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_SOKT_HIBT_SMR = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CN_T_SOKT_HIBT_SMR);
		db_CN_T_SOKT_SHBT_SMR = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CN_T_SOKT_SHBT_SMR);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		// DBアクセスクラスを生成します
		db_CN_T_SOKT_HIBT_SMR_2 = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CN_T_SOKT_HIBT_SMR);
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	@SuppressWarnings("unchecked")
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		// 処理日付情報を取得
		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(); 
		String strTranTgYmdSta = "";	// 集計対象週開始年月日
		String strTranTgYmdEnd = "";	// 集計対象週終了年月日
		String strTranTgYmdMaeS = "";	// 前週の集計対象週開始年月日
		
		// 処理日付情報とエラーフラグ(true:エラーあり,false:エラーなし)の設定
		boolean tranErrFlg = true;
		for(map = db_CN_T_TRAN_YMD_INFO.selectNext(); 
				null != map; 
				map = db_CN_T_TRAN_YMD_INFO.selectNext())
		{
			ArrayList<String> resultList1 = new ArrayList();			// 初期化
			resultList1 = JCNBatCommon.getDayOfTheWeek(map.getString("TRAN_TG_YMD"));		// 今週日付取得
			strTranTgYmdSta = resultList1.get(0);		// バッチ処理日付の前の月曜日の日付
			strTranTgYmdEnd = resultList1.get(1);		// バッチ処理日付の次の日曜日の日付
			tranErrFlg = false;
		}
		
		// 処理日付情報エラーフラグ = true:エラーあり の場合は、エラー出力し終了する。
		if(tranErrFlg)
		{
			super.logPrint.printBusinessErrorLog(ECNB0080KE, new String[]
			                                                			{S_JOB_NAME, D_TBL_NAME_CN_T_TRAN_YMD_INFO, "BAT_TRAN_CD=" + JCNStrConst.S_BAT_TRAN_CD_SMR});

			throw new JBSbatBusinessException(ECNB0080KE, new String[]
			                                                			{S_JOB_NAME, D_TBL_NAME_CN_T_TRAN_YMD_INFO, "BAT_TRAN_CD=" + JCNStrConst.S_BAT_TRAN_CD_SMR});
		}
		
		//前週の集計対象週開始年月日の算出
		strTranTgYmdMaeS = JPCDateUtil.addDay(strTranTgYmdSta, I_M_SEVEN);
		
		// 重複データの削除
		JBSbatCommonDBInterface dbList3 = new JBSbatCommonDBInterface();
		dbList3.setValue(strTranTgYmdSta);
		dbList3.setValue(strTranTgYmdEnd);
		executeCN_T_SOKT_SHBT_SMR_CN_DELETE_001(dbList3.getList().toArray());
		
		String strCSSkbtCD = "";	// コンテンツサービス識別コード
		long lNewCntSmr = 0;		// 新規件数（合計値）
		long lDslCntSmr = 0;		// 解約件数（合計値）
		long lSalCntSmr = 0;		// 売上件数（合計値）
		long lSalAmntSmr = 0;		// 売上金額（合計値）
		long lKnsuRikiCnt = 0;		// 総括日別サマリー累計件数（今週）
		long lZnsuRikiCnt = 0;		// 総括週別サマリー累計件数（前週）
		long lZubnCnt = 0;			// 増分件数
		int intInsCnt = 0;			// 登録件数
		
		// 会員種別日別サマリーから今週分の売上情報を取得
		JBSbatCommonDBInterface dbList4 = new JBSbatCommonDBInterface();
		dbList4.setValue(strTranTgYmdSta);
		dbList4.setValue(strTranTgYmdEnd);
		executeCN_T_SOKT_HIBT_SMR_CN_SELECT_003(dbList4.getList().toArray());
		for(map = db_CN_T_SOKT_HIBT_SMR.selectNext(); null != map; map = db_CN_T_SOKT_HIBT_SMR.selectNext())
		{
			strCSSkbtCD = map.getString("CONT_SVC_SKBT_CD");
			lNewCntSmr = Long.parseLong(map.getString("NEW_CNT_SMR"));
			lDslCntSmr = Long.parseLong(map.getString("DSL_CNT_SMR"));
			lSalCntSmr = Long.parseLong(map.getString("SALES_CNT_SMR"));
			lSalAmntSmr = Long.parseLong(map.getString("SALES_AMNT_SMR"));
			lKnsuRikiCnt = 0;
			lZnsuRikiCnt = 0;
			lZubnCnt = 0;
			
			// 今週分の累計件数を取得
			JBSbatCommonDBInterface dbList5 = new JBSbatCommonDBInterface();
			dbList5.setValue(strTranTgYmdEnd);
			dbList5.setValue(strCSSkbtCD);
			executeCN_T_SOKT_HIBT_SMR_CN_SELECT_004(dbList5.getList().toArray());
			for(map = db_CN_T_SOKT_HIBT_SMR_2.selectNext(); null != map; map = db_CN_T_SOKT_HIBT_SMR_2.selectNext())
			{
				lKnsuRikiCnt = Long.parseLong(map.getString("RUIKEI_CNT"));
			}
			
			// 前週分の累計件数を取得
			JBSbatCommonDBInterface dbList6 = new JBSbatCommonDBInterface();
			dbList6.setValue(strTranTgYmdMaeS);
			dbList6.setValue(strCSSkbtCD);
			executeCN_T_SOKT_SHBT_SMR_CN_SELECT_001(dbList6.getList().toArray());
			for(map = db_CN_T_SOKT_SHBT_SMR.selectNext(); null != map; map = db_CN_T_SOKT_SHBT_SMR.selectNext())
			{
				lZnsuRikiCnt = Long.parseLong(map.getString("RUIKEI_CNT"));
			}
			
			// 増分件数を算出（今週の累積件数−前週の累積件数）
			lZubnCnt = lKnsuRikiCnt - lZnsuRikiCnt;
		
			// 登録処理
			JBSbatCommonDBInterface dbList7 = new JBSbatCommonDBInterface();
			dbList7.setValue(strTranTgYmdSta);
			dbList7.setValue(strTranTgYmdEnd);
			dbList7.setValue(strCSSkbtCD);
			dbList7.setValue(lKnsuRikiCnt);
			dbList7.setValue(lZubnCnt);
			dbList7.setValue(lNewCntSmr);
			dbList7.setValue(lDslCntSmr);
			dbList7.setValue(lSalCntSmr);
			dbList7.setValue(lSalAmntSmr);
			dbList7.setValue(JCNStrConst.S_ZERO);
//			dbList7.setValue(JCNBatCommon.getSysDateTimeStamp());
//			dbList7.setValue(commonItem.getBatchUserId());
//			dbList7.setValue(JCNBatCommon.getSysDateTimeStamp());
//			dbList7.setValue(commonItem.getBatchUserId());
			dbList7.setValue("");
			dbList7.setValue("");
//			dbList7.setValue(JCNStrConst.S_MK_FLG);
			executeCN_T_SOKT_SHBT_SMR_CN_INSERT_001(dbList7.getList().toArray());
			
			// 登録件数カウントアップ
			intInsCnt++;
		}
		
		// 登録件数が0件の場合は異常終了
		if(0 == intInsCnt)
		{
			super.logPrint.printBusinessErrorLog(ECNB0410JW, new String[] {S_JOB_NAME});
		}
		
		// 登録件数ログ出力
		super.logPrint.printBusinessErrorLog(ECNB0220AI, new String[] {D_TBL_NAME_CN_T_SOKT_SHBT_SMR, String.valueOf(intInsCnt)});
		
		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_CN_T_TRAN_YMD_INFO.close();
		db_CN_T_SOKT_HIBT_SMR.close();
		db_CN_T_SOKT_SHBT_SMR.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
		db_CN_T_SOKT_HIBT_SMR_2.close();
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
	
	/**
	 * SQLKEY(CN_SELECT_002)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	バッチ処理コード
	 * </pre>
	 * <p>
	 * @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_003)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	総括日別集計対象年月日
	 *		 	総括日別集計対象年月日
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCN_T_SOKT_HIBT_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_HIBT_SMR.selectBySqlDefine(paramList, CN_T_SOKT_HIBT_SMR_CN_SELECT_003);
	}

	/**
	 * SQLKEY(CN_SELECT_004)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	総括日別集計対象年月日
	 *		 	コンテンツサービス識別コード
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCN_T_SOKT_HIBT_SMR_CN_SELECT_004(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_2.selectBySqlDefine(paramList, CN_T_SOKT_HIBT_SMR_CN_SELECT_004);
	}

	/**
	 * SQLKEY(CN_SELECT_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	総括週別集計対象週開始年月日
	 *		 	コンテンツサービス識別コード
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCN_T_SOKT_SHBT_SMR_CN_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());

		// DBアクセスを実行します
		db_CN_T_SOKT_SHBT_SMR.selectBySqlDefine(paramList, CN_T_SOKT_SHBT_SMR_CN_SELECT_001);
	}

	/**
	 * SQLKEY(CN_INSERT_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	総括週別集計対象週開始年月日
	 *		 	総括週別集計対象週終了年月日
	 *		 	コンテンツサービス識別コード
	 *		 	累計件数
	 *		 	増分件数
	 *		 	新規件数
	 *		 	解約件数
	 *		 	売上件数
	 *		 	売上金額
	 *		 	購入者数
	 *		 	削除年月日時分秒
	 *		 	削除オペレータアカウント
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCN_T_SOKT_SHBT_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());
		paramList.setValue(param[11].toString());

		// DBアクセスを実行します
		db_CN_T_SOKT_SHBT_SMR.executeBySqlDefine(paramList, CN_T_SOKT_SHBT_SMR_CN_INSERT_001);
	}

	/**
	 * SQLKEY(CN_DELETE_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	総括週別集計対象週開始年月日
	 *		 	総括集計対象週終了年月日
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCN_T_SOKT_SHBT_SMR_CN_DELETE_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());

		// DBアクセスを実行します
		db_CN_T_SOKT_SHBT_SMR.executeBySqlDefine(paramList, CN_T_SOKT_SHBT_SMR_CN_DELETE_001);
	}
	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
}