Cold_Api/Nats/NatsServer/NatsWx.go

package NatsServer

import (
	"Cold_Api/controllers/lib"
	"Cold_Api/logs"
	"fmt"
	"time"
)

func Wx_GenerateQRCode(DeviceClass_id string) (string, bool) {
	logs.Println(" => Nats", lib.FuncName(), DeviceClass_id)

	// 请求-响应， 向 test3 发布一个 `help me` 请求数据，设置超时间3秒，如果有多个响应，只接收第一个收到的消息
	msg, err := lib.Nats.Request("Wx_GenerateQR", []byte(DeviceClass_id), 3*time.Second)
	if err != nil {
		fmt.Println(err)
	} else {
		fmt.Printf("Wx_GenerateQR : %s\n", string(msg.Data))
		return string(msg.Data), true
	}

	return string(msg.Data), false
}

func Wx_GenerateQRCode2(DeviceClass_id string) (string, bool) {
	logs.Println(" => Nats", lib.FuncName(), DeviceClass_id)

	// 请求-响应， 向 test3 发布一个 `help me` 请求数据，设置超时间3秒，如果有多个响应，只接收第一个收到的消息
	msg, err := lib.Nats.Request("Wx2_GenerateQR", []byte(DeviceClass_id), 3*time.Second)
	if err != nil {
		fmt.Println(err)
	} else {
		fmt.Printf("Wx2_GenerateQR : %s\n", string(msg.Data))
		return string(msg.Data), true
	}

	return string(msg.Data), false
}