using Dapper;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Web;
using VueWebApi.Tools;

namespace VueWebApi.DLL.DAL
{
    public class ErpSyncMesDAL
    {
        public static ToMessage mes = new ToMessage(); //定义全局返回信息对象

        #region[制造模型：单位同步]
        public static ToMessage SeaveSearchUnit(string username)
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                //存储过程名
                sql = @"h_p_IFCLD_ERPUnit";
                dynamicParams.Add("@username", username);
                bool a = DapperHelper.IsProcedure(sql, dynamicParams);
                if (a)
                {
                    mes.code = "200";
                    mes.count = 0;
                    mes.Message = "同步单位成功!";
                    mes.data = null;
                }
                else
                {
                    mes.code = "300";
                    mes.count = 0;
                    mes.Message = "同步单位失败!";
                    mes.data = null;
                }
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.Message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion

        #region[制造模型：存货分类同步]
        public static ToMessage SeaveSearchInventoryClass()
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                //存储过程名
                sql = @"h_p_IFCLD_ERPInventory_Class";
                bool a = DapperHelper.IsProcedureNo(sql);
                if (a)
                {
                    mes.code = "200";
                    mes.count = 0;
                    mes.Message = "同步存货分类成功!";
                    mes.data = null;
                }
                else 
                {
                    mes.code = "300";
                    mes.count = 0;
                    mes.Message = "同步存货分类失败!";
                    mes.data = null;
                }
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.Message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion

        #region[制造模型：存货档案同步]
        public static ToMessage SeaveSearchInventory(string username)
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                //存储过程名
                sql = @"h_p_IFCLD_ERPInventory";
                dynamicParams.Add("@username", username);
                bool a = DapperHelper.IsProcedure(sql, dynamicParams);
                if (a)
                {
                    mes.code = "200";
                    mes.count = 0;
                    mes.Message = "同步存货档案成功!";
                    mes.data = null;
                }
                else
                {
                    mes.code = "300";
                    mes.count = 0;
                    mes.Message = "同步存货档案失败!";
                    mes.data = null;
                }
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.Message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion

        #region[物料管理：仓库库位同步]
        public static ToMessage SeaveSearchWhareHouseLocation(string username)
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                //存储过程名
                sql = @"h_p_IFCLD_ERPWhareHousesLocation";
                dynamicParams.Add("@username", username);
                bool a = DapperHelper.IsProcedure(sql, dynamicParams);
                if (a)
                {
                    mes.code = "200";
                    mes.count = 0;
                    mes.Message = "同步仓库库位成功!";
                    mes.data = null;
                }
                else
                {
                    mes.code = "300";
                    mes.count = 0;
                    mes.Message = "同步仓库库位失败!";
                    mes.data = null;
                }
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.Message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion

        #region[基础设置:往来单位同步]
        public static ToMessage SeaveSearchPartner(string username)
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                //存储过程名
                sql = @"h_p_IFCLD_ERPPartner";
                dynamicParams.Add("@username", username);
                bool a = DapperHelper.IsProcedure(sql, dynamicParams);
                if (a)
                {
                    mes.code = "200";
                    mes.count = 0;
                    mes.Message = "同步往来单位成功!";
                    mes.data = null;
                }
                else
                {
                    mes.code = "300";
                    mes.count = 0;
                    mes.Message = "同步往来单位失败!";
                    mes.data = null;
                }
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.Message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion

        #region[生产管理：生产订单同步]
        public static ToMessage SeaveSearchErpOrder(string stu_torgcode,string stu_torgtypecode)
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                if (stu_torgcode == "" || stu_torgcode == null)
                {
                    stu_torgcode = "";
                }
                if (stu_torgtypecode == "D")
                {
                    sql = @" with CTE as (
                           select id, org_code,org_name, parent_id
                           from TOrganization A
                           where org_code =@stu_torgcode
                           union all
                           select A.id,A.org_code,A.org_name,A.parent_id
                           from TOrganization A
                           inner join CTE on A.parent_id = CTE.id
                           )
                           select org_code,org_name from CTE";
                    dynamicParams.Add("@stu_torgcode", stu_torgcode);
                    var data = DapperHelper.selectdata(sql, dynamicParams);
                    stu_torgcode=string.Join(",", data.AsEnumerable().Select(row => row.Field<string>("org_code")));
                    //stu_torgcode = string.Join(",", data.AsEnumerable().Select(row => $"'{row.Field<string>("org_code")}'"));
                    //LogHelper.WriteLogData("获取车间编码："+stu_torgcode);
                }
                //存储过程名
                sql = @"h_p_IFCLD_ERPMO";
                dynamicParams.Add("@stu_torgcode", stu_torgcode);
                dynamicParams.Add("@stu_torgtypecode", stu_torgtypecode);
                bool a = DapperHelper.IsProcedure(sql, dynamicParams);
                if (a)
                {
                    mes.code = "200";
                    mes.count = 0;
                    mes.Message = "同步生产订单成功!";
                    mes.data = null;
                }
                else
                {
                    mes.code = "300";
                    mes.count = 0;
                    mes.Message = "同步生产订单失败!";
                    mes.data = null;
                }
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.Message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion

        #region[采购管理：采购订单同步]
        public static ToMessage SeaveSearchErpPurchaseOrder()
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                //存储过程名
                sql = @"h_p_IFCLD_ERPPurchaseOrder";
                bool a = DapperHelper.IsProcedureNo(sql);
                if (a)
                {
                    mes.code = "200";
                    mes.count = 0;
                    mes.Message = "同步采购订单成功!";
                    mes.data = null;
                }
                else
                {
                    mes.code = "300";
                    mes.count = 0;
                    mes.Message = "同步采购订单失败!";
                    mes.data = null;
                }
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.Message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion
    }
}