using BLL.DAL;
|
using Commom.DotNetDevices;
|
using Model.WcsModel;
|
using NLog;
|
using System;
|
using System.Data;
|
using System.IO;
|
using System.Threading;
|
using Common;
|
using wms.Controllers;
|
using Model.MessageModel;
|
using System.Threading.Tasks;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Serialization;
|
|
namespace wms.Task
|
{
|
//Parallel.For
|
public static class TaskAction
|
{
|
// JC09WCS
|
private static bool IsRunTast = true; // 测试方法控制
|
private static bool IsRunConveyor = true; // 托盘运输线方法控制
|
private static bool IsRunBoxConveyor = true; // 件箱运输线方法控制
|
private static bool IsRunStacker = true; // 跺机方法控制
|
private static bool IsRunStackerAddre = true; // 跺机地址方法控制
|
private static DataTable PlcInfoDt; // 获取所有设备
|
private static DataTable PlcIpDt; // 获取所有IP地址
|
|
private static string plcConveyVal = ""; // 托盘输送线连接状态
|
private static PlcIO plcConvey; // 托盘输送线IP地址
|
|
private static string plcBoxConveyVal = ""; // 件箱输送线连接状态
|
private static PlcIO plcBoxConvey; // 件箱输送线IP地址
|
|
#region 垛机地址与链接状态
|
private static string plcStackVal1 = ""; // 跺机1连接状态
|
private static PlcIO plcStack1; // 跺机1IP地址
|
|
private static string plcStackVal2 = ""; // 跺机2连接状态
|
private static PlcIO plcStack2; // 跺机2IP地址
|
|
private static string plcStackVal3 = ""; // 跺机1连接状态
|
private static PlcIO plcStack3; // 跺机1IP地址
|
|
private static string plcStackVal4 = ""; // 跺机2连接状态
|
private static PlcIO plcStack4; // 跺机2IP地址
|
|
private static string plcStackVal5 = ""; // 跺机1连接状态
|
private static PlcIO plcStack5; // 跺机1IP地址
|
|
private static string plcStackVal6 = ""; // 跺机2连接状态
|
private static PlcIO plcStack6; // 跺机2IP地址
|
|
private static string plcStackVal7 = ""; // 跺机1连接状态
|
private static PlcIO plcStack7; // 跺机1IP地址
|
|
#endregion
|
|
public static bool fuwu = false; // 服务开启关闭
|
public static bool refresh = false; // 自刷新开启关闭
|
public static bool tuoji = false; // 脱机开启关闭
|
public static bool Demo = false; //演示模式开启关闭
|
|
/// <summary>
|
/// 服务初始化
|
/// </summary>
|
[Obsolete]
|
static TaskAction()
|
{
|
// WCS标准版本代码 执行一次
|
DALWcsMessage wcsSql = new DALWcsMessage();
|
PlcIpDt = wcsSql.GetPlcIps();
|
PlcInfoDt = wcsSql.GetPlcInfos();
|
|
// 开启服务
|
fuwu = true;
|
//自刷新
|
refresh = true;
|
|
// 打开设备连接（输送线 跺机 码垛...）
|
plcConvey = new PlcIO("192.168.21.2", 1, ref plcConveyVal);
|
plcStack1 = new PlcIO("192.168.21.30", 1, ref plcStackVal1);
|
plcStack2 = new PlcIO("192.168.21.40", 1, ref plcStackVal2);
|
}
|
|
|
|
/// <summary>
|
/// PLC读写测试
|
/// </summary>
|
/// <param name="source"></param>
|
/// <param name="e"></param>
|
public static async void TestPlc(object source, System.Timers.ElapsedEventArgs e)
|
{
|
try
|
{
|
if (IsRunTast)
|
{
|
IsRunTast = false;
|
//WebStocket发送消息
|
WSChatController wSChat = new WSChatController();
|
|
//通知设备--任务
|
//一号巷道
|
DeviceMessage message = new DeviceMessage();
|
message.Message = "任务更新";
|
message.Status = "1";
|
message.RoadwayNo = "R01";
|
message.StartLocat = 10;
|
message.EndLocat = 15;
|
var a = JsonConvert.SerializeObject(message);
|
wSChat.AlarmInformation(a);
|
|
//二号巷道 没问题
|
message.Message = "任务更新";
|
message.Status = "1";
|
message.RoadwayNo = "R02";
|
message.StartLocat = 53;
|
message.EndLocat = 15;
|
var b = JsonConvert.SerializeObject(message);
|
wSChat.AlarmInformation(b);
|
|
//三号巷道
|
message.Message = "任务更新";
|
message.Status = "1";
|
message.RoadwayNo = "R03";
|
message.StartLocat = 14;
|
message.EndLocat = 53;
|
var c = JsonConvert.SerializeObject(message);
|
wSChat.AlarmInformation(c);
|
|
//四号巷道
|
message.Message = "任务更新";
|
message.Status = "1";
|
message.RoadwayNo = "R04";
|
message.StartLocat = 15;
|
message.EndLocat = 10;
|
var d = JsonConvert.SerializeObject(message);
|
wSChat.AlarmInformation(d);
|
|
//一号巷道
|
message.Message = "垛机实时";
|
message.RoadwayNo = "R01";
|
message.Position = 15;
|
var f = JsonConvert.SerializeObject(message);
|
wSChat.AlarmInformation(f);
|
|
message.Message = "垛机实时";
|
message.RoadwayNo = "R01";
|
message.Position = 33;
|
f = JsonConvert.SerializeObject(message);
|
wSChat.AlarmInformation(f);
|
|
message.Message = "垛机实时";
|
message.RoadwayNo = "R01";
|
message.Position = 36;
|
f = JsonConvert.SerializeObject(message);
|
wSChat.AlarmInformation(f);
|
|
message.Message = "垛机实时";
|
message.RoadwayNo = "R01";
|
message.Position = 45;
|
f = JsonConvert.SerializeObject(message);
|
wSChat.AlarmInformation(f);
|
|
message.Message = "垛机实时";
|
message.RoadwayNo = "R01";
|
message.Position = 48;
|
f = JsonConvert.SerializeObject(message);
|
wSChat.AlarmInformation(f);
|
|
//wSChat.AlarmInformation(d);
|
//var s = fuwu;
|
//WSChatController wSChat = new WSChatController();
|
//wSChat.AlarmInformation(s.ToString());
|
//DALWcsMessage wcsMySql = new DALWcsMessage();
|
//string EndLocat = string.Empty;
|
|
// LED显示屏连接测试
|
//LedDll Led = new LedDll();
|
//Led.LEDstr("192.168.21.150", "最上方", "中间多文本区域!", "最下方区域 ");
|
//Led.LEDstr("192.168.21.150", "测试LED");
|
//TaskReques taskReques = new TaskReques();
|
//taskReques.taskNo = "TK2023092000001";
|
//taskReques.TaskType = "0";
|
//taskReques.TaskStatus = "2";
|
//bool bl = wcsMySql.RequestTasks(taskReques);
|
|
|
|
//string strMsg = wcsMySql.GetLocations("T2300021", "1", ref EndLocat);
|
//WSChatController wSChat = new WSChatController();
|
// wSChat.AlarmInformation("连接设备失败:");
|
|
|
//Logger logger = LogManager.GetCurrentClassLogger();
|
//logger.Error("在运行" + "执行该方法:", "iis自动回收机制");
|
|
//string plcStatus = "";
|
//PlcIO plc = new PlcIO("192.168.21.2", 1, ref plcStatus);
|
//if (plcStatus.Length > 0)
|
//{
|
// // 连接失败
|
//}
|
//bool bl = plc.SetPlcDBValue(107, "String", "CS2024010100002", "40.0");
|
//bool bl1 = plc.SetPlcDBValue(107, "String", "T2300063", "60.0");
|
|
|
//连接测试
|
//string plcStatus = "";
|
//PlcIO plc = new PlcIO("192.168.21.2", 1, ref plcStatus);
|
//if (plcStatus.Length > 0)
|
//{
|
// // 连接失败
|
//}
|
//plc = new PlcIO("192.168.21.30", 1, ref plcStatus);
|
//if (plcStatus.Length > 0)
|
//{
|
// // 连接失败
|
//}
|
//PlcIO plc2 = new PlcIO("192.168.21.40", 1, ref plcStatus);
|
//if (plcStatus.Length > 0)
|
//{
|
// // 连接失败
|
//}
|
//string plcValue = "";
|
//plcValue = plc.GetPlcDBValue(107, "Int", "84.0");
|
//if (plcValue!= "30")
|
//{
|
// var vl = plc.SetPlcDBValue(107, "Int", "30","84.0");
|
//}
|
//plcValue = plc.GetPlcDBValue(107, "String", "0.0");
|
//plcValue = plc.GetPlcDBValue(107, "String", "20.0");
|
//plcValue = plc.GetPlcDBValue(107, "String", "40.0");
|
//plcValue = plc.GetPlcDBValue(107, "String", "60.0");
|
//plcValue = plc.GetPlcDBValue(107, "Int", "80.0");
|
//plcValue = plc.GetPlcDBValue(107, "Int", "82.0");
|
//plcValue = plc.GetPlcDBValue(107, "Int", "84.0");
|
//plcValue = plc.GetPlcDBValue(107, "Int", "86.0");
|
|
//plcStatus = "";
|
//PlcIO plc2 = new PlcIO("192.168.21.30", 1, ref plcStatus);
|
//if (plcStatus.Length > 0)
|
//{
|
// // 连接失败
|
//}
|
//plcValue = plc2.GetPlcDBValue(100, "String", "0.0");
|
//plcValue = plc2.GetPlcDBValue(100, "String", "20.0");
|
//plcValue = plc2.GetPlcDBValue(100, "Int", "40.0");
|
//plcValue = plc2.GetPlcDBValue(100, "String", "42.0");
|
//plcValue = plc2.GetPlcDBValue(100, "String", "62.0");
|
//plcValue = plc2.GetPlcDBValue(100, "Int", "82.0");
|
//plcValue = plc2.GetPlcDBValue(100, "Int", "84.0");
|
//plcValue = plc2.GetPlcDBValue(100, "Int", "86.0");
|
//plcValue = plc2.GetPlcDBValue(100, "Int", "88.0");
|
//plcValue = plc2.GetPlcDBValue(100, "Int", "90.0");
|
//plcValue = plc2.GetPlcDBValue(100, "Int", "92.0");
|
//plcValue = plc2.GetPlcDBValue(100, "Int", "94.0");
|
|
//led灯相应位置显示
|
// 提示LED选择执行批次
|
// LedDisplay(row["LedIP"].ToString(), "38工位", "入库前，请操作执行批次信息!", "停止入库\t");
|
//LedDisplay("192.168.8.55", "38工位 C1口", "空闲中D", "整托空桶/重桶入库分拣交互工位38"); //D口
|
//LedDisplay("192.168.8.51", "28工位 C口", "空闲中C1", "人工处理/整托袋子入库交互工位28"); //C1口
|
//LedDisplay("192.168.8.52", "24工位 B口", "空闲中C", "托袋子入库交互工位24"); //C口
|
//LedDisplay("192.168.8.54", "18工位 A口", "空闲中B", "吨袋入库B口 交互工位18"); //B口
|
//LedDisplay("192.168.8.53", "13工位 D口", "空闲中A", "桶类出入库A口 交互工位13"); //A口
|
|
//LedDisplay("192.168.8.51", "28工位 C1口", "空闲中", "人工处理/整托袋子入库交互工位28"); //C1口
|
//LedDisplay("192.168.8.52", "24工位 C口", "空闲中", "托袋子入库交互工位24"); //C口
|
//LedDisplay("192.168.8.54", "18工位 B口", "空闲中", "吨袋入库B口 交互工位18"); //B口
|
//LedDisplay("192.168.8.53", "13工位 A口", "空闲中", "桶类出入库A口 交互工位13"); //A口
|
//LedDisplay("192.168.8.55", "38工位 D口", "空闲中", "整托空桶/重桶入库分拣交互工位38"); //D口
|
//return;
|
|
//// 手动设置各工位状态
|
//plc.SetPlcDBValue(1101, "Int", "100", "420.0"); // PLC控制流程字
|
//var aa = plc.SetPlcDBValue(1101, "String", "T2300001", "400.0"); // 托盘号
|
//plc.SetPlcDBValue(1101, "Int", "70", "424.0"); // 任务类型 70满桶子母托入 80满桶母托入
|
//plc.SetPlcDBValue(1101, "Int", "60", "426.0"); // 物料类型 60：满桶字母托盘 70：满桶母托盘
|
//plc.SetPlcDBValue(1101, "Byte", "1", "428.0"); // 目标工位号
|
//plc.SetPlcDBValue(1101, "Byte", "1", "429.0"); // 字母托盘状态 0无 1有
|
//plc.SetPlcDBValue(1101, "Byte", "1", "430.0"); // 物料数量
|
//plc.SetPlcDBValue(1101, "Real", "200", "432.0"); // 物料重量
|
//plc.SetPlcDBValue(1101, "Byte", "0", "431.0"); // 拆跺数量
|
|
// 读取
|
//string plcValue = "";
|
//plcValue = plc.GetPlcDBValue(101, "String", "20.0");
|
|
|
//bool inBl = plc.SetPlcDBValue(101, "String", "T2300001", "20.0");
|
//plcValue = plc.GetPlcDBValue(101, "String", "20.0");
|
|
//plcValue = plc.GetPlcDBValue(101, "Int", "82.0");
|
|
////bool inBl = plc.SetPlcDBValue(101, "Int", "1", "82.0");
|
////plc.SetPlcDBValue(1101, "String", "T2300001", "10.0");
|
//plcValue = "";
|
//plcValue = plc.GetPlcDBValue(1101, "Int", "20.0");
|
////plc.SetPlcDBValue(1101, "Int", "99", "22.0");
|
//plcValue = plc.GetPlcDBValue(1101, "Int", "424.0");
|
////plc.SetPlcDBValue(1101, "Int", "99", "24.0");
|
//plcValue = plc.GetPlcDBValue(1101, "Int", "426.0");
|
////plc.SetPlcDBValue(1101, "Int", "99", "26.0");
|
//plcValue = plc.GetPlcDBValue(1101, "Byte", "428.0");
|
////plc.SetPlcDBValue(1101, "Byte", "99", "28.0");
|
//plcValue = plc.GetPlcDBValue(1101, "Byte", "429.0");
|
////plc.SetPlcDBValue(1101, "Byte", "99", "29.0");
|
//plcValue = plc.GetPlcDBValue(1101, "Byte", "430.0");
|
////plc.SetPlcDBValue(1101, "Byte", "99", "30.0");
|
//plcValue = plc.GetPlcDBValue(1101, "Byte", "431.0");
|
////plc.SetPlcDBValue(1101, "Byte", "99", "31.0");
|
//plcValue = plc.GetPlcDBValue(1101, "Real", "432.0");
|
////plc.SetPlcDBValue(1101, "Real", "99", "32.0");
|
|
|
|
|
|
// 接口测试
|
//WCSPalletBind model = new WCSPalletBind();
|
//model.PalletNo = "T2300001";
|
//model.TaskType = "001";
|
//model.SubPallet = "0";
|
//model.SkuQty = 10;
|
//model.SkuWeight = "235";
|
|
//model.SkuType = "001";
|
//model.LotNo = "2305190";
|
//model.SupplierLot = "";
|
//DALWcsMessage wcsMySql = new DALWcsMessage();
|
//string endLocat = ""; // 取货工位号
|
//string strMsg = wcsMySql.GetLocation("T2300001", model, ref endLocat);
|
|
//plc.ClosePlc();
|
IsRunTast = true;
|
}
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
finally
|
{
|
//IsRunTast = true;
|
}
|
}
|
|
/// <summary>
|
/// 堆垛机
|
/// </summary>
|
//[Obsolete]
|
public static void Stackers(object source, System.Timers.ElapsedEventArgs e)
|
{
|
try
|
{
|
if (IsRunStacker)
|
{
|
IsRunStacker = false;
|
// 判断wcs服务是否开启
|
if (!fuwu)
|
{
|
IsRunStacker = true;
|
return;
|
}
|
|
// 判断运行的服务器
|
bool sqlBool = false;
|
DALWcsMessage wcsSql = new DALWcsMessage();
|
try
|
{
|
sqlBool = wcsSql.GetIsWcsAutoDB1(); // 抛出异常，证明DB2在运行
|
}
|
catch
|
{
|
IsRunStacker = true;
|
return;
|
};
|
|
PlcInteraction plcInteraction = new PlcInteraction();
|
while (fuwu && sqlBool)
|
{
|
if (plcStackVal1.Length > 0 || plcStackVal2.Length > 0)
|
{
|
if (plcStackVal1.Length > 0)
|
{
|
// 重新连接plc
|
plcStack1 = new PlcIO("192.168.21.30", 1, ref plcStackVal1);
|
}
|
|
if (plcStackVal2.Length > 0)
|
{
|
// 重新连接plc
|
plcStack2 = new PlcIO("192.168.21.40", 1, ref plcStackVal2);
|
}
|
}
|
else
|
{
|
// 自动模式
|
DataRow[] ipRows = PlcIpDt.Select(" Type = '0' ");
|
foreach (DataRow ipRow in ipRows)
|
{
|
if (ipRow["IP"].ToString() == "192.168.21.30")
|
{
|
plcInteraction.StackersInteraction2(ipRow, PlcInfoDt, plcStack1, plcConvey);
|
}
|
else if (ipRow["IP"].ToString() == "192.168.21.40")
|
{
|
plcInteraction.StackersInteraction2(ipRow, PlcInfoDt, plcStack2, plcConvey);
|
}
|
|
|
}
|
|
}
|
}
|
|
IsRunStacker = true;
|
}
|
}
|
catch (Exception ex)
|
{
|
IsRunStacker = true;
|
throw ex;
|
}
|
}
|
|
/// <summary>
|
/// 托盘运输线
|
/// </summary>
|
public static void Conveyors(object source, System.Timers.ElapsedEventArgs e)
|
{
|
try
|
{
|
if (IsRunConveyor)
|
{
|
IsRunConveyor = false;
|
|
// 判断wcs服务是否开启
|
if (!fuwu)
|
{
|
IsRunConveyor = true;
|
return;
|
}
|
|
// 判断运行的服务器
|
bool sqlBool = false;
|
DALWcsMessage wcsSql = new DALWcsMessage();
|
try
|
{
|
// 抛出异常，证明DB2在运行
|
sqlBool = wcsSql.GetIsWcsAutoDB1();
|
}
|
catch
|
{
|
IsRunConveyor = true;
|
return;
|
};
|
|
Logger logger = LogManager.GetCurrentClassLogger();
|
logger.Error("ASDF", "定时监控:");
|
|
PlcInteraction plcInteraction = new PlcInteraction();
|
while (fuwu && sqlBool)
|
{
|
Thread.Sleep(100);
|
|
if (plcConveyVal.Length > 0 || plcStackVal1.Length > 0 || plcStackVal2.Length > 0)
|
{
|
plcConvey.ClosePlc();
|
plcStack1.ClosePlc();
|
plcStack2.ClosePlc();
|
plcConveyVal = "";
|
plcStackVal1 = "";
|
plcStackVal2 = "";
|
// 重新连接plc
|
plcConvey = new PlcIO("192.168.21.2", 1, ref plcConveyVal);
|
plcStack1 = new PlcIO("192.168.21.30", 1, ref plcStackVal1);
|
plcStack2 = new PlcIO("192.168.21.40", 1, ref plcStackVal2);
|
logger.Error($"重新连接：输送线:{plcConveyVal}，跺机1:{plcStackVal1}，跺机2:{plcStackVal2}", "输送线错误重新连接关闭");
|
}
|
else
|
{
|
try
|
{
|
// 输送线
|
DataRow[] ipRows = PlcIpDt.Select(" Type = '1' ");
|
foreach (DataRow ipRow in ipRows)
|
{
|
plcInteraction.ConveyorsInteraction2(ipRow, PlcInfoDt, plcConvey, plcStack1, plcStack2);
|
}
|
|
// 堆垛机
|
DataRow[] ipRowsDJ = PlcIpDt.Select(" Type = '0' ");
|
foreach (DataRow ipRowDj in ipRowsDJ)
|
{
|
if (ipRowDj["IP"].ToString() == "192.168.21.30")
|
{
|
plcInteraction.StackersInteraction2(ipRowDj, PlcInfoDt, plcStack1, plcConvey);
|
}
|
else if (ipRowDj["IP"].ToString() == "192.168.21.40")
|
{
|
plcInteraction.StackersInteraction2(ipRowDj, PlcInfoDt, plcStack2, plcConvey);
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
plcConvey.ClosePlc();
|
plcStack1.ClosePlc();
|
plcStack2.ClosePlc();
|
|
plcConveyVal = "OFF";
|
plcStackVal1 = "OFF";
|
plcStackVal2 = "OFF";
|
|
logger.Error("异常重连：" + ex.Message, "输送线错误重新连接关闭");
|
}
|
}
|
}
|
|
IsRunConveyor = true;
|
}
|
}
|
catch (Exception ex)
|
{
|
IsRunConveyor = true;
|
throw ex;
|
}
|
}
|
|
/// <summary>
|
/// 件箱运输线
|
/// </summary>
|
public static void BoxConveyors(object source, System.Timers.ElapsedEventArgs e)
|
{
|
try
|
{
|
if (IsRunBoxConveyor)
|
{
|
IsRunBoxConveyor = false;
|
|
// 判断wcs服务是否开启
|
if (!fuwu)
|
{
|
IsRunBoxConveyor = true;
|
return;
|
}
|
|
// 判断运行的服务器
|
bool sqlBool = false;
|
DALWcsMessage wcsSql = new DALWcsMessage();
|
try
|
{
|
// 抛出异常，证明DB2在运行
|
sqlBool = wcsSql.GetIsWcsAutoDB1();
|
}
|
catch
|
{
|
IsRunBoxConveyor = true;
|
return;
|
};
|
|
Logger logger = LogManager.GetCurrentClassLogger();
|
logger.Error("件箱输送线定时运行", "定时监控:");
|
|
PlcInteraction plcInteraction = new PlcInteraction();
|
while (fuwu && sqlBool)
|
{
|
Thread.Sleep(100);
|
|
if (plcBoxConveyVal.Length > 0)
|
{
|
plcBoxConvey.ClosePlc();
|
plcBoxConveyVal = "";
|
// 重新连接plc
|
plcBoxConvey = new PlcIO("192.168.21.2", 1, ref plcConveyVal);
|
logger.Error($"重新连接：件箱输送线:{plcBoxConveyVal}", "件箱输送线错误重新连接关闭");
|
}
|
else
|
{
|
try
|
{
|
// 件箱输送线
|
DataRow[] ipRows = PlcIpDt.Select(" Type = '2' ");
|
foreach (DataRow ipRow in ipRows)
|
{
|
plcInteraction.BoxConveyorsInteraction2(ipRow, PlcInfoDt, plcConvey);
|
}
|
}
|
catch (Exception ex)
|
{
|
plcBoxConvey.ClosePlc();
|
|
plcBoxConveyVal = "OFF";
|
|
logger.Error("异常重连：" + ex.Message, "件箱输送线错误重新连接关闭");
|
}
|
}
|
}
|
|
IsRunBoxConveyor = true;
|
}
|
}
|
catch (Exception ex)
|
{
|
IsRunBoxConveyor = true;
|
throw ex;
|
}
|
}
|
|
/// <summary>
|
/// 跺机地址监控
|
/// </summary>
|
/// <param name="source"></param>
|
/// <param name="e"></param>
|
public static void StackerAddre(object source, System.Timers.ElapsedEventArgs e)
|
{
|
try
|
{
|
if (IsRunStackerAddre)
|
{
|
IsRunStackerAddre = false;
|
// 判断wcs服务是否开启
|
if (!fuwu)
|
{
|
IsRunStacker = true;
|
return;
|
}
|
|
// 判断运行的服务器
|
bool sqlBool = false;
|
DALWcsMessage wcsSql = new DALWcsMessage();
|
try
|
{
|
sqlBool = wcsSql.GetIsWcsAutoDB1(); // 抛出异常，证明DB2在运行
|
}
|
catch
|
{
|
IsRunStackerAddre = true;
|
return;
|
};
|
|
PlcInteraction plcInteraction = new PlcInteraction();
|
while (fuwu && sqlBool)
|
{
|
if (plcStackVal1.Length > 0 || plcStackVal2.Length > 0)
|
{
|
if (plcStackVal1.Length > 0)
|
{
|
// 重新连接plc
|
plcStack1 = new PlcIO("192.168.21.30", 1, ref plcStackVal1);
|
}
|
|
if (plcStackVal2.Length > 0)
|
{
|
// 重新连接plc
|
plcStack2 = new PlcIO("192.168.21.40", 1, ref plcStackVal2);
|
}
|
|
if (plcStackVal3.Length > 0)
|
{
|
// 重新连接plc
|
plcStack3 = new PlcIO("192.168.21.50", 1, ref plcStackVal3);
|
}
|
|
if (plcStackVal4.Length > 0)
|
{
|
// 重新连接plc
|
plcStack4 = new PlcIO("192.168.21.60", 1, ref plcStackVal4);
|
}
|
|
if (plcStackVal5.Length > 0)
|
{
|
// 重新连接plc
|
plcStack5 = new PlcIO("192.168.21.70", 1, ref plcStackVal5);
|
}
|
|
if (plcStackVal6.Length > 0)
|
{
|
// 重新连接plc
|
plcStack6 = new PlcIO("192.168.21.80", 1, ref plcStackVal6);
|
}
|
|
if (plcStackVal7.Length > 0)
|
{
|
// 重新连接plc
|
plcStack7 = new PlcIO("192.168.21.90", 1, ref plcStackVal7);
|
}
|
}
|
else
|
{
|
// 自动模式
|
DataRow[] ipRows = PlcIpDt.Select(" Type = '0' ");
|
foreach (DataRow ipRow in ipRows)
|
{
|
if (ipRow["IP"].ToString() == "192.168.21.30")
|
{
|
plcInteraction.StackersAddreInteraction(ipRow, PlcInfoDt, plcStack1, plcConvey);
|
}
|
else if (ipRow["IP"].ToString() == "192.168.21.40")
|
{
|
plcInteraction.StackersAddreInteraction(ipRow, PlcInfoDt, plcStack2, plcConvey);
|
}
|
else if (ipRow["IP"].ToString() == "192.168.21.50")
|
{
|
plcInteraction.StackersAddreInteraction(ipRow, PlcInfoDt, plcStack3, plcConvey);
|
}
|
else if (ipRow["IP"].ToString() == "192.168.21.60")
|
{
|
plcInteraction.StackersAddreInteraction(ipRow, PlcInfoDt, plcStack4, plcConvey);
|
}
|
else if (ipRow["IP"].ToString() == "192.168.21.70")
|
{
|
plcInteraction.StackersAddreInteraction(ipRow, PlcInfoDt, plcStack5, plcConvey);
|
}
|
else if (ipRow["IP"].ToString() == "192.168.21.80")
|
{
|
plcInteraction.StackersAddreInteraction(ipRow, PlcInfoDt, plcStack6, plcConvey);
|
}
|
else if (ipRow["IP"].ToString() == "192.168.21.90")
|
{
|
plcInteraction.StackersAddreInteraction(ipRow, PlcInfoDt, plcStack7, plcConvey);
|
}
|
|
|
|
}
|
|
}
|
}
|
|
IsRunStackerAddre = true;
|
}
|
}
|
catch (Exception ex)
|
{
|
IsRunStackerAddre = true;
|
throw ex;
|
}
|
}
|
|
/// <summary>
|
/// 清除log日志
|
/// </summary>
|
public static void DeleteNlogFile(object source, System.Timers.ElapsedEventArgs e)
|
{
|
try
|
{
|
// 时 分 秒
|
// 得到 hour minute second 如果等于某个值就开始执行某个程序。
|
int intHour = e.SignalTime.Hour;
|
int intMinute = e.SignalTime.Minute;
|
//int intSecond = e.SignalTime.Second;
|
// 定制时间； 比如 在10：30 ：00 的时候执行某个函数
|
int iHour = 00;
|
int iMinute = 05;
|
//int iSecond = 00;
|
// 设置 在每天晚上的23点50执行
|
//if (intHour == iHour && intMinute == iMinute && intSecond == iSecond)
|
if (intHour == iHour && intMinute == iMinute)
|
{
|
|
int count = 0;
|
string[] files = Directory.GetFiles("E:\\server\\WcsServer\\LogFile");//路径需要更改
|
//string[] files = Directory.GetFiles("D:\\WMS\\JC08Wcs\\WCS-V1.0\\wms\\LogFile");
|
foreach (string file in files)
|
{
|
FileInfo fi = new FileInfo(file);
|
var a = fi.Name.Split('.');
|
a[0].ToDate();
|
if (a[0].ToDate() < DateTime.Now.AddMonths(-1))
|
{
|
count += 1;
|
fi.Delete();
|
}
|
}
|
Logger logger = LogManager.GetCurrentClassLogger();
|
if (count > 0)
|
{
|
logger.Error("清除WCS日志消息：清除成功");
|
//调用WMS清除日志接口
|
var response = Utility.Extra.HttpHelper.DoPost("http://192.168.220.137:8081/api/DownAPi/DeleteNlogFile", null);//路径需要更改
|
if (response != "清除成功")
|
{
|
logger.Error("清除WMS日志消息：清除成功");
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
Logger logger = LogManager.GetCurrentClassLogger();
|
logger.Error("清除日志异常消息：" + ex.Message, "清除日志定时器错误");
|
}
|
|
}
|
|
/// <summary>
|
/// 获取当前工位交互流程字为多少
|
/// </summary>
|
public static string GetPlcOrWcsPos(string Ip, string Stat, string Plcpos)
|
{
|
#region 与PLC交互逻辑
|
//DataRow[] iProws = null;
|
|
//string type = "0";
|
|
////判断是输送线连接还是垛机连接
|
//if (Ip == "192.168.8.40")
|
//{
|
// type = "1";
|
// // 获取运输线交互IP集合
|
// iProws = PlcInfoDt.Select("Level = '0' and Type = '1' ");
|
//}
|
//else
|
//{
|
// // 获取跺机交互IP集合
|
// iProws = PlcInfoDt.Select("Level = '0' and Type = '0' ");
|
//}
|
|
|
//// 连接运输线PlC
|
////string plcIp = ipRow["PlcIP"].ToString();
|
//string plcStatus = ""; // PLC连接状态
|
//PlcIO plc = new PlcIO(Ip, 1, ref plcStatus);
|
//// 循环连接运输线设备
|
//foreach (DataRow ipRow in iProws)
|
//{
|
// // 循环各跺机与PLC进行交互
|
// DataRow[] rows = PlcInfoDt.Select($"Level = '2' and Type = '{type}' and PlcIP='{Ip}' ");
|
// //rows.Select(a=>a.)
|
// rows = PlcInfoDt.Select($"StationNum = '{Stat}' and PlcPos = '{Plcpos}'");
|
// foreach (DataRow row in rows)
|
// {
|
// // 读取工位流程字
|
// string dbNumber = row["DbNumber"].ToString();
|
// string posType = row["PosType"].ToString();
|
// string plcPos = row["PlcPos"].ToString();
|
// string wcsPos = row["WcsPos"].ToString();
|
// string stationNum = row["StationNum"].ToString();
|
// string plcValue = plc.GetPlcDBValue(int.Parse(dbNumber), posType, plcPos);
|
|
// //判断工位号
|
// if (stationNum == Stat)
|
// {
|
// if (plcValue == "0" || plcValue == "10" || plcValue == "20" || plcValue == "21" || plcValue == "22" || plcValue == "100" || plcValue == "110" || plcValue == "120" || plcValue == "130" || plcValue == "140" || plcValue == "200" || plcValue == "210" || plcValue == "300" || plcValue == "310" || plcValue == "320" || plcValue == "330")
|
// {
|
// // 关闭设备连接
|
// plc.ClosePlc();
|
// return plcValue;
|
// }
|
// else
|
// {
|
// continue;
|
// }
|
// }
|
// else
|
// {
|
// continue;
|
// }
|
// }
|
//}
|
|
|
//// 关闭设备连接
|
//plc.ClosePlc();
|
|
return null;
|
#endregion
|
|
}
|
|
/// <summary>
|
///// 获取当前工位偏移量值为多少
|
/// </summary>
|
public static PosNameVal GetPlcOrWcsPosVal(string plcInfoId)
|
{
|
#region 与PLC交互逻辑
|
PosNameVal list = new PosNameVal();
|
DALWcsMessage wcsMySql = new DALWcsMessage();
|
DataTable posDt = wcsMySql.GetPlcPos(plcInfoId); //偏移量
|
|
var plcInfo = PlcInfoDt.Select($"Id={plcInfoId} ")[0];
|
var ipInfo = PlcIpDt.Select($"Id = {plcInfo["PlcIP"].ToString()} ")[0];
|
|
var dbNumber = plcInfo["DbNumber"].ToString();//db块
|
var infoPlcPos = plcInfo["PlcPos"].ToString();//plc流程字值
|
var infoPosType = plcInfo["PosType"].ToString();//流程字类型
|
var infoWcsPos = plcInfo["WcsPos"].ToString();//wcs流程字值
|
|
string plcStatus = ""; // PLC连接状态
|
PlcIO plc = new PlcIO(ipInfo["IP"].ToString(), 1, ref plcStatus);
|
if (plcStatus.Length <= 0)
|
{
|
try
|
{
|
string plcValue1 = plc.GetPlcDBValue(int.Parse(dbNumber), infoPosType, infoPlcPos);
|
list.PlcPos = plcValue1;
|
string plcValue2 = plc.GetPlcDBValue(int.Parse(dbNumber), infoPosType, infoWcsPos);
|
list.WcsPos = plcValue2;
|
|
foreach (var row in posDt.Select())
|
{
|
// 读取工位流程字
|
string posType = row["PosType"].ToString();
|
string plcPos = row["PlcPos"].ToString();
|
string name = row["Name"].ToString();
|
string plcValue = plc.GetPlcDBValue(int.Parse(dbNumber), posType, plcPos);
|
|
#region 赋值
|
if (PosName.PlcTaskNo.ToString() == name)
|
{
|
list.PlcTaskNo = plcValue;
|
}
|
else if (PosName.PlcPalletNo.ToString() == name)
|
{
|
list.PlcPalletNo = plcValue;
|
}
|
else if (PosName.TaskNo.ToString() == name)
|
{
|
list.TaskNo = plcValue;
|
}
|
else if (PosName.PalletNo.ToString() == name)
|
{
|
list.PalletNo = plcValue;
|
}
|
else if (PosName.StartLocatNo.ToString() == name)
|
{
|
list.StartLocatNo = plcValue;
|
}
|
else if (PosName.EndLocatNo.ToString() == name)
|
{
|
list.EndLocatNo = plcValue;
|
}
|
else if (PosName.StartRow.ToString() == name)
|
{
|
list.StartRow = plcValue;
|
}
|
else if (PosName.StartColumn.ToString() == name)
|
{
|
list.StartColumn = plcValue;
|
}
|
else if (PosName.StartLayer.ToString() == name)
|
{
|
list.StartLayer = plcValue;
|
}
|
else if (PosName.EndRow.ToString() == name)
|
{
|
list.EndRow = plcValue;
|
}
|
else if (PosName.EndColumn.ToString() == name)
|
{
|
list.EndColumn = plcValue;
|
}
|
else if (PosName.EndLayer.ToString() == name)
|
{
|
list.EndLayer = plcValue;
|
}
|
|
#endregion
|
}
|
}
|
catch (Exception ex)
|
{
|
plc.ClosePlc();
|
throw ex;
|
}
|
}
|
|
// 关闭设备连接
|
plc.ClosePlc();
|
|
return list;
|
#endregion
|
}
|
|
/// <summary>
|
/// 应用池回收的时候调用的方法
|
/// </summary>
|
public static void SetContent(string type)
|
{
|
Logger logger = LogManager.GetCurrentClassLogger();
|
logger.Error(type + "执行该方法:", "iis自动回收机制");
|
|
}
|
|
}
|
}
|
