using OnlineStore;
using RemoteSheardObject;
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Xml;
using System.Xml.Linq;

namespace DeviceLibrary
{
    public class VStore
    {
        public VServerComm ServerCM;        
        public VLog VLog;
        VStoreCollection vc;
        MsgService Msg;
        /// <summary>
        /// 当前料仓终端口的物料reelid
        /// </summary>
        public string CurrentTerminalReelID
        {
            get => ConfigHelper.Config.Get("Runtime_Tower_" + CID + "_CurrentTerminalReelID");
            set => ConfigHelper.Config.Set("Runtime_Tower_" + CID + "_CurrentTerminalReelID", value);
        }
        public string CID;
        public string TowerName;
        public VStore(TowerInfo towerInfo, VStoreCollection storeCollection) {
            vc = storeCollection;
            CID = towerInfo.TowerID;
            TowerName = towerInfo.TowerName;
            VLog = new VLog(CID, CID);
            ServerCM = new VServerComm(CID,VLog);
            ServerCM.OutStoreEvent += ServerCM_OutStoreEvent;
            ServerCM.storeStatus = StoreStatus.None;
            Msg = new MsgService("RT-"+CID);
            OutStoreJobList = new StoreJobList(crc.GetString("Res0050","出库任务"));
        }
        
        public void ServerCM_OutStoreEvent(object sender, JobInfo e)
        {
            VLog.Info(sender+"出库指令信息:" + e.ToStr());
            OutStoreJobList.Enqueue(e.Clone());
            //MI.DeviceList[TowerList.List[CurrentOutJobInfo.CID].DeviceGroupName].EnqueueOutStore(CurrentOutJobInfo);
            
        }
        public RTStoreStatus RTStoreStatus = RTStoreStatus.Offline;
        DateTime LastStatusTime = DateTime.Now;
        internal void VTowerProcess() {
            var ti = ServerCM.GetTowerDetailInformation(CID);
            if (ti != null)
            {
                ServerCM.Temperature = ti.Temperature;
                ServerCM.Humidity = ti.Humidity;
                if (ti.StatusCode == 26)
                {
                    ServerCM.storeStatus = StoreStatus.StoreOnline;
                    if (RTStoreStatus != RTStoreStatus.LockToInStore)
                    {
                        if (RTStoreStatus != RTStoreStatus.Ready)
                            VLog.Info("料仓已空闲");
                        RTStoreStatus = RTStoreStatus.Ready;
                        if (OutStoreJobList.Count > 0)
                        {
                            if (OutStoreJobList.Dequeue(out JobInfo jobInfo))
                            {
                                RTStoreStatus = RTStoreStatus.LockToInStore;
                                if (!ServerCM.BeginOutStore(jobInfo.Clone(), VLog)) {
                                    RTStoreStatus = RTStoreStatus.Ready;
                                }
                                CurrentTerminalReelID = jobInfo.WareNum;
                            }
                        }
                        if (InStoreJobInfo != null)
                        {
                            VLog.Info("入库成功:" + InStoreJobInfo.ToStr());
                            string[] substrings = InStoreJobInfo.WareNum.Split('#');
                            string secondSubstring = substrings[1].Substring(1);
                            InStoreEnd(secondSubstring);
                            InStoreJobInfo = null;
                        }
                    }
                    else
                    {
                        Msg.add("料仓为入库锁定状态,请检查舱门口料盘状态", MsgLevel.alarm);
                    }
                }
                else if (ti.StatusCode == 1031)
                {
                    ServerCM.storeStatus = StoreStatus.InStoreExecute;
                    if (RTStoreStatus != RTStoreStatus.InStoreExecute)
                        VLog.Info("入库执行中");
                    RTStoreStatus = RTStoreStatus.InStoreExecute;
                    //InStoreJobInfo = null;
                }
                else if (ti.StatusCode == 1032)
                {
                    if ((DateTime.Now - LastStatusTime).TotalSeconds > 30) {
                        RTStoreStatus = RTStoreStatus.InStoreDataTimeOut;
                    }
                    if (RTStoreStatus != RTStoreStatus.InStoreReady && InStoreJobInfo != null)
                    {
                        LastStatusTime = DateTime.Now;
                        VLog.Info("物料已在舱口");
                        RTStoreStatus = RTStoreStatus.InStoreReady;

                        if (!ServerCM.BeginInStore(CID, InStoreJobInfo, VLog))
                        {
                            RTStoreStatus = RTStoreStatus.LockToInStore;
                            Msg.add(CID + crc.GetString("Res0051", "无法入库"), MsgLevel.alarm);
                            VLog.Info("入库指令失败:" + InStoreJobInfo.ToStr());
                        }
                        CurrentTerminalReelID = InStoreJobInfo.WareNum;
                        //Thread.Sleep()

                    }
                }
                else if (ti.StatusCode == 1040)
                {
                    ServerCM.storeStatus = StoreStatus.OutMoveExecute;
                    if (RTStoreStatus != RTStoreStatus.OutMoveExecute)
                        VLog.Info("出库执行中");
                    RTStoreStatus = RTStoreStatus.OutMoveExecute;
                }
                else if (ti.StatusCode == 1041)
                {
                    if (RTStoreStatus != RTStoreStatus.OutStoreReady)
                    {
                        VLog.Info("出库已完成");
                        OutStoreEnd(CurrentTerminalReelID, CID);
                    }

                    
                    RTStoreStatus = RTStoreStatus.OutStoreReady;
                    OutStoreJobList.ClearLastPosid();
                }
                else if (ti.StatusCode == 0 || ti.StatusCode == 18)
                {
                    RTStoreStatus = RTStoreStatus.Offline;
                    ServerCM.storeStatus = StoreStatus.None;
                }else if (ti.StatusCode == 310117)
                {
                    RTStoreStatus = RTStoreStatus.InStoreError;
                    ServerCM.storeStatus = StoreStatus.InStoreError;
                }
                else if (ti.StatusCode < 10000)
                {
                    RTStoreStatus = RTStoreStatus.Busy;
                    ServerCM.storeStatus = StoreStatus.None;
                    VLog.Info($"StatusCode:{ti.StatusCode},StatusText:{ti.StatusText},OnlineStatus:{ti.OnlineStatus}");
                }
                else
                {
                    VLog.Error($"StatusCode:{ti.StatusCode},StatusText:{ti.StatusText},OnlineStatus:{ti.OnlineStatus}");
                    ServerCM.storeStatus = StoreStatus.InTrouble;
                    RTStoreStatus = RTStoreStatus.Error;
                }
            }
            else {

                ServerCM.storeStatus = StoreStatus.None;
                RTStoreStatus = RTStoreStatus.Offline;
            }
            /*
            18 offline
            26 Ready/Idle
            1031 loading material
            1032 material put into Terminal from outside
            1040 出库执行中
            1041 unloading material 物料已到舱门口
            1042 material unloaded to Terminal from Tower 物料已取走
            6015 Reel already loaded.
            3068 初始化中
            */
        }

        public string GetStateStr()
        {
            if (RTStoreStatus == RTStoreStatus.OutStoreReady)
                return "出库中" + (!string.IsNullOrEmpty(CurrentTerminalReelID)?"SN:" + CurrentTerminalReelID:"");

            if (RTStoreStatus == RTStoreStatus.LockToInStore) {
                return "等待入库信息";
            }
            if ( RTStoreStatus == RTStoreStatus.InStoreExecute || RTStoreStatus == RTStoreStatus.InStoreReady)
            {
                return "入库中" + " Barcode:" + InStoreJobInfo?.WareNum;
            }
            if (RTStoreStatus == RTStoreStatus.InStoreError)
            {
                return "入库出错,物料NG";
            }
            return "空闲中";
        }

        public volatile JobInfo InStoreJobInfo;
        StoreJobList OutStoreJobList;
        public void RequestInStore(JobInfo jobInfo) {
            InStoreJobInfo = jobInfo.Clone();
           //return vc.BeginInStore(CID, jobInfo);
        }

        public bool OutStoreEnd(string reelid,string towerid) {
            CurrentTerminalReelID = reelid;
            TheLine.UpdateLocInfo("", CurrentTerminalReelID, TheLine.LineStatusE.BOXDOOR, towerid);
            return ServerCM.SendStoreState("", reelid, StoreStatus.OutStoreEnd);
        }
        public bool InStoreEnd(string posid)
        {
            return ServerCM.SendStoreState("", posid, StoreStatus.InStoreEnd);
        }
    }
    public enum RTStoreStatus {
        Offline,
        Ready,
        InStoreReady,
        InStoreExecute,
        InStoreError,
        OutStoreReady,
        OutMoveExecute,
        NGOutReady,
        LockToInStore,
        Busy,
        Error,
        InStoreDataTimeOut
    }
}