tgo
/
rabbitmqrpc


								package rabbitmqrpc


								import (

									"git.tetele.net/tgo/conf"

								)


								const DES_KEY = "mqbitrab"


								type MsgBody struct {

									Exchange string

									Key      string

									Data     string

								}

								type DelayMsgBody struct {

									Exchange string

									Key      string

									Data     string

									Delay    int64

								}

								type MsgSend struct {

									Result string

								}


								//订单路由

								const ORDER_EXCHANGE string = "ex_order"


								//已创建订单route key

								const ORDER_CREATED_KEY string = "created"


								//订单已创建队列，订单服务用

								const ORDER_CREATED_QUEUE = "order_created_queue"


								//已创建订单队列，串货服务用

								const CHANNEL_ORDER_CREATED_QUEUE = "channel_order_created_queue"


								//已支付订单route key

								const ORDER_PAYED_KEY string = "payed"


								//订单已支付队列，订单服务用

								const ORDER_PAYED_QUEUE = "order_payed_queue"


								//订单已支付队列，串货服务用

								const CHANNEL_ORDER_PAYED_QUEUE = "channel_order_payed_queue"


								//订单已支付队列，配送服务用

								const DELIVERY_ORDER_PAYED_QUEUE = "delivery_order_payed_queue"


								//订单已支付队列，打印服务用

								const PRINT_ORDER_PAYED_QUEUE = "print_order_payed_queue"


								//订单状态更新route key

								const ORDER_STATUS_CHANGE_KEY string = "status_change"


								//订单状态更新队列，订单服务用

								const ORDER_STATUS_UPDATE_QUEUE = "order_status_update_queue"


								//订单状态更新，串货服务用

								const CHANNEL_ORDER_STATUS_CHANGE_QUEUE = "channel_order_update_status"


								//订单取消route key

								const ORDER_CANCELED_KEY string = "canceled"


								//订单取消队列，订单服务用

								const ORDER_CANCELED_QUEUE = "order_canceled_queue"


								//订单取消队列，串货服务用

								const CHANNEL_ORDER_CANCELED_QUEUE = "channel_order_canceled_queue"


								//订单发货route key

								const ORDER_DELIVERED_KEY string = "delivered"


								//订单发货队列，订单服务用

								const ORDER_DELIVERED_QUEUE = "order_delivered_queue"


								//订单发货队列，串货服务用

								const CHANNEL_ORDER_DELIVERED_QUEUE = "channel_order_delivered_queue"


								//订单收货route key

								const ORDER_RECEIVED_KEY string = "received"


								//订单取消队列，订单服务用

								const ORDER_RECEIVED_QUEUE = "order_received_queue"


								//订单取消队列，串货服务用

								const CHANNEL_ORDER_RECEIVED_QUEUE = "channel_order_received_queue"


								//订单退款route key

								const ORDER_REFUNDED_KEY string = "refunded"


								//订单退款队列，订单服务用

								const ORDER_REFUNDED_QUEUE = "order_refunded_queue"


								//订单退款队列，串货服务用

								const CHANNEL_ORDER_REFUNDED_QUEUE = "channel_order_refunded_queue"


								//订单完成route key

								const ORDER_FINISHED_KEY string = "finished"


								//订单退款队列，订单服务用

								const ORDER_FINISHED_QUEUE = "order_finished_queue"


								//订单退款队列，串货服务用

								const CHANNEL_ORDER_FINISHED_QUEUE = "channel_order_finished_queue"


								//订单等待创建key，订单服务用

								const ORDER_ADD_KEY = "add"


								//订单等待创建队列，订单服务用

								const ORDER_ADD_QUEUE = "order_add_queue"


								//订单核销key

								const ORDER_VERIFY_KEY = "verify"


								//订单核销打印队列，打印服务用

								const PRINT_ORDER_VERIFY_QUEUE = "print_order_verify_queue"


								//订单延迟队列路由

								const ORDER_DELAY_EXCHANGE string = "ex_order_delay"


								//未支付订单过期自动取消key

								const ORDER_AUTO_CANCEL_KEY string = "order_auto_cancel"


								//未支付订单过期自动取消队列

								const ORDER_AUTO_CANCEL_QUEUE string = "order_auto_cancel_queue"


								//未支付订单过期自动取消队列，串货服务用

								const CHANNEL_ORDER_AUTO_CANCEL_QUEUE string = "channel_order_auto_cancel_queue"


								//订单发货后到期自动收货key

								const ORDER_AUTO_RECEIVE_KEY string = "order_auto_received"


								//订单发货后到期自动收货队列

								const ORDER_AUTO_RECEIVE_QUEUE string = "order_auto_receive_queue"


								//订单自动收货队列，串货服务用

								const CHANNEL_ORDER_AUTO_RECEIVE_QUEUE string = "channel_order_auto_receive_queue"


								//订单申请退款消息key

								const ORDER_ASK_FOR_REFUND_KEY string = "order_ask_for_refund"


								//订单申请退款消息队列

								const ORDER_ASK_FOR_REFUND_QUEUE string = "order_ask_for_refund_queue"


								//订单申请退款队列，串货服务用

								const CHANNEL_ORDER_ASK_FOR_REFUND_QUEUE string = "channel_order_ask_for_refund_queue"


								// --串货--

								//串货订单路由

								const CHANNEL_ORDER_EXCHANGE string = "ex_channel_order"


								//串货订单请求支付route key

								const CHANNEL_ORDER_ASKPAY_KEY = "channel_order_askpay"


								//订单请求支付队列，串货服务用

								const CHANNEL_ORDER_ASKPAY_QUEUE = "channel_order_askpay_queue"


								func rpc_server_conn(url ...string) (*RabbitmqServiceClient, error) {


									var rpc_url string

									if len(url) > 0 && 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", rpc_url)

									if err != nil {

										return nil, err

									}


									return conn, nil

								}