2023-10-12

Nats/NatsERP_user.go

@@ -21,7 +21,7 @@ func (m *NatsImpl) Verification(GetCookie string, GetString string) (userlibs.Us
 		return user, errors.New("user tokey is null")
 	}
 	// 请求-响应， 向 verification 发布一个 `ToKey` 请求数据，设置超时间3秒，如果有多个响应，只接收第一个收到的消息
-	msg, err := m.nats.Request("ERP_User_verification", []byte(User_tokey), 3*time.Second)
+	msg, err := m.nats.Request(m.NatsSubj_Prefix+"ERP_User_verification", []byte(User_tokey), 3*time.Second)
 	if err != nil {
 		return user, err
 	}
@@ -46,7 +46,7 @@ func (m *NatsImpl) Verification(GetCookie string, GetString string) (userlibs.Us
 }
 
 func (m *NatsImpl) Read_User_List_All() (list []userlibs.User, err error) {
-	msg, err := m.nats.Request("ERP_User_Read_User_List_All", []byte(""), 3*time.Second)
+	msg, err := m.nats.Request(m.NatsSubj_Prefix+"ERP_User_Read_User_List_All", []byte(""), 3*time.Second)
 	if err != nil {
 		return list, err
 	}
@@ -78,7 +78,7 @@ func (m *NatsImpl) Read_User_List_T_uuid(T_name string, T_uuid_list []string, pa
 	}
 	b, _ := msgpack.Marshal(&T_S{T_uuid: T_uuid_list, T_name: T_name, Page: page, Page_z: page_z})
 
-	msg, err := m.nats.Request("ERP_User_Read_User_List_T_uuid", b, 3*time.Second)
+	msg, err := m.nats.Request(m.NatsSubj_Prefix+"ERP_User_Read_User_List_T_uuid", b, 3*time.Second)
 	if err != nil {
 		return list, cnt, err
 	}
@@ -102,7 +102,7 @@ func (m *NatsImpl) Read_User_List_T_uuid(T_name string, T_uuid_list []string, pa
 }
 
 func (m *NatsImpl) Read_Power_List_All() (list []powerlibs.Power_R, err error) {
-	msg, err := m.nats.Request("ERP_User_Read_Power_List_All", []byte(""), 3*time.Second)
+	msg, err := m.nats.Request(m.NatsSubj_Prefix+"ERP_User_Read_Power_List_All", []byte(""), 3*time.Second)
 	if err != nil {
 		return list, err
 	}
@@ -137,7 +137,7 @@ func (m *NatsImpl) AddSysLogs(T_class, T_title string, T_txt interface{}) {
 	}
 	b, _ := msgpack.Marshal(&T_S{T_class: T_class, T_title: T_title, T_txt: string(jsonStu)})
 	// 发布-订阅 模式，向 test1 发布一个 `Hello World` 数据
-	_ = m.nats.Publish("ERP_AddSysLogs", b)
+	_ = m.nats.Publish(m.NatsSubj_Prefix+"ERP_AddSysLogs", b)
 
 }
 
@@ -154,7 +154,7 @@ func (m *NatsImpl) AddUserLogs(T_uuid, T_class, T_title string, T_txt interface{
 	}
 	b, _ := msgpack.Marshal(&T_S{T_uuid: T_uuid, T_class: T_class, T_title: T_title, T_txt: string(jsonStu)})
 	// 发布-订阅 模式，向 test1 发布一个 `Hello World` 数据
-	_ = m.nats.Publish("ERP_AddUserLogs", b)
+	_ = m.nats.Publish(m.NatsSubj_Prefix+"ERP_AddUserLogs", b)
 
 }
 
@@ -168,6 +168,6 @@ func (m *NatsImpl) AddNews(T_uuid, T_title, T_Url string) {
 	}
 	b, _ := msgpack.Marshal(&T_S{T_uuid: T_uuid, T_Title: T_title, T_Url: T_Url})
 	// 发布-订阅 模式，向 test1 发布一个 `Hello World` 数据
-	_ = m.nats.Publish("ERP_AddNews", b)
+	_ = m.nats.Publish(m.NatsSubj_Prefix+"ERP_AddNews", b)
 
 }

Nats/nats.go

@@ -2,10 +2,11 @@ package NatsServer
 
 import "github.com/nats-io/nats.go"
 
-func NewNats(nats *nats.Conn) NatsImpl {
-	return NatsImpl{nats: nats}
+func NewNats(nats *nats.Conn, NatsSubj_Prefix string) NatsImpl {
+	return NatsImpl{nats: nats, NatsSubj_Prefix: NatsSubj_Prefix}
 }
 
 type NatsImpl struct {
-	nats *nats.Conn
+	nats            *nats.Conn
+	NatsSubj_Prefix string
 }