using AutoMapper; using LinqKit; using Ropin.Core.Common; using Ropin.Inspection.Common.Accessor.Interface; using Ropin.Inspection.Model; using Ropin.Inspection.Model.Entities; using Ropin.Inspection.Repository; using Ropin.Inspection.Repository.Interface; using System; using System.Collections.Generic; using System.Linq; using System.Linq.Expressions; using System.Text; using System.Threading.Tasks; namespace Ropin.Inspection.Service { public class TdevDeviceTemplateService : ITdevDeviceTemplateService { private readonly ITdevDeviceTemplateRepository _repository; private readonly IMapper _mapper; private readonly IClaimsAccessor _claims; public TdevDeviceTemplateService(IClaimsAccessor claims, ITdevDeviceTemplateRepository repository, IMapper mapper) { _repository = repository; _mapper = mapper; _claims = claims; } public async Task CreateOneAsync(TdevDeviceTemplateViewModel viewModel) { var id = Guid.NewGuid().ToString(); var path = QRCoderHelper.RenderQrCode(id, "M", _claims.Linsence); var content = _mapper.Map(viewModel); content.C_ID = id; content.C_CreateBy = _claims.ApiUserId; content.D_CreateOn = DateTime.Now; content.C_Status = "1"; if(string.IsNullOrWhiteSpace(content.C_QRCode)) content.C_QRCode = path; _repository.Create(content); var result = await _repository.SaveAsync(); if (!result) { throw new Exception("创建失败"); } } public async Task GetDevTemplateQRCodeAsync(string devId) { var path = QRCoderHelper.RenderQrCode(devId, "M", _claims.Linsence); var content = await _repository.GetByIdAsync(Guid.Parse(devId)); if (content == null) { throw new Exception("没有此数据"); } content.C_LastUpdatedBy = _claims.ApiUserId; content.D_LastUpdatedOn = DateTime.Now; content.C_QRCode = path; _repository.Update(content); var result = await _repository.SaveAsync(); if (!result) { throw new Exception("更新失败"); } return await Task.FromResult(path); } public async Task DeleteAsync(Guid id) { var content = await _repository.GetByIdAsync(id); if (content == null) { throw new Exception("数据库中没有此数据"); } //_repository.Delete(content); //var result = await _repository.SaveAsync(); content.C_LastUpdatedBy = _claims.ApiUserId; 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 DeleteAsync(string code) { var items = await _repository.GetByConditionAsync(C => C.C_ID == code); var content = items.FirstOrDefault(); if (content == null) { throw new Exception("没有此数据"); } content.C_LastUpdatedBy = _claims.ApiUserId; 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> GetAllAsync() { var pagedList = await _repository.GetAllAsync(); var contentDtoList = _mapper.Map>(pagedList.Where(i => i.C_Status == "1").ToList()); return contentDtoList.ToList(); } public async Task> GetConditionAsync(TdevDeviceTemplateSearchModel searchModel) { var predicate = PredicateBuilder.New(true);//查询条件,推荐后台使用这种方式灵活筛选 #region 添加条件查询 //predicate = predicate.And(i => i.C_Status.Equals("1")); if (!string.IsNullOrEmpty(searchModel.C_Status)) { predicate = predicate.And(i => i.C_Status.Equals(searchModel.C_Status)); } if (!string.IsNullOrEmpty(searchModel.C_Category)) { predicate = predicate.And(i => i.C_Category.Equals(searchModel.C_Category)); } if (!string.IsNullOrEmpty(searchModel.C_QRCode)) { predicate = predicate.And(i => i.C_QRCode.Equals(searchModel.C_QRCode)); } if (!string.IsNullOrEmpty(searchModel.C_MachineCode)) { predicate = predicate.And(i => i.C_MachineCode.Equals(searchModel.C_MachineCode)); } if (!string.IsNullOrEmpty(searchModel.C_ID)) { predicate = predicate.And(i => i.C_ID.Equals(searchModel.C_ID)); } if (!string.IsNullOrEmpty(searchModel.C_Name)) { predicate = predicate.And(i => i.C_Name.Contains(searchModel.C_Name)); } #endregion var list = await _repository.GetPageAsync(predicate, "-D_CreateOn", searchModel.IsPagination, searchModel.PageIndex, searchModel.PageSize);//C_Name,-D_CreateOn searchModel.TotalCount = list.Totals; var dtoList = _mapper.Map, List>(list.Rows); return dtoList; } public async Task GetByIdAsync(Guid id) { var content = await _repository.GetByIdAsync(id); var contentDto = _mapper.Map(content); return contentDto; } public async Task UpdateAsync(string code, TdevDeviceTemplateUpdateModel updateModel) { var items = await _repository.GetByConditionAsync(C => C.C_ID == code); var content = items.FirstOrDefault(); if (content == null) { throw new Exception("没有此数据"); } content.C_LastUpdatedBy = _claims.ApiUserId; content.D_LastUpdatedOn = DateTime.Now; _mapper.Map(updateModel, content, typeof(TdevDeviceTemplateUpdateModel), typeof(TDEV_DeviceTemplate)); _repository.Update(content); var result = await _repository.SaveAsync(); if (!result) { throw new Exception("更新失败"); } } public async Task> GetDeviceTemplateTreeAsync() { var tree = await _repository.GetDeviceTemplateTreeAsync(); return tree; } public Task UpdateOneAsync(TdevDeviceTemplateViewModel viewModel, params string[] fields) { throw new NotImplementedException(); } public Task IsExistAsync(Guid id) { throw new NotImplementedException(); } public Task> GetByConditionAsync(Expression> expression) { throw new NotImplementedException(); } public Task UpdateAsync(string code, TpntAreaUpdateModel updateModel) { throw new NotImplementedException(); } public Task> GetConditionAsync(TpntAreaSearchModel searchModel) { throw new NotImplementedException(); } } }