消费者

common/components/rabbitmq/consumer/customConsumer.php

@@ -22,7 +22,7 @@ class customConsumer implements ConsumerInterface
      * ConsumerInterface::MSG_REJECT - 拒绝并从队列中删除消息
      * ConsumerInterface::MSG_REQUEUE - 拒绝并重新入队消息
      */
-    public function execute(AMQPMessage $msg): string
+    public function execute(AMQPMessage $msg)
     {
         try {
             // 反序列化消息体
@@ -72,7 +72,7 @@ class customConsumer implements ConsumerInterface
      * @param array $data 消息数据
      * @return bool 处理结果
      */
-    private function handleCreateCustom(array $data): bool
+    private function handleCreateCustom($data)
     {
         // TODO: 实现客户创建业务逻辑
         // 调用对应的 Service 或 Class 层处理
@@ -85,7 +85,7 @@ class customConsumer implements ConsumerInterface
      * @param array $data 消息数据
      * @return bool 处理结果
      */
-    private function handleUpdateCustom(array $data): bool
+    private function handleUpdateCustom($data)
     {
         // TODO: 实现客户更新业务逻辑
         // 调用对应的 Service 或 Class 层处理
@@ -98,7 +98,7 @@ class customConsumer implements ConsumerInterface
      * @param array $data 消息数据
      * @return bool 处理结果
      */
-    private function handleDeleteCustom(array $data): bool
+    private function handleDeleteCustom($data)
     {
         // TODO: 实现客户删除业务逻辑
         // 调用对应的 Service 或 Class 层处理

common/components/rabbitmq/consumer/notifyConsumer.php

@@ -22,7 +22,7 @@ class notifyConsumer implements ConsumerInterface
      * ConsumerInterface::MSG_REJECT - 拒绝并从队列中删除消息
      * ConsumerInterface::MSG_REQUEUE - 拒绝并重新入队消息
      */
-    public function execute(AMQPMessage $msg): string
+    public function execute(AMQPMessage $msg)
     {
         try {
             // 反序列化消息体
@@ -78,7 +78,7 @@ class notifyConsumer implements ConsumerInterface
      * @param array $data 消息数据，包含 order_id, customer_id 等
      * @return bool 处理结果
      */
-    private function handleNewOrderNotify(array $data): bool
+    private function handleNewOrderNotify($data)
     {
         // TODO: 实现新订单通知业务逻辑
         // 调用对应的 Service 或 Class 层处理
@@ -92,7 +92,7 @@ class notifyConsumer implements ConsumerInterface
      * @param array $data 消息数据，包含 customer_id 等
      * @return bool 处理结果
      */
-    private function handleNewCustomerNotify(array $data): bool
+    private function handleNewCustomerNotify($data)
     {
         // TODO: 实现新客户通知业务逻辑
         // 调用对应的 Service 或 Class 层处理
@@ -106,7 +106,7 @@ class notifyConsumer implements ConsumerInterface
      * @param array $data 消息数据，包含 customer_id, amount, recharge_no 等
      * @return bool 处理结果
      */
-    private function handleCustomerRechargeNotify(array $data): bool
+    private function handleCustomerRechargeNotify($data)
     {
         // TODO: 实现客户充值通知业务逻辑
         // 调用对应的 Service 或 Class 层处理
@@ -120,7 +120,7 @@ class notifyConsumer implements ConsumerInterface
      * @param array $data 消息数据，包含 customer_id, amount, writeoff_no 等
      * @return bool 处理结果
      */
-    private function handleCustomerWriteoffNotify(array $data): bool
+    private function handleCustomerWriteoffNotify($data)
     {
         // TODO: 实现客户销账通知业务逻辑
         // 调用对应的 Service 或 Class 层处理
@@ -134,7 +134,7 @@ class notifyConsumer implements ConsumerInterface
      * @param array $data 消息数据，包含 order_id, status, status_desc 等
      * @return bool 处理结果
      */
-    private function handleDeliveryStatusNotify(array $data): bool
+    private function handleDeliveryStatusNotify($data)
     {
         // TODO: 实现配送状态变更通知业务逻辑
         // 调用对应的 Service 或 Class 层处理

common/components/rabbitmq/consumer/stockConsumer.php

@@ -22,7 +22,7 @@ class stockConsumer implements ConsumerInterface
      * ConsumerInterface::MSG_REJECT - 拒绝并从队列中删除消息
      * ConsumerInterface::MSG_REQUEUE - 拒绝并重新入队消息
      */
-    public function execute(AMQPMessage $msg): string
+    public function execute(AMQPMessage $msg)
     {
         try {
             // 反序列化消息体
@@ -72,7 +72,7 @@ class stockConsumer implements ConsumerInterface
      * @param array $data 消息数据，包含 material_id, quantity 等
      * @return bool 处理结果
      */
-    private function handleAddStock(array $data): bool
+    private function handleAddStock($data)
     {
         // TODO: 实现库存增加业务逻辑
         // 调用对应的 Service 或 Class 层处理
@@ -86,7 +86,7 @@ class stockConsumer implements ConsumerInterface
      * @param array $data 消息数据，包含 material_id, quantity 等
      * @return bool 处理结果
      */
-    private function handleReduceStock(array $data): bool
+    private function handleReduceStock($data)
     {
         // TODO: 实现库存扣减业务逻辑
         // 调用对应的 Service 或 Class 层处理
@@ -100,7 +100,7 @@ class stockConsumer implements ConsumerInterface
      * @param array $data 消息数据，包含 material_id, quantity, type 等
      * @return bool 处理结果
      */
-    private function handleAdjustStock(array $data): bool
+    private function handleAdjustStock($data)
     {
         // TODO: 实现库存调整业务逻辑
         // 调用对应的 Service 或 Class 层处理