using Hanhe.iWCS.Business;
|
using Hanhe.iWCS.Common;
|
using Hanhe.iWCS.Interface;
|
using Hanhe.iWCS.TaizhouGEMTwoTCP;
|
using Hanhe.iWCS.Model;
|
using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using System.Linq;
|
using MongoDB.Bson;
|
using Hanhe.iWCS.MData;
|
using Newtonsoft.Json;
|
using MongoDB.Driver.Builders;
|
using static Hanhe.iWCS.TaizhouGEMTwoProtocol.MESHelper;
|
using MongoDB.Driver;
|
using static Hanhe.iWCS.TaizhouGEMTwoProtocol.ProcessHelper;
|
using static Hanhe.iWCS.TaizhouGEMTwoProtocol.ApiHelper;
|
using System.Threading;
|
using Hanhe.iWCS.Model.AMS;
|
using static Hanhe.iWCS.TaizhouGEMTwoProtocol.ERPService;
|
using static Hanhe.iWCS.TaizhouGEMTwoProtocol.AMSHelper;
|
using static Hanhe.iWCS.TaizhouGEMTwoProtocol.ProtocolAnalysis;
|
using log4net.Appender;
|
using System.Net.Configuration;
|
|
namespace Hanhe.iWCS.TaizhouGEMTwoProtocol
|
{
|
public class PLCControl : IPLCControl
|
{
|
private EquipmentCommandEQBLL commandBLL = new EquipmentCommandEQBLL();
|
|
/// <summary>
|
/// PLC 数据发送
|
/// </summary>
|
/// <param name="command"></param>
|
/// <returns></returns>
|
public void SendMessage(EquipmentCommandEQ command)
|
{
|
bool sended = SessionInstance.Instance.PLCSend(command.EquipmentIP, int.Parse(command.EquipmentPort), command.CommandText);
|
if (sended)
|
{
|
//CMMLog.Info("设备指令发送成功;EquipmentCode=" + command.EquipmentCode + "-指令=" + command.CommandText);
|
commandBLL.UpdateCommandEQStatus(command._id, Constants.COMMANDEQ_STATUS_SENDED, command.SendCount);
|
}
|
else
|
{
|
//CMMLog.Info("设备指令发送失败;EquipmentCode=" + command.EquipmentCode + "-指令=" + command.CommandText);
|
commandBLL.UpdateCommandEQStatus(command._id, Constants.COMMANDEQ_STATUS_SEND_ERRORS, command.SendCount);
|
}
|
}
|
|
/// <summary>
|
/// 处理光电信息
|
/// </summary>
|
/// <param name="data"></param>
|
public static void Analysis(string data) {
|
//3f 00 01 00 00 00 24 24
|
}
|
|
#region 纯3楼设备任务
|
|
#region 3楼包装机取料至复称平台流程——无需回报WMS任务状态——3楼包装取料——已完成（待测试，时间戳处理）
|
|
#region 收到包装机下料信号1，开始判断复称平台是否满足条件，选择性下发任务
|
|
/// <summary>
|
/// 3楼包装机取料至复称平台流程——任务开始前，判断包装机有没有下线信号，并判断当前复称平台是否NG以及有没有任务在进行中
|
/// </summary>
|
/// <param name="a"></param>
|
internal static void CheckPackingMachine(Settings.PlcInfo pmInfo)
|
{
|
//var count = MongoDBSingleton.Instance.FindOne<>//occupy
|
var count = MongoDBSingleton.Instance.FindOne<MachineInfo>(Query.EQ("occupy", "1"), "MachineInfo");
|
|
//检查包装机通道0是否有下料信号，如果有生成下料任务。线程循环读取，无需设置循环。——通道0参数为1
|
if(count == null)
|
{
|
// var secondInfo = MongoDBSingleton.Instance.FindOne<secondResult>(Query.EQ("Bit", pmInfo.location), "secondResult");
|
// if(secondInfo == null || secondInfo.Status == "OK")
|
// {
|
if (PickUpStartFree(pmInfo.location) && PickUpEndFree(pmInfo.location))
|
{
|
try
|
{
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = pmInfo.readAddr,
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
if (result != null && result.errCode == 0)
|
{
|
CMMLog.Debug($"包装下线流程-{pmInfo.location}：读取包装机通道号为：{pmInfo.readAddr}里面的值为{result.result[0]}");
|
//Console.WriteLine($"包装下线流程：读取包装机通道号为：{pmInfo.readAddr}里面的值为{result.result[0]}");
|
if (result != null && result.errCode == 0 && result.result.Count() > 0)
|
{
|
//1：取料
|
if (result.result[0] == 1)
|
{
|
string PlcBit02 = Settings.GetPlcInfo().Where(a => a.deviceType == "2").FirstOrDefault().location;
|
//包装下线任务，终点为复称位置（这里判断包装机起点，复称起点终点均无任务，则推送任务）
|
if (ProcessHelper.PickUpStartFree(pmInfo.location) && ProcessHelper.CheckEndFree(PlcBit02) && ProcessHelper.PickUpStartFree(PlcBit02))
|
{
|
//判断复称位置，没有货并且不为NG(ng参数0，1，2——0，不确定（包装机刚开始工作时）1，ok 2，ng)
|
var state = GetSecondWeighState(pmInfo.location);
|
CMMLog.Debug($"包装下线流程-{pmInfo.location}：判断复称位置空满状态为:{state.full},ng状态为：{state.ng}");
|
if (state.full == 0)
|
{
|
if (Settings.mesOpen == "0")
|
{
|
//可以生成任务，调mes接口获取生产信息 2022.7.28 变更 MES可能需要1~2年才能上线，先把MES功能注销
|
var info = MESHelper.GetPackingMachineInfo(pmInfo.location);
|
if (info != null)
|
{
|
CMMLog.Debug($"包装下线流程：获取MES之后进入info判断！");
|
Console.WriteLine($"包装下线流程：获取MES之后进入info判断！");
|
var trayCode = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
addr = pmInfo.readAddr + 10,
|
dataNum = 90,//ERP变更：90 原先：80
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
if (trayCode.errCode == 0 && trayCode.result.Length == 90)
|
{
|
//获取托盘码等信息 读取通道 10、11、12的数据作为托盘码 读取其它通道 重量 叠包等信息 所有数据存入MachineInfo表
|
string location = "";
|
GetMachineData(trayCode.result,ref location);
|
var tray = MongoDBSingleton.Instance.FindOne<MachineInfo>(Query.EQ("machineNo", pmInfo.location), "MachineInfo");
|
if (tray != null)
|
{
|
if (tray.addState == 0)
|
{
|
MongoDBSingleton.Instance.Remove<MachineInfo>(Query.EQ("machineNo", pmInfo.location), "MachineInfo", RemoveFlags.None);
|
if (ERPService.ERPSwitch01 == "0") MongoDBSingleton.Instance.Remove<MachineInfoTwo>(Query.EQ("machineNo", pmInfo.location), "MachineInfoTwo", RemoveFlags.Single);
|
CMMLog.Debug($"包装下线流程：叠托层数为0，不允许生成任务");
|
}
|
else if (tray.trayCode != "0" && tray.trayCode != "" && tray.trayCode != null)
|
{
|
//AMSHelper.CreateTask(DateTime.Now.Ticks.ToString(), pmInfo.location, GetSecondWeighBit(), "3楼包装取料", 1, JsonConvert.SerializeObject(info));
|
int i = 1;
|
while (i == 1)
|
{
|
var amsResult = AMSHelper.CreateTask(DateTime.Now.Ticks.ToString(), pmInfo.location, PlcBit02, "3楼包装取料", 0, tray.trayCode);
|
if (amsResult.success)
|
{
|
i = 2;
|
string weight = (int.Parse(tray.oneTrayWeight) / 100).ToString();
|
ERPService.packageInfo(tray.machineNo, tray.trayCode, "", weight);
|
CMMLog.Debug($"包装下线流程：AMS调用API成功！");
|
}
|
else CMMLog.Debug($"包装下线流程：AMS调用API失败，开始重新调用！");
|
}
|
CMMLog.Debug($"包装下线流程：接受并读取包装机通道里面的物料信息，并将其写入MachineInfo中间表中！接收到的信息：{JsonConvert.SerializeObject(trayCode.result)}");
|
}
|
}
|
else
|
{
|
CMMLog.Debug($"包装下线流程：tray==null!");
|
Console.WriteLine($"包装下线流程：tray==null!");
|
}
|
}
|
else
|
{
|
CMMLog.Debug($"包装下线流程：3楼包装至复称获取MODBUS值错误！trayCode.errCode:{trayCode.errCode},trayCode.result.Length:{trayCode.result.Length}");
|
Console.WriteLine($"包装下线流程：3楼包装至复称获取MODBUS值错误！trayCode.errCode:{trayCode.errCode},trayCode.result.Length:{trayCode.result.Length}");
|
}
|
}
|
else CMMLog.Debug($"包装下线流程：MES接口数据返回空值！MES接口数据:{info}");
|
}
|
else if (Settings.mesOpen == "1")
|
{
|
//可以生成任务，调mes接口获取生产信息 2022.7.28 变更 MES可能需要1~2年才能上线，先把MES功能注销
|
CMMLog.Debug($"包装下线流程-{pmInfo.location}：获取MES之后进入info判断！");
|
var trayCode = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
addr = pmInfo.readAddr + 10,
|
dataNum = 90,////ERP变更：90 原先：80
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
if (trayCode.errCode == 0 && trayCode.result.Length == 90)
|
{
|
//获取托盘码等信息 读取通道 11、12、13的数据作为托盘码 读取其它通道 重量 叠包等信息 所有数据存入MachineInfo表
|
string location = "";
|
string flLoc = "";
|
GetMachineData(trayCode.result, ref location, false);
|
if(pmInfo.location.Contains("FLZT"))
|
{
|
flLoc = pmInfo.location;
|
pmInfo.location = location;
|
}
|
var tray = MongoDBSingleton.Instance.FindOne<MachineInfo>(Query.EQ("machineNo", pmInfo.location), "MachineInfo");
|
if (tray != null)
|
{
|
bool IsContLaterCode = true;
|
if (ERPService.ERPSwitch01 == "1")
|
{
|
string employeeId = "G" + tray.trayCodeWeight.PadLeft(7, '0');
|
// 判断当前【员工编号】通道信息读出来的员工编号是否已经存在于我们的员工信息表-ERPEmployeeTable(查询字段-employee_id)
|
var erpEmployeeInfo = MongoDBSingleton.Instance.FindOne<ERPEmployeeTable>(Query.EQ("employee_id", employeeId), "ERPEmployeeTable");
|
if (erpEmployeeInfo == null) IsContLaterCode = false;
|
}
|
|
if (IsContLaterCode)
|
{
|
if (tray.addState == 0)
|
{
|
MongoDBSingleton.Instance.Remove<MachineInfo>(Query.EQ("machineNo", pmInfo.location), "MachineInfo", RemoveFlags.None);
|
if (ERPService.ERPSwitch01 == "0") MongoDBSingleton.Instance.Remove<MachineInfoTwo>(Query.EQ("machineNo", pmInfo.location), "MachineInfoTwo", RemoveFlags.None);
|
CMMLog.Debug($"包装下线流程-{pmInfo.location}：叠托层数为0，不允许生成任务");
|
}
|
else if (tray.trayCode != "0" && !string.IsNullOrEmpty(tray.trayCode))
|
{
|
string timeStamp = ProcessHelper.GetTimeStamp(31, 1, 1);
|
pmInfo.location = !string.IsNullOrEmpty(flLoc) ? flLoc : pmInfo.location;
|
HHAmsExecuteResult req = AMSHelper.CreateTask(DateTime.Now.Ticks.ToString(), pmInfo.location, PlcBit02, "3楼包装取料", 0, tray.trayCode, timeStamp);
|
if (req.success)
|
{
|
string weight = (double.Parse(tray.oneTrayWeight) / 100).ToString();
|
//int weight = int.Parse(tray.oneTrayWeight) / 100;
|
ERPService.packageInfo(tray.machineNo, tray.trayCode, tray.lotNo, weight);
|
}
|
}
|
}
|
else
|
{
|
CMMLog.Info($"包装下线流程-{pmInfo.location}：员工编码不存在，员工编码：G{tray.trayCodeWeight.PadLeft(7, '0')}");
|
//检索员工信息失败写入对方通道值1 读取地址+3
|
var wirteall01 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = pmInfo.readAddr + 3,
|
host = pmInfo.ip,
|
port = pmInfo.port,
|
data = 1
|
});
|
}
|
}
|
else CMMLog.Debug($"包装下线流程-{pmInfo.location}：tray==null!");
|
}
|
else CMMLog.Debug($"包装下线流程-{pmInfo.location}：3楼包装至复称获取MODBUS值错误！trayCode.errCode:{trayCode.errCode},trayCode.result.Length:{trayCode.result.Length}");
|
}
|
}
|
else
|
{
|
var task = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.Or(Query.EQ("CN_S_START_BIT", PlcBit02), Query.EQ("CN_S_END_BIT", PlcBit02)), "TN_I_TASK_MST");
|
if (task != null) CMMLog.Debug($"包装下线流程-{pmInfo.location}：检查复称中间表是否为空，不为空则检查其数据full以及ng是否为0和1！任务号为：{task.CN_S_TASK_NO}");
|
else CMMLog.Debug("包装下线流程-{pmInfo.location}：检查复称中间表是否为空，不为空则检查其数据full以及ng是否为0和1！");
|
}
|
}
|
else CMMLog.Debug($"包装下线流程-{pmInfo.location}：包装机起点或者复称起点终点有任务在执行中！包装机点位：{pmInfo.location},复称点位：{PlcBit02}");
|
}
|
else CMMLog.Debug($"包装下线流程-{pmInfo.location}：包装机通道0里面的数据不为1！result为：{JsonConvert.SerializeObject(result)}");
|
}
|
else CMMLog.Debug($"包装下线流程-{pmInfo.location}：未读取到包装机通道0里面的数据！！！result:{JsonConvert.SerializeObject(result)}");
|
}
|
else CMMLog.Debug($"包装下线流程-{pmInfo.location}：未读取到包装机通道0里面的数据！！！result:{JsonConvert.SerializeObject(result)}");
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Debug($"包装下线流程-{pmInfo.location}:" +ex.Message);
|
}
|
}
|
else
|
{
|
//var taskNo = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.Or(Query.EQ("CN_S_START_BIT", pmInfo.location), Query.EQ("CN_S_END_BIT", pmInfo.location)), "TN_I_TASK_MST");
|
//string task = "", startbit = "", endbit = "";
|
//if (taskNo != null)
|
//{
|
// task = taskNo.CN_S_TASK_NO;
|
// startbit = taskNo.CN_S_START_BIT;
|
// endbit = taskNo.CN_S_END_BIT;
|
//}
|
CMMLog.Debug($"当前包装机起点终点有任务正在执行，请确认当前包装机的任务是否取货卸货完成！包装机货位编码：{pmInfo.location}");
|
}
|
// }
|
// else CMMLog.Info($"当前包装机出现故障，无法生成任务。包装机号：{pmInfo.location}");
|
}
|
else CMMLog.Debug($"当前machineInfo中间表已存在数据：{JsonConvert.SerializeObject(count)}");
|
}
|
|
#endregion
|
|
#region 包装机MODBUS交互（开始取料，取料完成）
|
|
/// 小车请求进料 1 AMS写，PLC读 1-请求进入；2-到位后，请求接驳滚动；3-取货完成；4-离开安全门外，清零通道
|
/// 设备允许出料 1 PLC写，AMS读 1-XXXXXXXX；2-允许进入；3-接驳滚动，送出物料 ；4-结束；5-安全门关闭
|
|
/// <summary>
|
/// 小车到达包装机安全门口请求进入
|
/// </summary>
|
/// <param name="ips"></param>
|
internal static void PickUpFullDoorUnload(string ip, string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.ip == ip).FirstOrDefault();
|
if(plc.device != "24")
|
{
|
//ASM写入通道0小车动作，1-取料
|
int[] num = new int[2] { 1, 1 };
|
var writeRes0 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
host = ip,
|
addr = plc.writeAddr,
|
data = num,//原先是1,单个写入
|
port = plc.port
|
});
|
DateTime dateTime = DateTime.Now;
|
if (writeRes0.errCode == 0)
|
{
|
//小车请求进入安全门交互
|
//小车请求进料，并且查询设备是否允许AGV进入
|
//读地址1设备是否 2-可以进入
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = ip,
|
addr = plc.readAddr + 1,
|
port = plc.port
|
});
|
CMMLog.Debug($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
Console.WriteLine($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 2)
|
{
|
//设备允许进入，改参数通知AGV
|
WorkFlowAction.TrackLog(taskNo, 10, 1012, "success");
|
TSHelper.GoToAGV(taskNo, 10, 1);
|
}
|
}
|
else CMMLog.Debug($"包装下线：1012，readRes：{readRes},readRes.errCode:{readRes.errCode}");
|
}
|
}
|
else
|
{
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.writeAddr + 1,
|
data = 1
|
});
|
|
if (writeRes.errCode == 0)
|
{
|
//小车请求进入安全门交互
|
//小车请求进料，并且查询设备是否允许AGV进入
|
//读地址1设备是否 2-可以进入
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = ip,
|
addr = plc.readAddr + 1,
|
port = plc.port
|
});
|
CMMLog.Debug($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
Console.WriteLine($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 2)
|
{
|
//设备允许进入，改参数通知AGV
|
WorkFlowAction.TrackLog(taskNo, 10, 1012, "success");
|
TSHelper.GoToAGV(taskNo, 10, 1);
|
}
|
}
|
else CMMLog.Debug($"包装下线：1012，readRes：{readRes},readRes.errCode:{readRes.errCode}");
|
}
|
}
|
}
|
/// <summary>
|
/// 小车请求取货
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="taskNo"></param>
|
internal static void PickUpFullUnload(string ip , string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.ip == ip).FirstOrDefault();
|
if (ip != "")
|
{
|
//小车请求出料，并且查询设备是否允许AGV进入
|
//读地址2设备是否 2-允许进料 保险起见，可以不读
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = ip,
|
addr = plc.readAddr + 1,
|
port = plc.port
|
});
|
CMMLog.Debug($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
Console.WriteLine($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 2)
|
{
|
//TSHelper.GoToAGV(taskNo, 10, 2);//原先先改AGV参数
|
var writeRes1 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = ip,
|
addr = plc.writeAddr + 1,
|
data = 2,
|
port = plc.port
|
});
|
if(writeRes1.errCode == 0) TSHelper.GoToAGV(taskNo, 10, 2);
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为2.");
|
Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为2.");
|
}
|
}
|
else CMMLog.Debug($"包装下线，1112，readRes={readRes}");
|
}
|
else CMMLog.Debug($"包装下线，1112，ip=null!");
|
}
|
/// <summary>
|
/// 小车取货完成--二期协议无此指令动作
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="taskNo"></param>
|
internal static void PickUpFullComplete(string ip, string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.ip == ip).FirstOrDefault();
|
if (ip != "")
|
{
|
//小车请求出料，并且查询设备是否允许AGV进入
|
//读地址2设备是否 2-允许进料
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = ip,
|
addr = plc.readAddr+1,
|
port = plc.port
|
});
|
CMMLog.Debug($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
Console.WriteLine($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
DateTime dateTime = DateTime.Now;
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 3)
|
{
|
var writeRes1 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = ip,
|
addr = plc.writeAddr+1,
|
data = 3,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为3.");
|
Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为3.");
|
}
|
else if(readRes.result[0] == 4)
|
{
|
WorkFlowAction.TrackLog(taskNo, 10, 1212, "success");
|
TSHelper.GoToAGV(taskNo, 10, 5);
|
}
|
}
|
else CMMLog.Debug($"包装下线，1212，readRes={readRes}!");
|
}
|
else CMMLog.Debug($"包装下线，1212，ip=null!");
|
}
|
/// <summary>
|
/// 小车卸货完成离开安全门后通知包装机
|
/// </summary>
|
/// <param name="ips"></param>
|
/// <param name="taskNo"></param>
|
internal static void PickUpFullDoorComplete(string ip, string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.ip == ip).FirstOrDefault();
|
if (plc != null && !plc.location.Contains("FLZT"))
|
{
|
//写入包装机--安全门关门指令
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = ip,
|
addr = plc.writeAddr + 1,
|
data = 3,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为4.");
|
Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为4.");
|
}
|
else CMMLog.Debug($"包装下线，4，ip=null!");
|
}
|
#endregion
|
|
#region 复称平台交互
|
|
///小车请求进料 1 AMS写，PLC读 1-请求进入；2-小车进料，输送托盘；3-XXXXXXX
|
///设备允许出料 1 PLC写，AMS读 1-XXXXXXXX；2-允许进料，开始滚动；3-上料完成
|
///复称平台小车动作： 1：上料复称；2：上砝码教称；3：取复称NG托盘，4：取砝码到包装机
|
|
/// <summary>
|
///复称平台安全请求进入——因为现场需求，所以额外增加一个类似安全门的交互，直接改参数就行
|
/// </summary>
|
internal static void SecondWeightSafe(string ip,string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.ip == ip).FirstOrDefault();
|
//ASM写入小车动作，1：上料复称；2：上砝码教称；3：取复称NG托盘，4：取砝码到包装机
|
int[] num = new int[2] { 1, 1 };
|
var writeRes0 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
host = ip,
|
addr = plc.writeAddr,
|
data = num,//原先是1,单个写入
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr}里面数据为{JsonConvert.SerializeObject(num)}.");
|
Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr}里面数据为{JsonConvert.SerializeObject(num)}.");
|
///小车和复称位对接
|
//小车请求进料，并且查询设备是否允许AGV进入
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = plc.ip,
|
addr = plc.readAddr + 1,
|
port = plc.port
|
});
|
CMMLog.Debug($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
Console.WriteLine($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if(readRes.result[0] == 2)
|
{
|
WorkFlowAction.TrackLog(taskNo, 10, 1013, "success");
|
TSHelper.GoToAGV(taskNo, 10, 3);
|
}
|
}
|
}
|
|
/// <summary>
|
/// 复称卸货
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="cN_S_TASK_NO"></param>
|
internal static void CheckUpReqUnload(string ip, string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.location == ip).FirstOrDefault();
|
///小车和复称位对接
|
if (plc != null)
|
{
|
//设备允许进入，改参数通知AGV
|
WorkFlowAction.TrackLog(taskNo, 10, 1113, "success");
|
TSHelper.GoToAGV(taskNo, 10, 4);
|
CMMLog.Debug($"改AGV参数：10，4");
|
//判断任务起点，找到起点包装机设备号，在中间表MachineInfo中查找上一台设备（包装机）的数据，通过modbus通道传入（数据需要转换，ASCII转16short，可能还需要数据拆分）
|
var taskInfo = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), "TN_I_TASK_MST");
|
if (plc.deviceType == "22")
|
{
|
//四钴车间
|
var machine = MongoDBSingleton.Instance.FindOne<MachineInfoTetracobalt>(Query.EQ("trayCode", taskInfo.CN_S_BATCH_NO), "MachineInfoTetracobalt");
|
if (machine != null)
|
{
|
CMMLog.Debug("进入machine判断");
|
//向复称卸货复称，并将从包装机获取到的数据写入通道中
|
#region 多个数据写入MODBUS
|
|
var arr = JsonConvert.DeserializeObject<List<int>>(machine.jsonData);
|
int[] num = new int[22];
|
for (int i = 0; i <= 21; i++) num[i] = arr[i];
|
|
// 14,15 替换为时间戳，后续处理
|
//num[14] = int.Parse(machine.overlappingLayers);
|
//CMMLog.Debug($"machine.machinedown[14]:{num[14]}");
|
//num[15] = int.Parse(machine.bagNo);
|
//CMMLog.Debug($"machine.machinedown[15]:{num[15]}");
|
//时间戳处理
|
//for (int b = 16; b <= 17; b++)
|
//{
|
// int k = b % 2 == 0 ? 0 : 16;
|
// num[b] = Convert.ToInt32(Convert.ToString(int.Parse(taskInfo.Ext2), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
//}
|
|
CMMLog.Debug($"{JsonConvert.SerializeObject(num)}");
|
var wirteall = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
addr = plc.writeAddr + 5,
|
host = plc.ip,
|
data = num,
|
port = plc.port
|
});
|
var writeRes1 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
addr = plc.writeAddr + 1,
|
data = 2,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为2.");
|
Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为2.");
|
#endregion
|
}
|
else CMMLog.Debug($"machine判断错误，为null!");
|
}
|
else
|
{
|
var machine = MongoDBSingleton.Instance.FindOne<MachineInfo>(Query.EQ("trayCode", taskInfo.CN_S_BATCH_NO), "MachineInfo");
|
if (machine != null)
|
{
|
CMMLog.Debug("进入machine判断");
|
//向复称卸货复称，并将从包装机获取到的数据写入通道中
|
#region 多个数据写入MODBUS
|
|
var arr = JsonConvert.DeserializeObject<List<int>>(machine.jsonData);
|
int[] num = new int[18];
|
for (int i = 0; i <= 15; i++) num[i] = arr[i];
|
|
// 14,15 替换为时间戳，后续处理
|
num[14] = int.Parse(machine.overlappingLayers);
|
CMMLog.Debug($"machine.machinedown[14]:{num[14]}");
|
num[15] = int.Parse(machine.bagNo);
|
CMMLog.Debug($"machine.machinedown[15]:{num[15]}");
|
//时间戳处理
|
for (int b = 16; b <= 17; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(taskInfo.Ext2), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
|
CMMLog.Debug($"{num}");
|
Console.WriteLine(num);
|
var wirteall = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
addr = plc.writeAddr + 10,
|
host = plc.ip,
|
data = num,
|
port = plc.port
|
});
|
var writeRes1 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
addr = plc.writeAddr + 1,
|
data = 2,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为2.");
|
Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为2.");
|
#endregion
|
}
|
else CMMLog.Debug($"machine判断错误，为null!");
|
}
|
|
|
}
|
else CMMLog.Debug($"包装下线，1113，ip=null!");
|
}
|
/// <summary>
|
/// 复称卸货完成
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="cN_S_TASK_NO"></param>
|
/// <returns></returns>
|
internal static void CheckUpUnloadComplete(string ip, string cN_S_TASK_NO, int port)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.ip == ip && a.port == port).FirstOrDefault();
|
int[] num = new int[1] { 2 };
|
var writeRes0 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
host = ip,
|
addr = plc.writeAddr + 1,
|
data = num,//原先是1,单个写入
|
port = plc.port
|
});
|
|
var tray = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", cN_S_TASK_NO), "TN_I_TASK_MST");
|
|
var query = Query.And(Query.EQ("actionNo", "1"), Query.EQ("ext1", ip), Query.EQ("ext2", tray.CN_S_BATCH_NO));
|
var ActionControlInfo = MongoDBSingleton.Instance.FindOne<ActionControlModel>(query, "ActionControlModel");
|
if (ActionControlInfo == null)
|
{
|
MongoDBSingleton.Instance.Insert<ActionControlModel>(new ActionControlModel
|
{
|
actionNo = "1",
|
ext1 = ip,
|
ext2 = tray.CN_S_BATCH_NO,
|
ext3 = tray.CN_S_START_BIT,
|
ext4 = port,
|
machince = tray.CN_S_START_BIT
|
}, "ActionControlModel");
|
string PlcBit02 = Settings.GetPlcInfo().Where(a => a.deviceType == "2").FirstOrDefault().location;
|
MongoDBSingleton.Instance.Update<SecondWeighState>(Query.EQ("location", PlcBit02), Update.Set("full",1), "SecondWeighState", UpdateFlags.None);
|
}
|
}
|
/// <summary>
|
/// 复称平台安全退出（已退出）--二期无需执行此指令动作
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="cN_S_TASK_NO"></param>
|
/// <returns></returns>
|
internal static bool SecondWeightSafeComplete(string ip, string cN_S_TASK_NO)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.ip == ip).FirstOrDefault();
|
bool result = true;
|
if(ip != "")
|
{
|
//var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
//{
|
// addr = plc.writeAddr,
|
// data = 0,
|
// host = ip,
|
// port = plc.port
|
//});
|
//CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr}里面数据为0.");
|
//Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr}里面数据为0.");
|
//var wirte1 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
//{
|
// addr = plc.writeAddr + 1,
|
// data = 0,
|
// host = ip,
|
// port = plc.port
|
//});
|
//CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为0.");
|
//Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为0.");
|
result = true;
|
}
|
else
|
{
|
CMMLog.Debug($"包装下线，4，ip=null!");
|
}
|
return result;
|
}
|
|
internal static void SecondWeightActionOne(ActionControlModel model)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.ip == model.ext1 && a.port == model.ext4).FirstOrDefault();
|
|
if (plc != null)
|
{
|
bool req = false;
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 28,
|
addr = plc.readAddr + 1,
|
host = plc.ip,
|
port = plc.port
|
});
|
if (result.result.Length > 0)
|
{
|
if(plc.deviceType == "22")
|
{
|
var newWeight = result.result[19] + "," + result.result[20];
|
MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(Query.EQ("trayCode", model.ext2), Update.Set("secondNg", result.result[2]), UpdateFlags.None);
|
MongoDBSingleton.Instance.Update<MachineInfoTwoTetracobalt>(Query.EQ("trayCode", model.ext2), Update.Set("secondNg", result.result[2]).Set("oneTrayWeightFC",newWeight), UpdateFlags.None);
|
}
|
else
|
{
|
MongoDBSingleton.Instance.Update<MachineInfo>(Query.EQ("trayCode", model.ext2), Update.Set("secondNg", result.result[2]), UpdateFlags.None);
|
}
|
|
//获取从复称平台读出的 时间戳，并转换处理为 string 字符串
|
//string timeStamp = Convert.ToInt32(Completion(result.result[26]) + Completion(result.result[27]), 2).ToString();
|
string timeStamp = Convert.ToInt32(Completion(result.result[25]) + Completion(result.result[26]), 2).ToString();
|
string wmstaskno = "";
|
string traycode = "";
|
|
CMMLog.Info($"SecondWeightActionOne:readData:{JsonConvert.SerializeObject(result.result)},timeStamp:{timeStamp}");
|
|
if (result.result[0] == 3)
|
{
|
int[] num = new int[1] { 0 };
|
var writeRes0 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
host = plc.ip,
|
addr = plc.writeAddr + 1,
|
data = num,//原先是1,单个写入
|
port = plc.port
|
});
|
}
|
|
if (result.result[0] == 3 && result.result[2] == 1)
|
//if (result.result[2] == 1)
|
{
|
CMMLog.Info($"SecondWeightActionOne:准备生成复称入缓存架任务，开始确定托盘号:{model.ext2}");
|
if(plc.deviceType == "22")
|
{
|
req = WMSHelper.WMSInTwo(plc.location, model.ext2, ref wmstaskno, ref traycode, timeStamp);
|
}
|
else
|
{
|
req = WMSHelper.WMSIn(plc.location, model.ext2, ref wmstaskno, ref traycode, timeStamp);
|
}
|
|
ERPService.updatePackageInfo(model.machince, model.ext2, result.result);
|
//if (req) TSHelper.GoToAGV(cN_S_TASK_NO, 10, 6);
|
//else CMMLog.Debug($"WMS返回{req}");
|
//var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
//{
|
// addr = plc.writeAddr + 3,
|
// host = plc.ip,
|
// port = plc.port,
|
// data = 1
|
//});
|
}
|
if (result.result[2] == 2)
|
{
|
//复称平台复称货物NG——进入NG复称流程 调用WMS接口分配货架库位
|
//TSHelper.GoToAGV(cN_S_TASK_NO, 10, 6);
|
if(plc.deviceType == "22")
|
{
|
req = WMSHelper.WMSInTwo(plc.location, model.ext2, ref wmstaskno, ref traycode, timeStamp);
|
}
|
else
|
{
|
req = WMSHelper.WMSIn(plc.location, model.ext2, ref wmstaskno, ref traycode, timeStamp);
|
}
|
|
if (req) CMMLog.Info($"SecondWeightActionOne:复称入缓存架NG流程：WMS生成任务成功！");
|
else CMMLog.Info($"SecondWeightActionOne:复称入缓存架NG流程：WMS生成任务失败！");
|
var plcInfo = Settings.GetPlcInfo().Where(a => a.location == model.ext3).FirstOrDefault();
|
if (plcInfo != null)
|
{
|
CMMLog.Info($"SecondWeightActionOne:复称入缓存架NG流程：写入包装机NG通道数据1！");
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plcInfo.writeAddr + 29,
|
host = plcInfo.ip,
|
port = plcInfo.port,
|
data = 1
|
});
|
}
|
}
|
string PlcBit02 = Settings.GetPlcInfo().Where(a => a.deviceType == "2").FirstOrDefault().location;
|
UpdateBuilder update = Update.Set("ng", result.result[2]);
|
MongoDBSingleton.Instance.Update<SecondWeighState>(Query.EQ("location", PlcBit02), update, "SecondWeighState", UpdateFlags.None);
|
if (req) MongoDBSingleton.Instance.Remove<ActionControlModel>(Query.EQ("_id", model._id), "ActionControlModel", RemoveFlags.Single);
|
}
|
}
|
else CMMLog.Debug($"包装下线，1213，ip=null!");
|
}
|
|
#endregion
|
|
#endregion
|
|
#region 3楼复称平台入3楼双层缓存架流程——需回报WMS任务状态——3楼复称入缓存架——已完成(待测试)
|
|
/// <summary>
|
/// 判断复称通道3里面的值是否为1，并且复称平台上有货，调WMS生成入缓存架任务
|
/// </summary>
|
/// <param name="pmInfo"></param>
|
internal static void SecondWeightInCache(Settings.PlcInfo pmInfo)
|
{
|
//检查复称平台通道3是否值为1，并且复称平台上有货
|
if(ProcessHelper.CheckStartFree(GetSecondWeighBit()) && ProcessHelper.CheckEndFree(GetSecondWeighBit()))
|
{
|
try
|
{
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = pmInfo.readAddr + 3,
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
if (result != null && result.errCode == 0)
|
{
|
//复称平台 重新复核称重后，发送结果给AMS 1:OK，2:NG，当检测到通道2或者4的值为
|
if (result.result[0] == 1)
|
{
|
//判断一下当前复称点有没有任务占用中
|
if (ProcessHelper.CheckStartFree(GetSecondWeighBit()) && ProcessHelper.CheckEndFree(GetSecondWeighBit()))
|
{
|
//判断复称位置，产品NG合格值为1并且复称上有货
|
//var state = GetSecondWeighState(pmInfo.location);
|
//if (state.full == 1 && state.ng == 1)
|
//{
|
//#region 获取托盘码
|
//CMMLog.Info("复称入缓存：获取托盘,fc01");
|
//string traycode = GetMachineTrayCode();
|
//#endregion
|
|
//string wmstaskno = "";
|
//bool req = WMSHelper.WMSIn(pmInfo.location, traycode, ref wmstaskno, ref traycode);
|
//if (req)
|
//{
|
// CMMLog.Info($"复称入缓存架：WMS生成任务成功！");
|
//}
|
//else
|
//{
|
// CMMLog.Info($"复称入缓存架：WMS生成任务失败！");
|
//}
|
//}
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message, ex);
|
}
|
}
|
}
|
|
#region 复称交互
|
|
public static int SecondRelax = 0;
|
/// <summary>
|
/// 请求进入复称取货
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="taskNo"></param>
|
internal static void SecondWeightInCache1012(string ip, string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault();
|
if(ip != null)
|
{
|
///小车和复称位对接
|
if (ip != "")
|
{
|
//小车请求进料，并且查询设备是否允许AGV进入
|
WorkFlowAction.TrackLog(taskNo, 10, 1012, "success");
|
TSHelper.GoToAGV(taskNo, 10, 1);
|
SecondRelax = 0;
|
}
|
else CMMLog.Info($"复称入缓存架，1012，ip=null!");
|
}
|
}
|
/// <summary>
|
/// 取货完成，离开复称，复位通道，并读取设备通道数据
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="cN_S_TASK_NO"></param>
|
internal static void SecondWeightInCache4(string ip, string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault();
|
|
var trayCodeTask = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), "TN_I_TASK_MST");
|
if(trayCodeTask != null)
|
{
|
string trayCodeNo = trayCodeTask.CN_S_BATCH_NO;
|
if(trayCodeNo != "")
|
{
|
var status = MongoDBSingleton.Instance.FindOne<SecondWeighState>(Query.EQ("location", GetSecondWeighBit()), "SecondWeighState");
|
//UpdateBuilder update = Update.Set("full", 0);
|
//if (status.ng != 2)
|
//{
|
// update = Update.Set("ng", 0).Set("full", 0);
|
//}
|
|
UpdateBuilder update = Update.Set("ng", 0).Set("full", 0);
|
CMMLog.Debug($"开始更改复称状态中间表状态：full:0");
|
CMMLog.Debug($"三楼双层缓存架卸货交互：trayCode:{trayCodeTask.CN_S_BATCH_NO}");
|
if (plc.deviceType =="22")
|
{
|
MongoDBSingleton.Instance.Remove<MachineInfoTetracobalt>(Query.EQ("trayCode", trayCodeTask.CN_S_BATCH_NO), "MachineInfoTetracobalt", RemoveFlags.Single);
|
if (ERPService.ERPSwitch01 == "0") MongoDBSingleton.Instance.Remove<MachineInfoTetracobalt>(Query.EQ("trayCode", trayCodeTask.CN_S_BATCH_NO), "MachineInfoTetracobalt", RemoveFlags.Single);
|
}
|
else
|
{
|
MongoDBSingleton.Instance.Remove<MachineInfo>(Query.EQ("trayCode", trayCodeTask.CN_S_BATCH_NO), "MachineInfo", RemoveFlags.Single);
|
if (ERPService.ERPSwitch01 == "0") MongoDBSingleton.Instance.Remove<MachineInfoTwo>(Query.EQ("trayCode", trayCodeTask.CN_S_BATCH_NO), "MachineInfoTwo", RemoveFlags.Single);
|
}
|
|
//MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), Update.Set("CN_S_BATCH_NO", trayCodeNo), UpdateFlags.None);
|
MongoDBSingleton.Instance.Update<SecondWeighState>(Query.EQ("location", GetSecondWeighBit()), update, "SecondWeighState", UpdateFlags.None);
|
SecondRelax = 1;
|
}
|
}
|
if (plc != null)
|
{
|
var writeRes1 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
addr = plc.writeAddr + 3,// + 4
|
data = 1,
|
port = plc.port
|
});
|
//var writeRes1 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
//{
|
// host = plc.ip,
|
// addr = plc.writeAddr + 3,
|
// data = 1,
|
// port = plc.port
|
//});
|
}
|
}
|
|
#endregion
|
|
#region 三楼双层缓存架交互
|
|
/// <summary>
|
/// 请求进入三楼双层缓存架
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="taskNo"></param>
|
internal static void SecondWeightInCache1013(string taskNo)
|
{
|
TSHelper.GoToAGV(taskNo,10,3);
|
}
|
/// <summary>
|
/// 离开三楼双层缓存架回报信息
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="taskNo"></param>
|
internal static bool SecondWeightInCache6(string ip, string cN_S_TASK_NO)
|
{
|
//CMMLog.Info($"三楼双层缓存架卸货交互：trayCode:{trayCode}");
|
|
//var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault();
|
|
//if (plc != null)
|
//{
|
// var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
// {
|
// dataNum = 28,
|
// addr = plc.readAddr + 1,
|
// host = plc.ip,
|
// port = plc.port
|
// });
|
// var tray = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", cN_S_TASK_NO), "TN_I_TASK_MST");
|
// MongoDBSingleton.Instance.Update<MachineInfo>(Query.EQ("trayCode", tray.CN_S_BATCH_NO), Update.Set("secondNg", result.result[2]), UpdateFlags.None);
|
// //获取从复称平台读出的 时间戳，并转换处理为 string 字符串
|
// string timeStamp = Convert.ToInt32(Completion(result.result[26]) + Completion(result.result[27]), 2).ToString();
|
// string wmstaskno = "";
|
// string traycode = "";
|
// if (result.result[0] == 3 && result.result[2] == 1)
|
// {
|
// CMMLog.Debug($"准备生成复称入缓存架任务，开始确定托盘号:{tray.CN_S_BATCH_NO}");
|
// bool req = WMSHelper.WMSIn(plc.location, tray.CN_S_BATCH_NO, ref wmstaskno, ref traycode, timeStamp);
|
// if (req) TSHelper.GoToAGV(cN_S_TASK_NO, 10, 6);
|
// else CMMLog.Debug($"WMS返回{req}");
|
// }
|
// if (result.result[2] == 2)
|
// {
|
// //复称平台复称货物NG——进入NG复称流程 调用WMS接口分配货架库位
|
// TSHelper.GoToAGV(cN_S_TASK_NO, 10, 6);
|
// bool req = WMSHelper.WMSIn(plc.location, tray.CN_S_BATCH_NO, ref wmstaskno, ref traycode, timeStamp);
|
// if (req) CMMLog.Debug($"复称入缓存架NG流程：WMS生成任务成功！");
|
// else CMMLog.Debug($"复称入缓存架NG流程：WMS生成任务失败！");
|
// }
|
// string PlcBit02 = Settings.GetPlcInfo().Where(a => a.deviceType == "2").FirstOrDefault().location;
|
// UpdateBuilder update = Update.Set("ng", result.result[2]).Set("full", 1);
|
// MongoDBSingleton.Instance.Update<SecondWeighState>(Query.EQ("location", PlcBit02), update, UpdateFlags.None);
|
//}
|
//else CMMLog.Debug($"包装下线，1213，ip=null!");
|
|
|
return true;
|
}
|
|
#endregion
|
|
#endregion
|
|
internal static void writeStackingMouth6(string loca, string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.location == loca && a.enable == 1).FirstOrDefault();
|
CMMLog.Info($"3楼缓存架入叠托:收到信号4，查询设备信息：{JsonConvert.SerializeObject(plc)}。");
|
if (plc != null)
|
{
|
var task = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), "TN_I_TASK_MST");
|
CMMLog.Info($"3楼缓存架入叠托:收到信号4，查询任务信息：{JsonConvert.SerializeObject(task)}。");
|
var machine = MongoDBSingleton.Instance.FindOne<WMSInfo>(Query.EQ("trayCode", task.CN_S_BATCH_NO), "WMSInfo");
|
CMMLog.Info($"3楼缓存架入叠托:收到信号4，查询WMSInfo表信息：{JsonConvert.SerializeObject(machine)}。");
|
if (machine != null)
|
{
|
//int[] num = DiePan(machine);
|
//CMMLog.Info($"send num:{JsonConvert.SerializeObject(num)}");
|
//var wirteall01 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
//{
|
// addr = plc.writeAddr + 10,
|
// host = plc.ip,
|
// port = plc.port,
|
// data = num
|
//});
|
|
WriteCacheStackingData(plc, task, machine);
|
|
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
host = plc.ip,
|
port = plc.port,
|
data = 2
|
});
|
}
|
}
|
}
|
|
#region 3楼双层缓存货架到三楼叠托口——需回报WMS任务状态——3楼缓存架入叠托——半完成（待测试）
|
|
/// <summary>
|
/// 判断三楼叠托口是否有允许上料请求（通道1参数1），有就调WMS生成缓存架到叠托口任务
|
/// </summary>
|
/// <param name="pmInfo"></param>
|
internal static void CacheStackingMouth(Settings.PlcInfo pmInfo)
|
{
|
//需要设置时间延迟
|
try
|
{
|
//读取通道1里面参数是否为1，判断叠盘机是否需要上料
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = pmInfo.readAddr + 1,
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
if (result != null && result.errCode == 0)
|
{
|
//参数1表示叠托点申请入料
|
if (result.result[0] == 1)
|
{
|
var tasks = MongoDBSingleton.Instance.Find<TN_I_TASK_MST>(Query.EQ("CN_S_END_BIT", pmInfo.location), "TN_I_TASK_MST");
|
//判断一下当前叠托点是否有任务占用
|
if (ProcessHelper.CheckEndFree(pmInfo.location) && tasks.Count == 0)
|
{
|
//可以生成任务，调WMS接口获取任务信息
|
bool req = WMSHelper.WMSOut(pmInfo.location, "");
|
if (req) CMMLog.Debug($"调用WMS获取碟盘出库生成任务成功！");//现在任务由WMS自己下发，AMS做拦截处理（查询ext1里面对应的任务类型，并更改任务类型）
|
else CMMLog.Debug($"调用WMS获取碟盘出库生成任务失败！");
|
}
|
else CMMLog.Debug($"检查当前叠托点是否有任务占用，或者MST主表中有缓存架入叠盘机的任务！");
|
}
|
}
|
else CMMLog.Debug($"缓存入叠盘机，创建任务，result={result.errMsg}");
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message, ex);
|
}
|
}
|
|
#region 三楼叠托机交互
|
|
/// <summary>
|
/// 请求进入三楼叠托机
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="taskNo"></param>
|
internal static void CacheStackingMouth1013(string ip,string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault();
|
if(plc != null)
|
{
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
host = plc.ip,
|
port = plc.port,
|
data = 2
|
});
|
|
var readres = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = plc.readAddr + 1,
|
host = plc.ip,
|
port = plc.port
|
});
|
if (readres.result[0] == 0 || readres.result[0] == 1)
|
{
|
wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
host = plc.ip,
|
port = plc.port,
|
data = 1
|
});
|
}
|
else if (readres.result[0] == 2)
|
{
|
TSHelper.GoToAGV(taskNo, 10, 3);
|
}
|
}
|
else CMMLog.Debug($"缓存入叠盘机，1013，plc=null!");
|
}
|
|
public static void WriteCacheStackingData(Settings.PlcInfo plc, TN_I_TASK_MST task, WMSInfo machine)
|
{
|
if (plc.deviceType == "23")
|
{
|
//四钴车间
|
var machineTwo = MongoDBSingleton.Instance.FindOne<MachineInfoTwoTetracobalt>(Query.EQ("trayCode", task.CN_S_BATCH_NO), "MachineInfoTwoTetracobalt");
|
CMMLog.Info($"3楼缓存架入叠托:收到信号4，查询MachineInfoTwoTetracobalt表信息：{JsonConvert.SerializeObject(machineTwo)}。");
|
if (machineTwo != null)
|
{
|
CMMLog.Info($"3楼缓存架入叠托:获取数据：{JsonConvert.SerializeObject(machineTwo)},IPort:{plc.ip},{plc.port}");
|
int[] num = DiePanTwoTetracobalt(machine, machineTwo);
|
CMMLog.Info($"3楼缓存架入叠托:写入数据：{JsonConvert.SerializeObject(num)},IPort:{plc.ip},{plc.port}");
|
var wirteall01 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
addr = plc.writeAddr + 5,
|
host = plc.ip,
|
port = plc.port,
|
data = num
|
});
|
CMMLog.Info($"3楼缓存架入叠托:返回数据：{JsonConvert.SerializeObject(wirteall01)},IPort:{plc.ip},{plc.port}");
|
if (wirteall01.errCode == 0)
|
{
|
MongoDBSingleton.Instance.Remove<MachineInfoTwoTetracobalt>(Query.EQ("trayCode", task.CN_S_BATCH_NO), "MachineInfoTwoTetracobalt", RemoveFlags.Single);
|
}
|
}
|
}
|
else
|
{
|
var machineTwo = MongoDBSingleton.Instance.FindOne<MachineInfoTwo>(Query.EQ("trayCode", task.CN_S_BATCH_NO), "MachineInfoTwo");
|
CMMLog.Info($"3楼缓存架入叠托:收到信号4，查询MachineInfoTwo表信息：{JsonConvert.SerializeObject(machineTwo)}。");
|
if (machineTwo != null)
|
{
|
CMMLog.Info($"3楼缓存架入叠托:获取数据：{JsonConvert.SerializeObject(machineTwo)},IPort:{plc.ip},{plc.port}");
|
int[] num = DiePanTwo(machine, machineTwo);
|
CMMLog.Info($"3楼缓存架入叠托:写入数据：{JsonConvert.SerializeObject(num)},IPort:{plc.ip},{plc.port}");
|
var wirteall01 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
addr = plc.writeAddr + 10,
|
host = plc.ip,
|
port = plc.port,
|
data = num
|
});
|
CMMLog.Info($"3楼缓存架入叠托:返回数据：{JsonConvert.SerializeObject(wirteall01)},IPort:{plc.ip},{plc.port}");
|
if (wirteall01.errCode == 0)
|
{
|
MongoDBSingleton.Instance.Remove<MachineInfoTwo>(Query.EQ("trayCode", task.CN_S_BATCH_NO), "MachineInfoTwo", RemoveFlags.Single);
|
}
|
}
|
}
|
}
|
|
private static int[] DiePanTwoTetracobalt(WMSInfo machine, MachineInfoTwoTetracobalt machineInfoTwo)
|
{
|
|
var ErpItemInfo = MongoDBSingleton.Instance.FindOne<ERPItemTable>(Query.EQ("item_code", machineInfoTwo.materialCode), "ERPItemTable");
|
CMMLog.Info($"3楼缓存架入叠托:收到信号4，查询ERPItemTable表信息：{JsonConvert.SerializeObject(ErpItemInfo)}。");
|
|
//偏移量 +11 通道范围： 40311 ~ 40390
|
CMMLog.Info($"叠盘机数据处理.");
|
//10~19通道
|
int[] num = new int[105];//总长度：105
|
|
#region 0~23 => 6~29
|
int a = 0;//员工编号处理
|
for (int b = 0; b <= 4; b++)
|
{
|
num[b] = int.Parse(AsciiToTen(machineInfoTwo.empCode.Substring(a, 2)));
|
}
|
|
a = 0;//托盘码处理
|
for (int b = 5; b <= 7; b++)
|
{
|
//num[b] = int.Parse(AsciiToTen(machine.trayCode.Substring(a, 2)));
|
//a = a + 2;
|
|
num[b] = 0;
|
}
|
num[8] = int.Parse(AsciiToTen(machine.location));//包装机号
|
for (int b = 9; b <= 10; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.productWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 11; b <= 12; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machineInfoTwo.trayCodeWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 13; b <= 14; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.oneTrayWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 15; b <= 16; b++)
|
{
|
var arrTwo = machineInfoTwo.oneTrayWeightFC.Split(',').ToList();
|
num[b] = int.Parse(arrTwo[b - 15]);//复称重量
|
}
|
//for (int b = 15; b <= 16; b++) num[b] = 0;// 叠包后实际重量 && 复称结果 默认：0
|
num[17] = int.Parse(machineInfoTwo.trayType);
|
|
num[18] = machine.addState;//是否需要叠包
|
num[19] = int.Parse(machine.packageCode);//袋号
|
for (int b = 20; b <= 21; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machineInfoTwo.productTime), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
|
//时间戳处理
|
num[22] = 0;
|
num[23] = 0;
|
#endregion
|
|
string pcHead = "";
|
string cpHead = "";
|
string mtHead = "";// 设备的真实物料编码
|
|
#region 35~54 => 41~60 产品批次号
|
|
string data = machineInfoTwo.lotNo;
|
CMMLog.Info($"41~60data1_1:{data}");
|
if (data.Length % 2 != 0)
|
{
|
data = "0" + machineInfoTwo.lotNo;
|
pcHead = "" + machineInfoTwo.lotNo.Substring(0, 1);
|
}
|
CMMLog.Info($"41~60data1_2:{data}");
|
//字符串长度 / 2 = 写入通道数量(两位一转) 列： 3L0050 写入三个通道
|
int maxLength = 34 + (data.Length / 2);// data.Length / 2 至少为 1
|
int aa = 0;
|
for (int i = 35; i <= maxLength; i++)
|
{
|
num[i] = int.Parse(AsciiToTen(data.Substring(aa, 2)));
|
aa = aa + 2;
|
}
|
for (int x = maxLength + 1; x <= 54; x++) num[x] = 0;//将产品批次号无数据的通道全部置为 0
|
#endregion
|
|
#region 55~64 => 61~70 产品型号
|
|
ERPService.HandleItemInfoChina(machine.itemCode, 55, 64, num);// 中文处理 55~64 61~70
|
|
//string data2 = machine.itemCode;
|
//CMMLog.Info($"51~50data2_1:{data2}");
|
//if (data2.Length % 2 != 0)
|
//{
|
// data2 = "0" + machine.itemCode;
|
// cpHead = "" + machine.itemCode.Substring(0, 1);
|
//}
|
//CMMLog.Info($"51~60data2_2:{data2}");
|
//maxLength = 39 + (data2.Length / 2);
|
//int aaa = 0;
|
//for (int i = 40; i <= maxLength; i++)
|
//{
|
// num[i] = int.Parse(AsciiToTen(data2.Substring(aaa, 2)));
|
// aaa = aaa + 2;
|
//}
|
//for (int x = maxLength + 1; x <= 49; x++) num[x] = 0;//将产品型号无数据的通道全部置为0
|
#endregion
|
|
#region 65~79 => 71~85 物料编码
|
|
string data3 = machineInfoTwo.materialCode;
|
CMMLog.Info($"71~85 data3_1:{data3}");
|
if (data3.Length % 2 != 0)
|
{
|
//data3 = "0" + machineInfoTwo.materialCode;
|
mtHead = "" + machineInfoTwo.materialCode.Substring(0, 1);
|
}
|
CMMLog.Info($"71~85 data3_2:{data3}");
|
maxLength = 64 + (data3.Length / 2);
|
int aaaa = 0;
|
for (int i = 65; i <= maxLength; i++)
|
{
|
num[i] = int.Parse(AsciiToTen(data3.Substring(aaaa, 2)));
|
aaaa = aaaa + 2;
|
}
|
for (int x = maxLength + 1; x <= 79; x++) num[x] = 0;//将产品型号无数据的通道全部置为0
|
#endregion
|
|
ERPService.HandleItemInfoChina(ErpItemInfo.item_name, 80, 99, num);// 中文处理 80~99 86~105
|
ERPService.HandleItemInfo(ErpItemInfo.item_uom, 100, 104, num);// 100~104 106~110
|
|
// 如果 产品批次号 或者 产品型号 位数 为 奇数，则将提前取出的 首字符 重新转码 写入 其所对应通道区域的 首通道
|
if (pcHead != "") num[35] = int.Parse(AsciiToTen(pcHead));
|
if (cpHead != "") num[55] = int.Parse(AsciiToTen(cpHead));
|
if (mtHead != "") num[65] = int.Parse(AsciiToTen(mtHead));
|
if (pcHead != "" || cpHead != "") CMMLog.Info($"产品型号或批次号数量为奇数，特将首位取出单独处理，以下为批次号和产品型号的十进制数值{num[35]},{num[55]}");
|
|
CMMLog.Info($"叠盘机数据处理完毕：{JsonConvert.SerializeObject(num)}");
|
|
return num;
|
}
|
|
/// <summary>
|
/// 三楼叠托机扫码
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="taskNo"></param>
|
internal static void CacheStackingMouth1313(string ip,string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault();
|
if(plc != null)
|
{
|
if(plc.deviceType == "23")
|
{
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
host = plc.ip,
|
data = 3,
|
port = plc.port
|
});
|
if (wirte.errCode == 0)
|
{
|
var taskInfo = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), "TN_I_TASK_MST");
|
MongoDBSingleton.Instance.Remove<WMSInfo>(Query.EQ("trayCode", taskInfo.CN_S_BATCH_NO), RemoveFlags.Single);
|
|
wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
host = plc.ip,
|
data = 0,
|
port = plc.port
|
});
|
TSHelper.GoToAGV(taskNo, 10, 7);
|
}
|
}
|
else
|
{
|
OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
host = plc.ip,
|
data = 2,
|
port = plc.port
|
});
|
var readres = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 2,
|
addr = plc.readAddr + 1,
|
host = plc.ip,
|
port = plc.port
|
});
|
if (readres != null)
|
{
|
var taskInfo = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), "TN_I_TASK_MST");
|
if (readres.result[0] == 3 && readres.result[1] == 1)
|
{
|
CMMLog.Debug($"3楼缓存架入叠托OK：TaskNo:{taskInfo.CN_S_TASK_NO},叠包OK写入值3。");
|
//读码信息比对结果：OK 读到通道2参数为1时,小车将托盘放置在叠盘机上（改参数10为7）
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
host = plc.ip,
|
data = 3,
|
port = plc.port
|
});
|
if (wirte.errCode == 0)
|
{
|
//并删除WMSInfo中间表中对应托盘号的数据（也可在小车离开叠盘机之后删除，暂定通道2参数1）
|
CMMLog.Debug($"读码信息比对结果：OK ,并删除WMSInfo中间表中对应托盘号的数据");
|
MongoDBSingleton.Instance.Remove<WMSInfo>(Query.EQ("trayCode", taskInfo.CN_S_BATCH_NO), RemoveFlags.Single);
|
CMMLog.Debug($"3楼缓存架入叠托OK：TaskNo:{taskInfo.CN_S_TASK_NO},叠包OK写入值4。");
|
if (CacheStackingMouth8(plc))
|
{
|
CMMLog.Debug($"3楼缓存架入叠托OK：TaskNo:{taskInfo.CN_S_TASK_NO},叠包OK写入值成功，更改AGV参数10为7，让小车离开。");
|
TSHelper.GoToAGV(taskNo, 10, 7);
|
}
|
}
|
}
|
else if (readres.result[0] == 3 && readres.result[1] == 2)
|
{
|
CMMLog.Debug($"读码信息比对结果：条码与传送的数据不一致");
|
//二期--调用 WMS 改道接口 获取 目标点位，并 更改 AGV 站点
|
string ChangeBit = WMSHelper.WmsUpdateWay(taskInfo.CN_S_SOURCE_NO, plc.Extend);
|
if (!string.IsNullOrEmpty(ChangeBit))
|
{
|
int[] parms = { StockInstance.Instance.GetAGVCodeForBitCode(taskInfo.CN_S_END_BIT), StockInstance.Instance.GetAGVCodeForBitCode(ChangeBit) };
|
TSHelper.ChangeParam(taskNo, 1, parms);
|
TSHelper.GoToAGV(taskNo, 3, 1);// 泰州格林美更改起点层数为1-荆门也需要更改
|
|
//TSHelper.ChangeParam(taskNo, 1, StockInstance.Instance.GetAGVCodeForBitCode(taskInfo.CN_S_END_BIT));
|
//TSHelper.ChangeParam(taskNo, 2, StockInstance.Instance.GetAGVCodeForBitCode(ChangeBit));
|
TSHelper.GoToAGV(taskNo, 10, 8);
|
MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), Update.Set("CN_S_END_BIT", ChangeBit).Set("CN_S_START_BIT", taskInfo.CN_S_END_BIT), "TN_I_TASK_MST", UpdateFlags.None);
|
}
|
else CMMLog.Debug($"调用WMS改道接口，未获取到可用点位。");
|
Console.WriteLine($"读码信息比对结果：条码与传送的数据不一致");
|
}
|
//PLCControl.CacheStackingMouth6(plc);
|
}
|
}
|
|
}
|
}
|
|
/// <summary>
|
/// 叠托OK写入4
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="taskNo"></param>
|
internal static void CacheStackingMouth6(Settings.PlcInfo plc)
|
{
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
data = 3,
|
host = plc.ip,
|
port = plc.port
|
});
|
Thread.Sleep(2000);
|
wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
data = 0,
|
host = plc.ip,
|
port = plc.port
|
});
|
}
|
|
/// <summary>
|
/// 卸货离开三楼叠托机--二期：需要和TS对接，让小车 卸货完成等到 小车离开之后再发送
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="taskNo"></param>
|
internal static bool CacheStackingMouth8(Settings.PlcInfo plc)
|
{
|
bool result = false;
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
data = 4,
|
host = plc.ip,
|
port = plc.port
|
});
|
if (wirte.errCode == 0) result = true;
|
return result;
|
}
|
#endregion
|
|
#endregion
|
|
#region 3楼包装机空托补给3楼包装机流程——无需回报WMS任务状态——3楼包装补空——已完成(待测试)
|
|
/// <summary>
|
/// 3楼包装机补空托流程——任务开始前，判断包装机有没有下线信号，并判断当前包装机对应的地堆位是否有任务占用
|
/// </summary>
|
/// <param name="a"></param>
|
internal static void PickUpBlank(Settings.PlcInfo pmInfo)
|
{
|
/* 包装补空流程：
|
* 读取 包装机 是否需要补空托，如果有请求，则继续判断当前包装机无任务占用，以及当前包装机所对应的 地堆位 无任务占用
|
* 任务创建方式：调用WMS，传输 终点(当前包装机所对应的 地堆位)
|
* **/
|
try
|
{
|
//读取输入寄存器还是输出寄存器待定,读取通道0的数据
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = pmInfo.readAddr,
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
if (result != null && result.errCode == 0)
|
{
|
//1：取料；3：人工叫空托盘
|
if (result.result[0] == 3)
|
{
|
CMMLog.Info("包装机补空托流程：判断包装机通道0值为3");
|
//空托库区 -> 包装机对应地堆空托缓存位
|
if (ProcessHelper.PickUpEndFree(pmInfo.Extend))
|
{
|
bool req = WMSHelper.WMSOut(pmInfo.Extend, "");
|
if (req)
|
{
|
//任务完成之后，需要复位此通道数据为 0
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = pmInfo.ip,
|
addr = pmInfo.writeAddr + 2,
|
data = 1,
|
port = pmInfo.port
|
});
|
}
|
}
|
}
|
}
|
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message, ex);
|
}
|
}
|
|
/// <summary>
|
/// 包装补空任务完成--复位 收到上空信号 为 0
|
/// </summary>
|
/// <param name="PlcBitCache01"></param>
|
internal static void PickUpBlankComplete(string PlcBitCache01)
|
{
|
string PlcBit01 = PlcBitCache01;
|
var plcInfo = Settings.GetPlcInfo().Where(a => a.location == PlcBit01).FirstOrDefault();
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plcInfo.ip,
|
addr = plcInfo.writeAddr + 2,
|
data = 0,
|
port = plcInfo.port
|
});
|
}
|
|
#endregion
|
|
#region 3楼补给成品空托区到3楼拆盘机流程——需回报WMS任务状态——3楼拆盘补空——已完成(待测试)
|
|
/// <summary>
|
/// 线程循环查询拆盘机是否需要补空托
|
/// </summary>
|
/// <param name="plc"></param>
|
internal static void CheckPackingLineEmpty(Settings.PlcInfo plc)
|
{
|
//读plc信号，看有没有叫料请求，判断是否已经有任务
|
//没有任务，调WMS生成空托补充任务
|
try
|
{
|
//RegisterReadInPut 读取输入寄存器还是输出寄存器待定,读取通道1的数据
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = plc.readAddr+1,
|
host = plc.ip,
|
port = plc.port
|
});
|
if (result != null && result.errCode == 0)
|
{
|
//1.补空托盘
|
if (result.result[0] == 1)
|
{
|
//判断3楼拆盘机（补空托盘点位）终点是否有任务占用，没有则生成任务
|
if (ProcessHelper.CheckEndFree(plc.location))
|
{
|
CMMLog.Debug("拆盘补空流程调用。。。");
|
string wmstaskno = "";
|
string traycode = "";
|
string trayType = "";
|
if (result.result[1] == 1) trayType = "田字托";
|
else trayType = "川字托";
|
bool req = WMSHelper.WMSEmptyOut(plc.location, "", ref wmstaskno, ref traycode, trayType);
|
if (req) CMMLog.Debug($"调用WMS获取三楼拆盘机生成任务成功！");
|
else CMMLog.Debug($"调用WMS获取三楼拆盘机生成任务失败！");
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message, ex);
|
}
|
}
|
|
#region 拆盘机交互
|
|
/// 小车请求出料 1 AMS写，PLC读 1-请求出料；2-出料进行中；3-动作完成
|
/// 设备允许进料 1 PLC写，AMS读 1-允许进料；2-进料进行中；3-动作完成
|
/// <summary>
|
/// 向拆盘机请求卸货
|
/// </summary>
|
/// <param name="ips"></param>
|
internal static void DiscRemoverReqUnload(string ip, string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault();
|
if (plc != null)
|
{
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.readAddr + 1
|
});
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 0 || readRes.result[0] == 1)
|
{
|
//不允许进料，ams写入请求出料
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.writeAddr + 1,
|
data = 1
|
});
|
}
|
else if (readRes.result[0] == 2)
|
{
|
//设备允许进料
|
//改参数通知agv
|
if (TSHelper.GoToAGV(taskNo, 10, 3))
|
{
|
WorkFlowAction.TrackLog(taskNo, 10, 1013, "success");
|
//改成出料进行中
|
CMMLog.Debug("三楼拆盘机：小车正在卸空盘中！");
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.writeAddr + 1,
|
data = 2
|
});
|
}
|
else CMMLog.Debug($"三楼拆盘补空，1013，TS,10,3,false！");
|
}
|
}
|
}
|
}
|
|
/// <summary>
|
/// 小车卸货完成离开通知拆盘机
|
/// </summary>
|
/// <param name="ips"></param>
|
/// <param name="taskNo"></param>
|
internal static bool DiscRemoverUnloadComplete(string ip, string taskNo)
|
{
|
var result = false;
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault();
|
if (plc != null)
|
{
|
//1.0 读地址1设备是否动作完成
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.readAddr + 1
|
});
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 2)
|
{
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.writeAddr + 1,
|
data = 3
|
});
|
result = true;
|
CMMLog.Debug("读取设备【参数不为0】，AMS设置小车【动作完成】，等待设备【参数为0】时再改参数通知agv");
|
}
|
}
|
}
|
return result;
|
}
|
|
#endregion
|
|
#endregion
|
|
#region 3楼叠盘机满托下线入库流程——需回报WMS任务状态——3楼叠盘下线--已完成(待测试)
|
|
/// <summary>
|
/// 线程循环查询叠盘机是否需要下满托
|
/// </summary>
|
/// <param name="plc"></param>
|
internal static void StackingLineEmpty(Settings.PlcInfo plc)
|
{
|
//读plc信号，看有没有叫料请求，判断是否已经有任务
|
//没有任务，调WMS生成空托补充任务
|
try
|
{
|
//RegisterReadInPut 读取输入寄存器还是输出寄存器待定,读取通道1的数据
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 2,
|
addr = plc.readAddr + 1,
|
host = plc.ip,
|
port = plc.port
|
});
|
if (result != null && result.errCode == 0)
|
{
|
//1.满托下线
|
if (result.result[0] == 1)
|
{
|
//判断3楼叠盘起点是否有任务占用，没有则生成任务
|
if (ProcessHelper.CheckStartFree(plc.location))
|
{
|
string wmstaskno = "";
|
string traycode = "";
|
string trayType = "";
|
if(plc.deviceType == "25") trayType = result.result[1] == 1 ? "川字托" : "田字托";
|
bool req = WMSHelper.WMSIn(plc.location, "", ref wmstaskno, ref traycode,"","",false, trayType);
|
if (req)
|
{
|
CMMLog.Debug($"调用WMS获取三楼叠盘机生成任务成功！");
|
if (plc.deviceType == "25")
|
{
|
//记录托盘类型
|
var trayTypeInfo = MongoDBSingleton.Instance.FindOne<trayTypeTable>(Query.EQ("locCode", plc.location), "trayTypeTable");
|
if (trayTypeInfo == null)
|
{
|
MongoDBSingleton.Instance.Insert<trayTypeTable>(new trayTypeTable
|
{
|
locCode = plc.location,
|
trayType = result.result[1].ToString()
|
});
|
}
|
}
|
}
|
else CMMLog.Debug($"调用WMS获取三楼叠盘机生成任务失败！");
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message, ex);
|
}
|
}
|
|
#region 叠盘机交互
|
|
/// 小车请求出料 1 AMS写，PLC读 1-请求出料；2-出料进行中；3-动作完成
|
/// 设备允许进料 1 PLC写，AMS读 1-允许进料；2-进料进行中；3-动作完成
|
/// <summary>
|
/// 向叠盘机请求取货
|
/// </summary>
|
/// <param name="ips"></param>
|
internal static void StackingReqUnload(string ip, string taskNo)
|
{
|
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault();
|
if (plc != null)
|
{
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
host = plc.ip,
|
port = plc.port,
|
data = 1
|
});
|
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.readAddr + 1
|
});
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 0 || readRes.result[0] == 1)
|
{
|
//不允许进料，ams写入请求出料
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.writeAddr + 1,
|
data = 1
|
});
|
}
|
else if (readRes.result[0] == 2)
|
{
|
//设备允许进料
|
//改参数通知agv
|
if (TSHelper.GoToAGV(taskNo, 10, 1))
|
{
|
WorkFlowAction.TrackLog(taskNo, 10, 1013, "success");
|
//改成出料进行中
|
CMMLog.Debug("三楼叠盘机：小车正在取托盘中！");
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.writeAddr + 1,
|
data = 2
|
});
|
}
|
else CMMLog.Debug($"三楼叠盘机，1013，TS,10,3,false！");
|
}
|
}
|
}
|
|
#region
|
//var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault();
|
//if (plc != null)
|
//{
|
// var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
// {
|
// dataNum = 1,
|
// host = plc.ip,
|
// port = plc.port,
|
// addr = plc.readAddr + 1
|
// });
|
// if (readRes != null && readRes.errCode == 0)
|
// {
|
// if (readRes.result[0] == 0 || readRes.result[0] == 1)
|
// {
|
// //不允许进料，ams写入请求出料
|
// var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
// {
|
// host = plc.ip,
|
// port = plc.port,
|
// addr = plc.writeAddr + 1,
|
// data = 1
|
// });
|
// }
|
// else if (readRes.result[0] == 2)
|
// {
|
// //设备允许进料
|
// //改参数通知agv
|
// if (TSHelper.GoToAGV(taskNo, 10, 3))
|
// {
|
// WorkFlowAction.TrackLog(taskNo, 10, 1013, "success");
|
// //改成出料进行中
|
// CMMLog.Debug("三楼叠盘机：小车正在取托盘中！");
|
// var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
// {
|
// host = plc.ip,
|
// port = plc.port,
|
// addr = plc.writeAddr + 1,
|
// data = 2
|
// });
|
// }
|
// else CMMLog.Debug($"三楼叠盘机，1013，TS,10,3,false！");
|
// }
|
// }
|
//}
|
#endregion
|
}
|
|
/// <summary>
|
/// 小车取货完成离开通知叠盘机
|
/// </summary>
|
/// <param name="ips"></param>
|
/// <param name="taskNo"></param>
|
internal static bool StackingComplete(string ip, string taskNo)
|
{
|
var result = false;
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault();
|
if (plc != null)
|
{
|
//1.0 读地址1设备是否动作完成
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.writeAddr + 1,
|
data = 3
|
});
|
result = true;
|
CMMLog.Debug("读取设备【参数不为0】，AMS设置小车【动作完成】，等待设备【参数为0】时再改参数通知agv");
|
}
|
return result;
|
}
|
|
#endregion
|
|
#endregion
|
|
#endregion
|
|
#region 跨楼层任务
|
|
#region 货物入库流程——满托转运
|
|
#region 收到打包机下线信号，判断条件是否允许，选择性下发任务
|
/// <summary>
|
/// 3楼打包机下线，判断打包机是否由生成打包下线的任务，如果有，自己生成两条任务
|
/// </summary>
|
/// <param name="plc"></param>
|
internal static void CheckPackingLineFull(Settings.PlcInfo plc)
|
{
|
//读plc信号，看有没有下线请求，判断是否已经有任务
|
//没有任务，继续plc，包装下线的物料信号
|
//检查打包机通道1是否有出料任务信号，如果有生成取料任务。
|
if (CheckStartFree(plc.location))
|
{
|
try
|
{
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = plc.readAddr + 1,
|
host = plc.ip,
|
port = plc.port
|
});
|
if (result != null && result.errCode == 0)
|
{
|
if (result.result[0] == 1)
|
{
|
//获取MODBUS通道里面存放的时间戳
|
var resultTime = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
addr = plc.readAddr + 10,
|
host = plc.ip,
|
port = plc.port,
|
dataNum = 2
|
});
|
if (resultTime.errCode == 0)
|
{
|
string wmstaskno = "";
|
string traycode = "";
|
if (Settings.packChange == "0")
|
{
|
string timeCuoData = (resultTime.result[0] * 65536 + resultTime.result[1]).ToString();
|
CMMLog.Info($"获取到的MODBUS时间戳：{timeCuoData}");
|
Console.WriteLine($"获取到的MODBUS时间戳：{timeCuoData}");
|
//这里需要调用照相机接口，获取数据存入中间表，等到入库流程完成，将数据传送给WMS
|
string deviceNo = "";
|
var timecuo = TimeCuo(timeCuoData, ref deviceNo);
|
if (timecuo != null)
|
{
|
string timeStamp = timecuo.data.First().timeStamp.ToString();
|
string employeeId = timecuo.data.First().employeeID1.ToString();
|
// ERP变更-调用ERP接口传输相关数据
|
if (ERPService.ERPSwitch01 == "1")
|
{
|
// string employeeId = ERPService.GetEmployeeId(plc.readAddr + 18, plc.ip, plc.port);
|
// MongoDBSingleton.Instance.Update<TimeCuoInfoCom>(Query.EQ("timeStamp", int.Parse(timeStamp)), Update.Set("employeeId", employeeId), "TimeCuoInfoCom", UpdateFlags.None);
|
|
// if (ERPService.ERPApiFunc(timeStamp))
|
// WMSHelper.WMSIn(plc.location, "time", ref wmstaskno, ref timeStamp, timeStamp, employeeId);
|
|
WMSHelper.WMSIn(plc.location, "time", ref wmstaskno, ref timeStamp, timeStamp, employeeId);
|
}
|
else WMSHelper.WMSIn(plc.location, "time", ref wmstaskno, ref timeStamp, timeStamp);
|
}
|
else CMMLog.Info($"时间戳接口返回值为空！");
|
}
|
else if(Settings.packChange == "1")
|
{
|
bool req = WMSHelper.WMSIn(plc.location, "", ref wmstaskno, ref traycode, "");
|
}
|
}
|
else CMMLog.Info($"MODBUS时间戳数据返回值错误：返回值解析：{JsonConvert.SerializeObject(result)}");
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message);
|
}
|
}
|
}
|
|
/// <summary>
|
/// 3楼打包机下线，判断打包机是否由生成打包下线的任务（四钴车间）
|
/// </summary>
|
/// <param name="plc"></param>
|
internal static void CheckPackingLineFullTwo(Settings.PlcInfo plc)
|
{
|
//读plc信号，看有没有下线请求，判断是否已经有任务
|
//没有任务，继续plc，包装下线的物料信号
|
//检查打包机通道1是否有出料任务信号，如果有生成取料任务。
|
if (CheckStartFree(plc.location))
|
{
|
try
|
{
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = plc.readAddr + 1,
|
host = plc.ip,
|
port = plc.port
|
});
|
if (result != null && result.errCode == 0)
|
{
|
if (result.result[0] == 1)
|
{
|
//获取MODBUS通道里面存放的时间戳
|
var resultTime = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
addr = plc.readAddr + 10,
|
host = plc.ip,
|
port = plc.port,
|
dataNum = 170
|
});
|
if (resultTime.errCode == 0)
|
{
|
string wmstaskno = "";
|
TimeCuoInfoComTwo timecuo = TimeCuoTwo(resultTime.result);
|
if (timecuo != null)
|
{
|
string timeStamp = timecuo.TimeCuo;
|
string employeeId = timecuo.employeeId1;
|
// ERP变更-调用ERP接口传输相关数据
|
WMSHelper.WMSIn(plc.location, "time", ref wmstaskno, ref timeStamp, timeStamp, employeeId,true);
|
}
|
else CMMLog.Info($"时间戳接口返回值为空！");
|
}
|
else CMMLog.Info($"MODBUS时间戳数据返回值错误：返回值解析：{JsonConvert.SerializeObject(result)}");
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message);
|
}
|
}
|
}
|
#endregion
|
|
#region 打包机出口MODBUS交互（开始取料，取料完成）
|
|
/// 小车请求进料 1 AMS写，PLC读 1-AGV到位信号；2-到位后，请求接驳滚动；3-取货完成；
|
/// 设备允许出料 1 PLC写，AMS读 1-设备请求出料；2-允许进入；3-确认货物取走，送出物料；
|
|
///打包线下线——小车开始取货
|
internal static void PackingLineUnload1012(string ip, string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == "4").FirstOrDefault();
|
if (plc != null)
|
{
|
try
|
{
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = plc.readAddr + 1,
|
host = plc.ip,
|
port = plc.port
|
});
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 1)
|
{
|
var write = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
data = 1,
|
host = plc.ip,
|
port = plc.port
|
});
|
}
|
else if (readRes.result[0] == 2)
|
{
|
TSHelper.GoToAGV(taskNo, 10, 1);
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
data = 2,
|
host = plc.ip,
|
port = plc.port
|
});
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Info(ex.Message);
|
}
|
}
|
}
|
|
/// <summary>
|
/// 打包线下线——小车取货完成
|
/// </summary>
|
/// <param name="ip"></param>
|
/// <param name="taskNo"></param>
|
internal static void PackingLineComplete4(string ip, string taskNo)
|
{
|
//取货完成后需要读取设备时间戳里面的数据，并将其暂存至中间表等到入库任务完成传输给WMS
|
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == "4").FirstOrDefault();
|
if (plc != null)
|
{
|
try
|
{
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = plc.readAddr + 1,
|
host = plc.ip,
|
port = plc.port
|
});
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 3)
|
{
|
var write = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plc.writeAddr + 1,
|
data = 3,
|
host = plc.ip,
|
port = plc.port
|
});
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Info(ex.Message);
|
}
|
}
|
}
|
#endregion
|
|
#region 电梯安全门对接
|
/// <summary>
|
/// 入库一段任务请求进入
|
/// </summary>
|
/// <param name="mst"></param>
|
/// <param name="startfloor"></param>
|
internal static void RuKuOne1013(TN_I_TASK_MST mst, int startfloor)
|
{
|
//对电梯的modbus通道进行安全开门对接，
|
//var pmInfo = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.deviceType == "8").FirstOrDefault();
|
var pmInfo = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.location == mst.Ext3).FirstOrDefault();
|
if (pmInfo != null)
|
{
|
try
|
{
|
//进入Agv状态
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = pmInfo.writeAddr + 2,
|
data = 1,
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
CMMLog.Debug($"写入设备{pmInfo.location}通道{pmInfo.writeAddr + 2}里面数据为1.");
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = pmInfo.ip,
|
port = pmInfo.port,
|
addr = pmInfo.readAddr + 1
|
});
|
CMMLog.Debug($"读取设备{pmInfo.location}通道{pmInfo.readAddr + 1}里面数据为{JsonConvert.SerializeObject(readRes)}.");
|
if (readRes != null && readRes.errCode == 0)
|
{
|
//判断电梯状态是否是停梯状态，停梯状态则发对应的信号
|
if (readRes.result[0] == 0)
|
{
|
int num = startfloor == 1 ? 1 : startfloor == 2 ? 4 : startfloor == 3 ? 6 : 0;
|
//写入电梯楼层
|
wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = pmInfo.writeAddr + 1,
|
data = num,
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
CMMLog.Debug($"写入设备{pmInfo.location}通道{pmInfo.writeAddr + 1}里面数据为{num}.");
|
//读取输入寄存器还是输出寄存器待定,读取通道0的数据
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 2,
|
addr = pmInfo.readAddr + 2,
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
CMMLog.Debug($"读取设备{pmInfo.location}通道{pmInfo.readAddr + 2}里面数据为{JsonConvert.SerializeObject(result)}.");
|
if (result != null && result.errCode == 0)
|
{
|
if (result.result[0] == 2 && result.result[1] == num)
|
{
|
var eleBit = MongoDBSingleton.Instance.FindOne<ElevatorTask>(Query.EQ("taskNo", mst.CN_S_SOURCE_NO), "ElevatorTask");
|
//改终点为开启的电梯
|
TSHelper.GoToAGV(mst.CN_S_TASK_NO, 2, StockInstance.Instance.GetAGVCodeForBitCode(eleBit.endBit));
|
}
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message, ex);
|
}
|
}
|
else CMMLog.Info($"请检查电梯配置中心有没有开启，当前电梯点位:{mst.Ext3}");
|
}
|
|
/// <summary>
|
/// 入库一段任务请求退出
|
/// </summary>
|
/// <param name="mst"></param>
|
/// <param name="endfloor"></param>
|
internal static bool RuKuOne6(TN_I_TASK_MST mst, int endfloor)
|
{
|
bool req = false;
|
//对电梯的modbus通道进行安全开门对接，
|
var pmInfo = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.location == mst.Ext3).FirstOrDefault();
|
if (pmInfo != null)
|
{
|
try
|
{
|
//写入楼层信号和关门信号
|
int floorNum = endfloor == 1 ? 1 : endfloor == 2 ? 4 : endfloor == 3 ? 6 : 0;
|
int[] num = new int[2] { 4, floorNum };
|
var writeRes0 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
host = pmInfo.ip,
|
addr = pmInfo.writeAddr,
|
data = num,//原先是1,单个写入
|
port = pmInfo.port
|
});
|
CMMLog.Debug($"写入设备{pmInfo.location}通道{pmInfo.writeAddr}里面数据为{JsonConvert.SerializeObject(num)}.");
|
req = true;
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message, ex);
|
}
|
}
|
else CMMLog.Info($"请检查电梯配置中心有没有开启，当前电梯点位:{mst.Ext3}");
|
return req;
|
}
|
|
/// <summary>
|
/// 入库二段任务请求进入
|
/// </summary>
|
/// <param name="mst"></param>
|
/// <param name="startfloor"></param>
|
internal static void RuKuOne1012(TN_I_TASK_MST mst, int endfloor)
|
{
|
//对电梯的modbus通道进行安全开门对接，
|
var eleBit = MongoDBSingleton.Instance.FindOne<ElevatorTask>(Query.EQ("taskNo", mst.CN_S_SOURCE_NO), "ElevatorTask");
|
if(eleBit == null) CMMLog.Info($"当前任务来源号：{mst.CN_S_SOURCE_NO}，请在ElevatorTask表中查询字段taskNo为当前任务来源号");
|
var pmInfo = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.location == eleBit.endBit02).FirstOrDefault();
|
CMMLog.Info($"二段任务 1312 1 bit:{eleBit.endBit02} deivicetype:{pmInfo.deviceType}");
|
if (pmInfo != null)
|
{
|
try
|
{
|
int num = endfloor == 1 ? 1 : endfloor == 2 ? 4 : endfloor == 3 ? 6 : 0;
|
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 3,
|
addr = pmInfo.readAddr + 1,
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
CMMLog.Debug($"读取设备{pmInfo.location}通道{pmInfo.readAddr + 1}里面数据为{JsonConvert.SerializeObject(result)}.");
|
if (result != null && result.errCode == 0)
|
{
|
if (result.result[0] == 0 && result.result[1] == 2 && result.result[2] == num)
|
{
|
TSHelper.GoToAGV(mst.CN_S_TASK_NO, 1, StockInstance.Instance.GetAGVCodeForBitCode(eleBit.endBit02));
|
}
|
}
|
|
#region
|
//var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
//{
|
// dataNum = 1,
|
// addr = pmInfo.readAddr + 5,
|
// host = pmInfo.ip,
|
// port = pmInfo.port
|
//});
|
//var result2 = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
//{
|
// dataNum = 1,
|
// addr = pmInfo.readAddr + 6,
|
// host = pmInfo.ip,
|
// port = pmInfo.port
|
//});
|
//if (result != null && result2 != null)
|
//{
|
// if (result.result[0] == 1 && result2.result[0] == endfloor)
|
// {
|
// //TSHelper.GoToAGV(mst.CN_S_TASK_NO, 10, 1);
|
// //改终点为开启的电梯
|
// TSHelper.GoToAGV(mst.CN_S_TASK_NO, 1, StockInstance.Instance.GetAGVCodeForBitCode(eleBit.endBit02));
|
// }
|
//}
|
#endregion
|
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message, ex);
|
}
|
}
|
else CMMLog.Info($"请检查电梯配置中心有没有开启，当前电梯点位:{eleBit.endBit02}");
|
}
|
|
/// <summary>
|
/// 入库二段任务请求退出
|
/// </summary>
|
/// <param name="mst"></param>
|
/// <param name="startfloor"></param>
|
internal static bool RuKuOne4(TN_I_TASK_MST mst, int endfloor)
|
{
|
bool req = false;
|
var eleBit = MongoDBSingleton.Instance.FindOne<ElevatorTask>(Query.EQ("taskNo", mst.CN_S_SOURCE_NO), "ElevatorTask");
|
if (eleBit == null) CMMLog.Info($"当前任务来源号：{mst.CN_S_SOURCE_NO}，请在ElevatorTask表中查询字段taskNo为当前任务来源号");
|
var pmInfo = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.location == eleBit.endBit02).FirstOrDefault();
|
CMMLog.Info($"二段任务 1312 2 bit:{eleBit.endBit02} deivicetype:{pmInfo.deviceType}");
|
if (pmInfo != null)
|
{
|
try
|
{
|
int[] num = new int[4] { 4, 0,0,0 };
|
var writeRes0 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
host = pmInfo.ip,
|
addr = pmInfo.writeAddr,
|
data = num,//原先是1,单个写入
|
port = pmInfo.port
|
});
|
CMMLog.Debug($"写入设备{pmInfo.location}通道{pmInfo.writeAddr}里面数据为{JsonConvert.SerializeObject(num)}.");
|
//var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
//{
|
// addr = pmInfo.writeAddr + 1,
|
// data = 3,
|
// host = pmInfo.ip,
|
// port = pmInfo.port
|
//});
|
req = true;
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error(ex.Message, ex);
|
}
|
}
|
else CMMLog.Info($"请检查电梯配置中心有没有开启，当前电梯点位:{eleBit.endBit02}");
|
return req;
|
}
|
#endregion
|
|
#endregion
|
|
#region 电梯选择以及电梯点位赋值
|
|
/// <summary>
|
/// 读取MODBUS返回允许使用的电梯点位，如果没有电梯可以使用，返回0
|
/// </summary>
|
/// <returns></returns>
|
internal static string ElevatorTaskBit(int bit)
|
{
|
Console.WriteLine("进入电梯选择判断！");
|
CMMLog.Info("进入电梯选择判断！");
|
string location = "";
|
CMMLog.Info("满托转运流程，判断三楼两部电梯设备");
|
//满托转运流程，判断三楼两部电梯设备(获取到可用电梯之后，需要判断这部电梯的一楼以及三楼是否有任务占用，如果有，则不可用)
|
var plc = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.deviceType == "8").FirstOrDefault();
|
var plc2 = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.deviceType == "11").FirstOrDefault();
|
|
if(bit == 2)
|
{
|
plc = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.deviceType == "12").FirstOrDefault();
|
plc2 = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.deviceType == "13").FirstOrDefault();
|
}
|
|
if (plc != null || plc2 != null)
|
{
|
if (plc != null)
|
{
|
CMMLog.Info("进入3楼电梯1判断是否开启");
|
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
addr = plc.readAddr,
|
dataNum = 1,//数据个数要增加 addr以及dataNum的具体数据为16个
|
host = plc.ip,
|
port = plc.port
|
});
|
if (result != null && result.result.Length > 0)
|
{
|
if (result.result[0] == 3)
|
{
|
// 判断当前电梯的 一楼以及三楼 均没有任务占用，则可以使用
|
// (三楼电梯不能有任务执行中，一楼电梯取货完成可以使用)
|
var oneFloor = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.deviceType == "12").FirstOrDefault();
|
if (bit == 2)
|
{
|
oneFloor = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.deviceType == "8").FirstOrDefault();
|
}
|
var startTask = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("Ext3",location), "TN_I_TASK_MST");
|
bool endTaskState = false;
|
var endTask = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_START_BIT", oneFloor.location), "TN_I_TASK_MST");
|
if (endTask != null)
|
{
|
if (WorkFlowAction.ExistsTrackLogs(endTask.CN_S_TASK_NO, 1, 4)) endTaskState = true;
|
}
|
else endTaskState = true;
|
if (startTask == null && endTaskState) location = plc.location;
|
}
|
}
|
}
|
if (string.IsNullOrEmpty(location) && plc2 != null)
|
{
|
CMMLog.Info("进入三楼电梯2判断是否开启");
|
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
addr = plc2.readAddr,
|
dataNum = 1,//数据个数要增加 addr以及dataNum的具体数据为16个
|
host = plc2.ip,
|
port = plc2.port
|
});
|
CMMLog.Info($"获取电梯状态：{JsonConvert.SerializeObject(result)}");
|
if (result != null && result.result.Length > 0)
|
{
|
if (result.result[0] == 3)
|
{
|
// 判断当前电梯的 一楼以及三楼 均没有任务占用，则可以使用
|
var oneFloor = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.deviceType == "13").FirstOrDefault();
|
if (bit == 2)
|
{
|
oneFloor = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.deviceType == "11").FirstOrDefault();
|
}
|
var startTask = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("Ext3", location), "TN_I_TASK_MST");
|
bool endTaskState = false;
|
var endTask = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_START_BIT", oneFloor.location), "TN_I_TASK_MST");
|
if (endTask != null)
|
{
|
if (WorkFlowAction.ExistsTrackLogs(endTask.CN_S_TASK_NO, 1, 4)) endTaskState = true;
|
|
}
|
else endTaskState = true;
|
if (startTask == null && endTaskState) location = plc2.location;
|
}
|
}
|
}
|
if (location == "")
|
{
|
Console.WriteLine("无电梯开启！");
|
CMMLog.Info("无电梯开启！");
|
location = "0";
|
}
|
}
|
else
|
{
|
CMMLog.Info("检查配置文件里面两部电梯是否有开启！");
|
return "0";
|
}
|
Console.WriteLine("电梯选择判断结束！");
|
CMMLog.Info("电梯选择判断结束！");
|
return location;
|
}
|
/// <summary>
|
/// 获取电梯点位赋值
|
/// </summary>
|
/// <param name="eleBit"></param>
|
/// <returns></returns>
|
internal static string ElevatorTaskBit02(string eleBit)
|
{
|
CMMLog.Info("赋值阶段2任务电梯起点");
|
string bit = "";
|
if (eleBit != "")
|
{
|
CMMLog.Info("两部电梯，四个配置均需要开启");
|
//1号电梯三楼和一楼电梯点位
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == "8").FirstOrDefault();
|
var plc2 = Settings.GetPlcInfo().Where(a => a.deviceType == "12").FirstOrDefault();
|
//2号电梯三楼和一楼电梯点位
|
var plc3 = Settings.GetPlcInfo().Where(a => a.deviceType == "11").FirstOrDefault();
|
var plc4 = Settings.GetPlcInfo().Where(a => a.deviceType == "13").FirstOrDefault();
|
if (eleBit == plc.location) bit = plc2.location;
|
else if(eleBit == plc2.location) bit = plc.location;
|
else if(eleBit == plc3.location) bit = plc4.location;
|
else if(eleBit == plc4.location) bit = plc3.location;
|
}
|
else CMMLog.Info("EleBit is null!");
|
CMMLog.Info("获取电梯二段任务电梯点位："+bit);
|
return bit;
|
}
|
internal static void ElevatorTaskFloor(int startFloor,string bit)
|
{
|
CMMLog.Info($"终点安全对接:电梯卸货:呼叫楼层:{startFloor},当前电梯点位：{bit}");
|
|
var pmInfo = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.location == bit).FirstOrDefault();
|
if (pmInfo != null)
|
{
|
int[] num = new int[4] { startFloor, 0, 1, 1 };
|
var writeRes0 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
host = pmInfo.ip,
|
addr = pmInfo.writeAddr,
|
data = num,//原先是1,单个写入
|
port = pmInfo.port
|
});
|
}
|
else CMMLog.Info($"终点安全对接:电梯卸货:未当前电梯点位的配置数据：{bit}");
|
|
|
|
//var write = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
//{
|
// addr = pmInfo.writeAddr+2,
|
// data = 1,
|
// host = pmInfo.ip,
|
// port = pmInfo.port
|
//});
|
//var write0 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
//{
|
// addr = pmInfo.writeAddr,
|
// data = startFloor,
|
// host = pmInfo.ip,
|
// port = pmInfo.port
|
//});
|
}
|
#endregion
|
|
#endregion
|
|
public static DateTime TenMin = DateTime.MinValue;
|
/// <summary>
|
/// 每隔十分钟往所有开启的打包下线口MODBUS通道里面写小车电量
|
/// 其实地址26，连续往里面写入四个值
|
/// </summary>
|
internal static void WriteBattery()
|
{
|
CMMLog.Info("写入小车电量：进入写入电量信息流程！");
|
//Console.WriteLine("写入小车电量：进入写入电量信息流程！");
|
if(TenMin == DateTime.MinValue) TenMin = DateTime.Now;
|
else if (DateTime.Now.Subtract(TenMin).TotalMinutes >= 10)
|
{
|
Console.WriteLine("写入小车电量：写入所有开启的打包下线口MODBUS通道电量值,并重置时间为当前时间");
|
CMMLog.Info("写入小车电量：写入所有开启的打包下线口MODBUS通道电量值,并重置时间为当前时间");
|
//写入所有开启的打包下线口MODBUS通道电量值,并重置时间为当前时间
|
//获取所有电量值
|
int[] num = ProcessHelper.GetBatteryHang();
|
CMMLog.Info($"写入小车电量：写入数据：{JsonConvert.SerializeObject(num)}");
|
Console.WriteLine($"写入小车电量：写入数据：{JsonConvert.SerializeObject(num)}");
|
var PlcInfo04 = Settings.GetPlcInfo().Where(a => a.enable == 1 && a.deviceType == "4").FirstOrDefault();//plcInfo
|
if (PlcInfo04 != null)
|
{
|
var wirteall = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
addr = PlcInfo04.writeAddr + 5,
|
host = PlcInfo04.ip,
|
data = num,
|
port = PlcInfo04.port
|
});
|
}
|
TenMin = DateTime.Now;
|
}
|
}
|
#region 数据处理业务
|
|
/// <summary>
|
/// 获取设备的包装物料信息(并写入中间表)
|
/// </summary>
|
/// <param name="info"></param>
|
/// <param name="result"></param>
|
/// <param name="noPack">true : MES交互方式 false : 无MES交互方式</param>
|
private static void GetMachineData(int[] result, ref string loc, bool noPack = true)
|
{
|
CMMLog.Info($"数据处理流程：进入数据处理流程！");
|
|
string trayCode = GetTrayCode(result.Take(3).ToArray());//托盘码
|
string location = GetTrayCode(result.Skip(3).Take(1).ToArray());//设备货位编码
|
loc = location;
|
if(trayCode != null && location != null)
|
{
|
CMMLog.Info($"数据处理流程：trayCode:{trayCode},location:{location}");
|
var json = "";
|
if (!noPack)
|
{
|
CMMLog.Info($"数据处理流程：包装机无MES情况下，自动生成以当前包装机号{location}为首的数据");
|
var task = MongoDBSingleton.Instance.FindOne<MachineInfo>(Query.EQ("machineNo", location), "MachineInfo");
|
if(task == null)
|
{
|
MongoDBSingleton.Instance.Insert<MachineInfo>(new MachineInfo
|
{
|
machineNo = location
|
});
|
MongoDBSingleton.Instance.Insert<MachineInfoTwo>(new MachineInfoTwo
|
{
|
machineNo = location,
|
trayCode = trayCode
|
});
|
}
|
else CMMLog.Info($"数据处理流程：包装机无MES情况下，模拟MES数据，中间表<MachineInfo>中已有当前包装机号{location}为首的数据");
|
}
|
var info = MongoDBSingleton.Instance.FindOne<MachineInfo>(Query.EQ("machineNo", location), "MachineInfo");
|
|
if (info != null)
|
{
|
CMMLog.Info($"数据处理流程：info:{info}");
|
#region 获取设备通道信息
|
|
#region 转换后
|
info.location = location;
|
info.trayCode = trayCode;
|
//获取重量 叠包等其它信息
|
info.productWeight = Convert.ToInt32(Completion(result[4]) + Completion(result[5]), 2).ToString();
|
// ERP变更：根据最新信号协议 trayCodeWeight 变更为 【员工编号】通道
|
info.trayCodeWeight = Convert.ToInt32(Completion(result[6]) + Completion(result[7]), 2).ToString();
|
info.oneTrayWeight = Convert.ToInt32(Completion(result[8]) + Completion(result[9]), 2).ToString();
|
info.addWeight = Convert.ToInt32(Completion(result[10]) + Completion(result[11]), 2).ToString();
|
info.packNg = 1;//不需要此参数 result[12]
|
info.secondNg = Convert.ToInt32(Completion(result[13]), 2);
|
info.addState = Convert.ToInt32(Completion(result[14]), 2);
|
if (info.addState == 0) CMMLog.Error($"数据处理流程：获取MODBUS信息异常:是否叠包值为0.");
|
info.packageCode = Convert.ToInt32(Completion(result[15]), 2).ToString();
|
|
CMMLog.Info($"数据处理流程：获取MODBUS转换后的数据信息：location:{info.location},trayCode:{info.trayCode},productWeight:{info.productWeight}" +
|
$",trayCodeWeight:{info.trayCodeWeight},oneTrayWeight:{info.oneTrayWeight},addWeight:{info.addWeight}" +
|
$",packNg:{info.packNg},secondNg:{info.secondNg},addState:{info.addState},packageCode:{info.packageCode}");
|
|
#endregion
|
|
#region 转换前
|
for (int i = 0; i <= 15; i++)
|
{
|
info.machinedown[i] = result[i];
|
}
|
//将数组数据接受转换为JSON数据并在后续方法判断中存入中间表
|
json = JsonConvert.SerializeObject(info.machinedown);
|
CMMLog.Info($"数据处理流程：获取MODBUS转换前的数据信息：{json}");
|
#endregion
|
|
#endregion
|
}
|
else CMMLog.Info($"数据处理流程：请查询<MachineInfo>表中machineNo字段是否为当前包装机号，并且trayCode是否为0");
|
|
var infoPack = MongoDBSingleton.Instance.FindOne<MachineInfo>(Query.And(Query.EQ("machineNo", location), Query.EQ("trayCode", "0")), "MachineInfo");
|
|
if (infoPack != null)
|
{
|
//包装机下线至复称，读取包装机平台数据
|
CMMLog.Info("数据处理流程：进入info判断01");
|
//AMS包装机下线首先调用MES，之后获取新的设备数据存入中间表
|
//根据托盘号获取指定的通道的JSON数据，将其转换为数组类型——写入通道数据时会使用
|
//var arr = JsonConvert.DeserializeObject<List<int>>(json);
|
if(!noPack)
|
{
|
CMMLog.Info($"数据处理流程：包装机无MES情况下，获取以往MES传输的数据，并原样写入原先MES字段中。");
|
|
//info.lotNo = RemoveNull(GetTrayCode(result.Skip(20).Take(30).ToArray()).Trim().ToString());
|
//info.productType = RemoveNull(GetTrayCode(result.Skip(50).Take(10).ToArray()).Trim().ToString());
|
//info.materialCode = RemoveNull(GetTrayCode(result.Skip(60).Take(20).ToArray()).Trim().ToString());
|
|
info.lotNo = RemoveNull(GetTrayCode(result.Skip(20).Take(20).ToArray()).Trim().ToString());
|
// info.productType = RemoveNull(GetTrayCode(result.Skip(40).Take(10).ToArray()).Trim().ToString());
|
info.productType = "";
|
info.materialCode = RemoveNull(GetTrayCode(result.Skip(50).Take(20).ToArray()).Trim().ToString());
|
|
CMMLog.Info($"数据处理流程：包装机无MES情况下，获取以往MES传输的数据，新获得数据，lotNo:{info.lotNo},productType:{info.productType},materialCode:{info.materialCode}");
|
|
|
//注意：这里赋值中间表参数请对照信息交互表具体通道值对应
|
UpdateBuilder update = Update.Set("palletLayers", info.secondNg.ToString()).Set("overlappingLayers", info.addState.ToString()).Set("bagNo", info.packageCode).
|
Set("lotNo", info.lotNo).Set("productType", info.productType).Set("materialCode", info.materialCode);
|
MongoDBSingleton.Instance.Update<MachineInfo>(Query.EQ("machineNo", location), update, "MachineInfo", UpdateFlags.None);
|
MongoDBSingleton.Instance.Update<MachineInfoTwo>(Query.EQ("trayCode", trayCode), update, "MachineInfoTwo", UpdateFlags.None);
|
}
|
//在中间表中找到刚刚插入的MES数据（目前还没有读取并写入设备数据）
|
var query1 = Query.And(Query.EQ("machineNo", location), Query.EQ("trayCode", "0"));
|
UpdateBuilder updateBuider = Update.Set("location", info.location).
|
Set("trayCode", info.trayCode).Set("productWeight", info.productWeight).
|
Set("trayCodeWeight", info.trayCodeWeight).Set("oneTrayWeight", info.oneTrayWeight).
|
Set("addWeight", info.addWeight).Set("packNg", info.packNg).Set("secondNg", info.secondNg).Set("addState", info.addState).
|
Set("packageCode", info.packageCode).Set("jsonData", json).Set("modify", DateTime.Now);
|
MongoDBSingleton.Instance.Update<MachineInfo>(query1, updateBuider, "MachineInfo", UpdateFlags.None);
|
MongoDBSingleton.Instance.Update<MachineInfoTwo>(Query.EQ("trayCode", trayCode), updateBuider, "MachineInfoTwo", UpdateFlags.None);
|
CMMLog.Info($"数据处理流程：更新MachineInfo中间表刚刚插入的MES数据!设备号为：{location},托盘号为：{trayCode}");
|
}
|
else
|
{
|
//复称入缓存架，读取复称平台数据
|
CMMLog.Info("数据处理流程：进入info判断02");
|
//读取除包装机外其他设备的信息，更新包装机下线时的数据
|
var query2 = Query.And(Query.EQ("machineNo", location), Query.EQ("trayCode", trayCode));
|
var info2 = MongoDBSingleton.Instance.FindOne<MachineInfo>(query2, "MachineInfo");
|
if (info2 != null)
|
{
|
UpdateBuilder updateBuider = Update.Set("location", info.location).
|
Set("trayCode", info.trayCode).Set("productWeight", info.productWeight).
|
Set("trayCodeWeight", info.trayCodeWeight).Set("oneTrayWeight", info.oneTrayWeight).
|
Set("addWeight", info.addWeight).Set("packNg", info.packNg).Set("secondNg", info.secondNg).Set("addState", info.addState).
|
Set("packageCode", info.packageCode).Set("jsonData", json).Set("modify", DateTime.Now);
|
MongoDBSingleton.Instance.Update<MachineInfo>(query2, updateBuider, "MachineInfo", UpdateFlags.None);
|
MongoDBSingleton.Instance.Update<MachineInfoTwo>(Query.EQ("trayCode", trayCode), updateBuider, "MachineInfoTwo", UpdateFlags.None);
|
CMMLog.Info($"数据处理流程：更新MachineInfo中间表其他设备的数据!设备号为：{location},托盘号为：{trayCode}");
|
}
|
else CMMLog.Info($"数据处理流程：无法在MachineInfo中间表中找到当前设备编号的数据！当前设备编号为：{location}，托盘码为：{trayCode}");
|
}
|
}
|
else CMMLog.Error("数据处理流程：数据流程处理托盘号或包装机号为空值！");
|
|
CMMLog.Info($"数据处理流程：数据处理流程结束！");
|
}
|
|
/// <summary>
|
/// 获取设备的包装物料信息(并写入中间表)
|
/// </summary>
|
/// <param name="info"></param>
|
/// <param name="result"></param>
|
/// <param name="noPack">true : MES交互方式 false : 无MES交互方式</param>
|
private static void GetMachineDataTetracobalt(int[] result, ref string timeStamp, bool noPack = true)
|
{
|
CMMLog.Info($"数据处理流程：进入数据处理流程！");
|
|
string empCode = RemoveNull(GetTrayCode(result.Take(5).ToArray()));//员工编码
|
string trayCode = GetTrayCode(result.Skip(5).Take(3).ToArray());//托盘码
|
trayCode = "0";
|
string location = GetTrayCode(result.Skip(8).Take(1).ToArray());//设备货位编码
|
if(trayCode != null && location != null)
|
{
|
CMMLog.Info($"数据处理流程：trayCode:{trayCode},location:{location},empCode:{empCode}");
|
var json = "";
|
if (!noPack)
|
{
|
CMMLog.Info($"数据处理流程：包装机无MES情况下，自动生成以当前包装机号{location}为首的数据");
|
var task = MongoDBSingleton.Instance.FindOne<MachineInfoTetracobalt>(Query.EQ("machineNo", location), "MachineInfo");
|
if(task == null)
|
{
|
MongoDBSingleton.Instance.Insert<MachineInfoTetracobalt>(new MachineInfoTetracobalt
|
{
|
machineNo = location
|
});
|
MongoDBSingleton.Instance.Insert<MachineInfoTwoTetracobalt>(new MachineInfoTwoTetracobalt
|
{
|
machineNo = location,
|
trayCode = trayCode
|
});
|
}
|
else CMMLog.Info($"数据处理流程：包装机无MES情况下，模拟MES数据，中间表<MachineInfoTetracobalt>中已有当前包装机号{location}为首的数据");
|
}
|
var info = MongoDBSingleton.Instance.FindOne<MachineInfoTetracobalt>(Query.EQ("machineNo", location), "MachineInfoTetracobalt");
|
|
if (info != null)
|
{
|
CMMLog.Info($"数据处理流程：info:{info}");
|
#region 获取设备通道信息
|
|
#region 转换后
|
info.empCode = empCode;
|
info.location = location;
|
info.trayCode = trayCode;
|
//获取重量 叠包等其它信息
|
info.productWeight = Convert.ToInt32(Completion(result[9]) + Completion(result[10]), 2).ToString();
|
// ERP变更：根据最新信号协议 trayCodeWeight 变更为 【员工编号】通道
|
info.trayCodeWeight = Convert.ToInt32(Completion(result[11]) + Completion(result[12]), 2).ToString();
|
info.oneTrayWeight = Convert.ToInt32(Completion(result[13]) + Completion(result[14]), 2).ToString();
|
info.trayType = Convert.ToInt32(Completion(result[17]), 2).ToString();
|
info.addState = Convert.ToInt32(Completion(result[18]), 2);
|
if (info.addState == 0) CMMLog.Error($"数据处理流程：获取MODBUS信息异常:是否叠包值为0.");
|
info.packageCode = Convert.ToInt32(Completion(result[19]), 2).ToString();
|
info.productTime = Convert.ToInt32(Completion(result[20]) + Completion(result[21]), 2).ToString();
|
|
//info.addWeight = Convert.ToInt32(Completion(result[10]) + Completion(result[11]), 2).ToString();
|
//info.packNg = 1;//不需要此参数 result[12]
|
//info.secondNg = Convert.ToInt32(Completion(result[13]), 2);
|
|
CMMLog.Info($"数据处理流程：获取MODBUS转换后的数据信息：empCoe:{info.empCode},location:{info.location},trayCode:{info.trayCode},productWeight:{info.productWeight}" +
|
$",trayCodeWeight:{info.trayCodeWeight},oneTrayWeight:{info.oneTrayWeight},trayType:{info.trayType}" +
|
$",productTime:{info.productTime},addState:{info.addState},packageCode:{info.packageCode}");
|
|
#endregion
|
|
#region 转换前
|
for (int i = 0; i <= 21; i++)
|
{
|
info.machinedown[i] = result[i];
|
}
|
//将数组数据接受转换为JSON数据并在后续方法判断中存入中间表
|
json = JsonConvert.SerializeObject(info.machinedown);
|
CMMLog.Info($"数据处理流程：获取MODBUS转换前的数据信息：{json}");
|
#endregion
|
|
#endregion
|
}
|
else CMMLog.Info($"数据处理流程：请查询<MachineInfoTetracobalt>表中machineNo字段是否为当前包装机号，并且trayCode是否为0");
|
|
var infoPack = MongoDBSingleton.Instance.FindOne<MachineInfoTetracobalt>(Query.And(Query.EQ("machineNo", location), Query.EQ("trayCode", "0")), "MachineInfoTetracobalt");
|
|
if (infoPack != null)
|
{
|
//包装机下线至复称，读取包装机平台数据
|
CMMLog.Info("数据处理流程：进入info判断01");
|
//AMS包装机下线首先调用MES，之后获取新的设备数据存入中间表
|
//根据托盘号获取指定的通道的JSON数据，将其转换为数组类型——写入通道数据时会使用
|
//var arr = JsonConvert.DeserializeObject<List<int>>(json);
|
if(!noPack)
|
{
|
CMMLog.Info($"数据处理流程：包装机无MES情况下，获取以往MES传输的数据，并原样写入原先MES字段中。");
|
|
//info.lotNo = RemoveNull(GetTrayCode(result.Skip(20).Take(30).ToArray()).Trim().ToString());
|
//info.productType = RemoveNull(GetTrayCode(result.Skip(50).Take(10).ToArray()).Trim().ToString());
|
//info.materialCode = RemoveNull(GetTrayCode(result.Skip(60).Take(20).ToArray()).Trim().ToString());
|
|
info.lotNo = RemoveNull(GetTrayCode(result.Skip(35).Take(20).ToArray()).Trim().ToString());
|
info.productType = RemoveNull(GetTrayCode(result.Skip(55).Take(10).ToArray()).Trim().ToString());
|
info.materialCode = RemoveNull(GetTrayCode(result.Skip(65).Take(15).ToArray()).Trim().ToString());
|
info.materialName = RemoveNull(GetTrayCode(result.Skip(80).Take(20).ToArray()).Trim().ToString());
|
info.measurementUnit = RemoveNull(GetTrayCode(result.Skip(100).Take(5).ToArray()).Trim().ToString());
|
|
CMMLog.Info($"数据处理流程：包装机无MES情况下，获取以往MES传输的数据，新获得数据，lotNo:{info.lotNo},productType:{info.productType},materialCode:{info.materialCode},materialName:{info.materialName},measurementUnit:{info.measurementUnit}");
|
|
|
//注意：这里赋值中间表参数请对照信息交互表具体通道值对应
|
UpdateBuilder update = Update.Set("palletLayers", info.secondNg.ToString()).Set("overlappingLayers", info.addState.ToString()).Set("bagNo", info.packageCode).
|
Set("lotNo", info.lotNo).Set("productType", info.productType).Set("materialCode", info.materialCode).Set("materialName", info.materialName).Set("measurementUnit", info.measurementUnit);
|
MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(Query.EQ("machineNo", location), update, "MachineInfoTetracobalt", UpdateFlags.None);
|
MongoDBSingleton.Instance.Update<MachineInfoTwoTetracobalt>(Query.EQ("trayCode", trayCode), update, "MachineInfoTwoTetracobalt", UpdateFlags.None);
|
}
|
//在中间表中找到刚刚插入的MES数据（目前还没有读取并写入设备数据）
|
|
timeStamp = ProcessHelper.GetTimeStamp(31, 1, 1);
|
trayCode = "VW" + timeStamp;
|
|
var query1 = Query.And(Query.EQ("machineNo", location), Query.EQ("trayCode", "0"));
|
UpdateBuilder updateBuider = Update.Set("empCode", info.empCode).Set("location", info.location).
|
Set("trayCode", trayCode).Set("productWeight", info.productWeight).
|
Set("trayCodeWeight", info.trayCodeWeight).Set("oneTrayWeight", info.oneTrayWeight).Set("trayType", info.trayType).Set("addState", info.addState).
|
Set("addWeight", info.addWeight).Set("packNg", info.packNg).Set("secondNg", info.secondNg).Set("productTime", info.productTime).Set("packageCode", info.packageCode).
|
Set("jsonData", json).Set("modify", DateTime.Now);
|
MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(query1, updateBuider, "MachineInfoTetracobalt", UpdateFlags.None);
|
MongoDBSingleton.Instance.Update<MachineInfoTwoTetracobalt>(query1, updateBuider, "MachineInfoTwoTetracobalt", UpdateFlags.None);
|
CMMLog.Info($"数据处理流程：更新MachineInfoTetracobalt中间表刚刚插入的MES数据!设备号为：{location},托盘号为：{trayCode}");
|
}
|
else
|
{
|
//复称入缓存架，读取复称平台数据
|
CMMLog.Info("数据处理流程：进入info判断02");
|
//读取除包装机外其他设备的信息，更新包装机下线时的数据
|
var query2 = Query.And(Query.EQ("machineNo", location), Query.EQ("trayCode", trayCode));
|
var info2 = MongoDBSingleton.Instance.FindOne<MachineInfoTetracobalt>(query2, "MachineInfo");
|
if (info2 != null)
|
{
|
UpdateBuilder updateBuider = Update.Set("empCode", info.empCode).Set("location", info.location).
|
Set("trayCode", info.trayCode).Set("productWeight", info.productWeight).
|
Set("trayCodeWeight", info.trayCodeWeight).Set("oneTrayWeight", info.oneTrayWeight).
|
Set("addWeight", info.addWeight).Set("packNg", info.packNg).Set("secondNg", info.secondNg).Set("productTime", info.productTime).
|
Set("jsonData", json).Set("modify", DateTime.Now);
|
MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(query2, updateBuider, "MachineInfoTetracobalt", UpdateFlags.None);
|
MongoDBSingleton.Instance.Update<MachineInfoTwoTetracobalt>(Query.EQ("trayCode", trayCode), updateBuider, "MachineInfoTwoTetracobalt", UpdateFlags.None);
|
CMMLog.Info($"数据处理流程：更新MachineInfoTetracobalt中间表其他设备的数据!设备号为：{location},托盘号为：{trayCode}");
|
}
|
else CMMLog.Info($"数据处理流程：无法在MachineInfoTetracobalt中间表中找到当前设备编号的数据！当前设备编号为：{location}，托盘码为：{trayCode}");
|
}
|
}
|
else CMMLog.Error("数据处理流程：数据流程处理托盘号或包装机号为空值！");
|
|
CMMLog.Info($"数据处理流程：数据处理流程结束！");
|
}
|
|
/// <summary>
|
/// 获取复称点状态信息
|
/// </summary>
|
/// <returns></returns>
|
public static SecondWeighState GetSecondWeighState(string location)
|
{
|
//传入当前设备编号，并将传入的设备编号放入复称中间表的来源变量中
|
string PlcBit02 = Settings.GetPlcInfo().Where(a => a.deviceType == "2").FirstOrDefault().location;
|
var query = Query.EQ("location", PlcBit02);
|
var model = MongoDBSingleton.Instance.FindOne<SecondWeighState>(query, "SecondWeighState");
|
if (model == null)
|
{
|
MongoDBSingleton.Instance.Insert<SecondWeighState>(new SecondWeighState { location = PlcBit02, from = location,full = 0,ng = 1 });
|
CMMLog.Debug($"判断复称状态信息服务，复称中间表数据为空，开始插入默认值！");
|
}
|
else MongoDBSingleton.Instance.Update<SecondWeighState>(query, Update.Set("from", location), "SecondWeighState", UpdateFlags.None);
|
return model;
|
}
|
|
/// <summary>
|
/// 获取复称点状态信息（四钴）
|
/// </summary>
|
/// <returns></returns>
|
public static SecondWeighState GetSecondWeighStateTetracobalt(string location)
|
{
|
//传入当前设备编号，并将传入的设备编号放入复称中间表的来源变量中
|
string PlcBit02 = Settings.GetPlcInfo().Where(a => a.deviceType == "22").FirstOrDefault().location;
|
var query = Query.EQ("location", PlcBit02);
|
var model = MongoDBSingleton.Instance.FindOne<SecondWeighState>(query, "SecondWeighState");
|
if (model == null)
|
{
|
MongoDBSingleton.Instance.Insert<SecondWeighState>(new SecondWeighState { location = PlcBit02, from = location,full = 0,ng = 1 });
|
CMMLog.Debug($"判断复称状态信息服务，复称中间表数据为空，开始插入默认值！");
|
}
|
else MongoDBSingleton.Instance.Update<SecondWeighState>(query, Update.Set("from", location), "SecondWeighState", UpdateFlags.None);
|
return model;
|
}
|
|
/// <summary>
|
/// 复称平台数据
|
/// </summary>
|
public class SecondWeighState
|
{
|
public ObjectId _id { get; set; }
|
public string location { get; set; }
|
/// <summary>
|
/// 0未知 1合格 2不合格
|
/// </summary>
|
public int ng { get; set; }
|
/// <summary>
|
/// 复称平台货从哪里来的
|
/// </summary>
|
public string from { get; set; }
|
/// <summary>
|
/// 批次号
|
/// </summary>
|
public string batchNo { get; set; }
|
/// <summary>
|
/// 包装机下线重量
|
/// </summary>
|
public int weight { get; set; }
|
/// <summary>
|
/// 1 满 0 空
|
/// </summary>
|
public int full { get; set; }
|
public string mesInfo { get; set; }
|
}
|
|
/// <summary>
|
/// 获取复称点位位置
|
/// </summary>
|
/// <returns></returns>
|
/// <exception cref="NotImplementedException"></exception>
|
public static string GetSecondWeighBit()
|
{
|
//改成读settings
|
var plc = Settings.GetPlcInfo().Where(a => a.deviceType == "2").FirstOrDefault();
|
return plc.location;
|
}
|
|
/// <summary>
|
/// 将设备通道里面读取的16位short转成ascii字符串
|
/// </summary>
|
/// <param name="data"></param>
|
/// <returns></returns>
|
public static string GetTrayCode(int[] data)
|
{
|
StringBuilder sb = new StringBuilder();
|
data.ToList().ForEach(a => {
|
var bytes = BitConverter.GetBytes((short)a).Reverse().ToArray();
|
sb.Append(Encoding.ASCII.GetString(bytes));
|
});
|
return sb.ToString();
|
}
|
|
/// <summary>
|
/// 十进制转换为2进制（自动补全16位）
|
/// </summary>
|
/// <param name="data"></param>
|
/// <returns></returns>
|
public static string Completion(int data)
|
{
|
var result = Convert.ToString(data, 2).PadLeft(16, '0');
|
return result;
|
}
|
|
/// <summary>
|
/// ascii转10进制（通过16进制中转）
|
/// </summary>
|
/// <param name="data"></param>
|
/// <returns></returns>
|
public static string AsciiToTen(string data)
|
{
|
byte[] oneSixbad = System.Text.ASCIIEncoding.Default.GetBytes(data);
|
StringBuilder oneSixsb = new StringBuilder();
|
foreach (byte b in oneSixbad)
|
{
|
oneSixsb.Append(b.ToString("x"));
|
}
|
int oneSixA2 = Convert.ToInt32(oneSixsb.ToString(), 16);
|
return oneSixA2.ToString();
|
}
|
|
#region 叠盘机批量写入数据
|
|
#region 产品型号分离处理方法
|
//public static int[] DiePan(WMSInfo machine)
|
//{
|
// //偏移量 +11 通道范围： 40311 ~ 40370
|
// CMMLog.Info($"进入DiePan数据处理方法");
|
// //10~19通道
|
// int[] num = new int[60];
|
// int[] num3 = new int[40];
|
// int a = 0;//托盘码处理
|
// for (int b = 0; b <= 2; b++)
|
// {
|
// num[b] = int.Parse(AsciiToTen(machine.trayCode.Substring(a, 2)));
|
// a = a + 2;
|
// }
|
// num[3] = int.Parse(AsciiToTen(machine.location));//包装机号
|
// for (int b = 4; b <= 5; b++)
|
// {
|
// int k = b % 2 == 0 ? 0 : 16;
|
// num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.productWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
// }
|
// for (int b = 6; b <= 7; b++)
|
// {
|
// int k = b % 2 == 0 ? 0 : 16;
|
// num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.trayCodeWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
// }
|
// for (int b = 8; b <= 9; b++)
|
// {
|
// int k = b % 2 == 0 ? 0 : 16;
|
// num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.oneTrayWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
// }
|
// for (int b = 10; b <= 12; b++) num[b] = 0;// 叠包后实际重量 && 复称结果 默认：0
|
// num[13] = string.IsNullOrEmpty(machine.palletLayers) ? 0 : int.Parse(machine.palletLayers);//是否需要叠托盘
|
// num[14] = machine.addState;//是否需要叠包
|
// num[15] = int.Parse(machine.packageCode);//袋号
|
// //时间戳处理
|
// string timeStamp = ProcessHelper.GetTimeStamp(32, 1, 1);
|
// for (int b = 16; b <= 17; b++)
|
// {
|
// int k = b % 2 == 0 ? 0 : 16;
|
// num[b] = Convert.ToInt32(Convert.ToString(int.Parse(timeStamp), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
// }
|
// for (int b = 18; b <= 19; b++) num[b] = 0;//预留的两个通道 默认：0
|
|
// //19 = 30 31 ~ 60
|
// //30~59通道 60~70通道
|
// string pcHead = "";
|
// string cpHead = "";
|
// #region 31~60
|
|
// string data = machine.itemPCode;
|
// CMMLog.Info($"31~60data1_1:{data}");
|
// if (data.Length % 2 != 0)
|
// {
|
// data = "0" + machine.itemPCode;
|
// pcHead = "" + machine.itemPCode.Substring(0, 1);
|
// }
|
// CMMLog.Info($"31~60data1_2:{data}");
|
// int x = data.Length / 2;
|
// int aa = 0;
|
// for (int i = 0; i <= x - 1; i++)
|
// {
|
// num3[i] = int.Parse(AsciiToTen(data.Substring(aa, 2)));
|
// aa = aa + 2;
|
// }
|
// for (int m = x; m <= 29; m++) num3[m] = 0;//将产品批次号无数据的通道全部置为 0
|
// CMMLog.Info($"itemPCode:" + JsonConvert.SerializeObject(num3));
|
// #endregion
|
|
// #region 61~70
|
|
// string data2 = machine.itemCode;
|
// CMMLog.Info($"61~70data2_1:{data2}");
|
// if (data2.Length % 2 != 0)
|
// {
|
// data2 = "0" + machine.itemCode;
|
// cpHead = "" + machine.itemCode.Substring(0, 1);
|
// }
|
// CMMLog.Info($"61~70data2_2:{data2}");
|
// int y = data2.Length / 2;
|
// CMMLog.Info($"{y}");
|
// int aaa = 0;
|
// //4 2 32 9 41
|
// for (int i = 30; i <= y + 29; i++)
|
// {
|
// num3[i] = int.Parse(AsciiToTen(data2.Substring(aaa, 2)));
|
// CMMLog.Info(JsonConvert.SerializeObject(num3[i]));
|
// aaa = aaa + 2;
|
// }
|
// int mm = y + 30;
|
// CMMLog.Info($"mm:{mm}");
|
// for (int mmm = mm; mmm <= 39; mmm++)
|
// {
|
// num3[mmm] = 0;
|
// CMMLog.Info(JsonConvert.SerializeObject(num3[mmm]));
|
// }
|
// CMMLog.Info($"itemPCode+itemCode:{JsonConvert.SerializeObject(num3)}");
|
// #endregion
|
|
// for (int i = 20; i <= 60; i++) num[i] = num3[i - 20];
|
|
// // 如果 产品批次号 或者 产品型号 位数 为 奇数，则将提前取出的 首字符 重新转码 写入 其所对应通道区域的 首通道
|
// if (pcHead != "" || cpHead != "")
|
// {
|
// if (pcHead != "") num[20] = int.Parse(AsciiToTen(pcHead));
|
// if (cpHead != "") num[50] = int.Parse(AsciiToTen(cpHead));
|
// CMMLog.Info($"产品型号或批次号数量为奇数，特将首位取出单独处理，以下为批次号和产品型号的十进制数值{num[20]},{num[50]}");
|
// }
|
// CMMLog.Info($"DiePan数据处理方法完毕");
|
|
// return num;
|
//}
|
#endregion
|
|
public static int[] DiePan(WMSInfo machine)
|
{
|
//偏移量 +11 通道范围： 40311 ~ 40370
|
CMMLog.Info($"叠盘机数据处理.");
|
//10~19通道
|
int[] num = new int[50];//ERP变更：变更后通道 50 变更前：60
|
|
#region 0~19 => 11~30
|
|
int a = 0;//托盘码处理
|
for (int b = 0; b <= 2; b++)
|
{
|
num[b] = int.Parse(AsciiToTen(machine.trayCode.Substring(a, 2)));
|
a = a + 2;
|
}
|
num[3] = int.Parse(AsciiToTen(machine.location));//包装机号
|
for (int b = 4; b <= 5; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.productWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 6; b <= 7; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.trayCodeWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 8; b <= 9; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.oneTrayWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 10; b <= 12; b++) num[b] = 0;// 叠包后实际重量 && 复称结果 默认：0
|
num[13] = string.IsNullOrEmpty(machine.palletLayers) ? 0 : int.Parse(machine.palletLayers);//是否需要叠托盘
|
num[14] = machine.addState;//是否需要叠包
|
num[15] = int.Parse(machine.packageCode);//袋号
|
//时间戳处理
|
string timeStamp = ProcessHelper.GetTimeStamp(32, 1, 1);
|
for (int b = 16; b <= 17; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(timeStamp), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 18; b <= 19; b++) num[b] = 0;//预留的两个通道 默认：0
|
|
#endregion
|
|
string pcHead = "";
|
string cpHead = "";
|
|
#region 20~39 => 31~50 产品批次号
|
|
string data = machine.itemPCode;
|
CMMLog.Info($"31~50data1_1:{data}");
|
if (data.Length % 2 != 0)
|
{
|
data = "0" + machine.itemPCode;
|
pcHead = "" + machine.itemPCode.Substring(0, 1);
|
}
|
CMMLog.Info($"31~50data1_2:{data}");
|
//字符串长度 / 2 = 写入通道数量(两位一转) 列： 3L0050 写入三个通道
|
int maxLength = 19 + (data.Length / 2);// data.Length / 2 至少为 1
|
int aa = 0;
|
for (int i = 20; i <= maxLength; i++)
|
{
|
num[i] = int.Parse(AsciiToTen(data.Substring(aa, 2)));
|
aa = aa + 2;
|
}
|
for (int x = maxLength + 1; x <= 39; x++) num[x] = 0;//将产品批次号无数据的通道全部置为 0
|
#endregion
|
|
#region 40~49 => 51~60 产品型号
|
|
string data2 = machine.itemCode;
|
CMMLog.Info($"51~60data2_1:{data2}");
|
if (data2.Length % 2 != 0)
|
{
|
data2 = "0" + machine.itemCode;
|
cpHead = "" + machine.itemCode.Substring(0, 1);
|
}
|
CMMLog.Info($"51~60data2_2:{data2}");
|
maxLength = 39 + (data2.Length / 2);
|
int aaa = 0;
|
for (int i = 40; i <= maxLength; i++)
|
{
|
num[i] = int.Parse(AsciiToTen(data2.Substring(aaa, 2)));
|
aaa = aaa + 2;
|
}
|
for (int x = maxLength + 1; x <= 49; x++) num[x] = 0;//将产品型号无数据的通道全部置为0
|
#endregion
|
|
// 如果 产品批次号 或者 产品型号 位数 为 奇数，则将提前取出的 首字符 重新转码 写入 其所对应通道区域的 首通道
|
if (pcHead != "") num[20] = int.Parse(AsciiToTen(pcHead));
|
if (cpHead != "") num[40] = int.Parse(AsciiToTen(cpHead));
|
if (pcHead != "" || cpHead != "") CMMLog.Info($"产品型号或批次号数量为奇数，特将首位取出单独处理，以下为批次号和产品型号的十进制数值{num[20]},{num[50]}");
|
|
CMMLog.Info($"叠盘机数据处理完毕：{JsonConvert.SerializeObject(num)}");
|
|
return num;
|
}
|
|
public static int[] DiePanTwo(WMSInfo machine, MachineInfoTwo machineInfoTwo)
|
{
|
var ErpItemInfo = MongoDBSingleton.Instance.FindOne<ERPItemTable>(Query.EQ("item_code", machineInfoTwo.materialCode), "ERPItemTable");
|
CMMLog.Info($"3楼缓存架入叠托:收到信号5，查询MachineInfoTwo表信息：{JsonConvert.SerializeObject(ErpItemInfo)}。");
|
|
//偏移量 +11 通道范围： 40311 ~ 40390
|
CMMLog.Info($"叠盘机数据处理.");
|
//10~19通道
|
int[] num = new int[90];//总长度：80
|
|
#region 0~19 => 11~30
|
|
int a = 0;//托盘码处理
|
for (int b = 0; b <= 2; b++)
|
{
|
num[b] = int.Parse(AsciiToTen(machine.trayCode.Substring(a, 2)));
|
a = a + 2;
|
}
|
num[3] = int.Parse(AsciiToTen(machine.location));//包装机号
|
for (int b = 4; b <= 5; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.productWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 6; b <= 7; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.trayCodeWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 8; b <= 9; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.oneTrayWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 10; b <= 11; b++) num[b] = 0;// 叠包后实际重量 && 复称结果 默认：0
|
num[12] = 1;
|
num[13] = 2;//是否需要叠托盘 // string.IsNullOrEmpty(machine.palletLayers) ? 0 : int.Parse(machine.palletLayers)
|
num[14] = machine.addState;//是否需要叠包
|
num[15] = int.Parse(machine.packageCode);//袋号
|
//时间戳处理
|
string timeStamp = ProcessHelper.GetTimeStamp(32, 1, 1);
|
for (int b = 16; b <= 17; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(timeStamp), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 18; b <= 19; b++) num[b] = 0;//预留的两个通道 默认：0
|
|
#endregion
|
|
string pcHead = "";
|
string cpHead = "";
|
string mtHead = "";// 设备的真实物料编码
|
|
#region 20~39 => 31~50 产品批次号
|
|
string data = machineInfoTwo.lotNo;
|
CMMLog.Info($"31~50data1_1:{data}");
|
if (data.Length % 2 != 0)
|
{
|
data = "0" + machineInfoTwo.lotNo;
|
pcHead = "" + machineInfoTwo.lotNo.Substring(0, 1);
|
}
|
CMMLog.Info($"31~50data1_2:{data}");
|
//字符串长度 / 2 = 写入通道数量(两位一转) 列： 3L0050 写入三个通道
|
int maxLength = 19 + (data.Length / 2);// data.Length / 2 至少为 1
|
int aa = 0;
|
for (int i = 20; i <= maxLength; i++)
|
{
|
num[i] = int.Parse(AsciiToTen(data.Substring(aa, 2)));
|
aa = aa + 2;
|
}
|
for (int x = maxLength + 1; x <= 39; x++) num[x] = 0;//将产品批次号无数据的通道全部置为 0
|
#endregion
|
|
#region 40~49 => 51~60 产品型号
|
|
ERPService.HandleItemInfoChina(machine.itemCode, 40, 49, num);// 中文处理 70~84 81~95
|
|
//string data2 = machine.itemCode;
|
//CMMLog.Info($"51~50data2_1:{data2}");
|
//if (data2.Length % 2 != 0)
|
//{
|
// data2 = "0" + machine.itemCode;
|
// cpHead = "" + machine.itemCode.Substring(0, 1);
|
//}
|
//CMMLog.Info($"51~60data2_2:{data2}");
|
//maxLength = 39 + (data2.Length / 2);
|
//int aaa = 0;
|
//for (int i = 40; i <= maxLength; i++)
|
//{
|
// num[i] = int.Parse(AsciiToTen(data2.Substring(aaa, 2)));
|
// aaa = aaa + 2;
|
//}
|
//for (int x = maxLength + 1; x <= 49; x++) num[x] = 0;//将产品型号无数据的通道全部置为0
|
#endregion
|
|
#region 50~69 => 61~80 物料编码
|
|
string data3 = machineInfoTwo.materialCode;
|
CMMLog.Info($"61~80data3_1:{data3}");
|
if (data3.Length % 2 != 0)
|
{
|
//data3 = "0" + machineInfoTwo.materialCode;
|
mtHead = "" + machineInfoTwo.materialCode.Substring(0, 1);
|
}
|
CMMLog.Info($"61~80data3_2:{data3}");
|
maxLength = 49 + (data3.Length / 2);
|
int aaaa = 0;
|
for (int i = 50; i <= maxLength; i++)
|
{
|
num[i] = int.Parse(AsciiToTen(data3.Substring(aaaa, 2)));
|
aaaa = aaaa + 2;
|
}
|
for (int x = maxLength + 1; x <= 69; x++) num[x] = 0;//将产品型号无数据的通道全部置为0
|
#endregion
|
|
ERPService.HandleItemInfoChina(ErpItemInfo.item_name, 70, 84, num);// 中文处理 70~84 81~95
|
ERPService.HandleItemInfo(ErpItemInfo.item_uom, 85, 89, num);// 85~89 96~100
|
|
// 如果 产品批次号 或者 产品型号 位数 为 奇数，则将提前取出的 首字符 重新转码 写入 其所对应通道区域的 首通道
|
if (pcHead != "") num[20] = int.Parse(AsciiToTen(pcHead));
|
if (cpHead != "") num[40] = int.Parse(AsciiToTen(cpHead));
|
if (mtHead != "") num[50] = int.Parse(AsciiToTen(mtHead));
|
if (pcHead != "" || cpHead != "") CMMLog.Info($"产品型号或批次号数量为奇数，特将首位取出单独处理，以下为批次号和产品型号的十进制数值{num[20]},{num[50]}");
|
|
CMMLog.Info($"叠盘机数据处理完毕：{JsonConvert.SerializeObject(num)}");
|
|
return num;
|
}
|
|
|
public static int[] DiePanThree(WMSInfo machine, MachineInfoTwo machineInfoTwo)
|
{
|
//偏移量 +11 通道范围： 40311 ~ 40390
|
CMMLog.Info($"叠盘机数据处理.");
|
//10~19通道
|
int[] num = new int[80];//总长度：80
|
|
#region 0~19 => 11~30
|
|
int a = 0;//托盘码处理
|
for (int b = 0; b <= 2; b++)
|
{
|
num[b] = int.Parse(AsciiToTen(machine.trayCode.Substring(a, 2)));
|
a = a + 2;
|
}
|
num[3] = int.Parse(AsciiToTen(machine.location));//包装机号
|
for (int b = 4; b <= 5; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.productWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 6; b <= 7; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.trayCodeWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 8; b <= 9; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.oneTrayWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 10; b <= 12; b++) num[b] = 0;// 叠包后实际重量 && 复称结果 默认：0
|
num[13] = string.IsNullOrEmpty(machine.palletLayers) ? 0 : int.Parse(machine.palletLayers);//是否需要叠托盘
|
num[14] = machine.addState;//是否需要叠包
|
num[15] = int.Parse(machine.packageCode);//袋号
|
//时间戳处理
|
string timeStamp = ProcessHelper.GetTimeStamp(32, 1, 1);
|
for (int b = 16; b <= 17; b++)
|
{
|
int k = b % 2 == 0 ? 0 : 16;
|
num[b] = Convert.ToInt32(Convert.ToString(int.Parse(timeStamp), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2);
|
}
|
for (int b = 18; b <= 19; b++) num[b] = 0;//预留的两个通道 默认：0
|
|
#endregion
|
|
string pcHead = "";
|
string cpHead = "";
|
string mtHead = "";// 设备的真实物料编码
|
|
#region 20~49 => 31~60 产品批次号
|
|
string data = machine.itemPCode;
|
CMMLog.Info($"31~60data1_1:{data}");
|
if (data.Length % 2 != 0)
|
{
|
data = "0" + machine.itemPCode;
|
pcHead = "" + machine.itemPCode.Substring(0, 1);
|
}
|
CMMLog.Info($"31~60data1_2:{data}");
|
//字符串长度 / 2 = 写入通道数量(两位一转) 列： 3L0050 写入三个通道
|
int maxLength = 19 + (data.Length / 2);// data.Length / 2 至少为 1
|
int aa = 0;
|
for (int i = 20; i <= maxLength; i++)
|
{
|
num[i] = int.Parse(AsciiToTen(data.Substring(aa, 2)));
|
aa = aa + 2;
|
}
|
for (int x = maxLength + 1; x <= 49; x++) num[x] = 0;//将产品批次号无数据的通道全部置为 0
|
#endregion
|
|
#region 50~59 => 61~70 产品型号
|
|
string data2 = machine.itemCode;
|
CMMLog.Info($"61~70data2_1:{data2}");
|
if (data2.Length % 2 != 0)
|
{
|
data2 = "0" + machine.itemCode;
|
cpHead = "" + machine.itemCode.Substring(0, 1);
|
}
|
CMMLog.Info($"61~70data2_2:{data2}");
|
maxLength = 49 + (data2.Length / 2);
|
int aaa = 0;
|
for (int i = 50; i <= maxLength; i++)
|
{
|
num[i] = int.Parse(AsciiToTen(data2.Substring(aaa, 2)));
|
aaa = aaa + 2;
|
}
|
for (int x = maxLength + 1; x <= 59; x++) num[x] = 0;//将产品型号无数据的通道全部置为0
|
#endregion
|
|
#region 60~79 => 71~90 产品型号
|
|
string data3 = machineInfoTwo.materialCode;
|
CMMLog.Info($"71~90data3_1:{data3}");
|
if (data3.Length % 2 != 0)
|
{
|
data3 = "0" + machineInfoTwo.materialCode;
|
mtHead = "" + machineInfoTwo.materialCode.Substring(0, 1);
|
}
|
CMMLog.Info($"71~90data3_2:{data3}");
|
maxLength = 59 + (data3.Length / 2);
|
int aaaa = 0;
|
for (int i = 60; i <= maxLength; i++)
|
{
|
num[i] = int.Parse(AsciiToTen(data3.Substring(aaaa, 2)));
|
aaaa = aaaa + 2;
|
}
|
for (int x = maxLength + 1; x <= 79; x++) num[x] = 0;//将产品型号无数据的通道全部置为0
|
#endregion
|
|
// 如果 产品批次号 或者 产品型号 位数 为 奇数，则将提前取出的 首字符 重新转码 写入 其所对应通道区域的 首通道
|
if (pcHead != "") num[20] = int.Parse(AsciiToTen(pcHead));
|
if (cpHead != "") num[50] = int.Parse(AsciiToTen(cpHead));
|
if (mtHead != "") num[60] = int.Parse(AsciiToTen(mtHead));
|
if (pcHead != "" || cpHead != "") CMMLog.Info($"产品型号或批次号数量为奇数，特将首位取出单独处理，以下为批次号和产品型号的十进制数值{num[20]},{num[50]}");
|
|
CMMLog.Info($"叠盘机数据处理完毕：{JsonConvert.SerializeObject(num)}");
|
|
return num;
|
}
|
#endregion
|
|
#endregion
|
|
public class Z_ChaiPanEmptyOrFull
|
{
|
public ObjectId _id { get; set; }
|
/// <summary>
|
/// 拆盘点位
|
/// </summary>
|
public string ChaiPanBit { get; set; }
|
/// <summary>
|
/// 拆盘点位空满状态--空|满
|
/// </summary>
|
public string ChaiPanState { get; set; }
|
}
|
|
|
public class ActionControlModel
|
{
|
public ObjectId _id { get; set; }
|
/// <summary>
|
/// 功能码-- 1-生成复称平台入缓存架任务
|
/// </summary>
|
public string actionNo { get; set; } = "0";
|
/// <summary>
|
/// 1-ip
|
/// </summary>
|
public string ext1 { get; set; } = "";
|
/// <summary>
|
/// 1-CN_S_BATCH_NO
|
/// </summary>
|
public string ext2 { get; set; } = "";
|
public string ext3 { get; set; } = "";
|
public int ext4 { get; set; } = 0;
|
public string machince { get; set; } = "";
|
}
|
|
internal static void changeSignal()
|
{
|
CMMLog.Info("车辆状态处理：执行开始！");
|
try
|
{
|
//查询小车状态表，写入小车坐标和方向 并写入中间表
|
var agvState = MongoDBSingleton.Instance.FindAll<AGV_STATE>();
|
if (agvState.Count > 0)
|
{
|
agvState.ForEach(a =>
|
{
|
var stateInfo = Settings.GetAGVStateList().Where(it => it.AgvNo == a.forkliftNo).FirstOrDefault();
|
if (stateInfo != null)
|
{
|
int[] num = new int[6];//总长度：6
|
int divisor = 65536; // 除数
|
int xPos = int.Parse(a.xPos) * 10;
|
int yPos = int.Parse(a.yPos) * 10;
|
|
int xquotient = xPos / divisor; // 计算商数
|
int xremainder = xPos % divisor; // 计算余数
|
num[0] = xquotient;
|
num[1] = xremainder;
|
|
int yquotient = yPos / divisor; // 计算商数
|
int yremainder = yPos % divisor; // 计算余数
|
num[2] = yquotient;
|
num[3] = yremainder;
|
|
#region
|
//int m = 0;//托盘码处理
|
//for (int b = 0; b <= 1; b++)
|
//{
|
// num[b] = int.Parse(AsciiToTen(a.xPos.Substring(m, 2)));
|
// m = m + 2;
|
//}
|
//m = 0;
|
//for (int b = 2; b <= 3; b++)
|
//{
|
// num[b] = int.Parse(AsciiToTen(a.yPos.Substring(m, 2)));
|
// m = m + 2;
|
//}
|
#endregion
|
|
num[4] = string.IsNullOrEmpty(a.Degree) ? 0 : int.Parse(a.Degree);
|
//num[4] = int.Parse(a.Degree);
|
num[5] = a.errCode != "0" || a.errCode2 != "0" || a.faildCode != "0" ? 2 : 0;
|
|
//if (a.errCode != "0" || a.errCode2 != "0" || a.faildCode != "0") num[5] = 2;
|
|
CMMLog.Info($"车辆状态处理：写入车辆数据：车号：{a.forkliftNo},ip:{stateInfo.ip},port:{stateInfo.port},data:{JsonConvert.SerializeObject(num)}");
|
var wirteal = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
addr = stateInfo.writeAddr,
|
host = stateInfo.ip,
|
port = stateInfo.port,
|
data = num
|
});
|
}
|
else CMMLog.Info($"车辆状态处理：小车{a.forkliftNo}未配置");
|
});
|
}
|
else CMMLog.Info("车辆状态处理：AGV_STATE 车辆状态表未获取到车辆状态数据！");
|
}
|
catch(Exception ex)
|
{
|
CMMLog.Info($"车辆状态处理-异常：{ex.Message}！");
|
}
|
|
CMMLog.Info("车辆状态处理：执行结束！");
|
Thread.Sleep(1000);
|
}
|
|
/// <summary>
|
/// 返料站台送物料
|
/// </summary>
|
/// <param name="device"></param>
|
internal static void LiftAction(Settings.PlcInfo plc, string taskNo, bool result)
|
{
|
if(plc.device == "24")
|
{
|
if (result)
|
{
|
//返料站台任务
|
//ASM写入通道0小车动作，1-取料
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.writeAddr,
|
data = 1
|
});
|
if (writeRes.errCode == 0)
|
{
|
//小车请求进入安全门交互
|
//小车请求进料，并且查询设备是否允许AGV进入
|
//读地址1设备是否 2-可以进入
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = plc.ip,
|
addr = plc.readAddr,
|
port = plc.port
|
});
|
CMMLog.Debug($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
Console.WriteLine($"读取设备{plc.location}通道{plc.readAddr + 1}里面数据为{readRes.result[0]}.");
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 2)
|
{
|
//设备允许进入，改参数通知AGV
|
WorkFlowAction.TrackLog(taskNo, 10, 1013, "success");
|
TSHelper.GoToAGV(taskNo, 10, 1);
|
}
|
}
|
else CMMLog.Debug($"入返料站台：1013，readRes：{readRes},readRes.errCode:{readRes.errCode}");
|
}
|
}
|
else
|
{
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
port = plc.port,
|
addr = plc.writeAddr,
|
data = 3
|
});
|
}
|
}
|
}
|
|
/// <summary>
|
/// 3楼包装机取料至复称平台流程——任务开始前，判断包装机有没有下线信号，并判断当前复称平台是否NG以及有没有任务在进行中(四钴)
|
/// </summary>
|
/// <param name="a"></param>
|
internal static void CheckPackingMachineTetracobalt(Settings.PlcInfo pmInfo)
|
{
|
//var count = MongoDBSingleton.Instance.FindOne<>//occupy
|
var count = MongoDBSingleton.Instance.FindOne<MachineInfoTetracobalt>(Query.EQ("occupy", "1"), "MachineInfoTetracobalt");
|
|
//检查包装机通道0是否有下料信号，如果有生成下料任务。线程循环读取，无需设置循环。——通道0参数为1
|
if (count == null)
|
{
|
// var secondInfo = MongoDBSingleton.Instance.FindOne<secondResult>(Query.EQ("Bit", pmInfo.location), "secondResult");
|
// if(secondInfo == null || secondInfo.Status == "OK")
|
// {
|
if (PickUpStartFree(pmInfo.location) && PickUpEndFree(pmInfo.location))
|
{
|
try
|
{
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = pmInfo.readAddr,
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
if (result != null && result.errCode == 0)
|
{
|
CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：读取包装机通道号为：{pmInfo.readAddr}里面的值为{result.result[0]}");
|
//Console.WriteLine($"包装下线流程：读取包装机通道号为：{pmInfo.readAddr}里面的值为{result.result[0]}");
|
if (result != null && result.errCode == 0 && result.result.Count() > 0)
|
{
|
//1：取料
|
if (result.result[0] == 1)
|
{
|
string PlcBit02 = Settings.GetPlcInfo().Where(a => a.deviceType == "22").FirstOrDefault().location;
|
//包装下线任务，终点为复称位置（这里判断包装机起点，复称起点终点均无任务，则推送任务）
|
if (ProcessHelper.PickUpStartFree(pmInfo.location) && ProcessHelper.CheckEndFree(PlcBit02) && ProcessHelper.PickUpStartFree(PlcBit02))
|
{
|
//判断复称位置，没有货并且不为NG(ng参数0，1，2——0，不确定（包装机刚开始工作时）1，ok 2，ng)
|
var state = GetSecondWeighStateTetracobalt(pmInfo.location);
|
CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：判断复称位置空满状态为:{state.full},ng状态为：{state.ng}");
|
if (state.full == 0)
|
{
|
if (Settings.mesOpen == "1")
|
{
|
//可以生成任务，调mes接口获取生产信息 2022.7.28 变更 MES可能需要1~2年才能上线，先把MES功能注销
|
CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：获取MES之后进入info判断！");
|
var trayCode = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
addr = pmInfo.readAddr + 5,
|
dataNum = 105,////ERP变更：90 原先：80
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
if (trayCode.errCode == 0 && trayCode.result.Length == 105)
|
{
|
//获取托盘码等信息 读取通道 11、12、13的数据作为托盘码 读取其它通道 重量 叠包等信息 所有数据存入MachineInfo表
|
string timeStamp = "";
|
GetMachineDataTetracobalt(trayCode.result, ref timeStamp, false);
|
var tray = MongoDBSingleton.Instance.FindOne<MachineInfoTetracobalt>(Query.EQ("machineNo", pmInfo.location), "MachineInfoTetracobalt");
|
if (tray != null)
|
{
|
CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：MachineInfoTetracobalt数据插入成功！");
|
bool IsContLaterCode = true;
|
if (ERPService.ERPSwitch01 == "1")
|
{
|
string employeeId = "G" + tray.empCode.PadLeft(7, '0');
|
CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：员工编码：{employeeId}");
|
// 判断当前【员工编号】通道信息读出来的员工编号是否已经存在于我们的员工信息表-ERPEmployeeTable(查询字段-employee_id)
|
var erpEmployeeInfo = MongoDBSingleton.Instance.FindOne<ERPEmployeeTable>(Query.EQ("employee_id", employeeId), "ERPEmployeeTable");
|
var erpItemInfo = MongoDBSingleton.Instance.FindOne<ERPItemTable>(Query.EQ("item_code", tray.materialCode), "ERPItemTable");
|
if (string.IsNullOrEmpty(tray.empCode) || string.IsNullOrEmpty(tray.materialCode) || erpEmployeeInfo == null || erpEmployeeInfo == null)
|
{
|
CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：人员表或者物料表未找到该数据，员工编号：{employeeId}，物料编码：{tray.materialCode}！");
|
IsContLaterCode = false;
|
}
|
else CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：员工编码查询成功");
|
}
|
|
if (IsContLaterCode)
|
{
|
//检索员工信息成功
|
var wirteall01 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = pmInfo.writeAddr,
|
host = pmInfo.ip,
|
port = pmInfo.port,
|
data = 4
|
});
|
|
//string timeStamp = ProcessHelper.GetTimeStamp(31, 1, 1);
|
//tray.trayCode = "VW" + timeStamp;
|
//MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(Query.EQ("_id", tray._id), Update.Set("trayCode", tray.trayCode), UpdateFlags.None);
|
//MongoDBSingleton.Instance.Update<MachineInfoTwoTetracobalt>(Query.EQ("_id", tray._id), Update.Set("trayCode", tray.trayCode), UpdateFlags.None);
|
CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：托盘码：{tray.trayCode}");
|
if (tray.addState == 0)
|
{
|
MongoDBSingleton.Instance.Remove<MachineInfoTetracobalt>(Query.EQ("machineNo", pmInfo.location), "MachineInfoTetracobalt", RemoveFlags.None);
|
if (ERPService.ERPSwitch01 == "0") MongoDBSingleton.Instance.Remove<MachineInfoTetracobalt>(Query.EQ("machineNo", pmInfo.location), "MachineInfoTwo", RemoveFlags.None);
|
CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：叠托层数为0，不允许生成任务");
|
}
|
else if (tray.trayCode != "0" && !string.IsNullOrEmpty(tray.trayCode))
|
{
|
HHAmsExecuteResult req = AMSHelper.CreateTask(DateTime.Now.Ticks.ToString(), pmInfo.location, PlcBit02, "3楼包装取料(四钴)", 0, tray.trayCode, timeStamp);
|
if (req.success)
|
{
|
string weight = (double.Parse(tray.oneTrayWeight) / 100).ToString();
|
ERPService.packageInfo(tray.machineNo, tray.trayCode, tray.lotNo, weight);
|
|
//记录托盘类型
|
var trayTypeInfo = MongoDBSingleton.Instance.FindOne<trayTypeTable>(Query.EQ("locCode", pmInfo.location), "trayTypeTable");
|
if(trayTypeInfo == null)
|
{
|
MongoDBSingleton.Instance.Insert<trayTypeTable>(new trayTypeTable
|
{
|
locCode = pmInfo.location,
|
trayType = tray.trayType
|
});
|
}
|
}
|
}
|
}
|
else
|
{
|
CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：员工编码查询失败");
|
//检索员工信息失败写入对方通道值1 读取地址+3
|
var wirteall01 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = pmInfo.readAddr + 3,
|
host = pmInfo.ip,
|
port = pmInfo.port,
|
data = 1
|
});
|
}
|
}
|
else CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：tray==null!");
|
}
|
else CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：3楼包装至复称获取MODBUS值错误！trayCode.errCode:{trayCode.errCode},trayCode.result.Length:{trayCode.result.Length}");
|
}
|
}
|
else
|
{
|
var task = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.Or(Query.EQ("CN_S_START_BIT", PlcBit02), Query.EQ("CN_S_END_BIT", PlcBit02)), "TN_I_TASK_MST");
|
if (task != null) CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：检查复称中间表是否为空，不为空则检查其数据full以及ng是否为0和1！任务号为：{task.CN_S_TASK_NO}");
|
else CMMLog.Debug("（四钴车间）包装下线流程-{pmInfo.location}：检查复称中间表是否为空，不为空则检查其数据full以及ng是否为0和1！");
|
}
|
}
|
else CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：包装机起点或者复称起点终点有任务在执行中！包装机点位：{pmInfo.location},复称点位：{PlcBit02}");
|
}
|
else CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：包装机通道0里面的数据不为1！result为：{JsonConvert.SerializeObject(result)}");
|
}
|
else CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：未读取到包装机通道0里面的数据！！！result:{JsonConvert.SerializeObject(result)}");
|
}
|
else CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}：未读取到包装机通道0里面的数据！！！result:{JsonConvert.SerializeObject(result)}");
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Debug($"（四钴车间）包装下线流程-{pmInfo.location}:" + ex.Message);
|
}
|
}
|
else
|
{
|
//var taskNo = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.Or(Query.EQ("CN_S_START_BIT", pmInfo.location), Query.EQ("CN_S_END_BIT", pmInfo.location)), "TN_I_TASK_MST");
|
//string task = "", startbit = "", endbit = "";
|
//if (taskNo != null)
|
//{
|
// task = taskNo.CN_S_TASK_NO;
|
// startbit = taskNo.CN_S_START_BIT;
|
// endbit = taskNo.CN_S_END_BIT;
|
//}
|
CMMLog.Debug($"当前包装机起点终点有任务正在执行，请确认当前包装机的任务是否取货卸货完成！包装机货位编码：{pmInfo.location}");
|
}
|
// }
|
// else CMMLog.Info($"当前包装机出现故障，无法生成任务。包装机号：{pmInfo.location}");
|
}
|
else CMMLog.Debug($"当前MachineInfoTetracobalt中间表已存在数据：{JsonConvert.SerializeObject(count)}");
|
}
|
|
|
static object PickUpBlankCompleteLock = new object();
|
internal static void PickUpBlankCompleteTetracobalt(string PlcBitCache01, string Extend = "")
|
{
|
lock (PickUpBlankCompleteLock)
|
{
|
CMMLog.Info("包装线补空流程任务处理");
|
try
|
{
|
if (Extend != "")
|
{
|
CMMLog.Info($"当前周转托盘位:{Extend}");
|
int addr = 0;
|
int qun = 0;
|
//修改中间表的值，若中间表的数量为0，则调用解绑方法
|
var bzEmp = MongoDBSingleton.Instance.FindOne<BZEmptyPoint>(Query.EQ("Bit", Extend), "BZEmptyPoint");
|
if (bzEmp != null)
|
{
|
CMMLog.Info($"当前货位的数量:{bzEmp.Quantity}");
|
if (bzEmp.Quantity == 1)
|
{
|
CMMLog.Info($"调用解绑接口");
|
//解绑
|
if (WMSHelper.WMSEmptyUnbind(Extend))
|
{
|
//删除中间表数据
|
MongoDBSingleton.Instance.Remove<BZEmptyPoint>(Query.EQ("Bit", Extend), RemoveFlags.Single);
|
}
|
}
|
else
|
{
|
var quantity = bzEmp.Quantity - 1;
|
var updateBuider = Update.Set("Quantity", quantity);
|
MongoDBSingleton.Instance.Update<BZEmptyPoint>(Query.EQ("Bit", Extend), updateBuider, UpdateFlags.None);
|
CMMLog.Info($"减去当前周转托盘位数量之后，数量为：{quantity}");
|
qun = quantity;
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
CMMLog.Error($"PickUpBlankComplete Error:" + ex.Message);
|
}
|
}
|
}
|
|
#region 包装线补空任务
|
internal static void PackingLine(string ip, string taskNo)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.ip == ip).FirstOrDefault();
|
//ASM写入小车动作，1：上料复称；2：上砝码教称；3：取复称NG托盘，4：取砝码到包装机
|
int[] num = new int[3] { 3, 0, 1 };
|
var writeRes0 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
host = ip,
|
addr = plc.writeAddr,
|
data = num,//原先是1,单个写入
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 2}里面数据为{JsonConvert.SerializeObject(num)}.");
|
//Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr + 2}里面数据为1.");
|
///小车和复称位对接
|
//小车请求进料，并且查询设备是否允许AGV进入
|
var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
host = plc.ip,
|
addr = plc.readAddr + 2,
|
port = plc.port
|
});
|
CMMLog.Debug($"读取设备{plc.location}通道{plc.readAddr + 2}里面数据为{readRes.result[0]}.");
|
//Console.WriteLine($"读取设备{plc.location}通道{plc.readAddr + 2}里面数据为{readRes.result[0]}.");
|
if (readRes != null && readRes.errCode == 0)
|
{
|
if (readRes.result[0] == 2)
|
{
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = ip,
|
addr = plc.writeAddr + 2,
|
data = 2,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 2}里面数据为2.");
|
//Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr + 2}里面数据为2.");
|
|
WorkFlowAction.TrackLog(taskNo, 10, 1013, "success");
|
TSHelper.GoToAGV(taskNo, 10, 3);
|
}
|
}
|
}
|
|
internal static void PackingLineComplete(string ip)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.ip == ip).FirstOrDefault();
|
if (plc != null)
|
{
|
//写入包装机--安全门关门指令
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = ip,
|
addr = plc.writeAddr + 2,
|
data = 3,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 2}里面数据为3.");
|
}
|
else CMMLog.Debug($"包装线空托上线，3，ip=null!");
|
}
|
|
internal static void PickUpBlankTwo(Settings.PlcInfo pmInfo)
|
{
|
//四钴车间 从地堆缓存位获取空托
|
if (ProcessHelper.PickUpEndFree(pmInfo.location))
|
{
|
CMMLog.Info($"包装机补空托流程：查询包装机：{pmInfo.location}");
|
//读取输入寄存器还是输出寄存器待定,读取通道0的数据
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = pmInfo.readAddr,
|
host = pmInfo.ip,
|
port = pmInfo.port
|
});
|
|
CMMLog.Info($"包装机补空托流程：判断包装机通道{pmInfo.readAddr}值为{JsonConvert.SerializeObject(result)},ip:{pmInfo.ip}");
|
if (result != null && result.errCode == 0)
|
{
|
//3：人工叫空托盘(川字) 4:人工叫空托盘(田字)
|
if (result.result[0] == 3 || result.result[0] == 4)
|
{
|
//包装线补空流程
|
//判断空托缓存点（5 对 2）是否有空托，有空托判断是否有任务，有任务则判断另一个点位
|
|
var locInfo = Settings.GetAGVLocationList().Where(b => b.machineLoc.Contains(pmInfo.location) && b.Enabel == 1).First();
|
if (locInfo != null)
|
{
|
CMMLog.Info($"包装机点位：{pmInfo.location}");
|
foreach (var a in locInfo.ddLoc)
|
{
|
CMMLog.Info($"周转托盘位：{a}");
|
var ddInfo = Settings.GetDDSiteList().Where(b => b.ddLoc == a && b.Enable == 1).FirstOrDefault();
|
if(ddInfo != null)
|
{
|
if(ddInfo.trayType == result.result[0] - 2)
|
{
|
if (ProcessHelper.PickUpEndFree(pmInfo.location) && ProcessHelper.PickUpStartFree(a))
|
{
|
var empInfo = MongoDBSingleton.Instance.FindOne<BZEmptyPoint>(Query.EQ("Bit", a), "BZEmptyPoint");
|
if (empInfo != null && empInfo.Quantity > 0)
|
{
|
CMMLog.Info($"包装线补空任务，包装机点位：{pmInfo.location}，周转托盘位：{a}，周转托盘位数量：{empInfo.Quantity}");
|
HHAmsExecuteResult amsResult = AMSHelper.CreateTask(DateTime.Now.Ticks.ToString(), a, pmInfo.location, "包装线补空", 0, "");
|
if (amsResult.success)
|
{
|
CMMLog.Info($"包装线补空任务生成成功");
|
break;
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
else
|
{
|
CMMLog.Info("配置文件未配置包装机空托缓存点");
|
}
|
}
|
//流程未对接好，是否这样使用 待定
|
//if (result.result[0] == 4)
|
//{
|
// //调用wms出库接口
|
// var tasks = MongoDBSingleton.Instance.Find<TN_I_TASK_MST>(Query.EQ("CN_S_END_BIT", pmInfo.location), "TN_I_TASK_MST");
|
// //判断一下当前叠托点是否有任务占用
|
// if (ProcessHelper.CheckEndFree(pmInfo.location) && tasks.Count == 0)
|
// {
|
// //可以生成任务，调WMS接口获取任务信息
|
// bool req = WMSHelper.WMSOut(pmInfo.location, "");
|
// if (req) CMMLog.Debug($"调用WMS获取辅材出库生成任务成功！");//现在任务由WMS自己下发，AMS做拦截处理（查询ext1里面对应的任务类型，并更改任务类型）
|
// else CMMLog.Debug($"调用WMS获取辅材出库生成任务失败！");
|
// }
|
// else CMMLog.Debug($"检查当前叠托点是否有任务占用，或者MST主表中有缓存架入叠盘机的任务！");
|
//}
|
}
|
else
|
{
|
CMMLog.Info($"err 包装机通道{pmInfo.readAddr} ip:{pmInfo.ip}");
|
}
|
}
|
}
|
|
internal static void productOutWare(string endBit, string taskNo, bool action)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.location == endBit).FirstOrDefault();
|
if (plc != null)
|
{
|
if (action)
|
{
|
int[] num = new int[3] {1,1,1};
|
var writeRes = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
host = plc.ip,
|
addr = plc.writeAddr,
|
data = num,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr}里面数据为{JsonConvert.SerializeObject(num)}.");
|
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 3,
|
addr = plc.readAddr,
|
host = plc.ip,
|
port = plc.port
|
});
|
CMMLog.Debug($"查询设备{plc.location}通道{plc.readAddr}里面数据为{result.result[0]}、{result.result[1]}、{result.result[2]}.");
|
if (result != null && result.errCode == 0)
|
{
|
if (result.result[0] == 1 && result.result[1] == 1 && result.result[2] == 2)
|
{
|
//推送小车进入
|
TSHelper.GoToAGV(taskNo, 10, 3);
|
writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
addr = plc.writeAddr + 2,
|
data = 2,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 2}里面数据为2.");
|
}
|
}
|
}
|
else
|
{
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
addr = plc.writeAddr + 2,
|
data = 3,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 2}里面数据为3.");
|
}
|
}
|
}
|
|
internal static void productInWare(string startBit, string taskNo, bool action)
|
{
|
var plc = Settings.GetPlcInfo().Where(a => a.location == startBit).FirstOrDefault();
|
if (plc != null)
|
{
|
if (action)
|
{
|
var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 1,
|
addr = plc.readAddr + 3,
|
host = plc.ip,
|
port = plc.port
|
});
|
CMMLog.Debug($"查询设备{plc.location}通道{plc.readAddr + 3}里面数据为{result.result[0]}.");
|
if (result.result[0] == 1)
|
{
|
int[] num = new int[4] { 2, 0, 0, 1 };
|
var writeRes = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti
|
{
|
host = plc.ip,
|
addr = plc.writeAddr,
|
data = num,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr}里面数据为{JsonConvert.SerializeObject(num)}.");
|
}
|
|
result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel
|
{
|
dataNum = 4,
|
addr = plc.readAddr,
|
host = plc.ip,
|
port = plc.port
|
});
|
CMMLog.Debug($"查询设备{plc.location}通道{plc.readAddr}里面数据为{result.result[0]}、{result.result[1]}、{result.result[3]}.");
|
if (result != null && result.errCode == 0)
|
{
|
if (result.result[0] == 2 && result.result[1] == 2 && result.result[3] == 2)
|
{
|
//推送小车进入
|
TSHelper.GoToAGV(taskNo, 10, 3);
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
addr = plc.writeAddr + 3,
|
data = 2,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 3}里面数据为2.");
|
}
|
}
|
}
|
else
|
{
|
var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
host = plc.ip,
|
addr = plc.writeAddr + 3,
|
data = 3,
|
port = plc.port
|
});
|
CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 3}里面数据为3.");
|
}
|
}
|
}
|
|
internal static void SendHeartBeat()
|
{
|
var taskInfo = MongoDBSingleton.Instance.Find<TN_I_TASK_MST>(Query.Or(Query.EQ("CN_S_BUSS_TYPE", "电梯取货"), Query.EQ("CN_S_BUSS_TYPE", "电梯卸货")), "TN_I_TASK_MST");
|
if (taskInfo.Count > 0)
|
{
|
foreach (var item in taskInfo)
|
{
|
if (item.CN_S_BUSS_TYPE == "电梯卸货" || (item.CN_S_BUSS_TYPE == "电梯取货" && !WorkFlowAction.ExistsTrackLogs(item.CN_S_TASK_NO, 1, 4)))
|
{
|
//发送心跳信号
|
string DTBit = item.CN_S_BUSS_TYPE == "电梯卸货" ? item.CN_S_END_BIT : item.CN_S_START_BIT;
|
var plcInfo = Settings.GetPlcInfo().Where(a => a.Extend == DTBit).FirstOrDefault();
|
if(plcInfo != null)
|
{
|
var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel
|
{
|
addr = plcInfo.writeAddr + 12,
|
data = 1,
|
host = plcInfo.ip,
|
port = plcInfo.port
|
});
|
}
|
else
|
{
|
CMMLog.Info($"{DTBit}电梯未配置");
|
}
|
}
|
}
|
}
|
Thread.Sleep(100000);
|
}
|
#endregion
|
}
|
}
|
