diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareCircleController.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareCircleController.java index b7480ea..8f0632e 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareCircleController.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareCircleController.java @@ -2,22 +2,25 @@ package com.schisandra.share.application.controller; import com.alibaba.fastjson.JSON; import com.google.common.base.Preconditions; -import com.google.gson.Gson; import com.schisandra.share.application.convert.SchisandraShareCircleDTOConverter; import com.schisandra.share.application.dto.SchisandraShareCircleDTO; import com.schisandra.share.common.entity.Result; +import com.schisandra.share.common.redis.RedisUtil; import com.schisandra.share.domain.bo.SchisandraShareCircleBO; import com.schisandra.share.domain.service.SchisandraShareCircleDomainService; import lombok.extern.slf4j.Slf4j; -import org.apache.rocketmq.client.producer.SendCallback; -import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.springframework.cache.annotation.Cacheable; -import org.springframework.web.bind.annotation.*; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; -import java.util.HashMap; +import java.text.SimpleDateFormat; +import java.util.Date; import java.util.List; +import java.util.concurrent.TimeUnit; /** * 分享圈 controller @@ -29,7 +32,9 @@ import java.util.List; @RequestMapping("/share/circle/") @Slf4j public class SchisandraShareCircleController { - + private final String SHARE_USER_RECENT = "share:user:recent:situation"; + @Resource + RedisUtil redisUtil; @Resource private SchisandraShareCircleDomainService schisandraShareCircleDomainService; @Resource @@ -48,7 +53,16 @@ public class SchisandraShareCircleController { Preconditions.checkNotNull(schisandraShareCircleDTO.getIcon(), "图标不能为空"); Preconditions.checkNotNull(schisandraShareCircleDTO.getDescription(), "描述不能为空"); SchisandraShareCircleBO SchisandraShareCircleBO = SchisandraShareCircleDTOConverter.INSTANCE.convertDTOToBO(schisandraShareCircleDTO); - return Result.ok(schisandraShareCircleDomainService.add(SchisandraShareCircleBO)); + if (schisandraShareCircleDomainService.add(SchisandraShareCircleBO)) { + String value = "您最近创建了一个圈子：" + schisandraShareCircleDTO.getName(); + Date date = new Date(); + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String formattedDate = dateFormat.format(date); + String key = redisUtil.buildKey(SHARE_USER_RECENT, schisandraShareCircleDTO.getUserId(), formattedDate); + redisUtil.setNx(key, value, 30L, TimeUnit.DAYS); + return Result.ok(); + } + return Result.fail(); } catch (Exception e) { log.error("SchisandraShareCircleController.register.error:{}", e.getMessage(), e); return Result.fail("新增分享圈失败"); @@ -59,14 +73,14 @@ public class SchisandraShareCircleController { /** * 分享圈列表返回 */ - @Cacheable(value = "sharelist",key = "'sharelist'") + @Cacheable(value = "sharelist", key = "'sharelist'") @GetMapping("sharelist") public Result> getShareList() { try { List result = schisandraShareCircleDomainService.queryAll(); List schisandraShareCircleDTOS = SchisandraShareCircleDTOConverter.INSTANCE.convertBOToDTOList(result); return Result.ok(schisandraShareCircleDTOS); - }catch (Exception e) { + } catch (Exception e) { log.error("SchisandraShareCircleController.getShareList.error:{}", e.getMessage(), e); return Result.fail("分享圈列表获取失败"); } @@ -119,7 +133,17 @@ public class SchisandraShareCircleController { Preconditions.checkNotNull(schisandraShareCircleDTO.getViews(), "不能为空"); SchisandraShareCircleBO schisandraShareCircleBO = SchisandraShareCircleDTOConverter.INSTANCE.convertDTOToBO(schisandraShareCircleDTO); - return Result.ok(schisandraShareCircleDomainService.delete(schisandraShareCircleBO)); + + if (schisandraShareCircleDomainService.delete(schisandraShareCircleBO)) { + String value = "您最近删除了一个圈子：" + schisandraShareCircleDTO.getName(); + Date date = new Date(); + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String formattedDate = dateFormat.format(date); + String key = redisUtil.buildKey(SHARE_USER_RECENT, schisandraShareCircleDTO.getUserId(), formattedDate); + redisUtil.setNx(key, value, 30L, TimeUnit.DAYS); + return Result.ok(); + } + return Result.fail(); } catch (Exception e) { log.error("SchisandraShareCircleController.delete.error:{}", e.getMessage(), e); return Result.fail("删除分享圈信息失败"); diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareCommentReplyController.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareCommentReplyController.java index cb986a3..b7ca817 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareCommentReplyController.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareCommentReplyController.java @@ -4,10 +4,14 @@ import com.alibaba.fastjson.JSON; import com.google.common.base.Preconditions; import com.google.gson.Gson; import com.schisandra.share.application.convert.SchisandraShareCommentReplyDTOConverter; +import com.schisandra.share.application.convert.SchisandraUserLikesCommentDTOConverter; import com.schisandra.share.application.dto.SchisandraShareCommentReplyDTO; +import com.schisandra.share.application.dto.SchisandraUserLikesCommentDTO; import com.schisandra.share.common.entity.Result; +import com.schisandra.share.common.redis.RedisUtil; import com.schisandra.share.common.utils.CaffeineUtil; import com.schisandra.share.domain.bo.SchisandraShareCommentReplyBO; +import com.schisandra.share.domain.bo.SchisandraUserLikesCommentBO; import com.schisandra.share.domain.service.SchisandraShareCommentReplyDomainService; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.client.producer.SendCallback; @@ -16,8 +20,11 @@ import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; +import java.text.SimpleDateFormat; +import java.util.Date; import java.util.HashMap; import java.util.List; +import java.util.concurrent.TimeUnit; /** * 评论回复表 controller @@ -29,14 +36,7 @@ import java.util.List; @RequestMapping("/share/comment/reply/") @Slf4j public class SchisandraShareCommentReplyController { - - /** - * 点赞 - * - * @param Id - * @return - */ - + private final String SHARE_USER_RECENT = "share:user:recent:situation"; @Resource RocketMQTemplate rocketMQTemplate; @Resource @@ -44,14 +44,21 @@ public class SchisandraShareCommentReplyController { @Resource private SchisandraShareCommentReplyDomainService schisandraShareCommentReplyDomainService; + @Resource + RedisUtil redisUtil; + /** + * @description: 点赞 + * @param: [schisandraUserLikesCommentDTO] + * @return: void + * @author zlg + * @date: 2024/7/20 14:39 + */ @GetMapping("addlike") - public void addLike(@RequestParam String Id) { - HashMap map = new HashMap<>(); - map.put("Id", Id); - map.put("like", true); - Gson gson = new Gson(); - String message = gson.toJson(map); - rocketMQTemplate.asyncSend("CommentLikes-topic", message, new SendCallback() { + public void addLike(@RequestParam SchisandraUserLikesCommentDTO schisandraUserLikesCommentDTO) { + Preconditions.checkNotNull(schisandraUserLikesCommentDTO); + SchisandraUserLikesCommentBO schisandraUserLikesCommentBO=SchisandraUserLikesCommentDTOConverter.INSTANCE.convertDTOToBO(schisandraUserLikesCommentDTO); + schisandraUserLikesCommentBO.setLike(true); + rocketMQTemplate.asyncSend("CommentLikes-topic", schisandraUserLikesCommentBO, new SendCallback() { @Override public void onSuccess(SendResult sendResult) { System.out.println(sendResult); @@ -66,13 +73,12 @@ public class SchisandraShareCommentReplyController { } @GetMapping("dellike") - public void delLike(String Id) { - HashMap map = new HashMap<>(); - map.put("Id", Id); - map.put("like", false); - Gson gson = new Gson(); - String message = gson.toJson(map); - rocketMQTemplate.asyncSend("CommentLikes-topic", message, new SendCallback() { + public void delLike( @RequestParam SchisandraUserLikesCommentDTO schisandraUserLikesCommentDTO) { + + Preconditions.checkNotNull(schisandraUserLikesCommentDTO); + SchisandraUserLikesCommentBO schisandraUserLikesCommentBO=SchisandraUserLikesCommentDTOConverter.INSTANCE.convertDTOToBO(schisandraUserLikesCommentDTO); + schisandraUserLikesCommentBO.setLike(false); + rocketMQTemplate.asyncSend("CommentLikes-topic", schisandraUserLikesCommentBO, new SendCallback() { @Override public void onSuccess(SendResult sendResult) { System.out.println(sendResult); @@ -212,6 +218,12 @@ public class SchisandraShareCommentReplyController { } } ); + String value = "您最近发表评论：" + schisandraShareCommentReplyDTO.getContent(); + Date date = new Date(); + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String formattedDate = dateFormat.format(date); + String key = redisUtil.buildKey(SHARE_USER_RECENT,schisandraShareCommentReplyDTO.getUserId(), formattedDate); + redisUtil.setNx(key, value, 30L, TimeUnit.DAYS); return Result.ok(); } return Result.fail(); diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareDetailController.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareDetailController.java index d298fb3..d3af656 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareDetailController.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraShareDetailController.java @@ -4,11 +4,16 @@ import com.alibaba.fastjson.JSON; import com.google.common.base.Preconditions; import com.google.gson.Gson; import com.schisandra.share.application.convert.SchisandraShareDetailDTOConverter; +import com.schisandra.share.application.convert.SchisandraUserLikesDetailDTOConverter; import com.schisandra.share.application.dto.SchisandraShareDetailDTO; +import com.schisandra.share.application.dto.SchisandraUserLikesDetailDTO; import com.schisandra.share.common.entity.Result; +import com.schisandra.share.common.redis.RedisUtil; import com.schisandra.share.common.utils.CaffeineUtil; import com.schisandra.share.domain.bo.SchisandraShareDetailBO; +import com.schisandra.share.domain.bo.SchisandraUserLikesDetailBO; import com.schisandra.share.domain.service.SchisandraShareDetailDomainService; +import feign.form.FormData; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.client.producer.SendCallback; import org.apache.rocketmq.client.producer.SendResult; @@ -17,8 +22,11 @@ import org.springframework.cache.annotation.Cacheable; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; +import java.text.SimpleDateFormat; +import java.util.Date; import java.util.HashMap; import java.util.List; +import java.util.concurrent.TimeUnit; /** * 分享详情表 controller @@ -31,12 +39,62 @@ import java.util.List; @Slf4j public class SchisandraShareDetailController { + private final String SHARE_USER_RECENT = "share:user:recent:situation"; + @Resource + CaffeineUtil caffeineUtil; + @Resource + RedisUtil redisUtil; @Resource private SchisandraShareDetailDomainService schisandraShareDetailDomainService; @Resource private RocketMQTemplate rocketMQTemplate; - @Resource - CaffeineUtil caffeineUtil; + + + /** + * @description: 点赞 + * @param: [schisandraUserLikesDetailDTO] + * @return: void + * @author zlg + * @date: 2024/7/20 14:38 + */ + @GetMapping("addlike") + public void addLike(@RequestParam SchisandraUserLikesDetailDTO schisandraUserLikesDetailDTO) { + Preconditions.checkNotNull(schisandraUserLikesDetailDTO); + SchisandraUserLikesDetailBO schisandraUserLikesDetailBO = SchisandraUserLikesDetailDTOConverter.INSTANCE.convertDTOToBO(schisandraUserLikesDetailDTO); + schisandraUserLikesDetailBO.setLike(true); + rocketMQTemplate.asyncSend("DetailLikes-topic", schisandraUserLikesDetailBO, new SendCallback() { + @Override + public void onSuccess(SendResult sendResult) { + System.out.println(sendResult); + } + + @Override + public void onException(Throwable e) { + e.printStackTrace(); + } + } + ); + } + + @GetMapping("dellike") + public void delLike(@RequestParam SchisandraUserLikesDetailDTO schisandraUserLikesDetailDTO) { + Preconditions.checkNotNull(schisandraUserLikesDetailDTO); + SchisandraUserLikesDetailBO schisandraUserLikesDetailBO = SchisandraUserLikesDetailDTOConverter.INSTANCE.convertDTOToBO(schisandraUserLikesDetailDTO); + schisandraUserLikesDetailBO.setLike(false); + rocketMQTemplate.asyncSend("DetailLikes-topic", schisandraUserLikesDetailBO, new SendCallback() { + @Override + public void onSuccess(SendResult sendResult) { + System.out.println(sendResult); + } + + @Override + public void onException(Throwable e) { + e.printStackTrace(); + } + } + ); + + } /** * 返回评论回复总数 @@ -52,6 +110,7 @@ public class SchisandraShareDetailController { return Result.fail("获取评论数量失败！！！"); } } + /** * 获取我的分享 */ @@ -59,7 +118,7 @@ public class SchisandraShareDetailController { public Result mydetail(@RequestParam("userId") String userId) { List result = (List) caffeineUtil .caffeineBuild().getIfPresent("mydetail" + userId); - if(result == null) { + if (result == null) { result = schisandraShareDetailDomainService.mydetail(userId); caffeineUtil.caffeineBuild().put("list" + userId, result); return Result.ok(SchisandraShareDetailDTOConverter.INSTANCE.convertBOToDTOList(result)); @@ -73,37 +132,44 @@ public class SchisandraShareDetailController { * @param schisandraShareDetailDTO * @return */ - @PostMapping("add_detail") - public Result addDetail(@RequestBody SchisandraShareDetailDTO schisandraShareDetailDTO) { - Preconditions.checkNotNull(schisandraShareDetailDTO.getTitle(),"标题不能为空"); - Preconditions.checkNotNull(schisandraShareDetailDTO.getIcon(),"图标不能为空"); - Preconditions.checkNotNull(schisandraShareDetailDTO.getDescription(),"摘要不能为空"); - Preconditions.checkNotNull(schisandraShareDetailDTO.getCircleId(),"摘要不能为空"); - caffeineUtil.caffeineBuild().invalidate("list" + schisandraShareDetailDTO.getCircleId()); - caffeineUtil.caffeineBuild().invalidate("mydetail" + schisandraShareDetailDTO.getUserId()); - SchisandraShareDetailBO schisandraShareDetailBO = SchisandraShareDetailDTOConverter.INSTANCE.convertDTOToBO(schisandraShareDetailDTO); - if (schisandraShareDetailDomainService.addDetail(schisandraShareDetailBO)){ - HashMap map = new HashMap<>(); - map.put("Id", schisandraShareDetailDTO.getCircleId()); - map.put("isCount", true); - Gson gson = new Gson(); - String message = gson.toJson(map); - rocketMQTemplate.asyncSend("CircleCounts-topic", message, new SendCallback() { - @Override - public void onSuccess(SendResult sendResult) { - System.out.println(sendResult); - } - @Override - public void onException(Throwable e) { - e.printStackTrace(); - } - } - ); - return Result.ok(); - } - return Result.fail(); + @PostMapping("add_detail") + public Result addDetail(@RequestBody SchisandraShareDetailDTO schisandraShareDetailDTO) { + Preconditions.checkNotNull(schisandraShareDetailDTO.getTitle(), "标题不能为空"); + Preconditions.checkNotNull(schisandraShareDetailDTO.getIcon(), "图标不能为空"); + Preconditions.checkNotNull(schisandraShareDetailDTO.getDescription(), "摘要不能为空"); + Preconditions.checkNotNull(schisandraShareDetailDTO.getCircleId(), "摘要不能为空"); + caffeineUtil.caffeineBuild().invalidate("list" + schisandraShareDetailDTO.getCircleId()); + caffeineUtil.caffeineBuild().invalidate("mydetail" + schisandraShareDetailDTO.getUserId()); + SchisandraShareDetailBO schisandraShareDetailBO = SchisandraShareDetailDTOConverter.INSTANCE.convertDTOToBO(schisandraShareDetailDTO); + if (schisandraShareDetailDomainService.addDetail(schisandraShareDetailBO)) { + HashMap map = new HashMap<>(); + map.put("Id", schisandraShareDetailDTO.getCircleId()); + map.put("isCount", true); + Gson gson = new Gson(); + String message = gson.toJson(map); + rocketMQTemplate.asyncSend("CircleCounts-topic", message, new SendCallback() { + @Override + public void onSuccess(SendResult sendResult) { + System.out.println(sendResult); + } - } + @Override + public void onException(Throwable e) { + e.printStackTrace(); + } + } + ); + String value="您最近创建了一个分享："+schisandraShareDetailDTO.getTitle(); + Date date = new Date(); + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String formattedDate = dateFormat.format(date); + String key = redisUtil.buildKey(SHARE_USER_RECENT, schisandraShareDetailDTO.getUserId(),formattedDate); + redisUtil.setNx(key, value, 30L, TimeUnit.DAYS); + return Result.ok(); + } + return Result.fail(); + + } /** @@ -124,6 +190,7 @@ public class SchisandraShareDetailController { public void onSuccess(SendResult sendResult) { System.out.println(sendResult); } + @Override public void onException(Throwable e) { e.printStackTrace(); @@ -148,7 +215,7 @@ public class SchisandraShareDetailController { public Result> selectCircleList(@RequestParam("circleId") String circleId) { List result = (List) caffeineUtil .caffeineBuild().getIfPresent("list" + circleId); - if(result == null){ + if (result == null) { result = schisandraShareDetailDomainService.list(circleId); caffeineUtil.caffeineBuild().put("list" + circleId, result); return Result.ok(SchisandraShareDetailDTOConverter.INSTANCE.convertBOToDTOList(result)); @@ -163,6 +230,7 @@ public class SchisandraShareDetailController { public void onSuccess(SendResult sendResult) { System.out.println(sendResult); } + @Override public void onException(Throwable e) { e.printStackTrace(); @@ -189,7 +257,7 @@ public class SchisandraShareDetailController { Preconditions.checkNotNull(schisandraShareDetailDTO.getDescription(), "描述不能为空"); Preconditions.checkNotNull(schisandraShareDetailDTO.getContent(), "内容不能为空"); SchisandraShareDetailBO SchisandraShareDetailBO = SchisandraShareDetailDTOConverter.INSTANCE.convertDTOToBO(schisandraShareDetailDTO); - if(schisandraShareDetailDomainService.add(SchisandraShareDetailBO)){ + if (schisandraShareDetailDomainService.add(SchisandraShareDetailBO)) { caffeineUtil.caffeineBuild().invalidate("list" + schisandraShareDetailDTO.getCircleId()); caffeineUtil.caffeineBuild().invalidate("mydetail" + schisandraShareDetailDTO.getUserId()); } @@ -248,7 +316,7 @@ public class SchisandraShareDetailController { } Preconditions.checkNotNull(schisandraShareDetailDTO.getId(), "详情id不能为空"); SchisandraShareDetailBO schisandraShareDetailBO = SchisandraShareDetailDTOConverter.INSTANCE.convertDTOToBO(schisandraShareDetailDTO); - if (schisandraShareDetailDomainService.delete(schisandraShareDetailBO)){ + if (schisandraShareDetailDomainService.delete(schisandraShareDetailBO)) { caffeineUtil.caffeineBuild().invalidate("list" + schisandraShareDetailDTO.getCircleId()); caffeineUtil.caffeineBuild().invalidate("mydetail" + schisandraShareDetailDTO.getUserId()); HashMap map = new HashMap<>(); @@ -261,12 +329,19 @@ public class SchisandraShareDetailController { public void onSuccess(SendResult sendResult) { System.out.println(sendResult); } + @Override public void onException(Throwable e) { e.printStackTrace(); } } ); + String value="您最近删除了一个分享："+schisandraShareDetailDTO.getTitle(); + Date date = new Date(); + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String formattedDate = dateFormat.format(date); + String key = redisUtil.buildKey(SHARE_USER_RECENT, schisandraShareDetailDTO.getUserId(),formattedDate); + redisUtil.setNx(key, value, 30L, TimeUnit.DAYS); return Result.ok(); } return Result.fail(); diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraUserFavoritesController.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraUserFavoritesController.java index f5c0aed..f4c21ac 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraUserFavoritesController.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/controller/SchisandraUserFavoritesController.java @@ -5,14 +5,17 @@ import com.google.common.base.Preconditions; import com.schisandra.share.application.convert.SchisandraUserFavoritesDTOConverter; import com.schisandra.share.application.dto.SchisandraUserFavoritesDTO; import com.schisandra.share.common.entity.Result; +import com.schisandra.share.common.utils.CaffeineUtil; import com.schisandra.share.domain.bo.SchisandraUserFavoritesBO; import com.schisandra.share.domain.service.SchisandraUserFavoritesDomainService; import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; +import java.util.List; /** * 收藏表 controller @@ -28,26 +31,46 @@ public class SchisandraUserFavoritesController { @Resource private SchisandraUserFavoritesDomainService schisandraUserFavoritesDomainService; + @Resource + CaffeineUtil caffeineUtil; + /** - * 新增收藏表 + * 我的收藏 + * @param userId + * @return + */ + @GetMapping("myfavor") + public Result myfavor(String userId) { + try{ + if (log.isInfoEnabled()) { + log.info("SchisandraUserFavoritesController.myfavor.userId:{}", JSON.toJSONString(userId)); + } + Preconditions.checkNotNull(userId, "userId不能为空"); + List result= (List) caffeineUtil + .caffeineBuild().getIfPresent("myfavor"+userId); + if(result!=null){ + return Result.ok(result); + } + result = schisandraUserFavoritesDomainService.returnMyFavor(userId); + return Result.ok(result); + } catch (Exception e) { + log.error("SchisandraUserFavoritesController.myfavor.error:{}", e.getMessage(), e); + return Result.fail("获取用户收藏表失败"); + } + } + + + /** + * 新增收藏 */ @RequestMapping("add") public Result add(@RequestBody SchisandraUserFavoritesDTO schisandraUserFavoritesDTO) { - try { if (log.isInfoEnabled()) { log.info("SchisandraUserFavoritesController.add.dto:{}", JSON.toJSONString(schisandraUserFavoritesDTO)); } - Preconditions.checkNotNull(schisandraUserFavoritesDTO.getId(), "不能为空"); - Preconditions.checkNotNull(schisandraUserFavoritesDTO.getUserId(), "不能为空"); - Preconditions.checkNotNull(schisandraUserFavoritesDTO.getDetailId(), "不能为空"); - Preconditions.checkNotNull(schisandraUserFavoritesDTO.getCircleId(), "不能为空"); - Preconditions.checkNotNull(schisandraUserFavoritesDTO.getExtJson(), "不能为空"); - Preconditions.checkNotNull(schisandraUserFavoritesDTO.getCreatedBy(), "创建人不能为空"); - Preconditions.checkNotNull(schisandraUserFavoritesDTO.getCreatedTime(), "创建时间不能为空"); - Preconditions.checkNotNull(schisandraUserFavoritesDTO.getUpdateBy(), "更新人不能为空"); - Preconditions.checkNotNull(schisandraUserFavoritesDTO.getUpdateTime(), "更新时间不能为空"); - Preconditions.checkNotNull(schisandraUserFavoritesDTO.getIsDeleted(), "不能为空"); + Preconditions.checkNotNull(schisandraUserFavoritesDTO.getUserId(), "userId不能为空"); + Preconditions.checkNotNull(schisandraUserFavoritesDTO.getDetailId(), "detailId不能为空"); SchisandraUserFavoritesBO SchisandraUserFavoritesBO = SchisandraUserFavoritesDTOConverter.INSTANCE.convertDTOToBO(schisandraUserFavoritesDTO); return Result.ok(schisandraUserFavoritesDomainService.add(SchisandraUserFavoritesBO)); } catch (Exception e) { diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/convert/SchisandraUserLikesCommentDTOConverter.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/convert/SchisandraUserLikesCommentDTOConverter.java new file mode 100644 index 0000000..9a88638 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/convert/SchisandraUserLikesCommentDTOConverter.java @@ -0,0 +1,25 @@ +package com.schisandra.share.application.convert; + +import com.schisandra.share.application.dto.SchisandraUserLikesCommentDTO; +import com.schisandra.share.domain.bo.SchisandraUserLikesCommentBO; +import org.mapstruct.Mapper; +import org.mapstruct.factory.Mappers; + +import java.util.List; + +/** + * 评论点赞表 dto转换器 + * + * @author zlg + * @since 2024-07-20 14:11:01 + */ +@Mapper +public interface SchisandraUserLikesCommentDTOConverter { + + SchisandraUserLikesCommentDTOConverter INSTANCE = Mappers.getMapper(SchisandraUserLikesCommentDTOConverter.class); + + SchisandraUserLikesCommentBO convertDTOToBO(SchisandraUserLikesCommentDTO schisandraUserLikesCommentDTO); + SchisandraUserLikesCommentDTO convertBOToDTO(SchisandraUserLikesCommentBO schisandraUserLikesCommentBO); + List convertBOToDTOList(List schisandraUserLikesCommentBOList); + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/convert/SchisandraUserLikesDetailDTOConverter.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/convert/SchisandraUserLikesDetailDTOConverter.java new file mode 100644 index 0000000..635883f --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/convert/SchisandraUserLikesDetailDTOConverter.java @@ -0,0 +1,25 @@ +package com.schisandra.share.application.convert; + +import com.schisandra.share.application.dto.SchisandraUserLikesDetailDTO; +import com.schisandra.share.domain.bo.SchisandraUserLikesDetailBO; +import org.mapstruct.Mapper; +import org.mapstruct.factory.Mappers; + +import java.util.List; + +/** + * 分享详情点赞表 dto转换器 + * + * @author zlg + * @since 2024-07-20 14:12:42 + */ +@Mapper +public interface SchisandraUserLikesDetailDTOConverter { + + SchisandraUserLikesDetailDTOConverter INSTANCE = Mappers.getMapper(SchisandraUserLikesDetailDTOConverter.class); + + SchisandraUserLikesDetailBO convertDTOToBO(SchisandraUserLikesDetailDTO schisandraUserLikesDetailDTO); + SchisandraUserLikesDetailDTO convertBOToDTO(SchisandraUserLikesDetailBO schisandraUserLikesDetailBO); + List convertBOToDTOList(List schisandraUserLikesDetailBOList); + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/dto/SchisandraUserLikesCommentDTO.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/dto/SchisandraUserLikesCommentDTO.java new file mode 100644 index 0000000..0058cf5 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/dto/SchisandraUserLikesCommentDTO.java @@ -0,0 +1,39 @@ +package com.schisandra.share.application.dto; + +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + * 评论点赞表 dto + * + * @author zlg + * @since 2024-07-20 14:11:01 + */ +@Data +public class SchisandraUserLikesCommentDTO implements Serializable { + + private Boolean like; + /** + * + */ + private String id; + + /** + * + */ + private String userId; + + /** + * + */ + private String commentId; + + /** + * 是否删除 0 未删除 1已删除 + */ + private Integer isDeleted; + +} + diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/dto/SchisandraUserLikesDetailDTO.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/dto/SchisandraUserLikesDetailDTO.java new file mode 100644 index 0000000..67bef45 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-controller/src/main/java/com/schisandra/share/application/dto/SchisandraUserLikesDetailDTO.java @@ -0,0 +1,39 @@ +package com.schisandra.share.application.dto; + +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + * 分享详情点赞表 dto + * + * @author zlg + * @since 2024-07-20 14:12:42 + */ +@Data +public class SchisandraUserLikesDetailDTO implements Serializable { + private Boolean like; + + /** + * + */ + private String id; + + /** + * + */ + private String userId; + + /** + * + */ + private String detailId; + + /** + * + */ + private Integer isDeleted; + +} + diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/CommentLikesConsumer.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/CommentLikesConsumer.java index 3dc5da5..04e30e1 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/CommentLikesConsumer.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/CommentLikesConsumer.java @@ -2,7 +2,9 @@ package com.schisandra.share.mq.comment; import com.google.gson.Gson; +import com.schisandra.share.domain.bo.SchisandraUserLikesCommentBO; import com.schisandra.share.domain.service.SchisandraShareCommentReplyDomainService; +import com.schisandra.share.domain.service.SchisandraUserLikesCommentDomainService; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.core.RocketMQListener; @@ -15,19 +17,19 @@ import java.util.HashMap; @RocketMQMessageListener(topic = "CommentLikes-topic", consumerGroup = "schisandra-cloud-storage-CommentLikes-consumer-group") @Slf4j @Component -public class CommentLikesConsumer implements RocketMQListener { +public class CommentLikesConsumer implements RocketMQListener { @Resource SchisandraShareCommentReplyDomainService schisandraShareCommentReplyDomainService; + @Resource + SchisandraUserLikesCommentDomainService schisandraUserLikesCommentDomainService; @Override - public void onMessage(String message) { - Gson gson = new Gson(); - HashMap map = gson.fromJson(message, HashMap.class); - log.info("收到消息：{}", map); - String id = (String) map.get("Id"); - Boolean likes = (Boolean) map.get("like"); + public void onMessage(SchisandraUserLikesCommentBO message) { + log.info("收到消息：{}", message); + String id = message.getCommentId(); + Boolean likes = message.getLike(); schisandraShareCommentReplyDomainService.updateCommentsLikes(id, likes); - + schisandraUserLikesCommentDomainService.add(message); } diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/DetailLikesConsumer.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/DetailLikesConsumer.java new file mode 100644 index 0000000..583b45c --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-application/schisandra-cloud-storage-share-application-mq/src/main/java/com/schisandra/share/mq/comment/DetailLikesConsumer.java @@ -0,0 +1,32 @@ +package com.schisandra.share.mq.comment; + +import com.google.gson.Gson; +import com.schisandra.share.domain.bo.SchisandraUserLikesCommentBO; +import com.schisandra.share.domain.bo.SchisandraUserLikesDetailBO; +import com.schisandra.share.domain.service.SchisandraShareDetailDomainService; +import com.schisandra.share.domain.service.SchisandraUserLikesDetailDomainService; +import lombok.extern.slf4j.Slf4j; +import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; +import org.apache.rocketmq.spring.core.RocketMQListener; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.HashMap; + +@RocketMQMessageListener(topic = "DetailLikes-topic", consumerGroup = "schisandra-cloud-storage-DetailLikes-consumer-group") +@Slf4j +@Component +public class DetailLikesConsumer implements RocketMQListener { + @Resource + SchisandraShareDetailDomainService schisandraShareDetailDomainService; + @Resource + SchisandraUserLikesDetailDomainService schisandraUserLikesDetailDomainService; + @Override + public void onMessage(SchisandraUserLikesDetailBO message) { + log.info("收到消息：{}", message); + String id = message.getDetailId(); + Boolean likes = message.getLike(); + schisandraShareDetailDomainService.updateDetailLikes(id, likes); + schisandraUserLikesDetailDomainService.add(message); + } +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-common/src/main/java/com/schisandra/share/common/redis/RedisConfig.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-common/src/main/java/com/schisandra/share/common/redis/RedisConfig.java new file mode 100644 index 0000000..4aed55d --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-common/src/main/java/com/schisandra/share/common/redis/RedisConfig.java @@ -0,0 +1,46 @@ +package com.schisandra.share.common.redis; + +import com.fasterxml.jackson.annotation.JsonAutoDetect; +import com.fasterxml.jackson.annotation.JsonTypeInfo; +import com.fasterxml.jackson.annotation.PropertyAccessor; +import com.fasterxml.jackson.databind.DeserializationFeature; +import com.fasterxml.jackson.databind.ObjectMapper; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.data.redis.connection.RedisConnectionFactory; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; +import org.springframework.data.redis.serializer.RedisSerializer; +import org.springframework.data.redis.serializer.StringRedisSerializer; + +/** + * Redis的config处理 + * + * @author: schisandra + */ +@Configuration +public class RedisConfig { + + @Bean + public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) { + RedisTemplate redisTemplate = new RedisTemplate<>(); + RedisSerializer redisSerializer = new StringRedisSerializer(); + redisTemplate.setConnectionFactory(redisConnectionFactory); + redisTemplate.setKeySerializer(redisSerializer); + redisTemplate.setHashKeySerializer(redisSerializer); + redisTemplate.setValueSerializer(jackson2JsonRedisSerializer()); + redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer()); + return redisTemplate; + } + + private Jackson2JsonRedisSerializer jackson2JsonRedisSerializer() { + Jackson2JsonRedisSerializer jsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class); + ObjectMapper objectMapper = new ObjectMapper(); + objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); + objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); + objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY); + jsonRedisSerializer.setObjectMapper(objectMapper); + return jsonRedisSerializer; + } + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-common/src/main/java/com/schisandra/share/common/redis/RedisUtil.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-common/src/main/java/com/schisandra/share/common/redis/RedisUtil.java new file mode 100644 index 0000000..2d6baee --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-common/src/main/java/com/schisandra/share/common/redis/RedisUtil.java @@ -0,0 +1,150 @@ +package com.schisandra.share.common.redis; + +import lombok.extern.slf4j.Slf4j; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Set; +import java.util.concurrent.TimeUnit; +import java.util.stream.Collectors; +import java.util.stream.Stream; + +/** + * RedisUtil工具类 + * + * @author: schisandra + * @date: 2024/2/19 + */ +@Component +@Slf4j +public class RedisUtil { + + @Resource + private RedisTemplate redisTemplate; + + private static final String CACHE_KEY_SEPARATOR = ":"; + + + public List getDataFromDirectory(String directory) { + Setkeys=redisTemplate.keys(directory+":*"); + List keysList=new ArrayList<>(); + keys.forEach(key->{ + HashMap map=new HashMap<>(); + String value= (String) redisTemplate.opsForValue().get(key); + String keyName=key.substring(key.lastIndexOf(":")+1); + map.put(keyName,value); + keysList.add(map); + }); + return keysList; + } + public List> getDataFromDir(String directory) { + + Setkeys=redisTemplate.keys(directory); + List> keysList=new ArrayList<>(); + keys.forEach(key->{ + HashMap map=new HashMap<>(); + HashMap value= (HashMap) redisTemplate.opsForValue().get(key); + map.put(key,value); + keysList.add(map); + }); + return keysList; + } + + + + /** + * 构建缓存key + */ + public String buildKey(String... strObjs) { + return Stream.of(strObjs).collect(Collectors.joining(CACHE_KEY_SEPARATOR)); + } + + /** + * 是否存在key + */ + public boolean exist(String key) { + return redisTemplate.hasKey(key); + } + + /** + * 删除key + */ + public boolean del(String key) { + return redisTemplate.delete(key); + } + + /** + * set(不带过期) + */ + public void set(String key, String value) { + redisTemplate.opsForValue().set(key, value); + } + + public void setJson(String key, Object value) { + redisTemplate.opsForValue().set(key, value); + } + + public HashMap getJson(String key) { + return (HashMap) redisTemplate.opsForValue().get(key); + } + + + /** + * set(带过期) + */ + public boolean setNx(String key, String value, Long time, TimeUnit timeUnit) { + return redisTemplate.opsForValue().setIfAbsent(key, value, time, timeUnit); + } + + /** + * 获取string类型缓存 + */ + public String get(String key) { + return (String) redisTemplate.opsForValue().get(key); + } + + public Boolean zAdd(String key, String value, Long score) { + return redisTemplate.opsForZSet().add(key, value, Double.valueOf(String.valueOf(score))); + } + + public Long countZset(String key) { + return redisTemplate.opsForZSet().size(key); + } + + public Set rangeZset(String key, long start, long end) { + return redisTemplate.opsForZSet().range(key, start, end); + } + + public Long removeZset(String key, Object value) { + return redisTemplate.opsForZSet().remove(key, value); + } + + public void removeZsetList(String key, Set value) { + value.stream().forEach((val) -> redisTemplate.opsForZSet().remove(key, val)); + } + + public Double score(String key, Object value) { + return redisTemplate.opsForZSet().score(key, value); + } + + public Set rangeByScore(String key, long start, long end) { + return redisTemplate.opsForZSet().rangeByScore(key, Double.valueOf(String.valueOf(start)), Double.valueOf(String.valueOf(end))); + } + + public Object addScore(String key, Object obj, double score) { + return redisTemplate.opsForZSet().incrementScore(key, obj, score); + } + + public Object rank(String key, Object obj) { + return redisTemplate.opsForZSet().rank(key, obj); + } + + + public void setNx(String key, HashMap map, Long time, TimeUnit timeUnit) { + redisTemplate.opsForValue().set(key, map, time, timeUnit); + } +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/bo/SchisandraUserLikesCommentBO.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/bo/SchisandraUserLikesCommentBO.java new file mode 100644 index 0000000..3a6e717 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/bo/SchisandraUserLikesCommentBO.java @@ -0,0 +1,39 @@ +package com.schisandra.share.domain.bo; + +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; +/** + * 评论点赞表 bo + * + * @author zlg + * @since 2024-07-20 14:11:01 + */ +@Data +public class SchisandraUserLikesCommentBO implements Serializable { + + private Boolean like; + + /** + * + */ + private String id; + + /** + * + */ + private String userId; + + /** + * + */ + private String commentId; + + /** + * 是否删除 0 未删除 1已删除 + */ + private Integer isDeleted; + +} + diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/bo/SchisandraUserLikesDetailBO.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/bo/SchisandraUserLikesDetailBO.java new file mode 100644 index 0000000..c92e8c0 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/bo/SchisandraUserLikesDetailBO.java @@ -0,0 +1,38 @@ +package com.schisandra.share.domain.bo; + +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; +/** + * 分享详情点赞表 bo + * + * @author zlg + * @since 2024-07-20 14:12:42 + */ +@Data +public class SchisandraUserLikesDetailBO implements Serializable { + + private Boolean like; + /** + * + */ + private String id; + + /** + * + */ + private String userId; + + /** + * + */ + private String detailId; + + /** + * + */ + private Integer isDeleted; + +} + diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/convert/SchisandraUserFavoritesBOConverter.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/convert/SchisandraUserFavoritesBOConverter.java index ed7bcfb..eba5dca 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/convert/SchisandraUserFavoritesBOConverter.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/convert/SchisandraUserFavoritesBOConverter.java @@ -5,6 +5,8 @@ import com.schisandra.share.infra.basic.entity.SchisandraUserFavorites; import org.mapstruct.Mapper; import org.mapstruct.factory.Mappers; +import java.util.List; + /** * 收藏表 bo转换器 * @@ -19,4 +21,5 @@ public interface SchisandraUserFavoritesBOConverter { SchisandraUserFavorites convertBOToEntity(SchisandraUserFavoritesBO schisandraUserFavoritesBO); SchisandraUserFavoritesBO convertEntityToBO(SchisandraUserFavorites schisandraUserFavorites); + List convertEntityToBOList(List schisandraUserFavorites); } diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/convert/SchisandraUserLikesCommentBOConverter.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/convert/SchisandraUserLikesCommentBOConverter.java new file mode 100644 index 0000000..ffe85c7 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/convert/SchisandraUserLikesCommentBOConverter.java @@ -0,0 +1,22 @@ +package com.schisandra.share.domain.convert; + +import com.schisandra.share.domain.bo.SchisandraUserLikesCommentBO; +import com.schisandra.share.infra.basic.entity.SchisandraUserLikesComment; +import org.mapstruct.Mapper; +import org.mapstruct.factory.Mappers; + +/** + * 评论点赞表 bo转换器 + * + * @author zlg + * @since 2024-07-20 14:11:01 + */ +@Mapper +public interface SchisandraUserLikesCommentBOConverter { + + SchisandraUserLikesCommentBOConverter INSTANCE = Mappers.getMapper(SchisandraUserLikesCommentBOConverter.class); + + SchisandraUserLikesComment convertBOToEntity(SchisandraUserLikesCommentBO schisandraUserLikesCommentBO); + SchisandraUserLikesCommentBO convertEntityToBO(SchisandraUserLikesComment schisandraUserLikesComment); + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/convert/SchisandraUserLikesDetailBOConverter.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/convert/SchisandraUserLikesDetailBOConverter.java new file mode 100644 index 0000000..925df4f --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/convert/SchisandraUserLikesDetailBOConverter.java @@ -0,0 +1,22 @@ +package com.schisandra.share.domain.convert; + +import com.schisandra.share.domain.bo.SchisandraUserLikesDetailBO; +import com.schisandra.share.infra.basic.entity.SchisandraUserLikesDetail; +import org.mapstruct.Mapper; +import org.mapstruct.factory.Mappers; + +/** + * 分享详情点赞表 bo转换器 + * + * @author zlg + * @since 2024-07-20 14:12:42 + */ +@Mapper +public interface SchisandraUserLikesDetailBOConverter { + + SchisandraUserLikesDetailBOConverter INSTANCE = Mappers.getMapper(SchisandraUserLikesDetailBOConverter.class); + + SchisandraUserLikesDetail convertBOToEntity(SchisandraUserLikesDetailBO schisandraUserLikesDetailBO); + SchisandraUserLikesDetailBO convertEntityToBO(SchisandraUserLikesDetail schisandraUserLikesDetail); + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraShareDetailDomainService.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraShareDetailDomainService.java index d6d3914..299478e 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraShareDetailDomainService.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraShareDetailDomainService.java @@ -37,4 +37,6 @@ public interface SchisandraShareDetailDomainService { Boolean updateCommentsLikes(String id,Boolean isReply); Boolean updateDetailViews(String id,Boolean isView); + + Boolean updateDetailLikes(String id,Boolean isLike); } diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraUserFavoritesDomainService.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraUserFavoritesDomainService.java index f293e65..a63c1e5 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraUserFavoritesDomainService.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraUserFavoritesDomainService.java @@ -2,6 +2,8 @@ package com.schisandra.share.domain.service; import com.schisandra.share.domain.bo.SchisandraUserFavoritesBO; +import java.util.List; + /** * 收藏表 领域service * @@ -25,4 +27,6 @@ public interface SchisandraUserFavoritesDomainService { */ Boolean delete(SchisandraUserFavoritesBO schisandraUserFavoritesBO); + List returnMyFavor(String userId); + } diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraUserLikesCommentDomainService.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraUserLikesCommentDomainService.java new file mode 100644 index 0000000..7060d1d --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraUserLikesCommentDomainService.java @@ -0,0 +1,28 @@ +package com.schisandra.share.domain.service; + +import com.schisandra.share.domain.bo.SchisandraUserLikesCommentBO; + +/** + * 评论点赞表 领域service + * + * @author zlg + * @since 2024-07-20 14:11:01 + */ +public interface SchisandraUserLikesCommentDomainService { + + /** + * 添加 评论点赞表 信息 + */ + Boolean add(SchisandraUserLikesCommentBO schisandraUserLikesCommentBO); + + /** + * 更新 评论点赞表 信息 + */ + Boolean update(SchisandraUserLikesCommentBO schisandraUserLikesCommentBO); + + /** + * 删除 评论点赞表 信息 + */ + Boolean delete(SchisandraUserLikesCommentBO schisandraUserLikesCommentBO); + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraUserLikesDetailDomainService.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraUserLikesDetailDomainService.java new file mode 100644 index 0000000..5d1a56a --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/SchisandraUserLikesDetailDomainService.java @@ -0,0 +1,28 @@ +package com.schisandra.share.domain.service; + +import com.schisandra.share.domain.bo.SchisandraUserLikesDetailBO; + +/** + * 分享详情点赞表 领域service + * + * @author zlg + * @since 2024-07-20 14:12:42 + */ +public interface SchisandraUserLikesDetailDomainService { + + /** + * 添加 分享详情点赞表 信息 + */ + Boolean add(SchisandraUserLikesDetailBO schisandraUserLikesDetailBO); + + /** + * 更新 分享详情点赞表 信息 + */ + Boolean update(SchisandraUserLikesDetailBO schisandraUserLikesDetailBO); + + /** + * 删除 分享详情点赞表 信息 + */ + Boolean delete(SchisandraUserLikesDetailBO schisandraUserLikesDetailBO); + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraShareDetailDomainServiceImpl.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraShareDetailDomainServiceImpl.java index 6cce0bc..bdfcf38 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraShareDetailDomainServiceImpl.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraShareDetailDomainServiceImpl.java @@ -199,4 +199,13 @@ public class SchisandraShareDetailDomainServiceImpl implements SchisandraShareDe return schisandraShareDetailService.delDetailViews(id) > 0; } } + + @Override + public Boolean updateDetailLikes(String id, Boolean isLike) { + if (isLike) { + return schisandraShareDetailService.addDetailLike(id) > 0; + } else { + return schisandraShareDetailService.delDetailLike(id) > 0; + } + } } diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraUserFavoritesDomainServiceImpl.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraUserFavoritesDomainServiceImpl.java index fdd0799..64b5296 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraUserFavoritesDomainServiceImpl.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraUserFavoritesDomainServiceImpl.java @@ -10,6 +10,7 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import javax.annotation.Resource; +import java.util.List; /** * 收藏表 领域service实现了 @@ -45,4 +46,10 @@ public class SchisandraUserFavoritesDomainServiceImpl implements SchisandraUserF return schisandraUserFavoritesService.update(schisandraUserFavorites) > 0; } + @Override + public List returnMyFavor(String userId){ + List schisandraUserFavoritesBOS = SchisandraUserFavoritesBOConverter.INSTANCE.convertEntityToBOList(schisandraUserFavoritesService.returnMyFavor(userId)); + return schisandraUserFavoritesBOS; + } + } diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraUserLikesCommentDomainServiceImpl.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraUserLikesCommentDomainServiceImpl.java new file mode 100644 index 0000000..ea6daa2 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraUserLikesCommentDomainServiceImpl.java @@ -0,0 +1,48 @@ +package com.schisandra.share.domain.service.impl; + +import com.schisandra.share.common.enums.IsDeletedFlagEnum; +import com.schisandra.share.domain.convert.SchisandraUserLikesCommentBOConverter; +import com.schisandra.share.domain.bo.SchisandraUserLikesCommentBO; +import com.schisandra.share.domain.service.SchisandraUserLikesCommentDomainService; +import com.schisandra.share.infra.basic.entity.SchisandraUserLikesComment; +import com.schisandra.share.infra.basic.service.SchisandraUserLikesCommentService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; + +/** + * 评论点赞表 领域service实现了 + * + * @author zlg + * @since 2024-07-20 14:11:01 + */ +@Service +@Slf4j +public class SchisandraUserLikesCommentDomainServiceImpl implements SchisandraUserLikesCommentDomainService { + + @Resource + private SchisandraUserLikesCommentService schisandraUserLikesCommentService; + + @Override + public Boolean add(SchisandraUserLikesCommentBO schisandraUserLikesCommentBO) { + SchisandraUserLikesComment schisandraUserLikesComment = SchisandraUserLikesCommentBOConverter.INSTANCE.convertBOToEntity(schisandraUserLikesCommentBO); + schisandraUserLikesComment.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode()); + return schisandraUserLikesCommentService.insert(schisandraUserLikesComment) > 0; + } + + @Override + public Boolean update(SchisandraUserLikesCommentBO schisandraUserLikesCommentBO) { + SchisandraUserLikesComment schisandraUserLikesComment = SchisandraUserLikesCommentBOConverter.INSTANCE.convertBOToEntity(schisandraUserLikesCommentBO); + return schisandraUserLikesCommentService.update(schisandraUserLikesComment) > 0; + } + + @Override + public Boolean delete(SchisandraUserLikesCommentBO schisandraUserLikesCommentBO) { + SchisandraUserLikesComment schisandraUserLikesComment = new SchisandraUserLikesComment(); + schisandraUserLikesComment.setId(schisandraUserLikesCommentBO.getId()); + schisandraUserLikesComment.setIsDeleted(IsDeletedFlagEnum.DELETED.getCode()); + return schisandraUserLikesCommentService.update(schisandraUserLikesComment) > 0; + } + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraUserLikesDetailDomainServiceImpl.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraUserLikesDetailDomainServiceImpl.java new file mode 100644 index 0000000..78539f7 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-domain/src/main/java/com/schisandra/share/domain/service/impl/SchisandraUserLikesDetailDomainServiceImpl.java @@ -0,0 +1,48 @@ +package com.schisandra.share.domain.service.impl; + +import com.schisandra.share.common.enums.IsDeletedFlagEnum; +import com.schisandra.share.domain.convert.SchisandraUserLikesDetailBOConverter; +import com.schisandra.share.domain.bo.SchisandraUserLikesDetailBO; +import com.schisandra.share.domain.service.SchisandraUserLikesDetailDomainService; +import com.schisandra.share.infra.basic.entity.SchisandraUserLikesDetail; +import com.schisandra.share.infra.basic.service.SchisandraUserLikesDetailService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; + +/** + * 分享详情点赞表 领域service实现了 + * + * @author zlg + * @since 2024-07-20 14:12:42 + */ +@Service +@Slf4j +public class SchisandraUserLikesDetailDomainServiceImpl implements SchisandraUserLikesDetailDomainService { + + @Resource + private SchisandraUserLikesDetailService schisandraUserLikesDetailService; + + @Override + public Boolean add(SchisandraUserLikesDetailBO schisandraUserLikesDetailBO) { + SchisandraUserLikesDetail schisandraUserLikesDetail = SchisandraUserLikesDetailBOConverter.INSTANCE.convertBOToEntity(schisandraUserLikesDetailBO); + schisandraUserLikesDetail.setIsDeleted(IsDeletedFlagEnum.UN_DELETED.getCode()); + return schisandraUserLikesDetailService.insert(schisandraUserLikesDetail) > 0; + } + + @Override + public Boolean update(SchisandraUserLikesDetailBO schisandraUserLikesDetailBO) { + SchisandraUserLikesDetail schisandraUserLikesDetail = SchisandraUserLikesDetailBOConverter.INSTANCE.convertBOToEntity(schisandraUserLikesDetailBO); + return schisandraUserLikesDetailService.update(schisandraUserLikesDetail) > 0; + } + + @Override + public Boolean delete(SchisandraUserLikesDetailBO schisandraUserLikesDetailBO) { + SchisandraUserLikesDetail schisandraUserLikesDetail = new SchisandraUserLikesDetail(); + schisandraUserLikesDetail.setId(schisandraUserLikesDetailBO.getId()); + schisandraUserLikesDetail.setIsDeleted(IsDeletedFlagEnum.DELETED.getCode()); + return schisandraUserLikesDetailService.update(schisandraUserLikesDetail) > 0; + } + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/dao/SchisandraUserLikesCommentDao.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/dao/SchisandraUserLikesCommentDao.java new file mode 100644 index 0000000..6a5eec4 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/dao/SchisandraUserLikesCommentDao.java @@ -0,0 +1,17 @@ +package com.schisandra.share.infra.basic.dao; + +import com.schisandra.share.infra.basic.entity.SchisandraUserLikesComment; +import com.mybatisflex.core.BaseMapper; +import org.springframework.stereotype.Repository; + +/** + * 评论点赞表 表数据库访问层 + * + * @author zlg + * @since 2024-07-20 14:11:01 + */ +@Repository +public interface SchisandraUserLikesCommentDao extends BaseMapper { + +} + diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/dao/SchisandraUserLikesDetailDao.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/dao/SchisandraUserLikesDetailDao.java new file mode 100644 index 0000000..3cf0e67 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/dao/SchisandraUserLikesDetailDao.java @@ -0,0 +1,17 @@ +package com.schisandra.share.infra.basic.dao; + +import com.schisandra.share.infra.basic.entity.SchisandraUserLikesDetail; +import com.mybatisflex.core.BaseMapper; +import org.springframework.stereotype.Repository; + +/** + * 分享详情点赞表 表数据库访问层 + * + * @author zlg + * @since 2024-07-20 14:12:42 + */ +@Repository +public interface SchisandraUserLikesDetailDao extends BaseMapper { + +} + diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/entity/SchisandraUserLikesComment.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/entity/SchisandraUserLikesComment.java new file mode 100644 index 0000000..3d5bcef --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/entity/SchisandraUserLikesComment.java @@ -0,0 +1,47 @@ +package com.schisandra.share.infra.basic.entity; + +import com.mybatisflex.annotation.Column; +import com.mybatisflex.annotation.Id; +import com.mybatisflex.annotation.KeyType; +import com.mybatisflex.annotation.Table; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + * 评论点赞表 实体类 + * + * @author zlg + * @since 2024-07-20 14:11:01 + */ +@Data +@Table("schisandra_user_likes_comment") +public class SchisandraUserLikesComment implements Serializable { + + /** + * + */ + @Id(value = "id", keyType = KeyType.Auto) + private String id; + + /** + * + */ + @Column("user_id") + private String userId; + + /** + * + */ + @Column("comment_id") + private String commentId; + + /** + * 是否删除 0 未删除 1已删除 + */ + @Column("is_deleted") + private Integer isDeleted; + +} + diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/entity/SchisandraUserLikesDetail.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/entity/SchisandraUserLikesDetail.java new file mode 100644 index 0000000..ac55683 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/entity/SchisandraUserLikesDetail.java @@ -0,0 +1,47 @@ +package com.schisandra.share.infra.basic.entity; + +import com.mybatisflex.annotation.Column; +import com.mybatisflex.annotation.Id; +import com.mybatisflex.annotation.KeyType; +import com.mybatisflex.annotation.Table; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + * 分享详情点赞表 实体类 + * + * @author zlg + * @since 2024-07-20 14:12:42 + */ +@Data +@Table("schisandra_user_likes_detail") +public class SchisandraUserLikesDetail implements Serializable { + + /** + * + */ + @Id(value = "id", keyType = KeyType.Auto) + private String id; + + /** + * + */ + @Column("user_id") + private String userId; + + /** + * + */ + @Column("detail_id") + private String detailId; + + /** + * + */ + @Column("is_deleted") + private Integer isDeleted; + +} + diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraShareDetailService.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraShareDetailService.java index c4fcceb..4e8347e 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraShareDetailService.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraShareDetailService.java @@ -31,6 +31,9 @@ public interface SchisandraShareDetailService { int delDetailViews(String Id); + int addDetailLike(String Id); + int delDetailLike(String Id); + /** * 通过ID查询单条数据 diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraUserFavoritesService.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraUserFavoritesService.java index 57db2e4..70ac970 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraUserFavoritesService.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraUserFavoritesService.java @@ -2,6 +2,8 @@ package com.schisandra.share.infra.basic.service; import com.schisandra.share.infra.basic.entity.SchisandraUserFavorites; +import java.util.List; + /** * 收藏表 表服务接口 * @@ -42,5 +44,5 @@ public interface SchisandraUserFavoritesService { */ boolean deleteById(Long id); - + List returnMyFavor(String userId); } diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraUserLikesCommentService.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraUserLikesCommentService.java new file mode 100644 index 0000000..9d79834 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraUserLikesCommentService.java @@ -0,0 +1,46 @@ +package com.schisandra.share.infra.basic.service; + +import com.schisandra.share.infra.basic.entity.SchisandraUserLikesComment; + +/** + * 评论点赞表 表服务接口 + * + * @author zlg + * @since 2024-07-20 14:11:01 + */ +public interface SchisandraUserLikesCommentService { + + /** + * 通过ID查询单条数据 + * + * @param id 主键 + * @return 实例对象 + */ + SchisandraUserLikesComment queryById(Long id); + + /** + * 新增数据 + * + * @param schisandraUserLikesComment 实例对象 + * @return 实例对象 + */ + int insert(SchisandraUserLikesComment schisandraUserLikesComment); + + /** + * 修改数据 + * + * @param schisandraUserLikesComment 实例对象 + * @return 实例对象 + */ + int update(SchisandraUserLikesComment schisandraUserLikesComment); + + /** + * 通过主键删除数据 + * + * @param id 主键 + * @return 是否成功 + */ + boolean deleteById(Long id); + + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraUserLikesDetailService.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraUserLikesDetailService.java new file mode 100644 index 0000000..1a78ab0 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/SchisandraUserLikesDetailService.java @@ -0,0 +1,46 @@ +package com.schisandra.share.infra.basic.service; + +import com.schisandra.share.infra.basic.entity.SchisandraUserLikesDetail; + +/** + * 分享详情点赞表 表服务接口 + * + * @author zlg + * @since 2024-07-20 14:12:42 + */ +public interface SchisandraUserLikesDetailService { + + /** + * 通过ID查询单条数据 + * + * @param id 主键 + * @return 实例对象 + */ + SchisandraUserLikesDetail queryById(Long id); + + /** + * 新增数据 + * + * @param schisandraUserLikesDetail 实例对象 + * @return 实例对象 + */ + int insert(SchisandraUserLikesDetail schisandraUserLikesDetail); + + /** + * 修改数据 + * + * @param schisandraUserLikesDetail 实例对象 + * @return 实例对象 + */ + int update(SchisandraUserLikesDetail schisandraUserLikesDetail); + + /** + * 通过主键删除数据 + * + * @param id 主键 + * @return 是否成功 + */ + boolean deleteById(Long id); + + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraShareDetailServiceImpl.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraShareDetailServiceImpl.java index e1c3cc8..24b20f9 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraShareDetailServiceImpl.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraShareDetailServiceImpl.java @@ -65,6 +65,24 @@ public class SchisandraShareDetailServiceImpl implements SchisandraShareDetailSe return schisandraShareDetailDao.update(schisandraShareDetail); } + @Override + public int addDetailLike(String Id) { + SchisandraShareDetail schisandraShareDetail = UpdateEntity.of(SchisandraShareDetail.class, Id); + UpdateWrapper wrapper = UpdateWrapper.of(schisandraShareDetail); + wrapper.set(SchisandraShareDetailTableDef.SCHISANDRA_SHARE_DETAIL.LIKES_COUNT, + SchisandraShareDetailTableDef.SCHISANDRA_SHARE_DETAIL.LIKES_COUNT.add(1)); + return schisandraShareDetailDao.update(schisandraShareDetail); + } + + @Override + public int delDetailLike(String Id) { + SchisandraShareDetail schisandraShareDetail = UpdateEntity.of(SchisandraShareDetail.class, Id); + UpdateWrapper wrapper = UpdateWrapper.of(schisandraShareDetail); + wrapper.set(SchisandraShareDetailTableDef.SCHISANDRA_SHARE_DETAIL.LIKES_COUNT, + SchisandraShareDetailTableDef.SCHISANDRA_SHARE_DETAIL.LIKES_COUNT.subtract(1)); + return schisandraShareDetailDao.update(schisandraShareDetail); + } + /** * 通过ID查询单条数据 * diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraUserFavoritesServiceImpl.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraUserFavoritesServiceImpl.java index 8849840..1cd94fb 100644 --- a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraUserFavoritesServiceImpl.java +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraUserFavoritesServiceImpl.java @@ -1,11 +1,14 @@ package com.schisandra.share.infra.basic.service.impl; +import com.mybatisflex.core.query.QueryWrapper; import com.schisandra.share.infra.basic.entity.SchisandraUserFavorites; import com.schisandra.share.infra.basic.dao.SchisandraUserFavoritesDao; +import com.schisandra.share.infra.basic.entity.table.SchisandraUserFavoritesTableDef; import com.schisandra.share.infra.basic.service.SchisandraUserFavoritesService; import org.springframework.stereotype.Service; import javax.annotation.Resource; +import java.util.List; /** * 收藏表 表服务实现类 @@ -63,5 +66,17 @@ public class SchisandraUserFavoritesServiceImpl implements SchisandraUserFavorit return this.schisandraUserFavoritesDao.deleteById(id) > 0; } + @Override + public List returnMyFavor(String userId) { + QueryWrapper wrapper = QueryWrapper.create() + .select(SchisandraUserFavoritesTableDef.SCHISANDRA_USER_FAVORITES.ID, + SchisandraUserFavoritesTableDef.SCHISANDRA_USER_FAVORITES.DETAIL_ID, + SchisandraUserFavoritesTableDef.SCHISANDRA_USER_FAVORITES.CIRCLE_ID, + SchisandraUserFavoritesTableDef.SCHISANDRA_USER_FAVORITES.CREATED_TIME) + .where(SchisandraUserFavoritesTableDef.SCHISANDRA_USER_FAVORITES.USER_ID.eq(userId)) + .orderBy(SchisandraUserFavoritesTableDef.SCHISANDRA_USER_FAVORITES.CREATED_TIME,false); + return this.schisandraUserFavoritesDao.selectListByQuery(wrapper); + } + } diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraUserLikesCommentServiceImpl.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraUserLikesCommentServiceImpl.java new file mode 100644 index 0000000..26feb33 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraUserLikesCommentServiceImpl.java @@ -0,0 +1,67 @@ +package com.schisandra.share.infra.basic.service.impl; + +import com.schisandra.share.infra.basic.entity.SchisandraUserLikesComment; +import com.schisandra.share.infra.basic.dao.SchisandraUserLikesCommentDao; +import com.schisandra.share.infra.basic.service.SchisandraUserLikesCommentService; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; + +/** + * 评论点赞表 表服务实现类 + * + * @author zlg + * @since 2024-07-20 14:11:01 + */ +@Service("SchisandraUserLikesCommentService") +public class SchisandraUserLikesCommentServiceImpl implements SchisandraUserLikesCommentService { + + @Resource + private SchisandraUserLikesCommentDao schisandraUserLikesCommentDao; + + /** + * 通过ID查询单条数据 + * + * @param id 主键 + * @return 实例对象 + */ + @Override + public SchisandraUserLikesComment queryById(Long id) { + return this.schisandraUserLikesCommentDao.selectOneById(id); + } + + /** + * 新增数据 + * + * @param schisandraUserLikesComment 实例对象 + * @return 实例对象 + */ + @Override + public int insert(SchisandraUserLikesComment schisandraUserLikesComment) { + return this.schisandraUserLikesCommentDao.insertSelective(schisandraUserLikesComment); + } + + /** + * 修改数据 + * + * @param schisandraUserLikesComment 实例对象 + * @return 实例对象 + */ + @Override + public int update(SchisandraUserLikesComment schisandraUserLikesComment) { + return this.schisandraUserLikesCommentDao.update(schisandraUserLikesComment,true); + } + + /** + * 通过主键删除数据 + * + * @param id 主键 + * @return 是否成功 + */ + @Override + public boolean deleteById(Long id) { + return this.schisandraUserLikesCommentDao.deleteById(id) > 0; + } + + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraUserLikesDetailServiceImpl.java b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraUserLikesDetailServiceImpl.java new file mode 100644 index 0000000..5cf5734 --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/java/com/schisandra/share/infra/basic/service/impl/SchisandraUserLikesDetailServiceImpl.java @@ -0,0 +1,67 @@ +package com.schisandra.share.infra.basic.service.impl; + +import com.schisandra.share.infra.basic.entity.SchisandraUserLikesDetail; +import com.schisandra.share.infra.basic.dao.SchisandraUserLikesDetailDao; +import com.schisandra.share.infra.basic.service.SchisandraUserLikesDetailService; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; + +/** + * 分享详情点赞表 表服务实现类 + * + * @author zlg + * @since 2024-07-20 14:12:42 + */ +@Service("SchisandraUserLikesDetailService") +public class SchisandraUserLikesDetailServiceImpl implements SchisandraUserLikesDetailService { + + @Resource + private SchisandraUserLikesDetailDao schisandraUserLikesDetailDao; + + /** + * 通过ID查询单条数据 + * + * @param id 主键 + * @return 实例对象 + */ + @Override + public SchisandraUserLikesDetail queryById(Long id) { + return this.schisandraUserLikesDetailDao.selectOneById(id); + } + + /** + * 新增数据 + * + * @param schisandraUserLikesDetail 实例对象 + * @return 实例对象 + */ + @Override + public int insert(SchisandraUserLikesDetail schisandraUserLikesDetail) { + return this.schisandraUserLikesDetailDao.insertSelective(schisandraUserLikesDetail); + } + + /** + * 修改数据 + * + * @param schisandraUserLikesDetail 实例对象 + * @return 实例对象 + */ + @Override + public int update(SchisandraUserLikesDetail schisandraUserLikesDetail) { + return this.schisandraUserLikesDetailDao.update(schisandraUserLikesDetail,true); + } + + /** + * 通过主键删除数据 + * + * @param id 主键 + * @return 是否成功 + */ + @Override + public boolean deleteById(Long id) { + return this.schisandraUserLikesDetailDao.deleteById(id) > 0; + } + + +} diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/resources/mapper/SchisandraUserLikesCommentDao.xml b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/resources/mapper/SchisandraUserLikesCommentDao.xml new file mode 100644 index 0000000..105cbaa --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/resources/mapper/SchisandraUserLikesCommentDao.xml @@ -0,0 +1,12 @@ + + + + + + + + + + + + diff --git a/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/resources/mapper/SchisandraUserLikesDetailDao.xml b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/resources/mapper/SchisandraUserLikesDetailDao.xml new file mode 100644 index 0000000..9d6f45f --- /dev/null +++ b/schisandra-cloud-storage-share/schisandra-cloud-storage-share-infra/src/main/resources/mapper/SchisandraUserLikesDetailDao.xml @@ -0,0 +1,12 @@ + + + + + + + + + + + +