xs_httpserver/deviceHttpServer/hedidenain/HeidenhainServer.cs

using HeidenhainDNCLib;
using Newtonsoft.Json;
using RequestServer.HttpServer;
using ResponseServer.HttpServer;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net.NetworkInformation;
using System.Runtime.InteropServices;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace Fanuc_HttpServer.hedidenain
{
    class HeidenhainServer
    {
        private int iChannel = 0;
        private string RemotePath = "TNC:\\nc_prog\\ATUO";//ConfigurationManager.AppSettings["RemotePath"]; 
        private static string ON_LINE_STATE = "在线";
        private Dictionary<String, List<string>> jcIpDict = new Dictionary<String, List<string>>();
        
        //连接设备列表
        public Dictionary<string, DNC_STATE> deviceList { get; set; } = new Dictionary<string, DNC_STATE>();
        private DNC_STATE m_ControlState;
        public static Dictionary<string, JHMachineInProcess> machineList { get; set; } = new Dictionary<string, JHMachineInProcess>();
        public  HeidenhainServer()
        {
            List<string> ip1 = new List<string>();
            ip1.Add("\\PLC\\memory\\D\\17600");
            ip1.Add("\\PLC\\memory\\D\\4448"); 
            jcIpDict.Add("192.168.10.109", ip1);
            List<string> ip2 = new List<string>();
            ip2.Add("\\PLC\\memory\\D\\368");
            ip2.Add("\\PLC\\memory\\D\\5048"); 
            jcIpDict.Add("192.168.10.101", ip2);
        }
        public ResponseBody requestHttpServer(RequestBody requestBody)
        {
            string ip = requestBody.serverUrl;
            string port = requestBody.port;
            string fun = requestBody.type;
            ResponseBody responseBody = new ResponseBody();
            JHMachineInProcess Machine = null;
            if (fun == ActionTypeEnum.Collect.ToString()) 
            {
                Ping pingSender = new Ping();
                PingReply reply = pingSender.Send(requestBody.serverUrl);
                if (reply.Status != IPStatus.Success)
                {
                    //responseBody.result = false;
                    responseBody.msg = "调用失败";
                }

                else
                {
                    //第一次连接加入数组,以支持多台设备
                    if (machineList == null || (machineList.Where(m => m.Key == requestBody.machineName).Count() == 0))
                    {
                        DNC_STATE m_ControlState = connect(requestBody.machineName);

                        Thread.Sleep(100);
                    }
                    //DNC连接正常,获取连接Machine = machineList.Where(m => m.Key == requestBody.machineName).FirstOrDefault().Value;
                    Machine = machineList.Where(m => m.Key == requestBody.machineName).FirstOrDefault().Value;
                    if (Machine != null)
                    {
                        if (Machine.GetState().ToString() == "DNC_STATE_MACHINE_IS_AVAILABLE")
                        {
                            responseBody.deviceState = ON_LINE_STATE;
                            JHError m_Error = Machine.GetInterface(HeidenhainDNCLib.DNC_INTERFACE_OBJECT.DNC_INTERFACE_JHERROR);
                            JHErrorEntry2List errorsList = m_Error.GetErrorList();
                            IJHErrorEntry2 pErrorEntry = null;
                            for (int i = 0; i < errorsList.Count; i++)
                            {
                                pErrorEntry = errorsList[i];
                                if (pErrorEntry != null && pErrorEntry.Text != null)
                                {
                                    //Console.WriteLine("===" + pErrorEntry.Text.ToString());
                                    responseBody.errorsInfo += pErrorEntry.Text.ToString() + " ";
                                }
                            }

                            if (fun == ActionTypeEnum.Collect.ToString())
                            {

                                JHAutomatic m_Automatic = Machine.GetInterface(DNC_INTERFACE_OBJECT.DNC_INTERFACE_JHAUTOMATIC);

                                JHProcessData m_ProcessData = Machine.GetInterface(HeidenhainDNCLib.DNC_INTERFACE_OBJECT.DNC_INTERFACE_JHPROCESSDATA);


                                object pFeed = new object();
                                object pSpeed = new object();
                                object pRapid = new object();
                                object proStatus = new object();
                                //进出倍率 主轴倍率 
                                m_Automatic.GetOverrideInfo(ref pFeed, ref pSpeed, ref pRapid);
                                //主程序
                                object pSelectedProgram = new object(); ;
                                m_Automatic.GetExecutionPoint(ref pSelectedProgram);
                                responseBody.mainProg = pSelectedProgram.ToString();

                                m_Automatic.GetExecutionMode();
                                DNC_STS_PROGRAM dncProgram = m_Automatic.GetProgramStatus();

                                RunDatasInfo runDatasInfo = new RunDatasInfo();
                                responseBody.feedRateOvr = pFeed.ToString();
                                responseBody.spindleMagnification = pSpeed.ToString();
                                //responseBody.actSpindle = pRapid.ToString();
                                //计算开机时长
                                object oHours = new object();
                                object oMinutes = new object();
                                // --- NC uptime --------------------------------------------------------------------------
                                m_ProcessData.GetNcUpTime(ref oHours, ref oMinutes);
                                string ncUpTime = oHours.ToString() + ":" + (Convert.ToInt32(oMinutes) > 9 ? oMinutes.ToString() : ("0" + oMinutes.ToString()));

                                // --- Machine uptime ---------------------------------------------------------------------
                                m_ProcessData.GetMachineUpTime(ref oHours, ref oMinutes);
                                string machineUpTime = oHours.ToString() + ":" + (Convert.ToInt32(oMinutes) > 9 ? oMinutes.ToString() : ("0" + oMinutes.ToString()));
                                // --- Machine running time ---------------------------------------------------------------
                                m_ProcessData.GetMachineRunningTime(ref oHours, ref oMinutes);
                                string runningTimes = oHours.ToString() + ":" + (Convert.ToInt32(oMinutes) > 9 ? oMinutes.ToString() : ("0" + oMinutes.ToString()));

                                responseBody.powerOnTime = (Convert.ToInt32(oHours) * 60 + Convert.ToInt32(oMinutes)).ToString();

                                JHDataAccess m_DataAccess = Machine.GetInterface(HeidenhainDNCLib.DNC_INTERFACE_OBJECT.DNC_INTERFACE_JHDATAACCESS);
                                HeidenhainDNCLib.DNC_ACCESS_MODE accessModeEnum = (HeidenhainDNCLib.DNC_ACCESS_MODE)Enum.Parse(typeof(HeidenhainDNCLib.DNC_ACCESS_MODE), "DNC_ACCESS_MODE_PLCDATAACCESS");
                                m_DataAccess.SetAccessMode(accessModeEnum, "807667");
                                List<string> param = jcIpDict[ip];
                                for (int j = 0; j < param.Count; j++)
                                {
                                    IJHDataEntry m_DataEntry = m_DataAccess.GetDataEntry(param[j]);
                                    IJHDataEntryPropertyList dataEntryPropertyList = m_DataEntry.propertyList;
                                    for (int i = 0; i < dataEntryPropertyList.Count; i++)
                                    {
                                        IJHDataEntryProperty dataEntryProperty = dataEntryPropertyList[i];
                                        if (dataEntryProperty.kind == DNC_DATAENTRY_PROPKIND.DNC_DATAENTRY_PROPKIND_DATA)
                                        {
                                            if (j == 0)
                                            {
                                                if(ip == "192.168.10.109")
                                                {
                                                    responseBody.actSpindle = (Convert.ToInt32(dataEntryProperty.varValue) / 1000).ToString();
                                                }
                                                else
                                                {
                                                    responseBody.actSpindle = dataEntryProperty.varValue.ToString();
                                                }
                                                
                                            }else if (j == 1)
                                            {
                                                responseBody.actFeed = dataEntryProperty.varValue.ToString();
                                            }

                                        }


                                    }
                                }
                               
                            }
                            else if (fun == ActionTypeEnum.Upload.ToString())
                            {

                                JHFileSystem m_FileSystem = Machine.GetInterface(DNC_INTERFACE_OBJECT.DNC_INTERFACE_JHFILESYSTEM);

                                JHAutomatic m_Automatic = Machine.GetInterface(DNC_INTERFACE_OBJECT.DNC_INTERFACE_JHAUTOMATIC);

                                string sSelectedFile = Path.GetFileName(requestBody.path);

                                string dncPath = GenPath(RemotePath, sSelectedFile);
                                string tempDncPath = RemotePath + "\\2.h";
                                //设置临时程序为主程序
                                //  m_Automatic.SelectProgram(iChannel, tempDncPath);
                                try
                                { //删除上传文件，try异常防止文件不存在
                                  //m_FileSystem.DeleteFile(dncPath);
                                }
                                catch (Exception edel)
                                {
                                }
                                //上传
                                m_FileSystem.TransmitFile(requestBody.path, dncPath);
                                //设当前上传程序为主程序
                                // m_Automatic.SelectProgram(iChannel, dncPath);
                            }

                            else if (fun == ActionTypeEnum.StartNcProgram.ToString())//启动程序备用
                            {

                                JHAutomatic m_Automatic = Machine.GetInterface(DNC_INTERFACE_OBJECT.DNC_INTERFACE_JHAUTOMATIC);

                                //m_Automatic.SelectProgram(iChannel, GenPath(RemotePath, hdhBody.Path));
                                //Thread.Sleep(1000);
                                m_Automatic.StartProgram(GenPath(RemotePath, requestBody.path));
                            }
                            else if (fun == ActionTypeEnum.ToolList.ToString())
                            {
                                IJHDataEntry2 ToolLine = null;
                                IJHDataEntry2List ToolCells = null;
                                //IJHDataEntry2 ToolCell = null;                                    
                                List<ToolsInfo> toolsList = new List<ToolsInfo>();
                                JHDataAccess dataAccess = Machine.GetInterface(HeidenhainDNCLib.DNC_INTERFACE_OBJECT.DNC_INTERFACE_JHDATAACCESS);
                                dataAccess.SetAccessMode(DNC_ACCESS_MODE.DNC_ACCESS_MODE_TABLEDATAACCESS, "");
                                //string ToolColumnNamesAccessor = @"\TABLE\TOOL\T\('1'-'50')";   // see Init()
                                string ToolColumnNamesAccessor = @"\TABLE\TOOL_P\T\('1'-'50')";
                                IJHDataEntry2 ToolTable = dataAccess.GetDataEntry2(ToolColumnNamesAccessor, DNC_DATA_UNIT_SELECT.DNC_DATA_UNIT_SELECT_METRIC, false);
                                IJHDataEntry2List ToolLines = ToolTable.GetChildList();
                                int ToolLinesCount = ToolLines.Count >= 50 ? 50 : ToolLines.Count;
                                //int ToolLinesCount = ToolLines.Count;                                    
                                for (int i = 0; i < ToolLinesCount; i++)
                                {
                                    ToolLine = ToolLines[i];
                                    ToolCells = ToolLine.GetChildList();
                                    // get child list from server                                       
                                    ToolsInfo toolsInfo = new ToolsInfo();

                                    //刀位编码
                                    int[] pCode = ToolCells[0].GetPropertyValue(DNC_DATAENTRY_PROPKIND.DNC_DATAENTRY_PROPKIND_DATA);
                                    toolsInfo.position = string.Join(".", pCode);
                                    toolsInfo.number = ToolCells[1].GetPropertyValue(DNC_DATAENTRY_PROPKIND.DNC_DATAENTRY_PROPKIND_DATA).ToString();
                                    toolsInfo.name = ToolCells[2].GetPropertyValue(DNC_DATAENTRY_PROPKIND.DNC_DATAENTRY_PROPKIND_DATA).ToString();


                                    if (!String.IsNullOrEmpty(toolsInfo.name) && !String.IsNullOrEmpty(toolsInfo.number) && pCode.Length > 0 && pCode[1] > 0)
                                    {
                                        string ToolNumberAccessor = @"\TABLE\TOOL\T\" + toolsInfo.number.ToString();
                                        IJHDataEntry2List ToolList = dataAccess.GetDataEntry2(ToolNumberAccessor, DNC_DATA_UNIT_SELECT.DNC_DATA_UNIT_SELECT_METRIC, false).GetChildList();

                                        //报警期限
                                        toolsInfo.warnLife = ToolList[10].GetPropertyValue(DNC_DATAENTRY_PROPKIND.DNC_DATAENTRY_PROPKIND_DATA).ToString();
                                        //刀具寿命目标值
                                        toolsInfo.targetLife = ToolList[11].GetPropertyValue(DNC_DATAENTRY_PROPKIND.DNC_DATAENTRY_PROPKIND_DATA).ToString();
                                        //Cur_Time使用时间
                                        toolsInfo.curTime = ToolList[12].GetPropertyValue(DNC_DATAENTRY_PROPKIND.DNC_DATAENTRY_PROPKIND_DATA).ToString();

                                        toolsList.Add(toolsInfo);
                                    }
                                }
                                //获取海德汉的刀具寿命信息
                                responseBody.toolsInfo = toolsList;
                            }
                        }
                        else if (Machine.GetState().ToString() != "DNC_STATE_MACHINE_IS_AVAILABLE") //机床状态不可用 断开连接
                        {
                            responseBody.msg = Machine.GetState().ToString();
                            responseBody.result = false;
                            Machine.Disconnect();
                            Marshal.ReleaseComObject(Machine);
                            Machine = null;
                            machineList.Remove(requestBody.machineName);
                        }
                    }
                }

            }
            return responseBody;
        }
        private DNC_STATE connect(string connectName)
        {
            DNC_CNC_TYPE CncType;

            IJHConnectionList connectionList = null;
            IJHConnection connection = null;
            try
            {
                JHMachineInProcess Machine = new JHMachineInProcess();
                Machine.ConnectRequest(connectName);
                string sCurrentMachine = Machine.currentMachine;

                // Find out control type
                connectionList = Machine.ListConnections();
                for (int i = 0; i < connectionList.Count; i++)
                {
                    connection = connectionList[i];

                    if (connection.name == sCurrentMachine)
                    {
                        CncType = connection.cncType;
                    }

                    if (connection != null)
                        Marshal.ReleaseComObject(connection);
                }
                // //DNC连接正常,加入数组 第一次连接加入数组,以支持多台设备

                machineList.Add(connectName, Machine);
                Thread.Sleep(20);

                return Machine.GetState();
            }
            catch (COMException cex)
            {
                YG.Log.Instance.WriteLogAdd($"海德汉响应结果-cex-->> " + cex.Message);
                return DNC_STATE.DNC_STATE_NOT_INITIALIZED;
            }
            catch (Exception ex)
            {
                YG.Log.Instance.WriteLogAdd($"海德汉响应结果-ex-->> " + ex.Message);
                return DNC_STATE.DNC_STATE_NOT_INITIALIZED;
            }
            finally
            {
                if (connectionList != null)
                    Marshal.ReleaseComObject(connectionList);
                if (connection != null)
                    Marshal.ReleaseComObject(connection);
            }
        }
        private string GenPath(string part1, string part2)
        {
            string sFullPath = part1;
            switch (part2)
            {
                case ".":
                    break;
                case "..":
                    if (part1.EndsWith(@"\") && part1.Length > 5)
                        part1 = part1.Substring(0, part1.Length - 3);
                    int iLastFolderPos = part1.LastIndexOf(@"\");
                    if (iLastFolderPos >= 0)
                        sFullPath = part1.Substring(0, iLastFolderPos + 1);
                    break;
                default:
                    if (part1.EndsWith(@"\"))
                        sFullPath = part1 + part2;
                    else
                        sFullPath = part1 + @"\" + part2;
                    break;
            }
            return sFullPath;
        }
    }
}