using System;
using System.Threading;
using WIDESEA_Common;
using WIDESEA_Common.Tools;
using WIDESEA_Entity.DomainModels;
using WIDESEA_WCS.WCSClient;

namespace WIDESEA_WCS.JobsPart.AGV
{
    public partial class AGVServer
    {
        /// <summary>
        /// 取消agv任务
        /// </summary>
        public void CanselAgvTask(dt_agvtask task, PLCClient client)
        {
            Send(task, client);
            //等待处理
            Thread.Sleep(1000);
            int taskSendRespone = Convert.ToInt32(client.ReadValue(TaskDBName.taskInteractiveR.ToString()));
            if (taskSendRespone == 1)
            {
                //复位
                client.WriteValue(TaskDBName.taskInteractiveW.ToString(), 0);
                freeDB.Add(new dt_agvtask_hty()
                {
                    hty_pkid = Guid.NewGuid(),
                    agv_id = Guid.Empty,
                    agv_tasknum = task.agv_tasknum,
                    agv_materielid = task.agv_materielid,
                    agv_qty = task.agv_qty,
                    agv_createtime = task.agv_createtime,
                    agv_realesstime = task.agv_realesstime,
                    agv_executingBeginTime = task.agv_executingBeginTime,
                    agv_executingEndTime = task.agv_executingEndTime,
                    agv_completeBeginTime = task.agv_completeBeginTime,
                    agv_finishedtime = DateTime.Now,
                    agv_taskstate = AGVTaskStateEnum.Cancel.ToString(),
                    agv_tasktype = task.agv_tasktype,
                    agv_fromaddress = task.agv_fromaddress,
                    agv_toaddress = task.agv_toaddress,
                    agv_operatetype = string.Empty,
                    agv_compeletor = task.agv_userid,
                    agv_completedate = DateTime.Now,
                    agv_grade = task.agv_grade,
                    agv_userid = task.agv_userid,
                    agv_barcode = task.agv_barcode,
                    agv_code = task.agv_code,
                    agv_worktype = task.agv_worktype
                });
                //移入历史
                freeDB.Remove(task);
            }
            else
            {
                //任务下发其它错误
                WriteLog.GetLog().Write($"【异常】任务{task.agv_tasknum}，下发取消后反馈异常，反馈值{taskSendRespone}。" + "\n", client.PLCName);

                task.agv_taskstate = AGVTaskStateEnum.CancelAbnormal.ToString();
                freeDB.Update(task).UpdateColumns(t => new { t.agv_taskstate }).ExecuteAffrows();
                //复位
                client.WriteValue(TaskDBName.taskInteractiveW.ToString(), 0);
            }
        }
    }
}