/*
 *所有关于Dt_agvtask类的业务代码应在此处编写
*可使用repository.调用常用方法，获取EF/Dapper等信息
*如果需要事务请使用repository.DbContextBeginTransaction
*也可使用DBServerProvider.手动获取数据库相关信息
*用户信息、权限、角色等使用UserContext.Current操作
*Dt_agvtaskService对增、删、改查、导入、导出、审核业务代码扩展参照ServiceFunFilter
*/
using System;
using System.Collections.Generic;
using System.Linq;
using WIDESEA_Common;
using WIDESEA_Common.DBHelper;
using WIDESEA_Common.Tools;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Core.ManageUser;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services.IRepositories;
using WIDESEA_Services.Repositories;

namespace WIDESEA_Services.Services
{
    public partial class dt_agvtaskService
    {
        FreeDB freeDB = new FreeDB();

        /// <summary>
        /// 取消任务
        /// </summary>
        /// <param name="keys"></param>
        /// <param name="delList"></param>
        /// <returns></returns>
        public override WebResponseContent Del(object[] keys, bool delList = true)
        {

            WebResponseContent content = new WebResponseContent();
            try
            {
                var task = dt_agvtaskRepository.Instance
                    .Find(t => t.agv_tasknum == keys[0].ToString())
                    .FirstOrDefault();
                VOLContext Context = new VOLContext();
                Ibase_ware_locationRepository locationRepository = new base_ware_locationRepository(Context);
                Idt_stationinfoRepository stationinfoRepository=new dt_stationinfoRepository(Context);
                if (task != null)
                {

                    base_ware_location loc_from = locationRepository.FindFirst(t => t.upper_code == task.agv_fromaddress);
                    base_ware_location loc_to = locationRepository.FindFirst(t => t.upper_code == task.agv_toaddress);
                    if (loc_from != null && loc_to != null)
                    {
                        if (loc_to.upper_code.Contains("GFHCJ"))
                        {
                            if (loc_to.upper_code.Contains("ZJ-GFHCJ10-"))
                            {
                                //string NUM = loc_to.upper_code.Remove(11) + "4";
                                //base_ware_location loc_gf = locationRepository.FindFirst(t => t.upper_code == NUM);
                                //if (loc_gf != null)
                                //{
                          
                                    loc_to.logic_col = 0;
                                    loc_to.task = 2;
                                    freeDB.Update(loc_to).UpdateColumns(t => new { t.location_state, t.logic_col, t.task }).ExecuteAffrows();
                                
                        
                            }
                            else
                            {
                                //string NUM = loc_to.upper_code.Remove(10) + "4";
                                //base_ware_location loc_gf = locationRepository.FindFirst(t => t.upper_code == NUM);
                                //if (loc_gf != null) {
                                dt_agvtask Agvtask = dt_agvtaskRepository.Instance.FindFirst(d => d.agv_tasknum != task.agv_tasknum && d.agv_toaddress.Contains(loc_to.upper_code));
                                if (Agvtask == null)
                                {
                                    loc_to.logic_col = 0;
                                    loc_to.task = 2;
                                    int A = freeDB.Update(loc_from).UpdateColumns(t => new { t.logic_col, t.task }).ExecuteAffrows();
                                }
                     
                            }

                        }
                    }
                    else if (loc_from != null && loc_to == null)
                    {
                        if (task.agv_toaddress.Contains("GFHCJ"))
                        {
                            string NUM = "";
                            string upcode = "";
                            if (task.agv_toaddress.Contains("ZJ-GFHCJ10-"))
                            {
                                NUM = task.agv_toaddress.Remove(11);
                            }
                            else
                            {
                                NUM = task.agv_toaddress.Remove(10);
                            }
                            if (NUM != "")
                            {
                                upcode = NUM + "4";
                            }
                            base_ware_location loc_gf = locationRepository.FindFirst(t => t.upper_code == upcode);
                            if (loc_gf != null)
                            {
                        
                                    loc_gf.logic_col = 0;
                                    loc_gf.task = 2;
                                    freeDB.Update(loc_gf).UpdateColumns(t => new { t.logic_col, t.task }).ExecuteAffrows();
                                
                            }
                            AddHtyTask(task, "手动取消");
                            return content.OK($"任务{keys[0]},取消成功");
                        }
                    }
                    if (loc_from != null)
                    {
                            loc_from.logic_col = 0;
                            loc_from.task = 2;
                            //loc_from.light_color = "0";
                            int a = freeDB.Update(loc_from).UpdateColumns(t => new { t.logic_col, t.task }).ExecuteAffrows();
                        
                    }
                    if (loc_to != null)
                    {
                            loc_to.logic_col = 0;
                            loc_to.task = 2;
                            int a = freeDB.Update(loc_to).UpdateColumns(t => new { t.logic_col, t.task }).ExecuteAffrows();
                    }

                    //一二楼铝壳缓存架任务取消
                    dt_stationinfo Stationinfo_from = stationinfoRepository.FindFirst(d => d.stationCode== task.agv_fromaddress);
                    dt_stationinfo Stationinfo_to = stationinfoRepository.FindFirst(d => d.stationCode == task.agv_toaddress);
                    if (Stationinfo_from != null)
                    {
                        Stationinfo_from.task = false;
                        //loc_from.light_color = "0";
                        int a = freeDB.Update(Stationinfo_from).UpdateColumns(t => new { t.task }).ExecuteAffrows();

                    }
                    if (Stationinfo_to != null)
                    {
                        Stationinfo_to.task = false;
                        int a = freeDB.Update(Stationinfo_to).UpdateColumns(t => new { t.task }).ExecuteAffrows();
                    }

                    AddHtyTask(task, "手动取消");
                    content.OK($"任务{keys[0]},取消成功");
                    //}

                }
                else
                {
                    content.Error($"未找到任务信息");
                }
                //}
                //else
                //{
                //    task.agv_taskstate = AGVTaskStateEnum.WaitCancel.ToString();
                //    freeDB.Update(task).UpdateColumns(t => t.agv_taskstate).ExecuteAffrows();
                //}

                //else
                //{
                //    throw new Exception($"任务{keys[0]},已不存在");
                //}
            }
            catch (Exception ex)
            {
                //if (ex.Message.Contains("成功"))
                //{
                //    content.OK(ex.Message);
                //}
                //else
                //{
                //    content.Error(ex.Message);
                //}

            }
            return content;
        }

        private void AddHtyTask(dt_agvtask task, string agv_taskstate)
        {
            freeDB.Add(new dt_agvtask_hty()
            {
                hty_pkid = Guid.NewGuid(),
                agv_id = Guid.Empty,
                agv_tasknum = task.agv_tasknum,
                agv_materielid = task.agv_materielid,
                agv_qty = task.agv_qty,
                agv_createtime = task.agv_createtime,
                agv_realesstime = task.agv_realesstime,
                agv_executingBeginTime = task.agv_executingBeginTime,
                agv_executingEndTime = task.agv_executingEndTime,
                agv_completeBeginTime = task.agv_completeBeginTime,
                agv_finishedtime = DateTime.Now,
                agv_taskstate = agv_taskstate,
                agv_tasktype = task.agv_tasktype,
                agv_fromaddress = task.agv_fromaddress,
                agv_toaddress = task.agv_toaddress,
                agv_operatetype = string.Empty,
                agv_compeletor = "wcs",
                agv_completedate = DateTime.Now,
                agv_grade = task.agv_grade,
                agv_userid = UserContext.Current.UserName,
                agv_barcode = task.agv_barcode,
                agv_code = task.agv_code,
                agv_worktype = task.agv_worktype
            });
            int a = freeDB.Remove(task);
        }


        /// <summary>
        /// 手动任务完成
        /// </summary>
        /// <param name="agv_tasknum"></param>
        public WebResponseContent FinishTask(string agv_tasknum)
        {
            VOLContext Context = new VOLContext();
            Ibase_ware_locationRepository locRepository = new base_ware_locationRepository(Context);
            List<base_ware_location> base_Ware_Locations_zj = locRepository.Find(t => t.upper_code.Contains("ZJ-BC") || t.upper_code.Contains("ZJ-TB")).OrderBy(t => t.order_num).ToList();
            WebResponseContent content = new WebResponseContent();
            try
            {
                var task = dt_agvtaskRepository.Instance
                    .Find(t => t.agv_tasknum == agv_tasknum)
                    .FirstOrDefault();
                if (task != null)
                {
                    AddHtyTask(task, "手动完成");
                    //更新最后操作时间
                    FreeDB.DB.Update<dt_stationinfo>()
                        .Set(t => t.lastUpdateTime, DateTime.Now)
                        .Where(t => t.stationCode == task.agv_fromaddress || t.stationCode == task.agv_toaddress)
                        .ExecuteAffrows();
                }
                else
                {
                    throw new Exception($"任务{agv_tasknum},已不存在");
                }
            }
            catch (Exception ex)
            {
                content.Error(ex.Message);
            }
            return content;
        }

        /// <summary>
        /// 手动下发任务
        /// </summary>
        /// <param name="agv_tasknum"></param>
        public WebResponseContent sendTask(string fromaddress, string toaddress)
        {
            WebResponseContent content = new WebResponseContent();
            FreeDB freeDB = new FreeDB();
            try
            {
                if (fromaddress == null || toaddress == null)
                {
                    content.Message = "数据不完整!";
                    content.Status = false;
                    throw new Exception(content.Message);
                }
                var from_location = freeDB.Select<base_ware_location>().Where(x => x.upper_code == fromaddress);
                var to_location = freeDB.Select<base_ware_location>().Where(x => x.upper_code == toaddress);
                //var from_location = base_ware_locationRepository.Instance.FindFirst(x => x.upper_code == fromaddress);
                //var to_location = base_ware_locationRepository.Instance.FindFirst(x => x.upper_code == toaddress);
                if (from_location == null)
                {
                    content.Message = "起点地址不存在!";
                    content.Status = false;
                    throw new Exception(content.Message);
                }
                if (to_location == null)
                {
                    content.Message = "终点地址不存在!";
                    content.Status = false;
                    throw new Exception(content.Message);
                }
                //if ((!fromaddress.Contains("ZJ-JKHCJ") && !fromaddress.Contains("ZJ-QJHCJ")))
                //{
                //    content.Message = "起始货位不允许手动下发";
                //    content.Status = false;
                //    throw new Exception(content.Message);
                //}
                //if ((!toaddress.Contains("ZJ-JKHCJ") && !toaddress.Contains("ZJ-QJHCJ")))
                //{
                //    content.Message = "目的货位不允许手动下发";
                //    content.Status = false;
                //    throw new Exception(content.Message);
                //}
                //判断首尾地址是否存在执行中任务
                var task_to = dt_agvtaskRepository.Instance
                    .Find(t => t.agv_toaddress == toaddress || t.agv_fromaddress == toaddress)
                    .FirstOrDefault();
                var task_from = dt_agvtaskRepository.Instance
                   .Find(t => t.agv_fromaddress == fromaddress || t.agv_toaddress == fromaddress)
                   .FirstOrDefault();

                // var location_to=base_ware_locationRepository.Instance.Find(t=>t)

                //判断路由合法性
                //var rout = base_routing_tableRepository.Instance.Find(t => t.route_began == fromaddress && t.route_end == toaddress).FirstOrDefault();

                if (task_to == null && task_from == null)//&& rout != null)
                {
                    dt_agvtask agvtask = new dt_agvtask();
                    agvtask.agv_id = Guid.NewGuid();
                    agvtask.agv_fromaddress = fromaddress;
                    agvtask.agv_toaddress = toaddress;
                    agvtask.agv_tasknum = "KH-" + IdenxManager.GetTaskNo();
                    agvtask.agv_code = "组装AGV调度";
                    agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
                    agvtask.agv_tasktype = AGVTaskTypeEnum.TaskType_Outbound.ToString();
                    agvtask.agv_worktype = 2;//工作类型
                    agvtask.agv_materielid = "A23";
                    agvtask.agv_qty = 1;
                    agvtask.agv_createtime = DateTime.Now;
                    agvtask.agv_grade = 0;//任务优先级
                    agvtask.agv_userid = UserContext.Current.UserName;
                    agvtask.agv_remark = "手动生成";

                    freeDB.Add(agvtask);

                    content.Status = true;
                    content.Message = "任务创建成功，正在通知AGV调度中心";
                }
                else
                {
                    if (task_from != null)
                    {
                        content.Status = false;
                        content.Message += "起始地址正在执行任务!   ";
                    }
                    if (task_to != null)
                    {
                        content.Status = false;
                        content.Message += "目的地址正在执行任务!   ";
                    }
                    //if (rout == null)
                    //{
                    //    content.Status = false;
                    //    content.Message += "非法的路由规则!  ";
                    //}
                    throw new Exception(content.Message);
                }
            }
            catch (Exception ex)
            {
                content.Error(ex.Message);
            }
            return content;
        }

        public List<dt_agvtask> PDATask(List<dt_agvtask> agvtask)
        {
            WebResponseContent content = new WebResponseContent();
            VOLContext Context = new VOLContext();
            Ibase_pda_locationRepository pdaloctionRepository = new base_pda_locationRepository(Context);
            Idt_containerRepository containerRepository = new dt_containerRepository(Context);
            IVV_ContainerInfoRepository VV_ContainerInfoRepository = new VV_ContainerInfoRepository(Context);
            Idt_materielinfoRepository materielinfoRepository = new dt_materielinfoRepository(Context);
            Idt_agvtaskRepository agvRepository = new dt_agvtaskRepository(Context);
            Ibase_routing_tableRepository routingRepository = new base_routing_tableRepository(Context);
            Ibase_ware_locationRepository ibase_Ware_Location = new base_ware_locationRepository(Context);
            try
            {
                List<dt_agvtask> agvtasks = agvRepository.Find(d => d.agv_remark.Contains("PDA")).ToList();
                return agvtasks;
            }
            catch (Exception ex)
            {

                throw;
            }


        }
    }
}