Compare commits

...

50 Commits

Author SHA1 Message Date
FCL
8ce0a52046 Merge branch 'refs/heads/zt-test' into test 2026-02-04 11:25:07 +08:00
ranke
da77f92523 Merge branch 'dev-klw' into test
* dev-klw:
  清理与ztcloud中重复的代码,改为 jar 包方式引用 ztcloud

# Conflicts:
#	zt-module-system/zt-module-system-api/src/main/java/com/zt/plat/module/system/api/sms/dto/send/SmsSendSingleToUserReqDTO.java
#	zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/controller/admin/sms/SmsCallbackController.java
#	zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/mq/message/sms/SmsSendMessage.java
2026-02-03 16:18:37 +08:00
ranke
4d997d9b86 清理与ztcloud中重复的代码,改为 jar 包方式引用 ztcloud 2026-02-03 15:23:43 +08:00
chenbowen
f1bafb98f6 Merge branch 'dev' into test 2026-02-03 09:35:55 +08:00
chenbowen
47e2529b2b Merge remote-tracking branch 'base-version/test' into dev 2026-02-03 09:35:39 +08:00
ranke
5f43006ee2 新增监听器的demo 2026-02-03 09:30:37 +08:00
chenbowen
1a5959a7e1 Merge branch 'dev' into test 2026-02-02 18:40:01 +08:00
chenbowen
351e4ab1ae 新增计划定额服务路由 2026-02-02 18:39:26 +08:00
chenbowen
634a84f8b8 Merge branch 'dev' into test 2026-02-02 18:16:13 +08:00
chenbowen
edb1a0f8ed 新增计划定额服务路由 2026-02-02 18:15:49 +08:00
朝锦 杨
7a8291992c Merge branch 'dev' into 'test'
重写手动针对用户以及组织的单条同步逻辑

See merge request jygk/dsc!29
2026-02-02 08:36:22 +00:00
yangchaojin
b689dd7741 Merge remote-tracking branch 'ztcloud/test' into dev
# Conflicts:
#	zt-framework/zt-spring-boot-starter-biz-data-permission/src/main/java/com/zt/plat/framework/datapermission/core/rule/dept/DeptDataPermissionRule.java
2026-02-02 16:34:03 +08:00
chenbowen
1a9e602ce7 删除用户不再限制 dept 数据权限 2026-02-02 16:20:39 +08:00
yangchaojin
8a27141edc 添加前端加密文件预览支持 2026-02-02 16:00:07 +08:00
chenbowen
c4aff51c36 Merge branch 'dev' into test 2026-02-02 11:57:56 +08:00
chenbowen
34bfe041e8 重写手动针对用户以及组织的单条同步逻辑
登录获取 token 时新增客户端编号标识
支持根据客户端编号以及用户id批量失效 token 方法
2026-02-02 11:57:26 +08:00
ranke
394e6b6bbb 解决Bean冲突 2026-02-02 11:25:01 +08:00
chenbowen
2e47c66fda 修复用户下其他 schema 包含同名 flowable 表无法启动 bpm 服务的错误 2026-01-30 16:02:48 +08:00
wuzongyong
42c01dc0a4 docs(iwork): 添加用印流程集成开发文档
- 新增完整的 iWork 用印流程集成开发文档
- 包含整体架构图和完整流程时序图
- 详细说明数据库设计和状态流转机制
- 提供 API 接口说明和请求参数定义
- 描述 MQ 消息机制和消息格式定义
- 编写业务模块接入指南和消费者实现示例
- 说明重试机制配置和手工重试接口
- 提供本地开发调试和常见问题解决方案
- 列出相关代码位置便于查阅和维护
2026-01-30 10:12:45 +08:00
wuzongyong
399875bc77 feat(iwork): 合并流程创建日志和回调日志(iwork统一用印内容)
- 将原 iwork_workflow_log.sql 重命名为 iwork_workflow_log_20260130.sql
- 在数据库表中新增回调状态、重试次数、错误信息等字段
- 更新表注释为 iWork 流程日志,表明合并了创建日志和回调日志
- 修改 requestId 字段长度从 64 扩展到 128
- 新增回调相关索引配置
- 删除 IWorkCallbackLogService 相关接口及实现类
- 将 IWorkBizCallbackListener 中的日志服务替换为工作流日志服务
- 在控制器层将回调日志查询统一到工作流日志服务
- 合并 IWorkIntegrationServiceImpl 中的流程日志处理逻辑
- 移除独立的用印流程回调日志实体类 IWorkSealLogDO
- 在 IWorkWorkflowLogDO 中增加回调相关字段定义
- 完善工作流日志服务接口和实现类,支持回调状态管理
- 更新流程回调处理逻辑,统一使用工作流日志表进行状态跟踪
2026-01-30 10:07:41 +08:00
wuzongyong
bcdba608c7 feat(iwork): 合并流程创建日志和回调日志(iwork统一用印内容)
- 将原 iwork_workflow_log.sql 重命名为 iwork_workflow_log_20260130.sql
- 在数据库表中新增回调状态、重试次数、错误信息等字段
- 更新表注释为 iWork 流程日志,表明合并了创建日志和回调日志
- 修改 requestId 字段长度从 64 扩展到 128
- 新增回调相关索引配置
- 删除 IWorkCallbackLogService 相关接口及实现类
- 将 IWorkBizCallbackListener 中的日志服务替换为工作流日志服务
- 在控制器层将回调日志查询统一到工作流日志服务
- 合并 IWorkIntegrationServiceImpl 中的流程日志处理逻辑
- 移除独立的用印流程回调日志实体类 IWorkSealLogDO
- 在 IWorkWorkflowLogDO 中增加回调相关字段定义
- 完善工作流日志服务接口和实现类,支持回调状态管理
- 更新流程回调处理逻辑,统一使用工作流日志表进行状态跟踪
2026-01-30 10:06:45 +08:00
ranke
860f13914d bpm加入maven管理 2026-01-29 18:53:43 +08:00
ranke
24352b34db ztcloud-dist 中 bpm 覆盖回来,包含 http://172.16.46.63:31560/index.php?m=task&f=view&taskID=735http://172.16.46.63:31560/index.php?m=task&f=view&taskID=552 中的修复 2026-01-29 18:53:35 +08:00
ranke
df2b0f52e3 no message 2026-01-29 18:53:22 +08:00
ranke
61d85988fc 修复数据总线访问日志无法显示状态码问题: http://172.16.46.63:31560/index.php?m=task&f=view&taskID=703. databus 新增 client 统一出口内容管理审计: http://172.16.46.63:31560/index.php?m=task&f=view&taskID=716 2026-01-29 18:51:48 +08:00
ranke
6b3bc5d18e userId改为 workcode , 修复数据权限的问题. http://172.16.46.63:31560/index.php?m=task&f=view&taskID=715 2026-01-29 18:51:20 +08:00
chenbowen
5f55c90e1b 重写手动针对用户以及组织的单条同步逻辑
登录获取 token 时新增客户端编号标识
支持根据客户端编号以及用户id批量失效 token 方法
2026-01-29 18:28:00 +08:00
ranke
b94fcd17ac bpm加入maven管理 2026-01-29 18:15:57 +08:00
ranke
c8cc9a9cb4 ztcloud-dist 中 bpm 覆盖回来,包含 http://172.16.46.63:31560/index.php?m=task&f=view&taskID=735http://172.16.46.63:31560/index.php?m=task&f=view&taskID=552 中的修复 2026-01-29 18:07:49 +08:00
朝锦 杨
2b2460a143 Merge branch 'dev' into 'test'
Dev

See merge request jygk/dsc!28
2026-01-29 09:39:08 +00:00
yangchaojin
ee4645dce3 Merge remote-tracking branch 'ztcloud/test' into dev 2026-01-29 17:27:14 +08:00
yangchaojin
4da9bd6cc5 修复kkfile预览加密文件问题、修改文件下载验证码发送模板 2026-01-29 17:26:35 +08:00
朝锦 杨
687d392392 Merge branch 'dev' into 'test'
feat(iwork): 添加工作流创建操作中operatorUserId字段验证

See merge request jygk/dsc!27
2026-01-29 07:39:54 +00:00
yangchaojin
c852d9f111 Merge remote-tracking branch 'ztcloud/test' into dev 2026-01-29 15:38:43 +08:00
yangchaojin
cabd6e3297 修复测试环境多级代理路劲拼接问题 2026-01-29 15:38:07 +08:00
wuzongyong
2af0f178dc feat(iwork): 添加工作流创建操作中operatorUserId字段验证
- 在createWorkflow方法中添加operatorUserId必填字段检查
- 在createGenericWorkflow方法中添加operatorUserId必填字段检查
- 当operatorUserId为空时抛出IWORK_SEAL_REQUIRED_FIELD_MISSING异常
- 优化createGenericWorkflow中operatorUserId参数传递逻辑
2026-01-29 15:26:59 +08:00
wuzongyong
f91d2d05e8 feat(iwork): 添加工作流创建操作中operatorUserId字段验证
- 在createWorkflow方法中添加operatorUserId必填字段检查
- 在createGenericWorkflow方法中添加operatorUserId必填字段检查
- 当operatorUserId为空时抛出IWORK_SEAL_REQUIRED_FIELD_MISSING异常
- 优化createGenericWorkflow中operatorUserId参数传递逻辑
2026-01-29 15:26:25 +08:00
朝锦 杨
947e1cc891 Merge branch 'dev' into 'test'
feat(iwork): 扩展iWork集成功能支持通用流程创建和回调处理

See merge request jygk/dsc!26
2026-01-29 07:10:59 +00:00
yangchaojin
e2a3280b70 Merge remote-tracking branch 'ztcloud/test' into dev 2026-01-29 15:09:44 +08:00
yangchaojin
9f622d460f 添加测试环境调试信息 2026-01-29 15:08:08 +08:00
wuzongyong
0fd7756d17 feat(iwork): 扩展iWork集成功能支持通用流程创建和回调处理
- 添加通用流程创建接口支持透传任意业务参数
- 实现流程创建日志记录功能包括requestId、workflowId等关键信息
- 增强文件回调处理记录日志并发送MQ通知业务系统
- 添加iWork业务回调消息测试消费者用于验证回调机制
- 在模板模块合同详情中增加业务附件列表展示功能
- 更新应用配置忽略缓存新增iWork印章日志表配置项
2026-01-29 14:54:59 +08:00
chenbowen
891bfad529 Merge branch 'dev' into test 2026-01-29 14:53:49 +08:00
wuzongyong
958ae5a519 feat(iwork): 扩展iWork集成功能支持通用流程创建和回调处理
- 添加通用流程创建接口支持透传任意业务参数
- 实现流程创建日志记录功能包括requestId、workflowId等关键信息
- 增强文件回调处理记录日志并发送MQ通知业务系统
- 添加iWork业务回调消息测试消费者用于验证回调机制
- 在模板模块合同详情中增加业务附件列表展示功能
- 更新应用配置忽略缓存新增iWork印章日志表配置项
2026-01-29 14:53:18 +08:00
chenbowen
b02ed67fa4 Merge remote-tracking branch 'base-version/test' into dev 2026-01-29 14:52:57 +08:00
chenbowen
9e98fa8c23 重写手动针对用户以及组织的单条同步逻辑
登录获取 token 时新增客户端编号标识
支持根据客户端编号以及用户id批量失效 token 方法
2026-01-29 14:51:32 +08:00
朝锦 杨
d7a6be298d Merge branch 'dev' into 'test'
Dev

See merge request jygk/dsc!25
2026-01-29 02:44:09 +00:00
yangchaojin
b2d29a1423 Merge remote-tracking branch 'ztcloud/test' into dev 2026-01-29 10:43:20 +08:00
yangchaojin
58df702cef 日志输出预览地址 2026-01-29 10:42:37 +08:00
chenbowen
d15dabfeac 1. 修改 iwork 用户同步逻辑,不对非 iwork 来源的关联关系进行覆盖,不覆盖已关联的岗位信息 2026-01-29 09:22:30 +08:00
ranke
396b26225f 新增根据用户id查询是否超级管理员的接口 2026-01-29 09:20:23 +08:00
3407 changed files with 829 additions and 259881 deletions

File diff suppressed because it is too large Load Diff

23
pom.xml
View File

@@ -4,28 +4,19 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>com.zt.plat</groupId> <groupId>com.zt.plat</groupId>
<artifactId>zt</artifactId> <artifactId>zt-dsc</artifactId>
<version>${revision}</version> <version>${revision}</version>
<packaging>pom</packaging> <packaging>pom</packaging>
<modules> <modules>
<module>zt-dependencies</module>
<module>zt-gateway</module> <module>zt-gateway</module>
<module>zt-framework</module> <module>zt-framework-dsc</module>
<!-- Server 主项目 -->
<!-- <module>zt-server</module>-->
<!-- 各种 module 拓展 -->
<module>zt-module-system</module> <module>zt-module-system</module>
<module>zt-module-infra</module> <module>zt-module-infra</module>
<!-- <module>zt-module-bpm</module>--> <module>zt-module-bpm</module>
<module>zt-module-report</module> <module>zt-module-report</module>
<!--<module>zt-module-mp</module>-->
<!-- <module>zt-module-ai</module>-->
<module>zt-module-template</module> <module>zt-module-template</module>
<!-- <module>zt-module-iot</module>-->
<module>zt-module-databus</module> <module>zt-module-databus</module>
<!-- <module>zt-module-rule</module>--> <module>zt-server</module>
<!-- <module>zt-module-html2pdf</module>-->
<!-- <module>zt-server</module>-->
</modules> </modules>
<name>${project.artifactId}</name> <name>${project.artifactId}</name>
@@ -57,6 +48,12 @@
<type>pom</type> <type>pom</type>
<scope>import</scope> <scope>import</scope>
</dependency> </dependency>
<dependency>
<groupId>com.zt.plat</groupId>
<artifactId>zt-common-dsc</artifactId>
<version>${revision}</version>
</dependency>
</dependencies> </dependencies>
</dependencyManagement> </dependencyManagement>

View File

@@ -0,0 +1,53 @@
-- iWork 流程日志表(达梦数据库)
-- 合并了流程创建日志和回调日志
CREATE TABLE system_iwork_workflow_log (
id BIGINT NOT NULL,
request_id VARCHAR(128) NOT NULL,
workflow_id BIGINT,
business_code VARCHAR(128),
biz_callback_key VARCHAR(255),
raw_request VARCHAR(2000),
status VARCHAR(32),
callback_status INTEGER,
retry_count INTEGER DEFAULT 0,
max_retry INTEGER,
last_error_message VARCHAR(512),
raw_callback VARCHAR(2000),
last_callback_time TIMESTAMP,
creator VARCHAR(64) DEFAULT '',
create_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
updater VARCHAR(64) DEFAULT '',
update_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
deleted SMALLINT NOT NULL DEFAULT 0,
tenant_id BIGINT NOT NULL DEFAULT 0,
PRIMARY KEY (id)
);
-- 添加注释
COMMENT ON TABLE system_iwork_workflow_log IS 'iWork 流程日志';
COMMENT ON COLUMN system_iwork_workflow_log.id IS '主键';
COMMENT ON COLUMN system_iwork_workflow_log.request_id IS 'iWork 请求编号';
COMMENT ON COLUMN system_iwork_workflow_log.workflow_id IS '流程模板 ID';
COMMENT ON COLUMN system_iwork_workflow_log.business_code IS '业务编码';
COMMENT ON COLUMN system_iwork_workflow_log.biz_callback_key IS '业务回调标识';
COMMENT ON COLUMN system_iwork_workflow_log.raw_request IS '创建请求原文';
COMMENT ON COLUMN system_iwork_workflow_log.status IS '流程状态';
COMMENT ON COLUMN system_iwork_workflow_log.callback_status IS '回调处理状态';
COMMENT ON COLUMN system_iwork_workflow_log.retry_count IS '已重试次数';
COMMENT ON COLUMN system_iwork_workflow_log.max_retry IS '最大重试次数';
COMMENT ON COLUMN system_iwork_workflow_log.last_error_message IS '最后错误信息';
COMMENT ON COLUMN system_iwork_workflow_log.raw_callback IS '回调原文';
COMMENT ON COLUMN system_iwork_workflow_log.last_callback_time IS '最近回调时间';
COMMENT ON COLUMN system_iwork_workflow_log.creator IS '创建者';
COMMENT ON COLUMN system_iwork_workflow_log.create_time IS '创建时间';
COMMENT ON COLUMN system_iwork_workflow_log.updater IS '更新者';
COMMENT ON COLUMN system_iwork_workflow_log.update_time IS '更新时间';
COMMENT ON COLUMN system_iwork_workflow_log.deleted IS '是否删除';
COMMENT ON COLUMN system_iwork_workflow_log.tenant_id IS '租户编号';
-- 创建唯一索引
CREATE UNIQUE INDEX uk_iwork_workflow_log_request_id ON system_iwork_workflow_log(request_id);
-- 创建普通索引
-- CREATE INDEX idx_iwork_workflow_log_business_code ON system_iwork_workflow_log(business_code);
-- CREATE INDEX idx_iwork_workflow_log_biz_callback_key ON system_iwork_workflow_log(biz_callback_key);

View File

@@ -1,43 +0,0 @@
-- iWork 用印回调日志DM8
-- 表system_iwork_seal_log
-- 序列system_iwork_seal_log_seq
-- 清理旧对象(若存在)
DROP TABLE IF EXISTS system_iwork_seal_log;
CREATE TABLE system_iwork_seal_log (
id BIGINT NOT NULL,
request_id VARCHAR(128) NOT NULL,
business_code VARCHAR(128),
biz_callback_key VARCHAR(255),
status INTEGER,
retry_count INTEGER DEFAULT 0,
max_retry INTEGER,
last_error_message VARCHAR(512),
raw_callback VARCHAR(2000),
last_callback_time DATETIME,
creator VARCHAR(64),
create_time DATETIME DEFAULT SYSDATE,
updater VARCHAR(64),
update_time DATETIME DEFAULT SYSDATE,
deleted SMALLINT DEFAULT 0 NOT NULL,
PRIMARY KEY (id),
UNIQUE (request_id)
);
COMMENT ON TABLE system_iwork_seal_log IS 'iWork 用印回调日志';
COMMENT ON COLUMN system_iwork_seal_log.id IS '主键';
COMMENT ON COLUMN system_iwork_seal_log.request_id IS 'iWork requestId 唯一标识';
COMMENT ON COLUMN system_iwork_seal_log.business_code IS '业务单号';
COMMENT ON COLUMN system_iwork_seal_log.biz_callback_key IS '业务回调标识';
COMMENT ON COLUMN system_iwork_seal_log.status IS '状态枚举';
COMMENT ON COLUMN system_iwork_seal_log.retry_count IS '已重试次数';
COMMENT ON COLUMN system_iwork_seal_log.max_retry IS '最大重试次数快照';
COMMENT ON COLUMN system_iwork_seal_log.last_error_message IS '最后错误信息';
COMMENT ON COLUMN system_iwork_seal_log.raw_callback IS '回调原文截断';
COMMENT ON COLUMN system_iwork_seal_log.last_callback_time IS '最近回调时间';
COMMENT ON COLUMN system_iwork_seal_log.creator IS '创建者';
COMMENT ON COLUMN system_iwork_seal_log.create_time IS '创建时间';
COMMENT ON COLUMN system_iwork_seal_log.updater IS '更新者';
COMMENT ON COLUMN system_iwork_seal_log.update_time IS '最后更新时间';
COMMENT ON COLUMN system_iwork_seal_log.deleted IS '是否删除';

File diff suppressed because it is too large Load Diff

29
zt-framework-dsc/pom.xml Normal file
View File

@@ -0,0 +1,29 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<artifactId>zt-dsc</artifactId>
<groupId>com.zt.plat</groupId>
<version>${revision}</version>
</parent>
<packaging>pom</packaging>
<modules>
<module>zt-common-dsc</module>
</modules>
<artifactId>zt-framework-dsc</artifactId>
<description>
该包是技术组件,每个子包,代表一个组件。每个组件包括两部分:
1. core 包:是该组件的核心封装
2. config 包:是该组件基于 Spring 的配置
技术组件,也分成两类:
1. 框架组件:和我们熟悉的 MyBatis、Redis 等等的拓展
2. 业务组件:和业务相关的组件的封装,例如说数据字典、操作日志等等。
如果是业务组件Maven 名字会包含 biz
</description>
<url>https://github.com/YunaiV/ruoyi-vue-pro</url>
</project>

View File

@@ -4,11 +4,11 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent> <parent>
<groupId>com.zt.plat</groupId> <groupId>com.zt.plat</groupId>
<artifactId>zt-framework</artifactId> <artifactId>zt-framework-dsc</artifactId>
<version>${revision}</version> <version>${revision}</version>
</parent> </parent>
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<artifactId>zt-common</artifactId> <artifactId>zt-common-dsc</artifactId>
<packaging>jar</packaging> <packaging>jar</packaging>
<name>${project.artifactId}</name> <name>${project.artifactId}</name>
@@ -16,6 +16,10 @@
<url>https://github.com/YunaiV/ruoyi-vue-pro</url> <url>https://github.com/YunaiV/ruoyi-vue-pro</url>
<dependencies> <dependencies>
<dependency>
<groupId>com.zt.plat</groupId>
<artifactId>zt-common</artifactId>
</dependency>
<!-- Spring 核心 --> <!-- Spring 核心 -->
<dependency> <dependency>
<groupId>org.springframework</groupId> <groupId>org.springframework</groupId>

View File

@@ -1,7 +1,5 @@
package com.zt.plat.framework.common.util.asyncTask; package com.zt.plat.framework.common.util.asyncTask;
import com.alibaba.ttl.TransmittableThreadLocal;
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;
import java.util.concurrent.*; import java.util.concurrent.*;
@@ -11,7 +9,7 @@ import java.util.concurrent.*;
* 多次提交,一次等待 * 多次提交,一次等待
*/ */
public class AsyncLatchUtils { public class AsyncLatchUtils {
private static final TransmittableThreadLocal<List<TaskInfo>> THREAD_LOCAL = TransmittableThreadLocal.withInitial(LinkedList::new); private static final ThreadLocal<List<TaskInfo>> THREADLOCAL = ThreadLocal.withInitial(LinkedList::new);
/** /**
* 提交一个异步任务 * 提交一个异步任务
@@ -19,7 +17,7 @@ public class AsyncLatchUtils {
* @param runnable 需要异步执行的具体业务逻辑 * @param runnable 需要异步执行的具体业务逻辑
*/ */
public static void submitTask(Executor executor, Runnable runnable) { public static void submitTask(Executor executor, Runnable runnable) {
THREAD_LOCAL.get().add(new TaskInfo(executor, runnable)); THREADLOCAL.get().add(new TaskInfo(executor, runnable));
} }
/** /**
@@ -27,8 +25,8 @@ public class AsyncLatchUtils {
* @return * @return
*/ */
private static List<TaskInfo> popTask() { private static List<TaskInfo> popTask() {
List<TaskInfo> taskInfos = THREAD_LOCAL.get(); List<TaskInfo> taskInfos = THREADLOCAL.get();
THREAD_LOCAL.remove(); THREADLOCAL.remove();
return taskInfos; return taskInfos;
} }
@@ -41,7 +39,7 @@ public class AsyncLatchUtils {
*/ */
public static boolean waitFor(long timeout, TimeUnit timeUnit) { public static boolean waitFor(long timeout, TimeUnit timeUnit) {
List<TaskInfo> taskInfos = popTask(); List<TaskInfo> taskInfos = popTask();
if (taskInfos.isEmpty()) { if (taskInfos.isEmpty()) {
return true; return true;
} }
CountDownLatch latch = new CountDownLatch(taskInfos.size()); CountDownLatch latch = new CountDownLatch(taskInfos.size());
@@ -59,11 +57,8 @@ public class AsyncLatchUtils {
boolean await = false; boolean await = false;
try { try {
await = latch.await(timeout, timeUnit); await = latch.await(timeout, timeUnit);
} catch (Exception ignored) { } catch (Exception ignored) {}
// 恢复中断状态 return await;
Thread.currentThread().interrupt();
}
return await;
} }
private static final class TaskInfo { private static final class TaskInfo {

Some files were not shown because too many files have changed in this diff Show More