8.6 KiB
8.6 KiB
认证流程重构说明
概述
本次重构主要针对认证流程中的企业信息管理进行了重大调整，删除了 CertificationEnterpriseInfo 实体，改为使用 EnterpriseInfoSubmitRecord 来管理认证过程中的企业信息。
主要变更
1. 实体结构调整
删除的实体
CertificationEnterpriseInfo- 认证过程中的企业信息实体CertificationEnterpriseInfoRepository- 认证企业信息仓储接口GormCertificationEnterpriseInfoRepository- 认证企业信息GORM仓储实现
保留的实体
EnterpriseInfoSubmitRecord- 企业信息提交记录（用于认证流程）EnterpriseInfo- 用户企业信息（认证完成后存储）
2. 业务流程调整
企业信息提交流程
// 1. 用户提交企业信息
// 2. 创建 EnterpriseInfoSubmitRecord 记录
// 3. 状态标记为 "submitted"
// 4. 认证申请状态转换为 "info_submitted"
企业认证流程
// 1. 获取 EnterpriseInfoSubmitRecord 记录
// 2. 调用e签宝服务生成认证文件
// 3. 更新记录状态为 "verified"
// 4. 认证申请状态转换为 "enterprise_verified"
认证完成流程
// 1. 从 EnterpriseInfoSubmitRecord 获取企业信息
// 2. 创建用户的 EnterpriseInfo 记录
// 3. 认证申请状态转换为 "completed"
3. 应用服务修改
依赖注入调整
type CertificationApplicationServiceImpl struct {
certManagementService *services.CertificationManagementService
certWorkflowService *services.CertificationWorkflowService
enterpriseService *user_services.EnterpriseService
esignService *esign_service.EQService
enterpriseRecordRepo repositories.EnterpriseInfoSubmitRecordRepository // 新增
logger *zap.Logger
}
方法实现调整
SubmitEnterpriseInfo 方法
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 方法
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 方法
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签宝服务注册
// 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)
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)
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 表数据，需要进行数据迁移：
-- 迁移认证过程中的企业信息到提交记录表
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;
代码迁移
- 删除所有对
CertificationEnterpriseInfo的引用 - 更新应用服务使用
EnterpriseInfoSubmitRecord - 更新容器配置移除相关仓储注册
- 更新API文档和测试用例
总结
本次重构通过删除冗余的 CertificationEnterpriseInfo 实体，简化了认证流程的数据模型，提高了代码的可维护性和数据一致性。新的架构更加清晰，业务流程更加明确，为后续的功能扩展奠定了良好的基础。