更新mq

configs/config.go

@@ -155,15 +155,15 @@ func init() {
 	}
 	supply.InitSupply(supply.Config{
 		Url:       "https://supply_api.reecook.cn/supply",
-		AppKey:    "33jTu4x683dEA3U3wiPj60RfZ1KIMQCq",
+		AppKey:    "u0zPiIEZwMnmVdu20zZ1jAV931K5lMWM",
-		AppSecret: "wCWFon9CbP7KEFbczZ2wT8CcSRCKSdhSFIFK34e2jwlqm3dg5JGy1qlhTJwqllcs",
+		AppSecret: "494lfrgeLIkzKHNf6R1V5jc0SKmlHPMHFrvdUhIemqBbAsFFZjkOkvCCoKSttEZo",
 	})
 
 	rabbitmq.InitRabbitmq(rabbitmq.Config{
 		Host:     "supply_api.reecook.cn",
 		Port:     5672,
-		User:     "33jTu4x683dEA3U3wiPj60RfZ1KIMQCq",
+		User:     "u0zPiIEZwMnmVdu20zZ1jAV931K5lMWM",
-		Password: "wCWFon9CbP7KEFbczZ2wT8CcSRCKSdhSFIFK34e2jwlqm3dg5JGy1qlhTJwqllcs",
+		Password: "dfbfe3da92d363727a1e0bca612e40a4",
 	})
 	//rabbitmq.InitRabbitmq("127.0.0.1", 5672, "33jTu4x683dEA3U3wiPj60RfZ1KIMQCq", "wCWFon9CbP7KEFbczZ2wT8CcSRCKSdhSFIFK34e2jwlqm3dg5JGy1qlhTJwqllcs")
 }

internal/v2/lib/supply/api.go

@@ -9,6 +9,7 @@ import (
 	"fmt"
 	"github.com/google/uuid"
 	"github.com/mitchellh/mapstructure"
+	"log"
 	"strconv"
 	"time"
 )
@@ -61,6 +62,7 @@ func exec(action string, data interface{}, result interface{}) error {
 	if err != nil {
 		return err
 	}
+	log.Println(string(bytes))
 	res := resp{}
 	json.Unmarshal(bytes, &res)
 	if res.Code == 200 {

internal/v2/lib/supply/mq.go

@@ -19,6 +19,9 @@ const (
 	// queueOrderFinish 订单出库
 	queueOrderFinish = "supplyOrderFinish:%s"
 
+	// 订阅地址
+	mqSubscribe = "/mq/subscribe" // 订阅mq
+
 	OrderCancelSuccess = 1 // 取消成功
 	OrderCancelFail    = 2 // 取消失败
 	OrderCancelReject  = 3 // 拒收/商家主动取消
@@ -27,6 +30,15 @@ const (
 type mq struct {
 }
 
+// Subscribe @Title 订阅mq
+func (m *mq) Subscribe(name string) (err error) {
+	var reply interface{}
+	err = exec(mqSubscribe, map[string]string{
+		"name": name,
+	}, &reply)
+	return
+}
+
 type skuMessage struct {
 	SkuId uint `json:"skuId"`
 }