using Autofac.Core;
using MailKit.Search;
using Mapster;
using Masuit.Tools;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
using System.Diagnostics;
using System.Reflection.Emit;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using WIDESEA_Common;
using WIDESEA_Core.Const;
using WIDESEA_DTO.WMS;
using WIDESEA_IServices;
using WIDESEA_IStoragIntegrationServices;
using WIDESEA_Model.Models;
using WIDESEA_StorageBasicRepository;
using WIDESEAWCS_BasicInfoRepository;
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob.Models;


namespace WIDESEA_StorageTaskServices;

public partial class Dt_TaskService : ServiceBase<Dt_Task, IDt_TaskRepository>, IDt_TaskService
{
    private readonly LogFactory LogFactory = new LogFactory();
    private readonly IUnitOfWorkManage _unitOfWorkManage;
    private readonly IDt_Task_HtyRepository _task_HtyRepository;
    private readonly IMapper _mapper;
    private readonly ILocationInfoRepository _locationRepository;
    private readonly ITaskExecuteDetailRepository _taskExecuteDetailRepository;
    private readonly ILocationStatusChangeRecordRepository _locationStatusChangeRecordRepository;
    private readonly IDt_StationManagerRepository _stationManagerRepository;
    private readonly ISys_ConfigService _configService;
    private readonly IDt_InWheels_mesRepository _InWheels_MesRepository;
    private readonly IDt_WheelsStockRepository _WheelsStockRepository;
    private readonly IDt_WheelsStock_htyRepository _WheelsStock_HtyRepository;
    private readonly IDt_InWheels_mes_htyRepository _InWheels_Mes_HtyRepository;
    private readonly IDt_CacheInfoRepository _CacheInfoRepository;
    private readonly IDt_OutWheels_htyRepository _OutWheels_HtyRepository;
    private readonly IDt_InZdp_mesRepository _InZdp_MesRepository;
    private readonly IDt_InZdp_mes_htyRepository _InZdp_Mes_HtyRepository; 
    private readonly IDt_ZdpStockRepository _ZdpStockRepository;
    private readonly IDt_ZdpStock_htyRepository _ZdpStock_HtyRepository;

    public Dt_TaskService(IDt_TaskRepository BaseDal,
                                IUnitOfWorkManage unitOfWorkManage,
                                IDt_OutOrderRepository outOrderRepository,
                                IStockInfoRepository stockInfoRepository,
                                IDt_Task_HtyRepository task_HtyRepository,
                                IMapper mapper,
                                ILocationInfoRepository locationRepository,
                                ITaskExecuteDetailRepository taskExecuteDetailRepository,
                                ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository,
                                IStockInfoDetailRepository stockInfoDetailRepository,
                                IDt_StationManagerRepository stationManagerRepository,
                                ISys_ConfigService configService,
                                IDt_InWheels_mesRepository inWheels_MesRepository,
                                IDt_WheelsStockRepository wheelsStockRepository,
                                IDt_WheelsStock_htyRepository wheelsStock_HtyRepository,
                                IDt_InWheels_mes_htyRepository inWheels_Mes_HtyRepository,
                                IDt_OutWheels_htyRepository dt_OutWheels_HtyRepository,
                                IDt_CacheInfoRepository cacheInfoRepository,
                                IDt_InZdp_mesRepository inZdp_MesRepository,
                                IDt_InZdp_mes_htyRepository inZdp_Mes_HtyRepository,
                                IDt_ZdpStockRepository zdpStockRepository,
                                IDt_ZdpStock_htyRepository dt_ZdpStock_HtyRepository) : base(BaseDal)

    {
        _unitOfWorkManage = unitOfWorkManage;
        _task_HtyRepository = task_HtyRepository;
        _mapper = mapper;
        _locationRepository = locationRepository;
        _taskExecuteDetailRepository = taskExecuteDetailRepository;
        _locationStatusChangeRecordRepository = locationStatusChangeRecordRepository;
        _stationManagerRepository = stationManagerRepository;
        _configService = configService;
        _InWheels_MesRepository = inWheels_MesRepository;
        _WheelsStockRepository = wheelsStockRepository;
        _WheelsStock_HtyRepository = wheelsStock_HtyRepository;
        _InWheels_Mes_HtyRepository = inWheels_Mes_HtyRepository;
        _OutWheels_HtyRepository = dt_OutWheels_HtyRepository;
        _CacheInfoRepository = cacheInfoRepository;
        _InZdp_MesRepository = inZdp_MesRepository;
        _InZdp_Mes_HtyRepository = inZdp_Mes_HtyRepository;
        _ZdpStockRepository = zdpStockRepository;
        _ZdpStock_HtyRepository = dt_ZdpStock_HtyRepository;
    }

    #region 外部接口方法


    #region 移库任务完成

    /// <summary>
    /// 移库任务完成
    /// </summary>
    /// <param name="saveModel">任务数据合集</param>
    /// <returns>返回结果集</returns>
    public async Task<WebResponseContent> CompleteTransferTaskAsync(Dt_Task task, Dt_WheelsStock stock)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            // 更新货位和库存信息
            (Dt_WheelsStock updateStock, DtLocationInfo locationInForm, DtLocationInfo locationInfoTo) = UpdateStockLocation(stock, task);
            var taskHty = CreateHistoricalTask(task);
            LogFactory.GetLog("任务完成").InfoFormat(true, "移库任务完成", $"货位地址：{task.TargetAddress},修改后库存数据：{JsonConvert.SerializeObject(updateStock)}，原先货位数据：{locationInForm}");

            // 执行数据库事务
            bool isResult = await ExecuteTransaction(updateStock, taskHty, locationInForm, locationInfoTo, task.TaskId);
            if (isResult)
                content.OK("移库任务完成成功");
            else
                content.Error("移库任务完成失败");
        }
        catch (Exception err)
        {
            Console.WriteLine(err.Message.ToString());
        }
        return content;
    }

    #endregion 移库任务完成

    #region 制动盘移库任务完成

    /// <summary>
    /// 移库任务完成
    /// </summary>
    /// <param name="saveModel">任务数据合集</param>
    /// <returns>返回结果集</returns>
    public async Task<WebResponseContent> CompleteZdpTaskAsync(Dt_Task task, Dt_ZdpStock stock)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            // 更新货位和库存信息
            (Dt_ZdpStock updateStock, DtLocationInfo locationInForm, DtLocationInfo locationInfoTo) = UpdateZdpStockLocation(stock,task);
            var taskHty = CreateHistoricalTask(task);
            LogFactory.GetLog("任务完成").InfoFormat(true, "移库任务完成", $"货位地址：{task.TargetAddress},修改后库存数据：{JsonConvert.SerializeObject(updateStock)}，原先货位数据：{locationInForm}");

            // 执行数据库事务
            bool isResult = await ZdpExecuteTransaction(updateStock, taskHty, locationInForm, locationInfoTo, task.TaskId);
            if (isResult)
                content.OK("移库任务完成成功");
            else
                content.Error("移库任务完成失败");
        }
        catch (Exception err)
        {
            Console.WriteLine(err.Message.ToString());
        }
        return content;
    }

    #endregion 移库任务完成

    #region 入库任务完成

    /// <summary>
    /// 完成入库任务
    /// </summary>
    /// <param name="task">任务数据合集</param>
    /// <returns>返回结果集</returns>
    public async Task<WebResponseContent> CompleteInboundTaskAsync(Dt_Task task)
    {
        // 初始化响应内容
        WebResponseContent content = new WebResponseContent();
        try
        {

            // 获取MES信息和目标位置信息
            Dt_InWheels_mes mes_Wheels = null;
            Dt_InZdp_mes mes_Zdp = null;
            Dt_WheelsStock wheelsStock = null;
            Dt_ZdpStock zdpStock = null;

            if (task.TaskType== (int)TaskInboundTypeEnum.InBrake)
                mes_Zdp = await _InZdp_MesRepository.QueryFirstNavAsync(x => x.Zdp_code == task.PalletCode);
            else
                mes_Wheels = await _InWheels_MesRepository.QueryFirstNavAsync(x => x.Wheels_Num == task.PalletCode);
            

            var locationInf = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress && x.RoadwayNo == task.Roadway);

            int lastStatus = locationInf.LocationStatus;
            // 更新目标位置状态为库存中
            locationInf.LocationStatus = (int)LocationEnum.InStock;

            // 创建历史任务实例模型
            var taskHty = CreateHistoricalTask(task);

            if(task.TaskType == (int)TaskInboundTypeEnum.InBrake)
            {
                // 根据创建库存实例模型
                zdpStock = new Dt_ZdpStock
                {
                    Zdp_code= mes_Zdp.Zdp_code,
                    Zdp_ZPH = mes_Zdp.Zdp_ZPH,
                    Zdp_CurrentStatue = 1,
                    Zdp_Location = task.TargetAddress,
                    Zdp_chexing= mes_Zdp.Zdp_chexing,
                    Zdp_neworold = mes_Zdp.Zdp_neworold,
                    Zdp_POS = mes_Zdp.Zdp_POS,
                    Zdp_LSXH = mes_Zdp.Zdp_LSXH,
                    Zdp_MAT = mes_Zdp.Zdp_MAT,
                    Zdp_SITE = mes_Zdp.Zdp_SITE,
                    Zdp_GKA1 = mes_Zdp.Zdp_GKA1,
                    Zdp_GKA2 = mes_Zdp.Zdp_GKA2,
                    Zdp_GKA3 = mes_Zdp.Zdp_GKA3,
                    Zdp_GKA = mes_Zdp.Zdp_GKA,
                    Zdp_GKB1 = mes_Zdp.Zdp_GKB1,
                    Zdp_GKB2 = mes_Zdp.Zdp_GKB2,
                    Zdp_GKB3 = mes_Zdp.Zdp_GKB3,
                    Zdp_GKB = mes_Zdp.Zdp_GKB,
                    Zdp_GKC1 = mes_Zdp.Zdp_GKC1,
                    Zdp_GKC2 = mes_Zdp.Zdp_GKC2,
                    Zdp_GKC3 = mes_Zdp.Zdp_GKC3,
                    Zdp_GKC = mes_Zdp.Zdp_GKC,
                    Zdp_GKJZ = mes_Zdp.Zdp_GKJZ,
                    Zdp_LSCSYMH = mes_Zdp.Zdp_LSCSYMH,
                    Zdp_LMCSYMH = mes_Zdp.Zdp_LMCSYMH,
                    Zdp_rksj = mes_Zdp.Zdp_rksj,
                    CreateDate = DateTime.Now,
                    Creater = task.Creater,
                };
            }
            else
            {
                // 根据创建库存实例模型
                 wheelsStock = new Dt_WheelsStock
                {
                    Wheels_ldtm = mes_Wheels.Wheels_ldtm,
                    CreateDate = DateTime.Now,
                    Creater = task.Creater,
                    Wheels_Type = mes_Wheels.Wheels_Type,
                    Wheels_gkcc = mes_Wheels.Wheels_gkcc,
                    WheelsProps = mes_Wheels.WheelsProps,
                    Wheels_CarNo = mes_Wheels.Wheels_CarNo,
                    Wheels_CarType = mes_Wheels.Wheels_CarType,
                    Wheels_ldxh = mes_Wheels.Wheels_ldxh,
                    Wheels_code = mes_Wheels.Wheels_code,
                    Wheels_InDate = mes_Wheels.Wheels_InDate,
                    Wheels_level = mes_Wheels.Wheels_level,
                    Wheels_Location = task.TargetAddress,
                    Wheels_NewOrOld = mes_Wheels.Wheels_NewOrOld,
                    Wheels_Num = mes_Wheels.Wheels_Num,
                    Wheels_psj = mes_Wheels.Wheels_psj,
                    Wheels_CurrentStatue = 1,
                    Wheels_mttype = mes_Wheels.Wheels_mttype,
                    Wheels_ljz = mes_Wheels.Wheels_ljz,
                    Wheels_ldh = mes_Wheels.Wheels_ldh,
                    //Wheels_SequenceNum = mes_Wheels.Wheels_SequenceNum,
                    Wheels_ygljz = mes_Wheels.Wheels_ygljz,
                    Wheels_gkzja = mes_Wheels.Wheels_gkzja,
                    Wheels_gkzjb = mes_Wheels.Wheels_gkzjb,
                    Wheels_gkzjc = mes_Wheels.Wheels_gkzjc,
                };
            }

            // 执行数据库事务ZDPExecuteTransaction
            bool isResult = false;
            if (task.TaskType == (int)TaskInboundTypeEnum.InBrake)
            {
                isResult = await ZDPExecuteTransaction(zdpStock, taskHty, locationInf, task.TaskId, mes_Zdp);
            }
            else
            {
                isResult=await ExecuteTransaction(wheelsStock, taskHty, locationInf, task.TaskId, mes_Wheels);
            }
            
            if (isResult)
            {
                _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(locationInf, lastStatus, (int)StatusChangeTypeEnum.AutomaticStorage, task.TaskNum);
                content.OK("入库任务完成成功");
            }
            else
            {
                content.Error("入库任务完成失败");
            }
        }
        catch (Exception err)
        {
            // 记录异常信息到控制台和日志
            Console.WriteLine(err.Message.ToString());
            LogFactory.GetLog("任务完成").Error(true, err);
            content.Error(err.Message);
        }
        return content;
    }
    #endregion 入库任务完成

    #region 出库任务完成
    public async Task<WebResponseContent> CompleteStackTaskAsync(Dt_Task task, Dt_WheelsStock stock)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            if(stock ==null) return content.Error("任务完成失败，未找到当前库存信息，删除失败");

            // 更新库位状态与任务状态
            (var loc, var tas) = UpdateStockAndTaskStatus(stock, task);
            var taskHty = task.Adapt<Dt_Task_Hty>();
            taskHty.FinishTime = DateTime.Now;
            taskHty.OperateType = (int)OperateTypeEnum.自动完成;

            Dt_WheelsStock_hty stockInfo_Hty = stock.Adapt<Dt_WheelsStock_hty>();
            stockInfo_Hty.FinishWheelDate = DateTime.Now;
            stockInfo_Hty.OperateType = (int)OperateTypeEnum.自动完成;

            Dt_OutWheels_hty Outwheels_hty = new Dt_OutWheels_hty
            {
                Wheels_code = stock.Wheels_code,
                Wheels_Type = stock.Wheels_Type == "1"?"轮":"盘",
                Wheels_Num = stock.Wheels_Num,
                CreateDate = DateTime.Now,
                Creater = App.User.UserName == null ? "admin" : App.User.UserName,
                WheelsProps = stock.WheelsProps,
                Wheels_CarNo = stock.Wheels_CarNo,
                Wheels_CarType = stock.Wheels_CarType,
                Wheels_ldxh = stock.Wheels_ldxh,
                Wheels_ldtm = stock.Wheels_ldtm,
                Wheels_InDate = stock.Wheels_InDate,
                Wheels_level = stock.Wheels_level,
                Wheels_NewOrOld = stock.Wheels_NewOrOld,
                Wheels_psj = stock.Wheels_psj,
                Wheels_gkcc = stock.Wheels_gkcc,
                Wheels_gkzja = stock.Wheels_gkzja,
                Wheels_gkzjb = stock.Wheels_gkzjb,
                Wheels_gkzjc = stock.Wheels_gkzjc,
                Wheels_ldh = stock.Wheels_ldh,
                Wheels_ljz = stock.Wheels_ljz,
                Wheels_mttype = stock.Wheels_mttype,
                //Wheels_SequenceNum = "",
                Wheels_ygljz = stock.Wheels_ygljz,
            };



            // 事务处理
            await _unitOfWorkManage.UseTranAsync(async () =>
            {
                var isStockUpdated = await _WheelsStockRepository.DeleteDataByIdAsync(stock.Wheels_ID);     //删除库存
                var isLocationUpdate = await _locationRepository.UpdateDataAsync(loc);                      //更新库位
                //var isTaskUpdated = await BaseDal.DeleteDataByIdAsync(task.TaskId);                         //删除任务
                var isTaskAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;                        //加入历史任务
                var isStockHtyAdd = await _WheelsStock_HtyRepository.AddDataAsync(stockInfo_Hty);           //加入历史库存

                var isoutWheelsHtyAdd = await _OutWheels_HtyRepository.AddDataAsync(Outwheels_hty);         //添加车轮出库信息
            });

            return content.OK("任务完成成功", task.Remark);
        }
        catch (Exception err)
        {
            LogFactory.GetLog("任务完成").Error(true, $"系统异常，异常信息：{err.Message}");
            return content.Error(err.Message);
        }
    }

    private (DtLocationInfo, Dt_Task) UpdateStockAndTaskStatus( Dt_Task task)
    {
        var location = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
        int lastStatus = location.LocationStatus;
        location.LocationStatus = (int)LocationEnum.Free;
        task.TaskState = (int)TaskOutStatusEnum.OutFinish;
        //task.CurrentAddress = task.NextAddress;
        //task.NextAddress = task.TargetAddress;

        _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(location, lastStatus, (int)StatusChangeTypeEnum.AutomaticDelivery, task.TaskNum);

        LogFactory.GetLog("任务完成").Info(true, "更新库位状态与任务状态");
        return (location, task);
    }
    #endregion

    #region 制动盘出库任务完成
    public async Task<WebResponseContent> CompleteOutZdpTaskAsync(Dt_Task task, Dt_ZdpStock stock)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            if (stock == null) return content.Error("任务完成失败，未找到当前库存信息，删除失败");

            // 更新库位状态与任务状态
            (var loc, var tas) = UpdateStockAndTaskStatus(task);
            var taskHty = task.Adapt<Dt_Task_Hty>();
            taskHty.FinishTime = DateTime.Now;
            taskHty.OperateType = (int)OperateTypeEnum.自动完成;

            Dt_ZdpStock_hty stockInfo_Hty = stock.Adapt<Dt_ZdpStock_hty>();
            stockInfo_Hty.FinishDate = DateTime.Now;
            stockInfo_Hty.OperateType = (int)OperateTypeEnum.自动完成;

            Dt_OutZdp_hty Outwheels_hty = new Dt_OutZdp_hty
            {
                Zdp_code = stock.Zdp_code,
                Zdp_ZPH = stock.Zdp_ZPH,
                Zdp_Location = stock.Zdp_Location,
                Zdp_chexing = stock.Zdp_chexing,
                Zdp_neworold = stock.Zdp_neworold,
                Zdp_POS = stock.Zdp_POS,
                Zdp_LSXH = stock.Zdp_LSXH,
                Zdp_MAT = stock.Zdp_MAT,
                Zdp_SITE = stock.Zdp_SITE,
                Zdp_GKA1 = stock.Zdp_GKA1,
                Zdp_GKA2 = stock.Zdp_GKA2,
                Zdp_GKA3 = stock.Zdp_GKA3,
                Zdp_GKA = stock.Zdp_GKA,
                Zdp_GKB1 = stock.Zdp_GKB1,
                Zdp_GKB2 = stock.Zdp_GKB2,
                Zdp_GKB3 = stock.Zdp_GKB3,
                Zdp_GKB = stock.Zdp_GKB,
                Zdp_GKC1 = stock.Zdp_GKC1,
                Zdp_GKC2 = stock.Zdp_GKC2,
                Zdp_GKC3 = stock.Zdp_GKC3,
                Zdp_GKC = stock.Zdp_GKC,
                Zdp_GKJZ = stock.Zdp_GKJZ,
                Zdp_LSCSYMH = stock.Zdp_LSCSYMH,
                Zdp_rksj = stock.Zdp_rksj,
            };

            // 事务处理
            await _unitOfWorkManage.UseTranAsync(async () =>
            {
                var isStockUpdated = await _ZdpStockRepository.DeleteDataByIdAsync(stock.Zdp_ID);     //删除库存
                var isLocationUpdate = await _locationRepository.UpdateDataAsync(loc);                      //更新库位
                //var isTaskUpdated = await BaseDal.DeleteDataByIdAsync(task.TaskId);                         //删除任务
                var isTaskAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;                        //加入历史任务
                var isStockHtyAdd = await _ZdpStock_HtyRepository.AddDataAsync(stockInfo_Hty);           //加入历史库存
            });

            return content.OK("任务完成成功", task.Remark);
        }
        catch (Exception err)
        {
            LogFactory.GetLog("任务完成").Error(true, $"系统异常，异常信息：{err.Message}");
            return content.Error(err.Message);
        }
    }

    private (DtLocationInfo, Dt_Task) UpdateStockAndTaskStatus(Dt_WheelsStock stock, Dt_Task task)
    {
        var location = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
        int lastStatus = location.LocationStatus;
        location.LocationStatus = (int)LocationEnum.Free;
        task.TaskState = (int)TaskOutStatusEnum.OutFinish;
        //task.CurrentAddress = task.NextAddress;
        //task.NextAddress = task.TargetAddress;

        _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(location, lastStatus, (int)StatusChangeTypeEnum.AutomaticDelivery, task.TaskNum);

        LogFactory.GetLog("任务完成").Info(true, "更新库位状态与任务状态");
        return (location, task);
    }
    #endregion

    #region 任务完成

    /// <summary>
    /// 完成任务
    /// </summary>
    /// <param name="taskNum">任务编号</param>
    /// <returns>返回结果集</returns>
    public async Task<WebResponseContent> CompleteAsync(int taskNum)
    {
        // 初始化响应内容
        WebResponseContent content = new WebResponseContent();

        // 提取任务数据
        LogFactory.GetLog("任务完成").InfoFormat(true, "提取任务数据", $"任务号：{taskNum}");

        // 验证任务是否存在
        var task = await GetByTaskNum(taskNum);
        if (task == null)
        {
            return content.Error("任务不存在");
        }
        LogFactory.GetLog("任务完成").InfoFormat(true, "验证任务是否存在", JsonConvert.SerializeObject(task));


        // 验证库存是否存在
        var stock = await _WheelsStockRepository.QueryFirstNavAsync(x => x.Wheels_Num.Contains(task.PalletCode) && x.Wheels_Location==task.SourceAddress);
        var ZdpStock = await _ZdpStockRepository.QueryFirstNavAsync(x => x.Zdp_code == task.PalletCode && x.Zdp_Location == task.SourceAddress);
        

        // 根据任务类型调用相应的完成任务方法
        switch (task.TaskType)
        {
            case (int)TaskInboundTypeEnum.Inbound:
            case (int)TaskInboundTypeEnum.InWheels:
            case (int)TaskInboundTypeEnum.InBrake:
                LogFactory.GetLog("任务完成").InfoFormat(true, "入库任务", "");
                return await CompleteInboundTaskAsync(task);

            case (int)TaskOutboundTypeEnum.Outbound:
            case (int)TaskOutboundTypeEnum.OutWheels:
                LogFactory.GetLog("任务完成").InfoFormat(true, "出库任务", "");
                return await CompleteStackTaskAsync(task, stock);

            case (int)TaskOutboundTypeEnum.OutBrake:
                LogFactory.GetLog("任务完成").InfoFormat(true, "制动盘出库任务", "");
                return await CompleteOutZdpTaskAsync(task, ZdpStock);

            case (int)TaskRelocationTypeEnum.Relocation:
                if (stock != null)
                    return await CompleteTransferTaskAsync(task, stock);
                else
                    return await CompleteZdpTaskAsync(task, ZdpStock);

            default:
                return content.Error("任务类型不存在");
        }
    }

    #endregion 任务完成

    #region 请求任务入库

    #region

    #endregion 请求任务入库

    /// <summary>
    /// 更新任务货位
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task<WebResponseContent> UpdateExistingTask(RequestTaskDto input)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            var task = await BaseDal.QueryFirstAsync(x => x.PalletCode == input.PalletCode);
            if (task == null)
                return content.Error($"暂未找到【{input.PalletCode}】的任务");

            return content = await UpdateExistingTask(input, task);
        }
        catch (Exception err)
        {
            return content.Error(err.Message);
        }
    }

    #endregion 外部接口方法

    #region 请求出库（实盘）


    /// <summary>
    /// 创建任务DTO
    /// </summary>
    private WMSTaskDTO CreateTaskDTO(Dt_Task task)
    {
        return new WMSTaskDTO
        {
            TaskNum = task.TaskNum.Value,
            Grade = task.Grade.Value,
            PalletCode = task.PalletCode,
            RoadWay = task.Roadway,
            SourceAddress = task.SourceAddress,
            TargetAddress = task.TargetAddress,
            TaskState = task.TaskState.Value,
            wheels_gkcc = task.wheels_gkcc,
            wheels_mttype = task.wheels_mttype,
            WheelsLX = task.WheelsLX,
            WheelsNewOrOld = task.WheelsNewOrOld,
            IsCheck = true,
            CarType = task.CarType,
            Id = 0,
            TaskType = task.TaskType
        };
    }

    #endregion 请求出库（实盘&空盘）

    #region 任务状态更改

    /// <summary>
    /// 更新任务状态
    /// </summary>
    /// <param name="taskNum"></param>
    /// <param name="taskState"></param>
    /// <returns></returns>
    public async Task<WebResponseContent> UpdateTaskStatus(int taskNum, int taskState)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            var task = await BaseDal.QueryFirstAsync(x => x.TaskNum == taskNum);
            if (task == null)
                return content.Error("未找到任务");

            if (taskState == (int)TaskOutStatusEnum.Line_OutFinish || taskState == (int)TaskInStatusEnum.SC_InFinish)
            {
                var taskHty = CreateHistoricalTask(task);
                await _unitOfWorkManage.UseTranAsync(async () =>
                {
                    var asb = await BaseDal.DeleteDataByIdAsync(task.TaskId);
                    var asbHty = await _task_HtyRepository.AddDataAsync(taskHty) > 0;
                    if (asb && asbHty)
                        content.OK();
                    else
                        throw new Exception();
                });
                content.OK();
            }
            else
            {
                task.TaskState = taskState;
                var asb = await BaseDal.UpdateDataAsync(task);
                if (asb)
                    content.OK();
                else
                    content.Error();
            }
        }
        catch (Exception ex)
        {
            content.Error(ex.Message);
        }
        return content;
    }

    #endregion 任务状态更改

    #region 指定任务出库

    public WebResponseContent CreateAndSendOutboundTask(SaveModel saveModel)
    {
        WebResponseContent content = new WebResponseContent();
        try
        {
            List<Dt_WheelsStock> WheelList = new List<Dt_WheelsStock>();
            List<Dt_ZdpStock> ZdpStockList = new List<Dt_ZdpStock>();
            List<Dt_Task> TaskList = new List<Dt_Task>();
            List<DtLocationInfo> Locationslist = new List<DtLocationInfo>();
            List<WMSTaskDTO> WMSTaskDTOdata = new List<WMSTaskDTO>();


            string palletCode = saveModel.MainData["palletCode"].ToString();
            string station = saveModel.MainData["station"].ToString();
            string outtype = saveModel.MainData["outtype"].ToString();  //1为指定车轮出库，2为指定制动盘出库

            List<string> palletCodes = JsonConvert.DeserializeObject<List<string>>(palletCode);     //把托盘条码显示

            List<DtLocationInfo> locationinfoData = _locationRepository.QueryData(x => x.LocationStatus == 2);  //查找全部库位
            if (outtype == "2")
            {
                List<Dt_ZdpStock> stocktData = _ZdpStockRepository.QueryData(x => x.Zdp_CurrentStatue == 1);  //查找全部在库的库存
                foreach (var item in palletCodes)
                {
                    Dt_ZdpStock zdpInfo = _ZdpStockRepository.QueryFirst(x => x.Zdp_code == item);
                    if (zdpInfo == null) return content.Error("未查询到对应的库存信息");
                    zdpInfo.Zdp_CurrentStatue = 4;
                    string Location = zdpInfo.Zdp_Location;
                   
                    var locationst = locationinfoData.FirstOrDefault(x => x.LocationCode == Location);
                    if (locationst.LocationStatus != (int)LocationEnum.InStock && locationst.EnalbeStatus != 1) return content.Error($"库位异常,请检查一下库位,库存条码：{item}，库位号：{Location}");

                    locationst.LocationStatus = (int)LocationEnum.InStockDisable;

                    var task = BaseDal.QueryFirst(x => x.PalletCode == item);
                    if (task != null)
                    {
                        return content.Error($"【{item}】已存在任务");
                    }


                    CheckInfo checkInfo = new CheckInfo()
                    {
                        CarType = zdpInfo.Zdp_chexing ,
                        MTType ="0" ,    //制动盘没有动拖属性

                        //CheckType = stockInfo.Wheels_Type == "1" ? "1" : "2",
                        CheckType = outtype,

                        HubLevel = "0" ,
                        CLTM =zdpInfo.Zdp_code,
                        IsCheck = true,
                        Standards = zdpInfo.Zdp_neworold 
                    };

                    task = new Dt_Task
                    {
                        CarType = zdpInfo.Zdp_chexing,
                        wheels_gkcc =  zdpInfo.Zdp_GKJZ,
                        WheelsNewOrOld = zdpInfo.Zdp_neworold,
                        WheelsLX = "",
                        Grade = 1,
                        Roadway = "SC1",
                        TargetAddress = station,
                        Dispatchertime = DateTime.Now,
                        MaterialNo = "",
                        NextAddress = "2010",
                        OrderNo = null,
                        PalletCode =  zdpInfo.Zdp_code,
                        wheels_mttype =  "" ,
                        SourceAddress = zdpInfo.Zdp_Location,
                        CurrentAddress =zdpInfo.Zdp_Location,
                        TaskState = (int)TaskOutStatusEnum.OutNew,
                        TaskType = outtype == "2" ? (int)TaskOutboundTypeEnum.OutBrake : (int)TaskOutboundTypeEnum.OutWheels,
                        TaskNum = BaseDal.GetTaskNo().Result,
                        Creater = "System",
                        CreateDate = DateTime.Now,
                        TaskId = 0,
                        task_bak1 = JsonConvert.SerializeObject(checkInfo),
                        Towhereabouts = station,
                    };

                    // 创建任务传输用的DTO对象
                    var taskDTO = CreateTaskDTO(task);

                    WMSTaskDTOdata.Add(taskDTO);
                    Locationslist.Add(locationst);
                    TaskList.Add(task);
                    ZdpStockList.Add(zdpInfo);
                }
            }
            else
            {
                List<Dt_WheelsStock> stocktData = _WheelsStockRepository.QueryData(x => x.Wheels_CurrentStatue == 1);  //查找全部在库的库存
                foreach (var item in palletCodes)
                {
                    Dt_WheelsStock stockInfo = _WheelsStockRepository.QueryFirst(x => x.Wheels_code == item);
                    if (stockInfo == null) return content.Error("未查询到对应的库存信息");
                    stockInfo.Wheels_CurrentStatue = 4;
                    string Location = stockInfo.Wheels_Location;
                    var locationst = locationinfoData.Where(x => x.LocationCode== stockInfo.Wheels_Location).FirstOrDefault();
                    if (locationst.LocationStatus == (int)LocationEnum.Lock) return content.Error("库位锁定,请先解锁后再指定出库");

                    locationst.LocationStatus = (int)LocationEnum.InStockDisable;

                    var task = BaseDal.QueryFirst(x => x.PalletCode == item);
                    if (task != null)
                    {
                        return content.Error($"【{item}】已存在任务");
                    }

                    CheckInfo checkInfo = new CheckInfo()
                    {
                        CarType = stockInfo.Wheels_CarType,
                        MTType = stockInfo.Wheels_mttype,    //制动盘没有动拖属性

                        //CheckType = stockInfo.Wheels_Type == "1" ? "1" : "2",
                        CheckType = outtype,

                        HubLevel = stockInfo.Wheels_level.Contains("等级") ? stockInfo.Wheels_level.Replace("等级", "") : "0",
                        CLTM = stockInfo.Wheels_Num,
                        IsCheck = true,
                        Standards = stockInfo.Wheels_NewOrOld
                    };


                    task = new Dt_Task
                    {
                        CarType =  stockInfo.Wheels_CarType,
                        wheels_gkcc = stockInfo.Wheels_gkcc,
                        WheelsNewOrOld =  stockInfo.Wheels_NewOrOld,
                        WheelsLX = outtype == "2" ? "" : stockInfo.Wheels_ldxh,
                        Grade = 1,
                        Roadway = "SC1",
                        TargetAddress = station,
                        Dispatchertime = DateTime.Now,
                        MaterialNo = "",
                        NextAddress = "2010",
                        OrderNo = null,
                        PalletCode =  stockInfo.Wheels_Num,
                        wheels_mttype = stockInfo.Wheels_mttype,
                        SourceAddress =stockInfo.Wheels_Location,
                        CurrentAddress =  stockInfo.Wheels_Location,
                        TaskState = (int)TaskOutStatusEnum.OutNew,
                        TaskType = outtype == "2" ? (int)TaskOutboundTypeEnum.OutBrake : (int)TaskOutboundTypeEnum.OutWheels,
                        TaskNum = BaseDal.GetTaskNo().Result,
                        Creater = "System",
                        CreateDate = DateTime.Now,
                        TaskId = 0,
                        task_bak1 = JsonConvert.SerializeObject(checkInfo),
                        Towhereabouts = station,
                    };

                    // 创建任务传输用的DTO对象
                    var taskDTO = CreateTaskDTO(task);

                    WMSTaskDTOdata.Add(taskDTO);
                    Locationslist.Add(locationst);
                    TaskList.Add(task);
                    WheelList.Add(stockInfo);
                }
            }


            // 获取WMS IP地址用于发送任务请求
            var wmsIpAddress = GetWCSIpReceiveTask();
            if (wmsIpAddress == null)
            {
                throw new InvalidOperationException("WMS IP 未配置");
            }
            // 发送任务请求到WMS
            var result = HttpHelper.Post(wmsIpAddress, WMSTaskDTOdata.ToJsonString());
            content = JsonConvert.DeserializeObject<WebResponseContent>(result);
            if (content.Status)
            {
                // 添加任务到数据库
                BaseDal.AddData(TaskList);
                // 更新库位位置状态为不可用
                _locationRepository.UpdateData(Locationslist);
                if (outtype == "2")
                {
                    _ZdpStockRepository.UpdateData(ZdpStockList);
                }
                else
                {
                    _WheelsStockRepository.UpdateData(WheelList);
                }
            }

        }
        catch (Exception ex)
        {
            Console.WriteLine($"发生异常: {ex.Message}");
            content.Error(ex.Message);
        }

        return content;
    }

    private string GetWCSIpReceiveTask()
    {
        var configs = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
        var wmsBase = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.WCSIPAddress)?.ConfigValue;
        var ipAddress = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.ReceiveTask)?.ConfigValue;
        if (wmsBase == null || ipAddress == null)
        {
            return null;
        }
        return wmsBase + ipAddress;
    }

    #endregion 指定任务出库

    #endregion 外部接口方法

    #region 内部调用方法

    /// <summary>
    /// 创建一个新的任务
    /// </summary>
    /// <param name="model">任务模型</param>
    /// <returns>创建的任务</returns>
    public async Task<Dt_Task> Create(Dt_Task model)
    {
        return await BaseDal.Create(model);
    }

    /// <summary>
    /// 批量创建任务
    /// </summary>
    /// <param name="models">任务模型列表</param>
    /// <returns>是否创建成功</returns>
    public async Task<bool> Create(List<Dt_Task> models)
    {
        return await BaseDal.Create(models);
    }

    /// <summary>
    /// 删除一个任务
    /// </summary>
    /// <param name="id">任务ID</param>
    /// <returns>是否删除成功</returns>
    public async Task<bool> Delete(int id)
    {
        return await BaseDal.Delete(id);
    }

    /// <summary>
    /// 批量删除任务
    /// </summary>
    /// <param name="ids">任务ID列表</param>
    /// <returns>是否删除成功</returns>
    public async Task<bool> Delete(List<int> ids)
    {
        return await BaseDal.Delete(ids);
    }

    public override WebResponseContent DeleteData(object[] key)
    {
        WebResponseContent content = new WebResponseContent();
        // 创建历史任务实例模型
        try
        {
            Dt_Task task = BaseDal.QueryFirst(x => x.TaskId == Convert.ToInt32(key[0]));
            if (task == null)
            {
                return content.Error("未找到任务信息!");
            }

            if (task.TaskState != (int)TaskInStatusEnum.InNew && task.TaskState != (int)TaskOutStatusEnum.OutNew && task.TaskState != (int)TaskStatus.Created)
            {
                return content.Error("任务不处于新建状态,禁止删除!");
            }

            var taskHtyNG = CreateHistoricalTask(task, true);

            //if (task.TaskState == (int)TaskInStatusEnum.InNew || task.TaskState == (int)TaskOutStatusEnum.OutNew)
            //{
            //    //if(task.TaskType ==  )
            //}

            // 添加历史任务
            var isTaskHtyAdd = _task_HtyRepository.AddData(taskHtyNG) > 0;

            // 删除任务数据
            var isTaskDelete = BaseDal.Delete(task.TaskId);

            return content.OK("删除成功!");
        }
        catch (Exception ex)
        {
            return content.Error("删除任务异常：" + ex.Message);
        }
    }

    /// <summary>
    /// 通过ID获取任务
    /// </summary>
    /// <param name="id">任务ID</param>
    /// <returns>任务模型</returns>
    public async Task<Dt_Task> GetById(int id)
    {
        return await BaseDal.GetById(id);
    }

    /// <summary>
    /// 获取所有任务列表
    /// </summary>
    /// <returns>任务模型列表</returns>
    public async Task<List<Dt_Task>> GetList()
    {
        return await BaseDal.GetList();
    }

    /// <summary>
    /// 根据出库订单ID获取任务列表
    /// </summary>
    /// <param name="outOrderId">出库订单ID</param>
    /// <returns>任务模型列表</returns>
    public async Task<List<Dt_Task>> GetListByOutOrder(int outOrderId)
    {
        return await BaseDal.GetListByOutOrder(outOrderId);
    }

    /// <summary>
    /// 根据出库订单ID和状态获取任务列表
    /// </summary>
    /// <param name="outOrderId">出库订单ID</param>
    /// <param name="status">任务状态</param>
    /// <returns>任务模型列表</returns>
    public async Task<List<Dt_Task>> GetListByOutOrderAndStatus(int outOrderId, int status)
    {
        return await BaseDal.GetListByOutOrderAndStatus(outOrderId, status);
    }

    /// <summary>
    /// 根据状态获取任务列表
    /// </summary>
    /// <param name="status">任务状态</param>
    /// <returns>任务模型列表</returns>
    public async Task<List<Dt_Task>> GetListByStatus(int status)
    {
        return await BaseDal.GetListByStatus(status);
    }

    /// <summary>
    /// 更新一个任务
    /// </summary>
    /// <param name="model">任务模型</param>
    /// <returns>是否更新成功</returns>
    public async Task<bool> Update(Dt_Task model)
    {
        return await BaseDal.UpdateDataAsync(model);
    }

    /// <summary>
    /// 批量更新任务
    /// </summary>
    /// <param name="models">任务模型列表</param>
    /// <returns>是否更新成功</returns>
    public async Task<bool> Update(List<Dt_Task> models)
    {
        return await BaseDal.UpdateDataAsync(models);
    }

    /// <summary>
    /// 检查任务是否存在
    /// </summary>
    /// <param name="palletCode">托盘编码</param>
    /// <returns>任务是否存在</returns>
    public bool IsExist(string palletCode)
    {
        return Db.Queryable<Dt_Task>().Any(x => x.PalletCode == palletCode);
    }

    /// <summary>
    /// 根据货位ID获取任务
    /// </summary>
    /// <param name="locationID"></param>
    /// <returns></returns>
    public async Task<Dt_Task> GetByLocation(string locationID)
    {
        return await BaseDal.QueryFirstAsync(x => x.SourceAddress == locationID);
    }

    /// <summary>
    /// 根据任务号获取任务
    /// </summary>
    /// <param name="taskNum"></param>
    /// <returns></returns>
    public async Task<Dt_Task> GetByTaskNum(int taskNum)
    {
        return await BaseDal.QueryFirstAsync(x => x.TaskNum == taskNum);
    }

    #endregion 内部调用方法

    #region private 内部方法

    /// <summary>
    /// 创建历史任务记录
    /// </summary>
    /// <param name="task"></param>
    /// <returns></returns>
    private Dt_Task_Hty CreateHistoricalTask(Dt_Task task, bool isHand = false)
    {
        // 更新任务状态
        task.TaskState = task.TaskType > 199 ? (int)TaskInStatusEnum.InFinish : (int)TaskOutStatusEnum.OutFinish;
        task.CurrentAddress = task.NextAddress;

        // 创建历史任务
        var taskHty = _mapper.Map<Dt_Task_Hty>(task);
        taskHty.FinishTime = DateTime.Now;
        taskHty.TaskId = 0;
        taskHty.OperateType = isHand ? (int)OperateTypeEnum.人工删除 : (int)OperateTypeEnum.自动完成;
        taskHty.SourceId = task.TaskId;
        if (isHand)
        {
            taskHty.Creater = App.User.UserName != null ? App.User.UserName : "System";
        }
        taskHty.TaskState = task.TaskType > 199 ? (int)TaskInStatusEnum.InFinish : (int)TaskOutStatusEnum.OutFinish;
        return taskHty;
    }

    /// <summary>
    /// 更新库存位置
    /// </summary>
    /// <param name="stock">库存对象</param>
    /// <param name="toLocation">目标位置</param>
    // 更新库存和位置信息
    private (Dt_WheelsStock, DtLocationInfo, DtLocationInfo) UpdateStockLocation(Dt_WheelsStock stock, Dt_Task task)
    {
        //修改来源库位和 目标库位状态
        var fromLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
        fromLocation.LocationStatus = (int)LocationEnum.Free;
        var toLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.TargetAddress && x.RoadwayNo == task.Roadway);
        toLocation.LocationStatus = (int)LocationEnum.InStock;

        // 将库存位置设置为目标位置
        stock.Wheels_Location = task.TargetAddress;

        // 返回更新后的库存和位置信息
        return (stock, fromLocation, toLocation);
    }

    /// <summary>
    /// 制动盘更新库存位置
    /// </summary>
    /// <param name="stock"></param>
    /// <param name="task"></param>
    /// <returns></returns>
    private (Dt_ZdpStock, DtLocationInfo, DtLocationInfo) UpdateZdpStockLocation(Dt_ZdpStock stock, Dt_Task task)
    {
        //修改来源库位和 目标库位状态
        var fromLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
        fromLocation.LocationStatus = (int)LocationEnum.Free;
        var toLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.TargetAddress && x.RoadwayNo == task.Roadway);
        toLocation.LocationStatus = (int)LocationEnum.InStock;

        // 将库存位置设置为目标位置
        stock.Zdp_Location = task.TargetAddress;

        // 返回更新后的库存和位置信息
        return (stock, fromLocation, toLocation);
    }



    #region 车轮执行数据库事务
    /// <summary>
    /// 车轮执行数据库事务
    /// </summary>
    /// <param name="stock">库存对象</param>
    /// <param name="taskHty">历史任务对象</param>
    /// <param name="taskId">任务ID</param>
    /// <returns></returns>
    private async Task<bool> ExecuteTransaction(Dt_WheelsStock stock, Dt_Task_Hty taskHty, DtLocationInfo locationInfo, int taskId, Dt_InWheels_mes inWheels_Mes = null)
    {
        _unitOfWorkManage.BeginTran();
        try
        {
            var isUpdateStock = false;
            var isDeleteWheelsMes = false;


            // 添加库存
            isUpdateStock = _WheelsStockRepository.AddData(stock) > 0;
            if (inWheels_Mes != null)
            {
                isDeleteWheelsMes = _InWheels_MesRepository.DeleteData(inWheels_Mes);

                var wheels_Mes_Hty = inWheels_Mes.Adapt<Dt_InWheels_mes_hty>();

                wheels_Mes_Hty.Wheels_CurrentStatue = "2";
                wheels_Mes_Hty.FinishDate = DateTime.Now;
                wheels_Mes_Hty.OperateType = (int)OperateTypeEnum.自动完成;

                _InWheels_Mes_HtyRepository.AddData(wheels_Mes_Hty);
            }


            // 添加历史任务
            var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;

            // 修改移库前货位状态
            var isUpdateLoc = _locationRepository.UpdateData(locationInfo);

            // 删除任务数据
            var isTaskDelete = await Delete(taskId);

            // 提交或回滚事务
            if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc && isDeleteWheelsMes)
            {
                LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"事务处理完成,提交事务。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新或添加库存：{isUpdateStock},修改入库前货位状态：{isUpdateLoc}");
                _unitOfWorkManage.CommitTran();
                return true;
            }
            else
            {
                LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"数据处理失败,请检查数据是否正确,数据回滚。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新库存：{isUpdateStock},修改入库前货位状态：{isUpdateLoc}");
                _unitOfWorkManage.RollbackTran();
                return false;
            }
        }
        catch (Exception err)
        {
            LogFactory.GetLog("任务完成").InfoFormat(true, $"任务完成,系统异常，异常信息：{err.Message}", "无参数");
            _unitOfWorkManage.RollbackTran();
            throw; // 抛出异常以便外部捕获
        }
    }
    #endregion

    #region 制动盘执行数据库事务
    /// <summary>
    ///  制动盘执行数据库事务
    /// </summary>
    /// <param name="stock">库存对象</param>
    /// <param name="taskHty">历史任务对象</param>
    /// <param name="taskId">任务ID</param>
    /// <returns></returns>
    private async Task<bool> ZDPExecuteTransaction(Dt_ZdpStock stock, Dt_Task_Hty taskHty, DtLocationInfo locationInfo, int taskId, Dt_InZdp_mes inZdp_Mes = null)
    {
        _unitOfWorkManage.BeginTran();
        try
        {
            var isUpdateStock = false;
            var isDeleteWheelsMes = false;


            // 添加库存
            isUpdateStock = _ZdpStockRepository.AddData(stock) > 0;
            if (inZdp_Mes != null)
            {
                isDeleteWheelsMes = _InZdp_MesRepository.DeleteData(inZdp_Mes);

                var InZdp_mes_hty = inZdp_Mes.Adapt<Dt_InZdp_mes_hty>();

                InZdp_mes_hty.Zdp_CurrentStatue = "2";
                InZdp_mes_hty.FinishDate = DateTime.Now;
                InZdp_mes_hty.OperateType = (int)OperateTypeEnum.自动完成;

                _InZdp_Mes_HtyRepository.AddData(InZdp_mes_hty);
            }


            // 添加历史任务
            var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;

            // 修改移库前货位状态
            var isUpdateLoc = _locationRepository.UpdateData(locationInfo);

            // 删除任务数据
            var isTaskDelete = await Delete(taskId);

            // 提交或回滚事务
            if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc && isDeleteWheelsMes)
            {
                LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"事务处理完成,提交事务。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新或添加库存：{isUpdateStock},修改入库前货位状态：{isUpdateLoc}");
                _unitOfWorkManage.CommitTran();
                return true;
            }
            else
            {
                LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"数据处理失败,请检查数据是否正确,数据回滚。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新库存：{isUpdateStock},修改入库前货位状态：{isUpdateLoc}");
                _unitOfWorkManage.RollbackTran();
                return false;
            }
        }
        catch (Exception err)
        {
            LogFactory.GetLog("任务完成").InfoFormat(true, $"任务完成,系统异常，异常信息：{err.Message}", "无参数");
            _unitOfWorkManage.RollbackTran();
            throw; // 抛出异常以便外部捕获
        }
    }
    #endregion

    #region 移库任务事务

    private async Task<bool> ExecuteTransaction(Dt_WheelsStock stock, Dt_Task_Hty taskHty, DtLocationInfo fromLocation, DtLocationInfo toLocation, int taskId)
    {
        _unitOfWorkManage.BeginTran();
        try
        {
            var isUpdateStock = _WheelsStockRepository.UpdateData(stock);

            // 添加历史任务
            var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;

            // 修改移库前货位状态
            var isUpdateLocF = _locationRepository.UpdateData(fromLocation);
            var isUpdateLocT = _locationRepository.UpdateData(toLocation);

            // 删除任务数据
            var isTaskDelete = await Delete(taskId);

            // 提交或回滚事务
            if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLocF && isUpdateLocT)
            {
                LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"事务处理完成,提交事务。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新或添加库存：{isUpdateStock},修改移库前货位状态：{isUpdateLocF}");
                _unitOfWorkManage.CommitTran();
                return true;
            }
            else
            {
                LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"数据处理失败,请检查数据是否正确,数据回滚。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新库存：{isUpdateStock},修改移库前货位状态：{isUpdateLocF}");
                _unitOfWorkManage.RollbackTran();
                return false;
            }
        }
        catch (Exception err)
        {
            LogFactory.GetLog("任务完成").InfoFormat(true, $"任务完成,系统异常，异常信息：{err.Message}", "无参数");
            _unitOfWorkManage.RollbackTran();
            throw new Exception(err.Message); // 抛出异常以便外部捕获
        }
    }

    #endregion MyRegion

    #region 制动盘移库任务事务

    private async Task<bool> ZdpExecuteTransaction(Dt_ZdpStock stock, Dt_Task_Hty taskHty, DtLocationInfo fromLocation, DtLocationInfo toLocation, int taskId)
    {
        _unitOfWorkManage.BeginTran();
        try
        {
            var isUpdateStock = _ZdpStockRepository.UpdateData(stock);

            // 添加历史任务
            var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;

            // 修改移库前货位状态
            var isUpdateLocF = _locationRepository.UpdateData(fromLocation);
            var isUpdateLocT = _locationRepository.UpdateData(toLocation);

            // 删除任务数据
            var isTaskDelete = await Delete(taskId);

            // 提交或回滚事务
            if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLocF && isUpdateLocT)
            {
                LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"事务处理完成,提交事务。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新或添加库存：{isUpdateStock},修改移库前货位状态：{isUpdateLocF}");
                _unitOfWorkManage.CommitTran();
                return true;
            }
            else
            {
                LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"数据处理失败,请检查数据是否正确,数据回滚。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新库存：{isUpdateStock},修改移库前货位状态：{isUpdateLocF}");
                _unitOfWorkManage.RollbackTran();
                return false;
            }
        }
        catch (Exception err)
        {
            LogFactory.GetLog("任务完成").InfoFormat(true, $"任务完成,系统异常，异常信息：{err.Message}", "无参数");
            _unitOfWorkManage.RollbackTran();
            throw new Exception(err.Message); // 抛出异常以便外部捕获
        }
    }

    #endregion MyRegion

    #region 任务请求方法


    private static readonly SemaphoreSlim _semaphoreUpdate = new SemaphoreSlim(1, 1);
    // 更新任务货位

    private async Task<WebResponseContent> UpdateExistingTask(RequestTaskDto input, Dt_Task task)
    {
        await _semaphoreUpdate.WaitAsync();
        try
        {
            if (task == null)
            {
                return new WebResponseContent().Error("任务对象为空");
            }

            try
            {
                // 创建WebResponseContent对象
                var content = new WebResponseContent();

                // 获取库位
                var location = RequestLocation(input);
                if (location == null)
                {
                    return content.Error("无法获取货位信息");
                }

                string toAddress = location.LocationCode;
                int taskState = (int)TaskInStatusEnum.Line_InFinish;
                int beforeStatus = location.LocationStatus;
                // 更新货位信息
                location.LocationStatus = (int)LocationEnum.Lock;

                // 更新任务信息
                MapTaskProperties(task, input, toAddress, taskState);

                _unitOfWorkManage.BeginTran();
                // 开始事务
                var isResult = await UpdateTaskAsync(task, location, beforeStatus);
                if (!isResult)
                {
                    _unitOfWorkManage.RollbackTran();
                    return content.Error("更新任务失败");
                }

                // 提交事务
                _unitOfWorkManage.CommitTran();
                return content.OK(data: task);
            }
            catch (Exception ex)
            {
                // 回滚事务
                _unitOfWorkManage.RollbackTran();
                // 这里可以添加日志记录
                return new WebResponseContent().Error($"更新任务时发生错误: {ex.Message}");
            }
        }
        catch (Exception)
        {

            throw;
        }
        finally { _semaphoreUpdate.Release(); }
    }

    private void MapTaskProperties(Dt_Task task, RequestTaskDto input, string toAddress, int taskState)
    {
        task.CurrentAddress = input.Position;
        task.TargetAddress = toAddress;
        task.NextAddress = toAddress;
        task.TaskState = taskState;
    }

    // 修改任务
    private async Task<bool> UpdateTaskAsync(Dt_Task task, DtLocationInfo location, int beforeStatus)
    {
        bool isResult = await BaseDal.UpdateDataAsync(task);
        bool isTaskDetail = await _taskExecuteDetailRepository.AddDetailAsync(task, false, TaskDescription.GetTaskUpdateDescription(task.PalletCode, task.CurrentAddress, task.TargetAddress, TaskInStatusEnum.Line_InFinish.GetIntegralRuleTypeEnumDesc()));

        LocationChangeRecordDto changeRecordDto = new LocationChangeRecordDto()
        {
            AfterStatus = location.LocationStatus,
            BeforeStatus = beforeStatus,
            TaskNum = task.TaskNum.Value,
            LocationId = location.Id,
            LocationCode = location.LocationCode,
            ChangeType = (int)StatusChangeTypeEnum.AutomaticStorage,
        };

        bool isUpdateChange = _locationStatusChangeRecordRepository.AddStatusChangeRecord(changeRecordDto);
        bool isUpdateLo = await _locationRepository.UpdateDataAsync(location);

        return isResult && isUpdateLo && isTaskDetail;
    }
    #endregion 任务请求方法

    #endregion private 内部方法
}