zgty/zt-dsc
9
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
778 Commits 2 Branches 0 Tags
d6ef89b70dcdf822d6b87c1a14d764ea5a95cc58
Commit Graph

68 Commits

Author SHA1 Message Date
chenbowen
83545f90bd Merge remote-tracking branch 'base-version/test' into dev 2026-01-22 17:22:02 +08:00
wuzongyong
83bf2aa9fb refactor(gateway): 简化网关表达式中的响应处理逻辑 
- 移除冗余的响应体检查逻辑
- 优化状态码和消息的处理流程
- 保持原有的响应体设置行为不变
- 提升代码可读性和维护性
 2026-01-22 16:39:02 +08:00
wuzongyong
924c27596e feat(gateway): 实现API网关响应模板和请求映射增强功能 
- 添加getLastHttpStepId方法获取最后HTTP步骤ID用于响应体设置判断
- 实现响应模板功能支持自定义JSON响应格式通过responseTemplate配置
- 增强请求映射逻辑支持查询参数、请求头和请求体的灵活映射与合并
- 优化HTTP步骤处理器中的请求载荷转换和响应映射逻辑
- 在START节点中支持公共参数自动继承到后续HTTP步骤
- 添加查询参数环境变量绑定便于JSONata表达式访问
- 实现向后兼容的默认响应格式保持现有功能不变
 2026-01-22 16:39:02 +08:00
ranke
413ce4c1ef 修复数据总线访问日志无法显示状态码问题: 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-22 09:35:13 +08:00
chenbowen
b637c619f1 Merge remote-tracking branch 'base-version/test' into dev 2026-01-20 08:58:56 +08:00
chenbowen
4595cef06e 1.获取 token 失败后进行十次重试 2026-01-20 08:57:34 +08:00
chenbowen
d3a771a8a8 Merge remote-tracking branch 'base-version/test' into dev 2026-01-16 12:51:19 +08:00
wuzongyong
ac5e210269 refactor(databus): 移除API客户端凭证服务中的缓存实现 
- 删除了基于Caffeine的凭证缓存逻辑
- 移除了PostConstruct注解的缓存初始化方法
- 删除了缓存相关的成员变量和配置
- 移除了所有缓存失效操作包括创建、更新和删除时的缓存清理
- 简化了凭证查询逻辑直接通过数据库访问
- 保留了核心的API凭证管理功能和匿名用户服务集成
 2026-01-16 09:23:29 +08:00
chenbowen
e2688268ac Merge remote-tracking branch 'base-version/test' into dev 
# Conflicts:
#	zt-module-databus/zt-module-databus-server-app/src/main/resources/application-dev.yml
 2026-01-15 22:43:56 +08:00
wuzongyong
06fb92462c feat(config): 更新开发环境数据库连接和安全过滤器加密功能 
- 修改 application-dev.yml 中的数据库连接地址和凭据信息
- 在 GatewaySecurityFilter 中实现条件加密验证逻辑
- 添加 wzy 环境配置文件支持 Nacos 配置中心连接
- 优化请求体解密和签名验证流程以支持选择性加密处理
- 更新缓存请求体构造以确保解密后数据正确传递
 2026-01-15 18:06:26 +08:00
lenovo
ec99f49c93 Merge remote-tracking branch 'refs/remotes/ztcloud/test' into dev 2026-01-15 16:26:57 +08:00
ranke
d1e2e25b96 新增 zt-module-databus-server-app 的 dockerfile 2026-01-15 16:05:02 +08:00
wuzongyong
287d24fc7f feat(gateway): 添加API客户端凭证加密功能支持 
- 在ApiClientCredentialDO实体类中新增enableEncryption字段
- 在ApiClientCredentialRespVO响应对象中添加加密启用状态字段
- 在ApiClientCredentialSaveReqVO请求对象中添加加密启用状态字段
- 在GatewaySecurityFilter中实现加密启用状态检查逻辑
- 添加数据库表结构变更脚本支持加密字段
 2026-01-14 18:11:02 +08:00
chenbowen
479d6c6c2a Merge remote-tracking branch 'base-version/test' into dev 
# Conflicts:
#	zt-framework/zt-common/src/main/java/com/zt/plat/framework/common/util/security/CryptoSignatureUtils.java
#	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/api/databus/DatabusDeptProviderApiImpl.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/framework/sms/core/enums/SmsChannelEnum.java
 2026-01-13 11:00:28 +08:00
ranke
6644710fe0 把-server项目改为jar包,新增 server-app项目作为启动器 http://172.16.46.63:31560/index.php?m=task&f=view&taskID=699 2026-01-12 18:36:39 +08:00
chenbowen
82c819c59a Merge remote-tracking branch 'base-version/test' into dev 2026-01-09 15:32:39 +08:00
chenbowen
c3502e78c8 1. 调整 databus 默认的重试策略 2026-01-09 15:25:42 +08:00
chenbowen
e338de722f Merge remote-tracking branch 'base-version/main' into dev 2026-01-07 16:51:19 +08:00
chenbowen
b3b691a7e3 1.初始化日志时并没有有效的用户信息，设置为空字符串占位 2026-01-07 16:49:47 +08:00
chenbowen
b86a9a2811 Merge remote-tracking branch 'base-version/main' into dev 2026-01-06 15:24:13 +08:00
chenbowen
797cd2abd9 1. 修复 deptignore 注解会导致的空指针问题 
2. 延长 databus 默认的请求超时时间
3. 调整初始化脚本部分字段的长度
 2026-01-06 09:18:47 +08:00
qianshijiang
b155b1a00a 数据库配置修改 2025-12-31 16:36:01 +08:00
hewencai
3903b73905 Merge remote-tracking branch 'ztcloud/main' into main-ztcloud 
# Conflicts:
#	zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/dept/DeptService.java
 2025-12-24 11:15:23 +08:00
hewencai
8823e316a0 update：调整数据同步用户-部门，用户-岗位同步逻辑 2025-12-24 11:04:49 +08:00
hewencai
7ef5545dc0 update：调整数据同步用户-部门，用户-岗位同步顺序 2025-12-24 11:04:03 +08:00
hewencai
9b0e63a33e update：调整数据同步用户-部门，用户-岗位同步顺序 2025-12-24 11:04:01 +08:00
hewencai
2baede83e5 update：调整数据同步生产topic生成器 2025-12-24 11:03:59 +08:00
hewencai
bf27ebd5ba update：调整数据同步用户-部门，用户-岗位同步逻辑 2025-12-24 10:42:18 +08:00
chenbowen
5843e2eb7a Merge remote-tracking branch 'refs/remotes/base-version/main' into dev 2025-12-23 17:52:55 +08:00
chenbowen
7b1991cc1c 1. 修复 get 请求时，转义后的字符串解析签名会存在问题 2025-12-23 16:36:06 +08:00
hewencai
0bdded447a update：调整数据同步用户-部门，用户-岗位同步顺序 2025-12-22 11:03:15 +08:00
hewencai
cea886c9b2 update：调整数据同步用户-部门，用户-岗位同步顺序 2025-12-22 09:51:05 +08:00
hewencai
0b8e200aa1 Merge remote-tracking branch 'origin/dev' into dev 2025-12-17 11:32:12 +08:00
hewencai
738c82b000 update：调整数据同步生产topic生成器 2025-12-17 11:31:57 +08:00
chenbowen
12157d5dcb 1. 修复 databus 在多层嵌套的 json 报文，签名存在异常的 bug 2025-12-16 21:35:08 +08:00
hewencai
fcc32fa2d8 Merge remote-tracking branch 'ztcloud/main' into main-ztcloud 2025-12-16 16:36:56 +08:00
hewencai
8782631eaa update：数据同步分发机构岗位绑定关系 2025-12-16 16:36:30 +08:00
hewencai
ba1bc1fb6f update：数据同步分发机构岗位绑定关系 2025-12-16 12:03:15 +08:00
chenbowen
2323ee5c3b 1. 新增生成自有组织 CODE，同步其他系统额外生成编码映射关系 2025-12-15 19:25:19 +08:00
chenbowen
8d25f4224b 1. 临时去除掉硬性的 databus 签名校验 2025-12-14 13:52:14 +08:00
chenbowen
cae0b9e4af 1. 新增 api 绑定客户凭证进行权限校验 
2. 去除 api 定义的缓存策略
3. 新增短信渠道
4. 新增用户信息模糊查询
5. 修复全局的单元测试
 2025-12-12 10:03:10 +08:00
chenbowen
29e0c7da14 1. 新增 api 绑定客户凭证进行权限校验 2025-12-09 16:24:17 +08:00
chenbowen
52a0109960 临时关闭签名校验 2025-12-05 09:04:02 +08:00
hewencai
25978ad4b9 fix:还原databus端口配置 2025-12-04 15:49:46 +08:00
hewencai
ffc7d0247d refactor(databus): 代码审查修复和TODO完成 
修复硬编码配置：
- 修改日志路径为环境变量：${LOG_PATH:./logs}/${spring.application.name}.log
- 修改 RocketMQ 地址为环境变量：${ROCKETMQ_NAME_SERVER:172.16.46.63:30876}
- 还原 Nacos namespace 从 hwc 到 dev

完成 TODO 功能：
- TODO #1: 实现死信重试逻辑（重新投递消息到 MQ）
- TODO #2: 实现日志重试逻辑（根据事件记录重新推送）
- TODO #3: 实现全量同步触发（创建任务并异步执行）
- TODO #4: 实现事件 ID 查询（通过 eventType 查询事件定义）

涉及文件：
- pom.xml: 还原 Nacos namespace 到 dev
- DatabusSyncDeadLetterServiceImpl: 实现死信重试
- DatabusSyncLogServiceImpl: 实现日志重试
- DatabusSyncSubscriptionServiceImpl: 实现全量同步触发
- DatabusEventPublisherImpl: 实现事件 ID 查询
- application-*.yml/yaml: 修复硬编码配置

Ref: 代码审查报告
 2025-12-04 15:49:46 +08:00
hewencai
6ac4a356cd fix(databus): 修复客户端消息处理和防止消息循环 
1. 修复消息格式不匹配问题
   - 增量消息：兼容 SyncMessage 格式，从 dataSnapshot 字段反序列化数据
   - 批量消息：添加 getDataType() 方法获取泛型类型，正确转换 JSONObject

2. 防止消息循环
   - 添加 zt.databus.change.producer.enabled 配置项
   - 客户端禁用变更消息发送，避免 客户端写入 → 发送变更 → 循环

3. 修复 Feign 客户端注入
   - 在 RpcConfiguration 中添加 DeptApi、PostApi
   - 确保客户端能通过 Feign 调用本地 system-server API

相关文件：
- DatabusClientConsumer.java: 修复消息解析逻辑
- BatchSyncEventHandler.java: 添加 getDataType() 方法
- DatabusChangeProducer.java: 添加 enabled 开关
- RpcConfiguration.java: 启用 DeptApi/PostApi Feign 客户端

Ref: 修复 ClassCastException 和消息循环问题
 2025-12-04 15:49:45 +08:00
hewencai
bd90ec9d70 feat(databus): 完成阶段四-DataBus Server完整功能 
- 补充缺失的 API 类（DatabusMessage、DatabusBatchMessage、DatabusEventType）
- 新增变更消息消费者（3个：部门、用户、岗位）
- 新增数据提供者（3个：部门、用户、岗位）
- 确认分发器服务（核心定向推送逻辑）
- 确认全量同步与消息推送组件
- 确认管理后台 API（5个 Controller）
- 确认 Service ��（4个核心服务）
- 确认 DAL 层（7个 DO + Mapper）
- 添加 databus-server starter 依赖到 pom.xml
- 编译验证通过

Ref: docs/databus/implementation-checklist.md 任务 39-70
 2025-12-04 15:49:42 +08:00
hewencai
acdc73999a feat(databus): 完成阶段一+二-数据契约层与数据提供者 
阶段一：数据契约层（任务 1-16）
- 新增 DatabusDeptData, DatabusAdminUserData, DatabusPostData 数据对象
- 新增 CursorPageReqDTO, CursorPageResult 游标分页 DTO
- 新增 DatabusDeptProviderApi, DatabusUserProviderApi, DatabusPostProviderApi Feign 接口
- 修改 system-api pom.xml 添加 databus-api 依赖

阶段二：数据提供者实现（任务 17-38）
- 新增 DatabusDeptProviderApiImpl, DatabusUserProviderApiImpl, DatabusPostProviderApiImpl Feign 接口实现
- 实现游标分页查询（基于 cursorTime + cursorId 复合游标）
- 新增 DatabusDeptChangeMessage, DatabusUserChangeMessage, DatabusPostChangeMessage MQ 消息类
- 新增 DatabusChangeProducer 消息生产者（支持部门、用户、岗位三实体）
- 修改 DeptServiceImpl, AdminUserServiceImpl, PostServiceImpl 添加事件发布

技术要点：
- 游标分页：cursorTime + cursorId 复合游标解决雪花ID乱序问题
- 事件发布：create/update/delete 操作后异步发送 MQ 消息
- 数据聚合：用户数据包含部门和岗位简要信息

Ref: docs/databus/implementation-checklist.md 任务 1-38
 2025-12-04 15:49:41 +08:00
chenbowen
45140c7f5a 1. 调整 databus 模块写入日志的时机，解决获取不到租户的问题 2025-12-03 09:51:43 +08:00
chenbowen
e11065a596 1. 启动默认调度，定时请求 databus api 
2. 修复 databus 单元测试
3. 调整 iwork 回调业务编号
 2025-12-02 17:45:58 +08:00