933 lines
35 KiB
VB.net
933 lines
35 KiB
VB.net
|
Imports System.Net.Sockets
|
|||
|
|
Imports System.Text
|
|||
|
|
Imports System.Threading
|
|||
|
|
Imports System.Windows.Forms
|
|||
|
|
Imports UTS_Core.UTSModule.DbConnect
|
|||
|
|
Imports UTS_Core.UTSModule.DbTableModel.Customer
|
|||
|
|
Imports UTS_Core.UTSModule.Login
|
|||
|
|
Imports UTS_Core.UTSModule.Production
|
|||
|
|
Imports UTS_Core.UTSModule.Service
|
|||
|
|
Imports UTS_Core.UTSModule.Station
|
|||
|
|
Imports UTS_Core.UTSModule.Test
|
|||
|
|
Imports UTS_Core.UTSModule.Test.StatusMonitor
|
|||
|
|
|
|||
|
|
|
|||
|
|
Namespace UTSModule
|
|||
|
|
''' <summary>
|
|||
|
|
'''UTS系列App与UtsCore交互为避免重复书写产生的中间类
|
|||
|
|
''' </summary>
|
|||
|
|
Public Class UtsAppForm
|
|||
|
|
Implements IDisposable
|
|||
|
|
|
|||
|
|
''' <summary>本地服务索引</summary>
|
|||
|
|
Private _serviceIndex As Integer
|
|||
|
|
|
|||
|
|
''' <summary>本地服务角色,0客户端，1服务器</summary>
|
|||
|
|
Private _serviceRoles As Integer
|
|||
|
|
|
|||
|
|
''' <summary>本地服务别名</summary>
|
|||
|
|
Private _serviceAlias As String
|
|||
|
|
|
|||
|
|
''' <summary>本地服务组名（子网名）</summary>
|
|||
|
|
Private _serviceGroup As String
|
|||
|
|
|
|||
|
|
''' <summary>软件名称</summary>
|
|||
|
|
Private _appName As String
|
|||
|
|
|
|||
|
|
''' <summary>软件版本</summary>
|
|||
|
|
Private _appVersion As String
|
|||
|
|
|
|||
|
|
''' <summary>测试记录表名</summary>
|
|||
|
|
Private _testLogTableName As String
|
|||
|
|
|
|||
|
|
''' <summary>登录用户信息</summary>
|
|||
|
|
Private _userInfo As UserInfo
|
|||
|
|
|
|||
|
|
''' <summary>鉴权文件信息</summary>
|
|||
|
|
Private _license As License.License
|
|||
|
|
|
|||
|
|
''' <summary>当前选择站位信息</summary>
|
|||
|
|
Private _processStation As ProcessStation
|
|||
|
|
|
|||
|
|
''' <summary>测试结果内容</summary>
|
|||
|
|
Private ReadOnly _testResult As TestResult
|
|||
|
|
|
|||
|
|
''' <summary>软件注册器</summary>
|
|||
|
|
Private _register As AppRegister
|
|||
|
|
|
|||
|
|
''' <summary>服务通讯TCP客户端</summary>
|
|||
|
|
Private _tcpClient As TcpClient
|
|||
|
|
|
|||
|
|
''' <summary>是否释放当前类</summary>
|
|||
|
|
Private _disposedValue As Boolean
|
|||
|
|
|
|||
|
|
''' <summary>站位观察者集合</summary>
|
|||
|
|
Private ReadOnly _observerList As List(Of IProcessStation)
|
|||
|
|
|
|||
|
|
''' <summary>当前软件所属站位类型,None则无类型</summary>
|
|||
|
|
Private _stationType As ProcessStation.StationTypeEnum
|
|||
|
|
|
|||
|
|
''' <summary>UTS软件单例对象</summary>
|
|||
|
|
Private Shared _utsApp As UtsAppForm
|
|||
|
|
|
|||
|
|
''' <summary>UTS软件单例对象初始化锁</summary>
|
|||
|
|
Private Shared InitLock As New Object
|
|||
|
|
|
|||
|
|
'CZH 2023-05-19 增加站位列表集
|
|||
|
|
Public projectInfo As Project.ProjectInfo
|
|||
|
|
''' <summary>
|
|||
|
|
''' 创建单例对象
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public Shared Function CreateSingleton() As UtsAppForm
|
|||
|
|
If _utsApp IsNot Nothing Then
|
|||
|
|
Return _utsApp
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
SyncLock InitLock
|
|||
|
|
Thread.MemoryBarrier()
|
|||
|
|
If _utsApp Is Nothing Then
|
|||
|
|
_utsApp = New UtsAppForm
|
|||
|
|
End If
|
|||
|
|
End SyncLock
|
|||
|
|
|
|||
|
|
Return _utsApp
|
|||
|
|
End Function
|
|||
|
|
|
|||
|
|
|
|||
|
|
Private Sub New()
|
|||
|
|
_disposedValue = False
|
|||
|
|
|
|||
|
|
_testLogTableName = String.Empty
|
|||
|
|
|
|||
|
|
_testResult = New TestResult()
|
|||
|
|
|
|||
|
|
_observerList = New List(Of IProcessStation)()
|
|||
|
|
|
|||
|
|
ShowUnSearchOrderIDTip = True
|
|||
|
|
|
|||
|
|
SaveUnSearchOrderIDLog = False
|
|||
|
|
|
|||
|
|
IsInitialized = False
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 添加站位修改观察者,唯一添加
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="observer"></param>
|
|||
|
|
Public Sub AddStatisticsObserver(observer As IProcessStation)
|
|||
|
|
If _observerList.Contains(observer) = False Then _observerList.Add(observer)
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 移除站位修改观察者
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="observer"></param>
|
|||
|
|
Public Sub RemoveStatisticsObserver(observer As IProcessStation)
|
|||
|
|
If _observerList.Contains(observer) Then _observerList.Remove(observer)
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 清空站位修改观察者
|
|||
|
|
''' </summary>
|
|||
|
|
Public Sub ClearStatisticsObserver()
|
|||
|
|
_observerList.Clear()
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 初始化完成
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public Property IsInitialized As Boolean
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 用户账号信息
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property Account As UserInfo
|
|||
|
|
Get
|
|||
|
|
Return _userInfo
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 服务索引
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property ServiceIndex As Integer
|
|||
|
|
Get
|
|||
|
|
Return _serviceIndex
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 服务角色,0客户端，1服务器
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property ServiceRoles As Integer
|
|||
|
|
Get
|
|||
|
|
Return _serviceRoles
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 服务别名
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property ServiceAlias As String
|
|||
|
|
Get
|
|||
|
|
Return _serviceAlias
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 服务所属分组
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property ServiceGroup As String
|
|||
|
|
Get
|
|||
|
|
Return _serviceGroup
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 鉴权文件信息
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property License As License.License
|
|||
|
|
Get
|
|||
|
|
Return _license
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 工厂产线信息
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property ProductionLines() As ProductionLinesManager
|
|||
|
|
Get
|
|||
|
|
Return ProductionLinesManager.CreateManager()
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 测试站信息
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property TestResult() As TestResult
|
|||
|
|
Get
|
|||
|
|
Return _testResult
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 测试站信息
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property ProcessStation() As ProcessStation
|
|||
|
|
Get
|
|||
|
|
Return _processStation
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' APP注册机
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property Register() As AppRegister
|
|||
|
|
Get
|
|||
|
|
Return _register
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 测试记录表名
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public ReadOnly Property TestLogTableName() As String
|
|||
|
|
Get
|
|||
|
|
Return _testLogTableName
|
|||
|
|
End Get
|
|||
|
|
End Property
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 未查询到数据库订单号时是否显示提示
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public Property ShowUnSearchOrderIDTip() As Boolean
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 允许保存未查询到订单号的记录入库,显示提示时,此字段不生效。
|
|||
|
|
''' </summary>
|
|||
|
|
''' <returns></returns>
|
|||
|
|
Public Property SaveUnSearchOrderIDLog() As Boolean
|
|||
|
|
|
|||
|
|
Private _testChangedTime As DateTime
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 初始化信息,唯一初始化
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="sType">软件选择站位时，可以选择的站位类型,默认显示测试站位</param>
|
|||
|
|
Public Sub Initialize(Optional sType As ProcessStation.StationTypeEnum = ProcessStation.StationTypeEnum.Test)
|
|||
|
|
If IsInitialized = True Then Return
|
|||
|
|
IsInitialized = True
|
|||
|
|
|
|||
|
|
'建立Tcp与服务通讯的套接字
|
|||
|
|
ConnectDataService()
|
|||
|
|
|
|||
|
|
'显示登录窗体
|
|||
|
|
ShowLoginForm()
|
|||
|
|
|
|||
|
|
'注册软件
|
|||
|
|
RegisterApp()
|
|||
|
|
|
|||
|
|
'给测试记录附上初始值
|
|||
|
|
InitializeTestResult()
|
|||
|
|
|
|||
|
|
'记录站位类型提供过滤筛选
|
|||
|
|
_stationType = sType
|
|||
|
|
|
|||
|
|
'记录测试变化信息
|
|||
|
|
_testChangedTime = Now
|
|||
|
|
AddHandler TestStatusMonitor.TestStatusChanged, AddressOf TestStatusChanged
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 测试状态改变处理事件
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="sender"></param>
|
|||
|
|
''' <param name="e"></param>
|
|||
|
|
Private Sub TestStatusChanged(sender As Object, e As TestStatusChangedEventArgs)
|
|||
|
|
'记录上一次变化的时间
|
|||
|
|
_testChangedTime = Now
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
|
|||
|
|
#Region "服务通讯模块"
|
|||
|
|
''' <summary>
|
|||
|
|
''' 连接数据服务,异步执行
|
|||
|
|
''' </summary>
|
|||
|
|
Public Sub ConnectDataService()
|
|||
|
|
ThreadPool.QueueUserWorkItem(New WaitCallback(AddressOf KeepTcpClientAlive))
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 保持与数据服务的Tcp连接存活
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="state"></param>
|
|||
|
|
Private Sub KeepTcpClientAlive(state As Object)
|
|||
|
|
Static remoteIp As String = "127.0.0.1"
|
|||
|
|
|
|||
|
|
While True
|
|||
|
|
Try
|
|||
|
|
If _tcpClient Is Nothing OrElse _tcpClient.Client Is Nothing Then
|
|||
|
|
_tcpClient = New TcpClient(remoteIp, CInt(UtsRegistry.DataServicePort))
|
|||
|
|
|
|||
|
|
'开启监听
|
|||
|
|
ThreadPool.QueueUserWorkItem(New WaitCallback(AddressOf ClientReceive), _tcpClient)
|
|||
|
|
|
|||
|
|
'通知服务软件启动
|
|||
|
|
SendAppMsg(_tcpClient, TaskJsonParam.AppMsgTypes.AppStart)
|
|||
|
|
|
|||
|
|
'开启与服务通知心跳包
|
|||
|
|
ThreadPool.QueueUserWorkItem(New WaitCallback(AddressOf SendAppAlive), _tcpClient)
|
|||
|
|
End If
|
|||
|
|
Catch ex As Exception
|
|||
|
|
Console.WriteLine($"InitTcpClient Error:{ex.Message}!")
|
|||
|
|
End Try
|
|||
|
|
|
|||
|
|
Thread.Sleep(1000 * 10)
|
|||
|
|
End While
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 定期发送App心跳包
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="state"></param>
|
|||
|
|
Private Sub SendAppAlive(state As Object)
|
|||
|
|
Dim client As TcpClient = CType(state, TcpClient)
|
|||
|
|
While True
|
|||
|
|
If client Is Nothing OrElse client.Client Is Nothing Then Return
|
|||
|
|
|
|||
|
|
Thread.Sleep(1000)
|
|||
|
|
|
|||
|
|
SendAppMsg(client, TaskJsonParam.AppMsgTypes.AppAlive)
|
|||
|
|
|
|||
|
|
End While
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 主动向服务发送变化数据
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="type">变化类型</param>
|
|||
|
|
''' <param name="fileds">字段内容</param>
|
|||
|
|
Public Sub SendAppMsg(type As TaskJsonParam.AppMsgTypes, fileds As Dictionary(Of String, String))
|
|||
|
|
If _tcpClient Is Nothing OrElse _tcpClient.Client Is Nothing Then Return
|
|||
|
|
|
|||
|
|
Dim param As New TaskJsonParam
|
|||
|
|
param.CmdName = TaskJsonParam.CmdNamesEnum.AppMsg
|
|||
|
|
param.AppName = Application.ProductName
|
|||
|
|
|
|||
|
|
If _userInfo Is Nothing Then
|
|||
|
|
param.User = "Admin"
|
|||
|
|
Else
|
|||
|
|
param.User = _userInfo.UserName
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
param.AppInfo.Add("AppStatus", type.ToString)
|
|||
|
|
For Each filed As KeyValuePair(Of String, String) In fileds
|
|||
|
|
param.AppInfo.Add(filed.Key, filed.Value)
|
|||
|
|
Next
|
|||
|
|
|
|||
|
|
SendJsonString(_tcpClient, TaskJsonParam.SerializeToJson(param) & vbCrLf)
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 发送App上报信息
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="client"></param>
|
|||
|
|
''' <param name="type"></param>
|
|||
|
|
Private Sub SendAppMsg(client As TcpClient, type As TaskJsonParam.AppMsgTypes)
|
|||
|
|
If client Is Nothing OrElse client.Client Is Nothing Then Return
|
|||
|
|
|
|||
|
|
Dim param As New TaskJsonParam
|
|||
|
|
param.CmdName = TaskJsonParam.CmdNamesEnum.AppMsg
|
|||
|
|
param.AppName = Application.ProductName
|
|||
|
|
|
|||
|
|
If _userInfo Is Nothing Then
|
|||
|
|
param.User = "Admin"
|
|||
|
|
Else
|
|||
|
|
param.User = _userInfo.UserName
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
Select Case type
|
|||
|
|
Case TaskJsonParam.AppMsgTypes.AppStart
|
|||
|
|
param.AppInfo.Add("AppStatus", TaskJsonParam.AppMsgTypes.AppStart.ToString)
|
|||
|
|
param.AppInfo.Add("Version", Application.ProductVersion)
|
|||
|
|
param.AppInfo.Add("AppPath", Application.StartupPath)
|
|||
|
|
Case TaskJsonParam.AppMsgTypes.AppClose
|
|||
|
|
param.AppInfo.Add("AppStatus", TaskJsonParam.AppMsgTypes.AppClose.ToString)
|
|||
|
|
Case TaskJsonParam.AppMsgTypes.AppAlive
|
|||
|
|
param.AppInfo.Add("AppStatus", TaskJsonParam.AppMsgTypes.AppAlive.ToString)
|
|||
|
|
param.AppInfo.Add("Version", Application.ProductVersion)
|
|||
|
|
|
|||
|
|
If _processStation Is Nothing Then
|
|||
|
|
param.AppInfo.Add("Project", "")
|
|||
|
|
param.AppInfo.Add("Station", "")
|
|||
|
|
param.AppInfo.Add("TestPlan", "")
|
|||
|
|
Else
|
|||
|
|
param.AppInfo.Add("Project", _processStation.ParentProject.Name)
|
|||
|
|
param.AppInfo.Add("Station", _processStation.Name)
|
|||
|
|
param.AppInfo.Add("TestPlan", _processStation.Packet.FileName)
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
param.AppInfo.Add("UtsStatus", StatusMonitor.ComportStatusMonitor.ComportStatus.ToString)
|
|||
|
|
param.AppInfo.Add("TestStatus", StatusMonitor.TestStatusMonitor.TestStatus.ToString)
|
|||
|
|
Case TaskJsonParam.AppMsgTypes.StationChanged
|
|||
|
|
param.AppInfo.Add("AppStatus", TaskJsonParam.AppMsgTypes.StationChanged.ToString)
|
|||
|
|
param.AppInfo.Add("Project", _processStation.ParentProject.Name)
|
|||
|
|
param.AppInfo.Add("Station", _processStation.Name)
|
|||
|
|
param.AppInfo.Add("TestPlan", _processStation.Packet.FileName)
|
|||
|
|
End Select
|
|||
|
|
|
|||
|
|
SendJsonString(client, TaskJsonParam.SerializeToJson(param) & vbCrLf)
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 发送数据
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="tcpClient"></param>
|
|||
|
|
''' <param name="jsonString"></param>
|
|||
|
|
Private Sub SendJsonString(tcpClient As TcpClient, jsonString As String)
|
|||
|
|
Static SendLock As New Object
|
|||
|
|
Static FailCount As Integer = 0
|
|||
|
|
|
|||
|
|
If tcpClient Is Nothing OrElse tcpClient.Client Is Nothing Then Return
|
|||
|
|
|
|||
|
|
SyncLock SendLock
|
|||
|
|
Try
|
|||
|
|
Dim buf() As Byte = Encoding.UTF8.GetBytes(jsonString)
|
|||
|
|
tcpClient.GetStream().Write(buf, 0, buf.Length)
|
|||
|
|
FailCount = 0
|
|||
|
|
Catch ex As Exception
|
|||
|
|
FailCount += 1
|
|||
|
|
If FailCount > 3 Then
|
|||
|
|
FailCount = 0
|
|||
|
|
tcpClient.Close()
|
|||
|
|
End If
|
|||
|
|
Console.WriteLine($"TcpClient Send Data Error!{ex.Message}")
|
|||
|
|
End Try
|
|||
|
|
End SyncLock
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' APP接收服务器数据
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="state"></param>
|
|||
|
|
Public Sub ClientReceive(state As Object)
|
|||
|
|
Dim client As TcpClient = CType(state, TcpClient)
|
|||
|
|
Dim len As Integer
|
|||
|
|
Dim buf(4096) As Byte
|
|||
|
|
|
|||
|
|
While True
|
|||
|
|
Try
|
|||
|
|
len = client.Client.Receive(buf)
|
|||
|
|
Catch ex As Exception
|
|||
|
|
Console.WriteLine($"TcpServer Receive Error:{ex.Message},Recycling Connection!")
|
|||
|
|
Exit While
|
|||
|
|
End Try
|
|||
|
|
|
|||
|
|
If len = 0 Then
|
|||
|
|
Console.WriteLine($"TcpServer {client.Client.RemoteEndPoint} Is Disconnect.")
|
|||
|
|
Exit While
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
Dim destBuf(len - 1) As Byte
|
|||
|
|
Array.Copy(buf, 0, destBuf, 0, destBuf.Length)
|
|||
|
|
ThreadPool.QueueUserWorkItem(New WaitCallback(AddressOf DealData), New TcpData(client, destBuf))
|
|||
|
|
End While
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
Public Sub DealData(state As Object)
|
|||
|
|
Dim data As TcpData = CType(state, TcpData)
|
|||
|
|
Dim jsonStrings As String = Encoding.UTF8.GetString(data.Buffer)
|
|||
|
|
|
|||
|
|
'校验Json字符串，必须以回车换行结尾
|
|||
|
|
If jsonStrings.EndsWith(vbCrLf) = False Then Return
|
|||
|
|
|
|||
|
|
For Each jsonString As String In jsonStrings.Split(New String() {vbCrLf}, Integer.MaxValue, StringSplitOptions.RemoveEmptyEntries)
|
|||
|
|
Try
|
|||
|
|
'反序列化
|
|||
|
|
Dim taskParam As TaskJsonParam = TaskJsonParam.DeserializeFormJson(jsonString)
|
|||
|
|
|
|||
|
|
'反序列化失败,则处理下一包
|
|||
|
|
If IsNothing(taskParam) Then Continue For
|
|||
|
|
|
|||
|
|
'处理数据,返回回复数据
|
|||
|
|
Dim reply As TaskJsonParam = DealReceiveData(taskParam)
|
|||
|
|
|
|||
|
|
'无需回复,则处理下一包
|
|||
|
|
If reply Is Nothing Then Continue For
|
|||
|
|
|
|||
|
|
'序列化回复数据
|
|||
|
|
Dim replyString As String = TaskJsonParam.SerializeToJson(reply) & vbCrLf
|
|||
|
|
|
|||
|
|
'回复数据
|
|||
|
|
SendJsonString(data.Client, replyString)
|
|||
|
|
Catch ex As Exception
|
|||
|
|
Console.WriteLine($"Deal Receive Data Error!{ex.Message}")
|
|||
|
|
End Try
|
|||
|
|
Next
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 处理数据,并返回回复数据
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="taskParam">需要处理的数据参数</param>
|
|||
|
|
''' <returns>需要回复的数据</returns>
|
|||
|
|
Private Function DealReceiveData(taskParam As TaskJsonParam) As TaskJsonParam
|
|||
|
|
Dim replyParam As TaskJsonParam
|
|||
|
|
Select Case taskParam.CmdName
|
|||
|
|
Case TaskJsonParam.CmdNamesEnum.AppMsg
|
|||
|
|
replyParam = Nothing '不处理
|
|||
|
|
|
|||
|
|
If taskParam.CmdStatus = "Fail" Then Exit Select
|
|||
|
|
|
|||
|
|
Dim status As TaskJsonParam.AppMsgTypes
|
|||
|
|
Try
|
|||
|
|
status = CType([Enum].Parse(GetType(TaskJsonParam.AppMsgTypes), taskParam.AppInfo("AppStatus")), TaskJsonParam.AppMsgTypes)
|
|||
|
|
|
|||
|
|
Select Case status
|
|||
|
|
Case TaskJsonParam.AppMsgTypes.AppAlive
|
|||
|
|
Static dbLastStatus As Integer = -1
|
|||
|
|
Static ftpLastStatus As Integer = -1
|
|||
|
|
Static cacheLastStatus As Integer = -1
|
|||
|
|
Static syncLastStatus As String = ""
|
|||
|
|
Static servicesLastStatus As String = ""
|
|||
|
|
|
|||
|
|
Dim dbStatus As Integer = -1
|
|||
|
|
Dim ftpStatus As Integer = -1
|
|||
|
|
Dim cacheCount As Integer = -1
|
|||
|
|
|
|||
|
|
Integer.TryParse(taskParam.AppInfo("DbStatus"), dbStatus)
|
|||
|
|
If dbLastStatus <> dbStatus Then
|
|||
|
|
dbLastStatus = dbStatus
|
|||
|
|
RaiseEvent DbStatusChanged(dbLastStatus)
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
Integer.TryParse(taskParam.AppInfo("FtpStatus"), ftpStatus)
|
|||
|
|
If ftpLastStatus <> ftpStatus Then
|
|||
|
|
ftpLastStatus = ftpStatus
|
|||
|
|
RaiseEvent FtpStatusChanged(dbLastStatus)
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
Dim flg As Boolean = False '是否更新同步状态文本
|
|||
|
|
Integer.TryParse(taskParam.AppInfo("CacheCount"), cacheCount)
|
|||
|
|
If cacheLastStatus <> cacheCount Then
|
|||
|
|
cacheLastStatus = cacheCount
|
|||
|
|
flg = True
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
Dim syncTime As String = taskParam.AppInfo("SyncTime")
|
|||
|
|
If syncLastStatus <> syncTime Then
|
|||
|
|
syncLastStatus = syncTime
|
|||
|
|
flg = True
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
If flg Then
|
|||
|
|
RaiseEvent SyncTimeChanged($"[{cacheLastStatus}] {syncLastStatus}")
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
Dim tmpTime As Date
|
|||
|
|
If Date.TryParse(syncTime, tmpTime) Then
|
|||
|
|
If (Now - tmpTime).TotalMinutes > 6 Then
|
|||
|
|
DatabaseStatusMonitor.DatabaseSyncStatus = DatabaseStatusMonitor.DatabaseSyncStatusEnum.UnCompleted
|
|||
|
|
Else
|
|||
|
|
DatabaseStatusMonitor.DatabaseSyncStatus = DatabaseStatusMonitor.DatabaseSyncStatusEnum.Completed
|
|||
|
|
End If
|
|||
|
|
Else
|
|||
|
|
DatabaseStatusMonitor.DatabaseSyncStatus = DatabaseStatusMonitor.DatabaseSyncStatusEnum.Unknown
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
Dim services As String = taskParam.AppInfo("Services")
|
|||
|
|
If servicesLastStatus <> services Then
|
|||
|
|
servicesLastStatus = services
|
|||
|
|
RaiseEvent ServicesChanged(servicesLastStatus)
|
|||
|
|
End If
|
|||
|
|
Case Else
|
|||
|
|
Console.WriteLine($"status:{status}")
|
|||
|
|
End Select
|
|||
|
|
Catch ex As Exception
|
|||
|
|
|
|||
|
|
End Try
|
|||
|
|
|
|||
|
|
Case TaskJsonParam.CmdNamesEnum.ServiceMsg
|
|||
|
|
replyParam = DealServiceMsg(taskParam)
|
|||
|
|
Case Else
|
|||
|
|
replyParam = Nothing
|
|||
|
|
Console.WriteLine($"Invalid CmdName:{taskParam.CmdName}")
|
|||
|
|
End Select
|
|||
|
|
Return replyParam
|
|||
|
|
End Function
|
|||
|
|
|
|||
|
|
Public Event DbStatusChanged(status As Integer)
|
|||
|
|
Public Event FtpStatusChanged(status As Integer)
|
|||
|
|
Public Event SyncTimeChanged(timeString As String)
|
|||
|
|
Public Event ServicesChanged(services As String)
|
|||
|
|
|
|||
|
|
|
|||
|
|
Private Function DealServiceMsg(taskParam As TaskJsonParam) As TaskJsonParam
|
|||
|
|
Dim replyParam As New TaskJsonParam(taskParam.CmdName, True)
|
|||
|
|
|
|||
|
|
Try
|
|||
|
|
If taskParam.AppInfo Is Nothing OrElse taskParam.AppInfo.Count = 0 Then Return Nothing
|
|||
|
|
|
|||
|
|
'依此判断App修改类型
|
|||
|
|
Dim status As TaskJsonParam.ServiceMsgTypes
|
|||
|
|
status = CType([Enum].Parse(GetType(TaskJsonParam.ServiceMsgTypes), taskParam.AppInfo("AppStatus")), TaskJsonParam.ServiceMsgTypes)
|
|||
|
|
|
|||
|
|
Select Case status
|
|||
|
|
Case TaskJsonParam.ServiceMsgTypes.DbHostChange
|
|||
|
|
UtsDb.DbHostChanged(taskParam.AppInfo("DbHost"))
|
|||
|
|
Case TaskJsonParam.ServiceMsgTypes.FtpHostChange
|
|||
|
|
UtsFtp.CreateObject.FtpHost = taskParam.AppInfo("FtpHost")
|
|||
|
|
End Select
|
|||
|
|
|
|||
|
|
replyParam.CmdStatus = TaskJsonParam.CmdStatusEnum.Pass.ToString()
|
|||
|
|
Catch ex As Exception
|
|||
|
|
replyParam.CmdStatus = TaskJsonParam.CmdStatusEnum.Fail.ToString()
|
|||
|
|
replyParam.CmdMsg = ex.Message
|
|||
|
|
End Try
|
|||
|
|
|
|||
|
|
Return replyParam
|
|||
|
|
End Function
|
|||
|
|
|
|||
|
|
Public Class TcpData
|
|||
|
|
Sub New(c As TcpClient, buf() As Byte)
|
|||
|
|
Client = c
|
|||
|
|
Buffer = buf
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
Public Client As TcpClient
|
|||
|
|
|
|||
|
|
Public Buffer() As Byte
|
|||
|
|
End Class
|
|||
|
|
#End Region
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 显示登陆页面
|
|||
|
|
''' </summary>
|
|||
|
|
Private Sub ShowLoginForm()
|
|||
|
|
If LoginParams.IsShowLoginForm = False Then Return
|
|||
|
|
Using frmLogin As New LoginForm
|
|||
|
|
If frmLogin.ShowDialog() = DialogResult.OK Then
|
|||
|
|
_userInfo = frmLogin.UserLoginInfo
|
|||
|
|
_license = frmLogin.UserLicense
|
|||
|
|
Else
|
|||
|
|
Throw New Exception($"User Quit!")
|
|||
|
|
End If
|
|||
|
|
End Using
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 注册APP
|
|||
|
|
''' </summary>
|
|||
|
|
Private Sub RegisterApp()
|
|||
|
|
_serviceIndex = CInt(UtsRegistry.DataServiceIndex)
|
|||
|
|
_serviceRoles = CInt(UtsRegistry.Roles)
|
|||
|
|
_serviceAlias = UtsRegistry.DataServiceAlias
|
|||
|
|
_serviceGroup = UtsRegistry.BarnchNet
|
|||
|
|
_appName = Application.ProductName
|
|||
|
|
_appVersion = Application.ProductVersion
|
|||
|
|
|
|||
|
|
AppRegister.CreateAppListTable() '创建日志列表
|
|||
|
|
AppRegister.CreateAppLogTable() '创建日志记录表
|
|||
|
|
_register = New AppRegister(_serviceIndex, _appName, _appVersion)
|
|||
|
|
ThreadPool.QueueUserWorkItem(New WaitCallback(AddressOf UpdateAppAliveTime))
|
|||
|
|
ThreadPool.QueueUserWorkItem(New WaitCallback(AddressOf SaveServiceLog))
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 初始化测试结果字段信息
|
|||
|
|
''' </summary>
|
|||
|
|
Private Sub InitializeTestResult()
|
|||
|
|
_testResult.UserID = Account.UserId
|
|||
|
|
_testResult.ServiceID = _serviceIndex
|
|||
|
|
_testResult.AppName = _appName & _appVersion
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 填充测试结果订单信息字段
|
|||
|
|
''' </summary>
|
|||
|
|
Private Sub FillTestResultOrderID()
|
|||
|
|
_testResult.OrderID = DbConnector.SearchOrderID(_processStation.ParentProject.Index, _testResult.DUT_SN)
|
|||
|
|
|
|||
|
|
If _testResult.OrderID = -1 Then
|
|||
|
|
'仅自动生成条码模式下保证有订单号,其余模式条码不检测
|
|||
|
|
If _processStation.SnType <> ProcessStation.SnTypeEnum.Auto Then Return
|
|||
|
|
If ShowUnSearchOrderIDTip Then
|
|||
|
|
If MsgBox($"未查询到条码[{_testResult.DUT_SN}]对应的订单号,是否继续录入？", MsgBoxStyle.OkCancel, "Tip") <> MsgBoxResult.Ok Then
|
|||
|
|
Throw New Exception($"未查询条码[{_testResult.DUT_SN}]到指定订单号")
|
|||
|
|
End If
|
|||
|
|
Else
|
|||
|
|
If SaveUnSearchOrderIDLog = False Then
|
|||
|
|
Throw New Exception($"未查询条码[{_testResult.DUT_SN}]到指定订单号")
|
|||
|
|
End If
|
|||
|
|
End If
|
|||
|
|
End If
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 根据序号分配给测试记录的订单号，并将测试记录写入到数据库中，提交成功后会重置测试记录。
|
|||
|
|
''' </summary>
|
|||
|
|
Public Sub CommitTestResult(Optional uniqueRecord As Boolean = False)
|
|||
|
|
'填充订单号
|
|||
|
|
FillTestResultOrderID()
|
|||
|
|
|
|||
|
|
'提交测试记录
|
|||
|
|
If uniqueRecord Then
|
|||
|
|
DbConnector.SaveUniqueTestLog(_testLogTableName, _processStation, _testResult)
|
|||
|
|
Else
|
|||
|
|
DbConnector.SaveTestLog(_testLogTableName, _processStation, _testResult)
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 根据项目名与站位名称，加载项目站信息
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="projectName"></param>
|
|||
|
|
''' <param name="stationName"></param>
|
|||
|
|
Public Sub LoadStation(projectName As String, stationName As String, Optional filed As Dictionary(Of String, String) = Nothing)
|
|||
|
|
If String.IsNullOrWhiteSpace(projectName) Or String.IsNullOrWhiteSpace(stationName) Then
|
|||
|
|
Return
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
Using dlg As New DlgLoadStation
|
|||
|
|
dlg.UserInfo = Account '用与初始化项目信息时,更新操作者，同时可用与根据用户权限筛选项目
|
|||
|
|
If dlg.InitProjectStationWithoutShow(projectName, stationName) Then
|
|||
|
|
_processStation = dlg.ProcessStation
|
|||
|
|
projectInfo = dlg._projectInfo
|
|||
|
|
If String.IsNullOrEmpty(ProcessStation.Packet.FileName) Then
|
|||
|
|
ProcessStation.Packet.CreatePacket() '新建测试站包
|
|||
|
|
Else
|
|||
|
|
ProcessStation.Packet.LoadPacket() '读取测试站包
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
StationChanged(ProcessStation, filed) '测试站修改
|
|||
|
|
End If
|
|||
|
|
End Using
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 显示切换项目站信息页面，供用户修改测试站
|
|||
|
|
''' </summary>
|
|||
|
|
Public Sub ChangeStation(Optional filed As Dictionary(Of String, String) = Nothing)
|
|||
|
|
Using dlg As New DlgLoadStation
|
|||
|
|
dlg.UserInfo = Account '用与初始化项目信息时,更新操作者，同时可用与根据用户权限筛选项目
|
|||
|
|
|
|||
|
|
If _processStation Is Nothing Then
|
|||
|
|
If dlg.ShowDialog("", "", _stationType) <> DialogResult.OK Then Return
|
|||
|
|
Else
|
|||
|
|
If dlg.ShowDialog(_processStation.ParentProject.Name, _processStation.Name, _stationType) <> DialogResult.OK Then Return
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
If dlg.ProcessStation Is Nothing Then Return
|
|||
|
|
_processStation = dlg.ProcessStation
|
|||
|
|
projectInfo = dlg._projectInfo
|
|||
|
|
If String.IsNullOrEmpty(ProcessStation.Packet.FileName) Then
|
|||
|
|
ProcessStation.Packet.CreatePacket() '新建测试站包
|
|||
|
|
Else
|
|||
|
|
ProcessStation.Packet.LoadPacket() '读取测试站包
|
|||
|
|
End If
|
|||
|
|
StationChanged(ProcessStation, filed)
|
|||
|
|
|
|||
|
|
End Using
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
'2022-10-19 CZH 该改动针对已固定某一站的 资源包刷新
|
|||
|
|
Public Sub ChangeStation(processStation As ProcessStation， Optional filed As Dictionary(Of String, String) = Nothing)
|
|||
|
|
'Using dlg As New DlgLoadStation
|
|||
|
|
' dlg.UserInfo = Account '用与初始化项目信息时,更新操作者，同时可用与根据用户权限筛选项目
|
|||
|
|
|
|||
|
|
' If _processStation Is Nothing Then
|
|||
|
|
' If dlg.ShowDialog("", "", _stationType) <> DialogResult.OK Then Return
|
|||
|
|
' Else
|
|||
|
|
' If dlg.ShowDialog(_processStation.ParentProject.Name, _processStation.Name, _stationType) <> DialogResult.OK Then Return
|
|||
|
|
' End If
|
|||
|
|
|
|||
|
|
If processStation Is Nothing Then Return
|
|||
|
|
_processStation = processStation
|
|||
|
|
|
|||
|
|
If String.IsNullOrEmpty(processStation.Packet.FileName) Then
|
|||
|
|
processStation.Packet.CreatePacket() '新建测试站包
|
|||
|
|
Else
|
|||
|
|
processStation.Packet.LoadPacket() '读取测试站包
|
|||
|
|
End If
|
|||
|
|
StationChanged(processStation, filed)
|
|||
|
|
|
|||
|
|
'End Using
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 用户选择测试站后回调函数
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="station"></param>
|
|||
|
|
''' <param name="filed"></param>
|
|||
|
|
Private Sub StationChanged(station As ProcessStation, Optional filed As Dictionary(Of String, String) = Nothing)
|
|||
|
|
_testLogTableName = TestLogTable.TableName(station.ParentProject.Index, ProcessStation.StationID)
|
|||
|
|
|
|||
|
|
'本地新建测试记录表
|
|||
|
|
DbConnector.UtsCreateTestLogTableToLocal(_testLogTableName)
|
|||
|
|
|
|||
|
|
'添加预添加列
|
|||
|
|
If filed IsNot Nothing AndAlso filed.Count > 0 Then
|
|||
|
|
DbConnector.AddTestLogCols(_testLogTableName, filed)
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
'修改测试记录中测试流程
|
|||
|
|
_testResult.TestPlan = _processStation.Packet.FileName
|
|||
|
|
|
|||
|
|
'App日志
|
|||
|
|
_register.ProjectName = _processStation.ParentProject.Name
|
|||
|
|
_register.StationName = _processStation.Name
|
|||
|
|
_register.TestPlan = _processStation.Packet.FileName
|
|||
|
|
_register.AppendTraceLog($"Station Changed,PN:{station.ParentProject.Name},SN:{station.Name}.")
|
|||
|
|
_register.AppMsg = $"PN:{_processStation.ParentProject.Name},SN:{_processStation.Name},TP:{_register.TestPlan}"
|
|||
|
|
|
|||
|
|
'触发其他页面的站位修改事件
|
|||
|
|
For Each observer As IProcessStation In _observerList
|
|||
|
|
observer.StationChanged()
|
|||
|
|
Next
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 定期更新APP存活时间
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="state"></param>
|
|||
|
|
Private Sub UpdateAppAliveTime(state As Object)
|
|||
|
|
Dim Interval As Integer = 1000 * 60 * 1 '单位ms
|
|||
|
|
|
|||
|
|
While _disposedValue = False
|
|||
|
|
|
|||
|
|
If (Now - _testChangedTime).TotalMinutes >= 1 AndAlso TestStatusMonitor.TestStatus <> TestStatusMonitor.TestStatusEnum.Testing Then
|
|||
|
|
_register.AppStatus = 0
|
|||
|
|
Else
|
|||
|
|
_register.AppStatus = 1
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
Try
|
|||
|
|
_register.UpdateAliveTime()
|
|||
|
|
Catch ex As Exception
|
|||
|
|
Console.WriteLine($"UpdateAppAliveTime Error:{ex.Message}")
|
|||
|
|
End Try
|
|||
|
|
|
|||
|
|
Thread.Sleep(Interval)
|
|||
|
|
End While
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 保存软件运行日志至数据库
|
|||
|
|
''' </summary>
|
|||
|
|
''' <param name="state"></param>
|
|||
|
|
Private Sub SaveServiceLog(state As Object)
|
|||
|
|
Dim Interval As Integer = 1000 * 60 * 1 '单位ms
|
|||
|
|
|
|||
|
|
While _disposedValue = False
|
|||
|
|
SaveServiceLogQueueToDb()
|
|||
|
|
|
|||
|
|
Thread.Sleep(Interval)
|
|||
|
|
End While
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
''' <summary>
|
|||
|
|
''' 保存软件运行日志至数据库
|
|||
|
|
''' </summary>
|
|||
|
|
Private Sub SaveServiceLogQueueToDb()
|
|||
|
|
Try
|
|||
|
|
If _register IsNot Nothing Then
|
|||
|
|
_register.SaveLogQueueToDb()
|
|||
|
|
End If
|
|||
|
|
Catch ex As Exception
|
|||
|
|
Console.WriteLine($"SaveServiceLog Error:{ex.Message}")
|
|||
|
|
End Try
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
|
|||
|
|
Protected Overridable Sub Dispose(disposing As Boolean)
|
|||
|
|
If Not _disposedValue Then
|
|||
|
|
If disposing Then
|
|||
|
|
'释放托管状态(托管对象)
|
|||
|
|
End If
|
|||
|
|
|
|||
|
|
'释放未托管的资源(未托管的对象)并替代终结器
|
|||
|
|
'将大型字段设置为 null
|
|||
|
|
|
|||
|
|
_disposedValue = True
|
|||
|
|
|
|||
|
|
SaveServiceLogQueueToDb()
|
|||
|
|
End If
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
Public Sub Dispose() Implements IDisposable.Dispose
|
|||
|
|
' 不要更改此代码。请将清理代码放入“Dispose(disposing As Boolean)”方法中
|
|||
|
|
Dispose(disposing:=True)
|
|||
|
|
GC.SuppressFinalize(Me)
|
|||
|
|
End Sub
|
|||
|
|
|
|||
|
|
End Class
|
|||
|
|
End Namespace
|