CPL
/
banboshi_V2
1
0
Форкнуть 0
Код Задачи 0 Pull Request'ы 0 Релизы 1 Вики Активность
版博士V2.0程序
Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.
62 коммитов
5 Ветки
6.2 GiB
 
 
 
 
Дерево: c8213ffcf8
Ветки Теги
${ item.name }
Создать ветку ${ searchTerm }
из 'c8213ffcf8'
${ noResults }
banboshi_V2/halftoneproject-master/BanBoShi/WebServer/WebService.cs

678 строки
34 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. 

  17. namespace ProductionControl

  18. {

  19.     public class WebService

  20.     {

  21.         private HttpListener svcHttpListener;

  22.         public Action<WarningEnum, string> LogEvent;

  23.         /// <summary>

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

  25.         /// </summary>

  26.         public string Defect_Compress_SavePath {  get; set; }

  27.         /// <summary>

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

  29.         /// </summary>

  30.         public string SizeBmp_Zoom_Image_SavePath { get; set; }

  31. 

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

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

  34.         {

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

  36.         }

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

  38.         {

  39.             try

  40.             {

  41.                 if (HttpPort > 0)

  42.                 {

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

  44.                     this.svcHttpListener = new HttpListener();

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

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

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

  48.                     //{

  49.                     //    lstIp.Clear();

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

  51.                     //}

  52.                     //lstIp.Clear();

  53.                     if (lstIp.Count < 1)

  54.                     {

  55.                         lstIp.Add(HttpIP);

  56.                         lstIp.Add("127.0.0.1");

  57.                     }

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

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

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

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

  62.                     this.svcHttpListener.Start();

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

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

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

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

  67.                 }

  68.                 //------WEB Socket

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

  70.                 //{

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

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

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

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

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

  76.                 //} 

  77.             }

  78.             catch (Exception ex)

  79.             {

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

  81.             }

  82.         }

  83.         public void stop()

  84.         {

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

  86.             try

  87.             {

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

  89.                 {

  90.                     this.svcHttpListener.Stop();

  91.                     this.svcHttpListener.Close();

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

  93.                 }

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

  95.                 //{

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

  97.                 //    this.svcWebSocket = null;

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

  99.                 //} 

  100.             }

  101.             catch (Exception ex)

  102.             {

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

  104.             }

  105.         }

  106.          

  107.         //

  108.         private void GetContextCallBack(IAsyncResult ar)

  109.         {

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

  111.             HttpListenerContext httpListenerContext;

  112.             try

  113.             {

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

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

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

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

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

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

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

  121. 

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

  123.             }

  124.             catch (Exception ex)

  125.             {

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

  127.                 return;

  128.             }

  129. 

  130.             //

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

  132.             string reqHttpMethod = httpListenerContext.Request.HttpMethod;

  133.             string reqUrl = httpListenerContext.Request.RawUrl;

  134.             string reqData = "";

  135.             try

  136.             {

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

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

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

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

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

  142.                 {

  143.                     #region 

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

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

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

  147. 

  148.                    // string filePath = Config.appBasePath;

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

  150.                     foreach (var sub in subUrls)

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

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

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

  154.                     {

  155.                         httpListenerContext.Response.ContentLength64 = 0;

  156.                         httpListenerContext.Response.StatusCode = 404;

  157.                         httpListenerContext.Response.Abort();

  158.                     }

  159.                     else

  160.                     {

  161.                         httpListenerContext.Response.StatusCode = 200;

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

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

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

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

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

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

  168.                         fileStream.Close();

  169.                         fileStream.Dispose();

  170.                         httpListenerContext.Response.ContentLength64 = byteLength;

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

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

  173.                     }

  174.                     #endregion

  175.                     return;

  176.                 }

  177. 

  178.                 if (reqData == null)

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

  180.                 httpListenerContext.Response.StatusCode = 200;

  181. 

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

  183.                 string respText;

  184.                 JObject result = new JObject();

  185.                 string sourceSessionId;

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

  187.                 {

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

  189.                         break;

  190.                     case "test":

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

  192.                         break;

  193.                     case "api":

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

  195.                         {

  196.                             case "query_table":

  197.                                 #region 

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

  199.                                 //    goto case "http_error";

  200.                                  

  201.                                 result = getTableList(joReqData);

  202.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  206.                                 #endregion

  207.                                 break;

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

  209.                                 #region 

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

  211.                                 //    goto case "http_error";

  212.                                  

  213.                                 result = updateTableList(joReqData);

  214.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  218.                                 #endregion

  219.                                 break;

  220.                             case "delete_table":

  221.                                 #region 

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

  223.                                 //    goto case "http_error";

  224.                                  

  225.                                 result = delTableList(joReqData);

  226.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  230.                                 #endregion

  231.                                 break;

  232.                             case "getreport_qualified":

  233.                                 #region 

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

  235.                                 //    goto case "http_error";

  236.                                  

  237.                                 result = getReport_Qualified(joReqData);

  238.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  242.                                 #endregion

  243.                                 break;  

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

  245.                                 #region 

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

  247.                                 //    goto case "http_error";

  248. 

  249.                                 result = GetChart_Qualified_Rate(joReqData);

  250.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  254.                                 #endregion

  255.                                 break;

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

  257.                                 #region 

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

  259.                                 //    goto case "http_error";

  260. 

  261.                                 result = GetChart_Qualified_Date(joReqData);

  262.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  266.                                 #endregion

  267.                                 break;

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

  269.                                 #region 

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

  271.                                 //    goto case "http_error";

  272. 

  273.                                 result = GetReport_Defects_Date(joReqData);

  274.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  278.                                 #endregion

  279.                                 break;

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

  281.                                 #region 

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

  283.                                 //    goto case "http_error";

  284. 

  285.                                 result = GetReport_Defects_Total(joReqData);

  286.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  290.                                 #endregion

  291.                                 break;

  292.                             //修复台

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

  294.                                 #region 

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

  296.                                 //    goto case "http_error"; 

  297. 

  298.                                 result = getDefectFromSN(joReqData);

  299.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  303.                                 #endregion

  304.                                 break;

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

  306.                                 #region 

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

  308.                                 //    goto case "http_error"; 

  309. 

  310.                                 result = getDefectBmpBase64(joReqData);

  311.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  315.                                 #endregion 

  316.                                 break;

  317.                             default:

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

  319.                                 break;

  320.                         }

  321.                         break; 

  322.                     case "http_error":

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

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

  325.                         respText = JsonConvert.SerializeObject(result);

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

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

  328.                         {

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

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

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

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

  333.                         }

  334.                         break;

  335.                     case "url_error":

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

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

  338.                         respText = JsonConvert.SerializeObject(result);

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

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

  341.                         {

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

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

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

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

  346.                         }

  347.                         break;

  348.                     case "param_error":

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

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

  351.                         respText = JsonConvert.SerializeObject(result);

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

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

  354.                         {

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

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

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

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

  359.                         }

  360.                         break;

  361.                     default:

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

  363.                         break;

  364.                 }

  365.             }

  366.             catch (Exception ex)

  367.             {

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

  369.                 httpListenerContext.Response.StatusCode = 500;

  370.             }

  371.             finally

  372.             {

  373.                 try

  374.                 { 

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

  376.                 }

  377.                 catch { }

  378.             }

  379.         }

  380. 

  381.         //----

  382.         private JObject getTableList(JObject req)

  383.         {

  384.             JObject res = new JObject();

  385.             try

  386.             {

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

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

  389. 

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

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

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

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

  394. 

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

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

  397. 

  398.                 //创建表达式

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

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

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

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

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

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

  405. 

  406. 

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

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

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

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

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

  412.             }

  413.             catch (Exception ex)

  414.             {

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

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

  417.             }

  418.             return res;

  419.         }

  420.         private JObject delTableList(JObject req)

  421.         {

  422.             JObject res = new JObject();

  423.             try

  424.             {

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

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

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

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

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

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

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

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

  433.             }

  434.             catch (Exception ex)

  435.             {

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

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

  438.             }

  439.             return res;

  440.         }

  441.         private JObject updateTableList(JObject req)

  442.         {

  443.             JObject res = new JObject();

  444.             try

  445.             {

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

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

  448.                 string[] updateColumns = null;

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

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

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

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

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

  454.             }

  455.             catch (Exception ex)

  456.             {

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

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

  459.             }

  460.             return res;

  461.         }

  462.         private JObject getReport_Qualified(JObject req)

  463.         {

  464.             JObject res = new JObject();

  465.             try

  466.             {

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

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

  469.                  

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

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

  472. 

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

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

  475.                  

  476.                 //创建表达式 

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

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

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

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

  481.             }

  482.             catch (Exception ex)

  483.             {

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

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

  486.             }

  487.             return res;

  488.         }     

  489.        

  490.         /// <summary>

  491.         ///  获取缺陷数据

  492.         /// </summary>

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

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

  495.         private JObject getDefectFromSN(JObject req)

  496.         {

  497.             JObject res = new JObject();

  498.             try

  499.             {

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

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

  502. 

  503.                 JObject data = new JObject();

  504.                 string path, key;

  505.                 string[] files;

  506. 

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

  508.                 //--缺陷

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

  510.                 if (Directory.Exists(path))

  511.                 { 

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

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

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

  515.                     foreach (string file in files)

  516.                     {

  517.                         key = Path.GetFileNameWithoutExtension(file);

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

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

  520.                     }

  521.                 }

  522.                 //--比对 

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

  524.                 if (Directory.Exists(path))

  525.                 {

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

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

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

  529.                     foreach (string file in files)

  530.                     {

  531.                         key = Path.GetFileNameWithoutExtension(file);

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

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

  534.                     }

  535.                 }

  536. 

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

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

  539.             }

  540.             catch (Exception ex)

  541.             {

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

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

  544.             }

  545.             return res; 

  546.         }

  547.         private JObject getDefectBmpBase64(JObject req)

  548.         {

  549.             JObject res = new JObject();

  550.             try

  551.             {

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

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

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

  555. 

  556.                 string file_path;

  557.                 //--缺陷

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

  559.                 {

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

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

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

  563. 

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

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

  566.                 }

  567.                 //--比对 

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

  569.                 {

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

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

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

  573. 

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

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

  576.                 }

  577.                 else

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

  579.             }

  580.             catch (Exception ex)

  581.             {

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

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

  584.             }

  585.             return res;

  586.         }

  587. 

  588.         private JObject GetChart_Qualified_Rate(JObject req)

  589.         {

  590.             JObject res = new JObject();

  591.             try

  592.             { 

  593.                 var list = svcOrder.GetReport_Qualified_Total(); 

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

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

  596.             }

  597.             catch (Exception ex)

  598.             {

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

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

  601.             }

  602.             return res;

  603.         } 

  604.         private JObject GetReport_Defects_Date(JObject req)

  605.         {

  606.             JObject res = new JObject();

  607.             try

  608.             {

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

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

  611. 

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

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

  614. 

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

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

  617. 

  618.                 //创建表达式   

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

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

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

  622.             }

  623.             catch (Exception ex)

  624.             {

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

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

  627.             }

  628.             return res;

  629.         }

  630.         private JObject GetReport_Defects_Total(JObject req)

  631.         {

  632.             JObject res = new JObject();

  633.             try

  634.             {

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

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

  637. 

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

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

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

  641.             }

  642.             catch (Exception ex)

  643.             {

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

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

  646.             }

  647.             return res;

  648.         }

  649.         private JObject GetChart_Qualified_Date(JObject req)

  650.         {

  651.             JObject res = new JObject();

  652.             try

  653.             {

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

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

  656.                  

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

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

  659. 

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

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

  662. 

  663.                 //创建表达式  

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

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

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

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

  668.             }

  669.             catch (Exception ex)

  670.             {

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

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

  673.             }

  674.             return res;

  675.         }

  676.     }

  677. }