using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WcfControlMonitorLib;

namespace WcfControlMonitorWebLib.Controllers
{
    [ApiController, Route("api/managetask")]
    public class ManageTaskController : ControllerBase
    {
        DBFactory.DBOperator dbo = CStaticClass.dbo;
        StringBuilder sql = new StringBuilder();
        DataView dv = new DataView();
        SControlMonitor WcfControl = new SControlMonitor(false);

        /// <summary>
        /// 获取数据
        /// </summary>
        /// <param name="id">调度任务索引</param>
        /// <param name="barcode"></param>
        /// <param name="startDevice"></param>
        /// <param name="startCell"></param>
        /// <param name="endDevice"></param>
        /// <param name="endCell"></param>
        /// <param name="taskStatus"></param>
        /// <param name="sort"></param>
        /// <param name="offset"></param>
        /// <param name="limit"></param>
        /// <returns></returns>
        [HttpGet]
        public IActionResult Get(
            [FromQuery] string id,
            [FromQuery] string barcode,
            //[FromQuery] string taskKind,
            [FromQuery] string controlTaskKind,
            //[FromQuery] string ftaskLevel,
            [FromQuery] string startDevice,
            [FromQuery] string startCell,
            [FromQuery] string endDevice,
            [FromQuery] string endCell,
            //[FromQuery] string fIntoStepOK,
            [FromQuery] string currentDevice,
            [FromQuery] string taskStatus,
            [FromQuery] string palletType,
            //[FromQuery] string errorInfo,
            [FromQuery] string sort,
            [FromQuery] int? offset,
            [FromQuery] int? limit)//可以不传这么多 看前端允许根据什么来筛选 允许什么传什么就行
        {

            if (offset == null)
            {
                offset = 0;
            }
            if (limit == null)
            {
                limit = 30;
            }
            #region  排序信息需要转一下
            if (sort?.Length > 1)
            {
                var format = sort?.StartsWith("~") == true ? "{0} DESC" : "{0}";
                if ((bool)sort?.StartsWith("~"))
                {
                    switch (sort.Substring(2))
                    {
                        //barcode,fid,taskKind,controlTaskKind,ftaskLevel,startDevice,startCell,endDevice,endCell,fIntoStepOK,currentDevice,taskStatus,startTime,errorInfo
                        case "arcode":
                            sort = string.Format(format, "条码");
                            break;
                        case "d":
                            sort = string.Format(format, "调度任务索引");
                            break;
                        case "askKind":
                            sort = string.Format(format, "任务类型");
                            break;
                        case "ontrolTaskKind":
                            sort = string.Format(format, "作业类型");
                            break;
                        case "taskLevel":
                            sort = string.Format(format, "优先级");
                            break;
                        case "tartDevice":
                            sort = string.Format(format, "起点");
                            break;
                        case "tartCell":
                            sort = string.Format(format, "起点货位");
                            break;
                        case "ndDevice":
                            sort = string.Format(format, "终点");
                            break;
                        case "ndCell":
                            sort = string.Format(format, "终点货位");
                            break;
                        case "IntoStepOK":
                            sort = string.Format(format, "拆分状态");
                            break;
                        case "urrentDevice":
                            sort = string.Format(format, "当前执行设备");
                            break;
                        case "askStatus":
                            sort = string.Format(format, "任务状态");
                            break;
                        case "tartTime":
                            sort = string.Format(format, "开始时间");
                            break;
                        case "rrorInfo":
                            sort = string.Format(format, "故障信息");
                            break;
                        default:
                            sort = "调度任务索引";
                            break;
                    }
                }
                else
                {
                    switch (sort.Substring(1))
                    {
                        case "arcode":
                            sort = string.Format(format, "条码");
                            break;
                        case "d":
                            sort = string.Format(format, "调度任务索引");
                            break;
                        case "askKind":
                            sort = string.Format(format, "任务类型");
                            break;
                        case "ontrolTaskKind":
                            sort = string.Format(format, "作业类型");
                            break;
                        case "taskLevel":
                            sort = string.Format(format, "优先级");
                            break;
                        case "tartDevice":
                            sort = string.Format(format, "起点");
                            break;
                        case "tartCell":
                            sort = string.Format(format, "起点货位");
                            break;
                        case "ndDevice":
                            sort = string.Format(format, "终点");
                            break;
                        case "ndCell":
                            sort = string.Format(format, "终点货位");
                            break;
                        case "IntoStepOK":
                            sort = string.Format(format, "拆分状态");
                            break;
                        case "urrentDevice":
                            sort = string.Format(format, "当前执行设备");
                            break;
                        case "askStatus":
                            sort = string.Format(format, "任务状态");
                            break;
                        case "tartTime":
                            sort = string.Format(format, "开始时间");
                            break;
                        case "rrorInfo":
                            sort = string.Format(format, "故障信息");
                            break;
                        default:
                            sort = "调度任务索引";
                            break;
                    }
                }

            }
            else
            {
                sort = "调度任务索引";
            }
            #endregion
            //barcode,fid,taskKind,controlTaskKind,ftaskLevel,startDevice,startCell,endDevice,endCell,fIntoStepOK,currentDevice,taskStatus,startTime,errorInfo
            #region  拼接 where 条件
            var where = "1=1";
            if (!string.IsNullOrEmpty(barcode))
            {
                where = $"{where} AND 条码 = '{barcode}'";
            }
            if (!string.IsNullOrEmpty(id))
            {
                where = $"{where} AND 调度任务索引 = {id}";
            }
            if (!string.IsNullOrEmpty(palletType))
            {
                where = $"{where} AND 托盘类型 = '{palletType}'";
            }
            if (!string.IsNullOrEmpty(controlTaskKind))
            {
                where = $"{where} AND 作业类型 = '{controlTaskKind}'";
            }
            //if (!string.IsNullOrEmpty(ftaskLevel))
            //{
            //    where = $"{where} AND 优先级 = {ftaskLevel}";
            //}
            if (!string.IsNullOrEmpty(startDevice))
            {
                where = $"{where} AND 起点 = '{startDevice}'";
            }
            if (!string.IsNullOrEmpty(startCell))
            {
                where = $"{where} AND 起点货位 = '{startCell}'";
            }
            if (!string.IsNullOrEmpty(endDevice))
            {
                where = $"{where} AND 终点 = '{endDevice}'";
            }
            if (!string.IsNullOrEmpty(endCell))
            {
                where = $"{where} AND 终点货位 = '{endCell}'";
            }
            //if (!string.IsNullOrEmpty(fIntoStepOK))
            //{
            //    where = $"{where} AND 拆分状态 = {fIntoStepOK}";
            //}
            if (!string.IsNullOrEmpty(currentDevice))
            {
                where = $"{where} AND 当前执行设备 = '{currentDevice}'";
            }
            if (!string.IsNullOrEmpty(taskStatus))
            {
                switch (taskStatus)
                {
                    case "0":
                        taskStatus = "等待执行";
                        break;
                    case "1":
                        taskStatus = "开始执行";
                        break;

                }
                where = $"{where} AND 任务状态 = '{taskStatus}'";
            }
            //if (!string.IsNullOrEmpty(startTime))
            //{
            //    where = $"{where} AND 开始时间 = '{startTime}'";
            //}
            //if (!string.IsNullOrEmpty(errorInfo))
            //{
            //    where = $"{where} AND 故障信息 LIKE '%{errorInfo}%'";
            //}
            #endregion
            var sql = $"SELECT TOP {limit} barcode,id,taskKind,controlTaskKind,ftaskLevel,startDevice,startCell,endDevice,endCell,fIntoStepOK,currentDevice,taskStatus,startTime,errorInfo,statusCode,useAwayFork,palletType FROM (SELECT 条码 as barcode, 调度任务索引 AS id,任务类型 as TaskKind,作业类型 as ControlTaskKind ,优先级 as ftaskLevel,起点 as StartDevice,起点货位 as StartCell,终点 as EndDevice ,终点货位 as EndCell,拆分状态 as FIntoStepOK ,当前执行设备 as CurrentDevice,任务状态 AS TaskStatus,开始时间 AS StartTime,故障信息 as errorInfo,F_Status as statusCode,货叉 as useAwayFork,托盘类型 as palletType ,ROW_NUMBER() OVER (ORDER BY {sort}) AS ROW_NUM FROM  V_manage_task WHERE {where}) AS T WHERE ROW_NUM > {offset}";
            var sqlAll = $"SELECT barcode,id,TaskKind,ControlTaskKind,ftaskLevel,StartDevice,StartCell,EndDevice,EndCell,FIntoStepOK,CurrentDevice,TaskStatus,StartTime,errorInfo,statusCode,useAwayFork,palletType FROM (SELECT 条码 as barcode, 调度任务索引 AS id,任务类型 as TaskKind,作业类型 as ControlTaskKind ,优先级 as ftaskLevel,起点 as StartDevice,起点货位 as StartCell,终点 as EndDevice ,终点货位 as EndCell,拆分状态 as FIntoStepOK ,当前执行设备 as CurrentDevice,任务状态 AS TaskStatus,开始时间 AS StartTime,故障信息 as errorInfo,F_Status as statusCode,货叉 as useAwayFork,托盘类型 as palletType ,ROW_NUMBER() OVER (ORDER BY {sort}) AS ROW_NUM FROM  V_manage_task WHERE {where}) AS T WHERE ROW_NUM > 0";

            DataView dv1 = CStaticClass.dbo.ExceSQL(sqlAll.ToString()).Tables[0].DefaultView;//满足的条件的所有数据 返回总记录条数用

            dv = CStaticClass.dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;

            var items = new dynamic[dv.Count];
            for (int i = 0; i < dv.Count; i++)
            {
                //barcode,fid,taskKind,controlTaskKind,ftaskLevel,startDevice,startCell,endDevice,endCell,fIntoStepOK,currentDevice,taskStatus,startTime,errorInfo
                items[i] = new {
                    id = Convert.ToInt32(dv[i]["id"]),
                    barcode = Convert.ToString(dv[i]["barcode"]),
                    taskKind = Convert.ToString(dv[i]["taskKind"]),
                    controlTaskKind = Convert.ToString(dv[i]["controlTaskKind"]),
                    ftaskLevel = Convert.ToInt32(dv[i]["ftaskLevel"]),
                    startDevice = Convert.ToString(dv[i]["startDevice"]),
                    startCell = Convert.ToString(dv[i]["startCell"]),
                    endDevice = Convert.ToString(dv[i]["endDevice"]),
                    endCell = Convert.ToString(dv[i]["endCell"]),
                    fIntoStepOK = Convert.ToInt32(dv[i]["fIntoStepOK"]),
                    currentDevice = Convert.ToString(dv[i]["currentDevice"]),
                    taskStatus = Convert.ToString(dv[i]["taskStatus"]),
                    startTime = Convert.ToString(dv[i]["startTime"]),
                    errorInfo = Convert.ToString(dv[i]["errorInfo"]),
                    statusCode = Convert.ToInt32(dv[i]["statusCode"]),
                    useAwayFork = Convert.ToString(dv[i]["useAwayFork"]),
                    palletType = Convert.ToString(dv[i]["palletType"]),
                };
            }
            return Ok(new { total = dv1.Count, items });
        }


        /// <summary>
        /// 操作 删除 完成
        /// </summary>
        /// <param name="id">任务编号FID</param>
        /// <param name="action">动作代码 999 990</param>
        /// <param name="kind">TaskKindIndex 调度任务 自动任务。。</param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult Post(
           [FromMember] int id,
           [FromMember] int action,
           [FromMember] string kind)
        {
            // 写入数据库
            string o;
            sql.Remove(0, sql.Length);
            sql.Append("SELECT F_TaskKindIndex FROM T_Base_Manage_Task_Kind WHERE F_TaskKindName = '").Append(kind).Append("'");
            dv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
            if (dv.Count > 0)
            {
                int iKind = int.Parse(dv[0]["F_TaskKindIndex"].ToString());
                WcfControl.ModifyManageTask(iKind, id, action, out o);
                if (!string.IsNullOrEmpty(o))
                {
                    return StatusCode(422);
                }
                return StatusCode(200);
            }

            return StatusCode(422);

        }

        /// <summary>
        /// 批量处理
        /// 前端批量删除时候调用 
        /// </summary
        //[HttpPost("batch")]
        //public IActionResult Batch(
        //    [FromMember] string[] data) // 这个是指令编号
        //{
        //    int count = 0;
        //    int action = 900;
        //    // 写入数据库
        //    foreach (var item in data)
        //    {
        //        var sqlStatus = $"select FSTATUS from T_Manage_Task where fid={item}";
        //        dv = dbo.ExceSQL(sqlStatus.ToString()).Tables[0].DefaultView;
        //        if (dv.Count > 0)
        //        {
        //            if (Convert.ToInt32(dv[0]["FSTATUS"]) <= 0)
        //            {
        //                string o;
        //                sql.Remove(0, sql.Length);
        //                sql.Append("select F_ManageTaskKindIndex from T_Manage_Task where fid=").Append(item);
        //                dv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
        //                if (dv.Count > 0)
        //                {
        //                    int iKind = int.Parse(dv[0]["F_ManageTaskKindIndex"].ToString());
        //                    sc.ModifyManageTask(iKind, int.Parse(item), action, out o);
        //                    if (o == "")
        //                    {
        //                        count++;
        //                    }
        //                }
        //            }
        //        }
        //    }
        //    if (count > 0)
        //    {
        //        return StatusCode(200);
        //    }
        //    else
        //    {
        //        return StatusCode(422);
        //    }

        //}

    }
}