Skip to content

C
cloud-esearch
Commit 3902d947 by liangkaiping
Options

copy

parent a39db23c
Showing with 4825 additions and 0 deletions
cloud-esearch-api/pom.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>cloud-esearch</artifactId>
<groupId>com.yizhi</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<packaging>jar</packaging>
<version>1.0-SNAPSHOT</version>
<artifactId>cloud-esearch-api</artifactId>
<dependencies>
<dependency>
<groupId>com.yizhi</groupId>
<artifactId>cloud-common-api</artifactId>
<version>1.0-SNAPSHOT</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-elasticsearch</artifactId>
<version>4.0.1.RELEASE</version>
<scope>compile</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
<configuration>
<skip>true</skip>
</configuration>
</plugin>
</plugins>
</build>
</project>
\ No newline at end of file
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/constant/Constant.java 0 → 100644
package com.yizhi.esearch.application.constant;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 15:30
*/
public interface Constant {
String index_Assignment = "assignment";
String INDEX_CASE_LIBRARY = "case_library";
String INDEX_COURSE = "course";
String INDEX_EXAM = "exam";
String INDEX_LECTURER = "lecturer";
String INDEX_MARKETING_COURSE = "course";
String INDEX_RESEARCH = "research";
String INDEX_STUDENT_CASE = "student_case";
String INDEX_TRAINING_PROJECT = "training_project";
String INDEX_ACCOUNT = "account";
String INDEX_ALBUM = "album";
String FIELD_COMPANY_ID = "companyId";
String FIELD_SITE_ID = "siteId";
String FIELD_ORG_ID = "orgId";
String FIELD_DELETED = "deleted";
String FIELD_VISIBLE_RANGE = "visibleRange";
// /**
// * pojo实体的index类型
// */
// Map<Class, String> POJO_INDEX_MAP = new HashMap<>();
// /**
// * pojo实体的type类型
// */
// Map<Class, String> POJO_TYPE_MAP = new HashMap<>();
//
// static {
// POJO_INDEX_MAP.put(TrainingProject.class, "training_project");
// POJO_INDEX_MAP.put(Assignment.class, "assignment");
// POJO_INDEX_MAP.put(Course.class, "course");
// POJO_INDEX_MAP.put(Exam.class, "exam");
// POJO_INDEX_MAP.put(Research.class, "research");
//
// POJO_TYPE_MAP.put(TrainingProject.class, "training_project");
// POJO_TYPE_MAP.put(Assignment.class, "assignment");
// POJO_TYPE_MAP.put(Course.class, "course");
// POJO_TYPE_MAP.put(Exam.class, "exam");
// POJO_TYPE_MAP.put(Research.class, "research");
// }
/**
* 是否删除：否
*/
Integer DELETED_NO = 0;
/**
* 是否删除：是
*/
Integer DELETED_YES = 1;
/**
* 上架状态
*/
Integer STATUS_UP = 1;
/**
* 下架状态
*/
Integer STATUS_DOWN = 2;
/**
* 草稿状态
*/
Integer STATUS_DRAFT = 0;
/**
* 可见范围：全站点可见
*/
Integer VISIBLE_RANGE_PUBLIC = 1;
/**
* 可见范围：指定范围可见
*/
Integer VISIBLE_RANGE_APPOINTED = 2;
/**
* 可见范围指定部门
*/
Integer VISIBLE_RANGE_APPOINTED_ORGANIZATION = 1;
/**
* 可见范围指定用户
*/
Integer VISIBLE_RANGE_APPOINTED_ACCOUNT = 2;
/**
* ---------------------------------------- 可见范围查询type ---------------------------------------------------
*/
String BIZ_TYPE_VISIBLE_ASSIGNMENT = "assignment_auth";
String BIZ_TYPE_VISIBLE_CASE_LIBRARY = "case_library_auth";
String BIZ_TYPE_VISIBLE_COURSE = "course_auth";
String BIZ_TYPE_VISIBLE_EXAM = "exam_auth";
String BIZ_TYPE_VISIBLE_STUDENT_CASE = "student_case_auth";
String BIZ_TYPE_VISIBLE_TRAINING_PROJECT = "training_project_auth";
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsAlbum.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import com.yizhi.esearch.application.constant.Constant;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 21:09
*/
@Data
@Document(indexName = "album")
public class EsAlbum {
@Id
private String id;
private String name;
private String keyword;
private String code;
/**
* @see Constant
*/
private Integer status;
/**
* @see Constant
*/
private Integer visibleRange;
/**
* @see Constant
*/
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
private LocalDateTime createTime;
private LocalDateTime updateTime;
private Long updateTimeLong;
public void setUpdateTime(LocalDateTime updateTime) {
this.updateTime = updateTime;
this.updateTimeLong = updateTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
public Long getUpdateTimeLong() {
if (updateTime == null) {
return null;
}
return updateTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
\ No newline at end of file
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsAssignment.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 21:09
*/
@Data
@Document(indexName = "assignment")
public class EsAssignment {
@ApiModelProperty("id")
@Id
private String id;
@ApiModelProperty("名称")
private String name;
private String keyword;
@ApiModelProperty("编码")
private String code;
@ApiModelProperty("是否支持补交(0：否，1：是")
private Integer amendable;
@ApiModelProperty("结束时间，如果是 null 值，则是长期有效")
private LocalDateTime endTime;
@ApiModelProperty("结束时间戳")
private Long endTimeLong;
private Integer status;
private Integer visibleRange;
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
public void setEndTime(LocalDateTime time) {
this.endTime = time;
if (null != time) {
endTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public Long getEndTimeLong() {
if (null == endTime) {
return null;
}
return endTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsBizKeyword.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import com.yizhi.esearch.application.constant.Constant;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 21:09
*/
@Data
@Document(indexName = "biz_keyword")
public class EsBizKeyword {
/**
* recommendType_siteId_{keyword}
*/
@Id
private String id;
private String recommendType;
/**
* 业务id
*/
@Field
private String bizId;
private String value;
private String kw_value;
/**
* @see Constant
*/
@Field
private Integer status;
@Field
private Integer deleted;
@Field
private String companyId;
@Field
private String siteId;
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsBizVisibleRange.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import com.yizhi.esearch.application.constant.Constant;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
import java.time.LocalDateTime;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 21:09
*/
@Data
@Document(indexName = "biz_visible_range")
public class EsBizVisibleRange {
/**
* concat(id, '_training_project_auth') as id,
*/
@Id
private String id;
@Field(type = FieldType.Keyword)
private String bizType;
/**
* 业务id
*/
@Field(type = FieldType.Keyword)
private String bizId;
/**
* @see Constant
*/
private Integer type;
@Field(type = FieldType.Keyword)
private String relationId;
/**
*
*/
private String name;
@Field
private Integer deleted;
@Field(type = FieldType.Keyword)
private String siteId;
private LocalDateTime indexTime;
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsCaseLibrary.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import com.yizhi.esearch.application.constant.Constant;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 21:09
*/
@Data
@Document(indexName = "case_library")
public class EsCaseLibrary {
@Id
private String id;
/**
* title
*/
private String name;
/**
* @see Constant
*/
private Integer status;
/**
* @see Constant
*/
private Integer visibleRange;
/**
* @see Constant
*/
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsCourse.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 15:24
*/
@Data
@Document(indexName = "course")
public class EsCourse {
@ApiModelProperty("id")
@Id
private String id;
@ApiModelProperty("名称")
private String name;
private String keyword;
// private String code;
//
// private String authorUnit;
//
// private String description;
//
// private String keyword;
@ApiModelProperty("上架时间")
private LocalDateTime releaseTime;
@ApiModelProperty("上架时间戳")
private Long releaseTimeLong;
private Integer visibleRange;
private Integer status;
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
public void setReleaseTime(LocalDateTime time) {
this.releaseTime = time;
if (time != null) {
this.releaseTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public Long getReleaseTimeLong() {
if (releaseTime == null) {
return null;
}
return releaseTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsDocRecommend.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import com.yizhi.esearch.application.constant.Constant;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 15:24
*/
@Data
@Document(indexName = "doc_recommend")
public class EsDocRecommend {
@Id
private String id;
private String recommendId;
private String recommendType;
private String name;
private String code;
private String keyword;
/**
* @see Constant
*/
private Integer status;
/**
* @see Constant
*/
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsExam.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 20:42
*/
@Data
@Document(indexName = "exam")
public class EsExam {
@ApiModelProperty("id")
@Id
private String id;
@ApiModelProperty("编码")
private String code;
@ApiModelProperty("名称")
private String name;
private String keyword;
private String description;
@ApiModelProperty("开始时间")
private LocalDateTime startTime;
@ApiModelProperty("开始时间戳")
private Long startTimeLong;
@ApiModelProperty("结束时间")
private LocalDateTime endTime;
@ApiModelProperty("结束时间戳")
private Long endTimeLong;
private Integer status;
private Integer visibleRange;
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
public void setStartTime(LocalDateTime time) {
this.startTime = time;
if (null != time) {
this.startTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public void setEndTime(LocalDateTime time) {
this.endTime = time;
if (null != time) {
this.endTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public Long getStartTimeLong() {
if (null == startTime) {
return null;
}
return startTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
public Long getEndTimeLong() {
if (null == endTime) {
return null;
}
return endTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsLecturer.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import com.yizhi.esearch.application.constant.Constant;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 21:09
*/
@Data
@Document(indexName = "lecturer")
public class EsLecturer {
@Id
private String id;
private String username;
/**
* 所在平台用户id
*/
private String accountId;
private String lecturerName;
private String keyword;
private String relationIds;
private String classifyId;
private String source;
private String avatar;
private String image;
private String title;
/**
* @see Constant
*/
private Integer status;
/**
* @see Constant
*/
private Integer deleted;
private String companyId;
private String siteId;
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsLive.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import com.yizhi.esearch.application.constant.Constant;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
/**
* @ClassName Live
* @Description TODO
* @Author shengchenglong
* @DATE 2019-12-26 15:39
* @Version 1.0
*/
@Data
@Document(indexName = "live")
public class EsLive {
@Id
private String id;
/**
* title
*/
private String name;
/**
* @see Constant
*/
private Integer status;
private String code;
private String keyword;
/**
* @see Constant
*/
private Integer visibleRange;
/**
* @see Constant
*/
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsMarketingCourse.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 15:24
*/
@Data
@Document(indexName = "course")
public class EsMarketingCourse {
@ApiModelProperty("id")
@Id
private String id;
@ApiModelProperty("名称")
private String name;
// private String code;
//
// private String authorUnit;
//
// private String description;
//
// private String keyword;
private String keyword;
@ApiModelProperty("上架时间")
private LocalDateTime releaseTime;
@ApiModelProperty("上架时间戳")
private Long releaseTimeLong;
private Integer visibleRange;
private Integer status;
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
public void setReleaseTime(LocalDateTime time) {
this.releaseTime = time;
if (time != null) {
this.releaseTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public Long getReleaseTimeLong() {
if (releaseTime == null) {
return null;
}
return releaseTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsOfflineCourse.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import com.yizhi.esearch.application.constant.Constant;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
/**
* @ClassName OfflineCourse
* @Description TODO
* @Author shengchenglong
* @DATE 2019-05-21 15:55
* @Version 1.0
*/
@Data
@Document(indexName = "offline_course")
public class EsOfflineCourse {
@Id
private String id;
private String name;
private String keyword;
private String code;
/**
* @see Constant
*/
private Integer status;
/**
* @see Constant
*/
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsResearch.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 09:46
*/
@Data
@Document(indexName = "research")
public class EsResearch {
@ApiModelProperty("id")
@Id
private String id;
@ApiModelProperty("编码")
private String code;
@ApiModelProperty("名称")
private String name;
private String keyword;
@ApiModelProperty("开始时间")
private LocalDateTime startTime;
@ApiModelProperty("开始时间戳")
private Long startTimeLong;
@ApiModelProperty("结束时间")
private LocalDateTime endTime;
@ApiModelProperty("结束时间戳")
private Long endTimeLong;
private Integer status;
private Integer visibleRange;
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
public void setStartTime(LocalDateTime time) {
this.startTime = time;
if (null != time) {
this.startTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public void setEndTime(LocalDateTime time) {
this.endTime = time;
if (null != time) {
this.endTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public Long getStartTimeLong() {
if (startTime == null) {
return null;
}
return startTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
public Long getEndTimeLong() {
if (endTime == null) {
return null;
}
return endTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsStudentCase.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import com.yizhi.esearch.application.constant.Constant;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 21:09
*/
@Data
@Document(indexName = "student_case")
public class EsStudentCase {
@Id
private String id;
/**
* title
*/
private String name;
/**
* @see Constant
*/
private Integer status;
/**
* @see Constant
*/
private Integer visibleRange;
/**
* @see Constant
*/
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsTrainingProject.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 16:18
*/
@Data
@Document(indexName = "training_project")
public class EsTrainingProject {
@ApiModelProperty("id")
@Id
private String id;
@ApiModelProperty("名称")
private String name;
// private String description;
private String keyword;
@ApiModelProperty("开始时间")
private LocalDateTime startTime;
@ApiModelProperty("开始时间戳")
private Long startTimeLong;
@ApiModelProperty("结束时间")
private LocalDateTime endTime;
@ApiModelProperty("结束时间戳")
private Long endTimeLong;
@ApiModelProperty("上架时间")
private LocalDateTime releaseTime;
@ApiModelProperty("上架时间戳")
private Long releaseTimeLong;
private Integer status;
private Integer enableEnroll;
/**
* 项目是否0：指定学员可见，1平台用户可见（创建人管理权限范围）
*/
private Integer visibleRange;
private Integer deleted;
private String companyId;
private String siteId;
private String orgId;
private String image;
public void setStartTime(LocalDateTime time) {
this.startTime = time;
if (null != time) {
this.startTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public void setEndTime(LocalDateTime time) {
this.endTime = time;
if (null != time) {
this.endTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public void setReleaseTime(LocalDateTime time) {
this.releaseTime = time;
if (time != null) {
this.releaseTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public Long getStartTimeLong() {
if (startTime == null) {
return null;
}
return startTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
public Long getEndTimeLong() {
if (endTime == null) {
return null;
}
return endTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
public Long getReleaseTimeLong() {
if (releaseTime == null) {
return null;
}
return releaseTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/biz/EsTrainingProjectEnrollRecord.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 16:18
*/
@Data
@Document(indexName = "training_project_enroll_record")
public class EsTrainingProjectEnrollRecord {
@Id
private String id;
@Field(type = FieldType.Keyword)
private String trainingProjectId;
@Field(type = FieldType.Keyword)
private String siteId;
@Field(type = FieldType.Keyword)
private String enrollId;
@Field(type = FieldType.Keyword)
private String accountId;
private LocalDateTime startTime;
private Long startTimeLong;
private LocalDateTime endTime;
private Long endTimeLong;
private LocalDateTime joinTime;
private Long joinTimeLong;
public void setStartTime(LocalDateTime time) {
this.startTime = time;
if (null != time) {
this.startTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public void setEndTime(LocalDateTime time) {
this.endTime = time;
if (null != time) {
this.endTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public void setJoinTime(LocalDateTime time) {
this.joinTime = time;
if (time != null) {
this.joinTimeLong = time.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
public Long getStartTimeLong() {
if (startTime == null) {
return null;
}
return startTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
public Long getEndTimeLong() {
if (endTime == null) {
return null;
}
return endTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
public Long getJoinTimeLong() {
if (joinTime == null) {
return null;
}
return joinTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
}
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/system/EsAccount.java 0 → 100644
package com.yizhi.esearch.application.pojo.system;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.data.elasticsearch.annotations.Document;
/**
* @ClassName Account
* @Description 平台用户
* @Author chengchenglong
* @DATE 2019-04-17 14:57
* @Version 1.0
*/
@Data
@Document(indexName = "account")
@ApiModel(value = "用户")
public class EsAccount {
@ApiModelProperty(value = "id")
private String id;
@ApiModelProperty(value = "账号名称")
private String name;
@ApiModelProperty(value = "性别(‘M’:男,'F':女)")
private String sex;
@ApiModelProperty(value = "账号描述")
private String description;
@ApiModelProperty(value = "全名")
private String fullName;
@ApiModelProperty(value = "工号")
private String workNum;
@ApiModelProperty(value = "座机")
private String telephone;
@ApiModelProperty(value = "手机号")
private String mobile;
@ApiModelProperty(value = "邮箱地址")
private String email;
@ApiModelProperty(value = "微信")
private String wechat;
@ApiModelProperty(value = "职位")
private String position;
@ApiModelProperty(value = "是否开通")
private Integer enabled;
@ApiModelProperty(value = "是否锁定")
private Integer locked;
@ApiModelProperty(value = "部门id")
private Long orgId;
@ApiModelProperty(value = "部门名称")
private String orgName;
private Integer orgLeftIndex;
private Integer orgRightIndex;
@ApiModelProperty(value = "租户(公司)id")
private String companyId;
@ApiModelProperty(value = "公司名称")
private String companyName;
}
\ No newline at end of file
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/pojo/system/EsOrganization.java 0 → 100644
package com.yizhi.esearch.application.pojo.system;
import com.yizhi.esearch.application.constant.Constant;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
/**
* @ClassName Organization
* @Description 部门
* @Author chengchenglong
* @DATE 2019-04-17 20:18
* @Version 1.0
*/
@Data
@Document(indexName = "organization")
public class EsOrganization {
@Id
private String id;
private String name;
private String parentId;
// private String parentIdLayer;
//
// private String parentIdLayerName;
//
// private String childIdLayer;
//
// private String childIdLayerName;
private Integer layer;
/**
* @see Constant
*/
private Integer deleted;
private String companyId;
private Integer leftIndex;
private Integer rightIndex;
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/query/CIndexQuery.java 0 → 100644
package com.yizhi.esearch.application.query;
/**
* @ClassName CIndexQuery
* @Description TODO
* @Author shengchenglong
* @DATE 2019-12-30 19:26
* @Version 1.0
*/
public class CIndexQuery {
}
cloud-esearch-api/src/main/java/com/yizhi/esearch/application/vo/GlobalSearchVo.java 0 → 100644
package com.yizhi.esearch.application.vo;
import com.yizhi.esearch.application.pojo.biz.*;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/27 10:32
*/
@Data
@ApiModel("全局搜索返回 vo")
public class GlobalSearchVo {
@ApiModelProperty("课程")
private List<EsCourse> courses;
@ApiModelProperty("营销课程")
private List<EsMarketingCourse> marketingCourses;
@ApiModelProperty("培训项目")
private List<EsTrainingProject> trainingProjects;
@ApiModelProperty("考试")
private List<EsExam> exams;
@ApiModelProperty("作业")
private List<EsAssignment> assignments;
@ApiModelProperty("调研")
private List<EsResearch> research;
@ApiModelProperty("讲师")
private List<EsLecturer> lecturers;
@ApiModelProperty("案例库")
private List<EsStudentCase> studentCases;
@ApiModelProperty("案例库")
private List<EsAlbum> albums;
}
cloud-esearch-service/pom.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>cloud-esearch</artifactId>
<groupId>com.yizhi</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>cloud-esearch-service</artifactId>
<dependencies>
<dependency>
<groupId>com.yizhi</groupId>
<artifactId>cloud-core</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-elasticsearch</artifactId>
<version>4.0.1.RELEASE</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>com.yizhi</groupId>-->
<!-- <artifactId>cloud-orm</artifactId>-->
<!-- <version>1.0-SNAPSHOT</version>-->
<!-- -->
<!-- </dependency>-->
<dependency>
<groupId>com.yizhi</groupId>
<artifactId>cloud-util</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.yizhi</groupId>
<artifactId>cloud-esearch-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!-- https://mvnrepository.com/artifact/cglib/cglib -->
<dependency>
<groupId>cglib</groupId>
<artifactId>cglib</artifactId>
</dependency>
<dependency>
<groupId>com.yizhi</groupId>
<artifactId>cloud-drools-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
<build>
<plugins>
<!-- deploy 时跳过该模块 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-deploy-plugin</artifactId>
<configuration>
<skip>true</skip>
</configuration>
</plugin>
</plugins>
</build>
</project>
\ No newline at end of file
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/CloudEsearchApplication.java 0 → 100644
package com.yizhi.esearch.application;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
import org.springframework.scheduling.annotation.EnableScheduling;
@EnableDiscoveryClient
@SpringBootApplication
@EnableElasticsearchRepositories(basePackages = {"com.yizhi.esearch.application.repository"})
@EnableScheduling
@ComponentScan({"com.yizhi"})
public class CloudEsearchApplication {
public static void main(String[] args) {
SpringApplication.run(CloudEsearchApplication.class, args);
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/config/DateGenericConverter.java 0 → 100644
//package com.fulan.esearch.application.config;
//
//import cn.hutool.core.date.DateTime;
//import cn.hutool.core.date.DateUtil;
//import org.springframework.beans.factory.InitializingBean;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.core.convert.TypeDescriptor;
//import org.springframework.core.convert.converter.GenericConverter;
//import org.springframework.core.convert.support.GenericConversionService;
//import org.springframework.stereotype.Component;
//
//import java.util.Collections;
//import java.util.Date;
//import java.util.Set;
//
///**
// * @ClassName DateGenericConverter
// * @Description TODO
// * @Author shengchenglong
// * @DATE 2020/7/19 4:31 下午
// * @Version 1.0
// */
//@Component
//public class DateGenericConverter implements GenericConverter, InitializingBean {
//
// private static final String PARTTERN = "yyyy-MM-dd'T'HH:mm:ss.SSSXXX";
//
// @Autowired
// private GenericConversionService genericConversionService;
//
// @Override
// public Set<ConvertiblePair> getConvertibleTypes() {
// return Collections.singleton(new ConvertiblePair(String.class, Date.class));
// }
//
// @Override
// public Object convert(Object source, TypeDescriptor sourceType, TypeDescriptor targetType) {
// DateTime dateTime = DateUtil.parse(String.valueOf(source), PARTTERN);
// return dateTime.toJdkDate();
// }
//
//
// @Override
// public void afterPropertiesSet() throws Exception {
// genericConversionService.addConverter(this);
// }
//}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/config/SwaggerConfig.java 0 → 100644
package com.yizhi.esearch.application.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
/**
* @Author: shengchenglong
* @Date: 2018/3/6 14:30
*/
@Configuration
@EnableSwagger2
public class SwaggerConfig {
@Bean
public Docket createRestApi() {
return new Docket(DocumentationType.SWAGGER_2)
.groupName("搜索")
.apiInfo(apiInfo())
.select()
.apis(RequestHandlerSelectors.basePackage("com.fulan.application"))
.paths(PathSelectors.any())
.build();
}
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
.title("搜索")
//版本
.version("1.0")
.build();
}
// @Override
// public void addResourceHandlers(ResourceHandlerRegistry registry) {
// registry.addResourceHandler("swagger-ui.html").addResourceLocations("classpath:/META-INF/resources/");
// registry.addResourceHandler("docs.html").addResourceLocations("classpath:/META-INF/resources/");
// registry.addResourceHandler("/webjars/**").addResourceLocations("classpath:/META-INF/resources/webjars/");
// }
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/AlbumController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.biz.EsAlbum;
import com.yizhi.esearch.application.pojo.biz.EsAssignment;
import com.yizhi.esearch.application.util.QueryHelper;
import com.yizhi.esearch.application.util.ResponseHelper;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/26 17:54
*/
@Api(tags = "作业搜索")
@RestController
@RequestMapping("/search/albums")
public class AlbumController {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@GetMapping("name/{keyword}/{pageNo}/{pageSize}")
@ApiOperation(value = "作业搜索", response = EsAssignment.class)
public Response<List<EsAlbum>> name(
@ApiParam(name = "keyword", value = "搜索关键词") @PathVariable("keyword") String keyword,
@ApiParam(name = "pageNo", value = "第几页") @PathVariable("pageNo") Integer pageNo,
@ApiParam(name = "pageSize", value = "每页几条") @PathVariable("pageSize") Integer pageSize) {
Query searchQuery = QueryHelper.commonPageSearchQueryForKeyword(keyword, EsAlbum.class, pageNo, pageSize, "indexTime", false, elasticsearchRestTemplate);
Page<EsAlbum> page = elasticsearchRestTemplate.queryForPage(searchQuery, EsAlbum.class, IndexCoordinates.of(Constant.INDEX_ALBUM));
return ResponseHelper.ok(page);
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/AssignmentController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.biz.EsAssignment;
import com.yizhi.esearch.application.util.QueryHelper;
import com.yizhi.esearch.application.util.ResponseHelper;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/26 17:54
*/
@Api(tags = "作业搜索")
@RestController
@RequestMapping("/search/assignment")
public class AssignmentController {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@GetMapping("name/{keyword}/{pageNo}/{pageSize}")
@ApiOperation(value = "作业搜索", response = EsAssignment.class)
public Response<List<EsAssignment>> name(
@ApiParam(name = "keyword", value = "搜索关键词") @PathVariable("keyword") String keyword,
@ApiParam(name = "pageNo", value = "第几页") @PathVariable("pageNo") Integer pageNo,
@ApiParam(name = "pageSize", value = "每页几条") @PathVariable("pageSize") Integer pageSize) {
Query searchQuery = QueryHelper.commonPageSearchQueryForKeyword(keyword, EsAssignment.class, pageNo, pageSize, "endTime", false, elasticsearchRestTemplate);
Page<EsAssignment> page = elasticsearchRestTemplate.queryForPage(searchQuery, EsAssignment.class, IndexCoordinates.of(Constant.index_Assignment));
return ResponseHelper.ok(page);
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/CourseController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.biz.EsCourse;
import com.yizhi.esearch.application.util.QueryHelper;
import com.yizhi.esearch.application.util.ResponseHelper;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/26 17:06
*/
@Api(tags = "课程搜索")
@RestController
@RequestMapping("/search/course")
public class CourseController {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@GetMapping("name/{keyword}/{pageNo}/{pageSize}")
@ApiOperation(value = "课程搜索", response = EsCourse.class)
public Response<List<EsCourse>> name(
@ApiParam(name = "keyword", value = "搜索关键词") @PathVariable("keyword") String keyword,
@ApiParam(name = "pageNo", value = "第几页") @PathVariable("pageNo") Integer pageNo,
@ApiParam(name = "pageSize", value = "每页几条") @PathVariable("pageSize") Integer pageSize) {
Query searchQuery = QueryHelper.commonPageSearchQueryForKeyword(keyword, EsCourse.class, pageNo, pageSize, "releaseTime", false, elasticsearchRestTemplate);
Page<EsCourse> page = elasticsearchRestTemplate.queryForPage(searchQuery, EsCourse.class, IndexCoordinates.of(Constant.INDEX_COURSE));
return ResponseHelper.ok(page);
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/ExamController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.biz.EsExam;
import com.yizhi.esearch.application.util.QueryHelper;
import com.yizhi.esearch.application.util.ResponseHelper;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/27 10:00
*/
@Api(tags = "考试搜索")
@RestController
@RequestMapping("/search/exam")
public class ExamController {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@GetMapping("name/{keyword}/{pageNo}/{pageSize}")
@ApiOperation(value = "考试搜索", response = EsExam.class)
public Response<List<EsExam>> name(
@ApiParam(name = "keyword", value = "搜索关键词") @PathVariable("keyword") String keyword,
@ApiParam(name = "pageNo", value = "第几页") @PathVariable("pageNo") Integer pageNo,
@ApiParam(name = "pageSize", value = "每页几条") @PathVariable("pageSize") Integer pageSize) {
Query searchQuery = QueryHelper.commonPageSearchQueryForKeyword(keyword, EsExam.class, pageNo, pageSize, "endTime", false, elasticsearchRestTemplate);
Page<EsExam> page = elasticsearchRestTemplate.queryForPage(searchQuery, EsExam.class, IndexCoordinates.of(Constant.INDEX_EXAM));
return ResponseHelper.ok(page);
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/GlobalSearchController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.esearch.application.pojo.biz.*;
import com.yizhi.esearch.application.util.QueryHelper;
import com.yizhi.esearch.application.vo.GlobalSearchVo;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @Author: shengchenglong
* @Date: 2018/12/27 10:08
*/
@Api(tags = "全局搜索")
@RestController
@RequestMapping("/search/global")
public class GlobalSearchController {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@Autowired
private LecturerController lecturerController;
@GetMapping("/{keyword}")
@ApiOperation(value = "全局搜索", response = GlobalSearchVo.class)
public Response<GlobalSearchVo> globalSearch(
@ApiParam(name = "keyword", value = "搜索关键字") @PathVariable("keyword") String keyword) {
GlobalSearchVo vo = new GlobalSearchVo();
vo.setAssignments(QueryHelper.globalSearch(keyword, EsAssignment.class, elasticsearchRestTemplate));
vo.setCourses(QueryHelper.globalSearch(keyword, EsCourse.class, elasticsearchRestTemplate));
vo.setMarketingCourses(QueryHelper.globalSearch(keyword, EsMarketingCourse.class, elasticsearchRestTemplate));
vo.setExams(QueryHelper.globalSearch(keyword, EsExam.class, elasticsearchRestTemplate));
vo.setResearch(QueryHelper.globalSearch(keyword, EsResearch.class, elasticsearchRestTemplate));
vo.setTrainingProjects(QueryHelper.globalSearch(keyword, EsTrainingProject.class, elasticsearchRestTemplate));
vo.setStudentCases(QueryHelper.globalSearch(keyword, EsStudentCase.class, elasticsearchRestTemplate));
vo.setAlbums(QueryHelper.globalSearch(keyword, EsAlbum.class, elasticsearchRestTemplate));
Page page = (Page) lecturerController.name(keyword, 1, 2).getData();
if (page != null) {
vo.setLecturers((page.getContent()));
}
return Response.ok(vo);
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/LecturerController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.core.application.context.ContextHolder;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.biz.EsCourse;
import com.yizhi.esearch.application.pojo.biz.EsLecturer;
import com.yizhi.esearch.application.pojo.biz.EsOfflineCourse;
import com.yizhi.esearch.application.pojo.biz.EsTrainingProject;
import com.yizhi.esearch.application.repository.CourseRepository;
import com.yizhi.esearch.application.repository.LecturerRepository;
import com.yizhi.esearch.application.repository.OfflineCourseRepository;
import com.yizhi.esearch.application.repository.TrainingProjectRepository;
import com.yizhi.esearch.application.util.QueryHelper;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.sort.SortBuilders;
import org.elasticsearch.search.sort.SortOrder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.document.Document;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.data.elasticsearch.core.query.UpdateQuery;
import org.springframework.data.elasticsearch.core.query.UpdateResponse;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.*;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
/**
* @Author: shengchenglong
* @Date: 2018/12/26 17:54
*/
@Api(tags = "讲师搜索")
@RestController
@RequestMapping("/search/lecturer")
public class LecturerController {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@Autowired
private CourseRepository courseRepository;
@Autowired
private TrainingProjectRepository trainingProjectRepository;
@Autowired
private OfflineCourseRepository offlineCourseRepository;
@Autowired
private LecturerRepository lecturerRepository;
@GetMapping("name/{keyword}/{pageNo}/{pageSize}")
@ApiOperation(value = "讲师搜索", response = EsLecturer.class)
public Response<EsLecturer> name(
@ApiParam(name = "keyword", value = "搜索关键词") @PathVariable("keyword") String keyword,
@ApiParam(name = "pageNo", value = "第几页") @PathVariable("pageNo") Integer pageNo,
@ApiParam(name = "pageSize", value = "每页几条") @PathVariable("pageSize") Integer pageSize) {
return list(keyword, null, pageNo, pageSize);
}
@GetMapping("/list")
@ApiOperation(value = "讲师搜索", response = EsLecturer.class)
public Response<EsLecturer> list(
@ApiParam(name = "keyword", value = "搜索关键字") @RequestParam(name = "keyword", required = false) String keyword,
@ApiParam(name = "classifyId", value = "讲师分类") @RequestParam(name = "classifyId", required = false) String classifyId,
@ApiParam(name = "pageNo", value = "第几页") @RequestParam("pageNo") Integer pageNo,
@ApiParam(name = "pageSize", value = "每页几条") @RequestParam("pageSize") Integer pageSize) {
String siteId = String.valueOf(ContextHolder.get().getSiteId());
QueryBuilder qbContext = QueryHelper.getCommonQueryBuilderForContext();
QueryBuilder qbSearch = null;
if (!StringUtils.isEmpty(keyword)) {
String relationIds = "";
// 查出课程的
List<EsCourse> courses = courseRepository.findBySiteIdEqualsAndNameAndStatusAndDeleted(siteId, keyword, Constant.STATUS_UP, Constant.DELETED_NO);
if (!CollectionUtils.isEmpty(courses)) {
for (EsCourse c : courses) {
relationIds = relationIds.concat(c.getId().concat(" "));
}
}
// 查出培训项目的
List<EsTrainingProject> trainingProjects = trainingProjectRepository.findBySiteIdEqualsAndNameAndStatusAndDeleted(siteId, keyword, Constant.STATUS_UP, Constant.DELETED_NO);
if (!CollectionUtils.isEmpty(trainingProjects)) {
for (EsTrainingProject tp : trainingProjects) {
relationIds = relationIds.concat(tp.getId().concat(" "));
}
}
// 查出线下课程的
List<EsOfflineCourse> offlineCourses = offlineCourseRepository.findBySiteIdEqualsAndNameAndStatusAndDeleted(siteId, keyword, Constant.STATUS_UP, Constant.DELETED_NO);
if (!CollectionUtils.isEmpty(offlineCourses)) {
for (EsOfflineCourse oc : offlineCourses) {
relationIds = relationIds.concat(oc.getId().concat(" "));
}
}
QueryBuilder qbForRelationIds = QueryBuilders.boolQuery().must(QueryBuilders.matchQuery("relationIds", relationIds));
//支持模糊查询，以*为前缀会影响查询性能。
QueryBuilder qbForLecturerName = QueryBuilders.boolQuery().must(QueryBuilders.matchQuery("lecturerName", keyword));
qbSearch = QueryBuilders.boolQuery().should(qbForRelationIds).should(qbForLecturerName);
}
if (!StringUtils.isEmpty(classifyId)) {
String[] classifyIds = classifyId.split(",");
BoolQueryBuilder qb = QueryBuilders.boolQuery();
for (String id : classifyIds) {
qb.should(QueryBuilders.matchQuery("classifyId", id));
}
if (qbSearch != null) {
qbSearch = QueryBuilders.boolQuery().must(qbSearch).must(qb);
} else {
qbSearch = QueryBuilders.boolQuery().must(qb);
}
}
Query searchQuery = new NativeSearchQueryBuilder()
// .addAggregation(getTimeAggreation())
.withQuery(qbSearch)
.withFilter(qbContext)
// page从0开始
.withPageable(PageRequest.of(pageNo - 1, pageSize))
// notice: 先按评分倒排，再按业务要求排序
.withSort(SortBuilders.scoreSort().order(SortOrder.DESC))
.build();
Page<EsLecturer> page = elasticsearchRestTemplate.queryForPage(searchQuery, EsLecturer.class, IndexCoordinates.of(Constant.INDEX_LECTURER));
return Response.ok(page);
}
/**
* 更新启用禁用状态
*
* @param map
* @return
*/
@PostMapping("/enableStatus/update")
public boolean updateEnableStatus(@RequestBody Map<String, Object> map) {
Long id = Long.valueOf(String.valueOf(map.get("id")));
boolean enabled = Boolean.valueOf(String.valueOf(map.get("enabled")));
Optional<EsLecturer> optional = lecturerRepository.findById(id);
if (!optional.isPresent()) {
return false;
}
EsLecturer lecturer = optional.get();
HashMap<String, Object> params = new HashMap<>();
params.put("status", enabled ? Constant.STATUS_UP : Constant.STATUS_DOWN);
UpdateQuery updateQuery = UpdateQuery.builder(lecturer.getId())
.withDocument(Document.from(params))
.build();
UpdateResponse updateResponse = elasticsearchRestTemplate.update(updateQuery, IndexCoordinates.of(Constant.INDEX_LECTURER));
return UpdateResponse.Result.UPDATED.equals(updateResponse.getResult())
// 未改变值也算更新成功
|| UpdateResponse.Result.NOOP.equals(updateResponse.getResult());
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/MarketingCourseController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.biz.EsMarketingCourse;
import com.yizhi.esearch.application.util.QueryHelper;
import com.yizhi.esearch.application.util.ResponseHelper;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/26 17:06
*/
@Api(tags = "营销课程搜索")
@RestController
@RequestMapping("/search/marketingCourse")
public class MarketingCourseController {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@GetMapping("name/{keyword}/{pageNo}/{pageSize}")
@ApiOperation(value = "课程搜索", response = EsMarketingCourse.class)
public Response<List<EsMarketingCourse>> name(
@ApiParam(name = "keyword", value = "搜索关键词") @PathVariable("keyword") String keyword,
@ApiParam(name = "pageNo", value = "第几页") @PathVariable("pageNo") Integer pageNo,
@ApiParam(name = "pageSize", value = "每页几条") @PathVariable("pageSize") Integer pageSize) {
Query searchQuery = QueryHelper.commonPageSearchQueryForKeyword(keyword, EsMarketingCourse.class, pageNo, pageSize, "releaseTime", false, elasticsearchRestTemplate);
Page<EsMarketingCourse> page = elasticsearchRestTemplate.queryForPage(searchQuery, EsMarketingCourse.class, IndexCoordinates.of(Constant.INDEX_MARKETING_COURSE));
return ResponseHelper.ok(page);
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/ResearchController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.biz.EsResearch;
import com.yizhi.esearch.application.util.QueryHelper;
import com.yizhi.esearch.application.util.ResponseHelper;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/26 17:06
*/
@Api(tags = "调研搜索")
@RestController
@RequestMapping("/search/research")
public class ResearchController {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@GetMapping("name/{keyword}/{pageNo}/{pageSize}")
@ApiOperation(value = "调研搜索", response = EsResearch.class)
public Response<List<EsResearch>> name(
@ApiParam(name = "keyword", value = "搜索关键词") @PathVariable("keyword") String keyword,
@ApiParam(name = "pageNo", value = "第几页") @PathVariable("pageNo") Integer pageNo,
@ApiParam(name = "pageSize", value = "每页几条") @PathVariable("pageSize") Integer pageSize) {
Query searchQuery = QueryHelper.commonPageSearchQueryForKeyword(keyword, EsResearch.class, pageNo, pageSize, "endTime", true, elasticsearchRestTemplate);
Page<EsResearch> page = elasticsearchRestTemplate.queryForPage(searchQuery, EsResearch.class, IndexCoordinates.of(Constant.INDEX_RESEARCH));
return ResponseHelper.ok(page);
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/StudentCaseController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.biz.EsExam;
import com.yizhi.esearch.application.pojo.biz.EsStudentCase;
import com.yizhi.esearch.application.util.QueryHelper;
import com.yizhi.esearch.application.util.ResponseHelper;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/27 10:00
*/
@Api(tags = "案例库搜索")
@RestController
@RequestMapping("/search/studentCase")
public class StudentCaseController {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@GetMapping("name/{keyword}/{pageNo}/{pageSize}")
@ApiOperation(value = "案例库搜索", response = EsExam.class)
public Response<List<EsStudentCase>> name(
@ApiParam(name = "keyword", value = "搜索关键词") @PathVariable("keyword") String keyword,
@ApiParam(name = "pageNo", value = "第几页") @PathVariable("pageNo") Integer pageNo,
@ApiParam(name = "pageSize", value = "每页几条") @PathVariable("pageSize") Integer pageSize) {
Query searchQuery = QueryHelper.commonPageSearchQueryForKeyword(keyword, EsStudentCase.class, pageNo, pageSize, "status", false, elasticsearchRestTemplate);
Page<EsStudentCase> page = elasticsearchRestTemplate.queryForPage(searchQuery, EsStudentCase.class, IndexCoordinates.of(Constant.INDEX_STUDENT_CASE));
return ResponseHelper.ok(page);
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/TrainingProjectController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.biz.EsTrainingProject;
import com.yizhi.esearch.application.util.QueryHelper;
import com.yizhi.esearch.application.util.ResponseHelper;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 14:39
*/
@Api(tags = "培训项目搜索")
@RestController
@RequestMapping("/search/trainingProject")
public class TrainingProjectController {
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@GetMapping("name/{keyword}/{pageNo}/{pageSize}")
@ApiOperation(value = "培训项目搜索", response = EsTrainingProject.class)
public Response<List<EsTrainingProject>> name(
@ApiParam(name = "keyword", value = "搜索关键词") @PathVariable("keyword") String keyword,
@ApiParam(name = "pageNo", value = "第几页") @PathVariable("pageNo") Integer pageNo,
@ApiParam(name = "pageSize", value = "每页几条") @PathVariable("pageSize") Integer pageSize) {
Query searchQuery = QueryHelper.commonPageSearchQueryForKeyword(keyword, EsTrainingProject.class, pageNo, pageSize, "releaseTime", false, elasticsearchRestTemplate);
Page<EsTrainingProject> page = elasticsearchRestTemplate.queryForPage(searchQuery, EsTrainingProject.class, IndexCoordinates.of(Constant.INDEX_TRAINING_PROJECT));
return ResponseHelper.ok(page);
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/api/WebErrorLogController.java 0 → 100644
package com.yizhi.esearch.application.controller.api;
import com.yizhi.core.application.context.ContextHolder;
import com.yizhi.core.application.context.RequestContext;
import com.yizhi.esearch.application.pojo.biz.WebErrorLog;
import com.yizhi.esearch.application.repository.WebErrorLogRepository;
import com.yizhi.esearch.application.util.ResponseHelper;
import com.yizhi.util.application.domain.Response;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Date;
/**
* @Author: shengchenglong
* @Date: 2018/12/26 17:54
*/
@Api(tags = "前端错误日志")
@RestController
@RequestMapping("/webErrorLog")
public class WebErrorLogController {
@Autowired
private WebErrorLogRepository webErrorLogRepository;
@PostMapping("/save")
@ApiOperation(value = "保存前端错误日志", response = String.class)
public Response saveWebErrorLog(@ApiParam(name = "webErrorLog", value = "保存错误日志")
@RequestBody WebErrorLog webErrorLog) {
RequestContext context = ContextHolder.get();
webErrorLog.setCompanyId(context.getCompanyId().toString());
webErrorLog.setSiteId(context.getSiteId().toString());
webErrorLog.setOrgId(context.getOrgId().toString());
webErrorLog.setCreateById(context.getAccountId().toString());
webErrorLog.setCreateByName(context.getAccountName());
webErrorLog.setCreateTime(new Date());
WebErrorLog save = webErrorLogRepository.save(webErrorLog);
if (save != null) {
return ResponseHelper.ok("保存成功！");
}
return ResponseHelper.ok("保存失败！");
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/remote/BizKeywordController.java 0 → 100644
package com.yizhi.esearch.application.controller.remote;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.yizhi.core.application.context.ContextHolder;
import com.yizhi.core.application.context.RequestContext;
import com.yizhi.esearch.application.pojo.biz.EsBizKeyword;
import com.yizhi.esearch.application.repository.BizKeywordRepository;
import com.yizhi.esearch.application.util.QueryHelper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @ClassName RecommendController
* @Description TODO
* @Author shengchenglong
* @DATE 2019-12-30 14:14
* @Version 1.0
*/
@Slf4j
@RestController
@RequestMapping("/recommend/bizKeyword")
public class BizKeywordController {
@Autowired
private BizKeywordRepository bizKeywordRepository;
/**
* taskId
* taskFieldValue
* taskParamsType
*/
@PostMapping("keywordPage")
public Map<String, String> keywordPage(@RequestBody Map<String, String> map) {
int pageNo = Integer.parseInt(map.get("pageNo"));
int pageSize = Integer.parseInt(map.get("pageSize"));
String contextJson = map.get("context");
RequestContext context = JSON.parseObject(contextJson, RequestContext.class);
ContextHolder.set(context);
BoolQueryBuilder qb = QueryBuilders.boolQuery()
.must(QueryBuilders.termQuery("recommendType", map.get("taskType").toLowerCase()));
if (StringUtils.isNotEmpty(map.get("taskParamsValue"))) {
qb.must(QueryBuilders.matchQuery("value", map.get("taskParamsValue")));
}
Query searchQuery = new NativeSearchQueryBuilder()
.withQuery(qb)
.withFilter(QueryHelper.getCommonQueryBuilderForContext())
.withPageable(PageRequest.of(pageNo - 1, pageSize))
.build();
Page page = bizKeywordRepository.search(searchQuery);
List<EsBizKeyword> list = page.getContent();
Map<String, String> resMap = new HashMap<>();
resMap.put("total", String.valueOf(page.getTotalElements()));
if (!CollectionUtils.isEmpty(list)) {
JSONArray jsonArray = new JSONArray();
list.forEach(item -> {
JSONObject jsonObject = new JSONObject();
jsonObject.put("taskId", item.getBizId());
jsonObject.put("taskFieldValue", item.getValue());
jsonObject.put("taskParamsType", "keyword");
jsonArray.add(jsonObject);
});
resMap.put("record", jsonArray.toJSONString());
}
log.info(JSON.toJSONString(resMap));
return resMap;
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/remote/OrganizationController.java 0 → 100644
package com.yizhi.esearch.application.controller.remote;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.system.EsOrganization;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.sort.SortBuilders;
import org.elasticsearch.search.sort.SortOrder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.GetQuery;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
/**
* @ClassName OrganizationController
* @Description TODO
* @Author chengchenglong
* @DATE 2019-04-18 16:47
* @Version 1.0
*/
@RestController
@RequestMapping("/org")
public class OrganizationController {
@Autowired
private ElasticsearchRestTemplate elasticsearchTemplate;
/**
* 查询父级部门的名称集合
* @param orgId
* @return
*/
@GetMapping("/parent/names")
public List<String> getParentNames(@RequestParam("orgId") Long orgId) {
GetQuery getQuery = new GetQuery(String.valueOf(orgId));
EsOrganization org = elasticsearchTemplate.queryForObject(getQuery, EsOrganization.class);
if (org != null) {
int leftIndex = org.getLeftIndex();
int rightIndex = org.getRightIndex();
QueryBuilder leftIndexQB = QueryBuilders.rangeQuery("leftIndex").lte(leftIndex);
QueryBuilder rightIndexQB = QueryBuilders.rangeQuery("rightIndex").gte(rightIndex);
QueryBuilder queryBuilder = QueryBuilders.boolQuery()
.must(QueryBuilders.termQuery(Constant.FIELD_COMPANY_ID, org.getCompanyId()))
.must(QueryBuilders.termQuery(Constant.FIELD_DELETED, Constant.DELETED_NO))
.must(leftIndexQB)
.must(rightIndexQB);
Query searchQuery = new NativeSearchQueryBuilder()
.withQuery(queryBuilder)
.withSort(SortBuilders.fieldSort("leftIndex").order(SortOrder.ASC))
// notice: 这里指定字段则只会查询相应的字段值，其余字段为null
.withFields("name")
.build();
List<EsOrganization> parents = elasticsearchTemplate.queryForList(searchQuery, EsOrganization.class, IndexCoordinates.of("organization"));
if (!CollectionUtils.isEmpty(parents)) {
List<String> names = new ArrayList<>(parents.size() + 1);
parents.forEach(item -> names.add(item.getName()));
names.add(org.getName());
return names;
}
}
return null;
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/remote/RemoteBizVisibleRangeController.java 0 → 100644
package com.yizhi.esearch.application.controller.remote;
import com.alibaba.fastjson.JSON;
import com.yizhi.core.application.context.ContextHolder;
import com.yizhi.core.application.context.RequestContext;
import com.yizhi.esearch.application.util.QueryHelper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
/**
* @ClassName RemoteBizVisibleRangeController
* @Description TODO
* @Author shengchenglong
* @DATE 2020-03-27 19:28
* @Version 1.0
*/
@Slf4j
@RestController
@RequestMapping("remote/bizVisibleRange")
public class RemoteBizVisibleRangeController {
@Autowired
private ElasticsearchRestTemplate elasticsearchTemplate;
@GetMapping("getVisibleBizId")
public List<Long> getVisibleBizId(@RequestParam("bizType") String bizType,
@RequestParam("requestContext") String requestContext) {
RequestContext context = (RequestContext) JSON.parse(requestContext);
ContextHolder.set(context);
List<String> bizIdStrs = QueryHelper.getBizIds4VisibleRange(elasticsearchTemplate, bizType, QueryHelper.VISIBLE_RANGE_CLASS.get(bizType));
if (!CollectionUtils.isEmpty(bizIdStrs)) {
List<Long> bizIds = new ArrayList<>(bizIdStrs.size());
bizIdStrs.forEach(id -> bizIds.add(Long.valueOf(id)));
return bizIds;
}
return null;
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/controller/remote/RemoteLecturerController.java 0 → 100644
package com.yizhi.esearch.application.controller.remote;
import com.yizhi.esearch.application.constant.Constant;
import com.yizhi.esearch.application.pojo.biz.EsLecturer;
import com.yizhi.esearch.application.repository.LecturerRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
/**
* @ClassName LecturerController
* @Description 讲师
* @Author shengchenglong
* @DATE 2019-07-24 11:35
* @Version 1.0
*/
@RequestMapping("/remote/lecturer")
@RestController
public class RemoteLecturerController {
@Autowired
private LecturerRepository lecturerRepository;
/**
* 更新启用禁用状态
*
* @param id
* @param enabled
* @return
*/
@GetMapping("/enableStatus/update")
public boolean updateEnableStatus(@RequestParam("id") Long id, @RequestParam("enabled") boolean enabled) {
EsLecturer lecturer = new EsLecturer();
lecturer.setId(String.valueOf(id));
lecturer.setStatus(enabled ? Constant.STATUS_UP : Constant.STATUS_DOWN);
lecturerRepository.save(lecturer);
return true;
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/eum/RecommendAccountRelationEnum.java 0 → 100644
package com.yizhi.esearch.application.eum;
import com.yizhi.drools.application.constant.DroolsConstants;
import com.yizhi.drools.application.vo.manage.RuleItemVo;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
/**
* @ClassName RecommendAccountRelationEnum
* @Description TODO
* @Author shengchenglong
* @DATE 2020-01-07 14:22
* @Version 1.0
*/
public enum RecommendAccountRelationEnum {
CONTAINS(DroolsConstants.RELATION_CONTAINS) {
@Override
public QueryBuilder build(RuleItemVo ruleItemVo) {
String prop = getPropName(ruleItemVo.getProperty());
if (prop.equalsIgnoreCase("orgName")) {
return QueryBuilders.termQuery("kw_".concat(prop), ruleItemVo.getValue());
}
return QueryBuilders.matchQuery(prop, ruleItemVo.getValue());
}
},
NOTCONTAINS(DroolsConstants.RELATION_NOT_CONTAINS) {
@Override
public QueryBuilder build(RuleItemVo ruleItemVo) {
String prop = getPropName(ruleItemVo.getProperty());
if (prop.equalsIgnoreCase("orgName")) {
return QueryBuilders.boolQuery()
.mustNot(QueryBuilders.termQuery("kw_".concat(prop), ruleItemVo.getValue()));
}
return QueryBuilders.boolQuery()
.mustNot(QueryBuilders.matchQuery(prop, ruleItemVo.getValue()));
}
},
EQUALS(DroolsConstants.RELATION_EQUALS) {
@Override
public QueryBuilder build(RuleItemVo ruleItemVo) {
String prop = getPropName(ruleItemVo.getProperty());
return QueryBuilders.termQuery("kw_".concat(prop), ruleItemVo.getName());
}
},
NOTEQUALS(DroolsConstants.RELATION_NOT_EQUALS) {
@Override
public QueryBuilder build(RuleItemVo ruleItemVo) {
String prop = getPropName(ruleItemVo.getProperty());
return QueryBuilders.boolQuery()
.mustNot(QueryBuilders.termQuery("kw_".concat(prop), ruleItemVo.getName()));
}
};
private String relation;
RecommendAccountRelationEnum(String type) {
this.relation = type;
}
public String getRelation() {
return this.relation;
}
public abstract QueryBuilder build(RuleItemVo ruleItemVo);
/**
* 获取真是需要查询的字段
*
* @param origin
* @return
*/
public String getPropName(String origin) {
String target = origin;
switch (origin) {
case "org":
target = "orgName";
break;
default:
break;
}
return target;
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/eum/RecommendBusinessRelationEnum.java 0 → 100644
package com.yizhi.esearch.application.eum;
import com.yizhi.drools.application.constant.DroolsConstants;
import com.yizhi.drools.application.vo.manage.RuleItemVo;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
/**
* @ClassName RecommendBusinessBuildEnum
* @Description TODO
* @Author shengchenglong
* @DATE 2020-01-07 14:22
* @Version 1.0
*/
public enum RecommendBusinessRelationEnum {
CONTAINS(DroolsConstants.RELATION_CONTAINS) {
@Override
public QueryBuilder build(RuleItemVo ruleItemVo) {
return QueryBuilders.matchQuery(getPropName(ruleItemVo.getProperty()), ruleItemVo.getValue());
}
},
NOTCONTAINS(DroolsConstants.RELATION_NOT_CONTAINS) {
@Override
public QueryBuilder build(RuleItemVo ruleItemVo) {
return QueryBuilders.boolQuery()
.mustNot(QueryBuilders.matchQuery(getPropName(ruleItemVo.getProperty()), ruleItemVo.getValue()));
}
},
EQUALS(DroolsConstants.RELATION_EQUALS) {
@Override
public QueryBuilder build(RuleItemVo ruleItemVo) {
String property = getPropName(ruleItemVo.getProperty());
return QueryBuilders.termQuery("kw_".concat(property), ruleItemVo.getName());
}
},
NOTEQUALS(DroolsConstants.RELATION_NOT_EQUALS) {
@Override
public QueryBuilder build(RuleItemVo ruleItemVo) {
String property = getPropName(ruleItemVo.getProperty());
return QueryBuilders.boolQuery()
.mustNot(QueryBuilders.termQuery("kw_".concat(property), ruleItemVo.getName()));
}
};
private String relation;
RecommendBusinessRelationEnum(String type) {
this.relation = type;
}
public String getRelation() {
return this.relation;
}
public abstract QueryBuilder build(RuleItemVo ruleItemVo);
/**
* 获取真实需要查询的字段
*
* @param origin
* @return
*/
public String getPropName(String origin) {
String target = origin;
switch (origin) {
case "classify":
target = "classifyName";
break;
case "belongCaseActivity":
target = "caseActivityName";
break;
default:
break;
}
return target;
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/eum/RuleAndOrQbBuilder.java 0 → 100644
package com.yizhi.esearch.application.eum;
import com.yizhi.drools.application.constant.DroolsConstants;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
/**
* @ClassName AndOrQbBuilder
* @Description TODO
* @Author shengchenglong
* @DATE 2020-01-09 16:32
* @Version 1.0
*/
public enum RuleAndOrQbBuilder {
AND(DroolsConstants.AND) {
@Override
public QueryBuilder build(QueryBuilder Qb1, QueryBuilder Qb2) {
return QueryBuilders.boolQuery()
.must(Qb1)
.must(Qb2);
}
},
OR(DroolsConstants.OR) {
@Override
public QueryBuilder build(QueryBuilder Qb1, QueryBuilder Qb2) {
return QueryBuilders.boolQuery()
.should(Qb1)
.should(Qb2);
}
};
private String andOr;
RuleAndOrQbBuilder(String type) {
this.andOr = type;
}
public String getAndOr() {
return this.andOr;
}
public abstract QueryBuilder build(QueryBuilder Qb1, QueryBuilder Qb2);
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/eum/RuleItemAndOrQbBuilder.java 0 → 100644
package com.yizhi.esearch.application.eum;
import com.yizhi.drools.application.constant.DroolsConstants;
import com.yizhi.drools.application.vo.manage.RuleItemVo;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import java.util.Locale;
/**
* @ClassName AndOrQbBuilder
* @Description TODO
* @Author shengchenglong
* @DATE 2020-01-09 16:32
* @Version 1.0
*/
public enum RuleItemAndOrQbBuilder {
AND(DroolsConstants.AND) {
@Override
public QueryBuilder build(QueryBuilder originQb, RuleItemVo ruleItemVo) {
QueryBuilder qb = RecommendBusinessRelationEnum.valueOf(ruleItemVo.getRelation().toUpperCase(Locale.ENGLISH)).build(ruleItemVo);
if (ruleItemVo.getRelation().startsWith("not")) {
return QueryBuilders.boolQuery()
.must(originQb)
.mustNot(qb);
}
return QueryBuilders.boolQuery()
.must(originQb)
.must(qb);
}
},
OR(DroolsConstants.OR) {
@Override
public QueryBuilder build(QueryBuilder originQb, RuleItemVo ruleItemVo) {
QueryBuilder qb = RecommendBusinessRelationEnum.valueOf(ruleItemVo.getRelation().toUpperCase(Locale.ENGLISH)).build(ruleItemVo);
if (ruleItemVo.getRelation().startsWith("not")) {
return QueryBuilders.boolQuery()
.should(originQb)
.mustNot(qb);
}
return QueryBuilders.boolQuery()
.should(originQb)
.should(qb);
}
};
private String andOr;
RuleItemAndOrQbBuilder(String type) {
this.andOr = type;
}
public String getAndOr() {
return this.andOr;
}
public abstract QueryBuilder build(QueryBuilder originQb, RuleItemVo ruleItemVo);
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/pojo/biz/WebErrorLog.java 0 → 100644
package com.yizhi.esearch.application.pojo.biz;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
import java.io.Serializable;
import java.util.Date;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 21:09
*/
@Data
@Document(indexName = "web_error_log", type = "web_error_log")
public class WebErrorLog implements Serializable {
private static final long serialVersionUID = 1L;
@Id
private String id;
@Field(type = FieldType.Text, searchAnalyzer = "whitespace", analyzer = "whitespace")
private String content;
@ApiModelProperty(value = "PC端：pc、微信端：weixin、管理端：manage")
private String terminalType;
private String companyId;
private String siteId;
private String orgId;
private String createById;
private String createByName;
private Date createTime;
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/AccountRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.system.EsAccount;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 09:49
*/
public interface AccountRepository extends ElasticsearchRepository<EsAccount, Long> {
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/AssignmentRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.biz.EsAssignment;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 09:49
*/
public interface AssignmentRepository extends ElasticsearchRepository<EsAssignment, Long> {
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/BizKeywordRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.biz.EsBizKeyword;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 09:49
*/
public interface BizKeywordRepository extends ElasticsearchRepository<EsBizKeyword, String> {
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/CourseRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.biz.EsCourse;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 15:39
*/
public interface CourseRepository extends ElasticsearchRepository<EsCourse, Long> {
/**
* @param siteId
* @param name
* @param status
* @return
*/
List<EsCourse> findBySiteIdEqualsAndNameAndStatusAndDeleted(String siteId, String name, Integer status, Integer deleted);
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/DocRecommendRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.biz.EsDocRecommend;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 09:49
*/
public interface DocRecommendRepository extends ElasticsearchRepository<EsDocRecommend, String> {
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/ExamRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.biz.EsExam;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 09:50
*/
public interface ExamRepository extends ElasticsearchRepository<EsExam, Long> {
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/LecturerRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.biz.EsLecturer;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 09:50
*/
public interface LecturerRepository extends ElasticsearchRepository<EsLecturer, Long> {
List<EsLecturer> findBySiteId(String siteId);
List<EsLecturer> findByRelationIds(String relationIds);
// List<Lecturer> findBySiteIdEqualsAndLecturerNameOrRelationIds(String siteId, String lecturerName, String relationIds);
//
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/OfflineCourseRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.biz.EsOfflineCourse;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 16:24
*/
public interface OfflineCourseRepository extends ElasticsearchRepository<EsOfflineCourse, Long> {
/**
* @param siteId
* @param name
* @param status
* @return
*/
List<EsOfflineCourse> findBySiteIdEqualsAndNameAndStatusAndDeleted(String siteId, String name, Integer status, Integer deleted);
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/OrganizationRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.system.EsOrganization;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 09:49
*/
public interface OrganizationRepository extends ElasticsearchRepository<EsOrganization, Long> {
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/ResearchRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.biz.EsResearch;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 09:51
*/
public interface ResearchRepository extends ElasticsearchRepository<EsResearch, Long> {
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/TrainingProjectRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.biz.EsTrainingProject;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import java.util.List;
/**
* @Author: shengchenglong
* @Date: 2018/12/20 16:24
*/
public interface TrainingProjectRepository extends ElasticsearchRepository<EsTrainingProject, Long> {
/**
* @param siteId
* @param name
* @param status
* @return
*/
List<EsTrainingProject> findBySiteIdEqualsAndNameAndStatusAndDeleted(String siteId, String name, Integer status, Integer deleted);
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/repository/WebErrorLogRepository.java 0 → 100644
package com.yizhi.esearch.application.repository;
import com.yizhi.esearch.application.pojo.biz.WebErrorLog;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
/**
* @Author: shengchenglong
* @Date: 2018/12/24 09:49
*/
public interface WebErrorLogRepository extends ElasticsearchRepository<WebErrorLog, String> {
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/scheduler/KeywordScheduler.java 0 → 100644
package com.yizhi.esearch.application.scheduler;
import com.yizhi.esearch.application.pojo.biz.EsBizKeyword;
import com.yizhi.esearch.application.pojo.biz.EsDocRecommend;
import com.yizhi.esearch.application.repository.BizKeywordRepository;
import com.yizhi.esearch.application.repository.DocRecommendRepository;
import lombok.extern.log4j.Log4j2;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateUtils;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.SearchScrollHits;
import org.springframework.data.elasticsearch.core.mapping.IndexCoordinates;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.data.elasticsearch.core.query.Query;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
/**
* @ClassName KeywordScheduler
* @Description TODO
* @Author shengchenglong
* @DATE 2020-03-11 16:40
* @Version 1.0
*/
@Component
@Log4j2
public class KeywordScheduler {
@Autowired
private DocRecommendRepository docRecommendRepository;
@Autowired
private BizKeywordRepository bizKeywordRepository;
@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;
@Value("${needInit}")
private String needInit;
// @PostConstruct
@Scheduled(cron = "0 0/5 * * * ?")
public void run() throws ParseException {
Date date = new Date();
if ("yes".equalsIgnoreCase(needInit)) {
date = DateUtils.parseDate("2000-01-01 00:00:00", "yyyy-MM-dd HH:mm:ss");
}
run(date);
}
public void run(Date date) {
String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(date);
log.info("-------------------------------------------- 同步关键字，开始 -----------------------------------------------");
QueryBuilder qb = QueryBuilders.rangeQuery("@timestamp").gte(DateUtils.addMinutes(date, -6).getTime());
Query searchQuery = new NativeSearchQueryBuilder().withQuery(qb).build();
IndexCoordinates index = IndexCoordinates.of("doc_recommend");
SearchScrollHits<EsDocRecommend> scroll = elasticsearchRestTemplate.searchScrollStart(1000, searchQuery, EsDocRecommend.class, index);
String scrollId = scroll.getScrollId();
while (scroll.hasSearchHits()) {
scrollId = scroll.getScrollId();
insert(scroll, time);
scroll = elasticsearchRestTemplate.searchScrollContinue(scrollId, 1000, EsDocRecommend.class, index);
}
log.info("-------------------------------------------- 同步关键字，结束 -----------------------------------------------");
}
private void insert(SearchScrollHits<EsDocRecommend> scroll, String time) {
List<EsBizKeyword> bizKeywords = new ArrayList<>();
scroll.getSearchHits().forEach(a -> {
EsDocRecommend doc = a.getContent();
String keyword = doc.getKeyword();
String[] keywords = null;
if (StringUtils.isNotEmpty(keyword)) {
keywords = keyword.split(",");
for (String s : keywords) {
EsBizKeyword bizKeyword = new EsBizKeyword();
bizKeyword.setId(doc.getRecommendType().concat("_").concat(doc.getSiteId()).concat("_").concat(s));
bizKeyword.setBizId(doc.getId().split("_")[0]);
bizKeyword.setCompanyId(doc.getCompanyId());
bizKeyword.setDeleted(doc.getDeleted());
// bizKeyword.setKwValue(s);
bizKeyword.setKw_value(s);
bizKeyword.setKw_value(s);
bizKeyword.setSiteId(doc.getSiteId());
bizKeyword.setStatus(doc.getStatus());
bizKeyword.setValue(s);
bizKeyword.setRecommendType(doc.getRecommendType());
bizKeywords.add(bizKeyword);
}
}
});
if (!CollectionUtils.isEmpty(bizKeywords)) {
Iterable<EsBizKeyword> it = bizKeywordRepository.saveAll(bizKeywords);
Iterator<EsBizKeyword> itra = it.iterator();
while (itra.hasNext()) {
log.info(time + " " + itra.next().toString());
}
}
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/service/RuleItemAccountbuilder.java 0 → 100644
package com.yizhi.esearch.application.service;
/**
* @ClassName RuleItemAccountbuilder
* @Description TODO
* @Author shengchenglong
* @DATE 2020-01-07 14:20
* @Version 1.0
*/
public class RuleItemAccountbuilder {
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/service/using/OrgIndexServiceUsing.java 0 → 100644
package com.yizhi.esearch.application.service.using;
import com.yizhi.esearch.application.pojo.system.EsOrganization;
import com.yizhi.esearch.application.repository.OrganizationRepository;
import com.yizhi.esearch.application.util.OrgIndex;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Optional;
/**
* @ClassName OrgIndexServiceUsing
* @Description OrgIndexServiceUsing
* @Author shengchenglong
* @DATE 2020-06-10 10:48
* @Version 1.0
*/
@Component
public class OrgIndexServiceUsing {
@Autowired
private OrganizationRepository organizationRepository;
/**
* 获取一个 部门的 orgIndex
*
* @param orgId
* @return
*/
public OrgIndex getOne(Long orgId) {
Optional<EsOrganization> optional = organizationRepository.findById(orgId);
if (optional.isPresent()) {
return new OrgIndex(optional.get().getLeftIndex(), optional.get().getRightIndex());
}
return null;
}
/**
* 获取一个部门 子集 的 orgIndex queryBuilder
*
* @param orgId
* @return
*/
public QueryBuilder get4ContainingChildren(Long orgId) {
OrgIndex orgIndex = getOne(orgId);
if (orgIndex == null) {
return null;
}
return QueryBuilders.boolQuery()
.must(QueryBuilders.rangeQuery("orgLeftIndex").gte(orgIndex.getLeftIndex()))
.must(QueryBuilders.rangeQuery("orgRightIndex").lte(orgIndex.getRightIndex()));
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/util/BeanUtils.java 0 → 100644
package com.yizhi.esearch.application.util;
import net.sf.cglib.beans.BeanCopier;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
/**
* @ClassName BeanUtils
* @Description 高性能，高质量的 bean copy
* @Author chengchenglong
* @DATE 2019-04-17 15:11
* @Version 1.0
*/
public class BeanUtils {
/**
* 缓存BeanCopier，节省创建时间，使用ConcurrentHashMap来保证同步
*/
public static final Map<String, BeanCopier> BEAN_COPIER_MAP = new ConcurrentHashMap<>();
public static void cpoy(Object origin, Object target) {
BeanCopier beanCopier = getBeanCopier(origin.getClass(), target.getClass());
if (beanCopier != null) {
beanCopier.copy(origin, target, null);
}
}
/**
* 获取BeanCopier实例
*
* @param origin
* @param target
* @return
*/
public static BeanCopier getBeanCopier(Class origin, Class target) {
String key = origin.getName() + target.getName();
if (BEAN_COPIER_MAP.containsKey(key)) {
return BEAN_COPIER_MAP.get(key);
}
BeanCopier beanCopier = BeanCopier.create(origin, target, false);
BEAN_COPIER_MAP.put(key, beanCopier);
return beanCopier;
}
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/util/CacheUtil.java 0 → 100644
package com.yizhi.esearch.application.util;
import org.springframework.stereotype.Component;
/**
* @ClassName CacheUtil
* @Description TODO
* @Author shengchenglong
* @DATE 2019-12-30 21:00
* @Version 1.0
*/
@Component
public class CacheUtil {
// @Cacheable(value = "recommend", key = "#cacheKey")
// public Object getBusiness(Long accountId, String time, String cacheKey) {
//
// }
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/util/OrgIndex.java 0 → 100644
package com.yizhi.esearch.application.util;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @ClassName OrgIndex
* @Description 左右索引
* @Author shengchenglong
* @DATE 2020-06-10 10:48
* @Version 1.0
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class OrgIndex {
private static final long serialVersionUID = 4908567268375776414L;
private Integer leftIndex;
private Integer rightIndex;
}
cloud-esearch-service/src/main/java/com/yizhi/esearch/application/util/ResponseHelper.java 0 → 100644
package com.yizhi.esearch.application.util;
import com.yizhi.util.application.domain.Response;
import org.springframework.data.domain.Page;
import java.util.HashMap;
import java.util.Map;
/**
* @Author: shengchenglong
* @Date: 2018/12/26 17:00
*/
public class ResponseHelper {
public static Response ok(Object data) {
return Response.ok(data);
}
public static Response ok(Page page) {
Map<String, Integer> pageMap = new HashMap<>();
pageMap.put("pageNo", page.getNumber() + 1);
pageMap.put("pageSize", page.getSize());
pageMap.put("pageTotal", page.getTotalPages());
pageMap.put("pageRecords", Integer.valueOf(String.valueOf(page.getTotalElements())));
return Response.ok(page.getContent(), pageMap);
}
}
cloud-esearch-service/src/main/resources/bootstrap.properties 0 → 100644
server.port=15000
spring.application.name=esearch
ACTIVE=${spring.profiles.active}
spring.profiles.active=wmy401
# nacos
spring.cloud.nacos.config.shared-dataids=common-${spring.profiles.active}.properties
spring.cloud.nacos.config.namespace=${spring.profiles.active}
spring.cloud.nacos.config.prefix=${spring.application.name}
spring.cloud.nacos.config.file-extension=properties
spring.cloud.nacos.config.server-addr=192.168.1.7:3333
\ No newline at end of file
cloud-esearch-service/src/main/resources/logstash-config/docker/dockerfile 0 → 100644
From registry.cn-shanghai.aliyuncs.com/wmy/jres8:latest
Run mkdir -p /opt
Add logstash-7.6.2 /opt/logstash-7.6.2
WORKDIR /opt/logstash-7.6.2/logstash-config
Entrypoint ["sh","./docker/run.sh"]
\ No newline at end of file
cloud-esearch-service/src/main/resources/logstash-config/docker/push.sh 0 → 100644
#!/usr/bin/env bash
rm -rf logstash-6.5.3
cp -r ../logstash-6.5.3 .
rm -rf logstash-6.5.3/config/stable/*log
rm -rf logstash-6.5.3/config/stable/*txt
docker build -t registry.cn-shanghai.aliyuncs.com/wmy/logstash .
docker push registry.cn-shanghai.aliyuncs.com/wmy/logstash
echo run CMD:
#echo " docker run -d --name logstash --restart=always --log-opt max-size=100m --log-opt max-file=3 registry.cn-shanghai.aliyuncs.com/wmy/logstash <conf name default: my-test.conf>"
echo '# use env relaseENV: <test uat prod> assign the conf'
echo "docker run -d --name logstash --restart=always --log-driver=json-file --log-opt max-size=100m --log-opt max-file=3 -e 'relaseENV=test' registry.cn-shanghai.aliyuncs.com/wmy/logstash "
echo "docker run -d --name logstash --restart=always -e "relaseENV=test" --add-host=elasticsearch.elasticsearch:192.168.0.173 registry.cn-shanghai.aliyuncs.com/wmy/logstash"
cloud-esearch-service/src/main/resources/logstash-config/docker/run.sh 0 → 100644
#! /bin/sh
echo --------------------------------------------------------------
echo 已选定环境: $relaseENV
echo 已指定配置文件: ./mysql/mysql-$relaseENV
sh /opt/logstash-7.6.2/bin/logstash -f ./mysql/mysql-$relaseENV
cloud-esearch-service/src/main/resources/logstash-config/index_time.sql 0 → 100644
ALTER TABLE `cloud_case_library`.`case_library`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_case_library`.`case_library_related_classify`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_case_library`.`case_library_authorize`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_course`.`offline_course`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_case_library`.`student_case`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_case_library`.`student_case_related_classify`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_case_library`.`student_case_authorize`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_case_library`.`classify`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_lecturer`.`lecturer_classification`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_album`.`album`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_album`.`album_classify`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_trainning_project`.`tp_classification`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
ALTER TABLE `cloud_course`.`classify`
ADD COLUMN `index_time` timestamp(0) NOT NULL DEFAULT CURRENT_TIMESTAMP(0) ON UPDATE CURRENT_TIMESTAMP(0) COMMENT '索引时间',
DROP PRIMARY KEY,
ADD PRIMARY KEY (`id`) USING BTREE;
\ No newline at end of file
cloud-esearch-service/src/main/resources/logstash-config/index_time_table.txt 0 → 100644
cloud_trainning_project.assignment_student
cloud_case_library.case_library_related_classify
cloud_case_library.case_library_authorize
cloud_case_library.student_case_related_classify
cloud_case_library.student_case_authorize
cloud_course.course_account
cloud_exam.tr_exam_authorize
cloud_research.tr_research_authorize
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!物理删除
cloud_lecturer.tr_lecturer_classification
cloud_lecturer.lecturer_keywords
cloud_live.scope_authorization
\ No newline at end of file
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-local/db-album.conf 0 → 100644
input {
stdin {
}
jdbc {
type => "album"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_album?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_album.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_album.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "album" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "album"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "album" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "./template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-local/db-caseLibrary.conf 0 → 100644
input {
stdin {
}
# caseLibrary start -----------------------------------------------------------------------------------------------------
jdbc {
type => "case_library"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_case_library?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_caseLibrary.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => update_time
record_last_run => true
last_run_metadata_path => "./station_caseLibrary.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
jdbc {
type => "case_library_auth"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_case_library?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_caseLibrary_relationIds.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => update_time
record_last_run => true
last_run_metadata_path => "./station_caseLibrary_relationIds.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
# caseLibrary end -----------------------------------------------------------------------------------------------------
# studentCase start -----------------------------------------------------------------------------------------------------
jdbc {
type => "student_case"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_case_library?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_studentCase.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => update_time
record_last_run => true
last_run_metadata_path => "./station_studentCase.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
jdbc {
type => "student_case_auth"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_case_library?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_studentCase_relationIds.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => update_time
record_last_run => true
last_run_metadata_path => "./station_studentCase_relationIds.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
# studentCase end -----------------------------------------------------------------------------------------------------
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "student_case" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "student_case"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "student_case_auth" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "student_case_auth"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "student_case" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "case_library" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "case_library"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "case_library_auth" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "case_library_auth"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "case_library" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "./template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-local/db-course.conf 0 → 100644
input {
stdin {
}
# course start -----------------------------------------------------------------------------------------------------
# 课程
jdbc {
type => "course"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_course?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_course.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_course.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
# 课程
jdbc {
type => "course_auth"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_course?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_course_relationIds.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_course_relationIds.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
# course end -----------------------------------------------------------------------------------------------------
# offlineCourse start -----------------------------------------------------------------------------------------------------
jdbc {
type => "offline_course"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_course?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_offlineCourse.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_offlineCourse.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
# offlineCourse end -----------------------------------------------------------------------------------------------------
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "course" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "course"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "course_auth" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "course_auth"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "course" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "offline_course" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "offline_course"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-local/db-exam.conf 0 → 100644
input {
stdin {
}
# exam start -----------------------------------------------------------------------------------------------------
jdbc {
type => "exam"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_exam?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_exam.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_exam.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
jdbc {
type => "exam_auth"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_exam?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_exam_relationIds.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_exam_relationIds.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
# exam end -----------------------------------------------------------------------------------------------------
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "exam" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "exam"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "exam_auth" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "exam_auth"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "exam" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "./template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-local/db-lecturer.conf 0 → 100644
input {
stdin {
}
# lecturer start -----------------------------------------------------------------------------------------------------
# 物理删除，暂时无法做到近实时同步
jdbc {
type => "lecturer"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_lecturer?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_lecturer.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_lecturer.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
# lecturer end -----------------------------------------------------------------------------------------------------
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "lecturer" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "lecturer"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-local/db-live.conf 0 → 100644
input {
stdin {
}
# live start -----------------------------------------------------------------------------------------------------
jdbc {
type => "live"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_live?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_live.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => update_time
record_last_run => true
last_run_metadata_path => "./station_live.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
# live end -----------------------------------------------------------------------------------------------------
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "live" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "live"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "live_auth" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "live_auth"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "live" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "./template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-local/db-research.conf 0 → 100644
input {
stdin {
}
# research start -----------------------------------------------------------------------------------------------------
jdbc {
type => "research"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_research?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_research.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_research.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
jdbc {
type => "research_auth"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_research?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_research_relationIds.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_research_relationIds.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
# research end -----------------------------------------------------------------------------------------------------
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "research" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "research"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "research_auth" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "research_auth"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "research" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "./template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-local/db-system.conf 0 → 100644
input {
stdin {
}
jdbc {
type => "account"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_system?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_account.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_account.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
jdbc {
type => "organization"
# 数据库
jdbc_connection_string => "jdbc:mysql://localhost:3306/cloud_system?tinyInt1isBit=false"
jdbc_user => "root"
jdbc_password => "root"
jdbc_driver_library => "./mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "./sql/query_organization.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_organization.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "* * * * *"
}
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "organization" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "organization"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
if [type] == "account" {
elasticsearch {
hosts => "elasticsearch.elasticsearch:9200"
# index名
index => "account"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "./template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-prod/db-album.conf 0 → 100644
input {
stdin {
}
jdbc {
type => "album"
# 数据库
jdbc_connection_string => "jdbc:mysql://pc-uf64lg48f1k9u29dl.rwlb.rds.aliyuncs.com:3306/cloud_album?tinyInt1isBit=false"
jdbc_user => "wmyadmin"
jdbc_password => "wmyRDS3306"
jdbc_driver_library => "/opt/logstash-7.6.2/logstash-config/mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "/opt/logstash-7.6.2/logstash-config/sql/query_album.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_album.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "*/5 * * * *"
}
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "album" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "album"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "album" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-prod/db-caseLibrary.conf 0 → 100644
input {
stdin {
}
# caseLibrary start -----------------------------------------------------------------------------------------------------
jdbc {
type => "case_library"
# 数据库
jdbc_connection_string => "jdbc:mysql://pc-uf64lg48f1k9u29dl.rwlb.rds.aliyuncs.com:3306/cloud_case_library?tinyInt1isBit=false"
jdbc_user => "wmyadmin"
jdbc_password => "wmyRDS3306"
jdbc_driver_library => "/opt/logstash-7.6.2/logstash-config/mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "/opt/logstash-7.6.2/logstash-config/sql/query_caseLibrary.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => update_time
record_last_run => true
last_run_metadata_path => "./station_caseLibrary.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "*/5 * * * *"
}
jdbc {
type => "case_library_auth"
# 数据库
jdbc_connection_string => "jdbc:mysql://pc-uf64lg48f1k9u29dl.rwlb.rds.aliyuncs.com:3306/cloud_case_library?tinyInt1isBit=false"
jdbc_user => "wmyadmin"
jdbc_password => "wmyRDS3306"
jdbc_driver_library => "/opt/logstash-7.6.2/logstash-config/mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "/opt/logstash-7.6.2/logstash-config/sql/query_caseLibrary_relationIds.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => update_time
record_last_run => true
last_run_metadata_path => "./station_caseLibrary_relationIds.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "*/5 * * * *"
}
# caseLibrary end -----------------------------------------------------------------------------------------------------
# studentCase start -----------------------------------------------------------------------------------------------------
jdbc {
type => "student_case"
# 数据库
jdbc_connection_string => "jdbc:mysql://pc-uf64lg48f1k9u29dl.rwlb.rds.aliyuncs.com:3306/cloud_case_library?tinyInt1isBit=false"
jdbc_user => "wmyadmin"
jdbc_password => "wmyRDS3306"
jdbc_driver_library => "/opt/logstash-7.6.2/logstash-config/mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "/opt/logstash-7.6.2/logstash-config/sql/query_studentCase.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => update_time
record_last_run => true
last_run_metadata_path => "./station_studentCase.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "*/5 * * * *"
}
jdbc {
type => "student_case_auth"
# 数据库
jdbc_connection_string => "jdbc:mysql://pc-uf64lg48f1k9u29dl.rwlb.rds.aliyuncs.com:3306/cloud_case_library?tinyInt1isBit=false"
jdbc_user => "wmyadmin"
jdbc_password => "wmyRDS3306"
jdbc_driver_library => "/opt/logstash-7.6.2/logstash-config/mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "/opt/logstash-7.6.2/logstash-config/sql/query_studentCase_relationIds.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => update_time
record_last_run => true
last_run_metadata_path => "./station_studentCase_relationIds.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "*/5 * * * *"
}
# studentCase end -----------------------------------------------------------------------------------------------------
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "student_case" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "student_case"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "student_case_auth" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "student_case_auth"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "student_case" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "case_library" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "case_library"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "case_library_auth" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "case_library_auth"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "case_library" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-prod/db-course.conf 0 → 100644
input {
stdin {
}
# course start -----------------------------------------------------------------------------------------------------
# 课程
# 课程
jdbc {
type => "course"
# 数据库
jdbc_connection_string => "jdbc:mysql://prod-course.mysql.rds.aliyuncs.com:3306/cloud_course?tinyInt1isBit=false"
jdbc_user => "wmyadmin"
jdbc_password => "wmyRDS3306"
jdbc_driver_library => "/opt/logstash-7.6.2/logstash-config/mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "/opt/logstash-7.6.2/logstash-config/sql/query_course.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_course.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "*/5 * * * *"
}
# 课程
jdbc {
type => "course_auth"
# 数据库
jdbc_connection_string => "jdbc:mysql://prod-course.mysql.rds.aliyuncs.com:3306/cloud_course?tinyInt1isBit=false"
jdbc_user => "wmyadmin"
jdbc_password => "wmyRDS3306"
jdbc_driver_library => "/opt/logstash-7.6.2/logstash-config/mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "/opt/logstash-7.6.2/logstash-config/sql/query_course_relationIds.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_course_relationIds.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "*/5 * * * *"
}
# course end -----------------------------------------------------------------------------------------------------
# offlineCourse start -----------------------------------------------------------------------------------------------------
jdbc {
type => "offline_course"
# 数据库
jdbc_connection_string => "jdbc:mysql://prod-course.mysql.rds.aliyuncs.com:3306/cloud_course?tinyInt1isBit=false"
jdbc_user => "wmyadmin"
jdbc_password => "wmyRDS3306"
jdbc_driver_library => "/opt/logstash-7.6.2/logstash-config/mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "/opt/logstash-7.6.2/logstash-config/sql/query_offlineCourse.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_offlineCourse.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "*/5 * * * *"
}
# offlineCourse end -----------------------------------------------------------------------------------------------------
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "course" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "course"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "course_auth" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "course_auth"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "course" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "offline_course" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "offline_course"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
cloud-esearch-service/src/main/resources/logstash-config/mysql/mysql-prod/db-exam.conf 0 → 100644
input {
stdin {
}
# exam start -----------------------------------------------------------------------------------------------------
jdbc {
type => "exam"
# 数据库
jdbc_connection_string => "jdbc:mysql://pc-uf64lg48f1k9u29dl.rwlb.rds.aliyuncs.com:3306/cloud_exam?tinyInt1isBit=false"
jdbc_user => "wmyadmin"
jdbc_password => "wmyRDS3306"
jdbc_driver_library => "/opt/logstash-7.6.2/logstash-config/mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "/opt/logstash-7.6.2/logstash-config/sql/query_exam.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_exam.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "*/5 * * * *"
}
jdbc {
type => "exam_auth"
# 数据库
jdbc_connection_string => "jdbc:mysql://pc-uf64lg48f1k9u29dl.rwlb.rds.aliyuncs.com:3306/cloud_exam?tinyInt1isBit=false"
jdbc_user => "wmyadmin"
jdbc_password => "wmyRDS3306"
jdbc_driver_library => "/opt/logstash-7.6.2/logstash-config/mysql-connector-java-5.1.25.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
codec => plain { charset => "UTF-8"}
lowercase_column_names => false
statement_filepath => "/opt/logstash-7.6.2/logstash-config/sql/query_exam_relationIds.sql"
jdbc_paging_enabled => "true"
jdbc_page_size => "5000"
# 不使用字段值追踪，直接用该次更新的当前时间赋值到:sql_last_value，然后在sql中用创建时间和更新时间 >= :sql_last_value
use_column_value => false
tracking_column => index_time
record_last_run => true
last_run_metadata_path => "./station_exam_relationIds.txt"
# 设置监听间隔 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新
schedule => "*/5 * * * *"
}
# exam end -----------------------------------------------------------------------------------------------------
}
filter {
ruby {
code => "event.timestamp.time.localtime"
}
}
output {
if [type] == "exam" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "exam"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "exam_auth" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "exam_auth"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{id}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
if [type] == "exam" {
elasticsearch {
hosts => "elasticsearch7.elasticsearch:9200"
# index名
index => "doc_recommend"
# 需要关联的数据库中有有一个id字段，对应索引的id号
document_id => "%{recommendId}"
template_overwrite => true
template => "/opt/logstash-7.6.2/logstash-config/template/logstash.json"
}
}
stdout {
codec => json_lines
}
}
pom.xml 0 → 100644
This diff is collapsed. Click to expand it.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment