test 数据检查

This commit is contained in:
2024-06-04 14:10:21 +08:00
parent 60aac5a03a
commit 9812275c8f
4 changed files with 10 additions and 12 deletions

View File

@@ -10,8 +10,6 @@ public class HangfirePack : BaseAppPack
{
public override int Order => 990;
public override bool IsBeforeUseRouting { get; }
public override void ConfigureServices(IServiceCollection services)
{
services.AddHangfire((sp, config) =>

View File

@@ -6,7 +6,6 @@ namespace Dlhis.ScheduledTask.Packs;
public class JinkoSapHttpClientPack : BaseAppPack
{
public override bool IsBeforeUseRouting { get; }
public override void ConfigureServices(IServiceCollection services)
{

View File

@@ -4,16 +4,13 @@ using Hangfire;
using Hangfire.Common;
using Kurisu.AspNetCore.Startup;
using Kurisu.AspNetCore.Utils.Extensions;
using Kurisu.Scheduled;
using Kurisu.Scheduled.Attributes;
using SqlSugar;
namespace Dlhis.ScheduledTask.Packs;
public class JobPack : BaseAppPack
{
public override int Order => 999;
public override bool IsBeforeUseRouting { get; }
public override void Invoke(IServiceProvider serviceProvider)
{

View File

@@ -1,5 +1,4 @@
using Dlhis.Basic.Api;
using Dlhis.Basic.Api.Request;
using Dlhis.Basic.Api.Request;
using Dlhis.Entity.Canteen.Entities;
using Dlhis.Entity.Canteen.Enums;
using Dlhis.ScheduledTask.Common.Request;
@@ -23,7 +22,7 @@ public class HangfireController : ControllerBase
private readonly IHangfireService _hangfireService;
private readonly IDbContext _dbContext;
public HangfireController(IHangfireService hangfireService , IDbContext dbContext)
public HangfireController(IHangfireService hangfireService, IDbContext dbContext)
{
_hangfireService = hangfireService;
_dbContext = dbContext;
@@ -58,8 +57,8 @@ public class HangfireController : ControllerBase
{
_hangfireService.GeneratePermissions(request);
}
[IgnoreTenant]
[HttpPost("recalc")]
public async Task<object> ReCalc()
@@ -77,6 +76,11 @@ public class HangfireController : ControllerBase
.Having(x => SqlFunc.IsNull(x.Remark, "") != "" && SqlFunc.AggregateCount(1) > 1 && x.Remark != "用户取消" && x.Remark != "正常发放")
.ToListAsync();
return ls.Count;
var row = ls.First();
var code = row.UserCode;
var data = _dbContext.Queryable<BalanceRecordEntity>().Where(x => x.UserCode == code).Where(x => x.Remark == row.Remark);
return data;
}
}