修复

cmd/source/customer/customer.go

@@ -35,7 +35,7 @@ func Import(wg *sync.WaitGroup) {
 		err           error
 		err           error
 		customer      model.Customer
 		customer      model.Customer
 	)
 	)
-	excelFileName = "./cmd/source/data/customer.xlsx"
+	excelFileName = "../cmd/source/data/customer.xlsx"
 	xlFile, err = xlsx.OpenFile(excelFileName)
 	xlFile, err = xlsx.OpenFile(excelFileName)
 	if err != nil {
 	if err != nil {
 		fmt.Printf("open failed: %s\n", err)
 		fmt.Printf("open failed: %s\n", err)
@@ -71,6 +71,8 @@ func Import(wg *sync.WaitGroup) {
 				fmt.Println(err)
 				fmt.Println(err)
 			}
 			}
 			body := string(data)
 			body := string(data)
+			fmt.Println(body)
+			return
 			rabbitmq.Send(Exchange, body)
 			rabbitmq.Send(Exchange, body)
 		}
 		}
 	}
 	}

cmd/source/goods/goods.go

@@ -34,7 +34,7 @@ func Import(wg *sync.WaitGroup) {
 		err           error
 		err           error
 		goods         model.Goods
 		goods         model.Goods
 	)
 	)
-	excelFileName = "./cmd/source/data/goods.xlsx"
+	excelFileName = "../cmd/source/data/goods.xlsx"
 	xlFile, err = xlsx.OpenFile(excelFileName)
 	xlFile, err = xlsx.OpenFile(excelFileName)
 	if err != nil {
 	if err != nil {
 		fmt.Printf("open failed: %s\n", err)
 		fmt.Printf("open failed: %s\n", err)
@@ -67,6 +67,8 @@ func Import(wg *sync.WaitGroup) {
 				fmt.Println(err)
 				fmt.Println(err)
 			}
 			}
 			body := string(data)
 			body := string(data)
+			fmt.Println(body)
+			return
 			rabbitmq.Send(Exchange, body)
 			rabbitmq.Send(Exchange, body)
 		}
 		}
 	}
 	}

cmd/source/main.go

@@ -11,7 +11,7 @@ import (
 
 
 func main() {
 func main() {
 	var path string
 	var path string
-	flag.StringVar(&path, "config", "conf/config.ini", "conf/config.ini")
+	flag.StringVar(&path, "config", "../conf/config.ini", "conf/config.ini")
 	flag.Parse()
 	flag.Parse()
 	configs.Setup(path)
 	configs.Setup(path)
 	var wg sync.WaitGroup
 	var wg sync.WaitGroup

cmd/source/supplier/supplier.go

@@ -3,13 +3,14 @@ package supplier
 import (
 import (
 	"encoding/json"
 	"encoding/json"
 	"fmt"
 	"fmt"
-	"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
-	"github.com/tealeg/xlsx"
 	"scm_server/configs"
 	"scm_server/configs"
 	"scm_server/internal/logic"
 	"scm_server/internal/logic"
 	"scm_server/internal/model"
 	"scm_server/internal/model"
 	"scm_server/internal/service"
 	"scm_server/internal/service"
 	"sync"
 	"sync"
+
+	"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
+	"github.com/tealeg/xlsx"
 )
 )
 
 
 var Exchange rabbitmq.QueueExchange
 var Exchange rabbitmq.QueueExchange
@@ -37,7 +38,7 @@ func Import(wg *sync.WaitGroup) {
 		err           error
 		err           error
 		supplier      model.Supplier
 		supplier      model.Supplier
 	)
 	)
-	excelFileName = "./cmd/source/data/supplier.xlsx"
+	excelFileName = "../cmd/source/data/supplier.xlsx"
 	xlFile, err = xlsx.OpenFile(excelFileName)
 	xlFile, err = xlsx.OpenFile(excelFileName)
 	if err != nil {
 	if err != nil {
 		fmt.Printf("open failed: %s\n", err)
 		fmt.Printf("open failed: %s\n", err)
@@ -67,6 +68,8 @@ func Import(wg *sync.WaitGroup) {
 					fmt.Println(err)
 					fmt.Println(err)
 				}
 				}
 				body := string(data)
 				body := string(data)
+				fmt.Println(body)
+				return
 				rabbitmq.Send(Exchange, body)
 				rabbitmq.Send(Exchange, body)
 			}
 			}
 		}
 		}