绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zxl
2025-10-16 79b026c753c25f998776d8a6210fc6afab97e647 
 framework/src/main/java/cn/lili/modules/order/order/serviceimpl/OrderServiceImpl.java


@@ -17,26 +17,23 @@


import cn.lili.common.event.TransactionCommitSendMQEvent;


import cn.lili.common.exception.ServiceException;


import cn.lili.common.properties.RocketmqCustomProperties;


import cn.lili.common.security.AuthUser;


import cn.lili.common.security.OperationalJudgment;


import cn.lili.common.security.context.UserContext;


import cn.lili.common.security.enums.UserEnums;


import cn.lili.common.utils.CurrencyUtil;


import cn.lili.common.utils.SnowFlake;


import cn.lili.common.utils.StringUtils;


import cn.lili.common.vo.ResultMessage;


import cn.lili.modules.goods.entity.dos.Goods;


import cn.lili.modules.goods.entity.dos.GoodsSku;


import cn.lili.modules.goods.entity.dto.GoodsCompleteMessage;


import cn.lili.modules.goods.service.GoodsService;


import cn.lili.modules.goods.service.GoodsSkuService;


import cn.lili.modules.lmk.domain.entity.CouponVirtual;


import cn.lili.modules.lmk.domain.vo.OrderCountByDayAndHourVO;


import cn.lili.modules.lmk.domain.vo.OrderCountVO;


import cn.lili.modules.lmk.enums.general.AdminRoleEnum;


import cn.lili.modules.lmk.enums.general.VirtualGoodsTypeEnum;


import cn.lili.modules.lmk.mapper.LmkOrderSelectMapper;


import cn.lili.modules.lmk.service.CouponVirtualService;


import cn.lili.modules.member.entity.dos.Member;


import cn.lili.modules.member.entity.dto.MemberAddressDTO;


import cn.lili.modules.member.mapper.MemberMapper;


import cn.lili.modules.order.cart.entity.dto.TradeDTO;


@@ -51,9 +48,7 @@


import cn.lili.modules.order.trade.entity.dos.OrderLog;


import cn.lili.modules.order.trade.service.OrderLogService;


import cn.lili.modules.payment.entity.enums.PaymentMethodEnum;


import cn.lili.modules.permission.entity.dos.AdminUser;


import cn.lili.modules.permission.service.AdminUserService;


import cn.lili.modules.permission.service.RoleService;


import cn.lili.modules.promotion.entity.dos.Coupon;


import cn.lili.modules.promotion.entity.dos.Pintuan;


import cn.lili.modules.promotion.service.CouponService;


@@ -91,7 +86,6 @@


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import io.reactivex.rxjava3.core.Maybe;


import lombok.extern.slf4j.Slf4j;


import org.apache.poi.ss.usermodel.Cell;


import org.apache.poi.ss.usermodel.Row;


@@ -113,15 +107,13 @@


import javax.servlet.http.HttpServletResponse;


import java.io.InputStream;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.net.URLEncoder;


import java.text.SimpleDateFormat;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.LocalTime;


import java.util.*;


import java.util.concurrent.TimeUnit;


import java.util.stream.Collectors;


import cn.lili.modules.permission.entity.dos.Role;




/**


 * 子订单业务层实现


 *


@@ -227,6 +219,11 @@




    @Autowired


    private GoodsSkuService goodsSkuService;




    @Autowired


    private LmkOrderSelectMapper lmkOrderSelectMapper;






    private final static  String LOCK_ORDER_NO_MQ="lock_order_no_mq:";


    private final static  String LOCK_EDIT_ORDER_ADDRESS="lock_edit_order_address:";


    private final static  String LOCK_COUPON_CARD="lock_coupon_card:";


@@ -277,6 +274,9 @@


                                String couponName = skuInfo.getCouponName();


                                orderItem.setCouponId(couponId);


                                orderItem.setCouponName(couponName);


                            }//订单中有定制商品将订单改为定制商品


                            else if (CustomizeFlagEnum.CUSTOMIZE.name().equals(skuInfo.getCustomizeFlag())) {


                                order.setCustomizeFlag(CustomizeFlagEnum.CUSTOMIZE.name());


                            }


                        }


                        orderItems.add(orderItem);


@@ -1399,7 +1399,7 @@


            }


        }




        List<Map<String, Object>> maps = baseMapper.selectOrderCountByDay(startTime,endTime);


        List<Map<String, Object>> maps = lmkOrderSelectMapper.selectOrderCountByDay(startTime,endTime,queryParam.getStoreId());




        Map<String, Long> dayCountMap = maps.stream()


                .collect(Collectors.toMap(


@@ -1494,7 +1494,20 @@








        List<Map<String, Object>> maps = baseMapper.selectOrderTimePeriod(startTime,endTime);


        List<Map<String, Object>> maps = lmkOrderSelectMapper.selectOrderTimePeriod(startTime,endTime,queryParam.getStoreId());


        List<String> goodsIds = new ArrayList<>();


        //如果查询条件带了店铺 查询店铺的商品


        if (StringUtils.isNotBlank(queryParam.getStoreId())){


            List<Goods> list = new LambdaQueryChainWrapper<>(goodsService.getBaseMapper())


                    .eq(Goods::getDeleteFlag, Boolean.FALSE)


                    .eq(Goods::getStoreId, queryParam.getStoreId())


                    .list();


            goodsIds = list.stream().map(Goods::getId).collect(Collectors.toList());


        }






        List<Map<String,Object>> countMap = lmkOrderSelectMapper.selectViewDataCount(startTime,endTime,queryParam.getStoreId(),goodsIds);






        Map<String, Long> countByDayHour = maps.stream()


                .collect(Collectors.toMap(


@@ -1502,20 +1515,258 @@


                        map -> Long.valueOf(map.get("count").toString()),


                        Long::sum  // 如果有重复，累加count


                ));




        Map<String, Long> viewDataCountByDayHour = countMap.stream()


                        .collect(Collectors.toMap(


                                map -> map.get("hour").toString(),


                                map -> Long.valueOf(map.get("count").toString()),


                                Long::sum


                        ));


        // 遍历查看结果


        List<Long> countList = new ArrayList<>();


        List<Long> viewData = new ArrayList<>();


        for (int i = 0; i < 24; i++) {


            String hourKey = String.valueOf(i);


            Long viewDataCount = viewDataCountByDayHour.getOrDefault(hourKey,0L);


            Long count = countByDayHour.getOrDefault(hourKey, 0L);


            countList.add(count);


            viewData.add(viewDataCount);


        }




        Map<String,Object> map = new HashMap<>();


        map.put("dateData",dateList);


        map.put("countData",countList);


        //TODO 浏览数据未加入


//        map.put();


        map.put("viewData",viewData);




        return Result.ok().data(map);


    }


    @Override


    public Result getPvUv(StatisticsQueryParam queryParam) {


        Date startTime = null;


        Date endTime = new Date(); // 结束时间默认是当前时间


        List<String> dateList = new ArrayList<>();


        Calendar calendar = Calendar.getInstance(); // 用于日期计算的日历实例


        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");


        int days = 0;


        if (queryParam.getYear() != null && queryParam.getMonth() != null) {


            Date[] dates =CommonUtil.getMonthStartAndEnd(queryParam.getYear(),queryParam.getMonth());


            startTime = dates[0];


            endTime = dates[1];


            Calendar tempCalendar = Calendar.getInstance();


            tempCalendar.setTime(startTime);


            days = tempCalendar.getActualMaximum(Calendar.DAY_OF_MONTH);


            for (int i = 0; i < days; i++) {


                dateList.add(sdf.format(tempCalendar.getTime()));


                tempCalendar.add(Calendar.DATE, 1); // 每天累加1天


            }


        }else{


            switch (queryParam.getSearchType()) {


                case "TODAY":


                    // 今天：从今天0点到现在


                    calendar.setTime(new Date()); // 重置为当前时间


                    calendar.set(Calendar.HOUR_OF_DAY, 0); // 小时设为0（24小时制）


                    calendar.set(Calendar.MINUTE, 0);      // 分钟设为0


                    calendar.set(Calendar.SECOND, 0);      // 秒设为0


                    calendar.set(Calendar.MILLISECOND, 0); // 毫秒设为0


                    startTime = calendar.getTime();        // 得到今天0点的Date对象


                    dateList.add(sdf.format(startTime));


                    break;


                case "YESTERDAY":


                    // 昨天：从昨天0点到昨天23:59:59.999


                    calendar.setTime(new Date());


                    calendar.add(Calendar.DATE, -1); // 日期减1天（变为昨天）




                    // 设置昨天0点


                    calendar.set(Calendar.HOUR_OF_DAY, 0);


                    calendar.set(Calendar.MINUTE, 0);


                    calendar.set(Calendar.SECOND, 0);


                    calendar.set(Calendar.MILLISECOND, 0);


                    startTime = calendar.getTime();




                    // 设置昨天23:59:59.999


                    calendar.set(Calendar.HOUR_OF_DAY, 23);


                    calendar.set(Calendar.MINUTE, 59);


                    calendar.set(Calendar.SECOND, 59);


                    calendar.set(Calendar.MILLISECOND, 999);


                    endTime = calendar.getTime();


                    dateList.add(sdf.format(startTime));


                    break;


                case "LAST_SEVEN":


                    // 过去七天：从7天前0点到现在（含今天共7天）


                    calendar.setTime(new Date());


                    calendar.add(Calendar.DATE, -6); // 日期减6天（7天前的今天）




                    // 设置7天前0点


                    calendar.set(Calendar.HOUR_OF_DAY, 0);


                    calendar.set(Calendar.MINUTE, 0);


                    calendar.set(Calendar.SECOND, 0);


                    calendar.set(Calendar.MILLISECOND, 0);


                    startTime = calendar.getTime();


                    days = 7;


                    // 循环生成7天的日期字符串


                    Calendar tempCalendar = Calendar.getInstance();


                    tempCalendar.setTime(startTime);


                    for (int i = 0; i < days; i++) {


                        dateList.add(sdf.format(tempCalendar.getTime()));


                        tempCalendar.add(Calendar.DATE, 1); // 每天累加1天


                    }


                    break;


                case "LAST_THIRTY":


                    // 过去30天：从30天前0点到现在（含今天共30天）


                    calendar.setTime(new Date());


                    calendar.add(Calendar.DATE, -29); // 日期减29天（30天前的今天）




                    // 设置30天前0点


                    calendar.set(Calendar.HOUR_OF_DAY, 0);


                    calendar.set(Calendar.MINUTE, 0);


                    calendar.set(Calendar.SECOND, 0);


                    calendar.set(Calendar.MILLISECOND, 0);


                    startTime = calendar.getTime();


                    days = 30;


                    // 循环生成30天的日期字符串


                    Calendar tempCalendar30 = Calendar.getInstance();


                    tempCalendar30.setTime(startTime);


                    for (int i = 0; i < days; i++) {


                        dateList.add(sdf.format(tempCalendar30.getTime()));


                        tempCalendar30.add(Calendar.DATE, 1); // 每天累加1天


                    }


                    break;


                default:


                    return Result.error("不支持的时间范围类型");


            }


        }


        List<String> goodsIds = new ArrayList<>();


        //如果查询条件带了店铺 查询店铺的商品


        if (StringUtils.isNotBlank(queryParam.getStoreId())){


            List<Goods> list = new LambdaQueryChainWrapper<>(goodsService.getBaseMapper())


                    .eq(Goods::getDeleteFlag, Boolean.FALSE)


                    .eq(Goods::getStoreId, queryParam.getStoreId())


                    .list();


            goodsIds = list.stream().map(Goods::getId).collect(Collectors.toList());


        }


        List<Map<String,Object>> maps = lmkOrderSelectMapper.selectPvUv(startTime,endTime,queryParam.getStoreId(),goodsIds);


        Map<String, Long> pvDataMap = maps.stream()


                .collect(Collectors.toMap(


                        map -> map.get("day").toString(),


                        map -> Long.valueOf(map.get("pvData").toString()),


                        Long::sum  // 如果有重复，累加count


                ));


        Map<String, Long> uvDataMap = maps.stream()


                .collect(Collectors.toMap(


                        map -> map.get("day").toString(),


                        map -> Long.valueOf(map.get("uvData").toString()),


                        Long::sum  // 如果有重复，累加count


                ));


        List<Long> pvData = new ArrayList<>();


        List<Long> uvData = new ArrayList<>();


        for (String date: dateList){


            String dayKey = String.valueOf(date);


            Long pv = pvDataMap.getOrDefault(dayKey,0L);


            Long uv = uvDataMap.getOrDefault(dayKey, 0L);


            pvData.add(pv);


            uvData.add(uv);


        }




        Map<String,Object> map = new HashMap<>();


        map.put("dateData",dateList);


        map.put("pvData",pvData);


        map.put("uvData",uvData);


        return Result.ok().data(map);




    }




    @Override


    public Result gerProductRepurchase(StatisticsQueryParam queryParam) {


        Date startTime = null;


        Date endTime = new Date(); // 结束时间默认是当前时间




        Calendar calendar = Calendar.getInstance(); // 用于日期计算的日历实例




        if (queryParam.getYear() != null && queryParam.getMonth() != null) {


            Date[] dates =CommonUtil.getMonthStartAndEnd(queryParam.getYear(),queryParam.getMonth());


            startTime = dates[0];


            endTime = dates[1];


        }else{


            switch (queryParam.getSearchType()) {


                case "TODAY":


                    // 今天：从今天0点到现在


                    calendar.setTime(new Date()); // 重置为当前时间


                    calendar.set(Calendar.HOUR_OF_DAY, 0); // 小时设为0（24小时制）


                    calendar.set(Calendar.MINUTE, 0);      // 分钟设为0


                    calendar.set(Calendar.SECOND, 0);      // 秒设为0


                    calendar.set(Calendar.MILLISECOND, 0); // 毫秒设为0


                    startTime = calendar.getTime();        // 得到今天0点的Date对象


                    break;


                case "YESTERDAY":


                    // 昨天：从昨天0点到昨天23:59:59.999


                    calendar.setTime(new Date());


                    calendar.add(Calendar.DATE, -1); // 日期减1天（变为昨天）




                    // 设置昨天0点


                    calendar.set(Calendar.HOUR_OF_DAY, 0);


                    calendar.set(Calendar.MINUTE, 0);


                    calendar.set(Calendar.SECOND, 0);


                    calendar.set(Calendar.MILLISECOND, 0);


                    startTime = calendar.getTime();




                    // 设置昨天23:59:59.999


                    calendar.set(Calendar.HOUR_OF_DAY, 23);


                    calendar.set(Calendar.MINUTE, 59);


                    calendar.set(Calendar.SECOND, 59);


                    calendar.set(Calendar.MILLISECOND, 999);


                    endTime = calendar.getTime();


                    break;


                case "LAST_SEVEN":


                    // 过去七天：从7天前0点到现在（含今天共7天）


                    calendar.setTime(new Date());


                    calendar.add(Calendar.DATE, -6); // 日期减6天（7天前的今天）




                    // 设置7天前0点


                    calendar.set(Calendar.HOUR_OF_DAY, 0);


                    calendar.set(Calendar.MINUTE, 0);


                    calendar.set(Calendar.SECOND, 0);


                    calendar.set(Calendar.MILLISECOND, 0);


                    startTime = calendar.getTime();




                    break;


                case "LAST_THIRTY":


                    // 过去30天：从30天前0点到现在（含今天共30天）


                    calendar.setTime(new Date());


                    calendar.add(Calendar.DATE, -29); // 日期减29天（30天前的今天）




                    // 设置30天前0点


                    calendar.set(Calendar.HOUR_OF_DAY, 0);


                    calendar.set(Calendar.MINUTE, 0);


                    calendar.set(Calendar.SECOND, 0);


                    calendar.set(Calendar.MILLISECOND, 0);


                    startTime = calendar.getTime();




                    break;


                default:


                    return Result.error("不支持的时间范围类型");


            }


        }


        List<Map<String, Object>> maps = lmkOrderSelectMapper.selectProductRepurchase(startTime,endTime,queryParam.getCurrentLimit(),queryParam.getStoreId());


        List<String> goodsData = new ArrayList<>();


        List<BigDecimal> rateData = new ArrayList<>();




        // 遍历结果集，提取数据到集合


        for (Map<String, Object> map : maps) {


            // 提取商品名（注意：键是resultMap中定义的property值"goodsName"）


            if (Objects.nonNull(map.get("goodsName"))) {


                String goodsName = map.get("goodsName").toString();


                goodsData.add(goodsName);


            }




            // 提取复购率（复购率通常是数字类型，这里用BigDecimal接收）


            if (Objects.nonNull(map.get("repurchaseRate"))) {


                // 转换为BigDecimal（根据实际类型调整，也可能是Double等）


                BigDecimal rate = new BigDecimal(map.get("repurchaseRate").toString()).setScale(2, RoundingMode.HALF_UP);


                rateData.add(rate);


            }


        }


        Map<String,Object> map = new HashMap<>();


        map.put("goodsData",goodsData);


        map.put("rateData",rateData);




        return Result.ok().data(map);


    }