S8SceneConfigService.cs 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. using Admin.NET.Plugin.AiDOP.Entity.S8;
  2. namespace Admin.NET.Plugin.AiDOP.Service.S8;
  3. public class S8SceneConfigService : ITransient
  4. {
  5. private readonly SqlSugarRepository<AdoS8SceneConfig> _rep;
  6. public S8SceneConfigService(SqlSugarRepository<AdoS8SceneConfig> rep) => _rep = rep;
  7. public async Task<List<AdoS8SceneConfig>> ListAsync(long tenantId, long factoryId) =>
  8. await _rep.AsQueryable()
  9. .Where(x => x.TenantId == tenantId && x.FactoryId == factoryId)
  10. .OrderBy(x => x.SortNo)
  11. .ToListAsync();
  12. public async Task<AdoS8SceneConfig> CreateAsync(AdoS8SceneConfig body)
  13. {
  14. if (string.IsNullOrWhiteSpace(body.SceneCode) || string.IsNullOrWhiteSpace(body.SceneName))
  15. throw new S8BizException("场景编码和名称必填");
  16. var exists = await _rep.AsQueryable()
  17. .AnyAsync(x => x.TenantId == body.TenantId && x.FactoryId == body.FactoryId && x.SceneCode == body.SceneCode);
  18. if (exists) throw new S8BizException("场景编码已存在");
  19. body.Id = 0;
  20. body.CreatedAt = DateTime.Now;
  21. await _rep.InsertAsync(body);
  22. return body;
  23. }
  24. public async Task<AdoS8SceneConfig> UpdateAsync(long id, AdoS8SceneConfig body)
  25. {
  26. var e = await _rep.GetByIdAsync(id) ?? throw new S8BizException("记录不存在");
  27. if (string.IsNullOrWhiteSpace(body.SceneCode) || string.IsNullOrWhiteSpace(body.SceneName))
  28. throw new S8BizException("场景编码和名称必填");
  29. var exists = await _rep.AsQueryable()
  30. .AnyAsync(x => x.Id != id && x.TenantId == body.TenantId && x.FactoryId == body.FactoryId && x.SceneCode == body.SceneCode);
  31. if (exists) throw new S8BizException("场景编码已存在");
  32. body.Id = id;
  33. body.CreatedAt = e.CreatedAt;
  34. body.UpdatedAt = DateTime.Now;
  35. await _rep.UpdateAsync(body);
  36. return body;
  37. }
  38. public async Task DeleteAsync(long id) => await _rep.DeleteByIdAsync(id);
  39. }