상품 판매 통계 로그 정확도 개선 소스 변경 비교 | PHP 8 · GODO25

Component (2)

Component/Order/OrderNew.php+8-4

	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($arrOrderGoodsSno['mq'])) {
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $this->orderNo, 'orderGoodsNos' => $arrOrderGoodsSno['mq']]);

	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($arrOrderGoodsSno['mq'], 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $this->orderNo], is_array($result) ? $result : []));
	}
	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($mqData)) {
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData]);

	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($mqData, 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $orderNo], is_array($result) ? $result : []));
	}
	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($arrOrderGoodsSno['mq'])) {

	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($arrOrderGoodsSno['mq'], 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', $result);
	}

	unset($arrOrderGoodsSno['mq']);
	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($mqData)) {

	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($mqData, 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', $result);
	}
	unset($mqData);

	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($arrOrderGoodsSno['mq'])) {
	$request = \App::getInstance('request');
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $this->orderNo, 'orderGoodsNos' => $arrOrderGoodsSno['mq'], 'reqUri' => $request->getRequestUri()]);
	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($arrOrderGoodsSno['mq'], 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $this->orderNo], is_array($result) ? $result : []));
	}
	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($mqData)) {
	$request = \App::getInstance('request');
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData, 'reqUri' => $request->getRequestUri()]);
	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($mqData, 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $orderNo], is_array($result) ? $result : []));
	}
	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($arrOrderGoodsSno['mq'])) {
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $this->orderNo, 'orderGoodsNos' => $arrOrderGoodsSno['mq']]);
	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($arrOrderGoodsSno['mq'], 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $this->orderNo], is_array($result) ? $result : []));
	}

	unset($arrOrderGoodsSno['mq']);
	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($mqData)) {
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData]);
	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($mqData, 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $orderNo], is_array($result) ? $result : []));
	}
	unset($mqData);

Component/Order/Order.php+8-4

	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($arrOrderGoodsSno['mq'])) {
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $this->orderNo, 'orderGoodsNos' => $arrOrderGoodsSno['mq']]);

	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($arrOrderGoodsSno['mq'], 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $this->orderNo], is_array($result) ? $result : []));
	}
	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($mqData)) {
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData]);

	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($mqData, 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $orderNo], is_array($result) ? $result : []));
	}
	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($arrOrderGoodsSno['mq'])) {

	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($arrOrderGoodsSno['mq'], 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', $result);
	}
	unset($arrOrderGoodsSno['mq']);

	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($mqData)) {

	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($mqData, 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', $result);
	}
	unset($mqData);

	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($arrOrderGoodsSno['mq'])) {
	$request = \App::getInstance('request');
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $this->orderNo, 'orderGoodsNos' => $arrOrderGoodsSno['mq'], 'reqUri' => $request->getRequestUri()]);
	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($arrOrderGoodsSno['mq'], 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $this->orderNo], is_array($result) ? $result : []));
	}
	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($mqData)) {
	$request = \App::getInstance('request');
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData, 'reqUri' => $request->getRequestUri()]);
	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($mqData, 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $orderNo], is_array($result) ? $result : []));
	}
	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($arrOrderGoodsSno['mq'])) {
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $this->orderNo, 'orderGoodsNos' => $arrOrderGoodsSno['mq']]);
	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($arrOrderGoodsSno['mq'], 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $this->orderNo], is_array($result) ? $result : []));
	}
	unset($arrOrderGoodsSno['mq']);

	$kafka = new ProducerUtils();
	// 주문카운트 대상이 있을 때만 발행 (없으면 null 메시지 방지)
	if (!empty($mqData)) {
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData]);
	$result = $kafka->send($kafka::TOPIC_PRODUCT_ORDER_COUNT, $kafka->makeData($mqData, 'p'), $kafka::MODE_RESULT_CALLLBACK, true);
	\Logger::channel('kafka')->info('process sendMQ - return :', array_merge(['orderNo' => $orderNo], is_array($result) ? $result : []));
	}
	unset($mqData);