using HH.Redis.ReisModel;
using HH.WMS.BLL;
using HH.WMS.BLL.Algorithm;
using HH.WMS.BLL.External;
using HH.WMS.BLL.InStock;
using HH.WMS.BLL.MoveStock;
using HH.WMS.BLL.SysMgr;
using HH.WMS.Common;
using HH.WMS.Common.Algorithm;
using HH.WMS.Common.External;
using HH.WMS.Common.Para;
using HH.WMS.Common.Response;
using HH.WMS.DAL;
using HH.WMS.DAL.Algorithm;
using HH.WMS.DAL.Basic;
using HH.WMS.DAL.InStock;
using HH.WMS.Entitys;
using HH.WMS.Entitys.Basic;
using HH.WMS.Entitys.Entitys;
using HH.WMS.Entitys.External;
using HH.WMS.Entitys.MoveStock;
using HH.WMS.TaskService.Dto;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;

namespace HH.WMS.TaskService.Jobs
{
    /// <summary>
    /// 巨星同步数据（货位、托盘）Job
    /// </summary>
    public class JxSyncDataJob
    {
        private readonly LockDto _lockDto = new LockDto { IsLock = false };

        public void Run()
        {

            var logPara = LogType.LogPara("巨星同步数据");
            if (_lockDto.IsLock)
            {
                Log.Detail(logPara, "当前同步数据任务正在被锁定，还存在未执行结束的任务");
                return;
            }
            _lockDto.Lock("");
            try
            {
                SyncDataTask(logPara);
            }
            catch (Exception ex)
            {
                Log.Detail(logPara, "异常：" + ex.Message);

            }
            _lockDto.Unlock();
        }



        //获取移库管理中未执行的数据，只取一条，且将状态变为执行中
        private void SyncDataTask(LogPara logPara)
        {

            List<TN_WM_TASKEntity> lstTasks = BLLCreator.Create<TN_WM_TASKBLL>().GetTask(" AND CN_S_EXT1 = 'NeedSync' ");
            if (lstTasks.Count == 0)
            {
                Log.Detail(logPara, "当前没有需要执行的同步数据！");
                return;
            }
            else
            {

                foreach (TN_WM_TASKEntity entity in lstTasks)
                {

                    JXJobReference.WebServiceSoapClient jxService = new JXJobReference.WebServiceSoapClient();
                    string returnFromJuxing = jxService.SetAGVJobStatus("GreatStar", "HNWSRFID", entity.CN_S_TRAY_CODE, entity.CN_S_END_BIT, "", "");

                    //调用巨星接口回报托盘所入货位及库区
                    if (string.IsNullOrEmpty(returnFromJuxing))
                    {
                        DALCreator.Create<DapperDAL<TN_WM_TASKEntity>>().Update(new
                        {
                            CN_S_EXT1 = "Y"
                        }, new
                        {
                            CN_S_TASK_NO = entity.CN_S_TASK_NO
                        }, null);
                        Log.Detail(logPara, "调用巨星WMS返回结果：" + "调用成功");
                    }
                }
            }

        }

        private void MoveTrayFromTmpArea(LogPara logPara)
        {
            List<AutoBomStockAreaEntity> lstArea = DALCreator.Create<TN_WMS_AREADAL>().GetAreaCodeByClass("缓存区");
            if (lstArea.Count == 0)
            {
                return;
            }
            List<outAssignLocation> lstCanOutL = DALCreator.Create<Out_AlgorDAL>().GetAssignFlatItemQtyJX(lstArea[0].CN_S_AREA_CODE);
            List<AutoBomLocationAbbreEntity> lstTrueLocation = DALCreator.Create<TN_WMS_LOCATIONDAL>().GetLocationByLocationCode(lstCanOutL.Select(o => o.locationCode).ToList());
            lstCanOutL = lstCanOutL.Join(lstTrueLocation, u => u.locationCode, d => d.CN_S_LOCATION_CODE, (u, d) => new { u, d }).Select(o => new outAssignLocation
            {
                trayCode = o.u.trayCode,
                locationCode = o.u.locationCode,
                stockAreaCode = o.u.stockAreaCode,
                useState = o.u.useState,
                opTime = o.u.opTime,
                productDate = o.u.productDate,
                lotNo = o.u.lotNo,
                CN_S_STOCK_CODE = o.d.CN_S_STOCK_CODE,
                CN_S_ROADWAY = o.d.CN_S_ROADWAY,
                CN_S_ROW = o.d.CN_S_ROW,
                CN_S_COL = o.d.CN_S_COL,
                CN_S_FLOOR = o.d.CN_S_FLOOR,
                CN_S_LOCATION_STATE = o.d.CN_S_LOCATION_STATE
            }).ToList();
            List<TN_WM_LOCATIONCODE_EXT_Entity> locationInLock = DALCreator.Create<TN_WM_LOCATION_EXTDAL>().GetLockLocationByState("", lstArea[0].CN_S_AREA_CODE, null, Constants.Location_State_InLock);
            Log.AlgorInfo("OutAssign-FlatAreaOutLocation", "locationInLock数据:" + JsonConvert.SerializeObject(locationInLock));
            foreach (TN_WM_LOCATIONCODE_EXT_Entity lEntity in locationInLock)
            {
                lstCanOutL.RemoveAll(o => o.CN_S_ROW == lEntity.CN_S_ROW && o.CN_S_COL == lEntity.CN_S_COL);
            }
            lstCanOutL = lstCanOutL.OrderBy(o => o.CN_S_ROW).ThenByDescending(a => a.CN_S_COL).ToList();
            string jxWebUrl = string.Empty;
            foreach (outAssignLocation outAL in lstCanOutL)
            {
                InWorkAreaEntity inWorkAreaEntity = new InWorkAreaEntity();
                inWorkAreaEntity.trayCode = outAL.trayCode;
                inWorkAreaEntity.startBit = outAL.locationCode;
                inWorkAreaEntity.locationGear = "";
                inWorkAreaEntity.endArea = "";
                inWorkAreaEntity.endBit = "";
                inWorkAreaEntity.isTransport = "Y";
                inWorkAreaEntity.needCreateAMSTask = "Y";
                List<InWorkAreaEntity> lstInWork = new List<InWorkAreaEntity>();
                lstInWork.Add(inWorkAreaEntity);
                //调用巨星接口获取入库库区
                DataSet ds = new DataSet();
                string clientKey1 = string.Empty;
                string clientKey2 = string.Empty;
                //调用巨星接口获取托盘入库库区
                try
                {
                    try
                    {
                        jxWebUrl = System.Configuration.ConfigurationManager.AppSettings["jxWebUrl"].ToString();
                    }
                    catch (Exception ep)
                    {
                        ExternalResponse eResponse = new ExternalResponse { success = false, errMsg = "异常：获取webconfig中jxWebUrl配置异常！" + ep.Message };
                        Log.Detail(logPara, "InWorkArea接口返回结果：" + JsonConvert.SerializeObject(eResponse));
                        return;
                    }
                    try
                    {
                        clientKey1 = System.Configuration.ConfigurationManager.AppSettings["clientKey1"].ToString();
                    }
                    catch (Exception ep)
                    {
                        ExternalResponse eResponse = new ExternalResponse { success = false, errMsg = "异常：获取webconfig中clientKey1配置异常！" + ep.Message };
                        Log.Detail(logPara, "InWorkArea接口返回结果：" + JsonConvert.SerializeObject(eResponse));
                        return;
                    }
                    try
                    {
                        clientKey2 = System.Configuration.ConfigurationManager.AppSettings["clientKey2"].ToString();
                    }
                    catch (Exception ep)
                    {
                        ExternalResponse eResponse = new ExternalResponse { success = false, errMsg = "异常：获取webconfig中clientKey2配置异常！" + ep.Message };
                        Log.Detail(logPara, "InWorkArea接口返回结果：" + JsonConvert.SerializeObject(eResponse));
                        return;
                    }
                    WebServiceAgent jxAgent = new WebServiceAgent(jxWebUrl);
                    object[] para = { clientKey1, clientKey2, "AGV", inWorkAreaEntity.trayCode, "", "I", "N", null, null };
                    Log.Detail(logPara, "调用巨星接口获取托盘入库库区输入参数：" + JsonConvert.SerializeObject(para));
                    object returnObject = jxAgent.Invoke("GetJobDetail", para);
                    ds = (DataSet)returnObject;
                    Log.Detail(logPara, "调用巨星接口获取托盘入库库区：" + JsonConvert.SerializeObject(ds));
                    if (ds.Tables[0].Rows.Count == 0)
                    {
                        ExternalResponse eResponse = new ExternalResponse { success = false, errMsg = string.Format("托盘号{0}调用巨星WMS的GetJobDetail未获取到数据！", inWorkAreaEntity.trayCode) };
                        Log.Detail(logPara, "InWorkArea接口返回结果：" + JsonConvert.SerializeObject(eResponse));
                        return;
                    }
                    object[] para1 = { clientKey1, clientKey2, ds.Tables[0].Rows[0]["TrnSeqNo"].ToString(), inWorkAreaEntity.trayCode, "", "80", "8", "hh" };
                    Log.Detail(logPara, "调用巨星接口SetAGVJobStatus输入参数：" + JsonConvert.SerializeObject(para1));
                    object returnObject1 = jxAgent.Invoke("SetAGVJobStatus", para);
                    // HH.WMS.JX.JXWMSServices.WebServiceSoapClient jxServices = new JX.JXWMSServices.WebServiceSoapClient();
                    // jxServices.SetAGVJobStatus("GreatStar", "HNWSRFID", transportTask.CN_S_TRAY_CODE, transportTask.CN_S_END_BIT, "", "");
                    Log.Detail(logPara, "returnFromJuxing,SetAGVJobStatus,8:" + returnObject1.ToString());
                }
                catch (Exception ex)
                {
                    ExternalResponse eResponse = new ExternalResponse { success = false, errMsg = string.Format("调用巨星WMS的GetJobDetail接口异常：{0}！", ex.Message) };
                    Log.Detail(logPara, "InWorkArea接口返回结果：" + JsonConvert.SerializeObject(eResponse));
                    return;
                }
                if (string.IsNullOrEmpty(inWorkAreaEntity.endBit))
                {
                    inWorkAreaEntity.endArea = ds.Tables[0].Rows[0]["ToAreaCode"].ToString();
                    inWorkAreaEntity.remark = ds.Tables[0].Rows[0]["TrnSeqNo"].ToString();
                }
                else
                {
                    inWorkAreaEntity.remark = ds.Tables[0].Rows[0]["TrnSeqNo"].ToString();
                }
                string needCreateAMSTask = string.Empty;
                try
                {
                    needCreateAMSTask = System.Configuration.ConfigurationManager.AppSettings["needCreateAMSTask"].ToString();
                }
                catch (Exception ep)
                {
                    ExternalResponse eResponse = new ExternalResponse { success = false, errMsg = "异常：获取webconfig中needCreateAMSTask配置异常！" + ep.Message };
                    Log.Detail(logPara, "InWorkArea接口返回结果：" + JsonConvert.SerializeObject(eResponse));
                    return;
                }
                inWorkAreaEntity.needCreateAMSTask = needCreateAMSTask;
                List<InWorkAreaEntity> inWorkAreaEntitys = new List<InWorkAreaEntity>();
                inWorkAreaEntitys.Add(inWorkAreaEntity);
                ExternalResponse resultJX = BLLCreator.Create<WmsApiForJxhnBLL>().InWorkAreaJX(inWorkAreaEntitys);
                try
                {
                    if (resultJX.success)
                    {
                        Log.Detail(logPara, "调用巨星WebService接口反馈托盘搬运货位异动");
                        //更新是否传递给巨星任务完成     
                        WebServiceAgent jxAgent = new WebServiceAgent(jxWebUrl);
                        object[] para = { clientKey1, clientKey2, inWorkAreaEntitys[0].remark, resultJX.okList[0].trayCode, resultJX.okList[0].startBit, "", "I", "hh" };
                        object returnObject = jxAgent.Invoke("SetLocation", para);
                    }
                }
                catch (Exception ex)
                {
                    Log.Detail(LogType.LogPara("调用巨星WMS接口反馈状态"), "调用巨星WMS接口反馈托盘搬运货位异动：" + ex.Message + ex.StackTrace);
                }
                string result = JsonConvert.SerializeObject(resultJX);
                if (result.IndexOf("false") > 0)
                {
                    break;
                }
            }
        }

    }
}