From 7dafce3977afbd03c0336468f8ef085d7614dd1c Mon Sep 17 00:00:00 2001
From: yangwei <867012372@qq.com>
Date: Mon, 28 Apr 2025 15:05:20 +0800
Subject: [PATCH] =?UTF-8?q?[feat]=201=E3=80=81=E4=BF=AE=E6=94=B9=E9=A3=9E?=
 =?UTF-8?q?=E8=A1=8C=E6=AC=A1=E6=95=B0=E6=97=B6=E9=95=BF=E6=8E=A5=E5=8F=97?=
 =?UTF-8?q?=E5=8F=82=E6=95=B0=E5=92=8C=E5=BC=82=E6=AD=A5=E8=B0=83=E7=94=A8?=
 =?UTF-8?q?=E2=91=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/IDeviceFlightRecordsService.java  |  2 +-
 .../impl/DeviceFlightRecordsServiceImpl.java  | 24 +++++++++----------
 2 files changed, 13 insertions(+), 13 deletions(-)

diff --git a/dk-modules/sample/src/main/java/org/dromara/sample/manage/service/IDeviceFlightRecordsService.java b/dk-modules/sample/src/main/java/org/dromara/sample/manage/service/IDeviceFlightRecordsService.java
index 71012f0..b451499 100644
--- a/dk-modules/sample/src/main/java/org/dromara/sample/manage/service/IDeviceFlightRecordsService.java
+++ b/dk-modules/sample/src/main/java/org/dromara/sample/manage/service/IDeviceFlightRecordsService.java
@@ -8,7 +8,7 @@ import java.util.Map;
 public interface IDeviceFlightRecordsService {
 
 
-    void saveDeviceFlight(List<DeviceFlightRecordsEntity> deviceFlightRecords);
+    void saveDeviceFlight(DeviceFlightRecordsEntity deviceFlightRecords);
 
     Map<String,Integer> getDeviceFlightCount();
 
diff --git a/dk-modules/sample/src/main/java/org/dromara/sample/manage/service/impl/DeviceFlightRecordsServiceImpl.java b/dk-modules/sample/src/main/java/org/dromara/sample/manage/service/impl/DeviceFlightRecordsServiceImpl.java
index 9f08d95..7176e15 100644
--- a/dk-modules/sample/src/main/java/org/dromara/sample/manage/service/impl/DeviceFlightRecordsServiceImpl.java
+++ b/dk-modules/sample/src/main/java/org/dromara/sample/manage/service/impl/DeviceFlightRecordsServiceImpl.java
@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.dromara.sample.manage.mapper.DeviceFlightRecordsMapper;
 import org.dromara.sample.manage.model.entity.DeviceFlightRecordsEntity;
 import org.dromara.sample.manage.service.IDeviceFlightRecordsService;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
 import java.util.HashMap;
@@ -18,21 +19,20 @@ public class DeviceFlightRecordsServiceImpl extends ServiceImpl<DeviceFlightReco
 
 
     @Override
-    public void saveDeviceFlight(List<DeviceFlightRecordsEntity> deviceFlightRecords) {
+    @Async
+    public void saveDeviceFlight(DeviceFlightRecordsEntity deviceFlightRecords) {
 
-        deviceFlightRecords.forEach(deviceFlightRecord -> {
-            //查询之前的数据
-            DeviceFlightRecordsEntity deviceFlightRecordsEntities = this.baseMapper.selectOne(new LambdaQueryWrapper<DeviceFlightRecordsEntity>().eq(DeviceFlightRecordsEntity::getDeviceSn,deviceFlightRecord.getDeviceSn()));
+        //查询之前的数据
+        DeviceFlightRecordsEntity deviceFlightRecordsEntities = this.baseMapper.selectOne(new LambdaQueryWrapper<DeviceFlightRecordsEntity>().eq(DeviceFlightRecordsEntity::getDeviceSn,deviceFlightRecords.getDeviceSn()));
 
-            if (ObjectUtil.isNotEmpty(deviceFlightRecordsEntities)) {
-                deviceFlightRecordsEntities.setFlyCount(deviceFlightRecordsEntities.getFlyCount() + deviceFlightRecord.getFlyCount());
-                deviceFlightRecordsEntities.setFlyAccTime(deviceFlightRecordsEntities.getFlyAccTime() + deviceFlightRecord.getFlyAccTime());
+        if (ObjectUtil.isNotEmpty(deviceFlightRecordsEntities)) {
+            deviceFlightRecordsEntities.setFlyCount(deviceFlightRecordsEntities.getFlyCount() + deviceFlightRecords.getFlyCount());
+            deviceFlightRecordsEntities.setFlyAccTime(deviceFlightRecordsEntities.getFlyAccTime() + deviceFlightRecords.getFlyAccTime());
 
-                this.updateById(deviceFlightRecordsEntities);
-            }else {
-                this.save(deviceFlightRecord);
-            }
-        });
+            this.updateById(deviceFlightRecordsEntities);
+        }else {
+            this.save(deviceFlightRecords);
+        }
     }
 
     @Override