Boonlive_RD_Web/Desktop_RCULogAgent
8
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
main
Desktop_RCULogAgent/LogParsing.vb

1615 lines
69 KiB
VB.net
Raw Permalink Normal View History

初始化
2025-12-11 11:39:02 +08:00
Imports System.Data.Common
Imports System.Data.SQLite
Imports System.IO
Imports System.Text
Imports System.Threading
Imports Scripting
Public Class LogParsing
Enum Debugtype
log = 1
End Enum
Enum LNetComm
N_Send = 1 '网络发送数据
N_Recv '网络接收数据
End Enum
''' <summary>
''' 日志数据 - 设备通讯信息
''' </summary>
Enum LCOMM
ASK_TO_Reply = 1 '轮询回复数据
Send_Control 'RCU下发控制数据
Control_Reply 'RCU控制回复数据
Adjust_Baud '设备调整波特率
End Enum
''' <summary>
''' 温控器设备数据结构
''' </summary>
Class Device_Temp
Public on_off As Byte '开关机
Public mode As Byte '模式
Public fan As Byte '风速
Public valve As Byte '阀门
Public set_temp As Byte '设置温度
Public indoor_temp As Byte '室内温度
End Class
''' <summary>
''' BLV设备类型
''' </summary>
Enum BLV_DEVICE_TYPE
RS485_Switch = &H6 'T1开关
RS485_Temp = &H7 'T1温控器
RS485_Card = &HA 'T1插卡取电
RS485_IR_SEND = &HF '红外转发
RS485_RGB_Light = &H12 'RGB灯带
RS485_XiaoBao = &H13 '小宝语音
RS485_Time = &H23 '时间同步
C12Dimming = &H12 'BLV_Cx Dimming设备
C5Music = &H15 'BLV_Cx MUSIC设备
C5IO = &HF1 'BLV_Cx IO设备
PC_TEST = &HF2 'BLV_Cx PC测试
End Enum
''' <summary>
''' 日志数据 - 系统运行信息
''' </summary>
Enum LSYS
PHY_Change = 1 'PHY状态变化记录
DevInfo_Error '设备链表信息错误
API_State '升级状态
NET_ARGC '网络初始化参数
MQTT_ARGC 'MQTT参数
NetComm_State '网络通讯状态
NET_DafaultARGC '网络默认参数
End Enum
Enum LOG_DEV_State
Online = &H1
Offline = &H2
End Enum
''' <summary>
''' 日志数据类型
''' </summary>
Enum log_type
Launcher = 1 'Launcher信息记录
SYS_Record '系统运行信息记录
Device_COMM '设备通讯记录
Device_Online '设备通讯状态记录
Global_Parameters '所有设备状态定期记录 - 暂时还没用
Net_COMM '网络通讯记录 - 暂时还没定
Logic_Record '逻辑处理记录 - 暂时还没定
End Enum
''' <summary>
''' 日志数据 - Launcher记录信息
''' </summary>
Enum LLauncher
''' <summary>
''' 校验APP
''' </summary>
App_Check = 1
''' <summary>
''' 读取APP
''' </summary>
Read_App
''' <summary>
''' 写Flash
''' </summary>
Write_Flash
''' <summary>
''' 恢复出厂设置
''' </summary>
Factory_Reset
''' <summary>
''' 复位信号源
''' 0x00：软件复位
''' 0x01：上电复位
''' 0x02：看门狗复位
''' 0x03：外部手动复位
''' 0x05：从下电模式唤醒时的复位 - 通过WCHISPTool烧录后的复位
''' </summary>
Reset_Source
End Enum
Public Structure LogDataInfoStruct
Public MAC As String
Public Log_Valid As Boolean
Public Log_SN As UInt16
Public Log_Len As UInt16
Public Log_DateTime As Log_DateStruct
Public Log_TimeSpan As Int64
Public Log_Type As Byte
Public Log_Content() As Byte
Public HotelId As String
Public RoomId As String
Public CreateDateTime As String
Public LogFileName As String
Public parsing As List(Of String)
End Structure
Public Structure Log_DateStruct
Public year As UInt16
Public month As Byte
Public day As Byte
Public hour As Byte
Public minute As Byte
Public second As Byte
Public milliscond As UInt16
End Structure
''' <summary>
''' 文件名结构解析
''' </summary>
Public Structure fileNameInfoStruct
Public MAC As String
Public HotelId As String
Public RoomId As String
Public CreateDateTime As String
Public LogFileName As String
End Structure
''' <summary>
''' dat原始文件内容中的数据格式
''' </summary>
Enum LOG_DATA_FORMAT
Hand = 0
SN '日志每条数据增加序列号
Len
Len_8 '新增
Check
Date_H '年：5bit 月：5bit 日：5bit
Date_L
Type
Time8B '小时时间戳
Time16B
Time24B
Time32B
Data
End Enum
Private Shared Log_Data_Len_Max As Int16 = 512
Private g_Queue As Queue
Sub New()
InsertData = True
g_Queue = New Queue（）
IsCreationDbFile()
' CreateTable("Insqlite_UserTest")
End Sub
Public Function ScanFile(g_StrPath As String)
End Function
Public Function Parsefile(path As String， strFileName As String) As Boolean
Dim MacDataList As New List(Of List(Of LogDataInfoStruct))
Dim ObjFileSystem As New FileSystemObject
Dim ErrMsg As String = ""
Dim AvalibFileList As New List(Of Scripting.File)
If IsFileReady(strFileName) = False Then Return False
Dim tmpFileInfo As New FileInfo(strFileName)
Dim LastModified As Integer = (Now - tmpFileInfo.LastWriteTime).Minutes
Dim ObjFileExtName As String = tmpFileInfo.Extension.ToUpper '获取文件后缀名
Dim FileSize As Long = tmpFileInfo.Length
If ObjFileExtName <> ".DAT" OrElse
FileSize = 0 OrElse
LastModified < 1 Then
If ObjFileExtName <> ".DAT" OrElse
FileSize = 0 Then
IO.File.Delete(strFileName) '删除非法文件
End If
Return False
End If
'文件内容读取到 objfile 中
'’ShowRichTextBox(RichTextBox1, ">>>read：" & strFileName)
Dim ObjFile As Scripting.File = ObjFileSystem.GetFile(strFileName)
'解析文件名，获取MAC、酒店id、房号、生成日期等信息
Dim tmpFileNameInfo As fileNameInfoStruct = GetFileNameInfo(ObjFile)
Dim tablenamelog As String = "TBL_Rcu_Log"
' If CreateTable(tablenamelog) Then
'解析文件内容，获取详细文件信息
Dim tmpDataInfoList As New List(Of LogDataInfoStruct) '读取文件内容保存在此变量
'’ShowRichTextBox(RichTextBox1, ">>>get：" & strFileName)
'Dim tmpResult As Boolean = GetFileInfoList(tmpFileNameInfo, ObjFile, tmpDataInfoList, ErrMsg)
'If tmpResult = False Then
' AddErrorFileToErrorfile（path， strFileName） '错误文件
' Return False '读取文件失败
'End If
'文件数据入队列了 【通过线程进行入库】
'g_Queue.Enqueue(tmpDataInfoList)
'文件解析合法
'’ShowRichTextBox(RichTextBox1, ">>>add：" & strFileName)
AddAvalibFileToErrorfile（path， strFileName）
'建表
'线程入库
' StartThread()
'Else
' Return False
'End If
Return True
End Function
Public Event Fileschedule(ispass As Integer, ismax As Boolean)
''' <summary>
''' 解析文件内容
''' </summary>
''' <param name="datFile"></param>
''' <returns></returns>
Private Function GetFileInfoList(ByVal datFileName As fileNameInfoStruct,
ByVal datFile As Scripting.File,
ByRef fileInfoList As List(Of LogDataInfoStruct),
ByRef ErrMsg As String) As Boolean
Dim result As Boolean = True
'确认文件是否存在
If IO.File.Exists(datFile.Path) = False Then
ErrMsg = "文件不存在"
Return False
End If
'读取文件内容
Dim file_data As Byte() = My.Computer.FileSystem.ReadAllBytes(datFile.Path)
Dim sampleArr_len As UInt32 = file_data.Length
Dim sampleArr_showlen As UInt32 = 0
Dim data_len As UInt16
Dim data_end As Byte
' Dim data_list As New List(Of Byte())
Dim Addnode As LogDataInfoStruct
'Dim wacth As New Stopwatch
'wacth.Restart() '开启计时
RaiseEvent Fileschedule(file_data.Length, False)
Try
While sampleArr_showlen < sampleArr_len
If file_data(sampleArr_showlen) = &HA5 And sampleArr_showlen + 3 < sampleArr_len Then '判断文件头
data_len = file_data(sampleArr_showlen + LOG_DATA_FORMAT.Len) Or (file_data(sampleArr_showlen + LOG_DATA_FORMAT.Len_8) << 8) '读取数据长度
RaiseEvent Fileschedule(sampleArr_showlen, True)
If data_len < Log_Data_Len_Max And sampleArr_showlen + data_len - 1 < file_data.Length Then
data_end = file_data(sampleArr_showlen + data_len - 1)
'Console.WriteLine($"Data Len :{data_len:d} Data :{data_end:X}")
If sampleArr_showlen + data_len <= sampleArr_len AndAlso file_data(sampleArr_showlen + data_len - 1) = &H5A Then '判断文件尾
Dim data_buff(data_len - 1) As Byte
' Dim data_string As String
Array.Copy(file_data, sampleArr_showlen, data_buff, 0, data_len)
sampleArr_showlen += data_len '数据偏移
If GetSumCheckMod(data_buff, data_len) = &H0 Then
'Console.WriteLine("Data Check Succ !\r\n")
'Parsing_a_piece_of_data(data_buff, show_form， DataGridView1)
' data_list.Add(data_buff) '保存一份数据，添加到列表中
If fileInfoList.Count = 0 Then
Addnode = File_Data_Parsing_To_Iten(datFileName, data_buff, Nothing)
Else
Addnode = File_Data_Parsing_To_Iten(datFileName, data_buff, fileInfoList.Item(fileInfoList.Count - 1))
End If
fileInfoList.Add(Addnode)
'data_string = BitConverter.ToString(data_buff)
'data_string = data_string.Replace("-", " ")
'Console.WriteLine(data_string)
Else
' AnalysisLog("Data Check Fail !\r\n")
Console.WriteLine("Data Check Fail !\r\n")
End If
Else
sampleArr_showlen += 1
' AnalysisLog("Data Len Fail!!! Now Len:" & sampleArr_showlen)
Console.WriteLine("Data Len Fail!!! Now Len:" & sampleArr_showlen)
result = False
End If
Else
sampleArr_showlen += 1
'AnalysisLog("Data Len Fail!!! Now Len:" & sampleArr_showlen)
result = False
Console.WriteLine("Data Len Error!!! " & sampleArr_showlen)
End If
Else
sampleArr_showlen += 1
result = False
End If
'delay(1)
'Application.DoEvents()
End While
RaiseEvent Fileschedule(sampleArr_len， True)
Catch ex As Exception
AdminLog.ApplicationLog.WriteErrorLog(ex)
End Try
'数据添加到列表
' fileInfoList = File_Data_Parsing_To_List(datFileName, data_list)
Return result
End Function
Public Function File_Data_Parsing_To_Iten(ByVal datFileName As fileNameInfoStruct, databuff() As Byte， lastdata As LogDataInfoStruct) As LogDataInfoStruct
Dim save_data As New LogDataInfoStruct
'Dim parsing_string As String
Dim hour_tick As Int32
Dim hour_temp As Int32
Dim data_date As Int32
'数据类型及长度等
'save_data.original_data = file_data(idx)
save_data.Log_SN = databuff(LOG_DATA_FORMAT.SN)
save_data.Log_Type = databuff(LOG_DATA_FORMAT.Type)
hour_temp = databuff(LOG_DATA_FORMAT.Len_8)
save_data.Log_Len = (databuff(LOG_DATA_FORMAT.Len) Or (hour_temp << 8)) - LOG_DATA_FORMAT.Data '数据长度
' If save_data.Log_Len > Log_Data_Len_Max Then
'save_data.len = Log_Data_Len_Max 数据长度超过数据最大长度
' Return tmpDataList
' End If
'日期
data_date = (databuff(LOG_DATA_FORMAT.Date_L) And &HFF) '记录时间
hour_temp = databuff(LOG_DATA_FORMAT.Date_H)
data_date = data_date Or (hour_temp << 8)
hour_tick = databuff(LOG_DATA_FORMAT.Time8B)
hour_temp = databuff(LOG_DATA_FORMAT.Time16B)
hour_tick = hour_tick Or (hour_temp << 8)
hour_temp = databuff(LOG_DATA_FORMAT.Time24B)
hour_tick = hour_tick Or (hour_temp << 16)
hour_temp = databuff(LOG_DATA_FORMAT.Time32B)
hour_tick = hour_tick Or (hour_temp << 24)
save_data.Log_DateTime.year = (data_date >> 10) And &H1F
save_data.Log_DateTime.month = (data_date >> 5) And &H1F
save_data.Log_DateTime.day = (data_date) And &H1F
'时间
save_data.Log_DateTime.hour = hour_tick \ 3600000
'防止24:00:00 溢出 Momo 2022-06-26 24：00：00
If save_data.Log_DateTime.hour >= 24 Then save_data.Log_DateTime.hour = 0
hour_temp = hour_tick Mod 3600000
save_data.Log_DateTime.minute = hour_temp \ 60000
hour_temp = hour_temp Mod 60000
save_data.Log_DateTime.second = hour_temp \ 1000
save_data.Log_DateTime.milliscond = hour_temp Mod 1000
'分离文件内容中的数据
Dim copy As UInt16 = save_data.Log_Len - 1
Dim parsing_data(copy - 1) As Byte
Array.Copy(databuff, LOG_DATA_FORMAT.Data, parsing_data, 0, copy)
save_data.Log_Content = parsing_data
'parsing_string = BitConverter.ToString(parsing_data)
'parsing_string = parsing_string.Replace("-", " ")
'Console.WriteLine($"parsing_string:{parsing_string}")
'parsing_string = $"Data SN:{save_data.Log_SN:d} TYPE:{save_data.Log_Type:d} Len:{save_data.Log_Len:d} data_date:{data_date:X} hour_tick:{hour_tick:X}"
' Console.WriteLine(parsing_string)
'解析数据内容
Dim Parsing_Param As New List(Of String)
Parsing_Data_Content(save_data.Log_Type, parsing_data, Parsing_Param) '解析
'判断Param参数,不够10个则补足
If Parsing_Param.Count > 0 Then
Dim len As Integer = 10 - Parsing_Param.Count
Dim par(len - 1) As String
Parsing_Param.AddRange(par)
End If
save_data.parsing = Parsing_Param
save_data.Log_TimeSpan = Get_Data_Time_Difference2(lastdata, save_data) '时间差
save_data.Log_Valid = True
save_data.HotelId = datFileName.HotelId
save_data.RoomId = datFileName.RoomId
save_data.CreateDateTime = datFileName.CreateDateTime
save_data.LogFileName = datFileName.LogFileName
save_data.MAC = datFileName.MAC
' Dim savedata As String = $"[HotelId:{save_data.HotelId }],{vbCrLf}[RoomId:{save_data.RoomId}],{vbCrLf}[LogFileName:{save_data.LogFileName }],{vbCrLf}[Log_SN:{save_data.Log_SN }],{vbCrLf}[Log_Len:{save_data.Log_SN}],{vbCrLf}[Log_DateTime:{ newtime_h(save_data).ToString("yyyy-MM-dd HH:mm:ss") }],{vbCrLf}[Log_TimeSpan:{save_data.Log_TimeSpan}],{vbCrLf}[Log_Type:{Parsing_Param}],{vbCrLf}[CreateDateTime:{save_data.CreateDateTime}],{vbCrLf}[LogFileName:{save_data.LogFileName }]"
' Console.WriteLine($"解析数据包({idx}):{vbCrLf}{savedata}")
' Console.WriteLine($"解析数据包({idx})")
Return save_data
End Function
Public Function File_Data_Parsing_To_List(ByVal datFileName As fileNameInfoStruct,
ByVal file_data As List(Of Byte())) As List(Of LogDataInfoStruct)
Dim data_num As Int32 = file_data.Count
Dim hour_tick As Int32
Dim hour_temp As Int32
Dim data_date As Int32
Console.WriteLine($"当前有效数据总包数:{data_num}")
Dim tmpDataList As New List(Of LogDataInfoStruct)
'Try
For idx = 0 To data_num - 1
Dim save_data As New LogDataInfoStruct
Dim parsing_string As String
'数据类型及长度等
'save_data.original_data = file_data(idx)
save_data.Log_SN = file_data(idx)(LOG_DATA_FORMAT.SN)
save_data.Log_Type = file_data(idx)(LOG_DATA_FORMAT.Type)
hour_temp = file_data(idx)(LOG_DATA_FORMAT.Len_8)
save_data.Log_Len = (file_data(idx)(LOG_DATA_FORMAT.Len) Or (hour_temp << 8)) - LOG_DATA_FORMAT.Data '数据长度
If save_data.Log_Len > Log_Data_Len_Max Then
'save_data.len = Log_Data_Len_Max 数据长度超过数据最大长度
' Return tmpDataList
End If
'日期
data_date = (file_data(idx)(LOG_DATA_FORMAT.Date_L) And &HFF) '记录时间
hour_temp = file_data(idx)(LOG_DATA_FORMAT.Date_H)
data_date = data_date Or (hour_temp << 8)
hour_tick = file_data(idx)(LOG_DATA_FORMAT.Time8B)
hour_temp = file_data(idx)(LOG_DATA_FORMAT.Time16B)
hour_tick = hour_tick Or (hour_temp << 8)
hour_temp = file_data(idx)(LOG_DATA_FORMAT.Time24B)
hour_tick = hour_tick Or (hour_temp << 16)
hour_temp = file_data(idx)(LOG_DATA_FORMAT.Time32B)
hour_tick = hour_tick Or (hour_temp << 24)
save_data.Log_DateTime.year = (data_date >> 10) And &H1F
save_data.Log_DateTime.month = (data_date >> 5) And &H1F
save_data.Log_DateTime.day = (data_date) And &H1F
'时间
save_data.Log_DateTime.hour = hour_tick \ 3600000
'防止24:00:00 溢出 Momo 2022-06-26 24：00：00
If save_data.Log_DateTime.hour >= 24 Then save_data.Log_DateTime.hour = 0
hour_temp = hour_tick Mod 3600000
save_data.Log_DateTime.minute = hour_temp \ 60000
hour_temp = hour_temp Mod 60000
save_data.Log_DateTime.second = hour_temp \ 1000
save_data.Log_DateTime.milliscond = hour_temp Mod 1000
'分离文件内容中的数据
Dim copy As UInt16 = save_data.Log_Len - 1
Dim parsing_data(copy - 1) As Byte
Array.Copy(file_data(idx), LOG_DATA_FORMAT.Data, parsing_data, 0, copy)
save_data.Log_Content = parsing_data
parsing_string = BitConverter.ToString(parsing_data)
parsing_string = parsing_string.Replace("-", " ")
'Console.WriteLine($"parsing_string:{parsing_string}")
parsing_string = $"Data SN:{save_data.Log_SN:d} TYPE:{save_data.Log_Type:d} Len:{save_data.Log_Len:d} data_date:{data_date:X} hour_tick:{hour_tick:X}"
' Console.WriteLine(parsing_string)
'解析数据内容
Dim Parsing_Param As New List(Of String)
Parsing_Data_Content(save_data.Log_Type, parsing_data, Parsing_Param) '解析
'判断Param参数,不够10个则补足
If Parsing_Param.Count > 0 Then
Dim len As Integer = 10 - Parsing_Param.Count
Dim par(len - 1) As String
Parsing_Param.AddRange(par)
End If
save_data.parsing = Parsing_Param
save_data.Log_TimeSpan = Get_Data_Time_Difference2(tmpDataList, save_data) '时间差
save_data.Log_Valid = True
save_data.HotelId = datFileName.HotelId
save_data.RoomId = datFileName.RoomId
save_data.CreateDateTime = datFileName.CreateDateTime
save_data.LogFileName = datFileName.LogFileName
save_data.MAC = datFileName.MAC
Dim savedata As String = $"[HotelId:{save_data.HotelId }],{vbCrLf}[RoomId:{save_data.RoomId}],{vbCrLf}[LogFileName:{save_data.LogFileName }],{vbCrLf}[Log_SN:{save_data.Log_SN }],{vbCrLf}[Log_Len:{save_data.Log_SN}],{vbCrLf}[Log_DateTime:{ newtime_h(save_data).ToString("yyyy-MM-dd HH:mm:ss") }],{vbCrLf}[Log_TimeSpan:{save_data.Log_TimeSpan}],{vbCrLf}[Log_Type:{Parsing_Param}],{vbCrLf}[CreateDateTime:{save_data.CreateDateTime}],{vbCrLf}[LogFileName:{save_data.LogFileName }]"
' Console.WriteLine($"解析数据包({idx}):{vbCrLf}{savedata}")
Console.WriteLine($"解析数据包({idx})")
' AnalysisLog($"解析数据包({idx}):{vbCrLf}{savedata}")
'将解析后的数据添加到列表中
tmpDataList.Add(save_data)
'delay(1)
Next
'Catch ex As Exception
' AdminLog.ApplicationLog.WriteErrorLog(ex)
'End Try
Return tmpDataList
End Function
Public Function newtime_h(data As LogDataInfoStruct) As DateTime
Dim temp_time As New Log_DateStruct
temp_time.year = data.Log_DateTime.year + 2000
If data.Log_DateTime.month = 0 Then
temp_time.month = data.Log_DateTime.month + 1
Else
temp_time.month = data.Log_DateTime.month
End If
If data.Log_DateTime.day = 0 Then
temp_time.day = data.Log_DateTime.day + 1
Else
temp_time.day = data.Log_DateTime.day
End If
temp_time.hour = data.Log_DateTime.hour
temp_time.minute = data.Log_DateTime.minute
temp_time.second = data.Log_DateTime.second
temp_time.milliscond = data.Log_DateTime.milliscond
Dim temp_date1 As New DateTime(temp_time.year, temp_time.month, temp_time.day, temp_time.hour, temp_time.minute, temp_time.second)
Return temp_date1
End Function
''' <summary>
''' 本条数据与上条数据的时间差
''' </summary>
''' <param name="data_list"></param>
''' <param name="data"></param>
''' <returns></returns>
Public Function Get_Data_Time_Difference2(data_list As List(Of LogDataInfoStruct), data As LogDataInfoStruct) As Int64
Dim temp_tick As Int64 = 0
Dim temp_time As New Log_DateStruct
Dim temp_time2 As New Log_DateStruct
Dim temp_num As Int32
temp_num = data_list.Count '获取当前数据列表中有多少条数据
'Console.WriteLine($"now list num:{temp_num:00}")
If temp_num >= 1 Then
temp_time.year = data.Log_DateTime.year + 2000
If data.Log_DateTime.month = 0 Then
temp_time.month = data.Log_DateTime.month + 1
Else
temp_time.month = data.Log_DateTime.month
End If
If data.Log_DateTime.day = 0 Then
temp_time.day = data.Log_DateTime.day + 1
Else
temp_time.day = data.Log_DateTime.day
End If
temp_time.hour = data.Log_DateTime.hour
temp_time.minute = data.Log_DateTime.minute
temp_time.second = data.Log_DateTime.second
temp_time.milliscond = data.Log_DateTime.milliscond
temp_time2.year = data_list(temp_num - 1).Log_DateTime.year + 2000
If data_list(temp_num - 1).Log_DateTime.month = 0 Then
temp_time2.month = data_list(temp_num - 1).Log_DateTime.month + 1
Else
temp_time2.month = data_list(temp_num - 1).Log_DateTime.month
End If
If data_list(temp_num - 1).Log_DateTime.day = 0 Then
temp_time2.day = data_list(temp_num - 1).Log_DateTime.day + 1
Else
temp_time2.day = data_list(temp_num - 1).Log_DateTime.day
End If
temp_time2.hour = data_list(temp_num - 1).Log_DateTime.hour
temp_time2.minute = data_list(temp_num - 1).Log_DateTime.minute
temp_time2.second = data_list(temp_num - 1).Log_DateTime.second
temp_time2.milliscond = data_list(temp_num - 1).Log_DateTime.milliscond
Dim tmpSn As UInt16 = data_list(temp_num - 1).Log_SN
Try
Dim temp_date1 As New DateTime(temp_time.year, temp_time.month, temp_time.day, temp_time.hour, temp_time.minute, temp_time.second)
Dim temp_date2 As New DateTime(temp_time2.year, temp_time2.month, temp_time2.day, temp_time2.hour, temp_time2.minute, temp_time2.second)
temp_tick = DateDiff(DateInterval.Second, temp_date2, temp_date1) 'temp_date1 - temp_date2
temp_tick = temp_tick * 1000 + temp_time.milliscond - temp_time2.milliscond
Catch ex As Exception
'ShowRichTextBox(RichTextBox1, " xxx 时间格式错误：tempDate1：" & tmpSn & "," & temp_time.year & "," & temp_time.month & "," & temp_time.day & "," & temp_time.hour & "," & temp_time.minute & "," & temp_time.second)
'ShowRichTextBox(RichTextBox1, " xxx 时间格式错误：tempDate2：" & tmpSn & "," & temp_time2.year & "," & temp_time2.month & "," & temp_time2.day & "," & temp_time2.hour & "," & temp_time2.minute & "," & temp_time2.second)
End Try
End If
Return temp_tick
End Function
Public Function Get_Data_Time_Difference2(lastdata As LogDataInfoStruct, data As LogDataInfoStruct) As Int64
Dim temp_tick As Int64 = 0
Dim temp_time As New Log_DateStruct
Dim temp_time2 As New Log_DateStruct
If IsNothing(lastdata) Then Return temp_tick
temp_time.year = data.Log_DateTime.year + 2000
If data.Log_DateTime.month = 0 Then
temp_time.month = data.Log_DateTime.month + 1
Else
temp_time.month = data.Log_DateTime.month
End If
If data.Log_DateTime.day = 0 Then
temp_time.day = data.Log_DateTime.day + 1
Else
temp_time.day = data.Log_DateTime.day
End If
temp_time.hour = data.Log_DateTime.hour
temp_time.minute = data.Log_DateTime.minute
temp_time.second = data.Log_DateTime.second
temp_time.milliscond = data.Log_DateTime.milliscond
temp_time2.year = lastdata.Log_DateTime.year + 2000
If lastdata.Log_DateTime.month = 0 Then
temp_time2.month = lastdata.Log_DateTime.month + 1
Else
temp_time2.month = lastdata.Log_DateTime.month
End If
If lastdata.Log_DateTime.day = 0 Then
temp_time2.day = lastdata.Log_DateTime.day + 1
Else
temp_time2.day = lastdata.Log_DateTime.day
End If
temp_time2.hour = lastdata.Log_DateTime.hour
temp_time2.minute = lastdata.Log_DateTime.minute
temp_time2.second = lastdata.Log_DateTime.second
temp_time2.milliscond = lastdata.Log_DateTime.milliscond
Try
Dim temp_date1 As New DateTime(temp_time.year, temp_time.month, temp_time.day, temp_time.hour, temp_time.minute, temp_time.second)
Dim temp_date2 As New DateTime(temp_time2.year, temp_time2.month, temp_time2.day, temp_time2.hour, temp_time2.minute, temp_time2.second)
temp_tick = DateDiff(DateInterval.Second, temp_date2, temp_date1) 'temp_date1 - temp_date2
temp_tick = temp_tick * 1000 + temp_time.milliscond - temp_time2.milliscond
Catch ex As Exception
'ShowRichTextBox(RichTextBox1, " xxx 时间格式错误：tempDate1：" & tmpSn & "," & temp_time.year & "," & temp_time.month & "," & temp_time.day & "," & temp_time.hour & "," & temp_time.minute & "," & temp_time.second)
'ShowRichTextBox(RichTextBox1, " xxx 时间格式错误：tempDate2：" & tmpSn & "," & temp_time2.year & "," & temp_time2.month & "," & temp_time2.day & "," & temp_time2.hour & "," & temp_time2.minute & "," & temp_time2.second)
End Try
Return temp_tick
End Function
Private Sub AddErrorFileToErrorfile(g_StrPath As String, strFileName As String)
Dim errorfilepath As String = g_StrPath & "\NG\"
If Not IO.Directory.Exists(errorfilepath) Then
IO.Directory.CreateDirectory(errorfilepath)
End If
Dim filen As String = strFileName.Substring(strFileName.LastIndexOf("\") + 1)
Dim bufa() As String = filen.Split("_")
errorfilepath = errorfilepath & bufa(0) & "\"
If Not IO.Directory.Exists(errorfilepath) Then
IO.Directory.CreateDirectory(errorfilepath)
End If
errorfilepath = errorfilepath & filen
'IO.File.Copy(strFileName, errorfilepath, True)
' IO.File.Delete(strFileName)
Try
My.Computer.FileSystem.MoveFile(strFileName, errorfilepath)
Catch ex As Exception
AdminLog.ApplicationLog.WriteErrorLog($"文件{strFileName}移动到{vbCrLf }{errorfilepath}{vbCrLf} 失败！{vbCrLf} 问题详情{vbCrLf }{ex.Message }")
End Try
End Sub
Private Sub AddAvalibFileToErrorfile(g_StrPath As String, strFileName As String)
Dim errorfilepath As String = g_StrPath & "\OK\"
If Not IO.Directory.Exists(errorfilepath) Then
IO.Directory.CreateDirectory(errorfilepath)
End If
Dim filen As String = strFileName.Substring(strFileName.LastIndexOf("\") + 1)
Dim bufa() As String = filen.Split("_")
errorfilepath = errorfilepath & bufa(0) & "\"
If Not IO.Directory.Exists(errorfilepath) Then
IO.Directory.CreateDirectory(errorfilepath)
End If
errorfilepath = errorfilepath & filen
'IO.File.Copy(strFileName, errorfilepath, True)
' IO.File.Delete(strFileName)
Try
My.Computer.FileSystem.MoveFile(strFileName, errorfilepath)
Catch ex As Exception
AdminLog.ApplicationLog.WriteErrorLog($"文件{strFileName}移动到{vbCrLf }{errorfilepath}{vbCrLf} 失败！{vbCrLf} 问题详情{vbCrLf }{ex.Message }")
End Try
End Sub
''' <summary>
''' Launcher类型数据解析
''' </summary>
''' <param name="data_content"></param>
''' <returns></returns>
Public Function Parsing_LogData_Launcher_Content(data_content As Byte(), ByRef Type_Param As List(Of String)) As List(Of String)
Dim Launcher_type As Byte = data_content(0)
Try
Select Case Launcher_type
Case LLauncher.App_Check
Type_Param.Add("校验APP")
If data_content(1) = &H0 Then
Type_Param.Add("相同")
ElseIf data_content(1) = &H1 Then
Type_Param.Add("APP版本号不同")
ElseIf data_content(1) = &H2 Then
Type_Param.Add("特征区CRC不同")
ElseIf data_content(1) = &H3 Then
Type_Param.Add("Flash APP地址错误")
ElseIf data_content(1) = &H4 Then
Type_Param.Add("Flash APP数据校验错误")
ElseIf data_content(1) = &H5 Then
Type_Param.Add("Flash APP标志未置位")
ElseIf data_content(1) = &H6 Then
Type_Param.Add("Flash 特征区的CRC校验错误")
ElseIf data_content(1) = &H7 Then
Type_Param.Add("MCU Flash数据校验错误")
ElseIf data_content(1) = &H8 Then
Type_Param.Add("MCU Flash的APP标志未置位")
ElseIf data_content(1) = &H9 Then
Type_Param.Add("MCU Flash特征区的CRC校验错误")
Else
Type_Param.Add("数据错误")
End If
Case LLauncher.Read_App
Type_Param.Add("读取APP")
If data_content(1) = &H0 Then
Type_Param.Add("成功")
ElseIf data_content(1) = &H1 Then
Type_Param.Add("失败")
End If
Case LLauncher.Reset_Source
Type_Param.Add("复位源")
If data_content(1) = &H0 Then
Type_Param.Add("软件复位")
ElseIf data_content(1) = &H1 Then
Type_Param.Add("上电复位")
ElseIf data_content(1) = &H2 Then
Type_Param.Add("看门狗超时复位")
ElseIf data_content(1) = &H3 Then
Type_Param.Add("外部手动复位")
ElseIf data_content(1) = &H5 Then
Type_Param.Add("从下电模式唤醒时的复位")
Else
Type_Param.Add($"复位源位置：{data_content(1):00}")
End If
Case Else
Type_Param.Add("数据类型错误")
End Select
Catch ex As Exception
AdminLog.ApplicationLog.WriteErrorLog(ex)
End Try
Return Type_Param
End Function
Private Function GetFileNameInfo(ByVal datFile As Scripting.File) As fileNameInfoStruct
Dim tmpFileInfo As New fileNameInfoStruct
Dim FileNameStr As String = datFile.Name
Dim Strbyte As String() = FileNameStr.Split("_")
Try
tmpFileInfo.MAC = Strbyte(0)
tmpFileInfo.HotelId = Strbyte(1)
tmpFileInfo.RoomId = Strbyte(2)
'tmpFileInfo.CreateDateTime = datFile.DateLastModified
tmpFileInfo.CreateDateTime = Format(datFile.DateLastModified, "yyyy-MM-dd HH:mm:ss")
tmpFileInfo.LogFileName = datFile.Name
Catch ex As Exception
AdminLog.ApplicationLog.WriteErrorLog(ex)
End Try
Return tmpFileInfo
End Function
''' <summary>
''' 解析数据内容
''' 按照数据类型来解析,用于加载表格时的数据显示 - 简单的内容解析
''' </summary>
''' <param name="data_content"></param>
''' <returns></returns>
Public Function Parsing_Data_Content(data_type As Byte, data_content As Byte(), ByRef Type_Param As List(Of String)) As List(Of String)
Dim dev_temp As New Device_Temp
Try
Select Case data_type
Case log_type.Launcher
Type_Param.Add("Launcher信息")
Type_Param = Parsing_LogData_Launcher_Content(data_content, Type_Param)
Case log_type.SYS_Record
Type_Param.Add("系统信息")
Type_Param = Parsing_LogData_SYS_Record_Content(data_content, Type_Param)
Case log_type.Device_COMM
Type_Param.Add("设备通讯")
Type_Param = Parsing_LogData_Device_COMM_Content(data_content, Type_Param)
Case log_type.Device_Online
Type_Param.Add("设备通讯状态")
Type_Param = Parsing_LogData_Device_Online_Content(data_content, Type_Param)
Case log_type.Global_Parameters
Type_Param.Add("定期保存设备信息")
Type_Param = Parsing_LogData_Global_Parameters_Content(data_content, Type_Param)
Case log_type.Net_COMM
Type_Param.Add("网络处理")
Type_Param = Parsing_LogData_Net_COMM_Content(data_content, Type_Param)
Case log_type.Logic_Record
Type_Param.Add("事件处理")
Type_Param = Parsing_LogData_Logic_Record_Content(data_content, Type_Param)
Case Else
Type_Param.Add("数据类型错误")
End Select
Catch ex As Exception
AdminLog.ApplicationLog.WriteErrorLog(ex)
End Try
Return Type_Param
End Function
''' <summary>
''' 事件处理记录信息解析
''' </summary>
''' <param name="data_content"></param>
''' <returns></returns>
Public Function Parsing_LogData_Logic_Record_Content(data_content As Byte(), ByRef Type_Param As List(Of String)) As List(Of String)
'Type_Param.Add("事件处理记录信息解析" & BitConverter.ToString(data_content).Replace("-", " "))
Dim net_type As Byte = data_content(0)
Select Case net_type
Case Debugtype.log
Type_Param.Add("调试日志")
Type_Param.Add(Encoding.GetEncoding("GBK").GetString(data_content, 1, data_content.Length - 1)）
End Select
Return Type_Param
End Function
''' <summary>
''' 网络处理记录信息解析
''' </summary>
''' <param name="data_content"></param>
''' <returns></returns>
Public Function Parsing_LogData_Net_COMM_Content(data_content As Byte(), ByRef Type_Param As List(Of String)) As List(Of String)
Dim net_type As Byte = data_content(0)
Dim net_port As UInt16
Select Case net_type
Case LNetComm.N_Recv
Try
Type_Param.Add("网络接收记录")
Type_Param.Add($"套接字序号(1~4):{data_content(1)}")
Type_Param.Add($"接收IP:{data_content(2)}.{data_content(3)}.{data_content(4)}.{data_content(5)}")
net_port = data_content(7)
net_port <<= 8
net_port = net_port Or data_content(6)
Type_Param.Add($"接收端口Port:{net_port}")
Type_Param.Add("Data:" & BitConverter.ToString(data_content, 8).Replace("-", " "))
DataTypes.Check_Network_Data(data_content, Type_Param, True)
Catch ex As Exception
Type_Param.Add("网络数据解析错误：" & BitConverter.ToString(data_content, 1).Replace("-", " "))
End Try
Case LNetComm.N_Send
Try
Type_Param.Add("网络发送记录")
Type_Param.Add($"套接字序号(1~4):{data_content(1)}")
Type_Param.Add($"发送IP:{data_content(2)}.{data_content(3)}.{data_content(4)}.{data_content(5)}")
net_port = data_content(7)
net_port <<= 8
net_port = net_port Or data_content(6)
Type_Param.Add($"发送端口Port:{net_port}")
Type_Param.Add("Data:" & BitConverter.ToString(data_content, 8).Replace("-", " "))
DataTypes.Check_Network_Data(data_content, Type_Param, False)
Catch ex As Exception
Console.WriteLine("网络数据解析错误：长度不够")
Type_Param.Add("网络数据解析错误：" & BitConverter.ToString(data_content, 1).Replace("-", " "))
End Try
End Select
Return Type_Param
End Function
''' <summary>
''' 所有设备状态定期保存数据解析
''' </summary>
''' <param name="data_content"></param>
''' <returns></returns>
Public Function Parsing_LogData_Global_Parameters_Content(data_content As Byte(), ByRef Type_Param As List(Of String)) As List(Of String)
Type_Param.Add("所有设备状态定期保存数据解析" & BitConverter.ToString(data_content).Replace("-", " "))
Return Type_Param
End Function
''' <summary>
''' 设备通讯数据解析
''' </summary>
''' <param name="data_content"></param>
''' <returns></returns>
Public Function Parsing_LogData_Device_COMM_Content(data_content As Byte(), ByRef Type_Param As List(Of String)) As List(Of String)
Dim data_type As Byte = data_content(0)
Dim data_port As Byte = data_content(1)
Dim data_baud As UInt32
Dim data_buff(data_content.Length - 7) As Byte
Array.Copy(data_content, 6, data_buff, 0, data_content.Length - 6)
data_baud = data_content(5)
data_baud = (data_baud << 8) Or data_content(4)
data_baud = (data_baud << 8) Or data_content(3)
data_baud = (data_baud << 8) Or data_content(2)
Try
Select Case data_type
Case LCOMM.Adjust_Baud '设备切换通讯波特率
Type_Param.Add($"设备切换通讯波特率")
data_baud = data_content(6)
data_baud = (data_baud << 8) Or data_content(5)
data_baud = (data_baud << 8) Or data_content(4)
data_baud = (data_baud << 8) Or data_content(3)
Obtaining_The_Device_Type(data_content(1), Type_Param)
Type_Param.Add($" 设备地址:{data_content(2)}")
Type_Param.Add($" 切换波特率:{data_baud}" & vbCrLf)
Case LCOMM.ASK_TO_Reply '轮询回复数据
Type_Param.Add($"轮询回复数据")
Type_Param.Add($"Port_{data_port} ")
Type_Param.Add($"Baud:{data_baud} ")
Type_Param.Add("485通讯数据:" & BitConverter.ToString(data_buff).Replace("-", " "))
DataTypes.Parsing_485Data_type(data_buff, Type_Param)
Case LCOMM.Control_Reply 'RCU下发数据
Type_Param.Add($"RCU下发数据")
Type_Param.Add($"Port_{data_port}")
Type_Param.Add($"Baud:{data_baud}")
Type_Param.Add("485通讯数据:" & BitConverter.ToString(data_buff).Replace("-", " "))
DataTypes.Parsing_485Data_type(data_buff, Type_Param)
Case LCOMM.Send_Control 'RCU接收控制回复数据
Type_Param.Add($"RCU接收控制回复数据")
Type_Param.Add($"Port_{data_port}")
Type_Param.Add($"Baud:{data_baud}")
Type_Param.Add("485通讯数据:" & BitConverter.ToString(data_buff).Replace("-", " "))
DataTypes.Parsing_485Data_type(data_buff, Type_Param)
Case Else
Type_Param.Add("类型错误:" & BitConverter.ToString(data_content).Replace("-", " "))
End Select
Catch ex As Exception
AdminLog.ApplicationLog.WriteErrorLog(ex)
End Try
Return Type_Param
End Function
''' <summary>
''' 系统运行信息数据解析
''' </summary>
''' <param name="data_content"></param>
''' <returns></returns>
Public Function Parsing_LogData_SYS_Record_Content(data_content As Byte(), ByRef Type_Param As List(Of String)) As List(Of String)
'data_parsing = "系统运行数据解析" & BitConverter.ToString(data_content).Replace("-", " ")
Dim sys_type As Byte = data_content(0)
Try
Select Case sys_type
Case LSYS.PHY_Change
Type_Param.Add("网络PHY状态记录")
If data_content(1) = &H0 Then
Type_Param.Add("拔出")
ElseIf data_content(1) = &H1 Then
Type_Param.Add("插入")
Else
Type_Param.Add($"PHY状态错误： {data_content(1)}")
End If
Case LSYS.DevInfo_Error
Type_Param.Add("设备链表读取信息错误记录")
Type_Param.Add($"设备类型：{data_content(1)}")
Type_Param.Add($"地址：{data_content(2)}")
Type_Param.Add($"链表信息读取错误")
Case LSYS.API_State
Type_Param.Add("系统升级信息")
If data_content(1) = &H1 Then
Type_Param.Add("串口升级")
ElseIf data_content(1) = &H2 Then
Type_Param.Add("网络升级")
Else
Type_Param.Add("错误升级类型")
End If
If data_content(2) = &H1 Then
Type_Param.Add("写入成功")
ElseIf data_content(2) = &H2 Then
Type_Param.Add("写入失败")
ElseIf data_content(2) = &H3 Then
Type_Param.Add("文件块数错误")
ElseIf data_content(2) = &H4 Then
Type_Param.Add("MD5校验错误")
ElseIf data_content(2) = &H5 Then
Type_Param.Add("CRC校验错误")
ElseIf data_content(2) = &H6 Then
Type_Param.Add("跳转Launcher")
Else
Type_Param.Add("未知状态")
End If
Case LSYS.NET_ARGC
Type_Param.Add("网络初始化：")
Type_Param.Add($"IP : {data_content(1)}.{data_content(2)}.{data_content(3)}.{data_content(4)}")
Type_Param.Add($"MAC : {data_content(5)}.{data_content(6)}.{data_content(7)}.{data_content(8)}.{data_content(9)}.{data_content(10)}")
Type_Param.Add($"服务器IP : {data_content(11)}.{data_content(12)}.{data_content(13)}.{data_content(14)}")
Type_Param.Add($"TFTP服务器IP : {data_content(15)}.{data_content(16)}.{data_content(17)}.{data_content(18)}")
Type_Param.Add($"MQTT服务器IP : {data_content(19)}.{data_content(20)}.{data_content(21)}.{data_content(22)}")
Case LSYS.MQTT_ARGC
Type_Param.Add("MQTT初始化参数")
Type_Param.Add("还没解析")
Case LSYS.NetComm_State
Type_Param.Add("云端通讯状态")
If data_content(1) = &H0 Then
Type_Param.Add("服务器状态：离线")
ElseIf data_content(1) = &H1 Then
Type_Param.Add("本地服务器通信正常")
ElseIf data_content(1) = &H2 Then
Type_Param.Add("云端服务器通信正常")
Else
Type_Param.Add("云端通讯状态 - 未知状态")
End If
Case LSYS.NET_DafaultARGC
Type_Param.Add("网络初始化")
Type_Param.Add($"IP : {data_content(1)}.{data_content(2)}.{data_content(3)}.{data_content(4)}")
Type_Param.Add($"网关 : {data_content(5)}.{data_content(6)}.{data_content(7)}.{data_content(8)}")
Type_Param.Add($"子网掩码 : {data_content(9)}.{data_content(10)}.{data_content(11)}.{data_content(12)}")
Type_Param.Add($"DNS_IP : {data_content(13)}.{data_content(14)}.{data_content(15)}.{data_content(16)}")
If data_content(17) = &H1 Then
Type_Param.Add("网络ArgcFlag标志：PC设置参数")
Else
Type_Param.Add("网络ArgcFlag标志：主机默认参数")
End If
If data_content(18) = &H2 Then
Type_Param.Add("DHCP标志：关闭DHCP")
Else
Type_Param.Add("DHCP标志：启动DHCP")
End If
If data_content(19) = &H1 Then
Type_Param.Add("使用本地服务器标志")
Else
Type_Param.Add("使用云端服务器标志")
End If
Case Else
Type_Param.Add($"系统运行信息 类型错误{sys_type}")
End Select
Catch ex As Exception
AdminLog.ApplicationLog.WriteErrorLog(ex)
Type_Param.Add("数据异常----")
End Try
Return Type_Param
End Function
''' <summary>
''' 获取设备类型
''' </summary>
''' <returns></returns>
Public Function Obtaining_The_Device_Type(data As Byte, ByRef Type_Param As List(Of String)) As List(Of String)
Try
Select Case data
Case BLV_DEVICE_TYPE.C12Dimming
Type_Param.Add("设备类型:C12调光设备")
Case BLV_DEVICE_TYPE.C5IO
Type_Param.Add("设备类型:C5IO设备")
Case BLV_DEVICE_TYPE.C5Music
Type_Param.Add("设备类型:C5Music设备")
Case BLV_DEVICE_TYPE.PC_TEST
Type_Param.Add("设备类型:BLV PC TEST")
Case BLV_DEVICE_TYPE.RS485_Card
Type_Param.Add("设备类型:RS485 插卡取电")
Case BLV_DEVICE_TYPE.RS485_IR_SEND
Type_Param.Add("设备类型:RS485 红外转发")
Case BLV_DEVICE_TYPE.RS485_RGB_Light
Type_Param.Add("设备类型:RS485 RGB灯带")
Case BLV_DEVICE_TYPE.RS485_Switch
Type_Param.Add("设备类型:RS485 开关")
Case BLV_DEVICE_TYPE.RS485_Temp
Type_Param.Add("设备类型:RS485 温控器")
Case BLV_DEVICE_TYPE.RS485_Time
Type_Param.Add("设备类型:时间同步")
Case BLV_DEVICE_TYPE.RS485_XiaoBao
Type_Param.Add("设备类型:RS485 小宝语音")
Case Else
Type_Param.Add($"未知设备:{data}")
End Select
Catch ex As Exception
AdminLog.ApplicationLog.WriteErrorLog(ex)
End Try
Return Type_Param
End Function
''' <summary>
''' 设备通讯状态数据解析
''' </summary>
''' <param name="data_content"></param>
''' <returns></returns>
Public Function Parsing_LogData_Device_Online_Content(data_content As Byte(), ByRef Type_Param As List(Of String)) As List(Of String)
Dim dev_type As Byte = data_content(0)
Dim dev_addr As Byte = data_content(1)
Dim dev_state As Byte = data_content(2)
Try
Type_Param.Add("设备状态改变")
Type_Param = Obtaining_The_Device_Type(dev_type, Type_Param)
Type_Param.Add($"设备地址:{dev_addr} ")
If dev_state = LOG_DEV_State.Offline Then
Type_Param.Add("设备状态:离线")
ElseIf dev_state = LOG_DEV_State.Online Then
Type_Param.Add("设备状态:在线")
Else
Type_Param.Add($"状态错误:{dev_state}")
End If
Catch ex As Exception
AdminLog.ApplicationLog.WriteErrorLog(ex)
End Try
Return Type_Param
End Function
''' <summary>
''' 和校验取余数
''' 求Byte数组的和校验取余数
''' </summary>
''' <param name="dataPacket">Byte数组</param>
''' <returns></returns>
Public Function GetSumCheckMod(dataPacket As Byte(), datalen As Byte) As Byte
Dim sum As Integer
For idx = 0 To datalen - 1
sum += dataPacket(idx)
sum = sum And &HFF
Next
Dim sumMod As Byte = &HFF - sum
Return sumMod
End Function
''' <summary>
''' 判断文件是否被占用
''' </summary>
''' <param name="filepath"></param>
''' <returns></returns>
Public Function IsFileReady(ByVal filepath As String) As Boolean '检查文件是否正在被使用的函数
If IO.File.Exists(filepath) = False Then
Return True
Exit Function '如果filpath文件不存在，也就不没有被占用，应该返回true
End If
Try
IO.File.Open(filepath, FileMode.Open).Close()
Return True
Catch e As Exception
'MsgBox("Writing was disallowed, as expected: " & e.ToString())
Return False
End Try
End Function
#Region "线程入库"
Private g_FileDataToSql As Thread
'Private g_IsThread As Boolean = False
Public Sub StartThread()
If IsNothing(g_FileDataToSql) Then
g_FileDataToSql = New Thread(AddressOf FileDataToSqlRuning)
End If
If g_FileDataToSql.IsAlive Then Return
g_FileDataToSql = New Thread(AddressOf FileDataToSqlRuning)
g_FileDataToSql.Start()
End Sub
Public InsertData As Boolean
Public Sub FileDataToSqlRuning()
Dim tmpDataInfoList As List(Of LogDataInfoStruct)
Dim starttime As Date = Date.Now
Dim tsp As TimeSpan
If InsertData Then
While True
If g_Queue.Count > 0 Then
starttime = Date.Now
tmpDataInfoList = g_Queue.Dequeue()
'WriteDataToDB(tmpDataInfoList)
tsp = Now - starttime
Console.WriteLine("线程入库时间：" & tsp.TotalMilliseconds)
Else
Exit While
End If
End While
Else
g_Queue.Clear()
End If
End Sub
#End Region
#Region "数据库操作"
Public DbConnString As String = "Server=blv-cloud-db.mysql.rds.aliyuncs.com;Port=3307;Database=rculog;Uid=blv_rcu;Pwd=fnadiaJDIJ7546;charset=utf8;"
Public Function CreateTable(tadblname As String) As Boolean
Dim localConn As New DbConnectionStringBuilder
localConn.Add("Data Source", $"{Application.StartupPath }\LocalDB\LogService.db")
'localConn.Add("Password", "123456")
Dim LocalConnString As String = localConn.ToString()
Using db As New DbExecutor(DbExecutor.DbTypeEnum.Mysql, DbConnString)
Try
db.Open()
Dim CreateTableStr As String = MysqlCreateTablecolumn(tadblname)
db.ExecuteNonQuery(CreateTableStr)
db.Close()
Return True
Catch ex As Exception
' MsgBox($"Create Tableco Error, {ex.Message}")
AdminLog.ApplicationLog.WriteErrorLog($"Create Tableco Error, {ex.Message}")
db.Close()
Return False
End Try
End Using
End Function
''' <summary>
''' 拼接sql语句入库
''' </summary>
''' <param name="dataDict"></param>
''' <returns></returns>
Private Function WriteDataToDB(lstLogData As List(Of LogDataInfoStruct)) As Boolean
Dim LocalConnString As String
Dim localConn As New DbConnectionStringBuilder
localConn.Add("Data Source", $"{Application.StartupPath }\LocalDB\LogService.db")
'localConn.Add("Password", "123456")
LocalConnString = localConn.ToString()
Dim dic As New Dictionary(Of String, String)
Dim trans As DbTransaction
Dim Isauto As Integer = 0
Using db As New DbExecutor(DbExecutor.DbTypeEnum.Mysql, DbConnString)
Try
Try
db.Open()
Catch ex As Exception
Console.WriteLine($"Open local db Error, {ex.Message}")
' MsgBox($"Open local db Error, {ex.Message}")
AdminLog.ApplicationLog.WriteErrorLog($"Open database Error, {ex.Message}")
Return False
End Try
trans = db.BeginTransaction
For Each logDataInfo As LogDataInfoStruct In lstLogData
' AddLoadSqlRequestData(logDataInfo.MAC, logDataInfo, logDataInfo.parsing) '本地入库
'组插入键值对
dic.Clear()
InsertDictionary(dic, logDataInfo.MAC, logDataInfo, logDataInfo.parsing)
'添加测试记录
Dim tablenamelog As String = "TBL_Rcu_Log"
Dim cmdText As String = db.CmdHelper.Insert(tablenamelog, dic)
Try
db.ExecuteNonQuery(cmdText)
Catch ex As Exception
db.Close()
'MsgBox($"Insert Table error,{ex.Message} {vbCrLf }{cmdText}")
AdminLog.ApplicationLog.WriteErrorLog($"Insert Table error, {ex.Message}")
Return False
End Try
Isauto = Isauto + 1
If Isauto > 500 Then
trans.Commit()
trans = db.BeginTransaction
Isauto = 0
Thread.Sleep(1000)
End If
Next
trans.Commit()
db.Close()
Return True
Catch ex As Exception
Console.WriteLine($"写库失败:{ex.ToString }")
AdminLog.ApplicationLog.WriteErrorLog(ex)
db.Close()
Return False
End Try
End Using
End Function
Private _1970StartDateTime As DateTime = TimeZone.CurrentTimeZone.ToLocalTime(New System.DateTime(1970, 1, 1, 0, 0, 0, 0))
Public Function AddLoadSqlRequestData(strMacAdd As String, logDataInfo As LogDataInfoStruct, parsing_data As List(Of String))
'组插入键值对
Dim dic As New Dictionary(Of String, String)
InsertDictionary(dic, strMacAdd, logDataInfo, parsing_data)
Dim LocalConnString As String
Dim localConn As New DbConnectionStringBuilder
localConn.Add("Data Source", $"{Application.StartupPath }\LocalDB\LogService.db")
'localConn.Add("Password", "123456")
LocalConnString = localConn.ToString()
Using db As New DbExecutor(DbExecutor.DbTypeEnum.Mysql, DbConnString)
Try
db.Open()
Catch ex As Exception
Console.WriteLine($"Open local db Error, {ex.Message}")
MsgBox($"Open local db Error, {ex.Message}")
Return False
End Try
'建表
Dim CreateTableStr As String = $"Create Table if Not exists {strMacAdd} ( 'ID' integer COLLATE BINARY NOT NULL PRIMARY KEY AUTOINCREMENT );"
Try
db.ExecuteNonQuery(CreateTableStr)
Catch ex As Exception
db.Close()
MsgBox($"Create Table error,{ex.Message}")
Return False
End Try
'添加字段
Dim dtCol As DataTable
Try
dtCol = db.ExecuteDataTable($"Select * From {strMacAdd} ")
Catch ex As Exception
MsgBox($"Select Table error,{ex.Message}")
db.Close()
Return False
End Try
Dim length As Integer
Dim typeString As String
For Each colname As String In dic.Keys
If String.IsNullOrWhiteSpace(colname) Then Continue For '剔除无效数据库字段名
length = GetFiledLength(dic(colname).Length)
If length = -1 Then
Throw New Exception($"字段[{colname}] 超过最大长度2048的限制,无法入库!")
Else
typeString = $"varchar({length})"
End If
If dtCol.Columns.Contains(colname) Then '当前数据表是否已经存在对应列信息
Else
Try
db.ExecuteNonQuery(db.CmdHelper.DbAddCol("", strMacAdd, colname, typeString))
Catch ex As Exception
db.Close()
MsgBox($"Add column[{strMacAdd}] To Table error,{ex.Message}")
Return False
End Try '插入字段语句
End If
Next
'添加测试记录
Dim cmdText As String = db.CmdHelper.Insert(strMacAdd, dic)
Try
db.ExecuteNonQuery(cmdText)
Catch ex As Exception
db.Close()
MsgBox($"Insert Table error,{ex.Message}")
Return False
End Try
db.Close()
End Using
End Function
Public Sub IsCreationDbFile()
'If Not IO.File.Exists($"{Application.StartupPath }\LocalDB\LogService.db") Then
' If Not IO.Directory.Exists($"{Application.StartupPath }\LocalDB") Then
' IO.Directory.CreateDirectory($"{Application.StartupPath }\LocalDB")
' End If
' SQLiteConnection.CreateFile($"{Application.StartupPath }\LocalDB\LogService.db")
' Dim Main_dataBase_file As FileInfo = New FileInfo($"{Application.StartupPath }\LocalDB\LogService.db")
'End If
End Sub
Public Sub InsertDictionary(ByRef dic As Dictionary(Of String, String), strMacAdd As String, logDataInfo As LogDataInfoStruct, parsing_data As List(Of String))
Dim DataTimes As String = Parsing_DateTime(logDataInfo.Log_DateTime)
Dim data_string = BitConverter.ToString(logDataInfo.Log_Content).Replace("-", " ")
dic.Add("TimeSpan", CType（Math.Round((DateTime.Now - _1970StartDateTime).TotalSeconds, MidpointRounding.AwayFromZero)， UInteger))
dic.Add("MAC".ToLower(), $"{strMacAdd}")
dic.Add("CreateDateTime".ToLower(), $"{logDataInfo.CreateDateTime}")
dic.Add("LogFileName".ToLower(), $"{logDataInfo.LogFileName}")
dic.Add("LogProjectid".ToLower(), $"{logDataInfo.HotelId}")
dic.Add("LogRoomid".ToLower(), $"{logDataInfo.RoomId}")
dic.Add("Log_Valid".ToLower(), $"{logDataInfo.Log_Valid}")
dic.Add("Log_SN".ToLower(), $"{logDataInfo.Log_SN}")
dic.Add("Log_Len".ToLower(), $"{logDataInfo.Log_Len}")
dic.Add("Log_DateTime".ToLower(), $"{DataTimes}")
dic.Add("Log_TimeSpan".ToLower(), $"{logDataInfo.Log_TimeSpan}")
dic.Add("Log_Type".ToLower(), $"{logDataInfo.Log_Type}")
dic.Add("Log_Content".ToLower(), $"{data_string}")
dic.Add("Type_Param_1".ToLower(), $"{parsing_data(0)}")
dic.Add("Type_Param_2".ToLower(), $"{parsing_data(1)}")
dic.Add("Type_Param_3".ToLower(), $"{parsing_data(2)}")
dic.Add("Type_Param_4".ToLower(), $"{parsing_data(3)}")
dic.Add("Type_Param_5".ToLower(), $"{parsing_data(4)}")
dic.Add("Type_Param_6".ToLower(), $"{parsing_data(5)}")
dic.Add("Type_Param_7".ToLower(), $"{parsing_data(6)}")
dic.Add("Type_Param_8".ToLower(), $"{parsing_data(7)}")
dic.Add("Type_Param_9".ToLower(), $"{parsing_data(8)}")
dic.Add("Type_Param_10".ToLower(), $"{parsing_data(9)}")
dic.Add("Remark".ToLower(), " ")
End Sub
Public Function MysqlCreateTablecolumn(strMacAdd As String)
Dim result As String
result = $"CREATE TABLE IF NOT EXISTS `{strMacAdd}` (
`ID` int NOT NULL AUTO_INCREMENT ,
`TimeSpan` varchar(254) DEFAULT NULL,
`mac` varchar(254) DEFAULT NULL,
`createdatetime` varchar(254) DEFAULT NULL,
`logfilename` varchar(254) DEFAULT NULL,
`logprojectid` varchar(254) DEFAULT NULL,
`logroomid` varchar(254) DEFAULT NULL,
`log_valid` varchar(254) DEFAULT NULL,
`log_sn` varchar(254) DEFAULT NULL,
`log_len` varchar(254) DEFAULT NULL,
`log_datetime` varchar(254) DEFAULT NULL,
`log_timespan` varchar(254) DEFAULT NULL,
`log_type` varchar(254) DEFAULT NULL,
`log_content` text DEFAULT NULL,
`type_param_1` text DEFAULT NULL,
`type_param_2` text DEFAULT NULL,
`type_param_3` text DEFAULT NULL,
`type_param_4` text DEFAULT NULL,
`type_param_5` text DEFAULT NULL,
`type_param_6` text DEFAULT NULL,
`type_param_7` text DEFAULT NULL,
`type_param_8` text DEFAULT NULL,
`type_param_9` text DEFAULT NULL,
`type_param_10` text DEFAULT NULL,
`remark` varchar(254) DEFAULT NULL,
PRIMARY KEY (`ID`)
) "
Return result
End Function
Public Function CreateTablecolumn(strMacAdd As String)
Dim result As String
result = $"Create Table if Not exists {strMacAdd} ( [ID] integer COLLATE BINARY NOT NULL PRIMARY KEY AUTOINCREMENT,
[TimeSpan] varchar(16) COLLATE BINARY DEFAULT 'Null',
[mac] varchar(8) COLLATE BINARY DEFAULT 'Null',
[createdatetime] varchar(24) COLLATE BINARY DEFAULT 'Null',
[logfilename] varchar(40) COLLATE BINARY DEFAULT 'Null',
[logprojectid] varchar(8) COLLATE BINARY DEFAULT 'Null',
[logroomid] varchar(8) COLLATE BINARY DEFAULT 'Null',
[log_valid] varchar(8) COLLATE BINARY DEFAULT 'Null',
[log_sn] varchar(8) COLLATE BINARY DEFAULT 'Null',
[log_len] varchar(8) COLLATE BINARY DEFAULT 'Null',
[log_datetime] varchar(24) COLLATE BINARY DEFAULT 'Null',
[log_timespan] varchar(8) COLLATE BINARY DEFAULT 'Null',
[log_type] varchar(8) COLLATE BINARY DEFAULT 'Null',
[log_content] varchar(40) COLLATE BINARY DEFAULT 'Null',
[type_param_1] varchar(8) COLLATE BINARY DEFAULT 'Null',
[type_param_2] varchar(16) COLLATE BINARY DEFAULT 'Null',
[type_param_3] varchar(8) COLLATE BINARY DEFAULT 'Null',
[type_param_4] varchar(16) COLLATE BINARY DEFAULT 'Null',
[type_param_5] varchar(32) COLLATE BINARY DEFAULT 'Null',
[type_param_6] varchar(8) COLLATE BINARY DEFAULT 'Null',
[type_param_7] varchar(8) COLLATE BINARY DEFAULT 'Null',
[type_param_8] varchar(8) COLLATE BINARY DEFAULT 'Null',
[type_param_9] varchar(8) COLLATE BINARY DEFAULT 'Null',
[type_param_10] varchar(8) COLLATE BINARY DEFAULT 'Null',
[remark] varchar(8) COLLATE BINARY DEFAULT 'Null');"
Return result
End Function
Private Shared Function GetFiledLength(len As Integer) As Integer
Dim result As Integer
If len = 0 Then
result = 8
ElseIf len <= 2048 Then
If len Mod 8 = 0 Then
result = len
Else
result = ((len \ 8) + 1) * 8
End If
Else
result = -1
End If
Return result
End Function
''' <summary>
''' 字符串显示 DateTime
''' </summary>
''' <param name="data_list"></param>
''' <returns></returns>
Public Function Parsing_DateTime(data_list As Log_DateStruct) As String
Dim temp_string As String
temp_string = $"20{data_list.year:00}-{data_list.month:00}-{data_list.day:00} {data_list.hour:00}:{data_list.minute:00}:{data_list.second:00}.{data_list.milliscond:000}"
'temp_string = $"{data_list.hour:00}:{data_list.minute:00}:{data_list.second:00}.{data_list.milliscond:000}"
Return temp_string
End Function
#End Region
Public Function Gettablename() As List(Of String）
Dim dic As New List(Of String)
Dim localConn As New DbConnectionStringBuilder
localConn.Add("Data Source", $"{Application.StartupPath }\LocalDB\LogService.db")
'localConn.Add("Password", "123456")
Dim LocalConnString As String = localConn.ToString()
Dim CreateTableStr As String = "SELECT name FROM sqlite_master WHERE type='table' ORDER BY name;"
Dim dtCol As DataTable
Using db As New DbExecutor(DbExecutor.DbTypeEnum.Sqlite, LocalConnString)
Try
db.Open()
dtCol = db.ExecuteDataTable(CreateTableStr)
For i As Integer = 1 To dtCol.Rows.Count - 1
If dtCol.Rows(i)(0).ToString.Contains("sqlite_") Then Continue For
dic.Add(dtCol.Rows(i)(0).ToString)
Next
db.Close()
Return dic
Catch ex As Exception
MsgBox($"Create Tableco Error, {ex.Message}")
db.Close()
Return Nothing
End Try
End Using
End Function
Public Function DeleteTable(tabname As String) As Boolean
Dim dic As New List(Of String)
Dim localConn As New DbConnectionStringBuilder
localConn.Add("Data Source", $"{Application.StartupPath }\LocalDB\LogService.db")
'localConn.Add("Password", "123456")
Dim LocalConnString As String = localConn.ToString()
Dim CreateTableStr As String = $"DROP TABLE '{tabname}';"
Using db As New DbExecutor(DbExecutor.DbTypeEnum.Sqlite, LocalConnString)
Try
db.Open()
db.ExecuteNonQuery(CreateTableStr)
db.Close()
Return True
Catch ex As Exception
MsgBox($"Create Tableco Error, {ex.Message}")
db.Close()
Return False
End Try
End Using
End Function
Public Function QueryDatabase(tabname As String) As DataTable
Dim dic As New List(Of String)
Dim localConn As New DbConnectionStringBuilder
localConn.Add("Data Source", $"{Application.StartupPath }\LocalDB\LogService.db")
'localConn.Add("Password", "123456")
Dim LocalConnString As String = localConn.ToString()
Dim CreateTableStr As String = $"DROP TABLE '{tabname}';"
Dim udt As DataTable
Using db As New DbExecutor(DbExecutor.DbTypeEnum.Sqlite, LocalConnString)
Try
db.Open()
udt = db.ExecuteDataTable($"Select * From {tabname} ")
db.Close()
Return udt
Catch ex As Exception
MsgBox($"Create Tableco Error, {ex.Message}")
db.Close()
Return Nothing
End Try
End Using
End Function
End Class
Reference in New Issue Copy Permalink