将CMQ替换为rabbitmq

admin

2024-10-16 62a447d89331aee1feae7724c7616aa1bb2cfe79

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/TeamFansInfo.java

@@ -1,227 +1,283 @@
package com.yeshi.fanli.entity.bus.user;



import java.math.BigDecimal;

import java.util.Date;



import org.springframework.data.annotation.Id;

import org.springframework.data.mongodb.core.mapping.Document;

import org.springframework.data.mongodb.core.mapping.Field;



import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;



@Document(collection = "team_fans_info")

public class TeamFansInfo {



   @Id

   @Field("id")

   private String id;



   @Field("bossId")

   private Long bossId; // 上级id



   @Field("bossSuperId")

   private Long bossSuperId; // 上上级id



   @Field("workerId")

   private Long workerId; // 下级id



   @Field("nickName")

   private String nickName; // 昵称

	
   @Field("level")

   private UserLevelEnum level; // 当前等级



   @Field("stateValid")

   private Boolean stateValid; // 有效粉丝



   @Field("taobaoBind")

   private Boolean taobaoBind; // 绑定淘宝



   @Field("weixinBind")

   private Boolean weixinBind; // 绑定微信



   @Field("activeTime")

   private Date activeTime; // 活跃时间



   @Field("fansNum")

   private Integer fansNum; // 粉丝数量



   @Field("income")

   private BigDecimal income; // 账户收入



   @Field("incomeTime")

   private Date incomeTime; // 账户收入统计时间



   @Field("joinTime")

   private Date joinTime; // 邀请成功时间



   @Field("memoName")

   private String memoName; // 直接上级备注名



   @Field("tags")

   private String tags; // 直接上级标签



   @Field("memoNameSup")

   private String memoNameSup; // 间接上级备注名

	
	


   @Field("tagsSup")

   private String tagsSup; // 间接上级标签



   @Field("updateTime")

   private Date updateTime; // 更新时间



   public String getId() {

      return id;

   }



   public void setId(String id) {

      this.id = id;

   }



   public Long getBossId() {

      return bossId;

   }



   public void setBossId(Long bossId) {

      this.bossId = bossId;

   }



   public Long getBossSuperId() {

      return bossSuperId;

   }



   public void setBossSuperId(Long bossSuperId) {

      this.bossSuperId = bossSuperId;

   }



   public Long getWorkerId() {

      return workerId;

   }



   public void setWorkerId(Long workerId) {

      this.workerId = workerId;

   }



   public String getNickName() {

      return nickName;

   }



   public void setNickName(String nickName) {

      this.nickName = nickName;

   }



   public String getMemoName() {

      return memoName;

   }



   public void setMemoName(String memoName) {

      this.memoName = memoName;

   }



   public String getTags() {

      return tags;

   }



   public void setTags(String tags) {

      this.tags = tags;

   }



   public Boolean getStateValid() {

      return stateValid;

   }



   public void setStateValid(Boolean stateValid) {

      this.stateValid = stateValid;

   }



   public Boolean getTaobaoBind() {

      return taobaoBind;

   }



   public void setTaobaoBind(Boolean taobaoBind) {

      this.taobaoBind = taobaoBind;

   }



   public Boolean getWeixinBind() {

      return weixinBind;

   }



   public void setWeixinBind(Boolean weixinBind) {

      this.weixinBind = weixinBind;

   }



   public Date getActiveTime() {

      return activeTime;

   }



   public void setActiveTime(Date activeTime) {

      this.activeTime = activeTime;

   }



   public Integer getFansNum() {

      return fansNum;

   }



   public void setFansNum(Integer fansNum) {

      this.fansNum = fansNum;

   }



   public BigDecimal getIncome() {

      return income;

   }



   public void setIncome(BigDecimal income) {

      this.income = income;

   }



   public Date getIncomeTime() {

      return incomeTime;

   }



   public void setIncomeTime(Date incomeTime) {

      this.incomeTime = incomeTime;

   }



   public Date getUpdateTime() {

      return updateTime;

   }



   public void setUpdateTime(Date updateTime) {

      this.updateTime = updateTime;

   }



   public Date getJoinTime() {

      return joinTime;

   }



   public void setJoinTime(Date joinTime) {

      this.joinTime = joinTime;

   }



   public String getMemoNameSup() {

      return memoNameSup;

   }



   public void setMemoNameSup(String memoNameSup) {

      this.memoNameSup = memoNameSup;

   }



   public String getTagsSup() {

      return tagsSup;

   }



   public void setTagsSup(String tagsSup) {

      this.tagsSup = tagsSup;

   }



   public UserLevelEnum getLevel() {

      return level;

   }



   public void setLevel(UserLevelEnum level) {

      this.level = level;

   }



}

package com.yeshi.fanli.entity.bus.user;

import java.util.Date;

import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;

import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;

@Document(collection = "teamFansInfo")
public class TeamFansInfo {

   @Id
   @Field
   private String id;

   @Field
   @Indexed
   private Long bossId; // 上级id

   @Field
   @Indexed
   private Long bossSuperId; // 上上级id

   @Field
   @Indexed
   private Long workerId; // 下级id

   @Field
   private String nickName; // 昵称

   @Field
   private UserLevelEnum level; // 当前等级

   @Field
   private Boolean stateValid; // 有效粉丝

   @Field
   private Boolean taobaoBind; // 绑定淘宝

   @Field
   private String weixinId; // 微信号

   @Field
   private Boolean weixinIdExist; // 填写微信号

   @Field
   private String phone; // 电话号码

   @Field
   private Boolean phoneOpen; // 电话号码公开

   @Field
   private String inviteCode; // 邀请码

   @Field
   private Date activeTime; // 活跃时间

   @Field
   private Integer fansNum; // 粉丝数量

   @Field
   private Integer income; // 账户收入 乘以100

   @Field
   private Date incomeTime; // 账户收入统计时间

   @Field
   private Date joinTime; // 邀请成功时间

   @Field
   private String memoName; // 直接上级备注名

   @Field
   private String tags; // 直接上级标签

   @Field
   private String memoNameSup; // 间接上级备注名

   @Field
   private String tagsSup; // 间接上级标签

   @Field
   private Date crateTime; // 创建时间
	
   @Field
   private Date updateTime; // 更新时间

   public String getId() {
      return id;
   }

   public void setId(String id) {
      this.id = id;
   }

   public Long getBossId() {
      return bossId;
   }

   public void setBossId(Long bossId) {
      this.bossId = bossId;
   }

   public Long getBossSuperId() {
      return bossSuperId;
   }

   public void setBossSuperId(Long bossSuperId) {
      this.bossSuperId = bossSuperId;
   }

   public Long getWorkerId() {
      return workerId;
   }

   public void setWorkerId(Long workerId) {
      this.workerId = workerId;
   }

   public String getNickName() {
      return nickName;
   }

   public void setNickName(String nickName) {
      this.nickName = nickName;
   }

   public UserLevelEnum getLevel() {
      return level;
   }

   public void setLevel(UserLevelEnum level) {
      this.level = level;
   }

   public Boolean getStateValid() {
      return stateValid;
   }

   public void setStateValid(Boolean stateValid) {
      this.stateValid = stateValid;
   }

   public Boolean getTaobaoBind() {
      return taobaoBind;
   }

   public void setTaobaoBind(Boolean taobaoBind) {
      this.taobaoBind = taobaoBind;
   }

   public String getWeixinId() {
      return weixinId;
   }

   public void setWeixinId(String weixinId) {
      this.weixinId = weixinId;
   }

   public Boolean getWeixinIdExist() {
      return weixinIdExist;
   }

   public void setWeixinIdExist(Boolean weixinIdExist) {
      this.weixinIdExist = weixinIdExist;
   }

   public String getPhone() {
      return phone;
   }

   public void setPhone(String phone) {
      this.phone = phone;
   }

   public Boolean getPhoneOpen() {
      return phoneOpen;
   }

   public void setPhoneOpen(Boolean phoneOpen) {
      this.phoneOpen = phoneOpen;
   }

   public String getInviteCode() {
      return inviteCode;
   }

   public void setInviteCode(String inviteCode) {
      this.inviteCode = inviteCode;
   }

   public Date getActiveTime() {
      return activeTime;
   }

   public void setActiveTime(Date activeTime) {
      this.activeTime = activeTime;
   }

   public Integer getFansNum() {
      return fansNum;
   }

   public void setFansNum(Integer fansNum) {
      this.fansNum = fansNum;
   }

   public Integer getIncome() {
      return income;
   }

   public void setIncome(Integer income) {
      this.income = income;
   }

   public Date getIncomeTime() {
      return incomeTime;
   }

   public void setIncomeTime(Date incomeTime) {
      this.incomeTime = incomeTime;
   }

   public Date getJoinTime() {
      return joinTime;
   }

   public void setJoinTime(Date joinTime) {
      this.joinTime = joinTime;
   }

   public String getMemoName() {
      return memoName;
   }

   public void setMemoName(String memoName) {
      this.memoName = memoName;
   }

   public String getTags() {
      return tags;
   }

   public void setTags(String tags) {
      this.tags = tags;
   }

   public String getMemoNameSup() {
      return memoNameSup;
   }

   public void setMemoNameSup(String memoNameSup) {
      this.memoNameSup = memoNameSup;
   }

   public String getTagsSup() {
      return tagsSup;
   }

   public void setTagsSup(String tagsSup) {
      this.tagsSup = tagsSup;
   }

   public Date getUpdateTime() {
      return updateTime;
   }

   public void setUpdateTime(Date updateTime) {
      this.updateTime = updateTime;
   }

   public Date getCrateTime() {
      return crateTime;
   }

   public void setCrateTime(Date crateTime) {
      this.crateTime = crateTime;
   }

}