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 ]); } } /** * 파트너십 해지 처리 */ public function terminatePartnership() { try { $mappingSeq = $this->request->getVar('mappingSeq'); $terminatedBy = $this->request->getVar('terminatedBy'); $responseMessage = $this->request->getVar('responseMessage'); if (!$mappingSeq || !$terminatedBy) { return $this->response->setJSON([ 'success' => false, 'message' => '필수 파라미터가 누락되었습니다.' ]); } // 처리자 정보 확인 $userModel = new UserModel(); $vendorModel = new VendorModel(); $processor = $userModel->find($terminatedBy); if (!$processor) { $processor = $vendorModel->find($terminatedBy); } if (!$processor) { return $this->response->setJSON([ 'success' => false, 'message' => '처리자 정보를 찾을 수 없습니다.' ]); } $partnershipModel = new VendorInfluencerPartnershipModel(); // 현재 파트너십 상태 확인 $partnership = $partnershipModel->find($mappingSeq); if (!$partnership) { return $this->response->setJSON([ 'success' => false, 'message' => '파트너십 정보를 찾을 수 없습니다.' ]); } // 해지 처리 실행 $result = $partnershipModel->terminatePartnership($mappingSeq, $terminatedBy, $responseMessage); if (!$result['success']) { log_message('error', 'Termination failed: ' . json_encode($result)); return $this->response->setJSON([ 'success' => false, 'message' => '해지 처리 중 오류가 발생했습니다.', 'debug' => $result['debug'] ?? null ]); } // 성공 응답 return $this->response->setJSON([ 'success' => true, 'message' => '파트너십이 해지되었습니다.', 'data' => $result['data'] ]); } catch (\Exception $e) { log_message('error', '[terminatePartnership] Exception: ' . $e->getMessage()); return $this->response->setJSON([ 'success' => false, 'message' => '해지 처리 중 오류가 발생했습니다.', 'debug' => [ 'error' => $e->getMessage(), 'file' => $e->getFile(), 'line' => $e->getLine() ] ]); } } /** * 인플루언서의 벤더사 검색 * 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 (is_array($result) && isset($result['success']) && $result['success'] === false) { return $this->response->setStatusCode(500)->setJSON([ 'success' => false, 'message' => '재승인 요청 생성 중 오류가 발생했습니다.', 'error' => $result ]); } // 생성된 파트너십 정보 조회 $partnershipSeq = is_array($result) && isset($result['data']['SEQ']) ? $result['data']['SEQ'] : $result; $createdPartnership = $this->partnershipModel->find($partnershipSeq); 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' => $e->getMessage() ]); } } /** * 재승인 요청 생성 * 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 ?? ''; $requestedBy = $request->requestedBy ?? null; if (!$vendorSeq || !$influencerSeq || !$requestedBy) { return $this->response->setStatusCode(400)->setJSON([ 'success' => false, 'message' => '필수 파라미터가 누락되었습니다.' ]); } // createReapplyRequest 호출 (새로 추가한 메서드) $result = $this->partnershipModel->createReapplyRequest($vendorSeq, $influencerSeq, $requestMessage, $requestedBy); // 에러 응답이면 그대로 반환 if (is_array($result) && isset($result['success']) && $result['success'] === false) { return $this->response->setStatusCode(500)->setJSON([ 'success' => false, 'message' => '재승인 요청 생성 중 오류가 발생했습니다.', 'error' => $result ]); } // 생성된 파트너십 정보 조회 $partnershipSeq = is_array($result) && isset($result['data']['SEQ']) ? $result['data']['SEQ'] : $result; $createdPartnership = $this->partnershipModel->find($partnershipSeq); 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' => [ 'db_error' => [ 'code' => $e->getCode(), 'message' => $e->getMessage() ] ] ]); } } }