yuangb/jinko.yikatong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix .

Browse Source
This commit is contained in:
liguoyang
2024-08-22 19:14:58 +08:00
parent c6b732ab96
commit 3e8f5da91d
6 changed files with 189 additions and 247 deletions
Download Patch File Download Diff File Expand all files Collapse all files

328
Src/Dlhis.ScheduledTask/Jobs/MealChunengSupplementHandlerJob.cs
View File

@@ -1,164 +1,164 @@
using Dlhis.Canteen.Api;
using Dlhis.Canteen.Api.Request;
using Dlhis.Entity.Basic.Entity;
using Dlhis.Entity.Basic.Enums;
using Dlhis.Entity.Canteen.Entities;
using Dlhis.Entity.Canteen.Enums;
using Dlhis.ScheduledTask.Attributes;
using Dlhis.ScheduledTask.Common.Request;
using Dlhis.ScheduledTask.Common.Services;
using Hangfire;
using Kurisu.AspNetCore.DataAccess.SqlSugar.Extensions;
using Kurisu.AspNetCore.Utils;
using Kurisu.AspNetCore.Utils.Extensions;
namespace Dlhis.ScheduledTask.Jobs;
/// <summary>
/// 餐补核算
/// </summary>
[RecurringJob(nameof(MealChunengSupplementHandlerJob), "0 0/30 * * * ?", Name = "储能餐补核算")]
public class MealChunengSupplementHandlerJob : BaseJob
{
private readonly IHainingMealSupplementApi _hainingMealSupplementApi;
private readonly IJinkoJIPService _jinkoJIPService;
public MealChunengSupplementHandlerJob(IServiceProvider serviceProvider,
IHainingMealSupplementApi hainingMealSupplementApi,
IJinkoJIPService jinkoJIPService) : base(serviceProvider)
{
_hainingMealSupplementApi = hainingMealSupplementApi;
_jinkoJIPService = jinkoJIPService;
}
protected override async Task RunAsync(IServiceProvider serviceProvider)
{
//查询待处理餐补
var mealSupplements = await DbContext.Queryable<MealSupplementRecordEntity>()
.Where(x => x.Status == MealSupplementStatusEnumtype.Wait || x.Status == MealSupplementStatusEnumtype.Error)
.Where(x => x.Workplace == "5" && x.Factory == "501")//储能
.Where(x => !x.Sync)
.ToListAsync();
foreach (var item in mealSupplements)
{
var gainfo = await DbContext.Queryable<GainfoEntity>().Where(x => x.Code == item.Code).SingleAsync();
if (gainfo == null)
{
gainfo = await DbContext.Queryable<GainfoEntity>().AS("GainfoLeave").Where(x => x.Code == item.Code).SingleAsync();
if (gainfo == null)
{
await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Error)
.SetColumns(x => x.Result == "人员档案不存在")
.SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == item.UniqueId)
.ExecuteCommandAsync();
//后台任务获取人员
BackgroundJob.Enqueue<IGainfoUpdateService>(x => x.TodoByCodeAsync(item.Code));
continue;
}
else if (gainfo.ResignationDate < item.Date)
{
try
{
var r = await _jinkoJIPService.SyncMealSupplementRecordsAsync(new List<SyncMealSupplementRecordRequest>
{
new()
{
UniqueId = item.UniqueId,
Status = "FAIL",
Msg = "人员离职"
}
});
await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Result == r)
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Success)
.SetColumns(x => x.Sync == true)
.SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == item.UniqueId)
.ExecuteCommandAsync();
}
catch
{
}
continue;
}
}
//创建余额数据
var mealUser = await DbContext.Queryable<GainfoMealEntity>().Where(x => x.UserCode == gainfo.Code).SingleAsync();
if (mealUser == null)
{
mealUser = new GainfoMealEntity
{
Balance = 0,
BalanceOfRecharge = 0,
BalanceOfSubsidies = 0,
UserCode = gainfo.Code,
Version = 0,
};
await DbContext.InsertAsync(mealUser);
}
await SetHainingMealSupplementAsync(item);
}
}
private async Task SetHainingMealSupplementAsync(MealSupplementRecordEntity mealSupplement)
{
await DbContext.Client.Ado.BeginTranAsync();
try
{
var hnResponse = await _hainingMealSupplementApi.AddHsChuNengMealSupplementAsync(new AddHainingMealSupplementRequest
{
Code = mealSupplement.Code,
Amount = mealSupplement.Amount,
Date = mealSupplement.Date.Date,
Remark = mealSupplement.Remark,
UniqueId = mealSupplement.UniqueId
});
(hnResponse == null || hnResponse.Code != 200).ThrowIfTrue("海宁餐补写入失败:" + hnResponse?.Message);
var r = await _jinkoJIPService.SyncMealSupplementRecordsAsync(new List<SyncMealSupplementRecordRequest>
{
new()
{
UniqueId = mealSupplement.UniqueId,
Status = "SUCCESS",
Msg = "操作成功"
}
});
//更新餐补信息为成功(同步成功)
await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Result == r)
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Success)
.SetColumns(x => x.Sync == true)
.SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == mealSupplement.UniqueId)
.ExecuteCommandAsync();
await DbContext.Client.Ado.CommitTranAsync();
}
catch (Exception ex)
{
await DbContext.Client.Ado.RollbackTranAsync();
await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Error)
.SetColumns(x => x.Result == ex.Message + " " + ex.StackTrace)
.SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == mealSupplement.UniqueId)
.ExecuteCommandAsync();
}
}
}
// using Dlhis.Canteen.Api;
// using Dlhis.Canteen.Api.Request;
// using Dlhis.Entity.Basic.Entity;
// using Dlhis.Entity.Basic.Enums;
// using Dlhis.Entity.Canteen.Entities;
// using Dlhis.Entity.Canteen.Enums;
// using Dlhis.ScheduledTask.Attributes;
// using Dlhis.ScheduledTask.Common.Request;
// using Dlhis.ScheduledTask.Common.Services;
// using Hangfire;
// using Kurisu.AspNetCore.DataAccess.SqlSugar.Extensions;
// using Kurisu.AspNetCore.Utils;
// using Kurisu.AspNetCore.Utils.Extensions;
//
// namespace Dlhis.ScheduledTask.Jobs;
//
// /// <summary>
// /// 餐补核算
// /// </summary>
// [RecurringJob(nameof(MealChunengSupplementHandlerJob), "0 0/30 * * * ?", Name = "储能餐补核算")]
// public class MealChunengSupplementHandlerJob : BaseJob
// {
// private readonly IHainingMealSupplementApi _hainingMealSupplementApi;
// private readonly IJinkoJIPService _jinkoJIPService;
//
// public MealChunengSupplementHandlerJob(IServiceProvider serviceProvider,
// IHainingMealSupplementApi hainingMealSupplementApi,
// IJinkoJIPService jinkoJIPService) : base(serviceProvider)
// {
// _hainingMealSupplementApi = hainingMealSupplementApi;
// _jinkoJIPService = jinkoJIPService;
// }
//
// protected override async Task RunAsync(IServiceProvider serviceProvider)
// {
// //查询待处理餐补
// var mealSupplements = await DbContext.Queryable<MealSupplementRecordEntity>()
// .Where(x => x.Status == MealSupplementStatusEnumtype.Wait || x.Status == MealSupplementStatusEnumtype.Error)
// .Where(x => x.Workplace == "5" && x.Factory == "501")//储能
// .Where(x => !x.Sync)
// .ToListAsync();
//
// foreach (var item in mealSupplements)
// {
// var gainfo = await DbContext.Queryable<GainfoEntity>().Where(x => x.Code == item.Code).SingleAsync();
// if (gainfo == null)
// {
// gainfo = await DbContext.Queryable<GainfoEntity>().AS("GainfoLeave").Where(x => x.Code == item.Code).SingleAsync();
//
// if (gainfo == null)
// {
// await DbContext.Updateable<MealSupplementRecordEntity>()
// .SetColumns(x => x.Status == MealSupplementStatusEnumtype.Error)
// .SetColumns(x => x.Result == "人员档案不存在")
// .SetColumns(x => x.ModifiedTime == DateTime.Now)
// .Where(x => x.UniqueId == item.UniqueId)
// .ExecuteCommandAsync();
//
// //后台任务获取人员
// BackgroundJob.Enqueue<IGainfoUpdateService>(x => x.TodoByCodeAsync(item.Code));
//
// continue;
// }
// else if (gainfo.ResignationDate < item.Date)
// {
// try
// {
// var r = await _jinkoJIPService.SyncMealSupplementRecordsAsync(new List<SyncMealSupplementRecordRequest>
// {
// new()
// {
// UniqueId = item.UniqueId,
// Status = "FAIL",
// Msg = "人员离职"
// }
// });
//
// await DbContext.Updateable<MealSupplementRecordEntity>()
// .SetColumns(x => x.Result == r)
// .SetColumns(x => x.Status == MealSupplementStatusEnumtype.Success)
// .SetColumns(x => x.Sync == true)
// .SetColumns(x => x.ModifiedTime == DateTime.Now)
// .Where(x => x.UniqueId == item.UniqueId)
// .ExecuteCommandAsync();
// }
// catch
// {
// }
//
// continue;
// }
// }
//
//
// //创建余额数据
// var mealUser = await DbContext.Queryable<GainfoMealEntity>().Where(x => x.UserCode == gainfo.Code).SingleAsync();
// if (mealUser == null)
// {
// mealUser = new GainfoMealEntity
// {
// Balance = 0,
// BalanceOfRecharge = 0,
// BalanceOfSubsidies = 0,
// UserCode = gainfo.Code,
// Version = 0,
// };
//
// await DbContext.InsertAsync(mealUser);
// }
//
// await SetHainingMealSupplementAsync(item);
// }
// }
//
// private async Task SetHainingMealSupplementAsync(MealSupplementRecordEntity mealSupplement)
// {
// await DbContext.Client.Ado.BeginTranAsync();
// try
// {
// var hnResponse = await _hainingMealSupplementApi.AddHsChuNengMealSupplementAsync(new AddHainingMealSupplementRequest
// {
// Code = mealSupplement.Code,
// Amount = mealSupplement.Amount,
// Date = mealSupplement.Date.Date,
// Remark = mealSupplement.Remark,
// UniqueId = mealSupplement.UniqueId
// });
//
// (hnResponse == null || hnResponse.Code != 200).ThrowIfTrue("海宁餐补写入失败:" + hnResponse?.Message);
//
// var r = await _jinkoJIPService.SyncMealSupplementRecordsAsync(new List<SyncMealSupplementRecordRequest>
// {
// new()
// {
// UniqueId = mealSupplement.UniqueId,
// Status = "SUCCESS",
// Msg = "操作成功"
// }
// });
//
// //更新餐补信息为成功(同步成功)
// await DbContext.Updateable<MealSupplementRecordEntity>()
// .SetColumns(x => x.Result == r)
// .SetColumns(x => x.Status == MealSupplementStatusEnumtype.Success)
// .SetColumns(x => x.Sync == true)
// .SetColumns(x => x.ModifiedTime == DateTime.Now)
// .Where(x => x.UniqueId == mealSupplement.UniqueId)
// .ExecuteCommandAsync();
//
// await DbContext.Client.Ado.CommitTranAsync();
// }
// catch (Exception ex)
// {
// await DbContext.Client.Ado.RollbackTranAsync();
//
// await DbContext.Updateable<MealSupplementRecordEntity>()
// .SetColumns(x => x.Status == MealSupplementStatusEnumtype.Error)
// .SetColumns(x => x.Result == ex.Message + " " + ex.StackTrace)
// .SetColumns(x => x.ModifiedTime == DateTime.Now)
// .Where(x => x.UniqueId == mealSupplement.UniqueId)
// .ExecuteCommandAsync();
// }
// }
// }

3
Src/Dlhis.ScheduledTask/Jobs/MealHainingSupplementHandlerJob.cs
View File

@@ -61,7 +61,8 @@ public class MealHainingSupplementHandlerJob : BaseJob
continue;
}
else if (gainfo.ResignationDate < item.Date)
if (gainfo.ResignationDate < item.Date)
{
try
{

83
Src/Dlhis.ScheduledTask/Jobs/MealSupplementHandlerJob.cs
View File

@@ -1,6 +1,4 @@
using Dlhis.Canteen.Api;
using Dlhis.Canteen.Api.Request;
using Dlhis.Entity.Basic.Entity;
using Dlhis.Entity.Basic.Entity;
using Dlhis.Entity.Basic.Enums;
using Dlhis.Entity.Canteen.Entities;
using Dlhis.Entity.Canteen.Enums;
@@ -10,7 +8,6 @@ using Dlhis.ScheduledTask.Common.Services;
using Hangfire;
using Kurisu.AspNetCore.DataAccess.SqlSugar.Extensions;
using Kurisu.AspNetCore.Utils;
using Kurisu.AspNetCore.Utils.Extensions;
namespace Dlhis.ScheduledTask.Jobs;
@@ -20,23 +17,22 @@ namespace Dlhis.ScheduledTask.Jobs;
[RecurringJob(nameof(MealSupplementHandlerJob), "0 0/30 * * * ?", Name = "餐补核算")]
public class MealSupplementHandlerJob : BaseJob
{
private readonly IHainingMealSupplementApi _hainingMealSupplementApi;
private readonly IJinkoJIPService _jinkoJIPService;
public MealSupplementHandlerJob(IServiceProvider serviceProvider,
IHainingMealSupplementApi hainingMealSupplementApi,
IJinkoJIPService jinkoJIPService) : base(serviceProvider)
{
_hainingMealSupplementApi = hainingMealSupplementApi;
_jinkoJIPService = jinkoJIPService;
}
protected override async Task RunAsync(IServiceProvider serviceProvider)
{
var others = new[] { "502", "503", "504", "505" };
//查询待处理餐补
var mealSupplements = await DbContext.Queryable<MealSupplementRecordEntity>()
.Where(x => x.Status == MealSupplementStatusEnumtype.Wait || x.Status == MealSupplementStatusEnumtype.Error)
.Where(x => x.Workplace != "5")
.Where(x => !others.Contains(x.Factory))
.Where(x => !x.Sync)
.ToListAsync();
@@ -61,7 +57,8 @@ public class MealSupplementHandlerJob : BaseJob
continue;
}
else if (gainfo.ResignationDate < item.Date)
if (gainfo.ResignationDate < item.Date)
{
try
{
@@ -108,14 +105,7 @@ public class MealSupplementHandlerJob : BaseJob
await DbContext.InsertAsync(mealUser);
}
if (item.Workplace == "5")
{
await SetHainingMealSupplementAsync(item);
}
else
{
await SetMealSupplementAsync(gainfo, item);
}
await SetMealSupplementAsync(gainfo, item);
}
}
@@ -198,63 +188,4 @@ public class MealSupplementHandlerJob : BaseJob
.ExecuteCommandAsync();
}
}
private async Task SetHainingMealSupplementAsync(MealSupplementRecordEntity mealSupplement)
{
await DbContext.Client.Ado.BeginTranAsync();
try
{
var hnResponse = mealSupplement.Factory == "501"
? await _hainingMealSupplementApi.AddHsChuNengMealSupplementAsync(new AddHainingMealSupplementRequest
{
Code = mealSupplement.Code,
Amount = mealSupplement.Amount,
Date = mealSupplement.Date.Date,
Remark = mealSupplement.Remark,
UniqueId = mealSupplement.UniqueId
})
: await _hainingMealSupplementApi.AddMealSupplementAsync(new AddHainingMealSupplementRequest
{
Code = mealSupplement.Code,
Amount = mealSupplement.Amount,
Date = mealSupplement.Date.Date,
Remark = mealSupplement.Remark,
UniqueId = mealSupplement.UniqueId
});
(hnResponse == null || hnResponse.Code != 200).ThrowIfTrue("海宁餐补写入失败:" + hnResponse?.Message);
var r = await _jinkoJIPService.SyncMealSupplementRecordsAsync(new List<SyncMealSupplementRecordRequest>
{
new()
{
UniqueId = mealSupplement.UniqueId,
Status = "SUCCESS",
Msg = "操作成功"
}
});
//更新餐补信息为成功(同步成功)
await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Result == r)
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Success)
.SetColumns(x => x.Sync == true)
.SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == mealSupplement.UniqueId)
.ExecuteCommandAsync();
await DbContext.Client.Ado.CommitTranAsync();
}
catch (Exception ex)
{
await DbContext.Client.Ado.RollbackTranAsync();
await DbContext.Updateable<MealSupplementRecordEntity>()
.SetColumns(x => x.Status == MealSupplementStatusEnumtype.Error)
.SetColumns(x => x.Result == ex.Message + " " + ex.StackTrace)
.SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UniqueId == mealSupplement.UniqueId)
.ExecuteCommandAsync();
}
}
}