fix lack of result num

read.go

@@ -190,6 +190,7 @@ func (r *Read) Run(fn ImportFunc, num ...int) (results *Result, err error) {
 
 	var (
 		row         int
+		dataRow     int
 		headerFound bool
 	)
 	for r.rows.Next() {
@@ -211,6 +212,7 @@ func (r *Read) Run(fn ImportFunc, num ...int) (results *Result, err error) {
 		}
 
 		r.wg.Add(1)
+		dataRow++
 		// 向携程池提交任务
 		if err = r.concPool.Submit(func() {
 			r.exec(row, columns)
@@ -222,7 +224,7 @@ func (r *Read) Run(fn ImportFunc, num ...int) (results *Result, err error) {
 
 	r.wg.Wait()
 
-	r.results.totalRow = row - r.results.dataStartRow
+	r.results.totalRow = dataRow
 	r.results.errorRow = len(r.results.errors)
 
 	results = r.results

simulate_scenario_test/read_test.go

@@ -1,6 +1,7 @@
 package simulateTest
 
 import (
+	"errors"
 	"fmt"
 	"os"
 	"strings"
@@ -55,7 +56,8 @@ func Test_Batch_Read(t *testing.T) {
 	})
 
 	t.Run("each_business_cost_200ms_10_goroutine", func(t *testing.T) {
-		_, err = r.Run(func(any any) (err error) {
+		var rr *excelizex.Result
+		rr, err = r.Run(func(any any) (err error) {
 			b := any.(*batchData)
 			time.Sleep(200 * time.Millisecond)
 			fmt.Println(b)
@@ -66,17 +68,24 @@ func Test_Batch_Read(t *testing.T) {
 		if err != nil {
 			t.Error(err)
 		}
+
+		fmt.Println(rr.TotalNum())
+		fmt.Println(rr.ErrorNum())
 	})
 
 	t.Run("each_business_cost_200ms_100_goroutine", func(t *testing.T) {
-		if _, err = r.Run(func(any any) (err error) {
+		var rr *excelizex.Result
+		if rr, err = r.Run(func(any any) (err error) {
 			b := any.(*batchData)
 			time.Sleep(200 * time.Millisecond)
 			fmt.Println(b)
 
-			return
+			return errors.New("test")
 		}, 100); err != nil {
 			t.Error(err)
 		}
+
+		fmt.Println(rr.TotalNum())
+		fmt.Println(rr.ErrorNum())
 	})
 }