zgty/zt-dsc
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
227 Commits 2 Branches 0 Tags
b11ffb4782e13b6216a148dc81d0403c85405c6c
Commit Graph

33 Commits

Author SHA1 Message Date
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
adf3ec601a feat(databus-client): 完成核心组件及编译验证（任务 89-92） 
新增核心组件（任务 89-90）：
1. HandlerRegistry.java - Handler 策略注册表
   - 自动注册所有 SyncEventHandler 和 BatchSyncEventHandler
   - 根据 eventType 路由到对应 Handler
   - 提供 getIncrementalHandler/getBatchHandler 方法
   - 支持 hasIncrementalHandler/hasBatchHandler 检查

2. DatabusClientConsumer.java - 统一消费者
   - 监听 databus-sync-{clientCode} Topic（简化版）
   - 根据消息字段判断增量/批量消息
   - 调用 HandlerRegistry 路由到具体 Handler
   - 支持全量同步生命周期回调（onFullSyncStart/onFullSyncComplete）

已存在接口（任务 91-92）：
1. SyncEventHandler.java - 增量同步 Handler 接口
2. BatchSyncEventHandler.java - 全量同步 Handler 接口

架构设计：
- 策略模式：通过 HandlerRegistry 动态路由
- Topic 简化：databus-sync-{clientCode}（所有事件共用）
- 消息路由：通过 eventType 字段区分事件类型
- 条件装配：@ConditionalOnProperty 灵活启用/禁用

编译结果：✅ BUILD SUCCESS（30个源文件）

Ref: docs/databus/implementation-checklist.md 任务 89-92
 2025-12-04 15:49:44 +08:00
hewencai
8329f9c834 feat(databus-client): 完成岗位 Handler 及编译验证（任务 75-88） 
新增文件（任务 75-88）：
- PostSyncService.java - 岗位同步服务接口
- PostSyncServiceImpl.java - 岗位同步服务实现（Feign调用）
- SystemPostCreateHandler.java - 岗位创建事件处理器
- SystemPostUpdateHandler.java - 岗位更新事件处理器
- SystemPostDeleteHandler.java - 岗位删除事件处理器
- SystemPostFullHandler.java - 岗位全量同步处理器（批量）

修复问题：
1. 修复 DTO 导入：DeptSaveReqVO → DeptSaveReqDTO, PostSaveReqVO → PostSaveReqDTO
2. 修复注解：@Resource(required=false) → @Autowired(required=false)
3. 修复 PostApi 包路径：com.zt.plat.module.system.api.post → com.zt.plat.module.system.api.dept
4. 修复 DeptSaveReqDTO 字段映射（移除不存在的字段：code, shortName, isCompany, isGroup, deptSource）
5. 修复 AdminUserSaveReqDTO 字段映射：
   - deptIds: List<Long> → Set<Long>
   - postIds: List<Long> → Set<Long>

编译结果：✅ BUILD SUCCESS（28个源文件）

Ref: docs/databus/implementation-checklist.md 任务 75-88
 2025-12-04 15:49:43 +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
chenbowen
e11065a596 1. 启动默认调度，定时请求 databus api 
2. 修复 databus 单元测试
3. 调整 iwork 回调业务编号
 2025-12-02 17:45:58 +08:00
chenbowen
ee9bc438b5 1. 剔除外域 url 2025-12-02 14:10:47 +08:00
chenbowen
95d905e76f 1. 限制记录 api 日志的字段长度 
2. 完整记录所有的 databus api 的请求日志
3. 新增 iwork 同步可以按 id 维度进行
4. 新增自动扫描 BusinessBaseDO 的 公司部门数据权限模式
 2025-12-01 17:46:42 +08:00
chenbowen
0c22975df0 1. 剔除掉多余的文档以及标记 2025-11-28 18:12:00 +08:00
chenbowen
30bd4810f5 1. 修复自定义 sql 中大写表名无法匹配到 mybatis 中的缓存表信息，导致表被忽略租户的问题 2025-11-28 16:16:49 +08:00
chenbowen
542466270a 1. 修复自定义 sql 中大写表名无法匹配到 mybatis 中的缓存表信息，导致表被忽略租户的问题 
2. 新增 iwork feign api 调用
 2025-11-28 11:05:09 +08:00
chenbowen
446b5ca7a4 剔除掉 swagger 不能请求的 rpc-api 2025-11-27 13:48:55 +08:00
chenbowen
06909fafea 当前登录用户新增公司编码与部门编码属性 2025-11-26 20:01:34 +08:00
chenbowen
65b99740c1 新增 long 集合类型的 string 转换 2025-11-24 19:18:23 +08:00
chenbowen
7e3baeba46 修复 nacos 刷新配置后，ignoreurl 失效的bug 2025-11-21 17:23:36 +08:00
chenbowen
266eb45e00 1. 新增分页接口聚合查询注解支持 
2. 优化 databus api 日志记录的字段缺失问题
3. 新增 eplat sso 页面登录校验
4. 用户、部门编辑新增 seata 事务支持
5. 新增 iwork 流程发起接口
6. 新增 eban 同步用户时的岗位处理逻辑
7. 新增无 skywalking 时的 traceId 支持
 2025-11-18 10:03:34 +08:00
chenbowen
af7f103a38 调整后台返回部门id与公司id类型为 string 2025-11-13 21:39:27 +08:00
chenbowen
71e63519ae 调整后台返回部门id与公司id类型为 string 2025-11-13 21:10:38 +08:00
chenbowen
c1f12dfe5e 1. 修复 userinfo 过多导致的用户登录失败错误 2025-11-13 18:44:28 +08:00
chenbowen
aa159638b9 1. 只要标记了业务接口，就需要全量的拦截，不再区分 url 2025-11-11 17:14:31 +08:00
chenbowen
b98f605dfd 1. 优化 bpm 流程中所有关于用户选择，部门选择的组件 
2. 优化 api 调试提示，优化 api 调用因为链接复用导致的链接被拒绝问题
3. 新增字典数据导入功能
 2025-11-03 14:20:13 +08:00
chenbowen
ddee4da72a 1. 新增 api 调用日志记录，历史版本回滚 
2. 新增用户角色权限监督功能
 2025-10-31 09:28:59 +08:00
chenbowen
04597fad6c 1. 统一网关未命中缓存时，进行兜底查询 
2. loginUser 新增 mobile username 作为 userInfo 扩展内容
 2025-10-28 17:32:42 +08:00
chenbowen
6e4cc4d55e 1. 修复界面bug 
2. 新增 api 可配置匿名访问固定用户配置
3. 新增密码弱口令校验规则
4. e 办使用 loginName 确认唯一用户逻辑
 2025-10-24 17:02:10 +08:00
chenbowen
78bc88b7a6 1. 新增外部系统编码部门编码关联管理 
2. 新增统一的 api 对外门户管理
3. 修正各个模块的 api 命名
 2025-10-17 17:40:46 +08:00
chenbowen
97bd87de55 完善自动填充逻辑，确保公司、部门、岗位等信息在缺失时自动填充 2025-09-29 11:49:01 +08:00
qianshijiang
952fde209a 1. 流程枚举状态补充方法返回对应枚举 
2. 新增获得指定用户的公司部门信息携带 Code
 2025-09-28 16:19:48 +08:00
chenbowen
ea04d0dee6 1. 升级 3.0.38 
补全业务附件表缺失的 api
 支持 api 获取附件二进制数据
 新增业务附件表状态信息
 补全部分存在嵌套结构的 bpm api 缺失数据
 2025-09-25 19:24:06 +08:00
chenbowen
f33d3f07b8 1. xxl-job 设置虚拟用户 0 登录操作 
2. Access-Control-Expose-Headers 允许暴露 content-disposition
 2025-09-25 12:01:19 +08:00
chenbowen
0c17191bc4 1. 新增根据 fileId 获取 onlyoffice token 接口 2025-09-24 14:23:20 +08:00
chenbowen
39963e6ae2 1. 新建统一的查询用户名称工具类 
2. 新增业务附件带 url 查询返回 创建人信息
 2025-09-23 14:57:06 +08:00
chenbowen
386d47fde1 1. 统一包名修改 2025-09-22 14:53:45 +08:00
chenbowen
0d46897482 1. 统一包名修改 2025-09-22 11:55:27 +08:00