eta_api/models/bi_approve/bi_approve_node.go

package biapprove

import (
	"eta_gn/eta_api/global"
	"fmt"
	"time"
)

type BiApproveNode struct {
	BiApproveNodeId int       `gorm:"column:bi_approve_node_id;primaryKey"`
	BiApproveFlowId int       `gorm:"column:bi_approve_flow_id"`
	PrevNodeId      int       `gorm:"column:prev_node_id"`
	NextNodeId      int       `gorm:"column:next_node_id"`
	NodeType        int       `gorm:"column:node_type"`
	ApproveType     int       `gorm:"column:approve_type"`
	Users           string    `gorm:"column:users"`
	CurrVersion     int       `gorm:"column:curr_version"`
	CreatedTime     time.Time `gorm:"column:created_time"`
}

func (b *BiApproveNode) TableName() string {
	return "bi_approve_node"
}

func UpdateNextNodes(nodes []*BiApproveNode) (err error) {
	if len(nodes) == 0 {
		return
	}
	updateCols := []string{"NextNodeId"}
	for _, v := range nodes {
		e := global.DmSQL["rddp"].Select(updateCols).Updates(v).Error
		if e != nil {
			err = fmt.Errorf("prev node update err: %v", e)
			return
		}
	}
	return
}

func GetBiApproveNodeByFlowIdAndVersionId(flowId int, versionId int) (node []*BiApproveNode, err error) {
	err = global.DmSQL["rddp"].Model(&BiApproveNode{}).Where("bi_approve_flow_id =? AND curr_version =?", flowId, versionId).Scan(&node).Error
	return
}