import java.io.IOException;
import java.math.BigInteger;
import java.util.*;
import java.util.logging.Level;

import geniusweb.actions.*;
import geniusweb.bidspace.AllBidsList;
import geniusweb.issuevalue.Bid;
import geniusweb.issuevalue.Value;
import geniusweb.issuevalue.ValueSet;
import geniusweb.party.Capabilities;
import geniusweb.party.DefaultParty;
import geniusweb.party.inform.ActionDone;
import geniusweb.party.inform.Finished;
import geniusweb.party.inform.Inform;
import geniusweb.party.inform.Settings;
import geniusweb.party.inform.YourTurn;
import geniusweb.profile.DefaultPartialOrdering;
import geniusweb.profile.Profile;
import geniusweb.profileconnection.ProfileConnectionFactory;
import geniusweb.profileconnection.ProfileInterface;
import geniusweb.progress.Progress;
import geniusweb.progress.ProgressRounds;
import tudelft.utilities.logging.Reporter;

public class HammingAgent extends DefaultParty {
	private Bid lastReceivedBid = null;
	private Set<String> issues;
	private int n_issues;
	private final Map<String, Value> maxBid = new HashMap<>();
	private final Map<String, Value> minBid = new HashMap<>();
	private List<Bid> SortedBid = null;
	private final Map<String, ValueSet> values = new HashMap<>();
	private PartyId me;
	private final Random random = new Random();
	protected ProfileInterface profileint;
	private Progress progress;

	public HammingAgent() {}

	public HammingAgent(Reporter reporter) {
		super(reporter);
	}

	@Override
	public void notifyChange(Inform info) {
		try {
			if (info instanceof Settings) {
				Settings settings = (Settings) info;
				this.profileint = ProfileConnectionFactory
						.create(settings.getProfile().getURI(), getReporter());
				this.me = settings.getID();
				this.progress = settings.getProgress();
				if (this.profileint.getProfile() instanceof DefaultPartialOrdering) {
					// Partial時だけ呼び出す
					this.initProfile((DefaultPartialOrdering) this.profileint.getProfile());
				}
			} else if (info instanceof ActionDone) {
				Action otheract = ((ActionDone) info).getAction();
				if (otheract instanceof Offer && otheract.getActor() != me) {
					lastReceivedBid = ((Offer) otheract).getBid();
				}
			} else if (info instanceof YourTurn) {
				myTurn();
			} else if (info instanceof Finished) {
				getReporter().log(Level.INFO, "Final outcome:" + info);
			}
		} catch (Exception e) {
			throw new RuntimeException("Failed to handle info", e);
		}
	}

	@Override
	public Capabilities getCapabilities() {
		return new Capabilities(new HashSet<>(Arrays.asList("SHAOP")));
	}

	@Override
	public String getDescription() {
		return "Without elicitation agent";
	}

	private void initProfile(DefaultPartialOrdering profile) {
		SortedBid = getSortedBids(profile);
		Bid maxBid = SortedBid.get(0);
		Bid minBid = SortedBid.get(SortedBid.size()-1);
		issues = profile.getDomain().getIssues();
		n_issues = issues.size();
		for (String i: issues) {
			this.maxBid.put(i, maxBid.getValue(i));
			this.minBid.put(i, minBid.getValue(i));
			this.values.put(i, profile.getDomain().getValues(i));
		}
	}

	private static List<Bid> getSortedBids(DefaultPartialOrdering prof) {
		List<Bid> bidslist = prof.getBids();
		// 効用値降順にソート
		bidslist.sort((b1, b2) -> prof.isPreferredOrEqual(b1, b2) ? -1 : 1);
		return bidslist;
	}

	private void myTurn() throws IOException {
		Action action = SortedBid == null ? randomBid() :
				(isAcceptable() ? new Accept(me, lastReceivedBid) : makeBid());
		if (progress instanceof ProgressRounds) {
			progress = ((ProgressRounds) progress).advance();
		}
		getConnection().send(action);
	}

	private boolean isAcceptable() {
		if (lastReceivedBid == null) return false;
		if (progress instanceof ProgressRounds) {
			ProgressRounds rounds = (ProgressRounds) progress;
			if (rounds.getCurrentRound() + 1 == rounds.getTotalRounds()) {
				return true;
			}
		}
		int max_count = 0;
		int min_count = 0;
		for (String i: issues) {
			Value value = lastReceivedBid.getValue(i);
			if (value.equals(maxBid.get(i))) {
				max_count++;
			} else if (value.equals(minBid.get(i))) {
				min_count++;
				if (min_count >= threshold()) {
					max_count--;
					min_count = 0;
				}
			}
		}
		return max_count > n_issues - threshold();
	}

	private int threshold() {
		int n;
		Double time = progress.get(System.currentTimeMillis());
		if (time <= 0.3) {
			n = 1;
		} else if (time <= 0.5) {
			n = Math.min(2, (int) Math.ceil((double)n_issues / 3));
		} else if (time <= 0.7) {
			n = Math.min(3, (int) Math.ceil((double)n_issues / 3));
		} else if (time <= 0.9) {
			n = Math.min(4, (int) Math.ceil((double)n_issues / 3));
		} else {
			n = Math.min(4, (int) Math.ceil((double)n_issues / 2));
		}
		return n;
	}

	private Offer makeBid() {
		int count = 0;
		Set<Integer> integerSet = new HashSet<>();

		for (int i = 0; i < threshold(); i++) {
			integerSet.add(random.nextInt(n_issues));
		}

		Map<String, Value> bid = new HashMap<>();
		for (String i: issues) {
			if (integerSet.contains(count)) {
				ValueSet issueValues = values.get(i);
				Value minValue = minBid.get(i);
				int nextValueNum;
				Value nextValue;
				do {
					nextValueNum = random.nextInt(issueValues.size().intValue());
					nextValue = issueValues.get(nextValueNum);
				} while (nextValue.equals(minValue));
				bid.put(i, nextValue);
			} else {
				bid.put(i, maxBid.get(i));
			}
			count++;
		}
		return new Offer(me, new Bid(bid));
	}

	private Offer randomBid() throws IOException {
		AllBidsList bidspace = new AllBidsList(profileint.getProfile().getDomain());
		long i = random.nextInt(bidspace.size().intValue());
		Bid bid = bidspace.get(BigInteger.valueOf(i));
		return new Offer(me, bid);
	}
}