diff --git a/Service/AlarmService.cs b/Service/AlarmService.cs index 2439c1a..648bdd9 100644 --- a/Service/AlarmService.cs +++ b/Service/AlarmService.cs @@ -39,23 +39,20 @@ namespace LY.App.Service public async Task AddAlarm(RevData input) { await SetDeviceStataus(input); - if (input.data.Any()) + var key = RedisKeyList.DeviceInfo(input.product_ad_id); + var deviceinfo = await _redisService.GetAsync(key); + if (deviceinfo == null) { - var key = RedisKeyList.DeviceInfo(input.product_ad_id); - var deviceinfo = await _redisService.GetAsync(key); + deviceinfo = await _db.CopyNew().Queryable().Where(s => s.DeviceSN == input.product_ad_id).FirstAsync(); if (deviceinfo == null) { - deviceinfo = await _db.CopyNew().Queryable().Where(s => s.DeviceSN == input.product_ad_id).FirstAsync(); - if (deviceinfo == null) - { - return new ApiResult() { code = 1, msg = "设备不存在" }; - } - await _redisService.SetAsync(key, deviceinfo, TimeSpan.FromDays(1)); - deviceinfo.Lat = input.product_lat; - deviceinfo.Lon = input.product_lon; - //更新位置 - await _db.Updateable(deviceinfo).ExecuteCommandAsync(); + return new ApiResult() { code = 1, msg = "设备不存在" }; } + await _redisService.SetAsync(key, deviceinfo, TimeSpan.FromDays(1)); + deviceinfo.Lat = input.product_lat; + deviceinfo.Lon = input.product_lon; + //更新位置 + await _db.Updateable(deviceinfo).ExecuteCommandAsync(); var entity = input.data.Adapt>(); foreach (var item in entity) {