yuangb/jinko.yikatong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix 数据绑定调整

Browse Source
This commit is contained in:
liguoyang
2025-03-05 12:31:52 +08:00
parent c300b5b457
commit 66df7b809b
3 changed files with 8 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
Src/Dlhis.Basic/Device/Services/Implements/DeviceConnectService.cs
View File

@@ -26,7 +26,9 @@ public class DeviceConnectService : IDeviceConnectService
public async Task<string> RegisterAsync(DeviceRegisterRequest request)
{
var businessPlace = await _dbContext.Queryable<BusinessPlaceEntity>().Where(x => x.CustomCode == request.BusinessCustomCode).SingleAsync();
var businessPlace = await _dbContext.Queryable<BusinessPlaceEntity>()
.Where(x => x.CustomCode == request.BusinessCustomCode)
.SingleAsync();
businessPlace.ThrowIfNull("营业点不存在");
var device = await GetEnableDeviceAsync(request.UniqueNo, false, request.DeployPlace, businessPlace.TenantId);
@@ -47,8 +49,7 @@ public class DeviceConnectService : IDeviceConnectService
DeviceUniqueNo = request.UniqueNo,
LastHeartbeatTime = DateTime.Now,
RegisterTime = DateTime.Now,
BusinessPlaceCode = businessPlace.Code,
TenantId = device.TenantId
BusinessPlaceCode = businessPlace.Code
};
await _dbContext.InsertAsync(registry);
@@ -163,7 +164,6 @@ public class DeviceConnectService : IDeviceConnectService
private async Task<DeviceEntity> GetEnableDeviceAsync(string uniqueNo, bool checkExists = true, string deployPlace = "", string tenantId = "")
{
var device = await _dbContext.Queryable<DeviceEntity>().Where(x => x.UniqueNo == uniqueNo).SingleAsync();
if (checkExists)
{
device.ThrowIfNull($"未知的设备唯一编码{uniqueNo}");
@@ -195,14 +195,6 @@ public class DeviceConnectService : IDeviceConnectService
await _dbContext.InsertAsync(device);
}
else
{
if (tenantId.IsPresent())
{
device.TenantId = tenantId;
await _dbContext.UpdateAsync(device);
}
}
}
return device;