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 System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Volo.Abp.BackgroundWorkers;
|
using Volo.Abp.Domain.Repositories;
|
using Volo.Abp.Threading;
|
using Volo.Abp.Uow;
|
using ZeroD.Util;
|
|
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 IRepository<LifePayOrder, Guid> lifePayOrderRepository;
|
|
public CheckUnPayOrderWork(
|
AbpAsyncTimer timer,
|
IServiceScopeFactory serviceScopeFactory,
|
ILifePayOrderService lifePayOrderService,
|
ILifePayService lifePayService,
|
IRepository<LifePayOrder, Guid> lifePayOrderRepository) : base(timer, serviceScopeFactory)
|
{
|
timer.Period = (int)TimeSpan.FromMinutes(10).TotalMilliseconds;
|
this.lifePayOrderService = lifePayOrderService;
|
this.lifePayService = lifePayService;
|
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 orderNos = lifePayOrderRepository.Where(it => it.PayStatus == LifePayStatusEnum.未支付 && it.CreationTime >= start && it.CreationTime <= end).Select(it => it.OrderNo).ToList();
|
foreach (var orderNo in orderNos)
|
{
|
var wxPayNotice = await lifePayService.WxPayTradeQuery(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);
|
}
|
|
|
}
|
}
|
}
|
