using LifePayment.Application;
|
using LifePayment.Application.Contracts;
|
using LifePayment.Application.LifePay;
|
using LifePayment.Domain.Models;
|
using LifePayment.Domain.Shared;
|
using Microsoft.Extensions.DependencyInjection;
|
using Microsoft.Extensions.Logging;
|
using Nest;
|
using StackExchange.Redis;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Volo.Abp.BackgroundWorkers;
|
using Volo.Abp.DistributedLocking;
|
using Volo.Abp.Domain.Repositories;
|
using Volo.Abp.Threading;
|
using Volo.Abp.Uow;
|
using ZeroD.Util;
|
using ZeroD.Util.Fadd;
|
|
namespace LifePayment.Worker.Worker
|
{
|
public class CheckUnPayOrderWork : AsyncPeriodicBackgroundWorkerBase
|
{
|
private readonly int _doWorkHour = 0;
|
private readonly int _doWorkMinute = 1;
|
private readonly ILifePayOrderService lifePayOrderService;
|
private readonly ILifePayService lifePayService;
|
private readonly IAbpDistributedLock distributedLock;
|
private readonly IRepository<LifePayOrder, Guid> lifePayOrderRepository;
|
|
public CheckUnPayOrderWork(
|
AbpAsyncTimer timer,
|
IServiceScopeFactory serviceScopeFactory,
|
ILifePayOrderService lifePayOrderService,
|
ILifePayService lifePayService,
|
IAbpDistributedLock distributedLock,
|
IRepository<LifePayOrder, Guid> lifePayOrderRepository) : base(timer, serviceScopeFactory)
|
{
|
timer.Period = (int)TimeSpan.FromSeconds(5).TotalMilliseconds;
|
this.lifePayOrderService = lifePayOrderService;
|
this.lifePayService = lifePayService;
|
this.distributedLock = distributedLock;
|
this.lifePayOrderRepository = lifePayOrderRepository;
|
}
|
|
[UnitOfWork]
|
protected override async Task DoWorkAsync(PeriodicBackgroundWorkerContext workerContext)
|
{
|
try
|
{
|
Logger.LogInformation($"检查未支付订单状态开始: {DateTime.Now}");
|
var end = DateTime.Now;
|
var start = end.AddMinutes(-15);
|
var orders = lifePayOrderRepository.Where(it => it.PayStatus == LifePayStatusEnum.未支付 && it.CreationTime >= start && it.CreationTime <= end).ToList();
|
foreach (var order in orders)
|
{
|
await using var orderLock = await distributedLock.TryAcquireAsync($"LockKey:UpdateOrder:{order.OrderNo}", TimeSpan.FromSeconds(60));
|
|
Logger.LogInformation($"订单：{order.OrderNo}-{order.ToJson()}");
|
var wxPayNotice = await lifePayService.WxPayTradeQuery(order.OrderNo);
|
var json = wxPayNotice.ToJson();
|
Logger.LogInformation($"订单（{wxPayNotice.OutTradeNo}）信息: {json}");
|
if (wxPayNotice.OutTradeNo.Contains("JF") && wxPayNotice.TradeState == LifePaymentConstant.WxPayStatus.支付成功)
|
{
|
await lifePayService.LifePaySuccessHandler(wxPayNotice.OutTradeNo, wxPayNotice.TransactionId);
|
|
// 插入收支流水
|
await lifePayOrderService.AddLifePayExpensesReceipts(new AddLifePayExpensesReceiptsInput()
|
{
|
OrderNo = wxPayNotice.OutTradeNo,
|
OutOrderNo = wxPayNotice.TransactionId,
|
LifePayType = LifePayTypeEnum.WxPay,
|
ExpensesReceiptsType = ExpensesReceiptsTypeEnum.Expenses,
|
Amount = wxPayNotice.Amount.Total
|
});
|
|
Logger.LogInformation("已改为支付成功");
|
}
|
else
|
{
|
Logger.LogInformation("未更新");
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
Logger.LogError($"检查未支付订单状态发生异常: {DateTime.Now}" + ex.Message);
|
}
|
|
|
}
|
}
|
}
|
