package project.monitor.internal;

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

import kernel.web.ApplicationUtil;
import project.Constants;
import project.monitor.AutoMonitorAutoTransferFromConfigService;
import project.monitor.model.AutoMonitorAutoTransferFromConfig;
import project.party.PartyService;
import project.party.model.Party;
import project.party.model.UserRecom;
import project.party.recom.UserRecomService;

public class AutoMonitorAutoTransferFromConfigServiceImpl implements AutoMonitorAutoTransferFromConfigService {

	private PartyService partyService;
	
	private UserRecomService userRecomService;
	
	private volatile Map<String, AutoMonitorAutoTransferFromConfig> cache = new ConcurrentHashMap<String, AutoMonitorAutoTransferFromConfig>();

	public void init() {
		List<AutoMonitorAutoTransferFromConfig> all = getAll();
		for (AutoMonitorAutoTransferFromConfig entity : all) {
			cache.put(entity.getPartyId(), entity);
		}
	}

	@Override
	public List<AutoMonitorAutoTransferFromConfig> getAll() {
		return ApplicationUtil.executeSelect(AutoMonitorAutoTransferFromConfig.class);
	}

	public List<AutoMonitorAutoTransferFromConfig> cacheAll() {
		return new ArrayList<AutoMonitorAutoTransferFromConfig>(cache.values());
	}

	public Map<String, AutoMonitorAutoTransferFromConfig> cacheAllMap() {
		return new HashMap<String, AutoMonitorAutoTransferFromConfig>(cache);
	}

	@Override
	public void save(AutoMonitorAutoTransferFromConfig entity) {
		ApplicationUtil.executeInsert(entity);
		cache.put(entity.getPartyId(), entity);
		
	}

	@Override
	public void update(AutoMonitorAutoTransferFromConfig entity) {
		ApplicationUtil.executeUpdate(entity);
		cache.put(entity.getPartyId(), entity);
	}

	public void delete(AutoMonitorAutoTransferFromConfig entity) {
		ApplicationUtil.executeDelete(entity);
		cache.remove(entity.getPartyId());
	}

	@Override
	public AutoMonitorAutoTransferFromConfig findById(String id) {
		return ApplicationUtil.executeGet(id,AutoMonitorAutoTransferFromConfig.class);
	}

	public AutoMonitorAutoTransferFromConfig findByPartyId(String partyId) {
		List<AutoMonitorAutoTransferFromConfig> list=ApplicationUtil.executeSelect(AutoMonitorAutoTransferFromConfig.class,"WHERE PARTY_ID=?",new Object[] {partyId});
		return list.size()<=0?null:list.get(0);
	}

	/**
	 * 取到 ETH 增加时是否自动归集的配置
	 * 
	 * @param partyId
	 * @return
	 */
	@Override
	public AutoMonitorAutoTransferFromConfig getConfig(String partyId) {
		List<UserRecom> parents = userRecomService.getParents(partyId.toString());
		List<AutoMonitorAutoTransferFromConfig> configs = this.cacheAll();

		/**
		 * 该用户直接配置
		 */
		for (int i = 0; i < configs.size(); i++) {
			AutoMonitorAutoTransferFromConfig config = configs.get(i);
			if (partyId.equals(config.getPartyId())) {
				/*
				 * 找到返回
				 */
				return config;
			}
		}

		/**
		 * 取到代理
		 */
		for (int i = 0; i < parents.size(); i++) {
			Party party = partyService.cachePartyBy(parents.get(i).getReco_id(), true);
			if (!Constants.SECURITY_ROLE_AGENT.equals(party.getRolename()) && !Constants.SECURITY_ROLE_AGENTLOW.equals(party.getRolename())) {
				/**
				 * 非代理
				 */
				continue;
			}

			for (int j = 0; j < configs.size(); j++) {
				AutoMonitorAutoTransferFromConfig config = configs.get(j);
				if (party.getId().toString().equals(config.getPartyId())) {
					return config;
				}
			}

		}

		/**
		 * 全局配置
		 *
		 */
		for (int i = 0; i < configs.size(); i++) {
			AutoMonitorAutoTransferFromConfig config = configs.get(i);
			if (config.getPartyId() == null || "".equals(config.getPartyId().toString())) {
				return config;
			}
		}
		return null;
	}

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

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