- set dynamic token when starting up.
This commit is contained in:
@@ -218,8 +218,7 @@ func (s *DefScheduler) createWaybillOn3rdProviders(order *model.GoodsOrder, excl
|
||||
func (s *DefScheduler) cancelOtherWaybills(savedOrderInfo *WatchOrderInfo, bill *model.Waybill) (err error) {
|
||||
globals.SugarLogger.Debugf("cancelOtherWaybills, order:%v, bill:%v", savedOrderInfo.order, bill)
|
||||
for _, v := range savedOrderInfo.waybills {
|
||||
if bill == nil || (v.WaybillVendorID != bill.OrderVendorID && !(v.WaybillVendorID == bill.WaybillVendorID && v.VendorWaybillID == bill.VendorWaybillID)) {
|
||||
globals.SugarLogger.Debugf("cancelOtherWaybills, cancel bill:%v", v)
|
||||
if (v.OrderVendorID != v.WaybillVendorID) && (bill == nil || !(v.WaybillVendorID == bill.WaybillVendorID && v.VendorWaybillID == bill.VendorWaybillID)) {
|
||||
_ = s.GetDeliveryPlatformFromVendorID(v.WaybillVendorID).CancelWaybill(v)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -36,7 +36,7 @@ func RefreshConfig(configKey string, expiresTime time.Duration, configGetter fun
|
||||
if sleepGap > maxRefreshGap {
|
||||
sleepGap = maxRefreshGap
|
||||
}
|
||||
refreshFunc := func() error {
|
||||
refreshFunc := func() (string, error) {
|
||||
curConfig := &models.Config{
|
||||
Thirdparty: configKey,
|
||||
}
|
||||
@@ -46,22 +46,18 @@ func RefreshConfig(configKey string, expiresTime time.Duration, configGetter fun
|
||||
if err := db.Read(curConfig, "Thirdparty"); err != nil {
|
||||
if err != orm.ErrNoRows {
|
||||
globals.SugarLogger.Errorf("db error:%v, curConfig:%v", err, curConfig)
|
||||
return err
|
||||
} else {
|
||||
curConfig.Token = configGetter()
|
||||
return "", err
|
||||
}
|
||||
handleType = 2
|
||||
}
|
||||
} else {
|
||||
latestTimeStr := utils.Time2Str(time.Now().Add(-needRefreshGap))
|
||||
if curConfig.Date <= latestTimeStr {
|
||||
if curConfig.Token = configGetter(); curConfig.Token == "" {
|
||||
return fmt.Errorf("can not get token for %s", configKey)
|
||||
}
|
||||
} else if curConfig.Date <= utils.Time2Str(time.Now().Add(-needRefreshGap)) {
|
||||
handleType = 1
|
||||
}
|
||||
}
|
||||
if handleType != 0 {
|
||||
if curConfig.Token = configGetter(); curConfig.Token == "" {
|
||||
return "", fmt.Errorf("can not get token for %s", configKey)
|
||||
}
|
||||
globals.SugarLogger.Debugf("refresh %s, value:%s", configKey, curConfig.Token)
|
||||
|
||||
curConfig.Date = utils.GetCurTimeStr()
|
||||
var num int64
|
||||
var err error
|
||||
@@ -73,15 +69,16 @@ func RefreshConfig(configKey string, expiresTime time.Duration, configGetter fun
|
||||
}
|
||||
if err != nil || num == 0 {
|
||||
globals.SugarLogger.Errorf("db error:%v, num:%d, curConfig:%v", err, num, curConfig)
|
||||
return err
|
||||
return "", err
|
||||
} else {
|
||||
configSetter(curConfig.Token)
|
||||
}
|
||||
}
|
||||
return nil
|
||||
return curConfig.Token, nil
|
||||
}
|
||||
err := refreshFunc() // 这样写的目的是强制第一次调用时要刷新一次
|
||||
token, err := refreshFunc() // 这样写的目的是强制第一次调用时要刷新一次
|
||||
if err == nil {
|
||||
configSetter(token)
|
||||
go func() {
|
||||
for {
|
||||
time.Sleep(sleepGap)
|
||||
|
||||
Reference in New Issue
Block a user