CPL
/
banboshi_V2
1
0
Креирај огранак 0
Код Дискусије 0 Захтеви за спајање 0 Издања 1 Вики Activity
版博士V2.0程序
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
63 Комити
5 Гране
6.2 GiB
 
 
 
 
Дрво: 1bdb56afaf
Гране Ознаке
${ item.name }
Create branch ${ searchTerm }
from '1bdb56afaf'
${ noResults }
banboshi_V2/halftoneproject-master/BanBoShi/WebServer/WebService.cs

825 lines
41 KiB
Датотека Blame Историја 

  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.         Service.OrderService svcOrder = new Service.OrderService();

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

  38.         {

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

  40.         }

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

  42.         {

  43.             try

  44.             {

  45.                 if (HttpPort > 0)

  46.                 {

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

  48.                     this.svcHttpListener = new HttpListener();

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

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

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

  52.                     //{

  53.                     //    lstIp.Clear();

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

  55.                     //}

  56.                     //lstIp.Clear();

  57.                     if (lstIp.Count < 1)

  58.                     {

  59.                         lstIp.Add(HttpIP);

  60.                         lstIp.Add("127.0.0.1");

  61.                     }

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

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

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

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

  66.                     this.svcHttpListener.Start();

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

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

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

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

  71.                 }

  72.                 //------WEB Socket

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

  74.                 //{

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

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

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

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

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

  80.                 //} 

  81.             }

  82.             catch (Exception ex)

  83.             {

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

  85.             }

  86.         }

  87.         public void stop()

  88.         {

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

  90.             try

  91.             {

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

  93.                 {

  94.                     this.svcHttpListener.Stop();

  95.                     this.svcHttpListener.Close();

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

  97.                 }

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

  99.                 //{

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

  101.                 //    this.svcWebSocket = null;

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

  103.                 //} 

  104.             }

  105.             catch (Exception ex)

  106.             {

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

  108.             }

  109.         }

  110.          

  111.         //

  112.         private void GetContextCallBack(IAsyncResult ar)

  113.         {

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

  115.             HttpListenerContext httpListenerContext;

  116.             try

  117.             {

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

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

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

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

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

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

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

  125. 

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

  127.             }

  128.             catch (Exception ex)

  129.             {

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

  131.                 return;

  132.             }

  133. 

  134.             //

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

  136.             string reqHttpMethod = httpListenerContext.Request.HttpMethod;

  137.             string reqUrl = httpListenerContext.Request.RawUrl;

  138.             string reqData = "";

  139.             try

  140.             {

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

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

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

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

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

  146.                 {

  147.                     #region 

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

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

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

  151. 

  152.                    // string filePath = Config.appBasePath;

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

  154.                     foreach (var sub in subUrls)

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

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

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

  158.                     {

  159.                         httpListenerContext.Response.ContentLength64 = 0;

  160.                         httpListenerContext.Response.StatusCode = 404;

  161.                         httpListenerContext.Response.Abort();

  162.                     }

  163.                     else

  164.                     {

  165.                         httpListenerContext.Response.StatusCode = 200;

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

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

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

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

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

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

  172.                         fileStream.Close();

  173.                         fileStream.Dispose();

  174.                         httpListenerContext.Response.ContentLength64 = byteLength;

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

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

  177.                     }

  178.                     #endregion

  179.                     return;

  180.                 }

  181. 

  182.                 if (reqData == null)

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

  184.                 httpListenerContext.Response.StatusCode = 200;

  185. 

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

  187.                 string respText;

  188.                 JObject result = new JObject();

  189.                 string sourceSessionId;

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

  191.                 {

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

  193.                         break;

  194.                     case "test":

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

  196.                         break;

  197.                     case "api":

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

  199.                         {

  200.                             case "query_table":

  201.                                 #region 

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

  203.                                 //    goto case "http_error";

  204.                                  

  205.                                 result = getTableList(joReqData);

  206.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  210.                                 #endregion

  211.                                 break;

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

  213.                                 #region 

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

  215.                                 //    goto case "http_error";

  216.                                  

  217.                                 result = updateTableList(joReqData);

  218.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  222.                                 #endregion

  223.                                 break;

  224.                             case "delete_table":

  225.                                 #region 

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

  227.                                 //    goto case "http_error";

  228.                                  

  229.                                 result = delTableList(joReqData);

  230.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  234.                                 #endregion

  235.                                 break;

  236.                             case "getreport_qualified":

  237.                                 #region 

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

  239.                                 //    goto case "http_error";

  240.                                  

  241.                                 result = getReport_Qualified(joReqData);

  242.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  246.                                 #endregion

  247.                                 break;  

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

  249.                                 #region 

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

  251.                                 //    goto case "http_error";

  252. 

  253.                                 result = GetChart_Qualified_Rate(joReqData);

  254.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  258.                                 #endregion

  259.                                 break;

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

  261.                                 #region 

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

  263.                                 //    goto case "http_error";

  264. 

  265.                                 result = GetChart_Qualified_Date(joReqData);

  266.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  270.                                 #endregion

  271.                                 break;

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

  273.                                 #region 

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

  275.                                 //    goto case "http_error";

  276. 

  277.                                 result = GetReport_Defects_Date(joReqData);

  278.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  282.                                 #endregion

  283.                                 break;

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

  285.                                 #region 

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

  287.                                 //    goto case "http_error";

  288. 

  289.                                 result = GetReport_Defects_Total(joReqData);

  290.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  294.                                 #endregion

  295.                                 break;

  296.                             //修复台

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

  298.                                 #region 

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

  300.                                 //    goto case "http_error"; 

  301. 

  302.                                 result = getDefectFromSN(joReqData);

  303.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  307.                                 #endregion

  308.                                 break;

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

  310.                                 #region 

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

  312.                                 //    goto case "http_error"; 

  313. 

  314.                                 result = getDefectBmpBase64(joReqData);

  315.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  319.                                 #endregion 

  320.                                 break;

  321.                             default:

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

  323.                                 break;

  324.                         }

  325.                         break; 

  326.                     case "http_error":

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

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

  329.                         respText = JsonConvert.SerializeObject(result);

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

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

  332.                         {

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

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

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

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

  337.                         }

  338.                         break;

  339.                     case "url_error":

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

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

  342.                         respText = JsonConvert.SerializeObject(result);

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

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

  345.                         {

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

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

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

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

  350.                         }

  351.                         break;

  352.                     case "param_error":

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

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

  355.                         respText = JsonConvert.SerializeObject(result);

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

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

  358.                         {

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

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

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

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

  363.                         }

  364.                         break;

  365.                     default:

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

  367.                         break;

  368.                 }

  369.             }

  370.             catch (Exception ex)

  371.             {

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

  373.                 httpListenerContext.Response.StatusCode = 500;

  374.             }

  375.             finally

  376.             {

  377.                 try

  378.                 { 

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

  380.                 }

  381.                 catch { }

  382.             }

  383.         }

  384. 

  385.         //----

  386.         private JObject getTableList(JObject req)

  387.         {

  388.             JObject res = new JObject();

  389.             try

  390.             {

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

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

  393. 

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

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

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

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

  398. 

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

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

  401. 

  402.                 //创建表达式

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

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

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

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

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

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

  409. 

  410. 

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

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

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

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

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

  416.             }

  417.             catch (Exception ex)

  418.             {

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

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

  421.             }

  422.             return res;

  423.         }

  424.         private JObject delTableList(JObject req)

  425.         {

  426.             JObject res = new JObject();

  427.             try

  428.             {

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

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

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

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

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

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

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

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

  437.             }

  438.             catch (Exception ex)

  439.             {

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

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

  442.             }

  443.             return res;

  444.         }

  445.         private JObject updateTableList(JObject req)

  446.         {

  447.             JObject res = new JObject();

  448.             try

  449.             {

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

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

  452.                 string[] updateColumns = null;

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

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

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

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

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

  458.             }

  459.             catch (Exception ex)

  460.             {

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

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

  463.             }

  464.             return res;

  465.         }

  466.         private JObject getReport_Qualified(JObject req)

  467.         {

  468.             JObject res = new JObject();

  469.             try

  470.             {

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

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

  473.                  

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

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

  476. 

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

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

  479.                  

  480.                 //创建表达式 

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

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

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

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

  485.             }

  486.             catch (Exception ex)

  487.             {

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

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

  490.             }

  491.             return res;

  492.         }     

  493.        

  494.         /// <summary>

  495.         ///  获取缺陷数据

  496.         /// </summary>

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

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

  499.         private JObject getDefectFromSN(JObject req)

  500.         {

  501.             JObject res = new JObject();

  502.             try

  503.             {

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

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

  506. 

  507.                 JObject dataall = new JObject();

  508.                 string path, key;

  509.                 string[] files;

  510. 

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

  512. 

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

  514.                 //--缺陷

  515.                 JObject data = new JObject();

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

  517.                 if (Directory.Exists(path))

  518.                 { 

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

  520.                     if (files.Length > 0)

  521.                     {

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

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

  524.                         foreach (string file in files)

  525.                         {

  526.                             key = Path.GetFileNameWithoutExtension(file);

  527.                             if (File.Exists(path + key + ".bmp"))

  528.                             {

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

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

  531.                                 allData.AddRange(temp);

  532.                             }

  533.                             else

  534.                             {

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

  536.                                 if (name_array.Length > 6)

  537.                                     name_array[5] = "C0";

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

  539.                                 if (File.Exists(path + file_name + ".bmp"))

  540.                                 {

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

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

  543.                                     allData.AddRange(temp);

  544.                                 }

  545.                             }

  546.                         }

  547.                     }

  548.                 }

  549.                 //--缺陷 --比对

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

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

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

  553.                 if (Directory.Exists(path))

  554.                 {

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

  556.                     if (files.Length > 0)

  557.                     {

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

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

  560.                         foreach (string file in files)

  561.                         {

  562.                             key = Path.GetFileNameWithoutExtension(file);

  563.                             if (File.Exists(path + key + ".bmp"))

  564.                             {

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

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

  567.                                 allDataTxt.AddRange(temp);

  568.                             }

  569.                             else

  570.                             {

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

  572.                                 if (name_array.Length > 6)

  573.                                     name_array[5] = "C0";

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

  575.                                 if (File.Exists(path + file_name + ".bmp"))

  576.                                 {

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

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

  579.                                     allDataTxt.AddRange(temp);

  580.                                 }

  581.                             }

  582.                         }

  583.                     }

  584.                 }

  585. 

  586.                 //--比对 

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

  588.                 JObject data2 = new JObject();

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

  590.                 if (Directory.Exists(path))

  591.                 {

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

  593.                     if (files.Length > 0)

  594.                     {

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

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

  597.                         foreach (string file in files)

  598.                         {

  599.                             key = Path.GetFileNameWithoutExtension(file);

  600.                             if (File.Exists(path + key + ".bmp"))

  601.                             {

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

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

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

  605.                                 allData2.AddRange(temp);

  606.                             }

  607.                         }

  608.                     }

  609.                 }

  610. 

  611.                 ////--比对2 

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

  613.                 if (Directory.Exists(path))

  614.                 {

  615.                     //DefectSize_SN

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

  617.                     if (files.Length > 0)

  618.                     {

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

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

  621.                         foreach (string file in files)

  622.                         {

  623.                             key = Path.GetFileNameWithoutExtension(file);

  624.                             if (File.Exists(path + key + ".bmp"))

  625.                             {

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

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

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

  629.                                 allData2.AddRange(temp);

  630.                             }

  631.                         }

  632.                     }

  633.                 }

  634.                 Yolo_Class yolo = new Yolo_Class();

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

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

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

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

  639. 

  640. #if OpenSizeDefectComp

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

  642. 

  643.                 foreach (var kv in data)

  644.                 {

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

  646.                 }

  647.                 foreach (var kv in data2)

  648.                 {

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

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

  651. 

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

  653.                     foreach (var i in temp)

  654.                     {

  655.                         foreach (var j in defectInfor2RestorationDesk)

  656.                         {

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

  658.                                 dlist.Add(i);

  659.                         }

  660. 

  661.                     }

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

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

  664.                 }

  665. #endif

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

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

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

  669.                 else

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

  671. 

  672. 

  673.             }

  674.             catch (Exception ex)

  675.             {

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

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

  678.             }

  679.             return res; 

  680.         }

  681.         private JObject getDefectBmpBase64(JObject req)

  682.         {

  683.             JObject res = new JObject();

  684.             try

  685.             {

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

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

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

  689. 

  690.                 string file_path;

  691.                 //--缺陷

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

  693.                 {

  694.                     file_path = $"{Defect_Compress_SavePath}\\{date}\\{sn}\\{file_name}.bmp";

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

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

  697.                     {

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

  699.                         {

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

  701.                             if (name_array.Length > 6)

  702.                                 name_array[5] = "C0";

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

  704.                         }

  705.                     }

  706.                     file_path = $"{Defect_Compress_SavePath}\\{date}\\{sn}\\{file_name}.bmp";

  707. 

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

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

  710. 

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

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

  713.                 }

  714.                 //--比对 

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

  716.                 {

  717.                     file_path = $"{SizeBmp_Zoom_Image_SavePath}\\{date}\\{sn}\\{file_name}.bmp";

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

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

  720. 

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

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

  723.                 }

  724.                 else

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

  726.             }

  727.             catch (Exception ex)

  728.             {

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

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

  731.             }

  732.             return res;

  733.         }

  734. 

  735.         private JObject GetChart_Qualified_Rate(JObject req)

  736.         {

  737.             JObject res = new JObject();

  738.             try

  739.             { 

  740.                 var list = svcOrder.GetReport_Qualified_Total(); 

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

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

  743.             }

  744.             catch (Exception ex)

  745.             {

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

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

  748.             }

  749.             return res;

  750.         } 

  751.         private JObject GetReport_Defects_Date(JObject req)

  752.         {

  753.             JObject res = new JObject();

  754.             try

  755.             {

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

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

  758. 

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

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

  761. 

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

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

  764. 

  765.                 //创建表达式   

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

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

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

  769.             }

  770.             catch (Exception ex)

  771.             {

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

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

  774.             }

  775.             return res;

  776.         }

  777.         private JObject GetReport_Defects_Total(JObject req)

  778.         {

  779.             JObject res = new JObject();

  780.             try

  781.             {

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

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

  784. 

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

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

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

  788.             }

  789.             catch (Exception ex)

  790.             {

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

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

  793.             }

  794.             return res;

  795.         }

  796.         private JObject GetChart_Qualified_Date(JObject req)

  797.         {

  798.             JObject res = new JObject();

  799.             try

  800.             {

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

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

  803.                  

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

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

  806. 

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

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

  809. 

  810.                 //创建表达式  

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

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

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

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

  815.             }

  816.             catch (Exception ex)

  817.             {

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

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

  820.             }

  821.             return res;

  822.         }

  823.     }

  824. }