1 | package agents.anac.y2019.agentgp;
|
---|
2 |
|
---|
3 | import java.util.ArrayList;
|
---|
4 | import java.util.List;
|
---|
5 | import java.util.Random;
|
---|
6 |
|
---|
7 | import agents.anac.y2019.agentgp.etc.BidSearch;
|
---|
8 | import agents.anac.y2019.agentgp.etc.NegotiationInfo;
|
---|
9 | import genius.core.AgentID;
|
---|
10 | import genius.core.Bid;
|
---|
11 | import genius.core.Domain;
|
---|
12 | import genius.core.actions.Accept;
|
---|
13 | import genius.core.actions.Inform;
|
---|
14 | import genius.core.actions.Action;
|
---|
15 | import genius.core.actions.EndNegotiation;
|
---|
16 | import genius.core.actions.Offer;
|
---|
17 | import genius.core.parties.AbstractNegotiationParty;
|
---|
18 | import genius.core.persistent.PersistentDataType;
|
---|
19 | import genius.core.persistent.StandardInfoList;
|
---|
20 | import genius.core.persistent.StandardInfo;
|
---|
21 | import genius.core.timeline.TimeLineInfo;
|
---|
22 | import genius.core.uncertainty.BidRanking;
|
---|
23 | import genius.core.utility.AbstractUtilitySpace;
|
---|
24 | import genius.core.utility.CustomUtilitySpace;
|
---|
25 | import agents.anac.y2019.agentgp.etc.NegotiationStrategy;
|
---|
26 |
|
---|
27 | /**
|
---|
28 | * This is your negotiation party.
|
---|
29 | */
|
---|
30 | public class AgentGP extends AbstractNegotiationParty {
|
---|
31 |
|
---|
32 | private TimeLineInfo timelineInfo; // タイムライン
|
---|
33 | private AbstractUtilitySpace utilitySpace;
|
---|
34 |
|
---|
35 | private Bid lastReceivedBid = null;
|
---|
36 | private StandardInfoList history; //過去の交渉情報
|
---|
37 |
|
---|
38 | private NegotiationInfo negotiationInfo; // 交渉情報
|
---|
39 | private BidSearch bidSearch; // 合意案候補の探索
|
---|
40 | private NegotiationStrategy negotiationStrategy; // 交渉戦略
|
---|
41 |
|
---|
42 | private Bid offeredBid = null; // 最近提案された合意案候補
|
---|
43 | private int supporter_num = 0; // 支持者数
|
---|
44 | private int CList_index = 0; // CListのインデックス:最終提案フェーズにおける遡行を行うために利用(ConcessionList)
|
---|
45 | private boolean isPrinting = false; // デバッグ用
|
---|
46 |
|
---|
47 | @Override
|
---|
48 | //public void init(AbstractUtilitySpace utilSpace, Deadline dl, negotiator.timeline.TimeLineInfo tl, long randomSeed,
|
---|
49 | // AgentID agentId, PersistentDataContainer storage) {
|
---|
50 | // super.init(utilSpace, dl, tl, randomSeed, agentId, storage);
|
---|
51 | public void init(genius.core.parties.NegotiationInfo info) {
|
---|
52 | super.init(info);
|
---|
53 |
|
---|
54 | this.timelineInfo = info.getTimeline();
|
---|
55 | this.utilitySpace = info.getUtilitySpace();
|
---|
56 |
|
---|
57 | negotiationInfo = new NegotiationInfo(utilitySpace, isPrinting);
|
---|
58 | negotiationStrategy = new NegotiationStrategy(utilitySpace, isPrinting);
|
---|
59 | try { bidSearch = new BidSearch(utilitySpace, negotiationInfo, isPrinting);
|
---|
60 | } catch (Exception e) {
|
---|
61 | // TODO Auto-generated catch block
|
---|
62 | e.printStackTrace();
|
---|
63 | }
|
---|
64 |
|
---|
65 | if (getData().getPersistentDataType() == PersistentDataType.STANDARD) {
|
---|
66 | history = (StandardInfoList) getData().get();
|
---|
67 | if(history.size() > 0){
|
---|
68 | for(StandardInfo standardInfo: history){
|
---|
69 | if(standardInfo.getAgreement().get2()>0.1){
|
---|
70 | try { negotiationInfo.updatePBList(standardInfo.getAgreement().get1());
|
---|
71 | } catch (Exception e) {
|
---|
72 | e.printStackTrace();
|
---|
73 | }
|
---|
74 | }
|
---|
75 | }
|
---|
76 | }
|
---|
77 | //throw new IllegalStateException("need standard persistent data");
|
---|
78 | }
|
---|
79 | }
|
---|
80 |
|
---|
81 | /**
|
---|
82 | * Each round this method gets called and ask you to accept or offer. The
|
---|
83 | * first party in the first round is a bit different, it can only propose an
|
---|
84 | * offer.
|
---|
85 | *
|
---|
86 | * @param validActions
|
---|
87 | * Either a list containing both accept and offer or only offer.
|
---|
88 | * @return The chosen action.
|
---|
89 | */
|
---|
90 | static int turn_num;
|
---|
91 | @Override
|
---|
92 | public Action chooseAction(List<Class<? extends Action>> validActions) {
|
---|
93 | //NegotiationInfo.saveFrequency();
|
---|
94 | //NegotiationInfo.saveSort();
|
---|
95 |
|
---|
96 | double time = timelineInfo.getTime(); // 現在の時刻
|
---|
97 | //if(turn_num++ % 3 == 0)
|
---|
98 | //System.out.println(turn_num+":"+NegotiationStrategy.getThreshold(time));
|
---|
99 | negotiationInfo.updateTimeScale(time); // 自身の手番が回ってくる時間間隔を記録
|
---|
100 |
|
---|
101 | // 最終提案フェーズにおけるアクション
|
---|
102 | ArrayList<Bid> CList = negotiationInfo.getPBList();
|
---|
103 | if(time > 1.0 - negotiationInfo.getTimeScale() * (CList.size() + 1)){
|
---|
104 | //System.out.println("FinalAction!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
|
---|
105 | try { return chooseFinalAction(offeredBid, CList); }
|
---|
106 | catch (Exception e) {
|
---|
107 | System.out.println("最終提案フェーズにおけるActionの選択に失敗しました");
|
---|
108 | e.printStackTrace();
|
---|
109 | }
|
---|
110 | }
|
---|
111 |
|
---|
112 | // Acceptの判定
|
---|
113 | if(validActions.contains(Accept.class) && negotiationStrategy.selectAccept(offeredBid, time)){
|
---|
114 | return new Accept(getPartyId(), lastReceivedBid);
|
---|
115 | }
|
---|
116 | // EndNegotiationの判定
|
---|
117 | if(negotiationStrategy.selectEndNegotiation(time)){
|
---|
118 | return new EndNegotiation(getPartyId());
|
---|
119 | }
|
---|
120 | // 他のプレイヤーに新たなBidをOffer
|
---|
121 | return OfferAction();
|
---|
122 |
|
---|
123 | }
|
---|
124 | public Action OfferAction() {
|
---|
125 | Bid offerBid = bidSearch.getBid(utilitySpace.getDomain().getRandomBid(new Random()), negotiationStrategy.getThreshold(timelineInfo.getTime()), timelineInfo.getTime());
|
---|
126 | return OfferBidAction(offerBid);
|
---|
127 | }
|
---|
128 |
|
---|
129 | public Action OfferBidAction(Bid offerBid) {
|
---|
130 | //System.out.println("call CA:"+utilitySpace.getUtility(offerBid));
|
---|
131 | negotiationInfo.updateMyBidHistory(offerBid);
|
---|
132 | return new Offer(getPartyId(), offerBid);
|
---|
133 | }
|
---|
134 |
|
---|
135 | public Action chooseFinalAction(Bid offeredBid, ArrayList<Bid> CList) throws Exception {
|
---|
136 | double offeredBid_util = 0;
|
---|
137 | double rv = utilitySpace.getReservationValue();
|
---|
138 |
|
---|
139 | if(offeredBid != null){ offeredBid_util = utilitySpace.getUtility(offeredBid); }
|
---|
140 | if(CList_index >= CList.size()){
|
---|
141 | if(offeredBid_util >= rv) return new Accept(getPartyId(), lastReceivedBid); // 遡行を行っても合意が失敗する場合,Acceptする
|
---|
142 | else OfferAction();
|
---|
143 | }
|
---|
144 |
|
---|
145 | // CListの遡行
|
---|
146 | Bid CBid = CList.get(CList_index);
|
---|
147 | double CBid_util = utilitySpace.getUtility(CBid);
|
---|
148 | if(CBid_util > offeredBid_util && CBid_util > rv){
|
---|
149 | CList_index++;
|
---|
150 | OfferBidAction(CBid);
|
---|
151 | } else if(offeredBid_util > rv) return new Accept(getPartyId(), lastReceivedBid);
|
---|
152 |
|
---|
153 | return OfferAction();
|
---|
154 | }
|
---|
155 |
|
---|
156 |
|
---|
157 | /**
|
---|
158 | * All offers proposed by the other parties will be received as a message.
|
---|
159 | * You can use this information to your advantage, for example to predict
|
---|
160 | * their utility.
|
---|
161 | *
|
---|
162 | * @param sender
|
---|
163 | * The party that did the action. Can be null.
|
---|
164 | * @param action
|
---|
165 | * The action that party did.
|
---|
166 | */
|
---|
167 | //private int callRM = 1;
|
---|
168 | @Override
|
---|
169 | public void receiveMessage(AgentID sender, Action action) {
|
---|
170 |
|
---|
171 | //if(action instanceof Inform)
|
---|
172 | // System.out.println("Inf RM:"+callRM+++","+sender);
|
---|
173 | //if(action instanceof Accept)
|
---|
174 | // System.out.println("Acc RM:"+callRM+++","+sender);
|
---|
175 | //if(action instanceof Offer)
|
---|
176 | // //System.out.println("Off RM:"+callRM+++","+sender+":"+utilitySpace.getUtility(((Offer) action).getBid()));
|
---|
177 | // System.out.println("Off RM:"+callRM+++","+sender+":"+((Offer) action).getBid());
|
---|
178 | //if(action instanceof EndNegotiation){
|
---|
179 | // System.out.println("End RM:"+callRM+++","+sender);
|
---|
180 | //}
|
---|
181 | super.receiveMessage(sender, action);
|
---|
182 | if (action instanceof Offer) {
|
---|
183 | lastReceivedBid = ((Offer) action).getBid();
|
---|
184 | }
|
---|
185 | //if(isPrinting){ System.out.println("Sender:"+sender+", Action:"+action); }
|
---|
186 |
|
---|
187 | if (action != null) {
|
---|
188 | if(action instanceof Inform && ((Inform) action).getName() == "NumberOfAgents" && ((Inform) action).getValue() instanceof Integer) {
|
---|
189 | Integer opponentsNum = (Integer) ((Inform) action).getValue();
|
---|
190 | negotiationInfo.updateOpponentsNum(opponentsNum);
|
---|
191 | //if(isPrinting){ System.out.println("NumberofNegotiator:" + NegotiationInfo.getNegotiatorNum());}
|
---|
192 | } else if(action instanceof Accept){
|
---|
193 | if(!negotiationInfo.getOpponents().contains(sender)){ negotiationInfo.initOpponent(sender); } // 初出の交渉者は初期化
|
---|
194 | supporter_num++;
|
---|
195 | negotiationInfo.updateAcceptNum(sender);
|
---|
196 | } else if(action instanceof Offer) {
|
---|
197 | if(!negotiationInfo.getOpponents().contains(sender)){ negotiationInfo.initOpponent(sender); } // 初出の交渉者は初期化
|
---|
198 | supporter_num = 1; // supporterをリセット
|
---|
199 | offeredBid = ((Offer) action).getBid(); // 提案された合意案候補
|
---|
200 | negotiationStrategy.addBid(timelineInfo.getTime(), utilitySpace.getUtility(offeredBid));
|
---|
201 | try { negotiationInfo.updateInfo(sender, offeredBid); } // 交渉情報を更新
|
---|
202 | catch (Exception e) {
|
---|
203 | System.out.println("交渉情報の更新に失敗しました");
|
---|
204 | e.printStackTrace();
|
---|
205 | }
|
---|
206 | } else if(action instanceof EndNegotiation) { }
|
---|
207 |
|
---|
208 | // 自身以外が賛成している合意案候補を記録(自身以外のエージェントを1つの交渉者とみなす.そもそも自身以外のエージェントが二人以上非協力であれば,自身の選択に関わらず合意は不可能である)
|
---|
209 | if(supporter_num == negotiationInfo.getNegotiatorNum()-1){
|
---|
210 | if(offeredBid != null){
|
---|
211 | try { negotiationInfo.updatePBList(offeredBid); }
|
---|
212 | catch (Exception e) {
|
---|
213 | System.out.println("PBListの更新に失敗しました"); // PopularBidHistoryを更新
|
---|
214 | e.printStackTrace();
|
---|
215 | }
|
---|
216 | }
|
---|
217 | }
|
---|
218 | }
|
---|
219 | }
|
---|
220 |
|
---|
221 | /**
|
---|
222 | * We override the default estimate of the utility
|
---|
223 | * space by using {@link ClosestKnownBid} defined below.
|
---|
224 | */
|
---|
225 | @Override
|
---|
226 | public AbstractUtilitySpace estimateUtilitySpace()
|
---|
227 | {
|
---|
228 | return new ClosestKnownBid(getDomain());
|
---|
229 | }
|
---|
230 |
|
---|
231 | /**
|
---|
232 | * Defines a custom UtilitySpace based on the closest known bid to deal with preference uncertainty.
|
---|
233 | */
|
---|
234 | private class ClosestKnownBid extends CustomUtilitySpace
|
---|
235 | {
|
---|
236 |
|
---|
237 | public ClosestKnownBid(Domain dom) {
|
---|
238 | super(dom);
|
---|
239 | }
|
---|
240 |
|
---|
241 | @Override
|
---|
242 | public double getUtility(Bid bid)
|
---|
243 | {
|
---|
244 | Bid closestRankedBid = getClosestBidRanked(bid);
|
---|
245 | return estimateUtilityOfRankedBid(closestRankedBid);
|
---|
246 | }
|
---|
247 |
|
---|
248 | @Override
|
---|
249 | public Double getReservationValue()
|
---|
250 | {
|
---|
251 | return 0.15;
|
---|
252 | }
|
---|
253 |
|
---|
254 | public double estimateUtilityOfRankedBid(Bid b)
|
---|
255 | {
|
---|
256 | BidRanking bidRanking = getUserModel().getBidRanking();
|
---|
257 | Double min = bidRanking.getLowUtility();
|
---|
258 | double max = bidRanking.getHighUtility();
|
---|
259 |
|
---|
260 | int i = bidRanking.indexOf(b);
|
---|
261 |
|
---|
262 | // index:0 has utility min, index n-1 has utility max
|
---|
263 | return min + i * (max - min) / (double) bidRanking.getSize();
|
---|
264 | }
|
---|
265 |
|
---|
266 | /**
|
---|
267 | * Finds the bid in the bid ranking that is most similar to bid given in the argument bid
|
---|
268 | */
|
---|
269 | public Bid getClosestBidRanked(Bid bid)
|
---|
270 | {
|
---|
271 | List<Bid> bidOrder = getUserModel().getBidRanking().getBidOrder();
|
---|
272 | Bid closestBid = null;
|
---|
273 | double closestDistance = Double.MAX_VALUE;
|
---|
274 |
|
---|
275 | for (Bid b : bidOrder)
|
---|
276 | {
|
---|
277 | double d = 1 / (double) b.countEqualValues(bid);
|
---|
278 | if (d < closestDistance)
|
---|
279 | {
|
---|
280 | closestDistance = d;
|
---|
281 | closestBid = b;
|
---|
282 | }
|
---|
283 | }
|
---|
284 | return closestBid;
|
---|
285 | }
|
---|
286 |
|
---|
287 | }
|
---|
288 |
|
---|
289 | @Override
|
---|
290 | public String getDescription() {
|
---|
291 | return "Gaussian Process Agent";
|
---|
292 | }
|
---|
293 |
|
---|
294 | }
|
---|
295 |
|
---|