|
@@ -1,63 +0,0 @@
|
|
|
-package org.dbsyncer.biz.checker.impl.mapping;
|
|
|
-
|
|
|
-import org.dbsyncer.biz.checker.AbstractChecker;
|
|
|
-import org.dbsyncer.manager.Manager;
|
|
|
-import org.dbsyncer.parser.enums.MetaEnum;
|
|
|
-import org.dbsyncer.parser.model.ConfigModel;
|
|
|
-import org.dbsyncer.parser.model.Mapping;
|
|
|
-import org.dbsyncer.parser.model.Meta;
|
|
|
-import org.dbsyncer.storage.constant.ConfigConstant;
|
|
|
-import org.slf4j.Logger;
|
|
|
-import org.slf4j.LoggerFactory;
|
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import org.springframework.stereotype.Component;
|
|
|
-import org.springframework.util.Assert;
|
|
|
-
|
|
|
-import java.util.Map;
|
|
|
-import java.util.concurrent.ConcurrentHashMap;
|
|
|
-import java.util.concurrent.atomic.AtomicInteger;
|
|
|
-
|
|
|
-/**
|
|
|
- * @author AE86
|
|
|
- * @version 1.0.0
|
|
|
- * @date 2020/1/8 15:17
|
|
|
- */
|
|
|
-@Component
|
|
|
-public class MetaChecker extends AbstractChecker {
|
|
|
-
|
|
|
- private final Logger logger = LoggerFactory.getLogger(getClass());
|
|
|
-
|
|
|
- @Autowired
|
|
|
- private Manager manager;
|
|
|
-
|
|
|
- @Override
|
|
|
- public ConfigModel checkAddConfigModel(Map<String, String> params) {
|
|
|
- logger.info("params:{}", params);
|
|
|
- String mappingId = params.get(ConfigConstant.CONFIG_MODEL_ID);
|
|
|
- Mapping mapping = manager.getMapping(mappingId);
|
|
|
- Assert.notNull(mapping, "驱动不存在.");
|
|
|
-
|
|
|
- // TODO 获取驱动数据源总条数
|
|
|
- AtomicInteger total = new AtomicInteger(1000);
|
|
|
- AtomicInteger success = new AtomicInteger(500);
|
|
|
- AtomicInteger fail = new AtomicInteger(0);
|
|
|
- Map<String, String> map = new ConcurrentHashMap<>();
|
|
|
- Meta meta = new Meta(mappingId, MetaEnum.RUNNING.getCode(), total, success, fail, map);
|
|
|
- meta.setType(ConfigConstant.META);
|
|
|
- meta.setName(ConfigConstant.META);
|
|
|
-
|
|
|
- // 修改基本配置
|
|
|
- this.modifyConfigModel(meta, params);
|
|
|
-
|
|
|
- // 修改驱动元信息ID
|
|
|
- mapping.setMetaId(meta.getId());
|
|
|
- manager.editMapping(mapping);
|
|
|
- return meta;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public ConfigModel checkEditConfigModel(Map<String, String> params) {
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
-}
|