변경 파일 목록
총 2개
변경 파일 코드
추가삭제
변경 전OrderNew.php
| $kafka = new ProducerUtils(); | |
| $mqData = []; | |
| $mqData['orderGoodsNos'] = $arrOrderGoodsSno['mq']; | |
| $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($arrOrderGoodsSno['mq']); | |
| $arrOrderGoodsSno['GoodsSno'] = $arrOrderGoodsSno['sno']; | |
| } | |
| $kafka = new ProducerUtils(); | |
| $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); | |
| // 현재 상태 수정 처리 | |
변경 후OrderNew.php
| $kafka = new ProducerUtils(); | |
| $mqData = []; | |
| $mqData['orderGoodsNos'] = $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); | |
| unset($arrOrderGoodsSno['mq']); | |
| $arrOrderGoodsSno['GoodsSno'] = $arrOrderGoodsSno['sno']; | |
| } | |
| $kafka = new ProducerUtils(); | |
| // 주문카운트 대상이 있을 때만 발행 (없으면 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); | |
| // 현재 상태 수정 처리 | |
변경 전Order.php
| $kafka = new ProducerUtils(); | |
| $mqData = []; | |
| $mqData['orderGoodsNos'] = $arrOrderGoodsSno['mq']; | |
| $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($arrOrderGoodsSno['mq']); | |
| $arrOrderGoodsSno['GoodsSno'] = $arrOrderGoodsSno['sno']; | |
| } | |
| $kafka = new ProducerUtils(); | |
| $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); | |
| // 현재 상태 수정 처리 | |
변경 후Order.php
| $kafka = new ProducerUtils(); | |
| $mqData = []; | |
| $mqData['orderGoodsNos'] = $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); | |
| unset($arrOrderGoodsSno['mq']); | |
| $arrOrderGoodsSno['GoodsSno'] = $arrOrderGoodsSno['sno']; | |
| } | |
| $kafka = new ProducerUtils(); | |
| // 주문카운트 대상이 있을 때만 발행 (없으면 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); | |
| // 현재 상태 수정 처리 | |