|
using DataEntity;
|
using DataEntity.Share;
|
using DataRWDAL;
|
using DriverLib.Engine;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using System;
|
using System.Collections.Generic;
|
using System.Configuration;
|
using System.Data;
|
using System.IO;
|
using System.Net;
|
using System.Runtime.Serialization.Formatters.Binary;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using System.Windows;
|
using System.Windows.Threading;
|
using System.Xml;
|
using XCommon.Log;
|
using XCore;
|
using XCoreBLL;
|
using XHandler.Class;
|
using XHandler.Controls;
|
using XHandler.View;
|
using XImaging.Automation.Service.Interface;
|
using XImagingXhandler.XDAL;
|
using DataEntity;
|
using System.ComponentModel;
|
using System.Reflection;
|
using Sodao.FastSocket.Server.Config;
|
using System.Collections.ObjectModel;
|
using System.Text;
|
using MySqlX.XDevAPI.Common;
|
using XImaging.Automation.Service.Instruction;
|
|
namespace XHandler.Runtime
|
{
|
class DeviceRuntime : IRuntime
|
{
|
public ErrorHandleDelegate errorHandle { get; set; }
|
|
public ErrorHandleDelegate abortHandle { get; set; }
|
public FinishHandleDelegate finishHandle { get; set; }
|
|
public string ErrorState { get; set; }
|
public RuntimeState State { get; set; }
|
public int TroubleShoot { get; set; }
|
DeviceSimulator deviceSimulator = new DeviceSimulator();
|
|
#region 回零
|
/// <summary>
|
/// 运行回到设备零位
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Home(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
try
|
{
|
JObject job = obj as JObject;
|
string strParam = string.Empty;
|
bool isSimulator = false;
|
strParam = job["parameters"].ToString();
|
//string experimentId = job["experiment_id"].ToString();
|
//string workflowid = job["workflow_id"].ToString();
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【home】remote progress: " + obj.ToString());
|
|
JObject jobParms = JObject.Parse(strParam);
|
isSimulator = jobParms["IsSimulator"].ToString().ToLower() == "true" ? true : false;
|
string experimentnum = jobParms["Experimentnum"].ToString();
|
|
//调用复位方法全部轴复位回零
|
//调用执行方法,更新执行结果字符串
|
HomeControl homeControl = new HomeControl(Shared.SoftwareInformation.currentculture);
|
HomeBll homeBll = new HomeBll();
|
float xAxisSafeVal = (float)Convert.ToDouble(ConfigurationManager.AppSettings["xAxisSafeVal"]);
|
float yAxisSafeVal = (float)Convert.ToDouble(ConfigurationManager.AppSettings["yAxisSafeVal"]);
|
float zAxisSafeVal = (float)Convert.ToDouble(ConfigurationManager.AppSettings["zAxisSafeVal"]);
|
|
HomeMParam homeMParam = new HomeMParam();
|
int iresult = 1;
|
homeMParam.xAxisVal = xAxisSafeVal;
|
homeMParam.yAxisVal = yAxisSafeVal;
|
homeMParam.zAxisVal = zAxisSafeVal;
|
|
isStop = false;
|
SaveState(_isStopFilePath, 2, false);//重新开始流程
|
|
HxResult ret = new HxResult();
|
ret = CommonBll.StatusLamp(4, false);
|
ret = homeBll.ExecuteHome(homeMParam, isSimulator);
|
_manualResetEvent = new ManualResetEvent(false);
|
SaveState(_filePath, 1, false);//存储暂停控制信号状态
|
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
RunWnd runWnd = new RunWnd();
|
runWnd.mainWindow = (MainWindow)Application.Current.MainWindow;
|
runWnd.isRemotingOper = true;
|
runWnd.EnableSimulator = isSimulator;
|
if (runWnd.mainWindow.socketTcpListener != null)
|
{
|
if (runWnd.isRemotingOper)
|
{
|
if (Shared.SoftwareInformation.software_device_number == DeviceCategory.DeviceChoice)
|
{
|
MethodMsg methodMsgS = new MethodMsg(Guid.NewGuid().ToString(), "ID202_Choice_machine", 2, "", "ClawOpen", "", "", 1, 0);
|
|
//if (!runWnd.mainWindow.socketTcpListener.IsConnect())
|
//{
|
// runWnd.mainWindow.socketTcpListener.ReConnect();
|
//}
|
// 拍照
|
runWnd.mainWindow.socketTcpListener.SendMessage(runWnd.mainWindow.socketTcpListener.CreateSendOpenCraw(methodMsgS), true);
|
System.Threading.Thread.Sleep(5000);
|
}
|
|
if (ret.Result != ResultType.Success)
|
{
|
MethodAction.Instance.StatusLamp(7);
|
errorHandle?.Invoke(obj, "EC-1039", 5, "home is fail! error information：" + ret.AlarmInfo, 2);
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【home】progress: home is fail! error information：" + ret.AlarmInfo);
|
iresult = 0;
|
}
|
else
|
{
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【home】progress: home is success!");
|
}
|
}
|
}
|
}));
|
|
if (ret.Result != ResultType.Success)
|
{
|
errorHandle?.Invoke(obj, "EC-1039", 5, "home is fail! error information：" + ret.AlarmInfo, 2);
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【home】progress: home is fail! error information：" + ret.AlarmInfo);
|
iresult = 0;
|
}
|
else
|
{
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【home】progress: home is success!");
|
}
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【home】progress: complete;");
|
|
if (iresult == 0)
|
{
|
State = RuntimeState.OnError;
|
result = JObject.Parse("{method_status:3}");
|
errorHandle?.Invoke(obj, "EC-1039", 5, "home is fail! error information：" + ret.AlarmInfo.ToString(), 1);
|
}
|
else if (iresult == 1)
|
{
|
State = RuntimeState.OnIdle;
|
|
result = JObject.Parse("{method_status:2}");
|
}
|
else if (iresult == 2)
|
{
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:4}");
|
}
|
try
|
{
|
GenerateRunLogBase(experimentnum, "", iresult == 1 ? 1 : 0);
|
GenerateRunLog(experimentnum);
|
}
|
catch(Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
}
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
State = RuntimeState.OnError;
|
errorHandle?.Invoke(obj, "EC-1039", 5, "home is fail! error information：" + ex.Message.ToString(), 2);
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
#endregion
|
|
#region 运行时实验日志
|
/// <summary>
|
/// 实验记录入库
|
/// </summary>
|
public void GenerateRunLogBase(string experimentid, string workflowid, int result)
|
{
|
ExperimentModel experiment = new ExperimentModel();
|
string methodFileName = workflowid;
|
experiment.ExperimentId = experimentid;
|
experiment.ExperimentName = "";
|
experiment.ExperimentXmlContent = "";
|
experiment.ExperimentFile = methodFileName;
|
experiment.LunchTime = DateTime.Now;
|
experiment.Status = result;
|
experiment.OperaterName = "中控";
|
|
ExperimentDB.Add(experiment);
|
}
|
#endregion
|
|
#region 运行开始时日志
|
public ExperimentRunLog GenerateRunLog(string experimentId)
|
{
|
ExperimentRunLog experimentRunLog = new ExperimentRunLog();
|
try
|
{
|
experimentRunLog.experimentrunid = experimentId;
|
experimentRunLog.experimentid = experimentId;
|
experimentRunLog.lunchtime = DateTime.Now;
|
experimentRunLog.endtime = DateTime.Now;
|
experimentRunLog.operatorname = "中控";
|
experimentRunLog.status = 0;
|
|
|
int iResult = ExperimentRunLogDB.AddExperimentRunLogIntodb(experimentRunLog);
|
if (iResult == 1)
|
{
|
}
|
else
|
{
|
experimentRunLog = null;
|
}
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("添加运行记录时错误：" + ex.ToString());
|
}
|
return experimentRunLog;
|
}
|
#endregion
|
|
#region 成像专用--拍照参数
|
/// <summary>
|
/// 设置挑菌参数
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_PhotoParam(Object obj)
|
{
|
bool bRet = false;
|
string path = ConfigurationManager.AppSettings.Get("choiceFilePath");
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
|
try
|
{
|
|
if (File.Exists(path))
|
{
|
if (File.Exists(path.Split('.')[0] + "_1." + path.Split('.')[1]))
|
{
|
File.Delete(path.Split('.')[0] + "_1." + path.Split('.')[1]);
|
}
|
File.Copy(path, path.Split('.')[0] + "_1." + path.Split('.')[1]);
|
File.Delete(path);
|
}
|
|
JObject Obj = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【PhotoParam】remote progress:get data: " + obj.ToString());
|
|
string objstr = Obj["parameters"].ToString();
|
//通过URL获取参数
|
Dictionary<string, object> strdata = JsonConvert.DeserializeObject<Dictionary<string, object>>(objstr);
|
string jsonURL = strdata["SetBacteriaParam_param"].ToString();
|
string jsonFilePath = ConfigurationManager.AppSettings["captureFilePath"].ToString() + "\\downJson";
|
LoggerHelper.InfoLog("the opeate of write file is starting...1");
|
int fiMax = 1;
|
if (Directory.Exists(jsonFilePath))
|
{
|
//获取目录下文件的最大名称值
|
string[] files = Directory.GetFiles(jsonFilePath);
|
foreach (string f in files)
|
{
|
string f1 = f.Split('.')[0];
|
int startIndex = f1.LastIndexOf('\\');
|
string namestr = f1.Substring(startIndex + 1, f1.Length - startIndex - 1);
|
int fileName = Convert.ToInt32(namestr);
|
if (fileName > fiMax)
|
{
|
fiMax = fileName;
|
}
|
}
|
}
|
else
|
{
|
Directory.CreateDirectory(jsonFilePath);
|
}
|
LoggerHelper.InfoLog("the opeate of write file is starting...2");
|
using (WebClient client = new WebClient())
|
{
|
string fullJsonFileName = string.Empty;
|
if (Directory.Exists(jsonFilePath))
|
{
|
fullJsonFileName = jsonFilePath + "\\" + (fiMax + 1).ToString() + ".json";
|
if (File.Exists(fullJsonFileName))
|
{
|
File.Delete(fullJsonFileName);
|
}
|
client.DownloadFile(jsonURL, fullJsonFileName);
|
}
|
LoggerHelper.InfoLog("the opeate of write file is starting...3");
|
string jsonText = File.ReadAllText(fullJsonFileName);
|
//JObject ObjTxt = JObject.Parse(jsonText);
|
//string strParams = ObjTxt["parameters"].ToString();
|
JObject objParam = JObject.Parse(jsonText);
|
|
string experiment_id = objParam["experiment_id"].ToString();
|
string experimentnum = objParam["experimentnum"].ToString();
|
string barcode = objParam["barcode"].ToString();
|
string bacterias = objParam["bacterias"].ToString();
|
string shape = objParam["shape"].ToString();
|
string edge = objParam["edge"].ToString();
|
string color = objParam["color"].ToString();
|
string min_diameterSize = objParam["min_diam"].ToString();
|
string max_diameterSize = objParam["max_diam"].ToString();
|
string proximity = objParam["prox"].ToString();
|
string choice_mode = objParam["choice_mode"].ToString();
|
string choice_distance_mode = objParam["choice_distance_mode"].ToString();
|
string choice_distance_value = objParam["choice_distance_value"].ToString();
|
string choice_xAxis_offsite = objParam["choice_xAxis_offsite"].ToString();
|
string choice_yAxis_offsite = objParam["choice_yAxis_offsite"].ToString();
|
string coating_bottom_distance = objParam["coating_bottom_distance"].ToString();
|
string coating_xAxis_offsite = objParam["coating_xAxis_offsite"].ToString();
|
string coating_yAxis_offsite = objParam["coating_yAxis_offsite"].ToString();
|
string coating_mode = objParam["coating_mode"].ToString();
|
LoggerHelper.InfoLog("the opeate of write file is starting...4");
|
DataTable dtResult = GenerateDataTableByChoiceParams(objParam);
|
LoggerHelper.InfoLog("the opeate of write file is starting...");
|
bRet = ExcelAndCsvHelper.WriteDataTableToExcelFile(dtResult, path);
|
LoggerHelper.InfoLog("write file=" + path + ", return=" + bRet.ToString());
|
bRet = false;
|
}
|
|
result = JObject.Parse("{method_status:2}");
|
|
State = RuntimeState.OnIdle;
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
State = RuntimeState.OnIdle;
|
if (!bRet)
|
{
|
if (!File.Exists(path))
|
{
|
File.Copy(path.Split('.')[0] + "_1." + path.Split('.')[1], path);
|
}
|
if (File.Exists(path.Split('.')[0] + "_1." + path.Split('.')[1]))
|
{
|
File.Delete(path.Split('.')[0] + "_1." + path.Split('.')[1]);
|
}
|
result = JObject.Parse("{method_status:3}");
|
State = RuntimeState.OnError;
|
}
|
else
|
{
|
if (File.Exists(path.Split('.')[0] + "_1." + path.Split('.')[1]))
|
{
|
File.Delete(path.Split('.')[0] + "_1." + path.Split('.')[1]);
|
}
|
}
|
}
|
return result;
|
}
|
|
public DataTable GenerateDataTableByChoiceParams(JObject objParam)
|
{
|
//构建datatable
|
DataTable dataResult = new DataTable();
|
DataColumn dc = new DataColumn();
|
dc.ColumnName = "中文名";
|
dataResult.Columns.Add(dc);
|
|
dc = new DataColumn();
|
dc.ColumnName = "属性名";
|
dataResult.Columns.Add(dc);
|
|
dc = new DataColumn();
|
dc.ColumnName = "属性值";
|
dataResult.Columns.Add(dc);
|
|
DataRow dr = dataResult.NewRow();
|
dr["中文名"] = "实验ID";
|
dr["属性名"] = "experiment_id";
|
dr["属性值"] = objParam["experiment_id"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "皿的二维码信息";
|
dr["属性名"] = "barcode";
|
dr["属性值"] = objParam["barcode"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "菌名称";
|
dr["属性名"] = "bacterias";
|
dr["属性值"] = objParam["bacterias"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "形状";
|
dr["属性名"] = "shape";
|
dr["属性值"] = objParam["shape"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "边缘";
|
dr["属性名"] = "edge";
|
dr["属性值"] = objParam["edge"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "颜色";
|
dr["属性名"] = "color";
|
dr["属性值"] = objParam["color"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "最小直径";
|
dr["属性名"] = "min_diam";
|
dr["属性值"] = objParam["min_diam"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "最大直径";
|
dr["属性名"] = "max_diam";
|
dr["属性值"] = objParam["max_diam"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "临近度";
|
dr["属性名"] = "prox";
|
dr["属性值"] = objParam["prox"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "挑菌模式";
|
dr["属性名"] = "choice_mode";
|
dr["属性值"] = objParam["choice_mode"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "挑菌距离底部或菌类形";
|
dr["属性名"] = "choice_distance_mode";
|
dr["属性值"] = objParam["choice_distance_mode"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "挑菌距离底部或菌类距离";
|
dr["属性名"] = "choice_distance_value";
|
dr["属性值"] = objParam["choice_distance_value"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "挑菌时x轴偏移量";
|
dr["属性名"] = "choice_xAxis_offsite";
|
dr["属性值"] = objParam["choice_xAxis_offsite"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "挑菌时y轴偏移量";
|
dr["属性名"] = "choice_yAxis_offsite";
|
dr["属性值"] = objParam["choice_yAxis_offsite"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "涂布距离底部距离";
|
dr["属性名"] = "coating_bottom_distance";
|
dr["属性值"] = objParam["coating_bottom_distance"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "涂布时x轴偏移量";
|
dr["属性名"] = "coating_xAxis_offsite";
|
dr["属性值"] = objParam["coating_xAxis_offsite"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "涂布时y轴偏移量";
|
dr["属性名"] = "coating_yAxis_offsite";
|
dr["属性值"] = objParam["coating_yAxis_offsite"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "涂布方式";
|
dr["属性名"] = "coating_mode";
|
dr["属性值"] = objParam["coating_mode"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "涂布速度";
|
dr["属性名"] = "coating_speed";
|
dr["属性值"] = objParam["coating_speed"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "模型类型";
|
dr["属性名"] = "model_type";
|
dr["属性值"] = objParam["model_type"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "合并识别";
|
dr["属性名"] = "merge_masks";
|
dr["属性值"] = objParam["merge_masks"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "降采样率";
|
dr["属性名"] = "ds_ratio";
|
dr["属性值"] = objParam["ds_ratio"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "平均直径";
|
dr["属性名"] = "mean_diam";
|
dr["属性值"] = objParam["mean_diam"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "到边缘距离";
|
dr["属性名"] = "dist_to_edge";
|
dr["属性值"] = objParam["dist_to_edge"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "菌标记颜色";
|
dr["属性名"] = "mark_color";
|
dr["属性值"] = objParam["mark_color"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "菌标记序号";
|
dr["属性名"] = "draw_label";
|
dr["属性值"] = objParam["draw_label"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "菌标记字体大小";
|
dr["属性名"] = "fontsize";
|
dr["属性值"] = objParam["fontsize"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "顶部背光亮度";
|
dr["属性名"] = "top_light";
|
dr["属性值"] = objParam["top_light"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "底部背光亮度";
|
dr["属性名"] = "bottom_light";
|
dr["属性值"] = objParam["bottom_light"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "挑菌落方式";
|
dr["属性名"] = "choice_category";
|
dr["属性值"] = objParam["choice_category"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "挑菌时下压的距离";
|
dr["属性名"] = "press_distanceval";
|
dr["属性值"] = objParam["press_distanceval"].ToString();
|
dataResult.Rows.Add(dr);
|
|
dr = dataResult.NewRow();
|
dr["中文名"] = "实验编号";
|
dr["属性名"] = "experimentnum";
|
dr["属性值"] = objParam["experimentnum"].ToString();
|
dataResult.Rows.Add(dr);
|
|
return dataResult;
|
}
|
#endregion
|
|
#region 成像专用--涂布
|
/// <summary>
|
/// 设置涂布数据
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_RunDataParamC(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
JObject result = new JObject();
|
|
try
|
{
|
|
State = RuntimeState.OnBusy;
|
|
|
|
DataTable dt = new DataTable();
|
dt.Columns.Add("序号", typeof(string));
|
dt.Columns.Add("来源板", typeof(string));
|
dt.Columns.Add("来源板码", typeof(string));
|
dt.Columns.Add("来源孔", typeof(string));
|
dt.Columns.Add("目标板", typeof(string));
|
dt.Columns.Add("目标板码", typeof(string));
|
dt.Columns.Add("目标孔", typeof(string));
|
dt.Columns.Add("移液体积", typeof(string));
|
dt.Columns.Add("是否更换吸头", typeof(string));
|
|
JObject Obj = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【RunDataParam】remote progress:get data: " + obj.ToString());
|
string objstr = Obj["parameters"].ToString();
|
Dictionary<string, object> strdata = JsonConvert.DeserializeObject<Dictionary<string, object>>(objstr);
|
string jsonURL = strdata["Method_Coatingfile_Param"].ToString();
|
string jsonFilePath = ConfigurationManager.AppSettings["captureFilePath"].ToString() + "\\downJson";
|
|
int fiMax = 1;
|
if (Directory.Exists(jsonFilePath))
|
{
|
//获取目录下文件的最大名称值
|
string[] files = Directory.GetFiles(jsonFilePath);
|
foreach (string f in files)
|
{
|
string f1 = f.Split('.')[0];
|
int startIndex = f1.LastIndexOf('\\');
|
string namestr = f1.Substring(startIndex + 1, f1.Length - startIndex - 1);
|
int fileName = Convert.ToInt32(namestr);
|
if (fileName > fiMax)
|
{
|
fiMax = fileName;
|
}
|
}
|
}
|
else
|
{
|
Directory.CreateDirectory(jsonFilePath);
|
}
|
|
using (WebClient client = new WebClient())
|
{
|
string fullJsonFileName = string.Empty;
|
if (Directory.Exists(jsonFilePath))
|
{
|
fullJsonFileName = jsonFilePath + "\\" + (fiMax + 1).ToString() + ".json";
|
if (File.Exists(fullJsonFileName))
|
{
|
File.Delete(fullJsonFileName);
|
}
|
client.DownloadFile(jsonURL, fullJsonFileName);
|
}
|
string jsonText = File.ReadAllText(fullJsonFileName);
|
//JObject jsonObj = JObject.Parse(jsonText);
|
|
List<SetCoatingData_param> strdata1 = JsonConvert.DeserializeObject<List<SetCoatingData_param>>(jsonText);
|
foreach (SetCoatingData_param sd in strdata1)
|
{
|
DataRow dr = dt.NewRow();
|
int i = 0;
|
dr["序号"] = sd.CoatingDataId.ToString();
|
dr["来源板"] = sd.SourcePlateID.ToString();
|
dr["来源板码"] = sd.SourcePlateBarcode.ToString();
|
dr["来源孔"] = sd.SourcePlateWell.ToString();
|
|
dr["目标板"] = sd.TargetPlateID.ToString();
|
dr["目标板码"] = sd.TargetPlateBarcode.ToString();
|
dr["目标孔"] = sd.TargetPlateWell.ToString();
|
dr["移液体积"] = sd.Volume.ToString();
|
dr["是否更换吸头"] = sd.changetips.ToString();
|
dt.Rows.Add(dr);
|
}
|
string filePath = strdata["PickAndCoatTable"].ToString();
|
|
string file = filePath;
|
|
string path = file.Substring(0, file.LastIndexOf('\\'));
|
if (!Directory.Exists(path))
|
{
|
Directory.CreateDirectory(path);
|
LoggerHelper.InfoLog("creat directory: " + path);
|
}
|
ExcelAndCsvHelper.WriteDataTableToCSV(dt, file);
|
bool bRet = true;
|
LoggerHelper.InfoLog("write file=" + file + ", return=" + bRet.ToString());
|
if (!bRet)
|
{
|
State = RuntimeState.OnError;
|
result = JObject.Parse("{method_status:3}");
|
throw new Exception("Execute was failed!");
|
}
|
else if (bRet)
|
{
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:2}");
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
|
/// <summary>
|
/// 运行方法
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_Run(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
try
|
{
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【Run】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
string methodFileName = string.Empty;
|
string strParam2 = string.Empty;
|
bool isSimulator = false;
|
string experimentrunid = job["experiment_id"].ToString();
|
strParam = job["parameters"].ToString();
|
|
JObject jobParms = JObject.Parse(strParam);
|
methodFileName = jobParms["FlowName"].ToString();
|
strParam2 = jobParms["PickAndCoatTable"].ToString();
|
isSimulator = jobParms["isSimulator"].ToString().ToLower() == "true" ? true : false;
|
|
string shortDir = ConfigurationManager.AppSettings["MethodFileBasePath"].ToString();
|
string fullName = shortDir + "\\" + methodFileName + ".xmed";
|
if (File.Exists(fullName))
|
{
|
XmlDocument xmlDocument = new XmlDocument();
|
xmlDocument.Load(fullName);
|
|
MethodListBll methodListBll = new MethodListBll();
|
XmlNodeList xmlNodeMethodList = xmlDocument.SelectNodes("root/method[@id>=3]");
|
for (int n = 0; n < xmlNodeMethodList.Count; n++)
|
{
|
string MethodName = xmlNodeMethodList[n].SelectSingleNode("name").InnerText;
|
int iNum = methodListBll.getNumByMethodName(MethodName);
|
switch (iNum)
|
{
|
case (int)MethodNameEnum.coatingfile:
|
if (xmlNodeMethodList[n].SelectSingleNode("status").InnerText == "enable")
|
{
|
xmlNodeMethodList[n].SelectSingleNode("filePath").InnerText = strParam2;
|
}
|
break;
|
default:
|
break;
|
}
|
}
|
App.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
RunWnd runWnd = new RunWnd();
|
runWnd.xmlDocument = xmlDocument;
|
runWnd.isRemotingOper = true;
|
runWnd.EnableSimulator = isSimulator;
|
// 从文件中读取已经使用的Tip信息
|
RunWnd.currentIsUsedWellLattice = runWnd.GetUsedTipFromXML();
|
TaskFactory taskFactory = new TaskFactory();
|
int iresult = runWnd.LoadLabwareOnRunningRemote();
|
|
if (iresult == 0)
|
{
|
State = RuntimeState.OnError;
|
result = JObject.Parse("{method_status:3}");
|
throw new Exception("Execute was failed!");
|
}
|
else if (iresult == 1)
|
{
|
State = RuntimeState.OnIdle;
|
runWnd.xmlDocument.Save(fullName);
|
|
var dt = DateTime.Now.ToString("yyyy-MM-dd-hh-mm-ss");
|
string fileNameStr = dt + ".json";
|
string fileNameImg = dt + ".jpg";
|
|
// 从拍照的json文件中，读取菌属性值，打包成涂布报告的格式
|
string jsonFilePath = ConfigurationManager.AppSettings["captureFilePath"].ToString();
|
string[] files = Directory.GetFiles(jsonFilePath);
|
int fiMax = 1;
|
|
foreach (string f in files)
|
{
|
string f1 = f.Split('.')[0];
|
int startIndex = f1.LastIndexOf('\\');
|
string namestr = f1.Substring(startIndex + 1, f1.Length - startIndex - 1);
|
if (namestr.Contains("_原"))
|
{
|
continue;
|
}
|
int fileName = Convert.ToInt32(namestr);
|
if (fileName > fiMax)
|
{
|
fiMax = fileName;
|
}
|
}
|
|
string fullJsonFileName = jsonFilePath + "\\" + (fiMax).ToString() + ".jpg";
|
string folder = "UploadFolder";
|
string uploadPath = AppDomain.CurrentDomain.BaseDirectory + folder;
|
if (!Directory.Exists(uploadPath))
|
{
|
Directory.CreateDirectory(uploadPath);
|
}
|
string pathStr = uploadPath + "\\" + fileNameImg;
|
string pathStrJson = uploadPath + "\\" + fileNameStr;
|
|
//改图像名，存入新的路径下
|
File.Copy(fullJsonFileName, pathStr, true);
|
|
string ip = HttpServer.GetLocalIP();
|
string port = ConfigurationManager.AppSettings["socketURLPort"].ToString();
|
string server = $"http://{ip}:{port}/UploadFolder/";
|
|
string strResultJson = runWnd.GenerateCoatingReport(server + fileNameImg);
|
|
HttpServer.CreateFileContent(pathStrJson, strResultJson);
|
//string fullPath = HttpServer.Init(HttpServer.GetLocalIP(), "8081", fileNameStr, runWnd.GenerateCoatingReport());
|
//string fullPathImg = HttpServer.Init(HttpServer.GetLocalIP(), "8081", fileNameImg, "");
|
|
result = JObject.Parse("{json:\"" + server + fileNameStr + "\"" +
|
"}");
|
}
|
else if (iresult == 2)
|
{
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:2}");
|
}
|
}));
|
|
}
|
else
|
{
|
//弹出窗口提示所执行的方法不存在
|
}
|
|
State = RuntimeState.OnIdle;
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
State = RuntimeState.OnError;
|
throw new Exception() { };
|
}
|
finally
|
{
|
//HxResult ret = MethodAction.Instance.StatusLamp(7);
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
#endregion
|
|
#region 成像专用--拍照
|
/// <summary>
|
/// 拍照
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_TakePhoto(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
try
|
{
|
|
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【TakePhoto】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
string methodFileName = string.Empty;
|
bool isSimulator = false;
|
//查询出最后一条实验记录id
|
string experimentId = job["experiment_id"].ToString();
|
strParam = job["parameters"].ToString();
|
JObject jobParms = JObject.Parse(strParam);
|
methodFileName = jobParms["FlowName"].ToString();
|
isSimulator = jobParms["isSimulator"].ToString().ToLower() == "true" ? true : false;
|
|
|
string shortDir = ConfigurationManager.AppSettings["MethodFileBasePath"].ToString();
|
string fullName = shortDir + "\\" + methodFileName + ".xmed";
|
if (File.Exists(fullName))
|
{
|
XmlDocument xmlDocument = new XmlDocument();
|
//XmlDocument
|
xmlDocument.Load(fullName);
|
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
RunWnd runWnd = new RunWnd();
|
runWnd.xmlDocument = xmlDocument;
|
runWnd.mainWindow = (MainWindow)Application.Current.MainWindow;
|
runWnd.isRemotingOper = true;
|
runWnd.EnableSimulator = isSimulator;
|
|
TaskFactory taskFactory = new TaskFactory();
|
int iresult = runWnd.LoadLabwareOnRunningRemote();
|
|
if (iresult == 0)
|
{
|
State = RuntimeState.OnError;
|
result = JObject.Parse("{method_status:3}");
|
// errorHandle("10001", 7, "Execute was failed!Can't get any bacteria,please check algorithm on camera system.");
|
throw new Exception("Execute was failed!Can't get any bacteria,please check algorithm on camera system.");
|
}
|
else if (iresult == 1)
|
{
|
if (!string.IsNullOrEmpty(runWnd.captureData))
|
{
|
result = JObject.Parse(runWnd.captureData);
|
}
|
else
|
{
|
result = JObject.Parse("{method_status:2}");
|
//errorHandle("10001", 7, "Can't get any bacteria,please check algorithm on camera system.");
|
throw new Exception("Execute was failed!Can't get any bacteria,please check algorithm on camera system.");
|
}
|
}
|
else if (iresult == 2)
|
{
|
result = JObject.Parse("{method_status:4}");
|
}
|
}), DispatcherPriority.Send);
|
|
}
|
else
|
{
|
//弹出窗口提示所执行的方法不存在
|
}
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
State = RuntimeState.OnIdle;
|
}
|
return result;
|
}
|
#endregion
|
|
#region 抓板转移
|
/// <summary>
|
/// 运行抓板方法,抓耗材命令
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_MoveBoard(Object obj)
|
{
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
try
|
{
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【Method_MoveBoard】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
string methodFileName = string.Empty;
|
string strSrouceLatticeName = string.Empty;
|
string strTargetLatticeName = string.Empty;
|
int iGripperLabwarePos = 1;
|
int iSrcGripperLatticeDriector = 1;
|
int iTarGripperLatticeDriector = 1;
|
string iGripPickObject = "1";
|
bool isSimulator = false;
|
strParam = job["parameters"].ToString();
|
LoggerHelper.InfoLog("Start Method_MoveBoard");
|
|
JObject jobParms = JObject.Parse(strParam);
|
methodFileName = jobParms["MethodName"].ToString();
|
strSrouceLatticeName = jobParms["SrcPosition"].ToString();
|
strTargetLatticeName = jobParms["TarPosition"].ToString();
|
iSrcGripperLatticeDriector = Convert.ToInt32(jobParms["SrcGriperpos"].ToString());
|
iTarGripperLatticeDriector = Convert.ToInt32(jobParms["TarGriperpos"].ToString());
|
iGripperLabwarePos = Convert.ToInt32(jobParms["Boardpos"].ToString());
|
iGripPickObject = jobParms["BoardId"].ToString();
|
string shortDir = ConfigurationManager.AppSettings["MethodFileBasePath"].ToString();
|
isSimulator = jobParms["IsSimulator"].ToString().ToLower() == "true" ? true : false;
|
string fullName = shortDir + "\\" + methodFileName + ".xmed";
|
if (File.Exists(fullName))
|
{
|
XmlDocument xmlDocument = new XmlDocument();
|
//XmlDocument
|
xmlDocument.Load(fullName);
|
xmlDocument = deviceSimulator.UpdateGripMoveParamByxml(xmlDocument, jobParms);
|
App.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
RunWnd runWnd = new RunWnd();
|
runWnd.OnError += (p1, p2, p3, p4, p5) => { this.errorHandle(p1, p2, p3, p4, p5); };
|
runWnd.remoteObjectCmd = obj;
|
runWnd.xmlDocument = xmlDocument;
|
runWnd.mainWindow = (MainWindow)Application.Current.MainWindow;
|
runWnd.isRemotingOper = true;
|
runWnd.EnableSimulator = isSimulator;
|
SaveState(_filePath, 1, false);//存储暂停控制信号状态
|
int iresult = runWnd.LoadLabwareOnRunningRemote();
|
|
if (iresult == 0)
|
{
|
State = RuntimeState.OnError;
|
result = JObject.Parse("{method_status:3}");
|
errorHandle?.Invoke(obj, "EC-1041", 5, "程序运行中遇到错误（具体原因请查看日志），运行方法终止.", 2);
|
}
|
else if (iresult == 1)
|
{
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:2}");
|
}
|
else if (iresult == 2)
|
{
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:4}");
|
}
|
}));
|
|
}
|
else
|
{
|
//弹出窗口提示所执行的方法不存在
|
errorHandle?.Invoke(obj, "EC-1041", 5, "程序运行中遇到错误（具体原因请查看日志），运行方法终止.", 2);
|
}
|
|
State = RuntimeState.OnIdle;
|
LoggerHelper.InfoLog("end Method_MoveBoard");
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
State = RuntimeState.OnError;
|
throw new Exception() { };
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
RunWnd.IsRunning = false;
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
#endregion
|
|
#region 移液专用--移液参数
|
/// <summary>
|
/// 设置移液的数据
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_RunDataParam(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
JObject result = new JObject();
|
|
try
|
{
|
State = RuntimeState.OnBusy;
|
JObject Obj = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【RunDataParam】remote progress:get data: " + obj.ToString());
|
string objstr = Obj["parameters"].ToString();
|
Dictionary<string, object> strdata = JsonConvert.DeserializeObject<Dictionary<string, object>>(objstr);
|
|
string jsonURL = strdata["Method_Param_URL"].ToString();
|
LoggerRunHelper.InfoLog("remote jsonURL:" + jsonURL.ToString());
|
|
string jsonFilePath = ConfigurationManager.AppSettings["captureFilePath"].ToString() + "\\downJson";
|
LoggerRunHelper.InfoLog("remote jsonFilePath:" + jsonFilePath.ToString());
|
|
int fiMax = 1;
|
if (Directory.Exists(jsonFilePath))
|
{
|
// 获取目录下文件的最大名称值
|
string[] files = Directory.GetFiles(jsonFilePath);
|
foreach (string f in files)
|
{
|
string f1 = f.Split('.')[0];
|
int startIndex = f1.LastIndexOf('\\');
|
string namestr = f1.Substring(startIndex + 1, f1.Length - startIndex - 1);
|
int fileName = Convert.ToInt32(namestr);
|
if (fileName > fiMax)
|
{
|
fiMax = fileName;
|
}
|
}
|
}
|
else
|
{
|
Directory.CreateDirectory(jsonFilePath);
|
}
|
|
LoggerRunHelper.InfoLog("remote fiMax:" + fiMax.ToString());
|
|
using (WebClient client = new WebClient())
|
{
|
string fullJsonFileName = string.Empty;
|
if (Directory.Exists(jsonFilePath))
|
{
|
fullJsonFileName = jsonFilePath + "\\" + (fiMax + 1).ToString() + ".json";
|
if (File.Exists(fullJsonFileName))
|
{
|
File.Delete(fullJsonFileName);
|
}
|
LoggerRunHelper.InfoLog("remote fullJsonFileName:" + fullJsonFileName.ToString());
|
client.DownloadFile(jsonURL, fullJsonFileName);
|
}
|
string jsonText = File.ReadAllText(fullJsonFileName);
|
|
LoggerRunHelper.InfoLog("remote local jsonText:" + jsonText.ToString());
|
|
DataTable dt = new DataTable();
|
List<dynamic> strdata1 = JsonConvert.DeserializeObject<List<dynamic>>(jsonText);
|
|
#region 构建表结构
|
foreach (dynamic newObj in strdata1)
|
{
|
// 获取所有属性名称
|
var propertyNames = ((JObject)newObj).Properties();
|
|
// 属性名称
|
foreach (var propertyName in propertyNames)
|
{
|
dt.Columns.Add(propertyName.Name, typeof(string));
|
}
|
|
//var items =((JObject)newObj).Children();
|
//for(int i=0;i<items.;i++)
|
//{
|
|
// dt.Columns.Add("", typeof(string));
|
//}
|
//var newObjClazz = newObj.GetType();
|
//PropertyInfo[] fields = newObjClazz.GetProperties(BindingFlags.Public | BindingFlags.Instance);
|
//foreach (PropertyInfo field in fields)
|
//{
|
// dt.Columns.Add(field.Name, typeof(string));
|
//}
|
break;
|
}
|
#endregion
|
|
#region 构建表数据行
|
foreach (dynamic newObj in strdata1)
|
{
|
DataRow dr = dt.NewRow();
|
var propertyNames = ((JObject)newObj).Properties();
|
|
// 属性名称
|
foreach (var propertyName in propertyNames)
|
{
|
dr[propertyName.Name] = ((JObject)newObj)[propertyName.Name].ToString();
|
//dt.Columns.Add(((JObject)newObj)[propertyName.Name].ToString(), typeof(string));
|
}
|
//var newObjClazz = newObj.GetType();
|
//PropertyInfo[] fields = newObjClazz.GetProperties(BindingFlags.Public | BindingFlags.Instance);
|
//foreach (PropertyInfo field in fields)
|
//{
|
// Object newValue = field.GetValue(newObj);
|
// dr[field.Name] = newValue.ToString();
|
//}
|
dt.Rows.Add(dr);
|
}
|
#endregion
|
|
string filePath = strdata["SaveFilePath"].ToString();
|
|
string file = filePath;
|
|
string path = file.Substring(0, file.LastIndexOf('\\'));
|
if (!Directory.Exists(path))
|
{
|
Directory.CreateDirectory(path);
|
LoggerHelper.InfoLog("creat directory: " + path);
|
}
|
ExcelAndCsvHelper.WriteDataTableToCSV(dt, file);
|
bool bRet = true;
|
LoggerHelper.InfoLog("write file=" + file + ", return=" + bRet.ToString());
|
if (!bRet)
|
{
|
State = RuntimeState.OnError;
|
result = JObject.Parse("{method_status:3}");
|
throw new Exception("Execute was failed!");
|
}
|
else if (bRet)
|
{
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:2}");
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LoggerRunHelper.ErrorLog("remote error:" + ex.Message.ToString());
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
#endregion
|
|
#region 查询设备状态
|
public JObject Method_GetStatus(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
try
|
{
|
|
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【Method_GetStatus】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
string strType = string.Empty;
|
|
if (MethodAction.Instance != null)
|
{
|
if (!MethodAction.Instance.Connected)
|
{
|
HxResult ret = MethodAction.Instance.Connect();
|
if (ret.Result == ResultType.Success)
|
{
|
//State = RuntimeState.OnIdle;
|
//result = JObject.Parse("{method_status:2}");
|
}
|
else
|
{
|
string strDetail = string.Empty;
|
foreach(string content in ret.Details)
|
{
|
strDetail += content;
|
}
|
errorHandle?.Invoke(obj, "EC-1000", 5, "设备连接异常,详情："+strDetail, 2);
|
}
|
}
|
else
|
{
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{equipment_status:1}");
|
}
|
}
|
|
//State = RuntimeState.OnIdle;
|
//result = JObject.Parse("{method_status:2}");
|
|
LoggerHelper.InfoLog("end Method_GetStatus");
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
State = RuntimeState.OnError;
|
//throw new Exception() { };
|
errorHandle?.Invoke(obj, "EC-1000", 5, "设备连接异常,详情：" + ex.Message.ToString(), 2);
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
#endregion
|
|
#region 移动到安全位置
|
public JObject Method_MoveToSafePosition(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
try
|
{
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【Method_MoveToSafePosition】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
string strType = string.Empty;
|
string xAxisSafeVal = ConfigurationManager.AppSettings["xAxisSafeVal"].ToString();
|
string yAxisSafeVal = ConfigurationManager.AppSettings["yAxisSafeVal"].ToString();
|
|
if (MethodAction.Instance != null)
|
{
|
HxResult ret = MethodAction.Instance.Move((float)Convert.ToDouble(xAxisSafeVal), (float)Convert.ToDouble(yAxisSafeVal), Shared.GripperArmId);
|
if (ret.Result == ResultType.Success)
|
{
|
//State = RuntimeState.OnIdle;
|
//result = JObject.Parse("{method_status:2}");
|
}
|
else
|
{
|
string strDetail = string.Empty;
|
foreach (string content in ret.Details)
|
{
|
strDetail += content;
|
}
|
errorHandle?.Invoke(obj, "EC-1054", 5, "设备移动到安全位置异常,详情：" + strDetail, 2);
|
}
|
}
|
|
LoggerHelper.InfoLog("end Method_MoveToSafePosition");
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
State = RuntimeState.OnError;
|
//throw new Exception() { };
|
errorHandle?.Invoke(null, "EC-1054", 5, "设备移动到安全位置异常,详情：" + ex.Message.ToString(), 2);
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
#endregion
|
|
#region 查询工作站所有的应用方法
|
public JObject Method_GetAllMethod(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
result = JObject.Parse("{ methodname:\"\"" +
|
"}");
|
try
|
{
|
|
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【Method_GetAllMethod】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
string strType = string.Empty;
|
|
string basePath = System.AppDomain.CurrentDomain.BaseDirectory;
|
string runFolderPath = //basePath +
|
ConfigurationManager.AppSettings["MethodFileBasePath"].ToString();//方法所在目录
|
|
if (Directory.Exists(runFolderPath))
|
{
|
string[] runFileInfo = Directory.GetFiles(runFolderPath);
|
string methodNameCollection = string.Empty;
|
foreach (string file in runFileInfo)
|
{
|
string filename = file.Substring(file.LastIndexOf('\\') + 1, file.Length - file.LastIndexOf('\\')-1);
|
methodNameCollection += filename.Substring(0, filename.LastIndexOf('.')) + ",";
|
}
|
|
if (methodNameCollection != string.Empty)
|
{
|
methodNameCollection = methodNameCollection.Substring(0, methodNameCollection.Length - 1);
|
}
|
//byte[] utf8Bytes = Encoding.GetEncoding("utf8").GetString(methodNameCollection);
|
|
//string resultText = DecFileName(methodNameCollection);
|
|
string resultText = methodNameCollection;
|
result = JObject.Parse("{ methodname:\"" + resultText + "\"" +
|
"}");
|
}
|
|
State = RuntimeState.OnIdle;
|
|
LoggerHelper.InfoLog("end Method_GetAllMethod");
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
State = RuntimeState.OnError;
|
throw new Exception() { };
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
#endregion
|
|
public string DecFileName(string str)
|
{
|
Encoding utf8 = Encoding.GetEncoding("utf-8");
|
byte[] btArr = utf8.GetBytes(str);
|
return Encoding.UTF8.GetString(btArr);
|
}
|
|
#region 查询工作站所有的耗材信息
|
public JObject Method_GetAllLabware(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
result = JObject.Parse("{ labwareid:\"\"," +
|
"labwarename:\"\""+
|
"}");
|
try
|
{
|
|
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【Method_GetAllLabware】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
string strType = string.Empty;
|
|
ObservableCollection<Labware> labwares = LabwareDB.GetLabware(2);
|
string labwareIdCollection = string.Empty;
|
string labwareNameCollection = string.Empty;
|
foreach(Labware labware in labwares)
|
{
|
labwareIdCollection += labware.labware_id + ",";
|
labwareNameCollection += labware.labware_name + ",";
|
}
|
|
if(labwareIdCollection!=string.Empty)
|
{
|
labwareIdCollection= labwareIdCollection.Substring(0, labwareIdCollection.Length - 1);
|
labwareNameCollection = labwareNameCollection.Substring(0, labwareNameCollection.Length - 1);
|
result = JObject.Parse("{ labwareid:\"" + labwareIdCollection + "\"," +
|
"labwarename:\"" + labwareNameCollection + "\""+
|
"}");
|
}
|
State = RuntimeState.OnIdle;
|
|
LoggerHelper.InfoLog("end Method_GetAllLabware");
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
State = RuntimeState.OnError;
|
throw new Exception() { };
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
#endregion
|
|
/// <summary>
|
/// 设置移液的barcode数据
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_MoveLiquidTo96Params(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
JObject result = new JObject();
|
|
try
|
{
|
|
State = RuntimeState.OnBusy;
|
|
//DataTable dt = new DataTable();
|
//dt.Columns.Add("Id", typeof(string));
|
//dt.Columns.Add("SrcCode", typeof(string));
|
//dt.Columns.Add("TarCode", typeof(string));
|
DataTable dt = new DataTable();
|
dt.Columns.Add("CoatingDataId", typeof(string));
|
dt.Columns.Add("SourceA", typeof(string));
|
dt.Columns.Add("SourceBarcode", typeof(string));
|
dt.Columns.Add("SourceWell", typeof(string));
|
dt.Columns.Add("TargetB", typeof(string));
|
dt.Columns.Add("TargetBarcode", typeof(string));
|
dt.Columns.Add("TargetWell", typeof(string));
|
dt.Columns.Add("Volume", typeof(string));
|
|
JObject Obj = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【RunDataParam】remote progress:get data: " + obj.ToString());
|
string objstr = Obj["parameters"].ToString();
|
Dictionary<string, object> strdata = JsonConvert.DeserializeObject<Dictionary<string, object>>(objstr);
|
string jsonURL = strdata["Method_Coatingfile_Param"].ToString();
|
|
string jsonFilePath = ConfigurationManager.AppSettings["captureFilePath"].ToString() + "\\downJson";
|
|
int fiMax = 1;
|
if (Directory.Exists(jsonFilePath))
|
{
|
//获取目录下文件的最大名称值
|
string[] files = Directory.GetFiles(jsonFilePath);
|
foreach (string f in files)
|
{
|
string f1 = f.Split('.')[0];
|
int startIndex = f1.LastIndexOf('\\');
|
string namestr = f1.Substring(startIndex + 1, f1.Length - startIndex - 1);
|
int fileName = Convert.ToInt32(namestr);
|
if (fileName > fiMax)
|
{
|
fiMax = fileName;
|
}
|
}
|
}
|
else
|
{
|
Directory.CreateDirectory(jsonFilePath);
|
}
|
|
using (WebClient client = new WebClient())
|
{
|
string fullJsonFileName = string.Empty;
|
if (Directory.Exists(jsonFilePath))
|
{
|
fullJsonFileName = jsonFilePath + "\\" + (fiMax + 1).ToString() + ".json";
|
if (File.Exists(fullJsonFileName))
|
{
|
File.Delete(fullJsonFileName);
|
}
|
client.DownloadFile(jsonURL, fullJsonFileName);
|
}
|
string jsonText = File.ReadAllText(fullJsonFileName);
|
//JObject jsonObj = JObject.Parse(jsonText);
|
|
List<SetMoveLiquidData_param> strdata1 = JsonConvert.DeserializeObject<List<SetMoveLiquidData_param>>(jsonText);
|
//foreach (SetCoatingData_param sd in strdata1)
|
//{
|
// DataRow dr = dt.NewRow();
|
// int i = 0;
|
// dr["Id"] = sd.CoatingDataId.ToString();
|
// dr["SrcCode"] = sd.SourcePlateID.ToString();
|
// dr["TarCode"] = sd.SourcePlateBarcode.ToString();
|
// dt.Rows.Add(dr);
|
//}
|
foreach (SetMoveLiquidData_param sd in strdata1)
|
{
|
DataRow dr = dt.NewRow();
|
int i = 0;
|
dr["CoatingDataId"] = sd.CoatingDataId.ToString();
|
dr["SourceA"] = sd.SourceA.ToString();
|
dr["SourceBarcode"] = sd.SourceBarcode.ToString();
|
dr["SourceWell"] = sd.SourceWell.ToString();
|
|
dr["TargetB"] = sd.TargetB.ToString();
|
dr["TargetBarcode"] = sd.TargetBarcode.ToString();
|
dr["TargetWell"] = sd.TargetWell.ToString();
|
dr["Volume"] = sd.Volume.ToString();
|
//dr["changetips"] = sd.changetips.ToString();
|
dt.Rows.Add(dr);
|
}
|
string filePath = strdata["PickAndCoatTable"].ToString();
|
|
string file = filePath;
|
|
string path = file.Substring(0, file.LastIndexOf('\\'));
|
if (!Directory.Exists(path))
|
{
|
Directory.CreateDirectory(path);
|
LoggerHelper.InfoLog("creat directory: " + path);
|
}
|
ExcelAndCsvHelper.WriteDataTableToCSV(dt, file);
|
bool bRet = true;
|
LoggerHelper.InfoLog("write file=" + file + ", return=" + bRet.ToString());
|
if (!bRet)
|
{
|
State = RuntimeState.OnError;
|
result = JObject.Parse("{method_status:3}");
|
throw new Exception("Execute was failed!");
|
}
|
else if (bRet)
|
{
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:2}");
|
}
|
}
|
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
|
return result;
|
}
|
|
private void DownloadFileForMoveLiquid(string jsonURL,string terminalPath)
|
{
|
string jsonFilePath = ConfigurationManager.AppSettings["captureFilePath"].ToString() + "\\downJson";
|
LoggerRunHelper.InfoLog("remote jsonFilePath:" + jsonFilePath.ToString());
|
|
int fiMax = 1;
|
if (Directory.Exists(jsonFilePath))
|
{
|
// 获取目录下文件的最大名称值
|
string[] files = Directory.GetFiles(jsonFilePath);
|
foreach (string f in files)
|
{
|
string f1 = f.Split('.')[0];
|
int startIndex = f1.LastIndexOf('\\');
|
string namestr = f1.Substring(startIndex + 1, f1.Length - startIndex - 1);
|
int fileName = Convert.ToInt32(namestr);
|
if (fileName > fiMax)
|
{
|
fiMax = fileName;
|
}
|
}
|
}
|
else
|
{
|
Directory.CreateDirectory(jsonFilePath);
|
}
|
|
LoggerRunHelper.InfoLog("remote fiMax:" + fiMax.ToString());
|
|
using (WebClient client = new WebClient())
|
{
|
client.Encoding = Encoding.UTF8; // 设置编码格式为UTF-8
|
string fullJsonFileName = string.Empty;
|
if (Directory.Exists(jsonFilePath))
|
{
|
fullJsonFileName = jsonFilePath + "\\" + (fiMax + 1).ToString() + ".json";
|
if (File.Exists(fullJsonFileName))
|
{
|
File.Delete(fullJsonFileName);
|
}
|
LoggerRunHelper.InfoLog("remote fullJsonFileName:" + fullJsonFileName.ToString());
|
client.DownloadFile(jsonURL, fullJsonFileName);
|
}
|
string jsonText = File.ReadAllText(fullJsonFileName);
|
|
LoggerRunHelper.InfoLog("remote local jsonText:" + jsonText.ToString());
|
|
DataTable dt = new DataTable();
|
List<dynamic> strdata1 = JsonConvert.DeserializeObject<List<dynamic>>(jsonText);
|
|
#region 构建表结构
|
foreach (dynamic newObj in strdata1)
|
{
|
// 获取所有属性名称
|
var propertyNames = ((JObject)newObj).Properties();
|
|
// 属性名称
|
foreach (var propertyName in propertyNames)
|
{
|
dt.Columns.Add(propertyName.Name, typeof(string));
|
}
|
break;
|
}
|
#endregion
|
|
#region 构建表数据行
|
foreach (dynamic newObj in strdata1)
|
{
|
DataRow dr = dt.NewRow();
|
var propertyNames = ((JObject)newObj).Properties();
|
|
// 属性名称
|
foreach (var propertyName in propertyNames)
|
{
|
dr[propertyName.Name] = ((JObject)newObj)[propertyName.Name].ToString();
|
}
|
dt.Rows.Add(dr);
|
}
|
#endregion
|
|
string filePath = terminalPath;
|
|
string file = filePath;
|
|
string path = file.Substring(0, file.LastIndexOf('\\'));
|
if (!Directory.Exists(path))
|
{
|
Directory.CreateDirectory(path);
|
LoggerHelper.InfoLog("creat directory: " + path);
|
}
|
ExcelAndCsvHelper.WriteDataTableToCSV(dt, file);
|
bool bRet = true;
|
LoggerHelper.InfoLog("write file=" + file + ", return=" + bRet.ToString());
|
}
|
}
|
|
/// <summary>
|
/// 运行移液方法
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_RunMoveLiquid(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
try
|
{
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【Method_RunMoveLiquid】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
string methodFileName = string.Empty;
|
string strParam2 = string.Empty;
|
bool isSimulator = false;
|
string experimentrunid = job["experiment_id"].ToString();
|
strParam = job["parameters"].ToString();
|
|
JObject jobParms = JObject.Parse(strParam);
|
methodFileName = jobParms["MethodName"].ToString();
|
string jsonURL = "";// jobParms["Method_Param_URL"].ToString();
|
//strParam2 = jobParms["FilePath"].ToString();
|
isSimulator = jobParms["IsSimulator"].ToString().ToLower() == "true" ? true : false;
|
|
string shortDir = ConfigurationManager.AppSettings["MethodFileBasePath"].ToString();
|
string fullName = shortDir + "\\" + methodFileName + ".xmed";
|
if (File.Exists(fullName))
|
{
|
XmlDocument xmlDocument = new XmlDocument();
|
xmlDocument.Load(fullName);
|
|
MethodListBll methodListBll = new MethodListBll();
|
XmlNodeList xmlNodeMethodList = xmlDocument.SelectNodes("root/method[@id>=3]");
|
for (int n = 0; n < xmlNodeMethodList.Count; n++)
|
{
|
string MethodName = xmlNodeMethodList[n].SelectSingleNode("name").InnerText;
|
int iNum = methodListBll.getNumByMethodName(MethodName);
|
switch (iNum)
|
{
|
//case (int)MethodNameEnum.VariableImport:
|
// if (xmlNodeMethodList[n].SelectSingleNode("status").InnerText == "enable")
|
// {
|
// DownloadFileForMoveLiquid(jsonURL, xmlNodeMethodList[n].SelectSingleNode("filePath").InnerText);
|
// //xmlNodeMethodList[n].SelectSingleNode("filePath").InnerText = strParam2;
|
// strParam2 = xmlNodeMethodList[n].SelectSingleNode("filePath").InnerText;
|
// }
|
// break;
|
case (int)MethodNameEnum.transferfile:
|
if (xmlNodeMethodList[n].SelectSingleNode("status").InnerText == "enable")
|
{
|
//DownloadFileForMoveLiquid(jsonURL, xmlNodeMethodList[n].SelectSingleNode("filePath").InnerText);
|
//xmlNodeMethodList[n].SelectSingleNode("filePath").InnerText = strParam2;
|
strParam2 = xmlNodeMethodList[n].SelectSingleNode("filePath").InnerText;
|
}
|
break;
|
case (int)MethodNameEnum.coatingfile:
|
if (xmlNodeMethodList[n].SelectSingleNode("status").InnerText == "enable")
|
{
|
//xmlNodeMethodList[n].SelectSingleNode("filePath").InnerText = strParam2;
|
DownloadFileForMoveLiquid(jsonURL, xmlNodeMethodList[n].SelectSingleNode("filePath").InnerText);
|
strParam2 = xmlNodeMethodList[n].SelectSingleNode("filePath").InnerText;
|
}
|
break;
|
default:
|
break;
|
}
|
}
|
|
App.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
RunWnd runWnd = new RunWnd();
|
runWnd.xmlDocument = xmlDocument;
|
runWnd.isRemotingOper = true;
|
runWnd.EnableSimulator = isSimulator;
|
runWnd.remoteObjectCmd = obj;
|
runWnd.OnError += (p1, p2, p3, p4, p5) => { this.errorHandle(p1, p2, p3, p4, p5); };
|
//从文件中读取已经使用的Tip信息
|
RunWnd.currentIsUsedWellLattice = runWnd.GetUsedTipFromXML();
|
runWnd.currentExperimentRunLog.experimentrunid = experimentrunid;
|
TaskFactory taskFactory = new TaskFactory();
|
SaveState(_filePath, 1, false);//存储暂停控制信号状态
|
int iresult = runWnd.LoadLabwareOnRunningRemote();
|
|
if (iresult == 0)
|
{
|
State = RuntimeState.OnError;
|
result = JObject.Parse("{method_status:3}");
|
throw new Exception("EC-1041 程序运行中遇到错误（具体原因请查看日志），运行方法终止!");
|
}
|
else if (iresult == 1)
|
{
|
State = RuntimeState.OnIdle;
|
var dt = DateTime.Now.ToString("yyyy-MM-dd-hh-mm-ss");
|
string fileNameStr = dt + ".json";
|
string folder = "UploadFolder";
|
string uploadPath = AppDomain.CurrentDomain.BaseDirectory + folder;
|
string pathStrJson = uploadPath + "\\" + fileNameStr;
|
string ip = HttpServer.GetLocalIP();
|
string port = ConfigurationManager.AppSettings["socketURLPort"].ToString();
|
string server = $"http://{ip}:{port}/UploadFolder/";
|
string strResultJson = runWnd.GenerateMoveLiquidReport(strParam2);
|
HttpServer.CreateFileContent(pathStrJson, strResultJson);
|
//string fullPath = HttpServer.Init(HttpServer.GetLocalIP(), "8081", fileNameStr, runWnd.GenerateCoatingReport());
|
//string fullPathImg = HttpServer.Init(HttpServer.GetLocalIP(), "8081", fileNameImg, "");
|
result = JObject.Parse("{json:\"" + server + fileNameStr + "\"" +
|
"}");
|
}
|
else if (iresult == 2)
|
{
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:2}");
|
}
|
}));
|
}
|
else
|
{
|
throw new Exception("EC-1041 程序运行中遇到错误（具体原因请查看日志），运行方法终止!");
|
}
|
|
State = RuntimeState.OnIdle;
|
LoggerHelper.InfoLog("end Method_RunMoveLiquid");
|
}
|
catch (Exception ex)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
State = RuntimeState.OnError;
|
throw ex;
|
}
|
finally
|
{
|
//HxResult ret = MethodAction.Instance.StatusLamp(7);
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
|
bool isRunningOfSwitch = false;
|
/// <summary>
|
/// 开关灯、等
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_TurnOnOFF(Object obj)
|
{
|
JObject result = new JObject();
|
if (isRunningOfSwitch)
|
{
|
State = RuntimeState.OnBusy;
|
return result;
|
}
|
isRunningOfSwitch = true;
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
|
try
|
{
|
|
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【Method_TurnOnOFF】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
string equipname = string.Empty;
|
string equipstate = string.Empty;
|
strParam = job["parameters"].ToString();
|
JObject jobParms = JObject.Parse(strParam);
|
equipname = jobParms["EquipName"].ToString();
|
equipstate = jobParms["EquipState"].ToString();
|
bool isSimulator = jobParms["IsSimulator"].ToString().ToLower() == "true" ? true : false;
|
|
HxResult ret = new HxResult();
|
string strType = string.Empty;
|
if (equipstate == "0")
|
{
|
strType = "关闭";
|
}
|
else if (equipstate == "1")
|
{
|
strType = "开启";
|
}
|
if (isSimulator)
|
{
|
LoggerRunHelper.InfoLog(equipname + "已开启");
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:4}");
|
LoggerHelper.InfoLog("end Method_TurnOnOFF");
|
|
}
|
else
|
{
|
switch (equipname)
|
{
|
case "UV":
|
ret = MethodAction.Instance.SterilizingLamp(Convert.ToInt32(equipstate));
|
break;
|
case "FFU":
|
ret = MethodAction.Instance.FFU(Convert.ToInt32(equipstate));
|
break;
|
case "LED":
|
ret = MethodAction.Instance.Floodlight(Convert.ToInt32(equipstate));
|
break;
|
}
|
|
if (ret.Result == ResultType.Success)
|
{
|
LoggerRunHelper.InfoLog(equipname + "已开启");
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:4}");
|
}
|
else if (ret.Result == ResultType.FailQ)
|
{
|
LoggerRunHelper.InfoLog("开启HEPA动作终止！");
|
throw new Exception("EC-1041 程序运行中遇到错误（具体原因请查看日志），运行方法终止!");
|
}
|
else if (ret.Result == ResultType.Fail)
|
{
|
LoggerRunHelper.InfoLog(strType + equipname + "失败，信息：" + ret.AlarmInfo.ToString());
|
State = RuntimeState.OnError;
|
result = JObject.Parse("{method_status:3}");
|
throw new Exception("EC-1041 程序运行中遇到错误（具体原因请查看日志），运行方法终止!");
|
//throw new Exception(strType + equipname + "失败，信息：" + ret.AlarmInfo.ToString());
|
//errorHandle?.Invoke(obj, "EC-1041", 5, "程序运行中遇到错误（具体原因请查看日志），运行方法终止.", 2);
|
}
|
|
State = RuntimeState.OnIdle;
|
LoggerHelper.InfoLog("end Method_TurnOnOFF");
|
}
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
throw ex;
|
}
|
finally
|
{
|
isRunningOfSwitch = false;
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
|
/// <summary>
|
/// 夹爪回零
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_GriperZero(Object obj)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Hidden;
|
a.remoteGrid.Visibility = Visibility.Visible;
|
}
|
}));
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
try
|
{
|
|
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【GriperZero】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
|
HxResult ret = new HxResult();
|
string strType = string.Empty;
|
|
ret = MethodAction.Instance.HomeZ(7);
|
|
if (ret.Result == ResultType.Success)
|
{
|
LoggerRunHelper.InfoLog("夹爪已回零");
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:4}");
|
}
|
else if (ret.Result == ResultType.FailQ)
|
{
|
LoggerRunHelper.InfoLog("开启HEPA动作终止！");
|
}
|
else if (ret.Result == ResultType.Fail)
|
{
|
LoggerRunHelper.InfoLog("夹爪回零失败，信息：" + ret.AlarmInfo.ToString());
|
State = RuntimeState.OnError;
|
result = JObject.Parse("{method_status:3}");
|
throw new Exception("夹爪回零失败，信息：" + ret.AlarmInfo.ToString());
|
}
|
|
State = RuntimeState.OnIdle;
|
}
|
catch (Exception ex)
|
{
|
LoggerHelper.ErrorLog("ERROR:", ex);
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
throw ex;
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
}
|
return result;
|
}
|
|
#region 运行时暂停/继续/停止
|
/// <summary>
|
/// 运行时暂停/继续/停止
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_PauseStopContinue(Object obj)
|
{
|
JObject result = new JObject();
|
try
|
{
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【PauseStopContinue】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
int equipstate = 0;
|
strParam = job["parameters"].ToString();
|
JObject jobParms = JObject.Parse(strParam);
|
equipstate = Convert.ToInt32(jobParms["RequestState"].ToString());
|
|
if (equipstate == -1)//停止
|
{
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【PauseStopContinue】remote progress:stop");
|
|
//把请求取消的请求放入文件中保存，在运行的函数中启动线程定时器进行实时监控，监控要取消，即可调用取消请求即可。
|
SaveState(_isStopFilePath, 2, true);
|
|
HxResult ret = MethodAction.Instance.StatusLamp(7);
|
Task.Factory.StartNew(() => MethodAction.Instance.Interrupt(3, true));
|
App.Current.Dispatcher.Invoke(DispatcherPriority.Send, new Action(() =>
|
{
|
RunWnd runWnd = new RunWnd();
|
runWnd.AddLogs("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】> Xhandler:实验停止指令已发出!!");
|
LoggerRunHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】> Xhandler:实验停止指令已发出!!");
|
}));
|
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:4}");
|
}
|
else if (equipstate == 1)//暂停
|
{
|
LoadState(_filePath, 1);
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【PauseStopContinue】remote progress:pause");
|
_manualResetEvent.Reset();
|
SaveState(_filePath, 1, false);
|
HxResult ret = MethodAction.Instance.StatusLamp(5);
|
Task.Factory.StartNew(() => MethodAction.Instance.Interrupt(1, true));
|
|
App.Current.Dispatcher.Invoke(DispatcherPriority.Send, new Action(() =>
|
{
|
RunWnd runWnd = new RunWnd();
|
runWnd.AddLogs("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】> Xhandler:实验暂停指令已发出!!");
|
LoggerRunHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】> Xhandler:实验暂停指令已发出!!");
|
}));
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:4}");
|
}
|
else if (equipstate == 0)//继续
|
{
|
LoadState(_filePath, 1);
|
_manualResetEvent.Set();
|
SaveState(_filePath, 1, false);
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【PauseStopContinue】remote progress:continue");
|
|
HxResult ret = MethodAction.Instance.StatusLamp(4);
|
MethodAction.Instance.Interrupt(2);
|
App.Current.Dispatcher.Invoke(DispatcherPriority.Send, new Action(() =>
|
{
|
RunWnd runWnd = new RunWnd();
|
runWnd.AddLogs("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】> Xhandler:实验继续指令已发出!!");
|
LoggerRunHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】> Xhandler:实验继续指令已发出!!");
|
}));
|
|
State = RuntimeState.OnIdle;
|
result = JObject.Parse("{method_status:4}");
|
}
|
|
State = RuntimeState.OnIdle;
|
}
|
catch (Exception ex)
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
throw ex;
|
}
|
finally
|
{
|
Application.Current.Dispatcher.Invoke(new Action(() =>
|
{
|
var a = (MainWindow)Application.Current.MainWindow;
|
if (a != null)
|
{
|
a.rootGrid.Visibility = Visibility.Visible;
|
a.remoteGrid.Visibility = Visibility.Hidden;
|
}
|
}));
|
State = RuntimeState.OnIdle;
|
}
|
return result;
|
}
|
#endregion
|
|
#region 消除对话框
|
/// <summary>
|
/// 消除对话框
|
/// </summary>
|
/// <param name="obj"></param>
|
/// <returns></returns>
|
public JObject Method_ClearPopWin(Object obj)
|
{
|
State = RuntimeState.OnBusy;
|
JObject result = new JObject();
|
try
|
{
|
JObject job = obj as JObject;
|
LoggerHelper.InfoLog("【" + DateTime.Now.ToString("HH:mm:ss:fff") + "】>Xhandler: 【ClearPopwin】remote progress:get data: " + obj.ToString());
|
string strParam = string.Empty;
|
int dialogstate = 0;
|
strParam = job["parameters"].ToString();
|
JObject jobParms = JObject.Parse(strParam);
|
dialogstate = Convert.ToInt32(jobParms["dialogstate"].ToString());
|
|
if(dialogstate==1)//跳过
|
{
|
((MainWindow)((Window)Shared.Main)).remoteMark = 1;
|
}
|
else if(dialogstate==2)//重试
|
{
|
((MainWindow)((Window)Shared.Main)).remoteMark = 2;
|
}
|
else if (dialogstate == 3)//终止
|
{
|
((MainWindow)((Window)Shared.Main)).remoteMark = 3;
|
}
|
else if (dialogstate == 4)//确认继续
|
{
|
((MainWindow)((Window)Shared.Main)).remoteMark = 4;
|
}
|
State = RuntimeState.OnIdle;
|
}
|
catch (Exception ex)
|
{
|
|
}
|
return result;
|
}
|
#endregion
|
|
#region 序列化ManualResetEvent对象
|
ManualResetEvent _manualResetEvent = new ManualResetEvent(false);
|
CancellationTokenSource _cancelSource = new CancellationTokenSource();
|
static string basePath = System.AppDomain.CurrentDomain.BaseDirectory;
|
public string _filePath = basePath + @"Run\ManualResetEventState.bin";
|
public string _isStopFilePath = basePath + @"Run\isStop.bin";
|
public string _pauseStateFilePath = basePath + @"Run\pauseState.bin";
|
private bool isStop = true;
|
private int pauseState = 0;//0：正常；1：暂停
|
/// <summary>
|
/// 序列化对象状态存入BIN文件
|
/// </summary>
|
/// <param name="category">1:ManualResetEvent对象;2:isStop;3:pauseState;</param>
|
/// <param name="state">true;false</param>
|
/// <param name="pauseState">0未暂停；1暂停</param>
|
public void SaveState(string filePath, int category, bool state, int pauseState = 0)
|
{
|
if (File.Exists(filePath))
|
{
|
File.Delete(filePath);
|
}
|
|
string dirPath = filePath.Substring(0, filePath.LastIndexOf('\\'));
|
if(!Directory.Exists(dirPath))
|
{
|
Directory.CreateDirectory(dirPath);
|
}
|
|
// 创建文件流，并使用二进制格式化器进行序列化
|
using (var fileStream = new FileStream(filePath, FileMode.Create))
|
{
|
var formatter = new BinaryFormatter();
|
if (category.Equals(1))
|
{
|
formatter.Serialize(fileStream, _manualResetEvent.WaitOne(0));
|
}
|
else if (category.Equals(2))
|
{
|
isStop = Convert.ToBoolean(isStop);
|
formatter.Serialize(fileStream, isStop);
|
}
|
else if (category.Equals(3))
|
{
|
pauseState = Convert.ToInt32(pauseState);
|
formatter.Serialize(fileStream, pauseState);
|
}
|
fileStream.Close();
|
}
|
|
}
|
#endregion
|
|
#region 反序列化ManualResetEvent对象
|
/// <summary>
|
/// 反序列化ManualResetEvent对象
|
/// </summary>
|
/// <param name="category">1:ManualResetEvent对象;2:isStop;3:pauseState;</param>
|
public void LoadState(string filePath, int category)
|
{
|
// 如果文件存在，则反序列化并设置ManualResetEvent的状态
|
if (File.Exists(filePath))
|
{
|
using (var fileStream = new FileStream(filePath, FileMode.Open))
|
{
|
var formatter = new BinaryFormatter();
|
|
if (category.Equals(1))
|
{
|
var isSet = (bool)formatter.Deserialize(fileStream);
|
_manualResetEvent = new ManualResetEvent(isSet);
|
}
|
else if (category.Equals(2))
|
{
|
var isSet = formatter.Deserialize(fileStream);
|
isStop = Convert.ToBoolean(isSet);
|
}
|
else if (category.Equals(3))
|
{
|
var isSet = formatter.Deserialize(fileStream);
|
pauseState = Convert.ToInt32(isSet);
|
}
|
fileStream.Close();
|
}
|
}
|
}
|
#endregion
|
|
#region 接口中的3个方法
|
public void ReplyAbort()
|
{
|
|
}
|
public void ReplyRetry()
|
{
|
|
}
|
public void ReplyIgnore()
|
{
|
|
}
|
#endregion
|
|
public void Dispose(string methodName)
|
{
|
if (errorHandle == null)
|
return;
|
var list = errorHandle.GetInvocationList();
|
foreach (Delegate del in list)
|
{
|
TaskInstruction taskInstruction = del.Target as TaskInstruction;
|
if (taskInstruction.InsName == methodName)
|
{
|
object delObj = del.GetType().GetProperty("Method").GetValue(del, null);
|
string funcName = (string)delObj.GetType().GetProperty("Name").GetValue(delObj, null);
|
Console.WriteLine(funcName);
|
errorHandle -= del as ErrorHandleDelegate;
|
}
|
}
|
}
|
}
|
}
|
