20211208 fish

xiaoyong931011

2021-12-08 f5e6133809c553cfd9fb28ee61019927c547c374

 src/main/java/com/xcong/excoin/websocket/handler/FishHitWebSocketHandler.java

@@ -99,7 +99,7 @@
        // 消耗金币
        BigDecimal consume = (BigDecimal) fortObj;

        MsgModel msg = new MsgModel(consume, fishGold, SID_MID.get(session.getId()));
        MsgModel msg = new MsgModel(consume, fishGold, SID_MID.get(session.getId()), fortId);
        // 发送打渔消息
        fishHitProducer.sendFishHitMsg(JSONObject.toJSONString(msg));
    }
@@ -110,9 +110,12 @@

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
        log.info("离开websocket");
        Long memberId = SID_MID.get(session.getId());

        if (memberId != null) {
            MEMBER_SESSIONS.remove(memberId);
        }
        SID_MID.remove(session.getId());
        MEMBER_SESSIONS.remove(memberId);
    }
}