From 90f19cfec1055182b6e2b77cac8f7cafe1664e46 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期一, 10 十一月 2025 14:24:10 +0800
Subject: [PATCH] 修改bug
---
UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java | 116 +++++++++++++++++++++++++++++++++++-----------------------
1 files changed, 70 insertions(+), 46 deletions(-)
diff --git a/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java b/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java
index c4d2dd9..b591005 100644
--- a/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java
+++ b/UserQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/TaskUtil.java
@@ -22,10 +22,15 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.web.context.WebServerInitializedEvent;
+import org.springframework.boot.web.server.WebServer;
+import org.springframework.context.ApplicationListener;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.math.BigDecimal;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
import java.util.*;
@@ -34,7 +39,7 @@
*/
@Slf4j
@Component
-public class TaskUtil {
+public class TaskUtil implements ApplicationListener<WebServerInitializedEvent> {
@Autowired
private IUserCouponRecordService userCouponRecordService;
@@ -72,6 +77,8 @@
private IDriverService driverService;
@Autowired
private ICompanyService companyService;
+
+ private String ip = null;
/**
@@ -79,62 +86,61 @@
*/
@Scheduled(fixedRate = 1000 * 60)
public void taskMinute() {
- try {
- //处理超时未支付的订单
- timoutNoPayment();
- //修改过期的优惠券
- userCouponRecordService.updateTimeOut();
- //修改过期的商家优惠券
- userMerchantCouponService.updateExpired();
- } catch (Exception e) {
- e.printStackTrace();
+ if(null != ip && "10.31.182.11".equals(ip)){
+ try {
+ //处理超时未支付的订单
+ timoutNoPayment();
+ //修改过期的优惠券
+ userCouponRecordService.updateTimeOut();
+ //修改过期的商家优惠券
+ userMerchantCouponService.updateExpired();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
}
+
}
-
- /**
- * 每天的凌晨执行的任务
- */
- @Scheduled(fixedRate = 1000 * 60)
- public void taskDay() {
- }
-
+
/**
* 每天中午12点发送提醒短信
*/
@Scheduled(cron = "0 0 12 * * ?")
public void taskMonth() {
- try {
- List<OrderPrivateCar> orderPrivateCars = orderPrivateCarService.selectList(new EntityWrapper<OrderPrivateCar>().eq("isDelete", 1)
- .eq("state", 7).eq("abnormal", 1)
- .last(" and now() > DATE_ADD(endServiceTime, INTERVAL 24 HOUR)"));
- for (OrderPrivateCar orderPrivateCar : orderPrivateCars) {
- UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
- SendSmsRequest request = new SendSmsRequest();
- request.setDestAddress(userInfo.getPhone());
- request.setTemplateId("TPL202507300002");
- Map<String, String> templateParams = new HashMap<>();
- request.setTemplateParams(templateParams);
- request.setSpId("Y86asr7J");
- SMSUtil.sendSms(request);
+ if(null != ip && "10.31.182.11".equals(ip)){
+ try {
+ List<OrderPrivateCar> orderPrivateCars = orderPrivateCarService.selectList(new EntityWrapper<OrderPrivateCar>().eq("isDelete", 1)
+ .eq("state", 7).eq("abnormal", 1)
+ .last(" and now() > DATE_ADD(endServiceTime, INTERVAL 24 HOUR)"));
+ for (OrderPrivateCar orderPrivateCar : orderPrivateCars) {
+ UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId());
+ SendSmsRequest request = new SendSmsRequest();
+ request.setDestAddress(userInfo.getPhone());
+ request.setTemplateId("TPL202507300002");
+ Map<String, String> templateParams = new HashMap<>();
+ request.setTemplateParams(templateParams);
+ request.setSpId("Y86asr7J");
+ SMSUtil.sendSms(request);
+ }
+ List<OrderTaxi> orderTaxis = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("isDelete", 1)
+ .eq("state", 7).eq("abnormal", 1)
+ .last(" and now() > DATE_ADD(endServiceTime, INTERVAL 24 HOUR)"));
+ for (OrderTaxi orderTaxi : orderTaxis) {
+ UserInfo userInfo = userInfoService.selectById(orderTaxi.getUserId());
+ SendSmsRequest request = new SendSmsRequest();
+ request.setDestAddress(userInfo.getPhone());
+ request.setTemplateId("TPL202507300002");
+ Map<String, String> templateParams = new HashMap<>();
+ request.setTemplateParams(templateParams);
+ request.setSpId("Y86asr7J");
+ SMSUtil.sendSms(request);
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
}
- List<OrderTaxi> orderTaxis = orderTaxiService.selectList(new EntityWrapper<OrderTaxi>().eq("isDelete", 1)
- .eq("state", 7).eq("abnormal", 1)
- .last(" and now() > DATE_ADD(endServiceTime, INTERVAL 24 HOUR)"));
- for (OrderTaxi orderTaxi : orderTaxis) {
- UserInfo userInfo = userInfoService.selectById(orderTaxi.getUserId());
- SendSmsRequest request = new SendSmsRequest();
- request.setDestAddress(userInfo.getPhone());
- request.setTemplateId("TPL202507300002");
- Map<String, String> templateParams = new HashMap<>();
- request.setTemplateParams(templateParams);
- request.setSpId("Y86asr7J");
- SMSUtil.sendSms(request);
- }
- } catch (Exception e) {
- e.printStackTrace();
}
+
}
@@ -297,4 +303,22 @@
}
}
}
+
+ @Override
+ public void onApplicationEvent(WebServerInitializedEvent event) {
+ // 获取环境对象
+ WebServer webServer = event.getWebServer();
+ // 获取端口号
+ int port = webServer.getPort();
+ // 打印端口号
+ System.out.println("Spring Boot应用已启动，访问端口：" + port);
+ InetAddress inetAddress = null;
+ try {
+ inetAddress = InetAddress.getLocalHost();
+ } catch (UnknownHostException e) {
+ throw new RuntimeException(e);
+ }
+ System.out.println("本机 IP 地址: " + inetAddress.getHostAddress());
+ this.ip = inetAddress.getHostAddress();
+ }
}
--
Gitblit v1.7.1