aidlab/aida_back
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

edit 产品图失败会导致sort不对试验3

Browse Source
This commit is contained in:
litianxiang
2025-12-17 14:12:20 +08:00
parent b459148d58
commit 7720c8c771
1 changed files with 28 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
src/main/java/com/ai/da/service/impl/UserLikeGroupServiceImpl.java
View File

@@ -1461,18 +1461,18 @@ public class UserLikeGroupServiceImpl extends ServiceImpl<UserLikeGroupMapper, U
if (StringUtil.isNullOrEmpty(fluxResult)) { if (StringUtil.isNullOrEmpty(fluxResult)) {
toProductImageResult.setStatus("Fail"); toProductImageResult.setStatus("Fail");
toProductImageResultMapper.updateById(toProductImageResult); toProductImageResultMapper.updateById(toProductImageResult);
collectionSortMapper.delete(new QueryWrapper<CollectionSort>().lambda().eq(CollectionSort::getRelationId, toProductImageResult.getId()).orderByDesc(BaseEntity::getCreateTime).last("limit 1")); sortRank(toProductImageResult);
results.add(new MagicToolResultVO(taskId, "Fail")); results.add(new MagicToolResultVO(taskId, "Fail"));
} else if (fluxResult.equals("Fail") || fluxResult.equals("Pending")) { } else if (fluxResult.equals("Fail") || fluxResult.equals("Pending")) {
toProductImageResult.setStatus(fluxResult); toProductImageResult.setStatus(fluxResult);
toProductImageResultMapper.updateById(toProductImageResult); toProductImageResultMapper.updateById(toProductImageResult);
collectionSortMapper.delete(new QueryWrapper<CollectionSort>().lambda().eq(CollectionSort::getRelationId, toProductImageResult.getId()).orderByDesc(BaseEntity::getCreateTime).last("limit 1")); sortRank(toProductImageResult);
results.add(new MagicToolResultVO(taskId, fluxResult)); results.add(new MagicToolResultVO(taskId, fluxResult));
} else { } else {
fluxResult="Fail"; fluxResult="Fail";
toProductImageResult.setStatus(fluxResult); toProductImageResult.setStatus(fluxResult);
toProductImageResultMapper.updateById(toProductImageResult); toProductImageResultMapper.updateById(toProductImageResult);
collectionSortMapper.delete(new QueryWrapper<CollectionSort>().lambda().eq(CollectionSort::getRelationId, toProductImageResult.getId()).orderByDesc(BaseEntity::getCreateTime).last("limit 1")); sortRank(toProductImageResult);
results.add(new MagicToolResultVO(taskId, fluxResult)); results.add(new MagicToolResultVO(taskId, fluxResult));
// results.add(processFluxResult(fluxResult, toProductImageResult, taskId, toProductImageRecord.getPrompt())); // results.add(processFluxResult(fluxResult, toProductImageResult, taskId, toProductImageRecord.getPrompt()));
// // 扣积分 // // 扣积分
@@ -1522,6 +1522,31 @@ public class UserLikeGroupServiceImpl extends ServiceImpl<UserLikeGroupMapper, U
return results; return results;
} }
private void sortRank(ToProductImageResult toProductImageResult) {
LambdaQueryWrapper<CollectionSort> collectionSortLambdaQueryWrapper = new LambdaQueryWrapper<>();
collectionSortLambdaQueryWrapper.eq(CollectionSort::getRelationId, toProductImageResult.getId());
// 查询符合条件的CollectionSort集合
List<CollectionSort> collectionSorts = collectionSortMapper.selectList(collectionSortLambdaQueryWrapper);
if (!collectionSorts.isEmpty()) {
// 按照创建时间排序，找到最新的一条记录
collectionSorts.sort((a, b) -> b.getCreateTime().compareTo(a.getCreateTime()));
// 删除最新的一条记录
CollectionSort latestSort = collectionSorts.remove(0);
collectionSortMapper.deleteById(latestSort.getId());
// 将其他记录的sort值减一并更新回数据库
for (CollectionSort sort : collectionSorts) {
if (sort.getSort() != null && sort.getSort() > 0) {
sort.setSort(sort.getSort() - 1);
collectionSortMapper.updateById(sort);
}
}
}
}
public static String convert(InputStream inputStream) { public static String convert(InputStream inputStream) {
try (BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))) { try (BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))) {
return reader.lines().collect(Collectors.joining("\n")); return reader.lines().collect(Collectors.joining("\n"));