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.OutboundArea
{
    public partial class OutboundAreaDispatch
    {
        public static string[] endStationNo = new string[] { "70101", "70103", "70104", "70106", "70109", "70110", "70113", "70114" };
        /// <summary>
        /// 出库任务完成
        /// </summary>
        /// <param name="taskWCSinfoRepository"></param>
        /// <param name="client"></param>
        public static void OutboundCompleteAction(IDt_TaskWCSinfoRepository taskWCSinfoRepository, PLCClient client)
        {
            foreach (var item in endStationNo)
            {
                try
                {
                    string barcode = client.ReadValue(CLineInfoDBName.R_Line_Barcode.ToString(), item).ToString();
                    //查找任务表中的 轴承出库任务
                    Dt_TaskWCSinfo emptyOutWcsInfo = taskWCSinfoRepository.FindFirst(x => ((x.wcstask_type == TaskType.TaskType_Box_Pallet_Outbound.ToString() &&
                    x.wcstask_state == TaskState.TaskState_Box_Out_Line_Executing.ToString()) ||
                    (x.wcstask_type == TaskType.TaskType_Empty_Pallet_Outbound.ToString() && x.wcstask_state == TaskState.TaskState_Empty_Out_Line_Executing.ToString()))
                        && x.wcstask_barcode == barcode);
                    if (null != emptyOutWcsInfo)
                    {
                        //在此完成该空托出库任务
                        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(item).Write(str, item);
                    }
                }
                catch (Exception ex)
                {

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

        }
    }
}