sequence.cs

基于C/S的医疗卫生管理系统

using System;
using System.Collections.Generic;
using System.Text;
using System.Runtime.CompilerServices;
using System.Data;

using Oracle.DataAccess.Client;

using Qeb.DBProxy;

namespace Qeb.Support.Common
{
    public class Sequence
    {
        private static DbProxyClient m_Proxy = App.DbProxy;
        /// <summary>
        /// 取序号
        /// </summary>
        /// <param name="name"></param>
        /// <param name="length"></param>
        /// <returns></returns>
        [MethodImpl(MethodImplOptions.Synchronized)]        
        public static string GetXhByName(string seqName,int length)
        {
            string sql = "SELECT Fun_GY_GetSequence('" + seqName + "'," + length.ToString() + ") FROM DUAL";
            string xh = m_Proxy.ExecuteScalar(sql);
            if (xh == null)
                return "";

            //if (length > 0 && xh.Length < length)
            //{
            //    xh = xh.PadLeft(length, '0');
            //}

            return xh; 
        }

        /// <summary>
        /// 取序号
        /// </summary>
        /// <param name="seqName"></param>
        /// <returns></returns>
        public static string GetXhByName(string seqName)
        {
            return GetXhByName(seqName, 0);
        }

        /// <summary>
        /// 取药库房单据号
        /// </summary>
        /// <param name="yyId">应用ID</param>
        /// <param name="crkFsId">出入库方式ID</param>
        /// <returns></returns>
        public static string GetYkfDjh(string yyId,string crkFsId)
        {
            string xhMc = yyId + "_" + crkFsId;


            OracleCommand command = new OracleCommand();
            command.CommandText = "PKG_GY_YKF.Prc_GetDjh";
            command.CommandType = CommandType.StoredProcedure;

            //序号名称
            OracleParameter p_XhMc = new OracleParameter();
            p_XhMc.ParameterName = ":p_xhmc";
            p_XhMc.Value = xhMc;
            p_XhMc.DbType = DbType.String;
            p_XhMc.Direction = ParameterDirection.Input;

            OracleParameter p_AppCode = new OracleParameter();
            p_AppCode.ParameterName = ":p_appcode";
            p_AppCode.DbType = DbType.Int32;
            p_AppCode.Direction = ParameterDirection.Output;

            OracleParameter p_OutBuffer = new OracleParameter();
            p_OutBuffer.ParameterName = ":p_outbuffer";
            p_OutBuffer.DbType = DbType.String;
            p_OutBuffer.Size = 600;
            p_OutBuffer.Direction = ParameterDirection.Output;


            command.Parameters.Add(p_XhMc);
            command.Parameters.Add(p_AppCode);
            command.Parameters.Add(p_OutBuffer);

            m_Proxy.Clear();
            m_Proxy.AddDbCommand(command);
            m_Proxy.Update();
            if (p_AppCode.Value != null && p_AppCode.Value.ToString() == "1")
            {
                return p_OutBuffer.Value.ToString();
            }
            else
            {
                throw new Exception(p_OutBuffer.Value.ToString());
            }
        }
    }
}