直播积分添加

fs-service-system/src/main/java/com/fs/live/service/impl/LiveCompletionPointsRecordServiceImpl.java

@@ -6,6 +6,7 @@ import com.fs.common.exception.BaseException;
 import com.fs.live.domain.Live;
 import com.fs.live.domain.LiveCompletionPointsRecord;
 import com.fs.live.domain.LiveWatchConfig;
+import com.fs.live.enums.FsUserIntegralLogTypeEnum;
 import com.fs.live.mapper.LiveCompletionPointsRecordMapper;
 import com.fs.live.service.ILiveCompletionPointsRecordService;
 import com.fs.live.service.ILiveService;
@@ -24,6 +25,7 @@ import java.math.RoundingMode;
 import java.time.LocalDate;
 import java.time.ZoneId;
 import java.time.temporal.ChronoUnit;
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 
@@ -223,13 +225,15 @@ public class LiveCompletionPointsRecordServiceImpl implements ILiveCompletionPoi
             "live_completion_" + recordId,             // busId: 业务ID
             null                                       // tuiUserId: 推荐人ID，这里为null
         );
-
+        List<FsUser> addUserLists = new ArrayList<FsUser>();
+        addUserLists.add(user);
         // 6. 更新完课记录状态
         LiveCompletionPointsRecord updateRecord = new LiveCompletionPointsRecord();
         updateRecord.setId(recordId);
         updateRecord.setReceiveStatus(1);
         updateRecord.setReceiveTime(new Date());
         recordMapper.updateRecord(updateRecord);
+        fsUserService.openPlatformGeneralUserIntegralHandle(addUserLists,recordId, Long.valueOf(record.getPointsAwarded()), FsUserIntegralLogTypeEnum.TYPE_28.getValue());
 
         // 7. 返回更新后的记录
         record.setReceiveStatus(1);

fs-user-app/src/main/java/com/fs/app/controller/live/LiveCompletionPointsController.java

@@ -84,9 +84,9 @@ public class LiveCompletionPointsController extends AppBaseController {
      */
     @PostMapping("/receive")
     @RepeatSubmit
-    public R receive(@RequestParam Long recordId) {
+    public R receive(@RequestParam Long liveId) {
         Long userId = Long.parseLong(getUserId());
-        LiveCompletionPointsRecord record = completionPointsRecordService.receiveCompletionPoints(recordId, userId);
+        LiveCompletionPointsRecord record = completionPointsRecordService.receiveCompletionPoints(liveId, userId);
         return R.ok().put("data", record);
     }