package project.web.admin.monitor;

import java.math.BigDecimal;
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.security.providers.encoding.PasswordEncoder;
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.StringUtils;
import kernel.util.ThreadUtils;
import kernel.web.Page;
import kernel.web.PageActionSupport;
import project.Constants;
import project.monitor.AdminAutoMonitorOrderService;
import project.monitor.AutoMonitorOrderService;
import project.monitor.AutoMonitorTransferAddressConfigService;
import project.monitor.bonus.AutoMonitorSettleAddressConfigService;
import project.monitor.bonus.model.SettleAddressConfig;
import project.monitor.model.AutoMonitorTransferAddressConfig;
import project.user.googleauth.GoogleAuthService;
import security.SecUser;
import security.internal.SecUserService;

/**
 * 归集记录
 *
 */
@RestController
public class AdminAutoMonitorOrderController extends PageActionSupport {

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

	@Autowired
	private AdminAutoMonitorOrderService adminAutoMonitorOrderService;
	@Autowired
	private AutoMonitorOrderService autoMonitorOrderService;
	@Autowired
	protected PasswordEncoder passwordEncoder;
	@Autowired
	protected GoogleAuthService googleAuthService;
	@Autowired
	protected SecUserService secUserService;
	@Autowired
	private AutoMonitorTransferAddressConfigService autoMonitorTransferAddressConfigService;
	@Autowired
	private AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService;
	
	private Map<String, Object> session = new HashMap();
	private final static Object obj = new Object();

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

	@RequestMapping(value = action + "list.action")
	public ModelAndView list(HttpServletRequest request) {
		
		int pageNo = this.checkAndSetPageNo(request.getParameter("pageNo"));
		int pageSize = 20;
		String loginPartyId = getLoginPartyId();
		
		String usename_para = request.getParameter("usename_para");
		String succeeded_para = request.getParameter("succeeded_para");
		// 订单号
		String order_para = request.getParameter("order_para");
		String start_time = request.getParameter("start_time");
		String end_time = request.getParameter("end_time");
		// 清算订单号
		String settle_order_no_para = request.getParameter("settle_order_no_para");
		// 清算状态
		String settle_state_para = request.getParameter("settle_state_para");
		String message = request.getParameter("message");
		
		Page page = this.adminAutoMonitorOrderService.pagedQuery(pageNo, pageSize, usename_para, succeeded_para, 
				order_para, start_time, end_time, loginPartyId, settle_order_no_para, settle_state_para);
		
		for(Map<String,Object> map : (List<Map<String,Object>>)page.getElements()) {
			map.put("monitor_address_hide", map.get("monitor_address")==null?null:hideAddress(map.get("monitor_address").toString(),4));
			map.put("channel_address_hide", map.get("channel_address")==null?null:hideAddress(map.get("channel_address").toString(),4));
			map.put("volume", new BigDecimal(map.get("volume").toString()).toPlainString());
			
			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);
			}
		}

		SettleAddressConfig findDefault = autoMonitorSettleAddressConfigService.findDefault();
		String collectAddress = "";
		if (findDefault != null) {
			collectAddress = findDefault.getChannel_address();
		}
		
		ModelAndView model = new ModelAndView();
		model.addObject("pageNo", pageNo);
		model.addObject("pageSize", pageSize);
		model.addObject("page", page);
		model.addObject("collectAddress", collectAddress);
		model.addObject("usename_para", usename_para);
		model.addObject("settle_order_no_para", settle_order_no_para);
		model.addObject("settle_state_para", settle_state_para);
		model.addObject("succeeded_para", succeeded_para);
		
		model.addObject("message", message);
		model.setViewName("auto_monitor_order_list");
		return model;
	}

	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;
	}
	
	/**
	 * 所有转账地址处理
	 * @return
	 */
	public Map<String,String> allTransferAddress(){
		List<AutoMonitorTransferAddressConfig> findAll = autoMonitorTransferAddressConfigService.findAll();
		Map<String,String> map = new HashMap<>();
		for(AutoMonitorTransferAddressConfig add:findAll) {
			map.put(add.getId().toString(), add.getAddress());
		}
		return map;
	}
	
	/**
	 * 授权归集记录-钱包余额归集
	 */
	@RequestMapping(value = action + "CollectAll.action")
	public ModelAndView CollectAll(HttpServletRequest request) {
		ModelAndView model = new ModelAndView();
		String message = "";
		String error = "";
		try {
			
            String session_token = request.getParameter("session_token");
            Object object = this.session.get("session_token");
            this.session.remove("session_token");
            if ((object == null) || (StringUtils.isNullOrEmpty(session_token))
                    || (!session_token.equals((String) object))) {
                return list(request);
            }
			
			SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
			String google_auth_code = request.getParameter("google_auth_code");
			String safeword = request.getParameter("safeword");
			googleAuthService.checkGoogleAuthCode(sec, google_auth_code);

			checkLoginSafeword(sec, this.getUsername_login(), safeword);
			
			SettleAddressConfig findDefault = autoMonitorSettleAddressConfigService.findDefault();
			if(findDefault==null) {
				throw new BusinessException("归集地址未配置");
			}
			String collectAddress = findDefault.getChannel_address();
			String usercode_collection = request.getParameter("usercode_collection");
			
			String collectAmount = request.getParameter("collect_amount");
			if (!StringUtils.isNullOrEmpty(collectAmount) && !StringUtils.isDouble(collectAmount)) {
				throw new BusinessException("请输入正确的归集金额");
			}
			
			double collect_amount = !StringUtils.isNullOrEmpty(collectAmount) ? Double.valueOf(collectAmount) : 0;
			
            synchronized (obj) {
    			autoMonitorOrderService.save(collectAddress, usercode_collection, this.getUsername_login(), this.getIp(getRequest()), "", collect_amount);
                ThreadUtils.sleep(300);
            }

			message = "操作成功";
		} catch (BusinessException e) {
			this.error = e.getMessage();
		} catch (Throwable t) {
			logger.error(" error ", t);
			error = ("[ERROR] 服务器错误");
		}
		model.addObject("error", error);
		model.addObject("message", message);
		model.setViewName("redirect:/" + action + "list.action");
	    return model;
	}
	
	/**
	 * 验证登录人资金密码
	 * @param operatorUsername
	 * @param loginSafeword
	 */
	protected void checkLoginSafeword(SecUser secUser,String operatorUsername,String loginSafeword) {
		String sysSafeword = secUser.getSafeword();
		String safeword_md5 = passwordEncoder.encodePassword(loginSafeword, operatorUsername);
		if (!safeword_md5.equals(sysSafeword)) {
			throw new BusinessException("登录人资金密码错误");
		}
	}
	
    public void setSession(Map<String, Object> session) {
        this.session = session;
    }

}