using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using CoreFS.CA06;
using System.Data;
using System.Collections;

namespace Core.StlMes.Client.LgCommon
{
    public class CommonClientToServer : FrmBase
    {
        /// <summary>
        /// 查询
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="ServerParams">参数SqlID</param>
        /// <returns>DataSet</returns>
        public DataSet ExecuteQueryFunctions(string ServerName, string MethodName, string ServerParams, out string strErr)
        {
            CoreClientParam ccp = new CoreClientParam();
            ccp.ServerName = ServerName;
            ccp.MethodName = MethodName;
            ccp.ServerParams = new Object[] { ServerParams };
            DataTable dt = new DataTable();
            ccp.SourceDataTable = dt;
            ExecuteSortResultByQueryToDataTable(ccp, CoreInvokeType.Internal);
            DataSet ds = new DataSet();
            ds.Tables.Add(dt);
            strErr = ccp.ReturnInfo;
            return ds;
        }

        /// <summary>
        /// 查询
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="strSqlID">SQLID</param>
        /// <param name="altParams">参数</param>
        /// <returns>DataSet</returns>
        public DataSet ExecuteQueryFunctions(string ServerName, string MethodName, ArrayList altParams, out string strErr)
        {
            try
            {
                CoreClientParam ccp = new CoreClientParam();
                ccp.ServerName = ServerName;
                ccp.MethodName = MethodName;
                ccp.ServerParams = new Object[] { altParams };
                DataTable dt = new DataTable();
                ccp.SourceDataTable = dt;
                this.ExecuteSortResultByQueryToDataTable(ccp, CoreInvokeType.Internal);
                strErr = ccp.ReturnInfo;
                DataSet ds = new DataSet();
                ds.Tables.Add(dt);
                return ds;
            }
            catch 
            {
                strErr = MethodName + "方法查询数据异常！";
                return null;
            }

        }

        /// <summary>
        /// 查询
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="strSqlID">SQLID</param>
        /// <param name="altParams">参数</param>
        /// <returns>DataSet</returns>
        public DataSet ExecuteQueryFunctions(string ServerName, string MethodName, string strSqlID, ArrayList altParams)
        {
            CoreClientParam ccp = new CoreClientParam();
            ccp.ServerName = ServerName;
            ccp.MethodName = MethodName;
            ccp.ServerParams = new Object[] { strSqlID, altParams };
            DataTable dt = new DataTable();
            ccp.SourceDataTable = dt;
            ccp.IfShowErrMsg = false;
            ExecuteSortResultByQueryToDataTable(ccp, CoreInvokeType.Internal);
            DataSet ds = new DataSet();
            ds.Tables.Add(dt);
            return ds;
        }
        
        /// <summary>
        /// 调用服务端业务执行返回结果
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="strSqlID">SQLID</param>
        /// <param name="altParams">参数</param>
        /// <returns>DataSet</returns>
        public CoreClientParam ExecuteClietnToServer(string ServerName, string MethodName, ArrayList altParams, out string strErr)
        {
            try
            {
                CoreClientParam ccp = new CoreClientParam();
                ccp.ServerName = ServerName;
                ccp.MethodName = MethodName;
                ccp.ServerParams = new Object[] { altParams };
                DataTable dt = new DataTable();
                ccp.SourceDataTable = dt;
                ccp.IfShowErrMsg = false;
                this.ExecuteNonQuery(ccp, CoreInvokeType.Internal);                
                strErr = ccp.ReturnInfo;
                return ccp;
            }
            catch
            {
                strErr = MethodName + "方法查询数据异常！";
                return null;
            }

        }

        /// <summary>
        /// 调用服务端业务执行返回结果ArrayList
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="strSqlID">SQLID</param>
        /// <param name="altParams">参数</param>
        /// <returns>DataSet</returns>
        public CoreClientParam ExecuteQueryArrayList(string ServerName, string MethodName, ArrayList altParams, out string strErr)
        {
            try
            {
                CoreClientParam ccp = new CoreClientParam();
                ccp.ServerName = ServerName;
                ccp.MethodName = MethodName;
                ccp.ServerParams = new Object[] { altParams };
                DataTable dt = new DataTable();
                ccp.SourceDataTable = dt;
                this.ExecuteNonQuery(ccp, CoreInvokeType.Internal);                 
                strErr = ccp.ReturnInfo;
                return ccp;
            }
            catch
            {
                strErr = MethodName + "方法查询数据异常！";
                return null;
            }

        }

        /// <summary>
        /// 增加、删除、修改
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="ServerParams">参数</param>
        /// <returns></returns>
        public string NoQueryFunctions(string ServerName, string MethodName, ArrayList ServerParams,out string strErr)
        {
            CoreClientParam ccp_K = new CoreClientParam();
            ccp_K.ServerName = ServerName;
            ccp_K.MethodName = MethodName;
            ccp_K.ServerParams = new Object[] { ServerParams };            
            ExecuteNonQuery(ccp_K, CoreInvokeType.Internal);
            strErr = ccp_K.ReturnInfo.ToString();
            return ccp_K.ReturnInfo.ToString();
        }

        /// <summary>
        /// 执行存储过程
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="strSqlID">SQLID</param>
        /// <param name="ht">存储过程输入输出参数</param>
        /// <param name="strErr">错误信息</param>
        /// <returns>返回执行代码</returns>
        public string ExecuteProcedureFunctions(string ServerName, string MethodName, string strSqlID, Hashtable ht, out string strErr)
        {
            CoreClientParam ccp = new CoreClientParam();
            ccp.ServerName = ServerName;
            ccp.MethodName = MethodName;
            ccp.ServerParams = new Object[] { strSqlID, ht };
            this.ExecuteNonQuery(ccp, CoreInvokeType.Internal);
            strErr = ccp.ReturnInfo;
            return ccp.ReturnCode.ToString();
        }

        /// <summary>
        /// 执行存储过程
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="strSqlID">SQLID</param>
        /// <param name="ht">存储过程输入输出参数</param>
        /// <param name="strErr">错误信息</param>
        /// <returns>返回执行代码</returns>
        public CoreClientParam ExecuteProcedureFunctionsCCP(string ServerName, string MethodName, string strSqlID, Hashtable ht, out string strErr)
        {
            CoreClientParam ccp = new CoreClientParam();
            ccp.ServerName = ServerName;
            ccp.MethodName = MethodName;
            ccp.ServerParams = new Object[] { strSqlID, ht };
            this.ExecuteNonQuery(ccp, CoreInvokeType.Internal);
            strErr = ccp.ReturnInfo;
            return ccp;
        }

        /// <summary>
        /// 执行传输数组存储过程
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="strSqlID">SQLID</param>
        /// <param name="ht">存储过程输入输出参数</param>
        /// <param name="strErr">错误信息</param>
        /// <returns>返回执行代码</returns>
        public string ExecuteProcedureFunctions(string ServerName, string MethodName, string strSqlID, object[] sArgs, out string strErr)
        {
            CoreClientParam ccp = new CoreClientParam();
            ccp.ServerName = ServerName;
            ccp.MethodName = MethodName;
            ccp.ServerParams = new Object[] { strSqlID, sArgs };
            this.ExecuteNonQuery(ccp, CoreInvokeType.Internal);
            strErr = ccp.ReturnInfo;
            return ccp.ReturnCode.ToString();
        }

        /// <summary>
        /// 通过SqlID从数据表读取SQL语句进行查询
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="strSqlID">SQLID</param>
        /// <param name="moduleCod">模块编码 1：销售管理，2：计划管理，3：质量管理， 4：仓库和发货管理、5：炼钢MES、6：轧钢MES</param>
        /// <param name="altParams">参数</param>
        /// <returns>DataSet</returns>
        /// 2012-10-30 新增方法
        public DataSet ExecuteQueryFunctionsSqlID(string ServerName, string MethodName, string strSqlID, int moduleCode, ArrayList altParams, out string strErr)
        {
            CoreClientParam ccp = new CoreClientParam();
            ccp.ServerName = ServerName;
            ccp.MethodName = MethodName;
            ccp.ServerParams = new Object[] { strSqlID, moduleCode, altParams };
            DataTable dt = new DataTable();
            ccp.SourceDataTable = dt;
            ccp.IfShowErrMsg = false;           
            ExecuteSortResultByQueryToDataTable(ccp, CoreInvokeType.Internal);
            strErr = ccp.ReturnInfo;
            DataSet ds = new DataSet();
            ds.Tables.Add(dt);
            return ds;
        }

        /// <summary>
        /// 通过SqlID从数据表读取SQL语句执行存储过程
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="strSqlID">SQLID</param>
        /// <param name="ht">存储过程输入输出参数</param>
        /// <param name="strErr">错误信息</param>
        /// <returns>返回执行代码</returns>
        /// 2012-10-30 新增方法
        public CoreClientParam ExecuteProcedureFunctionsSqlID(string ServerName, string MethodName, string strSqlID, int moduleCode, Hashtable ht, out string strErr)
        {
            CoreClientParam ccp = new CoreClientParam();
            ccp.ServerName = ServerName;
            ccp.MethodName = MethodName;
            ccp.ServerParams = new Object[] { strSqlID, moduleCode, ht };
            this.ExecuteNonQuery(ccp, CoreInvokeType.Internal);
            strErr = ccp.ReturnInfo;
            return ccp;
        }

        /// <summary>
        /// 通过SqlID从数据表读取SQL语句执行存储过程（传入数组）
        /// </summary>
        /// <param name="ServerName">服务名</param>
        /// <param name="MethodName">方法名</param>
        /// <param name="strSqlID">SQLID</param>
        /// <param name="ht">存储过程输入输出参数</param>
        /// <param name="strErr">错误信息</param>
        /// <returns>返回执行代码</returns>
        /// 2013-08-21 新增方法
        public CoreClientParam ExecuteProcedureFunctionsSqlID(string ServerName, string MethodName, string strSqlID, int moduleCode, object[] sArgs, out string strErr)
        {
            CoreClientParam ccp = new CoreClientParam();
            ccp.ServerName = ServerName;
            ccp.MethodName = MethodName;
            ccp.ServerParams = new Object[] { strSqlID, moduleCode, sArgs };
            this.ExecuteNonQuery(ccp, CoreInvokeType.Internal);
            strErr = ccp.ReturnInfo;
            return ccp;
        }
    }
}