using Microsoft.Extensions.Logging;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using WIDESEA.Common;
using WIDESEA.Core.ManageUser;
using WIDESEA.Core.Services;
using WIDESEA.Core.Utilities;
using WIDESEA.Entity.DomainModels;
using WIDESEA.Services.IRepositories;
using WIDESEA.Services.Repositories;
using WIDESEA_Common.LogEnum;
using WIDESEA_Services;

namespace WIDESEA.Services.Services
{
    public partial class CommonFunction
    {

        /// <summary>
        /// 移库出库
        /// </summary>
        /// <param name="saveModel"></param>
        /// <returns></returns>
        public static WebResponseContent AddCheckTaskAction(SaveModel saveModel)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                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 || saveModel.DelKeys.Count > 1)
                        return content.Error("应急模式只能出1个任务.");
                }
                IVV_ContainerInfoRepository repository = VV_ContainerInfoRepository.Instance;
                List<string> locationState = new List<string>()
                {
                    LocationState.LocationState_Stored.ToString(),
                    LocationState.LocationState_Error.ToString(),
                };
                List<VV_ContainerInfo> listContainer = new List<VV_ContainerInfo>();
                foreach (var item in saveModel.DelKeys)
                {
                    Guid id = new Guid(item.ToString());
                    VV_ContainerInfo containerInfo = repository.FindFirst(x => x.containerdtl_id == id);
                    if (null != containerInfo)
                    {
                        if (!locationState.Contains(containerInfo.location_state) || containerInfo.location_islocked)
                            throw new Exception($"只能复核有货状态和解锁的库存,货位号:{containerInfo.location_id}");
                        listContainer.Add(containerInfo);
                    }
                }
                content = repository.DbContextBeginTransaction(() =>
                {
                    List<Dt_taskinfo> listTask = new List<Dt_taskinfo>();
                    foreach (var containerInfo in listContainer)
                    {
                        //更改货位状态
                        Dt_locationinfo locationinfo = Dt_locationinfoRepository.Instance.FindFirst(x => x.location_id == containerInfo.location_id);
                        if (containerInfo.location_state.Equals(LocationState.LocationState_Stored.ToString()))
                            locationinfo.location_state = LocationState.LocationState_CheckOutbound.ToString();
                        else if (containerInfo.location_state.Equals(LocationState.LocationState_Error.ToString()))
                            locationinfo.location_state = LocationState.LocationState_ErrorCheckOutbound.ToString();
                        else
                            throw new Exception("无效货位状态." + containerInfo.location_state);

                        Dt_locationinfoRepository.Instance.Update(locationinfo, x => x.location_state, true);
                        string target = CommonFunction.GetOutboundAddress(general_Info, locationinfo.location_layer);
                        //生成WMS任务
                        Dt_taskinfo taskinfo = new Dt_taskinfo();
                        taskinfo.task_id = Guid.NewGuid();
                        taskinfo.task_type = TaskType.TaskType_CheckOutbound.ToString();
                        taskinfo.task_state = TaskState.TaskState_Create.ToString();
                        taskinfo.task_barcode = containerInfo.containerdtl_barcode;
                        taskinfo.task_materielid = containerInfo.materiel_id;
                        taskinfo.task_weight = containerInfo.containerdtl_goodsWeight;
                        taskinfo.task_sn = containerInfo.containerdtl_goodsCode;
                        taskinfo.task_materielType = containerInfo.containerdtl_type;
                        //起始货位
                        taskinfo.task_fromlocationid = containerInfo.location_id;
                        //目的货位，应该是穿梭车的放货站台 (50301-50308)
                        taskinfo.task_tolocationid = target;
                        //测量出库任务穿梭车的放货站台(50301-50308)
                        taskinfo.task_beginstation = target;
                        //目的站台
                        taskinfo.task_endstation = "20101";
                        taskinfo.task_grade = 0;
                        taskinfo.task_creator = UserContext.Current.UserTrueName;
                        taskinfo.task_createtime = DateTime.Now;
                        taskinfo.task_weight = containerInfo.containerdtl_goodsWeight;
                        taskinfo.task_materielType = containerInfo.containerdtl_type;
                        taskinfo.task_sn = containerInfo.containerdtl_number;
                        Dt_taskinfoRepository.Instance.Add(taskinfo, true);
                        dt_checkRecord checkRecord = new dt_checkRecord()
                        {
                            record_barcode = containerInfo.containerdtl_barcode,
                            record_createTime = DateTime.Now,
                            record_id = Guid.NewGuid(),
                            record_locationId = containerInfo.location_id,
                            record_madeUnit = containerInfo.containerdtl_madeUnit,
                            record_materielId = containerInfo.materiel_id,
                            record_materielNumber = containerInfo.containerdtl_number,
                            record_materielType = containerInfo.containerdtl_type,
                            record_result = "",
                            record_standa = containerInfo.containerdtl_standard,
                            record_userName = UserContext.Current.UserTrueName,
                            record_weight = string.IsNullOrEmpty(containerInfo.containerdtl_goodsWeight) ? 0 : decimal.Parse(containerInfo.containerdtl_goodsWeight)
                        };
                        dt_checkRecordRepository.Instance.Add(checkRecord, true);
                        listTask.Add(taskinfo);
                        LogRecord.WriteLog((int)LogEnum.Check, $"{UserContext.Current.UserName}【手动添加复核任务】给货位：【{locationinfo.location_id}】、托盘号：【{containerInfo.containerdtl_barcode}】的轴承添加了复核任务");
                    }
                    content = WCSApi.SendTaskToWCS(listTask);
                    if (content.Status)
                        content.OK($"测量复核回库任务下发给WCS成功.");
                    else
                        content.Error($"测量复核回库任务下发给WCS失败,原因 => {content.Message}");
                    return content.OK("手动增加测量任务成功.");
                });
            }
            catch (Exception ex)
            {
                content.Error("创建复核任务失败:" + ex.Message);
            }
            finally
            {
                Logger.AddLog(Core.Enums.LoggerType.Add, saveModel, content, content);
            }
            return content;

        }

    }
}