From 1d44c20eabc99e9970fb58d4dbd3a94d77e83e39 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期五, 07 三月 2025 18:35:50 +0800
Subject: [PATCH] 冥想
---
xinquan-modules/xinquan-user/src/main/java/com/xinquan/user/controller/client/ClientAppUserViewingHistoryController.java | 474 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 461 insertions(+), 13 deletions(-)
diff --git a/xinquan-modules/xinquan-user/src/main/java/com/xinquan/user/controller/client/ClientAppUserViewingHistoryController.java b/xinquan-modules/xinquan-user/src/main/java/com/xinquan/user/controller/client/ClientAppUserViewingHistoryController.java
index 239e7e4..ca2d549 100644
--- a/xinquan-modules/xinquan-user/src/main/java/com/xinquan/user/controller/client/ClientAppUserViewingHistoryController.java
+++ b/xinquan-modules/xinquan-user/src/main/java/com/xinquan/user/controller/client/ClientAppUserViewingHistoryController.java
@@ -1,17 +1,43 @@
package com.xinquan.user.controller.client;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.xinquan.common.core.domain.R;
+import com.xinquan.common.core.utils.page.PageDTO;
+import com.xinquan.common.core.web.domain.BaseModel;
+import com.xinquan.common.security.service.TokenService;
+import com.xinquan.common.security.utils.SecurityUtils;
+import com.xinquan.course.api.domain.Course;
+import com.xinquan.course.api.domain.CourseChapter;
+import com.xinquan.course.api.domain.OrderCourseVO;
+import com.xinquan.course.api.feign.RemoteCourseService;
+import com.xinquan.meditation.api.domain.Meditation;
+import com.xinquan.meditation.api.feign.RemoteMeditationService;
+import com.xinquan.system.api.domain.*;
+import com.xinquan.system.api.domain.vo.AppUserVO;
+import com.xinquan.system.api.model.LoginUser;
+import com.xinquan.user.api.feign.RemoteAppUserService;
+import com.xinquan.user.service.AppUserEnergyRecordService;
+import com.xinquan.user.service.AppUserService;
+import com.xinquan.user.service.AppUserTreeService;
import com.xinquan.user.service.AppUserViewingHistoryService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
+import io.swagger.models.auth.In;
+import lombok.Data;
import lombok.RequiredArgsConstructor;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.stream.Collectors;
/**
* <p>
@@ -28,23 +54,445 @@
public class ClientAppUserViewingHistoryController {
private final AppUserViewingHistoryService appUserViewingHistoryService;
+ @Resource
+ private TokenService tokenService;
+ @Resource
+ private AppUserTreeService appUserTreeService;
+ @Resource
+ private AppUserService appUserService;
+ @Resource
+ private RemoteMeditationService remoteMeditationService;
+ @Resource
+ private RemoteCourseService courseUserFavoriteService;
+ @Resource
+ private RemoteCourseService remoteCourseService;
+ private final RemoteAppUserService remoteAppUserService;
+
+ /**
+ * 远程调用 根据章节id和用户id查询是否观看完毕
+ *
+ * @param id
+ * @return
+ */
+ @PostMapping("/getCourseChapterHistoryState/{id}/{chapterId}")
+ public R<Integer> getCourseChapterHistoryState(@PathVariable("id") Long id, @PathVariable("chapterId") Long chapterId) {
+ List<AppUserViewingHistory> list = appUserViewingHistoryService.lambdaQuery()
+ .eq(AppUserViewingHistory::getChapterId, chapterId)
+ .eq(AppUserViewingHistory::getAppUserId, id)
+ .eq(AppUserViewingHistory::getViewingType, 2)
+ .list();
+ for (AppUserViewingHistory appUserViewingHistory : list) {
+ if (appUserViewingHistory.getIsOver() != null && appUserViewingHistory.getIsOver() == 1) {
+ return R.ok(1);
+ }
+ }
+ return R.ok(2);
+ }
+
+ /**
+ * 远程调用查询用户观看了哪些课程
+ *
+ * @return
+ */
+ @PostMapping("/getCourseHistoryByUserId/{id}")
+ public R<List<Long>> getCourseHistoryByUserId(@PathVariable("id") Long id) {
+ List<Long> one = appUserViewingHistoryService.lambdaQuery()
+ .eq(AppUserViewingHistory::getAppUserId, id)
+ .eq(AppUserViewingHistory::getViewingType, 2)
+ .list().stream().map(AppUserViewingHistory::getBizId)
+ .collect(Collectors.toList());
+ return R.ok(one);
+ }
+
+ @PostMapping("/getMeditationHistoryCount/{id}")
+ public R<Long> getMeditationHistoryCount(@PathVariable("id") Long id) {
+ List<AppUserViewingHistory> list = appUserViewingHistoryService.lambdaQuery()
+ .eq(AppUserViewingHistory::getBizId, id)
+ .eq(AppUserViewingHistory::getViewingType, 1)
+ .groupBy(AppUserViewingHistory::getAppUserId)
+ .list();
+ return R.ok(Long.valueOf(list.size()));
+ }
+
+ @PostMapping("/getCourseHistoryCount/{id}")
+ public R<Long> getCourseHistoryCount(@PathVariable("id") Long id) {
+ List<AppUserViewingHistory> list = appUserViewingHistoryService.lambdaQuery()
+ .eq(AppUserViewingHistory::getBizId, id)
+ .eq(AppUserViewingHistory::getViewingType, 2)
+ .list();
+ return R.ok(Long.valueOf(list.size()));
+ }
+
+ @PostMapping("/getCourseChapterHistoryCount/{id}")
+ public R<Long> getCourseChapterHistoryCount(@PathVariable("id") Long id) {
+ List<AppUserViewingHistory> list = appUserViewingHistoryService.lambdaQuery()
+ .eq(AppUserViewingHistory::getChapterId, id)
+ .eq(AppUserViewingHistory::getViewingType, 2)
+ .groupBy(AppUserViewingHistory::getAppUserId)
+ .list();
+ return R.ok(Long.valueOf(list.size()));
+ }
+
+ @PostMapping("/lookHistory")
+ @ApiOperation(value = "观看历史")
+ @ApiImplicitParams({
+ @ApiImplicitParam(name = "state", value = "1冥想 2课程", dataType = "Integer", required = true),
+ @ApiImplicitParam(name = "pageCurr", value = "分页参数，当前页码", dataType = "Integer", required = true),
+ @ApiImplicitParam(name = "pageSize", value = "分页参数，每页数量", dataType = "Integer", required = true)
+ })
+ public R<List<OrderCourseVO>> lookHistory(Integer state, Integer pageCurr, Integer pageSize) {
+ LoginUser loginUser = tokenService.getLoginUser();
+ if (loginUser == null) {
+ return R.tokenError("登录失效");
+ }
+ Long userId = loginUser.getUserid();
+ List<OrderCourseVO> orderCourseVOS = new ArrayList<>();
+
+ switch (state) {
+ case 1:
+ List<Long> collect1 = appUserViewingHistoryService.lambdaQuery()
+ .eq(AppUserViewingHistory::getAppUserId, userId)
+ .eq(AppUserViewingHistory::getViewingType, 1).list()
+ .stream().map(AppUserViewingHistory::getBizId).collect(Collectors.toList());
+ List<Long> collect2 = collect1.stream().distinct().collect(Collectors.toList());
+ StringBuilder temp = new StringBuilder();
+ if (collect1.isEmpty()) {
+ temp = temp.append("-1");
+ } else {
+ for (Long l : collect2) {
+ temp.append(l).append(",");
+ }
+ temp.deleteCharAt(temp.length() - 1);
+ }
+ Page<Meditation> data = remoteMeditationService.getMeditationByIds(pageCurr, pageSize, temp.toString()).getData();
+
+ for (Meditation meditation : data.getRecords()) {
+ OrderCourseVO orderCourseVO = new OrderCourseVO();
+ orderCourseVO.setBusinessId(meditation.getId());
+ orderCourseVO.setCourseTitle(meditation.getMeditationTitle());
+ orderCourseVO.setDescription(meditation.getDetailDescription());
+ orderCourseVO.setChargeType(meditation.getChargeType());
+ orderCourseVO.setGeneralPrice(meditation.getGeneralPrice());
+ orderCourseVO.setIosPrice(meditation.getIosPrice());
+ orderCourseVO.setCoverUrl(meditation.getCoverUrl());
+ orderCourseVO.setCount(meditation.getRealLearnedNum() + meditation.getVirtualLearnedNum());
+ orderCourseVO.setCoverDescription(meditation.getCoverDescription());
+ orderCourseVOS.add(orderCourseVO);
+ }
+ break;
+ case 2:
+ List<Long> collect3 = appUserViewingHistoryService.lambdaQuery()
+ .eq(AppUserViewingHistory::getAppUserId, userId)
+ .eq(AppUserViewingHistory::getViewingType, 2).list()
+ .stream().map(AppUserViewingHistory::getBizId).collect(Collectors.toList());
+ List<Long> collect4 = collect3.stream().distinct().collect(Collectors.toList());
+ StringBuilder temp1 = new StringBuilder();
+ if (collect4.isEmpty()) {
+ temp1 = temp1.append("-1");
+ } else {
+ for (Long l : collect4) {
+ temp1.append(l).append(",");
+ }
+ temp1.deleteCharAt(temp1.length() - 1);
+ }
+ Page<Course> data2 = remoteCourseService.getCourseByIds(pageCurr, pageSize, temp1.toString()).getData();
+ for (Course record : data2.getRecords()) {
+ OrderCourseVO orderCourseVO = new OrderCourseVO();
+ orderCourseVO.setBusinessId(record.getId());
+ orderCourseVO.setCourseTitle(record.getCourseTitle());
+ orderCourseVO.setDescription(record.getDescription());
+ orderCourseVO.setChargeType(record.getChargeType());
+ orderCourseVO.setGeneralPrice(record.getGeneralPrice());
+ orderCourseVO.setIosPrice(record.getIosPrice());
+ orderCourseVO.setCoverUrl(record.getCoverUrl());
+ List<CourseChapter> data1 = remoteCourseService.getChapterByCourseId(orderCourseVO.getBusinessId() + "").getData();
+ int a = 0;
+ int b = 0;
+ for (CourseChapter courseChapter : data1) {
+ a += courseChapter.getVirtualLearnedNum();
+ Long data9 = remoteAppUserService.getCourseChapterHistoryCount(courseChapter.getId()).getData();
+ b += data9;
+ }
+ orderCourseVO.setCount(a + b);
+ orderCourseVOS.add(orderCourseVO);
+ }
+ break;
+ }
+ return R.ok(orderCourseVOS);
+ }
/**
* 记录用户观看记录
- *
- * @param bizId 业务id
- * @param viewingType 观看类型 1=疗愈 2=课程
*/
@PostMapping("/saveViewingHistory")
- @ApiOperation(value = "记录用户观看记录", tags = {"用户端-用户相关接口"})
+ @ApiOperation(value = "记录用户观看冥想记录", tags = {"用户端-用户相关接口"})
@ApiImplicitParams({
- @ApiImplicitParam(name = "bizId", value = "业务id", dataType = "Long", required = true),
- @ApiImplicitParam(name = "viewingType", value = "观看类型 1=疗愈 2=课程", dataType = "Integer", required = true)
+ @ApiImplicitParam(name = "id", value = "冥想id", dataType = "Long", required = true),
+ @ApiImplicitParam(name = "timeLook", value = "播放时长单位秒", dataType = "Integer", required = true)
})
- public R<?> saveViewingRecord(@RequestParam("bizId") Long bizId,
- @RequestParam("viewingType") Integer viewingType) {
- appUserViewingHistoryService.saveViewingRecord(bizId, viewingType);
+ public R<?> saveViewingRecord(@RequestParam("id") Long id,
+ @RequestParam("timeLook") Integer timeLook
+ ) {
+ LoginUser loginUser = tokenService.getLoginUser();
+ if (loginUser == null) {
+ return R.tokenError("登录失效");
+ }
+ Long userId = loginUser.getUserid();
+ AppUserViewingHistory appUserViewingHistory = new AppUserViewingHistory();
+ appUserViewingHistory.setAppUserId(userId);
+ appUserViewingHistory.setBizId(id);
+ appUserViewingHistory.setViewingType(1);
+ appUserViewingHistory.setTimeLook(timeLook);
+ appUserViewingHistory.setCreateTime(LocalDateTime.now());
+ appUserViewingHistoryService.save(appUserViewingHistory);
+ AppUser byId = appUserService.getById(userId);
+ appUserService.updateById(byId);
+ // 查询用户今日观看疗愈多少秒
+ LocalDateTime now = LocalDateTime.now();
+ LocalDateTime startOfDay = now.toLocalDate().atStartOfDay();
+ LocalDateTime endOfDay = now.toLocalDate().atTime(LocalTime.MAX);
+ List<AppUserViewingHistory> list = appUserViewingHistoryService
+ .lambdaQuery().eq(AppUserViewingHistory::getAppUserId, userId)
+ .eq(AppUserViewingHistory::getViewingType, 1)
+ .eq(BaseModel::getDelFlag, 0)
+ .between(AppUserViewingHistory::getCreateTime, startOfDay, endOfDay).list();
+ int temp = 0;
+ for (AppUserViewingHistory appUserViewingHistory1 : list) {
+ if (appUserViewingHistory1.getTimeLook() != null) {
+ temp += appUserViewingHistory1.getTimeLook();
+
+ }
+ }
+ AppUserTree one = appUserTreeService.lambdaQuery().eq(AppUserTree::getAppUserId, userId)
+ .eq(AppUserTree::getSowAgain, 2).one();
+
+ if (one == null) {
+ AppUserTree appUserTree = new AppUserTree();
+ appUserTree.setTime(LocalDateTime.now());
+ appUserTree.setAppUserId(userId);
+ appUserTree.setTreeLevelType(1);
+ appUserTree.setGrowthValue(0);
+ appUserTree.setSowAgain(2);
+ appUserTree.setCreateTime(LocalDateTime.now());
+ // 如果用户的签到时间是今天 那么修改为已签到
+ if (byId.getSignTime() != null && byId.getSignTime().toLocalDate().equals(LocalDateTime.now().toLocalDate())) {
+ appUserTree.setIsSign(1);
+ } else {
+ appUserTree.setIsSign(2);
+ }
+ if (temp >= 3600) {
+ if (appUserTree.getTaskOne() == 2) {
+ AppUserEnergyRecord appUserEnergyRecord = new AppUserEnergyRecord();
+ appUserEnergyRecord.setAppUserId(userId);
+ appUserEnergyRecord.setChangeType(1);
+ appUserEnergyRecord.setEnergyValue(10);
+ appUserEnergyRecord.setReason("完成【每日疗愈30分钟】任务");
+ appUserEnergyRecordService.save(appUserEnergyRecord);
+ byId.setTotalEnergyValue(byId.getTotalEnergyValue() + 10);
+ byId.setEnergyValue(byId.getEnergyValue() + 10);
+
+ }
+ if (appUserTree.getTaskTwo() == 2) {
+ AppUserEnergyRecord appUserEnergyRecord = new AppUserEnergyRecord();
+ appUserEnergyRecord.setAppUserId(userId);
+ appUserEnergyRecord.setChangeType(1);
+ appUserEnergyRecord.setEnergyValue(20);
+ appUserEnergyRecord.setReason("完成【每日疗愈60分钟】任务");
+ appUserEnergyRecordService.save(appUserEnergyRecord);
+ byId.setTotalEnergyValue(byId.getTotalEnergyValue() + 20);
+ byId.setEnergyValue(byId.getEnergyValue() + 20);
+
+ }
+ appUserTree.setTaskOne(1);
+ appUserTree.setTaskTwo(1);
+ } else if (temp >= 1800) {
+ if (appUserTree.getTaskOne() == 2) {
+ AppUserEnergyRecord appUserEnergyRecord = new AppUserEnergyRecord();
+ appUserEnergyRecord.setAppUserId(userId);
+ appUserEnergyRecord.setChangeType(1);
+ appUserEnergyRecord.setEnergyValue(10);
+ appUserEnergyRecord.setReason("完成【每日疗愈30分钟】任务");
+ appUserEnergyRecordService.save(appUserEnergyRecord);
+ byId.setTotalEnergyValue(byId.getTotalEnergyValue() + 10);
+ byId.setEnergyValue(byId.getEnergyValue() + 10);
+ }
+ appUserTree.setTaskOne(2);
+ appUserTree.setTaskTwo(1);
+ } else {
+ appUserTree.setTaskOne(2);
+ appUserTree.setTaskTwo(2);
+ }
+ appUserTree.setEnergyValue(byId.getEnergyValue());
+ appUserTree.setNextLevel(1000);
+ appUserTreeService.save(appUserTree);
+ appUserTree.setTotalEnergyValue(byId.getTotalEnergyValue());
+ return R.ok(appUserTree);
+ } else {
+ if (temp >= 3600) {
+ if (one.getTaskOne() == 2) {
+ AppUserEnergyRecord appUserEnergyRecord = new AppUserEnergyRecord();
+ appUserEnergyRecord.setAppUserId(userId);
+ appUserEnergyRecord.setChangeType(1);
+ appUserEnergyRecord.setEnergyValue(10);
+ appUserEnergyRecord.setReason("完成【每日疗愈30分钟】任务");
+ appUserEnergyRecordService.save(appUserEnergyRecord);
+ byId.setTotalEnergyValue(byId.getTotalEnergyValue() + 10);
+ one.setTaskOne(1);
+ byId.setEnergyValue(byId.getEnergyValue() + 10);
+
+ }
+ if (one.getTaskTwo() == 2) {
+ AppUserEnergyRecord appUserEnergyRecord = new AppUserEnergyRecord();
+ appUserEnergyRecord.setAppUserId(userId);
+ appUserEnergyRecord.setChangeType(1);
+ appUserEnergyRecord.setEnergyValue(20);
+ appUserEnergyRecord.setReason("完成【每日疗愈60分钟】任务");
+ appUserEnergyRecordService.save(appUserEnergyRecord);
+ byId.setTotalEnergyValue(byId.getTotalEnergyValue() + 20);
+ one.setTaskTwo(1);
+ byId.setEnergyValue(byId.getEnergyValue() + 20);
+
+ }
+
+ } else if (temp >= 1800) {
+ if (one.getTaskOne() == 2) {
+ AppUserEnergyRecord appUserEnergyRecord = new AppUserEnergyRecord();
+ appUserEnergyRecord.setAppUserId(userId);
+ appUserEnergyRecord.setChangeType(1);
+ appUserEnergyRecord.setEnergyValue(10);
+ appUserEnergyRecord.setReason("完成【每日疗愈30分钟】任务");
+ appUserEnergyRecordService.save(appUserEnergyRecord);
+ byId.setTotalEnergyValue(byId.getTotalEnergyValue() + 10);
+ one.setTaskOne(1);
+ byId.setEnergyValue(byId.getEnergyValue() + 10);
+ }
+ } else {
+ one.setTaskOne(2);
+ one.setTaskTwo(2);
+ }
+ appUserTreeService.updateById(one);
+ appUserService.updateById(byId);
+ return R.ok();
+ }
+ }
+
+ @Resource
+ private AppUserEnergyRecordService appUserEnergyRecordService;
+
+ @PostMapping("/saveCourseStudyHistory")
+ @ApiOperation(value = "记录用户观看课程记录", tags = {"用户端-用户相关接口"})
+ @ApiImplicitParams({
+ @ApiImplicitParam(name = "chapterId", value = "章节id", dataType = "Long", required = true),
+ @ApiImplicitParam(name = "isOver", value = "是否观看完成 1是2否", dataType = "int", required = true),
+ @ApiImplicitParam(name = "minuteLook", value = "观看到xx分钟", dataType = "int", required = true),
+ @ApiImplicitParam(name = "secondLook", value = "观看到xx秒", dataType = "int", required = true),
+ })
+ public R<?> saveCourseStudyHistory(@RequestParam("chapterId") Long chapterId,
+ @RequestParam("minuteLook") Integer minuteLook,
+ @RequestParam("secondLook") Integer secondLook,
+ @RequestParam("isOver") Integer isOver
+ ) {
+ LoginUser loginUser = tokenService.getLoginUser();
+ if (loginUser == null) {
+ return R.tokenError("登录失效");
+ }
+ Long userId = loginUser.getUserid();
+ AppUserViewingHistory one = appUserViewingHistoryService.lambdaQuery()
+ .eq(AppUserViewingHistory::getAppUserId, userId)
+ .eq(AppUserViewingHistory::getViewingType, 2)
+ .eq(AppUserViewingHistory::getChapterId, chapterId).one();
+ if (one != null) {
+ if (one.getIsOver() == 1) {
+ // 如果已经看完了 那么不更新状态 只更新观看时间
+ one.setMinuteLook(minuteLook);
+ one.setSecondLook(secondLook);
+ one.setTimeLook(secondLook);
+ } else {
+ one.setIsOver(isOver);
+ }
+ appUserViewingHistoryService.updateById(one);
+ } else {
+ AppUserViewingHistory appUserViewingHistory = new AppUserViewingHistory();
+ appUserViewingHistory.setAppUserId(userId);
+ appUserViewingHistory.setBizId(chapterId);
+ appUserViewingHistory.setViewingType(2);
+ appUserViewingHistory.setMinuteLook(minuteLook);
+ appUserViewingHistory.setSecondLook(secondLook);
+ appUserViewingHistory.setChapterId(chapterId);
+ appUserViewingHistory.setIsOver(isOver);
+ appUserViewingHistory.setTimeLook(secondLook);
+
+ appUserViewingHistoryService.save(appUserViewingHistory);
+ }
return R.ok();
}
+
+ @PostMapping("/getCourseStudyHistory")
+ public R<AppUserViewingHistory> getCourseStudyHistory(@RequestParam("chapterId") Long chapterId) {
+ LoginUser loginUser = tokenService.getLoginUser();
+ if (loginUser == null) {
+ return R.tokenError("登录失效");
+ }
+ Long userId = loginUser.getUserid();
+ AppUserViewingHistory one = appUserViewingHistoryService.lambdaQuery()
+ .eq(AppUserViewingHistory::getAppUserId, userId)
+ .eq(AppUserViewingHistory::getViewingType, 2)
+ .eq(AppUserViewingHistory::getChapterId, chapterId).one();
+ if (one == null) {
+ AppUserViewingHistory appUserViewingHistory = new AppUserViewingHistory();
+ appUserViewingHistory.setAppUserId(userId);
+ appUserViewingHistory.setBizId(chapterId);
+ appUserViewingHistory.setViewingType(2);
+ appUserViewingHistory.setMinuteLook(0);
+ appUserViewingHistory.setSecondLook(0);
+ appUserViewingHistory.setChapterId(chapterId);
+ appUserViewingHistory.setIsOver(2);
+ appUserViewingHistoryService.save(appUserViewingHistory);
+ return R.ok(appUserViewingHistory);
+ }
+ return R.ok(one);
+ }
+
+// @PostMapping("/studyRecord")
+// @ApiOperation(value = "学习页面记录观看到xx分钟xx秒")
+// @ApiImplicitParams({
+// @ApiImplicitParam(value = "章节id", name = "chapterId", required = true, dataType = "String"),
+// @ApiImplicitParam(value = "上次观看到xx分钟", name = "minuteLook", required = true, dataType = "Integer"),
+// @ApiImplicitParam(value = "上次观看到xx秒", name = "secondLook", required = true, dataType = "Integer"),
+// @ApiImplicitParam(value = "是否观看完成", name = "isOver", required = true, dataType = "Integer"),
+// })
+// public R studyRecord(@RequestParam(value = "chapterId")Long chapterId,
+// @RequestParam(value = "minuteLook") Integer minuteLook,
+// @RequestParam(value = "secondLook") Integer secondLook,
+// @RequestParam(value = "isOver") Integer isOver
+// ) {
+// Long userId = tokenService.getLoginUser().getUserid();
+// if(userId ==null || userId == 0)return R.tokenError("登录失效");
+// AppUserViewingHistory one = appUserViewingHistoryService.lambdaQuery()
+// .eq(AppUserViewingHistory::getAppUserId, userId)
+// .eq(AppUserViewingHistory::getViewingType, 2)
+// .eq(AppUserViewingHistory::getChapterId, chapterId).one();
+// if (one!=null){
+// if (one.getIsOver() == 1){
+// // 如果已经看完了 那么不更新状态 只更新观看时间
+// one.setMinuteLook(minuteLook);
+// one.setSecondLook(secondLook);
+// }else{
+// one.setIsOver(isOver);
+// }
+// appUserViewingHistoryService.updateById(one);
+// }else{
+// AppUserViewingHistory appUserViewingHistory = new AppUserViewingHistory();
+// appUserViewingHistory.setAppUserId(userId);
+// appUserViewingHistory.setBizId(chapterId);
+// appUserViewingHistory.setViewingType(2);
+// appUserViewingHistory.setMinuteLook(minuteLook);
+// appUserViewingHistory.setSecondLook(secondLook);
+// appUserViewingHistory.setChapterId(chapterId);
+// appUserViewingHistory.setIsOver(isOver);
+// appUserViewingHistoryService.save(appUserViewingHistory);
+// }
+// return R.ok();
+// }
}
--
Gitblit v1.7.1