using Microsoft.AspNetCore.Mvc; using Newtonsoft.Json.Serialization; using OASystem.API.OAMethodLib; using OASystem.Domain.Dtos.Groups; using OASystem.Domain.Entities.Business; using OASystem.Domain.Entities.Groups; using OASystem.Domain.ViewModels.Groups; using OASystem.Infrastructure.Repositories.Groups; using static OpenAI.GPT3.ObjectModels.SharedModels.IOpenAiModels; namespace OASystem.API.Controllers { /// /// 团组相关 /// //[Authorize] [Route("api/[controller]/[action]")] public class GroupsController : ControllerBase { private readonly GrpScheduleRepository _grpScheduleRep; private readonly IMapper _mapper; private readonly DelegationInfoRepository _groupRepository; private readonly TaskAssignmentRepository _taskAssignmentRep; private readonly AirTicketResRepository _airTicketResRep; public GroupsController(IMapper mapper, GrpScheduleRepository grpScheduleRep, DelegationInfoRepository groupRepository, TaskAssignmentRepository taskAssignmentRep, AirTicketResRepository airTicketResRep) { _mapper = mapper; _grpScheduleRep = grpScheduleRep; _groupRepository = groupRepository; _taskAssignmentRep = taskAssignmentRep; _airTicketResRep = airTicketResRep; } #region 流程管控 /// /// 获取团组流程管控信息 /// /// 参数Json字符串 /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task PostSearchGrpSchedule(JsonDtoBase _jsonDto) { if (string.IsNullOrEmpty(_jsonDto.Paras)) { return Ok(JsonView(false, "参数为空")); } Grp_ScheduleDto _ScheduleDto = JsonConvert.DeserializeObject(_jsonDto.Paras); if (_ScheduleDto != null) { if (_ScheduleDto.SearchType == 2)//获取列表 { List _grpScheduleViewList = await _grpScheduleRep.GetViewList_GrpSchedule(_ScheduleDto); return Ok(JsonView(_grpScheduleViewList)); } else//获取对象 { Grp_ScheduleCombinView _grpScheduleView = await _grpScheduleRep.GetView_GrpSchedule(_ScheduleDto); if (_grpScheduleView != null) { return Ok(JsonView(_grpScheduleView)); } } } else { return Ok(JsonView(false, "参数反序列化失败")); } return Ok(JsonView(false, "暂无数据!")); } /// /// 修改团组流程管控详细表数据 /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task PostUpdateGrpScheduleDetail(Grp_ScheduleDetailUpdDto dto) { Grp_ScheduleDetailInfo _detail = _mapper.Map(dto); var result = await _grpScheduleRep._sqlSugar.Updateable() .SetColumns(it => it.Duty == _detail.Duty) .SetColumns(it => it.ExpectBeginDt == _detail.ExpectBeginDt) .SetColumns(it => it.ExpectEndDt == _detail.ExpectEndDt) .SetColumns(it => it.JobContent == _detail.JobContent) .SetColumns(it => it.Remark == _detail.Remark) .SetColumns(it => it.StepStatus == _detail.StepStatus) .Where(s => s.Id == dto.Id) //.UpdateColumns(s => new { s.Duty, s.ExpectBeginDt, s.ExpectEndDt, s.JobContent, s.Remark, s.StepStatus }) .ExecuteCommandAsync(); if (result > 0) { return Ok(JsonView(true, "保存成功!")); } return Ok(JsonView(false, "保存失败!")); } /// /// 删除团组流程管控详细表数据,删除人Id请放在Duty /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task PostDeleteGrpScheduleDetail(Grp_ScheduleDetailUpdDto dto) { Grp_ScheduleDetailInfo _detail = _mapper.Map(dto); _detail.IsDel = 1; _detail.DeleteUserId = dto.Duty; _detail.DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); var result = await _grpScheduleRep._sqlSugar.Updateable() .SetColumns(it => it.IsDel == _detail.IsDel) .SetColumns(it => it.DeleteUserId == _detail.DeleteUserId) .SetColumns(it => it.DeleteTime == _detail.DeleteTime) .Where(it => it.Id == dto.Id) //.UpdateColumns(s => new { s.IsDel, s.DeleteUserId, s.DeleteTime }) //.WhereColumns(s => s.Id == dto.Id) .ExecuteCommandAsync(); if (result > 0) { return Ok(JsonView(true, "删除成功!")); } return Ok(JsonView(false, "删除失败!")); } /// /// 增加团组流程管控详细表数据 /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task PostInsertGrpScheduleDetail(Grp_ScheduleDetailInsertDto dto) { Grp_ScheduleDetailInfo _detail = _mapper.Map(dto); if (DateTime.Now < _detail.ExpectBeginDt) { _detail.StepStatus = 0; } else {//若大于设置时间,不考虑设置的预计结束日期,统一视为进行中 _detail.StepStatus = 1; } var result = await _grpScheduleRep._sqlSugar.Insertable(_detail).ExecuteReturnIdentityAsync(); if (result > 0) { Grp_ScheduleDetailView _result = await _grpScheduleRep.GetInsertBackData(result); return Ok(JsonView(true, "添加成功!", _result)); } return Ok(JsonView(false, "添加失败!")); } #endregion #region 团组基本信息 /// /// 接团信息列表 /// /// 团组列表请求dto /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GetGroupList(GroupListDto dto) { var groupData = await _groupRepository.GetGroupList(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(groupData.Data)); } /// /// 接团信息详情 /// /// 团组info请求dto /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GetGroupInfo(GroupInfoDto dto) { var groupData = await _groupRepository.GetGroupInfo(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(groupData.Data)); } /// /// 接团信息 编辑添加 /// 基础信息数据源 /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GroupEditBasicSource(GroupListDto dto) { var groupData = await _groupRepository.GroupEditBasicSource(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(groupData.Data)); } /// /// 接团信息 操作(增改) /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GroupOperation(GroupOperationDto dto) { try { var groupData = await _groupRepository.GroupOperation(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(true)); } catch (Exception ex) { Logs("[response]" + JsonConvert.SerializeObject(dto)); Logs(ex.Message); return Ok(JsonView(false, ex.Message)); } } /// /// 接团信息 操作(删除) /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GroupDel(GroupDelDto dto) { try { var groupData = await _groupRepository.GroupDel(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(true)); } catch (Exception ex) { Logs("[response]" + JsonConvert.SerializeObject(dto)); Logs(ex.Message); return Ok(JsonView(false, ex.Message)); } } /// /// 获取团组销售报价号 /// 团组添加时 使用 /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GetGroupSalesQuoteNo() { var groupData = await _groupRepository.GetGroupSalesQuoteNo(); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } object salesQuoteNo = new { SalesQuoteNo = groupData.Data }; return Ok(JsonView(salesQuoteNo)); } /// /// 设置确认出团 /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task SetConfirmationGroup(ConfirmationGroupDto dto) { var groupData = await _groupRepository.ConfirmationGroup(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } GroupStepForDelegation.CreateWorkStep(dto.GroupId); //创建管控流程 return Ok(JsonView(groupData.Data)); } /// /// 获取团组名称 List /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GetGroupNameList(GroupNameDto dto) { var groupData = await _groupRepository.GetGroupNameList(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(groupData.Data, groupData.Data.Count)); } /// /// 获取团组名称data And 签证国别Data /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GetGroupNameAndVisaNationality(GroupNameDto dto) { var groupData = await _groupRepository.GetGroupNameAndVisaNationality(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(groupData.Data)); } #endregion #region 团组&签证 /// /// 根据团组Id获取签证客户信息List /// /// 请求dto /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GetCrmByGroupId(ClientByGroupIdDto dto) { var groupData = await _groupRepository.GetCrmByGroupId(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(groupData.Data)); } #endregion #region 团组任务分配 /// /// 团组任务分配初始化 /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GetTaskAssignmen() { var groupData = await _taskAssignmentRep.GetTaskAssignmen(); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(true, groupData.Msg, groupData.Data)); } /// /// 团组任务分配查询 /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task TaskAssignmenQuery(TaskAssignmenQueryDto dto) { var groupData = await _taskAssignmentRep.TaskAssignmenQuery(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(true, groupData.Msg, groupData.Data)); } /// /// 团组任务分配操作 /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task GetTaskAssignmenOp(TaskAssignmenDto dto) { Result groupData = await _taskAssignmentRep.GetTaskAssignmenOp(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(true, groupData.Msg, groupData.Data)); } #endregion #region 团组费用审核 /// /// 获取团组费用审核 /// /// 参数Json字符串 /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task PostSearchGrpCreditCardPayment(Search_GrpCreditCardPaymentDto _dto) { if (_dto.DiId < 1) { return Ok(JsonView(false, "团组Id为空")); } Grp_CreditCardPaymentView _view = new Grp_CreditCardPaymentView(); #region 团组基本信息 Grp_DelegationInfo _delegation = _groupRepository.Query(s => s.Id == _dto.DiId).First(); if (_delegation != null) { _view.ClientName = _delegation.ClientName; _view.DiId = _dto.DiId; _view.TeamName = _delegation.TeamName; _view.VisitCountry = _delegation.VisitCountry; _view.VisitDate = _delegation.VisitStartDate.ToString("yyyy-MM-dd") + " ~ " + _delegation.VisitEndDate.ToString("yyyy-MM-dd"); _view.VisitDays = _delegation.VisitDays; _view.VisitPNumber = _delegation.VisitPNumber; } else { return Ok(JsonView(false, "团组信息为空")); } #endregion #region 费用清单 var exp = Expressionable.Create(); exp.AndIF(_dto.AuditStatus != -1, it => it.IsAuditGM == _dto.AuditStatus); exp.AndIF(_dto.Label != -1, it => it.CTable == _dto.Label); //缺少IF的语法糖 CTable List entityList = _groupRepository .Query(s => s.DIId == _dto.DiId && s.IsDel == 0 && s.CreateUserId > 0) .Where(exp.ToExpression()) .ToList(); List detailList = new List(); decimal CNY = 0; decimal PayCNY = 0; decimal BalanceCNY = 0; decimal YSFYCNY = 0; decimal USD = 0; decimal PayUSD = 0; decimal BalanceUSD = 0; decimal YSFYUSD = 0; decimal EUR = 0; decimal PayEUR = 0; decimal BalanceEUR = 0; decimal YSFYEUR = 0; foreach (var entity in entityList) { Grp_CreditCardPaymentDetailView _detail = new Grp_CreditCardPaymentDetailView(); _detail.Id=entity.Id; /* * Bus名称 */ _detail.BusName = ""; /* *费用所属 */ switch (entity.CTable) { case 85: Grp_AirTicketReservations jpRes = _groupRepository.Query(s => s.Id == entity.CId).First(); if (jpRes != null) { string FlightsDescription = jpRes.FlightsDescription; string PriceDescription = jpRes.PriceDescription; _detail.PriceMsgContent = "航班号:" + jpRes.FlightsCode + "
城市A-B:" + jpRes.FlightsCity + "
航班描述:" + FlightsDescription.Replace("\r\n", "
") + "
" + "价格描述:" + PriceDescription; _detail.PriceNameContent = "(" + jpRes.FlightsCode + ")"; } break; case 79: _detail.BusName = "待增加"; break; default: break; } /* * 费用模块 */ Sys_SetData sdPriceName = _groupRepository.Query(s => s.Id == entity.CTable).First(); if (sdPriceName != null) { _detail.PriceName = sdPriceName.Name; } /* * 应付款金额 */ Sys_SetData sdPaymentCurrency_WaitPay = _groupRepository.Query(s => s.Id == entity.PaymentCurrency).First(); string PaymentCurrency_WaitPay = "Unknown"; if (sdPaymentCurrency_WaitPay != null) { PaymentCurrency_WaitPay = sdPaymentCurrency_WaitPay.Name; } _detail.WaitPay = entity.PayMoney.ToString("#0.00") + " " + PaymentCurrency_WaitPay; /* * 此次付款金额 */ decimal CurrPayStr = 0; if (entity.PayPercentage == 0) { if (entity.PayThenMoney != 0) CurrPayStr = entity.PayThenMoney * decimal.Parse(entity.DayRate); } else { CurrPayStr = entity.PayMoney * (decimal.Parse(entity.PayPercentage.ToString("#0.00")) / 100 * decimal.Parse(entity.DayRate)); } _detail.CurrPay = CurrPayStr.ToString("#0.00") + " CNY"; /* * 剩余尾款 */ decimal BalanceStr = 0; if (entity.PayMoney - (CurrPayStr / decimal.Parse(entity.DayRate)) < 0.01M) BalanceStr = 0; else BalanceStr = (entity.PayMoney - CurrPayStr / decimal.Parse(entity.DayRate)); _detail.Balance = BalanceStr.ToString("#0.00") + " " + PaymentCurrency_WaitPay; /* * 申请人 */ string operatorName = "无"; Sys_Users _opUser = _groupRepository.Query(s => s.Id == entity.CreateUserId).First(); if (_opUser != null) { operatorName = _opUser.CnName; } _detail.OperatorName = operatorName; /* * 审核人 */ string auditOperatorName = "Unknown"; if (entity.AuditGMOperate == 0) auditOperatorName = "无"; else if (entity.AuditGMOperate == 4) auditOperatorName = "自动审核"; else { Sys_Users _adUser = _groupRepository.Query(s => s.Id == entity.AuditGMOperate).First(); if (_adUser != null) { auditOperatorName = _adUser.CnName; } } _detail.AuditOperatorName = auditOperatorName; /* * * *超预算比例 */ string overBudgetStr = ""; if (entity.ExceedBudget == -1) overBudgetStr = sdPriceName.Name + "尚无预算"; else if (entity.ExceedBudget == 0) overBudgetStr = "未超预算"; else overBudgetStr = entity.ExceedBudget.ToString("P"); _detail.OverBudget = overBudgetStr; /* * 费用总计 */ if (entity.PaymentCurrency == 48) { CNY += entity.PayMoney; PayCNY += CurrPayStr; BalanceCNY += BalanceStr; YSFYCNY += CurrPayStr; } if (entity.PaymentCurrency == 49) { USD += entity.PayMoney; PayUSD += CurrPayStr; BalanceUSD += BalanceStr; YSFYUSD += CurrPayStr; } if (entity.PaymentCurrency == 51) { EUR += entity.PayMoney; PayEUR += CurrPayStr; BalanceEUR += BalanceStr; YSFYEUR += CurrPayStr; } _detail.TotalStr1 = string.Format(@"应付款总金额:{0}CNY | {1}USD | {2}EUR", CNY, USD, EUR); _detail.TotalStr2 = string.Format(@"此次付款总金额:{0}CNY | {1}USD | {2}EUR", PayCNY, PayUSD, PayEUR); _detail.TotalStr3 = string.Format(@"目前剩余尾款总金额:{0}CNY | {1}USD | {2}EUR", BalanceCNY, BalanceUSD, BalanceEUR); _detail.TotalStr4 = string.Format(@"已审费用总额:{0}CNY | {1}USD | {2}EUR", YSFYCNY, YSFYUSD, YSFYEUR); detailList.Add(_detail); } #endregion _view.DetailList = new List(detailList); return Ok(JsonView(_view)); } /// /// 修改团组费用审核状态 /// /// 参数Json字符串 /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task PostAuditGrpCreditCardPayment(Edit_GrpCreditCardPaymentDto _dto) { List idList = _dto.CreditIdStr.Split(',').ToList(); Grp_CreditCardPayment _detail = _mapper.Map(_dto); DateTime dtNow = DateTime.Now; _groupRepository.BeginTran(); int rst = 0; foreach (var item in idList) { int CreditId = int.Parse(item); var result = await _grpScheduleRep._sqlSugar.Updateable() .SetColumns(it => it.IsAuditGM == _dto.AuditCode) .SetColumns(it => it.AuditGMOperate == _dto.User) .SetColumns(it => it.AuditGMDate == dtNow) .Where(s => s.Id == CreditId) .ExecuteCommandAsync(); if (result < 1) { rst = -1; } else { _groupRepository.RollbackTran(); return Ok(JsonView(false, "保存失败并回滚!")); } } _groupRepository.CommitTran(); if (rst == 0) { return Ok(JsonView(true, "保存成功!")); } return Ok(JsonView(false, "保存失败!")); } #endregion #region 机票费用录入 /// /// 机票录入当前登录人可操作团组 /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task AirTicketResSelect(AirTicketResDto dto) { try { Result groupData = await _airTicketResRep.AirTicketResSelect(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(true, groupData.Msg, groupData.Data)); } catch (Exception ex) { return Ok(JsonView(false, "程序错误!")); throw; } } /// /// 机票费用录入列表 /// /// /// [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task AirTicketResList(AirTicketResListDto dto) { try { Result groupData = await _airTicketResRep.AirTicketResList(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(true, groupData.Msg, groupData.Data)); } catch (Exception ex) { return Ok(JsonView(false, "程序错误!")); throw; } } [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task AirTicketResById(AirTicketResByIdDto dto) { try { Result groupData = await _airTicketResRep.AirTicketResById(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(true, groupData.Msg, groupData.Data)); } catch (Exception ex) { return Ok(JsonView(false, "程序错误!")); throw; } } [HttpPost] [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)] public async Task OpAirTicketRes(AirTicketResOpDto dto) { try { Result groupData = await _airTicketResRep.OpAirTicketRes(dto); if (groupData.Code != 0) { return Ok(JsonView(false, groupData.Msg)); } return Ok(JsonView(true, groupData.Msg, groupData.Data)); } catch (Exception ex) { return Ok(JsonView(false, "程序错误!")); throw; } } #endregion } }