错误返回

business/jxutils/tasksch/task.go

@@ -64,16 +64,10 @@ type ITask interface {
 	GetLeafResult() (finishedItemCount, failedItemCount int)
 	AddBatchErr(err error)
 	AddErrMsg(failedList ...interface{})
-	GetErrMsg() (failedList []*ErrMsg)
+	GetErrMsg() (failedList []interface{})
+	SetFinishHook(func(task ITask))
 	json.Marshaler
 }
-type ErrMsg struct {
-	SkuID       int
-	VendorSkuID string
-	StoreID     int
-	VendorPrice int64
-	Err         string
-}
 
 // type TaskError struct {
 // 	name   string
@@ -137,6 +131,7 @@ type BaseTask struct {
 	ctx               *jxcontext.Context
 	isGetResultCalled bool
 	FailedList        []interface{}
+	FinishHook        func(task ITask)
 }
 
 func (s TaskList) Len() int {
@@ -364,7 +359,11 @@ func (t *BaseTask) Error() (errMsg string) {
 	return errMsg
 }
 
-func (t *BaseTask) GetErrMsg() (failedList []*ErrMsg) {
+func (t *BaseTask) SetFinishHook(hook func(task ITask)) {
+	t.FinishHook = hook
+}
+
+func (t *BaseTask) GetErrMsg() (failedList []interface{}) {
 	t.locker.RLock()
 	defer t.locker.RUnlock()
 	if len(t.FailedList) == 0 {
@@ -372,7 +371,7 @@ func (t *BaseTask) GetErrMsg() (failedList []*ErrMsg) {
 	}
 	if t.parent != nil {
 		for _, v := range t.FailedList {
-			failedList = append(failedList, v.(*ErrMsg))
+			failedList = append(failedList, v)
 		}
 	}
 	return failedList
@@ -475,6 +474,7 @@ func (t *BaseTask) run(taskHandler func()) {
 					ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "异步任务完成", content)
 				}
 			}
+			t.SetFinishHook(t.FinishHook)
 		})
 	}
 }