项目初始化

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/dto/ModelColumnDto.java

@@ -6,7 +6,6 @@ import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 import javax.validation.constraints.NotBlank;
-import javax.validation.constraints.NotNull;
 import java.io.Serializable;
 
 /**
@@ -41,6 +40,8 @@ public class ModelColumnDto implements Serializable {
     private String columnScale;
     @ApiModelProperty(value = "列默认值")
     private String defaultValue;
+    @ApiModelProperty(value = "是否系统默认（0否，1是）")
+    private String isSystem;
     @ApiModelProperty(value = "是否主键（0否，1是）")
     private String isPk;
     @ApiModelProperty(value = "是否必填（0否，1是）")

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/entity/ModelColumnEntity.java

 package cn.datax.service.data.masterdata.api.entity;
 
-import cn.datax.service.data.masterdata.api.enums.OracleDataTypeEnum;
+import cn.datax.service.data.masterdata.api.enums.MysqlDataTypeEnum;
 import cn.datax.service.data.masterdata.api.parser.ColumnParser;
 import cn.datax.service.data.masterdata.api.parser.DataType;
-import cn.datax.service.data.masterdata.api.parser.oracle.OracleColumnParser;
+import cn.datax.service.data.masterdata.api.parser.mysql.MysqlColumnParser;
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableName;
 import cn.datax.common.base.BaseEntity;
@@ -63,6 +63,11 @@ public class ModelColumnEntity extends BaseEntity {
     private String defaultValue;
 
     /**
+     * 是否系统默认（0否，1是）
+     */
+    private String isSystem;
+
+    /**
      * 是否主键（0否，1是）
      */
     private String isPk;
@@ -128,9 +133,9 @@ public class ModelColumnEntity extends BaseEntity {
     @TableField(exist = false)
     private String columnDefinition;
 
-    public String getColumnDefinition() throws Exception {
-        ColumnParser columnParser = new OracleColumnParser();
-        DataType parse = columnParser.parse(OracleDataTypeEnum.match(this.columnType, OracleDataTypeEnum.CHAR));
+    public String getColumnDefinition() {
+        ColumnParser columnParser = new MysqlColumnParser();
+        DataType parse = columnParser.mysqlParse(MysqlDataTypeEnum.match(this.columnType, MysqlDataTypeEnum.VARCHAR));
         return parse.fillTypeString(this.columnLength, this.columnScale);
     }
 }

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/entity/ModelEntity.java

@@ -40,6 +40,11 @@ public class ModelEntity extends DataScopeBaseEntity {
      */
     private String modelPhysicalTable;
 
+    /**
+     * 是否建模（0否，1是）
+     */
+    private String isSync;
+
     @TableField(exist = false)
     private List<ModelColumnEntity> modelColumns;
 }

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/enums/MysqlDataTypeEnum.java

+package cn.datax.service.data.masterdata.api.enums;
+
+public enum MysqlDataTypeEnum {
+
+    TINYINT("tinyint", "tinyint整型"), INT("int", "int整型"), BIGINT("bigint", "bigint整型"),
+    FLOAT("float", "单精度"), DOUBLE("double", "双精度"), DECIMAL("decimal", "定点数"),
+    CHAR("char", "定长字符串"), VARCHAR("varchar", "变长字符串"), TEXT("text", "长文本"),
+    DATE("date", "date日期"), TIME("time", "time日期"), YEAR("year", "year日期"), DATETIME("datetime", "datetime日期"),
+    BLOB("blob", "二进制");
+
+    private String value;
+    private String title;
+
+    MysqlDataTypeEnum(String value, String title) {
+        this.value = value;
+        this.title = title;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public static MysqlDataTypeEnum match(String value, MysqlDataTypeEnum defaultItem) {
+        if (value != null) {
+            for (MysqlDataTypeEnum item: MysqlDataTypeEnum.values()) {
+                if (item.getValue().equals(value)) {
+                    return item;
+                }
+            }
+        }
+        return defaultItem;
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/enums/OracleDataTypeEnum.java

@@ -2,7 +2,7 @@ package cn.datax.service.data.masterdata.api.enums;
 
 public enum OracleDataTypeEnum {
 
-    CHAR("char", "字符串"), NUMBER("number", "数值"), DATE("date", "日期"), CLOB("clob", "大文本"), BLOB("blob", "二进制");
+    CHAR("char", "字符串"), NUMBER("number", "数值"), DATE("date", "日期"), CLOB("clob", "长文本"), BLOB("blob", "二进制");
 
     private String value;
     private String title;

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/ColumnParser.java

 package cn.datax.service.data.masterdata.api.parser;
 
+import cn.datax.service.data.masterdata.api.enums.MysqlDataTypeEnum;
 import cn.datax.service.data.masterdata.api.enums.OracleDataTypeEnum;
 
-public interface ColumnParser {
+public abstract class ColumnParser {
 
-	DataType parse(OracleDataTypeEnum dataTypeEnum) throws Exception;
-	
+	public abstract DataType oracleParse(OracleDataTypeEnum dataTypeEnum);
+
+	public abstract DataType mysqlParse(MysqlDataTypeEnum dataTypeEnum);
 }

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlBigintDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+public class MysqlBigintDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "bigint";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlBlobDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+public class MysqlBlobDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "blob";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlCharDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+import java.util.Optional;
+
+public class MysqlCharDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "char(" + Optional.ofNullable(columnLength).orElse("1") + ")";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlColumnParser.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.common.exception.DataException;
+import cn.datax.service.data.masterdata.api.enums.MysqlDataTypeEnum;
+import cn.datax.service.data.masterdata.api.enums.OracleDataTypeEnum;
+import cn.datax.service.data.masterdata.api.parser.ColumnParser;
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+public class MysqlColumnParser extends ColumnParser {
+
+    @Override
+    public DataType oracleParse(OracleDataTypeEnum dataTypeEnum) {
+        return null;
+    }
+
+    @Override
+    public DataType mysqlParse(MysqlDataTypeEnum dataTypeEnum) {
+        switch(dataTypeEnum) {
+            case TINYINT:
+                return new MysqlTinyintDataType();
+            case INT:
+                return new MysqlIntDataType();
+            case BIGINT:
+                return new MysqlBigintDataType();
+            case FLOAT:
+                return new MysqlFloatDataType();
+            case DOUBLE:
+                return new MysqlDoubleDataType();
+            case DECIMAL:
+                return new MysqlDecimalDataType();
+            case CHAR:
+                return new MysqlCharDataType();
+            case VARCHAR:
+                return new MysqlVarcharDataType();
+            case TEXT:
+                return new MysqlTextDataType();
+            case DATE:
+                return new MysqlDateDataType();
+            case TIME:
+                return new MysqlTimeDataType();
+            case YEAR:
+                return new MysqlYearDataType();
+            case DATETIME:
+                return new MysqlDatetimeDataType();
+            case BLOB:
+                return new MysqlBlobDataType();
+            default:
+                throw new DataException("字段数据类型错误");
+        }
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlDateDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+public class MysqlDateDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "date";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlDatetimeDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+public class MysqlDatetimeDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "datetime";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlDecimalDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+import java.util.Optional;
+
+public class MysqlDecimalDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "decimal(" + Optional.ofNullable(columnLength).orElse("10") + ", " + Optional.ofNullable(columnScale).orElse("2") + ")";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlDoubleDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+import java.util.Optional;
+
+public class MysqlDoubleDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "double(" + Optional.ofNullable(columnLength).orElse("5") + ", " + Optional.ofNullable(columnScale).orElse("2") + ")";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlFloatDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+import java.util.Optional;
+
+public class MysqlFloatDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "float(" + Optional.ofNullable(columnLength).orElse("5") + ", " + Optional.ofNullable(columnScale).orElse("2") + ")";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlIntDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+public class MysqlIntDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "int";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlTextDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+public class MysqlTextDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "text";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlTimeDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+public class MysqlTimeDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "time";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlTinyintDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+public class MysqlTinyintDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "tinyint";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlVarcharDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+import java.util.Optional;
+
+public class MysqlVarcharDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "varchar(" + Optional.ofNullable(columnLength).orElse("255") + ")";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/mysql/MysqlYearDataType.java

+package cn.datax.service.data.masterdata.api.parser.mysql;
+
+import cn.datax.service.data.masterdata.api.parser.DataType;
+
+public class MysqlYearDataType implements DataType {
+
+    @Override
+    public String fillTypeString(String columnLength, String columnScale) {
+        return "year";
+    }
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/parser/oracle/OracleColumnParser.java

 package cn.datax.service.data.masterdata.api.parser.oracle;
 
 import cn.datax.common.exception.DataException;
+import cn.datax.service.data.masterdata.api.enums.MysqlDataTypeEnum;
 import cn.datax.service.data.masterdata.api.enums.OracleDataTypeEnum;
 import cn.datax.service.data.masterdata.api.parser.ColumnParser;
 import cn.datax.service.data.masterdata.api.parser.DataType;
 
-public class OracleColumnParser implements ColumnParser {
+public class OracleColumnParser extends ColumnParser {
 
     @Override
-    public DataType parse(OracleDataTypeEnum dataTypeEnum) throws Exception {
+    public DataType oracleParse(OracleDataTypeEnum dataTypeEnum) {
         switch(dataTypeEnum) {
             case CHAR:
                 return new OracleCharDataType();
@@ -20,7 +21,13 @@ public class OracleColumnParser implements ColumnParser {
                 return new OracleClobDataType();
             case BLOB:
                 return new OracleBlobDataType();
+            default:
+                throw new DataException("字段数据类型错误");
         }
-        throw new DataException("字段数据类型错误");
+    }
+
+    @Override
+    public DataType mysqlParse(MysqlDataTypeEnum dataTypeEnum)  {
+        return null;
     }
 }

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/vo/ModelColumnVo.java

@@ -30,6 +30,7 @@ public class ModelColumnVo implements Serializable {
     private String columnLength;
     private String columnScale;
     private String defaultValue;
+    private String isSystem;
     private String isPk;
     private String isRequired;
     private String isInsert;

datax-modules/data-masterdata-service-parent/data-masterdata-service-api/src/main/java/cn/datax/service/data/masterdata/api/vo/ModelVo.java

@@ -27,5 +27,6 @@ public class ModelVo implements Serializable {
     private String modelName;
     private String modelLogicTable;
     private String modelPhysicalTable;
+    private String isSync;
     private List<ModelColumnVo> modelColumns;
 }

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/controller/ModelColumnController.java

@@ -7,7 +7,7 @@ import cn.datax.service.data.masterdata.api.dto.ModelColumnDto;
 import cn.datax.service.data.masterdata.api.entity.ModelColumnEntity;
 import cn.datax.service.data.masterdata.api.vo.ModelColumnVo;
 import cn.datax.service.data.masterdata.api.query.ModelColumnQuery;
-import cn.datax.service.data.masterdata.mapstruct.ModelColumnMapper;
+import cn.datax.service.data.masterdata.mapstruct.ModelColumnMapstruct;
 import cn.datax.service.data.masterdata.service.ModelColumnService;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -43,7 +43,7 @@ public class ModelColumnController extends BaseController {
     private ModelColumnService modelColumnService;
 
     @Autowired
-    private ModelColumnMapper modelColumnMapper;
+    private ModelColumnMapstruct modelColumnMapstruct;
 
     /**
      * 通过ID查询信息
@@ -56,7 +56,7 @@ public class ModelColumnController extends BaseController {
     @GetMapping("/{id}")
     public R getModelColumnById(@PathVariable String id) {
         ModelColumnEntity modelColumnEntity = modelColumnService.getModelColumnById(id);
-        return R.ok().setData(modelColumnMapper.toVO(modelColumnEntity));
+        return R.ok().setData(modelColumnMapstruct.toVO(modelColumnEntity));
     }
 
     /**
@@ -75,7 +75,7 @@ public class ModelColumnController extends BaseController {
         queryWrapper.eq(StrUtil.isNotBlank(modelColumnQuery.getModelId()), "model_id", modelColumnQuery.getModelId());
         queryWrapper.like(StrUtil.isNotBlank(modelColumnQuery.getColumnName()), "column_name", modelColumnQuery.getColumnName());
         IPage<ModelColumnEntity> page = modelColumnService.page(new Page<>(modelColumnQuery.getPageNum(), modelColumnQuery.getPageSize()), queryWrapper);
-        List<ModelColumnVo> collect = page.getRecords().stream().map(modelColumnMapper::toVO).collect(Collectors.toList());
+        List<ModelColumnVo> collect = page.getRecords().stream().map(modelColumnMapstruct::toVO).collect(Collectors.toList());
         JsonPage<ModelColumnVo> jsonPage = new JsonPage<>(page.getCurrent(), page.getSize(), page.getTotal(), collect);
         return R.ok().setData(jsonPage);
     }
@@ -90,7 +90,7 @@ public class ModelColumnController extends BaseController {
     @PostMapping()
     public R saveModelColumn(@RequestBody @Validated({ValidationGroups.Insert.class}) ModelColumnDto modelColumn) {
         ModelColumnEntity modelColumnEntity = modelColumnService.saveModelColumn(modelColumn);
-        return R.ok().setData(modelColumnMapper.toVO(modelColumnEntity));
+        return R.ok().setData(modelColumnMapstruct.toVO(modelColumnEntity));
     }
 
     /**
@@ -106,7 +106,7 @@ public class ModelColumnController extends BaseController {
     @PutMapping("/{id}")
     public R updateModelColumn(@PathVariable String id, @RequestBody @Validated({ValidationGroups.Update.class}) ModelColumnDto modelColumn) {
         ModelColumnEntity modelColumnEntity = modelColumnService.updateModelColumn(modelColumn);
-        return R.ok().setData(modelColumnMapper.toVO(modelColumnEntity));
+        return R.ok().setData(modelColumnMapstruct.toVO(modelColumnEntity));
     }
 
     /**

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/controller/ModelController.java

@@ -7,7 +7,7 @@ import cn.datax.service.data.masterdata.api.dto.ModelDto;
 import cn.datax.service.data.masterdata.api.entity.ModelEntity;
 import cn.datax.service.data.masterdata.api.vo.ModelVo;
 import cn.datax.service.data.masterdata.api.query.ModelQuery;
-import cn.datax.service.data.masterdata.mapstruct.ModelMapper;
+import cn.datax.service.data.masterdata.mapstruct.ModelMapstruct;
 import cn.datax.service.data.masterdata.service.ModelService;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -43,7 +43,7 @@ public class ModelController extends BaseController {
     private ModelService modelService;
 
     @Autowired
-    private ModelMapper modelMapper;
+    private ModelMapstruct modelMapstruct;
 
     /**
      * 通过ID查询信息
@@ -56,7 +56,7 @@ public class ModelController extends BaseController {
     @GetMapping("/{id}")
     public R getModelById(@PathVariable String id) {
         ModelEntity modelEntity = modelService.getModelById(id);
-        return R.ok().setData(modelMapper.toVO(modelEntity));
+        return R.ok().setData(modelMapstruct.toVO(modelEntity));
     }
 
     /**
@@ -74,7 +74,7 @@ public class ModelController extends BaseController {
         QueryWrapper<ModelEntity> queryWrapper = new QueryWrapper<>();
         queryWrapper.like(StrUtil.isNotBlank(modelQuery.getModelName()), "model_name", modelQuery.getModelName());
         IPage<ModelEntity> page = modelService.page(new Page<>(modelQuery.getPageNum(), modelQuery.getPageSize()), queryWrapper);
-        List<ModelVo> collect = page.getRecords().stream().map(modelMapper::toVO).collect(Collectors.toList());
+        List<ModelVo> collect = page.getRecords().stream().map(modelMapstruct::toVO).collect(Collectors.toList());
         JsonPage<ModelVo> jsonPage = new JsonPage<>(page.getCurrent(), page.getSize(), page.getTotal(), collect);
         return R.ok().setData(jsonPage);
     }
@@ -89,7 +89,7 @@ public class ModelController extends BaseController {
     @PostMapping()
     public R saveModel(@RequestBody @Validated({ValidationGroups.Insert.class}) ModelDto model) {
         ModelEntity modelEntity = modelService.saveModel(model);
-        return R.ok().setData(modelMapper.toVO(modelEntity));
+        return R.ok().setData(modelMapstruct.toVO(modelEntity));
     }
 
     /**
@@ -105,7 +105,7 @@ public class ModelController extends BaseController {
     @PutMapping("/{id}")
     public R updateModel(@PathVariable String id, @RequestBody @Validated({ValidationGroups.Update.class}) ModelDto model) {
         ModelEntity modelEntity = modelService.updateModel(model);
-        return R.ok().setData(modelMapper.toVO(modelEntity));
+        return R.ok().setData(modelMapstruct.toVO(modelEntity));
     }
 
     /**
@@ -133,4 +133,10 @@ public class ModelController extends BaseController {
         modelService.deleteModelBatch(ids);
         return R.ok();
     }
+
+    @PostMapping("/table/{id}")
+    public R createTable(@PathVariable String id) {
+        modelService.createTable(id);
+        return R.ok();
+    }
 }

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/dao/MysqlDynamicDao.java

+package cn.datax.service.data.masterdata.dao;
+
+import cn.datax.service.data.masterdata.api.entity.ModelDataEntity;
+import cn.datax.service.data.masterdata.api.entity.ModelEntity;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+@Mapper
+public interface MysqlDynamicDao {
+
+    void createTable(ModelEntity modelEntity);
+
+    void dropTable(@Param("tableName") String tableName);
+
+    void insertData(ModelDataEntity modelDataEntity);
+
+    void updateData(ModelDataEntity modelDataEntity);
+
+    void deleteData(ModelDataEntity modelDataEntity);
+}

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/mapstruct/ModelColumnMapper.java → datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/mapstruct/ModelColumnMapstruct.java

@@ -15,6 +15,6 @@ import org.mapstruct.Mapper;
  * @since 2020-08-26
  */
 @Mapper(componentModel = "spring")
-public interface ModelColumnMapper extends EntityMapper<ModelColumnDto, ModelColumnEntity, ModelColumnVo> {
+public interface ModelColumnMapstruct extends EntityMapper<ModelColumnDto, ModelColumnEntity, ModelColumnVo> {
 
 }

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/mapstruct/ModelMapper.java → datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/mapstruct/ModelMapstruct.java

@@ -15,6 +15,6 @@ import org.mapstruct.Mapper;
  * @since 2020-08-26
  */
 @Mapper(componentModel = "spring")
-public interface ModelMapper extends EntityMapper<ModelDto, ModelEntity, ModelVo> {
+public interface ModelMapstruct extends EntityMapper<ModelDto, ModelEntity, ModelVo> {
 
 }

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/service/ModelService.java

@@ -25,4 +25,6 @@ public interface ModelService extends BaseService<ModelEntity> {
     void deleteModelById(String id);
 
     void deleteModelBatch(List<String> ids);
+
+    void createTable(String id);
 }

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/service/impl/ModelColumnServiceImpl.java

@@ -3,7 +3,7 @@ package cn.datax.service.data.masterdata.service.impl;
 import cn.datax.service.data.masterdata.api.entity.ModelColumnEntity;
 import cn.datax.service.data.masterdata.api.dto.ModelColumnDto;
 import cn.datax.service.data.masterdata.service.ModelColumnService;
-import cn.datax.service.data.masterdata.mapstruct.ModelColumnMapper;
+import cn.datax.service.data.masterdata.mapstruct.ModelColumnMapstruct;
 import cn.datax.service.data.masterdata.dao.ModelColumnDao;
 import cn.datax.common.base.BaseServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -29,12 +29,12 @@ public class ModelColumnServiceImpl extends BaseServiceImpl<ModelColumnDao, Mode
     private ModelColumnDao modelColumnDao;
 
     @Autowired
-    private ModelColumnMapper modelColumnMapper;
+    private ModelColumnMapstruct modelColumnMapstruct;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
     public ModelColumnEntity saveModelColumn(ModelColumnDto modelColumnDto) {
-        ModelColumnEntity modelColumn = modelColumnMapper.toEntity(modelColumnDto);
+        ModelColumnEntity modelColumn = modelColumnMapstruct.toEntity(modelColumnDto);
         modelColumnDao.insert(modelColumn);
         return modelColumn;
     }
@@ -42,7 +42,7 @@ public class ModelColumnServiceImpl extends BaseServiceImpl<ModelColumnDao, Mode
     @Override
     @Transactional(rollbackFor = Exception.class)
     public ModelColumnEntity updateModelColumn(ModelColumnDto modelColumnDto) {
-        ModelColumnEntity modelColumn = modelColumnMapper.toEntity(modelColumnDto);
+        ModelColumnEntity modelColumn = modelColumnMapstruct.toEntity(modelColumnDto);
         modelColumnDao.updateById(modelColumn);
         return modelColumn;
     }

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/java/cn/datax/service/data/masterdata/service/impl/ModelServiceImpl.java

 package cn.datax.service.data.masterdata.service.impl;
 
+import cn.datax.common.core.DataConstant;
+import cn.datax.common.exception.DataException;
 import cn.datax.service.data.masterdata.api.entity.ModelColumnEntity;
 import cn.datax.service.data.masterdata.api.entity.ModelEntity;
 import cn.datax.service.data.masterdata.api.dto.ModelDto;
 import cn.datax.service.data.masterdata.dao.ModelColumnDao;
+import cn.datax.service.data.masterdata.dao.MysqlDynamicDao;
+import cn.datax.service.data.masterdata.mapstruct.ModelMapstruct;
 import cn.datax.service.data.masterdata.service.ModelService;
-import cn.datax.service.data.masterdata.mapstruct.ModelMapper;
 import cn.datax.service.data.masterdata.dao.ModelDao;
 import cn.datax.common.base.BaseServiceImpl;
 import cn.hutool.core.collection.CollUtil;
@@ -36,15 +39,19 @@ public class ModelServiceImpl extends BaseServiceImpl<ModelDao, ModelEntity> imp
     private ModelDao modelDao;
 
     @Autowired
-    private ModelMapper modelMapper;
+    private ModelMapstruct modelMapstruct;
 
     @Autowired
     private ModelColumnDao modelColumnDao;
 
+    @Autowired
+    private MysqlDynamicDao dynamicDao;
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public ModelEntity saveModel(ModelDto modelDto) {
-        ModelEntity model = modelMapper.toEntity(modelDto);
+        ModelEntity model = modelMapstruct.toEntity(modelDto);
+        model.setIsSync(DataConstant.TrueOrFalse.FALSE.getKey());
         model.setModelPhysicalTable("dynamic_" + DateUtil.format(new Date(), DatePattern.PURE_DATETIME_PATTERN));
         modelDao.insert(model);
         String modelId = model.getId();
@@ -61,7 +68,7 @@ public class ModelServiceImpl extends BaseServiceImpl<ModelDao, ModelEntity> imp
     @Override
     @Transactional(rollbackFor = Exception.class)
     public ModelEntity updateModel(ModelDto modelDto) {
-        ModelEntity model = modelMapper.toEntity(modelDto);
+        ModelEntity model = modelMapstruct.toEntity(modelDto);
         modelDao.updateById(model);
         String modelId = model.getId();
         modelColumnDao.delete(Wrappers.<ModelColumnEntity>lambdaQuery()
@@ -97,4 +104,15 @@ public class ModelServiceImpl extends BaseServiceImpl<ModelDao, ModelEntity> imp
                 .in(ModelColumnEntity::getModelId, ids));
         modelDao.deleteBatchIds(ids);
     }
+
+    @Override
+    public void createTable(String id) {
+        ModelEntity modelEntity = super.getById(id);
+        if (DataConstant.TrueOrFalse.TRUE.getKey().equals(modelEntity.getIsSync())) {
+            throw new DataException("重复建模");
+        }
+        dynamicDao.createTable(modelEntity);
+        modelEntity.setIsSync(DataConstant.TrueOrFalse.TRUE.getKey());
+        modelDao.updateById(modelEntity);
+    }
 }

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/resources/mapper/ModelColumnMapper.xml

@@ -18,6 +18,7 @@
         <result column="column_length" property="columnLength" />
         <result column="column_scale" property="columnScale" />
         <result column="default_value" property="defaultValue" />
+        <result column="is_system" property="isSystem" />
         <result column="is_pk" property="isPk" />
         <result column="is_required" property="isRequired" />
         <result column="is_insert" property="isInsert" />
@@ -41,7 +42,7 @@
         update_by,
         update_time,
         remark,
-        model_id, column_name, column_comment, column_type, column_length, column_scale, default_value, is_pk, is_required, is_insert, is_edit, is_list, is_query, query_type, is_bind_dict, bind_dict_type_id, bind_dict_column, html_type, sort
+        model_id, column_name, column_comment, column_type, column_length, column_scale, default_value, is_system, is_pk, is_required, is_insert, is_edit, is_list, is_query, query_type, is_bind_dict, bind_dict_type_id, bind_dict_column, html_type, sort
     </sql>
 
 </mapper>

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/resources/mapper/ModelMapper.xml

@@ -15,6 +15,7 @@
         <result column="model_name" property="modelName" />
         <result column="model_logic_table" property="modelLogicTable" />
         <result column="model_physical_table" property="modelPhysicalTable" />
+        <result column="is_sync" property="isSync" />
     </resultMap>
 
     <resultMap id="ExtendResultMap" type="cn.datax.service.data.masterdata.api.entity.ModelEntity" extends="BaseResultMap">
@@ -31,7 +32,7 @@
         update_by,
         update_time,
         remark,
-        model_name, model_logic_table, model_physical_table
+        model_name, model_logic_table, model_physical_table, is_sync
     </sql>
 
     <select id="getModelColumnList" resultType="cn.datax.service.data.masterdata.api.entity.ModelColumnEntity">

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/resources/mapper/MysqlDynamicMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="cn.datax.service.data.masterdata.dao.MysqlDynamicDao">
+
+    <insert id="createTable" parameterType="cn.datax.service.data.masterdata.api.entity.ModelEntity">
+        CREATE TABLE `${modelPhysicalTable}` (
+            <foreach collection="modelColumns" item="column" separator=",">
+                `${column.columnName}` ${column.columnDefinition}
+                <if test="column.defaultValue != null and column.defaultValue != ''">
+                    DEFAULT #{column.defaultValue}
+                </if>
+                <if test="column.isRequired != null and column.isRequired == '1'.toString()">
+                    NOT NULL
+                </if>
+                <if test="column.columnComment != null and column.columnComment != ''">
+                    comment #{column.columnComment}
+                </if>
+            </foreach>
+            , PRIMARY KEY (`id`) USING BTREE
+        ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC
+        <if test="modelName != null and modelName != ''">
+            comment=#{modelName}
+        </if>
+    </insert>
+
+    <!-- 验证表是否存在 -->
+    <update id="dropTable" parameterType="java.lang.String">
+		DROP TABLE IF EXISTS ${tableName}
+	</update>
+
+    <!-- 插入数据 -->
+    <insert id="insertData" parameterType="cn.datax.service.data.masterdata.api.entity.ModelDataEntity">
+        INSERT INTO ${tableName}
+            <foreach collection="datas.keys" item="key" open="(" close=")" separator=",">
+                ${key}
+            </foreach>
+        VALUES
+            <foreach collection="datas.values" item="value" open="(" close=")" separator=",">
+                #{value}
+            </foreach>
+    </insert>
+
+    <!-- 更新数据 -->
+    <update id="updateData" parameterType="cn.datax.service.data.masterdata.api.entity.ModelDataEntity">
+        UPDATE ${tableName} SET
+            <foreach collection="datas.keys" index="key" item="value" separator=",">
+                ${key} = #{value}
+            </foreach>
+        WHERE ID = #{datas[id]}
+    </update>
+
+    <!-- 删除数据 -->
+    <delete id="deleteData" parameterType="cn.datax.service.data.masterdata.api.entity.ModelDataEntity">
+        DELETE FROM ${tableName} WHERE id = #{datas[id]}
+    </delete>
+</mapper>

datax-modules/data-masterdata-service-parent/data-masterdata-service/src/main/resources/mapper/OracleDynamicMapper.xml

@@ -3,15 +3,7 @@
 <mapper namespace="cn.datax.service.data.masterdata.dao.OracleDynamicDao">
 
     <insert id="createTable" parameterType="cn.datax.service.data.masterdata.api.entity.ModelEntity">
-        CREATE TABLE ${modelLogicTable} (
-            ID VARCHAR2(20) NOT NULL PRIMARY KEY,
-            STATUS NUMBER(1, 0) DEFAULT '1' NOT NULL,
-            CREATE_BY VARCHAR2(20),
-            CREATE_TIME DATE,
-            CREATE_DEPT VARCHAR2(20),
-            UPDATE_BY VARCHAR2(20),
-            UPDATE_TIME DATE,
-            REMARK VARCHAR2(2000),
+        CREATE TABLE ${modelPhysicalTable} (
             <foreach collection="modelColumns" item="column" separator=",">
                 ${column.columnName} ${column.columnDefinition}
                 <if test="column.defaultValue != null and column.defaultValue != ''">
@@ -20,9 +12,6 @@
                 <if test="column.isRequired != null and column.isRequired == '1'.toString()">
                     NOT NULL
                 </if>
-                <if test="column.isPk != null and column.isPk == '1'.toString()">
-                    PRIMARY KEY
-                </if>
             </foreach>
         )
     </insert>

datax-ui/src/api/masterdata/datamodel.js

@@ -44,3 +44,10 @@ export function updateDataModel(data) {
     data: data
   })
 }
+
+export function createTable(id) {
+  return request({
+    url: '/data/masterdata/models/table/' + id,
+    method: 'post'
+  })
+}

datax-ui/src/views/market/apimask/ApiMaskAdd.vue

@@ -283,8 +283,7 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
-          }).catch(error => {
-            this.$message.error(error.data.msg || '保存失败')
+          }).catch(() => {
             this.loadingOptions.loading = false
             this.loadingOptions.loadingText = '保存'
             this.loadingOptions.isDisabled = false

datax-ui/src/views/market/apimask/ApiMaskEdit.vue

@@ -322,8 +322,7 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
-          }).catch(error => {
-            this.$message.error(error.data.msg || '保存失败')
+          }).catch(() => {
             this.loadingOptions.loading = false
             this.loadingOptions.loadingText = '保存'
             this.loadingOptions.isDisabled = false

datax-ui/src/views/market/dataapi/DataApiAdd.vue

@@ -556,8 +556,7 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
-          }).catch(error => {
-            this.$message.error(error || '保存失败')
+          }).catch(() => {
             this.loadingOptions.loading = false
             this.loadingOptions.loadingText = '保存'
             this.loadingOptions.isDisabled = false

datax-ui/src/views/market/dataapi/DataApiEdit.vue

@@ -587,8 +587,7 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
-          }).catch(error => {
-            this.$message.error(error || '保存失败')
+          }).catch(() => {
             this.loadingOptions.loading = false
             this.loadingOptions.loadingText = '保存'
             this.loadingOptions.isDisabled = false

datax-ui/src/views/market/dataservice/DataServiceAdd.vue

@@ -185,6 +185,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/market/dataservice/DataServiceEdit.vue

@@ -195,6 +195,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/masterdata/datamodel/DataModelDetail.vue

@@ -3,6 +3,7 @@
     <div slot="header" class="clearfix">
       <span>{{ title }}</span>
       <el-button-group style="float: right;">
+        <el-button size="mini" icon="el-icon-s-data" round @click="createTable">建模</el-button>
         <el-button size="mini" icon="el-icon-back" round @click="showCard">返回</el-button>
       </el-button-group>
     </div>
@@ -162,7 +163,7 @@
 </template>
 
 <script>
-import { getDataModel } from '@/api/masterdata/datamodel'
+import { getDataModel, createTable } from '@/api/masterdata/datamodel'
 
 export default {
   name: 'DataModelDetail',
@@ -202,7 +203,7 @@ export default {
         this.statusOptions = response.data
       }
     })
-    this.getDicts('data_type_oracle').then(response => {
+    this.getDicts('data_type_mysql').then(response => {
       if (response.success) {
         this.columnTypeOptions = response.data
       }
@@ -232,6 +233,15 @@ export default {
           this.form = response.data
         }
       })
+    },
+    createTable() {
+      createTable(this.data.id).then(response => {
+        if (response.success) {
+          this.$message.error('建模成功')
+        } else {
+          this.$message.error('建模失败')
+        }
+      })
     }
   }
 }

datax-ui/src/views/metadata/changerecord/ChangeRecordAdd.vue

@@ -128,6 +128,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/metadata/changerecord/ChangeRecordEdit.vue

@@ -151,6 +151,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/metadata/datasource/DataSourceAdd.vue

@@ -214,6 +214,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/metadata/datasource/DataSourceEdit.vue

@@ -212,6 +212,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/scheduler/job/JobAdd.vue

@@ -125,6 +125,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/scheduler/job/JobEdit.vue

@@ -135,6 +135,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/standard/datadict/DataDictAdd.vue

@@ -115,6 +115,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/standard/datadict/DataDictEdit.vue

@@ -126,6 +126,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/config/ConfigAdd.vue

@@ -116,6 +116,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/config/ConfigEdit.vue

@@ -126,6 +126,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/dept/DeptAdd.vue

@@ -151,6 +151,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/dept/DeptEdit.vue

@@ -159,6 +159,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/dict/DictAdd.vue

@@ -114,6 +114,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/dict/DictEdit.vue

@@ -124,6 +124,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/dict/item/DictItemAdd.vue

@@ -120,6 +120,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/dict/item/DictItemEdit.vue

@@ -127,6 +127,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/menu/MenuAdd.vue

@@ -203,6 +203,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/menu/MenuEdit.vue

@@ -208,6 +208,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/post/PostAdd.vue

@@ -104,6 +104,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/post/PostEdit.vue

@@ -114,6 +114,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/role/RoleAdd.vue

@@ -222,6 +222,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/role/RoleEdit.vue

@@ -247,6 +247,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/user/UserAdd.vue

@@ -231,6 +231,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/system/user/UserEdit.vue

@@ -232,6 +232,10 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
+          }).catch(() => {
+            this.loadingOptions.loading = false
+            this.loadingOptions.loadingText = '保存'
+            this.loadingOptions.isDisabled = false
           })
         }
       })

datax-ui/src/views/visual/dataset/DataSetAdd.vue

@@ -341,8 +341,7 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
-          }).catch(error => {
-            this.$message.error(error.data.msg || '保存失败')
+          }).catch(() => {
             this.loadingOptions.loading = false
             this.loadingOptions.loadingText = '保存'
             this.loadingOptions.isDisabled = false

datax-ui/src/views/visual/dataset/DataSetEdit.vue

@@ -360,8 +360,7 @@ export default {
               this.loadingOptions.loadingText = '保存'
               this.loadingOptions.isDisabled = false
             }
-          }).catch(error => {
-            this.$message.error(error.data.msg || '保存失败')
+          }).catch(() => {
             this.loadingOptions.loading = false
             this.loadingOptions.loadingText = '保存'
             this.loadingOptions.isDisabled = false