abp(net core)+easyui+efcore实现仓储管理系统——入库管理之三存储过程(三十九)

在使用ABP框架构建项目时，若是想在仓储层调用存储过程，咱们应该如何来实现呢？关于这个问题，我搜索了不少资料，最后还看了官方文档：https://aspnetboilerplate.com/Pages/Documents/Articles/Using-Stored-Procedures,-User-Defined-Functions-and-Views/index.html

在看完官方文档，对于如何在ABP中使用存储过程已经有了一个相应的思路。如今咱们来实现。

在Visual Studio 2017的“解决方案资源管理器”中，右键单击“ABP.TPLMS.Core”项目的“IRepositories”文件夹，在弹出菜单中选择“添加” > “类”，在弹出对话框中选择“接口”，将接口命名为 IInStockOrderRepository，而后选择“添加”。以下图。

2.在IInStockOrderRepository接口定义咱们须要用到的方法，代码以下。

using Abp.Domain.Repositories;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Data.Common;
using System.Linq;
using System.Text;
using ABP.TPLMS.Entitys;
using System.Threading.Tasks;
using Abp.Dependency; 

namespace ABP.TPLMS.IRepositories
{

    public interface IInStockOrderRepository : IRepository<InStockOrder,int>, ITransientDependency
    {

        /// <summary>
        /// 执行给定的命令
        /// </summary>
        /// <param name="sql">命令字符串</param>
        /// <param name="parameters">要应用于命令字符串的参数</param>
        /// <returns>执行命令后由数据库返回的结果</returns>
        int Execute(string sql, params object[] parameters);

        /// <summary>
        /// 建立一个原始 SQL 查询，该查询将返回给定泛型类型的元素。
        /// </summary>
        /// <typeparam name="T">查询所返回对象的类型</typeparam>
        /// <param name="sql">SQL 查询字符串</param>
        /// <param name="parameters">要应用于 SQL 查询字符串的参数</param>
        /// <returns></returns>

        IQueryable<T> SqlQuery<T>(string sql, params object[] parameters);

        DbCommand CreateCommand(string commandText, CommandType commandType, params object[] parameters);

        /// <summary>
        /// 建立单号
        /// </summary>
        /// <param name="name">单证名称代码</param>
        /// <returns></returns>

        string GetNo(string name);

        /// <summary>
        /// 导入货物信息
        /// </summary>
        /// <param name="ids">导入货物的ID集合</param>
        /// <param name="no">单号</param>
        void ImportCargo(string ids,string no);

    }
}

3. 在Visual Studio 2017的“解决方案资源管理器”中，右键单击“ABP.TPLMS.EntityFrameworkCore”项目的“Repositories”文件夹，在弹出菜单中选择“添加” > “类”，将类命名为 InStockOrderRepository，并继承IInStockOrderRepository接口。实现接口中的方法。代码以下。

using Abp.Data;
using Abp.Dependency;
using Abp.Domain.Entities;
using Abp.EntityFrameworkCore;
using ABP.TPLMS.Entitys;

using ABP.TPLMS.IRepositories;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;

using System.Data;
using System.Data.Common;
using System.Data.SqlClient;

using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
 

namespace ABP.TPLMS.EntityFrameworkCore.Repositories
{

    public class InStockOrderRepository : TPLMSRepositoryBase<InStockOrder, int> ,IInStockOrderRepository, ITransientDependency
    {

        private readonly IActiveTransactionProvider _transactionProvider; 

        public InStockOrderRepository(IDbContextProvider<TPLMSDbContext> dbContextProvider) : base(dbContextProvider)
        { }

        protected InStockOrderRepository(IDbContextProvider<TPLMSDbContext> dbContextProvider, IActiveTransactionProvider transactionProvider)
            : base(dbContextProvider)
        {

            _transactionProvider = transactionProvider;
        }

        public DbCommand CreateCommand(string commandText, CommandType commandType, params SqlParameter[] parameters)
        {

            EnsureConnectionOpen();
            var dbFacade = Context.Database;

            var connection = Microsoft.EntityFrameworkCore.RelationalDatabaseFacadeExtensions.GetDbConnection(dbFacade);
            var command = connection.CreateCommand();
            command.CommandText = commandText;
            command.CommandType = commandType;
            command.Transaction = GetActiveTransaction();

            foreach (var parameter in parameters)
            {
                command.Parameters.Add(parameter);

            }
            return command;

        }

        DbCommand IInStockOrderRepository.CreateCommand(string commandText, CommandType commandType, params object[] parameters)
        {

            EnsureConnectionOpen();
            var dbFacade = Context.Database;
            var connection = Microsoft.EntityFrameworkCore.RelationalDatabaseFacadeExtensions.GetDbConnection(dbFacade);
 

            var command = connection.CreateCommand();
            command.CommandText = commandText;
            command.CommandType = commandType;
            command.Transaction = GetActiveTransaction();
            foreach (var parameter in parameters)
            {
                command.Parameters.Add(parameter);

            }
            return command;
        }

 

        private void EnsureConnectionOpen()
        {

            var dbFacade = Context.Database;
            var connection = Microsoft.EntityFrameworkCore.RelationalDatabaseFacadeExtensions.GetDbConnection(dbFacade);

            if (connection.State != ConnectionState.Open)
            {
                connection.Open();
            }

        }

        int IInStockOrderRepository.Execute(string sql, params object[] parameters)
        {
            throw new NotImplementedException();

        }

        private DbTransaction GetActiveTransaction()
        {
            return (DbTransaction)_transactionProvider.GetActiveTransaction(new ActiveTransactionProviderArgs
            {
                {"ContextType", typeof(TPLMSDbContext) },
                {"MultiTenancySide", MultiTenancySide }
            });

        }
 

         string IInStockOrderRepository.GetNo(string name)
        {       

            SqlParameter[] parameters = {
                 new SqlParameter("Name",System.Data.SqlDbType.NVarChar,10),
                 new SqlParameter("BH", System.Data.SqlDbType.NVarChar,20)

                                          };

            parameters[0].Value = name;
            parameters[1].Direction = System.Data.ParameterDirection.Output;

            int cnt = Context.Database.ExecuteSqlCommand(
 "EXEC p_NextBH @Name, @BH output",
parameters);

            string no = parameters[1].Value.ToString();

            if (cnt < 0)
            {
                no = string.Empty;
            }
            return no;
        }

 

        void IInStockOrderRepository.ImportCargo(string ids,string no)
        {

            SqlParameter[] parameters = {
                new SqlParameter("id",System.Data.SqlDbType.VarChar,500),
                new SqlParameter("No", System.Data.SqlDbType.NVarChar,20)

         };

            parameters[0].Value = ids + ",";
            parameters[1].Value = no;
            int cnt = Context.Database.ExecuteSqlCommand(
 "EXEC SP_ImportCargo2GDE @id, @No",
parameters);
        }

        IQueryable<T> IInStockOrderRepository.SqlQuery<T>(string sql, params object[] parameters)
        {
            throw new NotImplementedException();
        }
    }
}

4.在这里我一共使用了两个存储过程，p_NextBH 与SP_ImportCargo2GDE。

5.定义一张表TPLMS_NO，专门用来存放存全部须要惟一单号的单号的类型，以及类单号当前所使用到最大值。

CREATE TABLE [dbo].[TPLMS_NO](
[Name] [nvarchar](10) NOT NULL,
[Head] [nvarchar](10) NOT NULL,
[CurrentNo] [int] NOT NULL,
[BHLen] [bigint] NOT NULL,
[IsYear] [int] NOT NULL,
[DESCRIPTION] [nvarchar](50) NULL,
PRIMARY KEY CLUSTERED 
(
[Name] ASC
)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON) ON [PRIMARY]
) ON [PRIMARY]

GO
ALTER TABLE [dbo].[TPLMS_NO] ADD  DEFAULT ('') FOR [Head]

GO
ALTER TABLE [dbo].[TPLMS_NO] ADD  DEFAULT ((0)) FOR [CurrentNo]

GO
ALTER TABLE [dbo].[TPLMS_NO] ADD  DEFAULT ((6)) FOR [BHLen]

GO
ALTER TABLE [dbo].[TPLMS_NO] ADD  DEFAULT ((1)) FOR [IsYear]

GO
INSERT INTO [TPLMS_NO]([Name],[Head],[CurrentNo] ,[BHLen],[IsYear],[DESCRIPTION]) VALUES  ('GDE','GD',0,6,1,'入库单')

GO
INSERT INTO [TPLMS_NO]([Name],[Head],[CurrentNo],[BHLen],[IsYear],[DESCRIPTION])
VALUES ('BAT','A' ,0,7,0,'批次号')

GO

6.因为这是一个小应用，因此单号的生成就是字母+日期+流水号。经过 p_NextBH来实现单号的建立，专门用来在上一步的表中取单号。 p_NextBH这个存储过程的实现以下：

--获取新编号的存储过程

CREATE PROC [dbo].[p_NextBH]
@Name nvarchar(10),           --编号种类
@BH nvarchar(20) OUTPUT --新编号
AS

BEGIN TRAN
UPDATE [TPLMS_NO] WITH(ROWLOCK) SET 
@BH=Head+case isyear when 1 then convert(varchar(4),year(getdate())) else '' end 
+RIGHT(POWER(convert(bigint,10),BHLen)+CurrentNo+1,BHLen),
CurrentNo=CurrentNo+1
WHERE Name=@Name
select @BH

COMMIT TRAN
GO

7. 关于使用p_NextBH这个存储过程生成单号有什么优缺点呢？在存储过程当中使用事物，数据库的性能会急剧下滑。对于小应用来讲，这并非太大的问题，对于中大型应用来讲，就多是问题了。能够直接使用UPDATE获取到的更新锁，即SQL SERVER会保证UPDATE的顺序执行。适用中型应用，可是没法知足高并发性能要求。咱们来改一下存储过程。

--获取新编号的存储过程
CREATE PROC [dbo].[p_NextBH]
@Name nvarchar(10),           --编号种类
@BH nvarchar(20) OUTPUT --新编号

AS

UPDATE [TPLMS_NO] WITH(ROWLOCK) SET 
@BH=Head+case isyear when 1 then convert(varchar(4),year(getdate())) else '' end 
+RIGHT(POWER(convert(bigint,10),BHLen)+CurrentNo+1,BHLen),
CurrentNo=CurrentNo+1
WHERE Name=@Name

select @BH

GO

8. 经过传递货物信息的ID，把货物信息导入到入库单中，这个功能经过存储过程SP_ImportCargo2GDE来实现。这个存储过程的实现以下：

CREATE Proc [dbo].[SP_ImportCargo2GDE]
@id varchar(1000),           --id集合
@No nvarchar(20)  --单号

as 
 

CREATE TABLE #IdTable(Id int  NULL) 

DECLARE @PointerPrev int
    DECLARE @PointerCurr int
    DECLARE @TName nvarchar(100)
    Set @PointerPrev=1
    while (@PointerPrev < LEN(@id))
    Begin

        Set @PointerCurr=CharIndex(',',@id,@PointerPrev)
        if(@PointerCurr>0)
        Begin

            set @TName=SUBSTRING(@id,@PointerPrev,@PointerCurr-@PointerPrev)         --若是做为查询条件，我须要建立一个临时表，将数据插入进去
         insert into #IdTable (Id) VALUES (convert(int,@TName))
         SET @PointerPrev = @PointerCurr+1

        End
        else
            Break
    End 

DECLARE @BH nvarchar(20),@batch varchar(20),@maxseqno int
select @BH=@No
select @maxseqno=isnull(MAX(seqno),0) from [InStockOrderDetail] where InStockNo= @BH

--建立批次号

EXEC [dbo].[p_NextBH] 'BAT', @batch OUTPUT 

INSERT INTO [dbo].[InStockOrderDetail]
           ([InStockNo],[SeqNo],[SupplierId],[CargoCode],[HSCode],[CargoName],[Spcf]
           ,[Unit],[Country],[Brand] ,[Curr],[Package],[Length],[Width],[Height],[Qty]
           ,[Vol],[LawfQty],[SecdLawfQty],[Price],[TotalAmt],[GrossWt],[NetWt]
           ,[LawfUnit] ,[SecdLawfUnit],[Batch],[DeliveryOrderDetailId],[CreationTime])

   SELECT @BH,convert(int,seqno)+@maxseqno,a.supplierid,[CargoCode],[HSCode],[CargoName],[Spcf]
         ,[Unit],[Country],[Brand],[Curr]  ,[Package],[Length],[Width],[Height],0 [Qty]
 ,[Vol] ,0 [LawfQty], 0 [SecdLawfQty] ,[Price],0 [TotalAmt],[GrossWt],[NetWt]
 ,'' [LawfUnit],'' [SecdLawfUnit],@batch,a.id,getdate()
  FROM 
  (select row_number() OVER  ( order by id) seqno,* from [dbo].Cargos
   where id in (select id from #IdTable
  where  id not in (select [DeliveryOrderDetailId] 
  from [InStockOrderDetail]
  where InStockNo= @BH
  )
  )   
  ) a 

drop table #IdTable

GO

9. 关于单号的建立，除了使用存储过程，也可使用应用程序来建立。不过使用应用程序来建立，你要保证应用的高可用性，而且建议把最大值保存到数据库。我在这里只是给出大概的代码。

public class BillNoBuilder{
    private static object locker = new object();      

    private static int seq = 0;      

    public static string NextBillNumber(string head){
       //在这里执行，或是通过必定的步长以后，再执行。GetMaxSeq();
        lock(locker){
            if(seq == 99999999)
                seq = 0;
            else
                seq++;

            return head+DateTime.Now.ToString("yyyyMMdd") + sn.ToString().PadLeft(8, '0');
        }
}

//获取数据库中最大的序列号
private static void GetMaxSeq()
{
//seq =数据库中的最大值

}

 
    // 防止建立类的实例
    private BillNoBuilder(){}
}