using DBHelper;
using System;
using System.Linq;
using WCS.Entity;
using WCS.Service.Log;

namespace WCS.Service
{
    public class Uploader
    {
        private static bool Stoped = false;
        //public static void Start()
        //{
        //    Stoped = false;
        //    Task.Run(() =>
        //    {
        //        while (!Stoped)
        //        {
        //            DB.Do(db =>
        //            {
        //                Upload(db);
        //            });
        //            Task.Delay(10000);
        //        }
        //    });

        //}

        private static object UpLoadLockObj = new object();

        public static void Upload(DB db)
        {
            //lock (UpLoadLockObj)
            //{
            //    try
            //    {
            //        var tasks = db.Default.Set<WCS_TASK>().Where(v => v.WMSTASK > 0).Where(v => v.STATUS != v.UPLOADED).ToArray();
            //        foreach (var task in tasks)
            //        {
            //            try
            //            {
            //                WMS.UpdateTask(task.ADDRNEXT?.ToString(), task.WMSTASK, (int)task.STATUS, task.HEIGHT);
            //                var st = task.UPLOADED;
            //                task.UPLOADED = task.STATUS;
            //                //task.CreateStatusLog(db);
            //                InfoLog.INFO_SYTASKSTATUS($"[{task.ID}]---old:[{st}]-new:[{task.UPLOADED}]---{task.HEIGHT}");
            //            }
            //            catch (Exception ex)
            //            {
            //                Console.WriteLine($"上传任务状态失败:WCS任务号{task.ID},{ex.Message}");
            //            }
            //        }
            //        db.Default.SaveChanges();
            //    }
            //    catch { }
            //}
        }

        //public static void Stop()
        //{
        //    Stoped = true;
        //}
    }
}