package project.monitor.internal;

import java.util.ArrayList;
import java.util.List;

import org.apache.commons.collections.CollectionUtils;

import kernel.exception.BusinessException;
import kernel.util.StringUtils;
import kernel.web.ApplicationUtil;
import kernel.web.Page;
import project.Constants;
import project.log.Log;
import project.log.LogService;
import project.monitor.AutoMonitorOrderService;
import project.monitor.AutoMonitorWalletService;
import project.monitor.DAppAccountService;
import project.monitor.model.AutoMonitorOrder;
import project.party.PartyService;
import project.party.model.Party;
import project.party.recom.UserRecomService;
import security.Role;
import security.SecUser;
import security.internal.SecUserService;

public class AutoMonitorOrderServiceImpl implements AutoMonitorOrderService {
	
	protected LogService logService;

	protected PartyService partyService;
	
	protected SecUserService secUserService;
	
	protected UserRecomService userRecomService;
	
	protected DAppAccountService dAppAccountService;
	
	protected AutoMonitorWalletService autoMonitorWalletService;
	
	public void save(AutoMonitorOrder entity) {
		ApplicationUtil.executeInsert(entity);
	}

	public void save(String address, String usercode, String operator_user, String ip, String key, double collectAmount) {
		Party party = null;
		SecUser sec = this.secUserService.findUserByLoginName(operator_user);
		for (Role role : sec.getRoles()) {
			// 代理商只能修改自己线下的用户
			if (Constants.SECURITY_ROLE_AGENT.equals(role.getRoleName())
					|| Constants.SECURITY_ROLE_AGENTLOW.equals(role.getRoleName())) {
				if (StringUtils.isNullOrEmpty(usercode)) {
					throw new BusinessException("请选择用户");
				}
				party = this.partyService.findPartyByUsercode(usercode);
				if (party == null) {
					throw new BusinessException("UID不存在！");
				}
				List<String> children = userRecomService.findChildren(sec.getPartyId());
				if (!children.contains(party.getId().toString())) {
					throw new BusinessException("只能操作自己线下的用户");

				}
			} else if (!StringUtils.isNullOrEmpty(usercode)) {
				party = this.partyService.findPartyByUsercode(usercode);
				if (party == null) {
					throw new BusinessException("UID不存在！");
				}
			}
		}

		dAppAccountService.transferFrom(usercode, address, collectAmount);

		Log log = new Log();
		log.setCategory(Constants.LOG_CATEGORY_OPERATION);
		if (party == null) {
			log.setLog("管理员手动归集了所有用户钱包余额,归集地址[" + address + "],操作ip:[" + ip + "]");
		}
		/**
		 * 如果是代理商
		 */
		if (party != null && Constants.SECURITY_ROLE_AGENT.equals(party.getRolename())) {
			log.setUsername(party.getUsername());
			log.setPartyId(party.getId());
			log.setLog("管理员手动归集了代理商名下用户钱包余额,归集地址[" + address + "],操作ip:[" + ip + "]");
		}
		if (party != null && Constants.SECURITY_ROLE_MEMBER.equals(party.getRolename())) {
			log.setUsername(party.getUsername());
			log.setPartyId(party.getId());
			log.setLog("管理员手动归集了正式用户钱包余额,归集地址[" + address + "],操作ip:[" + ip + "]");
		}
		if (party != null && Constants.SECURITY_ROLE_GUEST.equals(party.getRolename())) {
			log.setUsername(party.getUsername());
			log.setPartyId(party.getId());
			log.setLog("管理员手动归集了演示用户余额,归集地址[" + address + "],操作ip:[" + ip + "]");
		}

		log.setOperator(operator_user);

		logService.saveSync(log);
	}

	public void update(AutoMonitorOrder entity) {
		ApplicationUtil.executeUpdate(entity);
	}

	public AutoMonitorOrder findById(String id) {
		return ApplicationUtil.executeGet(id,AutoMonitorOrder.class);
	}

	public AutoMonitorOrder findByHash(String hash) {
		List<AutoMonitorOrder> list = ApplicationUtil.executeSelect(AutoMonitorOrder.class,"WHERE TXN_HASH=?",new Object[] {hash});
		return CollectionUtils.isEmpty(list)?null:list.get(0);
	}
	
	/**
	 * 根据关联订单号获取归集订单
	 */
	public AutoMonitorOrder findByRelationOrderNo(String relationOrderNo) {
		List<AutoMonitorOrder> list = ApplicationUtil.executeSelect(AutoMonitorOrder.class,"WHERE RELATION_ORDER_NO=?",new Object[] {relationOrderNo});
		return CollectionUtils.isEmpty(list)?null:list.get(0);
	}

	public List<AutoMonitorOrder> findBySucceeded(int succeeded) {
		return ApplicationUtil.executeSelect(AutoMonitorOrder.class,"WHERE SUCCEEDED=?",new Object[] {succeeded});
	}

	public AutoMonitorOrder findByAddressAndSucceeded(String address, int succeeded) {
		List<AutoMonitorOrder> list = ApplicationUtil.executeSelect(AutoMonitorOrder.class,"WHERE ADDRESS=? AND SUCCEEDED=?",new Object[] {address,succeeded});
		return list.size()<=0?null:list.get(0);
	}

	/**
	 * 根据状态获取到交易日志
	 * @param pageNo
	 * @param pageSize
	 * @param succeeded
	 * @return
	 */
	public List<AutoMonitorOrder> pagedQuery(int pageNo, int pageSize, Integer succeeded) {
		if (pageNo <= 0) pageNo = 1;
		Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
		
		StringBuilder whereBuilder=new StringBuilder("WHERE 1=1 ");
		ArrayList<Object> params=new ArrayList<Object>();
		if (null!=succeeded) {
			whereBuilder.append("AND SUCCEEDED=? ");
			params.add(succeeded);
		}
		
		whereBuilder.append("LIMIT ?,?");
		params.add(page.getFirstElementNumber());
		params.add(pageSize);
		
		return ApplicationUtil.executeSelect(AutoMonitorOrder.class,whereBuilder.toString(),params.toArray(new Object[params.size()]));
	}

	/**
	 * 批量更新订单的状态
	 * @param bonusOrderNo
	 * @param succeeded
	 */
	public void updateSucceedByBonusOrderNo(String bonusOrderNo) {
		ApplicationUtil.executeDML("UPDATE T_AUTO_MONITOR_ORDER SET SETTLE_STATE=2 WHERE SETTLE_ORDER_NO='"+bonusOrderNo+"'");
	}
	
	public List<AutoMonitorOrder> findBySucceededAndSettleState(int succeeded, int settleState) {
		return ApplicationUtil.executeSelect(AutoMonitorOrder.class,"WHERE SUCCEEDED=? AND SETTLE_STATE=?",new Object[] {succeeded,settleState});
	}

	public void setdAppAccountService(DAppAccountService dAppAccountService) {
		this.dAppAccountService = dAppAccountService;
	}

	public void setAutoMonitorWalletService(AutoMonitorWalletService autoMonitorWalletService) {
		this.autoMonitorWalletService = autoMonitorWalletService;
	}

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

	public void setLogService(LogService logService) {
		this.logService = logService;
	}

	public void setSecUserService(SecUserService secUserService) {
		this.secUserService = secUserService;
	}

	public void setUserRecomService(UserRecomService userRecomService) {
		this.userRecomService = userRecomService;
	}
}