using Newtonsoft.Json;
|
using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
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 PrintJob : JobBase, IJob
|
{
|
|
static List<AGVCenterEqDB> centerEqDBList;
|
public PrintJob()
|
{
|
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.OmronPLCClient.Read<bool>(station.dbData["R_hreat"]);
|
// var waring = clinet.OmronPLCClient.Read<bool>(station.dbData["R_waring"]);
|
var step = clinet.OmronPLCClient.Read<ushort>(station.dbData["R_step"]);
|
//var requestType = clinet.OmronPLCClient.Read<ushort>(station.dbData["R_requestType"]);
|
//var isAB = clinet.OmronPLCClient.Read<bool>(station.dbData["R_isAB"]);
|
//var isToRihgt = clinet.OmronPLCClient.Read<bool>(station.dbData["R_isToRihgt"]);
|
//var diffNum = clinet.OmronPLCClient.Read<ushort>(station.dbData["R_diffNum"]);
|
|
//转换为调度中心地址
|
byte[] clientData = new byte[100];
|
//clientData[0] = (byte)(hreat ? 1 : 0);
|
clientData[90 + 1] = (byte)step;
|
//clientData[92] = (byte)(waring ? 1 : 0);
|
//int data_93 = 0;
|
//data_93 += isAB ? 2 : 0;
|
//data_93 += isToRihgt ? 4 : 0;
|
//clientData[93] = (byte)data_93;
|
//clientData[94] = (byte)diffNum;
|
|
TransferData(station, clinet, clientData);
|
//Create(clinet, station, requestType);
|
}
|
else if (station.stationType == "out")
|
{
|
//var materialtype = clinet.OmronPLCClient.Read<bool>(station.dbData["R_materialtype"]);
|
var waring = clinet.OmronPLCClient.Read<bool>(station.dbData["R_waring"]);
|
var step = clinet.OmronPLCClient.Read<ushort>(station.dbData["R_step"]);
|
var requestType = clinet.OmronPLCClient.Read<ushort>(station.dbData["R_requestType"]);
|
var isAB = clinet.OmronPLCClient.Read<bool>(station.dbData["R_isAB"]);
|
var isToRihgt = clinet.OmronPLCClient.Read<bool>(station.dbData["R_isToRihgt"]);
|
var diffNum = clinet.OmronPLCClient.Read<ushort>(station.dbData["R_diffNum"]);
|
|
//转换为调度中心地址
|
byte[] clientData = new byte[100];
|
clientData[90 + 1] = (byte)step;
|
clientData[92] = (byte)(waring ? 1 : 0);
|
int data_93 = 0;
|
data_93 += isAB ? 2 : 0;
|
data_93 += isToRihgt ? 4 : 0;
|
clientData[93] = (byte)data_93;
|
clientData[94] = (byte)diffNum;
|
|
TransferData(station, clinet, clientData);
|
Create(clinet, station, requestType);
|
}
|
}
|
}
|
}
|
|
private void Create(PLCClient clinet, StationInfo station, int requestType)
|
{
|
try
|
{
|
//入口上料
|
if (station.stationType == "in" && requestType == 1)
|
{
|
WCSCommon.CreateTask(station, true);
|
}
|
//出口卸料
|
else if (station.stationType == "out" && requestType == 2)
|
{
|
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">AGV的PLC</param>
|
/// <param name="eq_Client">主机设备PLC</param>
|
/// <param name="eqData">读的主机设备状态</param>
|
private void TransferData(StationInfo station, PLCClient eq_Client, byte[] eqData)
|
{
|
var agv_Client = WIDESEA_WCS.WCSService.Clients.FirstOrDefault(t => t.PLCName == station.agvCenterName);
|
if (agv_Client != null)
|
{
|
//读AGV
|
var agvData = (byte[])agv_Client.ReadDBValue(station.agvDBList[0], 100);
|
int hreat = (int)agvData[0];
|
int step = (int)agvData[90 + 1];
|
bool waring = agvData[92] == 0x1;
|
|
//写涂布主机流程步骤
|
eq_Client.OmronPLCClient.Write(station.dbData["W_step"], step);
|
eq_Client.OmronPLCClient.Write(station.dbData["W_waring"], waring);
|
if (station.stationType == "in")
|
{
|
eq_Client.OmronPLCClient.Write(station.dbData["W_hreat"], hreat);
|
var material_Type = DataTrans.GetStr(agvData, 26);
|
eq_Client.OmronPLCClient.Write(station.dbData["W_materialtype"], material_Type);
|
}
|
//写给AGV
|
agv_Client.WriteDBValue(station.agvDBList[1], eqData);
|
}
|
else
|
{
|
WriteLog.GetLog().Write($"【异常】{station.agvCenterName}，读取调度中心PLC失败" + "\n", eq_Client.PLCName);
|
}
|
}
|
}
|
}
|
