using HH.WMS.BLL;
using HH.WMS.BLL.Basic;
using HH.WMS.BLL.External;
using HH.WMS.BLL.SysMgr;
using HH.WMS.Common;
using HH.WMS.Common.External;
using HH.WMS.Common.Response;
using HH.WMS.DAL;
using HH.WMS.Entitys;
using HH.WMS.Entitys.Common;
using HH.WMS.Entitys.Dto;
using HH.WMS.Utils;
using HH.WMS.WebApi.App_Start;
using HH.WMS.WebApi.Areas.Common.Controllers;
using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Web.Http;

namespace HH.WMS.WebApi.Areas.TaskMgr.Controllers
{
    public class TaskController : BaseController
    {
        [HttpPost]
        public OperateResult GetList(SearchModel searchModel)
        {
            try
            {
                return ValidateToken(searchModel.TokenId, t =>
                {
                    var result = BLLCreator.Create<TN_WM_TASKBLL>().GetList(searchModel);
                    return result;
                });
            }
            catch (Exception ex)
            {
                return OperateResult.Error(ex.Message);
            }
        }

        [HttpGet]
        public OperateResult StartTask(string taskNos)
        {
            return ValidateToken(t =>
            {
                OperateResult or;
                int successQty = 0;
                string[] arrTask = taskNos.Split(',');

                List<OperateResult> errOr = new List<OperateResult>();
                foreach (string taskNo in arrTask)
                {
                    or = BLLCreator.Create<TN_WM_TASKBLL>().StartTask(taskNo,t);
                    if (or.Success)
                        successQty++;
                    else
                        errOr.Add(or);
                }
                if (successQty == arrTask.Length)
                    return OperateResult.Succeed();
                else if (successQty == 0)
                    return OperateResult.Error(errOr[0].Msg);
                else
                    return OperateResult.Warning(errOr[0].Msg);
            });
        }

        [HttpGet]
        public OperateResult EndTask(string taskNos)
        {
            return ValidateToken(t =>
            {
                OperateResult or;
                int successQty = 0;
                string[] arrTask = taskNos.Split(',');

                List<OperateResult> errOr = new List<OperateResult>();
                foreach (string taskNo in arrTask)
                {
                    or = BLLCreator.Create<TN_WM_TASKBLL>().EndTask(taskNo,t);
                    if (or.Success)
                        successQty++;
                    else
                        errOr.Add(or);
                }
                if (successQty == arrTask.Length)
                    return OperateResult.Succeed();
                else if (successQty == 0)
                    return OperateResult.Error(errOr[0].Msg);
                else
                    return OperateResult.Warning(errOr[0].Msg);
            });
        }

        /// <summary>
        /// 获取正在执行中或者未执行的任务
        /// </summary>
        /// <param name="trayCode"></param>
        /// <returns></returns>
        [HttpGet]
        public OperateResult GetTaskByTray(string trayCode)
        {
            try
            {
                return ValidateToken(t =>
                {
                   List< TN_WM_TASKEntity> trayLocationEntity = BLLCreator.Create<TN_WM_TASKBLL>().GetTaskByTray(trayCode);
                    return OperateResult.Succeed("", trayLocationEntity);
                });
            }
            catch (Exception ex)
            {
                return OperateResult.Error(ex.Message.ToString());
            }
        }

        #region 完工回报 + ExecuteState
        
        /// <summary>
        /// AGV执行情况 完成时调用
        /// </summary>
        /// <param name="json">传入的Json数组</param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/4/8</history>
        [HttpPost]
        public string ExecuteState(JObject json)
        {
            try
            {
                var taskNos = json.Value<string>("taskNos");
                var taskList = taskNos.Split(',').ToList();
                var taskStateNo = json.Value<int>("stateNo");
                var executeStates = new List<ExecuteStateDto>();

                foreach (var taskNo in taskList)
                {
                    executeStates.Add(new ExecuteStateDto
                    {
                        taskNo = taskNo,
                        stateNo = taskStateNo
                    });
                }
              
                var result = WmsApiBLLRoute.ExecuteState(executeStates);


                try
                {
              
                 
                    var projectCode = System.Configuration.ConfigurationManager.AppSettings["projectCode"].ToString();
                  
                    if (result.IndexOf("true") > 0 && executeStates[0].stateNo == 2 && projectCode == ProjectCodes.JuXingHaiNing)
                    {
                        var logPara = LogType.LogPara("调用巨星WMS接口反馈状态");
                        HH.WMS.Common.Log.Detail(logPara, "result:" + result + ",data.stateNo" + executeStates[0].stateNo.ToString() + ",projectCode:" + projectCode);
                        HH.WMS.Common.Log.Detail(logPara, "调用巨星WebService反馈状态");
                        //更新是否传递给巨星任务完成
                        TN_WM_TASKEntity transportTask = DALCreator.Create<DapperDAL<TN_WM_TASKEntity>>().GetSingleEntity(new { CN_S_TASK_NO = executeStates[0].taskNo });
                        string jxWebUrl = string.Empty;
                        try
                        {
                            jxWebUrl = System.Configuration.ConfigurationManager.AppSettings["jxWebUrl"].ToString();
                        }
                        catch (Exception ep)
                        {

                            HH.WMS.Common.Log.Detail(logPara, "异常：获取webconfig中jxWebUrl配置异常！");
                            return result;
                        }
                      
                        WebServiceAgent jxAgent = new WebServiceAgent(jxWebUrl);
                        object[] para = { "GreatStar", "HNWSRFID", transportTask.CN_S_TRAY_CODE, transportTask.CN_S_END_BIT, "", "hh" };

                        object returnObject = jxAgent.Invoke("SetAGVJobStatus", para);
                        string returnFromJuxing = returnObject.ToString();
         
                        Log.Detail(logPara, "returnFromJuxing:" + returnObject.ToString());
                        //调用巨星接口回报托盘所入货位及库区
                        if (string.IsNullOrEmpty(returnFromJuxing))
                        {
                            DALCreator.Create<DapperDAL<TN_WM_TASKEntity>>().Update(new
                            {
                                CN_S_EXT1 = "Y"
                            }, new
                            {
                                CN_S_TASK_NO = executeStates[0].taskNo
                            }, null);
                            HH.WMS.Common.Log.Detail(logPara, "调用巨星WMS反馈状态返回结果：" + "调用成功");
                        }
                        else
                        {
                            DALCreator.Create<DapperDAL<TN_WM_TASKEntity>>().Update(new
                            {
                                CN_S_EXT1 = "NeedSync"
                            }, new
                            {
                                CN_S_TASK_NO = executeStates[0].taskNo
                            }, null);
                            HH.WMS.Common.Log.Detail(logPara, "调用巨星WMS反馈状态返回结果：" + returnFromJuxing);
                        }
                    }
               
                }
                catch (Exception ex)
                {
                    HH.WMS.Common.Log.Detail(LogType.LogPara("调用巨星WMS接口反馈状态"), "调用巨星WMS反馈状态返回结果：" + ex.Message + ex.StackTrace);
                }
                return result;
            }
            catch (Exception ex)
            {
                return JsonConvert.SerializeObject(new { Success = false, Msg = ex.Message });
            }
            
        }
        
        #endregion
    }
}