fix: subscribe duration and expired error
This commit is contained in:
@@ -63,20 +63,25 @@ func (s *SubscribeService) PayBack(outTradeNo string) int {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 创建订阅信息
|
// 创建订阅信息
|
||||||
expired := order.Duration * 24 * 60 * 60
|
duration := order.Duration * 24 * 60 * 60
|
||||||
if !s.subscribeDao.IsExists(order.Uid) {
|
if !s.subscribeDao.IsExists(order.Uid) {
|
||||||
subscribe := models.SubscribeCreateParam{
|
subscribe := models.SubscribeCreateParam{
|
||||||
Uid: order.Uid,
|
Uid: order.Uid,
|
||||||
Version: 2,
|
Version: 2,
|
||||||
Expired: expired,
|
Expired: time.Now().Unix() + duration,
|
||||||
}
|
}
|
||||||
if err := s.subscribeDao.Create(&subscribe); err != nil {
|
if err := s.subscribeDao.Create(&subscribe); err != nil {
|
||||||
return response.ErrCodeFailed
|
return response.ErrCodeFailed
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
si, err := s.subscribeDao.GetInfo(order.Uid)
|
||||||
|
if err != nil {
|
||||||
|
return response.ErrCodeFailed
|
||||||
|
}
|
||||||
subscribe := models.SubscribeUpdateParam{
|
subscribe := models.SubscribeUpdateParam{
|
||||||
Uid: order.Uid,
|
Uid: order.Uid,
|
||||||
Expired: expired,
|
Version: 2,
|
||||||
|
Expired: si.Expired + duration,
|
||||||
}
|
}
|
||||||
if err := s.subscribeDao.Update(&subscribe); err != nil {
|
if err := s.subscribeDao.Update(&subscribe); err != nil {
|
||||||
return response.ErrCodeFailed
|
return response.ErrCodeFailed
|
||||||
|
|||||||
Reference in New Issue
Block a user