using AngleSharp.Io;
using COSXML.Network;
using Elastic.Clients.Elasticsearch;
using Elastic.Clients.Elasticsearch.Inference;
using Furion.Logging;
using NewLife.Http;
using Newtonsoft.Json;
using System.Diagnostics.CodeAnalysis;
using System.Linq;
using System.Text;
using WCS.Application.Entity;

namespace WCS.Application;

/// <summary>
/// 示例开放接口
/// </summary>
[ApiDescriptionSettings("开放接口", Name = "Demo", Order = 100)]
//[Authorize(AuthenticationSchemes = SignatureAuthenticationDefaults.AuthenticationScheme)]
[AllowAnonymous]
public class DemoOpenApi : IDynamicApiController
{
    private static readonly ISqlSugarClient _db = SqlSugarSetup.ITenant.GetConnectionScope(SqlSugarConst.MainConfigId);

    private readonly UserManager _userManager;

    public DemoOpenApi(UserManager userManager)
    {
        _userManager = userManager;
    }

    //[HttpGet("helloWord")]
    //public Task<string> HelloWord()
    //{
    //    return Task.FromResult($"Hello word. {_userManager.Account}");
    //}

    // <summary>
    /// WCS接受WMS下发的任务
    /// </summary>
    /// <param name="models">任务信息</param>
    /// <returns>反馈信息</returns>
    [AllowAnonymous]
    public ResponseModel AddWcsTasks(List<ResponseTasksModel> modelList)
    {
        ResponseModel result = new ResponseModel();
        result.StatusCode = 0;
        try
        {            
            foreach (var models in modelList)
            {
                var res = AddWcsTask(models);
                if (res.StatusCode == -1)
                {
                    result.StatusCode = -1;
                    result.Msg = res.Msg;
                }
                else if (res.StatusCode == 0)
                {
                    result.StatusCode = 0;
                    result.Msg = models.TaskNo + "任务" + res.Msg;
                }
            }            
        }
        catch (Exception ex)
        {
            return new ResponseModel() { StatusCode = -1, Msg = ex.Message };
        }
        return result;
    }
    /// <summary>
    /// WCS接受WMS下发的任务(单条任务)
    /// </summary>
    /// <param name="models">任务信息</param>
    /// <returns>反馈信息</returns>
    [AllowAnonymous]
    public ResponseModel AddWcsTask(ResponseTasksModel models)
    {
        ResponseModel result = new ResponseModel();
        try
        {
            // 验证任务是否已存在
            var taskInfo = _db.Queryable<WcsTask>().First(w => w.TaskNo == models.TaskNo);
            if (taskInfo != null)
            {
                result.StatusCode = -1;
                result.Msg = "任务:" + models.TaskNo + ";已存在!";
                return result;
            }
            if (models.TaskType == "0")
            {
                models.Order = 1;
            }
            else
            {
                models.Order = 2;
            }

            int aaa = int.Parse(models.TaskType);
            var taskAdd = new WcsTask()
            {
                TaskNo = models.TaskNo,
                TaskType = (TaskTypeEnum)aaa,
                Status = TaskStatusEnum.Wait,
                //IsSuccess =TaskSuccessEnum.Success,
                Origin = "WMS",
                StartRoadway = models.StartRoadway,
                StartLocate = models.StartLocate,
                EndLocate = models.EndLocate,
                EndRoadway = models.EndRoadway,
                PalletNo = models.PalletNo,
                Levels = 999

                //LotNo =models.LotNo,
                //SkuNo=models.SkuNo,
                //SkuName=models.SkuName,
                //Qty=models.Qty
            };
            _db.Insertable(taskAdd).ExecuteCommand();           

            return new ResponseModel() { StatusCode = 0, Msg = "插入成功" };
        }
        catch (Exception ex)
        {
            return new ResponseModel() { StatusCode = -1, Msg = ex.Message };
        }
    }

    /// <summary>
    /// WCS接收WMS下发的入库单任务
    /// </summary>
    /// <param name="models"></param>
    /// <returns></returns>
    [AllowAnonymous]
    public ResponseModel AddOrderTask(List<ResponseOrderTaskModel> models)
    {
        ResponseModel result = new ResponseModel();
        try
        {
            foreach (var item in models)
            {
                // 验证任务是否已存在
                //var taskInfo = _db.Queryable<WcsOderTask>().First(w => w.OrderNo == item.OrderNo && w.SkuNo == item.SkuNo && w.LotNo == item.LotNo);
                //if (taskInfo == null)
                //{
                    var orderAdd = new WcsOderTask()
                    {
                        OrderNo = item.OrderNo.Trim(),
                        TaskNo = "",
                        LotNo = item.LotNo.Trim(),
                        SkuNo = item.SkuNo.Trim(),
                        SkuName = item.SkuName.Trim(),
                        BoxType = item.BoxType,
                        Qty = item.Qty,
                        TaskType = (TaskTypeEnum)item.TaskType,
                        Status=TaskStatusEnum.Wait
                    };
                    _db.Insertable(orderAdd).ExecuteCommand();
               //}
            }
            return new ResponseModel() { StatusCode = 0, Msg = "插入成功" };
        }
        catch (Exception ex)
        {
            return new ResponseModel() { StatusCode = -1, Msg = ex.Message };
        }
    }

    /// <summary>
    /// 获取空托盘垛申请入库工位
    /// </summary>
    /// <returns></returns>
    [AllowAnonymous]
    [HttpPost]
    public ResponseModel GetNullPalletRukuStation()
    {
        try
        {
            string rukuAdress = "";
            var conveyList4 = new List<string>() { "266", "265" };//四楼入库工位
            foreach (var item in conveyList4)
            {
                // 根据目标工位号获取输送线链接
                var plcCconn = PLCCommon.GetPlcIp(item);
                // 读取目标工位当前状态
                var ConveyorMod = PLCTaskAction.plcDevices.First(m => m.StationNum == item && m.DeviceType == DeviceTypeEnum.Business);
                var (result, value) = plcCconn.GetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.PlcPos);
                if (result.IsSucceed)
                {
                    if (value.ToString() == "120")//空闲状态
                    {
                        // 判断该工位是否存在未完成的出库任务
                        var modInTask = _db.Queryable<WcsTask>().OrderBy(m => m.Levels, OrderByType.Asc).OrderBy(m => m.CreateTime, OrderByType.Asc)
                            .First(s => (s.Status == TaskStatusEnum.Wait || s.Status == TaskStatusEnum.Doing) && s.TaskType == TaskTypeEnum.Out && s.EndLocate == item);

                        if (modInTask == null)
                        {
                            // 若空闲并没有未完成的出库任务提前占用此工位
                            var ret = plcCconn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "130");
                            if (ret.IsSucceed)
                            {
                                rukuAdress = item;
                                break;
                            }
                        }                        
                    }
                }
            }
            if (!string.IsNullOrEmpty(rukuAdress))
            {
                return new ResponseModel() { StatusCode = 0, Msg = rukuAdress };
            }
            else
            {
                return new ResponseModel() { StatusCode = -1, Msg = "无空闲入库工位" };
            }
        }
        catch (Exception ex)
        {
            return new ResponseModel() { StatusCode = -1, Msg = ex.Message };
        }
    }
    /// <summary>
    /// 小车入库口放货完成，WMS调用WCS更改PLC
    /// </summary>
    /// <param name="StationNum"></param>
    /// <returns></returns>
    [AllowAnonymous]
    [HttpPost]
    public ResponseModel UpdatePlcPosAgvTaskFinsh(AgvTaskFinshModel model)
    {
        try
        {
            var conveyList4 = new List<string>() { "266", "265" };//四楼入库工位
            if (!conveyList4.Contains(model.StationNum))
            {
                return new ResponseModel() { StatusCode = -1, Msg = "工位号无效" };
            }
            // 根据目标工位号获取输送线链接
            var plcCconn = PLCCommon.GetPlcIp(model.StationNum);
            // 读取目标工位当前状态
            var ConveyorMod = PLCTaskAction.plcDevices.First(m => m.StationNum == model.StationNum && m.DeviceType == DeviceTypeEnum.Business);
            var (result, value) = plcCconn.GetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.PlcPos);
            if (result.IsSucceed)
            {
                if (value.ToString() != "150")//空闲状态
                {
                    return new ResponseModel() { StatusCode = -1, Msg = "工位号PLC状态异常" };
                }
                // 写入160，放货完成
                var ret = plcCconn.SetPlcDBValue(ConveyorMod.PosType, ConveyorMod.DbNumber, ConveyorMod.WcsPos, "160");
                if (ret.IsSucceed)
                {
                    return new ResponseModel() { StatusCode = 0, Msg = "成功" };
                }
                else
                {
                    return new ResponseModel() { StatusCode = -1, Msg = "写入PLC失败" };
                }
            }
            else
            {
                return new ResponseModel() { StatusCode = -1, Msg = "连接PLC失败" };
            }
        }
        catch (Exception ex)
        {
            return new ResponseModel() { StatusCode = -1, Msg = ex.Message };
        }
    }

    /// <summary>
    /// WCS接受赋码系统推送的箱码信息
    /// </summary>
    /// <param name="models">箱码信息</param>
    /// <returns>反馈信息</returns>
    [HttpPost("AddHttpBoxInfo")]
    [AllowAnonymous]
    public ResponseFuMaModel AddHttpBoxInfo(FumaBoxModel models)
    {
        try
        {
            string str = JsonConvert.SerializeObject(models);
            Log.Information("接收赋码推送的箱码信息：" + str);

            var num = _db.Queryable<WcsBoxInfo>().Where(m => m.BoxNo == models.Product.BoxNo && m.IsDelete == false).ToList();
            var type = "add";
            if (num.Count > 0)
            {
                //WCS存在箱码信息，更新箱码信息(需判断箱码是否已组盘入库)
                var num2 = num.Count(m => m.Status != "0" || !string.IsNullOrWhiteSpace(m.PalletNo));
                if (num2 > 0)
                {
                    throw new Exception("该箱已入盘入库，不可更新信息");
                }
                type = "edit";
            }

            if (models.Product.Barcodes.Count == 0)
            {
                throw new Exception("盒码集合不能为空");
            }

            var listBox = new List<WcsBoxInfo>();
            foreach (var item in models.Product.Barcodes)
            {
                if (string.IsNullOrWhiteSpace(models.Product.ProductionTime) || string.IsNullOrWhiteSpace(models.Product.ExpirationTime))
                {
                    throw new Exception("生产日期或过期日期不能为空");
                }
                DateTime proTime;
                DateTime expTime;
                var isValid = DateTime.TryParse(models.Product.ProductionTime, out proTime);
                var isValid2 = DateTime.TryParse(models.Product.ExpirationTime, out expTime);
                if (!isValid || !isValid2)
                {
                    throw new Exception("生产日期或失效日期格式错误");
                };

                var boxAdd = new WcsBoxInfo()
                {
                    SkuNo = models.Product.SkuNo,
                    SkuName = models.Product.SkuName,                    
                    LotNo = models.Product.LotNo,
                    LotText = models.Product.LotText,
                    Custom = models.Product.Custom,
                    CustomName = models.Product.CustomName,
                    ProductionTime = proTime,
                    ExpirationTime = expTime,
                    LineNo=models.Product.Line_No,
                    Standard = models.Product.Standard,
                    PackageStandard = models.Product.PackageStandard,
                    PackUnit = models.Product.PackUnit,
                    StoreTime = DateTime.Parse(models.Product.StoreTime),
                    BitBoxMark = models.Product.BitBoxMark,
                    BoxNo = models.Product.BoxNo,                    
                    Qty = 1,//数量
                    FullQty = 0,//整箱数量
                    InsPectMark = models.Product.InsPectMark,//抽检标记
                    BoxNo2 = item.BoxNo2,
                    BoxNo3 = "",
                    Level = item.Level,
                    EndLotFlag = string.IsNullOrWhiteSpace(models.Product.BitBoxMark) ? "0" : models.Product.BitBoxMark,//结批标识                     
                    QtyCount = 0,//总件数
                    QtyOrd = 0,//第几件
                    Status = "0",
                    IsDelete = false
                };
                listBox.Add(boxAdd);
            }
            _db.Insertable(listBox).ExecuteCommand();
            if (type == "edit")
            {
                _db.Deleteable(num).ExecuteCommand();               
            }
            return new ResponseFuMaModel() { Success = true, Message = "ok" };
        }
        catch (Exception ex)
        {
            return new ResponseFuMaModel() { Success = false, Message = ex.Message };
        }
    }
}