From d6328902c9f01c17efdbdd92a7eba5dae4edcdfd Mon Sep 17 00:00:00 2001 From: gaowdong Date: Wed, 19 Mar 2025 11:15:03 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=8C=E5=B1=8F=E6=9C=BA-=E8=AE=BE=E5=A4=87?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3-=E8=AE=BE=E5=A4=87=E6=97=B6=E9=97=B4?= =?UTF-8?q?=E4=B8=8B=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../canteen/core/device/task/MqttTask.java | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) create mode 100644 bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/device/task/MqttTask.java diff --git a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/device/task/MqttTask.java b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/device/task/MqttTask.java new file mode 100644 index 00000000..7cbc5c01 --- /dev/null +++ b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/device/task/MqttTask.java @@ -0,0 +1,19 @@ +package com.bonus.canteen.core.device.task; + +import com.bonus.canteen.core.device.android.constant.DeviceMqMessage; +import com.xxl.job.core.handler.annotation.XxlJob; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Component; + +import java.time.Instant; + +@Component +public class MqttTask { + private static final Logger log = LoggerFactory.getLogger(MqttTask.class); + + @XxlJob("timeCalibrationV4") + public void timeCalibrationV4() { + DeviceMqMessage.timeCalibrationV4(Instant.now().toEpochMilli()); + } +}