http

incubator-common/build.gradle

@@ -38,6 +38,7 @@ dependencies {
     api 'cn.hutool:hutool-all:5.8.25' // Hutool 工具包
 //    api 'org.springframework.boot:spring-boot-starter-amqp:2.6.3' //mq
     api 'com.rabbitmq:amqp-client:5.14.2' //mq
+    api 'org.springframework:spring-web:5.3.33' //web
 
     // Excel 操作
     api 'com.alibaba:easyexcel:4.0.3' // EasyExcel

incubator-game/src/main/java/com/incubator/game/data/entity/ZjBackpack.java

@@ -35,7 +35,7 @@ public class ZjBackpack implements Serializable {
     /**
      * 物品数量
      */
-    private BigDecimal goodsNum;
+    private Integer goodsNum;
 
 
     /**
@@ -84,11 +84,11 @@ public class ZjBackpack implements Serializable {
         this.goodsId = goodsId;
     }
 
-    public BigDecimal getGoodsNum() {
+    public Integer getGoodsNum() {
         return goodsNum;
     }
 
-    public void setGoodsNum(BigDecimal goodsNum) {
+    public void setGoodsNum(Integer goodsNum) {
         this.goodsNum = goodsNum;
     }
 

incubator-game/src/main/java/com/incubator/game/data/entity/ZjClub.java

@@ -79,4 +79,116 @@ public class ZjClub implements Serializable {
      */
     private Integer extendInviteNum;
     private static final long serialVersionUID = 1L;
+
+    public String getClubId() {
+        return clubId;
+    }
+
+    public void setClubId(String clubId) {
+        this.clubId = clubId;
+    }
+
+    public String getClubName() {
+        return clubName;
+    }
+
+    public void setClubName(String clubName) {
+        this.clubName = clubName;
+    }
+
+    public String getClubImg() {
+        return clubImg;
+    }
+
+    public void setClubImg(String clubImg) {
+        this.clubImg = clubImg;
+    }
+
+    public Integer getClubMemberNum() {
+        return clubMemberNum;
+    }
+
+    public void setClubMemberNum(Integer clubMemberNum) {
+        this.clubMemberNum = clubMemberNum;
+    }
+
+    public String getClubDescription() {
+        return clubDescription;
+    }
+
+    public void setClubDescription(String clubDescription) {
+        this.clubDescription = clubDescription;
+    }
+
+    public String getClubCreator() {
+        return clubCreator;
+    }
+
+    public void setClubCreator(String clubCreator) {
+        this.clubCreator = clubCreator;
+    }
+
+    public String getClubStatus() {
+        return clubStatus;
+    }
+
+    public void setClubStatus(String clubStatus) {
+        this.clubStatus = clubStatus;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public String getClubAddress() {
+        return clubAddress;
+    }
+
+    public void setClubAddress(String clubAddress) {
+        this.clubAddress = clubAddress;
+    }
+
+    public Integer getClubChampionship() {
+        return clubChampionship;
+    }
+
+    public void setClubChampionship(Integer clubChampionship) {
+        this.clubChampionship = clubChampionship;
+    }
+
+    public Integer getClubLevel() {
+        return clubLevel;
+    }
+
+    public void setClubLevel(Integer clubLevel) {
+        this.clubLevel = clubLevel;
+    }
+
+    public String getClubNo() {
+        return clubNo;
+    }
+
+    public void setClubNo(String clubNo) {
+        this.clubNo = clubNo;
+    }
+
+    public Integer getClubMasterScore() {
+        return clubMasterScore;
+    }
+
+    public void setClubMasterScore(Integer clubMasterScore) {
+        this.clubMasterScore = clubMasterScore;
+    }
+
+    public Integer getExtendInviteNum() {
+        return extendInviteNum;
+    }
+
+    public void setExtendInviteNum(Integer extendInviteNum) {
+        this.extendInviteNum = extendInviteNum;
+    }
 }

incubator-game/src/main/java/com/incubator/game/data/entity/ZjClubMember.java

@@ -55,4 +55,76 @@ public class ZjClubMember implements Serializable {
     private String ownerType;
 
     private static final long serialVersionUID = 1L;
+
+    public String getMemberId() {
+        return memberId;
+    }
+
+    public void setMemberId(String memberId) {
+        this.memberId = memberId;
+    }
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+
+    public String getClubId() {
+        return clubId;
+    }
+
+    public void setClubId(String clubId) {
+        this.clubId = clubId;
+    }
+
+    public String getMemberStatus() {
+        return memberStatus;
+    }
+
+    public void setMemberStatus(String memberStatus) {
+        this.memberStatus = memberStatus;
+    }
+
+    public Date getJoinTime() {
+        return joinTime;
+    }
+
+    public void setJoinTime(Date joinTime) {
+        this.joinTime = joinTime;
+    }
+
+    public Date getQuitTime() {
+        return quitTime;
+    }
+
+    public void setQuitTime(Date quitTime) {
+        this.quitTime = quitTime;
+    }
+
+    public String getRequestExplain() {
+        return requestExplain;
+    }
+
+    public void setRequestExplain(String requestExplain) {
+        this.requestExplain = requestExplain;
+    }
+
+    public String getRequestChannel() {
+        return requestChannel;
+    }
+
+    public void setRequestChannel(String requestChannel) {
+        this.requestChannel = requestChannel;
+    }
+
+    public String getOwnerType() {
+        return ownerType;
+    }
+
+    public void setOwnerType(String ownerType) {
+        this.ownerType = ownerType;
+    }
 }

incubator-game/src/main/java/com/incubator/game/data/entity/ZjMemberAddr.java

@@ -66,5 +66,83 @@ public class ZjMemberAddr implements Serializable {
      */
     private Date updateTime;
 
+    public String getAddrId() {
+        return addrId;
+    }
 
+    public void setAddrId(String addrId) {
+        this.addrId = addrId;
+    }
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+
+    public String getReceiver() {
+        return receiver;
+    }
+
+    public void setReceiver(String receiver) {
+        this.receiver = receiver;
+    }
+
+    public String getCity() {
+        return city;
+    }
+
+    public void setCity(String city) {
+        this.city = city;
+    }
+
+    public String getAddr() {
+        return addr;
+    }
+
+    public void setAddr(String addr) {
+        this.addr = addr;
+    }
+
+    public String getMobile() {
+        return mobile;
+    }
+
+    public void setMobile(String mobile) {
+        this.mobile = mobile;
+    }
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    public Integer getCommonAddr() {
+        return commonAddr;
+    }
+
+    public void setCommonAddr(Integer commonAddr) {
+        this.commonAddr = commonAddr;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public Date getUpdateTime() {
+        return updateTime;
+    }
+
+    public void setUpdateTime(Date updateTime) {
+        this.updateTime = updateTime;
+    }
 }

incubator-game/src/main/java/com/incubator/game/data/entity/ZjOrder.java

@@ -5,6 +5,7 @@ import jdk.nashorn.internal.objects.annotations.Getter;
 
 import java.io.Serializable;
 import java.math.BigDecimal;
+import java.util.Date;
 
 /**
  * <p>
@@ -121,7 +122,7 @@ public class ZjOrder implements Serializable {
     /**
      * 创建时间
      */
-    private String createTime;
+    private Date createTime;
 
     /**
      * 更新时间
@@ -322,11 +323,11 @@ public class ZjOrder implements Serializable {
         this.isDelete = isDelete;
     }
 
-    public String getCreateTime() {
+    public Date getCreateTime() {
         return createTime;
     }
 
-    public void setCreateTime(String createTime) {
+    public void setCreateTime(Date createTime) {
         this.createTime = createTime;
     }
 

incubator-game/src/main/java/com/incubator/game/data/entity/ZjUser.java

@@ -82,5 +82,115 @@ public class ZjUser implements Serializable {
      */
     private String characterUrl;
 
+    public String getUserId() {
+        return userId;
+    }
 
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+
+    public String getNickName() {
+        return nickName;
+    }
+
+    public void setNickName(String nickName) {
+        this.nickName = nickName;
+    }
+
+    public String getAvatarUrl() {
+        return avatarUrl;
+    }
+
+    public void setAvatarUrl(String avatarUrl) {
+        this.avatarUrl = avatarUrl;
+    }
+
+    public Integer getHonorLevel() {
+        return honorLevel;
+    }
+
+    public void setHonorLevel(Integer honorLevel) {
+        this.honorLevel = honorLevel;
+    }
+
+    public Integer getMasterScoreLevel() {
+        return masterScoreLevel;
+    }
+
+    public void setMasterScoreLevel(Integer masterScoreLevel) {
+        this.masterScoreLevel = masterScoreLevel;
+    }
+
+    public Integer getMasterScore() {
+        return masterScore;
+    }
+
+    public void setMasterScore(Integer masterScore) {
+        this.masterScore = masterScore;
+    }
+
+    public Integer getRanking() {
+        return ranking;
+    }
+
+    public void setRanking(Integer ranking) {
+        this.ranking = ranking;
+    }
+
+    public String getSex() {
+        return sex;
+    }
+
+    public void setSex(String sex) {
+        this.sex = sex;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public BigDecimal getRmb() {
+        return rmb;
+    }
+
+    public void setRmb(BigDecimal rmb) {
+        this.rmb = rmb;
+    }
+
+    public String getUserClub() {
+        return userClub;
+    }
+
+    public void setUserClub(String userClub) {
+        this.userClub = userClub;
+    }
+
+    public Integer getCharm() {
+        return charm;
+    }
+
+    public void setCharm(Integer charm) {
+        this.charm = charm;
+    }
+
+    public String getUserNo() {
+        return userNo;
+    }
+
+    public void setUserNo(String userNo) {
+        this.userNo = userNo;
+    }
+
+    public String getCharacterUrl() {
+        return characterUrl;
+    }
+
+    public void setCharacterUrl(String characterUrl) {
+        this.characterUrl = characterUrl;
+    }
 }

incubator-game/src/main/java/com/incubator/game/data/entity/ZjUserLongin.java

@@ -114,4 +114,172 @@ public class ZjUserLongin implements Serializable {
      * 零时账户
      */
     private String account;
+
+    public String getLoginId() {
+        return loginId;
+    }
+
+    public void setLoginId(String loginId) {
+        this.loginId = loginId;
+    }
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+
+    public String getPhoneNumber() {
+        return phoneNumber;
+    }
+
+    public void setPhoneNumber(String phoneNumber) {
+        this.phoneNumber = phoneNumber;
+    }
+
+    public String getWxOpenId() {
+        return wxOpenId;
+    }
+
+    public void setWxOpenId(String wxOpenId) {
+        this.wxOpenId = wxOpenId;
+    }
+
+    public String getPassword() {
+        return password;
+    }
+
+    public void setPassword(String password) {
+        this.password = password;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public Date getLoginTime() {
+        return loginTime;
+    }
+
+    public void setLoginTime(Date loginTime) {
+        this.loginTime = loginTime;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public Date getUpdateTime() {
+        return updateTime;
+    }
+
+    public void setUpdateTime(Date updateTime) {
+        this.updateTime = updateTime;
+    }
+
+    public String getGps() {
+        return gps;
+    }
+
+    public void setGps(String gps) {
+        this.gps = gps;
+    }
+
+    public String getGpsAddr() {
+        return gpsAddr;
+    }
+
+    public void setGpsAddr(String gpsAddr) {
+        this.gpsAddr = gpsAddr;
+    }
+
+    public String getCertNo() {
+        return certNo;
+    }
+
+    public void setCertNo(String certNo) {
+        this.certNo = certNo;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getWxId() {
+        return wxId;
+    }
+
+    public void setWxId(String wxId) {
+        this.wxId = wxId;
+    }
+
+    public String getLoginIp() {
+        return loginIp;
+    }
+
+    public void setLoginIp(String loginIp) {
+        this.loginIp = loginIp;
+    }
+
+    public String getLoginDevice() {
+        return loginDevice;
+    }
+
+    public void setLoginDevice(String loginDevice) {
+        this.loginDevice = loginDevice;
+    }
+
+    public String getFreeze() {
+        return freeze;
+    }
+
+    public void setFreeze(String freeze) {
+        this.freeze = freeze;
+    }
+
+    public Date getFreezeTime() {
+        return freezeTime;
+    }
+
+    public void setFreezeTime(Date freezeTime) {
+        this.freezeTime = freezeTime;
+    }
+
+    public Date getThawTime() {
+        return thawTime;
+    }
+
+    public void setThawTime(Date thawTime) {
+        this.thawTime = thawTime;
+    }
+
+    public String getAccount() {
+        return account;
+    }
+
+    public void setAccount(String account) {
+        this.account = account;
+    }
 }

incubator-game/src/main/java/com/incubator/game/data/mq/RabbitMQUtil.java

@@ -45,7 +45,7 @@ public class RabbitMQUtil {
     public static void sendMessage(String message) throws Exception {
         // 发送消息
         channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, null, message.getBytes());
-        System.out.println("Sent message: " + message);
+        System.out.println("发送消息: " + message);
     }
 
     public static void closeConnection() {

incubator-game/src/main/java/com/incubator/game/data/po/ZjOrderPO.java

@@ -61,7 +61,7 @@ public class ZjOrderPO {
     /**
      * 订单状态( 0  取消  1 进行中 2 待取消 3 已完成)'
      */
-    private String status;
+    private String orderStatus;
 
     /**
      * 币种
@@ -124,6 +124,14 @@ public class ZjOrderPO {
      */
     private String merchantInfo;
 
+    public String getOrderStatus() {
+        return orderStatus;
+    }
+
+    public void setOrderStatus(String orderStatus) {
+        this.orderStatus = orderStatus;
+    }
+
     public String getMerchantInfo() {
         return merchantInfo;
     }
@@ -236,13 +244,6 @@ public class ZjOrderPO {
         this.balance = balance;
     }
 
-    public String getStatus() {
-        return status;
-    }
-
-    public void setStatus(String status) {
-        this.status = status;
-    }
 
     public String getProductUnit() {
         return productUnit;

incubator-game/src/main/java/com/incubator/game/handler/address/SaveAddress.java

@@ -9,7 +9,9 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjMemberAddr;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjMemberAddrPO;
 import com.incubator.game.util.ObjectMapperUtil;
 import com.incubator.game.util.UtilCore;
@@ -66,12 +68,22 @@ public class SaveAddress extends NetHandler {
                 zjMemberAddrPOList.forEach(po -> po.setCommonAddr(po.getAddrId().equals(zjMemberAddrPO.getAddrId()) ? 1 : 0));
             }
         }
+        ZjMemberAddr zjMemberAddr = new ZjMemberAddr();
 
         boolean isNewAddress = zjMemberAddrPO.getAddrId() == null;
         if (isNewAddress) {
             zjMemberAddrPO.setAddrId(UtilCore.getDateRandomId());
             zjMemberAddrPO.setCreateTime(new Date());
             zjMemberAddrPOList.add(zjMemberAddrPO);
+
+            zjMemberAddr.setAddrId(zjMemberAddrPO.getAddrId());
+            zjMemberAddr.setCreateTime(zjMemberAddrPO.getCreateTime());
+            zjMemberAddr.setAddr(zjMemberAddrPO.getAddr());
+            zjMemberAddr.setReceiver(zjMemberAddrPO.getReceiver());
+            zjMemberAddr.setMobile(zjMemberAddrPO.getMobile());
+            zjMemberAddr.setStatus(zjMemberAddrPO.getStatus());
+            zjMemberAddr.setCommonAddr(zjMemberAddrPO.getCommonAddr());
+            zjMemberAddr.setUserId(zjMemberAddrPO.getUserId());
         } else {
             Optional<ZjMemberAddrPO> addressToUpdate = zjMemberAddrPOList.stream()
                     .filter(p -> p.getAddrId().equals(zjMemberAddrPO.getAddrId()))
@@ -82,9 +94,27 @@ public class SaveAddress extends NetHandler {
             addressToUpdate.ifPresent(address -> {
                 address.setUpdateTime(new Date());
                 address.setStatus(zjMemberAddrPO.getStatus());
+                address.setReceiver(zjMemberAddrPO.getReceiver());
+                address.setMobile(zjMemberAddrPO.getMobile());
+                address.setCommonAddr(zjMemberAddrPO.getCommonAddr());
+                zjMemberAddr.setUpdateTime(address.getUpdateTime());
+                zjMemberAddr.setCommonAddr(address.getCommonAddr());
+                zjMemberAddr.setAddrId(address.getAddrId());
+                zjMemberAddr.setReceiver(address.getReceiver());
+                zjMemberAddr.setMobile(address.getMobile());
+                zjMemberAddr.setStatus(address.getStatus());
+                zjMemberAddr.setAddr(address.getAddr());
+                zjMemberAddr.setUserId(address.getUserId());
             });
         }
-
+        JSONObject object = new JSONObject();
+        object.put("type", "saveAddr");
+        object.put("data", zjMemberAddr);
+        try {
+            RabbitMQUtil.sendMessage(object.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
 
 
         // 更新Redis中的用户信息

incubator-game/src/main/java/com/incubator/game/handler/club/AgreeOrRefuseJoin.java

@@ -9,7 +9,10 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjClub;
+import com.incubator.game.data.entity.ZjClubMember;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjClubMemberPo;
 import com.incubator.game.data.po.ZjClubPo;
 import com.incubator.game.data.po.ZjUserLobbyPo;
@@ -66,10 +69,29 @@ public class AgreeOrRefuseJoin extends NetHandler {
             ZjClubMemberPo member = memberMap.get(userId);
             if (member != null) {
                 member.setMemberStatus(status);
+                ZjClubMember zjClubMember = new ZjClubMember();
+                zjClubMember.setMemberId(member.getMemberId());
+                zjClubMember.setMemberStatus(member.getMemberStatus());
+                zjClubMember.setUserId(member.getUserId());
+                zjClubMember.setClubId(member.getClubId());
                 if ("1".equals(status)) {
                     zjClub.setClubMemberNum(zjClub.getClubMemberNum() + 1);
+                    ZjClub zjClub1 = new ZjClub();
+                    zjClub1.setClubId(zjClub.getClubId());
+                    zjClub1.setClubMemberNum(zjClub.getClubMemberNum());
+                    JSONObject object = new JSONObject();
+                    object.put("type", "saveClub");
+                    object.put("data", zjClub1);
+                    try {
+                        RabbitMQUtil.sendMessage(object.toString());
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+
                     member.setIsMaster("N");
                     member.setJoinTime(now);
+                    zjClubMember.setJoinTime(now);
+
 
                     String userInfo = RedisUtil.get(RedisKeyConstant.USER_BASE + userId);
                     JSONObject userObject = JSONUtil.parseObj(userInfo);
@@ -89,6 +111,14 @@ public class AgreeOrRefuseJoin extends NetHandler {
                         RedisUtil.set(RedisKeyConstant.USER_BASE + userId, userObject.toString());
                     }
                 }
+                JSONObject object = new JSONObject();
+                object.put("type", "saveClubMember");
+                object.put("data", zjClubMember);
+                try {
+                    RabbitMQUtil.sendMessage(object.toString());
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
             }
         }
 

incubator-game/src/main/java/com/incubator/game/handler/club/ApplyJoinClub.java

@@ -9,7 +9,9 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjClubMember;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjClubMemberPo;
 import com.incubator.game.data.po.ZjClubPo;
 import com.incubator.game.data.po.ZjUserLobbyPo;
@@ -77,6 +79,23 @@ public class ApplyJoinClub extends NetHandler {
         String memBerList = RedisUtil.get(RedisKeyConstant.CLUB_MEMBER + newClubMember.getClubId());
         JSONArray clubMember = JSONUtil.parseObj(memBerList).getJSONArray("clubMember");
         clubMember.add(newClubMember);
+
+        ZjClubMember zjClubMember = new ZjClubMember();
+        zjClubMember.setUserId(newClubMember.getUserId());
+        zjClubMember.setClubId(newClubMember.getClubId());
+        zjClubMember.setMemberStatus(newClubMember.getMemberStatus());
+        zjClubMember.setRequestChannel(newClubMember.getRequestChannel()==null?"":newClubMember.getRequestChannel());
+        zjClubMember.setRequestExplain(newClubMember.getRequestExplain()==null?"":newClubMember.getRequestExplain());
+        JSONObject object1 = new JSONObject();
+        object1.put("type", "saveClubMember");
+        object1.put("data", zjClubMember);
+        try {
+            RabbitMQUtil.sendMessage(object1.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+
         JSONObject object = new JSONObject();
         object.put("clubMember", clubMember);
         RedisUtil.set(RedisKeyConstant.CLUB_MEMBER + newClubMember.getClubId(), object.toString());

incubator-game/src/main/java/com/incubator/game/handler/club/CreateClub.java

@@ -9,7 +9,10 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjClub;
+import com.incubator.game.data.entity.ZjClubMember;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjClubMemberPo;
 import com.incubator.game.data.po.ZjClubPo;
 import com.incubator.game.data.po.ZjUserLobbyPo;
@@ -73,6 +76,27 @@ public class CreateClub extends NetHandler {
             newClub.setMasterScore(lobbyUser.getMasterScore());
             newClub.setMasterName(lobbyUser.getNickName());
             newClub.setClubMemberNum(1);
+
+            ZjClub zjClub = new ZjClub();
+            zjClub.setClubId(newClub.getClubId());
+            zjClub.setClubName(newClub.getClubName());
+            zjClub.setClubImg(newClub.getClubImg());
+            zjClub.setClubDescription(newClub.getClubDescription());
+            zjClub.setClubAddress(newClub.getClubAddress());
+            zjClub.setCreateTime(new Date());
+            zjClub.setClubStatus("1");
+            zjClub.setClubCreator(userId);
+            zjClub.setClubMemberNum(newClub.getClubMemberNum());
+            JSONObject object = new JSONObject();
+            object.put("type","saveClub");
+            object.put("data",zjClub);
+            try {
+                RabbitMQUtil.sendMessage(object.toString());
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+
+
             addClubToRedis(jsonObject, clubArray, newClub);//添加俱乐部到redis
 
             addClubMemberToRedis(userObject, newClub);//添加俱乐部成员到redis
@@ -95,6 +119,27 @@ public class CreateClub extends NetHandler {
                 c.setClubDescription(club.getClubDescription());
                 c.setClubAddress(club.getClubAddress());
             });
+            ZjClubPo clubPo = existingClub.get();
+            ZjClub zjClub = new ZjClub();
+            zjClub.setClubId(clubPo.getClubId());
+            zjClub.setClubName(clubPo.getClubName());
+            zjClub.setClubImg(clubPo.getClubImg());
+            zjClub.setClubDescription(clubPo.getClubDescription());
+            zjClub.setClubAddress(clubPo.getClubAddress());
+            zjClub.setCreateTime(new Date());
+            zjClub.setClubStatus("1");
+            zjClub.setClubCreator(clubPo.getClubCreator());
+            zjClub.setClubMemberNum(clubPo.getClubMemberNum());
+            JSONObject object = new JSONObject();
+            object.put("type","saveClub");
+            object.put("data",zjClub);
+            try {
+                RabbitMQUtil.sendMessage(object.toString());
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+
+
             jsonObject.put("clubList", clubList);
             RedisUtil.set(RedisKeyConstant.CLUB_BASE, jsonObject.toString());
         }
@@ -121,6 +166,26 @@ public class CreateClub extends NetHandler {
         objects.add(zjClubMemberPo);
         object.put("clubMember",objects);
         RedisUtil.set(RedisKeyConstant.CLUB_MEMBER + newClub.getClubId(), object.toString());
+
+        ZjClubMember zjClubMember = new ZjClubMember();
+        zjClubMember.setUserId(zjClubMemberPo.getUserId());
+        zjClubMember.setClubId(zjClubMemberPo.getClubId());
+        zjClubMember.setMemberStatus(zjClubMemberPo.getMemberStatus());
+        zjClubMember.setRequestChannel(zjClubMemberPo.getRequestChannel()==null?"":zjClubMemberPo.getRequestChannel());
+        zjClubMember.setRequestExplain(zjClubMemberPo.getRequestExplain()==null?"":zjClubMemberPo.getRequestExplain());
+        zjClubMember.setMemberId(zjClubMemberPo.getMemberId());
+        JSONObject object1 = new JSONObject();
+        object1.put("type", "saveClubMember");
+        object1.put("data", zjClubMember);
+        try {
+            RabbitMQUtil.sendMessage(object1.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+
+
+
     }
 
     private JSONObject getClubListFromRedis() {
@@ -168,5 +233,16 @@ public class CreateClub extends NetHandler {
             oldClubJO.put("clubMember",updatedClubMembers);
             RedisUtil.set(RedisKeyConstant.CLUB_MEMBER + userClub,oldClubJO.toString());
         }
+        JSONObject object = new JSONObject();
+        object.put("type", "saveMainClub");
+        object.put("data", lobbyUser);
+        try {
+            RabbitMQUtil.sendMessage(object.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+
+
     }
 }

incubator-game/src/main/java/com/incubator/game/handler/club/DeleteMember.java

@@ -9,7 +9,10 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjClub;
+import com.incubator.game.data.entity.ZjClubMember;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjClubMemberPo;
 import com.incubator.game.data.po.ZjClubPo;
 import com.incubator.game.data.po.ZjUserLobbyPo;
@@ -62,6 +65,30 @@ public class DeleteMember extends NetHandler {
             zjClubMember.setQuitTime(new Date());
             zjClub.setClubMemberNum(zjClub.getClubMemberNum() - 1);
 
+            ZjClubMember zjClubMember1 = new ZjClubMember();
+            zjClubMember1.setMemberId(zjClubMember.getMemberId());
+            zjClubMember1.setMemberStatus(zjClubMember1.getMemberStatus());
+            JSONObject object1 = new JSONObject();
+            object1.put("type", "saveClubMember");
+            object1.put("data", zjClubMember1);
+            try {
+                RabbitMQUtil.sendMessage(object1.toString());
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+
+            ZjClub zjClub1 = new ZjClub();
+            zjClub1.setClubId(zjClub.getClubId());
+            zjClub1.setClubMemberNum(zjClub.getClubMemberNum());
+            JSONObject object2 = new JSONObject();
+            object2.put("type", "saveClub");
+            object2.put("data", zjClub1);
+            try {
+                RabbitMQUtil.sendMessage(object2.toString());
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+
             // 更新俱乐部列表和成员列表
             clubJson.set("clubList", clubList);
             memberObject.set("clubMember", clubMember);
@@ -86,6 +113,15 @@ public class DeleteMember extends NetHandler {
                     lobbyUser.setUserClub(newClub.getClubId());
                 }
                 userObject.put("lobbyUser", lobbyUser);
+
+                JSONObject object = new JSONObject();
+                object.put("type", "saveMainClub");
+                object.put("data", lobbyUser);
+                try {
+                    RabbitMQUtil.sendMessage(object.toString());
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
             }
             userObject.put("clubList", userClubList);
             RedisUtil.set(RedisKeyConstant.USER_BASE + userId, userObject.toString());

incubator-game/src/main/java/com/incubator/game/handler/club/DissolveClub.java

@@ -9,7 +9,10 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjClub;
+import com.incubator.game.data.entity.ZjClubMember;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjClubMemberPo;
 import com.incubator.game.data.po.ZjClubPo;
 import com.incubator.game.data.po.ZjUserLobbyPo;
@@ -46,6 +49,20 @@ public class DissolveClub extends NetHandler {
         }
         // 更新俱乐部状态
         zjClub.setClubStatus("0"); // 解散俱乐部
+
+        ZjClub zjClub1 = new ZjClub();
+        zjClub1.setClubId(zjClub.getClubId());
+        zjClub1.setClubStatus(zjClub.getClubStatus());
+        JSONObject object2 = new JSONObject();
+        object2.put("type", "saveClub");
+        object2.put("data", zjClub1);
+        try {
+            RabbitMQUtil.sendMessage(object2.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+
         clubJson.put("clubList", clubList);
         RedisUtil.set(RedisKeyConstant.CLUB_BASE, clubJson.toString());
 
@@ -70,6 +87,19 @@ public class DissolveClub extends NetHandler {
             }
             zjClubMember.setMemberStatus("3");
 
+            ZjClubMember zjClubMember1 = new ZjClubMember();
+            zjClubMember1.setMemberId(zjClubMember.getMemberId());
+            zjClubMember1.setMemberStatus(zjClubMember.getMemberStatus());
+            JSONObject object1 = new JSONObject();
+            object1.put("type", "saveClubMember");
+            object1.put("data", zjClubMember1);
+            try {
+                RabbitMQUtil.sendMessage(object1.toString());
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+
+
 
 
             JSONArray userClubList = userObject.getJSONArray("clubList");
@@ -82,6 +112,14 @@ public class DissolveClub extends NetHandler {
                     ZjClubPo newClub = userClubPoList.get(0); // 直接选择第一个作为主俱乐部
                     lobbyUser.setUserClub(newClub.getClubId());
                 }
+                JSONObject object = new JSONObject();
+                object.put("type", "saveMainClub");
+                object.put("data", lobbyUser);
+                try {
+                    RabbitMQUtil.sendMessage(object.toString());
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
                 userObject.put("lobbyUser", lobbyUser);
             }
             userObject.put("clubList", userClubList);

incubator-game/src/main/java/com/incubator/game/handler/club/QuitClub.java

@@ -10,7 +10,10 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjClub;
+import com.incubator.game.data.entity.ZjClubMember;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjClubMemberPo;
 import com.incubator.game.data.po.ZjClubPo;
 import com.incubator.game.data.po.ZjUserLobbyPo;
@@ -36,6 +39,35 @@ public class QuitClub extends NetHandler {
         String userId = session.getPlayerId();
         String clubId = request.getDataValue("clubId", String.class, "");
 
+
+        String clubListStr = RedisUtil.get(RedisKeyConstant.CLUB_BASE);
+
+        JSONObject clubJson = JSONUtil.parseObj(clubListStr);
+        JSONArray clubListArray = clubJson.getJSONArray("clubList");
+        List<ZjClubPo> clubList = clubListArray.toList(ZjClubPo.class);
+        ZjClubPo zjClub = clubList.stream()
+                .filter(club -> clubId.equals(club.getClubId()))
+                .findFirst()
+                .orElse(null);
+        if (zjClub == null) {
+            response.setCode(102);
+            response.setMessage("俱乐部不存在");
+            return;
+        }
+
+        ZjClub zjClub1 = new ZjClub();
+        zjClub1.setClubId(zjClub.getClubId());
+        zjClub1.setClubMemberNum(zjClub.getClubMemberNum());
+        JSONObject object2 = new JSONObject();
+        object2.put("type", "saveClub");
+        object2.put("data", zjClub1);
+        try {
+            RabbitMQUtil.sendMessage(object2.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+
         try {
             // 更新用户在俱乐部的状态
             updateClubMemberStatus(clubId, userId);
@@ -59,6 +91,19 @@ public class QuitClub extends NetHandler {
             if (clubPo.getUserId().equals(userId)) {
                 clubPo.setMemberStatus("3");
                 clubPo.setQuitTime(new Date());
+
+                ZjClubMember zjClubMember1 = new ZjClubMember();
+                zjClubMember1.setMemberId(clubPo.getMemberId());
+                zjClubMember1.setMemberStatus(zjClubMember1.getMemberStatus());
+                JSONObject object1 = new JSONObject();
+                object1.put("type", "saveClubMember");
+                object1.put("data", zjClubMember1);
+                try {
+                    RabbitMQUtil.sendMessage(object1.toString());
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+
                 break;
             }
         }
@@ -87,6 +132,15 @@ public class QuitClub extends NetHandler {
                 lobbyUser.setUserClub(newClubId);
             }
             jsonObject.put("lobbyUser", lobbyUser);
+
+            JSONObject object = new JSONObject();
+            object.put("type", "saveMainClub");
+            object.put("data", lobbyUser);
+            try {
+                RabbitMQUtil.sendMessage(object.toString());
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
         }
         jsonObject.put("clubList", clubList);
         RedisUtil.set(RedisKeyConstant.USER_BASE + userId, jsonObject.toString());

incubator-game/src/main/java/com/incubator/game/handler/club/SetMainClub.java

@@ -9,6 +9,7 @@ import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjUserLobbyPo;
 import com.incubator.message.proto.CommonProto;
 
@@ -46,5 +47,14 @@ public class SetMainClub extends NetHandler {
         RedisUtil.setEx(RedisKeyConstant.SET_MAIN_CLUB+userId, clubId, Math.toIntExact(30 * 24 * 60 * 60));//设置用户的主俱乐部为30天
         response.setCode(CommonProto.Code.OK_VALUE);
         response.setMessage("设置成功！");
+
+        JSONObject object = new JSONObject();
+        object.put("type", "saveMainClub");
+        object.put("data", lobbyUser);
+        try {
+            RabbitMQUtil.sendMessage(object.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
     }
 }

incubator-game/src/main/java/com/incubator/game/handler/http/WxLogin.java

@@ -0,0 +1,51 @@
+package com.incubator.game.handler.http;
+
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.incubator.common.MessageHandler;
+import com.incubator.core.net.http.HttpHandler;
+import com.incubator.core.net.http.HttpRequest;
+import com.incubator.core.net.http.HttpResponse;
+import com.incubator.message.proto.CommonProto;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Author:  xhb
+ * Date:  2024-12-17 10:43
+ */
+@MessageHandler(httpPath = "/wxLogin")
+public class WxLogin extends HttpHandler {
+
+    private static final String wxAppidC = "wxa1c5de9033d008fa";
+
+    private static final String wxAppSecretC = "dd530f78cab70c8d3b2cf960399116c2";
+
+    /**
+     * 设置消息内容
+     **/
+    @Override
+    public HttpResponse onDate(HttpRequest request, Map<String, String> params) throws Exception {
+        HttpResponse response = new HttpResponse();
+        String code = params.get("code");
+        String avatarUrl = params.get("avatarUrl");
+        String nickName = params.get("nickName");
+        String url = "https://api.weixin.qq.com/sns/jscode2session" +
+                "?appid=" + wxAppidC +
+                "&secret=" + wxAppSecretC +
+                "&js_code=" + code +
+                "&grant_type=authorization_code";
+        RestTemplate restTemplate = new RestTemplate();
+        String forObject = restTemplate.getForObject(url, String.class);
+        JSONObject jsonObject = JSONUtil.parseObj(forObject);
+        String sessionKey = (String)jsonObject.get("session_key");
+        String openId = (String)jsonObject.get("openid");
+        JSONObject object = new JSONObject();
+        object.put("code", code);
+        response.setCode(CommonProto.Code.OK_VALUE);
+        response.setData(object.toString());
+        return response;
+    }
+}

incubator-game/src/main/java/com/incubator/game/handler/login/LoginGameHandler.java

@@ -107,6 +107,9 @@ public class LoginGameHandler extends NetHandler {
 		map.put("contestId", player.data.contestId);
 		// 官方比赛信息列表
 		map.put("contestInfo", ProtoUtil.contestListToMessage());
+
+		//奖励弹窗
+
 		response.setData(map);
 	}
 }

incubator-game/src/main/java/com/incubator/game/handler/mall/ShopBuy.java

@@ -9,7 +9,11 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjBackpack;
+import com.incubator.game.data.entity.ZjOrder;
+import com.incubator.game.data.entity.ZjUser;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjBackpackPO;
 import com.incubator.game.data.po.ZjOrderPO;
 import com.incubator.game.data.po.ZjProductPo;
@@ -86,15 +90,41 @@ public class ShopBuy extends NetHandler {
                 Optional<ZjBackpackPO> optionalItem = zjBackpackPOS.stream()
                         .filter(item -> item.getGoodsId().equals(gId))
                         .findFirst();
+                ZjBackpack zjBackpack = new ZjBackpack();
                 if (optionalItem.isPresent()) {
                     ZjBackpackPO item = optionalItem.get();
                     item.setGoodsNum(gNum + item.getGoodsNum());
+                    zjBackpack.setBackId(item.getBackId());
+                    zjBackpack.setGoodsId(gId);
+                    zjBackpack.setUserId(userId);
+                    zjBackpack.setGoodsNum(item.getGoodsNum());
+                    JSONObject object = new JSONObject();
+                    object.put("type", "saveBack");
+                    object.put("data", zjBackpack);
+                    try {
+                        RabbitMQUtil.sendMessage(object.toString());
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
                 }else {
                     ZjBackpackPO newItem = new ZjBackpackPO();
+                    newItem.setBackId(UtilCore.getDateRandomId());
                     newItem.setGoodsId(gId);
                     newItem.setUserId(userId);
                     newItem.setGoodsNum(gNum);
                     zjBackpackPOS.add(newItem);
+                    zjBackpack.setBackId(newItem.getBackId());
+                    zjBackpack.setGoodsId(gId);
+                    zjBackpack.setUserId(userId);
+                    zjBackpack.setGoodsNum(newItem.getGoodsNum());
+                    JSONObject object = new JSONObject();
+                    object.put("type", "saveBack");
+                    object.put("data", zjBackpack);
+                    try {
+                        RabbitMQUtil.sendMessage(object.toString());
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
                 }
                 // 生成订单
                 ZjOrderPO zjOrder = new ZjOrderPO();
@@ -102,13 +132,31 @@ public class ShopBuy extends NetHandler {
                 String orderNo = UtilCore.getDateRandomId();//订单号
                 zjOrder.setOrderNo(orderNo);
                 zjOrder.setProductName(product.getProductName());
-                zjOrder.setStatus("3");
+                zjOrder.setOrderStatus("3");
                 zjOrder.setPayType("1");
                 zjOrder.setOrderType("1");
                 zjOrder.setCreateTime(new Date());
                 zjOrder.setMerchantInfo("武汉电子科技公司");
                 zjOrderPOS.add(zjOrder);
 
+                ZjOrder zjOrder1 = new ZjOrder();
+                zjOrder1.setOrderId(zjOrder.getOrderId());
+                zjOrder1.setProductName(product.getProductName());
+                zjOrder1.setMerchantInfo("武汉电子科技公司");
+                zjOrder1.setUserId(userId);
+                zjOrder1.setOrderNo(orderNo);
+                zjOrder1.setOrderStatus("3");
+                zjOrder1.setPayType("1");
+                zjOrder1.setOrderType("1");
+                zjOrder1.setCreateTime(new Date());
+                JSONObject object = new JSONObject();
+                object.put("type", "saveOrder");
+                object.put("data", zjOrder1);
+                try {
+                    RabbitMQUtil.sendMessage(object.toString());
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
             }
             // 更新背包
             userObject.put("lobbyUser", lobbyUser);

incubator-game/src/main/java/com/incubator/game/handler/user/UpdateAvatarUrlHandler.java

@@ -8,7 +8,9 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjUser;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjUserLobbyPo;
 import com.incubator.message.proto.CommonProto;
 
@@ -34,5 +36,17 @@ public class UpdateAvatarUrlHandler extends NetHandler {
         userObject.put("lobbyUser", lobbyUser);
         RedisUtil.set(RedisKeyConstant.USER_BASE + userId, userObject.toString());
         response.setMessage("修改成功！");
+
+        ZjUser zjUser = new ZjUser();
+        zjUser.setUserId(userId);
+        zjUser.setAvatarUrl(avatarUrl);
+        JSONObject object = new JSONObject();
+        object.put("type", "updateUser");
+        object.put("data", zjUser);
+        try {
+            RabbitMQUtil.sendMessage(object.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
     }
 }

incubator-game/src/main/java/com/incubator/game/handler/user/UpdateCharacterUrlHandler.java

@@ -8,7 +8,9 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjUser;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjUserLobbyPo;
 import com.incubator.message.proto.CommonProto;
 
@@ -34,5 +36,17 @@ public class UpdateCharacterUrlHandler extends NetHandler {
         userObject.put("lobbyUser", lobbyUser);
         RedisUtil.set(RedisKeyConstant.USER_BASE + userId, userObject.toString());
         response.setMessage("修改成功！");
+
+        ZjUser zjUser = new ZjUser();
+        zjUser.setUserId(userId);
+        zjUser.setCharacterUrl(characterUrl);
+        JSONObject object = new JSONObject();
+        object.put("type", "updateUser");
+        object.put("data", zjUser);
+        try {
+            RabbitMQUtil.sendMessage(object.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
     }
 }

incubator-game/src/main/java/com/incubator/game/handler/user/UpdateNickNameHandler.java

@@ -8,7 +8,9 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjUser;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjUserLobbyPo;
 import com.incubator.message.proto.CommonProto;
 
@@ -34,6 +36,18 @@ public class UpdateNickNameHandler extends NetHandler {
         userObject.put("lobbyUser", lobbyUser);
         RedisUtil.set(RedisKeyConstant.USER_BASE + userId, userObject.toString());
         response.setMessage("修改成功！");
+
+        ZjUser zjUser = new ZjUser();
+        zjUser.setUserId(userId);
+        zjUser.setNickName(nickName);
+        JSONObject object = new JSONObject();
+        object.put("type", "updateUser");
+        object.put("data", zjUser);
+        try {
+            RabbitMQUtil.sendMessage(object.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
     }
 
 }

incubator-game/src/main/java/com/incubator/game/handler/user/UpdatePhoneHandler.java

@@ -8,7 +8,10 @@ import com.incubator.core.net.ws.NetHandler;
 import com.incubator.core.net.ws.WSRequest;
 import com.incubator.core.net.ws.WSResponse;
 import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.data.entity.ZjUser;
+import com.incubator.game.data.entity.ZjUserLongin;
 import com.incubator.game.data.jedis.RedisUtil;
+import com.incubator.game.data.mq.RabbitMQUtil;
 import com.incubator.game.data.po.ZjUserLobbyPo;
 import com.incubator.message.proto.CommonProto;
 
@@ -36,5 +39,18 @@ public class UpdatePhoneHandler extends NetHandler {
         userObject.put("lobbyUser", lobbyUser);
         RedisUtil.set(RedisKeyConstant.USER_BASE + userId, userObject.toString());
         response.setMessage("修改成功！");
+
+        ZjUserLongin zjUserLongin = new ZjUserLongin();
+        zjUserLongin.setUserId(userId);
+        zjUserLongin.setName(name);
+        zjUserLongin.setPhoneNumber(phone);
+        JSONObject object = new JSONObject();
+        object.put("type", "updateUserLogin");
+        object.put("data", zjUserLongin);
+        try {
+            RabbitMQUtil.sendMessage(object.toString());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
     }
 }