From 2d0f12a9ff388b6c45c9a95be31a5e65ae64a419 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Wed, 2 Dec 2020 14:51:18 +0800
Subject: [PATCH] aa

---
 business/jxstore/cms/cms.go | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/business/jxstore/cms/cms.go b/business/jxstore/cms/cms.go
index 0c1e3241d..3ec8f59fb 100644
--- a/business/jxstore/cms/cms.go
+++ b/business/jxstore/cms/cms.go
@@ -278,7 +278,27 @@ func InitStation(ctx *jxcontext.Context) (err error) {
 			deleteList = append(deleteList, v)
 		}
 	}
+	task := tasksch.NewParallelTask("InitStation", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			step := batchItemList[0].(int)
+			switch step {
+			case 0:
+				if len(addList) > 0 {
+					err = dao.CreateMultiEntities(db, addList)
+				}
+			case 1:
+				if len(updateList) > 0 {
 
+				}
+			case 2:
+				if len(deleteList) > 0 {
+
+				}
+			}
+			return retVal, err
+		}, []int{0, 1, 2})
+	tasksch.HandleTask(task, nil, true).Run()
+	_, err = task.GetResult(0)
 	return err
 }