using Microsoft.AspNetCore.Builder;
|
using Quartz.Impl;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using WIDESEA_Common;
|
using WIDESEA_Common.CutomerModel;
|
using WIDESEA_Core.EFDbContext;
|
using WIDESEA_Core.Utilities;
|
using WIDESEA_Entity.DomainModels;
|
using WIDESEA_Services.IRepositories;
|
using WIDESEA_Services.IServices;
|
using WIDESEA_Services.Repositories;
|
using WIDESEA_Services.Services;
|
using WIDESEA_WCS.WCSClient;
|
|
namespace WIDESEA_WCS
|
{
|
/// <summary>
|
/// Quartz 启动服务
|
/// </summary>
|
public static class QuartzJobMiddleWare
|
{
|
/// <summary>
|
/// 使用Quartz(任务调度库)Job(工作)模式
|
/// </summary>
|
/// <param name="app"></param>
|
/// <exception cref="ArgumentNullException"></exception>
|
public static void UseQuartzJobMildd(this IApplicationBuilder app)
|
{
|
if (app == null) throw new ArgumentNullException(nameof(app));
|
try
|
{
|
//WIDESEA.Helper.GetToken();
|
using (VOLContext context = new VOLContext())
|
{
|
IDt_DispatchManagementRepository dispatchManagementRepository = new Dt_DispatchManagementRepository(context);
|
List<Dt_DispatchManagement> dispatchManagementList = dispatchManagementRepository.Find(r => r.dm_state == "Enable");
|
if (null == dispatchManagementList)
|
{
|
Console.Out.WriteLine("WCS系统未配置或未启用任务计划，请检查。");
|
return;
|
}
|
WCSService.jobs = FindJobOptions(dispatchManagementList);
|
WCSService.Clients = new List<PLCClient>();
|
StdSchedulerFactory factory = new StdSchedulerFactory();
|
ISchedulerCenterServer schedulerCenter = new SchedulerCenterServer(factory);
|
IDt_PLCinfoHeadRepository pLcinfoHeadRepository = new Dt_PLCinfoHeadRepository(context);
|
IDt_PLCinfoDetailRepository plcinfoDetailRepository = new Dt_PLCinfoDetailRepository(context);
|
List<Dt_PLCinfoHead> pLcinfoHeadsList = pLcinfoHeadRepository.Find(x => true);
|
|
foreach (Dt_PLCinfoHead item in pLcinfoHeadsList)
|
{
|
PLCClient client = new PLCClient
|
{
|
PLCIPAddress = item.plcinfo_ip,
|
PLCName = item.plcinfo_name,
|
PLCDescription = item.plcinfo_state,
|
PLCDBItems = plcinfoDetailRepository.Find(x => x.plcdetail_headid == item.plcinfo_id
|
&& !string.IsNullOrEmpty(x.plcdetail_name)).Select(x => new DBItemGroup
|
{
|
ItemAddress = x.plcdetail_db.Trim() + "." + x.plcdetail_value.Trim(),
|
ItemDataType = x.plcdetail_valtype.Trim(),
|
ItemName = x.plcdetail_name.Trim(),
|
ItemOperatorType = x.plcdetail_opratortype?.Trim(),
|
EquipNum = x.plcdetail_number.Trim(),
|
Remark = x.plcdetail_remark.Trim()
|
}).ToList(),
|
plcinfo_equiptype = item.plcinfo_equiptype
|
};
|
string msg = client.Connect();
|
client.Start(() => { });
|
WCSService.Clients.Add(client);
|
}
|
|
WCSService.jobs.ForEach(x => { x.JobParams = WCSService.Clients.Where(y => y.plcinfo_equiptype == x.JobGroup).ToList(); });
|
if (!WCSService.jobs.Any())
|
return;
|
for (int i = 0; i < WCSService.jobs.Count; i++)
|
{
|
WebResponseContent content = schedulerCenter.AddScheduleJobAsync(WCSService.jobs[i]).Result;
|
if (!content.Status)
|
{
|
factory = null;
|
schedulerCenter = null;
|
return;
|
}
|
}
|
schedulerCenter.StartScheduleAsync();
|
}
|
}
|
catch (Exception ex)
|
{
|
Console.Out.WriteLine("启动WCS服务失败." + ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 查找任务计划
|
/// </summary>
|
/// <param name="dispatches"></param>
|
/// <returns></returns>
|
public static List<JobOptions> FindJobOptions(List<Dt_DispatchManagement> dispatches)
|
{
|
List<JobOptions> jobOptions = new List<JobOptions>();
|
foreach (var item in dispatches)
|
{
|
JobOptions options = new JobOptions()
|
{
|
AssemblyName = item.dm_assembly,
|
BeginTime = item.dm_begintime,
|
ClassName = item.dm_class,
|
Cron = item.dm_cron,
|
CycleRunTimes = item.dm_cycleruntimes ?? 0,
|
EndTime = item.dm_endtime,
|
IntervalSecond = item.dm_intervalsecond,
|
IsStart = false,
|
JobGroup = item.dm_group,
|
JobName = item.dm_group,
|
JobParams = null,
|
Remark = item.dm_remark,
|
TriggerType = item.dm_triggertype,
|
PLCConnectState = "未连接PLC"
|
};
|
jobOptions.Add(options);
|
}
|
return jobOptions;
|
}
|
|
|
}
|
}
|
