增加“铁合金服务通知（管理端专用）”业务

global/topic.go

@@ -2,4 +2,6 @@ package global
 
 var (
 	TOPIC_THJ_NTF = "thj_ntf" // 铁合金服务通知
+
+	TOPIC_MANAGER_THJ_NTF = "manager_thj_ntf" // 铁合金服务通知（管理端专用）
 )

main.go

@@ -32,10 +32,10 @@ func main() {
 	} else {
 		return
 	}
-	// 开始向总线创建和绑定队列
-	service.StartRabbitMQSubscribe()
 	// 构建总线信息处理器
 	service.InitRabbitMQMsgPreccesser()
+	// 开始向总线创建和绑定队列
+	service.StartRabbitMQSubscribe()
 	// 开始接收总线消息
 	service.StartRabbitMQReceive()
 

service/common.go

@@ -18,15 +18,27 @@ func InitRabbitMQMsgPreccesser() (err error) {
 	t := new(THJNtf)
 	global.M2A_MSGPROCESSER[global.TOPIC_THJ_NTF] = t
 
+	// 铁合金服务通知（管理端专用）
+	t1 := new(THJNtf)
+	global.M2A_MSGPROCESSER[global.TOPIC_MANAGER_THJ_NTF] = t1
+
 	return
 }
 
 // StartRabbitMQSubscribe 开始向总线创建和绑定队列
 func StartRabbitMQSubscribe() (err error) {
 	// 订阅需要的总线主题
-	if err = subscribeTopic(global.TOPIC_THJ_NTF); err != nil {
-		global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
-		return
+	// if err = subscribeTopic(global.TOPIC_THJ_NTF); err != nil {
+	// 	global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
+	// 	return
+	// }
+
+	// 订阅需要的总线主题
+	for key := range global.M2A_MSGPROCESSER {
+		if err = subscribeTopic(key); err != nil {
+			global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
+			return
+		}
 	}
 	global.M2A_LOG.Info("rabbitmq subscribe topic success.")