using Newtonsoft.Json;
using System;
using WIDESEA_Common;
using WIDESEA_Common.APIAdderss;
using WIDESEA_Common.DBHelper;
using WIDESEA_Common.Tools;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Entity.DomainModels.TongRi;

namespace WIDESEA_WCS.ToTongRi
{
       
    public partial class ToTongRiServer
    {
         
        FreeDB freeDB = new FreeDB();
          
        /// <summary>
        /// 申请入库
        /// </summary>
        public void requestInWHTask(dt_agvtask agvtask)
        {
            try
            {
                RequestParm request = new RequestParm();
                request.taskId = agvtask.agv_tasknum;
                request.wareHouse = agvtask.agv_fromaddress.Contains("ZJ") ? "1" : "2";
                request.containerType = agvtask.agv_fromaddress.Contains("ZJ") ? "铝箔" : "铜箔"; ;
                var res = HttpHelper<RequestParm>.Post(request, OrtherAPIAddress.TongRi + "requestInWHTask");
                if (res.code == 2)
                {
                    throw new Exception("同日wms返回异常：\n" + res.msg);
                }
            }
            catch (Exception ex)
            {
         WriteLog.GetLog().Write($"【异常】任务号:{agvtask.agv_tasknum}\n{ex.Message}", "同日申请库");
                throw ex;
            }
        }
           
        /// <summary>
        /// 申请出库
        /// </summary>
        public void requestOutWHTask(dt_agvtask agvtask)
        {
            try
            {
                RequestParm request = new RequestParm();
                request.taskId = agvtask.agv_tasknum;
                request.wareHouse = agvtask.agv_fromaddress.Contains("ZJ") ? "1" : "2";
                request.containerType = agvtask.agv_fromaddress.Contains("ZJ") ? "铝箔" : "铜箔"; ;
                var res = HttpHelper<RequestParm>.Post(request, OrtherAPIAddress.TongRi + "requestOutWHTask");
                if (res.code == 2)
                {
                    throw new Exception("同日wms返回异常：\n" + res.msg);
                }
            }
            catch (Exception ex)
            {
                WriteLog.GetLog().Write($"【异常】任务号:{agvtask.agv_tasknum}\n{ex.Message}", "同日申请入库");
                throw ex;
            }
        }
           
        /// <summary>
        /// 物料出入库反馈 （同日调用）放的取的位置
        /// </summary>
        public TongRiRespone reportTaskPoint(object json)
        {
            TongRiRespone tongRiRespone = new TongRiRespone();
            try
            {
                var report = JsonConvert.DeserializeObject<ReportTask>(json.ToString());
                var task = freeDB.Select<dt_agvtask>().Where(t => t.agv_tasknum == report.taskNo).ToOne();
                task.agv_taskstate = AGVTaskStateEnum.Create.ToString();
                //入库
                if (report.taskType == "1")
                {
                    task.agv_toaddress = report.fromLocationCode;
                }
                //出库
                else if (report.taskType == "2")
                {
                    task.agv_fromaddress = report.fromLocationCode;
                }
                int changeRows = freeDB.Update(task).UpdateColumns(t => new { t.agv_taskstate, t.agv_toaddress, t.agv_fromaddress }).ExecuteAffrows();

                WriteLog.GetLog().Write($"【成功】{json}", "同日反馈取放位置");
                tongRiRespone.code = 1;
            }
            catch (Exception ex)
            {
                WriteLog.GetLog().Write($"【异常】{ex.Message}\n{json}", "同日反馈取放位置");
                tongRiRespone.code = 2;
                tongRiRespone.msg = ex.Message;
            }
            return tongRiRespone;
        }
           
        /// <summary>
        /// 物料入库/出库AGV取放货完成上报（agv状态2，起点完成）
        /// </summary>
        public void reportTaskComplete(dt_agvtask agvtask)
        {
            try
            {
                ReportTaskComplete reportTask = new ReportTaskComplete();
                reportTask.refTaskId = agvtask.agv_tasknum;

                if (agvtask.agv_tasktype == "入库")
                {
                    reportTask.taskType = "1";
                    reportTask.fromLocationCode = agvtask.agv_toaddress;
                    reportTask.containerType = agvtask.agv_toaddress.Contains("ZJ") ? "铝箔" : "铜箔";
                }
                else
                {
                    //出库
                    reportTask.taskType = "2";
                    reportTask.fromLocationCode = agvtask.agv_fromaddress;
                    reportTask.containerType = agvtask.agv_fromaddress.Contains("ZJ") ? "铝箔" : "铜箔";
                }
                WriteLog.GetLog().Write($"【成功】任务号：{agvtask.agv_tasknum}", "同日agv完成上报");
            }
            catch (Exception ex)
            {
                WriteLog.GetLog().Write($"【异常】任务号:{agvtask.agv_tasknum}\n{ex.Message}", "同日agv完成上报");
                throw ex;
            }
        }
          
        /// <summary>
        /// 物料出入库任务取消/手动完成申请接口
        /// </summary>
        public void requestCancelTask(dt_agvtask agvtask)
        {
            try
            {
                RequestCancelTask requestCancelTask = new RequestCancelTask();
                requestCancelTask.refTaskId = agvtask.agv_tasknum;

                if (agvtask.agv_tasktype == "入库")
                {
                    requestCancelTask.containerCode = agvtask.agv_fromaddress.Contains("ZJ") ? "铝箔" : "铜箔";
                    requestCancelTask.taskType = "1";
                }
                else
                {
                    requestCancelTask.containerCode = agvtask.agv_toaddress.Contains("ZJ") ? "铝箔" : "铜箔";
                    requestCancelTask.taskType = "2";
                }
                if (agvtask.agv_taskstate == AGVTaskStateEnum.Cancel.ToString())
                {
                    requestCancelTask.taskState = "1";
                }
                else if (agvtask.agv_taskstate == "手动完成")
                {

                    requestCancelTask.taskState = "2";
                }
                WriteLog.GetLog().Write($"【成功】任务号：{agvtask.agv_tasknum}", "同日手动操作任务");
            }
            catch (Exception ex)
            {
                WriteLog.GetLog().Write($"【异常】任务号:{agvtask.agv_tasknum}\n{ex.Message}", "同日手动操作任务");
                throw ex;
            }
        }
          
    }

}