|
|
|
@ -22,7 +22,7 @@ namespace Aucma.Core.DataCollector
|
|
|
|
if (app == null) throw new ArgumentNullException(nameof(app));
|
|
|
|
if (app == null) throw new ArgumentNullException(nameof(app));
|
|
|
|
|
|
|
|
|
|
|
|
var stationCode = Appsettings.app("StationInfo", "StationCode");
|
|
|
|
var stationCode = Appsettings.app("StationInfo", "StationCode");
|
|
|
|
Console.WriteLine($"获取当前工位编码：{stationCode}");
|
|
|
|
|
|
|
|
var _deviceParamServices = app.ApplicationServices.GetService<IBaseDeviceParamServices>();
|
|
|
|
var _deviceParamServices = app.ApplicationServices.GetService<IBaseDeviceParamServices>();
|
|
|
|
var _deviceAlarmInfoServices = app.ApplicationServices.GetService<IRecordDeviceAlarmInfoServices>();
|
|
|
|
var _deviceAlarmInfoServices = app.ApplicationServices.GetService<IRecordDeviceAlarmInfoServices>();
|
|
|
|
var _deviceElectricityServices = app.ApplicationServices.GetService< IRecordDeviceElectricityServices>();
|
|
|
|
var _deviceElectricityServices = app.ApplicationServices.GetService< IRecordDeviceElectricityServices>();
|
|
|
|
@ -31,7 +31,7 @@ namespace Aucma.Core.DataCollector
|
|
|
|
{
|
|
|
|
{
|
|
|
|
try
|
|
|
|
try
|
|
|
|
{
|
|
|
|
{
|
|
|
|
if (stationCode == "1002") //箱壳、内胆，包含预装线、集存库
|
|
|
|
if (stationCode == "1002") //暂未使用--箱壳、内胆，包含预装线、集存库
|
|
|
|
{
|
|
|
|
{
|
|
|
|
Task.Run(() =>
|
|
|
|
Task.Run(() =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
@ -47,84 +47,80 @@ namespace Aucma.Core.DataCollector
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else if (stationCode == "1004")//泡前库、发泡线、发泡机、泡后库
|
|
|
|
else if (stationCode == "1005")//泡前库、发泡线、发泡机
|
|
|
|
{
|
|
|
|
{
|
|
|
|
//发泡机
|
|
|
|
|
|
|
|
Task.Run(() =>
|
|
|
|
Task.Run(() =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
DataCollectorFactory collector = new BoxFoamFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
DataCollectorFactory collector = new BoxFoamFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
|
|
|
|
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
//发泡线1
|
|
|
|
}
|
|
|
|
|
|
|
|
else if (stationCode == "1008")//条码绑定工位
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
// 包装线采集
|
|
|
|
Task.Run(() =>
|
|
|
|
Task.Run(() =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
DataCollectorFactory collector = new BoxFoamFixture1Factory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
DataCollectorFactory collector = new PackingCX02Factory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
|
|
|
|
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
//发泡线2
|
|
|
|
|
|
|
|
|
|
|
|
// 箱壳
|
|
|
|
Task.Run(() =>
|
|
|
|
Task.Run(() =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
DataCollectorFactory collector = new BoxFoamFixture2Factory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
DataCollectorFactory collector = new ShellStoreFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
|
|
|
|
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
// 内胆
|
|
|
|
else if (stationCode == "1012")//门体发泡
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
Console.WriteLine("开始执行异常数据采集");
|
|
|
|
|
|
|
|
Task.Run(() =>
|
|
|
|
Task.Run(() =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
DataCollectorFactory collector = new DoorFoamFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
DataCollectorFactory collector = new LinerStoreFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
|
|
|
|
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
//箱壳预装线
|
|
|
|
else if (stationCode == "1010")//成品分垛
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
//Task.Run(() =>
|
|
|
|
|
|
|
|
//{
|
|
|
|
|
|
|
|
// DataCollectorFactory collector = new PalletizFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
|
|
|
|
//});
|
|
|
|
|
|
|
|
Task.Run(() =>
|
|
|
|
Task.Run(() =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
DataCollectorFactory collector = new ShellStoreFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
DataCollectorFactory collector = new ShellPreassembleFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
|
|
|
|
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
// 内胆预装线
|
|
|
|
Task.Run(() =>
|
|
|
|
Task.Run(() =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
DataCollectorFactory collector = new LinerStoreFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
DataCollectorFactory collector = new LinerPreassembleFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
|
|
|
|
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
// 泡后库
|
|
|
|
Task.Run(() =>
|
|
|
|
Task.Run(() =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
DataCollectorFactory collector = new ShellPreassembleFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
DataCollectorFactory collector = new FoamBackFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
|
|
|
|
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
else if (stationCode == "1010")//分垛A库
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
// 二线分垛
|
|
|
|
Task.Run(() =>
|
|
|
|
Task.Run(() =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
DataCollectorFactory collector = new LinerPreassembleFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
DataCollectorFactory collector = new PalletizFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
|
|
|
|
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
// 二线输送平台
|
|
|
|
Task.Run(() =>
|
|
|
|
Task.Run(() =>
|
|
|
|
{
|
|
|
|
{
|
|
|
|
DataCollectorFactory collector = new FoamBackFactory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
DataCollectorFactory collector = new TransPlatformCX02Factory(_deviceParamServices, _deviceAlarmInfoServices, _deviceElectricityServices);
|
|
|
|
|
|
|
|
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
Parallel.Invoke(() => collector.CollectDeviceAlarmInfo(out var alarmInfos), () => collector.CollectDeviceElectricity(out var electricity));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}catch(Exception ex)
|
|
|
|
}
|
|
|
|
|
|
|
|
catch(Exception ex)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
_logger.Error($"UseDataCollectorExtensions逻辑执行异常:{ex.Message}");
|
|
|
|
_logger.Error($"UseDataCollectorExtensions逻辑执行异常:{ex.Message}");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
liulb@mesnac.com
12 months ago