netcore/src/Modularity/Extend/NCC.Extend/LqYcsdJsjService.cs

using NCC.Common.Core.Manager;
using NCC.Common.Enum;
using NCC.Common.Extension;
using NCC.Common.Filter;
using NCC.Dependency;
using NCC.DynamicApiController;
using NCC.FriendlyException;
using NCC.Extend.Interfaces.LqYcsdJsj;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Globalization;
using System.Linq;
using System.Threading.Tasks;
using NCC.Extend.Entitys.lq_ycsd_jsj;
using NCC.Extend.Entitys.lq_jinsanjiao_user;
using NCC.Extend.Entitys.lq_mdxx;
using NCC.Extend.Entitys.Dto.LqYcsdJsj;
using Yitter.IdGenerator;
using NCC.Common.Helper;
using NCC.JsonSerialization;
using NCC.Common.Model.NPOI;
using NCC.Common.Configuration;
using NCC.DataEncryption;
using NCC.ClayObject;
namespace NCC.Extend.LqYcsdJsj
{
    /// <summary>
    /// 金三角设定服务
    /// </summary>
    [ApiDescriptionSettings(Tag = "Extend",Name = "LqYcsdJsj", Order = 200)]
    [Route("api/Extend/[controller]")]
    public class LqYcsdJsjService : ILqYcsdJsjService, IDynamicApiController, ITransient
    {
        private readonly ISqlSugarRepository<LqYcsdJsjEntity> _lqYcsdJsjRepository;
        private readonly SqlSugarScope _db;
        private readonly IUserManager _userManager;
        /// <summary>
        /// 初始化一个<see cref="LqYcsdJsjService"/>类型的新实例
        /// </summary>
        public LqYcsdJsjService(
            ISqlSugarRepository<LqYcsdJsjEntity> lqYcsdJsjRepository,
            IUserManager userManager)
        {
            _lqYcsdJsjRepository = lqYcsdJsjRepository;            
            _db = _lqYcsdJsjRepository.Context;
            _userManager = userManager;
        }
        /// <summary>
        /// 获取金三角设定
        /// </summary>
        /// <param name="id">参数</param>
        /// <returns></returns>
        [HttpGet("{id}")]
        public async Task<dynamic> GetInfo(string id)
        {
            var entity = await _db.Queryable<LqYcsdJsjEntity>().FirstAsync(p => p.Id == id);
            var output = entity.Adapt<LqYcsdJsjInfoOutput>();
            return output;
        }
        /// <summary>
        /// 获取金三角设定详情（包含成员信息）
        /// </summary>
        /// <param name="id">金三角ID</param>
        /// <returns></returns>
        [HttpGet("{id}/detail")]
        public async Task<dynamic> GetDetail(string id)
        {
            var entity = await _db.Queryable<LqYcsdJsjEntity>().FirstAsync(p => p.Id == id);
            if (entity == null) throw NCCException.Oh(ErrorCode.COM1005);
            
            var output = entity.Adapt<LqYcsdJsjInfoOutput>();
            
            // 获取成员信息
            var members = await _db.Queryable<LqJinsanjiaoUserEntity>()
                .Where(x => x.JsjId == id && x.Status == "ACTIVE")
                .OrderBy(x => x.SortOrder)
                .Select(x => new
                {
                    id = x.Id,
                    userId = x.UserId,
                    userName = x.UserName,
                    isLeader = x.IsLeader,
                    sortOrder = x.SortOrder,
                    status = x.Status
                })
                .ToListAsync();
            
            return new
            {
                jsj = output,
                members = members
            };
        }
        /// <summary>
		/// 获取金三角设定列表
		/// </summary>
		/// <param name="input">请求参数</param>
		/// <returns></returns>
        [HttpGet("")]
        public async Task<dynamic> GetList([FromQuery] LqYcsdJsjListQueryInput input)
        {
            var sidx = input.sidx == null ? "id" : input.sidx;
            var data = await _db.Queryable<LqYcsdJsjEntity>()
                .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                .WhereIF(!string.IsNullOrEmpty(input.yf), p => p.Yf.Contains(input.yf))
                .WhereIF(!string.IsNullOrEmpty(input.md), p => p.Md.Contains(input.md))
                .WhereIF(!string.IsNullOrEmpty(input.jsj), p => p.Jsj.Contains(input.jsj))
                .Select(it=> new LqYcsdJsjListOutput
                {
                    id = it.Id,
                    yf = it.Yf,
                    md = it.Md,
                    jsj = it.Jsj
                }).MergeTable().OrderBy(sidx+" "+input.sort).ToPagedListAsync(input.currentPage, input.pageSize);
                return PageResult<LqYcsdJsjListOutput>.SqlSugarPageResult(data);
        }
        /// <summary>
        /// 新建金三角
        /// </summary>
        /// <param name="input">参数</param>
        /// <returns></returns>
        [HttpPost("")]
        public async Task Create([FromBody] LqYcsdJsjCrInput input)
        {
            var userInfo = await _userManager.GetUserInfo();
            
            // 参数验证
            if (string.IsNullOrEmpty(input.yf))
                throw NCCException.Oh(ErrorCode.COM1000, "月份不能为空");
            if (string.IsNullOrEmpty(input.md))
                throw NCCException.Oh(ErrorCode.COM1000, "门店不能为空");
            if (string.IsNullOrEmpty(input.jsj))
                throw NCCException.Oh(ErrorCode.COM1000, "金三角名称不能为空");
            
            // 验证月份格式
            if (!DateTime.TryParseExact(input.yf, "yyyyMM", null, DateTimeStyles.None, out _))
            {
                throw NCCException.Oh(ErrorCode.COM1000, "月份格式必须为yyyyMM");
            }
            
            // 验证多人战队必须有顾问
            if (input.members != null && input.members.Count >= 2)
            {
                var hasLeader = input.members.Any(m => m.isLeader == 1);
                if (!hasLeader)
                {
                    throw NCCException.Oh(ErrorCode.COM1000, "两人或两人以上的战队必须有一个顾问");
                }
            }
            
            // 验证金三角名称是否已存在
            var existingJsj = await _db.Queryable<LqYcsdJsjEntity>()
                .Where(x => x.Yf == input.yf && x.Md == input.md && x.Jsj == input.jsj)
                .FirstAsync();
            if (existingJsj != null)
            {
                throw NCCException.Oh(ErrorCode.COM1000, "该门店该月份已存在同名金三角");
            }
            try
            {
                // 开启事务
                _db.BeginTran();
                // 1. 创建门店T区（如果不存在）
                await CreateOrUpdateStoreTArea(input.yf, input.md, userInfo.userId);
                // 2. 创建金三角基础信息
                var entity = input.Adapt<LqYcsdJsjEntity>();
                entity.Id = YitIdHelper.NextId().ToString();
                var isOk = await _db.Insertable(entity).IgnoreColumns(ignoreNullColumn: true).ExecuteCommandAsync();
                if (!(isOk > 0)) throw NCCException.Oh(ErrorCode.COM1000);
                // 3. 创建金三角成员绑定关系
                if (input.members != null && input.members.Count > 0)
                {
                    await CreateJsjMembers(entity.Id, input.members, userInfo.userId);
                }
                // 4. 创建站点战队T区（如果金三角不是T区）
                if (!input.jsj.EndsWith("T区"))
                {
                    await CreateOrUpdateTeamTArea(input.yf, input.jsj, input.md, userInfo.userId);
                }
                // 提交事务
                _db.CommitTran();
            }
            catch (Exception ex)
            {
                // 回滚事务
                _db.RollbackTran();
                throw NCCException.Oh(ErrorCode.COM1000, ex.Message);
            }
        }
        /// <summary>
		/// 获取金三角设定无分页列表
		/// </summary>
		/// <param name="input">请求参数</param>
		/// <returns></returns>
        [NonAction]
        public async Task<dynamic> GetNoPagingList([FromQuery] LqYcsdJsjListQueryInput input)
        {
            var sidx = input.sidx == null ? "id" : input.sidx;
            var data = await _db.Queryable<LqYcsdJsjEntity>()
                .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                .WhereIF(!string.IsNullOrEmpty(input.yf), p => p.Yf.Contains(input.yf))
                .WhereIF(!string.IsNullOrEmpty(input.md), p => p.Md.Contains(input.md))
                .WhereIF(!string.IsNullOrEmpty(input.jsj), p => p.Jsj.Contains(input.jsj))
                .Select(it=> new LqYcsdJsjListOutput
                {
                    id = it.Id,
                    yf = it.Yf,
                    md = it.Md,
                    jsj = it.Jsj
                }).MergeTable().OrderBy(sidx+" "+input.sort).ToListAsync();
                return data;
        }
        /// <summary>
		/// 导出金三角设定
		/// </summary>
		/// <param name="input">请求参数</param>
		/// <returns></returns>
        [HttpGet("Actions/Export")]
        public async Task<dynamic> Export([FromQuery] LqYcsdJsjListQueryInput input)
        {
            var userInfo = await _userManager.GetUserInfo();
            var exportData = new List<LqYcsdJsjListOutput>();
            if (input.dataType == 0)
            {
                var data = Clay.Object(await this.GetList(input));
                exportData = data.Solidify<PageResult<LqYcsdJsjListOutput>>().list;
            }
            else
            {
                exportData = await this.GetNoPagingList(input);
            }
            List<ParamsModel> paramList = "[{\"value\":\"主键\",\"field\":\"id\"},{\"value\":\"月份\",\"field\":\"yf\"},{\"value\":\"门店\",\"field\":\"md\"},{\"value\":\"金三角\",\"field\":\"jsj\"}]".ToList<ParamsModel>();           
            ExcelConfig excelconfig = new ExcelConfig();
            excelconfig.FileName = "金三角设定.xls";
            excelconfig.HeadFont = "微软雅黑";
            excelconfig.HeadPoint = 10;
            excelconfig.IsAllSizeColumn = true;
            excelconfig.ColumnModel = new List<ExcelColumnModel>();
            List<string> selectKeyList = input.selectKey.Split(',').ToList();
            foreach (var item in selectKeyList)
            {
                var isExist = paramList.Find(p => p.field == item);
                if (isExist != null)
                {
                    excelconfig.ColumnModel.Add(new ExcelColumnModel() { Column = isExist.field, ExcelColumn = isExist.value });
                }
            }
            var addPath = FileVariable.TemporaryFilePath + excelconfig.FileName;
            ExcelExportHelper<LqYcsdJsjListOutput>.Export(exportData, excelconfig, addPath);
            var fileName = _userManager.UserId + "|" + addPath + "|xls";
            var output = new
            {
                name = excelconfig.FileName,
                url = "/api/File/Download?encryption=" + DESCEncryption.Encrypt(fileName, "NCC")
            };
            return output;
        }
        /// <summary>
        /// 批量删除金三角设定
        /// </summary>
        /// <param name="ids">主键数组</param>
        /// <returns></returns>
        [HttpPost("batchRemove")]
        public async Task BatchRemove([FromBody] List<string> ids)
        {
            var entitys = await _db.Queryable<LqYcsdJsjEntity>().In(it => it.Id, ids).ToListAsync();
            if (entitys.Count > 0)
            {
                try
                {
                    //开启事务
                    _db.BeginTran();
                    //批量删除金三角设定
                    await _db.Deleteable<LqYcsdJsjEntity>().In(d => d.Id,ids).ExecuteCommandAsync();
                    //关闭事务
                    _db.CommitTran();
                }
                catch (Exception)
                {
                    //回滚事务
                    _db.RollbackTran();
                    throw NCCException.Oh(ErrorCode.COM1002);
                }
            }
        }
        /// <summary>
        /// 更新金三角设定
        /// </summary>
        /// <param name="id">主键</param>
        /// <param name="input">参数</param>
        /// <returns></returns>
        [HttpPut("{id}")]
        public async Task Update(string id, [FromBody] LqYcsdJsjUpInput input)
        {
            var entity = input.Adapt<LqYcsdJsjEntity>();
            var isOk = await _db.Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
            if (!(isOk > 0)) throw NCCException.Oh(ErrorCode.COM1001);
        }
        /// <summary>
        /// 删除金三角设定
        /// </summary>
        /// <returns></returns>
        [HttpDelete("{id}")]
        public async Task Delete(string id)
        {
            var entity = await _db.Queryable<LqYcsdJsjEntity>().FirstAsync(p => p.Id == id);
            _ = entity ?? throw NCCException.Oh(ErrorCode.COM1005);
            var isOk = await _db.Deleteable<LqYcsdJsjEntity>().Where(d => d.Id == id).ExecuteCommandAsync();
            if (!(isOk > 0)) throw NCCException.Oh(ErrorCode.COM1002);
        }
        #region 私有辅助方法
        /// <summary>
        /// 创建或更新门店T区
        /// </summary>
        /// <param name="yf">月份</param>
        /// <param name="mdId">门店ID</param>
        /// <param name="creatorUserId">创建人ID</param>
        /// <returns></returns>
        private async Task CreateOrUpdateStoreTArea(string yf, string mdId, string creatorUserId)
        {
            // 获取门店名称
            var storeName = await GetStoreNameById(mdId);
            var tAreaName = $"{storeName}T区";
            
            // 检查该门店该月份是否已有T区
            var existingTArea = await _db.Queryable<LqYcsdJsjEntity>()
                .Where(x => x.Yf == yf && x.Md == mdId && x.Jsj == tAreaName)
                .FirstAsync();
            
            if (existingTArea == null)
            {
                // 创建门店T区
                var tAreaEntity = new LqYcsdJsjEntity
                {
                    Id = YitIdHelper.NextId().ToString(),
                    Yf = yf,
                    Md = mdId,
                    Jsj = tAreaName
                };
                
                await _db.Insertable(tAreaEntity).ExecuteCommandAsync();
            }
        }
        /// <summary>
        /// 创建或更新战队T区
        /// </summary>
        /// <param name="yf">月份</param>
        /// <param name="teamName">战队名称</param>
        /// <param name="mdId">门店ID</param>
        /// <param name="creatorUserId">创建人ID</param>
        /// <returns></returns>
        private async Task CreateOrUpdateTeamTArea(string yf, string teamName, string mdId, string creatorUserId)
        {
            var tAreaName = $"{teamName}T区";
            
            // 检查该战队该月份是否已有T区
            var existingTArea = await _db.Queryable<LqYcsdJsjEntity>()
                .Where(x => x.Yf == yf && x.Md == mdId && x.Jsj == tAreaName)
                .FirstAsync();
            
            if (existingTArea == null)
            {
                // 创建战队T区
                var tAreaEntity = new LqYcsdJsjEntity
                {
                    Id = YitIdHelper.NextId().ToString(),
                    Yf = yf,
                    Md = mdId,
                    Jsj = tAreaName
                };
                
                await _db.Insertable(tAreaEntity).ExecuteCommandAsync();
            }
        }
        /// <summary>
        /// 创建金三角成员绑定关系
        /// </summary>
        /// <param name="jsjId">金三角ID</param>
        /// <param name="members">成员列表</param>
        /// <param name="creatorUserId">创建人ID</param>
        /// <returns></returns>
        private async Task CreateJsjMembers(string jsjId, List<JsjMemberInput> members, string creatorUserId)
        {
            var memberEntities = new List<LqJinsanjiaoUserEntity>();
            
            for (int i = 0; i < members.Count; i++)
            {
                var member = members[i];
                var memberEntity = new LqJinsanjiaoUserEntity
                {
                    Id = YitIdHelper.NextId().ToString(),
                    JsjId = jsjId,
                    UserId = member.userId,
                    UserName = member.userName,
                    IsLeader = member.isLeader,
                    Status = "ACTIVE",
                    SortOrder = member.sortOrder > 0 ? member.sortOrder : i + 1,
                    CreatorTime = DateTime.Now,
                    CreatorUserId = creatorUserId,
                    DeleteMark = 0
                };
                
                memberEntities.Add(memberEntity);
            }
            
            if (memberEntities.Count > 0)
            {
                await _db.Insertable(memberEntities).ExecuteCommandAsync();
            }
        }
        /// <summary>
        /// 根据门店ID获取门店名称
        /// </summary>
        /// <param name="mdId">门店ID</param>
        /// <returns></returns>
        private async Task<string> GetStoreNameById(string mdId)
        {
            try
            {
                var storeName = await _db.Queryable<LqMdxxEntity>()
                    .Where(x => x.Id == mdId)
                    .Select(x => x.Dm)
                    .FirstAsync();
                return string.IsNullOrEmpty(storeName) ? "未知门店" : storeName;
            }
            catch
            {
                return "未知门店";
            }
        }
        #endregion
    }
}