hz_ccs/IMCS_CCS/Service/Impl/HttpRequestService.cs

using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using System.Threading;
using IMCS.CCS.Entitys;
using IMCS.CCS.Models.vo;
using IMCS.CCS.Models;
using IMCS.CCS.DeviceProtocol;
using System;
using S7.Net;
using IMCS_CCS.Utils;
using Newtonsoft.Json;
using IMCS_CCS.Utils.DeviceProtocol;
using HslCommunication.Profinet.Siemens;
using Microsoft.Extensions.Configuration;
using IMCS.CCS.Service;
using IMCS_CCS.Model.vo;
using FTP;
using HslCommunication;
using System.Text.RegularExpressions;
using System.IO;
using Org.BouncyCastle.Ocsp;
using MySqlX.XDevAPI.Common;
using IMCS_CCS.Service.Impl;
using IMCS_CCS.Service;
using IMCS_CCS.Entitys;
using static Google.Protobuf.Reflection.SourceCodeInfo.Types;
using Newtonsoft.Json.Linq;
using static AutoMapper.Internal.ExpressionFactory;
using Microsoft.EntityFrameworkCore.Internal;
using Org.BouncyCastle.Asn1.Ocsp;
using Ubiety.Dns.Core;
using static IMCS.CCS.Models.vo.ResponseECSData;

namespace IMCS.CCS.Services
{
    public class HttpRequestService : IHttpRequestService
    {
        private readonly IDeviceService _deviceService;

        private readonly ITaskCallbackService _taskCallbackService;

        private readonly ICcsActionService _ccsActionService;

        private readonly ICcsTagValueService _ccsTagValueService;

        private readonly IEquipmentMonitorService _equipmentMonitorService;

        private readonly ICcsActionAddressService _ccsActionAddressService;

        private readonly ITaskJobService _taskJobService;

        private readonly ICcsActionDeviceSourceCheckService _ccsActionDeviceSourceCheckService;

        private int SLEEP_TIME = 100;

        string LocalPath = "D:\\PROG";

        private string fanucUrlContext;

        private string opcuacUrlContext;

        private string hdhUrlContext; 

        private string ecsRootUrlContext;

        public IConfiguration Configuration { get; }

        private readonly IApiRequestService _apiRequestService;



        //上下料站 上料请求
        private static Dictionary<string, string> sxlzslqq = new Dictionary<string, string>();
        //上下料站 下料请求
        private static Dictionary<string, string> sxlzxlqq = new Dictionary<string, string>();

        //上下料站 下料完成信号
        private static Dictionary<string, string> sxlzxlwcxh = new Dictionary<string, string>();
        //上下料站 上料完成信号
        private static Dictionary<string, string> sxlzslwcxh = new Dictionary<string, string>();

        //上下料站 机床 允许取放状态
        private static Dictionary<string, string> pointDict = new Dictionary<string, string>();

        public HttpRequestService(IDeviceService deviceService, ITaskCallbackService taskCallbackService,
                                  ICcsActionService ccsActionService, ICcsTagValueService ccsTagValueService,
                                  IEquipmentMonitorService equipmentMonitorService, ICcsActionAddressService ccsActionAddressService,
                                  IApiRequestService apiRequestService, ITaskJobService taskJobService, ICcsActionDeviceSourceCheckService ccsActionDeviceSourceCheckService,
                                  IConfiguration configuration)
        {
            _deviceService = deviceService;
            _taskCallbackService = taskCallbackService;
            _ccsActionService = ccsActionService;
            _ccsTagValueService = ccsTagValueService;
            _equipmentMonitorService = equipmentMonitorService;
            _ccsActionAddressService = ccsActionAddressService;
            _apiRequestService = apiRequestService;
            _taskJobService = taskJobService;
            _ccsActionDeviceSourceCheckService = ccsActionDeviceSourceCheckService;
            Configuration = configuration;
            fanucUrlContext = Configuration.GetConnectionString("fanucUrlContext");
            opcuacUrlContext = Configuration.GetConnectionString("opcuacUrlContext");
            hdhUrlContext = Configuration.GetConnectionString("hdhUrlContext"); 
            ecsRootUrlContext = Configuration.GetConnectionString("ecsRootUrlContext");


            if(sxlzslqq.Count == 0)
            {
                sxlzslqq.Add("129", "DB1001.106");
                sxlzslqq.Add("446", "DB1001.106");

                sxlzslqq.Add("130", "DB1001.108");
                sxlzslqq.Add("447", "DB1001.108");
            }
            if (sxlzxlqq.Count == 0)
            {
                sxlzxlqq.Add("129", "DB1001.112");
                sxlzxlqq.Add("446", "DB1001.112");

                sxlzxlqq.Add("130", "DB1001.114");
                sxlzxlqq.Add("447", "DB1001.114");
            }

            if (sxlzxlwcxh.Count == 0)
            {
                sxlzxlwcxh.Add("129", "DB1000.42");
                sxlzxlwcxh.Add("446", "DB1000.42");



                sxlzxlwcxh.Add("130", "DB1000.44");
                sxlzxlwcxh.Add("447", "DB1000.44");
            }
            if (sxlzslwcxh.Count == 0)
            {
                sxlzslwcxh.Add("129", "DB1000.48");
                sxlzslwcxh.Add("446", "DB1000.48");


                sxlzslwcxh.Add("130", "DB1000.50");
                sxlzslwcxh.Add("447", "DB1000.50");
            }

            if(pointDict.Count == 0)
            {
                /*//上下料站1
                pointDict.Add("129", "");
                pointDict.Add("446", "");

                //上下料站2
                pointDict.Add("130", "");
                pointDict.Add("447", "");*/

                //德玛吉
                pointDict.Add("121", "");
                pointDict.Add("441", "");

                //永进TV158B三轴
                pointDict.Add("122", "");
                pointDict.Add("442", "");

                //永进TV158B四轴 + 尾架 - 1
                pointDict.Add("123", "");
                pointDict.Add("124", "");
                pointDict.Add("443", "");

                //永进TV158B四轴 + 尾架 - 2
                pointDict.Add("125", "");
                pointDict.Add("126", "");
                pointDict.Add("444", "");

                //永进TV158B五轴转台
                pointDict.Add("127", "");
                pointDict.Add("128", "");
                pointDict.Add("445", "");
            }

        }

        /// <summary>
        /// 获取状态当前值
        /// </summary> 
        public string GetTagValue(RequestTagValueData req)
        {
            CcsTagValue queryParam = new CcsTagValue();
            queryParam.Ip = req.ip;
            queryParam.Address = req.tagname;
            List<CcsTagValue> tagValues = _ccsTagValueService.GetList(queryParam);
            string tagValue = "0";
            if (tagValues != null && tagValues.Count > 0)
            {
                tagValue = tagValues[0].TagValue;
            }
            return tagValue;

        }

        /// <summary>
        /// 益模调用接口，显示3D
        /// </summary> 
        public async Task<List<ResponseDigitalTwinsData>> GetDigitalTwins()
        {
            List<Device> devices = _deviceService.GetDeviceList();            
            List<ResponseDigitalTwinsData> list = new List<ResponseDigitalTwinsData>();

            String query3dUrl = ecsRootUrlContext + "/api/authority/agv/agvCallbackService/query3dResouceDataInfo";
            var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, query3dUrl, new Object(), null);
            ResponsePageData<ResponseDigitalTwinsData> responseData = JsonConvert.DeserializeObject<ResponsePageData<ResponseDigitalTwinsData>>(result.Message);
            list = responseData.Data;
            foreach(ResponseDigitalTwinsData responseDigitalTwinsData in list)
            {
                EquipmentMonitor equipmentMonitor = await _equipmentMonitorService.GetById(long.Parse(responseDigitalTwinsData.resourceId));
                if (equipmentMonitor==null || equipmentMonitor.IP == null)
                {
                    continue;
                }
                Device device = devices.Where(x => x.Ip.Equals(equipmentMonitor.IP)).FirstOrDefault();
                if (null!=device && equipmentMonitor.Type == "HEIDEHAIN")
                {
                    RequestHeidhData hdhReq = new RequestHeidhData();                    
                    hdhReq.ServerUrl = device.ServerUrl;
                    hdhReq.MachineName = device.UserName;
                    hdhReq.Type = "Collect";
                    var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
                    if (Result.IsSuccess)
                    {
                        ResponseHeidhData retData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
                        if (!string.IsNullOrEmpty(retData.runDatasInfo.Trim()))
                        {                            
                            ResponseDigitalTwinsData twinsData = JsonConvert.DeserializeObject<ResponseDigitalTwinsData>(retData.runDatasInfo);
                            responseDigitalTwinsData.feedRate = !string.IsNullOrEmpty(twinsData.feedRate)? twinsData.feedRate : "0";
                            responseDigitalTwinsData.spindleMagnification = !string.IsNullOrEmpty(twinsData.spindleMagnification)? twinsData.spindleMagnification:"0";
                            responseDigitalTwinsData.spindleSpeed = !string.IsNullOrEmpty(twinsData.spindleSpeed) ? twinsData.spindleSpeed + "00" : "0";
                            responseDigitalTwinsData.spindleLoad = !string.IsNullOrEmpty(twinsData.spindleLoad) ? twinsData.spindleMagnification : "-";
                        }
                    }
                }
                else if(null != device && equipmentMonitor.Type == "FANUC")
                {
                    string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
                    //调用发那科接口
                    var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=All", null, null);

                    if (Result.IsSuccess)
                    {
                        ResponseFanucData responseFanucData = JsonConvert.DeserializeObject<ResponseFanucData>(Result.Message);
                        responseDigitalTwinsData.feedRate = !string.IsNullOrEmpty(responseFanucData.ActFeed)? responseFanucData.ActFeed:"0";
                        responseDigitalTwinsData.spindleMagnification = !string.IsNullOrEmpty(responseFanucData.SpindleMagnification)? responseFanucData.SpindleMagnification:"0";
                        responseDigitalTwinsData.spindleSpeed = !string.IsNullOrEmpty(responseFanucData.ActSpindle)? responseFanucData.ActSpindle : "0";
                        responseDigitalTwinsData.spindleLoad = !string.IsNullOrEmpty(responseFanucData.SpindleLoad)? responseFanucData.SpindleLoad : "-";
                    }
                }
            }

            return list;

        }

        /// <summary>
        /// 查询设备状态
        /// </summary> 
        public async Task<List<EquipmentMonitor>> GetEquipMent()
        {
            return await _equipmentMonitorService.GetList();

        }
     

        /// <summary>
        /// 机器人取放动作
        /// </summary> 
        public async Task<ResponseECSData> RobotAction(RequestData<LocationData> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.RobotAction + "任务接受===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.RobotAction));

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId,"执行成功");
            SiemensS7Net s7 = null;
            try
            {

                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == req.url && x.Port == req.port).FirstOrDefault();
                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.RobotAction + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.RobotAction));
                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + req.url;
                    return responseData;
                }

                // 根据ip查询设备
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.RobotAction.ToString();
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                // 进行plc的连接
                s7 = DevicePlcS7.SiemensS7(actionInfo.Ip);
                OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd(ActionTypeEnum.RobotAction + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.RobotAction));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.RobotAction + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req);
                    return responseData;
                }
                string slReuslt = null;
                if (sxlzslwcxh.ContainsKey(req.data.location))
                {
                    slReuslt = s7.ReadInt16(sxlzslwcxh[req.data.location]).Content.ToString();
                }

                string xlReuslt = null;
                if (sxlzxlwcxh.ContainsKey(req.data.destLocation))
                {
                    xlReuslt = s7.ReadInt16(sxlzxlwcxh[req.data.destLocation]).Content.ToString();
                }


                //上料请求
                if (sxlzslqq.ContainsKey(req.data.location) && slReuslt != null && slReuslt!="1")
                {
                    
                    s7.Write(sxlzslqq[req.data.location], Convert.ToInt16(1));
                    Console.WriteLine(sxlzslqq[req.data.location]);
                    s7.ConnectClose();
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.RobotAction + "上料请求已发送，请点击上料按钮，"+ JsonConvert.SerializeObject(req);
                    return responseData;
                }


                if (sxlzxlqq.ContainsKey(req.data.destLocation) && xlReuslt != null && xlReuslt != "1")
                {
                    
                    s7.Write(sxlzxlqq[req.data.destLocation], Convert.ToInt16(1));
                    s7.ConnectClose();
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.RobotAction + "下料请求已发送，请点击下料按钮，" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                //判断取地址是否满足条件
                if (pointDict.ContainsKey(req.data.location))
                {
                    string location = pointDict[req.data.location]; //取
                    if (location != null)
                    {
                        string getResult = s7.ReadInt16(location).Content.ToString();
                        if (getResult != "8")
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd(ActionTypeEnum.RobotAction + "异常===>>" + "点位" + req.data.location + "取条件不满足【" + getResult + "】" + JsonConvert.SerializeObject(req),
                            EnumHelper.GetDescription(ActionTypeEnum.RobotAction));
                            responseData.result = "false";
                            responseData.msg = "异常===>>" + "点位" + req.data.location + "取条件不满足【" + getResult + "】";
                            return responseData;
                        }
                    }
                }

                //判断放地址是否满足条件
                if (pointDict.ContainsKey(req.data.destLocation))
                {
                    string destLocation = pointDict[req.data.destLocation]; //放
                    if (destLocation != null)
                    {
                        string putResult = s7.ReadInt16(destLocation).Content.ToString();
                        if (putResult != "16")
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd(ActionTypeEnum.RobotAction + "异常===>>" + "点位" + req.data.destLocation + "放条件不满足【" + putResult + "】" + JsonConvert.SerializeObject(req),
                            EnumHelper.GetDescription(ActionTypeEnum.RobotAction));
                            responseData.result = "false";
                            responseData.msg = "异常===>>" + "点位" + req.data.destLocation + "放条件不满足【" + putResult + "】";
                            return responseData;
                        }
                    }
                }



                // 查询需要操作的plc的db块
                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                //查询出需要检查的地址列表
                List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                    {

                        string operateResult = "";
                        if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.BOOL.ToString()))
                        {
                            operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.SHORT.ToString()))
                        {
                            operateResult = s7.ReadInt16(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.String.ToString()))
                        {
                            operateResult = s7.ReadString(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.Byte.ToString()))
                        {
                            operateResult = s7.ReadByte(actionAddress.Address).Content.ToString();
                        }

                        if (actionAddress.CheckType ? operateResult != actionAddress.Value : operateResult == actionAddress.Value)
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd(ActionTypeEnum.RobotAction + "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "====实际为：" + operateResult +"，要查询的参数"+ JsonConvert.SerializeObject(actionAddress) +", 请求参数"+ JsonConvert.SerializeObject(req),
                            EnumHelper.GetDescription(ActionTypeEnum.RobotAction));
                            responseData.result = "false";
                            responseData.resultMsg = "异常===>>" + "条件不满足"+ actionAddress.Description+"；采集数据：" + actionAddress.Address + "值应为：" + actionAddress.Value + "==实际为：" + operateResult;
                            return responseData;
                        }
                    }
                }

                //写入子盘编码，让plc去校验编码是否正确
                if (req.data.trayLatheType == "1")
                {
                    s7.Write("DB1001.6", ToolUtils.ReturnBtyesWtitString(req.data.trayLatheCode, 39));
                    
                }
                else if (req.data.trayLatheType == "4")
                {
                    s7.Write("DB1001.54", ToolUtils.ReturnBtyesWtitString(req.data.trayLatheCode, 39));
                }

                //查询写入地址列表
                string log = "任务【" + req.taskNodeId + "】写入:";
                List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address))
                    {
                        if (string.IsNullOrEmpty(actionAddress.Value))
                        {
                            //取参数传参值
                            string dataValue = getProperties(req.data, actionAddress.Description);
                            if (!string.IsNullOrEmpty(dataValue))
                            {
                                s7.Write(actionAddress.Address, Convert.ToInt16(dataValue));
                                log = log + "地址:" + actionAddress.Address + "【" + dataValue + "】";
                            }
                        }
                        else
                        {
                            s7.Write(actionAddress.Address, Convert.ToBoolean(actionAddress.Value));
                            log = log + "地址:" + actionAddress.Address + "【" + actionAddress.Value + "】";
                        }
                    }
                }



                s7.ConnectClose();

                //查询回调表是否存在此数据（避免在数据重复下发时，产生多条回调数据）
                TaskCallback vo = new TaskCallback(null, ActionTypeEnum.RobotAction.ToString(),
                    null, req.taskId, req.taskNodeId);

                List<TaskCallback> taskCallbackList = await _taskCallbackService.GetListByCondition(vo);
                //插入回调
                TaskCallback taskCallbackData = new TaskCallback();
                if (taskCallbackList != null && taskCallbackList.Count > 0)
                {
                    taskCallbackData = taskCallbackList[0];

                    taskCallbackData.State = true;
                }
                else
                {
                    taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.RobotAction.ToString(),
                                        EnumHelper.GetDescription(ActionTypeEnum.RobotAction), req.taskId, req.taskNodeId);
                }

                taskCallbackData = setCallBackValue(CcsActionAddresses, taskCallbackData);

                

                // 保存数据
                await _taskCallbackService.CreateOrUpdateAndCache(taskCallbackData);
                Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.RobotAction) + "命令下发成功===>>" + JsonConvert.SerializeObject(req)
                   , EnumHelper.GetDescription(ActionTypeEnum.RobotAction));
                return responseData;
            }
            catch (Exception ex)
            {
                // 记录日志
                Log.Instance.WriteLogAdd(ActionTypeEnum.RobotAction + "取放异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.RobotAction));
                responseData.resultMsg = ActionTypeEnum.RobotAction + "取放异常===>>" + ex.Message + JsonConvert.SerializeObject(req);
                responseData.result = "false";

                // 关闭plc连接
                if (s7 != null)
                {
                    s7.ConnectClose();
                }
                return responseData;
            }
        }

        public string getProperties<T>(T t, string propertyName)
        {
            string tStr = string.Empty;
            if (t == null)
            {
                return tStr;
            }
            System.Reflection.PropertyInfo[] properties = t.GetType().GetProperties(System.Reflection.BindingFlags.Instance | System.Reflection.BindingFlags.Public);

            if (properties.Length <= 0)
            {
                return tStr;
            }
            foreach (System.Reflection.PropertyInfo item in properties)
            {
                string name = item.Name;
                object value = item.GetValue(t, null);
                /*if ((item.PropertyType.IsValueType || item.PropertyType.Name.StartsWith("String")) && name == propertyName)
                {
                    tStr = value.ToString();
                    break;
                }*/

                if ((item.PropertyType.IsValueType || item.PropertyType == typeof(string))
            && string.Equals(name, propertyName, StringComparison.OrdinalIgnoreCase))
                {
                    tStr = value?.ToString() ?? string.Empty;
                    break;
                }

            }
            return tStr;
        }


        /// <summary>
        /// 天轨机器人取放动作
        /// </summary> 
        /// 

        public async Task<ResponseECSData> CutterRobotAction(RequestData<CutterLocationData> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.CutterRobotAction + "任务接受===>>" + JsonConvert.SerializeObject(req),
        EnumHelper.GetDescription(ActionTypeEnum.CutterRobotAction));

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId, "执行成功");
            SiemensS7Net s7 = null;
            try
            {

                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == req.url && x.Port == req.port).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.CutterRobotAction + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.CutterRobotAction));
                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + req.url;
                    return responseData;
                }

                // 根据ip查询设备
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.CutterRobotAction.ToString();
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                // 进行plc的连接
                s7 = DevicePlcS7.SiemensS7(actionInfo.Ip);
                OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd(ActionTypeEnum.CutterRobotAction + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.CutterRobotAction));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.CutterRobotAction + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                // 检查出发地，目的地比对数据开始====
                if (req.data.LocationDevice != null)
                {  // 判断取料设备是否满足条件
                    CcsActionDeviceSourceCheck ccsActionDeviceSourceCheck = new CcsActionDeviceSourceCheck();
                    ccsActionDeviceSourceCheck.Type = CcsActionDeviceSourceCheckTypeEnum.CHECK.ToString();
                    ccsActionDeviceSourceCheck.ActionId = actionInfo.Id;
                    ccsActionDeviceSourceCheck.DeviceCode = req.data.LocationDevice;
                    ccsActionDeviceSourceCheck.DeviceSource = "out";
                    ResponseECSCallbackData callbackData = _ccsActionDeviceSourceCheckService.checkDataAddress(ccsActionDeviceSourceCheck, s7);

                    if (!callbackData.isSuccess)
                    {
                        s7.ConnectClose();
                        Log.Instance.WriteLogAdd(ActionTypeEnum.CutterRobotAction + "====" + callbackData.msg + "====" + JsonConvert.SerializeObject(req),
                        EnumHelper.GetDescription(ActionTypeEnum.CutterRobotAction));
                        responseData.result = "false";
                        responseData.resultMsg = callbackData.msg;
                        return responseData;
                    }
                }

                if (req.data.DestLocationDevice != null)
                {
                    CcsActionDeviceSourceCheck ccsActionDeviceSourceCheck = new CcsActionDeviceSourceCheck();
                    ccsActionDeviceSourceCheck.Type = CcsActionDeviceSourceCheckTypeEnum.CHECK.ToString();
                    ccsActionDeviceSourceCheck.ActionId = actionInfo.Id;
                    ccsActionDeviceSourceCheck.DeviceCode = req.data.DestLocationDevice;
                    ccsActionDeviceSourceCheck.DeviceSource = "in";
                    ResponseECSCallbackData callbackData = _ccsActionDeviceSourceCheckService.checkDataAddress(ccsActionDeviceSourceCheck, s7);

                    if (!callbackData.isSuccess)
                    {
                        s7.ConnectClose();
                        Log.Instance.WriteLogAdd(ActionTypeEnum.CutterRobotAction + "====" + callbackData.msg + "====" + JsonConvert.SerializeObject(req),
                        EnumHelper.GetDescription(ActionTypeEnum.CutterRobotAction));
                        responseData.result = "false";
                        responseData.resultMsg = callbackData.msg;
                        return responseData;
                    }
                }
                // 检查出发地，目的地比对数据结束===


                //=========================上下料站请求判断 开始======================
                // 目标点位是上下料站的判断下料请求是否为true，上料请求为false,
                // 如果不是判断上料请求是否为true，
                // 是提示状态不对，否则写下料请求状态

                // 上料料请求
                
                //=========================上下料站请求判断 结束======================


                // 查询需要操作的plc的db块
                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                //查询出需要检查的地址列表
                List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                    {
                        string operateResult = "";
                        if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.BOOL.ToString()))
                        {
                            operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.SHORT.ToString()))
                        {
                            operateResult = s7.ReadInt16(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.String.ToString()))
                        {
                            operateResult = s7.ReadString(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.Byte.ToString()))
                        {
                            operateResult = s7.ReadByte(actionAddress.Address).Content.ToString();
                        }
                        if (actionAddress.CheckType ? operateResult != actionAddress.Value : operateResult == actionAddress.Value)
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd(ActionTypeEnum.CutterRobotAction + "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "====实际为：" + operateResult + JsonConvert.SerializeObject(req),
                            EnumHelper.GetDescription(ActionTypeEnum.CutterRobotAction));
                            responseData.result = "false";
                            responseData.resultMsg = "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "==实际为：" + operateResult;
                            return responseData;
                        }
                    }
                }

                // 报文
                string baowen = null;

                //查询需要写入地址列表
                List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address))
                    {
                        string parValue = "";
                        // 写入取放点位、需要进行点位拼接
                        if (actionAddress.Sort == 1)
                        {
                            //区域块为七位，点位为三位
                            //parValue = req.data.LocationArea.PadRight(7,'0')+ req.data.Location.PadLeft(3, '0') + req.data.DestLocationArea.PadRight(7, '0') + req.data.DestLocation.PadLeft(3, '0');
                            parValue = req.data.Location + req.data.DestLocation;
                            baowen = Convert.ToString(parValue);
                            s7.Write(actionAddress.Address, baowen);
                        }
                        else if (actionAddress.Sort == 2)
                        {
                            // 需要写入启动状态
                            parValue = actionAddress.Value;
                            s7.Write(actionAddress.Address, Convert.ToBoolean(parValue));
                        }
                        else if (actionAddress.Sort == 3)
                        {
                            // 写入源刀位号
                            parValue = req.data.LocationNo;
                            if (req.data.LocationNo == null || req.data.LocationNo == "")
                            {
                                parValue = "0";
                            }
                            s7.Write(actionAddress.Address, Convert.ToByte(parValue));
                        }
                        else if (actionAddress.Sort == 4)
                        {
                            // 写入目的刀位号
                            parValue = req.data.DestLocationNo;
                            if (req.data.DestLocationNo == null || req.data.DestLocationNo == "")
                            {
                                parValue = "0";
                            }
                            s7.Write(actionAddress.Address, Convert.ToByte(parValue));
                        }
                        else if (actionAddress.Sort == 5) {
                            parValue = req.data.rfid;
                            s7.Write(actionAddress.Address, Convert.ToInt16(parValue));
                        }

                        // 同步TagValue数据状态
                        CcsTagValue tagValueQuery = new CcsTagValue();
                        tagValueQuery.Ip = req.url;
                        tagValueQuery.Address = actionAddress.Address;
                        CcsTagValue tagValue = _ccsTagValueService.GetList(tagValueQuery).ToList().FirstOrDefault();
                        if (tagValue != null)
                        {
                            tagValue.TagValue = parValue;
                            await _ccsTagValueService.Update(tagValue);
                        }


                        Thread.Sleep(SLEEP_TIME);
                    }
                }

                s7.ConnectClose();

                //插入回调
                TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.CutterRobotAction.ToString(),
                    EnumHelper.GetDescription(ActionTypeEnum.CutterRobotAction), req.taskId, req.taskNodeId);
                taskCallbackData = setCallBackValue(CcsActionAddresses, taskCallbackData);

                //比较数据设为动态数据
                taskCallbackData.CallBackCheckAddressValue = baowen;

                // 保存数据
                await _taskCallbackService.CreateOrUpdateAndCache(taskCallbackData);
                Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.CutterRobotAction) + "命令下发成功===>>" + JsonConvert.SerializeObject(req)
                   , EnumHelper.GetDescription(ActionTypeEnum.CutterRobotAction));
                return responseData;
            }
            catch (Exception ex)
            {
                // 记录日志
                Log.Instance.WriteLogAdd(ActionTypeEnum.CutterRobotAction + "取放异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.CutterRobotAction));
                responseData.resultMsg = ActionTypeEnum.CutterRobotAction + "取放异常===>>" + ex.Message + JsonConvert.SerializeObject(req);
                responseData.result = "false";

                // 关闭plc连接
                if (s7 != null)
                {
                    s7.ConnectClose();
                }
                return responseData;
            }
        }

        /// <summary>
        /// CNC刀具库请求上下料动作
        /// </summary>
        /// <param name="req"></param>
        /// <returns></returns>
        public async Task<ResponseECSData> CutterDeviceTakeOrPutRequest(RequestData<CutterLocationData> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.CutterCncDeviceAction + "任务接受===>>" + JsonConvert.SerializeObject(req),
        EnumHelper.GetDescription(ActionTypeEnum.CutterCncDeviceAction));

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId, "执行成功");
            SiemensS7Net s7 = null;
            String dizhi = "";
            try
            {
                dizhi = req.data.Location;
                if (req.data.Location == null) {
                    dizhi = req.data.DestLocation;
                }

                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == req.url && x.Port == req.port).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.CutterCncDeviceAction+ dizhi + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.CutterCncDeviceAction));
                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + req.url;
                    return responseData;
                }

                // 根据ip查询设备
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.CutterCncDeviceAction.ToString() + dizhi;
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                // 进行plc的连接
                s7 = DevicePlcS7.SiemensS7(actionInfo.Ip);
                OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd(ActionTypeEnum.CutterCncDeviceAction + dizhi + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.CutterCncDeviceAction));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.CutterCncDeviceAction + dizhi + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                // 查询需要操作的plc的db块
                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                //查询出需要检查的地址列表
                List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                    {

                        string operateResult = "";
                        if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.BOOL.ToString()))
                        {
                            operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.SHORT.ToString()))
                        {
                            operateResult = s7.ReadInt16(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.String.ToString()))
                        {
                            operateResult = s7.ReadString(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.Byte.ToString()))
                        {
                            operateResult = s7.ReadByte(actionAddress.Address).Content.ToString();
                        }

                        if (actionAddress.CheckType ? operateResult != actionAddress.Value : operateResult == actionAddress.Value)
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd(ActionTypeEnum.CutterCncDeviceAction + dizhi + "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "====实际为：" + operateResult + JsonConvert.SerializeObject(req),
                            EnumHelper.GetDescription(ActionTypeEnum.CutterCncDeviceAction));
                            responseData.result = "false";
                            responseData.resultMsg = "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "==实际为：" + operateResult;
                            return responseData;
                        }
                    }
                }

                //查询需要写入地址列表
                List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address))
                    {
                        string parValue = "";
                        // 写入取放点位、需要进行点位拼接
                        if (actionAddress.Sort == 1)
                        {

                            string before = "EMPTY00000";
                            if (req.data.Location != null && req.data.Location.Length>0) {

                                int separatorIndex = req.data.LocationNo.IndexOf(".");
                                string substring = req.data.LocationNo.Substring(separatorIndex+1); // 从第7个字符开始截取5个字符
                                int num = int.Parse(substring);
                                string formatted = num.ToString("D2");  

                                before = "ATC00" + formatted + req.data.Location.Substring(7, 3);
                            }
                            string theTail = "EMPTY00000";
                            if (req.data.DestLocation != null && req.data.DestLocation.Length>0) {

                                int separatorIndex = req.data.DestLocationNo.IndexOf(".");
                                string substring = req.data.DestLocationNo.Substring(separatorIndex+1); // 从第7个字符开始截取5个字符
                                int num = int.Parse(substring);
                                string formatted = num.ToString("D2");


                                theTail = "ATC00" + formatted + req.data.DestLocation.Substring(7, 3);
                            }
                            parValue = before + theTail;

                            s7.Write(actionAddress.Address, Convert.ToString(parValue));
                        }
                        else if (actionAddress.Sort == 2)
                        {
                            // 需要写入启动状态
                            parValue = actionAddress.Value;
                            s7.Write(actionAddress.Address, Convert.ToBoolean(parValue));
                        }
                        

                        // 同步TagValue数据状态
                        CcsTagValue tagValueQuery = new CcsTagValue();
                        tagValueQuery.Ip = req.url;
                        tagValueQuery.Address = actionAddress.Address;
                        CcsTagValue tagValue = _ccsTagValueService.GetList(tagValueQuery).ToList().FirstOrDefault();
                        if (tagValue != null)
                        {
                            tagValue.TagValue = parValue;
                            await _ccsTagValueService.Update(tagValue);
                        }

                        Log.Instance.WriteLogAdd(ActionTypeEnum.CutterCncDeviceAction + "CNC刀具库请求上下料动作数据写入成功===>>" + JsonConvert.SerializeObject(tagValue),
                            EnumHelper.GetDescription(ActionTypeEnum.CutterCncDeviceAction));

                        Thread.Sleep(SLEEP_TIME);
                    }
                }

                s7.ConnectClose();
                
                return responseData;
            }
            catch (Exception ex)
            {
                // 记录日志
                Log.Instance.WriteLogAdd(ActionTypeEnum.CutterCncDeviceAction + dizhi + "取放异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.CutterCncDeviceAction));
                responseData.resultMsg = ActionTypeEnum.CutterCncDeviceAction + dizhi + "取放异常===>>" + ex.Message + JsonConvert.SerializeObject(req);
                responseData.result = "false";

                // 关闭plc连接
                if (s7 != null)
                {
                    s7.ConnectClose();
                }
                return responseData;
            }
        }




        /// <summary>
        /// 上传文件
        /// </summary> 
        public async Task<ResponseECSData> UploadFile(RequestData<UploadFileData> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "任务接受===>>" + JsonConvert.SerializeObject(req),
                            EnumHelper.GetDescription(ActionTypeEnum.UploadFile));

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);

            try
            {
                List<Device> devices = _deviceService.GetDeviceList();
                Device deviceFtp = devices.Where(x => x.Ip.Equals(req.url)
                                            && x.ProtocolType.Equals(ProtocalTypeEnum.FTP.ToString())).FirstOrDefault();
                Device deviceOpcUa = devices.Where(x => x.Ip.Equals(req.url)
                                           && x.ProtocolType.Equals(ProtocalTypeEnum.OPCUA.ToString())).FirstOrDefault();
           
                Device deviceHeidenhain = devices.Where(x => x.Ip.Equals(req.url)
                                            && x.ProtocolType.Equals(ProtocalTypeEnum.HEIDEHAIN.ToString())).FirstOrDefault();

                if (deviceOpcUa == null && deviceHeidenhain == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.UploadFile + "设备已离线===>>" + JsonConvert.SerializeObject(req);
                    return responseData;
                }
                //西门子系统上传
                if (deviceOpcUa != null)
                {
                    RequestOpcUaData opcUaReq = new RequestOpcUaData();
                    opcUaReq.ServerUrl = deviceOpcUa.ServerUrl;
                    opcUaReq.UserName = deviceOpcUa.UserName;
                    opcUaReq.Password = deviceOpcUa.Password;
                    opcUaReq.Path = req.data.fileName;
                    opcUaReq.Type = OpcUaActionTypeEnum.Upload.ToString();
                    var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, opcuacUrlContext, opcUaReq, null);
                    ResponseOpcUaData responseOpcUaData = JsonConvert.DeserializeObject<ResponseOpcUaData>(Result.Message);
                    if (!Result.IsSuccess || !responseOpcUaData.result)
                    {
                        Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "上传异常===>>" + JsonConvert.SerializeObject(req),
                       EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
                        responseData.result = "false";
                        responseData.resultMsg = Result.Message;
                        return responseData;
                    }
                }
                else if(deviceHeidenhain != null)
                { 
                 
                    RequestHeidhData hdhReq = new RequestHeidhData();
                    hdhReq.ServerUrl = deviceHeidenhain.ServerUrl;
                    hdhReq.MachineName = deviceHeidenhain.UserName;
                    hdhReq.Path = req.data.fileName;
                    hdhReq.Type = OpcUaActionTypeEnum.Upload.ToString();
                    //远程机床相对路径
                    hdhReq.Address = req.data.remotePath;
                    var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
                    ResponseHeidhData responseHeidhData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
                    if (!Result.IsSuccess || !responseHeidhData.result)
                    {
                        Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "预上传异常===>>" + JsonConvert.SerializeObject(req),
                        EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
                        responseData.result = "false";
                        responseData.resultMsg = responseHeidhData.msg;
                        return responseData;
                    }  
                }  
                //插入回调
                TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.UploadFile.ToString(),
                EnumHelper.GetDescription(ActionTypeEnum.UploadFile), req.taskId, req.taskNodeId);
                await _taskCallbackService.CreateOrUpdateAndCache(taskCallbackData);

                Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "上传成功===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
                return responseData;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "上传异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
                responseData.resultMsg = ActionTypeEnum.UploadFile + "上传异常===>>" + ex.Message + JsonConvert.SerializeObject(req);
                responseData.result = "false";
                return responseData;
            }
        }

       
        /// <summary>
        /// 启动机床程序
        /// </summary> 
        public async Task<ResponseECSData> StartNCProgram(RequestData<StartNCProgramData> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "任务接受===>>" + JsonConvert.SerializeObject(req),
                EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
            try
            {
                List<Device> devices = _deviceService.GetDeviceList();

                Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.StartNCProgram + "设备已离线===>>" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.StartNCProgram.ToString();
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
                //opcua启动程序
                if (actionInfo.ProtocolType == ProtocalTypeEnum.OPCUA.ToString())
                { 
                    //插入回调
                    //获取启动前放的 工位
                    TaskCallback queryTaskCallBack = new TaskCallback();
                    queryTaskCallBack.IP = actionInfo.PlcIp;
                    queryTaskCallBack.Description = ProtocalTypeEnum.OPCUA.ToString();
                    TaskCallback TaskBean = await _taskCallbackService.GetRobotActionList(queryTaskCallBack);

                    TaskCallback taskCallbackData = new TaskCallback(actionInfo.PlcIp, ActionTypeEnum.StartNCProgram.ToString(),
                    EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram), req.taskId, req.taskNodeId);
                    taskCallbackData = setCallBackValue(CcsActionAddresses, taskCallbackData);
                    taskCallbackData.Description = ProtocalTypeEnum.OPCUA.ToString();
                    if(TaskBean != null)
                    {
                        taskCallbackData.Data = TaskBean.Data;
                    }
                    else
                    {
                       Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "失败,上一放动作 没有工位信息===>>" + JsonConvert.SerializeObject(req),
                      EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
                        return responseData;
                    }
                    
                    await _taskCallbackService.CreateOrUpdateAndCache(taskCallbackData);
                    Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动成功===>>" + JsonConvert.SerializeObject(req),
                        EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
                    return responseData; 

                } 
                else if (actionInfo.ProtocolType == ProtocalTypeEnum.HEIDEHAIN.ToString()) 
                {
                    //调用机器人plc启动海德汉程序 
                    //SiemensS7Net s7 = DevicePlcS7.SiemensS7(actionInfo.PlcIp);
                    //OperateResult ConnectionResult = s7.ConnectServer();
                    //if (!ConnectionResult.IsSuccess)
                    //{
                    //    s7.ConnectClose();
                    //    Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                    //    EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
                    //    responseData.result = "false";
                    //    return responseData;
                    //}

                    ////查询条件
                    //List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
                    //foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
                    //{
                    //    if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                    //    {

                    //        string operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                    //        if (actionAddress.CheckType ? operateResult.Equals(actionAddress.Value) : operateResult != actionAddress.Value)
                    //        {
                    //            s7.ConnectClose();
                    //            Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
                    //            EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
                    //            responseData.result = "false";
                    //            return responseData;
                    //        }
                    //    }
                    //}


                    //s7.ConnectClose();

                    Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "任务接受===>>" + JsonConvert.SerializeObject(req),
                        EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));

                    RequestHeidhData hdhReq = new RequestHeidhData();
                    hdhReq.ServerUrl = device.ServerUrl;
                    hdhReq.MachineName = device.UserName;
                    hdhReq.Path = req.data.remotePath;
                    hdhReq.Type = OpcUaActionTypeEnum.StartNcProgram.ToString();

                    var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
                    ResponseHeidhData responseHeidhData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
                    if (!Result.IsSuccess || !responseHeidhData.result)
                    {
                        Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动异常===>>" + JsonConvert.SerializeObject(req),
                        EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
                        responseData.result = "false";
                        responseData.resultMsg = responseHeidhData.msg;
                        responseData.resultMsg = ActionTypeEnum.StartNCProgram + "启动异常===>>" + JsonConvert.SerializeObject(req);
                        return responseData;
                    }

                    //插入回调
                    TaskCallback taskCallbackData = new TaskCallback(actionInfo.PlcIp, ActionTypeEnum.StartNCProgram.ToString(),
                    EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram), req.taskId, req.taskNodeId);

                    await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
                    Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "调用成功===>>" + JsonConvert.SerializeObject(req),
                        EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));                    
                    return responseData;
                }
                else
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动异常===>>" + JsonConvert.SerializeObject(req),
                     EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.StartNCProgram + "启动异常===>>" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "程序异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
                responseData.result = "false";
                return responseData;
            }
        }
    

        /// <summary>
        /// 启动清洗机
        /// </summary> 
        public async Task<ResponseECSData> StartCleanMachine(RequestData<object> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.StartCleanMachine + "任务接受===>>" + JsonConvert.SerializeObject(req),
    EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
            try
            {
                List<Device> devices = _deviceService.GetDeviceList();

                Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.StartCleanMachine + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));
                    responseData.result = "false";
                    responseData.resultMsg= ActionTypeEnum.StartCleanMachine + "设备已离线===>>" + JsonConvert.SerializeObject(req);
                    return responseData;

                }
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.StartCleanMachine.ToString();
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault(); 

                SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
                HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
              
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd(ActionTypeEnum.StartCleanMachine + "启动故障===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));
                    responseData.result = "false";
                    return responseData;
                }

                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                     
                s7.ConnectClose();

                //插入回调
                TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.StartCleanMachine.ToString(),
                    EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine), req.taskId, req.taskNodeId);
                await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));

                Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine) + "启动成功===>>" + JsonConvert.SerializeObject(req)
                   , EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));
                return responseData;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd(ActionTypeEnum.StartCleanMachine + "启动故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));
                responseData.result = "false";
                return responseData;
            }
        }

        /// <summary>
        /// 启动吹干
        /// </summary> 
        public async Task<ResponseECSData> StartDryMachine(RequestData<object> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.StartDryMachine + "任务接受===>>" + JsonConvert.SerializeObject(req),
EnumHelper.GetDescription(ActionTypeEnum.StartDryMachine));

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
            try
            {
                List<Device> devices = _deviceService.GetDeviceList();

                Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.StartDryMachine + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.StartDryMachine));
                    responseData.result = "false";
                    return responseData;

                }

                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.StartDryMachine.ToString();
                actionQuery.Ip = req.url;
                CcsAction action = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = action.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
                HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd(ActionTypeEnum.StartDryMachine + "启动吹干机异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.StartDryMachine));
                    responseData.result = "false";
                    return responseData;
                } 

                s7.ConnectClose();

                //插入回调
                TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.StartDryMachine.ToString(),
                    EnumHelper.GetDescription(ActionTypeEnum.StartDryMachine), req.taskId, req.taskNodeId); 
                await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
                Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.StartDryMachine) + "启动吹干机成功===>>" + JsonConvert.SerializeObject(req)
                   , EnumHelper.GetDescription(ActionTypeEnum.StartDryMachine));
                return responseData;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd(ActionTypeEnum.StartDryMachine + "启动吹干机故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.StartDryMachine));
                responseData.result = "false";
                return responseData;
            }
        }

        
       

        /// <summary>
        /// 刀具接口列表
        /// </summary> 
        public async Task<ResponseData<List<ResponseToolData>>> GetTools(RequestToolData req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.ToolList + "任务接受===>>" + JsonConvert.SerializeObject(req),
                EnumHelper.GetDescription(ActionTypeEnum.ToolList));

            ResponseData<List<ResponseToolData>> responseData = new ResponseData<List<ResponseToolData>>();
            responseData.result = "true";

            List<Device> devices = _deviceService.GetDeviceList();

            List<Device> deviceList = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).ToList();

            if (deviceList ==null || deviceList.Count <= 0) {
                throw new InvalidOperationException("没查询到在线设备数据");
            }

            Device device = deviceList.FirstOrDefault();
            List<ResponseToolData> list = new List<ResponseToolData>();

            if (device.ProtocolType == ProtocalTypeEnum.OPCUA.ToString())
            {
                CcsTagValue tagValueQuery = new CcsTagValue();
                tagValueQuery.Ip = req.url;
                tagValueQuery.Component = "刀具";
                List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery);
                List<CcsTagValue> toolNumberList = tagValues.GroupBy(x => x.ComponentNumber)
                .Select(group => new CcsTagValue
                {
                    ComponentNumber = group.Key
                }).ToList();
                foreach (CcsTagValue toolNumber in toolNumberList)
                {
                    ResponseToolData toolData = new ResponseToolData();
                    foreach (CcsTagValue tagValue in tagValues)
                    {
                        if (toolNumber.ComponentNumber == tagValue.ComponentNumber)
                        {
                            toolData.number = toolNumber.ComponentNumber;
                            if (tagValue.Description == "刀具寿命预警")
                            {
                                toolData.warnLife = tagValue.TagValue;
                            }
                            else if (tagValue.Description == "刀具寿命目标值")
                            {
                                toolData.targetLife = tagValue.TagValue;
                            }
                            else if (tagValue.Description == "工件数")
                            {
                                toolData.workPiece = tagValue.TagValue;
                            }
                            else if (tagValue.Description == "工件数预警值")
                            {
                                toolData.workPieceWarn = tagValue.TagValue;
                            }
                            else if (tagValue.Description == "工件数目标值")
                            {
                                toolData.workPieceTarget = tagValue.TagValue;
                            }
                            else if (tagValue.Description == "磨损量")
                            {
                                toolData.wear = tagValue.TagValue;
                            }
                            else if (tagValue.Description == "磨损量预警值")
                            {
                                toolData.wearWarn = tagValue.TagValue;
                            }
                            else if (tagValue.Description == "磨损量目标值")
                            {
                                toolData.wearTarget = tagValue.TagValue;
                            }
                            else if (tagValue.Description == "刀具名称")
                            {
                                toolData.name = tagValue.TagValue;
                            }
                        }

                    }

                    list.Add(toolData);


                }
            }
            else if (device.ProtocolType == ProtocalTypeEnum.FANUC.ToString())
            {
                string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
                //调用发那科接口
                var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=ToolList", null, null);

                if (Result.IsSuccess)
                {
                    List<ResponseToolData> responseFanucData = JsonConvert.DeserializeObject<List<ResponseToolData>>(Result.Message);
                    //list = JsonConvert.DeserializeObject<List<ResponseToolData>>(Result.Message.ToolLife);                    
                    //list = JsonConvert.DeserializeObject<List<ResponseToolData>>(responseFanucData.ToolLife);
                    list = responseFanucData;
                }
                else {
                    responseData.result = "false";
                    responseData.Msg = Result.Message;
                }
            }
            else if(device.ProtocolType == ProtocalTypeEnum.HEIDEHAIN.ToString())
            {

                //检查机床是否在线，双层校验，检查PLC的DB块
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.CNCIsOnline.ToString();
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
                if (actionInfo != null) {
                    //连接PLC
                    SiemensS7Net s7 = DevicePlcS7.SiemensS7(actionInfo.PlcIp);
                    HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();

                    if (!ConnectionResult.IsSuccess)
                    {
                        s7.ConnectClose();
                        Log.Instance.WriteLogAdd(ActionTypeEnum.CNCIsOnline + "启动故障===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                        EnumHelper.GetDescription(ActionTypeEnum.ToolList));
                        responseData.result = "false";
                        return responseData;
                    }

                    CcsActionAddress actionAddressQuery = new CcsActionAddress();
                    actionAddressQuery.ActionId = actionInfo.Id;
                    List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                    // 检查字段
                    foreach (CcsActionAddress actionAddress in CcsActionAddresses)
                    {
                        if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                        {

                            string operateResult = "";
                            if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.BOOL.ToString()))
                            {
                                operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                            }
                            else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.SHORT.ToString()))
                            {
                                operateResult = s7.ReadInt16(actionAddress.Address).Content.ToString();
                            }
                            else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.String.ToString()))
                            {
                                operateResult = s7.ReadString(actionAddress.Address).Content.ToString();
                            }
                            else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.Byte.ToString()))
                            {
                                operateResult = s7.ReadByte(actionAddress.Address).Content.ToString();
                            }

                            if (actionAddress.CheckType ? operateResult != actionAddress.Value : operateResult == actionAddress.Value)
                            {
                                s7.ConnectClose();
                                Log.Instance.WriteLogAdd(ActionTypeEnum.CNCIsOnline + "机床不在线===>>" + "条件不满足,参数："+ actionAddress.Address,
                                EnumHelper.GetDescription(ActionTypeEnum.ToolList));
                                responseData.result = "false";
                                responseData.Msg = "机床不在线，条件不满足：" + actionAddress.Address;
                                return responseData;
                            }
                        }
                    }
                }

                // 读取机床刀具数据
                RequestHeidhData hdhReq = new RequestHeidhData();
                hdhReq.ServerUrl = device.ServerUrl;
                hdhReq.MachineName = device.UserName;
                hdhReq.Type = ActionTypeEnum.ToolList.ToString();
                var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
                if (Result.IsSuccess)
                {
                    ResponseHeidhData response = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
                    list = JsonConvert.DeserializeObject<List<ResponseToolData>>(response.toolsInfo);

                }
                else
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.ToolList + "任务执行失败===>>" + JsonConvert.SerializeObject(Result),
    EnumHelper.GetDescription(ActionTypeEnum.ToolList));

                    responseData.result = "false";
                    responseData.Msg = Result.Message;
                }
            }

            responseData.Data = list;
            responseData.Total = list.Count;

            return responseData;
        }

      

        /// <summary>
        /// 设备上线离线
        /// </summary> 
        public async Task<ResponseCommonData> UpdateDeviceState(RequestDeviceUpdateData req)
        {
            ResponseCommonData responseData = new ResponseCommonData();
            List<Device> devices = _deviceService.GetDevices();
            try
            {
                Device device = devices.Where(x => x.Ip == req.ip).FirstOrDefault();

                if (device == null)
                {
                    responseData.msg = "设备不存在";
                    responseData.result = "false";
                    return responseData;
                }
                device.UseState = req.useState;
                device.OfflineUpdateTime = DateTime.Now;
                await _deviceService.UpdateAndCache(device); 
                return responseData;
            }
            catch (Exception ex)
            {
                responseData.msg = ex.Message;
                responseData.result = "false";
                return responseData;
            }
        }
        /// <summary>
        /// 获取回调列表
        /// </summary> 
        public async Task<List<TaskCallback>> GetCallBackListByCondition(RequestCallBackData vo)
        {
            List<TaskCallback> list = new List<TaskCallback>();
            try {
                TaskCallback taskCallback = new TaskCallback();
                if (!string.IsNullOrEmpty(vo.IP))
                {
                    taskCallback.IP = vo.IP;
                } 
                if (!string.IsNullOrEmpty(vo.TaskId))
                {
                    taskCallback.TaskId = vo.TaskId;
                }
                if (!string.IsNullOrEmpty(vo.TaskNodeId))
                {
                    taskCallback.TaskNodeId = vo.TaskNodeId;
                }
                list = await _taskCallbackService.GetListByCondition(taskCallback);

            }
            catch (Exception ex)
            { 
                return list;
            }
            return list;
        }
 

        //设置回调值
        private TaskCallback setCallBackValue(List<CcsActionAddress> CcsActionAddresses, TaskCallback taskCallbackData)
        {

            List<CcsActionAddress> CcsActionAddressCallBackChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CALLBACK_CHECK.ToString()).ToList();
            List<CcsActionAddress> CcsActionAddressCallBacks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CALLBACK.ToString()).ToList();
            List<CcsActionAddress> CcsActionAddressCallBackFails = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CALLBACK_FAIL.ToString()).ToList();
            List<CcsActionAddress> CcsActionAddressCallBackResets = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.RESET.ToString()).ToList();

            // 回调检查项
            foreach (var item in CcsActionAddressCallBackChecks)
            {
                if (item.Sort == 1)
                {
                    taskCallbackData.CallBackCheckAddress = item.Address;
                    taskCallbackData.CallBackCheckAddressValue = item.Value;
                }

            }


            foreach (CcsActionAddress actionAddress in CcsActionAddressCallBacks)
            {
                if (actionAddress.Sort == 1)
                {
                    taskCallbackData.Address = actionAddress.Address;
                    taskCallbackData.CallbackValue = actionAddress.Value;
                }
                else if (actionAddress.Sort == 2)
                {
                    taskCallbackData.Address2 = actionAddress.Address;
                    taskCallbackData.CallbackValue2 = actionAddress.Value;
                }
                else if (actionAddress.Sort == 3)
                {
                    taskCallbackData.Address3 = actionAddress.Address;
                    taskCallbackData.CallbackValue3 = actionAddress.Value;
                }
            }
            foreach (CcsActionAddress actionAddress in CcsActionAddressCallBackFails)
            {
                if (actionAddress.Sort == 1)
                {
                    taskCallbackData.FailAddress = actionAddress.Address;
                    taskCallbackData.CallbackFailValue = actionAddress.Value;
                }
                else if (actionAddress.Sort == 2)
                {
                    taskCallbackData.FailAddress2 = actionAddress.Address;
                    taskCallbackData.CallbackFailValue2 = actionAddress.Value;
                }
                else if (actionAddress.Sort == 3)
                {
                    taskCallbackData.FailAddress3 = actionAddress.Address;
                    taskCallbackData.CallbackFailValue3 = actionAddress.Value;
                }
            }
            foreach (CcsActionAddress actionAddress in CcsActionAddressCallBackResets)
            {
                if (actionAddress.Sort == 1)
                {
                    taskCallbackData.SuccessResetAddress = actionAddress.Address;
                    taskCallbackData.SuccessResetValue = actionAddress.Value;
                }
                else if (actionAddress.Sort == 2)
                {
                    taskCallbackData.SuccessResetAddress2 = actionAddress.Address;
                    taskCallbackData.SuccessResetValue2 = actionAddress.Value;
                }
                
            }
            taskCallbackData.FailNumber = 0;    

            return taskCallbackData;
        }

        public async Task<ResponseECSData> PushPushToMachine(RequestData<CutterTestData> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.ReadAndWriteTool + "任务接受===>>" + JsonConvert.SerializeObject(req),
                EnumHelper.GetDescription(ActionTypeEnum.ReadAndWriteTool));

            // 1、根据url查询设备信息   2、调用httpserveer 发送执行消息

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
            try
            {
                List<Device> devices = _deviceService.GetDeviceList();

                Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.ReadAndWriteTool + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.ReadAndWriteTool));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.ReadAndWriteTool + "设备已离线===>>" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                if (device.ProtocolType == ProtocalTypeEnum.HEIDEHAIN.ToString())
                {

                    RequestHeidhData hdhReq = new RequestHeidhData();
                    hdhReq.ServerUrl = device.ServerUrl;
                    hdhReq.MachineName = device.UserName;
                    hdhReq.Type = ActionTypeEnum.ReadAndWriteTool.ToString();
                    hdhReq.CutterData = JsonConvert.SerializeObject(req.data);

                    var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
                    ResponseHeidhData responseHeidhData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
                    JObject jsonObject = JObject.Parse(Result.Message);
                    
                    if (!Result.IsSuccess || !responseHeidhData.result)
                    {
                        Log.Instance.WriteLogAdd(ActionTypeEnum.ReadAndWriteTool + "机外对刀仪数据上传异常1===>>" +  Result,
                            EnumHelper.GetDescription(ActionTypeEnum.ReadAndWriteTool));

                        responseData.result = "false";
                        responseData.resultMsg = jsonObject.GetValue("msg").ToString();
                    }
                    else
                    {
 
                        if (jsonObject.GetValue("result")!=null  && bool.Parse(jsonObject.GetValue("result").ToString())) { 
                            responseData.result = "true";
                            responseData.resultMsg = jsonObject.GetValue("msg").ToString();
                            responseData.returnData = jsonObject.GetValue("returnData").ToString();

                        }
                        else {
                            Log.Instance.WriteLogAdd(ActionTypeEnum.ReadAndWriteTool + "机外对刀仪数据上传异常2===>>" + Result,
                                EnumHelper.GetDescription(ActionTypeEnum.ReadAndWriteTool));

                            responseData.result = "false";
                            responseData.resultMsg = jsonObject.GetValue("msg").ToString();
                        }
                    }
                }
                else {
                    responseData.result = "false";
                    responseData.resultMsg = "没找到对应的类型方法";
                }
            }
            catch (Exception ex) {
                Log.Instance.WriteLogAdd(ActionTypeEnum.ReadAndWriteTool + "任务下发异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.ReadAndWriteTool));

                responseData.result = "false";
                responseData.resultMsg = ex.Message;
                return responseData;
            }


            return responseData;    
        }



        /// <summary>
        /// 查询三坐标是否允许取
        /// </summary> 
        public async Task<ResponseECSData> GetMiddleThreeCoordinates(RequestData<RequestToolData> req) {
            Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalTakeStatus + "任务接受===>>" + JsonConvert.SerializeObject(req),
                EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalTakeStatus));

            // 1、根据url查询设备信息   2、调用httpserveer 发送执行消息
            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId, "允许下料");
            SiemensS7Net s7 = null;
            try
            {
                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == req.url && x.Port == req.port).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalTakeStatus + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalTakeStatus));
                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + req.url;
                    return responseData;
                }

                // 根据ip查询配置的字节数据
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.ThreeDimensionalTakeStatus.ToString();
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                // 进行plc的连接
                s7 = DevicePlcS7.SiemensS7(actionInfo.Ip);
                OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalTakeStatus + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),"三坐标");
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.ThreeDimensionalTakeStatus + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                // 查询需要操作的plc的db块
                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                //查询出需要检查的地址列表
                List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                    {
                        string operateResult = "";
                        if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.BOOL.ToString()))
                        {
                            operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.SHORT.ToString()))
                        {
                            operateResult = s7.ReadInt16(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.String.ToString()))
                        {
                            operateResult = s7.ReadString(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.Byte.ToString()))
                        {
                            operateResult = s7.ReadByte(actionAddress.Address).Content.ToString();
                        }

                        if (actionAddress.CheckType ? operateResult != actionAddress.Value : operateResult == actionAddress.Value)
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalTakeStatus + "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "====实际为：" + operateResult + JsonConvert.SerializeObject(req),
                                EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalTakeStatus));

                            responseData.result = "false";
                            responseData.resultMsg = "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "==实际为：" + operateResult;
                            return responseData;
                        }
                    }
                }

                //  关闭连接
                s7.ConnectClose();

            }
            catch (Exception ex)
            {
                s7.ConnectClose();
                Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalTakeStatus + "任务下发异常===>>" + ex.Message + JsonConvert.SerializeObject(req), 
                    EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalTakeStatus));

                responseData.result = "false";
                responseData.resultMsg = ex.Message;
                return responseData;
            }

            return responseData;
        }

        /// <summary>
        /// 查询三坐标是否允许放
        /// </summary> 
        public async Task<ResponseECSData> QueryThreeCoordinatesFreePos(RequestData<RequestToolData> req) {

            Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalPutStatus + "任务接受===>>" + JsonConvert.SerializeObject(req),
                EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalPutStatus));

            // 1、根据url查询设备信息   2、调用httpserveer 发送执行消息
            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId, "允许上料");
            SiemensS7Net s7 = null;
            try
            {
                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == req.url && x.Port == req.port).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalPutStatus + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalPutStatus));
                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + req.url;
                    return responseData;
                }

                // 根据ip查询配置的字节数据
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.ThreeDimensionalPutStatus.ToString();
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                // 进行plc的连接
                s7 = DevicePlcS7.SiemensS7(actionInfo.Ip);
                OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalPutStatus + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalPutStatus));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.ThreeDimensionalPutStatus + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                // 查询需要操作的plc的db块
                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                //查询出需要检查的地址列表
                List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                    {
                        string operateResult = "";                        
                        if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.BOOL.ToString()))
                        {
                            operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.SHORT.ToString()))
                        {
                            operateResult = s7.ReadInt16(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.String.ToString()))
                        {
                            operateResult = s7.ReadString(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.Byte.ToString()))
                        {
                            operateResult = s7.ReadByte(actionAddress.Address).Content.ToString();
                        }
                      
                        if (actionAddress.CheckType ? operateResult != actionAddress.Value : operateResult == actionAddress.Value)
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalPutStatus + "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "====实际为：" + operateResult + JsonConvert.SerializeObject(req),
                            EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalPutStatus));

                            responseData.result = "false";
                            responseData.resultMsg = "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "==实际为：" + operateResult;
                            return responseData;
                        }
                    }
                }

                //  关闭连接
                s7.ConnectClose();

            }
            catch (Exception ex)
            {
                //  关闭连接
                s7.ConnectClose();

                Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalPutStatus + "任务下发异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalPutStatus));

                responseData.result = "false";
                responseData.resultMsg = ex.Message;
                return responseData;
            }

            return responseData;
        }


        
        /// <summary>
        /// 三坐标启动
        /// </summary> 
        public async Task<ResponseECSData> SendThreeCoordinates(RequestData<ThreeDimensional> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalRun + "任务接受===>>" + JsonConvert.SerializeObject(req),
                EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalRun));

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId, "执行成功");
            SiemensS7Net s7 = null;
            try
            {

                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == req.url && x.Port == req.port).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalRun + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalRun));
                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + req.url;
                    return responseData;
                }

                // 根据ip查询设备
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.ThreeDimensionalRun.ToString();
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                // 进行plc的连接
                s7 = DevicePlcS7.SiemensS7(actionInfo.Ip);
                OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalRun + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalRun));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.ThreeDimensionalRun + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                // 查询需要操作的plc的db块
                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                //查询出需要检查的地址列表
                List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                    {
                        string operateResult = s7.ReadByte(actionAddress.Address).Content.ToString();
                        if (actionAddress.CheckType ? operateResult != actionAddress.Value : operateResult == actionAddress.Value)
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalRun + "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "====实际为：" + operateResult + JsonConvert.SerializeObject(req),
                            EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalRun));
                            responseData.result = "false";
                            responseData.resultMsg = "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "==实际为：" + operateResult;
                            return responseData;
                        }
                    }
                }

                //查询需要写入地址列表
                List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address))
                    {
                        string parValue = "";
                        // 写入取放点位、需要进行点位拼接
                        if (actionAddress.Sort == 1)
                        {
                            parValue = req.data.workType;
                            s7.Write(actionAddress.Address, Convert.ToString(parValue));
                        }
                        else if (actionAddress.Sort == 2)
                        {
                            // 需要写入启动状态
                            parValue = actionAddress.Value;
                            s7.Write(actionAddress.Address, Convert.ToBoolean(parValue));
                        }

                        // 同步TagValue数据状态
                        CcsTagValue tagValueQuery = new CcsTagValue();
                        tagValueQuery.Ip = req.url;
                        tagValueQuery.Address = actionAddress.Address;
                        CcsTagValue tagValue = _ccsTagValueService.GetList(tagValueQuery).ToList().FirstOrDefault();
                        if (tagValue != null)
                        {
                            tagValue.TagValue = parValue;
                            await _ccsTagValueService.Update(tagValue);
                        }


                        Thread.Sleep(SLEEP_TIME);
                    }
                }

                s7.ConnectClose();

                // 睡100毫秒，保证plc那边进行数据处理完成,防止回调时候，plc状态不是最新状态
                Thread.Sleep(100);

                //插入回调
                TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.ThreeDimensionalRun.ToString(),
                    EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalRun), req.taskId, req.taskNodeId);
                taskCallbackData = setCallBackValue(CcsActionAddresses, taskCallbackData);

                // 保存数据
                await _taskCallbackService.CreateOrUpdateAndCache(taskCallbackData);
                Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalRun) + "命令下发成功===>>" + JsonConvert.SerializeObject(req)
                   , EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalRun));
                return responseData;
            }
            catch (Exception ex)
            {
                // 记录日志
                Log.Instance.WriteLogAdd(ActionTypeEnum.ThreeDimensionalRun + "任务异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.ThreeDimensionalRun));
                responseData.resultMsg = ActionTypeEnum.ThreeDimensionalRun + "任务异常===>>" + ex.Message + JsonConvert.SerializeObject(req);
                responseData.result = "false";

                // 关闭plc连接
                if (s7 != null)
                {
                    s7.ConnectClose();
                }
                return responseData;
            }
        }



        /// <summary>
        /// 坐标系偏移量设置
        /// </summary> 
        public async Task<ResponseECSData> SendOffsetSetting(RequestData<ThreeDimensionalOffset> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.WriteDeviationValue + "任务接受===>>"+ JsonConvert.SerializeObject(req),
    EnumHelper.GetDescription(ActionTypeEnum.WriteDeviationValue));

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId,"设置成功");

            try
            {
                List<Device> devices = _deviceService.GetDeviceList();
   
                Device deviceHeidenhain = devices.Where(x => x.Ip.Equals(req.url)
                                            && x.ProtocolType.Equals(ProtocalTypeEnum.HEIDEHAIN.ToString())).FirstOrDefault();

                if (deviceHeidenhain == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.WriteDeviationValue + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.WriteDeviationValue));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.WriteDeviationValue + "设备已离线===>>" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                if (deviceHeidenhain != null)
                {

                    RequestHeidhData hdhReq = new RequestHeidhData();
                    hdhReq.ServerUrl = deviceHeidenhain.ServerUrl;
                    hdhReq.MachineName = deviceHeidenhain.UserName;
                    hdhReq.Type = OpcUaActionTypeEnum.WriteDeviationValue.ToString();
                    hdhReq.DeviationValue = JsonConvert.SerializeObject(req.data);
                    
                    var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
                    ResponseHeidhData responseHeidhData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
                    if (!Result.IsSuccess || !responseHeidhData.result)
                    {
                        Log.Instance.WriteLogAdd(ActionTypeEnum.WriteDeviationValue + "坐标系偏差值设置失败===>>" + JsonConvert.SerializeObject(req) + "======结果数据：" + Result,
                            EnumHelper.GetDescription(ActionTypeEnum.WriteDeviationValue));

                        responseData.result = "false";
                        responseData.resultMsg = Result.Message;
                        return responseData;
                    }
                    else
                    {
                        responseData.result = "true";
                        responseData.resultMsg = "消费成功";
                    }
                }
                else
                {
                    responseData.result = "false";
                    responseData.resultMsg = "没找到对应的类型方法";

                    return responseData;
                }

                //插入回调
                TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.WriteDeviationValue.ToString(),
                EnumHelper.GetDescription(ActionTypeEnum.WriteDeviationValue), req.taskId, req.taskNodeId);
                await _taskCallbackService.CreateOrUpdateAndCache(taskCallbackData);

                Log.Instance.WriteLogAdd(ActionTypeEnum.WriteDeviationValue + "任务执行成功===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.WriteDeviationValue));


                return responseData;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd(ActionTypeEnum.WriteDeviationValue + "任务异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.WriteDeviationValue));

                responseData.resultMsg = ActionTypeEnum.WriteDeviationValue + "任务异常===>>" + ex.Message + JsonConvert.SerializeObject(req);
                responseData.result = "false";
                return responseData;
            }
        }

        public async Task<ResponseECSData> findRfidData(RequestData<RequestToolData> reqs)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.RfidRead + "任务接受===>>" + JsonConvert.SerializeObject(reqs),
                EnumHelper.GetDescription(ActionTypeEnum.RfidRead));

            // 1、根据url查询设备信息   2、调用httpserveer 发送执行消息

            ResponseECSData responseData = new ResponseECSData(reqs.taskId, reqs.taskNodeId, "执行成功");
            SiemensS7Net s7 = null;
            try
            {

                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == reqs.url && x.Port == reqs.port).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.RfidRead + "设备已离线===>>" + JsonConvert.SerializeObject(reqs),
                    EnumHelper.GetDescription(ActionTypeEnum.RfidRead));

                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + reqs.url;
                    return responseData;
                }

                // 根据ip查询设备
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.RfidRead.ToString();
                actionQuery.Ip = reqs.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                // 进行plc的连接
                s7 = DevicePlcS7.SiemensS7(actionInfo.Ip);
                OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd(ActionTypeEnum.RfidRead + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(reqs),
                    EnumHelper.GetDescription(ActionTypeEnum.RfidRead));

                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.RfidRead + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(reqs);
                    return responseData;
                }


                // 查询需要操作的plc的db块
                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                //查询出需要检查的地址列表
                List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                    {
                        string operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                        if (actionAddress.CheckType ? operateResult != actionAddress.Value : operateResult == actionAddress.Value)
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd("查询RFID异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "====实际为：" + operateResult + JsonConvert.SerializeObject(reqs),
                                EnumHelper.GetDescription(ActionTypeEnum.RfidRead));

                            responseData.result = "false";
                            responseData.resultMsg = "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "==实际为：" + operateResult;
                            return responseData;
                        }
                    }
                }

                // 查询需要读取的地址列表
                List<CcsActionAddress> CcsActionAddressReads = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.READ.ToString()).ToList();
                Dictionary<string, string> map = new Dictionary<string, string>();

                int i = 1;
                foreach (CcsActionAddress actionAddress in CcsActionAddressReads)
                {
                    if (string.IsNullOrEmpty(actionAddress.Address)) {
                        continue;
                    }


                    string operateResult = "";
                    if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.BOOL.ToString()))
                    {
                        operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                    }
                    else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.SHORT.ToString()))
                    {
                        operateResult = s7.ReadInt16(actionAddress.Address).Content.ToString();
                    }
                    else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.String.ToString()))
                    {
                        operateResult = s7.ReadString(actionAddress.Address).Content.ToString();
                    }
                    else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.Byte.ToString()))
                    {
                        operateResult = s7.ReadByte(actionAddress.Address).Content.ToString();
                    }

                    map.Add("par"+1, operateResult);

                }
                responseData.returnData = JsonConvert.SerializeObject(map, Formatting.Indented);


                //查询需要写入地址列表
                List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address))
                    {
                        string parValue = "";
                        if (actionAddress.Sort == 1)
                        {
                            parValue = actionAddress.Value;
                            s7.Write(actionAddress.Address, Convert.ToBoolean(parValue));
                        }
                        else if (actionAddress.Sort == 2)
                        {
                            parValue = actionAddress.Value;
                            s7.Write(actionAddress.Address, Convert.ToBoolean(parValue));
                        }

                        // 同步TagValue数据状态
                        CcsTagValue tagValueQuery = new CcsTagValue();
                        tagValueQuery.Ip = reqs.url;
                        tagValueQuery.Address = actionAddress.Address;
                        CcsTagValue tagValue = _ccsTagValueService.GetList(tagValueQuery).ToList().FirstOrDefault();
                        if (tagValue != null)
                        {
                            tagValue.TagValue = parValue;
                            await _ccsTagValueService.Update(tagValue);
                        }

                        Thread.Sleep(SLEEP_TIME);
                    }
                }

                s7.ConnectClose();
                Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.RfidRead) + "取成功===>>" + JsonConvert.SerializeObject(reqs)
                   , EnumHelper.GetDescription(ActionTypeEnum.RfidRead));

                return responseData;

            }
            catch (Exception ex)
            {
                s7.ConnectClose();
                Log.Instance.WriteLogAdd(ActionTypeEnum.RfidRead + "任务异常===>>" + ex.Message + JsonConvert.SerializeObject(reqs),
                    EnumHelper.GetDescription(ActionTypeEnum.RfidRead));

                responseData.resultMsg = ActionTypeEnum.RfidRead + "任务异常===>>" + ex.Message + JsonConvert.SerializeObject(reqs);
                responseData.result = "false";
                return responseData;
            }

        }


        public async Task<ResponseECSData> rfidReset(RequestData<RequestToolData> reqs)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.RfidReset + "任务接受===>>" + JsonConvert.SerializeObject(reqs)
               , EnumHelper.GetDescription(ActionTypeEnum.RfidReset));

            // 1、根据url查询设备信息   2、调用httpserveer 发送执行消息

            ResponseECSData responseData = new ResponseECSData(reqs.taskId, reqs.taskNodeId, "执行成功");
            SiemensS7Net s7 = null;
            try
            {

                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == reqs.url && x.Port == reqs.port).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.RfidReset + "设备已离线===>>" + JsonConvert.SerializeObject(reqs),
                    EnumHelper.GetDescription(ActionTypeEnum.RfidReset));

                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + reqs.url;
                    return responseData;
                }

                // 根据ip查询设备
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = ActionTypeEnum.RfidReset.ToString();
                actionQuery.Ip = reqs.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                // 进行plc的连接
                s7 = DevicePlcS7.SiemensS7(actionInfo.Ip);
                OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd(ActionTypeEnum.RfidReset + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(reqs),
                    EnumHelper.GetDescription(ActionTypeEnum.RfidReset));

                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.RfidReset + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(reqs);
                    return responseData;
                }


                // 查询需要操作的plc的db块
                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                //查询需要写入地址列表
                List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
                
                foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address))
                    {
                        string parValue = "";
                        if (actionAddress.Sort == 1)
                        {
                            parValue = actionAddress.Value;
                            s7.Write(actionAddress.Address, Convert.ToBoolean(parValue));
                        }
                        else if (actionAddress.Sort == 2)
                        {
                            parValue = actionAddress.Value;
                            s7.Write(actionAddress.Address, Convert.ToBoolean(parValue));
                        }

                        // 同步TagValue数据状态
                        CcsTagValue tagValueQuery = new CcsTagValue();
                        tagValueQuery.Ip = reqs.url;
                        tagValueQuery.Address = actionAddress.Address;
                        CcsTagValue tagValue = _ccsTagValueService.GetList(tagValueQuery).ToList().FirstOrDefault();
                        if (tagValue != null)
                        {
                            tagValue.TagValue = parValue;
                            await _ccsTagValueService.Update(tagValue);
                        }

                        Thread.Sleep(SLEEP_TIME);
                    }
                }

                s7.ConnectClose();
                Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.RfidReset) + "任务成功===>>" + JsonConvert.SerializeObject(reqs),
                    EnumHelper.GetDescription(ActionTypeEnum.RfidReset));

                return responseData;

            }
            catch (Exception ex)
            {
                s7.ConnectClose();
                Log.Instance.WriteLogAdd(ActionTypeEnum.RfidReset + "任务异常===>>" + ex.Message + JsonConvert.SerializeObject(reqs),
                    EnumHelper.GetDescription(ActionTypeEnum.RfidReset));

                responseData.resultMsg = ActionTypeEnum.RfidReset + "任务异常===>>" + ex.Message + JsonConvert.SerializeObject(reqs);
                responseData.result = "false";
                return responseData;
            }
        }

        /// <summary>
        /// 查询刀具上下料站、机床刀具位是否允许取
        /// </summary> 
        /// <returns></returns>
        public async Task<ResponseECSData> getCutterDeviceIsTake(RequestData<RequestToolData> req)
        {
            Log.Instance.WriteLogAdd("查询刀具上下料站、机床刀具位是否允许取===>> " + JsonConvert.SerializeObject(req), "CNC刀具取放状态");
            // 1、根据url查询设备信息   2、调用httpserveer 发送执行消息

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId, "允许下料");
            SiemensS7Net s7 = null;
            try
            {
                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == req.url && x.Port == req.port).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd("取==CutterTake" + req.data.location + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    "CNC刀具取放状态");
                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + req.url;
                    return responseData;
                }

                // 根据ip查询配置的字节数据
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = "CutterTake" + req.data.location.ToString();
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                if (actionInfo == null)
                {
                    Log.Instance.WriteLogAdd("取==CutterTake" + req.data.location + "没有查询到校验信息===>>" + "没有查询到配置方法，默认通过" + JsonConvert.SerializeObject(req),
                    "CNC刀具取放状态");
                    responseData.result = "true";
                    responseData.resultMsg = "取==CutterTake" + req.data.location + "没有查询到校验信息===>>" + "没有查询到配置方法，默认通过" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                // 进行plc的连接
                s7 = DevicePlcS7.SiemensS7(actionInfo.Ip);
                OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd("取==CutterTake" + req.data.location + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                    "CNC刀具取放状态");
                    responseData.result = "false";
                    responseData.resultMsg = "取==CutterTake" + req.data.location + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req);
                    return responseData;
                }


                //=========================上下料站请求判断 开始======================
                // 目标点位是上下料站的判断下料请求是否为true，上料请求为false,
                // 如果不是判断上料请求是否为true，
                // 是提示状态不对，否则写下料请求状态

                // 下料允许
                /*if (cutterTakeRequest.ContainsKey(req.data.location))
                {

                    string shangliaoqingqiuDB = cutterPutRequest[req.data.location];
                    string xialiaoqingqiuDB = cutterTakeRequest[req.data.location];
                    string shangliaoyunxuDB = cutterPutStatus[req.data.location];
                    string xialiaoyunxuDB = cutterTakeStatus[req.data.location];

                    string shangliaoqingqiu = s7.ReadBool(shangliaoqingqiuDB).Content.ToString();
                    string xialiaoqingqiu = s7.ReadBool(xialiaoqingqiuDB).Content.ToString();
                    string shangliaoyunxu = s7.ReadBool(shangliaoyunxuDB).Content.ToString();
                    string xialiaoyunxu = s7.ReadBool(xialiaoyunxuDB).Content.ToString();

                    if (shangliaoqingqiu == "False" && xialiaoqingqiu == "False")
                    {
                        s7.Write(xialiaoqingqiuDB, true);
                        s7.ConnectClose();
                        Log.Instance.WriteLogAdd("取==已发送下料请求，等待下料允许====" + JsonConvert.SerializeObject(req), "CNC刀具取放状态");
                        responseData.result = "false";
                        responseData.resultMsg = "已发送下料请求，等待下料允许";
                        return responseData;
                    }
                    else if (shangliaoqingqiu == "True" && xialiaoqingqiu == "False")
                    {
                        s7.ConnectClose();
                        Log.Instance.WriteLogAdd("取==状态不对，现在上料请求状态，等待上料任务完成====" + JsonConvert.SerializeObject(req), "CNC刀具取放状态"); ;
                        responseData.result = "false";
                        responseData.resultMsg = "已被上料请求占用，等待上料任务完成";
                        return responseData;
                    }
                    else if (xialiaoqingqiu == "True" && xialiaoyunxu == "False")
                    {
                        s7.ConnectClose();
                        Log.Instance.WriteLogAdd("取==已经发送下料请求，下料允许状态不满足====" + JsonConvert.SerializeObject(req), "CNC刀具取放状态"); ;
                        responseData.result = "false";
                        responseData.resultMsg = "已经发送下料请求，下料允许状态不满足";
                        return responseData;
                    }
                }*/
                //=========================上下料站请求判断 结束======================


                // 查询需要操作的plc的db块
                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                //查询出需要检查的地址列表
                List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                    {
                        string operateResult = "";
                        if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.BOOL.ToString()))
                        {
                            operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.SHORT.ToString()))
                        {
                            operateResult = s7.ReadInt16(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.String.ToString()))
                        {
                            operateResult = s7.ReadString(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.Byte.ToString()))
                        {
                            operateResult = s7.ReadByte(actionAddress.Address).Content.ToString();
                        }

                        if (actionAddress.CheckType ? operateResult != actionAddress.Value : operateResult == actionAddress.Value)
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd("取==CutterTake" + req.data.location + "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "====实际为：" + operateResult + JsonConvert.SerializeObject(req),
                            "CNC刀具取放状态");
                            responseData.result = "false";
                            responseData.resultMsg = "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "==实际为：" + operateResult;
                            return responseData;
                        }
                    }
                }

                //  关闭连接
                s7.ConnectClose();

            }
            catch (Exception ex)
            {
                //  关闭连接
                s7.ConnectClose();

                Log.Instance.WriteLogAdd("取==CutterTake" + req.data.location + "任务下发异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    "CNC刀具取放状态");
                responseData.result = "false";
                responseData.resultMsg = ex.Message;
                return responseData;
            }
            Log.Instance.WriteLogAdd("取==CutterTake" + req.data.location + "结果===>>" + JsonConvert.SerializeObject(responseData),  "CNC刀具取放状态");

            return responseData;
        }

        /// <summary>
        /// 查询刀具上下料站、机床刀具位是否允许放
        /// </summary> 
        /// <returns></returns>
        public async Task<ResponseECSData> getCutterDeviceIsPut(RequestData<RequestToolData> req)
        {

            Log.Instance.WriteLogAdd("查询刀具上下料站、机床刀具位是否允许放===>> " + JsonConvert.SerializeObject(req), "刀具取放状态");
            // 1、根据url查询设备信息   2、调用httpserveer 发送执行消息

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId, "允许下料");
            SiemensS7Net s7 = null;
            try
            {
                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == req.url && x.Port == req.port).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd("放==CutterPut" + req.data.location + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    "刀具取放状态");
                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + req.url;
                    return responseData;
                }



                // 根据ip查询配置的字节数据
                CcsAction actionQuery = new CcsAction();
                actionQuery.OperateType = "CutterPut" + req.data.location.ToString();
                actionQuery.Ip = req.url;
                CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();

                if (actionInfo == null) {
                   Log.Instance.WriteLogAdd("放==CutterPut" + req.data.location + "没有查询到校验信息===>>" + "没有查询到配置方法，默认通过" + JsonConvert.SerializeObject(req),
                    "刀具取放状态");
                    responseData.result = "true";
                    responseData.resultMsg = "放==CutterPut" + req.data.location + "没有查询到校验信息===>>" + "没有查询到配置方法，默认通过" + JsonConvert.SerializeObject(req);
                    return responseData;
                }


                // 进行plc的连接
                s7 = DevicePlcS7.SiemensS7(actionInfo.Ip);
                OperateResult ConnectionResult = s7.ConnectServer();
                if (!ConnectionResult.IsSuccess)
                {
                    s7.ConnectClose();
                    Log.Instance.WriteLogAdd("放==CutterPut" + req.data.location + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
                    "刀具取放状态");
                    responseData.result = "false";
                    responseData.resultMsg = "放==CutterPut" + req.data.location + "异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                //=========================上下料站请求判断 开始======================
                // 目标点位是上下料站的判断下料请求是否为true，上料请求为false,
                // 如果不是判断上料请求是否为true，
                // 是提示状态不对，否则写下料请求状态
                // 上料料请求
                /*if (cutterPutRequest.ContainsKey(req.data.location))
                {
                    string shangliaoqingqiuDB = cutterPutRequest[req.data.location];
                    string xialiaoqingqiuDB = cutterTakeRequest[req.data.location];
                    string shangliaoyunxuDB = cutterPutStatus[req.data.location];
                    string xialiaoyunxuDB = cutterTakeStatus[req.data.location];

                    string shangliaoqingqiu = s7.ReadBool(shangliaoqingqiuDB).Content.ToString();
                    string xialiaoqingqiu = s7.ReadBool(xialiaoqingqiuDB).Content.ToString();
                    string shangliaoyunxu = s7.ReadBool(shangliaoyunxuDB).Content.ToString();
                    string xialiaoyunxu = s7.ReadBool(xialiaoyunxuDB).Content.ToString();

                    if (shangliaoqingqiu == "False" && xialiaoqingqiu == "False")
                    {
                        s7.Write(shangliaoqingqiuDB, true);
                        s7.ConnectClose();
                        Log.Instance.WriteLogAdd("放==已发送上料请求，等待上料允许====" + JsonConvert.SerializeObject(req), "刀具取放状态");
                        responseData.result = "false";
                        responseData.resultMsg = "已发送上料请求，等待上料允许";
                        return responseData;
                    }
                    else if (shangliaoqingqiu == "False" && xialiaoqingqiu == "True")
                    {
                        s7.ConnectClose();
                        Log.Instance.WriteLogAdd("放==状态不对，现在下料请求状态，等待下料任务完成====" + JsonConvert.SerializeObject(req), "刀具取放状态");
                        responseData.result = "false";
                        responseData.resultMsg = "已被下料请求占用，等待下料任务完成";
                        return responseData;
                    }
                    else if (shangliaoqingqiu == "True" && shangliaoyunxu == "False")
                    {
                        s7.ConnectClose();
                        Log.Instance.WriteLogAdd("放 == 已经发送上料请求，上料允许状态不满足====" + JsonConvert.SerializeObject(req), "刀具取放状态");

                        responseData.result = "false";
                        responseData.resultMsg = "已经发送上料请求，上料允许状态不满";
                        return responseData;
                    }

                }*/
                //=========================上下料站请求判断 结束======================


                // 查询需要操作的plc的db块
                CcsActionAddress actionAddressQuery = new CcsActionAddress();
                actionAddressQuery.ActionId = actionInfo.Id;
                List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);

                //查询出需要检查的地址列表
                List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
                foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
                {
                    if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
                    {
                        string operateResult = "";
                        if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.BOOL.ToString()))
                        {
                            operateResult = s7.ReadBool(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.SHORT.ToString()))
                        {
                            operateResult = s7.ReadInt16(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.String.ToString()))
                        {
                            operateResult = s7.ReadString(actionAddress.Address).Content.ToString();
                        }
                        else if (actionAddress.AddressType.Equals(TagValueReadTypeEnum.Byte.ToString()))
                        {
                            operateResult = s7.ReadByte(actionAddress.Address).Content.ToString();
                        }

                        if (actionAddress.CheckType ? operateResult != actionAddress.Value : operateResult == actionAddress.Value)
                        {
                            s7.ConnectClose();
                            Log.Instance.WriteLogAdd("放==CutterPut" + req.data.location + "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "====实际为：" + operateResult + JsonConvert.SerializeObject(req),
                            "刀具取放状态");
                            responseData.result = "false";
                            responseData.resultMsg = "异常===>>" + "条件不满足" + actionAddress.Address + "值应为：" + actionAddress.Value + "==实际为：" + operateResult;
                            return responseData;
                        }
                    }
                }

                //  关闭连接
                s7.ConnectClose();

            }
            catch (Exception ex)
            {

                //  关闭连接
                s7.ConnectClose();
                Log.Instance.WriteLogAdd("放==CutterPut" + req.data.location + "任务下发异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    "刀具取放状态");
                responseData.result = "false";
                responseData.resultMsg = "异常错误"+ex.Message;
                return responseData;
            }

            return responseData;
        }

        public async Task<ResponseECSData> setWriteTakeCutter(RequestData<CutterTestData> req)
        {
            Log.Instance.WriteLogAdd("刀具取状态设置===>> " + JsonConvert.SerializeObject(req), "刀具取状态设置");
            // 1、根据url查询设备信息   2、调用httpserveer 发送执行消息

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId, "刀具取状态设置");
            try
            {
                // 获取所有在线的设备
                List<Device> devices = _deviceService.GetDeviceList();

                // 比较在线设备是否在其中
                Device device = devices.Where(x => x.Ip == req.url && x.Port == req.port).FirstOrDefault();

                if (device == null)
                {
                    Log.Instance.WriteLogAdd("设备已离线===>>" + JsonConvert.SerializeObject(req),
                    "刀具取状态设置");
                    responseData.result = "false";
                    responseData.resultMsg = "设备已离线：" + req.url;
                    return responseData;
                }

                // 调用httpserver 设置参数
                if (null != device && device.ProtocolType == "HEIDEHAIN")
                {
                    RequestHeidhData hdhReq = new RequestHeidhData();
                    hdhReq.ServerUrl = device.ServerUrl;
                    hdhReq.MachineName = device.UserName;
                    hdhReq.Type = "WriteTakeCutter";
                    hdhReq.CutterData = JsonConvert.SerializeObject(req.data);

                    var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
                    ResponseHeidhData responseHeidhData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
                    if (!Result.IsSuccess || !responseHeidhData.result)
                    {
                        Log.Instance.WriteLogAdd(ActionTypeEnum.WriteDeviationValue + "设置失败===>>" + JsonConvert.SerializeObject(req) + "======结果数据：" + Result, "刀具取状态设置");
                        responseData.result = "false";
                        responseData.resultMsg = Result.Message;
                        return responseData;
                    }
                    else
                    {
                        responseData.result = "true";
                        responseData.resultMsg = "消费成功";
                    }

                }


            }
            catch (Exception ex)
            {
                //  关闭连接
                Log.Instance.WriteLogAdd("任务执行异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    "刀具取状态设置");
                responseData.result = "false";
                responseData.resultMsg = ex.Message;
            }
            return responseData;

        }

        public async Task<ResponseECSData> sendTheBindingInfo(RequestData<BindInfo> req)
        {
            Log.Instance.WriteLogAdd(ActionTypeEnum.BindingInfo + "任务接受===>>" + JsonConvert.SerializeObject(req),
                EnumHelper.GetDescription(ActionTypeEnum.BindingInfo));

            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId, "设置成功");

            try
            {
                List<Device> devices = _deviceService.GetDeviceList();

                Device deviceHeidenhain = devices.Where(x => x.Ip.Equals(req.url)
                                            && x.ProtocolType.Equals(ProtocalTypeEnum.HEIDEHAIN.ToString())).FirstOrDefault();

                if (deviceHeidenhain == null)
                {
                    Log.Instance.WriteLogAdd(ActionTypeEnum.BindingInfo + "设备已离线===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.BindingInfo));
                    responseData.result = "false";
                    responseData.resultMsg = ActionTypeEnum.BindingInfo + "设备已离线===>>" + JsonConvert.SerializeObject(req);
                    return responseData;
                }

                if (deviceHeidenhain != null)
                {

                    RequestHeidhData hdhReq = new RequestHeidhData();
                    hdhReq.ServerUrl = deviceHeidenhain.ServerUrl;
                    hdhReq.MachineName = deviceHeidenhain.UserName;
                    hdhReq.Type = OpcUaActionTypeEnum.BindingInfo.ToString();
                    hdhReq.BindInfo = JsonConvert.SerializeObject(req.data);

                    var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
                    ResponseHeidhData responseHeidhData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
                    if (!Result.IsSuccess || !responseHeidhData.result)
                    {
                        Log.Instance.WriteLogAdd(ActionTypeEnum.BindingInfo + "绑定数据设置失败===>>" + JsonConvert.SerializeObject(req) + "======结果数据：" + Result, "设备绑定数据设置");
                        responseData.result = "false";
                        responseData.resultMsg = Result.Message;
                        return responseData;
                    }
                    else
                    {
                        responseData.result = "true";
                        responseData.resultMsg = "消费成功";
                    }
                }
                else
                {
                    responseData.result = "false";
                    responseData.resultMsg = "没找到对应的类型方法";

                    return responseData;
                }

                //插入回调
                TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.BindingInfo.ToString(),
                EnumHelper.GetDescription(ActionTypeEnum.BindingInfo), req.taskId, req.taskNodeId);
                await _taskCallbackService.CreateOrUpdateAndCache(taskCallbackData);

                Log.Instance.WriteLogAdd(ActionTypeEnum.BindingInfo + "任务成功===>>" + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.BindingInfo));

                return responseData;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd(ActionTypeEnum.BindingInfo + "任务异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
                    EnumHelper.GetDescription(ActionTypeEnum.BindingInfo));

                responseData.resultMsg = ActionTypeEnum.BindingInfo + "任务异常===>>" + ex.Message + JsonConvert.SerializeObject(req);
                responseData.result = "false";
                return responseData;
            }
        }


        public async Task<ResponseECSData> writePoint(RequestData<RequestPoint> req)
        {
            ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);

            List<string> pointList = req.data.pointList;

            if (pointList == null || pointList.Count == 0)
            {
                responseData.result = "false";
                responseData.msg = "参数点位集合为空";
                return responseData;
            }

            SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
            OperateResult ConnectionResult = s7.ConnectServer();
            if (!ConnectionResult.IsSuccess)
            {
                s7.ConnectClose();
                responseData.result = "false";
                responseData.msg = "PLC连接不上";
                return responseData;
            }

            foreach (string point in pointList)
            {
                s7.Write(point, Convert.ToInt16("0"));

            }
            responseData.result = "true";
            s7.ConnectClose();
            return responseData;
        }


        public async Task<ResponseCCSData<List<ResponseEcsPoint>>> readPoint(RequestData<RequestPoint> req)
        {
            ResponseCCSData<List<ResponseEcsPoint>> responseData = new ResponseCCSData<List<ResponseEcsPoint>>();

            List<string> pointList = req.data.pointList;

            if (pointList == null || pointList.Count == 0)
            {
                responseData.result = "false";
                responseData.msg = "参数点位集合为空";
                return responseData;
            }

            SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
            OperateResult ConnectionResult = s7.ConnectServer();
            if (!ConnectionResult.IsSuccess)
            {
                s7.ConnectClose();
                responseData.result = "false";
                responseData.msg = "PLC连接不上," + ConnectionResult.ErrorCode + "," + ConnectionResult.Message;
                return responseData;
            }
            List<ResponseEcsPoint> responseEcsPointList = new List<ResponseEcsPoint>();
            foreach (string point in pointList)
            {
                ResponseEcsPoint responseEcsPoint = new ResponseEcsPoint();
                string result = s7.ReadInt16(point).Content.ToString();
                responseEcsPoint.point = point;
                responseEcsPoint.result = result;
                responseEcsPointList.Add(responseEcsPoint);
            }
            responseData.result = "true";
            responseData.data = responseEcsPointList;
            s7.ConnectClose();
            return responseData;
        }
    }
}