package project.monitor.report.internal;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.springframework.jdbc.core.namedparam.NamedParameterJdbcOperations;

import kernel.util.Arith;
import kernel.util.DateUtils;
import kernel.util.StringUtils;
import kernel.web.Page;
import kernel.web.PagedQueryDao;
import project.monitor.report.AdminAutoMonitorDAppStatisticsService;

public class AdminAutoMonitorDAppStatisticsServiceImpl implements AdminAutoMonitorDAppStatisticsService{

	private PagedQueryDao pagedQueryDao;
	
	private NamedParameterJdbcOperations namedParameterJdbcTemplate;
	
	public Page pagedQuery(int pageNo, int pageSize,String startTime,String endTime) {
		Map<String,Object> parameters = new HashMap<String,Object>();
		StringBuffer queryString = new StringBuffer("SELECT ");
		queryString.append("DATE_FORMAT(ud.CREATE_TIME,\"%Y-%m-%d\") AS date, ");//日期
		queryString.append("IFNULL(SUM(ud.NEW_USER),0) AS new_user,IFNULL(SUM(ud.APPROVE_USER),0) AS approve_user,IFNULL(SUM(ud.USDT_USER),0) AS usdt_user,IFNULL(SUM(ud.TRANSFER_FROM),0) AS transfer_from,IFNULL(SUM(ud.SETTLE_AMOUNT),0) AS settle_amount ");
		queryString.append("FROM T_AUTO_MONITOR_USER_DATA_SUM ud ");
		
		queryString.append("WHERE 1=1 ");
		if (!StringUtils.isNullOrEmpty(startTime)) {
			queryString.append("AND DATE(ud.CREATE_TIME) >= DATE(:startTime)  ");
			parameters.put("startTime",DateUtils.toDate(startTime));
		}
		if (!StringUtils.isNullOrEmpty(endTime)) {
			queryString.append("AND DATE(ud.CREATE_TIME) <= DATE(:endTime)  ");
			parameters.put("endTime", DateUtils.toDate(endTime));
		}
		queryString.append("GROUP BY DATE(ud.CREATE_TIME) ");
		queryString.append("ORDER BY DATE(ud.CREATE_TIME) DESC ");
		Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
		return page;
	}
	
	public Map<String,Object> daySumData(String day){
		Map<String,Object> parameters = new HashMap<String,Object>();
		StringBuffer queryString = new StringBuffer("SELECT ");
//		queryString.append("DATE_FORMAT(ud.CREATE_TIME,\"%Y-%m-%d\") AS date, ");//日期
		queryString.append("IFNULL(SUM(ud.NEW_USER),0) AS new_user,IFNULL(SUM(ud.APPROVE_USER),0) AS approve_user,IFNULL(SUM(ud.USDT_USER),0) AS usdt_user,IFNULL(SUM(ud.USDT_USER_COUNT),0) AS usdt_user_count,IFNULL(SUM(ud.TRANSFER_FROM),0) AS transfer_from ");
		queryString.append("FROM T_AUTO_MONITOR_USER_DATA_SUM ud ");
		queryString.append("WHERE 1=1 ");
//		if (!StringUtils.isNullOrEmpty(loginPartyId)) {
//			List children = this.userRecomService.findChildren(loginPartyId);
//			if (children.size() == 0) {
//				return new HashMap<String,Object>();
//			}
//			queryString.append(" and ud.PARTY_ID in (:children) ");
//			parameters.put("children", children);
//		}
		if (!StringUtils.isNullOrEmpty(day)) {
			queryString.append("AND DATE(ud.CREATE_TIME) = DATE(:day)  ");
			parameters.put("day", DateUtils.toDate(day));
		}
		List<Map<String, Object>> queryForList = this.namedParameterJdbcTemplate.queryForList( queryString.toString(), parameters);
		return queryForList.get(0);
	}
	
	public Map<String,Object> sumDatas(String startTime,String endTime){
		Map<String,Object> parameters = new HashMap<String,Object>();
		StringBuffer queryString = new StringBuffer("SELECT ");
//		queryString.append("DATE_FORMAT(ud.CREATE_TIME,\"%Y-%m-%d\") AS date, ");//日期
		queryString.append("IFNULL(SUM(ud.NEW_USER),0) AS new_user,IFNULL(SUM(ud.APPROVE_USER),0) AS approve_user,IFNULL(SUM(ud.USDT_USER),0) AS usdt_user,IFNULL(SUM(ud.TRANSFER_FROM),0) AS transfer_from,IFNULL(SUM(ud.SETTLE_AMOUNT),0) AS settle_amount ");
		queryString.append("FROM T_AUTO_MONITOR_USER_DATA_SUM ud ");
		queryString.append("WHERE 1=1 ");
//		if (!StringUtils.isNullOrEmpty(loginPartyId)) {
//			List children = this.userRecomService.findChildren(loginPartyId);
//			if (children.size() == 0) {
//				return new HashMap<String, Object>();
//			}
//			queryString.append(" and ud.PARTY_ID in (:children) ");
//			parameters.put("children", children);
//		}
		if (!StringUtils.isNullOrEmpty(startTime)) {
			queryString.append("AND DATE(ud.CREATE_TIME) >= DATE(:startTime)  ");
			parameters.put("startTime",DateUtils.toDate(startTime));
		}
		if (!StringUtils.isNullOrEmpty(endTime)) {
			queryString.append("AND DATE(ud.CREATE_TIME) <= DATE(:endTime)  ");
			parameters.put("endTime", DateUtils.toDate(endTime));
		}
//		queryString.append("GROUP BY DATE(ud.CREATE_TIME) ");
		queryString.append("ORDER BY DATE(ud.CREATE_TIME) DESC ");
		List<Map<String, Object>> queryForList = this.namedParameterJdbcTemplate.queryForList( queryString.toString(), parameters);
		return queryForList.get(0);
	}
	
	public List<Object[]> dataBachHandel(List<Map<String,Object>> list){
		List<Object[]> result = new ArrayList<Object[]>();
		int i = 0;
		for(Map<String,Object> data:list) {
			i = 0;
			Object[] objs = new Object[18];
			objs[i++] = data.get("date");
			
			
			objs[i++] = data.get("recharge_usdt");
			objs[i++] = data.get("recharge_eth");
			objs[i++] = data.get("recharge_btc");
			objs[i++] = data.get("recharge");
			objs[i++] = data.get("gift_money");
			objs[i++] = data.get("withdraw");
			objs[i++] = data.get("recharge_withdrawal_fee");//TODO
			double recharge_usdt = 0D;
			double withdraw  = 0D;
			if (null != data.get("recharge_usdt")) {
				recharge_usdt = Double.parseDouble(data.get("recharge_usdt").toString());
			}
			if (null != data.get("withdraw")) {
				withdraw = Double.parseDouble(data.get("withdraw").toString());
			}
			objs[i++] = Arith.sub(recharge_usdt, withdraw);
			objs[i++] = data.get("balance_amount");

//			objs[i++] = data.get("amount");
			objs[i++] = data.get("fee");
			objs[i++] = data.get("order_income");

//			objs[i++] = data.get("finance_amount");
			objs[i++] = data.get("finance_income");

//			objs[i++] = data.get("exchange_amount");
			objs[i++] = data.get("exchange_fee");
//			objs[i++] = data.get("exchange_income");
			objs[i++] = 0;

//			objs[i++] = data.get("furtures_amount");
			objs[i++] = data.get("furtures_fee");
			objs[i++] = data.get("furtures_income");
			
			objs[i++] = data.get("totle_income");
			
			result.add(objs);
		}
		return result;
	}
	
	public PagedQueryDao getPagedQueryDao() {
		return pagedQueryDao;
	}

	public void setPagedQueryDao(PagedQueryDao pagedQueryDao) {
		this.pagedQueryDao = pagedQueryDao;
	}

	public NamedParameterJdbcOperations getNamedParameterJdbcTemplate() {
		return namedParameterJdbcTemplate;
	}

	public void setNamedParameterJdbcTemplate(NamedParameterJdbcOperations namedParameterJdbcTemplate) {
		this.namedParameterJdbcTemplate = namedParameterJdbcTemplate;
	}
}