56 lines
1.6 KiB
C#
56 lines
1.6 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using YLErp.BLL;
|
|
using YLErp.DBModels;
|
|
using YLErp.Enums;
|
|
|
|
namespace YLErp.Modules.SwapModule
|
|
{
|
|
/// <summary>
|
|
/// 系统任务服务
|
|
/// </summary>
|
|
public class SysJobService: YLBaseService
|
|
{
|
|
public readonly static string Swap_ComposeBack_JobName = "互换流水合成持仓重置";
|
|
public SysJobService(OptUserInfo optUser) : base(optUser)
|
|
{
|
|
|
|
}
|
|
/// <summary>
|
|
/// 更新任务状态信息
|
|
/// </summary>
|
|
/// <param name="jobName"></param>
|
|
/// <param name="jobState"></param>
|
|
/// <param name="jobMessage"></param>
|
|
public void UpdateJob(string jobName,int jobState,string jobMessage)
|
|
{
|
|
var sysjob = DbContext.system_job.FirstOrDefault(x=>x.JobName== jobName);
|
|
bool add = false;
|
|
if (sysjob==null)
|
|
{
|
|
add = true;
|
|
sysjob = new system_job()
|
|
{
|
|
JobName = jobName
|
|
};
|
|
|
|
}
|
|
sysjob.JobMessage= jobMessage;
|
|
sysjob.JobState = jobState;
|
|
sysjob.UpdateTime = DateTime.Now;
|
|
if (add)
|
|
{
|
|
DbContext.system_job.Add(sysjob);
|
|
}
|
|
DbContext.SaveChanges();
|
|
}
|
|
public system_job GetJob(string jobName)
|
|
{
|
|
return DbContext.system_job.FirstOrDefault(x => x.JobName == jobName&&x.JobState==(int)SysJobStateEnum.pendding);
|
|
}
|
|
}
|
|
}
|