using Aop.Api.Domain;
|
using Azure;
|
using FlexJobApi.Core;
|
using Furion.DatabaseAccessor;
|
using Furion.FriendlyException;
|
using Mapster;
|
using MediatR;
|
using Microsoft.EntityFrameworkCore;
|
using StackExchange.Redis;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace FlexJobApi.UserServer.Application
|
{
|
/// <summary>
|
/// 企业钱包查询处理器
|
/// </summary>
|
public class EnterpriseWalletQueryHandler(
|
IRepository<EnterpriseWallet> rep,
|
IRepository<EnterpriseWalletTransaction> repEnterpriseWalletTransaction,
|
IRepository<EnterpriseWalletExpandindirectOrder> repEnterpriseWalletExpandindirectOrder,
|
IRepository<Enterprise> repEnterprise,
|
AlipayUtils alipayUtils
|
) :
|
IRequestHandler<GetEnterpriseWalletQuery, GetEnterpriseWalletQueryResult>,
|
IRequestHandler<GetEnterpriseWalletTransactionQuery, GetEnterpriseWalletTransactionQueryResult>
|
{
|
private readonly IRepository<EnterpriseWallet> rep = rep;
|
private readonly IRepository<EnterpriseWalletTransaction> repEnterpriseWalletTransaction = repEnterpriseWalletTransaction;
|
private readonly IRepository<EnterpriseWalletExpandindirectOrder> repEnterpriseWalletExpandindirectOrder = repEnterpriseWalletExpandindirectOrder;
|
private readonly IRepository<Enterprise> repEnterprise = repEnterprise;
|
private readonly AlipayUtils alipayUtils = alipayUtils;
|
|
/// <summary>
|
/// 查询企业钱包详情
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
[UnitOfWork(false)]
|
public async Task<GetEnterpriseWalletQueryResult> Handle(GetEnterpriseWalletQuery request, CancellationToken cancellationToken)
|
{
|
var logier = JwtUtils.GetCurrentLogier();
|
if (request.EnterpriseId == null || logier.Type == EnumUserType.Enterprise)
|
{
|
request.EnterpriseId = logier.EnterpriseId;
|
}
|
var enterprise = repEnterprise.AsQueryable().AsNoTracking()
|
.Where(it => it.Id == request.EnterpriseId)
|
.FirstOrDefault();
|
if (enterprise == null) throw Oops.Oh(EnumErrorCodeType.s404, "企业");
|
var entity = await rep.AsQueryable()
|
.Where(it => it.EnterpriseId == request.EnterpriseId && it.Access == request.Access)
|
.FirstOrDefaultAsync();
|
if (entity == null)
|
{
|
return new GetEnterpriseWalletQueryResult
|
{
|
Access = request.Access,
|
SignStatus = EnumEnterpriseWalletSignStatus.Wait,
|
ExpandindirectOrderStatus = EnumEnterpriseWalletExpandindirectOrderStatus.Wait
|
};
|
}
|
var update = false;
|
if (entity.Access == EnumEnterpriseWalletAccess.Alipay)
|
{
|
if (entity.SignStatus == EnumEnterpriseWalletSignStatus.Apply)
|
{
|
var response = alipayUtils.UserAgreementQuery(new Aop.Api.Domain.AlipayUserAgreementQueryModel
|
{
|
PersonalProductCode = entity.PersonalProductCode,
|
SignScene = entity.SignScene,
|
ExternalAgreementNo = entity.Code,
|
ThirdPartyType = entity.ThirdPartyType,
|
});
|
if (!response.IsError)
|
{
|
entity.AgreementNo = response.AgreementNo;
|
entity.SignTime = response.SignTime.ToDateTime();
|
entity.ValidTime = response.ValidTime.ToDateTime();
|
entity.InvalidTime = response.InvalidTime.ToDateTime();
|
entity.SignStatus = response.Status == "TEMP"
|
? EnumEnterpriseWalletSignStatus.Apply
|
: response.Status == "NORMAL"
|
? EnumEnterpriseWalletSignStatus.Normal
|
: response.Status == "STOP"
|
? EnumEnterpriseWalletSignStatus.Stop
|
: throw Oops.Oh(EnumErrorCodeType.s510, "状态异常");
|
entity.PricipalType = response.PricipalType;
|
entity.AlipayLogonId = response.AlipayLogonId;
|
entity.PrincipalId = response.PrincipalId;
|
entity.PrincipalOpenId = response.PrincipalOpenId;
|
entity.ZmOpenId = response.ZmOpenId;
|
entity.CreditAuthMode = response.CreditAuthMode;
|
update = true;
|
}
|
}
|
|
if (entity.SignStatus == EnumEnterpriseWalletSignStatus.Normal && entity.AccountBookStatus != EnumEnterpriseWalletAccountBookStatus.Normal)
|
{
|
var response = alipayUtils.FundAccountbookCreate(new Aop.Api.Domain.AlipayFundAccountbookCreateModel
|
{
|
MerchantUserId = entity.Code,
|
MerchantUserType = "BUSINESS_ORGANIZATION",
|
SceneCode = "SATF_FUND_BOOK",
|
ExtInfo = new
|
{
|
agreement_no = entity.AgreementNo,
|
cert_no = enterprise.SocietyCreditCode
|
}.ToJson()
|
});
|
if (response.IsError) throw Oops.Oh(EnumErrorCodeType.s510, response.SubMsg ?? response.Msg);
|
entity.AccountBookId = response.AccountBookId;
|
entity.BankAccName = response.ExtCardInfo.BankAccName;
|
entity.CardBank = response.ExtCardInfo.CardBank;
|
entity.CardBranch = response.ExtCardInfo.CardBranch;
|
entity.CardDeposit = response.ExtCardInfo.CardDeposit;
|
entity.CardLocation = response.ExtCardInfo.CardLocation;
|
entity.CardNo = response.ExtCardInfo.CardNo;
|
entity.AccountBookStatus = response.ExtCardInfo.Status == "A"
|
? EnumEnterpriseWalletAccountBookStatus.Normal
|
: EnumEnterpriseWalletAccountBookStatus.Exception;
|
update = true;
|
}
|
|
if (entity.AccountBookStatus == EnumEnterpriseWalletAccountBookStatus.Normal)
|
{
|
var response = alipayUtils.FundAccountbookQuery(new AlipayFundAccountbookQueryModel
|
{
|
AccountBookId = entity.AccountBookId,
|
SceneCode = "SATF_FUND_BOOK",
|
MerchantUserId = entity.Code,
|
});
|
if (response.IsError) throw Oops.Oh(EnumErrorCodeType.s510, response.SubMsg ?? response.Msg);
|
entity.Balance = response.AvailableAmount.ToDecimal() ?? 0;
|
update = true;
|
}
|
}
|
|
if (update)
|
{
|
await rep.UpdateNowAsync(entity);
|
}
|
|
var model = entity.Adapt<GetEnterpriseWalletQueryResult>();
|
|
var expandindirectOrder = await repEnterpriseWalletExpandindirectOrder.AsQueryable().AsNoTracking()
|
.OrderByDescending(it => it.CreatedTime)
|
.Where(it => it.WalletId == model.Id)
|
.Select(it => new
|
{
|
it.OrderStatus
|
})
|
.FirstOrDefaultAsync();
|
model.ExpandindirectOrderStatus = expandindirectOrder == null
|
? EnumEnterpriseWalletExpandindirectOrderStatus.Wait
|
: expandindirectOrder.OrderStatus;
|
|
return model;
|
}
|
|
/// <summary>
|
/// 查询企业钱包交易详情
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public async Task<GetEnterpriseWalletTransactionQueryResult> Handle(GetEnterpriseWalletTransactionQuery request, CancellationToken cancellationToken)
|
{
|
var entity = await repEnterpriseWalletTransaction.AsQueryable()
|
.Where(it => it.Id == request.Id)
|
.FirstOrDefaultAsync();
|
if (entity == null) throw Oops.Oh(EnumErrorCodeType.s404, "交易");
|
var response = alipayUtils.FundTransCommonQuery(new Aop.Api.Domain.AlipayFundTransCommonQueryModel
|
{
|
ProductCode = entity.ProductCode,
|
BizScene = entity.BizScene,
|
OutBizNo = entity.Code
|
});
|
if (response.IsError) throw Oops.Oh(EnumErrorCodeType.s510, response.SubMsg ?? response.Msg);
|
entity.OrderId = response.OrderId;
|
entity.InflowSettleSerialNo = response.InflowSettleSerialNo;
|
entity.SettleSerialNo = response.SettleSerialNo;
|
entity.ReceiverOpenId = response.ReceiverOpenId;
|
entity.ReceiverUserId = response.ReceiverUserId;
|
entity.PayFundOrderId = response.PayFundOrderId;
|
entity.ArrivalTimeEnd = response.ArrivalTimeEnd.ToDateTime();
|
entity.OrderFee = response.OrderFee.ToDecimal();
|
entity.ErrorCode = response.ErrorCode;
|
entity.FailReason = response.FailReason;
|
entity.FailInstReason = response.FailInstReason;
|
entity.FailInstName = response.FailInstName;
|
entity.FailInstErrorCode = response.FailInstErrorCode;
|
entity.SubStatus = response.SubStatus;
|
entity.TransDate = response.PayDate.ToDateTime();
|
entity.Status = response.Status;
|
entity.TransactionStatus = response.Status == "SUCCESS"
|
? EnumWalletTransactionStatus.Success
|
: response.Status == "DEALING"
|
? EnumWalletTransactionStatus.Dealing
|
: response.Status == "REFUND"
|
? EnumWalletTransactionStatus.Refund
|
: response.Status == "FAIL"
|
? EnumWalletTransactionStatus.Fail
|
: throw Oops.Oh(EnumErrorCodeType.s510, $"未识别的状态：{response.Status}");
|
await repEnterpriseWalletTransaction.UpdateAsync(entity);
|
if (entity.TransactionStatus == EnumWalletTransactionStatus.Success)
|
{
|
await GetBalance(entity.WalletId);
|
}
|
return entity.Adapt<GetEnterpriseWalletTransactionQueryResult>();
|
}
|
|
private async Task GetBalance(Guid id)
|
{
|
var entity = await rep.AsQueryable()
|
.Where(it => it.Id == id)
|
.FirstOrDefaultAsync();
|
if (entity == null) throw Oops.Oh(EnumErrorCodeType.s404, "企业钱包");
|
var response = alipayUtils.FundAccountbookQuery(new AlipayFundAccountbookQueryModel
|
{
|
AccountBookId = entity.AccountBookId,
|
SceneCode = "SATF_FUND_BOOK",
|
MerchantUserId = entity.Code,
|
});
|
if (response.IsError) throw Oops.Oh(EnumErrorCodeType.s510, response.SubMsg ?? response.Msg);
|
entity.Balance = response.AvailableAmount.ToDecimal() ?? 0;
|
await rep.UpdateNowAsync(entity);
|
}
|
|
}
|
}
|
