influence/backend/app/Controllers/PartnershipController.php

<?php

namespace App\Controllers;

use App\Controllers\BaseController;
use App\Models\VendorInfluencerPartnershipModel;
use App\Models\UserModel;
use App\Models\VendorModel;
use CodeIgniter\HTTP\ResponseInterface;

/**
 * 벤더사-인플루언서 파트너십 관리 컨트롤러 (완전 재설계)
 */
class PartnershipController extends BaseController
{
    protected $partnershipModel;
    protected $userModel;
    protected $vendorModel;
    
    public function __construct()
    {
        $this->partnershipModel = new VendorInfluencerPartnershipModel();
        $this->userModel = new UserModel();
        $this->vendorModel = new VendorModel();
    }

    /**
     * 벤더사의 인플루언서 요청 목록 조회
     * POST /api/vendor-influencer/requests
     */
    public function getInfluencerRequests()
    {
        try {
            $request = $this->request->getJSON();
            
            $vendorSeq = $request->vendorSeq ?? null;
            $status = $request->status ?? null;
            $keyword = $request->keyword ?? null;
            $page = $request->page ?? 1;
            $size = $request->size ?? 20;

            if (!$vendorSeq) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '벤더사 SEQ가 필요합니다.'
                ]);
            }

            $filters = [];
            if ($status) $filters['status'] = $status;
            if ($keyword) $filters['keyword'] = $keyword;

            // 데이터 조회
            $items = $this->partnershipModel->getInfluencerRequestsForVendor($vendorSeq, $filters);
            
            // 페이징 처리
            $total = count($items);
            $offset = ($page - 1) * $size;
            $pagedItems = array_slice($items, $offset, $size);

            // 통계 조회
            $stats = $this->partnershipModel->getVendorStats($vendorSeq);

            return $this->response->setJSON([
                'success' => true,
                'message' => '요청 목록 조회 성공',
                'data' => [
                    'items' => $pagedItems,
                    'total' => $total,
                    'page' => $page,
                    'totalPages' => ceil($total / $size),
                    'size' => $size,
                    'stats' => $stats
                ]
            ]);

        } catch (\Exception $e) {
            log_message('error', '인플루언서 요청 목록 조회 오류: ' . $e->getMessage());
            
            return $this->response->setStatusCode(500)->setJSON([
                'success' => false,
                'message' => '요청 목록을 불러오는 중 오류가 발생했습니다.',
                'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
            ]);
        }
    }

    /**
     * 파트너십 승인/거부 처리
     * POST /api/vendor-influencer/approve
     */
    public function processInfluencerRequest()
    {
        try {
            $request = $this->request->getJSON();
            
            $mappingSeq = $request->mappingSeq ?? null;
            $action = $request->action ?? null; // APPROVE or REJECT
            $processedBy = $request->processedBy ?? null;
            $responseMessage = $request->responseMessage ?? '';

            if (!$mappingSeq || !$action) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '필수 파라미터가 누락되었습니다.',
                    'debug' => [
                        'mappingSeq' => $mappingSeq,
                        'action' => $action,
                        'processedBy' => $processedBy,
                        'received_data' => $request
                    ]
                ]);
            }

            // processedBy가 없으면 파트너십의 벤더 정보에서 기본값 설정
            if (!$processedBy) {
                $partnership = $this->partnershipModel->find($mappingSeq);
                if ($partnership) {
                    $processedBy = $partnership['VENDOR_SEQ']; // 임시로 벤더 SEQ 사용
                }
            }

            if (!in_array($action, ['APPROVE', 'REJECT'])) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '유효하지 않은 액션입니다. (APPROVE 또는 REJECT)'
                ]);
            }

            // 파트너십 존재 확인
            $partnership = $this->partnershipModel->find($mappingSeq);
            if (!$partnership) {
                return $this->response->setStatusCode(404)->setJSON([
                    'success' => false,
                    'message' => '파트너십 요청을 찾을 수 없습니다.'
                ]);
            }

            if ($partnership['STATUS'] !== 'PENDING') {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '대기 중인 요청만 처리할 수 있습니다.'
                ]);
            }

            // 처리자 검증
            $processor = $this->userModel->find($processedBy);
            if (!$processor) {
                $processor = $this->vendorModel->find($processedBy);
            }
            if (!$processor) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '처리자 정보를 찾을 수 없습니다.'
                ]);
            }

            // 승인/거부 처리
            $result = false;
            if ($action === 'APPROVE') {
                $result = $this->partnershipModel->approvePartnership($mappingSeq, $processedBy, $responseMessage);
                $message = '파트너십이 승인되었습니다.';
            } else {
                $result = $this->partnershipModel->rejectPartnership($mappingSeq, $processedBy, $responseMessage);
                $message = '파트너십이 거부되었습니다.';
            }

            if (!$result) {
                return $this->response->setStatusCode(500)->setJSON([
                    'success' => false,
                    'message' => '처리 중 오류가 발생했습니다.'
                ]);
            }

            // 처리된 파트너십 정보 조회
            $updatedPartnership = $this->partnershipModel->find($mappingSeq);

            return $this->response->setJSON([
                'success' => true,
                'message' => $message,
                'data' => [
                    'partnership' => $updatedPartnership,
                    'processedBy' => $processor['NAME'] ?? $processor['NICK_NAME'],
                    'processedAt' => date('Y-m-d H:i:s')
                ]
            ]);

        } catch (\Exception $e) {
            log_message('error', '파트너십 처리 오류: ' . $e->getMessage());
            
            return $this->response->setStatusCode(500)->setJSON([
                'success' => false,
                'message' => '처리 중 오류가 발생했습니다.',
                'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
            ]);
        }
    }

    /**
     * 파트너십 해지 처리
     * POST /api/vendor-influencer/terminate
     */
    public function terminatePartnership()
    {
        try {
            $request = $this->request->getJSON();
            
            $mappingSeq = $request->mappingSeq ?? null;
            $terminatedBy = $request->terminatedBy ?? null;
            $terminateReason = $request->terminateReason ?? '';

            if (!$mappingSeq || !$terminatedBy) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '필수 파라미터가 누락되었습니다.'
                ]);
            }

            // 파트너십 존재 확인
            $partnership = $this->partnershipModel->find($mappingSeq);
            if (!$partnership) {
                return $this->response->setStatusCode(404)->setJSON([
                    'success' => false,
                    'message' => '파트너십을 찾을 수 없습니다.'
                ]);
            }

            if ($partnership['STATUS'] !== 'APPROVED') {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '승인된 파트너십만 해지할 수 있습니다.'
                ]);
            }

            // 처리자 검증
            $processor = $this->userModel->find($terminatedBy);
            if (!$processor) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '처리자 정보를 찾을 수 없습니다.'
                ]);
            }

            // 해지 처리
            $result = $this->partnershipModel->terminatePartnership($mappingSeq, $terminatedBy, $terminateReason);

            if (!$result) {
                return $this->response->setStatusCode(500)->setJSON([
                    'success' => false,
                    'message' => '해지 처리 중 오류가 발생했습니다.'
                ]);
            }

            // 해지된 파트너십 정보 조회
            $updatedPartnership = $this->partnershipModel->find($mappingSeq);

            return $this->response->setJSON([
                'success' => true,
                'message' => '파트너십이 해지되었습니다.',
                'data' => [
                    'partnership' => $updatedPartnership,
                    'terminatedBy' => $processor['NAME'] ?? $processor['NICK_NAME'],
                    'terminateReason' => $terminateReason,
                    'terminatedAt' => date('Y-m-d H:i:s')
                ]
            ]);

        } catch (\Exception $e) {
            log_message('error', '파트너십 해지 오류: ' . $e->getMessage());
            
            return $this->response->setStatusCode(500)->setJSON([
                'success' => false,
                'message' => '해지 처리 중 오류가 발생했습니다.',
                'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
            ]);
        }
    }

    /**
     * 인플루언서의 벤더사 검색
     * POST /api/vendor-influencer/search-vendors
     */
    public function searchVendorsForInfluencer()
    {
        try {
            $request = $this->request->getJSON();
            
            $influencerSeq = $request->influencerSeq ?? null;
            $keyword = $request->keyword ?? null;
            $category = $request->category ?? null;
            $page = $request->page ?? 1;
            $size = $request->size ?? 20;

            if (!$influencerSeq) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '인플루언서 SEQ가 필요합니다.'
                ]);
            }

            $filters = [];
            if ($keyword) $filters['keyword'] = $keyword;
            if ($category) $filters['category'] = $category;

            // 벤더사 검색
            $items = $this->partnershipModel->searchVendorsForInfluencer($influencerSeq, $filters);
            
            // 페이징 처리
            $total = count($items);
            $offset = ($page - 1) * $size;
            $pagedItems = array_slice($items, $offset, $size);

            return $this->response->setJSON([
                'success' => true,
                'message' => '벤더사 검색 성공',
                'data' => [
                    'items' => $pagedItems,
                    'pagination' => [
                        'total' => $total,
                        'page' => $page,
                        'totalPages' => ceil($total / $size),
                        'size' => $size
                    ]
                ]
            ]);

        } catch (\Exception $e) {
            log_message('error', '벤더사 검색 오류: ' . $e->getMessage());
            
            return $this->response->setStatusCode(500)->setJSON([
                'success' => false,
                'message' => '검색 중 오류가 발생했습니다.',
                'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
            ]);
        }
    }

    /**
     * 파트너십 요청 생성
     * POST /api/vendor-influencer/create-request
     */
    public function createPartnershipRequest()
    {
        try {
            $request = $this->request->getJSON();
            
            $vendorSeq = $request->vendorSeq ?? null;
            $influencerSeq = $request->influencerSeq ?? null;
            $requestMessage = $request->requestMessage ?? '';
            $commissionRate = $request->commissionRate ?? null;
            $specialConditions = $request->specialConditions ?? '';

            if (!$vendorSeq || !$influencerSeq) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '벤더사 및 인플루언서 정보가 필요합니다.'
                ]);
            }

            // 중복 요청 확인
            $existingPartnership = $this->partnershipModel->getActivePartnership($vendorSeq, $influencerSeq);
            if ($existingPartnership && in_array($existingPartnership['STATUS'], ['PENDING', 'APPROVED'])) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '이미 활성화된 파트너십 요청이 있습니다.'
                ]);
            }

            $partnershipData = [
                'VENDOR_SEQ' => $vendorSeq,
                'INFLUENCER_SEQ' => $influencerSeq,
                'STATUS' => 'PENDING',
                'REQUEST_TYPE' => 'NEW',
                'REQUEST_MESSAGE' => $requestMessage,
                'COMMISSION_RATE' => $commissionRate,
                'SPECIAL_CONDITIONS' => $specialConditions,
                'REQUESTED_BY' => $influencerSeq,
                'IS_ACTIVE' => 'Y'
            ];

            $result = $this->partnershipModel->createPartnershipRequest($partnershipData);

            if (!$result) {
                return $this->response->setStatusCode(500)->setJSON([
                    'success' => false,
                    'message' => '요청 생성 중 오류가 발생했습니다.'
                ]);
            }

            // 생성된 파트너십 정보 조회
            $createdPartnership = $this->partnershipModel->find($result);

            return $this->response->setJSON([
                'success' => true,
                'message' => '파트너십 요청이 전송되었습니다.',
                'data' => [
                    'partnership' => $createdPartnership,
                    'requestedAt' => date('Y-m-d H:i:s')
                ]
            ]);

        } catch (\Exception $e) {
            log_message('error', '파트너십 요청 생성 오류: ' . $e->getMessage());
            
            return $this->response->setStatusCode(500)->setJSON([
                'success' => false,
                'message' => '요청 생성 중 오류가 발생했습니다.',
                'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
            ]);
        }
    }

    /**
     * 재승인 요청 생성
     * POST /api/vendor-influencer/reapply-request
     */
    public function createReapplyRequest()
    {
        try {
            $request = $this->request->getJSON();
            
            $vendorSeq = $request->vendorSeq ?? null;
            $influencerSeq = $request->influencerSeq ?? null;
            $requestMessage = $request->requestMessage ?? '';
            $commissionRate = $request->commissionRate ?? null;
            $specialConditions = $request->specialConditions ?? '';

            if (!$vendorSeq || !$influencerSeq) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '벤더사 및 인플루언서 정보가 필요합니다.'
                ]);
            }

            // 기존 파트너십 확인 (REJECTED 또는 TERMINATED 상태여야 함)
            $existingPartnership = $this->partnershipModel->getActivePartnership($vendorSeq, $influencerSeq);
            if (!$existingPartnership || !in_array($existingPartnership['STATUS'], ['REJECTED', 'TERMINATED'])) {
                return $this->response->setStatusCode(400)->setJSON([
                    'success' => false,
                    'message' => '재승인 요청이 가능한 파트너십이 없습니다.'
                ]);
            }

            $partnershipData = [
                'VENDOR_SEQ' => $vendorSeq,
                'INFLUENCER_SEQ' => $influencerSeq,
                'STATUS' => 'PENDING',
                'REQUEST_TYPE' => 'REAPPLY',
                'REQUEST_MESSAGE' => $requestMessage,
                'COMMISSION_RATE' => $commissionRate,
                'SPECIAL_CONDITIONS' => $specialConditions,
                'REQUESTED_BY' => $influencerSeq,
                'IS_ACTIVE' => 'Y'
            ];

            $result = $this->partnershipModel->createPartnershipRequest($partnershipData);

            if (!$result) {
                return $this->response->setStatusCode(500)->setJSON([
                    'success' => false,
                    'message' => '재승인 요청 생성 중 오류가 발생했습니다.'
                ]);
            }

            // 생성된 파트너십 정보 조회
            $createdPartnership = $this->partnershipModel->find($result);

            return $this->response->setJSON([
                'success' => true,
                'message' => '재승인 요청이 전송되었습니다.',
                'data' => [
                    'partnership' => $createdPartnership,
                    'requestedAt' => date('Y-m-d H:i:s')
                ]
            ]);

        } catch (\Exception $e) {
            log_message('error', '재승인 요청 생성 오류: ' . $e->getMessage());
            
            return $this->response->setStatusCode(500)->setJSON([
                'success' => false,
                'message' => '재승인 요청 생성 중 오류가 발생했습니다.',
                'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
            ]);
        }
    }
}