DDD领域驱动设计之领域服务

1、DDD领域驱动设计实践篇之如何提取模型

2、DDD领域驱动设计之聚合、实体、值对象

3、DDD领域驱动设计之领域基础设施层

什么是领域服务，DDD书中是说，有些类或者方法，放实体A也不好，放实体B也不好，因为很可能会涉及多个实体或者聚合的交互（也可能是多个相同类型的实体），此时就应该吧这些代码放到领域服务中，领域服务其实就跟传统三层的BLL很相似，只有方法没有属性，也就没有状态，而且最好是用动词命名，service为后缀，但是真正到了实践的时候，很多时候是很难区分是领域实体本身实现还是用领域服务区实现的，除了那些需要操作（一般是参数了）多个实体的方法外，有些单个实体的操作是很难严格区分的，实际上放实体和领域服务都可以，只是会有技术上的实现问题，比如实体里面怎么注入仓促的问题，如果放领域服务中了，就很容易注入了；还有一点就是实体或者聚合最好是不要去调用领域服务的，真是没有必要，如果要也会存在注入问题，所以比较合适的实践是，一些方法，如果有涉及系统性判断，如用户名唯一这种查找表的，那么就放到领域服务中，让运用层来调用，领域服务在去调用仓储。

1、仓储接口

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using DDD.Infrastructure;
using DDD.Infrastructure.Domain;

namespace DDD.Domain.Arrange
{
    public interface IPlanArrangeRepository : IRepository<PlanArrange>
    {
        /// <summary>
        /// 项目名称是否存在
        /// </summary>
        /// <param name="xmmc"></param>
        /// <returns></returns>
        bool ExistsXMMC(string xmmc);
        /// <summary>
        /// 是否已下发
        /// </summary>
        /// <param name="appc"></param>
        /// <param name="nd"></param>
        /// <param name="XZQDM"></param>
        /// <returns></returns>
        bool IsSent(int appc, int nd, string XZQDM);

        /// <summary>
        /// 统计计划安排表中，已经存储的指标数据
        /// </summary>
        /// <param name="year"></param>
        /// <param name="xzqdm"></param>
        /// <returns></returns>
        IndicatorArea TotalSendToIndicator(int year, string xzqdm);
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using DDD.Infrastructure.Domain;

namespace DDD.Domain.Indicator
{
    public interface IPlanIndicatorRepository : IRepository<PlanIndicator>
    {
        /// <summary>
        /// 获取预留指标
        /// </summary>
        /// <param name="year"></param>
        /// <param name="xzqdm"></param>
        /// <returns></returns>
        IndicatorArea TotalReserveIndicator(int year, string xzqdm);
        /// <summary>
        /// 获取指定行政区下发的指标（计划指标）
        /// </summary>
        /// <param name="year"></param>
        /// <param name="xzqdm"></param>
        /// <returns></returns>
        IndicatorArea TotalReceiveIndicator(int year, string xzqdm);
        /// <summary>
        /// 获取下发到指定行政区的指标
        /// </summary>
        /// <param name="year"></param>
        /// <param name="xzqdm"></param>
        /// <returns></returns>
        IndicatorArea TotalSendToIndicator(int year, string xzqdm);

        /// <summary>
        /// 是否已下发
        /// </summary>
        /// <param name="appc"></param>
        /// <param name="nd"></param>
        /// <param name="XZQDM"></param>
        /// <returns></returns>
        bool IsSent(int appc, int nd, string XZQDM);
        /// <summary>
        /// 是否存在已下发项目
        /// </summary>
        /// <param name="appc"></param>
        /// <param name="nd"></param>
        /// <param name="XZQDM"></param>
        /// <param name="XFXZQDM"></param>
        /// <returns></returns>
        bool Exists(int appc, int nd, string XZQDM, string XFXZQDM);
    }
}

　　

2、领域服务

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using DDD.Domain.Indicator;
using DDD.Infrastructure;

namespace DDD.Domain.Arrange
{
    /// <summary>
    /// 计划安排服务
    /// </summary>
    public class ArrangeService
    {
        private readonly IPlanArrangeRepository repository;
        /// <summary>
        /// service可以用多个不同的Repository接口吗
        /// </summary>
        private readonly IPlanIndicatorRepository indicatorRepository;

        public ArrangeService(IPlanArrangeRepository repository, IPlanIndicatorRepository indicatorRepository)
        {
            this.repository = repository;
            this.indicatorRepository = indicatorRepository;
        }

        /// <summary>
        /// 登记指标项目，如果是国家级别，那么projects可以不传
        /// </summary>
        /// <param name="planArrange"></param>
        /// <param name="planArranges"></param>
        public void Register(PlanArrange planArrange, IList<PlanArrange> planArranges)
        {
            CheckAndThrow(planArrange, false);
            planArrange.Register();
            if (planArranges != null)
            {
                foreach (var item in planArranges)
                {
                    item.APPC = planArrange.APPC;
                    item.ND = planArrange.ND;
                    item.XZQDM = planArrange.XZQDM;
                    item.Register();
                }
            }
        }

        /// <summary>
        /// 这个方法是修改的时候调用判断的
        /// </summary>
        /// <param name="planArrange"></param>
        public void CheckUpdate(PlanArrange planArrange)
        {
            CheckAndThrow(planArrange, true);
        }

        private void CheckAndThrow(PlanArrange planArrange, bool isUpdate)
        {
            if (repository.IsSent(planArrange.APPC, planArrange.ND, planArrange.XZQDM))
            {
                throw new DomainException("批次已下发，不允许登记或修改");
            }
            if (isUpdate)
            {
                var original = repository.Find(planArrange.Id);
                if (original.XMMC != planArrange.XMMC && repository.ExistsXMMC(planArrange.XMMC))
                {
                    throw new DomainException("项目名称已存在");
                }
            }
            else if(repository.ExistsXMMC(planArrange.XMMC))
            {
                throw new DomainException("项目名称已存在");
            }
            CheckOverPlus(planArrange, isUpdate);
        }

        /// <summary>
        /// 判断剩余指标是否足够
        /// <p>总指标等于指标分解中预留部分，如果是县级，那么等于市级下发给县级的</p>
        /// <p>剩余指标等于总指标-下发的指标（包含项目已下发和未下发的项目）</p>
        /// </summary>
        /// <param name="planArrange"></param>
        private void CheckOverPlus(PlanArrange planArrange, bool isUpdate)
        {
            //总指标数，这里是不是应该用领域事件呢
            IndicatorArea totalIndicator = null;
            if (planArrange.ZBJB == IndicatorGrade.Province || planArrange.ZBJB == IndicatorGrade.City)
            {
                totalIndicator = indicatorRepository.TotalReserveIndicator(planArrange.ND, planArrange.XZQDM);
            }
            else if (planArrange.ZBJB == IndicatorGrade.County)
            {
                totalIndicator = indicatorRepository.TotalReceiveIndicator(planArrange.ND, planArrange.XZQDM);
            }
            if (totalIndicator != null)
            {
                //计划单位是亩
                var xfIndicator = repository.TotalSendToIndicator(planArrange.ND, planArrange.XZQDM);
                xfIndicator += planArrange.JHSY;
                if (isUpdate)
                {
                    var original = repository.Find(planArrange.Id);
                    xfIndicator -= original.JHSY;
                }
                if (GreaterThan(xfIndicator.GD, totalIndicator.GD))
                {
                    throw new DomainException("耕地剩余指标不足");
                }
                if (GreaterThan(xfIndicator.NYD, totalIndicator.NYD))
                {
                    throw new DomainException("农用地剩余指标不足");
                }
                if (GreaterThan(xfIndicator.WLYD, totalIndicator.WLYD))
                {
                    throw new DomainException("未利用地剩余指标不足");
                }
            }
        }

        /// <summary>
        ///
        /// </summary>
        /// <param name="mu"></param>
        /// <param name="hectare"></param>
        /// <returns></returns>
        private bool GreaterThan(decimal mu, decimal hectare)
        {
            decimal left = 0;
            decimal right = 0;
            if (mu > 0 && mu % 15 == 0)
            {
                left = mu / 15;
                right = hectare;
            }
            else
            {
                left = mu * 666.6666667M;
                right = hectare * 10000;
            }
            return left > right;
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using DDD.Infrastructure;

namespace DDD.Domain.Indicator
{
    /// <summary>
    /// 计划指标登记服务
    /// </summary>
    public class IndicatorService
    {
        private readonly IPlanIndicatorRepository repository;

        public IndicatorService(IPlanIndicatorRepository repository)
        {
            this.repository = repository;
        }

        /// <summary>
        /// 登记指标项目，如果是国家级别，那么projects为空
        /// </summary>
        /// <param name="planIndicator"></param>
        /// <param name="planIndicators"></param>
        public void Register(PlanIndicator planIndicator, IList<PlanIndicator> planIndicators)
        {
            if (planIndicator.ZBJB != IndicatorGrade.Country)
            {
                var totalArea = planIndicator.IndicatorArea +
                                IndicatorArea.Sum(planIndicators.Select(t => t.IndicatorArea));
                CheckAndThrow(planIndicator, totalArea, false);
                //保证聚合完整性
                foreach (var item in planIndicators)
                {
                    item.APPC = planIndicator.APPC;
                    item.ND = planIndicator.ND;
                    item.XZQDM = planIndicator.XZQDM;
                    item.Register();
                }
            }
            planIndicator.Register();
        }

        /// <summary>
        /// 这个方法是修改的时候调用判断的
        /// </summary>
        /// <param name="planIndicator"></param>
        public void CheckUpdate(PlanIndicator planIndicator)
        {
            CheckAndThrow(planIndicator, planIndicator.IndicatorArea, true);
        }

        /// <summary>
        /// 这个方法是修改的时候调用判断的
        /// </summary>
        /// <param name="planIndicator"></param>
        private void CheckAndThrow(PlanIndicator planIndicator,IndicatorArea area, bool isUpdate)
        {
            var original = isUpdate ? repository.Find(planIndicator.Id) : null;
            if (repository.IsSent(planIndicator.APPC, planIndicator.ND, planIndicator.XZQDM))
            {
                throw new DomainException("批次已下发，不允许登记或修改");
            }
            //下发的时候判断，一个行政区只能一个文号
            if (planIndicator.XFXZQDM != planIndicator.XZQDM)
            {
                if (isUpdate)
                {
                    if(original.XFXZQDM != planIndicator.XFXZQDM && Exists(planIndicator))
                    {
                        throw new DomainException("同一批次中，不允许对同一个行政区下发多次");
                    }
                }
                else if(Exists(planIndicator))
                {
                    throw new DomainException("同一批次中，不允许对同一个行政区下发多次");
                }
            }
            var overIndicator = TotalOverPlusIndicator(planIndicator.ND, planIndicator.XZQDM);
            if (isUpdate)
            {
                overIndicator += original.IndicatorArea;
            }
            if (area.NYD > overIndicator.NYD)
            {
                throw new DomainException("农用地剩余指标不足");
            }
            if (area.GD > overIndicator.GD)
            {
                throw new DomainException("耕地剩余指标不足");
            }
            if (area.WLYD > overIndicator.WLYD)
            {
                throw new DomainException("未利用地剩余指标不足");
            }
        }

        /// <summary>
        /// 获取剩余指标
        /// </summary>
        /// <param name="year"></param>
        /// <param name="xzqdm"></param>
        /// <returns></returns>
        private IndicatorArea TotalOverPlusIndicator(int year, string xzqdm)
        {
            return repository.TotalReceiveIndicator(year, xzqdm) - repository.TotalReserveIndicator(year, xzqdm) - repository.TotalSendToIndicator(year, xzqdm);
        }

        private bool Exists(PlanIndicator planIndicator)
        {
            return repository.Exists(planIndicator.APPC, planIndicator.ND, planIndicator.XZQDM, planIndicator.XFXZQDM);
        }
    }
}

　　

时间： 2024-08-02 06:51:47

DDD领域驱动设计之领域服务的相关文章

领域驱动设计的面向服务架构

[.NET领域驱动设计实战系列]专题二:结合领域驱动设计的面向服务架构来搭建网上书店 一.前言 在前面专题一中,我已经介绍了我写这系列文章的初衷了.由于dax.net中的DDD框架和Byteart Retail案例并没有对其形成过程做一步步分析,而是把整个DDD的实现案例展现给我们,这对于一些刚刚接触领域驱动设计的朋友可能会非常迷茫,从而觉得领域驱动设计很难,很复杂,因为学习中要消化一个整个案例的知识,这样未免很多人消化不了就打退堂鼓,就不继续研究下去了,所以这样也不利于DDD的推广.然而本系列

[.NET领域驱动设计实战系列]专题二：结合领域驱动设计的面向服务架构来搭建网上书店

一.前言 在前面专题一中,我已经介绍了我写这系列文章的初衷了.由于dax.net中的DDD框架和Byteart Retail案例并没有对其形成过程做一步步分析,而是把整个DDD的实现案例展现给我们,这对于一些刚刚接触领域驱动设计的朋友可能会非常迷茫,从而觉得领域驱动设计很难,很复杂,因为学习中要消化一个整个案例的知识,这样未免很多人消化不了就打退堂鼓,就不继续研究下去了,所以这样也不利于DDD的推广.然而本系列可以说是刚接触领域驱动设计朋友的福音,本系列将结合领域驱动设计的思想来一步步构建一个网

DDD领域驱动设计之领域基础设施层

1.DDD领域驱动设计实践篇之如何提取模型 2.DDD领域驱动设计之聚合.实体.值对象 其实这里说的基础设施层只是领域层的一些接口和基类而已,没有其他的如日子工具等代码,仅仅是为了说明领域层的一些基础问题 1.领域事件简单实现代码,都是来至ASP.NET设计模式书中的代码 namespace DDD.Infrastructure.Domain.Events { public interface IDomainEvent { } } namespace DDD.Infrastructure.Dom

领域驱动设计:分离领域

本章大部分内容摘自:<领域驱动设计:软件核心复杂性应对之道>一书中的第四章,分离领域,纯属原创.如有错误请指正,相互学习. 模式:LAYERED ARCHITECTURE (分层结构) 在面向对象的程序中,常常会在业务对象中直接写入用户界面.数据库访问等支持代码.而一些额外的业务逻辑则会被嵌入到用户界面组件和数据库脚本的行为中.这么做是为了以最简单的方式在短期内完成开发工作. 如果与领域有关的代码大量分散在大量的其他代码之中,那么查看和分析领域代码就会变得相当困难.对用户界面的简单修改实际上很

微服务架构设计基础之领域驱动设计

DDD早于微服务「出道」十年,这两个「忘年交」的软件设计哲学是如何相爱相杀的? 背景 微服务现在可以说是软件研发领域无人不提的话题,然而业界流行的对比多数都是所谓的Monolithic(单体应用),而大量的系统在十几年前都已经是以SOA(面向服务架构)为基础的分布式系统了,那么微服务作为新的架构标准与SOA有什么差异点呢?其本质区别在于设计原理,微服务是去中心化设计,SOA是「集成」形成中心设计: 另外,笔者认为以下几点并不是微服务和SOA的区别点: CI/CD:持续集成.持续部署本身与敏捷.D

领域驱动设计 ——一种将概念模型化的方式

原文发布于:http://www.gufeng.tech/ 1.引子 2004年Eric Evans 发表了一本书:<Domain-Driven Design: Tackling Complexity in the Heart of Software>(中文名:<领域驱动设计:软件核心复杂性应对之道>),在这本书中作者提出了领域驱动设计(DDD)的概念,到现在已经10多年的时间了. 1.1 面向对象与面向对象语言 面向对象思想已经存在相当长的历史了(相对于软件的历史),我而们使用的

EntityFramework之领域驱动设计实践

EntityFramework之领域驱动设计实践 - 前言 EntityFramework之领域驱动设计实践 (一):从DataTable到EntityObject EntityFramework之领域驱动设计实践 (二):分层架构 EntityFramework之领域驱动设计实践 (三):案例:一个简易的销售系统 EntityFramework之领域驱动设计实践 (四):存储过程 - 领域驱动的反模式 EntityFramework之领域驱动设计实践 (五):聚合 EntityFramewor

Re：从零开始的领域驱动设计

领域驱动的火爆程度不用我赘述,但是即便其如此得耳熟能详,但大多数人对其的认识,还只是停留在知道它的缩写是DDD,知道它是一种软件思想,或者知道它和微服务有千丝万缕的关系.Eric Evans对DDD的诠释是那么地惜字如金,而我所认识的领域驱动设计的专家又都是行业中的资深前辈,他们擅长于对软件设计进行高屋建瓴的论述,如果没有丰富的互联网从业经验,是不能从他们的分享中获取太多的营养的,可以用曲高和寡来形容.1000个互联网从业者,100个懂微服务,10个人懂领域驱动设计. 可能有很多和我一样的读者,

NET 领域驱动设计实战系列总结

NET 领域驱动设计实战系列总结 一.引用 其实在去年本人已经看过很多关于领域驱动设计的书籍了,包括Microsoft .NET企业级应用框架设计.领域驱动设计C# 2008实现.领域驱动设计:软件核心复杂性应对之道.实现领域驱动设计和Asp.net 设计模式等书,但是去年的学习仅仅限制于看书,当时看下来感觉,领域驱动设计并没有那么难,并且感觉有些领域驱动设计的内容并没有好的,反而觉得有点华而不实的感觉,所以去年也就放弃了领域驱动设计系列的分享了,但是到今年,在博客园看到还是有很多人写领域驱动的