LegalServiceV1/SourceCode/V2/ContractService/ContractService.Application/Lawyer/LawyerApplicationService.cs

using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using System.Web.Mvc;
using Abp.Application.Services.Dto;
using Abp.Auditing;
using Abp.Authorization;
using Abp.Domain.Repositories;
using Abp.Runtime.Caching;
using IwbZero.Auditing;
using IwbZero.AppServiceBase;
using ContractService.Authorization;
using ContractService.Configuration;
using ContractService.Lawyer.Dto;
using ContractService.LegalContract;
using IwbZero.ToolCommon.StringModel;
using IwbZero.Runtime.Session;

namespace ContractService.Lawyer
{
    [AbpAuthorize, AuditLog("律师信息")]
    public class LawyerAppService : IwbAsyncCrudAppService<LawyerInfo, LawyerDto, string, IwbPagedRequestDto, LawyerCreateDto, LawyerUpdateDto >, ILawyerAppService
    {
        public LawyerAppService(
			ICacheManager cacheManager,
			IRepository<LawyerInfo, string> repository, LegalManager legalManager) : base(repository, "Id")
        {
            LegalManager = legalManager;
            CacheManager = cacheManager;
        }

        protected override bool KeyIsAuto { get; set; } = false;

        public LegalManager LegalManager { get; }

        #region GetSelect

        [DisableAuditing]
        public override async Task<List<SelectListItem>> GetSelectList()
        {
            var list = await Repository.GetAllListAsync();
            var sList = new List<SelectListItem> {new SelectListItem {Text = @"请选择...", Value = "", Selected = true}};
            foreach (var l in list)
            {
                sList.Add(new SelectListItem { Value = l.Id, Text = l.Name });
            }
            return sList;
        }
        [DisableAuditing]
        public override async Task<string> GetSelectStr()
        {
            var list = await Repository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.Name}</option>";
            }
            return str;
        }

        #endregion

        #region CURD

        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgCreate)]
        public override async Task Create(LawyerCreateDto input)
        {
            var entity = MapToEntity(input);
            entity.LawFirmNo = input.LawFirmNo.Empty() ? AbpSession.GetClaimValue(IwbConsts.UserCompanyLawFirmClaimType) : input.LawFirmNo;

            await LegalManager.CreateLawyer(entity, input.LawFirmNo); 
        }

        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgUpdate)]
        public override async Task Update(LawyerUpdateDto input)
        {
            var entity = await GetEntityById(input.Id);
            if (entity == null)
            {
                CheckErrors(NotExistMessage);
            }
            MapToEntity(input, entity);
            await LegalManager.UpdateLawyer(entity);
        }

        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgDelete)]
        public override Task Delete(EntityDto<string> input)
        {
            return LegalManager.DeleteLawyer(input.Id);
        }

        [DisableAuditing]
        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgQuery)]
        public override async Task<PagedResultDto<LawyerDto>> GetAll(IwbPagedRequestDto input)
        {
            LegalManager.CheckAccount(AccountTypeDefinition.System, AccountTypeDefinition.Lawyer);
            var query = LegalManager.QueryAllLawyer();

            if (input.SearchList.Any(a => a.KeyField.ToLower() == "lawfirm"))
            {
                var search = input.SearchList.FirstOrDefault(a => a.KeyField.ToLower() == "lawfirm");
                var no = search?.KeyWords;
                if (search != null) input.SearchList.Remove(search);
                query = LegalManager.QueryLawFirmAllLawyers(no);
            }

            if (!string.IsNullOrEmpty(input.KeyWords))
            {
                query = input.KeyField.ToLower() == "keyword" ? KeyWordFilter(query, input.KeyWords) : KeyWordFilter(query, input);
            }
            query = SearchListFilter(query, input);
            var totalCount = await AsyncQueryableExecuter.CountAsync(query);
            query = _ApplySorting(query, input);
            query = _ApplyPaging(query, input);
            var entities = await AsyncQueryableExecuter.ToListAsync(query);
            var dtoList = new PagedResultDto<LawyerDto>(totalCount, entities.Select(a=>new LawyerDto(a)).ToList());
            return dtoList;
        }

        protected override IQueryable<LawyerInfo> SelfSorting(IQueryable<LawyerInfo> query, IwbPagedRequestDto input)
        {
            return query.OrderByDescending(r => r.Id);
        }

        protected override IQueryable<LawyerInfo> KeyWordFilter(IQueryable<LawyerInfo> query, string keyword)
        {
            return query.Where(a => a.Id.Contains(keyword) || a.Name.Contains(keyword) ||
                                    a.PhoneNumber.Contains(keyword) || a.PhoneNumber2.Contains(keyword) ||
                                    a.Code.Contains(keyword) ||
                                    (a.LawFirmInfo != null &&
                                     (a.LawFirmInfo.Name.Contains(keyword) ||
                                      a.LawFirmInfo.DisplayName.Contains(keyword))) ||
                                    (a.OrganizationInfo != null && a.OrganizationInfo.Name.Contains(keyword)));
        }
        protected  IQueryable<LawyerInfoClone> KeyWordFilter(IQueryable<LawyerInfoClone> query, string keyword)
        {
            return query.Where(a => a.Id.Contains(keyword) || a.Name.Contains(keyword) || a.PhoneNumber.Contains(keyword) || a.PhoneNumber2.Contains(keyword) || a.Code.Contains(keyword));
        }

		#region GetEntity/Dto

        /// <summary>
        ///  查询实体Dto
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [DisableAuditing]
        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgQuery)]
        public override async Task<LawyerDto> GetDto(EntityDto<string> input)
        {
            var entity = await GetEntity(input);
            return MapToEntityDto(entity);
        }

        /// <summary>
        ///  查询实体Dto
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [DisableAuditing]
        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgQuery)]
        public override async Task<LawyerDto> GetDtoById(string id)
        {
            var entity = await GetEntityById(id);
            return MapToEntityDto(entity);
        }

        /// <summary>
        /// 查询实体Dto（需指明自定义字段）
        /// </summary>
        /// <param name="no"></param>
        /// <returns></returns>
        [DisableAuditing]
        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgQuery)]
        public override async Task<LawyerDto> GetDtoByNo(string no)
        {
            var entity = await GetEntityByNo(no);
            return MapToEntityDto(entity);
        }

        /// <summary>
        /// 查询实体
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [DisableAuditing]
        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgQuery)]
        public override async Task<LawyerInfo> GetEntity(EntityDto<string> input)
        {
            var entity = await GetEntityById(input.Id);
            return entity;
        }

        /// <summary>
        /// 查询实体
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [DisableAuditing]
        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgQuery)]
        public override async Task<LawyerInfo> GetEntityById(string id)
        {
            return await Repository.FirstOrDefaultAsync(a=>a.Id==id);
        }

        /// <summary>
        /// 查询实体（需指明自定义字段）
        /// </summary>
        /// <param name="no"></param>
        /// <returns></returns>
        [DisableAuditing]
        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgQuery)]
        public override async Task<LawyerInfo> GetEntityByNo(string no)
        {
            //CheckGetPermission();
            if (string.IsNullOrEmpty(KeyFiledName))
            {
                ThrowError("NoKeyFieldName");
            }
            return await base.GetEntityByNo(no);
        }

        #endregion

		#region Hide
       
		///// <summary>
        ///// 根据给定的<see cref="IwbPagedRequestDto"/>创建 <see cref="IQueryable{LawyerInfo}"/>过滤查询.
        ///// </summary>
        ///// <param name="input">The input.</param>
        //protected override IQueryable<LawyerInfo> CreateFilteredQuery(IwbPagedRequestDto input)
        //{
        //    var query = Repository.GetAll();
        //    var pagedInput = input as IIwbPagedRequest;
        //    if (pagedInput == null)
        //    {
        //        return query;
        //    }
        //    if (!string.IsNullOrEmpty(pagedInput.KeyWords))
        //    {
        //        object keyWords = pagedInput.KeyWords;
        //        LambdaObject obj = new LambdaObject()
        //        {
        //            FieldType = (LambdaFieldType)pagedInput.FieldType,
        //            FieldName = pagedInput.KeyField,
        //            FieldValue = keyWords,
        //            ExpType = (LambdaExpType)pagedInput.ExpType
        //        };
        //        var exp = obj.GetExp<LawyerInfo>();
        //        query = exp != null ? query.Where(exp) : query;
        //    }
        //    if (pagedInput.SearchList != null && pagedInput.SearchList.Count > 0)
        //    {
        //        List<LambdaObject> objList = new List<LambdaObject>();
        //       foreach (var o in pagedInput.SearchList)
        //        {
        //            if (string.IsNullOrEmpty(o.KeyWords))
        //                continue;
        //           object keyWords = o.KeyWords;
        //            objList.Add(new LambdaObject
        //            {
        //                FieldType = (LambdaFieldType)o.FieldType,
        //                FieldName = o.KeyField,
        //                FieldValue = keyWords,
        //                ExpType = (LambdaExpType)o.ExpType
        //            });
        //        }
        //        var exp = objList.GetExp<LawyerInfo>();
        //        query = exp != null ? query.Where(exp) : query;
        //    }
        //    return query;
        //}



        //protected override IQueryable<LawyerInfo> ApplySorting(IQueryable<LawyerInfo> query, IwbPagedRequestDto input)
        //{
        //    return query.OrderBy(a => a.No);
        //}

        //protected override IQueryable<LawyerInfo> ApplyPaging(IQueryable<LawyerInfo> query, IwbPagedRequestDto input)
        //{
        //    if (input is IPagedResultRequest pagedInput)
        //    {
        //        return query.Skip(pagedInput.SkipCount).Take(pagedInput.MaxResultCount);
        //    }
        //    return query;
        //}

        #endregion

        #endregion


        /// <summary>
        /// 绑定账号
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgBind),AuditLog("绑定账号")]
        public async Task Bind(BindDto input)
        {
            await LegalManager.BindLawyerAccount(input.LawyerNo, input.UserName);
        }
        /// <summary>
        /// 解绑账号
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [AbpAuthorize(PermissionNames.PagesLegalLawFirmMgLawyerMgUnBind),AuditLog("解绑账号")]
        public async Task UnBind(EntityDto<string> input)
        {
            await LegalManager.UnBindLawyerAccount(input.Id);
        }
    }
}