본문으로 건너뛰기

주문 카운트 토픽 발행 안정성 강화

PHP 8 · GODO25
변경 파일 수: 2개
변경 파일 목록
총 2개
변경 파일 코드
추가삭제
Component/Order/OrderNew.php+10-4
변경 전OrderNew.php
}
 
$kafka = new ProducerUtils();
$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();
$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);
 
// 현재 상태 수정 처리
 
변경 후OrderNew.php
}
 
$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);
 
// 현재 상태 수정 처리
 
Component/Order/Order.php+10-4
변경 전Order.php
}
 
$kafka = new ProducerUtils();
$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']);
 
$arrOrderGoodsSno['GoodsSno'] = $arrOrderGoodsSno['sno'];
}
 
$kafka = new ProducerUtils();
$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);
 
// 현재 상태 수정 처리
 
변경 후Order.php
}
 
$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']);
 
$arrOrderGoodsSno['GoodsSno'] = $arrOrderGoodsSno['sno'];
}
 
$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);
 
// 현재 상태 수정 처리