using HslCommunication;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using WIDESEA_Common;
using WIDESEA_Common.Tools;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services;
using WIDESEA_Services.IRepositories;
using WIDESEA_Services.Repositories;
using WIDESEA_Services.Services;
using WIDESEA_WCS.WCSClient;

namespace WIDESEA_WCS.Jobs.ConveyorLine.InboundArea
{
    public partial class InboundAreaDispatch
    {
        private static string InboundRequestStationNo = "20101";

        public static void InboundRequestStationAction(IDt_TaskWCSinfoRepository taskWCSinfoRepository, PLCClient client, string lineCode)
        {
            //读取设备正常
            try
            {
                //string lineCode = "InBound";
                string normalResult = client.ReadValue(CLineInfoDBName.R_Line_DeviceNormal.ToString(), InboundRequestStationNo).ToString();
                if (bool.Parse(normalResult))
                {
                    ComplateOutboundTask(taskWCSinfoRepository, client);
                    //读取逻辑控制值
                    int logicValue = int.Parse(client.ReadValue(CLineInfoDBName.R_Line_Logic.ToString(), lineCode).ToString());
                    //读取RFID值  暂时没启用，取当前待执行的任务
                    string rfidResult = client.ReadValue(CLineInfoDBName.W_Line_Barcode.ToString(), lineCode).ToString();
                    if (string.IsNullOrEmpty(rfidResult) || "0".Equals(rfidResult))
                        rfidResult = client.ReadValue(CLineInfoDBName.R_Line_Barcode.ToString(), InboundRequestStationNo).ToString();

                    Dt_TaskWCSinfo wcsInfo = null;
                    if (!string.IsNullOrEmpty(rfidResult) && !"0".Equals(rfidResult))
                        wcsInfo = taskWCSinfoRepository.FindFirst(r => r.wcstask_barcode == rfidResult);
                    else
                    {
                        wcsInfo = taskWCSinfoRepository.FindFirst(r => r.wcstask_startPoint == "20101" && r.wcstask_state == TaskState.TaskState_Assigned.ToString());
                        if (null == wcsInfo)
                            return;

                        if (wcsInfo.wcstask_type != TaskType.TaskType_Box_Pallet_Inbound.ToString() &&
                            wcsInfo.wcstask_type != TaskType.TaskType_Empty_Pallet_Inbound.ToString() &&
                            wcsInfo.wcstask_type != TaskType.TaskType_ErrorCheckBackIn.ToString() &&
                            wcsInfo.wcstask_type != TaskType.TaskType_CheckBackIn.ToString()
                            )
                        {
                            return;
                        }
                    }


                    //线体人工触发的确认信号
                    string confirmResult = client.ReadValue(CLineInfoDBName.R_Line_Confirm_OK.ToString(), InboundRequestStationNo).ToString();
                    if (null == wcsInfo)
                        return;

                    if ((logicValue == 1 || logicValue == 2) && bool.Parse(confirmResult))
                    {
                        //这里需要考虑该条任务的入库站台是否 ==> 已经开始了相对应站台的出库测量任务
                        List<Dt_TaskWCSinfo> tmpList = taskWCSinfoRepository.Find(x =>
                        x.wcstask_type == TaskType.TaskType_Box_Pallet_Measure_Out.ToString() &&
                        x.wcstask_endLocation == wcsInfo.wcstask_endPoint &&
                        (x.wcstask_state == TaskState.TaskState_RGV_Received.ToString() || x.wcstask_state == TaskState.TaskState_RGV_Finished.ToString()));
                        if (tmpList.Count != 0)
                        {
                            WriteLog.Info(InboundRequestStationNo).Write($"目的站台{wcsInfo.wcstask_endPoint}存在测量出库的任务,暂时调度", InboundRequestStationNo);
                            return;
                        }
                        WriteTaskInfo.WriteTaskInfoAction(wcsInfo, client, lineCode);
                    }
                    string barcode = client.ReadValue(CLineInfoDBName.W_Line_Barcode.ToString(), lineCode).ToString();
                    if (!wcsInfo.wcstask_barcode.Equals(barcode))
                        return;
                    logicValue = int.Parse(client.ReadValue(CLineInfoDBName.R_Line_Logic.ToString(), lineCode).ToString());
                    //说明站台已经收到任务数据，等待WCS的启动指令
                    if (logicValue == 3)    //读取输送线3，表示
                    {
                        //启动任务
                        client.WriteValue(CLineInfoDBName.W_Line_Logic.ToString(), lineCode, 1);
                    }
                    else if (logicValue == 4 || logicValue == 5)
                    {
                        if (wcsInfo.wcstask_state == TaskState.TaskState_ConveyorLineExecuting.ToString())
                            return;

                        wcsInfo.wcstask_state = TaskState.TaskState_ConveyorLineExecuting.ToString();
                        wcsInfo.wcstask_dispatcherTime = DateTime.Now;
                        taskWCSinfoRepository.Update(wcsInfo, true);

                        //入空托的时候，默认是托盘号核验一致
                        //bool checkFlag = client.WriteValue(CLineInfoDBName.W_Line_RFID_Done.ToString(), InboundRequestStationNo, true);
                        //读取RFID值，防止在logicValue == 3时更新任务状态失败
                        //是因为出现过写入启动信号，返回值是false，但是线体确又已经收到了启动信号，所以打了这个补丁
                        string str = string.Empty;
                        //启动成功后，在此更新任务状态、上报WMS任务状态
                        WebResponseContent content = WMSApi.PostTaskStateToWMS(wcsInfo.wcstask_barcode, TaskState.TaskState_ConveyorLineExecuting.ToString());
                        if (content.Status)
                            str = $" { DateTime.Now }上报WMS更新任务状态成功【TaskState_ConveyorLineExecuting】，托盘号:{wcsInfo.wcstask_barcode},任务号：{ wcsInfo.wcstask_taskNumber}";
                        else
                            str = $" { DateTime.Now }上报WMS更新任务状态失败【TaskState_ConveyorLineExecuting】，托盘号:{wcsInfo.wcstask_barcode},任务号：{ wcsInfo.wcstask_taskNumber},原因:{content.Message}";
                        WriteLog.Info(InboundRequestStationNo).Write(str, InboundRequestStationNo);
                    }
                }

            }
            catch (Exception ex)
            {
                WriteLog.Info(InboundRequestStationNo).Write($"{ DateTime.Now }入库申请站台调度失败:{ex.Message}", InboundRequestStationNo);
            }
        }
        static string[] taskTypes = new string[] { TaskState.TaskState_Empty_Out_Line_Executing.ToString(), TaskState.TaskState_Box_Out_Line_Executing.ToString() };
        private static void ComplateOutboundTask(IDt_TaskWCSinfoRepository taskWCSinfoRepository, PLCClient client)
        {
            try
            {
                //此处校验空托出库的任务在库存中的托盘码和工位RFID读取到的托盘码是否一致
                int taskNumber = int.Parse(client.ReadValue(CLineInfoDBName.R_Line_TaskNumber.ToString(), InboundRequestStationNo).ToString());
                Dt_TaskWCSinfo emptyOutWcsInfo = null;
                if (taskNumber > 0)
                    emptyOutWcsInfo = taskWCSinfoRepository.FindFirst(x => x.wcstask_taskNumber == taskNumber && taskTypes.Contains(x.wcstask_state));
                else
                {
                    string barcode = client.ReadValue(CLineInfoDBName.R_Line_RFID_OK.ToString(), InboundRequestStationNo).ToString();
                    emptyOutWcsInfo = taskWCSinfoRepository.FindFirst(x => x.wcstask_barcode == barcode && taskTypes.Contains(x.wcstask_state));
                }

                if (null != emptyOutWcsInfo)
                {
                    if (emptyOutWcsInfo.wcstask_type.Contains(TaskType.TaskType_Empty_Pallet_Outbound.ToString()) || emptyOutWcsInfo.wcstask_type
                        .Contains(TaskType.TaskType_Box_Pallet_Outbound.ToString()) || emptyOutWcsInfo.wcstask_type.Contains(TaskType.TaskType_CheckOutbound.ToString()))
                    {
                        //在此完成该空托出库任务
                        WebResponseContent content = taskWCSinfoRepository.DbContextBeginTransaction(() =>
                        {
                            //上报WMS任务完成
                            content = WMSApi.TellWmsTaskFinished(emptyOutWcsInfo.wcstask_barcode);
                            if (content.Status)
                            {
                                //移动任务到历史表
                                Dt_TaskWCSinfo_HtyRepository taskWCSinfo_HtyRepository = new Dt_TaskWCSinfo_HtyRepository(taskWCSinfoRepository.DbContext);
                                emptyOutWcsInfo.wcstask_state = TaskState.TaskState_Finished.ToString();
                                CommonFunction.AddWcsTaskToHistory(emptyOutWcsInfo, taskWCSinfoRepository, taskWCSinfo_HtyRepository);
                            }
                            else
                                throw new Exception($"{ DateTime.Now }上报WMS任务完成出错，原因：【{content.Message}】");

                            return content;
                        });
                        string str = string.Empty;
                        if (content.Status)
                            str = $" { DateTime.Now }上报WMS出库完成成功【TaskState_ConveyorLineExecuting】，托盘号:{emptyOutWcsInfo.wcstask_barcode},任务号：{ emptyOutWcsInfo.wcstask_taskNumber}";
                        else
                            str = $" { DateTime.Now }上报WMS出库完成失败【TaskState_ConveyorLineExecuting】，托盘号:{emptyOutWcsInfo.wcstask_barcode},任务号：{ emptyOutWcsInfo.wcstask_taskNumber}";

                        WriteLog.Info(InboundRequestStationNo).Write(str, InboundRequestStationNo);
                    }

                }
            }
            catch (Exception ex)
            {
                WriteLog.Info(InboundRequestStationNo).Write($"{ DateTime.Now }上报WMS出库完成任务失败:{ex.Message}", InboundRequestStationNo);
            }
        }
    }


}