using System;
using System.Collections.Generic;
using System.Text;
using WIDESEA_Common;
using WIDESEA_Common.TaskEnum;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services.IRepositories;
using WIDESEA_Services.Repositories;

namespace WIDESEA_Services.Services
{
    public partial class CommonFunction
    {

        /// <summary>
        /// 完成RGV任务
        /// </summary>
        /// <param name="taskRGVinfo"></param>
        /// <returns></returns>
        public static WebResponseContent FinishedRgvTask(Dt_TaskRGVinfo taskRGVinfo, string rgvId = null)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                IDt_TaskRGVinfoRepository taskRGVinfoRepository = Dt_TaskRGVinfoRepository.Instance;
                IDt_TaskRGVinfo_HtyRepository taskRGVinfo_HtyRepository = Dt_TaskRGVinfo_HtyRepository.Instance;
                IDt_TaskWCSinfoRepository taskWCSinfoRepository = Dt_TaskWCSinfoRepository.Instance;
                IDt_TaskWCSinfo_HtyRepository taskWCSinfo_HtyRepository = Dt_TaskWCSinfo_HtyRepository.Instance;

                //根据RGV任务，找到对应的WCS总任务
                Dt_TaskWCSinfo taskWCSinfo = Dt_TaskWCSinfoRepository.Instance.FindFirst(x => x.wcstask_taskNumber == taskRGVinfo.rgvtask_wcsTaskNumber);
                if (taskWCSinfo == null)
                    return content.Error($"手动完成穿梭车任务出错，没有找到任务号：【{taskRGVinfo.rgvtask_taskId}】对应的WCS总任务，WCS任务号：【{taskRGVinfo.rgvtask_wcsTaskNumber}】");

                content = Dt_TaskWCSinfoRepository.Instance.DbContextBeginTransaction(() =>
                {
                    taskWCSinfo.wcstask_backUp_2 = rgvId;
                    taskRGVinfo.rgvtask_backup_1 = rgvId;
                    //区分任务类型，如果是入库类型的任务，RGV完成，则总任务完成，出库型任务，RGV完成，则只是部分完成
                    //***空托入库**********轴承组盘入库***
                    if (taskWCSinfo.wcstask_type == TaskType.TaskType_Empty_Pallet_Inbound.ToString() ||
                        taskWCSinfo.wcstask_type == TaskType.TaskType_Box_Pallet_Inbound.ToString() ||
                           taskWCSinfo.wcstask_type == TaskType.TaskType_CheckBackIn.ToString() ||
                            taskWCSinfo.wcstask_type == TaskType.TaskType_ErrorCheckBackIn.ToString() ||
                        taskRGVinfo.rgvtask_taskType == RGVTaskType.RgvTaskType_Move.ToString() ||
                         (taskWCSinfo.wcstask_type == RGVTaskType.RgvTaskType_Inbound.ToString() &&
                          taskWCSinfo.wcstask_type == TaskType.TaskType_MoveOutbound.ToString())
                        )
                    {
                        //上报WMS任务完成，对于入库来说，穿梭车的任务完成，即是整个任务的生命周期结束
                        content = WMSApi.TellWmsTaskFinished(taskRGVinfo.rgvtask_barCode, rgvId);
                        if (!content.Status)
                            throw new Exception($"【入库任务】上报WMS任务完成出错，WCS任务号：【{taskWCSinfo.wcstask_taskNumber}】，托盘号：【{taskWCSinfo.wcstask_barcode}】");
                        taskRGVinfo.rgvtask_taskStatus = RGVTaskState.RgvTaskState_Done.ToString();
                        taskWCSinfo.wcstask_state = TaskState.TaskState_Finished.ToString();
                        //完成rgv、wcs任务、移动任务到历史
                        CommonFunction.AddWcsTaskToHistory(taskWCSinfo, taskWCSinfoRepository, taskWCSinfo_HtyRepository);
                        CommonFunction.AddRgvTaskToHistory(taskRGVinfo, taskRGVinfoRepository, taskRGVinfo_HtyRepository);
                    }
                    //***测量出库*******，不要删除库存，占着坑，等待测量完回库
                    else if (taskWCSinfo.wcstask_type == TaskType.TaskType_Box_Pallet_Measure_Out.ToString())
                    {
                        //上报WMS最新任务状态，此处状态是穿梭车的任务完成
                        content = WMSApi.PostTaskStateToWMS(taskRGVinfo.rgvtask_barCode, TaskState.TaskState_RGV_Finished.ToString(), rgvId);
                        if (!content.Status)
                            throw new Exception($"【测量出库】上报WMS任务完成出错，WCS任务号：【{taskWCSinfo.wcstask_taskNumber}】，托盘号：【{taskWCSinfo.wcstask_barcode}】");

                        //更新rgv、wcs任务状态
                        taskRGVinfo.rgvtask_taskStatus = RGVTaskState.RgvTaskState_Done.ToString();
                        taskWCSinfo.wcstask_state = TaskState.TaskState_RGV_Finished.ToString();
                        //完成rgv、移动任务到历史
                        CommonFunction.AddRgvTaskToHistory(taskRGVinfo, taskRGVinfoRepository, taskRGVinfo_HtyRepository);
                        Dt_TaskWCSinfoRepository.Instance.Update(taskWCSinfo, true);
                    }
                    //***测量回库*******
                    else if (taskWCSinfo.wcstask_type == TaskType.TaskType_Box_Pallet_Measure_Back.ToString())
                    {
                        //上报WMS任务完成，对于测量回库来说，穿梭车的任务完成，即是整个任务的生命周期结束
                        //由于测量出库的没有删除库存，所有只要放回去即可，要不生成库存，在WMS做逻辑
                        content = WMSApi.TellWmsTaskFinished(taskRGVinfo.rgvtask_barCode, rgvId);
                        if (!content.Status)
                            throw new Exception($"【测量回库】上报WMS任务完成出错，WCS任务号：【{taskWCSinfo.wcstask_taskNumber}】，托盘号：【{taskWCSinfo.wcstask_barcode}】");

                        //完成rgv、wcs任务、移动任务到历史
                        CommonFunction.AddWcsTaskToHistory(taskWCSinfo, taskWCSinfoRepository, taskWCSinfo_HtyRepository);
                        CommonFunction.AddRgvTaskToHistory(taskRGVinfo, taskRGVinfoRepository, taskRGVinfo_HtyRepository);
                    }
                    //***空托盘/轴承出库*****
                    else if (taskWCSinfo.wcstask_type == TaskType.TaskType_Empty_Pallet_Outbound.ToString()
                    || taskWCSinfo.wcstask_type == TaskType.TaskType_Box_Pallet_Outbound.ToString() ||
                    taskWCSinfo.wcstask_type == TaskType.TaskType_CheckOutbound.ToString())//tx 0808 
                    {
                        string state = string.Empty;
                        if (taskRGVinfo.rgvtask_areaCode == "OutboundArea")
                        {
                            if (taskWCSinfo.wcstask_type == TaskType.TaskType_Empty_Pallet_Outbound.ToString())
                                state = TaskState.TaskState_Empty_Out_Line_Executing.ToString();
                            else if (taskWCSinfo.wcstask_type == TaskType.TaskType_Box_Pallet_Outbound.ToString())
                                //state = TaskState.TaskState_Box_Out_Line_Executing.ToString();
                                state = TaskState.TaskState_Box_Out_RGV_Finished.ToString();    //（2525-12-12修改）修改成提升机运行中
                        }
                        else
                            state = TaskState.TaskState_RGV_Finished.ToString();

                        //上报WMS最新任务状态，此处状态是穿梭车的任务完成
                        content = WMSApi.PostTaskStateToWMS(taskRGVinfo.rgvtask_barCode, state, rgvId);
                        if (!content.Status)
                            throw new Exception($"【空/指定托盘出库】上报WMS【RGV】任务完成出错，WCS任务号：【{taskWCSinfo.wcstask_taskNumber}】，托盘号：【{taskWCSinfo.wcstask_barcode}】");

                        //更新rgv、wcs任务状态
                        taskRGVinfo.rgvtask_taskStatus = RGVTaskState.RgvTaskState_Done.ToString();
                        taskWCSinfo.wcstask_state = state;

                        //完成rgv、移动任务到历史
                        CommonFunction.AddRgvTaskToHistory(taskRGVinfo, taskRGVinfoRepository, taskRGVinfo_HtyRepository);
                        Dt_TaskWCSinfoRepository.Instance.Update(taskWCSinfo, true);
                    }
                    //移库出库任务完成
                    else if (taskRGVinfo.rgvtask_taskType == RGVTaskType.RgvTaskType_Outbound.ToString() &&
                         taskWCSinfo.wcstask_type == TaskType.TaskType_MoveOutbound.ToString())
                    {
                        taskRGVinfo.rgvtask_taskStatus = RGVTaskState.RgvTaskState_Done.ToString();
                        taskWCSinfo.wcstask_state = TaskState.TaskState_RGV_Finished.ToString();
                        //完成rgv、移动任务到历史
                        CommonFunction.AddRgvTaskToHistory(taskRGVinfo, taskRGVinfoRepository, taskRGVinfo_HtyRepository);
                        Dt_TaskWCSinfoRepository.Instance.Update(taskWCSinfo, true);
                    }

                    return content.OK();
                });
            }
            catch (Exception ex)
            {
                content.Error(ex.Message + ex.StackTrace);
            }

            return content;
        }

    }
}