From dba9034024de73ebf8d1184b53ec9a559c1c12c6 Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期四, 13 三月 2025 18:08:33 +0800
Subject: [PATCH] bug修改
---
ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/AuctionSalesroomServiceImpl.java | 15 ++++++++-------
1 files changed, 8 insertions(+), 7 deletions(-)
diff --git a/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/AuctionSalesroomServiceImpl.java b/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/AuctionSalesroomServiceImpl.java
index 73b0892..91bd6c3 100644
--- a/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/AuctionSalesroomServiceImpl.java
+++ b/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/AuctionSalesroomServiceImpl.java
@@ -479,6 +479,7 @@
memberAuctionSalesroomInfoVO.setType(byId.getType());
memberAuctionSalesroomInfoVO.setDescription(byId.getDescription());
memberAuctionSalesroomInfoVO.setShareTitle(byId.getShareTitle());
+ memberAuctionSalesroomInfoVO.setAuctionAgreement(byId.getAuctionAgreement());
if (StringUtils.isNotBlank(byId.getShareTitle())) {
memberAuctionSalesroomInfoVO.setShareTitle(byId.getShareTitle());
} else {
@@ -529,6 +530,7 @@
forepartAuctionSalesroomGoodsVO.setDealQuantity(salesroomGoods.getDealQuantity());
forepartAuctionSalesroomGoodsVO.setMaxAmount(salesroomGoods.getMaxAmount());
forepartAuctionSalesroomGoodsVO.setBidNum(salesroomGoods.getBidNum());
+ forepartAuctionSalesroomGoodsVO.setUnit(goodsSku.getUnit());
LambdaQueryWrapper<AuctionBidRecord> wrapper1=Wrappers.lambdaQuery();
wrapper1.eq(AuctionBidRecord::getMemberId,memberAuctionSalesroomDTO.getMemberId());
wrapper1.eq(AuctionBidRecord::getAuctionSalesroomId,byId.getId());
@@ -1620,8 +1622,7 @@
if (CollUtils.isNotEmpty(successMemberList)) {
// 推送websocket消息
sendWebsocketMsg(auctionSalesroomGoods.getId(), successMemberList,
- goodsSku, 1,
- orderIdMap, bidMap);
+ goodsSku, 1, orderIdMap, bidMap);
// 发送短信通知
List<String> mobileList = successMemberList.stream()
.map(Member::getPhone)
@@ -1638,8 +1639,7 @@
if (CollUtils.isNotEmpty(failedMemberList)) {
// 推送websocket消息
sendWebsocketMsg(auctionSalesroomGoods.getId(), failedMemberList,
- goodsSku, 0,
- orderIdMap, bidMap);
+ goodsSku, 0, orderIdMap, bidMap);
// 发送短信通知
List<String> mobileList = failedMemberList.stream()
.map(Member::getPhone)
@@ -1696,10 +1696,11 @@
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(), "0"));
+ map.put("member_id", member.getId().toString());
String msg = com.alibaba.fastjson2.JSONObject.toJSONString(map);
- sysUserClient.pushBatch(
- WebsocketMessageDTO.builder().message(msg).userId(member.getUserId()).build(),
- SecurityConstants.INNER);
+ sysUserClient.pushByClientType(
+ WebsocketMessageDTO.builder().message(msg).clientType(ClientTypeEnum.MEMBER)
+ .build(), SecurityConstants.INNER);
log.info("===================>发送websocket通知，消息体{}", msg);
}
}
--
Gitblit v1.7.1