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

Component (2)

Component/Order/OrderNew.php+8-4

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

	$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' => $this->orderNo], is_array($result) ? $result : []));
	}
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData['orderGoodsNos']]);

	$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 : []));
	}
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';

	$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);
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';

	$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);

	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';
	$request = \App::getInstance('request');
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $this->orderNo, 'orderGoodsNos' => $mqData['orderGoodsNos'], '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' => $this->orderNo], is_array($result) ? $result : []));
	}
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';
	$request = \App::getInstance('request');
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData['orderGoodsNos'], '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 : []));
	}
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $this->orderNo, 'orderGoodsNos' => $mqData['orderGoodsNos']]);
	$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' => $this->orderNo], is_array($result) ? $result : []));
	}

	unset($mqData);
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData['orderGoodsNos']]);
	$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

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

	$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' => $this->orderNo], is_array($result) ? $result : []));
	}
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData['orderGoodsNos']]);

	$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 : []));
	}
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';

	$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);
	unset($arrOrderGoodsSno['mq']);
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';

	$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);

	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';
	$request = \App::getInstance('request');
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $this->orderNo, 'orderGoodsNos' => $mqData['orderGoodsNos'], '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' => $this->orderNo], is_array($result) ? $result : []));
	}
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';
	$request = \App::getInstance('request');
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData['orderGoodsNos'], '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 : []));
	}
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $this->orderNo, 'orderGoodsNos' => $mqData['orderGoodsNos']]);
	$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' => $this->orderNo], is_array($result) ? $result : []));
	}
	unset($mqData);
	unset($arrOrderGoodsSno['mq']);
	// 주문카운트 대상이 있을 때만 발행 (없으면 orderGoodsNos null 메시지 방지)
	if (!empty($mqData['orderGoodsNos'])) {
	$mqData['mode'] = 'standardOrder';
	\Logger::channel('kafka')->info('process sendMQ - payload :', ['topic' => $kafka::TOPIC_PRODUCT_ORDER_COUNT, 'orderNo' => $orderNo, 'orderGoodsNos' => $mqData['orderGoodsNos']]);
	$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);