xps-server-g5/pkg/biz/repository/biz_object_oam_repo.go

package repository

import (
	"fmt"
	"time"
	"xorm.io/xorm"
	"xps/pkg/biz/datamodel"
	"xps/pkg/biz/viewmodel"
)

type BizObjectOAMRepo struct {
	engine *xorm.Engine
}

func NewBizObjectOAMRepo(engine *xorm.Engine) *BizObjectOAMRepo {
	return &BizObjectOAMRepo{
		engine: engine,
	}
}

func (d *BizObjectOAMRepo) GetList(m map[string]interface{}) ([]viewmodel.BizObjectOAMInfo, error) {
	sqlSelect 	:= ` 	SELECT     	A.*,
                           			B.object_title,
                           			B.object_code,
                           			B.object_type `
	sqlFrom 	:= ` 	FROM    	biz_object_oam AS A
                    	LEFT JOIN 	biz_object     AS B ON (A.biz_id = B.biz_id AND A.object_id = B.object_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 keywords, ok := m["keywords"]; ok {
		sqlWhere += ` AND A.oam_title like ` + "'%" + fmt.Sprintf("%s", keywords) + "%'"
	}
	sqlOrderBy := " ORDER BY A.oam_id ASC "

	datalist := make([]viewmodel.BizObjectOAMInfo, 0)
	err := d.engine.SQL(sqlSelect + sqlFrom + sqlWhere + sqlOrderBy).Find(&datalist)
	if err != nil {
		return nil, err
	} else {
		return datalist, nil
	}
}

func (d *BizObjectOAMRepo) GetListById(bizId, objectId int64) ([]viewmodel.BizObjectOAMInfo, error) {
	sqlSelect := ` SELECT    A.*,
                              B.object_title,
                              B.object_code,
                              B.object_type `
	sqlFrom := ` FROM      biz_object_oam AS A
                    LEFT JOIN biz_object     AS B ON (A.biz_id = B.biz_id AND A.object_id = B.object_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)
	sqlOrderBy := " ORDER BY A.oam_id ASC "

	datalist := make([]viewmodel.BizObjectOAMInfo, 0)
	err := d.engine.SQL(sqlSelect + sqlFrom + sqlWhere + sqlOrderBy).Find(&datalist)
	if err != nil {
		return nil, err
	} else {
		return datalist, nil
	}
}

func (d *BizObjectOAMRepo) GetById(bizId, objectId, oamId int64) (*viewmodel.BizObjectOAMInfo, error) {
	sqlSelect := ` SELECT    A.*,
                              B.object_title,
                              B.object_code,
                              B.object_type `
	sqlFrom := ` FROM      biz_object_oam AS A
                    LEFT JOIN biz_object     AS B ON (A.biz_id = B.biz_id AND A.object_id = B.object_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)
	data := &viewmodel.BizObjectOAMInfo{}
	has, err := d.engine.SQL(sqlSelect + sqlFrom + sqlWhere).Get(data)
	if !has || err != nil {
		return nil, err
	} else {
		return data, nil
	}
}

func (d *BizObjectOAMRepo) Create(data *datamodel.BizObjectOAM) error {
	data.CreatedAt = time.Now()
	_, err := d.engine.Insert(data)
	return err
}

func (d *BizObjectOAMRepo) Update(data *datamodel.BizObjectOAM) error {
	bizId := data.BizId
	objectId := data.ObjectId
	oamId := data.OamId
	data.UpdatedAt = time.Now()
	_, err := d.engine.
		Where("biz_id = ?", bizId).
		Where("object_id = ?", objectId).
		Where("oam_id = ?", oamId).
		AllCols().
		Update(data)
	return err
}

func (d *BizObjectOAMRepo) Delete(m map[string]interface{}) error {
	bizId := m["bizId"].(int64)
	objectId := m["objectId"].(int64)
	oamId := m["oamId"].(int64)
	deletedBy := m["deletedBy"].(int64)

	data := &datamodel.BizObjectOAM{}
	data.DeletedFlag = 1
	data.DeletedBy = deletedBy
	data.DeletedAt = time.Now()
	_, err := d.engine.
		Where("biz_id = ?", bizId).
		Where("object_id = ?", objectId).
		Where("oam_id = ?", oamId).
		Delete(data)
	return err
}

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