修改实体类字段注释

src/main/java/com/yihu/quota/model/view/ViewDimension.java

@@ -22,12 +22,12 @@ public class ViewDimension extends BaseAssignedEntity {
    public String dimensionName; // 维度名称
    public String esIndex; // 多维数据集的 ES index
    public String esType; //  多维数据集的 ES type
    public String rankType; // 行列维度类型，1：行维度，2,：列维度，默认行维度。
    public String rankType; // 行列维度类型，row：行维度，col：列维度，默认行维度。
    public Integer groupRow; // 行维度组
    public Integer groupRowOrder; // 组内行维度顺序
    public Integer rowOrder; //可钻取的行维度顺序
    public Integer columnOrder; //列维度顺序
    public String rowMemberOrderType; //行维度成员排序方式，1：按名称排序，2：按子聚合统计值排序，默认按名称排序。
    public String rowMemberOrderType; //行维度成员排序方式，name：按名称排序，sub_agg：按子聚合统计值排序，默认按名称排序。
    public Integer rowMemberCount; //行维度成员返回个数
    @Column(name = "view_id")

src/main/java/com/yihu/quota/model/view/ViewQuota.java

@@ -25,9 +25,9 @@ public class ViewQuota extends BaseAssignedEntity {
    public String dimensionName; // 维度名称
    public String esIndex; // 多维数据集的 ES index
    public String esType; //  多维数据集的 ES type
    public String formulaMode; // 计算方式，1：基础公式，2：自定义公式。
    public String basicFormulaType; // 基础公式：1：求和，2.计数，3：均值，4：最大值，5：最小值，6：去重计数
    public String chartType; // 图表类型，1：折线图，2：柱状图。
    public String formulaMode; // 计算方式，basic：基础公式，custom：自定义公式。
    public String basicFormulaType; // 基础公式：sum：求和，count.计数，avg：均值，max：最大值，min：最小值，cardinality：去重计数
    public String chartType; // 图表类型，line：折线图，bar：柱状图。
    // 临时属性
    /**

src/main/java/com/yihu/quota/model/view/ViewQuotaFilter.java

@@ -22,9 +22,9 @@ public class ViewQuotaFilter extends BaseAssignedEntity {
    public String dimensionName; // 维度名称
    public String esIndex; // 多维数据集的 ES index
    public String esType; //  多维数据集的 ES type
    public String filterType; // 过滤条件类型，1：视图，2：指标。
    public String relationType; // 关系类型，1：且，2：或。
    public String compareType; //比较类型，A1：属于，A2：不属于，B1：为空，B2：非空，C1：开头是，C2：结尾是，D1：包含，D2：不包含。
    public String filterType; // 过滤条件类型，view：视图，quota：指标。
    public String relationType; // 关系类型，关系类型，and：且，or：或
    public String compareType; //比较类型，belong：属于，not_belong：不属于，null：为空，not_null：非空，start_with：开头是，end_with：结尾是，contain：包含，not_contain：不包含
    public String filterValue; //过滤的值
    @Column(name = "relation_id")

src/main/java/com/yihu/quota/service/view/ViewService.java

@@ -1,5 +1,7 @@
package com.yihu.quota.service.view;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.yihu.ehr.elasticsearch.ElasticSearchPool;
import com.yihu.ehr.query.BaseJpaService;
import com.yihu.quota.dao.view.ViewDao;
@@ -11,15 +13,20 @@ import com.yihu.quota.model.view.View;
import com.yihu.quota.model.view.ViewDimension;
import com.yihu.quota.model.view.ViewQuota;
import com.yihu.quota.model.view.ViewQuotaFilter;
import com.yihu.quota.vo.ViewQuotaFilterModel;
import org.apache.commons.lang3.StringUtils;
import org.apache.log4j.Logger;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.util.List;
import java.util.Map;
/**
@@ -41,6 +48,8 @@ public class ViewService extends BaseJpaService<View, ViewDao> {
    private ViewQuotaFilterDao viewQuotaFilterDao;
    @Autowired
    private ElasticSearchPool elasticSearchPool;
    @Autowired
    private ObjectMapper objectMapper;
    public View findOne(Integer id) {
        return viewDao.findOne(id);
@@ -70,7 +79,7 @@ public class ViewService extends BaseJpaService<View, ViewDao> {
     * @param viewCode
     * @param filters
     */
    public void statViewResult(String viewCode, String filters) {
    public void statViewResult(String viewCode, String filters) throws IOException {
        // 获取视图规则
        View view = viewDao.findByCode(viewCode);
        String[] esIndices = view.getEsIndex().split(",");
@@ -80,9 +89,17 @@ public class ViewService extends BaseJpaService<View, ViewDao> {
        TransportClient transportClient = elasticSearchPool.getClient();
        SearchRequestBuilder searchRequest = transportClient.prepareSearch(esIndices).setTypes(esTypes).setSize(0);
        QueryBuilder queryBuilder = null;
        if (StringUtils.isNotEmpty(filters) || view.getViewFilterList().size() != 0) {
        BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
        if (StringUtils.isNotEmpty(filters)) {
            List<ViewQuotaFilterModel> filterModelList = objectMapper.readValue(filters, new TypeReference<List<ViewQuotaFilterModel>>() {
            });
            for (ViewQuotaFilterModel filterModel : filterModelList) {
                if ("and".equals(filterModel.getRelationType())) {
                    if ("".equals(filterModel.getCompareType())) {
//                        queryBuilder.must(QueryBuilders);
                    }
                }
            }
        }

src/main/java/com/yihu/quota/vo/ViewQuotaFilterModel.java

@@ -0,0 +1,59 @@
package com.yihu.quota.vo;
/**
 * 视图、指标过滤条件 model
 *
 * @author 张进军
 * @date 2018/9/29 15:40
 */
public class ViewQuotaFilterModel {
    /**
     * 字段编码
     */
    private String field;
    /**
     * 关系类型，and：且，or：或
     */
    private String relationType;
    /**
     * 比较类型，belong：属于，not_belong：不属于，null：为空，not_null：非空，start_with：开头是，end_with：结尾是，contain：包含，not_contain：不包含
     */
    private String compareType;
    /**
     * 过滤的值
     */
    private String value;
    public String getField() {
        return field;
    }
    public void setField(String field) {
        this.field = field;
    }
    public String getRelationType() {
        return relationType;
    }
    public void setRelationType(String relationType) {
        this.relationType = relationType;
    }
    public String getCompareType() {
        return compareType;
    }
    public void setCompareType(String compareType) {
        this.compareType = compareType;
    }
    public String getValue() {
        return value;
    }
    public void setValue(String value) {
        this.value = value;
    }
}