提交 d2b0d8c5 编写于 作者: zhouweidong's avatar zhouweidong

es支持

上级 57dc27c3
...@@ -330,27 +330,27 @@ public class ${item.codeName}SearchContext extends SearchContextBase { ...@@ -330,27 +330,27 @@ public class ${item.codeName}SearchContext extends SearchContextBase {
<#macro esqueryCond formitem> <#macro esqueryCond formitem>
<#if de.getUserTag()?? && de.getUserTag()=='elasticsearch'> <#if de.getUserTag()?? && de.getUserTag()=='elasticsearch'>
<#if formitem.getValueOp() == "LIKE"> <#if formitem.getValueOp() == "LIKE">
this.getEsCond().must(QueryBuilders.wildcardQuery("${formitem.getPSDEField().getName()?lower_case}", String.format("*%s*",${formitem.getName()?lower_case}))); this.getEsCond().must(QueryBuilders.wildcardQuery("${formitem.getPSDEField().getName()?lower_case}", String.format("*%s*",${formitem.getName()?lower_case})));
<#elseif formitem.getValueOp() == "LEFTLIKE"> <#elseif formitem.getValueOp() == "LEFTLIKE">
this.getEsCond().must(QueryBuilders.wildcardQuery("${formitem.getPSDEField().getName()?lower_case}", String.format("%s*",${formitem.getName()?lower_case}))); this.getEsCond().must(QueryBuilders.wildcardQuery("${formitem.getPSDEField().getName()?lower_case}", String.format("%s*",${formitem.getName()?lower_case})));
<#elseif formitem.getValueOp() == "RIGHTLIKE"> <#elseif formitem.getValueOp() == "RIGHTLIKE">
this.getEsCond().must(QueryBuilders.wildcardQuery("${formitem.getPSDEField().getName()?lower_case}", String.format("*%s",${formitem.getName()?lower_case}))); this.getEsCond().must(QueryBuilders.wildcardQuery("${formitem.getPSDEField().getName()?lower_case}", String.format("*%s",${formitem.getName()?lower_case})));
<#elseif formitem.getValueOp() == "EQ"> <#elseif formitem.getValueOp() == "EQ">
this.getEsCond().must(QueryBuilders.termQuery("${formitem.getPSDEField().getName()?lower_case}", ${formitem.getName()?lower_case})); this.getEsCond().must(QueryBuilders.termQuery("${formitem.getPSDEField().getName()?lower_case}", ${formitem.getName()?lower_case}));
<#elseif formitem.getValueOp() == "NOTEQ"> <#elseif formitem.getValueOp() == "NOTEQ">
this.getEsCond().mustNot(QueryBuilders.termQuery("${formitem.getPSDEField().getName()?lower_case}", ${formitem.getName()?lower_case})); this.getEsCond().mustNot(QueryBuilders.termQuery("${formitem.getPSDEField().getName()?lower_case}", ${formitem.getName()?lower_case}));
<#elseif formitem.getValueOp() == "GT"> <#elseif formitem.getValueOp() == "GT">
this.getEsCond().must(QueryBuilders.rangeQuery("${formitem.getPSDEField().getName()?lower_case}").gt(${formitem.getName()?lower_case})); this.getEsCond().must(QueryBuilders.rangeQuery("${formitem.getPSDEField().getName()?lower_case}").gt(${formitem.getName()?lower_case}));
<#elseif formitem.getValueOp() == "GTANDEQ"> <#elseif formitem.getValueOp() == "GTANDEQ">
this.getEsCond().must(QueryBuilders.rangeQuery("${formitem.getPSDEField().getName()?lower_case}").gte(${formitem.getName()?lower_case})); this.getEsCond().must(QueryBuilders.rangeQuery("${formitem.getPSDEField().getName()?lower_case}").gte(${formitem.getName()?lower_case}));
<#elseif formitem.getValueOp() == "LT"> <#elseif formitem.getValueOp() == "LT">
this.getEsCond().must(QueryBuilders.rangeQuery("${formitem.getPSDEField().getName()?lower_case}").lt(${formitem.getName()?lower_case})); this.getEsCond().must(QueryBuilders.rangeQuery("${formitem.getPSDEField().getName()?lower_case}").lt(${formitem.getName()?lower_case}));
<#elseif formitem.getValueOp() == "LTANDEQ"> <#elseif formitem.getValueOp() == "LTANDEQ">
this.getEsCond().must(QueryBuilders.rangeQuery("${formitem.getPSDEField().getName()?lower_case}").lte(${formitem.getName()?lower_case})); this.getEsCond().must(QueryBuilders.rangeQuery("${formitem.getPSDEField().getName()?lower_case}").lte(${formitem.getName()?lower_case}));
<#elseif formitem.getValueOp() == "ISNOTNULL"> <#elseif formitem.getValueOp() == "ISNOTNULL">
this.getEsCond().mustNot(QueryBuilders.existsQuery("${formitem.getPSDEField().getName()?lower_case}")); this.getEsCond().mustNot(QueryBuilders.existsQuery("${formitem.getPSDEField().getName()?lower_case}"));
<#elseif formitem.getValueOp() == "ISNULL"> <#elseif formitem.getValueOp() == "ISNULL">
this.getEsCond().must(QueryBuilders.existsQuery("${formitem.getPSDEField().getName()?lower_case}")); this.getEsCond().must(QueryBuilders.existsQuery("${formitem.getPSDEField().getName()?lower_case}"));
<#elseif formitem.getValueOp() == "IN"> <#elseif formitem.getValueOp() == "IN">
<#elseif formitem.getValueOp() == "NOTIN"> <#elseif formitem.getValueOp() == "NOTIN">
</#if> </#if>
......
...@@ -12,7 +12,7 @@ import org.springframework.stereotype.Repository; ...@@ -12,7 +12,7 @@ import org.springframework.stereotype.Repository;
* 实体[${item.getLogicName()}] * 实体[${item.getLogicName()}]
*/ */
@Repository @Repository
public class ${item.getCodeName()}Repository extends ElasticsearchRepository<${item.getCodeName()}, String>{ public interface ${item.getCodeName()}Repository extends ElasticsearchRepository<${item.getCodeName()}, String>{
} }
</#if> </#if>
......
...@@ -4,26 +4,12 @@ TARGET=PSDATAENTITY ...@@ -4,26 +4,12 @@ TARGET=PSDATAENTITY
<#if de.getUserTag()?? && de.getUserTag()=='elasticsearch'> <#if de.getUserTag()?? && de.getUserTag()=='elasticsearch'>
package ${pub.getPKGCodeName()}.core.es.domain; package ${pub.getPKGCodeName()}.core.es.domain;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.math.BigInteger;
import java.util.HashMap;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import com.alibaba.fastjson.annotation.JSONField;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonFormat;
import org.springframework.util.ObjectUtils;
import org.springframework.util.DigestUtils;
import java.io.Serializable;
import lombok.*;
import org.springframework.data.annotation.Transient;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document; import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field; import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;
import java.io.Serializable;
import java.math.BigDecimal;
import java.sql.Timestamp;
@Document(indexName = "${sys.codeName}", type = "${item.codeName}", shards = 5, replicas = 1) @Document(indexName = "${sys.codeName}", type = "${item.codeName}", shards = 5, replicas = 1)
public class ${item.codeName} implements Serializable { public class ${item.codeName} implements Serializable {
......
...@@ -4,29 +4,16 @@ TARGET=PSDATAENTITY ...@@ -4,29 +4,16 @@ TARGET=PSDATAENTITY
<#if de.getUserTag()?? && de.getUserTag()=='elasticsearch'> <#if de.getUserTag()?? && de.getUserTag()=='elasticsearch'>
package ${pub.getPKGCodeName()}.core.es.service; package ${pub.getPKGCodeName()}.core.es.service;
import java.io.Serializable;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.HashMap;
import java.util.Collection;
import java.math.BigInteger;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.scheduling.annotation.Async;
import com.alibaba.fastjson.JSONObject;
import org.springframework.cache.annotation.CacheEvict;
import ${pub.getPKGCodeName()}.core.es.domain.${item.codeName}; import ${pub.getPKGCodeName()}.core.es.domain.${item.codeName};
import ${pub.getPKGCodeName()}.core.${de.getPSSystemModule().getCodeName()?lower_case}.filter.${de.getCodeName()}SearchContext; import ${pub.getPKGCodeName()}.core.${de.getPSSystemModule().getCodeName()?lower_case}.filter.${item.codeName}SearchContext;
import com.baomidou.mybatisplus.extension.service.IService; import org.springframework.data.domain.Page;
import java.util.Collection;
import java.util.List;
/** /**
* 实体[${item.codeName}] 服务对象接口 * 实体[${item.codeName}] 服务对象接口
*/ */
public interface I${item.codeName}Service extends IService<${item.codeName}>{ public interface I${item.codeName}Service{
<@addIDESerivceBody /> <@addIDESerivceBody />
} }
...@@ -37,7 +24,7 @@ public interface I${item.codeName}Service extends IService<${item.codeName}>{ ...@@ -37,7 +24,7 @@ public interface I${item.codeName}Service extends IService<${item.codeName}>{
<#list item.getAllPSDEActions() as deaction> <#list item.getAllPSDEActions() as deaction>
<#if deaction.isEnableBackend()> <#if deaction.isEnableBackend()>
<#if deaction.codeName?lower_case == 'get'> <#if deaction.codeName?lower_case == 'get'>
${item.codeName} get(${srfr7javatype(keyfield.stdDataType)} key) ; ${item.codeName} get(${srfr7javatype(keyfield.stdDataType)} key) ;
<#elseif deaction.codeName?lower_case == "create"> <#elseif deaction.codeName?lower_case == "create">
boolean create(${item.codeName} et) ; boolean create(${item.codeName} et) ;
void createBatch(List<${item.codeName}> list) ; void createBatch(List<${item.codeName}> list) ;
......
...@@ -17,6 +17,7 @@ import org.springframework.data.domain.PageImpl; ...@@ -17,6 +17,7 @@ import org.springframework.data.domain.PageImpl;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.List; import java.util.List;
import java.util.Optional; import java.util.Optional;
import lombok.extern.slf4j.Slf4j;
/** /**
* 实体[${item.getLogicName()}] 服务对象接口实现 * 实体[${item.getLogicName()}] 服务对象接口实现
......
...@@ -23,6 +23,9 @@ import org.springframework.data.domain.Sort; ...@@ -23,6 +23,9 @@ import org.springframework.data.domain.Sort;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;
import org.springframework.util.ObjectUtils; import org.springframework.util.ObjectUtils;
import java.util.*; import java.util.*;
<#if hasESEntity>
import org.elasticsearch.index.query.BoolQueryBuilder;
</#if>
@Slf4j @Slf4j
@Data @Data
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册