/*
 *所有关于VV_ContainerInfo_EmptyPallet类的业务代码应在此处编写
*可使用repository.调用常用方法，获取EF/Dapper等信息
*如果需要事务请使用repository.DbContextBeginTransaction
*也可使用DBServerProvider.手动获取数据库相关信息
*用户信息、权限、角色等使用UserContext.Current操作
*VV_ContainerInfo_EmptyPalletService对增、删、改查、导入、导出、审核业务代码扩展参照ServiceFunFilter
*/
using WIDESEA.Core.BaseProvider;
using WIDESEA.Core.Extensions.AutofacManager;
using WIDESEA.Entity.DomainModels;
using System.Linq;
using WIDESEA.Core.Utilities;
using System.Linq.Expressions;
using WIDESEA.Core.Extensions;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.AspNetCore.Http;
using WIDESEA.Services.IRepositories;
using System;
using WIDESEA.Core.EFDbContext;
using WIDESEA.Services.Repositories;
using WIDESEA.Core.ManageUser;
using System.Collections.Generic;
using WIDESEA.Common;
using WIDESEA_Services;
using WIDESEA.Core.Services;
using WIDESEA_Services.Services.APIInvoke.RGV;
using WIDESEA_Entity.CustomModels.RGVModel;
using static WIDESEA_Entity.CustomModels.RGVModel.RgvDeviceStatusModel;

namespace WIDESEA.Services.Services
{
    public partial class VV_ContainerInfo_EmptyPalletService
    {
        private readonly IHttpContextAccessor _httpContextAccessor;
        private readonly IVV_ContainerInfo_EmptyPalletRepository _repository;//访问数据库


        [ActivatorUtilitiesConstructor]
        public VV_ContainerInfo_EmptyPalletService(
            IVV_ContainerInfo_EmptyPalletRepository dbRepository,
            IHttpContextAccessor httpContextAccessor
            )
        : base(dbRepository)
        {
            _httpContextAccessor = httpContextAccessor;
            _repository = dbRepository;
            //多租户会用到这init代码，其他情况可以不用
            //base.Init(dbRepository);
        }



        /// <summary>
        /// 呼叫空托盘、给WCS下发任务
        /// </summary>
        /// <param name="number">呼叫数量</param>
        /// <returns></returns>
        public WebResponseContent CallEmptyPallet(SaveModel saveModel)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                int number = int.Parse(saveModel.MainData["callNumber"].ToString());
                //查找库内空托盘数量
                List<VV_ContainerInfo_EmptyPallet> emptyPalletList = VV_ContainerInfo_EmptyPalletRepository.Instance.Find(x => x.location_state
                == LocationState.LocationState_Stored.ToString() && !x.location_islocked).OrderBy(x => x.containerdtl_createtime).ToList();

                if (number > emptyPalletList.Count())
                    throw new Exception($"无法呼叫数量为：【{number}】个空托盘，当库内可用空托盘数量为：【{emptyPalletList.Count()}】");

                List<int> rgvLayer = new List<int>();
                WebResponseContent resultcontent = RGVAPIInvokeGetRgvInfo.GetRgvInfo();
                if (resultcontent.Status)
                {
                    RgvDeviceStatusModel rgvData = (RgvDeviceStatusModel)resultcontent.Data;
                    //0离线 1正常 2故障
                    for (int i = 0; i < rgvData.data.Count(); i++)
                    {
                        Info _info = rgvData.data[i];
                        if (_info.status == 1)
                            rgvLayer.Add(_info.layer);
                    }
                }
                if (rgvLayer.Count <= 0)
                    return content.Error("当前无可用的RGV小车出库.");
                //剩下的
                //int count = number % rgvLayer.Count();
                // 每台车的,均分
                // int rgvCount = (number - count) / rgvLayer.Count();

                List<int> newLayer = new List<int>();
                //避免有的车当前层没有空托盘
                foreach (var item in rgvLayer)
                {
                    VV_ContainerInfo_EmptyPallet container = emptyPalletList.Find(r => r.location_layer == item);
                    if (null == container)
                    {
                        container = emptyPalletList.Find(r => !rgvLayer.Contains(r.location_layer));
                        if (null != container)
                            newLayer.Add(container.location_layer);
                        //rgvLayer.Remove(item);
                    }
                    else
                        newLayer.Add(item);
                }
                rgvLayer = newLayer;


                List<VV_ContainerInfo_EmptyPallet> listContainer = emptyPalletList.FindAll(r => rgvLayer.Contains(r.location_layer));
                if (listContainer.Count >= number)
                {
                    emptyPalletList = new List<VV_ContainerInfo_EmptyPallet>();
                    int layerCount = rgvLayer.Count();
                    int index = 0;
                    for (int i = 0; i < number; i++)
                    {
                        for (int layer = 0; layer < layerCount; layer++)
                        {
                            if (index == layerCount)
                                index = 1;
                            else
                                index++;
                            int item = rgvLayer[index - 1];
                            VV_ContainerInfo_EmptyPallet container = listContainer.Find(r => r.location_layer == item);
                            if (null != container)
                            {
                                emptyPalletList.Add(container);
                                listContainer.Remove(container);
                                break;
                            }
                        }
                    }
                    if (emptyPalletList.Count < number)
                        return content.Error("空托盘出库分配出错.");
                }
                else
                {
                    List<VV_ContainerInfo_EmptyPallet> ortherContainer = emptyPalletList.FindAll(r => !rgvLayer.Contains(r.location_layer));
                    emptyPalletList = new List<VV_ContainerInfo_EmptyPallet>();
                    emptyPalletList.AddRange(listContainer);
                    emptyPalletList.AddRange(ortherContainer.OrderBy(r => r.location_layer));
                }

                Dt_general_info general_Info = Dt_general_infoRepository.Instance.FindFirst(x => true);
                if ("应急模式".Equals(general_Info.general_inline_current_model))
                {
                    Dt_taskinfo task = Dt_taskinfoRepository.Instance.FindFirst(r => LayerToStation.inboundStations.Contains(r.task_endstation)
                 || LayerToStation.outboundStations.Contains(r.task_beginstation));
                    if (null != task || number > 1)
                        return content.Error("应急模式只能出1个任务.");
                }

                //更改货位状态、添加WMS任务和WCS任务
                content = VV_ContainerInfo_EmptyPalletRepository.Instance.DbContextBeginTransaction(() =>
                {
                    List<Dt_taskinfo> listTask = new List<Dt_taskinfo>();
                    foreach (var item in emptyPalletList.Take(number))
                    {
                        Dt_locationinfo locationinfo = Dt_locationinfoRepository.Instance.FindFirst(x => x.location_id == item.location_id);
                        //修改货位状态
                        CommonFunction.ChangeLocationState(locationinfo, LocationState.LocationState_Empty_OutBound_Wait_Executing.ToString());
                        Dt_container_head head = Dt_container_headRepository.Instance.FindFirst(r => r.containerhead_barcode == item.containerhead_barcode);
                        Dt_taskinfo tmpTaskInfo = CommonFunction.AddWMSTask_EmptyPalletOut(locationinfo, item.containerhead_barcode, head.containerhead_palletweight, general_Info);
                        listTask.Add(tmpTaskInfo);

                    }

                    content = WCSApi.SendTaskToWCS(listTask);
                    if (content.Status)
                        content.OK($"呼叫空托盘出库成功，任务托盘码为 = {listTask.Select(r => r.task_barcode).Serialize()}");
                    else
                        content.Error($"呼叫空托盘出库任务出错，原因：{content.Message}");

                    return content;
                });
            }
            catch (Exception ex)
            {
                content.Error($"呼叫空托盘出库任务出错" + ex.Message);
            }
            Logger.AddLog(Core.Enums.LoggerType.Add, saveModel, content, content);
            return content;

        }


        public override WebResponseContent Update(SaveModel saveModel)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                IDt_container_headRepository detailRepository = Dt_container_headRepository.Instance;
                Guid detID = saveModel.MainData["containerhead_id"].ToGuid();
                string testResult = saveModel.MainData["containerdtl_text1"].ToString();
                Dt_container_head container_Detail = detailRepository.FindFirst(x => x.containerhead_id == detID);
                container_Detail.containerhead_palletweight = testResult;
                detailRepository.Update(container_Detail, true);
                return content.OK("修改成功");
            }
            catch (Exception ex)
            {
                return content.Error($"修改失败，原因：{ex.Message}");
                throw;
            }
        }


        public override WebResponseContent Del(object[] keys, bool delList = true)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                if (keys.Length > 5)
                    return content.Error("一次最多删除5条库存记录");
                content = repository.DbContextBeginTransaction(() =>
                {
                    foreach (var item in keys)
                    {
                        Guid id = new Guid(item.ToString());
                        VV_ContainerInfo_EmptyPallet containerInfo = repository.FindFirst(x => x.containerhead_id == id);
                        if (null != containerInfo)
                        {
                            Dt_taskinfo task = Dt_taskinfoRepository.Instance.FindFirst(r => r.task_barcode == containerInfo.containerdtl_barcode);
                            if (null != task)
                                return content.Error($"托盘号{task.task_barcode}存在未完成的任务，请先确认。");

                            Dt_container_head container_Head = Dt_container_headRepository.Instance.FindFirst(x => x.containerhead_barcode == containerInfo.containerhead_barcode);
                            Dt_container_detail container_Detail = Dt_container_detailRepository.Instance.FindFirst(x => x.containerdtl_headid == id.ToString());
                            //将库存数据一到到历史表 head、detail
                            CommonFunction.AddContainerHeadToHistory(container_Head);
                            CommonFunction.AddContainerDetailToHistory(container_Detail);

                            //barcodeinfo数据移动到历史
                            Dt_barcodeinfo barcodeinfo = Dt_barcodeinfoRepository.Instance.FindFirst(x => x.barcode_value == containerInfo.containerhead_barcode);
                            CommonFunction.AddBarcodeInfoToHistory(barcodeinfo, UserContext.Current.UserTrueName);

                            //恢复空货位状态
                            Dt_locationinfo locationinfo = Dt_locationinfoRepository.Instance.FindFirst(x => x.location_id == containerInfo.location_id);
                            CommonFunction.ChangeLocationState(locationinfo, LocationState.LocationState_Empty.ToString());
                        }
                    }
                    return content.OK("删除空托盘信息成功.");
                });
            }
            catch (Exception ex)
            {
                return content.OK("删除空托盘信息失败." + ex.Message);
            }
            finally
            {
                Logger.AddLog(Core.Enums.LoggerType.Del, keys, content, content);
            }
            return content;
        }

    }
    public class emptyPalletOutInfo
    {
        public int layer { get; set; }
        public int count { get; set; }
    }

}