164 lines
6.9 KiB
C#
164 lines
6.9 KiB
C#
// 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();
|
|
// }
|
|
// }
|
|
// } |