using Newtonsoft.Json;
using System;
using WIDESEA_Common;
using WIDESEA_Common.Tools;
using WIDESEA_Core.ManageUser;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Entity.DomainModels.Mes;

namespace WIDESEA_WCS
{
    public partial class ToMesServer
    {

        /// <summary>
        /// 手动添加三楼任务
        /// </summary>
        /// <param name="requestTemp"></param>
        /// <returns></returns>
        public WebResponseContent AddToFloat3(MesRequestTemp requestTemp)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {                   

                var haveInRoute = freeDB.Select<base_routing_table>().Where(t => t.route_began == requestTemp.from_address && t.route_end == requestTemp.to_address).Any();

                if (!haveInRoute)
                {
                    throw new Exception("该路径不存在！");
                }
                
                var station = freeDB.Select<dt_stationinfo>().Where(t => t.stationCode == requestTemp.from_address).First();
                if (station == null)
                {
                    throw new Exception("缓存架位置不存在！");
                }

                if (station.getStatus != 1)
                {
                    throw new Exception("该缓存架不是有料状态！");
                }

                if ((DateTime.Now - station.getLastTime).TotalSeconds > 3)
                {
                    throw new Exception("该缓存架信号超时！");
                }

                var haveInTask = freeDB.Select<dt_agvtask>()
                   .Where(t => t.agv_fromaddress == requestTemp.from_address
                   || t.agv_fromaddress == requestTemp.to_address
                   || t.agv_toaddress == requestTemp.from_address
                   || t.agv_toaddress == requestTemp.to_address
                   ).Any();

                if (!haveInTask)
                {
                    dt_agvtask agvtask = new dt_agvtask();
                    agvtask.agv_id = Guid.NewGuid();
                    agvtask.agv_fromaddress = requestTemp.from_address;
                    agvtask.agv_toaddress = requestTemp.to_address;
                    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 = 1;//工作类型
                    agvtask.agv_materielid = "";
                    agvtask.agv_qty = 1;
                    agvtask.agv_createtime = DateTime.Now;
                    agvtask.agv_grade = 0;//任务优先级
                    agvtask.agv_userid = UserContext.Current.UserName;
                    freeDB.Add(agvtask);
                }
                else
                {
                    throw new Exception("起始或目的地址，已存在任务中！");
                }
                content.OK();
            }
            catch (Exception ex)
            {
                WriteLog.GetLog().Write($"【error】{ex.Message}\n{JsonConvert.SerializeObject(requestTemp)}" + "\n", "手动添加二楼任务");
                content.Error(ex.Message);
            }
            return content;
        }
    }
}