wkc/ccdi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
62 Commits 6 Branches 0 Tags
b932a7dba815f8d815ea61af8aa5dc6e2aa99540
Commit Graph

33 Commits

Author SHA1 Message Date
wkc
3d4a42b9fb 员工异步导入 2026-02-06 11:19:40 +08:00
wkc
61e8d45212 fix: 修复员工导入异步实现,实现真正的非阻塞异步 
问题分析:
- Service方法同时使用@Async和CompletableFuture.supplyAsync
- Controller调用future.get()会阻塞等待
- 这不是真正的异步

修复方案:
- 移除@Async注解
- Service方法使用CompletableFuture.runAsync()异步执行doImport
- Service方法改为void返回类型,立即返回
- Controller不调用future.get(),自己构建响应
- 实现真正的异步非阻塞导入

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 10:13:03 +08:00
wkc
0b0655174a fix: 修复员工导入异步方法的实现 
## 问题
- importEmployeeAsync方法在返回CompletableFuture之前同步调用了doImport()
- 方法上有@Transactional注解,会导致事务管理问题
- 不是真正的异步执行

## 解决方案
- 移除importEmployeeAsync方法上的@Transactional注解
- 使用CompletableFuture.supplyAsync()在importExecutor线程池中异步执行doImport
- 将@Transactional注解移到doImport方法上
- 注入importExecutor线程池

## 技术细节
- @Async注解会将方法提交到线程池执行
- CompletableFuture.supplyAsync()确保doImport在独立线程中执行
- 事务在doImport方法中管理,避免异步方法事务问题

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 10:06:20 +08:00
wkc
50ac577297 fix: 修复异步方法返回类型不兼容问题 
将@Async方法的返回类型从String改为CompletableFuture<ImportResultVO>,
并使用CompletableFuture.completedFuture()立即返回已完成的Future,
既符合@Async的要求,又能实现立即返回的效果。

修改文件:
- ICcdiEmployeeService.java: 更新接口返回类型
- CcdiEmployeeServiceImpl.java: 使用CompletableFuture.completedFuture()
- CcdiEmployeeController.java: 调用future.get()获取结果(不会阻塞)

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 09:59:30 +08:00
wkc
20bead7ddf fix: 修复Controller中success方法调用,直接使用AjaxResult.success() 2026-02-06 09:55:30 +08:00
wkc
db46521c8b fix: 修复异步导入方法的阻塞调用问题 
## 问题描述
Controller层使用了future.get()阻塞调用,导致异步导入失去意义

## 修复内容
1. 修改ICcdiEmployeeService接口:将返回类型从CompletableFuture<ImportResultVO>改为String
2. 修改CcdiEmployeeServiceImpl:importEmployeeAsync方法立即返回taskId
3. 修改CcdiEmployeeController:移除future.get()调用,直接使用返回的taskId
4. 移除不需要的CompletableFuture导入

## 技术细节
- Service方法保持@Async注解,在独立线程池中执行
- Controller立即返回taskId给前端,不等待导入完成
- 前端可通过/importStatus/{taskId}接口查询导入进度

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 09:46:27 +08:00
wkc
d709183561 refactor: 修改员工信息导入接口为异步并添加状态查询接口 
- 将importData接口改为异步调用,使用CompletableFuture
- 添加getImportStatus接口查询导入任务状态
- 添加getImportFailures接口查询导入失败记录(支持分页)
- 添加必要的导入:CompletableFuture、ImportResultVO、ImportStatusVO、ImportFailureVO
- 保持现有的权限注解@PreAuthorize和日志注解@Log

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 09:44:01 +08:00
wkc
6101d94d82 fix: 修复员工导入Service层的事务管理和批量插入性能问题 
问题1: importEmployeeAsync方法缺少@Transactional注解
- 在第239行添加@Transactional注解,确保异步操作的事务一致性

问题2: saveBatch方法性能问题
- 原实现: 循环内逐条调用insert(),不是真正的批量插入
- 修复方案:
  1. 在CcdiEmployeeMapper接口中新增insertBatch方法
  2. 在CcdiEmployeeMapper.xml中实现真正的批量插入SQL
  3. saveBatch方法改为调用insertBatch,分批次批量插入

性能提升:
- 之前: 1000条数据需要1000次数据库往返
- 之后: 1000条数据只需2次数据库往返(分批次500条)

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 09:41:50 +08:00
wkc
d5af1602f9 refactor: 重构validateEmployeeData方法复用逻辑 
- 修改validateEmployeeData方法,增加existingIds参数支持导入场景
- 删除validateEmployeeDataForImport方法,统一使用validateEmployeeData
- 单条新增场景(existingIds=null)执行原有验证逻辑
- 导入场景(existingIds!=null)跳过柜员号唯一性检查(已在调用前批量查询)
- 保持性能优化:批量查询一次existingIds,而非每条记录单独查询

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 09:37:54 +08:00
wkc
8bdce0adbf feat: 实现员工信息异步导入Service层方法 
完成功能:
- 新增异步导入方法 importEmployeeAsync,使用@Async注解实现异步处理
- 新增查询导入状态方法 getImportStatus
- 新增查询导入失败记录方法 getImportFailures
- 实现完整的导入逻辑,包括数据分类、批量操作、进度跟踪
- 使用Redis存储导入状态和失败记录,TTL设置为7天
- 支持增量更新模式,批量插入新数据,批量更新已有数据
- 实时更新导入进度到Redis

技术要点:
- 使用RedisTemplate操作Redis,Hash结构存储状态
- 使用importExecutor线程池异步执行导入任务
- 使用UUID生成唯一任务ID
- 使用CompletableFuture包装返回结果
- 批量操作提高性能(saveBatch每500条一批)
- 失败记录只保存到Redis,不保存成功记录

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 09:34:08 +08:00
wkc
e8a4b53a0e fix: 修复CcdiEmployeeMapper.xml中的remark字段问题 
- 删除insertOrUpdateBatch方法中的remark字段
- 确保SQL只包含数据库中实际存在的11个字段
- ON DUPLICATE KEY UPDATE中也删除了remark字段

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 09:24:40 +08:00
wkc
97bb899093 feat: 添加员工信息批量插入或更新Mapper方法 
在CcdiEmployeeMapper中新增insertOrUpdateBatch方法:
- 支持批量插入员工信息
- 使用ON DUPLICATE KEY UPDATE实现upsert功能
- 基于employee_id主键判断重复
- 插入时记录创建时间和创建人
- 更新时保留原创建信息,更新修改时间和修改人

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 09:22:06 +08:00
wkc
0aa812c283 feat: 添加导入相关VO类(ImportResultVO, ImportStatusVO, ImportFailureVO) 2026-02-06 09:18:31 +08:00
wkc
ce4000f477 feat: 添加异步配置类,配置导入任务专用线程池 
- 创建AsyncConfig配置类,启用Spring异步支持
- 配置importExecutor线程池:
  * 核心线程数: 2
  * 最大线程数: 5
  * 队列容量: 100
  * 线程名前缀: import-async-
  * 拒绝策略: CallerRunsPolicy
  * 优雅关闭: 等待60秒完成任务

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-06 09:15:14 +08:00
wkc
4c3eeea256 员工关系移除 2026-02-06 09:01:33 +08:00
wkc
1e691f9697 docs: 添加员工信息导入结果弹窗自适应优化设计文档 
- 分析现有问题：弹窗内容过多时超出视口
- 设计固定高度+内容可滚动的Flexbox布局方案
- 提供完整的CSS样式和响应式设计
- 包含实施计划、验收标准和技术要点

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-05 16:09:40 +08:00
wkc
07dea1bf0c feat: 员工信息必填项优化 - 柜员号、所属部门、电话设为必填 
## 后端修改
- AddDTO: deptId和phone添加@NotNull/@NotBlank注解
- EditDTO: deptId和phone添加@NotNull/@NotBlank注解
- Service: 导入验证添加deptId和phone必填校验

## 前端修改
- 表单校验规则: deptId和phone添加required校验
- 自动显示必填标记(红色星号)

## API文档更新
- 新增接口字段说明: deptId和phone标记为必填
- 导入模板: 标注必填项(*标记)
- 业务错误信息: 添加部门和电话相关错误提示

## 必填字段清单
1. employeeId(柜员号) - 7位数字
2. name(姓名)
3. deptId(所属部门)
4. idCard(身份证号)
5. phone(电话) - 11位手机号
6. status(状态)

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-05 14:26:40 +08:00
wkc
da663fb635 feat: 员工柜员号优化 - 移除tellerNo,employeeId作为7位数字柜员号 
## 数据库修改
- 删除teller_no字段
- employee_id改为非自增,手动输入7位数字
- 更新字段注释

## 后端修改
- Entity: 移除tellerNo,employeeId改为INPUT类型
- DTO: Add/Edit/Query/Excel全部使用employeeId
- VO: 移除tellerNo字段
- Service: 添加柜员号唯一性校验(使用selectById)
- Mapper XML: 移除teller_no查询和映射

## 前端修改
- 查询表单: tellerNo改为employeeId,添加7位数字限制
- 表格列: 显示employeeId作为柜员号
- 对话框: 新增可输入,编辑只读
- JavaScript: 数据结构和校验规则更新

## 文档更新
- API文档: 完整更新所有接口说明
- 实施报告: 生成详细实施报告

## 测试
- 生成测试脚本(9个测试用例)
- 测试账号: admin/admin123

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-05 14:18:28 +08:00
wkc
81d4038302 中介黑名单更新 2026-02-05 13:33:27 +08:00
wkc
1af2677c05 feat: 导入功能改为批量插入和批量更新 
## 修改内容

### Mapper 接口
- CcdiBizIntermediaryMapper: 新增 insertBatch() 和 updateBatch() 方法
- CcdiEnterpriseBaseInfoMapper: 新增 insertBatch() 和 updateBatch() 方法

### Mapper XML
- 新增 CcdiBizIntermediaryMapper.xml: 实现个人中介的批量插入和更新
- 新增 CcdiEnterpriseBaseInfoMapper.xml: 实现实体中介的批量插入和更新
  - 批量插入使用 VALUES (...), (...), (...) 语法
  - 批量更新使用 foreach 分隔多条 UPDATE 语句

### Service 实现
- importIntermediaryPerson(): 改为两轮处理模式
  - 第一轮：数据验证和分类（区分插入和更新）
  - 第二轮：批量插入新记录 + 批量更新已存在记录

- importIntermediaryEntity(): 改为两轮处理模式
  - 第一轮：数据验证和分类（区分插入和更新）
  - 第二轮：批量插入新记录 + 批量更新已存在记录

## 性能优化
- 从原来的逐条插入/更新改为批量操作
- 减少数据库连接次数，提升大数据量导入性能
- 事务一致性保证，全部成功或全部回滚

编译验证：通过
 2026-02-04 19:52:29 +08:00
wkc
cca2e620b5 fix: 修复intermediaryType字段访问错误 
- intermediaryType字段仅存在于VO中，不应在Entity上访问
- 移除查询条件中对getIntermediaryType()的错误引用
- 修改插入方法，使用正确的字段设置：
  - 个人中介：setPersonType('中介') + setDataSource
  - 实体中介：setRiskLevel('1') + setEntSource('INTERMEDIARY') + setDataSource
- 修复位置：查询条件、新增方法、导入方法共6处

编译验证：通过
 2026-02-04 19:45:05 +08:00
wkc
85d4289ba7 feat: 添加中介Controller控制器 
- 新增CcdiIntermediaryController,提供中介RESTful API
- 支持个人和实体中介的统一列表查询
- 提供个人和实体中介的详情查询接口
- 支持个人和实体中介的新增、修改、删除操作
- 提供唯一性校验接口
- 支持Excel模板下载和数据导入功能
- 完整的Swagger API文档注解

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-04 19:31:55 +08:00
wkc
4e55105c9e feat: 添加中介Excel导入导出类 
- 新增CcdiIntermediaryPersonExcel,支持个人中介信息导入导出
- 新增CcdiIntermediaryEntityExcel,支持实体中介信息导入导出
- 使用@DictDropdown注解支持字典下拉框
- 完整覆盖个人和实体中介的所有业务字段

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-04 19:31:51 +08:00
wkc
36698468f4 feat: 添加中介Service接口和实现类 
- 新增ICcdiIntermediaryService接口,定义中介服务层操作方法
- 新增CcdiIntermediaryServiceImpl实现类,提供中介CRUD功能
- 支持个人和实体中介的统一查询、详情查询、新增、修改、删除
- 实现证件号和统一社会信用代码唯一性校验
- 支持Excel批量导入功能

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-04 19:31:46 +08:00
wkc
7084b3ee6a feat: 添加中介Mapper接口和XML映射 2026-02-04 19:28:14 +08:00
wkc
b20abce3d4 feat: 添加中介查询DTO和VO类 
- 新增 CcdiIntermediaryQueryDTO 用于查询参数封装
- 新增 CcdiIntermediaryVO 用于统一列表展示
- 新增 CcdiIntermediaryPersonDetailVO 用于个人中介详情
- 新增 CcdiIntermediaryEntityDetailVO 用于实体中介详情

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-04 19:27:13 +08:00
wkc
fe0eb8eca2 feat: 添加实体中介DTO类 
- 新增 CcdiIntermediaryEntityAddDTO 用于实体中介的新增操作
- 新增 CcdiIntermediaryEntityEditDTO 用于实体中介的修改操作
- 包含完整的字段验证注解和Swagger文档注解
- 与企业基础信息表字段保持一致

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-04 19:25:59 +08:00
wkc
74c69956f9 feat: 添加个人中介DTO类 
- 创建 CcdiIntermediaryPersonAddDTO 用于新增操作
- 创建 CcdiIntermediaryPersonEditDTO 用于修改操作
- 使用 Jakarta 验证注解确保数据有效性
- 使用 Swagger 注解提供 API 文档说明

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
 2026-02-04 19:24:20 +08:00
wkc
5ccb68a98b feat: 添加实体中介实体类CcdiEnterpriseBaseInfo 2026-02-04 19:20:55 +08:00
wkc
1a944c2ba6 feat: 添加个人中介实体类CcdiBizIntermediary 2026-02-04 19:17:40 +08:00
wkc
dc8f1be4c3 中介黑名单更新 2026-02-04 19:16:34 +08:00
wkc
bc2959b93c 中介黑名单更新 2026-02-04 18:36:20 +08:00
wkc
29a2e60ee1 变更项目缩写 2026-01-30 14:15:21 +08:00