using Casic.Birmm.RbFreqStandMeasure.R_DataBase.Service;
using Casic.Birmm.RbFreqStandMeasure.R_DataBase.Service.Impl;
using Casic.Birmm.RbFreqStandMeasure.Tools;
using System;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using System.IO;
using System.IO.Ports;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading;
using System.Windows.Forms;
namespace Casic.Birmm.RbFreqStandMeasure.tools
{
static class DetectionHelper
{
private static System.Threading.Timer timerAccuracy;
delegate void TimerDelegate(string text);
private static long devId = -1;
private static SerialPort portAccuracy;
private static DetectionService detectionService = new DetectionServiceImpl();
private static DetectionItemService detectionItemService = new DetectionItemServiceImpl();
private static DeviceService deviceService = new DeviceServiceImpl();
//1-STABILITY，2-ACCURACY，3-BOOT_FEATURE，4-AGE_RATE
public static void detecAccuracy(long deviceId, SerialPort port, DateTime endTime)
{
portAccuracy = port;
devId = deviceId;
TimeSpan secondSpan = new TimeSpan(endTime.Ticks - DateTime.Now.Ticks);
int delay = secondSpan.Milliseconds;
timerAccuracy = new System.Threading.Timer(exeAccuracy,null, delay + 200 ,1000);
}
private static void exeAccuracy(Object State)
{
string result = "";
double sum = 0.0;
for (int i = 0; i < 3; i++)
{
string fre = getFrequencyData(portAccuracy);
if (fre.Equals(""))
{
MessageBox.Show("从"+ portAccuracy.PortName + "获取数据失败！");
return;
}
sum = sum + Convert.ToDouble(fre);
detectionService.add(devId, fre, "2");
Thread.Sleep(1000);
}
result = sum / 3 + "";
detectionItemService.updateDetecStatus(devId, "", result, "", "");
deviceService.updateStatus(devId, "3", "");
}
public static SerialPort portOpen(string portName, int bandRate)
{
try
{
SerialPort port = new SerialPort();
// 搜索串口
string[] names = SerialPort.GetPortNames();
if (names.Length == 0 || Array.IndexOf(names, portName) == -1)
{
MessageBox.Show("没有搜索到串口" + portName + "！");
return null;
}
// 设置串口参数
port.PortName = names[0];
port.BaudRate = bandRate;
port.Parity = Parity.None;
port.DataBits = 8;
port.StopBits = StopBits.One;
port.Handshake = Handshake.None;
port.ReadTimeout = -1;
port.WriteTimeout = 3000;
// 打开串口
if (!port.IsOpen)
{
port.Open();
}
if (port.IsOpen)
{
return port;
}
return null;
}
catch (Exception ex)
{
LogHelper.WriteInfoLog(MethodBase.GetCurrentMethod().DeclaringType, "打开串口失败！" + ex.Message);
return null;
}
}
// 获取检测数据
public static string getFrequencyData(SerialPort port)
{
string received = "";
if (ConfigHelper.GetAppConfig("deviceType").ToString().Equals("1"))
{
int count = 0;
while (count < 5)
{
int readLen = port.BytesToRead;
if (readLen > 0)
{
byte[] buffer = new byte[readLen];
port.Read(buffer, 0, readLen);// 接收数据到buffer里面
string data = Encoding.ASCII.GetString(buffer);
string[] dataArray = data.Split(' ');
if (data.StartsWith("$") && dataArray.Length == 2 && data.LastIndexOf('$') == 0)
{
received = dataArray[0].Replace("$", "") + "." + data.Split(' ')[1].Replace(".", "").TrimEnd('0');
break;
}
}
count++;
}
}
else
{
int count = 0;
while (count < 11)
{
int readLen = port.BytesToRead;
if (readLen > 0)
{
byte[] buffer = new byte[readLen];
port.Read(buffer, 0, readLen);// 接收数据到buffer里面
string data = Encoding.ASCII.GetString(buffer);
string[] dataArray = data.Split(' ');
if (dataArray.Length == 3)
{
received = dataArray[2];
break;
}
}
count++;
}
}
return received;
}
// 获取铷钟数据
public static string getClockData(SerialPort port)
{
string clockStatus = "";
int count = 0;
while (count < 5)
{
int Readlen = port.BytesToRead;
// 接收到数据
if (Readlen > 0)
{
byte[] buffer = new byte[Readlen];
port.Read(buffer, 0, Readlen);// 接收数据到buffer里面
string data = Encoding.ASCII.GetString(buffer);
if (data.StartsWith("$") && data.Contains("*"))
{
string clockStatusCode = data.Split(',')[9];
switch (clockStatusCode)
{
case "1": clockStatus = "预热"; break;
case "2": clockStatus = "自由运动"; break;
case "3": clockStatus = "捕获"; break;
case "4": clockStatus = "快锁"; break;
case "5": clockStatus = "慢锁"; break;
case "7": clockStatus = "保持"; break;
default: break;
}
break;
}
}
count++;
}
return clockStatus;
}
// 获取卫星RMC数据
public static string getSatelliteRMCData(SerialPort port)
{
// RMC
string strRMC = "";
int count = 0;
while (count < 5)
{
int Readlen = port.BytesToRead;
if (Readlen > 0)
{
byte[] buffer = new byte[Readlen];
port.Read(buffer, 0, Readlen);// 接收数据到buffer里面
string data = Encoding.ASCII.GetString(buffer);
string[] dataArray = data.Split('$');
if (dataArray.Length > 9)
{
foreach (string sss in dataArray)
{
if (sss.Contains("GNRMC") && sss.Contains("*"))
{
string[] resultArray = sss.Split(',');
string time = resultArray[1];
time = time.Substring(0, 2) + ":" + time.Substring(2, 2) + ":" + time.Substring(4);
string status = resultArray[2]=="A"?"定位有效":"警告";
string date = resultArray[9];
date = date.Substring(4, 2) + "-" + date.Substring(2, 2) + "-" + date.Substring(0, 2);
strRMC = date + "," + time + "," + status;
}
}
}
}
count++;
}
return strRMC;
}
// 获取卫星GSV数据
public static string getSatelliteGSVData(SerialPort port)
{
// RMC
string strRMC = "";
int count = 0;
while (count < 5)
{
int Readlen = port.BytesToRead;
if (Readlen > 0)
{
byte[] buffer = new byte[Readlen];
port.Read(buffer, 0, Readlen);// 接收数据到buffer里面
string data = Encoding.ASCII.GetString(buffer);
string[] dataArray = data.Split('$');
if (dataArray.Length > 9)
{
foreach (string sss in dataArray)
{
if (sss.Contains("GNRMC") && sss.Contains("*"))
{
string[] resultArray = sss.Split(',');
string time = resultArray[1];
time = time.Substring(0, 2) + ":" + time.Substring(2, 2) + ":" + time.Substring(4);
string status = resultArray[2] == "A" ? "定位有效" : "警告";
string date = resultArray[9];
date = date.Substring(4, 2) + "-" + date.Substring(2, 2) + "-" + date.Substring(0, 2);
strRMC = date + "," + time + "," + status;
}
}
}
}
count++;
}
return strRMC;
}
}
}
