用户服务-修改更新用户PV值接口

userCenter_service/src/main/java/com/bjtdba/userCenter/controller/UserController.java

@@ -632,7 +632,7 @@ public class UserController {
         return ApiResponse.success(userService.modifyUserContribute(request));
     }
 
-    @PostMapping("/modifyPV")
+    @PostMapping("/modifyUserPV")
     public ApiResponse<ModifyPVResponse> modifyUserPV(
             @Validated @RequestBody ModifyPVRequest request) {
         return ApiResponse.success(userService.modifyUserPV(request));

userCenter_service/src/main/java/com/bjtdba/userCenter/dao/UserDao.java

@@ -65,6 +65,9 @@ public interface UserDao {
     int updateUserContribute(@Param("uid") Integer uid,
                         @Param("newContribute") BigDecimal newContribute);
 
+    int updateUserPv(@Param("uid") Integer uid,
+                             @Param("newPv") BigDecimal newPv);
+
     int updateUserByUid(UserEntity userEntity);
 
     int insertUserByUserEntity(@Param("userEntity") UserEntity userEntity);

userCenter_service/src/main/java/com/bjtdba/userCenter/exception/BusinessException.java

@@ -54,6 +54,10 @@ public class BusinessException extends RuntimeException {
         return new BusinessException(500, "贡献值更新失败，请重试");
     }
 
+    public static BusinessException createPvFailed() {
+        return new BusinessException(500, "Pv值记录创建失败，请重试");
+    }
+
     public static BusinessException createUserFailed() {
         return new BusinessException(500, "创建用户信息失败");
     }

userCenter_service/src/main/java/com/bjtdba/userCenter/service/impl/UserServiceImpl.java

@@ -372,10 +372,34 @@ public class UserServiceImpl  implements UserService {
 
     @Override
     public ModifyPVResponse modifyUserPV(ModifyPVRequest request) {
+        // 1. 获取用户并加锁
+        UserEntity userEntity = userDao.getUserInfoByUidForUpdate(request.getUid());
+        if (userEntity == null) {
+            throw BusinessException.userNotFound();
+        }
+
+        // 2. PV值操作处理
+        BigDecimal newPv;
+        newPv = userEntity.getPv().add(request.getPv());
+
+        // 3. 更新用户贡献值（带乐观锁）
+        int updateCount = userDao.updateUserPv(
+                request.getUid(),
+                newPv
+        );
+        if (updateCount == 0) {
+            throw BusinessException.updateContributeFailed();
+        }
+
+        // 4. 创建贡献值记录
         UserPvLogEntity record = buildModifyPVRecord(request);
         record.setAddtime(LocalDateTime.now().toEpochSecond(ZoneOffset.UTC));
-        userPvLogDao.insertByEntity(record);
+        int createResult = userPvLogDao.insertByEntity(record);
+        if (createResult == 0) {
+            throw BusinessException.createPvFailed();
+        }
 
+        // 5. 构建响应
         return ModifyPVResponse.builder()
                 .id(record.getId())
                 .uid(record.getUid())
@@ -387,17 +411,18 @@ public class UserServiceImpl  implements UserService {
                 .settlementTime(record.getSettlementTime())
                 .build();
     }
-        private UserPvLogEntity buildModifyPVRecord(ModifyPVRequest request) {
-            UserPvLogEntity record = new UserPvLogEntity();
-            record.setUid(request.getUid());
-            record.setPv(request.getPv());
-            record.setStatus(request.getStatus());
-            record.setMark(request.getMark());
-            record.setOrderId(request.getOrderId());
-            record.setOrderType(request.getOrderType());
-            if (request.getStatus() == 1) {
-                record.setSettlementTime(Timestamp.valueOf(LocalDateTime.now()));
-            }
-            return record;
+
+    private UserPvLogEntity buildModifyPVRecord(ModifyPVRequest request) {
+        UserPvLogEntity record = new UserPvLogEntity();
+        record.setUid(request.getUid());
+        record.setPv(request.getPv());
+        record.setStatus(request.getStatus());
+        record.setMark(request.getMark());
+        record.setOrderId(request.getOrderId());
+        record.setOrderType(request.getOrderType());
+        if (request.getStatus() == 1) {
+            record.setSettlementTime(Timestamp.valueOf(LocalDateTime.now()));
+        }
+        return record;
     }
 }

userCenter_service/src/main/resources/mapper/UserExternalMapper.xml

@@ -79,6 +79,12 @@
         WHERE uid = #{uid}
     </update>
 
+    <update id="updateUserPv">
+        UPDATE rrx_user SET
+            pv = #{newPv}
+        WHERE uid = #{uid}
+    </update>
+
     <insert id="insertUserByUserEntity" useGeneratedKeys="true" keyProperty="userEntity.uid" keyColumn="uid">
         INSERT INTO rrx_user
         <trim prefix="(" suffix=")" suffixOverrides=",">