using HalconDotNet;
|
using LB_SmartVision.Forms.Pages.SettingPage;
|
using LB_SmartVision.Tool;
|
using LB_VisionFlowNode;
|
using LB_VisionProcesses;
|
using LB_VisionProcesses.Alogrithms;
|
using LB_VisionProcesses.Cameras;
|
using LB_VisionProcesses.Communicators;
|
using LB_VisionProcesses.Processes.ScriptTool;
|
using OpenCvSharp;
|
using System.Collections.Concurrent;
|
|
namespace LB_SmartVision.ProcessRun
|
{
|
public class ProcessContext : IFlowContext
|
{
|
/// <summary>
|
/// 通讯集合(Key:通讯名，Value:通讯句柄)
|
/// </summary>
|
public ObservableConcurrentDictionary<string, BaseCommunicator> dicCommunicators { get; set; }
|
|
/// <summary>
|
/// 相机集合(Key:相机SN，Value:相机句柄)
|
/// </summary>
|
public ObservableConcurrentDictionary<string, BaseCamera> dicCameras { get; set; }
|
|
public ConcurrentDictionary<string, List<Tuple<string, string>>> dicInputsMapping { get; set; }
|
|
public ConcurrentDictionary<string, List<string>> dicOutputsMapping { get; set; }
|
|
/// <summary>
|
/// 运行流程
|
/// </summary>
|
public ConcurrentDictionary<string, IProcess> dicContext = new ConcurrentDictionary<string, IProcess>();
|
|
/// <summary>
|
/// 运行标记
|
/// </summary>
|
public bool bRuning = false;
|
|
/// <summary>
|
/// 运行完成
|
/// </summary>
|
public bool bCompleted = true;
|
|
/// <summary>
|
/// 运行结果
|
/// </summary>
|
public bool Result = false;
|
|
/// <summary>
|
/// 运行消息
|
/// </summary>
|
public string Msg = string.Empty;
|
|
/// <summary>
|
/// 运行时间
|
/// </summary>
|
public double RunTime = 0;
|
|
/// <summary>
|
/// 开始时间
|
/// </summary>
|
public DateTime StartTime = DateTime.Now;
|
|
private HTuple ho_ImageWidth = new HTuple();
|
|
private HTuple ho_ImageHeight = new HTuple();
|
|
/// <summary>
|
/// 用于绘制结果图的窗口控件
|
/// </summary>
|
private HWindowControl hWindowControl = new HWindowControl();
|
|
public ProcessContext(ObservableConcurrentDictionary<string, BaseCamera> dicCameras, ObservableConcurrentDictionary<string, BaseCommunicator> dicCommunicators
|
, ConcurrentDictionary<string, List<Tuple<string, string>>> dicInputsMapping, ConcurrentDictionary<string, List<string>> dicOutputsMapping)
|
{
|
this.dicCameras = dicCameras;
|
this.dicCommunicators = dicCommunicators;
|
this.dicInputsMapping = dicInputsMapping;
|
this.dicOutputsMapping = dicOutputsMapping;
|
|
hWindowControl.Size = new System.Drawing.Size(1920, 1080);
|
|
TAlgorithm.set_display_font(hWindowControl.HalconWindow, 1080 / 20, "mono", "true", "false");
|
HOperatorSet.SetLineWidth(hWindowControl.HalconWindow, 5);
|
|
InitializeMethods();
|
InitializeDelegates();
|
|
mappingEngine = new ExpressionTreeMappingEngine(dicContext);
|
}
|
|
// 初始化
|
ExpressionTreeMappingEngine mappingEngine = null;
|
|
/// <summary>
|
/// 编译映射
|
/// </summary>
|
public void CompileMappings()
|
{
|
mappingEngine = new ExpressionTreeMappingEngine(dicContext);
|
mappingEngine.CompileMappings(dicInputsMapping);
|
}
|
|
/// <summary>
|
/// 更新输入（高性能执行）
|
/// </summary>
|
/// <param name="process"></param>
|
public void UpdateInputs(IProcess process)
|
{
|
mappingEngine.UpdateInputs(process);
|
}
|
|
//void UpdateInputs(IProcess process)
|
//{
|
// string ProcessName = process.strProcessName;
|
// List<Tuple<string, string>> listTuples = dicInputsMapping[ProcessName];
|
|
// foreach (var tuple in listTuples)
|
// {
|
// if (string.IsNullOrEmpty(tuple.Item2) || tuple.Item2.Trim() == "")
|
// continue;
|
|
// string[] arrInputs = tuple.Item1.Split(".");
|
// if (arrInputs.Length < 3)
|
// continue;
|
|
// string InputProcessName = arrInputs[0];
|
// string strInput = arrInputs[1];
|
// string InputValueName = arrInputs[2];
|
|
// string[] arrOutputs = tuple.Item2.Split(".");
|
// if (arrOutputs.Length < 2)
|
// continue;
|
|
// string IndexProcessName = arrOutputs[0];
|
// string IndexIsInputOrOutput = arrOutputs[1];
|
// string IndexValueName = arrOutputs.Length == 3 ? arrOutputs[2] : "";
|
|
// //这里的o是你所指向的输出流程
|
// object o = dicContext[IndexProcessName];
|
|
// if (o == null)
|
// continue;
|
// else if (o is IProcess)
|
// {
|
// IProcess i = (IProcess)o;
|
// if (i.strProcessName != IndexProcessName)
|
// continue;
|
|
// if (InputValueName == "Image")
|
// {
|
// switch (IndexIsInputOrOutput)
|
// {
|
// case "Inputs":
|
// //实际上不允许索引的值是输入
|
// if (IndexValueName == "Image")
|
// process.InputImage = i.InputImage;
|
// else
|
// process.InputImage = i.Params.Inputs[IndexValueName];
|
// break;
|
// case "Outputs":
|
// if (IndexValueName == "Image")
|
// process.InputImage = i.OutputImage;
|
// else
|
// process.InputImage = i.Params.Outputs[IndexValueName];
|
// break;
|
// default:
|
// process.InputImage = null;
|
// break;
|
// }
|
|
// if (IndexValueName == "")
|
// process.InputImage = null;
|
// }
|
// else if (InputValueName == "Fixture")
|
// {
|
// //赋值参数
|
// switch (IndexIsInputOrOutput)
|
// {
|
// case "Inputs":
|
// //实际上不允许索引的值是输入
|
// process.Params.Fixture = i.Params.Fixture;
|
// break;
|
// case "Outputs":
|
// process.Params.Fixture = i.Params.Fixture;
|
// break;
|
// default:
|
// //process.Params.Fixture = new Fixture();
|
// break;
|
// }
|
|
// if (IndexValueName == "")
|
// process.Params.Fixture = new Fixture();
|
// }
|
// else if (IndexValueName == "Result")
|
// {
|
// //赋值参数
|
// switch (IndexIsInputOrOutput)
|
// {
|
// case "Inputs":
|
// //实际上不允许索引的值是输入
|
// process.Params.Inputs[InputValueName] = i.Result;
|
// break;
|
// case "Outputs":
|
// process.Params.Inputs[InputValueName] = i.Result;
|
// break;
|
// default:
|
// process.Params.Inputs[InputValueName] = null;
|
// break;
|
// }
|
// }
|
// else if (process.Params.Inputs.Contains(InputValueName))
|
// {
|
// //赋值参数
|
// switch (IndexIsInputOrOutput)
|
// {
|
// case "Inputs":
|
// //实际上不允许索引的值是输入
|
// process.Params.Inputs[InputValueName] = i.Params.Inputs[IndexValueName];
|
// break;
|
// case "Outputs":
|
// process.Params.Inputs[InputValueName] = i.Params.Outputs[IndexValueName];
|
// break;
|
// default:
|
// process.Params.Inputs[InputValueName] = null;
|
// break;
|
// }
|
// }
|
// }
|
// }
|
//}
|
|
public bool GetValue(string map, out object obj)
|
{
|
obj = null;
|
if (string.IsNullOrEmpty(map))
|
return false;
|
|
try
|
{
|
string[] arrMap = map.Split(".");
|
if (arrMap.Length <= 1)
|
return false;
|
|
string IndexProcessName = arrMap[0];
|
string IndexIsInputOrOutput = arrMap[1];
|
string IndexValueName = arrMap.Length == 3 ? arrMap[2] : "";
|
|
//这里的o是你所指向的输出流程
|
object o = dicContext[IndexProcessName];
|
|
if (o != null && o is IProcess i)
|
{
|
if (i.strProcessName != IndexProcessName)
|
return false;
|
|
if (IndexValueName == "Result")
|
{
|
switch (IndexIsInputOrOutput)
|
{
|
case "Inputs":
|
//实际上不允许索引的值是输入
|
obj = i.Result;
|
break;
|
case "Outputs":
|
obj = i.Result;
|
break;
|
default:
|
return false;
|
}
|
}
|
else
|
{
|
//赋值参数
|
switch (IndexIsInputOrOutput)
|
{
|
case "Inputs":
|
obj = i.Params.Inputs[IndexValueName];
|
break;
|
case "Outputs":
|
obj = i.Params.Outputs[IndexValueName];
|
break;
|
default:
|
return false;
|
}
|
}
|
return true;
|
}
|
else
|
return false;
|
}
|
catch { obj = null; return false; }
|
}
|
|
public bool GetStringOutput(string map, out string str)
|
{
|
bool res = GetValue(map, out object obj);
|
str = ProcessParams.ConvertToString(obj);
|
return res;
|
}
|
|
public bool GetImage(Layout layout, out HObject InputImage, out HObject RecordImage)
|
{
|
InputImage = null; RecordImage = null;
|
try
|
{
|
if (layout == null)
|
return false;
|
|
string ProcessName = layout.ProcessName;
|
string InputImageMap = layout.InputImage;
|
string RecordImageMap1 = layout.RecordImage1;
|
string RecordImageMap2 = layout.RecordImage2;
|
string RecordImageMap3 = layout.RecordImage3;
|
|
string[] arrOutputs = new string[] { };
|
string IndexProcessName = string.Empty;
|
string IndexIsInputOrOutput = string.Empty;
|
string IndexValueName = string.Empty;
|
|
#region 获取输入图片
|
arrOutputs = InputImageMap.Split(".");
|
if (arrOutputs.Length > 2)
|
{
|
IndexProcessName = arrOutputs[0];
|
IndexIsInputOrOutput = arrOutputs[1];
|
IndexValueName = arrOutputs[2];
|
|
object o_InputImage = ((IProcess)dicContext[IndexProcessName]).OutputImage;
|
if (o_InputImage is HObject ho_image && ho_image.IsInitialized())
|
InputImage = ho_image;
|
else if (o_InputImage is Bitmap)
|
{
|
//将Mat转换为HObject
|
TAlgorithm.Bitmap2HObject((Bitmap)o_InputImage, out HObject ho_RecordImage);
|
InputImage = ho_RecordImage;
|
}
|
else if (o_InputImage is Mat)
|
{
|
//将Mat转换为HObject
|
TAlgorithm.Mat2HObject((Mat)o_InputImage, out HObject ho_RecordImage);
|
InputImage = ho_RecordImage;
|
}
|
|
if (InputImage != null && InputImage.IsInitialized())
|
{
|
HOperatorSet.GetImageSize(InputImage, out ho_ImageWidth, out ho_ImageHeight);
|
|
//图片尺寸变化才更新窗口尺寸[提高速度]
|
if ((ho_ImageWidth.Length > 0 && ho_ImageWidth.TupleInt() != hWindowControl.Size.Width)
|
|| (ho_ImageHeight.Length > 0 && ho_ImageHeight.TupleInt() != hWindowControl.Size.Height))
|
{
|
hWindowControl.Invoke(new Action(() =>
|
{
|
hWindowControl.Size = new System.Drawing.Size(ho_ImageWidth, ho_ImageHeight);
|
TAlgorithm.set_display_font(hWindowControl.HalconWindow, ho_ImageWidth.I / 20, "mono", "true", "false");
|
}));
|
}
|
}
|
|
TAlgorithm.DispImage(InputImage, hWindowControl.HalconWindow);
|
}
|
#endregion
|
|
#region 绘制结果图
|
arrOutputs = RecordImageMap1.Split(".");
|
if (arrOutputs.Length > 2)
|
{
|
IndexProcessName = arrOutputs[0];
|
IndexIsInputOrOutput = arrOutputs[1];
|
IndexValueName = arrOutputs[2];
|
|
if (dicContext.ContainsKey(IndexProcessName))
|
{
|
ObjectRecord objectRecord1 = ((IProcess)dicContext[IndexProcessName]).Record;
|
if (objectRecord1 != null)
|
{
|
objectRecord1.Display(hWindowControl.HalconWindow);
|
objectRecord1.Dispose();
|
}
|
}
|
}
|
|
arrOutputs = RecordImageMap2.Split(".");
|
if (arrOutputs.Length > 2)
|
{
|
IndexProcessName = arrOutputs[0];
|
IndexIsInputOrOutput = arrOutputs[1];
|
IndexValueName = arrOutputs[2];
|
|
if (dicContext.ContainsKey(IndexProcessName))
|
{
|
ObjectRecord objectRecord2 = ((IProcess)dicContext[IndexProcessName]).Record;
|
if (objectRecord2 != null)
|
{
|
objectRecord2.Display(hWindowControl.HalconWindow);
|
objectRecord2.Dispose();
|
}
|
}
|
}
|
|
arrOutputs = RecordImageMap3.Split(".");
|
if (arrOutputs.Length > 2)
|
{
|
IndexProcessName = arrOutputs[0];
|
IndexIsInputOrOutput = arrOutputs[1];
|
IndexValueName = arrOutputs[2];
|
|
if (dicContext.ContainsKey(IndexProcessName))
|
{
|
ObjectRecord objectRecord3 = ((IProcess)dicContext[IndexProcessName]).Record;
|
if (objectRecord3 != null)
|
{
|
objectRecord3.Display(hWindowControl.HalconWindow);
|
objectRecord3.Dispose();
|
}
|
}
|
}
|
|
if (Result)
|
{
|
Msg = "运行成功";
|
HOperatorSet.SetColor(hWindowControl.HalconWindow, "green");
|
}
|
else
|
HOperatorSet.SetColor(hWindowControl.HalconWindow, "red");
|
|
TAlgorithm.DispMsg(Msg, hWindowControl.HalconWindow, Result ? "green" : "red", 0, 0);
|
HOperatorSet.DumpWindowImage(out RecordImage, hWindowControl.HalconWindow);
|
#endregion
|
|
return true;
|
}
|
catch { return false; }
|
}
|
public bool GetCsv(CsvSetting csv, out List<string> DataTitle, out Dictionary<string, object> ResultData)
|
{
|
// 数据标题
|
DataTitle = (new string[] { "名称", "时间", "耗时", "结果", "原因" }).ToList();
|
|
ResultData = new Dictionary<string, object>();
|
try
|
{
|
ResultData.Add("名称", csv.ProcessName);
|
ResultData.Add("时间", DateTime.Now.ToString("HH:mm:ss.ff"));
|
ResultData.Add("耗时", $"{RunTime.ToString("F2")}");
|
ResultData.Add("结果", Result);
|
ResultData.Add("原因", Msg);
|
|
for (int i = 0; i < csv.Others.Count; i++)
|
{
|
string title = $"数据{i}";
|
string map = csv.Others[i];
|
GetValue(map, out object obj);
|
if (obj == null)
|
continue;
|
|
Type type = obj.GetType();
|
switch (type)
|
{
|
case Type t when t == typeof(double):
|
ResultData.Add(title, ((double)obj).ToString("F4"));
|
DataTitle.Add(title);
|
break;
|
default:
|
ResultData.Add(title, ProcessParams.ConvertToString(obj));
|
DataTitle.Add(title);
|
break;
|
}
|
}
|
|
return true;
|
}
|
catch { return false; }
|
}
|
|
/// <summary>
|
/// 非分支节点的统一调用方式
|
/// </summary>
|
private void RunNodeAsync(FlowNode node)
|
{
|
// 走默认分支
|
node.BranchIndex = "0";
|
string ProcessName = node.Text;
|
try
|
{
|
if (dicContext.TryGetValue(ProcessName, out IProcess obj)
|
&& obj is IProcess process)
|
{
|
process.InputImage = null;
|
UpdateInputs(process);
|
|
// 不同节点跳过的方式不同
|
if (node.Break)
|
{
|
switch (node.Description)
|
{
|
case "T306通讯":
|
node.BranchIndex = "0";
|
node.Result = true;
|
process.Result = false;
|
process.Msg = "T306通讯未启用";
|
return;
|
default:
|
node.BranchIndex = "0";
|
node.Result = true;
|
process.Result = true;
|
process.Msg = string.Empty;
|
return;
|
}
|
}
|
|
if (!process.Run())
|
{
|
node.Result = false;
|
Result &= false;
|
|
if (!string.IsNullOrEmpty(process.Msg)
|
&& !Msg.Contains($"[{process.strProcessName}]{process.Msg}"))
|
Msg += $"[{process.strProcessName}]{process.Msg}";
|
}
|
else
|
node.Result = true;
|
}
|
}
|
catch (Exception ex)
|
{
|
node.Result = false;
|
Result &= false;
|
Msg += $"[{ProcessName}]运行发生意外,{ex.Message}";
|
}
|
}
|
|
|
#region 注册工具事件
|
|
[Node("相机取图", "取像工具", "Basic", "相机取图")]
|
public void 相机取图(FlowNode node) { RunNodeAsync(node); }
|
|
[Node("Halcon2D斑点工具", "Haclon2D工具", "Basic", "Halcon2D斑点工具")]
|
public void Halcon2D斑点工具(FlowNode node) { RunNodeAsync(node); }
|
|
|
#endregion
|
|
|
|
|
|
[Node("开始", "控制", "Logic", "开始")]
|
public override void 开始(FlowNode node)
|
{
|
StartTime = DateTime.Now;
|
RunTime = 0;
|
|
Result = true;
|
bRuning = true;
|
bCompleted = false;
|
Msg = string.Empty;
|
|
HOperatorSet.ClearWindow(hWindowControl.HalconWindow);
|
HOperatorSet.SetColor(hWindowControl.HalconWindow, "green");
|
}
|
|
[Node("结束", "控制", "Logic", "结束")]
|
public override void 结束(FlowNode node)
|
{
|
bRuning = false;
|
bCompleted = true;
|
|
if (Result)
|
Msg = "运行成功";
|
|
RunTime = (DateTime.Now - StartTime).TotalMilliseconds;
|
}
|
|
[Node("分支", "控制", "Logic", "分支")]
|
public override void 分支(FlowNode node)
|
{
|
string ProcessName = node.Text;
|
node.BranchIndex = "-1";
|
node.Result = true;
|
try
|
{
|
if (dicContext.TryGetValue(ProcessName, out IProcess obj) && obj is ScriptTool script)
|
{
|
UpdateInputs(script);
|
if (node.Break)
|
{
|
node.BranchIndex = "0";
|
node.Result = true;
|
script.Result = true;
|
script.Msg = string.Empty;
|
return;
|
}
|
|
if (script.Params.Outputs.Count >= 2)
|
{
|
if (!script.Run())
|
{
|
node.Result = false;
|
Result &= false;
|
Msg = $"[{ProcessName}]{script.Msg}";
|
}
|
|
for (int i = 0; i < script.Params.Outputs.Count; i++)
|
{
|
if (script.Params.Outputs[$"Branch{i}"] != null
|
&& Convert.ToBoolean(script.Params.Outputs[$"Branch{i}"]))
|
{
|
node.BranchIndex = i.ToString();
|
return;
|
}
|
}
|
|
node.Result = false;
|
Result &= false;
|
Msg = $"[{ProcessName}]无满足条件的分支";
|
}
|
else
|
{
|
node.Result = false;
|
Result &= false;
|
Msg = $"[{ProcessName}]分支数量不为2";
|
}
|
}
|
else
|
{
|
node.Result = false;
|
Result &= false;
|
}
|
}
|
catch (Exception ex)
|
{
|
node.Result = false;
|
Result &= false;
|
Msg = $"[{ProcessName}]运行发生意外,{ex.Message}";
|
}
|
}
|
|
[Node("多分支", "控制", "Logic", "多分支")]
|
public override void 多分支(FlowNode node)
|
{
|
if (node.Break)
|
{
|
node.BranchIndex = "0";
|
node.Result = true;
|
return;
|
}
|
|
string ProcessName = node.Text;
|
node.BranchIndex = "-1";
|
node.Result = true;
|
try
|
{
|
if (dicContext.TryGetValue(ProcessName, out IProcess obj) && obj is ScriptTool script)
|
{
|
UpdateInputs(script);
|
if (node.Break)
|
{
|
node.BranchIndex = "0";
|
node.Result = true;
|
script.Result = true;
|
script.Msg = string.Empty;
|
return;
|
}
|
|
if (script.Params.Outputs.Count >= 1)
|
{
|
if (!script.Run())
|
{
|
node.Result = false;
|
Result &= false;
|
Msg = $"[{ProcessName}]{script.Msg}";
|
}
|
|
for (int i = 0; i < script.Params.Outputs.Count; i++)
|
{
|
if (script.Params.Outputs[$"Branch{i}"] != null
|
&& Convert.ToBoolean(script.Params.Outputs[$"Branch{i}"]))
|
{
|
node.BranchIndex = i.ToString();
|
return;
|
}
|
}
|
|
node.Result = false;
|
Result &= false;
|
Msg = $"[{ProcessName}]无满足条件的分支";
|
}
|
else
|
{
|
node.Result = false;
|
Result &= false;
|
Msg = $"[{ProcessName}]多分支数量小于1";
|
}
|
}
|
else
|
{
|
node.Result = false;
|
Result &= false;
|
}
|
}
|
catch (Exception ex)
|
{
|
node.Result = false;
|
Result &= false;
|
Msg = $"[{ProcessName}]运行发生意外,{ex.Message}";
|
}
|
}
|
}
|
}
|
