using CK.SCP.Models;
using CK.SCP.Models.ExchangeCenterTables;
using CK.SCP.Utils;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Entity.Migrations;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace CK.SCP.Controller
{
    public class UN_EC_CONTROLLER_PART
    {
        public static void Get_TES_PART_MSTR_List(TES_PART_MSTR p_entity, Action<ResultObject<IQueryable<TES_PART_MSTR>>> p_action)
        {
               ResultObject<IQueryable<TES_PART_MSTR>> _ret = new ResultObject<IQueryable<TES_PART_MSTR>>();
                try
            {
                using (var db = EntitiesFactory.CreateExchangeCenterInstance())
                {
                    IQueryable<TES_PART_MSTR> q = db.TES_PART_MSTR;
                    if (!string.IsNullOrEmpty(p_entity.PartCode))
                    {
                        q = q.Where(p => p.PartCode.Contains(p_entity.PartCode));
                    }
                    if (!string.IsNullOrEmpty(p_entity.Desc1))
                    {
                        q = q.Where(p => p.Desc1.Contains(p_entity.Desc1));
                    }
                    if (!string.IsNullOrEmpty(p_entity.Desc2))
                    {
                        q = q.Where(p => p.Desc2.Contains(p_entity.Desc2));
                    }
                    if (!string.IsNullOrEmpty(p_entity.Um))
                    {
                        q = q.Where(p => p.Um.Contains(p_entity.Um));
                    }
                    if (!string.IsNullOrEmpty(p_entity.ProdLine))
                    {
                        q = q.Where(p => p.ProdLine.Contains(p_entity.ProdLine));
                    }
                    if (!string.IsNullOrEmpty(p_entity.DsgnGroup))
                    {
                        q = q.Where(p => p.DsgnGroup.Contains(p_entity.DsgnGroup));
                    }
                    if (!string.IsNullOrEmpty(p_entity.PromotionGroup))
                    {
                        q = q.Where(p => p.PromotionGroup.Contains(p_entity.PromotionGroup));
                    }
                    if (!string.IsNullOrEmpty(p_entity.PartType))
                    {
                        q = q.Where(p => p.PartType.Contains(p_entity.PartType));
                    }
                    if (!string.IsNullOrEmpty(p_entity.Status))
                    {
                        q = q.Where(p => p.Status.Contains(p_entity.Status));
                    }
                    if (!string.IsNullOrEmpty(p_entity.Group))
                    {
                        q = q.Where(p => p.Group.Contains(p_entity.Group));
                    }
                    if (!string.IsNullOrEmpty(p_entity.Drawing))
                    {
                        q = q.Where(p => p.Drawing.Contains(p_entity.Drawing));
                    }
                    if (!string.IsNullOrEmpty(p_entity.PartRevision))
                    {
                        q = q.Where(p => p.PartRevision.Contains(p_entity.PartRevision));
                    }
                    if (!string.IsNullOrEmpty(p_entity.DrawingLocation))
                    {
                        q = q.Where(p => p.DrawingLocation.Contains(p_entity.DrawingLocation));
                    }
                    if (!string.IsNullOrEmpty(p_entity.Size))
                    {
                        q = q.Where(p => p.Size.Contains(p_entity.Size));
                    }
                    if (!string.IsNullOrEmpty(p_entity.PriceBreakCategory))
                    {
                        q = q.Where(p => p.PriceBreakCategory.Contains(p_entity.PriceBreakCategory));
                    }
                    if (p_entity.AuxiliaryMaterial != false)
                    {
                        q = q.Where(p => p.AuxiliaryMaterial == p_entity.AuxiliaryMaterial);
                    }
                    if (!string.IsNullOrEmpty(p_entity.Qgrade))
                    {
                        q = q.Where(p => p.Qgrade.Contains(p_entity.Qgrade));
                    }
                    if (p_entity.WmsPartType != 0)
                    {
                        q = q.Where(p => p.WmsPartType == p_entity.WmsPartType);
                    }
                    if (!string.IsNullOrEmpty(p_entity.ManageWay))
                    {
                        q = q.Where(p => p.ManageWay.Contains(p_entity.ManageWay));
                    }
                    if (!string.IsNullOrEmpty(p_entity.InventoryCode))
                    {
                        q = q.Where(p => p.InventoryCode.Contains(p_entity.InventoryCode));
                    }
                    if (!string.IsNullOrEmpty(p_entity.ManageType))
                    {
                        q = q.Where(p => p.ManageType.Contains(p_entity.ManageType));
                    }
                    if (p_entity.InspectType != null)
                    {
                        q = q.Where(p => p.InspectType == p_entity.InspectType);
                    }
                    if (p_entity.UID != 0)
                    {
                        q = q.Where(p => p.UID == p_entity.UID);
                    }
                    if (!string.IsNullOrEmpty(p_entity.CreateUser))
                    {
                        q = q.Where(p => p.CreateUser.Contains(p_entity.CreateUser));
                    }
                    if (!string.IsNullOrEmpty(p_entity.Remark))
                    {
                        q = q.Where(p => p.Remark.Contains(p_entity.Remark));
                    }
                    if (!string.IsNullOrEmpty(p_entity.CommandType))
                    {
                        q = q.Where(p => p.CommandType.Contains(p_entity.CommandType));
                    }
                    if (!string.IsNullOrEmpty(p_entity.Domain))
                    {
                        q = q.Where(p => p.Domain.Contains(p_entity.Domain));
                    }
                    if (!string.IsNullOrEmpty(p_entity.Site))
                    {
                        q = q.Where(p => p.Site.Contains(p_entity.Site));
                    }
                    _ret.Result = q;
                    _ret.State = ReturnStatus.Succeed;
                    p_action(_ret);
                }
            }
            catch (Exception e)
            {
                _ret.State = ReturnStatus.Failed;
                _ret.ErrorList.Add(e);
                LogHelper.Writlog(LogHelper.LogType.Error, typeof(TES_PART_MSTR), "Get_TES_PART_MSTR_List", e.Message);
                throw e;
            }
           
        }

        public static DataTable Get_TES_PART_MSTR_List(string p_PartCode, string p_tableName)
        {
            DataTable dt = new DataTable(); ;
            var dbSetting = GlobalConfig.ExchangeCenterDB;
            try
            {
                var strConn = EntitiesFactory.GetEfConnectionString(dbSetting);
                SqlConnection conn = new System.Data.SqlClient.SqlConnection();
                conn.ConnectionString = strConn;
                if (conn.State != ConnectionState.Open)
                {
                    conn.Open();
                }
                SqlCommand cmd = new SqlCommand();
                cmd.Connection = conn;
                string _sql = string.Format("select * from {0} where PartCode='{1}'", p_tableName, p_PartCode);

                cmd.CommandText = _sql;

                SqlDataAdapter adapter = new SqlDataAdapter(cmd);

                adapter.Fill(dt);

            }
            catch (SqlException ex)
            {
                throw new Exception($"系统无法连接到数据库:{dbSetting}，请检查配置的服务器,数据库,用户名和密码等信息是否正确。{Environment.NewLine}{ex}");
            }
            return dt;
        }

        public static ResultObject<bool> Save_TES_PART_MSTR(List<long> p_listUid, EnumTaskState p_state)
        {

            ResultObject<bool> _ret = new ResultObject<bool>();
            try
            {
                using (var db = EntitiesFactory.CreateExchangeCenterInstance())
                {
                    var _lst = db.TES_PART_MSTR.Where(p => p_listUid.Contains(p.UID)).ToList();
                    foreach (var itm in _lst)
                    {
                        db.TES_PART_MSTR.AddOrUpdate(itm);
                    }
                    if (db.SaveChanges() != -1)
                    {
                        _ret.State = ReturnStatus.Succeed;
                        _ret.Result = true;
                    }
                    else
                    {
                        _ret.State = ReturnStatus.Failed;
                        _ret.Result = false;
                    }
                }
            }
            catch (Exception e)
            {
                _ret.State = ReturnStatus.Failed;
                LogHelper.Writlog(LogHelper.LogType.Error, typeof(TES_PART_MSTR), "Save_TES_PART_MSTR", e.Message);
                _ret.Result = false;
                _ret.ErrorList.Add(e);
                throw e;
            }
            return _ret;

        }
        public ResultObject<bool> Del_TES_PART_MSTR(List<TES_PART_MSTR> p_entitys)
        {
            ResultObject<bool> _ret = new ResultObject<bool>();
            try
            {
                using (var db = EntitiesFactory.CreateExchangeCenterInstance())
                {
                    foreach (var itm in p_entitys)
                    {
                        db.TES_PART_MSTR.Remove(itm);
                    }
                    if (db.SaveChanges() != -1)
                    {
                        _ret.State = ReturnStatus.Succeed;
                        _ret.Result = true;
                    }
                    else
                    {
                        _ret.State = ReturnStatus.Failed;
                        _ret.Result = false;
                    }
                }
            }
            catch (Exception e)
            {
                _ret.State = ReturnStatus.Failed;
                _ret.Result = false;
                _ret.ErrorList.Add(e);
                LogHelper.Writlog(LogHelper.LogType.Error, typeof(TES_PART_MSTR), "Del_TES_PART_MSTR", e.Message); throw e;
            }
            return _ret;
        }


    }
}