fusenapi/model/gmodel/fs_address_logic.go

package gmodel

import (
	"context"

	"gorm.io/gorm"
)

func (a *FsAddressModel) GetOne(ctx context.Context, id int64, userId int64) (resp *FsAddress, err error) {
	err = a.db.WithContext(ctx).Model(&FsAddress{}).Where("`id` = ? and `user_id` = ? and `status` = ? ", id, userId, 1).Take(&resp).Error
	return resp, err
}

func (a *FsAddressModel) GetUserAllAddress(ctx context.Context, userId int64) (resp []FsAddress, err error) {
	err = a.db.WithContext(ctx).Model(&FsAddress{}).Where("`user_id` = ? and `status` = ?", userId, 1).Order("`id` DESC").Find(&resp).Error
	if err != nil {
		return nil, err
	}
	return
}

func (a *FsAddressModel) CreateOne(ctx context.Context, address *FsAddress) (result *FsAddress, err error) {

	err = a.db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
		// now := time.Now().UTC().Unix()
		result = &FsAddress{
			UserId:      address.UserId,
			AddressName: address.AddressName,
			FirstName:   address.FirstName,
			LastName:    address.LastName,
			Mobile:      address.Mobile,
			Street:      address.Street,
			Suite:       address.Suite,
			City:        address.City,
			State:       address.State,
			Country:     address.Country,
			ZipCode:     address.ZipCode,
			Status:      address.Status,
			IsDefault:   address.IsDefault,
		}

		return tx.Create(result).Error
	})

	if err != nil {
		return nil, err
	}

	return result, nil
}

func (a *FsAddressModel) UpdateAddAddress(ctx context.Context, address *FsAddress) (err error) {
	err = a.db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
		if *address.IsDefault > 0 {
			err = tx.Model(&FsAddress{}).Where("user_id = ? and is_default = 1 ", address.UserId).Update("is_default", 0).Error
			if err != nil {
				return err
			}
		}
		return tx.Model(&FsAddress{}).Where("id = ? and user_id = ?", address.AddressId, address.UserId).Omit("id", "user_id").Updates(address).Error
	})
	return err
}