source: src/main/java/agents/anac/y2017/agentkn/AgentKN.java

package agents.anac.y2017.agentkn;

import java.util.List;

import java.util.HashMap;
import java.util.Map;

import agents.anac.y2017.agentkn.etc.bidSearch;
import agents.anac.y2017.agentkn.etc.negotiationInfo;
import agents.anac.y2017.agentkn.etc.negotiationStrategy;
import genius.core.AgentID;
import genius.core.Bid;
import genius.core.actions.Accept;
import genius.core.actions.Action;
import genius.core.actions.EndNegotiation;
import genius.core.actions.Inform;
import genius.core.actions.Offer;
import genius.core.list.Tuple;
import genius.core.parties.AbstractNegotiationParty;
import genius.core.parties.NegotiationInfo;
import genius.core.persistent.PersistentDataType;
import genius.core.persistent.StandardInfo;
import genius.core.persistent.StandardInfoList;
import genius.core.timeline.TimeLineInfo;
import genius.core.utility.AbstractUtilitySpace;
import genius.core.utility.AdditiveUtilitySpace;

public class AgentKN extends AbstractNegotiationParty {
        private TimeLineInfo timelineInfo; // タイムライン
        private AbstractUtilitySpace utilitySpace;

        private Bid mLastReceivedBid = null;
        private int nrChosenActions = 0; // number of times chosenAction was called.
        private StandardInfoList history;
        private negotiationStrategy mStrategy;
        private negotiationInfo mNegotiationInfo;
        private bidSearch mBidSerch;

        private boolean isPrinting = false;

        private Bid mOfferedBid = null;

        @Override
        public void init(NegotiationInfo aInfo) {
                super.init(aInfo);

                if (isPrinting) {
                        System.out.println("*** AgentKN ***");
                }
                System.out.println("Discount Factor is " + getUtilitySpace().getDiscountFactor());
                System.out.println("Reservation Value is " + getUtilitySpace().getReservationValueUndiscounted());

                mNegotiationInfo = new negotiationInfo((AdditiveUtilitySpace) getUtilitySpace(), isPrinting);
                try {
                        mBidSerch = new bidSearch((AdditiveUtilitySpace) getUtilitySpace(), mNegotiationInfo, isPrinting);
                } catch (Exception e) {
                        throw new RuntimeException("init failed: " + e);
                }

                // need standard data 過去情報取得
                if (getData().getPersistentDataType() != PersistentDataType.STANDARD) {
                        throw new IllegalStateException("need standard persistent data");
                }
                history = (StandardInfoList) getData().get();

                if (!history.isEmpty()) {
                        // example of using the history. Compute for each party the maximum
                        // utility of the bids in last session.
                        Map<String, Double> maxutils = new HashMap<String, Double>();
                        StandardInfo lastinfo = history.get(history.size() - 1);
                        for (Tuple<String, Double> offered : lastinfo.getUtilities()) {
                                String party = offered.get1();
                                Double util = offered.get2();
                                maxutils.put(party, maxutils.containsKey(party) ? Math.max(maxutils.get(party), util) : util);
                        }
                }

                mStrategy = new negotiationStrategy((AdditiveUtilitySpace) getUtilitySpace(), mNegotiationInfo,
                                isPrinting);
        }

        @Override
        public Action chooseAction(List<Class<? extends Action>> validActions) {
                double time = getTimeLine().getTime();
                return (Action) (validActions.contains(Accept.class) && mStrategy.selectAccept(this.mOfferedBid, time)
                                ? new Accept(this.getPartyId(), this.mOfferedBid)
                                : (mStrategy.selectEndNegotiation(time) ? new EndNegotiation(this.getPartyId()) : this.OfferAction()));
        }

        private Action OfferAction() {
                Bid offerBid = mBidSerch.getBid(this.generateRandomBid(), mStrategy.getThreshold(getTimeLine().getTime()));
                mNegotiationInfo.updateMyBidHistory(offerBid);
                return new Offer(this.getPartyId(), offerBid);
        }

        @Override
        public void receiveMessage(AgentID sender, Action action) {
                super.receiveMessage(sender, action);

                if (action != null) {
                        if (action instanceof Inform && ((Inform) action).getName() == "NumberOfAgents"
                                        && ((Inform) action).getValue() instanceof Integer) {
                                Integer e = (Integer) ((Inform) action).getValue();
                                mNegotiationInfo.updateOpponentsNum(e.intValue());
                                if (isPrinting) {
                                        System.out.println("NumberofNegotiator:" + mNegotiationInfo.getNegotiatorNum());
                                }
                        } else if (action instanceof Accept) {
                                if (!mNegotiationInfo.getOpponents().contains(sender)) {
                                        mNegotiationInfo.initOpponent(sender);
                                }
                        } else if (action instanceof Offer) {
                                if (!mNegotiationInfo.getOpponents().contains(sender)) {
                                        mNegotiationInfo.initOpponent(sender);
                                }

                                mOfferedBid = ((Offer) action).getBid();

                                try {
                                        mNegotiationInfo.updateInfo(sender, this.mOfferedBid);
                                        mNegotiationInfo.updateOfferedValueNum(sender, this.mOfferedBid, getTimeLine().getTime());
                                } catch (Exception e) {
                                        System.out.println("交渉情報の更新に失敗しました");
                                        e.printStackTrace();
                                }
                        } else {
                                boolean var10000 = action instanceof EndNegotiation;
                        }
                }
        }

        @Override
        public String getDescription() {
                return "ANAC2017 accept Nth offer";
        }

}