From 9d72eb559e67e3f0bb321198fc562f3cfd9a8625 Mon Sep 17 00:00:00 2001
From: zhanghua <314079846@qq.com>
Date: 星期日, 21 一月 2024 20:54:33 +0800
Subject: [PATCH] Merge branch 'master' of http://42.193.1.25:9521/r/sccg_server
---
ycl-platform/src/main/java/com/ycl/timer/SendMsg.java | 36 ++++++++++++++++++++++++++++++++++++
1 files changed, 36 insertions(+), 0 deletions(-)
diff --git a/ycl-platform/src/main/java/com/ycl/timer/SendMsg.java b/ycl-platform/src/main/java/com/ycl/timer/SendMsg.java
new file mode 100644
index 0000000..1abb3d7
--- /dev/null
+++ b/ycl-platform/src/main/java/com/ycl/timer/SendMsg.java
@@ -0,0 +1,36 @@
+package com.ycl.timer;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.ycl.service.message.IMessageService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import com.ycl.entity.message.Message;
+
+import java.util.List;
+
+@Slf4j
+@Component
+public class SendMsg {
+ @Value("${spring.profiles.active}")
+ private String env;
+
+ @Autowired
+ IMessageService messageService;
+
+ @Scheduled(cron = "0 0/2 * * * ?")
+ public void runAction() {
+ if ("online".equals(env)) {
+
+ List<Message> messages = messageService.list(new LambdaQueryWrapper<Message>()
+ .eq(Message::getStatus, 0));
+
+ for (Message msg : messages) {
+ messageService.sendSMS(msg);
+ }
+ }
+ }
+
+}
--
Gitblit v1.8.0