CPL
/
banboshi_V2
1
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 1 Wiki 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.
61 Commits
5 Branches
6.2 GiB
 
 
 
 
Branch: TongWei
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'TongWei'
${ noResults }
banboshi_V2/halftoneproject-master/Code/WebService.cs

667 lines
32 KiB
Raw Permalink Blame History 

  1. using Models;

  2. using Newtonsoft.Json;

  3. using Newtonsoft.Json.Linq;

  4. using ProductionControl.Utils;

  5. using SqlSugar;

  6. using System;

  7. using System.Collections.Generic;

  8. using System.IO;

  9. using System.Linq;

  10. using System.Net;

  11. using System.Text;

  12. using System.Text.RegularExpressions;

  13. using System.Threading.Tasks;

  14. 

  15. namespace ProductionControl

  16. {

  17.     public class WebService

  18.     {

  19.         private HttpListener svcHttpListener;

  20.         public Action<WarningEnum, string> LogEvent;

  21. 

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

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

  24.         {

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

  26.         }

  27.         public void start()

  28.         {

  29.             try

  30.             {

  31.                 if (Config.LocalHttpPort > 0)

  32.                 {

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

  34.                     this.svcHttpListener = new HttpListener();

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

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

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

  38.                     //{

  39.                     //    lstIp.Clear();

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

  41.                     //}

  42.                     //lstIp.Clear();

  43.                     if (lstIp.Count < 1)

  44.                     {

  45.                         lstIp.Add(Config.LocalIp);

  46.                         lstIp.Add("127.0.0.1");

  47.                     }

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

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

  50.                         this.svcHttpListener.Prefixes.Add("http://" + lstIp[i] + ":" + Config.LocalHttpPort.ToString() + "/");

  51.                 

  52.                     this.svcHttpListener.Start();

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

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

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

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

  57.                 }

  58.                 //------WEB Socket

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

  60.                 //{

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

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

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

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

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

  66.                 //} 

  67.             }

  68.             catch (Exception ex)

  69.             {

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

  71.             }

  72.         }

  73.         public void stop()

  74.         {

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

  76.             try

  77.             {

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

  79.                 {

  80.                     this.svcHttpListener.Stop();

  81.                     this.svcHttpListener.Close();

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

  83.                 }

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

  85.                 //{

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

  87.                 //    this.svcWebSocket = null;

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

  89.                 //} 

  90.             }

  91.             catch (Exception ex)

  92.             {

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

  94.             }

  95.         }

  96.          

  97.         //

  98.         private void GetContextCallBack(IAsyncResult ar)

  99.         {

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

  101.             HttpListenerContext httpListenerContext;

  102.             try

  103.             {

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

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

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

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

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

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

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

  111. 

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

  113.             }

  114.             catch (Exception ex)

  115.             {

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

  117.                 return;

  118.             }

  119. 

  120.             //

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

  122.             string reqHttpMethod = httpListenerContext.Request.HttpMethod;

  123.             string reqUrl = httpListenerContext.Request.RawUrl;

  124.             string reqData = "";

  125.             try

  126.             {

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

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

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

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

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

  132.                 {

  133.                     #region 

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

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

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

  137. 

  138.                     string filePath = Config.appBasePath;

  139.                     foreach (var sub in subUrls)

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

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

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

  143.                     {

  144.                         httpListenerContext.Response.ContentLength64 = 0;

  145.                         httpListenerContext.Response.StatusCode = 404;

  146.                         httpListenerContext.Response.Abort();

  147.                     }

  148.                     else

  149.                     {

  150.                         httpListenerContext.Response.StatusCode = 200;

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

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

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

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

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

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

  157.                         fileStream.Close();

  158.                         fileStream.Dispose();

  159.                         httpListenerContext.Response.ContentLength64 = byteLength;

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

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

  162.                     }

  163.                     #endregion

  164.                     return;

  165.                 }

  166. 

  167.                 if (reqData == null)

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

  169.                 httpListenerContext.Response.StatusCode = 200;

  170. 

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

  172.                 string respText;

  173.                 JObject result = new JObject();

  174.                 string sourceSessionId;

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

  176.                 {

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

  178.                         break;

  179.                     case "test":

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

  181.                         break;

  182.                     case "api":

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

  184.                         {

  185.                             case "query_table":

  186.                                 #region 

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

  188.                                 //    goto case "http_error";

  189.                                  

  190.                                 result = getTableList(joReqData);

  191.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  195.                                 #endregion

  196.                                 break;

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

  198.                                 #region 

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

  200.                                 //    goto case "http_error";

  201.                                  

  202.                                 result = updateTableList(joReqData);

  203.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  207.                                 #endregion

  208.                                 break;

  209.                             case "delete_table":

  210.                                 #region 

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

  212.                                 //    goto case "http_error";

  213.                                  

  214.                                 result = delTableList(joReqData);

  215.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  219.                                 #endregion

  220.                                 break;

  221.                             case "getreport_qualified":

  222.                                 #region 

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

  224.                                 //    goto case "http_error";

  225.                                  

  226.                                 result = getReport_Qualified(joReqData);

  227.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  231.                                 #endregion

  232.                                 break;  

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

  234.                                 #region 

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

  236.                                 //    goto case "http_error";

  237. 

  238.                                 result = GetChart_Qualified_Rate(joReqData);

  239.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  243.                                 #endregion

  244.                                 break;

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

  246.                                 #region 

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

  248.                                 //    goto case "http_error";

  249. 

  250.                                 result = GetChart_Qualified_Date(joReqData);

  251.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  255.                                 #endregion

  256.                                 break;

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

  258.                                 #region 

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

  260.                                 //    goto case "http_error";

  261. 

  262.                                 result = GetReport_Defects_Date(joReqData);

  263.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  267.                                 #endregion

  268.                                 break;

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

  270.                                 #region 

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

  272.                                 //    goto case "http_error";

  273. 

  274.                                 result = GetReport_Defects_Total(joReqData);

  275.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  279.                                 #endregion

  280.                                 break;

  281.                             //修复台

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

  283.                                 #region 

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

  285.                                 //    goto case "http_error"; 

  286. 

  287.                                 result = getDefectFromSN(joReqData);

  288.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  292.                                 #endregion

  293.                                 break;

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

  295.                                 #region 

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

  297.                                 //    goto case "http_error"; 

  298. 

  299.                                 result = getDefectBmpBase64(joReqData);

  300.                                 respText = JsonConvert.SerializeObject(result);

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

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

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

  304.                                 #endregion 

  305.                                 break;

  306.                             default:

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

  308.                                 break;

  309.                         }

  310.                         break; 

  311.                     case "http_error":

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

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

  314.                         respText = JsonConvert.SerializeObject(result);

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

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

  317.                         {

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

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

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

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

  322.                         }

  323.                         break;

  324.                     case "url_error":

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

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

  327.                         respText = JsonConvert.SerializeObject(result);

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

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

  330.                         {

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

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

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

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

  335.                         }

  336.                         break;

  337.                     case "param_error":

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

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

  340.                         respText = JsonConvert.SerializeObject(result);

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

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

  343.                         {

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

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

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

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

  348.                         }

  349.                         break;

  350.                     default:

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

  352.                         break;

  353.                 }

  354.             }

  355.             catch (Exception ex)

  356.             {

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

  358.                 httpListenerContext.Response.StatusCode = 500;

  359.             }

  360.             finally

  361.             {

  362.                 try

  363.                 { 

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

  365.                 }

  366.                 catch { }

  367.             }

  368.         }

  369. 

  370.         //----

  371.         private JObject getTableList(JObject req)

  372.         {

  373.             JObject res = new JObject();

  374.             try

  375.             {

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

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

  378. 

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

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

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

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

  383. 

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

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

  386. 

  387.                 //创建表达式

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

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

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

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

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

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

  394. 

  395. 

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

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

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

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

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

  401.             }

  402.             catch (Exception ex)

  403.             {

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

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

  406.             }

  407.             return res;

  408.         }

  409.         private JObject delTableList(JObject req)

  410.         {

  411.             JObject res = new JObject();

  412.             try

  413.             {

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

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

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

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

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

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

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

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

  422.             }

  423.             catch (Exception ex)

  424.             {

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

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

  427.             }

  428.             return res;

  429.         }

  430.         private JObject updateTableList(JObject req)

  431.         {

  432.             JObject res = new JObject();

  433.             try

  434.             {

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

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

  437.                 string[] updateColumns = null;

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

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

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

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

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

  443.             }

  444.             catch (Exception ex)

  445.             {

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

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

  448.             }

  449.             return res;

  450.         }

  451.         private JObject getReport_Qualified(JObject req)

  452.         {

  453.             JObject res = new JObject();

  454.             try

  455.             {

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

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

  458.                  

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

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

  461. 

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

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

  464.                  

  465.                 //创建表达式 

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

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

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

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

  470.             }

  471.             catch (Exception ex)

  472.             {

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

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

  475.             }

  476.             return res;

  477.         }     

  478.        

  479.         /// <summary>

  480.         ///  获取缺陷数据

  481.         /// </summary>

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

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

  484.         private JObject getDefectFromSN(JObject req)

  485.         {

  486.             JObject res = new JObject();

  487.             try

  488.             {

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

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

  491. 

  492.                 JObject data = new JObject();

  493.                 string path, key;

  494.                 string[] files;

  495. 

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

  497.                 //--缺陷

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

  499.                 if (Directory.Exists(path))

  500.                 { 

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

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

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

  504.                     foreach (string file in files)

  505.                     {

  506.                         key = Path.GetFileNameWithoutExtension(file);

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

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

  509.                     }

  510.                 }

  511.                 //--比对 

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

  513.                 if (Directory.Exists(path))

  514.                 {

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

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

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

  518.                     foreach (string file in files)

  519.                     {

  520.                         key = Path.GetFileNameWithoutExtension(file);

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

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

  523.                     }

  524.                 }

  525. 

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

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

  528.             }

  529.             catch (Exception ex)

  530.             {

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

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

  533.             }

  534.             return res; 

  535.         }

  536.         private JObject getDefectBmpBase64(JObject req)

  537.         {

  538.             JObject res = new JObject();

  539.             try

  540.             {

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

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

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

  544. 

  545.                 string file_path;

  546.                 //--缺陷

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

  548.                 {

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

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

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

  552. 

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

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

  555.                 }

  556.                 //--比对 

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

  558.                 {

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

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

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

  562. 

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

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

  565.                 }

  566.                 else

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

  568.             }

  569.             catch (Exception ex)

  570.             {

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

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

  573.             }

  574.             return res;

  575.         }

  576. 

  577.         private JObject GetChart_Qualified_Rate(JObject req)

  578.         {

  579.             JObject res = new JObject();

  580.             try

  581.             { 

  582.                 var list = svcOrder.GetReport_Qualified_Total(); 

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

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

  585.             }

  586.             catch (Exception ex)

  587.             {

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

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

  590.             }

  591.             return res;

  592.         } 

  593.         private JObject GetReport_Defects_Date(JObject req)

  594.         {

  595.             JObject res = new JObject();

  596.             try

  597.             {

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

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

  600. 

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

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

  603. 

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

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

  606. 

  607.                 //创建表达式   

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

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

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

  611.             }

  612.             catch (Exception ex)

  613.             {

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

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

  616.             }

  617.             return res;

  618.         }

  619.         private JObject GetReport_Defects_Total(JObject req)

  620.         {

  621.             JObject res = new JObject();

  622.             try

  623.             {

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

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

  626. 

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

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

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

  630.             }

  631.             catch (Exception ex)

  632.             {

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

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

  635.             }

  636.             return res;

  637.         }

  638.         private JObject GetChart_Qualified_Date(JObject req)

  639.         {

  640.             JObject res = new JObject();

  641.             try

  642.             {

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

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

  645.                  

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

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

  648. 

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

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

  651. 

  652.                 //创建表达式  

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

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

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

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

  657.             }

  658.             catch (Exception ex)

  659.             {

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

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

  662.             }

  663.             return res;

  664.         }

  665.     }

  666. }