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 TdevDevSpotService : ITdevDevSpotService
{
private readonly ITdevDevSpotRepository _repository;
private readonly IUnitOfWork _unitOfWork;
private readonly ITispSpotRepository _tispSpotRepository;
private readonly IMapper _mapper;
private readonly IClaimsAccessor _claims;
public TdevDevSpotService(IClaimsAccessor claims, ITdevDevSpotRepository repository, IUnitOfWork unitOfWork, ITispSpotRepository tispSpotRepository, IMapper mapper)
{
_repository = repository;
_unitOfWork = unitOfWork;
_tispSpotRepository= tispSpotRepository;
_mapper = mapper;
_claims = claims;
}
public async Task CreateOneAsync(TdevDevSpotViewModel viewModel)
{
var content = _mapper.Map<TDEV_DevSpot>(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 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)
{
bool result = false;
try
{
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.Delete(content);
//var result = await _repository.SaveAsync();
Guid spotCode= new Guid(content.C_SpotCode);
TISP_Spot tispSpot = await _tispSpotRepository.GetByIdAsync(spotCode);
tispSpot.C_Status = "0";
_unitOfWork.BeginTransaction();
result = await _unitOfWork.RegisterDeleted(content);
if (result)
{
result = await _unitOfWork.RegisterDirty(tispSpot);
}
if (!result)
{
throw new Exception("删除失败");
}
}
catch
{
_unitOfWork.Rollback();
throw;
}
finally
{
if (result)
await _unitOfWork.CommitAsync();
else
_unitOfWork.Rollback();
}
}
public async Task<IEnumerable<TdevDevSpotViewModel>> GetAllAsync()
{
var pagedList = await _repository.GetAllAsync();
var contentDtoList = _mapper.Map<IEnumerable<TdevDevSpotViewModel>>(pagedList.ToList());
return contentDtoList.ToList();
}
public async Task<IEnumerable<TdevDevSpotViewModel>> GetConditionAsync(TdevDevSpotSearchModel searchModel)
{
var predicate = PredicateBuilder.New<TDEV_DevSpot>(true);//查询条件,推荐后台使用这种方式灵活筛选
#region 添加条件查询
//predicate = predicate.And(i => i.C_Status.Equals("1"));
if (!string.IsNullOrEmpty(searchModel.C_SpotCode))
{
predicate = predicate.And(i => i.C_SpotCode.Equals(searchModel.C_SpotCode));
}
if (!string.IsNullOrEmpty(searchModel.C_DevStoreCode))
{
predicate = predicate.And(i => i.C_DevStoreCode.Equals(searchModel.C_DevStoreCode));
}
if (!string.IsNullOrEmpty(searchModel.C_ID))
{
predicate = predicate.And(i => i.C_ID.Equals(searchModel.C_ID));
}
#endregion
var list = await _repository.GetPageAsync(predicate, "-D_CreateOn", searchModel.IsPagination, searchModel.PageIndex, searchModel.PageSize);
searchModel.TotalCount = list.Totals;
var dtoList = _mapper.Map<List<TDEV_DevSpot>, List<TdevDevSpotViewModel>>(list.Rows);
return dtoList;
}
public async Task<TdevDevSpotViewModel> GetByIdAsync(Guid id)
{
var content = await _repository.GetByIdAsync(id);
var contentDto = _mapper.Map<TdevDevSpotViewModel>(content);
return contentDto;
}
public async Task UpdateAsync(string code, TdevDevSpotUpdateModel 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(TdevDevSpotUpdateModel), typeof(TDEV_DevSpot));
_repository.Update(content);
var result = await _repository.SaveAsync();
if (!result)
{
throw new Exception("更新失败");
}
}
public async Task UpdateDevSpotAsync(TdevDevSpotsUpdateModel updateModel)
{
var result = false;
//_unitOfWork.BeginTransaction();
try
{
//MySqlConnector.MySqlParameter[] parameters = new[] { new MySqlConnector.MySqlParameter("DevStoreCode", updateModel.C_DevStoreCode) };
//string sql = "DELETE from TDEV_DevSpot WHERE C_DevStoreCode = @DevStoreCode";
//await _unitOfWork.ExecuteSqlCommandAsync(sql, parameters);
await _repository.DeleteByDevIdAsync(updateModel.C_DevStoreCode);
IList<TDEV_DevSpot> contentList = new List<TDEV_DevSpot>();
if (null != updateModel.SpotCodeList)
{
foreach (var item in updateModel.SpotCodeList)
{
TDEV_DevSpot devspot = new TDEV_DevSpot();
devspot.C_ID = Guid.NewGuid().ToString();
devspot.C_Remark = updateModel.C_Remark;
devspot.C_SpotCode = item;
devspot.C_DevStoreCode = updateModel.C_DevStoreCode;
devspot.C_CreateBy = _claims.ApiUserId;
devspot.D_CreateOn = DateTime.Now;
contentList.Add(devspot);
}
//result = await _unitOfWork.RegisterRangeNew(contentList);
result = await _repository.CreateRangeAsync(contentList)>0;
}
}
catch (Exception ex)
{
throw new Exception("创建失败");
}
finally
{
//if (result)
// await _unitOfWork.CommitAsync();
//else
// _unitOfWork.Rollback();
}
//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;
//foreach (var item in updateModel.SpotCodeList)
//{
// TDEV_DevSpot devSpot = new TDEV_DevSpot();
//}
//_mapper.Map(updateModel, content, typeof(TdevDevSpotUpdateModel), typeof(TDEV_DevSpot));
//_repository.Update(content);
//var result = await _repository.SaveAsync();
//if (!result)
//{
// throw new Exception("更新失败");
//}
}
public Task<int> UpdateOneAsync(TdevDevSpotViewModel viewModel, params string[] fields)
{
throw new NotImplementedException();
}
public Task<bool> IsExistAsync(Guid id)
{
throw new NotImplementedException();
}
public Task<IEnumerable<TdevDevSpotViewModel>> GetByConditionAsync(Expression<Func<TdevDevSpotViewModel, bool>> expression)
{
throw new NotImplementedException();
}
public Task UpdateAsync(string code, TpntAreaUpdateModel updateModel)
{
throw new NotImplementedException();
}
public Task<IEnumerable<TdevDevSpotViewModel>> GetConditionAsync(TpntAreaSearchModel searchModel)
{
throw new NotImplementedException();
}
}
}