| | |
| | | package com.ruoyi.auction.service.impl; |
| | | |
| | | import cn.binarywang.wx.miniapp.api.WxMaService; |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.alibaba.fastjson.TypeReference; |
| | | import com.alibaba.fastjson.parser.Feature; |
| | | import com.alipay.api.AlipayApiException; |
| | | import com.alipay.api.AlipayClient; |
| | | import com.alipay.api.internal.util.AlipayEncrypt; |
| | | import com.alipay.api.internal.util.AlipaySignature; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | |
| | | import java.time.LocalDateTime; |
| | | import java.util.ArrayList; |
| | | import java.util.Arrays; |
| | | import java.util.Collection; |
| | | import java.util.HashMap; |
| | | import java.util.HashSet; |
| | | import java.util.List; |
| | |
| | | String msg = objectMapper.writeValueAsString(map); |
| | | WebSocketUsers.sendMessageToUsersByType(ClientTypeEnum.AUCTIONEER.getCode(), msg); |
| | | } |
| | | |
| | | @Override |
| | | public List<AuctionSalesroom> getAuctionSalesroomByIds( |
| | | Collection<Long> auctionSalesroomGoodsIdSet) { |
| | | List<AuctionSalesroomGoods> auctionSalesroomGoods = auctionSalesroomGoodsMapper.selectList( |
| | | Wrappers.lambdaQuery(AuctionSalesroomGoods.class) |
| | | .in(AuctionSalesroomGoods::getId, auctionSalesroomGoodsIdSet)); |
| | | Set<Long> auctionSalesroomIdSet = auctionSalesroomGoods.stream() |
| | | .map(AuctionSalesroomGoods::getAuctionSalesroomId).collect( |
| | | Collectors.toSet()); |
| | | return this.listByIds(auctionSalesroomIdSet); |
| | | } |
| | | } |