using System;
|
using System.Collections.Generic;
|
using System.Drawing.Text;
|
using System.Linq;
|
using System.Net;
|
using System.Text;
|
using System.Net.Sockets;
|
using System.Threading;
|
using System.Windows.Forms.VisualStyles;
|
using HalconDotNet;
|
using System.Data;
|
using System.Data.SqlClient;
|
|
using DownloadDLL;
|
using System.Reflection;
|
|
namespace M423project
|
{
|
|
|
//数据上传
|
public class DetectionDataUpload
|
{
|
#region 数据上传相关私有成员
|
private DetectionData detectionData;
|
private Thread uploadDataProcesser = null;
|
//private RunCard runCard;
|
private ConfigStruct config;
|
#endregion
|
/// <summary>
|
/// 上料检类构造函数
|
/// </summary>
|
|
public DetectionDataUpload(DetectionData _detectionData, ConfigStruct _config)
|
{
|
detectionData = _detectionData;
|
config = _config;
|
//runCard = new RunCard();
|
}
|
|
/// <summary>
|
/// 启动检测线程
|
/// </summary>
|
public void Start()
|
{
|
if (uploadDataProcesser == null)
|
{
|
uploadDataProcesser = new Thread(Execute);
|
uploadDataProcesser.IsBackground = true;
|
uploadDataProcesser.Start();
|
}
|
}
|
|
public void Stop()
|
{
|
//if (uploadDataProcesser != null && uploadDataProcesser.IsAlive)
|
//{
|
// uploadDataProcesser.Abort();
|
// uploadDataProcesser.Join();
|
//}
|
//uploadDataProcesser = null;
|
}
|
|
//static object uploadLock = new object();
|
public void UploadData()
|
{
|
lock (CommonUtil.UploadDataLock)
|
{
|
if (!CommonUtil.UploadDataEnable)
|
return;
|
|
DataTable dtUpload = detectionData.QueryUnloadData();
|
if (dtUpload.Rows.Count <= 0)
|
return;
|
|
if (dtUpload.Rows.Count < 20)
|
{
|
Thread.Sleep(2000);
|
dtUpload = detectionData.QueryUnloadData();
|
}
|
|
CommonUtil.UploadDoneHandle.Reset();
|
|
// Type runCardClass = asm.GetType("AutoRunCard.RunCard");
|
// object runCardObj = Activator.CreateInstance(runCardClass);
|
|
// MethodInfo mi = runCardClass.GetMethod("Data_Collection_Auto", new Type[] {
|
//typeof(System.String), typeof(System.String), typeof(System.DateTime), typeof(System.String), typeof(System.String), typeof(System.String),
|
//typeof(System.String), typeof(System.String), typeof(System.String), typeof(System.String), typeof(System.String), typeof(System.String[]),
|
//typeof(System.String).MakeByRefType()});
|
|
|
CommonUtil.WriteLog(LogType.Inf, string.Format("开始上传检测记录..."));
|
string productNo, productStatus, LengthStatus, WidthStatus, HeightStatus, BarcodeStatus, testResult;
|
double productLength = 0.0, productWidth = 0.0, productHeight = 0.0;
|
DateTime detectTime;
|
int plateID, uploadCount = 0;
|
string retStr = string.Empty;
|
string[] arryParams = new string[4];
|
string autoidList = string.Empty;
|
int autoID = 0;
|
string carrierBarcode = "";
|
int isSample = 0;
|
|
foreach (DataRow dr in dtUpload.Rows)
|
{
|
isSample = dr.IsNull("IsSample") ? 0 : (int)dr["IsSample"];
|
autoID = dr.IsNull("AutoID") ? 0 : (int)dr["AutoID"];
|
plateID = dr.IsNull("PlateID") ? 0 : (int)dr["PlateID"];
|
productNo = dr.IsNull("ProductNo") ? "" : (string)dr["ProductNo"];
|
detectTime = dr.IsNull("DetectTime") ? DateTime.Now : (DateTime)dr["DetectTime"];
|
//
|
productStatus = dr.IsNull("ProductStatus") ? "NG" : (string)dr["ProductStatus"];
|
LengthStatus = dr.IsNull("ProductLengthStatus") ? "NG" : (string)dr["ProductLengthStatus"];
|
WidthStatus = dr.IsNull("ProductWidthStatus") ? "NG" : (string)dr["ProductWidthStatus"];
|
HeightStatus = dr.IsNull("ProductHeightStatus") ? "NG" : (string)dr["ProductHeightStatus"];
|
BarcodeStatus = dr.IsNull("ProductNoStatus") ? "NG" : (string)dr["ProductNoStatus"];
|
carrierBarcode = dr.IsNull("CarrierBarcode") ? "NA" : (string)dr["CarrierBarcode"];
|
|
testResult = "";
|
if (productStatus != "OK")
|
{
|
if (BarcodeStatus != "OK")
|
testResult += "Barcode-NG,";
|
if (LengthStatus != "OK")
|
testResult += "X-NG,";
|
if (WidthStatus != "OK")
|
testResult += "Y-NG,";
|
if (HeightStatus != "OK")
|
testResult += "Z-NG,";
|
|
if (testResult != "")
|
testResult = testResult.Substring(0, testResult.Length - 1);
|
}
|
|
//
|
productLength = dr.IsNull("ProductLength") ? 0.0 : (double)dr["ProductLength"];
|
productWidth = dr.IsNull("ProductWidth") ? 0.0 : (double)dr["ProductWidth"];
|
productHeight = dr.IsNull("ProductHeight") ? 0.0 : (double)dr["ProductHeight"];
|
|
//第一个参数设置为抽检标志
|
arryParams[0] = isSample.ToString();
|
arryParams[1] = productLength.ToString();
|
arryParams[2] = productWidth.ToString();
|
arryParams[3] = productHeight.ToString();
|
object[] paramArr = new object[] { "DA06", "APMT", detectTime, testResult, plateID.ToString(), productStatus, carrierBarcode, productNo, productNo, "", "", arryParams, retStr };
|
try
|
{
|
if ((bool)mi.Invoke(runCardObj, paramArr))
|
{
|
CommonUtil.WriteLog(LogType.Err, string.Format("数据上传成功：{0}；TestResult为：{1}", productNo, string.IsNullOrEmpty(testResult) ? "OK" : testResult));
|
autoidList += autoID.ToString() + ",";
|
uploadCount++;
|
}
|
else
|
{
|
CommonUtil.WriteLog(LogType.Err, string.Format("数据上传失败：{0}；TestResult为：{1}；原因：{2}", productNo, string.IsNullOrEmpty(testResult) ? "OK" : testResult, (string)paramArr[12]));
|
autoidList += autoID.ToString() + ",";
|
Thread.Sleep(50);
|
}
|
Thread.Sleep(20);
|
}
|
catch (Exception e)
|
{
|
autoidList += autoID.ToString() + ",";
|
CommonUtil.WriteLog(LogType.Inf, string.Format("处理数据上传过程中发生异常：{0}", e.Message + " 条码号：" + productNo));
|
continue;
|
}
|
|
int n = detectionData.SetUploadDataStatus(autoID.ToString());
|
CommonUtil.WriteLog(LogType.Inf, string.Format("已标记成功上传检测记录：{0}笔", n));
|
|
}
|
//if (autoidList != "")
|
//{
|
// int n = detectionData.SetUploadDataStatus(autoidList);
|
// CommonUtil.WriteLog(LogType.Inf, string.Format("已标记成功上传检测记录：{0}笔", n));
|
//}
|
|
CommonUtil.WriteLog(LogType.Inf, string.Format("检测记录上传结束,共有{0}笔待上传数据，成功上传{1}笔", dtUpload.Rows.Count, uploadCount));
|
CommonUtil.UploadDoneHandle.Set();
|
}
|
}
|
|
public void DownLoadDll()
|
{
|
try
|
{
|
string strErrorMessage;
|
Sync sync = new Sync();
|
if (sync.SyncDll(out strErrorMessage) == false)
|
{
|
CommonUtil.WriteLog(LogType.Inf, string.Format("下载程序集返回错误信息：{0}", strErrorMessage));
|
}
|
else
|
{
|
CommonUtil.WriteLog(LogType.Inf, string.Format("已完成dll下载"));
|
}
|
}
|
catch (Exception e)
|
{
|
CommonUtil.WriteLog(LogType.Inf, string.Format("下载程序集出现异常：{0}", e.Message));
|
}
|
}
|
|
public Assembly LoadAutoRunCardAssemble()
|
{
|
|
Assembly asm = null;
|
try
|
{
|
asm = Assembly.LoadFile(@"C:\MES_API\AutoRunCard.dll");
|
return asm;
|
}
|
catch (Exception e)
|
{
|
CommonUtil.WriteLog(LogType.Inf, string.Format("加载程序集AutoRunCard.dll出现异常：{0}", e.Message));
|
return null;
|
}
|
}
|
|
Assembly asm = null;
|
object runCardObj = null;
|
MethodInfo mi = null;
|
|
public void Execute()
|
{
|
//Assembly asm = null;
|
try
|
{
|
DownLoadDll();
|
|
asm = LoadAutoRunCardAssemble();
|
if (asm == null)
|
return;
|
|
Type runCardClass = asm.GetType("AutoRunCard.RunCard");
|
runCardObj = Activator.CreateInstance(runCardClass);
|
|
mi = runCardClass.GetMethod("Data_Collection_Auto", new Type[] {
|
typeof(System.String), typeof(System.String), typeof(System.DateTime), typeof(System.String), typeof(System.String), typeof(System.String),
|
typeof(System.String), typeof(System.String), typeof(System.String), typeof(System.String), typeof(System.String), typeof(System.String[]),
|
typeof(System.String).MakeByRefType()});
|
|
int times = 1200 * 5;
|
while (uploadDataProcesser.IsAlive)
|
{
|
//if (!CommonUtil.UploadDataEnable)
|
//{
|
// Thread.Sleep(20);
|
// continue;
|
//}
|
|
//UploadData(asm);
|
UploadData();
|
|
while (times > 0 && uploadDataProcesser.IsAlive)
|
{
|
Thread.Sleep(10);
|
times--;
|
}
|
times = 1200 * 5;
|
}
|
|
}
|
catch (ThreadAbortException)
|
{
|
;
|
}
|
catch (Exception e)
|
{
|
CommonUtil.WriteLog(LogType.Exc, string.Format("上传数据过程发生异常：{0}", e.Message));
|
Thread.Sleep(100);
|
}
|
finally
|
{
|
|
}
|
|
}
|
}
|
}
|
