480 lines
20 KiB
C#
480 lines
20 KiB
C#
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using JSON = Newtonsoft.Json.JsonConvert;
|
|||
|
|
using Newtonsoft.Json;
|
|||
|
|
using Unity;
|
|||
|
|
using System.Collections.Concurrent;
|
|||
|
|
using Cowain.Bake.BLL;
|
|||
|
|
using Cowain.Bake.Common.Enums;
|
|||
|
|
using Cowain.Bake.Model;
|
|||
|
|
using static Cowain.Bake.Common.Models.MESModel;
|
|||
|
|
using Cowain.Bake.Model.Models;
|
|||
|
|
using Cowain.Bake.Common.Core;
|
|||
|
|
using System.Linq;
|
|||
|
|
|
|||
|
|
namespace Cowain.Bake.Communication.MOM
|
|||
|
|
{
|
|||
|
|
public class MESProcess
|
|||
|
|
{
|
|||
|
|
readonly ConcurrentDictionary<int, float> dicMaxTemp = null; //表示该变量的引用（指针）不可变
|
|||
|
|
string url = null;
|
|||
|
|
public string URL
|
|||
|
|
{
|
|||
|
|
get
|
|||
|
|
{
|
|||
|
|
if (url != null)
|
|||
|
|
{
|
|||
|
|
return url;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
TDeviceConfig dev = _unityContainer.Resolve<DeviceConfigService>().GetConfig(EDeviceType.MOM)[0];
|
|||
|
|
GetJsonParam(dev.Json);
|
|||
|
|
return url;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
readonly IUnityContainer _unityContainer;
|
|||
|
|
public MESProcess(IUnityContainer unityContainer)
|
|||
|
|
{
|
|||
|
|
_unityContainer = unityContainer;
|
|||
|
|
dicMaxTemp = new ConcurrentDictionary<int, float>();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public void GetJsonParam(string param)
|
|||
|
|
{
|
|||
|
|
dynamic d = JsonConvert.DeserializeObject<dynamic>(param);
|
|||
|
|
this.url = d.URL;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 心跳
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public MESReturnCmdModel Alive()
|
|||
|
|
{
|
|||
|
|
EqptAlive eqptAlive = new EqptAlive();
|
|||
|
|
DateTime currentTime = DateTime.Now;
|
|||
|
|
DateTime oneMinuteAgo = currentTime.AddMinutes(-1);
|
|||
|
|
eqptAlive.Info.EquipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString()); ;
|
|||
|
|
eqptAlive.Info.PPM = _unityContainer.Resolve<BatteryInfoService>().GetPPM(oneMinuteAgo, currentTime).ToString();
|
|||
|
|
|
|||
|
|
var resultModel = SendData(JSON.SerializeObject(eqptAlive), (int)EMesLogClass.EqptAlive, true);
|
|||
|
|
//string result = HttpClientHelper.HttpPost(URL, JSON.SerializeObject(eqptAlive));
|
|||
|
|
//var resultModel = JSON.DeserializeObject<MESReturnCmdModel>(result);
|
|||
|
|
return resultModel;
|
|||
|
|
}
|
|||
|
|
//2.设备状态 报警要把报警信息传过去，（与PLC确认）
|
|||
|
|
public MESReturnCmdModel MESEqptStatus(UInt16 status, List<TAlarm> models)
|
|||
|
|
{
|
|||
|
|
string urlCmd = URL;
|
|||
|
|
EqptStatus eqptStatu = new EqptStatus();
|
|||
|
|
eqptStatu.Info.EquipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString());// "EC001";
|
|||
|
|
eqptStatu.Info.StatusCode = status.ToString();
|
|||
|
|
if (null != models)
|
|||
|
|
{
|
|||
|
|
foreach(var item in models)
|
|||
|
|
{
|
|||
|
|
eqptStatu.Info.AlertInfo.Add(
|
|||
|
|
new AlerInfoModel()
|
|||
|
|
{
|
|||
|
|
AlertMessage = item.Desc,
|
|||
|
|
AlertCode = item.Id.ToString()
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return SendData(JSON.SerializeObject(eqptStatu), (int)EMesLogClass.Status);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 3.设备报警
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="arrayAlert"></param>
|
|||
|
|
public void MESEqptAlert(List<AlertInfoModel> arrayAlert)
|
|||
|
|
{
|
|||
|
|
if (0 == arrayAlert.Count) return;
|
|||
|
|
|
|||
|
|
EqptAlertModel eqptAlertModel = new EqptAlertModel();
|
|||
|
|
EqptAlert eqptAlert = new EqptAlert();
|
|||
|
|
eqptAlertModel.AlertInfo = arrayAlert;
|
|||
|
|
eqptAlert.Info = eqptAlertModel;
|
|||
|
|
eqptAlert.Info.EquipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString());
|
|||
|
|
SendData(JSON.SerializeObject(eqptAlert), (int)EMesLogClass.Alarm, false);
|
|||
|
|
}
|
|||
|
|
//4.工艺参数请求:心跳为2时请求
|
|||
|
|
public EqptParameterReturnCmd GetProcessParam()
|
|||
|
|
{
|
|||
|
|
EqptParameter process = new EqptParameter();
|
|||
|
|
process.Info.EquipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString());
|
|||
|
|
var result = SendData<EqptParameterReturnCmd>(JSON.SerializeObject(process), (int)EMesLogClass.ParameterRequest);
|
|||
|
|
if (result == default(EqptParameterReturnCmd))
|
|||
|
|
{
|
|||
|
|
LogHelper.Instance.Error($"获取工艺参数失败！请求内容:{JSON.SerializeObject(process)}");
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
///5 参数变更
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="userId"></param>
|
|||
|
|
/// <param name="paramInfo"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public MESReturnCmdModel ChangeParam(string userId, List<EqptParameterModel> paramInfo)
|
|||
|
|
{
|
|||
|
|
ParameterChangeCmd param = new ParameterChangeCmd();
|
|||
|
|
//param.Info = new ParameterChange();
|
|||
|
|
param.Info.EquipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString());
|
|||
|
|
param.Info.EmployeeNo = userId;
|
|||
|
|
param.Info.ParameterInfo = paramInfo;
|
|||
|
|
return SendData(JSON.SerializeObject(param), (int)EMesLogClass.ParameterChange);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//6.联机请求
|
|||
|
|
public MESReturnCmdModel EqptRun(string user, string pwd, string equipmentModel)
|
|||
|
|
{
|
|||
|
|
EqptRunCmd eqptRunCmd = new EqptRunCmd();
|
|||
|
|
EqptRun eqptRun = new EqptRun();
|
|||
|
|
eqptRun.EmployeeNo = user;
|
|||
|
|
eqptRun.Password = pwd;
|
|||
|
|
eqptRun.EquipmentModel = equipmentModel;
|
|||
|
|
eqptRun.EquipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString());
|
|||
|
|
eqptRunCmd.Info = eqptRun;
|
|||
|
|
return SendData(JSON.SerializeObject(eqptRunCmd), (int)EMesLogClass.EqptRun);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
///7 电芯状态获取（进站电芯）
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public MESReturnCmdModel GetBatteryStatus(string batteryCode)
|
|||
|
|
{
|
|||
|
|
CellStateCmd cellStateCmd = new CellStateCmd();
|
|||
|
|
//cellStateCmd.Info = new CellState();
|
|||
|
|
cellStateCmd.Info.CellNo = batteryCode;
|
|||
|
|
cellStateCmd.Info.EquipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString());
|
|||
|
|
return SendData(JSON.SerializeObject(cellStateCmd), (int)EMesLogClass.GetCellState);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
///8 烘烤进站
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="LocationID"></param>
|
|||
|
|
/// <param name="palletCode"></param>
|
|||
|
|
/// <param name="batteryCodes"></param>
|
|||
|
|
public void MESBakingInput(string LocationID, string palletCode, List<string> batteryCodes, string recipeName)
|
|||
|
|
{
|
|||
|
|
BakingInputCmd bakingInputCmd = new BakingInputCmd();
|
|||
|
|
//bakingInputCmd.Info = new BakingInput();
|
|||
|
|
bakingInputCmd.Info.EquipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString());// "EC001";
|
|||
|
|
bakingInputCmd.Info.TrayNo = palletCode;
|
|||
|
|
bakingInputCmd.Info.LocationID = LocationID;
|
|||
|
|
bakingInputCmd.Info.RecipeName = recipeName;
|
|||
|
|
List<CellModel> cellModels = new List<CellModel>();
|
|||
|
|
batteryCodes.ForEach((x) =>
|
|||
|
|
{
|
|||
|
|
cellModels.Add(new CellModel() { CellNo = x });
|
|||
|
|
});
|
|||
|
|
bakingInputCmd.Info.Cells = cellModels;
|
|||
|
|
SendData(JSON.SerializeObject(bakingInputCmd), (int)EMesLogClass.EnterStation, true);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 9.烘烤过程参数采集
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public void MESBakingParameter(float vacuum, float[] temps, string LocationID)
|
|||
|
|
{
|
|||
|
|
int index = 0;
|
|||
|
|
BakingParameterCmd param = new BakingParameterCmd();
|
|||
|
|
//param.Info = new BakingParameter();
|
|||
|
|
List<ProcessData> processDatas = new List<ProcessData>();
|
|||
|
|
param.Info.LocationID = LocationID;
|
|||
|
|
param.Info.LocalTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); ;
|
|||
|
|
param.Info.EquipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString());
|
|||
|
|
|
|||
|
|
//真空
|
|||
|
|
ProcessData parameterInfo = new ProcessData();
|
|||
|
|
parameterInfo.ParameterCode = "HK-0017";
|
|||
|
|
parameterInfo.ParameterType = "float";
|
|||
|
|
parameterInfo.Value = vacuum.ToString();
|
|||
|
|
processDatas.Add(parameterInfo);
|
|||
|
|
|
|||
|
|
//温度
|
|||
|
|
int i = 0;
|
|||
|
|
foreach (var temp in temps)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
if (i % 2 != 0)
|
|||
|
|
{
|
|||
|
|
index++;
|
|||
|
|
parameterInfo = new ProcessData();
|
|||
|
|
parameterInfo.ParameterCode = "HK-00" + $"{12 + index}";
|
|||
|
|
parameterInfo.ParameterType = "float";
|
|||
|
|
parameterInfo.Value = temp.ToString();
|
|||
|
|
parameterInfo.Description = $"巡检-温度{index}";
|
|||
|
|
processDatas.Add(parameterInfo);
|
|||
|
|
}
|
|||
|
|
i++;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
param.Info.ParameterInfo = processDatas;
|
|||
|
|
SendData(JSON.SerializeObject(param), (int)EMesLogClass.BakingParameter, false);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
///10. 烘烤出站
|
|||
|
|
/// </summary>
|
|||
|
|
|
|||
|
|
public MESReturnCmdModel MESBakingOutput(string LocationID, TPalletInfo palletInfo, List<TBatteryInfo> batterys, bool outFlag, bool realTimeSend)
|
|||
|
|
{
|
|||
|
|
BakingOutputCmd outputParams = new BakingOutputCmd();
|
|||
|
|
|
|||
|
|
outputParams.Info.EquipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString());
|
|||
|
|
outputParams.Info.TrayNo = palletInfo.PalletCode;
|
|||
|
|
outputParams.Info.LocationID = LocationID;
|
|||
|
|
outputParams.Info.OutFlag = outFlag ? "Y" : "N";
|
|||
|
|
List<CellModel> cellModels = new List<CellModel>();
|
|||
|
|
WaterModel waterModel = new WaterModel();
|
|||
|
|
|
|||
|
|
if (!string.IsNullOrEmpty(palletInfo.WaterValue))
|
|||
|
|
{
|
|||
|
|
var waterModelList = JsonConvert.DeserializeObject<List<WaterModel>>(palletInfo.WaterValue); //输入水含量异常，导致
|
|||
|
|
waterModel = waterModelList.OrderByDescending(x => x.Id).First(); //最ID最大的
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var batteryCodes = batterys.Select(x => x.BatteryCode).ToList();
|
|||
|
|
batteryCodes.ForEach((x) =>
|
|||
|
|
{
|
|||
|
|
cellModels.Add(new CellModel() { CellNo = x });
|
|||
|
|
});
|
|||
|
|
outputParams.Info.Cells = cellModels;
|
|||
|
|
string RowAndColumn = "";
|
|||
|
|
foreach (var item in batterys)
|
|||
|
|
{
|
|||
|
|
RowAndColumn += $"{item.PositionX}行,{item.PositionY}列,";
|
|||
|
|
}
|
|||
|
|
List<ParametersModel> bakingOutputDatas = new List<ParametersModel>();
|
|||
|
|
|
|||
|
|
ParametersModel bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0001";
|
|||
|
|
bakingOutputData.ParameterDesc = "烘烤号";
|
|||
|
|
var cavity = _unityContainer.Resolve<MemoryDataProvider>().CavityInfo.Where(x => x.Id == (palletInfo.BakingPosition ?? 0)).FirstOrDefault();
|
|||
|
|
bakingOutputData.Value = (cavity == null) ? "" : cavity.Name;
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0002";
|
|||
|
|
bakingOutputData.ParameterDesc = "托盘号";
|
|||
|
|
bakingOutputData.Value = palletInfo.PalletCode;
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0003";
|
|||
|
|
bakingOutputData.ParameterDesc = "行列";
|
|||
|
|
bakingOutputData.Value = $"{RowAndColumn}";
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0004";
|
|||
|
|
bakingOutputData.ParameterDesc = "进站时间";
|
|||
|
|
bakingOutputData.Value = null == palletInfo.LoadingBegingTime ? DateTime.Now.ToString() : palletInfo.LoadingBegingTime.Value.ToString();
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0005";
|
|||
|
|
bakingOutputData.ParameterDesc = "出站时间";
|
|||
|
|
bakingOutputData.Value = DateTime.Now.ToString();
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0006";
|
|||
|
|
bakingOutputData.ParameterDesc = "烘烤开始时间";
|
|||
|
|
bakingOutputData.Value = null == palletInfo.BakingBeginTime ? DateTime.Now.ToString() : palletInfo.BakingBeginTime.Value.ToString();
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0007";
|
|||
|
|
bakingOutputData.ParameterDesc = "烘烤结束时间";
|
|||
|
|
bakingOutputData.Value = null == palletInfo.BakingOverTime ? DateTime.Now.ToString() : palletInfo.BakingOverTime.Value.ToString();
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0008";
|
|||
|
|
bakingOutputData.ParameterDesc = "电芯冷却温度";
|
|||
|
|
var temps = batterys.Select(x => x.CoolTemp).ToList();
|
|||
|
|
bakingOutputData.Value = string.Join(", ", temps);
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0011";
|
|||
|
|
bakingOutputData.ParameterDesc = "冷却开始时间";
|
|||
|
|
bakingOutputData.Value = DateTime.Now.ToString();
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0012";
|
|||
|
|
bakingOutputData.ParameterDesc = "冷却结束时间";
|
|||
|
|
bakingOutputData.Value = DateTime.Now.ToString();
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0013";
|
|||
|
|
bakingOutputData.ParameterDesc = "正极水含量";
|
|||
|
|
bakingOutputData.Value = waterModel.AnodeWaterValue;
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0014";
|
|||
|
|
bakingOutputData.ParameterDesc = "隔膜水含量";
|
|||
|
|
bakingOutputData.Value = waterModel.SeptumWaterValue;
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0015";
|
|||
|
|
bakingOutputData.ParameterDesc = "负极水含量";
|
|||
|
|
bakingOutputData.Value = waterModel.CathodeWaterValue;
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
//bakingOutputData = new ParametersModel();
|
|||
|
|
//bakingOutputData.ParameterCode = "HK-0019";
|
|||
|
|
//bakingOutputData.ParameterDesc = "是否出站";
|
|||
|
|
//bakingOutputData.Value = outFlag ? "Y" : "N";
|
|||
|
|
//bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
bakingOutputData = new ParametersModel();
|
|||
|
|
bakingOutputData.ParameterCode = "HK-0020";
|
|||
|
|
bakingOutputData.ParameterDesc = "最高温度";
|
|||
|
|
bakingOutputData.Value = GetMaxTemperature(palletInfo.VirtualId).ToString();
|
|||
|
|
bakingOutputDatas.Add(bakingOutputData);
|
|||
|
|
|
|||
|
|
outputParams.Info.Parameters = bakingOutputDatas;
|
|||
|
|
//return outputParams;
|
|||
|
|
return SendData(JSON.SerializeObject(outputParams), (int)EMesLogClass.ExitStation, realTimeSend);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public float GetMaxTemperature(int virtualId)
|
|||
|
|
{
|
|||
|
|
float value = 0;
|
|||
|
|
if (!dicMaxTemp.TryGetValue(virtualId, out value)) //可以不删除dicMaxTemp，因为量不大，
|
|||
|
|
{
|
|||
|
|
LogHelper.Instance.Warn("开始获取最高温度");
|
|||
|
|
value = _unityContainer.Resolve<StoveSctualPatrolService>().GetStoveMaxTemp(virtualId);
|
|||
|
|
LogHelper.Instance.Warn("结束获取最高温度");
|
|||
|
|
|
|||
|
|
dicMaxTemp.TryAdd(virtualId, value);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return value;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public MESReturnCmdModel SendData(string info, sbyte msgType = (int)EMesLogClass.ExitStation, bool isEanble = true)
|
|||
|
|
{
|
|||
|
|
var result = GetRecvData(info, msgType, isEanble);
|
|||
|
|
if (string.IsNullOrEmpty(result))
|
|||
|
|
{
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return JSON.DeserializeObject<MESReturnCmdModel>(result);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public T SendData<T>(string info, sbyte msgType, bool isEanble = true)
|
|||
|
|
{
|
|||
|
|
var result = GetRecvData(info, msgType, isEanble);
|
|||
|
|
if (string.IsNullOrEmpty(result))
|
|||
|
|
{
|
|||
|
|
return default(T); //default(T)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return JSON.DeserializeObject<T>(result);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public string GetRecvData(string info, sbyte msgType, bool isEanble = true)
|
|||
|
|
{
|
|||
|
|
CCommandType ct = new CCommandType();
|
|||
|
|
ct.UrlCmd = URL;
|
|||
|
|
TMesData mesModel = new TMesData();
|
|||
|
|
mesModel.CreateTime = DateTime.Now;
|
|||
|
|
mesModel.CommandType = JSON.SerializeObject(ct);
|
|||
|
|
mesModel.Content = info; //JSON.SerializeObject(obj);
|
|||
|
|
mesModel.MsgType = msgType;
|
|||
|
|
if (int.Parse(_unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.MOMEnable.ToString())) == (int)EMOMEnable.Enable
|
|||
|
|
&& isEanble) //又发又存
|
|||
|
|
{
|
|||
|
|
mesModel.SendTime = DateTime.Now;
|
|||
|
|
string result = HttpClientHelper.HttpPost(URL, info);
|
|||
|
|
mesModel.RecvTime = DateTime.Now;
|
|||
|
|
mesModel.RecvContent = result;
|
|||
|
|
mesModel.SendFlag = string.IsNullOrEmpty(result) ? (sbyte)EMesUpLoadStatus.Fail : (sbyte)EMesUpLoadStatus.Success;
|
|||
|
|
|
|||
|
|
if(msgType != (int)EMesLogClass.EqptAlive)
|
|||
|
|
{
|
|||
|
|
_unityContainer.Resolve<MesDataService>().Insert(mesModel); //保存数据
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (string.IsNullOrEmpty(result))
|
|||
|
|
{
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
WriteRequestLog(info);
|
|||
|
|
WriteResponseLog(result);
|
|||
|
|
//var resultModel = JSON.DeserializeObject<MESReturnCmdModel>(result);
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
else if (int.Parse(_unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.MOMEnable.ToString())) == (int)EMOMEnable.Disable
|
|||
|
|
|| !isEanble) //只存不发
|
|||
|
|
{
|
|||
|
|
mesModel.SendFlag = (sbyte)EMesUpLoadStatus.Wait;
|
|||
|
|
_unityContainer.Resolve<MesDataService>().Insert(mesModel); //保存数据
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
else //不发，也不存
|
|||
|
|
{
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
///发送
|
|||
|
|
public void WriteRequestLog(string info)
|
|||
|
|
{
|
|||
|
|
dynamic d = JsonConvert.DeserializeObject<dynamic>(info);
|
|||
|
|
string cmd = d.Cmd;
|
|||
|
|
string dateTime = DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss");
|
|||
|
|
string uuid = d.Info.Key;
|
|||
|
|
LogHelper.Instance.Trace($"[Request][{cmd}][{dateTime}][{uuid}][{info}]");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 接收
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="info"></param>
|
|||
|
|
public void WriteResponseLog(string info)
|
|||
|
|
{
|
|||
|
|
dynamic d = JsonConvert.DeserializeObject<dynamic>(info);
|
|||
|
|
string cmd = d.Cmd;
|
|||
|
|
string dateTime = DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss");
|
|||
|
|
string uuid = d.Info.Key;
|
|||
|
|
LogHelper.Instance.Trace($"[Response][{cmd}][{dateTime}][{uuid}][{info}]");
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public string GetEquipmentCode(int MachineID)
|
|||
|
|
{
|
|||
|
|
string equipmentCode = _unityContainer.Resolve<SysSetupService>().GetValueByParaID(ESysSetup.DeviceNum.ToString());
|
|||
|
|
string LineCode = equipmentCode.Substring(equipmentCode.Length - 2);
|
|||
|
|
MachineID = int.Parse(LineCode) + MachineID - 1;
|
|||
|
|
string formattedNumber = MachineID.ToString().PadLeft(2, '0');
|
|||
|
|
equipmentCode = equipmentCode.Replace(LineCode, formattedNumber);
|
|||
|
|
return equipmentCode;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
