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

namespace Core.Mes.Client.Common
{
    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;
            ExecuteQueryToDataTable(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.ExecuteQueryToDataTable(ccp, CoreInvokeType.Internal);
                int code = ccp.ReturnCode;
                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;
            ExecuteQueryToDataTable(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();
        }

       


        private void InitializeComponent()
        {
            this.SuspendLayout();
            // 
            // CommonClientToServer
            // 
            this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 12F);
            this.ClientSize = new System.Drawing.Size(736, 479);
            this.Name = "CommonClientToServer";
            this.Load += new System.EventHandler(this.CommonClientToServer_Load);
            this.ResumeLayout(false);

        }

        private void CommonClientToServer_Load(object sender, EventArgs e)
        {

        }

      
    }
}