积木报表Excel数据量大导出慢导不出问题、大量数据导不出问题优化方案和分 ...

积木报表Excel数据量大导出慢导不出问题、大量数据导不出问题优化方案和分析解决思绪（优化前一万多导出失败，优化后支持百万级跨库表导出，已开源）

   若条件允许建议使用数仓来做，性能会好很多很多，查询一秒内，下载百万明细数据几十秒，参考文档
数据仓库技能选型方案文档
Flink CDC MySQL数据同步到Doris表同步配置生成工具类
新版报表系统（明细报表、看板、数据大屏）方案&介绍
  反馈官方进度

跟官方反馈这个方案后，官方直接优化了但是把本来这个免费的大数据导出做成了收费功能！绝了，我直接把我方案开源

反馈后看到后续的版本里有说升级了这个，于是我升级了包测试，直接这个功能必要企业版才给用了，寄，不如直接用下载中央模式得了，有空把这个下载中央的代码抽出来封装好开源放github 0
下载中央这个本领抽出来脱敏成开源项目已预备的差不多了，预备好后更新文章,帮忙点star支持开源
地址：https://github.com/HumorChen/JimuExportDataExtension

优化结果

原积木导出有两种导出，直接导出和大数据导出（大数据导出是做了优化去掉了一些样式之类的，性能更好）
实测中发现
原积木大数据导出性能：1万条数据导出耗时30秒，1.5万条耗时1.5分钟导出失败，数据超过一万条后经常导出失败，还会导致容器实例探活失败/内存撑爆重启
异步+自实现导出功能优化方案导出性能：48万条数据一次导出耗时2.5分钟，导出时快速返回空数据文件，制止页面死等不可用，导出后的表格是在线OSS的文件URL直接每个人都可以快速下载，可随时多次下载。

需求背景息争决方案的思考

   具体讲了需求来由、解决历程的思考心路历程，有点长，想学习解决思绪的可认真阅读，只必要解决方案的可以不看。我这正是由于当前项目组还没有专门做数据仓库的人，先用的积木如许的报表来做的。数据量大之后性能看着很心累，数据量大建议招专业的做数仓的。
项目组的数据报表、导出最开始的技能职员选型的是开源的积木报表（积木报表GitHub地址（5.4K star）），后续积木闭源了。在后续数据量增加后，积木报表经常性导出失败，运营同砚反馈多次，于是优化报表的重担交给了我。
一期我先优化了SQL、涉及表的索引，取消走SQL join 一二十张表的方案，改为API代码分页实现查询。上线后结果仍旧不行，于是继续深入分析性能瓶颈，观察链路跟踪后发现，在导出时内存和CPU都飙升，甚至内存会被拉爆。
我看了下实际SQL执行时间其实相对于整个导出过程并没有很长，在500ms左右一个分页（5000条一个页，淘汰页到1000,2000未发现明显性能提拔），在整个导出操作流程中，我通过抓包和链路跟踪查看，链路是导出按钮调用了积木的一个exportAllExcelStream接口，然后积木内部代码又去调用我配置的表数据源接口地址，将分页和查询条件拿去调我们项目接口获取数据，并导出为excel写入导出哀求的响应流里，那既然我们获取数据的接口耗时占整个导出操作的占比低，其实性能瓶颈在积木框架内部。
于是我打开积木的代码一看，好家伙，都是abcdefg如许的命名，做过代码肴杂加密的就一眼看得出，变量名被重命名肴杂过了，甚至连积木导出接口的字符串都搜刮不到没法找到入口，看来接口字符串都做了隐藏，于是我怀疑是excel导出大量数据有性能问题，我看了下积木依赖的pom文件里引入的是org.apache.poi，我去百度搜刮了相干文章后，看到了其他博主说Apache POI导出有性能问题，性能低下，占用过多的内存，数据量大的时候特别明显，保举使用阿里巴巴的EasyExcel来导出表格，只有十分之一的消耗。
于是网络完情况后，现在摆在面前的两个痛点，第一个是导出慢会慢到网关直接504返回超时（一个接口调用几分钟以上），第二个是积木报表自身用了POI导出很慢，和领导讨论了一下，超时问题可以走异步实现解决，写一个导出下载中央，导出操作接口快速返回一个空的（注解+AOP切面实现拦截），然后异步去再次调用积木导出接口，并设置上哀求头，方便拦截接口导出的切面识别到这个是异步执行，就返回实际数据不要返回空数据，如许就不会接口超时了，这个方案我先实现了下确实可行。
第二个问题就是导出慢的解决，由于闭源还有代码肴杂加密操作，无法二开代码，因此要想解决POI这个问题你就必要本身实现导出，第一个想到的操作是直接在积木报表的页面加个快速导出按钮，可页面代码是积木本身生成的，不方便植入，第二个思绪是，识别积木的导出操作，由于积木导出的时候还是要来我们接口这获取数据的，获取的时候带了分页信息，我们根据每页数据和配置的积木导出时每页数据条数这个配置对比就能识别到是不是导出操作，平常查看是10条每页，导出的时候会变5000条一页，很好区分，但区分完了，怎么实现导出操作呢？报表都是在积木的报表设计里用鼠标点点点的UI操作设计的，你本身接口怎么知道表头、数据源、表名、哪个账户导出的？
带着这些问题我深入查看了积木的数据库表，你积木能读取我就能读取，我看看你到底把这些关键信息存储在哪里了，翻开数据表里可以看到的，确实把表格的字段、宽度、样式、表格ID之类的信息都在Mysql里存着呢，那我只必要写一个解析这些数据的服务就可以像积木一样导出了。
方案思绪可行性得到确认，那我就开始将复杂使命流程关键问题拆解并解决：
第一个是积木点击导出时的参数信息要完备拿到并生存到我们本身设计的导出使命里
(走积木自定义header预留的钩子实现透传哀求数据)
第二个是要能正确读取我们人工在积木报表里配置的数据源API、表头名、表头字段等信息
（自行配置一个示范表并看数据库数据怎么存的，写代码解析这个数据结构并返回我们标准化的解析方法）
第三个是要自行实现调用数据源AP时积木的那次导出操作被拦截返回空数据，我们本身的导出正常导出数据
（新加注解，拦截注解的API，识别是否为积木导出操作，是则拦截，生成导出使命，返回空数据集合，否则直接执行原接口逻辑返回正常数据）
第四个是正确根据积木里的表头字段等信息使用EasyExcel生成表格并将表格上传到OSS，中间不建议产生呆板上的物理文件（使用二进制流生存）
（写一个指定接口分页导出工具，按分页不断调用数据获取接口得到元数据，利用前面得到的表头字段举行解析生成EasyExcel导出数据时必要的结构体，末了使用EasyExcel将数据导出为excel文件的二进制流）
  解决方案

在数据获取的api接口上加注解标识这个导出走下载中央方案，若要恢复原样，则注释这个注解即可

流程形貌：

识别并拦截积木导出操作，透传导出时参数生成本身设计的导出使命，异步执行导出使命(自行实现积木导出的逻辑)，并使用高性能的阿里巴巴开源的EasyExcel工具，末了将EasyExcel导出的表格文件上传到OSS变为表格URL（记得做安全防护，制止表格走漏）
积木的逻辑
积木前端导出按钮->积木导出接口->分页调取你的数据接口拉数据->生成excel返回
关键代码

   大部分代码是不必要你改的，你可以根据本身项目连合使用，比方OSS上传的地方改为你本身的。后面的代码有点长~必要的人依次把代码弄进本身项目。
  引入easy excel

1.                         <dependency>
2.                 <groupId>com.alibaba</groupId>
3.                 <artifactId>easyexcel-core</artifactId>
4.                 <version>3.1.1</version>
5.             </dependency>
6.             <dependency>
7.                 <groupId>com.alibaba</groupId>
8.                 <artifactId>easyexcel</artifactId>
9.                 <version>3.1.1</version>
10.             </dependency>

复制代码

新建数据库表

1. CREATE TABLE `t_download_task` (
2.   `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT 'ID',
3.   `account` varchar(64) COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '提交任务的账号',
4.   `title` varchar(256) COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '下载任务标题',
5.   `icon` varchar(1024) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '图标',
6.   `url` varchar(1024) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '文件URL',
7.   `file_size` varchar(16) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '文件大小',
8.   `percent` varchar(16) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '进度（例如50%）',
9.   `state` tinyint(4) DEFAULT '0' COMMENT '任务状态（0 等待执行，1执行中，2执行成功，3执行失败）',
10.   `error` varchar(1024) COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '执行报错信息（有则填）',
11.   `json` varchar(4096) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '{}' COMMENT '预留的json扩展字段',
12.   `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
13.   `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
14.   PRIMARY KEY (`id`),
15.   KEY `idx_account_create_time` (`account`,`create_time`),
16.   KEY `idx_create_time` (`create_time`)
17. ) ENGINE=InnoDB AUTO_INCREMENT=78 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='下载中心的任务';

复制代码

下载使命

2. /**
3. * <p>
4. * 下载任务
5. * </p>
6. *
7. * @author humorchen
8. * @since 2024-01-05
9. */
10. @Data
11. @EqualsAndHashCode(callSuper = false)
12. @Accessors(chain = true)
13. @TableName("t_download_task")
14. public class DownloadTask implements Serializable {
16.     private static final long serialVersionUID = 1L;
18.     /**
19.      * ID
20.      */
21.     @TableId(value = "id", type = IdType.AUTO)
22.     private Integer id;
23.     /**
24.      * 创建下载任务的账号
25.      */
26.     @TableField("account")
27.     private String account;
29.     /**
30.      * 下载任务标题
31.      */
32.     @TableField("title")
33.     private String title;
35.     /**
36.      * 图标
37.      */
38.     @TableField("icon")
39.     private String icon;
41.     /**
42.      * 文件URL
43.      */
44.     @TableField("url")
45.     private String url;
47.     /**
48.      * 文件大小
49.      */
50.     @TableField("file_size")
51.     private String fileSize;
53.     /**
54.      * 进度（例如50%）
55.      */
56.     @TableField("percent")
57.     private String percent;
59.     /**
60.      * 任务状态（0 等待执行，1执行中，2执行成功，3执行失败）
61.      */
62.     @TableField("state")
63.     private Integer state;
65.     /**
66.      * 执行报错信息（有则填）
67.      */
68.     @TableField("error")
69.     private String error;
71.     /**
72.      * 预留的json扩展字段
73.      */
74.     @TableField("json")
75.     private String json;
77.     /**
78.      * 创建时间
79.      */
80.     @TableField("create_time")
81.     private Date createTime;
83.     /**
84.      * 更新时间
85.      */
86.     @TableField("update_time")
87.     private Date updateTime;
90.     public static final String ID = "id";
92.     public static final String ACCOUNT = "account";
94.     public static final String TITLE = "title";
96.     public static final String ICON = "icon";
98.     public static final String URL = "url";
100.     public static final String FILE_SIZE = "file_size";
102.     public static final String PERCENT = "percent";
104.     public static final String STATE = "state";
106.     public static final String ERROR = "error";
108.     public static final String JSON = "json";
110.     public static final String CREATE_TIME = "create_time";
112.     public static final String UPDATE_TIME = "update_time";
114. }

复制代码

使用mabatis plus code generator生成service、mapper等文件
识别所需注解、基类

数据获取api所调用服务上方法上标注的注解

1. /**
2. * @author: humorchen
3. * date: 2024/1/15
4. * description: 该报表接口使用下载任务中心代理掉，完成下载任务
5. * 使用要求：
6. * 参数中需要有一个参数是DownloadCenterBaseParam的子类，方法返回值类型需要是支持泛型的JimuPageDto类，方法上加注@UseDownloadTaskCenter注解
7. * 参考cn.sffix.recovery.report.service.impl.ReportServiceImpl#dashboardNewVersion(cn.sffix.recovery.report.entity.dto.DashBoardQueryDto)
8. **/
9. @Retention(RetentionPolicy.RUNTIME)
10. @Target({ElementType.METHOD})
11. @Documented
12. public @interface UseDownloadTaskCenter {
14. }

复制代码

示范给数据接口调用的服务加注解

1.     @Override
2.     @UseDownloadTaskCenter
3.     public JimuPageDto<DashBoardDataDto> dashboardNewVersion(DashBoardQueryDto dashBoardQueryDto) {
4.     //  你的数据接口逻辑
5.     }

复制代码

参数基类

1. /**
2. * @author: humorchen
3. * date: 2024/1/15
4. * description:
5. **/
6. @Data
7. public class DownloadCenterBaseParam {
9.     /**
10.      * 分页数据页号和页大小
11.      */
12.     private Integer pageNo;
13.     /**
14.      * 分页数据页号和页大小
15.      */
16.     private Integer pageSize;
17. }

复制代码

结果基类

1. /**
2. * @author: humorchen
3. * date: 2023/12/19
4. * description:
5. **/
6. @Data
7. @FieldNameConstants
8. @Accessors(chain = true)
9. public class JimuPageDto<T> {
10.     /**
11.      * 数据
12.      */
13.     private List<T> data;
14.     /**
15.      * 积木的count是总数据条数，不是当前页多少条！！！
16.      */
17.     private long count;
18.     /**
19.      * 积木的total是总页数，不是总数据条数！！！
20.      */
21.     private long total;
23.     public static final JimuPageDto EMPTY = new JimuPageDto().setData(Collections.emptyList()).setTotal(0).setCount(0);
24. }

复制代码

2. /**
3. * @author: humorchen
4. * date: 2024/1/5
5. * description: 下载任务状态
6. **/
7. @Getter
8. public enum DownloadTaskStateEnum {
9.     WAIT(0, "等待执行"),
10.     RUNNING(1, "执行中"),
11.     SUCCESS(2, "执行成功"),
12.     FAILED(3, "执行失败"),
14.     ;
16.     private final int state;
17.     private final String title;
19.     DownloadTaskStateEnum(int state, String title) {
20.         this.state = state;
21.         this.title = title;
22.     }
24.     /**
25.      * 根据状态获取枚举
26.      *
27.      * @param state
28.      * @return
29.      */
30.     public static DownloadTaskStateEnum of(int state) {
31.         for (DownloadTaskStateEnum value : values()) {
32.             if (value.state == state) {
33.                 return value;
34.             }
35.         }
36.         return null;
37.     }
38. }

复制代码

下载中央服务（报表下载的导出使命）

1. /**
2. * <p>
3. * 下载任务 服务类
4. * </p>
5. *
6. * @author humorchen
7. * @since 2024-01-05
8. */
9. public interface IDownloadTaskService extends IService<DownloadTask> {
10.     /**
11.      * 注册任务
12.      *
13.      * @param downloadTask
14.      * @return
15.      */
16.     DownloadTask registerTask(@NonNull DownloadTask downloadTask);
18.     /**
19.      * 10秒内是否有相同任务未完成，不给再次注册下载任务
20.      *
21.      * @param account
22.      * @param requestBody
23.      * @return
24.      */
25.     boolean setSameTaskLock(String account, String requestBody);
26.     /**
27.      * 更新任务
28.      *
29.      * @param downloadTask
30.      * @return
31.      */
32.     int updateTaskById(@NonNull DownloadTask downloadTask);
34.     /**
35.      * 更新任务进度
36.      *
37.      * @param id
38.      * @param percent
39.      * @return
40.      */
41.     int changeTaskPercent(int id, @NonNull String percent);
43.     /**
44.      * 更新任务状态
45.      *
46.      * @param id
47.      * @param state
48.      * @return
49.      */
50.     int changeTaskState(int id, @NonNull DownloadTaskStateEnum state);
52.     /**
53.      * 更新任务状态
54.      *
55.      * @param id
56.      * @param expectState
57.      * @param targetState
58.      * @return
59.      */
60.     int compareAndSwapTaskState(int id, @NonNull DownloadTaskStateEnum expectState, @NonNull DownloadTaskStateEnum targetState);
61.     /**
62.      * 根据任务ID获取任务
63.      *
64.      * @param id
65.      * @return
66.      */
67.     DownloadTask getDownloadTaskById(int id);
69.     /**
70.      * 分页查下载任务
71.      *
72.      * @param pageListDownloadTaskDto
73.      * @return
74.      */
75.     IPage<DownloadTask> pageListDownloadTask(PageListDownloadTaskDto pageListDownloadTaskDto);
77.     /**
78.      * 重新执行下载任务
79.      *
80.      * @param taskId
81.      * @return
82.      */
83.     @RequestMapping("/rerunTask")
84.     Result<String> rerunTask(Integer taskId);
86.     /**
87.      * 根据报表ID获取报表名称
88.      *
89.      * @param reportId
90.      * @return
91.      */
92.     String getReportNameByReportId(String reportId);
94.     /**
95.      * 从请求体中获取报表ID
96.      *
97.      * @param requestBody
98.      * @return
99.      */
100.     String getReportIdFromRequestBody(String requestBody);
102.     /**
103.      * 根据报表ID获取报表API地址或者SQL
104.      *
105.      * @param reportId
106.      * @return
107.      */
108.     JimuReportDataSourceDTO getReportApiOrSqlByReportId(String reportId);
110.     /**
111.      * 获取积木报表的头
112.      *
113.      * @param reportId
114.      * @return
115.      */
116.     List<JimuReportDataColumnDTO> getReportHead(String reportId);
118.     /**
119.      * 从积木请求体中获取请求参数
120.      *
121.      * @param json
122.      * @return
123.      */
124.     String getRequestParamFromJson(String json);
125. }

复制代码

实现类

1. /**
2. * <p>
3. * 下载任务 服务实现类
4. * </p>
5. *
6. * @author humorchen
7. * @since 2024-01-05
8. */
9. @Service
10. @Slf4j
11. public class DownloadTaskServiceImpl extends ServiceImpl<DownloadTaskMapper, DownloadTask> implements IDownloadTaskService {
12.     @Autowired
13.     private DownloadTaskMapper downloadTaskMapper;
14.     @Autowired
15.     private IReportDataGetService reportDataGetService;
16.     @Autowired
17.     private RedisTemplate<String, String> redisTemplate;
19.     /**
20.      * 注入spring 事件发布器
21.      */
22.     @Autowired
23.     private ApplicationEventPublisher eventPublisher;
25.     /**
26.      * 注册任务
27.      *
28.      * @param downloadTask
29.      * @return
30.      */
31.     @Override
32.     public DownloadTask registerTask(@NonNull DownloadTask downloadTask) {
33.         downloadTaskMapper.insert(downloadTask);
34.         return downloadTask;
35.     }
37.     /**
38.      * 10秒内是否有相同任务未完成，不给再次注册下载任务
39.      *
40.      * @param account
41.      * @param requestBody
42.      * @return
43.      */
44.     @Override
45.     public boolean setSameTaskLock(String account, String requestBody) {
46.         DownloadTaskSubmitLimitCacheKey limitCacheKey = new DownloadTaskSubmitLimitCacheKey(account, MD5.create().digestHex(requestBody));
47.         Boolean setIfAbsent = redisTemplate.opsForValue().setIfAbsent(limitCacheKey.getKey(), DateUtil.now(), limitCacheKey.getExpire(), limitCacheKey.getTimeUnit());
48.         return Boolean.TRUE.equals(setIfAbsent);
49.     }
51.     /**
52.      * 更新任务
53.      *
54.      * @param downloadTask
55.      * @return
56.      */
57.     @Override
58.     public int updateTaskById(@NonNull DownloadTask downloadTask) {
59.         return downloadTaskMapper.updateById(downloadTask);
60.     }
62.     /**
63.      * 更新任务进度
64.      *
65.      * @param id
66.      * @param percent
67.      * @return
68.      */
69.     @Override
70.     public int changeTaskPercent(int id, @NonNull String percent) {
71.         UpdateWrapper<DownloadTask> updateWrapper = new UpdateWrapper<>();
72.         updateWrapper.eq(DownloadTask.ID, id);
73.         updateWrapper.set(DownloadTask.PERCENT, percent);
74.         log.info("【下载中心】更新任务进度 id:{} percent:{}", id, percent);
75.         return downloadTaskMapper.update(null, updateWrapper);
76.     }
78.     /**
79.      * 更新任务状态
80.      *
81.      * @param id
82.      * @param state
83.      * @return
84.      */
85.     @Override
86.     public int changeTaskState(int id, @NonNull DownloadTaskStateEnum state) {
87.         UpdateWrapper<DownloadTask> updateWrapper = new UpdateWrapper<>();
88.         updateWrapper.eq(DownloadTask.ID, id);
89.         updateWrapper.set(DownloadTask.STATE, state.getState());
90.         return downloadTaskMapper.update(null, updateWrapper);
91.     }
93.     /**
94.      * 更新任务状态
95.      *
96.      * @param id
97.      * @param expectState
98.      * @param targetState
99.      * @return
100.      */
101.     @Override
102.     public int compareAndSwapTaskState(int id, @NonNull DownloadTaskStateEnum expectState, @NonNull DownloadTaskStateEnum targetState) {
103.         UpdateWrapper<DownloadTask> updateWrapper = new UpdateWrapper<>();
104.         updateWrapper.eq(DownloadTask.ID, id);
105.         updateWrapper.eq(DownloadTask.STATE, expectState.getState());
106.         updateWrapper.set(DownloadTask.STATE, targetState.getState());
107.         return downloadTaskMapper.update(null, updateWrapper);
108.     }
110.     /**
111.      * 根据任务ID获取任务
112.      *
113.      * @param id
114.      * @return
115.      */
116.     @Override
117.     public DownloadTask getDownloadTaskById(int id) {
118.         return downloadTaskMapper.selectById(id);
119.     }
121.     /**
122.      * 查下载任务
123.      *
124.      * @param pageListDownloadTaskDto
125.      * @return
126.      */
127.     @Override
128.     public IPage<DownloadTask> pageListDownloadTask(PageListDownloadTaskDto pageListDownloadTaskDto) {
129.         Integer id = pageListDownloadTaskDto.getId();
130.         String startTime = pageListDownloadTaskDto.getStartTime();
131.         String endTime = pageListDownloadTaskDto.getEndTime();
132.         String fileName = pageListDownloadTaskDto.getFileName();
133.         Integer taskState = pageListDownloadTaskDto.getTaskState();
134.         UserInfo userInfo = UserInfoHolder.get();
135.         String account = userInfo.getAccount();
136.         int pageNo = Optional.ofNullable(pageListDownloadTaskDto.getPageNo()).orElse(1);
137.         int pageSize = Optional.ofNullable(pageListDownloadTaskDto.getPageSize()).orElse(10);
139.         QueryWrapper<DownloadTask> queryWrapper = new QueryWrapper<>();
140.         queryWrapper.eq(DownloadTask.ACCOUNT, account);
141.         queryWrapper.eq(id != null, DownloadTask.ID, id);
142.         queryWrapper.between(startTime != null && endTime != null, DownloadTask.CREATE_TIME, startTime, endTime);
143.         queryWrapper.like(StrUtil.isNotBlank(fileName), DownloadTask.TITLE, "%" + fileName + "%");
144.         queryWrapper.eq(taskState != null, DownloadTask.STATE, taskState);
145.         // 最新的在前
146.         queryWrapper.orderByDesc(DownloadTask.CREATE_TIME);
147.         return page(new Page<>(pageNo, pageSize), queryWrapper);
148.     }
150.     /**
151.      * 重新执行下载任务
152.      *
153.      * @param taskId
154.      * @return
155.      */
156.     @Override
157.     public Result<String> rerunTask(Integer taskId) {
158.         DownloadTask downloadTask = getDownloadTaskById(taskId);
159.         if (downloadTask == null) {
160.             return Result.fail("未找到该任务，请刷新后重试");
161.         }
162.         if (downloadTask.getState() == DownloadTaskStateEnum.RUNNING.getState()) {
163.             return Result.fail("任务正在执行中，请稍后重试");
164.         }
165.         eventPublisher.publishEvent(new DownloadTaskPublishEvent(taskId));
166.         return Result.ok("重新执行中");
167.     }
169.     /**
170.      * 根据报表ID获取报表名称
171.      *
172.      * @param reportId
173.      * @return
174.      */
175.     @Override
176.     public String getReportNameByReportId(String reportId) {
177.         if (StrUtil.isBlank(reportId)) {
178.             return "";
179.         }
180.         String sql = "select name from report.jimu_report where id = '" + reportId + "'";
181.         JSONObject jsonObject = reportDataGetService.getOne(sql);
182.         return Optional.ofNullable(jsonObject.getString("name")).orElse("");
183.     }
185.     /**
186.      * 从请求体中获取报表ID
187.      *
188.      * @param requestBody
189.      * @return
190.      */
191.     @Override
192.     public String getReportIdFromRequestBody(String requestBody) {
193.         if (StrUtil.isNotBlank(requestBody)) {
194.             JSONObject jsonObject = JSONObject.parseObject(requestBody);
195.             return jsonObject.getString("excelConfigId");
196.         }
197.         return null;
198.     }
200.     /**
201.      * 根据报表ID获取报表API地址或者SQL
202.      *
203.      * @param reportId
204.      * @return
205.      */
206.     @Override
207.     public JimuReportDataSourceDTO getReportApiOrSqlByReportId(String reportId) {
208.         JimuReportDataSourceDTO jimuReportDataSourceDTO = new JimuReportDataSourceDTO();
209.         if (StrUtil.isNotBlank(reportId)) {
210.             String sql = "select db_dyn_sql,api_url from report.jimu_report_db where jimu_report_id = '" + reportId + "'";
211.             JSONObject jsonObject = reportDataGetService.getOne(sql);
212.             jimuReportDataSourceDTO.setSql(jsonObject.getString("db_dyn_sql"));
213.             jimuReportDataSourceDTO.setApiUrl(jsonObject.getString("api_url"));
214.         }
215.         List<List<String>> head = new ArrayList<>();
216.         EasyExcel.write(new OutputStream() {
217.             @Override
218.             public void write(int b) throws IOException {
220.             }
221.         }).head(head).sheet("sheet").doWrite(new ArrayList<>());
223.         return jimuReportDataSourceDTO;
224.     }
226.     /**
227.      * 获取积木报表的头
228.      *
229.      * @param reportId
230.      * @return
231.      */
232.     @Override
233.     public List<JimuReportDataColumnDTO> getReportHead(String reportId) {
234.         if (StrUtil.isBlank(reportId)) {
235.             return Collections.emptyList();
236.         }
237.         String sql = "select json_str from report.jimu_report where id = '" + reportId + "'";
238.         JSONObject jsonObject = reportDataGetService.getOne(sql);
239.         String jsonStr = jsonObject.getString("json_str");
240.         JSONObject json = JSONObject.parseObject(jsonStr);
241.         JSONObject rows = json.getJSONObject("rows");
242.         JSONObject rows0Cells = rows.getJSONObject("0").getJSONObject("cells");
243.         JSONObject rows1Cells = rows.getJSONObject("1").getJSONObject("cells");
245.         Set<String> rows0KeySets = rows0Cells.keySet();
246.         List<JimuReportDataColumnDTO> heads = rows0KeySets.stream().map(key -> {
247.             JSONObject keyObject = rows0Cells.getJSONObject(key);
248.             JSONObject columnObject = rows1Cells.getJSONObject(key);
249.             if (keyObject == null || columnObject == null) {
250.                 return null;
251.             }
252.             String name = keyObject.getString("text");
253.             String column = columnObject.getString("text");
254.             if (StrUtil.isBlank(name) || StrUtil.isBlank(column)) {
255.                 return null;
256.             }
257.             // 处理 #{vpjcgifyua.orderId}
258.             int indexOf = column.lastIndexOf(".");
259.             int indexOf2 = column.lastIndexOf("}");
260.             if (column.startsWith("#") && indexOf >= 0 && indexOf2 >= 0) {
261.                 column = column.substring(indexOf + 1, indexOf2);
262.                 if (StrUtil.isBlank(column)) {
263.                     return null;
264.                 }
265.             }
266.             JimuReportDataColumnDTO jimuReportDataColumnDTO = new JimuReportDataColumnDTO();
267.             jimuReportDataColumnDTO.setName(name);
268.             jimuReportDataColumnDTO.setColumn(column);
269.             jimuReportDataColumnDTO.setIndex(Integer.parseInt(key));
270.             return jimuReportDataColumnDTO;
271.         }).filter(Objects::nonNull).sorted(Comparator.comparing(JimuReportDataColumnDTO::getIndex)).collect(Collectors.toList());
272.         log.info("【下载中心】获取积木报表的头 reportId:{}，heads:{}", reportId, heads);
273.         return heads;
274.     }
276.     /**
277.      * 从积木请求体中获取请求参数
278.      *
279.      * @param json
280.      * @return
281.      */
282.     @Override
283.     public String getRequestParamFromJson(String json) {
284.         if (StrUtil.isNotBlank(json)) {
285.             JSONObject jsonObject = JSONObject.parseObject(json);
286.             if (jsonObject.containsKey("param")) {
287.                 return jsonObject.getJSONObject("param").toJSONString();
288.             }
289.             return "{}";
290.         }
291.         return "{}";
292.     }
295. }

复制代码

数据跨库获取工具

服务接口

2. /**
3. * @author: humorchen
4. * date: 2023/12/19
5. * description: 获取数据服务，直接SQL跨库拿数据
6. **/
7. @DS("slave_1")
8. public interface IReportDataGetService<T> {
9.     /**
10.      * 执行SQL返回数据
11.      *
12.      * @param sql
13.      * @return
14.      */
15.     JSONObject getOne(String sql);
17.     /**
18.      * 执行SQL返回数据，数据封装到类cls对象里
19.      *
20.      * @param sql
21.      * @param cls
22.      * @return
23.      */
24.     T getOne(String sql, Class<T> cls);
26.     /**
27.      * 执行SQL返回数据
28.      *
29.      * @param sql
30.      * @return
31.      */
32.     JSONArray getList(String sql);
34.     /**
35.      * 执行SQL返回数据，数据封装到类cls对象里
36.      *
37.      * @param sql
38.      * @param cls
39.      * @return
40.      */
41.     List<T> getList(String sql, Class<T> cls);
43.     /**
44.      * 分页查询
45.      *
46.      * @param sql
47.      * @param page
48.      * @param pageSize
49.      * @return
50.      */
51.     JSONArray pageGetList(String sql, int page, int pageSize);
53.     /**
54.      * 分页查询
55.      *
56.      * @param sql
57.      * @param page
58.      * @param pageSize
59.      * @return
60.      */
61.     JimuPageDto<JSONObject> pageGetListForJimu(String sql, int page, int pageSize);
63.     /**
64.      * 分页查询
65.      *
66.      * @param sql
67.      * @param page
68.      * @param pageSize
69.      * @param cls
70.      * @return
71.      */
72.     JimuPageDto<T> pageGetListForJimu(String sql, int page, int pageSize, Class<T> cls);
74.     /**
75.      * 计数
76.      *
77.      * @param sql
78.      * @return
79.      */
80.     long count(String sql);
83.     /**
84.      * 生成in语句
85.      *
86.      * @param columnName
87.      * @param elements
88.      * @return string
89.      */
90.     default String getColumnInSql(String columnName, List<String> elements) {
91.         StringBuilder sqlBuilder = new StringBuilder();
92.         sqlBuilder.append(" ");
93.         sqlBuilder.append(columnName);
94.         sqlBuilder.append(" in (");
95.         for (int i = 0; i < elements.size(); i++) {
96.             String id = elements.get(i);
97.             if (i > 0) {
98.                 sqlBuilder.append(",");
99.             }
100.             sqlBuilder.append("'");
101.             sqlBuilder.append(id);
102.             sqlBuilder.append("'");
103.         }
104.         sqlBuilder.append(")");
105.         return sqlBuilder.toString();
106.     }
108. }

复制代码

服务实现

2. /**
3. * @author: chenfuxing
4. * date: 2023/12/19
5. * description:
6. **/
7. @Service
8. @Slf4j
9. public class ReportDataGetServiceImpl implements IReportDataGetService {
10.     @Autowired
11.     private DataSource dataSource;
14.     /**
15.      * 执行SQL返回数据
16.      *
17.      * @param sql
18.      * @return
19.      */
20.     @Override
21.     public JSONObject getOne(String sql) {
22.         JSONObject ret = null;
23.         Connection connection = null;
24.         Statement statement = null;
25.         ResultSet resultSet = null;
26.         try {
27.             connection = dataSource.getConnection();
28.             statement = connection.createStatement();
29.             logSql(sql);
30.             resultSet = statement.executeQuery(sql);
31.             if (resultSet != null) {
32.                 while (resultSet.next()) {
33.                     if (ret != null) {
34.                         throw new RuntimeException("查询结果不止一条数据");
35.                     }
36.                     ret = new JSONObject();
37.                     ResultSetMetaData metaData = resultSet.getMetaData();
38.                     int columnCount = metaData.getColumnCount();
39.                     for (int i = 1; i <= columnCount; i++) {
40.                         String columnName = metaData.getColumnLabel(i);
41.                         ret.put(columnName, resultSet.getObject(columnName));
42.                     }
43.                 }
44.             }
45.         } catch (Exception e) {
46.             log.error("获取数据报错", e);
47.         } finally {
48.             // 释放资源
49.             IoUtil.close(resultSet);
50.             IoUtil.close(statement);
51.             IoUtil.close(connection);
52.         }
53.         return ret;
54.     }
56.     /**
57.      * 执行SQL返回数据
58.      *
59.      * @param sql
60.      * @return
61.      */
62.     @Override
63.     public JSONArray getList(String sql) {
64.         JSONArray ret = new JSONArray();
65.         Connection connection = null;
66.         Statement statement = null;
67.         ResultSet resultSet = null;
68.         try {
69.             connection = dataSource.getConnection();
70.             statement = connection.createStatement();
71.             logSql(sql);
72.             resultSet = statement.executeQuery(sql);
73.             if (resultSet != null) {
74.                 while (resultSet.next()) {
75.                     // 组装数据为json 对象
76.                     JSONObject data = new JSONObject();
77.                     ResultSetMetaData metaData = resultSet.getMetaData();
78.                     int columnCount = metaData.getColumnCount();
79.                     for (int i = 1; i <= columnCount; i++) {
80.                         String columnName = metaData.getColumnLabel(i);
81.                         data.put(columnName, resultSet.getObject(columnName));
82.                     }
83.                     ret.add(data);
84.                 }
85.             }
86.         } catch (Exception e) {
87.             log.error("获取数据报错", e);
88.         } finally {
89.             // 释放资源
90.             IoUtil.close(resultSet);
91.             IoUtil.close(statement);
92.             IoUtil.close(connection);
93.         }
94.         return ret;
95.     }
97.     private void logSql(String sql) {
98.         int len = 5000;
99.         // 执行SQL
100.         log.info("执行的SQL：{}", StrUtil.isNotBlank(sql) && sql.length() > len ? sql.substring(0, len) : sql);
101.     }
103.     /**
104.      * 计数
105.      *
106.      * @param sql
107.      * @return
108.      */
109.     @Override
110.     public long count(String sql) {
111.         String countSQL = getCountSqlFromQuerySql(sql);
112.         if (StrUtil.isBlank(countSQL)) {
113.             throw new RuntimeException("计数语句不得为空，SQL为：" + sql);
114.         }
115.         long ret = 0;
116.         Connection connection = null;
117.         Statement statement = null;
118.         ResultSet resultSet = null;
119.         try {
120.             connection = dataSource.getConnection();
121.             statement = connection.createStatement();
122.             logSql(sql);
123.             resultSet = statement.executeQuery(countSQL);
124.             if (resultSet != null) {
125.                 while (resultSet.next()) {
126.                     ret = resultSet.getLong(1);
127.                 }
128.             }
129.         } catch (Exception e) {
130.             log.error("获取数据报错", e);
131.         } finally {
132.             // 释放资源
133.             if (resultSet != null) {
134.                 try {
135.                     resultSet.close();
136.                 } catch (Exception ignored) {
137.                 }
138.             }
139.             if (statement != null) {
140.                 try {
141.                     statement.close();
142.                 } catch (Exception ignored) {
143.                 }
144.             }
145.             if (connection != null) {
146.                 try {
147.                     connection.close();
148.                 } catch (Exception ignored) {
149.                 }
150.             }
151.         }
152.         return ret;
153.     }
155.     /**
156.      * 从查询语句变计数语句
157.      *
158.      * @param sql
159.      * @return
160.      */
161.     public String getCountSqlFromQuerySql(String sql) {
162.         String selectStr = "select";
163.         int selectIndex = sql.indexOf(selectStr);
164.         int fromIndex = sql.indexOf("from");
165.         return sql.replace(sql.substring(selectIndex + selectStr.length(), fromIndex), " count(*) as c ");
166.     }
168.     /**
169.      * 分页查询
170.      *
171.      * @param sql
172.      * @param page
173.      * @param pageSize
174.      * @return
175.      */
176.     @Override
177.     public JSONArray pageGetList(String sql, int page, int pageSize) {
178.         String querySql = getPageSqlFromQuerySql(sql, page, pageSize);
179.         if (StrUtil.isBlank(querySql)) {
180.             throw new RuntimeException("分页查询解析失败，SQL：" + sql + " 页号: " + page + " 每页数量：" + pageSize);
181.         }
182.         return getList(querySql);
183.     }
185.     /**
186.      * 分页查询
187.      *
188.      * @param sql
189.      * @param page
190.      * @param pageSize
191.      * @return
192.      */
193.     @Override
194.     public JimuPageDto<JSONObject> pageGetListForJimu(String sql, int page, int pageSize) {
195.         JimuPageDto<JSONObject> jimuPageDto = new JimuPageDto<>();
196.         // 查count
197.         long count = count(sql);
198.         long total = count / pageSize + (count % pageSize > 0 ? 1 : 0);
199.         log.info("数据总条数：{} 条，每页：{} 条，总页数：{} 页", count, pageSize, total);
200.         jimuPageDto.setTotal(total);
201.         // 查分页数据
202.         JSONArray data = pageGetList(sql, page, pageSize);
203.         List<JSONObject> dataList = new ArrayList<>(data.size());
204.         for (int i = 0; i < data.size(); i++) {
205.             JSONObject jsonObject = data.getJSONObject(i);
206.             dataList.add(jsonObject);
207.         }
208.         jimuPageDto.setData(dataList);
209.         jimuPageDto.setCount(count);
210.         return jimuPageDto;
211.     }
213.     /**
214.      * 分页查询
215.      *
216.      * @param sql
217.      * @param page
218.      * @param pageSize
219.      * @return
220.      */
221.     public String getPageSqlFromQuerySql(String sql, int page, int pageSize) {
222.         Assert.isTrue(page >= 1, () -> new IllegalArgumentException("page不得小于1"));
223.         Assert.isTrue(pageSize >= 1, () -> new IllegalArgumentException("pageSize不得小于1"));
224.         int skip = (page - 1) * pageSize;
225.         StringBuilder builder = new StringBuilder(sql);
226.         builder.append(" limit ");
227.         if (skip > 0) {
228.             builder.append(skip);
229.             builder.append(",");
230.         }
231.         builder.append(pageSize);
232.         String querySql = builder.toString();
233.         log.info("分页查询原SQL：{}\n分页SQL处理后：{}", sql, querySql);
234.         return querySql;
235.     }
237.     /**
238.      * 执行SQL返回数据，数据封装到类cls对象里
239.      *
240.      * @param sql
241.      * @param cls
242.      * @return
243.      */
244.     @Override
245.     public Object getOne(String sql, Class cls) {
246.         return getOne(sql).toJavaObject(cls);
247.     }
249.     /**
250.      * 执行SQL返回数据，数据封装到类cls对象里
251.      *
252.      * @param sql
253.      * @param cls
254.      * @return
255.      */
256.     @Override
257.     public List getList(String sql, Class cls) {
258.         return getList(sql).toJavaList(cls);
259.     }
261.     /**
262.      * 分页查询
263.      *
264.      * @param sql
265.      * @param page
266.      * @param pageSize
267.      * @param cls
268.      * @return
269.      */
270.     @Override
271.     public JimuPageDto pageGetListForJimu(String sql, int page, int pageSize, Class cls) {
272.         JimuPageDto<JSONObject> jimuPageDto = pageGetListForJimu(sql, page, pageSize);
273.         JimuPageDto ret = new JimuPageDto<>();
274.         List list = new ArrayList(jimuPageDto.getData().size());
275.         for (int i = 0; i < jimuPageDto.getData().size(); i++) {
276.             list.add(jimuPageDto.getData().get(i).toJavaObject(cls));
277.         }
278.         ret.setData(list);
279.         ret.setTotal(jimuPageDto.getTotal());
280.         ret.setCount(jimuPageDto.getCount());
281.         return ret;
282.     }
285. }

复制代码

拦截切面

2. /**
3. * @author: humorchen
4. * date: 2024/1/15
5. * description: 下载任务切面
6. * 对加上了@UseDownloadTaskCenter注解的方法进行切面，使用下载任务中心代理掉，完成下载任务
7. **/
8. @Aspect
9. @Component
10. @Slf4j
11. public class DownloadTaskAspect {
12.     @Autowired
13.     private IDownloadTaskService downloadTaskService;
14.     /**
15.      * 注入spring 事件发布器
16.      */
17.     @Autowired
18.     private ApplicationEventPublisher eventPublisher;
22.     /**
23.      * 环绕通知
24.      *
25.      * @return
26.      */
27.     @Around("@annotation(cn.sffix.recovery.report.annotations.UseDownloadTaskCenter))")
28.     @Order(50)
29.     public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
30.         log.info("【下载中心】进入下载中心切面");
31.         // 是下载中心发的请求则直接执行分页数据
32.         if (DownloadCenterUtil.isDownloadCenterRequest()) {
33.             log.info("【下载中心】下载中心发的请求，直接执行分页数据");
34.             return joinPoint.proceed();
35.         }
37.         // 识别下载请求
38.         int pageNo = 1;
39.         int pageSize = 20;
40.         Object[] args = joinPoint.getArgs();
41.         if (args != null && args.length > 0) {
42.             DownloadCenterBaseParam downloadCenterBaseParam = null;
43.             // 找到参数
44.             for (Object arg : args) {
45.                 if (arg instanceof DownloadCenterBaseParam) {
46.                     downloadCenterBaseParam = (DownloadCenterBaseParam) arg;
47.                     break;
48.                 }
49.             }
50.             // 检查参数
51.             if (downloadCenterBaseParam != null) {
52.                 pageNo = Optional.ofNullable(downloadCenterBaseParam.getPageNo()).orElse(pageNo);
53.                 pageSize = Optional.ofNullable(downloadCenterBaseParam.getPageSize()).orElse(pageSize);
54.             }
55.             log.info("【下载中心】下载中心切面，downloadCenterBaseParam:{}", downloadCenterBaseParam);
56.             if (downloadCenterBaseParam != null) {
57.                 Object target = joinPoint.getTarget();
58.                 Method method = ((MethodSignature) joinPoint.getSignature()).getMethod();
59.                 Class<?> returnType = method.getReturnType();
60.                 // 返回值类型检查
61.                 if (returnType.equals(JimuPageDto.class)) {
62.                     // 如果是导出请求，则使用下载任务中心代理掉
63.                     if (isExportFirstPageRequest(pageNo, pageSize)) {
64.                         // 如果是导出第一页请求，则使用下载任务中心代理掉
65.                         DownloadTask downloadTask = registerTask(downloadCenterBaseParam, target, method, args);
67.                         if (downloadTask == null || downloadTask.getId() == null) {
68.                             log.error("【下载中心】注册下载任务失败，任务信息：{}", downloadTask);
69.                             return joinPoint.proceed();
70.                         }
71.                         log.info("【下载中心】注册下载任务成功，任务信息：{}", downloadTask);
72.                         // 返回积木所需要的数据
73.                         JimuPageDto<JSONObject> jimuPageDto = new JimuPageDto<>();
74.                         jimuPageDto.setTotal(0);
75.                         jimuPageDto.setCount(0);
76.                         JSONObject jsonObject = new JSONObject();
77.                         String downloadTaskJsonStr = downloadTask.getJson();
78.                         DownloadTaskJson downloadTaskJson = JSONObject.parseObject(downloadTaskJsonStr, DownloadTaskJson.class);
79.                         String requestBody = downloadTaskJson.getRequestBody();
80.                         String reportId = downloadTaskService.getReportIdFromRequestBody(requestBody);
81.                         List<JimuReportDataColumnDTO> reportHead = downloadTaskService.getReportHead(reportId);
82.                         log.info("【下载中心】reportHead:{}", reportHead);
83.                         if (CollectionUtil.isNotEmpty(reportHead) && reportHead.size() > 1) {
84.                             String column = reportHead.get(1).getColumn();
85.                             jsonObject.put(column, "请前往报表中台-下载中心查看（任务ID " + downloadTask.getId() + "）");
86.                             log.info("【下载中心】返回数据：{}", jsonObject);
87.                         } else {
88.                             log.info("【下载中心】返回数据为空");
89.                         }
90.                         List<JSONObject> list = Collections.singletonList(jsonObject);
91.                         jimuPageDto.setData(list);
92.                         eventPublisher.publishEvent(new DownloadTaskPublishEvent(downloadTask.getId()));
93.                         return jimuPageDto;
94.                     } else {
95.                         log.info("【下载中心】不是导出请求，直接执行分页数据");
96.                     }
97.                 } else {
98.                     log.error("【下载中心】返回值类型不是JimuPageDto，无法使用下载任务中心代理掉");
99.                 }
101.             }
103.         }
105.         return joinPoint.proceed();
106.     }
108.     /**
109.      * 生成下载任务
110.      *
111.      * @param downloadTaskParam
112.      * @return
113.      */
114.     private DownloadTask registerTask(DownloadCenterBaseParam downloadTaskParam, Object proxyTarget, Method method, Object[] args) {
115.         UserInfo loginUser = UserInfoHolder.get();
116.         String account = loginUser.getAccount();
117.         HttpServletRequest currentRequest = RequestUtil.getCurrentRequest();
118.         String requestBody = DownloadCenterUtil.getRequestBodyFromHeader(currentRequest);
120.         // 防止10秒内重复点击
121.         if (!downloadTaskService.setSameTaskLock(account, requestBody)) {
122.             log.error("【下载中心】10秒内重复点击，不给再次注册下载任务");
123.             return null;
124.         }
126.         String title = "导出-" + DateUtil.now().replace(" ", "_") + ".xlsx";
127.         try {
128.             title = downloadTaskService.getReportNameByReportId(downloadTaskService.getReportIdFromRequestBody(requestBody)) + title;
129.         } catch (Exception e) {
130.             log.error("【下载中心】获取报表名称失败", e);
131.         }
132.         String url = generateFileUrl();
133.         DownloadTask downloadTask = new DownloadTask();
134.         downloadTask.setAccount(account);
135.         downloadTask.setTitle(title);
136.         downloadTask.setIcon("");
137.         downloadTask.setUrl(url);
138.         downloadTask.setFileSize("");
139.         downloadTask.setPercent("0%");
140.         downloadTask.setState(DownloadTaskStateEnum.WAIT.getState());
141.         DownloadTaskJson downloadTaskJson = new DownloadTaskJson();
142.         // 拷贝最开始请求积木的token和requestBody，执行下载任务时需要
143.         downloadTaskJson.setRequestToken(DownloadCenterUtil.getRequestTokenFromHeader(currentRequest));
144.         downloadTaskJson.setRequestBody(requestBody);
145.         downloadTaskJson.setProxyMethod(method.getName());
146.         if (args != null) {
147.             for (Object arg : args) {
148.                 if (arg instanceof DownloadCenterBaseParam) {
149.                     downloadTaskJson.setParam((DownloadCenterBaseParam) arg);
150.                     break;
151.                 }
152.             }
153.         }
154.         downloadTask.setJson(JSONObject.toJSONString(downloadTaskJson));
156.         downloadTask = downloadTaskService.registerTask(downloadTask);
157.         return downloadTask;
158.     }
160.     /**
161.      * 生成文件url地址
162.      *
163.      * @return
164.      */
165.     private String generateFileUrl() {
166.         // todo 生成文件url地址
167.         return "";
168.     }
170.     /**
171.      * 注入jm report分页大小
172.      */
173.     @Value("${jeecg.jmreport.page-size-number:5000}")
174.     private int jmReportPageSizeNumber;
176.     /**
177.      * 判断是否为导出请求
178.      *
179.      * @param pageNo
180.      * @param pageSize
181.      * @return
182.      */
183.     private boolean isExportPageRequest(int pageNo, int pageSize) {
184.         return pageSize == jmReportPageSizeNumber;
185.     }
187.     /**
188.      * 判断是否为导出请求
189.      *
190.      * @param pageNo
191.      * @param pageSize
192.      * @return
193.      */
194.     private boolean isExportFirstPageRequest(int pageNo, int pageSize) {
195.         log.info("【下载中心】判断是否为导出请求 isExportFirstPageRequest pageNo:{},pageSize:{}，积木报表导出size：{}", pageNo, pageSize, jmReportPageSizeNumber);
196.         return pageNo == 1 && isExportPageRequest(pageNo, pageSize);
197.     }
198. }

复制代码

报表下载使命处理事件

   暂时由于导出项目只部署一个实例，导出使命使用的是spring 本地event来异步处理的，你可以使用MQ、调理来执行掉使命，可以参考我这个
上传华为云OSS的部分你更换为你的OSS上传操作，这个地方我是复用项目里已有的存储上传服务
内里的异步线程池、环境工具类、积木导出每页大小要设置本身的

1. /**
2. * @author: humorchen
3. * date: 2024/1/16
4. * description: 下载任务发布事件
5. **/
6. @Getter
7. public class DownloadTaskPublishEvent extends ApplicationEvent {
8.     /**
9.      * 任务ID
10.      */
11.     private final Integer taskId;
13.     public DownloadTaskPublishEvent(Integer taskId) {
14.         super(taskId);
15.         this.taskId = taskId;
16.     }
17.    
18. }

复制代码

处理器

2. /**
3. * @author: humorchen
4. * date: 2024/1/16
5. * description: 处理下载任务发布事件
6. **/
7. @Component
8. @Slf4j
9. public class DownloadTaskPublishEventHandler implements ApplicationListener<DownloadTaskPublishEvent> {
10.     @Autowired
11.     private IDownloadTaskService downloadTaskService;
12.     @Autowired
13.     private IReportService reportService;
14.     @Autowired
15.     @Qualifier(AsyncConfig.ASYNC_THREAD_POOL)
16.     private Executor executor;
18.     @Autowired
19.     private HwProperties hwProperties;
20.     @Autowired
21.     private EnvUtil envUtil;
23.     /**
24.      * 注入jm report分页大小
25.      */
26.     @Value("${jeecg.jmreport.page-size-number:5000}")
27.     private int jmReportPageSizeNumber;
29.     @Autowired
30.     private RedissonClient redissonClient;
33.     /**
34.      * 超时时间
35.      */
36.     private static final int TIMEOUT_MILLS = 1000 * 60 * 20;
38.     @Autowired
39.     private HwObjectStorageService hwObjectStorageService;
42.     /**
43.      * 上传文件到OSS的路径
44.      *
45.      * @param account
46.      * @param fileName
47.      * @return
48.      */
49.     private final StoragePath getStoragePath(String account, String fileName) {
50.         return StoragePath.path().addFolder("downloadTask").addFolder(account).fileName(fileName);
51.     }
53.     /**
54.      * Handle an application event.
55.      *
56.      * @param event the event to respond to
57.      */
58.     @Override
59.     @Async(AsyncConfig.ASYNC_THREAD_POOL)
60.     public void onApplicationEvent(DownloadTaskPublishEvent event) {
61.         Integer taskId = event.getTaskId();
63.         log.info("【下载中心】执行下载任务 taskId:{}", taskId);
64.         DownloadTask downloadTask = downloadTaskService.getById(taskId);
65.         if (downloadTask == null) {
66.             log.error("【下载中心】下载任务不存在，taskId:{}", taskId);
67.             return;
68.         }
69.         if (downloadTask.getState() == DownloadTaskStateEnum.RUNNING.getState()) {
70.             log.error("【下载中心】下载任务正在执行中，taskId:{}", taskId);
71.             return;
72.         }
74.         try {
75.             log.info("【下载中心】下载任务开始执行，taskId:{}", taskId);
76.             // 改状态到执行中
77.             DownloadTaskStateEnum downloadTaskStateEnum = Optional.ofNullable(DownloadTaskStateEnum.of(downloadTask.getState())).orElse(DownloadTaskStateEnum.WAIT);
78.             int compareAndSwapTaskState = downloadTaskService.compareAndSwapTaskState(taskId, downloadTaskStateEnum, DownloadTaskStateEnum.RUNNING);
79.             if (compareAndSwapTaskState < 1) {
80.                 log.info("【下载中心】下载任务状态不对，taskId:{}, state:{}", taskId, downloadTaskStateEnum);
81.                 return;
82.             }
83.             DownloadTaskJson downloadTaskJson = JSONObject.parseObject(downloadTask.getJson(), DownloadTaskJson.class);
85.             // 获取数据
86.             String requestBody = downloadTaskJson.getRequestBody();
87.             String requestToken = downloadTaskJson.getRequestToken();
88.             String reportId = downloadTaskService.getReportIdFromRequestBody(requestBody);
89.             String reportName = downloadTaskService.getReportNameByReportId(reportId);
90.             String requestParam = downloadTaskService.getRequestParamFromJson(downloadTask.getJson());
91.             JimuReportDataSourceDTO dataSourceDTO = downloadTaskService.getReportApiOrSqlByReportId(reportId);
92.             List<JimuReportDataColumnDTO> reportHead = downloadTaskService.getReportHead(reportId);
93.             // 打印上面拿到的数据
94.             log.info("reportId ：{} \n reportName：{} \n requestParam：{} \n requestBody:{}  \n dataSourceDTO：{} \n reportHead：{}", reportId, reportName, requestParam, requestBody, dataSourceDTO, reportHead);
95.             JimuReportDynamicEasyExcelImpl jimuReportDynamicEasyExcel = new JimuReportDynamicEasyExcelImpl(reportId, reportName, taskId, downloadTaskService, requestParam, requestToken, dataSourceDTO, reportHead);
96.             // 生成excel文件
97.             List<List<String>> head = reportHead.stream().map(d -> Collections.singletonList(d.getName())).collect(Collectors.toList());
98.             // 分页写数据
99.             InputStream inputStream = DynamicColumnEasyExcelUtil.writePageData(head, jimuReportDynamicEasyExcel, jmReportPageSizeNumber);
103.             // 上传excel文件到oss
104.             StoragePath storagePath = getStoragePath(downloadTask.getAccount(), downloadTask.getTitle());
105.             downloadTask.setPercent("100%");
106.             StopWatch stopWatch = new StopWatch();
107.             stopWatch.start();
108.             URI uri = hwObjectStorageService.savePublicFile(inputStream, storagePath);
109.             stopWatch.stop();
110.             log.info("【下载中心】上传文件到OSS，耗时：{} ms，uri：{}", stopWatch.getLastTaskTimeMillis(), uri);
111.             // 更新任务信息
112.             String url = getUrlPrefix() + uri.getPath();
113.             downloadTask.setUrl(url);
114.             downloadTask.setState(DownloadTaskStateEnum.SUCCESS.getState());
115.             log.info("【下载中心】下载任务成功，taskId:{}，task：{}", taskId, downloadTask);
116.             boolean updated = downloadTaskService.updateById(downloadTask);
117.             log.info("【下载中心】下载任务更新结果，taskId:{}, updated:{}", taskId, updated);
118.         } catch (Exception e) {
119.             log.error("【下载中心】下载任务执行失败", e);
120.             // 更新任务信息
121.             downloadTask.setState(DownloadTaskStateEnum.FAILED.getState());
122.             downloadTask.setError("【下载中心】执行失败（" + e.getMessage() + "）");
123.             boolean updated = downloadTaskService.updateById(downloadTask);
124.             log.info("【下载中心】下载任务更新结果，taskId:{}, updated:{}", taskId, updated);
125.         } finally {
126.             log.info("【下载中心】下载任务 {} 执行完毕", taskId);
127.         }
130.     }
132.     /**
133.      * 根据环境获取文件url前缀
134.      *
135.      * @return
136.      */
137.     private String getUrlPrefix() {
138.         String envCode = envUtil.isPreOrProdEnv() ? "pro" : "test";
139.         String prefix = "https://test-obs.xxxxx.com";
140.         for (String key : hwProperties.getUrlMap().keySet()) {
141.             if (key.contains(envCode)) {
142.                 prefix = hwProperties.getUrlMap().get(key);
143.             }
144.         }
145.         return prefix;
146.     }
148. }

复制代码

透传信息

紧张是在这个customApiHeader() 方法里DownloadCenterUtil.copyDownloadCenterHeader(request, header);自定义获取数据哀求的header这，读取这次积木导出哀求的参数信息，写到获取数据哀求的header里去

1. /**
2. * 自定义积木报表鉴权(如果不进行自定义，则所有请求不做权限控制)
3. * 1.自定义获取登录token
4. * 2.自定义获取登录用户
5. */
6. @Slf4j
7. @Component
8. public class JimuReportTokenService implements JmReportTokenServiceI {
10.     @Autowired
11.     @Lazy
12.     private UserAutenticationFeign userAutenticationFeign;
14.     @Autowired
15.     @Lazy
16.     private UserInfoFeign userInfoFeign;
18.     /**
19.      * 通过请求获取Token
20.      * @param request
21.      * @return
22.      */
23.     @Override
24.     public String getToken(HttpServletRequest request) {
25.         String token = request.getParameter("token");
26.         if (token == null) {
27.             token = request.getHeader("X-Access-Token");
28.         }
29.         if (token == null) {
30.             token = request.getHeader("token");
31.         }
32.         if (token == null) {
33.             token = request.getHeader("Token");
34.         }
35.         return token;
36.     }
38.     /**
39.      * 通过Token获取登录人用户名
40.      * @param token
41.      * @return
42.      */
43.     @Override
44.     public String getUsername(String token) {
45.         UserTokenDTO tokenInfo = new UserTokenDTO();
46.         tokenInfo.setToken(token);
47.         Result<CustomerInfoDTO> customerInfoDTOResult = userInfoFeign.customerInfo(tokenInfo);
48.         CustomerInfoDTO data = customerInfoDTOResult.getData();
49.         if(data != null){
50.             FxUserInfoDTO userInfo = JSONObject.parseObject(JSONObject.toJSONString(data.getBase()), FxUserInfoDTO.class);
51.             if(userInfo == null){
52.                 throw new RuntimeException("找不到相应平台用户信息");
53.             } else {
54.                 // 写到上下文
55.                 UserInfo user = new UserInfo();
56.                 BeanUtils.copyProperties(userInfo, user);
57.                 UserInfoHolder.set(user);
58.                 log.info("成功将用户信息写入上下文");
59.             }
60.             if(userInfo.getClientType() != PlatformTypeEnum.fx.name()){
61.                 return userInfo.getName();
62.             }else{
63.                 throw new RuntimeException("平台类型不支持");
64.             }
65.         }else {
66.             throw new RuntimeException("用户不存在");
67.         }
68.     }
70.     /**
71.      * 自定义用户拥有的角色
72.      *
73.      * @param token
74.      * @return
75.      */
76.     @Override
77.     public String[] getRoles(String token) {
78.         return new String[]{"admin"};
79.     }
81.     /**
82.      * Token校验
83.      * @param token
84.      * @return
85.      */
86.     @Override
87.     public Boolean verifyToken(String token) {
88.         ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
89.         HttpServletRequest request = requestAttributes.getRequest();
90.         request.setAttribute(UserAccountConstant.TOKEN,token);
91.         try {
92.             UserTokenDTO tokenInfo = new UserTokenDTO();
93.             tokenInfo.setToken(token);
94.             Result<CustomerInfoDTO> customerInfoDTOResult = userInfoFeign.customerInfo(tokenInfo);
96.             return customerInfoDTOResult.getData() != null;
97.         }catch (Exception e){
98.             log.error("校验Token异常:" + e.getMessage());
99.             return false;
100.         }
101.     }
103.     /**
104.      *  自定义请求头
105.      * @return
106.      */
107.     @Override
108.     public HttpHeaders customApiHeader() {
109.         ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
110.         HttpHeaders header = new HttpHeaders();
111.         header.add("custom-header1", "Please set a custom value 1");
112.         if (requestAttributes != null) {
113.             HttpServletRequest request = requestAttributes.getRequest();
114.             header.set("authorization", getToken(request));
115.             header.set("token", getToken(request));
116.             // 拷贝请求过去
117.             DownloadCenterUtil.copyDownloadCenterHeader(request, header);
118.             // 如果是下载中心发起的请求，设置请求头
119.             if (DownloadCenterUtil.isDownloadCenterRequest(requestAttributes.getRequest())) {
120.                 DownloadCenterUtil.setDownloadCenterHeaderRequest(header);
121.             }
122.         }
124.         return header;
125.     }
126. }

复制代码

下载中央工具类

2. /**
3. * @author: humorchen
4. * date: 2024/1/18
5. * description: 下载中心工具类
6. **/
7. @Slf4j
8. public class DownloadCenterUtil {
9.     private static final String DOWNLOAD_CENTER_HEADER_REQUEST = "download-center-request";
11.     /**
12.      * 是否为下载中心发起的请求
13.      *
14.      * @return
15.      */
16.     public static boolean isDownloadCenterRequest() {
17.         ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
18.         if (requestAttributes == null) {
19.             log.debug("DownloadCenterUtil#isDownloadCenterRequest requestAttributes is null");
20.             return false;
21.         }
22.         return isDownloadCenterRequest(requestAttributes.getRequest());
23.     }
25.     /**
26.      * 是否为下载中心发起的请求
27.      *
28.      * @param servletRequest
29.      * @return
30.      */
31.     public static boolean isDownloadCenterRequest(HttpServletRequest servletRequest) {
32.         return servletRequest != null && StrUtil.isNotBlank(servletRequest.getHeader(DOWNLOAD_CENTER_HEADER_REQUEST));
33.     }
35.     /**
36.      * 设置下载中心请求头
37.      *
38.      * @param headers
39.      */
40.     public static void setDownloadCenterHeaderRequest(HttpHeaders headers) {
41.         if (headers != null) {
42.             headers.set(DOWNLOAD_CENTER_HEADER_REQUEST, "true");
43.         }
44.     }
46.     /**
47.      * 复制下载中心请求头
48.      *
49.      * @param request
50.      * @param headers
51.      */
52.     public static void copyDownloadCenterHeader(HttpServletRequest request, HttpHeaders headers) {
53.         if (request == null || headers == null) {
54.             return;
55.         }
56.         // 复制request请求里的Token请求头
57.         String token = request.getHeader("Token");
58.         if (StrUtil.isNotBlank(token)) {
59.             headers.set(DownloadTaskJson.Fields.requestToken, token);
60.         }
61.         // 复制request请求里的请求体
62.         headers.set(DownloadTaskJson.Fields.requestBody, RequestUtil.getRequestBody(request));
63.     }
65.     /**
66.      * 获取下载请求头token
67.      *
68.      * @param request
69.      * @return
70.      */
71.     public static String getRequestTokenFromHeader(HttpServletRequest request) {
72.         if (request == null) {
73.             return null;
74.         }
75.         return request.getHeader(DownloadTaskJson.Fields.requestToken);
76.     }
78.     /**
79.      * 获取下载请求头
80.      *
81.      * @param request
82.      * @return
83.      */
84.     public static String getRequestBodyFromHeader(HttpServletRequest request) {
85.         if (request == null) {
86.             return null;
87.         }
88.         return request.getHeader(DownloadTaskJson.Fields.requestBody);
89.     }
90.     /**
91.      * 设置下载中心请求头
92.      *
93.      * @param request
94.      */
95.     public static void setDownloadCenterHeaderRequest(HttpRequest request) {
96.         if (request != null) {
97.             request.header(DOWNLOAD_CENTER_HEADER_REQUEST, "true");
98.         }
99.     }
102.     /**
103.      * 获取带参数的url
104.      *
105.      * @param url
106.      * @param params
107.      * @return
108.      */
109.     public static String getUrlWithParams(String url, JSONObject params) {
110.         if (StrUtil.isBlank(url) || params == null) {
111.             return url;
112.         }
113.         StringBuilder sb = new StringBuilder(url);
114.         if (url.contains("?")) {
115.             sb.append("&");
116.         } else {
117.             sb.append("?");
118.         }
119.         for (String key : params.keySet()) {
120.             sb.append(key).append("=").append(params.getString(key)).append("&");
121.         }
122.         return sb.substring(0, sb.length() - 1);
123.     }
125. }

复制代码

异步线程池

1. /**
2. * @author: humorchen
3. * date: 2024/1/16
4. * description: 异步配置
5. **/
6. @Slf4j
7. @Configuration
8. public class AsyncConfig {
9.     public static final String ASYNC_THREAD_POOL = "asyncThreadPool";
11.     /**
12.      * 异步线程池
13.      */
14.     @Bean(name = ASYNC_THREAD_POOL)
15.     public Executor asyncExecutor() {
16.         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
17.         executor.setCorePoolSize(8);
18.         executor.setMaxPoolSize(64);
19.         executor.setQueueCapacity(128);
20.         executor.setThreadNamePrefix("asyncThreadPool-");
21.         executor.initialize();
22.         return executor;
24.     }
25. }

复制代码

给前端袒露接口

1. /**
2. * @author humorchen
3. * date: 2024/2/28
4. * description: 下载中心API
5. **/
7. @RequestMapping("/report/form/downloadCenter")
8. public interface DownloadCenterApi {
11.     /**
12.      * 分页查下载任务
13.      *
14.      * @param pageListDownloadTaskDto
15.      * @return
16.      */
17.     @RequestMapping("/pageListDownloadTask")
18.     Result<IPage<DownloadTaskVo>> pageListDownloadTask(PageListDownloadTaskDto pageListDownloadTaskDto);
21.     /**
22.      * 删除下载任务
23.      *
24.      * @param taskId
25.      * @return
26.      */
27.     @RequestMapping("/deleteTask")
28.     Result<String> deleteTask(Integer taskId);
30.     /**
31.      * 重新执行下载任务
32.      *
33.      * @param taskId
34.      * @return
35.      */
36.     @RequestMapping("/rerunTask")
37.     Result<String> rerunTask(Integer taskId);
38. }

复制代码

2. /**
3. * @author humorchen
4. * date: 2024/2/28
5. * description: 下载中心
6. **/
7. @RestController
8. public class DownloadCenterController implements DownloadCenterApi {
9.     @Autowired
10.     private IDownloadTaskService downloadTaskService;
13.     /**
14.      * 分页查下载任务
15.      *
16.      * @param pageListDownloadTaskDto
17.      * @return
18.      */
19.     @Override
20.     public Result<IPage<DownloadTaskVo>> pageListDownloadTask(PageListDownloadTaskDto pageListDownloadTaskDto) {
21.         IPage<DownloadTask> downloadTaskPages = downloadTaskService.pageListDownloadTask(pageListDownloadTaskDto);
22.         Page<DownloadTaskVo> downloadTaskVoPage = new Page<>();
23.         downloadTaskVoPage.setCurrent(downloadTaskPages.getCurrent());
24.         downloadTaskVoPage.setPages(downloadTaskPages.getPages());
25.         downloadTaskVoPage.setSize(downloadTaskPages.getSize());
26.         downloadTaskVoPage.setTotal(downloadTaskPages.getTotal());
27.         List<DownloadTaskVo> downloadTaskVos = downloadTaskPages.getRecords().stream().map(downloadTask -> {
28.             DownloadTaskVo downloadTaskVo = BeanUtils.convert(downloadTask, DownloadTaskVo.class);
29.             downloadTaskVo.setStateStr(Optional.ofNullable(DownloadTaskStateEnum.of(downloadTask.getState())).orElse(DownloadTaskStateEnum.WAIT).getTitle());
30.             return downloadTaskVo;
31.         }).collect(Collectors.toList());
32.         downloadTaskVoPage.setRecords(downloadTaskVos);
34.         return Result.ok(downloadTaskVoPage);
35.     }
37.     /**
38.      * 删除下载任务
39.      *
40.      * @param taskId
41.      * @return
42.      */
43.     @Override
44.     public Result<String> deleteTask(Integer taskId) {
45.         boolean removeById = downloadTaskService.removeById(taskId);
47.         return removeById ? Result.ok("删除成功") : Result.fail("未找到该任务，请刷新后重试）");
48.     }
50.     /**
51.      * 重新执行下载任务
52.      *
53.      * @param taskId
54.      * @return
55.      */
56.     @Override
57.     public Result<String> rerunTask(Integer taskId) {
58.         return downloadTaskService.rerunTask(taskId);
59.     }
60. }

复制代码

DynamicColumnEasyExcelUtil 动态字段EasyExcel工具

2. /**
3. * @author humorchen
4. * date: 2024/3/5
5. * description: 动态列easyexcel工具类
6. **/
7. @Slf4j
8. public class DynamicColumnEasyExcelUtil {
9.     public static final String ROW = "=row()";
10.     public static interface DynamicColumnEasyExcelInterface<T> {
11.         /**
12.          * 分页获取数据
13.          *
14.          * @param page
15.          * @param size
16.          * @return
17.          */
18.         JimuPageDto<T> pageGetData(int page, int size);
20.         /**
21.          * 数据对象转换为字符串
22.          *
23.          * @param t
24.          * @return
25.          */
26.         List<String> mapDataToStringList(T t);
28.         /**
29.          * 分页获取数据加载第i页时触发函数，用于实现进度变更
30.          *
31.          * @param pageNo
32.          * @param pageSize
33.          */
34.         void onLoadedPage(int pageNo, int pageSize, int pages);
35.     }
36. /**
37.      * 从数据库分页读数据并写入成Excel文件，把文件内容写到输出流
38.      *
39.      * @param head
40.      * @param dynamicColumnEasyExcelInterface
41.      * @param pageSize
42.      * @param <T>
43.      * @return
44.      */
45.     public static <T> ByteArrayInputStream writePageData(List<List<String>> head, DynamicColumnEasyExcelInterface<T> dynamicColumnEasyExcelInterface, int pageSize) {
46.         ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
47.         ExcelWriter excelWriter = EasyExcel.write(outputStream).head(head).build();
48.         // 当前分页
49.         int currentPage = 1;
50.         // 总页数
51.         long pages = 1;
52.         // 当前写入的sheet页
53.         int sheetNo = 1;
54.         // 写入计数（用于自动翻sheet页）
55.         int writeRowCount = 0;
56.         // 积木序号编号
57.         int index = 1;
58.         StopWatch stopWatch = new StopWatch("报表分页写入Excel");
59.         WriteSheet sheet = getWriteSheet(sheetNo);
61.         do {
62.             // 加载数据
63.             stopWatch.start("加载第" + currentPage + "页数据");
64.             JimuPageDto<T> jimuPageDto = dynamicColumnEasyExcelInterface.pageGetData(currentPage, pageSize);
65.             stopWatch.stop();
66.             // 数据判空
67.             List<T> records = jimuPageDto.getData();
68.             if (CollectionUtil.isEmpty(records)) {
69.                 break;
70.             }
71.             // 转换数据
72.             stopWatch.start("转换第" + currentPage + "页数据");
73.             List<List<String>> data = records.stream().map(dynamicColumnEasyExcelInterface::mapDataToStringList).collect(Collectors.toList());
74.             stopWatch.stop();
75.             // 处理序号 row()
76.             if (CollectionUtil.isNotEmpty(data) && CollectionUtil.isNotEmpty(data.get(0)) && ROW.equals(data.get(0).get(0))) {
77.                 for (List<String> stringList : data) {
78.                     if (CollectionUtil.isNotEmpty(stringList) && ROW.equals(stringList.get(0))) {
79.                         stringList.set(0, String.valueOf(index));
80.                         ++index;
81.                     }
82.                 }
83.             }
84.             // 自动跳sheet页
85.             if (writeRowCount + data.size() >= MAX_SIZE_PER_SHEET) {
86.                 ++sheetNo;
87.                 writeRowCount = 0;
88.                 index = 1;
89.                 sheet = getWriteSheet(sheetNo);
90.             }
91.             // 写入数据
92.             stopWatch.start("写入第" + currentPage + "页数据（" + data.size() + "条数据）");
93.             excelWriter.write(data, sheet);
94.             stopWatch.stop();
96.             pages = jimuPageDto.getTotal();
97.             // 更新进度
98.             dynamicColumnEasyExcelInterface.onLoadedPage(currentPage, pageSize, (int) pages);
100.             log.info("【下载中心】 分页获取数据，第{}页，总页数：{} 第一行数据是：{}", currentPage, pages, data.get(0));
101.             // 自增
102.             currentPage++;
103.             writeRowCount += data.size();
104.         } while (currentPage <= pages);
105.         log.info("【下载中心】 耗时打印");
106.         for (StopWatch.TaskInfo taskInfo : stopWatch.getTaskInfo()) {
107.             log.info("【下载中心】 {} 耗时：{} ms", taskInfo.getTaskName(), taskInfo.getTimeMillis());
108.         }
109.         excelWriter.finish();
112.         return new ByteArrayInputStream(outputStream.toByteArray());
113.     }
115.     /**
116.      * 生成WriteSheet对象
117.      *
118.      * @param sheetNo 1开始
119.      * @return WriteSheet
120.      */
122.     private static WriteSheet getWriteSheet(int sheetNo) {
123.         WriteSheet sheet = new WriteSheet();
124.         sheet.setSheetName("sheet" + sheetNo);
125.         sheet.setSheetNo(sheetNo - 1);
126.         return sheet;
127.     }
128.     /**
129.      * 获取字段宽度策略
130.      *
131.      * @return
132.      */
133.     private AbstractHeadColumnWidthStyleStrategy getAbstractColumnWidthStyleStrategy() {
134.         return new AbstractHeadColumnWidthStyleStrategy() {
135.             /**
136.              * Returns the column width corresponding to each column head.
137.              *
138.              * <p>
139.              * if return null, ignore
140.              *
141.              * @param head        Nullable.
142.              * @param columnIndex Not null.
143.              * @return
144.              */
145.             @Override
146.             protected Integer columnWidth(Head head, Integer columnIndex) {
147.                 return null;
148.             }
149.         };
150.     }
152. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。