using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using NCC.Common.Core.Manager;
using NCC.Common.Filter;
using NCC.Dependency;
using NCC.DynamicApiController;
using NCC.Extend.Entitys.Dto.LqEvent;
using NCC.Extend.Entitys.Dto.LqEventUser;
using NCC.Extend.Entitys.lq_event;
using NCC.Extend.Entitys.lq_eventuser;
using NCC.Extend.Interfaces.LqEvent;
using NCC.FriendlyException;
using SqlSugar;
using Yitter.IdGenerator;

namespace NCC.Extend.LqEvent
{
    /// <summary>
    /// 拓客活动服务
    /// </summary>
    [ApiDescriptionSettings(Tag = "绿纤拓客活动服务", Name = "LqEvent", Order = 200)]
    [Route("api/Extend/[controller]")]
    [ApiController]
    public class LqEventService : ILqEventService, IDynamicApiController, ITransient
    {
        private readonly ISqlSugarClient _db;
        private readonly IUserManager _userManager;

        /// <summary>
        /// 初始化一个<see cref="LqEventService"/>类型的新实例
        /// </summary>
        /// <param name="db">数据库</param>
        /// <param name="userManager">用户管理</param>
        public LqEventService(ISqlSugarClient db, IUserManager userManager)
        {
            _db = db;
            _userManager = userManager;
        }

        #region 获取拓客活动列表
        /// <summary>
        /// 获取拓客活动列表
        /// </summary>
        /// <remarks>
        /// 分页查询拓客活动列表，支持多条件筛选和排序。
        /// 返回结果包含每个活动的成员数量统计。
        ///
        /// 示例请求：
        /// GET /api/Extend/LqEvent?page=1&amp;rows=10&amp;sidx=Id&amp;sord=desc&amp;eventName=春节拓客活动
        ///
        /// 支持的条件筛选：
        /// - 活动名称模糊查询
        /// - 活动编号模糊查询
        /// - 活动负责人模糊查询
        /// - 开始时间范围查询
        /// - 结束时间范围查询
        ///
        /// 支持的排序字段：
        /// - Id: 活动ID
        /// - EventName: 活动名称
        /// - EventNumber: 活动编号
        /// - EventCoordinator: 活动负责人
        /// - StartTime: 开始时间
        /// - EndTime: 结束时间
        /// </remarks>
        /// <param name="input">查询参数</param>
        /// <returns>分页的拓客活动列表，包含成员数量统计</returns>
        [HttpGet("")]
        public async Task<dynamic> GetList([FromQuery] LqEventListQueryInput input)
        {
            var sidx = input.sidx == null ? "id" : input.sidx;
            var sord = input.sord == null ? "desc" : input.sord;
            // 先查询活动列表
            var Data = await _db.Queryable<LqEventEntity>()
                .WhereIF(!string.IsNullOrEmpty(input.EventName), e => e.EventName.Contains(input.EventName))
                .WhereIF(!string.IsNullOrEmpty(input.EventNumber), e => e.EventNumber.Contains(input.EventNumber))
                .Select(e => new LqEventListOutput
                {
                    id = e.Id,
                    eventName = e.EventName,
                    startTime = e.StartTime,
                    endTime = e.EndTime,
                    eventCoordinator = e.EventCoordinator,
                    eventNumber = e.EventNumber,
                    memberCount = SqlFunc.Subqueryable<LqEventUserEntity>().Where(u => u.EventId == e.Id).Count(),
                })
                .MergeTable()
                .OrderBy(sidx + " " + sord)
                .ToPagedListAsync(input.page, input.rows);
            return PageResult<LqEventListOutput>.SqlSugarPageResult(Data);
        }
        #endregion

        #region 获取拓客活动详情

        /// <summary>
        /// 获取拓客活动详情
        /// </summary>
        /// <remarks>
        /// 根据活动ID获取拓客活动的详细信息，包括基础信息和所有参与成员列表。
        ///
        /// 示例请求：
        /// GET /api/Extend/LqEvent/1234567890123456789
        ///
        /// 返回数据包含：
        /// - 活动基础信息（ID、名称、编号、负责人、开始时间、结束时间）
        /// - 成员列表（用户ID、部门ID、战队名称、创建时间、创建用户）
        ///
        /// 如果活动不存在，将返回404错误。
        /// </remarks>
        /// <param name="id">拓客活动ID</param>
        /// <returns>拓客活动详情，包含成员信息</returns>
        /// <response code="200">成功返回拓客活动详情</response>
        /// <response code="404">拓客活动不存在</response>
        /// <response code="500">服务器内部错误</response>
        [HttpGet("{id}")]
        public async Task<dynamic> GetInfo(string id)
        {
            // 1. 获取拓客活动基本信息
            var entity = await _db.Queryable<LqEventEntity>().FirstAsync(p => p.Id == id);
            if (entity == null)
            {
                throw NCCException.Oh("拓客活动不存在");
            }

            var output = entity.Adapt<LqEventInfoOutput>();

            // 2. 获取拓客活动成员信息
            var members = await _db.Queryable<LqEventUserEntity>().Where(u => u.EventId == id.ToString()).ToListAsync();

            // 3. 转换为输出格式
            output.Members = members.Adapt<List<LqEventUserInfoOutput>>();

            return output;
        }
        #endregion

        #region 创建拓客活动
        /// <summary>
        /// 创建拓客活动
        /// </summary>
        /// <remarks>
        /// 创建新的拓客活动，可以同时添加参与成员。
        /// 系统会自动生成活动ID，并记录创建用户信息。
        ///
        /// 示例请求：
        /// POST /api/Extend/LqEvent
        /// Content-Type: application/json
        ///
        /// ```json
        /// {
        ///   "eventName": "春节拓客活动",
        ///   "eventNumber": "TK2024001",
        ///   "eventCoordinator": "张三",
        ///   "startTime": "2024-01-15T09:00:00",
        ///   "endTime": "2024-01-20T18:00:00",
        ///   "members": [
        ///     {
        ///       "userId": "user001",
        ///       "depId": "dept001",
        ///       "teamName": "第一战队"
        ///     },
        ///     {
        ///       "userId": "user002",
        ///       "depId": "dept001",
        ///       "teamName": "第二战队"
        ///     }
        ///   ]
        /// }
        /// ```
        ///
        /// 参数验证：
        /// - eventName: 必填，最大长度255字符
        /// - eventNumber: 可选，最大长度255字符
        /// - eventCoordinator: 可选，最大长度255字符
        /// - members: 可选，成员列表
        ///   - userId: 必填
        ///   - depId: 可选
        ///   - teamName: 可选
        ///
        /// 创建流程：
        /// 1. 生成新的活动ID
        /// 2. 插入拓客活动记录
        /// 3. 插入成员记录（如果有）
        /// </remarks>
        /// <param name="input">创建参数</param>
        /// <returns>无返回值</returns>
        [HttpPost("")]
        public async Task Create([FromBody] LqEventCrInput input)
        {
            var userInfo = await _userManager.GetUserInfo();
            var entity = input.Adapt<LqEventEntity>();

            // 生成新的ID
            entity.Id = YitIdHelper.NextId().ToString();

            // 插入拓客活动
            var isOk = await _db.Insertable(entity).ExecuteCommandAsync();
            if (!(isOk > 0))
                throw NCCException.Oh("创建拓客活动失败");

            // 插入拓客活动成员
            if (input.Members != null && input.Members.Count > 0)
            {
                var memberEntities = new List<LqEventUserEntity>();
                foreach (var member in input.Members)
                {
                    memberEntities.Add(
                        new LqEventUserEntity
                        {
                            Id = YitIdHelper.NextId().ToString(),
                            EventId = entity.Id.ToString(),
                            UserId = member.UserId,
                            DepId = member.DepId,
                            TeamName = member.TeamName,
                            CreationTime = DateTime.Now,
                            CreationUser = userInfo?.userName,
                        }
                    );
                }

                await _db.Insertable(memberEntities).ExecuteCommandAsync();
            }
        }
        #endregion

        #region 更新拓客活动
        /// <summary>
        /// 更新拓客活动
        /// </summary>
        /// <remarks>
        /// 更新拓客活动信息，包括基础信息和成员列表。
        /// 更新时会先删除原有成员，再添加新成员。
        ///
        /// 示例请求：
        /// PUT /api/Extend/LqEvent
        /// Content-Type: application/json
        ///
        /// ```json
        /// {
        ///   "id": "1234567890123456789",
        ///   "eventName": "春节拓客活动（更新）",
        ///   "eventNumber": "TK2024001",
        ///   "eventCoordinator": "李四",
        ///   "startTime": "2024-01-15T09:00:00",
        ///   "endTime": "2024-01-25T18:00:00",
        ///   "members": [
        ///     {
        ///       "userId": "user003",
        ///       "depId": "dept002",
        ///       "teamName": "精英战队"
        ///     }
        ///   ]
        /// }
        /// ```
        ///
        /// 参数验证：
        /// - id: 必填，拓客活动ID
        /// - eventName: 必填，最大长度255字符
        /// - eventNumber: 可选，最大长度255字符
        /// - eventCoordinator: 可选，最大长度255字符
        /// - members: 可选，成员列表（为空则清空所有成员）
        ///
        /// 更新流程：
        /// 1. 更新拓客活动记录
        /// 2. 删除原有成员记录
        /// 3. 插入新成员记录（如果有）
        /// </remarks>
        /// <param name="input">更新参数</param>
        /// <returns>无返回值</returns>
        /// <response code="200">拓客活动更新成功</response>
        /// <response code="400">请求参数错误或验证失败</response>
        /// <response code="404">拓客活动不存在</response>
        /// <response code="500">服务器内部错误</response>
        [HttpPut("")]
        public async Task Update([FromBody] LqEventUpInput input)
        {
            var userInfo = await _userManager.GetUserInfo();
            var entity = input.Adapt<LqEventEntity>();

            // 更新拓客活动
            var isOk = await _db.Updateable(entity).ExecuteCommandAsync();
            if (!(isOk > 0))
                throw NCCException.Oh("更新拓客活动失败");

            // 删除原有成员
            await _db.Deleteable<LqEventUserEntity>().Where(u => u.EventId == entity.Id.ToString()).ExecuteCommandAsync();

            // 插入新成员
            if (input.Members != null && input.Members.Count > 0)
            {
                var memberEntities = new List<LqEventUserEntity>();
                foreach (var member in input.Members)
                {
                    memberEntities.Add(
                        new LqEventUserEntity
                        {
                            Id = YitIdHelper.NextId().ToString(),
                            EventId = entity.Id.ToString(),
                            UserId = member.UserId,
                            DepId = member.DepId,
                            TeamName = member.TeamName,
                            CreationTime = DateTime.Now,
                            CreationUser = userInfo?.userName,
                        }
                    );
                }

                await _db.Insertable(memberEntities).ExecuteCommandAsync();
            }
        }
        #endregion

        #region 删除拓客活动
        /// <summary>
        /// 删除拓客活动
        /// </summary>
        /// <remarks>
        /// 删除指定的拓客活动，会同时删除该活动的所有成员记录。
        /// 删除操作不可恢复，请谨慎使用。
        ///
        /// 示例请求：
        /// DELETE /api/Extend/LqEvent/1234567890123456789
        ///
        /// 删除顺序：
        /// 1. 先删除所有相关成员记录
        /// 2. 再删除拓客活动记录
        ///
        /// 注意事项：
        /// - 删除操作不可恢复
        /// - 会级联删除所有相关成员记录
        /// - 如果活动不存在，将返回404错误
        /// - 建议在删除前先查询确认活动信息
        /// </remarks>
        /// <param name="id">拓客活动ID</param>
        /// <returns>无返回值</returns>
        /// <response code="200">拓客活动删除成功</response>
        /// <response code="404">拓客活动不存在</response>
        /// <response code="500">服务器内部错误</response>
        [HttpDelete("{id}")]
        public async Task Delete(string id)
        {
            // 删除拓客活动成员
            await _db.Deleteable<LqEventUserEntity>().Where(u => u.EventId == id.ToString()).ExecuteCommandAsync();

            // 删除拓客活动
            var isOk = await _db.Deleteable<LqEventEntity>().Where(p => p.Id == id).ExecuteCommandAsync();

            if (!(isOk > 0))
                throw NCCException.Oh("删除拓客活动失败");
        }
        #endregion

        #region 更新拓客目标数量
        /// <summary>
        /// 更新拓客目标数量
        /// </summary>
        /// <param name="id">拓客活动ID</param>
        /// <param name="target">拓客目标数量</param>
        /// <returns></returns>
        [HttpPut("{id}/target")]
        public async Task UpdateTarget(string id, int target)
        {
            var isOk = await _db.Updateable<LqEventUserEntity>().SetColumns(it => new LqEventUserEntity { EventTarget = target }).Where(x => x.EventId == id).ExecuteCommandAsync();
            if (!(isOk > 0))
                throw NCCException.Oh("更新拓客目标数量失败");
        }
        #endregion

        #region 获取拓客目标数量
        /// <summary>
        /// 获取拓客目标数量
        /// </summary>
        /// <param name="id">拓客活动ID</param>
        /// <returns></returns>
        [HttpGet("{id}/target")]
        public async Task<int> GetTarget(string id)
        {
            return await _db.Queryable<LqEventUserEntity>().Where(x => x.EventId == id).Select(x => x.EventTarget).FirstAsync();
        }
        #endregion

        #region 根据用户ID获取参与的拓客活动

        /// <summary>
        /// 根据用户ID获取参与的拓客活动
        /// </summary>
        /// <remarks>
        /// 根据用户ID查询该用户参与的所有拓客活动，支持时间范围筛选。
        /// 返回结果包含活动基础信息和用户在该活动中的详细信息。
        ///
        /// 示例请求：
        /// GET /api/Extend/LqEvent/user/user001?startTime=2024-01-01&amp;endTime=2024-12-31
        ///
        /// 参数说明：
        /// - userId: 用户ID（必填）
        /// - startTime: 开始时间（可选），查询在此时间之后开始的活动
        /// - endTime: 结束时间（可选），查询在此时间之前结束的活动
        ///
        /// 返回数据包含：
        /// - 活动基础信息（ID、名称、编号、负责人、开始时间、结束时间）
        /// - 用户参与信息（部门ID、战队名称、目标数量等）
        /// </remarks>
        /// <param name="userId">用户ID</param>
        /// <param name="startTime">开始时间（可选）</param>
        /// <param name="endTime">结束时间（可选）</param>
        /// <returns>用户参与的拓客活动列表</returns>
        /// <response code="200">成功返回用户参与的拓客活动列表</response>
        /// <response code="400">请求参数错误</response>
        /// <response code="500">服务器内部错误</response>
        [HttpGet("user/{userId}")]
        [ProducesResponseType(typeof(List<LqEventUserEventOutput>), 200)]
        [ProducesResponseType(400)]
        [ProducesResponseType(500)]
        public async Task<List<LqEventUserEventOutput>> GetUserEvents(string userId, [FromQuery] DateTime? startTime = null, [FromQuery] DateTime? endTime = null)
        {
            try
            {
                // 先测试简单的查询
                var eventUsers = await _db.Queryable<LqEventUserEntity>().Where(u => u.UserId == userId).ToListAsync();

                if (!eventUsers.Any())
                {
                    return new List<LqEventUserEventOutput>();
                }

                var eventIds = eventUsers.Select(u => u.EventId).ToList();

                // 查询活动信息
                var events = await _db.Queryable<LqEventEntity>().Where(e => eventIds.Contains(e.Id)).ToListAsync();

                // 时间范围筛选
                if (startTime.HasValue)
                {
                    events = events.Where(e => e.StartTime >= startTime.Value).ToList();
                }

                if (endTime.HasValue)
                {
                    events = events.Where(e => e.EndTime <= endTime.Value).ToList();
                }

                // 构建结果
                var result = new List<LqEventUserEventOutput>();
                foreach (var eventUser in eventUsers)
                {
                    var eventInfo = events.FirstOrDefault(e => e.Id == eventUser.EventId);
                    if (eventInfo != null)
                    {
                        result.Add(
                            new LqEventUserEventOutput
                            {
                                // 活动基础信息
                                EventId = eventInfo.Id,
                                EventName = eventInfo.EventName,
                                EventNumber = eventInfo.EventNumber,
                                EventCoordinator = eventInfo.EventCoordinator,
                                StartTime = eventInfo.StartTime,
                                EndTime = eventInfo.EndTime,
                                // 用户参与信息
                                UserId = eventUser.UserId,
                                DepId = eventUser.DepId,
                                TeamName = eventUser.TeamName,
                                EventTarget = eventUser.EventTarget,
                                CreationTime = eventUser.CreationTime,
                                CreationUser = eventUser.CreationUser,
                            }
                        );
                    }
                }

                // 按开始时间降序排列
                return result.OrderByDescending(x => x.StartTime).ToList();
            }
            catch (Exception ex)
            {
                throw NCCException.Oh("获取用户参与的拓客活动失败", ex);
            }
        }
        #endregion
    }
}