using AutoMapper; using LinqKit; using Newtonsoft.Json; 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.Security.Policy; using System.Text; using System.Threading.Tasks; using System.Xml.Linq; namespace Ropin.Inspection.Service { public class TmtnDevOpsRecordService : ITmtnDevOpsRecordService { private readonly ITmtnDevOpsRecordRepository _repository; private readonly ITmtnDevOpsRecordAppRepository _tmtnDevOpsRecordImageRepository; private readonly ITmtnDevOpsRepository _tmtnDevOpsRepository; private readonly IMapper _mapper; private readonly IClaimsAccessor _claims; public TmtnDevOpsRecordService(IClaimsAccessor claims, ITmtnDevOpsRepository tmtnDevOpsRepository, ITmtnDevOpsRecordRepository repository, ITmtnDevOpsRecordAppRepository tmtnDevOpsRecordImageRepository, IMapper mapper) { _repository = repository; _tmtnDevOpsRecordImageRepository = tmtnDevOpsRecordImageRepository; _tmtnDevOpsRepository = tmtnDevOpsRepository; _mapper = mapper; _claims = claims; } public async Task CreateOneAsync(TmtnDevOpsRecordViewModel viewModel) { var content = _mapper.Map(viewModel); content.C_ID = Guid.NewGuid().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 CreateDevOpsRecordListAsync(TmtnDevOpsRecordListCreateModel model) { string id = Guid.NewGuid().ToString(); await _tmtnDevOpsRepository.CreateOneAsync(new TMTN_DevOps { C_ID = id, C_SpotCode = model.C_SpotCode, C_Name = model.C_Name, C_Remark = model.C_Remark, C_CreateBy = _claims.ApiUserId, D_CreateOn = DateTime.Now, C_Status = "1" }); IList devOpsRecordList = new List(); foreach (var item in model.TmtnRecordItemList) { TMTN_DevOpsRecord record = new TMTN_DevOpsRecord(); record.C_SpotDevOpsContentCode = item.C_SpotDevOpsContentCode; record.C_DevOpsCode = id; record.C_Record = item.C_Record; record.C_Remark = item.C_Remark; record.C_ID = Guid.NewGuid().ToString(); record.C_CreateBy = _claims.ApiUserId; record.D_CreateOn = DateTime.Now; record.C_Status = "1"; devOpsRecordList.Add(record); if (null != item.FilePaths && item.FilePaths.Any()) { foreach (string imgPath in item.FilePaths) { await _tmtnDevOpsRecordImageRepository.CreateOneAsync(new TMTN_DevOpsRecordApp { C_ID = Guid.NewGuid().ToString(), C_DevOpsContentCode = record.C_ID, C_Name = "维保记录", C_Url = imgPath, C_Type = "1", C_Remark = "", C_CreateBy = _claims.ApiUserId, D_CreateOn = DateTime.Now, C_Status = "1" }); var resultItemImage = await _tmtnDevOpsRecordImageRepository.SaveAsync(); if (!resultItemImage) { throw new Exception("创建失败"); } } } } var result = await _repository.CreateRangeAsync(devOpsRecordList); if (result<=0) { throw new Exception("创建失败"); } } public async Task UpdataDevOpsRecordListAsync(TmtnDevOpsRecordListUpdataModel model) { var items = await _tmtnDevOpsRepository.GetByConditionAsync(C => C.C_ID == model.C_DevOpsCode); var content = items.FirstOrDefault(); if (content == null) { throw new Exception("没有此数据"); } //content.C_Name = model.C_Name; content.C_Status = model.C_Status; content.C_LastUpdatedBy = _claims.ApiUserId; content.D_LastUpdatedOn = DateTime.Now; _tmtnDevOpsRepository.Update(content); await _repository.SaveAsync(); //string id = Guid.NewGuid().ToString(); //await _tmtnDevOpsRepository.CreateOneAsync(new TMTN_DevOps //{ // C_ID = id, // C_SpotCode = model.C_SpotCode, // C_Name = model.C_Name, // C_Remark = model.C_Remark, // C_CreateBy = _claims.ApiUserId, // D_CreateOn = DateTime.Now, // C_Status = "4" //}); IList devOpsRecordList = new List(); foreach (var item in model.TmtnRecordItemList) { //if(string.IsNullOrWhiteSpace(item.C_Record)) { continue; } TMTN_DevOpsRecord record = new TMTN_DevOpsRecord(); record.C_SpotDevOpsContentCode = item.C_SpotDevOpsContentCode; record.C_DevOpsCode = model.C_DevOpsCode; record.C_Record = item.C_Record; if (item.DevOpsRecordSolidWaste != null) { record.C_SolidWaste = JsonConvert.SerializeObject(item.DevOpsRecordSolidWaste); } record.C_Remark = item.C_Remark; record.C_ID = Guid.NewGuid().ToString(); record.C_CreateBy = _claims.ApiUserId; record.D_CreateOn = DateTime.Now; record.C_Status = model.C_Status; devOpsRecordList.Add(record); if (null != item.FilePaths && item.FilePaths.Any()) { int i = 0; foreach (string imgPath in item.FilePaths) { if (string.IsNullOrWhiteSpace(imgPath)) { continue; } await _tmtnDevOpsRecordImageRepository.CreateOneAsync(new TMTN_DevOpsRecordApp { C_ID = Guid.NewGuid().ToString(), C_DevOpsContentCode = record.C_ID, C_Name = item?.FileNames?.ElementAt(i), //"维保记录" C_Url = imgPath, C_Type = "1", C_Remark = "", C_CreateBy = _claims.ApiUserId, D_CreateOn = DateTime.Now, C_Status = model.C_Status }); var resultItemImage = await _tmtnDevOpsRecordImageRepository.SaveAsync(); if (!resultItemImage) { throw new Exception("创建失败"); } i++; } } } var result = await _repository.CreateRangeAsync(devOpsRecordList); if (result <= 0) { throw new Exception("创建失败"); } } public async Task> GetRecordsConditionAsync(TmtnDevOpsRecordDetailSearchModel searchModel) { var result = await _repository.GetRecordsConditionAsync(searchModel); return result; } public async Task> GetDevOpsAsync(TmtnDevOpsDetailSearchModel searchModel) { var result = await _repository.GetDevOpsAsync(searchModel); return result; } public async Task>> GetRecordItemsGroupByRecordIdAsync(string recordId) { var result = await _repository.GetRecordItemsGroupByRecordIdAsync(recordId); return result; } public async Task> GetRecordItemsByRecordIdAsync(string recordId) { var result = await _repository.GetRecordItemsByRecordIdAsync(recordId); return result; } 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(TmtnDevOpsRecordSearchModel searchModel) { var predicate = PredicateBuilder.New(true);//查询条件,推荐后台使用这种方式灵活筛选 #region 添加条件查询 //predicate = predicate.And(i => i.C_Status.Equals("1")); if (!string.IsNullOrEmpty(searchModel.C_SpotDevOpsContentCode)) { predicate = predicate.And(i => i.C_SpotDevOpsContentCode.Equals(searchModel.C_SpotDevOpsContentCode)); } if (!string.IsNullOrEmpty(searchModel.C_ID)) { predicate = predicate.And(i => i.C_ID.Equals(searchModel.C_ID)); } if (!string.IsNullOrEmpty(searchModel.C_Record)) { predicate = predicate.And(i => i.C_Record.Contains(searchModel.C_Record)); } #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(string code, TmtnDevOpsRecordUpdateModel 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(TmtnDevOpsRecordUpdateModel), typeof(TMTN_DevOpsRecord)); _repository.Update(content); var result = await _repository.SaveAsync(); if (!result) { throw new Exception("更新失败"); } } public Task UpdateOneAsync(TmtnDevOpsRecordViewModel 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(); } } }