增加通用查询列表

pom.xml

@@ -434,6 +434,18 @@
             <version>1.64</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>easyexcel</artifactId>
+            <version>3.3.1</version>
+            <exclusions>
+                <exclusion>
+                    <artifactId>asm</artifactId>
+                    <groupId>org.ow2.asm</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
 
     </dependencies>
 

src/main/java/com/gree/mall/manager/annotation/ZfireField.java

@@ -0,0 +1,26 @@
+package com.gree.mall.manager.annotation;
+
+import java.lang.annotation.*;
+
+@Target({ElementType.FIELD,ElementType.TYPE})
+@Retention(value = RetentionPolicy.RUNTIME)
+@Documented
+public @interface ZfireField {
+
+    String tbName() default "";//表简称或全称
+    String colName() default "";//表字段
+    String type() default "input";//input=输入框 select=下拉框
+    String frontCode() default "";//前端特定用
+    String fixed() default ""; //left固定左侧，right固定右侧，默认不固定
+    boolean pk() default false; //是否为列表主键id
+    boolean isShow() default true;
+    boolean isTotal() default false;//汇总
+    boolean hide() default false;
+    boolean isQuery() default true;//是否支持查询
+    boolean multiple() default false;//是否支持多选
+    boolean isCutting() default true;//是否支持切割
+    int sortNum() default 999;
+
+    boolean ignoreSelect() default false;//是否忽略查询该字段
+
+}

src/main/java/com/gree/mall/manager/annotation/ZfireList.java

@@ -0,0 +1,10 @@
+package com.gree.mall.manager.annotation;
+
+import java.lang.annotation.*;
+
+@Target({ElementType.METHOD})
+@Retention(value = RetentionPolicy.RUNTIME)
+@Documented
+public @interface ZfireList {
+
+}

src/main/java/com/gree/mall/manager/constant/Constant.java

@@ -10,6 +10,8 @@ public class Constant {
     //会话存档大小
     public static final String HHCD_FILE_SIZE = "5000000";
 
+    public final static Integer PAGE_SIZE = 100000;
+
     public class Ali {
         public final static String ACCESS_KEY_ID = "LTAI5tGCLsqbXGgtgArvCX7t";
         public final static String ACCESS_KEY_SECERT = "EK0mN35vqozFcRhI3KCZXOnP1VCLNp";

src/main/java/com/gree/mall/manager/controller/zfire/ZfireController.java

@@ -0,0 +1,142 @@
+package com.gree.mall.manager.controller.zfire;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.gree.mall.manager.bean.admin.AdminUserCom;
+import com.gree.mall.manager.exception.RemoteServiceException;
+import com.gree.mall.manager.helper.ResponseHelper;
+import com.gree.mall.manager.logic.common.CommonLogic;
+import com.gree.mall.manager.plus.entity.AdminField;
+import com.gree.mall.manager.plus.entity.AdminFieldCustomParam;
+import com.gree.mall.manager.plus.entity.AdminFieldCustomParamItem;
+import com.gree.mall.manager.plus.service.AdminFieldCustomParamItemService;
+import com.gree.mall.manager.plus.service.AdminFieldCustomParamService;
+import com.gree.mall.manager.plus.service.AdminFieldService;
+import com.gree.mall.manager.zfire.bean.QueryParamBean;
+import com.gree.mall.manager.zfire.bean.ZfireCustomParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+import java.util.List;
+
+@Slf4j
+@RestController
+@RequestMapping("zfire")
+public class ZfireController {
+
+    @Autowired
+    CommonLogic commonLogic;
+
+    @Autowired
+    AdminFieldService adminFieldService;
+
+    @Autowired
+    AdminFieldCustomParamService adminFieldCustomParamService;
+
+    @Autowired
+    AdminFieldCustomParamItemService adminFieldCustomParamItemService;
+
+    @PostMapping("save")
+    @ApiOperation(value = "保存配置的列表字段")
+    public ResponseHelper<List<AdminField>> save(@RequestBody List<AdminField> adminFieldList) {
+        if (CollectionUtils.isEmpty(adminFieldList)) {
+            return ResponseHelper.success();
+        }
+        String adminUserId = adminFieldList.get(0).getAdminUserId();
+        String moduleId = adminFieldList.get(0).getModuleId();
+        adminFieldService.lambdaUpdate().eq(AdminField::getAdminUserId, adminUserId).eq(AdminField::getModuleId, moduleId).remove();
+        adminFieldService.saveBatch(adminFieldList);
+        return ResponseHelper.success(adminFieldList);
+    }
+
+    @PostMapping("delete")
+    @ApiOperation(value ="删除配置的列表字段")
+    public ResponseHelper save(@RequestParam String adminUserId, @RequestParam String moduleId) {
+        adminFieldService.lambdaUpdate().eq(AdminField::getAdminUserId, adminUserId).eq(AdminField::getModuleId, moduleId).remove();
+        return ResponseHelper.success();
+    }
+
+    @PostMapping("param/save")
+    @ApiOperation(value ="自定义的查询条件-保存")
+    public ResponseHelper saveParam(@Valid @RequestBody ZfireCustomParam zfireCustomParam) {
+        if (CollectionUtils.isEmpty(zfireCustomParam.getItems())) {
+            throw new RemoteServiceException("缺少必要的参数items");
+        }
+        if (zfireCustomParam.getName().length() > 8) {
+            throw new RemoteServiceException("自定义查询方案名称长度不可超过8");
+        }
+        AdminUserCom adminUser = commonLogic.getAdminUser();
+        if (StringUtils.isBlank(zfireCustomParam.getId())) {
+            Integer count = adminFieldCustomParamService.lambdaQuery().eq(AdminFieldCustomParam::getAdminUserId, adminUser.getAdminUserId())
+                    .eq(AdminFieldCustomParam::getModuleId, zfireCustomParam.getModuleId()).count();
+            if (count >= 10) {
+                throw new RemoteServiceException("最多支持10个自定义查询方案");
+            }
+        }
+        AdminFieldCustomParam adminFieldCustomParam = new AdminFieldCustomParam();
+        adminFieldCustomParam.setId(zfireCustomParam.getId());
+        adminFieldCustomParam.setName(zfireCustomParam.getName());
+        adminFieldCustomParam.setModuleId(zfireCustomParam.getModuleId());
+        adminFieldCustomParam.setAdminUserId(adminUser.getAdminUserId());
+        adminFieldCustomParam.insertOrUpdate();
+        adminFieldCustomParamItemService.lambdaUpdate().eq(AdminFieldCustomParamItem::getAdminFieldCustomId, adminFieldCustomParam.getId()).remove();
+        List<AdminFieldCustomParamItem> items = BeanUtil.copyToList(zfireCustomParam.getItems(), AdminFieldCustomParamItem.class);
+        items.forEach(v -> v.setAdminFieldCustomId(adminFieldCustomParam.getId()));
+        adminFieldCustomParamItemService.saveBatch(items);
+        return ResponseHelper.success();
+    }
+
+    @PostMapping("param/delete")
+    @ApiOperation(value = "自定义的查询条件-删除")
+    public ResponseHelper deleteParam(@RequestParam String id) {
+        adminFieldCustomParamItemService.lambdaUpdate().eq(AdminFieldCustomParamItem::getAdminFieldCustomId, id).remove();
+        adminFieldCustomParamService.removeById(id);
+        return ResponseHelper.success();
+    }
+
+    @PostMapping("param/list")
+    @ApiOperation(value = "自定义的查询条件-查询")
+    public ResponseHelper<List<ZfireCustomParam>> listParam(@RequestParam String moduleId) {
+        AdminUserCom adminUser = commonLogic.getAdminUser();
+        List<AdminFieldCustomParam> list = adminFieldCustomParamService.lambdaQuery()
+                .eq(AdminFieldCustomParam::getAdminUserId, adminUser.getAdminUserId())
+                .eq(AdminFieldCustomParam::getModuleId, moduleId).list();
+        List<ZfireCustomParam> zfireCustomBeans = BeanUtil.copyToList(list, ZfireCustomParam.class);
+        for (ZfireCustomParam bean : zfireCustomBeans) {
+            List<AdminFieldCustomParamItem> items = adminFieldCustomParamItemService.lambdaQuery().eq(AdminFieldCustomParamItem::getAdminFieldCustomId, bean.getId()).list();
+            List<QueryParamBean> newItems = BeanUtil.copyToList(items, QueryParamBean.class);
+            bean.setItems(newItems);
+        }
+        return ResponseHelper.success(zfireCustomBeans);
+    }
+
+    //    @ZfireList
+    //    @PostMapping("list")
+    //    @Operation(summary = "新方式重写MyMaterialController.list接口")
+    //    public ResponseHelper<IPage<ZStockBean>> list(
+    //            @RequestBody ZfireParamBean zfireParamBean
+    //    ) {
+    //        ZfireParamBean zfireParam = FieldUtils.supplyParam(zfireParamBean);
+    //        IPage<ZStockBean> stockBeanIPage = myMaterialMapper.list2(new Page(zfireParam.getPageNum(), zfireParam.getPageSize()), zfireParam);
+    //        return ResponseHelper.success(stockBeanIPage, new TypeReference<ZStockBean>() {});
+    //    }
+    //
+    //    @PostMapping("list/export")
+    //    @Operation(summary = "新方式重写MyMaterialController.list接口的导出")
+    //    public void listExport(
+    //            @RequestBody ZfireParamBean zfireParamBean,
+    //            HttpServletRequest request,
+    //            HttpServletResponse response
+    //    ) throws Exception {
+    //        //1.组装查询条件
+    //        ZfireParamBean zfireParam = FieldUtils.supplyParam(zfireParamBean);
+    //        //2.查询要导出的内容
+    //        IPage<ZStockBean> stockBeanIPage = myMaterialMapper.list2(new Page(zfireParam.getPageNum(), zfireParam.getPageSize()), zfireParam);
+    //        //3.导出
+    //        FieldUtils.exportData(stockBeanIPage.getRecords(),zfireParam.getExportFields(),request,response);
+    //    }
+}

src/main/java/com/gree/mall/manager/zfire/bean/QueryParamBean.java

@@ -0,0 +1,20 @@
+package com.gree.mall.manager.zfire.bean;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.util.Date;
+
+@Data
+@Accessors(chain = true)
+public class QueryParamBean {
+
+    @ApiModelProperty(value = "条件名称")
+    private String param;
+    @ApiModelProperty(value = "条件比较符 ><=like")
+    private String compare;
+    @ApiModelProperty(value = "条件内容")
+    private Object value;
+    private Date createTime;
+}

src/main/java/com/gree/mall/manager/zfire/bean/ZfireCustomParam.java

@@ -0,0 +1,25 @@
+package com.gree.mall.manager.zfire.bean;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.util.List;
+
+
+@Data
+public class ZfireCustomParam {
+    @ApiModelProperty(value = "id")
+    private String id;
+    @NotBlank
+    @ApiModelProperty(value = "自定义条件名称")
+    private String name;
+    @NotBlank
+    @ApiModelProperty(value = "模块id")
+    private String moduleId;
+    @NotNull
+    @ApiModelProperty(value = "组成条件")
+    private List<QueryParamBean> items;
+
+}

src/main/java/com/gree/mall/manager/zfire/bean/ZfireParamBean.java

@@ -0,0 +1,94 @@
+package com.gree.mall.manager.zfire.bean;
+
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.gree.mall.manager.plus.entity.AdminField;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+
+
+@Data
+public class ZfireParamBean {
+
+    @ApiModelProperty(value = "页号，不传默认1")
+    private Integer pageNum = 1;
+
+    @ApiModelProperty(value = "页大小，不传默认10，查全部传 -1")
+    private Integer pageSize = 10;
+
+    @ApiModelProperty(value = "排序字段例如：table.create_time desc")
+    private String orderBy = "";
+
+    @ApiModelProperty(value = "查询条件")
+    private List<com.gree.mall.manager.zfire.bean.QueryParamBean> params;
+
+    @ApiModelProperty(value = "导出的字段,导出必传")
+    private List<AdminField> exportFields;
+
+    @ApiModelProperty(value = "预留字段(前端忽略该字段)")
+    private String query;
+
+    @ApiModelProperty(value = "查询项")
+    private String selected;
+
+
+    @ApiModelProperty(value = "导出用字段")
+    private Integer exportCount = 0;
+
+    @JsonIgnore
+    @ApiModelProperty(value = "返回类的类型")
+    private Class clazzType;
+
+    @JsonIgnore
+    @ApiModelProperty("商户字段")
+    private String companyWechatId;
+
+    @JsonIgnore
+    private List<String> adminWebsitIds;
+
+    /**
+     * 查询指定条件内容
+     */
+    public Object getParamValue(String param){
+        if(CollectionUtils.isEmpty(params))
+            return null;
+        List<com.gree.mall.manager.zfire.bean.QueryParamBean> collect = params.stream().filter(v -> v.getParam().equals(param)).collect(Collectors.toList());
+        if(CollectionUtils.isEmpty(collect)){
+            return null;
+        }
+        return collect.get(0).getValue();
+    }
+
+    /**
+     * 指定查询条件内容
+     */
+    public Boolean setParamValue(String param,String compare,Object value){
+        if(CollectionUtils.isEmpty(params)) {
+            params = new ArrayList<>();
+        }
+        //1. if exists remove
+        this.removeParam(param);
+        //2. add
+        com.gree.mall.manager.zfire.bean.QueryParamBean queryParamBean = new com.gree.mall.manager.zfire.bean.QueryParamBean();
+        queryParamBean.setParam(param);
+        queryParamBean.setCompare(compare);
+        queryParamBean.setValue(value);
+        params.add(queryParamBean);
+        return true;
+    }
+
+    /**
+     * 删除指定查询条件
+     */
+    public Boolean removeParam(String param){
+        if(CollectionUtils.isEmpty(params)) {
+            return true;
+        }
+        params.removeIf(v -> v.getParam().equals(param));
+        return true;
+    }
+}

src/main/java/com/gree/mall/manager/zfire/util/BodyReaderHttpServletRequestWrapper.java

@@ -0,0 +1,89 @@
+package com.gree.mall.manager.zfire.util;
+
+import javax.servlet.ReadListener;
+import javax.servlet.ServletInputStream;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletRequestWrapper;
+import java.io.*;
+import java.nio.charset.Charset;
+
+public class BodyReaderHttpServletRequestWrapper extends HttpServletRequestWrapper {
+
+
+    private final byte[] body;
+    private String bodyStr;
+
+    public BodyReaderHttpServletRequestWrapper(HttpServletRequest request) throws IOException {
+        super(request);
+        String bodyString = getBodyString(request);
+        body = bodyString.getBytes(Charset.forName("UTF-8"));
+        bodyStr=bodyString;
+    }
+
+    public String getBodyStr() {
+        return bodyStr;
+    }
+
+    @Override
+    public ServletInputStream getInputStream() throws IOException {
+        final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(body);
+
+        return new ServletInputStream() {
+            @Override
+            public int read() throws IOException {
+                return byteArrayInputStream.read();
+            }
+
+            @Override
+            public boolean isFinished() {
+                return false;
+            }
+
+            @Override
+            public boolean isReady() {
+                return false;
+            }
+
+            @Override
+            public void setReadListener(ReadListener readListener) {
+
+            }
+        };
+    }
+
+
+    public  String getBodyString(HttpServletRequest request) throws IOException {
+        StringBuilder sb = new StringBuilder();
+        InputStream inputStream = null;
+        BufferedReader reader = null;
+        try {
+            inputStream = request.getInputStream();
+            reader = new BufferedReader(
+                    new InputStreamReader(inputStream, Charset.forName("UTF-8")));
+
+            char[] bodyCharBuffer = new char[1024];
+            int len = 0;
+            while ((len = reader.read(bodyCharBuffer)) != -1) {
+                sb.append(new String(bodyCharBuffer, 0, len));
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            if (inputStream != null) {
+                try {
+                    inputStream.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+            if (reader != null) {
+                try {
+                    reader.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+        return sb.toString();
+    }
+}

src/main/java/com/gree/mall/manager/zfire/util/FieldUtils.java

@@ -0,0 +1,473 @@
+package com.gree.mall.manager.zfire.util;
+
+import cn.hutool.core.date.LocalDateTimeUtil;
+import com.alibaba.excel.EasyExcel;
+import com.alibaba.excel.ExcelWriter;
+import com.alibaba.excel.util.BooleanUtils;
+import com.alibaba.excel.write.handler.CellWriteHandler;
+import com.alibaba.excel.write.handler.context.CellWriteHandlerContext;
+import com.alibaba.excel.write.metadata.WriteSheet;
+import com.alibaba.excel.write.metadata.style.WriteCellStyle;
+import com.alibaba.excel.write.metadata.style.WriteFont;
+import com.alibaba.excel.write.style.column.SimpleColumnWidthStyleStrategy;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.google.common.base.Joiner;
+import com.google.common.collect.Lists;
+import com.gree.mall.manager.annotation.ZfireField;
+import com.gree.mall.manager.bean.ExcelData;
+import com.gree.mall.manager.bean.admin.AdminUserCom;
+import com.gree.mall.manager.constant.Constant;
+import com.gree.mall.manager.plus.entity.AdminField;
+import com.gree.mall.manager.zfire.bean.QueryParamBean;
+import com.gree.mall.manager.zfire.bean.ZfireParamBean;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.poi.ss.usermodel.BorderStyle;
+import org.apache.poi.ss.usermodel.HorizontalAlignment;
+import org.apache.poi.ss.usermodel.IndexedColors;
+import org.apache.poi.ss.usermodel.VerticalAlignment;
+import org.jetbrains.annotations.NotNull;
+import org.springframework.beans.BeansException;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.lang.reflect.Field;
+import java.lang.reflect.Method;
+import java.text.SimpleDateFormat;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.*;
+import java.util.stream.Collectors;
+
+
+@Slf4j
+public class FieldUtils {
+
+
+    public void test() throws NoSuchFieldException, IllegalAccessException {
+//        QueryParamBean map = new QueryParamBean();
+//        map.setCompare("like");
+//        map.setParam("name");
+//        map.setValue("123");
+//
+//
+//        QueryParamBean map2 = new QueryParamBean();
+//        map2.setCompare("=");
+//        map2.setParam("phone");
+//        map2.setValue("1234");
+//        //map2.setCreateTime(new Date());
+//
+//        Field[] declaredFields = map2.getClass().getDeclaredFields();
+//
+//        Field param = map2.getClass().getDeclaredField("param");
+//        param.setAccessible(true);
+//        Object o = param.get(map2);
+//
+//        Field createTime = map2.getClass().getDeclaredField("createTime");
+//        createTime.setAccessible(true);
+//        Object o2 = createTime.get(map2);
+//        String typeName = createTime.getType().getTypeName();
+//
+//        String s = this.supplyParam(Arrays.asList(map, map2));
+//        System.out.print(s);
+    }
+
+
+    /**
+     * 组装最终的sql条件和排序
+     *
+     * @param bean
+     * @return
+     */
+    public static ZfireParamBean supplyParam(ZfireParamBean bean) {
+        return supplyParam(bean, null);
+    }
+
+    public static ZfireParamBean supplyParam(ZfireParamBean bean, Class cls) {
+        //限制最多查询10w条
+        if (bean.getPageSize() != null && (bean.getPageSize().equals(-1) || bean.getPageSize() > Constant.PAGE_SIZE)) {
+            bean.setPageSize(Constant.PAGE_SIZE);
+        }
+        //todo 框架自带防注入
+        bean.setQuery(supplyParam(bean.getParams()));
+        if (StringUtils.isNotBlank(bean.getCompanyWechatId())) {
+            bean.setQuery(bean.getQuery() + " and a.company_wechat_id = '" + bean.getCompanyWechatId() + "'");
+        }
+        if (bean.getClazzType() != null) {
+            bean.setSelected(buildSelectColumn(bean.getClazzType()));
+        } else if (cls != null) {
+            bean.setSelected(buildSelectColumn(cls));
+        }
+        if (StringUtils.isNotBlank(bean.getOrderBy()) && !bean.getOrderBy().contains("order by")) {
+            bean.setOrderBy("order by " + bean.getOrderBy());
+        }
+        return bean;
+    }
+
+    public static ZfireParamBean supplyParam(ZfireParamBean bean, Class cls, AdminUserCom adminUser) {
+        if (Objects.nonNull(adminUser.getAdminCompanyWechat())) {
+            bean.setCompanyWechatId(adminUser.getAdminCompanyWechat().getCompanyWechatId());
+        }
+        bean.setAdminWebsitIds(adminUser.getAdminWebsitIds());
+        //限制最多查询10w条
+        if (bean.getPageSize() != null && (bean.getPageSize().equals(-1) || bean.getPageSize() > Constant.PAGE_SIZE)) {
+            bean.setPageSize(Constant.PAGE_SIZE);
+        }
+        //todo 框架自带防注入
+        bean.setQuery(supplyParam(bean.getParams()));
+        if (StringUtils.isNotBlank(bean.getCompanyWechatId())) {
+            bean.setQuery(bean.getQuery() + " and a.company_wechat_id = '" + bean.getCompanyWechatId() + "'");
+        }
+        if (bean.getClazzType() != null) {
+            bean.setSelected(buildSelectColumn(bean.getClazzType()));
+        } else if (cls != null) {
+            bean.setSelected(buildSelectColumn(cls));
+        }
+        if (StringUtils.isNotBlank(bean.getOrderBy()) && !bean.getOrderBy().contains("order by")) {
+            bean.setOrderBy("order by " + bean.getOrderBy());
+        }
+        return bean;
+    }
+
+
+    public static ZfireParamBean materialParam(ZfireParamBean bean, Class cls, AdminUserCom adminUser) {
+        return supplyParam(bean, cls, adminUser);
+    }
+
+    /**
+     * 组装最终的sql查询字段
+     *
+     * @param clazz
+     * @return
+     */
+    private static String buildSelectColumn(Class clazz) {
+        if (Objects.isNull(clazz)) {
+            return "*";
+        }
+        String defaultTbName = Optional.of(clazz)
+                .filter(item -> item.isAnnotationPresent(ZfireField.class))
+                .map(item -> item.getAnnotation(ZfireField.class))
+                .map(ZfireField.class::cast)
+                .map(ZfireField::tbName)
+                .orElse("");
+
+        Field[] fields = clazz.getDeclaredFields();
+        List<String> sqlNameList = Lists.newArrayList();
+        for (Field field : fields) {
+            ZfireField annotation = field.getAnnotation(ZfireField.class);
+            if (annotation != null && annotation.ignoreSelect()) {
+                continue;
+            }
+
+            String fieldTbName = Optional.ofNullable(annotation)
+                    .map(ZfireField::tbName)
+                    .filter(StringUtils::isNotBlank)
+                    .orElse(defaultTbName);
+//            String sqlName = Optional.ofNullable(annotation)
+//                    .map(ZfireField::colName)
+//                    .filter(StringUtils::isNotBlank)
+//                    .orElseGet(() -> parseLineColName(field.getName(), fieldTbName));
+            String sqlName = parseLineColName(field.getName(), fieldTbName);
+            sqlNameList.add(sqlName);
+        }
+        if (CollectionUtils.isEmpty(sqlNameList)) {
+            return "*";
+        }
+        return Joiner.on(",")
+                .skipNulls()
+                .join(sqlNameList);
+    }
+
+    @NotNull
+    private static String parseLineColName(String name, String fieldTbName) {
+        String lineName = name.replaceAll("[A-Z]", "_" + "$0").toLowerCase();
+        String sqlName = StringUtils.isNotBlank(fieldTbName) ? fieldTbName + "." + lineName : lineName;
+        return sqlName;
+    }
+
+
+    /**
+     * 根据前端传的集合生成查询条件
+     * [{
+     * "param":"条件名称",
+     * "compare":"比较符(><=like)"
+     * "value":"内容"
+     * }]
+     *
+     * @return
+     */
+    public static String supplyParam(List<QueryParamBean> params) {
+        StringBuffer sb = new StringBuffer(" where 1=1 ");
+        if (params == null || params.size() == 0) {
+            return sb.toString();
+        }
+
+        for (QueryParamBean paramBean : params) {
+            if (paramBean.getValue() == null)
+                continue;
+            if (paramBean.getValue() instanceof ArrayList) {
+                List<String> values = (List<String>) paramBean.getValue();
+                if (values != null && values.size() > 0) {
+                    String join = "";
+                    for (String s : values) {
+                        s = replaceValue(s);
+                        join += "'" + s + "',";
+                    }
+                    join = join.substring(0, join.length() - 1);
+                    sb.append("and ").append(paramBean.getParam()).append(" in(").append(join).append(") ");
+                }
+            } else {
+                String value = "";
+                if (paramBean.getValue() instanceof Boolean) {
+                    value = paramBean.getValue().toString();
+                } else {
+                    value = paramBean.getValue().toString();
+                }
+                if (StringUtils.isBlank(value))
+                    continue;
+
+                value = replaceValue(value);
+
+                if (StringUtils.equals(paramBean.getCompare(), "like")) {
+                    value = "%" + value + "%";
+                }
+                sb.append("and ").append(paramBean.getParam()).append(" ").append(paramBean.getCompare());
+                if (value.equals("true") || value.equals("false")) {
+                    sb.append(" ").append(value).append(" ");
+                } else {
+                    sb.append(" '").append(value).append("' ");
+                }
+            }
+        }
+        return sb.toString();
+    }
+
+    public static String replaceValue(String value) {
+        return value.replaceAll("'", "").replaceAll("\"", "")
+                .replaceAll(" or ", "").replaceAll(" union ", "");
+    }
+
+
+    /**
+     * 通用导出
+     */
+    public static void exportData(List datas, List<AdminField> titles, HttpServletRequest request, HttpServletResponse response) throws Exception {
+//        String exportflag = request.getHeader("exportflag");
+//        if(StringUtils.isBlank(exportflag)){
+//            String bodyString = HttpContextUtils.getBodyString(request);
+//            log.info("【通用导出参数】:{}",bodyString);
+//            ExportLogic.add(request,bodyString);
+//            return;
+//        }
+
+        List<List<Object>> rows = new ArrayList<>();
+        List<String> excelTitles = new ArrayList<>();
+        if (CollectionUtils.isEmpty(datas)) {
+//            throw new RemoteServiceException("暂无内容导出");
+            excelTitles.add("暂无内容导出");
+        } else {
+//            Map<String, String> jMap = new LinkedHashMap<>();
+            List<String> jList = new ArrayList<>();
+            if (CollectionUtils.isNotEmpty(titles)) {
+//                for (AdminField title : titles) {
+//                    jMap.put(title.getJName(), title.getLabel());
+//                }
+                jList = titles.stream().map(AdminField::getJName).collect(Collectors.toList());
+            }
+            if (jList.isEmpty()) {
+                Object bean = datas.get(0);
+                Field[] fields = bean.getClass().getDeclaredFields();
+                for (Field field : fields) {
+                    jList.add(field.getName());
+                }
+            }
+
+            for (int i = 0; i < datas.size(); i++) {
+                Object bean = datas.get(i);
+                List<Object> row = new ArrayList<>();
+                Field[] fields = bean.getClass().getDeclaredFields();
+                List<Field> fieldList = Arrays.asList(fields);
+                Map<String, Field> fieldMap = fieldList.stream().collect(Collectors.toMap(Field::getName, v -> v));
+
+                for (String f : jList) {
+                    Field field = fieldMap.get(f);
+                    field.setAccessible(true);
+                    String jName = field.getName();
+                    if (!jList.isEmpty() && !jList.contains(jName)) {
+                        continue;
+                    }
+                    String label = "";
+                    ApiModelProperty annotation = field.getAnnotation(ApiModelProperty.class);
+                    if (annotation == null) {
+                        continue;
+                    }
+                    label = annotation.value();
+
+                    ZfireField zfireFieldAnnotation = field.getAnnotation(ZfireField.class);
+                    if (zfireFieldAnnotation != null && zfireFieldAnnotation.hide()) {
+                        continue;
+                    }
+
+                    //属性类型
+                    String typeName = field.getType().getName();
+                    if (typeName.equals("java.util.List") || typeName.equals("java.util.Map")) {
+                        continue;
+                    }
+                    Object value = field.get(bean);
+
+                    //处理枚举类型
+                    if (field.getType().isEnum()) {
+                        for (Object enumO : field.getType().getEnumConstants()) {
+                            Class<?> c = enumO.getClass();
+                            Method getKey = c.getDeclaredMethod("getKey");
+                            Method getValue = c.getDeclaredMethod("getRemark");
+                            Object invoke = getKey.invoke(enumO);
+                            //String enumKey =  invoke+"";
+                            String enumValue = (String) getValue.invoke(enumO);
+                            if (value != null && value.toString().equals(enumO.toString())) {
+                                value = enumValue;
+                            }
+                        }
+                    }
+
+//                    DictConversion dictConversion = field.getAnnotation(DictConversion.class);
+//                    if (dictConversion != null  && value instanceof String && StringUtils.isNotBlank((String) value)) {
+//                        value = DictUtils.getDictDataValue(dictConversion.value(), (String) value);
+//                    }
+
+                    if (value == null) {
+                        row.add("");
+                    }
+
+                    if (value != null) {
+                        if ("java.util.Date" .equals(typeName)) {
+                            //todo 格式化时间
+                            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+                            row.add(sdf.format(value));
+                        } else if (field.getType().isAssignableFrom(LocalDateTime.class)) {
+                            row.add(LocalDateTimeUtil.formatNormal((LocalDateTime) value));
+                        } else if (field.getType().isAssignableFrom(LocalDate.class)) {
+                            row.add(LocalDateTimeUtil.formatNormal((LocalDate) value));
+                        } else {
+                            row.add(value);
+                        }
+                    }
+                    if (i == 0) {
+                        excelTitles.add(label);
+                    }
+                }
+                rows.add(row);
+            }
+        }
+        ExcelData excelData = new ExcelData();
+        excelData.setRows(rows);
+        excelData.setTitles(excelTitles);
+        //目前是异步导出，名字由前端根据菜单名定义
+        //ExcelUtils.exportExcel(request,response,"test.xlsx",excelData);
+        export(excelData, "test.xlsx");
+    }
+
+
+    public static void export(ExcelData excelData, String fileName) throws IOException {
+        OutputStream outputStream = null;
+        try {
+            //标题
+            List<List<String>> titles = new ArrayList<>();
+            for (String title : excelData.getTitles()) {
+                titles.add(Arrays.asList(title));
+            }
+
+            //记录总数:实际中需要根据查询条件进行统计即可
+            Integer totalCount = excelData.getRows().size();
+            //每一个Sheet存放100w条数据
+            Integer sheetDataRows = 1000000;
+            //每次写入的数据量20w,每页查询20W
+            Integer writeDataRows = 200000;
+            //计算需要的Sheet数量
+            Integer sheetNum = totalCount % sheetDataRows == 0 ? (totalCount / sheetDataRows) : (totalCount / sheetDataRows + 1);
+            //计算一般情况下每一个Sheet需要写入的次数(一般情况不包含最后一个sheet,因为最后一个sheet不确定会写入多少条数据)
+            Integer oneSheetWriteCount = sheetDataRows / writeDataRows;
+            //计算最后一个sheet需要写入的次数
+            Integer lastSheetWriteCount = totalCount % sheetDataRows == 0 ? oneSheetWriteCount : (totalCount % sheetDataRows % writeDataRows == 0 ? (totalCount / sheetDataRows / writeDataRows) : (totalCount / sheetDataRows / writeDataRows + 1));
+            ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
+            HttpServletResponse response = requestAttributes.getResponse();
+            outputStream = response.getOutputStream();
+
+            //样式
+            WriteCellStyle cellStyle = writeCellStyle();
+
+            //必须放到循环外，否则会刷新流
+            ExcelWriter excelWriter = EasyExcel.write(outputStream).registerWriteHandler(new CellWriteHandler() {
+                public void afterCellDispose(CellWriteHandlerContext context) {
+                    CellWriteHandler.super.afterCellDispose(context);
+                    if (BooleanUtils.isNotTrue(context.getHead())) {
+                        context.getFirstCellData().setWriteCellStyle(cellStyle);
+                    }
+                }
+            }).build();
+            //开始分批查询分次写入
+            for (int i = 0; i < sheetNum; i++) {
+                //创建Sheet
+//                WriteSheet sheet = new WriteSheet();
+//                sheet.setSheetName("Sheet"+i);
+//                sheet.setSheetNo(i);
+                //循环写入次数: j的自增条件是当不是最后一个Sheet的时候写入次数为正常的每个Sheet写入的次数,如果是最后一个就需要使用计算的次数lastSheetWriteCount
+                for (int j = 0; j < (i != sheetNum - 1 ? oneSheetWriteCount : lastSheetWriteCount); j++) {
+                    //分页查询一次20w
+                    WriteSheet writeSheet = EasyExcel.writerSheet(i, "Sheet" + (i + 1)).head(titles)
+                            .registerWriteHandler(new SimpleColumnWidthStyleStrategy(30))
+                            .build();
+                    //写数据
+                    excelWriter.write(excelData.getRows(), writeSheet);
+                }
+            }
+            // 下载EXCEL
+            response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
+            response.setCharacterEncoding("utf-8");
+            // 这里URLEncoder.encode可以防止浏览器端导出excel文件名中文乱码 当然和easyexcel没有关系
+            //String fileName = URLEncoder.encode("员工信息", "UTF-8").replaceAll("\\+", "%20");
+            response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName);
+            excelWriter.finish();
+            outputStream.flush();
+        } catch (IOException e) {
+            e.printStackTrace();
+        } catch (BeansException e) {
+            e.printStackTrace();
+        } finally {
+            if (outputStream != null) {
+                outputStream.close();
+            }
+        }
+    }
+
+
+    /**
+     * excel样式
+     *
+     * @return
+     */
+    public static WriteCellStyle writeCellStyle() {
+        //样式
+        WriteFont font = new WriteFont();
+        font.setFontName("simsun");
+        font.setFontHeightInPoints((short) 10);
+        font.setColor(IndexedColors.BLACK.index);
+        WriteCellStyle cellStyle = new WriteCellStyle();
+        cellStyle.setHorizontalAlignment(HorizontalAlignment.CENTER);
+        cellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
+        cellStyle.setWriteFont(font);
+        cellStyle.setWrapped(false);
+        cellStyle.setBorderTop(BorderStyle.THIN);
+        cellStyle.setBorderLeft(BorderStyle.THIN);
+        cellStyle.setBorderBottom(BorderStyle.THIN);
+        cellStyle.setBorderRight(BorderStyle.THIN);
+        return cellStyle;
+    }
+
+
+}