Sync-kibővítése
This commit is contained in:
@@ -1,18 +1,12 @@
|
||||
using AutoMapper;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using Microsoft.Extensions.Configuration;
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Net.Http;
|
||||
using System.Net.Http.Json;
|
||||
using System.Security.Cryptography.X509Certificates;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
using WorkFlowCheck.Common.DTO;
|
||||
using WorkFlowCheck.MAUI.DataLayer;
|
||||
using WorkFlowCheck.MAUI.DataLayer.Entities;
|
||||
using WorkFlowCheck.MAUI.Services.Interfaces;
|
||||
using Location = WorkFlowCheck.MAUI.DataLayer.Entities.Location;
|
||||
|
||||
namespace WorkFlowCheck.MAUI.Services
|
||||
{
|
||||
@@ -25,6 +19,8 @@ namespace WorkFlowCheck.MAUI.Services
|
||||
public async Task SyncDatas()
|
||||
{
|
||||
await SyncCheckPoints();
|
||||
await SyncLocations();
|
||||
await SyncEquipments();
|
||||
await SyncCheckListTemplates();
|
||||
}
|
||||
public async Task SyncCheckPoints()
|
||||
@@ -35,17 +31,17 @@ namespace WorkFlowCheck.MAUI.Services
|
||||
string endpoint = $"{_httpClient.BaseAddress}api/Sync/GetAllCheckPoints";
|
||||
|
||||
// HTTP GET kérés küldése
|
||||
var response = await _httpClient.GetFromJsonAsync<ApiResponseDTO<CheckPointListDTO>>(endpoint);
|
||||
var response = await _httpClient.GetFromJsonAsync<ApiResponseDTO<List<CheckPointDTO>>>(endpoint);
|
||||
if (response != null)
|
||||
{
|
||||
if (response.IsSuccess)
|
||||
{
|
||||
var checkPointList = await _dbContext.CheckPoints.ToListAsync();
|
||||
var missingItems = response.Data.CheckPointList.Where(f => !checkPointList.Any(s => s.Id == f.Id)).ToList();
|
||||
var entityList = await _dbContext.CheckPoints.ToListAsync();
|
||||
var missingItems = response.Data.Where(f => !entityList.Any(s => s.Id == f.Id)).ToList();
|
||||
|
||||
var missingCheckPoint = _mapper.Map<List<CheckPoint>>(missingItems);
|
||||
var mappedMissingItems = _mapper.Map<List<CheckPoint>>(missingItems);
|
||||
|
||||
_dbContext.CheckPoints.AddRange(missingCheckPoint);
|
||||
_dbContext.CheckPoints.AddRange(mappedMissingItems);
|
||||
await _dbContext.SaveChangesAsync();
|
||||
}
|
||||
}
|
||||
@@ -56,13 +52,72 @@ namespace WorkFlowCheck.MAUI.Services
|
||||
|
||||
}
|
||||
}
|
||||
public async Task SyncLocations()
|
||||
{
|
||||
try
|
||||
{
|
||||
// Az API végpont meghatározása
|
||||
string endpoint = $"{_httpClient.BaseAddress}api/Sync/GetAllLocations";
|
||||
|
||||
// HTTP GET kérés küldése
|
||||
var response = await _httpClient.GetFromJsonAsync<ApiResponseDTO<List<LocationDTO>>>(endpoint);
|
||||
if (response != null)
|
||||
{
|
||||
if (response.IsSuccess)
|
||||
{
|
||||
var entityList = await _dbContext.Locations.ToListAsync();
|
||||
var missingItems = response.Data.Where(f => !entityList.Any(s => s.Id == f.Id)).ToList();
|
||||
|
||||
var mappedMissingItems = _mapper.Map<List<Location>>(missingItems);
|
||||
|
||||
_dbContext.Locations.AddRange(mappedMissingItems);
|
||||
await _dbContext.SaveChangesAsync();
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
// Hiba visszaadása
|
||||
|
||||
}
|
||||
}
|
||||
public async Task SyncEquipments()
|
||||
{
|
||||
try
|
||||
{
|
||||
// Az API végpont meghatározása
|
||||
string endpoint = $"{_httpClient.BaseAddress}api/Sync/GetAllEquipments";
|
||||
|
||||
// HTTP GET kérés küldése
|
||||
var response = await _httpClient.GetFromJsonAsync<ApiResponseDTO<List<EquipmentDTO>>>(endpoint);
|
||||
if (response != null)
|
||||
{
|
||||
if (response.IsSuccess)
|
||||
{
|
||||
var entityList = await _dbContext.Locations.ToListAsync();
|
||||
var missingItems = response.Data.Where(f => !entityList.Any(s => s.Id == f.Id)).ToList();
|
||||
|
||||
var mappedMissingItems = _mapper.Map<List<Equipment>>(missingItems);
|
||||
|
||||
_dbContext.Equipments.AddRange(mappedMissingItems);
|
||||
await _dbContext.SaveChangesAsync();
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
// Hiba visszaadása
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public async Task SyncCheckListTemplates()
|
||||
{
|
||||
try
|
||||
{
|
||||
// Az API végpont meghatározása
|
||||
string endpoint = $"{_httpClient.BaseAddress}api/Sync/GetAllCheckListHeader";
|
||||
string endpoint = $"{_httpClient.BaseAddress}api/Sync/GetAllCheckListTemplateHeader";
|
||||
|
||||
// HTTP GET kérés küldése
|
||||
var response = await _httpClient.GetFromJsonAsync<ApiResponseDTO<List<CheckListTemplateHeaderDTO>>>(endpoint);
|
||||
@@ -70,12 +125,12 @@ namespace WorkFlowCheck.MAUI.Services
|
||||
{
|
||||
if (response.IsSuccess)
|
||||
{
|
||||
var checkPointList = await _dbContext.CheckListTemplateHeaders.ToListAsync();
|
||||
var missingItems = response.Data.Where(f => !checkPointList.Any(s => s.Id == f.Id)).ToList();
|
||||
var checkListTemplateHeaderList = await _dbContext.CheckListTemplateHeaders.ToListAsync();
|
||||
var missingItems = response.Data.Where(f => !checkListTemplateHeaderList.Any(s => s.Id == f.Id)).ToList();
|
||||
|
||||
var missingCheckListHeaders = _mapper.Map<List<CheckListTemplateHeader>>(missingItems);
|
||||
var missingCheckListTemplateHeaders = _mapper.Map<List<CheckListTemplateHeader>>(missingItems);
|
||||
|
||||
_dbContext.CheckListTemplateHeaders.AddRange(missingCheckListHeaders);
|
||||
_dbContext.CheckListTemplateHeaders.AddRange(missingCheckListTemplateHeaders);
|
||||
await _dbContext.SaveChangesAsync();
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user