From 766e75f2ed67bf004b6d9a39e87c91bc0a7c1ecc Mon Sep 17 00:00:00 2001
From: xupei <xupei3360@163.com>
Date: Thu, 10 Jul 2025 13:38:00 +0800
Subject: [PATCH] =?UTF-8?q?BUGFIX:=20=E6=89=B9=E9=87=8F=E7=94=9F=E6=88=90?=
 =?UTF-8?q?=E7=A7=AF=E5=88=86=E6=89=A3=E9=99=A4=E6=9C=89=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/ai/da/service/impl/DesignServiceImpl.java   |  4 ++--
 .../com/ai/da/service/impl/GenerateServiceImpl.java |  4 ++--
 .../da/service/impl/UserLikeGroupServiceImpl.java   | 13 +++++++++----
 3 files changed, 13 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/ai/da/service/impl/DesignServiceImpl.java b/src/main/java/com/ai/da/service/impl/DesignServiceImpl.java
index 2fb16677..72b265b8 100644
--- a/src/main/java/com/ai/da/service/impl/DesignServiceImpl.java
+++ b/src/main/java/com/ai/da/service/impl/DesignServiceImpl.java
@@ -2345,9 +2345,9 @@ public class DesignServiceImpl extends ServiceImpl<DesignMapper, Design> impleme
                     Boolean b = pythonService.poseTransformationBatch(poseTransformBatchDTO.getProductImage(), poseTransformBatchDTO.getPoseId(), taskId);
                     if (b){
                         // 6、添加预扣除积分到redis
-                        creditsService.addRecordToCreditsDeduction(accountId, uuid, creditsEventsEnum, cloudTaskDTO.getNums());
+                        creditsService.addRecordToCreditsDeduction(accountId, taskBatchId, creditsEventsEnum, cloudTaskDTO.getNums());
                         // 6.1 添加积分扣除记录到db
-                        creditsService.preInsert(accountId, creditsEventsEnum.getName(), uuid, Boolean.TRUE, null, cloudTaskDTO.getNums());
+                        creditsService.preInsert(accountId, creditsEventsEnum.getName(), taskBatchId, Boolean.TRUE, null, cloudTaskDTO.getNums());
                     }else {
                         throw new BusinessException("pose transformation error", ResultEnum.ERROR.getCode());
                     }
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 07ec661f..78dd3a4b 100644
--- a/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java
+++ b/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java
@@ -1571,8 +1571,8 @@ public class GenerateServiceImpl extends ServiceImpl<GenerateMapper, Generate> i
         // 3、执行积分扣除
         String accountId = taskId.substring(taskId.lastIndexOf("-") + 1);
         String uuid = taskId.substring(0, taskId.lastIndexOf("-"));
-        Boolean flag = creditsService.taskCreditsDeduction(Long.parseLong(accountId), uuid);
-        if (flag) creditsService.updateChangedCredits(accountId, uuid);
+        Boolean flag = creditsService.taskCreditsDeduction(Long.parseLong(accountId), taskIdBatch);
+        if (flag) creditsService.updateChangedCredits(accountId, taskIdBatch);
     }
 
     /**
diff --git a/src/main/java/com/ai/da/service/impl/UserLikeGroupServiceImpl.java b/src/main/java/com/ai/da/service/impl/UserLikeGroupServiceImpl.java
index 267860d4..e7eb73db 100644
--- a/src/main/java/com/ai/da/service/impl/UserLikeGroupServiceImpl.java
+++ b/src/main/java/com/ai/da/service/impl/UserLikeGroupServiceImpl.java
@@ -2792,13 +2792,13 @@ public class UserLikeGroupServiceImpl extends ServiceImpl<UserLikeGroupMapper, U
             GenerateResultVO generateResultVO = new GenerateResultVO(taskId, toProductImageResult.getId(), url, status, null);
             redisUtil.addToString(key, new Gson().toJson(generateResultVO), CommonConstant.GENERATE_RESULT_EXPIRE_TIME);
 
-            Long accountId = Long.parseLong(taskId.substring(taskId.lastIndexOf("-") + 1));
+            /*Long accountId = Long.parseLong(taskId.substring(taskId.lastIndexOf("-") + 1));
             if (!status.equals("Invalid")) {
                 // 4、扣除积分
                 Boolean b = creditsService.taskCreditsDeduction(accountId, taskId);
                 // 3、记录积分变更
                 if (b) creditsService.updateChangedCredits(String.valueOf(accountId), taskId);
-            }
+            }*/
         }
 
     }
@@ -2841,13 +2841,13 @@ public class UserLikeGroupServiceImpl extends ServiceImpl<UserLikeGroupMapper, U
             GenerateResultVO generateResultVO = new GenerateResultVO(taskId, toProductImageResult.getId(), url, status, null);
             redisUtil.addToString(key, new Gson().toJson(generateResultVO), CommonConstant.GENERATE_RESULT_EXPIRE_TIME);
 
-            Long accountId = Long.parseLong(taskId.substring(taskId.lastIndexOf("-") + 1));
+            /*Long accountId = Long.parseLong(taskId.substring(taskId.lastIndexOf("-") + 1));
             if (!status.equals("Invalid")) {
                 // 4、扣除积分
                 Boolean b = creditsService.taskCreditsDeduction(accountId, taskId);
                 // 3、记录积分变更
                 if (b) creditsService.updateChangedCredits(String.valueOf(accountId), taskId);
-            }
+            }*/
         }
     }
 
@@ -2922,5 +2922,10 @@ public class UserLikeGroupServiceImpl extends ServiceImpl<UserLikeGroupMapper, U
         cloudTask.setStatus(1);
         cloudTask.setCompletedNum(cloudTask.getNums());
         cloudTaskMapper.updateById(cloudTask);
+
+        // 扣除积分
+        Boolean b = creditsService.taskCreditsDeduction(cloudTask.getAccountId(), cloudTask.getTaskId());
+        // 记录积分变更
+        if (b) creditsService.updateChangedCredits(String.valueOf(cloudTask.getAccountId()), cloudTask.getTaskId());
     }
 }