QRAPI/API/Wood.Service/Controllers/TaskSubService.cs

using Hangfire;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Collections.Generic;
using System.Linq;

using System.Text;
using System.Threading.Tasks;
using TaskManager.Contracts.Dtos;
using TaskManager.Controllers;
using TaskManager.Entity;
using TaskManager.EntityFramework;
using TaskManager.EntityFramework.Repository;
using Wood.Util.Filters;
using Z.EntityFramework.Plus;

namespace Wood.Service.Controllers
{
    public class TaskSubService : NormalBaseController<TaskSub>
    {



        public TaskSubService(JobDbContext context, IServiceProvider builder, IConfiguration configuration, IRepository<TaskSub> repository) : base(context, builder, configuration, repository)
        {
        }


        //private async Task<PagedResult<T>> GetDataPagedAsync<T,TService,TDTO>(RequestInputBase input) 
        //    where T : BaseEntity,new()
        //    where TService :CheryRecurringJobInputPageController<T,TDTO> ,new()
        //    where TDTO : class ,new()
        //{
        //    var service = _builder.GetRequiredService<TService>();
        //    var task = input.Condition.Filters.FirstOrDefault(p => p.Column == "TableName");
        //    input.Condition.Filters.Remove(task);
        //    var result = await service.GetDataPaged(input);
        //    return result.Value;
        //}

        [HttpGet]
        public async Task<ActionResult> GetDetail([FromBody] RequestInputBase requestInputBase)
        {

            var taskid = requestInputBase.Condition.Filters.FirstOrDefault(p => p.Column == "TaskId").Value;
            var tablename = requestInputBase.Condition.Filters.FirstOrDefault(p => p.Column == "TableName").Value;

            switch (tablename)
            {
                case "SUPPLIER_PRO_MATERIAL_STOCK":



                    //_builder.GetRequiredService(requestInputBase);


                    break;
                case "SUPPLIER_PRO_SCHEDULING":
                    //RecurringJob.AddOrUpdate<>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_INFO":
                    //RecurringJob.AddOrUpdate<>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_EMPLOYEE"://人员资质信息
                    //RecurringJob.AddOrUpdate<SUPPLIER_EMPLOYEE_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_BOM"://BOM主数据

                    var bomservice = _builder.GetRequiredService<CherySupplierBomService>();
                    var bomtask = requestInputBase.Condition.Filters.FirstOrDefault(p => p.Column == "TableName");
                    requestInputBase.Condition.Filters.Remove(bomtask);
                    var bomresult = await bomservice.GetDataPaged(requestInputBase);
                    return Ok(bomresult.Value);


                case "SUPPLIER_PRO_CPS"://过程控制项质量数据
                                        //var service = _builder.GetRequiredService<CherySupplierBomService>();
                                        //var task = requestInputBase.Condition.Filters.FirstOrDefault(p => p.Column == "TableName");
                                        //requestInputBase.Condition.Filters.Remove(task);
                                        //var result = await service.GetDataPaged(requestInputBase);
                                        //return Ok(result.Value);






                    //RecurringJob.AddOrUpdate<SUPPLIER_PRO_CPS_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_PRO_DATA":
                    //RecurringJob.AddOrUpdate<SUPPLIER_PRO_DATA_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_PRO_FIRST_PASSYIELD":
                    //RecurringJob.AddOrUpdate<SUPPLIER_PRO_FIRST_PASSYIELD_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_PRO_STATION_FIRST_PASSYIELD":
                    //RecurringJob.AddOrUpdate<SUPPLIER_PRO_STATION_FIRST_PASSYIELD_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_PRO_FLAW":
                    //RecurringJob.AddOrUpdate<SUPPLIER_PRO_FLAW_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_PRO_ENVIRONMENT":
                    //RecurringJob.AddOrUpdate<SUPPLIER_PRO_ENVIRONMENT_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_PRO_OEE_ACHIEVEMENT_RATE":
                    //RecurringJob.AddOrUpdate<SUPPLIER_PRO_OEE_ACHIEVEMENT_RATE_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_PRO_OEE_TIME_DETAILS":
                    //RecurringJob.AddOrUpdate<SUPPLIER_PRO_OEE_TIME_DETAILS_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_PRO_MATERIAL_DATA"://物料主数据
                    //RecurringJob.AddOrUpdate<SUPPLIER_PRO_MATERIAL_DATA_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_PRO_PROCESS_EQUIPMENT":// 工艺装备

                    //RecurringJob.AddOrUpdate<SUPPLIER_PRO_PROCESS_EQUIPMENT_CONTROLLER>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;
                case "SUPPLIER_PRO_PROCESS"://工艺
                    //RecurringJob.AddOrUpdate<>(
                    //    task.TaskName,
                    //    x => ((IDoExecute)x).ExecuteAsync(url, path, task.TaskName),
                    //    task.Corn,
                    //    TimeZoneInfo.Local
                    //);
                    break;



            }
            return Ok();
        }

    }






    
}