package project.web.admin.controller.index;

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

import javax.servlet.http.HttpServletRequest;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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.exception.BusinessException;
import kernel.util.DateUtils;
import project.Constants;
import project.party.PartyService;
import project.party.model.Party;
import project.user.UserDataService;
import project.web.admin.service.report.AdminAllStatisticsService;
import project.web.admin.service.report.AdminUserMoneyStatisticsService;
import security.web.BaseSecurityAction;
import project.web.api.HttpsTransport;
import project.web.api.JsonUtils;

/**
 * 综合查询
 */
@RestController
public class AdminIndexController extends BaseSecurityAction {

	private Logger logger = LoggerFactory.getLogger(AdminIndexController.class);

	@Autowired
	private AdminAllStatisticsService adminAllStatisticsService;
	@Autowired
	private AdminUserMoneyStatisticsService adminUserMoneyStatisticsService;
	@Autowired
	private PartyService partyService;
	@Autowired
	private UserDataService userDataService;

	private final String action = "normal/adminIndexAction!";

	/**
	 * 综合查询 页面
	 */
	@RequestMapping(value = action + "view.action")
	public ModelAndView view(HttpServletRequest request) {
		
		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("index_admin");

		Map<String, Object> statistics = new HashMap<String, Object>();		
		statistics.put("recharge", 0.0);
		statistics.put("withdraw", 0.0);
		// 充提差额
		statistics.put("balance_amount", 0.0);
		statistics.put("totle_income", 0.0);
		statistics.put("today_user_count", 0);
		statistics.put("all_user_count", 0);
		statistics.put("today_recharge_user_count", 0);
		statistics.put("sum_usdt_amount", 0.0);	
		
		try {
			
			String today = DateUtils.format(new Date(), DateUtils.DF_yyyyMMdd);
			
			String loginPartyId = this.getLoginPartyId();
			
			// 当日用户增量
			int todayUserCount = 0;
			
			// 用户总量
			int allUserCount = 0;
			
			List<Party> cacheAll = this.partyService.getAll();
			for (Party party : cacheAll) {
				if (Constants.SECURITY_ROLE_MEMBER.equals(party.getRolename())) {
					if (today.equals(DateUtils.format(party.getCreateTime(), DateUtils.DF_yyyyMMdd))) {
						todayUserCount++;
					}
					allUserCount++;
				}
			}
			
			Map<String, Object> daySumData = this.adminAllStatisticsService.daySumData(loginPartyId, today);
			
			statistics.put("recharge", daySumData.get("recharge_usdt"));
			statistics.put("withdraw", daySumData.get("withdraw"));
			// 充提差额
			statistics.put("balance_amount", daySumData.get("balance_amount"));
			statistics.put("totle_income", daySumData.get("totle_income"));
			statistics.put("today_user_count", todayUserCount);
			statistics.put("all_user_count", allUserCount);
			statistics.put("today_recharge_user_count", this.userDataService.filterRechargeByDate(today));
			statistics.put("sum_usdt_amount", this.adminUserMoneyStatisticsService.getSumWalletByMember(loginPartyId));	
			statistics.put("btc_balance_amount", this.btcBalance());	
			

		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			modelAndView.addObject("statistics", statistics);
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			modelAndView.addObject("statistics", statistics);
			return modelAndView;
		}

		modelAndView.addObject("statistics", statistics);
		return modelAndView;
	}
	
	public String btcBalance(){
		try{
			//btc | 10.钱包余额查询
			Map<String,Object> reqMap = new HashMap<String, Object>();
			reqMap.put("item_id", "4");
			System.out.println("提交字符串为："+ JsonUtils.toJson(reqMap));
			HttpsTransport httpsTransport = new HttpsTransport();
			httpsTransport.setSendEncoding("UTF-8");
			httpsTransport.setUrl("http://18.163.120.125:999/btc/wallet_balance");
			String response = (String) httpsTransport.query(reqMap);
			System.out.println("响应字符串为："+ JsonUtils.toJson(response));
			//8，返回参数转map
			Map<String,Object> responseMap = JsonUtils.jsonToMap(response);
			if(responseMap.get("status").toString().trim().equals("1")){
				Map<String,Object> balanceMap = (Map)responseMap.get("result");
				return balanceMap.get("balance").toString();
			}
		}catch (Exception e){
			e.printStackTrace();
		}
		return null;
	}

}