using System;
using System.Threading;
using iWareCommon.Utils;

using System.Linq;
using Newtonsoft.Json;
using System.Collections.Generic;
using iWareCommon;
using System.Text;
using iWareModel;



namespace iWareSda
{
    // 注意: 使用“重构”菜单上的“重命名”命令，可以同时更改代码和配置文件中的类名“LineService”。
    public class LineService : ILineService
    {
        private static string _namespace = "iWareSda.LineService";
        private static string nofoundStackerMsg = SysHelper.Language(WareSdaStruct.LanguageFlg, "没有找到输送线", "No found the Line");
        public LineView GetLineInfo(int deviceId)
        {
            var device = Line_CacheEntity.DeviceObjs.FirstOrDefault(x => x.View.DeviceId == deviceId);
            if (device == null)
            {
                return null;
            }
            return device.View;
        }

        /// <summary>
        /// 判断是否有心跳
        /// </summary>
        /// <param name="deviceId"></param>
        /// <returns></returns>
        public SdaResEntity IsHaveHeatBeat(int deviceId)
        {
            SdaResEntity sdaResult = new SdaResEntity();
            string msg;
            try
            {
                var device = Line_CacheEntity.DeviceObjs.FirstOrDefault(x => x.View.DeviceId == deviceId);
                if (device == null)
                {
                    sdaResult.resMsg = nofoundStackerMsg;
                    return sdaResult;
                }

                var result = device.IsHaveHeatBeat();

                sdaResult.result = true;
                sdaResult.resData = result;
                return sdaResult;

            }
            catch (Exception ex)
            {
                msg = "验证是否有心跳出现异常:" + ex.Message;
                Log4NetHelper.WriteErrorLog(LogType.LineSdaService, msg, ex);
                sdaResult.result = false;
                sdaResult.resMsg = msg;
                return sdaResult;
            }
        }

        /// <summary>
        /// 检测设备是否可以发任务
        /// </summary>
        /// <returns></returns>
        public SdaResEntity IsAllowSendTask(int deviceId)
        {
            SdaResEntity res = new SdaResEntity();
            res.result = true;
            return res;
            //try
            //{
            //    DeviceEnum device = (DeviceEnum)Enum.Parse(typeof(DeviceEnum), deviceId.ToString());
            //    AreaEnum area = BussinessHelper.GetAreaByDevice(device);
            //    var line = Line_CacheEntity.Lines[0];
            //    switch (area)
            //    {
            //        case AreaEnum.区域1:
            //            if (!line.R_AutoMode_1)
            //            {
            //                res.resData = false;
            //                res.resMsg = "区域1设备不是自动模式";
            //                return res;
            //            }
            //            break;
            //        case AreaEnum.区域2:
            //            if (!line.R_AutoMode_2)
            //            {
            //                res.resData = false;
            //                res.resMsg = "区域2设备不是自动模式";
            //                return res;
            //            }
            //            break;
            //    }

            //    if (!line.IsConnected)
            //    {
            //        res.resData = false;
            //        res.resMsg = "未与PLC连接";
            //        return res;
            //    }

            //    switch (device)
            //    {
            //        case DeviceEnum.翻转机R01:
            //            if (line.R_R01_TaskNo != 0)
            //            {
            //                res.resData = false;
            //                res.resMsg = "R01上有任务在执行";
            //                return res;
            //            }
            //            break;
            //        case DeviceEnum.翻转机R04:
            //            if (line.R_R04_TaskNo != 0)
            //            {
            //                res.resData = false;
            //                res.resMsg = "R04上有任务在执行";
            //                return res;
            //            }
            //            break;
            //        default:
            //            break;
            //    }

            //    res.resData = true;
            //    return res;
            //}
            //catch (Exception ex)
            //{
            //    Log4NetHelper.WriteErrorLog(LogType.SdaService, "检测R01是否可以发任务 出现异常", ex);
            //    res.result = false;
            //    res.resMsg = "检测R01是否可以发任务 出现异常:" + ex.Message;
            //    return res;
            //}
        }

        /// <summary>
        /// 写入TaskFinish
        /// </summary>
        /// <param name="deviceId"></param>
        /// <param name="rgvLocation"></param>
        /// <returns></returns>
        public SdaResEntity WriteTaskFinish(int deviceId, int rgvLocation)
        {
            SdaResEntity sdaResult = new SdaResEntity();
            string msg;
            try
            {
                var line = Line_CacheEntity.DeviceObjs.FirstOrDefault(x => x.View.DeviceId == deviceId);
                if (line == null)
                {
                    sdaResult.resMsg = nofoundStackerMsg;
                    return sdaResult;
                }
                LineLocation _rgv = (LineLocation)Enum.Parse(typeof(LineLocation), rgvLocation.ToString());
                MessageModel fr = null;
                switch (_rgv)
                {
                    case LineLocation.RGV1:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T1_Finish, 1, line.View.W_T1_Finish);
                        break;
                    case LineLocation.RGV2:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T2_Finish, 1, line.View.W_T2_Finish);
                        break;
                    case LineLocation.RGV3:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T3_Finish, 1, line.View.W_T3_Finish);
                        break;
                }
                if (fr.result)
                {
                    sdaResult.result = true;
                    return sdaResult;
                }
                else
                {
                    sdaResult.resMsg = fr.resMsg;
                    return sdaResult;
                }
            }
            catch (Exception ex)
            {
                msg = "写入Task_Finish_ACK出现异常:" + ex.Message;
                Log4NetHelper.WriteErrorLog(LogType.LineSdaService, msg, ex);
                sdaResult.result = false;
                sdaResult.resMsg = msg;
                return sdaResult;
            }
        }


        /// <summary>
        /// 写入 Die (是否有货)
        /// </summary>
        /// <param name="deviceId"></param>
        /// <param name="rgvLocation"></param>
        /// <returns></returns>
        public SdaResEntity WriteDie(int deviceId, int rgvLocation, int dieValue)
        {
            SdaResEntity sdaResult = new SdaResEntity();
            string msg;
            try
            {
                var line = Line_CacheEntity.DeviceObjs.FirstOrDefault(x => x.View.DeviceId == deviceId);
                if (line == null)
                {
                    sdaResult.resMsg = nofoundStackerMsg;
                    return sdaResult;
                }
                LineLocation _rgv = (LineLocation)Enum.Parse(typeof(LineLocation), rgvLocation.ToString());
                MessageModel fr = null;
                switch (_rgv)
                {
                    case LineLocation.RGV1:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T1_Die, dieValue, line.View.W_T1_Die);
                        break;
                    case LineLocation.RGV2:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T2_Die, dieValue, line.View.W_T2_Die);
                        break;
                    case LineLocation.RGV3:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T3_Die, dieValue, line.View.W_T3_Die);
                        break;
                }
                if (fr.result)
                {
                    sdaResult.result = true;
                    return sdaResult;
                }
                else
                {
                    sdaResult.resMsg = fr.resMsg;
                    return sdaResult;
                }
            }
            catch (Exception ex)
            {
                msg = "写入 Die 出现异常:" + ex.Message;
                Log4NetHelper.WriteErrorLog(LogType.LineSdaService, msg, ex);
                sdaResult.result = false;
                sdaResult.resMsg = msg;
                return sdaResult;
            }
        }


        /// <summary>
        /// 写入 Stock (是否有库存)
        /// </summary>
        /// <param name="deviceId"></param>
        /// <param name="rgvLocation"></param>
        /// <returns></returns>
        public SdaResEntity WriteStock(int deviceId, int rgvLocation, int stockValue)
        {
            SdaResEntity sdaResult = new SdaResEntity();
            string msg;
            try
            {
                var line = Line_CacheEntity.DeviceObjs.FirstOrDefault(x => x.View.DeviceId == deviceId);
                if (line == null)
                {
                    sdaResult.resMsg = nofoundStackerMsg;
                    return sdaResult;
                }
                LineLocation _rgv = (LineLocation)Enum.Parse(typeof(LineLocation), rgvLocation.ToString());
                MessageModel fr = null;
                switch (_rgv)
                {
                    case LineLocation.RGV1:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T1_Stock, stockValue, line.View.W_T1_Stock);
                        break;
                    case LineLocation.RGV2:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T2_Stock, stockValue, line.View.W_T2_Stock);
                        break;
                    case LineLocation.RGV3:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T3_Stock, stockValue, line.View.W_T3_Stock);
                        break;
                }
                if (fr.result)
                {
                    sdaResult.result = true;
                    return sdaResult;
                }
                else
                {
                    sdaResult.resMsg = fr.resMsg;
                    return sdaResult;
                }
            }
            catch (Exception ex)
            {
                msg = "写入 Stock 出现异常:" + ex.Message;
                Log4NetHelper.WriteErrorLog(LogType.LineSdaService, msg, ex);
                sdaResult.result = false;
                sdaResult.resMsg = msg;
                return sdaResult;
            }
        }



        /// <summary>
        /// 写入 request_ok (WCS确认标记)
        /// </summary>
        /// <param name="deviceId"></param>
        /// <param name="rgvLocation"></param>
        /// <returns></returns>
        public SdaResEntity Write_Request_ok(int deviceId, int rgvLocation, bool value)
        {
            SdaResEntity sdaResult = new SdaResEntity();
            string msg;
            try
            {
                var line = Line_CacheEntity.DeviceObjs.FirstOrDefault(x => x.View.DeviceId == deviceId);
                if (line == null)
                {
                    sdaResult.resMsg = nofoundStackerMsg;
                    return sdaResult;
                }
                LineLocation _rgv = (LineLocation)Enum.Parse(typeof(LineLocation), rgvLocation.ToString());
                MessageModel fr = null;
                switch (_rgv)
                {
                    case LineLocation.RGV1:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T1_request_ok, value, line.View.W_T1_request_ok);
                        break;
                    case LineLocation.RGV2:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T2_request_ok, value, line.View.W_T2_request_ok);
                        break;
                    case LineLocation.RGV3:
                        fr = line.plcService.WriteValuePoint(Line_CacheEntity.W_DBHeader, line.DBBlockForWrite.W_T3_request_ok, value, line.View.W_T3_request_ok);
                        break;
                }
                if (fr.result)
                {
                    sdaResult.result = true;
                    return sdaResult;
                }
                else
                {
                    sdaResult.resMsg = fr.resMsg;
                    return sdaResult;
                }
            }
            catch (Exception ex)
            {
                msg = "写入 request_ok 出现异常:" + ex.Message;
                Log4NetHelper.WriteErrorLog(LogType.LineSdaService, msg, ex);
                sdaResult.result = false;
                sdaResult.resMsg = msg;
                return sdaResult;
            }
        }

      
    }
}