package project.monitor.pledgegalaxy.internal;

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

import kernel.exception.BusinessException;
import kernel.util.Arith;
import kernel.web.ApplicationUtil;
import kernel.web.Page;
import project.Constants;
import project.log.MoneyLog;
import project.log.MoneyLogService;
import project.monitor.pledgegalaxy.PledgeGalaxyOrder;
import project.monitor.pledgegalaxy.PledgeGalaxyOrderService;
import project.monitor.pledgegalaxy.PledgeGalaxyProfit;
import project.monitor.pledgegalaxy.PledgeGalaxyProfitService;
import project.monitor.pledgegalaxy.PledgeGalaxyStatusConstants;
import project.syspara.SysparaService;
import project.user.UserDataService;
import project.wallet.Wallet;
import project.wallet.WalletService;

/**
 * 质押2.0收益记录serviceImpl
 */
@SuppressWarnings("rawtypes")
public class PledgeGalaxyProfitServiceImpl implements PledgeGalaxyProfitService {

	protected WalletService walletService;
	
	protected SysparaService sysparaService;
	
	protected MoneyLogService moneyLogService;
	
	protected UserDataService userDataService;
	
	protected PledgeGalaxyOrderService pledgeGalaxyOrderService;
	
	/**
	 * 收益记录列表
	 */
	@Override
	public Page pagedQuery(int pageNo, int pageSize, String partyId) {
		if (pageNo <= 0) pageNo = 1;
		Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
		
		StringBuilder sqlBuilder = new StringBuilder("SELECT profit.UUID id, profit.PARTY_ID partyId, profit.TYPE type, profit.AMOUNT amount, profit.STATUS status,");
		sqlBuilder.append("DATE_FORMAT(profit.CREATE_TIME,'%Y-%m-%d %H:%i:%S') createTime FROM T_AUTO_MONITOR_PLEDGE_GALAXY_PROFIT profit ");
		sqlBuilder.append("WHERE profit.PARTY_ID=? ORDER BY profit.CREATE_TIME DESC LIMIT ?,?");
		
		List<HashMap> list=ApplicationUtil.executeDQL(sqlBuilder.toString(), new Object[] {partyId,page.getFirstElementNumber(),pageSize}, HashMap.class);
		page.setElements(list);
		return page;
	}
	
	/**
	 * 收益记录列表-当日收益
	 */
	@Override
	public List<PledgeGalaxyProfit> queryTodayProfitList(String partyId, int status) {
		return ApplicationUtil.executeSelect(PledgeGalaxyProfit.class,"WHERE PARTY_ID=? AND STATUS=? AND DATEDIFF(AUDIT_TIME,NOW())=0",new Object[] {partyId,status});
	}
	
	/**
	 * 领取
	 */
	@Override
	public void updateReceive(String id) {
		PledgeGalaxyProfit profit = get(id);
		if (PledgeGalaxyStatusConstants.PROFIT_PENDING != profit.getStatus()) {
			throw new BusinessException("领取状态不匹配");
		}
		
		profit.setStatus(PledgeGalaxyStatusConstants.PROFIT_AUTID);
		ApplicationUtil.executeUpdate(profit);
	}
	
	/**
	 * 领取收益 及时到账
	 */
	public void updateReceiveToWallet(PledgeGalaxyProfit profit) {
		String partyId = profit.getPartyId();
		double amount = profit.getAmount();
		// 保存资金日志
		MoneyLog moneylog = new MoneyLog();
		// 动静收益
		if (profit.getType() != 3) {
			moneylog.setLog("质押2.0收益，订单号[" + profit.getRelationOrderNo() + "]");
			moneylog.setContent_type(Constants.MONEYLOG_CONTENT_GALAXY_PROFIT);
			PledgeGalaxyOrder order = pledgeGalaxyOrderService.findById(profit.getRelationOrderNo());
			if (null == order) {
				throw new BusinessException("order is null");
			}
			// 记息日期
			order.setSettleTime(new Date());
			order.setProfit(Arith.add(order.getProfit(), amount));
			
			pledgeGalaxyOrderService.update(order);
		}
		// 团队收益
		else {
			moneylog.setLog("质押2.0团队收益下发");
			moneylog.setContent_type(Constants.MONEYLOG_CONTENT_GALAXY_RECOM_PROFIT);
		}
		
		// 更新收益记录
		profit.setStatus(PledgeGalaxyStatusConstants.PROFIT_PASSED);
		profit.setAuditTime(new Date());
		profit.setMsg("");
		update(profit);
		
		Wallet wallet = walletService.saveWalletByPartyId(partyId);
		double amount_before = wallet.getMoney();
		walletService.update(partyId, amount);
		
		moneylog.setCategory(Constants.MONEYLOG_CATEGORY_GALAXY);
		moneylog.setAmount_before(amount_before);
		moneylog.setAmount(amount);
		moneylog.setAmount_after(Arith.add(amount_before, amount));
		moneylog.setPartyId(partyId);
		moneylog.setWallettype(Constants.WALLET);
		moneylog.setCreateTime(new Date());
		moneyLogService.save(moneylog);
		
		String projectType = this.sysparaService.find("project_type").getValue();
		if (projectType.equals("DAPP_EXCHANGE_IOEAI") || projectType.equals("DAPP_EXCHANGE_DAPPDEFIUSDT")) {
			// 质押总业绩 静态收益
			if (profit.getType() == 1) {
				userDataService.saveUserDataForGalaxy(partyId, amount, true);
			}
		} 
		
		if (projectType.equals("DAPP_EXCHANGE_SAFEPAL5")) {
			// 收益
			userDataService.saveUserDataForGalaxy(partyId, amount, true);
		} 
		
		if (projectType.equals("DAPP_EXCHANGE")) {
			// 质押总业绩 团队收益
			if (profit.getType() == 3) {
				userDataService.saveUserDataForGalaxy(partyId, amount, true);
			}
		}
	}
	
	public PledgeGalaxyProfit get(String id) {
		return ApplicationUtil.executeGet(id,PledgeGalaxyProfit.class);
	}

	/**
	 * 根据质押状态获取订单列表
	 */
	public List<PledgeGalaxyProfit> findByStatus(int status) {
		return ApplicationUtil.executeSelect(PledgeGalaxyProfit.class,"WHERE STATUS=? AND EXPIRE_TIME<NOW()",new Object[] {status});
	}
	
	/**
	 * 根据创建日期和关联订单号获取记录列表
	 */
	public List<PledgeGalaxyProfit> findByRelationOrderNo(String relationOrderNo, Date time) {
		return ApplicationUtil.executeSelect(PledgeGalaxyProfit.class,"WHERE RELATION_ORDER_NO=? AND CREATE_TIME=?)",new Object[] {relationOrderNo,time});
	}
	
	/**
	 * 更新收益订单
	 */
	public void update(PledgeGalaxyProfit profit) {
		ApplicationUtil.executeUpdate(profit);
	}
	
	public void setWalletService(WalletService walletService) {
		this.walletService = walletService;
	}

	public void setPledgeGalaxyOrderService(PledgeGalaxyOrderService pledgeGalaxyOrderService) {
		this.pledgeGalaxyOrderService = pledgeGalaxyOrderService;
	}

	public void setMoneyLogService(MoneyLogService moneyLogService) {
		this.moneyLogService = moneyLogService;
	}

	public void setUserDataService(UserDataService userDataService) {
		this.userDataService = userDataService;
	}

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