OA2023/OASystem/OASystem.Infrastructure/Repositories/Groups/EnterExitCostRepository.cs


using AutoMapper;
using OASystem.Domain;
using OASystem.Domain.Dtos.Groups;
using OASystem.Domain.Entities.Groups;
using OASystem.Domain.ViewModels.Groups;
using OASystem.Infrastructure.Repositories.System;
using OASystem.Infrastructure.Tools;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace OASystem.Infrastructure.Repositories.Groups
{
    /// <summary>
    /// 出入境费用 仓库
    /// </summary>
    public class EnterExitCostRepository:BaseRepository<Grp_EnterExitCost, EnterExitCostView>
    {
        private readonly IMapper _mapper;
        private readonly SetDataRepository _setDataRep;


        public EnterExitCostRepository(SqlSugarClient sqlSugar, IMapper mapper, SetDataRepository setDataRep)
            :base(sqlSugar) 
        {
            _setDataRep = setDataRep;
            _mapper = mapper;
        }

        /// <summary>
        /// 更新出入境费用汇率信息
        /// </summary>
        /// <returns></returns>
        public async Task<Result> SetEnterExitCostCurrencyChange()
        {
            Result result = new Result { Code = -1, Msg = "未知错误" };

            var enterExitList = await _sqlSugar.Queryable<Grp_EnterExitCost>().ToListAsync();

            foreach (var item in enterExitList)
            {
                string rateStr = string.Format(@"美元(USD):{0}|日元(JPY):{1}|欧元(EUR):{2}|英镑(GBP):{3}|港币(HKD):{4}", item.RateUSD,item.RateJPY,item.RateEUR,item.RateGBP,item.RateHKD);
                item.CurrencyRemark = rateStr;
            }

            var res = await _sqlSugar.Updateable(enterExitList)
                .WhereColumns(it => new { it.Id })
                .UpdateColumns(it => new { it.CurrencyRemark })
                .ExecuteCommandAsync();

            if (res > 0) 
            {
                result.Code = 0;
                result.Msg = res.ToString();
                return result;
            }

            return result;
        }

        
        /// <summary>
        /// 查询 根据 Diid 查询
        /// </summary>
        /// <returns></returns>
        public async Task<Result> GetEnterExitCostInfoByDiId(EnterExitCostInfobyDiIdDto dto)
        {
            Result result = new Result { Code = -1, Msg = "未知错误" };

            var enterExitCostData = await _sqlSugar.Queryable<Grp_EnterExitCost>().FirstAsync(it => it.DiId == dto.DiId && it.IsDel == 0);

            //Sys_PageFunctionPermission Function = _mapper.Map<Sys_PageFunctionPermission>(dto);

            EnterExitCostInfoView enterExitCostInfoView = new EnterExitCostInfoView();

            if (enterExitCostData != null)
            {
                enterExitCostInfoView = _mapper.Map<EnterExitCostInfoView>(enterExitCostData);

                var dayAndCostSql = string.Format(@"Select ssd.Name CurremcyCode,ssd.Remark CurrencyName,gdac.* From Grp_DayAndCost gdac
                                                Left Join Sys_SetData ssd On ssd.STid = 66 And gdac.Currency = ssd.Id
                                                Where gdac.Isdel = 0 And gdac.DiId = {0}", dto.DiId);
                var dayAndCostData = await _sqlSugar.SqlQueryable<DayAndCostInfoView>(dayAndCostSql).ToListAsync();


                enterExitCostInfoView.QuarterageData = dayAndCostData.Where(it => it.Type == 1).ToList(); //住宿费 1
                enterExitCostInfoView.BoardWagesData = dayAndCostData.Where(it => it.Type == 2).ToList(); //伙食费 2
                enterExitCostInfoView.MiscellaneousFeeData =dayAndCostData.Where(it => it.Type == 3).ToList();  //公杂费 3
                enterExitCostInfoView.TrainingExpenseData = dayAndCostData.Where(it => it.Type == 4).ToList();  //培训费 4

                enterExitCostInfoView.Currencys = (List<CurrencyInfo>?)CommonFun.GetCurrencyChinaToList(enterExitCostData.CurrencyRemark);

                result.Msg = "查询成功";
                result.Code = 0;
            }
            else
            {
                result.Msg = "未查询出数据!!!";
            }

            result.Data = enterExitCostInfoView;

            return result;
        }

        /// <summary>
        /// Add Or Update
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        public async Task<Result> PostEnterExitCostOperate(EnterExitCostOperateDto dto)
        { 
            Result result = new Result() { Code =-1,Msg="操作失败!" };

            var enterExitCost = _mapper.Map<Grp_EnterExitCost>(dto);
            var quarterageData = _mapper.Map<List<Grp_DayAndCost>>(dto.QuarterageData);  //住宿费 1
            var boardWagesData = _mapper.Map<List<Grp_DayAndCost>>(dto.BoardWagesData);  //伙食费 2
            var miscellaneousFeeData = _mapper.Map<List<Grp_DayAndCost>>(dto.MiscellaneousFeeData);  //公杂费 3
            var trainingExpenseData = _mapper.Map<List<Grp_DayAndCost>>(dto.TrainingExpenseData);    //培训费 4

            //处理币种string
            enterExitCost.CurrencyRemark = CommonFun.GetCurrencyChinaToString(dto.Currencys);
            _sqlSugar.BeginTran();
            try
            {
                var enterExit = _sqlSugar.Storageable<Grp_EnterExitCost>(enterExitCost).ToStorage();
                enterExit.AsInsertable.ExecuteCommand();   //不存在插入
                enterExit.AsUpdateable.ExecuteCommand();   //存在更新

                var quarterage = _sqlSugar.Storageable<Grp_DayAndCost>(quarterageData).ToStorage();
                quarterage.AsInsertable.ExecuteCommand();   //不存在插入
                quarterage.AsUpdateable.ExecuteCommand();   //存在更新

                var boardWages = _sqlSugar.Storageable<Grp_DayAndCost>(boardWagesData).ToStorage();
                boardWages.AsInsertable.ExecuteCommand();   //不存在插入
                boardWages.AsUpdateable.ExecuteCommand();   //存在更新

                var miscellaneousFee = _sqlSugar.Storageable<Grp_DayAndCost>(miscellaneousFeeData).ToStorage();
                miscellaneousFee.AsInsertable.ExecuteCommand();   //不存在插入
                miscellaneousFee.AsUpdateable.ExecuteCommand();   //存在更新

                var trainingExpense = _sqlSugar.Storageable<Grp_DayAndCost>(trainingExpenseData).ToStorage();
                trainingExpense.AsInsertable.ExecuteCommand();   //不存在插入
                trainingExpense.AsUpdateable.ExecuteCommand();   //存在更新

                _sqlSugar.CommitTran();
                result.Code = 0;
                result.Msg = "操作成功!";
            }
            catch (Exception ex)
            {
                _sqlSugar.RollbackTran();
                result.Msg = ex.Message;
            }


            return result;
        }


    }
}