diff --git a/consume/add_public_platoon_user_relation_commission.go b/consume/add_public_platoon_user_relation_commission.go index 0dea19f..1f6c009 100644 --- a/consume/add_public_platoon_user_relation_commission.go +++ b/consume/add_public_platoon_user_relation_commission.go @@ -66,6 +66,15 @@ func handleAddPublicPlatoonUserRelationCommissionConsume(msgData []byte) error { return err } + //3、加入公排 + var req []*md2.AddPublicPlatoonUserRelationCommissionReq + req = append(req, msg) + _, err = rule.AddPublicPlatoonUserRelationCommission(db.Db, req) + fmt.Println("err::::", err) + if err != nil { + return err + } + //2、给到直推奖励 eggEnergyBasicSettingDb := implement.NewEggEnergyBasicSettingDb(db.Db) eggEnergyBasicSetting, err := eggEnergyBasicSettingDb.EggEnergyBasicSettingGetOneByParams(map[string]interface{}{ @@ -96,14 +105,5 @@ func handleAddPublicPlatoonUserRelationCommissionConsume(msgData []byte) error { } session.Commit() } - - //3、加入公排 - var req []*md2.AddPublicPlatoonUserRelationCommissionReq - req = append(req, msg) - _, err = rule.AddPublicPlatoonUserRelationCommission(db.Db, req) - fmt.Println("err::::", err) - if err != nil { - return err - } return nil }