| | |
| | | auctionBidRecord.setStatus(BidStatusEnum.SUCCESSFUL); |
| | | Long orderId = AddOrder(auctionBidRecord.getTargetId(), |
| | | auctionBidRecord.getMemberId(), |
| | | auctionBidRecord.getLastBidAmount(), auctionSalesroom.getBond(), 1); |
| | | auctionBidRecord.getLastBidAmount(), auctionSalesroom.getBond(), |
| | | auctionSalesroomGoods.getDealQuantity()); |
| | | if (Objects.nonNull(orderId)) { |
| | | orderIdMap.put(auctionBidRecord.getMemberId(), orderId.toString()); |
| | | auctionBidRecord.setOrderId(orderId); |
| | |
| | | .equals(BidStatusEnum.SUCCESSFUL)) |
| | | .map(AuctionBidRecord::getMemberId) |
| | | .collect(Collectors.toList()); |
| | | Map<Long, Long> bidMap = auctionBidRecordList.stream().collect( |
| | | Collectors.toMap(AuctionBidRecord::getMemberId, AuctionBidRecord::getId)); |
| | | Map<Long, String> bidMap = auctionBidRecordList.stream().collect( |
| | | Collectors.toMap(AuctionBidRecord::getMemberId, |
| | | item -> item.getId().toString())); |
| | | if (CollUtils.isNotEmpty(successMemberIdList)) { |
| | | List<Member> successMemberList = memberClient.getMemberListByIds( |
| | | successMemberIdList, SecurityConstants.INNER).getData(); |
| | |
| | | * @param successFlag // 中标状态 1:中标 0:未中标 |
| | | */ |
| | | private void sendWebsocketMsg(Long id, List<Member> memberList, GoodsSku goodsSku, |
| | | Integer successFlag, Map<Long, String> userIdMap, Map<Long, Long> bidMap) { |
| | | Integer successFlag, Map<Long, String> userIdMap, Map<Long, String> bidMap) { |
| | | for (Member member : memberList) { |
| | | Map<String, Object> map = new ConcurrentHashMap<>(); |
| | | map.put("notification_type", NotificationTypeConstant.AUCTION_POPUP); |
| | |
| | | map.put("goods_name", Objects.nonNull(goodsSku) ? goodsSku.getSkuName() : ""); |
| | | map.put("success_flag", successFlag); |
| | | map.put("order_id", successFlag == 1 ? userIdMap.getOrDefault(member.getId(), "") : ""); |
| | | map.put("auction_bid_record_id", bidMap.getOrDefault(member.getId(), 0L)); |
| | | map.put("auction_bid_record_id", bidMap.getOrDefault(member.getId(), "0")); |
| | | String msg = JSONObject.toJSONString(map); |
| | | sysUserClient.pushBatch( |
| | | WebsocketMessageDTO.builder().message(msg).userId(member.getUserId()).build(), |
| | |
| | | |
| | | |
| | | public Long AddOrder(Long goodsSkuId, Long memberId, BigDecimal lastBidAmount, |
| | | BigDecimal bound, Integer goodsQuantity) { |
| | | BigDecimal bound, Integer dealQuantity) { |
| | | OrderDTO order=new OrderDTO(); |
| | | order.setGoodsSkuId(goodsSkuId); |
| | | order.setOrderTime(LocalDateTime.now()); |
| | |
| | | order.setMemberId(memberId); |
| | | AuctionSalesroomGoods auctionSalesroomGoods = this.getById(goodsSkuId); |
| | | |
| | | order.setGoodsQuantity(goodsQuantity); |
| | | order.setTotalAmount(lastBidAmount); |
| | | order.setGoodsQuantity(dealQuantity); |
| | | order.setTotalAmount(lastBidAmount.multiply(new BigDecimal(dealQuantity))); |
| | | order.setAuctionSalesroomId(auctionSalesroomGoods.getAuctionSalesroomId()); |
| | | |
| | | R<MemberAddress> memberAddressR = memberClient.getMemberAddressOne(memberId, |