软件工程之领域驱动设计

①用户接口层
// pkg: httpcontroller
func Routes(r *gin.Engine) {
    a := BuAlarmApi{}
    group := r.Group("/api/v1/bualarm")
    group.POST("/alarm", a.BuAlarm)
}
func (this *BuAlarmApi) BuAlarm(c *gin.Context) {
    bu := c.DefaultPostForm("bu", "")
    content := c.DefaultPostForm("content", "")
    username, err := this.GetUser(c)
    alarmDTO := dto.AlarmDTO{
        BudgetUnit:  bu,
        Content:     content,
        Sysname:     username,
    }
    err = app.BuAlarmApp.BuAlarm(alarmDTO)
    ...
    c.JSON(http.StatusOK, this.Success())
}


②应用层
// pkg: app
// 规范: 应用对象以全局变量方式对外暴露，目的是解耦类实现
var BuAlarmApp = new(BuAlarmAppplication)

// 依赖注入: 每个app文件，使用init函数完成注入
func init() {
    domain.BuAlarmDomainService.IMRepo = infra.IMRepo       // 依赖注入: 基础设施
    BuAlarmApp.domainBuAlarm = domain.BuAlarmDomainService  // 依赖注入: 领域
}

type BuAlarmAppplication struct {
    domainBuAlarm domain.BuAlarm
}
func (this *BuAlarmAppplication) BuAlarm(alarmDTO dto.AlarmDTO) error {
    alarmBO := bo.AlarmBO{
        BudgetUnit:  alarmDTO.BudgetUnit,
        Title:       alarmDTO.Title,
        Content:     alarmDTO.Content,
    }
    err = this.domainBuAlarm.AlarmByBu(alarmBO)
    ...
    return nil
}


③领域层(业务逻辑)
// pkg: domain
var BuAlarmDomainService = new(BuAlarmDomain)

// SPI: 基础设施接口定义
type IMRepo interface {
    SendIM(im *do.IM) error
}

// DomainService: 领域服务
type BuAlarmDomain struct {
    IMRepo     IMRepo     // IM基础设施
}
// API: 领域服务接口定义
func (this *BuAlarmDomain) AlarmByBu(alarmBO *bo.AlarmBO) (err error) {
    bu := strings.TrimSpace(alarmBO.BudgetUnit)
    ...
    imDO := do.IM{
        BU:      bu,
        Content: alarmBO.Content,
    }
    err = this.IMRepo.SendIM(&imDO)
    ...
    return nil
}


④基础设施层
// pkg: infra
// 规范: 基础设施对象以全局变量方式对外暴露，目的是解耦类实现、避免资源浪费
var IMRepo = new(IMSender)

// SP: 基础设施接口实现，IMSender实现IMRepo规定的SPI
type IMSender struct {
}
func (this *IMSender) SendIM(im *do.IM) (err error) {
    SendChat(im.Tos, im.Content)
    ...
    return nil
}

①用户接口层
package com.zyb.controller;
import com.zyb.application.BuAlarmApplication;
import com.zyb.application.dto.AlarmDTO;
import javax.annotation.Resource;

public class BuAlarmApi {
    @Resource
    private BuAlarmApplication buAlarmApplication;

    public void sendEvents(String metric){
        AlarmDTO alarmDTO = new AlarmDTO();
        alarmDTO.setMetric(metric);
        buAlarmApplication.buAlarm(alarmDTO);
    }
}


②应用层
package com.zyb.application;
import com.zyb.application.dto.AlarmDTO;
import com.zyb.domain.bualarm.bo.AlarmBO;
import org.springframework.stereotype.Service;
import com.zyb.domain.bualarm.service.*;
import javax.annotation.Resource;

@Service
public class BuAlarmApplicationImpl implements BuAlarmApplication {
    @Resource
    private BuAlarmDomainService buAlarmDomainService;

    @Override
    public boolean buAlarm(AlarmDTO alarmDTO) {
        AlarmBO alarmBO = new AlarmBO();
        alarmBO.setMetric(alarmDTO.getMetric());
        return buAlarmDomainService.alarmByBu(alarmBO);
    }
}


③领域层(业务逻辑)
package com.zyb.domain.bualarm.service;
import com.zyb.domain.bualarm.bo.AlarmBO;
import com.zyb.domain.bualarm.dependency.BuChatDependency;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;

@Service
public class BuAlarmDomainServiceImpl implements BuAlarmDomainService{
    @Resource
    private BuChatDependency buChatDependency;

    @Override
    public boolean alarmByBu(AlarmBO alarmBO) {
        buChatDependency.getBuChat(alarmBO.getMetric());
        return true;
    }
}


④基础设施层
package com.zyb.infrastructure;
import com.zyb.domain.bualarm.dataobject.BuChatDO;
import com.zyb.domain.bualarm.dependency.BuChatDependency;
import com.zyb.infrastructure.dao.BuChatMapper;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;

@Component
public class BuChatDependencyImpl implements BuChatDependency {
    @Resource
    private BuChatMapper buChatMapper;

    @Override
    public BuChatDO getBuChat(String bu) {
        return buChatMapper.getBuChat();
    }
}

// DAO
package com.zyb.infrastructure.dao;
import com.zyb.domain.bualarm.dataobject.BuChatDO;
import org.springframework.stereotype.Service;

@Service
public class BuChatMapper {
    public BuChatDO getBuChat(){
        return null;
    }
}