CPL
/
AOI_V2
1
0
Форкнуть 0
Код Задачи 0 Pull Request'ы 0 Релизы 0 Вики Активность
Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.
3 коммитов
1 ветка
10 MiB
 
 
 
 
Дерево: 74f686f5ec
Ветки Теги
${ item.name }
Создать ветку ${ searchTerm }
из '74f686f5ec'
${ noResults }
AOI_V2/halftoneproject-master/BanBoShi/WebServer/WebService.cs

975 строки
48 KiB
Исходник Вина История 

  1. using Newtonsoft.Json;

  2. using Newtonsoft.Json.Linq;

  3. using SqlSugar;

  4. using System;

  5. using System.Collections.Generic;

  6. using System.IO;

  7. using System.Linq;

  8. using System.Net;

  9. using System.Text;

  10. using System.Text.RegularExpressions;

  11. using System.Threading.Tasks;

  12. using MaiMuControl.Utils;

  13. using MaiMuControl.Device;

  14. using System.Reflection;

  15. using Models;

  16. using MaiMuAOI.SysCtrl;

  17. using OpenCvSharp;

  18. using Yolo5;

  19. using HalconDotNet;

  20. 

  21. namespace ProductionControl

  22. {

  23.     public class WebService

  24.     {

  25.         private HttpListener svcHttpListener;

  26.         public Action<WarningEnum, string> LogEvent;

  27.         /// <summary>

  28.         /// 缺陷图片和详情文件路径

  29.         /// </summary>

  30.         public string Defect_Compress_SavePath {  get; set; }

  31.         /// <summary>

  32.         /// 比对图片和详情文件路径

  33.         /// </summary>

  34.         public string SizeBmp_Zoom_Image_SavePath { get; set; }

  35. 

  36.         /// <summary>

  37.         /// 缺陷小图片和详情文件路径

  38.         /// </summary>

  39.         public string Defect_Small_SavePath { get; set; }

  40. 

  41.         Service.OrderService svcOrder = new Service.OrderService();

  42.         private void logEvent(string msg, WarningEnum warn = WarningEnum.Normal)

  43.         {

  44.             LogEvent?.Invoke(warn, msg);

  45.         }

  46.         public void start(string HttpIP, int HttpPort)

  47.         {

  48.             try

  49.             {

  50.                 if (HttpPort > 0)

  51.                 {

  52.                     //logEvent("Web服务启动...");

  53.                     this.svcHttpListener = new HttpListener();

  54.                     List<string> lstIp = HttpUtil.getLocalIPList();

  55.                     //logEvent($"Web服务已启动，运行于端口:{Config.LocalHttpPort.ToString()}, 监听Ip:{string.Join("|", lstIp)}");

  56.                     //if (!string.IsNullOrWhiteSpace(Config.LocalIp) && lstIp.FindIndex(m => m.Contains(Config.LocalIp)) >= 0)//没指定IP/指定的不对

  57.                     //{

  58.                     //    lstIp.Clear();

  59.                     //    lstIp.Add(Config.LocalIp);

  60.                     //}

  61.                     //lstIp.Clear();

  62.                     if (lstIp.Count < 1)

  63.                     {

  64.                         lstIp.Add(HttpIP);

  65.                         lstIp.Add("127.0.0.1");

  66.                     }

  67.                     logEvent($"Web服务已启动，运行于端口:{HttpPort.ToString()}, 监听Ip:{string.Join("|", lstIp)}");

  68.                     for (int i = 0; i < lstIp.Count; i++) 

  69.                         this.svcHttpListener.Prefixes.Add("http://" + lstIp[i] + ":" + HttpPort.ToString() + "/");

  70.                     //svcHttpListener.Prefixes.Add($"https://+:{HttpPort}");

  71.                     this.svcHttpListener.Start();

  72.                     //logEvent($"Web服务已启动，运行于端口:{Config.LocalHttpPort.ToString()}, 监听Ip:{string.Join("|", lstIp)}");

  73.                     //this.svcHttpListener.GetContext().Response.AppendHeader("Access-Control-Allow-Origin", "*");//后台跨域请求，通常设置为配置文件

  74.                     //this.svcHttpListener.GetContext().Response.AppendHeader("Access-Control-Allow-Credentials", "true"); //后台跨域请求 

  75.                     this.svcHttpListener.BeginGetContext(new AsyncCallback(this.GetContextCallBack), this.svcHttpListener);

  76.                 }

  77.                 //------WEB Socket

  78.                 //if (Config.localIp != "" && Config.localSocketPort > 0)

  79.                 //{

  80.                 //    logEvent( "WebSocket服务启动...");

  81.                 //    this.wssv = new WebSocketServer(Config.localSocketPort);

  82.                 //    this.wssv.AddWebSocketService<Socket1>("/socket1");

  83.                 //    this.wssv.Start();

  84.                 //    logEvent( "WebSocket服务已启动。");

  85.                 //} 

  86.             }

  87.             catch (Exception ex)

  88.             {

  89.                 logEvent("Web服务启动失败,ex="+ex.Message);

  90.             }

  91.         }

  92.         public void stop()

  93.         {

  94.             logEvent( "正在停止WEB服务...");

  95.             try

  96.             {

  97.                 if (this.svcHttpListener != null && this.svcHttpListener.IsListening)

  98.                 {

  99.                     this.svcHttpListener.Stop();

  100.                     this.svcHttpListener.Close();

  101.                     this.logEvent("Web服务已停止!");

  102.                 }

  103.                 //if (this.svcWebSocket != null && this.svcWebSocket.IsListening)

  104.                 //{

  105.                 //    this.svcWebSocket.Stop();

  106.                 //    this.svcWebSocket = null;

  107.                 //    this.AddTextEvent("WebSocket", "WebSocket服务已停止!");

  108.                 //} 

  109.             }

  110.             catch (Exception ex)

  111.             {

  112.                 logEvent("Web服务停止失败,ex=" + ex.Message);

  113.             }

  114.         }

  115.          

  116.         //

  117.         private void GetContextCallBack(IAsyncResult ar)

  118.         {

  119.             this.svcHttpListener = (ar.AsyncState as HttpListener);

  120.             HttpListenerContext httpListenerContext;

  121.             try

  122.             {

  123.                 httpListenerContext = this.svcHttpListener.EndGetContext(ar);

  124.                 //httpListenerContext.Response.AppendHeader("Access-Control-Allow-Origin", "*");//后台跨域请求，通常设置为配置文件

  125.                 //httpListenerContext.Response.AppendHeader("Access-Control-Allow-Credentials", "true"); //后台跨域请求 

  126.                 //httpListenerContext.Response.AppendHeader("Access-Control-Allow-Methods", "GET,POST");

  127.                 httpListenerContext.Response.AddHeader("Access-Control-Allow-Origin", "*");

  128.                 httpListenerContext.Response.AddHeader("Access-Control-Allow-Headers", "*");

  129.                 httpListenerContext.Response.AddHeader("Access-Control-Allow-Methods", "*");

  130. 

  131.                 this.svcHttpListener.BeginGetContext(new AsyncCallback(this.GetContextCallBack), this.svcHttpListener);

  132.             }

  133.             catch (Exception ex)

  134.             {

  135.                 logEvent(  "ex:" + ex.StackTrace);

  136.                 return;

  137.             }

  138. 

  139.             //

  140.             string sessionId = Convert.ToInt32(DateTime.Now.ToString("mmssfff")).ToString();//.ToString("X");

  141.             string reqHttpMethod = httpListenerContext.Request.HttpMethod;

  142.             string reqUrl = httpListenerContext.Request.RawUrl;

  143.             string reqData = "";

  144.             try

  145.             {

  146.                 this.logEvent(  $"{sessionId} / 收到请求:{reqHttpMethod} To Url:{reqUrl}");

  147.                 reqData = HttpUtil.getPostData(httpListenerContext.Request);

  148.                 this.logEvent( $"{sessionId} / 请求数据:{reqData}");

  149.                 var subUrls = reqUrl.Trim(new char[] { '/' }).Split(new char[] { '/' });

  150.                 if (subUrls[0].ToLower() == "static")

  151.                 {

  152.                     #region 

  153.                     //string InputStream = ""; //上传的数据

  154.                     //using (var streamReader = new StreamReader(httpListenerContext.Request.InputStream)) 

  155.                     //    InputStream = streamReader.ReadToEnd();

  156. 

  157.                    // string filePath = Config.appBasePath;

  158.                     string filePath = Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location);

  159.                     foreach (var sub in subUrls)

  160.                         filePath += "\\" + sub;

  161.                     if (!File.Exists(filePath)) filePath = filePath + "\\index.html";

  162.                     if (!File.Exists(filePath))

  163.                     {

  164.                         httpListenerContext.Response.ContentLength64 = 0;

  165.                         httpListenerContext.Response.StatusCode = 404;

  166.                         httpListenerContext.Response.Abort();

  167.                     }

  168.                     else

  169.                     {

  170.                         httpListenerContext.Response.StatusCode = 200;

  171.                         string exeName = Path.GetExtension(filePath);

  172.                         httpListenerContext.Response.ContentType = HttpUtil.GetContentType(exeName);

  173.                         FileStream fileStream = new System.IO.FileStream(filePath, System.IO.FileMode.Open, System.IO.FileAccess.Read, FileShare.ReadWrite);

  174.                         int byteLength = (int)fileStream.Length;

  175.                         byte[] fileBytes = new byte[byteLength];

  176.                         fileStream.Read(fileBytes, 0, byteLength);

  177.                         fileStream.Close();

  178.                         fileStream.Dispose();

  179.                         httpListenerContext.Response.ContentLength64 = byteLength;

  180.                         httpListenerContext.Response.OutputStream.Write(fileBytes, 0, byteLength);

  181.                         //httpListenerContext.Response.OutputStream.Close();

  182.                     }

  183.                     #endregion

  184.                     return;

  185.                 }

  186. 

  187.                 if (reqData == null)

  188.                     throw new Exception("请求数据不可为空！");

  189.                 httpListenerContext.Response.StatusCode = 200;

  190. 

  191.                 JObject joReqData = JObject.Parse(reqData);

  192.                 string respText;

  193.                 JObject result = new JObject();

  194.                 string sourceSessionId;

  195.                 switch (subUrls[0].ToLower())

  196.                 {

  197.                     case "static": //上面已处理

  198.                         break;

  199.                     case "test":

  200.                         HttpUtil.writeToHttpContext_text(httpListenerContext.Response, "测试回应！");

  201.                         break;

  202.                     case "api":

  203.                         switch (subUrls[1].ToLower())

  204.                         {

  205.                             case "query_table":

  206.                                 #region 

  207.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  208.                                 //    goto case "http_error";

  209.                                  

  210.                                 result = getTableList(joReqData);

  211.                                 respText = JsonConvert.SerializeObject(result);

  212.                                 this.logEvent($"{sessionId} / 返回:{(respText.Length > 30 ?respText.Substring(0,30):respText)}");

  213.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  214.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  215.                                 #endregion

  216.                                 break;

  217.                             case "update_table"://insert+update

  218.                                 #region 

  219.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  220.                                 //    goto case "http_error";

  221.                                  

  222.                                 result = updateTableList(joReqData);

  223.                                 respText = JsonConvert.SerializeObject(result);

  224.                                 this.logEvent($"{sessionId} / 返回:{(respText.Length > 30 ?respText.Substring(0,30):respText)}");

  225.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  226.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  227.                                 #endregion

  228.                                 break;

  229.                             case "delete_table":

  230.                                 #region 

  231.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  232.                                 //    goto case "http_error";

  233.                                  

  234.                                 result = delTableList(joReqData);

  235.                                 respText = JsonConvert.SerializeObject(result);

  236.                                 this.logEvent($"{sessionId} / 返回:{(respText.Length > 30 ? respText.Substring(0, 30) : respText)}");

  237.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  238.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  239.                                 #endregion

  240.                                 break;

  241.                             case "getreport_qualified":

  242.                                 #region 

  243.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  244.                                 //    goto case "http_error";

  245.                                  

  246.                                 result = getReport_Qualified(joReqData);

  247.                                 respText = JsonConvert.SerializeObject(result);

  248.                                 this.logEvent($"{sessionId} / 返回:{(respText.Length > 30 ? respText.Substring(0, 30) : respText)}");

  249.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  250.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  251.                                 #endregion

  252.                                 break;  

  253.                             case "getchart_qualified_rate"://图表：日月季年 合格率

  254.                                 #region 

  255.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  256.                                 //    goto case "http_error";

  257. 

  258.                                 result = GetChart_Qualified_Rate(joReqData);

  259.                                 respText = JsonConvert.SerializeObject(result);

  260.                                 this.logEvent($"{sessionId} / 返回:{(respText.Length > 30 ? respText.Substring(0, 30) : respText)}");

  261.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  262.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  263.                                 #endregion

  264.                                 break;

  265.                             case "getchart_qualified_date"://图表：合格率分析

  266.                                 #region 

  267.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  268.                                 //    goto case "http_error";

  269. 

  270.                                 result = GetChart_Qualified_Date(joReqData);

  271.                                 respText = JsonConvert.SerializeObject(result);

  272.                                 this.logEvent($"{sessionId} / 返回:{(respText.Length > 30 ? respText.Substring(0, 30) : respText)}");

  273.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  274.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  275.                                 #endregion

  276.                                 break;

  277.                             case "getchart_defects_date"://图表：按日期统计各缺陷数

  278.                                 #region 

  279.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  280.                                 //    goto case "http_error";

  281. 

  282.                                 result = GetReport_Defects_Date(joReqData);

  283.                                 respText = JsonConvert.SerializeObject(result);

  284.                                 this.logEvent($"{sessionId} / 返回:{(respText.Length > 30 ? respText.Substring(0, 30) : respText)}");

  285.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  286.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  287.                                 #endregion

  288.                                 break;

  289.                             case "getchart_defects_total"://图表：缺陷总数

  290.                                 #region 

  291.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  292.                                 //    goto case "http_error";

  293. 

  294.                                 result = GetReport_Defects_Total(joReqData);

  295.                                 respText = JsonConvert.SerializeObject(result);

  296.                                 this.logEvent($"{sessionId} / 返回:{(respText.Length > 30 ? respText.Substring(0, 30) : respText)}");

  297.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  298.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  299.                                 #endregion

  300.                                 break;

  301.                             //修复台

  302.                             case "get_defect_from_sn"://读取缺陷文件名列表和JSON数组

  303.                                 #region 

  304.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  305.                                 //    goto case "http_error"; 

  306. 

  307.                                 result = getDefectFromSN(joReqData);

  308.                                 respText = JsonConvert.SerializeObject(result);

  309.                                 this.logEvent($"{sessionId} / 返回:{(respText.Length > 30 ? respText.Substring(0, 30) : respText)}");

  310.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  311.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  312.                                 #endregion

  313.                                 break;

  314.                             case "get_defect_pic"://读取缺陷文件base64

  315.                                 #region 

  316.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  317.                                 //    goto case "http_error"; 

  318. 

  319.                                 result = getDefectBmpBase64(joReqData);

  320.                                 respText = JsonConvert.SerializeObject(result);

  321.                                 this.logEvent($"{sessionId} / 返回BaseLen:{(respText.Length > 30 ? respText.Substring(0, 30) : respText)}");

  322.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  323.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  324.                                 #endregion 

  325.                                 break;

  326.                             case "get_smalldir_from_sn"://读取缺陷小图文件名列表

  327.                                 #region 

  328.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  329.                                 //    goto case "http_error"; 

  330. 

  331.                                 result = getDefectSmallDirFromSN(joReqData);

  332.                                 respText = JsonConvert.SerializeObject(result);

  333.                                 this.logEvent($"{sessionId} / 返回:{(respText.Length > 30 ? respText.Substring(0, 30) : respText)}");

  334.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  335.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  336.                                 #endregion

  337.                                 break;

  338.                             case "get_defect_smallpic"://读取缺陷小图

  339.                                 #region 

  340.                                 //if (httpListenerContext.Request.HttpMethod != "POST")

  341.                                 //    goto case "http_error"; 

  342. 

  343.                                 result = getDefectSmallBmpBase64(joReqData);

  344.                                 respText = JsonConvert.SerializeObject(result);

  345.                                 this.logEvent($"{sessionId} / 返回BaseLen:{(respText.Length > 30 ? respText.Substring(0, 30) : respText)}");

  346.                                 if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  347.                                     this.logEvent($"{sessionId} / http返回时连接已断开！");

  348.                                 #endregion 

  349.                                 break;

  350.                             default:

  351.                                 HttpUtil.writeToHttpContext_text(httpListenerContext.Response, "未知请求！");

  352.                                 break;

  353.                         }

  354.                         break; 

  355.                     case "http_error":

  356.                         result.Add("code", -1);

  357.                         result.Add("msg", "不支持的请求协议！");

  358.                         respText = JsonConvert.SerializeObject(result);

  359.                         this.logEvent( $"{sessionId} / 返回:{respText}" );

  360.                         if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  361.                         {

  362.                             this.logEvent( $"{sessionId} / http返回时连接已断开！" );

  363.                             //this.logEvent( id + " /http连接已断开，" + (string.IsNullOrWhiteSpace(callback_url) ? "无法返回结果！" : "通过回调返回" + callback_url), 1);

  364.                             //if (callback_url != null && callback_url != "")

  365.                             //    HttpUtil.post(callback_url, respText);

  366.                         }

  367.                         break;

  368.                     case "url_error":

  369.                         result.Add("code", -2);

  370.                         result.Add("msg", "URL地址错误！");

  371.                         respText = JsonConvert.SerializeObject(result);

  372.                         this.logEvent( $"{sessionId} / 返回:{respText}" );

  373.                         if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  374.                         {

  375.                             this.logEvent( $"{sessionId} / http返回时连接已断开！" );

  376.                             //this.logEvent( id + " /http连接已断开，" + (string.IsNullOrWhiteSpace(callback_url) ? "无法返回结果！" : "通过回调返回" + callback_url), 1);

  377.                             //if (callback_url != null && callback_url != "")

  378.                             //    HttpUtil.post(callback_url, respText);

  379.                         }

  380.                         break;

  381.                     case "param_error":

  382.                         result.Add("code", -3);

  383.                         result.Add("msg", "参数错误！");

  384.                         respText = JsonConvert.SerializeObject(result);

  385.                         this.logEvent( $"{sessionId} / 返回:{respText}" );

  386.                         if (!HttpUtil.writeToHttpContext_json(httpListenerContext.Response, respText))

  387.                         {

  388.                             this.logEvent( $"{sessionId} / http返回时连接已断开！" );

  389.                             //this.logEvent( id + " /http连接已断开，" + (string.IsNullOrWhiteSpace(callback_url) ? "无法返回结果！" : "通过回调返回" + callback_url), 1);

  390.                             //if (callback_url != null && callback_url != "")

  391.                             //    HttpUtil.post(callback_url, respText);

  392.                         }

  393.                         break;

  394.                     default:

  395.                         HttpUtil.writeToHttpContext_text(httpListenerContext.Response, "未知请求！");

  396.                         break;

  397.                 }

  398.             }

  399.             catch (Exception ex)

  400.             {

  401.                 this.logEvent( $"{sessionId} / 异常:{ex.Message}\r\n{ex.StackTrace}" );

  402.                 httpListenerContext.Response.StatusCode = 500;

  403.             }

  404.             finally

  405.             {

  406.                 try

  407.                 { 

  408.                     httpListenerContext.Response.OutputStream.Close();//客户端断开时会异常

  409.                 }

  410.                 catch { }

  411.             }

  412.         }

  413. 

  414.         //----

  415.         private JObject getTableList(JObject req)

  416.         {

  417.             JObject res = new JObject();

  418.             try

  419.             {

  420.                 string model, fields = "", domain = "", order = "";

  421.                 int pageNum = 0, pageSize = 0, totalCount = 0;

  422. 

  423.                 model = req.Value<string>("model");

  424.                 if (req.ContainsKey("fields")) fields = req.Value<string>("fields");

  425.                 if (req.ContainsKey("domain")) domain = req.Value<JArray>("domain").ToString();

  426.                 if (req.ContainsKey("order")) order = req.Value<string>("order");

  427. 

  428.                 if (req.ContainsKey("pageNum")) pageNum = req.Value<int>("pageNum");

  429.                 if (req.ContainsKey("pageSize")) pageSize = req.Value<int>("pageSize");

  430. 

  431.                 //创建表达式

  432.                 var exp1 = Expressionable.Create<Order>()

  433.                                 //.AndIF((int)cobProductList.SelectedValue > 0, it => it.ProductId == (int)cobProductList.SelectedValue)

  434.                                 //.AndIF((int)cobStepList.SelectedValue > 0, it => it.StepId == (int)cobStepList.SelectedValue)

  435.                                 //.AndIF(dateTimePicker1.Checked, it => it.CreateTime >= dateTimePicker1.Value)

  436.                                 //.AndIF(dateTimePicker2.Checked, it => it.CreateTime < dateTimePicker2.Value)

  437.                                 .ToExpression();//注意 这一句 不能少

  438. 

  439. 

  440.                 var list = svcOrder.GetList(model, fields, domain, order, pageNum, pageSize, ref totalCount);

  441.                 //var list = svcOrder.GetListNav(pageNum, pageSize, ref totalCount, exp1);

  442.                 res.Add("code", 200);

  443.                 res.Add("data", JArray.FromObject(list));

  444.                 res.Add("totalCount", totalCount);

  445.             }

  446.             catch (Exception ex)

  447.             {

  448.                 res.Add("code", -9);

  449.                 res.Add("data", ex.Message);

  450.             }

  451.             return res;

  452.         }

  453.         private JObject delTableList(JObject req)

  454.         {

  455.             JObject res = new JObject();

  456.             try

  457.             {

  458.                 string model = req.Value<string>("model");

  459.                 string domain = req.Value<JArray>("domain").ToString();

  460.                 //var idArr = req.Value<JArray>("idList"); 

  461.                 //List<int> ids = new List<int>();

  462.                 //foreach (int id in idArr) ids.Add(id);

  463.                 int result = svcOrder.DeleteList(model, domain);

  464.                 res.Add("code", 200);

  465.                 res.Add("data", result); 

  466.             }

  467.             catch (Exception ex)

  468.             {

  469.                 res.Add("code", -9);

  470.                 res.Add("data", ex.Message);

  471.             }

  472.             return res;

  473.         }

  474.         private JObject updateTableList(JObject req)

  475.         {

  476.             JObject res = new JObject();

  477.             try

  478.             {

  479.                 string model = req.Value<string>("model");

  480.                 var list = req.Value<JArray>("datas");

  481.                 string[] updateColumns = null;

  482.                 if (req.ContainsKey("columns"))

  483.                     updateColumns = req.Value<JArray>("columns").ToObject<List<string>>().ToArray();

  484.                 int result = svcOrder.UpdateableList(model, list.ToString(), updateColumns);

  485.                 res.Add("code", 200);

  486.                 res.Add("data", result); 

  487.             }

  488.             catch (Exception ex)

  489.             {

  490.                 res.Add("code", -9);

  491.                 res.Add("data", ex.Message);

  492.             }

  493.             return res;

  494.         }

  495.         private JObject getReport_Qualified(JObject req)

  496.         {

  497.             JObject res = new JObject();

  498.             try

  499.             {

  500.                 string domain = "", order = "";

  501.                 int pageNum = 0, pageSize = 0, totalCount = 0;

  502.                  

  503.                 if (req.ContainsKey("domain")) domain = req.Value<JArray>("domain").ToString();

  504.                 if (req.ContainsKey("order")) order = req.Value<string>("order");

  505. 

  506.                 if (req.ContainsKey("pageNum")) pageNum = req.Value<int>("pageNum");

  507.                 if (req.ContainsKey("pageSize")) pageSize = req.Value<int>("pageSize");

  508.                  

  509.                 //创建表达式 

  510.                 var list = svcOrder.GetReport_Qualified( domain, order,  pageNum, pageSize, ref totalCount); 

  511.                 res.Add("code", 200); 

  512.                 res.Add("data", list);

  513.                 res.Add("totalCount", totalCount);

  514.             }

  515.             catch (Exception ex)

  516.             {

  517.                 res.Add("code", -9);

  518.                 res.Add("data", ex.Message);

  519.             }

  520.             return res;

  521.         }     

  522.        

  523.         /// <summary>

  524.         ///  获取缺陷数据

  525.         /// </summary>

  526.         /// <param name="req"></param>

  527.         /// <returns>{文件名:[["4","3.9","-0.8","dk","0.39"],["index","X","Y","缺陷类型","缺陷的置信度"],...]}</returns>

  528.         private JObject getDefectFromSN(JObject req)

  529.         {

  530.             JObject res = new JObject();

  531.             try

  532.             {

  533.                 string date = req.Value<string>("date");

  534.                 string sn = req.Value<string>("sn");

  535. 

  536.                 JObject dataall = new JObject();

  537.                 string path, key;

  538.                 string[] files;

  539. 

  540.                 List<List<string>> allData = new List<List<string>>();

  541. 

  542.                 //文件名格式：$"Size_SN{order.SN}_I{res.index}_X{res.Defects_X}_Y{res.Defects_Y}_.....json/bmp

  543.                 //--缺陷

  544.                 JObject data = new JObject();

  545.                 path = $"{Defect_Compress_SavePath}\\{date}\\{sn}\\";

  546.                 if (Directory.Exists(path))

  547.                 { 

  548.                     files = Directory.GetFiles(path, $"Defect_SN{sn}_*.json", SearchOption.TopDirectoryOnly);

  549.                     if (files.Length > 0)

  550.                     {

  551.                         //对文件名中的数字(index)进行大小排序

  552.                         files = files.OrderBy(s => int.Parse(Path.GetFileNameWithoutExtension(s).Split('_')[2].Substring(1))).ToArray();

  553.                         foreach (string file in files)

  554.                         {

  555.                             key = Path.GetFileNameWithoutExtension(file);

  556.                             if (File.Exists(path + key + ".jpg"))

  557.                             {

  558.                                 data.Add(key, JArray.Parse(File.ReadAllText(file)));

  559.                                 var temp = JsonConvert.DeserializeObject<List<List<string>>>(File.ReadAllText(file));

  560.                                 allData.AddRange(temp);

  561.                             }

  562.                             else

  563.                             {

  564.                                 string[] name_array = key.Split(new char[] { '_' });

  565.                                 if (name_array.Length > 6)

  566.                                     name_array[5] = "C0";

  567.                                 string file_name = string.Join("_", name_array);

  568.                                 if (File.Exists(path + file_name + ".jpg"))

  569.                                 {

  570.                                     data.Add(key, JArray.Parse(File.ReadAllText(file)));

  571.                                     var temp = JsonConvert.DeserializeObject<List<List<string>>>(File.ReadAllText(file));

  572.                                     allData.AddRange(temp);

  573.                                 }

  574.                             }

  575.                         }

  576.                     }

  577.                 }

  578.                 //--缺陷 --比对

  579.                 List<List<string>> allDataTxt = new List<List<string>>();

  580.                 //JObject data = new JObject();

  581.                 path = $"{Defect_Compress_SavePath}\\{date}\\{sn}\\";

  582.                 if (Directory.Exists(path))

  583.                 {

  584.                     files = Directory.GetFiles(path, $"Defect_SN{sn}_*.txt", SearchOption.TopDirectoryOnly);

  585.                     if (files.Length > 0)

  586.                     {

  587.                         //对文件名中的数字(index)进行大小排序

  588.                         files = files.OrderBy(s => int.Parse(Path.GetFileNameWithoutExtension(s).Split('_')[2].Substring(1))).ToArray();

  589.                         foreach (string file in files)

  590.                         {

  591.                             key = Path.GetFileNameWithoutExtension(file);

  592.                             if (File.Exists(path + key + ".jpg"))

  593.                             {

  594.                                 //data.Add(key, JArray.Parse(File.ReadAllText(file)));

  595.                                 var temp = JsonConvert.DeserializeObject<List<List<string>>>(File.ReadAllText(file));

  596.                                 allDataTxt.AddRange(temp);

  597.                             }

  598.                             else

  599.                             {

  600.                                 string[] name_array = key.Split(new char[] { '_' });

  601.                                 if (name_array.Length > 6)

  602.                                     name_array[5] = "C0";

  603.                                 string file_name = string.Join("_", name_array);

  604.                                 if (File.Exists(path + file_name + ".jpg"))

  605.                                 {

  606.                                     //data.Add(key, JArray.Parse(File.ReadAllText(file)));

  607.                                     var temp = JsonConvert.DeserializeObject<List<List<string>>>(File.ReadAllText(file));

  608.                                     allDataTxt.AddRange(temp);

  609.                                 }

  610.                             }

  611.                         }

  612.                     }

  613.                 }

  614. 

  615.                 //--比对 

  616.                 List<List<string>> allData2 = new List<List<string>>();

  617.                 JObject data2 = new JObject();

  618.                 path = $"{SizeBmp_Zoom_Image_SavePath}\\{date}\\{sn}\\";

  619.                 if (Directory.Exists(path))

  620.                 {

  621.                     files = Directory.GetFiles(path, $"Size_SN{sn}_*.json", SearchOption.TopDirectoryOnly);

  622.                     if (files.Length > 0)

  623.                     {

  624.                         //对文件名中的数字(index)进行大小排序

  625.                         files = files.OrderBy(s => int.Parse(Path.GetFileNameWithoutExtension(s).Split('_')[2].Substring(1))).ToArray();

  626.                         foreach (string file in files)

  627.                         {

  628.                             key = Path.GetFileNameWithoutExtension(file);

  629.                             if (File.Exists(path + key + ".jpg"))

  630.                             {

  631.                                 data.Add(key, JArray.Parse(File.ReadAllText(file)));

  632.                                 data2.Add(key, JArray.Parse(File.ReadAllText(file)));

  633.                                 var temp = JsonConvert.DeserializeObject<List<List<string>>>(File.ReadAllText(file));

  634.                                 allData2.AddRange(temp);

  635.                             }

  636.                         }

  637.                     }

  638.                 }

  639. 

  640.                 ////--比对2 

  641.                 path = $"{SizeBmp_Zoom_Image_SavePath}\\{date}\\{sn}\\";

  642.                 if (Directory.Exists(path))

  643.                 {

  644.                     //DefectSize_SN

  645.                     files = Directory.GetFiles(path, $"DefectSize_SN{sn}_*.json", SearchOption.TopDirectoryOnly);

  646.                     if (files.Length > 0)

  647.                     {

  648.                         //对文件名中的数字(index)进行大小排序

  649.                         files = files.OrderBy(s => int.Parse(Path.GetFileNameWithoutExtension(s).Split('_')[2].Substring(1))).ToArray();

  650.                         foreach (string file in files)

  651.                         {

  652.                             key = Path.GetFileNameWithoutExtension(file);

  653.                             if (File.Exists(path + key + ".jpg"))

  654.                             {

  655.                                 data.Add(key, JArray.Parse(File.ReadAllText(file)));

  656.                                 data2.Add(key, JArray.Parse(File.ReadAllText(file)));

  657.                                 var temp = JsonConvert.DeserializeObject<List<List<string>>>(File.ReadAllText(file));

  658.                                 allData2.AddRange(temp);

  659.                             }

  660.                         }

  661.                     }

  662.                 }

  663.                 Yolo_Class yolo = new Yolo_Class();

  664.                 File.WriteAllText("data.json", JsonConvert.SerializeObject(data));

  665.                 File.WriteAllText("defect.json", JsonConvert.SerializeObject(allData));

  666.                 File.WriteAllText("defectTxt.json", JsonConvert.SerializeObject(allDataTxt));

  667.                 File.WriteAllText("size.json", JsonConvert.SerializeObject(allData2));

  668. 

  669. #if OpenSizeDefectComp

  670.                 var defectInfor2RestorationDesk = yolo.FilteringOverlappingDefects(allDataTxt, allData2);

  671. 

  672.                 foreach (var kv in data)

  673.                 {

  674.                     dataall.Add(kv.Key, kv.Value);

  675.                 }

  676.                 foreach (var kv in data2)

  677.                 {

  678.                     var temp = JsonConvert.DeserializeObject<List<List<string>>>(kv.Value.ToString());

  679.                     List<List<string>> isexsist = temp.Intersect(defectInfor2RestorationDesk).ToList(); //交集 表示两个List都存在的集合

  680. 

  681.                     List<List<string>> dlist = new List<List<string>>();

  682.                     foreach (var i in temp)

  683.                     {

  684.                         foreach (var j in defectInfor2RestorationDesk)

  685.                         {

  686.                             if (j[0] == i[0] && j[1] == i[1] && j[2] == i[2] && j[3] == i[3] && j[4] == i[4])

  687.                                 dlist.Add(i);

  688.                         }

  689. 

  690.                     }

  691.                     if (dlist != null && dlist.Count > 0)

  692.                         dataall.Add(kv.Key, JArray.Parse(JsonConvert.SerializeObject(dlist)));

  693.                 }

  694. #endif

  695.                 res.Add("code", 200);

  696.                 if(ConfMgr.Instance.SysConfigParams.OpenRemoveDuplicates)

  697.                     res.Add("data", dataall);

  698.                 else

  699.                     res.Add("data", data);

  700. 

  701. 

  702.             }

  703.             catch (Exception ex)

  704.             {

  705.                 res.Add("code", -9);

  706.                 res.Add("data", ex.Message);

  707.             }

  708.             return res; 

  709.         }

  710.         /// <summary>

  711.         /// 获取修复台图片

  712.         /// </summary>

  713.         /// <param name="req"></param>

  714.         /// <returns></returns>

  715.         private JObject getDefectBmpBase64(JObject req)

  716.         {

  717.             JObject res = new JObject();

  718.             try

  719.             {

  720.                 string date = req.Value<string>("date");

  721.                 string sn = req.Value<string>("sn");

  722.                 string file_name = req.Value<string>("file_name");

  723. 

  724.                 string file_path;

  725.                 //--缺陷

  726.                 if (file_name.ToLower().IndexOf("defect") == 0)

  727.                 {

  728.                     file_path = $"{Defect_Compress_SavePath}\\{date}\\{sn}\\{file_name}.jpg";

  729.                     //如果显示打标修改名称

  730.                     if (ConfMgr.Instance.SysConfigParams.OpenShowDB)

  731.                     {

  732.                         if (!File.Exists(file_path))

  733.                         {

  734.                             string[] name_array = file_name.Split(new char[] { '_' });

  735.                             if (name_array.Length > 6)

  736.                                 name_array[5] = "C0";

  737.                             file_name = string.Join("_", name_array);

  738.                         }

  739.                     }

  740.                     file_path = $"{Defect_Compress_SavePath}\\{date}\\{sn}\\{file_name}.jpg";

  741. 

  742.                     if (!File.Exists(file_path))

  743.                         throw new Exception(file_name + " 缺陷文件不存在！");

  744. 

  745.                     res.Add("code", 200);

  746.                     res.Add("data", Convert.ToBase64String(File.ReadAllBytes(file_path)));

  747.                 }

  748.                 //--比对 

  749.                 else if (file_name.ToLower().IndexOf("size") == 0)

  750.                 {

  751.                     file_path = $"{SizeBmp_Zoom_Image_SavePath}\\{date}\\{sn}\\{file_name}.jpg";

  752.                     if (!File.Exists(file_path))

  753.                         throw new Exception(file_name + " 比对文件不存在！");

  754. 

  755.                     res.Add("code", 200);

  756.                     res.Add("data", Convert.ToBase64String(File.ReadAllBytes(file_path)));

  757.                 }

  758.                 else

  759.                     throw new Exception($"文件类型错误：file_name={file_name}");

  760.             }

  761.             catch (Exception ex)

  762.             {

  763.                 res.Add("code", -9);

  764.                 res.Add("data", ex.Message);

  765.             }

  766.             return res;

  767.         }

  768. 

  769.         /// <summary>

  770.         ///  获取缺陷小图数据

  771.         /// </summary>

  772.         /// <param name="req"></param>

  773.         /// <returns>{文件名:[["4","3.9","-0.8","dk","0.39"],["index","X","Y","缺陷类型","缺陷的置信度"],...]}</returns>

  774.         private JObject getDefectSmallDirFromSN(JObject req)

  775.         {

  776.             JObject res = new JObject();

  777.             try

  778.             {

  779.                 string date = req.Value<string>("date");

  780.                 string sn = req.Value<string>("sn");

  781. 

  782.                 JObject dataall = new JObject();

  783.                 string path, key;

  784.                 string[] files;

  785. 

  786.                 List<List<string>> allData = new List<List<string>>();

  787. 

  788.                 //文件名格式：$"Size_SN{order.SN}_I{res.index}_X{res.Defects_X}_Y{res.Defects_Y}_.....json/bmp

  789.                 //--缺陷

  790.                 JObject data = new JObject();

  791.                 path = $"{Defect_Small_SavePath}\\{date}\\{sn}\\";

  792.                 if (Directory.Exists(path))

  793.                 {

  794.                     files = Directory.GetFiles(path, $"Defect_SN{sn}_*.jpg", SearchOption.TopDirectoryOnly);

  795.                     if (files.Length > 0)

  796.                     {

  797.                         //对文件名中的数字(index)进行大小排序

  798.                         files = files.OrderBy(s => int.Parse(Path.GetFileNameWithoutExtension(s).Split('_')[2].Substring(1))).ToArray();

  799.                         foreach (string file in files)

  800.                         {

  801.                             key = Path.GetFileNameWithoutExtension(file);

  802.                             if (File.Exists(path + key + ".jpg"))

  803.                             {

  804.                                 data.Add(key, "dir");

  805.                                 //var temp = JsonConvert.DeserializeObject<List<List<string>>>(File.ReadAllText(file));

  806.                                 //allData.AddRange(temp);

  807.                             }

  808.                         }

  809.                     }

  810.                     files = Directory.GetFiles(path, $"Size_SN{sn}_*.jpg", SearchOption.TopDirectoryOnly);

  811.                     if (files.Length > 0)

  812.                     {

  813.                         //对文件名中的数字(index)进行大小排序

  814.                         files = files.OrderBy(s => int.Parse(Path.GetFileNameWithoutExtension(s).Split('_')[2].Substring(1))).ToArray();

  815.                         foreach (string file in files)

  816.                         {

  817.                             key = Path.GetFileNameWithoutExtension(file);

  818.                             if (File.Exists(path + key + ".jpg"))

  819.                             {

  820.                                 data.Add(key, "dir");

  821.                                 //var temp = JsonConvert.DeserializeObject<List<List<string>>>(File.ReadAllText(file));

  822.                                 //allData.AddRange(temp);

  823.                             }

  824.                         }

  825.                     }

  826.                 }

  827. 

  828.                 res.Add("code", 200);

  829.                 res.Add("data", data);

  830. 

  831.             }

  832.             catch (Exception ex)

  833.             {

  834.                 res.Add("code", -9);

  835.                 res.Add("data", ex.Message);

  836.             }

  837.             return res;

  838.         }

  839.         /// <summary>

  840.         /// 获取小图

  841.         /// </summary>

  842.         /// <param name="req"></param>

  843.         /// <returns></returns>

  844.         private JObject getDefectSmallBmpBase64(JObject req)

  845.         {

  846.             JObject res = new JObject();

  847.             try

  848.             {

  849.                 string date = req.Value<string>("date");

  850.                 string sn = req.Value<string>("sn");

  851.                 string file_name = req.Value<string>("file_name");

  852. 

  853.                 string file_path;

  854.                 //--缺陷

  855.                 if (file_name.ToLower().IndexOf("defect") == 0)

  856.                 {

  857.                     file_path = $"{Defect_Small_SavePath}\\{date}\\{sn}\\{file_name}.jpg";

  858. 

  859.                     if (!File.Exists(file_path))

  860.                         throw new Exception(file_name + " 缺陷文件不存在！");

  861. 

  862.                     res.Add("code", 200);

  863.                     res.Add("data", Convert.ToBase64String(File.ReadAllBytes(file_path)));

  864.                 }

  865.                 //--比对 

  866.                 else if (file_name.ToLower().IndexOf("size") == 0)

  867.                 {

  868.                     file_path = $"{Defect_Small_SavePath}\\{date}\\{sn}\\{file_name}.jpg";

  869.                     if (!File.Exists(file_path))

  870.                         throw new Exception(file_name + " 比对文件不存在！");

  871. 

  872.                     res.Add("code", 200);

  873.                     res.Add("data", Convert.ToBase64String(File.ReadAllBytes(file_path)));

  874.                 }

  875.                 else

  876.                     throw new Exception($"文件类型错误：file_name={file_name}");

  877.             }

  878.             catch (Exception ex)

  879.             {

  880.                 res.Add("code", -9);

  881.                 res.Add("data", ex.Message);

  882.             }

  883.             return res;

  884.         }

  885.         private JObject GetChart_Qualified_Rate(JObject req)

  886.         {

  887.             JObject res = new JObject();

  888.             try

  889.             { 

  890.                 var list = svcOrder.GetReport_Qualified_Total(); 

  891.                 res.Add("code", 200);

  892.                 res.Add("data", JArray.FromObject(list)); 

  893.             }

  894.             catch (Exception ex)

  895.             {

  896.                 res.Add("code", -9);

  897.                 res.Add("data", ex.Message);

  898.             }

  899.             return res;

  900.         } 

  901.         private JObject GetReport_Defects_Date(JObject req)

  902.         {

  903.             JObject res = new JObject();

  904.             try

  905.             {

  906.                 string domain = "", order = "";

  907.                 int pageNum = 0, pageSize = 0, totalCount = 0;

  908. 

  909.                 if (req.ContainsKey("domain")) domain = req.Value<JArray>("domain").ToString();

  910.                 if (req.ContainsKey("order")) order = req.Value<string>("order");

  911. 

  912.                 if (req.ContainsKey("pageNum")) pageNum = req.Value<int>("pageNum");

  913.                 if (req.ContainsKey("pageSize")) pageSize = req.Value<int>("pageSize");

  914. 

  915.                 //创建表达式   

  916.                 var list = svcOrder.GetReport_Defects_Date(domain, order, pageNum, pageSize, ref totalCount);

  917.                 res.Add("code", 200);

  918.                 res.Add("data",  list); 

  919.             }

  920.             catch (Exception ex)

  921.             {

  922.                 res.Add("code", -9);

  923.                 res.Add("data", ex.Message);

  924.             }

  925.             return res;

  926.         }

  927.         private JObject GetReport_Defects_Total(JObject req)

  928.         {

  929.             JObject res = new JObject();

  930.             try

  931.             {

  932.                 string domain = "", order = ""; 

  933.                 if (req.ContainsKey("domain")) domain = req.Value<JArray>("domain").ToString();

  934. 

  935.                 var list = svcOrder.GetReport_Defects_Total(domain); 

  936.                 res.Add("code", 200);

  937.                 res.Add("data", list); 

  938.             }

  939.             catch (Exception ex)

  940.             {

  941.                 res.Add("code", -9);

  942.                 res.Add("data", ex.Message);

  943.             }

  944.             return res;

  945.         }

  946.         private JObject GetChart_Qualified_Date(JObject req)

  947.         {

  948.             JObject res = new JObject();

  949.             try

  950.             {

  951.                 string domain = "", order = "";

  952.                 int pageNum = 0, pageSize = 0, totalCount = 0;

  953.                  

  954.                 if (req.ContainsKey("domain")) domain = req.Value<JArray>("domain").ToString();

  955.                 if (req.ContainsKey("order")) order = req.Value<string>("order");

  956. 

  957.                 if (req.ContainsKey("pageNum")) pageNum = req.Value<int>("pageNum");

  958.                 if (req.ContainsKey("pageSize")) pageSize = req.Value<int>("pageSize");

  959. 

  960.                 //创建表达式  

  961.                 var list = svcOrder.GetReport_Qualified_Date( domain, order,  pageNum, pageSize, ref totalCount); 

  962.                 res.Add("code", 200); 

  963.                 res.Add("data", list);

  964.                 res.Add("totalCount", totalCount);

  965.             }

  966.             catch (Exception ex)

  967.             {

  968.                 res.Add("code", -9);

  969.                 res.Add("data", ex.Message);

  970.             }

  971.             return res;

  972.         }

  973.     }

  974. }