xps-server-go/repositories/biz_object_oam_params_repo.go

package repositories

import (
    "errors"
    "fmt"
    "xorm.io/xorm"
    "xps/datamodels"
    "xps/viewmodels"
)

type BizObjectOAMParamsRepo struct {
    engine *xorm.Engine
}

func NewBizObjectOAMParamsRepo(engine *xorm.Engine) *BizObjectOAMParamsRepo {
    return &BizObjectOAMParamsRepo{
        engine: engine,
    }
}

func (d *BizObjectOAMParamsRepo) GetList(m map[string]interface{}) ([]viewmodels.BizObjectOAMParamsInfo, error) {
    sqlSelect  := ` SELECT A.*,
                           B.object_title,
                           B.object_code,
                           B.object_type,
                           C.oam_title,
                           D.attr_title AS target_attr_title,
                           D.attr_code  AS target_attr_code,
                           R.rule_title `
    sqlFrom    := ` FROM      biz_object_oam_params AS A
                    LEFT JOIN biz_object            AS B ON (A.biz_id = B.biz_id AND A.object_id = B.object_id)
                    LEFT JOIN biz_object_oam        AS C ON (A.biz_id = C.biz_id AND A.object_id = C.object_id AND A.oam_id = C.oam_id) `
    sqlWhere   := ` WHERE A.deleted_flag = 0    `
    if bizId, ok := m["bizId"]; ok {
        sqlWhere += fmt.Sprintf(" AND A.biz_id = %d ", bizId)
    }
    if objectId, ok := m["objectId"]; ok {
        sqlWhere += fmt.Sprintf(" AND A.object_id = %d ", objectId)
    }
    if oamId, ok := m["oamId"]; ok {
        sqlWhere += fmt.Sprintf(" AND A.oam_id = %d ", oamId)
    }
    sqlOrderBy := " ORDER BY A.params_id ASC "
    
    datalist   := make([]viewmodels.BizObjectOAMParamsInfo, 0)
    err := d.engine.SQL(sqlSelect + sqlFrom + sqlWhere + sqlOrderBy).Find(&datalist)
    if err != nil {
        return nil, err
    } else {
        return datalist, nil
    }
}

func (d *BizObjectOAMParamsRepo) GetById(bizId, objectId, oamId, orId int64) (*viewmodels.BizObjectOAMParamsInfo, error) {
    sqlSelect  := ` SELECT A.*,
                           B.object_title,
                           B.object_code,
                           B.object_type,
                           C.oam_title,
                           D.attr_title AS target_attr_title,
                           D.attr_code  AS target_attr_code,
                           R.rule_title `
    sqlFrom    := ` FROM      biz_object_oam_params AS A
                    LEFT JOIN biz_object            AS B ON (A.biz_id = B.biz_id AND A.object_id = B.object_id)
                    LEFT JOIN biz_object_oam        AS C ON (A.biz_id = C.biz_id AND A.object_id = C.object_id AND A.oam_id = C.oam_id) `
    sqlWhere   := ` WHERE A.deleted_flag = 0    `
    sqlWhere   += fmt.Sprintf(" AND A.biz_id    = %d ", bizId)
    sqlWhere   += fmt.Sprintf(" AND A.object_id = %d ", objectId)
    sqlWhere   += fmt.Sprintf(" AND A.oam_id    = %d ", oamId)
    sqlWhere   += fmt.Sprintf(" AND A.or_id     = %d ", orId)
    
    data    := &viewmodels.BizObjectOAMParamsInfo{}
    has, err := d.engine.SQL(sqlSelect + sqlFrom + sqlWhere).Get(data)
    if !has || err != nil {
        return nil, err
    } else {
        return data, nil
    }
}

func (d *BizObjectOAMParamsRepo) GetListById(bizId, objectId, oamId int64) ([]viewmodels.BizObjectOAMParamsInfo, error) {
    sqlSelect  := ` SELECT A.*,
                           B.object_title,
                           B.object_code,
                           B.object_type,
                           C.oam_title,
                           D.attr_title AS target_attr_title,
                           D.attr_code  AS target_attr_code,
                           R.rule_title `
    sqlFrom    := ` FROM      biz_object_oam_params AS A
                    LEFT JOIN biz_object            AS B ON (A.biz_id = B.biz_id AND A.object_id = B.object_id)
                    LEFT JOIN biz_object_oam        AS C ON (A.biz_id = C.biz_id AND A.object_id = C.object_id AND A.oam_id = C.oam_id) `
    sqlWhere   := ` WHERE A.deleted_flag = 0    `
    sqlWhere   += fmt.Sprintf(" AND A.biz_id    = %d ", bizId)
    sqlWhere   += fmt.Sprintf(" AND A.object_id = %d ", objectId)
    sqlWhere   += fmt.Sprintf(" AND A.oam_id    = %d ", oamId)
    
    sqlOrderBy := " ORDER BY A.sort_no "
    dataList    := make([]viewmodels.BizObjectOAMParamsInfo, 0)
    err := d.engine.SQL(sqlSelect + sqlFrom + sqlWhere + sqlOrderBy).Find(&dataList)
    if err != nil {
        return nil, err
    } else {
        return dataList, nil
    }
}


func (d *BizObjectOAMParamsRepo) Create(data *datamodels.BizObjectOAMParams) error {
    _, err := d.engine.Insert(data)
    return err
}

func (d *BizObjectOAMParamsRepo) Update(data *datamodels.BizObjectOAMParams) error {
    bizId     := data.BizId
    objectId  := data.ObjectId
    oamId     := data.OamId
    paramsId  := data.ParamsId
    _, err := d.engine.
        Where("biz_id = ?", bizId).
        Where("object_id = ?", objectId).
        Where("oam_id = ?", oamId).
        Where("params_id = ?", paramsId).
        AllCols().
        Update(data)
    return err
}

func (d *BizObjectOAMParamsRepo) Delete(m map[string]interface{}) error {
    bizId, ok1 := m["bizId"]
    objectId, ok2 := m["objectId"]
    oamId, ok3 := m["oamId"]
    paramsId, ok4 := m["paramsId"]
    if !ok1 || !ok2 || !ok3 || !ok4 {
        return errors.New("数据不完整")
    }
    data := &datamodels.BizObjectOAMParams{}
    _, err := d.engine.
        Where("biz_id = ?", bizId).
        Where("object_id = ?", objectId).
        Where("oam_id = ?", oamId).
        Where("params_id = ?", paramsId).
        Delete(data)
    return err
}

func (d *BizObjectOAMParamsRepo) DeleteByObjectId(bizId, objectId, oamId int64) error {
    data := &datamodels.BizObjectOAMParams{}
    _, err := d.engine.
        Where("biz_id = ?", bizId).
        Where("object_id = ?", objectId).
        Where("oam_id = ?", oamId).
        Delete(data)
    return err
}