using Newtonsoft.Json;
|
using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_Common.Tools;
|
using WIDESEA_Entity.DomainModels.Equipment;
|
using WIDESEA_WCS.Jobs;
|
using WIDESEA_WCS.JobsPart.Public;
|
using WIDESEA_WCS.WCSClient;
|
|
namespace WIDESEA_WCS
|
{
|
/// <summary>
|
/// 分切机调度【三菱】
|
/// </summary>
|
[DisallowConcurrentExecution]
|
public class SlitterJob : JobBase, IJob
|
{
|
static List<AGVCenterEqDB> centerEqDBList;
|
|
public SlitterJob()
|
{
|
if (centerEqDBList == null || centerEqDBList.Count == 0)
|
{
|
string tsjJson = File.ReadAllText(AppContext.BaseDirectory + "/分切机.json", Encoding.UTF8);
|
centerEqDBList = JsonConvert.DeserializeObject<List<AGVCenterEqDB>>(tsjJson);
|
}
|
}
|
|
public Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
//ExecuteJob(context, DoAction);
|
}
|
catch { }
|
return Task.FromResult(string.Empty);
|
}
|
|
|
//private void DoAction(IJobExecutionContext context)
|
//{
|
// var clinet = context.JobDetail.JobDataMap.Get("JobParams") as PLCClient;
|
|
// var stationList = centerEqDBList.FirstOrDefault(t => t.tiShenJiName == clinet.PLCName);
|
// if (stationList != null)
|
// {
|
// foreach (var station in stationList.stationInfos)
|
// {
|
// if (station.stationType == "in")
|
// {
|
// var hreat = clinet.MelsecPLCClient.Read<bool>(station.dbData["R_hreat"]);
|
// var requestIn = clinet.MelsecPLCClient.Read<bool>(station.dbData["R_requestIn"]);
|
// var allowIn = clinet.MelsecPLCClient.Read<bool>(station.dbData["R_allowIn"]);
|
// var allowLeave = clinet.MelsecPLCClient.Read<bool>(station.dbData["R_allowLeave"]);
|
|
// //转换为调度中心地址
|
// byte[] clientData = new byte[100];
|
// clientData[0] = (byte)(hreat ? 1 : 0);
|
// int step = 0;
|
// if (allowIn)
|
// {
|
// step = 1;
|
// }
|
// if (allowLeave)
|
// {
|
// step = 2;
|
// }
|
// clientData[90 + 1] = (byte)step;
|
|
// TransferData(station, clinet, clientData);
|
// Create(clinet, station, requestIn);
|
// }
|
// else if (station.stationType.StartsWith("out"))
|
// {
|
// var requestOut = clinet.MelsecPLCClient.Read<bool>(station.dbData["R_requestOut"]);
|
// var allowIn = clinet.MelsecPLCClient.Read<bool>(station.dbData["R_allowIn"]);
|
// var allowLeave = clinet.MelsecPLCClient.Read<bool>(station.dbData["R_allowLeave"]);
|
|
// //转换为调度中心地址
|
// byte[] clientData = new byte[100];
|
// int step = 0;
|
// if (allowIn)
|
// {
|
// step = 1;
|
// }
|
// if (allowLeave)
|
// {
|
// step = 2;
|
// }
|
// int data_93 = 0;
|
// if (station.stationType == "outB")
|
// {
|
// data_93 = 2;
|
// }
|
// clientData[93] = (byte)data_93;
|
// clientData[90 + 1] = (byte)step;
|
|
// TransferData(station, clinet, clientData);
|
// Create(clinet, station, requestOut);
|
// }
|
// }
|
// }
|
//}
|
|
private void Create(PLCClient clinet, StationInfo station, bool request)
|
{
|
try
|
{
|
//入口无料
|
if (station.stationType == "in" && request)
|
{
|
WCSCommon.CreateTask(station, true);
|
}
|
//出口有料
|
else if (station.stationType.StartsWith("out") && request)
|
{
|
WCSCommon.CreateTask(station, false);
|
}
|
}
|
catch (Exception ex)
|
{
|
WriteLog.GetLog().Write($"【提升机任务请求异常】{clinet.PLCName},{station.stationCode}口。{ex.Message}" + "\n", clinet.PLCName);
|
}
|
}
|
|
|
/// <summary>
|
/// 中转AGV对接数据
|
/// </summary>
|
/// <param name="station"></param>
|
/// <param name="eq_Client"></param>
|
/// <param name="eq_Data"></param>
|
//private void TransferData(StationInfo station, PLCClient eq_Client, byte[] eq_Data)
|
//{
|
// var agv_Client = WIDESEA_WCS.WCSService.Clients.FirstOrDefault(t => t.PLCName == station.agvCenterName);
|
// if (agv_Client != null)
|
// {
|
// var agvData = (byte[])agv_Client.ReadDBValue(station.agvDBList[0], 100);
|
// int step = (int)agvData[90 + 1];
|
|
// //物料类型
|
// if (station.stationType == "in")
|
// {
|
// //心跳
|
// int hreat = (int)agvData[0];
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_hreat"], hreat);
|
// if (step == 0)
|
// {
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_requestIn"], false);
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_requestClose"], false);
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_haveLeave"], false);
|
// }
|
// else if (step == 1)
|
// {
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_requestIn"], true);
|
// }
|
// else if (step == 2)
|
// {
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_requestClose"], true);
|
// }
|
// else if (step == 3)
|
// {
|
// //离开后，辊分机。自复位
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_haveLeave"], true);
|
// }
|
// }
|
// else if (station.stationType.StartsWith("out"))
|
// {
|
// if (step == 0)
|
// {
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_requestIn"], false);
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_requestOpen"], false);
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_haveLeave"], false);
|
// }
|
// else if (step == 1)
|
// {
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_requestIn"], true);
|
// }
|
// else if (step == 2)
|
// {
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_requestOpen"], true);
|
// }
|
// else if (step == 3)
|
// {
|
// eq_Client.MelsecPLCClient.Write(station.dbData["W_haveLeave"], true);
|
// }
|
// }
|
// agv_Client.WriteDBValue(station.agvDBList[1], eq_Data);
|
// }
|
// else
|
// {
|
// WriteLog.GetLog(eq_Client.PLCName).Write($"【异常】{station.agvCenterName}，读取调度中心PLC失败" + "\n", eq_Client.PLCName);
|
// }
|
//}
|
}
|
}
|
