Golang领域模型-实体

type Entity interface {
    //发布领域事件
    DomainEvent(string,interface{},...map[string]string)
    //唯一ID
    Identity() string
    //获取请求运行时对象
    GetWorker() Worker
    SetProducer(string)
    Marshal() []byte
}

package entity

import (
    "errors"
    "strconv"

    "github.com/8treenet/freedom"
    "github.com/8treenet/freedom/example/fshop/domain/po"
)

const (
    //热销
    GoodsHotTag = "HOT"
    //新品
    GoodsNewTag  = "NEW"
    GoodsNoneTag = "NONE"
)

// 商品实体
type Goods struct {
    freedom.Entity //继承实体基类接口
    po.Goods //继承持久化的商品模型，包含了商品的列和属性方法
}

// Identity 唯一
func (g *Goods) Identity() string {
    return strconv.Itoa(g.Id)
}

// CutStock 扣库存
func (g *Goods) CutStock(num int) error {
    if num > g.Stock {
        return errors.New("库存不足")
    }
    g.AddStock(-num) //po对象的方法，增加库存
    return nil
}

// MarkedTag 为商品打tag
func (g *Goods) MarkedTag(tag string) error {
    if tag != GoodsHotTag && tag != GoodsNewTag && tag != GoodsNoneTag {
        return errors.New("Tag doesn't exist")
    }
    g.SetTag(tag) //po对象的方法，设置tag
    return nil
}

package entity

import (
    "errors"
    "strconv"

    "github.com/8treenet/freedom"
    "github.com/8treenet/freedom/example/fshop/domain/po"
)

// 用户实体
type User struct {
    freedom.Entity //继承实体基类接口
    po.User  //继承持久化的用户模型，包含了用户的列和属性方法
}

// Identity 唯一
func (u *User) Identity() string {
    return strconv.Itoa(u.Id)
}

// ChangePassword 修改密码
func (u *User) ChangePassword(newPassword, oldPassword string) error {
       //判断旧密码是否正确
    if u.Password != oldPassword {
        return errors.New("Password error")
    }
    u.SetPassword(newPassword) //po对象的方法，可以设置密码
    return nil
}

package entity

import (
    "github.com/8treenet/freedom"
    "github.com/8treenet/freedom/example/fshop/domain/po"
)

const (
    OrderStatusPAID       = "PAID" //付款
    OrderStatusNonPayment = "NON_PAYMENT" //未付款
    OrderStatusShipment   = "SHIPMENT" //发货
)

// 订单实体
type Order struct {
    freedom.Entity //继承实体基类接口
    po.Order  //继承持久化的订单模型，包含了订单的列和属性方法
    Details []*po.OrderDetail  //定义订单商品详情成员变量，一个订单包含多个商品
}

// Identity 唯一
func (o *Order) Identity() string {
    return o.OrderNo
}

// AddOrderDetal 增加订单详情
func (o *Order) AddOrderDetal(detal *po.OrderDetail) {
    o.Details = append(o.Details, detal) //增加订单详情，repository会做持久化处理
}

// Pay 付款
func (o *Order) Pay() {
    o.SetStatus(OrderStatusPAID) //po对象的方法，设置状态
}

// Shipment 发货
func (o *Order) Shipment() {
    o.SetStatus(OrderStatusShipment) //po对象的方法，设置状态
}

// IsPay 是否支付
func (o *Order) IsPay() bool {
        //判断是否付款
    if o.Status != OrderStatusPAID {
        return false
    }
    return true
}