HM-CN\zhengxuan.zhang
3202 lines
153 KiB
C#
3202 lines
153 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.ComponentModel;
|
||
using System.Data;
|
||
using System.Drawing;
|
||
using System.Text;
|
||
using System.Windows.Forms;
|
||
using System.Text.RegularExpressions;
|
||
using System.Collections;
|
||
using System.IO;
|
||
using System.Xml;
|
||
using BaseFunction;
|
||
using Telerik.WinControls.UI;
|
||
using Telerik.WinControls;
|
||
using System.Linq;
|
||
using System.Windows.Forms.DataVisualization.Charting;
|
||
using NSAnalysis.Properties;
|
||
using static Telerik.WinControls.UI.ValueMapper;
|
||
using PLCModule;
|
||
using HslCommunication.Profinet.Siemens;
|
||
using static System.Windows.Forms.VisualStyles.VisualStyleElement.TrackBar;
|
||
using System.Threading;
|
||
using UserControlClass;
|
||
using DAL;
|
||
using System.Linq.Expressions;
|
||
using Newtonsoft.Json;
|
||
using System.Net;
|
||
using System.Xml.Linq;
|
||
using System.IO.Ports;
|
||
using System.Drawing.Printing;
|
||
|
||
namespace NSAnalysis
|
||
{
|
||
public partial class CenterControl : Telerik.WinControls.UI.ShapedForm
|
||
{
|
||
#region 全局变量
|
||
|
||
private int[] yValues = new int[3];
|
||
private string[] xValues = new string[3];
|
||
private DataTable dtCSVContent = new DataTable();
|
||
private DataTable dtRangeData = new DataTable();
|
||
private TMeasureMSSQLDAL tmdal = new TMeasureMSSQLDAL();
|
||
private string strSaveReprotPath = "";
|
||
private bool bReadCSVFlag = false;
|
||
private List<CheryIOTData> ListPostIOTData = new List<CheryIOTData>();
|
||
private FEHYLeftCarData fLEHY = null;
|
||
private FEHYRightCarData fREHY = null;
|
||
|
||
private FEH3LeftCarData fLEH3 = null;
|
||
private FEH3RightCarData fREH3 = null;
|
||
|
||
private int iCurrentMeasureItemsFailedCount = 0;
|
||
#region PLC相关变量
|
||
|
||
private bool bStopPlcNormal = false;
|
||
private static int HeartBeatCount = 0;
|
||
private bool bPlcLiveTickLast = false;
|
||
|
||
private Thread m_ThreadReconnectPLC = null;
|
||
private int m_ReConnectNum = 0;
|
||
private bool bTickt = true;
|
||
private int iLastNSStartMeasure = 0;
|
||
private int iLastCarPassFlag = 0;
|
||
private int iLastStation1To2 = 0;
|
||
private int iLastStation2To3 = 0;
|
||
private int iLastReadVINFinishFlag = 0;
|
||
|
||
private SerialPort serialTestPort = null;
|
||
|
||
private SerialPort serialPort = null;
|
||
private int iLastMesureCount = 0;
|
||
|
||
#endregion PLC相关变量
|
||
|
||
#region 分页全局变量
|
||
|
||
private DataTable PageTable = new DataTable();
|
||
|
||
/// <summary>
|
||
/// 每页记录数
|
||
/// </summary>
|
||
public int pageSize = 20;
|
||
|
||
/// <summary>
|
||
/// 总记录数
|
||
/// </summary>
|
||
public int recordCount = 0;
|
||
|
||
/// <summary>
|
||
/// 总页数
|
||
/// </summary>
|
||
public int pageCount = 0;
|
||
|
||
/// <summary>
|
||
/// 当前页
|
||
/// </summary>
|
||
public int currentPage = 0;
|
||
|
||
#endregion 分页全局变量
|
||
|
||
#endregion 全局变量
|
||
|
||
#region 主窗口事件
|
||
|
||
public CenterControl()
|
||
{
|
||
InitializeComponent();
|
||
SQLHelper.connStr = DatabaseDfn.SqlConnectStr();
|
||
|
||
//
|
||
|
||
#region 加载皮肤
|
||
|
||
ThemeResolutionService.LoadPackageFile(ConfigDfn.strTheme);
|
||
this.ThemeName = ConfigDfn.strSkinName.Substring(0, ConfigDfn.strSkinName.Length - 5);
|
||
RPV.ThemeName = ConfigDfn.strSkinName.Substring(0, ConfigDfn.strSkinName.Length - 5);
|
||
|
||
#endregion 加载皮肤
|
||
}
|
||
|
||
private void CenterControl_Load(object sender, EventArgs e)
|
||
{
|
||
#region 初始化全局变量
|
||
fLEHY = new FEHYLeftCarData(this);
|
||
fREHY = new FEHYRightCarData(this);
|
||
fLEH3 = new FEH3LeftCarData(this);
|
||
fREH3 = new FEH3RightCarData(this);
|
||
MyBase.rleMessage = rleMessage;
|
||
rdtpStartTime.Text = DateTime.Now.ToString("yyyy-MM-dd");
|
||
rdtpEndTime.Text = DateTime.Now.ToString("yyyy-MM-dd");
|
||
|
||
#endregion
|
||
//需要显示车身数据 不分析csv文件
|
||
if (ConfigDfn.iShowCarDataFlag == 1)
|
||
{
|
||
MyBase.TraceWriteLine(" 进入显示车身模式！显示车身界面。");
|
||
lpcShowCarData_Click(null, null);
|
||
//serialPort = new SerialPort(ConfigDfn.strCOMPort, 115200, Parity.None, 8, StopBits.One); // 设置串口参数
|
||
//serialPort.DataReceived += new SerialDataReceivedEventHandler(DataAutoReceivedHandler); // 注册数据接收事件处理方法
|
||
//serialPort.Open(); // 打开串口
|
||
//if (serialPort.IsOpen)
|
||
//{
|
||
// MyBase.TraceWriteLine(ConfigDfn.strCOMPort + "打开成功O(∩_∩)O");
|
||
//}
|
||
//else
|
||
//{
|
||
// MyBase.TraceWriteLine(ConfigDfn.strCOMPort + "打开失败！");
|
||
// MessageBox.Show(ConfigDfn.strCOMPort + "打开失败！请检查扫抢串口设置是否正确。", "错误", MessageBoxButtons.OK, MessageBoxIcon.Error);
|
||
//}
|
||
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine(" 进入不显示车身模式！");
|
||
}
|
||
if (ConfigDfn.iAnalysisCSVFlag == 1)
|
||
{
|
||
btnConnectPlc_Click(null, null);
|
||
MyBase.TraceWriteLine(" 进入解析CSV文件模式，开始解析扫码CSV文件！");
|
||
tmReadNextsenseCSV.Interval = 500;
|
||
tmReadNextsenseCSV.Start();
|
||
//tmdal.updateMaintenceInfoEmpty();
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine(" 进入不解析CSV文件模式！");
|
||
tmReadNextsenseCSV.Stop();
|
||
}
|
||
|
||
if (Directory.Exists(ConfigDfn.strNextSenseCSVEH3Path))
|
||
{
|
||
MyBase.TraceWriteLine("软件首次启动， Nextsense EH3 CSV读取路径存在；不清空，读取NextSense生成 CSV报告路径下的所有文件，路径为：" + ConfigDfn.strNextSenseCSVEH3Path);
|
||
}
|
||
else
|
||
{
|
||
string strTip = "错误：软件首次启动，读取NextSense生成EH3 CSV报告的路径：" + ConfigDfn.strNextSenseCSVEH3Path + " 不存在！请检查并进行修改！点击是按钮，软件将自动创建该路径！";
|
||
MyBase.TraceWriteLine(strTip);
|
||
Directory.CreateDirectory(ConfigDfn.strNextSenseCSVEH3Path);
|
||
//DialogResult dResult = MessageBox.Show(strTip, "错误", MessageBoxButtons.YesNo, MessageBoxIcon.Error);
|
||
//if (dResult == DialogResult.Yes)
|
||
//{
|
||
// Directory.CreateDirectory(ConfigDfn.strNextSenseCSVEH3Path);
|
||
// MyBase.TraceWriteLine(strTip + " ; 点击了是按钮，软件自动创建读取目录：" + ConfigDfn.strNextSenseCSVEH3Path);
|
||
//}
|
||
//else
|
||
//{
|
||
// MyBase.TraceWriteLine(strTip + " ；点击了否按钮，不创建目录！");
|
||
//}
|
||
}
|
||
if (Directory.Exists(ConfigDfn.strNextSenseCSVEHYPath))
|
||
{
|
||
MyBase.TraceWriteLine("软件首次启动， Nextsense EHY CSV读取路径存在；不清空，读取NextSense生成 CSV报告路径下的所有文件，路径为：" + ConfigDfn.strNextSenseCSVEHYPath);
|
||
}
|
||
else
|
||
{
|
||
string strTip = "错误：软件首次启动，读取NextSense生成EHY CSV报告的路径：" + ConfigDfn.strNextSenseCSVEHYPath + " 不存在！请检查并进行修改！点击是按钮，软件将自动创建该路径！";
|
||
MyBase.TraceWriteLine(strTip);
|
||
Directory.CreateDirectory(ConfigDfn.strNextSenseCSVEHYPath);
|
||
//DialogResult dResult = MessageBox.Show(strTip, "错误", MessageBoxButtons.YesNo, MessageBoxIcon.Error);
|
||
//if (dResult == DialogResult.Yes)
|
||
//{
|
||
// Directory.CreateDirectory(ConfigDfn.strNextSenseCSVEHYPath);
|
||
// MyBase.TraceWriteLine(strTip + " ; 点击了是按钮，软件自动创建读取目录：" + ConfigDfn.strNextSenseCSVEHYPath);
|
||
//}
|
||
//else
|
||
//{
|
||
// MyBase.TraceWriteLine(strTip + " ；点击了否按钮，不创建目录！");
|
||
//}
|
||
}
|
||
initLPCControl();
|
||
|
||
|
||
rddlSizeName.SelectedIndex = 0;
|
||
DataTable dtMPName = tmdal.SelectAllMeasPointName();
|
||
if (dtMPName.Rows.Count > 0)
|
||
{
|
||
for (int i = 0; i < dtMPName.Rows.Count; i++)
|
||
{
|
||
rddlMeasurePoint.Items.Add(dtMPName.Rows[i][0].ToString());
|
||
}
|
||
rddlMeasurePoint.SelectedIndex = 0;
|
||
}
|
||
//tmdal.updateMaintenceInfoEmpty();
|
||
//iLastMesureCount = tmdal.SelectTMeasureResultCount();
|
||
|
||
#region 清空信息
|
||
|
||
labVIN.Text = "";
|
||
labOKCount.Text = "";
|
||
labNGCount.Text = "";
|
||
labRejectCount.Text = "";
|
||
labSumMeasureCount.Text = "";
|
||
labMeaTime.Text = "";
|
||
labResultPercent.Text = "";
|
||
labResult.Text = "";
|
||
labCarType.Text = "";
|
||
|
||
#endregion 清空信息
|
||
|
||
InitTableColumns();
|
||
strSaveReprotPath = ConfigDfn.strReportPath + @"\";
|
||
}
|
||
|
||
private void InitTableColumns()
|
||
{
|
||
#region 测量数据表始化表
|
||
|
||
//创建虚拟表
|
||
DataColumn column2 = new DataColumn("CarID", Type.GetType("System.String"));
|
||
DataColumn dcCarType = new DataColumn("CarType", Type.GetType("System.String"));
|
||
DataColumn column3 = new DataColumn("MeasPointName", Type.GetType("System.String"));
|
||
DataColumn column4 = new DataColumn("DimensionName", Type.GetType("System.String"));
|
||
DataColumn column5 = new DataColumn("NormalValue", Type.GetType("System.String"));
|
||
DataColumn column6 = new DataColumn("LowerTolVal", Type.GetType("System.String"));
|
||
DataColumn column7 = new DataColumn("UpperTolVal", Type.GetType("System.String"));
|
||
DataColumn column8 = new DataColumn("MeasureValue", Type.GetType("System.String"));
|
||
DataColumn column10 = new DataColumn("MeasureItemResult", Type.GetType("System.String"));
|
||
DataColumn column9 = new DataColumn("MeasureDate", Type.GetType("System.DateTime"));
|
||
DataColumn column1 = new DataColumn("Remark", Type.GetType("System.String"));
|
||
//将列添加到table表中
|
||
|
||
dtCSVContent.Columns.Add(column2);
|
||
dtCSVContent.Columns.Add(dcCarType);
|
||
dtCSVContent.Columns.Add(column3);
|
||
dtCSVContent.Columns.Add(column4);
|
||
dtCSVContent.Columns.Add(column5);
|
||
dtCSVContent.Columns.Add(column6);
|
||
dtCSVContent.Columns.Add(column7);
|
||
dtCSVContent.Columns.Add(column8);
|
||
dtCSVContent.Columns.Add(column10);
|
||
dtCSVContent.Columns.Add(column9);
|
||
dtCSVContent.Columns.Add(column1);
|
||
|
||
#endregion 测量数据表始化表
|
||
|
||
#region 极差数据Table初始化
|
||
|
||
//创建虚拟表
|
||
DataColumn dcCarID = new DataColumn("CarID", Type.GetType("System.String"));
|
||
DataColumn dcRangeName = new DataColumn("RangeName", Type.GetType("System.String"));
|
||
DataColumn dcRangeValue = new DataColumn("RangeValue", Type.GetType("System.String"));
|
||
DataColumn dcRangeLowUpp = new DataColumn("RangeLowUpp", Type.GetType("System.String"));
|
||
DataColumn dcResult = new DataColumn("Result", Type.GetType("System.String"));
|
||
DataColumn dcCreateTime = new DataColumn("CreateTime", Type.GetType("System.DateTime"));
|
||
DataColumn dcRemark = new DataColumn("Remark", Type.GetType("System.String"));
|
||
//将列添加到table表中
|
||
|
||
dtRangeData.Columns.Add(dcCarID);
|
||
dtRangeData.Columns.Add(dcRangeName);
|
||
dtRangeData.Columns.Add(dcRangeValue);
|
||
dtRangeData.Columns.Add(dcRangeLowUpp);
|
||
dtRangeData.Columns.Add(dcResult);
|
||
dtRangeData.Columns.Add(dcCreateTime);
|
||
dtRangeData.Columns.Add(dcRemark);
|
||
|
||
#endregion 测量数据表始化表
|
||
|
||
#region 分页相关
|
||
|
||
//创建分页虚拟表
|
||
DataColumn column11 = new DataColumn("CarID", Type.GetType("System.String"));
|
||
DataColumn column12 = new DataColumn("MeasPointName", Type.GetType("System.String"));
|
||
DataColumn column13 = new DataColumn("DimensionName", Type.GetType("System.String"));
|
||
DataColumn column14 = new DataColumn("NormalValue", Type.GetType("System.String"));
|
||
DataColumn column15 = new DataColumn("LowerTolVal", Type.GetType("System.String"));
|
||
DataColumn column16 = new DataColumn("UpperTolVal", Type.GetType("System.String"));
|
||
DataColumn column17 = new DataColumn("MeasureValue", Type.GetType("System.String"));
|
||
DataColumn column18 = new DataColumn("MeasureDate", Type.GetType("System.String"));
|
||
DataColumn column19 = new DataColumn("MeasureItemResult", Type.GetType("System.String"));
|
||
|
||
//将列添加到table表中
|
||
PageTable.Columns.Add(column11);
|
||
PageTable.Columns.Add(column12);
|
||
PageTable.Columns.Add(column13);
|
||
PageTable.Columns.Add(column14);
|
||
PageTable.Columns.Add(column15);
|
||
PageTable.Columns.Add(column16);
|
||
PageTable.Columns.Add(column17);
|
||
PageTable.Columns.Add(column18);
|
||
PageTable.Columns.Add(column19);
|
||
|
||
labCurrentPage.Text = "当前页：" + currentPage.ToString(); //当前页
|
||
labSumPages.Text = "共 " + pageCount.ToString() + " 页";//总页数
|
||
labSumRecorders.Text = "总共 " + recordCount.ToString() + " 条记录";//总记录数
|
||
rddlPageRecorderCount.SelectedIndex = 0;
|
||
|
||
#endregion 分页相关
|
||
}
|
||
|
||
private void DataAutoReceivedHandler(object sender, SerialDataReceivedEventArgs e)
|
||
{
|
||
SerialPort sp = (SerialPort)sender;
|
||
string strScanVIN = sp.ReadExisting();
|
||
MyBase.TraceWriteLine("扫抢获取的VIN码为：" + strScanVIN);
|
||
if (strScanVIN.Length > 0)
|
||
{
|
||
tmdal.updateMaintenceInfo(strScanVIN, 3);
|
||
MyBase.TraceWriteLine("更新数据库中存储的VIN码：" + strScanVIN);
|
||
}
|
||
}
|
||
|
||
private void initLPCControl()
|
||
{
|
||
lpcSoftwareSetup.labPicture.Click += new EventHandler(lpcSoftwareSetup_Click);
|
||
lpcSoftwareSetup.labText.Click += new EventHandler(lpcSoftwareSetup_Click);
|
||
|
||
lpcToleranceSetup.labPicture.Click += new EventHandler(lpcToleranceSetup_Click);
|
||
lpcToleranceSetup.labText.Click += new EventHandler(lpcToleranceSetup_Click);
|
||
|
||
lpcRange.labPicture.Click += new EventHandler(lpcRange_Click);
|
||
lpcRange.labText.Click += new EventHandler(lpcRange_Click);
|
||
|
||
lpcPLCAddress.labPicture.Click += new EventHandler(lpcPLCAddress_Click);
|
||
lpcPLCAddress.labText.Click += new EventHandler(lpcPLCAddress_Click);
|
||
|
||
lpcPLCTest.labPicture.Click += new EventHandler(lpcPLCTest_Click);
|
||
lpcPLCTest.labText.Click += new EventHandler(lpcPLCTest_Click);
|
||
|
||
lpcAboutSoftware.labPicture.Click += new EventHandler(lpcAboutSoftware_Click);
|
||
lpcAboutSoftware.labText.Click += new EventHandler(lpcAboutSoftware_Click);
|
||
|
||
lpcUploadIOTTest.labPicture.Click += new EventHandler(lpcUploadIOTTest_Click);
|
||
lpcUploadIOTTest.labText.Click += new EventHandler(lpcUploadIOTTest_Click);
|
||
|
||
lpcTestGetCarTye.labPicture.Click += new EventHandler(lpcTestGetCarTye_Click);
|
||
lpcTestGetCarTye.labText.Click += new EventHandler(lpcTestGetCarTye_Click);
|
||
|
||
lpcShowCarData.labPicture.Click += new EventHandler(lpcShowCarData_Click);
|
||
lpcShowCarData.labText.Click += new EventHandler(lpcShowCarData_Click);
|
||
|
||
lpcShowLog.labPicture.Click += new EventHandler(lpcShowLog_Click);
|
||
lpcShowLog.labText.Click += new EventHandler(lpcShowLog_Click);
|
||
}
|
||
|
||
private void CenterControl_FormClosing(object sender, FormClosingEventArgs e)
|
||
{
|
||
if (DialogResult.Yes == MessageBox.Show("警告：您确定要退出该软件系统吗？", "警告", MessageBoxButtons.YesNo, MessageBoxIcon.Warning))
|
||
{
|
||
|
||
}
|
||
else
|
||
{
|
||
e.Cancel = true;
|
||
}
|
||
}
|
||
|
||
private void CenterControl_FormClosed(object sender, FormClosedEventArgs e)
|
||
{
|
||
MyBase.TraceWriteLine("-------------海克斯康面隙分析软件程序关闭---------------------");
|
||
LogDebugDfn.strEndTime = DateTime.Now.ToString("yyyy.MM.dd HH-mm-ss");
|
||
string CopyFileName = ConfigDfn.strFileFolder + "\\DebugFiles\\" + "Debug(" + LogDebugDfn.strStartTime + " To " + LogDebugDfn.strEndTime + ")" + ".txt";
|
||
if (File.Exists(LogDebugDfn.strDebugFile))
|
||
File.Copy(LogDebugDfn.strDebugFile, CopyFileName);
|
||
System.Environment.Exit(0);
|
||
}
|
||
|
||
private void tmSystem_Tick(object sender, EventArgs e)
|
||
{
|
||
rleTime.Text = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
||
if (ConfigDfn.iAnalysisCSVFlag == 1)
|
||
rleReadCSVStatus.ForeColor = bReadCSVFlag ? Color.Green : Color.White;
|
||
bReadCSVFlag = !bReadCSVFlag;
|
||
}
|
||
|
||
#endregion 主窗口事件
|
||
|
||
private void tmReadNextsenseCSV_Tick(object sender, EventArgs e)
|
||
{
|
||
tmReadNextsenseCSV.Stop();
|
||
AnalysisNextSenseSelfMeasureCSV();
|
||
AnalysisNextSenseEH3CSV();
|
||
AnalysisNextSenseEHYCSV();
|
||
tmReadNextsenseCSV.Start();
|
||
}
|
||
|
||
#region⭐⭐⭐⭐⭐ 解析Nextsense CSV文件功能 核心算法 ⭐⭐⭐⭐⭐
|
||
|
||
private double CalculateStrictLowerTolerance(double dLower, double dUpper)
|
||
{
|
||
double dStrictLower = 0;
|
||
double dNormalValue = (dLower + dUpper) / 2;
|
||
dStrictLower = dNormalValue + (dLower - dNormalValue) * ConfigDfn.dTolerancePer;
|
||
return dStrictLower;
|
||
}
|
||
|
||
private double CalculateStrictUpperTolerance(double dLower, double dUpper)
|
||
{
|
||
double dStrictUpper = 0;
|
||
double dNormalValue = (dLower + dUpper) / 2;
|
||
dStrictUpper = dNormalValue + (dUpper - dNormalValue) * ConfigDfn.dTolerancePer;
|
||
return dStrictUpper;
|
||
}
|
||
private double CalculateExceptionLowerTolerance(double dLower, double dUpper)
|
||
{
|
||
double dStrictLower = 0;
|
||
double dNormalValue = (dLower + dUpper) / 2;
|
||
dStrictLower = dNormalValue + (dLower - dNormalValue) * ConfigDfn.dExceptionTolerancePer;
|
||
return dStrictLower;
|
||
}
|
||
|
||
private double CalculateExceptionUpperTolerance(double dLower, double dUpper)
|
||
{
|
||
double dStrictUpper = 0;
|
||
double dNormalValue = (dLower + dUpper) / 2;
|
||
dStrictUpper = dNormalValue + (dUpper - dNormalValue) * ConfigDfn.dExceptionTolerancePer;
|
||
return dStrictUpper;
|
||
}
|
||
/// <summary>
|
||
/// 解析EH3 CSV文件函数;后续如果Nextsense的csv报告模板变了，修改该函数的行号即可LineNum wsp
|
||
/// </summary>
|
||
private void AnalysisNextSenseEH3CSV()
|
||
{
|
||
try
|
||
{
|
||
lbCSVFiles.Items.Clear();
|
||
FileInfo[] fileInfos = null;
|
||
if (Directory.Exists(ConfigDfn.strNextSenseCSVEH3Path))
|
||
{
|
||
DirectoryInfo di = new DirectoryInfo(ConfigDfn.strNextSenseCSVEH3Path);
|
||
fileInfos = di.GetFiles("*.CSV");
|
||
if (fileInfos.Count() >= 1)
|
||
{
|
||
MyBase.TraceWriteLine("存在EH3 CSV文件，开始解析：");
|
||
List<string> listCSVTitleInfo = new List<string>();
|
||
string strCarID = "";
|
||
foreach (FileInfo fi in fileInfos)
|
||
{
|
||
listCSVTitleInfo.Clear();
|
||
ListPostIOTData.Clear();
|
||
dtCSVContent.Clear();
|
||
dgvMeasureContent.Rows.Clear();
|
||
string strCSVName = fi.FullName;
|
||
File.Copy(fi.FullName, ConfigDfn.strFileFolder + "\\NextSenseCSVBackup\\" + fi.Name, true);
|
||
MyBase.TraceWriteLine("Copy " + fi.FullName + " TO " + ConfigDfn.strFileFolder + "\\NextSenseCSVBackup\\" + fi.Name + " Done. 备份完成");
|
||
lbCSVFiles.Items.Add(fi.Name);
|
||
|
||
#region 解析EH3 CSV报告
|
||
|
||
MyBase.TraceWriteLine("开始解析NextSense EH3 CSV 报告：" + strCSVName);
|
||
Encoding encoding = GetType(strCSVName);
|
||
FileStream fs = new FileStream(strCSVName, FileMode.Open, FileAccess.Read);
|
||
StreamReader sr = new StreamReader(fs, encoding);
|
||
//记录每次读取的一行记录
|
||
string strLine = "";
|
||
//记录每行记录中的各字段内容
|
||
string[] aryLineContent = null;
|
||
|
||
//逐行读取CSV中的数据
|
||
int LineNum = 0;
|
||
//表格行数
|
||
int dtRowCount = 0;
|
||
//超差个数
|
||
double OutCount = 0;
|
||
//Ok个数
|
||
double OKCount = 0;
|
||
//异常个数
|
||
double RejectedCount = 0;
|
||
//合格率
|
||
double FPYPercent = 0;
|
||
double dStrictTLower = 0;
|
||
double dStrictTUpper = 0;
|
||
double dLowerValue = 0;
|
||
double dUpperValue = 0;
|
||
double dExcepitonTLower = 0;
|
||
double dExceptionTUpper = 0;
|
||
double dMeasureValue = 0.0;
|
||
DataTable dt = null;
|
||
while ((strLine = sr.ReadLine()) != null)
|
||
{
|
||
LineNum++;
|
||
if (LineNum >= 3 & LineNum <= 16)
|
||
{
|
||
listCSVTitleInfo.Add(strLine);
|
||
}
|
||
if (LineNum == 10)
|
||
{
|
||
aryLineContent = strLine.Split(',');
|
||
MyBase.TraceWriteLine("解析出NextSense CSV中的VIN为：" + aryLineContent[1]);
|
||
strCarID = tmdal.SelectVINByCSVVIN(aryLineContent[1]);
|
||
MyBase.TraceWriteLine("通过CSV VIN从数据库中获取的完整VIN为：" + strCarID);
|
||
if (strCarID.ToLower().Contains("nofind"))
|
||
{
|
||
MyBase.TraceWriteLine("数据库中没有查找到VIN码，NoFind, +L 使用CSV码");
|
||
labVIN.Text = "L" + aryLineContent[1];
|
||
strCarID = "L" + aryLineContent[1];
|
||
}
|
||
else
|
||
{
|
||
labVIN.Text = strCarID;
|
||
tmdal.DeleteOneTTempVIN(strCarID);
|
||
MyBase.TraceWriteLine("在数据库表TTempSaveVIN中删除该VIN：" + strCarID);
|
||
}
|
||
}
|
||
if (LineNum >= 19)
|
||
{
|
||
aryLineContent = strLine.Split(',');
|
||
//ConfigDfn.strMeasureTime = aryLineContent[6].Substring(0, 4) + "-" + aryLineContent[6].Substring(4, 2) + "-" + aryLineContent[6].Substring(6, 2) + " " + aryLineContent[7].Substring(0, 2) + ":" + aryLineContent[7].Substring(2, 2) + ":" + aryLineContent[7].Substring(4, 2);
|
||
ConfigDfn.strMeasureTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
||
double dNormalValue = 0.0d;
|
||
|
||
dt = tmdal.SelectOneToleranceByCondition("EH3", aryLineContent[0], aryLineContent[1]);
|
||
if (dt.Rows.Count == 1)
|
||
{
|
||
dLowerValue = double.Parse(dt.Rows[0]["TolLower"].ToString());
|
||
dUpperValue = double.Parse(dt.Rows[0]["TolUpper"].ToString());
|
||
dNormalValue = (dLowerValue + dUpperValue) / 2;
|
||
dStrictTLower = CalculateStrictLowerTolerance(dLowerValue, dUpperValue);
|
||
dStrictTUpper = CalculateStrictUpperTolerance(dLowerValue, dUpperValue);
|
||
dExcepitonTLower = CalculateExceptionLowerTolerance(dLowerValue, dUpperValue);
|
||
dExceptionTUpper = CalculateExceptionUpperTolerance(dLowerValue, dUpperValue);
|
||
}
|
||
else
|
||
{
|
||
dStrictTLower = 0;
|
||
dStrictTUpper = 0;
|
||
dLowerValue = 0;
|
||
dUpperValue = 0;
|
||
MyBase.TraceWriteLine("EH3 " + aryLineContent[0] + " " + aryLineContent[1] + " 查询数据获取公差带失败！数据库中数量不唯一，请检查公差带配置！");
|
||
}
|
||
|
||
if (aryLineContent[2].ToLower().Contains("inv"))
|
||
{
|
||
aryLineContent[4] = "UNCLASSIFIED";
|
||
}
|
||
else
|
||
{
|
||
dMeasureValue = double.Parse(aryLineContent[2]);
|
||
if (dMeasureValue >= dLowerValue && dMeasureValue <= dUpperValue)
|
||
{
|
||
aryLineContent[4] = "good";
|
||
}
|
||
else if (dMeasureValue >= dStrictTLower && dMeasureValue <= dStrictTUpper)
|
||
{
|
||
aryLineContent[4] = "ng1";
|
||
}
|
||
else if (dMeasureValue >= dExceptionTUpper || dMeasureValue <= dExcepitonTLower)
|
||
{
|
||
aryLineContent[4] = "ng3";
|
||
aryLineContent[2] = "inv";
|
||
}
|
||
else
|
||
{
|
||
aryLineContent[4] = "ng2";
|
||
}
|
||
}
|
||
|
||
//测量数据存储到table里
|
||
dtCSVContent.Rows.Add(strCarID, "EH3", aryLineContent[0], aryLineContent[1], dNormalValue.ToString("F1"), dLowerValue.ToString("F1"), dUpperValue.ToString("F1"), aryLineContent[2], aryLineContent[4], DateTime.Now, "");
|
||
string strMeasureResult = aryLineContent[4].ToLower();
|
||
if (strMeasureResult.Contains("good") || strMeasureResult.Contains("best"))
|
||
{
|
||
OKCount++;
|
||
aryLineContent[4] = "OK";
|
||
}
|
||
else if (strMeasureResult.Contains("ng1") || strMeasureResult.Contains("ng2"))
|
||
{
|
||
OutCount++;
|
||
aryLineContent[4] = "NG";
|
||
}
|
||
else
|
||
{
|
||
RejectedCount++;
|
||
aryLineContent[4] = "";
|
||
aryLineContent[2] = "";
|
||
}
|
||
|
||
dgvMeasureContent.Rows.Add(aryLineContent[0], aryLineContent[1], dNormalValue.ToString("F1"), dLowerValue.ToString("F1"), dUpperValue.ToString("F1"), aryLineContent[2], ConfigDfn.strMeasureTime, aryLineContent[4]);
|
||
|
||
CheryIOTData cIOTData = new CheryIOTData();
|
||
cIOTData.vin = strCarID;
|
||
cIOTData.gfNo = aryLineContent[1];
|
||
cIOTData.pointNumber = aryLineContent[0];
|
||
cIOTData.actualValue = aryLineContent[2];
|
||
cIOTData.controlLine = dLowerValue.ToString("F1") + @"/" + dUpperValue.ToString("F1");
|
||
if (strMeasureResult.Contains("good") || strMeasureResult.Contains("best") || strMeasureResult.Contains("ng1"))
|
||
{
|
||
cIOTData.measurementResult = "OK";
|
||
}
|
||
else
|
||
{
|
||
cIOTData.measurementResult = "NG";
|
||
}
|
||
ListPostIOTData.Add(cIOTData);
|
||
dtRowCount++;
|
||
dgvMeasureContent.Rows[dtRowCount - 1].HeaderCell.Value = dtRowCount.ToString();
|
||
}
|
||
}//End While
|
||
sr.Close();
|
||
fs.Close();
|
||
tmdal.InsertTMeasureDatabyDataTable(dtCSVContent);
|
||
MyBase.TraceWriteLine("解析EH3数据完成，并将所有测量数据插入到数据库完毕。");
|
||
MyBase.TraceWriteLine("解析NextSense EH3 CSV 报告完毕！检测项数=" + dtRowCount.ToString());
|
||
if (dtRowCount <= ConfigDfn.iMeasureItemsCount)
|
||
{
|
||
iCurrentMeasureItemsFailedCount++;
|
||
}
|
||
else
|
||
{
|
||
iCurrentMeasureItemsFailedCount = 0;
|
||
}
|
||
|
||
// 连续多个车异常
|
||
if (iCurrentMeasureItemsFailedCount >= ConfigDfn.iFailedCarCount)
|
||
{
|
||
MyBase.TraceWriteLine("iCurrentMeasureItemsFailedCount=" + iCurrentMeasureItemsFailedCount.ToString() + "超过报警数量" + ConfigDfn.iFailedCarCount.ToString() + " ;给PLC发送报警10。");
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.MeasureError, (byte)10);
|
||
}
|
||
|
||
// 单个报告内 invalued 项超过某个值
|
||
|
||
|
||
|
||
// 机器人忙碌状态 且 多个小时无测量报告
|
||
|
||
|
||
|
||
|
||
|
||
#endregion 解析EH3 CSV报告
|
||
|
||
#region 计算极差
|
||
CalculateRange(strCarID, "EH3");
|
||
Thread.Sleep(20);
|
||
DataTable dtAllRangeDate = tmdal.SelectRangeDatabyCarID(strCarID);
|
||
if (dtAllRangeDate.Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in dtAllRangeDate.Rows)
|
||
{
|
||
if (ConfigDfn.iIncludeRangeFlag == 1)
|
||
{
|
||
if (row.ItemArray[5].ToString().Contains("OK"))
|
||
{
|
||
OKCount++;
|
||
}
|
||
else
|
||
{
|
||
OutCount++;
|
||
}
|
||
}
|
||
|
||
dgvMeasureContent.Rows.Add(row.ItemArray[2].ToString(), "G", "0", row.ItemArray[4].ToString().Substring(0, 3), row.ItemArray[4].ToString().Substring(4, 3), row.ItemArray[3].ToString(), ConfigDfn.strMeasureTime, row.ItemArray[5].ToString());
|
||
}
|
||
}
|
||
|
||
if (ConfigDfn.iIncludeRangeFlag == 1)
|
||
{
|
||
dtRowCount = dtRowCount + dtAllRangeDate.Rows.Count;
|
||
for (int i = 1; i <= dtRowCount; i++)
|
||
{
|
||
dgvMeasureContent.Rows[i - 1].HeaderCell.Value = i.ToString();
|
||
}
|
||
|
||
MyBase.TraceWriteLine("计算合格率的时：包含极差计算项！");
|
||
}
|
||
#endregion
|
||
|
||
#region 界面显示功能
|
||
|
||
labCarType.Text = "EH3";
|
||
TMeasureResultModel tmrm = new TMeasureResultModel();
|
||
labNGCount.Text = OutCount.ToString();
|
||
labOKCount.Text = OKCount.ToString();
|
||
labRejectCount.Text = RejectedCount.ToString();
|
||
labMeaTime.Text = ConfigDfn.strMeasureTime;
|
||
labSumMeasureCount.Text = dtRowCount.ToString();
|
||
FPYPercent = OKCount / (OKCount + OutCount);
|
||
if (FPYPercent >= ConfigDfn.dFPY)
|
||
{
|
||
labResultPercent.Text = Math.Round(FPYPercent * 100.00d, 2).ToString("F2") + "%";
|
||
labResult.Text = "合格";
|
||
labResultPercent.ForeColor = Color.LimeGreen;
|
||
labResult.ForeColor = Color.LimeGreen;
|
||
pbResult.Image = Resources.OK;
|
||
tmrm.Result = 1;
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.CMMResult, (byte)10);
|
||
}
|
||
else if (FPYPercent >= ConfigDfn.dFPY2 && FPYPercent < ConfigDfn.dFPY)
|
||
{
|
||
labResultPercent.Text = Math.Round(FPYPercent * 100.00d, 2).ToString("F2") + "%";
|
||
labResult.Text = "合格";
|
||
labResultPercent.ForeColor = Color.Yellow;
|
||
labResult.ForeColor = Color.Yellow;
|
||
pbResult.Image = Resources.OK;
|
||
tmrm.Result = 1;
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.CMMResult, (byte)20);
|
||
}
|
||
else
|
||
{
|
||
labResultPercent.Text = Math.Round(FPYPercent * 100.00d, 2).ToString("F2") + "%";
|
||
labResult.Text = "不合格";
|
||
labResultPercent.ForeColor = Color.Red;
|
||
labResult.ForeColor = Color.Red;
|
||
pbResult.Image = Resources.NG;
|
||
tmrm.Result = 2;
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.CMMResult, (byte)30);
|
||
}
|
||
xValues[0] = "合格 : " + OKCount.ToString();
|
||
xValues[1] = "不合格 : " + OutCount.ToString();
|
||
xValues[2] = "异常 : " + RejectedCount.ToString();
|
||
yValues[0] = (int)OKCount;
|
||
yValues[1] = (int)OutCount;
|
||
yValues[2] = (int)RejectedCount;
|
||
chartResultPie.Series[0].Points.DataBindXY(xValues, yValues);
|
||
|
||
string strTargetRate = Math.Round(ConfigDfn.dFPY2 * 100.00d, 2).ToString("F2") + "%";
|
||
|
||
tmrm.CarID = strCarID;
|
||
tmrm.CarType = "EH3";
|
||
tmrm.SumMeasureItems = dtRowCount;
|
||
tmrm.GoodMeasureItems = (int)OKCount;
|
||
tmrm.NoGoodMeasureItems = (int)OutCount;
|
||
tmrm.RejectMeasureItems = (int)RejectedCount;
|
||
tmrm.FPY = FPYPercent.ToString("F4");
|
||
tmrm.Remark = "";
|
||
tmrm.MeasureDate = ConfigDfn.strMeasureTime;
|
||
tmdal.InsertTMeasureResult(tmrm);
|
||
MyBase.TraceWriteLine("将EH3总结果插入数据库完毕。");
|
||
MyBase.TraceWriteLine("全部插入解析完毕，删除文件：" + fi.Name);
|
||
fi.Delete();
|
||
dgvMeasureContent.Rows.Add();
|
||
dgvMeasureContent.Rows[dgvMeasureContent.Rows.Count - 1].Cells["MResult"].Value = (dtRowCount - OutCount - RejectedCount).ToString() + "/" + dtRowCount.ToString();
|
||
this.dgvMeasureContent.Rows[dgvMeasureContent.Rows.Count - 1].DefaultCellStyle.ForeColor = Color.White;
|
||
if (dgvMeasureContent.Rows.Count > 0)
|
||
{
|
||
SetdgvRowBgColor(dgvMeasureContent);
|
||
for (int i = 0; i < dgvMeasureContent.Rows.Count; i++)
|
||
{
|
||
//if (dgvMeasureContent.Rows[i].Cells["MResult"].Value.ToString().ToLower().Contains("ok"))
|
||
//{
|
||
// dgvMeasureContent.Rows[i].DefaultCellStyle.BackColor = Color.Orange;
|
||
//}
|
||
if (dgvMeasureContent.Rows[i].Cells["MResult"].Value.ToString().ToLower().Contains("ng"))
|
||
{
|
||
dgvMeasureContent.Rows[i].DefaultCellStyle.BackColor = Color.Orange;
|
||
}
|
||
else if (string.IsNullOrEmpty(dgvMeasureContent.Rows[i].Cells["MResult"].Value.ToString()))
|
||
{
|
||
dgvMeasureContent.Rows[i].DefaultCellStyle.BackColor = Color.Red;
|
||
}
|
||
else
|
||
{
|
||
}
|
||
}
|
||
}
|
||
|
||
#endregion 界面显示功能
|
||
|
||
|
||
//生成客户的 CSV文件
|
||
if (ConfigDfn.iCreateReportFlag == 1)
|
||
{
|
||
#region 解析完报告后，重新生成客户模板报告
|
||
|
||
string filePath = strSaveReprotPath + DateTime.Now.ToString("yyyyMMddHHmmss") + "_" + strCarID + ".csv"; //wsp 后期还要再改
|
||
string strWithoutLCarVin = strCarID.Substring(1);
|
||
StringBuilder sb = new StringBuilder();
|
||
//添加表头
|
||
sb.Append("Measurement Info Name");
|
||
sb.Append(",");
|
||
sb.Append("Measurement Info");
|
||
sb.AppendLine();
|
||
sb.Append("Date_Time");
|
||
sb.Append(",");
|
||
sb.Append(DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
|
||
sb.AppendLine();
|
||
for (int i = 0; i < listCSVTitleInfo.Count; i++)
|
||
{
|
||
if (listCSVTitleInfo[i].Contains("prodnum"))
|
||
{
|
||
listCSVTitleInfo[i] = listCSVTitleInfo[i].Replace("prodnum", "Part_ident");
|
||
}
|
||
if (listCSVTitleInfo[i].Contains(strWithoutLCarVin))
|
||
{
|
||
listCSVTitleInfo[i] = listCSVTitleInfo[i].Replace(strWithoutLCarVin, strCarID);
|
||
}
|
||
sb.Append(listCSVTitleInfo[i]);
|
||
sb.AppendLine();
|
||
}
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
//添加测量数据
|
||
sb.Append("Characteristic");
|
||
sb.Append(",");
|
||
sb.Append("Extension");
|
||
sb.Append(",");
|
||
sb.Append("Measured_Value");
|
||
sb.AppendLine();
|
||
foreach (DataRow row in dtCSVContent.Rows)
|
||
{
|
||
sb.Append(row.ItemArray[2]);
|
||
sb.Append(",");
|
||
sb.Append(row.ItemArray[3]);
|
||
sb.Append(",");
|
||
sb.Append(row.ItemArray[7]);
|
||
sb.AppendLine();
|
||
}
|
||
if (dtAllRangeDate.Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in dtAllRangeDate.Rows)
|
||
{
|
||
sb.Append(row.ItemArray[2]);
|
||
sb.Append(",");
|
||
sb.Append("G");
|
||
sb.Append(",");
|
||
sb.Append(row.ItemArray[3]);
|
||
sb.AppendLine();
|
||
}
|
||
}
|
||
sb.Append("POP");
|
||
sb.Append(",");
|
||
sb.Append("P");
|
||
sb.Append(",");
|
||
sb.Append(Math.Round(FPYPercent * 100.00d, 2).ToString("F2"));
|
||
sb.AppendLine();
|
||
// 将数据写入CSV文件
|
||
File.WriteAllText(filePath, sb.ToString());
|
||
MyBase.TraceWriteLine("客户csv报告生成完毕，路径为：" + filePath);
|
||
|
||
#endregion 解析完报告后，重新生成客户模板报告
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine("EH3数据生成报告功能未启用！");
|
||
}
|
||
|
||
#region Update Data To IOT
|
||
|
||
if (ConfigDfn.iStartIOTFlag == 1)
|
||
{
|
||
bool bVINMeasuedFlag = tmdal.CheckVINExistInDB(strCarID);
|
||
if (bVINMeasuedFlag)
|
||
{
|
||
MyBase.TraceWriteLine("VIN:" + strCarID + " 该VIN码已经在数据库中存在了，说明已经测量过了，不再进行IOT数据上传操作。");
|
||
}
|
||
else
|
||
{
|
||
#region IOT上传功能
|
||
if (dtAllRangeDate.Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in dtAllRangeDate.Rows)
|
||
{
|
||
CheryIOTData cIOTData = new CheryIOTData();
|
||
cIOTData.vin = strCarID;
|
||
cIOTData.gfNo = "G";
|
||
cIOTData.pointNumber = row.ItemArray[2].ToString();
|
||
cIOTData.actualValue = row.ItemArray[3].ToString();
|
||
cIOTData.controlLine = row.ItemArray[4].ToString();
|
||
cIOTData.measurementResult = row.ItemArray[5].ToString();
|
||
if (cIOTData.measurementResult.ToUpper().Contains("NG"))
|
||
{
|
||
if (!cIOTData.actualValue.ToLower().Contains("inv"))
|
||
{
|
||
dLowerValue = double.Parse(row.ItemArray[4].ToString().Substring(0, 3));
|
||
dUpperValue = double.Parse(row.ItemArray[4].ToString().Substring(4, 3));
|
||
dStrictTLower = CalculateStrictLowerTolerance(dLowerValue, dUpperValue);
|
||
dStrictTUpper = CalculateStrictUpperTolerance(dLowerValue, dUpperValue);
|
||
double dValue = double.Parse(row.ItemArray[3].ToString());
|
||
if (dValue > dStrictTLower && dValue < dStrictTUpper)
|
||
{
|
||
cIOTData.measurementResult = "OK";
|
||
}
|
||
}
|
||
}
|
||
ListPostIOTData.Add(cIOTData);
|
||
}
|
||
}
|
||
string strGapList = JsonHelper.ObjectToJson(ListPostIOTData);
|
||
string strCaliResult = "OK";
|
||
if (labResult.Text == "合格")
|
||
{
|
||
strCaliResult = "OK";
|
||
}
|
||
else
|
||
{
|
||
strCaliResult = "NG";
|
||
}
|
||
string strPostData = "{\"serno\":\"" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + "\",\"requestData\":[{\"vin\":\"" + strCarID + "\",\"model\":\"EH3\",\"equipmentNo\":\"" + ConfigDfn.strEquipNo + "\",\"equipmentName\":\"" + ConfigDfn.strEquipName + "\",\"calibrationResult\":\"" + strCaliResult + "\",\"detectionTime\":\"" + ConfigDfn.strMeasureTime + "\",\"targetRate\":\"" + strTargetRate + "\",\"rate\":\"" + labResultPercent.Text + "\",\"GapList\":" + strGapList + "}]}";
|
||
MyBase.TraceWriteLine("Update To IOT Data Content: " + strPostData);
|
||
string strPostResult = PostJsonToIOT(ConfigDfn.strIOTAddress, strPostData, 10000);
|
||
MyBase.TraceWriteLine("EH3数据上传IOT完成，结果返回为：" + strPostResult);
|
||
if (strPostResult.Contains("成功"))
|
||
{
|
||
MyBase.TraceWriteLine("EH3数据上传IOT成功 ^_^");
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine("EH3数据上传IOT失败！");
|
||
}
|
||
|
||
#endregion IOT上传功能
|
||
}
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine("数据上传IOT功能未启用！");
|
||
}
|
||
|
||
#endregion Update Data To IOT
|
||
}
|
||
}
|
||
}
|
||
//else
|
||
//{
|
||
// MyBase.TraceWriteLine("错误：AnalysisNextSenseEH3CSV函数中，检测EH3 CSV 路径不存在：" + ConfigDfn.strNextSenseCSVPath);
|
||
//}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
MyBase.TraceWriteLine("AnalysisNextSenseCSV 函数分析异常：" + ex.ToString());
|
||
}
|
||
}
|
||
|
||
private void AnalysisNextSenseEHYCSV()
|
||
{
|
||
try
|
||
{
|
||
lbCSVFiles.Items.Clear();
|
||
FileInfo[] fileInfos = null;
|
||
if (Directory.Exists(ConfigDfn.strNextSenseCSVEHYPath))
|
||
{
|
||
DirectoryInfo di = new DirectoryInfo(ConfigDfn.strNextSenseCSVEHYPath);
|
||
fileInfos = di.GetFiles("*.CSV");
|
||
if (fileInfos.Count() >= 1)
|
||
{
|
||
MyBase.TraceWriteLine("存在EHY CSV文件，开始解析：");
|
||
List<string> listCSVTitleInfo = new List<string>();
|
||
string strCarID = "";
|
||
foreach (FileInfo fi in fileInfos)
|
||
{
|
||
listCSVTitleInfo.Clear();
|
||
ListPostIOTData.Clear();
|
||
dtCSVContent.Clear();
|
||
dgvMeasureContent.Rows.Clear();
|
||
string strCSVName = fi.FullName;
|
||
File.Copy(fi.FullName, ConfigDfn.strFileFolder + "\\NextSenseCSVBackup\\" + fi.Name, true);
|
||
MyBase.TraceWriteLine("Copy " + fi.FullName + " TO " + ConfigDfn.strFileFolder + "\\NextSenseCSVBackup\\" + fi.Name + " Done. 备份完成");
|
||
lbCSVFiles.Items.Add(fi.Name);
|
||
|
||
#region 解析EHY CSV报告
|
||
|
||
MyBase.TraceWriteLine("开始解析NextSense EHY CSV 报告：" + strCSVName);
|
||
Encoding encoding = GetType(strCSVName);
|
||
FileStream fs = new FileStream(strCSVName, FileMode.Open, FileAccess.Read);
|
||
StreamReader sr = new StreamReader(fs, encoding);
|
||
//记录每次读取的一行记录
|
||
string strLine = "";
|
||
//记录每行记录中的各字段内容
|
||
string[] aryLineContent = null;
|
||
|
||
//逐行读取CSV中的数据
|
||
int LineNum = 0;
|
||
//表格行数
|
||
int dtRowCount = 0;
|
||
//超差个数
|
||
double OutCount = 0;
|
||
//Ok个数
|
||
double OKCount = 0;
|
||
//异常个数
|
||
double RejectedCount = 0;
|
||
//合格率
|
||
double FPYPercent = 0;
|
||
double dStrictTLower = 0;
|
||
double dStrictTUpper = 0;
|
||
double dLowerValue = 0;
|
||
double dUpperValue = 0;
|
||
double dExcepitonTLower = 0;
|
||
double dExceptionTUpper = 0;
|
||
double dMeasureValue = 0.0;
|
||
DataTable dt = null;
|
||
while ((strLine = sr.ReadLine()) != null)
|
||
{
|
||
LineNum++;
|
||
if (LineNum >= 3 & LineNum <= 16)
|
||
{
|
||
listCSVTitleInfo.Add(strLine);
|
||
}
|
||
if (LineNum == 10)
|
||
{
|
||
aryLineContent = strLine.Split(',');
|
||
MyBase.TraceWriteLine("解析出NextSense CSV中的VIN为：" + aryLineContent[1]);
|
||
strCarID = tmdal.SelectVINByCSVVIN(aryLineContent[1]);
|
||
MyBase.TraceWriteLine("通过CSV VIN从数据库中获取的完整VIN为：" + strCarID);
|
||
if (strCarID.ToLower().Contains("nofind"))
|
||
{
|
||
MyBase.TraceWriteLine("数据库中没有查找到VIN码，NoFind, +L 使用CSV码");
|
||
labVIN.Text = "L" + aryLineContent[1];
|
||
strCarID = "L" + aryLineContent[1];
|
||
}
|
||
else
|
||
{
|
||
labVIN.Text = strCarID;
|
||
tmdal.DeleteOneTTempVIN(strCarID);
|
||
MyBase.TraceWriteLine("在数据库表TTempSaveVIN中删除该VIN：" + strCarID);
|
||
}
|
||
}
|
||
if (LineNum >= 19)
|
||
{
|
||
aryLineContent = strLine.Split(',');
|
||
ConfigDfn.strMeasureTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
||
double dNormalValue = 0.0d;
|
||
|
||
dt = tmdal.SelectOneToleranceByCondition("EHY", aryLineContent[0], aryLineContent[1]);
|
||
if (dt.Rows.Count == 1)
|
||
{
|
||
dLowerValue = double.Parse(dt.Rows[0]["TolLower"].ToString());
|
||
dUpperValue = double.Parse(dt.Rows[0]["TolUpper"].ToString());
|
||
dNormalValue = (dLowerValue + dUpperValue) / 2;
|
||
dStrictTLower = CalculateStrictLowerTolerance(dLowerValue, dUpperValue);
|
||
dStrictTUpper = CalculateStrictUpperTolerance(dLowerValue, dUpperValue);
|
||
dExcepitonTLower = CalculateExceptionLowerTolerance(dLowerValue, dUpperValue);
|
||
dExceptionTUpper = CalculateExceptionUpperTolerance(dLowerValue, dUpperValue);
|
||
}
|
||
else
|
||
{
|
||
dStrictTLower = 0;
|
||
dStrictTUpper = 0;
|
||
dLowerValue = 0;
|
||
dUpperValue = 0;
|
||
MyBase.TraceWriteLine("EHY " + aryLineContent[0] + " " + aryLineContent[1] + " 查询数据获取公差带失败！数据库中数量不唯一或不存在，请检查公差带配置！");
|
||
}
|
||
|
||
if (aryLineContent[2].ToLower().Contains("inv"))
|
||
{
|
||
aryLineContent[4] = "UNCLASSIFIED";
|
||
}
|
||
else
|
||
{
|
||
dMeasureValue = double.Parse(aryLineContent[2]);
|
||
if (dMeasureValue >= dLowerValue && dMeasureValue <= dUpperValue)
|
||
{
|
||
aryLineContent[4] = "good";
|
||
}
|
||
else if (dMeasureValue >= dStrictTLower && dMeasureValue <= dStrictTUpper)
|
||
{
|
||
aryLineContent[4] = "ng1";
|
||
}
|
||
else if (dMeasureValue >= dExceptionTUpper || dMeasureValue <= dExcepitonTLower)
|
||
{
|
||
aryLineContent[4] = "ng3";
|
||
aryLineContent[2] = "inv";
|
||
}
|
||
else
|
||
{
|
||
aryLineContent[4] = "ng2";
|
||
}
|
||
}
|
||
|
||
//测量数据存储到table里
|
||
dtCSVContent.Rows.Add(strCarID, "EHY", aryLineContent[0], aryLineContent[1], dNormalValue.ToString("F1"), dLowerValue.ToString("F1"), dUpperValue.ToString("F1"), aryLineContent[2], aryLineContent[4], DateTime.Now, "");
|
||
string strMeasureResult = aryLineContent[4].ToLower();
|
||
if (strMeasureResult.Contains("good") || strMeasureResult.Contains("best"))
|
||
{
|
||
OKCount++;
|
||
aryLineContent[4] = "OK";
|
||
}
|
||
else if (strMeasureResult.Contains("ng1") || strMeasureResult.Contains("ng2"))
|
||
{
|
||
OutCount++;
|
||
aryLineContent[4] = "NG";
|
||
}
|
||
else
|
||
{
|
||
RejectedCount++;
|
||
aryLineContent[4] = "";
|
||
aryLineContent[2] = "";
|
||
}
|
||
|
||
dgvMeasureContent.Rows.Add(aryLineContent[0], aryLineContent[1], dNormalValue.ToString("F1"), dLowerValue.ToString("F1"), dUpperValue.ToString("F1"), aryLineContent[2], ConfigDfn.strMeasureTime, aryLineContent[4]);
|
||
|
||
CheryIOTData cIOTData = new CheryIOTData();
|
||
cIOTData.vin = strCarID;
|
||
cIOTData.gfNo = aryLineContent[1];
|
||
cIOTData.pointNumber = aryLineContent[0];
|
||
cIOTData.actualValue = aryLineContent[2];
|
||
cIOTData.controlLine = dLowerValue.ToString("F1") + @"/" + dUpperValue.ToString("F1");
|
||
if (strMeasureResult.Contains("good") || strMeasureResult.Contains("best") || strMeasureResult.Contains("ng1"))
|
||
{
|
||
cIOTData.measurementResult = "OK";
|
||
}
|
||
else
|
||
{
|
||
cIOTData.measurementResult = "NG";
|
||
}
|
||
ListPostIOTData.Add(cIOTData);
|
||
dtRowCount++;
|
||
dgvMeasureContent.Rows[dtRowCount - 1].HeaderCell.Value = dtRowCount.ToString();
|
||
}
|
||
}//End While
|
||
sr.Close();
|
||
fs.Close();
|
||
tmdal.InsertTMeasureDatabyDataTable(dtCSVContent);
|
||
MyBase.TraceWriteLine("解析EHY数据完成，并将所有测量数据插入到数据库完毕。");
|
||
MyBase.TraceWriteLine("解析NextSense EHY CSV 报告完毕！检查数量=" + dtRowCount.ToString());
|
||
if (dtRowCount <= ConfigDfn.iMeasureItemsCount)
|
||
{
|
||
iCurrentMeasureItemsFailedCount++;
|
||
}
|
||
else
|
||
{
|
||
iCurrentMeasureItemsFailedCount = 0;
|
||
}
|
||
|
||
if (iCurrentMeasureItemsFailedCount >= ConfigDfn.iFailedCarCount)
|
||
{
|
||
MyBase.TraceWriteLine("iCurrentMeasureItemsFailedCount=" + iCurrentMeasureItemsFailedCount.ToString() + "超过报警数量" + ConfigDfn.iFailedCarCount.ToString() + " ;给PLC发送报警10。");
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.MeasureError, (byte)10);
|
||
}
|
||
#endregion 解析EHY CSV报告
|
||
|
||
#region 计算极差
|
||
CalculateRange(strCarID, "EHY");
|
||
Thread.Sleep(20);
|
||
DataTable dtAllRangeDate = tmdal.SelectRangeDatabyCarID(strCarID);
|
||
if (dtAllRangeDate.Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in dtAllRangeDate.Rows)
|
||
{
|
||
if (ConfigDfn.iIncludeRangeFlag == 1)
|
||
{
|
||
if (row.ItemArray[5].ToString().Contains("OK"))
|
||
{
|
||
OKCount++;
|
||
}
|
||
else
|
||
{
|
||
OutCount++;
|
||
}
|
||
}
|
||
|
||
dgvMeasureContent.Rows.Add(row.ItemArray[2].ToString(), "G", "0", row.ItemArray[4].ToString().Substring(0, 3), row.ItemArray[4].ToString().Substring(4, 3), row.ItemArray[3].ToString(), ConfigDfn.strMeasureTime, row.ItemArray[5].ToString());
|
||
}
|
||
}
|
||
|
||
if (ConfigDfn.iIncludeRangeFlag == 1)
|
||
{
|
||
dtRowCount = dtRowCount + dtAllRangeDate.Rows.Count;
|
||
for (int i = 1; i <= dtRowCount; i++)
|
||
{
|
||
dgvMeasureContent.Rows[i - 1].HeaderCell.Value = i.ToString();
|
||
}
|
||
MyBase.TraceWriteLine("计算合格率的时：包含极差计算项！");
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 界面显示功能
|
||
|
||
labCarType.Text = "EHY";
|
||
TMeasureResultModel tmrm = new TMeasureResultModel();
|
||
labNGCount.Text = OutCount.ToString();
|
||
labOKCount.Text = OKCount.ToString();
|
||
labRejectCount.Text = RejectedCount.ToString();
|
||
labMeaTime.Text = ConfigDfn.strMeasureTime;
|
||
labSumMeasureCount.Text = dtRowCount.ToString();
|
||
FPYPercent = OKCount / (OKCount + OutCount);
|
||
if (FPYPercent >= ConfigDfn.dFPY)
|
||
{
|
||
labResultPercent.Text = Math.Round(FPYPercent * 100.00d, 2).ToString("F2") + "%";
|
||
labResult.Text = "合格";
|
||
labResultPercent.ForeColor = Color.LimeGreen;
|
||
labResult.ForeColor = Color.LimeGreen;
|
||
pbResult.Image = Resources.OK;
|
||
tmrm.Result = 1;
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.CMMResult, (byte)10);
|
||
}
|
||
else if (FPYPercent >= ConfigDfn.dFPY2 && FPYPercent < ConfigDfn.dFPY)
|
||
{
|
||
labResultPercent.Text = Math.Round(FPYPercent * 100.00d, 2).ToString("F2") + "%";
|
||
labResult.Text = "合格";
|
||
labResultPercent.ForeColor = Color.Yellow;
|
||
labResult.ForeColor = Color.Yellow;
|
||
pbResult.Image = Resources.OK;
|
||
tmrm.Result = 1;
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.CMMResult, (byte)20);
|
||
}
|
||
else
|
||
{
|
||
labResultPercent.Text = Math.Round(FPYPercent * 100.00d, 2).ToString("F2") + "%";
|
||
labResult.Text = "不合格";
|
||
labResultPercent.ForeColor = Color.Red;
|
||
labResult.ForeColor = Color.Red;
|
||
pbResult.Image = Resources.NG;
|
||
tmrm.Result = 2;
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.CMMResult, (byte)30);
|
||
}
|
||
xValues[0] = "合格 : " + OKCount.ToString();
|
||
xValues[1] = "不合格 : " + OutCount.ToString();
|
||
xValues[2] = "异常 : " + RejectedCount.ToString();
|
||
yValues[0] = (int)OKCount;
|
||
yValues[1] = (int)OutCount;
|
||
yValues[2] = (int)RejectedCount;
|
||
chartResultPie.Series[0].Points.DataBindXY(xValues, yValues);
|
||
|
||
string strTargetRate = Math.Round(ConfigDfn.dFPY2 * 100.00d, 2).ToString("F2") + "%";
|
||
|
||
tmrm.CarID = strCarID;
|
||
tmrm.CarType = "EHY";
|
||
tmrm.SumMeasureItems = dtRowCount;
|
||
tmrm.GoodMeasureItems = (int)OKCount;
|
||
tmrm.NoGoodMeasureItems = (int)OutCount;
|
||
tmrm.RejectMeasureItems = (int)RejectedCount;
|
||
tmrm.FPY = FPYPercent.ToString("F4");
|
||
tmrm.Remark = "";
|
||
tmrm.MeasureDate = ConfigDfn.strMeasureTime;
|
||
tmdal.InsertTMeasureResult(tmrm);
|
||
MyBase.TraceWriteLine("将总结果插入数据库完毕。");
|
||
MyBase.TraceWriteLine("全部插入解析完毕，删除文件：" + fi.Name);
|
||
fi.Delete();
|
||
|
||
dgvMeasureContent.Rows.Add();
|
||
dgvMeasureContent.Rows[dgvMeasureContent.Rows.Count - 1].Cells["MResult"].Value = (dtRowCount - OutCount - RejectedCount).ToString() + "/" + dtRowCount.ToString();
|
||
this.dgvMeasureContent.Rows[dgvMeasureContent.Rows.Count - 1].DefaultCellStyle.ForeColor = Color.White;
|
||
if (dgvMeasureContent.Rows.Count > 0)
|
||
{
|
||
SetdgvRowBgColor(dgvMeasureContent);
|
||
for (int i = 0; i < dgvMeasureContent.Rows.Count; i++)
|
||
{
|
||
//if (dgvMeasureContent.Rows[i].Cells["MResult"].Value.ToString().ToLower().Contains("ok"))
|
||
//{
|
||
// dgvMeasureContent.Rows[i].DefaultCellStyle.BackColor = Color.Orange;
|
||
//}
|
||
if (dgvMeasureContent.Rows[i].Cells["MResult"].Value.ToString().ToLower().Contains("ng"))
|
||
{
|
||
dgvMeasureContent.Rows[i].DefaultCellStyle.BackColor = Color.Orange;
|
||
}
|
||
else if (string.IsNullOrEmpty(dgvMeasureContent.Rows[i].Cells["MResult"].Value.ToString()))
|
||
{
|
||
dgvMeasureContent.Rows[i].DefaultCellStyle.BackColor = Color.Red;
|
||
}
|
||
else
|
||
{
|
||
}
|
||
}
|
||
}
|
||
|
||
#endregion 界面显示功能
|
||
|
||
|
||
if (ConfigDfn.iCreateReportFlag == 1)
|
||
{
|
||
#region 解析完报告后，重新生成客户模板报告
|
||
|
||
MyBase.TraceWriteLine("开始生成客户所需要的CSV格式文件：");
|
||
string filePath = strSaveReprotPath + DateTime.Now.ToString("yyyyMMddHHmmss") + "_" + strCarID + ".csv"; //wsp 后期还要再改
|
||
string strWithoutLCarVin = strCarID.Substring(1);
|
||
StringBuilder sb = new StringBuilder();
|
||
//添加表头
|
||
sb.Append("Measurement Info Name");
|
||
sb.Append(",");
|
||
sb.Append("Measurement Info");
|
||
sb.AppendLine();
|
||
sb.Append("Date_Time");
|
||
sb.Append(",");
|
||
sb.Append(DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
|
||
sb.AppendLine();
|
||
for (int i = 0; i < listCSVTitleInfo.Count; i++)
|
||
{
|
||
if (listCSVTitleInfo[i].Contains("prodnum"))
|
||
{
|
||
listCSVTitleInfo[i] = listCSVTitleInfo[i].Replace("prodnum", "Part_ident");
|
||
}
|
||
if (listCSVTitleInfo[i].Contains(strWithoutLCarVin))
|
||
{
|
||
listCSVTitleInfo[i] = listCSVTitleInfo[i].Replace(strWithoutLCarVin, strCarID);
|
||
}
|
||
sb.Append(listCSVTitleInfo[i]);
|
||
sb.AppendLine();
|
||
}
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
//添加测量数据
|
||
sb.Append("Characteristic");
|
||
sb.Append(",");
|
||
sb.Append("Extension");
|
||
sb.Append(",");
|
||
sb.Append("Measured_Value");
|
||
sb.AppendLine();
|
||
foreach (DataRow row in dtCSVContent.Rows)
|
||
{
|
||
sb.Append(row.ItemArray[2]);
|
||
sb.Append(",");
|
||
sb.Append(row.ItemArray[3]);
|
||
sb.Append(",");
|
||
sb.Append(row.ItemArray[7]);
|
||
sb.AppendLine();
|
||
}
|
||
if (dtAllRangeDate.Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in dtAllRangeDate.Rows)
|
||
{
|
||
sb.Append(row.ItemArray[2]);
|
||
sb.Append(",");
|
||
sb.Append("G");
|
||
sb.Append(",");
|
||
sb.Append(row.ItemArray[3]);
|
||
sb.AppendLine();
|
||
}
|
||
}
|
||
sb.Append("POP");
|
||
sb.Append(",");
|
||
sb.Append("P");
|
||
sb.Append(",");
|
||
sb.Append(Math.Round(FPYPercent * 100.00d, 2).ToString("F2"));
|
||
sb.AppendLine();
|
||
// 将数据写入CSV文件
|
||
File.WriteAllText(filePath, sb.ToString());
|
||
MyBase.TraceWriteLine("客户EHY csv报告生成完毕，路径为：" + filePath);
|
||
|
||
#endregion 解析完报告后，重新生成客户模板报告
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine("iCreateReportFlag=0 : EHY数据生成报告功能未启用！");
|
||
}
|
||
|
||
|
||
#region Update Data To IOT
|
||
|
||
if (ConfigDfn.iStartIOTFlag == 1)
|
||
{
|
||
bool bVINMeasuedFlag = tmdal.CheckVINExistInDB(strCarID);
|
||
if (bVINMeasuedFlag)
|
||
{
|
||
MyBase.TraceWriteLine("VIN:" + strCarID + " 该VIN码已经在数据库中存在了，说明已经测量过了，不再进行IOT数据上传操作。");
|
||
}
|
||
else
|
||
{
|
||
#region IOT上传功能
|
||
|
||
if (dtAllRangeDate.Rows.Count > 0)
|
||
{
|
||
foreach (DataRow row in dtAllRangeDate.Rows)
|
||
{
|
||
|
||
CheryIOTData cIOTData = new CheryIOTData();
|
||
cIOTData.vin = strCarID;
|
||
cIOTData.gfNo = "G";
|
||
cIOTData.pointNumber = row.ItemArray[2].ToString();
|
||
cIOTData.actualValue = row.ItemArray[3].ToString();
|
||
cIOTData.controlLine = row.ItemArray[4].ToString();
|
||
cIOTData.measurementResult = row.ItemArray[5].ToString();
|
||
if (cIOTData.measurementResult.ToUpper().Contains("NG"))
|
||
{
|
||
if (!cIOTData.actualValue.ToLower().Contains("inv"))
|
||
{
|
||
dLowerValue = double.Parse(row.ItemArray[4].ToString().Substring(0, 3));
|
||
dUpperValue = double.Parse(row.ItemArray[4].ToString().Substring(4, 3));
|
||
dStrictTLower = CalculateStrictLowerTolerance(dLowerValue, dUpperValue);
|
||
dStrictTUpper = CalculateStrictUpperTolerance(dLowerValue, dUpperValue);
|
||
double dValue = double.Parse(row.ItemArray[3].ToString());
|
||
if (dValue > dStrictTLower && dValue < dStrictTUpper)
|
||
{
|
||
cIOTData.measurementResult = "OK";
|
||
}
|
||
}
|
||
}
|
||
ListPostIOTData.Add(cIOTData);
|
||
}
|
||
}
|
||
string strGapList = JsonHelper.ObjectToJson(ListPostIOTData);
|
||
string strCaliResult = "OK";
|
||
if (labResult.Text == "合格")
|
||
{
|
||
strCaliResult = "OK";
|
||
}
|
||
else
|
||
{
|
||
strCaliResult = "NG";
|
||
}
|
||
string strPostData = "{\"serno\":\"" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + "\",\"requestData\":[{\"vin\":\"" + strCarID + "\",\"model\":\"EHY\",\"equipmentNo\":\"" + ConfigDfn.strEquipNo + "\",\"equipmentName\":\"" + ConfigDfn.strEquipName + "\",\"calibrationResult\":\"" + strCaliResult + "\",\"detectionTime\":\"" + ConfigDfn.strMeasureTime + "\",\"targetRate\":\"" + strTargetRate + "\",\"rate\":\"" + labResultPercent.Text + "\",\"GapList\":" + strGapList + "}]}";
|
||
MyBase.TraceWriteLine("Update To IOT Data Content: " + strPostData);
|
||
string strPostResult = PostJsonToIOT(ConfigDfn.strIOTAddress, strPostData, 10000);
|
||
MyBase.TraceWriteLine("EHY数据上传IOT完成，结果返回为：" + strPostResult);
|
||
if (strPostResult.Contains("成功"))
|
||
{
|
||
MyBase.TraceWriteLine("EHY数据上传IOT成功 ^_^");
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine("EHY数据上传IOT失败！");
|
||
}
|
||
|
||
#endregion IOT上传功能
|
||
}
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine("EHY数据上传IOT功能未启用！");
|
||
}
|
||
|
||
#endregion Update Data To IOT
|
||
}
|
||
}
|
||
}
|
||
//else
|
||
//{
|
||
// MyBase.TraceWriteLine("错误：AnalysisNextSenseEHYCSV 函数中，检测EHY CSV 路径不存在：" + ConfigDfn.strNextSenseCSVEHYPath);
|
||
//}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
MyBase.TraceWriteLine("AnalysisNextSenseEHYCSV 函数分析异常：" + ex.ToString());
|
||
}
|
||
}
|
||
|
||
private void CalculateRange(string strVIN, string strCarType)
|
||
{
|
||
MyBase.TraceWriteLine(strVIN + " " + strCarType + "开始计算极差：============");
|
||
tmdal.DeleteRangeData(strVIN);
|
||
dtRangeData.Clear();
|
||
DataTable dtRange = tmdal.SelectRangeByCarType(strCarType);
|
||
if (dtRange != null && dtRange.Rows.Count > 0)
|
||
{
|
||
string strRangeValue = "";
|
||
string strRangeLowUpp = "";
|
||
string strRangeResult = "";
|
||
DateTime dtTime = DateTime.Now;
|
||
string strRemark = "";
|
||
for (int i = 0; i < dtRange.Rows.Count; i++)
|
||
{
|
||
string[] strArrRangePoint = dtRange.Rows[i]["RangePoint"].ToString().Split(',');
|
||
double[] dMeasureData = new double[strArrRangePoint.Length];
|
||
int iCalcCount = 0;
|
||
for (int j = 0; j < strArrRangePoint.Length; j++)
|
||
{
|
||
string strMeasureValue = tmdal.SelectOneMeasureValueByCondition(strVIN, strArrRangePoint[j].Substring(0, 4));
|
||
if (strMeasureValue.ToLower().Contains("inv"))
|
||
{
|
||
strRangeValue = "inv";
|
||
strRangeResult = "NG";
|
||
MyBase.TraceWriteLine(strArrRangePoint[j] + " G 查询的测量值为inv");
|
||
break;
|
||
}
|
||
else if (strMeasureValue.ToLower().Contains("nofind"))
|
||
{
|
||
strRangeValue = "inv";
|
||
strRangeResult = "NG";
|
||
MyBase.TraceWriteLine(strArrRangePoint[j] + " G 查询的测量值为no find");
|
||
break;
|
||
}
|
||
else
|
||
{
|
||
dMeasureData[j] = Convert.ToDouble(strMeasureValue);
|
||
iCalcCount++;
|
||
}
|
||
}
|
||
if (iCalcCount == strArrRangePoint.Length)
|
||
{
|
||
double dMax = dMeasureData.Max();
|
||
double dMin = dMeasureData.Min();
|
||
double dRangeData = dMax - dMin;
|
||
strRangeValue = dRangeData.ToString("F1");
|
||
if (dRangeData >= Convert.ToDouble(dtRange.Rows[i]["RangeLower"]) && dRangeData <= Convert.ToDouble(dtRange.Rows[i]["RangeUpper"]))
|
||
{
|
||
strRangeResult = "OK";
|
||
}
|
||
else
|
||
{
|
||
strRangeResult = "NG";
|
||
}
|
||
}
|
||
strRangeLowUpp = dtRange.Rows[i]["RangeLower"].ToString() + @"/" + dtRange.Rows[i]["RangeUpper"].ToString();
|
||
dtRangeData.Rows.Add(strVIN, dtRange.Rows[i]["RangeName"].ToString(), strRangeValue, strRangeLowUpp, strRangeResult, dtTime, strRemark);
|
||
}
|
||
tmdal.InsertTRangeDatabyDataTable(dtRangeData);
|
||
MyBase.TraceWriteLine(strVIN + " " + strCarType + "计算极差完成，并插入数据库：============");
|
||
}
|
||
|
||
}
|
||
|
||
public string PostJsonToIOT(string url, string jsonData, int? timeout = null)
|
||
{
|
||
try
|
||
{
|
||
HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(url);
|
||
|
||
if (null != timeout && 0 != timeout)
|
||
{
|
||
req.Timeout = timeout.Value;
|
||
}
|
||
Encoding encoding = Encoding.UTF8;
|
||
byte[] bs = Encoding.UTF8.GetBytes(jsonData);
|
||
string responseData;
|
||
req.Method = "POST";
|
||
req.ContentType = "application/json";
|
||
req.ContentLength = bs.Length;
|
||
using (Stream reqStream = req.GetRequestStream())
|
||
{
|
||
reqStream.Write(bs, 0, bs.Length);
|
||
reqStream.Close();
|
||
}
|
||
using (HttpWebResponse response = (HttpWebResponse)req.GetResponse())
|
||
{
|
||
using (StreamReader reader = new StreamReader(response.GetResponseStream(), encoding))
|
||
{
|
||
responseData = reader.ReadToEnd();
|
||
}
|
||
}
|
||
return responseData;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
return "Error: " + ex.ToString();
|
||
}
|
||
}
|
||
|
||
/// 通过给定的文件流，判断文件的编码类型
|
||
/// <param name="fs">文件流</param>
|
||
/// <returns>文件的编码类型</returns>
|
||
public static Encoding GetType(FileStream fs)
|
||
{
|
||
byte[] Unicode = new byte[] { 0xFF, 0xFE, 0x41 };
|
||
byte[] UnicodeBIG = new byte[] { 0xFE, 0xFF, 0x00 };
|
||
byte[] UTF8 = new byte[] { 0xEF, 0xBB, 0xBF }; //带BOM
|
||
System.Text.Encoding reVal = System.Text.Encoding.Default;
|
||
|
||
System.IO.BinaryReader r = new System.IO.BinaryReader(fs, System.Text.Encoding.Default);
|
||
int i;
|
||
int.TryParse(fs.Length.ToString(), out i);
|
||
byte[] ss = r.ReadBytes(i);
|
||
if (IsUTF8Bytes(ss) || (ss[0] == 0xEF && ss[1] == 0xBB && ss[2] == 0xBF))
|
||
{
|
||
reVal = System.Text.Encoding.UTF8;
|
||
}
|
||
else if (ss[0] == 0xFE && ss[1] == 0xFF && ss[2] == 0x00)
|
||
{
|
||
reVal = System.Text.Encoding.BigEndianUnicode;
|
||
}
|
||
else if (ss[0] == 0xFF && ss[1] == 0xFE && ss[2] == 0x41)
|
||
{
|
||
reVal = System.Text.Encoding.Unicode;
|
||
}
|
||
r.Close();
|
||
return reVal;
|
||
}
|
||
|
||
/// 判断是否是不带 BOM 的 UTF8 格式
|
||
/// <param name="data"></param>
|
||
/// <returns></returns>
|
||
private static bool IsUTF8Bytes(byte[] data)
|
||
{
|
||
int charByteCounter = 1; //计算当前正分析的字符应还有的字节数
|
||
byte curByte; //当前分析的字节.
|
||
for (int i = 0; i < data.Length; i++)
|
||
{
|
||
curByte = data[i];
|
||
if (charByteCounter == 1)
|
||
{
|
||
if (curByte >= 0x80)
|
||
{
|
||
//判断当前
|
||
while (((curByte <<= 1) & 0x80) != 0)
|
||
{
|
||
charByteCounter++;
|
||
}
|
||
//标记位首位若为非0 则至少以2个1开始 如:110XXXXX...........1111110X
|
||
if (charByteCounter == 1 || charByteCounter > 6)
|
||
{
|
||
return false;
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
//若是UTF-8 此时第一位必须为1
|
||
if ((curByte & 0xC0) != 0x80)
|
||
{
|
||
return false;
|
||
}
|
||
charByteCounter--;
|
||
}
|
||
}
|
||
if (charByteCounter > 1)
|
||
{
|
||
throw new Exception("非预期的byte格式");
|
||
}
|
||
return true;
|
||
}
|
||
|
||
public Encoding GetType(string FileName)
|
||
{
|
||
FileStream fs = new FileStream(FileName, FileMode.Open, FileAccess.Read);
|
||
Encoding er = GetType(fs);
|
||
fs.Close();
|
||
return er;
|
||
}
|
||
|
||
|
||
private void AnalysisNextSenseSelfMeasureCSV()
|
||
{
|
||
try
|
||
{
|
||
lbCSVFiles.Items.Clear();
|
||
FileInfo[] fileInfos = null;
|
||
if (Directory.Exists(ConfigDfn.strNextSenseSelfMeasurePath))
|
||
{
|
||
DirectoryInfo di = new DirectoryInfo(ConfigDfn.strNextSenseSelfMeasurePath);
|
||
fileInfos = di.GetFiles("*.CSV");
|
||
if (fileInfos.Count() >= 1)
|
||
{
|
||
MyBase.TraceWriteLine("存在EHY CSV文件，开始解析：");
|
||
List<string> listCSVTitleInfo = new List<string>();
|
||
string strCarID = "SelfMeasure" + DateTime.Now.ToString("yyyyMMddHHmmss");
|
||
foreach (FileInfo fi in fileInfos)
|
||
{
|
||
listCSVTitleInfo.Clear();
|
||
ListPostIOTData.Clear();
|
||
dtCSVContent.Clear();
|
||
dgvMeasureContent.Rows.Clear();
|
||
string strCSVName = fi.FullName;
|
||
File.Copy(fi.FullName, ConfigDfn.strFileFolder + "\\NextSenseCSVBackup\\" + fi.Name, true);
|
||
MyBase.TraceWriteLine("Copy " + fi.FullName + " TO " + ConfigDfn.strFileFolder + "\\NextSenseCSVBackup\\" + fi.Name + " Done. 备份完成");
|
||
lbCSVFiles.Items.Add(fi.Name);
|
||
|
||
#region 解析NextSense自检CSV报告
|
||
|
||
MyBase.TraceWriteLine("开始解析NextSense EHY CSV 报告：" + strCSVName);
|
||
Encoding encoding = GetType(strCSVName);
|
||
FileStream fs = new FileStream(strCSVName, FileMode.Open, FileAccess.Read);
|
||
StreamReader sr = new StreamReader(fs, encoding);
|
||
//记录每次读取的一行记录
|
||
string strLine = "";
|
||
//记录每行记录中的各字段内容
|
||
string[] aryLineContent = null;
|
||
|
||
//逐行读取CSV中的数据
|
||
int LineNum = 0;
|
||
//表格行数
|
||
int dtRowCount = 0;
|
||
|
||
while ((strLine = sr.ReadLine()) != null)
|
||
{
|
||
LineNum++;
|
||
if (LineNum >= 1 & LineNum <= 17)
|
||
{
|
||
listCSVTitleInfo.Add(strLine);
|
||
}
|
||
if (LineNum >= 19)
|
||
{
|
||
aryLineContent = strLine.Split(',');
|
||
ConfigDfn.strMeasureTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
||
|
||
|
||
if (aryLineContent[2].ToLower().Contains("inv"))
|
||
{
|
||
aryLineContent[10] = "NG";
|
||
}
|
||
string strMeasPointName = "";
|
||
if (aryLineContent[0].ToUpper().Contains("L"))
|
||
{
|
||
strMeasPointName = "L-ZJ1";
|
||
}
|
||
else
|
||
{
|
||
strMeasPointName = "R-ZJ1";
|
||
}
|
||
//测量数据存储到table里
|
||
dtCSVContent.Rows.Add(strCarID, "SelfMeasure", strMeasPointName, aryLineContent[1], aryLineContent[4], aryLineContent[8], aryLineContent[9], aryLineContent[2], aryLineContent[10], DateTime.Now, "");
|
||
|
||
|
||
dgvMeasureContent.Rows.Add(strMeasPointName, aryLineContent[1], aryLineContent[4], aryLineContent[8], aryLineContent[9], aryLineContent[2], ConfigDfn.strMeasureTime, aryLineContent[10]);
|
||
|
||
dtRowCount++;
|
||
dgvMeasureContent.Rows[dtRowCount - 1].HeaderCell.Value = dtRowCount.ToString();
|
||
}
|
||
}//End While
|
||
sr.Close();
|
||
fs.Close();
|
||
|
||
MyBase.TraceWriteLine("解析NextSense 自检报告完毕！检查数量=" + dtRowCount.ToString());
|
||
labCarType.Text = "自检报告";
|
||
|
||
fi.Delete();
|
||
#endregion 解析EHY CSV报告
|
||
|
||
if (ConfigDfn.iCreateReportFlag == 1)
|
||
{
|
||
#region 解析完报告后，重新生成客户模板报告
|
||
|
||
MyBase.TraceWriteLine("开始生成客户所需要的CSV格式文件：");
|
||
string filePath = strSaveReprotPath + DateTime.Now.ToString("yyyyMMddHHmmss") + "_" + strCarID + ".csv"; //wsp 后期还要再改
|
||
StringBuilder sb = new StringBuilder();
|
||
//添加表头
|
||
sb.Append("Measurement Info Name");
|
||
sb.Append(",");
|
||
sb.Append("Measurement Info");
|
||
sb.AppendLine();
|
||
sb.Append("Date_Time");
|
||
sb.Append(",");
|
||
sb.Append(DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
|
||
sb.AppendLine();
|
||
for (int i = 2; i < listCSVTitleInfo.Count-1; i++)
|
||
{
|
||
if (listCSVTitleInfo[i].Contains("prodnum"))
|
||
{
|
||
listCSVTitleInfo[i] = listCSVTitleInfo[i].Replace("prodnum,", "Part_ident,"+ DateTime.Now.ToString("yyyyMMdd"));
|
||
}
|
||
|
||
sb.Append(listCSVTitleInfo[i]);
|
||
sb.AppendLine();
|
||
}
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
sb.AppendLine();
|
||
//添加测量数据
|
||
sb.Append("Characteristic");
|
||
sb.Append(",");
|
||
sb.Append("Extension");
|
||
sb.Append(",");
|
||
sb.Append("Measured_Value");
|
||
sb.AppendLine();
|
||
foreach (DataRow row in dtCSVContent.Rows)
|
||
{
|
||
sb.Append(row.ItemArray[2]);
|
||
sb.Append(",");
|
||
sb.Append(row.ItemArray[3]);
|
||
sb.Append(",");
|
||
sb.Append(row.ItemArray[7]);
|
||
sb.AppendLine();
|
||
}
|
||
sb.AppendLine();
|
||
// 将数据写入CSV文件
|
||
File.WriteAllText(filePath, sb.ToString());
|
||
MyBase.TraceWriteLine("客户自检报告生成完毕，路径为：" + filePath);
|
||
|
||
#endregion 解析完报告后，重新生成客户模板报告
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine("iCreateReportFlag=0 : 数据生成报告功能未启用！");
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
MyBase.TraceWriteLine("AnalysisNextSenseSelfMeasureCSV 函数分析异常：" + ex.ToString());
|
||
}
|
||
}
|
||
#endregion 解析Nextsense CSV文件功能
|
||
|
||
#region Home Page
|
||
|
||
/// <summary>
|
||
/// 设置DataGridView各行变色
|
||
/// </summary>
|
||
/// <param name="dgv">DataGridView</param>
|
||
public void SetdgvRowBgColor(DataGridView dgv)
|
||
{
|
||
if (dgv.Rows.Count > 0)
|
||
{
|
||
foreach (DataGridViewRow item in dgv.Rows)
|
||
{
|
||
if (item.Index % 2 == 0)
|
||
{
|
||
item.DefaultCellStyle.BackColor = Color.FromArgb(19, 46, 53);
|
||
}
|
||
else
|
||
{
|
||
item.DefaultCellStyle.BackColor = Color.FromArgb(27, 60, 68);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
//TODO:
|
||
|
||
#endregion Home Page
|
||
|
||
#region Search Data
|
||
|
||
#region datagridview分页功能
|
||
|
||
/// <summary>
|
||
/// LoadPage方法
|
||
/// </summary>
|
||
private void LoadPage()
|
||
{
|
||
if (currentPage < 1) currentPage = 1;
|
||
if (currentPage > pageCount) currentPage = pageCount;
|
||
|
||
int beginRecord; //开始指针
|
||
int endRecord; //结束指针
|
||
DataTable dtTemp;
|
||
dtTemp = PageTable.Clone();//Clone方法只会复制DataTable的结构（列定义），而不会复制数据行的引用。
|
||
|
||
beginRecord = pageSize * (currentPage - 1);
|
||
if (currentPage == 1) beginRecord = 0;
|
||
endRecord = pageSize * currentPage;
|
||
|
||
if (currentPage == pageCount) endRecord = recordCount;
|
||
for (int i = beginRecord; i < endRecord; i++)
|
||
{
|
||
// 使用ImportRow方法将源PageTable的行导入到目标dtTemp
|
||
dtTemp.ImportRow(PageTable.Rows[i]);
|
||
}
|
||
|
||
dgvSelectMeasureData.Rows.Clear();
|
||
|
||
for (int i = 0; i < dtTemp.Rows.Count; i++)
|
||
{
|
||
dgvSelectMeasureData.Rows.Add(new object[] { dtTemp.Rows[i][0], dtTemp.Rows[i][1], dtTemp.Rows[i][2], dtTemp.Rows[i][3], dtTemp.Rows[i][4], dtTemp.Rows[i][5], dtTemp.Rows[i][6], dtTemp.Rows[i][7], dtTemp.Rows[i][8] });
|
||
}
|
||
SetdgvRowBgColor(dgvSelectMeasureData);
|
||
for (int i = 0; i < dgvSelectMeasureData.Rows.Count; i++)
|
||
{
|
||
string strResult = dgvSelectMeasureData.Rows[i].Cells["MeasureItemResult"].Value.ToString();
|
||
if (strResult.ToLower().Contains("ng"))
|
||
{
|
||
//dgvSelectMeasureData.Rows[i].Cells["MeasureItemResult"].Style.ForeColor = Color.Orange;
|
||
dgvSelectMeasureData.Rows[i].DefaultCellStyle.BackColor = Color.Orange;
|
||
}
|
||
if (strResult.ToLower().Contains("rej"))
|
||
{
|
||
dgvSelectMeasureData.Rows[i].Cells["MeasureItemResult"].Style.ForeColor = Color.Red;
|
||
}
|
||
}
|
||
labCurrentPage.Text = "当前页：" + currentPage.ToString(); //当前页
|
||
labSumPages.Text = "共 " + pageCount.ToString() + " 页";//总页数
|
||
labSumRecorders.Text = "总共 " + recordCount.ToString() + " 条记录";//总记录数
|
||
}
|
||
|
||
private void rbtnFirtstPage_Click(object sender, EventArgs e)
|
||
{
|
||
if (currentPage == 1)
|
||
{ return; }
|
||
currentPage = 1;
|
||
LoadPage();
|
||
}
|
||
|
||
private void rbtnPrevPage_Click(object sender, EventArgs e)
|
||
{
|
||
if (currentPage == 1)
|
||
{ return; }
|
||
currentPage--;
|
||
LoadPage();
|
||
}
|
||
|
||
private void rbtnNextPage_Click(object sender, EventArgs e)
|
||
{
|
||
if (currentPage == pageCount)
|
||
{ return; }
|
||
currentPage++;
|
||
LoadPage();
|
||
}
|
||
|
||
private void rbtnLastPage_Click(object sender, EventArgs e)
|
||
{
|
||
if (currentPage == pageCount)
|
||
{ return; }
|
||
currentPage = pageCount;
|
||
LoadPage();
|
||
}
|
||
|
||
private void rddlPageRecorderCount_SelectedIndexChanged(object sender, Telerik.WinControls.UI.Data.PositionChangedEventArgs e)
|
||
{
|
||
pageSize = int.Parse(rddlPageRecorderCount.Text.Trim());
|
||
//PageSorter();
|
||
}
|
||
|
||
#endregion datagridview分页功能
|
||
|
||
private void rbtnSearchMeaserData_Click(object sender, EventArgs e)
|
||
{
|
||
dgvFPYResult.Visible = false;
|
||
chartFPYLine.Visible = false;
|
||
rbtnExportCSVReport.Visible = false;
|
||
string strStartTime = rdtpStartTime.Value.ToString("yyyy-MM-dd") + " 00:00:00";
|
||
string strEndTime = rdtpEndTime.Value.ToString("yyyy-MM-dd") + " 23:59:59";
|
||
string strCarID = rtbPartID.Text.Trim();
|
||
PageTable.Clear();
|
||
PageTable = tmdal.SelectTMeasureDataByCarIDAndTime(strCarID, strStartTime, strEndTime);
|
||
if (PageTable.Rows.Count > 0)
|
||
{
|
||
recordCount = PageTable.Rows.Count; //记录总行数
|
||
pageCount = (recordCount / pageSize);
|
||
if ((recordCount % pageSize) > 0)
|
||
{
|
||
pageCount++;
|
||
}
|
||
|
||
//默认第一页
|
||
currentPage = 1;
|
||
|
||
LoadPage();//调用加载数据的方法
|
||
dgvSelectMeasureData.Visible = true;
|
||
rbtnExportCSVReport.Visible = true;
|
||
pnlPage.Visible = true;
|
||
labSearchResult.Visible = false;
|
||
pnlPage.Visible = true;
|
||
}
|
||
else
|
||
{
|
||
dgvSelectMeasureData.Visible = false;
|
||
labSearchResult.Visible = true;
|
||
rbtnExportCSVReport.Visible = false;
|
||
pnlPage.Visible = false;
|
||
}
|
||
}
|
||
|
||
private void rbtSelectFPY_Click(object sender, EventArgs e)
|
||
{
|
||
dgvSelectMeasureData.Visible = false;
|
||
rbtnExportCSVReport.Visible = false;
|
||
pnlPage.Visible = false;
|
||
string strStartTime = rdtpStartTime.Value.ToString("yyyy-MM-dd") + " 00:00:00";
|
||
string strEndTime = rdtpEndTime.Value.ToString("yyyy-MM-dd") + " 23:59:59";
|
||
string strCarID = rtbPartID.Text.Trim();
|
||
DataTable dtFPY = new DataTable();
|
||
dtFPY = tmdal.SelectTMeasureResultByTime(strCarID, strStartTime, strEndTime);
|
||
if (dtFPY.Rows.Count > 0)
|
||
{
|
||
dgvFPYResult.Visible = true;
|
||
labSearchResult.Visible = false;
|
||
rbtnExportCSVReport.Visible = true;
|
||
chartFPYLine.Visible = true;
|
||
dgvFPYResult.DataSource = dtFPY;
|
||
SetdgvRowBgColor(dgvFPYResult);
|
||
for (int i = 0; i < dgvFPYResult.Rows.Count; i++)
|
||
{
|
||
if (dgvFPYResult.Rows[i].Cells["SMResult"].Value.ToString().ToLower().Contains("不合格"))
|
||
{
|
||
dgvFPYResult.Rows[i].Cells["SMResult"].Style.ForeColor = Color.Red;
|
||
}
|
||
}
|
||
|
||
#region 合格率折线图
|
||
|
||
//合格率折线图
|
||
string[] strXDate = new string[dtFPY.Rows.Count];
|
||
double[] dFPYResult = new double[dtFPY.Rows.Count];
|
||
for (int i = 0; i < dtFPY.Rows.Count; i++)
|
||
{
|
||
strXDate[i] = dtFPY.Rows[i]["CarID"].ToString();
|
||
}
|
||
for (int i = 0; i < dtFPY.Rows.Count; i++)
|
||
{
|
||
double dResult = double.Parse(dtFPY.Rows[i]["FPY"].ToString());
|
||
dFPYResult[i] = dResult * 100.00;
|
||
}
|
||
chartFPYLine.ChartAreas[0].AxisX.LabelStyle.Angle = -50; //X轴标签倾斜角度设置
|
||
chartFPYLine.ChartAreas[0].AxisY.LabelStyle.Format = "{0:F2}" + "%"; //设置Y轴值的格式化 带%
|
||
chartFPYLine.Series[0].Label = "#VAL%"; //设置显示Y的值
|
||
chartFPYLine.Series[0].LabelForeColor = Color.White;
|
||
chartFPYLine.Series[0].ToolTip = "车身编号 : #VALX \r\n合格率 : #VAL%"; //鼠标移动到对应点显示数值
|
||
chartFPYLine.Series[0].Points.DataBindXY(strXDate, dFPYResult);
|
||
|
||
#endregion 合格率折线图
|
||
}
|
||
else
|
||
{
|
||
dgvFPYResult.Visible = false;
|
||
labSearchResult.Visible = true;
|
||
rbtnExportCSVReport.Visible = false;
|
||
chartFPYLine.Visible = false;
|
||
}
|
||
}
|
||
|
||
public static void ExportdgvDataToCsv(DataGridView dataGridView, string filePath)
|
||
{
|
||
StringBuilder sb = new StringBuilder();
|
||
|
||
// 添加列标题
|
||
foreach (DataGridViewColumn column in dataGridView.Columns)
|
||
{
|
||
sb.Append(column.HeaderText);
|
||
sb.Append(",");
|
||
}
|
||
sb.Remove(sb.Length - 1, 1);
|
||
sb.AppendLine();
|
||
|
||
// 添加行数据
|
||
foreach (DataGridViewRow row in dataGridView.Rows)
|
||
{
|
||
foreach (DataGridViewCell cell in row.Cells)
|
||
{
|
||
sb.Append(cell.Value);
|
||
sb.Append(",");
|
||
}
|
||
sb.Remove(sb.Length - 1, 1);
|
||
sb.AppendLine();
|
||
}
|
||
|
||
// 将数据写入CSV文件
|
||
File.WriteAllText(filePath, sb.ToString());
|
||
}
|
||
|
||
public static void ExportDataTableDataToCsv(DataTable dt, string filePath)
|
||
{
|
||
StringBuilder sb = new StringBuilder();
|
||
|
||
// 添加列标题
|
||
foreach (DataColumn column in dt.Columns)
|
||
{
|
||
sb.Append(column.ColumnName);
|
||
sb.Append(",");
|
||
}
|
||
sb.Remove(sb.Length - 1, 1);
|
||
sb.AppendLine();
|
||
|
||
// 添加行数据
|
||
foreach (DataRow row in dt.Rows)
|
||
{
|
||
foreach (object item in row.ItemArray)
|
||
{
|
||
sb.Append(item);
|
||
sb.Append(",");
|
||
}
|
||
sb.Remove(sb.Length - 1, 1);
|
||
sb.AppendLine();
|
||
}
|
||
|
||
// 将数据写入CSV文件
|
||
File.WriteAllText(filePath, sb.ToString());
|
||
}
|
||
|
||
private void rbtnExportCSVReport_Click(object sender, EventArgs e)
|
||
{
|
||
string strCSVExportPath = "";
|
||
string strExportTime = DateTime.Now.ToString("yyyyMMddHHmmssfff");
|
||
FolderBrowserDialog m_Folder = new FolderBrowserDialog();
|
||
m_Folder.Description = "请选择要导出的CSV文件的路径";
|
||
m_Folder.RootFolder = Environment.SpecialFolder.Desktop;
|
||
if (dgvFPYResult.Visible == true && dgvFPYResult.Rows.Count > 0)
|
||
{
|
||
m_Folder.ShowDialog();
|
||
if (Directory.Exists(m_Folder.SelectedPath))
|
||
{
|
||
strCSVExportPath = m_Folder.SelectedPath + "\\合格率" + strExportTime + ".CSV";
|
||
ExportdgvDataToCsv(dgvFPYResult, strCSVExportPath);
|
||
}
|
||
}
|
||
if (dgvSelectMeasureData.Visible == true && dgvSelectMeasureData.Rows.Count > 0)
|
||
{
|
||
m_Folder.ShowDialog();
|
||
if (Directory.Exists(m_Folder.SelectedPath))
|
||
{
|
||
strCSVExportPath = m_Folder.SelectedPath + "\\车身尺寸数据" + strExportTime + ".CSV";
|
||
ExportDataTableDataToCsv(PageTable, strCSVExportPath);
|
||
}
|
||
}
|
||
}
|
||
|
||
private void dgvFPYResult_RowStateChanged(object sender, DataGridViewRowStateChangedEventArgs e)
|
||
{
|
||
e.Row.HeaderCell.Value = string.Format("{0}", e.Row.Index + 1);
|
||
}
|
||
|
||
private void dgvSelectMeasureData_RowStateChanged(object sender, DataGridViewRowStateChangedEventArgs e)
|
||
{
|
||
e.Row.HeaderCell.Value = string.Format("{0}", e.Row.Index + 1);
|
||
}
|
||
|
||
#endregion Search Data
|
||
|
||
#region CP CPK
|
||
|
||
private void rbtnSearchCPCPK_Click(object sender, EventArgs e)
|
||
{
|
||
DataTable dtCPCPK = new DataTable();
|
||
string strMeasureName = rddlMeasurePoint.Text;
|
||
string strSizeName = rddlSizeName.Text.Trim().Substring(0, 1);
|
||
int iLimitCount = (int)nudMeasureCount.Value;
|
||
dtCPCPK = tmdal.SelectMeasureValuebyMeasureNameAndSize(strMeasureName, strSizeName, iLimitCount);
|
||
int iSelectRows = dtCPCPK.Rows.Count;
|
||
if (iSelectRows < 5)
|
||
{
|
||
chartCPCPK.Visible = false;
|
||
labSearchCPCPKResult.Visible = true;
|
||
pnlCPCPK.Visible = false;
|
||
}
|
||
else
|
||
{
|
||
double dNormalValue = double.Parse(dtCPCPK.Rows[0]["NormalValue"].ToString());
|
||
double dLowerTolValue = double.Parse(dtCPCPK.Rows[0]["LowerTolVal"].ToString());
|
||
double dUpperTolValue = double.Parse(dtCPCPK.Rows[0]["UpperTolVal"].ToString());
|
||
double dLSL = dNormalValue + dLowerTolValue;
|
||
double dUSL = dNormalValue + dUpperTolValue;
|
||
|
||
List<double> listMDoubleData = new List<double>();
|
||
List<string> listMStrData = new List<string>();
|
||
listMStrData.Clear();
|
||
listMDoubleData.Clear();
|
||
for (int i = 0; i < iSelectRows; i++)
|
||
{
|
||
listMDoubleData.Add(double.Parse(dtCPCPK.Rows[i]["MeasureValue"].ToString()));
|
||
listMStrData.Add(dtCPCPK.Rows[i]["MeasureValue"].ToString());
|
||
}
|
||
|
||
#region 数据赋值
|
||
|
||
labLSL.Text = dLSL.ToString("F2");
|
||
labUSL.Text = dUSL.ToString("F2");
|
||
labTarget.Text = dNormalValue.ToString("F2");
|
||
labSampleSize.Text = iSelectRows.ToString();
|
||
labAverage.Text = CpCpkHelper.GetAverage(listMStrData).ToString("F4");
|
||
labStdDev.Text = CpCpkHelper.GetSigma(listMStrData).ToString("F4");
|
||
List<double> listCpCpk = CpCpkHelper.GetCpList(listMStrData, dUSL, dLSL);
|
||
labCp.Text = listCpCpk[0].ToString("F4");
|
||
labCpl.Text = listCpCpk[1].ToString("F4");
|
||
labCpu.Text = listCpCpk[2].ToString("F4");
|
||
labCpk.Text = listCpCpk[3].ToString("F4");
|
||
List<double> listPpPpk = CpCpkHelper.GetPpList(listMStrData, dUSL, dLSL);
|
||
labPp.Text = listPpPpk[0].ToString("F4");
|
||
labPpl.Text = listPpPpk[1].ToString("F4");
|
||
labPpu.Text = listPpPpk[2].ToString("F4");
|
||
labPpk.Text = listPpPpk[3].ToString("F4");
|
||
|
||
#endregion 数据赋值
|
||
|
||
#region 画柱状图
|
||
|
||
Dictionary<string, string> histogramDataDic = new Dictionary<string, string>();
|
||
histogramDataDic = CpCpkHelper.GetHistogramData(listMDoubleData);
|
||
string[] strXValue = new string[histogramDataDic.Count];
|
||
int[] dYValue = new int[histogramDataDic.Count];
|
||
for (int i = 0; i <= histogramDataDic.Count - 1; i++)
|
||
{
|
||
strXValue[i] = (histogramDataDic.ElementAt(i).Key);
|
||
dYValue[i] = int.Parse(histogramDataDic.ElementAt(i).Value);
|
||
}
|
||
chartCPCPK.Series[0].Label = "#VAL"; //设置显示Y的值
|
||
chartCPCPK.Series[0].LabelForeColor = Color.White;
|
||
chartCPCPK.Series[0].ToolTip = "区间范围 : #VALX \r\n数量 : #VAL"; //鼠标移动到对应点显示数值
|
||
chartCPCPK.Series[0].Points.DataBindXY(strXValue, dYValue);
|
||
|
||
#endregion 画柱状图
|
||
|
||
chartCPCPK.Visible = true;
|
||
labSearchCPCPKResult.Visible = false;
|
||
pnlCPCPK.Visible = true;
|
||
}
|
||
}
|
||
|
||
#endregion CP CPK
|
||
|
||
#region 软件设置
|
||
|
||
private void lpcSoftwareSetup_Click(object sender, EventArgs e)
|
||
{
|
||
string strInputPwd = MyBase.InputBox("密码", "请输入密码 : ", "", "确定", "取消");
|
||
if (strInputPwd.Contains("-999.999"))
|
||
{
|
||
return;
|
||
}
|
||
else if (strInputPwd == ConfigDfn.strPwd)
|
||
{
|
||
FSoftwareSetup fss = new FSoftwareSetup();
|
||
fss.ShowDialog(this);
|
||
}
|
||
else
|
||
{
|
||
MessageBox.Show("密码错误！ ", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
|
||
}
|
||
}
|
||
|
||
private void lpcToleranceSetup_Click(object sender, EventArgs e)
|
||
{
|
||
string strInputPwd = MyBase.InputBox("密码", "请输入密码 : ", "", "确定", "取消");
|
||
if (strInputPwd.Contains("-999.999"))
|
||
{
|
||
return;
|
||
}
|
||
else if (strInputPwd == ConfigDfn.strPwd)
|
||
{
|
||
FToleranceSetup fts = new FToleranceSetup();
|
||
fts.ShowDialog(this);
|
||
}
|
||
else
|
||
{
|
||
MessageBox.Show("密码错误！ ", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
|
||
}
|
||
}
|
||
|
||
private void lpcRange_Click(object sender, EventArgs e)
|
||
{
|
||
string strInputPwd = MyBase.InputBox("密码", "请输入密码 : ", "", "确定", "取消");
|
||
if (strInputPwd.Contains("-999.999"))
|
||
{
|
||
return;
|
||
}
|
||
else if (strInputPwd == ConfigDfn.strPwd)
|
||
{
|
||
FRangeSetup frs = new FRangeSetup();
|
||
frs.ShowDialog(this);
|
||
}
|
||
else
|
||
{
|
||
MessageBox.Show("密码错误！ ", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
|
||
}
|
||
}
|
||
|
||
private void lpcPLCAddress_Click(object sender, EventArgs e)
|
||
{
|
||
string strInputPwd = MyBase.InputBox("密码", "请输入密码 : ", "", "确定", "取消");
|
||
if (strInputPwd.Contains("-999.999"))
|
||
{
|
||
return;
|
||
}
|
||
else if (strInputPwd == ConfigDfn.strPwd)
|
||
{
|
||
PlcAddrSetup PLCAS = new PlcAddrSetup(3, ConfigDfn.strConfigFile);
|
||
PLCAS.Show();
|
||
}
|
||
else
|
||
{
|
||
MessageBox.Show("密码错误！ ", "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
|
||
}
|
||
}
|
||
|
||
private void lpcPLCTest_Click(object sender, EventArgs e)
|
||
{
|
||
FormDebugSiemensS7 FDS7 = new FormDebugSiemensS7(SiemensPLCS.S1200);
|
||
FDS7.Show();
|
||
}
|
||
|
||
private void lpcAboutSoftware_Click(object sender, EventArgs e)
|
||
{
|
||
AboutSoftwareInfo asi = new AboutSoftwareInfo();
|
||
asi.ShowDialog();
|
||
}
|
||
|
||
private void lpcShowLog_Click(object sender, EventArgs e)
|
||
{
|
||
System.Diagnostics.Process.Start("notepad.exe", LogDebugDfn.strDebugFile);
|
||
}
|
||
|
||
#endregion 软件设置
|
||
|
||
#region RadButton鼠标事件
|
||
|
||
private void btn_MouseHover(object sender, EventArgs e)
|
||
{
|
||
RadButton btn = sender as RadButton;
|
||
btn.BackColor = Color.FromArgb(0, 151, 186);
|
||
}
|
||
|
||
private void btn_MouseLeave(object sender, EventArgs e)
|
||
{
|
||
RadButton btn = sender as RadButton;
|
||
btn.BackColor = Color.FromArgb(19, 46, 53);
|
||
}
|
||
|
||
#endregion RadButton鼠标事件
|
||
|
||
#region PLC相关函数
|
||
|
||
#region PLC重连操作
|
||
|
||
private void tmrReadPLCData_Tick(object sender, EventArgs e)
|
||
{
|
||
tmrReadPLCData.Stop();
|
||
|
||
#region 判断PLC是否正常运行
|
||
|
||
if (ConfigPlc.PlcType == 3 && ConfigPlc.bReConnect && !HslSiemensS7Obj.bConnected)
|
||
{
|
||
MyBase.TraceWriteLine("PLC断开，重连！");
|
||
tmrHeartBeatConnect.Stop();
|
||
ReConnectPLC();
|
||
return;
|
||
}
|
||
|
||
byte[] m_Datas = null;
|
||
if (!HslSiemensS7Obj.ReadDatas(PlcAddrSetup.S7ReadStartAddr, (ushort)PlcAddrSetup.S7ReadByteCount, ref m_Datas))
|
||
{
|
||
tmrReadPLCData.Start();
|
||
return;
|
||
}
|
||
if (m_Datas == null)
|
||
{
|
||
tmrReadPLCData.Start();
|
||
MyBase.TraceWriteLine("PLC读取数据对象为空，退出！");
|
||
return;
|
||
}
|
||
|
||
#endregion 判断PLC是否正常运行
|
||
|
||
try
|
||
{
|
||
#region 循环读取PLC数据块中的信息
|
||
|
||
if (m_Datas.Length >= PlcAddrSetup.S7ReadByteCount)
|
||
{
|
||
PLCDfn.bPlcLiveTick = PlcObject.GetS7ByteData(PlcSignalDfn.PlcLive) == 1;
|
||
PLCDfn.ReadVINFinishFlag = PlcObject.GetS7ByteData(PlcSignalDfn.ReadVINFinishFlag);
|
||
//从PLC获取VIN码后，通过访问IOT接口 获取汽车类型，再反馈给PLC
|
||
if (iLastReadVINFinishFlag == 0 && PLCDfn.ReadVINFinishFlag == 10)
|
||
{
|
||
string strCarID = PlcObject.GetS7StringData(PlcSignalDfn.PartID);
|
||
//PLCDfn.CarType = PlcObject.GetS7ByteData(PlcSignalDfn.CarType);
|
||
MyBase.TraceWriteLine("PLC读码完成信号：0->10;Read PLC VIN is: " + strCarID);
|
||
if (strCarID.Length > 10)
|
||
{
|
||
string strCarColor = "";
|
||
string strCarType = GetCarTypeByIOTAPI(strCarID, out strCarColor);
|
||
if (!strCarType.ToUpper().Contains("ERR"))
|
||
{
|
||
if (strCarType.ToUpper().Contains("EH3"))
|
||
{
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.WCarType, (byte)1);
|
||
}
|
||
else
|
||
{
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.WCarType, (byte)2);
|
||
}
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.WCarColor, strCarColor);
|
||
MyBase.TraceWriteLine("往PLC写入车型： " + strCarType + " ;车身颜色：" + strCarColor);
|
||
tmdal.InsertVIN(strCarID);
|
||
MyBase.TraceWriteLine(strCarID + " 插入到数据库表TTempSaveVIN中完成。");
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine("报错：根据VIN从IOT上获取车型信息失败，不发送给PLC车型信息和颜色信息。 ");
|
||
}
|
||
}
|
||
}
|
||
PLCDfn.CarPassFlag = PlcObject.GetS7ByteData(PlcSignalDfn.CarPassFlag);
|
||
if (iLastCarPassFlag == 0 && PLCDfn.CarPassFlag == 10)
|
||
{
|
||
string strCarID = PlcObject.GetS7StringData(PlcSignalDfn.PartID);
|
||
MyBase.TraceWriteLine("读取PLC CarPassFlag 完成信号：0->10;Read PLC VIN is: " + strCarID);
|
||
string strSecondPosCarID = tmdal.SelectMaintenanceStationVINbyStationNo(2);
|
||
if (strSecondPosCarID.Length == 21)
|
||
{
|
||
string strTempCarID = strSecondPosCarID.Substring(0, 17);
|
||
string strTempCarType = strSecondPosCarID.Substring(18, 3);
|
||
if (tmdal.CheckMRVINExistOrNotByVIN(strTempCarID) == 0)
|
||
{
|
||
string strTargetRate = Math.Round(ConfigDfn.dFPY2 * 100.00d, 2).ToString("F2") + "%";
|
||
|
||
MyBase.TraceWriteLine(strSecondPosCarID + " ；该VIN码只扫码没有测量,没有测量结果，上传IOT NG消息。");
|
||
string strPostData = "{\"serno\":\"" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + "\",\"requestData\":[{\"vin\":\"" + strTempCarID + "\",\"model\":\"" + strTempCarType + "\",\"equipmentNo\":\"" + ConfigDfn.strEquipNo + "\",\"equipmentName\":\"" + ConfigDfn.strEquipName + "\",\"calibrationResult\":\"NG\",\"detectionTime\":\"" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\",\"targetRate\":\"" + strTargetRate + "\",\"rate\":\"0.00%\",\"GapList\":[]}]}";
|
||
MyBase.TraceWriteLine("Update NG To IOT Data Content: " + strPostData);
|
||
string strPostResult = PostJsonToIOT(ConfigDfn.strIOTAddress, strPostData, 10000);
|
||
MyBase.TraceWriteLine("NG数据上传IOT完成，结果返回为：" + strPostResult);
|
||
}
|
||
}
|
||
|
||
if (!string.IsNullOrEmpty(strCarID) && strCarID.Length > 10)
|
||
{
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(6), 7);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(5), 6);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(4), 5);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(3), 4);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(2), 3);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(1), 2);
|
||
Thread.Sleep(20);
|
||
string strCarColor = "";
|
||
string strCarType = GetCarTypeByIOTAPI(strCarID, out strCarColor);
|
||
if (!strCarType.ToUpper().Contains("ERR"))
|
||
{
|
||
if (strCarType.ToUpper().Contains("EH3"))
|
||
{
|
||
strCarID = strCarID + "_EH3";
|
||
}
|
||
else
|
||
{
|
||
strCarID = strCarID + "_EHY";
|
||
}
|
||
}
|
||
tmdal.updateMaintenceInfo(strCarID, 1);
|
||
MyBase.TraceWriteLine("CarPassFlag 0->10 更新到MaintenceInfo数据库位置1中的VIN为： " + strCarID);
|
||
}
|
||
else
|
||
{
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(6), 7);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(5), 6);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(4), 5);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(3), 4);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(2), 3);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo(tmdal.SelectMaintenanceStationVINbyStationNo(1), 2);
|
||
Thread.Sleep(20);
|
||
tmdal.updateMaintenceInfo("empty", 1);
|
||
MyBase.TraceWriteLine("CarPassFlag 0->10 更新到MaintenceInfo数据库位置1中的VIN为：empty ");
|
||
}
|
||
|
||
}
|
||
if (ConfigDfn.iRecordEncoderFlag == 1)
|
||
{
|
||
double dSpeed1 = PlcObject.GetS7Double(PlcSignalDfn.Speed1);
|
||
double dSpeed2 = PlcObject.GetS7Double(PlcSignalDfn.Speed2);
|
||
double dR01 = PlcObject.GetS7Double(PlcSignalDfn.R01_Pules);
|
||
double dR02 = PlcObject.GetS7Double(PlcSignalDfn.R02_Pules);
|
||
NLogger.Fatal(dSpeed1 + "," + dSpeed2 + "," + dR01 + "," + dR02);
|
||
}
|
||
}
|
||
iLastCarPassFlag = PLCDfn.CarPassFlag;
|
||
iLastReadVINFinishFlag = PLCDfn.ReadVINFinishFlag;
|
||
#endregion 循环读取PLC数据块中的信息
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
MyBase.TraceWriteLine("tmrReadPLCData_Tick exception: " + ex.ToString());
|
||
}
|
||
|
||
|
||
tmrReadPLCData.Start();
|
||
}
|
||
|
||
private void tmrRefreshPLCStatus_Tick(object sender, EventArgs e)
|
||
{
|
||
if (labelTimeStatus_Tip.Text == "─") { labelTimeStatus_Tip.Text = "╲"; }
|
||
else if (labelTimeStatus_Tip.Text == "╲") { labelTimeStatus_Tip.Text = "│"; }
|
||
else if (labelTimeStatus_Tip.Text == "│") { labelTimeStatus_Tip.Text = "╱"; }
|
||
else if (labelTimeStatus_Tip.Text == "╱") { labelTimeStatus_Tip.Text = "─"; }
|
||
|
||
lampPLCHeart.State = PLCDfn.bPlcLiveTick ? LampColor.Green : LampColor.Silver;
|
||
rlePLCHeart.ForeColor = PLCDfn.bPlcLiveTick ? Color.Lime : Color.White;
|
||
}
|
||
|
||
private void tmrHeartBeatConnect_Tick(object sender, EventArgs e)
|
||
{
|
||
if (bPlcLiveTickLast != PLCDfn.bPlcLiveTick)
|
||
{
|
||
HeartBeatCount = 0;
|
||
}
|
||
else
|
||
{
|
||
HeartBeatCount++;
|
||
}
|
||
|
||
if (HeartBeatCount >= 600)
|
||
{
|
||
HeartBeatCount = 0;
|
||
if (!bStopPlcNormal)
|
||
{
|
||
MyBase.TraceWriteLine("PLC心跳检测10分钟内未变化，断开PLC，进行PLC重连！");
|
||
PlcObject.ClosePlc();
|
||
}
|
||
}
|
||
bPlcLiveTickLast = PLCDfn.bPlcLiveTick;
|
||
}
|
||
|
||
private void tmrWritePLCLive_Tick(object sender, EventArgs e)
|
||
{
|
||
bTickt = !bTickt;
|
||
PlcObject.InsertWriteQueue(PlcSignalDfn.SoftLive, Convert.ToByte(bTickt ? 1 : 0));
|
||
}
|
||
|
||
private void ReConnectPLC()
|
||
{
|
||
m_ThreadReconnectPLC = null;
|
||
m_ThreadReconnectPLC = new Thread(new ThreadStart(ReConnectPlcProcess));
|
||
if (!m_ThreadReconnectPLC.IsAlive)
|
||
{
|
||
m_ThreadReconnectPLC.Start();
|
||
}
|
||
}
|
||
|
||
private void ReConnectPlcProcess()
|
||
{
|
||
while (!PlcObject.IsPlcConnected())
|
||
{
|
||
bool bConnectResult = PlcObject.ConnectPlc();
|
||
if (!bConnectResult)
|
||
{
|
||
m_ReConnectNum++;
|
||
MyBase.TraceWriteLine("重连PLC，第" + m_ReConnectNum + "次!");
|
||
}
|
||
Thread.Sleep(1000);
|
||
}
|
||
MyBase.TraceWriteLine("重新连接PLC成功！");
|
||
lampConnectPLCStatus.State = LampColor.Green;
|
||
rlePLCStatus.ForeColor = Color.Lime;
|
||
this.BeginInvoke((EventHandler)delegate
|
||
{
|
||
tmrHeartBeatConnect.Start();
|
||
});
|
||
bStopPlcNormal = false;
|
||
m_ReConnectNum = 0;
|
||
this.Invoke((EventHandler)(delegate
|
||
{
|
||
tmrReadPLCData.Start();
|
||
tmrWritePLCLive.Start();//启动给PLC写入心跳 1s写一次 0 1
|
||
tmrRefreshPLCStatus.Start();//刷新PLC等的状态
|
||
}));
|
||
m_ThreadReconnectPLC.Abort();
|
||
}
|
||
|
||
#endregion PLC重连操作
|
||
|
||
private void ConnectThread()
|
||
{
|
||
MyBase.TraceWriteLine("连接PLC....");
|
||
|
||
bool bConnectResult = PlcObject.ConnectPlc();
|
||
this.Invoke((EventHandler)(delegate
|
||
{
|
||
if (bConnectResult)
|
||
{
|
||
lampConnectPLCStatus.State = LampColor.Green;
|
||
rlePLCStatus.ForeColor = Color.Lime;
|
||
MyBase.TraceWriteLine("连接PLC成功");
|
||
}
|
||
else
|
||
{
|
||
lampConnectPLCStatus.State = LampColor.Red;
|
||
rlePLCStatus.ForeColor = Color.Red;
|
||
tmrReadPLCData.Stop();
|
||
MyBase.TraceWriteLine("连接PLC失败");
|
||
return;
|
||
}
|
||
|
||
tmrReadPLCData.Start(); //读取PLC数据信息
|
||
tmrWritePLCLive.Start();//启动给PLC写入心跳 1s写一次 0 1
|
||
tmrRefreshPLCStatus.Start();//刷新PLC等的状态
|
||
if (ConfigPlc.bReConnect)
|
||
tmrHeartBeatConnect.Start(); //监测来自plc的心跳5分钟内没有变化，重新连接PLC
|
||
}));
|
||
}
|
||
|
||
private void btnConnectPlc_Click(object sender, EventArgs e)
|
||
{
|
||
try
|
||
{
|
||
PlcObject.InitWritePlcThread();
|
||
bStopPlcNormal = false;
|
||
Thread m_Thread = new Thread(ConnectThread);
|
||
m_Thread.Start();
|
||
return;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
MessageBox.Show(ex.Message, "警告", MessageBoxButtons.OK, MessageBoxIcon.Warning);
|
||
}
|
||
}
|
||
|
||
private void btnClosePlc_Click(object sender, EventArgs e)
|
||
{
|
||
try
|
||
{
|
||
MyBase.TraceWriteLine("点击了断开PLC按钮，断开PLC！");
|
||
tmrReadPLCData.Stop();
|
||
tmrHeartBeatConnect.Stop();
|
||
tmrWritePLCLive.Stop();
|
||
tmrRefreshPLCStatus.Stop();
|
||
lampConnectPLCStatus.State = LampColor.White;
|
||
rlePLCStatus.ForeColor = Color.White;
|
||
rlePLCHeart.ForeColor = Color.White;
|
||
lampPLCHeart.State = LampColor.White;
|
||
bStopPlcNormal = true;
|
||
PlcObject.ClosePlc();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
MessageBox.Show(ex.Message, "警告", MessageBoxButtons.OK, MessageBoxIcon.Warning);
|
||
}
|
||
}
|
||
|
||
#endregion PLC相关函数
|
||
|
||
private void lpcUploadIOTTest_Click(object sender, EventArgs e)
|
||
{
|
||
string strPostData = "{\"serno\":\"" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + "\",\"requestData\":[{\"vin\":\"test001\",\"model\":\"EHY\",\"equipmentNo\":\"" + ConfigDfn.strEquipNo + "\",\"equipmentName\":\"" + ConfigDfn.strEquipName + "\",\"calibrationResult\":\"OK\",\"detectionTime\":\"" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\",\"GapList\":[{\"vin\":\"test001\",\"gfNo\":\"F\",\"pointNumber\":\"L-01\",\"actualValue\":\"-0.30\",\"controlLine\":\"-1.00/1.00\",\"measurementResult\":\"OK\"}]}]}";
|
||
MyBase.TraceWriteLine("Test Post Data: " + strPostData);
|
||
string strPostResult = PostJsonToIOT(ConfigDfn.strIOTAddress, strPostData, 10000);
|
||
MessageBox.Show("测试上传数据完成，获取到的返回值为： " + strPostResult, "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
|
||
MyBase.TraceWriteLine("测试上传数据完成，获取到的返回值为： " + strPostResult);
|
||
}
|
||
private void lpcTestGetCarTye_Click(object sender, EventArgs e)
|
||
{
|
||
string strPostData = "{\"serno\":\"312314141\",\"vin\":\"LNNAJDDU9RDA00213\"}";
|
||
MyBase.TraceWriteLine("Test Post Data: " + strPostData);
|
||
string strPostResult = PostJsonToIOT(ConfigDfn.strIOTCarTypeAddress, strPostData, 10000);
|
||
MessageBox.Show("测试从IOT获取车型信息完成，获取到的返回值为： " + strPostResult, "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
|
||
MyBase.TraceWriteLine("测试从IOT获取车型信息完成，获取到的原返回值为： " + strPostResult);
|
||
string strNewResult = strPostResult.Substring(1, strPostResult.Length - 2).Replace("]", "");
|
||
MessageBox.Show("测试从IOT获取车型信息完成，处理后 获取到的返回值为： " + strNewResult, "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
|
||
MyBase.TraceWriteLine("测试从IOT获取车型信息完成，处理后 获取到的返回值为： " + strNewResult);
|
||
CheryCarTypeInfo ccti = new CheryCarTypeInfo();
|
||
ccti = JsonConvert.DeserializeObject<CheryCarTypeInfo>(strNewResult);
|
||
MessageBox.Show("测试从IOT获取车型信息完成，获取到的返回值为： " + strNewResult + "; 解析出的车型：" + ccti.data.model + " ;解析出的物料号为" + ccti.data.material + " ;解析出颜色编号：" + ccti.data.material.Substring(7, 2), "提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
|
||
}
|
||
private string GetCarTypeByIOTAPI(string strVIN, out string strMaterialNo)
|
||
{
|
||
string strPostData = "{\"serno\":\"" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + "\",\"vin\":\"" + strVIN + "\"}";
|
||
MyBase.TraceWriteLine(" Post VIN Data: " + strPostData);
|
||
string strPostResult = PostJsonToIOT(ConfigDfn.strIOTCarTypeAddress, strPostData, 5000);
|
||
MyBase.TraceWriteLine("GetCarTypeByIOTAPI IOT Return CarType Infomation : " + strPostResult);
|
||
string strNewResult = strPostResult.Substring(1, strPostResult.Length - 2).Replace("]", "");
|
||
MyBase.TraceWriteLine("GetCarTypeByIOTAPI IOT Return New CarType Infomation : " + strNewResult);
|
||
CheryCarTypeInfo ccti = new CheryCarTypeInfo();
|
||
ccti = JsonConvert.DeserializeObject<CheryCarTypeInfo>(strNewResult);
|
||
if (ccti.message.Contains("成功"))
|
||
{
|
||
|
||
if (ccti.data.material != null && ccti.data.material.Length > 9)
|
||
{
|
||
strMaterialNo = ccti.data.material.Substring(7, 2);
|
||
MyBase.TraceWriteLine(" IOT Return CarType Infomation : " + strNewResult + "; 解析出的车型：" + ccti.data.model + "解析出车颜色编号：" + strMaterialNo);
|
||
}
|
||
else
|
||
{
|
||
strMaterialNo = "TE";
|
||
MyBase.TraceWriteLine(" IOT Return CarType Infomation : " + strNewResult + "; 解析出的车型：" + ccti.data.model + "；未解析出车颜色编号");
|
||
}
|
||
return ccti.data.model;
|
||
}
|
||
else
|
||
{
|
||
MyBase.TraceWriteLine(" IOT Return CarType Infomation ERROR : " + strPostResult);
|
||
strMaterialNo = "ER";
|
||
return "ERR";
|
||
}
|
||
}
|
||
|
||
private void lpcShowCarData_Click(object sender, EventArgs e)
|
||
{
|
||
if (ConfigDfn.strShowCarLR == "L")
|
||
{
|
||
if (ConfigDfn.strCarModel.ToUpper().Contains("EH3"))
|
||
{
|
||
fLEH3.Show();
|
||
fLEHY.Show();
|
||
fLEHY.Hide();
|
||
}
|
||
else
|
||
{
|
||
fLEH3.Show();
|
||
fLEH3.Hide();
|
||
fLEHY.Show();
|
||
}
|
||
}
|
||
else
|
||
{
|
||
if (ConfigDfn.strCarModel.ToUpper().Contains("EH3"))
|
||
{
|
||
fREH3.Show();
|
||
fREHY.Show();
|
||
fREHY.Hide();
|
||
}
|
||
else
|
||
{
|
||
fREH3.Show();
|
||
fREH3.Hide();
|
||
fREHY.Show();
|
||
}
|
||
}
|
||
}
|
||
public void ShowCarMeasureDataByCarType(int iCarType)
|
||
{
|
||
if (ConfigDfn.strShowCarLR == "L")
|
||
{
|
||
if (iCarType == 1)
|
||
{
|
||
fLEH3.Show();
|
||
fLEHY.Show();
|
||
fLEHY.Hide();
|
||
MyBase.TraceWriteLine("显示左侧EH3车身数据界面。");
|
||
}
|
||
else
|
||
{
|
||
fLEH3.Show();
|
||
fLEH3.Hide();
|
||
fLEHY.Show();
|
||
MyBase.TraceWriteLine("显示左侧EHY车身数据界面。");
|
||
}
|
||
}
|
||
else
|
||
{
|
||
if (iCarType == 1)
|
||
{
|
||
fREH3.Show();
|
||
fREHY.Show();
|
||
fREHY.Hide();
|
||
MyBase.TraceWriteLine("显示右侧EH3车身数据界面。");
|
||
}
|
||
else
|
||
{
|
||
fREH3.Show();
|
||
fREH3.Hide();
|
||
fREHY.Show();
|
||
MyBase.TraceWriteLine("显示右侧EHY车身数据界面。");
|
||
}
|
||
}
|
||
}
|
||
private void rbtnTestCOM_Click(object sender, EventArgs e)
|
||
{
|
||
if (rbtnTestCOM.Text == "打开串口")
|
||
{
|
||
serialTestPort = new SerialPort(rtbPort.Text.Trim(), 115200, Parity.None, 8, StopBits.One); // 设置串口参数
|
||
serialTestPort.DataReceived += new SerialDataReceivedEventHandler(DataReceivedHandler); // 注册数据接收事件处理方法
|
||
serialTestPort.Open(); // 打开串口
|
||
if (serialTestPort.IsOpen)
|
||
{
|
||
rbtnTestCOM.Text = "关闭串口";
|
||
}
|
||
}
|
||
else
|
||
{
|
||
serialTestPort.DataReceived -= new SerialDataReceivedEventHandler(DataReceivedHandler);
|
||
serialTestPort.Close();
|
||
serialTestPort.Dispose();
|
||
rbtnTestCOM.Text = "打开串口";
|
||
}
|
||
}
|
||
|
||
private void DataReceivedHandler(object sender, SerialDataReceivedEventArgs e)
|
||
{
|
||
SerialPort sp = (SerialPort)sender;
|
||
string indata = sp.ReadExisting();
|
||
MyBase.TraceWriteLine(indata);
|
||
rtbCOMContent.Text = indata;
|
||
}
|
||
|
||
private void tmrMonitorDBToCreateReport_Tick(object sender, EventArgs e)
|
||
{
|
||
tmrMonitorDBToCreateReport.Stop();
|
||
int iCurrentMeasureCount = tmdal.SelectTMeasureResultCount();
|
||
if (iCurrentMeasureCount > iLastMesureCount && (iCurrentMeasureCount == (iLastMesureCount + 1)))
|
||
{
|
||
MyBase.TraceWriteLine("监控数据库，开始生成ipn文件：");
|
||
DataTable dtMeaResult = tmdal.SelectNewestTMeasureResult();
|
||
string strVIN = dtMeaResult.Rows[0]["CarID"].ToString();
|
||
DateTime dateMeaDate = Convert.ToDateTime(dtMeaResult.Rows[0]["Remark"].ToString());
|
||
DataTable dtMeaContent = tmdal.SelectTMeasureDataByVIN(strVIN);
|
||
string strCarType = dtMeaContent.Rows[0][2].ToString();
|
||
int iMeaCount = dtMeaContent.Rows.Count;
|
||
|
||
#region 解析完报告后，重新生成客户模板报告
|
||
|
||
string filePath = "";
|
||
if (strCarType.ToLower().Contains("tava"))
|
||
{
|
||
filePath = ConfigDfn.strReportPath + "\\" + strCarType + "_" + strVIN + "_" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".ipn";
|
||
}
|
||
else
|
||
{
|
||
filePath = ConfigDfn.strReportPath2 + "\\" + strCarType + "_" + strVIN + "_" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".ipn";
|
||
}
|
||
|
||
StringBuilder sb = new StringBuilder();
|
||
|
||
#region 添加表头
|
||
|
||
sb.Append("GAUGE ID");
|
||
sb.Append("\t");
|
||
sb.Append("JSN");
|
||
sb.Append("\t");
|
||
sb.Append("MO");
|
||
sb.Append("\t");
|
||
sb.Append("DAY");
|
||
sb.Append("\t");
|
||
sb.Append("YR");
|
||
sb.Append("\t");
|
||
sb.Append("HR");
|
||
sb.Append("\t");
|
||
sb.Append("MIN");
|
||
sb.Append("\t");
|
||
sb.Append("SEC");
|
||
sb.Append("\t");
|
||
sb.Append("MODEL");
|
||
sb.Append("\t");
|
||
sb.Append("AuxID1");
|
||
sb.Append("\t");
|
||
sb.Append("AuxID2");
|
||
sb.Append("\t");
|
||
sb.Append("QUAL");
|
||
sb.Append("\t");
|
||
sb.Append("SHIFT");
|
||
sb.Append("\t");
|
||
sb.Append("DATA TYPE");
|
||
sb.Append("\t");
|
||
sb.Append("FIXTURE");
|
||
sb.Append("\t");
|
||
for (int i = 0; i < iMeaCount / 2; i++)
|
||
{
|
||
string strMeaPointName = dtMeaContent.Rows[i * 2]["MeasPointName"].ToString();
|
||
string strMPF = strMeaPointName + " Flush";
|
||
string strMPG = strMeaPointName + " Gap";
|
||
sb.Append("D " + strMPF);
|
||
sb.Append("\t");
|
||
sb.Append("D " + strMPG);
|
||
sb.Append("\t");
|
||
|
||
sb.Append("B " + strMPF);
|
||
sb.Append("\t");
|
||
sb.Append("B " + strMPG);
|
||
sb.Append("\t");
|
||
|
||
sb.Append("A " + strMPF);
|
||
sb.Append("\t");
|
||
sb.Append("A " + strMPG);
|
||
sb.Append("\t");
|
||
|
||
sb.Append("US " + strMPF);
|
||
sb.Append("\t");
|
||
sb.Append("LS " + strMPF);
|
||
sb.Append("\t");
|
||
sb.Append("US " + strMPG);
|
||
sb.Append("\t");
|
||
sb.Append("LS " + strMPG);
|
||
sb.Append("\t");
|
||
|
||
sb.Append("UR " + strMPF);
|
||
sb.Append("\t");
|
||
sb.Append("LR " + strMPF);
|
||
sb.Append("\t");
|
||
sb.Append("UR " + strMPG);
|
||
sb.Append("\t");
|
||
sb.Append("LR " + strMPG);
|
||
sb.Append("\t");
|
||
|
||
sb.Append("UT " + strMPF);
|
||
sb.Append("\t");
|
||
sb.Append("LT " + strMPF);
|
||
sb.Append("\t");
|
||
sb.Append("UT " + strMPG);
|
||
sb.Append("\t");
|
||
sb.Append("LT " + strMPG);
|
||
sb.Append("\t");
|
||
}
|
||
|
||
#endregion 添加表头
|
||
|
||
sb.AppendLine();
|
||
|
||
#region 添加内容
|
||
|
||
sb.Append(ConfigDfn.strStationName);
|
||
sb.Append("\t");
|
||
sb.Append(strVIN);
|
||
sb.Append("\t");
|
||
sb.Append(dateMeaDate.Month.ToString());
|
||
sb.Append("\t");
|
||
sb.Append(dateMeaDate.Day.ToString());
|
||
sb.Append("\t");
|
||
sb.Append(dateMeaDate.Year.ToString().Substring(2));
|
||
sb.Append("\t");
|
||
sb.Append(dateMeaDate.Hour.ToString());
|
||
sb.Append("\t");
|
||
sb.Append(dateMeaDate.Minute.ToString());
|
||
sb.Append("\t");
|
||
sb.Append(dateMeaDate.Second.ToString());
|
||
sb.Append("\t");
|
||
if (strCarType.ToLower().Contains("tava"))
|
||
sb.Append(ConfigDfn.strUploadPath);
|
||
else
|
||
{
|
||
sb.Append(ConfigDfn.strUploadPath2);
|
||
}
|
||
sb.Append("\t");
|
||
sb.Append("Unknow");
|
||
sb.Append("\t");
|
||
sb.Append("Unknow");
|
||
sb.Append("\t");
|
||
sb.Append("2");
|
||
sb.Append("\t");
|
||
sb.Append("");
|
||
sb.Append("\t");
|
||
sb.Append("AUTO");
|
||
sb.Append("\t");
|
||
sb.Append("NONE");
|
||
sb.Append("\t");
|
||
|
||
double dDevFVal = 0;
|
||
double dDevGVal = 0;
|
||
|
||
double dMeaFVal = 0;
|
||
double dMeaGVal = 0;
|
||
|
||
double dNorFVal = 0;
|
||
double dNorGVal = 0;
|
||
|
||
double dFUpper = 0;
|
||
double dFLower = 0;
|
||
double dGUpper = 0;
|
||
double dGLower = 0;
|
||
|
||
double dFUpper2 = 0;
|
||
double dFLower2 = 0;
|
||
double dGUpper2 = 0;
|
||
double dGLower2 = 0;
|
||
|
||
double dFUpper3 = 0;
|
||
double dFLower3 = 0;
|
||
double dGUpper3 = 0;
|
||
double dGLower3 = 0;
|
||
for (int i = 0; i < iMeaCount / 2; i++)
|
||
{
|
||
string strMeasureFValue = dtMeaContent.Rows[i * 2]["MeasureValue"].ToString();
|
||
string strMeasureGValue = dtMeaContent.Rows[i * 2 + 1]["MeasureValue"].ToString();
|
||
string strNormalFValue = dtMeaContent.Rows[i * 2]["NormalValue"].ToString();
|
||
string strNormalGValue = dtMeaContent.Rows[i * 2 + 1]["NormalValue"].ToString();
|
||
|
||
dNorFVal = double.Parse(strNormalFValue);
|
||
dNorGVal = double.Parse(strNormalGValue);
|
||
dFUpper = double.Parse(dtMeaContent.Rows[i * 2]["UpperTolVal"].ToString());
|
||
dFLower = double.Parse(dtMeaContent.Rows[i * 2]["LowerTolVal"].ToString());
|
||
dGUpper = double.Parse(dtMeaContent.Rows[i * 2 + 1]["UpperTolVal"].ToString());
|
||
dGLower = double.Parse(dtMeaContent.Rows[i * 2 + 1]["LowerTolVal"].ToString());
|
||
|
||
dFUpper2 = dFUpper * ConfigDfn.dLevel2;
|
||
dFLower2 = dFLower * ConfigDfn.dLevel2;
|
||
dGUpper2 = dGUpper * ConfigDfn.dLevel2;
|
||
dGLower2 = dGLower * ConfigDfn.dLevel2;
|
||
|
||
dFUpper3 = dFUpper * ConfigDfn.dLevel3;
|
||
dFLower3 = dFLower * ConfigDfn.dLevel3;
|
||
dGUpper3 = dGUpper * ConfigDfn.dLevel3;
|
||
dGLower3 = dGLower * ConfigDfn.dLevel3;
|
||
|
||
if (strMeasureFValue.Contains("inv"))
|
||
{
|
||
sb.Append("inv");
|
||
sb.Append("\t");
|
||
}
|
||
else
|
||
{
|
||
dMeaFVal = double.Parse(strMeasureFValue);
|
||
dDevFVal = dMeaFVal - dNorFVal;
|
||
sb.Append(dDevFVal.ToString("F3"));
|
||
sb.Append("\t");
|
||
}
|
||
if (strMeasureGValue.Contains("inv"))
|
||
{
|
||
sb.Append("inv");
|
||
sb.Append("\t");
|
||
}
|
||
else
|
||
{
|
||
dMeaGVal = double.Parse(strMeasureGValue);
|
||
dDevGVal = dMeaGVal - dNorGVal;
|
||
sb.Append(dDevGVal.ToString("F3"));
|
||
sb.Append("\t");
|
||
}
|
||
|
||
sb.Append(strNormalFValue);
|
||
sb.Append("\t");
|
||
sb.Append(strNormalGValue);
|
||
sb.Append("\t");
|
||
|
||
sb.Append(strMeasureFValue);
|
||
sb.Append("\t");
|
||
sb.Append(strMeasureGValue);
|
||
sb.Append("\t");
|
||
|
||
sb.Append(dFUpper.ToString("F3"));
|
||
sb.Append("\t");
|
||
sb.Append(dFLower.ToString("F3"));
|
||
sb.Append("\t");
|
||
sb.Append(dGUpper.ToString("F3"));
|
||
sb.Append("\t");
|
||
sb.Append(dGLower.ToString("F3"));
|
||
sb.Append("\t");
|
||
|
||
sb.Append(dFUpper2.ToString("F3"));
|
||
sb.Append("\t");
|
||
sb.Append(dFLower2.ToString("F3"));
|
||
sb.Append("\t");
|
||
sb.Append(dGUpper2.ToString("F3"));
|
||
sb.Append("\t");
|
||
sb.Append(dGLower2.ToString("F3"));
|
||
sb.Append("\t");
|
||
|
||
sb.Append(dFUpper3.ToString("F3"));
|
||
sb.Append("\t");
|
||
sb.Append(dFLower3.ToString("F3"));
|
||
sb.Append("\t");
|
||
sb.Append(dGUpper3.ToString("F3"));
|
||
sb.Append("\t");
|
||
sb.Append(dGLower3.ToString("F3"));
|
||
sb.Append("\t");
|
||
}
|
||
|
||
#endregion 添加内容
|
||
|
||
// 将数据写入CSV文件
|
||
File.WriteAllText(filePath, sb.ToString());
|
||
MyBase.TraceWriteLine("客户定制ipn报告生成完毕，路径为：" + filePath);
|
||
|
||
#endregion 解析完报告后，重新生成客户模板报告
|
||
}
|
||
iLastMesureCount = iCurrentMeasureCount;
|
||
tmrMonitorDBToCreateReport.Start();
|
||
}
|
||
|
||
|
||
}
|
||
|
||
public class CheryIOTData
|
||
{
|
||
/// <summary> VIN号 </summary>
|
||
public string vin { get; set; }
|
||
|
||
/// <summary> FG </summary>
|
||
public string gfNo { get; set; }
|
||
|
||
/// <summary> 测点编号 </summary>
|
||
public string pointNumber { get; set; }
|
||
|
||
/// <summary> 实测值 </summary>
|
||
public string actualValue { get; set; }
|
||
|
||
/// <summary> 控制线 </summary>
|
||
public string controlLine { get; set; }
|
||
|
||
/// <summary> 测量结果 </summary>
|
||
public string measurementResult { get; set; }
|
||
}
|
||
public class CarInfoData
|
||
{
|
||
public string material { get; set; }
|
||
public string model { get; set; }
|
||
}
|
||
public class CheryCarTypeInfo
|
||
{
|
||
/// <summary> data </summary>
|
||
public CarInfoData data { get; set; }
|
||
|
||
/// <summary> message </summary>
|
||
public string message { get; set; }
|
||
|
||
/// <summary> serno </summary>
|
||
public string serno { get; set; }
|
||
|
||
/// <summary> success </summary>
|
||
public string success { get; set; }
|
||
|
||
}
|
||
|
||
public static class JsonHelper
|
||
{
|
||
/// <summary>
|
||
/// 对象转成JSON 格式字符串
|
||
/// </summary>
|
||
/// <param name="obj">对象</param>
|
||
/// <returns>JSON格式的字符串</returns>
|
||
public static string ObjectToJson(object obj)
|
||
{
|
||
return JsonConvert.SerializeObject(obj);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 解析JSON字符串生成对象实体
|
||
/// </summary>
|
||
/// <typeparam name="T">对象类型</typeparam>
|
||
/// <param name="json">json字符串</param>
|
||
/// <returns>对象实体</returns>
|
||
public static T DeserializeJsonToObject<T>(string json) where T : class
|
||
{
|
||
Newtonsoft.Json.JsonSerializer serializer = new Newtonsoft.Json.JsonSerializer();
|
||
StringReader sr = new StringReader(json);
|
||
object o = serializer.Deserialize(new JsonTextReader(sr), typeof(T));
|
||
T t = o as T;
|
||
return t;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 解析JSON数组生成对象实体集合
|
||
/// </summary>
|
||
/// <typeparam name="T">对象类型</typeparam>
|
||
/// <param name="json">json数组字符串(eg.[{"ID":"112","Name":"石子儿"}])</param>
|
||
/// <returns>对象实体集合</returns>
|
||
public static List<T> DeserializeJsonToList<T>(string json) where T : class
|
||
{
|
||
Newtonsoft.Json.JsonSerializer serializer = new JsonSerializer();
|
||
StringReader sr = new StringReader(json);
|
||
object o = serializer.Deserialize(new JsonTextReader(sr), typeof(List<T>));
|
||
List<T> list = o as List<T>;
|
||
return list;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 数据表转键值对集合
|
||
/// 把DataTable转成 List集合, 存每一行
|
||
/// 集合中放的是键值对字典,存每一列
|
||
/// </summary>
|
||
/// <param name="dt">数据表</param>
|
||
/// <returns>哈希表数组</returns>
|
||
public static List<Dictionary<string, object>> DataTableToList(DataTable dt)
|
||
{
|
||
List<Dictionary<string, object>> list = new List<Dictionary<string, object>>();
|
||
|
||
foreach (DataRow dr in dt.Rows)
|
||
{
|
||
Dictionary<string, object> dic = new Dictionary<string, object>();
|
||
foreach (DataColumn dc in dt.Columns)
|
||
{
|
||
dic.Add(dc.ColumnName, dr[dc.ColumnName]);
|
||
}
|
||
list.Add(dic);
|
||
}
|
||
return list;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 数据集转键值对数组字典
|
||
/// </summary>
|
||
/// <returns>键值对数组字典</returns>
|
||
public static Dictionary<string, List<Dictionary<string, object>>> DataSetToDic(DataSet ds)
|
||
{
|
||
Dictionary<string, List<Dictionary<string, object>>> result = new Dictionary<string, List<Dictionary<string, object>>>();
|
||
|
||
foreach (DataTable dt in ds.Tables)
|
||
result.Add(dt.TableName, DataTableToList(dt));
|
||
|
||
return result;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 数据表转JSON
|
||
/// </summary>
|
||
/// <param name="dt">数据表</param>
|
||
/// <returns>JSON字符串</returns>
|
||
public static string DataTableToJson(DataTable dt)
|
||
{
|
||
return ObjectToJson(DataTableToList(dt));
|
||
}
|
||
|
||
/// <summary>
|
||
/// JSON文本转对象,泛型方法 常用
|
||
/// </summary>
|
||
/// <typeparam name="T">类型</typeparam>
|
||
/// <param name="jsonText">JSON文本</param>
|
||
/// <returns>指定类型的对象</returns>
|
||
public static T JsonToObject<T>(string jsonText)
|
||
{
|
||
return JsonConvert.DeserializeObject<T>(jsonText);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 将JSON文本转换为数据表数据
|
||
/// </summary>
|
||
/// <param name="jsonText">JSON文本</param>
|
||
/// <returns>数据表字典</returns>
|
||
public static Dictionary<string, List<Dictionary<string, object>>> TablesDataFromJson(string jsonText)
|
||
{
|
||
return JsonToObject<Dictionary<string, List<Dictionary<string, object>>>>(jsonText);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 将JSON文本转换成数据行
|
||
/// </summary>
|
||
/// <param name="jsonText">JSON文本</param>
|
||
/// <returns>数据行的字典</returns>
|
||
public static Dictionary<string, object> DataRowFromJson(string jsonText)
|
||
{
|
||
return JsonToObject<Dictionary<string, object>>(jsonText);
|
||
}
|
||
}
|
||
} |