using AutoMapper; using LinqKit; 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 TpntStoreService : ITpntStoreService { private readonly ITpntStoreRepository _repository; private readonly ITpntStoreOrgRepository _storeOrgrepository; private readonly IUnitOfWork _unitOfWork; private readonly IMapper _mapper; private readonly IClaimsAccessor _claims; public TpntStoreService(IClaimsAccessor claims, ITpntStoreRepository repository, ITpntStoreOrgRepository storeOrgrepository, IUnitOfWork unitOfWork, IMapper mapper) { _repository = repository; _storeOrgrepository = storeOrgrepository; _unitOfWork = unitOfWork; _mapper = mapper; _claims = claims; } public async Task CreateOneAsync(TpntStoreViewModel viewModel) { var content = _mapper.Map(viewModel); content.C_ID = Guid.NewGuid(); content.C_Code = content.C_ID.ToString(); content.C_CreateBy = _claims.ApiUserId; content.D_CreateOn = DateTime.Now; content.C_Status = "1"; _repository.Create(content); var result = await _repository.SaveAsync(); if (!result) { throw new Exception("创建失败"); } } public async Task CreateStoreByOrgAsync(Guid orgCode, TpntStoreCreateModel viewModel) { var content = _mapper.Map(viewModel); content.C_ID = Guid.NewGuid(); content.C_Code = content.C_ID.ToString(); content.C_CreateBy = _claims.ApiUserId; content.D_CreateOn = DateTime.Now; content.C_Status = "1"; //_repository.Create(content); //var result = await _repository.SaveAsync(); //_storeOrgrepository.Create( // new TPNT_StoreOrg { C_StoreCode = content.C_Code, // C_OrgCode = orgCode,C_CreateBy = _claims.ApiUserId, // D_CreateOn = DateTime.Now }); //result = await _storeOrgrepository.SaveAsync(); //if (!result) //{ // throw new Exception("创建失败"); //} bool bResult = false; try { _unitOfWork.BeginTransaction(); bResult = await _unitOfWork.RegisterNew(content); var storeOrg = new TPNT_StoreOrg { C_StoreCode = content.C_Code, C_OrgCode = orgCode, C_Type = "1", C_CreateBy = _claims.ApiUserId, D_CreateOn = DateTime.Now }; bResult = await _unitOfWork.RegisterNew(storeOrg); } catch { _unitOfWork.Rollback(); throw ; } finally { if (bResult) await _unitOfWork.CommitAsync(); else _unitOfWork.Rollback(); } } public async Task AllotStoreByOrgAsync(Guid orgCode, Guid storeCode) { List StoreOrgList = _storeOrgrepository.GetAll().Where(t => t.C_OrgCode == orgCode && t.C_StoreCode == storeCode.ToString()).ToList(); if (StoreOrgList.Count > 0) { throw new Exception("该组织下已经分配了相同的业主!"); } bool bResult = false; try { _unitOfWork.BeginTransaction(); var storeOrg = new TPNT_StoreOrg { C_StoreCode = storeCode.ToString(), C_OrgCode = orgCode, C_Type = "2", C_CreateBy = _claims.ApiUserId, D_CreateOn = DateTime.Now }; bResult = await _unitOfWork.RegisterNew(storeOrg); } catch { _unitOfWork.Rollback(); throw; } finally { if (bResult) await _unitOfWork.CommitAsync(); else _unitOfWork.Rollback(); } } 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> 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(TpntStoreSearchModel searchModel) { var predicate = PredicateBuilder.New(true);//查询条件,推荐后台使用这种方式灵活筛选 #region 添加条件查询 predicate = predicate.And(i => i.C_Status.Equals("1")); if (!string.IsNullOrEmpty(searchModel.C_Name)) { predicate = predicate.And(i => i.C_Name.Contains(searchModel.C_Name)); } #endregion var list = await _repository.GetPageAsync(predicate, "C_Name,-D_CreateOn", searchModel.IsPagination, searchModel.PageIndex, searchModel.PageSize); 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(Guid id, TpntStoreUpdateModel updateModel) { var content = await _repository.GetByIdAsync(id); if (content == null) { throw new Exception("没有此数据"); } content.C_LastUpdatedBy = _claims.ApiUserId; content.D_LastUpdatedOn = DateTime.Now; _mapper.Map(updateModel, content, typeof(TpntStoreUpdateModel), typeof(TPNT_Store)); _repository.Update(content); var result = await _repository.SaveAsync(); if (!result) { throw new Exception("更新失败"); } } public Task> GetAllPntType() { var v = _repository.GetAllPntType(); var list = _mapper.Map>(v); return Task.FromResult(list); } public Task GetStoreByCodeAsync(string code) { return _repository.GetStoreByCodeAsync(code); } public Task UpdateOneAsync(TpntStoreViewModel viewModel, params string[] fields) { throw new NotImplementedException(); } public Task IsExistAsync(Guid id) { throw new NotImplementedException(); } public Task> GetByConditionAsync(Expression> expression) { throw new NotImplementedException(); } } }