package project.data.task;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import db.DBBackupLock;
import db.util.BackupUtil;
import project.bonus.job.RecharegeBonus1DayJob;
import project.c2c.job.C2cStatistics1DayJob;
import project.data.WithdrawLimitAmountr1DayJob;
import project.data.job.CleanDataJob;
import project.finance.job.FinanceOrder1DayJob;
import project.finance.job.FinanceOrderCreateRecomJob;
import project.futures.job.FuturesOrderCreateRecomJob;
import project.log.SysLogService;
import project.miner.job.MinerOrderProfitJob;
import project.monitor.activity.job.ActivityOrderTaskJobHandle;
import project.syspara.Syspara;
import project.syspara.SysparaService;

public class TaskJobHandle {

	private static final Logger logger = LoggerFactory.getLogger(TaskJobHandle.class);

	protected CleanDataJob cleanDataJob;
	
	protected MinerOrderProfitJob minerOrderProfitJob;
	protected FinanceOrder1DayJob financeOrder1DayJob;
	protected RecharegeBonus1DayJob recharegeBonus1DayJob;
	
//	protected UserDataHoldingMoneyJob userDataHoldingMoneyJob;
	protected SysLogService sysLogService;
	protected SysparaService sysparaService;
	protected FinanceOrderCreateRecomJob financeOrderCreateRecomJob;
	protected FuturesOrderCreateRecomJob futuresOrderCreateRecomJob;
	protected ActivityOrderTaskJobHandle activityOrderTaskJobHandle;

	protected WithdrawLimitAmountr1DayJob withdrawLimitAmountr1DayJob;
	
	protected C2cStatistics1DayJob c2cStatistics1DayJob;
	
	public void newTaskJob() {
		/**
		 * 16点定时任务
		 */
		try {
			logger.error("newTaskJobHandle backup 发起调用 start...........");
			// 每日备份数据库
			BackupUtil.backup(sysLogService,sysparaService);
			logger.error("newTaskJobHandle backup 调用结束 end...........");
		}catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
			logger.error("TaskJobHandle fail e:",e);
		}
	}
	
	public void taskJob() {
		/**
		 * 凌晨4点主定时任务
		 */
		try {
			DBBackupLock.add(DBBackupLock.ALL_DB_LOCK);
			
			activityOrderTaskJobHandle.taskJob();
			
			// 理财每日计息
			financeOrder1DayJob.taskJob();
			
			// 矿机每日计息
			minerOrderProfitJob.taskJob();
			
			// 每日定时返佣前一天的 充值,为空则 上级不 返佣
			// 是否开启每日定时任务返佣，为空则不开启 0.5% 0.3% 0.2% = 0.005,0.003,0.002
			Syspara dailyRechargeRecom = this.sysparaService.find("daily_recharge_recom");
			if(null != dailyRechargeRecom && !"".equals(dailyRechargeRecom.getValue())) {
				recharegeBonus1DayJob.taskJob();
			}
			
			/**
			 * 每日定时任务是否重置提现限制流水，1重置，2不重置
			 */
			String withdraw_reset_daily = this.sysparaService.find("withdraw_reset_daily").getValue();
			/**
			 * 用户提现限制流水重置时间(1为凌晨4点，2为凌晨0点)
			 */
			String withdraw_reset_daily_time = this.sysparaService.find("withdraw_reset_daily_time").getValue();
			/**
			 *	是否重置当日提现限制流水
			 */
			if("1".equals(withdraw_reset_daily) && "1".equals(withdraw_reset_daily_time)) {
				withdrawLimitAmountr1DayJob.taskJob();
			}
			
			// 理财计算前一日购买奖励金额
			financeOrderCreateRecomJob.taskJob();

			// 交割计算前一日购买推荐奖励
			futuresOrderCreateRecomJob.taskJob();
			
			// 删除和重置分时和K线数据
			cleanDataJob.taskJob();
			
			// C2C统计数据
			c2cStatistics1DayJob.taskJob();
			
			logger.error("TaskJobHandle backup 发起调用 start...........");
			// 每日备份数据库
			BackupUtil.backup(sysLogService,sysparaService);
			logger.error("TaskJobHandle backup 调用结束 end...........");
			
		}catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
			logger.error("TaskJobHandle fail e:",e);
		}finally {
			DBBackupLock.remove(DBBackupLock.ALL_DB_LOCK);
		}
	}

	public void setCleanDataJob(CleanDataJob cleanDataJob) {
		this.cleanDataJob = cleanDataJob;
	}

//	public void setUserDataHoldingMoneyJob(UserDataHoldingMoneyJob userDataHoldingMoneyJob) {
//		this.userDataHoldingMoneyJob = userDataHoldingMoneyJob;
//	}

	public void setSysLogService(SysLogService sysLogService) {
		this.sysLogService = sysLogService;
	}

	public void setSysparaService(SysparaService sysparaService) {
		this.sysparaService = sysparaService;
	}


	public void setActivityOrderTaskJobHandle(ActivityOrderTaskJobHandle activityOrderTaskJobHandle) {
		this.activityOrderTaskJobHandle = activityOrderTaskJobHandle;
	}

	public void setMinerOrderProfitJob(MinerOrderProfitJob minerOrderProfitJob) {
		this.minerOrderProfitJob = minerOrderProfitJob;
	}

	public void setFinanceOrder1DayJob(FinanceOrder1DayJob financeOrder1DayJob) {
		this.financeOrder1DayJob = financeOrder1DayJob;
	}

	public void setFinanceOrderCreateRecomJob(FinanceOrderCreateRecomJob financeOrderCreateRecomJob) {
		this.financeOrderCreateRecomJob = financeOrderCreateRecomJob;
	}

	public void setFuturesOrderCreateRecomJob(FuturesOrderCreateRecomJob futuresOrderCreateRecomJob) {
		this.futuresOrderCreateRecomJob = futuresOrderCreateRecomJob;
	}

	public void setRecharegeBonus1DayJob(RecharegeBonus1DayJob recharegeBonus1DayJob) {
		this.recharegeBonus1DayJob = recharegeBonus1DayJob;
	}

	public void setWithdrawLimitAmountr1DayJob(WithdrawLimitAmountr1DayJob withdrawLimitAmountr1DayJob) {
		this.withdrawLimitAmountr1DayJob = withdrawLimitAmountr1DayJob;
	}

	public void setC2cStatistics1DayJob(C2cStatistics1DayJob c2cStatistics1DayJob) {
		this.c2cStatistics1DayJob = c2cStatistics1DayJob;
	}
	
}