From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:28:37 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq

---
 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/TeamFansInfo.java |  551 ++++++++++++++++++++++++++++--------------------------
 1 files changed, 283 insertions(+), 268 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/entity/bus/user/TeamFansInfo.java b/fanli/src/main/java/com/yeshi/fanli/entity/bus/user/TeamFansInfo.java
index ac9098f..351a552 100644
--- a/fanli/src/main/java/com/yeshi/fanli/entity/bus/user/TeamFansInfo.java
+++ b/fanli/src/main/java/com/yeshi/fanli/entity/bus/user/TeamFansInfo.java
@@ -1,268 +1,283 @@
-package com.yeshi.fanli.entity.bus.user;
-
-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 = "teamFansInfo")
-public class TeamFansInfo {
-
-	@Id
-	@Field
-	private String id;
-
-	@Field
-	private Long bossId; // 涓婄骇id
-
-	@Field
-	private Long bossSuperId; // 涓婁笂绾d
-
-	@Field
-	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 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;
-	}
-
-}
+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; // 涓婁笂绾d
+
+	@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;
+	}
+
+}

--
Gitblit v1.8.0