fix: fix some issues

app/pages/Import/TaskList/TemplateModal/index.tsx

@@ -79,7 +79,6 @@ const TemplateModal = (props: IProps) => {
 
   const validateAddress = useCallback((client) => {
     const msg = validateEmpty('address', client.address);
-    console.log('msg', msg);
     if(msg) return msg;
     const address = client.address.split(',');
     if(address.some(i => i.startsWith('http'))) {

app/pages/Import/TaskList/index.tsx

@@ -44,10 +44,8 @@ const TaskList = (props: IProps) => {
   const handleTaskStop = useCallback(async (id: number) => {
     clearTimeout(timer.current);
     const { code } = await stopTask(id);
-    if(code === 0) {
-      message.success(intl.get('import.stopImportingSuccess'));
-      getTaskList();
-    }
+    code === 0 && message.success(intl.get('import.stopImportingSuccess'));
+    getTaskList();
   }, []);
   const handleTaskDelete = useCallback(async (id: number) => {
     clearTimeout(timer.current);

app/pages/Schema/SchemaConfig/List/SchemaVisualization/index.module.less

@@ -20,6 +20,7 @@
     }
     .tip {
       max-width: 600px;
+      min-width: 300px;
       background: #DBEFFF;
       border-radius: 3px;
       padding: 13px;

app/utils/function.ts

@@ -11,11 +11,7 @@ export const handleVidStringName = (name: string, spaceVidType?: string) => {
   if (spaceVidType && spaceVidType === 'INT64') {
     return convertBigNumberToString(name);
   }
-  if (name.indexOf(`"`) > -1 && name.indexOf(`'`) === -1) {
-    return `'${name}'`;
-  } else {
-    return `"${name}"`;
-  }
+  return JSON.stringify(name);
 };
 
 export const convertBigNumberToString = (value: any) => {

server/api/studio/internal/service/datasource.go

@@ -111,11 +111,11 @@ func (d *datasourceService) Update(request types.DatasourceUpdateRequest) error
 	}
 	cfgStr, crypto, err := validate(typ, platform, cfg)
 	if err != nil {
-		return err
+		return ecode.WithErrorMessage(ecode.ErrBadRequest, err)
 	}
 	err = d.update(datasourceId, request.Type, request.Platform, request.Name, cfgStr, crypto)
 	if err != nil {
-		return err
+		return ecode.WithErrorMessage(ecode.ErrInternalServer, err)
 	}
 	return nil
 }
@@ -182,16 +182,35 @@ func (d *datasourceService) Remove(request types.DatasourceRemoveRequest) error
 	return nil
 }
 
+func contains(s []int, e int) bool {
+	for _, a := range s {
+		if a == e {
+			return true
+		}
+	}
+	return false
+}
+
 func (d *datasourceService) BatchRemove(request types.DatasourceBatchRemoveRequest) error {
 	user := d.ctx.Value(auth.CtxKeyUserInfo{}).(*auth.AuthData)
+	var existingIDs []int
+	db.CtxDB.Model(&db.Datasource{}).Where("id in (?)", request.IDs).Pluck("id", &existingIDs)
+	if len(existingIDs) != len(request.IDs) {
+		var missingIDs []int
+		for _, id := range request.IDs {
+			if !contains(existingIDs, id) {
+				missingIDs = append(missingIDs, id)
+			}
+		}
+		return ecode.WithErrorMessage(ecode.ErrBadRequest, fmt.Errorf("some data are not found: %v", missingIDs))
+	}
 	result := db.CtxDB.Where("id IN (?) AND username = ?", request.IDs, user.Username).Delete(&db.Datasource{})
-
 	if result.Error != nil {
 		return d.gormErrorWrapper(result.Error)
 	}
 
 	if result.RowsAffected == 0 {
-		return ecode.WithErrorMessage(ecode.ErrBadRequest, fmt.Errorf("test"), "there is available item to delete")
+		return ecode.WithErrorMessage(ecode.ErrBadRequest, fmt.Errorf("no data found"))
 	}
 
 	return nil

server/api/studio/internal/service/import.go

@@ -199,6 +199,7 @@ func (i *importService) CreateImportTask(req *types.CreateImportTaskRequest) (*t
 	// start import
 	if err = importer.StartImport(taskID); err != nil {
 		task.TaskInfo.TaskStatus = importer.StatusAborted.String()
+		task.TaskInfo.TaskMessage = err.Error()
 		importer.GetTaskMgr().AbortTask(taskID)
 		return nil, ecode.WithErrorMessage(ecode.ErrInternalServer, err)
 	}

server/api/studio/internal/service/importer/importer.go

@@ -57,6 +57,7 @@ func StartImport(taskID int) (err error) {
 			abort()
 			return
 		}
+		task.Client.HasStarted = true
 		err = mgr.Wait()
 		if err != nil {
 			task.TaskInfo.TaskStatus = StatusAborted.String()

server/api/studio/internal/service/importer/task.go

@@ -9,9 +9,10 @@ import (
 )
 
 type Client struct {
-	Cfg     config.Configurator `json:"cfg,omitempty"`
-	Logger  logger.Logger       `json:"logger,omitempty"`
-	Manager manager.Manager     `json:"manager,omitempty"`
+	Cfg        config.Configurator `json:"cfg,omitempty"`
+	Logger     logger.Logger       `json:"logger,omitempty"`
+	Manager    manager.Manager     `json:"manager,omitempty"`
+	HasStarted bool                `json:"has_started,omitempty"`
 }
 type Task struct {
 	Client   *Client      `json:"client,omitempty"`

server/api/studio/internal/service/importer/taskmgr.go

@@ -2,6 +2,7 @@ package importer
 
 import (
 	"errors"
+	"fmt"
 	"os"
 	"path/filepath"
 	"strconv"
@@ -102,9 +103,10 @@ func (mgr *TaskMgr) NewTask(host string, user string, taskName string, cfg impor
 
 	task := &Task{
 		Client: &Client{
-			Cfg:     cfg,
-			Manager: nil,
-			Logger:  nil,
+			Cfg:        cfg,
+			Manager:    nil,
+			Logger:     nil,
+			HasStarted: false,
 		},
 		TaskInfo: taskInfo,
 	}
@@ -214,12 +216,23 @@ and then call FinishTask
 */
 func (mgr *TaskMgr) StopTask(taskID int) error {
 	if task, ok := mgr.getTaskFromMap(taskID); ok {
+		var err error
 		manager := task.Client.Manager
-		task.TaskInfo.TaskStatus = StatusStoped.String()
-		err := manager.Stop()
+		if manager != nil {
+			if task.Client.HasStarted {
+				err = manager.Stop()
+			} else {
+				// hack import not support stop before start()
+				err = errors.New("task has not started, please try later")
+			}
+		} else {
+			err = errors.New("manager is nil, please try later")
+		}
+
 		if err != nil {
-			return errors.New("stop task fail")
+			return fmt.Errorf("stop task failed: %w", err)
 		}
+		task.TaskInfo.TaskStatus = StatusStoped.String()
 		if err := mgr.FinishTask(taskID); err != nil {
 			return ecode.WithErrorMessage(ecode.ErrInternalServer, err)
 		}

server/api/studio/studio.go

@@ -37,9 +37,7 @@ func main() {
 	var c config.Config
 	conf.MustLoad(*configFile, &c, conf.UseEnv())
 
-	var lc logx.LogConf
-	conf.MustLoad(*configFile, &lc)
-	logx.MustSetup(lc)
+	logx.MustSetup(c.Log)
 	defer logx.Close()
 
 	// init logger