Reconfigure for GIT

2017-03-26 20:00:03 +02:00
commit 00637826ab
8056 changed files with 535977 additions and 0 deletions
@@ -0,0 +1,164 @@
+Imports System
+Imports System.IO
+Imports System.Configuration
+Imports DevExpress.Persistent.Base
+
+Imports Microsoft.VisualBasic
+Imports System.Collections.Generic
+Imports System.Linq
+Imports System.Text
+Imports DevExpress.ExpressApp
+Imports System.Collections
+Imports DevExpress.ExpressApp.Xpo
+Imports System.Runtime.Remoting.Channels
+Imports System.Security.Principal
+Imports System.Threading
+Imports DevExpress.Persistent.BaseImpl
+Imports DevExpress.Persistent.AuditTrail
+
+Imports RabbitMQ.Client
+Imports RabbitMQ.ServiceModel
+Imports RabbitMQ.Client.Events
+Imports Newtonsoft.Json
+Imports DevExpress.Xpo
+Imports DevExpress.Data.Filtering
+Imports System.Xml
+Imports System.Collections.Specialized
+Imports SISBusiness.RabbitMQ.Module
+
+Public Class WinService
+    Inherits System.ServiceProcess.ServiceBase
+
+    Private _Session As DevExpress.Xpo.Session
+
+    Dim _TimerCore As System.Threading.Timer
+    Dim _Semaphor As Boolean = True
+    Dim _RunningMode As String = ConfigurationManager.AppSettings("RunningMode")
+
+    Dim _factory As ConnectionFactory
+    Dim _connection As IConnection
+    Dim _channel As IModel
+    Dim _consumer As EventingBasicConsumer
+
+    Protected Overrides Sub OnStart(ByVal args() As String)
+        ' Diagnostics.EventLog.WriteEntry(ConfigurationManager.AppSettings("ServiceName"), "Service Start at " + Now.ToString)
+
+        _Session = LoginSession()
+        Try
+            If _Session IsNot Nothing Then
+                If _Session.IsConnected Then
+                    Select Case _RunningMode
+                        Case "0" 'Olvas
+                            Try
+                                '   ValueManager.ValueManagerType = GetType(MultiThreadValueManager(Of )).GetGenericTypeDefinition()
+
+                                Dim _Factory_HostName As String = ConfigurationManager.AppSettings("Factory_HostName")
+                                Dim _Factory_UserName As String = ConfigurationManager.AppSettings("Factory_UserName")
+                                Dim _Factory_Password As String = ConfigurationManager.AppSettings("Factory_Password")
+                                Dim _Factory_VirtualHost As String = ConfigurationManager.AppSettings("Factory_VirtualHost")
+
+                                Dim _Queue_Name As String = ConfigurationManager.AppSettings("Queue_Name")
+
+                                _factory = New ConnectionFactory
+                                _factory.HostName = _Factory_HostName
+                                _factory.UserName = _Factory_UserName
+                                _factory.Password = _Factory_Password
+                                _factory.VirtualHost = _Factory_VirtualHost
+                                _factory.RequestedChannelMax = 10
+
+
+                                _connection = _factory.CreateConnection
+                                _channel = _connection.CreateModel
+
+                                _consumer = New EventingBasicConsumer
+
+                                AddHandler _consumer.Received, AddressOf Consumer_Received
+
+                                '   Diagnostics.EventLog.WriteEntry(ConfigurationManager.AppSettings("ServiceName"), "Starting server pool at " + Now.ToString)
+
+                                ' _channel.BasicConsume(_Queue_Name, False, _consumer) 'Fenthagyni a queue-ban
+                                _channel.BasicConsume(_Queue_Name, True, _consumer) 'Leszedni a queue-ból 
+
+                            Catch e As Exception
+                                'Diagnostics.EventLog.WriteEntry(ConfigurationManager.AppSettings("ServiceName"), e.Message)
+                            End Try
+                        Case "1" 'Küld
+                            Try
+                                '   ValueManager.ValueManagerType = GetType(MultiThreadValueManager(Of )).GetGenericTypeDefinition()
+
+                                _TimerCore = New System.Threading.Timer(AddressOf _TimerCore_Tick, Nothing, 0, 10000)
+
+                            Catch e As Exception
+                                'Diagnostics.EventLog.WriteEntry(ConfigurationManager.AppSettings("ServiceName"), e.Message)
+                            End Try
+                        Case "2" 'Mindkettő
+
+                        Case Else
+                            'Gáz van
+
+                    End Select
+                End If
+            Else
+                'Throw New Exception(String.Format("Nem lehet csatlakozni az SQL serverhez. ConnenctionString:{0}", ConfigurationManager.ConnectionStrings.Item("ConnectionString").ConnectionString))
+            End If
+        Catch ex As Exception
+            'Diagnostics.EventLog.WriteEntry(ConfigurationManager.AppSettings("ServiceName"), ex.Message)
+        End Try
+    End Sub
+    Protected Overrides Sub OnStop()
+        Select Case _RunningMode
+            Case "0" 'Olvas
+                _channel.Close()
+                _connection.Close()
+            Case "1"
+                _TimerCore.Change(Timeout.Infinite, 0)
+                _TimerCore.Dispose()
+            Case "2"
+        End Select
+
+        If _Session.IsConnected Then LogoffSession(_Session)
+
+        ' Diagnostics.EventLog.WriteEntry(ConfigurationManager.AppSettings("ServiceName"), "Service STOP")
+    End Sub
+    Private Sub Consumer_Received(sender As IBasicConsumer, args As BasicDeliverEventArgs)
+        '// Itt afogadás
+        'Console.WriteLine("Fogadás...")
+
+        Try
+            Dim _JSONText As String = Encoding.UTF8.GetString(args.Body)
+            Dim _XML As System.Xml.XmlDocument = JsonConvert.DeserializeXmlNode(_JSONText, "JsonXML")
+
+            If _XML IsNot Nothing Then
+                Dim _method As String = _XML.SelectSingleNode("JsonXML/method").InnerText
+
+                If _method.Contains("ugyfelimport") Then GetCustomers.CustomerImport(_XML, "JsonXML/params", "", _Session, True)
+                If _method.Contains("szamlaimport") Then GetGLAccounts.GLAccountImport(_XML, "", _Session, True)
+                If _method.Contains("get_version") Then SISVersion.SendSISVersion(_XML, args.BasicProperties)
+            End If
+        Catch ex As Exception
+            WriteErrorLog((Now + " " + ex.Message).ToString, "")
+        End Try
+    End Sub
+    Private Sub _TimerCore_Tick(ByVal state As Object)
+        _TimerCore.Change(Timeout.Infinite, 0)
+        PublishCustomers.PublishCustomers("", _Session, True)
+        _TimerCore.Change(0, 10000)
+    End Sub
+    Private Function LoginSession() As DevExpress.Xpo.Session
+        Dim _Session As New DevExpress.Xpo.Session
+
+        _Session.ConnectionString = ConfigurationManager.ConnectionStrings.Item("ConnectionString").ConnectionString
+        _Session.AutoCreateOption = DB.AutoCreateOption.None
+        _Session.Connect()
+
+        If Not _Session.IsConnected Then
+            _Session = Nothing
+        End If
+
+        Return _Session
+    End Function
+    Private Sub LogoffSession(_Session As DevExpress.Xpo.Session)
+        _Session.Connection.Close()
+    End Sub
+
+End Class