package com.yami.trading.service.miner.job;

import java.util.Date;
import java.util.List;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.bean.syspara.domain.Syspara;
import com.yami.trading.service.miner.service.MinerOrderProfitService;
import com.yami.trading.bean.data.domain.Realtime;
import com.yami.trading.bean.miner.MinerOrder;
import com.yami.trading.bean.model.Log;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.service.data.DataService;
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.service.system.LogService;
import lombok.extern.slf4j.Slf4j;
import net.bytebuddy.asm.Advice;
import org.apache.commons.lang3.ObjectUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

@Component
@Slf4j
public class MinerOrderProfitJob {
	private static Logger logger = LoggerFactory.getLogger(MinerOrderProfitJob.class);
	@Autowired
	protected MinerOrderProfitService minerOrderProfitService;
	@Autowired
	protected SysparaService sysparaService;
	@Autowired
	protected DataService dataService;
	@Autowired
	protected LogService sysLogService;

	public void taskJob() {

		try {
			int pageNo = 1;
			int pageSize = 300;
			minerOrderProfitService.cacheRecomProfitClear();

			String miner_bonus_parameters = sysparaService.find("miner_bonus_parameters").getSvalue();
			String miner_profit_symbol = sysparaService.find("miner_profit_symbol").getSvalue();
			List<Realtime> realtime_list = this.dataService.realtime(miner_profit_symbol);
			Realtime realtime = null;
			if (!realtime_list.isEmpty()) {
				realtime = realtime_list.get(0);
			}
			if (StringUtils.isNotEmpty(miner_profit_symbol) && realtime == null) {
				// 行情不存在，则退出计算
				return;
			}

			while (true) {
				Page page = minerOrderProfitService.pagedQueryComputeOrder(pageNo, pageSize);
				List minerOrders = page.getRecords();
				if (CollectionUtils.isEmpty(minerOrders)) {// 分页没数据时表示已经计算结束
					break;
				}
				try {
					this.minerOrderProfitService.saveComputeOrderProfit(minerOrders, miner_profit_symbol, realtime,
							miner_bonus_parameters);
				} catch (Throwable e) {
					logger.error("error:", e);
				}
				logger.info("miner profit finished ,count:" + minerOrders.size());
				pageNo++;
			}
			// 用户收益计算完，计算推荐人收益
			minerOrderProfitService.saveRecomProfit();
		} catch (Throwable e) {
			logger.error("miner profit run fail", e);
		}

	}

	public void handleData(Date systemTime) {

		try {
			int pageNo = 1;
			int pageSize = 300;
			minerOrderProfitService.cacheRecomProfitClear();

			String miner_bonus_parameters = sysparaService.find("miner_bonus_parameters").getSvalue();
			String miner_profit_symbol = sysparaService.find("miner_profit_symbol").getSvalue();
			List<Realtime> realtime_list = this.dataService.realtime(miner_profit_symbol);
			Realtime realtime = null;
			if (realtime_list.size() > 0) {
				realtime = realtime_list.get(0);
			}
			if (StringUtils.isNotEmpty(miner_profit_symbol) && realtime == null)
				return;// 行情不存在，则退出计算

			while (true) {
				Page page = minerOrderProfitService.pagedQueryComputeOrder(pageNo, pageSize);
				List minerOrders = page.getRecords();
				if (CollectionUtils.isEmpty(minerOrders)) {// 分页没数据时表示已经计算结束
					break;
				}
				try {
					this.minerOrderProfitService.saveComputeOrderProfit(minerOrders, miner_profit_symbol, realtime,
							miner_bonus_parameters,systemTime);
				} catch (Throwable e) {
					logger.error("error:", e);
				}
				logger.info("miner profit finished ,count:" + minerOrders.size());
				pageNo++;
			}
			// 用户收益计算完，计算推荐人收益
			minerOrderProfitService.saveRecomProfit(systemTime);
		} catch (Throwable e) {
			logger.error("MinerOrderProfitJob run fail e:", e);
			Log entity = new Log();
//			entity.setLevel(SysLog.level_error);
			entity.setCreateTime(new Date());
			entity.setOperator("MinerOrderProfitJob 矿机任务 执行失败  e:"+e);
			sysLogService.save(entity);
		}

	}
	public void setMinerOrderProfitService(MinerOrderProfitService minerOrderProfitService) {
		this.minerOrderProfitService = minerOrderProfitService;
	}

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

	public void setDataService(DataService dataService) {
		this.dataService = dataService;
	}

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

	// 计时器--------------------------------------------------------------------------------
//	<!-- 每天凌晨4点启动 -->
//	cron="0 0 0 * * ?"
	// @Scheduled(cron = "0 */3 * * * ?")
	@Scheduled(cron = "0 0 4 * * ?")
	public void zeroJobHandle() {
		logger.error("矿机收益凌晨4点开始下发");
		Syspara syspara = this.sysparaService.find("time_task_config");
//		System.out.println("syspara.getSvalue1() => " + syspara.getSvalue());
		if( ObjectUtils.isEmpty(syspara) || (ObjectUtils.isNotEmpty(syspara)&&"1".equals(syspara.getSvalue()))) {
			logger.error("矿机配置为1矿机收益凌晨4点开始下发");
			//矿机每日计息
			this.taskJob();
		}
	}
//	<!-- 每天0,12点启动 -->
//	cron="0 0 0,12 * * ?"
	// @Scheduled(cron = "0 0 0,12 * * ?")
	// @Scheduled(cron = "0 */2 * * * ?")
	@Scheduled(cron = "0 0 0,12 * * ?")
	public void zeroOrtwelveJobHandle() {
		logger.error("矿机收益凌晨零点和12点开始下发");
		Syspara syspara = this.sysparaService.find("time_task_config");
//		System.out.println("syspara.getSvalue2() => " + syspara.getSvalue());
		if(ObjectUtils.isNotEmpty(syspara)&&"2".equals(syspara.getSvalue())) {
			logger.error("矿机配置为2矿机收益凌晨和12点开始下发");
			// 矿机每日计息
			this.taskJob();
		}
	}


	public void taskJob1() {
		/**
		 * 凌晨4点主定时任务
		 */
		try {
			// DBBackupLock.add(DBBackupLock.ALL_DB_LOCK);
			
			// activityOrderTaskJobHandle.taskJob();
			
			// 理财每日计息
			// financeOrder1DayJob.taskJob();
			logger.error("矿机收益凌晨4点开始下发");
			Syspara syspara = this.sysparaService.find("time_task_config");
			if(ObjectUtils.isEmpty(syspara)) {
				logger.error("当前配置为空矿机收益默认凌晨4点下");
				// 矿机每日计息
				this.taskJob();
			}else {
				if("0".equals(syspara.getSvalue())) {
					logger.error("当前配置为0矿机收益凌晨4点下");
					// 矿机每日计息
					this.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);
		}
	}
	

}