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 ILogger<CheckUnPayOrderWork> logger;
|
private readonly ILifePayOrderService lifePayOrderService;
|
private readonly ILifePayService lifePayService;
|
private readonly IAbpDistributedLock distributedLock;
|
private readonly IRepository<LifePayOrder, Guid> lifePayOrderRepository;
|
|
public CheckUnPayOrderWork(
|
AbpAsyncTimer timer,
|
ILogger<CheckUnPayOrderWork> logger,
|
IServiceScopeFactory serviceScopeFactory,
|
ILifePayOrderService lifePayOrderService,
|
ILifePayService lifePayService,
|
IAbpDistributedLock distributedLock,
|
IRepository<LifePayOrder, Guid> lifePayOrderRepository) : base(timer, serviceScopeFactory)
|
{
|
timer.Period = (int)TimeSpan.FromMinutes(30).TotalMilliseconds;
|
this.logger = logger;
|
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(-45);
|
//end = 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($"锁：LockKey:UpdateOrder:{order.OrderNo} - {orderLock != null}");
|
|
// 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);
|
}
|
|
|
}
|
}
|
}
|
