LS5zXhit

1public function getAllUplineId($id,$i,$position,$profile_field_id){
2$select = "SELECT father_id
3            FROM 161_ft_individual
4            WHERE id=$id ";
5$result = db_query($select);    
6while($node = db_fetch_object($result))
7    {
8    $user_id = $node->father_id;   
9    if($user_id > 0)
10        {
11        $amount = 1;        
12        $this->update_profile_value($user_id,$profile_field_id,$amount);
13        $i=$i+1;         
14        $this->getAllUplineId($user_id,$i,$position,$profile_field_id);
15        }
16
17    }
18}
19
20public function update_profile_value($user_id,$profile_field_id,$amount){
21$query = "UPDATE 161_ft_individual SET total_leg=total_leg+$amount
22            WHERE id='$user_id' LIMIT 1";
23$result = db_query($query);    
24return $result;
25} 
26     
27DROP TABLE IF EXISTS fathers_to_update;
28CREATE TABLE fathers_to_update
29(
30    father_id INT NOT NULL,
31    PRIMARY KEY (father_id)
32); 
33     
34DROP TABLE IF EXISTS fathers_to_queue;
35CREATE TABLE fathers_to_queue
36(
37    father_id INT,
38    id INT NOT NULL AUTO_INCREMENT,
39    PRIMARY KEY (id)
40);
41INSERT INTO fathers_to_queue (father_id) VALUES (12); 
42     
43SELECT COUNT(1) FROM fathers_to_queue; 
44     
45SELECT MIN(id),father_id INTO @frontndx,@dad FROM fathers_to_queue;
46DELETE FROM fathers_to_queue WHERE id = @frontndx; 
47     
48INSERT INTO fathers_to_update SELECT father_id FROM 161_ft_individual WHERE id = @dad;
49INSERT INTO fathers_to_queue (father_id) SELECT father_id FROM 161_ft_individual WHERE id = @dad; 
50     
51UPDATE fathers_to_update A
52LEFT JOIN 161_ft_individual B
53USING (father_id)
54SET B.total_leg=B.total_leg+@amount;