From b937cb08826165b16ad4fa7f27b104650da6ec8b Mon Sep 17 00:00:00 2001 From: wangshuai Date: Sat, 17 Aug 2024 16:33:18 +0800 Subject: [PATCH] =?UTF-8?q?1=EF=BC=9B=E7=9F=AD=E4=BF=A1=E5=8F=91=E9=80=81?= =?UTF-8?q?=E5=A4=B1=E8=B4=A5=E8=B7=B3=E5=87=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/ruoyi/business/service/IAiService.java | 2 +- .../java/com/ruoyi/business/service/impl/AiConsumer.java | 5 ++++- .../com/ruoyi/business/service/impl/AiServiceImpl.java | 7 ++++--- 3 files changed, 9 insertions(+), 5 deletions(-) diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/IAiService.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/IAiService.java index 8c8e21c..6b7f666 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/IAiService.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/IAiService.java @@ -17,5 +17,5 @@ public interface IAiService { void sms(); - void sendSmsTask(String content, BusOrderInfo busOrderInfo); + Boolean sendSmsTask(String content, BusOrderInfo busOrderInfo); } diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java index ba74907..5020078 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java @@ -199,7 +199,10 @@ public class AiConsumer { fifteenInfo.setLastVisitTime(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); fifteenInfoService.insertBusFifteenInfo(fifteenInfo); }else if("sms".equals(busStoreInfo.getMarketingChannels())){ - aiService.sendSmsTask(content,busOrderInfo); + Boolean aBoolean = aiService.sendSmsTask(content,busOrderInfo); + if(!aBoolean){ + return; + } BusAgentInfo busAgentInfo =agentInfo; int a = 1; int reduce = busAgentInfo.getAiDurationBalance() - a; diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java index edeb5d5..f93d852 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java @@ -328,7 +328,7 @@ public class AiServiceImpl implements IAiService { @Override @Transactional(rollbackFor = ServiceException.class) - public void sendSmsTask(String content, BusOrderInfo busOrderInfo) { + public Boolean sendSmsTask(String content, BusOrderInfo busOrderInfo) { try { String limitNum = Optional.ofNullable(redisTemplate.opsForValue().get("limitNum")).orElse(null); BusSmsInfo busSmsInfo1 = busSmsInfoMapper.selectBusSmsInfoByNum(limitNum); @@ -339,7 +339,7 @@ public class AiServiceImpl implements IAiService { redisTemplate.delete("limitNum"); redisTemplate.delete("totalNum"); log.error("短信余额为空，请充值"); - return; + return false; } redisTemplate.opsForValue().set("limitNum",busSmsInfo1.getLimitNum()+""); redisTemplate.opsForValue().set("totalNum",busSmsInfo1.getTotalNum()+""); @@ -358,10 +358,11 @@ public class AiServiceImpl implements IAiService { }else { log.error(busOrderInfo.getStoreCode()+"sendSmsTask****短信回访失败 "+phoneNo); } + return true; } catch (Exception e) { e.printStackTrace(); log.error(busOrderInfo.getOrderNo()+"建立sendSmsTask错误： "+e.getMessage()); - throw new ServiceException("短信发送失败！"); + return false; } }