imcs_ccs/IMCS_CCS/Service/Impl/TaskJobService.cs

using IMCS.CCS.Common.Redis;
using IMCS.CCS.DeviceProtocol;
using IMCS.CCS.Entitys;
using IMCS.CCS.Model.vo;
using IMCS.CCS.Services;
using IMCS_CCS.Model.vo;
using IMCS_CCS.Utils;
using IMCS_CCS.Utils.DeviceProtocol;
using Microsoft.Extensions.Configuration;
using Newtonsoft.Json;
using S7.Net;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;

namespace IMCS.CCS.Service.Impl
{
    /// <summary>
    /// 任务调度服务
    /// </summary>
    public class TaskJobService : ITaskJobService
    {
        private readonly IRedisService _redisService;

        private readonly IDeviceService _deviceService;

        private readonly IApiRequestService _apiRequestService;

        private readonly ITaskCallbackService _taskCallbackService;

        private readonly ICcsTagValueService _ccsTagValueService;

        private readonly IEquipmentMonitorService _equipmentMonitorService;

        private string ecsUrlContext;

        private string fanucUrlContext;

        private string LOG_TITLE_OPCUA = "OPCUA采集";

        private string LOG_TITLE_S7 = "S7采集";

        private string LOG_TITLE_CALLBACK = "回调任务";

        private string LOG_TITLE_DEVICE = "设备监控";

        public IConfiguration Configuration { get; }


        public TaskJobService(IRedisService redisService,
                              ITaskCallbackService taskCallbackService,
                              IDeviceService deviceService,
                              IApiRequestService apiRequestService,
                              ICcsTagValueService ccsTagValueService,
                              IEquipmentMonitorService equipmentMonitorService,
                              IConfiguration configuration)
        {
            _redisService = redisService;
            _taskCallbackService = taskCallbackService;
            _deviceService = deviceService;
            _apiRequestService = apiRequestService;
            _ccsTagValueService = ccsTagValueService;
            _equipmentMonitorService = equipmentMonitorService;
            Configuration = configuration;
            ecsUrlContext = Configuration.GetConnectionString("ecsUrlContext");
            fanucUrlContext = Configuration.GetConnectionString("fanucUrlContext");

        }

        /// <summary>
        /// 采集数据OPCUA
        /// </summary> 
        /// <returns></returns>
        public async Task<string> DataCollectOPCUAJob()
        {
            try
            {
                List<Device> deviceList = _deviceService.GetDeviceList();

                deviceList = deviceList.Where(x => x.ProtocolType.Equals(ProtocalTypeEnum.OPCUA.ToString())).ToList();

                foreach (Device device in deviceList)
                {
                    List<CcsTagValue> tagValues = new List<CcsTagValue>();
                    string redis_key = device.Ip + ":" + device.ProtocolType;
                    var data = await _redisService.Database.StringGetAsync(redis_key);
                    if (data.IsNullOrEmpty)
                    {
                        CcsTagValue tagQuery = new CcsTagValue();
                        tagQuery.ProtocolType = device.ProtocolType;
                        tagQuery.Ip = device.Ip;
                        tagValues = _ccsTagValueService.GetList(tagQuery);
                        //首次设置redis
                        if (tagValues != null && tagValues.Count > 0)
                        {
                            await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
                        }
                    }
                    else
                    {
                        tagValues = JsonConvert.DeserializeObject<List<CcsTagValue>>(data);
                    }

                    if (tagValues != null && tagValues.Count > 0)
                    {
                        List<CcsTagValue> changTagValues = new List<CcsTagValue>();

                        DeviceOPCUat deviceOPCUat = new DeviceOPCUat(device.ServerUrl, device.UserName, device.Password);
                        if (!deviceOPCUat.IsConnection)
                        {
                            device.State = false;
                            await _deviceService.UpdateDevice(device);
                            Log.Instance.WriteLogAdd("OpcUA采集异常,连不上设备", LOG_TITLE_OPCUA);
                            return "采集失败，连不上设备";
                        }
                        else
                        {
                            List<string> addresses = new List<string>();
                            foreach (CcsTagValue tagValue in tagValues)
                            {
                                addresses.Add(tagValue.Address);
                            }
                            List<string> values = deviceOPCUat.OpcUa_Read(addresses);
                            for (int i = 0; i < tagValues.Count; i++)
                            {
                                CcsTagValue tagValueData = (CcsTagValue)tagValues[i];
                                if (!tagValueData.TagValue.Equals(values[i]))
                                {
                                    tagValueData.TagValue = values[i];
                                    tagValueData.UpdateTime = DateTime.Now;
                                    changTagValues.Add(tagValueData);
                                    Log.Instance.WriteLogAdd("OpcUA采集,Ip:" + tagValueData.Ip + " 地址:" + tagValueData.Address + ",值:" + tagValueData.TagValue + ",发生变化", LOG_TITLE_OPCUA);
                                    //有变化更新数据库
                                    await _ccsTagValueService.Update(tagValueData);
                                }
                            }
                            deviceOPCUat.OpcUa_Close();
                            //值有变化，重新设置一次redis
                            if (changTagValues != null && changTagValues.Count > 0)
                            {
                                await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
                            }
                        }
                    }
                    else
                    {
                        Log.Instance.WriteLogAdd("OpcUA采集异常,没有采集数据===", LOG_TITLE_OPCUA);
                        return "没有采集数据";
                    }
                }
                return "OpcUA采集成功";
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("OpcUA采集异常===>>" + ex.Message, LOG_TITLE_OPCUA);
                return "OpcUA采集失败";
            }
        }

        /// <summary>
        /// 采集数据S7
        /// </summary> 
        /// <returns></returns>
        public async Task<string> DataCollectS7Job()
        {
            try
            {
                List<Device> deviceList = _deviceService.GetDeviceList();
                deviceList = deviceList.Where(x => x.ProtocolType.Equals(ProtocalTypeEnum.S7_1500.ToString())).ToList();
                foreach (Device device in deviceList)
                {
                    List<CcsTagValue> tagValues = new List<CcsTagValue>();
                    string redis_key = device.Ip + ":" + device.ProtocolType;
                    var data = await _redisService.Database.StringGetAsync(redis_key);
                    if (data.IsNullOrEmpty)
                    {
                        CcsTagValue tagQuery = new CcsTagValue();
                        tagQuery.ProtocolType = device.ProtocolType;
                        tagQuery.Ip = device.Ip;
                        tagValues = _ccsTagValueService.GetList(tagQuery);
                        //首次设置redis
                        if (tagValues != null && tagValues.Count > 0)
                        {
                            await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
                        }
                    }
                    else
                    {
                        tagValues = JsonConvert.DeserializeObject<List<CcsTagValue>>(data);
                    }

                    if (tagValues != null && tagValues.Count > 0)
                    {
                        tagValues = JsonConvert.DeserializeObject<List<CcsTagValue>>(data);
                        List<CcsTagValue> changTagValues = new List<CcsTagValue>();


                        Plc s7 = DevicePlcS7.S7(device.ServerUrl, ProtocalTypeEnum.S7_1500.ToString());

                        if (s7.IsConnected != true)
                        {
                            device.State = false;
                            await _deviceService.UpdateDevice(device);
                            s7.Close();
                            Log.Instance.WriteLogAdd("S7采集异常,plc连不上", LOG_TITLE_S7);
                            return "采集失败，plc连不上";
                        }
                        else
                        {
                            foreach (CcsTagValue tagValueData in tagValues)
                            {
                                string Address = ToolUtils.AddressConvertDBW(tagValueData.Address);
                                var operateResult = ((ushort)s7.Read(Address)).ConvertToShort();
                                if (!tagValueData.TagValue.Equals(operateResult))
                                {
                                    tagValueData.TagValue = operateResult.ToString();
                                    tagValueData.UpdateTime = DateTime.Now;
                                    changTagValues.Add(tagValueData);
                                    Log.Instance.WriteLogAdd("S7采集,Ip:" + tagValueData.Ip + " 地址:" + tagValueData.Address + ",值:" + tagValueData.TagValue + ",发生变化", LOG_TITLE_S7);
                                    //有变化更新数据库
                                    await _ccsTagValueService.Update(tagValueData);
                                }
                                Thread.Sleep(50);
                            }
                            s7.Close();
                            //值有变化，重新设置一次redis
                            if (changTagValues != null && changTagValues.Count > 0)
                            {
                                await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
                            }
                        }

                    }
                }
                return "S7采集成功";
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("S7采集异常===>>" + ex.Message, LOG_TITLE_S7);
                return "S7采集失败";
            }
        }

        /// <summary>
        /// 采集数据FANUC
        /// </summary> 
        /// <returns></returns>
        public async Task<string> DataCollectFanucJob()
        {
            try
            {
                List<Device> deviceList = _deviceService.GetDeviceList();
                deviceList = deviceList.Where(x => x.ProtocolType.Equals(ProtocalTypeEnum.FANUC.ToString())).ToList();
                foreach (Device device in deviceList)
                {
                    List<CcsTagValue> tagValues = new List<CcsTagValue>();
                    string redis_key = device.Ip + ":" + device.ProtocolType;
                    var data = await _redisService.Database.StringGetAsync(redis_key);
                    if (data.IsNullOrEmpty)
                    {
                        CcsTagValue tagQuery = new CcsTagValue();
                        tagQuery.ProtocolType = device.ProtocolType;
                        tagQuery.Ip = device.Ip;
                        tagValues = _ccsTagValueService.GetList(tagQuery);
                        //首次设置redis
                        if (tagValues != null && tagValues.Count > 0)
                        {
                            await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
                        }
                    }
                    else
                    {
                        tagValues = JsonConvert.DeserializeObject<List<CcsTagValue>>(data);
                    }

                    if (tagValues != null && tagValues.Count > 0)
                    {
                        tagValues = JsonConvert.DeserializeObject<List<CcsTagValue>>(data);
                        List<CcsTagValue> changTagValues = new List<CcsTagValue>();
                        string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
                        //调用发那科是否连接接口
                        var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=Connect", null, null);

                        if (!Result.IsSuccess || Result.Message != "0")
                        {
                            device.State = false;
                            await _deviceService.UpdateDevice(device);
                            Log.Instance.WriteLogAdd("FANUC采集异常,FANUC连不上", LOG_TITLE_S7);
                            return "采集失败，FANUC连不上";
                        }
                        else
                        {   
                            //调用发那科采集接口
                            Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=All", null, null);
                            ResponseFanucData fanucData = JsonConvert.DeserializeObject<ResponseFanucData>(Result.Message);
                            foreach (CcsTagValue tagValueData in tagValues)
                            {
                                string operateResult = GetFanucValue(fanucData, tagValueData.TagValue);
                                if (!tagValueData.TagValue.Equals(operateResult))
                                {
                                    tagValueData.TagValue = operateResult.ToString();
                                    tagValueData.UpdateTime = DateTime.Now;
                                    changTagValues.Add(tagValueData);
                                    Log.Instance.WriteLogAdd("FANUC采集,Ip:" + tagValueData.Ip + " 地址:" + tagValueData.Address + ",值:" + tagValueData.TagValue + ",发生变化", LOG_TITLE_S7);
                                    //有变化更新数据库
                                    await _ccsTagValueService.Update(tagValueData);
                                }
                                Thread.Sleep(50);
                            }

                            //值有变化，重新设置一次redis
                            if (changTagValues != null && changTagValues.Count > 0)
                            {
                                await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
                            }
                        }

                    }
                }
                return "FANUC采集成功";
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("FANUC采集异常===>>" + ex.Message, LOG_TITLE_S7);
                return "FANUC采集失败";
            }
        }

        /// <summary>
        /// 上传程序回调任务
        /// </summary> 
        /// <returns></returns>
        public async Task<string> CallbackJob1()
        {
            List<TaskCallback> list = await _taskCallbackService.GetAllList();

            list = list.Where(x => x.OperateType.Equals(ActionTypeEnum.UploadFile.ToString())).ToList();
            string message = "";
            try
            {
                foreach (TaskCallback task in list)
                {
                    DateTime currentTime = DateTime.Now;
                    if (currentTime.Subtract(task.CreateTime).TotalSeconds > 5)
                    {
                        CallBackRequestData requestData = new CallBackRequestData();
                        requestData.taskId = long.Parse(task.TaskId);
                        requestData.taskNodeId = long.Parse(task.TaskNodeId);
                        var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
                        if (result.IsSuccess)
                        {
                            task.State = false;
                            task.UpdateTime = DateTime.Now;
                            await _taskCallbackService.Update(task);
                            message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
                            Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
                        }
                        else
                        {
                            message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
                            Log.Instance.WriteLogAdd("回调异常，请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        }

                    }
                }
                return string.IsNullOrEmpty(message) ? "无回调任务" : message;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
                return "回调异常" + ex.Message;
            }
        }

        /// <summary>
        /// 柔性产线,伺服回调任务
        /// </summary> 
        /// <returns></returns>
        public async Task<string> CallbackJob2()
        {
            List<TaskCallback> taskList = await _taskCallbackService.GetAllList();
            //在线设备
            List<Device> deviceList = _deviceService.GetDeviceList();

            taskList = taskList.Where(x => x.OperateType.Equals(ActionTypeEnum.GetFlexibleWire.ToString())
                                 || x.OperateType.Equals(ActionTypeEnum.SendFlexibleWire.ToString())
                                 || x.OperateType.Equals(ActionTypeEnum.MoveRobotPosition.ToString())
                                 || x.OperateType.Equals(ActionTypeEnum.GetServoStacker.ToString())
                                 || x.OperateType.Equals(ActionTypeEnum.SendServoStacker.ToString())).ToList();
            List<TaskCallback> list = new List<TaskCallback>();
            foreach (Device device in deviceList)
            {
                foreach (TaskCallback task in taskList)
                {
                    if (task.IP.Equals(device.Ip))
                    {
                        list.Add(task);
                    }
                }
            }
            string message = "";
            try
            {
                foreach (TaskCallback task in list)
                {
                    DateTime currentTime = DateTime.Now;
                    CcsTagValue tagValueQuery = new CcsTagValue();
                    tagValueQuery.Ip = task.IP;
                    tagValueQuery.Address = task.Address;
                    List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery);
                    CcsTagValue tagValue = null;
                    if (tagValues != null && tagValues.Count > 0)
                    {
                        tagValue = tagValues[0];
                    }
                    else
                    {

                        message = message + JsonConvert.SerializeObject(task) + ",此节点没配置;";
                        Log.Instance.WriteLogAdd("回调异常，此节点没配置" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        continue;

                    }
                    if (tagValue.TagValue.Equals(task.CallbackValue))
                    {
                        CallBackRequestData requestData = new CallBackRequestData();
                        requestData.taskId = long.Parse(task.TaskId);
                        requestData.taskNodeId = long.Parse(task.TaskNodeId);
                        var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
                        if (result.IsSuccess)
                        {
                            task.State = false;
                            task.UpdateTime = DateTime.Now;
                            await _taskCallbackService.Update(task);
                            message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
                            Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
                        }
                        else
                        {
                            message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
                            Log.Instance.WriteLogAdd("回调异常，请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        }

                    }
                    else if (!string.IsNullOrEmpty(task.CallbackValue2) && tagValue.TagValue.Equals(task.CallbackValue2))
                    {
                        CallBackRequestData requestData = new CallBackRequestData();
                        requestData.taskId = long.Parse(task.TaskId);
                        requestData.taskNodeId = long.Parse(task.TaskNodeId);
                        requestData.code = "0";
                        requestData.msg = "操作失败";
                        var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
                        if (result.IsSuccess)
                        {
                            task.State = false;
                            task.UpdateTime = DateTime.Now;
                            await _taskCallbackService.Update(task);
                            message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + message + ",请求结果:" + result.Message + ";";
                            Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
                        }
                        else
                        {
                            message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
                            Log.Instance.WriteLogAdd("回调异常，请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        }
                    }
                    else if (!string.IsNullOrEmpty(task.CallbackValue3))
                    {
                        CcsTagValue tagValueQuery3 = new CcsTagValue();
                        tagValueQuery.Ip = task.IP;
                        tagValueQuery.Address = task.Address3;
                        List<CcsTagValue> tagValues3 = _ccsTagValueService.GetList(tagValueQuery);

                        if (tagValues3 != null && tagValues3.Count > 0)
                        {
                            CcsTagValue tagValue3 = tagValues3[0];
                            if (tagValue3.TagValue.Equals(task.CallbackValue3))
                            {
                                CallBackRequestData requestData = new CallBackRequestData();
                                requestData.taskId = long.Parse(task.TaskId);
                                requestData.taskNodeId = long.Parse(task.TaskNodeId);
                                requestData.code = "0";
                                requestData.msg = "操作失败";
                                var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
                                if (result.IsSuccess)
                                {
                                    task.State = false;
                                    task.UpdateTime = DateTime.Now;
                                    await _taskCallbackService.Update(task);
                                    message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + message + ",请求结果:" + result.Message + ";";
                                    Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
                                }
                                else
                                {
                                    message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
                                    Log.Instance.WriteLogAdd("回调异常，请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                                }
                            }
                        }
                    }
                }
                return string.IsNullOrEmpty(message) ? "无回调任务" : message;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
                return "回调异常" + ex.Message;
            }
        }

        /// <summary>
        /// 打标机回调任务
        /// </summary> 
        /// <returns></returns>
        public async Task<string> CallbackJob3()
        {
            List<TaskCallback> taskList = await _taskCallbackService.GetAllList();
            //在线设备
            List<Device> deviceList = _deviceService.GetDeviceList();

            taskList = taskList.Where(x => x.OperateType.Equals(ActionTypeEnum.StartLabelMachine.ToString())).ToList();
            List<TaskCallback> list = new List<TaskCallback>();
            foreach (Device device in deviceList)
            {
                foreach (TaskCallback task in taskList)
                {
                    if (task.IP.Equals(device.Ip))
                    {
                        list.Add(task);
                    }
                }
            }
            string message = "";
            try
            {
                foreach (TaskCallback task in list)
                {
                    DateTime currentTime = DateTime.Now;
                    CcsTagValue tagValueQuery = new CcsTagValue();
                    tagValueQuery.Ip = task.IP;
                    tagValueQuery.Address = task.Address;
                    List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery);

                    CcsTagValue tagValueQuery3 = new CcsTagValue();
                    tagValueQuery3.Ip = task.IP;
                    tagValueQuery3.Address = task.Address3;
                    List<CcsTagValue> tagValues3 = _ccsTagValueService.GetList(tagValueQuery3);
                    CcsTagValue tagValue = null;
                    CcsTagValue tagValue3 = null;
                    if (tagValues != null && tagValues.Count > 0 && tagValues3 != null && tagValues3.Count > 0)
                    {
                        tagValue = tagValues[0];
                        tagValue3 = tagValues3[0];
                    }
                    else
                    {

                        message = message + JsonConvert.SerializeObject(task) + ",此节点没配置;";
                        Log.Instance.WriteLogAdd("回调异常，此节点没配置" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        continue;

                    }
                    if (tagValue.TagValue.Equals(task.CallbackValue))
                    {
                        CallBackRequestData requestData = new CallBackRequestData();
                        requestData.taskId = long.Parse(task.TaskId);
                        requestData.taskNodeId = long.Parse(task.TaskNodeId);
                        var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
                        if (result.IsSuccess)
                        {
                            if (!string.IsNullOrEmpty(task.Address3))
                            {
                                Plc s7 = DevicePlcS7.S7(task.IP, ProtocalTypeEnum.S7_1500.ToString());
                                if (s7.IsConnected == true)
                                {
                                    string Address3 = ToolUtils.AddressConvertDBW(task.Address3);
                                    short mc = 0;
                                    s7.Write(Address3, mc);
                                    s7.Close();
                                }
                            }

                            task.State = false;
                            task.UpdateTime = DateTime.Now;
                            await _taskCallbackService.Update(task);
                            message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
                            Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
                        }
                        else
                        {
                            message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
                            Log.Instance.WriteLogAdd("回调异常，请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        }

                    }
                    else if (!string.IsNullOrEmpty(task.CallbackValue2) && tagValue.TagValue.Equals(task.CallbackValue2))
                    {
                        CallBackRequestData requestData = new CallBackRequestData();
                        requestData.taskId = long.Parse(task.TaskId);
                        requestData.taskNodeId = long.Parse(task.TaskNodeId);
                        requestData.code = "0";
                        requestData.msg = "操作失败";
                        var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
                        if (result.IsSuccess)
                        {
                            task.State = false;
                            task.UpdateTime = DateTime.Now;
                            await _taskCallbackService.Update(task);
                            message = message + result.Message + ";";
                            Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
                        }
                        else
                        {
                            message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
                            Log.Instance.WriteLogAdd("回调异常，请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        }
                    }

                }
                return string.IsNullOrEmpty(message) ? "无回调任务" : message;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
                return "回调异常" + ex.Message;
            }
        }

        /// <summary>
        /// 启动机床程序,智能单元及质量中心取放回调任务
        /// </summary> 
        /// <returns></returns>
        public async Task<string> CallbackJob4()
        {
            List<TaskCallback> taskList = await _taskCallbackService.GetAllList();
            //在线设备
            List<Device> deviceList = _deviceService.GetDeviceList();

            taskList = taskList.Where(x => x.OperateType.Equals(ActionTypeEnum.GetIntelligenceUnit.ToString())
                                 || x.OperateType.Equals(ActionTypeEnum.SendIntelligenceUnit.ToString())
                                 || x.OperateType.Equals(ActionTypeEnum.GetQualityCenter.ToString())
                                 || x.OperateType.Equals(ActionTypeEnum.SendQualityCenter.ToString())
                                 || x.OperateType.Equals(ActionTypeEnum.StartNCProgram.ToString())).ToList();
            List<TaskCallback> list = new List<TaskCallback>();
            foreach (Device device in deviceList)
            {
                foreach (TaskCallback task in taskList)
                {
                    if (task.IP.Equals(device.Ip))
                    {
                        list.Add(task);
                    }
                }
            }
            string message = "";
            try
            {
                foreach (TaskCallback task in list)
                {
                    DateTime currentTime = DateTime.Now;
                    CcsTagValue tagValueQuery = new CcsTagValue();
                    tagValueQuery.Ip = task.IP;
                    tagValueQuery.Address = task.Address;
                    List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery);
                    CcsTagValue tagValue = null;
                    if (tagValues != null && tagValues.Count > 0)
                    {
                        tagValue = tagValues[0];
                    }
                    else
                    {
                        message = message + JsonConvert.SerializeObject(task) + ",此节点没配置;";
                        Log.Instance.WriteLogAdd("回调异常，此节点没配置" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        continue;
                    }
                    if (tagValue.TagValue.Equals(task.CallbackValue))
                    {
                        CallBackRequestData requestData = new CallBackRequestData();
                        requestData.taskId = long.Parse(task.TaskId);
                        requestData.taskNodeId = long.Parse(task.TaskNodeId);
                        var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
                        if (result.IsSuccess)
                        {
                            task.State = false;
                            task.UpdateTime = DateTime.Now;
                            await _taskCallbackService.Update(task);
                            message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
                            Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
                        }
                        else
                        {
                            message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
                            Log.Instance.WriteLogAdd("回调异常，请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        }
                    }
                }
                return string.IsNullOrEmpty(message) ? "无回调任务" : message;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
                return "回调异常" + ex.Message;
            }
        }
        /// <summary>
        /// 启动清洗机回调任务
        /// </summary> 
        /// <returns></returns>
        public async Task<string> CallbackJob5()
        {
            List<TaskCallback> taskList = await _taskCallbackService.GetAllList();
            //在线设备
            List<Device> deviceList = _deviceService.GetDeviceList();

            taskList = taskList.Where(x => x.OperateType.Equals(ActionTypeEnum.StartCleanMachine.ToString())).ToList();
            List<TaskCallback> list = new List<TaskCallback>();
            foreach (Device device in deviceList)
            {
                foreach (TaskCallback task in taskList)
                {
                    if (task.IP.Equals(device.Ip))
                    {
                        list.Add(task);
                    }
                }
            }
            string message = "";
            try
            {
                foreach (TaskCallback task in list)
                {
                    DateTime currentTime = DateTime.Now;
                    CcsTagValue tagValueQuery = new CcsTagValue();
                    tagValueQuery.Ip = task.IP;
                    tagValueQuery.Address = task.Address;
                    List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery);
                    CcsTagValue tagValue = null;
                    if (tagValues != null && tagValues.Count > 0)
                    {
                        tagValue = tagValues[0];
                    }
                    else
                    {
                        message = message + JsonConvert.SerializeObject(task) + ",此节点没配置;";
                        Log.Instance.WriteLogAdd("回调异常，此节点没配置" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        continue;
                    }
                    if (tagValue.TagValue.Equals(task.CallbackValue))
                    {
                        CallBackRequestData requestData = new CallBackRequestData();
                        requestData.taskId = long.Parse(task.TaskId);
                        requestData.taskNodeId = long.Parse(task.TaskNodeId);
                        var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
                        if (result.IsSuccess)
                        {
                            task.State = false;
                            task.UpdateTime = DateTime.Now;
                            await _taskCallbackService.Update(task);
                            message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
                            Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
                        }
                        else
                        {
                            message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
                            Log.Instance.WriteLogAdd("回调异常，请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        }
                    }
                }
                return string.IsNullOrEmpty(message) ? "无回调任务" : message;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
                return "回调异常" + ex.Message;
            }
        }

        /// <summary>
        /// 启动三坐标回调任务
        /// </summary> 
        /// <returns></returns>
        public async Task<string> CallbackJob6()
        {
            List<TaskCallback> taskList = await _taskCallbackService.GetAllList();
            //在线设备
            List<Device> deviceList = _deviceService.GetDeviceList();

            taskList = taskList.Where(x => x.OperateType.Equals(ActionTypeEnum.StartCoordinateMeasuringMachine.ToString())).ToList();
            List<TaskCallback> list = new List<TaskCallback>();
            foreach (Device device in deviceList)
            {
                foreach (TaskCallback task in taskList)
                {
                    if (task.IP.Equals(device.Ip))
                    {
                        list.Add(task);
                    }
                }
            }
            string message = "";
            try
            {
                foreach (TaskCallback task in list)
                {
                    DateTime currentTime = DateTime.Now;
                    CcsTagValue tagValueQuery = new CcsTagValue();
                    tagValueQuery.Ip = task.IP;
                    tagValueQuery.Address = task.Address;
                    List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery);
                    CcsTagValue tagValue = null;
                    if (tagValues != null && tagValues.Count > 0)
                    {
                        tagValue = tagValues[0];
                    }
                    else
                    {
                        message = message + JsonConvert.SerializeObject(task) + ",此节点没配置;";
                        Log.Instance.WriteLogAdd("回调异常，此节点没配置" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        continue;
                    }
                    if (tagValue.TagValue.Equals(task.CallbackValue))
                    {
                        CallBackRequestData requestData = new CallBackRequestData();
                        requestData.taskId = long.Parse(task.TaskId);
                        requestData.taskNodeId = long.Parse(task.TaskNodeId);
                        var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
                        if (result.IsSuccess)
                        {
                            task.State = false;
                            task.UpdateTime = DateTime.Now;
                            await _taskCallbackService.Update(task);
                            message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
                            Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
                        }
                        else
                        {
                            message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
                            Log.Instance.WriteLogAdd("回调异常，请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
                        }
                    }
                }
                return string.IsNullOrEmpty(message) ? "无回调任务" : message;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
                return "回调异常" + ex.Message;
            }
        }

        /// <summary>
        /// 监控设备状态
        /// </summary> 
        /// <returns></returns>
        public async Task<string> MonitorEquipmentStatusJob()
        {
            try
            {
                string message = "MonitorEquipmentStatusJob调度成功";
                List<Device> devices = _deviceService.GetDeviceList();
                //ftp不监控
                devices = devices.Where(x => !x.ProtocolType.Equals(ProtocalTypeEnum.FTP.ToString())).ToList();
                CcsTagValue tagQuery = new CcsTagValue();
                List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagQuery);
                List<EquipmentMonitor> equipmentMonitors = await _equipmentMonitorService.GetList();
                foreach (EquipmentMonitor equipment in equipmentMonitors)
                {
                    Device device = devices.Where(x => x.Ip.Equals(equipment.IP)).FirstOrDefault();
                    if (device == null)
                    {
                        equipment.Status = "离线";
                        continue;
                    }
                    else
                    {
                        if (equipment.Name == "机械手")
                        {
                            CcsTagValue ccsTagValue = tagValues.Where(x => x.Ip.Equals(equipment.IP) && x.Address.Equals(equipment.Address)).FirstOrDefault();
                            if (ccsTagValue != null)
                            {
                                if (ccsTagValue.TagValue == "3")
                                {
                                    equipment.Status = "报警";
                                    continue;
                                }
                            }
                            CcsTagValue ccsTagValue2 = tagValues.Where(x => x.Ip.Equals(equipment.IP) && x.Address.Equals(equipment.Address2)).FirstOrDefault();
                            if (ccsTagValue2 != null)
                            {
                                if (ccsTagValue2.TagValue == "9")
                                {
                                    equipment.Status = "报警";
                                    continue;
                                }
                            }

                            if (ccsTagValue2.TagValue == "0" || ccsTagValue2.TagValue == "3" || ccsTagValue2.TagValue == "6" || ccsTagValue2.TagValue == "8")
                            {
                                equipment.Status = "空闲";
                                continue;
                            }
                            equipment.Status = "生产中";
                        }
                    }
                    _equipmentMonitorService.Update(equipment);


                }
                return message;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("MonitorEquipmentStatusJob:" + ex.Message, LOG_TITLE_DEVICE);

                return "MonitorEquipmentStatusJob : " + ex.Message;
            }
        }

        /// <summary>
        /// 监控设备状态
        /// </summary> 
        /// <returns></returns>
        public async Task<string> DeviceStatusJob()
        {
            try
            {
                string message = "";
                List<Device> devices = _deviceService.GetDeviceAllList();
                //ftp不监控
                devices = devices.Where(x => !x.ProtocolType.Equals(ProtocalTypeEnum.FTP.ToString())).ToList();
                foreach (Device device in devices)
                {
                    if (device.ProtocolType.Equals(ProtocalTypeEnum.S7_1500.ToString()))
                    {
                        try
                        {

                            Plc s7 = DevicePlcS7.S7(device.ServerUrl, ProtocalTypeEnum.S7_1500.ToString());

                            if (s7.IsConnected != true)
                            {
                                Device oldDevice = await _deviceService.GetDeviceById(device.Id);
                                if (oldDevice.State)
                                {
                                    device.State = false;
                                    await _deviceService.UpdateDevice(device);
                                }
                                s7.Close();
                                Log.Instance.WriteLogAdd("plc连接失败,或已离线", LOG_TITLE_DEVICE);
                                message = message + ",plc连接失败,或已离线，ip:" + device.Ip + ",协议类型:" + device.ProtocolType;
                                continue;
                            }
                            else
                            {
                                Device oldDevice = await _deviceService.GetDeviceById(device.Id);
                                if (!oldDevice.State)
                                {
                                    device.State = true;
                                    await _deviceService.UpdateDevice(device);
                                }
                                s7.Close();
                                Log.Instance.WriteLogAdd("plc连接失败,或已离线", LOG_TITLE_DEVICE);
                                message = message + ",plc连接成功，ip:" + device.Ip + ",协议类型:" + device.ProtocolType;
                                continue;
                            }
                        }
                        catch (Exception s7ex)
                        {
                            Device oldDevice = await _deviceService.GetDeviceById(device.Id);
                            if (oldDevice.State)
                            {
                                device.State = false;
                                await _deviceService.UpdateDevice(device);
                            }
                            Log.Instance.WriteLogAdd("plc连接失败,或已离线", LOG_TITLE_DEVICE);
                            message = message + ",plc连接失败，plc连不上" + s7ex.Message + "，ip:" + device.Ip + ",协议类型:" + device.ProtocolType;
                        }
                    }
                    else if (device.ProtocolType.Equals(ProtocalTypeEnum.OPCUA.ToString()))
                    {
                        try
                        {

                            DeviceOPCUat deviceOPCUat = new DeviceOPCUat(device.ServerUrl, device.UserName, device.Password);
                            if (!deviceOPCUat.IsConnection)
                            {
                                device.State = false;
                                Device oldDevice = await _deviceService.GetDeviceById(device.Id);
                                if (oldDevice.State)
                                {
                                    await _deviceService.UpdateDevice(device);
                                }
                                Log.Instance.WriteLogAdd("OPCUA连接异常,或已离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType, LOG_TITLE_OPCUA);
                                message = message + ",OPCUA连接异常，或以离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType; ;
                                continue;
                            }
                            else
                            {
                                device.State = true;
                                await _deviceService.UpdateDevice(device);
                                deviceOPCUat.disConnect();
                                Log.Instance.WriteLogAdd("OPCUA连接成功,ip:" + device.Ip + ",协议类型:" + device.ProtocolType, LOG_TITLE_DEVICE);
                                continue;
                            }
                        }
                        catch (Exception opcex)
                        {
                            Device oldDevice = await _deviceService.GetDeviceById(device.Id);
                            if (oldDevice.State)
                            {
                                device.State = false;
                                await _deviceService.UpdateDevice(device);
                            }
                            Log.Instance.WriteLogAdd("OPCUA连接异常,或以离线" + opcex.Message + ",ip:" + device.Ip + ", 协议类型: " + device.ProtocolType, LOG_TITLE_DEVICE);
                            continue;
                        }
                    }
                    else if (device.ProtocolType.Equals(ProtocalTypeEnum.FANUC.ToString()))
                    {
                        try
                        {
                            string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
                            //调用发那科是否连接接口
                            var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=Connect", null, null);

                            if (!Result.IsSuccess || Result.Message != "0")
                            {
                                Device oldDevice = await _deviceService.GetDeviceById(device.Id);
                                if (oldDevice.State)
                                {
                                    device.State = false;
                                    await _deviceService.UpdateDevice(device);
                                }
                                Log.Instance.WriteLogAdd("Fanuc连接异常,或已离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType, LOG_TITLE_OPCUA);
                                message = message + ",Fanuc连接异常，或以离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType; ;
                                continue;
                            }
                            else
                            {
                                Device oldDevice = await _deviceService.GetDeviceById(device.Id);
                                if (!oldDevice.State)
                                {
                                    device.State = true;
                                    await _deviceService.UpdateDevice(device);
                                }
                                Log.Instance.WriteLogAdd("Fanuc连接成功,ip:" + device.Ip + ",协议类型:" + device.ProtocolType, LOG_TITLE_DEVICE);
                                continue;
                            }
                        }
                        catch (Exception opcex)
                        {
                            Device oldDevice = await _deviceService.GetDeviceById(device.Id);
                            if (oldDevice.State)
                            {
                                device.State = false;
                                await _deviceService.UpdateDevice(device);
                            }
                            Log.Instance.WriteLogAdd("Fanuc连接异常,或以离线" + opcex.Message + ",ip:" + device.Ip + ", 协议类型: " + device.ProtocolType, LOG_TITLE_DEVICE);
                            continue;
                        }
                    }
                }
                return message;
            }
            catch (Exception ex)
            {
                Log.Instance.WriteLogAdd("设备连接异常,或以离线" + ex.Message, LOG_TITLE_DEVICE);

                return "设备连接异常,或以离线" + ex.Message;
            }
        }

        /// <summary>
        /// fanuc根据类型获取值
        /// </summary> 
        /// <returns></returns>
        private string GetFanucValue(ResponseFanucData fanucData, string tagValue)
        {
            string value = "";
            if (tagValue.Equals(FanucAddressEnum.MainProg.ToString()))
            {
                value = fanucData.MainProg;
            }
            else if (tagValue.Equals(FanucAddressEnum.Status.ToString()))
            {
                value = fanucData.Status;
            }
            else if (tagValue.Equals(FanucAddressEnum.PowerOnTime.ToString()))
            {
                value = fanucData.PowerOnTime;
            }
            return value;

        }

    }
}