<?php
/**
 * close-project-rewards.php
 * 
 * Processes rewards when a project is closed:
 *   1. Member survey rewards — credits points to panel members with sample_status='complete'
 *   2. Affiliate revenue share — credits commission for referred members who completed surveys
 * 
 * Place in: /public_html/close-project-rewards.php
 * Called by: clients/edit-project.php when project status changes to "Closed"
 */

function processProjectCloseRewards($projectNumericId, $shopPdo = null, $panelPdo = null) {
    $summary = [
        'members_rewarded' => 0,
        'total_member_points' => 0,
        'affiliates_rewarded' => 0,
        'total_affiliate_commission' => 0,
        'errors' => []
    ];

    try {
        // Get DB connections
        if ($shopPdo === null) {
            if (function_exists('getClientDBConnection')) {
                $shopPdo = getClientDBConnection();
            } elseif (function_exists('getDBConnection')) {
                $shopPdo = getDBConnection();
            } else {
                throw new Exception('No shop database connection available');
            }
        }
        if ($panelPdo === null) {
            if (function_exists('getPanelDBConnection')) {
                $panelPdo = getPanelDBConnection();
            } else {
                $summary['errors'][] = 'No panel DB connection — member points not credited';
                $panelPdo = null;
            }
        }

        // Get project details
        $stmt = $shopPdo->prepare("SELECT * FROM projects WHERE id = ?");
        $stmt->execute([$projectNumericId]);
        $project = $stmt->fetch();
        
        if (!$project) {
            $summary['errors'][] = 'Project not found';
            return $summary;
        }
        
        $projectCode = $project['project_id']; // e.g. RRIT130226001
        
        // Determine reward per complete from project level
        $rewardPerComplete = floatval($project['reward_per_complete'] ?? 0);
        
        // Get all selections for this project
        $stmt = $shopPdo->prepare("SELECT * FROM project_selections WHERE project_id = ?");
        $stmt->execute([$projectNumericId]);
        $selections = $stmt->fetchAll();
        
        if (empty($selections)) {
            $summary['errors'][] = 'No selections found';
            return $summary;
        }
        
        foreach ($selections as $selection) {
            $selectionId = $selection['id'];
            
            // Use selection-level reward if project-level is 0
            $selReward = $rewardPerComplete > 0 ? $rewardPerComplete : floatval($selection['reward_per_complete'] ?? 0);
            
            if ($selReward <= 0) {
                $summary['errors'][] = "Selection #{$selectionId}: no reward_per_complete set — skipping member rewards";
            }
            
            // Find all selection_members with sample_status = 'complete'
            $stmt = $shopPdo->prepare("
                SELECT sm.* FROM selection_members sm
                WHERE sm.selection_id = ? AND sm.sample_status = 'complete'
            ");
            $stmt->execute([$selectionId]);
            $completeMembers = $stmt->fetchAll();
            
            foreach ($completeMembers as $member) {
                $userId = $member['user_id'];
                
                try {
                    // ========================================
                    // 1. CREDIT MEMBER SURVEY REWARD
                    // ========================================
                    if ($selReward > 0 && $panelPdo !== null) {
                        // Check if already credited
                        $alreadyCredited = false;
                        try {
                            $stmt = $shopPdo->prepare("SELECT id FROM survey_rewards_log WHERE user_id = ? AND project_id = ?");
                            $stmt->execute([$userId, $projectCode]);
                            $alreadyCredited = (bool)$stmt->fetch();
                        } catch (Exception $e) { /* table might not exist */ }
                        
                        if (!$alreadyCredited) {
                            // Log in shop DB
                            try {
                                $stmt = $shopPdo->prepare("
                                    INSERT INTO survey_rewards_log (user_id, project_id, selection_id, points_awarded, status)
                                    VALUES (?, ?, ?, ?, 'pending')
                                ");
                                $stmt->execute([$userId, $projectCode, $selectionId, $selReward]);
                            } catch (Exception $e) {
                                error_log("survey_rewards_log insert: " . $e->getMessage());
                            }
                            
                            // Credit points in panel DB
                            $stmt = $panelPdo->prepare("
                                UPDATE user_points SET points = points + ?, total_earned = total_earned + ? WHERE user_id = ?
                            ");
                            $stmt->execute([$selReward, $selReward, $userId]);
                            
                            if ($stmt->rowCount() === 0) {
                                $stmt = $panelPdo->prepare("
                                    INSERT INTO user_points (user_id, points, total_earned) VALUES (?, ?, ?)
                                    ON DUPLICATE KEY UPDATE points = points + ?, total_earned = total_earned + ?
                                ");
                                $stmt->execute([$userId, $selReward, $selReward, $selReward, $selReward]);
                            }
                            
                            // Add transaction record
                            $stmt = $panelPdo->prepare("
                                INSERT INTO point_transactions (user_id, transaction_type, points, source, description)
                                VALUES (?, 'earned', ?, 'survey_reward', ?)
                            ");
                            $stmt->execute([$userId, $selReward, 'Survey reward: ' . $projectCode . ' - ' . $project['project_name']]);
                            
                            // Update survey_responses in panel DB
                            try {
                                $stmt = $panelPdo->prepare("
                                    INSERT INTO survey_responses (user_id, project_id, selection_id, status, incentive_amount, points_awarded, reward_status, completed_at)
                                    VALUES (?, ?, ?, 'complete', ?, ?, 'pending', NOW())
                                    ON DUPLICATE KEY UPDATE points_awarded = ?, reward_status = 'pending'
                                ");
                                $stmt->execute([$userId, $projectCode, $selectionId, $selReward, $selReward, $selReward]);
                            } catch (Exception $e) { /* non-critical */ }
                            
                            // Update selection_members points_awarded
                            try {
                                $stmt = $shopPdo->prepare("UPDATE selection_members SET points_awarded = ? WHERE selection_id = ? AND user_id = ?");
                                $stmt->execute([$selReward, $selectionId, $userId]);
                            } catch (Exception $e) { /* non-critical */ }
                            
                            $summary['members_rewarded']++;
                            $summary['total_member_points'] += $selReward;
                        }
                    }
                    
                    // ==========================================
                    // 2. CREDIT AFFILIATE REVENUE SHARE
                    // ==========================================
                    $stmt = $shopPdo->prepare("
                        SELECT a.id as affiliate_id, a.signup_reward
                        FROM affiliate_signups asu
                        JOIN affiliates a ON asu.affiliate_id = a.id
                        WHERE asu.panel_user_id = ? AND asu.email_verified = 1
                        LIMIT 1
                    ");
                    $stmt->execute([$userId]);
                    $affiliateLink = $stmt->fetch();
                    
                    if ($affiliateLink) {
                        $affiliateId = $affiliateLink['affiliate_id'];
                        $revenueShare = 0;
                        
                        // Try survey_reward column first
                        try {
                            $stmt = $shopPdo->prepare("SELECT survey_reward FROM affiliates WHERE id = ?");
                            $stmt->execute([$affiliateId]);
                            $row = $stmt->fetch();
                            $revenueShare = floatval($row['survey_reward'] ?? 0);
                        } catch (Exception $e) { /* column might not exist */ }
                        
                        // Fallback: revenue_share_per_survey
                        if ($revenueShare <= 0) {
                            try {
                                $stmt = $shopPdo->prepare("SELECT revenue_share_per_survey FROM affiliates WHERE id = ?");
                                $stmt->execute([$affiliateId]);
                                $row = $stmt->fetch();
                                $revenueShare = floatval($row['revenue_share_per_survey'] ?? 0);
                            } catch (Exception $e) { /* column might not exist */ }
                        }
                        
                        // Fallback: percentage of member reward
                        if ($revenueShare <= 0 && $selReward > 0) {
                            $commPct = floatval($project['affiliate_commission_pct'] ?? 10);
                            $revenueShare = round($selReward * ($commPct / 100), 2);
                        }
                        
                        if ($revenueShare > 0) {
                            $alreadyCredited = false;
                            try {
                                $stmt = $shopPdo->prepare("
                                    SELECT id FROM partner_commission_log 
                                    WHERE affiliate_id = ? AND type = 'survey_revenue_share' AND reference_id = ? AND panel_user_id = ?
                                ");
                                $stmt->execute([$affiliateId, $projectCode, $userId]);
                                $alreadyCredited = (bool)$stmt->fetch();
                            } catch (Exception $e) { /* table might not exist */ }
                            
                            if (!$alreadyCredited) {
                                try {
                                    $stmt = $shopPdo->prepare("
                                        INSERT INTO partner_commission_log (affiliate_id, type, amount, reference_id, panel_user_id, description)
                                        VALUES (?, 'survey_revenue_share', ?, ?, ?, ?)
                                    ");
                                    $stmt->execute([$affiliateId, $revenueShare, $projectCode, $userId,
                                        'Survey revenue share: ' . $projectCode . ' - ' . $project['project_name']]);
                                } catch (Exception $e) {
                                    error_log("partner_commission_log insert: " . $e->getMessage());
                                }
                                
                                $stmt = $shopPdo->prepare("
                                    UPDATE affiliates SET total_commission_earned = total_commission_earned + ?,
                                        commission_balance = commission_balance + ? WHERE id = ?
                                ");
                                $stmt->execute([$revenueShare, $revenueShare, $affiliateId]);
                                
                                $summary['affiliates_rewarded']++;
                                $summary['total_affiliate_commission'] += $revenueShare;
                            }
                        }
                    }
                    
                } catch (Exception $e) {
                    $summary['errors'][] = "User {$userId}: " . $e->getMessage();
                }
            }
        }
        
    } catch (Exception $e) {
        $summary['errors'][] = $e->getMessage();
    }
    
    return $summary;
}
?>