using AutoMapper; using Ropin.Core.Common; using Ropin.Inspection.Common.Accessor.Interface; using Ropin.Inspection.Model.Entities; using Ropin.Inspection.Model.SearchModel.VMC; using Ropin.Inspection.Model.ViewModel.VMC; using Ropin.Inspection.Repository.VMC.Interface; using Ropin.Inspection.Service.VMC.Interface; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace Ropin.Inspection.Service.VMC { public class VmcCameraService: IVmcCameraService { private readonly IVmcCameraRepository _repository; private readonly IVmcCameraMigrateRepository _vmcCameraMigrateRepository; private readonly IVMCDevCameraRepository _vmcDevCameraRepository; private readonly IMapper _mapper; private readonly IClaimsAccessor _claims; private readonly InspectionDbContext _sqlDBContext; public VmcCameraService(IClaimsAccessor claims, InspectionDbContext sqlDBContext, IVmcCameraRepository repository, IMapper mapper, IVmcCameraMigrateRepository vmcCameraMigrateRepository, IVMCDevCameraRepository vmcDevCameraRepository) { _repository = repository; _vmcCameraMigrateRepository = vmcCameraMigrateRepository; _mapper = mapper; _claims = claims; _sqlDBContext = sqlDBContext; _vmcDevCameraRepository = vmcDevCameraRepository; } public async Task> GetConditionAsync(VmcCameraSearch searchModel) { var list = await _repository.GetConditionAsync(searchModel); return list; } public async Task> GetCameraMigrateConditionAsync(VmcCameraMigrateSearch searchModel) { var list = await _vmcCameraMigrateRepository.GetConditionAsync(searchModel); return list; } public async Task> GetDevCameraConditionAsync(VmcDevSearch searchModel) { var list = await _vmcDevCameraRepository.GetConditionAsync(searchModel); return list; } public async Task CreateCameraMigrate(TVMC_CameraMigrate content) { var models = await _repository.GetByIdAsync(content.C_CameraCode); if (models == null) { throw new Exception("没有找到该摄像头数据"); } content.C_ID = Guid.NewGuid().ToString(); content.C_CreateBy = _claims.ApiUserId.ToString(); content.D_CreateOn = DateTime.Now; _vmcCameraMigrateRepository.Create(content); var result = await _vmcCameraMigrateRepository.SaveAsync(); if (result) { models.C_StoreCode = content.C_CurrentStoreCode; models.C_LastUpdatedBy = _claims.Linsence == null ? _claims.ApiUserId.ToString() : "6e864cbc-5252-11ec-8681-fa163e02b3e4"; models.D_LastUpdatedOn = DateTime.Now; _repository.Update(models); var result1 = await _repository.SaveAsync(); if (!result1) { throw new Exception("数据迁移失败"); } } if (!result) { throw new Exception("创建失败"); } } public async Task CreateDevCamera(TVMC_DevCamera content) { content.C_ID = Guid.NewGuid().ToString(); content.C_CreateBy = _claims.ApiUserId.ToString(); content.D_CreateOn = DateTime.Now; content.C_Creator=_claims.ApiUserName.ToString(); _vmcDevCameraRepository.Create(content); var result = await _vmcDevCameraRepository.SaveAsync(); if (!result) { throw new Exception("创建失败"); } } public async Task CreateDevCameraList(VmcDevCamera model) { List list=new List(); bool bol=await _vmcDevCameraRepository.DeleteBYDevStoreCode(model.C_DevStoreCode); if (bol) { foreach (var item in model.CameraList) { TVMC_DevCamera content = new TVMC_DevCamera(); content.C_DevStoreCode = model.C_DevStoreCode; content.C_CameraCode = item.C_CameraId; content.F_ShootingTime = item.F_ShootingTime; content.C_Status = (string.IsNullOrEmpty(item.C_Status)?"1":item.C_Status); content.C_ID = Guid.NewGuid().ToString(); content.C_CreateBy = _claims.ApiUserId.ToString(); content.D_CreateOn = DateTime.Now; content.C_Creator = _claims.ApiUserName.ToString(); list.Add(content); } var result = await _vmcDevCameraRepository.CreateRangeAsync(list) > 0; if (!result) { throw new Exception("创建失败"); } } else { throw new Exception("关联失败"); } } public async Task CreateOneAsync(VmcCameraViewModel viewModel) { var content = _mapper.Map(viewModel); content.C_ID = Guid.NewGuid().ToString(); var path = QRCoderHelper.RenderQrCode(content.C_ID, "M", _claims.Linsence); content.C_QRCode = path; content.C_CreateBy = _claims.ApiUserId.ToString(); content.D_CreateOn = DateTime.Now; content.C_RunStatus = string.IsNullOrEmpty(content.C_RunStatus) ? "2" : content.C_RunStatus; content.C_Status =string.IsNullOrEmpty(content.C_Status)? "1": content.C_Status; _repository.Create(content); var result = await _repository.SaveAsync(); if (!result) { throw new Exception("创建失败"); } } public async Task DeleteAsync(string id) { var content = await _repository.GetByIdAsync(id); if (content == null) { throw new Exception("数据库中没有此数据"); } _repository.Delete(content); var result = await _repository.SaveAsync(); if (!result) { throw new Exception("删除失败"); } } public async Task DeleteDevCameraAsync(string id) { var content = await _vmcDevCameraRepository.GetByIdAsync(id); if (content == null) { throw new Exception("数据库中没有此数据"); } _vmcDevCameraRepository.Delete(content); var result = await _vmcDevCameraRepository.SaveAsync(); if (!result) { throw new Exception("删除失败"); } } public async Task ForbiddenAsync(string id) { var content = await _repository.GetByIdAsync(id); if (content == null) { throw new Exception("数据库中没有此数据"); } content.C_LastUpdatedBy = _claims.ApiUserId.ToString(); content.D_LastUpdatedOn = DateTime.Now; content.C_Status = "0"; _repository.Update(content); var result = await _repository.SaveAsync(); if (!result) { throw new Exception("禁用失败"); } } public async Task GetByIdAsync(string id) { VmcCameraSearch searchModel = new VmcCameraSearch(); searchModel.IsPagination = false; searchModel.C_ID = id; var list = await _repository.GetConditionAsync(searchModel); return list?.FirstOrDefault(); } public async Task UpdateAsync(VmcCameraViewModel viewModel, string Id) { var content = await _repository.GetByIdAsync(Id); if (content == null) { throw new Exception("没有此数据"); } _mapper.Map(viewModel, content, typeof(VmcCameraViewModel), typeof(TVMC_Camera)); content.C_LastUpdatedBy = _claims.Linsence == null ? _claims.ApiUserId.ToString() : "6e864cbc-5252-11ec-8681-fa163e02b3e4"; content.D_LastUpdatedOn = DateTime.Now; _repository.Update(content); var result = await _repository.SaveAsync(); if (!result) { throw new Exception("更新失败"); } } public Task IsExistAsync(string id) { throw new NotImplementedException(); } public Task UpdateOneAsync(VmcCameraViewModel viewModel, params string[] fields) { throw new NotImplementedException(); } } }