HEGII.ss.mes.plc/HG5000.3/PLC_S/ServerModel/GoodsLevel_QR2.cs


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

using Curtain.DataAccess;
using Curtain.Extension.ExCompareOperator;
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>
    /// 返回扫码结果（0：复位 1：通过 2：扫码异常 3：工序异常 4：防伪码读取错误 5：防伪码验证错误）等信息（3#刮登对接乾润）
    /// </summary>
    public class GoodsLevel_QR2 : SocketServer<SimpleSocketServerModel>, IShowFormLog, IWindowsServer
    {
        public Dictionary<string, PLC_S_GL_QR> PLC_FLAGS = new Dictionary<string, PLC_S_GL_QR>();
        public const string M_NAME = "GL_QR";
        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 GoodsLevel_QR2()
        {
            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

        int int_code = 0;
        /// <summary>
        /// 返回产品型号
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void ServerSocket_Received(object sender, ReceiveSession e)
        {
            PLC_S_GL_QR 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);

                    if (string.IsNullOrWhiteSpace(e.Content))
                    {
                        outputMessage = "接收数据为空";
                        Logger.Warn(outputMessage, logKeyT, logger_t);
                        Logger.Warn(outputMessage, logKeyE, logger_e);
                        FormLogShow?.ShowLog(outputMessage);

                        SendCode(plc_s, e, logKeyT, logKeyE, plc, 2);
                        return;
                    }

                    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);
                        SendCode(plc_s, e, logKeyT, logKeyE, plc, 2);
                        return;
                    }

                    //int ws_id = 0;
                    //if (flag == "0")
                    //{
                    //    // 3#刮登
                    //    ws_id = 74;
                    //}

                    plc_s = GetPLC_S_GC(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);
                        SendCode(plc_s, e, logKeyT, logKeyE, plc, 2);
                        return;
                    }

                    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.IP, plc_s.Port);

                    if (string.IsNullOrWhiteSpace(barcode) ||
                        barcode == "0" ||
                        barcode.Length != 11 ||
                        barcode.StartsWith("0"))
                    {
                        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;
                    }

                    string usercode = "";
                    string p_id = "";
                    string goodstypecode = "";
                    //string se_flag = null;
                    //string se_flag_code = null;
                    using (IDataAccess dataAccess = PLC_S_DataAccess.GetDataAccess())
                    {
                        string sqlString = "select gdd.GOODSLEVELTYPEID,g.goodstypeid, inp.flowprocedureid,gt.goodstypecode\n" +
                        "  from tp_pm_groutingdailydetail gdd\n" +
                        "  LEFT JOIN tp_pm_inproduction inp on inp.groutingdailydetailid = gdd.groutingdailydetailid\n" +
                        "  inner join tp_mst_goods g on g.goodsid = gdd.goodsid\n" +
                        " inner join tp_mst_goodsType gt on g.goodstypeid = gt.goodstypeid\n" +
                        " where gdd.barcode = :barcode";
                        DataTable dataTable = dataAccess.ExecuteDatatable(sqlString, new CDAParameter(":barcode", barcode));
                        DataRow codeRow = null;
                        if (dataTable.HasData())
                        {
                            codeRow = dataTable.Rows[0];
                        }
                        if (codeRow == null)
                        {
                            outputMessage = $"[{e.Content}]此条码[{barcode}]不存在";
                            Logger.Warn(outputMessage, logKeyT, logger_t);
                            Logger.Warn(outputMessage, logKeyE, logger_e);
                            FormLogShow?.ShowLog(outputMessage);

                            SendCode(plc_s, e, logKeyT, logKeyE, plc, 2);
                            return;
                        }

                        p_id = codeRow["flowprocedureid"].ToString();
                        goodstypecode = codeRow["goodstypecode"].ToString();

                        #region 刮边工号 从工位配置中读取
                        sqlString = @"
                            SELECT t.usercode, u.userid
                              FROM tp_mst_workstation t
                              inner join tp_mst_user u on u.usercode = t.usercode
                             WHERE t.workstationtypeid = 3201
                               AND t.workstationid = @workstationid@
                            ";
                        CDAParameter[] ps = new CDAParameter[]
                        {
                        new CDAParameter("workstationid", plc_s.WS_ID),
                        };

                        int userid = 0;
                        dataTable = dataAccess.ExecuteDatatable(sqlString, ps);
                        if (dataTable.HasData())
                        {
                            usercode = dataTable.Rows[0]["usercode"].ToString();
                            userid = dataTable.Rows[0]["userid"].ToInt32();
                        }
                        outputMessage = $"[{e.Content}]DB_UserCode=[{usercode}]";
                        Logger.Trace(outputMessage, logKeyT, logger_t);
                        FormLogShow?.ShowLog(outputMessage);
                        #endregion 
                        // 是否启用防伪码 S_PM_031 这个是验证的
                        //se_flag = "," + dataAccess.ExecuteScalar("select t.settingvalue from tp_mst_systemsetting t where t.settingcode = 'S_PM_031'") + ",";
                        //se_flag_code = dataAccess.ExecuteScalar("select t.settingvalue from tp_mst_systemsetting t where t.settingcode = 'S_PM_032'") + "";
                    }

                    #region 防伪码处理过程 xuwei add 2021-12-30

                    //【防伪码】1寄存条码到PLC，用于防伪码绑定读取===================================
                    outputMessage = $"[{e.Content}]SET_SE_BarCode=[{barcode}]{plc_s.Add_SE_BarCode + plc_s.Add_SE_BarCodeNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    PLCResult p_r = plc?.Write<string>(plc_s.Add_SE_BarCode, plc_s.Add_SE_BarCodeNum, barcode);
                    outputMessage = $"[{e.Content}]END_SE_BarCode=[{p_r.ToString()}]{plc_s.Add_SE_BarCode + plc_s.Add_SE_BarCodeNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    //===============================================================================

                    //【防伪码】2寄存产品类型到PLC，用于设置控制智能扫码头还是连体扫码头去扫码=======
                    Int16 goodsType = Convert.ToInt16(GetGoodsType(barcode, e, logKeyT));

                    outputMessage = $"[{e.Content}]SET_SE_Type=[{goodsType}]{plc_s.Add_SE_Type + plc_s.Add_SE_TypeNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    p_r = plc?.Write<short>(plc_s.Add_SE_Type, plc_s.Add_SE_TypeNum, goodsType);
                    outputMessage = $"[{e.Content}]END_SE_Type=[{p_r.ToString()}]{plc_s.Add_SE_Type + plc_s.Add_SE_TypeNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    //===============================================================================

                    //【防伪码】3写产品是否验证防伪码标识到PLC，以确定是否继续扫描防伪码还是放行=====
                    string resultFlag = SmartDeviceProxy.Instance.Invoke<string>(
                    p => p.GetStatusByBarcode(
                        _mes_s.AccountCode,
                        usercode,
                        barcode,
                        plc_s.P_ID + ""
                        ));
                    if (resultFlag.IndexOf("OK") != 0)
                    {
                        if (resultFlag == "EX")
                        {
                            outputMessage = $"MES服务端异常（详情参见MES端日志）";
                        }
                        else if (resultFlag == "EU-01")
                        {
                            outputMessage = $"无效的帐套或工号（详情参见MES端日志）";
                        }
                        else
                        {
                            outputMessage = $"其他错误（详情参见MES端日志）[{resultFlag}]";
                        }
                        Logger.Error(null, outputMessage, logKeyT, logger_t);
                        Logger.Error(null, outputMessage, logKeyE, logger_e);
                        FormLogShow?.ShowLog(outputMessage);
                        SendCode(plc_s, e, logKeyT, logKeyE, plc, 2);
                        return;
                    }
                    //Logger.Trace(resultFlag+"_"+resultFlag.Substring(3), logKeyT, logger_t);
                    Int16 goodsFlag = Convert.ToInt16(resultFlag.Substring(3));

                    outputMessage = $"[{e.Content}]SET_SE_Flag=[{goodsFlag}]{plc_s.Add_SE_Flag + plc_s.Add_SE_FlagNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    p_r = plc?.Write<short>(plc_s.Add_SE_Flag, plc_s.Add_SE_FlagNum, goodsFlag);
                    outputMessage = $"[{e.Content}]END_SE_Flag=[{p_r.ToString()}]{plc_s.Add_SE_Flag + plc_s.Add_SE_FlagNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    //===============================================================================

                    #endregion

                    #region 防伪码 取消原方法
                    /*
                    if (!string.IsNullOrWhiteSpace(plc_s.Add_SE_Code1) &&
                        se_flag.Contains($",{plc_s.P_ID},") &&
                        goodstypecode.StartsWith(se_flag_code)
                        )
                    {
                        // 读取防伪码
                        //outputMessage = $"[{e.Content}]GET_SE_Code1=[ ]{plc_s.Add_SE_Code1 + plc_s.Add_SE_Code1Num}";
                        //Logger.Trace(outputMessage, logKeyT, logger_t);
                        //FormLogShow?.ShowLog(outputMessage);
                        PLCResult<string> se1_result = plc.Read<string>(plc_s.Add_SE_Code1, plc_s.Add_SE_Code1Num, 12);
                        outputMessage = $"[{e.Content}]END_SE_Code1=[{se1_result.Data}]{se1_result}";
                        Logger.Trace(outputMessage, logKeyT, logger_t);
                        FormLogShow?.ShowLog(outputMessage);

                        ////outputMessage = $"[{e.Content}]GET_SE_Code2=[ ]{plc_s.Add_SE_Code2 + plc_s.Add_SE_Code2Num}";
                        ////Logger.Trace(outputMessage, logKeyT, logger_t);
                        ////FormLogShow?.ShowLog(outputMessage);
                        //PLCResult<string> se2_result = plc.Read<string>(plc_s.Add_SE_Code2, plc_s.Add_SE_Code2Num, 12);
                        //outputMessage = $"[{e.Content}]END_SE_Code2=[{se2_result.Data}]{plc_s.Add_SE_Code2 + plc_s.Add_SE_Code2Num}";
                        //Logger.Trace(outputMessage, logKeyT, logger_t);
                        //FormLogShow?.ShowLog(outputMessage);

                        string se_code = "";
                        if (!string.IsNullOrWhiteSpace(se1_result.Data) &&
                            !se1_result.Data.StartsWith("0") &&
                            !se1_result.Data.StartsWith("ERROR")
                            )
                        {
                            se_code = se1_result.Data;
                        }
                        //else if (!string.IsNullOrWhiteSpace(se2_result.Data) && !se2_result.Data.StartsWith("0"))
                        //{
                        //    se_code = se2_result.Data;
                        //}
                        if (string.IsNullOrWhiteSpace(se_code))
                        {
                            SendCode(plc_s, e, logKeyT, logKeyE, plc, 4);
                            return;
                        }
                        string result = SmartDeviceProxy.Instance.Invoke<string>(
                            p => p.CheckSecurityCodeByBarcode(
                                _mes_s.AccountCode,
                                usercode,
                                barcode,
                                se_code
                                ));

                        outputMessage = $"[{e.Content}]SE_Result=[{result}]{se_code}";
                        Logger.Trace(outputMessage, logKeyT, logger_t);
                        FormLogShow?.ShowLog(outputMessage);

                        // 返回状态（成功、失败）
                        if (result != "OK")
                        {
                            if (result == "EX")
                            {
                                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);
                            SendCode(plc_s, e, logKeyT, logKeyE, plc, 5);
                            return;
                        }
                    }
                    */
                    #endregion

                    if (p_id != plc_s.P_ID.ToString())
                    {
                        // 3#刮登计件
                        string result = SmartDeviceProxy.Instance.Invoke<string>(
                            p => p.AddWorkPieceByStatus3(
                                _mes_s.AccountCode,
                                //plc_s.USER_CODE,
                                usercode,
                                null,
                                plc_s.P_ID,
                                barcode,
                                null));

                        outputMessage = $"[{e.Content}]MES_Result=[{result}]";
                        Logger.Trace(outputMessage, logKeyT, logger_t);
                        FormLogShow?.ShowLog(outputMessage);

                        // 返回状态（成功、失败）
                        if (result != "OK")
                        {
                            if (result == "EE")
                            {
                                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);
                            SendCode(plc_s, e, logKeyT, logKeyE, plc, 3);
                            return;
                        }
                    }

                    //1：通过
                    if (goodsFlag == 2 || goodsFlag == 1)
                        SendCode(plc_s, e, logKeyT, logKeyE, plc, 0);
                    else
                        SendCode(plc_s, e, logKeyT, logKeyE, plc, 1);

                }
            }
            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);
                    if (plc?.Socket?.Connected ?? false)
                    {
                        SendCode(plc_s, e, logKeyT, logKeyE, plc, 3);
                    }
                }
                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();
                //e.ReturnMessage("0000");
            }
        }

        private void SendCode(PLC_S_GL_QR plc_s, ReceiveSession e, string loggerNameT,
            string loggerNameE, SocketClient<SiemensS7_1200Model> plc, short code)
        {
            try
            {
                //using (SocketClient<SiemensS7_1200Model> plc = new SocketClient<SiemensS7_1200Model>())
                {
                    // 扫码结果：【0：复位 1：通过 2：扫码异常 3：工序异常 4：防伪码读取错误 5：防伪码绑定错误】
                    string outputMessage = $"[{e.Content}]SET_CODE=[{code}]{plc_s.Add_Code + plc_s.Add_CodeNum}【0：复位 1：通过 2：扫码异常 3：工序异常 4：防伪码读取错误 5：防伪码验证错误】";
                    Logger.Trace(outputMessage, loggerNameT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    PLCResult p_r = plc?.Write<short>(plc_s.Add_Code, plc_s.Add_CodeNum, code);
                    outputMessage = $"[{e.Content}]END_CODE=[{p_r}]{plc_s.Add_Code + plc_s.Add_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 PLC_S_GL_QR GetPLC_S_GC(string flag, ReceiveSession e, string loggerName)
        {
            try
            {
                flag = M_NAME + flag;
                if (PLC_FLAGS.ContainsKey(flag))
                {
                    return PLC_FLAGS[flag];
                }
                else
                {
                    PLC_S_GL_QR plc_s = new PLC_S_GL_QR();
                    INIHelper ini = INIHelper.Create($@"PLC_S_INI\PLC_S_{M_NAME}.ini");

                    plc_s.IP = ini.Read(flag, "IP");
                    plc_s.Port = ini.Read(flag, "Port").ToInt32();
                    plc_s.P_ID = ini.Read(flag, "P_ID").ToInt32();
                    plc_s.WS_ID = ini.Read(flag, "WS_ID").ToInt32();
                    plc_s.USER_CODE = ini.Read(flag, "USER_CODE");
                    plc_s.Add_Code = ini.Read(flag, "Add_Code");
                    plc_s.Add_CodeNum = ini.Read(flag, "Add_CodeNum");

                    plc_s.Add_SE_Code1 = ini.Read(flag, "Add_SE_Code1");
                    plc_s.Add_SE_Code1Num = ini.Read(flag, "Add_SE_Code1Num");
                    plc_s.Add_SE_Code2 = ini.Read(flag, "Add_SE_Code2");
                    plc_s.Add_SE_Code2Num = ini.Read(flag, "Add_SE_Code2Num");

                    //xuwei add 2021-12-24
                    plc_s.Add_FinishFlag = ini.Read(flag, "Add_FinishFlag");
                    plc_s.Add_FinishFlagNum = ini.Read(flag, "Add_FinishFlagNum");

                    //xuwei add 2021-12-30
                    plc_s.Add_SE_Flag = ini.Read(flag, "Add_SE_Flag");
                    plc_s.Add_SE_FlagNum = ini.Read(flag, "Add_SE_FlagNum");
                    plc_s.Add_SE_Type = ini.Read(flag, "Add_SE_Type");
                    plc_s.Add_SE_TypeNum = ini.Read(flag, "Add_SE_TypeNum");
                    plc_s.Add_SE_BarCode = ini.Read(flag, "Add_SE_BarCode");
                    plc_s.Add_SE_BarCodeNum = ini.Read(flag, "Add_SE_BarCodeNum");

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

        private string GetGoodsType(string barcode, ReceiveSession e, string loggerName)
        {
            using (IDataAccess dataAccess = PLC_S_DataAccess.GetDataAccess(e))
            {
                try
                {
                    string sqlString = @"
                    SELECT
	                    -- G.GOODSCODE,
	                    -- G.SEATCOVERCODE,
	                    CASE 
                            WHEN T.GOODSTYPECODE = '001001001' THEN 2 --连体
							WHEN T.GOODSTYPECODE = '001001002' THEN 0 --分体
							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 = dataAccess.ExecuteScalar(sqlString, 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 "-1";
                }
            }
        }

    }
}