OA2023/OASystem/OASystem.Api/Controllers/BusinessController.cs

using OASystem.API.OAMethodLib;
using OASystem.API.OAMethodLib.ALiYun;
using OASystem.API.OAMethodLib.ExcelOutput;
using OASystem.Domain.AesEncryption;
using OASystem.Domain.Dtos.Business;
using OASystem.Domain.Dtos.CRM;
using OASystem.Domain.Dtos.FileDto;
using OASystem.Domain.Dtos.Financial;
using OASystem.Domain.Dtos.Groups;
using OASystem.Domain.Entities.Business;
using OASystem.Domain.Entities.Customer;
using OASystem.Domain.Entities.Groups;
using OASystem.Domain.ViewModels.Business;
using OASystem.Domain.ViewModels.CRM;
using OASystem.Domain.ViewModels.Groups;
using OASystem.Infrastructure.Repositories.Business;
using OASystem.Infrastructure.Repositories.CRM;
using OASystem.Infrastructure.Repositories.Groups;

namespace OASystem.API.Controllers
{
    /// <summary>
    /// 通用业务操作
    /// </summary>
    [Route("api/[controller]/[action]")]
    public class BusinessController : ControllerBase
    {
        private readonly IMapper _mapper;
        private readonly CommonBusRepository _busRep;
        private readonly SetDataRepository _setDataRep;
        private readonly DelegationInfoRepository _groupRep;
        private readonly TeamRateRepository _teamRateRep;
        private readonly TableOperationRecordRepository _TableOperationRecordRep;

        public BusinessController(IMapper mapper, CommonBusRepository busRep, SetDataRepository setDataRep, DelegationInfoRepository groupRep, TeamRateRepository teamRateRep,
            TableOperationRecordRepository tableOperationRecordRep)
        {
            _mapper = mapper;
            _busRep = busRep;
            _setDataRep = setDataRep;
            _groupRep = groupRep;
            _teamRateRep = teamRateRep;
            _TableOperationRecordRep = tableOperationRecordRep;
        }

        #region 团组信息 
        /// <summary>
        ///  团组信息 
        ///  团组简略详情 
        /// </summary>
        /// <param name="dto">团组info请求dto</param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostShareGroupInfo(ShareGroupInfoDto dto)
        {
            return Ok(await _groupRep.PostShareGroupInfo(dto));
        }

        /// <summary>
        /// 团组信息 团组名称 List
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GetGroupNameList(GroupNameDto dto)
        {
            return Ok(await _groupRep.GetGroupNameList(dto));
        }

        /// <summary>
        /// 团组信息 团组名称 Page List
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostGroupNameScreen(GroupNameScreenDto dto)
        {
            //验证
            var validator = new GroupNameScreenDtoFoaValidator();
            var validatorRes = await validator.ValidateAsync(dto);
            if (!validatorRes.IsValid)
            {
                var errors = new StringBuilder();
                foreach (var error in validatorRes.Errors) errors.AppendLine(error.ErrorMessage);
                return Ok(JsonView(false, errors.ToString()));
            }

            //获取数据
            var res = await _groupRep.GetGroupNameList(dto.PortType, dto.PageIndex, dto.PageSize, dto.groupName, dto.userId);

            return Ok(res);
        }

        /// <summary>
        /// 获取团组指向分类
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostGroupDirectionalClassificationInit()
        {
            var result = new Result();
            result = await _setDataRep.GetSetDataBySTId(_setDataRep, 16); //团组指向分类
            if (result.Code != 0)
            {
                return Ok(JsonView(false, "获取失败!"));
            }

            List<SetDataInfoView> _view1 = JsonConvert.DeserializeObject<List<SetDataInfoView>>(JsonConvert.SerializeObject(result.Data));

            var xc_view = new SetDataInfoView();//77	行程 //移除行程
            xc_view = _view1.Where(it => it.Id == 77).FirstOrDefault();
            if (xc_view != null) { _view1.Remove(xc_view); };

           var _view = new List<SetDataInfoView>();
            //_view.Insert(0, new SetDataInfoView { Id = -1, Name = "所有模块" });

            var qz_view = new SetDataInfoView();//80	签证
            qz_view = _view1.Where(it => it.Id == 80).FirstOrDefault();
            if (qz_view != null) { _view.Insert(0, qz_view); _view1.Remove(qz_view); };

            var jpyd_view = new SetDataInfoView();//85	机票预订
            jpyd_view = _view1.Where(it => it.Id == 85).FirstOrDefault();
            if (jpyd_view != null) { _view.Insert(1, jpyd_view); _view1.Remove(jpyd_view); };

            var jdyd_view = new SetDataInfoView();//76	酒店预订
            jdyd_view = _view1.Where(it => it.Id == 76).FirstOrDefault();
            if (jdyd_view != null) { _view.Insert(2, jdyd_view); _view1.Remove(jdyd_view); };

            var jdzc_view = new SetDataInfoView();//751	酒店早餐
            jdzc_view = _view1.Where(it => it.Id == 751).FirstOrDefault();
            if (jdzc_view != null)
            {
                _view1.Remove(jdzc_view);
                //_view.Insert(3, jdzc_view); _view1.Remove(jdzc_view);
            };

            var cdy_view = new SetDataInfoView();//79	车/导游地接
            cdy_view = _view1.Where(it => it.Id == 79).FirstOrDefault();
            if (cdy_view != null) { _view.Insert(3, cdy_view); _view1.Remove(cdy_view); }
            ;

            var yqgw_view = new SetDataInfoView();//81	邀请/公务活动
            yqgw_view = _view1.Where(it => it.Id == 81).FirstOrDefault();
            if (yqgw_view != null) { _view.Insert(4, yqgw_view); _view1.Remove(yqgw_view); }
            ;

            var bx_view = new SetDataInfoView();//82	团组客户保险
            bx_view = _view1.Where(it => it.Id == 82).FirstOrDefault();
            if (bx_view != null) { _view.Insert(5, bx_view); _view1.Remove(bx_view); }
            ;

            var qtkx_view = new SetDataInfoView();//98	其他款项
            qtkx_view = _view1.Where(it => it.Id == 98).FirstOrDefault();
            if (qtkx_view != null) { _view.Insert(6, qtkx_view); _view1.Remove(qtkx_view); }
            ;

            var skth_view = new SetDataInfoView();//285	收款退还与其他款项
            skth_view = _view1.Where(it => it.Id == 285).FirstOrDefault();
            if (skth_view != null) { _view.Insert(7, skth_view); _view1.Remove(skth_view); }
            ;

            if (_view1.Count > 0)
            {
                _view.AddRange(_view1);
            }

            return Ok(JsonView(_view));
        }

        /// <summary>
        /// 查询团组简略详情列表
        /// Page 根据Ctable And User 返回可操作的团
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostGroupListByCTableAndUserId(GroupListByCTableAndUserIdDto dto)
        {
            return Ok(await _groupRep.ListByCTableAndUserId(dto));
        }

        #endregion

        #region 接团客户名单 2026版

        /// <summary>
        /// 接团客户名单 2026版
        /// 根据团组Id查询客户信息
        /// </summary>
        /// <param name="groupId"></param>
        /// <returns></returns>
        [HttpGet("/api/group/client/list/{groupId}")]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> GetTourClientListByDiId(int groupId)
        {
            if (groupId < 1) return Ok(JsonView(false, "请传入有效的团组Id"));

            var result = await _busRep._sqlSugar.Queryable<Grp_TourClientList>()
                .LeftJoin<Crm_DeleClient>((x, y) => x.ClientId == y.Id)
                .LeftJoin<Crm_CustomerCert>((x, y, z) => y.Id == z.DcId && z.PassportType == 773)
                .Where((x, y, z) => x.DiId == groupId && x.IsDel == 0 && y.IsDel == 0)
                .Select((x, y, z) => new
                {
                    TourClientId = x.Id,
                    CrmId = y.Id,
                    y.FirstName,
                    y.LastName,
                    y.Pinyin,
                    y.BirthDay,
                    z.CertNo,
                    y.Sex,
                    x.ShippingSpaceTypeId
                }).ToListAsync();


            var view = result.Select(x =>
            {
                string firstName = AesEncryptionHelper.Decrypt(x.FirstName);
                string lastName = AesEncryptionHelper.Decrypt(x.LastName);
                string pinyin = AesEncryptionHelper.Decrypt(x.Pinyin);

                return new { x.TourClientId, x.CrmId, firstName , lastName, pinyin,x.CertNo, x.BirthDay, x.Sex, x.ShippingSpaceTypeId };
            }).ToList();

            if(result.Any()) return Ok(JsonView(true, "查询成功", view));

            return Ok(JsonView(false, "暂无数据"));
        }

        #endregion

        #region 币种 List
        /// <summary>
        /// 币种 List
        /// </summary>
        /// <returns></returns>
        [HttpGet, HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostCurrencyList()
        {
            try
            {
                Result setData = await _setDataRep.GetSetDataBySTId(_setDataRep, 66); //币种类型
                if (setData.Code == 0)
                {
                    return Ok(JsonView(true, "查询成功", setData.Data));
                }
                else
                {
                    return Ok(JsonView(false, setData.Msg));
                }
            }
            catch (Exception)
            {
                return Ok(JsonView(false, "程序错误！"));
                throw;
            }
        }

        /// <summary>
        /// 团组汇率 币种 Item (来源：团组汇率)
        /// 根据 团组Id And 业务类型(CTable)Id
        /// api处理CTable = 285,默认返回CNY
        /// </summary>
        /// <param name="dto"> 请求参数Dto </param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostGroupTeamRateByDiIdAndCTableId(GeneralTeamRateInfoDto dto)
        {
            try
            {
                if (dto == null)
                {
                    return Ok(JsonView(false, "请输入参数!"));
                }

                if (dto.DiId == 0)
                {
                    return Ok(JsonView(false, "请输入正确的团组Id!"));
                }
                if (dto.CTable == 0)
                {
                    return Ok(JsonView(false, "请输入正确的业务类型(CTable)Id!"));
                }


                if (dto.PortType == 1 || dto.PortType == 2 || dto.PortType == 3)
                {
                    var _vew = await GeneralMethod.PostGroupTeamRateByDiIdAndCTableId(dto.PortType, dto.DiId, dto.CTable);

                    return Ok(JsonView(true, "操作成功!", _vew));

                }
                else
                {
                    return Ok(JsonView(false, "请输入正确的端口号! 1 Web 2 Android 3 Ios;"));
                }



            }
            catch (Exception ex)
            {
                return Ok(JsonView(false, ex.Message));
            }
        }


        /// <summary>
        /// 根据团组Id币种Id及类型Id查询团组汇率
        /// </summary>
        /// <param name="DiId"></param>
        /// <param name="CId"></param>
        /// <param name="CurrencyId"></param>
        /// <returns></returns>
        [HttpGet, HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostCurrencyByDiid(int DiId, int CId, int CurrencyId)
        {
            try
            {
                Result setData = await _setDataRep.PostCurrencyByDiid(DiId, CId, CurrencyId); //币种类型
                if (setData.Code == 0)
                {
                    return Ok(JsonView(true, "查询成功", setData.Data));
                }
                else
                {
                    return Ok(JsonView(false, setData.Msg));
                }
            }
            catch (Exception)
            {
                return Ok(JsonView(false, "程序错误！"));
                throw;
            }

        }
        #endregion

        #region 查询页面关联Ctable


        /// <summary>
        /// 页面关联Ctable
        /// 根据PageId 返回 CTable Id
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public IActionResult PostPageLinkCTable(PageLinkCTableDto dto)
        {
            try
            {
                if (dto == null) return Ok(JsonView(false, "请求参数不能为空！"));

                if (dto.PageId == 0) return Ok(JsonView(false, "页面Id不能为0！"));

                var data = AppSettingsHelper.Get<CTableCorrelationPageDatas>("CTableCorrelationPageDatas");
                var correlationPageDatas = new CTableCorrelationPageDatas();

                foreach (var item in data)
                {
                    if (item.PageIdDatas != null)
                    {
                        var pageId = item.PageIdDatas.Where(it => it == dto.PageId).FirstOrDefault();
                        if (pageId != 0)
                        {
                            correlationPageDatas = item;
                            break;
                        }
                    }
                }

                if (correlationPageDatas.CTableId == 0)
                {
                    return Ok(JsonView(false, "您查询的页面Id，未配置AppSettings,请前往配置！"));
                }

                return Ok(JsonView(true, "操作成功", new { CTable = correlationPageDatas.CTableId }));
            }
            catch (Exception ex)
            {
                return Ok(JsonView(false, ex.Message));
            }
        }
        #endregion

        #region 会务物料单

        /// <summary>
        /// 获取会务活动列表
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostConferenceList()
        {
            var listSource = _busRep.Query<Grp_DelegationInfo>(s => s.TeamDid == 691 && s.IsDel == 0).ToList();
            var viewList = listSource.Select(x => new GroupNameView() { Id = x.Id,GroupName=x.TeamName }).ToList();

            return Ok(JsonView(viewList));
        }

        /// <summary>
        /// 获取会务的采购物品计划清单
        /// </summary>
        /// <param name="ConfId">会务活动Id</param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostConfItemList(int ConfId)
        {
            var view = new Bus_ConfItemListView();

            Bus_ConfItemListInfo _confListInfo = await _busRep.Query<Bus_ConfItemListInfo>(s => s.Diid == ConfId).FirstAsync();
            if (_confListInfo != null)
            {
                view.TotalCost = _confListInfo.TotalCost;

                string sqlItem = string.Format(@" Select c.Id,c.ItemId,d.ItemName,c.[Count],c.CurrCost,c.OpRemark
From Bus_ConfItem as c With(Nolock) 
Inner Join Res_ItemDetail as d with(Nolock) On c.ItemId=d.Id
Where c.ConfListId = {0}", ConfId);
                List<Bus_ConfItemView> confItemList = await _busRep._sqlSugar.SqlQueryable<Bus_ConfItemView>(sqlItem).ToListAsync();
                view.ItemList = new List<Bus_ConfItemView>(confItemList);
            }
            else
            {
                view.ItemList = new List<Bus_ConfItemView>();
                view.TotalCost = 0;
            }

            return Ok(JsonView(view));
        }

        /// <summary>
        /// 获取会务可采购的物料集合
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostOptionalItemList()
        {
            List<OptionalBusRangeView> result = await _busRep.GetViewList_OptionalItem();

            return Ok(JsonView(result));
        }

        /// <summary>
        /// 编辑物料采购清单
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostEditOptionalItemList(JsonDtoBase jsonDto)
        {
            if (string.IsNullOrEmpty(jsonDto.Paras))
            {
                return Ok(JsonView(false, "参数为空"));
            }
            Edit_OptionalItemListDto _dto = JsonConvert.DeserializeObject<Edit_OptionalItemListDto>(jsonDto.Paras);
            //Edit_OptionalItemListDto _dto = System.Text.Json.JsonSerializer.Deserialize<Edit_OptionalItemListDto>(jsonDto.Paras);

            if (_dto.DiId < 1)
            {
                return Ok(JsonView(false, "团组Id为空"));
            }

            if (_dto.ConfItemListId < 1)
            {
                //新增
                int rstInsert = await _busRep.Insert_ConfItemList(_dto);
                return Ok(JsonView(rstInsert == 0));
            }
            else
            {
                //修改
                int rstUpdate = await _busRep.Edit_ConfItemList(_dto);
                return Ok(JsonView(rstUpdate == 0));
            }

            //return Ok(JsonView(false));
        }

        /// <summary>
        /// 获取会务采购物料清单Excel
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> Excel_ConfItemList(JsonDtoBase jsonDto)
        {
            if (string.IsNullOrEmpty(jsonDto.Paras))
            {
                return Ok(JsonView(false, "参数为空"));
            }

            dynamic confList = JsonConvert.DeserializeObject<dynamic>(jsonDto.Paras);
            int confListId = confList.ConfListId;
            Bus_ConfItemListInfo _entityConfList = await _busRep.Query<Bus_ConfItemListInfo>(s => s.Id == confListId).FirstAsync();
            if (_entityConfList != null)
            {
                string result = new Excel_BusConfItemList().Excel(_entityConfList);


            }
            else
            {
                return Ok(JsonView(false, "请先保存数据"));
            }

            return Ok(JsonView(false));
        }

        #endregion

        #region 阿里云短信测试

        /// <summary>
        /// 编辑物料采购清单
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> AliMessageTest(string mobile)
        {

            string add2dayZH = DateTime.Now.AddDays(2).ToString("yyyy年MM月dd日");
            string templateParam = JsonConvert.SerializeObject(new { teams = "测试团组", date = add2dayZH });
            AliMessagePost.PostMessage(mobile, "泛美国际团组", "SMS_461575447", templateParam);
            return Ok(JsonView(true));
        }

        #endregion

        #region 文件删除
        /// <summary>
        ///  文件操作 
        ///  删除指定文件 
        /// </summary>
        /// <param name="dto">Dto</param>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostFileDel(FileDelDto dto)
        {
            try
            {
                string pathUrl = dto.PathUrl;
                if (string.IsNullOrEmpty(pathUrl))
                    return Ok(JsonView(false, "路径为空或者不是有效路径!"));

                if (System.IO.File.Exists(pathUrl))
                {
                    System.IO.File.Delete(pathUrl);
                    return Ok(JsonView(false, "操作成功!"));
                }
                else
                {
                    return Ok(JsonView(false, "该文件不存在!"));
                }
            }
            catch (Exception ex)
            {

                return Ok(JsonView(false, ex.Message));
            }
        }

        #endregion

        #region 表操作记录

        /// <summary>
        /// 表操作记录
        /// 添加
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTableOperationRecordAdd(TableOperationRecordAddDto _dto)
        {
            try
            {
                var _TableOperationRecord = new Crm_TableOperationRecord()
                {
                    TableName = _dto.TableName,
                    PortType = _dto.PortType,
                    OperationItem = _dto.OperationItem,
                    DataId = _dto.DataId,
                    CreateUserId = _dto.UserId,
                    CreateTime = DateTime.Now,
                    Remark = "",
                    IsDel = 0
                };

                bool _view = await _TableOperationRecordRep._Add(_TableOperationRecord);
                if (_view)
                {
                    return Ok(JsonView(true, "操作成功!"));
                }
                else
                {
                    return Ok(JsonView(false, "操作失败!"));
                }
            }
            catch (Exception)
            {
                return Ok(JsonView(false, "程序错误！"));
            }
        }



        /// <summary>
        /// 表操作记录
        /// 分页
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public async Task<IActionResult> PostTableOperationRecordPageList(TableOperationRecordPageDto _dto)
        {
            try
            {
                string whereSql = "";

                if (!string.IsNullOrEmpty(_dto.TableName))
                {
                    whereSql = string.Format(" And tor.TableName = '{0}'", _dto.TableName);
                }

                string sql = string.Format(@"Select row_number() over(order by tor.CreateTime Desc) As Row_Number,
                                             tor.TableName,tor.PortType,tor.OperationItem,tor.DataId,u.CnName As OperationUserName,
                                             tor.CreateTime,tor.Remark
                                             From Crm_TableOperationRecord tor
                                             Left Join Sys_Users u On tor.CreateUserId = u.Id
                                             Where tor.Isdel = 0 {0}", whereSql);

                RefAsync<int> total = 0;//REF和OUT不支持异步,想要真的异步这是最优解
                var _view = await _TableOperationRecordRep._sqlSugar.SqlQueryable<TableOperationRecordPageView>(sql).ToPageListAsync(_dto.PageIndex, _dto.PageSize, total);//ToPageAsync

                return Ok(JsonView(true, "查询成功!", _view, total));
            }
            catch (Exception ex)
            {
                return Ok(JsonView(false, "程序错误！Msg:" + ex.Message));
            }
        }


        #endregion


        /// <summary>
        /// 汉字转拼音
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult ChineseToEnFn(ChineseToEn dto)
        {
            var jw = JsonView(false, "请输入中文!");
            if (dto.originalText.Count == 0)
            {
                return Ok(jw);
            }

            var values = new List<string>();
            foreach (var item in dto.originalText)
            {
                var val = item.GetTotalPingYin();
                if (dto.isUp)
                {
                    val = val.Select(x => x.ToUpper()).ToList();
                }
                values.Add(val.Count > 0 ? val[0] : "暂无该拼音!");
            }

            jw = JsonView(true, "转换成功！", values);

            return Ok(jw);
        }


        [HttpGet]
        [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
        public IActionResult CodeTest()
        {

            return Ok(JsonView(true, "测试成功！"));
        }
    }
}