using Newtonsoft.Json;
|
using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using WIDESEA_Common;
|
using WIDESEA_Common.CutomerModel;
|
using WIDESEA_Core.EFDbContext;
|
using WIDESEA_Core.ManageUser;
|
using WIDESEA_Core.Utilities;
|
using WIDESEA_Entity.DomainModels;
|
using WIDESEA_Services;
|
using WIDESEA_Services.IRepositories;
|
using WIDESEA_Services.Repositories;
|
using WIDESEA_Services.Services;
|
using WIDESEA_WCS.EquipBaseInfo;
|
using WIDESEA_WCS.Jobs;
|
using WIDESEA_WCS.WCSClient;
|
|
namespace WIDESEA_WCS
|
{
|
public class InboundDispatchJob : JobBase, IJob
|
{
|
/// <summary>
|
/// 输送线调度
|
/// </summary>
|
/// <param name="context"></param>
|
/// <returns></returns>
|
public Task Execute(IJobExecutionContext context)
|
{
|
return Task.Run(() =>
|
{
|
//var executeLog = ExecuteJob(context, () => Run(context));
|
});
|
}
|
|
public string Run(IJobExecutionContext context)
|
{
|
JobDataMap data = context.JobDetail.JobDataMap;
|
PLCClient client = data.Get("JobParams") as PLCClient;//传入的PLC连接,所有DB块读写
|
//client.Read("DB3.0", "i");
|
LineOutboundExecutor.SendLineOutboundTask(client);
|
|
LineOutboundExecutor.LineOutboundTaskCompleted(client);
|
return "";
|
}
|
}
|
}
|
