统计

src/main/java/com/izouma/nineth/repo/OrderRepo.java

@@ -120,4 +120,5 @@ public interface OrderRepo extends JpaRepository<Order, Long>, JpaSpecificationE
     @Query(nativeQuery = true, value = "SELECT o.name name,sum(o.total_price) as count, min(o.pic) pic FROM order_info o WHERE o.status = ?1  and o.created_at >=?2 and o.created_at < ?3  GROUP  BY o.name  ORDER BY sum(o.total_price) DESC limit 30")
     List<Map<String, BigDecimal>> salesStatistics3(String status, LocalDateTime startTime, LocalDateTime endTime);
 
+    List<Order> findAllByStatus(OrderStatus status);
 }

src/main/java/com/izouma/nineth/repo/UserRepo.java

@@ -203,4 +203,6 @@ public interface UserRepo extends JpaRepository<User, Long>, JpaSpecificationExe
     @Modifying
     Integer updateAppClientId(Long userId, String appClientId);
 
+    long countAllByDelFalse();
+
 }

src/main/java/com/izouma/nineth/service/StatisticService.java

@@ -0,0 +1,49 @@
+package com.izouma.nineth.service;
+
+import com.izouma.nineth.domain.Order;
+import com.izouma.nineth.enums.CollectionSource;
+import com.izouma.nineth.enums.OrderStatus;
+import com.izouma.nineth.repo.OrderRepo;
+import com.izouma.nineth.repo.TokenHistoryRepo;
+import com.izouma.nineth.repo.UserRepo;
+import lombok.AllArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Service
+@AllArgsConstructor
+public class StatisticService {
+    private UserRepo         userRepo;
+    private OrderRepo        orderRepo;
+    private TokenHistoryRepo tokenHistoryRepo;
+
+    public Map<String, Object> total() {
+        Map<String, Object> total = new HashMap<>();
+        List<Order> orders;
+        long user = userRepo.countAllByDelFalse();
+        total.put("userNum", user);
+        orders = orderRepo.findAllByStatus(OrderStatus.FINISH);
+
+        Map<CollectionSource, List<Order>> orderMap = orders.stream().collect(Collectors.groupingBy(Order::getSource));
+        List<Order> officialOrders = Optional.ofNullable(orderMap.get(CollectionSource.OFFICIAL))
+                .orElse(Collections.emptyList());
+        List<Order> transferOrders = Optional.ofNullable(orderMap.get(CollectionSource.TRANSFER))
+                .orElse(Collections.emptyList());
+
+        total.put("officialNum", officialOrders.size());
+        total.put("transferNum", transferOrders.size());
+
+        BigDecimal officialPrice = officialOrders.stream()
+                .map(Order::getTotalPrice)
+                .reduce(BigDecimal.ZERO, BigDecimal::add);
+        BigDecimal transferPrice = transferOrders.stream()
+                .map(Order::getTotalPrice)
+                .reduce(BigDecimal.ZERO, BigDecimal::add);
+        total.put("officialPrice", officialPrice);
+        total.put("transferPrice", transferPrice);
+        return total;
+    }
+}

src/main/java/com/izouma/nineth/web/StatisticController.java

@@ -0,0 +1,26 @@
+package com.izouma.nineth.web;
+
+import com.izouma.nineth.service.StatisticService;
+import lombok.AllArgsConstructor;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Map;
+
+@RestController
+@RequestMapping("/statistic")
+@AllArgsConstructor
+public class StatisticController {
+    private StatisticService statisticService;
+//    private CacheService     cacheService;
+
+    @PostMapping("/total")
+    @Cacheable("total")
+    @PreAuthorize("hasRole('ADMIN')")
+    public Map<String, Object> total() {
+        return statisticService.total();
+    }
+}