using HH.WMS.BLL;
using HH.WMS.Common;
using HH.WMS.DAL.CoreServer;
using HH.WMS.Entitys;
using HH.WMS.Entitys.Algorithm;
using HH.WMS.Entitys.Basic;
using HH.WMS.Entitys.Common;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace HH.WMS.BLL.CoreServer
{
    public class BasicDataBLL : BaseBLL
    {
        public DataTable GetInventoryData()
        {
            return CreateDAL<BasicDataDAL>().GetInventoryData();
        }

        public DataTable GetWarehouseData()
        {
            return CreateDAL<BasicDataDAL>().GetWarehouseData();
        }

        public DataTable GetCustomerData()
        {
            return CreateDAL<BasicDataDAL>().GetCustomerData();
        }

        public DataTable GetVendnrData()
        {
            return CreateDAL<BasicDataDAL>().GetVendnrData();
        }

        public SqlExecuteResult UpdateInventoryCheckState(List<PLM_itemEntity> itemEntityList)
        {
            return CreateDAL<BasicDataDAL>().UpdateInventoryCheckState(itemEntityList);
        }

        public SqlExecuteResult UpdateWarehouseCheckState(List<TN_AB_STOCKEntity> stockEntityList)
        {
            return CreateDAL<BasicDataDAL>().UpdateWarehouseCheckState(stockEntityList);
        }

        public SqlExecuteResult UpdateCustomerCheckState(List<PLM_CusEntity> customEntityList)
        {
            return CreateDAL<BasicDataDAL>().UpdateCustomerCheckState(customEntityList);
        }

        public SqlExecuteResult UpdateVendnrCheckState(List<PLM_VenEntity> vendnrEntityList)
        {
            return CreateDAL<BasicDataDAL>().UpdateVendnrCheckState(vendnrEntityList);
        }

        /// <summary>
        /// 调用autobom接口 保存item信息
        /// </summary>
        /// <param name="itemEntityList"></param>
        /// <returns></returns>
        public AutobomResult AddList(List<PLM_itemEntity> itemEntityList)
        {
            string result = WebApiManager.HttpAutoBom_Post("Api/PLM/ItemRelease", JsonConvert.SerializeObject(itemEntityList));

            List<AutobomResult> autobomRes = JsonConvert.DeserializeObject<List<AutobomResult>>(result);

            return autobomRes[0];
        }

        public OperateResult DataCompare()
        {
            OperateResult sqlResult = new OperateResult();

            //获取U8现有量
            List<U8RebackData> u8RebackData = CreateDAL<BasicDataDAL>().GetStockData();

            //获取wms仓库量表
            string stockStr = WebApiManager.HttpWMS_Get("api/AreaQty/GetStockQty");
            OperateResult or = JsonConvert.DeserializeObject<OperateResult>(stockStr);
            List<TN_WM_B_STOCK_QTYEntity> stockQtyList = JsonConvert.DeserializeObject<List<TN_WM_B_STOCK_QTYEntity>>(or.Data.ToString());

            foreach (var item in u8RebackData)
            {
                string outState = InIHelper.ReadConfig<string>("SS", item.cWhCode);
                item.itemState = outState;
            }
            List<TN_WM_STOCKQTY_COMPAREEntity> stockQtyCom = new List<TN_WM_STOCKQTY_COMPAREEntity>();
            foreach (var item in u8RebackData)
            {
                TN_WM_STOCKQTY_COMPAREEntity comEntity = new TN_WM_STOCKQTY_COMPAREEntity();
                comEntity.CN_GUID = System.Guid.NewGuid().ToString().ToUpper();

                var comResult = stockQtyList.Where(x => x.CN_S_ITEM_CODE == item.cInvCode &&
                                                        x.CN_S_ITEM_STATE == item.itemState &&
                                                        x.CN_S_PRODUCTION_BATCH == item.cBatch).ToList();
                comEntity.CN_S_ITEM_CODE = item.cInvCode;
                comEntity.CN_S_ITEM_NAME = item.cInvName;
                comEntity.CN_S_MEASURE_UNIT = item.cComUnitName;
                comEntity.CN_S_MODEL = item.cInvStd;
                comEntity.CN_S_PRODUCTION_BATCH = item.cBatch;
                comEntity.CN_F_U8STOCK_QTY = item.iQuantity;
                comEntity.CN_T_COMARE_DATE = DateTime.Now;

                if (comResult.Count > 0)
                {
                    AutoBomItemEntity itemenity = BLLCreator.Create<MongoBLL>().GetItemEntity(comEntity.CN_S_ITEM_CODE);

                    if (itemenity != null)
                    {
                        Log.Info("位置一：未获取到物料实体！", comEntity.CN_S_ITEM_CODE);
                        sqlResult.Success = false;
                        return sqlResult;
                    }
                    decimal jishu = 0;
                    if (!string.IsNullOrEmpty(itemenity.CN_S_CONERSION))
                    {
                        string conersion = itemenity.CN_S_CONERSION;
                        jishu = Convert.ToDecimal(itemenity.CN_S_CONERSION.Substring(0, itemenity.CN_S_CONERSION.IndexOf("-")));

                    }
                    else
                    {
                        Log.Info("失败！", "请维护物料 " + itemenity.CN_S_ITEM_CODE + " 的换算比例！");
                        sqlResult.Success = false;
                        return sqlResult;
                    }
                    
                    comEntity.CN_F_WMSSTOCK_QTY = comResult[0].CN_F_QUANTITY * jishu;
                    comEntity.CN_F_DIFFER_QTY = item.iQuantity - (comResult[0].CN_F_QUANTITY * jishu);
                    if (comEntity.CN_F_DIFFER_QTY == 0) continue;
                }
                else
                {
                    comEntity.CN_F_WMSSTOCK_QTY = 0;
                    comEntity.CN_F_DIFFER_QTY = item.iQuantity;
                }
                stockQtyCom.Add(comEntity);
            }
            foreach (var item in stockQtyList)
            {
                var comResult = u8RebackData.Where(x => x.cInvCode == item.CN_S_ITEM_CODE &&
                                                      x.itemState == item.CN_S_ITEM_STATE &&
                                                      x.cBatch == item.CN_S_PRODUCTION_BATCH).ToList();
                if (comResult.Count == 0)
                {
                    AutoBomItemEntity itemenity = BLLCreator.Create<MongoBLL>().GetItemEntity(item.CN_S_ITEM_CODE);

                    if (itemenity == null)
                    {
                        Log.Info("位置二：未获取到物料实体！", item.CN_S_ITEM_CODE);
                        sqlResult.Success = false;
                        return sqlResult;
                    }
                    decimal jishu = 0;
                    if (!string.IsNullOrEmpty(itemenity.CN_S_CONERSION))
                    {
                        string conersion = itemenity.CN_S_CONERSION;
                        jishu = Convert.ToDecimal(itemenity.CN_S_CONERSION.Substring(0, itemenity.CN_S_CONERSION.IndexOf("-")));

                    }
                    else
                    {
                        Log.Info("失败！", "请维护物料 " + itemenity.CN_S_ITEM_CODE + " 的换算比例！");
                        sqlResult.Success = false;
                        return sqlResult;
                    }

                    TN_WM_STOCKQTY_COMPAREEntity comEntity = new TN_WM_STOCKQTY_COMPAREEntity();
                    comEntity.CN_GUID = System.Guid.NewGuid().ToString().ToUpper();
                    comEntity.CN_S_ITEM_CODE = item.CN_S_ITEM_CODE;
                    comEntity.CN_S_ITEM_NAME = item.CN_S_ITEM_NAME;
                    comEntity.CN_S_MEASURE_UNIT = itemenity.CN_S_MEASURE_UNIT;
                    comEntity.CN_S_MODEL = itemenity.CN_S_MODEL;
                    comEntity.CN_S_PRODUCTION_BATCH = item.CN_S_PRODUCTION_BATCH;
                    comEntity.CN_F_U8STOCK_QTY = 0;
                    comEntity.CN_F_WMSSTOCK_QTY = item.CN_F_QUANTITY * jishu;
                    comEntity.CN_F_DIFFER_QTY = 0 - item.CN_F_QUANTITY * jishu;

                    comEntity.CN_T_COMARE_DATE = DateTime.Now;

                    stockQtyCom.Add(comEntity);
                }
            }

            string resultStrMst = WebApiManager.HttpWMSTool_Post("Api/Report/AddU8CompareData", JsonConvert.SerializeObject(stockQtyCom));
            if (resultStrMst == "")
            {
                Log.Info("保存比对数据接口未调通！", "Api/Report/AddU8CompareData");
                sqlResult.Success = false;
                sqlResult.Msg = "保存比对数据接口未调通！";
            }
            else
            {
                OperateResult orMst = JsonConvert.DeserializeObject<OperateResult>(resultStrMst);
                if (!orMst.Success)
                {
                    Log.Info("保存比对数据接口调用失败！", orMst.Msg);
                    return orMst;
                }
                else
                {
                    sqlResult.Success = orMst.Success;
                }
            }
            return sqlResult;
        }


        public AutobomResult AddCusList(List<PLM_CusEntity> customEntityList)
        {
            string result = WebApiManager.HttpAutoBom_Post("Api/PLM/CustomerRelease", JsonConvert.SerializeObject(customEntityList));

            List<AutobomResult> autobomRes = JsonConvert.DeserializeObject<List<AutobomResult>>(result);

            return autobomRes[0];
        }

        public AutobomResult AddVenList(List<PLM_VenEntity> vendnrEntityList)
        {
            string result = WebApiManager.HttpAutoBom_Post("Api/PLM/SupplierRelease", JsonConvert.SerializeObject(vendnrEntityList));

            List<AutobomResult> autobomRes = JsonConvert.DeserializeObject<List<AutobomResult>>(result);

            return autobomRes[0];
        }
    }
}