商品瀑布流销量统计 待定

yami-shop-platform/src/main/java/com/yami/shop/platform/task/ProdWaterfallFlowTask.java

@@ -0,0 +1,71 @@
+/*
+ * Copyright (c) 2018-2999 广州亚米信息科技有限公司 All rights reserved.
+ *
+ * https://www.gz-yami.com/
+ *
+ * 未经允许，不可做商业用途！
+ *
+ * 版权所有，侵权必究！
+ */
+
+package com.yami.shop.platform.task;
+
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.date.DateUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.yami.shop.bean.bo.PayInfoBo;
+import com.yami.shop.bean.enums.OrderStatus;
+import com.yami.shop.bean.model.Order;
+import com.yami.shop.bean.model.OrderItem;
+import com.yami.shop.bean.model.OrderSettlement;
+import com.yami.shop.common.enums.PayType;
+import com.yami.shop.service.*;
+import com.yami.shop.service.hb.IHBOrderService;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+
+
+/**
+ * 商品瀑布流相关定时任务
+ */
+@Component("prodWaterfallFlowTask")
+public class ProdWaterfallFlowTask {
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    @Autowired
+    OrderService orderService;
+
+    /**
+     * 统计销量
+     */
+    public void countSales() {
+        LocalDate localDate = LocalDate.now();
+        LocalDateTime todayDateTime = localDate.atStartOfDay();
+        LocalDateTime first7DaysDateTime = localDate.minusDays(7).atStartOfDay();
+        // 获取当前时间
+        Date todayStartDate = Date.from(
+                todayDateTime
+                        .atZone(ZoneId.systemDefault())
+                        .toInstant()
+        );//获取当前时间
+        Date first7DaysStartDate = Date.from(
+                first7DaysDateTime
+                        .atZone(ZoneId.systemDefault())
+                        .toInstant()
+        );//获取7天前的时间
+//        orderService.countSales(todayStartDate,first7DaysStartDate);
+    }
+
+
+}

yami-shop-service/src/main/java/com/yami/shop/service/OrderService.java

@@ -184,4 +184,7 @@ public interface OrderService extends IService<Order> {
 
 
     OrderCountVo orderCount(BackendOrderParam orderParam);
+
+
+//    void countSales(Date todayStartDate, Date first7DaysStartDate);
 }