diff --git a/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/repository/manage/entity/EsDatasource.java b/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/repository/manage/entity/EsDatasource.java new file mode 100644 index 00000000..6fe0fce3 --- /dev/null +++ b/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/repository/manage/entity/EsDatasource.java @@ -0,0 +1,131 @@ +package com.zyplayer.doc.data.repository.manage.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import java.util.Date; +import com.baomidou.mybatisplus.annotation.TableId; +import java.io.Serializable; + +/** + *

+ * + *

+ * + * @author 暮光:城中城 + * @since 2019-07-27 + */ +public class EsDatasource implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 主键自增ID + */ + @TableId(value = "id", type = IdType.AUTO) + private Long id; + + /** + * 数据源名称 + */ + private String name; + + /** + * 地址和端口 + */ + private String hostPort; + + /** + * scheme,http或其他 + */ + private String scheme; + + /** + * 创建人ID + */ + private Long createUserId; + + /** + * 创建人名字 + */ + private String createUserName; + + /** + * 创建时间 + */ + private Date createTime; + + /** + * 是否有效 0=无效 1=有效 + */ + private Integer yn; + + public Long getId() { + return id; + } + + public void setId(Long id) { + this.id = id; + } + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + public String getHostPort() { + return hostPort; + } + + public void setHostPort(String hostPort) { + this.hostPort = hostPort; + } + public String getScheme() { + return scheme; + } + + public void setScheme(String scheme) { + this.scheme = scheme; + } + public Long getCreateUserId() { + return createUserId; + } + + public void setCreateUserId(Long createUserId) { + this.createUserId = createUserId; + } + public String getCreateUserName() { + return createUserName; + } + + public void setCreateUserName(String createUserName) { + this.createUserName = createUserName; + } + public Date getCreateTime() { + return createTime; + } + + public void setCreateTime(Date createTime) { + this.createTime = createTime; + } + public Integer getYn() { + return yn; + } + + public void setYn(Integer yn) { + this.yn = yn; + } + + @Override + public String toString() { + return "EsDatasource{" + + "id=" + id + + ", name=" + name + + ", hostPort=" + hostPort + + ", scheme=" + scheme + + ", createUserId=" + createUserId + + ", createUserName=" + createUserName + + ", createTime=" + createTime + + ", yn=" + yn + + "}"; + } +} diff --git a/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/repository/manage/mapper/EsDatasourceMapper.java b/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/repository/manage/mapper/EsDatasourceMapper.java new file mode 100644 index 00000000..7763d182 --- /dev/null +++ b/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/repository/manage/mapper/EsDatasourceMapper.java @@ -0,0 +1,16 @@ +package com.zyplayer.doc.data.repository.manage.mapper; + +import com.zyplayer.doc.data.repository.manage.entity.EsDatasource; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; + +/** + *

+ * Mapper 接口 + *

+ * + * @author 暮光:城中城 + * @since 2019-07-27 + */ +public interface EsDatasourceMapper extends BaseMapper { + +} diff --git a/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/repository/support/generator/CodeGenerator.java b/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/repository/support/generator/CodeGenerator.java index 79f1d0ef..c7930008 100644 --- a/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/repository/support/generator/CodeGenerator.java +++ b/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/repository/support/generator/CodeGenerator.java @@ -19,7 +19,8 @@ public class CodeGenerator { final String moduleName = "manage"; // final String[] tableName = { "zyplayer_storage", "auth_info", "user_auth", "user_info", "db_datasource" }; // final String[] tableName = { "wiki_space", "wiki_page", "wiki_page_content", "wiki_page_file", "wiki_page_comment", "wiki_page_zan" }; - final String[] tableName = { "db_datasource" }; +// final String[] tableName = { "db_datasource" }; + final String[] tableName = { "es_datasource" }; // 代码生成器 AutoGenerator mpg = new AutoGenerator(); diff --git a/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/service/manage/EsDatasourceService.java b/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/service/manage/EsDatasourceService.java new file mode 100644 index 00000000..3fe0989f --- /dev/null +++ b/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/service/manage/EsDatasourceService.java @@ -0,0 +1,16 @@ +package com.zyplayer.doc.data.service.manage; + +import com.zyplayer.doc.data.repository.manage.entity.EsDatasource; +import com.baomidou.mybatisplus.extension.service.IService; + +/** + *

+ * 服务类 + *

+ * + * @author 暮光:城中城 + * @since 2019-07-27 + */ +public interface EsDatasourceService extends IService { + +} diff --git a/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/service/manage/impl/EsDatasourceServiceImpl.java b/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/service/manage/impl/EsDatasourceServiceImpl.java new file mode 100644 index 00000000..202a1682 --- /dev/null +++ b/zyplayer-doc-data/src/main/java/com/zyplayer/doc/data/service/manage/impl/EsDatasourceServiceImpl.java @@ -0,0 +1,20 @@ +package com.zyplayer.doc.data.service.manage.impl; + +import com.zyplayer.doc.data.repository.manage.entity.EsDatasource; +import com.zyplayer.doc.data.repository.manage.mapper.EsDatasourceMapper; +import com.zyplayer.doc.data.service.manage.EsDatasourceService; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.springframework.stereotype.Service; + +/** + *

+ * 服务实现类 + *

+ * + * @author 暮光:城中城 + * @since 2019-07-27 + */ +@Service +public class EsDatasourceServiceImpl extends ServiceImpl implements EsDatasourceService { + +} diff --git a/zyplayer-doc-data/src/main/resources/mapper/manage/EsDatasourceMapper.xml b/zyplayer-doc-data/src/main/resources/mapper/manage/EsDatasourceMapper.xml new file mode 100644 index 00000000..0adbf19c --- /dev/null +++ b/zyplayer-doc-data/src/main/resources/mapper/manage/EsDatasourceMapper.xml @@ -0,0 +1,5 @@ + + + + + diff --git a/zyplayer-doc-es/src/main/java/com/zyplayer/doc/elasticsearch/controller/EsDatasourceController.java b/zyplayer-doc-es/src/main/java/com/zyplayer/doc/elasticsearch/controller/EsDatasourceController.java new file mode 100644 index 00000000..fadd8d63 --- /dev/null +++ b/zyplayer-doc-es/src/main/java/com/zyplayer/doc/elasticsearch/controller/EsDatasourceController.java @@ -0,0 +1,70 @@ +package com.zyplayer.doc.elasticsearch.controller; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.zyplayer.doc.core.annotation.AuthMan; +import com.zyplayer.doc.core.json.DocResponseJson; +import com.zyplayer.doc.core.json.ResponseJson; +import com.zyplayer.doc.data.config.security.DocUserDetails; +import com.zyplayer.doc.data.config.security.DocUserUtil; +import com.zyplayer.doc.data.repository.manage.entity.EsDatasource; +import com.zyplayer.doc.data.service.manage.EsDatasourceService; +import org.apache.commons.lang3.StringUtils; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import javax.annotation.Resource; +import java.util.Date; +import java.util.List; +import java.util.Optional; + +/** + * 数据源控制器 + * + * @author 暮光:城中城 + * @since 2019年7月27日 + */ +@AuthMan("ES_DATASOURCE_MANAGE") +@RestController +@RequestMapping("/zyplayer-doc-es/datasource") +public class EsDatasourceController { + + @Resource + EsDatasourceService esDatasourceService; + + @PostMapping(value = "/list") + public ResponseJson list() { + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("yn", 1); + List datasourceList = esDatasourceService.list(wrapper); + return DocResponseJson.ok(datasourceList); + } + + @PostMapping(value = "/update") + public ResponseJson update(EsDatasource esDatasource) { + if (StringUtils.isBlank(esDatasource.getName())) { + return DocResponseJson.warn("名字必填"); + } else if (StringUtils.isBlank(esDatasource.getHostPort())) { + return DocResponseJson.warn("地址端口必选"); + } else if (StringUtils.isBlank(esDatasource.getScheme())) { + return DocResponseJson.warn("scheme必填"); + } + Long sourceId = Optional.ofNullable(esDatasource.getId()).orElse(0L); + if (sourceId > 0) { + // 这三项不需要修改 + esDatasource.setCreateTime(null); + esDatasource.setCreateUserId(null); + esDatasource.setCreateUserName(null); + esDatasourceService.updateById(esDatasource); + } else { + DocUserDetails currentUser = DocUserUtil.getCurrentUser(); + esDatasource.setCreateTime(new Date()); + esDatasource.setCreateUserId(currentUser.getUserId()); + esDatasource.setCreateUserName(currentUser.getUsername()); + esDatasource.setYn(1); + esDatasourceService.save(esDatasource); + } + return DocResponseJson.ok(); + } +} + diff --git a/zyplayer-doc-manage/src/main/resources/sql/zyplayer_doc_manage.1.0.3.sql b/zyplayer-doc-manage/src/main/resources/sql/zyplayer_doc_manage.1.0.3.sql index f4909f04..0a6e7d3d 100644 --- a/zyplayer-doc-manage/src/main/resources/sql/zyplayer_doc_manage.1.0.3.sql +++ b/zyplayer-doc-manage/src/main/resources/sql/zyplayer_doc_manage.1.0.3.sql @@ -23,6 +23,9 @@ CREATE TABLE `db_datasource` ( INSERT INTO `auth_info`(`auth_name`, `auth_desc`, `can_edit`, `create_uid`, `creation_time`, `auth_type`) VALUES ( 'DB_DATASOURCE_MANAGE', '数据源管理权', 0, 1, '2019-06-29 13:01:20', 1); +INSERT INTO `auth_info`(`auth_name`, `auth_desc`, `can_edit`, `create_uid`, `creation_time`, `auth_type`) +VALUES ( 'ES_DATASOURCE_MANAGE', 'ES数据源管理权', 0, 1, '2019-07-27 00:39:20', 1); + insert into user_auth(`user_id`, `auth_id`, `create_uid`, `del_flag`, `creation_time`) select a.id, b.id, a.id, 0, now() from user_info a,auth_info b where a.user_no='zyplayer' and b.auth_name='DB_DATASOURCE_MANAGE'; @@ -31,6 +34,21 @@ ALTER TABLE `wiki_page_content` MODIFY COLUMN `preview` varchar(16000) CHARACTER -- alter table `db_datasource` add `name` varchar(50) DEFAULT NULL COMMENT '数据源名称'; +CREATE TABLE `es_datasource` ( + `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键自增ID', + `name` varchar(50) DEFAULT NULL COMMENT '数据源名称', + `host_port` varchar(512) DEFAULT NULL COMMENT '地址和端口', + `scheme` varchar(512) DEFAULT NULL COMMENT 'scheme,http或其他', + `create_user_id` bigint(20) DEFAULT NULL COMMENT '创建人ID', + `create_user_name` varchar(20) DEFAULT NULL COMMENT '创建人名字', + `create_time` datetime DEFAULT NULL COMMENT '创建时间', + `yn` tinyint(4) DEFAULT NULL COMMENT '是否有效 0=无效 1=有效', + PRIMARY KEY (`id`) USING BTREE +) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC; + + + + -- ------------------------全新的库:------------------------ diff --git a/zyplayer-doc-ui/es-ui/src/App.vue b/zyplayer-doc-ui/es-ui/src/App.vue index d4928ebb..701ac645 100644 --- a/zyplayer-doc-ui/es-ui/src/App.vue +++ b/zyplayer-doc-ui/es-ui/src/App.vue @@ -15,6 +15,13 @@ 数据源管理 + + + 数据查询 + 新增 - - - - + + +