chf_ccs_httpserver/IMCS_CCS/Controllers/JobTasksController.cs

using IMCS.CCS.Entitys;
using IMCS.CCS.Service;
using IMCS.CCS.Services; 
using Microsoft.AspNetCore.Mvc;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using IMCS_CCS.Model.vo;
using IMCS.body.Device;

namespace IMCS.CCS.Controllers
{
    [ApiController]
    [Route("api/[controller]")]
    /// <summary>
    /// 任务调度器
    /// </summary> 
    public class JobTasksController : ControllerBase
    {
        private readonly ITaskJobService _taskJobService;

        public JobTasksController(ITaskJobService taskJobService)  
        {
            _taskJobService = taskJobService;
        }
        
        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        [HttpPost("test")]
        public async Task<string> Test()
        {
          
            return "not exist"; 
        }

        /// <summary>
        /// 上传程序回调任务
        /// </summary> 
        /// <returns></returns>
        [HttpPost("CallbackJob1")]
        public async Task<string> CallbackJob1()
        {
            return await _taskJobService.CallbackJob1();
            //return "not exist";
        }
        /// <summary>
        /// 柔性产线,伺服回调任务
        /// </summary> 
        /// <returns></returns>
        [HttpPost("CallbackJob2")]
        public async Task<string> CallbackJob2()
        {
            return await _taskJobService.CallbackJob2();
        }
        /// <summary>
        /// 打标机回调任务
        /// </summary> 
        /// <returns></returns>
        [HttpPost("CallbackJob3")]
        public async Task<string> CallbackJob3()
        {
            return await _taskJobService.CallbackJob3();
        }
        /// <summary>
        /// 启动机床程序,智能单元及质量中心取放回调任务
        /// </summary> 
        /// <returns></returns>
        [HttpPost("CallbackJob4")]
        public async Task<string> CallbackJob4()
        {
            return await _taskJobService.CallbackJob4();
        }
        /// <summary>
        /// 启动清洗机回调任务
        /// </summary> 
        /// <returns></returns>
        [HttpPost("CallbackJob5")]
        public async Task<string> CallbackJob5()
        {
            return await _taskJobService.CallbackJob5();
        }
       
      
        /// <summary>
        /// 采集数据S7
        /// </summary> 
        /// <returns></returns>
        [HttpPost("DataCollectS7Job")]
        public async Task<string> DataCollectS7Job()
        {
            return await _taskJobService.DataCollectS7Job();
        }
      

        /// <summary>
        /// 采集数据HEIDEHAIN
        /// </summary> 
        /// <returns></returns>
        [HttpPost("DataCollectHeidehainJob")]
        public async Task<string> DataCollectHeidehainJob()
        {
            return await _taskJobService.DataCollectHeidehainJob();
        }

        /// <summary>
        /// 监控设备状态
        /// </summary> 
        /// <returns></returns>
        /*[HttpPost("MonitorEquipmentStatusJob")]
        public async Task<string> MonitorEquipmentStatusJob()
        {
            return await _taskJobService.MonitorEquipmentStatusJob();
        }*/
        /// <summary>
        /// 监控设备状态
        /// </summary> 
        /// <returns></returns>
        [HttpPost("DeviceStatusJob")]
        public async Task<string> DeviceStatusJob()
        {
            return await _taskJobService.DeviceStatusJob(); 
        }
        /// <summary>
        /// 删除redis
        /// </summary> 
        /// <returns></returns> 

        [HttpPost("RemoveRedis")]
        public void RemoveRedis()
        {
            //_taskJobService.removeRedis();
        }

        /// <summary>
        /// 心跳任务
        /// </summary> 
        /// <returns></returns> 
        [HttpPost("PlcHeartbeatJob")]
        public async Task<string> PlcHeartbeatJob()
        {
            return await _taskJobService.PlcHeartbeatJob();
        }

        /// <summary>
        /// 监控设备状态
        /// </summary> 
        /// <returns></returns>
        [HttpPost("MonitorEquipmentStatusJob")]
        public async Task<string> MonitorEquipmentStatusJob2()
        {
            return await _taskJobService.MonitorEquipmentStatusJob2();
        }


        /// <summary>
        /// 采集数据S7报警数据
        /// </summary> 
        /// <returns></returns>
        [HttpPost("DataCollectS7JobWarn")]
        public async Task<List<string>> DataCollectS7JobWarn()
        {
            return await _taskJobService.DataCollectS7JobWarn();
        }

        /// <summary>
        /// 采集机床报警数据
        /// </summary> 
        /// <returns></returns>
        [HttpPost("DataCollectToolJobWarn")]
        public async Task<ResponseBody> DataCollectToolJobWarn(RequestOpcUaData requestOpcUaData)
        {
            return await _taskJobService.DataCollectToolJobWarn(requestOpcUaData);
        }


        /// <summary>
        /// 定时清楚redis缓存
        /// </summary> 
        /// <returns></returns>
        [HttpPost("remoteRedis")]
        public async Task<string> remoteRedis()
        {
            return await _taskJobService.remoteRedis();
        }

    }
}