Bladeren bron

update

three
DengBiao 1 jaar geleden
bovenliggende
commit
ee8ce6213b
4 gewijzigde bestanden met toevoegingen van 8 en 8 verwijderingen
  1. +2
    -2
      consume/dou_shen_user_register_for_my_my_fans.go
  2. +2
    -2
      consume/dou_shen_user_register_for_my_my_recommender.go
  3. +2
    -2
      consume/dou_shen_user_register_for_official_consume.go
  4. +2
    -2
      consume/dou_shen_user_register_for_operation_center.go

+ 2
- 2
consume/dou_shen_user_register_for_my_my_fans.go Bestand weergeven

@@ -64,7 +64,7 @@ func DouShenUserRegisterConsumeForMyFans(queue md.MqQueue) {
}

func handleDouShenUserRegisterConsumeForMyFans(msgData []byte) error {
time.Sleep(time.Duration(10) * time.Second)
time.Sleep(time.Duration(15) * time.Second)
//1、解析mq中queue的数据结构体
var msg *md.DouShenUserRegisterMessageStructForMyFans
err := json.Unmarshal(msgData, &msg)
@@ -100,7 +100,7 @@ func handleDouShenUserRegisterConsumeForMyFans(msgData []byte) error {
IsAutoAddedFriends: 0,
})
if err != nil {
return err
return errors.New("用户暂未注册im系统")
}
gimUser, err = db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{
"key": "id",


+ 2
- 2
consume/dou_shen_user_register_for_my_my_recommender.go Bestand weergeven

@@ -63,7 +63,7 @@ func DouShenUserRegisterConsumeForMyRecommender(queue md.MqQueue) {
}

func handleDouShenUserRegisterConsumeForMyRecommender(msgData []byte) error {
time.Sleep(time.Duration(10) * time.Second)
time.Sleep(time.Duration(20) * time.Second)
//1、解析mq中queue的数据结构体
var msg *md.DouShenUserRegisterMessageStructForMyRecommender
err := json.Unmarshal(msgData, &msg)
@@ -99,7 +99,7 @@ func handleDouShenUserRegisterConsumeForMyRecommender(msgData []byte) error {
IsAutoAddedFriends: 0,
})
if err != nil {
return err
return errors.New("用户暂未注册im系统")
}
gimUser, err = db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{
"key": "id",


+ 2
- 2
consume/dou_shen_user_register_for_official_consume.go Bestand weergeven

@@ -63,7 +63,7 @@ func DouShenUserRegisterConsumeForOfficial(queue md.MqQueue) {
}

func handleDouShenUserRegisterConsumeForOfficial(msgData []byte) error {
time.Sleep(time.Duration(10) * time.Second)
time.Sleep(time.Duration(5) * time.Second)
//1、解析mq中queue的数据结构体
var msg *md.DouShenUserRegisterMessageStructForOfficial
err := json.Unmarshal(msgData, &msg)
@@ -99,7 +99,7 @@ func handleDouShenUserRegisterConsumeForOfficial(msgData []byte) error {
IsAutoAddedFriends: 0,
})
if err != nil {
return err
return errors.New("用户暂未注册im系统")
}
gimUser, err = db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{
"key": "id",


+ 2
- 2
consume/dou_shen_user_register_for_operation_center.go Bestand weergeven

@@ -64,7 +64,7 @@ func DouShenUserRegisterConsumeForOperationCenter(queue md.MqQueue) {
}

func handleDouShenUserRegisterConsumeForOperationCenter(msgData []byte) error {
time.Sleep(time.Duration(10) * time.Second)
time.Sleep(time.Duration(30) * time.Second)
//1、解析mq中queue的数据结构体
var msg *md.DouShenUserRegisterMessageStructForOperationCenter
err := json.Unmarshal(msgData, &msg)
@@ -100,7 +100,7 @@ func handleDouShenUserRegisterConsumeForOperationCenter(msgData []byte) error {
IsAutoAddedFriends: 0,
})
if err != nil {
return err
return errors.New("用户暂未注册im系统")
}
gimUser, err = db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{
"key": "id",


Laden…
Annuleren
Opslaan