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


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

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;

namespace PLC_S.ServerModel
{
    /// <summary>
    /// 返回产品等级（1次品、2漏气、3重烧、4副品[盖子]、5良品（智能）,6良品（连体））等信息（成检分线对接）
    /// </summary>
    public class GoodsLevel_CF : SocketServer<SimpleSocketServerModel>, IShowFormLog, IWindowsServer
    {
        public Dictionary<string, PLC_S_GL_CF> PLC_FLAGS = new Dictionary<string, PLC_S_GL_CF>();
        public const string M_NAME = "GL_CF";

        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_CF()
        {
            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;
        }

        #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_GL_CF 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);
                        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);
                        return;
                    }

                    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);
                        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);
                    //outputMessage = $"[{e.Content}]PLC_Connect=[{plc_s.IP}:{plc_s.Port}]";
                    //Logger.Trace(outputMessage, logKeyT, logger_t);
                    //FormLogShow?.ShowLog(outputMessage);

                    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);
                        SET_GoodsLevel(e, plc_s, logKeyT, plc, 0);
                        SendError(plc_s, e, logKeyT, logKeyE, plc);
                        return;
                    }

                    DataRow codeRow = GetGoodsLevel(barcode, e, logKeyE);
                    if (codeRow == null)
                    {
                        outputMessage = $"[{e.Content}]此条码[{barcode}]不存在";
                        Logger.Warn(outputMessage, logKeyT, logger_t);
                        Logger.Warn(outputMessage, logKeyE, logger_e);
                        FormLogShow?.ShowLog(outputMessage);
                        SET_GoodsLevel(e, plc_s, logKeyT, plc, 0);
                        SendError(plc_s, e, logKeyT, logKeyE, plc);
                        return;
                    }

                    string level = codeRow["GOODSLEVELTYPEID"].ToString();
                    string leak1 = codeRow["LEAKFLAG1"].ToString();
                    string leak2 = codeRow["LEAKFLAG2"].ToString();
                    string leak3 = codeRow["LEAKFLAG3"].ToString();

                    // xuwei add 2024-04-13 修磨合格标识
                    int leak7 = Convert.ToInt32(codeRow["LEAKFLAG7"]);

                    string gtid = codeRow["goodstypeid"].ToString();
                    // 1次品、2漏气、3重烧、4副品[盖子]、5良品
                    int code;
                    string codeName;
                    //6221    2楼分线1 测漏气
                    //6222    2楼分线2 堵漏气
                    //6121    1楼分线1 内漏+通球
                    GetLevelCode(flag, gtid, level, leak1, leak2, leak3, out code, out codeName);

                    outputMessage = $"[{e.Content}]产品等级={codeName}[{code}][{level}-{leak1}-{leak2}-{leak3}]{gtid}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);

                    if (code == 0)
                    {
                        outputMessage = $"[{e.Content}]此条码[{barcode}]未设置产品等级";
                        Logger.Error(null, outputMessage, logKeyT, logger_t);
                        Logger.Error(null, outputMessage, logKeyE, logger_e);
                        FormLogShow?.ShowLog(outputMessage);
                        SET_GoodsLevel(e, plc_s, logKeyT, plc, 0);
                        SendError(plc_s, e, logKeyT, logKeyE, plc);
                        return;
                    }

                    //1. 产品分级（int）【1次品、2漏气、3重烧、4副品[盖子]、5良品（智能）,6良品（连体）】
                    SET_GoodsLevel(e, plc_s, logKeyT, plc, code);

                    //xuwei add 2024-04-13 修磨（int）【1：合格、2：不合格】 
                    SET_GoodsLeak7(e, plc_s, logKeyT, plc, leak7);
                    //xuwei end

                    //xuwei add 2024-04-23 漏气（int）【1：合格、2：不合格】 
                    SET_GoodsLeak1(e, plc_s, logKeyT, plc, Convert.ToInt32(leak1));
                    //xuwei end

                    //2.状态（int）【0：无，1:PLC等待读取；2.PLC读取完成】
                    outputMessage = $"[{e.Content}]SET_F_Code=[1]{plc_s.Add_F_Code + plc_s.Add_F_CodeNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    PLCResult p_r = plc?.Write<short>(plc_s.Add_F_Code, plc_s.Add_F_CodeNum, (short)1);
                    outputMessage = $"[{e.Content}]END_F_Code=[{p_r}]{plc_s.Add_F_Code + plc_s.Add_F_CodeNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);

                    //3.通信异常标识（int）【0：正常，1:后台处理异常，报警】
                    outputMessage = $"[{e.Content}]SET_ErrorNum=[0]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    p_r = plc?.Write<short>(plc_s.Add_Error, plc_s.Add_ErrorNum, (short)0);
                    outputMessage = $"[{e.Content}]END_ErrorNum=[{p_r}]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                }
            }
            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);
                    SendError(plc_s, e, logKeyT, logKeyE, plc);
                }
                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 SET_GoodsLevel(ReceiveSession e, PLC_S_GL_CF plc_s, string logKeyT, SocketClient<SiemensS7_1200Model> plc, int code)
        {
            string outputMessage = $"[{e.Content}]SET_GoodsLevel=[{code}]{plc_s.Add_Code + plc_s.Add_CodeNum}";
            Logger.Trace(outputMessage, logKeyT, logger_t);
            FormLogShow?.ShowLog(outputMessage);
            PLCResult p_r = plc.Write<short>(plc_s.Add_Code, plc_s.Add_CodeNum, (short)(code));
            outputMessage = $"[{e.Content}]END_GoodsLevel=[{p_r}]{plc_s.Add_Code + plc_s.Add_CodeNum}";
            Logger.Trace(outputMessage, logKeyT, logger_t);
            FormLogShow?.ShowLog(outputMessage);
            //return outputMessage;
        }

        //xuwei add 2024-04-13 增加修磨写入
        private void SET_GoodsLeak7(ReceiveSession e, PLC_S_GL_CF plc_s, string logKeyT, SocketClient<SiemensS7_1200Model> plc, int code)
        {
            if (!string.IsNullOrEmpty(plc_s.Add_GoodsLeak7Code) && !string.IsNullOrEmpty(plc_s.Add_GoodsLeak7CodeNum))
            {
                string outputMessage = $"[{e.Content}]SET_GoodsLeak7=[{code}]{plc_s.Add_GoodsLeak7Code + plc_s.Add_GoodsLeak7CodeNum}";
                Logger.Trace(outputMessage, logKeyT, logger_t);
                FormLogShow?.ShowLog(outputMessage);
                PLCResult p_r = plc.Write<short>(plc_s.Add_GoodsLeak7Code, plc_s.Add_GoodsLeak7CodeNum, (short)(code));
                outputMessage = $"[{e.Content}]END_GoodsLeak7=[{p_r}]{plc_s.Add_GoodsLeak7Code + plc_s.Add_GoodsLeak7CodeNum}";
                Logger.Trace(outputMessage, logKeyT, logger_t);
                FormLogShow?.ShowLog(outputMessage);
            }
        }

        //xuwei add 2024-04-23 增加漏气写入
        private void SET_GoodsLeak1(ReceiveSession e, PLC_S_GL_CF plc_s, string logKeyT, SocketClient<SiemensS7_1200Model> plc, int code)
        {
            if (!string.IsNullOrEmpty(plc_s.Add_GoodsLeak1Code) && !string.IsNullOrEmpty(plc_s.Add_GoodsLeak1CodeNum))
            {
                string outputMessage = $"[{e.Content}]SET_GoodsLeak1=[{code}]{plc_s.Add_GoodsLeak1Code + plc_s.Add_GoodsLeak1CodeNum}";
                Logger.Trace(outputMessage, logKeyT, logger_t);
                FormLogShow?.ShowLog(outputMessage);
                PLCResult p_r = plc.Write<short>(plc_s.Add_GoodsLeak1Code, plc_s.Add_GoodsLeak1CodeNum, (short)(code));
                outputMessage = $"[{e.Content}]END_GoodsLeak1=[{p_r}]{plc_s.Add_GoodsLeak1Code + plc_s.Add_GoodsLeak1CodeNum}";
                Logger.Trace(outputMessage, logKeyT, logger_t);
                FormLogShow?.ShowLog(outputMessage);
            }
        }

        private static void GetLevelCode(string flag, string gtid, string level,
            string leak1, string leak2, string leak3, out int code, out string codeName)
        {
            code = 0;
            codeName = "";
            bool zhineng = gtid.EqualAny("18", "19");
            // 连体： 次品1 》 漏气2 》 重烧3 》 副品4 》 正品6 >> 冷补8
            // 智能： 次品1 》 重烧3 》 副品4 》 漏气7 》 正品5 >> 冷补9
            // 1次品、2漏气【连体】、3重烧、4副品[盖子]、5良品（智能）,6良品（连体）、7漏气【智能】、8冷补【连体】、9冷补【智能】
            if (zhineng)
            {
                codeName = "[智能]";
                if (leak1 == "1")
                {
                    codeName += "[合格]";
                }
                else
                {
                    codeName += "[漏气]";
                }
                if (level == "7")
                {
                    codeName += "次品";
                }
                else if (level == "6")
                {
                    codeName += "重烧";
                }
                else if (level == "5")
                {
                    codeName += "副品";
                }
                //xuwei add 2023-04-19 加冷补
                else if (level == "16")
                {
                    codeName += "冷补";
                }
                //xuwei end
                else
                {
                    codeName += "正品";
                }

                if (level == "7")
                {
                    code = 1;
                    return;
                }
                if (level == "6")
                {
                    code = 3;
                    return;
                }
                if (level == "5")
                {
                    code = 4;
                    codeName += "[盖子]";
                    return;
                }
                //xuwei add 2023-04-19 加冷补
                if (level == "16")
                {
                    code = 9;
                    return;
                }
                //xuwei end

                if (flag == "6221" || flag == "21")
                {
                    if (leak1 != "1")
                    {
                        code = 7;
                        codeName += "[漏气]";
                        return;
                    }
                }

                code = 5;
                return;
            }

            codeName = "[连体]";
            if (leak1 == "1")
            {
                codeName += "[合格]";
            }
            else
            {
                codeName += "[漏气]";
            }
            if (level == "7")
            {
                codeName += "次品";
            }
            else if (level == "6")
            {
                codeName += "重烧";
            }
            else if (level == "5")
            {
                codeName += "副品";
            }
            //xuwei add 2023-04-19 加冷补
            else if (level == "16")
            {
                codeName += "冷补";
            }
            //xuwei end
            else
            {
                codeName += "正品";
            }

            if (level == "7")
            {
                code = 1;
                return;
            }
            if (flag == "6221" || flag == "21")
            {
                if (leak1 != "1")
                {
                    code = 2;
                    codeName += "[漏气]";
                    return;
                }
            }
            if (level == "6")
            {
                code = 3;
                return;
            }
            if (level == "5")
            {
                code = 4;
                codeName += "[盖子]";
                return;
            }
            //xuwei add 2023-04-19 加冷补
            if (level == "16")
            {
                code = 8;
                return;
            }
            //xuwei end
            code = 6;
        }

        private void SendError(PLC_S_GL_CF plc_s, ReceiveSession e, string loggerNameT,
            string loggerNameE, SocketClient<SiemensS7_1200Model> plc)
        {
            try
            {
                //using (SocketClient<SiemensS7_1200Model> plc = new SocketClient<SiemensS7_1200Model>())
                {
                    string outputMessage = $"[{e.Content}]SET_ErrorNum=[1]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
                    Logger.Trace(outputMessage, loggerNameT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    PLCResult p_r = plc?.Write<short>(plc_s.Add_Error, plc_s.Add_ErrorNum, (short)1);
                    outputMessage = $"[{e.Content}]END_ErrorNum=[{p_r}]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
                    Logger.Trace(outputMessage, loggerNameT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                }
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-SendError", loggerNameT, logger_t);
                Logger.Error(ex, $"[{e.Content}]ERROR-SendError", loggerNameE, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-SendError={ex.Message}");
            }
        }

        private DataRow GetGoodsLevel(string barcode, ReceiveSession e, string loggerName)
        {
            IDataAccess dataAccess = null;
            try
            {
                dataAccess = PLC_S_DataAccess.GetDataAccess(e);

                string sqlString = "select gdd.GOODSLEVELTYPEID,g.goodstypeid, decode(gdd.LEAKFLAG1,'0','2','1') AS LEAKFLAG1, gdd.LEAKFLAG2, gdd.LEAKFLAG3, decode(gdd.LEAKFLAG7,'0','2','1') AS LEAKFLAG7 \n" +
                "  from tp_pm_groutingdailydetail gdd\n" +
                "  inner join tp_mst_goods g on g.goodsid = gdd.goodsid\n" +
                " where gdd.barcode = :barcode";
                DataTable dataTable = dataAccess.ExecuteDatatable(sqlString, new CDAParameter(":barcode", barcode));
                if (dataTable.HasData())
                {
                    return dataTable.Rows[0];
                }
                return null;
            }
            catch (Exception ex)
            {
                Logger.Error(ex, $"[{e.Content}]ERROR-GetGoodsLevel", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetGoodsLevel={ex.Message}");
                return null;
            }
            finally
            {
                dataAccess?.Close();
            }
        }

        private PLC_S_GL_CF 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_CF plc_s = new PLC_S_GL_CF();
                    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.Add_Code = ini.Read(flag, "Add_Code");
                    plc_s.Add_CodeNum = ini.Read(flag, "Add_CodeNum");
                    plc_s.Add_F_Code = ini.Read(flag, "Add_F_Code");
                    plc_s.Add_F_CodeNum = ini.Read(flag, "Add_F_CodeNum");
                    plc_s.Add_Error = ini.Read(flag, "Add_Error");
                    plc_s.Add_ErrorNum = ini.Read(flag, "Add_ErrorNum");
                    
                    //xuwei add 2024-04-13 增加修磨标识
                    plc_s.Add_GoodsLeak7Code = ini.Read(flag, "Add_GoodsLeak7Code");
                    plc_s.Add_GoodsLeak7CodeNum = ini.Read(flag, "Add_GoodsLeak7CodeNum");

                    //xuwei add 2024-04-23 增加漏气标识
                    plc_s.Add_GoodsLeak1Code = ini.Read(flag, "Add_GoodsLeak1Code");
                    plc_s.Add_GoodsLeak1CodeNum = ini.Read(flag, "Add_GoodsLeak1CodeNum");

                    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;
            }
        }
    }
}