using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEA.Common;
using WIDESEA.Core.Services;
using WIDESEA.Core.Utilities;
using WIDESEA.Entity.DomainModels;
using WIDESEA.Services.Repositories;

namespace WIDESEA.Services.IServices
{
    public partial class ToWCSService
    {

        /// <summary>
        /// 接收WMS上报的任务状态，修改对应的任务状态，以保持wms和wcs任务状态同步
        /// </summary>
        /// <param name="saveModel"></param>
        /// <returns></returns>
        public WebResponseContent UpdateWmsTaskState(SaveModel saveModel)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                string barcode = saveModel.MainData["barcode"].ToString();
                string taskState = saveModel.MainData["taskState"].ToString();

                Dt_taskinfo taskinfo = Dt_taskinfoRepository.Instance.FindFirst(x => x.task_barcode == barcode);
                if (taskinfo == null)
                    throw new Exception($"在WMS中没有找到条码值：【{barcode}】对应的任务");

                //穿梭车取货完成
                if (taskState.Equals("TaskState_RGV_PickedFinished"))
                {
                    taskinfo.task_bak_2 = "2";
                    Dt_taskinfoRepository.Instance.Update(taskinfo, x => x.task_bak_2, true);
                    return content.OK("接收WCS上报状态成功.");
                }


                if (taskinfo.task_type == TaskType.TaskType_Empty_Pallet_Outbound.ToString() &&
                    taskState == TaskState.TaskState_RGV_Finished.ToString())
                {
                    string rgvId = saveModel.MainData["rgvId"]?.ToString();
                    taskinfo.task_rgvId = rgvId;
                }
                if (taskinfo.task_type == TaskType.TaskType_Box_Pallet_Measure_Out.ToString() &&
                    taskState == TaskState.TaskState_RGV_Finished.ToString())
                {
                    string rgvId = saveModel.MainData["rgvId"]?.ToString();
                    taskinfo.task_rgvId = rgvId;
                }

                taskinfo.task_dispatchertime = DateTime.Now;
                taskinfo.task_state = taskState;
                Dt_taskinfoRepository.Instance.Update(taskinfo, true);

                //空托入库
                if (taskinfo.task_type == TaskType.TaskType_Empty_Pallet_Inbound.ToString() &&
                   taskinfo.task_state == TaskState.TaskState_ConveyorLineExecuting.ToString())
                {
                    Dt_locationinfo locationinfo = Dt_locationinfoRepository.Instance.FindFirst(x => x.location_id == taskinfo.task_fromlocationid);
                    if (locationinfo != null)
                    {
                        locationinfo.location_state = LocationState.LocationState_Empty_Inbound_Executing.ToString();
                        Dt_locationinfoRepository.Instance.Update(locationinfo, true);
                    }
                }
                //实托入库
                else if (taskinfo.task_type == TaskType.TaskType_Box_Pallet_Inbound.ToString() &&
                         taskinfo.task_state == TaskState.TaskState_ConveyorLineExecuting.ToString())
                {
                    Dt_locationinfo locationinfo = Dt_locationinfoRepository.Instance.FindFirst(x => x.location_id == taskinfo.task_fromlocationid);
                    if (locationinfo != null)
                    {
                        locationinfo.location_state = LocationState.LocationState_Box_Inbound_Executing.ToString();
                        Dt_locationinfoRepository.Instance.Update(locationinfo, true);
                    }
                }
                //测量出库、测量回库
                else if ((taskinfo.task_type == TaskType.TaskType_Box_Pallet_Measure_Out.ToString() ||
                         taskinfo.task_type == TaskType.TaskType_Box_Pallet_Measure_Back.ToString()) &&
                         (taskState.Contains("_Measure") || taskState == TaskState.TaskState_RGV_Received.ToString()))
                {
                    //说明要准备回库了，将任务类型改为测量回库
                    if (taskinfo.task_state == TaskState.TaskState_Measure_Back_Line_Wait_Executing.ToString())
                    {
                        taskinfo.task_type = TaskType.TaskType_Box_Pallet_Measure_Back.ToString();
                        Dt_taskinfoRepository.Instance.Update(taskinfo, true);
                    }

                    Dt_locationinfo locationinfo = Dt_locationinfoRepository.Instance.FindFirst(x => x.location_id == taskinfo.task_fromlocationid);
                    if (locationinfo != null)
                    {
                        locationinfo.location_state = LocationState.LocationState_Measureing.ToString();
                        Dt_locationinfoRepository.Instance.Update(locationinfo, true);
                    }
                }
                //空托出库
                else if (taskinfo.task_type == TaskType.TaskType_Empty_Pallet_Outbound.ToString())
                {
                    if (taskState == TaskState.TaskState_RGV_Received.ToString())
                    {
                        Dt_locationinfo locationinfo = Dt_locationinfoRepository.Instance.FindFirst(x => x.location_id == taskinfo.task_fromlocationid);
                        locationinfo.location_state = LocationState.LocationState_Empty_OutBound_Executing.ToString();
                        Dt_locationinfoRepository.Instance.Update(locationinfo, true);
                    }
                    else if (taskState == TaskState.TaskState_RGV_Finished.ToString())
                    {
                        //恢复空货位状态
                        Dt_locationinfo locationinfo = Dt_locationinfoRepository.Instance.FindFirst(x => x.location_id == taskinfo.task_fromlocationid);
                        locationinfo.location_state = LocationState.LocationState_Empty.ToString();
                        Dt_locationinfoRepository.Instance.Update(locationinfo, true);
                    }
                }
                else if (taskinfo.task_type == TaskType.TaskType_Box_Pallet_Outbound.ToString())
                {
                    if (taskState == TaskState.TaskState_RGV_Received.ToString())
                    {
                        Dt_locationinfo locationinfo = Dt_locationinfoRepository.Instance.FindFirst(x => x.location_id == taskinfo.task_fromlocationid);
                        locationinfo.location_state = LocationState.LocationState_Box_OutBound_Executing.ToString();
                        Dt_locationinfoRepository.Instance.Update(locationinfo, true);
                    }
                    else if (taskState == TaskState.TaskState_RGV_Finished.ToString())
                    {
                        //恢复空货位状态
                        Dt_locationinfo locationinfo = Dt_locationinfoRepository.Instance.FindFirst(x => x.location_id == taskinfo.task_fromlocationid);
                        locationinfo.location_state = LocationState.LocationState_Empty.ToString();
                        Dt_locationinfoRepository.Instance.Update(locationinfo, true);
                    }
                }
                else if (taskinfo.task_type == TaskType.TaskType_MoveOutbound.ToString())
                {

                }
                content.OK("接收WCS上报状态成功.");
            }
            catch (Exception ex)
            {
                content.Error("接收WCS上报状态失败:" + ex.Message);
            }
            //Services.CommonFunction.AddInterfaceLogAction(saveModel, content, "UpdateWmsTaskState");
            return content;
        }

    }
}