From 42521c9b51c1bd9a40036f18fd610cd46601222d Mon Sep 17 00:00:00 2001
From: yanghui <2536613402@qq.com>
Date: 星期一, 28 十一月 2022 14:45:22 +0800
Subject: [PATCH] #feat .

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerGoodsServiceImpl.java |   15 +++++++++++++--
 1 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerGoodsServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerGoodsServiceImpl.java
index 8bf6854..146dade 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerGoodsServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerGoodsServiceImpl.java
@@ -30,6 +30,7 @@
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 import static java.util.Objects.isNull;
@@ -43,7 +44,6 @@
  */
 @Service
 @Slf4j
-@Transactional(rollbackFor = Exception.class)
 public class ComShopFlowerGoodsServiceImpl extends ServiceImpl<ComShopFlowerGoodsDAO, ComShopFlowerGoodsDO> implements ComShopFlowerGoodsService {
 
     @Resource
@@ -62,6 +62,7 @@
     private ComShopFlowerGoodsViewStatisticsDAO comShopFlowerGoodsViewStatisticsDAO;
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public R saveShopFlowerGoods(AddShopFlowerGoodsVO addShopFlowerGoodsVO) {
         if (addShopFlowerGoodsVO == null) {
             return R.ok("500", "数据为空!");
@@ -234,6 +235,7 @@
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public R editFlowerShopGoods(Long id, AddShopFlowerGoodsVO addShopFlowerGoodsVO) {
         if (addShopFlowerGoodsVO == null) {
             return R.ok("500", "数据为空!");
@@ -303,6 +305,7 @@
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public R deleteShopFlowerGoods(Long id) {
         ComShopFlowerGoodsDO comShopFlowerGoodsDO = this.baseMapper.selectById(id);
         comShopFlowerGoodsDO.setDeleteStatus(ComShopFlowerGoodsDO.deleteStatus.yes);
@@ -311,6 +314,7 @@
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public R changeStatus(Long id, Integer status) {
         ComShopFlowerGoodsDO shopGoodsDO = this.baseMapper.selectById(id);
         if (shopGoodsDO == null) {
@@ -332,10 +336,17 @@
         ComShopFlowerGoodsViewStatisticsDO statisticsDO = comShopFlowerGoodsViewStatisticsDAO.selectOne(new LambdaQueryWrapper<ComShopFlowerGoodsViewStatisticsDO>()
                 .eq(ComShopFlowerGoodsViewStatisticsDO::getGoodsId, goodsId).eq(ComShopFlowerGoodsViewStatisticsDO::getStatisticDate, nowDate));
         if (isNull(statisticsDO)) {
-            comShopFlowerGoodsViewStatisticsDAO.createTodayStatistic(goodsId);
+            comShopFlowerGoodsViewStatisticsDAO.createTodayStatistic(goodsId,nowDate);
         } else {
             comShopFlowerGoodsViewStatisticsDAO.incrViewNum(goodsId, nowDate);
         }
         return R.ok();
     }
+
+    @Override
+    public R countSaleByUserId(Long userId){
+        List<ComShopOrderStoreIdCountVO> comShopOrderStoreIdCountVOS = this.baseMapper.countSaleByUserId(userId);
+        Map<String, Integer> collect = comShopOrderStoreIdCountVOS.stream().collect(Collectors.toMap(ComShopOrderStoreIdCountVO::getCountName, ComShopOrderStoreIdCountVO::getCountNum));
+        return R.ok(collect);
+    }
 }

--
Gitblit v1.7.1