HEGII.gt.mes.plc/PLC/PLC_S/ServerModel/GoodsAuto.cs


using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;

using Curtain.DataAccess;
using Curtain.Extension.ExObjectConvert;
using Curtain.Extension.ExSystemData;
using Curtain.Framework.Json;
using Curtain.Helpers;
using Curtain.Log;
using Curtain.Net.Sockets.PLC;
using Curtain.Net.Sockets.PLC.Model;
using Curtain.Net.Sockets.PLC.Model.Siemens;
using PLC_S.Proxy;

namespace PLC_S.ServerModel
{
    /// <summary>
    /// 自动返回产品型号等信息 xuwei add 2022-01-10
    /// </summary>
    public class GoodsAuto : SocketServer<SimpleSocketServerModel>, IShowFormLog, IWindowsServer
    {
        public Dictionary<string, PLC_S_GA> PLC_FLAGS = new Dictionary<string, PLC_S_GA>();
        public const string M_NAME = "GA";
        private MES_S _mes_s = null;

        private readonly Logger logger = Logger.CreateLogger(M_NAME);
        private readonly LogInfo logger_t = new LogInfo();
        private readonly LogInfo logger_e = new LogInfo();

        private bool _S_STOP = false;

        public int Interval
        {
            get;
            set;
        }
        public string EPTS_CODE
        {
            get;
            set;
        }
        public GoodsAuto()
        {
            logger.FileExistDays = 30;
            logger.FilePrefix = "";
            logger.FileSuffix = M_NAME;
            logger.LevelOneFile = true;
            logger.FileNameWithoutDate = true;

            logger_t.SubFolderFormat = "<name>";
            logger_t.FileExistDays = 30;
            logger_t.LevelOneFile = true;

            logger_e.FileExistDays = 10;

            this.Model.FormatType = CommandFormatType.StartStopChar;

            this.ServerStarting += ServerSocket_ServerStarting;
            this.ServerStarted += ServerSocket_ServerStarted;
            this.ServerStoping += ServerSocket_ServerStoping;
            this.ServerStoped += ServerSocket_ServerStoped;

            this.ServerMessage += ServerSocket_ServerMessage;
            this.Received += ServerSocket_Received;

            _mes_s = MES_S.Get();
        }

        #region Server
        public IFormLogShow FormLogShow
        {
            get;
            set;
        }

        private void ServerSocket_ServerStarting(object sender, CancelEventArgs e)
        {
            try
            {
                _S_STOP = false;
                logger.OutputTrace($"{M_NAME}_ServerStarting");
            }
            catch { }
        }
        private void ServerSocket_ServerStarted(object sender, EventArgs e)
        {
            try
            {
                _S_STOP = false;
                logger.OutputTrace($"{M_NAME}_ServerStarted");
            }
            catch { }
        }
        private void ServerSocket_ServerStoping(object sender, CancelEventArgs e)
        {
            try
            {
                _S_STOP = false;
                logger.OutputTrace($"{M_NAME}_ServerStoping");
            }
            catch { }
        }
        private void ServerSocket_ServerStoped(object sender, EventArgs e)
        {
            try
            {
                _S_STOP = false;
                logger.OutputTrace($"{M_NAME}_ServerStoped");
            }
            catch { }
        }
        private void ServerSocket_ServerMessage(object sender, ServerMessageEventArgs e)
        {
            try
            {
                _S_STOP = false;
                string message = e.ToString();
                string cip = e?.Client?.IP;
                if (e.Type == ServerMessageType.Debug)
                {
                    Logger.Debug(message, $"{M_NAME}-T[{cip}]", logger_t);
                }
                if (e.Type == ServerMessageType.Error)
                {
                    Logger.Error(e.Exception, message, $"{M_NAME}-E[{cip}]", logger_e);
                }
                if (e.Type == ServerMessageType.Trace)
                {
                    Logger.Trace(message, $"{M_NAME}-T[{cip}]", logger_t);
                }
                if (e.Type == ServerMessageType.Warning)
                {
                    Logger.Warn(message, $"{M_NAME}-E[{cip}]", logger_e);
                }
                FormLogShow?.ShowLog("ServerMessage=" + message);
            }
            catch { }
        }
        #endregion

        /// <summary>
        /// 返回产品型号
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void ServerSocket_Received(object sender, ReceiveSession e)
        {
            PLC_S_GA plc_s = null;
            string cIP = e?.Client?.IP;
            string logKeyT = $"{M_NAME}-T[{cIP}]";
            string logKeyE = $"{M_NAME}-E[{cIP}]";

            _S_STOP = false;

            SocketClient<SiemensS7_1200Model> plc = null;
            Logger LoggerT = null;
            try
            {
                LoggerT = Logger.CreateLogger(logKeyT, logger_t);
                lock (LoggerT)
                {
                    LoggerT.BeginTracking();

                    string outputMessage = e.ToString();
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);

                    #region 【必须】判断接收数据是否为空
                    if (string.IsNullOrWhiteSpace(e.Content))
                    {
                        outputMessage = "接收数据为空";
                        Logger.Warn(outputMessage, logKeyT, logger_t);
                        Logger.Warn(outputMessage, logKeyE, logger_e);
                        FormLogShow?.ShowLog(outputMessage);
                        return;
                    }
                    #endregion

                    #region 【必须】判断接收设备代码是否为空
                    outputMessage = e.Content;
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);

                    string[] c = e.Content.Split('#');
                    string flag = null;
                    if (c.Length > 0)
                    {
                        flag = c[0];
                    }
                    string barCode = null;
                    if (c.Length > 1)
                    {
                        barCode = c[1];
                    }

                    if (string.IsNullOrWhiteSpace(flag))
                    {
                        outputMessage = $"[{e.Content}]接收设备代码为空";
                        Logger.Warn(outputMessage, logKeyT, logger_t);
                        Logger.Warn(outputMessage, logKeyE, logger_e);
                        FormLogShow?.ShowLog(outputMessage);
                        return;
                    }
                    #endregion

                    #region 【必须】读取INI配置文件
                    plc_s = GetPLC_S_GA(flag, e, logKeyE);
                    if (plc_s == null)
                    {
                        outputMessage = $"[{e.Content}]设备代码[{flag}]未找到ini配置或有错误";
                        Logger.Error(null, outputMessage, logKeyT, logger_t);
                        Logger.Error(null, outputMessage, logKeyE, logger_e);
                        FormLogShow?.ShowLog(outputMessage);
                        return;
                    }
                    #endregion

                    #region 【必须】建立PLC连接
                    if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                    {
                        outputMessage = $"[{e.Content}]PLC_Connect={JsonHelper.FromObject(plc_s)}";
                        Logger.Trace(outputMessage, logKeyT, logger_t);
                        FormLogShow?.ShowLog(outputMessage);

                        plc = new SocketClient<SiemensS7_1200Model>();
                        plc.Connect(plc_s.PLC_IP, plc_s.PLC_PORT);
                    }
                    else
                    {
                        Logger.Trace("PLC地址未设置，测试数据使用！", logKeyT, logger_t);
                    }
                    PLCResult p_r;

                    #endregion

                    #region 【必须】判断接收条码格式是否正确
                    if (string.IsNullOrWhiteSpace(barCode) ||
                        barCode == "0" ||
                        barCode.Length != 11 ||
                        barCode.StartsWith("0") ||
                        barCode.StartsWith("ERROR")
                        )
                    {
                        outputMessage = $"[{e.Content}]接收条码格式错误";
                        Logger.Warn(outputMessage, logKeyT, logger_t);
                        Logger.Warn(outputMessage, logKeyE, logger_e);
                        FormLogShow?.ShowLog(outputMessage);
                        SendCode(plc_s, e, logKeyT, logKeyE, plc, 2);
                        return;
                    }
                    #endregion

                    #region 【可选】产品型号写入
                    if (!string.IsNullOrEmpty(plc_s.PLC_GOODSCODE_CODE) && !string.IsNullOrEmpty(plc_s.PLC_GOODSCODE_CODENUM))
                    {
                        string goodsCode = GetGoodsCode(barCode, e, logKeyE);
                        if (goodsCode == null)
                        {
                            outputMessage = $"[{e.Content}]此条码[{barCode}]不存在";
                            Logger.Warn(outputMessage, logKeyT, logger_t);
                            Logger.Warn(outputMessage, logKeyE, logger_e);
                            FormLogShow?.ShowLog(outputMessage);
                            if (!string.IsNullOrEmpty(plc_s.PLC_IP)) SendCode(plc_s, e, logKeyT, logKeyE, plc, 2);
                            return;
                        }
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_GOODSCODE=[{goodsCode}]{plc_s.PLC_GOODSCODE_CODE + plc_s.PLC_GOODSCODE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc.Write<string>(plc_s.PLC_GOODSCODE_CODE, plc_s.PLC_GOODSCODE_CODENUM, goodsCode);
                            outputMessage = $"[{e.Content}]END_GOODSCODE=[{p_r}]{plc_s.PLC_GOODSCODE_CODE + plc_s.PLC_GOODSCODE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]产品型号=[{goodsCode}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }

                    }
                    #endregion

                    #region 【可选】产品型号代码写入
                    if (!string.IsNullOrEmpty(plc_s.PLC_SEATCOVER_CODE) && !string.IsNullOrEmpty(plc_s.PLC_SEATCOVER_CODENUM))
                    {
                        string intCode = GetSeatCoverCode(barCode, e, logKeyE);
                        if (intCode == null)
                        {
                            outputMessage = $"[{e.Content}]此条码[{barCode}]不存在";
                            Logger.Warn(outputMessage, logKeyT, logger_t);
                            Logger.Warn(outputMessage, logKeyE, logger_e);
                            FormLogShow?.ShowLog(outputMessage);
                            if (!string.IsNullOrEmpty(plc_s.PLC_IP)) SendCode(plc_s, e, logKeyT, logKeyE, plc, 2);
                            return;
                        }
                        if (string.IsNullOrWhiteSpace(intCode))
                        {
                            outputMessage = $"[{e.Content}]此条码[{barCode}]未设置型号代码";
                            Logger.Error(null, outputMessage, logKeyT, logger_t);
                            Logger.Error(null, outputMessage, logKeyE, logger_e);
                            FormLogShow?.ShowLog(outputMessage);
                            if (!string.IsNullOrEmpty(plc_s.PLC_IP)) SendCode(plc_s, e, logKeyT, logKeyE, plc, 2);
                            return;
                        }
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_SEATCOVER=[{intCode}]{plc_s.PLC_SEATCOVER_CODE + plc_s.PLC_SEATCOVER_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc.Write<short>(plc_s.PLC_SEATCOVER_CODE, plc_s.PLC_SEATCOVER_CODENUM, (short)(intCode.ToInt32()));
                            outputMessage = $"[{e.Content}]END_SEATCOVER=[{p_r}]{plc_s.PLC_SEATCOVER_CODE + plc_s.PLC_SEATCOVER_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]产品型号=[{intCode}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }

                    }
                    #endregion

                    #region 【可选】产品类型写入
                    if (!string.IsNullOrEmpty(plc_s.PLC_GOODSTYPE_CODE) && !string.IsNullOrEmpty(plc_s.PLC_GOODSTYPE_CODENUM))
                    {
                        Int16 goodsType = Convert.ToInt16(GetGoodsType(barCode, e, logKeyT));
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_GoodsType=[{goodsType}]{plc_s.PLC_GOODSTYPE_CODE + plc_s.PLC_GOODSTYPE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc?.Write<short>(plc_s.PLC_GOODSTYPE_CODE, plc_s.PLC_GOODSTYPE_CODENUM, goodsType);
                            outputMessage = $"[{e.Content}]END_GoodsType=[{p_r.ToString()}]{plc_s.PLC_GOODSTYPE_CODE + plc_s.PLC_GOODSTYPE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]产品类型=[{goodsType}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】产品条码写入（字符串）
                    if (!string.IsNullOrEmpty(plc_s.PLC_BARCODE_CODE) && !string.IsNullOrEmpty(plc_s.PLC_BARCODE_CODENUM))
                    {
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_BarCode=[{barCode}]{plc_s.PLC_BARCODE_CODE + plc_s.PLC_BARCODE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc.Write<string>(plc_s.PLC_BARCODE_CODE, plc_s.PLC_BARCODE_CODENUM, barCode);
                            outputMessage = $"[{e.Content}]END_BarCode=[{p_r}]{plc_s.PLC_BARCODE_CODE + plc_s.PLC_BARCODE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]产品条码=[{barCode}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】产品条码写入（长数字）
                    if (!string.IsNullOrEmpty(plc_s.PLC_BARCODENUM_CODE) && !string.IsNullOrEmpty(plc_s.PLC_BARCODENUM_CODENUM))
                    {
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_BarCodeNum=[{barCode}]{plc_s.PLC_BARCODENUM_CODE + plc_s.PLC_BARCODENUM_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc.Write<float>(plc_s.PLC_BARCODENUM_CODE, plc_s.PLC_BARCODENUM_CODENUM, Convert.ToSingle(barCode));
                            outputMessage = $"[{e.Content}]END_BarCodeNum=[{p_r}]{plc_s.PLC_BARCODENUM_CODE + plc_s.PLC_BARCODENUM_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]产品条码=[{barCode}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】半检返工标识写入
                    if (!string.IsNullOrEmpty(plc_s.PLC_SEMIREWORK_CODE) && !string.IsNullOrEmpty(plc_s.PLC_SEMIREWORK_CODENUM))
                    {
                        Int16 goodsType = Convert.ToInt16(GetSemiReWork(barCode, e, logKeyT));
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_SemiRework=[{goodsType}]{plc_s.PLC_SEMIREWORK_CODE + plc_s.PLC_SEMIREWORK_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc?.Write<short>(plc_s.PLC_SEMIREWORK_CODE, plc_s.PLC_SEMIREWORK_CODENUM, goodsType);
                            outputMessage = $"[{e.Content}]END_SemiRework=[{p_r.ToString()}]{plc_s.PLC_SEMIREWORK_CODE + plc_s.PLC_SEMIREWORK_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]半检返工标识=[{goodsType}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】产品等级写入
                    if (!string.IsNullOrEmpty(plc_s.PLC_GOODSLEVEL_CODE) && !string.IsNullOrEmpty(plc_s.PLC_GOODSLEVEL_CODENUM))
                    {
                        Int16 goodsLevel = Convert.ToInt16(GetGoodsLevel(barCode, e, logKeyT));
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_GoodsLevel=[{goodsLevel}]{plc_s.PLC_GOODSLEVEL_CODE + plc_s.PLC_GOODSLEVEL_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc?.Write<short>(plc_s.PLC_GOODSLEVEL_CODE, plc_s.PLC_GOODSLEVEL_CODENUM, goodsLevel);
                            outputMessage = $"[{e.Content}]END_GoodsLevel=[{p_r.ToString()}]{plc_s.PLC_GOODSLEVEL_CODE + plc_s.PLC_GOODSLEVEL_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]产品等级=[{goodsLevel}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】半检补土（适用于官塘）
                    if (!string.IsNullOrEmpty(plc_s.PLC_SEMIREPAIR_CODE) && !string.IsNullOrEmpty(plc_s.PLC_SEMIREPAIR_CODENUM))
                    {
                        Int16 semiRepair = Convert.ToInt16(GetSemiRepair(barCode, e, logKeyT));
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_SemiRepair=[{semiRepair}]{plc_s.PLC_SEMIREPAIR_CODE + plc_s.PLC_SEMIREPAIR_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc?.Write<short>(plc_s.PLC_SEMIREPAIR_CODE, plc_s.PLC_SEMIREPAIR_CODENUM, semiRepair);
                            outputMessage = $"[{e.Content}]END_SemiRepair=[{p_r.ToString()}]{plc_s.PLC_SEMIREPAIR_CODE + plc_s.PLC_SEMIREPAIR_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]半检补土=[{semiRepair}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】产品等级写入(重烧过的产品写6，非重烧的写4)（适用于官塘）
                    if (!string.IsNullOrEmpty(plc_s.PLC_GOODSLEVEL2_CODE) && !string.IsNullOrEmpty(plc_s.PLC_GOODSLEVEL2_CODENUM))
                    {
                        Int16 goodsLevel = Convert.ToInt16(GetGoodsLevel(barCode, e, logKeyT));

                        //如果判定为重烧不算重烧品，暂时当副品，重烧过才真正算重烧
                        if (goodsLevel == 6) goodsLevel = 5;
                        goodsLevel = Convert.ToInt16(GetAutoFireID(barCode, goodsLevel.ToString(), "6", e, logKeyT));

                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_GoodsLevel2=[{goodsLevel}]{plc_s.PLC_GOODSLEVEL2_CODE + plc_s.PLC_GOODSLEVEL2_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc?.Write<short>(plc_s.PLC_GOODSLEVEL2_CODE, plc_s.PLC_GOODSLEVEL2_CODENUM, goodsLevel);
                            outputMessage = $"[{e.Content}]END_GoodsLevel2=[{p_r.ToString()}]{plc_s.PLC_GOODSLEVEL2_CODE + plc_s.PLC_GOODSLEVEL2_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]产品等级=[{goodsLevel}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】产品重烧标识写入
                    if (!string.IsNullOrEmpty(plc_s.PLC_ISREFIRE_CODE) && !string.IsNullOrEmpty(plc_s.PLC_ISREFIRE_CODENUM))
                    {
                        Int16 isRefire = Convert.ToInt16(GetAutoFireID(barCode, "1", "6", e, logKeyT));
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_IsRefire=[{isRefire}]{plc_s.PLC_ISREFIRE_CODE + plc_s.PLC_ISREFIRE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc?.Write<short>(plc_s.PLC_ISREFIRE_CODE, plc_s.PLC_ISREFIRE_CODENUM, isRefire);
                            outputMessage = $"[{e.Content}]END_IsRefire=[{p_r.ToString()}]{plc_s.PLC_ISREFIRE_CODE + plc_s.PLC_ISREFIRE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]产品重烧=[{isRefire}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】质量登记返修写入（官塘厂）
                    if (!string.IsNullOrEmpty(plc_s.PLC_GOODSREPAIR_CODE) && !string.IsNullOrEmpty(plc_s.PLC_GOODSREPAIR_CODENUM))
                    {
                        Int16 goodsRepair = Convert.ToInt16(GetGoodsRepair(barCode, e, logKeyT));
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_GoodsLevel=[{goodsRepair}]{plc_s.PLC_GOODSREPAIR_CODE + plc_s.PLC_GOODSREPAIR_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc?.Write<short>(plc_s.PLC_GOODSREPAIR_CODE, plc_s.PLC_GOODSREPAIR_CODENUM, goodsRepair);
                            outputMessage = $"[{e.Content}]END_GoodsLevel=[{p_r.ToString()}]{plc_s.PLC_GOODSREPAIR_CODE + plc_s.PLC_GOODSREPAIR_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]返修=[{goodsRepair}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】智能连体重烧写入，智能重烧253，连体重烧254，其他返回立库配置代码，未配置返回252（官塘厂）
                    if (!string.IsNullOrEmpty(plc_s.PLC_GOODSTYPEISREFIRE_CODE) && !string.IsNullOrEmpty(plc_s.PLC_GOODSTYPEISREFIRE_CODENUM))
                    {
                        //产品代码读取
                        string intCode = GetWareHouse(barCode, e, logKeyE);
                        if (intCode == "") intCode = "252";
                        
                        //重烧识别读取
                        Int16 isRefire = Convert.ToInt16(GetAutoFireID(barCode, "1", "6", e, logKeyT));

                        //重烧产品返回 智能253，连体254
                        if (isRefire == 6)
                        {
                            //智能连体读取
                            Int16 goodsType = Convert.ToInt16(GetGoodsType(barCode, e, logKeyT));
                            if (goodsType == 1) intCode = "253";
                            if (goodsType == 2) intCode = "254";
                        }

                        //写入智能连体重烧标识
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_GOODSTYPEISREFIRE=[{intCode}]{plc_s.PLC_GOODSTYPEISREFIRE_CODE + plc_s.PLC_GOODSTYPEISREFIRE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc.Write<short>(plc_s.PLC_GOODSTYPEISREFIRE_CODE, plc_s.PLC_GOODSTYPEISREFIRE_CODENUM, (short)(intCode.ToInt32()));
                            outputMessage = $"[{e.Content}]END_GOODSTYPEISREFIRE=[{p_r}]{plc_s.PLC_GOODSTYPEISREFIRE_CODE + plc_s.PLC_GOODSTYPEISREFIRE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]智能连体重烧=[{intCode}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】产品缺陷类别写入
                    if (!string.IsNullOrEmpty(plc_s.PLC_GOODSDEFECTTYPE_CODE) && !string.IsNullOrEmpty(plc_s.PLC_GOODSDEFECTTYPE_CODENUM))
                    {
                        Int16 goodsDefectType = Convert.ToInt16(GetDefectTypeId(barCode, e, logKeyT));

                        //如果是重烧产品写入 16 代替产品缺陷类别
                        //goodsDefectType = Convert.ToInt16(GetAutoFireID(barCode, goodsDefectType.ToString(), "16", e, logKeyT));

                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            outputMessage = $"[{e.Content}]SET_DefectType=[{goodsDefectType}]{plc_s.PLC_GOODSDEFECTTYPE_CODE + plc_s.PLC_GOODSDEFECTTYPE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                            p_r = plc?.Write<short>(plc_s.PLC_GOODSDEFECTTYPE_CODE, plc_s.PLC_GOODSDEFECTTYPE_CODENUM, goodsDefectType);
                            outputMessage = $"[{e.Content}]END_DefectType=[{p_r.ToString()}]{plc_s.PLC_GOODSDEFECTTYPE_CODE + plc_s.PLC_GOODSDEFECTTYPE_CODENUM}";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]缺陷类别=[{goodsDefectType}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                    #region 【可选】工序验证
                    if (!string.IsNullOrEmpty(plc_s.PROCEDURE_CHECKID))
                    {
                        Int16 plc_flag = Convert.ToInt16(GetProcedureCheck(barCode, plc_s.PROCEDURE_CHECKID, e, logKeyT, logKeyE));
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            SendCode(plc_s, e, logKeyT, logKeyE, plc, plc_flag);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]工序=[{plc_s.PROCEDURE_CHECKID}]工序验证=[{plc_flag}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                        return;
                    }
                    #endregion

                    #region 【可选】工序计件
                    if (!string.IsNullOrEmpty(plc_s.PROCEDURE_ID) && (!string.IsNullOrEmpty(plc_s.PROCEDURE_USERCODE) || !string.IsNullOrEmpty(plc_s.WORKSTATION_ID)) )
                    {
                        //如果是重烧产品使用重烧ID
                        if (!string.IsNullOrEmpty(plc_s.PROCEDURE_AUTOREFIRE_ID))
                        {
                            plc_s.PROCEDURE_ID = GetAutoFireID(barCode, plc_s.PROCEDURE_ID, plc_s.PROCEDURE_AUTOREFIRE_ID, e, logKeyE);
                        }

                        string p_id = GetFlowId(barCode, e, logKeyE);
                        Int16 plc_flag = 0;
                        if (p_id != plc_s.PROCEDURE_ID.ToString())
                        {
                            string userCode = "";

                            //默认读取userCode
                            if(!string.IsNullOrEmpty(plc_s.PROCEDURE_USERCODE))
                            {
                                userCode = plc_s.PROCEDURE_USERCODE;
                            }

                            //优先从工位取userCode
                            if (!string.IsNullOrEmpty(plc_s.WORKSTATION_ID))
                            {
                                userCode = GetUserCodeFromWorkStation(plc_s.WORKSTATION_ID, e, logKeyE);
                                outputMessage = $"[{e.Content}]DB_UserCode=[{userCode}]";
                                Logger.Trace(outputMessage, logKeyT, logger_t);
                                FormLogShow?.ShowLog(outputMessage);
                            }

                            //工序计件
                            string result = SmartDeviceProxy.Instance.Invoke<string>(
                                p => p.AddWorkPieceByStatus3(
                                    _mes_s.AccountCode,
                                    userCode,
                                    null,
                                    Convert.ToInt32(plc_s.PROCEDURE_ID),
                                    barCode,
                                    null));

                            outputMessage = $"[{e.Content}]工序=[{plc_s.PROCEDURE_ID}]工号=[{userCode}]工序计件=[{result}]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);

                            // 返回状态（成功、失败）
                            if (result != "OK")
                            {
                                plc_flag = 3;
                                if (result == "EE")
                                {
                                    plc_flag = 4;
                                    outputMessage = $"MES服务端异常（详情参见MES端日志）";
                                }
                                else if (result == "EU-01")
                                {
                                    outputMessage = $"无效的帐套或工号（详情参见MES端日志）";
                                }
                                else
                                {
                                    outputMessage = $"其他错误（详情参见MES端日志）[{result}]";
                                }
                                Logger.Error(null, outputMessage, logKeyT, logger_t);
                                Logger.Error(null, outputMessage, logKeyE, logger_e);
                                FormLogShow?.ShowLog(outputMessage);
                                if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                                {
                                    SendCode(plc_s, e, logKeyT, logKeyE, plc, plc_flag);
                                }
                                return;
                            }
                        }
                    }
                    #endregion

                    #region 【可选】工序计件（产品等级判定为重烧的产品自动重烧交接工序计件）（官塘厂）
                    if (!string.IsNullOrEmpty(plc_s.PROCEDURE_REFIRE_RECIVE_ID) && (!string.IsNullOrEmpty(plc_s.PROCEDURE_REFIRE_RECIVE_USERCODE) ))
                    {
                        //识别是否判定为重烧的产品
                        Int16 goodsLevel = Convert.ToInt16(GetGoodsLevel(barCode, e, logKeyT));
                        if(goodsLevel == 6)
                        {
                            string p_id = GetFlowId(barCode, e, logKeyE);
                            Int16 plc_flag = 0;
                            if (p_id != plc_s.PROCEDURE_REFIRE_RECIVE_ID.ToString())
                            {
                                string userCode = "";

                                //默认读取userCode
                                if (!string.IsNullOrEmpty(plc_s.PROCEDURE_REFIRE_RECIVE_USERCODE))
                                {
                                    userCode = plc_s.PROCEDURE_REFIRE_RECIVE_USERCODE;
                                }

                                //工序计件
                                string result = SmartDeviceProxy.Instance.Invoke<string>(
                                    p => p.AddWorkPieceByStatus3(
                                        _mes_s.AccountCode,
                                        userCode,
                                        null,
                                        Convert.ToInt32(plc_s.PROCEDURE_REFIRE_RECIVE_ID),
                                        barCode,
                                        null));

                                outputMessage = $"[{e.Content}]工序=[{plc_s.PROCEDURE_REFIRE_RECIVE_ID}]工号=[{userCode}]工序计件=[{result}]";
                                Logger.Trace(outputMessage, logKeyT, logger_t);
                                FormLogShow?.ShowLog(outputMessage);

                                // 返回状态（成功、失败）
                                if (result != "OK")
                                {
                                    plc_flag = 3;
                                    if (result == "EE")
                                    {
                                        plc_flag = 4;
                                        outputMessage = $"MES服务端异常（详情参见MES端日志）";
                                    }
                                    else if (result == "EU-01")
                                    {
                                        outputMessage = $"无效的帐套或工号（详情参见MES端日志）";
                                    }
                                    else
                                    {
                                        outputMessage = $"其他错误（详情参见MES端日志）[{result}]";
                                    }
                                    Logger.Error(null, outputMessage, logKeyT, logger_t);
                                    Logger.Error(null, outputMessage, logKeyE, logger_e);
                                    FormLogShow?.ShowLog(outputMessage);
                                    if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                                    {
                                        SendCode(plc_s, e, logKeyT, logKeyE, plc, plc_flag);
                                    }
                                    return;
                                }
                            }
                        }

                    }
                    #endregion

                    #region 【可选】写入PLC扫码结果 【1：通过，2：扫码异常，3：工序异常，0：复位】
                    if (!string.IsNullOrEmpty(plc_s.PLC_FLAG_CODE) && !string.IsNullOrEmpty(plc_s.PLC_FLAG_CODENUM))
                    {
                        if (!string.IsNullOrEmpty(plc_s.PLC_IP))
                        {
                            SendCode(plc_s, e, logKeyT, logKeyE, plc, 1);
                        }
                        else
                        {
                            outputMessage = $"[{e.Content}]PLC标识=[1]";
                            Logger.Trace(outputMessage, logKeyT, logger_t);
                            FormLogShow?.ShowLog(outputMessage);
                        }
                    }
                    #endregion

                }
            }
            catch (Exception ex)
            {
                FormLogShow?.ShowLog($"[{e.Content}]ERROR={ex.Message}");
                if (plc_s != null)
                {
                    Logger.Error(ex, $"[{e.Content}]ERROR", logKeyT, logger_t);
                    Logger.Error(ex, $"[{e.Content}]ERROR", logKeyE, logger_e);
                    SendCode(plc_s, e, logKeyT, logKeyE, plc, 2);
                }
                else
                {
                    Logger.Error(ex, $"[{e.Content}]ERROR-NOFLAG", logKeyT, logger_t);
                    Logger.Error(ex, $"[{e.Content}]ERROR-NOFLAG", logKeyE, logger_e);
                }
            }
            finally
            {
                LoggerT?.EndTracking();
                plc?.Disconnect();
                plc?.Close();
            }
        }

        private void SendCode(PLC_S_GA plc_s, ReceiveSession e, string loggerNameT, string loggerNameE, SocketClient<SiemensS7_1200Model> plc, short code)
        {
            try
            {
                string outputMessage = $"[{e.Content}]SET_FLAG_CODE=[{code}]{plc_s.PLC_FLAG_CODE + plc_s.PLC_FLAG_CODENUM}";
                Logger.Trace(outputMessage, loggerNameT, logger_t);
                FormLogShow?.ShowLog(outputMessage);
                PLCResult p_r = plc?.Write<short>(plc_s.PLC_FLAG_CODE, plc_s.PLC_FLAG_CODENUM, (short)code);
                outputMessage = $"[{e.Content}]SET_FLAG_CODE=[{p_r}]{plc_s.PLC_FLAG_CODE + plc_s.PLC_FLAG_CODENUM}";
                Logger.Trace(outputMessage, loggerNameT, logger_t);
                FormLogShow?.ShowLog(outputMessage);
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-SendCode", loggerNameT, logger_t);
                Logger.Error(ex, $"[{e.Content}]ERROR-SendCode", loggerNameE, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-SendCode={ex.Message}");
            }
        }

        private string GetGoodsCode(string barCode, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess(e))
                {
                    string sqlStr = @"
                        SELECT
	                        GDD.GOODSCODE
                        FROM
	                        TP_PM_GROUTINGDAILYDETAIL GDD
                        WHERE
	                        GDD.BARCODE = :BARCODE
                    ";
                    object result = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode));
                    return result == null ? "" : result.ToString();
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetGoodsCode", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetGoodsCode={ex.Message}");
                return null;
            }
        }

        private string GetSeatCoverCode(string barCode, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess(e))
                {
                    string sqlStr = @"
                        SELECT
	                        G.SEATCOVERCODE 
                        FROM
	                        TP_PM_GROUTINGDAILYDETAIL GDD
	                        INNER JOIN TP_MST_GOODS G ON G.GOODSID = GDD.GOODSID 
                        WHERE
	                        GDD.BARCODE = :BARCODE
                    ";
                    object result = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode));
                    return result == null ? "" : result.ToString();
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetSeatCoverCode", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetSeatCoverCode={ex.Message}");
                return null;
            }
        }

        private string GetGoodsType(string barCode, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess(e))
                {
                    string sqlStr = @"
                        SELECT
	                        -- G.GOODSCODE,
	                        -- G.SEATCOVERCODE,
	                        CASE 
                                WHEN T.GOODSTYPECODE = '001001001' THEN 2 --连体
							    WHEN T.GOODSTYPECODE = '001001002' THEN 3 --分体
							    WHEN T.GOODSTYPECODE = '001001003' THEN 1 --智能
							    WHEN T.GOODSTYPECODE = '001001004' THEN 1 --智能高压
							    ELSE 0 --其他
						    END AS GOODSTYPE
                        FROM
	                        TP_PM_GROUTINGDAILYDETAIL GDD
	                        INNER JOIN TP_MST_GOODS G ON G.GOODSID = GDD.GOODSID 
	                        INNER JOIN TP_MST_GOODSTYPE T ON G.GOODSTYPEID = T.GOODSTYPEID
                        WHERE
	                        GDD.BARCODE = :BARCODE --'10006800247'
                        ";
                    string goodsType = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode)).ToString();
                    return goodsType;
                }

            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetGoodsType", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetGoodsType={ex.Message}");
                return "0";
            }
        }

        private string GetFlowId(string barCode, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess())
                {
                    string sqlStr = @"
                        SELECT
	                        GDD.FLOWPROCEDUREID
                        FROM
	                        TP_PM_INPRODUCTION GDD
                        WHERE
	                        GDD.BARCODE = :BARCODE
                    ";
                    object result = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode));
                    return result == null ? "0" : result.ToString();
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetFlowId", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetFlowId={ex.Message}");
                return "0";
            }
        }

        private string GetAutoFireID(string barCode, string procedureId, string autoFireId, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess(e))
                {
                    string sqlStr = @"
                        SELECT T.ISREFIRE
                        FROM   TP_PM_INPRODUCTION T
                        WHERE  T.BARCODE = :BARCODE
                        UNION
                        SELECT T.ISREFIRE
                        FROM   TP_PM_INPRODUCTIONTRASH T
                        WHERE  T.BARCODE = :BARCODE
                        ";
                    string result = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode)).ToString();
                    if (result == "6")
                        return autoFireId;
                    else
                        return procedureId;
                }

            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetAutoFireID", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetAutoFireID={ex.Message}");
                return "0";
            }
        }

        private string GetUserCodeFromWorkStation(string workStationId, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess())
                {
                    string sqlStr = @"
                        SELECT
	                        T.USERCODE
                        FROM
	                        TP_MST_WORKSTATION T
	                        INNER JOIN TP_MST_USER U ON U.USERCODE = T.USERCODE 
                        WHERE
	                        T.WORKSTATIONID = :WORKSTATIONID
                    ";
                    object result = conn.ExecuteScalar(sqlStr, new CDAParameter(":WORKSTATIONID", workStationId));
                    return result == null ? "0" : result.ToString();
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetUserCodeFromWorkStation", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetUserCodeFromWorkStation={ex.Message}");
                return "0";
            }

        }
        
        private string GetSemiReWork(string barCode, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess())
                {
                    string sqlStr = @"
                        SELECT
	                        P.ISREWORKFLAG 
                        FROM
	                        TP_PM_INPRODUCTION P
                        WHERE
	                        P.BARCODE = :BARCODE
                    ";
                    object result = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode));
                    //返工标识(0：正常，1：半检返工中， 2：半检返修)
                    //没找到记录表明产品报废写 3
                    string resultFlag = "0";
                    if(result !=null)
                    {
                        if (result.ToString() == "0") resultFlag = "1"; //正常
                        if (result.ToString() == "1" || result.ToString() == "2") resultFlag = "2";//返工
                    }
                    else
                    {
                        resultFlag = "3";//报废
                    }
                    return resultFlag;
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetSemiReWork", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetSemiReWork={ex.Message}");
                return "0";
            }

        }

        private string GetGoodsLevel(string barCode, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess())
                {
                    string sqlStr = @"
                          SELECT GL.GOODSLEVELTYPEID
                          FROM   TP_PM_GROUTINGDAILYDETAIL GDD
                          LEFT   JOIN TP_MST_GOODSLEVEL GL
                          ON     GDD.GOODSLEVELTYPEID = GL.GOODSLEVELTYPEID
                          WHERE  GDD.BARCODE = :BARCODE
                    ";
                    object result = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode));
                    return result == null ? "0" : result.ToString();
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetGoodsLevel", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetGoodsLevel={ex.Message}");
                return "0";
            }

        }

        private string GetGoodsRepair(string barCode, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess())
                {
                    string sqlStr = @"
                        SELECT
	                        DECODE( GR.REPAIRPATH, NULL, GDD.GOODSLEVELTYPEID, 0, GDD.GOODSLEVELTYPEID, GR.REPAIRPATH ) 
                        FROM
	                        TP_PM_GROUTINGDAILYDETAIL GDD
	                        LEFT JOIN TP_PM_GOODSREPAIR GR ON GDD.BARCODE = GR.BARCODE 
	                        AND GR.VALUEFLAG = 1 
                        WHERE
                            GDD.VALUEFLAG = 1
	                        AND GDD.BARCODE = @BARCODE@
                    ";
                    object result = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode));
                    return result == null ? "0" : result.ToString();
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetGoodsRepair", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetGoodsRepair={ex.Message}");
                return "0";
            }

        }

        private string GetProcedureCheck(string barCode,string procedureId, ReceiveSession e, string loggerNameT, string loggerNameE)
        {
            try
            {
                using (IDataAccess dataAccess = PLC_S_DataAccess.GetDataAccess())
                {
                    CDAParameter[] parameters = new CDAParameter[]
                    {
                            new CDAParameter("in_procedureid", procedureId),
                            new CDAParameter("in_barcode", barCode),
                            new CDAParameter("out_errType",DataType.Int32, ParameterDirection.Output),
                            new CDAParameter("out_errMsg",DataType.VarChar, 4000, ParameterDirection.Output),
                            new CDAParameter("out_goodsID",DataType.Int32, ParameterDirection.Output),
                            new CDAParameter("out_goodsCode",DataType.VarChar, 400, ParameterDirection.Output),
                            new CDAParameter("out_goodsType",DataType.Int32, ParameterDirection.Output),
                    };
                    
                    int ii = dataAccess.ExecuteSPNonQuery("PRO_PM_CheckBarcode_PLC", parameters);

                    Int16 plc_flag = 0;
                    if (!int.TryParse(parameters[2].Value + "", out int errtype))
                    {
                        errtype = 4;
                    }
                    // 其他情况显示MES异常
                    if (errtype == 4)
                    {
                        plc_flag = 4;
                    }
                    else if (errtype == 0)
                    {
                        plc_flag = 1;
                    }
                    else // errtype == 1 || errtype == 2 || errtype == 3
                    {
                        // 无效条码，显示不可到达
                        plc_flag = 3;
                    }
                    string outputMessage = $"[{e.Content}]MESSAGE=[{errtype}][{parameters[3].Value}]";
                    Logger.Trace(outputMessage, loggerNameT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    return plc_flag.ToString();
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetProcedureCheck", loggerNameE, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetProcedureCheck={ex.Message}");
                return "0";
            }
        }

        private string GetDefectTypeId(string barCode, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess())
                {
                    string sqlStr = @"
                        SELECT D.DEFECTCODE, D.DEFECTNAME, DT.DEFECTTYPENAME, DT.DEFECTTYPEID, DT.REMARKS
                        FROM   TP_PM_DEFECT PD
                        LEFT   JOIN TP_MST_DEFECT D
                        ON     PD.DEFECTID = D.DEFECTID
                        LEFT   JOIN TP_MST_DEFECTTYPE DT
                        ON     D.DEFECTTYPEID = DT.DEFECTTYPEID
                        WHERE  D.VALUEFLAG = 1
                               AND BARCODE = :BARCODE
                        ORDER  BY D.CREATETIME DESC
                    ";
                    DataTable dt = conn.ExecuteDatatable(sqlStr, new CDAParameter(":BARCODE", barCode));
                    if (dt.Rows.Count > 0)
                    {
                        return dt.Rows[0]["REMARKS"].ToString();
                    }
                    else
                    {
                        return "0";
                    }
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetDefectTypeId", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetDefectTypeId={ex.Message}");
                return "0";
            }

        }

        private string GetSemiRepair(string barCode,ReceiveSession e,string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess())
                {
                    string sqlStr = @"
                          SELECT GL.GOODSLEVELTYPEID
                          FROM   TP_PM_GROUTINGDAILYDETAIL GDD
                          LEFT   JOIN TP_MST_GOODSLEVEL GL
                          ON     GDD.GOODSLEVELTYPEID = GL.GOODSLEVELTYPEID
                          WHERE  GDD.BARCODE = :BARCODE
                    ";
                    object goodsLevel = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode));

                    sqlStr = @"
                        SELECT
	                        99 
                        FROM
	                        TP_PM_INPRODUCTION 
                        WHERE
	                        BARCODE = :BARCODE
	                        AND PROCEDUREID = 64 --完成的最后一个工序是1#二检补土时直接return 99（作为二检补土识别）
                    ";
                    object semiRepair = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode));

                    if (semiRepair != null)
                    {
                        return semiRepair.ToString();
                    }
                    else
                    {
                        return goodsLevel.ToString();
                    }
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetSemiReWork", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetSemiReWork={ex.Message}");
                return "0";
            }
        }

        private string GetWareHouse(string barCode, ReceiveSession e, string loggerName)
        {
            try
            {
                using (IDataAccess conn = PLC_S_DataAccess.GetDataAccess(e))
                {
                    string sqlStr = @"
                        SELECT
	                        PART 
                        FROM
	                        (
	                        SELECT
		                        T.PART,',' 
                                || LISTAGG ( T.GOODSID1, ',' ) WITHIN GROUP ( ORDER BY T.PART ) || ',' 
                                || LISTAGG ( T.GOODSID2, ',' ) WITHIN GROUP ( ORDER BY T.PART ) || ',' 
                                || LISTAGG ( T.GOODSID3, ',' ) WITHIN GROUP ( ORDER BY T.PART ) || ',' 
                                || LISTAGG ( T.GOODSID4, ',' ) WITHIN GROUP ( ORDER BY T.PART ) || ',' 
                                || LISTAGG ( T.GOODSID5, ',' ) WITHIN GROUP ( ORDER BY T.PART ) || ',' 
                                || LISTAGG ( T.GOODSID6, ',' ) WITHIN GROUP ( ORDER BY T.PART ) || ',' 
                                || LISTAGG ( T.GOODSID7, ',' ) WITHIN GROUP ( ORDER BY T.PART ) || ',' 
                                || LISTAGG ( T.GOODSID8, ',' ) WITHIN GROUP ( ORDER BY T.PART ) || ',' 
                                || LISTAGG ( T.GOODSID9, ',' ) WITHIN GROUP ( ORDER BY T.PART ) || ',' 
                                || LISTAGG ( T.GOODSID10, ',' ) WITHIN GROUP ( ORDER BY T.PART ) || ',' AS SQLSTR 
	                        FROM
		                        (
		                        SELECT
			                        m.SETTINGNO AS part,
			                        M.GOODSID1,
			                        M.GOODSID2,
			                        M.GOODSID3,
			                        M.GOODSID4,
			                        M.GOODSID5,
			                        M.GOODSID6,
			                        M.GOODSID7,
			                        M.GOODSID8,
			                        M.GOODSID9,
			                        M.GOODSID10 
		                        FROM
			                        TP_MST_WAREHOUSESETTING M 
		                        ) T 
	                        GROUP BY
		                        T.PART 
	                        ) TT 
                        WHERE
	                        INSTR( TT.SQLSTR, ',' || ( SELECT GOODSID FROM TP_PM_GROUTINGDAILYDETAIL WHERE BARCODE = :BARCODE) || ',' ) > 0
                        ";
                    string wareHouse = conn.ExecuteScalar(sqlStr, new CDAParameter(":BARCODE", barCode)).ToString();
                    return wareHouse;
                }

            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetWareHouse", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetWareHouse={ex.Message}");
                return "0";
            }
        }


        private PLC_S_GA GetPLC_S_GA(string flag, ReceiveSession e, string loggerName)
        {
            try
            {
                flag = M_NAME + flag;
                if (PLC_FLAGS.ContainsKey(flag))
                {
                    return PLC_FLAGS[flag];
                }
                else
                {
                    PLC_S_GA plc_s = new PLC_S_GA();
                    INIHelper ini = INIHelper.Create($@"PLC_S_INI\PLC_S_{M_NAME}.ini");

                    plc_s.PLC_IP = ini.Read(flag, "PLC_IP");
                    plc_s.PLC_PORT = ini.Read(flag, "PLC_PORT").ToInt32();

                    plc_s.PLC_FLAG_CODE = ini.Read(flag, "PLC_FLAG_CODE");
                    plc_s.PLC_FLAG_CODENUM = ini.Read(flag, "PLC_FLAG_CODENUM");

                    plc_s.PLC_SEATCOVER_CODE = ini.Read(flag, "PLC_SEATCOVER_CODE");
                    plc_s.PLC_SEATCOVER_CODENUM = ini.Read(flag, "PLC_SEATCOVER_CODENUM");

                    plc_s.PLC_BARCODE_CODE = ini.Read(flag, "PLC_BARCODE_CODE");
                    plc_s.PLC_BARCODE_CODENUM = ini.Read(flag, "PLC_BARCODE_CODENUM");

                    plc_s.PLC_BARCODENUM_CODE = ini.Read(flag, "PLC_BARCODENUM_CODE");
                    plc_s.PLC_BARCODENUM_CODENUM = ini.Read(flag, "PLC_BARCODENUM_CODENUM");

                    plc_s.PLC_GOODSCODE_CODE = ini.Read(flag, "PLC_GOODSCODE_CODE");
                    plc_s.PLC_GOODSCODE_CODENUM = ini.Read(flag, "PLC_GOODSCODE_CODENUM");

                    plc_s.PLC_GOODSTYPE_CODE = ini.Read(flag, "PLC_GOODSTYPE_CODE");
                    plc_s.PLC_GOODSTYPE_CODENUM = ini.Read(flag, "PLC_GOODSTYPE_CODENUM");

                    plc_s.PLC_SEMIREWORK_CODE = ini.Read(flag, "PLC_SEMIREWORK_CODE");
                    plc_s.PLC_SEMIREWORK_CODENUM = ini.Read(flag, "PLC_SEMIREWORK_CODENUM");

                    plc_s.PLC_SEMIREPAIR_CODE = ini.Read(flag, "PLC_SEMIREPAIR_CODE");
                    plc_s.PLC_SEMIREPAIR_CODENUM = ini.Read(flag, "PLC_SEMIREPAIR_CODENUM");

                    plc_s.PLC_GOODSLEVEL_CODE = ini.Read(flag, "PLC_GOODSLEVEL_CODE");
                    plc_s.PLC_GOODSLEVEL_CODENUM = ini.Read(flag, "PLC_GOODSLEVEL_CODENUM");

                    plc_s.PLC_GOODSLEVEL2_CODE = ini.Read(flag, "PLC_GOODSLEVEL2_CODE");
                    plc_s.PLC_GOODSLEVEL2_CODENUM = ini.Read(flag, "PLC_GOODSLEVEL2_CODENUM");

                    plc_s.PLC_ISREFIRE_CODE = ini.Read(flag, "PLC_ISREFIRE_CODE");
                    plc_s.PLC_ISREFIRE_CODENUM = ini.Read(flag, "PLC_ISREFIRE_CODENUM");

                    plc_s.PLC_GOODSTYPEISREFIRE_CODE = ini.Read(flag, "PLC_GOODSTYPEISREFIRE_CODE");
                    plc_s.PLC_GOODSTYPEISREFIRE_CODENUM = ini.Read(flag, "PLC_GOODSTYPEISREFIRE_CODENUM");

                    plc_s.PLC_GOODSREPAIR_CODE = ini.Read(flag, "PLC_GOODSREPAIR_CODE");
                    plc_s.PLC_GOODSREPAIR_CODENUM = ini.Read(flag, "PLC_GOODSREPAIR_CODENUM");

                    plc_s.PLC_GOODSDEFECTTYPE_CODE = ini.Read(flag, "PLC_GOODSDEFECTTYPE_CODE");
                    plc_s.PLC_GOODSDEFECTTYPE_CODENUM = ini.Read(flag, "PLC_GOODSDEFECTTYPE_CODENUM");

                    plc_s.PROCEDURE_ID = ini.Read(flag, "PROCEDURE_ID");
                    plc_s.PROCEDURE_USERCODE = ini.Read(flag, "PROCEDURE_USERCODE");

                    plc_s.PROCEDURE_REFIRE_RECIVE_ID = ini.Read(flag, "PROCEDURE_REFIRE_RECIVE_ID");
                    plc_s.PROCEDURE_REFIRE_RECIVE_USERCODE = ini.Read(flag, "PROCEDURE_REFIRE_RECIVE_USERCODE");

                    plc_s.WORKSTATION_ID = ini.Read(flag, "WORKSTATION_ID");
                    plc_s.WORKSTATION_NAME = ini.Read(flag, "WORKSTATION_NAME");

                    PLC_FLAGS.Add(flag, plc_s);
                    return plc_s;
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetPLC_S_GA", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetPLC_S_GA={ex.Message}");
                return null;
            }
        }
    }
}