using HH.WCS.Hexafluo;
using HH.WCS.Hexafluo.util;
using HH.WCS.SJML.Dto;
using HH.WCS.SJML.Entitys;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;

namespace HH.WCS.SJML.wms
{
    public class SupplierHelper
    {
        public OperateResult SJsupplierMainAdd(List<TN_SupplierEntitys> suppliers)
        {
            OperateResult result = new OperateResult();
            var db = new SqlHelper<object>().GetInstance();
            try
            {
                var Supp = suppliers.Select(e => e.S_SUPPLIER_NO).ToList();
                //查询是否存在相同数据
                var location = db.Queryable<TN_SupplierEntitys>().Where(it => Supp.Contains(it.S_SUPPLIER_NO)).ToList();
                if (location.Count > 0)
                {
                    suppliers.RemoveAll(e => location.Select(c => c.S_SUPPLIER_NO).ToList().Contains(e.S_SUPPLIER_NO));
                }
                if (suppliers.Count() > 0)
                {
                    db.BeginTran();
                    var I = db.Insertable(suppliers).ExecuteCommand();
                    db.Ado.CommitTran();
                    if (I > 0)
                    {
                        result.Success = true;
                        result.AffectedRows = I;
                    }
                    else
                    {
                        result.Success = false;
                        result.Msg = "添加失败!";
                    }
                }
                else
                {
                    result.Success = false;
                    result.Msg = "经过验证数据已存在,无法重复添加!";
                }
                return result;
            }
            catch (Exception ex)
            {
                LogHelper.Info("供应商维护", "添加报错--" + ex.Message + ex.StackTrace);
                db.Ado.RollbackTran();
                return OperateResult.Error(ex.Message);
            }
        }


        public OperateResult SJsupplierMainDelete(List<TN_SupplierEntitys> suppliers)
        {
            OperateResult result = new OperateResult();
            var db = new SqlHelper<object>().GetInstance();
            try
            {
                db.BeginTran();
                var I = db.Deleteable<TN_SupplierEntitys>().WhereColumns(suppliers, it => new { it.S_SUPPLIER_NO }).ExecuteCommand();
                db.Ado.CommitTran();
                if (I > 0)
                {
                    result.Success = true;
                    result.AffectedRows = I;
                }
                else
                {
                    result.Success = false;
                    result.Msg = "添加失败!";
                }
                return result;
            }
            catch (Exception ex)
            {
                LogHelper.Info("供应商维护", "删除报错--" + ex.Message + ex.StackTrace);
                db.Ado.RollbackTran();
                return OperateResult.Error(ex.Message);
            }
        }


        public OperateResult SJsupplierMainUpdate(List<TN_SupplierEntitys> suppliers)
        {
            OperateResult result = new OperateResult();
            var db = new SqlHelper<object>().GetInstance();
            try
            {
                db.BeginTran();
                var I = db.Updateable(suppliers).WhereColumns(e => new { e.S_SUPPLIER_NO }).ExecuteCommand();
                db.Ado.CommitTran();
                if (I > 0)
                {
                    result.Success = true;
                    result.AffectedRows = I;
                }
                else
                {
                    result.Success = false;
                    result.Msg = "更新失败!";
                }
                return result;
            }
            catch (Exception ex)
            {
                LogHelper.Info("供应商维护", "更新报错--" + ex.Message + ex.StackTrace);
                db.Ado.RollbackTran();
                return OperateResult.Error(ex.Message);
            }
        }

        public OperateResult SJsupplierMainSelect(SupplierMainDto suppliers)
        {
            OperateResult result = new OperateResult();
            var db = new SqlHelper<object>().GetInstance();
            var exp = Expressionable.Create<TN_SupplierEntitys>();
            exp.AndIF(string.IsNullOrEmpty(suppliers.S_SUPPLIER_NO), it => it.S_SUPPLIER_NO.Contains(suppliers.S_SUPPLIER_NO));
            exp.AndIF(string.IsNullOrEmpty(suppliers.S_SUPPLIER_TYPE), it => it.S_SUPPLIER_TYPE == suppliers.S_SUPPLIER_TYPE);
            exp.AndIF(string.IsNullOrEmpty(suppliers.S_SUPPLIER_LEVEL), it => it.S_SUPPLIER_LEVEL == suppliers.S_SUPPLIER_LEVEL);
            exp.AndIF(string.IsNullOrEmpty(suppliers.S_SUPPLIER), it => it.S_SUPPLIER.Contains(suppliers.S_SUPPLIER));
            var I = db.Queryable<TN_SupplierEntitys>().Where(exp.ToExpression()).ToList();
            result.Success = true;
            result.Data = I;
            return result;
        }
    }
}