using FreeSql;
|
using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Reflection;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_Comm.ItemDB;
|
using WIDESEA_Comm.LogInfo;
|
using WIDESEA_Core.EFDbContext;
|
using WIDESEA_Entity.DomainModels;
|
using WIDESEA_WCS.IRepositories;
|
using WIDESEA_WCS.IServices;
|
using WIDESEA_WCS.Repositories;
|
using WIDESEA_WCS.Services;
|
using WIDESEA_WCS.WCSClient;
|
using static System.Collections.Specialized.BitVector32;
|
|
namespace WIDESEA_WCS
|
{
|
/// <summary>
|
/// 一二单元调度
|
/// </summary>
|
[DisallowConcurrentExecution]
|
public class One_two_unitJob : IJob
|
{
|
public Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
var client = context.JobDetail.JobDataMap.Get("JobParams") as PLCClient;
|
if (client == null)
|
{
|
return Task.CompletedTask;
|
}
|
|
//自动重连
|
if (!client.IsConnected)
|
{
|
client.Connect();
|
return Task.CompletedTask;
|
}
|
|
DoAction(client);
|
}
|
catch { }
|
return Task.CompletedTask;
|
}
|
static List<GDXDB> gDXDBs = new List<GDXDB>();
|
private void DoAction(PLCClient client)
|
{
|
try
|
{
|
#region 读写方法、日志、执行时间
|
//client.Write("DB400.DBX0", "123456");
|
//client.WriteByOrder("R_wheel_SN", "123456", "4.1");
|
//client.WriteByOrder("R_wheel_SN", "666666", "4.2");
|
|
//var res = client.Read<string>("DB400.DBX0", 20);
|
//var res1 = client.ReadByOrder<string>("R_wheel_SN", "4.1");
|
//var res2 = client.ReadByOrder<string>("R_wheel_SN", "4.2");
|
|
//日志写入
|
//WriteDBLog.Info("一二单元调度", "4.1:" + res1 + ";4.2:" + res2, "PCS");
|
|
//执行完成时间
|
//Console.WriteLine(DateTime.Now);
|
#endregion
|
|
#region 添加PLC地址信息
|
//VOLContext Context = new VOLContext();
|
//Idt_plcinfodetailRepository dt_PlcinfodetailService = new dt_plcinfodetailRepository(Context);
|
//List<dt_plcinfodetail> plcinfodetails = new List<dt_plcinfodetail>();
|
//for (int i = 106; i <= 110; i++)
|
//{
|
// dt_plcinfodetail dt_Plcinfodetail = new dt_plcinfodetail()
|
// {
|
// plcdetail_id = Guid.NewGuid(),
|
// plcdetail_iotype = "One_two_unit",
|
// plcdetail_db = "DB400",
|
// plcdetail_value = "DBX" + ((i - 1) * 30),
|
// plcdetail_valtype = "string",
|
// plcdetail_len = 20,
|
// plcdetail_name = "R_wheel_SN",
|
// plcdetail_number = "7." + (i - 80),
|
// plcdetail_remark = "读取车轮SN号"
|
// };
|
// plcinfodetails.Add(dt_Plcinfodetail);
|
// dt_plcinfodetail dt_Plcinfodetail1 = new dt_plcinfodetail()
|
// {
|
// plcdetail_id = Guid.NewGuid(),
|
// plcdetail_iotype = "One_two_unit",
|
// plcdetail_db = "DB400",
|
// plcdetail_value = "DBX" + ((i - 1) * 30 + 20),
|
// plcdetail_valtype = "int",
|
// plcdetail_name = "R_wheel_type",
|
// plcdetail_number = "7." + (i - 80),
|
// plcdetail_remark = "读取车轮类型"
|
// };
|
// plcinfodetails.Add(dt_Plcinfodetail1);
|
// dt_plcinfodetail dt_Plcinfodetail2 = new dt_plcinfodetail()
|
// {
|
// plcdetail_id = Guid.NewGuid(),
|
// plcdetail_iotype = "One_two_unit",
|
// plcdetail_db = "DB400",
|
// plcdetail_value = "DBX" + ((i - 1) * 30 + 22),
|
// plcdetail_valtype = "byte",
|
// plcdetail_name = "R_part_status",
|
// plcdetail_number = "7." + (i - 80),
|
// plcdetail_remark = "读取车轮零件状态"
|
// };
|
// plcinfodetails.Add(dt_Plcinfodetail2);
|
// dt_plcinfodetail dt_Plcinfodetail3 = new dt_plcinfodetail()
|
// {
|
// plcdetail_id = Guid.NewGuid(),
|
// plcdetail_iotype = "One_two_unit",
|
// plcdetail_db = "DB400",
|
// plcdetail_value = "DBX" + ((i - 1) * 30 + 23),
|
// plcdetail_valtype = "byte",
|
// plcdetail_name = "R_part_process",
|
// plcdetail_number = "7." + (i - 80),
|
// plcdetail_remark = "读取车轮零件工艺"
|
// };
|
// plcinfodetails.Add(dt_Plcinfodetail3);
|
// dt_plcinfodetail dt_Plcinfodetail4 = new dt_plcinfodetail()
|
// {
|
// plcdetail_id = Guid.NewGuid(),
|
// plcdetail_iotype = "One_two_unit",
|
// plcdetail_db = "DB400",
|
// plcdetail_value = "DBX" + ((i - 1) * 30 + 24),
|
// plcdetail_valtype = "byte",
|
// plcdetail_name = "R_machine_nr",
|
// plcdetail_number = "7." + (i - 80),
|
// plcdetail_remark = "读取辊道machine_nr"
|
// };
|
// plcinfodetails.Add(dt_Plcinfodetail4);
|
// dt_plcinfodetail dt_Plcinfodetail5 = new dt_plcinfodetail()
|
// {
|
// plcdetail_id = Guid.NewGuid(),
|
// plcdetail_iotype = "One_two_unit",
|
// plcdetail_db = "DB400",
|
// plcdetail_value = "DBX" + ((i - 1) * 30 + 25),
|
// plcdetail_valtype = "byte",
|
// plcdetail_name = "R_direction",
|
// plcdetail_number = "7." + (i - 80),
|
// plcdetail_remark = "读取辊道direction"
|
// };
|
// plcinfodetails.Add(dt_Plcinfodetail5);
|
//}
|
//dt_PlcinfodetailService.AddRange(plcinfodetails, true);
|
#endregion
|
|
VOLContext Context = new VOLContext();
|
Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context);
|
Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context);
|
|
PropertyInfo[] propertyInfos = typeof(GDXDB).GetProperties();//获取所有属性
|
var plc = repository.FindFirst(x => x.plcinfo_name == client.PLCName);
|
var numbers = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep).GroupBy(x => x.plcdetail_number).ToList();
|
foreach (var number in numbers)
|
{
|
GDXDB dBItem = gDXDBs.Where(x => x.R_Name == number.Key).FirstOrDefault();
|
if (dBItem == null)
|
{
|
dBItem = new();
|
dBItem.OnReadSignal += HandleReadSignal;
|
gDXDBs.Add(dBItem);
|
//object obj = dBItem.R_part_status;
|
//dBItem.R_part_status = client.Read<byte>(number.Key);
|
}
|
List<dt_plcinfodetail> details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == number.Key).ToList();
|
for (int i = 0; i < propertyInfos.Length; i++)
|
{
|
if (i == 0)
|
{
|
dBItem.R_Name = number.Key;
|
}
|
else
|
{
|
object readData = DBExtension.Read(details.Where(x => x.plcdetail_name == propertyInfos[i].Name).FirstOrDefault(), client);
|
if (readData != null) { }
|
object obj = propertyInfos[i].GetValue(dBItem);
|
if (obj != readData)
|
propertyInfos[i].SetValue(dBItem, readData);
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine(ex.Message);
|
}
|
}
|
|
public void HandleReadSignal(GDXDB DBItem)
|
{
|
VOLContext Context = new VOLContext();
|
Idt_ActualProductionRepository repository = new dt_ActualProductionRepository(Context);
|
var info = repository.FindFirst(x => x.SN == DBItem.R_wheel_SN);//查询车轮的详细信息
|
if (info != null)
|
{
|
//告诉桁架
|
|
}
|
}
|
}
|
}
|
