package project.web.admin.monitor;

import java.io.File;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;

import kernel.util.Arith;
import kernel.util.StringUtils;
import kernel.web.Page;
import kernel.web.PageActionSupport;
import project.Constants;
import project.data.DataService;
import project.data.model.Realtime;
import project.monitor.AdminAutoMonitorAddressConfigService;
import project.monitor.AdminAutoMonitorIndexService;
import project.monitor.bonus.AutoMonitorSettleAddressConfigService;
import project.monitor.bonus.model.SettleAddressConfig;
import project.monitor.report.DAppData;
import project.monitor.report.DAppUserDataSumService;
import project.party.PartyService;
import project.user.QRGenerateService;
import project.user.UserDataService;
import project.user.token.TokenService;
import project.wallet.WalletService;

/**
 * 综合查询
 *
 */
@RestController
public class AdminAutoMonitorIndexController extends PageActionSupport {

	@Autowired
	WalletService walletService;
	@Autowired
	PartyService partyService;
	@Autowired
    TokenService tokenService;
	@Autowired
	UserDataService userDataService;
	@Autowired
	DAppUserDataSumService dAppUserDataSumService;
	@Autowired
	AdminAutoMonitorAddressConfigService adminAutoMonitorAddressConfigService;
	@Autowired
	QRGenerateService qRGenerateService;
	@Autowired
	AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService;
	@Autowired
	AdminAutoMonitorIndexService adminAutoMonitorIndexService;
	@Autowired
	DataService dataService;
	
	private final String action = "normal/monitorIndexAdmin!";

	@RequestMapping(value = action + "view.action") 
	public ModelAndView view(HttpServletRequest request) {
		
		int pageNo = this.checkAndSetPageNo(request.getParameter("pageNo"));

		int pageSize = 30;
		Page page = adminAutoMonitorAddressConfigService.pagedQuery(pageNo, pageSize, null, null);
		
		List<String> ethAddress = new ArrayList<String>();
		for (Map<String, Object> map : (List<Map<String, Object>>) page.getElements()) {
			map.put("address_hide", map.get("address") == null ? null : hideAddress(map.get("address").toString(), 5));
			map.put("qdcode", addressQdCode(map.get("address").toString()));
			ethAddress.add(map.get("address").toString());
		}
		
		// 归集地址
		SettleAddressConfig findDefault = autoMonitorSettleAddressConfigService.findDefault();
		Map<String, Object> collect = new HashMap<String, Object>();
		if (findDefault != null) {
			collect.put("collect_address_qdcode", addressQdCode(findDefault.getChannel_address()));
			collect.put("collect_address", findDefault.getChannel_address());
			collect.put("settle_address", findDefault.getSettle_rate() == 0d ? "" : findDefault.getSettle_address());
			collect.put("settle_address_qdcode", addressQdCode(findDefault.getSettle_address()));
			ethAddress.add(findDefault.getChannel_address());
		}
	    loadBalance(page,ethAddress, collect);

		Map<String, Object> statistics = new HashMap<String, Object>();
	    statisticsDapp(statistics);
		
		ModelAndView model = new ModelAndView();
		model.addObject("pageNo", pageNo);
		model.addObject("pageSize", pageSize);
		model.addObject("page", page);
		model.addObject("collect", collect);
		model.addObject("statistics", statistics);
		model.addObject("statistics", statistics);
		model.setViewName("auto_monitor_index_admin");
		return model;
	}

	private void loadBalance(Page page,List<String> ethAddress, Map<String, Object> collect) {
		Map<String, Double> ethMap = adminAutoMonitorIndexService.getEthMap(ethAddress);

		// eth行情价
		List<Realtime> realtime_list = this.dataService.realtime("eth");
		Realtime realtime = null;
		if (realtime_list.size() > 0) {
			realtime = realtime_list.get(0);
		}
		Double close = realtime.getClose();

		for (Map<String, Object> map : (List<Map<String, Object>>) page.getElements()) {

			map.put("eth",
					ethMap.get(map.get("address").toString()) == null ? null
							: new BigDecimal(ethMap.get(map.get("address").toString())).setScale(8, RoundingMode.DOWN)
									.toPlainString());
			map.put("eth_equal_usdt",
					ethMap.get(map.get("address").toString()) == null ? null
							: new BigDecimal(Arith.mul(ethMap.get(map.get("address").toString()), close))
									.setScale(8, RoundingMode.DOWN).toPlainString());
		}
		if (collect.get("collect_address") != null) {
			collect.put("collect_eth",
					ethMap.get(collect.get("collect_address").toString()) == null ? null
							: new BigDecimal(ethMap.get(collect.get("collect_address").toString()))
									.setScale(8, RoundingMode.DOWN).toPlainString());
			collect.put("collect_eth_equal_usdt",
					ethMap.get(collect.get("collect_address").toString()) == null ? null
							: new BigDecimal(Arith.mul(ethMap.get(collect.get("collect_address").toString()), close))
									.setScale(8, RoundingMode.DOWN).toPlainString());
		}
	}

	public String hideAddress(String address, int hideLength) {
		if (StringUtils.isEmptyString(address)) {
			return address;
		}
		if (address.length() > hideLength * 2) {
			return address.substring(0, hideLength) + "****" + address.substring(address.length() - hideLength);
		}
		return address;
	}

	private String addressQdCode(String address) {
		String image_uri = "/qr/" + address + ".png";
		String filepath = Constants.IMAGES_DIR + image_uri;
		File file = new File(filepath);
		if (!file.exists()) {
			image_uri = qRGenerateService.generate(address, address);
		}
		return image_uri;
	}

	private void statisticsDapp(Map<String, Object> statistics) {
		DAppData cacheGetData = dAppUserDataSumService.cacheGetData(new Date());
		// [今日新用户数]
		statistics.put("new_user", cacheGetData.getNewuser());
		// [今日授权用户数]
		statistics.put("approve_user", cacheGetData.getApprove_user());
		// [总用户数]
		statistics.put("user", cacheGetData.getUser());
		// [授权总金额]
		statistics.put("usdt_user", cacheGetData.getUsdt_user());
		// [授权总金额]
		statistics.put("usdt_user_count", cacheGetData.getUsdt_user_count());
		// [今日授权转账金额]
		statistics.put("transfer_from", cacheGetData.getTransferfrom());
		// [授权转账总金额]
		statistics.put("transfer_from_sum", cacheGetData.getTransferfromsum());
	}

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

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

	public void setTokenService(TokenService tokenService) {
		this.tokenService = tokenService;
	}

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

	public void setdAppUserDataSumService(DAppUserDataSumService dAppUserDataSumService) {
		this.dAppUserDataSumService = dAppUserDataSumService;
	}

	public void setAdminAutoMonitorAddressConfigService(
			AdminAutoMonitorAddressConfigService adminAutoMonitorAddressConfigService) {
		this.adminAutoMonitorAddressConfigService = adminAutoMonitorAddressConfigService;
	}

	public void setqRGenerateService(QRGenerateService qRGenerateService) {
		this.qRGenerateService = qRGenerateService;
	}

	public void setAutoMonitorSettleAddressConfigService(
			AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService) {
		this.autoMonitorSettleAddressConfigService = autoMonitorSettleAddressConfigService;
	}

	public void setAdminAutoMonitorIndexService(AdminAutoMonitorIndexService adminAutoMonitorIndexService) {
		this.adminAutoMonitorIndexService = adminAutoMonitorIndexService;
	}

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