HEGII.ss.mes.plc/HG5000.3/PLC_S/ServerModel/BarcodePrint.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.Melsec;
using Curtain.Net.Sockets.PLC.Model.Siemens;

using PLC_S.Proxy;

namespace PLC_S.ServerModel
{
    /// <summary>
    /// 条码打印
    /// </summary>
    public class BarcodePrint : SocketServer<SimpleSocketServerModel>, IShowFormLog, IWindowsServer
    {
        public Dictionary<string, PLC_S_BP> PLC_FLAGS = new Dictionary<string, PLC_S_BP>();
        public const string M_NAME = "BP";
        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();

        public int Interval
        {
            get;
            set;
        }
        public string EPTS_CODE
        {
            get;
            set;
        }
        public BarcodePrint()
        {
            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
            {
                logger.OutputTrace($"{M_NAME}_ServerStarting");
            }
            catch { }
        }
        private void ServerSocket_ServerStarted(object sender, EventArgs e)
        {
            try
            {
                logger.OutputTrace($"{M_NAME}_ServerStarted");
            }
            catch { }
        }
        private void ServerSocket_ServerStoping(object sender, CancelEventArgs e)
        {
            try
            {
                logger.OutputTrace($"{M_NAME}_ServerStoping");
            }
            catch { }
        }
        private void ServerSocket_ServerStoped(object sender, EventArgs e)
        {
            try
            {
                logger.OutputTrace($"{M_NAME}_ServerStoped");
            }
            catch { }
        }
        private void ServerSocket_ServerMessage(object sender, ServerMessageEventArgs e)
        {
            try
            {
                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_BP plc_s = null;
            string cIP = e?.Client?.IP;
            string logKeyT = $"{M_NAME}-T[{cIP}]";
            string logKeyE = $"{M_NAME}-E[{cIP}]";

            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_BP(flag, e, logKeyE);
                    if (plc_s == null || string.IsNullOrWhiteSpace(plc_s.IP) || plc_s.Port == 0)
                    {
                        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);
                        SendError(plc_s, e, logKeyT, logKeyE, plc);
                        return;
                    }

                    string usercode = "";
                    string code;
                    short intcode;
                    short intLogoid;
                    using (IDataAccess dataAccess = PLC_S_DataAccess.GetDataAccess())
                    {
                        string sqlString = @"
                            SELECT t.usercode
                              FROM tp_mst_workstation t
                             WHERE t.workstationtypeid = 3161
                               AND t.workstationid = @workstationid@
                            ";
                        CDAParameter[] ps = new CDAParameter[]
                        {
                            new CDAParameter("workstationid", plc_s.WS_ID),
                        };

                        DataTable dataTable = dataAccess.ExecuteDatatable(sqlString, ps);
                        if (dataTable.HasData())
                        {
                            usercode = dataTable.Rows[0]["usercode"].ToString();
                        }

                        DataRow codeRow = GetGoodsCode(dataAccess, 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);
                            SendError(plc_s, e, logKeyT, logKeyE, plc);
                            return;
                        }

                        code = codeRow["goodscode"].ToString();
                        intcode = codeRow["seatcovercode"].ToInt16();
                        intLogoid = codeRow["logoid"].ToInt16();
                    }

                    outputMessage = $"[{e.Content}]产品型号={code}[{intcode}]{intLogoid}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);

                    if (intcode == 0)
                    {
                        outputMessage = $"[{e.Content}]此条码[{barcode}]未设置型号代码";
                        Logger.Error(null, outputMessage, logKeyT, logger_t);
                        Logger.Error(null, outputMessage, logKeyE, logger_e);
                        FormLogShow?.ShowLog(outputMessage);
                        SendError(plc_s, e, logKeyT, logKeyE, plc);
                        return;
                    }

                    PLCResult plc_r = null;

                    // 写入PLC 型号
                    outputMessage = $"[{e.Content}]SET_G_Code=[{intcode}]{plc_s.Add_SeatCoverCode + plc_s.Add_SeatCoverCodeNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    PLCResult p_r = plc.Write<short>(plc_s.Add_SeatCoverCode, plc_s.Add_SeatCoverCodeNum, intcode);
                    outputMessage = $"[{e.Content}]END_G_Code=[{p_r}]{plc_s.Add_SeatCoverCode + plc_s.Add_SeatCoverCodeNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);

                    // 写入PLC 商标
                    outputMessage = $"[{e.Content}]SET_L_Code=[{intLogoid}]{plc_s.Add_L_Code + plc_s.Add_L_CodeNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    p_r = plc.Write<short>(plc_s.Add_L_Code, plc_s.Add_L_CodeNum, intLogoid);
                    outputMessage = $"[{e.Content}]END_L_Code=[{p_r}]{plc_s.Add_L_Code + plc_s.Add_L_CodeNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);

                    // 写入条码读取状态
                    outputMessage = $"[{e.Content}]SET_R_CODE=[1]{plc_s.Add_BarCodeReadFlag + plc_s.Add_BarCodeReadFlagNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);
                    p_r = plc.Write<short>(plc_s.Add_BarCodeReadFlag, plc_s.Add_BarCodeReadFlagNum, 1);
                    outputMessage = $"[{e.Content}]END_R_CODE=[{p_r}]{plc_s.Add_BarCodeReadFlag + plc_s.Add_BarCodeReadFlagNum}";
                    Logger.Trace(outputMessage, logKeyT, logger_t);
                    FormLogShow?.ShowLog(outputMessage);

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


                    // xuwei add 由PLC地址控制包装线是 自动帖标 还是 手动打印
                    // plc_s.Add_PrintCode; plc_s.Add_PrintCodeNum;
                    // ============================================================
                    if (!string.IsNullOrEmpty(plc_s.Add_PrintCode) && !string.IsNullOrEmpty(plc_s.Add_PrintCodeNum))
                    {
                        //由PLC标识位控制
                        //读取自动帖标 标识==============================================================
                        outputMessage = $"[{e.Content}]GET_PrintCode=[]{plc_s.Add_PrintCode + plc_s.Add_PrintCodeNum}";
                        Logger.Trace(outputMessage, logKeyT, logger_t);
                        FormLogShow?.ShowLog(outputMessage);
                        PLCResult<short> se_read = plc.Read<short>(plc_s.Add_PrintCode, plc_s.Add_PrintCodeNum, 1);
                        outputMessage = $"[{e.Content}]END_PrintCode=[{se_read.ToString()}]{plc_s.Add_PrintCode + plc_s.Add_PrintCodeNum}";
                        Logger.Trace(outputMessage, logKeyT, logger_t);
                        FormLogShow?.ShowLog(outputMessage);
                        string printCode = se_read.Data.ToString();
                        if( printCode != "1" )
                        {
                            return;
                        }
                        //===============================================================================
                    }
                    else
                    {
                        //原始逻辑（如果配置文件没有配置PLC地址使用INI配置）
                        //TODO 临时只返回型号信息，不打印
                        if (plc_s.BEGIN_PRINT == null || plc_s.BEGIN_PRINT != "1")
                        {
                            return;
                        }
                    }
                    // ============================================================
                    //xuwei end 


                    //MES_S _mes_s = MES_S.Get();
                    string result = SmartDeviceProxy.Instance.Invoke<string>(
                    p => p.PrintBarcode_3BL(
                        _mes_s.AccountCode,
                        usercode,
                        barcode,
                        plc_s.WS_ID));

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

                    // 返回状态（成功、失败）
                    if (result == "OK")
                    {
                        // 条码打印任务发送状态
                        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);
                        p_r = plc.Write<short>(plc_s.Add_F_Code, plc_s.Add_F_CodeNum, 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);

                        // 通信异常标识
                        outputMessage = $"[{e.Content}]SET_E_CODE=[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, 0);
                        outputMessage = $"[{e.Content}]END_E_CODE=[{p_r}]{plc_s.Add_Error + plc_s.Add_ErrorNum}";
                        Logger.Trace(outputMessage, logKeyT, logger_t);
                        FormLogShow?.ShowLog(outputMessage);
                        return;
                    }
                    else if (result == "EE")
                    {
                        outputMessage = $"MES服务端异常（详情参见MES端日志）";
                    }
                    else if (result == "EU-01")
                    {
                        outputMessage = $"无效的帐套或工号（详情参见MES端日志）";
                    }
                    else
                    {
                        outputMessage = $"其他错误（详情参见MES端日志）[{result}]";
                    }

                    // 通信异常标识
                    outputMessage = $"[{e.Content}]SET_E_CODE=[1]{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, 1);
                    outputMessage = $"[{e.Content}]END_E_CODE=[{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();
            }
        }

        private void SendError(PLC_S_BP 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_E_CODE=[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_E_CODE=[{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 PLC_S_BP GetPLC_S_BP(string flag, ReceiveSession e, string loggerName)
        {
            try
            {
                flag = M_NAME + flag;
                if (PLC_FLAGS.ContainsKey(flag))
                {
                    return PLC_FLAGS[flag];
                }
                else
                {
                    PLC_S_BP plc_s = new PLC_S_BP();
                    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.WS_ID = ini.Read(flag, "WS_ID").ToInt32();
                    plc_s.Add_SeatCoverCode = ini.Read(flag, "Add_SeatCoverCode");
                    plc_s.Add_SeatCoverCodeNum = ini.Read(flag, "Add_SeatCoverCodeNum");
                    plc_s.Add_BarCodeReadFlag = ini.Read(flag, "Add_BarCodeReadFlag");
                    plc_s.Add_BarCodeReadFlagNum = ini.Read(flag, "Add_BarCodeReadFlagNum");
                    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");
                    plc_s.Add_L_Code = ini.Read(flag, "Add_L_Code");
                    plc_s.Add_L_CodeNum = ini.Read(flag, "Add_L_CodeNum");

                    plc_s.BEGIN_PRINT = ini.Read(flag, "BEGIN_PRINT");

                    //xuwei add 2022-02-14 用于控制 自动帖标 或 手动帖标
                    plc_s.Add_PrintCode = ini.Read(flag, "Add_PrintCode");
                    plc_s.Add_PrintCodeNum = ini.Read(flag, "Add_PrintCodeNum");

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

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

                string sqlString = "select g.goodscode, g.seatcovercode, gdd.logoid\n" +
                "  from tp_pm_groutingdailydetail gdd\n" +
                " inner join tp_mst_goods g\n" +
                "    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-GetGoodsCode", loggerName, logger_e);
                FormLogShow?.ShowLog($"[{e.Content}]ERROR-GetGoodsCode={ex.Message}");
                return null;
            }
            //finally
            //{
            //    dataAccess?.Close();
            //}
        }
    }
}