using Leit.FrameWork.Log;
using Leit.Model;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Leit.StationFunction
{
    public static class Function_OP60
    {
        /// <summary>
        /// 工位标签信息
        /// </summary>
        public static List<StationTagInfo> StationTagInfos { get; set; }


        /// <summary>
        /// 工位报警标签信息
        /// </summary>
        public static List<StationTagInfo> StationAlarmTagInfos { get; set; }

        /// <summary>
        /// 工位质量数据标签信息
        /// </summary>
        public static List<StationTagInfo> StationQualityTagInfos { get; set; }

        /// <summary>
        /// 工位交互数据标签信息
        /// </summary>
        public static List<StationTagInfo> StationCommunicatedTagInfos { get; set; }


        /// <summary>
        /// 工位信息
        /// </summary>
        public static StationInfo StationInf { get; set; }

        /// <summary>
        /// 托盘号
        /// </summary>
        public static byte PalletNum { get; set; }

        public static bool ReadDataOk { get; set; }

        /// <summary>
        /// 业务逻辑
        /// </summary>
        public static  void CycleRunTimer()
        {

            try
            {
//读取托盘号
            byte palletNum = ServiceData.OpcTags.Where(p => p.TagId == StationCommunicatedTagInfos.Where(q => q.TagMarkCode == 1010).First().TagId).First().GetValue<byte>();
            if (palletNum != 0)
            {
                //托盘号保持
                PalletNum = palletNum;
            }


            if (ServiceData.OpcTags.Where(p => p.TagId == StationCommunicatedTagInfos.Where(q => q.TagMarkCode == 1050).First().TagId).First().GetValue<byte>() == 1)
            {
                //收到允许保存   保存质量数据   
                if (!ReadDataOk)
                {
                    //读取质量数据.
                    string sql = "update Deploy_Data set ";

                    foreach (var item in StationQualityTagInfos)
                    {

                        if(item.TagDataType=="byte")
                        {
                            sql = sql + item.ColName + "='" + ServiceData.OpcTags.Where(p => p.TagId == item.TagId).First().GetValue<byte>()+"'";
                        }
                        else if (item.TagDataType == "float")
                        {
                            sql = sql + item.ColName + "='" + ServiceData.OpcTags.Where(p => p.TagId == item.TagId).First().GetValue<float>().ToString()+"'";
                        }

                        sql = sql + ",";
                    }

                    sql=sql.Remove(sql.Length-1,1);
                    sql = sql +$",op60_time='{DateTime.Now}' where tuopan_id={PalletNum} and process_state=1";
                    if(SqlSugarAdo.ExecuteCommand(sql)>0)
                    {
                        ReadDataOk = true;
                    }

                   
                }
                //回写保存完成
                ServiceData.PlcServer.Write(StationCommunicatedTagInfos.Where(p => p.TagMarkCode == 1060).First().TagAddr, 1);


            }
            else
            {
                ReadDataOk = false;
            }

            }
            catch (Exception ex)
            {
                LogHelper.WriteLog(LogHelper.GetMethodInfo(), ex);
            }


        }
    }
}