VendorInfluencerController.php 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910
  1. <?php
  2. namespace App\Controllers;
  3. use App\Controllers\BaseController;
  4. use App\Models\VendorModel;
  5. use App\Models\UserModel;
  6. use App\Models\VendorInfluencerMappingModel;
  7. use CodeIgniter\HTTP\ResponseInterface;
  8. class VendorInfluencerController extends BaseController
  9. {
  10. protected $vendorModel;
  11. protected $userModel;
  12. protected $vendorInfluencerModel;
  13. public function __construct()
  14. {
  15. $this->vendorModel = new VendorModel();
  16. $this->userModel = new UserModel();
  17. $this->vendorInfluencerModel = new VendorInfluencerMappingModel();
  18. }
  19. /**
  20. * 벤더사 검색
  21. */
  22. public function searchVendors()
  23. {
  24. try {
  25. $request = $this->request->getJSON();
  26. $keyword = $request->keyword ?? '';
  27. $category = $request->category ?? '';
  28. $region = $request->region ?? '';
  29. $sortBy = $request->sortBy ?? 'latest';
  30. $page = intval($request->page ?? 1);
  31. $size = intval($request->size ?? 12);
  32. $influencerSeq = $request->influencerSeq ?? null;
  33. $builder = $this->vendorModel->builder();
  34. $builder->where('IS_ACT', 'Y');
  35. // 키워드 검색
  36. if (!empty($keyword)) {
  37. $builder->groupStart()
  38. ->like('COMPANY_NAME', $keyword)
  39. ->orLike('DESCRIPTION', $keyword)
  40. ->orLike('TAGS', $keyword)
  41. ->groupEnd();
  42. }
  43. // 카테고리 필터
  44. if (!empty($category)) {
  45. $builder->where('CATEGORY', $category);
  46. }
  47. // 지역 필터
  48. if (!empty($region)) {
  49. $builder->where('REGION', $region);
  50. }
  51. // 정렬
  52. switch ($sortBy) {
  53. case 'partnership':
  54. $builder->orderBy('PARTNERSHIP_COUNT', 'DESC')
  55. ->orderBy('REG_DATE', 'DESC');
  56. break;
  57. case 'name':
  58. $builder->orderBy('COMPANY_NAME', 'ASC');
  59. break;
  60. case 'latest':
  61. default:
  62. $builder->orderBy('REG_DATE', 'DESC');
  63. break;
  64. }
  65. // 전체 개수
  66. $totalCount = $builder->countAllResults(false);
  67. // 페이징
  68. $offset = ($page - 1) * $size;
  69. $vendors = $builder->limit($size, $offset)->get()->getResultArray();
  70. // 파트너십 개수 추가
  71. foreach ($vendors as &$vendor) {
  72. $partnershipCount = $this->vendorInfluencerModel
  73. ->where('VENDOR_SEQ', $vendor['SEQ'])
  74. ->where('STATUS', 'APPROVED')
  75. ->where('IS_ACT', 'Y')
  76. ->countAllResults();
  77. $vendor['PARTNERSHIP_COUNT'] = $partnershipCount;
  78. // 인플루언서의 파트너십 상태 확인
  79. if ($influencerSeq) {
  80. $partnershipStatus = $this->vendorInfluencerModel
  81. ->where('VENDOR_SEQ', $vendor['SEQ'])
  82. ->where('INFLUENCER_SEQ', $influencerSeq)
  83. ->where('IS_ACT', 'Y')
  84. ->first();
  85. $vendor['PARTNERSHIP_STATUS'] = $partnershipStatus['STATUS'] ?? null;
  86. $vendor['REQUEST_TYPE'] = $partnershipStatus['REQUEST_TYPE'] ?? null;
  87. }
  88. }
  89. $totalPages = ceil($totalCount / $size);
  90. return $this->response->setJSON([
  91. 'success' => true,
  92. 'data' => [
  93. 'items' => $vendors,
  94. 'pagination' => [
  95. 'currentPage' => $page,
  96. 'totalPages' => $totalPages,
  97. 'totalCount' => $totalCount,
  98. 'pageSize' => $size,
  99. 'hasNext' => $page < $totalPages,
  100. 'hasPrev' => $page > 1
  101. ]
  102. ]
  103. ]);
  104. } catch (\Exception $e) {
  105. return $this->response->setStatusCode(500)->setJSON([
  106. 'success' => false,
  107. 'message' => '벤더사 검색 중 오류가 발생했습니다.',
  108. 'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
  109. ]);
  110. }
  111. }
  112. /**
  113. * 승인 요청 생성
  114. */
  115. public function createRequest()
  116. {
  117. try {
  118. $request = $this->request->getJSON();
  119. $vendorSeq = $request->vendorSeq ?? null;
  120. $influencerSeq = $request->influencerSeq ?? null;
  121. $requestType = $request->requestType ?? 'INFLUENCER_REQUEST';
  122. $requestMessage = $request->requestMessage ?? '';
  123. $requestedBy = $request->requestedBy ?? null;
  124. $commissionRate = $request->commissionRate ?? null;
  125. $specialConditions = $request->specialConditions ?? '';
  126. // 필수 파라미터 검증
  127. if (!$vendorSeq || !$influencerSeq || !$requestedBy) {
  128. return $this->response->setStatusCode(400)->setJSON([
  129. 'success' => false,
  130. 'message' => '필수 파라미터가 누락되었습니다.'
  131. ]);
  132. }
  133. // 중복 요청 확인
  134. $existingRequest = $this->vendorInfluencerModel
  135. ->where('VENDOR_SEQ', $vendorSeq)
  136. ->where('INFLUENCER_SEQ', $influencerSeq)
  137. ->where('STATUS', 'PENDING')
  138. ->where('IS_ACT', 'Y')
  139. ->first();
  140. if ($existingRequest) {
  141. return $this->response->setStatusCode(409)->setJSON([
  142. 'success' => false,
  143. 'message' => '이미 처리 중인 요청이 있습니다.'
  144. ]);
  145. }
  146. // 요청 생성
  147. $data = [
  148. 'VENDOR_SEQ' => $vendorSeq,
  149. 'INFLUENCER_SEQ' => $influencerSeq,
  150. 'REQUEST_TYPE' => $requestType,
  151. 'STATUS' => 'PENDING',
  152. 'REQUEST_MESSAGE' => $requestMessage,
  153. 'REQUESTED_BY' => $requestedBy,
  154. 'COMMISSION_RATE' => $commissionRate,
  155. 'SPECIAL_CONDITIONS' => $specialConditions,
  156. 'EXPIRED_DATE' => date('Y-m-d H:i:s', strtotime('+7 days'))
  157. ];
  158. $insertId = $this->vendorInfluencerModel->insert($data);
  159. // 생성된 데이터 조회
  160. $createdRequest = $this->vendorInfluencerModel
  161. ->select('vim.*, v.COMPANY_NAME as vendorName, u.NICK_NAME as influencerName, req_user.NICK_NAME as requestedByName')
  162. ->from('VENDOR_INFLUENCER_MAPPING vim')
  163. ->join('VENDOR_LIST v', 'vim.VENDOR_SEQ = v.SEQ', 'left')
  164. ->join('USER_LIST u', 'vim.INFLUENCER_SEQ = u.SEQ', 'left')
  165. ->join('USER_LIST req_user', 'vim.REQUESTED_BY = req_user.SEQ', 'left')
  166. ->where('vim.SEQ', $insertId)
  167. ->get()
  168. ->getRowArray();
  169. return $this->response->setJSON([
  170. 'success' => true,
  171. 'message' => '승인 요청이 성공적으로 생성되었습니다.',
  172. 'data' => $createdRequest
  173. ]);
  174. } catch (\Exception $e) {
  175. return $this->response->setStatusCode(500)->setJSON([
  176. 'success' => false,
  177. 'message' => '승인 요청 생성 중 오류가 발생했습니다.',
  178. 'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
  179. ]);
  180. }
  181. }
  182. /**
  183. * 매핑 리스트 조회 (벤더사용 승인요청 목록 포함)
  184. */
  185. public function getList()
  186. {
  187. try {
  188. $request = $this->request->getJSON();
  189. $vendorSeq = $request->vendorSeq ?? null;
  190. $influencerSeq = $request->influencerSeq ?? null;
  191. $status = $request->status ?? null;
  192. $requestType = $request->requestType ?? null;
  193. $keyword = $request->keyword ?? null;
  194. $category = $request->category ?? null;
  195. $sortBy = $request->sortBy ?? 'latest';
  196. $page = intval($request->page ?? 1);
  197. $size = intval($request->size ?? 12);
  198. $builder = $this->vendorInfluencerModel->builder();
  199. $builder->select('vim.SEQ, vim.VENDOR_SEQ, vim.INFLUENCER_SEQ, vim.REQUEST_TYPE, vim.STATUS,
  200. vim.REQUEST_MESSAGE, vim.RESPONSE_MESSAGE, vim.REQUESTED_BY, vim.APPROVED_BY,
  201. vim.REQUEST_DATE, vim.RESPONSE_DATE, vim.EXPIRED_DATE,
  202. vim.PARTNERSHIP_START_DATE, vim.PARTNERSHIP_END_DATE,
  203. vim.COMMISSION_RATE, vim.SPECIAL_CONDITIONS, vim.IS_ACT,
  204. vim.REG_DATE, vim.MOD_DATE, vim.ADD_INFO1, vim.ADD_INFO2, vim.ADD_INFO3,
  205. v.COMPANY_NAME as vendorName, v.EMAIL as vendorEmail, v.LOGO as vendorLogo,
  206. inf.NICK_NAME as influencerNickname, inf.NAME as influencerName,
  207. inf.EMAIL as influencerEmail, inf.PHONE as influencerPhone,
  208. inf.PROFILE_IMAGE as influencerAvatar, inf.REGION as influencerRegion,
  209. inf.PRIMARY_CATEGORY as influencerCategory,
  210. inf.FOLLOWER_COUNT as followerCount,
  211. inf.AVG_VIEWS as avgViews,
  212. inf.ENGAGEMENT_RATE as engagementRate,
  213. inf.DESCRIPTION as influencerDescription,
  214. inf.SNS_CHANNELS as influencerSnsChannels,
  215. req_user.NICK_NAME as requestedByName,
  216. app_user.NICK_NAME as approvedByName,
  217. CASE WHEN vim.EXPIRED_DATE < NOW() AND vim.STATUS = "PENDING"
  218. THEN "EXPIRED" ELSE vim.STATUS END as displayStatus')
  219. ->distinct()
  220. ->from('VENDOR_INFLUENCER_MAPPING vim')
  221. ->join('VENDOR_LIST v', 'vim.VENDOR_SEQ = v.SEQ', 'left')
  222. ->join('USER_LIST inf', 'vim.INFLUENCER_SEQ = inf.SEQ', 'left')
  223. ->join('USER_LIST req_user', 'vim.REQUESTED_BY = req_user.SEQ', 'left')
  224. ->join('USER_LIST app_user', 'vim.APPROVED_BY = app_user.SEQ', 'left')
  225. ->where('vim.IS_ACT', 'Y');
  226. // 필터 적용
  227. if ($vendorSeq) {
  228. $builder->where('vim.VENDOR_SEQ', $vendorSeq);
  229. }
  230. if ($influencerSeq) {
  231. $builder->where('vim.INFLUENCER_SEQ', $influencerSeq);
  232. }
  233. if ($status) {
  234. $builder->where('vim.STATUS', $status);
  235. }
  236. if ($requestType) {
  237. $builder->where('vim.REQUEST_TYPE', $requestType);
  238. }
  239. // 키워드 검색 (인플루언서명)
  240. if (!empty($keyword)) {
  241. $builder->groupStart()
  242. ->like('inf.NICK_NAME', $keyword)
  243. ->orLike('inf.NAME', $keyword)
  244. ->groupEnd();
  245. }
  246. // 카테고리 필터 (인플루언서 카테고리)
  247. if (!empty($category)) {
  248. $builder->where('inf.PRIMARY_CATEGORY', $category);
  249. }
  250. // 전체 개수
  251. $totalCount = $builder->countAllResults(false);
  252. // 정렬
  253. switch ($sortBy) {
  254. case 'oldest':
  255. $builder->orderBy('vim.REG_DATE', 'ASC');
  256. break;
  257. case 'expiring':
  258. $builder->orderBy('vim.EXPIRED_DATE', 'ASC');
  259. break;
  260. case 'latest':
  261. default:
  262. $builder->orderBy('vim.REG_DATE', 'DESC');
  263. break;
  264. }
  265. // 페이징
  266. $offset = ($page - 1) * $size;
  267. $items = $builder->limit($size, $offset)->get()->getResultArray();
  268. $totalPages = ceil($totalCount / $size);
  269. // 통계 데이터 계산 (벤더사용)
  270. $stats = [];
  271. if ($vendorSeq) {
  272. $statsBuilder = $this->vendorInfluencerModel->builder();
  273. $stats = [
  274. 'pending' => $statsBuilder->where('VENDOR_SEQ', $vendorSeq)->where('STATUS', 'PENDING')->where('IS_ACT', 'Y')->countAllResults(),
  275. 'approved' => $statsBuilder->resetQuery()->where('VENDOR_SEQ', $vendorSeq)->where('STATUS', 'APPROVED')->where('IS_ACT', 'Y')->countAllResults(),
  276. 'rejected' => $statsBuilder->resetQuery()->where('VENDOR_SEQ', $vendorSeq)->where('STATUS', 'REJECTED')->where('IS_ACT', 'Y')->countAllResults(),
  277. 'total' => $totalCount
  278. ];
  279. }
  280. return $this->response->setJSON([
  281. 'success' => true,
  282. 'data' => [
  283. 'items' => $items,
  284. 'pagination' => [
  285. 'currentPage' => $page,
  286. 'totalPages' => $totalPages,
  287. 'totalCount' => $totalCount,
  288. 'pageSize' => $size,
  289. 'hasNext' => $page < $totalPages,
  290. 'hasPrev' => $page > 1
  291. ],
  292. 'stats' => $stats
  293. ]
  294. ]);
  295. } catch (\Exception $e) {
  296. return $this->response->setStatusCode(500)->setJSON([
  297. 'success' => false,
  298. 'message' => '리스트 조회 중 오류가 발생했습니다.',
  299. 'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
  300. ]);
  301. }
  302. }
  303. /**
  304. * 요청 취소
  305. */
  306. public function cancelRequest()
  307. {
  308. try {
  309. $request = $this->request->getJSON();
  310. $mappingSeq = $request->mappingSeq ?? null;
  311. $cancelledBy = $request->cancelledBy ?? null;
  312. $cancelReason = $request->cancelReason ?? '요청자에 의해 취소됨';
  313. // 필수 파라미터 검증
  314. if (!$mappingSeq || !$cancelledBy) {
  315. return $this->response->setStatusCode(400)->setJSON([
  316. 'success' => false,
  317. 'message' => '필수 파라미터가 누락되었습니다.'
  318. ]);
  319. }
  320. // 기존 요청 확인
  321. $existingMapping = $this->vendorInfluencerModel
  322. ->where('SEQ', $mappingSeq)
  323. ->where('STATUS', 'PENDING')
  324. ->where('IS_ACT', 'Y')
  325. ->first();
  326. if (!$existingMapping) {
  327. return $this->response->setStatusCode(404)->setJSON([
  328. 'success' => false,
  329. 'message' => '취소할 수 있는 요청을 찾을 수 없습니다.'
  330. ]);
  331. }
  332. // 권한 확인
  333. if ($existingMapping['REQUESTED_BY'] != $cancelledBy) {
  334. return $this->response->setStatusCode(403)->setJSON([
  335. 'success' => false,
  336. 'message' => '요청을 취소할 권한이 없습니다.'
  337. ]);
  338. }
  339. // 취소 처리
  340. $updateData = [
  341. 'STATUS' => 'CANCELLED',
  342. 'RESPONSE_MESSAGE' => $cancelReason,
  343. 'RESPONSE_DATE' => date('Y-m-d H:i:s'),
  344. 'APPROVED_BY' => $cancelledBy
  345. ];
  346. $this->vendorInfluencerModel->update($mappingSeq, $updateData);
  347. // 업데이트된 데이터 조회
  348. $updatedMapping = $this->vendorInfluencerModel
  349. ->select('vim.*, v.COMPANY_NAME as vendorName, u.NICK_NAME as influencerName, req_user.NICK_NAME as requestedByName')
  350. ->from('VENDOR_INFLUENCER_MAPPING vim')
  351. ->join('VENDOR_LIST v', 'vim.VENDOR_SEQ = v.SEQ', 'left')
  352. ->join('USER_LIST u', 'vim.INFLUENCER_SEQ = u.SEQ', 'left')
  353. ->join('USER_LIST req_user', 'vim.REQUESTED_BY = req_user.SEQ', 'left')
  354. ->where('vim.SEQ', $mappingSeq)
  355. ->get()
  356. ->getRowArray();
  357. return $this->response->setJSON([
  358. 'success' => true,
  359. 'message' => '요청이 취소되었습니다.',
  360. 'data' => $updatedMapping
  361. ]);
  362. } catch (\Exception $e) {
  363. return $this->response->setStatusCode(500)->setJSON([
  364. 'success' => false,
  365. 'message' => '요청 취소 중 오류가 발생했습니다.',
  366. 'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
  367. ]);
  368. }
  369. }
  370. /**
  371. * 요청 승인/거부 처리
  372. */
  373. public function approveRequest()
  374. {
  375. try {
  376. $request = $this->request->getJSON();
  377. $mappingSeq = $request->mappingSeq ?? null;
  378. $action = $request->action ?? 'APPROVE'; // 'APPROVE' or 'REJECT'
  379. $processedBy = $request->processedBy ?? $request->approvedBy ?? null; // 기존 코드 호환성
  380. $responseMessage = $request->responseMessage ?? '';
  381. $commissionRate = $request->commissionRate ?? null;
  382. if (!$mappingSeq || !$processedBy) {
  383. return $this->response->setStatusCode(400)->setJSON([
  384. 'success' => false,
  385. 'message' => '필수 파라미터가 누락되었습니다.'
  386. ]);
  387. }
  388. // processedBy가 벤더사 SEQ인지 사용자 SEQ인지 확인
  389. $processingUser = null;
  390. // 1. 먼저 USER_LIST에서 확인 (인플루언서)
  391. $processingUser = $this->userModel
  392. ->where('SEQ', $processedBy)
  393. ->where('IS_ACT', 'Y')
  394. ->first();
  395. if ($processingUser) {
  396. // 사용자 SEQ인 경우 (인플루언서) - 바로 사용
  397. $approvedByUserSeq = $processedBy;
  398. } else {
  399. // 2. VENDOR_LIST에서 확인 (벤더사)
  400. $vendorInfo = $this->vendorModel
  401. ->where('SEQ', $processedBy)
  402. ->where('IS_ACT', 'Y')
  403. ->first();
  404. if ($vendorInfo) {
  405. // 벤더사 SEQ인 경우 - 벤더사가 직접 처리하는 것으로 간주
  406. $approvedByUserSeq = $processedBy;
  407. log_message('debug', "벤더사 SEQ {$processedBy}가 직접 처리합니다.");
  408. } else {
  409. return $this->response->setStatusCode(400)->setJSON([
  410. 'success' => false,
  411. 'message' => "처리자 SEQ {$processedBy}는 USER_LIST나 VENDOR_LIST에서 찾을 수 없습니다."
  412. ]);
  413. }
  414. }
  415. // 기존 요청 확인
  416. $existingMapping = $this->vendorInfluencerModel
  417. ->where('SEQ', $mappingSeq)
  418. ->where('STATUS', 'PENDING')
  419. ->where('IS_ACT', 'Y')
  420. ->first();
  421. if (!$existingMapping) {
  422. return $this->response->setStatusCode(404)->setJSON([
  423. 'success' => false,
  424. 'message' => '처리할 수 있는 요청을 찾을 수 없습니다.'
  425. ]);
  426. }
  427. // 벤더사 권한 확인 (선택적)
  428. // 벤더사만 자신의 요청을 처리할 수 있도록 하려면 주석 해제
  429. // if ($existingMapping['VENDOR_SEQ'] !== $processingUser['SEQ']) {
  430. // return $this->response->setStatusCode(403)->setJSON([
  431. // 'success' => false,
  432. // 'message' => '해당 요청을 처리할 권한이 없습니다.'
  433. // ]);
  434. // }
  435. $status = $action === 'APPROVE' ? 'APPROVED' : 'REJECTED';
  436. $updateData = [
  437. 'STATUS' => $status,
  438. 'APPROVED_BY' => $approvedByUserSeq,
  439. 'RESPONSE_MESSAGE' => $responseMessage,
  440. 'RESPONSE_DATE' => date('Y-m-d H:i:s')
  441. ];
  442. if ($commissionRate !== null && $action === 'APPROVE') {
  443. $updateData['COMMISSION_RATE'] = $commissionRate;
  444. }
  445. // 단계별 업데이트로 외래키 제약조건 문제 우회
  446. try {
  447. // 1단계: APPROVED_BY 없이 먼저 업데이트
  448. $firstUpdateData = [
  449. 'STATUS' => $status,
  450. 'RESPONSE_MESSAGE' => $responseMessage,
  451. 'RESPONSE_DATE' => date('Y-m-d H:i:s')
  452. ];
  453. if ($commissionRate !== null && $action === 'APPROVE') {
  454. $firstUpdateData['COMMISSION_RATE'] = $commissionRate;
  455. }
  456. log_message('debug', "1단계 업데이트 시도: " . json_encode($firstUpdateData));
  457. $result1 = $this->vendorInfluencerModel->update($mappingSeq, $firstUpdateData);
  458. log_message('debug', "1단계 업데이트 결과: " . ($result1 ? 'SUCCESS' : 'FAILED'));
  459. // 2단계: APPROVED_BY만 별도로 업데이트
  460. $secondUpdateData = [
  461. 'APPROVED_BY' => $approvedByUserSeq
  462. ];
  463. log_message('debug', "2단계 업데이트 시도: " . json_encode($secondUpdateData));
  464. $result2 = $this->vendorInfluencerModel->update($mappingSeq, $secondUpdateData);
  465. log_message('debug', "2단계 업데이트 결과: " . ($result2 ? 'SUCCESS' : 'FAILED'));
  466. if (!$result1 || !$result2) {
  467. throw new \Exception("단계별 업데이트 실패: 1단계={$result1}, 2단계={$result2}");
  468. }
  469. } catch (\Exception $updateException) {
  470. log_message('error', "단계별 업데이트 실패: " . $updateException->getMessage());
  471. // 외래키 제약조건 오류인 경우 더 상세한 정보 제공
  472. if (strpos($updateException->getMessage(), 'foreign key constraint') !== false) {
  473. // 추가 디버깅: 직접 SQL로 사용자 존재 확인
  474. $db = \Config\Database::connect();
  475. $userCheck = $db->query("SELECT SEQ, NICK_NAME, EMAIL, IS_ACT FROM USER_LIST WHERE SEQ = ?", [$processedBy])->getRowArray();
  476. // 추가 디버깅: 현재 매핑 레코드 상태 확인
  477. $mappingCheck = $db->query("SELECT SEQ, STATUS, APPROVED_BY FROM VENDOR_INFLUENCER_MAPPING WHERE SEQ = ?", [$mappingSeq])->getRowArray();
  478. return $this->response->setStatusCode(500)->setJSON([
  479. 'success' => false,
  480. 'message' => '외래키 제약조건 오류가 발생했습니다.',
  481. 'error' => $updateException->getMessage(),
  482. 'debug_info' => [
  483. 'processedBy' => $processedBy,
  484. 'approvedByUserSeq' => $approvedByUserSeq,
  485. 'processingUser' => $processingUser,
  486. 'existingMapping' => $existingMapping,
  487. 'userCheck' => $userCheck,
  488. 'mappingCheck' => $mappingCheck,
  489. 'updateData' => $updateData
  490. ]
  491. ]);
  492. }
  493. throw $updateException; // 다른 예외는 기존 처리 방식 유지
  494. }
  495. $actionText = $action === 'APPROVE' ? '승인' : '거부';
  496. return $this->response->setJSON([
  497. 'success' => true,
  498. 'message' => "요청이 {$actionText}되었습니다.",
  499. 'data' => $updateData
  500. ]);
  501. } catch (\Exception $e) {
  502. return $this->response->setStatusCode(500)->setJSON([
  503. 'success' => false,
  504. 'message' => '요청 처리 중 오류가 발생했습니다.',
  505. 'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
  506. ]);
  507. }
  508. }
  509. /**
  510. * 상세 조회
  511. */
  512. public function getDetail()
  513. {
  514. try {
  515. $request = $this->request->getJSON();
  516. $mappingSeq = $request->mappingSeq ?? null;
  517. if (!$mappingSeq) {
  518. return $this->response->setStatusCode(400)->setJSON([
  519. 'success' => false,
  520. 'message' => '매핑 SEQ가 필요합니다.'
  521. ]);
  522. }
  523. $detail = $this->vendorInfluencerModel
  524. ->select('vim.*, v.*, u.NICK_NAME as influencerName, u.EMAIL as influencerEmail')
  525. ->from('VENDOR_INFLUENCER_MAPPING vim')
  526. ->join('VENDOR_LIST v', 'vim.VENDOR_SEQ = v.SEQ', 'left')
  527. ->join('USER_LIST u', 'vim.INFLUENCER_SEQ = u.SEQ', 'left')
  528. ->where('vim.SEQ', $mappingSeq)
  529. ->where('vim.IS_ACT', 'Y')
  530. ->get()
  531. ->getRowArray();
  532. if (!$detail) {
  533. return $this->response->setStatusCode(404)->setJSON([
  534. 'success' => false,
  535. 'message' => '요청을 찾을 수 없습니다.'
  536. ]);
  537. }
  538. return $this->response->setJSON([
  539. 'success' => true,
  540. 'data' => $detail
  541. ]);
  542. } catch (\Exception $e) {
  543. return $this->response->setStatusCode(500)->setJSON([
  544. 'success' => false,
  545. 'message' => '상세 조회 중 오류가 발생했습니다.',
  546. 'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
  547. ]);
  548. }
  549. }
  550. /**
  551. * 승인된 파트너십 해지
  552. */
  553. public function terminate()
  554. {
  555. try {
  556. $request = $this->request->getJSON();
  557. $mappingSeq = $request->mappingSeq ?? null;
  558. $terminateReason = $request->terminateReason ?? null;
  559. $terminatedBy = $request->terminatedBy ?? null;
  560. // 필수 파라미터 검증
  561. if (!$mappingSeq || !$terminateReason || !$terminatedBy) {
  562. return $this->response->setStatusCode(400)->setJSON([
  563. 'success' => false,
  564. 'message' => '필수 파라미터가 누락되었습니다.'
  565. ]);
  566. }
  567. // 해지 사유 길이 검증
  568. if (strlen($terminateReason) > 500) {
  569. return $this->response->setStatusCode(400)->setJSON([
  570. 'success' => false,
  571. 'message' => '해지 사유는 500자를 초과할 수 없습니다.'
  572. ]);
  573. }
  574. // 기존 매핑 확인 (승인된 상태여야 함)
  575. $existingMapping = $this->vendorInfluencerModel
  576. ->where('SEQ', $mappingSeq)
  577. ->where('STATUS', 'APPROVED')
  578. ->where('IS_ACT', 'Y')
  579. ->first();
  580. if (!$existingMapping) {
  581. return $this->response->setStatusCode(404)->setJSON([
  582. 'success' => false,
  583. 'message' => '해지할 수 있는 승인된 파트너십을 찾을 수 없습니다.'
  584. ]);
  585. }
  586. // 해지 처리자 확인 (벤더사 SEQ인지 사용자 SEQ인지 확인)
  587. $terminatingUser = null;
  588. // 1. 먼저 USER_LIST에서 확인 (인플루언서)
  589. $terminatingUser = $this->userModel
  590. ->where('SEQ', $terminatedBy)
  591. ->where('IS_ACT', 'Y')
  592. ->first();
  593. if ($terminatingUser) {
  594. // 사용자 SEQ인 경우 (인플루언서) - 바로 사용
  595. $approvedByUserSeq = $terminatedBy;
  596. } else {
  597. // 2. VENDOR_LIST에서 확인 (벤더사)
  598. $vendorInfo = $this->vendorModel
  599. ->where('SEQ', $terminatedBy)
  600. ->where('IS_ACT', 'Y')
  601. ->first();
  602. if ($vendorInfo) {
  603. // 벤더사 SEQ인 경우 - 벤더사가 직접 처리하는 것으로 간주
  604. // 벤더사 자체의 SEQ를 APPROVED_BY에 저장 (벤더사 계정이 처리)
  605. $approvedByUserSeq = $terminatedBy;
  606. // 응답용 정보 설정
  607. $terminatingUser = [
  608. 'SEQ' => $vendorInfo['SEQ'],
  609. 'NICK_NAME' => $vendorInfo['COMPANY_NAME'] . ' (벤더사)',
  610. 'NAME' => $vendorInfo['COMPANY_NAME']
  611. ];
  612. } else {
  613. return $this->response->setStatusCode(400)->setJSON([
  614. 'success' => false,
  615. 'message' => "해지 처리자 SEQ {$terminatedBy}는 USER_LIST나 VENDOR_LIST에서 찾을 수 없습니다."
  616. ]);
  617. }
  618. }
  619. // 해지 처리
  620. $terminateData = [
  621. 'STATUS' => 'TERMINATED',
  622. 'RESPONSE_MESSAGE' => '파트너십 해지: ' . $terminateReason,
  623. 'RESPONSE_DATE' => date('Y-m-d H:i:s'),
  624. 'PARTNERSHIP_END_DATE' => date('Y-m-d H:i:s'),
  625. 'MOD_DATE' => date('Y-m-d H:i:s')
  626. ];
  627. log_message('debug', "해지 처리 데이터: " . json_encode($terminateData));
  628. log_message('debug', "매핑 SEQ: {$mappingSeq}");
  629. log_message('debug', "처리자 SEQ: {$terminatedBy} -> 승인자 SEQ: {$approvedByUserSeq}");
  630. // 단계별 업데이트로 외래키 제약조건 문제 우회
  631. try {
  632. // 1단계: APPROVED_BY 없이 먼저 업데이트
  633. $result1 = $this->vendorInfluencerModel->update($mappingSeq, $terminateData);
  634. log_message('debug', "1단계 업데이트 결과: " . ($result1 ? 'SUCCESS' : 'FAILED'));
  635. // 2단계: APPROVED_BY만 별도로 업데이트 (필요시에만)
  636. if ($result1 && $approvedByUserSeq) {
  637. $approvedByData = ['APPROVED_BY' => $approvedByUserSeq];
  638. $result2 = $this->vendorInfluencerModel->update($mappingSeq, $approvedByData);
  639. log_message('debug', "2단계 업데이트 결과: " . ($result2 ? 'SUCCESS' : 'FAILED'));
  640. } else {
  641. $result2 = true; // APPROVED_BY 업데이트가 필요없는 경우
  642. }
  643. if (!$result1 || !$result2) {
  644. throw new \Exception("단계별 업데이트 실패: 1단계={$result1}, 2단계={$result2}");
  645. }
  646. } catch (\Exception $updateException) {
  647. log_message('error', "해지 처리 업데이트 오류: " . $updateException->getMessage());
  648. // 외래키 제약조건 오류인 경우 더 상세한 정보 제공
  649. if (strpos($updateException->getMessage(), 'foreign key constraint') !== false) {
  650. return $this->response->setStatusCode(500)->setJSON([
  651. 'success' => false,
  652. 'message' => '외래키 제약조건 오류가 발생했습니다.',
  653. 'error' => ENVIRONMENT === 'development' ? $updateException->getMessage() : null,
  654. 'debug_info' => ENVIRONMENT === 'development' ? [
  655. 'terminatedBy' => $terminatedBy,
  656. 'approvedByUserSeq' => $approvedByUserSeq,
  657. 'terminatingUser' => $terminatingUser,
  658. 'existingMapping' => $existingMapping,
  659. 'terminateData' => $terminateData
  660. ] : null
  661. ]);
  662. }
  663. throw $updateException; // 다른 예외는 기존 처리 방식 유지
  664. }
  665. // 해지된 매핑 정보 조회
  666. $terminatedMapping = $this->vendorInfluencerModel
  667. ->select('vim.SEQ, vim.VENDOR_SEQ, vim.INFLUENCER_SEQ, vim.STATUS,
  668. vim.RESPONSE_MESSAGE, vim.RESPONSE_DATE, vim.PARTNERSHIP_END_DATE,
  669. v.COMPANY_NAME as vendorName,
  670. inf.NICK_NAME as influencerNickname, inf.NAME as influencerName')
  671. ->from('VENDOR_INFLUENCER_MAPPING vim')
  672. ->join('VENDOR_LIST v', 'vim.VENDOR_SEQ = v.SEQ', 'left')
  673. ->join('USER_LIST inf', 'vim.INFLUENCER_SEQ = inf.SEQ', 'left')
  674. ->where('vim.SEQ', $mappingSeq)
  675. ->get()
  676. ->getRowArray();
  677. return $this->response->setJSON([
  678. 'success' => true,
  679. 'message' => '파트너십이 성공적으로 해지되었습니다.',
  680. 'data' => [
  681. 'terminatedMapping' => $terminatedMapping,
  682. 'terminateDate' => date('Y-m-d H:i:s'),
  683. 'terminatedBy' => $terminatingUser['NICK_NAME'] ?? $terminatingUser['NAME']
  684. ]
  685. ]);
  686. } catch (\Exception $e) {
  687. log_message('error', "파트너십 해지 처리 오류: " . $e->getMessage());
  688. log_message('error', "스택 트레이스: " . $e->getTraceAsString());
  689. return $this->response->setStatusCode(500)->setJSON([
  690. 'success' => false,
  691. 'message' => '파트너십 해지 처리 중 오류가 발생했습니다.',
  692. 'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null,
  693. 'trace' => ENVIRONMENT === 'development' ? $e->getTraceAsString() : null
  694. ]);
  695. }
  696. }
  697. /**
  698. * 재승인 요청 (해지된 파트너십에 대한 재계약 요청)
  699. */
  700. public function reapplyRequest()
  701. {
  702. try {
  703. $request = $this->request->getJSON();
  704. $vendorSeq = $request->vendorSeq ?? null;
  705. $influencerSeq = $request->influencerSeq ?? null;
  706. $requestMessage = $request->requestMessage ?? '';
  707. $requestedBy = $request->requestedBy ?? null;
  708. // 필수 파라미터 검증
  709. if (!$vendorSeq || !$influencerSeq || !$requestedBy) {
  710. return $this->response->setStatusCode(400)->setJSON([
  711. 'success' => false,
  712. 'message' => '필수 파라미터가 누락되었습니다.'
  713. ]);
  714. }
  715. // 기존 해지된 파트너십 확인
  716. $terminatedPartnership = $this->vendorInfluencerModel
  717. ->where('VENDOR_SEQ', $vendorSeq)
  718. ->where('INFLUENCER_SEQ', $influencerSeq)
  719. ->where('STATUS', 'TERMINATED')
  720. ->where('IS_ACT', 'Y')
  721. ->orderBy('REG_DATE', 'DESC')
  722. ->first();
  723. if (!$terminatedPartnership) {
  724. return $this->response->setStatusCode(404)->setJSON([
  725. 'success' => false,
  726. 'message' => '해지된 파트너십 기록을 찾을 수 없습니다.'
  727. ]);
  728. }
  729. // 현재 처리 중인 요청이 있는지 확인
  730. $existingPendingRequest = $this->vendorInfluencerModel
  731. ->where('VENDOR_SEQ', $vendorSeq)
  732. ->where('INFLUENCER_SEQ', $influencerSeq)
  733. ->where('STATUS', 'PENDING')
  734. ->where('IS_ACT', 'Y')
  735. ->first();
  736. if ($existingPendingRequest) {
  737. return $this->response->setStatusCode(409)->setJSON([
  738. 'success' => false,
  739. 'message' => '이미 처리 중인 승인 요청이 있습니다.'
  740. ]);
  741. }
  742. // 재승인 요청 생성
  743. $reapplyData = [
  744. 'VENDOR_SEQ' => $vendorSeq,
  745. 'INFLUENCER_SEQ' => $influencerSeq,
  746. 'REQUEST_TYPE' => 'INFLUENCER_REQUEST',
  747. 'STATUS' => 'PENDING',
  748. 'REQUEST_MESSAGE' => '[재계약 요청] ' . $requestMessage,
  749. 'REQUESTED_BY' => $requestedBy,
  750. 'COMMISSION_RATE' => $terminatedPartnership['COMMISSION_RATE'], // 이전 수수료율 유지
  751. 'SPECIAL_CONDITIONS' => $terminatedPartnership['SPECIAL_CONDITIONS'], // 이전 특별조건 유지
  752. 'EXPIRED_DATE' => date('Y-m-d H:i:s', strtotime('+7 days')),
  753. 'ADD_INFO1' => 'REAPPLY', // 재신청 구분자
  754. 'ADD_INFO2' => $terminatedPartnership['SEQ'], // 이전 파트너십 SEQ 참조
  755. 'ADD_INFO3' => date('Y-m-d H:i:s') // 재신청 일시
  756. ];
  757. $insertId = $this->vendorInfluencerModel->insert($reapplyData);
  758. // 생성된 재승인 요청 정보 조회
  759. $createdReapply = $this->vendorInfluencerModel
  760. ->select('vim.*, v.COMPANY_NAME as vendorName, u.NICK_NAME as influencerName, req_user.NICK_NAME as requestedByName')
  761. ->from('VENDOR_INFLUENCER_MAPPING vim')
  762. ->join('VENDOR_LIST v', 'vim.VENDOR_SEQ = v.SEQ', 'left')
  763. ->join('USER_LIST u', 'vim.INFLUENCER_SEQ = u.SEQ', 'left')
  764. ->join('USER_LIST req_user', 'vim.REQUESTED_BY = req_user.SEQ', 'left')
  765. ->where('vim.SEQ', $insertId)
  766. ->get()
  767. ->getRowArray();
  768. return $this->response->setJSON([
  769. 'success' => true,
  770. 'message' => '재승인 요청이 성공적으로 생성되었습니다.',
  771. 'data' => [
  772. 'reapplyRequest' => $createdReapply,
  773. 'previousPartnership' => $terminatedPartnership
  774. ]
  775. ]);
  776. } catch (\Exception $e) {
  777. return $this->response->setStatusCode(500)->setJSON([
  778. 'success' => false,
  779. 'message' => '재승인 요청 생성 중 오류가 발생했습니다.',
  780. 'error' => ENVIRONMENT === 'development' ? $e->getMessage() : null
  781. ]);
  782. }
  783. }
  784. }