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()); + } +}