Atomx/Atomx.Admin/Atomx.Admin/Controllers/StateProvinceController.cs

using Atomx.Admin.Client.Models;
using Atomx.Admin.Services;
using Atomx.Common.Constants;
using Atomx.Common.Entities;
using Atomx.Common.Models;
using Atomx.Data;
using Atomx.Data.CacheServices;
using Atomx.Data.Services;
using FluentValidation;
using MapsterMapper;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Localization;
using System.Threading.Tasks;

namespace Atomx.Admin.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    public class StateProvinceController : ControllerBase
    {
        private readonly ILogger<StateProvinceController> _logger;
        private readonly DataContext _dbContext;
        private readonly IIdCreatorService _idCreator;
        private readonly IIdentityService _identityService;
        private readonly IMapper _mapper;
        private readonly ICacheService _cacheService;
        readonly IValidator<StateProvinceModel> _validator;
        readonly IStringLocalizer<StateProvinceController> _localizer;

        /// <summary>
        /// 
        /// </summary>
        /// <param name="logger"></param>
        /// <param name="idCreator"></param>
        /// <param name="identityService"></param>
        /// <param name="dbContext"></param>
        /// <param name="mapper"></param>
        /// <param name="jwtSettings"></param>
        /// <param name="cacheService"></param>
        public StateProvinceController(ILogger<StateProvinceController> logger, IIdCreatorService idCreator, IIdentityService identityService, DataContext dbContext, IMapper mapper, ICacheService cacheService, IValidator<StateProvinceModel> validator, IStringLocalizer<StateProvinceController> localizer)
        {
            _logger = logger;
            _idCreator = idCreator;
            _identityService = identityService;
            _dbContext = dbContext;
            _mapper = mapper;
            _cacheService = cacheService;
            _validator = validator;
            _localizer = localizer;
        }

        /// <summary>
        /// 数据查询
        /// </summary>
        /// <param name="search"></param>
        /// <param name="page"></param>
        /// <param name="size"></param>
        /// <returns></returns>
        [HttpGet("tree/{countryId:long}")]
        public async Task<IActionResult> GetTree(long countryId, int page, int size = 20)
        {
            var list = await _cacheService.GetAreaTree(countryId);

            return new JsonResult(new ApiResult<List<KeyValueTree>>().IsSuccess(list));
        }

        /// <summary>
        /// 数据查询
        /// </summary>
        /// <param name="search"></param>
        /// <param name="page"></param>
        /// <param name="size"></param>
        /// <returns></returns>
        [HttpGet("select/{countryId:long}")]
        public IActionResult Select(long countryId, int page, int size = 20)
        {
            var list = new List<KeyValue>();
            var query = from p in _dbContext.StateProvinces
                        where p.CountryId == countryId && p.Enabled
                        select p;
            list = query.OrderByDescending(p => p.DisplayOrder).Select(p => new KeyValue() { Label = p.Id.ToString(), Value = p.Name }).ToList();

            return new JsonResult(new ApiResult<List<KeyValue>>().IsSuccess(list));
        }

        /// <summary>
        /// 数据查询
        /// </summary>
        /// <param name="search"></param>
        /// <param name="page"></param>
        /// <param name="size"></param>
        /// <returns></returns>
        [HttpPost("search")]
        public IActionResult Search(StateProvinceSearch search, int page, int size = 20)
        {
            if (page < 1)
            {
                page = 1;
            }
            var result = new ApiResult<PagingList<StateProvince>>();
            var list = new PagingList<StateProvince>() { Index = page, Size = size };
            var query = from p in _dbContext.StateProvinces
                        select p;

            if (!string.IsNullOrEmpty(search.Name))
            {
                query = from p in query
                        where p.Name.Contains(search.Name)
                        select p;
            }

            if (search.CountryId > 0)
            {
                query = from p in query
                        where p.CountryId == search.CountryId
                        select p;
            }
            list.Count = query.Count();
            list.Items = query.OrderByDescending(p => p.DisplayOrder).Skip((page - 1) * size).Take(size).ToList();

            result = result.IsSuccess(list);

            return new JsonResult(result);
        }

        /// <summary>
        /// 通过ID获取数据
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [HttpGet("{id:long}")]
        public IActionResult Get(long id)
        {
            var result = new ApiResult<StateProvince>();
            var data = _dbContext.StateProvinces.SingleOrDefault(p => p.Id == id);
            if (data == null)
            {
                return new JsonResult(new ApiResult<string>().IsFail("数据不存在", null));
            }

            result = result.IsSuccess(data);
            return new JsonResult(result);
        }


        /// <summary>
        /// 通过ID获取详情,含多语言
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [HttpGet("detail")]
        public IActionResult Detail(long id)
        {
            var result = new ApiResult<StateProvinceLocalizedModel>();
            var data = _dbContext.StateProvinces.SingleOrDefault(p => p.Id == id);
            if (data == null)
            {
                return new JsonResult(new ApiResult<string>().IsFail("数据不存在", null));
            }
            var localizedList = _dbContext.LocalizedProperties.Where(p => p.EntityId == id).ToList();
            var model = _mapper.Map<StateProvinceLocalizedModel>(data);
            model.Locales = localizedList;

            result = result.IsSuccess(model);

            return new JsonResult(result);
        }


        /// <summary>
        /// 新增编辑数据
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [HttpPost("save")]
        public IActionResult AddressEdit(StateProvinceModel model)
        {
            var result = new ApiResult<bool>();
            var validation = _validator.Validate(model);
            if (!validation.IsValid)
            {
                var message = validation.Errors.FirstOrDefault()?.ErrorMessage ?? string.Empty;
                return new JsonResult(new ApiResult<string>().IsFail(message, null));
            }
            var data = _dbContext.StateProvinces.SingleOrDefault(p => p.CountryId == model.CountryId && p.Name == model.Name && p.Id != model.Id);
            if (data != null)
            {
                return new JsonResult(new ApiResult<string>().IsFail("当前数据已经存在，请认真检查", null));
            }
            if (model.Id > 0)
            {
                data = _dbContext.StateProvinces.SingleOrDefault(p => p.Id == model.Id);
                if (data == null)
                {
                    return new JsonResult(new ApiResult<string>().IsFail("数据不存在", null));
                }

                data = _mapper.Map(model, data);

                _dbContext.SaveChanges();

            }
            else
            {
                data = _mapper.Map<StateProvince>(model);
                data.Id = _idCreator.CreateId();

                _dbContext.StateProvinces.Add(data);
                _dbContext.SaveChanges();
            }

            return new JsonResult(new ApiResult<string>().IsSuccess("操作成功"));
        }

        /// <summary>
        /// 删除数据
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>

        [HttpPost("delete")]
        public async Task<IActionResult> DeleteAsync(long id)
        {
            var result = new ApiResult<string>();
            try
            {
                Console.WriteLine($"{id} deleted");
                var count = _dbContext.StateProvinces.Where(p => p.Id == id).ExecuteDelete();
                result = result.IsSuccess(count.ToString());
            }
            catch (Exception ex)
            {
                result = result.IsFail(ex.Message);
                _logger.LogError(ex.Message);
            }
            return new JsonResult(result);
        }

    }
}