wangshuai
/
youshi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1;营销日志去除 

2；优化短信发送锁
This commit is contained in:
Lenovo 2024-08-08 17:04:50 +08:00
parent 0f2b88f86f
commit 19dbf4bbad
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java
View File

@ -63,7 +63,7 @@ public class AiServiceImpl implements IAiService {
@Autowired @Autowired
private AiProducter aiProducer; private AiProducter aiProducer;
private final ReentrantLock lock = new ReentrantLock(); private final static ReentrantLock lock = new ReentrantLock();
private String userSn = "SYSUSER|8398f13f3feccef770ee4d465fe22fbf"; private String userSn = "SYSUSER|8398f13f3feccef770ee4d465fe22fbf";
private String aiUserSn = "SYSUSER|2665bcca63a2b5c724095fa01dce0470"; private String aiUserSn = "SYSUSER|2665bcca63a2b5c724095fa01dce0470";
@ -237,7 +237,6 @@ public class AiServiceImpl implements IAiService {
for (BusStoreInfo busStoreInfo : storeInfoList) { for (BusStoreInfo busStoreInfo : storeInfoList) {
try { try {
if ("2".equals(busStoreInfo.getReturnVisitStatus())) { if ("2".equals(busStoreInfo.getReturnVisitStatus())) {
log.error("未开启营销的跳出");
continue;// 未开启营销的跳出 continue;// 未开启营销的跳出
} }
// 配置规则 // 配置规则
@ -247,10 +246,8 @@ public class AiServiceImpl implements IAiService {
List<BusOrderInfo> list = new ArrayList<>(); List<BusOrderInfo> list = new ArrayList<>();
if ("1".equals(busStoreInfo.getSelfDeliveryStatus())) { if ("1".equals(busStoreInfo.getSelfDeliveryStatus())) {
log.error("自动营销");
list = orderInfoService.selectBusOrderInfoListToAi(busStoreInfo.getStoreCode(), t1, t2); list = orderInfoService.selectBusOrderInfoListToAi(busStoreInfo.getStoreCode(), t1, t2);
} else if ("2".equals(busStoreInfo.getSelfDeliveryStatus())) { } else if ("2".equals(busStoreInfo.getSelfDeliveryStatus())) {
log.error("自配送营销");
LocalDateTime t180 = now.minusMinutes(180); LocalDateTime t180 = now.minusMinutes(180);
String t18 = t180.format(formatter); String t18 = t180.format(formatter);
LocalDateTime tN = now.minusMinutes(busStoreConfigInfo.getSelfDeliveryDuration()); LocalDateTime tN = now.minusMinutes(busStoreConfigInfo.getSelfDeliveryDuration());
@ -284,6 +281,7 @@ public class AiServiceImpl implements IAiService {
aiProducer.sendInfo(mqDataInfo); aiProducer.sendInfo(mqDataInfo);
} }
}catch (Exception e){ }catch (Exception e){
log.error("***************************"+e.getMessage());
e.printStackTrace(); e.printStackTrace();
continue; continue;
} }
@ -307,7 +305,6 @@ public class AiServiceImpl implements IAiService {
@Override @Override
public void sendSmsTask(String content, BusOrderInfo busOrderInfo) { public void sendSmsTask(String content, BusOrderInfo busOrderInfo) {
lock.lock(); lock.lock();
try { try {
BusSmsInfo busSmsInfo = new BusSmsInfo(); BusSmsInfo busSmsInfo = new BusSmsInfo();
@ -322,6 +319,8 @@ public class AiServiceImpl implements IAiService {
log.error("短信余额为空，请充值"); log.error("短信余额为空，请充值");
return; return;
} }
redisTemplate.opsForValue().set("limitNum",busSmsInfo1.getLimitNum()+"");
redisTemplate.opsForValue().set("totalNum",busSmsInfo1.getTotalNum()+"");
}else{ }else{
redisTemplate.opsForValue().set("limitNum",busSmsInfo1.getLimitNum()+""); redisTemplate.opsForValue().set("limitNum",busSmsInfo1.getLimitNum()+"");
redisTemplate.opsForValue().set("totalNum",busSmsInfo1.getTotalNum()+""); redisTemplate.opsForValue().set("totalNum",busSmsInfo1.getTotalNum()+"");