From 94fcc2ae095689bd55f0382eee9290b20781ca80 Mon Sep 17 00:00:00 2001 From: SongZhang <2064194730@qq.com> Date: Thu, 25 Jul 2024 14:47:21 +0800 Subject: [PATCH] =?UTF-8?q?1.=E8=80=97=E6=9D=90=E9=A2=84=E8=AD=A6=E6=8E=A8?= =?UTF-8?q?=E9=80=81=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../system/cashierservice/rabbit/ConsMsgConsumer.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/ConsMsgConsumer.java b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/ConsMsgConsumer.java index 2c9fbf6..2a91822 100644 --- a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/ConsMsgConsumer.java +++ b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/ConsMsgConsumer.java @@ -127,10 +127,12 @@ public class ConsMsgConsumer { String value = redisUtil.getMessage(key); log.info("redis_key:{}",value); if (Objects.isNull(value)) { - wxAccountUtil.sendStockWarnMsg(shopInfo.getShopName(), "耗材库存不足: " + tbConsInfo.getConName(), - tbConsInfo.getStockNumber().subtract(tbConsInfo.getStockConsume()).setScale(2,BigDecimal.ROUND_DOWN).toPlainString(), tbUserShopMsg.getOpenId()); - log.info("写入redis:{}",key); - redisUtil.saveMessage(key, "1", 10 * 60); + JSONObject jsonObject = wxAccountUtil.sendStockWarnMsg(shopInfo.getShopName(), "耗材:" + tbConsInfo.getConName(), + tbConsInfo.getStockNumber().subtract(tbConsInfo.getStockConsume()).setScale(2, BigDecimal.ROUND_DOWN).toPlainString(), tbUserShopMsg.getOpenId()); + if (jsonObject != null) { + log.info("写入redis:{}",key); + redisUtil.saveMessage(key, "1", 10 * 60); + } } });