From 3c923d976c45df37ea752153e12107a3a29437e1 Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期四, 16 一月 2025 17:54:22 +0800 Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/qijisheng --- ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/SeckillActivityInfoServiceImpl.java | 54 ++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 52 insertions(+), 2 deletions(-) diff --git a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/SeckillActivityInfoServiceImpl.java b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/SeckillActivityInfoServiceImpl.java index f994879..6155d24 100644 --- a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/SeckillActivityInfoServiceImpl.java +++ b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/SeckillActivityInfoServiceImpl.java @@ -5,8 +5,10 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.account.api.feignClient.AppUserClient; import com.ruoyi.account.api.model.AppUser; +import com.ruoyi.common.core.utils.PageUtils; import com.ruoyi.common.core.utils.ServletUtils; import com.ruoyi.common.core.utils.StringUtils; +import com.ruoyi.common.core.web.page.TableDataInfo; import com.ruoyi.common.security.service.TokenService; import com.ruoyi.common.security.utils.SecurityUtils; import com.ruoyi.order.feignClient.OrderClient; @@ -62,10 +64,11 @@ private GoodsEvaluateService goodsEvaluateService; @Override - public List<SeckillActivityVO> listSeckillActivity(Goods goods) { + public TableDataInfo<SeckillActivityVO> listSeckillActivity(Goods goods) { LoginUser loginUserApplet = tokenService.getLoginUserApplet(); AppUser appUser = appUserClient.getAppUserById(loginUserApplet.getUserid()); goods.setVipId(appUser.getVipId()); + List<SeckillActivityVO> seckillActivityVOS = seckillActivityInfoMapper.listSeckillActivity(goods); for (SeckillActivityVO seckillActivityVO : seckillActivityVOS) { Integer data = orderClient.getGoodsSaleNum(seckillActivityVO.getGoodsId(), 2).getData(); @@ -81,7 +84,54 @@ seckillActivityVO.setStatus(1); // 未开始 } } - return seckillActivityVOS; + + Integer pageCurr = goods.getPageCurr(); + Integer pageSize = goods.getPageSize(); + String orderByColumn = goods.getOrderByColumn(); + String isAsc = goods.getIsAsc(); + // 排序 + Comparator<SeckillActivityVO> comparator = getComparator(orderByColumn, isAsc); + List<SeckillActivityVO> sortedList = seckillActivityVOS.stream() + .sorted(comparator) + .collect(Collectors.toList()); + + // 分页 + int startIndex = (pageCurr - 1) * pageSize; + int endIndex = Math.min(startIndex + pageSize, sortedList.size()); + + if (startIndex >= sortedList.size()) { + return new TableDataInfo(); + } + TableDataInfo tableDataInfo = new TableDataInfo(); + tableDataInfo.setRows(sortedList.subList(startIndex, endIndex)); + tableDataInfo.setTotal(sortedList.size()); + tableDataInfo.setCode(200); + return tableDataInfo; + } + + private Comparator<SeckillActivityVO> getComparator(String orderByColumn, String isAsc) { + Comparator<SeckillActivityVO> comparator; + + switch (orderByColumn) { + case "tgs.selling_price": + comparator = Comparator.comparing(SeckillActivityVO::getSellingPrice); + break; + case "integral": + comparator = Comparator.comparing(SeckillActivityVO::getIntegral); + break; + case "sale_num": + comparator = Comparator.comparing(SeckillActivityVO::getSaleNum); + break; + // 添加其他排序字段 + default: + comparator = Comparator.comparing(SeckillActivityVO::getId); // 默认按ID排序 + break; + } + + if ("desc".equalsIgnoreCase(isAsc)) { + comparator = comparator.reversed(); + } + return comparator; } @Override -- Gitblit v1.7.1