using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using yunneiWCS.Common;
using yunneiWCS.data;
using yunneiWCS.DataAccess;
using yunneiWCS.EnumDefine;
using yunneiWCS.ORM;
using yunneiWCS.SystemInteraction.tianyong;

namespace yunneiWCS.ExtendFunction
{
    /// <summary>
    /// 一些任务的处理类
    /// </summary>
    public class TaskHelper
    {
        /// <summary>
        /// 下发旁路工位的任务
        /// </summary>
        /// <param name="taskId"></param>
        /// <param name="errMsg"></param>
        /// <returns></returns>
        public static bool IssueTaskForPangLuGongWei(int taskId, string midStorePosition, ref string errMsg)
        {
            using (dbmodel mod = new dbmodel())
            {
                //判断输送线站点是否有任务占用
                var isStationHasDoingTaskResult = MyExtendHelper.IsStationHasDoingTask(mod, midStorePosition);
                if (isStationHasDoingTaskResult.result == false)
                {
                    errMsg = isStationHasDoingTaskResult.resMsg;
                    return false;
                }

                var task = mod.task.Where(x => x.taskId == taskId).FirstOrDefault();
                if (task == null)
                {
                    errMsg = "没有找到任务";
                    return false;
                }
                if (task.taskStatus != (int)taskStatus.新建)
                {
                    errMsg = "任务状态不是新建状态，不允许操作";
                    return false;
                }
                if (task.taskType != (int)taskType.旁路工位缸体空托回库 && task.taskType != (int)taskType.旁路工位缸体余料回库)
                {
                    errMsg = "任务类型不是旁路工位缸体空托回库或旁路工位缸体余料回库，不允许操作";
                    return false;
                }
                //更新状态为 未下发
                task.middlePlace = midStorePosition;
                task.taskStatus = (int)taskStatus.未下发;
                task.remark = "未下发";
                task.LastModifyTime = DateTime.Now;
                var res = mod.SaveChanges();
                if (res > 0)
                {
                    return true;
                }
                else
                {
                    errMsg = "更新任务状态失败";
                    return false;
                }
            }
        }


        /// <summary>
        /// 处理任务是下发中，任务类型是 呼叫空托And缸体上线And缸盖上线的库存管理
        /// </summary>
        /// <param name="mod"></param>
        /// <param name="item"></param>
        /// <param name="convPlace">输送线站点</param>
        /// <param name="tasktype"></param>
        public static void sendTaskForHasIssuedFor呼叫空托And缸体上线And缸盖上线(dbmodel mod, task item, string convPlace, string tasktype)
        {
            #region 清空库存更新状态
            item.taskStatus = (int)taskStatus.完成;
            item.remark = "完成";
            //mod.SaveChanges();
            //agvSendStatus[0] = DateTime.Now.ToString("dd日HH:mm:ss") + "发送成功,任务ID:" + item.taskId;
            //库存位
            position sourcePosition = mod.position.FirstOrDefault(x => x.positionName == item.sourcePlace);
            //上下线站点位

            //解锁输送线
            position convs = mod.position.FirstOrDefault(x => x.positionName == convPlace);
            //convs.isLock = false;
            PositionHandler.Lock(false, convs, "处理任务是下发中，任务类型是 呼叫空托And缸体上线And缸盖上线的库存管理", SysGloble.WCSNAME, item);

            if (sourcePosition != null)
            {
                #region 清空库位
                productStock stock = mod.productStock.FirstOrDefault(x => x.positionId == sourcePosition.positionId);
                if (stock != null)
                {
                    if (item.taskType == (int)taskType.缸体上线
                        || item.taskType == (int)taskType.缸盖上线
                        )//上线就把数据放到上线站点上
                    {
                        position positionStation = mod.position.FirstOrDefault(x => x.positionName == item.toPlace);
                        if (positionStation != null)
                        {
                            stock.positionId = positionStation.positionId;
                            stock.updateTime = Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                            //positionStation.isfree = true;
                            PositionHandler.Free(true, positionStation, "处理任务是下发中，任务类型是 呼叫空托And缸体上线And缸盖上线的库存管理", SysGloble.WCSNAME, item);
                        }
                        List<productStockList> stocklist = mod.productStockList.Where(x => x.stockId == sourcePosition.positionId).ToList();
                        if (stocklist.Count > 0)
                        {
                            foreach (var itemList in stocklist)
                            {
                                itemList.stockId = positionStation.positionId;
                            }
                        }
                    }
                    else//呼叫空托就清空库存
                    {
                        mod.productStock.Remove(stock);
                    }
                    //sourcePosition.isfree = false;
                    //sourcePosition.isLock = false;
                    PositionHandler.LockAndFree(false, false, sourcePosition, "处理任务是下发中，任务类型是 呼叫空托And缸体上线And缸盖上线的库存管理", SysGloble.WCSNAME, item);
                    sourcePosition.quantity = 0;
                    sourcePosition.positionType = 1;


                    OutInStockRecordHandler.AddOutInStockRecord(mod, OutInFlag.出库, item.sourcePlace, item.toPlace, item, "出库类型的任务");

                }
                else
                {
                    WZ.Useful.Commons.LogTextHelper.WriteLine("Form1", "sendTask", "任务ID" + item.taskId + "-" + tasktype + "查找库存失败");
                }
                #endregion
            }
            else
            {
                WZ.Useful.Commons.LogTextHelper.WriteLine("Form1", "sendTask", "任务ID" + item.taskId + "-" + tasktype + "查找库位失败");
            }
            #endregion

            if (item.taskType == (int)taskType.缸盖上线) //增加任务类型 【EditBy shaocx,2022-04-23】
            {
                //给天永发信号
                TianYongSystem.UpdateStoreByTaskID(mod, item, item.toPlace, (int)item.taskId, "缸盖上线,进入天永站点");
            }

            int saveRes = mod.SaveChanges();
            if (saveRes < 1)
            {
                WZ.Useful.Commons.LogTextHelper.WriteLine("Form1", "sendTask", "数据库保存失败！ 任务id:" + item.taskId);
            }
            else
            {//处理成功后

            }
        }

        /// <summary>
        /// 处理任务是下发中,发送堆垛机任务
        /// </summary>
        /// <param name="mod"></param>
        /// <param name="srm"></param>
        /// <param name="item"></param>
        /// <param name="convPlace">输送线站点</param>
        public static void sendTaskForHasIssuedFor发送堆垛机任务(dbmodel mod, task item, string convPlace)
        {
            if (convPlace == "")
            {
                //保存失败信息到任务表中 【EditBy shaocx,2022-03-16】
                item.remark = "起点为空!!!!";
                mod.SaveChanges();
                return;
            }
            if (!MyExtendHelper.IsAllowSimulatorHandle(item))
            {
                //if (srm.mode == "自动" && srm.Alarm_info == "无故障" && srm.state == "待机")
                if (MyExtendHelper.IsAllowSendNewTaskToSrm())
                {
                    //发送堆垛机任务
                    baseData.sendSrmTask(item, item.taskId, convPlace, item.toPlace, 1);
                }
                else
                {
                    //保存失败信息到任务表中 【EditBy shaocx,2022-03-16】
                    item.remark = "堆垛机不是自动，无故障，待机状态，不能下发堆垛机任务!!!!";
                    mod.SaveChanges();
                    return;
                }
            }
            #region 数据操作
            position convs = mod.position.FirstOrDefault(x => x.positionName == convPlace);
            if (convs != null)
            {
                // convs.isLock = false;
                PositionHandler.Lock(false, convs, "处理任务是下发中,发送堆垛机任务", SysGloble.WCSNAME, item);
            }

            item.taskStatus = (int)taskStatus.待完成;
            item.remark = "待完成";


            int saveRes = mod.SaveChanges();

            for (int i = 0; i < 4; i++)
            {
                if (saveRes < 1)
                {
                    saveRes = mod.SaveChanges();
                }
                else
                {
                    break;
                }
            }
            if (saveRes < 1)
            {
                WZ.Useful.Commons.LogTextHelper.WriteLine("Form1", "sendTask", "数据库保存失败！ 任务id:" + item.taskId);
            }
            #endregion

        }

        /// <summary>
        /// 处理任务是未下发,发送堆垛机任务
        /// </summary>
        /// <param name="mod"></param>
        /// <param name="srm"></param>
        /// <param name="item"></param>
        /// <param name="convPlace">输送线站点</param>
        public static void sendTaskForNoIssuedFor发送堆垛机任务(dbmodel mod, task item, string convPlace)
        {

            if (!MyExtendHelper.IsAllowSimulatorHandle(item))
            {
                // if (srm.mode == "自动" && srm.Alarm_info == "无故障" && srm.state == "待机")
                if (MyExtendHelper.IsAllowSendNewTaskToSrm())
                {
                    //发送堆垛机任务
                    baseData.sendSrmTask(item, item.taskId, item.sourcePlace, convPlace, 1);
                }
                else
                {
                    //保存失败信息到任务表中 【EditBy shaocx,2022-03-16】
                    item.remark = "堆垛机不是自动，无故障，待机状态，不能下发堆垛机任务!!!!";
                    mod.SaveChanges();
                    return;
                }
            }
            #region 数据操作
            position unlockPosition = mod.position.FirstOrDefault(x => x.positionName == convPlace);
            if (unlockPosition != null)
            {
                //unlockPosition.isLock = true;
                PositionHandler.Lock(true, unlockPosition, "发送堆垛机任务时", SysGloble.WCSNAME, item);
            }
            //保存任务记录
            item.middlePlace = convPlace;
            //item.taskStatus = 3;
            item.taskStatus = (int)taskStatus.已下发;
            item.remark = "已下发";
            //增加出库单 状态更改

            int saveRes = mod.SaveChanges();

            for (int i = 0; i < 4; i++)
            {
                if (saveRes < 1)
                {
                    saveRes = mod.SaveChanges();
                }
                else
                {
                    break;
                }
            }
            if (saveRes < 1)
            {
                WZ.Useful.Commons.LogTextHelper.WriteLine("Form1", "sendTask", "数据库保存失败！ 任务id:" + item.taskId);
            }
            #endregion

        }
    }
}