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(){}
}

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。