Arrange/data masking v3 ce

[LordofAvernus]

User description

关联的 issue

link https://github.com/actiontech/dms-ee/issues/821

描述你的变更

确认项（pr提交后操作）

Tip

请在指定复审人之前，确认并完成以下事项，完成后✅

---

• 我已完成自测
• 我已记录完整日志方便进行诊断
• 我已在关联的issue里补充了实现方案
• 我已在关联的issue里补充了测试影响面
• 我已确认了变更的兼容性，如果不兼容则在issue里标记 not_compatible
• 我已确认了是否要更新文档，如果要更新则在issue里标记 need_update_doc

---

---

Description

• 增加查看原文/脱敏工单新接口

• 添加 unmasking workflow 数据结构与业务逻辑

• 调整 SQL 脱敏及数据导出流程支持项目 UID

• 添加 CE 版占位实现与构建校验脚本

---

Diagram Walkthrough

flowchart LR
  A["新增 unmasking_workflow API"] --> B["新增业务数据结构与逻辑"]
  B --> C["调整数据导出与 SQL 脱敏接口"]
  C --> D["新增 CE 版占位实现"]
  D --> E["更新构建校验脚本与构建目标"]

Loading

File Walkthrough

	Relevant files
Enhancement	26 files data_export_task.go 增加血缘分析与脱敏配置快照字段                                                                                    +5/-0      data_export_workflow.go 增加下载原文工单参数及接口文档                                                                                    +15/-0    db_structure_columns.go 新增列结构 API 定义                                                                                          +36/-0    masking.go 调整 ProjectUid 查询参数说明                                                                          +2/-3      unmasking_workflow.go 新增完整 unmasking workflow API 定义                                                      +261/-0  data_mask_controller.go 添加内部接口 ListTableColumns 与 unmasking 接口                                      +310/-36 unmasking_workflow.go 新增 unmasking workflow 业务逻辑及数据结构                                                    +271/-0  unmasking_workflow_ce.go CE 版 unmasking workflow 占位实现                                                          +84/-0    types.go 新增 Confidence 类型定义                                                                              +14/-0    cloudbeaver.go 调整 SQLResultMasker 接口支持 ProjectUID 参数                                        +12/-9    data_export_workflow.go 集成 unmasking workflow 与 masking 快照逻辑                                          +7/-3      data_export_workflow_ce.go 添加 DownloadOriginalDataExportWorkflow 占位方法                              +4/-0      db_service.go 新增查询及判断敏感数据脱敏任务的方法                                                                              +20/-0    cloudbeaver.go 修改 CloudbeaverUsecase 初始化参数                                                            +1/-1      data_export_workflow.go 调用填充 unmasking workflow 汇总信息                                                          +13/-0    data_export_workflow_ce.go 添加 CE 版下载原文工单接口占位                                                                                +16/-0    db_structures_ce.go 添加 DBStructures CE 版占位实现                                                                  +14/-0    service.go 更新 DMSService 初始化 unmasking workflow usecase                          +7/-1      sql_workbench_result_masker_ce.go 添加 CE 版 SQLResultMasker 占位实现                                                          +14/-0    unmasking_workflow_ce.go 添加 CE 版 unmasking workflow 占位接口实现                                                +46/-0    data_masking_middleware.go 添加配置项支持 UnmaskingWorkflowUsecase                                                  +15/-0    data_masking_middleware_ce.go 添加 CE 版 data masking middleware 占位                                              +24/-0    sql_workbench_service.go 更新 SQLWorkbenchService 逻辑与 Base64 解码方式                                      +45/-33  masker.go 新增 SQLResultMasker 接口与参数定义                                                              +18/-0    verify_build_editions.sh 新增多版本构建校验脚本                                                                                            +102/-0  Makefile 添加 verify_edition_builds 构建目标                                                        +4/-0
Documentation	3 files message_zh.go 新增 unmasking workflow 国际化消息                                                            +60/-45  active.en.toml 增加 unmasking workflow 对应英文消息                                                          +9/-0      active.zh.toml 增加 unmasking workflow 对应中文消息                                                          +9/-0

---

[actiontech-bot]

没有在复审记录中找到这个MR => https://github.com/actiontech/dms-ee/issues/821

[actiontech-bot]

没有在复审记录中找到这个MR => https://github.com/actiontech/dms-ee/issues/821

[github-actions]

PR Reviewer Guide 🔍

(Review updated until commit 162dc22)

⏱️ Estimated effort to review: 5 🔵🔵🔵🔵🔵

🧪 No relevant tests

🔒 No security concerns identified

⚡ No major issues detected

[github-actions]

PR Code Suggestions ✨

Latest suggestions up to d6d303f
Explore these optional code suggestions:

Category	Suggestion	Impact
Possible issue	增加 nil 检查 建议在构造响应拦截器时增加对 c.Response() 和 c.Response().Writer 的非空检查，以防止在这些对象为 nil 时触发空指针解引用而导致 panic。这样可以提升代码的健壮性并方便定位配置异常。 internal/sql_workbench/service/sql_workbench_service.go [1-7] func NewStreamExecuteResponseWriter(c echo.Context) *StreamExecuteResponseWriter { + if c.Response() == nil || c.Response().Writer == nil { + // 根据实际需求可以选择返回 nil 或采取其他错误处理措施 + return nil + } buf := new(bytes.Buffer) return &StreamExecuteResponseWriter{ Response: *c.Response(), Buffer: buf, Original: c.Response().Writer, } } Suggestion importance[1-10]: 6 __ Why: 该建议在创建 StreamExecuteResponseWriter 时增加了对 c.Response() 和 c.Response().Writer 的 nil 检查，有助于防止潜在的 panic，从而提升代码健壮性，但改动属于防御性编程的改进，影响相对较小。	Low
General	增加日志记录 建议在返回默认值之前增加日志记录，当 d.maskingTaskRepo 为 nil 或 dbServiceUID 为空时记录警告日志，有助于排查配置或数据缺失的问题。此举可以帮助运维人员及早发现潜在异常。 internal/dms/biz/db_service.go [1-6] func (d *DBServiceUsecase) CheckSensitiveDataMaskingTask(ctx context.Context, dbServiceUID string) (bool, error) { if d == nil || d.maskingTaskRepo == nil || dbServiceUID == "" { + if d != nil && d.log != nil { + d.log.Warnf("CheckSensitiveDataMaskingTask: missing maskingTaskRepo or empty dbServiceUID") + } return false, nil } return d.maskingTaskRepo.CheckMaskingTaskExist(ctx, dbServiceUID) } Suggestion importance[1-10]: 5 __ Why: 该建议通过在返回默认值前记录警告日志来帮助排查配置或数据问题，提升了问题诊断能力，但改动较为轻微，不会显著改变业务流程。	Low

---

Previous suggestions

Suggestions up to commit d7a70a6

Category	Suggestion	Impact
Possible issue	分离空返回判断 建议分别处理 err 非 nil 和返回空数组的情况，避免在 err 为 nil 时使用 %w 包裹 nil。这样可以确保错误信息更明确，降低后续调试风险。 internal/dms/service/data_export_workflow.go [342-345] tasks, err := d.DataExportWorkflowUsecase.BatchGetDataExportTask(ctx, []string{req.DataExportTaskUid}) -if err != nil || len(tasks) == 0 { +if err != nil { return nil, fmt.Errorf("failed to get data export task: %w", err) } +if len(tasks) == 0 { + return nil, errors.New("failed to get data export task: no task found") +} Suggestion importance[1-10]: 6 __ Why: 该建议正确地将 err 非 nil 和返回空数组的情况分开处理，避免了在 err 为 nil 时调用 %w，从而提高了错误信息的明确性和后续调试的可靠性。	Low

[actiontech-bot]

没有在复审记录中找到这个MR => https://github.com/actiontech/dms-ee/issues/821

[github-actions]

Persistent review updated to latest commit d6d303f

[actiontech-bot]

没有在复审记录中找到这个MR => https://github.com/actiontech/dms-ee/issues/821

[github-actions]

Persistent review updated to latest commit 162dc22

[github-actions]

Failed to generate code suggestions for PR