这脚本写得真帅，记录一下；很少这么佩服自己

using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Ports;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using UNI.MES.Core;
using UNI.MES.Services;

namespace UNI_IPC_MES.modules
{
/// <summary>
/// 气密检查流程
/// </summary>
public class AirtightnessWorkFlow : ModuleBaseFlow
{
//线程池，负责存取已扫条码到出库记录
private CoreThreadPool pool = new CoreThreadPool();
//检测通过的数据
private Queue<AirtghtnessResult> scanQueue = new Queue<AirtghtnessResult>();

private Regex codeRegex = new Regex(@"^C\d{8}$");
protected IModuleFlowFormService FlowFormService { get; private set; }
/// <summary>
/// Com端口的集合
/// </summary>
protected Dictionary<string, object> ComPorts = new Dictionary<string, object>();
/// <summary>
/// 缓存区集合，每个串口使用自己的缓冲区
/// </summary>
protected Dictionary<string, List<byte>> revBuffer = new Dictionary<string, List<byte>>();
public AirtightnessWorkFlow(IModuleFlowFormService fromService)
{
FlowFormService = fromService;
}

/// <summary>
/// 扫码条码处理
/// </summary>
/// <param name="data"></param>
public override void OnExecScanReceiving(string data)
{
var temp = data.Split("|".ToCharArray());
string flag = temp.LastOrDefault();
data = temp.FirstOrDefault();
if (data.IndexOf("NR") != -1)
{
string msg = string.Format("{0}道读取条码错误，NOREAD！", flag);
RaiseException(this, msg, new object[] { data });
}
if (codeRegex.IsMatch(data))
{
RaiseInfo(this, string.Format("{0}道读取到条码[{1}]。", flag, data));
using (var db = new MESDb())
{
string cmd = string.Format("select line from hkwsAll with(nolock) where code3='{0}'", data);
string lineNo = db.Database.SqlQuery<string>(cmd).FirstOrDefault();
if (!lineNo.Equals(flowContext.LineNo))
{
string msg = string.Format("{0}道校验条码错误，条码{1}上一站测试未通过,或者非本线产品！", flag, data);
RaiseException(this, msg, new object[] { data });
}
}
if (flag.Equals("A"))
{
flowContext.L1Code = data;
}
if (flag.Equals("B"))
{
flowContext.L2Code = data;
}
RaiseCustomEvent("StartNewTest", "", flag, data);
}
else
{
string msg = string.Format("{0}道读取条码错误，编码规则错误！条码：{1}", flag, data);
RaiseException(this, msg, new object[] { data });
}
}
/// <summary>
/// 脚本初始化
/// </summary>
protected override void BeforeWorkInit()
{
ComPorts.Clear();
revBuffer.Clear();
string path = AppDomain.CurrentDomain.BaseDirectory + "portname.txt";
using (var sr = new StreamReader(path, false))
{
string str = "";
while ((str = sr.ReadLine()) != null)
{
#region 读取每一行
if (str.IndexOf("线体=") != -1)    //找到txt中通道1的各行
{
string[] mm = Regex.Split(str, "=", RegexOptions.IgnoreCase);   //通过txt中_分隔符取出文件名信息，和超时信息
flowContext.LineNo = mm[1];
}
else if (str.IndexOf("上层条码a=") != -1)    //找到txt中通道1的各行
{
string[] mm = Regex.Split(str, "=", RegexOptions.IgnoreCase);   //通过txt中_分隔符取出文件名信息，和超时信息
ComPorts.Add("COM_Up_A", new SerialPort()
{
PortName = mm[1],
BaudRate = 9600,
DataBits = 8,
StopBits = StopBits.One,
//ParityReplace = 63,
ReadBufferSize = 4096,
WriteBufferSize = 2048
});
}
else if (str.IndexOf("上层条码b=") != -1)    //找到txt中通道1的各行
{
string[] mm = Regex.Split(str, "=", RegexOptions.IgnoreCase);   //通过txt中_分隔符取出文件名信息，和超时信息
ComPorts.Add("COM_Up_B", new SerialPort()
{
PortName = mm[1],
BaudRate = 9600,
DataBits = 8,
StopBits = StopBits.One,
//ParityReplace = 63,
ReadBufferSize = 4096,
WriteBufferSize = 2048
});
}
else if (str.IndexOf("下层条码a=") != -1)    //找到txt中通道1的各行
{
string[] mm = Regex.Split(str, "=", RegexOptions.IgnoreCase);   //通过txt中_分隔符取出文件名信息，和超时信息
ComPorts.Add("COM_Down_A", new SerialPort()
{
PortName = mm[1],
BaudRate = 9600,
DataBits = 8,
StopBits = StopBits.One,
//ParityReplace = 63,
ReadBufferSize = 4096,
WriteBufferSize = 2048
});
}
else if (str.IndexOf("下层条码b=") != -1)    //找到txt中通道1的各行
{
string[] mm = Regex.Split(str, "=", RegexOptions.IgnoreCase);   //通过txt中_分隔符取出文件名信息，和超时信息
ComPorts.Add("COM_Down_B", new SerialPort()
{
PortName = mm[1],
BaudRate = 9600,
DataBits = 8,
StopBits = StopBits.One,
//ParityReplace = 63,
ReadBufferSize = 4096,
WriteBufferSize = 2048
});
}
#endregion
}
sr.Close();
}
#region 启动参数检测
if (string.IsNullOrEmpty(flowContext.WorkStation))
{
RaiseException(this, "请联系管理员设置工位或者线号！");
}
if (string.IsNullOrEmpty(flowContext.Operator))
{
RaiseException(this, "请点击'切换员工'进行身份验证！");
}
#endregion
#region 打开全部COM口
foreach (var com in ComPorts)
{
var sp = com.Value as SerialPort;
try
{
sp.Open();
sp.DataReceived += Sp_DataReceived;
revBuffer.Add(com.Key, new List<byte>(4096));
}
catch (Exception ex)
{
RaiseException(this, ex.Message);
}
}
#endregion
pool.Exceute += Pool_Exceute;
pool.Start();
flowContext.L1CountEx = 0;
RaiseInfo(this, "程序初始化完成，准备就绪请开始作业！");
}
/// <summary>
/// 接收数据逻辑,是扫描枪的调用OnExecScanReceiving,是PLC的消息调用OnExecDataReceived
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void Sp_DataReceived(object sender, SerialDataReceivedEventArgs e)
{
var sp = sender as SerialPort;
var dict = ComPorts.SingleOrDefault(port => port.Value == sp);
if (sp.BytesToRead == 0)
{
revBuffer[dict.Key].Clear();
return;
}
byte[] buffer = new byte[sp.BytesToRead];
int numofbyte = sp.Read(buffer, 0, buffer.Length);
if (numofbyte > 0)
{
revBuffer[dict.Key].AddRange(buffer);
}
string revMessage = Encoding.UTF8.GetString(revBuffer[dict.Key].ToArray()).Trim();
if (dict.Key.IndexOf("Up") != -1 && revMessage.Length > 8)
{
string[] temp = revMessage.Split(Environment.NewLine.ToCharArray(), StringSplitOptions.RemoveEmptyEntries);
string message = temp.FirstOrDefault().Length > 9 ? temp.FirstOrDefault().Substring(0, 9) : temp.FirstOrDefault();
FrameAppContext.GetInstance().AppLogger.Info(string.Format("收到扫描枪数据：[{0}]", message));
OnExecScanReceiving(message + "|" + dict.Key.Split("_".ToCharArray()).LastOrDefault());
revBuffer[dict.Key].Clear();
}
if (dict.Key.IndexOf("Down") != -1 && revMessage.Contains("OK"))
{
FrameAppContext.GetInstance().AppLogger.Info(string.Format("收到PLC数据：[{0}]", revMessage));
OnExecDataReceived(revMessage + "|" + dict.Key.Split("_".ToCharArray()).LastOrDefault());
revBuffer[dict.Key].Clear();
}
//try
//{
//    if (sp.BytesToRead == 0)
//    {
//        revBuffer.Clear();
//        return;
//    }
//    byte[] buffer = new byte[sp.BytesToRead];
//    int numofbyte = sp.Read(buffer, 0, buffer.Length);
//    if (numofbyte > 0)
//    {
//        revBuffer.AddRange(buffer);
//    }
//    string line = Encoding.UTF8.GetString(revBuffer.ToArray()).Trim();
//    if (line.Length > 8)
//    {
//        FrameAppContext.GetInstance().AppLogger.Info(string.Format("收到数据：[{0}]", line));
//    }
//    回车换行符是结束标志
//    if (revBuffer)
//    {
//        var dict = ComPorts.SingleOrDefault(port => port.Value == sp);
//        if (dict.Key.IndexOf("Up") != -1)
//        {
//            if (line.Length < 11)
//                return;
//            string message = line.Substring(0, line.IndexOf(Environment.NewLine));
//            FrameAppContext.GetInstance().AppLogger.Info(string.Format("收到扫描枪数据：[{0}]", message));
//            OnExecScanReceiving(message + "|" + dict.Key.Split("_".ToCharArray()).LastOrDefault());
//        }
//        if (dict.Key.IndexOf("Down") != -1)
//        {
//            string message = line.Substring(0, line.IndexOf(Environment.NewLine));
//            FrameAppContext.GetInstance().AppLogger.Info(string.Format("收到PLC数据：[{0}]", message));
//            OnExecDataReceived(message + "|" + dict.Key.Split("_".ToCharArray()).LastOrDefault());
//        }
//    }
//}
//catch (Exception ex)
//{
//    FrameAppContext.GetInstance().AppLogger.Error(ex);
//}
}
/// <summary>
/// 执行数据库操作
/// </summary>
/// <param name="obj"></param>
private void Pool_Exceute(object obj)
{
if (obj is AirtghtnessResult && scanQueue.Contains(obj))
{
AirtghtnessResult result = scanQueue.Peek();
using (var db = new MESDb())
{
try
{
string cmd = string.Format(@"update hkwsAll set code4='{0}',name4='{1}',time4='{2}',fth=1,Res='成功' where code3='{3}'",
result.Barcode, result.Oper, result.ResultTime, result.Barcode);
db.Database.ExecuteSqlCommand(cmd);
}
finally
{
scanQueue.Dequeue();
}
}
}
System.Threading.Thread.Sleep(100);
}
/// <summary>
/// 接收到PLC返回的数据
/// </summary>
/// <param name="data"></param>
protected void OnExecDataReceived(string data)
{
var temp = data.Split("|".ToCharArray());
string flag = temp.LastOrDefault();
data = temp.FirstOrDefault();
string barcode = string.Empty;
if (flag.Equals("A"))
barcode = flowContext.L1Code;
if (flag.Equals("B"))
barcode = flowContext.L2Code;
data.Replace("|" + flag, "");
#region 获取检测结果
byte[] buffer = Encoding.UTF8.GetBytes(data);
int mol = 0;
for (int i = 0; i < buffer.Length; i++)
{
if (buffer[i] == 0x6c)
{
mol = i;
}
}
byte[] xlv = new byte[9];
xlv[0] = buffer[mol - 10];
xlv[1] = buffer[mol - 9];
xlv[2] = buffer[mol - 8];
xlv[3] = buffer[mol - 7];
xlv[4] = buffer[mol - 6];
xlv[5] = buffer[mol - 5];
xlv[6] = buffer[mol - 4];
xlv[7] = buffer[mol - 3];
xlv[8] = buffer[mol - 2];
if (flag.Equals("A"))
flowContext.Parameter1 = Encoding.UTF8.GetString(xlv);
if (flag.Equals("B"))
flowContext.Parameter2 = Encoding.UTF8.GetString(xlv);
#endregion
AirtghtnessResult result = new AirtghtnessResult()
{
Barcode = barcode,
LineNo = flowContext.LineNo,
Oper = flowContext.Operator,
ResultTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
};
data.Replace("NOK","NG");
//测试不通过
if (data.Contains("NG"))
{
if (flag.Equals("A"))
flowContext.L1Code = string.Empty;
if (flag.Equals("B"))
flowContext.L2Code = string.Empty;
RaiseCustomEvent("DataReceived", flag, "NG", string.Join("|", new string[] { barcode, data }));
}
else if (data.Contains("OK"))
{
scanQueue.Enqueue(result);
pool.Post(result);
RaiseCustomEvent("DataReceived", flag, "OK", string.Join("|", new string[] { barcode, data }));
//计数加1
flowContext.L1CountEx++;
}
else
{
if (flag.Equals("A"))
flowContext.L1Code = string.Empty;
if (flag.Equals("B"))
flowContext.L2Code = string.Empty;
RaiseCustomEvent("DataReceived", flag, "NG", string.Join("|", new string[] { barcode, data }));
}
}
/// <summary>
/// 停止作业时的检查
/// </summary>
protected override void StopWorkCheck()
{
if (scanQueue.Count > 0)
{
var list = scanQueue.ToArray();
if (list != null)
{
foreach (var dict in list)
{
pool.Post(dict);
}
}
RaiseException(this, string.Format("还有已经检测的条码没有保存到数据库，请重试！"));
}
}
/// <summary>
/// 结束作业
/// </summary>
public override void ExecEndWork()
{
pool.Stop();
foreach (var sp in ComPorts)
{
var com = sp.Value as SerialPort;
com.Close();
}
ComPorts.Clear();
base.ExecEndWork();
}
/// <summary>
/// 异常提醒方法
/// </summary>
/// <param name="sender"></param>
/// <param name="message"></param>
/// <param name="args"></param>
protected override void RaiseException(object sender, string message, params object[] args)
{
OnFeedInfo(sender, new Exception(message), message, MessageTipsLevel.Error);
FlowFormService.ShowErrorAlertNotityForm(1000, 1888, message);
}
}
}

虽然解决了别人老程序崩溃引起产线停线的事情，但是领导并没有高看我。哎！老程序是个菜鸟写的，他反反复复改了好几版还是像个DEMO。以前正常用了好久，刚开始产线工人还说我这个麻烦些。