更新广钻出境保税主题

global/topic.go

@@ -22,6 +22,9 @@ var (
 	TOPIC_REQ_WAREHOUSE_TRADE_GZ = "warehouse_trade_gz_req" // 广钻仓单贸易请求
 	TOPIC_RSP_WAREHOUSE_TRADE_GZ = "warehouse_trade_gz_rsp" // 广钻仓单贸易响应
 
+	TOPIC_REQ_CJBS_TRADE_GZ = "cjbs_trade_gz_req" // 广钻出境保税请求
+	TOPIC_RSP_CJBS_TRADE_GZ = "cjbs_trade_gz_rsp" // 广钻出境保税响应
+
 	TOPIC_REQ_WAREHOUSE_PRESALE_THJ = "warehouse_presale_thj_req" // 掌上铁合金现货预售请求
 	TOPIC_RSP_WAREHOUSE_PRESALE_THJ = "warehouse_presale_thj_rsp" // 掌上铁合金现货预售响应
 

initialize/rabbitmq.go

@@ -457,6 +457,10 @@ func RabbitMQSubscribeTopic() (err error) {
 		global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
 		return
 	}
+	if err = global.SubscribeTopic(global.TOPIC_RSP_CJBS_TRADE_GZ); err != nil {
+		global.M2A_LOG.Error("rabbitmq subscribe topic failed, err:", zap.Error(err))
+		return
+	}
 
 	// 铁合金
 	if err = global.SubscribeTopic(global.TOPIC_RSP_WAREHOUSE_PRESALE_THJ); err != nil {
@@ -528,6 +532,8 @@ func InitFuncodeTopic() {
 		global.ZSSellOrderDestingApplyOperateReq,
 		global.ZSBuyOrderDestingNegPriceReq,
 		global.ZSBuyOrderDestingNegPriceOperateReq,
+	}
+	global.M2A_FuncodeTopic[global.TOPIC_REQ_CJBS_TRADE_GZ] = []int{
 		global.CJJCMemberOperateReq,
 		global.BSFWMemberOperateReq,
 	}