新增了阅读记录

src/main/java/com/example/caseData/controller/UserCaseReadController.java

@@ -214,10 +214,10 @@ public class UserCaseReadController extends BaseController {
         }
 
         try {
-//            boolean res = userCaseReadService.AddUserCaseRead(request,userId);
+            boolean res = userCaseReadService.AddUserCaseRead(request,userId);
-//            if (!res){
+            if (!res){
-//                return Response.error("操作失败");
+                return Response.error("操作失败");
-//            }
+            }
         } catch (BusinessException e) {
             return Response.error(e.getMessage());
         }

src/main/java/com/example/caseData/dao/UserCaseReadDao.java

@@ -7,6 +7,7 @@ import com.example.caseData.dto.userCaseRead.UserCaseReadDto;
 import com.example.caseData.dto.userCollectClinicalArticle.UserCollectClinicalArticleDto;
 import com.example.caseData.model.UserCaseReadModel;
 import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Update;
 
 public interface UserCaseReadDao extends BaseMapper<UserCaseReadModel> {
     /**
@@ -41,4 +42,25 @@ public interface UserCaseReadDao extends BaseMapper<UserCaseReadModel> {
             @Param("keyword") String keyword,
             @Param("userId") String userId
     );
+
+    /**
+     * Inc 自增
+     * @param field     字段名称
+     * @param numeral   增加的数值
+     * @return 更新的行数
+     */
+    @Update("UPDATE user_case_read SET ${field} = ${field} + #{numeral} WHERE read_id = #{readId}")
+    int inc(@Param("readId") Long readId, @Param("field") String field, @Param("numeral") int numeral);
+
+    /**
+     * Dec 自减
+     *
+     * @param field     字段名称
+     * @param numeral   减少的数值
+     * @return 更新的行数
+     */
+    @Update("UPDATE user_case_read " +
+            "SET ${field} = CASE WHEN ${field} >= #{numeral} THEN ${field} - #{numeral} ELSE 0 END " +
+            "WHERE read_id = #{statsId}")
+    int dec(@Param("readId") Long readId, @Param("field") String field, @Param("numeral") int numeral);
 }

src/main/java/com/example/caseData/request/publicRequest/LoginRequest.java

@@ -13,10 +13,4 @@ public class LoginRequest {
 
     @NotEmpty(message = "错误请求2", groups = {Login.class})
     private String wx_code;
-
-    /**
-     * 来源（1:小程序 2:h5）
-     */
-    @NotNull(message = "错误请求", groups = {Login.class})
-    private Integer source;
 }

src/main/java/com/example/caseData/service/UserCaseReadService.java

@@ -1,48 +1,77 @@
 package com.example.caseData.service;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.example.caseData.dao.*;
 import com.example.caseData.exception.BusinessException;
+import com.example.caseData.model.CaseClinicalArticleAuthorModel;
 import com.example.caseData.model.CaseClinicalArticleModel;
+import com.example.caseData.model.UserCaseReadModel;
 import com.example.caseData.model.UserCommentClinicalArticleModel;
 import com.example.caseData.request.CaseClinicalArticleRequest.addClinicalArticleComment;
 import com.example.caseData.request.userCaseReadRequest.addUserCaseRead;
 import com.example.caseData.utils.Replace;
+import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.List;
+
 @Slf4j
 @Service
 public class UserCaseReadService {
-//    /**
+    @Resource
-//     * 浏览记录-新增
+    private UserCaseReadDao userCaseReadDao;
-//     * @return bool
+
-//     */
+    @Resource
-//    @Transactional
+    private CaseClinicalArticleDao caseClinicalArticleDao;
-//    public boolean AddUserCaseRead(addUserCaseRead request, String userId){
+
-//        // 检测是否已存在
+    @Resource
-//
+    private CaseClinicalVideoDao caseClinicalVideoDao;
-//
+
-//        // 新增评论
+    @Resource
-//        UserCommentClinicalArticleModel userCommentClinicalArticleData = new UserCommentClinicalArticleModel();
+    private CaseExchangeDao caseExchangeDao;
-//        userCommentClinicalArticleData.setUserId(Long.valueOf(userId));
+
-//        userCommentClinicalArticleData.setArticleId(Long.valueOf(articleId));
+    /**
-//        userCommentClinicalArticleData.setStatus(1);
+     * 浏览记录-新增
-//        userCommentClinicalArticleData.setIsSensitive(0);
+     * @return bool
-//        userCommentClinicalArticleData.setContent(request.getContent());
+     */
-//        userCommentClinicalArticleData.setCommentImage(Replace.removeOssDomain(request.getCommentImage()));
+    @Transactional
-//
+    public boolean AddUserCaseRead(addUserCaseRead request, String userId){
-//        // 评论根id
+        // 检测是否已存在
-//        if (request.getRootId() != null) {
+        LambdaQueryWrapper<UserCaseReadModel> queryWrapper = new LambdaQueryWrapper<>();
-//            userCommentClinicalArticleData.setRootId(Long.valueOf(request.getRootId()));
+        queryWrapper.eq(UserCaseReadModel::getUserId, userId);
-//        }
+        queryWrapper.eq(UserCaseReadModel::getId, request.getId());
-//
+        queryWrapper.eq(UserCaseReadModel::getType, request.getType());
-//        // 评论父级id
+        UserCaseReadModel userCaseRead = userCaseReadDao.selectOne(queryWrapper);
-//        if (request.getParentId() != null) {
+        if (userCaseRead == null){
-//            userCommentClinicalArticleData.setParentId(Long.valueOf(request.getParentId()));
+            UserCaseReadModel data = new UserCaseReadModel();
-//        }
+            data.setUserId(Long.valueOf(userId));
-//
+            data.setId(Long.valueOf( request.getId()));
-//        int res = userCommentClinicalArticleDao.insert(userCommentClinicalArticleData);
+            data.setType(request.getType());
-//        return res > 0;
+            data.setReadNum(1);
-//    }
+            int res = userCaseReadDao.insert(data);
+            return res > 0;
+        }else{
+            userCaseReadDao.inc(userCaseRead.getReadId(),"read_num",1);
+        }
+
+        // 文章
+        if (request.getType() == 1){
+            caseClinicalArticleDao.inc(Long.valueOf(request.getId()),"read_num",1);
+        }
+
+        // 视频
+        if (request.getType() == 2){
+            caseClinicalVideoDao.inc(Long.valueOf(request.getId()),"read_num",1);
+        }
+
+        // 病例交流
+        if (request.getType() == 3){
+            caseExchangeDao.inc(Long.valueOf(request.getId()),"read_num",1);
+        }
+
+        return true;
+    }
 
 }