- avoid nil TaskError

business/jxutils/tasksch/parallel_task.go

@@ -175,7 +175,9 @@ func (task *ParallelTask) Run() {
 				task.Status = TaskStatusFinished
 			}
 		}
-		task.Err = NewTaskError(taskErr)
+		if taskErr != nil {
+			task.Err = NewTaskError(taskErr)
+		}
 		task.Result = taskResult
 		task.TerminatedAt = time.Now()
 		task.locker.Unlock()

business/jxutils/tasksch/sequence_task.go

@@ -64,7 +64,9 @@ func (task *SeqTask) Run() {
 				task.Status = TaskStatusFinished
 			}
 		}
-		task.Err = NewTaskError(taskErr)
+		if taskErr != nil {
+			task.Err = NewTaskError(taskErr)
+		}
 		task.Result = taskResult
 		task.TerminatedAt = time.Now()
 		task.locker.Unlock()

business/partner/purchase/ebai/store_sku.go

@@ -191,8 +191,8 @@ func (p *PurchaseHandler) ReadStoreSku(storeID, skuID int) (skuNameExt *model.Sk
 
 func (p *PurchaseHandler) GetAllRemoteSkus(storeID int) (skus []map[string]interface{}, err error) {
 	page1, err := api.EbaiAPI.SkuList(utils.Int2Str(storeID), utils.Params2Map("pagesize", MaxPageSize))
-	skus = append(skus, page1.List...)
 	if err == nil {
+		skus = append(skus, page1.List...)
 		if page1.Pages > 1 {
 			pages := make([]int, page1.Pages-1)
 			for i := 2; i <= page1.Pages; i++ {

business/partner/purchase/ebai/store_sku_test.go

@@ -4,7 +4,6 @@ import (
 	"testing"
 	"time"
 
-	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
 	"git.rosy.net.cn/jx-callback/business/model/dao"
 )
@@ -37,11 +36,11 @@ func TestSyncOneStoreCategoriesFromLocal2Remote(t *testing.T) {
 }
 
 func TestGetAllRemoteSkus(t *testing.T) {
-	result, err := new(PurchaseHandler).GetAllRemoteSkus(9)
+	result, err := new(PurchaseHandler).GetAllRemoteSkus(testShopID)
 	if err != nil {
 		t.Fatal(err.Error())
 	} else {
-		t.Log(utils.Format4Output(result, false))
+		t.Log(len(result))
 	}
 }