using DBHelper;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WCS.Core;
using WCS.Entity;
using WCS.Entity.Protocol;

namespace WCS.Service.Works.Stations
{
    [WorkTitle(typeof(ProductHandler), "输送机全局", true)]
    public class All : DeviceWork<Device<IStation521, IStation523>>
    { 
        protected override void Do(Device<IStation521, IStation523> obj)
        { 
            if (obj.Data2.Fault != 0)
            {
                if (obj.Entity.WakeupOn(5000,"All"))
                {
                    WMS.DevInfo(obj.Entity.CODE, obj.Data2.Fault.ToString());
                }
            }
            return;
            
            //if (obj.Data.TASKNUM < 5000)
            //    return;
            //if (obj.Data.PH_STATUS == false)
            //    return;
            //var taskId = obj.Entity.Get<int>("Task");
            //if (taskId == obj.Data.TASKNUM)
            //    return;

            //DB.Do(db =>
            //{
            //    var task = db.Default.Find<WCS_TASK>(obj.Data.TASKNUM);
            //    if (task != null)
            //    {
            //        if (task.ADDRCURRENT != obj.Entity.CODE)
            //        {
            //            task.ADDRCURRENT = obj.Entity.CODE;
            //            task.UPDATETIME = DateTime.Now;
            //            db.Default.SaveChanges();
            //        }
            //    }
            //    obj.Entity.Set("Task", obj.Data.TASKNUM);
            //});

        } 
        protected override bool SelectDevice(WCS_DEVICE dev)
        {
            return true;
        }
    }
}