using CommLayerFactory;
using ICommLayer;
using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Data;
using System.Text;
using WcfControlMonitorLib;

namespace WcfControlMonitorWebLib.Controllers
{
    /// <summary>
    /// 设备状态
    /// </summary>
    [ApiController, Route("api/device")]
    public class DeviceController: ControllerBase
    {
        DBFactory.DBOperator dbo = CStaticClass.dbo;
        DBFactory.DBOperator dboMan = CStaticClass.dboM;
        StringBuilder sql = new StringBuilder();
        //List<Model.MDevice> deviceList = new List<Model.MDevice>();
        List<Model.ClientMDevice> deviceList = new List<Model.ClientMDevice>();

        //SControlMonitor scontrol = new SControlMonitor();

        /// <summary>
        /// 获取初始化设备状态
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        public IActionResult GetList()
        {
            //sql.Remove(0, sql.Length);
            //sql.Append("select T_Base_Device.F_DeviceIndex from T_Base_Device, T_Base_Device_Kind " +
            //    "where T_Base_Device.F_DeviceKindIndex = T_Base_Device_Kind.F_DeviceKindIndex" +
            //    " and T_Base_Device_Kind.F_GoodsMoveKindIndex = 1 and T_Base_Device.F_DeviceKindIndex not in (12) ");//not in 是为了把虚拟关键设备拿掉 
            ////T_Base_Device_Kind里面关键设备的F_GoodsMoveKindIndex =1 没动数据库配置 就在这排除一下 虚拟关键设备客户端没画 会报错
            ///
            sql.Remove(0, sql.Length);
            sql.Append("select T_Base_Device.F_DeviceIndex from T_Base_Device, T_Base_Device_Kind " +
                "where T_Base_Device.F_DeviceKindIndex = T_Base_Device_Kind.F_DeviceKindIndex" +
                " and (T_Base_Device_Kind.F_GoodsMoveKindIndex = 1 or T_Base_Device_Kind.F_DeviceKindIndex=7) and T_Base_Device.F_SUBSCRIBECLIENT =1 and T_Base_Device.F_DeviceKindIndex not in (12,22,35,10,8,37) ");//not in 是为了把虚拟关键设备拿掉  F_DeviceKindIndex=7是扫码器
            //T_Base_Device_Kind里面关键设备的F_GoodsMoveKindIndex =1 没动数据库配置 就在这排除一下 虚拟关键设备客户端没画 会报错
            DataView dv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
            if (dv.Count > 0)
            {
                int iDevice = 0;
                for (int i = 0; i < dv.Count; i++)
                {
                    iDevice = int.Parse(dv[i]["F_DeviceIndex"].ToString());

                    //方案一 简化一下给客户端发
                    Model.MDevice mDevice = Model.CGetInfo.GetDeviceInfo(iDevice);
                    deviceList.Add(Model.CGetInfo.SendMessageToClient(mDevice));

                    #region 
                    //Model.MDevice mDevice= Model.CGetInfo.GetDeviceInfo(iDevice);
                    //if (mDevice.LogicHaveGoods)
                    //{
                    //    mDevice.HaveGoodsMeg = "逻辑有货";
                    //}
                    //else
                    //{
                    //    mDevice.HaveGoodsMeg = "逻辑无货";
                    //}
                    ////处理数据库查询相关的
                    //#region 目标位置 和条码
                    //sql.Remove(0, sql.Length);
                    //sql.Append("SELECT F_MonitorIndex,F_DeviceCommandIndex,F_NumParam1,F_NumParam2,F_NumParam3,F_NumParam4,F_NumParam5,F_NumParam6, F_TxtParam FROM T_Monitor_Task WHERE F_MonitorIndex =").Append(mDevice.TaskNo);
                    //DataView dvdv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                    //if (dvdv.Count > 0)
                    //{
                    //    int order = Convert.ToInt32(dvdv[0]["F_DeviceCommandIndex"]);
                    //    string info = string.Empty;

                    //    int Z = Convert.ToInt32(dvdv[0]["F_NumParam1"]);
                    //    int X = Convert.ToInt32(dvdv[0]["F_NumParam2"]);
                    //    int Y = Convert.ToInt32(dvdv[0]["F_NumParam3"]);
                    //    int Z1 = Convert.ToInt32(dvdv[0]["F_NumParam4"]);
                    //    int X1 = Convert.ToInt32(dvdv[0]["F_NumParam5"]);
                    //    int Y1 = Convert.ToInt32(dvdv[0]["F_NumParam6"]);

                    //    if (mDevice.DeviceKind == 1)
                    //    {
                    //        switch (order)
                    //        {
                    //            case 1://回原点
                    //                info = string.Format("回原点:01列01层");
                    //                break;
                    //            case 2://将取
                    //                info = string.Format("将取:{0:D2}排-{1:D2}列-{2:D2}层", Z, X, Y);
                    //                break;
                    //            case 3://将送
                    //                info = string.Format("将送:{0:D2}排-{1:D2}列-{2:D2}层", Z1, X1, Y1);
                    //                break;
                    //            case 4://取
                    //                info = string.Format("取货:{0:D2}排-{1:D2}列-{2:D2}层", Z, X, Y);

                    //                break;
                    //            case 5://送
                    //                info = string.Format("送货:{0:D2}排-{1:D2}列-{2:D2}层", Z1, X1, Y1);
                    //                break;
                    //            case 6:
                    //                info = string.Format("取送货:{0:D2}排-{1:D2}列-{2:D2}层 到 {3:D2}排-{4:D2}列-{5:D2}层", Z, X, Y, Z1, X1, Y1);
                    //                break;
                    //        }
                    //    }
                    //    else if (mDevice.DeviceKind == 2)
                    //    {
                    //        switch (order)
                    //        {
                    //            case 1://正转
                    //                info = string.Format("正转");
                    //                break;
                    //            case 2://反转
                    //                info = string.Format("反转");
                    //                break;
                    //            case 6://送出
                    //                info = string.Format("{0}送出到{1}", Z, Z1);
                    //                break;
                    //        }
                    //    }
                    //    else if (mDevice.DeviceKind == 4)
                    //    {
                    //        switch (order)
                    //        {
                    //            case 7://运动
                    //                info = string.Format("运动:{0}", Z);
                    //                break;
                    //            case 8://取
                    //                info = string.Format("取货:{0}", Z);
                    //                break;
                    //            case 9://送
                    //                info = string.Format("送货:{0}", Z);
                    //                break;
                    //        }
                    //    }
                    //    mDevice.ArrowLocation = info;
                    //    mDevice.Barcode = dvdv[0]["F_TxtParam"].ToString();
                    //}
                    //else
                    //{
                    //    //20140109
                    //    if (mDevice.DeviceKind == 2)
                    //    {
                    //        // add for CATL 动作完成状态
                    //        if (mDevice.RunState == 5 && mDevice.SplitByte_0 == 1)
                    //        {
                    //            //条码号
                    //            object bcode = dbo.GetSingle(string.Format("SELECT F_PALLETBARCODE FROM T_Base_Device WHERE (F_DeviceIndex = {0})", mDevice.DeviceIndex));
                    //            if (bcode != null)
                    //            {
                    //                mDevice.Barcode = bcode.ToString();
                    //            }
                    //            else
                    //            {
                    //                mDevice.Barcode = "";

                    //            }
                    //        }
                    //        else
                    //        {
                    //            //条码号
                    //            mDevice.Barcode = "";
                    //        }
                    //    }
                    //    else
                    //    {
                    //        //条码号
                    //        mDevice.Barcode = "";
                    //    }
                    //    //目标位置
                    //    mDevice.ArrowLocation = "";
                    //}
                    //#endregion

                    //#region 获取报警信息
                    //设备状态
                    switch (mDevice.RunState)
                    {
                        case 0:
                            mDevice.ErrorMessage = "空闲";
                            break;
                        case 1:
                            mDevice.ErrorMessage = "运行";
                            break;
                        case 2:
                            mDevice.ErrorMessage = "故障";
                            break;
                        case 3:
                            mDevice.ErrorMessage = "离线";
                            break;
                        case 4:
                            mDevice.ErrorMessage = "停用";
                            break;
                        case 5://20090920
                            mDevice.ErrorMessage = "动作完成";
                            break;
                    }
                    if (mDevice.ErrorCode >= 30)
                    {
                        Model.MError err = Model.CGetInfo.GetErrorInfo(Convert.ToInt32(mDevice.DeviceKind.ToString() + mDevice.ErrorCode.ToString()));
                        if (err != null)
                        {
                            mDevice.ErrorMessage = err.ErrorName + "，代码：" + mDevice.ErrorCode.ToString();
                        }
                        else
                        {
                            mDevice.ErrorMessage = mDevice.ErrorCode.ToString();
                        }
                    }
                    else
                    {
                        mDevice.ErrorMessage = "";
                    }
                    //#endregion
                    //#region 获取管理任务号
                    ////sql.Remove(0, sql.Length);
                    ////sql.Append("");
                    ////dv = dbo.ExceSQL(sql.ToString()).Tables[0].DefaultView;
                    //#endregion

                    //deviceList.Add(mDevice);
                    #endregion
                }
            }
            return StatusCode(200, deviceList);
        }


        /// <summary>
        /// 补码
        /// </summary>
        [HttpPost]
        [Route("barcode")]
        public IActionResult BarcodeApplyCreate(
            [FromMember] int deviceIndex, 
            [FromMember] string newBarcode,
            string session
            )
        {
            Model.MDevice dev = Model.CGetInfo.GetDeviceInfo(deviceIndex);

            StringBuilder dtime = new StringBuilder(DateTime.Now.ToString("u"));
            dtime.Remove(dtime.Length - 1, 1);
            int apptype = 0;
            int intBarDevice = 0;
            string warehouse = "1";
            string applyStation = "CW";

            DataView dvapp = dbo.ExceSQL(string.Format("SELECT F_MANAGEASKKIND,F_DEVICEINDEX,F_WareHouse,F_BindingDevice FROM T_BASE_PLC_ASK WHERE  F_DEVICEINDEX = {0}", deviceIndex)).Tables[0].DefaultView;
            if (dvapp.Count > 0)
            {
                apptype = Convert.ToInt32(dvapp[0]["F_MANAGEASKKIND"]);
                intBarDevice = Convert.ToInt32(dvapp[0]["F_DEVICEINDEX"]);
                warehouse = Convert.ToString(dvapp[0]["F_WareHouse"]);
                applyStation = Convert.ToString(dvapp[0]["F_BindingDevice"]);
            }
            
            
            string barcode = newBarcode.ToString();
            DataView dvbcApply = new DataView();
            dvbcApply = dboMan.ExceSQL(string.Format("SELECT DEVICE_CODE,STOCK_BARCODE FROM IO_CONTROL_APPLY WHERE APPLY_TASK_STATUS<2  and (STOCK_BARCODE = '{0}')", barcode)).Tables[0].DefaultView;
            if (dvbcApply.Count > 0)
            {
                return StatusCode(409);
                //tbBarcode.Text = "";
                //MessageBox.Show("当前条码已存在申请！", "误操作提示", MessageBoxButtons.OK, MessageBoxIcon.Warning);
            }
            DataView dvbc = new DataView();
            dvbc = dboMan.ExceSQL(string.Format("select CONTROL_ID from IO_CONTROL  where CONTROL_STATUS<>999 and CONTROL_STATUS<>300 and  STOCK_BARCODE = '{0}'", barcode)).Tables[0].DefaultView;//管理系统有可能还没处理已经报告完成的任务
            if (dvbc.Count > 0)
            {
                return StatusCode(410);
                //tbBarcode.Text = "";
                //MessageBox.Show("当前条码已经生成控制任务！", "误操作提示", MessageBoxButtons.OK, MessageBoxIcon.Warning);
            }
            DataView dvbcc = new DataView();
            dvbcc = dbo.ExceSQL(string.Format("select fid from T_Manage_Task  where FPALLETBARCODE = '{0}'", barcode)).Tables[0].DefaultView;
            if (dvbcc.Count > 0)
            {
                return StatusCode(422);
                //tbBarcode.Text = "";
                //MessageBox.Show("当前条码存在调度任务！", "误操作提示", MessageBoxButtons.OK, MessageBoxIcon.Warning);
            }

            int row = 0;
            string remake = "补码";
            object[] ob = new object[7] { apptype, applyStation, barcode, 0, dtime, remake, warehouse };
            //oracle
            //row = dboMan.ExecuteSql(string.Format("INSERT INTO IO_CONTROL_APPLY ( CONTROL_APPLY_ID,CONTROL_APPLY_TYPE,DEVICE_CODE, STOCK_BARCODE, APPLY_TASK_STATUS, CREATE_TIME,CONTROL_APPLY_REMARK,WAREHOUSE_CODE)VALUES ( IO_CONTROL_APPLY_SEQ.Nextval,{0},'{1}','{2}',{3},'{4}','{5}','{6}')", ob));
            row = dboMan.ExecuteSql(string.Format("INSERT INTO IO_CONTROL_APPLY (CONTROL_APPLY_TYPE,DEVICE_CODE, STOCK_BARCODE, APPLY_TASK_STATUS, CREATE_TIME,CONTROL_APPLY_REMARK,WAREHOUSE_CODE)VALUES ({0},'{1}','{2}',{3},'{4}','{5}','{6}')", ob));

            string sql = "UPDATE T_BASE_PLC_ASK SET F_BARCODE ='" + barcode + "' WHERE F_DEVICEINDEX =" + deviceIndex;
            dbo.ExceSQL(sql);
            if (row == 1)
            {
                object[] ob1 = new object[7] { apptype, applyStation, barcode, 0, dtime, remake, warehouse.ToString() };
                //dbo.ExecuteSql(string.Format("INSERT INTO IO_CONTROL_APPLY_WCS (CONTROL_APPLY_ID,CONTROL_APPLY_TYPE,DEVICE_CODE, STOCK_BARCODE, APPLY_TASK_STATUS, CREATE_TIME,CONTROL_APPLY_PARA01,WAREHOUSE_CODE)VALUES (IO_CONTROL_APPLY_WCS_SEQ.Nextval,{0},'{1}','{2}',{3},'{4}','{5}','{6}')", ob1));
                dbo.ExecuteSql(string.Format("INSERT INTO IO_CONTROL_APPLY_WCS (CONTROL_APPLY_TYPE,DEVICE_CODE, STOCK_BARCODE, APPLY_TASK_STATUS, CREATE_TIME,CONTROL_APPLY_REMARK,WAREHOUSE_CODE)VALUES ({0},'{1}','{2}',{3},'{4}','{5}','{6}')", ob1));
                CommonClassLib.CCarryConvert.WriteDarkCasket("ClientBacorde", "客户端补码", barcode.ToString().ToUpper(), "补码站台和账户:" + deviceIndex.ToString() + "|" + session);

                dev.Barcode = barcode;
                Model.CGetInfo.SetDeviceInfo(dev);
                
            }
            return Ok();
        }

        /// <summary>
        /// 设备操作
        /// </summary>
        /// <param name="Device"></param>
        /// <param name="Action">4.设备复位；2.完成应答；1.逻辑有无物；3.逻辑预约锁解锁</param>
        /// <param name="value"></param>
        [HttpPut]

        public void Put(
            [FromQuery]int Device,
            [FromQuery]int Action,
            [FromQuery]int? value,
            string session)//这个session就能拿到用户名
        {
            //string a = session;
            string o = string.Empty;
            Model.MDevice dev = Model.CGetInfo.GetDeviceInfo(Device);
            ISendDeviceOrder sdo;
            sdo = CommModeCreate.CreateSendDeviceOrder(Device);

            switch (Action)
            {
                case 1:
                    if (value.HasValue)
                    {
                        if (value == 1)
                        {
                            dbo.ExceSQL(string.Format("UPDATE T_Base_Device SET F_HaveGoods = 1 where  F_DeviceIndex ={0}", Device));
                            dev.LogicHaveGoods = true;
                        }
                        else if (value == 0)
                        {
                            dbo.ExceSQL(string.Format("UPDATE T_Base_Device SET F_HaveGoods = 0 where  F_DeviceIndex ={0}", Device));
                            dev.LogicHaveGoods = false;
                        }
                        Model.CGetInfo.SetDeviceInfo(dev);
                    }
                    break;
                case 2:
                    if ((dev.DeviceKind == 1) || (dev.DeviceKind == 6))
                    {
                        sdo.SendDeviceOrder(2, 0, 0, Device, 0, 0, 0, 0, 0, 0);
                    }
                    else
                    {
                        //// add for CATL  联机停车值判断
                        //if (deviceKind == 40)
                        //{
                        //    sdo.SendDeviceOrder(ResetOrder, 0, ResetOrder, Device, 0);
                        //}
                        //else
                        //{
                        sdo.SendDeviceOrder(2, 0, 0, Device, 0);
                        //}
                    }
                    dev.SendMessage = null;
                    Model.CGetInfo.SetDeviceInfo(dev);

                    break;
                case 3:
                    int count=dbo.ExecuteSql(string.Format("UPDATE T_Base_Device SET F_ManTaskReserve = 0 where F_ManTaskReserve != 0 and F_DeviceIndex ={0}", Device));
                    if (count > 0)
                    {
                        Model.CGetInfo.SetDeviceInfo(dev);
                    }
                    break;
                case 4:
                    if ((dev.DeviceKind == 1) || (dev.DeviceKind == 6))
                    {
                        sdo.SendDeviceOrder(4, 0, 0, Device, 0, 0, 0, 0, 0, 0);
                    }
                    else
                    {
                        //// add for CATL  联机停车值判断
                        //if (deviceKind == 40)
                        //{
                        //    sdo.SendDeviceOrder(ResetOrder, 0, ResetOrder, Device, 0);
                        //}
                        //else
                        //{
                        sdo.SendDeviceOrder(4, 0, 0, Device, 0);
                        //}
                    }
                    dev.SendMessage = null;
                    Model.CGetInfo.SetDeviceInfo(dev);
                    break;
                default:
                    break;
            }

        }

        /// <summary>
        /// 设备上位机急停
        /// </summary>
        /// <param name="device"></param>
        /// <param name="deviceaction"></param>
        /// <returns></returns>
        [HttpGet("stopMoveDevice")]
        public IActionResult StopMoveDevice([FromQuery] string device, [FromQuery] string deviceaction)
        {
            //联机停车
            try
            {
                Model.MDevice dev = Model.CGetInfo.GetDeviceInfo(Convert.ToInt32(device));
                ISendDeviceOrder sdo;
                StringBuilder[] wv = { new StringBuilder("2") };
                StringBuilder[] witemnames = { new StringBuilder("") };
                sdo = CommModeCreate.CreateSendDeviceOrder(Convert.ToInt32(device));
                witemnames[0].Clear();
                witemnames[0].Append(Model.CGeneralFunction.DBSend).Append(".").Append(Convert.ToString(dev.Dbw1Address + 19)).Append(",b");//20130510
                wv[0].Clear();
                wv[0].Append(deviceaction.ToString());
                sdo = CommModeCreate.CreateSendDeviceOrder(Convert.ToInt32(device));
                sdo.WriteDBData(witemnames, wv, dev.S7Connection);
                return Ok();
            }
            catch (Exception ex)
            {
                return Ok();
            }
        }




    }


}