yanghongwei
/
ly
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

细节调整

This commit is contained in:
yanghongwei 2025-04-05 17:50:08 +08:00
parent c25f5463c1
commit 7bf4c684b2
1 changed files with 10 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
Service/AlarmService.cs
View File

@ -39,23 +39,20 @@ namespace LY.App.Service
public async Task<ApiResult> AddAlarm(RevData input) public async Task<ApiResult> AddAlarm(RevData input)
{ {
await SetDeviceStataus(input); await SetDeviceStataus(input);
if (input.data.Any()) var key = RedisKeyList.DeviceInfo(input.product_ad_id);
var deviceinfo = await _redisService.GetAsync<DeviceEntity>(key);
if (deviceinfo == null)
{ {
var key = RedisKeyList.DeviceInfo(input.product_ad_id); deviceinfo = await _db.CopyNew().Queryable<DeviceEntity>().Where(s => s.DeviceSN == input.product_ad_id).FirstAsync();
var deviceinfo = await _redisService.GetAsync<DeviceEntity>(key);
if (deviceinfo == null) if (deviceinfo == null)
{ {
deviceinfo = await _db.CopyNew().Queryable<DeviceEntity>().Where(s => s.DeviceSN == input.product_ad_id).FirstAsync(); return new ApiResult() { code = 1, msg = "设备不存在" };
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();
} }
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<List<Alarm>>(); var entity = input.data.Adapt<List<Alarm>>();
foreach (var item in entity) foreach (var item in entity)
{ {