.net core实现动态API功能

引文

不知各位有没有想过,如果能把数据库操作和http访问都统一封装成接口(interface)的形式,然后接口对应的实现类由框架去自动生成,那么必然能大大降低工作量,因为不需要去写很多重复的代码了,还有一个好处是,都是提供接口,我们把原来数据库操作的部分,改成http访问,对于业务层来说,是无感的,因为接口和方法都没变。致力于降低上手net core的门槛,我开源了SummerBoot项目,下面让我们来看一下效果。

数据库表对应实体类,这些都是常规操作,略过

重头戏,如何写接口,以一个简单的购物功能为例子

数据库访问

订单详情仓储

.net core实现动态API功能

订单仓储

.net core实现动态API功能

http访问

.net core实现动态API功能

控制器中进行构造函数注入

.net core实现动态API功能

实际调用

<code>        /// 
        /// 添加订单
        /// 
        /// 
        /// 
        [HttpPost("AddOrder")]
        public async Task AddOrder([FromBody]AddOrderDto dto)
        {
            if (dto?.ProductList==null) return BadRequest("参数不能为空");

            Uow.BeginTransaction();
            try
            {
                var orderHeader = new OrderHeader
                {
                    CreateTime = DateTime.UtcNow,
                    CustomerNo = dto.CustomerNo,
                    State = 1,
                    OrderNo = Guid.NewGuid().ToString("N")
                };

                await OrderHeaderRepository.InsertAsync(orderHeader);

                var orderDetailList = new List();
                //总消费金额
                var totalAmount = 0m;
                dto.ProductList.ForEach(it =>
                {
                    var orderDetail = new OrderDetail
                    {
                        OrderHeaderId = orderHeader.Id,
                        ProductNo = it.ProductNo,
                        ProductName = it.ProductName,
                        Quantity = it.Quantity,
                        Price = it.Price
                    };
                    orderDetailList.Add(orderDetail);

                    totalAmount += it.Quantity * it.Price;
                });

                await OrderDetailRepository.BatchInsertAsync(orderDetailList);
                //更新用户消费金额
                var success = await CustomerRepository.UpdateCustomerAmount(dto.CustomerNo, totalAmount);
                
                if (!success)
                {
                    Uow.RollBack();

                    return BadRequest();
                }
            }
            catch (Exception e)
            {
                Uow.RollBack();
            }
           
            Uow.Commit();

            return Ok();
        }
		
		/// 
		/// 删库跑路
		/// 
		/// 
		[HttpGet("DeleteDatabase")]
		public async Task DeleteDatabase()
		{
			await OrderHeaderRepository.DeleteAllOrder();
		}

		/// 
		/// 根据会员编号取消订单
		/// 
		/// 
		/// 
		[HttpGet("CancelOrderByCustomerNo")]
		public async Task CancelOrderByCustomerNo(string customerNo)
		{
			var count = await OrderHeaderRepository.CancelOrderByCustomerNoAsync(customerNo);
			return count > 0;
		}

		/// 
		/// 分页,根据会员编号获取消费详情
		/// 
		/// 
		/// 
		[HttpGet("QueryOrderDetailByCustomerNoByPage")]
		public async Task> QueryOrderDetailByCustomerNoByPage(int pageNumber,int pageSize, string customerNo)
		{
			var page=new Pageable(pageNumber,pageSize);
			var result = await OrderDetailRepository.GetOrderDetailByCustomerNoByPageAsync(page,customerNo);
			return result;
		}

		/// 
		/// 根据会员编号获取消费详情
		/// 
		/// 
		/// 
		[HttpGet("QueryOrderDetailByCustomerNo")]
		public async Task> QueryOrderDetailByCustomerNo(string customerNo)
		{
			var result= await OrderDetailRepository.GetOrderDetailByCustomerNoAsync(customerNo);
			return result;
		}
/<code>

动态生成接口实现类的原理

.net core实现动态API功能

  最开始写的时候,思路是,采用AOP思想,castle动态生成接口实现类,实现类里的方法都没有具体实现,然后在切面里对方法进行拦截并且模拟方法的实现,提供返回值,java中很多骚操作就是这么实现的,但是后来发现在.net中这种实现方式有很大的弊端,因为.net有异步方法,而castle对于异步方法的支持是很弱的,不足以实现最开始的设想,于是,我换了一种思路,在数据库操作和http调用中,抛开动态实现类这个壳子,具体执行操作的类是恒定不变的,那么利用emit技术动态路由到要执行的方法就行了。


分享到:


相關文章: