|
|
602eb84f9c
|
feat(video): 添加缩略图URL设置功能
- 在视频片段获取器中新增缩略图URL字段
- 完善图片源信息的处理逻辑- 提高视频资源信息的完整性
|
2025-10-20 10:29:44 +08:00 |
|
|
|
8d24e7f9e5
|
feat(source): 添加缩略图URL字段并优化商品详情展示逻辑
- 在 SourceRespVO 中新增 thumbUrl 字段用于存储缩略图地址- 修改 GoodsServiceImpl 中的商品详情封面图设置逻辑，优先使用缩略图
- 更新 SourceMapper.xml 查询语句，增加 thumb_url 字段的查询支持
|
2025-10-20 10:20:12 +08:00 |
|
|
|
8eed685373
|
feat(source): 添加缩略图字段支持
- 在SourceEntity中新增thumbUrl字段用于存储缩略图地址- 在ZTSourceDataService中设置缩略图URL并优化裁剪配置逻辑
- 更新SourceMapper.xml中的SQL语句以支持缩略图字段的插入和更新
- 移除不必要的URL查询条件以提高查询灵活性
|
2025-10-20 10:05:22 +08:00 |
|
|
|
2b79302874
|
feat(printer): 引入唯一处理标识符避免文件冲突
- 添加 UUID 依赖以生成唯一标识符
-为打印任务生成唯一处理 ID，防止多线程文件名冲突
- 更新原图、水印图及旋转图片的文件命名逻辑
- 确保每个打印任务使用独立的临时文件名
|
2025-10-16 15:37:51 +08:00 |
|
|
|
56e1081304
|
refactor(storage): 移除不再使用的人脸存储路径常量
ZhenTu-BE/pipeline/head This commit looks good
- 删除 StorageConstant 中的 VIID_FACE 常量定义
- 移除 FaceCleaner 中对 VIID_FACE 的引用和相关文件清理逻辑
- 清理相关的导入语句和静态引用
|
2025-10-15 19:13:48 +08:00 |
|
|
|
658e741611
|
feat(printer): 添加图片方向检测与自动旋转功能
- 引入 ImageUtils 工具类处理图片旋转逻辑
- 实现打印前对竖图自动旋转为横图处理
- 完成水印处理后将图片旋转回原始方向-优化临时文件清理逻辑，确保所有中间文件被删除
- 添加图片方向判断方法 isLandscape- 新增图片旋转90度和270度的工具方法
|
2025-10-15 18:53:28 +08:00 |
|
|
|
d5cd1924f5
|
feat(task): 添加视频生成通知防重机制- 新增Redis缓存键VIDEO_NOTIFICATION_CACHE_KEY用于记录通知发送状态
- 设置通知发送间隔为2分钟，防止重复发送
- 在发送通知前检查缓存，若3分钟内已发送则跳过- 发送成功后更新Redis缓存并设置过期时间
- 添加相关日志记录以方便追踪通知发送情况
|
2025-10-15 18:43:54 +08:00 |
|
|
|
645afbaf0c
|
feat(printer): 添加打印照片水印处理功能
- 引入图片水印处理相关依赖和工具类
- 实现根据景区配置动态添加水印逻辑
- 支持从配置中读取存储类型和水印类型
- 下载原始图片并应用水印处理
- 将处理后的水印图片上传至指定存储服务
- 打印任务使用水印图片URL替代原始URL
- 增加异常失败时回处理确保水印退到原始图片- 清理处理过程中产生的临时文件
|
2025-10-15 17:37:26 +08:00 |
|
|
|
a7ede3303d
|
refactor(task): 移除重复的景区配置查询逻辑
ZhenTu-BE/pipeline/head This commit looks good
- 删除了 DownloadNotificationTasker 中多次调用的 getScenicMpConfig 方法
- 简化了视频下载通知任务的执行流程- 提高代码可读性和维护性
- 避免不必要的数据库查询操作
|
2025-10-14 20:32:36 +08:00 |
|
|
|
aa7330000f
|
fix(task): 避免重复发送下载和过期通知
ZhenTu-BE/pipeline/head This commit looks good
- 在发送下载通知前检查用户是否已接收通知
- 在发送过期通知前检查用户是否已接收通知- 在发送额外下载通知前检查用户是否已接收通知
- 使用ConcurrentHashMap.newKeySet()确保线程安全- 添加调试日志以追踪重复通知的跳过情况- 优化通知逻辑以提升定时任务执行效率
|
2025-10-14 20:31:45 +08:00 |
|
|
|
29f4bbf2d8
|
feat(message): 添加ZT消息生产者空实现服务
- 创建 ZtMessageProducerNoOpService 类作为 Kafka 禁用时的替代实现- 实现 ConditionalOnProperty 注解，当 kafka.enabled=false 时激活该服务- 覆写 send 方法，仅记录日志而不实际发送消息
- 添加构造函数以满足父类依赖要求
- 提供详细注释说明服务用途和实现逻辑
|
2025-10-14 20:28:00 +08:00 |
|
|
|
ad42254ea0
|
refactor(task): 移除通知模块依赖
- 删除了对通知模块的包引用
- 移除了通知模块相关的类导入- 清理了与通知功能相关的代码依赖
-优化了任务服务实现类的依赖结构
- 简化了下载通知任务器的代码引用
- 解除了通知工厂类的直接依赖关系
|
2025-10-14 19:38:47 +08:00 |
|
|
|
0ceecf0488
|
fix(message): 将消息相关接口的日志级别从 info 调整为 debug
- 修改消息列表查询接口的日志级别- 修改获取消息通道列表接口的日志级别- 统一调整日志输出方式以减少生产环境日志量
|
2025-10-14 19:20:41 +08:00 |
|
|
|
311008cbf2
|
feat(message): 集成ZT消息服务发送通知
ZhenTu-BE/pipeline/head This commit looks good
- 在TaskTaskServiceImpl中引入ZtMessageProducerService依赖
- 替换原有微信通知逻辑，使用ZT消息服务发送视频生成通知- 在DownloadNotificationTasker中引入ZtMessageProducerService依赖
- 修改视频下载通知发送逻辑，使用ZT消息服务
- 修改视频过期提醒通知逻辑，使用ZT消息服务
- 调整额外通知时间配置获取方式，从scenicConfigManager获取
- 统一构建通知消息参数格式，包含data和page信息
- 添加详细的日志记录，便于追踪消息发送过程
|
2025-10-14 19:06:30 +08:00 |
|
|
|
f54d40d026
|
feat(message):为消息添加唯一标识符支持
- 在 ZtMessage DTO 中新增 messageId 字段
- 发送消息前自动生成 UUID 作为默认 messageId
- 更新 Kafka 生产者日志，包含 messageId 以便追踪
- 增强错误日志记录，附带 messageId 提升调试效率
|
2025-10-14 18:27:15 +08:00 |
|
|
|
3cb12c13c2
|
feat(printer):优化用户照片添加逻辑并返回结果ID
ZhenTu-BE/pipeline/head This commit looks good
- 修改 addUserPhoto 方法参数，使用 MemberPrintEntity 实体传参- 在 PrinterMapper.xml 中配置 insert 语句返回主键 ID- 更新 addUserPhotoFromSource 方法返回值为 List<Integer>
- 添加异常处理和日志记录
- 调整 AppPrinterController 接口返回照片 ID 列表
|
2025-10-14 11:45:46 +08:00 |
|
|
|
feac2e8d93
|
refactor(config): 移除ScenicConfigManager中的冗余代码
- 删除了未使用的configMap字段- 移除了基于Map的构造函数- 清理了所有与configMap相关的getter方法
- 移除了hasKey和hasNonNullValue方法
- 删除了获取所有配置键和配置数量的方法
- 移除了配置子集和扁平化配置相关功能
- 简化了toString方法的实现
|
2025-10-12 01:09:54 +08:00 |
|
|
|
be375067ce
|
feat(message): 移除ZT消息生产者示例代码- 删除ZtMessageProducerExample类及相关依赖
- 移除示例消息发送逻辑
- 清理无用的HashMap和日志记录代码
- 移除条件注解@ConditionalOnProperty配置
- 删除消息构建及发送示例实现
|
2025-10-11 20:34:00 +08:00 |
|
|
|
7dec2e614c
|
feat(watchdog): 增强任务监控告警机制
- 引入ZtMessageProducerService实现消息通知
- 添加任务积压、失败任务和长时间运行任务的分类监控
- 实现异常通知计数器，限制重复告警次数
-优化告警逻辑，支持异常恢复后计数器重置
- 移除旧的通知工厂依赖，统一使用消息队列发送
- 增加长时任务监控的清理机制，避免无效计数累积
|
2025-10-11 20:33:49 +08:00 |
|
|
|
51d0716606
|
Merge branch 'message-microservice'
# Conflicts:
# src/main/java/com/ycwl/basic/integration/CLAUDE.md
|
2025-10-11 15:07:52 +08:00 |
|
|
|
765998bd97
|
docs(integration): 移除示例代码并更新配置说明- 删除设备集成测试中的默认配置启用示例
- 移除了消息集成组件中的示例引用
- 更新ZT-Message集成概述，去除对旧文档的引用
- 简化目录结构展示，移除example模块
- 清理冗余的配置键值说明- 统一删除各模块下的example目录引用
- 优化文档结构，提高可读性
|
2025-10-11 11:24:42 +08:00 |
|
|
|
5f4f89112b
|
refactor(scenic): 移除ScenicV2WithConfigDTO并简化实体转换逻辑
ZhenTu-BE/pipeline/head This commit looks good
- 删除ScenicV2WithConfigDTO类定义
- 更新ScenicV2Controller中的导入依赖- 更新ScenicV2Client中的导入依赖
- 更新ScenicIntegrationService中的导入依赖
- 更新ScenicRepository中的导入依赖
- 简化convertToScenicEntity方法参数类型
- 移除手动组合ScenicV2WithConfigDTO的代码逻辑
|
2025-10-11 00:11:42 +08:00 |
|
|
|
d68b062951
|
refactor(repository):重构景区配置管理逻辑- 引入 ScenicConfigManager 管理配置信息
- 移除手动构建 configMap 的逻辑
- 修改 convertToScenicEntity 方法签名，支持传入配置管理器
- 使用 configManager 替代直接从 DTO 获取配置值的方式
- 统一配置项获取方式，增强代码可维护性与扩展性
|
2025-10-11 00:10:25 +08:00 |
|
|
|
99857db006
|
feat(examples): 移除设备和问卷集成示例代码
- 删除默认配置集成服务使用示例类- 移除设备配置筛选功能使用示例
- 清理设备集成基础操作示例代码
- 移除设备集成降级机制示例
- 删除Kafka集成使用示例
- 清理问卷集成服务示例代码
|
2025-10-11 00:09:33 +08:00 |
|
|
|
e8c645a3c0
|
refactor(device): 移除设备与景区的冗余配置接口
ZhenTu-BE/pipeline/head There was a failure building this commit
- 删除 DeviceV2Controller 中的设备配置相关接口
- 删除 ScenicV2Controller 中的景区配置相关接口
- 移除 DeviceConfigV2Client 中的扁平化配置接口
- 移除 DeviceV2Client 中的设备详情配置接口
- 更新 DeviceIntegrationExample 示例代码
- 移除 DeviceIntegrationFallbackExample 中的配置缓存示例
- 删除 DeviceConfigIntegrationService 中的配置获取方法
- 删除 DeviceIntegrationService 中的设备配置服务方法- 移除 RenderWorkerV2Client 中的工作器配置接口- 删除 RenderWorkerConfigIntegrationService 中的配置键名- 移除 RenderWorkerIntegrationService 中的工作器配置方法
- 删除 ScenicConfigV2Client 中的扁平化配置接口
- 移除 ScenicV2Client 中的景区配置接口
- 更新 ScenicIntegrationExample 示例代码
- 删除 ScenicConfigIntegrationService 中的配置获取方法
- 删除 ScenicIntegrationService 中的景区配置服务方法
- 修改 ScenicRepository 中景区实体获取逻辑
|
2025-10-10 23:55:17 +08:00 |
|
|
|
fe8068b3d9
|
refactor(scenic): 重构景区配置响应结构
- 移除了过时的配置字段，如预约流程、强制完成时间等
- 调整了字段顺序并添加分类注释（基础配置、功能开关、提示文案）
-保留并优化核心配置项，如水印URL、防录屏类型等
- 清理了未使用的导入包和冗余代码
- 统一了优惠券开关字段，移除重复定义
|
2025-10-10 13:46:59 +08:00 |
|
|
|
c689496130
|
feat(scenic): 添加分享功能配置项
- 在ScenicConfigResp中新增shareEnable字段
- 在AppScenicController中设置shareEnable默认值为true
- 支持景区配置是否开启分享功能
- 保持与shareBeforeBuy配置项的一致性处理
|
2025-10-10 10:38:47 +08:00 |
|
|
|
7e16ad35e7
|
feat(app): 新增分享前购买配置项
- 在AppScenicController中增加shareBeforeBuy配置项- 默认值设置为true以启用该功能- 更新响应对象以支持新的配置选项
|
2025-10-10 09:26:42 +08:00 |
|
|
|
1727619b29
|
refactor(kafka): 将人脸识别处理改为异步执行- 引入CompletableFuture实现异步处理
ZhenTu-BE/pipeline/head This commit looks good
- 修改processFaceRecognition方法为异步版本
- 移除原同步处理中的try-catch块
- 更新方法返回类型从boolean改为void-保留处理成功和失败的状态更新逻辑- 添加异步处理成功后的日志记录
|
2025-10-04 10:12:37 +08:00 |
|
|
|
3099e68a97
|
refactor(logging): 调整人脸处理服务中的日志级别
- 将接收到人脸消息的日志级别从 info 调整为 debug
- 移除了部分冗余的 info 级别日志输出
- 统一异常处理中的日志记录方式
-优化日志内容，减少不必要的信息输出
- 确保关键操作仍然保留适当日志记录- 提升系统在高并发下的日志可读性与性能
|
2025-10-03 13:46:22 +08:00 |
|
|
|
db86c82bc8
|
refactor(task):优化视频片段获取逻辑并增强日志记录
- 移除任务执行前的空列表检查，统一通过VideoPieceGetter.addTask处理
- 增强Placeholder初始化阶段的日志输出，区分有无templateId情况- 细化计数器递减过程中的日志信息，记录设备关联及剩余数量
- 完善进度检查时的日志内容，增加已完成与未完成的统计显示- 补充Callback调用条件判断，避免重复触发并记录调用状态
- 添加兜底逻辑中对Callback是否已触发的判断和相应日志提示
|
2025-10-01 22:01:34 +08:00 |
|
|
|
f33ce8e7a7
|
feat(video):优化视频切片任务处理逻辑
ZhenTu-BE/pipeline/head This commit looks good
- 添加对配对设备的处理，确保主设备也能正确执行切片任务
- 调整计数器逻辑，使主设备和配对设备的未完成占位符计数一致
- 增强日志记录，明确标识设备占位符满足情况
- 改进进度计算方式，更准确地反映任务完成状态- 在所有占位符满足时提前调用回调函数，提升任务执行效率
|
2025-10-01 21:22:19 +08:00 |
|
|
|
de65fa1dd8
|
feat(scenic): 添加水印URL配置支持
- 在ScenicConfigResp中新增watermarkUrl字段
- 在AppScenicController中设置水印URL配置项
- 支持从scenicConfig中获取watermark_url配置值
|
2025-10-01 17:00:44 +08:00 |
|
|
|
132a539bb6
|
fix(kafka): 调整人脸识别消息处理逻辑，确保消息始终被消费- 修改消息处理失败时的确认机制，避免消息堆积
- 即使人脸样本保存或识别处理失败，也消费消息防止重复处理
- 异常情况下同样确认消息消费，记录错误日志而非阻塞流程- 优化日志记录，明确区分处理结果与消息确认状态
|
2025-09-28 11:26:01 +08:00 |
|
|
|
9f66544a29
|
feat(source): 处理ZT-Source消息时支持设备裁剪配置
- 新增DeviceRepository依赖注入
- 获取设备配置管理器并检查裁剪配置
- 根据裁剪配置设置缩略图URL
-优化sourceEntity数据处理逻辑
|
2025-09-27 23:28:50 +08:00 |
|
|
|
f4a16b5b09
|
feat(dto): 添加位置信息字段支持
- 在 ZTSourceMessage DTO 中新增 posJson 字段
- 更新数据库插入语句以支持 posJson 字段存储
- 调整日志输出内容，突出关键业务标识
- 在数据服务层增加对 posJson 的处理逻辑
|
2025-09-27 23:09:44 +08:00 |
|
|
|
9bc34fcfdb
|
feat(kafka): 新增ZT-Source Kafka消息处理功能
- 新增ZTSourceMessage实体类用于接收Kafka消息
- 新增ZTSourceConsumerService监听zt-source主题
- 新增ZTSourceDataService处理消息并保存至数据库- 扩展SourceMapper支持从ZT-Source消息新增素材
- 实现照片类型素材的解析、校验与存储逻辑
- 添加Kafka手动ACK确认机制确保消息可靠处理
|
2025-09-27 22:16:47 +08:00 |
|
|
|
4b01e4cf82
|
feat(task):优化人脸识别任务中的样本排序逻辑
- 引入HashMap以支持按ID顺序排序人脸样本列表
- 在筛选前对搜索结果按分数降序排序
- 简化设备照片限制逻辑，去除冗余的时间排序步骤
- 提升匹配准确性和处理效率
|
2025-09-27 13:45:05 +08:00 |
|
|
|
f885f734ad
|
perf(viid):优化线程池配置与图片裁剪内存管理
- 调整线程池核心线程数为8，最大线程数为32，空闲时间10秒- 队列大小从1024降至100，提升响应速度
- 添加CallerRunsPolicy策略，防止任务丢失
- 图片裁剪方法增加try-finally块确保资源释放- 显式调用image.flush()和System.gc()优化内存使用
- ByteArrayOutputStream关闭操作添加异常捕获
-修复潜在的内存泄漏问题
|
2025-09-27 13:17:48 +08:00 |
|
|
|
ddbc2a0edb
|
fix(biz):修复用户购买检查逻辑
- 修改PriceBiz中checkUserBuyItem方法的模板ID参数为-1
- 在FaceServiceImpl中增加对模板ID的购买检查逻辑- 确保用户购买状态判断的准确性
|
2025-09-27 01:50:26 +08:00 |
|
|
|
da89067c48
|
refactor(task):优化视频片段获取任务的设备计数逻辑
- 将 currentUnFinPlaceholder从 List 类型改为 Map<String, AtomicInteger>- 使用 AtomicInteger 跟踪每个设备的未完成任务数量
- 在设备任务完成时正确减少计数并清理已完成的设备
- 更新进度日志以反映去重后的设备总数
|
2025-09-27 01:07:52 +08:00 |
|
|
|
2836326518
|
fix(face):修复vlog渲染状态显示错误问题
ZhenTu-BE/pipeline/head This commit looks good
- 调整step3状态逻辑，确保渲染中状态正确显示
- 修改状态文本提示，优化用户体验
-修复渲染完成状态判断逻辑错误
|
2025-09-26 17:34:12 +08:00 |
|
|
|
6091d41df9
|
feat(face):优化视频切分任务筛选逻辑
- 按设备ID分组并按创建时间倒序排序
- 根据设备配置限制视频数量
- 修复日志中原始
|
2025-09-26 16:43:20 +08:00 |
|
|
|
d4f9f1fe0d
|
feat(face):优化视频重切任务的样本选择逻辑
- 根据设备配置限制视频样本数量
- 实现按设备分组并应用数量限制- 更新视频重切任务中的样本ID列表
- 保留原有照片与视频数量比较逻辑
|
2025-09-26 16:20:31 +08:00 |
|
|
|
d860996f6d
|
feat(face):优化视频重切任务的样本选择逻辑
- 根据设备配置限制视频样本数量
- 实现按设备分组并应用数量限制- 更新视频重切任务中的样本ID列表
- 保留原有照片与视频数量比较逻辑
|
2025-09-26 16:15:34 +08:00 |
|
|
|
1b2793215f
|
fix(video): 解决并发环境下视频片段处理的文件名冲突问题
ZhenTu-BE/pipeline/head This commit looks good
- 为输出文件名添加时间戳和线程ID后缀，确保唯一性
-为临时文件名添加时间戳和线程ID后缀，防止并发冲突
- 避免因文件名重复导致的视频处理错误
|
2025-09-26 14:26:09 +08:00 |
|
|
|
4f1443a3ca
|
fix(video): 处理空imgSource情况- 添加空值检查以避免保存空source记录
ZhenTu-BE/pipeline/head This commit looks good
- 记录警告日志当imgSource为空时- 返回false以跳过无效处理流程
|
2025-09-26 12:39:22 +08:00 |
|
|
|
aba9fb0a15
|
feat(printer): 添加用户购买项设置的Redis缓存控制
- 引入RedisTemplate依赖用于缓存控制
- 新增60秒的缓存键避免重复处理用户购买项
- 在setUserIsBuyItem方法中实现缓存检查逻辑- 添加TimeUnit依赖支持缓存过期时间设置
- 定义USER_PHOTO_LIST_TO_PRINTER缓存键前缀
|
2025-09-26 12:39:17 +08:00 |
|
|
|
ab3208c9df
|
feat(kafka): 添加手动提交模式支持以增强消息处理可靠性
- 在 KafkaConfig 中新增 manualCommitKafkaListenerContainerFactory 配置
- 启用手动提交模式并设置 AckMode 为 MANUAL_IMMEDIATE
- 修改 FaceProcessingKafkaService 使用新的容器工厂- 添加 Acknowledgment 参数以控制消息提交时机
-仅在人脸样本保存和识别全部成功后才手动确认消息
- 处理失败时不再调用 ack.acknowledge()使消息可重新消费
- 更新 processFaceRecognition 方法返回处理结果状态
- 增强异常处理逻辑，确保失败情况下不提交消息
|
2025-09-25 18:46:15 +08:00 |
|
|
|
09e376e089
|
refactor(kafka): 统一时人脸消息时间类型为Date
- 将FaceProcessingMessage中的LocalDateTime替换为Date类型- 更新消息创建工厂方法以使用Date参数
- 调整Kafka服务中时间转换逻辑以匹配新类型
- 移除LocalDateTime相关的导入和引用- 更新字段注释以反映新的时间类型
|
2025-09-25 18:09:17 +08:00 |
|
