using System;
using System.Collections.Generic;
using System.Text;
using System.Reflection;
using System.Data;
using System.IO;
using SiaSun.LMS.Model;
using System.Xml;
using System.Net;
using System.Web.UI.WebControls;
using System.Threading;
using System.Net.Http;
using System.Net.Http.Headers;

namespace SiaSun.LMS.Implement
{
    class S_ERPService : SiaSun.LMS.Implement.S_BaseService, SiaSun.LMS.Interface.I_ERPService
    {
        #region 基础信息

        /// <summary>服务地址
        /// 服务地址
        /// </summary>
        public string _sUrl = string.Empty;

        /// <summary>用户
        /// 用户
        /// </summary>
        private string _sUserName = string.Empty;

        /// <summary>密码
        /// 密码
        /// </summary>
        private string _sUserPsd = string.Empty;

        /// <summary>路径
        /// 路径
        /// </summary>
        public string _sPath;

        /// <summary>方法
        /// 方法
        /// </summary>
        public string _sMethod;

        /// <summary>xml文档
        /// xml文档
        /// </summary>
        public string _sXml;

        #endregion

        public S_ERPService()
        {
            this._sUrl = SiaSun.LMS.Common.StringUtil.GetConfig("ERP");
        }

        //解析传入XML转成DataTable

        private System.Data.DataTable XmlToDataTable(string str)
        {
            XmlTextReader reader = null;
            try
            {
                str = str.Replace("换行符", "\r\n").Replace("~", "/");
                DataSet xmlds = new DataSet();
                StringReader stream = new StringReader(str);
                reader = new XmlTextReader(stream);
                xmlds.ReadXml(reader);

                if (reader != null)
                {
                    reader.Close();
                }

                return xmlds.Tables[0];
            }
            catch (Exception ex)
            {
                if (reader != null)
                {
                    reader.Close();
                }
                return null;
            }

            //StringBuilder sbResult = new StringBuilder();

            //DataTable dt = new DataTable();
            //str = str.Replace("\n", string.Empty);

            ////string[] aStr = str.Replace("&gt;", ">").Replace("&lt;", "<").Replace("<?xml version=\"1.0\" encoding=\"utf-8\"?><root><invokeServiceReturn xsi:type=\"xsd:string\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\">", "").Replace("</invokeServiceReturn></root>", "").Split(new string[] { "</C>" }, StringSplitOptions.None);
            //string[] aStr = str.Replace("&gt;", ">").Replace("&lt;", "<").Replace("<?xml version=\"1.0\" encoding=\"UTF-8\"?>", "").Replace("</invokeServiceReturn></root>", "").Split(new string[] { "</C>" }, StringSplitOptions.None);

            //string sField = string.Empty;

            //string sTmp = string.Empty;

            //int iBegin = 0;

            //int iEnd = 0;

            //int i = 0;

            //foreach (string s in aStr)
            //{
            //    //if (s.IndexOf("<DBSET RESULT=\"0\"></DBSET>") > 0)
            //    //{
            //    //    return dt;
            //    //}

            //    //if (s.IndexOf("<C N=\"SUCCEED_FLAG\">1") > 0)
            //    //{
            //    //    return dt;
            //    //}

            //    iBegin = s.IndexOf("<C N=\"");

            //    if (iBegin < 0)
            //    {
            //        sbResult.Append(s);

            //        continue;
            //    }

            //    iEnd = s.LastIndexOf("\">");

            //    sField = s.Substring(iBegin, iEnd - iBegin);

            //    sField = sField.Replace("<C N=\"", "");

            //    sTmp = s.Replace("<C N=\"", "<");

            //    sTmp = sTmp.Replace("\">", ">");

            //    if (sTmp.Contains("RESULT="))
            //    {
            //        sTmp = sTmp.Replace(sTmp.Substring(sTmp.IndexOf("RESULT="), sTmp.IndexOf("><R><") - sTmp.IndexOf("RESULT=")), "");
            //    }


            //    sbResult.Append(sTmp);

            //    sbResult.Append("</");

            //    sbResult.Append(sField);

            //    sbResult.Append(">");

            //    i++;
            //}

            //dt = new SiaSun.LMS.Common.Xml().GetDataTable_0(sbResult.ToString());

            //return dt;
        }

        public DataTable CreateData(SiaSun.LMS.Model.PLAN_LIST mPLAN_LIST)
        {
            DataTable dataTable = new DataTable(typeof(SiaSun.LMS.Model.PLAN_LIST).Name);

            foreach (PropertyInfo propertyInfo in typeof(SiaSun.LMS.Model.PLAN_LIST).GetProperties())
            {
                dataTable.Columns.Add(new DataColumn(propertyInfo.Name, propertyInfo.PropertyType));
            }

            return dataTable;
        }

        public string getInfo(string IN_XMAL)
        {        
            bool bResult = false;
            string sResult = string.Empty;
            string outpara = string.Empty;

            try
            {
                DataTable dt = this.XmlToDataTable(IN_XMAL);

                if (dt != null && dt.Rows.Count > 0)
                {
                     foreach (DataRow dr in dt.Rows)
                    {
                        SiaSun.LMS.Model.GOODS_MAIN mGOODS_MAIN = new SiaSun.LMS.Model.GOODS_MAIN();
                        mGOODS_MAIN = this._P_GOODS_MAIN.GetModel(dr["equipCode"].ToString());

                        #region 校验

                        if (mGOODS_MAIN == null)
                        {
                            bResult = false;

                            sResult=string.Format("失败，未找到物料编码{0}！",dr["equipCode"]);

                            return sResult;
                        }
                        if (!(mGOODS_MAIN.GOODS_NAME == dr["equipName"].ToString()))
                        {
                            bResult = false;

                            sResult=string.Format("失败，物料名称{0}与基础信息不符！",dr["equipName"]);

                            return sResult;
                        }
                        if (!(dr["equipState"].ToString() == "0"))
                        {
                            bResult = false;

                            sResult = string.Format("失败，物料编码{0}状态故障，任务不执行！", dr["equipCode"].ToString());

                            return sResult;
                        }

                        #endregion

                        if (dr["event"].ToString() == "0")///入库
                        {
                            string num=dr["equipNum"].ToString();

                            if (!(Convert.ToInt32(dr["equipNum"].ToString()) > 0))
                            {
                                bResult = false;

                                sResult = string.Format("失败，物料{0}计划入库数量小于0，任务不执行！", dr["equipCode"].ToString());

                                return sResult;
                            }

                            int _PLAN_ID = 0;

                            Model.PLAN_MAIN mPLAN_MAIN = new Model.PLAN_MAIN();
                            mPLAN_MAIN.PLAN_CREATE_TIME = dr["time"].ToString();
                            mPLAN_MAIN.PLAN_CREATER = "MES";
                            mPLAN_MAIN.PLAN_ID = 0;
                            mPLAN_MAIN.PLAN_STATUS = SiaSun.LMS.Enum.PLAN_STATUS.Waiting.ToString();
                            mPLAN_MAIN.PLAN_FLAG = "0";
                            mPLAN_MAIN.PLAN_TYPE_CODE = "PlanIn";
                            mPLAN_MAIN.PLAN_RELATIVE_ID = 0;

                            Model.PLAN_LIST mPLAN_LIST = new Model.PLAN_LIST();

                            mPLAN_LIST.PLAN_ID = 0;
                            mPLAN_LIST.PLAN_LIST_QUANTITY = Convert.ToInt32(dr["equipNum"].ToString());
                            mPLAN_LIST.PLAN_LIST_ORDERED_QUANTITY = 0;
                            mPLAN_LIST.PLAN_LIST_FINISHED_QUANTITY = 0;
                            mPLAN_LIST.GOODS_ID = mGOODS_MAIN.GOODS_ID;

                            DataTable dtPLAN_LIST = CreateData(mPLAN_LIST);
                            DataRow dataRow = dtPLAN_LIST.NewRow();
                            foreach (PropertyInfo propertyInfo in typeof(SiaSun.LMS.Model.PLAN_LIST).GetProperties())
                            {
                                dataRow[propertyInfo.Name] = propertyInfo.GetValue(mPLAN_LIST, null);
                            }
                            dtPLAN_LIST.Rows.Add(dataRow);

                            object[] outParams = new object[] { };

                            bResult = this.Invoke("PlanBase", "PlanCreate", new object[] { mPLAN_MAIN, dtPLAN_LIST, _PLAN_ID, sResult }, out outParams);

                            sResult = outParams[3].ToString();
                        }
                        else if (dr["event"].ToString() == "1")///出库
                        {
                            string num = dr["equipNum"].ToString();

                            if (!(Convert.ToInt32(dr["equipNum"].ToString()) > 0))
                            {
                                bResult = false;

                                sResult = string.Format("失败，物料{0}计划入库数量小于0，任务不执行！", dr["equipCode"].ToString());

                                return sResult;
                            }

                            int _PLAN_ID = 0;

                            Model.PLAN_MAIN mPLAN_MAIN = new Model.PLAN_MAIN();
                            mPLAN_MAIN.PLAN_CREATE_TIME = dr["time"].ToString();
                            mPLAN_MAIN.PLAN_CREATER = "MES";
                            mPLAN_MAIN.PLAN_ID = 0;
                            mPLAN_MAIN.PLAN_STATUS = SiaSun.LMS.Enum.PLAN_STATUS.Waiting.ToString();
                            mPLAN_MAIN.PLAN_FLAG = "0";
                            mPLAN_MAIN.PLAN_TYPE_CODE = "PlanOut";
                            mPLAN_MAIN.PLAN_RELATIVE_ID = 0;

                            Model.PLAN_LIST mPLAN_LIST = new Model.PLAN_LIST();

                            mPLAN_LIST.PLAN_ID = 0;
                            mPLAN_LIST.PLAN_LIST_QUANTITY = Convert.ToInt32(dr["equipNum"].ToString());
                            mPLAN_LIST.PLAN_LIST_ORDERED_QUANTITY = 0;
                            mPLAN_LIST.PLAN_LIST_FINISHED_QUANTITY = 0;
                            mPLAN_LIST.GOODS_ID = mGOODS_MAIN.GOODS_ID;

                            List<PLAN_LIST> lmPLAN_LIST = new List<PLAN_LIST>();

                            lmPLAN_LIST.Add(mPLAN_LIST);

                            DataTable dtPLAN_LIST = CreateData(mPLAN_LIST);

                            DataRow dataRow = dtPLAN_LIST.NewRow();
                            foreach (PropertyInfo propertyInfo in typeof(SiaSun.LMS.Model.PLAN_LIST).GetProperties())
                            {
                                dataRow[propertyInfo.Name] = propertyInfo.GetValue(mPLAN_LIST, null);
                            }
                            dtPLAN_LIST.Rows.Add(dataRow);

                            object[] outParams = new object[] { };

                            bResult = this.Invoke("PlanBase", "PlanCreate", new object[] { mPLAN_MAIN, dtPLAN_LIST, _PLAN_ID, sResult }, out outParams);

                            sResult = outParams[3].ToString();
                        }
                        else
                        {
                            bResult = false;

                            sResult = string.Format("失败，任务状态{0}输入有误，任务不执行！", dr["enent"].ToString());

                            return sResult;
                        }                  
                    }
                }
                else
                {
                    bResult = false;

                    sResult = "失败，未得到数据！";

                }
                
            }
            catch (Exception ex)
            {
                bResult = false;

                sResult = "处理MES传入的参数错误" + ex.Message;
            }

            if (bResult == true)
            {
                sResult = "计划录入成功！";
            }

            return sResult;
        }


        public bool HttpPost( string JsonParas, out string sResult)
        {
            string _SapUrl ="http://192.168.181.39/api/yunhai/wms/stock/score";

           // string strURL =  "";

            sResult = string.Empty;

            bool bResult = true;
            //创建一个HTTP请求  
            HttpWebRequest request;

            HttpWebResponse resp;
            #region
            //Authorization auth;

            // Dictionary<string, string> s = new Dictionary<string, string>();

            // //s.Add("TOKEN", "hQeB+Y442Uk=");

            //// s.Add("actionmethod", MethodName);

            // s.Add("parms", JsonParas);

            //jsonParas = "TOKEN=42A+o0BDiq8=&actionmethod=/WSO2/RequestDemo&JSONSTR=" + jsonParas;
            #endregion
            try
            {
                request = (HttpWebRequest)WebRequest.Create(_SapUrl);

                request.Proxy = null;

             // request.Headers.Add("ContentType", "application/json");

                //Post请求方式  
                request.Method = "POST";

                request.Timeout = 8000;
      
                //内容类型
             // request.ContentType = "application/x-www-form-urlencoded";
                request.ContentType = "application/json";


                //using (HttpClient httpClient = new HttpClient())
                //{
                //    httpClient.Timeout = Timeout;
                //    using (HttpRequestMessage request = new HttpRequestMessage(new HttpMethod("Post"), uri))
                //    {
                //        request.Headers.TryAddWithoutValidation("User-Agent", "Warehouse Management System");
                //        request.Headers.TryAddWithoutValidation("Content-Type", "application/json");
                //        request.Content = new StringContent(body, Encoding.UTF8);
                //        request.Content.Headers.ContentType = MediaTypeHeaderValue.Parse("application/json");
                //        content = httpClient.SendAsync(request).Result.Content.ReadAsStringAsync().Result;
                //    }
                //}
               
                #region
                //int i = 0;

                //StringBuilder builder = new StringBuilder();

                //foreach (var item in s)
                //{
                //    if (i > 0)
                //        builder.Append("&");
                //    builder.AppendFormat("{0}={1}", item.Key, item.Value);
                //    i++;
                //}

                //string strDecrypt = builder.ToString();

                //strDecrypt = strDecrypt.Replace("+","%2B");

                #endregion

                //string paraUrlCoded = System.Web.HttpUtility.UrlEncode("parms");
                //paraUrlCoded += "=" + System.Web.HttpUtility.UrlEncode(JsonParas);

                //byte[] payload = Encoding.UTF8.GetBytes(JsonParas);
               byte[] payload = Encoding.UTF8.GetBytes(JsonParas);

               request.ContentLength = payload.Length;

                using (Stream reqStream = request.GetRequestStream())
                {
                    reqStream.Write(payload, 0, payload.Length);

                    reqStream.Close();
                }
                //HttpWebResponse response = (HttpWebResponse)request.GetResponse();
                //if (response.StatusCode == HttpStatusCode.OK)
                //{
                //    Stream responseStream = response.GetResponseStream();
                //    StreamReader myStreamReader = new StreamReader(responseStream);
                //    sResult = myStreamReader.ReadToEnd();
                //}
                //response.Close();
                resp = (HttpWebResponse)request.GetResponse();

                Stream stream = resp.GetResponseStream();

                //获取响应内容
                using (StreamReader reader = new StreamReader(stream))
                {
                    sResult = reader.ReadToEnd();

                    reader.Close();
                }


            }
            catch (Exception ex)
            {
                sResult = ex.Message.ToString();
                bResult = false;
            }

            return bResult;
        }


        /// <summary>
        /// 查询极卷信息zupan
        /// </summary>
        /// <param name="labelNumber">标签号</param>
        public bool MesRetry(string strRequest, out string sResult)
        {
            bool bResult = false;
            sResult = string.Empty;
            SiaSun.LMS.Common.Log log = new Common.Log();
            //_sUsername = SiaSun.LMS.Common.StringUtil.GetConfig("wsUserName");
            //_sPassword = SiaSun.LMS.Common.StringUtil.GetConfig("wsPassword");

            try
            {
                bResult=this.HttpPost(strRequest, out sResult);
                if (!bResult)
                {
                    sResult = "调用接口报错信息：" + sResult + ":联系维护人员查看问题后再进行重发";
                    bResult = false;
                }
                else
                {
                    #region 日志
                    Model.MES_INTERFACE_LOG mMES_INTERFACE_LOG = new Model.MES_INTERFACE_LOG();
                    mMES_INTERFACE_LOG.INTERFACE = "MesRetry";
                    mMES_INTERFACE_LOG.IN_MESSAGE = strRequest;
                    mMES_INTERFACE_LOG.OUT_MESSAGE = sResult;
                    mMES_INTERFACE_LOG.SENDER = "WMS";
                    mMES_INTERFACE_LOG.RECEIVER = "MES";
                    mMES_INTERFACE_LOG.TIME_STAMP = Common.StringUtil.GetDateTime();
                    this._P_MES_INTERFACE_LOG.Add(mMES_INTERFACE_LOG);
                    #endregion
                }
                //HeaderDetailOut response = new HeaderDetailOut();
                //response= Newtonsoft.Json.JsonConvert.DeserializeObject<HeaderDetailOut>(sResult);

                //if (response.IsSuccess.Equals("0"))
                //{
                //    sResult = "接口重发失败";
                //    return bResult;
                //}
            }
            catch (Exception ex)
            {
                //HostLog.Error("QueryPolarcoilInfo-" + ex);
                log.SaveLog(ex.Message);

            }
            //#region 日志
            //Model.MES_INTERFACE_LOG mMES_INTERFACE_LOG = new Model.MES_INTERFACE_LOG();
            //mMES_INTERFACE_LOG.INTERFACE = "MesRetry";
            //mMES_INTERFACE_LOG.IN_MESSAGE = strRequest;
            //mMES_INTERFACE_LOG.OUT_MESSAGE = sResult;
            //mMES_INTERFACE_LOG.SENDER = "WMS";
            //mMES_INTERFACE_LOG.RECEIVER = "MES";
            //mMES_INTERFACE_LOG.TIME_STAMP = Common.StringUtil.GetDateTime();
            //this._P_MES_INTERFACE_LOG.Add(mMES_INTERFACE_LOG);
            //#endregion
            return bResult;
        }

        ///// <summary>
        ///// 客户端查传递物料主数据
        ///// </summary>
        ///// <param name="labelNumber">标签号</param>
        //public bool GoodsDataToBaili(string producttype, out string sResult)
        //{
        //    bool bResult = false;
        //    sResult = string.Empty;
        //    SiaSun.LMS.Common.Log log = new Common.Log();
        //    //_sUsername = SiaSun.LMS.Common.StringUtil.GetConfig("wsUserName");
        //    //_sPassword = SiaSun.LMS.Common.StringUtil.GetConfig("wsPassword");

        //    //MaterialInfo hic = new MaterialInfo();
        //    //hic.productItems = new productItems[1];
        //    //hic.productItems[0] = new productItems();

        //    RESPONST_TO_BAILIMES baili = new RESPONST_TO_BAILIMES();
        //    baili.content = new Content[1];
        //    baili.content[0] = new Content();
        //    try
        //    {
        //        IList<GOODS_MAIN> lstgoods = this._P_GOODS_MAIN.GetList();
        //        foreach (GOODS_MAIN gds in lstgoods)
        //        {
        //            //百利 原材料
        //            baili.content[0].ProductType = "01";
        //            baili.content[0].MaterialCodification = gds.GOODS_CODE;
        //            baili.content[0].Name = gds.GOODS_NAME;
        //            baili.content[0].Specification = gds.GOODS_CONST_PROPERTY1;
        //            baili.content[0].UnitID = gds.GOODS_UNITS;
        //            baili.content[0].PartNo = gds.GOODS_CONST_PROPERTY3;
        //            baili.content[0].Status = "有效";

        //            //原材料 琥崧
        //            //hic.productItems[0].productType = "物料";
        //            //hic.productItems[0].materialCodification = gds.GOODS_CODE;
        //            //hic.productItems[0].name = gds.GOODS_NAME;
        //            //hic.productItems[0].specification = gds.GOODS_CONST_PROPERTY1;
        //            //hic.productItems[0].code = gds.GOODS_CONST_PROPERTY2;
        //            //hic.productItems[0].partNo = gds.GOODS_CONST_PROPERTY3;
        //            //hic.productItems[0].supplierPartNo = gds.GOODS_CONST_PROPERTY4;

        //            //if (S_ERPService.Post($"{HusongUrl}syncProductItems", Common.JsonHelper.Serializer(hic), out string cont))
        //            //{
        //            //    HusongResponseData data = Common.JsonHelper.Deserialize<HusongResponseData>(cont);
        //            //  if (data != null && (data.success==true))
        //            //  {
        //            //      sResult += $"推送琥崧成品入库成功\n";
        //            //  }
        //            //  else
        //            //  {
        //            //      bResult = false;
        //            //     sResult += $"推送琥崧成品入库失败 {(data != null && !string.IsNullOrWhiteSpace(data.msg) ? data.msg : cont)}\n";
        //            //  }
        //            //}
        //            //else
        //            //{
        //            //  bResult = false;
        //            //  sResult += $"推送佰利成品入库异常\n";
        //            //}
        //            if (S_ERPService.Post($"{BailiUrl}saveMaterialInfo", Common.JsonHelper.Serializer(baili), out string cont))
        //            {
        //                BailiResponseData data = Common.JsonHelper.Deserialize<BailiResponseData>(cont);
        //                if (data != null && (data.code.Equals("200")))
        //                {
        //                    sResult += $"推送百利物料数据成功\n";
        //                }
        //                else
        //                {
        //                    bResult = false;
        //                    sResult += $"推送百利物料数据失败 {(data != null && !string.IsNullOrWhiteSpace(data.message) ? data.message : cont)}\n";
        //                }
        //            }
        //            else
        //            {
        //                bResult = false;
        //                sResult += $"推送百利物料数据异常\n";
        //            }


        //        }
        //    }
        //    catch (Exception ex)
        //    {
        //        //HostLog.Error("QueryPolarcoilInfo-" + ex);
        //        log.SaveLog(ex.Message);

        //    }

        //    return bResult;
        //}

        public static bool Post(string uri, string body, out string content)
        {
            try
            {
                using (HttpClient httpClient = new HttpClient())
                {
                    //TimeSpan timeout = DateTime.Now;
                    //httpClient.Timeout = Timeout;
                    using (HttpRequestMessage request = new HttpRequestMessage(new HttpMethod("Post"), uri))
                    {
                        request.Headers.TryAddWithoutValidation("User-Agent", "Warehouse Management System");
                        request.Headers.TryAddWithoutValidation("Content-Type", "application/json");
                        request.Content = new StringContent(body, Encoding.UTF8);
                        request.Content.Headers.ContentType = MediaTypeHeaderValue.Parse("application/json");
                        content = httpClient.SendAsync(request).Result.Content.ReadAsStringAsync().Result;
                    }
                }
            }
            catch (Exception ex)
            {
                content = $"异常 {ex.Message}";
                return false;
            }
            return true;
        }

        /// <summary>
        /// 根据MES组盘，暂存区
        /// </summary>
        /// <param name="json"></param>
        /// <param name="body"></param>
        /// <param name="content"></param>
        /// <returns></returns>
        public bool MesInfo(string json, out string sResult)
        { 
            bool bResult = false;
            sResult = string.Empty;
            ManageIn manageIn = new ManageIn();

            SiaSun.LMS.Model.MANAGE_MAIN mMANAGE_MAIN = null;

            SiaSun.LMS.Model.MANAGE_LIST mMANAGE_LIST = null;

            List<SiaSun.LMS.Model.MANAGE_LIST> lsMANAGE_LIST = new List<SiaSun.LMS.Model.MANAGE_LIST>();
            #region 生成MANAGE_MAIN
            //生成暂存区库存
            mMANAGE_MAIN = new Model.MANAGE_MAIN();

            mMANAGE_MAIN.PLAN_ID = 0;

            mMANAGE_MAIN.PLAN_TYPE_CODE = string.Empty;

            mMANAGE_MAIN.MANAGE_TYPE_CODE = SiaSun.LMS.Enum.MANAGE_TYPE.ManageMove.ToString();

            mMANAGE_MAIN.MANAGE_STATUS = SiaSun.LMS.Enum.MANAGE_STATUS.Waiting.ToString();

            mMANAGE_MAIN.STOCK_BARCODE = "ABC1070402001093";

          //  mMANAGE_MAIN.FULL_FLAG = mSTORAGE_MAIN.FULL_FLAG;

            mMANAGE_MAIN.CELL_MODEL = "0";

            mMANAGE_MAIN.START_CELL_ID =0;

            mMANAGE_MAIN.END_CELL_ID = 0;

            mMANAGE_MAIN.MANAGE_OPERATOR = "MES";

            mMANAGE_MAIN.MANAGE_BEGIN_TIME = SiaSun.LMS.Common.StringUtil.GetCurDateTimeString();

            #endregion

            #region 生成MANAGE_LIST

             mMANAGE_LIST = new Model.MANAGE_LIST();

             mMANAGE_LIST.GOODS_ID = 910;

             mMANAGE_LIST.PLAN_LIST_ID = 0;

             mMANAGE_LIST.STORAGE_LIST_ID = 0;

             mMANAGE_LIST.MANAGE_LIST_QUANTITY =1;

             mMANAGE_LIST.MANAGE_LIST_REMARK ="";
             mMANAGE_LIST.GOODS_PROPERTY6 = "未翻转";

           lsMANAGE_LIST.Add(mMANAGE_LIST);

            bResult= manageIn.ManageCreate(mMANAGE_MAIN, lsMANAGE_LIST,true,true,false, out sResult);

            #endregion
            //条码作为托盘码，物料码从中截取

            bResult = this.ApplyIn(mMANAGE_MAIN.STOCK_BARCODE, out sResult, out string lany_way);
            return bResult;
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="json"></param>
        /// <param name="body"></param>
        /// <param name="content"></param>
        /// <returns></returns>
        public bool ApplyIn(string stock_barcode, out string sResult, out string lane_way)
        {
            bool bResult = false;
            sResult=string.Empty;
            int end_cell_id = 0;
            Common.Log log = new Common.Log();
       
            lane_way = "2";
            //物料码转托盘码
            string good_code = stock_barcode.Substring(3,12);
            //查翻转机构库存，CELL_LOGICAL_NAME是FZ就是翻转货位
            string sqlfz = string.Format("select * from wh_cell where cell_status='Nohave' and run_status='Enable' and  CELL_LOGICAL_NAME = 'FZ'", stock_barcode);
            DataTable dtfz = this.GetList(sqlfz);
            #region 查管理和调度任务
            //查管理任务
            string sql4 = string.Format("select * from manage_main where stock_barcode='{0}'", stock_barcode);
            DataTable dt4 = this.GetList(sql4);
            //查调度任务
            string sql5 = string.Format("select * from io_control where stock_barcode='{0}'", stock_barcode);
            DataTable dt5 = this.GetList(sql5);
            #endregion
            #region 查CELL_ID
            ///查暂存区CELL_ID
            string sql6 = string.Format("SELECT CELL_ID FROM WH_CELL WHERE CELL_CODE = 'zcq'");
            DataTable dt6 = this.GetList(sql6);
            ///查CELL_ID
            string sql7 = string.Format("SELECT CELL_ID FROM WH_CELL WHERE CELL_CODE = '{0}'", "12001");
            DataTable dt7 = this.GetList(sql7);
            #endregion
            string strSQL = string.Format(@"SELECT *   FROM WH_CELL  WHERE 1=1  AND CELL_STATUS = 'Nohave'and cell_type='cell' and area_id=1
                                                 AND RUN_STATUS = 'Enable' ORDER BY CELL_X,CELL_Y,CELL_Z");

            DataTable dtCELL = base.GetList(strSQL);

            if (dtCELL.Rows.Count <=0)
            {       
                bResult = false;

                sResult = string.Format("可用货位不足");

                return bResult;
            }
            lane_way = dtCELL.Rows[0]["LANE_WAY"].ToString();
            ManageIn manageIn = new ManageIn();
               ///上报高度
              ///  CELL_MODEL = "0";
                //有管理和控制任务不能入库
                if (dt4.Rows.Count > 0 || dt5.Rows.Count > 0)
                {
                    bResult = false;

                    sResult = string.Format("托盘条码[{0}]存在未完成的任务！", stock_barcode);

                    return bResult;
                }

                //判断翻转是否有可用货位
                if (dtfz.Rows.Count <= 0)
                {
                    //入到正常货位里面,logic_area=0传入，实际是用CELL_LOGIC_NAME来找的翻转货位，CELL表里面用CELL_LOGIC_NAME为FZ标记翻转货位,
                    bResult = new ManageUp().ManageCreate(stock_barcode.TrimEnd(), Convert.ToInt32(dt7.Rows[0]["CELL_ID"].ToString()), end_cell_id, "0", "0", true, true, "SYS", out sResult);
                    log.SaveLog("MES调用入库："+sResult);
                    return bResult;

                }
                else
                {
                    //入到反转货位里面 logic_area='FZ'，传入，实际是用CELL_LOGIC_NAME来找的翻转货位，CELL表里面用CELL_LOGIC_NAME为FZ标记翻转货位
                    bResult = new ManageUp().ManageCreate(stock_barcode.TrimEnd(), Convert.ToInt32(dt7.Rows[0]["CELL_ID"].ToString()), end_cell_id, "0", "FZ", true, true, "SYS", out sResult);
                    log.SaveLog("MES调用入库：" + sResult);
                    return bResult;
                    #region \\控制任务 暂时用不上
                    //SiaSun.LMS.Model.IO_CONTROL mIO_CONTROL = new SiaSun.LMS.Model.IO_CONTROL();
                    //mIO_CONTROL.RELATIVE_CONTROL_ID = -1;
                    //mIO_CONTROL.MANAGE_ID = 0;
                    //mIO_CONTROL.STOCK_BARCODE = mIO_CONTROL_APPLY.STOCK_BARCODE;
                    //mIO_CONTROL.CONTROL_TASK_LEVEL = "0";
                    //mIO_CONTROL.PRE_CONTROL_STATUS = string.Empty;
                    //mIO_CONTROL.CONTROL_TASK_TYPE = 4;
                    //mIO_CONTROL.START_DEVICE_CODE = mIO_CONTROL_APPLY.DEVICE_CODE;
                    //mIO_CONTROL.END_DEVICE_CODE = "12101";
                    //mIO_CONTROL.CONTROL_BEGIN_TIME = SiaSun.LMS.Common.StringUtil.GetDateTime();

                    //mIO_CONTROL.CONTROL_STATUS = 0;
                    //mIO_CONTROL.START_WAREHOUSE_CODE = "1";
                    //mIO_CONTROL.END_WAREHOUSE_CODE = "1";

                    //mIO_CONTROL.ERROR_TEXT = "";

                    //this._P_IO_CONTROL.Add(mIO_CONTROL);
                    #endregion
                }

           // return bResult;
        }


    }
}