using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using WIDESEA_Common;
using WIDESEA_Common.Tools;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services;
using WIDESEA_Services.IRepositories;
using WIDESEA_Services.Repositories;
using WIDESEA_Services.Services;
using WIDESEA_WCS.WCSClient;

namespace WIDESEA_WCS.Jobs
{
    public partial class EquipmentExecutor : SchedulerExecuteBase
    {
        private static int _readJROutBindSignalso = 0;
        /// <summary>
        /// 拆包站逻辑流程
        /// </summary>
        /// <param name="client"></param>
        /// <returns></returns>
        public static void JROutBind()
        {
            if (Interlocked.Exchange(ref _readJROutBindSignalso, 1) == 0)
            {
                try
                {
                    VOLContext Context = new VOLContext();
                    IJROutBindRepository jrRepository = new JROutBindRepository(Context);
                    Idt_agvtaskRepository agvRepository = new dt_agvtaskRepository(Context);
                    var task = agvRepository.Find(v => v.agv_toaddress.Contains("JR") && v.agv_taskstate == "WaitStockOut");
                    if (task != null)
                    {
                        var bind = jrRepository.Find(f => f.sum != 0);
                        if (bind != null)
                        {
                            for (int b = 0; b < bind.Count(); b++)
                            {
                                var tasks = agvRepository.Find(v => v.agv_materielid == bind[b].materialtype && v.agv_toaddress.Contains(bind[b].barcode.Substring(0, 2)) && v.agv_toaddress.Contains("JR") && v.agv_taskstate == "WaitStockOut");
                                if (tasks.Count() > 0)
                                {
                                    if (tasks.Count() >= bind[b].sum)
                                    {
                                        for (int i = 0; i < bind[b].sum; i++)
                                        {
                                            tasks[i].agv_fromaddress = bind[b].Devid;
                                            tasks[i].agv_taskstate = "Create";
                                            if (string.IsNullOrEmpty(bind[b].barcodes))
                                            {
                                                tasks[i].agv_materbarcode = bind[b].barcode;
                                            }
                                            else
                                            {
                                                tasks[i].agv_materbarcode = bind[b].barcodes.Split(',')[b];
                                            }
                                            #region
                                            //if (bind[b].Devid == "ZJXL-FBT001")
                                            //{
                                            //          if (BarcodesData.barcodes1.Count() == 0)
                                            //    {
                                            //        tasks[i].agv_materbarcode = bind[b].barcode;
                                            //    }
                                            //    else
                                            //    {
                                            //        tasks[i].agv_materbarcode = BarcodesData.barcodes1[b];
                                            //    }
                                            //}
                                            //else if (bind[b].Devid == "ZJXL-FBT002")
                                            //{
                                            //    if (BarcodesData.barcodes2.Count() == 0)
                                            //    {
                                            //        tasks[i].agv_materbarcode = bind[b].barcode;
                                            //    }
                                            //    else
                                            //    {
                                            //        tasks[i].agv_materbarcode = BarcodesData.barcodes2[b];
                                            //    }
                                            //}
                                            //else if (bind[b].Devid == "FJXL-FBT001")
                                            //{
                                            //    if (BarcodesData.barcodes3.Count() == 0)
                                            //    {
                                            //        tasks[i].agv_materbarcode = bind[b].barcode;
                                            //    }
                                            //    else
                                            //    {
                                            //        tasks[i].agv_materbarcode = BarcodesData.barcodes3[b];
                                            //    }
                                            //}
                                            //else if (bind[b].Devid == "FJXL-FBT002")
                                            //{
                                            //    if (BarcodesData.barcodes4.Count() == 0)
                                            //    {
                                            //        tasks[i].agv_materbarcode = bind[b].barcode;
                                            //    }
                                            //    else
                                            //    {
                                            //        tasks[i].agv_materbarcode = BarcodesData.barcodes4[b];
                                            //    }
                                            //}
                                            #endregion
                                            tasks[i].agv_materielid = bind[b].materialtype;
                                            if (i>0)
                                            {
                                                int size = int.Parse(tasks[i].size);
                                                //总宽度
                                                int zwigth = bind[b].sum * size;
                                                //已用宽度
                                                int nwigth = size * i;
                                                //剩余宽度
                                                int newwigth = zwigth - nwigth;
                                                tasks[i].JRunm = bind[b].sum - 1 + ";" + newwigth;
                                            }

                                            if (i == bind[b].sum - 1) { tasks[i].agv_remark = "true"; tasks[i].agv_qty = tasks.Count(); }
                                            agvRepository.Update(tasks[i], true);
                                        }
                                        bind[b].barcode = "";
                                        bind[b].materialtype = "";
                                        bind[b].sum = 0;
                                        bind[b].taskid = "";
                                        bind[b].barcodes = "";
                                        jrRepository.Update(bind[b], true);
                                        #region
                                        //if (bind[b].Devid == "ZJXL-FBT001")
                                        //{
                                        //   BarcodesData.barcodes1=null;
                                        //}
                                        //else if (bind[b].Devid == "ZJXL-FBT002")
                                        //{
                                        //    BarcodesData.barcodes2= null;
                                        //}
                                        //else if (bind[b].Devid == "FJXL-FBT001")
                                        //{
                                        //    BarcodesData.barcodes3 = null;
                                        //}
                                        //else if (bind[b].Devid == "FJXL-FBT002")
                                        //{
                                        //    BarcodesData.barcodes4= null;
                                        //}
                                        #endregion
                                    }
                                    else
                                    {
                                        for (int i = 0; i < tasks.Count(); i++)
                                        {
                                            tasks[i].agv_fromaddress = bind[b].Devid;
                                            tasks[i].agv_taskstate = "Create";
                                            if (string.IsNullOrEmpty( bind[b].barcodes))
                                            {
                                                tasks[i].agv_materbarcode = bind[b].barcode;
                                            }
                                            else
                                            {
                                                tasks[i].agv_materbarcode = bind[b].barcodes.Split(',')[b];
                                            }
                                            #region
                                            //if (bind[b].Devid == "ZJXL-FBT001")
                                            //{
                                            //    if (BarcodesData.barcodes1.Count() == 0)
                                            //    {
                                            //        tasks[i].agv_materbarcode = bind[b].barcode;
                                            //    }
                                            //    else
                                            //    {
                                            //        tasks[i].agv_materbarcode = BarcodesData.barcodes1[b];
                                            //    }
                                            //}
                                            //else if (bind[b].Devid == "ZJXL-FBT002")
                                            //{
                                            //    if (BarcodesData.barcodes2.Count() == 0)
                                            //    {
                                            //        tasks[i].agv_materbarcode = bind[b].barcode;
                                            //    }
                                            //    else
                                            //    {
                                            //        tasks[i].agv_materbarcode = BarcodesData.barcodes2[b];
                                            //    }
                                            //}
                                            //else if (bind[b].Devid == "FJXL-FBT001")
                                            //{
                                            //    if (BarcodesData.barcodes3.Count() == 0)
                                            //    {
                                            //        tasks[i].agv_materbarcode = bind[b].barcode;
                                            //    }
                                            //    else
                                            //    {
                                            //        tasks[i].agv_materbarcode = BarcodesData.barcodes3[b];
                                            //    }
                                            //}
                                            //else if (bind[b].Devid == "FJXL-FBT002")
                                            //{
                                            //    if (BarcodesData.barcodes4.Count() == 0)
                                            //    {
                                            //        tasks[i].agv_materbarcode = bind[b].barcode;
                                            //    }
                                            //    else
                                            //    {
                                            //        tasks[i].agv_materbarcode = BarcodesData.barcodes4[b];
                                            //    }
                                            //}
                                            #endregion

                                            if (i>0)
                                            {
                                                int size = int.Parse(tasks[i].size);
                                                //总宽度
                                                int zwigth = bind[b].sum * size;
                                                //已用宽度
                                                int nwigth = size * i;
                                                //剩余宽度
                                                int newwigth = zwigth - nwigth;
                                                tasks[i].JRunm = bind[b].sum - 1 + ";" + newwigth;
                                            }

                                            tasks[i].agv_materielid = bind[b].materialtype;
                                            if (i == tasks.Count() - 1) { tasks[i].agv_remark = "true"; tasks[i].agv_qty = tasks.Count(); }
                                            agvRepository.Update(tasks[i], true);
                                        }
                                        bind[b].barcode = "";
                                        bind[b].materialtype = "";
                                        bind[b].sum = 0;
                                        bind[b].taskid = "";
                                        bind[b].barcodes = "";
                                        jrRepository.Update(bind[b], true);
                                        #region
                                      //  List<string> newbarcodes = null;
                                        //if (bind[b].Devid == "ZJXL-FBT001")
                                        //{
                                        //    for (int j = tasks.Count(); j < BarcodesData.barcodes1.Count(); j++)
                                        //    {
                                        //        newbarcodes.Add(BarcodesData.barcodes1[j]);
                                        //        WriteLog.Info("剩余卷绕绑定条码").Write(bind[b].Devid+"卷绕绑定条码：" + BarcodesData.barcodes1[j] + DateTime.Now, "剩余卷绕绑定条码");
                                        //    }
                                        //    BarcodesData.barcodes1 = newbarcodes;
                                        //}
                                        //else if (bind[b].Devid == "ZJXL-FBT002")
                                        //{
                                        //    for (int j = tasks.Count(); j < BarcodesData.barcodes2.Count(); j++)
                                        //    {
                                        //        newbarcodes.Add(BarcodesData.barcodes2[j]);
                                        //        WriteLog.Info("剩余卷绕绑定条码").Write(bind[b].Devid + "卷绕绑定条码：" + BarcodesData.barcodes1[j] + DateTime.Now, "剩余卷绕绑定条码");
                                        //    }
                                        //    BarcodesData.barcodes2 = newbarcodes;
                                        //}
                                        //else if (bind[b].Devid == "FJXL-FBT001")
                                        //{
                                        //    for (int j = tasks.Count(); j < BarcodesData.barcodes3.Count(); j++)
                                        //    {
                                        //        newbarcodes.Add(BarcodesData.barcodes3[j]);
                                        //        WriteLog.Info("剩余卷绕绑定条码").Write(bind[b].Devid + "卷绕绑定条码：" + BarcodesData.barcodes1[j] + DateTime.Now, "剩余卷绕绑定条码");
                                        //    }
                                        //    BarcodesData.barcodes3 = newbarcodes;
                                        //}
                                        //else if (bind[b].Devid == "FJXL-FBT002")
                                        //{
                                        //    for (int j = tasks.Count(); j < BarcodesData.barcodes4.Count(); j++)
                                        //    {
                                        //        newbarcodes.Add(BarcodesData.barcodes4[j]);
                                        //        WriteLog.Info("剩余卷绕绑定条码").Write(bind[b].Devid + "卷绕绑定条码：" + BarcodesData.barcodes1[j] + DateTime.Now, "剩余卷绕绑定条码");
                                        //    }
                                        //    BarcodesData.barcodes4 = newbarcodes;
                                        //}
                                        #endregion
                                    }
                                }
                            }
                        }
                    }
                }
                catch (Exception)
                {

                }
                finally
                {
                    Interlocked.Exchange(ref _readJROutBindSignalso, 0);
                }
            }
        }
    }
}