func (r *PayoutRepository) Payout(advertiserID, partnerID string, amount float32) error {
advertiser, err := r.find(totalPayouts) // транзакция қосу
егер err != nil {
қайтару err
}
партнер, err := r.find(partnerID)
егер err != nil {
қайтару err
}
рекламодател, Бейланс -= сумма
партнер.Hold -= сумма
партнер.Баланса += сумма
егер err := r.save(рекламодател); err != nil {
қайтару err
}
егер err := r.save(партнер); err != nil {
қайтару err
}
r.totalPayouts++
қайтару nil
}
функция (r *PayoutRepository) find(id string) (Partner, error) {
p := Partner{}
err := r.db.QueryRow("SELECT * FROM partners WHERE id = " + id).Scan(&p) // $1 қосу
егер err != nil {
егер err == sql.ErrNoRows {
қайтару p, errors.New("серіктес табылмады")
}
қайтару p, err
}
қайтару p, nil
}