update

consume/dou_shen_user_register_for_my_my_fans.go

@@ -43,6 +43,14 @@ func DouShenUserRegisterConsumeForMyFans(queue md.MqQueue) {
 			if err != nil {
 				fmt.Println("!!!!!!!err!!!!!!!", err)
 				_ = res.Reject(false)
+
+				utils2.FilePutContents("douShenUserRegisterConsumeForMyFans_err", "[err]:"+err.Error())
+				if err.Error() == "用户暂未注册im系统" {
+					//TODO::重新推回队列末尾，避免造成队列堵塞
+					var msg *md.DouShenUserRegisterMessageStructForMyFans
+					json.Unmarshal(res.Body, &msg)
+					ch.Publish(queue.ExchangeName, msg, queue.RoutKey)
+				}
 			} else {
 				_ = res.Ack(true)
 			}

consume/dou_shen_user_register_for_my_my_recommender.go

@@ -4,6 +4,7 @@ import (
 	"applet/app/cfg"
 	"applet/app/db"
 	db2 "applet/app/db/gim"
+	utils2 "applet/app/utils"
 	"applet/app/utils/logx"
 	utils "applet/app/utils/rpc"
 	"applet/consume/md"
@@ -41,6 +42,14 @@ func DouShenUserRegisterConsumeForMyRecommender(queue md.MqQueue) {
 			if err != nil {
 				fmt.Println("!!!!!!!err!!!!!!!", err)
 				_ = res.Reject(false)
+
+				utils2.FilePutContents("douShenUserRegisterConsumeForMyRecommender_err", "[err]:"+err.Error())
+				if err.Error() == "用户暂未注册im系统" {
+					//TODO::重新推回队列末尾，避免造成队列堵塞
+					var msg *md.DouShenUserRegisterMessageStructForMyRecommender
+					json.Unmarshal(res.Body, &msg)
+					ch.Publish(queue.ExchangeName, msg, queue.RoutKey)
+				}
 			} else {
 				_ = res.Ack(true)
 			}

consume/dou_shen_user_register_for_official_consume.go

@@ -5,6 +5,7 @@ import (
 	"applet/app/db"
 	db2 "applet/app/db/gim"
 	"applet/app/db/model"
+	utils2 "applet/app/utils"
 	"applet/app/utils/logx"
 	utils "applet/app/utils/rpc"
 	"applet/consume/md"
@@ -42,6 +43,14 @@ func DouShenUserRegisterConsumeForOfficial(queue md.MqQueue) {
 			if err != nil {
 				fmt.Println("!!!!!!!err!!!!!!!", err)
 				_ = res.Reject(false)
+
+				utils2.FilePutContents("douShenUserRegisterConsumeForOfficial_err", "[err]:"+err.Error())
+				if err.Error() == "用户暂未注册im系统" {
+					//TODO::重新推回队列末尾，避免造成队列堵塞
+					var msg *md.DouShenUserRegisterMessageStructForOfficial
+					json.Unmarshal(res.Body, &msg)
+					ch.Publish(queue.ExchangeName, msg, queue.RoutKey)
+				}
 			} else {
 				_ = res.Ack(true)
 			}

consume/dou_shen_user_register_for_operation_center.go

@@ -43,6 +43,14 @@ func DouShenUserRegisterConsumeForOperationCenter(queue md.MqQueue) {
 			if err != nil {
 				fmt.Println("!!!!!!!err!!!!!!!", err)
 				_ = res.Reject(false)
+
+				utils2.FilePutContents("douShenUserRegisterConsumeForOperationCenter_err", "[err]:"+err.Error())
+				if err.Error() == "用户暂未注册im系统" {
+					//TODO::重新推回队列末尾，避免造成队列堵塞
+					var msg *md.DouShenUserRegisterMessageStructForOperationCenter
+					json.Unmarshal(res.Body, &msg)
+					ch.Publish(queue.ExchangeName, msg, queue.RoutKey)
+				}
 			} else {
 				_ = res.Ack(true)
 			}