up

erp/main.go

@@ -24,6 +24,7 @@ type RecvPro struct {
 //// 实现消费者 消费消息失败 自动进入延时尝试  尝试3次之后入库db
 //// 实现消费者 消费消息失败 自动进入延时尝试  尝试3次之后入库db
 func (t *RecvPro) Consumer(dataByte []byte) error {
 func (t *RecvPro) Consumer(dataByte []byte) error {
 	logger.Info(string(dataByte))
 	logger.Info(string(dataByte))
+	fmt.Println(string(dataByte))
 	error := label.AddTemplateRelations(dataByte)
 	error := label.AddTemplateRelations(dataByte)
 	return error
 	return error
 }
 }
@@ -86,7 +87,7 @@ func main() {
 	initDb("InitCmsDB",util.Configs.Liexincms_databases.Dns)
 	initDb("InitCmsDB",util.Configs.Liexincms_databases.Dns)
 
 
 	t := &RecvPro{}
 	t := &RecvPro{}
-
+fmt.Println("123")
 
 
 	rabbitmq.Recv(rabbitmq.QueueExchange{
 	rabbitmq.Recv(rabbitmq.QueueExchange{
 		util.Configs.Rabbitmq_erp_label.QueueName,
 		util.Configs.Rabbitmq_erp_label.QueueName,