feat:开发

sunpengfei

16 小时以前 c682cd59ded8e71957a802dd4f8dcf58e0113c0f

 FlexJobApi.UserServer.Application/EnterpriseWallets/Commands/EnterpriseWalletExpandindirectCommandHandler.cs

@@ -23,7 +23,8 @@
    public class EnterpriseWalletExpandindirectCommandHandler(
            AlipayUtils alipayUtils,
            IHttpRemoteService httpRemoteService,
            IRepository<EnterpriseWalletExpandindirectOrder> rep
            IRepository<EnterpriseWalletExpandindirectOrder> rep,
            IRepository<EnterpriseWallet> repEnterpriseWallet
        ) :
        IRequestHandler<EnterpriseWalletExpandindirectCreateCommand, Guid>,
        IRequestHandler<EnterpriseWalletExpandindirectOrderCancelCommand, Guid>,
@@ -32,6 +33,7 @@
        private readonly AlipayUtils alipayUtils = alipayUtils;
        private readonly IHttpRemoteService httpRemoteService = httpRemoteService;
        private readonly IRepository<EnterpriseWalletExpandindirectOrder> rep = rep;
        private readonly IRepository<EnterpriseWallet> repEnterpriseWallet = repEnterpriseWallet;

        /// <summary>
        /// 支付宝资金二级商户KYB代进件
@@ -48,11 +50,19 @@
                request.EnterpriseId = logier.EnterpriseId;
            }
            if (request.EnterpriseId == null) throw Oops.Oh(EnumErrorCodeType.s400, "请填写企业Id");
            var wallet = await repEnterpriseWallet.AsQueryable().AsNoTracking()
                .Where(it => it.EnterpriseId == request.EnterpriseId)
                .FirstOrDefaultAsync();
            if (wallet == null)
            {
                throw Oops.Oh(EnumErrorCodeType.s404, "企业钱包");
            }
            var source = await rep.AsQueryable()
                .OrderByDescending(it => it.CreatedTime)
                .Where(it => it.Wallet.EnterpriseId == request.EnterpriseId && it.OrderId != null && it.OrderId != "")
                .Where(it => it.WalletId == wallet.Id && it.OrderId != null && it.OrderId != "")
                .FirstOrDefaultAsync();
            var entity = new EnterpriseWalletExpandindirectOrder();
            entity.WalletId = wallet.Id;
            if (source != null)
            {
                if (source.OrderStatus == EnumEnterpriseWalletExpandindirectOrderStatus.PROCESSING)