增加通知主题

global/topic.go

@@ -1,7 +1,8 @@
 package global
 
 var (
-	TOPIC_THJ_NTF = "thj_ntf" // 铁合金服务通知
+	TOPIC_THJ_NTF = "thj_ntf"    // 铁合金服务通知
+	TOPIC_RSP_NTF = "notify_rsp" // 回报主题
 
 	TOPIC_MANAGER_THJ_NTF = "manager_thj_ntf" // 铁合金服务通知（管理端专用）
 )

service/common.go

@@ -17,10 +17,10 @@ func InitRabbitMQMsgPreccesser() (err error) {
 	// global.M2A_MSGPROCESSER[global.TOPIC_THJ_NTF] = &t
 	t := new(THJNtf)
 	global.M2A_MSGPROCESSER[global.TOPIC_THJ_NTF] = t
+	global.M2A_MSGPROCESSER[global.TOPIC_RSP_NTF] = t
 
 	// 铁合金服务通知（管理端专用）
-	t1 := new(THJNtf)
-	global.M2A_MSGPROCESSER[global.TOPIC_MANAGER_THJ_NTF] = t1
+	global.M2A_MSGPROCESSER[global.TOPIC_MANAGER_THJ_NTF] = t
 
 	return
 }