添加异常退出恢复判断

cmd/queue/main.go

+package main

cmd/queue/sync_goods/main.go

@@ -191,5 +191,5 @@ func main() {
 		"store",
 		"store",
 		"direct",
 		"direct",
 		configs.RABBITMQDSN,
 		configs.RABBITMQDSN,
-	}, t, 1)
+	}, t, 3)
 }
 }

cmd/source/customer/customer.go

@@ -24,7 +24,12 @@ func init() {
 	}
 	}
 }
 }
 func Import(wg *sync.WaitGroup) {
 func Import(wg *sync.WaitGroup) {
-	defer wg.Done()
+	defer func() {
+		if err := recover(); err != nil {
+			fmt.Println(err)
+		}
+		wg.Done()
+	}()
 	var (
 	var (
 		excelFileName string
 		excelFileName string
 		xlFile        *xlsx.File
 		xlFile        *xlsx.File

cmd/source/goods/goods.go

@@ -26,7 +26,12 @@ func init() {
 
 
 //导入委托方的信息(excel导入)
 //导入委托方的信息(excel导入)
 func Import(wg *sync.WaitGroup) {
 func Import(wg *sync.WaitGroup) {
-	defer wg.Done()
+	defer func() {
+		if err := recover(); err != nil {
+			fmt.Println(err)
+		}
+		wg.Done()
+	}()
 	var (
 	var (
 		excelFileName string
 		excelFileName string
 		xlFile        *xlsx.File
 		xlFile        *xlsx.File

cmd/source/supplier/supplier.go

@@ -26,7 +26,12 @@ func init() {
 
 
 //导入委托方的信息(excel导入)
 //导入委托方的信息(excel导入)
 func Import(wg *sync.WaitGroup) {
 func Import(wg *sync.WaitGroup) {
-	defer wg.Done()
+	defer func() {
+		if err := recover(); err != nil {
+			fmt.Println(err)
+		}
+		wg.Done()
+	}()
 	var (
 	var (
 		excelFileName string
 		excelFileName string
 		xlFile        *xlsx.File
 		xlFile        *xlsx.File