using System;
using System.Collections.Generic;
using System.Text;
using WIDESEA_Common;
using WIDESEA_Common.LogEnum;
using WIDESEA_Common.TaskEnum;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services.Repositories;
using WIDESEA_Services.Services.APIInvoke;

namespace WIDESEA_Services.Services.APIReceive.RGV
{
    public class WCSReceiveMsgFromRGV
    {
        /// <summary>
        /// WCS接收RGV上报的任务状态
        /// </summary>
        /// <param name="taskModel">任务信息</param>
        /// <returns></returns>
        //public static Dictionary<string, object> WCSReceiveRGVData(Dictionary<string, object> statusData)
        //{            
        //    Dictionary<string, object> resultDic = new Dictionary<string, object>();
        //    try
        //    {
        //        //任务编号
        //        string taskId = statusData["taskId"].ToString();
        //        //小车编号
        //        string reportTime = statusData["rgvId"].ToString();
        //        //任务状态
        //        int taskStatus = int.Parse(statusData["status"].ToString());

        //        Console.WriteLine($"接受到RGV上报的任务状态：任务号：{taskId}，小车编号：{reportTime}，任务状态：{taskStatus}");
        //        LogRecord.WriteLog(LogEnum.RGV, $"接受到RGV上报的任务状态：任务号：{taskId}，小车编号：{reportTime}，任务状态：{taskStatus}");

        //        //在此根据上报的任务号，更新任务状态以及任务完成后的相关操作
        //        VOLContext dbcontext = new VOLContext();
        //        Dt_TaskRGVinfoRepository taskRGVinfoRepository = new Dt_TaskRGVinfoRepository(dbcontext);
        //        Dt_TaskRGVinfo_HtyRepository taskRGVinfo_HtyRepository = new Dt_TaskRGVinfo_HtyRepository(dbcontext);
        //        Dt_TaskRGVinfo_HtyService taskRGVinfo_HtyService = new Dt_TaskRGVinfo_HtyService(taskRGVinfo_HtyRepository);

        //        Dt_TaskWCSinfoRepository taskWCSinfoRepository = new Dt_TaskWCSinfoRepository(dbcontext);
        //        Dt_TaskWCSinfo_HtyRepository taskWCSinfo_HtyRepository = new Dt_TaskWCSinfo_HtyRepository(dbcontext);
        //        Dt_TaskWCSinfo_HtyService taskWCSinfo_HtyService = new Dt_TaskWCSinfo_HtyService(taskWCSinfo_HtyRepository);
        //        Dt_TaskWCSinfo_Hty taskWCSinfo_Hty = new Dt_TaskWCSinfo_Hty();
        //        Dt_TaskRGVinfo_Hty taskRGVinfo_Hty = new Dt_TaskRGVinfo_Hty();

        //        Dt_TaskRGVinfo taskRGVinfo = taskRGVinfoRepository.FindFirst(x => x.rgvtask_taskId == taskId);
        //        Dt_TaskWCSinfo taskWCSinfo = taskWCSinfoRepository.FindFirst(x => x.wcstask_taskNumber == taskRGVinfo.rgvtask_wcsTaskNumber);
        //        if (taskRGVinfo != null)
        //        {
        //            WebResponseContent content = new WebResponseContent();
        //            //RGV上报对应的任务正常完成
        //            if (taskStatus == 1)
        //           {

        //                taskWCSinfoRepository.DbContextBeginTransaction(()=>
        //                {
        //                    try
        //                    {
        //                        //区分任务类型，如果是入库类型的任务，RGV完成，则总任务完成，出库型任务，RGV完成，则只是部分完成
        //                        //***空托入库*******
        //                        //***轴承组盘入库***
        //                        if (taskWCSinfo.wcstask_type == TaskType.TaskType_Empty_Pallet_Inbound.ToString() ||
        //                            taskWCSinfo.wcstask_type == TaskType.TaskType_Box_Pallet_Inbound.ToString())
        //                        {
        //                            //完成rgv、wcs任务、移动任务到历史
        //                            taskRGVinfoRepository.Delete(taskRGVinfo, true);
        //                            taskWCSinfoRepository.Delete(taskWCSinfo, true);
        //                            taskRGVinfo_HtyService.AddRgvTaskToHistory(taskRGVinfo, dbcontext);
        //                            taskWCSinfo_HtyService.AddWcsTaskToHistory(taskWCSinfo, dbcontext);

        //                            //上报WMS任务完成，对于入库来说，穿梭车的任务完成，即是整个任务的生命周期结束
        //                            content = WMSApi.TellWmsTaskFinished(taskRGVinfo.rgvtask_barCode);
        //                            if (content.Status)
        //                            {
        //                                content.OK();
        //                            }
        //                            else
        //                            {
        //                                throw new Exception($"【入库任务】上报WMS任务完成出错，WCS任务号：【{taskWCSinfo.wcstask_taskNumber}】，托盘号：【{taskWCSinfo.wcstask_barcode}】");
        //                            }
        //                        }
        //                        //***测量出库*******，不要删除库存，占着坑，等待测量完回库
        //                        else if (taskWCSinfo.wcstask_type == TaskType.TaskType_Box_Pallet_Measure_Out.ToString())
        //                        {
        //                            //更新rgv、wcs任务状态
        //                            taskRGVinfo.rgvtask_taskStatus = RGVTaskState.RgvTaskState_Done.ToString();
        //                            taskWCSinfo.wcstask_state = TaskState.TaskState_RGV_Finished.ToString();

        //                            //完成rgv、移动任务到历史
        //                            taskRGVinfoRepository.Delete(taskRGVinfo, true);
        //                            taskRGVinfo_HtyService.AddRgvTaskToHistory(taskRGVinfo, dbcontext);

        //                            //上报WMS最新任务状态，此处状态是穿梭车的任务完成
        //                            content = WMSApi.PostTaskStateToWMS(taskRGVinfo.rgvtask_barCode, TaskState.TaskState_RGV_Finished.ToString());
        //                            if (content.Status)
        //                            {
        //                                content.OK();
        //                                //进入线体的测量出库逻辑

        //                            }
        //                            else
        //                            {
        //                                throw new Exception($"【测量出库】上报WMS任务完成出错，WCS任务号：【{taskWCSinfo.wcstask_taskNumber}】，托盘号：【{taskWCSinfo.wcstask_barcode}】");
        //                            }
        //                        }
        //                        //***测量回库*******
        //                        else if (taskWCSinfo.wcstask_type == TaskType.TaskType_Box_Pallet_Measure_Back.ToString())
        //                        {
        //                            //完成rgv、wcs任务、移动任务到历史
        //                            taskRGVinfoRepository.Delete(taskRGVinfo, true);
        //                            taskWCSinfoRepository.Delete(taskWCSinfo, true);
        //                            taskRGVinfo_HtyService.AddRgvTaskToHistory(taskRGVinfo, dbcontext);
        //                            taskWCSinfo_HtyService.AddWcsTaskToHistory(taskWCSinfo, dbcontext);

        //                            //上报WMS任务完成，对于测量回库来说，穿梭车的任务完成，即是整个任务的生命周期结束
        //                            //由于测量出库的没有删除库存，所有只要放回去即可，要不生成库存，在WMS做逻辑
        //                            content = WMSApi.TellWmsTaskFinished(taskRGVinfo.rgvtask_barCode);
        //                            if (content.Status)
        //                            {
        //                                content.OK();
        //                            }
        //                            else
        //                            {
        //                                throw new Exception($"【测量回库】上报WMS任务完成出错，WCS任务号：【{taskWCSinfo.wcstask_taskNumber}】，托盘号：【{taskWCSinfo.wcstask_barcode}】");
        //                            }
        //                        }


        //                    }
        //                    catch(Exception ex)
        //                    {
        //                        content.Error(ex.Message);
        //                    }

        //                    return content;
        //                });

        //           }
        //        }
        //        else
        //        {
        //            Console.WriteLine($"RGV上报了任务状态，但是在RGV任务表中没有找到对应的任务，任务号：【{taskId}】");
        //        }

        //        resultDic.Add("Code", "1");
        //        resultDic.Add("Message", "Scuccess");
        //        resultDic.Add("data ", null);
        //    }
        //    catch (Exception ex)
        //    {
        //        resultDic.Add("Code", "0");
        //        resultDic.Add("Message", "Failed");
        //        resultDic.Add("data ", ex.Message);
        //    }

        //    return resultDic;
        //}



        /// <summary>
        /// WCS接收RGV上报的任务状态
        /// </summary>
        /// <param name="taskModel">任务信息</param>
        /// <returns></returns>
        //public static Dictionary<string, object> GetElevatorInfo()
        //{
        //    Dictionary<string, object> resultDic = new Dictionary<string, object>();
        //    try
        //    {

        //        resultDic.Add("code", "1");
        //        resultDic.Add("layer", "3");
        //        resultDic.Add("status ", "提升机当前状态");
        //    }
        //    catch (Exception ex)
        //    {
        //        resultDic.Add("code", "0");
        //        resultDic.Add("layer", "-1");
        //        resultDic.Add("status ", "获取提升机状态失败"+ex.Message);
        //    }

        //    return resultDic;
        //}
    }
}