267 lines
8.6 KiB
Markdown
267 lines
8.6 KiB
Markdown
# 认证流程重构说明
|
||
|
||
## 概述
|
||
|
||
本次重构主要针对认证流程中的企业信息管理进行了重大调整，删除了 `CertificationEnterpriseInfo` 实体，改为使用 `EnterpriseInfoSubmitRecord` 来管理认证过程中的企业信息。
|
||
|
||
## 主要变更
|
||
|
||
### 1. 实体结构调整
|
||
|
||
#### 删除的实体
|
||
- `CertificationEnterpriseInfo` - 认证过程中的企业信息实体
|
||
- `CertificationEnterpriseInfoRepository` - 认证企业信息仓储接口
|
||
- `GormCertificationEnterpriseInfoRepository` - 认证企业信息GORM仓储实现
|
||
|
||
#### 保留的实体
|
||
- `EnterpriseInfoSubmitRecord` - 企业信息提交记录（用于认证流程）
|
||
- `EnterpriseInfo` - 用户企业信息（认证完成后存储）
|
||
|
||
### 2. 业务流程调整
|
||
|
||
#### 企业信息提交流程
|
||
```go
|
||
// 1. 用户提交企业信息
|
||
// 2. 创建 EnterpriseInfoSubmitRecord 记录
|
||
// 3. 状态标记为 "submitted"
|
||
// 4. 认证申请状态转换为 "info_submitted"
|
||
```
|
||
|
||
#### 企业认证流程
|
||
```go
|
||
// 1. 获取 EnterpriseInfoSubmitRecord 记录
|
||
// 2. 调用e签宝服务生成认证文件
|
||
// 3. 更新记录状态为 "verified"
|
||
// 4. 认证申请状态转换为 "enterprise_verified"
|
||
```
|
||
|
||
#### 认证完成流程
|
||
```go
|
||
// 1. 从 EnterpriseInfoSubmitRecord 获取企业信息
|
||
// 2. 创建用户的 EnterpriseInfo 记录
|
||
// 3. 认证申请状态转换为 "completed"
|
||
```
|
||
|
||
### 3. 应用服务修改
|
||
|
||
#### 依赖注入调整
|
||
```go
|
||
type CertificationApplicationServiceImpl struct {
|
||
certManagementService *services.CertificationManagementService
|
||
certWorkflowService *services.CertificationWorkflowService
|
||
enterpriseService *user_services.EnterpriseService
|
||
esignService *esign_service.EQService
|
||
enterpriseRecordRepo repositories.EnterpriseInfoSubmitRecordRepository // 新增
|
||
logger *zap.Logger
|
||
}
|
||
```
|
||
|
||
#### 方法实现调整
|
||
|
||
**SubmitEnterpriseInfo 方法**
|
||
```go
|
||
func (s *CertificationApplicationServiceImpl) SubmitEnterpriseInfo(ctx context.Context, cmd *commands.SubmitEnterpriseInfoCommand) (*responses.EnterpriseInfoResponse, error) {
|
||
// 1. 验证企业信息
|
||
// 2. 获取或创建认证申请
|
||
// 3. 提交企业信息（状态转换）
|
||
// 4. 创建企业信息提交记录
|
||
enterpriseRecord := entities.NewEnterpriseInfoSubmitRecord(
|
||
certification.ID,
|
||
cmd.UserID,
|
||
cmd.CompanyName,
|
||
cmd.UnifiedSocialCode,
|
||
cmd.LegalPersonName,
|
||
cmd.LegalPersonID,
|
||
)
|
||
_, err = s.enterpriseRecordRepo.Create(ctx, *enterpriseRecord)
|
||
// ...
|
||
}
|
||
```
|
||
|
||
**GetEnterpriseAuthURL 方法**
|
||
```go
|
||
func (s *CertificationApplicationServiceImpl) GetEnterpriseAuthURL(ctx context.Context, userID string) (*responses.EnterpriseAuthURLResponse, error) {
|
||
// 1. 获取认证申请
|
||
// 2. 检查认证状态
|
||
// 3. 获取企业信息提交记录
|
||
enterpriseRecord, err := s.enterpriseRecordRepo.GetLatestByCertificationID(ctx, certification.ID)
|
||
// 4. 生成e签宝认证文件
|
||
// 5. 更新企业信息提交记录状态为已验证
|
||
enterpriseRecord.MarkAsVerified()
|
||
err = s.enterpriseRecordRepo.Update(ctx, *enterpriseRecord)
|
||
// ...
|
||
}
|
||
```
|
||
|
||
**CompleteEnterpriseAuth 方法**
|
||
```go
|
||
func (s *CertificationApplicationServiceImpl) CompleteEnterpriseAuth(ctx context.Context, userID string) (*responses.CertificationResponse, error) {
|
||
// 1. 获取认证申请
|
||
// 2. 获取企业信息提交记录
|
||
enterpriseRecord, err := s.enterpriseRecordRepo.GetLatestByCertificationID(ctx, certification.ID)
|
||
// 3. 检查企业信息是否已验证
|
||
if !enterpriseRecord.IsVerified() {
|
||
return nil, fmt.Errorf("企业信息尚未验证，请先完成e签宝认证")
|
||
}
|
||
// 4. 完成企业认证（状态转换）
|
||
// 5. 转移企业信息到用户账户
|
||
_, err = s.enterpriseService.CreateEnterpriseInfo(ctx, userID,
|
||
enterpriseRecord.CompanyName,
|
||
enterpriseRecord.UnifiedSocialCode,
|
||
enterpriseRecord.LegalPersonName,
|
||
enterpriseRecord.LegalPersonID)
|
||
// ...
|
||
}
|
||
```
|
||
|
||
### 4. 容器配置更新
|
||
|
||
#### e签宝服务注册
|
||
```go
|
||
// e签宝服务
|
||
func(cfg *config.Config) *esign_service.EQService {
|
||
esignConfig := &esign_service.Config{
|
||
AppID: cfg.Esign.AppID,
|
||
AppSecret: cfg.Esign.AppSecret,
|
||
ServerURL: cfg.Esign.ServerURL,
|
||
TemplateID: cfg.Esign.TemplateID,
|
||
}
|
||
return esign_service.NewEQService(esignConfig)
|
||
}
|
||
```
|
||
|
||
## 数据库结构
|
||
|
||
### 企业信息提交记录表 (enterprise_info_submit_records)
|
||
```sql
|
||
CREATE TABLE enterprise_info_submit_records (
|
||
id VARCHAR(36) PRIMARY KEY,
|
||
certification_id VARCHAR(36) NOT NULL,
|
||
user_id VARCHAR(36) NOT NULL,
|
||
|
||
-- 企业信息
|
||
company_name VARCHAR(200) NOT NULL,
|
||
unified_social_code VARCHAR(50) NOT NULL,
|
||
legal_person_name VARCHAR(50) NOT NULL,
|
||
legal_person_id VARCHAR(50) NOT NULL,
|
||
|
||
-- 提交状态
|
||
status VARCHAR(20) NOT NULL DEFAULT 'submitted',
|
||
submit_at TIMESTAMP NOT NULL,
|
||
verified_at TIMESTAMP NULL,
|
||
failed_at TIMESTAMP NULL,
|
||
failure_reason TEXT,
|
||
|
||
-- 系统字段
|
||
created_at TIMESTAMP NOT NULL,
|
||
updated_at TIMESTAMP NOT NULL,
|
||
deleted_at TIMESTAMP NULL,
|
||
|
||
INDEX idx_certification_id (certification_id),
|
||
INDEX idx_user_id (user_id),
|
||
INDEX idx_unified_social_code (unified_social_code)
|
||
);
|
||
```
|
||
|
||
### 用户企业信息表 (enterprise_infos)
|
||
```sql
|
||
CREATE TABLE enterprise_infos (
|
||
id VARCHAR(36) PRIMARY KEY,
|
||
user_id VARCHAR(36) NOT NULL UNIQUE,
|
||
|
||
-- 企业四要素
|
||
company_name VARCHAR(255) NOT NULL,
|
||
unified_social_code VARCHAR(50) NOT NULL,
|
||
legal_person_name VARCHAR(100) NOT NULL,
|
||
legal_person_id VARCHAR(50) NOT NULL,
|
||
|
||
-- 认证状态
|
||
is_ocr_verified BOOLEAN DEFAULT FALSE,
|
||
is_face_verified BOOLEAN DEFAULT FALSE,
|
||
is_certified BOOLEAN DEFAULT FALSE,
|
||
verification_data TEXT,
|
||
|
||
-- 认证完成时间
|
||
certified_at TIMESTAMP NULL,
|
||
|
||
-- 系统字段
|
||
created_at TIMESTAMP NOT NULL,
|
||
updated_at TIMESTAMP NOT NULL,
|
||
deleted_at TIMESTAMP NULL,
|
||
|
||
INDEX idx_user_id (user_id),
|
||
INDEX idx_unified_social_code (unified_social_code)
|
||
);
|
||
```
|
||
|
||
## API接口变更
|
||
|
||
### 企业信息提交接口
|
||
**POST /api/certification/submit-enterprise-info**
|
||
- 功能：提交企业信息，创建企业信息提交记录
|
||
- 响应：返回企业信息提交记录ID和基本信息
|
||
|
||
### 获取企业认证链接接口
|
||
**GET /api/certification/enterprise-auth-url**
|
||
- 功能：获取e签宝企业认证链接
|
||
- 前置条件：企业信息已提交且状态为 "info_submitted"
|
||
- 响应：返回认证链接和过期时间
|
||
|
||
### 完成企业认证接口
|
||
**POST /api/certification/complete-enterprise-auth**
|
||
- 功能：完成企业认证，转移企业信息到用户账户
|
||
- 前置条件：企业信息已通过e签宝认证
|
||
- 响应：返回更新后的认证状态
|
||
|
||
## 重构优势
|
||
|
||
### 1. 数据模型简化
|
||
- 删除了冗余的 `CertificationEnterpriseInfo` 实体
|
||
- 使用现有的 `EnterpriseInfoSubmitRecord` 管理认证流程
|
||
- 减少了数据库表的数量和维护成本
|
||
|
||
### 2. 业务流程清晰
|
||
- 认证流程中的企业信息通过提交记录管理
|
||
- 认证完成后企业信息转移到用户账户
|
||
- 状态转换更加明确和可追踪
|
||
|
||
### 3. 代码维护性提升
|
||
- 减少了重复的仓储接口和实现
|
||
- 统一了企业信息的管理方式
|
||
- 简化了应用服务的依赖注入
|
||
|
||
### 4. 数据一致性保证
|
||
- 企业信息提交记录作为认证流程的中间状态
|
||
- 认证完成后才创建用户企业信息
|
||
- 避免了数据不一致的问题
|
||
|
||
## 迁移说明
|
||
|
||
### 数据迁移
|
||
如果系统中存在旧的 `certification_enterprise_infos` 表数据，需要进行数据迁移：
|
||
|
||
```sql
|
||
-- 迁移认证过程中的企业信息到提交记录表
|
||
INSERT INTO enterprise_info_submit_records (
|
||
id, certification_id, user_id, company_name, unified_social_code,
|
||
legal_person_name, legal_person_id, status, submit_at,
|
||
verified_at, created_at, updated_at
|
||
)
|
||
SELECT
|
||
id, certification_id, user_id, company_name, unified_social_code,
|
||
legal_person_name, legal_person_id,
|
||
CASE WHEN is_verified THEN 'verified' ELSE 'submitted' END,
|
||
created_at, verified_at, created_at, updated_at
|
||
FROM certification_enterprise_infos
|
||
WHERE deleted_at IS NULL;
|
||
```
|
||
|
||
### 代码迁移
|
||
1. 删除所有对 `CertificationEnterpriseInfo` 的引用
|
||
2. 更新应用服务使用 `EnterpriseInfoSubmitRecord`
|
||
3. 更新容器配置移除相关仓储注册
|
||
4. 更新API文档和测试用例
|
||
|
||
## 总结
|
||
|
||
本次重构通过删除冗余的 `CertificationEnterpriseInfo` 实体，简化了认证流程的数据模型，提高了代码的可维护性和数据一致性。新的架构更加清晰，业务流程更加明确，为后续的功能扩展奠定了良好的基础。 |