feature: 门锁对接

1.门锁电量同步定时任务

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/controller/lock/LockController.java

@@ -34,7 +34,7 @@ public class LockController {
      * @param lockId 门锁Id
      * @return 状态
      */
-    @GetMapping(value = "/device/battery", produces = "application/json; charset=utf-8")
+    @GetMapping(value = "/device/battery")
     ReturnResult queryDeviceBattery(@RequestParam("lockId") String lockId) {
         Boolean result = lockBusiness.syncLockPower(115L);
         if(result) {

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/task/AsyncTaskService.java

@@ -3,10 +3,13 @@ package org.dromara.backstage.task;
 import cn.hutool.http.HttpRequest;
 import cn.hutool.http.HttpUtil;
 import cn.hutool.json.JSONUtil;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.dromara.backstage.business.lock.LockBusiness;
 import org.dromara.common.core.api.ReturnResult;
 import org.dromara.common.redis.utils.RedisUtils;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 
 import java.util.HashMap;
@@ -22,10 +25,12 @@ import java.util.Map;
  */
 @Slf4j
 @Service
+@RequiredArgsConstructor
 public class AsyncTaskService {
     @Value("${third-api.sms-api}")
     String smsApi;
 
+
     public void asyncSendSms(String mobile, String message) {
         String keyToken = "yktSmsToken";
         String sendUrl = smsApi + "sms/api/v1/send";
@@ -46,4 +51,5 @@ public class AsyncTaskService {
             log.info("[短信发送]-{\"内容\":\"{}\",\"发送异常\":\"{}\"", message, ex.getMessage());
         }
     }
+
 }

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/task/ScheduledTasks.java

@@ -0,0 +1,29 @@
+package org.dromara.backstage.task;
+
+import lombok.RequiredArgsConstructor;
+import org.dromara.backstage.business.lock.LockBusiness;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * name: ScheduledTasks
+ * package: org.dromara.backstage.task
+ * description: 定时任务
+ * date: 2024-12-11 13:32:36 13:32
+ *
+ * @author luoyibo
+ * @version 0.1
+ * @since JDK 1.8
+ */
+@Component
+@RequiredArgsConstructor
+public class ScheduledTasks {
+    private final LockBusiness lockBusiness;
+    /**
+     * 定时同步门锁电量
+     */
+    @Scheduled(fixedDelay = 10 * 60 * 1000)
+    public void syncLockBattery(){
+        lockBusiness.syncLockPower();
+    }
+}

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/task/SubsidyScheduled.java

@@ -3,7 +3,10 @@ package org.dromara.backstage.task;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.dromara.backstage.business.payments.PayOrderBusiness;
+import org.dromara.common.core.domain.R;
 import org.springframework.boot.CommandLineRunner;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
 
 /**
  * name: SubsidyScheduled
@@ -16,16 +19,16 @@ import org.springframework.boot.CommandLineRunner;
  * @since JDK 1.8
  */
 @Slf4j
-// @Component
+@Component
 @RequiredArgsConstructor
 public class SubsidyScheduled implements CommandLineRunner {
     private final PayOrderBusiness subsidyOrderBusiness;
 
-    // @Scheduled(fixedDelay = 10 * 60 * 1000)
-    // public void rechargeSubsidy(){
-    //     R<Object> result = subsidyOrderBusiness.createSubsidyOrder();
-    //     log.info(result.getMsg());
-    // }
+    @Scheduled(fixedDelay = 10 * 60 * 1000)
+    public void rechargeSubsidy() {
+        R<Object> result = subsidyOrderBusiness.createSubsidyOrder();
+        log.info(result.getMsg());
+    }
 
     @Override
     public void run(String... args) throws Exception {

ruoyi-server/ruoyi-server-mqdata/src/main/java/org/dromara/server/mq/consumer/KafkaConsumer.java

@@ -31,7 +31,6 @@ import static org.dromara.common.message.kafka.constant.KafkaTopicConstants.SYNC
 @Slf4j
 @Component
 public class KafkaConsumer {
-
     private final EventStrategyContext eventStrategyContext;
 
     @KafkaListener(topics = "eventBus", groupId = "test-group-id")