99 lines
3.7 KiB
C#
99 lines
3.7 KiB
C#
using Dlhis.Entity.Canteen.Entities;
|
|
using Dlhis.Entity.Canteen.Entities.Voucher;
|
|
using Dlhis.Entity.Canteen.Enums;
|
|
using Dlhis.Jip.Api;
|
|
using Dlhis.Jip.Api.Requests;
|
|
using Dlhis.ScheduledTask.Attributes;
|
|
using SqlSugar;
|
|
|
|
namespace Dlhis.ScheduledTask.Jobs;
|
|
|
|
/// <summary>
|
|
/// 生日券发放消费上传
|
|
/// </summary>
|
|
[RecurringJob(nameof(BirthdayCostUploadJob), "0 0 0 10 * ? ", Name = "生日券发放消费上传")]
|
|
public class BirthdayCostUploadJob : BaseJob
|
|
{
|
|
|
|
public BirthdayCostUploadJob(IServiceProvider serviceProvider) : base(serviceProvider)
|
|
{
|
|
}
|
|
|
|
protected override async Task RunAsync(IServiceProvider serviceProvider)
|
|
{
|
|
var jipApi = serviceProvider.GetService<IJinkoJipApi>();
|
|
|
|
var now = DateTime.Now;
|
|
|
|
var year = now.Month == 1 ? now.Year - 1 : now.Year;
|
|
var month = now.Month == 1 ? 12 : now.Month - 1;
|
|
|
|
var s = new DateTime(year, month, 1);
|
|
var e = s.AddMonths(1);
|
|
var endDayOfMonth = e.AddDays(-1);
|
|
|
|
var userCodeAll = await DbContext.Queryable<UserBalanceEntity>()
|
|
.Select(x => x.UserCode)
|
|
.Distinct()
|
|
.ToListAsync();
|
|
|
|
//获取所有人员的生日券发放和消费数据，逐人上传
|
|
foreach (var userCode in userCodeAll)
|
|
{
|
|
var request = new UploadCostRequest
|
|
{
|
|
Data = new List<UploadCostItemRequest>(2)
|
|
};
|
|
|
|
try
|
|
{
|
|
//查询生日券发放数据
|
|
var voucher = await DbContext.Queryable<VoucherEntity>()
|
|
.LeftJoin<VoucherUserInfoEntity>((x, xu) => x.No == xu.VoucherNo)
|
|
.Where((x, xu) => xu.UserCode == userCode)// 指定用户
|
|
.Where(x => x.Type == VoucherEnumType.Birthday)
|
|
.Where(x => x.ClaimDateTime >= s && x.ClaimDateTime < e)
|
|
.Select((x, xu) => new
|
|
{
|
|
x.OriginalBalance
|
|
})
|
|
.SingleAsync();
|
|
|
|
if (voucher != null)
|
|
{
|
|
request.Data.Add(new UploadCostItemRequest
|
|
{
|
|
WorkCode = userCode,
|
|
Code = "2088",
|
|
BeginDate = endDayOfMonth.ToString("yyyy-MM-dd"),
|
|
Charge = voucher.OriginalBalance
|
|
});
|
|
}
|
|
//生日券消费数据
|
|
var cost = await DbContext.Queryable<BalanceRecordEntity>()
|
|
.Where(record => record.UserCode == userCode)// 指定用户
|
|
.Where(record => record.CostDate >= s && record.CostDate < e)
|
|
.Where(record => record.Source == BalanceRecordSourceEnumType.Birthday)
|
|
.Where(record => record.Type == BalanceRecordTypeEnumType.Out && record.Status == BalanceRecordStatusEnumType.Valid)
|
|
.SumAsync(record => SqlFunc.Abs(SqlFunc.IsNull(record.Amount, 0)));
|
|
|
|
request.Data.Add(new UploadCostItemRequest
|
|
{
|
|
WorkCode = userCode,
|
|
Code = "2089",
|
|
BeginDate = endDayOfMonth.ToString("yyyy-MM-dd"),
|
|
Charge = cost
|
|
});
|
|
|
|
var response = await jipApi.UploadCostAsync(request);
|
|
var handleData = response.Data.Where(x => x.Success == "S").ToList();
|
|
Logger.LogInformation("BirthdayCostUploadJob生日券发放消费上传成功{userCode}", userCode);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Logger.LogError(ex, "BirthdayCostUploadJob生日券发放消费上传失败-{userCode}:{error}", userCode, ex.Message);
|
|
}
|
|
}
|
|
}
|
|
}
|