using AutoMapper;
using Newtonsoft.Json;
using OASystem.Domain;
using OASystem.Domain.Dtos;
using OASystem.Domain.Dtos.Financial;
using OASystem.Domain.Dtos.UserDto;
using OASystem.Domain.Entities.Financial;
using OASystem.Domain.Entities.Groups;
using OASystem.Domain.ViewModels.Financial;
using OASystem.Infrastructure.Repositories.Groups;
using OASystem.Infrastructure.Repositories.System;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;
namespace OASystem.Infrastructure.Repositories.Financial
{
/// <summary>
/// 财务 - 收款退还与其他款项
/// </summary>
public class PaymentRefundAndOtherMoneyRepository:BaseRepository<Fin_PaymentRefundAndOtherMoney, Fin_PaymentRefundAndOtherMoneyView>
{
private readonly IMapper _mapper;
private readonly Result _result;
private readonly SetDataRepository _setDataRep;
private readonly TeamRateRepository _teamRateRep;
/// <summary>
/// 初始化
/// </summary>
/// <param name="sqlSugar"></param>
/// <param name="mapper"></param>
public PaymentRefundAndOtherMoneyRepository(SqlSugarClient sqlSugar, IMapper mapper, SetDataRepository setDataRep, TeamRateRepository teamRateRep)
: base(sqlSugar)
{
_mapper = mapper;
_result = new Result() { Code = -2 };
_setDataRep = setDataRep;
_teamRateRep = teamRateRep;
}
/// <summary>
/// 根据团组ID 查询
/// </summary>
/// <param name="diId"></param>
/// <returns></returns>
public async Task<Result> PostItemByDiId(int diId)
{
string sql = string.Format(@"Select prom.Id,prom.PriceName,prom.Price,sd.Name As CurrencyCode,
prom.Remark,ccp.IsAuditGM,u.CnName As CreateUserName,prom.CreateTime
From Fin_PaymentRefundAndOtherMoney prom
Left Join Sys_Users u On u.Id = prom.CreateUserId
Left Join Sys_SetData sd On prom.CurrencyId = sd.Id
Left Join Grp_CreditCardPayment ccp On ccp.CTable = 285 And ccp.CId = prom.Id
Where prom.IsDel = 0 And u.IsDel = 0 And sd.IsDel = 0 And ccp.IsDel = 0
And prom.DiId = {0}", diId);
var data = await _sqlSugar.SqlQueryable<Fin_PaymentRefundAndOtherMoneyItemView>(sql).ToListAsync();
_result.Data = data;
_result.Code = 0;
_result.Msg = "查询成功!";
return _result;
}
/// <summary>
/// 删除
/// </summary>
/// <param name="diId"></param>
/// <returns></returns>
public async Task<Result> _Del(PaymentRefundAndOtherMoneyDelDto dto)
{
Fin_PaymentRefundAndOtherMoney _PaymentRefundAndOtherMoney = new Fin_PaymentRefundAndOtherMoney() {
Id = dto.Id,
DeleteUserId = dto.UserId,
DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
IsDel = 1
};
_sqlSugar.BeginTran();
var prom_del = await _sqlSugar.Updateable( _PaymentRefundAndOtherMoney )
.UpdateColumns(it => new { it.DeleteUserId,it.DeleteTime,it.IsDel })
.WhereColumns(it => new { it.Id})
.ExecuteCommandAsync();
Fin_PaymentRefundAndOtherMoney _PaymentRefundAndOtherMoneyInfo = new Fin_PaymentRefundAndOtherMoney();
_PaymentRefundAndOtherMoneyInfo = await _sqlSugar.Queryable<Fin_PaymentRefundAndOtherMoney>().Where(it => it.Id == dto.Id).FirstAsync();
if (_PaymentRefundAndOtherMoneyInfo != null)
{
Grp_CreditCardPayment _CreditCardPayment = new Grp_CreditCardPayment() {
Id = _PaymentRefundAndOtherMoneyInfo.Id,
DeleteUserId = dto.UserId,
DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
IsDel = 1
};
var ccp_del = await _sqlSugar.Updateable(_CreditCardPayment)
.UpdateColumns(it => new { it.DeleteUserId, it.DeleteTime, it.IsDel })
.WhereColumns(it => new { it.Id })
.ExecuteCommandAsync();
}
if (prom_del > 0 )
{
_result.Code = 0;
_result.Msg = "操作成功!";
}
else
{
_result.Msg = "操作失败!";
}
_sqlSugar.CommitTran();
return _result;
}
/// <summary>
/// 详情 数据源
/// </summary>
/// <param name="diId"></param>
/// <returns></returns>
public async Task<Result> _InfoDataSource(PortDtoBase dto)
{
if (dto.PortType == 1 || dto.PortType == 2 || dto.PortType == 3) //1 Web 2 Android 3 Ios
{
dynamic _currencyData = null, _payTypeData = null;
Result currencyData = await _setDataRep.GetSetDataBySTId(_setDataRep, 66); //币种类型
if (currencyData != null)
{
if (currencyData.Code == 0)
{
_currencyData = currencyData.Data;
}
}
Result payTypeData = await _setDataRep.GetSetDataBySTId(_setDataRep, 14); //支付类型
if (payTypeData != null)
{
if (payTypeData.Code == 0)
{
_payTypeData = payTypeData.Data;
}
}
List<dynamic> _priceTypeDatas = new List<dynamic>();
_priceTypeDatas.Add(new { Id = 0, Name = "其他", Remark = "" });
_priceTypeDatas.Add(new { Id = 1, Name = "退多付款", Remark = "" });
List<dynamic> _orbitalPrivateTransferDatas = new List<dynamic>();
_orbitalPrivateTransferDatas.Add(new { Id = 0, Name = "公转", Remark = "" });
_orbitalPrivateTransferDatas.Add(new { Id = 1, Name = "私转", Remark = "" });
dynamic _InfoDataSource = new
{
CurrencyDatas = _currencyData,
PayTypeDatas = _payTypeData,
OrbitalPrivateTransferDatas = _orbitalPrivateTransferDatas,
PriceTypeDatas = _priceTypeDatas
};
_result.Data = _InfoDataSource;
_result.Code = 0;
_result.Msg = "查询成功!";
}
else
{
_result.Msg = "请输入正确的端口号! 1 Web 2 Android 3 Ios;";
}
return _result;
}
/// <summary>
/// 详情
/// </summary>
/// <param name="diId"></param>
/// <returns></returns>
public async Task<Result> _Info(PaymentRefundAndOtherMoneyInfoDto dto)
{
if (dto.PortType == 1 || dto.PortType == 2 || dto.PortType == 3) //1 Web 2 Android 3 Ios
{
string sql = string.Format(@"Select prom.Id,ccp.Id CcpId,prom.DiId,prom.PriceName,prom.Price,prom.CurrencyId,ccp.Payee,ccp.PayDId,
ccp.OrbitalPrivateTransfer,ccp.ConsumptionPatterns,prom.PayType,prom.Remark
From Fin_PaymentRefundAndOtherMoney prom
Left Join Grp_CreditCardPayment ccp On ccp.CId = prom.id And ccp.CTable = 79 And ccp.IsDel = 0
Where prom.IsDel = 0 And prom.Id = {0}", dto.Id);
var data = await _sqlSugar.SqlQueryable<Fin_PaymentRefundAndOtherMoneyInfoView>(sql).ToListAsync();
if (data != null)
{
_result.Data = data;
_result.Code = 0;
_result.Msg = "查询成功!";
}
else
{
_result.Msg = "查询失败!";
}
}
else
{
_result.Msg = "请输入正确的端口号! 1 Web 2 Android 3 Ios;";
}
return _result;
}
/// <summary>
/// 操作(Add Or Edit)
/// </summary>
/// <param name="diId"></param>
/// <returns></returns>
public async Task<Result> _AddOrEdit(PaymentRefundAndOtherMoneyAddOrEditDto dto)
{
if (dto.PortType == 1 || dto.PortType == 2 || dto.PortType == 3) //1 Web 2 Android 3 Ios
{
#region 参数处理
Fin_PaymentRefundAndOtherMoney _PaymentRefundAndOtherMoney = new Fin_PaymentRefundAndOtherMoney() {
//Id = dto.Id,
DiId = dto.DiId,
PriceName = dto.PriceName,
Price = dto.Price,
CurrencyId = dto.CurrencyId,
PayType = dto.PayType,
//PriceType = dto.PriceType,
CreateUserId = dto.UserId,
Remark = dto.Remark
};
//处理团组汇率
decimal dayRate = 0.00M;
decimal CNY_Price = 0.00M;
decimal payThenMoney = 0.00M;
#region 其他款项 团组汇率 验证
if (dto.CurrencyId == 836) //人民币币种Id
{
dayRate = 1.0000M;
CNY_Price = dto.Price;
payThenMoney = dto.Price;
}
else //其他币种Id
{
List<TeamRateModelView> teamReteDatas = await _teamRateRep.PostGroupRateInfoByDiId(dto.DiId);
if (teamReteDatas.Count <= 0)
{
_result.Msg = "该团未设置团组汇率,请先设置!";
return _result;
}
var teamReteData1 = teamReteDatas.Where(it => it.CTableId == 285).FirstOrDefault();
if (teamReteData1 == null)
{
_result.Msg = "该团下的“其他款项”未设置团组汇率,请先设置!";
return _result;
}
var teamReteData2 = teamReteData1.TeamRates.Where(it => it.CurrencyCode == dto.CurrencyCode).FirstOrDefault();
if (teamReteData2 == null)
{
_result.Msg = @"该团下的“其他款项”币种 “"+ dto.CurrencyCode + "”未设置团组汇率,请先设置!";
return _result;
}
dayRate = teamReteData2.Rate;
CNY_Price = dayRate * dayRate;
payThenMoney = dayRate * dayRate;
}
#endregion
Grp_CreditCardPayment _CreditCardPayment = new Grp_CreditCardPayment() {
//Id = dto.CcpId,
//CId = dto.CcpId,
DIId = dto.DiId,
CTable = 285,
PayDId = dto.PayDId,
ConsumptionPatterns = dto.ConsumptionPatterns,
ConsumptionDate = string.Empty,
CTDId = 0,
BankNo = string.Empty,
CardholderName = string.Empty,
PayMoney = dto.Price,
PaymentCurrency = dto.CurrencyId,
DayRate = dayRate,
CompanyBankNo = string.Empty,
OtherBankName = string.Empty,
OtherSideNo = string.Empty,
OtherSideName = string.Empty,
MFOperator = 0,
MFOperatorDate = string.Empty,
IsAuditDM = 0,
AuditDMOperate = 0,
AuditDMDate = string.Empty,
IsAuditMF = 0,
AuditMFOperate = 0,
AuditMFDate = string.Empty,
IsAuditGM = 0,
AuditGMOperate = 0,
AuditGMDate = string.Empty,
IsPay = 0,
PayPercentage = 100.00M,
PayThenMoney = payThenMoney,
PayPercentageOld = 0.00M,
PayThenMoneyOld = 0.00M,
UpdateDate = string.Empty,
Payee = dto.Payee,
RMBPrice = CNY_Price,
OrbitalPrivateTransfer = dto.OrbitalPrivateTransfer,
ExceedBudget = 0.00M,
CreateUserId = dto.UserId,
DeleteUserId = null,
DeleteTime = string.Empty,
Remark = string.Empty,
IsDel = 0
};
#endregion
if (dto.Status == 1) //添加
{
_sqlSugar.BeginTran();
var addReturnId = await _sqlSugar.Insertable(_PaymentRefundAndOtherMoney).ExecuteReturnIdentityAsync();
if (addReturnId <= 0)
{
_result.Msg = "操作失败!收款退还与其他款项添加失败!";
_sqlSugar.RollbackTran();
return _result;
}
_CreditCardPayment.CId = addReturnId;
var addStatus = await _sqlSugar.Insertable(_CreditCardPayment).ExecuteReturnIdentityAsync();
if (addStatus <= 0)
{
_result.Msg = "操作失败!付款类型添加失败!";
_sqlSugar.RollbackTran();
return _result;
}
_sqlSugar.CommitTran();
_result.Msg = "操作成功!";
_result.Code = 0;
}
else if (dto.Status == 2) //修改
{
_PaymentRefundAndOtherMoney.Id = dto.Id;
_CreditCardPayment.Id = dto.CcpId;
_CreditCardPayment.CId = dto.Id;
_sqlSugar.BeginTran();
var prom_update = await _sqlSugar.Updateable(_PaymentRefundAndOtherMoney)
.IgnoreColumns(it => new { it.CreateUserId, it.CreateTime, it.DeleteUserId, it.DeleteTime, it.IsDel })
.WhereColumns(it => new { it.Id })
.ExecuteCommandAsync();
if (prom_update <= 0)
{
_result.Msg = "操作失败!收款退还与其他款项修改失败!";
_sqlSugar.RollbackTran();
return _result;
}
var ccp_update = await _sqlSugar.Updateable(_CreditCardPayment)
.UpdateColumns(it => new
{
it.ConsumptionPatterns,
it.PayMoney,
it.PaymentCurrency,
it.DayRate,
it.PayThenMoney,
it.OrbitalPrivateTransfer
})
.WhereColumns(it => new { it.Id })
.ExecuteCommandAsync();
if (ccp_update <= 0)
{
_result.Msg = "操作失败!付款信息修改失败!";
_sqlSugar.RollbackTran();
return _result;
}
_sqlSugar.CommitTran();
_result.Msg = "操作成功!";
_result.Code = 0;
}
else
{
_result.Msg = "请输入正确的状态! 1 添加 2 修改;";
}
}
else
{
_result.Msg = "请输入正确的端口号! 1 Web 2 Android 3 Ios;";
}
return _result;
}
}
}