From f4b22fe8746d45956eba262d1926360d65bb6d87 Mon Sep 17 00:00:00 2001 From: xupei Date: Mon, 14 Jul 2025 19:17:21 +0800 Subject: [PATCH] =?UTF-8?q?BUGFIX:=201=E3=80=81=E8=BF=98=E6=9C=AA=E7=94=9F?= =?UTF-8?q?=E6=88=90=E5=87=BA=E7=BB=93=E6=9E=9C=E4=BD=86=E6=98=AF=E6=B2=A1?= =?UTF-8?q?=E6=9C=89=E5=A4=B1=E8=B4=A5=E7=9A=84pose=20transfer=E9=9C=80?= =?UTF-8?q?=E8=BF=94=E5=9B=9EtaskID?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../da/service/impl/GenerateServiceImpl.java | 22 +++++++++++-------- 1 file changed, 13 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java b/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java index 8553c1d8..1996913d 100644 --- a/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java +++ b/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java @@ -318,7 +318,7 @@ public class GenerateServiceImpl extends ServiceImpl i } ToProductImageResult toProductImageResult = toProductImageResults.get(0); toProductImageResult.setUrl(url); - toProductImageResult.setResultType("Success"); + toProductImageResult.setTaskStatus("Success"); // toProductImageResult.setResultType("ToProductImage"); toProductImageResultMapper.updateById(toProductImageResult); @@ -1235,15 +1235,15 @@ public class GenerateServiceImpl extends ServiceImpl i poseTransformation.setUniqueId(taskId); poseTransformation.setProductImage(productImage); poseTransformation.setPoseId(poseId); - poseTransformation.setIsLiked((byte) 1); + poseTransformation.setIsLiked((byte) 0); String taskStatus = flag ? "Executing" : "Fail"; poseTransformation.setTaskStatus(taskStatus); poseTransformation.setCreateTime(LocalDateTime.now()); - poseTransformationMapper.insert(poseTransformation); // 当需要默认like ToProductImageResultVO toProductImageResultVO = new ToProductImageResultVO(); if (Objects.nonNull(poseTransformDTO.getIsDefaultLike()) && poseTransformDTO.getIsDefaultLike()) { // 满足条件下添加到like + poseTransformation.setIsLiked((byte) 1); Integer sort = addPoseTransferLike(poseTransformDTO, poseTransformation.getId()); Integer reSort = userLikeGroupService.rearrangeChildSort(poseTransformation.getId(), CollectionType.POSE_TRANSFORM.getValue(), poseTransformDTO.getParentId(), poseTransformDTO.getUserLikeSortId()); @@ -1251,6 +1251,7 @@ public class GenerateServiceImpl extends ServiceImpl i } else if (Objects.nonNull(poseTransformDTO.getIsDefaultLike()) && Objects.nonNull(poseTransformDTO.getParentId())) { toProductImageResultVO.setParentId(poseTransformDTO.getParentId()); } + poseTransformationMapper.insert(poseTransformation); if (flag) { // 6、添加预扣除积分到redis @@ -1371,7 +1372,8 @@ public class GenerateServiceImpl extends ServiceImpl i } public List getPoseTransformationResultList(Long projectId, boolean like) { - List poseTransformations = poseTransformationMapper.selectList(new QueryWrapper().eq("project_id", projectId).eq("is_liked", like ? 1 : 0)); + List poseTransformations = poseTransformationMapper.selectList(new QueryWrapper().eq("project_id", projectId) + .eq("is_liked", like ? 1 : 0).ne("task_status", "Fail")); List vos = new ArrayList<>(); // if (poseTransformations != null && poseTransformations.size() > 1){ if (!CollectionUtils.isEmpty(poseTransformations)) { @@ -1403,20 +1405,22 @@ public class GenerateServiceImpl extends ServiceImpl i } // 添加有效数据到结果列表 - if (!"Invalid".equals(poseTransformationVO.getStatus()) && !"Failed".equals(poseTransformationVO.getStatus())) { + if (!"Invalid".equals(poseTransformationVO.getStatus()) && !"Fail".equals(poseTransformationVO.getStatus())) { vos.add(poseTransformationVO); } } else { // 处理Redis中没有缓存的情况 poseTransformationVO = CopyUtil.copyObject(item, PoseTransformationVO.class); - // todo 面对没有生成成功的情况 如何处理? - if (StringUtil.isNullOrEmpty(item.getVideoUrl())) { - continue; - } + poseTransformationVO.setTaskId(taskId); poseTransformationVO.setProductImage( minioUtil.getPreSignedUrl(item.getProductImage(), CommonConstant.MINIO_IMAGE_EXPIRE_TIME)); + // todo 面对没有生成结束的情况,返回taskId + if (StringUtil.isNullOrEmpty(item.getVideoUrl())) { + vos.add(poseTransformationVO); + continue; + } // 处理各种URL processUrl(poseTransformationVO.getGifUrl(), url -> poseTransformationVO.setGifUrl(minioUtil.getPreSignedUrl(url, CommonConstant.MINIO_IMAGE_EXPIRE_TIME)));