MoniteringPointLocationService.cs 2.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879
  1. using System;
  2. using System.Collections.Generic;
  3. using Microsoft.Extensions.Logging;
  4. using FMSAdmin.Data;
  5. using System.Linq;
  6. using FMSAdmin.Helpers;
  7. using FMSAdmin.Entities;
  8. using FMSAdmin.Models;
  9. using Microsoft.EntityFrameworkCore;
  10. namespace FMSAdmin.Services {
  11. public class MonitoringPointLocationService {
  12. private readonly ILogger<MonitoringPointLocationService> _logger;
  13. private readonly FMSContext _context;
  14. private readonly StorageHelper _storage;
  15. public MonitoringPointLocationService(
  16. ILogger<MonitoringPointLocationService> logger,
  17. FMSContext context,
  18. StorageHelper storage
  19. ) {
  20. _logger = logger;
  21. _context = context;
  22. _storage = storage;
  23. }
  24. public IQueryable<BemsMonitoringPoint> GetAll() {
  25. var query = _context.BemsMonitoringPoint;//.AsNoTracking();
  26. return query;
  27. }
  28. public IQueryable<BemsMonitoringPoint> Get(int siteId, int facilityCode, int propertyId) {
  29. var data = _context.BemsMonitoringPoint.Where(x => x.SiteId == siteId && x.FacilityCode == facilityCode && x.PropertyId == propertyId);
  30. return data;
  31. }
  32. public void Edit(int siteId, ICollection<PointToLocation> data) {
  33. using (var transaction = _context.Database.BeginTransaction()) {
  34. foreach (var location in data) {
  35. var foundQuery = _context.BemsMonitoringPoint.Where(x => x.SiteId == location.SiteId && x.FacilityCode == location.FacilityCode && x.PropertyId == location.PropertyId);
  36. if (foundQuery.Any() == false) continue;
  37. var found = foundQuery.First();
  38. found.BuildingId = location.BuildingId;
  39. if (location.FloorId != 0) {
  40. found.FloorId = location.FloorId;
  41. }
  42. if (location.ZoneId != 0) {
  43. found.ZoneId = location.ZoneId;
  44. }
  45. _context.BemsMonitoringPoint.Update(found);
  46. }
  47. _context.SaveChanges();
  48. transaction.Commit();
  49. }
  50. }
  51. public void Delete(List<BemsMonitoringPoint> data) {
  52. using (var transaction = _context.Database.BeginTransaction()) {
  53. foreach (var point in data) {
  54. var persist = _context.BemsMonitoringPoint.First(x => x.SiteId == point.SiteId && x.FacilityCode == point.FacilityCode && x.PropertyId == point.PropertyId);
  55. persist.BuildingId = null;
  56. persist.FloorId = null;
  57. persist.ZoneId = null;
  58. _context.BemsMonitoringPoint.Update(persist);
  59. }
  60. _context.SaveChanges();
  61. transaction.Commit();
  62. }
  63. }
  64. }
  65. }