WEP_V2.1.3/SourceCode/We.Platform/WePlatform.Application/BaseSystem/Query/QueryAppService.cs

using System.Collections.Generic;
using System.Data.Entity;
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.AppServiceBase;
using IwbZero.ToolCommon.StringModel;
using WeEngine.Enum;
using WePlatform.Authorization.Users;
using WePlatform.BaseSystem.Users.Dto;
using WePlatform.Configuration;
using WePlatform.WeBase;
using WePlatform.WeLib;
using WePlatform.WeLib.Guide.Dto;
using WePlatform.WeLib.Knowledge;
using WePlatform.WeLib.Knowledge.Plan.Dto;
using WePlatform.WeLib.Scene.Dto;
using WePlatform.WeLib.SceneFlow.Dto;
using WePlatform.WeModel;

namespace WePlatform.BaseSystem.Query
{
    [AbpAuthorize, DisableAuditing]
    public class QueryAppService : IwbAppServiceBase, IQueryAppService
    {

        #region 仓储

        public QueryAppService(
            IRepository<User, long> userRepository,
            ICacheManager cacheManager, IRepository<SceneCategoryInfo, string> sceneCategoryRepository, IRepository<EngineInfo, string> engineRepository, IRepository<EngineModelInfo, string> engineModelRepository, IRepository<BehaviorInfo, string> behaviorRepository, IRepository<BehaviorRoleInfo, string> behaviorRoleRepository, IRepository<SceneInfo, string> sceneRepository, IRepository<GuideInfo, string> guideRepository, IRepository<KnowledgeInfo, string> knowledgeRepository, IRepository<SceneFlowInfo, string> sceneFlowRepository, IRepository<EngineComponentInfo, string> componentRepository, IRepository<EnvironResourceInfo, string> environRepository, IRepository<EvalModelInfo, string> evalModelRepository, IRepository<RoleRelateCategoryInfo> roleCategoryRepository, IRepository<EmergencyPlanInfo, string> planRepository, IRepository<EvalTargetInfo, string> evalTargetRepository)
        {
            UserRepository = userRepository;
            SceneCategoryRepository = sceneCategoryRepository;
            EngineRepository = engineRepository;
            EngineModelRepository = engineModelRepository;
            BehaviorRepository = behaviorRepository;
            BehaviorRoleRepository = behaviorRoleRepository;
            SceneRepository = sceneRepository;
            GuideRepository = guideRepository;
            KnowledgeRepository = knowledgeRepository;
            SceneFlowRepository = sceneFlowRepository;
            ComponentRepository = componentRepository;
            EnvironRepository = environRepository;
            EvalModelRepository = evalModelRepository;
            RoleCategoryRepository = roleCategoryRepository;
            PlanRepository = planRepository;
            EvalTargetRepository = evalTargetRepository;
            CacheManager = cacheManager;
        }

        protected IRepository<User, long> UserRepository { get; }
        protected IRepository<SceneCategoryInfo, string> SceneCategoryRepository { get; }
        protected IRepository<RoleRelateCategoryInfo> RoleCategoryRepository { get; }
        protected IRepository<BehaviorInfo, string> BehaviorRepository { get; }
        protected IRepository<BehaviorRoleInfo, string> BehaviorRoleRepository { get; }
        protected IRepository<SceneInfo, string> SceneRepository { get; }
        protected IRepository<SceneFlowInfo, string> SceneFlowRepository { get; }
        protected IRepository<EmergencyPlanInfo, string> PlanRepository { get; }
        protected IRepository<KnowledgeInfo, string> KnowledgeRepository { get; }
        protected IRepository<GuideInfo, string> GuideRepository { get; }
        protected IRepository<EngineInfo, string> EngineRepository { get; }
        protected IRepository<EngineComponentInfo, string> ComponentRepository { get; }
        protected IRepository<EngineModelInfo, string> EngineModelRepository { get; }
        protected IRepository<EvalModelInfo, string> EvalModelRepository { get; }
        protected IRepository<EvalTargetInfo, string> EvalTargetRepository { get; }
        protected IRepository<EnvironResourceInfo, string> EnvironRepository { get; }

        #endregion

        #region SELECT

        #region 场景类别

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetCategorySelectList()
        {
            var list = await SceneCategoryRepository.GetAllListAsync(a => a.ParentNo != null);
            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.CategoryName });
            }
            return sList;
        }

        [DisableAuditing]
        public async Task<string> GetCategorySelectStr()
        {
            var list = await SceneCategoryRepository.GetAllListAsync();
            string str = "";//"<option  value=\"\" selected >请选择场景类别...</option>";
            var tempParentNo = list.FirstOrDefault(a=>a.ParentNo==null)?.Id??"";
            foreach (var l in list)
            {
                var name = l.CategoryName;
                var parentNo = l.ParentNo;
                var id = l.Id;
                if (l.ParentNo == null)
                {
                    parentNo = "0";
                    id = "";
                    name = "请选择场景类别";
                }
                else if(l.ParentNo == tempParentNo)
                {
                    parentNo = "";
                }
                str += $"<option parent=\"{parentNo}\" value=\"{id}\">{name}</option>";
            }
            return str;
        }

        #endregion 场景类别

        #region 行为角色

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetBehaviorRoleSelectList()
        {
            var list = await BehaviorRoleRepository.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.RoleName });
            }
            return sList;
        }

        [DisableAuditing]
        public async Task<string> GetBehaviorRoleSelectStr()
        {
            var list = await BehaviorRoleRepository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择行为角色...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.RoleName}</option>";
            }
            return str;
        }
        [DisableAuditing]
        public async Task<string> GetBehaviorRoleSelectStrByCategory(string no)
        {
            return await CacheManager.GetCache(IwbCacheNames.BehaviorRoleCache).GetAsync($"SC-{no}",async () => {
                var list = await RoleCategoryRepository.GetAllIncluding(a => a.RoleInfo).Where(a => a.CategoryNo == no).ToListAsync();
                string str = "<option value=\"\" selected>请选择行为角色...</option>";
                foreach (var l in list)
                {
                    str += $"<option value=\"{l.RoleNo}\">{l.RoleName}</option>";
                }
                return str;
            });
            
        }

        #endregion 行为角色

        #region 行为

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetBehaviorSelectList()
        {
            var list = await BehaviorRepository.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.BehaviorName });
            }
            return sList;
        }

        [DisableAuditing]
        public async Task<string> GetBehaviorSelectStr()
        {
            var list = await BehaviorRepository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择行为规则...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.BehaviorName}</option>";
            }
            return str;
        }
        [DisableAuditing]
        public async Task<string> GetBehaviorSelectStrByCategory(string no)
        {
            var list = await BehaviorRepository.GetAllListAsync(a => a.SceneCategory == no);
            string str = "<option value=\"\" selected>请选择行为规则...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.BehaviorName}</option>";
            }
            return str;
        }

        [DisableAuditing]
        public async Task<string> GetBehaviorScoreTypeStr()
        {
            string str = "<option value=\"\" selected>请选择行为评估类型...</option>";
            str += await StatesManager.GetSelectListStrAsync("Behavior", "ScoreType");
            return str;
        }
        [DisableAuditing]
        public string GetBehaviorNonEvolutionTypeStr()
        {
            string str = "<option value=\"\" selected>请选择答案类型...</option>";
            str += $"<option value=\"{BehaviorScoreType.Normal.ToInt()}\" selected>正确</option>";
            str += $"<option value=\"{BehaviorScoreType.ImportantNegative.ToInt()}\" selected>错误</option>";
            return str;
        }

        #endregion 行为

        #region 情景

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetSceneSelectList()
        {
            var list = await SceneRepository.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 async Task<string> GetSceneSelectStr()
        {
            var list = await SceneRepository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择情景信息...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.Name}</option>";
            }
            return str;
        }
        [DisableAuditing]
        public async Task<string> GetSceneSelectStrByCategory(string no)
        {
            var list = await SceneRepository.GetAllListAsync(a => a.SceneCategory == no);
            string str = "<option value=\"\" selected>请选择情景信息...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.Name}</option>";
            }
            return str;
        }
        [DisableAuditing]
        public async Task<string> GetSceneTypeStr()
        {
            string str = "<option value=\"\" selected>请选择情景类型...</option>";
            str += await StatesManager.GetSelectListStrAsync("Scene", "SceneType");
            return str;
        }
        

        #endregion 情景

        #region 情景流

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetSceneFlowSelectList()
        {
            var list = await SceneFlowRepository.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.FlowName });
            }
            return sList;
        }

        [DisableAuditing]
        public async Task<string> GetSceneFlowSelectStr()
        {
            var list = await SceneFlowRepository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择情景流信息...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.FlowName}</option>";
            }
            return str;
        }
        [DisableAuditing]
        public async Task<string> GetSceneFlowSelectStrByCategory(string no)
        {
            var list = await SceneFlowRepository.GetAllListAsync(a => a.SceneCategory == no);
            string str = "<option value=\"\" selected>请选择情景流信息...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.FlowName}</option>";
            }
            return str;
        }
        

        #endregion 情景流

        #region 知识引导信息

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetGuideSelectList()
        {
            var list = await GuideRepository.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 async Task<string> GetGuideSelectStr()
        {
            var list = await GuideRepository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择引导提示信息...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.Name}</option>";
            }
            return str;
        }

        [DisableAuditing]
        public async Task<string> GetGuideTypeSelectStr()
        {
            string str = "<option value=\"\" selected>请选择引导提示类型...</option>";
            str += await StatesManager.GetSelectListStrAsync("Guide", "GuideType");
            return str;
        }

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetKnowledgeSelectList()
        {
            var list = await KnowledgeRepository.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 async Task<string> GetKnowledgeSelectStr()
        {
            var list = await KnowledgeRepository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择知识信息...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.Name}</option>";
            }
            return str;
        }
        [DisableAuditing]
        public async Task<string> GetPlanTreeSelectStr()
        {
            var list = await PlanRepository.GetAllListAsync();
            string str = "";
            var tempParentNo = list.FirstOrDefault(a => a.ParentNo == null)?.Id ?? "";
            foreach (var l in list)
            {
                var name = l.Name;
                var parentNo = l.ParentNo;
                var id = l.Id;
                if (l.ParentNo == null)
                {
                    parentNo = "0";
                    id = "";
                    name = "请选择应急预案";
                }
                else if (l.ParentNo == tempParentNo)
                {
                    parentNo = "";
                }
                str += $"<option parent=\"{parentNo}\" value=\"{id}\">{name}</option>";
            }
            return str;
        }

        #endregion 知识引导信息

        #region 事务组件

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetComponentSelectList()
        {
            var list = await ComponentRepository.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 async Task<string> GetComponentSelectStr()
        {
            var list = await ComponentRepository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择事务组件...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.Name}</option>";
            }
            return str;
        }

        #endregion 引擎

        #region 引擎

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetEngineSelectList()
        {
            var list = await EngineRepository.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.EngineName });
            }
            return sList;
        }

        [DisableAuditing]
        public async Task<string> GetEngineSelectStr()
        {
            var list = await EngineRepository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择推演引擎...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.EngineName}</option>";
            }
            return str;
        }

        #endregion 引擎

        #region 模型

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetModelSelectList()
        {
            var list = await EngineModelRepository.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.ModelName });
            }
            return sList;
        }

        [DisableAuditing]
        public async Task<string> GetModelSelectStr()
        {
            var list = await EngineModelRepository.GetAllIncluding(a=>a.EngineInfo).ToListAsync();
            string str = "<option value=\"\" selected>请选择推演模型...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\" data-model-type=\"{l.ModelType}\" data-engine-type=\"{l.EngineType}\">{l.ModelName}</option>";
            }
            return str;
        }


        [DisableAuditing]
        public async Task<string> GetEngineModelTypeSelectStr()
        {
            string str = "<option value=\"\" selected>请选择推演模型...</option>";
            str += await StatesManager.GetSelectListStrAsync("Engine", "ModelType");
            return str;
        }

        [DisableAuditing]
        public async Task<string> GetEvalModelSelectStr()
        {
            var list = await EvalModelRepository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择评估模型...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.ModelName}</option>";
            }
            return str;
        }

        [DisableAuditing]
        public async Task<string> GetEvalTargetSelectStr()
        {
            var list = await EvalTargetRepository.GetAllListAsync();
            var tempParentNo = list.FirstOrDefault(a => a.ParentNo == null)?.Id ?? "";
            var str = "";
            foreach (var l in list)
            {
                var name = l.Name;
                var parentNo = l.ParentNo;
                var id = l.Id;
                if (l.ParentNo == null)
                {
                    parentNo = "0";
                    id = "";
                    name = "请选择评估指标";
                }
                else if (l.ParentNo == tempParentNo)
                {
                    parentNo = "";
                }
                str += $"<option parent=\"{parentNo}\" value=\"{id}\">{name}</option>";
            }
            return str;
        }

        [DisableAuditing]
        public async Task<string> GetEvalTargetTypeSelectStr()
        {
            string str = "<option value=\"\" selected>请选择指标类型...</option>";
            str += await StatesManager.GetSelectListStrAsync("Eval", "TargetType");
            return str;
        }


        #endregion 模型

        #region 环境资源配置

        [DisableAuditing]
        public async Task<List<SelectListItem>> GetEnvironmentSelectList()
        {
            var list = await EnvironRepository.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.ResourceName });
            }
            return sList;
        }

        [DisableAuditing]
        public async Task<string> GetEnvironmentSelectStr()
        {
            var list = await EnvironRepository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择环境资源...</option>";
            foreach (var l in list)
            {
                str += $"<option value=\"{l.Id}\">{l.ResourceName}</option>";
            }
            return str;
        }

        [DisableAuditing]
        public async Task<string> GetResourceTypeStr()
        {
            string str = "<option value=\"\" selected>请选择资源类型...</option>";
            str += await StatesManager.GetSelectListStrAsync("Resource", "Type");
            return str;
        }
        #endregion 模型

        #endregion SELECT

        /// <summary>
        /// 查询用户信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [DisableAuditing]
        public async Task<PagedResultDto<UserDto>> QueryUsers(IwbPagedRequestDto input)
        {
            var query = UserRepository.GetAll().Where(a => a.IsActive);
            query = ApplyFilter(query, input);
            var totalCount = await query.CountAsync();
            query = query.OrderBy(a => a.Id);
            query = query.Skip(input.SkipCount).Take(input.MaxResultCount);
            var entities = await query.ToListAsync();
            var dtoList = new PagedResultDto<UserDto>(totalCount, ObjectMapper.Map<List<UserDto>>(entities));
            return dtoList;
        }
        /// <summary>
        /// 查询情景信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [DisableAuditing]
        public async Task<PagedResultDto<SceneDto>> QueryScenes(IwbPagedRequestDto input)
        {
            var query = SceneRepository.GetAllIncluding(a=>a.SceneCategoryInfo);
            var search = input.SearchList?.FirstOrDefault(a => a.KeyWords.IsNotEmpty() && a.KeyField.ToLower() == "scenecategory");
            if (search != null)
            {
                query = query.Where(a => a.SceneCategoryInfo.CategoryPath.Contains(search.KeyWords));
                input.SearchList.Remove(search);
            }
            query = ApplyFilter(query, input);
            var totalCount = await query.CountAsync();
            query = query.OrderBy(a => a.Id);
            query = query.Skip(input.SkipCount).Take(input.MaxResultCount);
            var entities = await query.ToListAsync();
            var dtoList = new PagedResultDto<SceneDto>(totalCount, ObjectMapper.Map<List<SceneDto>>(entities));
            return dtoList;
        }
        /// <summary>
        /// 查询引导信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [DisableAuditing]
        public async Task<PagedResultDto<GuideDto>> QueryGuides(IwbPagedRequestDto input)
        {
            var query = GuideRepository.GetAll();
            query = ApplyFilter(query, input);
            var totalCount = await query.CountAsync();
            query = query.OrderBy(a => a.Id);
            query = query.Skip(input.SkipCount).Take(input.MaxResultCount);
            var entities = await query.ToListAsync();
            var dtoList = new PagedResultDto<GuideDto>(totalCount, ObjectMapper.Map<List<GuideDto>>(entities));
            return dtoList;
        }

        /// <summary>
        /// 根据编号查询情景流信息
        /// </summary>
        /// <param name="no"></param>
        /// <returns></returns>
        [DisableAuditing]
        public async Task<SceneFlowDto> QuerySceneFlowByNo(string no)
        {
            var entity = await SceneFlowRepository.FirstOrDefaultAsync(a => a.Id == no);
            return ObjectMapper.Map<SceneFlowDto>(entity);
        }

        /// <summary>
        /// 查询情景流信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [DisableAuditing]
        public async Task<PagedResultDto<SceneFlowDto>> QuerySceneFlows(IwbPagedRequestDto input)
        {
            var query = SceneFlowRepository.GetAllIncluding(a => a.SceneCategoryInfo);
            var search = input.SearchList?.FirstOrDefault(a => a.KeyWords.IsNotEmpty() && a.KeyField.ToLower() == "scenecategory");
            if (search != null)
            {
                query = query.Where(a => a.SceneCategoryInfo.CategoryPath.Contains(search.KeyWords));
                input.SearchList.Remove(search);
            }
            query = ApplyFilter(query, input);
            var totalCount = await query.CountAsync();
            query = query.OrderBy(a => a.Id);
            query = query.Skip(input.SkipCount).Take(input.MaxResultCount);
            var entities = await query.ToListAsync();
            
            var dtoList = new PagedResultDto<SceneFlowDto>(totalCount, ObjectMapper.Map<List<SceneFlowDto>>(entities));
            return dtoList;
        }

        /// <summary>
        /// 查询子目录
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [DisableAuditing]
        public async Task<List<JsTreeDto>> GetChildSceneCategory(EntityDto<string> input)
        {
            if (input.Id.IsEmpty() || input.Id == "#" || input.Id == "0")
            {
                input.Id = null;
            }
            var list = new List<JsTreeDto>();
            var children = await SceneCategoryRepository.GetAllListAsync(a => a.ParentNo == input.Id);
            if (children.Any())
            {
                foreach (var child in children)
                {
                    list.Add(new JsTreeDto()
                    {
                        Id = child.Id,
                        Text = child.CategoryName,
                        Children = (await SceneCategoryRepository.CountAsync(a => a.ParentNo == child.Id)) > 0
                    });
                }
            }

            return list;
        }

    }
}