shanshanzhong
1d81df6664
Some checks failed
Build docker and publish / build (20.15.1) (push) Has been cancelled
61 lines
1.7 KiB
Go
61 lines
1.7 KiB
Go
package task
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/hibiken/asynq"
|
|
"github.com/perfect-panel/server/internal/svc"
|
|
"github.com/perfect-panel/server/pkg/exchangeRate"
|
|
"github.com/perfect-panel/server/pkg/logger"
|
|
"github.com/perfect-panel/server/pkg/tool"
|
|
)
|
|
|
|
type RateLogic struct {
|
|
svcCtx *svc.ServiceContext
|
|
}
|
|
|
|
func NewRateLogic(svcCtx *svc.ServiceContext) *RateLogic {
|
|
return &RateLogic{
|
|
svcCtx: svcCtx,
|
|
}
|
|
}
|
|
|
|
func (l *RateLogic) ProcessTask(ctx context.Context, _ *asynq.Task) error {
|
|
// Retrieve system currency configuration
|
|
currency, err := l.svcCtx.SystemModel.GetCurrencyConfig(ctx)
|
|
if err != nil {
|
|
logger.Errorw("[PurchaseCheckout] GetCurrencyConfig error", logger.Field("error", err.Error()))
|
|
return err
|
|
}
|
|
// Parse currency configuration
|
|
configs := struct {
|
|
CurrencyUnit string
|
|
CurrencySymbol string
|
|
AccessKey string
|
|
FixedRate float64
|
|
}{}
|
|
tool.SystemConfigSliceReflectToStruct(currency, &configs)
|
|
|
|
// Check if fixed rate is enabled (greater than 0)
|
|
if configs.FixedRate > 0 {
|
|
l.svcCtx.ExchangeRate = configs.FixedRate
|
|
logger.WithContext(ctx).Infof("[RateLogic] Use Fixed Exchange Rate: %f", configs.FixedRate)
|
|
return nil
|
|
}
|
|
|
|
// Skip conversion if no exchange rate API key configured
|
|
if configs.AccessKey == "" {
|
|
logger.Debugf("[RateLogic] skip exchange rate, no access key configured")
|
|
return nil
|
|
}
|
|
// Update exchange rates
|
|
result, err := exchangeRate.GetExchangeRete(configs.CurrencyUnit, "CNY", configs.AccessKey, 1)
|
|
if err != nil {
|
|
logger.Errorw("[RateLogic] GetExchangeRete error", logger.Field("error", err.Error()))
|
|
return err
|
|
}
|
|
l.svcCtx.ExchangeRate = result
|
|
logger.WithContext(ctx).Infof("[RateLogic] GetExchangeRete success, result: %+v", result)
|
|
return nil
|
|
}
|