| | |
| | | |
| | | try |
| | | { |
| | | HttpSvcHost = new System.Net.HttpListener(); |
| | | HttpSvcHost.AuthenticationSchemes = System.Net.AuthenticationSchemes.Anonymous; |
| | | HttpSvcHost.Prefixes.Add("http://10.221.55.116:8808/"); |
| | | HttpSvcHost.Start(); |
| | | HttpSvcHost.BeginGetContext(HttpSvcListenerCallback, null); |
| | | //HttpSvcHost = new System.Net.HttpListener(); |
| | | //HttpSvcHost.AuthenticationSchemes = System.Net.AuthenticationSchemes.Anonymous; |
| | | //HttpSvcHost.Prefixes.Add("http://10.221.55.117:8808/"); |
| | | //HttpSvcHost.Start(); |
| | | //HttpSvcHost.BeginGetContext(HttpSvcListenerCallback, null); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | //æ§è¡å¤æ¬¡ |
| | | for (int iii = 0; iii < 1; iii++) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250323151832119][ä¸å¡é»è¾.Program4] |
| | | ////Conn.é»è®¤Redis.SetValue("西é¨å2.Param3","300","西é¨å2Queue"); |
| | | ////return; |
| | | //if(false){ |
| | | // List<string> locs = new List<string>() { "vxr1l", "vx1r", "vxr1c1", "vxr1c2", "vxr2l", "vxr2r", "vxr2c1", "vxr2c2" }; |
| | | // List<string> sites = new List<string>() { "196365BB283162", "193841BB283149", "198756BB287300", "198767BB286133", "206987BB282931", "204460BB282975", "209405BB287057", "209377BB285899" }; |
| | | |
| | | // LocRepository locservice = new LocRepository(); |
| | | // for (int i = 0; i < locs.Count; i++) |
| | | // { |
| | | // string loccode = locs[i]; |
| | | // string sitesss = sites[i]; |
| | | // var loc = locservice.FindEntity(x => x.S_LOC_CODE == loccode); |
| | | // if (loc == null) |
| | | // { |
| | | // locservice.Insert(new LocEntity |
| | | // { |
| | | // S_ID = Guid.NewGuid().ToString(), |
| | | // S_STATE = "ç¼è¾", |
| | | // T_CREATE = DateTime.Now, |
| | | // T_MODIFY = DateTime.Now, |
| | | // S_DEEP = "vxr", |
| | | |
| | | // S_LOC_CODE = loccode, |
| | | // S_AGV_SITE = sitesss, |
| | | |
| | | // S_LOCK_STATE = "æ ", |
| | | // N_ROW = 1, |
| | | // N_COL = 1, |
| | | // N_AGV_CODE = 0, |
| | | // N_AGV_SITE_LAYER = 0, |
| | | // N_CAPACITY = 1, |
| | | // N_CURRENT_NUM = 0, |
| | | // S_TYPE = "", |
| | | |
| | | // }); |
| | | // } |
| | | // } |
| | | // // TaskProcess.CreateTask("", locs[6], locs[7], "test", 9, new List<string> { "test" }, 1, 1, 1); |
| | | // } |
| | | |
| | | #endregion [èæ¬][20250323151832119][ä¸å¡é»è¾.Program4] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | /// <summary> |
| | | /// ç¨åºç段:æ·ç¬æè1 |
| | | /// æè¿°: |
| | |
| | | // if (di.deviceType == 2 || di.deviceType == 1) |
| | | // RunafterMac(di,true); |
| | | /// TODO mes ä¸åã æ¹ææºæ¢°èçæ§ - çæ§ç©ºçè¿æ¯æ»¡ç - èå¨mes ä»»å¡ã |
| | | |
| | | //LogHelper.Info($"设å¤ç¶æï¼ç»´å¸å°1ï¼ç»´å¸å°æè1.State:{Device.ç»´å¸å°æè1.State} "); |
| | | //Device.ç»´å¸å°æè1.ReadPLC("ç»´å¸å°æè1.R50", out object value); |
| | | //LogHelper.Info($"设å¤ç¶æï¼ç»´å¸å°1ï¼ç»´å¸å°æè1.R50:{value?.ToString()} "); |
| | | |
| | | //LogHelper.Info($"设å¤ç¶æï¼ç»´å¸å°2ï¼ç»´å¸å°æè2.State:{Device.ç»´å¸å°æè2.State} "); |
| | | //Device.ç»´å¸å°æè2.ReadPLC("ç»´å¸å°æè2.R50", out value); |
| | | //LogHelper.Info($"设å¤ç¶æï¼ç»´å¸å°2ï¼ç»´å¸å°æè2.R50:{value?.ToString()} "); |
| | | |
| | | //LogHelper.Info($"设å¤ç¶æï¼æ·ç¬1ï¼Jsæ·é¡º1.State:{Device.Jsæ·é¡º1.State} "); |
| | | //Device.Jsæ·é¡º1.ReadPLC("Jsæ·é¡º1.D1202", out value); |
| | | //LogHelper.Info($"设å¤ç¶æï¼æ·ç¬1 Jsæ·é¡º1.D1202:{value?.ToString()} "); |
| | | |
| | | //LogHelper.Info($"设å¤ç¶æï¼æ·ç¬2ï¼Jsæ·é¡º2.State:{Device.Jsæ·é¡º2.State} "); |
| | | //Device.Jsæ·é¡º2.ReadPLC("Jsæ·é¡º2.D1202", out value); |
| | | //LogHelper.Info($"设å¤ç¶æï¼æ·ç¬2 Jsæ·é¡º2.D1202:{value?.ToString()} "); |
| | | |
| | | |
| | | #endregion [èæ¬][20250325085810885][ä¸å¡é»è¾.ç¬¬ä¸æ 段.èªæµè½¬æµç¨] |
| | | } |
| | | catch (Exception ex) |
| | |
| | | try |
| | | { |
| | | #region [èæ¬][20250605212104026][ä¸å¡é»è¾.SocketServer] |
| | | var host = System.Net.Dns.GetHostEntry(System.Net.Dns.GetHostName()); |
| | | foreach (var ip in host.AddressList) |
| | | { |
| | | if (ip.AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork) |
| | | { |
| | | Console.WriteLine($"ip= {ip.ToString()}"); |
| | | new TcpServer(ip.ToString()); |
| | | } |
| | | } |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "TaskEverythingRun"); |
| | | #endregion [èæ¬][20250605212104026][ä¸å¡é»è¾.SocketServer] |
| | | } |
| | | catch (Exception ex) |
| | |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | //æ§è¡å¤æ¬¡ |
| | | for (int iii = 0; iii < 1; iii++) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250323151832119][ä¸å¡é»è¾.Program4] |
| | | |
| | | //LogHelper.Info($"<<<<<<<<<<<<<<<<<<<<<<>>>>>>>>>>>>>>>>>>"); |
| | | //LogHelper.Info($"<<<<<<<<<<<<<<<<<ç¨åºÂ·å¯å¨>>>>>>>>>>>>>>"); |
| | | |
| | | //// ä½¿ç¨æ¦æªå¨ |
| | | //var interceptor = new ConsoleInterceptor(); |
| | | //Console.SetOut(interceptor); |
| | | |
| | | //LogHelper.Info($"<<<<<<<<<<<<<<<<<<<<<<>>>>>>>>>>>>>>>>>>"); |
| | | //AnsiConsole.Markup("[underline red]Hello[/] World!"); |
| | | // AnsiConsole.Markup("[underline red]Hello[/] World!"); |
| | | #endregion [èæ¬][20250323151832119][ä¸å¡é»è¾.Program4] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | |
| | | } |
| | | /// <summary> |
| | |
| | | } |
| | | #endregion |
| | | |
| | | #region View2äºä»¶ |
| | | /// <summary> |
| | | /// View2æå¼äºä»¶ |
| | | /// </summary> |
| | | /// <param name="sender"></param> |
| | | /// <param name="e"></param> |
| | | public void View2_LoadEvent(object sender, RoutedEventArgs e) |
| | | { |
| | | |
| | | |
| | | |
| | | } |
| | | /// <summary> |
| | | /// View2å
³éäºä»¶ |
| | | /// </summary> |
| | | /// <param name="sender"></param> |
| | | /// <param name="e"></param> |
| | | public void View2_CloseEvent(object sender, System.ComponentModel.CancelEventArgs e) |
| | | { |
| | | |
| | | |
| | | } |
| | | /// <summary> |
| | | /// View2åå§å |
| | | /// </summary> |
| | | /// <param name="sender"></param> |
| | | /// <param name="e"></param> |
| | | public void View2_Init(object sender, RoutedEventArgs e) |
| | | { |
| | | } |
| | | #endregion |
| | | |
| | | #region 忢tab页 |
| | | public void tab_SelectionChanged(object sender, EventArgs e) |
| | | { |
| | |
| | | #endregion |
| | | |
| | | #region Httpæå¡çå¬ |
| | | private void HttpSvcListenerCallback(IAsyncResult ar) |
| | | private async void HttpSvcListenerCallback(IAsyncResult ar) |
| | | { |
| | | System.Net.HttpListenerContext context = null; |
| | | try |
| | | { |
| | | HttpSvcHost.BeginGetContext(HttpSvcListenerCallback, null); |
| | | System.Net.HttpListenerContext context = HttpSvcHost.EndGetContext(ar); |
| | | context = HttpSvcHost.EndGetContext(ar); |
| | | System.Net.HttpListenerRequest request = context.Request; |
| | | System.Net.HttpListenerResponse response = context.Response; |
| | | switch (request.LocalEndPoint.ToString()) |
| | | { |
| | | case "10.221.55.116:8808": |
| | | case "10.221.55.117:8808": |
| | | { |
| | | using (var reader = new System.IO.StreamReader(request.InputStream, System.Text.Encoding.UTF8)) |
| | | { |
| | | string requestJson = reader.ReadToEnd(); |
| | | |
| | | string respstr = HttpSvcListenerCallback_he(request.HttpMethod, request.Url.AbsolutePath, requestJson, out System.Net.HttpStatusCode statusCode); |
| | | |
| | | System.Net.HttpStatusCode statusCode = 0; |
| | | string respstr = await Task.Run(() => |
| | | { |
| | | return HttpSvcListenerCallback_he(request.HttpMethod, request.Url.AbsolutePath, requestJson, out statusCode); |
| | | }); |
| | | string logContent = ""; |
| | | logContent += $"\r\n[{request.HttpMethod}]{request.Url.AbsolutePath}"; |
| | | logContent += $"\r\n[request]{requestJson}"; |
| | | logContent += $"\r\n[response]{respstr}"; |
| | | Conn.é»è®¤æ¥å¿?.Info(logContent); |
| | | _ = Task.Run(() => |
| | | { |
| | | Conn.é»è®¤æ¥å¿?.Info(logContent); |
| | | }); |
| | | |
| | | byte[] bytstr = Encoding.UTF8.GetBytes(respstr); |
| | | response.StatusCode = (int)statusCode; |
| | | response.SendChunked = false; |
| | | response.ContentLength64 = bytstr.Length; |
| | | response.OutputStream.Write(bytstr, 0, bytstr.Length); |
| | | response.Close(); |
| | | // 弿¥åå
¥ååº |
| | | await response.OutputStream.WriteAsync(bytstr, 0, bytstr.Length); |
| | | |
| | | } |
| | | break; |
| | | } |
| | |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | context?.Response.Close(); |
| | | } |
| | | } |
| | | private System.String HttpSvcListenerCallback_he(System.String method, System.String path, System.String requestJson, out System.Net.HttpStatusCode statusCode) |
| | |
| | | { |
| | | switch (path) |
| | | { |
| | | case "/inddddddddddddddddd": |
| | | case var _ when System.Text.RegularExpressions.Regex.IsMatch(path, @"\.(html|ico|js|css)(\?.*)?$", System.Text.RegularExpressions.RegexOptions.IgnoreCase): |
| | | { |
| | | statusCode = System.Net.HttpStatusCode.OK; |
| | | // å¤å¶å°case ä¸ |
| | | //var _ when System.Text.RegularExpressions.Regex.IsMatch(path, @"\.(html|ico|js|css)(\?.*)?$", System.Text.RegularExpressions.RegexOptions.IgnoreCase) |
| | | var filePath = System.IO.Path.Combine("Static", path.Substring(1)); |
| | | var filePath = /*Directory.GetCurrentDirectory() + "\\Static" + "\\" + path.Substring(1);*/System.IO.Path.Combine(Directory.GetCurrentDirectory() + "\\Static", path.Substring(1)); |
| | | return File.ReadAllText(filePath); |
| | | } |
| | | } |