调试代码

app/queue/supplier.go

@@ -27,6 +27,7 @@ func init() {
 
 
 func (t *RecvPro) Consumer(dataByte []byte) (err error) {
 func (t *RecvPro) Consumer(dataByte []byte) (err error) {
 	message := string(dataByte)
 	message := string(dataByte)
+	fmt.Println(message)
 	supplierCode := gjson.Get(message, "PTID").String()
 	supplierCode := gjson.Get(message, "PTID").String()
 	erpSupplierCode := gjson.Get(message, "supplierNumber").String()
 	erpSupplierCode := gjson.Get(message, "supplierNumber").String()
 	erpSupplierName := gjson.Get(message, "supplierName").String()
 	erpSupplierName := gjson.Get(message, "supplierName").String()

cmd/main.go

@@ -5,17 +5,18 @@ import (
 	"go_supplier_sever/app/queue"
 	"go_supplier_sever/app/queue"
 	"go_supplier_sever/boot"
 	"go_supplier_sever/boot"
 )
 )
+
 var (
 var (
 	configPath string
 	configPath string
 	logPath    string
 	logPath    string
 )
 )
-func main(){
+
+func main() {
 	flag.StringVar(&configPath, "config", "./config/dev/", "配置文件")
 	flag.StringVar(&configPath, "config", "./config/dev/", "配置文件")
 	flag.StringVar(&logPath, "logdir", "./logs/", "日志文件存储目录")
 	flag.StringVar(&logPath, "logdir", "./logs/", "日志文件存储目录")
 	flag.Parse()
 	flag.Parse()
 
 
-	boot.Init(configPath,logPath)
-
+	boot.Init(configPath, logPath)
 	queue.Run()
 	queue.Run()
 
 
 }
 }