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

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.bean.constans.WalletConstants;
import com.yami.trading.bean.finance.FinanceOrder;
import com.yami.trading.bean.model.MoneyLog;
import com.yami.trading.bean.model.User;
import com.yami.trading.bean.model.UserRecom;
import com.yami.trading.bean.model.Wallet;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.util.Arith;
import com.yami.trading.common.util.DateUtils;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.service.MoneyLogService;
import com.yami.trading.service.WalletService;
import com.yami.trading.service.finance.service.FinanceOrderService;
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.service.user.UserRecomService;
import com.yami.trading.service.user.UserService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.concurrent.ConcurrentHashMap;

@Component
@Slf4j
public class FinanceOrderCreateRecomServiceImpl implements FinanceOrderCreateRecomService {
	@Autowired
	protected FinanceOrderService financeOrderService;
	@Autowired
	protected SysparaService sysparaService;
	@Autowired
	protected UserRecomService userRecomService;
	@Autowired
	protected UserService partyService;
	@Autowired
	protected WalletService walletService;
	@Autowired
	protected MoneyLogService moneyLogService;
	/**
	 * 计算推荐人收益
	 */
	protected Map<String, Double> cacheRecomProfit = new ConcurrentHashMap<String, Double>();

	/**
	 * 计算前一日购买产品的订单
	 */
	public void computeRecom() {
		String finance_buy_bonus_parameters = sysparaService.find("finance_buy_bonus_parameters").getSvalue();
		if (StringUtils.isEmptyString(finance_buy_bonus_parameters)) {
			return;
		}
		cacheRecomProfit.clear();
		int pageSize = 1000;
		int pageNo = 1;
		String date = DateUtils.getDateStr(DateUtils.addDate(new Date(), -1));
		while (true) {
			Page page = financeOrderService.pagedQueryByDate(pageNo, pageSize, date);
			List<FinanceOrder> list = (List<FinanceOrder>) page.getRecords();
			if (list.isEmpty()) {
				break;
			}
			for (FinanceOrder order : list) {
				handleCacheRecom(order, finance_buy_bonus_parameters);
			}
			pageNo++;
		}
		saveRecomProfit();
	}

	/**
	 * 购买推荐奖励
	 * 
	 * @param entity
	 */
	public void handleCacheRecom(FinanceOrder entity, String finance_buy_bonus_parameters) {
		List<UserRecom> list_parents = this.userRecomService.getParents((String)entity.getPartyId());

		if (CollectionUtils.isNotEmpty(list_parents)) {
			String[] finance_buy_bonus_array = finance_buy_bonus_parameters.split(",");
			int loop = 0;
			int loopMax = finance_buy_bonus_array.length;
			for (int i = 0; i < list_parents.size(); i++) {
				if (loop >= loopMax) {
					break;
				}
				User party_parent = this.partyService.cacheUserBy(list_parents.get(i).getRecomUserId());
				if (!Constants.SECURITY_ROLE_MEMBER.equals(party_parent.getRoleName())) {
					continue;
				}
				loop++;
				double pip_amount = Double.valueOf(finance_buy_bonus_array[loop - 1]);
				double get_money = Arith.mul(entity.getAmount(), pip_amount);

				if (cacheRecomProfit.containsKey(party_parent.getUserId())) {
					cacheRecomProfit.put(party_parent.getUserId(),
							Arith.add(cacheRecomProfit.get(party_parent.getUserId()), get_money));
				} else {
					cacheRecomProfit.put(party_parent.getUserId(), get_money);
				}
			}

		}
	}

	public void saveRecomProfit() {
		if (cacheRecomProfit.isEmpty()) {
			return;
		}
		for (Entry<String, Double> entry : cacheRecomProfit.entrySet()) {
			Wallet wallet_parent = walletService.saveWalletByPartyId(entry.getKey());
			BigDecimal amount_before_parent = wallet_parent.getMoney();
			walletService.update(wallet_parent.getUserId(), entry.getValue());
			/**
			 * 保存资金日志
			 */
			MoneyLog moneyLog = new MoneyLog();
			moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_FINANCE);
			moneyLog.setAmountBefore(amount_before_parent);
			moneyLog.setAmount(BigDecimal.valueOf(entry.getValue()));
			moneyLog.setAmountAfter(BigDecimal.valueOf(Arith.add(wallet_parent.getMoney(), BigDecimal.valueOf(entry.getValue()))));
			moneyLog.setLog("下级购买理财佣金奖励");
			moneyLog.setUserId(entry.getKey());
			moneyLog.setWalletType(Constants.WALLET);
			moneyLog.setContentType(WalletConstants.MONEYLOG_CONTENT_FINANCE_RECOM_PROFIT);
			moneyLogService.save(moneyLog);
		}
	}

	public void setFinanceOrderService(FinanceOrderService financeOrderService) {
		this.financeOrderService = financeOrderService;
	}

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

	public void setUserRecomService(UserRecomService userRecomService) {
		this.userRecomService = userRecomService;
	}

	public void setPartyService(UserService partyService) {
		this.partyService = partyService;
	}

	public void setWalletService(WalletService walletService) {
		this.walletService = walletService;
	}

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

	public void setCacheRecomProfit(Map<String, Double> cacheRecomProfit) {
		this.cacheRecomProfit = cacheRecomProfit;
	}

}