新增观战功能

nc~
ainilili · Sep 27, 2020 · 4fa796f · 4fa796f
2 parents cfb1a39 + 2710b6e
commit 4fa796f
Show file tree

Hide file tree

Showing 16 changed files with 425 additions and 15 deletions.
diff --git a/landlords-client/src/main/java/org/nico/ratel/landlords/client/entity/User.java b/landlords-client/src/main/java/org/nico/ratel/landlords/client/entity/User.java
@@ -0,0 +1,29 @@
+package org.nico.ratel.landlords.client.entity;
+
+public class User {
+    public static final User INSTANCE = new User();
+
+    /** 是否游戏中 */
+    private boolean isPlaying = false;
+
+    /** 是否观战中 */
+    private boolean isWatching = false;
+
+    private User() {}
+
+    public boolean isPlaying() {
+        return isPlaying;
+    }
+
+    public void setPlaying(boolean playing) {
+        isPlaying = playing;
+    }
+
+    public boolean isWatching() {
+        return isWatching;
+    }
+
+    public void setWatching(boolean watching) {
+        isWatching = watching;
+    }
+}
diff --git a/.../main/java/org/nico/ratel/landlords/client/event/ClientEventListener_CODE_GAME_WATCH.java b/.../main/java/org/nico/ratel/landlords/client/event/ClientEventListener_CODE_GAME_WATCH.java
@@ -0,0 +1,148 @@
+package org.nico.ratel.landlords.client.event;
+
+import io.netty.channel.Channel;
+import org.nico.noson.Noson;
+import org.nico.noson.entity.NoType;
+import org.nico.ratel.landlords.client.entity.User;
+import org.nico.ratel.landlords.entity.Poker;
+import org.nico.ratel.landlords.enums.ClientEventCode;
+import org.nico.ratel.landlords.helper.MapHelper;
+import org.nico.ratel.landlords.print.SimplePrinter;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.List;
+import java.util.Map;
+
+public class ClientEventListener_CODE_GAME_WATCH extends ClientEventListener {
+
+    @Override
+    public void call(Channel channel, String wrapData) {
+        Map<String, Object> wrapMap = MapHelper.parser(wrapData);
+        ClientEventCode rawCode = ClientEventCode.valueOf(wrapMap.get("code").toString());
+        Object rawData = wrapMap.get("data");
+
+        switch (rawCode) {
+            case CODE_ROOM_JOIN_SUCCESS:
+                printJoinPlayerInfo(rawData);
+                break;
+
+            // 游戏开始
+            case CODE_GAME_STARTING:
+                printGameStartInfo(rawData);
+                break;
+
+            // 抢地主
+            case CODE_GAME_LANDLORD_ELECT:
+                printRobLandlord(rawData);
+                break;
+
+            // 地主确认
+            case CODE_GAME_LANDLORD_CONFIRM:
+                printConfirmLandlord(rawData);
+                break;
+
+            // 出牌
+            case CODE_SHOW_POKERS:
+                printPlayPokers(rawData);
+                break;
+
+            // 不出（过）
+            case CODE_GAME_POKER_PLAY_PASS:
+                printPlayPass(rawData);
+                break;
+
+            // 玩家退出（此时可以退出观战，修改User.isWatching状态）
+            case CODE_CLIENT_EXIT:
+                printPlayerExit(rawData, channel);
+                break;
+
+            // 玩家被提出房间
+            case CODE_CLIENT_KICK:
+                printKickInfo(rawData);
+                break;
+
+            // 游戏结束（此时可以退出观战，修改User.isWatching状态）
+            case CODE_GAME_OVER:
+                printGameResult(rawData, channel);
+                break;
+
+            // 其他事件忽略
+            default:
+                break;
+        }
+    }
+
+    private void printJoinPlayerInfo(Object rawData) {
+        printNoticeWithTime("Player [" + rawData + "] join room");
+    }
+
+    private void printGameStartInfo(Object rawData) {
+        Map<String, Object> map = MapHelper.parser(rawData.toString());
+
+        printNoticeWithTime("Game start");
+        printNoticeWithTime("Player1 : " + map.get("player1"));
+        printNoticeWithTime("Player2 : " + map.get("player2"));
+        printNoticeWithTime("Player3 : " + map.get("player3"));
+    }
+
+    private void printRobLandlord(Object rawData) {
+        printNoticeWithTime("Player [" + rawData + "] don't rob the landlord");
+    }
+
+    private void printConfirmLandlord(Object rawData) {
+        Map<String, Object> map = MapHelper.parser(rawData.toString());
+
+        printNoticeWithTime("Player [" + map.get("landlord") + "] grabbed the landlord and got extra three poker shots:");
+        SimplePrinter.printPokers(Noson.convert(map.get("additionalPokers"), new NoType<List<Poker>>() {}));
+    }
+
+    private void printPlayPokers(Object rawData) {
+        Map<String, Object> map = MapHelper.parser(rawData.toString());
+
+        printNoticeWithTime("Player [" + map.get("clientNickname") + "] play pokers:");
+        SimplePrinter.printPokers(Noson.convert(map.get("pokers"), new NoType<List<Poker>>() {}));
+    }
+
+    private void printPlayPass(Object rawData) {
+        printNoticeWithTime("Player [" + rawData + "] : pass");
+    }
+
+    private void printPlayerExit(Object rawData, Channel channel) {
+        printNoticeWithTime("Player [" + rawData + "] exit room");
+        quitWatch(channel);
+    }
+
+    private void quitWatch(Channel channel) {
+        printNoticeWithTime("This room will be close!");
+        printNoticeWithTime("Quit watch, bye.");
+        SimplePrinter.printNotice("");
+        SimplePrinter.printNotice("");
+
+        // 修改玩家是否观战状态
+        User.INSTANCE.setWatching(false);
+
+        // 退出watch展示
+        get(ClientEventCode.CODE_SHOW_OPTIONS).call(channel, "");
+    }
+
+    private void printGameResult(Object rawData, Channel channel) {
+        Map<String, Object> map = MapHelper.parser(rawData.toString());
+
+        printNoticeWithTime("Player [" + map.get("winnerNickname") + "](" + map.get("winnerType") + ") won the game");
+        quitWatch(channel);
+    }
+
+    private void printKickInfo(Object rawData) {
+        printNoticeWithTime("Player [" + rawData + "] play time out, kick out of room.");
+    }
+
+
+    private static final DateTimeFormatter FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+
+    private void printNoticeWithTime(String notice) {
+        String msg = FORMATTER.format(LocalDateTime.now()) + "  " + notice;
+
+        SimplePrinter.printNotice(msg);
+    }
+}
diff --git a/...org/nico/ratel/landlords/client/event/ClientEventListener_CODE_GAME_WATCH_SUCCESSFUL.java b/...org/nico/ratel/landlords/client/event/ClientEventListener_CODE_GAME_WATCH_SUCCESSFUL.java
@@ -0,0 +1,28 @@
+package org.nico.ratel.landlords.client.event;
+
+import io.netty.channel.Channel;
+import org.nico.ratel.landlords.client.entity.User;
+import org.nico.ratel.landlords.helper.MapHelper;
+import org.nico.ratel.landlords.print.SimplePrinter;
+
+import java.util.Map;
+
+public class ClientEventListener_CODE_GAME_WATCH_SUCCESSFUL extends ClientEventListener {
+
+    private static final String WATCH_SUCCESSFUL_TIPS = "                                                 \n" +
+                                                        "+------------------------------------------------\n" +
+                                                        "|You are already watch the game.         \n"         +
+                                                        "|Room owner: %s. Room current status: %s.\n"         +
+                                                        "+------------------------------------------------\n" +
+                                                        "                                                   ";
+
+    @Override
+    public void call(Channel channel, String data) {
+        // 修改User.isWatching状态
+        User.INSTANCE.setWatching(true);
+
+        // 进入观战提示
+        Map<String, Object> map = MapHelper.parser(data);
+        SimplePrinter.printNotice(String.format(WATCH_SUCCESSFUL_TIPS, map.get("owner"), map.get("status")));
+    }
+}
diff --git a/...java/org/nico/ratel/landlords/client/event/ClientEventListener_CODE_SHOW_OPTIONS_PVP.java b/...java/org/nico/ratel/landlords/client/event/ClientEventListener_CODE_SHOW_OPTIONS_PVP.java
@@ -16,6 +16,7 @@ public void call(Channel channel, String data) {
 		SimplePrinter.printNotice("1. Create Room");
 		SimplePrinter.printNotice("2. Room List");
 		SimplePrinter.printNotice("3. Join Room");
+		SimplePrinter.printNotice("4. Watch Game");
 		SimplePrinter.printNotice("Please enter the number of options (enter [BACK] return options list)");
 		String line = SimpleWriter.write("pvp");
 
@@ -43,7 +44,22 @@ public void call(Channel channel, String data) {
 						pushToServer(channel, ServerEventCode.CODE_ROOM_JOIN, String.valueOf(option));
 					}
 				}
-			}else {
+			} else if (choose == 4) {
+				SimplePrinter.printNotice("Please enter the room id you want to watch (enter [BACK] return options list)");
+				line = SimpleWriter.write("roomid");
+
+				if(line.equalsIgnoreCase("BACK")) {
+					call(channel, data);
+				}else {
+					int option = OptionsUtils.getOptions(line);
+					if(line == null || option < 1) {
+						SimplePrinter.printNotice("Invalid options, please choose again：");
+						call(channel, data);
+					}else{
+						pushToServer(channel, ServerEventCode.CODE_GAME_WATCH, String.valueOf(option));
+					}
+				}
+			} else {
 				SimplePrinter.printNotice("Invalid option, please choose again：");
 				call(channel, data);
 			}

diff --git a/landlords-client/src/main/java/org/nico/ratel/landlords/client/handler/TransferHandler.java b/landlords-client/src/main/java/org/nico/ratel/landlords/client/handler/TransferHandler.java
@@ -1,6 +1,8 @@
 package org.nico.ratel.landlords.client.handler;
 
+import org.nico.noson.Noson;
 import org.nico.ratel.landlords.channel.ChannelUtils;
+import org.nico.ratel.landlords.client.entity.User;
 import org.nico.ratel.landlords.client.event.ClientEventListener;
 import org.nico.ratel.landlords.entity.ClientTransferData.ClientTransferDataProtoc;
 import org.nico.ratel.landlords.enums.ClientEventCode;
@@ -12,6 +14,9 @@
 import io.netty.handler.timeout.IdleState;
 import io.netty.handler.timeout.IdleStateEvent;
 
+import java.util.HashMap;
+import java.util.Map;
+
 public class TransferHandler extends ChannelInboundHandlerAdapter{
 
 	@Override
@@ -24,7 +29,15 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
 			}
 			ClientEventCode code = ClientEventCode.valueOf(clientTransferData.getCode());
 			if(code != null) {
-				ClientEventListener.get(code).call(ctx.channel(), clientTransferData.getData());
+				if (User.INSTANCE.isWatching()) {
+					Map<String, Object> wrapMap = new HashMap<>(3);
+					wrapMap.put("code", code);
+					wrapMap.put("data", clientTransferData.getData());
+
+					ClientEventListener.get(ClientEventCode.CODE_GAME_WATCH).call(ctx.channel(), Noson.reversal(wrapMap));
+				} else {
+					ClientEventListener.get(code).call(ctx.channel(), clientTransferData.getData());
+				}
 			}
 		}
 	}

diff --git a/landlords-common/src/main/java/org/nico/ratel/landlords/entity/Room.java b/landlords-common/src/main/java/org/nico/ratel/landlords/entity/Room.java
@@ -1,5 +1,6 @@
 package org.nico.ratel.landlords.entity;
 
+import java.util.ArrayList;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
@@ -39,6 +40,9 @@ public class Room{
 	private long createTime;
 
 	private int firstSellClient;
+
+	/** 观战者列表 */
+	private List<ClientSide> watcherList = new ArrayList<>(5);
 
 	public Room() {
 	}
@@ -169,4 +173,8 @@ public int getFirstSellClient() {
 	public void setFirstSellClient(int firstSellClient) {
 		this.firstSellClient = firstSellClient;
 	}
+
+	public List<ClientSide> getWatcherList() {
+		return watcherList;
+	}
 }
diff --git a/landlords-common/src/main/java/org/nico/ratel/landlords/enums/ClientEventCode.java b/landlords-common/src/main/java/org/nico/ratel/landlords/enums/ClientEventCode.java
@@ -61,7 +61,10 @@ public enum ClientEventCode implements Serializable{
 	CODE_GAME_OVER("游戏结束"),
 
 	CODE_PVE_DIFFICULTY_NOT_SUPPORT("人机难度不支持"),
-	;
+
+	CODE_GAME_WATCH("观战"),
+
+	CODE_GAME_WATCH_SUCCESSFUL("观战成功");
 
 	private String msg;
 

diff --git a/landlords-common/src/main/java/org/nico/ratel/landlords/enums/ServerEventCode.java b/landlords-common/src/main/java/org/nico/ratel/landlords/enums/ServerEventCode.java
@@ -29,8 +29,8 @@ public enum ServerEventCode implements Serializable{
 	CODE_GAME_POKER_PLAY_REDIRECT("出牌重定向"),
 
 	CODE_GAME_POKER_PLAY_PASS("不出"),
-	
-	;
+
+	CODE_GAME_WATCH("观战");
 
 	private String msg;
 

diff --git a/...main/java/org/nico/ratel/landlords/server/event/ServerEventListener_CODE_CLIENT_EXIT.java b/...main/java/org/nico/ratel/landlords/server/event/ServerEventListener_CODE_CLIENT_EXIT.java
@@ -27,8 +27,22 @@ public void call(ClientSide clientSide, String data) {
 					client.init();
 				}
 			}
+
+			notifyWatcherClientExit(room, clientSide);
+
 			ServerContains.removeRoom(room.getId());
 		}
 	}
 
+	/**
+	 * 通知所有观战者玩家退出游戏
+	 *
+	 * @param room 房间
+	 * @param player 退出游戏玩家
+	 */
+	private void notifyWatcherClientExit(Room room, ClientSide player) {
+		for (ClientSide watcher : room.getWatcherList()) {
+			ChannelUtils.pushToClient(watcher.getChannel(), ClientEventCode.CODE_CLIENT_EXIT, player.getNickname());
+		}
+	}
 }