增加怡亚通队列

common.go

@@ -1,5 +1,9 @@
 package rabbitmqrpc
 
+import (
+	"git.tetele.net/tgo/conf"
+)
+
 const DES_KEY = "mqbitrab"
 
 type MsgBody struct {
@@ -152,11 +156,16 @@ const CHANNEL_ORDER_ASKPAY_QUEUE = "channel_order_askpay_queue"
 
 func rpc_server_conn(url ...string) (*RabbitmqServiceClient, error) {
 
-	var wx_rpc_url string = "127.0.0.1:7955"
+	var rpc_url string
 	if len(url) > 0 && url[0] != "" {
-		wx_rpc_url = url[0]
+		rpc_url = url[0]
+	} else if conf.RABBITMQ_RPC_URL != "" {
+		rpc_url = conf.RABBITMQ_RPC_URL
+	} else {
+		rpc_url = "127.0.0.1:" + conf.RABBITMQ_RPC_PORT
 	}
-	conn, _, err := DialRabbitmqService("tcp", wx_rpc_url)
+
+	conn, _, err := DialRabbitmqService("tcp", rpc_url)
 	if err != nil {
 		return nil, err
 	}

const_v2.go

@@ -0,0 +1,21 @@
+package rabbitmqrpc
+
+//v2
+
+//订单路由
+const ORDER_EXCHANGE_V2 string = "ex_order_v2"
+
+//已创建订单route key
+const ORDER_CREATED_KEY_V2 string = "created_v2"
+
+//订单已创建队列，订单服务用
+const ORDER_CREATED_QUEUE_V2 = "order_created_queue_v2"
+
+//已支付订单route key
+const ORDER_PAYED_KEY_V2 string = "payed_v2"
+
+//订单已支付队列，订单服务用
+const ORDER_PAYED_QUEUE_V2 = "order_payed_queue_v2"
+
+//怡亚通订单已支付队列，怡亚通订单服务用
+const ORDER_PAYED_QUEUE_V2_380STAR = "order_payed_queue_v2_380star"

go.mod

@@ -3,6 +3,7 @@ module git.tetele.net/tgo/rabbitmqrpc
 go 1.14
 
 require (
+	git.tetele.net/tgo/conf v0.38.0 // indirect
 	git.tetele.net/tgo/crypter v0.2.2 // indirect
 	github.com/chai2010/protorpc v1.0.0 // indirect
 	github.com/golang/protobuf v1.5.2 // indirect

go.sum

@@ -1,3 +1,5 @@
+git.tetele.net/tgo/conf v0.38.0 h1:mqiljzhjY9SbTmS2yL8p5clrTkkiD5JzeLrG1FT+gHM=
+git.tetele.net/tgo/conf v0.38.0/go.mod h1:AWVIBEDE5dtotthUgR0SWaR2Qa6/f+O5WQ3s7Tj8q7A=
 git.tetele.net/tgo/crypter v0.2.2 h1:YMQJh2Gj5Po4ZfelJUmXBKi01UbmtiSy3bmqRfnYQMo=
 git.tetele.net/tgo/crypter v0.2.2/go.mod h1:vfvRLZA8+lHNgNXneOcgvVhDyuv25ZRb+C6xHOmXNx0=
 github.com/chai2010/protorpc v1.0.0 h1:aJ45G9sl1utSKo35EqnBSTs5jqTpdJDJAuZMMYPAtFo=