313 lines
13 KiB
C#
313 lines
13 KiB
C#
using Cowain.Bake.BLL;
|
||
using Cowain.Bake.Common;
|
||
using Cowain.Bake.Common.Core;
|
||
using Cowain.Bake.Common.Enums;
|
||
using Cowain.Bake.Common.Interface;
|
||
using Cowain.Bake.Communication.Interface;
|
||
using Cowain.Bake.Communication.MOM;
|
||
using Cowain.Bake.Main.Common;
|
||
using Cowain.Bake.Main.ViewModels;
|
||
using Cowain.Bake.Model;
|
||
using Cowain.Bake.Model.Models;
|
||
using HslCommunication;
|
||
using Newtonsoft.Json;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Text.RegularExpressions;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
using Unity;
|
||
|
||
namespace Cowain.Bake.Main.Station
|
||
{
|
||
public class DataCollectStation : IServerManager
|
||
{
|
||
public string Name { get; set; }
|
||
public IUnityContainer _unityContainer { get; set; }
|
||
readonly List<TDeviceConfig> stoveConfs = null;
|
||
readonly CancellationTokenSource cts = new CancellationTokenSource();
|
||
readonly List<TStoveSctualPatrol> listStoveTemp = new List<TStoveSctualPatrol>();
|
||
|
||
private Dictionary<int, StoveDataModel> cacheStoveData { set; get; } = new Dictionary<int, StoveDataModel>();//如果只有一个保存炉子的真空值，数据容易不及时，且冲突
|
||
//private Dictionary<int, int> cacheElectricEnergyData { set; get; } = new Dictionary<int, int>();
|
||
private readonly Prism.Events.IEventAggregator _eventAggregator;
|
||
public DataCollectStation(IUnityContainer unityContainer, Prism.Events.IEventAggregator eventAggregator)
|
||
{
|
||
_unityContainer = unityContainer;
|
||
_eventAggregator = eventAggregator;
|
||
stoveConfs = _unityContainer.Resolve<DeviceConfigService>().GetConfig(EDeviceType.PLC, EStationType.Stove.ToString());//
|
||
Start();
|
||
}
|
||
|
||
public void Start()
|
||
{
|
||
string tempCycle = _unityContainer.Resolve<Cowain.Bake.BLL.SysSetupService>()
|
||
.GetValueByParaID(Cowain.Bake.Common.Enums.ESysSetup.DataCollectionCycle.ToString());
|
||
int tempCycleValue = int.Parse(tempCycle);
|
||
|
||
Task.Run(async () =>
|
||
{
|
||
await Task.Delay(20 * 1000); //等待去读PLC的数据
|
||
while (!cts.Token.IsCancellationRequested)
|
||
{
|
||
await Task.Delay(tempCycleValue * 1000);
|
||
if (Global.AppExit)
|
||
{
|
||
return;
|
||
}
|
||
|
||
CollectTemp();
|
||
}
|
||
});
|
||
}
|
||
|
||
void CollectTemp()
|
||
{
|
||
bool isWork = false;
|
||
float vacuum = 0;
|
||
UInt16 workTime = 0;
|
||
UInt16 totalWorkTime = 0;
|
||
float[] temps = null;
|
||
OperateResult<Int16[]> resultTemp;
|
||
listStoveTemp.Clear();
|
||
cacheStoveData.Clear();
|
||
foreach (var conf in stoveConfs)
|
||
{
|
||
IPLCDevice plc = _unityContainer.Resolve<IPLCDevice>(conf.Name);
|
||
|
||
if (null == plc || !plc.IsConnect)
|
||
{
|
||
continue;
|
||
}
|
||
|
||
var stoves = (from v in plc.Storages
|
||
group v by v.StationId
|
||
into a
|
||
orderby a.Key
|
||
select a).ToList();
|
||
|
||
//每个炉子都循环
|
||
foreach (var item in stoves) //一个PLC控制二台炉子(一台炉子)
|
||
{
|
||
//0 / 空闲 1 / 待机 2 / 停止 3 / 工作 4 / 保压
|
||
var workStatus = plc.GetValue<Int16>(EStoveSignal.CavityStatus.ToString(), item.Key);
|
||
if (!workStatus.IsSuccess || (int)EStoveWorkMode.Standby >= workStatus.Content) //系统状态寄存器
|
||
{
|
||
isWork = false;
|
||
}
|
||
else
|
||
{
|
||
isWork = true;
|
||
}
|
||
|
||
if (item.Key == Global.DEW_STOVE_NUMBER) //IP:70
|
||
{
|
||
//露点温度
|
||
var dewTemp = plc.GetValue<float>(EStoveSignal.DewTemperature.ToString(), item.Key);
|
||
if (!dewTemp.IsSuccess)
|
||
{
|
||
LogHelper.Instance.Error($"读取露点温度失败！{dewTemp.Message}");
|
||
_unityContainer.Resolve<BasicInfoViewModel>().SetTempData("-0");
|
||
}
|
||
else
|
||
{
|
||
DealDewTemp(dewTemp.Content);
|
||
_unityContainer.Resolve<BasicInfoViewModel>().SetTempData(Math.Round(dewTemp.Content,2).ToString());
|
||
}
|
||
}
|
||
|
||
//真空值
|
||
var result = plc.GetValue<int>(EStoveSignal.Vacuum.ToString(), item.Key);
|
||
if (!result.IsSuccess)
|
||
{
|
||
LogHelper.Instance.Error($"读取真空值失败！{result.Message}");
|
||
continue;
|
||
}
|
||
vacuum = (float)(result.Content);
|
||
|
||
//工作时长
|
||
var workTimeResult = plc.GetValue<UInt16>(EStoveSignal.WorkTime.ToString(), item.Key);
|
||
var totalTimeResult = plc.GetValue<UInt16>(EStoveSignal.TotalWorkTime.ToString(), item.Key);
|
||
if (!workTimeResult.IsSuccess
|
||
|| !totalTimeResult.IsSuccess)
|
||
{
|
||
LogHelper.Instance.Error($"读取工作时长失败！{workTimeResult.Message},{totalTimeResult.Message}");
|
||
continue;
|
||
}
|
||
workTime = workTimeResult.Content;
|
||
totalWorkTime = totalTimeResult.Content;
|
||
|
||
//获取一个炉子的温度节点
|
||
var stoveTempNode = (from storage in plc.Storages
|
||
from itemTemp in storage.VariableList
|
||
where storage.StationId == item.Key
|
||
&& itemTemp.TagType == (int)ETagType.Temperature //&& itemTemp.Number == layer
|
||
select itemTemp).ToList();
|
||
|
||
foreach (var tempParam in stoveTempNode) //每一层的温度
|
||
{
|
||
int layer = tempParam.Number;
|
||
int cavityId = _unityContainer.Resolve<CavityInfoService>().GetCavityId(item.Key, layer);
|
||
TPalletInfo palletInfo = _unityContainer.Resolve<PalletInfoService>().GetPalletCode(cavityId);
|
||
|
||
if (null == palletInfo
|
||
|| 0 == palletInfo.Id) //没有托盘
|
||
{
|
||
continue;
|
||
}
|
||
if (palletInfo.BakingBeginTime == null //没有烘烤开始时间的不用上传
|
||
|| 0 == palletInfo.VirtualId) //没有绑定电芯
|
||
{
|
||
continue;
|
||
}
|
||
|
||
//PID
|
||
var resultPID = plc.GetValue<float[]>(EStoveSignal.PID.ToString() + layer, item.Key, layer);
|
||
if (!resultPID.IsSuccess)
|
||
{
|
||
LogHelper.Instance.GetCurrentClassError("读取PID失败！");
|
||
continue;
|
||
}
|
||
|
||
//温度
|
||
resultTemp = plc.GetValue<Int16[]>(tempParam.ParamName, item.Key, layer); //温度
|
||
if (!resultTemp.IsSuccess)
|
||
{
|
||
LogHelper.Instance.GetCurrentClassError("读取温度失败！");
|
||
continue;
|
||
}
|
||
|
||
if (resultTemp.Content.All(x => x == 0)
|
||
|| resultPID.Content.All(x => x == 0))
|
||
{
|
||
//LogHelper.Instance.GetCurrentClassError("读取温度异常，全为0！");
|
||
continue;
|
||
}
|
||
|
||
temps = CommonFun.Instance.UShortToFloat(resultTemp.Content);
|
||
|
||
cacheStoveData[cavityId] = new StoveDataModel() //少了两个条件，1.VirtualId为0，2.工作状态
|
||
{
|
||
Temps = temps,
|
||
Vacuum = vacuum,
|
||
WorkTime = workTime,
|
||
TotalWorkTime = totalWorkTime
|
||
};
|
||
|
||
if (isWork) //add by lsm 20250926, 测试用
|
||
{
|
||
string tempData = MakeJsonTemperature(tempParam.VarDesc, temps);
|
||
string pid = MakeJsonPid(EStoveSignal.PID.ToString(), resultPID.Content);
|
||
listStoveTemp.Add(MakeTStoveSctualPatrol(palletInfo.VirtualId, cavityId, palletInfo.PalletCode, vacuum, tempData, pid));
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
//UploadProcessData(cacheStoveData); //1.上传Mom //太多，太卡，不上传
|
||
_eventAggregator.GetEvent<StoveDataEvent>().Publish(cacheStoveData);//2.界面刷新，发布事件（发送消息）
|
||
if (0 != listStoveTemp.Count)
|
||
{
|
||
_unityContainer.Resolve<StoveSctualPatrolService>().Insert(listStoveTemp);//批量插入数据
|
||
}
|
||
}
|
||
|
||
static bool? failDev;
|
||
void DealDewTemp(float value)
|
||
{
|
||
float target = float.Parse(_unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DewTempAlarmTargetValue.ToString()));
|
||
TAlarm alarm = new TAlarm()
|
||
{
|
||
StationId = (int)EAlarmStationId.DevTemp,
|
||
Desc = "露点温度超标，请检查压缩空气！",
|
||
StartTime = DateTime.Now,
|
||
Status = EAlarmStatus.Alert.GetDescription(),
|
||
};
|
||
|
||
if (value <= target) //正常
|
||
{
|
||
if (false != failDev)
|
||
{
|
||
failDev = false;
|
||
_eventAggregator.GetEvent<AlarmCancelEvent>().Publish(alarm);
|
||
}
|
||
}
|
||
else //异常
|
||
{
|
||
if (true != failDev)
|
||
{
|
||
failDev = true;
|
||
_eventAggregator.GetEvent<AlarmAddEvent>().Publish(alarm);
|
||
}
|
||
}
|
||
}
|
||
|
||
//上转Mom
|
||
public void UploadProcessData(Dictionary<int, StoveDataModel> datas)
|
||
{
|
||
if (int.Parse(_unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.MOMEnable.ToString())) == (int)EMOMEnable.Enable)
|
||
{
|
||
foreach (var item in datas)
|
||
{
|
||
string cavityName = _unityContainer.Resolve<MemoryDataProvider>().CavityInfo.Find(x => x.Id == item.Key).Name;
|
||
_unityContainer.Resolve<MESProcess>().MESBakingParameter(item.Value.Vacuum, item.Value.Temps, cavityName);
|
||
}
|
||
}
|
||
}
|
||
|
||
TStoveSctualPatrol MakeTStoveSctualPatrol(int palletVirtualId, int cavityId, string palletCode, float vacuum, string temperature,string pid)
|
||
{
|
||
return new TStoveSctualPatrol()
|
||
{
|
||
PalletVirtualId = palletVirtualId,
|
||
CavityId = cavityId,
|
||
PalletCode = palletCode,
|
||
Vacuum = vacuum,
|
||
Temperature = temperature,
|
||
CreateTime = DateTime.Now,
|
||
PID = pid
|
||
};
|
||
}
|
||
|
||
public string MakeJsonTemperature(string headName, float[] value)
|
||
{
|
||
headName = Regex.Replace(headName, @"\d", "");
|
||
List<PallletTemp> listTemp = new List<PallletTemp>();
|
||
for (int i = 0; i < value.Length; i++)
|
||
{
|
||
listTemp.Add(new PallletTemp()
|
||
{
|
||
HeadName = $"{headName}{i + 1}",
|
||
Value = value[i]
|
||
});
|
||
}
|
||
|
||
return JsonConvert.SerializeObject(listTemp);
|
||
}
|
||
|
||
public string MakeJsonPid(string headName, float[] value)
|
||
{
|
||
//headName = Regex.Replace(headName, @"\d", "");
|
||
List<PallletTemp> listTemp = new List<PallletTemp>();
|
||
for (int i = 1; i < value.Length; i++) //数组0不使用
|
||
{
|
||
listTemp.Add(new PallletTemp()
|
||
{
|
||
HeadName = $"{headName}{i}",
|
||
Value = value[i]
|
||
});
|
||
}
|
||
|
||
return JsonConvert.SerializeObject(listTemp);
|
||
}
|
||
|
||
public void Stop()
|
||
{
|
||
// 在需要取消任务的时候，调用以下代码：
|
||
cts.Cancel();
|
||
}
|
||
}
|
||
}
|
