| | |
| | | { |
| | | var entities = await rep.AsQueryable() |
| | | .Where(it => |
| | | it.TransactionStatus == EnumEnterpriseWalletTransactionStatus.WaitPay |
| | | || it.TransactionStatus == EnumEnterpriseWalletTransactionStatus.Dealing) |
| | | it.TransactionStatus == EnumWalletTransactionStatus.WaitPay |
| | | || it.TransactionStatus == EnumWalletTransactionStatus.Dealing) |
| | | .ToListAsync(); |
| | | if (entities.IsNotNull()) |
| | | { |
| | |
| | | entity.TransDate = response.PayDate.ToDateTime(); |
| | | entity.Status = response.Status; |
| | | entity.TransactionStatus = response.Status == "SUCCESS" |
| | | ? EnumEnterpriseWalletTransactionStatus.Success |
| | | ? EnumWalletTransactionStatus.Success |
| | | : response.Status == "DEALING" |
| | | ? EnumEnterpriseWalletTransactionStatus.Dealing |
| | | ? EnumWalletTransactionStatus.Dealing |
| | | : response.Status == "REFUND" |
| | | ? EnumEnterpriseWalletTransactionStatus.Refund |
| | | ? EnumWalletTransactionStatus.Refund |
| | | : response.Status == "FAIL" |
| | | ? EnumEnterpriseWalletTransactionStatus.Fail |
| | | ? EnumWalletTransactionStatus.Fail |
| | | : throw Oops.Oh(EnumErrorCodeType.s510, $"未识别的状态:{response.Status}"); |
| | | await rep.UpdateAsync(entity); |
| | | } |
| | | var walletIds = entities |
| | | .Where(it => it.TransactionStatus == EnumEnterpriseWalletTransactionStatus.Success) |
| | | .Where(it => it.TransactionStatus == EnumWalletTransactionStatus.Success) |
| | | .Select(it => it.WalletId) |
| | | .Distinct() |
| | | .ToList(); |