CC/Jarvis_java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

菜单优化

Browse Source
This commit is contained in:
雷欧（林平凡）
2025-03-12 17:19:44 +08:00
parent 727b1a5200
commit 4964d973d0
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/cn/van/business/mq/MessageConsumerService.java
View File

@@ -30,7 +30,7 @@ import static cn.van.business.util.WXUtil.WX_BASE_URL;
public class MessageConsumerService implements RocketMQListener<JSONObject> { public class MessageConsumerService implements RocketMQListener<JSONObject> {
private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class); private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class);
private static final RateLimiter rateLimiter = RateLimiter.create(2, // 1 QPS private static final RateLimiter rateLimiter = RateLimiter.create(4, // 1 QPS
0, // 预热期 5 秒 0, // 预热期 5 秒
TimeUnit.SECONDS); TimeUnit.SECONDS);

7
src/main/java/cn/van/business/util/OrderUtil.java
View File

@@ -73,8 +73,11 @@ public class OrderUtil {
String wxId = getWxidFromJdid(orderRowList.get(0).getUnionId().toString()); String wxId = getWxidFromJdid(orderRowList.get(0).getUnionId().toString());
StringBuilder content = new StringBuilder(); StringBuilder content = new StringBuilder();
content.append("批量订单：\n\r ").append(" 共 ").append(orderRowList.size()).append("单 \n\r"); content.append("批量订单：\n\r ").append(" 共 ").append(orderRowList.size()).append("单 \n\r");
List<OrderRow> filterList = orderRowList.stream().filter(orderRow -> orderRow.getValidCode() != 16 && orderRow.getValidCode() != 17).toList(); List<OrderRow> filterList = orderRowList.stream().filter(orderRow -> orderRow.getValidCode() == 16
content.append("移除取消的订单, 共 ").append(filterList.size()).append("单 \n\r"); || orderRow.getValidCode() == 17
|| orderRow.getValidCode() == 15
|| orderRow.getValidCode() == 13).toList();
content.append("移除取消的订单（保留状态 13 15 16 17）, 共 ").append(filterList.size()).append("单 \n\r");
for (OrderRow orderRow : filterList) { for (OrderRow orderRow : filterList) {
String oldValidCode = redisTemplate.opsForValue().get(ORDER_ROW_KEY + orderRow.getId()); String oldValidCode = redisTemplate.opsForValue().get(ORDER_ROW_KEY + orderRow.getId());