fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

info address default

Browse Source
This commit is contained in:
eson 2023-10-08 11:23:22 +08:00
parent 6aa842e328
commit 0410685138
1 changed files with 20 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
model/gmodel/fs_address_logic.go
View File

@ -14,7 +14,7 @@ func (a *FsAddressModel) GetOne(ctx context.Context, addressId int64, userId int
} }
func (a *FsAddressModel) GetUserAllAddress(ctx context.Context, userId int64) (resp []FsAddress, err error) { 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` = 1", userId).Order("`ctime` DESC").Find(&resp).Error err = a.db.WithContext(ctx).Model(&FsAddress{}).Where("`user_id` = ? and `status` = 1", userId).Order("`ltime` DESC").Find(&resp).Error
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -65,44 +65,31 @@ func (a *FsAddressModel) UpdateAddress(ctx context.Context, address *FsAddress)
return err return err
} }
func (a *FsAddressModel) SettingUserDefaultAddressMutex(ctx context.Context, userId int64, addressId int64, isDefault int64) (err error) {
err = a.db.WithContext(ctx).Model(&FsAddress{}).Transaction(func(tx *gorm.DB) error {
logx.Info("address_id:", addressId, " set default ", isDefault)
now := time.Now().UTC()
err = tx.Where("`user_id` = ? and `status` = 1 and `is_default` = 1", userId).
UpdateColumn("is_default", 0).
UpdateColumn("utime", now).Error
if err != nil {
return err
}
err = tx.Where("`address_id` = ? and `user_id` = ? and `status` = 1", addressId, userId).
UpdateColumn("is_default", isDefault).
UpdateColumn("ltime", now).
UpdateColumn("utime", now).Error
if err != nil {
return err
}
return nil
})
return err
}
func (a *FsAddressModel) SettingUserDefaultAddress(ctx context.Context, userId int64, addressId int64, isDefault int64) (err error) { func (a *FsAddressModel) SettingUserDefaultAddress(ctx context.Context, userId int64, addressId int64, isDefault int64) (err error) {
err = a.db.WithContext(ctx).Model(&FsAddress{}).Transaction(func(tx *gorm.DB) error { err = a.db.WithContext(ctx).Model(&FsAddress{}).Transaction(func(tx *gorm.DB) error {
logx.Info("address_id:", addressId, " set default ", isDefault) logx.Info("address_id:", addressId, " set default ", isDefault)
now := time.Now().UTC() now := time.Now().UTC()
err = tx.Where("`address_id` = ? and `user_id` = ? and `status` = 1", addressId, userId).
UpdateColumn("is_default", isDefault). if isDefault == 1 {
UpdateColumn("ltime", now). err = tx.Where("`user_id` = ? and `status` = 1 and `ltime` > ? and `address_id` != ?", userId, now.AddDate(10, 0, 0), addressId).
UpdateColumn("utime", now).Error UpdateColumn("ltime", now).
UpdateColumn("utime", now).Error
if err != nil {
return err
}
}
tr := tx.Where("`address_id` = ? and `user_id` = ? and `status` = 1", addressId, userId).
UpdateColumn("utime", now)
if isDefault == 1 {
tr.UpdateColumn("ltime", now.AddDate(250, 0, 0))
} else {
tr.UpdateColumn("ltime", now)
}
err = tr.Error
if err != nil { if err != nil {
return err return err
} }