From c39795863bdd49202e9b1d2f2ba2f926837bb923 Mon Sep 17 00:00:00 2001 From: 陶杰 <1378534974@qq.com> Date: 星期三, 27 十一月 2024 22:36:57 +0800 Subject: [PATCH] 1.合伙人-需要修改联系人名称、联系方式、城市仓名称、地区、地址、身份证照片 --- src/main/java/com/mzl/flower/service/statistics/StatisticsService.java | 82 +++++++++++++++++++++++++++++++++++++---- 1 files changed, 74 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/mzl/flower/service/statistics/StatisticsService.java b/src/main/java/com/mzl/flower/service/statistics/StatisticsService.java index a2c7a37..92767a5 100644 --- a/src/main/java/com/mzl/flower/service/statistics/StatisticsService.java +++ b/src/main/java/com/mzl/flower/service/statistics/StatisticsService.java @@ -1,30 +1,38 @@ package com.mzl.flower.service.statistics; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.mzl.flower.config.exception.ValidationException; +import com.mzl.flower.config.security.SecurityUtils; import com.mzl.flower.constant.Constants; import com.mzl.flower.dto.request.flower.FlowerQueryDTO; import com.mzl.flower.dto.request.payment.OrderItemSalesQueryDTO; import com.mzl.flower.dto.request.payment.OrderQueryDTO; +import com.mzl.flower.dto.response.payment.OrderStatusCountDTO; import com.mzl.flower.dto.response.statistics.FlowerStatisticsDTO; import com.mzl.flower.dto.response.statistics.OrderStatisticsDTO; import com.mzl.flower.dto.response.statistics.RateStatisticsDTO; import com.mzl.flower.dto.response.statistics.SaleStatisticsDTO; import com.mzl.flower.entity.customer.Customer; +import com.mzl.flower.entity.ip.UserAccess; import com.mzl.flower.entity.payment.Order; import com.mzl.flower.entity.supplier.Supplier; import com.mzl.flower.mapper.customer.CustomerMapper; import com.mzl.flower.mapper.flower.FlowerMapper; +import com.mzl.flower.mapper.ip.UserAccessMapper; import com.mzl.flower.mapper.payment.*; import com.mzl.flower.mapper.supplier.SupplierMapper; import com.mzl.flower.service.BaseService; +import com.mzl.flower.utils.IpUtil; import io.micrometer.core.instrument.util.StringUtils; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import javax.servlet.http.HttpServletRequest; +import java.io.IOException; import java.math.BigDecimal; import java.math.RoundingMode; import java.time.LocalDate; @@ -54,6 +62,9 @@ @Autowired private CustomerMapper customerMapper; + + @Autowired + private UserAccessMapper userAccessMapper; public SaleStatisticsDTO getSaleStatistics(String date){ if(StringUtils.isEmpty(date)){ @@ -95,14 +106,27 @@ .eq("is_enabled", 1) .eq("status", "P") .eq("deleted", 0)); - dto.setSupplierCount(sc.longValue());//用户管理:统计商户列表已启用的全部用户(点击跳转到商户列表) + dto.setSupplierCount(sc.longValue()); - Integer oc = orderMapper.selectCount(new QueryWrapper<Order>() - .eq("deleted", 0) - .isNotNull("payment_time") - .isNull("cancel_time") - .isNull("refund_time")); - dto.setOrderCount(oc.longValue());//订单管理:全部订单数量-待付款-已取消-已退款(点击跳转到订单列表) + Integer cc = customerMapper.selectCount(new QueryWrapper<Customer>() + .eq("is_enabled", 1) + .eq("deleted", 0)); + dto.setCustomerCount(cc.longValue());//用户管理:统计商户列表已启用的全部用户(点击跳转到商户列表) + + //订单管理:全部订单数量-待付款-已取消-已退款(点击跳转到订单列表) + List<OrderStatusCountDTO> ll = orderMapper.getOrderStatusCount(new OrderQueryDTO()); + Integer oc = 0; + if (ll != null && ll.size() > 0) { + for (OrderStatusCountDTO c : ll) { + if(Constants.ORDER_STATUS_BACKEND.PENDING.name().equals(c.getValue()) + || Constants.ORDER_STATUS_BACKEND.CANCEL.name().equals(c.getValue()) + || Constants.ORDER_STATUS_BACKEND.REFUND.name().equals(c.getValue())){ + continue; + } + oc += c.getOrderCount(); + } + } + dto.setOrderCount(oc.longValue()); page = new Page(1, 1); OrderQueryDTO oq = new OrderQueryDTO(); @@ -297,8 +321,22 @@ LocalDateTime beginY = begin.plusDays(-1); RateStatisticsDTO dto = new RateStatisticsDTO(); - //TODO 用户访问量:点击到交易大厅或者商品详情页面计算,同一个用户,每天只计算一次(包含游客)(并计算新增量,计算日环比) + //用户访问量:点击到交易大厅或者商品详情页面计算,同一个用户,每天只计算一次(包含游客)(并计算新增量,计算日环比) + Integer c = userAccessMapper.selectCount(new QueryWrapper<UserAccess>()); + dto.setCount(c.longValue()); + + Integer cT = userAccessMapper.selectCount(new QueryWrapper<UserAccess>() + .gt("create_time", begin) + .le("create_time", end) + ); + dto.setCountToday(cT.longValue()); + + Integer cY = userAccessMapper.selectCount(new QueryWrapper<UserAccess>() + .gt("create_time", beginY) + .le("create_time", endY) + ); + dto.setCountRate(getRate(cT, cY)); return dto; } @@ -356,8 +394,36 @@ BigDecimal yy = BigDecimal.valueOf(yesterday); BigDecimal rate = ttyy.divide(yy, 2, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); return rate.doubleValue(); + } else if (today <= 0) { + return 0D; } return 100D; } + + + public void addUserAccessRecord(HttpServletRequest request){ + String userId = SecurityUtils.getUserId(); + String ip = null; + try { + ip = IpUtil.getIpAddress(request); + } catch (IOException e) { + ip = "127.0.0.1"; + } + String ipId = ip+":"+(StringUtils.isBlank(userId)?"0":userId); + + LocalDate localDate = LocalDate.now(); + LocalDateTime end = localDate.atTime(23, 59, 59); + LocalDateTime begin = localDate.atTime(0, 0, 0); + int count = userAccessMapper.selectCount(new LambdaQueryWrapper<UserAccess>() + .eq(UserAccess::getIpId, ipId) + .gt(UserAccess::getCreateTime, begin) + .le(UserAccess::getCreateTime, end)); + if(count==0){ + UserAccess record = new UserAccess(); + record.setIpId(ipId); + record.setCreateTime(LocalDateTime.now()); + userAccessMapper.insert(record); + } + } } -- Gitblit v1.9.3