Commit 0efd3c63 by 孙龙

up

parent 8a639d01
Showing with 0 additions and 7 deletions
...@@ -28,16 +28,13 @@ func Init(dns string) error { ...@@ -28,16 +28,13 @@ func Init(dns string) error {
} }
func InitLabelDB(dns string) error{ func InitLabelDB(dns string) error{
fmt.Println(666)
var err error var err error
LabelDB, err = sqlx.Open("mysql", dns) LabelDB, err = sqlx.Open("mysql", dns)
fmt.Println(err)
if err != nil { if err != nil {
return err return err
} }
err = LabelDB.Ping() err = LabelDB.Ping()
fmt.Println(err)
if err != nil { if err != nil {
return err return err
} }
...@@ -63,8 +60,6 @@ func InitCmslDB(dns string) error{ ...@@ -63,8 +60,6 @@ func InitCmslDB(dns string) error{
} }
func CreateDB(action string,dns string) error{ func CreateDB(action string,dns string) error{
fmt.Println(action)
fmt.Println(dns)
var err error var err error
switch action { switch action {
case "Init": case "Init":
......
...@@ -24,7 +24,6 @@ type RecvPro struct { ...@@ -24,7 +24,6 @@ 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
} }
...@@ -88,7 +87,6 @@ func main() { ...@@ -88,7 +87,6 @@ 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,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment