using IStation.DataDockingSocket;
|
using IStation.Untity;
|
using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
|
namespace IStation.Server
|
{
|
/// <summary>
|
/// 用户登录日志报表任务
|
/// </summary>
|
[DisallowConcurrentExecution]//此特性标识 必须等待这次任务执行完成后，才能执行下次任务
|
public class UserLoginLogReportJob : IJob
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public Task Execute(IJobExecutionContext context)
|
{
|
var otherDay = DateTime.Today.AddDays(-AppParasHelper.UserLoginLog.OtherDay);
|
return Task.Run(() =>
|
{
|
try
|
{
|
try
|
{
|
LogHelper.Info("调用API");
|
var url = $" {AppParasHelper.UserLoginLog.GenerateUrl}{otherDay}";
|
var responseText = HttpRequestHelper.Post(url);
|
var result = JsonHelper.Json2Object<Result>(responseText);
|
if (result.Code != 0)
|
{
|
throw new Exception(result.Message);
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error(ex.Message);
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"用户登陆日志统计,保存{otherDay.ToString("d")}数据出错", ex);
|
var e = new JobExecutionException(ex);
|
throw e;
|
}
|
});
|
}
|
}
|
}
|
