218 lines
8.5 KiB
C#
218 lines
8.5 KiB
C#
using Microsoft.Extensions.Localization;
|
|
using SJZY.Expand.ABP.Core.Common.Dto;
|
|
using SJZY.Expand.ABP.Core.Localization;
|
|
using SJZY.Track.Application.Contract.Dtos.TrackContents;
|
|
using SJZY.Track.Application.Contract.Dtos.TrackPull;
|
|
using SJZY.Track.Application.Localization;
|
|
using SJZY.Track.Domain.Aggregates.TrackContentAggregate;
|
|
using SJZY.Track.Domain.Aggregates.TrackPullAggregate;
|
|
using SJZY.Track.Domain.Dtos.TrackContents;
|
|
using System.Linq.Expressions;
|
|
using Volo.Abp.DependencyInjection;
|
|
|
|
namespace SJZY.Track.Application.Services.TrackContents
|
|
{
|
|
/// <summary>
|
|
/// 轨迹内容服务
|
|
/// </summary>
|
|
[ApiExplorerSettings(GroupName = "轨迹内容")]
|
|
[Route("/Track/Content")]
|
|
public class TrackContentService : ApplicationService, ITransientDependency
|
|
{
|
|
private readonly IStringLocalizer<TrackLocalizationResource> _stringLocalizer;
|
|
private readonly ITrackContentRepository _trackContentRepository;
|
|
|
|
public TrackContentService(
|
|
IStringLocalizer<TrackLocalizationResource> stringLocalizer,
|
|
ITrackContentRepository trackContentRepository
|
|
|
|
)
|
|
{
|
|
this._stringLocalizer = stringLocalizer;
|
|
this._trackContentRepository = trackContentRepository;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 轨迹内容编辑
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[HttpPost("Edit")]
|
|
public async Task<UnifyResultDto> EditAsync(EditTrackContentInput input)
|
|
{
|
|
return input.Options switch
|
|
{
|
|
OptionType.新增 => await AddAsync(input),
|
|
OptionType.修改 => await UpdateAsync(input),
|
|
OptionType.删除 => await DeleteAsync(input),
|
|
_ => throw new BusinessException(message: "当前操作动作不合法")
|
|
};
|
|
}
|
|
|
|
/// <summary>
|
|
/// 根据内容id获取轨迹内容
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <returns></returns>
|
|
[HttpGet("GetDetail")]
|
|
public async Task<UnifyResultDto<GetTrackContentDetailDto>> GetDetailAsync(int id)
|
|
{
|
|
var detailInfo = await _trackContentRepository.GetDetailAsync(id);
|
|
if (detailInfo == null)
|
|
{
|
|
return new UnifyResultDto<GetTrackContentDetailDto>(false, null, "未查询到轨迹状态");
|
|
}
|
|
|
|
var dto = ObjectMapper.Map<GetTrackContentDetailVO, GetTrackContentDetailDto>(detailInfo);
|
|
return new UnifyResultDto<GetTrackContentDetailDto>("200", "", dto);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取分页轨迹内容
|
|
/// </summary>
|
|
/// <param name="input"></param>
|
|
/// <returns></returns>
|
|
[HttpPost("GetList")]
|
|
public async Task<UnifyPageResultDto<GetTrackContentListDto>> GetPageTrackContent(
|
|
GetPageTrackContentInput input)
|
|
{
|
|
var vo = ObjectMapper.Map<GetPageTrackContentInput, GetPageTrackContentVO>(input);
|
|
var resultDto = await _trackContentRepository.GetPageTrackContent(vo);
|
|
var pageResultDto =
|
|
ObjectMapper.Map<UnifyPageResultDto<GetTrackContentListVO>, UnifyPageResultDto<GetTrackContentListDto>>(
|
|
resultDto);
|
|
|
|
return pageResultDto;
|
|
}
|
|
|
|
#region 私有方法
|
|
|
|
private async Task<UnifyResultDto> AddAsync(EditTrackContentInput input)
|
|
{
|
|
#region 业务逻辑校验
|
|
|
|
var trackContentEntity = await _trackContentRepository.GetFirstAsync(a =>
|
|
a.SubSystemId == input.SubSystemId && (a.Code == input.Code ||
|
|
a.Content == input.Content || a.EnContent == input.EnContent));
|
|
if (trackContentEntity != null)
|
|
{
|
|
throw new BusinessException(message: _stringLocalizer["TrackContentExist"]);
|
|
}
|
|
|
|
#endregion 业务逻辑校验
|
|
|
|
var entity = ObjectMapper.Map<EditTrackContentInput, TrackContentEntity>(input);
|
|
var isTrue = await _trackContentRepository.InsertAsync(entity);
|
|
|
|
return new UnifyResultDto("200", "新增成功", isTrue);
|
|
}
|
|
|
|
private async Task<UnifyResultDto> UpdateAsync(EditTrackContentInput input)
|
|
{
|
|
#region 业务逻辑校验
|
|
|
|
var trackContentEntity = await _trackContentRepository.GetFirstAsync(a => a.Id != input.Id &&
|
|
a.SubSystemId == input.SubSystemId && (a.Code == input.Code ||
|
|
a.Content == input.Content || a.EnContent == input.EnContent));
|
|
if (trackContentEntity != null)
|
|
{
|
|
throw new BusinessException(message: _stringLocalizer["TrackContentExist"]);
|
|
}
|
|
|
|
#endregion 业务逻辑校验
|
|
|
|
//更新的时候需要覆盖内容映射轨迹代码
|
|
var templateEntity = await _trackContentRepository.GetFirstAsync(a => a.Id == input.Id);
|
|
ObjectMapper.Map(input, templateEntity);
|
|
var isTrue = await _trackContentRepository.UpdateAsync(templateEntity);
|
|
|
|
return new UnifyResultDto("200", "修改成功", isTrue);
|
|
}
|
|
|
|
private async Task<UnifyResultDto> DeleteAsync(EditTrackContentInput input)
|
|
{
|
|
#region 业务校验
|
|
|
|
//需要加个判断,存在内容映射,则出提示
|
|
|
|
#endregion 业务校验
|
|
|
|
var isTrue = await _trackContentRepository.SoftDeleteAsync(x => x.Id == input.Id);
|
|
|
|
return new UnifyResultDto("200", "删除成功", isTrue);
|
|
}
|
|
|
|
#endregion 私有方法
|
|
|
|
/// <summary>
|
|
/// 轨迹内容映射列表
|
|
/// </summary>
|
|
/// <param name="input"></param>
|
|
/// <returns></returns>
|
|
[HttpPost("GetMapPage")]
|
|
public async Task<UnifyPageResultDto<GetTrackContentMapPageOutputVO>> GetMapPageAsync([FromBody] GetTrackContentMapPageInputVO input)
|
|
{
|
|
return await _trackContentRepository.GetMapPageAsync(input);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 轨迹内容映射详情
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <returns></returns>
|
|
[HttpGet("GetMapDetail")]
|
|
public async Task<GetTrackContentMapDetailOutputVO> GetMapDetailAsync(int id)
|
|
{
|
|
return await _trackContentRepository.GetMapDetailAsync(id);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 轨迹内容映射编辑
|
|
/// </summary>
|
|
/// <param name="input"></param>
|
|
/// <returns></returns>
|
|
[HttpPost("EditMap")]
|
|
public async Task<bool> EditMapAsync([FromBody] EditTrackContentMapInput input)
|
|
{
|
|
if (input.Options != OptionTypeNoNull.删除)
|
|
{
|
|
Expression<Func<TrackContentMapEntity, bool>> isMapAnyExp = x =>
|
|
x.TrackContentId == input.TrackContentId && x.MapTrackContentId == input.MapTrackContentId;
|
|
if (input.Options == OptionTypeNoNull.修改) isMapAnyExp.And(x => x.Id != input.Id);
|
|
|
|
if (await _trackContentRepository.IsMapAnyAsync(isMapAnyExp))
|
|
throw new BusinessException(message: _stringLocalizer["IsTrackContentMapAny"]);
|
|
}
|
|
|
|
switch (input.Options)
|
|
{
|
|
case OptionTypeNoNull.新增:
|
|
{
|
|
var trackContentMapEntity = ObjectMapper.Map<EditTrackContentMapInput, TrackContentMapEntity>(input);
|
|
|
|
await _trackContentRepository.InsertMapAsync(trackContentMapEntity);
|
|
}
|
|
break;
|
|
|
|
case OptionTypeNoNull.修改:
|
|
{
|
|
var oldTrackContentMapEntity = await _trackContentRepository.GetMapByIdAsync(input.Id!.Value) ?? throw new BusinessException(message: _stringLocalizer["NotFindData"]);
|
|
|
|
ObjectMapper.Map(input, oldTrackContentMapEntity);
|
|
|
|
await _trackContentRepository.UpdateMapAsync(oldTrackContentMapEntity);
|
|
}
|
|
break;
|
|
|
|
case OptionTypeNoNull.删除:
|
|
await _trackContentRepository.SoftDeleteMapAsync(x => x.Id == input.Id);
|
|
break;
|
|
|
|
default:
|
|
throw new BusinessException(message: _stringLocalizer[SjzyBasicLocalization.Validation_IsInEnum,
|
|
nameof(EditTrackContentMapInput.Options)]);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
}
|
|
} |