1

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
 }