Browse Source

#2701

update point serialNo
pull/2885/head
chenyifan01 2 years ago
parent
commit
811e02e2ee
2 changed files with 5 additions and 21 deletions
  1. +0
    -17
      services/reward/operator.go
  2. +5
    -4
      services/reward/serial.go

+ 0
- 17
services/reward/operator.go View File

@@ -276,22 +276,5 @@ func generateOperateSerialNo(operateType models.RewardOperateType, rewardType mo


return "", err return "", err
} }

switch operateType {
case models.OperateTypeIncrease:
s += "1"
case models.OperateTypeDecrease:
s += "2"
default:
s += "9"
}

switch rewardType {
case models.RewardTypePoint:
s += "1"
default:
s += "9"
}

return s, nil return s, nil
} }

+ 5
- 4
services/reward/serial.go View File

@@ -11,13 +11,14 @@ import (


func GetSerialNoByRedis() (string, error) { func GetSerialNoByRedis() (string, error) {
now := time.Now() now := time.Now()
n, err := redis_client.IncrBy(redis_key.RewardSerialCounter(now), 1)
r := int64(rand.Intn(4)) + 1
n, err := redis_client.IncrBy(redis_key.RewardSerialCounter(now), r)
if err != nil { if err != nil {
log.Error("GetSerialNoByRedis RewardSerialCounter error. %v", err) log.Error("GetSerialNoByRedis RewardSerialCounter error. %v", err)
return "", err return "", err
} }
if n == 1 {
redis_client.Expire(redis_key.RewardSerialCounter(now), 5*time.Minute)
if n == r {
redis_client.Expire(redis_key.RewardSerialCounter(now), 2*time.Minute)
} }
return now.Format("200601021504") + fmt.Sprint(rand.Intn(10)) + fmt.Sprintf("%02d", n), nil
return now.Format("200601021504") + fmt.Sprintf("%03d", n) + fmt.Sprint(rand.Intn(10)), nil
} }

Loading…
Cancel
Save